forked from uav/ard-uav-server
blame | history | patch | commit | commitdiff | ignore whitespace
zhaowenyu
2025-12-09 a0741df5a2cff792740d7d31f7101ba2339ba3ec 
 ard-sample/src/main/java/com/ard/sample/component/mqtt/handler/StateLiveStatusHandler.java


@@ -1,5 +1,7 @@


package com.ard.sample.component.mqtt.handler;




import com.ard.common.core.redis.RedisConst;


import com.ard.common.core.redis.RedisOpsUtils;


import com.ard.sample.component.mqtt.model.CommonTopicReceiver;


import com.ard.sample.component.mqtt.model.StateDataEnum;


import com.ard.sample.component.websocket.enums.MessageType;


@@ -24,8 +26,6 @@


public class StateLiveStatusHandler extends AbstractStateTopicHandler{




    @Autowired


    private DockWebSocketHandler _dockWebSocketHandler;


    @Autowired


    private IDeviceService _deviceService;




    protected StateLiveStatusHandler(@Autowired @Qualifier("stateFirmwareVersionHandler")AbstractStateTopicHandler handler) {


@@ -36,15 +36,14 @@


    public CommonTopicReceiver handleState(Map<String, Object> dataNode, CommonTopicReceiver stateReceiver, String sn) throws JsonProcessingException {


        if (dataNode.containsKey(StateDataEnum.LIVESTATUS.getDesc())) {


            stateReceiver.setType(MessageType.LIVESTATUS.getType());


            String deviceSn= stateReceiver.getGateway();


            DeviceQueryParam param = DeviceQueryParam.builder().deviceSn(deviceSn).build();


            List<DeviceDTO> deviceDTOS = _deviceService.getDevicesByParams(param);


            if(deviceDTOS!=null && deviceDTOS.size()>0)


            DeviceDTO device = (DeviceDTO) RedisOpsUtils.get(RedisConst.DEVICE_ONLINE_PREFIX + sn);


            if(device != null)


            {


                String childSn = deviceDTOS.get(0).getChildDeviceSn();


                List<LiveStatusTwoReceiver> list = mapper.convertValue(dataNode.get(StateDataEnum.LIVESTATUS.getDesc()), new TypeReference<List<LiveStatusTwoReceiver>>() {});


                String childSn = device.getChildDeviceSn();


                List<LiveStatusTwoReceiver> list = mapper.convertValue(dataNode.get(StateDataEnum.LIVESTATUS.getDesc()),


                        new TypeReference<List<LiveStatusTwoReceiver>>() {});


                for (LiveStatusTwoReceiver receiver : list) {


                    if(receiver.getVideoId().contains(childSn)){


                    if(receiver.getVideoId()!=null && receiver.getVideoId().contains(childSn)){


                        stateReceiver.setData(receiver);


                        continue;


                    }