2021-11-16 1.更新

JLChen

2021-11-16 a4246a571c78ac6c46e7bf7dbfc123b7148caed8

 HDLSDK/hdl-connect/src/main/java/com/hdl/sdk/connect/socket/HDLSocket.java

@@ -7,19 +7,24 @@
import com.hdl.sdk.common.config.TopicConstant;

import com.hdl.sdk.common.event.EventDispatcher;

import com.hdl.sdk.common.event.EventListener;

import com.hdl.sdk.common.exception.HDLLinkCode;

import com.hdl.sdk.common.exception.HDLLinkException;

import com.hdl.sdk.common.utils.IdUtils;

import com.hdl.sdk.common.utils.IpUtils;

import com.hdl.sdk.common.utils.SPUtils;

import com.hdl.sdk.common.utils.ThreadToolUtils;

import com.hdl.sdk.common.utils.gson.GsonConvert;

import com.hdl.sdk.connect.bean.BaseLocalResponse;

import com.hdl.sdk.connect.bean.DeviceControlRequest;

import com.hdl.sdk.connect.bean.FunctionAttributeRequest;

import com.hdl.sdk.connect.bean.GatewaySearchBean;

import com.hdl.sdk.connect.bean.response.BaseLocalResponse;

import com.hdl.sdk.connect.bean.request.DeviceControlRequest;

import com.hdl.sdk.connect.bean.request.FunctionAttributeRequest;

import com.hdl.sdk.connect.bean.response.GatewaySearchBean;

import com.hdl.sdk.connect.bean.LinkRequest;

import com.hdl.sdk.connect.bean.LinkResponse;

import com.hdl.sdk.connect.bean.PropertyReadRequest;

import com.hdl.sdk.connect.bean.PropertyUpRequest;

import com.hdl.sdk.connect.bean.request.PropertyReadRequest;

import com.hdl.sdk.connect.bean.request.PropertyUpRequest;

import com.hdl.sdk.connect.callback.BaseCallBack;

import com.hdl.sdk.connect.callback.HDLLinkCallBack;

import com.hdl.sdk.connect.config.HDLLinkConfig;

import com.hdl.sdk.connect.protocol.LinkMessageDecoder;

import com.hdl.sdk.connect.protocol.LinkMessageEncoder;

import com.hdl.sdk.socket.SocketBoot;

@@ -44,22 +49,14 @@
 */

public class HDLSocket {



    private static final String GATEWAY_KEY = "gateway_key";

    private static final String TCP_IP_KEY = "tcp_ip_key";

    private String gatewayId;



    public interface CallBack {



        void onError(String error);



        void onResponse(String data);



    }



    /**

     * udp默认组播ip

     */

    private static final String UDP_GROUP_IP = "239.0.168.188";

//    public interface CallBack extends BaseCallBack {

//        void onResponse(String data);

//    }

//

//    /**

//     * udp默认组播ip

//     */

//    private static final String UDP_GROUP_IP = "239.0.168.188";



    /**

     * udp默认端口

@@ -71,21 +68,21 @@
     */

    private static final int TCP_PORT = 8586;



    private String tcpIp;

    private int tcpPort;

    //    private String tcpIp;

//    private int tcpPort;



    private int udpPort;

    private String udpIp;

//    private int udpPort;

//    private String udpIp;



    private static SocketBoot updBoot;

//    private static SocketBoot updBoot;

    private SocketBoot tcpBoot;



    private ConnectStatusListener statusListener;



    private EventListener searchEvent;

    private CallBack searchCallBack;

    private ScheduledExecutorService searchGatewayThread;

    private final AtomicInteger searchCount = new AtomicInteger(0);

//    private EventListener searchEvent;

//    private CallBack searchCallBack;

//    private ScheduledExecutorService searchGatewayThread;

//    private final AtomicInteger searchCount = new AtomicInteger(0);



    private HDLSocket() {

        statusListener = new ConnectStatusListener() {

@@ -104,43 +101,43 @@


            }

        };

