| | |
| | | package com.ard.sample.wayline.service.impl; |
| | | |
| | | import com.ard.sample.common.error.CommonErrorEnum; |
| | | import com.ard.sample.common.model.ResponseResult; |
| | | import com.ard.sample.component.mqtt.model.*; |
| | | import com.ard.sample.component.mqtt.service.IMessageSenderService; |
| | |
| | | new TypeReference<EventsReceiver<WaylineTaskProgressReceiver>>(){}); |
| | | eventsReceiver.setBid(receiver.getBid()); |
| | | eventsReceiver.setSn(receiver.getGateway()); |
| | | eventsReceiver.setGateway(receiver.getGateway()); |
| | | eventsReceiver.setType(MessageType.STATUS.getType()+"-flighttask_progress"); |
| | | eventsReceiver.setMethod(EventsMethodEnum.FLIGHT_TASK_PROGRESS.getMethod()); |
| | | |
| | | |
| | | |
| | | WaylineTaskProgressReceiver output = eventsReceiver.getOutput(); |
| | | |
| | | log.info("Task progress: {}", output.getProgress().toString()); |
| | | |
| | | if (eventsReceiver.getResult() != ResponseResult.CODE_SUCCESS) { |
| | | log.error("Task progress ===> Error code: " + eventsReceiver.getResult()); |
| | | String errorMsg = CommonErrorEnum.getMsgByCode(eventsReceiver.getResult()); |
| | | log.error("Task progress ===> Error code: {},Error Msg: {}", eventsReceiver.getResult(),errorMsg); |
| | | } |
| | | |
| | | EventsResultStatusEnum statusEnum = EventsResultStatusEnum.find(output.getStatus()); |
| | |
| | | .bizCode(BizCodeEnum.FLIGHT_TASK_PROGRESS.getCode()) |
| | | .build()); |
| | | |
| | | String json=""; |
| | | try { |
| | | json = mapper.writeValueAsString(eventsReceiver); |
| | | } |
| | | catch (Exception e){ |
| | | e.printStackTrace(); |
| | | } |
| | | _dockWebSocketHandler.sendMessageToSubscribers(dockSn, MessageType.STATUS.getType(),json); |
| | | |
| | | if (receiver.getNeedReply()!=null &&receiver.getNeedReply() == 1) { |
| | | messageSender.publish(receivedTopic + TopicConst._REPLY_SUF, |
| | | CommonTopicResponse.builder() |
| | |
| | | .data(RequestsReply.success()) |
| | | .build()); |
| | | } |
| | | |
| | | // 进度 |
| | | if(eventsReceiver.getOutput().getProgress().getPercent()>=95){ |
| | | return; |
| | | } |
| | | String json=""; |
| | | try { |
| | | json = mapper.writeValueAsString(eventsReceiver); |
| | | } |
| | | catch (Exception e){ |
| | | e.printStackTrace(); |
| | | } |
| | | _dockWebSocketHandler.sendMessageToSubscribers(dockSn, MessageType.STATUS.getType(),json); |
| | | } |
| | | |
| | | /** |