| | |
| | | |
| | | import com.alibaba.fastjson.JSONArray; |
| | | 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.web.core.BaseComponentSMO; |
| | | import com.java110.core.component.BaseComponentSMO; |
| | | import com.java110.web.smo.ICarServiceSMO; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | |
| | | //数据校验是否 商户是否入驻该小区 |
| | | super.checkStoreEnterCommunity(pd, storeId, storeTypeCd, communityId, restTemplate); |
| | | |
| | | JSONObject viewSelectParkingSpace = this.getObj(infos,"viewSelectParkingSpace"); |
| | | JSONObject viewOwnerInfo = this.getObj(infos,"viewOwnerInfo"); |
| | | JSONObject addCar = this.getObj(infos,"addCar"); |
| | | JSONObject hireParkingSpaceFee = this.getObj(infos,"hireParkingSpaceFee"); |
| | | JSONObject viewSelectParkingSpace = this.getObj(infos, "viewSelectParkingSpace"); |
| | | JSONObject viewOwnerInfo = this.getObj(infos, "viewOwnerInfo"); |
| | | JSONObject addCar = this.getObj(infos, "addCar"); |
| | | JSONObject parkingSpaceFee = null; |
| | | if(hasThisFlowComponent(infos, "hireParkingSpaceFee")) { |
| | | parkingSpaceFee = this.getObj(infos, "hireParkingSpaceFee"); |
| | | }else{ |
| | | parkingSpaceFee = this.getObj(infos, "sellParkingSpaceFee"); |
| | | } |
| | | JSONObject newParamIn = new JSONObject(); |
| | | newParamIn.putAll(addCar); |
| | | newParamIn.putAll(hireParkingSpaceFee); |
| | | newParamIn.putAll(parkingSpaceFee); |
| | | newParamIn.put("communityId", communityId); |
| | | newParamIn.put("ownerId", viewOwnerInfo.getString("ownerId")); |
| | | newParamIn.put("psId", viewSelectParkingSpace.getString("psId")); |
| | |
| | | return responseEntity; |
| | | } |
| | | |
| | | @Override |
| | | public ResponseEntity<String> listCarType(IPageData pd) { |
| | | //获取请求参数 |
| | | JSONObject reqParam = JSONObject.parseObject(pd.getReqData()); |
| | | //拉取数据 |
| | | String url=ServiceConstant.SERVICE_API_URL.concat("/api/dict.type").concat(mapToUrlParam(reqParam)); |
| | | ResponseEntity<String> responseEntity = this.callCenterService(restTemplate, pd, "",url , HttpMethod.GET); |
| | | return responseEntity; |
| | | } |
| | | |
| | | /** |
| | | * 删除小区楼 校验 |
| | | * |
| | |
| | | |
| | | JSONArray infos = info.getJSONArray("data"); |
| | | |
| | | if(infos.size() != 4){ |
| | | if (infos.size() != 4) { |
| | | throw new IllegalArgumentException("数据被篡改"); |
| | | } |
| | | |
| | |
| | | Assert.hasKeyByFlowData(infos, "addCar", "carBrand", "请求报文中未包含carBrand"); |
| | | Assert.hasKeyByFlowData(infos, "addCar", "carType", "请求报文中未包含carType"); |
| | | Assert.hasKeyByFlowData(infos, "addCar", "carColor", "未包含carColor"); |
| | | Assert.hasKeyByFlowData(infos, "hireParkingSpaceFee", "receivedAmount", "未包含receivedAmount"); |
| | | Assert.hasKeyByFlowData(infos, "hireParkingSpaceFee", "sellOrHire", "未包含sellOrHire"); |
| | | |
| | | JSONObject viewSelectParkingSpace = this.getObj(infos,"viewSelectParkingSpace"); |
| | | JSONObject viewOwnerInfo = this.getObj(infos,"viewOwnerInfo"); |
| | | JSONObject addCar = this.getObj(infos,"addCar"); |
| | | JSONObject hireParkingSpaceFee = this.getObj(infos,"hireParkingSpaceFee"); |
| | | JSONObject parkingSpaceFee = null; |
| | | if (hasThisFlowComponent(infos, "hireParkingSpaceFee")) { |
| | | Assert.hasKeyByFlowData(infos, "hireParkingSpaceFee", "receivedAmount", "未包含receivedAmount"); |
| | | Assert.hasKeyByFlowData(infos, "hireParkingSpaceFee", "sellOrHire", "未包含sellOrHire"); |
| | | parkingSpaceFee = this.getObj(infos, "hireParkingSpaceFee"); |
| | | }else{ |
| | | Assert.hasKeyByFlowData(infos, "sellParkingSpaceFee", "receivedAmount", "未包含receivedAmount"); |
| | | Assert.hasKeyByFlowData(infos, "sellParkingSpaceFee", "sellOrHire", "未包含sellOrHire"); |
| | | parkingSpaceFee = this.getObj(infos, "sellParkingSpaceFee"); |
| | | } |
| | | |
| | | JSONObject viewSelectParkingSpace = this.getObj(infos, "viewSelectParkingSpace"); |
| | | JSONObject viewOwnerInfo = this.getObj(infos, "viewOwnerInfo"); |
| | | JSONObject addCar = this.getObj(infos, "addCar"); |
| | | |
| | | |
| | | Assert.hasLength(info.getString("communityId"), "小区ID不能为空"); |
| | | Assert.hasLength(viewOwnerInfo.getString("ownerId"), "ownerId不能为空"); |
| | | Assert.hasLength(viewSelectParkingSpace.getString("psId"), "psId不能为空"); |
| | | Assert.hasLength(hireParkingSpaceFee.getString("receivedAmount"), "receivedAmount不能为空"); |
| | | Assert.hasLength(parkingSpaceFee.getString("receivedAmount"), "receivedAmount不能为空"); |
| | | |
| | | if(!"H".equals(hireParkingSpaceFee.getString("sellOrHire")) |
| | | && !"S".equals(hireParkingSpaceFee.getString("sellOrHire"))){ |
| | | if (!"H".equals(parkingSpaceFee.getString("sellOrHire")) |
| | | && !"S".equals(parkingSpaceFee.getString("sellOrHire"))) { |
| | | throw new IllegalArgumentException("入参错误,无法识别该操作"); |
| | | } |
| | | |
| | | if("H".equals(hireParkingSpaceFee.getString("sellOrHire"))){ |
| | | Assert.jsonObjectHaveKey(hireParkingSpaceFee, "cycles", "未包含cycles"); |
| | | Assert.hasLength(hireParkingSpaceFee.getString("cycles"), "cycles不能为空"); |
| | | if ("H".equals(parkingSpaceFee.getString("sellOrHire"))) { |
| | | Assert.jsonObjectHaveKey(parkingSpaceFee, "cycles", "未包含cycles"); |
| | | Assert.hasLength(parkingSpaceFee.getString("cycles"), "cycles不能为空"); |
| | | } |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | } |
| | | |
| | | /** |
| | | * 校验查询小区楼信息 |
| | | * |
| | |
| | | throw new IllegalArgumentException("未找到组件编码为【" + flowComponent + "】数据"); |
| | | } |
| | | |
| | | /** |
| | | * 是否有 这个组件 |
| | | * |
| | | * @param infos 所有组件信息 |
| | | * @param currentFlowComponent 当前组件 |
| | | * @return |
| | | */ |
| | | private boolean hasThisFlowComponent(JSONArray infos, String currentFlowComponent) { |
| | | JSONObject serviceInfo = null; |
| | | |
| | | for (int infoIndex = 0; infoIndex < infos.size(); infoIndex++) { |
| | | serviceInfo = infos.getJSONObject(infoIndex); |
| | | |
| | | if (currentFlowComponent.equals(serviceInfo.getString("flowComponent"))) { |
| | | return true; |
| | | } |
| | | |
| | | } |
| | | |
| | | return false; |
| | | } |
| | | |
| | | |
| | | public RestTemplate getRestTemplate() { |
| | | return restTemplate; |