|
|
@@ -1062,14 +1062,6 @@ class Events
|
|
|
*/
|
|
|
private static function userOnlineTask($group = 0, $uid = 0, $last = [], $client_id = '')
|
|
|
{
|
|
|
- $wiyikey = 'WIYIKEY';
|
|
|
- $oldwiyikeyval = self::$redis->get($wiyikey);
|
|
|
- if ($oldwiyikeyval) {
|
|
|
- echo date("Y-m-d H:i:s") . " - userOnlineTask 存在并发运行,本次中止\n";
|
|
|
- return;
|
|
|
- }
|
|
|
- self::$redis->setex($wiyikey, 10, time());
|
|
|
-
|
|
|
|
|
|
if ($group && $uid) {
|
|
|
// 指定用指定组 [可能存在断线重连的情况] 如果存在旧的会话,直接连线客服和用户
|
|
|
@@ -1093,11 +1085,19 @@ class Events
|
|
|
];
|
|
|
Gateway::sendToCurrentClient(json_encode($toOld_message, 256));
|
|
|
}
|
|
|
- self::$redis->del($wiyikey);
|
|
|
return;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ $wiyikey = 'WIYIKEY';
|
|
|
+ $oldwiyikeyval = self::$redis->get($wiyikey);
|
|
|
+ if ($oldwiyikeyval) {
|
|
|
+ echo date("Y-m-d H:i:s") . " - userOnlineTask 存在并发运行,本次中止\n";
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ self::$redis->setex($wiyikey, 10, time());
|
|
|
+
|
|
|
+
|
|
|
$allusergkarr = self::getUserListData();
|
|
|
if (empty($allusergkarr)) {
|
|
|
self::$redis->del($wiyikey);
|