2026年03月24日16:03:57

wjc

2026-03-24 c4ae4589c6c001329ebb731589b209e8ddcbf7ca

 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;
@@ -39,6 +42,7 @@
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;
@@ -47,7 +51,9 @@
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;
@@ -70,8 +76,10 @@
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;
@@ -851,7 +859,6 @@
                    //设备定位
                    case HDLUniMP.UNI_EVENT_REPLY_OTHER_GET_DEVICE_LOCATION: {
                        this.uniGetDeviceFind(mode_type, data, TopicApi.DELETING_GATEWAY_FIND, callback);
                        ;
                    }
                    break;
                }
@@ -938,6 +945,173 @@
                    }
                });

            } 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;
                }

            }

        } catch (Exception e) {
@@ -946,6 +1120,62 @@

    }

    /**
     * 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指定页面
@@ -968,6 +1198,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);
@@ -1862,7 +2093,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();
@@ -1870,14 +2101,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);
                }
            }
@@ -1897,7 +2129,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));//储存在本地驱动文件路径
@@ -1910,7 +2142,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) {
@@ -1962,7 +2194,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);
@@ -2556,8 +2788,13 @@
     */
    private void uniGetCurrentHomeLocalAndCloudGatewayList(String type, Object data, DCUniMPJSCallback callback) {
        String homeId = getKeyValue("homeId", getKeyValue("data", data));
        String plantType = getKeyValue("plantType", getKeyValue("data", data));
        if (plantType.equals("bms")) {
            plantType = PowerStationType.BMS;
        }
//        plantType = PowerStationType.BMS;//模拟测试
//        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);
@@ -3086,6 +3323,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) {