package com.hdl.photovoltaic.other;
|
|
import android.text.TextUtils;
|
|
import com.google.gson.Gson;
|
import com.google.gson.JsonArray;
|
import com.google.gson.JsonObject;
|
import com.google.gson.reflect.TypeToken;
|
import com.hdl.hdlhttp.HxHttp;
|
import com.hdl.photovoltaic.bean.HttpResponsePack;
|
import com.hdl.photovoltaic.config.AppConfigManage;
|
import com.hdl.photovoltaic.config.UserConfigManage;
|
import com.hdl.photovoltaic.internet.HttpClient;
|
import com.hdl.photovoltaic.internet.TcpClient;
|
import com.hdl.photovoltaic.internet.api.HttpApi;
|
import com.hdl.photovoltaic.internet.api.TopicApi;
|
import com.hdl.photovoltaic.listener.BaseSuccessFailureCallBeak;
|
import com.hdl.photovoltaic.listener.CloudCallBeak;
|
import com.hdl.photovoltaic.ui.bean.CloudInverterChildDeviceBean;
|
import com.hdl.photovoltaic.ui.bean.CloudInverterDeviceBean;
|
import com.hdl.photovoltaic.ui.bean.InverterDeviceBean;
|
import com.hdl.photovoltaic.ui.bean.OidBean;
|
import com.hdl.photovoltaic.uni.HDLUniMP;
|
import com.hdl.photovoltaic.uni.HDLUniMPSDKManager;
|
import com.hdl.sdk.link.common.exception.HDLLinkCode;
|
import com.hdl.sdk.link.common.exception.HDLLinkException;
|
import com.hdl.sdk.link.core.bean.gateway.GatewayBean;
|
import com.hdl.sdk.link.core.callback.GatewayCallBack;
|
import com.hdl.sdk.link.core.callback.HDLLinkCallBack;
|
import com.hdl.sdk.link.gateway.HDLLinkLocalGateway;
|
|
import java.lang.reflect.Type;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import io.reactivex.rxjava3.disposables.Disposable;
|
|
/**
|
* 设备逻辑的界面
|
*/
|
public class HdlDeviceLogic {
|
private static volatile HdlDeviceLogic sHdlDeviceLogic;
|
|
/**
|
* 获取当前对象
|
*
|
* @return HdlDeviceLogic
|
*/
|
public static synchronized HdlDeviceLogic getInstance() {
|
if (sHdlDeviceLogic == null) {
|
synchronized (HdlDeviceLogic.class) {
|
if (sHdlDeviceLogic == null) {
|
sHdlDeviceLogic = new HdlDeviceLogic();
|
}
|
}
|
|
}
|
return sHdlDeviceLogic;
|
}
|
|
/**
|
* 添加逆变器到云端上
|
*
|
* @param mac -
|
* @param spk -
|
* @param sid -
|
* @param oid -
|
* @param name -
|
* @param cloudCallBeak
|
*/
|
public void addInverterDeviceToCloud(String mac, String spk, String sid, String oid, String name, CloudCallBeak<Boolean> cloudCallBeak) {
|
|
String requestUrl = HttpApi.POST_Device_Add;
|
JsonObject json = new JsonObject();
|
json.addProperty("homeId", UserConfigManage.getInstance().getHomeId());
|
json.addProperty("mac", mac);
|
json.addProperty("spk", spk);
|
json.addProperty("sid", sid);
|
json.addProperty("oid", oid);
|
json.addProperty("name", name);
|
// json.addProperty("zoneType", "password");//区域
|
|
HttpClient.getInstance().requestHttp(requestUrl, json.toString(), true, true, new BaseSuccessFailureCallBeak() {
|
@Override
|
public void onSuccess(HttpResponsePack httpResponsePack) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(true);
|
}
|
}
|
|
@Override
|
public void onFailure(Exception exception) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(exception);
|
}
|
}
|
});
|
}
|
|
/**
|
* 获取云端逆变器列表
|
*
|
* @param homeId 住宅id
|
* @param cloudCallBeak 回调
|
*/
|
public void getCloudInverterDeviceList(String homeId, CloudCallBeak<List<CloudInverterDeviceBean>> cloudCallBeak) {
|
String requestUrl = HttpApi.POST_Device_List;
|
JsonObject json = new JsonObject();
|
json.addProperty("homeId", homeId);
|
// json.addProperty("zoneType", "password");//区域
|
|
HttpClient.getInstance().requestHttp(requestUrl, json.toString(), true, true, new BaseSuccessFailureCallBeak() {
|
@Override
|
public void onSuccess(HttpResponsePack httpResponsePack) {
|
try {
|
if (httpResponsePack != null && httpResponsePack.getData() != null) {
|
Gson gson = new Gson();
|
String json = gson.toJson(httpResponsePack.getData());
|
Type type = new TypeToken<List<CloudInverterDeviceBean>>() {
|
}.getType();
|
List<CloudInverterDeviceBean> list = new Gson().fromJson(json, type);
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(list);
|
}
|
}
|
} catch (Exception e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(e);
|
}
|
}
|
}
|
|
@Override
|
public void onFailure(Exception e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(e);
|
}
|
}
|
});
|
}
|
|
|
/**
|
* 删除逆变器
|
*
|
* @param deviceId 设备id
|
* @param cloudCallBeak 回调
|
*/
|
public void delInverterDevice(String deviceId, CloudCallBeak<Boolean> cloudCallBeak) {
|
String requestUrl = HttpApi.POST_Device_Remove;
|
JsonObject json = new JsonObject();
|
json.addProperty("homeId", UserConfigManage.getInstance().getHomeId());
|
json.addProperty("deviceId", deviceId);
|
// json.addProperty("zoneType", "password");//区域
|
|
HttpClient.getInstance().requestHttp(requestUrl, json.toString(), true, true, new BaseSuccessFailureCallBeak() {
|
@Override
|
public void onSuccess(HttpResponsePack httpResponsePack) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(true);
|
}
|
}
|
|
@Override
|
public void onFailure(Exception exception) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(exception);
|
}
|
}
|
});
|
}
|
|
/**
|
* 获取逆变器下挂设备列表
|
*
|
* @param parentOid 上级设备的Oid
|
* @param cloudCallBeak 回调
|
*/
|
public void getInverterDeviceChildDeviceList(String parentOid, CloudCallBeak<List<CloudInverterChildDeviceBean>> cloudCallBeak) {
|
String requestUrl = HttpApi.POST_Device_ChildDevices_List;
|
JsonObject json = new JsonObject();
|
json.addProperty("homeId", UserConfigManage.getInstance().getHomeId());
|
json.addProperty("parentOid", parentOid);
|
// json.addProperty("zoneType", "password");//区域
|
|
HttpClient.getInstance().requestHttp(requestUrl, json.toString(), true, true, new BaseSuccessFailureCallBeak() {
|
@Override
|
public void onSuccess(HttpResponsePack httpResponsePack) {
|
if (httpResponsePack != null && httpResponsePack.getData() != null) {
|
Gson gson = new Gson();
|
String json = gson.toJson(httpResponsePack.getData());
|
Type typeOfT = new TypeToken<List<CloudInverterChildDeviceBean>>() {
|
}.getType();
|
List<CloudInverterChildDeviceBean> list = gson.fromJson(json, typeOfT);
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(list);
|
}
|
}
|
}
|
|
@Override
|
public void onFailure(Exception exception) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(exception);
|
}
|
}
|
});
|
}
|
|
/**
|
* 全量更新OID
|
*
|
* @param oidList oid列表
|
* @param cloudCallBeak 回调update
|
*/
|
public void fullUpdateOid(List<OidBean> oidList, CloudCallBeak<Boolean> cloudCallBeak) {
|
String requestUrl = HttpApi.POST_Device_ChildDevices_List;
|
JsonObject json = new JsonObject();
|
json.addProperty("operationSource", "PROGRAM_ENERGY");//
|
json.addProperty("homeId", UserConfigManage.getInstance().getHomeId());
|
JsonArray jsonArray = new JsonArray();
|
for (int i = 0; i < oidList.size(); i++) {
|
OidBean oidBean = oidList.get(i);
|
JsonObject jsonObject = new JsonObject();
|
jsonObject.addProperty("protocolType", oidBean.getProtocolType());
|
jsonObject.addProperty("deviceType", oidBean.getDeviceType());
|
jsonObject.addProperty("mac", oidBean.getMac());
|
jsonObject.addProperty("oid", oidBean.getOid());
|
jsonObject.addProperty("device_name", oidBean.getDevice_name());
|
jsonObject.addProperty("device_model", oidBean.getDevice_model());
|
jsonObject.addProperty("addresses", oidBean.getAddresses());
|
jsonObject.addProperty("parentOid", oidBean.getParentOid());
|
jsonArray.add(jsonObject);
|
|
}
|
json.add("devices", jsonArray);
|
// json.addProperty("zoneType", "password");//区域
|
|
HttpClient.getInstance().requestHttp(requestUrl, json.toString(), true, true, new BaseSuccessFailureCallBeak() {
|
@Override
|
public void onSuccess(HttpResponsePack httpResponsePack) {
|
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(true);
|
}
|
|
}
|
|
@Override
|
public void onFailure(Exception exception) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(exception);
|
}
|
}
|
});
|
|
}
|
|
|
/**
|
* 设置网关远程参数
|
*
|
* @param mac 设备mac
|
* @param cloudCallBeak 回调update
|
*/
|
public void steGatewayParam(String mac, CloudCallBeak<Boolean> cloudCallBeak) {
|
String requestUrl = TopicApi.SET_GATEWAY_REMOTE_EDIT;
|
JsonObject json = new JsonObject();
|
json.addProperty("homeId", UserConfigManage.getInstance().getHomeId());
|
json.addProperty("server_addr", AppConfigManage.getUserRegionUrl());
|
json.addProperty("local_secret", UserConfigManage.getInstance().getLocalSecret());
|
//解密负载数据(因为写密钥给网关一定明文，因为那时网关还没有密钥)
|
TcpClient.getInstance().sendDataToLinkGateway(mac, false, requestUrl, json, "", new HDLLinkCallBack() {
|
@Override
|
public void onSuccess(String msg) {
|
GatewayBean gatewayBean = HDLLinkLocalGateway.getInstance().getLocalGateway(mac);
|
if (gatewayBean != null) {
|
if (!TextUtils.isEmpty(UserConfigManage.getInstance().getLocalSecret())) {
|
gatewayBean.setLocalEncrypt(true);
|
}
|
}
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(true);
|
}
|
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 编辑网关参数
|
*
|
* @param mac 设备mac
|
* @param cloudCallBeak 回调update
|
*/
|
public void editGatewayParam(String mac, CloudCallBeak<Boolean> cloudCallBeak) {
|
String requestUrl = TopicApi.SET_GATEWAY_EDIT;
|
JsonObject json = new JsonObject();
|
json.addProperty("master", "true");
|
TcpClient.getInstance().sendDataToLinkGateway(mac, requestUrl, json, "", new HDLLinkCallBack() {
|
@Override
|
public void onSuccess(String msg) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(true);
|
}
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(e);
|
}
|
}
|
});
|
|
}
|
|
|
/**
|
* 获取网关详情信息
|
*
|
* @param mac 网关mac
|
* @param cloudCallBeak 回调
|
*/
|
public void getGatewayInfo(String mac, CloudCallBeak<GatewayBean> cloudCallBeak) {
|
String requestUrl = TopicApi.GET_GATEWAY_INFO;
|
TcpClient.getInstance().sendDataToLinkGateway(mac, requestUrl, null, "", new HDLLinkCallBack() {
|
@Override
|
public void onSuccess(String msg) {
|
try {
|
if (!TextUtils.isEmpty(msg)) {
|
Gson gson = new Gson();
|
String json = gson.toJson(msg);
|
GatewayBean gatewayBean = gson.fromJson(json, GatewayBean.class);
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(gatewayBean);
|
}
|
} else {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(new GatewayBean());
|
}
|
}
|
|
} catch (Exception e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(e);
|
}
|
}
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(e);
|
}
|
}
|
});
|
|
}
|
|
/**
|
* 获取网关oid列表
|
*
|
* @param mac 网关mac
|
* @param cloudCallBeak 回调
|
*/
|
public void getGatewayOidList(String mac, CloudCallBeak<List<OidBean>> cloudCallBeak) {
|
String requestUrl = TopicApi.GET_GATEWAY_OID_LIST;
|
TcpClient.getInstance().sendDataToLinkGateway(mac, requestUrl, null, "", new HDLLinkCallBack() {
|
@Override
|
public void onSuccess(String msg) {
|
try {
|
if (!TextUtils.isEmpty(msg)) {
|
Gson gson = new Gson();
|
String json = gson.toJson(msg);
|
Type typeOfT = new TypeToken<List<OidBean>>() {
|
}.getType();
|
List<OidBean> list = gson.fromJson(json, typeOfT);
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(list);
|
}
|
} else {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(new ArrayList<>());
|
}
|
}
|
|
} catch (Exception e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(e);
|
}
|
}
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(e);
|
}
|
}
|
});
|
|
}
|
|
/**
|
* 获取本地设备列表
|
* 注意:有外网以云端设备为准,本地存在，云端没有则删除；内网以本地为主,搜索多少个设备就显示多少个；
|
*
|
* @param cloudCallBeak -
|
*/
|
public void getLocalGatewayList(CloudCallBeak<Boolean> cloudCallBeak) {
|
HdlDeviceLogic.getInstance().searchGateway(new GatewayCallBack() {
|
@Override
|
public void onSuccess(List<GatewayBean> gatewayBeanList) {
|
HdlDeviceLogic.getInstance().getCloudInverterDeviceList(UserConfigManage.getInstance().getHomeId(), new CloudCallBeak<List<CloudInverterDeviceBean>>() {
|
@Override
|
public void onSuccess(List<CloudInverterDeviceBean> list) {
|
if (list == null) {
|
//云端没有绑定逆变器,清空本地列表;
|
HDLLinkLocalGateway.getInstance().getGatewayList().clear();
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(true);
|
}
|
return;
|
}
|
//收集删除逆变器sid
|
List<String> removeSidList = new ArrayList<>();
|
for (int i = 0; i < list.size(); i++) {
|
CloudInverterDeviceBean cloudInverterDeviceBean = list.get(i);
|
for (int j = 0; j < HDLLinkLocalGateway.getInstance().getGatewayList().size(); j++) {
|
GatewayBean gatewayBean = HDLLinkLocalGateway.getInstance().getGatewayList().get(j);
|
if (!cloudInverterDeviceBean.getSid().equals(gatewayBean.getSid())) {
|
//本地有，云端没有,删除本地；
|
removeSidList.add(gatewayBean.getSid());
|
}
|
|
}
|
}
|
for (int i = 0; i < removeSidList.size(); i++) {
|
//获取本地的毫米波
|
removeInverter(removeSidList.get(i));
|
}
|
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(true);
|
}
|
}
|
|
@Override
|
public void onFailure(Exception exception) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(exception);
|
}
|
}
|
});
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
HdlDeviceLogic.getInstance().getCloudInverterDeviceList(UserConfigManage.getInstance().getHomeId(), new CloudCallBeak<List<CloudInverterDeviceBean>>() {
|
@Override
|
public void onSuccess(List<CloudInverterDeviceBean> list) {
|
if (list == null) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(true);
|
}
|
return;
|
}
|
if (list.size() <= 0) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(true);
|
}
|
return;
|
}
|
HDLLinkLocalGateway.getInstance().getGatewayList().clear();
|
for (int i = 0; i < list.size(); i++) {
|
CloudInverterDeviceBean cloudInverterDeviceBean = list.get(i);
|
GatewayBean gatewayBean = new GatewayBean();
|
gatewayBean.setOid(cloudInverterDeviceBean.getOid());
|
gatewayBean.setSid(cloudInverterDeviceBean.getSid());
|
gatewayBean.setGatewayId(cloudInverterDeviceBean.getGatewayId());
|
gatewayBean.setOnline(cloudInverterDeviceBean.isOnline());
|
gatewayBean.setDevice_name(cloudInverterDeviceBean.getGatewayName());
|
gatewayBean.setHomeId(UserConfigManage.getInstance().getHomeId());
|
gatewayBean.setLocalEncrypt(true);
|
gatewayBean.setMaster("true");
|
HDLLinkLocalGateway.getInstance().getGatewayList().add(gatewayBean);
|
}
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(true);
|
}
|
|
}
|
|
@Override
|
public void onFailure(Exception exception) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(exception);
|
}
|
}
|
});
|
}
|
});
|
}
|
|
/**
|
* 删除本地逆变器
|
*
|
* @param sid 设备sid
|
*/
|
private void removeInverter(String sid) {
|
//获取本地的毫米波
|
GatewayBean gatewayBean = HDLLinkLocalGateway.getInstance().getLocalGateway(sid);
|
if (gatewayBean != null) {
|
HDLLinkLocalGateway.getInstance().getGatewayList().remove(gatewayBean);
|
}
|
}
|
|
/**
|
* 搜索网关列表
|
*
|
* @param gatewayCallBack -
|
*/
|
public void searchGateway(GatewayCallBack gatewayCallBack) {
|
List<String> spks = this.getGatewaySpk();
|
//网关搜索
|
HDLLinkLocalGateway.getInstance().refreshGatewayByHomeIdAndSpk(UserConfigManage.getInstance().getHomeId(), spks, true, gatewayCallBack);
|
}
|
|
/**
|
* 获取网关spk列表
|
*
|
* @return -
|
*/
|
private List<String> getGatewaySpk() {
|
List<String> spks = new ArrayList<>();
|
spks.add("energy.hdl_inverter");
|
return spks;
|
}
|
}
|
