package com.hdl.sdk.link.core.connect;

import com.google.gson.JsonObject;
import com.hdl.sdk.link.common.config.TopicConstant;
import com.hdl.sdk.link.common.exception.HDLLinkException;
import com.hdl.sdk.link.common.utils.IdUtils;
import com.hdl.sdk.link.common.utils.LogUtils;
import com.hdl.sdk.link.common.utils.gson.GsonConvert;
import com.hdl.sdk.link.core.bean.LinkRequest;
import com.hdl.sdk.link.core.bean.LinkResponse;
import com.hdl.sdk.link.core.bean.gateway.GatewayBean;
import com.hdl.sdk.link.core.bean.request.BroadcastRequest;
import com.hdl.sdk.link.core.callback.HDLLinkResponseCallBack;
import com.hdl.sdk.link.core.config.HDLLinkConfig;
import com.hdl.sdk.link.core.protocol.LinkMessageDecoder;
import com.hdl.sdk.link.core.protocol.LinkMessageEncoder;
import com.hdl.sdk.link.gateway.HDLLinkLocalGateway;
import com.hdl.sdk.link.socket.TcpSocketBoot;
import com.hdl.sdk.link.socket.SocketOptions;
import com.hdl.sdk.link.socket.client.IHeartbeat;
import com.hdl.sdk.link.socket.client.TcpClient;
import com.hdl.sdk.link.socket.codec.MessagePipeLine;
import com.hdl.sdk.link.socket.listener.ConnectStatusListener;

/**
 * Created by Tong on 2021/9/26.
 * 1、通过Udp 组播或者广播搜索网关
 * 2、通过Udp 获取Tcp ip 端口统一8586
 */
public class HDLTcpConnect {

    /**
     * tcp默认端口
     */
    private static final int TCP_PORT = 8586;


    private ConnectStatusListener statusListener;

    private HDLTcpConnect() {
        statusListener = new ConnectStatusListener() {
            @Override
            public void onConnecting() {
                broadcastRequest();
            }

            @Override
            public void onConnected() {

            }

            @Override
            public void onConnectFailed() {

            }
        };
    }

    /**
     * 广播自身信息给主网关
     */
    private void broadcastRequest() {
        String time = String.valueOf(System.currentTimeMillis());
        if (null == HDLLinkConfig.getInstance().getDeviceInfoBean()) {
            LogUtils.i("DeviceInfoBean为空，请设置当前对象");
            return;
        }
        BroadcastRequest request = new BroadcastRequest(IdUtils.getUUId(), time, HDLLinkConfig.getInstance().getDeviceInfoBean(), "200");
        HDLUdpConnect.getInstance().udpSendMsg(TopicConstant.BROADCAST, GsonConvert.getGson().toJson(request), true);
        HDLUdpConnect.getInstance().udpSendMsg(TopicConstant.BROADCAST, GsonConvert.getGson().toJson(request), true, new HDLLinkResponseCallBack() {
            @Override
            public void onSuccess(LinkResponse msg) {
                LogUtils.i("广播信息给主网关成功！");
            }

            @Override
            public void onError(HDLLinkException e) {

            }
        });
        HDLUdpConnect.getInstance().udpSendMsg(TopicConstant.BROADCAST, GsonConvert.getGson().toJson(request), true);
    }

    private static class SingletonInstance {
        private static final HDLTcpConnect INSTANCE = new HDLTcpConnect();
    }

    public static HDLTcpConnect getInstance() {
        return SingletonInstance.INSTANCE;
    }

    /**
     * 通过IP及端口找出连接客户端，如果当前没有连接。主要是针对调试软件使用，支持连接主网关、从网关
     *
     * @param ip 连接的网关IP
     * @return
     */
    public static synchronized TcpSocketBoot getTcpSocketBoot(String ip) {
        return initTcp(ip);
    }

    static  int dddd;
    /**
     * 初始化tcp连接
     *
     * @param ip 连接的网关IP
     * @return
     */
    public static synchronized TcpSocketBoot initTcp(String ip) {
        int port = TCP_PORT;
        TcpSocketBoot tcpSocketBoot = TcpSocketBoot.getByEndPoint(ip, port);

        if (null == tcpSocketBoot) {
            final SocketOptions options = new SocketOptions();
            final MessagePipeLine pipeLine = new MessagePipeLine();
            pipeLine.add(new LinkMessageDecoder());
            pipeLine.add(new LinkMessageEncoder());
            options.setHandleMessage(pipeLine);
            tcpSocketBoot = TcpClient.init(ip, port, options);
            tcpSocketBoot.SetHeartbeat(new IHeartbeat() {
                @Override
                public void heartbeat() {

                    String time = String.valueOf(System.currentTimeMillis());

                    JsonObject jsonObject = new JsonObject();
                    jsonObject.addProperty("id", IdUtils.getUUId());
                    jsonObject.addProperty("time_stamp", time);

                    GatewayBean gatewayBean= HDLLinkLocalGateway.getInstance().getGatewayByOidOrGatewayId(ip);
                    if(gatewayBean==null){
                        return;
                    }
                    String topic = String.format(TopicConstant.HEARTBEAT, gatewayBean.getOid());

                    LinkRequest request = new LinkRequest(topic, jsonObject.toString(), false);
                    new HDLConnectHelper(ip, request, null, true).send();
                }
            });
        }
        return tcpSocketBoot;
    }
}