直播间列表接口、任务列表接口

app/admin/controller/liveroom/Index.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace app\admin\controller\liveroom;
+
+use app\admin\model\LiveRoom;
+use app\common\controller\AdminController;
+use think\App;
+
+class Index extends AdminController
+{
+
+    public function __construct(App $app)
+    {
+        parent::__construct($app);
+        $this->model = new LiveRoom();
+    }
+
+}

app/admin/controller/liveroom/Task.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace app\admin\controller\liveroom;
+
+use app\common\controller\AdminController;
+use think\App;
+use app\admin\model\Task as TaskModel;
+
+class Task extends AdminController
+{
+
+    public function __construct(App $app)
+    {
+        parent::__construct($app);
+        $this->model = new TaskModel();
+    }
+
+
+}

app/admin/model/Ip.php

@@ -13,7 +13,7 @@ class Ip extends TimeModel
     public static function getPageList($param = [])
     {
         $page  = $param['page'] ?? 1;
-        $limit = $param['$limit'] ?? 10;
+        $limit = $param['limit'] ?? 10;
         $where = [['status', '=', 1]];
         if (isset($param['keyword'])) {
             $where[] = ['ip', 'like', '%'.$param['keyword'].'%'];

app/admin/model/LiveRoom.php

@@ -0,0 +1,27 @@
+<?php
+
+namespace app\admin\model;
+
+use app\common\model\TimeModel;
+
+class LiveRoom extends TimeModel
+{
+    protected $deleteTime = 'delete_time';
+
+    protected $defaultSoftDelete = '0';
+
+    public static function getPageList($param = []): array
+    {
+        $page  = $param['page'] ?? 1;
+        $limit = $param['limit'] ?? 10;
+        $where = [['status', '=', 1]];
+        if (isset($param['keyword'])) {
+            $where[] = ['room_id', 'like', '%'.$param['keyword'].'%'];
+        }
+        $field = 'id, room_id, anchor_information, link, create_time';
+        $order = 'id desc';
+        $count = self::where($where)->count();
+        $list  = self::where($where)->field($field)->order($order)->page($page, $limit)->select();
+        return ['data' => $list, 'count' => $count];
+    }
+}

app/admin/model/Task.php

@@ -10,4 +10,19 @@ class Task extends TimeModel
     protected $deleteTime = 'delete_time';
 
     protected $defaultSoftDelete = '0';
+
+    public static function getPageList($param = []): array
+    {
+        $page  = $param['page'] ?? 1;
+        $limit = $param['limit'] ?? 10;
+        $where = [['status', '=', 1]];
+        if (isset($param['keyword'])) {
+            $where[] = ['uuid', 'like', '%'.$param['keyword'].'%'];
+        }
+        $field = 'id, uuid, integral, duration';
+        $order = 'id desc';
+        $count = self::where($where)->count();
+        $list  = self::where($where)->field($field)->order($order)->page($page, $limit)->select();
+        return ['data' => $list, 'count' => $count];
+    }
 }

app/admin/model/User.php

@@ -18,8 +18,8 @@ class User extends TimeModel
     public static function getPageList($param = [])
     {
         $page  = $param['page'] ?? 1;
-        $limit = $param['$limit'] ?? 10;
-        $where = ['status' => 1];
+        $limit = $param['limit'] ?? 10;
+        $where = [['status', '=', 1]];
         if (isset($param['keyword'])) {
             $where[] = ['nick_name', 'like', '%'.$param['keyword'].'%'];
         }

app/api/controller/LiveRoom.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace app\api\controller;
+use app\admin\model\LiveRoom as LiveRoomModel;
+use think\response\Json;
+
+class LiveRoom extends ApiController
+{
+
+    public function getList(): Json
+    {
+        if (!$this->request->isPost()) {
+            return $this->renderError('不支持GET请求');
+        }
+        $param = $this->request->post();
+        $list = LiveRoomModel::getPageList($param);
+        return $this->renderSuccess(['list' => $list['data'], 'count' => $list['count']]);
+    }
+}

app/api/controller/Task.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace app\api\controller;
+
+use \app\admin\model\Task as TaskModel;
+use think\response\Json;
+
+class Task extends ApiController
+{
+
+    public function getList(): Json
+    {
+        if (!$this->request->isPost()) {
+            return $this->renderError('不支持GET请求');
+        }
+        $param = $this->request->post();
+        $list = TaskModel::getPageList($param);
+        return $this->renderSuccess(['list' => $list['data'], 'count' => $list['count']]);
+    }
+
+}

app/api/middleware/LcJWTAuth.php

@@ -2,6 +2,7 @@
 
 namespace app\api\middleware;
 
+use app\api\model\User;
 use app\api\service\LcJWTService;
 use app\Request;
 
@@ -24,6 +25,8 @@ class LcJWTAuth
             return json(['code' => 401, 'msg' => 'token verification failed']);
         }
 
+        $request->uid = $claims->get('uid');
+        $request->user_info = User::where('uid', $request->uid)->find();
         return $next($request);
     }
-}
+}