正在显示
1 个修改的文件
包含
3 行增加
和
4 行删除
| @@ -46,12 +46,11 @@ class RankDataLog extends BaseCommands | @@ -46,12 +46,11 @@ 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 | - | ||
| 50 | if (!$log_id) { | 49 | if (!$log_id) { |
| 51 | - $log = RankDataLogModel::where('status', 0)->first(); | ||
| 52 | - }else{ | ||
| 53 | - $log = RankDataLogModel::where('id', $log_id)->where('status', 0)->first(); | 50 | + $log_id = RankDataLogModel::where('status', 0)->value('id'); |
| 54 | } | 51 | } |
| 52 | + $log = RankDataLogModel::where('id', $log_id)->where('status', 0)->first(); | ||
| 53 | + | ||
| 55 | if(!$log){ | 54 | if(!$log){ |
| 56 | sleep(10); | 55 | sleep(10); |
| 57 | continue; | 56 | continue; |
-
请 注册 或 登录 后发表评论