| | |
| | | package com.java110.web.smo.impl; |
| | | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.java110.common.constant.PrivilegeCodeConstant; |
| | | import com.java110.common.constant.ResponseConstant; |
| | | import com.java110.common.constant.ServiceConstant; |
| | | import com.java110.common.exception.SMOException; |
| | | import com.java110.common.util.Assert; |
| | | import com.java110.utils.constant.PrivilegeCodeConstant; |
| | | import com.java110.utils.constant.ResponseConstant; |
| | | import com.java110.utils.constant.ServiceConstant; |
| | | import com.java110.utils.exception.SMOException; |
| | | import com.java110.utils.util.Assert; |
| | | import com.java110.core.context.IPageData; |
| | | import com.java110.entity.component.ComponentValidateResult; |
| | | import com.java110.web.core.BaseComponentSMO; |
| | | import com.java110.web.smo.IFloorServiceSMO; |
| | | import org.slf4j.Logger; |
| | |
| | | |
| | | private static Logger logger = LoggerFactory.getLogger(FloorServiceSMOImpl.class); |
| | | |
| | | private static final int MAX_ROW = 50; |
| | | |
| | | |
| | | @Autowired |
| | | private RestTemplate restTemplate; |
| | | |
| | | /** |
| | | * 查询 楼栋 |
| | | * @param pd 页面数据封装对象 |
| | | * @return 返回 ResponseEntity对象包含 http状态 信息 body信息 |
| | | */ |
| | | public ResponseEntity<String> getFloor(IPageData pd){ |
| | | JSONObject paramIn = JSONObject.parseObject(pd.getReqData()); |
| | | paramIn.put("page",1); |
| | | paramIn.put("row",1); |
| | | super.checkUserHasPrivilege(pd, restTemplate, PrivilegeCodeConstant.PRIVILEGE_FLOOR); |
| | | |
| | | ComponentValidateResult result = super.validateStoreStaffCommunityRelationship(pd, restTemplate); |
| | | |
| | | ResponseEntity responseEntity = this.callCenterService(restTemplate, pd, "", |
| | | ServiceConstant.SERVICE_API_URL + "/api/floor.queryFloors" + mapToUrlParam(paramIn), |
| | | HttpMethod.GET); |
| | | |
| | | return responseEntity; |
| | | } |
| | | |
| | | /** |
| | | * 查询小区楼 |
| | |
| | | */ |
| | | @Override |
| | | public ResponseEntity<String> listFloor(IPageData pd) { |
| | | |
| | | validateListFloor(pd); |
| | | |
| | | JSONObject paramIn = JSONObject.parseObject(pd.getReqData()); |
| | | if(paramIn.containsKey("row")){ |
| | | paramIn.put("rows",paramIn.getString("row")); |
| | | } |
| | | validateListFloor(pd,paramIn); |
| | | |
| | | int page = Integer.parseInt(paramIn.getString("page")); |
| | | int rows = Integer.parseInt(paramIn.getString("rows")); |
| | | String communityId = paramIn.getString("communityId"); |
| | | |
| | | //小区楼编号 |
| | | String floorNum = paramIn.getString("floorNum"); |
| | | |
| | | |
| | | //校验用户是否有权限 |
| | |
| | | String storeTypeCd = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeTypeCd"); |
| | | //数据校验是否 商户是否入驻该小区 |
| | | super.checkStoreEnterCommunity(pd, storeId, storeTypeCd, communityId, restTemplate); |
| | | String apiUrl = ServiceConstant.SERVICE_API_URL + "/api/floor.queryFloors" + mapToUrlParam(paramIn); |
| | | |
| | | responseEntity = this.callCenterService(restTemplate, pd, "", |
| | | ServiceConstant.SERVICE_API_URL + "/api/floor.queryFloors?row=" + rows + "&page=" + page + "&communityId=" + communityId, |
| | | apiUrl, |
| | | HttpMethod.GET); |
| | | |
| | | if (responseEntity.getStatusCode() != HttpStatus.OK) { |
| | |
| | | |
| | | validateSaveFloor(pd); |
| | | |
| | | //校验员工是否有权限操作 |
| | | super.checkUserHasPrivilege(pd, restTemplate, PrivilegeCodeConstant.PRIVILEGE_FLOOR); |
| | | |
| | | JSONObject paramIn = JSONObject.parseObject(pd.getReqData()); |
| | | String communityId = paramIn.getString("paramIn"); |
| | | String communityId = paramIn.getString("communityId"); |
| | | ResponseEntity responseEntity = super.getStoreInfo(pd, restTemplate); |
| | | if (responseEntity.getStatusCode() != HttpStatus.OK) { |
| | | return responseEntity; |
| | |
| | | } |
| | | |
| | | /** |
| | | * 编辑小区楼信息 |
| | | * |
| | | * @param pd 页面数据封装对象 |
| | | * @return |
| | | */ |
| | | @Override |
| | | public ResponseEntity<String> editFloor(IPageData pd) { |
| | | |
| | | validateEditFloor(pd); |
| | | |
| | | //校验员工是否有权限操作 |
| | | super.checkUserHasPrivilege(pd, restTemplate, PrivilegeCodeConstant.PRIVILEGE_FLOOR); |
| | | |
| | | JSONObject paramIn = JSONObject.parseObject(pd.getReqData()); |
| | | String communityId = paramIn.getString("communityId"); |
| | | ResponseEntity responseEntity = super.getStoreInfo(pd, restTemplate); |
| | | if (responseEntity.getStatusCode() != HttpStatus.OK) { |
| | | return responseEntity; |
| | | } |
| | | Assert.jsonObjectHaveKey(responseEntity.getBody().toString(), "storeId", "根据用户ID查询商户ID失败,未包含storeId节点"); |
| | | Assert.jsonObjectHaveKey(responseEntity.getBody().toString(), "storeTypeCd", "根据用户ID查询商户类型失败,未包含storeTypeCd节点"); |
| | | |
| | | String storeId = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeId"); |
| | | String storeTypeCd = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeTypeCd"); |
| | | //数据校验是否 商户是否入驻该小区 |
| | | super.checkStoreEnterCommunity(pd, storeId, storeTypeCd, communityId, restTemplate); |
| | | paramIn.put("userId", pd.getUserId()); |
| | | paramIn.put("name", paramIn.getString("floorName")); |
| | | responseEntity = this.callCenterService(restTemplate, pd, paramIn.toJSONString(), |
| | | ServiceConstant.SERVICE_API_URL + "/api/floor.editFloor", |
| | | HttpMethod.POST); |
| | | |
| | | return responseEntity; |
| | | } |
| | | |
| | | @Override |
| | | public ResponseEntity<String> deleteFloor(IPageData pd) { |
| | | validateDeleteFloor(pd); |
| | | //校验员工是否有权限操作 |
| | | super.checkUserHasPrivilege(pd, restTemplate, PrivilegeCodeConstant.PRIVILEGE_FLOOR); |
| | | JSONObject paramIn = JSONObject.parseObject(pd.getReqData()); |
| | | String communityId = paramIn.getString("communityId"); |
| | | ResponseEntity responseEntity = super.getStoreInfo(pd, restTemplate); |
| | | if (responseEntity.getStatusCode() != HttpStatus.OK) { |
| | | return responseEntity; |
| | | } |
| | | Assert.jsonObjectHaveKey(responseEntity.getBody().toString(), "storeId", "根据用户ID查询商户ID失败,未包含storeId节点"); |
| | | Assert.jsonObjectHaveKey(responseEntity.getBody().toString(), "storeTypeCd", "根据用户ID查询商户类型失败,未包含storeTypeCd节点"); |
| | | |
| | | String storeId = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeId"); |
| | | String storeTypeCd = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeTypeCd"); |
| | | //数据校验是否 商户是否入驻该小区 |
| | | super.checkStoreEnterCommunity(pd, storeId, storeTypeCd, communityId, restTemplate); |
| | | |
| | | responseEntity = this.callCenterService(restTemplate, pd, paramIn.toJSONString(), |
| | | ServiceConstant.SERVICE_API_URL + "/api/floor.deleteFloor", |
| | | HttpMethod.POST); |
| | | |
| | | return responseEntity; |
| | | } |
| | | |
| | | /** |
| | | * 删除小区楼 校验 |
| | | * |
| | | * @param pd 页面数据封装 |
| | | */ |
| | | private void validateDeleteFloor(IPageData pd) { |
| | | |
| | | Assert.jsonObjectHaveKey(pd.getReqData(), "communityId", "未包含小区ID"); |
| | | Assert.jsonObjectHaveKey(pd.getReqData(), "floorId", "未包含小区楼ID"); |
| | | |
| | | } |
| | | |
| | | /** |
| | | * 校验保存小区楼 信息 |
| | | * |
| | | * @param pd 页面数据封装 |
| | | */ |
| | | private void validateEditFloor(IPageData pd) { |
| | | Assert.jsonObjectHaveKey(pd.getReqData(), "communityId", "未包含小区ID"); |
| | | Assert.jsonObjectHaveKey(pd.getReqData(), "floorId", "未包含小区楼ID"); |
| | | Assert.jsonObjectHaveKey(pd.getReqData(), "floorName", "未包含小区楼名称"); |
| | | Assert.jsonObjectHaveKey(pd.getReqData(), "floorNum", "未包含小区楼编码"); |
| | | Assert.jsonObjectHaveKey(pd.getReqData(), "remark", "未包含小区楼备注"); |
| | | } |
| | | |
| | | /** |
| | | * 校验保存小区楼 信息 |
| | | * |
| | | * @param pd 页面数据封装 |
| | | */ |
| | | private void validateSaveFloor(IPageData pd) { |
| | | Assert.jsonObjectHaveKey(pd.getReqData(), "communityId", "未包含小区ID"); |
| | | Assert.jsonObjectHaveKey(pd.getReqData(), "name", "未包含小区名称"); |
| | | Assert.jsonObjectHaveKey(pd.getReqData(), "floorNum", "未包含小区编码"); |
| | | Assert.jsonObjectHaveKey(pd.getReqData(), "remark", "未包含小区备注"); |
| | | Assert.jsonObjectHaveKey(pd.getReqData(), "name", "未包含小区楼名称"); |
| | | Assert.jsonObjectHaveKey(pd.getReqData(), "floorNum", "未包含小区楼编码"); |
| | | Assert.jsonObjectHaveKey(pd.getReqData(), "remark", "未包含小区楼备注"); |
| | | } |
| | | |
| | | /** |
| | |
| | | * |
| | | * @param pd 页面封装对象 |
| | | */ |
| | | private void validateListFloor(IPageData pd) { |
| | | Assert.jsonObjectHaveKey(pd.getReqData(), "page", "请求报文中未包含page节点"); |
| | | Assert.jsonObjectHaveKey(pd.getReqData(), "rows", "请求报文中未包含rows节点"); |
| | | Assert.jsonObjectHaveKey(pd.getReqData(), "communityId", "请求报文中未包含communityId节点"); |
| | | JSONObject paramIn = JSONObject.parseObject(pd.getReqData()); |
| | | private void validateListFloor(IPageData pd, JSONObject paramIn) { |
| | | Assert.jsonObjectHaveKey(paramIn, "page", "请求报文中未包含page节点"); |
| | | Assert.jsonObjectHaveKey(paramIn, "rows", "请求报文中未包含rows节点"); |
| | | Assert.jsonObjectHaveKey(paramIn, "communityId", "请求报文中未包含communityId节点"); |
| | | //JSONObject paramIn = JSONObject.parseObject(pd.getReqData()); |
| | | Assert.isInteger(paramIn.getString("page"), "page不是数字"); |
| | | Assert.isInteger(paramIn.getString("rows"), "rows不是数字"); |
| | | Assert.hasLength(paramIn.getString("communityId"), "小区ID不能为空"); |