fnvtk/ckb-SuperAdmin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

【操盘手】 自动点赞 ---更新用户标签

Browse Source
This commit is contained in:
wong
2025-05-30 18:03:42 +08:00
parent 4f681f66a4
commit ff3bb5eb74
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
Server/application/job/WorkbenchAutoLikeJob.php
View File

@@ -220,7 +220,7 @@ class WorkbenchAutoLikeJob
$automaticAssign = new AutomaticAssign(); $automaticAssign = new AutomaticAssign();
$automaticAssign->allotWechatFriend(['wechatFriendId' => $friend['friendId'], 'toAccountId' => $toAccountId], true); $automaticAssign->allotWechatFriend(['wechatFriendId' => $friend['friendId'], 'toAccountId' => $toAccountId], true);
// 执行采集朋友圈命令 // 创建WebSocket链接
$webSocket = new WebSocketController(['userName' => $username, 'password' => $password, 'accountId' => $toAccountId]); $webSocket = new WebSocketController(['userName' => $username, 'password' => $password, 'accountId' => $toAccountId]);
// 查询未点赞的朋友圈 // 查询未点赞的朋友圈
@@ -232,8 +232,6 @@ class WorkbenchAutoLikeJob
} }
if (empty($moments) || count($moments) == 0) { if (empty($moments) || count($moments) == 0) {
// 处理完毕切换回原账号 // 处理完毕切换回原账号
$automaticAssign->allotWechatFriend(['wechatFriendId' => $friend['friendId'], 'toAccountId' => $friend['accountId']], true); $automaticAssign->allotWechatFriend(['wechatFriendId' => $friend['friendId'], 'toAccountId' => $friend['accountId']], true);
@@ -251,16 +249,21 @@ class WorkbenchAutoLikeJob
$labels = $this->getFriendLabels($friend); $labels = $this->getFriendLabels($friend);
$labels[] = $config['friendTags']; $labels[] = $config['friendTags'];
$webSocket->modifyFriendLabel(['wechatFriendId' => $friend['friendId'], 'wechatAccountId' => $friend['wechatAccountId'], 'labels' => $labels]); $webSocket->modifyFriendLabel(['wechatFriendId' => $friend['friendId'], 'wechatAccountId' => $friend['wechatAccountId'], 'labels' => $labels]);
//更新用户标签
$friendData = Db::table('s2_wechat_friend')->where('id', $friend['friendId'])->find();
Db::table('s2_wechat_friend')->where('id', $friend['friendId'])->update(['labels' => json_encode($labels,256)]);
} }
break;
} }
// 处理完毕切换回原账号 // 处理完毕切换回原账号
$automaticAssign->allotWechatFriend(['wechatFriendId' => $friend['friendId'], 'toAccountId' => $friend['accountId']], true); $automaticAssign->allotWechatFriend(['wechatFriendId' => $friend['friendId'], 'toAccountId' => $friend['accountId']], true);
} catch (\Exception $e) { } catch (\Exception $e) {
// 异常情况下也要确保切换回原账号 // 异常情况下也要确保切换回原账号
$automaticAssign = new AutomaticAssign();
$automaticAssign->allotWechatFriend(['wechatFriendId' => $friend['friendId'], 'toAccountId' => $friend['accountId']], true); $automaticAssign->allotWechatFriend(['wechatFriendId' => $friend['friendId'], 'toAccountId' => $friend['accountId']], true);
Log::error("处理好友 {$friend['friendId']} 朋友圈失败异常: " . $e->getMessage());
Log::error("处理好友 {$friend['friendId']} 朋友圈失败: " . $e->getMessage());
} }
} }