From a15a8cfd7b01ce4bba6fe9fd876f6704ca23a12d Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期二, 07 一月 2025 16:40:32 +0800
Subject: [PATCH] 1、取水口用水日统计表中增加金额、次数字段; 2、优化或重写“累计流量超过指定值的取水口”、“累计流量低于指定值的取水口”、“指定时间段内用水量超过指定值的取水口”、“指定时间段内消费金额超过指定值的取水口”几个统计查询; 3、改“指定时间段内用水时长超过指定值的取水口”为“指定时间段内用水次数超过指定值的取水口”

---
 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmOpenCloseValveHistory.java |  142 +++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 131 insertions(+), 11 deletions(-)

diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmOpenCloseValveHistory.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmOpenCloseValveHistory.java
index c8510df..33cb325 100644
--- a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmOpenCloseValveHistory.java
+++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmOpenCloseValveHistory.java
@@ -1,8 +1,7 @@
 package com.dy.pipIrrGlobal.pojoRm;
 
-import com.dy.common.mw.protocol.p206V1_0_0.DataV1_0_1;
-import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCd83CloseVo;
-import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCd83OpenVo;
+import com.dy.common.mw.protocol.p206V1.DataV1;
+import com.dy.common.mw.protocol.p206V2.DataV2;
 import com.dy.common.mw.protocol.p206V202404.DataV202404;
 import com.dy.common.mw.protocol.p206V202404.upVos.DataCd84Vo;
 import com.dy.common.mw.protocol.p206V202404.upVos.DataCd85Vo;
