直播间管理

1 year ago · d097ed3afe
8 changed files with 323 additions and 4 deletions
--- a/app/admin/controller/liveroom/Index.php
+++ b/app/admin/controller/liveroom/Index.php
@ -3,8 +3,10 @@
 namespace app\admin\controller\liveroom;

 use app\admin\model\LiveRoom;
+use app\admin\validate\LiveRoomValidate;
 use app\common\controller\AdminController;
 use think\App;
+use think\exception\ValidateException;

 class Index extends AdminController
 {
@ -15,4 +17,129 @@ class Index extends AdminController
        $this->model = new LiveRoom();
    }

+    public function index()
+    {
+        if ($this->request->isAjax()) {
+            if (input('selectFields')) {
+                return $this->selectList();
+            }
+            list($page, $limit, $where) = $this->buildTableParames();
+            $count = $this->model
+                ->where($where)
+                ->count();
+            $list  = $this->model
+                ->withoutField('update_time, delete_time')
+                ->where($where)
+                ->page($page, $limit)
+                ->order('id')
+                ->select()
+                ->each(function ($item) {
+
+                    return $item;
+                });
+            $data  = [
+                'code'  => 0,
+                'msg'   => '',
+                'count' => $count,
+                'data'  => $list
+            ];
+            return json($data);
+        }
+        return $this->fetch();
+    }
+
+    /**
+     * @NodeAnotation(title="添加")
+     */
+    public function add()
+    {
+        if ($this->request->isPost()) {
+            $post = $this->request->post();
+            try {
+                validate(LiveRoomValidate::class)->scene('add')->check($post);
+                $exists = LiveRoomValidate::existsRoomId($post['room_id']);
+                if ($exists !== true) throw new ValidateException($exists);
+                $save                = $this->model->save($post);
+            } catch (ValidateException $e) {
+                $this->error($e->getMessage());
+            } catch (\Exception $e) {
+                $this->error('保存失败');
+            }
+            $save ? $this->success('保存成功') : $this->error('保存失败');
+        }
+        return $this->fetch();
+    }
+
+    /**
+     * @NodeAnotation(title="编辑")
+     */
+    public function edit($id)
+    {
+        $row = $this->model->find($id);
+        empty($row) && $this->error('数据不存在');
+        if ($this->request->isPost()) {
+            $post = $this->request->post();
+            try {
+                validate(LiveRoomValidate::class)->scene('add')->check($post);
+                $exists = LiveRoomValidate::existsRoomId($post['room_id'], $id);
+                if ($exists !== true) throw new ValidateException($exists);
+                $save = $row->save($post);
+            } catch (ValidateException $e) {
+                $this->error($e->getMessage());
+            } catch (\Exception $e) {
+                $this->error('保存失败');
+            }
+            $save ? $this->success('保存成功') : $this->error('保存失败');
+        }
+        $this->assign('row', $row);
+        return $this->fetch();
+    }
+
+    /**
+     * @NodeAnotation(title="删除")
+     */
+    public function delete($id)
+    {
+        $this->checkPostRequest();
+        $row = $this->model->whereIn('id', $id)->select();
+        $row->isEmpty() && $this->error('数据不存在');
+        try {
+            $save = false;
+            foreach ($row as $value) {
+                $save = $this->model->where('id', $value['id'])->useSoftDelete('delete_time', time())->delete();
+            }
+        } catch (\Exception $e) {
+            $this->error('删除失败');
+        }
+        $save ? $this->success('删除成功') : $this->error('删除失败');
+    }
+
+    /**
+     * @NodeAnotation(title="属性修改")
+     */
+    public function modify()
+    {
+        $this->checkPostRequest();
+        $post = $this->request->post();
+        $rule = [
+            'id|ID'    => 'require',
+            'field|字段' => 'require',
+            'value|值'  => 'require',
+        ];
+        $this->validate($post, $rule);
+        if (!in_array($post['field'], $this->allowModifyFields)) {
+            $this->error('该字段不允许修改：' . $post['field']);
+        }
+        $row = $this->model->find($post['id']);
+        empty($row) && $this->error('数据不存在');
+        try {
+            $row->save([
+                $post['field'] => $post['value'],
+            ]);
+        } catch (\Exception $e) {
+            $this->error($e->getMessage());
+        }
+        $this->success('保存成功');
+    }
+
 }
