From 44a361259bef44c5d8164d0910b7f7b806f2f17e Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期日, 06 九月 2020 21:56:20 +0800
Subject: [PATCH] 优化 手工抄表
---
service-api/src/main/java/com/java110/api/listener/meterWater/UpdateMeterWaterListener.java | 25 ++++++++++++++++++++++---
1 files changed, 22 insertions(+), 3 deletions(-)
diff --git a/service-api/src/main/java/com/java110/api/listener/meterWater/UpdateMeterWaterListener.java b/service-api/src/main/java/com/java110/api/listener/meterWater/UpdateMeterWaterListener.java
index 4f2263b..8adaabc 100644
--- a/service-api/src/main/java/com/java110/api/listener/meterWater/UpdateMeterWaterListener.java
+++ b/service-api/src/main/java/com/java110/api/listener/meterWater/UpdateMeterWaterListener.java
@@ -6,10 +6,16 @@
import com.java110.core.annotation.Java110Listener;
import com.java110.core.context.DataFlowContext;
import com.java110.core.event.service.api.ServiceDataFlowEvent;
+import com.java110.dto.meterWater.MeterWaterDto;
+import com.java110.intf.fee.IMeterWaterInnerServiceSMO;
+import com.java110.po.fee.PayFeePo;
+import com.java110.utils.constant.BusinessTypeConstant;
import com.java110.utils.constant.ServiceCodeMeterWaterConstant;
import com.java110.utils.util.Assert;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpMethod;
+
+import java.util.List;
/**
* 淇濆瓨姘寸數璐逛睛鍚�
@@ -21,13 +27,13 @@
@Autowired
private IMeterWaterBMO meterWaterBMOImpl;
+ @Autowired
+ private IMeterWaterInnerServiceSMO meterWaterInnerServiceSMOImpl;
+
@Override
protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
Assert.hasKeyAndValue(reqJson, "waterId", "waterId涓嶈兘涓虹┖");
- Assert.hasKeyAndValue(reqJson, "meterType", "璇锋眰鎶ユ枃涓湭鍖呭惈meterType");
- Assert.hasKeyAndValue(reqJson, "objType", "璇锋眰鎶ユ枃涓湭鍖呭惈objType");
- Assert.hasKeyAndValue(reqJson, "objId", "璇锋眰鎶ユ枃涓湭鍖呭惈objId");
Assert.hasKeyAndValue(reqJson, "preDegrees", "璇锋眰鎶ユ枃涓湭鍖呭惈preDegrees");
Assert.hasKeyAndValue(reqJson, "curDegrees", "璇锋眰鎶ユ枃涓湭鍖呭惈curDegrees");
Assert.hasKeyAndValue(reqJson, "preReadingTime", "璇锋眰鎶ユ枃涓湭鍖呭惈preReadingTime");
@@ -39,6 +45,19 @@
@Override
protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
+ MeterWaterDto meterWaterDto = new MeterWaterDto();
+ meterWaterDto.setWaterId(reqJson.getString("waterId"));
+ meterWaterDto.setCommunityId(reqJson.getString("communityId"));
+ List<MeterWaterDto> meterWaterDtos = meterWaterInnerServiceSMOImpl.queryMeterWaters(meterWaterDto);
+
+ Assert.listOnlyOne(meterWaterDtos, "鏁版嵁寮傚父鏈壘鍒拌垂鐢ㄤ俊鎭�");
+
+ PayFeePo payFeePo = new PayFeePo();
+ payFeePo.setFeeId(meterWaterDtos.get(0).getFeeId());
+ payFeePo.setCommunityId(meterWaterDtos.get(0).getCommunityId());
+ payFeePo.setStartTime(reqJson.getString("preReadingTime"));
+ payFeePo.setEndTime(reqJson.getString("curReadingTime"));
+ super.update(context, payFeePo, BusinessTypeConstant.BUSINESS_TYPE_ONLY_UPDATE_FEE_INFO);
meterWaterBMOImpl.updateMeterWater(reqJson, context);
}
--
Gitblit v1.8.0