| | |
| | | // jobid、status字段赋值 |
| | | if (!listTask.isEmpty()) { |
| | | String json = listTask.get(listTask.size() - 1); |
| | | EventsReceiver<WaylineTaskProgressReceiver> eventsReceiver = mapper.convertValue(json, |
| | | log.info("当前任务记录最后一条数据:{}", json); |
| | | try { |
| | | EventsReceiver<WaylineTaskProgressReceiver> eventsReceiver = mapper.readValue(json, |
| | | new TypeReference<EventsReceiver<WaylineTaskProgressReceiver>>() { |
| | | }); |
| | | jobId = eventsReceiver.getOutput().getExt().getFlightId(); |
| | | isOK = eventsReceiver.getOutput().getStatus(); |
| | | |
| | | log.info("当前任务jobId:{},任务执行进度isOK:{}", jobId, isOK); |
| | | } catch (Exception e) { |
| | | log.error("解析任务状态JSON失败: {}", e.getMessage()); |
| | | log.error("JSON内容: {}", json); |
| | | } |
| | | } |
| | | if (listTrajectory.size() >= CHUNK_SIZE || listTask.size() >= CHUNK_SIZE) { |
| | | progress = Convert.toStr(pro + 1); |