NN2026031605/app/Services/Api/MessageService.php

<?php
// +----------------------------------------------------------------------
// | LARAVEL8.0 框架 [ LARAVEL ][ RXThinkCMF ]
// +----------------------------------------------------------------------
// | 版权所有 2017~2021 LARAVEL研发中心
// +----------------------------------------------------------------------
// | 官方网站: http://www.laravel.cn
// +----------------------------------------------------------------------
// | Author: laravel开发员 <laravel.qq.com>
// +----------------------------------------------------------------------

namespace App\Services\Api;

use App\Models\MessageModel;
use App\Services\BaseService;
use App\Services\ConfigService;
use App\Services\RedisService;

/**
 * 消息服务-服务类
 * @author laravel开发员
 * @since 2020/11/11
 * @package App\Services\Api
 */
class MessageService extends BaseService
{
    // 静态对象
    protected static $instance = null;

    /**
     * 构造函数
     * @author laravel开发员
     * @since 2020/11/11
     * NoticeService constructor.
     */
    public function __construct()
    {
        $this->model = new MessageModel();
    }

    /**
     * 静态入口
     */
    public static function make()
    {
        if (!self::$instance) {
            self::$instance = new static();
        }
        return self::$instance;
    }

    /**
     * @param $params
     * @param int $pageSize
     * @return array
     */
    public function getDataList($params, $pageSize = 20)
    {
        $query = $this->getQuery($params);
        $list = $query->select(['a.*'])
            ->orderBy('a.create_time','desc')
            ->paginate($pageSize > 0 ? $pageSize : 9999999);
        $list = $list? $list->toArray() :[];
        if($list){
            foreach($list['data'] as &$item){
                $item['create_time'] = $item['create_time']? datetime($item['create_time'],'Y-m-d H.i.s') : '';
                $item['time_text'] = $item['create_time']? dateFormat($item['create_time']) : '';
                $msgType = $item['msg_type']? $item['msg_type'] : 1;
                if($msgType == 1 || $msgType == 3){
                    $item['content'] = format_message($item['content']);
                }else if($msgType==2){
                    $item['content'] = $item['content']? get_image_url($item['content']) : '';
                }else if($msgType == 4){
                    $item['content'] = $item['content']? json_decode($item['content'], true) : [];
                }

                if(isset($item['from_user']) && $item['from_user']){
                    $item['from_user_name'] = $item['from_user']['realname']? $item['from_user']['realname'] : '用户'.$item['from_uid'];
                    $item['from_user_avatar'] = $item['from_user']['avatar']? get_image_url($item['from_user']['avatar']) : get_image_url('/images/member/logo.png');
                }else if($item['from_uid'] <=1){
                    $item['from_user_name'] = '客服';
                    $item['from_user_avatar'] = get_image_url('/images/member/custom.png');
                }

                if(isset($item['to_user']) && $item['to_user']){
                    $item['to_user_name'] = $item['to_user']['realname']? $item['to_user']['realname'] : '用户'.$item['to_uid'];
                    $item['to_user_avatar'] = $item['to_user']['avatar']? get_image_url($item['to_user']['avatar']) : get_image_url('/images/member/logo.png');
                }else if($item['to_uid'] <=1){
                    $item['to_user_name'] = '客服';
                    $item['to_user_avatar'] = get_image_url('/images/member/custom.png');
                }
            }

            if(count($list['data'])) {
                $this->model->where(['chat_key' => $list['data'][0]['chat_key'], 'is_read' => 2, 'mark' => 1])->where('id', '<=', $list['data'][0]['id'])->update(['is_read' => 1, 'update_time' => time()]);
                RedisService::keyDel("caches:messages:unread_count*");
            }
        }

        return [
            'pageSize'=> $pageSize,
            'total'=>isset($list['total'])? $list['total'] : 0,
            'list'=> isset($list['data'])? array_reverse($list['data']) : []
        ];
    }

    /**
     * 查询
     * @param $params
     * @return mixed
     */
    public function getQuery($params)
    {
        $where = ['a.mark' => 1];
        $status = isset($params['status'])? $params['status'] : 0;
        $type = isset($params['type'])? $params['type'] : 0;
        if($status>0){
            $where['a.status'] = $status;
        }
        if($type>0){
            $where['a.type'] = $type;
        }

        return $this->model->with(['fromUser','toUser'])->from('message as a')
            ->where($where)
            ->where(function ($query) use($params){
                $keyword = isset($params['keyword'])? $params['keyword'] : '';
                if($keyword){
                    $query->where('a.title','like',"%{$keyword}%");
                }


                $fromUserId= isset($params['from_uid'])? intval($params['from_uid']) : 0;
                if($fromUserId>0){
                    $query->where('a.from_uid', $fromUserId);
                }

                $toUserId= isset($params['to_uid'])? intval($params['to_uid']) : 0;
                if($fromUserId>0){
                    $query->where('a.to_uid', $toUserId);
                }

                $isRead= isset($params['is_read'])? intval($params['is_read']) : 0;
                if($isRead>0){
                    $query->where('a.is_read', $isRead);
                }

            }) ->where(function ($query) use($params){
                $userId = isset($params['user_id'])? intval($params['user_id']) : 0;
                if($userId>0){
                    $query->where('a.from_uid',$userId)->orWhere('a.to_uid', $userId);
                }
            });
    }

