diff --git a/Server/application/command/WechatChatroomCommand.php b/Server/application/command/WechatChatroomCommand.php index b751435b..e770b4b4 100644 --- a/Server/application/command/WechatChatroomCommand.php +++ b/Server/application/command/WechatChatroomCommand.php @@ -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},跳过执行"); diff --git a/Server/application/command/WechatFriendCommand.php b/Server/application/command/WechatFriendCommand.php index 3978f218..71a20e6a 100644 --- a/Server/application/command/WechatFriendCommand.php +++ b/Server/application/command/WechatFriendCommand.php @@ -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},跳过执行"); diff --git a/Server/application/cunkebao/controller/plan/PlanSceneV1Controller.php b/Server/application/cunkebao/controller/plan/PlanSceneV1Controller.php index c4cd7e08..c71643ee 100644 --- a/Server/application/cunkebao/controller/plan/PlanSceneV1Controller.php +++ b/Server/application/cunkebao/controller/plan/PlanSceneV1Controller.php @@ -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'].'%')