feat: 增加后台消息模板

2023-07-03 10:09:04 +08:00
parent 4e377def8d
commit c23e649d65
7 changed files with 790 additions and 0 deletions
--- a/app/admin/controller/system/AdminNotice.php
+++ b/app/admin/controller/system/AdminNotice.php
@@ -0,0 +1,181 @@
+<?php
+
+declare(strict_types=1);
+// +----------------------------------------------------------------------
+// | swiftAdmin 极速开发框架 [基于ThinkPHP6开发]
+// +----------------------------------------------------------------------
+// | Copyright (c) 2020-2030 http://www.swiftadmin.net
+// +----------------------------------------------------------------------
+// | swiftAdmin.net High Speed Development Framework
+// +----------------------------------------------------------------------
+// | Author: meystack <coolsec@foxmail.com> Apache 2.0 License Code
+// +----------------------------------------------------------------------
+
+namespace app\admin\controller\system;
+
+use app\admin\enums\AdminNoticeEnum;
+use app\admin\service\AdminNoticeService;
+use app\AdminController;
+use app\common\exception\OperateException;
+use app\common\model\system\AdminNotice as AdminNoticeModel;
+use app\common\model\system\Admin as AdminModel;
+use Exception;
+use support\Response;
+use think\db\exception\DataNotFoundException;
+use think\db\exception\DbException;
+use think\db\exception\ModelNotFoundException;
+
+class AdminNotice extends AdminController
+{
+    /**
+     * 消息类型
+     * @var array
+     */
+    public array $msgType = [
+        'notice'  => '通知',
+        'message' => '消息',
+        'todo'    => '待办',
+    ];
+
+    // 初始化函数
+    public function __construct()
+    {
+        parent::__construct();
+        $this->model = new AdminNoticeModel();
+    }
+
+    /**
+     * 获取资源列表
+     * @return Response
+     * @throws Exception
+     */
+    public function index(): Response
+    {
+        if (request()->isAjax()) {
+            list($count, $list) = AdminNoticeService::dataList(get_admin_id());
+            return $this->success('查询成功', null, $list, $count);
+        }
+
+        return view('/system/admin_notice/index', [
+            'msgType' => $this->msgType,
+        ]);
+    }
+
+    /**
+     * 消息模板
+     * @return Response
+     * @throws DataNotFoundException
+     * @throws DbException
+     * @throws ModelNotFoundException
+     */
+    public function bells(): Response
+    {
+        list($count, $list) = AdminNoticeService::bells(get_admin_id());
+        return view('/system/admin_notice/bells', [
+            'list'  => $list,
+            'count' => $count
+        ]);
+    }
+
+    /**
+     * 获取消息列表
+     * @return Response
+     * @throws DbException
+     */
+    public function getBells(): Response
+    {
+        $data = AdminNoticeService::getBells(get_admin_id());
+        return $this->success('获取成功', '/', $data);
+    }
+
+    /**
+     * 阅读消息
+     * @return Response
+     * @throws OperateException
+     */
+    public function read(): Response
+    {
+        $id = request()->get('id', 0);
+        $detail = AdminNoticeService::getDetail($id, get_admin_id());
+        return view('/system/admin_notice/' . $detail['type'], [
+            'detail' => $detail
+        ]);
+    }
+
+    /**
+     * 发送消息
+     * @return Response
+     * @throws DataNotFoundException
+     * @throws DbException
+     * @throws ModelNotFoundException
+     * @throws OperateException
+     */
+    public function add(): Response
+    {
+        if (request()->isPost()) {
+            $post = request()->post();
+            $post['send_id'] = get_admin_id();
+            $post['type'] = AdminNoticeEnum::MESSAGE;
+            $post['send_ip'] = request()->getRealIp();
+            $post['create_time'] = time();
+            validate(\app\common\validate\system\AdminNotice::class)->check($post);
+            AdminNoticeService::add($post);
+            return $this->success('发送成功');
+        }
+
+        return view('/system/admin_notice/add', [
+            'adminList' => AdminModel::select()->toArray(),
+        ]);
+    }
+
+    /**
+     * 清空消息
+     * @return Response
+     * @throws Exception
+     */
+    public function clear(): Response
+    {
+        $type = input('type', AdminNoticeEnum::NOTICE);
+        $where[] = ['type', '=', $type];
+        $where[] = ['admin_id', '=', get_admin_id()];
+        $where[] = ['status', '=', AdminNoticeEnum::STATUS_READ];
+        try {
+            AdminNoticeModel::where($where)->delete();
+        } catch (Exception $e) {
+            return $this->error('清空失败');
+        }
+        return $this->success('清空成功');
+    }
+
+    /**
+     * 全部消息已读
+     * @return Response
+     * @throws Exception
+     */
+    public function readAll(): Response
+    {
+        $type = input('type', AdminNoticeEnum::NOTICE);
+        $where[] = ['type', '=', $type];
+        $where[] = ['admin_id', '=', get_admin_id()];
+        $where[] = ['status', '=', AdminNoticeEnum::STATUS_UNREAD];
+        try {
+            AdminNoticeModel::where($where)->update(['status' => 1]);
+        } catch (Exception $e) {
+            return $this->error('操作失败');
+        }
+
+        return $this->success('全部已读成功');
+    }
+
+    /**
+     * 删除消息
+     * @return Response
+     * @throws OperateException
+     */
+    public function del(): Response
+    {
+        $id = request()->get('id', 0);
+        AdminNoticeService::delete($id, get_admin_id());
+        return $this->success('删除成功');
+    }
+}