Skip to content

Commit f8873ce

Browse files
committed
fix(repo): 失败任务处理时间为 10 分钟
1 parent 52ed6df commit f8873ce

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

laravel/app/Console/Kernel.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ protected function schedule(Schedule $schedule)
4747

4848
// 每隔一小时检测需要自动处理的任务
4949
$schedule->call(function() {
50-
ApiRepository::getInstent()->handleAutoTask();
50+
ApiRepository::getInstent()->handleAutoDelete();
5151
})->hourly()->between('4:00', '23:59');
5252
}
5353

laravel/app/Http/Repository/ApiRepository.php

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -64,15 +64,16 @@ public function handleAutoDelete()
6464

6565
/**
6666
* 自动失败的任务
67+
* 开启任务后 state = 1 的一直未更新状态的为失败任务
6768
*/
6869
public function autoFailed()
6970
{
7071
// 查询数据库已完成的任务,判断过期条件
71-
$excels = ApiExcel::where('state', 1)->get(['id', 'auto_delete', 'created_at']);
72+
$excels = ApiExcel::where('state', 1)->get(['id', 'auto_delete', 'created_at', 'updated_at']);
7273

7374
foreach ($excels as $excel) {
74-
if ($excel['auto_delete'] > 0 && strtotime($excel['created_at']) + $excel['auto_delete'] * 86400 < time()) {
75-
// 获取过期时间戳
75+
// 开启任务后 10 分钟未查询出结果=》失败
76+
if ($excel['auto_delete'] > 0 && strtotime($excel['updated_at']) + 600 < time()) {
7677
ApiExcel::where('id', $excel['id'])->update(['state' => 5]);
7778

7879
}

0 commit comments

Comments
 (0)