2025-10-17 zwy 接收机器状态信息时，将机场、飞行器工作状态入库更新，并将机场信息websocket发送给前端。

zhaowenyu

2025-10-17 6398918ca0f0a0471b4feec76341c168cbe58da8

 ard-sample/src/main/java/com/ard/sample/manage/service/impl/DeviceServiceImpl.java

@@ -256,6 +256,12 @@
                > 0;
    }

    /**
     * 发布状态回复消息
     *
     * @param sn 序列号
     * @param response 通用主题响应对象
     */
    @Override
    public void publishStatusReply(String sn, CommonTopicResponse<Object> response) {
        Map<String, Integer> result = new ConcurrentHashMap<>(1);
@@ -417,6 +423,12 @@
        this.pushDeviceUpdateTopo(allSessions, sn);
    }

    /**
     * 处理来自MQTT消息的OSD消息
     *
     * @param message 接收到的MQTT消息
     * @throws IOException 如果处理消息时出现IO异常
     */
    @Override
    @ServiceActivator(inputChannel = ChannelName.INBOUND_OSD)
    public void handleOSD(Message<?> message) {
@@ -559,6 +571,7 @@

    /**
     * Convert the received drone device object into a database entity object.
     * 将接收到的无人机设备对象转换为数据库实体对象。
     *
     * @param device
     * @return
@@ -623,6 +636,7 @@
                .nickname(entity.getNickname())
                .firmwareVersion(entity.getFirmwareVersion())
                .deptId(entity.getDeptId())
                .workType(entity.getWorkType())
                .workspaceName(entity.getDeptId() != null
                        ? Optional.ofNullable(sysDeptService.selectDeptById(entity.getDeptId()))
                        .map(SysDept::getDeptName)
@@ -658,6 +672,19 @@
    public Boolean updateDevice(DeviceDTO deviceDTO) {
        int update = mapper.update(this.deviceDTO2Entity(deviceDTO),
                new LambdaUpdateWrapper<DeviceEntity>().eq(DeviceEntity::getDeviceSn, deviceDTO.getDeviceSn()));
        return update > 0;
    }

    @Override
    public Boolean updateWorkType(String sn, Long workType) {
        // 方式1：使用LambdaUpdateWrapper（推荐，类型安全，避免字段名硬编码）
        LambdaUpdateWrapper<DeviceEntity> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();
        // 设置更新条件：deviceSn = 100
        lambdaUpdateWrapper.eq(DeviceEntity::getDeviceSn, sn)
                // 只更新status字段为"online"
                .set(DeviceEntity::getWorkType, workType);
        // 执行更新（第一个参数传null，因为更新字段已通过wrapper的set指定）
        int update = mapper.update(null, lambdaUpdateWrapper);
        return update > 0;
    }

@@ -781,6 +808,14 @@

    }

    /**
     * 根据域名分页获取已绑定的设备信息
     *
     * @param page      当前页码
     * @param pageSize  每页显示数量
     * @param domain    域名
     * @return PaginationData<DeviceDTO> 包含分页信息的设备DTO列表
     */
    @Override
    public PaginationData<DeviceDTO> getBoundDevicesWithDomain(Long page,
                                                               Long pageSize, Integer domain) {
@@ -788,7 +823,8 @@
        Page<DeviceEntity> pagination = mapper.selectPage(new Page<>(page, pageSize),
                new LambdaQueryWrapper<DeviceEntity>()
                        .eq(DeviceEntity::getDomain, domain)
                        .eq(DeviceEntity::getBoundStatus, true));
                        .isNotNull(DeviceEntity::getDeptId));
//                        .eq(DeviceEntity::getBoundStatus, true));
        List<DeviceDTO> devicesList = pagination.getRecords().stream().map(this::deviceEntityConvertToDTO)
                .peek(device -> {
                    device.setStatus(RedisOpsUtils.checkExist(RedisConst.DEVICE_ONLINE_PREFIX + device.getDeviceSn()));
@@ -814,6 +850,7 @@
        DeviceDTO device = DeviceDTO.builder()
                .deviceSn(deviceSn)
                .boundStatus(false)
                .deptId(null)
                .build();
        this.updateDevice(device);
    }
@@ -988,6 +1025,7 @@
                .childSn(dto.getChildDeviceSn())
                .domain(dto.getDomain())
                .firmwareVersion(dto.getFirmwareVersion())
                .workType(dto.getWorkType())
                .compatibleStatus(dto.getFirmwareStatus() == null ? null :
                        DeviceFirmwareStatusEnum.CONSISTENT_UPGRADE != DeviceFirmwareStatusEnum.find(dto.getFirmwareStatus()))
                .build();
@@ -1091,6 +1129,12 @@
    }


    /**
     * 处理获取机场组织信息的请求
     *
     * @param receiver 接收到的消息
     * @param headers 消息头
     */
    @ServiceActivator(inputChannel = ChannelName.INBOUND_REQUESTS_AIRPORT_ORGANIZATION_GET, outputChannel =
            ChannelName.OUTBOUND)
    public void replyOrganizationGet(CommonTopicReceiver receiver, MessageHeaders headers) {