NN2022060801/app/Services/ChatMessageService.php

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

namespace App\Services;

use App\Models\ChatMessageModel;
use App\Models\ConfigModel;

/**
 * 聊天-服务类
 * Class ChatMessageService
 * @package App\Services
 */
class ChatMessageService extends BaseService
{
    // 静态对象
    protected static $instance = null;

    /**
     * 构造函数
     * ChatMessageService constructor.
     */
    public function __construct()
    {
        $this->model = new ChatMessageModel();
    }

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

    /**
     * 绑定用户
     * @param $fd
     * @param $data
     * @return bool
     */
    public function bind($fd, $data)
    {
        $userId = isset($data['from_uid'])? intval($data['from_uid']) : 0;
        if($userId<=0){
            $this->error = '1013';
            return false;
        }

        RedisService::set("chats:bind:{$userId}", ['fd'=> $fd, 'user_id'=> $userId], 86400);
        return true;
    }

    /**
     * 获取列表
     * @param $params
     * @param int $pageSize
     * @return array
     */
    public function getDataList($params, $pageSize = 15)
    {
        $where = ['a.mark' => 1,'a.status'=>1];
        $type = isset($params['type'])? $params['type'] : 1;
        $chatKey = isset($params['chat_key'])? $params['chat_key'] : '';
        $fromUid = isset($params['from_uid'])? $params['from_uid'] : 0;
        $toUid = isset($params['to_uid'])? $params['to_uid'] : 0;
        $orderNo = isset($params['order_no'])? $params['order_no'] : '';
        if($type>0){
            $where['a.type'] = $type;
        }
        if($chatKey){
            $where['a.chat_key'] = $chatKey;
        }
        if($fromUid>0){
            $where['a.from_uid'] = $fromUid;
        }
        if($toUid>0){
            $where['a.to_uid'] = $toUid;
        }
        if($orderNo){
            $where['a.order_no'] = $orderNo;
        }
        $list = $this->model->from('chat_message as a')
            ->leftJoin('member as m', 'm.id', '=', 'a.from_uid')
            ->leftJoin('member as m1', 'm1.id', '=', 'a.to_uid')
            ->where($where)
            ->where(function ($query) use($params){
                $id = isset($params['id'])? $params['id'] : 0;
                if($id>0){
                    $query->where('id','<', $id);
                }
            })
            ->where(function ($query) use($params){
                $userId = isset($params['user_id'])? $params['user_id'] : 0;
                if($userId){
                    $query->where('a.from_uid','=',$userId)->orWhere('a.to_uid','=', $userId);
                }

            })
            ->select(['a.*', 'm.username as from_username','m.avatar as from_avatar','m1.username as to_username','m1.avatar as to_avatar'])
            ->orderBy('a.create_time','desc')
            ->orderBy('a.id','desc')
            ->paginate($pageSize > 0 ? $pageSize : 9999999);
        $list = $list? $list->toArray() :[];
        if($list){
            foreach($list['data'] as &$item){
                $item['from_username_text'] = $item['from_username']? format_account($item['from_username']):'客服';
                $item['to_username_text'] = $item['to_username']? format_account($item['to_username']):'客服';
                $item['message_url'] = $item['message_type']==2? get_image_url($item['message']):'';
                $item['from_avatar'] = $item['from_avatar']? get_image_url($item['from_avatar']):'';
                $item['to_avatar'] = $item['to_avatar']? get_image_url($item['to_avatar']):'';
                $item['time_text'] = $item['create_time']? format_time(strtotime($item['create_time'])):'刚刚';
                $userId = isset($params['user_id'])? $params['user_id'] : 0;
                if($userId == $item['to_uid']){
                    // 已读
                    $this->model->where(['id'=> $item['id']])->update(['is_read'=>1,'update_time'=> time()]);
                }
            }
        }

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

    public function getNewList($params, $pageSize = 15)
    {
        $where = ['a.mark' => 1,'status'=>1];
        $type = isset($params['type'])? $params['type'] : 1;
        $chatKey = isset($params['chat_key'])? $params['chat_key'] : '';
        $fromUid = isset($params['from_uid'])? $params['from_uid'] : 0;
        $toUid = isset($params['to_uid'])? $params['to_uid'] : 0;
        $orderNo = isset($params['order_no'])? $params['order_no'] : '';
        if($type>0){
            $where['a.type'] = $type;
        }
        if($chatKey){
            $where['a.chat_key'] = $chatKey;
        }
        if($fromUid>0){
            $where['a.from_uid'] = $fromUid;
        }
        if($toUid>0){
            $where['a.to_uid'] = $toUid;
        }
        if($orderNo){
            $where['a.order_no'] = $orderNo;
        }
        $list = $this->model->from('chat_message as a')
            ->leftJoin('member as m', 'm.id', '=', 'a.from_uid')
            ->leftJoin('member as m1', 'm1.id', '=', 'a.to_uid')
            ->where($where)
            ->where(function ($query) use($params){
                $userId = isset($params['user_id'])? $params['user_id'] : 0;
                if($userId){
                    $query->where('a.from_uid','=',$userId)->orWhere('a.to_uid','=', $userId);
                }

            })
            ->select(['a.id', 'a.from_uid','a.to_uid','a.type','a.chat_key','a.order_no','a.create_time', 'm.username as from_username','m.avatar as from_avatar','m1.username as to_username','m1.avatar as to_avatar'])
            ->groupBy('a.chat_key')
            ->orderBy('a.create_time','desc')
            ->orderBy('a.id','desc')
            ->paginate($pageSize > 0 ? $pageSize : 9999999);
        $list = $list? $list->toArray() :[];
        if($list){
            foreach($list['data'] as &$item){
                $item['from_username_text'] = $item['from_username']? format_account($item['from_username']):'客服';
                $item['to_username_text'] = $item['to_username']? format_account($item['to_username']):'客服';
                $item['from_avatar'] = $item['from_avatar']? get_image_url($item['from_avatar']):'';
                $item['to_avatar'] = $item['to_avatar']? get_image_url($item['to_avatar']):'';
                $item['time_text'] = $item['create_time']? format_time(strtotime($item['create_time'])):'刚刚';
                $item['info'] = $this->getTempInfo($item['chat_key']);
            }
        }

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

    /**
     * 获取最新的聊天消息
     * @param $chatKey 聊天窗口标识
     * @return array|mixed
     */
    public function getTempInfo($chatKey)
    {
        $cacheKey = "caches:chats:temp:{$chatKey}";
        $info = RedisService::get($cacheKey);
        if($info){
            return $info;
        }

        $info = $this->model->where(['chat_key'=> $cacheKey,'status'=>1,'mark'=>1])
                ->select(['id','message','is_read','message_type','create_time'])
                ->orderBy('create_time','desc')
                ->orderBy('id','desc')
                ->first();
        if($info){
            $info['message_url'] = $info['message_type']==2? get_image_url($info['message']):'';
            $info['time_text'] = $info['create_time']? format_time(strtotime($info['create_time'])):'刚刚';
            RedisService::set($cacheKey, $info, rand(3,5));
        }

        return $info;
    }

    /**
     * 添加或编辑
     * @return array
     */
    public function saveData($data)
    {

        $data = [
            'type'=> isset($data['type'])? $data['type'] : 1,
            'message_type'=> isset($data['message_type'])? $data['message_type'] : 1,
            'from_uid'=> isset($data['from_uid'])? $data['from_uid'] : 1,
            'to_uid'=> isset($data['to_uid'])? $data['to_uid'] : 1,
            'order_no'=> isset($data['order_no'])? $data['order_no'] : '',
            'chat_key'=> getChatKey($data['from_uid'],$data['to_uid']),
            'message'=> isset($data['message'])? $data['message'] : '',
            'create_time'=> time(),
            'update_time'=> time(),
            'is_read'=> 2,
            'status'=> 1,
            'mark'=> 1,
        ];

        return $this->model->insertGetId($data);
    }

    /**
     * 推送保存消息，如订单消息
     * @param $data 消息数据
     * @return int|number
     */
    public function pushMessage($data)
    {
        return $this->model->edit($data);
    }
}