代码同步
This commit is contained in:
@@ -168,7 +168,7 @@ class Adapter implements WeChatServiceInterface
|
|||||||
->where(['status'=> 0,'task_id'=>$item['id']])
|
->where(['status'=> 0,'task_id'=>$item['id']])
|
||||||
->whereRaw("id % $process_count_for_status_0 = {$current_worker_id}")
|
->whereRaw("id % $process_count_for_status_0 = {$current_worker_id}")
|
||||||
->order('id DESC')
|
->order('id DESC')
|
||||||
->limit(20)
|
->limit(5)
|
||||||
->select();
|
->select();
|
||||||
$taskData = array_merge($taskData, $tasks);
|
$taskData = array_merge($taskData, $tasks);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user