@@ -98,6 +97,7 @@
      * 寮�闃�鏃剁疮璁℃祦閲�
      */
     @Schema(description = "寮�闃�鏃剁疮璁℃祦閲�", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
+    @JsonFormat(shape = JsonFormat.Shape.NUMBER_FLOAT, pattern="0.00" )
     public Double opTotalAmount;
 
     /**
@@ -116,6 +116,7 @@
      * 寮�闃�鏃跺墿浣欓噾棰�
      */
     @Schema(description = "寮�闃�鏃跺墿浣欓噾棰�", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
+    @JsonFormat(shape = JsonFormat.Shape.NUMBER_FLOAT, pattern="0.00" )
     public Double opRemainMoney;
 
     /**
@@ -128,12 +129,14 @@
      * 寮�闃�鏃剁數琛ㄧ疮璁$數閲�
      */
     @Schema(description = "寮�闃�鏃剁數琛ㄧ疮璁$數閲�", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
+    @JsonFormat(shape = JsonFormat.Shape.NUMBER_FLOAT, pattern="0.00" )
     public Double opEleTotalAmount;
 
     /**
      * 寮�闃�鏃剁敤姘存埛鍓╀綑姘撮噺
      */
     @Schema(description = "寮�闃�鏃剁敤姘存埛鍓╀綑姘撮噺", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
+    @JsonFormat(shape = JsonFormat.Shape.NUMBER_FLOAT, pattern="0.00" )
     public Double opWaterRemainUser;
 
     /**
@@ -158,6 +161,7 @@
      * 鍏抽榾鏃剁疮璁℃祦閲�
      */
     @Schema(description = "鍏抽榾鏃剁疮璁℃祦閲�", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
+    @JsonFormat(shape = JsonFormat.Shape.NUMBER_FLOAT, pattern="0.00" )
     public Double clTotalAmount;
 
     /**
@@ -176,18 +180,21 @@
      * 鍏抽榾鏃跺墿浣欓噾棰�
      */
     @Schema(description = "鍏抽榾鏃跺墿浣欓噾棰�", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
+    @JsonFormat(shape = JsonFormat.Shape.NUMBER_FLOAT, pattern="0.00" )
     public Double clRemainMoney;
 
     /**
      * 鍏抽榾鎶ヤ腑鏈鐢ㄦ按閲�
      */
     @Schema(description = "鍏抽榾鏃舵湰娆$敤姘撮噺", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
+    @JsonFormat(shape = JsonFormat.Shape.NUMBER_FLOAT, pattern="0.00" )
     public Double clThisAmount;
 
     /**
      * 鍏抽榾鎶ヤ腑鏈娑堣垂閲戦
      */
     @Schema(description = "鍏抽榾鏃舵湰娆℃秷璐归噾棰�", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
+    @JsonFormat(shape = JsonFormat.Shape.NUMBER_FLOAT, pattern="0.00" )
     public Double clThisMoney;
 
     /**
@@ -200,6 +207,7 @@
      * 鍏抽榾鎶ヤ腑姘翠环
      */
     @Schema(description = "鍏抽榾鎶ヤ腑姘翠环", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
+    @JsonFormat(shape = JsonFormat.Shape.NUMBER_FLOAT, pattern="0.00" )
     public Double clPrice ;//姘翠环
 
     /**
@@ -222,20 +230,23 @@
     /**
      * 鐢佃〃绱鐢甸噺
      */
+    @JsonFormat(shape = JsonFormat.Shape.NUMBER_FLOAT, pattern="0.00" )
     public Double clEleTotalAmount;
 
     /**
      * 鐢ㄦ埛鍓╀綑姘撮噺
      */
+    @JsonFormat(shape = JsonFormat.Shape.NUMBER_FLOAT, pattern="0.00" )
     public Double clWaterRemainUser;
 
     /**
      * 鏈浣跨敤鐢甸噺
      */
+    @JsonFormat(shape = JsonFormat.Shape.NUMBER_FLOAT, pattern="0.00" )
     public Double clThisEle;
 
-    public void valueFrom(DataV1_0_1 dV1_0_1, DataCd83OpenVo dataCd83OpenVo) throws Exception {
-        this.opDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt);
+    public void valueFrom(DataV1 dV1, com.dy.common.mw.protocol.p206V1.upVos.DataCd83OpenVo dataCd83OpenVo) throws Exception {
+        this.opDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1.dt);
         this.opType = dataCd83OpenVo.type;
         this.opTotalAmount = dataCd83OpenVo.totalAmount;
         this.opIcCardNo = dataCd83OpenVo.icCardNo;
@@ -264,8 +275,58 @@
         this.clThisEle = null;//姹熸捣鍗忚鐗规湁
     }
 
-    public void valueFrom(DataV1_0_1 dV1_0_1, DataCd83CloseVo dataCd83CloseVo) throws Exception {
-        this.clDt =  DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt);
+    public void valueFrom(DataV2 dV2, com.dy.common.mw.protocol.p206V2.upVos.DataCd83OpenVo dataCd83OpenVo) throws Exception {
+        this.opDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV2.dt);
+        this.opType = dataCd83OpenVo.type;
+        this.opTotalAmount = dataCd83OpenVo.totalAmount;
+        this.opIcCardNo = dataCd83OpenVo.icCardNo;
+        this.opIcCardAddr = dataCd83OpenVo.icCardAddr;
+        this.opRemainMoney = dataCd83OpenVo.remainMoney;
+        this.opOrderNo = null; //姹熸捣鍗忚鐗规湁
+        this.opEleTotalAmount = null; //姹熸捣鍗忚鐗规湁
+        this.opWaterRemainUser = null; //姹熸捣鍗忚鐗规湁
+        this.openDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt);
+        this.clDt = null;
+        this.clType = null;
+        this.clTotalAmount = null;
+        this.clIcCardNo = null;
+        this.clIcCardAddr = null;
+        this.clRemainMoney = null;
+        this.clThisAmount = null;
+        this.clThisMoney = null;
+        this.clThisTime = null;
+        this.clPrice = null;
+        this.clOpenDt = null;
+        this.closeDt = null;
+
+        this.clOrderNo = null;//姹熸捣鍗忚鐗规湁
+        this.clEleTotalAmount = null;//姹熸捣鍗忚鐗规湁
+        this.clWaterRemainUser = null;//姹熸捣鍗忚鐗规湁
+        this.clThisEle = null;//姹熸捣鍗忚鐗规湁
+    }
+
+    public void valueFrom(DataV1 dV1, com.dy.common.mw.protocol.p206V1.upVos.DataCd83CloseVo dataCd83CloseVo) throws Exception {
+        this.clDt =  DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1.dt);
+        this.clType = dataCd83CloseVo.type;
+        this.clTotalAmount = dataCd83CloseVo.totalAmount;
+        this.clIcCardNo = dataCd83CloseVo.icCardNo;
+        this.clIcCardAddr = dataCd83CloseVo.icCardAddr;
+        this.clRemainMoney = dataCd83CloseVo.remainMoney;
+        this.clThisAmount = dataCd83CloseVo.thisAmount;
+        this.clThisMoney = dataCd83CloseVo.thisMoney;
+        this.clThisTime = dataCd83CloseVo.thisTime;
+        this.clPrice = dataCd83CloseVo.price;
+        this.clOpenDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83CloseVo.openDt);
+        this.closeDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83CloseVo.closeDt);
+
+        this.clOrderNo = null;//姹熸捣鍗忚鐗规湁
+        this.clEleTotalAmount = null;//姹熸捣鍗忚鐗规湁
+        this.clWaterRemainUser = null;//姹熸捣鍗忚鐗规湁
+        this.clThisEle = null;//姹熸捣鍗忚鐗规湁
+    }
+
+    public void valueFrom(DataV2 dV2, com.dy.common.mw.protocol.p206V2.upVos.DataCd83CloseVo dataCd83CloseVo) throws Exception {
+        this.clDt =  DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV2.dt);
         this.clType = dataCd83CloseVo.type;
         this.clTotalAmount = dataCd83CloseVo.totalAmount;
         this.clIcCardNo = dataCd83CloseVo.icCardNo;
@@ -332,8 +393,37 @@
         this.clThisEle = cdData.thisEle;
     }
 
-    public void updateFrom(DataV1_0_1 dV1_0_1, DataCd83OpenVo dataCd83OpenVo, Boolean clearCloseValve) throws Exception {
-        this.opDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt);
+    public void updateFrom(DataV1 dV1, com.dy.common.mw.protocol.p206V1.upVos.DataCd83OpenVo dataCd83OpenVo, Boolean clearCloseValve) throws Exception {
+        this.opDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1.dt);
+        this.opType = dataCd83OpenVo.type;
+        this.opTotalAmount = dataCd83OpenVo.totalAmount;
+        this.opIcCardNo = dataCd83OpenVo.icCardNo;
+        this.opIcCardAddr = dataCd83OpenVo.icCardAddr;
+        this.opRemainMoney = dataCd83OpenVo.remainMoney;
+        this.openDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt);
+        if (clearCloseValve != null && clearCloseValve.booleanValue()) {
+            this.clDt = null;
+            this.clType = null;
+            this.clTotalAmount = null;
+            this.clIcCardNo = null;
+            this.clIcCardAddr = null;
+            this.clRemainMoney = null;
+            this.clThisAmount = null;
+            this.clThisMoney = null;
+            this.clThisTime = null;
+            this.clPrice = null;
+            this.clOpenDt = null;
+            this.closeDt = null;
+
+            this.clOrderNo = null;//姹熸捣鍗忚鐗规湁
+            this.clEleTotalAmount = null;//姹熸捣鍗忚鐗规湁
+            this.clWaterRemainUser = null;//姹熸捣鍗忚鐗规湁
+            this.clThisEle = null;//姹熸捣鍗忚鐗规湁
+        }
+    }
+
+    public void updateFrom(DataV2 dV2, com.dy.common.mw.protocol.p206V2.upVos.DataCd83OpenVo dataCd83OpenVo, Boolean clearCloseValve) throws Exception {
+        this.opDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV2.dt);
         this.opType = dataCd83OpenVo.type;
         this.opTotalAmount = dataCd83OpenVo.totalAmount;
         this.opIcCardNo = dataCd83OpenVo.icCardNo;
