代码提交

Server/extend/WeChatDeviceApi/Adapters/ChuKeBao/Adapter.php

@@ -153,14 +153,16 @@ class Adapter implements WeChatServiceInterface
 
     public function handleCustomerTaskWithStatusIsNew(int $current_worker_id, int $process_count_for_status_0)
     {
-        $tasks = Db::name('task_customer')
-            ->where('status', 0)
-            ->whereRaw("id % $process_count_for_status_0 = {$current_worker_id}")
-            ->limit(50)
+
+        $tasks = Db::name('customer_acquisition_task')->alias('task')
+            ->join('task_customer customer','task.id=customer.task_id')
+            ->where(['task.status' => 1,'customer.status'=>0,'task.deleteTime' => 0])
+            ->whereRaw("customer.id % $process_count_for_status_0 = {$current_worker_id}")
             ->order('id DESC')
             ->select();
 
 
+
         if ($tasks) {
 
             foreach ($tasks as $task) {