2026年03月31日17:12:34

wjc

2026-03-31 56f5de5eb6c1501175e7a36b10cf3d1b57284b47

 app/src/main/java/com/hdl/photovoltaic/other/HdlUniLogic.java

@@ -2,6 +2,8 @@


import android.Manifest;
import android.bluetooth.BluetoothDevice;
import android.bluetooth.le.ScanResult;
import android.content.ComponentName;
import android.content.Context;
import android.content.Intent;
@@ -9,6 +11,7 @@
import android.content.pm.PackageManager;
import android.location.Location;
import android.location.LocationManager;
import android.net.Uri;
import android.os.IBinder;
import android.os.SystemClock;
import android.provider.Settings;
@@ -38,6 +41,8 @@
import com.hdl.photovoltaic.bean.PageNumberObject;
import com.hdl.photovoltaic.config.AppConfigManage;
import com.hdl.photovoltaic.config.UserConfigManage;
import com.hdl.photovoltaic.enums.LogoutType;
import com.hdl.photovoltaic.enums.PowerStationType;
import com.hdl.photovoltaic.internet.HttpClient;
import com.hdl.photovoltaic.internet.HttpServer.MyNanoHttpServer;
import com.hdl.photovoltaic.internet.TcpClient;
@@ -46,13 +51,16 @@
import com.hdl.photovoltaic.listener.LinkCallBack;
import com.hdl.photovoltaic.ui.LoginActivity;
import com.hdl.photovoltaic.ui.bean.CUserInfo;
import com.hdl.photovoltaic.ui.bean.ChatMessageBean;
import com.hdl.photovoltaic.ui.bean.CloudInverterDeviceBean;
import com.hdl.photovoltaic.ui.bean.CustomBluetoothBean;
import com.hdl.photovoltaic.ui.bean.DeviceInfoBean;
import com.hdl.photovoltaic.ui.bean.DeviceTimeBean;
import com.hdl.photovoltaic.ui.bean.Geolocation;
import com.hdl.photovoltaic.ui.bean.HouseIdBean;
import com.hdl.photovoltaic.ui.bean.LinkBean;
import com.hdl.photovoltaic.ui.bean.MemberBean;
import com.hdl.photovoltaic.ui.bean.MessageBean;
import com.hdl.photovoltaic.ui.bean.NotRunBean;
import com.hdl.photovoltaic.ui.bean.OidBean;
import com.hdl.photovoltaic.ui.bean.QrcodeUrlBean;
@@ -61,13 +69,17 @@
import com.hdl.photovoltaic.ui.bean.UserRightTypeBean;
import com.hdl.photovoltaic.ui.me.AsRegardsActivity;
import com.hdl.photovoltaic.ui.me.CPersonalDataActivity;
import com.hdl.photovoltaic.ui.me.HelpWebActivity;
import com.hdl.photovoltaic.ui.me.SetActivity;
import com.hdl.photovoltaic.ui.message.MessageInfoActivity;
import com.hdl.photovoltaic.ui.newC.MessageCenterListActivity;
import com.hdl.photovoltaic.ui.newC.PowerStationsListActivity;
import com.hdl.photovoltaic.uni.HDLUniMP;
import com.hdl.photovoltaic.uni.HDLUniMPSDKManager;
import com.hdl.photovoltaic.utils.BleWifiConfiguratorUtils;
import com.hdl.photovoltaic.utils.NetworkUtils;
import com.hdl.photovoltaic.utils.PermissionUtils;
import com.hdl.photovoltaic.utils.SharedPreUtils;
import com.hdl.photovoltaic.utils.WifiUtils;
import com.hdl.sdk.link.common.exception.HDLLinkException;
import com.hdl.sdk.link.core.bean.eventbus.BaseEventBus;
@@ -400,6 +412,11 @@
                        this.uniDeleteOid(mode_type, data, callback);
                    }
                    break;
                    //设备清空运行数据
                    case HDLUniMP.UNI_EVENT_REPLY_DEVICE_clear_data: {
                        this.uniDeviceClearData(mode_type, data, callback);
                    }
                    break;
                }

            } else if (HDLUniMP.UNI_EVENT_REPLY_WIFI_MODEL.equals(topic)) {
@@ -668,6 +685,29 @@

                    }
                    break;
                    //打开消息详情
                    case HDLUniMP.UNI_EVENT_REPLY_Message_Center_Detail: {
                        try {
                            String msgId = getKeyValue("msgId", getKeyValue("data", data));//唯一标识
                            MessageBean messageBean = new MessageBean();
                            messageBean.setMsgId(Long.parseLong(msgId));
                            Intent intent = new Intent();
                            intent.putExtra("messageBean", new Gson().toJson(messageBean));
                            intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
                            intent.setClass(HDLApp.getInstance(), MessageInfoActivity.class);
                            HDLApp.getInstance().startActivity(intent);
                        } catch (Exception e) {
                        }
                    }
                    break;
                    //打开C端帮助页面
                    case HDLUniMP.UNI_EVENT_REPLY_help_Detail: {
                        Intent intent = new Intent();
                        intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
                        intent.setClass(HDLApp.getInstance(), HelpWebActivity.class);
                        HDLApp.getInstance().startActivity(intent);
                    }
                    break;


                }
@@ -714,7 +754,8 @@
                    //uni通知原生退出登录
                    case HDLUniMP.UNI_EVENT_REPLY_OTHER_LOGOUT: {
                        HdlLogLogic.print("uni通知原生退出登录---", true);
                        HDLLinkPMUser.getInstance().logout(0);
//                        HDLLinkPMUser.getInstance().logout(0);
                        HdlAccountLogic.getInstance().logout(LogoutType.NormalLogout);
                    }
                    break;
                    //本地密钥获取
