| | |
| | | import com.java110.core.context.DataFlowContext; |
| | | import com.java110.core.smo.junkRequirement.IJunkRequirementInnerServiceSMO; |
| | | import com.java110.dto.junkRequirement.JunkRequirementDto; |
| | | import com.java110.po.file.FileRelPo; |
| | | import com.java110.po.junkRequirement.JunkRequirementPo; |
| | | import com.java110.utils.constant.BusinessTypeConstant; |
| | | import com.java110.utils.constant.CommonConstant; |
| | | import com.java110.utils.util.Assert; |
| | |
| | | * @param dataFlowContext 数据上下文 |
| | | * @return 订单服务能够接受的报文 |
| | | */ |
| | | public JSONObject addJunkRequirement(JSONObject paramInJson, DataFlowContext dataFlowContext) { |
| | | public void addJunkRequirement(JSONObject paramInJson, DataFlowContext dataFlowContext) { |
| | | |
| | | |
| | | JSONObject business = JSONObject.parseObject("{\"datas\":{}}"); |
| | | business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_SAVE_JUNK_REQUIREMENT); |
| | | business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ); |
| | | business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S); |
| | | JSONObject businessJunkRequirement = new JSONObject(); |
| | | businessJunkRequirement.putAll(paramInJson); |
| | | businessJunkRequirement.put("junkRequirementId", "-1"); |
| | | //计算 应收金额 |
| | | business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessJunkRequirement", businessJunkRequirement); |
| | | return business; |
| | | if (!paramInJson.containsKey("junkRequirementId")) { |
| | | businessJunkRequirement.put("junkRequirementId", "-1"); |
| | | } |
| | | JunkRequirementPo junkRequirementPo = BeanConvertUtil.covertBean(businessJunkRequirement, JunkRequirementPo.class); |
| | | |
| | | super.insert(dataFlowContext, junkRequirementPo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_JUNK_REQUIREMENT); |
| | | |
| | | } |
| | | |
| | | |
| | |
| | | * @param dataFlowContext 数据上下文 |
| | | * @return 订单服务能够接受的报文 |
| | | */ |
| | | public JSONObject updateJunkRequirement(JSONObject paramInJson, DataFlowContext dataFlowContext) { |
| | | public void updateJunkRequirement(JSONObject paramInJson, DataFlowContext dataFlowContext) { |
| | | |
| | | JunkRequirementDto junkRequirementDto = new JunkRequirementDto(); |
| | | junkRequirementDto.setJunkRequirementId(paramInJson.getString("junkRequirementId")); |
| | |
| | | |
| | | Assert.listOnlyOne(junkRequirementDtos, "未找到需要修改的活动 或多条数据"); |
| | | |
| | | |
| | | JSONObject business = JSONObject.parseObject("{\"datas\":{}}"); |
| | | business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_UPDATE_JUNK_REQUIREMENT); |
| | | business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ); |
| | | business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S); |
| | | JSONObject businessJunkRequirement = new JSONObject(); |
| | | businessJunkRequirement.putAll(BeanConvertUtil.beanCovertMap(junkRequirementDtos.get(0))); |
| | | businessJunkRequirement.putAll(paramInJson); |
| | | //计算 应收金额 |
| | | business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessJunkRequirement", businessJunkRequirement); |
| | | return business; |
| | | JunkRequirementPo junkRequirementPo = BeanConvertUtil.covertBean(businessJunkRequirement, JunkRequirementPo.class); |
| | | |
| | | super.update(dataFlowContext, junkRequirementPo, BusinessTypeConstant.BUSINESS_TYPE_UPDATE_JUNK_REQUIREMENT); |
| | | } |
| | | |
| | | |
| | |
| | | * @param dataFlowContext 数据上下文 |
| | | * @return 订单服务能够接受的报文 |
| | | */ |
| | | public JSONObject deleteJunkRequirement(JSONObject paramInJson, DataFlowContext dataFlowContext) { |
| | | public void deleteJunkRequirement(JSONObject paramInJson, DataFlowContext dataFlowContext) { |
| | | |
| | | |
| | | JSONObject business = JSONObject.parseObject("{\"datas\":{}}"); |
| | | business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_DELETE_JUNK_REQUIREMENT); |
| | | business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ); |
| | | business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S); |
| | | JSONObject businessJunkRequirement = new JSONObject(); |
| | | businessJunkRequirement.putAll(paramInJson); |
| | | //计算 应收金额 |
| | | business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessJunkRequirement", businessJunkRequirement); |
| | | return business; |
| | | JunkRequirementPo junkRequirementPo = BeanConvertUtil.covertBean(paramInJson, JunkRequirementPo.class); |
| | | |
| | | super.delete(dataFlowContext, junkRequirementPo, BusinessTypeConstant.BUSINESS_TYPE_DELETE_JUNK_REQUIREMENT); |
| | | } |
| | | |
| | | /** |
| | | * 添加物业费用 |
| | | * |
| | | * @param paramInJson 接口调用放传入入参 |
| | | * @param dataFlowContext 数据上下文 |
| | | * @return 订单服务能够接受的报文 |
| | | */ |
| | | public void addPhoto(JSONObject paramInJson, DataFlowContext dataFlowContext) { |
| | | |
| | | JSONObject businessUnit = new JSONObject(); |
| | | businessUnit.put("fileRelId", "-1"); |
| | | businessUnit.put("relTypeCd", "80000"); |
| | | businessUnit.put("saveWay", "ftp"); |
| | | businessUnit.put("objId", paramInJson.getString("junkRequirementId")); |
| | | businessUnit.put("fileRealName", paramInJson.getString("photoId")); |
| | | businessUnit.put("fileSaveName", paramInJson.getString("fileSaveName")); |
| | | FileRelPo fileRelPo = BeanConvertUtil.covertBean(businessUnit, FileRelPo.class); |
| | | |
| | | super.insert(dataFlowContext, fileRelPo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_FILE_REL); |
| | | } |
| | | |
| | | } |