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