| | |
| | | |
| | | |
| | | import android.Manifest; |
| | | import android.bluetooth.BluetoothDevice; |
| | | import android.bluetooth.le.ScanResult; |
| | | import android.content.ComponentName; |
| | | import android.content.Context; |
| | | import android.content.Intent; |
| | |
| | | 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; |
| | |
| | | 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.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; |
| | |
| | | //设备定位 |
| | | 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_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 { |
| | | // Log.d("===", "onDeviceFound: " + Objects.requireNonNull(result.getScanRecord()).getDeviceName()); |
| | | 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); |
| | | |
| | | } catch (Exception ignored) { |
| | | |
| | | } |
| | | |
| | | } |
| | | |
| | | @Override |
| | | public void onScanFailed(int errorCode) { |
| | | // uniCallbackData(mode_type, errorCode, -2, "Bluetooth is not enabled.", callback); |
| | | } |
| | | }); |
| | | } else { |
| | | HdlBluetoothLogic.getInstance().stopScan(); |
| | | // uniSuccessCallback(mode_type, true, callback); |
| | | } |
| | | 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() { |
| | | uniSuccessCallback(mode_type, true, callback); |
| | | } |
| | | |
| | | @Override |
| | | public void onDisconnected() { |
| | | uniCallbackData(type, null, -2, "disconnected", callback); |
| | | } |
| | | |
| | | @Override |
| | | public void onConnectionFailed(String 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); |
| | | |
| | | } |
| | | 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: "); |
| | | uniCallbackData(type, status, -2, "write failed", callback); |
| | | } |
| | | |
| | | @Override |
| | | public void onDeviceResponse(String response) { |
| | | Log.d("HdlUniLogic", "onDeviceResponse: "); |
| | | 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); |
| | | |
| | | } |
| | | break; |
| | | case HDLUniMP.UNI_EVENT_REPLY_BLUETOOTH_Release: { |
| | | //释放蓝牙设备资源 |
| | | HdlBluetoothLogic.getInstance().release(); |
| | | |
| | | } |
| | | break; |
| | | } |
| | | |
| | | } |
| | | |
| | | } catch (Exception e) { |
| | |
| | | |
| | | } |
| | | |
| | | /** |
| | | * 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指定页面 |
| | |
| | | */ |
| | | 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); |
| | |
| | | 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(); |
| | |
| | | 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); |
| | | } |
| | | } |
| | |
| | | |
| | | // 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));//储存在本地驱动文件路径 |
| | |
| | | @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) { |
| | |
| | | @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); |
| | |
| | | // 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) { |