@@ -775,10 +816,10 @@
                                            } else if (s.startsWith("[")) {
                                                uniSuccessCallback(type, new Gson().fromJson(s, JsonArray.class), callback);
                                            } else {
                                                uniSuccessCallback(type, s, callback);
                                                uniSuccessCallback(type, new JsonArray(), callback);
                                            }
                                        } catch (Exception e) {
                                            uniSuccessCallback(type, s, callback);
                                            uniSuccessCallback(type, new JsonArray(), callback);
                                        }
                                    }
                                }
@@ -799,10 +840,10 @@
                                    } else if (json.startsWith("[")) {
                                        uniSuccessCallback(type, new Gson().fromJson(json, JsonArray.class), callback);
                                    } else {
                                        uniSuccessCallback(type, json, callback);
                                        uniSuccessCallback(type, new JsonArray(), callback);
                                    }
                                } catch (Exception e) {
                                    uniSuccessCallback(type, json, callback);
                                    uniSuccessCallback(type, new JsonArray(), callback);
                                }
                                long endTime = System.currentTimeMillis() - startTime;
                                Log.d("====耗时时间====", String.valueOf(endTime));
@@ -815,6 +856,11 @@

                    }
                    break;
                    //设备定位
                    case HDLUniMP.UNI_EVENT_REPLY_OTHER_GET_DEVICE_LOCATION: {
                        this.uniGetDeviceFind(mode_type, data, TopicApi.DELETING_GATEWAY_FIND, callback);
                    }
                    break;
                }
            } else if (HDLUniMP.UNI_EVENT_REPLY_NO_WORK_MODEL.equals(topic)) {
                //无网模式
@@ -822,6 +868,7 @@
                    case HDLUniMP.UNI_EVENT_REPLY_NO_WORK_MODEL_EXIT: {
                        //退出无网模式标识
                        UserConfigManage.getInstance().setNoNetworkFlag(false);
                        UserConfigManage.getInstance().setAutomaticSkipNoNetworkFlag(false);
                        UserConfigManage.getInstance().Save();
                        uniSuccessCallback(mode_type, true, callback);
                        if (null != HDLUniMPSDKManager.getInstance().getUniMP()) {
@@ -830,6 +877,12 @@
                        Intent intent = new Intent(HDLApp.getInstance(), LoginActivity.class);
                        intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK | Intent.FLAG_ACTIVITY_CLEAR_TOP);
                        HDLApp.getInstance().startActivity(intent);
                    }
                    break;
                    case HDLUniMP.UNI_EVENT_REPLY_NO_WORK_MODEL_FROM_OFFLINE: {
                        //设备离网时有入口进入无网模式
                        uniSuccessCallback(mode_type, true, callback);
                        HdlAccountLogic.getInstance().logout(LogoutType.UniLogout);
                    }
                    break;
                    case HDLUniMP.UNI_EVENT_REPLY_NO_WORK_MODEL_DEVICE_INFO: {
@@ -892,6 +945,183 @@
                    }
                });

            } else if (HDLUniMP.UNI_EVENT_REPLY_AI_MODEL.equals(topic)) {
                switch (type) {
                    //发送ai对话聊天
                    case HDLUniMP.UNI_EVENT_REPLY_AI_MODEL_SENDAIREQUEST: {
                        this.uniSendAIChat(mode_type, data, callback);
                    }
                    break;
                    //发送(取消/暂停)AI聊天对话
                    case HDLUniMP.UNI_EVENT_REPLY_AI_MODEL_PAUSEAIREQUEST: {
                        this.uniSendStopAIChat(mode_type, data, callback);
                    }
                    break;
                }
            } else if (HDLUniMP.UNI_EVENT_REPLY_BLUETOOTH_MODEL.equals(topic)) {
                //蓝牙模块
                switch (type) {
                    case HDLUniMP.UNI_EVENT_REPLY_BLUETOOTH_PERMISSION: {
                        //请求蓝牙权限
                        boolean isGranted = HdlBluetoothLogic.getInstance().getMissingPermissions();
                        uniSuccessCallback(mode_type, isGranted, callback);
                    }
                    break;
                    case HDLUniMP.UNI_EVENT_REPLY_BLUETOOTH_OPEN_SETTING: {
                        //前往蓝牙设置页
                        Intent intent = new Intent();
                        intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
                        intent.setAction(Settings.ACTION_APPLICATION_DETAILS_SETTINGS);
                        Uri uri = Uri.fromParts("package", HDLApp.getInstance().getPackageName(), null);
                        intent.setData(uri);
                        HDLApp.getInstance().startActivity(intent);
                    }
                    break;
                    case HDLUniMP.UNI_EVENT_REPLY_BLUETOOTH_LIST: {
                        //搜索/停止蓝牙(startSearch,stopSearch)
                        String startSearch = getKeyValue("operateType", getKeyValue("data", data));
                        String mac = getKeyValue("mac", getKeyValue("data", data));
                        if (!HdlBluetoothLogic.getInstance().checkBluetoothEnabled()) {
                            uniCallbackData(mode_type, 1, -2, HDLApp.getInstance().getString(R.string.bluetooth_not_enabled), callback);
                        }
                        if (startSearch.equals("startSearch")) {
                            HdlBluetoothLogic.getInstance().scanDevices(new BleWifiConfiguratorUtils.ScanListener() {
                                @Override
                                public void onDeviceFound(BluetoothDevice device, int rssi, byte[] scanRecord, ScanResult result) {
                                    try {
//
                                        if (result.getScanRecord().getDeviceName() == null || !result.getScanRecord().getDeviceName().startsWith("BMS")) {
                                            return;
                                        }
                                        // 检查 MAC 地址是否匹配
                                        String deviceAddress = device.getAddress();
                                        if (!TextUtils.isEmpty(mac) && !deviceAddress.equals(mac)) {
                                            // 如果指定了 MAC 地址且不匹配，直接返回
                                            return;
                                        }
                                        //创建并推送设备信息
                                        CustomBluetoothBean customBluetoothBean = new CustomBluetoothBean();
                                        customBluetoothBean.setBluetoothName(result.getScanRecord().getDeviceName());
                                        customBluetoothBean.setBluetoothMac(device.getAddress());
//                                      customBluetoothBean.setUuid(result.getScanRecord());
                                        HDLUniMP.UniCallBackBaseBean uniCallBackBaseBean = new HDLUniMP.UniCallBackBaseBean();
                                        uniCallBackBaseBean.setType(HDLUniMP.UNI_EVENT_NOTIFICATION_DEVICE_find_bluetooth_device);
                                        uniCallBackBaseBean.setData(customBluetoothBean);
                                        HdlUniLogic.getInstance().sendUni(HDLUniMP.UNI_EVENT_NOTIFICATION_DEVICE_MODEL, uniCallBackBaseBean);
                                        Log.d("HdlUniLogic", "onDeviceFound: " + new Gson().toJson(customBluetoothBean));


                                    } catch (Exception ignored) {

                                    }

                                }

                                @Override
                                public void onScanFailed(int errorCode) {
                                    Log.d("HdlUniLogic", "onScanFailed: " + errorCode);
//                                    uniCallbackData(mode_type, errorCode, -2, "Bluetooth is not enabled.", callback);
                                }
                            });
                        } else {
                            HdlBluetoothLogic.getInstance().stopScan();
//                            uniSuccessCallback(mode_type, true, callback);
                            Log.d("HdlUniLogic", "stopScan: ");
                        }
                        uniSuccessCallback(mode_type, true, callback);
                    }
                    break;
                    case HDLUniMP.UNI_EVENT_REPLY_BLUETOOTH_Connect: {
                        //先停止吧，再连接
                        HdlBluetoothLogic.getInstance().stopScan();
                        //连接蓝牙
                        String mac = getKeyValue("mac", getKeyValue("data", data));
                        HdlBluetoothLogic.getInstance().connect(mac, new BleWifiConfiguratorUtils.ConnectListener() {
                            @Override
                            public void onConnected() {
                                Log.d("HdlUniLogic", "onConnected: ");
                                uniSuccessCallback(mode_type, true, callback);
                            }

                            @Override
                            public void onDisconnected() {
                                Log.d("HdlUniLogic", "onDisconnected: ");
                                uniCallbackData(type, null, -2, "disconnected", callback);
                            }

                            @Override
                            public void onConnectionFailed(String reason) {
                                Log.d("HdlUniLogic", "onConnectionFailed: " + reason);
                                uniCallbackData(type, null, -2, "connectionFailed " + reason, callback);
                            }
                        });

                    }
                    break;
                    case HDLUniMP.UNI_EVENT_REPLY_BLUETOOTH_Disconnect: {
                        //断开蓝牙设备
                        String mac = getKeyValue("mac", getKeyValue("data", data));
                        HdlBluetoothLogic.getInstance().disconnect(mac);
                        Log.d("HdlUniLogic", "断开蓝牙设备: ");
                    }
                    break;
                    case HDLUniMP.UNI_EVENT_REPLY_BLUETOOTH_Send: {
                        //发送数据给设备
                        String objString = getKeyValue("data", data);
                        HdlBluetoothLogic.getInstance().sendConfig(objString, new BleWifiConfiguratorUtils.WriteListener() {
                            @Override
                            public void onWriteSuccess() {
                                Log.d("HdlUniLogic", "onWriteSuccess: ");
                            }

                            @Override
                            public void onWriteComplete(boolean success) {
                                Log.d("HdlUniLogic", "onWriteComplete: " + success);
                            }

                            @Override
                            public void onWriteFailed(int status) {
                                Log.d("HdlUniLogic", "onWriteFailed: " + status);
                                uniCallbackData(type, status, -2, HDLApp.getInstance().getString(R.string.write_failed), callback);
                            }

                            @Override
                            public void onDeviceResponse(String response) {
                                Log.d("HdlUniLogic", "onDeviceResponse: " + response);
                                uniSuccessCallback(mode_type, response, callback);
                            }
                        });

                    }
                    break;
                    case HDLUniMP.UNI_EVENT_REPLY_BLUETOOTH_status_check: {
                        //检查蓝牙连接状态
                        String mac = getKeyValue("mac", getKeyValue("data", data));
                        boolean status = HdlBluetoothLogic.getInstance().bluetoothStatusCheck(mac);
                        uniSuccessCallback(mode_type, status, callback);
                        Log.d("HdlUniLogic", "bluetoothStatusCheck: " + status);

                    }
                    break;
                    case HDLUniMP.UNI_EVENT_REPLY_BLUETOOTH_Release: {
                        //释放蓝牙设备资源
                        HdlBluetoothLogic.getInstance().release();
                        Log.d("HdlUniLogic", "释放蓝牙设备资源: ");

                    }
                    break;
                    case HDLUniMP.UNI_EVENT_REPLY_BLUETOOTH_Bms_Device_Bluetooth_Get: {
                        //获取蓝牙状态（BMS设备）
                        this.uniGetOrSetDeviceBluetooth(mode_type, data, TopicApi.GATEWAY_Bluetooth_Get, callback);
                    }
                    break;
                    case HDLUniMP.UNI_EVENT_REPLY_BLUETOOTH_Bms_Device_Bluetooth_Set: {
                        //蓝牙设置开启/关闭（BMS设备）
                        this.uniGetOrSetDeviceBluetooth(mode_type, data, TopicApi.GATEWAY_Bluetooth_Set, callback);
                    }
                    break;
                }

            }

        } catch (Exception e) {
@@ -900,6 +1130,107 @@

    }

    /**
     * 获取设备蓝牙状态,设置蓝牙开开启或者关闭
     *
     * @param callback -
     */
    private void uniGetOrSetDeviceBluetooth(String type, Object data, String TopicApi, DCUniMPJSCallback callback) {
        String mac = getKeyValue("mac", getKeyValue("data", data));
        JsonArray jsonArray = new JsonArray();
        JsonObject jObject = null;
        String attribute_data = getKeyValue("attribute_data", getKeyValue("data", data));
        if (!TextUtils.isEmpty(attribute_data)) {
            try {
                jObject = new Gson().fromJson(attribute_data, JsonObject.class);
            } catch (Exception ignored) {
                jObject = new JsonObject();
            }
        }
        jsonArray.add(jObject);
        TcpClient.getInstance().sendDataToLinkGateway(mac, true, TopicApi, jsonArray, "", new HDLLinkCallBack() {
            @Override
            public void onSuccess(String s) {
                if (callback != null) {
                    try {
                        if (s.startsWith("{")) {
                            uniSuccessCallback(type, new Gson().fromJson(s, JsonObject.class), callback);
                        } else if (s.startsWith("[")) {
                            uniSuccessCallback(type, new Gson().fromJson(s, JsonArray.class), callback);
                        } else {
                            uniSuccessCallback(type, s, callback);
                        }
                    } catch (Exception e) {
                        uniSuccessCallback(type, s, callback);
                    }
                }
            }

            @Override
            public void onError(HDLLinkException e) {
                if (callback != null) {
                    uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
                }
            }
        });
    }

    /**
     * Uni(取消/暂停)AI聊天对话
     *
     * @param callback -
     */
    private void uniSendStopAIChat(String type, Object data, DCUniMPJSCallback callback) {
        String task_id = getKeyValue("task_id", getKeyValue("data", data));
        if (TextUtils.isEmpty(task_id)) {
            uniCallbackData(type, null, -2, "task_id empty", callback);
        }
        HdlAiLogic.getInstance().chatMessageStop(task_id, new CloudCallBeak<Boolean>() {
            @Override
            public void onSuccess(Boolean obj) {
                if (callback != null) {
                    uniSuccessCallback(type, obj, callback);
                }
            }

            @Override
            public void onFailure(HDLException e) {
                uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
            }
        });
    }

    /**
     * Uni发起AI聊天对话
     *
     * @param callback -
     */
    private void uniSendAIChat(String type, Object data, DCUniMPJSCallback callback) {
        String query = getKeyValue("query", getKeyValue("data", data));
        HdlAiLogic.getInstance().chatMessages(query, new CloudCallBeak<ChatMessageBean>() {
            @Override
            public void onSuccess(ChatMessageBean obj) {
                HDLUniMP.UniCallBackBaseBean uniCallBackBaseBean = new HDLUniMP.UniCallBackBaseBean();
                if (obj == null) {
                    //表示结束
                    uniCallBackBaseBean.setType(HDLUniMP.UNI_EVENT_REPLY_AI_MODEL_AISTREAMINGEND);
                } else {
                    uniCallBackBaseBean.setType(HDLUniMP.UNI_EVENT_REPLY_AI_MODEL_AISTREAMING);
                    uniCallBackBaseBean.setData(obj);
                }
                HdlUniLogic.getInstance().sendUni(HDLUniMP.UNI_EVENT_NOTIFICATION_DEVICE_MODEL, uniCallBackBaseBean);
            }

            @Override
            public void onFailure(HDLException e) {
                uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
//                HDLUniMP.UniCallBackBaseBean uniCallBackBaseBean = new HDLUniMP.UniCallBackBaseBean();
//                uniCallBackBaseBean.setType(HDLUniMP.UNI_EVENT_REPLY_AI_MODEL_AISTREAMINGEND);
//                uniCallBackBaseBean.setData(e.getMessage());
//                HdlUniLogic.getInstance().sendUni(HDLUniMP.UNI_EVENT_NOTIFICATION_DEVICE_MODEL, uniCallBackBaseBean);
            }
        });
    }

    /**
     * 原生【打开】uni指定页面
@@ -922,6 +1253,7 @@
     */
    public void sendUni(String topic, HDLUniMP.UniCallBackBaseBean callBackBaseBean) {
        try {
//            HdlLogLogic.print("uni---原生主动向小程序发送通知事件---" +topic, false);
            HDLUniMPSDKManager.getInstance().sendUniMPEvent(HDLUniMP.UNI_APP_ID, topic, getJSONObject(callBackBaseBean));
        } catch (Exception e) {
            HdlLogLogic.print("uni---原生主动向小程序发送通知事件---" + e.getMessage(), false);
@@ -956,6 +1288,47 @@
            @Override
            public void onError(HDLLinkException e) {

                if (callback != null) {
                    uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
                }
            }
        });
    }

    /**
     * 设备定位
     */
    private void uniGetDeviceFind(String type, Object data, String TopicApi, DCUniMPJSCallback callback) {
        String mac = getKeyValue("mac", getKeyValue("data", data));
        JsonObject jObject = new JsonObject();
        String attribute_data = getKeyValue("attribute_data", getKeyValue("data", data));
        if (!TextUtils.isEmpty(attribute_data)) {
            try {
                jObject = new Gson().fromJson(attribute_data, JsonObject.class);
            } catch (Exception ignored) {
                jObject = new JsonObject();
            }
        }
        TcpClient.getInstance().sendDataToLinkGateway(mac, false, TopicApi, jObject, "", new HDLLinkCallBack() {
            @Override
            public void onSuccess(String s) {
                if (callback != null) {
                    try {
                        if (s.startsWith("{")) {
                            uniSuccessCallback(type, new Gson().fromJson(s, JsonObject.class), callback);
                        } else if (s.startsWith("[")) {
                            uniSuccessCallback(type, new Gson().fromJson(s, JsonArray.class), callback);
                        } else {
                            uniSuccessCallback(type, s, callback);
                        }
                    } catch (Exception e) {
                        uniSuccessCallback(type, s, callback);
                    }
                }
            }

            @Override
            public void onError(HDLLinkException e) {
                if (callback != null) {
                    uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
                }
@@ -1003,6 +1376,7 @@
                        jsonObject.addProperty("homeId", houseIdBean.getHomeId());
                        jsonObject.addProperty("homeName", houseIdBean.getHomeName());
                        jsonObject.addProperty("powerStationStatus", houseIdBean.getPowerStationStatus() + "");
                        jsonObject.addProperty("powerStationType", houseIdBean.getPowerStationType());
                        HDLUniMP.UniCallBackBaseBean uniCallBackBaseBean = new HDLUniMP.UniCallBackBaseBean();
                        uniCallBackBaseBean.setType(HDLUniMP.UNI_EVENT_NOTIFICATION_DEVICE_REFRESH_DETAILS);
                        uniCallBackBaseBean.setData(jsonObject);
@@ -1652,32 +2026,11 @@
                    });
                } else {
                    HdlLogLogic.print("在线升级---", true);
                    //远程升级需要检测在逆变器有没有连接上云
                    HdlDeviceLogic.getInstance().checkInverterConnectedCloud(homeId, deviceMac, new CloudCallBeak<CloudInverterDeviceBean>() {
                    //2026年03月31日14:59:10 云端会校验设备状态
                    HdlOtaLogic.getInstance().upgradeDeviceFirmware(deviceOidId, firmwareVersionId, new CloudCallBeak<Boolean>() {
                        @Override
                        public void onSuccess(CloudInverterDeviceBean cloudInverterDeviceBean) {
                            //1：连接中,2：故障,3：运行,4：离线,6:逆变器连不上云(自定义)
                            if (cloudInverterDeviceBean == null) {
                                uniCallbackData(type, null, 6, HDLApp.getInstance().getAppLocaleContext().getString(R.string.ota_binding_cloud_upgrade_fails), callback);
                                return;
                            }
                            if (cloudInverterDeviceBean.getDeviceStatus() != 3) {
                                uniCallbackData(type, null, cloudInverterDeviceBean.getDeviceStatus(), HDLApp.getInstance().getAppLocaleContext().getString(R.string.ota_not_cloud_upgrade_fails), callback);
                                return;
                            }
                            //4:运行
                            HdlOtaLogic.getInstance().upgradeDeviceFirmware(deviceOidId, firmwareVersionId, new CloudCallBeak<Boolean>() {
                                @Override
                                public void onSuccess(Boolean obj) {
                                    uniSuccessCallback(type, obj, callback);
                                }

                                @Override
                                public void onFailure(HDLException e) {
                                    uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
                                }
                            });

                        public void onSuccess(Boolean obj) {
                            uniSuccessCallback(type, obj, callback);
                        }

                        @Override
@@ -1685,38 +2038,50 @@
                            uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
                        }
                    });
//                    //远程升级需要检测在逆变器有没有连接上云
//                    HdlDeviceLogic.getInstance().checkInverterConnectedCloud(homeId, deviceMac, plantType, new CloudCallBeak<CloudInverterDeviceBean>() {
//                        @Override
//                        public void onSuccess(CloudInverterDeviceBean cloudInverterDeviceBean) {
//                            //1：连接中,2：故障,3：运行,4：离线,6:逆变器连不上云(自定义)
//                            if (cloudInverterDeviceBean == null) {
//                                uniCallbackData(type, null, 6, HDLApp.getInstance().getAppLocaleContext().getString(R.string.ota_binding_cloud_upgrade_fails), callback);
//                                return;
//                            }
//                            if (cloudInverterDeviceBean.getDeviceStatus() == 1 || cloudInverterDeviceBean.getDeviceStatus() == 4) {
//                                uniCallbackData(type, null, cloudInverterDeviceBean.getDeviceStatus(), HDLApp.getInstance().getAppLocaleContext().getString(R.string.ota_not_cloud_upgrade_fails), callback);
//                                return;
//                            }
//                            //4:运行
//                            HdlOtaLogic.getInstance().upgradeDeviceFirmware(deviceOidId, firmwareVersionId, new CloudCallBeak<Boolean>() {
//                                @Override
//                                public void onSuccess(Boolean obj) {
//                                    uniSuccessCallback(type, obj, callback);
//                                }
//
//                                @Override
//                                public void onFailure(HDLException e) {
//                                    uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
//                                }
//                            });
//
//                        }
//
//                        @Override
//                        public void onFailure(HDLException e) {
//                            uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
//                        }
//                    });
                }
            }

            @Override
            public void onFailure(HDLException e) {
                HdlLogLogic.print("在线升级---", true);
                //远程升级需要检测在逆变器有没有连接上云
                HdlDeviceLogic.getInstance().checkInverterConnectedCloud(homeId, deviceMac, new CloudCallBeak<CloudInverterDeviceBean>() {
                //2026年03月31日14:59:10 云端会校验设备状态
                HdlOtaLogic.getInstance().upgradeDeviceFirmware(deviceOidId, firmwareVersionId, new CloudCallBeak<Boolean>() {
                    @Override
                    public void onSuccess(CloudInverterDeviceBean cloudInverterDeviceBean) {
                        //1：连接中,2：故障,3：运行,4：离线,6:逆变器连不上云(自定义)
                        if (cloudInverterDeviceBean == null) {
                            uniCallbackData(type, null, 6, HDLApp.getInstance().getAppLocaleContext().getString(R.string.ota_binding_cloud_upgrade_fails), callback);
                            return;
                        }
                        if (cloudInverterDeviceBean.getDeviceStatus() != 3) {
                            uniCallbackData(type, null, cloudInverterDeviceBean.getDeviceStatus(), HDLApp.getInstance().getAppLocaleContext().getString(R.string.ota_not_cloud_upgrade_fails), callback);
                            return;
                        }
                        //4:运行
                        HdlOtaLogic.getInstance().upgradeDeviceFirmware(deviceOidId, firmwareVersionId, new CloudCallBeak<Boolean>() {
                            @Override
                            public void onSuccess(Boolean obj) {
                                uniSuccessCallback(type, obj, callback);
                            }

                            @Override
                            public void onFailure(HDLException e) {
                                uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
                            }
                        });

                    public void onSuccess(Boolean obj) {
                        uniSuccessCallback(type, obj, callback);
                    }

                    @Override
@@ -1724,6 +2089,39 @@
                        uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
                    }
                });
//                //远程升级需要检测在逆变器有没有连接上云
//                HdlDeviceLogic.getInstance().checkInverterConnectedCloud(homeId, deviceMac, plantType, new CloudCallBeak<CloudInverterDeviceBean>() {
//                    @Override
//                    public void onSuccess(CloudInverterDeviceBean cloudInverterDeviceBean) {
//                        //1：连接中,2：故障,3：运行,4：离线,6:逆变器连不上云(自定义)
//                        if (cloudInverterDeviceBean == null) {
//                            uniCallbackData(type, null, 6, HDLApp.getInstance().getAppLocaleContext().getString(R.string.ota_binding_cloud_upgrade_fails), callback);
//                            return;
//                        }
//                        if (cloudInverterDeviceBean.getDeviceStatus() == 1 || cloudInverterDeviceBean.getDeviceStatus() == 4) {
//                            uniCallbackData(type, null, cloudInverterDeviceBean.getDeviceStatus(), HDLApp.getInstance().getAppLocaleContext().getString(R.string.ota_not_cloud_upgrade_fails), callback);
//                            return;
//                        }
//                        //4:运行
//                        HdlOtaLogic.getInstance().upgradeDeviceFirmware(deviceOidId, firmwareVersionId, new CloudCallBeak<Boolean>() {
//                            @Override
//                            public void onSuccess(Boolean obj) {
//                                uniSuccessCallback(type, obj, callback);
//                            }
//
//                            @Override
//                            public void onFailure(HDLException e) {
//                                uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
//                            }
//                        });
//
//                    }
//
//                    @Override
//                    public void onFailure(HDLException e) {
//                        uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
//                    }
//                });
            }
        });

@@ -1775,7 +2173,7 @@
    private void uniGetLocalDrivers(String type, Object data, DCUniMPJSCallback callback) {
        try {
            String driveCode = getKeyValue("driveCode", getKeyValue("data", data));//驱动编号或驱动名称
//            String osImageId = getKeyValue("osImageId", getKeyValue("data", data));//驱动类型id
            String imageId = getKeyValue("imageId", getKeyValue("data", data));//驱动镜像Id
//            String driverVersionId = getKeyValue("driverVersionId", getKeyValue("data", data));//驱动类型id
            List<GatewayDriverBean> list = new ArrayList<>();
            String driverFileList = HdlFileLogic.getInstance().getDriveRootPath();
@@ -1783,14 +2181,15 @@
            if (file.list() != null) {
                for (int i = 0; i < Objects.requireNonNull(file.list()).length; i++) {
                    String fileName = Objects.requireNonNull(file.list())[i];
                    if (!fileName.contains(driveCode)) {
                    if (!fileName.contains(driveCode + "_" + imageId)) {
                        continue;
                    }
                    String[] driverInfoAry = fileName.split("_");
                    GatewayDriverBean gatewayDriverBean = new GatewayDriverBean();
                    gatewayDriverBean.setDriverCode(driverInfoAry[0]);
                    gatewayDriverBean.setVersion(driverInfoAry[1].replace(".zip", ""));
                    gatewayDriverBean.setLocalUrl(HdlFileLogic.getInstance().getDrivePathFileName(gatewayDriverBean.getDriverCode(), gatewayDriverBean.getVersion()));
                    gatewayDriverBean.setImageId(driverInfoAry[1]);
                    gatewayDriverBean.setVersion(driverInfoAry[2].replace(".zip", ""));
                    gatewayDriverBean.setLocalUrl(HdlFileLogic.getInstance().getDrivePathFileName(gatewayDriverBean.getDriverCode(), gatewayDriverBean.getImageId(), gatewayDriverBean.getVersion()));
                    list.add(gatewayDriverBean);
                }
            }
@@ -1810,7 +2209,7 @@

//        String deviceOid = getKeyValue("oid", getKeyValue("data", data));//逆变器设备oid
        String driverCode = getKeyValue("driverCode", getKeyValue("data", data));//驱动编码
//        String imageId = getKeyValue("imageId", getKeyValue("data", data));//驱动镜像id
        String imageId = getKeyValue("imageId", getKeyValue("data", data));//驱动镜像id
        String version = getKeyValue("version", getKeyValue("data", data));//驱动版本
//        String driverVersionId = getKeyValue("driverVersionId", getKeyValue("data", data));//驱动版本id
        String localUrl = getKeyValue("localUrl", getKeyValue("data", data));//储存在本地驱动文件路径
@@ -1823,7 +2222,7 @@
                    @Override
                    public void run() {

                        String drivePathFileName = HdlFileLogic.getInstance().getDrivePathFileName(driverCode, version);
                        String drivePathFileName = HdlFileLogic.getInstance().getDrivePathFileName(driverCode, imageId, version);
                        //不在子线程读流会卡死主线程
                        boolean isBoolean = HdlOtaLogic.getInstance().disposeDownLoadFile(drivePathFileName, responseBody, md5, HdlOtaLogic.driver_type);
                        if (isBoolean) {
@@ -1854,6 +2253,7 @@
    private void uniUpgradeGatewayDriver(String type, Object data, DCUniMPJSCallback callback) {

        String homeId = UserConfigManage.getInstance().getHomeId();
        String plantType = getKeyValue("plantType", getKeyValue("data", data));
        String deviceMac = getKeyValue("mac", getKeyValue("data", data));//逆变器设备mac（查找socket）
        String deviceOid = getKeyValue("oid", getKeyValue("data", data));//逆变器设备oid
        String driverVersionId = getKeyValue("driverVersionId", getKeyValue("data", data));//驱动版本id
@@ -1875,7 +2275,7 @@
                        @Override
                        public void onServiceConnected(ComponentName name, IBinder service) {
                            //本地升级驱动文件路径
                            String drivePathFileName = HdlFileLogic.getInstance().getDrivePathFileName(driverCode, version);
                            String drivePathFileName = HdlFileLogic.getInstance().getDrivePathFileName(driverCode, imageId, version);
                            byte[] data = HdlFileLogic.getInstance().readFileByte(drivePathFileName);
                            if (data == null || data.length == 0) {
                                uniCallbackData(type, null, -2, HDLApp.getInstance().getAppLocaleContext().getString(R.string.found_locally_drive_file), callback);
@@ -1905,32 +2305,11 @@
                    });
                } else {
                    HdlLogLogic.print("在线升级---", true);
                    //远程升级需要【检测】在逆变器有没有连接上云
                    HdlDeviceLogic.getInstance().checkInverterConnectedCloud(homeId, deviceMac, new CloudCallBeak<CloudInverterDeviceBean>() {
                    //2026年03月31日14:59:10 云端会校验设备状态
                    HdlOtaLogic.getInstance().upgradeGatewayDriver(deviceOid, driverVersionId, new CloudCallBeak<Boolean>() {
                        @Override
                        public void onSuccess(CloudInverterDeviceBean cloudInverterDeviceBean) {
                            //1：连接中,2：故障,3：运行,4：离线,6:逆变器连不上云(自定义)
                            if (cloudInverterDeviceBean == null) {
                                uniCallbackData(type, null, 6, HDLApp.getInstance().getAppLocaleContext().getString(R.string.ota_binding_cloud_upgrade_fails), callback);
                                return;
                            }
                            if (cloudInverterDeviceBean.getDeviceStatus() != 3) {
                                uniCallbackData(type, null, cloudInverterDeviceBean.getDeviceStatus(), HDLApp.getInstance().getAppLocaleContext().getString(R.string.ota_not_cloud_upgrade_fails), callback);
                                return;
                            }
                            //4:运行
                            HdlOtaLogic.getInstance().upgradeGatewayDriver(deviceOid, driverVersionId, new CloudCallBeak<Boolean>() {
                                @Override
                                public void onSuccess(Boolean obj) {
                                    uniSuccessCallback(type, obj, callback);
                                }

                                @Override
                                public void onFailure(HDLException e) {
                                    uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
                                }
                            });

                        public void onSuccess(Boolean obj) {
                            uniSuccessCallback(type, obj, callback);
                        }

                        @Override
@@ -1938,38 +2317,50 @@
                            uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
                        }
                    });
//                    //远程升级需要【检测】在逆变器有没有连接上云
//                    HdlDeviceLogic.getInstance().checkInverterConnectedCloud(homeId, deviceMac, plantType, new CloudCallBeak<CloudInverterDeviceBean>() {
//                        @Override
//                        public void onSuccess(CloudInverterDeviceBean cloudInverterDeviceBean) {
//                            //1：连接中,2：故障,3：运行,4：离线,6:逆变器连不上云(自定义)
//                            if (cloudInverterDeviceBean == null) {
//                                uniCallbackData(type, null, 6, HDLApp.getInstance().getAppLocaleContext().getString(R.string.ota_binding_cloud_upgrade_fails), callback);
//                                return;
//                            }
//                            if (cloudInverterDeviceBean.getDeviceStatus() == 1 || cloudInverterDeviceBean.getDeviceStatus() == 4) {
//                                uniCallbackData(type, null, cloudInverterDeviceBean.getDeviceStatus(), HDLApp.getInstance().getAppLocaleContext().getString(R.string.ota_not_cloud_upgrade_fails), callback);
//                                return;
//                            }
//                            //4:运行
//                            HdlOtaLogic.getInstance().upgradeGatewayDriver(deviceOid, driverVersionId, new CloudCallBeak<Boolean>() {
//                                @Override
//                                public void onSuccess(Boolean obj) {
//                                    uniSuccessCallback(type, obj, callback);
//                                }
//
//                                @Override
//                                public void onFailure(HDLException e) {
//                                    uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
//                                }
//                            });
//
//                        }
//
//                        @Override
//                        public void onFailure(HDLException e) {
//                            uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
//                        }
//                    });
                }
            }

            @Override
            public void onFailure(HDLException e) {
                HdlLogLogic.print("在线升级---", true);
                //远程升级需要【检测】在逆变器有没有连接上云
                HdlDeviceLogic.getInstance().checkInverterConnectedCloud(homeId, deviceMac, new CloudCallBeak<CloudInverterDeviceBean>() {
                //2026年03月31日14:59:10 云端会校验设备状态
                HdlOtaLogic.getInstance().upgradeGatewayDriver(deviceOid, driverVersionId, new CloudCallBeak<Boolean>() {
                    @Override
                    public void onSuccess(CloudInverterDeviceBean cloudInverterDeviceBean) {
                        //1：连接中,2：故障,3：运行,4：离线,6:逆变器连不上云(自定义)
                        if (cloudInverterDeviceBean == null) {
                            uniCallbackData(type, null, 6, HDLApp.getInstance().getAppLocaleContext().getString(R.string.ota_binding_cloud_upgrade_fails), callback);
                            return;
                        }
                        if (cloudInverterDeviceBean.getDeviceStatus() != 3) {
                            uniCallbackData(type, null, cloudInverterDeviceBean.getDeviceStatus(), HDLApp.getInstance().getAppLocaleContext().getString(R.string.ota_not_cloud_upgrade_fails), callback);
                            return;
                        }
                        //4:运行
                        HdlOtaLogic.getInstance().upgradeGatewayDriver(deviceOid, driverVersionId, new CloudCallBeak<Boolean>() {
                            @Override
                            public void onSuccess(Boolean obj) {
                                uniSuccessCallback(type, obj, callback);
                            }

                            @Override
                            public void onFailure(HDLException e) {
                                uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
                            }
                        });

                    public void onSuccess(Boolean obj) {
                        uniSuccessCallback(type, obj, callback);
                    }

                    @Override
@@ -1977,6 +2368,39 @@
                        uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
                    }
                });
//                //远程升级需要【检测】在逆变器有没有连接上云
//                HdlDeviceLogic.getInstance().checkInverterConnectedCloud(homeId, deviceMac, plantType, new CloudCallBeak<CloudInverterDeviceBean>() {
//                    @Override
//                    public void onSuccess(CloudInverterDeviceBean cloudInverterDeviceBean) {
//                        //1：连接中,2：故障,3：运行,4：离线,6:逆变器连不上云(自定义)
//                        if (cloudInverterDeviceBean == null) {
//                            uniCallbackData(type, null, 6, HDLApp.getInstance().getAppLocaleContext().getString(R.string.ota_binding_cloud_upgrade_fails), callback);
//                            return;
//                        }
//                        if (cloudInverterDeviceBean.getDeviceStatus() == 1 || cloudInverterDeviceBean.getDeviceStatus() == 4) {
//                            uniCallbackData(type, null, cloudInverterDeviceBean.getDeviceStatus(), HDLApp.getInstance().getAppLocaleContext().getString(R.string.ota_not_cloud_upgrade_fails), callback);
//                            return;
//                        }
//                        //4:运行
//                        HdlOtaLogic.getInstance().upgradeGatewayDriver(deviceOid, driverVersionId, new CloudCallBeak<Boolean>() {
//                            @Override
//                            public void onSuccess(Boolean obj) {
//                                uniSuccessCallback(type, obj, callback);
//                            }
//
//                            @Override
//                            public void onFailure(HDLException e) {
//                                uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
//                            }
//                        });
//
//                    }
//
//                    @Override
//                    public void onFailure(HDLException e) {
//                        uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
//                    }
//                });
            }
        });

@@ -2469,8 +2893,9 @@
     */
    private void uniGetCurrentHomeLocalAndCloudGatewayList(String type, Object data, DCUniMPJSCallback callback) {
        String homeId = getKeyValue("homeId", getKeyValue("data", data));
        String plantType = getKeyValue("plantType", getKeyValue("data", data));
//        UserConfigManage.getInstance().setHomeId(homeId);
        HdlDeviceLogic.getInstance().getCurrentHomeLocalAndCloudGatewayList(homeId, new CloudCallBeak<List<GatewayBean>>() {
        HdlDeviceLogic.getInstance().getCurrentHomeLocalAndCloudGatewayList(homeId, plantType, new CloudCallBeak<List<GatewayBean>>() {
            @Override
            public void onSuccess(List<GatewayBean> list) {
                List<GatewayBean> newList = sortLogic(list);
@@ -2509,14 +2934,25 @@
        }
        List<GatewayBean> newList = new ArrayList<>();
        List<GatewayBean> inverterList = new ArrayList<>();
        List<GatewayBean> inverterUnactivatedList = new ArrayList<>();
        List<GatewayBean> lcList = new ArrayList<>();
        for (int i = 0; i < list.size(); i++) {
            if (list.get(i).getSpk().equals(HdlDeviceLogic.getInstance().INVERTER_DEVICE_SPK)) {
                inverterList.add(list.get(i));
            GatewayBean gatewayBean = list.get(i);
            if (gatewayBean == null) {
                continue;
            }
            if (gatewayBean.isActivate()) {
                if (gatewayBean.getSpk().equals(HdlDeviceLogic.getInstance().INVERTER_DEVICE_SPK)
                        || gatewayBean.getSpk().equals(HdlDeviceLogic.getInstance().OFF_INVERTER_OG_SPK)) {
                    inverterList.add(gatewayBean);
                } else {
                    lcList.add(gatewayBean);
                }
            } else {
                lcList.add(list.get(i));
                inverterUnactivatedList.add(gatewayBean);
            }
        }
        newList.addAll(inverterUnactivatedList);
        newList.addAll(inverterList);
        newList.addAll(lcList);
        return newList;
@@ -2722,6 +3158,7 @@
                    inverterDeviceBean.setDeviceStatus(gatewayBean.getDeviceStatus());
                    inverterDeviceBean.setSpk(gatewayBean.getSpk());
                    inverterDeviceBean.setDeviceType(gatewayBean.getDeviceType());
                    inverterDeviceBean.setActivate(gatewayBean.isActivate());
                    newList.add(inverterDeviceBean);
                }
            }
@@ -2881,6 +3318,28 @@
        });
    }

    /**
     * 设备清空运行数据
     *
     * @param type     类型
     * @param data     uni请求数据
     * @param callback uni回调
     */
    public void uniDeviceClearData(String type, Object data, DCUniMPJSCallback callback) {
        String mac = getKeyValue("mac", getKeyValue("data", data));
        HdlDeviceLogic.getInstance().DeviceClearData(mac, new LinkCallBack<Boolean>() {
            @Override
            public void onSuccess(Boolean obj) {
                uniSuccessCallback(type, obj, callback);
            }

            @Override
            public void onError(HDLLinkException e) {
                uniCallbackData(type, null, e.getCode(), e.getMsg(), callback);
            }
        });
    }


    /**
     * 发送modbus协议数据
@@ -2965,6 +3424,7 @@
//                data.put("appSecret", AppConfigManage.getAppSecret());
//            }
            data.put("appLanguage", UserConfigManage.getInstance().getCurrentAppLanguage());
            data.put("tourist_mode", UserConfigManage.getInstance().isTourist_mode());
            uniCallBackBaseBean.setData(data);
            return getJSONObject(uniCallBackBaseBean);
        } catch (Exception e) {