From 0b3ff378a9faaf9d7a4831b7f0de67378fe0dfea Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期二, 30 五月 2023 12:20:15 +0800
Subject: [PATCH] optimize 统计
---
service-fee/src/main/java/com/java110/fee/cmd/meterWater/SaveMeterWaterCmd.java | 16 ++++++++++------
1 files changed, 10 insertions(+), 6 deletions(-)
diff --git a/service-fee/src/main/java/com/java110/fee/cmd/meterWater/SaveMeterWaterCmd.java b/service-fee/src/main/java/com/java110/fee/cmd/meterWater/SaveMeterWaterCmd.java
index 62dd3fc..547f43e 100644
--- a/service-fee/src/main/java/com/java110/fee/cmd/meterWater/SaveMeterWaterCmd.java
+++ b/service-fee/src/main/java/com/java110/fee/cmd/meterWater/SaveMeterWaterCmd.java
@@ -71,7 +71,6 @@
public static final String CODE_PREFIX_ID = "10";
-
@Autowired
private IRoomInnerServiceSMO roomInnerServiceSMOImpl;
@@ -87,7 +86,6 @@
@Autowired
private IOwnerInnerServiceSMO ownerInnerServiceSMOImpl;
-
@Autowired
private IPayFeeBatchV1InnerServiceSMO payFeeBatchV1InnerServiceSMOImpl;
@@ -96,7 +94,6 @@
@Autowired
private IMeterWaterV1InnerServiceSMO meterWaterV1InnerServiceSMOImpl;
-
@Autowired
private IPayFeeV1InnerServiceSMO payFeeV1InnerServiceSMOImpl;
@@ -117,12 +114,14 @@
Assert.hasKeyAndValue(reqJson, "objType", "璇锋眰鎶ユ枃涓湭鍖呭惈objType");
Assert.hasKeyAndValue(reqJson, "meterType", "璇锋眰鎶ユ枃涓湭鍖呭惈鎶勮〃绫诲瀷");
+ if(reqJson.getDoubleValue("curDegrees") < reqJson.getDoubleValue("preDegrees")){
+ throw new CmdException("褰撳墠璇绘暟灏忎簬涓婃湡璇绘暟");
+ }
}
@Override
@Java110Transactional
public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
-
String objId = reqJson.getString("objId");
RoomDto roomDto = new RoomDto();
roomDto.setRoomId(objId);
@@ -168,6 +167,7 @@
payFeePo.setEndTime(reqJson.getString("preReadingTime"));
payFeePo.setPayerObjId(reqJson.getString("objId"));
//payFeePo.setPayerObjType(FeeDto.PAYER_OBJ_TYPE_ROOM);
+ payFeePo.setbId("-1");
payFeePo.setPayerObjType(reqJson.getString("objType"));
payFeePo.setFeeFlag(FeeDto.FEE_FLAG_ONCE);
payFeePo.setState(FeeDto.STATE_DOING);
@@ -231,22 +231,26 @@
}
cmdDataFlowContext.setResponseEntity(ResultVo.success());
}
+
/**
* 娣诲姞灏忓尯淇℃伅
*
- * @param paramInJson 鎺ュ彛璋冪敤鏀句紶鍏ュ叆鍙�
+ * @param paramInJson 鎺ュ彛璋冪敤鏀句紶鍏ュ叆鍙�
* @return 璁㈠崟鏈嶅姟鑳藉鎺ュ彈鐨勬姤鏂�
*/
public void addMeterWater(JSONObject paramInJson) {
MeterWaterPo meterWaterPo = BeanConvertUtil.covertBean(paramInJson, MeterWaterPo.class);
+ if (StringUtil.isEmpty(meterWaterPo.getbId())) {
+ meterWaterPo.setbId("-1");
+ }
meterWaterPo.setWaterId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID));
+
int flag = meterWaterV1InnerServiceSMOImpl.saveMeterWater(meterWaterPo);
if (flag < 1) {
throw new CmdException("淇濆瓨鏁版嵁澶辫触");
}
}
-
/**
--
Gitblit v1.8.0