package com.hdl.sdk.link;
|
|
|
|
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.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.LogUtils;
|
import com.hdl.sdk.link.common.utils.TextUtils;
|
import com.hdl.sdk.link.common.utils.gson.GsonConvert;
|
import com.hdl.sdk.link.bean.LinkCreateLogicBean;
|
import com.hdl.sdk.link.bean.LinkCreateSceneBean;
|
import com.hdl.sdk.link.bean.LinkEnableLogicBean;
|
import com.hdl.sdk.link.bean.LinkEnableSecurityBean;
|
import com.hdl.sdk.link.bean.LinkFunctionBean;
|
import com.hdl.sdk.link.bean.LinkLogicBean;
|
import com.hdl.sdk.link.bean.LinkOidBean;
|
import com.hdl.sdk.link.bean.LinkReNameGWBean;
|
import com.hdl.sdk.link.bean.LinkResponseBean;
|
import com.hdl.sdk.link.bean.LinkRoomBean;
|
import com.hdl.sdk.link.bean.LinkRoomBindBean;
|
import com.hdl.sdk.link.bean.LinkSceneBean;
|
import com.hdl.sdk.link.bean.LinkSidStrBean;
|
import com.hdl.sdk.link.bean.LinkSidUidBean;
|
import com.hdl.sdk.link.core.bean.FileRequest;
|
import com.hdl.sdk.link.core.bean.LinkRequest;
|
import com.hdl.sdk.link.core.bean.LinkResponse;
|
import com.hdl.sdk.link.core.bean.request.AuthenticateRequest;
|
import com.hdl.sdk.link.core.bean.request.DeviceControlRequest;
|
import com.hdl.sdk.link.core.bean.request.FunctionAttributeRequest;
|
import com.hdl.sdk.link.core.bean.request.PropertyReadRequest;
|
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.callback.HDLLinkResponseCallBack;
|
import com.hdl.sdk.link.common.event.EventDispatcher;
|
import com.hdl.sdk.link.common.event.EventListener;
|
import com.hdl.sdk.link.core.callback.HDLLinkTCallBack;
|
import com.hdl.sdk.link.core.config.HDLLinkConfig;
|
import com.hdl.sdk.link.core.connect.HDLUdpConnect;
|
import com.hdl.sdk.link.core.bean.gateway.GatewayBean;
|
import com.hdl.sdk.link.core.connect.HDLConnectHelper;
|
import com.hdl.sdk.link.core.utils.LinkResponseUtils;
|
import com.hdl.sdk.link.core.utils.QueueUtils;
|
import com.hdl.sdk.link.gateway.HDLLinkLocalGateway;
|
|
import java.lang.reflect.Type;
|
import java.nio.charset.StandardCharsets;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Locale;
|
|
/**
|
* Created by jlchen on 11/15/21.
|
*
|
* @Description : HDLLink
|
*/
|
public class HDLLinkLocalSdk {
|
|
private String language="zh";
|
/**
|
* instance
|
*/
|
private volatile static HDLLinkLocalSdk instance;
|
|
/**
|
* getInstance
|
*
|
* @return HDLLink
|
*/
|
public static synchronized HDLLinkLocalSdk getInstance() {
|
if (instance == null) {
|
synchronized (HDLLinkLocalSdk.class) {
|
if (instance == null) {
|
instance = new HDLLinkLocalSdk();
|
}
|
}
|
}
|
return instance;
|
}
|
|
/**
|
* 本地SDK初始化，初始化网关Id及本地通讯的密钥
|
* @param gatewayId 网关Id
|
* @param localSecret 密钥
|
*/
|
public void init(String gatewayId,String localSecret){
|
//对HDL应用软件来说，本地通讯密钥和网关Id在使用时要设置
|
HDLLinkConfig.getInstance().setLocalSecret(localSecret);
|
HDLLinkConfig.getInstance().setGatewayId(gatewayId);
|
QueueUtils.getInstance().start();//初始化接收数据线程
|
HDLUdpConnect.getInstance().initUdp();//初始化udp监听
|
searchGatewayBroadcast(null);//搜索网关
|
}
|
|
public void setlanguage(String language){
|
this.language=language;
|
}
|
public String getLanguage(){
|
return language;
|
}
|
|
|
/**
|
* 设置打印是否开启
|
* @param enable
|
*/
|
public void setLogEnabled(boolean enable){
|
LogUtils.setEnabled(enable);
|
}
|
|
/**
|
* 注册所有主题消息的监听
|
*
|
* @param listener
|
*/
|
public synchronized void registerAllTopicsListener(EventListener listener) {
|
EventDispatcher.getInstance().registerAllTopicsListener(listener);
|
}
|
|
/**
|
* 取消所有主题消息的监听
|
*
|
* @param listener
|
*/
|
public synchronized void removeAllTopicsListener(EventListener listener) {
|
if (listener == null) return;
|
EventDispatcher.getInstance().removeAllTopicsListener(listener);
|
}
|
|
/***********************三方设备和网关通信之前的认证流程****************************/
|
/**
|
* 检测是否已经认证过
|
* 认证通过才能进行设备控制
|
*
|
* @return
|
*/
|
public boolean checkIfCertified() {
|
return HDLLinkConfig.getInstance().checkIfCertified();
|
}
|
|
/**
|
* 开始监听和发起入网及认证请求
|
*
|
* @param request 认证请求信息
|
* @param callBack 结果回调
|
*/
|
public void startAuthenticateRequest(AuthenticateRequest request, HDLLinkCallBack callBack) {
|
HDLUdpConnect.getInstance().startAuthenticateRequest(request, callBack);
|
}
|
|
/**
|
* 发送入网及认证请求
|
*
|
* @param ip 网关IP
|
* @param request 认证请求信息
|
* @param callBack 结果回调
|
*/
|
public void sendAuthenticateRequest(String ip, AuthenticateRequest request, HDLLinkCallBack callBack) {
|
HDLUdpConnect.getInstance().sendAuthenticateRequest(ip, request, callBack);
|
}
|
|
/***********************三方设备请先认证成功 再调用下面的接口和网关通信****************************/
|
/**
|
* 组播搜索指定网关是否在线，搜索到则返回指定的网关对象
|
*
|
* @param callBack 回调
|
*/
|
public void searchGatewayMulticast(HDLUdpConnect.SearchGatewayCallBack callBack) {
|
HDLUdpConnect.getInstance().searchGatewayMulticast(callBack);
|
}
|
|
/**
|
* 组播搜索指定网关是否在线，搜索到则返回指定的网关对象
|
*
|
* @param callBack 回调
|
*/
|
public void searchGatewayBroadcast(HDLUdpConnect.SearchGatewayCallBack callBack) {
|
HDLUdpConnect.getInstance().searchGatewayBroadcast(callBack);
|
}
|
|
/**
|
* 获取设备列表
|
*/
|
public void getDeviceList(HDLLinkTCallBack<List<LinkOidBean>> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
|
if (!TextUtils.isEmpty(gatewayId)) {
|
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, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, jsonObject.toString(), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
|
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("getDeviceList onSuccess");
|
Type type = new TypeToken<BaseLocalResponse<List<LinkOidBean>>>() {
|
}.getType();
|
List<LinkOidBean> list = LinkResponseUtils.convertLinkResponse(msg, type);
|
if (list == null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_DATA_PARSING_ERROR));
|
} else {
|
callBack.onSuccess(list);
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
|
/**
|
* 更改网关备注名
|
*/
|
public void changeGWName(String gateWayName, HDLLinkTCallBack<String> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<LinkReNameGWBean> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
LinkReNameGWBean linkReNameGWBean = new LinkReNameGWBean();
|
linkReNameGWBean.setDevice_name(gateWayName);
|
data.setObjects(linkReNameGWBean);
|
String topic = String.format(TopicConstant.GATEWAY_RENAME, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
Type type = new TypeToken<BaseLocalResponse<LinkResponseBean>>() {
|
}.getType();
|
LinkResponseBean bean = LinkResponseUtils.convertLinkResponse(msg, type);
|
callBack.onSuccess("Success");
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* sid绑定房间
|
*/
|
public void sidBindUid(List<LinkSidUidBean> bean, HDLLinkTCallBack<String> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<List<LinkSidUidBean>> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
data.setObjects(bean);
|
String topic = String.format(TopicConstant.SID_BIND_ROOM, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
Type type = new TypeToken<BaseLocalResponse<LinkResponseBean>>() {
|
}.getType();
|
LinkResponseBean bean = LinkResponseUtils.convertLinkResponse(msg, type);
|
// TODO: 2022/1/13 处理200code
|
callBack.onSuccess("Success");
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* sid删除绑定房间关系
|
*/
|
public void sidDeleteUid(List<LinkSidUidBean> bean, HDLLinkTCallBack<String> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<List<LinkSidUidBean>> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
data.setObjects(bean);
|
String topic = String.format(TopicConstant.SID_DELETE_ROOM, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
callBack.onSuccess("Success");
|
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 创建场景
|
*/
|
public void createScene(List<LinkCreateSceneBean> bean, HDLLinkTCallBack<String> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<List<LinkCreateSceneBean>> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
data.setObjects(bean);
|
String topic = String.format(TopicConstant.CREATE_SCENE, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
callBack.onSuccess("Success");
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 编辑场景
|
*/
|
public void editScene(List<LinkCreateSceneBean> bean, HDLLinkTCallBack<String> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<List<LinkCreateSceneBean>> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
data.setObjects(bean);
|
String topic = String.format(TopicConstant.SCENE_EDIT, gatewayId);
|
for(int i=0;i<data.getObjects().size();i++){
|
if(data.getObjects().get(i).getFunctions().size()==0){
|
data.getObjects().get(i).setFunctions(null);
|
}
|
if(data.getObjects().get(i).getUids().size()==0){
|
data.getObjects().get(i).setUids(null);
|
}
|
}
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
LogUtils.d("LinkRequestLinkRequest", GsonConvert.getGson().toJson(request));
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
callBack.onSuccess("Success");
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 删除场景
|
*/
|
public void deleteScene(List<LinkSidStrBean> bean, HDLLinkTCallBack<String> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<List<LinkSidStrBean>> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
data.setObjects(bean);
|
String topic = String.format(TopicConstant.SCENE_DELETE, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
callBack.onSuccess("Success");
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 获取自动化列表
|
*/
|
public void getLogicList(HDLLinkTCallBack<List<LinkLogicBean>> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
|
if (!TextUtils.isEmpty(gatewayId)) {
|
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.LOGIC_LIST_GET, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, jsonObject.toString(), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("getSceneList onSuccess");
|
if (callBack != null) {
|
Type type = new TypeToken<BaseLocalResponse<List<LinkLogicBean>>>() {
|
}.getType();
|
List<LinkLogicBean> list = LinkResponseUtils.convertLinkResponse(msg, type);
|
if (list == null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_DATA_PARSING_ERROR));
|
} else {
|
callBack.onSuccess(list);
|
}
|
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 获取自动化详情
|
*/
|
public void getLogicDetail(List<LinkSidStrBean> list, HDLLinkTCallBack<List<LinkCreateLogicBean>> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<List<LinkSidStrBean>> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
data.setObjects(list);
|
|
String topic = String.format(TopicConstant.LOGIC_GET, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("getSceneList onSuccess");
|
if (callBack != null) {
|
Type type = new TypeToken<BaseLocalResponse<List<LinkCreateLogicBean>>>() {
|
}.getType();
|
List<LinkCreateLogicBean> list = LinkResponseUtils.convertLinkResponse(msg, type);
|
if (list == null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_DATA_PARSING_ERROR));
|
} else {
|
callBack.onSuccess(list);
|
}
|
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 新建自动化
|
*/
|
public void createLogic(List<LinkCreateLogicBean> bean, HDLLinkTCallBack<String> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<List<LinkCreateLogicBean>> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
data.setObjects(bean);
|
String topic = String.format(TopicConstant.LOGIC_EDIT, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
callBack.onSuccess("Success");
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 开启关闭自动化
|
*/
|
public void enableLogic(List<LinkEnableLogicBean> bean, HDLLinkTCallBack<String> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<List<LinkEnableLogicBean>> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
data.setObjects(bean);
|
String topic = String.format(TopicConstant.LOGIC_ENABLE_EDIT, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
callBack.onSuccess("Success");
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 删除自动化
|
*/
|
public void deleteLogic(List<LinkSidStrBean> bean, HDLLinkTCallBack<String> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<List<LinkSidStrBean>> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
data.setObjects(bean);
|
String topic = String.format(TopicConstant.LOGIC_DELETE, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
callBack.onSuccess("Success");
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 获取安防列表
|
*/
|
public void getSecurityList(HDLLinkTCallBack<List<LinkLogicBean>> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
|
if (!TextUtils.isEmpty(gatewayId)) {
|
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.SECURITY_LIST_GET, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, jsonObject.toString(), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("getSceneList onSuccess");
|
if (callBack != null) {
|
Type type = new TypeToken<BaseLocalResponse<List<LinkLogicBean>>>() {
|
}.getType();
|
List<LinkLogicBean> list = LinkResponseUtils.convertLinkResponse(msg, type);
|
if (list == null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_DATA_PARSING_ERROR));
|
} else {
|
callBack.onSuccess(list);
|
}
|
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 获取自动化详情
|
*/
|
public void getSecurityDetail(List<LinkSidStrBean> list, HDLLinkTCallBack<List<LinkCreateLogicBean>> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<List<LinkSidStrBean>> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
data.setObjects(list);
|
|
String topic = String.format(TopicConstant.SECURITY_GET, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("getSceneList onSuccess");
|
if (callBack != null) {
|
Type type = new TypeToken<BaseLocalResponse<List<LinkCreateLogicBean>>>() {
|
}.getType();
|
List<LinkCreateLogicBean> list = LinkResponseUtils.convertLinkResponse(msg, type);
|
if (list == null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_DATA_PARSING_ERROR));
|
} else {
|
callBack.onSuccess(list);
|
}
|
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 新建安防
|
*/
|
public void createSecurity(List<LinkCreateLogicBean> bean, HDLLinkTCallBack<String> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<List<LinkCreateLogicBean>> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
data.setObjects(bean);
|
String topic = String.format(TopicConstant.SECURITY_EDIT, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
callBack.onSuccess("Success");
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 删除安防
|
*/
|
public void deleteSecurity(List<LinkSidStrBean> bean, HDLLinkTCallBack<String> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<List<LinkSidStrBean>> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
data.setObjects(bean);
|
String topic = String.format(TopicConstant.SECURITY_DELETE, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
callBack.onSuccess("Success");
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 开启关闭自动化
|
*/
|
public void enableSecurity(List<LinkEnableSecurityBean> bean, HDLLinkTCallBack<String> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<List<LinkEnableSecurityBean>> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
data.setObjects(bean);
|
String topic = String.format(TopicConstant.SECURITY_STATUS_SET, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
callBack.onSuccess("Success");
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
|
/**
|
* 获取功能列表
|
*/
|
public void getFunctionList(HDLLinkTCallBack<List<LinkFunctionBean>> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
if (!TextUtils.isEmpty(gatewayId)) {
|
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, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, jsonObject.toString(), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
Type type = new TypeToken<BaseLocalResponse<List<LinkFunctionBean>>>() {
|
}.getType();
|
List<LinkFunctionBean> list = LinkResponseUtils.convertLinkResponse(msg, type);
|
if (list == null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_DATA_PARSING_ERROR));
|
} else {
|
callBack.onSuccess(list);
|
}
|
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 更改Sid备注名
|
*/
|
public void editSidName(BaseLocalResponse<List<JsonObject>> data, HDLLinkTCallBack<String> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
// LinkReNameGWBean linkReNameGWBean = new LinkReNameGWBean();
|
// linkReNameGWBean.setDevice_name(sidName);
|
// data.setObjects(linkReNameGWBean);
|
String topic = String.format(TopicConstant.EDIT_FUNCTION, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
Type type = new TypeToken<BaseLocalResponse<LinkResponseBean>>() {
|
}.getType();
|
LinkResponseBean bean = LinkResponseUtils.convertLinkResponse(msg, type);
|
callBack.onSuccess("Success");
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 获取功能属性
|
* 支持批量
|
*
|
* @param sids
|
* @param callBack
|
*/
|
public void getFunctionAttribute(List<String> sids, HDLLinkTCallBack<List<LinkFunctionBean>> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
|
if (!TextUtils.isEmpty(gatewayId)) {
|
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, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("getFunctionAttribute onSuccess");
|
if (callBack != null) {
|
Type type = new TypeToken<BaseLocalResponse<List<LinkFunctionBean>>>() {
|
}.getType();
|
List<LinkFunctionBean> list = LinkResponseUtils.convertLinkResponse(msg, type);
|
if (list == null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_DATA_PARSING_ERROR));
|
} else {
|
callBack.onSuccess(list);
|
}
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 设备控制
|
*
|
* @param requestList 控制状态参数
|
* @param callBack 结果回调
|
*/
|
public void propertyDown(List<DeviceControlRequest> requestList, HDLLinkCallBack callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
|
final BaseLocalResponse<List<DeviceControlRequest>> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
data.setObjects(requestList);
|
|
String topic = String.format(TopicConstant.PROPERTY_DOWN, gatewayId);
|
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
callBack.onSuccess(msg.toString());
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
|
}
|
|
/**
|
* 读取状态
|
*
|
* @param sids 请求参数 指定读取的设备sid列表
|
* @param callBack 回调
|
*/
|
public void propertyRead(List<String> sids, HDLLinkCallBack callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
|
if (!TextUtils.isEmpty(gatewayId)) {
|
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, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
callBack.onSuccess(msg.toString());
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 获取场景列表
|
*/
|
public void getSceneList(HDLLinkTCallBack<List<LinkSceneBean>> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
|
if (!TextUtils.isEmpty(gatewayId)) {
|
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, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, jsonObject.toString(), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("getSceneList onSuccess");
|
if (callBack != null) {
|
Type type = new TypeToken<BaseLocalResponse<List<LinkSceneBean>>>() {
|
}.getType();
|
List<LinkSceneBean> list = LinkResponseUtils.convertLinkResponse(msg, type);
|
if (list == null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_DATA_PARSING_ERROR));
|
} else {
|
callBack.onSuccess(list);
|
}
|
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 获取场景详情
|
*/
|
public void getSceneDetail(List<LinkSidStrBean> list, HDLLinkTCallBack<List<LinkCreateSceneBean>> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<List<LinkSidStrBean>> data = new BaseLocalResponse<>();
|
data.setId(IdUtils.getUUId());
|
data.setTime_stamp(time);
|
data.setObjects(list);
|
String topic = String.format(TopicConstant.SCENE_GET, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("getSceneList onSuccess");
|
if (callBack != null) {
|
Type type = new TypeToken<BaseLocalResponse<List<LinkCreateSceneBean>>>() {
|
}.getType();
|
List<LinkCreateSceneBean> list = LinkResponseUtils.convertLinkResponse(msg, type);
|
if (list == null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_DATA_PARSING_ERROR));
|
} else {
|
callBack.onSuccess(list);
|
}
|
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 场景控制
|
*
|
* @param sids 场景sid列表
|
* @param callBack 回调
|
*/
|
public void controlScene(List<String> sids, HDLLinkCallBack callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
if (!TextUtils.isEmpty(gatewayId)) {
|
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, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(data), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
callBack.onSuccess(msg.toString());
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 通用UDP发送指令
|
* 1秒没响应就让他重新发送,重试3次
|
*
|
* @param topic 发送数据
|
* @param bodyStr body内容
|
* @param callBack 回调
|
*/
|
public void udpSendMsg(String topic, String bodyStr, HDLLinkResponseCallBack callBack) {
|
HDLUdpConnect.getInstance().udpSendMsg(topic, bodyStr, false, callBack);
|
}
|
|
/**
|
* 通用广播UDP发送指令
|
* 1秒没响应就让他重新发送,重试3次
|
*
|
* @param topic 发送数据
|
* @param bodyStr body内容
|
* @param callBack 回调
|
*/
|
public void udpBroadcastSendMsg(String topic, String bodyStr, HDLLinkResponseCallBack callBack) {
|
HDLUdpConnect.getInstance().udpSendMsg(topic, bodyStr, true, callBack);
|
}
|
|
/**
|
* 通用TCP发送指令
|
* 1秒没响应就让他重新发送,重试3次
|
*
|
* @param topic 发送数据
|
* @param body body内容
|
* @param callBack 回调
|
*/
|
public void tcpSendMsg(String topic, String body, HDLLinkCallBack callBack) {
|
|
LinkRequest request = new LinkRequest(topic, body, HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
callBack.onSuccess(msg.toString());
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
}
|
|
/**
|
* 通用TCP发送指令 只发一次，不监听回复，不重发
|
*
|
* @param topic 发送数据
|
* @param body 回复的主题
|
*/
|
public void tcpSendMsg(String topic, String body) {
|
LinkRequest request = new LinkRequest(topic, body, HDLLinkConfig.getInstance().isLocalEncrypt());
|
new HDLConnectHelper(1, HDLLinkConfig.getInstance().getIpAddress(), request, true);
|
}
|
/**
|
* 创新网关列表，重新读取
|
*
|
* @param homeId 住宅Id
|
* @param callBack 回调所有读取到的网关列表
|
*/
|
public void refreshGatewayByHome(String homeId, GatewayCallBack callBack) {
|
HDLLinkLocalGateway.getInstance().refreshGatewayByHome(homeId, callBack);
|
}
|
|
/**
|
* 创新网关列表，重新读取
|
*
|
* @param callBack 回调所有读取到的网关列表
|
*/
|
public void refreshGateway(GatewayCallBack callBack) {
|
HDLLinkLocalGateway.getInstance().refreshGateway(callBack);
|
}
|
|
/**
|
* 获取当前住宅缓存的所有网关，一般是调试软件使用，三方不用调试此方法
|
* 如果之前还没有读取过网关，先调用方法refreshGatewayByHome读取一次
|
*
|
* @return
|
*/
|
public List<GatewayBean> getGatewayByHome() {
|
return HDLLinkLocalGateway.getInstance().getGatewayList();
|
}
|
|
|
/**
|
* 获取房间列表
|
*
|
* @param callBack
|
*/
|
public void getRoomList(HDLLinkTCallBack<List<LinkRoomBean>> callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
if (!TextUtils.isEmpty(gatewayId)) {
|
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.ROOM_LIST_GET, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, jsonObject.toString(), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("getRoomList onSuccess");
|
Type type = new TypeToken<BaseLocalResponse<List<LinkRoomBean>>>() {
|
}.getType();
|
List<LinkRoomBean> list = LinkResponseUtils.convertLinkResponse(msg, type);
|
if (list == null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_DATA_PARSING_ERROR));
|
} else {
|
callBack.onSuccess(list);
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 全量更新房间列表
|
*
|
* @param list
|
* @param callBack
|
*/
|
public void coverAddRoomList(List<LinkRoomBean> list, HDLLinkCallBack callBack) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
final BaseLocalResponse<List<LinkRoomBean>> senData = new BaseLocalResponse<>();
|
senData.setId(IdUtils.getUUId());
|
senData.setTime_stamp(time);
|
senData.setObjects(list);
|
|
String topic = String.format(TopicConstant.ROOM_COVER_ADD, gatewayId);
|
LinkRequest request = new LinkRequest(topic, GsonConvert.getGson().toJson(senData), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("sendMsg onSuccess");
|
if (callBack != null) {
|
callBack.onSuccess(msg.toString());
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
/**
|
* 获取房间绑定关系
|
*/
|
public void getRoomBindList(HDLLinkTCallBack<List<LinkRoomBindBean>> callBack,List<String> uidRoomList) {
|
if (null == callBack) {
|
return;
|
}
|
String gatewayId = HDLLinkConfig.getInstance().getGatewayId();
|
|
if (!TextUtils.isEmpty(gatewayId)) {
|
String time = String.valueOf(System.currentTimeMillis());
|
JsonObject jsonObject = new JsonObject();
|
jsonObject.addProperty("id", IdUtils.getUUId());
|
jsonObject.addProperty("time_stamp", time);
|
JsonArray array = new JsonArray();
|
for (String uid:uidRoomList){
|
array.add(uid);
|
}
|
jsonObject.add("objects", array);
|
|
String topic = String.format(TopicConstant.ROOM_BIND_LIST_GET, gatewayId);
|
|
LinkRequest request = new LinkRequest(topic, jsonObject.toString(), HDLLinkConfig.getInstance().isLocalEncrypt());
|
String replyTopic = topic + "_reply";
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), request, replyTopic, new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
if (msg instanceof LinkResponse) {
|
LogUtils.i("getRoomBindList onSuccess");
|
Type type = new TypeToken<BaseLocalResponse<List<LinkRoomBindBean>>>() {
|
}.getType();
|
List<LinkRoomBindBean> list = LinkResponseUtils.convertLinkResponse(msg, type);
|
if (list == null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_DATA_PARSING_ERROR));
|
} else {
|
callBack.onSuccess(list);
|
}
|
}
|
}
|
|
@Override
|
public void onFailure() {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_SEND_ERROR));
|
}
|
}
|
}, true).send();
|
} else {
|
if (callBack != null) {
|
callBack.onError(HDLLinkException.getErrorWithCode(HDLLinkCode.HDL_GATEWAY_NOT_EXIST));
|
}
|
}
|
}
|
|
|
|
/*********************** 文件传输 ****************************/
|
/**
|
* 文件用途通知
|
* @param fileId 文件Id
|
* @param fileName 文件名称
|
* @param purpose 用途 用途枚举
|
* zigbee设备配置恢复： ConfigRecoveryForZigbeeDevices
|
* 数据备份：DataBackup
|
* 数据恢复：DataRecovery
|
* @param callBack
|
*/
|
public void sendFileUserNotification(String fileId,String fileName,String purpose, HDLLinkCallBack callBack){
|
//帧格式：head+命令字+数据长度+二进制数据
|
String time = String.valueOf(System.currentTimeMillis());
|
String data ="hex"+"0001"+ fileId+"\r\n"+fileName+"\r\n"+purpose;
|
byte []dataBytes=data.getBytes(StandardCharsets.UTF_8);
|
FileRequest linkRequest = new FileRequest(fileId,0x0011,dataBytes,HDLLinkConfig.getInstance().isLocalEncrypt());
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), linkRequest, linkRequest.getAckTopic(), new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
|
}
|
|
@Override
|
public void onFailure() {
|
|
}
|
}, true).send();
|
}
|
|
/**
|
* 发送文件相关命令
|
*/
|
public void sendFileCommand(byte []dataBytes,Integer command, HDLLinkCallBack callBack){
|
//帧格式：head+命令字+数据长度+二进制数据
|
String time = String.valueOf(System.currentTimeMillis());
|
// byte []dataBytes=data.getBytes(StandardCharsets.UTF_8);
|
FileRequest linkRequest = new FileRequest("65531",command,dataBytes,HDLLinkConfig.getInstance().isLocalEncrypt());
|
new HDLConnectHelper(HDLLinkConfig.getInstance().getIpAddress(), linkRequest, linkRequest.getAckTopic(), new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
|
}
|
|
@Override
|
public void onFailure() {
|
|
}
|
}, true).send();
|
}
|
|
|
/********************************驱动升级***********************************/
|
/**
|
* 发送文件相关命令
|
*/
|
public void sendFileCommand(String ipAddress,byte []dataBytes,String fileId,Integer command, HDLLinkCallBack callBack){
|
//帧格式：head+命令字+数据长度+二进制数据
|
FileRequest linkRequest = new FileRequest(fileId,command,dataBytes,HDLLinkConfig.getInstance().isLocalEncrypt());
|
new HDLConnectHelper(ipAddress, linkRequest, linkRequest.getAckTopic(), new HDLConnectHelper.HdlSocketListener() {
|
@Override
|
public void onSucceed(Object msg) {
|
|
}
|
|
@Override
|
public void onFailure() {
|
|
}
|
}, true).send();
|
}
|
|
|
}
|
