zhongshen_project/addon/servicer/api/controller/Chat.php

<?php

/**
 * Niushop商城系统 - 团队十年电商经验汇集巨献!
 * =========================================================
 * Copy right 2019-2029 山西牛酷信息科技有限公司, 保留所有权利。
 * ----------------------------------------------
 * 官方网址: https://www.niushop.com

 * =========================================================
 */

namespace addon\servicer\api\controller;

use addon\servicer\model\Dialogue;
use addon\servicer\model\Member;
use addon\servicer\model\Servicer;
use app\api\controller\BaseApi;
use app\model\goods\Goods;
use app\model\order\Order;
use app\model\shop\Shop;
use app\model\system\Site;
use app\model\upload\Upload;
use Exception;
use GatewayClient\Gateway;
use think\db\exception\DataNotFoundException;
use think\db\exception\DbException;
use think\db\exception\ModelNotFoundException;
use think\facade\Db;
use think\facade\Request;
use think\facade\Config;
use app\model\web\WebSite as WebsiteModel;
use addon\servicer\model\Keyword as KeywordModel;
use addon\servicer\model\Config as ServicerConfig;

/**
 * 客户端客服相关API
 */
class Chat extends BaseApi
{
    /**
     * 构造函数
     */
    public function __construct()
    {
        Config::load(__DIR__ . "/../../config/gateway_client.php");

        // 注册GateWayClient 到 GatewayWorker
        Gateway::$registerAddress = @config()['registeraddress'] ?? '127.0.0.1:1241';

        parent::__construct();
    }

    /**
     * 查找当前是否有客服在线
     * @return false|string
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException
     */
    public function hasServicers()
    {
        $token = $this->checkToken();
        if ($token['code'] < 0) {
            return $this->response($token);
        }

        $site_id = $this->site_id;
        if (empty($site_id)) {
            return $this->response($this->error('没有指定店铺'));
        }

        $result = (new Servicer)->getOnlineServicers($site_id);
        if ($result['code'] != 0) {
            return $this->response($result);
        }

        $list = $result['data'];

        $onlineCount = 0;
        foreach ($list as $item) {
            $online = @Gateway::isUidOnline('ns_servicer_' . $item['user_id']) ?? 0;
            if ($online) {
                $onlineCount += 1;
            }
        }

        return $this->response($this->success(['online_count' => $onlineCount]));
    }

    /**
     * 绑定WebSocket client_id 和 member_id / user_id
     * @return false|string
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException
     */
    public function bind()
    {
        $token = $this->checkToken();
        if ($token['code'] < 0) {
            return $this->response($token);
        }

        $site_id = $this->site_id;
        if (empty($site_id) && $site_id != 0) {
            return $this->response($this->error('', '没有指定商家'));
        }
        $client_id = $this->params['client_id'] ?? '';
        $member_id = $this->member_id;


        if (empty($client_id)) {
            return $this->response($this->error('', '缺少必要的参数'));
        }

        // 检测当前用户是否仍然在线
        $isOnline = Gateway::isOnline($client_id);

        Gateway::bindUid($client_id, $member_id);

        // 获取匹配的客服
        $servicerModel = new Servicer();
        $servicerList = @$servicerModel->getUsefulServicer($site_id, $member_id);
        if (empty($servicerList)) {
                return $this->response($this->error('', '客服不在线'));
        }
        foreach ($servicerList as $item) {
            // ws是否在线
            $online = @Gateway::isUidOnline('ns_servicer_' . $item['user_id']) ?? 0;
            if (!$online) {
                continue;
            }
            $servicer = $item;
            if (!empty($servicer)) {
                break;
            }
        }
        if (empty($servicer)) {
            return $this->response($this->error('', '客服不在线'));
        }
        // 绑定客服
        $memberModel = new Member();

        $id = $memberModel->createMember($member_id, $servicer['user_id'], $isOnline, $client_id);
        if (!$id) {
            return $this->response($this->error('', '客服连接异常'));
        }

        // 向客服通知，有会员咨询
        $member = (new Member)->getMember($member_id, $servicer['user_id'], $this->site_id);
        Gateway::sendToUid(
            'ns_servicer_' . $servicer['user_id'],
            json_encode(['type' => 'connect', 'data' => $member])
        );

        return $this->response($this->success(['servicer_id' => $servicer['user_id']]));
    }

