From 59624aae15d09d3042d357f60613d844f42c6b1d Mon Sep 17 00:00:00 2001
From: zhaowenyu <35589726@qq.com>
Date: Tue, 16 Dec 2025 17:18:13 +0800
Subject: [PATCH] 2025-12-16 zwy 优化创建计划任务-定时任务时间提示错误码
---
ard-sample/src/main/java/com/ard/sample/wayline/service/impl/FlightTaskServiceImpl.java | 11 ++++++-----
1 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/ard-sample/src/main/java/com/ard/sample/wayline/service/impl/FlightTaskServiceImpl.java b/ard-sample/src/main/java/com/ard/sample/wayline/service/impl/FlightTaskServiceImpl.java
index 3f7a629..2d3e6a2 100644
--- a/ard-sample/src/main/java/com/ard/sample/wayline/service/impl/FlightTaskServiceImpl.java
+++ b/ard-sample/src/main/java/com/ard/sample/wayline/service/impl/FlightTaskServiceImpl.java
@@ -168,7 +168,7 @@
if (Objects.isNull(jobIdValue)) {
return;
}
- log.info("Check the timed tasks of the wayline. {}", jobIdValue);
+ log.info("检查 wayline 的定时任务。 {}", jobIdValue);
// format: {workspace_id}:{dock_sn}:{job_id}
String[] jobArr = String.valueOf(jobIdValue).split(RedisConst.DELIMITER);
double time = RedisOpsUtils.zScore(RedisConst.WAYLINE_JOB_TIMED_EXECUTE, jobIdValue);
@@ -204,8 +204,9 @@
long now = System.currentTimeMillis();
int offset = 30_000;
- // Expired tasks are deleted directly.
+ // 过期任务会直接删除。
if (time < now - offset) {
+ log.info("定时任务超时，jobId: {}", jobArr[1]);
RedisOpsUtils.zRemove(RedisConst.WAYLINE_JOB_TIMED_EXECUTE, jobIdValue);
waylineJobService.updateJob(WaylineJobDTO.builder()
.jobId(jobArr[1])
@@ -218,11 +219,11 @@
if (now <= time && time <= now + offset) {
try {
- waylineJobService.executeFlightTask(jobArr[2]);
+ waylineJobService.executeFlightTask(jobArr[1]);
} catch (Exception e) {
- log.info("The scheduled task delivery failed.");
+ log.info("计划中的任务交付失败了。jobId: {}，异常信息：{}", jobArr[1], e.getMessage());
waylineJobService.updateJob(WaylineJobDTO.builder()
- .jobId(jobArr[2])
+ .jobId(jobArr[1])
.status(WaylineJobStatusEnum.FAILED.getVal())
.executeTime(LocalDateTime.now())
.completedTime(LocalDateTime.now())
--
Gitblit v1.9.3