From 2c7615cd73dfa6a7ca4df975430d2217524513d2 Mon Sep 17 00:00:00 2001
From: mac <user@users-MacBook-Pro.local>
Date: 星期四, 28 九月 2023 11:38:28 +0800
Subject: [PATCH] 2023年09月28日11:38:24

---
 app/src/main/java/com/hdl/photovoltaic/other/HdlUniLogic.java |  162 +++++++++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 148 insertions(+), 14 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..690a6db 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,35 @@
 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.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.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.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;
@@ -97,11 +98,54 @@
                 //璁惧妯″潡
                 switch (type) {
                     case HDLUniMP.UNI_EVENT_REPLY_DEVICE_ADD: {
-                        //娣诲姞
+                        //娣诲姞璁惧鍒颁簯绔�
+                        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, -100, e.getMessage(), callback);
+                                                    }
+                                                });
+                                    }
+
+                                    @Override
+                                    public void onError(HDLLinkException e) {
+                                        uniCallbackData(null, -100, e.getMessage(), callback);
+                                    }
+                                });
+                            }
+
+                            @Override
+                            public void onError(HDLLinkException e) {
+                                uniCallbackData(null, -100, e.getMessage(), callback);
+                            }
+                        });
+
 
                     }
                     break;
-                    case HDLUniMP.UNI_EVENT_REPLY_DEVICE_LIST: {
+                    case HDLUniMP.UNI_EVENT_REPLY_DEVICE_NET_LIST: {
                         //缃戝叧鎼滅储
                         HdlDeviceLogic.getInstance().searchGateway(new GatewayCallBack() {
                             @Override
@@ -117,9 +161,86 @@
                         });
                     }
                     break;
+                    case HDLUniMP.UNI_EVENT_REPLY_DEVICE_LIST: {
+                        //鑾峰彇缃戝叧璁惧鍒楄〃
+                        HdlDeviceLogic.getInstance().getLocalGatewayList(new CloudCallBeak<Boolean>() {
+                            @Override
+                            public void onSuccess(Boolean obj) {
+                                if (callback != null) {
+                                    uniCallbackData(HdlDeviceLogic.getInstance().getGatewayList(), callback);
+                                }
+                            }
+
+                            @Override
+                            public void onFailure(HDLException e) {
+                                if (callback != null) {
+                                    uniCallbackData(null, -2, e.getMessage(), callback);
+                                }
+                            }
+                        });
+                    }
+                    break;
                     case HDLUniMP.UNI_EVENT_REPLY_DEVICE_MODBUS_SEND: {
                         sendModBus(data, callback);
+
                     }
+                    break;
+                    case HDLUniMP.UNI_EVENT_REPLY_DEVICE_OID: {
+                        //娣诲姞璁惧鍒颁簯绔�
+                        String mac = getKeyValue("mac", getKeyValue("data", data));
+                        //鑾峰彇oid鍒楄〃
+                        HdlDeviceLogic.getInstance().getGatewayOidList(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, -2, e.getMessage(), callback);
+                            }
+                        });
+                    }
+                    break;
+                    //璁惧鏃堕棿璇诲彇
+                    case HDLUniMP.UNI_EVENT_REPLY_DEVICE_TIME: {
+                        //娣诲姞璁惧鍒颁簯绔�
+                        String mac = getKeyValue("mac", getKeyValue("data", data));
+                        //鑾峰彇oid鍒楄〃
+                        HdlDeviceLogic.getInstance().getGatewayTime(mac, new LinkCallBack<Boolean>() {
+                            @Override
+                            public void onSuccess(Boolean obj) {
+
+                            }
+
+                            @Override
+                            public void onError(HDLLinkException e) {
+
+                            }
+                        });
+                    }
+                    //璁惧鏃堕棿缂栬緫
+                    break;
+                    case HDLUniMP.UNI_EVENT_REPLY_DEVICE_TIME_EDIT: {
+                        //娣诲姞璁惧鍒颁簯绔�
+                        String mac = getKeyValue("mac", getKeyValue("data", data));
+                        //鑾峰彇oid鍒楄〃
+                        HdlDeviceLogic.getInstance().getGatewayOidList(mac, new LinkCallBack<List<OidBean>>() {
+                            @Override
+                            public void onSuccess(List<OidBean> obj) {
+
+                            }
+
+                            @Override
+                            public void onError(HDLLinkException e) {
+
+                            }
+                        });
+                    }
+                    break;
+
                 }
 
             } else if (HDLUniMP.UNI_EVENT_REPLY_WIFI_MODEL.equals(event)) {
@@ -162,20 +283,28 @@
      */
     void sendModBus(Object data, DCUniMPJSCallback callback) {
         String tempData = getKeyValue("data", data);
-        if (tempData == null) {
-            LogUtils.i("data鍐呭涓虹┖");
+        if (TextUtils.isEmpty(tempData)) {
+            HdlLogLogic.print("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());
+        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=" + modBusBean.getData());
             return;
         }
 
+
         //鍙戦�乵odbus鍗忚
-        HDLModBusConnect.getInstance().Send(modBusBean.getOid(), modBusBean.getData(), new ModbusCallBack() {
+        HDLModBusConnect.getInstance().Send(modBusBean.getMac(), modBusBean.getData(), new ModbusCallBack() {
             @Override
-            public void onSuccess(byte[] data) {
+            public void onSuccess(int[] data) {
+                Log.d("data", Arrays.toString(data));
                 uniCallbackData(data, callback);
             }
 
@@ -268,6 +397,8 @@
             uniCallBackBaseBean.setData(obj);
             if (callback != null) {
                 callback.invoke(getJSONObject(uniCallBackBaseBean));
+//                callback.invoke(uniCallBackBaseBean);
+
             }
         } catch (Exception e) {
             HdlLogLogic.print("uni===缁勮uni鍙戦�佹暟鎹牸寮�", e.getMessage());
@@ -293,6 +424,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;
             }

--
Gitblit v1.8.0