    /**
     * 获取店铺信息
     * @return false|string
     */
    public function siteInfo()
    {
        $token = $this->checkToken();
        if ($token['code'] < 0) {
            return $this->response($token);
        }

        $site_id = $this->site_id;
        if (empty($site_id) && $site_id != 0) {
            return $this->response($this->error('没有指定站点'));
        }

        if ($site_id == 0) {
            $website_model = new WebsiteModel();
            $website_info = $website_model->getWebSite([['site_id', '=', 0]], '*');
            $result['data']['logo'] = $website_info['data']['logo'];
            $result['data']['site_name'] = '平台客服';
        } else {
            $result = (new Site())->getSiteInfo(['site_id' => $site_id, ['site_name', 'logo']]);
        }

        return $this->response($this->success($result));
    }

    /**
     * 订单详情
     * @return array|false|string
     */
    public function orderDetail()
    {
        $token = $this->checkToken();
        if ($token['code'] < 0) {
            return $this->response($token);
        }

        $orderId = $this->params['order_id'] ?? 0;
        $condition = array(
            ['order_id', '=', $orderId]
        );
        $orderDetail = (new Order)->getOrderDetail($condition);
        return $orderDetail;
    }

    /**
     * 商品详情
     * @return array|false|string
     */
    public function goodSkuDetial()
    {
        $token = $this->checkToken();
        if ($token['code'] < 0) {
            return $this->response($token);
        }
        $skuId = $this->params['sku_id'] ?? 0;

        $goodsSkuDetail = (new Goods)->getGoodsSkuInfo(['sku_id' => $skuId]);

        return $goodsSkuDetail;
    }

