|
@@ -1,4 +1,12 @@
|
|
|
<?php
|
|
<?php
|
|
|
|
|
+/*
|
|
|
|
|
+ * @Author: seven 7@seven.com
|
|
|
|
|
+ * @Date: 2025-10-09 17:31:51
|
|
|
|
|
+ * @LastEditors: seven 7@seven.com
|
|
|
|
|
+ * @LastEditTime: 2025-11-05 11:37:34
|
|
|
|
|
+ * @FilePath: \bot-28\app\Jobs\FiveSecondTaskJob.php
|
|
|
|
|
+ * @Description: 这是默认设置,请设置`customMade`, 打开koroFileHeader查看配置 进行设置: https://github.com/OBKoro1/koro1FileHeader/wiki/%E9%85%8D%E7%BD%AE
|
|
|
|
|
+ */
|
|
|
|
|
|
|
|
namespace App\Jobs;
|
|
namespace App\Jobs;
|
|
|
|
|
|
|
@@ -44,7 +52,7 @@ class FiveSecondTaskJob implements ShouldQueue
|
|
|
public function handle()
|
|
public function handle()
|
|
|
{
|
|
{
|
|
|
try {
|
|
try {
|
|
|
- Log::error('🚀 开始执行10秒任务: ' . now());
|
|
|
|
|
|
|
+ Log::error('🚀 开始执行15秒任务: ' . now());
|
|
|
|
|
|
|
|
IssueService::syncCountdownIssue(); // 提前20秒提醒
|
|
IssueService::syncCountdownIssue(); // 提前20秒提醒
|
|
|
|
|
|
|
@@ -55,15 +63,15 @@ class FiveSecondTaskJob implements ShouldQueue
|
|
|
IssueService::getLatestIssue(); // 获取最新的期号
|
|
IssueService::getLatestIssue(); // 获取最新的期号
|
|
|
|
|
|
|
|
// 重要:使用类名而不是 self(),避免递归
|
|
// 重要:使用类名而不是 self(),避免递归
|
|
|
- FiveSecondTaskJob::dispatch()->delay(now()->addSeconds(10));
|
|
|
|
|
|
|
+ FiveSecondTaskJob::dispatch()->delay(now()->addSeconds(15));
|
|
|
|
|
|
|
|
- Log::error('📅 下一个10秒任务已安排');
|
|
|
|
|
|
|
+ Log::error('📅 下一个15秒任务已安排');
|
|
|
|
|
|
|
|
} catch (\Exception $e) {
|
|
} catch (\Exception $e) {
|
|
|
- Log::error('❌ 10秒任务执行异常: ' . $e->getMessage());
|
|
|
|
|
|
|
+ Log::error('❌ 15秒任务执行异常: ' . $e->getMessage());
|
|
|
|
|
|
|
|
- // 异常后10秒重试
|
|
|
|
|
- FiveSecondTaskJob::dispatch()->delay(now()->addSeconds(10));
|
|
|
|
|
|
|
+ // 异常后15秒重试
|
|
|
|
|
+ FiveSecondTaskJob::dispatch()->delay(now()->addSeconds(15));
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -73,6 +81,6 @@ class FiveSecondTaskJob implements ShouldQueue
|
|
|
Log::error('任务失败: ' . $exception->getMessage());
|
|
Log::error('任务失败: ' . $exception->getMessage());
|
|
|
|
|
|
|
|
// 可选:重新分发或通知
|
|
// 可选:重新分发或通知
|
|
|
- dispatch(new self())->delay(now()->addSeconds(10));
|
|
|
|
|
|
|
+ dispatch(new self())->delay(now()->addSeconds(15));
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|