~wjc/HDLPhotovoltaicDebugAPP.git

			@@ -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,34 +41,45 @@
			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;
			import com.hdl.photovoltaic.internet.api.TopicApi;
			import com.hdl.photovoltaic.listener.CloudCallBeak;
			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.HouseInfoBean;
			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;
			import com.hdl.photovoltaic.ui.bean.StaffBean;
			import com.hdl.photovoltaic.ui.bean.UnCountBean;
			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.newC.MessageCenterList;
			import com.hdl.photovoltaic.ui.newC.PowerStationsListEdit;
			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;
			@@ -80,7 +94,6 @@
			import com.hdl.sdk.link.gateway.HDLLinkLocalGateway;

			import org.greenrobot.eventbus.EventBus;
			import org.json.JSONArray;
			import org.json.JSONObject;


			@@ -147,7 +160,7 @@
			String type = getKeyValue("type", data);//小类
			String logTag = getKeyValue("logTag", data);//标记uni指令
			String mode_type = "大类-" + topic + "---" + "小类-" + type;//用来打印的
			HdlLogLogic.print(logTag + ":" + "uni---发送---" + mode_type + "\r\n" + data, true);
			HdlLogLogic.print(logTag + ":" + "uni---发送---" + mode_type + "---" + data, true);
			if (HDLUniMP.UNI_EVENT_REPLY_USER_MODEL.equals(topic)) {
			//用户模块
			switch (type) {
			@@ -167,7 +180,7 @@
			jsonObject.addProperty("user_name", UserConfigManage.getInstance().getUserName());
			jsonObject.addProperty("user_image_url", UserConfigManage.getInstance().getUserImageUrl());
			jsonObject.addProperty("user_account", UserConfigManage.getInstance().getAccount());

			jsonObject.addProperty("appLanguage", UserConfigManage.getInstance().getCurrentAppLanguage());
			jsonObject.addProperty("token", HDLLinkPMUser.getInstance().getAccessToken());
			jsonObject.addProperty("refreshToken", HDLLinkPMUser.getInstance().getRefreshToken());
			if (TextUtils.isEmpty(AppConfigManage.getUserRegionUrl())) {
			@@ -177,7 +190,7 @@
			jsonObject.addProperty("appKey", AppConfigManage.getAppKey());
			jsonObject.addProperty("appSecret", AppConfigManage.getAppSecret());
			uniSuccessCallback(mode_type, jsonObject, callback);
			HdlLogLogic.print("获取用户本地缓存信息---->>>" + jsonObject.toString());
			HdlLogLogic.print("获取用户本地缓存信息----" + jsonObject.toString());
			}
			break;
			}
			@@ -205,8 +218,22 @@
			break;
			//创建电站
			case HDLUniMP.UNI_EVENT_REPLY_HOME_CREATION: {
			//uin创建电站成功后通知
			// HdlResidenceLogic.getInstance().getResidenceIdList("","","","","","",1,50,null);
			try {
			String dataJsonStr = getKeyValue("data", data);
			if (!TextUtils.isEmpty(dataJsonStr)) {
			Gson gson = new Gson();
			HouseIdBean houseIdBean = gson.fromJson(dataJsonStr, HouseIdBean.class);
			HdlResidenceLogic.getInstance().switchHouse(houseIdBean, true);
			}
			HdlLogLogic.print("uin创建电站成功后通知---" + dataJsonStr, true);
			} catch (Exception e) {
			HdlLogLogic.print("uin创建电站成功后通知---" + e.getMessage(), true);
			}

			//EventBus事件分发
			HdlCommonLogic.getInstance().postEventBus(HDLUniMP.UNI_EVENT_REPLY_HOME_MODEL, HDLUniMP.UNI_EVENT_REPLY_HOME_CREATION, getKeyValue("data", data));
			// HdlCommonLogic.getInstance().postEventBusSticky(HDLUniMP.UNI_EVENT_REPLY_HOME_MODEL, HDLUniMP.UNI_EVENT_REPLY_HOME_CREATION, getKeyValue("data", data));
			if (callback != null) {
			uniSuccessCallback(type, null, callback);
			}
			@@ -380,12 +407,32 @@
			this.uniGetGatewayInfo(mode_type, data, callback);
			}
			break;
			//删除BMS/电池包
			case HDLUniMP.UNI_EVENT_REPLY_DEVICE_del_oid: {
			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)) {
			WifiUtils wifiUtils = WifiUtils.getInstance();
			//wifi模块
			switch (type) {
			//获取位置权限
			case HDLUniMP.UNI_EVENT_REPLY_AUTHORIZATION_GET: {
			boolean isLocalAuthor = PermissionUtils.checkPermission(HDLApp.getInstance(), Manifest.permission.ACCESS_FINE_LOCATION);
			if (callback != null) {
			JsonObject jsonObject = new JsonObject();
			jsonObject.addProperty("localAuthor", isLocalAuthor);
			uniSuccessCallback(mode_type, jsonObject, callback);
			}
			}
			break;
			//获取手机wifi列表
			case HDLUniMP.UNI_EVENT_REPLY_PHONE_WIFI_LIST: {
			if (callback != null) {
			@@ -428,7 +475,10 @@
			break;
			//逆变器以太网配置
			case HDLUniMP.UNI_EVENT_REPLY_DEVICE_ETHERNET_SET: {
			uniGetAndSetNetwork(mode_type, data, TopicApi.DELETING_GATEWAY_ETHERNET_EDIT, callback);
			if (callback != null) {
			uniSuccessCallback(type, "", callback);
			}
			//uniGetAndSetNetwork(mode_type, data, TopicApi.DELETING_GATEWAY_ETHERNET_EDIT, callback);
			}
			break;
			//逆变器以太网获取
			@@ -533,7 +583,7 @@
			case HDLUniMP.UNI_EVENT_REPLY_MINE_SELECTED_POWERSTATION: {
			Intent intent = new Intent();
			intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
			intent.setClass(HDLApp.getInstance(), PowerStationsListEdit.class);
			intent.setClass(HDLApp.getInstance(), PowerStationsListActivity.class);
			HDLApp.getInstance().startActivity(intent);
			}
			break;
			@@ -543,7 +593,7 @@
			String isShowFault = getKeyValue("isShowFault", getKeyValue("data", data));
			Intent intent = new Intent();
			intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
			intent.setClass(HDLApp.getInstance(), MessageCenterList.class);
			intent.setClass(HDLApp.getInstance(), MessageCenterListActivity.class);
			if (!TextUtils.isEmpty(homeId)) {
			intent.putExtra("homeId", homeId);
			}
			@@ -635,12 +685,36 @@

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


			}
			} else if (HDLUniMP.UNI_EVENT_REPLY_OTHER_MODEL.equals(topic)) {
			//其它模块
			switch (type) {

			//获取温度单位
			case HDLUniMP.UNI_EVENT_REPLY_OTHER_UNIT: {
			uniSuccessCallback(mode_type, UserConfigManage.getInstance().getTemperature_unit(), callback);
			@@ -679,7 +753,9 @@
			break;
			//uni通知原生退出登录
			case HDLUniMP.UNI_EVENT_REPLY_OTHER_LOGOUT: {
			HDLLinkPMUser.getInstance().logout(0);
			HdlLogLogic.print("uni通知原生退出登录---", true);
			// HDLLinkPMUser.getInstance().logout(0);
			HdlAccountLogic.getInstance().logout(LogoutType.NormalLogout);
			}
			break;
			//本地密钥获取
			@@ -717,19 +793,21 @@
			break;
			//本地json资源文件获取
			case HDLUniMP.UNI_EVENT_REPLY_OTHER_GET_LOCAL_JSON: {
			String url = getKeyValue("url", getKeyValue("data", data));
			String deviceModel = getKeyValue("deviceModel", getKeyValue("data", data));
			// String url = getKeyValue("url", getKeyValue("data", data));
			String fileName = getKeyValue("fileName", getKeyValue("data", data));//唯一标识
			String deviceType = getKeyValue("deviceType", getKeyValue("data", data));//设备类型
			String deviceModel = getKeyValue("deviceModel", getKeyValue("data", data));//设备模型
			String language = getKeyValue("language", getKeyValue("data", data));
			String json = HdlESLocalJsonLogic.getInstance().readHdlESLocalJson(url, deviceModel);
			String json = HdlESLocalJsonLogic.getInstance().readHdlESLocalJson(fileName + ".json", deviceModel);
			if (TextUtils.isEmpty(json)) {
			//本地没有缓存
			HdlESLocalJsonLogic.getInstance().getHdlESLocalJson(url, deviceModel, new CloudCallBeak<String>() {
			HdlESLocalJsonLogic.getInstance().getHdlESLocalJson(fileName, deviceType, deviceModel, false, new CloudCallBeak<String>() {
			@Override
			public void onSuccess(String obj) {
			// if (callback != null) {
			// uniSuccessCallback(type, obj, callback);
			// }
			String s = HdlESLocalJsonLogic.getInstance().readHdlESLocalJson(url, deviceModel);
			String s = HdlESLocalJsonLogic.getInstance().readHdlESLocalJson(fileName, deviceModel);
			//本地缓存数据
			if (callback != null) {
			try {
			@@ -738,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);
			}
			}
			}
			@@ -762,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));
			@@ -773,31 +851,277 @@
			}
			}
			break;
			//uni获取图片
			case HDLUniMP.UNI_EVENT_REPLY_OTHER_GET_SELECTED_IMAGE: {

			}
			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_COMMON_MODEL.equals(topic)) {
			//网络请求模块
			if (type.equals(HDLUniMP.UNI_EVENT_REPLY_UNI_SEND_TO_CLOUD)) {
			String url = getKeyValue("url", getKeyValue("data", data));
			JsonObject jObject = new JsonObject();
			String body = getKeyValue("body", getKeyValue("data", data));
			if (!TextUtils.isEmpty(body)) {
			} else if (HDLUniMP.UNI_EVENT_REPLY_NO_WORK_MODEL.equals(topic)) {
			//无网模式
			switch (type) {
			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()) {
			HDLUniMPSDKManager.getInstance().getUniMP().closeUniMP();
			}
			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: {
			try {
			jObject = new Gson().fromJson(body, JsonObject.class);
			} catch (Exception ignored) {
			//进入无网模式逆变器详情页，缓存mac和密码
			String mac = getKeyValue("mac", getKeyValue("data", data));
			String password = getKeyValue("password", getKeyValue("data", data));
			UserConfigManage.getInstance().setNoNetworkDeviceMac(mac);
			UserConfigManage.getInstance().setNoNetworkPassword(password);
			UserConfigManage.getInstance().Save();
			uniSuccessCallback(mode_type, true, callback);
			} catch (Exception e) {
			uniSuccessCallback(mode_type, e, callback);
			}
			}
			HttpClient.getInstance().requestHttp(url, jObject.toString(), new CloudCallBeak<String>() {
			@Override
			public void onSuccess(String jsonStr) {
			uniSuccessCallback(mode_type, jsonStr, callback);
			}

			@Override
			public void onFailure(HDLException e) {
			uniExceptionCallback(mode_type, e, callback);
			}
			});
			break;
			case HDLUniMP.UNI_EVENT_REPLY_NO_WORK_MODEL_CLEAR_DEVICE_INFO: {
			//无网模式逆变器详情页，清除缓存mac和密码
			UserConfigManage.getInstance().setNoNetworkDeviceMac("");
			UserConfigManage.getInstance().setNoNetworkPassword("");
			UserConfigManage.getInstance().setNoNetworkFlag(false);
			UserConfigManage.getInstance().Save();
			uniSuccessCallback(mode_type, true, callback);
			}
			break;
			}
			} else if (HDLUniMP.UNI_EVENT_REPLY_UNI_SEND_TO_CLOUD.equals(topic)) {
			//网络请求模块
			JsonObject jObject = new JsonObject();
			String body = getKeyValue("data", data);
			if (!TextUtils.isEmpty(body)) {
			try {
			jObject = new Gson().fromJson(body, JsonObject.class);
			} catch (Exception e) {
			uniSuccessCallback(mode_type, e, callback);
			}
			}
			HttpClient.getInstance().requestHttp(type, jObject.toString(), new CloudCallBeak<String>() {
			@Override
			public void onSuccess(String jsonStr) {
			//本地缓存数据
			if (callback != null) {
			try {
			if (jsonStr.startsWith("{")) {
			uniSuccessCallback(mode_type, new Gson().fromJson(jsonStr, JsonObject.class), callback);
			} else if (jsonStr.startsWith("[")) {
			uniSuccessCallback(mode_type, new Gson().fromJson(jsonStr, JsonArray.class), callback);
			} else {
			uniSuccessCallback(mode_type, jsonStr, callback);
			}
			} catch (Exception e) {
			uniSuccessCallback(mode_type, jsonStr, callback);
			}
			}
			}

			@Override
			public void onFailure(HDLException e) {
			uniExceptionCallback(mode_type, e, callback);
			}
			});

			} 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) {
			@@ -806,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指定页面
			@@ -828,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);
			@@ -862,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);
			}
			@@ -909,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);
			@@ -1002,9 +1470,8 @@
			public void onSuccess(String obj) {
			try {
			Gson g = new Gson();
			JsonObject jObject = g.fromJson(obj, JsonObject.class);
			String deliveryUrl = jObject.get("deliveryUrl").toString();
			uniSuccessCallback(type, deliveryUrl, callback);
			QrcodeUrlBean qrcodeUrlBean = g.fromJson(obj, QrcodeUrlBean.class);
			uniSuccessCallback(type, qrcodeUrlBean.getDeliveryUrl(), callback);
			} catch (Exception ignored) {
			uniSuccessCallback(type, obj, callback);
			}
			@@ -1288,11 +1755,20 @@
			//解密负载数据(写密钥给网关一定是明文，因为那时网关还没有密钥)
			TcpClient.getInstance().sendDataToLinkGateway(mac, false, TopicApi, jsonArray, "", new HDLLinkCallBack() {
			@Override
			public void onSuccess(String msg) {
			public void onSuccess(String s) {
			if (callback != null) {
			uniSuccessCallback(type, msg, callback);
			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
			@@ -1318,14 +1794,14 @@
			//ACCESS_COARSE_LOCATION 允许使用WIFI热点或基站来获取粗略的定位
			if (ActivityCompat.checkSelfPermission(HDLApp.getInstance(), Manifest.permission.ACCESS_FINE_LOCATION) != PackageManager.PERMISSION_GRANTED && ActivityCompat.checkSelfPermission(HDLApp.getInstance(), Manifest.permission.ACCESS_COARSE_LOCATION) != PackageManager.PERMISSION_GRANTED) {
			geolocation.setResult(-2);
			geolocation.setDes(HDLApp.getInstance().getString(R.string.exception_no_location_information_permission));
			geolocation.setDes(HDLApp.getInstance().getAppLocaleContext().getString(R.string.exception_no_location_information_permission));
			uniSuccessCallback(type, geolocation, callback);
			return;
			}
			// 判断设备是否支持定位功能
			if (!locationManager.isProviderEnabled(LocationManager.GPS_PROVIDER)) {
			geolocation.setResult(-1);
			geolocation.setDes(HDLApp.getInstance().getString(R.string.exception_the_location_function_is_not_enabled));
			geolocation.setDes(HDLApp.getInstance().getAppLocaleContext().getString(R.string.exception_the_location_function_is_not_enabled));
			//todo 提示用户打开定位功能或者引导用户去系统设置页面打开定位功能
			uniSuccessCallback(type, geolocation, callback);
			return;
			@@ -1333,12 +1809,12 @@
			Location location = locationManager.getLastKnownLocation(LocationManager.GPS_PROVIDER);
			if (location == null) {
			geolocation.setResult(-3);
			geolocation.setDes(HDLApp.getInstance().getString(R.string.exception_unable_location_move10_meters_later));
			geolocation.setDes(HDLApp.getInstance().getAppLocaleContext().getString(R.string.exception_unable_location_move10_meters_later));
			uniSuccessCallback(type, geolocation, callback);
			return;
			}
			geolocation.setResult(0);
			geolocation.setDes(HDLApp.getInstance().getString(R.string.succeed));
			geolocation.setDes(HDLApp.getInstance().getAppLocaleContext().getString(R.string.succeed));
			BigDecimal latitude = BigDecimal.valueOf(location.getLatitude());//经度
			BigDecimal longitude = BigDecimal.valueOf(location.getLongitude());//纬度
			double lat = latitude.setScale(6, RoundingMode.HALF_DOWN).doubleValue();
			@@ -1476,9 +1952,9 @@
			}

			if (isBoolean) {
			uniCallbackData(type, null, 0, HDLApp.getInstance().getString(R.string.writing_firmware_upgrade_memory_succeeded), callback);
			uniCallbackData(type, null, 0, HDLApp.getInstance().getAppLocaleContext().getString(R.string.writing_firmware_upgrade_memory_succeeded), callback);
			} else {
			uniCallbackData(type, null, -2, HDLApp.getInstance().getString(R.string.download_firmware_upgrade_file_failed), callback);
			uniCallbackData(type, null, -2, HDLApp.getInstance().getAppLocaleContext().getString(R.string.download_firmware_upgrade_file_failed), callback);
			}
			}
			});
			@@ -1523,7 +1999,7 @@
			String firmwarePathFileName = HdlFileLogic.getInstance().getFirmwarePathFileName(imageId, version);
			byte[] data = HdlFileLogic.getInstance().readFileByte(firmwarePathFileName);
			if (data == null \|\| data.length == 0) {
			uniCallbackData(type, null, -2, HDLApp.getInstance().getString(R.string.found_locally_firmware_upgrade_file), callback);
			uniCallbackData(type, null, -2, HDLApp.getInstance().getAppLocaleContext().getString(R.string.found_locally_firmware_upgrade_file), callback);
			return;
			}
			String md5 = HDLMD5Utils.encodeMD5(data);//网关固件需要
			@@ -1538,44 +2014,23 @@

			@Override
			public void onError(HDLLinkException e) {
			uniCallbackData(type, null, -2, HDLApp.getInstance().getString(R.string.notify_gateway_firmware_upgrade_failed), callback);
			uniCallbackData(type, null, -2, HDLApp.getInstance().getAppLocaleContext().getString(R.string.notify_gateway_firmware_upgrade_failed), callback);
			}
			});
			}

			@Override
			public void onServiceDisconnected(ComponentName name) {
			uniCallbackData(type, null, -2, HDLApp.getInstance().getString(R.string.local_service_fails), callback);
			uniCallbackData(type, null, -2, HDLApp.getInstance().getAppLocaleContext().getString(R.string.local_service_fails), callback);
			}
			});
			} 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().getString(R.string.ota_binding_cloud_upgrade_fails), callback);
			return;
			}
			if (cloudInverterDeviceBean.getDeviceStatus() != 3) {
			uniCallbackData(type, null, cloudInverterDeviceBean.getDeviceStatus(), HDLApp.getInstance().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
			@@ -1583,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().getString(R.string.ota_binding_cloud_upgrade_fails), callback);
			return;
			}
			if (cloudInverterDeviceBean.getDeviceStatus() != 3) {
			uniCallbackData(type, null, cloudInverterDeviceBean.getDeviceStatus(), HDLApp.getInstance().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
			@@ -1622,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);
			// }
			// });
			}
			});

			@@ -1673,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();
			@@ -1681,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);
			}
			}
			@@ -1708,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));//储存在本地驱动文件路径
			@@ -1721,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) {
			@@ -1730,9 +2231,9 @@
			HdlFileLogic.getInstance().deleteFile(drivePathFileName);//下载失败，删除不完整驱动文件;
			}
			if (isBoolean) {
			uniCallbackData(type, null, 0, HDLApp.getInstance().getString(R.string.writing_drive_memory_succeeded), callback);
			uniCallbackData(type, null, 0, HDLApp.getInstance().getAppLocaleContext().getString(R.string.writing_drive_memory_succeeded), callback);
			} else {
			uniCallbackData(type, null, -2, HDLApp.getInstance().getString(R.string.download_drive_file_failed), callback);
			uniCallbackData(type, null, -2, HDLApp.getInstance().getAppLocaleContext().getString(R.string.download_drive_file_failed), callback);
			}
			}
			});
			@@ -1752,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
			@@ -1773,10 +2275,10 @@
			@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().getString(R.string.found_locally_drive_file), callback);
			uniCallbackData(type, null, -2, HDLApp.getInstance().getAppLocaleContext().getString(R.string.found_locally_drive_file), callback);
			return;
			}
			String md5 = HDLMD5Utils.encodeMD5(data);//网关驱动需要
			@@ -1791,44 +2293,23 @@

			@Override
			public void onError(HDLLinkException e) {
			uniCallbackData(type, null, -2, HDLApp.getInstance().getString(R.string.notify_gateway_drive_failed), callback);
			uniCallbackData(type, null, -2, HDLApp.getInstance().getAppLocaleContext().getString(R.string.notify_gateway_drive_failed), callback);
			}
			});
			}

			@Override
			public void onServiceDisconnected(ComponentName name) {
			uniCallbackData(type, null, -2, HDLApp.getInstance().getString(R.string.local_service_fails), callback);
			uniCallbackData(type, null, -2, HDLApp.getInstance().getAppLocaleContext().getString(R.string.local_service_fails), callback);
			}
			});
			} 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().getString(R.string.ota_binding_cloud_upgrade_fails), callback);
			return;
			}
			if (cloudInverterDeviceBean.getDeviceStatus() != 3) {
			uniCallbackData(type, null, cloudInverterDeviceBean.getDeviceStatus(), HDLApp.getInstance().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
			@@ -1836,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().getString(R.string.ota_binding_cloud_upgrade_fails), callback);
			return;
			}
			if (cloudInverterDeviceBean.getDeviceStatus() != 3) {
			uniCallbackData(type, null, cloudInverterDeviceBean.getDeviceStatus(), HDLApp.getInstance().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
			@@ -1875,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);
			// }
			// });
			}
			});

			@@ -1885,7 +2411,7 @@
			*/
			private void uniCancelDownloadingUpgradeFile(String type, Object data, DCUniMPJSCallback callback) {
			HdlOtaLogic.getInstance().stopDownloadUpgradeFile();
			uniCallbackData(type, null, 0, HDLApp.getInstance().getString(R.string.cancel_download_successfully), callback);
			uniCallbackData(type, null, 0, HDLApp.getInstance().getAppLocaleContext().getString(R.string.cancel_download_successfully), callback);
			}

			/**
			@@ -1936,13 +2462,13 @@
			public String getDeviceStatusString(int deviceStatus) {
			switch (deviceStatus) {
			case 1: {
			return HDLApp.getInstance().getString(R.string.my_power_station_connecting);
			return HDLApp.getInstance().getAppLocaleContext().getString(R.string.my_power_station_connecting);
			}
			case 2: {
			return HDLApp.getInstance().getString(R.string.my_power_station_malfunction);
			return HDLApp.getInstance().getAppLocaleContext().getString(R.string.my_power_station_malfunction);
			}
			case 4: {
			return HDLApp.getInstance().getString(R.string.my_power_station_off_line);
			return HDLApp.getInstance().getAppLocaleContext().getString(R.string.my_power_station_off_line);
			}
			default:
			return "";
			@@ -1985,7 +2511,7 @@
			UserConfigManage.getInstance().setBingEmail(cUserInfo.getMemberEmail());
			UserConfigManage.getInstance().setUserImageUrl(cUserInfo.getMemberHeadIcon());
			UserConfigManage.getInstance().Save();
			HdlLogLogic.print("头像路径---->>>" + cUserInfo.getMemberHeadIcon());
			HdlLogLogic.print("头像路径----" + cUserInfo.getMemberHeadIcon());
			}

			@Override
			@@ -2172,7 +2698,7 @@
			public void onSuccess(Boolean obj) {
			GatewayBean gatewayBean = HDLLinkLocalGateway.getInstance().getLocalGateway(mac);
			if (gatewayBean == null) {
			uniCallbackData(type, null, -100, HDLApp.getInstance().getString(R.string.The_gateway_cannot_be_found_locally), callback);
			uniCallbackData(type, null, -100, HDLApp.getInstance().getAppLocaleContext().getString(R.string.The_gateway_cannot_be_found_locally), callback);

			return;
			}
			@@ -2219,7 +2745,7 @@
			}.getType();
			List<GatewayBean> list = gson.fromJson(devices, typeOfT);
			if (list == null \|\| list.size() == 0) {
			uniCallbackData(type, null, -100, HDLApp.getInstance().getString(R.string.The_gateway_cannot_be_found_locally), callback);
			uniCallbackData(type, null, -100, HDLApp.getInstance().getAppLocaleContext().getString(R.string.The_gateway_cannot_be_found_locally), callback);
			return;
			}
			//记录条数
			@@ -2367,7 +2893,9 @@
			*/
			private void uniGetCurrentHomeLocalAndCloudGatewayList(String type, Object data, DCUniMPJSCallback callback) {
			String homeId = getKeyValue("homeId", getKeyValue("data", data));
			HdlDeviceLogic.getInstance().getCurrentHomeLocalAndCloudGatewayList(homeId, new CloudCallBeak<List<GatewayBean>>() {
			String plantType = getKeyValue("plantType", getKeyValue("data", data));
			// UserConfigManage.getInstance().setHomeId(homeId);
			HdlDeviceLogic.getInstance().getCurrentHomeLocalAndCloudGatewayList(homeId, plantType, new CloudCallBeak<List<GatewayBean>>() {
			@Override
			public void onSuccess(List<GatewayBean> list) {
			List<GatewayBean> newList = sortLogic(list);
			@@ -2406,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;
			@@ -2619,6 +3158,7 @@
			inverterDeviceBean.setDeviceStatus(gatewayBean.getDeviceStatus());
			inverterDeviceBean.setSpk(gatewayBean.getSpk());
			inverterDeviceBean.setDeviceType(gatewayBean.getDeviceType());
			inverterDeviceBean.setActivate(gatewayBean.isActivate());
			newList.add(inverterDeviceBean);
			}
			}
			@@ -2754,6 +3294,52 @@
			});
			}

			/**
			* 删除设备oid
			*
			* @param type 类型
			* @param data uni请求数据
			* @param callback uni回调
			*/
			public void uniDeleteOid(String type, Object data, DCUniMPJSCallback callback) {
			String mac = getKeyValue("mac", getKeyValue("data", data));
			String oid_json = getKeyValue("attribute_data", getKeyValue("data", data));
			JsonArray jsonArray = new Gson().fromJson(oid_json, JsonArray.class);
			HdlDeviceLogic.getInstance().deleteOid(mac, jsonArray, 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);
			}
			});
			}

			/**
			* 设备清空运行数据
			*
			* @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协议数据
			@@ -2792,7 +3378,7 @@
			//HdlLogLogic.print("uni---发送---ModBus---" + Arrays.toString(modBusBean.getData()), true);
			//发送modbus协议
			long startTime = System.currentTimeMillis();
			HDLModBusConnect.getInstance().Send(modBusBean.getMac(), modBusBean.getData(), new ModbusCallBack() {
			HDLModBusConnect.getInstance().asyncSend(modBusBean.getMac(), modBusBean.getData(), new ModbusCallBack() {
			@Override
			public void onSuccess(int[] data) {
			uniSuccessCallback(type, data, callback);
			@@ -2826,17 +3412,19 @@
			if (data == null) {
			data = new JSONObject();
			}
			if (isTokenAndRefreshToken) {
			//小程序那里有自己的请求方法,但需要原生提供这些数据
			data.put("token", HDLLinkPMUser.getInstance().getAccessToken());
			data.put("refreshToken", HDLLinkPMUser.getInstance().getRefreshToken());
			if (TextUtils.isEmpty(AppConfigManage.getUserRegionUrl())) {
			AppConfigManage.setUserRegionUrl(HDLLinkPMUser.getInstance().getUserRegionUrl());
			}
			data.put("serverAddress", AppConfigManage.getUserRegionUrl());
			data.put("appKey", AppConfigManage.getAppKey());
			data.put("appSecret", AppConfigManage.getAppSecret());
			}
			// if (isTokenAndRefreshToken) {
			// //小程序那里有自己的请求方法,但需要原生提供这些数据
			// data.put("token", HDLLinkPMUser.getInstance().getAccessToken());
			// data.put("refreshToken", HDLLinkPMUser.getInstance().getRefreshToken());
			// if (TextUtils.isEmpty(AppConfigManage.getUserRegionUrl())) {
			// AppConfigManage.setUserRegionUrl(HDLLinkPMUser.getInstance().getUserRegionUrl());
			// }
			// data.put("serverAddress", AppConfigManage.getUserRegionUrl());
			// data.put("appKey", AppConfigManage.getAppKey());
			// 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) {
			@@ -2871,8 +3459,7 @@
			uniCallBackBaseBean.setData(obj);
			if (callback != null) {
			callback.invoke(getJSONObject(uniCallBackBaseBean));
			// callback.invoke(uniCallBackBaseBean);
			HdlLogLogic.print("回复---uni---" + type + "---" + new Gson().toJson(uniCallBackBaseBean), true);
			HdlLogLogic.print("回复---uni---" + type + "---" + getJSONObject(uniCallBackBaseBean).toString(), true);
			}
			} catch (Exception e) {
			HdlLogLogic.print("回复---uni---" + type + "---" + e.getMessage(), true);