    /**
     * 发送聊天内容
     * @return false|string
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException
     */
    public function say()
    {
        $token = $this->checkToken();
        if ($token['code'] < 0) return $this->response($token);

        $servicer_id = $this->params['servicer_id'] ?? 0;
        $contentType = $this->params['content_type'] ?? '';
        $message     = $this->params['message'] ?? '';
        $goodsId     = $this->params['goods_id'] ?? 0;
        $orderId     = $this->params['order_id'] ?? 0;
        $relate_data = $this->params['relate_data'] ?? '';


        if (empty($message) && empty($goodsId) && empty($orderId)) {
            return $this->response($this->error('不能发送空消息哦！'));
        }

        try {
            $isServicerOnline = @Gateway::isUidOnline('ns_servicer_' . $servicer_id);
        } catch (Exception $e) {
            $isServicerOnline = false;
        }
        $siteId = 1;
//        $read = $isServicerOnline ? 1 : 0;
        $read = 0;

        // 消息持久化逻辑
        $dialogueModel = new Dialogue();
        $servicerModel = new Servicer();

        // 客服不在线时，不推送
        if (!$isServicerOnline) {
            // 重新匹配的客服
            $servicerList  = $servicerModel->assigning([]);
            $servicer      = [];
            foreach ($servicerList as $item) {
                // ws是否在线
                $online = @Gateway::isUidOnline('ns_servicer_' . $item['user_id']) ?? 0;
                if (!$online) {
                    continue;
                }
                $servicer = $item;
                if (!empty($servicer)) {
                    break;
                }
            }
            if (empty($servicer)) {
                $dialogueModel->createDialogue(0, $this->member_id, 0, $contentType, 0, $siteId, 0, $message, '', $goodsId, $orderId, $relate_data);

                // 关键词回复
                if ($contentType == Dialogue::CONTENTTYPE_STRING) {
                    $keyword_model = new KeywordModel();
                    $keyword_reply = $keyword_model->getContentByKeyword($siteId, strip_tags($message));
                    if (!empty($keyword_reply)) {
                        $keyword_reply = '<p>' . $keyword_reply . '</p>';
                        $dialogueModel = new Dialogue();
                        $dialogueId    = $dialogueModel->createDialogue(1, $this->member_id, 0, $contentType, 0, $siteId, 0, '', $keyword_reply, 0, 0);

                        // 客服信息
                        $servicer_info                = $servicerModel->handleServicerInfo([], $siteId);
                        $servicer_info['servicer_id'] = 0;

                        Gateway::sendToUid(
                            $this->member_id,
                            json_encode(['type' => 'connect', 'data' => $servicer_info])
                        );
                        $keyword_reply_dialogue = array_merge($dialogueModel->getDialogue($dialogueId), $servicer_info);
                        // 转发消息至会员
                        Gateway::sendToUid($this->member_id, json_encode(['type' => Dialogue::contentType($contentType)['type'], 'data' => $keyword_reply_dialogue]));
                    }
                }
                return $this->response($this->success(['read' => $read]));
            }
            // 绑定客服
            $servicer_id = $servicer['user_id'];
            $client_id   = Gateway::getClientIdByUid($this->member_id);
            $memberModel = new Member();
            $id          = $memberModel->createMember($this->member_id, $servicer['user_id'], 1, $client_id);
            if (!$id) {
                return $this->response($this->success(['read' => $read]));
            }
            // 向客服通知，有会员咨询
            $member = (new Member)->getMember($this->member_id, $servicer['user_id'], $this->site_id);
            Gateway::sendToUid(
                'ns_servicer_' . $servicer['user_id'],
                json_encode(['type' => 'connect', 'data' => $member])
            );

            // 客服信息
            $servicer_info                = $servicerModel->handleServicerInfo([['user_id', '=', $servicer['user_id']]], $siteId);
            $servicer_info['servicer_id'] = $servicer['user_id'];

            Gateway::sendToUid(
                $this->member_id,
                json_encode(['type' => 'connect', 'data' => $servicer_info])
            );
        } else {
            // 客服信息
            $servicer_info                = $servicerModel->handleServicerInfo([['user_id', '=', $servicer_id]], $siteId);
            $servicer_info['servicer_id'] = $servicer_id;
        }

        // 消息持久化逻辑
        $dialogueId = $dialogueModel->createDialogue(0, $this->member_id, $servicer_id, $contentType, $read, $siteId, 0, $message, '', $goodsId, $orderId, $relate_data);
        // 获取消息数据
        $dialogue = $dialogueModel->getDialogue($dialogueId);

        $type = Dialogue::contentType($contentType)['type'];

        // 关键词回复
        if ($contentType == Dialogue::CONTENTTYPE_STRING) {
            $keyword_model = new KeywordModel();
            $keyword_reply = $keyword_model->getContentByKeyword($siteId, strip_tags($message));
            if (!empty($keyword_reply)) {
                $keyword_reply          = '<p>' . $keyword_reply . '</p>';
                $dialogueModel          = new Dialogue();
                $dialogue_id            = $dialogueModel->createDialogue(1, $this->member_id, $servicer_id, $contentType, 0, $siteId, $servicer['user_id'] ?? 0, '', $keyword_reply, 0, 0);

                $keyword_reply_dialogue = array_merge($dialogueModel->getDialogue($dialogue_id), $servicer_info);
                // 转发消息至会员
                Gateway::sendToUid($this->member_id, json_encode(['type' => $type, 'data' => $keyword_reply_dialogue]));
            }
        }

        // 发送给所有连接的客服
        $memberModel = new Member();
        $memberList  = $memberModel->getList([['member_id', '=', $this->member_id], ['online', '=', 1]]);
        if (!empty($memberList)) {
            foreach ($memberList as $item) {
                $isServicerOnline = @Gateway::isUidOnline('ns_servicer_' . $item['servicer_id']);
                $isServicerOnline = $isServicerOnline ? 1 : 0;
                if ($isServicerOnline) {
                    // 转发消息至客服·
                    Gateway::sendToUid('ns_servicer_' . $item['servicer_id'], json_encode(['type' => $type, 'data' => $dialogue]));

                    // 关键词自动回复的消息转发到客服端
                    if (isset($keyword_reply_dialogue) && !empty($keyword_reply_dialogue)) {
                        Gateway::sendToUid('ns_servicer_' . $item['servicer_id'], json_encode(['type' => 'keyword_reply', 'data' => $keyword_reply_dialogue]));
                    }
                }
            }
        } else {
            if (!empty($servicer_id)) {
                // 向客服通知，有会员咨询
                $member = (new Member)->getMember($this->member_id, $servicer_id, $this->site_id);
                Gateway::sendToUid(
                    'ns_servicer_' . $servicer_id,
                    json_encode(['type' => 'connect', 'data' => $member])
                );

                // 客服信息
                $servicer_info                = $servicerModel->handleServicerInfo([['user_id', '=', $servicer_id]], $siteId);
                $servicer_info['servicer_id'] = $servicer_id;

                Gateway::sendToUid(
                    $this->member_id,
                    json_encode(['type' => 'connect', 'data' => $servicer_info])
                );
                Gateway::sendToUid('ns_servicer_' . $servicer_id, json_encode(['type' => $type, 'data' => $dialogue]));

                // 关键词自动回复的消息转发到客服端
                if (isset($keyword_reply_dialogue) && !empty($keyword_reply_dialogue)) {
                    Gateway::sendToUid('ns_servicer_' . $servicer_id, json_encode(['type' => 'keyword_reply', 'data' => $keyword_reply_dialogue]));
                }
            }
        }
        return $this->response($this->success(['read' => $read]));
    }

