HDLSDK_A_Android
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
panlili2024
2024-11-14 b1569b789eef12cf5d4252620ca7e7d2d9c8b93a 
 HDLSDK/hdl-connect/src/main/java/com/hdl/sdk/connect/socket/HDLSocket.java


@@ -2,13 +2,11 @@






import android.os.Build;



import android.text.TextUtils;



import android.util.Log;







import androidx.annotation.RequiresApi;







import com.google.gson.JsonObject;



import com.google.gson.reflect.TypeToken;



import com.hdl.sdk.common.HDLSdk;



import com.hdl.sdk.common.config.TopicConstant;



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



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



@@ -16,33 +14,29 @@


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



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



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



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.HDLLink;



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



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



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



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



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



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



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



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



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



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



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.LinkRequest;



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



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



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



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



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



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



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



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



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



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



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



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



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



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



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



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



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.connect.utils.AesUtil;



import com.hdl.sdk.socket.SocketBoot;



import com.hdl.sdk.socket.SocketOptions;



import com.hdl.sdk.socket.client.IHeartbeat;



@@ -52,7 +46,6 @@


import com.hdl.sdk.socket.listener.SendListener;







import java.util.ArrayList;



import java.util.Base64;



import java.util.List;



import java.util.concurrent.ScheduledExecutorService;



import java.util.concurrent.TimeUnit;



@@ -106,10 +99,13 @@


            public void run() {



                while (true) {



                    try {



                        Thread.sleep(1000);



//                        LogUtils.i("checkIfCertified=" + HDLLink.getInstance().checkIfCertified() + " getTcp().connected=" + getTcp().connected);



                        Thread.sleep(5000);



                        try {



                            if (!HDLLink.getInstance().checkIfCertified() || (!TextUtils.isEmpty(getTcpIp()) && getTcp().connected)) {



                            if (!HDLLink.getInstance().checkIfCertified()) {



                                continue;



                            }







                            if (!TextUtils.isEmpty(getTcpIp()) && getTcp().connected) {



                                continue;



                            }



                        } catch (Exception e) {



@@ -130,6 +126,10 @@


                                if (!TextUtils.isEmpty(data)) {



                                    DeviceInfoResponse response = GsonConvert.getGson().fromJson(data, new TypeToken<DeviceInfoResponse>() {



                                    }.getType());







                                    if ((response == null) || (response.getObjects() == null) || (response.getObjects().getIPAddress() == null))



                                        return;







                                    HDLLinkConfig.getInstance().setIpAddress(response.getObjects().getIPAddress());



                                    LogUtils.i("---getIpAddress=" + HDLLinkConfig.getInstance().getIpAddress());







@@ -466,14 +466,15 @@


        }



    }







    public SocketBoot getTcp() throws RuntimeException {



        if (TextUtils.isEmpty(getTcpIp())) {



    public synchronized SocketBoot getTcp() throws RuntimeException {



        String gatewayIpAddress = getTcpIp();



        if (TextUtils.isEmpty(gatewayIpAddress)) {



            LogUtils.e("请搜索网关");



            throw new RuntimeException("请搜索网关");



        }



        //如果没有初始化，或者网关IP更改了，就重新初始化



        if (tcpBoot == null || !getTcpOptions().getIp().equals(getTcpIp())) {



            tcpBoot = TcpClient.init(getTcpIp(), getTcpPort(), getTcpOptions());



        if (tcpBoot == null || !getTcpOptions().getIp().equals(gatewayIpAddress)) {



            tcpBoot = TcpClient.init(gatewayIpAddress, getTcpPort(), getTcpOptions());



            tcpBoot.SetHeartbeat(new IHeartbeat() {



                @Override



                public void heartbeat() {



@@ -655,12 +656,63 @@


            data.setId(IdUtils.getUUId());



            data.setTime_stamp(time);







            //2023.10.18修改，上报oid列表增加parentOid



            if (request != null && !TextUtils.isEmpty(HDLLinkConfig.getInstance().getParentOid())) {



                request.setParentOid(HDLLinkConfig.getInstance().getParentOid());



            }







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



            list.add(request);







            data.setObjects(list);







            String topic = String.format(TopicConstant.LIST_UPLOAD, 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));



            }



        }



    }







    /**



     * 上报Sid列表



     *



     * @param requestList sid列表



     * @param callBack    回调



     */



    public void UploadSidList(List<ListSidRequest> requestList, HDLLinkCallBack callBack) {



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



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



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



            data.setId(IdUtils.getUUId());



            data.setTime_stamp(time);







            data.setObjects(requestList);







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



            LinkRequest message = new LinkRequest(topic,



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







@@ -896,14 +948,13 @@


//        String replyTopic = topic + "_reply";







        try {



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



            sendMsg(message.getSendBytes(), topic, null, new SendListener() {



                @Override



                public void onSucceed() {



                    HDLLinkConfig.getInstance().clearConfig();



                    if (callBack == null) return;



                    try {



                        callBack.onSuccess("退网成功");



                        HDLLinkConfig.getInstance().clearConfig();







                    } catch (Exception e) {



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



                    }



@@ -942,7 +993,11 @@


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



        try {



            LinkRequest message = new LinkRequest(topic, bodyStr);



            if (topic != null && topic.endsWith("_reply")) {



                callBack = null;



            }



            String replyTopic = topic + "_reply";



            HDLLinkCallBack finalCallBack = callBack;



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



                @Override



                public void onSucceed() {



@@ -951,8 +1006,8 @@






                @Override



                public void onError() {



                    if (callBack != null) {



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



                    if (finalCallBack != null) {



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



                    }



                }



            });



@@ -1011,7 +1066,7 @@


                threadPool.scheduleWithFixedDelay(new Runnable() {



                    @Override



                    public void run() {



                        if (sendCount.get() < 3) {



                        if (sendCount.get() < 0) {



                            sendCount.set(sendCount.get() + 1);



                            getTcp().sendMsg(data);



                        } else {



@@ -1061,4 +1116,56 @@






    }







    /**



     * 回复网关配置命令



     *



     * @param mac_Oid_GatewayId



     * @param msgId             消息Id



     * @param callBack



     */



    public void gatewayRemoteEditReply(String mac_Oid_GatewayId, String msgId, HDLLinkCallBack callBack) {



        if (TextUtils.isEmpty(mac_Oid_GatewayId)) {



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



        }







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



        final BaseLocalCodeResponse<List<String>> data = new BaseLocalCodeResponse<>();



        data.setId(msgId);



        data.setTime_stamp(time);



        data.setCode("0");











        String topic = String.format(TopicConstant.GATEWAY_EDIT_REMOTE_REPLY, mac_Oid_GatewayId);



        LinkRequest message = new LinkRequest(topic,



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











        try {



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



                @Override



                public void onSucceed() {



                    if (callBack == null) return;



                    try {



                        callBack.onSuccess("退网成功");



                        HDLLinkConfig.getInstance().clearConfig();







                    } catch (Exception e) {



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



                    }



                }







                @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));



            }



        }



    }







}