|
@ -125,7 +125,6 @@ public class SDKWaylineService extends AbstractWaylineService { |
|
|
fileEntityList.forEach(f->{ |
|
|
fileEntityList.forEach(f->{ |
|
|
f.setStatus(DeviceQrtzConstants.QRTZ_FILE_STATUS_0); |
|
|
f.setStatus(DeviceQrtzConstants.QRTZ_FILE_STATUS_0); |
|
|
}); |
|
|
}); |
|
|
deviceQrtzFileMapper.updateById(fileEntityList); |
|
|
|
|
|
} |
|
|
} |
|
|
}else if(FlighttaskStatusEnum.OK == statusEnum){ |
|
|
}else if(FlighttaskStatusEnum.OK == statusEnum){ |
|
|
//正常
|
|
|
//正常
|
|
@ -133,13 +132,14 @@ public class SDKWaylineService extends AbstractWaylineService { |
|
|
fileEntityList.forEach(f->{ |
|
|
fileEntityList.forEach(f->{ |
|
|
f.setStatus(DeviceQrtzConstants.QRTZ_FILE_STATUS_3); |
|
|
f.setStatus(DeviceQrtzConstants.QRTZ_FILE_STATUS_3); |
|
|
}); |
|
|
}); |
|
|
deviceQrtzFileMapper.updateById(fileEntityList); |
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
waylineJobService.updateJob(job); |
|
|
waylineJobService.updateJob(job); |
|
|
waylineRedisService.delRunningWaylineJob(response.getGateway()); |
|
|
waylineRedisService.delRunningWaylineJob(response.getGateway()); |
|
|
waylineRedisService.delPausedWaylineJob(response.getBid()); |
|
|
waylineRedisService.delPausedWaylineJob(response.getBid()); |
|
|
|
|
|
deviceQrtzFileMapper.updateById(fileEntityList); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
webSocketMessageService.sendBatch(deviceOpt.get().getWorkspaceId(),UserTypeEnum.WEB.getVal(), |
|
|
webSocketMessageService.sendBatch(deviceOpt.get().getWorkspaceId(),UserTypeEnum.WEB.getVal(), |
|
|
BizCodeEnum.FLIGHT_TASK_PROGRESS.getCode(), eventsReceiver); |
|
|
BizCodeEnum.FLIGHT_TASK_PROGRESS.getCode(), eventsReceiver); |
|
|
|
|
|
|
|
|