|
|
@@ -25,13 +25,13 @@ public class WorkflowTaskScheduler {
|
|
|
private final WorkflowTaskResultHandler resultHandler;
|
|
|
|
|
|
/**
|
|
|
- * 每5分钟轮询一次:查询创建时间超过5分钟且仍处于"执行中"的订单,
|
|
|
+ * 每4分钟轮询一次:查询创建时间超过3分钟且仍处于"执行中"的订单,
|
|
|
* 主动向外部接口查询结果,防止 Redis 通知遗漏导致订单卡住。
|
|
|
*/
|
|
|
- @Scheduled(fixedRate = 5 * 60 * 1000, initialDelay = 60 * 1000)
|
|
|
+ @Scheduled(fixedRate = 4 * 60 * 1000, initialDelay = 60 * 1000)
|
|
|
@SchedulerLock(name = "pollPendingTaskResults", lockAtMostFor = "PT10M", lockAtLeastFor = "PT1M")
|
|
|
public void pollPendingTaskResults() {
|
|
|
- LocalDateTime threshold = LocalDateTime.now().minusMinutes(5);
|
|
|
+ LocalDateTime threshold = LocalDateTime.now().minusMinutes(3);
|
|
|
List<TAiOrderV2> pendingOrders = aiOrderV2Service.list(
|
|
|
new LambdaQueryWrapper<TAiOrderV2>()
|
|
|
.eq(TAiOrderV2::getTaskStatus, 1)
|