zhaowenyu
2025-12-03 97aed6e19bac0fefaaf0270ba94492228ebf0bb1
ard-sample/src/main/java/com/ard/sample/wayline/service/impl/FlightTaskServiceImpl.java
@@ -1,10 +1,13 @@
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;
@@ -48,6 +51,9 @@
    private ObjectMapper mapper;
    @Autowired
    private DockWebSocketHandler _dockWebSocketHandler;
    @Autowired
    private ISendMessageService websocketMessageService;
    @Autowired
@@ -66,13 +72,19 @@
                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());
@@ -122,6 +134,18 @@
                            .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);
    }
    /**