duanju_manage/modules/System/Services/Notice/NoticesService.php

<?php
/**
 * ${CARET}
 * @file:NoitceService.php
 * @Created by gnitif
 * @Date: 2023/3/27
 * @Time: 11:54
 */


namespace Modules\System\Services\Notice;

use Catch\Exceptions\FailedException;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\DB;
use Modules\System\Models\Notices;
use Modules\System\Models\UserNotice;
use Modules\Permissions\Models\Roles;
use Modules\User\Models\User;
use PharIo\Manifest\Author;

class NoticesService
{

    protected static function getModel()
    {
        return new Notices();
    }

    /**
     *  添加通知
     * name: addNotice
     * @param array $param
     *  $param = [
     *      'title' => '测试', // 通知标题
     *      'notice_type_id' =>  2, // 通知分类id
     *      'type' => '2', // 通知人群 1全部 2，指定人,3指定角色
     *      'notice_obj' => [['id' =>  1,'name' => "超管"]] , // 通知对象
     *      'is_popup' => '1', // 是否是弹窗 1弹窗  0 普通
     *       'content' => '312312', // 通知内容
     * ];
     *
     * date 2023/03/29 14:25
     */
    public static function addNotice(array $param)
    {

        if ($param['type'] != 1 && (!isset($param['notice_obj']) || empty($param['notice_obj']))) {
            throw new FailedException('通知对象不能为空！');
        }

        if ($param['type'] == 3) {
            $roleIds = array_column($param['notice_obj'], 'id');
            $userIds = DB::table('user_has_roles')->whereIn('role_id', $roleIds)->pluck('user_id')->toArray();
        } else if ($param['type'] == 2) {
            $userIds = array_column($param['notice_obj'], 'id');
        } else {
            $userIds = User::pluck('id')->toArray();
            $param['notice_obj'] = [];
        }
        $param['user_ids'] = $userIds;
        return self::getModel()->storeBy($param);
    }

    public static function delete($id)
    {
        return self::getModel()->updateBy($id, ['is_deleted' => 1, 'deleted_at' => get_date()]);
    }

    /**
     *  获取通知详情
     * name: getDetail
     * @param $id
     * @return \Illuminate\Database\Eloquent\Collection|\Illuminate\Support\Collection|Notices[]
     * date 2023/03/29 15:12
     */
    public static function getDetail($id)
    {
        $info = Notices::leftJoin('notice_types', 'notice_types.id', 'notices.notice_type_id')
            ->select('notices.*', 'notice_types.name as notice_type_name')->where('notices.id', $id)->first();
        return $info;
    }

    /**
     *  更新
     * name: update
     * @param $id
     * @param array $param
     * date 2023/03/29 18:32
     */
    public static function update($id, array $param)
    {
       return  self::getModel()->updateBy($id, $param);
    }

    /**
     *  管理员操作通知列表
     * name: list
     * @return mixed
     * date 2023/03/29 22:49
     */
    public static function  list()
    {
        $list = self::getModel()->setBeforeGetList(function ($query) {
            return $query->where('is_deleted', 0)->orderBy('created_at','desc');
        })->getList();
        if (!$list->isEmpty()) {
            $cate = NoitceTypeService::list([], true);
            if ($cate->isEmpty()) {
                $cate = [];
            } else {
                $cate = array_column($cate->toArray(), null, 'id');
            }

            foreach ($list as $value) {
                $value->notice_type_txt = $cate[$value->notice_type_id]['name'] ?? "";
                $value->type_txt = $value->type == 1 ? "全部" : ($value->type == 2 ? "指定用户" : "指定角色");
            }
        }
        return $list;
    }

    /**
     * 我的通知
     * name: myNoticesList
     * date 2023/03/29 22:49
     */
    public static function myNoticesList($param = [])
    {
        $type = $param['type'] ?? "";
        $noticeTypeId = $param['notice_type_id'] ?? 0;
        $title = $param['title'] ?? "";
        $pageSize = $param['limit'] ?? 0;
        $pageSize = $pageSize < 1 ? 15 : $pageSize;
        $userId = Auth::guard(getGuardName())->id();
        $where = [
            ['user_notice.is_deleted', '=', 0],
            ['user_notice.user_id', '=', $userId],
            ['notices.is_deleted', '=', 0],
            ['user_notice.is_deleted', '=', 0],
        ];
        if ($type) {
            $where[] = ['notices.type', '=', $type];
        }
        if ($noticeTypeId) {
            $where[] = ['notices.notice_type_id', '=', $noticeTypeId];
        }
        if ($title) {
            $where[] = ['notices.title', 'like', "%" . $title . "%"];
        }

        $list = UserNotice::leftJoin('notices', 'notices.id', "user_notice.notice_id")->where($where)->select('notices.id', 'notices.title', 'notices.is_popup', "user_notice.is_read", 'notices.created_at')
            ->orderBy('notices.created_at', 'desc')->orderBy('sort', 'desc')->paginate($pageSize);
        if (!$list->isEmpty()) {
            foreach ($list as $val) {
                $val->is_read_txt = $val->is_read == 1 ? "已读" : "未读";
            }
        }
        return $list;
    }

    /**
     *  设置已读
     * name: setRead
     * @param $id
     * date 2023/03/29 23:51
     */
    public static function setRead($id)
    {
        $userId = Auth::guard(getGuardName())->id();
        return UserNotice::where('user_id', $userId)->where('notice_id', $id)->update(['is_read' => 1, 'read_at' => get_date()]);
    }

    /**
     *  用户删除
     * name: userDel
     * @param $id
     * date 2023/03/29 23:55
     */
    public static function userDel($id)
    {
        $userId = Auth::guard(getGuardName())->id();
        return UserNotice::where('user_id', $userId)->where('notice_id', $id)->update(['is_deleted' => 1, 'deleted_at' => get_date()]);
    }

    /**
     *  阅读详情
     * name: detail
     * @param $id
     * @return Notices
     * date 2023/03/30 00:09
     */
    public static function detail($id)
    {
        return Notices::where('id', $id)->where('is_deleted', 0)->select('title', 'id', 'is_popup', 'content')->first();
    }

    /**
     *  获取指定对象选择项
     * name: objOption
     * @param $type
     * @param string $name
     * @return array
     * date 2023/03/30 10:23
     */
    public static function objOption($type, $name = ""): mixed
    {
        if ($type == 'user') {
            if ($name) {
                return  User::where("username", 'like', "%" . $name . "%")->without(['roles','jobs'])->select('id','username as name')->get();
            }
            return User::select('id','username as name')->without(['roles','jobs'])->get();
        } else if ($type == "role") {
            if ($name) {
                return Roles::where("role_name", 'like', "%" . $name . "%")->select('id','role_name as name')->get();
            }
            return Roles::select('id','role_name as name')->get();
        }
        return [];
    }

    /**
     *  一条获取弹窗信息
     * name: getPopup
     * @return Model|UserNotice|object|null
     * date 2023/03/30 16:45
     */
    public static function getPopup()
    {
        $where = [
            ['user_notice.is_deleted', '=', 0],
            ['user_notice.user_id', '=',  Auth::guard(getGuardName())->id()],
            ['notices.is_deleted', '=', 0],
            ['notices.is_popup', '=', 1],
            ['user_notice.is_read', '=', 0],
        ];

         $info =  UserNotice::leftJoin('notices', 'notices.id', "user_notice.notice_id")->where($where)->select('notices.id', 'notices.title', 'notices.content')
             ->orderBy('notices.created_at', 'desc')->orderBy('sort', 'desc')->first();
         if (empty($info)){
             return  [];
         }
         return  $info;
    }


}