    /**
     * 获取聊天记录表
     * @return false|string
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException
     */
    public function dialogs()
    {
        $token = $this->checkToken();
        if ($token['code'] < 0) {
            return $this->response($token);
        }
        $page = $this->params['page'] ?? 1;
        $limit = $this->params['limit'] ?? 5;
//        $siteId = input('site_id', '');
        $siteId = $this->site_id;
//        $servicer_id = input('servicer_id', 0);
        if (empty($siteId) && $siteId != 0) {
            return $this->response($this->error('没有指定商家'));
        }

        $pagelist = (new Dialogue())->getDialogueList($this->member_id, $page, $limit, $siteId);
        if (!empty($pagelist) && !empty($pagelist['list']) && count($pagelist['list']) > 0) {
            $pagelist['list'] = array_reverse($pagelist['list']);
        }

        return $this->response($this->success($pagelist));
    }

    /**
     * 客户端主动结束会话
     * @return false|string
     * @throws DbException
     */
    public function bye()
    {
        $token = $this->checkToken();
        if ($token['code'] < 0) {
            return $this->response($token);
        }
        $servicer_id = $this->params['servicer_id'] ?? 0;
        if (empty($servicer_id)) {
            return $this->response($this->error('没有指定客服'));
        }

        $member_id = $this->member_id;
        $client_id = Gateway::getClientIdByUid($member_id);

//        if (empty($client_id) || count($client_id) == 0) {
//            return $this->response($this->success($client_id, '会话已结束！'));
//        }

        // 发送给所有连接的客服
        $memberModel = new Member();
        $memberList = $memberModel->getList([['member_id', '=', $this->member_id], ['online', '=', 1]]);
        if (!empty($memberList)) {
            foreach ($memberList as $item) {
                $isServicerOnline = @Gateway::isUidOnline('ns_servicer_' . $item['servicer_id']);
                $isServicerOnline = $isServicerOnline ? 1 : 0;
                if ($isServicerOnline) {
                    // 转发消息至客服·
                    Gateway::sendToUid('ns_servicer_' . $item['servicer_id'], json_encode(['type' => 'disconnect', 'data' => ['member_id' => $member_id]]));
                }
            }
        }

        $memberModel = new Member();
        $memberModel->setMemberOnline($member_id, false);
//        // 关闭WS客户端（会员）
        if(!empty($client_id)){
            Gateway::closeClient($client_id[0], json_encode(['type' => 'close', 'data' => ['status' => true]]));
        }

        return $this->response($this->success('', '会话已结束！'));
    }