--- a/app/admin/validate/IpValidate.php
+++ b/app/admin/validate/IpValidate.php
@ -37,7 +37,7 @@ class IpValidate extends Validate
    {
        $IpModel = new IpModel();
        $where = [['ip', '=', $ip], ['port', '=', $port]];
-        if ($id > 0) $where[] = ['id', '!=', $id];
+        if ($id > 0) $where[] = ['id', '<>', $id];
        try {
            $existsRes = $IpModel->where($where)->find();
            return $existsRes ? 'IP及端口已存在' : true;
--- a/app/admin/validate/LiveRoomValidate.php
+++ b/app/admin/validate/LiveRoomValidate.php
@ -0,0 +1,42 @@
+<?php
+
+namespace app\admin\validate;
+
+use app\admin\model\LiveRoom;
+use think\Validate;
+
+class LiveRoomValidate extends Validate
+{
+
+
+    protected $rule = [
+        'id|编号'                   => 'require|number',
+        'room_id|房间号'             => 'require|alphaNum|max:50',
+        'anchor_information|主播信息' => 'require',
+        'link|直播间链接'              => 'require|checkLink',
+        'status|状态'               => 'require|in:0,1',
+    ];
+
+    protected $message = [];
+
+    protected $scene= [
+        'add'  => ['room_id', 'anchor_information', 'link', 'status'],
+        'edit' => ['id', 'room_id', 'anchor_information', 'link', 'status']
+    ];
+
+    protected function checkLink($value, $rule, $data=[])
+    {
+        if (strpos($value, 'http://') !== 0 && strpos($value, 'https://') !== 0) {
+            return '直播间链接填写错误';
+        }
+        return true;
+    }
+
+    public static function existsRoomId($room_id, $id = 0)
+    {
+        $where = [['room_id', "=", $room_id]];
+        if ($id > 0) $where[] = ['id', '<>', $id];
+        $res = LiveRoom::where($where)->find();
+        return !$res ? true : '房间号已存在';
+    }
+}
--- a/app/admin/view/liveroom/index/add.html
+++ b/app/admin/view/liveroom/index/add.html
@ -0,0 +1,43 @@
+<div class="layuimini-container">
+    <form id="app-form" class="layui-form layuimini-form">
+
+        <div class="layui-form-item">
+            <label class="layui-form-label required">房间号</label>
+            <div class="layui-input-block">
+                <input type="text" name="room_id" class="layui-input" lay-verify="required" lay-reqtext="请输入房间号" placeholder="请输入房间号" value="">
+                <tip>填写房间号。</tip>
+            </div>
+        </div>
+
+        <div class="layui-form-item">
+            <label class="layui-form-label required">主播信息</label>
+            <div class="layui-input-block">
+                <textarea name="anchor_information" lay-verify="required" lay-reqtext="请输入主播信息" placeholder="请输入主播信息" class="layui-textarea"></textarea>
+                <tip>填写主播信息。</tip>
+            </div>
+        </div>
+
+        <div class="layui-form-item">
+            <label class="layui-form-label required">直播间链接</label>
+            <div class="layui-input-block">
+                <input type="text" name="link" class="layui-input" lay-verify="required" lay-reqtext="请输入直播间链接" placeholder="请输入直播间链接" value="">
+                <tip>填写直播间链接。</tip>
+            </div>
+        </div>
+
+        <div class="layui-form-item">
+            <label class="layui-form-label required">状态</label>
+            <div class="layui-input-block">
+                <input type="radio" name="status" value="1" title="启用" checked>
+                <input type="radio" name="status" value="0" title="禁用">
+            </div>
+        </div>
+
+        <div class="hr-line"></div>
+        <div class="layui-form-item text-center">
+            <button type="submit" class="layui-btn layui-btn-normal layui-btn-sm" lay-submit>确认</button>
+            <button type="reset" class="layui-btn layui-btn-primary layui-btn-sm">重置</button>
+        </div>
+
+    </form>
+</div>
--- a/app/admin/view/liveroom/index/edit.html
+++ b/app/admin/view/liveroom/index/edit.html
@ -0,0 +1,43 @@
+<div class="layuimini-container">
+    <form id="app-form" class="layui-form layuimini-form">
+
+        <div class="layui-form-item">
+            <label class="layui-form-label required">房间号</label>
+            <div class="layui-input-block">
+                <input type="text" name="room_id" class="layui-input" lay-verify="required" lay-reqtext="请输入房间号" placeholder="请输入房间号" value="{$row.room_id|default=''}">
+                <tip>填写房间号。</tip>
+            </div>
+        </div>
+
+        <div class="layui-form-item">
+            <label class="layui-form-label required">主播信息</label>
+            <div class="layui-input-block">
+                <textarea name="anchor_information" lay-verify="required" lay-reqtext="请输入主播信息" placeholder="请输入主播信息" class="layui-textarea">{$row.anchor_information|default=''}</textarea>
+                <tip>填写主播信息。</tip>
+            </div>
+        </div>
+
+        <div class="layui-form-item">
+            <label class="layui-form-label required">直播间链接</label>
+            <div class="layui-input-block">
+                <input type="text" name="link" class="layui-input" lay-verify="required" lay-reqtext="请输入直播间链接" placeholder="请输入直播间链接" value="{$row.link|default=''}">
+                <tip>填写直播间链接。</tip>
+            </div>
+        </div>
+
+        <div class="layui-form-item">
+            <label class="layui-form-label required">状态</label>
+            <div class="layui-input-block">
+                <input type="radio" name="status" value="1" title="启用" {if $row.status == 1}checked{/if}>
+                <input type="radio" name="status" value="0" title="禁用" {if $row.status == 0}checked{/if}>
+            </div>
+        </div>
+
+        <div class="hr-line"></div>
+        <div class="layui-form-item text-center">
+            <button type="submit" class="layui-btn layui-btn-normal layui-btn-sm" lay-submit>确认</button>
+            <button type="reset" class="layui-btn layui-btn-primary layui-btn-sm">重置</button>
+        </div>
+
+    </form>
+</div>
--- a/app/admin/view/liveroom/index/index.html
+++ b/app/admin/view/liveroom/index/index.html
@ -0,0 +1,10 @@
+<div class="layuimini-container">
+    <div class="layuimini-main">
+        <table id="currentTable" class="layui-table layui-hide"
+               data-auth-add="{:auth('liveroom.index/add')}"
+               data-auth-edit="{:auth('liveroom.index/edit')}"
+               data-auth-delete="{:auth('liveroom.index/delete')}"
+               lay-filter="currentTable">
+        </table>
+    </div>
+</div>
--- a/public/static/admin/js/liveroom/index.js
+++ b/public/static/admin/js/liveroom/index.js
@ -0,0 +1,54 @@
+define(["jquery", "easy-admin"], function ($, ea) {
+
+    var init = {
+        table_elem: '#currentTable',
+        table_render_id: 'currentTableRenderId',
+        index_url: 'liveroom.index/index',
+        add_url: 'liveroom.index/add',
+        edit_url: 'liveroom.index/edit',
+        delete_url: 'liveroom.index/delete',
+        modify_url: 'liveroom.index/modify',
+    };
+
+    var Controller = {
+
+        index: function () {
+
+            ea.table.render({
+                init: init,
+                toolbar: [
+                    'refresh',
+                    'add',
+                    'delete'
+                ],
+                cols: [[
+                    {type: "checkbox"},
+                    {field: 'id', width: 80, title: '编号'},
+                    {field: 'room_id', minWidth: 80, title: '房间号'},
+                    {field: 'anchor_information', minWidth: 80, title: '主播信息'},
+                    {field: 'link', minWidth: 80, title: '直播间链接'},
+                    {field: 'status', title: '状态', width: 100, search: 'select', selectList: {0: '禁用', 1: '启用'}, templet: ea.table.switch},
+                    {field: 'create_time', minWidth: 80, title: '创建时间', search: 'range'},
+                    {
+                        width: 250,
+                        title: '操作',
+                        templet: ea.table.tool,
+                        operat: [
+                            'edit',
+                            'delete'
+                        ]
+                    }
+                ]],
+            });
+
+            ea.listen();
+        },
+        add: function () {
+            ea.listen();
+        },
+        edit: function () {
+            ea.listen();
+        }
+    };
+    return Controller;
+});
--- a/public/static/admin/js/user/ip.js
+++ b/public/static/admin/js/user/ip.js
@ -35,11 +35,11 @@ define(["jquery", "easy-admin"], function ($, ea) {
                    {type: "checkbox"},
                    {field: 'id', width: 80, title: '编号'},
                    {field: 'ip', minWidth: 80, title: 'IP'},
-                    {field: 'port', minWidth: 80, title: '端口'},
-                    {field: 'city', minWidth: 80, title: '城市'},
+                    {field: 'port', width: 80, title: '端口'},
+                    {field: 'city', width: 100, title: '城市'},
                    {field: 'isp', minWidth: 80, title: '运营商'},
                    {field: 'out_ip', minWidth: 80, title: '退出IP'},
-                    {field: 'expire_time', minWidth: 80, title: '到期时间'},
+                    {field: 'expire_time', width: 200, title: '到期时间'},
                    {field: 'status', title: '状态', width: 100, search: 'select', selectList: {0: '禁用', 1: '启用'}, templet: ea.table.switch},
                    {field: 'create_time', minWidth: 80, title: '创建时间', search: 'range'},
                    {