package com.hdl.sdk.link.gateway;
|
|
|
import com.google.gson.JsonArray;
|
import com.google.gson.JsonObject;
|
import com.google.gson.reflect.TypeToken;
|
import com.hdl.sdk.link.common.config.TopicConstant;
|
import com.hdl.sdk.link.common.event.EventDispatcher;
|
import com.hdl.sdk.link.common.event.EventListener;
|
import com.hdl.sdk.link.common.exception.HDLLinkCode;
|
import com.hdl.sdk.link.common.exception.HDLLinkException;
|
import com.hdl.sdk.link.common.utils.IdUtils;
|
import com.hdl.sdk.link.common.utils.IpUtils;
|
import com.hdl.sdk.link.common.utils.TextUtils;
|
import com.hdl.sdk.link.common.utils.ThreadToolUtils;
|
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.response.BaseLocalResponse;
|
import com.hdl.sdk.link.core.callback.GatewayCallBack;
|
import com.hdl.sdk.link.core.callback.HDLLinkCallBack;
|
import com.hdl.sdk.link.core.connect.HDLConnectHelper;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
* Created by hxb on 2021/12/23.
|
*/
|
public class HDLLinkLocalGateway {
|
//instance
|
private volatile static HDLLinkLocalGateway instance;
|
|
//getInstance
|
public static synchronized HDLLinkLocalGateway getInstance() {
|
if (instance == null) {
|
synchronized (HDLLinkLocalGateway.class) {
|
if (instance == null) {
|
instance = new HDLLinkLocalGateway();
|
}
|
}
|
}
|
return instance;
|
}
|
|
/**
|
* 网关列表，记录所有搜索到的网关，可能包含断线的网关
|
*/
|
private final List<GatewayBean> gatewayBeanList = new ArrayList();
|
|
/**
|
* 获取缓存的网关列表，可能包含断线的网关
|
*
|
* @return 网关列表
|
*/
|
public List<GatewayBean> getGatewayList() {
|
return gatewayBeanList;
|
}
|
|
/**
|
* 通过oid或者网关ID或者AMC获取内存中的网关
|
*
|
* @param oidOrGatewayId
|
* @return
|
*/
|
public GatewayBean getGatewayByOidOrGatewayId(String oidOrGatewayId) {
|
if (TextUtils.isEmpty(oidOrGatewayId)) {
|
return null;
|
}
|
for (GatewayBean gatewayBean : gatewayBeanList) {
|
if (oidOrGatewayId.equals(gatewayBean.getOid())
|
|| oidOrGatewayId.equals(gatewayBean.getGatewayId())
|
|| oidOrGatewayId.equals(gatewayBean.getDevice_mac())
|
|| oidOrGatewayId.equals(gatewayBean.getIp_address())
|
)
|
return gatewayBean;
|
}
|
return null;
|
}
|
|
/**
|
* 通过IP获取网关信息
|
*
|
* @param ipAddress
|
* @return
|
*/
|
public GatewayBean getGatewayByIpAddress(String ipAddress) {
|
if (TextUtils.isEmpty(ipAddress)) {
|
return null;
|
}
|
for (GatewayBean gatewayBean : gatewayBeanList) {
|
if (ipAddress.equals(gatewayBean.getIp_address()))
|
return gatewayBean;
|
}
|
return null;
|
}
|
|
/**
|
* 搜索网关，只发一次，没有回调
|
*/
|
public void serchGatewayOneTime() {
|
String time = String.valueOf(System.currentTimeMillis());
|
JsonObject jsonObject = new JsonObject();
|
jsonObject.addProperty("id", IdUtils.getUUId());
|
jsonObject.addProperty("time_stamp", time);
|
LinkRequest message = new LinkRequest(TopicConstant.GATEWAY_SEARCH,
|
jsonObject.toString(), false);
|
|
String ipAddress = IpUtils.getBroadcastAddress();
|
new HDLConnectHelper(1, ipAddress, message, false).send();
|
}
|
|
/**
|
* 创新所有在线的网关，包括当前住宅的及没有绑定过的网关
|
*
|
* @param callBack 回调
|
*/
|
public void refreshGatewayByHome(String homeId, GatewayCallBack callBack) {
|
refreshGatewayByHome(homeId,callBack,false);
|
}
|
|
/**
|
* 创新所有在线的网关，包括当前住宅的及没有绑定过的网关
|
*
|
* @param callBack 回调
|
*/
|
public void refreshGatewayByHome(String homeId, GatewayCallBack callBack,boolean needOldGateway) {
|
|
String topicReply = TopicConstant.GATEWAY_SEARCH_REPLY;
|
final List<GatewayBean> tempGatewayBeanList = new ArrayList<>();
|
EventListener eventListener = getSearchGatewayEvent(homeId, tempGatewayBeanList);
|
EventDispatcher.getInstance().register(topicReply, eventListener);
|
|
ThreadToolUtils.getInstance().newFixedThreadPool(1).execute(new Runnable() {
|
@Override
|
public void run() {
|
int count = 5;
|
while (0 < count--) {
|
try {
|
//搜索网关
|
serchGatewayOneTime();
|
Thread.sleep(300L);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
}
|
//超出次数后移除监听事件
|
EventDispatcher.getInstance().remove(topicReply, eventListener);
|
if (callBack != null) {
|
if (tempGatewayBeanList.size() == 0 && needOldGateway) {
|
for (int i = 0; i < gatewayBeanList.size(); i++) {
|
if (homeId.equals(gatewayBeanList.get(i).getHomeId())) {
|
tempGatewayBeanList.add(gatewayBeanList.get(i));
|
}
|
}
|
}
|
if (tempGatewayBeanList.size() == 0) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_GATEWAY_FAILURE_ERROR));
|
} else {
|
callBack.onSuccess(tempGatewayBeanList);
|
}
|
}
|
}
|
});
|
}
|
|
/**
|
* 创新所有在线的网关，包括当前住宅的及没有绑定过的网关
|
*
|
* @param callBack 回调
|
*/
|
public void refreshGateway(GatewayCallBack callBack) {
|
|
String topicReply = TopicConstant.GATEWAY_SEARCH_REPLY;
|
final List<GatewayBean> tempGatewayBeanList = new ArrayList<>();
|
EventListener eventListener = getSearchGatewayEvent(tempGatewayBeanList);
|
EventDispatcher.getInstance().register(topicReply, eventListener);
|
|
ThreadToolUtils.getInstance().newFixedThreadPool(1).execute(new Runnable() {
|
@Override
|
public void run() {
|
int count = 5;
|
while (0 < count--) {
|
try {
|
//搜索网关
|
serchGatewayOneTime();
|
Thread.sleep(300L);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
}
|
|
|
//超出次数后移除监听事件
|
EventDispatcher.getInstance().remove(topicReply, eventListener);
|
if (callBack != null) {
|
if (tempGatewayBeanList.size() == 0) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GET_GATEWAY_FAILURE_ERROR));
|
} else {
|
|
callBack.onSuccess(tempGatewayBeanList);
|
}
|
}
|
}
|
});
|
}
|
|
/**
|
* 获取搜索网关事件
|
*
|
* @param homeId
|
* @return
|
*/
|
private EventListener getSearchGatewayEvent(String homeId, final List<GatewayBean> tempGatewayBeanList) {
|
//注册搜索网关监听
|
return new EventListener() {
|
@Override
|
public void onMessage(Object msg) {
|
if (!(msg instanceof LinkResponse)) {
|
return;
|
}
|
GatewayBean gateway = getGatewayBeanByResponse((LinkResponse) msg);
|
if (gateway == null) {
|
return;
|
}
|
gateway.setOnline(true);
|
gateway.setIsLocalGateWay(true);//本地搜索到的网关标识为本地网关
|
//只加载住宅一样的或者网关还没有配置过的
|
if (homeId.equals(gateway.getHomeId()) || TextUtils.isEmpty(gateway.getHomeId())) {
|
//更新缓存网关，会记录所有收到的网关，以为了保存网关的IP信息
|
updateGatewayList(gatewayBeanList, gateway);
|
//更新当前读取网关的列表，这个列表每次都是清空再读取
|
updateGatewayList(tempGatewayBeanList, gateway);
|
}
|
}
|
};
|
}
|
|
/**
|
* 获取搜索网关事件 这边不过滤homeId
|
*
|
* @return
|
*/
|
private EventListener getSearchGatewayEvent(final List<GatewayBean> tempGatewayBeanList) {
|
//注册搜索网关监听
|
return new EventListener() {
|
@Override
|
public void onMessage(Object msg) {
|
if (!(msg instanceof LinkResponse)) {
|
return;
|
}
|
GatewayBean gateway = getGatewayBeanByResponse((LinkResponse) msg);
|
if (gateway == null) {
|
return;
|
}
|
gateway.setIsLocalGateWay(true);//本地搜索到的网关标识为本地网关
|
//升级网关驱动 需要显示所有网关
|
//⚠️这边不需要添加到gatewayBeanList 因为这个是网关离线升级的时候的功能
|
// updateGatewayList(gatewayBeanList, gateway);
|
//更新当前读取网关的列表，这个列表每次都是清空再读取
|
updateGatewayList(tempGatewayBeanList, gateway);
|
}
|
};
|
}
|
|
/**
|
* 更新收到的网关到列表
|
*
|
* @param gatewayBeanList
|
* @param gateway 当前收到的网关
|
*/
|
void updateGatewayList(final List<GatewayBean> gatewayBeanList, GatewayBean gateway) {
|
boolean isFound = false;//是否在内存中找到网关对象
|
//找出mac一样的网关更新最新数据
|
for (int i = 0; i < gatewayBeanList.size(); i++) {
|
if (gatewayBeanList.get(i).getOid().equals(""))
|
continue;
|
if (gatewayBeanList.get(i).getOid().equals(gateway.getOid())) {
|
isFound = true;
|
gatewayBeanList.set(i, gateway);
|
// break;
|
}
|
}
|
|
//清除oid一样，mac不一样的网关缓存。一般是在网关替换的情况空间出现
|
for (int i = 0; i < gatewayBeanList.size(); i++) {
|
if (gatewayBeanList.get(i).getOid().equals("")|| gatewayBeanList.get(i).getDevice_mac().equals(""))
|
continue;
|
if (gatewayBeanList.get(i).getOid().equals(gateway.getOid()) && !gatewayBeanList.get(i).getDevice_mac().equals(gateway.getDevice_mac())
|
|| gatewayBeanList.get(i).getDevice_mac().equals(gateway.getDevice_mac()) && !gatewayBeanList.get(i).getOid().equals(gateway.getOid())) {
|
gatewayBeanList.remove(i--);
|
}
|
}
|
|
//没有找到就添加
|
if (!isFound) {
|
gatewayBeanList.add(gateway);
|
}
|
}
|
|
/**
|
* 获取网关对象
|
*
|
* @param linkResponse
|
* @return
|
*/
|
private GatewayBean getGatewayBeanByResponse(LinkResponse linkResponse) {
|
String data = linkResponse.getData();
|
if (!TextUtils.isEmpty(data)) {
|
final BaseLocalResponse<GatewayBean> response = GsonConvert.getGson().fromJson(data, new TypeToken<BaseLocalResponse<GatewayBean>>() {
|
}.getType());
|
return response.getObjects();
|
}
|
return null;
|
}
|
|
/*
|
* 绑定网关
|
* */
|
public void bindGateway(String name, String mac, String homeId, String regionUrl, String ip, boolean isEncrypt, HDLLinkCallBack callBack) {
|
String topic = String.format(TopicConstant.GATEWAY_EDIT_REMOTE, mac);
|
|
JsonObject jObject = new JsonObject();
|
jObject.addProperty("homeId", homeId);
|
jObject.addProperty("server_addr", regionUrl);
|
// jObject.addProperty("device_name", name);
|
jObject.addProperty("remote", "true");
|
|
JsonObject sendJsonObj = new JsonObject();
|
sendJsonObj.add("objects", jObject);
|
String time = String.valueOf(System.currentTimeMillis());
|
sendJsonObj.addProperty("time_stamp", time);
|
sendJsonObj.addProperty("id", IdUtils.getUUId());
|
String sendStr = sendJsonObj.toString();
|
|
LinkRequest message = new LinkRequest(topic, sendStr, isEncrypt);
|
new HDLConnectHelper(ip, message, topic + "_reply", new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (callBack == null) return;
|
callBack.onSuccess("1");
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack == null) return;
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_TIMEOUT_ERROR));
|
}
|
}, true).send();
|
}
|
|
/*
|
* 初始化网关
|
* */
|
public void initializeGateway(String mac, String oid, String ip, boolean isEncrypt, HDLLinkCallBack callBack) {
|
String topic = String.format(TopicConstant.GATEWAY_INITIALIZE_REMOTE, oid);
|
|
JsonObject sendJsonObj = new JsonObject();
|
String time = String.valueOf(System.currentTimeMillis());
|
sendJsonObj.addProperty("time_stamp", time);
|
sendJsonObj.addProperty("id", IdUtils.getUUId());
|
JsonObject jObject = new JsonObject();
|
jObject.addProperty("device_mac", mac);
|
sendJsonObj.add("objects", jObject);
|
String sendStr = sendJsonObj.toString();
|
|
LinkRequest message = new LinkRequest(topic, sendStr, isEncrypt);
|
new HDLConnectHelper(ip, message, topic + "_reply", new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (callBack == null) return;
|
callBack.onSuccess("1");
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack == null) return;
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_TIMEOUT_ERROR));
|
}
|
}, true).send();
|
}
|
|
/*
|
* 设置主从网关标记
|
* */
|
public void setMasterGateway(String ip, String mac, String master, boolean isEncrypt, HDLLinkCallBack callBack) {
|
String topic = String.format(TopicConstant.GATEWAY_EDIT_LOCAL, mac);
|
|
JsonObject jObject = new JsonObject();
|
jObject.addProperty("master", master);
|
|
JsonObject sendJsonObj = new JsonObject();
|
sendJsonObj.add("objects", jObject);
|
String time = String.valueOf(System.currentTimeMillis());
|
sendJsonObj.addProperty("time_stamp", time);
|
sendJsonObj.addProperty("id", IdUtils.getUUId());
|
String sendStr = sendJsonObj.toString();
|
|
LinkRequest message = new LinkRequest(topic, sendStr, isEncrypt);
|
new HDLConnectHelper(ip, message, topic + "_reply", new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (callBack == null) return;
|
callBack.onSuccess("1");
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack == null) return;
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_TIMEOUT_ERROR));
|
}
|
}, true).send();
|
}
|
|
/**
|
* 设置网关入网从机模式
|
*/
|
public void AuthGateway(String ip, String mac) {
|
String topic = String.format(TopicConstant.GATEWAY_AUTH, mac);
|
|
JsonObject sendJsonObj = new JsonObject();
|
String time = String.valueOf(System.currentTimeMillis());
|
sendJsonObj.addProperty("time_stamp", time);
|
sendJsonObj.addProperty("id", IdUtils.getUUId());
|
JsonObject jObject = new JsonObject();
|
jObject.addProperty("spk", "LINKDEVICE");
|
jObject.addProperty("time", "120");
|
sendJsonObj.add("objects", jObject);
|
|
|
String sendStr = sendJsonObj.toString();
|
LinkRequest message = new LinkRequest(topic, sendStr, false);
|
new HDLConnectHelper(ip, message, topic + "_reply", new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
}
|
|
@Override
|
public void onFailure() {
|
}
|
}, true).send();
|
}
|
|
/*
|
* 获取网关信息
|
* */
|
public void getGatewayInfo(String ip, String mac, boolean isEncrypt, HDLLinkCallBack callBack) {
|
String topic = String.format(TopicConstant.GATEWAY_GET, mac);
|
|
JsonObject sendJsonObj = new JsonObject();
|
String time = String.valueOf(System.currentTimeMillis());
|
sendJsonObj.addProperty("time_stamp", time);
|
sendJsonObj.addProperty("id", IdUtils.getUUId());
|
String sendStr = sendJsonObj.toString();
|
|
LinkRequest message = new LinkRequest(topic, sendStr, isEncrypt);
|
new HDLConnectHelper(ip, message, topic + "_reply", new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (callBack == null) return;
|
callBack.onSuccess("1");
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack == null) return;
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_TIMEOUT_ERROR));
|
}
|
}, true).send();
|
}
|
|
|
|
/**
|
* 发送数据到Link网关
|
* @param ip 网关IP
|
* @param mac 网关mac
|
* @param isEncrypt 是否加密
|
* @param topic 请求主题
|
* @param jObject 负载数据<没有填null></>
|
* @param sendPath 发送路径<类名+方法名>class->methodName</>
|
*/
|
public void sendDataToLinkGateway(String ip, String mac, boolean isEncrypt,
|
String topic, Object jObject,String sendPath, HDLLinkCallBack callBack) {
|
String topicSend = topic.replace("%s", mac);
|
//组装需要发送的数据
|
String sendStr = createSendData(jObject);
|
System.out.print("sendDataToLinkGateway->"+sendPath+"->本地发送\r\n"+topicSend+"\r\n"+sendStr);
|
LinkRequest message = new LinkRequest(topicSend, sendStr, isEncrypt);
|
new HDLConnectHelper(ip, message, topicSend + "_reply", new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (callBack == null) return;
|
callBack.onSuccess(msg.toString());
|
System.out.print("sendDataToLinkGateway->"+sendPath+"->本地接收数据\r\n"+msg.toString());
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack == null) return;
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_TIMEOUT_ERROR));
|
System.out.print("sendDataToLinkGateway->"+sendPath+"->本地接收数据->失败(-200)");
|
}
|
}, true).send();
|
}
|
|
/**
|
* 组装需要发送的数据
|
*
|
* @param jObject
|
* @return 负载数据<没有填null>
|
*/
|
public String createSendData(Object jObject) {
|
//topic = String.format(TopicConstant.GATEWAY_EDIT_LOCAL, mac);
|
JsonObject sendJsonObj = new JsonObject();
|
if (jObject != null) {
|
if (jObject instanceof JsonObject) {
|
sendJsonObj.add("objects", (JsonObject) jObject);
|
} else if (jObject instanceof JsonArray) {
|
sendJsonObj.add("objects", (JsonArray) jObject);
|
}
|
}
|
String time = String.valueOf(System.currentTimeMillis());
|
sendJsonObj.addProperty("time_stamp", time);
|
sendJsonObj.addProperty("id", IdUtils.getUUId());
|
String sendStr = sendJsonObj.toString();
|
return sendStr;
|
}
|
}
|
