From 07edf1419915dcd06805570d3a0f8c2b18c5ad19 Mon Sep 17 00:00:00 2001 From: yq183 <645046984@qq.com> Date: Wed, 23 Apr 2025 11:12:05 +0800 Subject: [PATCH] 1 --- .../sample/wayline/service/impl/SDKWaylineService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dk-modules/sample/src/main/java/org/dromara/sample/wayline/service/impl/SDKWaylineService.java b/dk-modules/sample/src/main/java/org/dromara/sample/wayline/service/impl/SDKWaylineService.java index 227a16e..7fc2a21 100644 --- a/dk-modules/sample/src/main/java/org/dromara/sample/wayline/service/impl/SDKWaylineService.java +++ b/dk-modules/sample/src/main/java/org/dromara/sample/wayline/service/impl/SDKWaylineService.java @@ -125,7 +125,6 @@ public class SDKWaylineService extends AbstractWaylineService { fileEntityList.forEach(f->{ f.setStatus(DeviceQrtzConstants.QRTZ_FILE_STATUS_0); }); - deviceQrtzFileMapper.updateById(fileEntityList); } }else if(FlighttaskStatusEnum.OK == statusEnum){ //正常 @@ -133,13 +132,14 @@ public class SDKWaylineService extends AbstractWaylineService { fileEntityList.forEach(f->{ f.setStatus(DeviceQrtzConstants.QRTZ_FILE_STATUS_3); }); - deviceQrtzFileMapper.updateById(fileEntityList); } } waylineJobService.updateJob(job); waylineRedisService.delRunningWaylineJob(response.getGateway()); waylineRedisService.delPausedWaylineJob(response.getBid()); + deviceQrtzFileMapper.updateById(fileEntityList); } + webSocketMessageService.sendBatch(deviceOpt.get().getWorkspaceId(),UserTypeEnum.WEB.getVal(), BizCodeEnum.FLIGHT_TASK_PROGRESS.getCode(), eventsReceiver);