正在显示
1 个修改的文件
包含
6 行增加
和
7 行删除
| @@ -46,16 +46,15 @@ class RankDataLog extends BaseCommands | @@ -46,16 +46,15 @@ class RankDataLog extends BaseCommands | ||
| 46 | { | 46 | { |
| 47 | while (true) { | 47 | while (true) { |
| 48 | $log_id = Redis::rpop('rank_data_task'); | 48 | $log_id = Redis::rpop('rank_data_task'); |
| 49 | - echo $log_id . PHP_EOL; | 49 | + |
| 50 | if (!$log_id) { | 50 | if (!$log_id) { |
| 51 | - sleep(10); | ||
| 52 | - continue; | 51 | + $log = RankDataLogModel::where('id', $log_id)->where('status', 0)->first(); |
| 52 | + if(!$log){ | ||
| 53 | + sleep(10); | ||
| 54 | + continue; | ||
| 55 | + } | ||
| 53 | } | 56 | } |
| 54 | 57 | ||
| 55 | - $log = RankDataLogModel::where('id', $log_id)->where('status', 0)->first(); | ||
| 56 | - if(!$log){ | ||
| 57 | - continue; | ||
| 58 | - } | ||
| 59 | try { | 58 | try { |
| 60 | $this->output('项目开始:ID'.$log->project_id . ',APINO' . $log->api_no); | 59 | $this->output('项目开始:ID'.$log->project_id . ',APINO' . $log->api_no); |
| 61 | $project = Project::find($log->project_id); | 60 | $project = Project::find($log->project_id); |
-
请 注册 或 登录 后发表评论