代码提交
This commit is contained in:
@@ -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()
|
||||
]);
|
||||
}
|
||||
// ~~不用管,回头再添加再判断即可~~
|
||||
// 失败一定是另一个进程/定时器在检查的
|
||||
|
||||
|
||||
Reference in New Issue
Block a user