    /**
     * 在线信息
     * @return false|string
     */
    public function checkOnline()
    {
        $uidList = Gateway::getAllUidList();
        $clientList = Gateway::getAllClientIdList();
        return json_encode(['code'=>1, 'msg'=>'success', 'data'=>compact('uidList', 'clientList')]);
    }

    /**
     * 在线信息
     * @return false|string
     */
    public function checkClient()
    {
        $client_id = $this->params['client_id'] ?? '';
        $uid = $this->params['uid'] ?? 0;

        $online = 0;
        if (!empty($client_id)) {
            $session = Gateway::getSession($client_id);
            $uid = Gateway::getUidByClientId($client_id);
            $online = @Gateway::isOnline($client_id) ?? 0;
        }
        if (!empty($uid)) {
            $clients = Gateway::getClientIdByUid($uid);
            $client_id = $clients[0];
            $session = Gateway::getSession($client_id);
            $uid = Gateway::getUidByClientId($client_id);
            $online = @Gateway::isUidOnline($uid) ?? 0;
        }
        if (!$online) {
            return json_encode(['code'=>0, 'msg'=>'客服不在线', 'data'=>compact('session', 'uid', 'client_id')]);
        }
        return json_encode(['code'=>1, 'msg'=>'客服在线', 'data'=>compact('session', 'uid', 'client_id')]);
    }
    /**
     * 在线信息
     * @return false|string
     */
    public function sendMsg()
    {
        $client_id = $this->params['client_id'] ?? '';
        $uid = Gateway::getUidByClientId($client_id);
        Gateway::sendToUid(
            $uid,
            json_encode(['type' => 'connect', 'data' => ['servicer_id' => 111]])
        );
        return json_encode(['code'=>1, 'msg'=>'发送成功']);
    }

    /**
     * 客服列表
     * @return false|string
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException
     */
    public function servicerList()
    {
        $token = $this->checkToken();
        if ($token['code'] < 0) {
            return $this->response($token);
        }

        $page = $this->params['page'] ?? '';
        $size = $this->params['size'] ?? PAGE_LIST_ROWS;

        $map = [['sd.member_id', '=', $this->member_id]];
        $field = 'sd.shop_id,sh.logo,sh.site_name';
        $join = [
            ['user u', 'u.uid=sd.member_id', 'left'],
            ['site sh', 'sh.site_id=sd.shop_id', 'left'],
        ];
        $model = new Dialogue();
        $list = $model->getPageList($map, $field, 'sd.create_time desc', $page, $size, 'sd', $join, 'sd.shop_id');

        $shop = array_column($list['list'], 'shop_id');
        if (in_array(0, $shop)) {
            // 查询店铺信息
            $site_model = new Site();
            $site_info = $site_model->getSiteInfo([['site_id', '=', $this->site_id]], '*')['data'] ?? [];
            $key = array_search(0, $shop);
            $list['list'][$key]['logo'] = $site_info['logo'];
            $list['list'][$key]['site_name'] = '平台客服';
        }
        return $this->response($this->success($list));
    }


