package com.hdl.sdk.connect.socket;
|
|
import static com.hdl.sdk.connect.config.HDLLinkConfig.AUTHENTICATE_IS_DEVICEINFO_KEY;
|
|
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;
|
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.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.ListSidRequest;
|
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.request.PropertyReadRequest;
|
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;
|
import com.hdl.sdk.socket.client.TcpClient;
|
import com.hdl.sdk.socket.codec.MessagePipeLine;
|
import com.hdl.sdk.socket.listener.ConnectStatusListener;
|
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;
|
import java.util.concurrent.atomic.AtomicInteger;
|
|
/**
|
* Created by Tong on 2021/9/26.
|
* 1、通过Udp 组播或者广播搜索网关
|
* 2、通过Udp 获取Tcp ip 端口统一8586
|
*/
|
public class HDLSocket {
|
|
/**
|
* tcp默认端口
|
*/
|
private static final int TCP_PORT = 8586;
|
|
private SocketBoot tcpBoot;
|
|
private ConnectStatusListener statusListener;
|
|
private HDLSocket() {
|
statusListener = new ConnectStatusListener() {
|
@Override
|
public void onConnecting() {
|
//broadcastRequest();
|
}
|
|
@Override
|
public void onConnected() {
|
|
}
|
|
@Override
|
public void onConnectFailed() {
|
|
}
|
};
|
}
|
|
public boolean isBroadcast = false;
|
|
|
/**
|
* 广播自身信息给主网关
|
*/
|
public void broadcastRequest() {
|
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
while (true) {
|
try {
|
Thread.sleep(1000);
|
// LogUtils.i("checkIfCertified=" + HDLLink.getInstance().checkIfCertified() + " getTcp().connected=" + getTcp().connected);
|
try {
|
if (!HDLLink.getInstance().checkIfCertified() || (!TextUtils.isEmpty(getTcpIp()) && getTcp().connected)) {
|
continue;
|
}
|
} catch (Exception e) {
|
|
}
|
LogUtils.i("广播设备本身信息");
|
String time = String.valueOf(System.currentTimeMillis());
|
if (null == HDLLinkConfig.getInstance().getDeviceInfoBean()) {
|
LogUtils.i("DeviceInfoBean为空，请设置当前对象");
|
continue;
|
}
|
BroadcastRequest request = new BroadcastRequest(IdUtils.getUUId(), time, HDLLinkConfig.getInstance().getDeviceInfoBean(), "200");
|
HDLAuthSocket.getInstance().udpSendMsg(TopicConstant.BROADCAST, GsonConvert.getGson().toJson(request), true, new HDLLinkResponseCallBack() {
|
@RequiresApi(api = Build.VERSION_CODES.O)
|
@Override
|
public void onSuccess(LinkResponse msg) {
|
String data = msg.getData();
|
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());
|
|
HDLLinkConfig.getInstance().reSaveConfig();
|
}
|
|
isBroadcast = true;
|
getTcp();
|
LogUtils.i("广播信息给主网关成功！");
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
isBroadcast = false;
|
LogUtils.i("广播信息给主网关失败！---onError=" + e.toString());
|
}
|
});
|
// HDLAuthSocket.getInstance().udpSendMsg(TopicConstant.BROADCAST, GsonConvert.getGson().toJson(request), true);
|
//HDLAuthSocket.getInstance().udpSendMsg(TopicConstant.BROADCAST, GsonConvert.getGson().toJson(request), true);
|
} catch (Exception e) {
|
LogUtils.e("广播设备本身信息失败，失败信息：" + e.getMessage());
|
}
|
}
|
|
}
|
}).start();
|
}
|
|
// private static class SingletonInstance {
|
// }
|
private static final HDLSocket instance = new HDLSocket();
|
|
public static HDLSocket getInstance() {
|
return instance;
|
}
|
|
SocketOptions options;
|
|
private SocketOptions getTcpOptions() {
|
if (null != options) {
|
return options;
|
}
|
options = new SocketOptions();
|
final MessagePipeLine pipeLine = new MessagePipeLine();
|
pipeLine.add(new LinkMessageDecoder());
|
pipeLine.add(new LinkMessageEncoder());
|
options.setHandleMessage(pipeLine);
|
options.addConnectStatusListener(statusListener);
|
return options;
|
}
|
|
|
public int getTcpPort() {
|
return TCP_PORT;
|
}
|
|
public String getTcpIp() {
|
return HDLLinkConfig.getInstance().getIpAddress();
|
}
|
|
public String getGatewayId() {
|
return HDLLinkConfig.getInstance().getGatewayId();
|
}
|
|
/**
|
* 获取设备列表
|
*/
|
public void getDeviceList(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.GET_DEVICE_LIST, getGatewayId());
|
|
LinkRequest message = new LinkRequest(topic,
|
jsonObject.toString());
|
|
String replyTopic = String.format(TopicConstant.GET_DEVICE_LIST_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_GET_DEVICE_LIST_ERROR));
|
}
|
}
|
});
|
} catch (Exception e) {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_DEVICE_LIST_ERROR));
|
}
|
}
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_UNAUTHORIZED_ERROR));
|
}
|
}
|
}
|
|
|
/**
|
* 获取功能列表
|
*/
|
public void getFunctionList(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.GET_FUNCTION_LIST, getGatewayId());
|
|
LinkRequest message = new LinkRequest(topic,
|
jsonObject.toString());
|
|
String replyTopic = String.format(TopicConstant.GET_FUNCTION_LIST_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_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
|
* @param callBack
|
*/
|
public void getFunctionAttribute(List<String> sids, HDLLinkCallBack callBack) {
|
if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {
|
String time = String.valueOf(System.currentTimeMillis());
|
|
final BaseLocalResponse<List<FunctionAttributeRequest>> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
List<FunctionAttributeRequest> list = new ArrayList<>();
|
for (String s : sids) {
|
list.add(new FunctionAttributeRequest(s));
|
}
|
data.setObjects(list);
|
|
String topic = String.format(TopicConstant.GET_FUNCTION_ATTRIBUTE, getGatewayId());
|
LinkRequest message = new LinkRequest(topic,
|
GsonConvert.getGson().toJson(data));
|
|
String replyTopic = String.format(TopicConstant.GET_FUNCTION_ATTRIBUTE_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_GET_FUNCTION_PROPERTIES_ERROR));
|
}
|
}
|
});
|
} catch (Exception e) {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_FUNCTION_PROPERTIES_ERROR));
|
}
|
}
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_UNAUTHORIZED_ERROR));
|
}
|
}
|
}
|
|
/**
|
* 设备控制
|
*/
|
public void propertyDown(List<DeviceControlRequest> request, HDLLinkCallBack callBack) {
|
|
if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {
|
String time = String.valueOf(System.currentTimeMillis());
|
|
final BaseLocalResponse<List<DeviceControlRequest>> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
data.setObjects(request);
|
|
String topic = String.format(TopicConstant.PROPERTY_DOWN, getGatewayId());
|
LinkRequest message = new LinkRequest(topic,
|
GsonConvert.getGson().toJson(data));
|
|
String replyTopic = String.format(TopicConstant.PROPERTY_DOWN_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 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<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.PROPERTY_READ, getGatewayId());
|
LinkRequest message = new LinkRequest(topic,
|
GsonConvert.getGson().toJson(data));
|
|
String replyTopic = String.format(TopicConstant.PROPERTY_READ_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 SocketBoot getTcp() throws RuntimeException {
|
if (TextUtils.isEmpty(getTcpIp())) {
|
LogUtils.e("请搜索网关");
|
throw new RuntimeException("请搜索网关");
|
}
|
//如果没有初始化，或者网关IP更改了，就重新初始化
|
if (tcpBoot == null || !getTcpOptions().getIp().equals(getTcpIp())) {
|
tcpBoot = TcpClient.init(getTcpIp(), getTcpPort(), getTcpOptions());
|
tcpBoot.SetHeartbeat(new IHeartbeat() {
|
@Override
|
public void heartbeat() {
|
|
if (HDLLinkConfig.getInstance().getDeviceInfoBean() == null || HDLLinkConfig.getInstance().getDeviceInfoBean().getOID() == null) {
|
LogUtils.i("DeviceInfoBean为空，需要设置才能正常心跳");
|
return;
|
}
|
|
String time = String.valueOf(System.currentTimeMillis());
|
JsonObject jsonObject = new JsonObject();
|
jsonObject.addProperty("id", IdUtils.getUUId());
|
jsonObject.addProperty("time_stamp", time);
|
|
if (HDLLinkConfig.getInstance().getRequestBean() != null) {
|
jsonObject.addProperty("mac", HDLLinkConfig.getInstance().getRequestBean().getMAC());
|
}
|
|
String topic = String.format(TopicConstant.HEARTBEAT, HDLLinkConfig.getInstance().getDeviceInfoBean().getOID());
|
|
LinkRequest message = new LinkRequest(topic,
|
jsonObject.toString());
|
sendMsg(message.getSendBytes(), null, null, null);
|
}
|
});
|
}
|
|
return tcpBoot;
|
}
|
|
/**
|
* 获取场景列表
|
*/
|
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));
|
}
|
}
|
}
|
|
/**
|
* 获取场景列表
|
*/
|
public void getScene(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_GET, 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_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));
|
}
|
}
|
}
|
|
/**
|
* 上报oid列表
|
*
|
* @param request 设备信息
|
* @param callBack 回调
|
*/
|
public void UploadOidList(ListUploadRequest request, HDLLinkCallBack callBack) {
|
if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<List<ListUploadRequest>> data = new BaseLocalResponse<>();
|
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));
|
|
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));
|
}
|
}
|
}
|
|
/**
|
* 上报入网认证结果
|
*
|
* @param mac mac
|
* @param result 结果0/-1
|
* @param message 认证信息
|
* @param auth_code 云端认证code
|
* @param callBack 结果回调
|
*/
|
public void UploadDeviceAuth(String mac, String result, String message, String auth_code, HDLLinkCallBack callBack) {
|
if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) {
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<List<DeviceAuthRequest>> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
|
DeviceAuthRequest deviceAuthRequest = new DeviceAuthRequest();
|
deviceAuthRequest.setMac(mac);
|
deviceAuthRequest.setResult(result);
|
deviceAuthRequest.setMessage(message);
|
deviceAuthRequest.setAuth_code(auth_code);
|
|
List<DeviceAuthRequest> list = new ArrayList<>();
|
list.add(deviceAuthRequest);
|
|
data.setObjects(list);
|
|
String topic = String.format(TopicConstant.DEIVCE_AUTH_RESULT_NOTIFY, getGatewayId());
|
LinkRequest linkRequest = new LinkRequest(topic,
|
GsonConvert.getGson().toJson(data));
|
|
String replyTopic = topic + "_reply";
|
try {
|
sendMsg(linkRequest.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));
|
}
|
}
|
}
|
|
|
/**
|
* tcp登录方便获取状态
|
*
|
* @param clientType 客户端类型
|
* 应用：app；
|
* 调试软件：program；
|
* 第三方：third_party；
|
* 网关：gateway；
|
* 其它：other
|
* @param version 协议版本
|
*/
|
public void tcpLogin(String clientType, String version, HDLLinkCallBack callBack) {
|
final String msgId = IdUtils.getUUId();
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<LoginRequest> data = new BaseLocalResponse<>();
|
data.setId(msgId);
|
data.setTime_stamp(time);
|
|
final LoginRequest request = new LoginRequest();
|
request.setVersion(version);
|
request.setClientType(clientType);
|
|
data.setObjects(request);
|
|
String topic = String.format(TopicConstant.GATEWAY_LOGIN, HDLLinkConfig.getInstance().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() {
|
LogUtils.i("tcpLogin 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));
|
}
|
}
|
}
|
|
|
/**
|
* 通知删除并退网子设备
|
*
|
* @param oid 从网关（设备）oid
|
* @param isForce 是否强制退网
|
* @param callBack 结果回调
|
*/
|
public void deleteNetwork(String oid, boolean isForce, HDLLinkCallBack callBack) {
|
if (TextUtils.isEmpty(oid)) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_DATA_NULL_ERROR));
|
}
|
|
final String msgId = IdUtils.getUUId();
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<List<ListOidRequest2>> data = new BaseLocalResponse<>();
|
data.setId(msgId);
|
data.setTime_stamp(time);
|
|
final ListOidRequest2 request = new ListOidRequest2();
|
request.setOid(oid);
|
List<ListOidRequest2> list = new ArrayList<>();
|
list.add(request);
|
|
data.setObjects(list);
|
|
String topic = String.format(TopicConstant.DELETE_REQUEST, HDLLinkConfig.getInstance().getGatewayId());
|
LinkRequest message = new LinkRequest(topic,
|
GsonConvert.getGson().toJson(data));
|
|
String replyTopic = topic + "_reply";
|
|
if (isForce) {//强制退网，不等网关回复直接清除数据
|
HDLLinkConfig.getInstance().clearConfig();
|
}
|
|
try {
|
sendMsg(message.getSendBytes(), replyTopic, 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));
|
}
|
}
|
}
|
|
/**
|
* 通知删除并退网子设备拓扑关系
|
*
|
* @param oid 从网关（设备）oid
|
* @param callBack 结果回调
|
*/
|
public void deleteNetwork(String oid, HDLLinkCallBack callBack) {
|
if (TextUtils.isEmpty(oid)) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_DATA_NULL_ERROR));
|
}
|
|
final String msgId = IdUtils.getUUId();
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalCodeResponse<List<ListOidRequest>> data = new BaseLocalCodeResponse<>();
|
data.setId(msgId);
|
data.setTime_stamp(time);
|
data.setCode("0");
|
|
final ListOidRequest request = new ListOidRequest();
|
request.setOid(oid);
|
List<ListOidRequest> list = new ArrayList<>();
|
list.add(request);
|
|
data.setObjects(list);
|
|
String topic = String.format(TopicConstant.DELETE_NOTIFY_REPLY, HDLLinkConfig.getInstance().getGatewayId());
|
LinkRequest message = new LinkRequest(topic,
|
GsonConvert.getGson().toJson(data));
|
|
// String replyTopic = topic + "_reply";
|
|
try {
|
sendMsg(message.getSendBytes(), topic, null, new SendListener() {
|
@Override
|
public void onSucceed() {
|
HDLLinkConfig.getInstance().clearConfig();
|
if (callBack == null) return;
|
try {
|
callBack.onSuccess("退网成功");
|
} 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));
|
}
|
}
|
}
|
|
// /**
|
// * 清空缓存
|
// */
|
// 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);
|
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() {
|
|
}
|
|
@Override
|
public void onError() {
|
if (finalCallBack != null) {
|
finalCallBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
});
|
} catch (Exception e) {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}
|
|
/**
|
* 通用TCP发送指令 只发一次，不监听回复，不重发
|
*
|
* @param topic 发送数据
|
* @param bodyStr 回复的主题
|
*/
|
public void tcpSendMsg(String topic, String bodyStr) {
|
try {
|
if (TextUtils.isEmpty(topic) || TextUtils.isEmpty(bodyStr)) {
|
LogUtils.e("tcpSendMsg", "参数不能为空");
|
return;
|
}
|
LinkRequest message = new LinkRequest(topic, bodyStr);
|
getTcp().sendMsg(message.getSendBytes());
|
} catch (Exception e) {
|
LogUtils.e("tcpSendMsg", "发送失败 :" + e.getMessage());
|
}
|
}
|
|
/**
|
* 发送指令
|
* 1秒没响应就让他重新发送,重试3次
|
*/
|
public void sendMsg(byte[] data, String eventTag, HDLLinkCallBack callBack, SendListener sendListener) {
|
|
try {
|
if (eventTag != null) {
|
final AtomicInteger sendCount = new AtomicInteger(0);
|
|
final ScheduledExecutorService threadPool = ThreadToolUtils.getInstance().newScheduledThreadPool(1);
|
final EventListener eventListener = new EventListener() {
|
@Override
|
public void onMessage(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
threadPool.shutdownNow();
|
LogUtils.i("sendMsg eventListener remove");
|
EventDispatcher.getInstance().remove(eventTag, this);
|
if (callBack != null) {
|
callBack.onSuccess(msg.toString());
|
}
|
}
|
}
|
};
|
|
threadPool.scheduleWithFixedDelay(new Runnable() {
|
@Override
|
public void run() {
|
if (sendCount.get() < 0) {
|
sendCount.set(sendCount.get() + 1);
|
getTcp().sendMsg(data);
|
} else {
|
threadPool.shutdownNow();
|
LogUtils.e("sendMsg eventListener remove");
|
EventDispatcher.getInstance().remove(eventTag, eventListener);
|
ThreadToolUtils.getInstance().runOnUiThread(new Runnable() {
|
@Override
|
public void run() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
});
|
}
|
}
|
}, 1000, 500, TimeUnit.MILLISECONDS);
|
EventDispatcher.getInstance().register(eventTag, eventListener);
|
}
|
//先发送一次
|
getTcp().sendMsg(data, new SendListener() {
|
@Override
|
public void onSucceed() {
|
if (sendListener != null) {
|
sendListener.onSucceed();
|
}
|
}
|
|
@Override
|
public void onError() {
|
if (sendListener != null) {
|
sendListener.onError();
|
}
|
}
|
});
|
} catch (Exception e) {
|
e.printStackTrace();
|
ThreadToolUtils.getInstance().runOnUiThread(new Runnable() {
|
@Override
|
public void run() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
});
|
}
|
|
}
|
|
/**
|
* 回复网关配置命令
|
*
|
* @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));
|
}
|
}
|
}
|
|
}
|
