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