| | |
| | | import android.location.Location; |
| | | import android.location.LocationManager; |
| | | import android.os.IBinder; |
| | | import android.print.PageRange; |
| | | import android.provider.Settings; |
| | | import android.text.TextUtils; |
| | | |
| | |
| | | import com.hdl.photovoltaic.bean.ModBusBean; |
| | | import com.hdl.photovoltaic.bean.PageNumberObject; |
| | | import com.hdl.photovoltaic.config.AppConfigManage; |
| | | import com.hdl.photovoltaic.config.ConstantManage; |
| | | import com.hdl.photovoltaic.config.UserConfigManage; |
| | | import com.hdl.photovoltaic.enums.LowerTagType; |
| | | import com.hdl.photovoltaic.internet.HttpServer.MyNanoHttpServer; |
| | | import com.hdl.photovoltaic.internet.TcpClient; |
| | | import com.hdl.photovoltaic.internet.api.HttpApi; |
| | | 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.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.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 com.huawei.hms.api.Api; |
| | | |
| | | import org.greenrobot.eventbus.EventBus; |
| | | import org.json.JSONObject; |
| | |
| | | break; |
| | | //用户本地缓存信息 |
| | | case HDLUniMP.UNI_EVENT_REPLY_USER_LOCAL_INFO: { |
| | | HdlLogLogic.print("本地头像路径---->>>" + UserConfigManage.getInstance().getUserImageUrl()); |
| | | 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); |
| | | } |
| | | 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事件分发 |
| | |
| | | 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; |
| | | //电站删除 |
| | |
| | | // HDLUniMP.UNI_EVENT_REPLY_HOME_CLOSE_HOME_DETAILS_PAGE, |
| | | // LowerTagType.power_station.toString(), |
| | | // getKeyValue("data", data)); |
| | | if (callback != null) { |
| | | uniSuccessCallback(type, null, callback); |
| | | } |
| | | } |
| | | break; |
| | | //住宅【电站】编辑 |
| | |
| | | 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; |
| | | //电站手动交付(安装商) |
| | |
| | | break; |
| | | |
| | | } |
| | | if (callback != null) { |
| | | uniSuccessCallback(type, null, callback); |
| | | } |
| | | |
| | | } else if (HDLUniMP.UNI_EVENT_REPLY_DEVICE_MODEL.equals(topic)) { |
| | | //设备模块 |
| | | switch (type) { |
| | |
| | | //设备名称修改(修改是云端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; |
| | | } |
| | |
| | | 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; |
| | |
| | | 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; |
| | |
| | | |
| | | } |
| | | break; |
| | | //员工详情获取 |
| | | case HDLUniMP.UNI_EVENT_REPLY_STAFF_DETAIL: { |
| | | uniGetStaffInfo(type, data, callback); |
| | | |
| | | } |
| | | |
| | | break; |
| | | //员工删除 |
| | | case HDLUniMP.UNI_EVENT_REPLY_STAFF_DELETE: { |
| | | |
| | |
| | | } |
| | | break; |
| | | //获取当前账号在公司的身份 |
| | | case HDLUniMP.UNI_EVENT_REPLY_USERRIGHTTYPe: { |
| | | case HDLUniMP.UNI_EVENT_REPLY_USERRIGHTTYP: { |
| | | uniGetUserRightType(type, data, callback); |
| | | |
| | | } |
| | |
| | | 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); |
| | | if (callback != null) { |
| | | uniSuccessCallback(type, jsonObject, callback); |
| | | } |
| | | HdlLogLogic.print("uni---log---" + localSecret, true); |
| | | |
| | | } |
| | | break; |
| | | //本地密钥设置 |
| | | case HDLUniMP.UNI_EVENT_REPLY_OTHER_LOCAL_ENCRYPT_SET: { |
| | | String local_encrypt = getKeyValue("local_encrypt", getKeyValue("data", data)); |
| | | //重新设置本地通讯秘钥 |
| | | UserConfigManage.getInstance().setLocalSecret(local_encrypt); |
| | | UserConfigManage.getInstance().Save(); |
| | | //配置本地通信的信息 |
| | | HDLLinkConfig.getInstance().setLocalSecret(local_encrypt); |
| | | HdlLogLogic.print("uni---log---" + local_encrypt, true); |
| | | |
| | | } |
| | | break; |
| | | } |
| | | } |
| | | |
| | |
| | | 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); |
| | | } |
| | | |
| | | public void openUniMPDelay(String path, JSONObject jsonObject) { |
| | | JSONObject json = this.createdJSONObject(jsonObject, true); |
| | | HDLUniMPSDKManager.getInstance().openUniMPDelay(HDLUniMP.UNI_APP_ID, path, json, HdlUniLogic.this); |
| | | HdlLogLogic.print("uni---组装uni发送数据格式---" + json, false); |
| | | } |
| | | |
| | |
| | | * 电站删除 |
| | | */ |
| | | private void uniGetDelResidence(String type, Object data, DCUniMPJSCallback callback) { |
| | | |
| | | |
| | | String homeId = getKeyValue("homeId", getKeyValue("data", data)); |
| | | HdlResidenceLogic.getInstance().delResidence(homeId, new CloudCallBeak<Boolean>() { |
| | | @Override |
| | | public void onSuccess(Boolean obj) { |
| | | if (callback != null) { |
| | | uniSuccessCallback(type, null, callback); |
| | | } |
| | | List<GatewayBean> list = HdlDeviceLogic.getInstance().getCurrentHomeGatewayList(homeId); |
| | | for (int i = 0; i < list.size(); i++) { |
| | | GatewayBean gatewayBean = list.get(i); |
| | |
| | | list.clear();//清空缓存; |
| | | // HDLLinkLocalGateway.getInstance().getGatewayList().clear(); |
| | | HdlResidenceLogic.getInstance().delHouseId(homeId);//删除电站缓存 |
| | | //uni收到成功结果响应后,会自动关闭小程序,在HDLUniMPSDKManager类里面有方法()监听到小程序关闭,监听到小程序关闭事件后,会重新获取电站列表进行刷界面; |
| | | uniSuccessCallback(type, obj, callback); |
| | | if (UserConfigManage.getInstance().isBAccount()) { |
| | | //B端 |
| | | //收到成功结果响应后,会自动关闭小程序,在HDLUniMPSDKManager类里面有方法()监听到小程序关闭,监听到小程序关闭事件后,会重新获取电站列表进行刷界面; |
| | | if (null != HDLUniMPSDKManager.getInstance().getUniMP()) { |
| | | HDLUniMPSDKManager.getInstance().getUniMP().closeUniMP(); |
| | | } |
| | | } else { |
| | | //C端 |
| | | List<HouseIdBean> 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); |
| | | 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 |
| | |
| | | @Override |
| | | public void onSuccess(Boolean obj) { |
| | | uniSuccessCallback(type, obj, callback); |
| | | //收到成功结果响应后,会自动关闭小程序,在HDLUniMPSDKManager类里面有方法()监听到小程序关闭,监听到小程序关闭事件后,会重新获取电站列表进行刷界面; |
| | | if (null != HDLUniMPSDKManager.getInstance().getUniMP()) { |
| | | HDLUniMPSDKManager.getInstance().getUniMP().closeUniMP(); |
| | | } |
| | | } |
| | | |
| | | @Override |
| | |
| | | } |
| | | |
| | | /** |
| | | * 员工添加 |
| | | * 员工删除 |
| | | */ |
| | | private void uniGetStaffDelete(String type, Object data, DCUniMPJSCallback callback) { |
| | | StaffBean staffBean = new StaffBean(); |
| | |
| | | } |
| | | |
| | | /** |
| | | * 获取员工详情 |
| | | */ |
| | | private void uniGetStaffInfo(String type, Object data, DCUniMPJSCallback callback) { |
| | | String userId = getKeyValue("userId", getKeyValue("data", data)); |
| | | HdlMemberLogic.getInstance().getStaffInfo(userId, new CloudCallBeak<StaffBean>() { |
| | | @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<PageNumberObject<List<StaffBean>>>() { |
| | | HdlMemberLogic.getInstance().getStaffList(pageNo, pageSize, new CloudCallBeak<PageNumberObject<StaffBean>>() { |
| | | @Override |
| | | public void onSuccess(PageNumberObject<List<StaffBean>> obj) { |
| | | public void onSuccess(PageNumberObject<StaffBean> obj) { |
| | | uniSuccessCallback(type, obj.getList(), callback); |
| | | } |
| | | |
| | |
| | | } |
| | | }); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 成员编辑 |
| | |
| | | HdlMemberLogic.getInstance().getMemberAdd(memberBean, new CloudCallBeak<Boolean>() { |
| | | @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<byte[]>() { |
| | | @Override |
| | | public void onSuccess(byte[] obj) { |
| | | uniSuccessCallback(type, obj, callback); |
| | | } |
| | | |
| | |
| | | */ |
| | | private void uniGetCurrentDeviceFirmwares(String type, Object data, DCUniMPJSCallback callback) { |
| | | String deviceOidId = getKeyValue("deviceOidId", getKeyValue("data", data));//云端上设备id |
| | | HdlOtaLogic.getInstance().getCurrentDeviceFirmwares(deviceOidId, new CloudCallBeak<List<DeviceFirmwareBean>>() { |
| | | String oid = getKeyValue("oid", getKeyValue("data", data));//设备oid |
| | | String homeId = getKeyValue("homeId", getKeyValue("data", data));//电站id |
| | | HdlOtaLogic.getInstance().getCurrentDeviceFirmwares(deviceOidId, oid, homeId, new CloudCallBeak<List<DeviceFirmwareBean>>() { |
| | | @Override |
| | | public void onSuccess(List<DeviceFirmwareBean> obj) { |
| | | uniSuccessCallback(type, obj, callback); |
| | |
| | | */ |
| | | private void uniGetCurrentGatewayDrivers(String type, Object data, DCUniMPJSCallback callback) { |
| | | String deviceOid = getKeyValue("oid", getKeyValue("data", data)); |
| | | HdlOtaLogic.getInstance().getCurrentGatewayDrivers(deviceOid, new CloudCallBeak<List<GatewayDriverBean>>() { |
| | | String homeId = getKeyValue("homeId", getKeyValue("data", data));//电站id |
| | | HdlOtaLogic.getInstance().getCurrentGatewayDrivers(deviceOid, homeId, new CloudCallBeak<List<GatewayDriverBean>>() { |
| | | @Override |
| | | public void onSuccess(List<GatewayDriverBean> obj) { |
| | | uniSuccessCallback(type, obj, callback); |
| | |
| | | if (cUserInfo == null) { |
| | | return; |
| | | } |
| | | UserConfigManage.getInstance().setBingPhone(cUserInfo.getMemberPhone()); |
| | | UserConfigManage.getInstance().setBingEmail(cUserInfo.getMemberEmail()); |
| | | UserConfigManage.getInstance().Save(); |
| | | |
| | | //获取用户头像路径 |
| | | if (cUserInfo.getMemberHeadIcon().contains("http")) { |
| | | UserConfigManage.getInstance().setUserImageUrl(cUserInfo.getMemberHeadIcon()); |
| | | //更新用户头像 |
| | | 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<String>() { |
| | | @Override |
| | | public void onSuccess(String url) { |
| | | cUserInfo.setMemberHeadIcon(url); |
| | | UserConfigManage.getInstance().setUserImageUrl(cUserInfo.getMemberHeadIcon()); |
| | | 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 |
| | |
| | | |
| | | @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<Boolean>() { |
| | | @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); |
| | | } |
| | | }); |
| | |
| | | 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<Boolean>() { |
| | | @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) { |
| | | uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); |
| | | if (e.getCode() == 121005) { |
| | | //设备不存在(121005)状态码 |
| | | //初始化逆变器设备 |
| | | HdlDeviceLogic.getInstance().initializeInverter(mac, new LinkCallBack<Boolean>() { |
| | | @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); |
| | | } |
| | | } |
| | | }); |
| | | } |
| | |
| | | HdlDeviceLogic.getInstance().getCurrentHomeLocalAndCloudGatewayList(homeId, new CloudCallBeak<List<GatewayBean>>() { |
| | | @Override |
| | | public void onSuccess(List<GatewayBean> list) { |
| | | if (list == null || list.size() == 0) { |
| | | if (callback != null) { |
| | | uniSuccessCallback(type, list, callback); |
| | | } |
| | | return; |
| | | } |
| | | if (callback != null) { |
| | | uniSuccessCallback(type, list, callback); |
| | | } |
| | | //EventBus事件分发,进入住宅开始订阅主题 |
| | | BaseEventBus baseEventBus = new BaseEventBus(); |
| | | baseEventBus.setTopic(HDLUniMP.UNI_EVENT_REPLY_DEVICE_LIST); |
| | | baseEventBus.setType(HDLUniMP.UNI_EVENT_REPLY_DEVICE_LIST); |
| | | baseEventBus.setData(list); |
| | | baseEventBus.setData(homeId); |
| | | EventBus.getDefault().post(baseEventBus); |
| | | //进来住宅详情都要上传一次oid列表到云端; |
| | | HdlDeviceLogic.getInstance().uploadOidDataToCloud(homeId, list, false, null); |
| | |
| | | /** |
| | | * 初始化逆变器 |
| | | * |
| | | * @param type 账号 |
| | | * @param type 类型 |
| | | * @param data uni请求数据 |
| | | * @param callback uni回调 |
| | | */ |
| | |
| | | /** |
| | | * 初始化逆变器 |
| | | * |
| | | * @param type 账号 |
| | | * @param type 类型 |
| | | * @param data uni请求数据 |
| | | * @param callback uni回调 |
| | | */ |
| | |
| | | /** |
| | | * 修改设备名称逆变器BMS电池包 |
| | | * |
| | | * @param type 账号 |
| | | * @param type 类型 |
| | | * @param data uni请求数据 |
| | | * @param callback uni回调 |
| | | */ |
| | |
| | | @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<List<NotRunBean>>() { |
| | | @Override |
| | | public void onSuccess(List<NotRunBean> 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<Boolean>() { |
| | | @Override |
| | | public void onSuccess(Boolean obj) { |
| | | uniSuccessCallback(type, obj, callback); |
| | | } |
| | | |
| | | @Override |
| | | public void onFailure(HDLException e) { |
| | | uniCallbackData(type, null, e.getCode(), e.getMsg(), callback); |
| | | } |
| | | }); |
| | | } |
| | | |
| | | /** |
| | | * 获取设备详情 |
| | | * |
| | | * @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<List<DeviceInfoBean>>() { |
| | | @Override |
| | | public void onSuccess(List<DeviceInfoBean> list) { |
| | | uniSuccessCallback(type, list, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | } |
| | | if (isTokenAndRefreshToken) { |
| | | //小程序那里有自己的请求方法,但需要原生提供这些数据 |
| | | data.put("token", UserConfigManage.getInstance().getToken()); |
| | | data.put("refreshToken", UserConfigManage.getInstance().getRefreshToken()); |
| | | data.put("token", HDLLinkPMUser.getInstance().getAccessToken()); |
| | | data.put("refreshToken", HDLLinkPMUser.getInstance().getRefreshToken()); |
| | | if (TextUtils.isEmpty(AppConfigManage.getUserRegionUrl())) { |
| | | AppConfigManage.setUserRegionUrl(HDLLinkPMUser.getInstance().getUserRegionUrl()); |
| | | } |
| | |
| | | if (callback != null) { |
| | | callback.invoke(getJSONObject(uniCallBackBaseBean)); |
| | | // callback.invoke(uniCallBackBaseBean); |
| | | HdlLogLogic.print("uni---回复---" + type + "---" + new Gson().toJson(uniCallBackBaseBean), true); |
| | | HdlLogLogic.print("回复---uni---" + type + "---" + new Gson().toJson(uniCallBackBaseBean), true); |
| | | } |
| | | } catch (Exception e) { |
| | | HdlLogLogic.print("uni---回复---" + type + "---" + e.getMessage(), true); |
| | | HdlLogLogic.print("回复---uni---" + type + "---" + e.getMessage(), true); |
| | | } |
| | | |
| | | |
| | | } |
| | | |