From 6fe8b56ec83d32b22d4cca85f7591ea559d0cb95 Mon Sep 17 00:00:00 2001 From: wong <106998207@qq.com> Date: Mon, 30 Jun 2025 17:31:01 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=81=E9=87=8F=E5=88=86=E5=8F=91=E4=BC=98?= =?UTF-8?q?=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../job/WorkbenchTrafficDistributeJob.php | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/Server/application/job/WorkbenchTrafficDistributeJob.php b/Server/application/job/WorkbenchTrafficDistributeJob.php index 99fa2af8..674a54a0 100644 --- a/Server/application/job/WorkbenchTrafficDistributeJob.php +++ b/Server/application/job/WorkbenchTrafficDistributeJob.php @@ -58,7 +58,8 @@ class WorkbenchTrafficDistributeJob protected function processSingleWorkbench($workbench) { $page = 1; - $pageSize = 20; + $pageSize = 100; + $config = WorkbenchTrafficConfig::where('workbenchId', $workbench->id)->find(); if (!$config) { Log::error("流量分发工作台 {$workbench->id} 配置获取失败"); @@ -84,7 +85,7 @@ class WorkbenchTrafficDistributeJob ->whereNotLike('a.userName', '%_offline%') ->whereNotLike('a.userName', '%_delete%') ->leftJoin('workbench_traffic_config_item wti', "wti.wechatAccountId = a.id AND wti.workbenchId = {$workbench->id} AND wti.createTime BETWEEN {$todayStart} AND {$todayEnd}") - ->field('a.id,a.userName,a.realName,COUNT(wti.id) as todayCount') + ->field('a.id,a.userName,a.realName,a.nickname,COUNT(wti.id) as todayCount') ->group('a.id') ->having('todayCount <= ' . $config['maxPerDay']) ->select(); @@ -137,6 +138,14 @@ class WorkbenchTrafficDistributeJob 'wechatFriendId' => $friend['id'], 'toAccountId' => $account['id'] ], true); + Db::table('s2_wechat_friend') + ->where('id',$friend['id']) + ->update([ + 'accountId' => $account['id'], + 'accountUserName' => $account['userName'], + 'accountRealName' => $account['realName'], + 'accountNickname' => $account['nickname'], + ]); // 写入分配记录表 Db::name('workbench_traffic_config_item')->insert([ 'workbenchId' => $workbench->id,