forked from uav/ard-uav-server
blame | history | patch | commit | commitdiff | ignore whitespace
zhaowenyu
2026-01-16 aafd104dd7de1db565cd2081e8eb445d7a1bd481 
 ard-sample/src/main/java/com/ard/sample/manage/service/impl/DeviceOSDServiceImpl.java


@@ -17,6 +17,7 @@


import com.ard.sample.manage.model.receiver.OsdPayloadReceiver;


import com.ard.sample.manage.model.receiver.OsdSubDeviceReceiver;


import com.ard.sample.manage.service.IDeviceService;


import com.ard.sample.manage.service.IWaylineTrajectoryService;


import com.fasterxml.jackson.core.JsonProcessingException;


import com.fasterxml.jackson.databind.JsonNode;


import com.fasterxml.jackson.databind.node.ObjectNode;


@@ -41,6 +42,9 @@




    @Autowired


    private IDeviceService _deviceService;




    @Autowired


    private IWaylineTrajectoryService _waylineTrajectoryService;




    @Autowired


    private DockWebSocketHandler _dockWebSocketHandler;


@@ -118,6 +122,9 @@


            // 发送给websocket客户端


            _dockWebSocketHandler.sendMessageToSubscribers(device.getDeviceSn(), MessageType.STATUS.getType(), dockOsd, "");




            // 将飞行器的OSD数据dockOsd入库；device.getDeviceSn()为飞行器sn,这里要机场的sn，试试receiver.getGateway();


            _waylineTrajectoryService.setList(receiver.getGateway(),"0", dockOsd);




            sendMessageService.sendBatch(webSessions, wsMessage);


            this.pushTelemetryData(data, device.getDeviceSn());


        }