'修改重连机智'

vendor/GatewayWorker_windows/Applications/whisper/Events.php

@@ -906,23 +906,24 @@ class Events
             //否则按先到后到以及客服最大服务数限制
 
             if ($last) {
-                //self::$redis->hdel(self::USERLIST, $uid);
+                $userInfo = json_decode(self::$redis->hget(self::USERINFOKEY, $uid), true);
                 self::BeginOldTalk(self::getkfuid($last['kf_id']), $uid, $last['group_id'], $last['servicelog_id']);
-
-                // 查询工单历史会话.
-                $serviceid = $last['servicelog_id'];
-                //$chatLog = self::$db->query("SELECT * FROM `ws_chat_log` where `servicelog_id`= '$serviceid' order by `time_line`");
-                $toOld_message = [
-                    'message_type' => 'toOld',
-                    'data' => [
-                        //'chatLog' => $chatLog ?? [],
-                        'chatLog' => [],
-                        'content' => '接入至未结束的会话',
-                        'serviceid' => $serviceid,
-                        'uid' => $uid
-                    ]
-                ];
-                Gateway::sendToCurrentClient(json_encode($toOld_message, 256));
+                print_r([$client_id,$userInfo['client_id']]);
+                if ($client_id == $userInfo['client_id']) {
+                    // 查询工单历史会话.
+                    $serviceid = $last['servicelog_id'];
+                    $chatLog = self::$db->query("SELECT * FROM `ws_chat_log` where `servicelog_id`= '$serviceid' order by `time_line`");
+                    $toOld_message = [
+                        'message_type' => 'toOld',
+                        'data' => [
+                            'chatLog' => $chatLog ?? [],
+                            'content' => '接入至未结束的会话',
+                            'serviceid' => $serviceid,
+                            'uid' => $uid
+                        ]
+                    ];
+                    Gateway::sendToCurrentClient(json_encode($toOld_message, 256));
+                }
                 return;
             }
         }