@@ -362,8 +452,38 @@
     }
 
 
-    public void updateFrom(DataV1_0_1 dV1_0_1, DataCd83CloseVo dataCd83CloseVo, boolean clearOpenValve) throws Exception {
-        this.clDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt);
+    public void updateFrom(DataV1 dV1, com.dy.common.mw.protocol.p206V1.upVos.DataCd83CloseVo dataCd83CloseVo, boolean clearOpenValve) throws Exception {
+        this.clDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1.dt);
+        this.clType = dataCd83CloseVo.type;
+        this.clTotalAmount = dataCd83CloseVo.totalAmount;
+        this.clIcCardNo = dataCd83CloseVo.icCardNo;
+        this.clIcCardAddr = dataCd83CloseVo.icCardAddr;
+        this.clRemainMoney = dataCd83CloseVo.remainMoney;
+        this.clThisAmount = dataCd83CloseVo.thisAmount;
+        this.clThisMoney = dataCd83CloseVo.thisMoney;
+        this.clThisTime = dataCd83CloseVo.thisTime;
+        this.clPrice = dataCd83CloseVo.price;
+        this.clOpenDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83CloseVo.openDt);
+        this.closeDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83CloseVo.closeDt) ;
+
+        if(clearOpenValve){
+            this.opDt = null ;
+            this.opType = null ;
+            this.opTotalAmount = null ;
+            this.opIcCardNo = null ;
+            this.opIcCardAddr = null ;
+            this.opRemainMoney = null ;
+            this.openDt = null ;
+
+            this.clOrderNo = null;//姹熸捣鍗忚鐗规湁
+            this.clEleTotalAmount = null;//姹熸捣鍗忚鐗规湁
+            this.clWaterRemainUser = null;//姹熸捣鍗忚鐗规湁
+            this.clThisEle = null;//姹熸捣鍗忚鐗规湁
+        }
+    }
+
+    public void updateFrom(DataV2 dV2, com.dy.common.mw.protocol.p206V2.upVos.DataCd83CloseVo dataCd83CloseVo, boolean clearOpenValve) throws Exception {
+        this.clDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV2.dt);
         this.clType = dataCd83CloseVo.type;
         this.clTotalAmount = dataCd83CloseVo.totalAmount;
         this.clIcCardNo = dataCd83CloseVo.icCardNo;

--
Gitblit v1.8.0