package com.hdl.photovoltaic.other; import android.Manifest; import android.content.ComponentName; import android.content.Context; import android.content.Intent; import android.content.ServiceConnection; import android.content.pm.PackageManager; import android.location.Location; import android.location.LocationManager; import android.os.IBinder; import android.os.SystemClock; import android.provider.Settings; import android.text.TextUtils; import android.util.Log; import androidx.core.app.ActivityCompat; import com.google.gson.Gson; import com.google.gson.JsonArray; import com.google.gson.JsonObject; import com.google.gson.reflect.TypeToken; import com.hdl.link.error.HDLLinkCode; import com.hdl.linkpm.sdk.core.exception.HDLException; import com.hdl.linkpm.sdk.device.bean.DeviceOidInfoBean; import com.hdl.linkpm.sdk.ota.bean.CloudDeviceFirmwaresBean; import com.hdl.linkpm.sdk.ota.bean.CloudGatewayDriversBean; import com.hdl.linkpm.sdk.ota.bean.DeviceFirmwareBean; import com.hdl.linkpm.sdk.ota.bean.GatewayDriverBean; import com.hdl.linkpm.sdk.user.HDLLinkPMUser; import com.hdl.linkpm.sdk.utils.HDLMD5Utils; import com.hdl.photovoltaic.HDLApp; import com.hdl.photovoltaic.R; import com.hdl.photovoltaic.bean.InverterBean; import com.hdl.photovoltaic.bean.LocalResponse; import com.hdl.photovoltaic.bean.ModBusBean; import com.hdl.photovoltaic.bean.PageNumberObject; import com.hdl.photovoltaic.config.AppConfigManage; import com.hdl.photovoltaic.config.UserConfigManage; 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.bean.CUserInfo; import com.hdl.photovoltaic.ui.bean.CloudInverterDeviceBean; 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.NotRunBean; import com.hdl.photovoltaic.ui.bean.OidBean; 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.SetActivity; import com.hdl.photovoltaic.ui.newC.MessageCenterList; import com.hdl.photovoltaic.ui.newC.PowerStationsListEdit; import com.hdl.photovoltaic.uni.HDLUniMP; import com.hdl.photovoltaic.uni.HDLUniMPSDKManager; import com.hdl.photovoltaic.utils.NetworkUtils; import com.hdl.photovoltaic.utils.WifiUtils; import com.hdl.sdk.link.common.exception.HDLLinkException; import com.hdl.sdk.link.core.bean.eventbus.BaseEventBus; import com.hdl.sdk.link.core.bean.gateway.GatewayBean; import com.hdl.sdk.link.core.bean.response.BaseLocalResponse; import com.hdl.sdk.link.core.callback.GatewayCallBack; import com.hdl.sdk.link.core.callback.HDLLinkCallBack; import com.hdl.sdk.link.core.callback.ModbusCallBack; import com.hdl.sdk.link.core.config.HDLLinkConfig; import com.hdl.sdk.link.core.connect.HDLModBusConnect; import com.hdl.sdk.link.core.connect.HDLUdpConnect; import com.hdl.sdk.link.gateway.HDLLinkLocalGateway; import org.greenrobot.eventbus.EventBus; import org.json.JSONArray; import org.json.JSONObject; import java.io.File; import java.io.InputStream; import java.io.OutputStream; import java.lang.reflect.Type; import java.math.BigDecimal; import java.math.RoundingMode; import java.net.InetSocketAddress; import java.net.Socket; import java.util.ArrayList; import java.util.List; import java.util.Objects; import java.util.concurrent.atomic.AtomicInteger; import io.dcloud.feature.unimp.DCUniMPJSCallback; import okhttp3.ResponseBody; /** * uni小程序的逻辑 */ public class HdlUniLogic implements HDLUniMPSDKManager.IOnOtherUniMPEventCallBack { private static volatile HdlUniLogic sHdlUniLogic; public final static String separator = "---"; /** * 获取当前对象 * * @return HdlAccountLogic */ public static synchronized HdlUniLogic getInstance() { if (sHdlUniLogic == null) { synchronized (HdlUniLogic.class) { if (sHdlUniLogic == null) { sHdlUniLogic = new HdlUniLogic(); } } } return sHdlUniLogic; } //region ******【原生】和【小程序】通讯的3个方法名 onOtherUniMPEventReceive();openUniMP();sendUni();****** /** * 原生接收到uni发来的数据 * * @param appId -uni小程序指定的appId * @param topic -uni小程序发来主题(大类) * @param data JSONObject com.alibaba.fastjson解析处理 * @param callback callback.invoke(JSONObject) 用com.alibaba.fastjson */ @Override public void onOtherUniMPEventReceive(String appId, String topic, Object data, DCUniMPJSCallback callback) { try { if (!HDLUniMP.UNI_APP_ID.equals(appId)) { return; } long startTime = System.currentTimeMillis(); Log.d("===开始时间===", String.valueOf(startTime)); 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); if (HDLUniMP.UNI_EVENT_REPLY_USER_MODEL.equals(topic)) { //用户模块 switch (type) { //用户信息 case HDLUniMP.UNI_EVENT_REPLY_USER_INFO: { this.uniGetUserInfo(mode_type, data, callback); } break; //用户头像（旧平台逻辑是头像单独获取下载地址） case HDLUniMP.UNI_EVENT_REPLY_USER_IMAGE: { uniGetImageKey(mode_type, data, callback); } break; //用户本地缓存信息 case HDLUniMP.UNI_EVENT_REPLY_USER_LOCAL_INFO: { JsonObject jsonObject = new JsonObject(); jsonObject.addProperty("user_name", UserConfigManage.getInstance().getUserName()); jsonObject.addProperty("user_image_url", UserConfigManage.getInstance().getUserImageUrl()); jsonObject.addProperty("user_account", UserConfigManage.getInstance().getAccount()); jsonObject.addProperty("token", HDLLinkPMUser.getInstance().getAccessToken()); jsonObject.addProperty("refreshToken", HDLLinkPMUser.getInstance().getRefreshToken()); if (TextUtils.isEmpty(AppConfigManage.getUserRegionUrl())) { AppConfigManage.setUserRegionUrl(HDLLinkPMUser.getInstance().getUserRegionUrl()); } jsonObject.addProperty("serverAddress", AppConfigManage.getUserRegionUrl()); jsonObject.addProperty("appKey", AppConfigManage.getAppKey()); jsonObject.addProperty("appSecret", AppConfigManage.getAppSecret()); uniSuccessCallback(mode_type, jsonObject, callback); HdlLogLogic.print("获取用户本地缓存信息---->>>" + jsonObject.toString()); } break; } } else if (HDLUniMP.UNI_EVENT_REPLY_HOME_MODEL.equals(topic)) { //住宅模块 switch (type) { //扫码添加电站 case HDLUniMP.UNI_EVENT_REPLY_HOME_ADD: { String url = getKeyValue("url", getKeyValue("data", data)); //EventBus事件分发 HdlCommonLogic.getInstance().postEventBusSticky(HDLUniMP.UNI_EVENT_REPLY_HOME_ADD, HDLUniMP.UNI_EVENT_REPLY_HOME_ADD, url); if (callback != null) { uniSuccessCallback(type, null, callback); } } break; //账号下是否有电站列表 case HDLUniMP.UNI_EVENT_REPLY_HOME_LIST: { if (callback != null) { uniSuccessCallback(type, HdlResidenceLogic.getInstance().getHouseIdList().size(), callback); } } break; //创建电站 case HDLUniMP.UNI_EVENT_REPLY_HOME_CREATION: { //EventBus事件分发 HdlCommonLogic.getInstance().postEventBus(HDLUniMP.UNI_EVENT_REPLY_HOME_MODEL, HDLUniMP.UNI_EVENT_REPLY_HOME_CREATION, getKeyValue("data", data)); if (callback != null) { uniSuccessCallback(type, null, callback); } } break; //读取详情 case HDLUniMP.UNI_EVENT_REPLY_HOME_DETAILS: { if (callback != null) { uniSuccessCallback(type, null, callback); } } break; //电站删除 case HDLUniMP.UNI_EVENT_REPLY_HOME_DEl: { this.uniGetDelResidence(mode_type, data, callback); } break; //关闭详情页 case HDLUniMP.UNI_EVENT_REPLY_HOME_CLOSE_HOME_DETAILS_PAGE: { //EventBus事件分发 // todo 在HDLUniMPSDKManager类里面有方法()监听到小程序关闭，然后发布调用EventBus发布出去; // HdlCommonLogic.getInstance().postEventBus( // HDLUniMP.UNI_EVENT_REPLY_HOME_CLOSE_HOME_DETAILS_PAGE, // LowerTagType.power_station.toString(), // getKeyValue("data", data)); if (callback != null) { uniSuccessCallback(type, null, callback); } } break; //住宅【电站】编辑 case HDLUniMP.UNI_EVENT_REPLY_HOME_EDIT: { //EventBus事件分发 HdlCommonLogic.getInstance().postEventBus(HDLUniMP.UNI_EVENT_REPLY_HOME_MODEL, HDLUniMP.UNI_EVENT_REPLY_HOME_EDIT, getKeyValue("data", data)); if (callback != null) { uniSuccessCallback(type, null, callback); } } break; // //电站的交付二维码(安装商) // case HDLUniMP.UNI_EVENT_REPLY_HOME_DELIVERYURLQRCODE: { // uniGetDeliveryUrlQrcode(type, data, callback); // } // break; //电站的交付URL(安装商) case HDLUniMP.UNI_EVENT_REPLY_HOME_DELIVERYURLQRCODE: { uniGetDeliveryUrl(type, data, callback); } break; //电站手动交付(安装商) case HDLUniMP.UNI_EVENT_REPLY_HOME_DELIVERTOACCOUNT: { uniGetDeliverToAccount(type, data, callback); } break; //电站授权安装商(C端) case HDLUniMP.UNI_EVENT_REPLY_HOME_UPDATEDEBUGPERM: { uniHomeUpdateDebugPerm(type, data, callback); } break; } } else if (HDLUniMP.UNI_EVENT_REPLY_DEVICE_MODEL.equals(topic)) { //设备模块 switch (type) { //modBus协议专用 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_MODBUS_SEND: { sendModBus(mode_type, data, callback); } break; //添加逆变器到云端 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_ADD: { this.uniAddInverterDeviceToCloud(mode_type, data, callback); } break; //添加多个逆变器到云端 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_ADD_All: { this.uniAddAllInverterDeviceToCloud(mode_type, data, callback); } break; //删除云端逆变器 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_DEL: { this.uniDelInverterDevice(mode_type, data, callback); } break; //局域网搜索逆变器列表 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_NET_LIST: { this.uniSearchGateway(mode_type, callback); } break; //获取逆变器列表 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_LIST: { this.uniGetCurrentHomeLocalAndCloudGatewayList(mode_type, data, callback); } break; //获取oid列表 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_OID: { this.uniGetInverterOidList(mode_type, data, callback); } break; //逆变器时间读取 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_TIME: { this.uniGetInverterTime(mode_type, data, callback); } break; //逆变器时间编辑 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_TIME_EDIT: { this.uniEditInverterTime(mode_type, data, callback); } break; //逆变器上传数据到云端 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_UPLOADING_DATA: { this.uniUploadDataToCloud(mode_type, data, callback); } break; //逆变器清空住宅id case HDLUniMP.UNI_EVENT_REPLY_DEVICE_CLEAR_DATA: { this.uniClearInverterHomeId(mode_type, data, callback); } break; //spk属性编辑 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_Link_edit_SEND: { this.uniLinkSpkAttributeEdit(mode_type, data, callback); } break; //spk属性读取 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_Link_read_SEND: { this.uniLinkSpkAttributeRead(mode_type, data, callback); } break; //获取未处理/未读消息数量 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_MESSAGE_NUMBER: { this.uniGetMessageNumber(mode_type, data, callback); } break; //初始化逆变器 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_INITIALIZEINVERTER: { this.setInitializeGateway(mode_type, data, callback); } break; //读取设备远程信息 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_REMOTEINFO: { this.setInverterDeviceRemoteInfo(mode_type, data, callback); } break; //设备名称修改(修改是云端oid名称，设备使用modbus协议修改) case HDLUniMP.UNI_EVENT_REPLY_DEVICE_EDIT_NAME: { this.uniOidEditName(mode_type, data, callback); } break; //获取未运行逆变器列表 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_NOT_RUN_DEVICE_LIST: { this.uniGetListNotRun(mode_type, data, callback); } break; //快捷开启逆变器 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_OPEN_DEVICE_LIST: { this.uniSetDeviceStartup(mode_type, data, callback); } break; //获取设备详情（云端设备） case HDLUniMP.UNI_EVENT_REPLY_DEVICE_OPEN_DEVICE_info: { this.uniGetDeviceInfo(mode_type, data, callback); } break; //获取逆变器详情（物理设备） case HDLUniMP.UNI_EVENT_REPLY_DEVICE_OPEN_gateway_info: { this.uniGetGatewayInfo(mode_type, data, callback); } break; } } else if (HDLUniMP.UNI_EVENT_REPLY_WIFI_MODEL.equals(topic)) { WifiUtils wifiUtils = WifiUtils.getInstance(); //wifi模块 switch (type) { //获取手机wifi列表 case HDLUniMP.UNI_EVENT_REPLY_PHONE_WIFI_LIST: { if (callback != null) { uniSuccessCallback(mode_type, wifiUtils.getScanResult(), callback); } } break; //获取手机当前wifi详情 case HDLUniMP.UNI_EVENT_REPLY_PHONE_WIFI_INFO: { if (callback != null) { uniSuccessCallback(mode_type, wifiUtils.getCurrentConnectWifiInfo(), callback); } } break; //打开手机Wifi设置界面 case HDLUniMP.UNI_EVENT_REPLY_PHONE_OPEN_WIFI_SETTINGS: { Intent intent = new Intent(Settings.ACTION_WIFI_SETTINGS); intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK); HDLApp.getInstance().startActivity(intent); } //逆变器WiFi信息配置 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_WIFI_SET: { uniGetAndSetNetwork(mode_type, data, TopicApi.DELETING_GATEWAY_WIFI_EDIT, callback); } break; //逆变器WiFi信息获取 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_WIFI_GET: { uniGetAndSetNetwork(mode_type, data, TopicApi.DELETING_GATEWAY_WIFI_GET, callback); } break; //逆变器热点配置 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_HOTSPOT_SET: { uniGetAndSetNetwork(mode_type, data, TopicApi.DELETING_GATEWAY_HOTSPOT_EDIT, callback); } break; //逆变器热点获取 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_HOTSPOT_GET: { uniGetAndSetNetwork(mode_type, data, TopicApi.DELETING_GATEWAY_HOTSPOT_GET, callback); } break; //逆变器以太网配置 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_ETHERNET_SET: { uniGetAndSetNetwork(mode_type, data, TopicApi.DELETING_GATEWAY_ETHERNET_EDIT, callback); } break; //逆变器以太网获取 case HDLUniMP.UNI_EVENT_REPLY_DEVICE_ETHERNET_GET: { uniGetAndSetNetwork(mode_type, data, TopicApi.DELETING_GATEWAY_ETHERNET_GET, callback); } break; } } else if (HDLUniMP.UNI_EVENT_REPLY_OTA_MODEL.equals(topic)) { //OTA升级模块 switch (type) { //向云端获取oid列表 case HDLUniMP.UNI_EVENT_REPLY_OTA_CLOUD_OID_LIST: { this.uniGetCloudOidList(mode_type, data, callback); } break; //当前设备固件列表 case HDLUniMP.UNI_EVENT_REPLY_OTA_FIRMWARES_LIST: { this.uniGetCurrentDeviceFirmwares(mode_type, data, callback); } break; //设备新固件列表 case HDLUniMP.UNI_EVENT_REPLY_OTA_FIRMWARES_NEW_LIST: { this.uniGetNewDeviceFirmwares(mode_type, data, callback); } break; //设备本地固件列表 case HDLUniMP.UNI_EVENT_REPLY_OTA_FIRMWARES_LOCAL: { this.uniGetLocalFirmwares(mode_type, data, callback); } break; //设备固件下载 case HDLUniMP.UNI_EVENT_REPLY_OTA_FIRMWARES_DOWNLOAD: { this.uniDeviceFirmwareDownload(mode_type, data, callback); } break; //设备固件升级 case HDLUniMP.UNI_EVENT_REPLY_OTA_FIRMWARES_UPGRADE: { this.uniUpgradeDeviceFirmware(mode_type, data, callback); } break; //当前设备驱动列表 case HDLUniMP.UNI_EVENT_REPLY_OTA_DRIVER_LIST: { this.uniGetCurrentGatewayDrivers(mode_type, data, callback); } break; //设备新驱动列表 case HDLUniMP.UNI_EVENT_REPLY_OTA_DRIVER_NEW: { this.uniGetNewGatewayDrivers(mode_type, data, callback); } break; //设备本地驱动列表 case HDLUniMP.UNI_EVENT_REPLY_OTA_DRIVER_LOCAL: { this.uniGetLocalDrivers(mode_type, data, callback); } break; //设备驱动下载 case HDLUniMP.UNI_EVENT_REPLY_OTA_DRIVER_DOWNLOAD: { this.uniGatewayDriverDownload(mode_type, data, callback); } break; //设备驱动升级 case HDLUniMP.UNI_EVENT_REPLY_OTA_DRIVER_UPGRADE: { this.uniUpgradeGatewayDriver(mode_type, data, callback); } break; //设备取消驱动,固件下载升级文件 case HDLUniMP.UNI_EVENT_REPLY_OTA_DRIVER_CANCEL_DOWNLOAD: { this.uniCancelDownloadingUpgradeFile(mode_type, data, callback); } break; //设备驱动,固件取消升级 case HDLUniMP.UNI_EVENT_REPLY_OTA_CANCEL_UPGRADE: { this.uniCancelUpgrade(mode_type, data, callback); } break; //打开服务 case HDLUniMP.UNI_EVENT_REPLY_OTA_OPEN_SERVICE: { this.uniOpenService(mode_type, data, callback); } break; //关闭服务 case HDLUniMP.UNI_EVENT_REPLY_OTA_CLOSE_SERVICE: { this.uniCloseService(mode_type, data, callback); } break; } } else if (HDLUniMP.UNI_EVENT_REPLY_MINE_MODEL.equals(topic)) { //我的模块 switch (type) { //资料编辑 case HDLUniMP.UNI_EVENT_REPLY_MINE_EDIT_USER_INFO: { Intent intent = new Intent(); intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK); intent.setClass(HDLApp.getInstance(), CPersonalDataActivity.class); HDLApp.getInstance().startActivity(intent); } break; //电站选择 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); HDLApp.getInstance().startActivity(intent); } break; //消息中心 case HDLUniMP.UNI_EVENT_REPLY_MINE_MESSAGE_CENTER: { String homeId = getKeyValue("homeId", getKeyValue("data", data)); String isShowFault = getKeyValue("isShowFault", getKeyValue("data", data)); Intent intent = new Intent(); intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK); intent.setClass(HDLApp.getInstance(), MessageCenterList.class); if (!TextUtils.isEmpty(homeId)) { intent.putExtra("homeId", homeId); } if (!TextUtils.isEmpty(isShowFault)) { intent.putExtra("isShowFault", isShowFault); } HDLApp.getInstance().startActivity(intent); } break; //关于 case HDLUniMP.UNI_EVENT_REPLY_MINE_ABOUT: { Intent intent = new Intent(); intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK); intent.setClass(HDLApp.getInstance(), AsRegardsActivity.class); HDLApp.getInstance().startActivity(intent); } break; //设置 case HDLUniMP.UNI_EVENT_REPLY_MINE_SETTING: { Intent intent = new Intent(); intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK); intent.setClass(HDLApp.getInstance(), SetActivity.class); HDLApp.getInstance().startActivity(intent); } break; //下载成员（子账号）头像 case HDLUniMP.UNI_EVENT_REPLY_DOWNLOAD_MEMBER_AVATAR: { uniGetHeadPIortrait(type, data, callback); } break; //成员列表 case HDLUniMP.UNI_EVENT_REPLY_MEMBER_LIST: { uniGetMemberList(type, data, callback); } break; //成员添加 case HDLUniMP.UNI_EVENT_REPLY_MEMBER_ADD: { uniGetMemberAdd(type, data, callback); } break; //成员删除 case HDLUniMP.UNI_EVENT_REPLY_MEMBER_DELETE: { uniGetMemberDelete(type, data, callback); } break; //成员编辑 case HDLUniMP.UNI_EVENT_REPLY_MEMBER_EDIT: { uniGetMemberEdit(type, data, callback); } break; //获取员工列表 case HDLUniMP.UNI_EVENT_REPLY_STAFF_LIST: { uniGetStaffList(type, data, callback); } break; //员工添加 case HDLUniMP.UNI_EVENT_REPLY_STAFF_ADD: { uniGetStaffAdd(type, data, callback); } break; //员工详情获取 case HDLUniMP.UNI_EVENT_REPLY_STAFF_DETAIL: { uniGetStaffInfo(type, data, callback); } break; //员工删除 case HDLUniMP.UNI_EVENT_REPLY_STAFF_DELETE: { uniGetStaffDelete(type, data, callback); } break; //员工编辑 case HDLUniMP.UNI_EVENT_REPLY_STAFF_EDIT: { uniGetStaffEdit(type, data, callback); } break; //获取当前账号在公司的身份 case HDLUniMP.UNI_EVENT_REPLY_USERRIGHTTYP: { uniGetUserRightType(type, data, callback); } 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); } break; //获取当前app语言 case HDLUniMP.UNI_EVENT_REPLY_OTHER_APP_LANGUAGE: { uniSuccessCallback(mode_type, UserConfigManage.getInstance().getCurrentAppLanguage(), callback); } break; //获取位置信息 case HDLUniMP.UNI_EVENT_REPLY_OTHER_LOCATION_INFO: { this.uniGetLocationInfo(mode_type, data, callback); } break; //应用冲突 case HDLUniMP.UNI_EVENT_REPLY_OTHER_APPLICATION_CONFLICT: { if (callback != null) { uniSuccessCallback(type, HDLUdpConnect.getInstance().isBindSuccess(), callback); } } break; //专门收集uni日志 case HDLUniMP.UNI_EVENT_REPLY_OTHER_UNI_LOG: { String customizeContentFormat = getKeyValue("customizeContentFormat", getKeyValue("data", data)); HdlLogLogic.print("uni---log---" + customizeContentFormat, true); } break; //uni主页点击返回通知 case HDLUniMP.UNI_EVENT_REPLY_OTHER_BACK: { //EventBus事件分发 HdlCommonLogic.getInstance().postEventBus(HDLUniMP.UNI_EVENT_REPLY_OTHER_MODEL, HDLUniMP.UNI_EVENT_REPLY_OTHER_BACK); } break; //uni通知原生退出登录 case HDLUniMP.UNI_EVENT_REPLY_OTHER_LOGOUT: { HDLLinkPMUser.getInstance().logout(0); } break; //本地密钥获取 case HDLUniMP.UNI_EVENT_REPLY_OTHER_LOCAL_ENCRYPT_GET: { String localSecret = HDLLinkConfig.getInstance().getLocalSecret(); JsonObject jsonObject = new JsonObject(); jsonObject.addProperty("local_encrypt", localSecret); HdlLogLogic.print("uni---log---本地密钥获取---" + localSecret, true); if (callback != null) { uniSuccessCallback(type, jsonObject, callback); } } break; //本地密钥设置 case HDLUniMP.UNI_EVENT_REPLY_OTHER_LOCAL_ENCRYPT_SET: { String local_encrypt = getKeyValue("local_encrypt", getKeyValue("data", data)); if (!TextUtils.isEmpty(local_encrypt)) { //重新设置本地通讯秘钥 UserConfigManage.getInstance().setLocalSecret(local_encrypt); UserConfigManage.getInstance().Save(); //配置本地通信的信息 HDLLinkConfig.getInstance().setLocalSecret(local_encrypt); HdlLogLogic.print("uni---log---本地密钥设置---" + local_encrypt, true); } if (callback != null) { uniSuccessCallback(type, true, callback); } } break; //link进行密码验证 case HDLUniMP.UNI_EVENT_REPLY_OTHER_PASSWORD_VERIFIY: { uniCheckPasswordVerification(mode_type, data, callback); } 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 language = getKeyValue("language", getKeyValue("data", data)); String json = HdlESLocalJsonLogic.getInstance().readHdlESLocalJson(url, deviceModel); if (TextUtils.isEmpty(json)) { //本地没有缓存 HdlESLocalJsonLogic.getInstance().getHdlESLocalJson(url, deviceModel, new CloudCallBeak() { @Override public void onSuccess(String obj) { // if (callback != null) { // uniSuccessCallback(type, obj, callback); // } String s = HdlESLocalJsonLogic.getInstance().readHdlESLocalJson(url, deviceModel); //本地缓存数据 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 onFailure(HDLException e) { if (callback != null) { uniExceptionCallback(type, e, callback); } } }); } else { //本地缓存数据 if (callback != null) { try { if (json.startsWith("{")) { uniSuccessCallback(type, new Gson().fromJson(json, JsonObject.class), callback); } else if (json.startsWith("[")) { uniSuccessCallback(type, new Gson().fromJson(json, JsonArray.class), callback); } else { uniSuccessCallback(type, json, callback); } } catch (Exception e) { uniSuccessCallback(type, json, callback); } long endTime = System.currentTimeMillis() - startTime; Log.d("====耗时时间====", String.valueOf(endTime)); } } } 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)) { try { jObject = new Gson().fromJson(body, JsonObject.class); } catch (Exception ignored) { } } HttpClient.getInstance().requestHttp(url, jObject.toString(), new CloudCallBeak() { @Override public void onSuccess(String jsonStr) { uniSuccessCallback(mode_type, jsonStr, callback); } @Override public void onFailure(HDLException e) { uniExceptionCallback(mode_type, e, callback); } }); } } } catch (Exception e) { HdlLogLogic.print("uni---发送---" + e.getMessage(), true); } } /** * 原生【打开】uni指定页面 * * @param path 打开路径 * @param jsonObject 附件数据(没有数据填null) */ public void openUniMP(String path, JSONObject jsonObject) { JSONObject json = this.createdJSONObject(jsonObject, true); HDLUniMPSDKManager.getInstance().openUniMP(HDLUniMP.UNI_APP_ID, path, json, HdlUniLogic.this); HdlLogLogic.print("uni---组装uni发送数据格式---" + json, false); } /** * 原生【主动】向小程序发送通知事件 * 注意：需要提前小程序在运行才可成功 * * @param topic 主题大类(如:UNI_EVENT_REPLY_HOME_MODEL) * @param callBackBaseBean 自定义实体类 */ public void sendUni(String topic, HDLUniMP.UniCallBackBaseBean callBackBaseBean) { try { HDLUniMPSDKManager.getInstance().sendUniMPEvent(HDLUniMP.UNI_APP_ID, topic, getJSONObject(callBackBaseBean)); } catch (Exception e) { HdlLogLogic.print("uni---原生主动向小程序发送通知事件---" + e.getMessage(), false); } } /** * 检测是否当前页面注册的callback,是的话则移除 */ public void checkRemoveOtherUniMPEventCallBack() { HDLUniMPSDKManager.getInstance().checkRemoveOtherUniMPEventCallBack(this); } //endregion //region ******uni接口方法****** /** * link进行密码验证 */ private void uniCheckPasswordVerification(String type, Object data, DCUniMPJSCallback callback) { String password = getKeyValue("password", getKeyValue("data", data)); String mac = getKeyValue("mac", getKeyValue("data", data)); HdlDeviceLogic.getInstance().getPasswordVerification(mac, password, new LinkCallBack() { @Override public void onSuccess(LocalResponse obj) { if (callback != null) { uniCallbackData(type, obj.getObjects(), obj.getCode(), obj.getMsg(), callback); } } @Override public void onError(HDLLinkException e) { if (callback != null) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } } }); } /** * 电站删除 */ private void uniGetDelResidence(String type, Object data, DCUniMPJSCallback callback) { String homeId = getKeyValue("homeId", getKeyValue("data", data)); HdlResidenceLogic.getInstance().delResidence(homeId, new CloudCallBeak() { @Override public void onSuccess(Boolean obj) { if (callback != null) { uniSuccessCallback(type, null, callback); } List list = HdlDeviceLogic.getInstance().getCurrentHomeGatewayList(homeId); for (int i = 0; i < list.size(); i++) { GatewayBean gatewayBean = list.get(i); HdlDeviceLogic.getInstance().initializeInverter(gatewayBean.getDevice_mac(), null); } list.clear();//清空缓存; // HDLLinkLocalGateway.getInstance().getGatewayList().clear(); HdlResidenceLogic.getInstance().delHouseId(homeId);//删除电站缓存 if (UserConfigManage.getInstance().isBAccount()) { //B端 //收到成功结果响应后,会自动关闭小程序，在HDLUniMPSDKManager类里面有方法()监听到小程序关闭，监听到小程序关闭事件后，会重新获取电站列表进行刷界面； if (null != HDLUniMPSDKManager.getInstance().getUniMP()) { HDLUniMPSDKManager.getInstance().getUniMP().closeUniMP(); } } else { //C端 List HouseIdList = HdlResidenceLogic.getInstance().getHouseIdList(); if (HouseIdList.size() == 0) { String path = HDLUniMP.UNI_EVENT_OPEN_HOME_Null_C; HdlUniLogic.getInstance().openUniMP(path, null); } else { HouseIdBean houseIdBean = HouseIdList.get(0);//默认拿第一个 HdlResidenceLogic.getInstance().switchHouse(houseIdBean, true); JsonObject jsonObject = new JsonObject(); jsonObject.addProperty("homeId", houseIdBean.getHomeId()); jsonObject.addProperty("homeName", houseIdBean.getHomeName()); jsonObject.addProperty("powerStationStatus", houseIdBean.getPowerStationStatus() + ""); HDLUniMP.UniCallBackBaseBean uniCallBackBaseBean = new HDLUniMP.UniCallBackBaseBean(); uniCallBackBaseBean.setType(HDLUniMP.UNI_EVENT_NOTIFICATION_DEVICE_REFRESH_DETAILS); uniCallBackBaseBean.setData(jsonObject); HdlUniLogic.getInstance().sendUni(HDLUniMP.UNI_EVENT_NOTIFICATION_DEVICE_MODEL, uniCallBackBaseBean); } } } @Override public void onFailure(HDLException e) { uniExceptionCallback(type, e, callback); } }); } /** * 电站授权安装商(C端) */ private void uniHomeUpdateDebugPerm(String type, Object data, DCUniMPJSCallback callback) { String homeId = getKeyValue("homeId", getKeyValue("data", data)); boolean debugPerm = Boolean.parseBoolean(getKeyValue("debugPerm", getKeyValue("data", data))); HdlResidenceLogic.getInstance().homeUpdateDebugPerm(homeId, debugPerm, new CloudCallBeak() { @Override public void onSuccess(Boolean obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniExceptionCallback(type, e, callback); } }); } /** * 电站手动交付(安装商) */ private void uniGetDeliverToAccount(String type, Object data, DCUniMPJSCallback callback) { String homeId = getKeyValue("homeId", getKeyValue("data", data)); String account = getKeyValue("account", getKeyValue("data", data)); HdlResidenceLogic.getInstance().getDeliverToAccount(homeId, account, new CloudCallBeak() { @Override public void onSuccess(Boolean obj) { uniSuccessCallback(type, obj, callback); //收到成功结果响应后,会自动关闭小程序，在HDLUniMPSDKManager类里面有方法()监听到小程序关闭，监听到小程序关闭事件后，会重新获取电站列表进行刷界面； if (null != HDLUniMPSDKManager.getInstance().getUniMP()) { HDLUniMPSDKManager.getInstance().getUniMP().closeUniMP(); } } @Override public void onFailure(HDLException e) { uniExceptionCallback(type, e, callback); } }); } /** * 电站的交付二维码(安装商) */ private void uniGetDeliveryUrlQrcode(String type, Object data, DCUniMPJSCallback callback) { String homeId = getKeyValue("homeId", getKeyValue("data", data)); HdlResidenceLogic.getInstance().getDeliveryUrlQrcode(homeId, new CloudCallBeak() { @Override public void onSuccess(String obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniExceptionCallback(type, e, callback); } }); } /** * 电站的交付URl(安装商) */ private void uniGetDeliveryUrl(String type, Object data, DCUniMPJSCallback callback) { String homeId = getKeyValue("homeId", getKeyValue("data", data)); HdlResidenceLogic.getInstance().getDeliveryUrl(homeId, new CloudCallBeak() { @Override 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); } catch (Exception ignored) { uniSuccessCallback(type, obj, callback); } } @Override public void onFailure(HDLException e) { uniExceptionCallback(type, e, callback); } }); } /** * 获取当前账号在公司的身份 */ private void uniGetUserRightType(String type, Object data, DCUniMPJSCallback callback) { HdlMemberLogic.getInstance().getUserRightType(new CloudCallBeak() { @Override public void onSuccess(UserRightTypeBean userRightTypeBean) { uniSuccessCallback(type, userRightTypeBean, callback); } @Override public void onFailure(HDLException e) { uniExceptionCallback(type, e, callback); } }); } /** * 员工编辑 */ private void uniGetStaffEdit(String type, Object data, DCUniMPJSCallback callback) { StaffBean staffBean = new StaffBean(); String staffInfo = getKeyValue("staffInfo", getKeyValue("data", data)); if (!TextUtils.isEmpty(staffInfo)) { try { staffBean = new Gson().fromJson(staffInfo, StaffBean.class); } catch (Exception ignored) { } } HdlMemberLogic.getInstance().getStaffEdit(staffBean, new CloudCallBeak() { @Override public void onSuccess(Boolean obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniExceptionCallback(type, e, callback); } }); } /** * 员工删除 */ private void uniGetStaffDelete(String type, Object data, DCUniMPJSCallback callback) { StaffBean staffBean = new StaffBean(); String staffInfo = getKeyValue("staffInfo", getKeyValue("data", data)); if (!TextUtils.isEmpty(staffInfo)) { try { staffBean = new Gson().fromJson(staffInfo, StaffBean.class); } catch (Exception ignored) { } } HdlMemberLogic.getInstance().getStaffDelete(staffBean, new CloudCallBeak() { @Override public void onSuccess(Boolean obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniExceptionCallback(type, e, callback); } }); } /** * 员工添加 */ private void uniGetStaffAdd(String type, Object data, DCUniMPJSCallback callback) { StaffBean staffBean = new StaffBean(); String staffInfo = getKeyValue("staffInfo", getKeyValue("data", data)); if (!TextUtils.isEmpty(staffInfo)) { try { staffBean = new Gson().fromJson(staffInfo, StaffBean.class); } catch (Exception ignored) { } } HdlMemberLogic.getInstance().getStaffAdd(staffBean, new CloudCallBeak() { @Override public void onSuccess(Boolean obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniExceptionCallback(type, e, callback); } }); } /** * 获取员工详情 */ private void uniGetStaffInfo(String type, Object data, DCUniMPJSCallback callback) { String userId = getKeyValue("userId", getKeyValue("data", data)); HdlMemberLogic.getInstance().getStaffInfo(userId, new CloudCallBeak() { @Override public void onSuccess(StaffBean obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniExceptionCallback(type, e, callback); } }); } /** * 获取员工列表 */ private void uniGetStaffList(String type, Object data, DCUniMPJSCallback callback) { long pageNo = Long.parseLong(getKeyValue("pageNo", getKeyValue("data", data))); long pageSize = Long.parseLong(getKeyValue("pageSize", getKeyValue("data", data))); HdlMemberLogic.getInstance().getStaffList(pageNo, pageSize, new CloudCallBeak>() { @Override public void onSuccess(PageNumberObject obj) { uniSuccessCallback(type, obj.getList(), callback); } @Override public void onFailure(HDLException e) { uniExceptionCallback(type, e, callback); } }); } /** * 成员编辑 */ private void uniGetMemberEdit(String type, Object data, DCUniMPJSCallback callback) { MemberBean memberBean = new MemberBean(); String memberInfo = getKeyValue("memberInfo", getKeyValue("data", data)); if (!TextUtils.isEmpty(memberInfo)) { try { memberBean = new Gson().fromJson(memberInfo, MemberBean.class); } catch (Exception ignored) { } } HdlMemberLogic.getInstance().getMemberEdit(memberBean, new CloudCallBeak() { @Override public void onSuccess(Boolean obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniExceptionCallback(type, e, callback); } }); } /** * 成员删除 */ private void uniGetMemberDelete(String type, Object data, DCUniMPJSCallback callback) { MemberBean memberBean = new MemberBean(); String memberInfo = getKeyValue("memberInfo", getKeyValue("data", data)); if (!TextUtils.isEmpty(memberInfo)) { try { memberBean = new Gson().fromJson(memberInfo, MemberBean.class); } catch (Exception ignored) { } } HdlMemberLogic.getInstance().getMemberDelete(memberBean, new CloudCallBeak() { @Override public void onSuccess(Boolean obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniExceptionCallback(type, e, callback); } }); } /** * 成员添加 */ private void uniGetMemberAdd(String type, Object data, DCUniMPJSCallback callback) { MemberBean memberBean = new MemberBean(); String memberInfo = getKeyValue("memberInfo", getKeyValue("data", data)); if (!TextUtils.isEmpty(memberInfo)) { try { memberBean = new Gson().fromJson(memberInfo, MemberBean.class); } catch (Exception ignored) { } } HdlMemberLogic.getInstance().getMemberAdd(memberBean, new CloudCallBeak() { @Override public void onSuccess(Boolean obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniExceptionCallback(type, e, callback); } }); } /** * 下载成员（子账号）头像 */ private void uniGetHeadPIortrait(String type, Object data, DCUniMPJSCallback callback) { MemberBean memberBean = new MemberBean(); String memberInfo = getKeyValue("memberInfo", getKeyValue("data", data)); if (!TextUtils.isEmpty(memberInfo)) { try { memberBean = new Gson().fromJson(memberInfo, MemberBean.class); } catch (Exception ignored) { } } HdlMemberLogic.getInstance().getHeadPIortrait(memberBean, new CloudCallBeak() { @Override public void onSuccess(byte[] obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniExceptionCallback(type, e, callback); } }); } /** * 获取成员列表 */ private void uniGetMemberList(String type, Object data, DCUniMPJSCallback callback) { String homeId = getKeyValue("homeId", getKeyValue("data", data)); MemberBean memberBean = new MemberBean(); memberBean.setHomeId(homeId); HdlMemberLogic.getInstance().getMemberList(memberBean, new CloudCallBeak>() { @Override public void onSuccess(List list) { uniSuccessCallback(type, list, callback); } @Override public void onFailure(HDLException e) { uniExceptionCallback(type, e, callback); } }); } /** * 获取或者配置逆变器网络（包括逆变器热点，wifi，以太网）信息 */ private void uniGetAndSetNetwork(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, false, TopicApi, jsonArray, "", new HDLLinkCallBack() { @Override public void onSuccess(String msg) { if (callback != null) { uniSuccessCallback(type, msg, callback); } } @Override public void onError(HDLLinkException e) { if (callback != null) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } } }); } /** * 获取位置信息,包括经纬度 */ private void uniGetLocationInfo(String type, Object data, DCUniMPJSCallback callback) { try { // 初始化LocationManager对象 LocationManager locationManager = (LocationManager) HDLApp.getInstance().getSystemService(Context.LOCATION_SERVICE); Geolocation geolocation = new Geolocation(); //INTERNET 允许使用网络 //ACCESS_FINE_LOCATION 允许使用GPS定位 //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)); 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)); //todo 提示用户打开定位功能或者引导用户去系统设置页面打开定位功能 uniSuccessCallback(type, geolocation, callback); return; } 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)); uniSuccessCallback(type, geolocation, callback); return; } geolocation.setResult(0); geolocation.setDes(HDLApp.getInstance().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(); double lon = longitude.setScale(6, RoundingMode.HALF_DOWN).doubleValue(); geolocation.setLatitude(lat);//经度 geolocation.setLongitude(lon);//纬度 uniSuccessCallback(type, geolocation, callback); } catch (Exception e) { Geolocation geolocation = new Geolocation(); geolocation.setResult(-4); geolocation.setDes(e.getMessage()); uniSuccessCallback(type, geolocation, callback); } } /** * 向云端获取逆变器oid列表 * 前提条件:要上传逆变器oid列表给云端 * * @param callback - */ private void uniGetCloudOidList(String type, Object data, DCUniMPJSCallback callback) { HdlOtaLogic.getInstance().getCloudOidList(new CloudCallBeak>() { @Override public void onSuccess(List obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 向云端获取【当前设备固件】列表 * 前提条件:设备自动上报oid信息给云端 */ private void uniGetCurrentDeviceFirmwares(String type, Object data, DCUniMPJSCallback callback) { String deviceOidId = getKeyValue("deviceOidId", getKeyValue("data", data));//云端上设备id String oid = getKeyValue("oid", getKeyValue("data", data));//设备oid String homeId = getKeyValue("homeId", getKeyValue("data", data));//电站id HdlOtaLogic.getInstance().getCurrentDeviceFirmwares(deviceOidId, oid, homeId, new CloudCallBeak>() { @Override public void onSuccess(List obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 向云端获取【设备新固件】列表 * 前提条件:要通过平台软件上传新固件 */ private void uniGetNewDeviceFirmwares(String type, Object data, DCUniMPJSCallback callback) { String hardwareModel = getKeyValue("hardwareModel", getKeyValue("data", data));//硬件型号 String osImageId = getKeyValue("osImageId", getKeyValue("data", data));//系统镜像id HdlOtaLogic.getInstance().getNewDeviceFirmwares(hardwareModel, osImageId, new CloudCallBeak>() { @Override public void onSuccess(List obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 获取【设备本地固件】列表 */ private void uniGetLocalFirmwares(String type, Object data, DCUniMPJSCallback callback) { try { // String hardwareModel = getKeyValue("hardwareModel", getKeyValue("data", data));//硬件型号 String osImageId = getKeyValue("osImageId", getKeyValue("data", data));//系统镜像id // String firmwareVersionId = getKeyValue("firmwareVersionId", getKeyValue("data", data));//固件版本id // String oid = getKeyValue("oid", getKeyValue("data", data));//固件oid List list = new ArrayList<>(); String driverFileList = HdlFileLogic.getInstance().getFirmwareRootPath(); File file = new File(driverFileList); if (file.list() != null) { for (int i = 0; i < Objects.requireNonNull(file.list()).length; i++) { String path = Objects.requireNonNull(file.list())[i]; if (!path.contains(osImageId)) { continue; } String[] ary = path.split("/"); String[] driverInfoAry = ary[ary.length - 1].split("_"); DeviceFirmwareBean deviceFirmwareBean = new DeviceFirmwareBean(); deviceFirmwareBean.setImageId(driverInfoAry[0]); deviceFirmwareBean.setVersion(driverInfoAry[1].replace(".zip", "")); deviceFirmwareBean.setLocalUrl(HdlFileLogic.getInstance().getFirmwarePathFileName(osImageId, deviceFirmwareBean.getVersion())); list.add(deviceFirmwareBean); } } if (callback != null) { this.uniSuccessCallback(type, list, callback); } } catch (Exception ignored) { } } /** * 向云端发起【设备固件下载】指令 */ private void uniDeviceFirmwareDownload(String type, Object data, DCUniMPJSCallback callback) { // String deviceOidId = getKeyValue("deviceOidId", getKeyValue("data", data));//云端上设备id String oid = getKeyValue("oid", getKeyValue("data", data));//该固件的oid String imageId = getKeyValue("imageId", getKeyValue("data", data));//固件镜像id String version = getKeyValue("version", getKeyValue("data", data));//固件版本 String localUrl = getKeyValue("localUrl", getKeyValue("data", data));//储存在本地固件文件路径 String url = getKeyValue("url", getKeyValue("data", data));//云端上文件地址 String md5 = getKeyValue("md5", getKeyValue("data", data));//云端上文件MD5 HdlOtaLogic.getInstance().getDeviceUpgradeDownloadFile(url, new CloudCallBeak() { @Override public void onSuccess(ResponseBody responseBody) { HdlThreadLogic.runSubThread(new Runnable() { @Override public void run() { String firmwarePathFileName = HdlFileLogic.getInstance().getFirmwarePathFileName(imageId, version); //不在子线程读流会卡死主线程 boolean isBoolean = HdlOtaLogic.getInstance().disposeDownLoadFile(firmwarePathFileName, responseBody, md5, HdlOtaLogic.firmware_type); if (isBoolean) { HdlFileLogic.getInstance().deleteFile(localUrl);//下载成功,删除旧固件文件; } else { HdlFileLogic.getInstance().deleteFile(firmwarePathFileName);//下载失败，删除不完整固件文件; } if (isBoolean) { uniCallbackData(type, null, 0, HDLApp.getInstance().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); } } }); } @Override public void onFailure(HDLException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 向云端发起【设备固件】升级OTA指令 */ private void uniUpgradeDeviceFirmware(String type, Object data, DCUniMPJSCallback callback) { String homeId = UserConfigManage.getInstance().getHomeId(); String deviceMac = getKeyValue("mac", getKeyValue("data", data));//逆变器设备mac（查找socket） String deviceOidId = getKeyValue("deviceOidId", getKeyValue("data", data));//云端上设备id String oid = getKeyValue("oid", getKeyValue("data", data));//升级固件的oid String firmwareVersionId = getKeyValue("firmwareVersionId", getKeyValue("data", data));//固件版本id String version = getKeyValue("version", getKeyValue("data", data));//固件版本 // String hardwareModel = getKeyValue("hardwareModel", getKeyValue("data", data));//云端上文件MD5 String imageId = getKeyValue("imageId", getKeyValue("data", data));//固件镜像id String module = "FW#" + imageId;//模块信息(HW：硬件) //升级本地优先->云端升级 HdlDeviceLogic.getInstance().isLocalConnect(homeId, deviceMac, new CloudCallBeak() { @Override public void onSuccess(Boolean b) { if (b) { HdlLogLogic.print("本地升级---", true); //本地 //1,建立本地服务； //2,告诉网关手机ip和端口； //实例化 获取ip 地址 HdlOtaLogic.getInstance().startLocalService(new ServiceConnection() { @Override public void onServiceConnected(ComponentName name, IBinder service) { //本地升级固件文件路径 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); return; } String md5 = HDLMD5Utils.encodeMD5(data);//网关固件需要 //升级固件文件地址 String upgradeFileLocalPathUrl = "http://" + NetworkUtils.getIPAddress(HDLApp.getInstance()) + ":" + MyNanoHttpServer.HTTP_PORT + firmwarePathFileName; //通知给网关升级固件文件地址等信息 HdlOtaLogic.getInstance().pushUpgradePacketInfo(deviceMac, oid, module, version, data.length + "", upgradeFileLocalPathUrl, md5, new LinkCallBack() { @Override public void onSuccess(String obj) { HdlLogLogic.print("通知给网关升级固件文件地址成功.", true); } @Override public void onError(HDLLinkException e) { uniCallbackData(type, null, -2, HDLApp.getInstance().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); } }); } else { HdlLogLogic.print("在线升级---", true); //远程升级需要检测在逆变器有没有连接上云 HdlDeviceLogic.getInstance().checkInverterConnectedCloud(homeId, deviceMac, new CloudCallBeak() { @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() { @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() { @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() { @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); } }); } }); } /** * 向云端获取【当前设备驱动】列表 * 前提条件:设备自动上报oid信息给云端 */ private void uniGetCurrentGatewayDrivers(String type, Object data, DCUniMPJSCallback callback) { String deviceOid = getKeyValue("oid", getKeyValue("data", data)); String homeId = getKeyValue("homeId", getKeyValue("data", data));//电站id HdlOtaLogic.getInstance().getCurrentGatewayDrivers(deviceOid, homeId, new CloudCallBeak>() { @Override public void onSuccess(List obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 向云端获取【设备新驱动】列表 * 前提条件:要通过平台软件上传新驱动 */ private void uniGetNewGatewayDrivers(String type, Object data, DCUniMPJSCallback callback) { String driveCode = getKeyValue("driveCode", getKeyValue("data", data));//驱动编号或驱动名称 String osImageId = getKeyValue("osImageId", getKeyValue("data", data));//驱动类型id HdlOtaLogic.getInstance().getNewGatewayDrivers(driveCode, osImageId, new CloudCallBeak() { @Override public void onSuccess(CloudGatewayDriversBean obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 获取【设备本地驱动】列表 */ 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 driverVersionId = getKeyValue("driverVersionId", getKeyValue("data", data));//驱动类型id List list = new ArrayList<>(); String driverFileList = HdlFileLogic.getInstance().getDriveRootPath(); File file = new File(driverFileList); 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)) { 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())); list.add(gatewayDriverBean); } } if (callback != null) { this.uniSuccessCallback(type, list, callback); } } catch (Exception exception) { this.uniSuccessCallback(type, new ArrayList<>(), callback); } } /** * 向云端发起【设备驱动下载】指令 */ private void uniGatewayDriverDownload(String type, Object data, DCUniMPJSCallback callback) { // String deviceOid = getKeyValue("oid", getKeyValue("data", data));//逆变器设备oid String driverCode = getKeyValue("driverCode", getKeyValue("data", data));//驱动编码 // 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));//储存在本地驱动文件路径 String url = getKeyValue("url", getKeyValue("data", data));//云端上文件地址 String md5 = getKeyValue("md5", getKeyValue("data", data));//云端上文件MD5 HdlOtaLogic.getInstance().getDeviceUpgradeDownloadFile(url, new CloudCallBeak() { @Override public void onSuccess(ResponseBody responseBody) { HdlThreadLogic.runSubThread(new Runnable() { @Override public void run() { String drivePathFileName = HdlFileLogic.getInstance().getDrivePathFileName(driverCode, version); //不在子线程读流会卡死主线程 boolean isBoolean = HdlOtaLogic.getInstance().disposeDownLoadFile(drivePathFileName, responseBody, md5, HdlOtaLogic.driver_type); if (isBoolean) { HdlFileLogic.getInstance().deleteFile(localUrl);//下载成功,删除旧驱动文件; } else { HdlFileLogic.getInstance().deleteFile(drivePathFileName);//下载失败，删除不完整驱动文件; } if (isBoolean) { uniCallbackData(type, null, 0, HDLApp.getInstance().getString(R.string.writing_drive_memory_succeeded), callback); } else { uniCallbackData(type, null, -2, HDLApp.getInstance().getString(R.string.download_drive_file_failed), callback); } } }); } @Override public void onFailure(HDLException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 向云端发起【设备驱动】升级OTA指令 */ private void uniUpgradeGatewayDriver(String type, Object data, DCUniMPJSCallback callback) { String homeId = UserConfigManage.getInstance().getHomeId(); 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 String version = getKeyValue("version", getKeyValue("data", data));//驱动版本号 String driverCode = getKeyValue("driverCode", getKeyValue("data", data));//驱动编码 String imageId = getKeyValue("imageId", getKeyValue("data", data));//固件镜像id String module = driverCode + "#" + imageId; //升级本地优先->云端升级 HdlDeviceLogic.getInstance().isLocalConnect(homeId, deviceMac, new CloudCallBeak() { @Override public void onSuccess(Boolean b) { if (b) { HdlLogLogic.print("本地升级---", true); //本地 //1,建立本地服务； // 2，告诉网关手机ip和端口； //实例化 获取ip 地址 HdlOtaLogic.getInstance().startLocalService(new ServiceConnection() { @Override public void onServiceConnected(ComponentName name, IBinder service) { //本地升级驱动文件路径 String drivePathFileName = HdlFileLogic.getInstance().getDrivePathFileName(driverCode, 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); return; } String md5 = HDLMD5Utils.encodeMD5(data);//网关驱动需要 //升级驱动文件地址 String upgradeFileLocalPathUrl = "http://" + NetworkUtils.getIPAddress(HDLApp.getInstance()) + ":" + MyNanoHttpServer.HTTP_PORT + drivePathFileName; //通知给网关升级驱动文件地址等信息 HdlOtaLogic.getInstance().pushUpgradePacketInfo(deviceMac, deviceOid, module, version, data.length + "", upgradeFileLocalPathUrl, md5, new LinkCallBack() { @Override public void onSuccess(String obj) { HdlLogLogic.print("通知给网关升级驱动文件地址成功.", true); } @Override public void onError(HDLLinkException e) { uniCallbackData(type, null, -2, HDLApp.getInstance().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); } }); } else { HdlLogLogic.print("在线升级---", true); //远程升级需要【检测】在逆变器有没有连接上云 HdlDeviceLogic.getInstance().checkInverterConnectedCloud(homeId, deviceMac, new CloudCallBeak() { @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() { @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() { @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() { @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); } }); } }); } /** * 取消下载【驱动,固件】升级文件 */ 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); } /** * 取消【驱动,固件】升级 */ private void uniCancelUpgrade(String type, Object data, DCUniMPJSCallback callback) { HdlOtaLogic.getInstance().cancelUpgrade("", new LinkCallBack() { @Override public void onSuccess(Boolean obj) { } @Override public void onError(HDLLinkException e) { } }); } /** * 开启服务 */ private void uniOpenService(String type, Object data, DCUniMPJSCallback callback) { HdlOtaLogic.getInstance().startLocalService(new ServiceConnection() { @Override public void onServiceConnected(ComponentName name, IBinder service) { } @Override public void onServiceDisconnected(ComponentName name) { HdlOtaLogic.getInstance().mServiceStart = false; } }); } /** * 关闭服务 */ private void uniCloseService(String type, Object data, DCUniMPJSCallback callback) { HdlOtaLogic.getInstance().unLocalService(); } /** * @param deviceStatus 逆变器连接云端状态值（ 1：连接中,2：故障,3：运行,4：离线） * @return 返回文本 */ public String getDeviceStatusString(int deviceStatus) { switch (deviceStatus) { case 1: { return HDLApp.getInstance().getString(R.string.my_power_station_connecting); } case 2: { return HDLApp.getInstance().getString(R.string.my_power_station_malfunction); } case 4: { return HDLApp.getInstance().getString(R.string.my_power_station_off_line); } default: return ""; } } /** * 获取用户信息 * * @param data uni数据 * @param callback uni回调 */ private void uniGetUserInfo(String type, Object data, DCUniMPJSCallback callback) { HdlAccountLogic.getInstance().getMemberInfo_C(new CloudCallBeak() { @Override public void onSuccess(CUserInfo cUserInfo) { if (cUserInfo == null) { return; } //获取用户头像路径 if (cUserInfo.getMemberHeadIcon().contains("http")) { //更新用户头像 uniSuccessCallback(type, cUserInfo, callback); UserConfigManage.getInstance().setUserName(cUserInfo.getMemberName()); UserConfigManage.getInstance().setBingPhone(cUserInfo.getMemberPhone()); UserConfigManage.getInstance().setBingEmail(cUserInfo.getMemberEmail()); UserConfigManage.getInstance().setUserImageUrl(cUserInfo.getMemberHeadIcon()); UserConfigManage.getInstance().Save(); HdlLogLogic.print("头像路径---->>>" + cUserInfo.getMemberHeadIcon()); } else { HdlAccountLogic.getInstance().getImageKey_C(cUserInfo.getMemberHeadIcon(), new CloudCallBeak() { @Override public void onSuccess(String url) { cUserInfo.setMemberHeadIcon(url); uniSuccessCallback(type, cUserInfo, callback); UserConfigManage.getInstance().setUserName(cUserInfo.getMemberName()); UserConfigManage.getInstance().setBingPhone(cUserInfo.getMemberPhone()); UserConfigManage.getInstance().setBingEmail(cUserInfo.getMemberEmail()); UserConfigManage.getInstance().setUserImageUrl(cUserInfo.getMemberHeadIcon()); UserConfigManage.getInstance().Save(); HdlLogLogic.print("头像路径---->>>" + cUserInfo.getMemberHeadIcon()); } @Override public void onFailure(HDLException e) { uniSuccessCallback(type, cUserInfo, callback); } }); } } @Override public void onFailure(HDLException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 获取用户头像 * * @param data uni数据 * @param callback uni回调 */ private void uniGetImageKey(String type, Object data, DCUniMPJSCallback callback) { String imageKey = getKeyValue("imageKey", getKeyValue("data", data)); HdlAccountLogic.getInstance().getImageKey_C(imageKey, new CloudCallBeak() { @Override public void onSuccess(String url) { uniSuccessCallback(type, url, callback); } @Override public void onFailure(HDLException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 逆变器清空住宅id * * @param data uni数据 * @param callback uni回调 */ private void uniClearInverterHomeId(String type, Object data, DCUniMPJSCallback callback) { String mac = getKeyValue("mac", getKeyValue("data", data)); HdlDeviceLogic.getInstance().clearInverterHomeId(mac, new LinkCallBack() { @Override public void onSuccess(Boolean obj) { uniSuccessCallback(type, null, callback); } @Override public void onError(HDLLinkException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 获取未处理/未读消息数量 * * @param data uni数据 * @param callback uni回调 */ private void uniGetMessageNumber(String type, Object data, DCUniMPJSCallback callback) { String homeId = getKeyValue("homeId", getKeyValue("data", data)); HdlMessageLogic.getInstance().getMessageUntreatedCount(homeId, new CloudCallBeak() { @Override public void onSuccess(UnCountBean data) { uniSuccessCallback(type, data, callback); } @Override public void onFailure(HDLException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 逆变器【上传数据】到云端 * * @param data uni数据 * @param callback uni回调 */ private void uniUploadDataToCloud(String type, Object data, DCUniMPJSCallback callback) { String mac = getKeyValue("mac", getKeyValue("data", data)); List list = new ArrayList<>(); GatewayBean gatewayBean = new GatewayBean(); gatewayBean.setDevice_mac(mac); list.add(gatewayBean); HdlDeviceLogic.getInstance().uploadOidDataToCloud(UserConfigManage.getInstance().getHomeId(), list, true, null); } /** * 编辑逆变器时间 * * @param data uni数据 * @param callback uni回调 */ private void uniEditInverterTime(String type, Object data, DCUniMPJSCallback callback) { String mac = getKeyValue("mac", getKeyValue("data", data)); String date = getKeyValue("date", getKeyValue("data", data)); String time = getKeyValue("time", getKeyValue("data", data)); String timezone = getKeyValue("timezone", getKeyValue("data", data)); HdlDeviceLogic.getInstance().editGatewayTime(mac, date, time, timezone, new LinkCallBack() { @Override public void onSuccess(Boolean obj) { uniSuccessCallback(type, true, callback); } @Override public void onError(HDLLinkException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 获取逆变器时间 * * @param data uni数据 * @param callback uni回调 */ private void uniGetInverterTime(String type, Object data, DCUniMPJSCallback callback) { String mac = getKeyValue("mac", getKeyValue("data", data)); HdlDeviceLogic.getInstance().getGatewayTime(mac, new LinkCallBack() { @Override public void onSuccess(DeviceTimeBean deviceTimeBean) { if (callback != null) { uniSuccessCallback(type, deviceTimeBean, callback); } } @Override public void onError(HDLLinkException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 获取oid列表 * * @param data uni数据 * @param callback uni回调 */ private void uniGetInverterOidList(String type, Object data, DCUniMPJSCallback callback) { String mac = getKeyValue("mac", getKeyValue("data", data)); HdlDeviceLogic.getInstance().getInverterOidList(mac, new LinkCallBack>() { @Override public void onSuccess(List list) { if (callback != null) { uniSuccessCallback(type, list, callback); } } @Override public void onError(HDLLinkException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 逆变器添加到云端上 * * @param data uni数据 * @param callback uni回调 */ private void uniAddInverterDeviceToCloud(String type, Object data, DCUniMPJSCallback callback) { String mac = getKeyValue("mac", getKeyValue("data", data)); String homeId = UserConfigManage.getInstance().getHomeId(); HdlDeviceLogic.getInstance().setGatewayRemoteParam(homeId, mac, new LinkCallBack() { @Override public void onSuccess(Boolean obj) { HdlDeviceLogic.getInstance().editGatewayParam(mac, new LinkCallBack() { @Override 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); return; } HdlDeviceLogic.getInstance().addInverterDeviceToCloud(homeId, mac, gatewayBean.getGatewayType(), gatewayBean.getSid(), gatewayBean.getOid(), gatewayBean.getDevice_name(), new CloudCallBeak() { @Override public void onSuccess(Boolean obj) { uniSuccessCallback(type, null, callback); } @Override public void onFailure(HDLException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } @Override public void onError(HDLLinkException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } @Override public void onError(HDLLinkException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 多个逆变器添加到云端上 * * @param data uni数据 * @param callback uni回调 */ private void uniAddAllInverterDeviceToCloud(String type, Object data, DCUniMPJSCallback callback) { // com.alibaba.fastjson.JSONArray jsonArray = JSON.parseArray(data); try { String devices = getKeyValue("devices", getKeyValue("data", data)); String homeId = getKeyValue("homeId", getKeyValue("data", data)); Gson gson = new Gson(); Type typeOfT = new TypeToken>() { }.getType(); List 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); return; } //记录条数 AtomicInteger atomicInteger = new AtomicInteger(0); final boolean[] is_boolean = {false}; for (int i = 0; i < list.size(); i++) { GatewayBean gatewayBean = list.get(i); HdlDeviceLogic.getInstance().setGatewayRemoteParam(homeId, gatewayBean.getDevice_mac(), new LinkCallBack() { @Override public void onSuccess(Boolean obj) { HdlDeviceLogic.getInstance().editGatewayParam(gatewayBean.getDevice_mac(), new LinkCallBack() { @Override public void onSuccess(Boolean obj) { atomicInteger.set(atomicInteger.get() + 1); //最后一条才做添加逆变器逻辑处理 if (atomicInteger.get() == list.size()) { HdlDeviceLogic.getInstance().addAllInverterDeviceToCloud(homeId, list, new CloudCallBeak() { @Override public void onSuccess(Boolean obj) { uniSuccessCallback(type, null, callback); } @Override public void onFailure(HDLException e) { //添加逆变器失败后初始化逆变器 HdlLogLogic.print("添加逆变器失败后开始初始化逆变器-->", true); for (int i = 0; i < list.size(); i++) { GatewayBean gatewayBean = list.get(i); HdlDeviceLogic.getInstance().initializeInverter(gatewayBean.getDevice_mac(), new LinkCallBack() { @Override public void onSuccess(Boolean obj) { HdlLogLogic.print("初始化逆变器成功-->mac:" + gatewayBean.getDevice_mac(), true); } @Override public void onError(HDLLinkException e) { HdlLogLogic.print("初始化逆变器失败-->mac:" + gatewayBean.getDevice_mac(), true); } }); } uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } } @Override public void onError(HDLLinkException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); is_boolean[0] = true; } }); } @Override public void onError(HDLLinkException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); is_boolean[0] = true; } }); if (is_boolean[0]) { //只有中间有一条指令设置失败,默认全部失败; break; } } } catch (Exception ignored) { } } /** * 删除云端上逆变器 * * @param data uni数据 * @param callback uni回调 */ private void uniDelInverterDevice(String type, Object data, DCUniMPJSCallback callback) { String deviceId = getKeyValue("deviceId", getKeyValue("data", data)); String homeId = getKeyValue("homeId", getKeyValue("data", data)); String mac = getKeyValue("mac", getKeyValue("data", data)); HdlDeviceLogic.getInstance().delInverterDevice(homeId, deviceId, new CloudCallBeak() { @Override public void onSuccess(Boolean obj) { //初始化逆变器设备 HdlDeviceLogic.getInstance().initializeInverter(mac, null); //移除本地缓存 HdlDeviceLogic.getInstance().removeLocalCacheMemoryGatewayToDeviceId(homeId, deviceId); uniSuccessCallback(type, null, callback); } @Override public void onFailure(HDLException e) { if (e.getCode() == 121005) { //设备不存在（121005）状态码 //初始化逆变器设备 HdlDeviceLogic.getInstance().initializeInverter(mac, new LinkCallBack() { @Override public void onSuccess(Boolean obj) { //移除本地缓存 HdlDeviceLogic.getInstance().removeLocalCacheMemoryGatewayToDeviceId(homeId, deviceId); uniSuccessCallback(type, null, callback); } @Override public void onError(HDLLinkException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } else { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } } }); } /** * 局域网搜索逆变器列表 * * @param callback uni回调 */ private void uniSearchGateway(String type, DCUniMPJSCallback callback) { HdlDeviceLogic.getInstance().searchAllNetworkGateway(new GatewayCallBack() { @Override public void onSuccess(List gatewayBeanList) { uniSuccessCallback(type, gatewayBeanList, callback); } @Override public void onError(HDLLinkException e) { //发送失败 uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 获取逆变器列表 * * @param callback uni回调 */ private void uniGetCurrentHomeLocalAndCloudGatewayList(String type, Object data, DCUniMPJSCallback callback) { String homeId = getKeyValue("homeId", getKeyValue("data", data)); HdlDeviceLogic.getInstance().getCurrentHomeLocalAndCloudGatewayList(homeId, new CloudCallBeak>() { @Override public void onSuccess(List list) { List newList = sortLogic(list); if (callback != null) { uniSuccessCallback(type, newList, callback); } //EventBus事件分发,进入住宅开始订阅主题 BaseEventBus baseEventBus = new BaseEventBus(); baseEventBus.setTopic(HDLUniMP.UNI_EVENT_REPLY_DEVICE_LIST); baseEventBus.setType(HDLUniMP.UNI_EVENT_REPLY_DEVICE_LIST); baseEventBus.setData(homeId); EventBus.getDefault().post(baseEventBus); //进来住宅详情都要上传一次oid列表到云端; HdlDeviceLogic.getInstance().uploadOidDataToCloud(homeId, newList, false, null); } @Override public void onFailure(HDLException e) { if (callback != null) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } } }); } /** * 进行排序（逆变器-负载中心） * * @param list 源数据 * @return 返回列表 */ private List sortLogic(List list) { if (list == null || list.size() == 0) { return new ArrayList<>(); } List newList = new ArrayList<>(); List inverterList = new ArrayList<>(); List 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)); } else { lcList.add(list.get(i)); } } newList.addAll(inverterList); newList.addAll(lcList); return newList; } /** * link spk 属性编辑 * * @param data uni数据 * @param callback uni回调 */ private void uniLinkSpkAttributeEdit(String type, Object data, DCUniMPJSCallback callback) { String mac = getKeyValue("mac", getKeyValue("data", data)); String attribute_data = getKeyValue("attribute_data", getKeyValue("data", data)); JsonArray jay = new JsonArray(); if (!TextUtils.isEmpty(attribute_data)) { try { Gson gson = new Gson(); JsonObject jObject = gson.fromJson(attribute_data, JsonObject.class); String objects = jObject.get("objects").toString(); jay = gson.fromJson(objects, JsonArray.class); } catch (Exception ignored) { } } TcpClient.getInstance().sendDataToLinkGateway(mac, TopicApi.PROPERTY_DOWN, jay, "", new HDLLinkCallBack() { @Override public void onSuccess(String msg) { uniSuccessCallback(type, msg, callback); } @Override public void onError(HDLLinkException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * link spk 属性读取 * * @param data uni数据 * @param callback uni回调 */ private void uniLinkSpkAttributeRead(String type, Object data, DCUniMPJSCallback callback) { String mac = getKeyValue("mac", getKeyValue("data", data)); String attribute_data = getKeyValue("attribute_data", getKeyValue("data", data)); JsonArray jay = new JsonArray(); if (!TextUtils.isEmpty(attribute_data)) { try { Gson gson = new Gson(); JsonObject jObject = gson.fromJson(attribute_data, JsonObject.class); String objects = jObject.get("objects").toString(); jay = gson.fromJson(objects, JsonArray.class); } catch (Exception ignored) { } } TcpClient.getInstance().sendDataToLinkGateway(mac, TopicApi.PROPERTY_READ, jay, "", new HDLLinkCallBack() { @Override public void onSuccess(String msg) { try { Gson gson = new Gson(); Type typeOfT = new TypeToken>>() { }.getType(); BaseLocalResponse> baseLocalResponse = gson.fromJson(msg, typeOfT); uniSuccessCallback(type, baseLocalResponse, callback); } catch (Exception e) { uniCallbackData(type, msg, -2, "", callback); } } @Override public void onError(HDLLinkException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 发送账号和密码给逆变器 * * @param ssid 账号 * @param password 密码 * @param callback uni回调 */ public void startTcpThreadSendAccountAndPassword(String type, String ssid, String password, DCUniMPJSCallback callback) { new Thread(() -> { Socket socket = null; OutputStream outputStreamTcp = null; InputStream inputStreamTcp = null; try { socket = new Socket(); socket.setTcpNoDelay(true); socket.setSoTimeout(10 * 1000);//10秒超时 socket.connect(new InetSocketAddress("192.168.8.1", 8586)); socket.setKeepAlive(true); // logMessage("tcp连接状态成功", 0, ""); outputStreamTcp = socket.getOutputStream(); JsonObject jsonObject = new JsonObject(); jsonObject.addProperty("id", "102030"); jsonObject.addProperty("ssid", ssid); jsonObject.addProperty("password", password); jsonObject.addProperty("server_addr", HDLLinkPMUser.getInstance().getHomeRegionUrl()); jsonObject.addProperty("homeId", UserConfigManage.getInstance().getHomeId()); String sendData = "Topic:/user/id/custom/wifi/set\r\n"; sendData += "Length:" + jsonObject.toString().getBytes().length + "\r\n\r\n"; sendData += jsonObject.toString(); outputStreamTcp.write(sendData.getBytes()); outputStreamTcp.flush(); Thread.sleep(200); inputStreamTcp = socket.getInputStream(); byte[] bytes = new byte[1204 * 2]; int len = inputStreamTcp.read(bytes); if (len != -1) { String str = new String(bytes, 0, bytes.length); String[] strings = str.split("\r\n\r\n"); String[] topicAndLength = strings[0].split("\r\n"); String topic = topicAndLength[0]; JSONObject json = new JSONObject(strings[1]); // logMessage("tcp回复数据", 0, strings[0] + "\r\n" + json.toString()); if (topic.endsWith("wifi/set_reply") || topic.endsWith("wifi/result/notify")) { if (callback != null) { uniSuccessCallback(type, json, callback); } if (json.has("mac")) { //回复成功再拿设备mac // this.device_mac = json.getString("mac"); // this.isSucceedTcp = true;//表示成功 } } } } catch (Exception ignored) { } finally { try { if (outputStreamTcp != null) { outputStreamTcp.close(); outputStreamTcp = null; } if (inputStreamTcp != null) { inputStreamTcp.close(); inputStreamTcp = null; } if (socket != null) { socket.close(); socket = null; } } catch (Exception ignored) { } } }).start(); } /** * 初始化逆变器 * * @param type 类型 * @param data uni请求数据 * @param callback uni回调 */ public void setInitializeGateway(String type, Object data, DCUniMPJSCallback callback) { String mac = getKeyValue("mac", getKeyValue("data", data)); HdlDeviceLogic.getInstance().initializeInverter(mac, new LinkCallBack() { @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 setInverterDeviceRemoteInfo(String type, Object data, DCUniMPJSCallback callback) { String homeId = getKeyValue("homeId", getKeyValue("data", data)); String json = getKeyValue("list", getKeyValue("data", data)); List newList = new ArrayList<>(); try { List list = new Gson().fromJson(json, new TypeToken>() { }.getType()); if (list != null && list.size() > 0) { for (int i = 0; i < list.size(); i++) { GatewayBean gatewayBean = list.get(i); CloudInverterDeviceBean inverterDeviceBean = new CloudInverterDeviceBean(); inverterDeviceBean.setCategorySecondName(gatewayBean.getCategorySecondName()); inverterDeviceBean.setOsn(gatewayBean.getDevice_mac()); inverterDeviceBean.setOmodel(gatewayBean.getDevice_model()); inverterDeviceBean.setOid(gatewayBean.getOid()); inverterDeviceBean.setAddresses(gatewayBean.getAddresses()); inverterDeviceBean.setSid(gatewayBean.getSid()); inverterDeviceBean.setDeviceId(gatewayBean.getDeviceId()); inverterDeviceBean.setName(gatewayBean.getDevice_name()); inverterDeviceBean.setDeviceStatus(gatewayBean.getDeviceStatus()); inverterDeviceBean.setSpk(gatewayBean.getSpk()); inverterDeviceBean.setDeviceType(gatewayBean.getDeviceType()); newList.add(inverterDeviceBean); } } } catch (Exception ignored) { } HdlDeviceLogic.getInstance().setDeviceRemoteInfo(newList, homeId, new CloudCallBeak>() { @Override public void onSuccess(List obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 修改设备名称逆变器BMS电池包 * * @param type 类型 * @param data uni请求数据 * @param callback uni回调 */ public void uniOidEditName(String type, Object data, DCUniMPJSCallback callback) { String homeId = getKeyValue("homeId", getKeyValue("data", data)); String deviceType = getKeyValue("deviceType", getKeyValue("data", data)); String deviceId = getKeyValue("deviceId", getKeyValue("data", data)); String name = getKeyValue("name", getKeyValue("data", data)); HdlDeviceLogic.getInstance().setRename(homeId, deviceType, deviceId, name, new CloudCallBeak() { @Override public void onSuccess(Boolean obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 获取未运行逆变器列表 * * @param type 类型 * @param data uni请求数据 * @param callback uni回调 */ public void uniGetListNotRun(String type, Object data, DCUniMPJSCallback callback) { String homeId = getKeyValue("homeId", getKeyValue("data", data)); HdlDeviceLogic.getInstance().getListNotRun(homeId, new CloudCallBeak>() { @Override public void onSuccess(List obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 逆变器开机 * * @param type 类型 * @param data uni请求数据 * @param callback uni回调 */ public void uniSetDeviceStartup(String type, Object data, DCUniMPJSCallback callback) { String homeId = getKeyValue("homeId", getKeyValue("data", data)); String aryJson = getKeyValue("deviceIds", getKeyValue("data", data)); JsonArray jsonArray = new Gson().fromJson(aryJson, JsonArray.class); HdlDeviceLogic.getInstance().setDeviceStartup(homeId, jsonArray, new CloudCallBeak() { @Override public void onSuccess(Boolean obj) { uniSuccessCallback(type, obj, callback); } @Override public void onFailure(HDLException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 获取设备详情（云端） * * @param type 类型 * @param data uni请求数据 * @param callback uni回调 */ public void uniGetDeviceInfo(String type, Object data, DCUniMPJSCallback callback) { String homeId = getKeyValue("homeId", getKeyValue("data", data)); String aryJson = getKeyValue("deviceIds", getKeyValue("data", data)); JsonArray jsonArray = new Gson().fromJson(aryJson, JsonArray.class); HdlDeviceLogic.getInstance().getDeviceInfo(homeId, jsonArray, new CloudCallBeak>() { @Override public void onSuccess(List list) { uniSuccessCallback(type, list, callback); } @Override public void onFailure(HDLException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 获取逆变器详情 * * @param type 类型 * @param data uni请求数据 * @param callback uni回调 */ public void uniGetGatewayInfo(String type, Object data, DCUniMPJSCallback callback) { String mac = getKeyValue("mac", getKeyValue("data", data)); HdlDeviceLogic.getInstance().getGatewayInfo(mac, new LinkCallBack() { @Override public void onSuccess(InverterBean obj) { uniSuccessCallback(type, obj, callback); } @Override public void onError(HDLLinkException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); } }); } /** * 发送modbus协议数据 * 透传协议 * 下发主题：/user/${gw_id}/custom/native/${driver}/down; * 逆变器回复主题：/user/${gw_id}/custom/native/${driver}/down_reply; * Modbus ECU协议：事件ID(2个byte)->协议[固定:0,0](2个byte)->长度(2byte)->标识符[oid的addresses值](4个byte)->功能码(1个byte)->负载数据(N个byte); * 长度(2个byte)=标识符(4个byte)+功能码(1个byte)+负载数据(N个byte); * 负载数据=寄存器地址(2个byte)+寄存器长度(2个byte)+内容长度(1个byte)+内容数据(N个byte)【注意:单个写入寄存器-->去掉<寄存器长度>和<内容长度>】; * 寄存器长度=(内容数据/2); * 例子:new byte[]{00,01,00,00,00,0x09,00,00,00,01,03,00,00,00,01}; * * @param data modbus数据 * @param callback 回调 */ private void sendModBus(String type, Object data, DCUniMPJSCallback callback) { String tempData = getKeyValue("data", data); if (TextUtils.isEmpty(tempData)) { uniCallbackData(type, null, -2, "data内容为空", callback); //HdlLogLogic.print("data内容为空---", false); return; } ModBusBean modBusBean = new Gson().fromJson(tempData, ModBusBean.class); // ModBusBean modBusBean = new ModBusBean(); // modBusBean.setOid("0101050219D44A00"); // modBusBean.setData(new byte[]{00,01,00,00,00,0x09,00,00,00,01,03,00,00,00,01}); // if (TextUtils.isEmpty(modBusBean.getOid())) { // modBusBean.setOid("0101050217BBC400"); // } if (modBusBean.getMac() == null || modBusBean.getData() == null) { uniCallbackData(type, null, -2, "发送失败,(mac或者oid)为空", callback); //HdlLogLogic.print("uni---发送---ModBus---发送失败,(mac或者oid)为空." + Arrays.toString(modBusBean.getData()), true); return; } //HdlLogLogic.print("uni---发送---ModBus---" + Arrays.toString(modBusBean.getData()), true); //发送modbus协议 HDLModBusConnect.getInstance().Send(modBusBean.getMac(), modBusBean.getData(), new ModbusCallBack() { @Override public void onSuccess(int[] data) { uniSuccessCallback(type, data, callback); // HdlLogLogic.print("uni---接收---ModBus---" + Arrays.toString(data), true); } @Override public void onError(HDLLinkException e) { uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); // HdlLogLogic.print("uni---接收---ModBus---" + e.getMsg() + "(" + e.getCode() + ")", true); } }); } //endregion //region ******一般方法****** /** * 组装uni发送数据格式 * * @param data 附加数据(没有数据填null) * @param isTokenAndRefreshToken (true=底层默认添加token和refreshToken;false=不加) * @return JSONObject uni方法名里面参数需要的JSONObject对象 */ private JSONObject createdJSONObject(JSONObject data, boolean isTokenAndRefreshToken) { HDLUniMP.UniCallBackBaseBean uniCallBackBaseBean = new HDLUniMP.UniCallBackBaseBean(); try { 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()); } uniCallBackBaseBean.setData(data); return getJSONObject(uniCallBackBaseBean); } catch (Exception e) { HdlLogLogic.print("uni---组装发送给uni数据格式有异常---" + e.getMessage(), false); } return new JSONObject(); } private void uniSuccessCallback(String type, Object obj, DCUniMPJSCallback callback) { uniCallbackData(type, obj, HDLLinkCode.HDL_SUCCESS.getCode(), HDLLinkCode.HDL_SUCCESS.getMsg(), callback); } private void uniExceptionCallback(String type, HDLException hdlException, DCUniMPJSCallback callback) { uniCallbackData(type, null, hdlException.getCode(), hdlException.getMsg(), callback); } /** * 组装uni发送数据格式 * 回调数据给uni小程序,统一在这里处理; * * @param type 请求的小类 * @param obj 附加数据 * @param code 状态码-成功（0）或者失败（-2） * @param msg 结果描述的信息 * @param callback 回调 */ private void uniCallbackData(String type, Object obj, int code, String msg, DCUniMPJSCallback callback) { HDLUniMP.UniCallBackBaseBean uniCallBackBaseBean = new HDLUniMP.UniCallBackBaseBean(); try { uniCallBackBaseBean.setCode(code); uniCallBackBaseBean.setMsg(msg); uniCallBackBaseBean.setData(obj); if (callback != null) { callback.invoke(getJSONObject(uniCallBackBaseBean)); // callback.invoke(uniCallBackBaseBean); HdlLogLogic.print("回复---uni---" + type + "---" + new Gson().toJson(uniCallBackBaseBean), true); } } catch (Exception e) { HdlLogLogic.print("回复---uni---" + type + "---" + e.getMessage(), true); } } /** * 当前对象转 JSONObject * * @return JSONObject */ public JSONObject getJSONObject(Object obj) { try { if (obj == null) { return new JSONObject(); } if (TextUtils.isEmpty(obj.toString())) { return new JSONObject(); } if (obj.toString().startsWith("{") && obj.toString().endsWith("}")) { return new JSONObject(obj.toString()); } if (obj instanceof JSONObject) { return (JSONObject) obj; } String json = new Gson().toJson(obj); return new JSONObject(json); } catch (Exception e) { return new JSONObject(); } } /** * 获取 KeyValue * * @param key - * @param obj - * @return value */ public String getKeyValue(String key, Object obj) { try { JSONObject jsonObject = this.getJSONObject(obj); if (jsonObject.has(key)) { return jsonObject.getString(key); } return ""; } catch (Exception e) { return ""; } } //endregion }