| | |
| | | > 0; |
| | | } |
| | | |
| | | /** |
| | | * 发布状态回复消息 |
| | | * |
| | | * @param sn 序列号 |
| | | * @param response 通用主题响应对象 |
| | | */ |
| | | @Override |
| | | public void publishStatusReply(String sn, CommonTopicResponse<Object> response) { |
| | | Map<String, Integer> result = new ConcurrentHashMap<>(1); |
| | |
| | | this.pushDeviceUpdateTopo(allSessions, sn); |
| | | } |
| | | |
| | | /** |
| | | * 处理来自MQTT消息的OSD消息 |
| | | * |
| | | * @param message 接收到的MQTT消息 |
| | | * @throws IOException 如果处理消息时出现IO异常 |
| | | */ |
| | | @Override |
| | | @ServiceActivator(inputChannel = ChannelName.INBOUND_OSD) |
| | | public void handleOSD(Message<?> message) { |
| | |
| | | |
| | | /** |
| | | * Convert the received drone device object into a database entity object. |
| | | * 将接收到的无人机设备对象转换为数据库实体对象。 |
| | | * |
| | | * @param device |
| | | * @return |
| | |
| | | return null; |
| | | } |
| | | DeviceDTO.DeviceDTOBuilder deviceDTOBuilder = DeviceDTO.builder() |
| | | .id(entity.getId()) |
| | | .deviceSn(entity.getDeviceSn()) |
| | | .childDeviceSn(entity.getChildSn()) |
| | | .deviceName(entity.getDeviceName()) |
| | |
| | | |
| | | } |
| | | |
| | | /** |
| | | * 根据域名分页获取已绑定的设备信息 |
| | | * |
| | | * @param page 当前页码 |
| | | * @param pageSize 每页显示数量 |
| | | * @param domain 域名 |
| | | * @return PaginationData<DeviceDTO> 包含分页信息的设备DTO列表 |
| | | */ |
| | | @Override |
| | | public PaginationData<DeviceDTO> getBoundDevicesWithDomain(Long page, |
| | | Long pageSize, Integer domain) { |
| | |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 处理获取机场组织信息的请求 |
| | | * |
| | | * @param receiver 接收到的消息 |
| | | * @param headers 消息头 |
| | | */ |
| | | @ServiceActivator(inputChannel = ChannelName.INBOUND_REQUESTS_AIRPORT_ORGANIZATION_GET, outputChannel = |
| | | ChannelName.OUTBOUND) |
| | | public void replyOrganizationGet(CommonTopicReceiver receiver, MessageHeaders headers) { |