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.linkpm.sdk.core.exception.HDLException;
|
import com.hdl.linkpm.sdk.home.type.GatewayType;
|
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.CloudCallBeak;
|
import com.hdl.photovoltaic.listener.LinkCallBack;
|
import com.hdl.photovoltaic.ui.bean.CloudInverterChildDeviceBean;
|
import com.hdl.photovoltaic.ui.bean.CloudInverterDeviceBean;
|
import com.hdl.photovoltaic.ui.bean.DeviceRemoteInfo;
|
import com.hdl.photovoltaic.ui.bean.DeviceTimeBean;
|
import com.hdl.photovoltaic.ui.bean.OidBean;
|
import com.hdl.sdk.link.HDLLinkLocalSdk;
|
import com.hdl.sdk.link.common.exception.HDLLinkException;
|
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.config.HDLLinkConfig;
|
import com.hdl.sdk.link.gateway.HDLLinkLocalGateway;
|
import com.hdl.sdk.link.gateway.type.GatewayMasterType;
|
|
|
import java.lang.reflect.Type;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.concurrent.atomic.AtomicInteger;
|
|
import io.dcloud.common.adapter.util.DeviceInfo;
|
|
|
/**
|
* 设备逻辑
|
*/
|
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;
|
}
|
|
/**
|
* 获取当前住宅的逆变器列表(包括从的逆变器)
|
*/
|
public List<GatewayBean> getCurrentHomeGatewayList(String homeId) {
|
List<GatewayBean> newList = new ArrayList<>();
|
List<GatewayBean> list = HDLLinkLocalGateway.getInstance().getGatewayList();
|
if (list.size() > 0) {
|
for (int i = 0; i < list.size(); i++) {
|
GatewayBean gatewayBean = list.get(i);
|
if (TextUtils.isEmpty(gatewayBean.getDevice_mac())) {
|
continue;
|
}
|
//用homeId筛选当前住宅的逆变器列表
|
if (gatewayBean.getHomeId().equals(homeId)) {
|
newList.add(gatewayBean);
|
}
|
}
|
}
|
return newList;
|
}
|
|
/**
|
* 获取当前住宅的【主】逆变器
|
*/
|
public GatewayBean getCurrentHomeMainGateway(String homeId) {
|
return queryCurrentHomeMainGateway(this.getCurrentHomeGatewayList(homeId), homeId);
|
}
|
|
/**
|
* 查询当前住宅的【主】逆变器
|
*/
|
public GatewayBean queryCurrentHomeMainGateway(List<GatewayBean> list, String homeId) {
|
if (list == null || list.size() == 0) {
|
return null;
|
}
|
GatewayBean findGatewayBean = null;
|
for (int i = 0; i < list.size(); i++) {
|
GatewayBean gatewayBean = list.get(i);
|
if (gatewayBean.getMaster().equals(GatewayMasterType.MasterTrue) && gatewayBean.getHomeId().equals(homeId)) {
|
//找到返回
|
findGatewayBean = gatewayBean;
|
break;
|
}
|
}
|
return findGatewayBean;
|
}
|
|
|
/**
|
* 逆变器上传数据到云端(包括:sid，oid)
|
*
|
* @param homeId 住宅id
|
* @param mac 设备mac
|
*/
|
public void uploadDataToCloud(String homeId, String mac, CloudCallBeak<Boolean> callBeak) {
|
getInverterOidList(mac, new LinkCallBack<List<OidBean>>() {
|
@Override
|
public void onSuccess(List<OidBean> oidBeanList) {
|
if (oidBeanList == null) {
|
return;
|
}
|
fullUpdateOid(homeId, oidBeanList, new CloudCallBeak<Boolean>() {
|
@Override
|
public void onSuccess(Boolean obj) {
|
HdlLogLogic.print("上传oid列表到云端成功--->住宅id:" + homeId + "--->mac:" + mac, true);
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HdlLogLogic.print("上传oid列表到云端失败--->住宅id:" + homeId + "--->mac:" + mac + "-->" + e.getMsg() + "(" + e.getCode() + ")", true);
|
}
|
});
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
HdlLogLogic.print("获取逆变器oid列表失败--->住宅id:" + homeId + "--->mac:" + mac + "-->" + e.getMsg() + "(" + e.getCode() + ")", true);
|
}
|
});
|
|
}
|
|
/**
|
* 添加逆变器到云端上
|
*
|
* @param mac -
|
* @param spk -
|
* @param sid -
|
* @param oid -
|
* @param name -
|
* @param cloudCallBeak -
|
*/
|
public void addInverterDeviceToCloud(String homeId, 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", homeId);
|
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(), new CloudCallBeak<String>() {
|
@Override
|
public void onSuccess(String str) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(true);
|
//临时的逻辑，上传oid列表到云端
|
uploadDataToCloud(UserConfigManage.getInstance().getHomeId(), mac, null);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 添加多个逆变器到云端上
|
*
|
* @param mac -
|
* @param cloudCallBeak -
|
*/
|
public void addAllInverterDeviceToCloud(String homeId, String mac, List<GatewayBean> list, CloudCallBeak<Boolean> cloudCallBeak) {
|
|
String requestUrl = HttpApi.POST_Device_Add_All;
|
JsonObject json = new JsonObject();
|
json.addProperty("homeId", homeId);
|
JsonArray ary = new JsonArray();
|
for (int i = 0; i < list.size(); i++) {
|
GatewayBean gatewayBean=list.get(i);
|
JsonObject inverterInfo = new JsonObject();
|
inverterInfo.addProperty("mac",gatewayBean.getDevice_mac());
|
inverterInfo.addProperty("spk",gatewayBean.getGatewayType());
|
inverterInfo.addProperty("sid",gatewayBean.getSid());
|
inverterInfo.addProperty("oid",gatewayBean.getOid());
|
inverterInfo.addProperty("name",gatewayBean.getDevice_name());
|
ary.add(inverterInfo);
|
}
|
json.add("devices", ary);
|
// json.addProperty("zoneType", "password");//区域
|
|
HttpClient.getInstance().requestHttp(requestUrl, json.toString(), new CloudCallBeak<String>() {
|
@Override
|
public void onSuccess(String str) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(true);
|
//临时的逻辑，上传oid列表到云端
|
uploadDataToCloud(UserConfigManage.getInstance().getHomeId(), mac, null);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 获取云端逆变器列表
|
*
|
* @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(), new CloudCallBeak<String>() {
|
@Override
|
public void onSuccess(String jsonStr) {
|
if (TextUtils.isEmpty(jsonStr)) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(null);
|
}
|
}
|
Type type = new TypeToken<List<CloudInverterDeviceBean>>() {
|
}.getType();
|
List<CloudInverterDeviceBean> list = new Gson().fromJson(jsonStr, type);
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(list);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(e);
|
}
|
}
|
});
|
}
|
|
|
/**
|
* 删除云端上逆变器
|
*
|
* @param deviceId 设备id
|
* @param cloudCallBeak 回调
|
*/
|
public void delInverterDevice(String homeId, String deviceId, CloudCallBeak<Boolean> cloudCallBeak) {
|
String requestUrl = HttpApi.POST_Device_Remove;
|
JsonObject json = new JsonObject();
|
json.addProperty("homeId", homeId);
|
json.addProperty("deviceId", deviceId);
|
// json.addProperty("zoneType", "password");//区域
|
|
HttpClient.getInstance().requestHttp(requestUrl, json.toString(), new CloudCallBeak<String>() {
|
@Override
|
public void onSuccess(String str) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(true);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 获取逆变器下挂设备列表
|
*
|
* @param parentOid 上级设备的Oid
|
* @param cloudCallBeak 回调
|
*/
|
public void getInverterDeviceChildDeviceList(String homeId, String parentOid, CloudCallBeak<List<CloudInverterChildDeviceBean>> cloudCallBeak) {
|
String requestUrl = HttpApi.POST_Device_ChildDevices_List;
|
JsonObject json = new JsonObject();
|
json.addProperty("homeId", homeId);
|
json.addProperty("parentOid", parentOid);
|
// json.addProperty("zoneType", "password");//区域
|
|
HttpClient.getInstance().requestHttp(requestUrl, json.toString(), new CloudCallBeak<String>() {
|
@Override
|
public void onSuccess(String jsonStr) {
|
if (TextUtils.isEmpty(jsonStr)) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(null);
|
}
|
return;
|
}
|
Gson gson = new Gson();
|
Type typeOfT = new TypeToken<List<CloudInverterChildDeviceBean>>() {
|
}.getType();
|
List<CloudInverterChildDeviceBean> list = gson.fromJson(jsonStr, typeOfT);
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(list);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 全量更新OID
|
*
|
* @param homeId 住宅id
|
* @param oidList oid列表
|
* @param cloudCallBeak 回调update
|
*/
|
public void fullUpdateOid(String homeId, List<OidBean> oidList, CloudCallBeak<Boolean> cloudCallBeak) {
|
if (oidList == null || oidList.size() == 0) {
|
HdlLogLogic.print("oid列表为空，无法全量更新oid到云端--->", true);
|
return;
|
}
|
String requestUrl = HttpApi.POST_Device_Oid;
|
JsonObject json = new JsonObject();
|
json.addProperty("operationSource", "PROGRAM_ENERGY");//
|
json.addProperty("homeId", homeId);
|
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.getDevice_mac());
|
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(), new CloudCallBeak<String>() {
|
@Override
|
public void onSuccess(String str) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(true);
|
}
|
|
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(e);
|
}
|
}
|
});
|
|
}
|
|
|
/**
|
* (oid)增量添加
|
*
|
* @param homeId 住宅id
|
* @param oidList oid列表
|
* @param cloudCallBeak 回调update
|
*/
|
public void updateOidAdd(String homeId, List<OidBean> oidList, CloudCallBeak<Boolean> cloudCallBeak) {
|
if (oidList == null || oidList.size() == 0) {
|
HdlLogLogic.print("oid列表为空，无法增量添加oid到云端--->", true);
|
return;
|
}
|
String requestUrl = HttpApi.POST_Device_IncrAdd;
|
JsonObject json = new JsonObject();
|
json.addProperty("homeId", homeId);
|
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.getDevice_mac());
|
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(), new CloudCallBeak<String>() {
|
@Override
|
public void onSuccess(String str) {
|
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(true);
|
}
|
HdlLogLogic.print("增量添加oid到云端成功--->");
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(e);
|
}
|
HdlLogLogic.print("增量添加oid到云端失败--->" + e.getMsg() + "(" + e.getCode() + ")", true);
|
}
|
});
|
|
}
|
|
|
/**
|
* 设置网关远程参数
|
*
|
* @param mac 设备mac
|
* @param linkCallBack 回调update
|
*/
|
public void setGatewayRemoteParam(String homeId, String mac, LinkCallBack<Boolean> linkCallBack) {
|
String requestUrl = TopicApi.SET_GATEWAY_REMOTE_EDIT;
|
JsonObject json = new JsonObject();
|
json.addProperty("homeId", homeId);
|
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 (linkCallBack != null) {
|
linkCallBack.onSuccess(true);
|
}
|
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
if (linkCallBack != null) {
|
linkCallBack.onError(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 网关时间读取
|
*
|
* @param mac 设备mac
|
* @param linkCallBack 回调updatetime
|
*/
|
public void getGatewayTime(String mac, LinkCallBack<DeviceTimeBean> linkCallBack) {
|
String requestUrl = TopicApi.GET_GATEWAY_TIME;
|
TcpClient.getInstance().sendDataToLinkGateway(mac, requestUrl, null, "", new HDLLinkCallBack() {
|
@Override
|
public void onSuccess(String json) {
|
|
if (TextUtils.isEmpty(json)) {
|
if (linkCallBack != null) {
|
linkCallBack.onSuccess(new DeviceTimeBean());
|
}
|
return;
|
}
|
|
Gson gson = new Gson();
|
Type typeOfT = new TypeToken<BaseLocalResponse<DeviceTimeBean>>() {
|
}.getType();
|
BaseLocalResponse<DeviceTimeBean> baseLocalResponse = gson.fromJson(json, typeOfT);
|
if (linkCallBack != null) {
|
linkCallBack.onSuccess(baseLocalResponse.getObjects());
|
}
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
if (linkCallBack != null) {
|
linkCallBack.onError(e);
|
}
|
}
|
});
|
|
}
|
|
/**
|
* 网关时间修改
|
*
|
* @param mac 设备mac
|
* @param date 日期
|
* @param time 时间
|
* @param timezone 时区
|
* @param linkCallBack 回调update
|
*/
|
public void editGatewayTime(String mac, String date, String time, String timezone, LinkCallBack<Boolean> linkCallBack) {
|
String requestUrl = TopicApi.SET_GATEWAY_TIME_EDIT;
|
JsonObject json = new JsonObject();
|
if (!TextUtils.isEmpty(date)) {
|
json.addProperty("date", date);// "2020-08-15"
|
}
|
if (!TextUtils.isEmpty(time)) {
|
json.addProperty("time", time);//"17:25:20"
|
}
|
if (!TextUtils.isEmpty(timezone)) {
|
json.addProperty("timezone", timezone);//时区(语雀https://hdl-gz.yuque.com/wnkbmh/cdrglh/yckkyp#qWOPS)
|
}
|
|
TcpClient.getInstance().sendDataToLinkGateway(mac, requestUrl, json, "", new HDLLinkCallBack() {
|
@Override
|
public void onSuccess(String msg) {
|
if (linkCallBack != null) {
|
linkCallBack.onSuccess(true);
|
}
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
if (linkCallBack != null) {
|
linkCallBack.onError(e);
|
}
|
}
|
});
|
|
}
|
|
/**
|
* 编辑网关参数
|
*
|
* @param mac 设备mac
|
* @param linkCallBack 回调update
|
*/
|
public void editGatewayParam(String mac, LinkCallBack<Boolean> linkCallBack) {
|
String requestUrl = TopicApi.SET_GATEWAY_EDIT;
|
JsonObject json = new JsonObject();
|
json.addProperty("master", GatewayMasterType.MasterTrue);
|
TcpClient.getInstance().sendDataToLinkGateway(mac, requestUrl, json, "", new HDLLinkCallBack() {
|
@Override
|
public void onSuccess(String msg) {
|
if (linkCallBack != null) {
|
linkCallBack.onSuccess(true);
|
}
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
if (linkCallBack != null) {
|
linkCallBack.onError(e);
|
}
|
}
|
});
|
|
}
|
|
/**
|
* 获取网关详情信息
|
*
|
* @param mac 网关mac
|
* @param linkCallBack 回调
|
*/
|
public void getGatewayInfo(String mac, LinkCallBack<GatewayBean> linkCallBack) {
|
String requestUrl = TopicApi.GET_GATEWAY_INFO;
|
TcpClient.getInstance().sendDataToLinkGateway(mac, requestUrl, null, "", new HDLLinkCallBack() {
|
@Override
|
public void onSuccess(String json) {
|
if (TextUtils.isEmpty(json)) {
|
if (linkCallBack != null) {
|
linkCallBack.onSuccess(null);
|
}
|
return;
|
}
|
Gson gson = new Gson();
|
GatewayBean gatewayBean = gson.fromJson(json, GatewayBean.class);
|
if (linkCallBack != null) {
|
linkCallBack.onSuccess(gatewayBean);
|
}
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
if (linkCallBack != null) {
|
linkCallBack.onError(e);
|
}
|
}
|
});
|
|
}
|
|
/**
|
* 获取逆变器oid列表
|
*
|
* @param mac 网关mac
|
* @param linkCallBack 回调
|
*/
|
public void getInverterOidList(String mac, LinkCallBack<List<OidBean>> linkCallBack) {
|
String requestUrl = TopicApi.GET_GATEWAY_OID_LIST;
|
TcpClient.getInstance().sendDataToLinkGateway(mac, requestUrl, null, "", new HDLLinkCallBack() {
|
@Override
|
public void onSuccess(String json) {
|
if (TextUtils.isEmpty(json)) {
|
if (linkCallBack != null) {
|
linkCallBack.onSuccess(null);
|
}
|
return;
|
}
|
Gson gson = new Gson();
|
Type typeOfT = new TypeToken<BaseLocalResponse<List<OidBean>>>() {
|
}.getType();
|
BaseLocalResponse<List<OidBean>> baseLocalResponse = gson.fromJson(json, typeOfT);
|
|
if (linkCallBack == null) {
|
return;
|
}
|
if (baseLocalResponse == null || baseLocalResponse.getObjects() == null) {
|
linkCallBack.onSuccess(new ArrayList<>());
|
} else {
|
linkCallBack.onSuccess(baseLocalResponse.getObjects());
|
}
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
if (linkCallBack != null) {
|
linkCallBack.onError(e);
|
}
|
}
|
});
|
|
}
|
|
/**
|
* 获取逆变器列表(整合云端和本地列表)
|
* 注意:有外网，以云端设备为准,本地存在，云端没有则删除；内网，以本地为主,搜索多少个设备就显示多少个；
|
*
|
* @param homeId 住宅id
|
* @param cloudCallBeak 返回逆变器列表
|
*/
|
public void getCurrentHomeLocalAndCloudGatewayList(String homeId, CloudCallBeak<List<GatewayBean>> cloudCallBeak) {
|
HdlDeviceLogic.getInstance().searchCurrentHomeGateway(new GatewayCallBack() {
|
@Override
|
public void onSuccess(List<GatewayBean> gatewayBeanList) {
|
//局域网有2种情况(1:有局域网，有外网；2:有局域网，没有外网);
|
HdlDeviceLogic.getInstance().getCloudInverterDeviceList(homeId, new CloudCallBeak<List<CloudInverterDeviceBean>>() {
|
@Override
|
public void onSuccess(List<CloudInverterDeviceBean> list) {
|
///情况1:有局域网，有外网；
|
if (list == null || list.size() == 0) {
|
//云端没有绑定逆变器,默认返回本地逆变器列表;
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(getCurrentHomeGatewayList(homeId));
|
}
|
return;
|
}
|
//记录条数
|
AtomicInteger atomicInteger = new AtomicInteger(0);
|
for (int i = 0; i < list.size(); i++) {
|
CloudInverterDeviceBean cloudInverterDeviceBean = list.get(i);
|
//获取远程设备通讯信息(拿到网关ID，mqtt通讯秘钥)
|
getDeviceRemoteInfo(homeId, cloudInverterDeviceBean.getSpk(), cloudInverterDeviceBean.getOsn(), new CloudCallBeak<DeviceRemoteInfo>() {
|
@Override
|
public void onSuccess(DeviceRemoteInfo deviceRemoteInfo) {
|
atomicInteger.set(atomicInteger.get() + 1);
|
//更新逆变器本地缓存信息
|
refreshGatewayCacheData(true, cloudInverterDeviceBean, deviceRemoteInfo, homeId);
|
//最后一条才做删除逆变器逻辑处理
|
if (atomicInteger.get() == list.size()) {
|
//收集删除逆变器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++) {
|
//删除本地的逆变器
|
removeLocalInverter(removeSidList.get(i));
|
}
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(getCurrentHomeGatewayList(homeId));
|
}
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
atomicInteger.set(atomicInteger.get() + 1);
|
//当最后一条请求失败了，才在这里做删除逆变器逻辑处理
|
if (atomicInteger.get() == list.size()) {
|
//收集删除逆变器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++) {
|
//删除本地的逆变器
|
removeLocalInverter(removeSidList.get(i));
|
}
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(getCurrentHomeGatewayList(homeId));
|
}
|
}
|
HdlLogLogic.print("获取设备远程通讯信息失败->msg->" + e.getMsg() + "(" + e.getCode() + ")");
|
}
|
});
|
}
|
|
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
///情况2:有局域网，没有外网;
|
//本地有逆变器列表,获取云端绑定逆变器失败,默认返回本地逆变器列表;
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(getCurrentHomeGatewayList(homeId));
|
}
|
}
|
});
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
//外网只有1种情况(本地搜索逆变器列表失败了)
|
HdlDeviceLogic.getInstance().getCloudInverterDeviceList(homeId, new CloudCallBeak<List<CloudInverterDeviceBean>>() {
|
@Override
|
public void onSuccess(List<CloudInverterDeviceBean> list) {
|
//外网进来先【默认】清空本地逆变器列表
|
HDLLinkLocalGateway.getInstance().getGatewayList().clear();
|
if (list == null || list.size() == 0) {
|
if (cloudCallBeak != null) {
|
//云端也没有逆变器列表,返回空列表回去
|
cloudCallBeak.onSuccess(new ArrayList<>());
|
}
|
HdlLogLogic.print("在只有【外网】情况下获取云端逆变器列表返回空列表", true);
|
return;
|
}
|
//记录条数
|
AtomicInteger atomicInteger = new AtomicInteger(0);
|
|
for (int i = 0; i < list.size(); i++) {
|
CloudInverterDeviceBean cloudInverterDeviceBean = list.get(i);
|
|
//获取远程设备通讯信息(拿到网关ID，mqtt通讯秘钥)
|
getDeviceRemoteInfo(homeId, cloudInverterDeviceBean.getSpk(), cloudInverterDeviceBean.getOsn(), new CloudCallBeak<DeviceRemoteInfo>() {
|
@Override
|
public void onSuccess(DeviceRemoteInfo deviceRemoteInfo) {
|
atomicInteger.set(atomicInteger.get() + 1);
|
//更新逆变器本地缓存信息
|
refreshGatewayCacheData(false, cloudInverterDeviceBean, deviceRemoteInfo, homeId);
|
//到最后一条，才有回调
|
if (atomicInteger.get() == list.size()) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(getCurrentHomeGatewayList(homeId));
|
}
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
atomicInteger.set(atomicInteger.get() + 1);
|
//当最后一条请求失败了，才有回调
|
if (atomicInteger.get() == list.size()) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(getCurrentHomeGatewayList(homeId));
|
}
|
}
|
HdlLogLogic.print("获取设备远程通讯信息失败--->msg--->" + e.getMsg() + "(" + e.getCode() + ")");
|
}
|
});
|
}
|
|
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(e);
|
}
|
}
|
});
|
}
|
});
|
}
|
|
/**
|
* 获取设备远程通讯信息
|
*
|
* @param homeId 住宅Id
|
* @param spk spk
|
* @param mac 设备mac
|
* @param cloudCallBeak 回调
|
*/
|
public void getDeviceRemoteInfo(String homeId, String spk, String mac, CloudCallBeak<DeviceRemoteInfo> cloudCallBeak) {
|
String requestUrl = HttpApi.POST_Device_RemoteInfo;
|
JsonObject json = new JsonObject();
|
json.addProperty("homeId", homeId);
|
json.addProperty("spk", spk);
|
json.addProperty("mac", mac);
|
HttpClient.getInstance().requestHttp(requestUrl, json.toString(), new CloudCallBeak<String>() {
|
@Override
|
public void onSuccess(String jsonStr) {
|
if (TextUtils.isEmpty(jsonStr)) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(null);
|
}
|
}
|
Type type = new TypeToken<DeviceRemoteInfo>() {
|
}.getType();
|
DeviceRemoteInfo deviceRemoteInfo = new Gson().fromJson(jsonStr, type);
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(deviceRemoteInfo);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 删除本地缓存逆变器
|
*
|
* @param sid 设备sid
|
*/
|
private void removeLocalInverter(String sid) {
|
GatewayBean gatewayBean = HDLLinkLocalGateway.getInstance().getLocalGateway(sid);
|
if (gatewayBean != null) {
|
HDLLinkLocalGateway.getInstance().getGatewayList().remove(gatewayBean);
|
}
|
}
|
|
/**
|
* 清空逆变器住宅id
|
*
|
* @param mac mac
|
*/
|
public void clearInverterHomeId(String mac, LinkCallBack<Boolean> callBeak) {
|
String requestUrl = TopicApi.SET_GATEWAY_REMOTE_EDIT;
|
JsonObject json = new JsonObject();
|
json.addProperty("homeId", "");
|
json.addProperty("server_addr", "");
|
json.addProperty("local_secret", "");
|
TcpClient.getInstance().sendDataToLinkGateway(mac, true, 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 (callBeak != null) {
|
callBeak.onSuccess(true);
|
}
|
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
if (callBeak != null) {
|
callBeak.onError(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 搜索逆变器列表
|
* 注意:只搜索当前住宅逆变器和没有被绑定的逆变器
|
*
|
* @param gatewayCallBack -
|
*/
|
public void searchCurrentHomeGateway(GatewayCallBack gatewayCallBack) {
|
List<String> spks = this.getGatewaySpk();
|
//网关搜索
|
HDLLinkLocalGateway.getInstance().refreshGatewayByHomeIdAndSpk(UserConfigManage.getInstance().getHomeId(), spks, true, gatewayCallBack);
|
}
|
|
/**
|
* 搜索局域网所有逆变器列表
|
* 注意:包括已经被绑定到住宅的逆变器
|
*
|
* @param gatewayCallBack -
|
*/
|
public void searchAllNetworkGateway(GatewayCallBack gatewayCallBack) {
|
//网关搜索
|
HDLLinkLocalSdk.getInstance().refreshGateway(gatewayCallBack, this.getGatewaySpk());
|
}
|
|
/**
|
* 检测本地连接状态
|
*
|
* @param deviceMac 设备mac，
|
* @param callBeak 返回 true=本地连接;false=远程;
|
*/
|
public void isLocalConnect(String deviceMac, CloudCallBeak<Boolean> callBeak) {
|
searchCurrentHomeGateway(new GatewayCallBack() {
|
@Override
|
public void onSuccess(List<GatewayBean> gatewayBeanList) {
|
if (gatewayBeanList == null || gatewayBeanList.size() == 0) {
|
if (callBeak != null) {
|
callBeak.onSuccess(false);
|
}
|
return;
|
}
|
boolean is_find = false;
|
for (int i = 0; i < gatewayBeanList.size(); i++) {
|
GatewayBean gatewayBean = gatewayBeanList.get(i);
|
if (gatewayBean.getDevice_mac().equals(deviceMac)) {
|
//升级的时候搜索网关列表,把之前mqtt秘钥覆盖掉,要重新获取才行;
|
if (!TextUtils.isEmpty(gatewayBean.getHomeId())) {
|
getDeviceRemoteInfo(gatewayBean.getHomeId(), gatewayBean.getSpk(), gatewayBean.getDevice_mac(), new CloudCallBeak<DeviceRemoteInfo>() {
|
@Override
|
public void onSuccess(DeviceRemoteInfo deviceRemoteInfo) {
|
if (deviceRemoteInfo != null) {
|
gatewayBean.setAesKey(deviceRemoteInfo.getSecret());//设置mqtt通讯秘钥
|
gatewayBean.setGatewayId(deviceRemoteInfo.getGatewayId());//设置gatewayId
|
//todo 设置到【库】里面,底层mqtt订阅，加解密会用到该参数;
|
HDLLinkConfig.getInstance().setAesKey(deviceRemoteInfo.getSecret());//设置mqtt通讯秘钥库
|
HDLLinkConfig.getInstance().setGatewayId(deviceRemoteInfo.getGatewayId());//设置gatewayId
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
|
}
|
});
|
}
|
is_find = true;
|
break;
|
}
|
|
}
|
if (callBeak != null) {
|
callBeak.onSuccess(is_find);
|
}
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
if (callBeak != null) {
|
callBeak.onSuccess(false);
|
}
|
}
|
});
|
}
|
|
/**
|
* 检测逆变器有没有连接上云
|
*
|
* @param deviceMac 设备mac
|
*/
|
public void checkInverterConnectedCloud(String homeId, String deviceMac, CloudCallBeak<CloudInverterDeviceBean> cloudCallBeak) {
|
this.getCloudInverterDeviceList(homeId, new CloudCallBeak<List<CloudInverterDeviceBean>>() {
|
@Override
|
public void onSuccess(List<CloudInverterDeviceBean> list) {
|
CloudInverterDeviceBean cloudInverterDeviceBean = null;
|
if (list != null && list.size() > 0) {
|
for (int i = 0; i < list.size(); i++) {
|
if (list.get(i).getOsn().equals(deviceMac)) {
|
cloudInverterDeviceBean = list.get(i);
|
break;
|
}
|
|
}
|
}
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(cloudInverterDeviceBean);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onFailure(e);
|
}
|
}
|
});
|
}
|
|
|
/**
|
* 刷新逆变器缓存信息(包括设置mqtt秘钥）
|
* 注:
|
* 1:本地存在,更新信息即可;
|
* 2:本地不存在,则虚拟一个逆变器对象添加在本地;
|
*
|
* @param deviceRemoteInfo 设备远程通讯信息
|
* @param cloudInverterDeviceBean 逆变器
|
*/
|
private void refreshGatewayCacheData(boolean isLocal, CloudInverterDeviceBean cloudInverterDeviceBean, DeviceRemoteInfo deviceRemoteInfo, String homeId) {
|
//本地查找逆变器
|
GatewayBean gatewayBean = HDLLinkLocalGateway.getInstance().getLocalGateway(cloudInverterDeviceBean.getOsn());
|
if (gatewayBean == null) {
|
//不存在，虚拟一个逆变器对象;
|
gatewayBean = new GatewayBean();
|
HDLLinkLocalGateway.getInstance().getGatewayList().add(gatewayBean);//添加逆变器设备
|
}
|
//更新属性
|
if (deviceRemoteInfo != null) {
|
gatewayBean.setAesKey(deviceRemoteInfo.getSecret());//设置mqtt通讯秘钥
|
gatewayBean.setGatewayId(deviceRemoteInfo.getGatewayId());//设置gatewayId
|
//todo 设置到【库】里面,底层mqtt订阅，加解密会用到该参数;
|
HDLLinkConfig.getInstance().setAesKey(deviceRemoteInfo.getSecret());//设置mqtt通讯秘钥库
|
HDLLinkConfig.getInstance().setGatewayId(deviceRemoteInfo.getGatewayId());//设置gatewayId
|
|
}
|
gatewayBean.setHomeId(homeId);//住宅id
|
gatewayBean.setDeviceStatus(cloudInverterDeviceBean.getDeviceStatus());//设置网关状态
|
gatewayBean.setDeviceId(cloudInverterDeviceBean.getDeviceId());//设置link设备id
|
gatewayBean.setDevice_mac(cloudInverterDeviceBean.getOsn());//设置mac
|
gatewayBean.setOid(cloudInverterDeviceBean.getOid());//设备oid
|
gatewayBean.setSid(cloudInverterDeviceBean.getSid());//设备sid
|
gatewayBean.setDevice_name(cloudInverterDeviceBean.getName());//设备名称
|
gatewayBean.setGatewayType(cloudInverterDeviceBean.getSpk());//设置spk
|
gatewayBean.setLocalEncrypt(true);
|
gatewayBean.setMaster(GatewayMasterType.MasterTrue);//默认都是主逆变器(以后支持从逆变器要更改)
|
gatewayBean.setSystemStatusDesc(cloudInverterDeviceBean.getSystemStatusDesc());//设备状态
|
gatewayBean.setHwVersion(cloudInverterDeviceBean.getHwVersion());//软件版本号
|
gatewayBean.setCategorySecondName(cloudInverterDeviceBean.getCategorySecondName());//设备类型(产品二级分类名称
|
gatewayBean.setAddresses(cloudInverterDeviceBean.getAddresses());//子网号/设备号,逆变器地址
|
gatewayBean.setPowerPvNow(cloudInverterDeviceBean.getPowerPvNow());//发电功率
|
gatewayBean.setTotalElectricityPvToday(cloudInverterDeviceBean.getTotalElectricityPvToday());//今日发电量
|
gatewayBean.setDevice_model(cloudInverterDeviceBean.getOmodel());//设备型号
|
gatewayBean.setSpk(cloudInverterDeviceBean.getSpk());//设备spk
|
|
|
}
|
|
|
/**
|
* 获取网关支持spk列表
|
*
|
* @return -
|
*/
|
public List<String> getGatewaySpk() {
|
List<String> spks = new ArrayList<>();
|
spks.add(DEVICE_SPK);
|
return spks;
|
}
|
|
public boolean isGatewaySpk(String spk) {
|
if (TextUtils.isEmpty(spk)) {
|
return false;
|
}
|
for (int i = 0; i < this.getGatewaySpk().size(); i++) {
|
if (this.getGatewaySpk().get(i).equals(spk)) {
|
return true;
|
}
|
}
|
return false;
|
}
|
|
public final String DEVICE_SPK = "energy.hdl_inverter";
|
}
|
