ff

vendor/GatewayWorker_linux/GatewayWorker/Applications/whisper/Events.php

@@ -245,8 +245,7 @@ class Events
     }
 
 //客服获取自己的用户列表
-    public
-    static function kfusersmaps($kfuid, $clientid)
+    public static function kfusersmaps($kfuid, $clientid)
     {
         $kfuid = self::getkfuid($kfuid);
         if (empty($kfuid)) {
@@ -271,8 +270,7 @@ class Events
     }
 
 //客服信息更新
-    public
-    static function kfupdateinfo($client_id, $message)
+    public static function kfupdateinfo($client_id, $message)
     {
         $kfid = intval(self::getkfid($message['kfuid']));
         $kfuid = self::getkfuid($kfid);
@@ -300,8 +298,7 @@ class Events
     }
 
 //将某个客服踢下线 (只能是管理员连上来的socket才可以操作)
-    public
-    static function tickkf($client_id, $messag)
+    public static function tickkf($client_id, $messag)
     {
 
         $kfuid = self::getkfuid($messag['kfuid']);
@@ -323,8 +320,7 @@ class Events
 
 
 //看一个连接是否来自管理员的
-    public
-    static function isAdmin($client_id)
+    public static function isAdmin($client_id)
     {
         return self::$redis->sismember(self::ADMINLIST, $client_id);
     }
@@ -347,16 +343,14 @@ class Events
 //    }
 
 //更新用户缓存信息
-    public
-    static function updateusercache($client_id, $dataArray)
+    public static function updateusercache($client_id, $dataArray)
     {
         $uid = intval($dataArray['userid']);
         self::getUserInfoCache($uid, 180, 0);
     }
 
 //加入工单群组(未完)
-    public
-    static function joinServiceGroup($client_id, $message)
+    public static function joinServiceGroup($client_id, $message)
     {
         $uid = $message['uid'];
         $serviceLogId = $message['conversationId'];
@@ -376,15 +370,13 @@ class Events
     }
 
 //强制更新缓存信息
-    public
-    static function updatecache($client_id, $dataArray)
+    public static function updatecache($client_id, $dataArray)
     {
         self::upsystemconfig();
     }
 
 //用户取消排队
-    public
-    static function cancelqueue($messageArray)
+    public static function cancelqueue($messageArray)
     {
         $uid = intval($messageArray['uid']);
         if (empty($uid)) {
@@ -407,8 +399,7 @@ class Events
     }
 
 // 弹出评价.
-    public
-    static function getEvaluate($message)
+    public static function getEvaluate($message)
     {
         // 获取当前会话工单.
         $data = json_decode(self::$redis->HGET('SERVICELOG', $message['conversationId']), true);
@@ -425,8 +416,7 @@ class Events
     }
 
 //客服聊天
-    public
-    static function chatMessage($message)
+    public static function chatMessage($message)
     {
         // 获取当前会话工单.
         $data = json_decode(self::$redis->HGET('SERVICELOG', $message['conversationId']), true);
@@ -951,6 +941,8 @@ class Events
             echo date("Y-m-d H:i:s") . ' - ' . "客服发生异常退出." . print_r([$client_id, $uid, $group, $uinfo], true) . "\n";
             return;
         }
+        self::$db->update('ws_users')->cols(['token' => uniqid()])->where('id=' . self::getkfid($uid))->query();
+
         $user_info = self::$redis->hgetall(self::getKfServiceKey($uid));
         if (!empty($user_info)) {
             foreach ($user_info as $val => $serverid) {

vendor/GatewayWorker_windows/Applications/whisper/Events.php

@@ -941,6 +941,8 @@ class Events
             echo date("Y-m-d H:i:s") . ' - ' . "客服发生异常退出." . print_r([$client_id, $uid, $group, $uinfo], true) . "\n";
             return;
         }
+        self::$db->update('ws_users')->cols(['token' => uniqid()])->where('id=' . self::getkfid($uid))->query();
+
         $user_info = self::$redis->hgetall(self::getKfServiceKey($uid));
         if (!empty($user_info)) {
             foreach ($user_info as $val => $serverid) {