        searchEvent = new EventListener() {

            @Override

            public void onMessage(Object msg) {

                try {

                    if (msg instanceof LinkResponse) {

                        LinkResponse linkResponse = (LinkResponse) msg;

                        String data = linkResponse.getData();

                        if (!TextUtils.isEmpty(data)) {

                            final BaseLocalResponse<GatewaySearchBean> response = GsonConvert.getGson().fromJson(data, new TypeToken<BaseLocalResponse<GatewaySearchBean>>() {

                            }.getType());

                            GatewaySearchBean searchBean = response.getObjects();

                            if (searchBean != null) {

                                gatewayId = searchBean.getGatewayId();

                                if (!TextUtils.isEmpty(gatewayId)) {

                                    SPUtils.put(GATEWAY_KEY, gatewayId);

                                }

                                tcpIp = searchBean.getIp_address();

                                if (!TextUtils.isEmpty(tcpIp)) {

                                    SPUtils.put(TCP_IP_KEY, tcpIp);

                                }

                            }



                            if (searchCallBack != null) {

                                searchCallBack.onResponse(linkResponse.toString());

                            }

                        }



                    }

                } catch (Exception e) {

                    if (searchCallBack != null) {

                        searchCallBack.onError("解析失败");

                    }

                }





            }

        };

//        searchEvent = new EventListener() {

//            @Override

//            public void onMessage(Object msg) {

//                try {

//                    if (msg instanceof LinkResponse) {

//                        LinkResponse linkResponse = (LinkResponse) msg;

//                        String data = linkResponse.getData();

//                        if (!TextUtils.isEmpty(data)) {

//                            final BaseLocalResponse<GatewaySearchBean> response = GsonConvert.getGson().fromJson(data, new TypeToken<BaseLocalResponse<GatewaySearchBean>>() {

//                            }.getType());

//                            GatewaySearchBean searchBean = response.getObjects();

//                            if (searchBean != null) {

////                                gatewayId = searchBean.getGatewayId();

////                                if (!TextUtils.isEmpty(gatewayId)) {

////                                    SPUtils.put(GATEWAY_KEY, gatewayId);

////                                }

////                                tcpIp = searchBean.getIp_address();

////                                if (!TextUtils.isEmpty(tcpIp)) {

////                                    SPUtils.put(TCP_IP_KEY, tcpIp);

////                                }

//                            }

//

//                            if (searchCallBack != null) {

//                                searchCallBack.onResponse(linkResponse.toString());

//                            }

//                        }

//

//                    }

//                } catch (Exception e) {

//                    if (searchCallBack != null) {

//                        searchCallBack.onError("解析失败");

//                    }

//                }

//

//

//            }

//        };

    }



    private static class SingletonInstance {

@@ -152,15 +149,15 @@
    }





    private SocketOptions getUdpOptions() {

        final SocketOptions options = new SocketOptions();

        final MessagePipeLine pipeLine = new MessagePipeLine();

        pipeLine.add(new LinkMessageDecoder());

        pipeLine.add(new LinkMessageEncoder());

        options.setHandleMessage(pipeLine);

        options.setEnabledHeartbeat(false);

        return options;

    }

//    private SocketOptions getUdpOptions() {

//        final SocketOptions options = new SocketOptions();

//        final MessagePipeLine pipeLine = new MessagePipeLine();

//        pipeLine.add(new LinkMessageDecoder());

//        pipeLine.add(new LinkMessageEncoder());

//        options.setHandleMessage(pipeLine);

//        options.setEnabledHeartbeat(false);

//        return options;

//    }



    private SocketOptions getTcpOptions() {

        final SocketOptions options = new SocketOptions();

@@ -181,107 +178,101 @@
    }



    public String getTcpIp() {

        if (!TextUtils.isEmpty(tcpIp)) {

            return tcpIp;

        }

        return SPUtils.getString(TCP_IP_KEY, "");

        return HDLLinkConfig.getInstance().getIpAddress();

    }



    public String getGatewayId() {

        if (!TextUtils.isEmpty(gatewayId)) {

            return gatewayId;

        }

        return SPUtils.getString(GATEWAY_KEY, "");

        return HDLLinkConfig.getInstance().getGatewayId();

    }





    private String getUdpIp() {

        if (TextUtils.isEmpty(udpIp)) {

            udpIp = UDP_GROUP_IP;

        }

        return udpIp;

    }

//    private String getUdpIp() {

//        if (TextUtils.isEmpty(udpIp)) {

//            udpIp = UDP_GROUP_IP;

//        }

//        return udpIp;

