作者 赵彬吉

update

@@ -31,20 +31,22 @@ class SyncSubmitTask extends Command @@ -31,20 +31,22 @@ class SyncSubmitTask extends Command
31 while (true) { 31 while (true) {
32 $task_id = Redis::rpop('sync_submit_task'); 32 $task_id = Redis::rpop('sync_submit_task');
33 if(!$task_id){ 33 if(!$task_id){
34 - sleep(3);  
35 continue; 34 continue;
36 } 35 }
37 $this->output('任务' . $task_id . '开始'); 36 $this->output('任务' . $task_id . '开始');
  37 + $time = microtime();
38 $task_info = SyncSubmitTaskModel::find($task_id); 38 $task_info = SyncSubmitTaskModel::find($task_id);
39 if (empty($task_info) || $task_info->status !=3) { 39 if (empty($task_info) || $task_info->status !=3) {
40 $this->output('任务不存在或者已执行'); 40 $this->output('任务不存在或者已执行');
41 continue; 41 continue;
42 } 42 }
  43 + $time1 = $time2 = $time3 = microtime();
43 try { 44 try {
44 $project = Project::getProjectByDomain($task_info['data']['domain'] ?? ''); 45 $project = Project::getProjectByDomain($task_info['data']['domain'] ?? '');
45 $task_info->project_id = $project->id; 46 $task_info->project_id = $project->id;
46 - 47 + $time2 = microtime();
47 SyncSubmitTaskService::handler($task_info); 48 SyncSubmitTaskService::handler($task_info);
  49 + $time3 = microtime();
48 $task_info->status = 1; 50 $task_info->status = 1;
49 $task_info->save(); 51 $task_info->save();
50 52
@@ -68,6 +70,10 @@ class SyncSubmitTask extends Command @@ -68,6 +70,10 @@ class SyncSubmitTask extends Command
68 70
69 $this->output('任务失败:' . $e->getMessage()); 71 $this->output('任务失败:' . $e->getMessage());
70 } 72 }
  73 + $time4 = microtime();
  74 + if($time4 - $time1 > 1000){
  75 + $this->output('任务用时:' . $time2 - $time1 . '|' . $time3 - $time2 . '|' . $time4 - $time3);
  76 + }
71 } 77 }
72 } 78 }
73 79
@@ -44,7 +44,6 @@ class SyncSubmitTaskDistribution extends Command @@ -44,7 +44,6 @@ class SyncSubmitTaskDistribution extends Command
44 } 44 }
45 } 45 }
46 } 46 }
47 - sleep(3);  
48 } 47 }
49 } 48 }
50 49