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