Pārlūkot izejas kodu

Merge branch 'develop' of gitadmin/tuoheng_lc into release

tags/v1.2.0^2
wanjing pirms 1 gada
vecāks
revīzija
c539943cf7
2 mainītis faili ar 9 papildinājumiem un 2 dzēšanām
  1. +1
    -1
      tuoheng-admin/src/main/java/com/tuoheng/admin/service/third/UpdateEmergencyMissionStatusService.java
  2. +8
    -1
      tuoheng-admin/src/main/java/com/tuoheng/admin/service/third/airport/AirportCallBackUpdateStatusService.java

+ 1
- 1
tuoheng-admin/src/main/java/com/tuoheng/admin/service/third/UpdateEmergencyMissionStatusService.java Parādīt failu

* @param oldMission * @param oldMission
*/ */
public void updateStatus(ThMission oldMission, Integer status) { public void updateStatus(ThMission oldMission, Integer status) {
log.info("进入修改应急任务数据");
log.info("进入修改应急任务数据, type:{}, emergencyDataMissionId:{}, status={}", oldMission.getType()), oldMission.getEmergencyDataMissionId(), status);
if (1 == oldMission.getType()) { if (1 == oldMission.getType()) {
return; return;
} }

+ 8
- 1
tuoheng-admin/src/main/java/com/tuoheng/admin/service/third/airport/AirportCallBackUpdateStatusService.java Parādīt failu



Integer status = null; Integer status = null;
if (AirPortTaskStatusEnum.FLIGHT.getCode() == missionStatusRequest.getStatus()) { if (AirPortTaskStatusEnum.FLIGHT.getCode() == missionStatusRequest.getStatus()) {
log.info("被硬件调用,存任务状态:执行中");
// ThMission thMission = getRecentlyRecord(missionStatusRequest,TaskStatusEnum.WAIT.getCode()); // ThMission thMission = getRecentlyRecord(missionStatusRequest,TaskStatusEnum.WAIT.getCode());
Assert.notNull(thMission, "飞行任务不能为空!"); Assert.notNull(thMission, "飞行任务不能为空!");
ThMission thMissionUpdate = setStatus(missionStatusRequest, thMission, AirPortTaskStatusEnum.FLIGHT); ThMission thMissionUpdate = setStatus(missionStatusRequest, thMission, AirPortTaskStatusEnum.FLIGHT);
try { try {
//开始分析 //开始分析
log.info("被硬件调用,存任务状态:开始分析");
JSONObject jsonObject = this.startAI(missionStatusRequest); JSONObject jsonObject = this.startAI(missionStatusRequest);
thMissionUpdate.setRequestId(jsonObject.getJSONObject("data").getString("requestId")); thMissionUpdate.setRequestId(jsonObject.getJSONObject("data").getString("requestId"));
thMissionUpdate.setAipullUrl(jsonObject.getJSONObject("data").getString("aipullUrl")); thMissionUpdate.setAipullUrl(jsonObject.getJSONObject("data").getString("aipullUrl"));
thMissionUpdate.setAiplayUrl(jsonObject.getJSONObject("data").getString("aiplayUrl")); thMissionUpdate.setAiplayUrl(jsonObject.getJSONObject("data").getString("aiplayUrl"));
thMissionUpdate.setAnalyseStatus(AiAnalyseStatusEnum.WAITING.getCode()); thMissionUpdate.setAnalyseStatus(AiAnalyseStatusEnum.WAITING.getCode());


log.info("修改飞行状态:{}", JSONObject.toJSONString(thMissionUpdate));
log.info("被硬件调用,原任务状态:status:{}", thMission.getStatus());
thMissionMapper.updateById(thMissionUpdate); thMissionMapper.updateById(thMissionUpdate);


status = TaskStatusEnum.FLIGHT.getCode(); status = TaskStatusEnum.FLIGHT.getCode();
} }
updateEmergencyMissionStatusService.updateStatus(thMission, status); updateEmergencyMissionStatusService.updateStatus(thMission, status);
} else if (AirPortTaskStatusEnum.WAIT.getCode() == missionStatusRequest.getStatus()) { } else if (AirPortTaskStatusEnum.WAIT.getCode() == missionStatusRequest.getStatus()) {
log.info("被硬件调用,存任务状态:已完成");
// 机场飞行完成,立即修改任务状态为已完成 // 机场飞行完成,立即修改任务状态为已完成
ThMission thMissionUpdate = new ThMission(UpdateOrCreateEnum.UPDATE.getCode()); ThMission thMissionUpdate = new ThMission(UpdateOrCreateEnum.UPDATE.getCode());
thMissionUpdate.setId(Integer.parseInt(missionStatusRequest.getRequestId())); thMissionUpdate.setId(Integer.parseInt(missionStatusRequest.getRequestId()));
thMissionUpdate.setWeather(""); thMissionUpdate.setWeather("");
log.info("获取天气信息失败,请重试"); log.info("获取天气信息失败,请重试");
} }

log.info("被硬件调用,任务状态:status:{}", thMissionUpdate.getStatus());
thMissionMapper.updateById(thMissionUpdate); thMissionMapper.updateById(thMissionUpdate);


status = TaskStatusEnum.COMPLETE.getCode(); status = TaskStatusEnum.COMPLETE.getCode();
} }


private JSONObject startAI(MissionStatusRequest missionStatusRequest) throws ServiceException { private JSONObject startAI(MissionStatusRequest missionStatusRequest) throws ServiceException {
log.info("开始AI分析");
//任务调用完成之后,调用发送通道,请求DSP需要分析 //任务调用完成之后,调用发送通道,请求DSP需要分析
//调用DSP接口 //调用DSP接口
JSONObject request = new JSONObject(); JSONObject request = new JSONObject();
} }


private Boolean stopAI(MissionStatusRequest missionStatusRequest, ThMission thMission) { private Boolean stopAI(MissionStatusRequest missionStatusRequest, ThMission thMission) {
log.info("停止AI分析");
Assert.notNull(thMission, "飞行任务不能为空!"); Assert.notNull(thMission, "飞行任务不能为空!");
ThMission thMissionUpdate = new ThMission(UpdateOrCreateEnum.UPDATE.getCode()); ThMission thMissionUpdate = new ThMission(UpdateOrCreateEnum.UPDATE.getCode());
thMissionUpdate.setId(thMission.getId()); thMissionUpdate.setId(thMission.getId());

Notiek ielāde…
Atcelt
Saglabāt