From 727051b5955d816ae70a6572ac0279b448bec43d Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期日, 06 九月 2020 21:00:49 +0800
Subject: [PATCH] 优化代码
---
service-api/src/main/java/com/java110/api/listener/meterWater/SaveMeterWaterListener.java | 38 +++++++++++++++++++++++++++++++++++++-
1 files changed, 37 insertions(+), 1 deletions(-)
diff --git a/service-api/src/main/java/com/java110/api/listener/meterWater/SaveMeterWaterListener.java b/service-api/src/main/java/com/java110/api/listener/meterWater/SaveMeterWaterListener.java
index 55a8f9e..70b43aa 100644
--- a/service-api/src/main/java/com/java110/api/listener/meterWater/SaveMeterWaterListener.java
+++ b/service-api/src/main/java/com/java110/api/listener/meterWater/SaveMeterWaterListener.java
@@ -1,13 +1,22 @@
package com.java110.api.listener.meterWater;
import com.alibaba.fastjson.JSONObject;
+import com.java110.api.bmo.fee.IFeeBMO;
import com.java110.api.bmo.meterWater.IMeterWaterBMO;
import com.java110.api.listener.AbstractServiceApiPlusListener;
import com.java110.core.annotation.Java110Listener;
import com.java110.core.context.DataFlowContext;
import com.java110.core.event.service.api.ServiceDataFlowEvent;
+import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.dto.fee.FeeConfigDto;
+import com.java110.dto.fee.FeeDto;
+import com.java110.po.fee.PayFeePo;
+import com.java110.utils.constant.BusinessTypeConstant;
+import com.java110.utils.constant.CommonConstant;
import com.java110.utils.constant.ServiceCodeMeterWaterConstant;
import com.java110.utils.util.Assert;
+import com.java110.utils.util.BeanConvertUtil;
+import com.java110.utils.util.DateUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpMethod;
@@ -21,11 +30,15 @@
@Autowired
private IMeterWaterBMO meterWaterBMOImpl;
+ @Autowired
+ private IFeeBMO feeBMOImpl;
+
@Override
protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
//Assert.hasKeyAndValue(reqJson, "xxx", "xxx");
- Assert.hasKeyAndValue(reqJson, "meterType", "璇锋眰鎶ユ枃涓湭鍖呭惈meterType");
+ Assert.hasKeyAndValue(reqJson, "feeTypeCd", "璇锋眰鎶ユ枃涓湭鍖呭惈璐圭敤绫诲瀷");
+ Assert.hasKeyAndValue(reqJson, "configId", "璇锋眰鎶ユ枃涓湭鍖呭惈璐圭敤椤�");
Assert.hasKeyAndValue(reqJson, "objType", "璇锋眰鎶ユ枃涓湭鍖呭惈objType");
Assert.hasKeyAndValue(reqJson, "objId", "璇锋眰鎶ユ枃涓湭鍖呭惈objId");
Assert.hasKeyAndValue(reqJson, "preDegrees", "璇锋眰鎶ユ枃涓湭鍖呭惈preDegrees");
@@ -38,6 +51,29 @@
@Override
protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
+
+ if (FeeConfigDto.FEE_TYPE_CD_WATER.equals(reqJson.getString("feeTypeCd"))) {
+ reqJson.put("meterType", "1010");
+ } else {
+ reqJson.put("meterType", "2020");
+ }
+
+ PayFeePo payFeePo = BeanConvertUtil.covertBean(reqJson, PayFeePo.class);
+ payFeePo.setFeeId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_feeId));
+ payFeePo.setIncomeObjId(reqJson.getString("storeId"));
+ payFeePo.setAmount("-1");
+ payFeePo.setStartTime(reqJson.getString("preDegrees"));
+ payFeePo.setEndTime(reqJson.getString("preDegrees"));
+ payFeePo.setPayerObjId(reqJson.getString("objId"));
+ payFeePo.setPayerObjType(FeeDto.PAYER_OBJ_TYPE_ROOM);
+ payFeePo.setFeeFlag(FeeDto.FEE_FLAG_ONCE);
+ payFeePo.setState(FeeDto.STATE_DOING);
+ payFeePo.setUserId(context.getRequestCurrentHeaders().get(CommonConstant.HTTP_USER_ID));
+
+ super.insert(context, payFeePo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_FEE_INFO);
+
+ reqJson.put("feeId",payFeePo.getFeeId());
+
meterWaterBMOImpl.addMeterWater(reqJson, context);
}
--
Gitblit v1.8.0