diff --git a/Server/extend/WeChatDeviceApi/Adapters/ChuKeBao/Adapter.php b/Server/extend/WeChatDeviceApi/Adapters/ChuKeBao/Adapter.php index 08f720ea..a1ef4e3e 100644 --- a/Server/extend/WeChatDeviceApi/Adapters/ChuKeBao/Adapter.php +++ b/Server/extend/WeChatDeviceApi/Adapters/ChuKeBao/Adapter.php @@ -236,15 +236,17 @@ class Adapter implements WeChatServiceInterface $task['processed_wechat_ids'] = $task['processed_wechat_ids'] . ',' . $wechatId; // 处理失败任务用,用于过滤已处理的微信号 break; } - $res = Db::name('task_customer') - ->where('id', $task['id']) - ->update([ - 'status' => $friendAddTaskCreated ? 1 : 3, - 'fail_reason' => '', - 'processed_wechat_ids' => $task['processed_wechat_ids'], - 'addTime' => time(), - 'updateTime' => time() - ]); + if (!empty($friendAddTaskCreated)){ + Db::name('task_customer') + ->where('id', $task['id']) + ->update([ + 'status' => $friendAddTaskCreated ? 1 : 3, + 'fail_reason' => '', + 'processed_wechat_ids' => $task['processed_wechat_ids'], + 'addTime' => time(), + 'updateTime' => time() + ]); + } // ~~不用管,回头再添加再判断即可~~ // 失败一定是另一个进程/定时器在检查的