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


import android.text.TextUtils;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.hdl.link.error.ErrorUtils;
import com.hdl.link.error.HDLLinkCode;
import com.hdl.sdk.link.common.event.EventDispatcher;
import com.hdl.sdk.link.common.event.EventListener;
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.RealLinkResponse;
import com.hdl.sdk.link.core.bean.gateway.GatewayBean;
import com.hdl.sdk.link.core.bean.response.BaseLocalResponse;
import com.hdl.sdk.link.core.callback.RealLinkCallBack;
import com.hdl.sdk.link.core.config.HDLLinkConfig;
import com.hdl.sdk.link.gateway.HDLLinkLocalGateway;

import java.util.ArrayList;
import java.util.List;

/**
 * Created by hxb on 2021/12/8.
 * 原生通讯相关接口
 */
public class HDLRealLinkConnect {

    private static final String TAG = "HDLRealLinkConnect";
    private static HDLRealLinkConnect instance;

    /**
     * 返回当前实例，不存在就创建并同时注册监听事件
     *
     * @return
     */
    public static HDLRealLinkConnect getInstance() {
        if (null == instance) {
            instance = new HDLRealLinkConnect();
            instance.initEventListener();
        }
        return instance;
    }

    /**
     * 初始化监听事件
     */
    private void initEventListener() {
        final EventListener eventListener = new EventListener() {
            @Override
            public void onMessage(Object msg) {
                try {
                    if (msg instanceof LinkResponse) {
                        LinkResponse linkResponse = (LinkResponse) msg;
                        //透传数据不处理
                        if (linkResponse.getTopic() == null || linkResponse.getTopic().contains("/custom/native/")) {
                            return;
                        }

                        JSONObject jsonObject = JSON.parseObject(linkResponse.getData());
                        String id = jsonObject.getString("id");
                        Integer code = jsonObject.getInteger("code");
                        RealLinkResponse realLinkResponse = new RealLinkResponse();
                        String topic = String.format(linkResponse.getTopic() + "/s%", id);//用topic+信息id表示唯一
                        realLinkResponse.setTopic(topic);
                        realLinkResponse.setData(linkResponse.getData());
                        realLinkResponse.setByteData(linkResponse.getByteData());
                        realLinkResponse.setHdlLinkCode(ErrorUtils.getByCode(code));
                        String oid = linkResponse.getTopic().split("/")[2];
                        //是否是通过主网关透传主题
                        if (linkResponse.getTopic().contains("/slaveoid/")) {
                            oid = linkResponse.getTopic().split("/")[8];
                        }
                        realLinkResponse.setOid(oid);
                        for (GatewayBean gatewayBean : HDLLinkLocalGateway.getInstance().getGatewayList()) {
                            if (oid.equals(gatewayBean.getGatewayId()) || oid.equals(gatewayBean.getDevice_mac()) || oid.equals(gatewayBean.getOid())) {
                                //上面的oid可能是网关id或者mac或者是oid，不管是哪个统一使用oid表示方式
                                realLinkResponse.setOid(gatewayBean.getOid());
                                break;
                            }
                        }
                        EventDispatcher.getInstance().post(topic, realLinkResponse);
                    }
                } catch (Exception e) {
                    LogUtils.e(TAG, "LinkResponse转RealLinkResponse异常:" + e.getMessage());
                }
            }
        };

        EventDispatcher.getInstance().registerAllTopicsListener(eventListener);
    }

    /**
     * 发送原生数据
     *
     * @param gatewayOidOrGatewayId 目标网关的oid或者网关Id
     * @param payload               发送数据
     * @param realLinkCallBack      结果回调
     */
    public void Send(String gatewayOidOrGatewayId, String topic, String payload, final RealLinkCallBack realLinkCallBack) {
        Send(gatewayOidOrGatewayId, topic, payload, 4, realLinkCallBack);//默认4秒超时
    }

    /**
     * 发送原生数据
     *
     * @param gatewayOidOrGatewayId 目标网关的oid或者网关Id
     * @param payload               发送数据
     * @param timeout               超时时间(s)
     * @param realLinkCallBack      结果回调
     */
    public void Send(String gatewayOidOrGatewayId, String topic, String payload, int timeout, final RealLinkCallBack realLinkCallBack) {

        if(TextUtils.isEmpty(gatewayOidOrGatewayId)||TextUtils.isEmpty(payload)||TextUtils.isEmpty(payload)) {
            LogUtils.i(TAG, String.format("部分数据为空，gatewayOidOrGatewayId:%s，topic:%s，payload：%s", gatewayOidOrGatewayId, topic, payload));
            realLinkCallBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
            return;
        }

        String time = String.valueOf(System.currentTimeMillis());
        final BaseLocalResponse<List<JSONObject>> data = new BaseLocalResponse<>();
        data.setId(IdUtils.getUUId());
        data.setTime_stamp(time);
        List<JSONObject> objectList = new ArrayList<>();
        objectList.add(JSONObject.parseObject(payload));
        data.setObjects(objectList);

        LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
        request.setReplyTopic(String.format(request.getReplyTopic() + "/s%", data.getId()));//用topic+消息id表示唯一
        long awaitTime = timeout * 1000L;

        new HDLConnectHelper(awaitTime, 1, HDLLinkConfig.getInstance().getIpAddress(), 8586, request, new HDLConnectHelper.HdlSocketListener() {
            @Override
            public void onSucceed(Object object) {
                if (object instanceof RealLinkResponse) {
                    if (realLinkCallBack != null) {
                        HDLLinkCode hdlLinkCode = ((RealLinkResponse) object).getHdlLinkCode();
                        Integer code = hdlLinkCode.getCode();
                        //有的话只有200才会成功
                        if (code.intValue() == 200 || code.intValue() == 0) {
                            realLinkCallBack.onSuccess((RealLinkResponse) object);
                        } else {
                            realLinkCallBack.onError(HDLLinkException.getErrorWithCode(hdlLinkCode));
                        }
                    }
                } else {
                    LogUtils.e(TAG, "发送Link回调对象类型非数组类型，类型是" + object.getClass());
                }
            }
            @Override
            public void onFailure(HDLLinkCode hdlLinkCode) {
                if (realLinkCallBack != null) {
                    realLinkCallBack.onError(HDLLinkException.getErrorWithCode(hdlLinkCode));
                }
            }
        }, true, gatewayOidOrGatewayId).send();
    }
}