| | |
| | | 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; |
| | |
| | | |
| | | @Autowired |
| | | private IDeviceService _deviceService; |
| | | |
| | | @Autowired |
| | | private IWaylineTrajectoryService _waylineTrajectoryService; |
| | | |
| | | @Autowired |
| | | private DockWebSocketHandler _dockWebSocketHandler; |
| | |
| | | // 发送给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()); |
| | | } |