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

代码提交

Browse Source
This commit is contained in:
wong
2025-10-16 11:42:59 +08:00
parent 1083822513
commit 8bf6cbe1d4
3 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
Server/application/command/WechatChatroomCommand.php
View File

@@ -38,6 +38,7 @@ class WechatChatroomCommand extends Command
// 检查队列是否已经在运行
$queueLockKey = "queue_lock:{$this->queueName}:{$isDel}";
Cache::rm($queueLockKey);
if (Cache::get($queueLockKey)) {
$output->writeln("队列 {$this->queueName} 已经在运行中，删除状态:{$isDel}，跳过执行");
Log::warning("队列 {$this->queueName} 已经在运行中，删除状态:{$isDel}，跳过执行");

1
Server/application/command/WechatFriendCommand.php
View File

@@ -38,6 +38,7 @@ class WechatFriendCommand extends Command
// 检查队列是否已经在运行
$queueLockKey = "queue_lock:{$this->queueName}:{$isDel}";
Cache::rm($queueLockKey);
if (Cache::get($queueLockKey)) {
$output->writeln("队列 {$this->queueName} 已经在运行中，删除状态:{$isDel}，跳过执行");
Log::warning("队列 {$this->queueName} 已经在运行中，删除状态:{$isDel}，跳过执行");

2
Server/application/cunkebao/controller/plan/PlanSceneV1Controller.php
View File

@@ -458,7 +458,7 @@ class PlanSceneV1Controller extends BaseController
$total = $query->count();
$list = $query->page($page, $pageSize)->order('id', 'desc')->select();
foreach ($list as &$item) {
unset($item['fail_reason'],$item['processed_wechat_ids'],$item['task_id']);
unset($item['processed_wechat_ids'],$item['task_id']);
$userinfo = Db::table('s2_wechat_friend')
->field('alias,wechatId,nickname,avatar')
->where('alias|wechatId|phone|conRemark','like','%'.$item['phone'].'%')