//    }



    public void searchGateway() {

        searchGateway(null);

    }



    /**

     * 组播搜索

     */

    public void searchGateway(CallBack callBack) {

        gatewayId = "";//重置网关ID

        this.searchCallBack = callBack;



        if (searchGatewayThread != null) {

            searchGatewayThread.shutdownNow();

        }





        new Thread(new Runnable() {

            @Override

            public void run() {

                while (TextUtils.isEmpty(gatewayId)) {

                    //搜索网关

                    searchGateway(IdUtils.getUUId(), searchEvent);

                    try {

                        Thread.sleep(1000L);

                    } catch (InterruptedException e) {

                        e.printStackTrace();

                    }

                }

            }

        }).start();

    }





    /**

     * 通过组播搜索网关

     */

    public void searchGateway(String msgId, EventListener eventListener) {

        searchGateway(getUdpIp(), getUdpPort(), msgId, eventListener);

    }



    /**

     * 通过广播搜索网关

     */

    public void searchGatewayByBroadcast(String msgId, EventListener eventListener) {

        searchGateway(IpUtils.getBroadcastAddress(), getUdpPort(), msgId, eventListener);

    }



    /**

     * 默认是组播搜索网关

     */

    public void searchGateway(String ip, int port, String msgId, EventListener eventListener) {



        if (updBoot == null) {

            updBoot = UdpClient.init(ip, port, getUdpOptions());

            updBoot.connect();

        }





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

        JsonObject jsonObject = new JsonObject();

        jsonObject.addProperty("id", msgId);

        jsonObject.addProperty("time_stamp", time);



        EventDispatcher.getInstance().registerIo(TopicConstant.GATEWAY_SEARCH_REPLY, eventListener);

        LinkRequest message = new LinkRequest(TopicConstant.GATEWAY_SEARCH,

                jsonObject.toString());



        try {

            updBoot.sendMsg(message.toString().getBytes("utf-8"));

        } catch (UnsupportedEncodingException e) {

            e.printStackTrace();

        }



    }

//    public void searchGateway() {

//        searchGateway(null);

//    }

//

//    /**

//     * 组播搜索

//     */

//    public void searchGateway(CallBack callBack) {

////        gatewayId = "";//重置网关ID

////        this.searchCallBack = callBack;

////

////        if (searchGatewayThread != null) {

////            searchGatewayThread.shutdownNow();

////        }

////

////

////        new Thread(new Runnable() {

////            @Override

////            public void run() {

////                while (TextUtils.isEmpty(gatewayId)) {

////                    //搜索网关

////                    searchGateway(IdUtils.getUUId(), searchEvent);

////                    try {

////                        Thread.sleep(1000L);

////                    } catch (InterruptedException e) {

////                        e.printStackTrace();

////                    }

////                }

////            }

////        }).start();

//    }

//

//

//    /**

//     * 通过组播搜索网关

//     */

//    public void searchGateway(String msgId, EventListener eventListener) {

//        searchGateway(getUdpIp(), getUdpPort(), msgId, eventListener);

//    }

//

//    /**

//     * 通过广播搜索网关

//     */

//    public void searchGatewayByBroadcast(String msgId, EventListener eventListener) {

//        searchGateway(IpUtils.getBroadcastAddress(), getUdpPort(), msgId, eventListener);

//    }

//

//    /**

//     * 默认是组播搜索网关

//     */

//    public void searchGateway(String ip, int port, String msgId, EventListener eventListener) {

//

//        if (updBoot == null) {

//            updBoot = UdpClient.init(ip, port, getUdpOptions());

//            updBoot.connect();

//        }

//

//

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

//        JsonObject jsonObject = new JsonObject();

//        jsonObject.addProperty("id", msgId);

//        jsonObject.addProperty("time_stamp", time);

//

//        EventDispatcher.getInstance().registerIo(TopicConstant.GATEWAY_SEARCH_REPLY, eventListener);

//        LinkRequest message = new LinkRequest(TopicConstant.GATEWAY_SEARCH,

//                jsonObject.toString());

//

//        try {

//            updBoot.sendMsg(message.getSendBytes());

//        } catch (UnsupportedEncodingException e) {

//            e.printStackTrace();

//        }

//

//    }





    /**

     * 获取设备列表

     */

    public void getDeviceList(CallBack callBack) {

    public void getDeviceList(HDLLinkCallBack callBack) {

        if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {

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

            JsonObject jsonObject = new JsonObject();

@@ -295,7 +286,7 @@


            String replyTopic = String.format(TopicConstant.GET_DEVICE_LIST_REPLY, getGatewayId());

            try {

                sendMsg(message.toString().getBytes("utf-8"), replyTopic, callBack, new SendListener() {

                sendMsg(message.getSendBytes(), replyTopic, callBack, new SendListener() {

                    @Override

                    public void onSucceed() {



@@ -304,18 +295,18 @@
                    @Override

                    public void onError() {

                        if (callBack != null) {

                            callBack.onError("获取设备列表失败");

                            callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_DEVICE_LIST_ERROR));

                        }

                    }

                });

            } catch (UnsupportedEncodingException e) {

            } catch (Exception e) {

                if (callBack != null) {

                    callBack.onError("获取设备列表失败");

                    callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_DEVICE_LIST_ERROR));

                }

            }

        } else {

            if (callBack != null) {

                callBack.onError("ip地址丢失");

                callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_UNAUTHORIZED_ERROR));

            }

        }

    }

