| | |
| | | package com.ard.sample.wayline.service.impl; |
| | | |
| | | import com.ard.common.utils.uuid.IdUtils; |
| | | import com.ard.route.domain.route.ArdRouteInfo; |
| | | import com.ard.route.service.IArdRouteInfoService; |
| | | import com.ard.route.service.IArdRouteMissionService; |
| | | import com.ard.sample.common.error.CommonErrorEnum; |
| | | import com.ard.sample.common.model.ResponseResult; |
| | | import com.ard.sample.component.mqtt.model.*; |
| | |
| | | |
| | | @Autowired |
| | | private IWaylineJobHistoryService _waylineJobHistoryService; |
| | | |
| | | @Autowired |
| | | private IArdRouteMissionService _ardRouteMissionService; |
| | | |
| | | @Autowired |
| | | private IArdRouteInfoService _ardRouteInfoService; |
| | | |
| | | @Override |
| | | @ServiceActivator(inputChannel = ChannelName.INBOUND_EVENTS_FLIGHT_TASK_PROGRESS, outputChannel = ChannelName.OUTBOUND) |
| | |
| | | if(jobHistory.isPresent()) { |
| | | log.info("任务执行成功,保存到历史记录。 {}", jobHistory); |
| | | } |
| | | |
| | | // 同步更新4.2的计划任务的状态;等待夏吉建的接口。1:已执行 0:未执行 |
| | | // 在任务中查找航线文件id,取航线文件信息中的状态,是3的修改状态 |
| | | ArdRouteInfo ardRouteInfo = _ardRouteInfoService.selectArdRouteInfoById(job.get().getFileId()); |
| | | if(ardRouteInfo != null && ardRouteInfo.getType().equals("3")) { |
| | | _ardRouteMissionService.updateArdRouteMissionStatus(jobId, "1"); |
| | | log.info("任务航线-执行成功,更新航线状态。 jobId:{}", jobId); |
| | | } |
| | | } |
| | | |
| | | } |