增加回复指令通过websocket返回给前端

liusuyi

2025-10-22 1a09dd79bd0b156ceb13470c312e44e522238780

增加回复指令通过websocket返回给前端

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

@@ -155,7 +155,7 @@
                    String serverId = (String) channel.attr(AttributeKey.valueOf("serverId")).get();
                    HeartbeatCmd heartbeat = new HeartbeatCmd(timestamp);
                    channel.writeAndFlush(heartbeat);
                    log.info("→ 向边缘服务器 [{}]发送心跳，时间戳={}", serverId, timestamp);
                    log.info("❤\uFE0F 向边缘服务器 [{}]发送心跳，时间戳={}", serverId, timestamp);
                });
    }
}

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

@@ -23,6 +23,7 @@
import com.ard.work.component.netty.command.wayline.*;
import com.ard.work.component.netty.handler.ErrorCodeEnum;
import com.ard.work.component.netty.protobuf.TelemetryDataPB;
import com.ard.work.component.websocket.utils.WebSocketUtil;
import com.ard.work.domain.cache.UavSignalInfoCache;
import com.ard.work.domain.cache.UavStateCache;
import com.ard.work.domain.cache.UavTelemetryDataCache;
@@ -901,21 +902,27 @@

    //公共日志打印
    private void logPrint(String message, Object obj) {
        log.debug("收到{}回复{}", message, obj);
        String text = String.format("收到%s回复%s", message, obj);
        WebSocketUtil.sendMessageAll(text);
        log.info(text);
    }

    //公共日志打印
    private void logPrint(String message, byte result, Integer errorCode) {
        log.info("收到{}回复:{} 错误码：{}【{}】",
        String text = String.format(
                "收到%s回复:%s 错误码：%d【%s】",
                message,
                ByteUtils.byteToHex(result),
                errorCode,
                ErrorCodeEnum.getDescByCode(errorCode));
                ErrorCodeEnum.getDescByCode(errorCode)
        );
        WebSocketUtil.sendMessageAll(text);
        log.info(text);
    }


    /**
     * 发送消息
     * 发送tcp消息
     */
    private void sendMessage(String key, BaseCmd msg) {
        TcpClientUtil.sendMessage(key, msg);