修复同步进程脚本
Showing
1 changed file
with
3 additions
and
3 deletions
| ... | @@ -86,12 +86,12 @@ class StakeholderIncomeSyncCommand extends Command | ... | @@ -86,12 +86,12 @@ class StakeholderIncomeSyncCommand extends Command |
| 86 | 86 | ||
| 87 | //处理返回体 | 87 | //处理返回体 |
| 88 | $this->dealResponse($serial_no, $http_data, $http_res); | 88 | $this->dealResponse($serial_no, $http_data, $http_res); |
| 89 | $this->consumeTask($http_res, $redis, $key, $id); | ||
| 89 | 90 | ||
| 90 | } else { | 91 | } else { |
| 91 | Log::channel('api')->info(__METHOD__, ['msg'=>'找不到需要同步的对应的收益记录', 'serial_no'=>$serial_no]); | 92 | //此处需要加入 重试计数移除任务机制 |
| 93 | Log::channel('api')->info(__METHOD__, ['msg'=>'暂时找不到需要同步的对应的收益记录', 'serial_no'=>$serial_no]); | ||
| 92 | } | 94 | } |
| 93 | |||
| 94 | $this->consumeTask($http_res, $redis, $key, $id); | ||
| 95 | } | 95 | } |
| 96 | } | 96 | } |
| 97 | } | 97 | } | ... | ... |
-
Please register or sign in to post a comment