    /**
     * 消息分类数据
     * @param $userId
     * @return array|array[]|mixed
     */
    public function getIndexList($userId)
    {
        $cacheKey = "caches:message:index_{$userId}";
        $datas = RedisService::get($cacheKey);
        if($datas){
            return $datas;
        }

        $datas  = [
            6=>['id'=>6,'code'=>'trade','title'=>'交易通知','count'=>0],
            5=>['id'=>5,'code'=>'activity','title'=>'活动通知','count'=>0],
            4=>['id'=>4,'code'=>'love','title'=>'互动通知','count'=>0],
            2=>['id'=>2,'code'=>'notice','title'=>'系统消息','count'=>0],
            1=>['id'=>1,'code'=>'custom','title'=>'客服消息','count'=>0],
            3=>['id'=>3,'code'=>'service','title'=>'服务通知','count'=>0],
        ];

        $counts = $this->model->where(['to_uid'=>$userId,'status'=>1,'mark'=>1])
            ->selectRaw('count(id) as count,type')
            ->groupBy('type')
            ->get();
        $counts = $counts?$counts->toArray() :[];
        if($counts){
            foreach ($counts as $item){
                $type = isset($item['type'])?$item['type']:0;
                if(isset($datas[$type])){
                    $datas[$type]['count'] = isset($item['count'])?$item['count']:0;
                }
            }
        }

        $datas = array_values($datas);
        RedisService::set($cacheKey, $datas, rand(10,20));
        return $datas;
    }

    /**
     * 设置全部已读
     * @param $id
     * @param $userId
     * @return bool
     */
    public function readAll($userId)
    {
        $this->model->where(['to_id'=>$userId])->update(['is_read'=>1,'update_time'=>time()]);
        $this->error = '设置成功';
        return true;
    }

    /**
     * 消息推送处理
     * @param $userId 用户
     * @param $msgData 消息数据
     * @return bool
     */
    public function pushMessage($userId, $msgData)
    {
        try {
            $msgData = [
                'title' => isset($msgData['title'])?$msgData['title'] : '',
                'from_uid' => isset($msgData['from_uid']) && $msgData['from_uid']?$msgData['from_uid'] : 0,
                'to_uid' => $userId,
                'type' => isset($msgData['type'])?$msgData['type'] : 1,
                'msg_type' => isset($msgData['msg_type'])?$msgData['msg_type'] : 1,
                'description' => isset($msgData['description'])?$msgData['description'] : '',
                'content' => isset($msgData['content'])?json_encode($msgData['content'],256) : '',
                'order_no' => isset($msgData['order_no'])?$msgData['order_no'] : '',
                'chat_key' => getChatKey(0,$userId),
                'create_time' => time(),
                'update_time' => time(),
                'is_read' => 2,
                'status' => 1
            ];
            if(!$id = $this->model->insertGetId($msgData)){
                $this->error = '消息推送失败';
                return false;
            }

            $this->error = '消息推送成功';
            return $id;
        } catch (\Exception $exception){
            $this->error = '消息推送失败：'.$exception->getMessage();
            return false;
        }
    }

    /**
     * 未读通知消息
     * @param $type
     * @return array|mixed
     */
    public function getUnreadCount($userId)
    {
        $cacheKey = "caches:messages:unread_count_{$userId}";
        $count = RedisService::get($cacheKey);
        if($count){
            return $count;
        }

        $count = $this->model->where(function($query) use($userId){
            if($userId){
                $query->where('to_uid',$userId);
            }
        })->where(['is_read'=>2,'type'=>1,'status'=>1,'mark'=>1])
        ->count('id');

        if($count){
            RedisService::set($cacheKey, $count, rand(300,600));
        }
        return $count;
    }

    /**
     * 验证是否有敏感词
     * @param $message
     * @return bool
     */
    public function checkMessage($message)
    {
        $chatSensitive = ConfigService::make()->getConfigByCode('chat_sensitive','');
        $chatSensitiveList = $chatSensitive? explode('、', $chatSensitive) : [];
        if(empty($chatSensitiveList)){
            return $message;
        }

        $pattern = '/\b(' . implode('|', array_map('preg_quote', $chatSensitiveList)) . ')\b/iu';
        $result =  preg_replace($pattern, '***', $message);
        return !preg_match("/^\*+$/",$result)? $result : '';
    }
}