package com.ard.work.component.netty;

import com.ard.work.component.netty.command.BaseCmd;
import com.ard.work.component.netty.cache.TyTcpServerCache;
import io.netty.channel.Channel;
import lombok.extern.slf4j.Slf4j;
import java.net.InetSocketAddress;

/**
 * Description:
 * Author: lsy
 * Date: 2025年10月17日14:27
 **/
@Slf4j
public class TcpClientUtil {

    /**
     * 向指定边缘服务器发送消息
     */
    public static void sendMessage(String serverId, BaseCmd msg) {
        try {
            Channel channel = TyTcpServerCache.getChannel(serverId);
            if (channel == null) {
                log.error("未找到边缘服务器 [{}] 的连接", serverId);
                return;
            }

            if (!channel.isActive()) {
                log.warn("边缘服务器 [{}] 连接未激活，无法发送消息", serverId);
                return;
            }

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