    /**
     * 客服聊天列表
     * @return false|string
     */
    public function chatList()
    {
        $token = $this->checkToken();
        if ($token['code'] < 0) return $this->response($token);

        $prefix = config('database.connections.mysql.prefix');
        $member_id = $this->member_id;
        // 获取有过聊天记录的客服列表，获取未读消息数量，头像、昵称、在线状态，获取最后一次聊天内容、类型
        $sql = "SELECT * FROM (SELECT sd.id,sd.shop_id,sd.create_time,sd.servicer_say,sd.consumer_say,sd.type,sd.content,sd.content_type,sd.add_time,"
            . "IFNULL(s.site_name, '') as shop_name,IFNULL(s.logo,'') as logo,IFNULL(s.logo,'') as avatar,IFNULL(sr.`online`, 0) as online,"
            . "(SELECT count(sd1.member_id) FROM {$prefix}servicer_dialogue sd1 where sd1.type=1 AND sd1.`read`=0 AND  sd1.shop_id = sd.shop_id AND sd1.member_id={$member_id}) AS unread "
            . "FROM {$prefix}servicer_dialogue sd "
            . "LEFT JOIN {$prefix}site s on s.site_id=sd.shop_id "
            . "LEFT JOIN {$prefix}servicer sr on sr.shop_id=sd.shop_id AND sr.online=1 "
            . "WHERE sd.member_id={$member_id} "
            . "ORDER BY `online` desc,sd.id desc) as part "
            . "GROUP BY shop_id ORDER BY `online` desc,id desc";
        $chat_list = Db::query($sql);

        return $this->response($this->success($chat_list));
    }

    /**
     * 聊天图片上传
     */
    public function chatimg()
    {
        $upload_model = new Upload($this->site_id);
        $param = array(
            "thumb_type" => "",
            "name" => "file",
            "watermark" => 0,
            "cloud" => 1
        );
        $result = $upload_model->setPath("chat_img/" . date("Ymd") . '/')->image($param);
        return $this->response($result);
    }


    /**
     * @return false|string
     */
    public function checkServicer()
    {
        $servicer_id = $this->params['servicer_id'] ?? 0;

        $servicer = (new Servicer)->getDetail([['user_id', '=', $servicer_id]])['data'];

        $online = 0;
        if (!empty($servicer)) {
            $uid = 'ns_servicer_'.$servicer['user_id'];
            $clients   = Gateway::getClientIdByUid($uid);
            if (empty($clients)) return $this->response($this->error('', '客服不在线'));
            $client_id = $clients[0];
            $session   = Gateway::getSession($client_id);
            $uid       = Gateway::getUidByClientId($client_id);
            $online    = @Gateway::isUidOnline($uid) ?? 0;
        }
        if (!$online) {
            return $this->response($this->error(compact('servicer', 'session'), '客服不在线'));
        }
        return $this->response($this->success(compact('servicer', 'session'), '客服在线'));
    }

    /**
     * 消息设为已读
     * @return false|string
     */
    public function setRead()
    {
        $token = $this->checkToken();
        if ($token['code'] < 0) return $this->response($token);

        $site_id = $this->params['site_id'] ?? 0;

        if (empty($site_id)) return $this->response($this->error('没有指定店铺'));

        // 查询后设为已读
        $condition = [
            ['member_id', '=', $this->member_id],
            ['type', '=', 1],
        ];
        (new Dialogue())->setDialoguesRead($condition, true);
        return $this->response($this->success());
    }

    /**
     * 关键词回复设置
     * @return false|string
     */
    public function keyword()
    {
        $condition = [['site_id', '=', $this->site_id], ['is_use', '=', 1]];
        $keyword_model = new KeywordModel();
        $keyword_list = $keyword_model->getPageList($condition, 1, 100, 'sort desc', 'keyword')['data']['list'];

        $servicer_model = new ServicerConfig();
        $config = $servicer_model->getKeywordConfig();
        $is_open = $config['data']['value']['is_open'] ?? 0;

        return $this->response($this->success(compact('is_open', 'keyword_list')));
    }
    
    public function check()
    {
        $client = Gateway::getAllGroupClientIdList();
        $client_count = Gateway::getAllGroupClientIdCount();
        $group_uid = Gateway::getAllGroupUidList();
        $group_id = Gateway::getAllGroupIdList();
        return json(compact('client', 'client_count', 'group_uid', 'group_id'));
    }

    public function test()
    {
        $order_id = request()->param('order_id');

        $result = ( new Order )->getOrderDetail($order_id);
        return json($result);
    }
}