| | |
| | | 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; |
| | | import com.ard.common.core.redis.RedisConst; |
| | | import com.ard.common.core.redis.RedisOpsUtils; |
| | | import com.ard.sample.component.websocket.enums.MessageType; |
| | | import com.ard.sample.component.websocket.handler.DockWebSocketHandler; |
| | | import com.ard.sample.component.websocket.model.BizCodeEnum; |
| | | import com.ard.sample.component.websocket.model.CustomWebSocketMessage; |
| | | import com.ard.sample.component.websocket.service.ISendMessageService; |
| | |
| | | private ObjectMapper mapper; |
| | | |
| | | @Autowired |
| | | private DockWebSocketHandler _dockWebSocketHandler; |
| | | |
| | | @Autowired |
| | | private ISendMessageService websocketMessageService; |
| | | |
| | | @Autowired |
| | |
| | | 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()); |
| | |
| | | .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); |
| | | } |
| | | |
| | | /** |