From 96ef84e192807b383af7d3f2e5c89f08b359137f Mon Sep 17 00:00:00 2001 From: mac <user@users-MacBook-Pro.local> Date: 星期四, 28 十二月 2023 10:23:39 +0800 Subject: [PATCH] 2023年12月28日10:23:22 --- app/src/main/java/com/hdl/photovoltaic/other/HdlDeviceLogic.java | 277 +++++++++++++++++++++++++++++++++++++++++++----------- 1 files changed, 218 insertions(+), 59 deletions(-) diff --git a/app/src/main/java/com/hdl/photovoltaic/other/HdlDeviceLogic.java b/app/src/main/java/com/hdl/photovoltaic/other/HdlDeviceLogic.java index 0a4b5c0..bbe7790 100644 --- a/app/src/main/java/com/hdl/photovoltaic/other/HdlDeviceLogic.java +++ b/app/src/main/java/com/hdl/photovoltaic/other/HdlDeviceLogic.java @@ -6,22 +6,7 @@ import com.google.gson.JsonArray; import com.google.gson.JsonObject; import com.google.gson.reflect.TypeToken; -import com.hdl.hdlhttp.HxHttp; -import com.hdl.linkpm.sdk.core.api.HDLCloudHomeApi; -import com.hdl.linkpm.sdk.core.callback.IDefaultCallBack; -import com.hdl.linkpm.sdk.core.callback.IResponseCallBack; import com.hdl.linkpm.sdk.core.exception.HDLException; -import com.hdl.linkpm.sdk.core.response.HDLResponse; -import com.hdl.linkpm.sdk.device.bean.DeviceOidInfoBean; -import com.hdl.linkpm.sdk.device.bean.GatewayCloudBean; -import com.hdl.linkpm.sdk.ota.HDLLinkPMOta; -import com.hdl.linkpm.sdk.ota.bean.CloudDeviceFirmwaresBean; -import com.hdl.linkpm.sdk.ota.bean.CloudGatewayDriversBean; -import com.hdl.linkpm.sdk.ota.bean.DeviceFirmwareBean; -import com.hdl.linkpm.sdk.ota.bean.DownloadUrlBean; -import com.hdl.linkpm.sdk.ota.bean.GatewayDriverBean; -import com.hdl.linkpm.sdk.project.HDLLinkPMProject; -import com.hdl.linkpm.sdk.utils.HDLExceptionSubmitUtils; import com.hdl.photovoltaic.config.AppConfigManage; import com.hdl.photovoltaic.config.UserConfigManage; import com.hdl.photovoltaic.internet.HttpClient; @@ -35,6 +20,7 @@ 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; @@ -44,15 +30,11 @@ import com.hdl.sdk.link.gateway.HDLLinkLocalGateway; import com.hdl.sdk.link.gateway.type.GatewayMasterType; -import org.json.JSONException; import java.lang.reflect.Type; import java.util.ArrayList; import java.util.List; import java.util.concurrent.atomic.AtomicInteger; - -import io.dcloud.feature.unimp.DCUniMPJSCallback; -import io.reactivex.rxjava3.disposables.Disposable; /** @@ -79,7 +61,7 @@ } /** - * 鑾峰彇褰撳墠浣忓畢鐨勯�嗗彉鍣ㄥ垪琛� + * 鑾峰彇褰撳墠浣忓畢鐨勯�嗗彉鍣ㄥ垪琛�(鍖呮嫭浠庣殑閫嗗彉鍣�) */ public List<GatewayBean> getCurrentHomeGatewayList() { List<GatewayBean> newList = new ArrayList<>(); @@ -100,54 +82,61 @@ } /** - * 鑾峰彇褰撳墠浣忓畢鐨勩�愪富銆戦�嗗彉鍣ㄥ垪琛� + * 鑾峰彇褰撳墠浣忓畢鐨勩�愪富銆戦�嗗彉鍣� */ public GatewayBean getCurrentHomeMainGateway() { - 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; - } - if (gatewayBean.getMaster().equals(GatewayMasterType.MasterTrue) && gatewayBean.getHomeId().equals(UserConfigManage.getInstance().getHomeId())) { - //鎵惧埌杩斿洖 - return gatewayBean; - } + return queryCurrentHomeMainGateway(this.getCurrentHomeGatewayList()); + } + + /** + * 鏌ヨ褰撳墠浣忓畢鐨勩�愪富銆戦�嗗彉鍣� + */ + public GatewayBean queryCurrentHomeMainGateway(List<GatewayBean> list) { + 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(UserConfigManage.getInstance().getHomeId())) { + //鎵惧埌杩斿洖 + findGatewayBean = gatewayBean; + break; } } - return null; + return findGatewayBean; } /** * 閫嗗彉鍣ㄤ笂浼犳暟鎹埌浜戠(鍖呮嫭:sid锛宱id) * - * @param mac 璁惧mac + * @param homeId 浣忓畢id + * @param mac 璁惧mac */ - public void uploadDataToCloud(String mac, CloudCallBeak<Boolean> callBeak) { + public void uploadDataToCloud(String homeId, String mac, CloudCallBeak<Boolean> callBeak) { getInverterOidList(mac, new LinkCallBack<List<OidBean>>() { @Override public void onSuccess(List<OidBean> obj) { if (obj == null) { return; } - fullUpdateOid(obj, new CloudCallBeak<Boolean>() { + fullUpdateOid(homeId, obj, new CloudCallBeak<Boolean>() { @Override public void onSuccess(Boolean obj) { - + HdlLogLogic.print("涓婁紶oid鍒楄〃鍒颁簯绔垚鍔�-->" + homeId + "--->" + mac, true); } @Override public void onFailure(HDLException e) { - + HdlLogLogic.print("涓婁紶oid鍒楄〃鍒颁簯绔け璐�-->" + homeId + "--->" + mac + "-->" + e.getMsg() + "(" + e.getCode() + ")", true); } }); } @Override public void onError(HDLLinkException e) { - + HdlLogLogic.print("鑾峰彇閫嗗彉鍣╫id鍒楄〃澶辫触-->" + homeId + "--->" + mac + "-->" + e.getMsg() + "(" + e.getCode() + ")", true); } }); @@ -181,7 +170,7 @@ if (cloudCallBeak != null) { cloudCallBeak.onSuccess(true); //涓存椂鐨勯�昏緫锛屼笂浼爋id鍒楄〃鍒颁簯绔� - uploadDataToCloud(mac, null); + uploadDataToCloud(UserConfigManage.getInstance().getHomeId(), mac, null); } } @@ -305,14 +294,75 @@ /** * 鍏ㄩ噺鏇存柊OID * + * @param homeId 浣忓畢id * @param oidList oid鍒楄〃 * @param cloudCallBeak 鍥炶皟update */ - public void fullUpdateOid(List<OidBean> oidList, CloudCallBeak<Boolean> cloudCallBeak) { + public void fullUpdateOid(String homeId, List<OidBean> oidList, CloudCallBeak<Boolean> cloudCallBeak) { + if (oidList == null || oidList.size() == 0) { + HdlLogLogic.print("oid鍒楄〃涓虹┖锛屾棤娉曞叏閲忔洿鏂皁id鍒颁簯绔�--->", true); + return; + } String requestUrl = HttpApi.POST_Device_Oid; JsonObject json = new JsonObject(); json.addProperty("operationSource", "PROGRAM_ENERGY");// - json.addProperty("homeId", UserConfigManage.getInstance().getHomeId()); + 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鍒颁簯绔垚鍔�--->", true); + + } + + @Override + public void onFailure(HDLException e) { + if (cloudCallBeak != null) { + cloudCallBeak.onFailure(e); + } + HdlLogLogic.print("鍏ㄩ噺鏇存柊oid鍒颁簯绔け璐�--->" + e.getMsg() + "(" + e.getCode() + ")", true); + } + }); + + } + + + /** + * (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鍒楄〃涓虹┖锛屾棤娉曞閲忔坊鍔爋id鍒颁簯绔�--->", 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); @@ -338,7 +388,7 @@ if (cloudCallBeak != null) { cloudCallBeak.onSuccess(true); } - + HdlLogLogic.print("澧為噺娣诲姞oid鍒颁簯绔垚鍔�--->"); } @Override @@ -346,6 +396,7 @@ if (cloudCallBeak != null) { cloudCallBeak.onFailure(e); } + HdlLogLogic.print("澧為噺娣诲姞oid鍒颁簯绔け璐�--->" + e.getMsg() + "(" + e.getCode() + ")", true); } }); @@ -364,7 +415,7 @@ json.addProperty("homeId", UserConfigManage.getInstance().getHomeId()); json.addProperty("server_addr", AppConfigManage.getUserRegionUrl()); json.addProperty("local_secret", UserConfigManage.getInstance().getLocalSecret()); - //瑙e瘑璐熻浇鏁版嵁(鍥犱负鍐欏瘑閽ョ粰缃戝叧涓�瀹氭槑鏂囷紝鍥犱负閭f椂缃戝叧杩樻病鏈夊瘑閽�) + //瑙e瘑璐熻浇鏁版嵁(鍐欏瘑閽ョ粰缃戝叧涓�瀹氭槸鏄庢枃锛屽洜涓洪偅鏃剁綉鍏宠繕娌℃湁瀵嗛挜) TcpClient.getInstance().sendDataToLinkGateway(mac, false, requestUrl, json, "", new HDLLinkCallBack() { @Override public void onSuccess(String msg) { @@ -564,16 +615,17 @@ /** * 鑾峰彇閫嗗彉鍣ㄥ垪琛�(鏁村悎浜戠鍜屾湰鍦板垪琛�) - * 娉ㄦ剰:鏈夊缃戜互浜戠璁惧涓哄噯,鏈湴瀛樺湪锛屼簯绔病鏈夊垯鍒犻櫎锛涘唴缃戜互鏈湴涓轰富,鎼滅储澶氬皯涓澶囧氨鏄剧ず澶氬皯涓紱 + * 娉ㄦ剰:鏈夊缃戯紝浠ヤ簯绔澶囦负鍑�,鏈湴瀛樺湪锛屼簯绔病鏈夊垯鍒犻櫎锛涘唴缃戯紝浠ユ湰鍦颁负涓�,鎼滅储澶氬皯涓澶囧氨鏄剧ず澶氬皯涓紱 * + * @param homeId 浣忓畢id * @param cloudCallBeak 杩斿洖閫嗗彉鍣ㄥ垪琛� */ - public void getCurrentHomeLocalAndCloudGatewayList(CloudCallBeak<List<GatewayBean>> cloudCallBeak) { - HdlDeviceLogic.getInstance().searchGateway(new GatewayCallBack() { + 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(UserConfigManage.getInstance().getHomeId(), new CloudCallBeak<List<CloudInverterDeviceBean>>() { + HdlDeviceLogic.getInstance().getCloudInverterDeviceList(homeId, new CloudCallBeak<List<CloudInverterDeviceBean>>() { @Override public void onSuccess(List<CloudInverterDeviceBean> list) { ///鎯呭喌1:鏈夊眬鍩熺綉锛屾湁澶栫綉锛� @@ -589,7 +641,7 @@ for (int i = 0; i < list.size(); i++) { CloudInverterDeviceBean cloudInverterDeviceBean = list.get(i); //鑾峰彇杩滅▼璁惧閫氳淇℃伅(鎷垮埌缃戝叧ID锛宮qtt閫氳绉橀挜) - getDeviceRemoteInfo(UserConfigManage.getInstance().getHomeId(), cloudInverterDeviceBean.getSpk(), cloudInverterDeviceBean.getOsn(), new CloudCallBeak<DeviceRemoteInfo>() { + getDeviceRemoteInfo(homeId, cloudInverterDeviceBean.getSpk(), cloudInverterDeviceBean.getOsn(), new CloudCallBeak<DeviceRemoteInfo>() { @Override public void onSuccess(DeviceRemoteInfo deviceRemoteInfo) { atomicInteger.set(atomicInteger.get() + 1); @@ -668,7 +720,7 @@ @Override public void onError(HDLLinkException e) { //澶栫綉鍙湁1绉嶆儏鍐�(鏈湴鎼滅储閫嗗彉鍣ㄥ垪琛ㄥけ璐ヤ簡) - HdlDeviceLogic.getInstance().getCloudInverterDeviceList(UserConfigManage.getInstance().getHomeId(), new CloudCallBeak<List<CloudInverterDeviceBean>>() { + HdlDeviceLogic.getInstance().getCloudInverterDeviceList(homeId, new CloudCallBeak<List<CloudInverterDeviceBean>>() { @Override public void onSuccess(List<CloudInverterDeviceBean> list) { //澶栫綉杩涙潵鍏堛�愰粯璁ゃ�戞竻绌烘湰鍦伴�嗗彉鍣ㄥ垪琛� @@ -678,6 +730,7 @@ //浜戠涔熸病鏈夐�嗗彉鍣ㄥ垪琛�,杩斿洖绌哄垪琛ㄥ洖鍘� cloudCallBeak.onSuccess(new ArrayList<>()); } + HdlLogLogic.print("鍦ㄥ彧鏈夈�愬缃戙�戞儏鍐典笅鑾峰彇浜戠閫嗗彉鍣ㄥ垪琛ㄨ繑鍥炵┖鍒楄〃", true); return; } //璁板綍鏉℃暟 @@ -685,8 +738,9 @@ for (int i = 0; i < list.size(); i++) { CloudInverterDeviceBean cloudInverterDeviceBean = list.get(i); + //鑾峰彇杩滅▼璁惧閫氳淇℃伅(鎷垮埌缃戝叧ID锛宮qtt閫氳绉橀挜) - getDeviceRemoteInfo(UserConfigManage.getInstance().getHomeId(), cloudInverterDeviceBean.getSpk(), cloudInverterDeviceBean.getOsn(), new CloudCallBeak<DeviceRemoteInfo>() { + getDeviceRemoteInfo(homeId, cloudInverterDeviceBean.getSpk(), cloudInverterDeviceBean.getOsn(), new CloudCallBeak<DeviceRemoteInfo>() { @Override public void onSuccess(DeviceRemoteInfo deviceRemoteInfo) { atomicInteger.set(atomicInteger.get() + 1); @@ -815,24 +869,117 @@ /** * 鎼滅储閫嗗彉鍣ㄥ垪琛� + * 娉ㄦ剰:鍙悳绱㈠綋鍓嶄綇瀹呴�嗗彉鍣ㄥ拰娌℃湁琚粦瀹氱殑閫嗗彉鍣� * * @param gatewayCallBack - */ - public void searchGateway(GatewayCallBack gatewayCallBack) { + public void searchCurrentHomeGateway(GatewayCallBack gatewayCallBack) { List<String> spks = this.getGatewaySpk(); //缃戝叧鎼滅储 HDLLinkLocalGateway.getInstance().refreshGatewayByHomeIdAndSpk(UserConfigManage.getInstance().getHomeId(), spks, true, gatewayCallBack); } /** - * 鍒ゆ柇鏄湰鍦拌繛鎺� + * 鎼滅储灞�鍩熺綉鎵�鏈夐�嗗彉鍣ㄥ垪琛� + * 娉ㄦ剰:鍖呮嫭宸茬粡琚粦瀹氬埌浣忓畢鐨勯�嗗彉鍣� + * + * @param gatewayCallBack - + */ + public void searchAllGateway(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)) { + //鍗囩骇鐨勬椂鍊欐悳绱㈢綉鍏冲垪琛�,鎶婁箣鍓峬qtt绉橀挜瑕嗙洊鎺�,瑕侀噸鏂拌幏鍙栨墠琛�; + 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璁㈤槄锛屽姞瑙e瘑浼氱敤鍒拌鍙傛暟; + 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 - * @return true=鏈湴杩炴帴 */ - public boolean isLocalConnect(String deviceMac) { - GatewayBean gatewayBean = HDLLinkLocalGateway.getInstance().getLocalGateway(deviceMac); - return gatewayBean == null; + public void checkInverterConnectedCloud(String deviceMac, CloudCallBeak<CloudInverterDeviceBean> cloudCallBeak) { + this.getCloudInverterDeviceList(UserConfigManage.getInstance().getHomeId(), 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); + } + } + }); } @@ -875,7 +1022,7 @@ gatewayBean.setSystemStatusDesc(cloudInverterDeviceBean.getSystemStatusDesc());//璁惧鐘舵�� gatewayBean.setHwVersion(cloudInverterDeviceBean.getHwVersion());//杞欢鐗堟湰鍙� gatewayBean.setCategorySecondName(cloudInverterDeviceBean.getCategorySecondName());//璁惧绫诲瀷(浜у搧浜岀骇鍒嗙被鍚嶇О - gatewayBean.setAddresses(cloudInverterDeviceBean.getAddresses());//瀛愮綉鍙�/璁惧鍙� + gatewayBean.setAddresses(cloudInverterDeviceBean.getAddresses());//瀛愮綉鍙�/璁惧鍙�,閫嗗彉鍣ㄥ湴鍧� gatewayBean.setPowerPvNow(cloudInverterDeviceBean.getPowerPvNow());//鍙戠數鍔熺巼 gatewayBean.setTotalElectricityPvToday(cloudInverterDeviceBean.getTotalElectricityPvToday());//浠婃棩鍙戠數閲� gatewayBean.setDevice_model(cloudInverterDeviceBean.getOmodel());//璁惧鍨嬪彿 @@ -890,11 +1037,23 @@ * * @return - */ - private List<String> getGatewaySpk() { + 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"; } -- Gitblit v1.8.0