From 6b6364d2afb0ccfe59b8878d3f43adc6adf3e483 Mon Sep 17 00:00:00 2001
From: zhaowenyu <35589726@qq.com>
Date: Tue, 16 Dec 2025 14:47:58 +0800
Subject: [PATCH] 2025-12-16 zwy 优化-待执行的定时任务状态在立即任务执行时，不发送websocket消息
---
ard-sample/src/main/java/com/ard/sample/wayline/service/impl/FlightTaskServiceImpl.java | 48 ++++++++++++++++++++++++++----------------------
1 files changed, 26 insertions(+), 22 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 0907f99..3f7a629 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
@@ -172,30 +172,34 @@
// 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);
- // 取到待执行的定时任务ID，获取任务信息websocket发给前端
// region 取定时任务信息websocket发给前端
- // pending status状态待执行
- EventsReceiver<WaylineTaskProgressReceiver> eventsReceiver = new EventsReceiver<>();
- WaylineTaskProgressReceiver waylineTaskProgressReceiver = new WaylineTaskProgressReceiver();
- WaylineTaskProgressExt waylineTaskProgressExt = new WaylineTaskProgressExt();
- waylineTaskProgressExt.setFlightId(jobArr[1]);
- waylineTaskProgressReceiver.setStatus("pending");
- waylineTaskProgressReceiver.setExt(waylineTaskProgressExt);
- eventsReceiver.setOutput(waylineTaskProgressReceiver);
- eventsReceiver.setResult(ResponseResult.CODE_SUCCESS);
- eventsReceiver.setBid(IdUtils.simpleUUID());
- eventsReceiver.setSn(jobArr[0]);
- eventsReceiver.setGateway(jobArr[0]);
- eventsReceiver.setType(MessageType.STATUS.getType() + "-flighttask_progress");
- eventsReceiver.setMethod(EventsMethodEnum.FLIGHT_TASK_PROGRESS.getMethod());
- String json = "";
- try {
- json = mapper.writeValueAsString(eventsReceiver);
- } catch (Exception e) {
- e.printStackTrace();
+ // 定时任务执行前，判断有没有任务正在执行，在执行则不发送websocket消息
+ String key = RedisConst.WAYLINE_JOB_RUNNING_PREFIX + jobArr[0];
+ if (!RedisOpsUtils.checkExist(key)) {
+ // 取到待执行的定时任务ID，获取任务信息websocket发给前端
+ // pending status状态待执行
+ EventsReceiver<WaylineTaskProgressReceiver> eventsReceiver = new EventsReceiver<>();
+ WaylineTaskProgressReceiver waylineTaskProgressReceiver = new WaylineTaskProgressReceiver();
+ WaylineTaskProgressExt waylineTaskProgressExt = new WaylineTaskProgressExt();
+ waylineTaskProgressExt.setFlightId(jobArr[1]);
+ waylineTaskProgressReceiver.setStatus("pending");
+ waylineTaskProgressReceiver.setExt(waylineTaskProgressExt);
+ eventsReceiver.setOutput(waylineTaskProgressReceiver);
+ eventsReceiver.setResult(ResponseResult.CODE_SUCCESS);
+ eventsReceiver.setBid(IdUtils.simpleUUID());
+ eventsReceiver.setSn(jobArr[0]);
+ eventsReceiver.setGateway(jobArr[0]);
+ eventsReceiver.setType(MessageType.STATUS.getType() + "-flighttask_progress");
+ eventsReceiver.setMethod(EventsMethodEnum.FLIGHT_TASK_PROGRESS.getMethod());
+ String json = "";
+ try {
+ json = mapper.writeValueAsString(eventsReceiver);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ _dockWebSocketHandler.sendMessageToSubscribers(jobArr[0], MessageType.STATUS.getType(), json, "");
+ log.info("定时任务自定义状态为待执行，json: {}", json);
}
- _dockWebSocketHandler.sendMessageToSubscribers(jobArr[0], MessageType.STATUS.getType(), json, "");
- log.info("定时任务自定义状态为待执行，json: {}", json);
// endregion
long now = System.currentTimeMillis();
int offset = 30_000;
--
Gitblit v1.9.3