| | |
| | | import android.location.Location; |
| | | import android.location.LocationManager; |
| | | import android.os.IBinder; |
| | | import android.os.SystemClock; |
| | | import android.print.PageRange; |
| | | import android.provider.Settings; |
| | | import android.text.TextUtils; |
| | | |
| | |
| | | import com.hdl.photovoltaic.HDLApp; |
| | | import com.hdl.photovoltaic.R; |
| | | 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.ui.bean.DeviceTimeBean; |
| | | import com.hdl.photovoltaic.ui.bean.Geolocation; |
| | | import com.hdl.photovoltaic.ui.bean.LinkBean; |
| | | import com.hdl.photovoltaic.ui.bean.MemberBean; |
| | | 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 java.util.Objects; |
| | | import java.util.concurrent.atomic.AtomicInteger; |
| | | |
| | | import io.dcloud.feature.sdk.DCUniMPSDK; |
| | | import io.dcloud.feature.unimp.DCUniMPJSCallback; |
| | | import okhttp3.ResponseBody; |
| | | |
| | |
| | | jsonObject.addProperty("user_name", UserConfigManage.getInstance().getUserName()); |
| | | jsonObject.addProperty("user_image_url", UserConfigManage.getInstance().getUserImageUrl()); |
| | | jsonObject.addProperty("user_account", UserConfigManage.getInstance().getAccount()); |
| | | uniCallbackData(mode_type, jsonObject, callback); |
| | | 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_CREATION: { |
| | | //EventBus事件分发 |
| | | BaseEventBus baseEventBus = new BaseEventBus(); |
| | | baseEventBus.setTopic(HDLUniMP.UNI_EVENT_REPLY_HOME_MODEL); |
| | | baseEventBus.setType(HDLUniMP.UNI_EVENT_REPLY_HOME_CREATION); |
| | | baseEventBus.setData(getKeyValue("data", data)); |
| | | EventBus.getDefault().post(baseEventBus); |
| | | 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事件分发 |
| | | BaseEventBus baseEventBus = new BaseEventBus(); |
| | | baseEventBus.setType(HDLUniMP.UNI_EVENT_REPLY_HOME_CLOSE_HOME_DETAILS_PAGE); |
| | | baseEventBus.setData(getKeyValue("data", data)); |
| | | EventBus.getDefault().post(baseEventBus); |
| | | // 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事件分发 |
| | | BaseEventBus baseEventBus = new BaseEventBus(); |
| | | baseEventBus.setTopic(HDLUniMP.UNI_EVENT_REPLY_HOME_MODEL); |
| | | baseEventBus.setType(HDLUniMP.UNI_EVENT_REPLY_HOME_EDIT); |
| | | baseEventBus.setData(getKeyValue("data", data)); |
| | | EventBus.getDefault().post(baseEventBus); |
| | | 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; |
| | | //电站手动交付(安装商) |
| | | 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; |
| | | |
| | | |
| | | } |
| | | if (callback != null) { |
| | | uniCallbackData(type, null, callback); |
| | | } |
| | | |
| | | } else if (HDLUniMP.UNI_EVENT_REPLY_DEVICE_MODEL.equals(topic)) { |
| | | //设备模块 |
| | | switch (type) { |
| | |
| | | //获取手机wifi列表 |
| | | case HDLUniMP.UNI_EVENT_REPLY_PHONE_WIFI_LIST: { |
| | | if (callback != null) { |
| | | uniCallbackData(mode_type, wifiUtils.getScanResult(), callback); |
| | | uniSuccessCallback(mode_type, wifiUtils.getScanResult(), callback); |
| | | } |
| | | } |
| | | break; |
| | | //获取手机当前wifi详情 |
| | | case HDLUniMP.UNI_EVENT_REPLY_PHONE_WIFI_INFO: { |
| | | if (callback != null) { |
| | | uniCallbackData(mode_type, wifiUtils.getCurrentConnectWifiInfo(), callback); |
| | | uniSuccessCallback(mode_type, wifiUtils.getCurrentConnectWifiInfo(), callback); |
| | | } |
| | | } |
| | | break; |
| | |
| | | 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_USERRIGHTTYPe: { |
| | | uniGetUserRightType(type, data, callback); |
| | | |
| | | } |
| | | break; |
| | |
| | | switch (type) { |
| | | //获取温度单位 |
| | | case HDLUniMP.UNI_EVENT_REPLY_OTHER_UNIT: { |
| | | uniCallbackData(mode_type, UserConfigManage.getInstance().getTemperature_unit(), callback); |
| | | uniSuccessCallback(mode_type, UserConfigManage.getInstance().getTemperature_unit(), callback); |
| | | } |
| | | break; |
| | | //获取当前app语言 |
| | | case HDLUniMP.UNI_EVENT_REPLY_OTHER_APP_LANGUAGE: { |
| | | uniCallbackData(mode_type, UserConfigManage.getInstance().getCurrentAppLanguage(), callback); |
| | | uniSuccessCallback(mode_type, UserConfigManage.getInstance().getCurrentAppLanguage(), callback); |
| | | } |
| | | break; |
| | | //获取位置信息 |
| | |
| | | //应用冲突 |
| | | case HDLUniMP.UNI_EVENT_REPLY_OTHER_APPLICATION_CONFLICT: { |
| | | if (callback != null) { |
| | | uniCallbackData(type, HDLUdpConnect.getInstance().isBindSuccess(), callback); |
| | | uniSuccessCallback(type, HDLUdpConnect.getInstance().isBindSuccess(), callback); |
| | | } |
| | | } |
| | | break; |
| | |
| | | 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); |
| | | } |
| | | |
| | | /** |
| | | * 原生【主动】向小程序发送通知事件 |
| | | * 注意:需要提前小程序在运行才可成功 |
| | |
| | | |
| | | //region ******uni接口方法****** |
| | | |
| | | /** |
| | | * 电站删除 |
| | | */ |
| | | 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) { |
| | | List<GatewayBean> 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);//删除电站缓存 |
| | | //收到成功结果响应后,会自动关闭小程序,在HDLUniMPSDKManager类里面有方法()监听到小程序关闭,监听到小程序关闭事件后,会重新获取电站列表进行刷界面; |
| | | if (null != HDLUniMPSDKManager.getInstance().getUniMP()) { |
| | | HDLUniMPSDKManager.getInstance().getUniMP().closeUniMP(); |
| | | } |
| | | if (!UserConfigManage.getInstance().isBAccount()) { |
| | | HdlCommonLogic.getInstance().postEventBus(HDLUniMP.UNI_EVENT_REPLY_HOME_MODEL, HDLUniMP.UNI_EVENT_REPLY_HOME_DEl, homeId); |
| | | } |
| | | } |
| | | |
| | | @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<Boolean>() { |
| | | @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<Boolean>() { |
| | | @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<String>() { |
| | | @Override |
| | | public void onSuccess(String obj) { |
| | | 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<UserRightTypeBean>() { |
| | | @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<Boolean>() { |
| | | @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<Boolean>() { |
| | | @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<Boolean>() { |
| | | @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<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<StaffBean>>() { |
| | | @Override |
| | | public void onSuccess(PageNumberObject<StaffBean> 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<Boolean>() { |
| | | @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<Boolean>() { |
| | | @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<Boolean>() { |
| | | @Override |
| | | public void onSuccess(Boolean 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<List<MemberBean>>() { |
| | | @Override |
| | | public void onSuccess(List<MemberBean> list) { |
| | | uniSuccessCallback(type, list, callback); |
| | | } |
| | | |
| | | @Override |
| | | public void onFailure(HDLException e) { |
| | | uniExceptionCallback(type, e, callback); |
| | | } |
| | | }); |
| | | } |
| | | |
| | | /** |
| | | * 获取或者配置逆变器网络(包括逆变器热点,wifi,以太网)信息 |
| | |
| | | @Override |
| | | public void onSuccess(String msg) { |
| | | if (callback != null) { |
| | | uniCallbackData(type, msg, callback); |
| | | uniSuccessCallback(type, msg, callback); |
| | | } |
| | | |
| | | } |
| | |
| | | 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)); |
| | | uniCallbackData(type, geolocation, callback); |
| | | uniSuccessCallback(type, geolocation, callback); |
| | | return; |
| | | } |
| | | // 判断设备是否支持定位功能 |
| | |
| | | geolocation.setResult(-1); |
| | | geolocation.setDes(HDLApp.getInstance().getString(R.string.exception_the_location_function_is_not_enabled)); |
| | | //todo 提示用户打开定位功能或者引导用户去系统设置页面打开定位功能 |
| | | uniCallbackData(type, geolocation, callback); |
| | | 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)); |
| | | uniCallbackData(type, geolocation, callback); |
| | | uniSuccessCallback(type, geolocation, callback); |
| | | return; |
| | | } |
| | | geolocation.setResult(0); |
| | |
| | | double lon = longitude.setScale(6, RoundingMode.HALF_DOWN).doubleValue(); |
| | | geolocation.setLatitude(lat);//经度 |
| | | geolocation.setLongitude(lon);//纬度 |
| | | uniCallbackData(type, geolocation, callback); |
| | | uniSuccessCallback(type, geolocation, callback); |
| | | } catch (Exception e) { |
| | | Geolocation geolocation = new Geolocation(); |
| | | geolocation.setResult(-4); |
| | | geolocation.setDes(e.getMessage()); |
| | | uniCallbackData(type, geolocation, callback); |
| | | uniSuccessCallback(type, geolocation, callback); |
| | | } |
| | | } |
| | | |
| | |
| | | HdlOtaLogic.getInstance().getCloudOidList(new CloudCallBeak<List<DeviceOidInfoBean>>() { |
| | | @Override |
| | | public void onSuccess(List<DeviceOidInfoBean> obj) { |
| | | uniCallbackData(type, obj, callback); |
| | | uniSuccessCallback(type, obj, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | HdlOtaLogic.getInstance().getCurrentDeviceFirmwares(deviceOidId, new CloudCallBeak<List<DeviceFirmwareBean>>() { |
| | | @Override |
| | | public void onSuccess(List<DeviceFirmwareBean> obj) { |
| | | uniCallbackData(type, obj, callback); |
| | | uniSuccessCallback(type, obj, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | HdlOtaLogic.getInstance().getNewDeviceFirmwares(hardwareModel, osImageId, new CloudCallBeak<List<CloudDeviceFirmwaresBean>>() { |
| | | @Override |
| | | public void onSuccess(List<CloudDeviceFirmwaresBean> obj) { |
| | | uniCallbackData(type, obj, callback); |
| | | uniSuccessCallback(type, obj, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | } |
| | | } |
| | | if (callback != null) { |
| | | this.uniCallbackData(type, list, callback); |
| | | this.uniSuccessCallback(type, list, callback); |
| | | } |
| | | } catch (Exception ignored) { |
| | | } |
| | |
| | | HdlOtaLogic.getInstance().upgradeDeviceFirmware(deviceOidId, firmwareVersionId, new CloudCallBeak<Boolean>() { |
| | | @Override |
| | | public void onSuccess(Boolean obj) { |
| | | uniCallbackData(type, obj, callback); |
| | | uniSuccessCallback(type, obj, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | HdlOtaLogic.getInstance().upgradeDeviceFirmware(deviceOidId, firmwareVersionId, new CloudCallBeak<Boolean>() { |
| | | @Override |
| | | public void onSuccess(Boolean obj) { |
| | | uniCallbackData(type, obj, callback); |
| | | uniSuccessCallback(type, obj, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | HdlOtaLogic.getInstance().getCurrentGatewayDrivers(deviceOid, new CloudCallBeak<List<GatewayDriverBean>>() { |
| | | @Override |
| | | public void onSuccess(List<GatewayDriverBean> obj) { |
| | | uniCallbackData(type, obj, callback); |
| | | uniSuccessCallback(type, obj, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | HdlOtaLogic.getInstance().getNewGatewayDrivers(driveCode, osImageId, new CloudCallBeak<CloudGatewayDriversBean>() { |
| | | @Override |
| | | public void onSuccess(CloudGatewayDriversBean obj) { |
| | | uniCallbackData(type, obj, callback); |
| | | uniSuccessCallback(type, obj, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | } |
| | | } |
| | | if (callback != null) { |
| | | this.uniCallbackData(type, list, callback); |
| | | this.uniSuccessCallback(type, list, callback); |
| | | } |
| | | } catch (Exception exception) { |
| | | this.uniCallbackData(type, new ArrayList<>(), callback); |
| | | this.uniSuccessCallback(type, new ArrayList<>(), callback); |
| | | } |
| | | |
| | | } |
| | |
| | | HdlOtaLogic.getInstance().upgradeGatewayDriver(deviceOid, driverVersionId, new CloudCallBeak<Boolean>() { |
| | | @Override |
| | | public void onSuccess(Boolean obj) { |
| | | uniCallbackData(type, obj, callback); |
| | | uniSuccessCallback(type, obj, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | HdlOtaLogic.getInstance().upgradeGatewayDriver(deviceOid, driverVersionId, new CloudCallBeak<Boolean>() { |
| | | @Override |
| | | public void onSuccess(Boolean obj) { |
| | | uniCallbackData(type, obj, callback); |
| | | uniSuccessCallback(type, obj, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | if (cUserInfo.getMemberHeadIcon().contains("http")) { |
| | | UserConfigManage.getInstance().setUserImageUrl(cUserInfo.getMemberHeadIcon()); |
| | | //更新用户头像 |
| | | uniCallbackData(type, cUserInfo, callback); |
| | | uniSuccessCallback(type, cUserInfo, callback); |
| | | } else { |
| | | HdlAccountLogic.getInstance().getImageKey_C(cUserInfo.getMemberHeadIcon(), new CloudCallBeak<String>() { |
| | | @Override |
| | | public void onSuccess(String url) { |
| | | cUserInfo.setMemberHeadIcon(url); |
| | | UserConfigManage.getInstance().setUserImageUrl(cUserInfo.getMemberHeadIcon()); |
| | | uniCallbackData(type, cUserInfo, callback); |
| | | uniSuccessCallback(type, cUserInfo, callback); |
| | | } |
| | | |
| | | @Override |
| | | public void onFailure(HDLException e) { |
| | | uniCallbackData(type, cUserInfo, callback); |
| | | uniSuccessCallback(type, cUserInfo, callback); |
| | | } |
| | | }); |
| | | } |
| | |
| | | HdlAccountLogic.getInstance().getImageKey_C(imageKey, new CloudCallBeak<String>() { |
| | | @Override |
| | | public void onSuccess(String url) { |
| | | uniCallbackData(type, url, callback); |
| | | uniSuccessCallback(type, url, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | HdlDeviceLogic.getInstance().clearInverterHomeId(mac, new LinkCallBack<Boolean>() { |
| | | @Override |
| | | public void onSuccess(Boolean obj) { |
| | | uniCallbackData(type, null, callback); |
| | | uniSuccessCallback(type, null, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | HdlMessageLogic.getInstance().getMessageUntreatedCount(homeId, new CloudCallBeak<UnCountBean>() { |
| | | @Override |
| | | public void onSuccess(UnCountBean data) { |
| | | uniCallbackData(type, data, callback); |
| | | uniSuccessCallback(type, data, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | HdlDeviceLogic.getInstance().editGatewayTime(mac, date, time, timezone, new LinkCallBack<Boolean>() { |
| | | @Override |
| | | public void onSuccess(Boolean obj) { |
| | | uniCallbackData(type, true, callback); |
| | | uniSuccessCallback(type, true, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | @Override |
| | | public void onSuccess(DeviceTimeBean deviceTimeBean) { |
| | | if (callback != null) { |
| | | uniCallbackData(type, deviceTimeBean, callback); |
| | | uniSuccessCallback(type, deviceTimeBean, callback); |
| | | } |
| | | } |
| | | |
| | |
| | | @Override |
| | | public void onSuccess(List<OidBean> list) { |
| | | if (callback != null) { |
| | | uniCallbackData(type, list, callback); |
| | | uniSuccessCallback(type, list, callback); |
| | | } |
| | | } |
| | | |
| | |
| | | HdlDeviceLogic.getInstance().addInverterDeviceToCloud(homeId, mac, gatewayBean.getGatewayType(), gatewayBean.getSid(), gatewayBean.getOid(), gatewayBean.getDevice_name(), new CloudCallBeak<Boolean>() { |
| | | @Override |
| | | public void onSuccess(Boolean obj) { |
| | | uniCallbackData(type, null, callback); |
| | | uniSuccessCallback(type, null, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | HdlDeviceLogic.getInstance().addAllInverterDeviceToCloud(homeId, list, new CloudCallBeak<Boolean>() { |
| | | @Override |
| | | public void onSuccess(Boolean obj) { |
| | | uniCallbackData(type, null, callback); |
| | | uniSuccessCallback(type, null, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | private void uniDelInverterDevice(String type, Object data, DCUniMPJSCallback callback) { |
| | | String deviceId = getKeyValue("deviceId", getKeyValue("data", data)); |
| | | String homeId = getKeyValue("homeId", getKeyValue("data", data)); |
| | | if (TextUtils.isEmpty(homeId)) { |
| | | homeId = UserConfigManage.getInstance().getHomeId(); |
| | | } |
| | | String mac = getKeyValue("mac", getKeyValue("data", data)); |
| | | HdlDeviceLogic.getInstance().delInverterDevice(homeId, deviceId, new CloudCallBeak<Boolean>() { |
| | | @Override |
| | | public void onSuccess(Boolean obj) { |
| | | uniCallbackData(type, null, callback); |
| | | //初始化逆变器设备 |
| | | HdlDeviceLogic.getInstance().initializeInverter(mac, null); |
| | | //移除本地缓存 |
| | | HdlDeviceLogic.getInstance().removeLocalCacheMemoryGatewayToDeviceId(homeId, deviceId); |
| | | uniSuccessCallback(type, null, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | HdlDeviceLogic.getInstance().searchAllNetworkGateway(new GatewayCallBack() { |
| | | @Override |
| | | public void onSuccess(List<GatewayBean> gatewayBeanList) { |
| | | uniCallbackData(type, gatewayBeanList, callback); |
| | | uniSuccessCallback(type, gatewayBeanList, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | public void onSuccess(List<GatewayBean> list) { |
| | | if (list == null || list.size() == 0) { |
| | | if (callback != null) { |
| | | uniCallbackData(type, list, callback); |
| | | uniSuccessCallback(type, list, callback); |
| | | } |
| | | return; |
| | | } |
| | | if (callback != null) { |
| | | uniCallbackData(type, list, callback); |
| | | uniSuccessCallback(type, list, callback); |
| | | } |
| | | //EventBus事件分发,进入住宅开始订阅主题 |
| | | BaseEventBus baseEventBus = new BaseEventBus(); |
| | |
| | | TcpClient.getInstance().sendDataToLinkGateway(mac, TopicApi.PROPERTY_DOWN, jay, "", new HDLLinkCallBack() { |
| | | @Override |
| | | public void onSuccess(String msg) { |
| | | uniCallbackData(type, msg, callback); |
| | | uniSuccessCallback(type, msg, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | Type typeOfT = new TypeToken<BaseLocalResponse<List<LinkBean>>>() { |
| | | }.getType(); |
| | | BaseLocalResponse<List<LinkBean>> baseLocalResponse = gson.fromJson(msg, typeOfT); |
| | | uniCallbackData(type, baseLocalResponse, callback); |
| | | uniSuccessCallback(type, baseLocalResponse, callback); |
| | | } catch (Exception e) { |
| | | uniCallbackData(type, msg, -2, "", callback); |
| | | } |
| | |
| | | // logMessage("tcp回复数据", 0, strings[0] + "\r\n" + json.toString()); |
| | | if (topic.endsWith("wifi/set_reply") || topic.endsWith("wifi/result/notify")) { |
| | | if (callback != null) { |
| | | uniCallbackData(type, json, callback); |
| | | uniSuccessCallback(type, json, callback); |
| | | } |
| | | if (json.has("mac")) { //回复成功再拿设备mac |
| | | // this.device_mac = json.getString("mac"); |
| | |
| | | HdlDeviceLogic.getInstance().initializeInverter(mac, new LinkCallBack<Boolean>() { |
| | | @Override |
| | | public void onSuccess(Boolean obj) { |
| | | uniCallbackData(type, obj, callback); |
| | | uniSuccessCallback(type, obj, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | HdlDeviceLogic.getInstance().setDeviceRemoteInfo(newList, homeId, new CloudCallBeak<List<GatewayBean>>() { |
| | | @Override |
| | | public void onSuccess(List<GatewayBean> obj) { |
| | | uniCallbackData(type, obj, callback); |
| | | uniSuccessCallback(type, obj, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | HdlDeviceLogic.getInstance().setRename(homeId, deviceType, deviceId, name, new CloudCallBeak<Boolean>() { |
| | | @Override |
| | | public void onSuccess(Boolean obj) { |
| | | uniCallbackData(type, obj, callback); |
| | | uniSuccessCallback(type, obj, callback); |
| | | } |
| | | |
| | | @Override |
| | |
| | | HDLModBusConnect.getInstance().Send(modBusBean.getMac(), modBusBean.getData(), new ModbusCallBack() { |
| | | @Override |
| | | public void onSuccess(int[] data) { |
| | | uniCallbackData(type, data, callback); |
| | | uniSuccessCallback(type, data, callback); |
| | | // HdlLogLogic.print("uni---接收---ModBus---" + Arrays.toString(data), true); |
| | | |
| | | } |
| | |
| | | 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发送数据格式 |
| | |
| | | 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); |
| | | } |
| | | |
| | | |
| | | } |
| | | |
| | | private void uniCallbackData(String type, Object obj, DCUniMPJSCallback callback) { |
| | | uniCallbackData(type, obj, HDLLinkCode.HDL_SUCCESS.getCode(), HDLLinkCode.HDL_SUCCESS.getMsg(), callback); |
| | | } |
| | | |
| | | /** |
| | | * 当前对象转 JSONObject |