|
@@ -70,7 +70,7 @@ class Events
|
|
|
foreach ($group as $groupid => $gname) {
|
|
foreach ($group as $groupid => $gname) {
|
|
|
$users = self::getUselistData($groupid);
|
|
$users = self::getUselistData($groupid);
|
|
|
if (!empty($users)) {
|
|
if (!empty($users)) {
|
|
|
- Gateway::sendToGroup('group_' . $groupid, json_encode(['type' => 'lineupCount', coung($users)], 256));
|
|
|
|
|
|
|
+ Gateway::sendToGroup('group_' . $groupid, json_encode(['type' => 'lineupCount', count($users)], 256));
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -811,38 +811,38 @@ class Events
|
|
|
// 指定用指定组 [可能存在断线重连的情况] 如果存在旧的会话，直接连线客服和用户
|
|
// 指定用指定组 [可能存在断线重连的情况] 如果存在旧的会话，直接连线客服和用户
|
|
|
//否则按先到后到以及客服最大服务数限制
|
|
//否则按先到后到以及客服最大服务数限制
|
|
|
$last = self::UserHasOldTalk($uid);
|
|
$last = self::UserHasOldTalk($uid);
|
|
|
- if ($last) {
|
|
|
|
|
|
|
+ if ($last) {print_r(time());
|
|
|
self::BeginTalk(self::getkfuid($last['kf_id']), $uid, $last['group_id'], $last['servicelog_id']);
|
|
self::BeginTalk(self::getkfuid($last['kf_id']), $uid, $last['group_id'], $last['servicelog_id']);
|
|
|
return;
|
|
return;
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- //系统定时调用时，无组，无用户
|
|
|
|
|
- foreach ($allusergkarr as $group => $gusersArr) {
|
|
|
|
|
- if (!isset($allkfgkarr[$group]) || count($allkfgkarr[$group]) <= 0) {
|
|
|
|
|
- //所属客服组无人在线
|
|
|
|
|
- continue;
|
|
|
|
|
- }
|
|
|
|
|
- $nowkfs = $allkfgkarr[$group];
|
|
|
|
|
- $count = count($nowkfs);
|
|
|
|
|
- $i = 0;
|
|
|
|
|
|
|
+ } else {
|
|
|
|
|
+ //系统定时调用时，无组，无用户
|
|
|
|
|
+ foreach ($allusergkarr as $group => $gusersArr) {
|
|
|
|
|
+ if (!isset($allkfgkarr[$group]) || count($allkfgkarr[$group]) <= 0) {
|
|
|
|
|
+ //所属客服组无人在线
|
|
|
|
|
+ continue;
|
|
|
|
|
+ }
|
|
|
|
|
+ $nowkfs = $allkfgkarr[$group];
|
|
|
|
|
+ $count = count($nowkfs);
|
|
|
|
|
+ $i = 0;
|
|
|
|
|
|
|
|
- foreach ($gusersArr as $user) {
|
|
|
|
|
- if ($nowkfs[$i]['task'] > $maxset) {
|
|
|
|
|
- break;
|
|
|
|
|
- }
|
|
|
|
|
- $nowkfs[$i]['task']++;
|
|
|
|
|
|
|
+ foreach ($gusersArr as $user) {
|
|
|
|
|
+ if ($nowkfs[$i]['task'] > $maxset) {
|
|
|
|
|
+ break;
|
|
|
|
|
+ }
|
|
|
|
|
+ $nowkfs[$i]['task']++;
|
|
|
|
|
|
|
|
- self::BeginTalk($nowkfs[$i]['id'], $user['id'], $group, 0, $user);
|
|
|
|
|
- self::$redis->hdel(self::USERLIST, $user['id']);
|
|
|
|
|
|
|
+ self::BeginTalk($nowkfs[$i]['id'], $user['id'], $group, 0, $user);
|
|
|
|
|
+ self::$redis->hdel(self::USERLIST, $user['id']);
|
|
|
|
|
|
|
|
- $i++;
|
|
|
|
|
- if ($i >= $count) {
|
|
|
|
|
- $i = 0;
|
|
|
|
|
|
|
+ $i++;
|
|
|
|
|
+ if ($i >= $count) {
|
|
|
|
|
+ $i = 0;
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
|
|
+ return;
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
- return;
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
//开启一个会话
|
|
//开启一个会话
|
|
@@ -869,7 +869,7 @@ class Events
|
|
|
|
|
|
|
|
if (empty($server)) {
|
|
if (empty($server)) {
|
|
|
$array = [
|
|
$array = [
|
|
|
- 'user_id' => $uid,
|
|
|
|
|
|
|
+ 'user_id' => intval($uid),
|
|
|
'client_id' => $userInfo['client_id'],
|
|
'client_id' => $userInfo['client_id'],
|
|
|
'user_name' => $userInfo['name'],
|
|
'user_name' => $userInfo['name'],
|
|
|
'user_avatar' => $userInfo['avatar'],
|
|
'user_avatar' => $userInfo['avatar'],
|
|
@@ -1413,6 +1413,8 @@ class Events
|
|
|
|
|
|
|
|
//回转接人，转接成功
|
|
//回转接人，转接成功
|
|
|
Gateway::sendToCurrentClient(json_encode(['message_type' => 'trunconnect', 'data' => ['status' => 1]], 256));
|
|
Gateway::sendToCurrentClient(json_encode(['message_type' => 'trunconnect', 'data' => ['status' => 1]], 256));
|
|
|
|
|
+ // 发送给用户转接消息
|
|
|
|
|
+ Gateway::sendToClient($user_info['client_id'], json_encode(['message_type' => 'changeKeFuSuccess', 'data' => ['content' => "会话转接成功"]], 256));
|
|
|
|
|
|
|
|
self::DebugOut('changekf 转换成功!');
|
|
self::DebugOut('changekf 转换成功!');
|
|
|
|
|
|
Ethan