package com.hdl.linkpm.sdk.template.controller;/*
|
*create by wxr
|
*date 2022/1/19
|
*/
|
|
import com.google.gson.JsonElement;
|
import com.google.gson.JsonObject;
|
import com.hdl.hdlhttp.HxHttp;
|
import com.hdl.linkpm.sdk.HDLLinkPMSdk;
|
import com.hdl.linkpm.sdk.core.api.HDLCloudUserApi;
|
import com.hdl.linkpm.sdk.core.callback.IDefaultCallBack;
|
import com.hdl.linkpm.sdk.core.exception.HDLException;
|
import com.hdl.linkpm.sdk.core.response.HDLResponse;
|
import com.hdl.linkpm.sdk.template.bean.CloudTemplateDevice;
|
import com.hdl.linkpm.sdk.template.bean.CloudTemplateSpatialInfo;
|
import com.hdl.linkpm.sdk.template.bean.TemplateDeviceBean;
|
import com.hdl.linkpm.sdk.template.bean.TemplateFunctionBean;
|
import com.hdl.linkpm.sdk.template.bean.TemplateGatewayBean;
|
import com.hdl.linkpm.sdk.template.bean.TemplateListResponseBean;
|
import com.hdl.linkpm.sdk.template.bean.TemplateLogicBean;
|
import com.hdl.linkpm.sdk.template.bean.TemplateRoomPackBean;
|
import com.hdl.linkpm.sdk.template.bean.TemplateSceneBean;
|
import com.hdl.linkpm.sdk.template.bean.TemplateSecurityBean;
|
import com.hdl.linkpm.sdk.template.callback.ICreateTemplateCallBack;
|
import com.hdl.linkpm.sdk.template.callback.IGetTemplateDeviceListCallBack;
|
import com.hdl.linkpm.sdk.template.callback.IGetTemplateGatewayListCallBack;
|
import com.hdl.linkpm.sdk.template.callback.IGetTemplateSpatialInfoCallBack;
|
import com.hdl.linkpm.sdk.template.callback.ITemplateFunctionsCallBack;
|
import com.hdl.linkpm.sdk.template.callback.ITemplateListCallBack;
|
import com.hdl.linkpm.sdk.template.callback.ITemplateLogicCallBack;
|
import com.hdl.linkpm.sdk.template.callback.ITemplateScenesCallBack;
|
import com.hdl.linkpm.sdk.template.callback.ITemplateSecurityCallBack;
|
import com.hdl.linkpm.sdk.utils.HDLExceptionSubmitUtils;
|
import com.hdl.linkpm.sdk.utils.HDLGsonUtils;
|
|
import java.util.List;
|
|
import io.reactivex.rxjava3.disposables.Disposable;
|
|
public class HDLTemplateController {
|
private volatile static HDLTemplateController instance;
|
|
public static synchronized HDLTemplateController getInstance() {
|
if (instance == null) {
|
synchronized (HDLTemplateController.class) {
|
if (instance == null) {
|
instance = new HDLTemplateController();
|
}
|
}
|
}
|
return instance;
|
}
|
|
|
/**
|
* 创建模板
|
* @param templateName
|
* @param communityCode
|
* @param houseLayoutId
|
* @param templateDesc
|
* @param callBack
|
* @return
|
*/
|
public Disposable CreateTemplate(String templateName, String communityCode, String houseLayoutId, String templateDesc, ICreateTemplateCallBack callBack) {
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_TEMPLATE_CREATE;
|
JsonObject json = new JsonObject();
|
json.addProperty("templateName", templateName);
|
json.addProperty("templateSourcePlatform", "app");
|
json.addProperty("communityCode", communityCode);
|
json.addProperty("houseLayoutId", houseLayoutId);
|
json.addProperty("templateDesc", templateDesc);
|
return HxHttp.builder()
|
.url(requestUrl)
|
.raw(json.toString())
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<String>() {
|
@Override
|
public void onResponse(String data) {
|
if (callBack != null) {
|
callBack.onSuccess(data);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
public Disposable GetTemplateList(int pageNo,int pageSize,ITemplateListCallBack callBack) {
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_TEMPLATE_GET_LIST;
|
JsonObject json = new JsonObject();
|
json.addProperty("pageNo",pageNo);
|
json.addProperty("pageSize",pageSize);
|
return HxHttp.builder()
|
.url(requestUrl)
|
.raw(json.toString())
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<TemplateListResponseBean>() {
|
@Override
|
public void onResponse(TemplateListResponseBean beans) {
|
if (callBack != null) {
|
callBack.onSuccess(beans);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
/**
|
* 删除模板
|
* @param templateExtendsId 模板ID
|
* @param callBack
|
* @return
|
*/
|
public Disposable DeleteTemplate(String templateExtendsId,IDefaultCallBack callBack) {
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_TEMPLATE_DELETE;
|
JsonObject json = new JsonObject();
|
json.addProperty("templateExtendsId", templateExtendsId);
|
return HxHttp.builder()
|
.url(requestUrl)
|
.raw(json.toString())
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<String>() {
|
@Override
|
public void onResponse(String code) {
|
if (callBack != null) {
|
callBack.onSuccess();
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 更新网关列表(全量)
|
* @param templateExtendsId
|
* @param gatewayBeans
|
* @param callBack
|
* @return
|
*/
|
public Disposable UpdateTemplateGateway(String templateExtendsId, List<TemplateGatewayBean> gatewayBeans,IDefaultCallBack callBack){
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_TEMPLATE_UPDATE_GATEWAY;
|
JsonObject json = new JsonObject();
|
json.addProperty("templateExtendsId", templateExtendsId);
|
json.add("beans", HDLGsonUtils.toJsonArray(gatewayBeans));
|
return HxHttp.builder()
|
.url(requestUrl)
|
.raw(json.toString())
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<String>() {
|
@Override
|
public void onResponse(String code) {
|
if (callBack != null) {
|
callBack.onSuccess();
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 更新房间（楼层）信息(全量)
|
* @param templateExtendsId
|
* @param rooms
|
* @param callBack
|
* @return
|
*/
|
public Disposable UpdateTemplateRoom(String templateExtendsId ,List<TemplateRoomPackBean.TemplateRoomInfoBean> rooms,
|
IDefaultCallBack callBack){
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_TEMPLATE_UPDATE_ROOM;
|
JsonObject json = new JsonObject();
|
json.addProperty("templateExtendsId", templateExtendsId);
|
json.add("roomInfos", HDLGsonUtils.toJsonArray(rooms));
|
return HxHttp.builder()
|
.url(requestUrl)
|
.raw(json.toString())
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<String>() {
|
@Override
|
public void onResponse(String code) {
|
if (callBack != null) {
|
callBack.onSuccess();
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 添加设备(全量)
|
* @param templateExtendsId
|
* @param beans
|
* @param callBack
|
* @return
|
*/
|
public Disposable UpdateTemplateDevices(String templateExtendsId,List<TemplateDeviceBean> beans,
|
IDefaultCallBack callBack) {
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_TEMPLATE_UPDATE_DEVICES;
|
JsonObject json = new JsonObject();
|
json.addProperty("templateExtendsId", templateExtendsId);
|
json.add("beans", HDLGsonUtils.toJsonArray(beans));
|
return HxHttp.builder()
|
.url(requestUrl)
|
.raw(json.toString())
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<String>() {
|
@Override
|
public void onResponse(String code) {
|
if (callBack != null) {
|
callBack.onSuccess();
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 添加功能(全量)
|
* @param templateExtendsId
|
* @param functionInfoList
|
* @param callBack
|
* @return
|
*/
|
public Disposable UpdateTemplateFunctions(String templateExtendsId, List<TemplateFunctionBean> functionInfoList,
|
IDefaultCallBack callBack) {
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_TEMPLATE_UPDATE_FUNCTIONS;
|
JsonObject json = new JsonObject();
|
json.addProperty("templateExtendsId", templateExtendsId);
|
json.add("deviceInfos", HDLGsonUtils.toJsonArray(functionInfoList));
|
return HxHttp.builder()
|
.url(requestUrl)
|
.raw(json.toString())
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<String>() {
|
@Override
|
public void onResponse(String code) {
|
if (callBack != null) {
|
callBack.onSuccess();
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 更新模板场景(全量)
|
* @param templateExtendsId
|
* @param sceneBeans
|
* @param callBack
|
* @return
|
*/
|
public Disposable UpdataTemplateScenes(String templateExtendsId, List<TemplateSceneBean> sceneBeans,
|
IDefaultCallBack callBack){
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_TEMPLATE_UPDATE_SCENES;
|
JsonObject json = new JsonObject();
|
json.addProperty("templateExtendsId", templateExtendsId);
|
json.add("sceneInfos", HDLGsonUtils.toJsonArray(sceneBeans));
|
return HxHttp.builder()
|
.url(requestUrl)
|
.raw(json.toString())
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<String>() {
|
@Override
|
public void onResponse(String code) {
|
if (callBack != null) {
|
callBack.onSuccess();
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 更新模板自动化 (全量)
|
* @param templateExtendsId
|
* @param logicBeansJson
|
* @param callBack
|
* @return
|
*/
|
public Disposable UpdataTemplateLogic(String templateExtendsId, JsonElement logicBeansJson,// List<TemplateLogicBean> logicBeans,
|
IDefaultCallBack callBack){
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_TEMPLATE_UPDATE_LOGIC;
|
JsonObject json = new JsonObject();
|
json.addProperty("templateExtendsId", templateExtendsId);
|
json.add("logicInfos", logicBeansJson);
|
// json.add("logicInfos", HDLGsonUtils.toJsonArray(logicBeans));
|
return HxHttp.builder()
|
.url(requestUrl)
|
.raw(json.toString())
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<String>() {
|
@Override
|
public void onResponse(String code) {
|
if (callBack != null) {
|
callBack.onSuccess();
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 更新模板安防列表 全量
|
* @param templateExtendsId
|
* @param securityBeansJson
|
* @param callBack
|
* @return
|
*/
|
public Disposable UpdataTemplateSecurity(String templateExtendsId, JsonElement securityBeansJson,// List<TemplateLogicBean> logicBeans,
|
IDefaultCallBack callBack){
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_TEMPLATE_UPDATE_SECURITY;
|
JsonObject json = new JsonObject();
|
json.addProperty("templateExtendsId", templateExtendsId);
|
json.add("securityInfos", securityBeansJson);
|
// json.add("logicInfos", HDLGsonUtils.toJsonArray(logicBeans));
|
return HxHttp.builder()
|
.url(requestUrl)
|
.raw(json.toString())
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<String>() {
|
@Override
|
public void onResponse(String code) {
|
if (callBack != null) {
|
callBack.onSuccess();
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
|
/**
|
* 获取模板区域信息列表
|
* @param templateExtendsId
|
* @param callBack
|
* @return
|
*/
|
public Disposable GetTemplateAreaSpatialInfo(String templateExtendsId, IGetTemplateSpatialInfoCallBack callBack){
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_GET_TEMPLATE_SPATIAL_INFO;
|
JsonObject json = new JsonObject();
|
json.addProperty("templateExtendsId", templateExtendsId);
|
return HxHttp.builder()
|
.url(requestUrl)
|
.raw(json.toString())
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<List<CloudTemplateSpatialInfo>>() {
|
@Override
|
public void onResponse(List<CloudTemplateSpatialInfo> data) {
|
if (callBack != null) {
|
callBack.onSuccess(data);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 获取网关列表
|
* @param templateExtendsId
|
* @param callBack
|
* @return
|
*/
|
public Disposable GetTemplateGatewayList(String templateExtendsId, IGetTemplateGatewayListCallBack callBack){
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_GET_TEMPLATE_GATEWAY_LIST;
|
JsonObject json = new JsonObject();
|
json.addProperty("templateExtendsId", templateExtendsId);
|
return HxHttp.builder()
|
.url(requestUrl)
|
.raw(json.toString())
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<List<TemplateGatewayBean>>() {
|
@Override
|
public void onResponse(List<TemplateGatewayBean> data) {
|
if (callBack != null) {
|
callBack.onSuccess(data);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 获取设备信息
|
* @param templateExtendsId
|
* @param callBack
|
* @return
|
*/
|
public Disposable GetTemplateDeviceList(String templateExtendsId, IGetTemplateDeviceListCallBack callBack){
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_TEMPALTE_GET_DEVICES;
|
JsonObject json = new JsonObject();
|
json.addProperty("templateExtendsId", templateExtendsId);
|
return HxHttp.builder()
|
.url(requestUrl)
|
.raw(json.toString())
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<List<CloudTemplateDevice>>() {
|
@Override
|
public void onResponse(List<CloudTemplateDevice> data) {
|
if (callBack != null) {
|
callBack.onSuccess(data);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 获取功能列表
|
* @param templateExtendsId
|
* @param callBack
|
* @return
|
*/
|
public Disposable GetTemplateFunctions(String templateExtendsId , ITemplateFunctionsCallBack callBack) {
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_GET_TEMPLATE_FUNCTION_LIST;
|
JsonObject json = new JsonObject();
|
json.addProperty("templateExtendsId", templateExtendsId);
|
return HxHttp.builder()
|
.url(requestUrl)
|
.raw(json.toString())
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<List<TemplateFunctionBean>>() {
|
@Override
|
public void onResponse(List<TemplateFunctionBean> data) {
|
if (callBack != null) {
|
callBack.onSuccess(data);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 获取场景列表
|
* @param templateExtendsId
|
* @param callBack
|
* @return
|
*/
|
public Disposable GetTemplateScenes(String templateExtendsId , ITemplateScenesCallBack callBack) {
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_GET_TEMPLATE_SCENE_LIST;
|
JsonObject json = new JsonObject();
|
json.addProperty("templateExtendsId", templateExtendsId);
|
return HxHttp.builder()
|
.url(requestUrl)
|
.raw(json.toString())
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<List<TemplateSceneBean>>() {
|
@Override
|
public void onResponse(List<TemplateSceneBean> data) {
|
if (callBack != null) {
|
callBack.onSuccess(data);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 获取安防列表
|
* @param templateExtendsId
|
* @param callBack
|
* @return
|
*/
|
public Disposable GetTemplateSecurity(String templateExtendsId , ITemplateSecurityCallBack callBack) {
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_GET_TEMPLATE_SECURITY_LIST;
|
JsonObject json = new JsonObject();
|
json.addProperty("templateExtendsId", templateExtendsId);
|
return HxHttp.builder()
|
.url(requestUrl)
|
.raw(json.toString())
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<List<TemplateSecurityBean>>() {
|
@Override
|
public void onResponse(List<TemplateSecurityBean> data) {
|
if (callBack != null) {
|
callBack.onSuccess(data);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
|
/**
|
* 获取逻辑列表
|
* @param templateExtendsId
|
* @param callBack
|
* @return
|
*/
|
public Disposable GetTemplateLogic(String templateExtendsId , ITemplateLogicCallBack callBack) {
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_GET_TEMPLATE_LOGIC_LIST;
|
JsonObject json = new JsonObject();
|
json.addProperty("templateExtendsId", templateExtendsId);
|
return HxHttp.builder()
|
.url(requestUrl)
|
.raw(json.toString())
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<List<TemplateLogicBean>>() {
|
@Override
|
public void onResponse(List<TemplateLogicBean> data) {
|
if (callBack != null) {
|
callBack.onSuccess(data);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
|
}
|