@@ -324,7 +315,7 @@
    /**

     * 获取功能列表

     */

    public void getFunctionList(CallBack callBack) {

    public void getFunctionList(HDLLinkCallBack callBack) {

        if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {

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

            JsonObject jsonObject = new JsonObject();

@@ -338,7 +329,7 @@


            String replyTopic = String.format(TopicConstant.GET_FUNCTION_LIST_REPLY, getGatewayId());

            try {

                sendMsg(message.toString().getBytes("utf-8"), replyTopic, callBack, new SendListener() {

                sendMsg(message.getSendBytes(), replyTopic, callBack, new SendListener() {

                    @Override

                    public void onSucceed() {



@@ -347,18 +338,18 @@
                    @Override

                    public void onError() {

                        if (callBack != null) {

                            callBack.onError("获取功能列表失败");

                            callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_FUNCTION_LIST_ERROR));

                        }

                    }

                });

            } catch (UnsupportedEncodingException e) {

            } catch (Exception e) {

                if (callBack != null) {

                    callBack.onError("获取功能列表失败");

                    callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_FUNCTION_LIST_ERROR));

                }

            }

        } else {

            if (callBack != null) {

                callBack.onError("ip地址丢失");

                callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_UNAUTHORIZED_ERROR));

            }

        }

    }

@@ -367,10 +358,10 @@
    /**

     * 获取功能属性

     *

     * @param sids

     * @param callBack

     * @param sid

     */

    public void getFunctionAttribute(CallBack callBack, String... sid) {

    public void getFunctionAttribute(List<String> sids, HDLLinkCallBack callBack) {

        if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {

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



@@ -378,7 +369,7 @@
            data.setId(IdUtils.getUUId());

            data.setTime_stamp(time);

            List<FunctionAttributeRequest> list = new ArrayList<>();

            for (String s : sid) {

            for (String s : sids) {

                list.add(new FunctionAttributeRequest(s));

            }

            data.setObjects(list);

@@ -389,7 +380,7 @@


            String replyTopic = String.format(TopicConstant.GET_FUNCTION_ATTRIBUTE_REPLY, getGatewayId());

            try {

                sendMsg(message.toString().getBytes("utf-8"), replyTopic, callBack, new SendListener() {

                sendMsg(message.getSendBytes(), replyTopic, callBack, new SendListener() {

                    @Override

                    public void onSucceed() {



@@ -398,18 +389,18 @@
                    @Override

                    public void onError() {

                        if (callBack != null) {

                            callBack.onError("获取功能属性失败");

                            callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_FUNCTION_PROPERTIES_ERROR));

                        }

                    }

                });

            } catch (UnsupportedEncodingException e) {

            } catch (Exception e) {

                if (callBack != null) {

                    callBack.onError("获取功能属性失败");

                    callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_FUNCTION_PROPERTIES_ERROR));

                }

            }

        } else {

            if (callBack != null) {

                callBack.onError("ip地址丢失");

                callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_UNAUTHORIZED_ERROR));

            }

        }

    }

