diff --git a/Server/extend/WeChatDeviceApi/Adapters/ChuKeBao/Adapter.php b/Server/extend/WeChatDeviceApi/Adapters/ChuKeBao/Adapter.php index e1ab20af..cae1dae8 100644 --- a/Server/extend/WeChatDeviceApi/Adapters/ChuKeBao/Adapter.php +++ b/Server/extend/WeChatDeviceApi/Adapters/ChuKeBao/Adapter.php @@ -144,7 +144,7 @@ class Adapter implements WeChatServiceInterface /* todo 以上方法待实现，基于/参考 application/api/controller/WebSocketController.php 去实现 */ - + // NOTE: run in background; 5min 同步一次 // todo: 后续经过`s2_`表，直接对接三方的api去sync public function syncFriendship() @@ -265,7 +265,8 @@ class Adapter implements WeChatServiceInterface ->alias('a') ->join(['s2_device' => 'd'], 'd.imei = a.imei') ->join(['s2_company_account' => 'c'], 'c.id = d.currentAccountId') - ->field('d.id as deviceId, a.wechatId, a.wechatAlive as alive, c.departmentId as companyId, a.updateTime as createTime') + // ->field('d.id as deviceId, a.wechatId, a.wechatAlive as alive, c.departmentId as companyId, a.updateTime as createTime') + ->field('d.id as deviceId, a.wechatId, a.wechatAlive as alive, c.departmentId as companyId, a.updateTime as updateTime') ->cursor(); // $insertData = []; @@ -288,8 +289,9 @@ class Adapter implements WeChatServiceInterface Db::table('ck_device_wechat_login') ->where('deviceId', $item['deviceId']) ->where('wechatId', $item['wechatId']) - ->update(['alive' => $item['alive']]); + ->update(['alive' => $item['alive'], 'updateTime' => $item['updateTime']]); } else { + $item['createTime'] = $item['updateTime']; Db::table('ck_device_wechat_login')->insert($item); } @@ -368,4 +370,207 @@ class Adapter implements WeChatServiceInterface return $affectedRows; } + + + + /** + * 同步/更新微信客服信息到ck_wechat_customer表 + * + * @param int $batchSize 每批处理的数据量 + * @return int 影响的行数 + */ + public function syncWechatCustomer($batchSize = 1000) + { + try { + // 1. 获取要处理的wechatId和companyId列表 + $customerList = Db::table('ck_device_wechat_login') + ->field('DISTINCT wechatId, companyId') + ->select(); + + $totalAffected = 0; + $batchCount = ceil(count($customerList) / $batchSize); + + for ($i = 0; $i < $batchCount; $i++) { + $batch = array_slice($customerList, $i * $batchSize, $batchSize); + $insertData = []; + + foreach ($batch as $customer) { + $wechatId = $customer['wechatId']; + $companyId = $customer['companyId']; + + if (empty($wechatId)) continue; + + // 2. 获取s2_wechat_account数据 + $accountInfo = Db::table('s2_wechat_account') + ->where('wechatId', $wechatId) + ->find(); + + // 3. 获取群数量 (不包含 @openim 结尾的identifier) + $groupCount = Db::table('ck_wechat_group_member') + ->where('identifier', $wechatId) + ->where('customerIs', 1) + ->where('identifier', 'not like', '%@openim') + ->count(); + + // 4. 检查记录是否已存在 + $existingRecord = Db::table('ck_wechat_customer') + ->where('wechatId', $wechatId) + ->find(); + + // 5. 构建basic JSON数据 + $basic = []; + if ($existingRecord && !empty($existingRecord['basic'])) { + $basic = json_decode($existingRecord['basic'], true) ?: []; + } + + if (empty($basic['registerDate'])) { + $basic['registerDate'] = date('Y-m-d H:i:s', strtotime('-' . mt_rand(1, 150) . ' months')); + } + + // 6. 构建activity JSON数据 + $activity = []; + if ($existingRecord && !empty($existingRecord['activity'])) { + $activity = json_decode($existingRecord['activity'], true) ?: []; + } + + if ($accountInfo) { + $activity['yesterdayMsgCount'] = $accountInfo['yesterdayMsgCount'] ?? 0; + $activity['sevenDayMsgCount'] = $accountInfo['sevenDayMsgCount'] ?? 0; + $activity['thirtyDayMsgCount'] = $accountInfo['thirtyDayMsgCount'] ?? 0; + + // 计算totalMsgCount + if (empty($activity['totalMsgCount'])) { + $activity['totalMsgCount'] = $activity['thirtyDayMsgCount']; + } else { + $activity['totalMsgCount'] += $activity['yesterdayMsgCount']; + } + } + + // 7. 构建friendShip JSON数据 + $friendShip = []; + if ($existingRecord && !empty($existingRecord['friendShip'])) { + $friendShip = json_decode($existingRecord['friendShip'], true) ?: []; + } + + if ($accountInfo) { + $friendShip['totalFriend'] = $accountInfo['totalFriend'] ?? 0; + $friendShip['maleFriend'] = $accountInfo['maleFriend'] ?? 0; + $friendShip['unknowFriend'] = $accountInfo['unknowFriend'] ?? 0; + $friendShip['femaleFriend'] = $accountInfo['femaleFriend'] ?? 0; + } + $friendShip['groupNumber'] = $groupCount; + + // 8. 构建weight JSON数据 (每天只计算一次) + $weight = []; + if ($existingRecord && !empty($existingRecord['weight'])) { + $weight = json_decode($existingRecord['weight'], true) ?: []; + + // 如果不是今天更新的，重新计算权重 + $lastUpdateDate = date('Y-m-d', $existingRecord['updateTime'] ?? 0); + if ($lastUpdateDate !== date('Y-m-d')) { + $weight = $this->calculateCustomerWeight($basic, $activity, $friendShip); + } + } else { + $weight = $this->calculateCustomerWeight($basic, $activity, $friendShip); + } + + // 9. 准备更新或插入的数据 + $data = [ + 'wechatId' => $wechatId, + 'companyId' => $companyId, + 'basic' => json_encode($basic), + 'activity' => json_encode($activity), + 'friendShip' => json_encode($friendShip), + 'weight' => json_encode($weight), + 'updateTime' => time() + ]; + + if ($existingRecord) { + // 更新记录 + Db::table('ck_wechat_customer') + ->where('wechatId', $wechatId) + ->update($data); + } else { + // 插入记录 + Db::table('ck_wechat_customer')->insert($data); + } + + $totalAffected++; + } + + // 释放内存 + if ($i % 5 == 0) { + gc_collect_cycles(); + } + + usleep(50000); // 50毫秒短暂休息 + } + + return $totalAffected; + } catch (\Exception $e) { + Log::error("同步微信客服信息异常: " . $e->getMessage() . ", 堆栈: " . $e->getTraceAsString()); + throw $e; + } + } + + /** + * 计算客服权重 + * + * @param array $basic 基础信息 + * @param array $activity 活跃信息 + * @param array $friendShip 好友关系信息 + * @return array 权重信息 + */ + private function calculateCustomerWeight($basic, $activity, $friendShip) + { + // 1. 计算账号年龄权重（最大20分） + $ageWeight = 0; + if (!empty($basic['registerDate'])) { + $registerTime = strtotime($basic['registerDate']); + $accountAgeMonths = floor((time() - $registerTime) / (30 * 24 * 3600)); + $ageWeight = min(20, floor($accountAgeMonths / 12) * 4); + } + + // 2. 计算活跃度权重（最大30分） + $activityWeight = 0; + if (!empty($activity)) { + // 基于消息数计算活跃度 + $msgScore = 0; + if ($activity['thirtyDayMsgCount'] > 10000) $msgScore = 15; + elseif ($activity['thirtyDayMsgCount'] > 5000) $msgScore = 12; + elseif ($activity['thirtyDayMsgCount'] > 1000) $msgScore = 8; + elseif ($activity['thirtyDayMsgCount'] > 500) $msgScore = 5; + elseif ($activity['thirtyDayMsgCount'] > 100) $msgScore = 3; + + // 连续活跃天数加分（这里简化处理，实际可能需要更复杂逻辑） + $activeScore = min(15, $activity['yesterdayMsgCount'] > 10 ? 15 : floor($activity['yesterdayMsgCount'] / 2)); + + $activityWeight = $msgScore + $activeScore; + } + + // 3. 计算限制影响权重（最大15分） + $restrictWeight = 15; // 默认满分，无限制 + + // 4. 计算实名认证权重（最大10分） + $realNameWeight = 0; // 简化处理，默认未实名 + + // 5. 计算可加友数量限制（基于好友数量，最大为5000） + $addLimit = 0; + if (!empty($friendShip['totalFriend'])) { + $addLimit = max(0, min(5000 - $friendShip['totalFriend'], 5000)); + $addLimit = floor($addLimit / 1000); // 每1000个空位1分，最大5分 + } + + // 6. 计算总分（满分75+5分） + $scope = $ageWeight + $activityWeight + $restrictWeight + $realNameWeight; + + return [ + 'ageWeight' => $ageWeight, + 'activityWeight' => $activityWeight, // 注意这里修正了拼写错误 + 'restrictWeight' => $restrictWeight, + 'realNameWeight' => $realNameWeight, + 'scope' => $scope, + 'addLimit' => $addLimit + ]; + } }