fyy

app/Service/FinishedOrderService.php

@@ -58,7 +58,11 @@ class FinishedOrderService extends Service
             'result' => $msg,
             'data' => $data,
         ];
-        $job = dispatch(new ProcessDataJob($redis,$user,1))->onQueue(ProcessDataJob::job_one);
+        file_put_contents('1.txt','start:'.microtime(true).PHP_EOL,8);
+        $job = ProcessDataJob::dispatch($redis,$user,1)->onQueue('finished_operation');
+        file_put_contents('1.txt','end:'.microtime(true).PHP_EOL,8);
+        $job =true;
+
         if(! $job){
             return [false,'任务没有进入队列！'];
         }
@@ -70,6 +74,7 @@ class FinishedOrderService extends Service
         DispatchSub::whereIn('id',$data['id'])->update([
             'job_status' => 1,
         ]);
+
         return [true,'任务已进入队列！'];
     }
 
@@ -386,7 +391,9 @@ class FinishedOrderService extends Service
             'data' => $data,
             'quantity_count' => $count_arr,
         ];
-        $job = dispatch(new ProcessDataJob($redis,$user,3))->onQueue(ProcessDataJob::job_one);
+        file_put_contents('1.txt','start:'.time().PHP_EOL,8);
+        $job =  ProcessDataJob::dispatch($redis,$user,3)->onQueue(ProcessDataJob::job_one);
+        file_put_contents('1.txt','end:'.time().PHP_EOL,8);
         if(! $job) return [false,'任务没有进入队列！'];
 
         //错误计数