@@ -417,7 +408,7 @@
    /**

     * 设备控制

     */

    public void propertyDown(List<DeviceControlRequest> request, CallBack callBack) {

    public void propertyDown(List<DeviceControlRequest> request, HDLLinkCallBack callBack) {



        if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {

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

@@ -427,10 +418,9 @@
            data.setTime_stamp(time);

            data.setObjects(request);





            String topic = String.format(TopicConstant.PROPERTY_DOWN, getGatewayId());

            LinkRequest message = new LinkRequest(topic,

                    GsonConvert.getGson().toJson(request));

                    GsonConvert.getGson().toJson(data));



            String replyTopic = String.format(TopicConstant.PROPERTY_DOWN_REPLY, getGatewayId());

            try {

@@ -443,87 +433,90 @@
                    @Override

                    public void onError() {

                        if (callBack != null) {

                            callBack.onError("控制指令发送失败");

                            callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));

                        }

                    }

                });

            } catch (Exception e) {

                if (callBack != null) {

                    callBack.onError("控制指令发送失败");

                    callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));

                }

            }

        } else {

            if (callBack != null) {

                callBack.onError("控制指令发送失败");

                callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));

            }

        }



    }



    /**

     * 状态上报

     */

    public void propertyUp(List<PropertyUpRequest> request, CallBack callBack) {

        if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {

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



            final BaseLocalResponse<List<PropertyUpRequest>> data = new BaseLocalResponse<>();

            data.setId(IdUtils.getUUId());

            data.setTime_stamp(time);

            data.setObjects(request);





            String topic = String.format(TopicConstant.PROPERTY_UP, getGatewayId());

            LinkRequest message = new LinkRequest(topic,

                    GsonConvert.getGson().toJson(request));



            String replyTopic = String.format(TopicConstant.PROPERTY_UP_REPLY, getGatewayId());

            try {

                sendMsg(message.toString().getBytes("utf-8"), replyTopic, callBack, new SendListener() {

                    @Override

                    public void onSucceed() {



                    }



                    @Override

                    public void onError() {

                        if (callBack != null) {

                            callBack.onError("指令发送失败");

                        }

                    }

                });

            } catch (UnsupportedEncodingException e) {

                if (callBack != null) {

                    callBack.onError("指令发送失败");

                }

            }

        } else {

            if (callBack != null) {

                callBack.onError("指令发送失败");

            }

        }

    }

//    /**

//     * 状态上报

//     */

//    public void propertyUp(List<PropertyUpRequest> request, CallBack callBack) {

//        if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {

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

//

//            final BaseLocalResponse<List<PropertyUpRequest>> data = new BaseLocalResponse<>();

//            data.setId(IdUtils.getUUId());

//            data.setTime_stamp(time);

//            data.setObjects(request);

//

//

//            String topic = String.format(TopicConstant.PROPERTY_UP, getGatewayId());

//            LinkRequest message = new LinkRequest(topic,

//                    GsonConvert.getGson().toJson(request));

//

//            String replyTopic = String.format(TopicConstant.PROPERTY_UP_REPLY, getGatewayId());

//            try {

//                sendMsg(message.getSendBytes(), replyTopic, callBack, new SendListener() {

//                    @Override

//                    public void onSucceed() {

//

//                    }

//

//                    @Override

//                    public void onError() {

//                        if (callBack != null) {

//                            callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));

//                        }

//                    }

//                });

//            } catch (Exception e) {

//                if (callBack != null) {

//                    callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));

//                }

//            }

//        } else {

//            if (callBack != null) {

//                callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));

//            }

//        }

//    }



    /**

     * 读取状态

     */

    public void propertyRead(List<PropertyReadRequest> request, CallBack callBack) {

    public void propertyRead(List<String> sids, HDLLinkCallBack callBack) {

        if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {

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



            final BaseLocalResponse<List<PropertyReadRequest>> data = new BaseLocalResponse<>();

            data.setId(IdUtils.getUUId());

            data.setTime_stamp(time);

            data.setObjects(request);



            List<PropertyReadRequest> list = new ArrayList<>();

            for (String s : sids) {

                list.add(new PropertyReadRequest(s));

            }

            data.setObjects(list);



            String topic = String.format(TopicConstant.PROPERTY_READ, getGatewayId());

            LinkRequest message = new LinkRequest(topic,

                    GsonConvert.getGson().toJson(request));

                    GsonConvert.getGson().toJson(data));



            String replyTopic = String.format(TopicConstant.PROPERTY_READ_REPLY, getGatewayId());

            try {

                sendMsg(message.toString().getBytes("utf-8"), replyTopic, callBack, new SendListener() {

                sendMsg(message.getSendBytes(), replyTopic, callBack, new SendListener() {

                    @Override

                    public void onSucceed() {



@@ -532,18 +525,18 @@
                    @Override

                    public void onError() {

                        if (callBack != null) {

                            callBack.onError("指令发送失败");

                            callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));

                        }

                    }

                });

            } catch (UnsupportedEncodingException e) {

            } catch (Exception e) {

                if (callBack != null) {

                    callBack.onError("指令发送失败");

                    callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));

                }

            }

        } else {

            if (callBack != null) {

                callBack.onError("指令发送失败");

                callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));

            }

        }

    }

