From f10bd384ab2c5e459b9bf20766970615e429b4ec Mon Sep 17 00:00:00 2001 From: mac <user@users-MacBook-Pro.local> Date: 星期四, 16 十一月 2023 16:53:22 +0800 Subject: [PATCH] 备份一下代码 --- app/src/main/java/com/hdl/photovoltaic/other/HdlUniLogic.java | 609 ++++++++++++++++++++++++++++++++++++++++++++++++------ 1 files changed, 538 insertions(+), 71 deletions(-) diff --git a/app/src/main/java/com/hdl/photovoltaic/other/HdlUniLogic.java b/app/src/main/java/com/hdl/photovoltaic/other/HdlUniLogic.java index 5914e25..ff4307a 100644 --- a/app/src/main/java/com/hdl/photovoltaic/other/HdlUniLogic.java +++ b/app/src/main/java/com/hdl/photovoltaic/other/HdlUniLogic.java @@ -1,34 +1,40 @@ package com.hdl.photovoltaic.other; -import android.content.Intent; import android.text.TextUtils; +import android.util.Log; -import com.alibaba.fastjson.JSON; import com.google.gson.Gson; +import com.hdl.linkpm.sdk.core.exception.HDLException; +import com.hdl.linkpm.sdk.device.bean.DeviceOidInfoBean; +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.GatewayDriverBean; import com.hdl.photovoltaic.HDLApp; -import com.hdl.photovoltaic.bean.BaseEventBus; import com.hdl.photovoltaic.bean.ModBusBean; -import com.hdl.photovoltaic.config.ConstantManage; import com.hdl.photovoltaic.config.UserConfigManage; import com.hdl.photovoltaic.listener.CloudCallBeak; -import com.hdl.photovoltaic.ui.bean.HouseIdBean; +import com.hdl.photovoltaic.listener.LinkCallBack; +import com.hdl.photovoltaic.ui.bean.DeviceTimeBean; +import com.hdl.photovoltaic.ui.bean.OidBean; import com.hdl.photovoltaic.uni.HDLUniMP; import com.hdl.photovoltaic.uni.HDLUniMPSDKManager; -import com.hdl.photovoltaic.uni.UniToAndroidBean; import com.hdl.photovoltaic.utils.WifiUtils; import com.hdl.sdk.link.common.exception.HDLLinkCode; import com.hdl.sdk.link.common.exception.HDLLinkException; -import com.hdl.sdk.link.common.utils.LogUtils; +import com.hdl.sdk.link.core.bean.eventbus.BaseEventBus; import com.hdl.sdk.link.core.bean.gateway.GatewayBean; import com.hdl.sdk.link.core.callback.GatewayCallBack; import com.hdl.sdk.link.core.callback.ModbusCallBack; import com.hdl.sdk.link.core.connect.HDLModBusConnect; +import com.hdl.sdk.link.gateway.HDLLinkLocalGateway; import org.greenrobot.eventbus.EventBus; import org.json.JSONObject; +import java.util.Arrays; import java.util.List; import io.dcloud.feature.unimp.DCUniMPJSCallback; @@ -56,7 +62,7 @@ return sHdlUniLogic; } - //region ******銆愬師鐢熴�戝拰銆愬皬绋嬪簭銆戦�氳鐨勬柟娉� onOtherUniMPEventReceive();openUniMP();sendUni();****** + //region ******銆愬師鐢熴�戝拰銆愬皬绋嬪簭銆戦�氳鐨�3涓柟娉曞悕 onOtherUniMPEventReceive();openUniMP();sendUni();****** /** * 鍘熺敓鎺ユ敹鍒皍ni鍙戞潵鐨勬暟鎹� @@ -76,16 +82,28 @@ if (HDLUniMP.UNI_EVENT_REPLY_HOME_MODEL.equals(event)) { //浣忓畢妯″潡 switch (type) { + //鍒涘缓鐢电珯 case HDLUniMP.UNI_EVENT_REPLY_HOME_CREATION: { - //鍒涘缓 + //EventBus浜嬩欢鍒嗗彂 BaseEventBus baseEventBus = new BaseEventBus(); - baseEventBus.setType(ConstantManage.EVENTBUS_POST_HOME_CREATED); + baseEventBus.setType(HDLUniMP.UNI_EVENT_REPLY_HOME_CREATION); + baseEventBus.setData(getKeyValue("data", data)); EventBus.getDefault().post(baseEventBus); } break; + //璇诲彇璇︽儏 case HDLUniMP.UNI_EVENT_REPLY_HOME_DETAILS: { - //璇︽儏 + + } + break; + //鍏抽棴璇︽儏椤� + case HDLUniMP.UNI_EVENT_REPLY_HOME_CLOSE_HOME_DETAILS_PAGE: { + //EventBus浜嬩欢鍒嗗彂 + BaseEventBus baseEventBus = new BaseEventBus(); + baseEventBus.setType(HDLUniMP.UNI_EVENT_REPLY_HOME_CLOSE_HOME_DETAILS_PAGE); + baseEventBus.setData(getKeyValue("data", data)); + EventBus.getDefault().post(baseEventBus); } break; @@ -96,95 +114,132 @@ } else if (HDLUniMP.UNI_EVENT_REPLY_DEVICE_MODEL.equals(event)) { //璁惧妯″潡 switch (type) { + //娣诲姞閫嗗彉鍣ㄥ埌浜戠 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_ADD: { - //娣诲姞 - + this.uniAddInverterDeviceToCloud(data, callback); } break; + //鍒犻櫎浜戠閫嗗彉鍣� + case HDLUniMP.UNI_EVENT_REPLY_DEVICE_DEL: { + this.uniDelInverterDevice(data, callback); + } + break; + //灞�鍩熺綉鎼滅储閫嗗彉鍣ㄥ垪琛� + case HDLUniMP.UNI_EVENT_REPLY_DEVICE_NET_LIST: { + this.uniSearchGateway(callback); + } + break; + //鑾峰彇閫嗗彉鍣ㄥ垪琛� case HDLUniMP.UNI_EVENT_REPLY_DEVICE_LIST: { - //缃戝叧鎼滅储 - HdlDeviceLogic.getInstance().searchGateway(new GatewayCallBack() { - @Override - public void onSuccess(List<GatewayBean> gatewayBeanList) { - uniCallbackData(gatewayBeanList, callback); - } - - @Override - public void onError(HDLLinkException e) { - //鍙戦�佸け璐� - uniCallbackData(null, e.getCode(), "", callback); - } - }); + this.uniGetCurrentHomeLocalAndCloudGatewayList(callback); } break; case HDLUniMP.UNI_EVENT_REPLY_DEVICE_MODBUS_SEND: { sendModBus(data, callback); } + break; + //鑾峰彇oid鍒楄〃 + case HDLUniMP.UNI_EVENT_REPLY_DEVICE_OID: { + this.uniGetInverterOidList(data, callback); + } + break; + //閫嗗彉鍣ㄦ椂闂磋鍙� + case HDLUniMP.UNI_EVENT_REPLY_DEVICE_TIME: { + this.uniGetInverterTime(data, callback); + } + + break; + //閫嗗彉鍣ㄦ椂闂寸紪杈� + case HDLUniMP.UNI_EVENT_REPLY_DEVICE_TIME_EDIT: { + this.uniEditInverterTime(data, callback); + } + break; + //閫嗗彉鍣ㄤ笂浼犳暟鎹埌浜戠 + case HDLUniMP.UNI_EVENT_REPLY_DEVICE_UPLOADING_DATA: { + this.uniUploadDataToCloud(data, callback); + } + break; + //閫嗗彉鍣ㄦ竻绌轰綇瀹卛d + case HDLUniMP.UNI_EVENT_REPLY_DEVICE_CLEAR_DATA: { + this.uniClearInverterHomeId(data, callback); + } + break; + } } else if (HDLUniMP.UNI_EVENT_REPLY_WIFI_MODEL.equals(event)) { WifiUtils wifiUtils = new WifiUtils(HDLApp.getInstance()); //wifi妯″潡 switch (type) { + //鑾峰彇wifi鍒楄〃 case HDLUniMP.UNI_EVENT_REPLY_WIFI_LIST: { - //鑾峰彇wifi鍒楄〃 if (callback != null) { uniCallbackData(wifiUtils.getScanResult(), callback); } } break; + //褰撳墠wifi璇︽儏 case HDLUniMP.UNI_EVENT_REPLY_WIFI_INFO: { - //褰撳墠wifi璇︽儏 if (callback != null) { uniCallbackData(wifiUtils.getCurrentConnectWifiInfo(), callback); } } break; + //wifi杩炴帴 case HDLUniMP.UNI_EVENT_REPLY_WIFI_CONNECT: { - //wifi杩炴帴 + + } + break; + + } + } else if (HDLUniMP.UNI_EVENT_REPLY_OTA_MODEL.equals(event)) { + //OTA鍗囩骇妯″潡 + switch (type) { + //鍚戜簯绔幏鍙杘id鍒楄〃 + case HDLUniMP.UNI_EVENT_REPLY_OTA_CLOUD_OID_LIST: { + this.uniGetCloudOidList(data, callback); + } + break; + //褰撳墠璁惧鍥轰欢鍒楄〃 + case HDLUniMP.UNI_EVENT_REPLY_OTA_FIRMWARES_LIST: { + this.uniGetCurrentDeviceFirmwares(data, callback); + } + break; + //璁惧鏂板浐浠跺垪琛� + case HDLUniMP.UNI_EVENT_REPLY_OTA_FIRMWARES_NEW_LIST: { + this.uniGetNewDeviceFirmwares(data, callback); + } + break; + //璁惧鍥轰欢鍗囩骇 + case HDLUniMP.UNI_EVENT_REPLY_OTA_FIRMWARES_UPGRADE: { + this.uniUpgradeDeviceFirmware(data, callback); + } + break; + //褰撳墠璁惧椹卞姩鍒楄〃 + case HDLUniMP.UNI_EVENT_REPLY_OTA_DRIVER_LIST: { + this.uniGetCurrentGatewayDrivers(data, callback); + } + break; + //璁惧鏂伴┍鍔ㄥ垪琛� + case HDLUniMP.UNI_EVENT_REPLY_OTA_DRIVER_NEW: { + this.uniGetNewGatewayDrivers(data, callback); + } + break; + //璁惧椹卞姩鍗囩骇 + case HDLUniMP.UNI_EVENT_REPLY_OTA_DRIVER_UPGRADE: { + this.uniUpgradeGatewayDriver(data, callback); } break; } } - HdlLogLogic.print("uni===鍘熺敓鎺ユ敹uni鍙戞潵鐨勬暟鎹�", event + "\r\n" + data); + HdlLogLogic.print("uni===鍘熺敓鎺ユ敹uni鍙戞潵鐨勬暟鎹�===" + event + "\r\n" + data, false); } catch (Exception e) { - HdlLogLogic.print("uni===鍘熺敓鎺ユ敹uni鍙戞潵鐨勬暟鎹�", e.getMessage()); + HdlLogLogic.print("uni===鍘熺敓鎺ユ敹uni鍙戞潵鐨勬暟鎹�===" + e.getMessage(), false); } } - /** - * 鍙戦�乵odbus鍗忚鏁版嵁 - * - * @param data modbus鏁版嵁 - * @param callback 鍥炶皟 - */ - void sendModBus(Object data, DCUniMPJSCallback callback) { - String tempData = getKeyValue("data", data); - if (tempData == null) { - LogUtils.i("data鍐呭涓虹┖"); - return; - } - ModBusBean modBusBean = com.alibaba.fastjson.JSONObject.parseObject(JSON.toJSONString(tempData), ModBusBean.class); - if (modBusBean.getOid() == null || modBusBean.getData() == null) { - LogUtils.i("鍐呭涓虹┖,oid=" + modBusBean.getOid() + " data=" + modBusBean.getData()); - return; - } - - //鍙戦�乵odbus鍗忚 - HDLModBusConnect.getInstance().Send(modBusBean.getOid(), modBusBean.getData(), new ModbusCallBack() { - @Override - public void onSuccess(byte[] data) { - uniCallbackData(data, callback); - } - - @Override - public void onError(HDLLinkException e) { - uniCallbackData(null, e.getCode(), e.getMsg(), callback); - } - }); - } /** * 鍘熺敓鎵撳紑uni鎸囧畾椤甸潰 @@ -193,10 +248,9 @@ * @param jsonObject 闄勪欢鏁版嵁(娌℃湁鏁版嵁濉玭ull) */ public void openUniMP(String path, JSONObject jsonObject) { - - JSONObject json = this.createdJsonDate(jsonObject, true); - HdlLogLogic.print("uni===缁勮uni鍙戦�佹暟鎹牸寮�", json.toString()); + JSONObject json = this.createdJSONObject(jsonObject, true); HDLUniMPSDKManager.getInstance().openUniMP(HDLUniMP.UNI_APP_ID, path, json, HdlUniLogic.this); + HdlLogLogic.print("uni===缁勮uni鍙戦�佹暟鎹牸寮�===" + json, false); } /** @@ -210,7 +264,7 @@ try { HDLUniMPSDKManager.getInstance().sendUniMPEvent(HDLUniMP.UNI_APP_ID, topic, getJSONObject(callBackBaseBean)); } catch (Exception e) { - HdlLogLogic.print("uni===鍘熺敓涓诲姩鍚戝皬绋嬪簭鍙戦�侀�氱煡浜嬩欢", e.getMessage()); + HdlLogLogic.print("uni===鍘熺敓涓诲姩鍚戝皬绋嬪簭鍙戦�侀�氱煡浜嬩欢===" + e.getMessage(), false); } } @@ -222,17 +276,424 @@ } //endregion + //region ******uni鎺ュ彛鏂规硶****** + + /** + * 鍚戜簯绔幏鍙栭�嗗彉鍣╫id鍒楄〃 + * 鍓嶆彁鏉′欢:瑕佷笂浼犻�嗗彉鍣╫id鍒楄〃缁欎簯绔� + * + * @param callback - + */ + private void uniGetCloudOidList(Object data, DCUniMPJSCallback callback) { + HdlOtaLogic.getInstance().getCloudOidList(new CloudCallBeak<List<DeviceOidInfoBean>>() { + @Override + public void onSuccess(List<DeviceOidInfoBean> obj) { + uniCallbackData(obj, callback); + } + + @Override + public void onFailure(HDLException e) { + uniCallbackData(null, e.getCode(), e.getMsg(), callback); + } + }); + } + + /** + * 鍚戜簯绔幏鍙栥�愬綋鍓嶈澶囧浐浠躲�戝垪琛� + * 鍓嶆彁鏉′欢:璁惧鑷姩涓婃姤oid淇℃伅缁欎簯绔� + */ + private void uniGetCurrentDeviceFirmwares(Object data, DCUniMPJSCallback callback) { + String deviceOidId = getKeyValue("deviceOidId", getKeyValue("data", data)); + HdlOtaLogic.getInstance().getCurrentDeviceFirmwares(deviceOidId, new CloudCallBeak<List<DeviceFirmwareBean>>() { + @Override + public void onSuccess(List<DeviceFirmwareBean> obj) { + uniCallbackData(obj, callback); + } + + @Override + public void onFailure(HDLException e) { + uniCallbackData(null, e.getCode(), e.getMsg(), callback); + } + }); + } + + /** + * 鍚戜簯绔幏鍙栥�愯澶囨柊鍥轰欢銆戝垪琛� + * 鍓嶆彁鏉′欢:瑕侀�氳繃骞冲彴杞欢涓婁紶鏂板浐浠� + */ + private void uniGetNewDeviceFirmwares(Object data, DCUniMPJSCallback callback) { + String hardwareModel = getKeyValue("hardwareModel", getKeyValue("data", data));//纭欢鍨嬪彿 + String osImageId = getKeyValue("osImageId", getKeyValue("data", data));//绯荤粺闀滃儚id + HdlOtaLogic.getInstance().getNewDeviceFirmwares(hardwareModel, osImageId, new CloudCallBeak<List<CloudDeviceFirmwaresBean>>() { + @Override + public void onSuccess(List<CloudDeviceFirmwaresBean> obj) { + uniCallbackData(obj, callback); + } + + @Override + public void onFailure(HDLException e) { + uniCallbackData(null, e.getCode(), e.getMsg(), callback); + } + }); + } + + /** + * 鍚戜簯绔彂璧枫�愯澶囧浐浠躲�戝崌绾TA鎸囦护 + */ + private void uniUpgradeDeviceFirmware(Object data, DCUniMPJSCallback callback) { + String deviceOidId = getKeyValue("deviceOidId", getKeyValue("data", data));//璁惧id + String firmwareVersionId = getKeyValue("firmwareVersionId", getKeyValue("data", data));//鍥轰欢鐗堟湰id + HdlOtaLogic.getInstance().upgradeDeviceFirmware(deviceOidId, firmwareVersionId, new CloudCallBeak<Boolean>() { + @Override + public void onSuccess(Boolean obj) { + uniCallbackData(obj, callback); + } + + @Override + public void onFailure(HDLException e) { + uniCallbackData(null, e.getCode(), e.getMsg(), callback); + } + }); + } + + /** + * 鍚戜簯绔幏鍙栥�愬綋鍓嶈澶囬┍鍔ㄣ�戝垪琛� + * 鍓嶆彁鏉′欢:璁惧鑷姩涓婃姤oid淇℃伅缁欎簯绔� + */ + private void uniGetCurrentGatewayDrivers(Object data, DCUniMPJSCallback callback) { + String deviceOid = getKeyValue("oid", getKeyValue("data", data)); + HdlOtaLogic.getInstance().getCurrentGatewayDrivers(deviceOid, new CloudCallBeak<List<GatewayDriverBean>>() { + @Override + public void onSuccess(List<GatewayDriverBean> obj) { + uniCallbackData(obj, callback); + } + + @Override + public void onFailure(HDLException e) { + uniCallbackData(null, e.getCode(), e.getMsg(), callback); + } + }); + } + + /** + * 鍚戜簯绔幏鍙栥�愯澶囨柊椹卞姩銆戝垪琛� + * 鍓嶆彁鏉′欢:瑕侀�氳繃骞冲彴杞欢涓婁紶鏂伴┍鍔� + */ + private void uniGetNewGatewayDrivers(Object data, DCUniMPJSCallback callback) { + String driveCode = getKeyValue("driveCode", getKeyValue("data", data));//椹卞姩缂栧彿鎴栭┍鍔ㄥ悕绉� + String osImageId = getKeyValue("osImageId", getKeyValue("data", data));//椹卞姩绫诲瀷id + HdlOtaLogic.getInstance().getNewGatewayDrivers(driveCode, osImageId, new CloudCallBeak<CloudGatewayDriversBean>() { + @Override + public void onSuccess(CloudGatewayDriversBean obj) { + uniCallbackData(obj, callback); + } + + @Override + public void onFailure(HDLException e) { + uniCallbackData(null, e.getCode(), e.getMsg(), callback); + } + }); + } + + /** + * 鍚戜簯绔彂璧枫�愯澶囬┍鍔ㄣ�戝崌绾TA鎸囦护 + */ + private void uniUpgradeGatewayDriver(Object data, DCUniMPJSCallback callback) { + String deviceOid = getKeyValue("oid", getKeyValue("data", data));//缃戝叧璁惧oid + String driverVersionId = getKeyValue("driverVersionId", getKeyValue("data", data));//椹卞姩鐗堟湰id + HdlOtaLogic.getInstance().upgradeGatewayDriver(deviceOid, driverVersionId, new CloudCallBeak<Boolean>() { + @Override + public void onSuccess(Boolean obj) { + uniCallbackData(obj, callback); + } + + @Override + public void onFailure(HDLException e) { + uniCallbackData(null, e.getCode(), e.getMsg(), callback); + } + }); + } + + /** + * 閫嗗彉鍣ㄦ竻绌轰綇瀹卛d + * + * @param data uni鏁版嵁 + * @param callback uni鍥炶皟 + */ + private void uniClearInverterHomeId(Object data, DCUniMPJSCallback callback) { + String mac = getKeyValue("mac", getKeyValue("data", data)); + HdlDeviceLogic.getInstance().clearInverterHomeId(mac, new LinkCallBack<Boolean>() { + @Override + public void onSuccess(Boolean obj) { + uniCallbackData(null, callback); + } + + @Override + public void onError(HDLLinkException e) { + uniCallbackData(null, e.getCode(), e.getMsg(), callback); + } + }); + } + + /** + * 閫嗗彉鍣ㄣ�愪笂浼犳暟鎹�戝埌浜戠 + * + * @param data uni鏁版嵁 + * @param callback uni鍥炶皟 + */ + private void uniUploadDataToCloud(Object data, DCUniMPJSCallback callback) { + String mac = getKeyValue("mac", getKeyValue("data", data)); + HdlDeviceLogic.getInstance().uploadDataToCloud(mac, null); + } + + /** + * 缂栬緫閫嗗彉鍣ㄦ椂闂� + * + * @param data uni鏁版嵁 + * @param callback uni鍥炶皟 + */ + private void uniEditInverterTime(Object data, DCUniMPJSCallback callback) { + String mac = getKeyValue("mac", getKeyValue("data", data)); + String date = getKeyValue("date", getKeyValue("data", data)); + String time = getKeyValue("time", getKeyValue("data", data)); + HdlDeviceLogic.getInstance().editGatewayTime(mac, date, time, new LinkCallBack<Boolean>() { + @Override + public void onSuccess(Boolean obj) { + uniCallbackData(true, callback); + } + + @Override + public void onError(HDLLinkException e) { + uniCallbackData(null, e.getCode(), e.getMsg(), callback); + } + }); + } + + /** + * 鑾峰彇閫嗗彉鍣ㄦ椂闂� + * + * @param data uni鏁版嵁 + * @param callback uni鍥炶皟 + */ + private void uniGetInverterTime(Object data, DCUniMPJSCallback callback) { + String mac = getKeyValue("mac", getKeyValue("data", data)); + HdlDeviceLogic.getInstance().getGatewayTime(mac, new LinkCallBack<DeviceTimeBean>() { + @Override + public void onSuccess(DeviceTimeBean deviceTimeBean) { + if (callback != null) { + uniCallbackData(deviceTimeBean, callback); + } + } + + @Override + public void onError(HDLLinkException e) { + uniCallbackData(null, e.getCode(), e.getMsg(), callback); + } + }); + } + + /** + * 鑾峰彇oid鍒楄〃 + * + * @param data uni鏁版嵁 + * @param callback uni鍥炶皟 + */ + private void uniGetInverterOidList(Object data, DCUniMPJSCallback callback) { + String mac = getKeyValue("mac", getKeyValue("data", data)); + HdlDeviceLogic.getInstance().getInverterOidList(mac, new LinkCallBack<List<OidBean>>() { + @Override + public void onSuccess(List<OidBean> list) { + if (callback != null) { + uniCallbackData(list, callback); + } + } + + @Override + public void onError(HDLLinkException e) { + uniCallbackData(null, e.getCode(), e.getMsg(), callback); + } + }); + } + + /** + * 閫嗗彉鍣ㄦ坊鍔犲埌浜戠涓� + * + * @param data uni鏁版嵁 + * @param callback uni鍥炶皟 + */ + private void uniAddInverterDeviceToCloud(Object data, DCUniMPJSCallback callback) { + String mac = getKeyValue("mac", getKeyValue("data", data)); + HdlDeviceLogic.getInstance().setGatewayRemoteParam(mac, new LinkCallBack<Boolean>() { + @Override + public void onSuccess(Boolean obj) { + HdlDeviceLogic.getInstance().editGatewayParam(mac, new LinkCallBack<Boolean>() { + @Override + public void onSuccess(Boolean obj) { + GatewayBean gatewayBean = HDLLinkLocalGateway.getInstance().getLocalGateway(mac); + if (gatewayBean == null) { + uniCallbackData(null, -100, "鏈湴鎵句笉鍒扮綉鍏�", callback); + return; + } + HdlDeviceLogic.getInstance().addInverterDeviceToCloud(mac, gatewayBean.getGatewayType(), gatewayBean.getSid(), gatewayBean.getOid(), gatewayBean.getDevice_name(), new CloudCallBeak<Boolean>() { + @Override + public void onSuccess(Boolean obj) { + uniCallbackData(null, callback); + } + + @Override + public void onFailure(HDLException e) { + uniCallbackData(null, e.getCode(), e.getMsg(), callback); + } + }); + } + + @Override + public void onError(HDLLinkException e) { + uniCallbackData(null, e.getCode(), e.getMsg(), callback); + } + }); + } + + @Override + public void onError(HDLLinkException e) { + uniCallbackData(null, e.getCode(), e.getMsg(), callback); + } + }); + } + + /** + * 鍒犻櫎浜戠涓婇�嗗彉鍣� + * + * @param data uni鏁版嵁 + * @param callback uni鍥炶皟 + */ + private void uniDelInverterDevice(Object data, DCUniMPJSCallback callback) { + String deviceId = getKeyValue("deviceId", getKeyValue("data", data)); + HdlDeviceLogic.getInstance().delInverterDevice(deviceId, new CloudCallBeak<Boolean>() { + @Override + public void onSuccess(Boolean obj) { + uniCallbackData(null, callback); + } + + @Override + public void onFailure(HDLException e) { + uniCallbackData(null, e.getCode(), e.getMsg(), callback); + } + }); + } + + + /** + * 灞�鍩熺綉鎼滅储閫嗗彉鍣ㄥ垪琛� + * + * @param callback uni鍥炶皟 + */ + private void uniSearchGateway(DCUniMPJSCallback callback) { + HdlDeviceLogic.getInstance().searchGateway(new GatewayCallBack() { + @Override + public void onSuccess(List<GatewayBean> gatewayBeanList) { + uniCallbackData(gatewayBeanList, callback); + } + + @Override + public void onError(HDLLinkException e) { + //鍙戦�佸け璐� + uniCallbackData(null, e.getCode(), e.getMsg(), callback); + } + }); + + } + + /** + * 鑾峰彇閫嗗彉鍣ㄥ垪琛� + * + * @param callback uni鍥炶皟 + */ + private void uniGetCurrentHomeLocalAndCloudGatewayList(DCUniMPJSCallback callback) { + HdlDeviceLogic.getInstance().getCurrentHomeLocalAndCloudGatewayList(new CloudCallBeak<List<GatewayBean>>() { + @Override + public void onSuccess(List<GatewayBean> list) { + if (callback != null) { + uniCallbackData(list, callback); + //EventBus浜嬩欢鍒嗗彂 + BaseEventBus baseEventBus = new BaseEventBus(); + baseEventBus.setType(HDLUniMP.UNI_EVENT_REPLY_DEVICE_LIST); + baseEventBus.setData(list); + EventBus.getDefault().post(baseEventBus); + } + } + + @Override + public void onFailure(HDLException e) { + if (callback != null) { + uniCallbackData(null, e.getCode(), e.getMsg(), callback); + } + } + }); + + } + + + /** + * 鍙戦�乵odbus鍗忚鏁版嵁 + * 閫忎紶鍗忚 + * 涓嬪彂涓婚锛�/user/${gw_id}/custom/native/${driver}/down; + * 閫嗗彉鍣ㄥ洖澶嶄富棰橈細/user/${gw_id}/custom/native/${driver}/down_reply; + * Modbus ECU鍗忚锛氫簨浠禝D(2涓猙yte)->鍗忚[鍥哄畾:0,0](2涓猙yte)->闀垮害(2byte)->鏍囪瘑绗oid鐨刟ddresses鍊糫(4涓猙yte)->鍔熻兘鐮�(1涓猙yte)->璐熻浇鏁版嵁(N涓猙yte); + * 闀垮害(2涓猙yte)=鏍囪瘑绗�(4涓猙yte)+鍔熻兘鐮�(1涓猙yte)+璐熻浇鏁版嵁(N涓猙yte); + * 璐熻浇鏁版嵁=瀵勫瓨鍣ㄥ湴鍧�(2涓猙yte)+瀵勫瓨鍣ㄩ暱搴�(2涓猙yte)+鍐呭闀垮害(1涓猙yte)+鍐呭鏁版嵁(N涓猙yte)銆愭敞鎰�:鍗曚釜鍐欏叆瀵勫瓨鍣�-->鍘绘帀<瀵勫瓨鍣ㄩ暱搴�>鍜�<鍐呭闀垮害>銆�; + * 瀵勫瓨鍣ㄩ暱搴�=(鍐呭鏁版嵁/2); + * 渚嬪瓙:new byte[]{00,01,00,00,00,0x09,00,00,00,01,03,00,00,00,01}; + * + * @param data modbus鏁版嵁 + * @param callback 鍥炶皟 + */ + private void sendModBus(Object data, DCUniMPJSCallback callback) { + String tempData = getKeyValue("data", data); + if (TextUtils.isEmpty(tempData)) { + HdlLogLogic.print("data鍐呭涓虹┖", false); + return; + } + ModBusBean modBusBean = new Gson().fromJson(tempData, ModBusBean.class); +// ModBusBean modBusBean = new ModBusBean(); +// modBusBean.setOid("0101050219D44A00"); +// modBusBean.setData(new byte[]{00,01,00,00,00,0x09,00,00,00,01,03,00,00,00,01}); +// if (TextUtils.isEmpty(modBusBean.getOid())) { +// modBusBean.setOid("0101050217BBC400"); +// } + if (modBusBean.getMac() == null || modBusBean.getData() == null) { + HdlLogLogic.print("鍐呭涓虹┖===oid=" + modBusBean.getMac() + " data=" + Arrays.toString(modBusBean.getData()), false); + return; + } + + + //鍙戦�乵odbus鍗忚 + HDLModBusConnect.getInstance().Send(modBusBean.getMac(), modBusBean.getData(), new ModbusCallBack() { + @Override + public void onSuccess(int[] data) { + Log.d("data", Arrays.toString(data)); + uniCallbackData(data, callback); + } + + @Override + public void onError(HDLLinkException e) { + uniCallbackData(null, e.getCode(), e.getMsg(), callback); + } + }); + } + + //endregion //region ******涓�鑸柟娉�****** /** * 缁勮uni鍙戦�佹暟鎹牸寮� * - * @param data -闄勪欢鏁版嵁(娌℃湁鏁版嵁濉玭ull) + * @param data 闄勫姞鏁版嵁(娌℃湁鏁版嵁濉玭ull) * @param isTokenAndRefreshToken (true=搴曞眰榛樿娣诲姞token鍜宺efreshToken;false=涓嶅姞) - * @return JSONObject + * @return JSONObject uni鏂规硶鍚嶉噷闈㈠弬鏁伴渶瑕佺殑JSONObject瀵硅薄 */ - private JSONObject createdJsonDate(JSONObject data, boolean isTokenAndRefreshToken) { + private JSONObject createdJSONObject(JSONObject data, boolean isTokenAndRefreshToken) { HDLUniMP.UniCallBackBaseBean uniCallBackBaseBean = new HDLUniMP.UniCallBackBaseBean(); try { if (data == null) { @@ -245,7 +706,7 @@ uniCallBackBaseBean.setData(data); return getJSONObject(uniCallBackBaseBean); } catch (Exception e) { - HdlLogLogic.print("uni===缁勮uni鍙戦�佹暟鎹牸寮�", e.getMessage()); + HdlLogLogic.print("uni===缁勮uni鍙戦�佹暟鎹牸寮�===" + e.getMessage(), false); } return new JSONObject(); } @@ -268,9 +729,11 @@ uniCallBackBaseBean.setData(obj); if (callback != null) { callback.invoke(getJSONObject(uniCallBackBaseBean)); +// callback.invoke(uniCallBackBaseBean); + } } catch (Exception e) { - HdlLogLogic.print("uni===缁勮uni鍙戦�佹暟鎹牸寮�", e.getMessage()); + HdlLogLogic.print("uni===缁勮uni鍙戦�佹暟鎹牸寮�===" + e.getMessage(), false); } @@ -292,6 +755,9 @@ } if (TextUtils.isEmpty(obj.toString())) { return new JSONObject(); + } + if (obj.toString().startsWith("{") && obj.toString().endsWith("}")) { + return new JSONObject(obj.toString()); } if (obj instanceof JSONObject) { return (JSONObject) obj; @@ -321,6 +787,7 @@ } catch (Exception e) { return ""; } + } //endregion -- Gitblit v1.8.0