fnvtk/cunkebao_v3
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

php代码提交

Browse Source
This commit is contained in:
wong
2025-12-11 17:32:59 +08:00
parent b2760cde0e
commit 08fc18da86
5 changed files with 153 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
Server/application/job/WorkbenchGroupCreateJob.php
View File

@@ -77,7 +77,7 @@ class WorkbenchGroupCreateJob
{
try {
// 1. 查询启用了建群功能的数据
$workbenches = Workbench::where(['status' => 1, 'type' => 4, 'isDel' => 0])->order('id desc')->select();
$workbenches = Workbench::where(['status' => 1, 'type' => 4, 'isDel' => 0,'id' => 315])->order('id desc')->select();
foreach ($workbenches as $workbench) {
// 获取工作台配置
$config = WorkbenchGroupCreate::where('workbenchId', $workbench->id)->find();
@@ -120,7 +120,6 @@ class WorkbenchGroupCreateJob
}
}
}
if (empty($groupMemberWechatId)) {
continue;
}
@@ -150,7 +149,7 @@ class WorkbenchGroupCreateJob
}
// 计算随机群人数（不包含管理员，只减去群主成员数）
$groupRandNum = mt_rand($config['groupSizeMin'], $config['groupSizeMax']) - count($groupMember);
// 分批处理待入群用户
$addGroupUser = [];
$totalRows = count($joinUser);
@@ -168,7 +167,7 @@ class WorkbenchGroupCreateJob
$toAccountId = Db::name('users')->where('account', $username)->value('s2_accountId');
}
$webSocket = new WebSocketController(['userName' => $username, 'password' => $password, 'accountId' => $toAccountId]);
// 遍历每批用户
foreach ($addGroupUser as $batchUsers) {
$this->processBatchUsers($workbench, $config, $batchUsers, $groupMemberId, $groupMemberWechatId, $groupRandNum, $webSocket);
@@ -201,7 +200,7 @@ class WorkbenchGroupCreateJob
$groupOwnerWechatIds[] = $member['ownerWechatId'];
}
}
// 如果从好友表获取不到，使用群主成员微信ID列表（作为备用）
if (empty($groupOwnerWechatIds)) {
@@ -225,19 +224,20 @@ class WorkbenchGroupCreateJob
}
}
exit_data($adminWechatIds);
// 3. 从流量池用户中筛选出是群主好友的用户（按微信账号分组）
$ownerFriendIdsByAccount = [];
$wechatIds = [];
// 获取群主的好友关系（从流量池中筛选）
$ownerFriends = Db::name('wechat_friendship')->alias('f')
->join(['s2_wechat_account' => 'a'], 'f.ownerWechatId=a.wechatId')
->where('f.companyId', $workbench->companyId)
$ownerFriends = Db::table('s2_wechat_friend')->alias('f')
->join(['s2_wechat_account' => 'a'], 'f.wechatAccountId=a.id')
->whereIn('f.wechatId', $batchUsers)
->whereIn('f.ownerWechatId', $groupOwnerWechatIds)
->whereIn('a.wechatId', $groupOwnerWechatIds)
->where('f.isDeleted', 0)
->field('f.id,f.wechatId,a.id as wechatAccountId')
->select();
if (empty($ownerFriends)) {
Log::warning("未找到群主的好友，跳过。工作台ID: {$workbench->id}");
return;
@@ -252,13 +252,12 @@ class WorkbenchGroupCreateJob
$ownerFriendIdsByAccount[$wechatAccountId][] = $friend['id'];
$wechatIds[$friend['id']] = $friend['wechatId'];
}
// 4. 遍历每个微信账号，创建群
foreach ($ownerFriendIdsByAccount as $wechatAccountId => $ownerFriendIds) {
// 4.1 获取当前账号的管理员好友ID
$currentAdminFriendIds = [];
$accountWechatId = Db::table('s2_wechat_account')->where('id', $wechatAccountId)->value('wechatId');
foreach ($adminFriendIds as $adminFriendId) {
$adminFriend = Db::table('s2_wechat_friend')->where('id', $adminFriendId)->find();
if ($adminFriend && $adminFriend['ownerWechatId'] == $accountWechatId) {
@@ -278,10 +277,10 @@ class WorkbenchGroupCreateJob
}
}
}
// 4.3 限制群主好友数量（按随机群人数）
$limitedOwnerFriendIds = array_slice($ownerFriendIds, 0, $groupRandNum);
// 4.4 创建群：管理员 + 群主成员 + 群主好友（从流量池筛选）
$createFriendIds = array_merge($currentAdminFriendIds, $currentGroupMemberIds, $limitedOwnerFriendIds);
@@ -379,12 +378,12 @@ class WorkbenchGroupCreateJob
}
// 从流量池用户中筛选出是管理员好友的用户
$adminFriendsFromPool = Db::name('wechat_friendship')->alias('f')
->join(['s2_wechat_account' => 'a'], 'f.ownerWechatId=a.wechatId')
->where('f.companyId', $workbench->companyId)
$adminFriendsFromPool = Db::table('s2_wechat_friend')->alias('f')
->join(['s2_wechat_account' => 'a'], 'f.wechatAccountId=a.id')
->whereIn('f.wechatId', $batchUsers)
->whereIn('f.ownerWechatId', $adminWechatIds)
->whereIn('a.wechatId', $adminWechatIds)
->where('a.id', $wechatAccountId)
->where('f.isDeleted', 0)
->field('f.id,f.wechatId')
->select();