@@ -559,11 +552,133 @@
    }



    /**

     * 清空缓存

     * 获取场景列表

     */

    public void clearCache() {

        SPUtils.remove(TCP_IP_KEY);

        SPUtils.remove(GATEWAY_KEY);

    public void getSceneList(HDLLinkCallBack callBack) {

        if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {

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

            JsonObject jsonObject = new JsonObject();

            jsonObject.addProperty("id", IdUtils.getUUId());

            jsonObject.addProperty("time_stamp", time);



            String topic = String.format(TopicConstant.SCENE_LIST_GET, getGatewayId());



            LinkRequest message = new LinkRequest(topic,

                    jsonObject.toString());

            String replyTopic = topic + "_reply";

            try {

                sendMsg(message.getSendBytes(), replyTopic, callBack, new SendListener() {

                    @Override

                    public void onSucceed() {



                    }



                    @Override

                    public void onError() {

                        if (callBack != null) {

                            callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_FUNCTION_LIST_ERROR));

                        }

                    }

                });

            } catch (Exception e) {

                if (callBack != null) {

                    callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_FUNCTION_LIST_ERROR));

                }

            }

        } else {

            if (callBack != null) {

                callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_UNAUTHORIZED_ERROR));

            }

        }

    }



    /**

     *  场景控制

     * @param sids 场景sid列表

     * @param callBack 回调

     */

    public void controlScene(List<String> sids, HDLLinkCallBack callBack) {

        if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {

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

            final BaseLocalResponse<List<PropertyReadRequest>> data = new BaseLocalResponse<>();

            data.setId(IdUtils.getUUId());

            data.setTime_stamp(time);



            List<PropertyReadRequest> list = new ArrayList<>();

            for (String s : sids) {

                list.add(new PropertyReadRequest(s));

            }

            data.setObjects(list);



            String topic = String.format(TopicConstant.SCENE_CONTROL, getGatewayId());

            LinkRequest message = new LinkRequest(topic,

                    GsonConvert.getGson().toJson(data));



            String replyTopic = topic + "_reply";

            try {

                sendMsg(message.getSendBytes(), replyTopic, callBack, new SendListener() {

                    @Override

                    public void onSucceed() {



                    }



                    @Override

                    public void onError() {

                        if (callBack != null) {

                            callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));

                        }

                    }

                });

            } catch (Exception e) {

                if (callBack != null) {

                    callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));

                }

            }

        } else {

            if (callBack != null) {

                callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));

            }

        }

    }



//    /**

//     * 清空缓存

//     */

//    public void clearCache() {

//        SPUtils.remove(TCP_IP_KEY);

//        SPUtils.remove(GATEWAY_KEY);

//    }



    /**

     * 通用TCP发送指令

     * 1秒没响应就让他重新发送,重试3次

     *

     * @param topic    发送数据

     * @param bodyStr  回复的主题

     * @param callBack 回调

     */

    public void tcpSendMsg(String topic, String bodyStr, HDLLinkCallBack callBack) {

        try {

            LinkRequest message = new LinkRequest(topic, bodyStr);

            String replyTopic = topic + "_reply";

            sendMsg(message.getSendBytes(), replyTopic, callBack, new SendListener() {

                @Override

                public void onSucceed() {



                }



                @Override

                public void onError() {

                    if (callBack != null) {

                        callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));

                    }

                }

            });

        } catch (Exception e) {

            if (callBack != null) {

                callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));

            }

        }

    }





@@ -571,7 +686,7 @@
     * 发送指令

     * 1秒没响应就让他重新发送,重试3次

     */

    public void sendMsg(byte[] data, String eventTag, CallBack callBack, SendListener sendListener) {

    public void sendMsg(byte[] data, String eventTag, HDLLinkCallBack callBack, SendListener sendListener) {



        try {

            final AtomicInteger sendCount = new AtomicInteger(0);

@@ -583,7 +698,7 @@
                    if (msg instanceof LinkResponse) {



                        if (callBack != null) {

                            callBack.onResponse(msg.toString());

                            callBack.onSuccess(msg.toString());

                        }

                        threadPool.shutdownNow();

                    }

@@ -603,7 +718,7 @@
                            @Override

                            public void run() {

                                if (callBack != null) {

                                    callBack.onError("发送失败");

                                    callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));

                                }

                            }

                        });

@@ -632,7 +747,7 @@
                @Override

                public void run() {

                    if (callBack != null) {

                        callBack.onError("发送失败");

                        callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));

                    }

                }

            });