1.修改名称(天宇 ——》六合)。

Xiajijian

2025-10-13 e90fcceee583f9428b40a551c31ae29a3492f2bf

1.修改名称(天宇 ——》六合)。

 ard-work/src/main/java/com/ard/work/component/netty/TyTcpClientManager.java

@@ -62,7 +62,7 @@
    }

    /**
     * 初始化与天宇服务器的连接
     * 初始化与六合服务器的连接
     */
    public void initConnection(String serverId, String host, Integer port) {
        String key = host + ":" + port;
@@ -113,23 +113,23 @@
        try {
            TcpClientSession session = channels.get(serverId);
            if (session == null) {
                log.error("未找到天宇服务器 [{}] 的连接", serverId);
                log.error("未找到六合服务器 [{}] 的连接", serverId);
                return;
            }

            ChannelFuture future = session.getChannelFuture();
            if (future == null || !future.channel().isActive()) {
                log.warn("天宇服务器 [{}] 连接未激活，无法发送消息", serverId);
                log.warn("六合服务器 [{}] 连接未激活，无法发送消息", serverId);
                return;
            }

            InetSocketAddress remote = (InetSocketAddress) future.channel().remoteAddress();
            future.channel().writeAndFlush(msg);
            log.debug("→ 向天宇服务器 [{}] ({}:{}) 发送消息，命令码：0x{}",
            log.debug("→ 向六合服务器 [{}] ({}:{}) 发送消息，命令码：0x{}",
                    serverId, remote.getHostString(), remote.getPort(),
                    String.format("%02X", msg.getCmdCode() & 0xFF));
        } catch (Exception e) {
            log.error("发送消息到天宇服务器 [{}] 异常：{}", serverId, e.getMessage());
            log.error("发送消息到六合服务器 [{}] 异常：{}", serverId, e.getMessage());
        }
    }


 ard-work/src/main/java/com/ard/work/domain/entity/ArdDroneInfo.java

@@ -15,7 +15,6 @@
 * @author ruoyi
 * @date 2025-03-04
 */

@Data
@Builder
@AllArgsConstructor

 ard-work/src/main/java/com/ard/work/mapper/ArdDroneInfoMapper.java

@@ -11,6 +11,7 @@
 * @date 2025-03-04
 */
public interface ArdDroneInfoMapper {

    /**
     * 查询无人机盒子
     *
@@ -18,6 +19,13 @@
     * @return 无人机盒子
     */
    ArdDroneInfo selectArdDroneById(String id);

    /**
     * 查询无人机盒子
     *
     * @param boxSn 盒子编码
     * @return 无人机盒子
     */
    ArdDroneInfo selectArdDroneByBoxSn(String boxSn);
    /**
     * 查询无人机盒子列表

 ard-work/src/main/java/com/ard/work/service/impl/ArdDroneServiceImpl.java

@@ -42,6 +42,12 @@
        return ArdDroneInfoMapper.selectArdDroneById(id);
    }

    /**
     * 查询无人机盒子
     *
     * @param boxSn 盒子编码
     * @return 无人机盒子
     */
    @Override
    public ArdDroneInfo selectArdDroneByboxSn(String boxSn) {
        return ArdDroneInfoMapper.selectArdDroneByBoxSn(boxSn);

 ard-work/src/main/java/com/ard/work/service/impl/TyServiceImpl.java

@@ -90,7 +90,6 @@
     */
    @Override
    public AccessTokenReceiver getAccessToken(String serverId) {

        return ardServerService.getAccessToken(serverId);
    }

@@ -125,7 +124,6 @@
     */
    @Override
    public BoxStreamUrlReceiver getBoxLiveUrl(String boxSn) {

        ArdDroneInfo ardDroneInfo = ardDroneService.selectArdDroneByboxSn(boxSn);
        String baseUrl="http://"+ardDroneInfo.getArdServerInfo().getHost()+":"+ardDroneInfo.getArdServerInfo().getHttpPort();
        TyHttpCommonReceiver<BoxStreamUrlReceiver> boxLiveUrl = tyClient.getBoxLiveUrl(baseUrl,boxSn);
@@ -869,7 +867,7 @@


    /**
     * 定时向所有已连接的天宇服务器发送心跳
     * 定时向所有已连接的六合服务器发送心跳
     */
    @Scheduled(fixedRate = 5000) // 每5秒执行一次
    public void sendHeartBeat() {