From 9f046d256726cc43af43e8704a2888190029c241 Mon Sep 17 00:00:00 2001
From: Administrator <zhubaomin>
Date: 星期一, 05 八月 2024 18:52:44 +0800
Subject: [PATCH] 2024-08-05 朱宝民 指定时间段内指定开关阀类型开关阀次数

---
 pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/qo/SignalIntensityQO.java |    6 
 pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOpenCloseValveHistoryMapper.xml                               |  966 ++++++++++++------------
 pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/qo/CloseTypeQo.java       |   35 
 pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/IntkeCtrl.java            |   42 
 pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/IntakeSv.java             |  134 +++
 pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/qo/OpenTypeQO.java        |   35 
 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoRm/RmOnHourReportLastMapper.java                     |    1 
 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voSt/VoCountOfCloseType.java                            |   24 
 pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOpenCloseValveLastMapper.xml                                  | 1028 +++++++++++++------------
 pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOnHourReportLastMapper.xml                                    |    1 
 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoRm/RmOpenCloseValveLastMapper.java                   |   14 
 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voSt/VoCountOfOpenType.java                             |   24 
 12 files changed, 1,333 insertions(+), 977 deletions(-)

diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoRm/RmOnHourReportLastMapper.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoRm/RmOnHourReportLastMapper.java
index d4604e2..582f401 100644
--- a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoRm/RmOnHourReportLastMapper.java
+++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoRm/RmOnHourReportLastMapper.java
@@ -138,4 +138,5 @@
      * @return
      */
     List<VoSignalIntensity> getSpecifiedSignalIntakes(Map<?, ?> params);
+
 }
\ No newline at end of file
diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoRm/RmOpenCloseValveLastMapper.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoRm/RmOpenCloseValveLastMapper.java
index e9b9ec6..0a8722f 100644
--- a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoRm/RmOpenCloseValveLastMapper.java
+++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoRm/RmOpenCloseValveLastMapper.java
@@ -84,4 +84,18 @@
      * @return
      */
     List<VoOpenCloseValve> getOpenCloseValveReports_last(Map<?, ?> params);
+
+    /**
+     * 鏍规嵁寮�闃�绫诲瀷鑾峰彇鎿嶄綔娆℃暟
+     * @param params
+     * @return
+     */
+    Integer getCountByOpenType(Map<?, ?> params);
+
+    /**
+     * 鏍规嵁鍏抽榾绫诲瀷鑾峰彇鎿嶄綔娆℃暟
+     * @param params
+     * @return
+     */
+    Integer getCountByCloseType(Map<?, ?> params);
 }
\ No newline at end of file
diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voSt/VoCountOfCloseType.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voSt/VoCountOfCloseType.java
new file mode 100644
index 0000000..9d488e6
--- /dev/null
+++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voSt/VoCountOfCloseType.java
@@ -0,0 +1,24 @@
+package com.dy.pipIrrGlobal.voSt;
+
+import lombok.Data;
+
+/**
+ * @author ZhuBaoMin
+ * @date 2024-08-05 16:11
+ * @LastEditTime 2024-08-05 16:11
+ * @Description 鍏抽榾绫诲瀷娆℃暟缁熻瑙嗗浘
+ */
+
+@Data
+public class VoCountOfCloseType {
+
+    /**
+     * 鍏抽榾绫诲瀷鍚嶇О
+     */
+    private String closeTypeName;
+
+    /**
+     * 鍏抽榾绫诲瀷娆℃暟
+     */
+    private Integer closeTypeCount;
+}
diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voSt/VoCountOfOpenType.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voSt/VoCountOfOpenType.java
new file mode 100644
index 0000000..22eda61
--- /dev/null
+++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voSt/VoCountOfOpenType.java
@@ -0,0 +1,24 @@
+package com.dy.pipIrrGlobal.voSt;
+
+import lombok.Data;
+
+/**
+ * @author ZhuBaoMin
+ * @date 2024-08-05 16:03
+ * @LastEditTime 2024-08-05 16:03
+ * @Description 寮�闃�绫诲瀷娆℃暟缁熻瑙嗗浘
+ */
+
+@Data
+public class VoCountOfOpenType {
+
+    /**
+     * 寮�闃�鏂圭被鍨嬪悕绉�
+     */
+    private String openTypeName;
+
+    /**
+     * 寮�闃�绫诲瀷娆℃暟
+     */
+    private Integer openTypeCount;
+}
diff --git a/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOnHourReportLastMapper.xml b/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOnHourReportLastMapper.xml
index 29f966b..a41ef3c 100644
--- a/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOnHourReportLastMapper.xml
+++ b/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOnHourReportLastMapper.xml
@@ -417,4 +417,5 @@
             </if>
         </trim>
     </select>
+
 </mapper>
\ No newline at end of file
diff --git a/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOpenCloseValveHistoryMapper.xml b/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOpenCloseValveHistoryMapper.xml
index 16e4487..b332c90 100644
--- a/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOpenCloseValveHistoryMapper.xml
+++ b/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOpenCloseValveHistoryMapper.xml
@@ -1,507 +1,531 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.dy.pipIrrGlobal.daoRm.RmOpenCloseValveHistoryMapper">
-  <resultMap id="BaseResultMap" type="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveHistory">
-    <!--@mbg.generated-->
-    <!--@Table rm_open_close_valve_history-->
-    <id column="id" jdbcType="BIGINT" property="id" />
-    <result column="client_id" jdbcType="BIGINT" property="clientId" />
-    <result column="client_name" jdbcType="VARCHAR" property="clientName" />
-    <result column="controller_id" jdbcType="BIGINT" property="controllerId" />
-    <result column="intake_id" jdbcType="BIGINT" property="intakeId" />
-    <result column="rtu_addr" jdbcType="VARCHAR" property="rtuAddr" />
-    <result column="op_dt" jdbcType="TIMESTAMP" property="opDt" />
-    <result column="op_type" jdbcType="TINYINT" property="opType" />
-    <result column="op_total_amount" jdbcType="DOUBLE" property="opTotalAmount" />
-    <result column="op_ic_card_no" jdbcType="VARCHAR" property="opIcCardNo" />
-    <result column="op_ic_card_addr" jdbcType="VARCHAR" property="opIcCardAddr" />
-    <result column="op_remain_money" jdbcType="DOUBLE" property="opRemainMoney" />
-    <result column="open_dt" jdbcType="TIMESTAMP" property="openDt" />
-    <result column="op_order_no" jdbcType="VARCHAR" property="opOrderNo" />
-    <result column="op_ele_total_amount" jdbcType="FLOAT" property="opEleTotalAmount" />
-    <result column="op_water_remain_user" jdbcType="FLOAT" property="opWaterRemainUser" />
-    <result column="cl_dt" jdbcType="TIMESTAMP" property="clDt" />
-    <result column="cl_type" jdbcType="TINYINT" property="clType" />
-    <result column="cl_total_amount" jdbcType="DOUBLE" property="clTotalAmount" />
-    <result column="cl_ic_card_no" jdbcType="VARCHAR" property="clIcCardNo" />
-    <result column="cl_ic_card_addr" jdbcType="VARCHAR" property="clIcCardAddr" />
-    <result column="cl_remain_money" jdbcType="DOUBLE" property="clRemainMoney" />
-    <result column="cl_this_amount" jdbcType="DOUBLE" property="clThisAmount" />
-    <result column="cl_this_money" jdbcType="DOUBLE" property="clThisMoney" />
-    <result column="cl_this_time" jdbcType="INTEGER" property="clThisTime" />
-    <result column="cl_open_dt" jdbcType="TIMESTAMP" property="clOpenDt" />
-    <result column="close_dt" jdbcType="TIMESTAMP" property="closeDt" />
-    <result column="cl_order_no" jdbcType="VARCHAR" property="clOrderNo" />
-    <result column="cl_ele_total_amount" jdbcType="FLOAT" property="clEleTotalAmount" />
-    <result column="cl_water_remain_user" jdbcType="FLOAT" property="clWaterRemainUser" />
-    <result column="cl_this_ele" jdbcType="FLOAT" property="clThisEle" />
-  </resultMap>
-  <sql id="Base_Column_List">
-    <!--@mbg.generated-->
-    id, client_id, client_name,
-    controller_id, intake_id, rtu_addr, op_dt, op_type, op_total_amount, op_ic_card_no,
-    op_ic_card_addr, op_remain_money, open_dt, op_order_no, op_ele_total_amount, op_water_remain_user, 
-    cl_dt, cl_type, cl_total_amount, cl_ic_card_no, cl_ic_card_addr, cl_remain_money, 
-    cl_this_amount, cl_this_money, cl_this_time, cl_open_dt, close_dt, cl_order_no, cl_ele_total_amount, 
-    cl_water_remain_user, cl_this_ele
-  </sql>
-  <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
-    <!--@mbg.generated-->
-    select 
-    <include refid="Base_Column_List" />
-    from rm_open_close_valve_history
-    where id = #{id,jdbcType=BIGINT}
-  </select>
-  <delete id="deleteByPrimaryKey" parameterType="java.lang.Long">
-    <!--@mbg.generated-->
-    delete from rm_open_close_valve_history
-    where id = #{id,jdbcType=BIGINT}
-  </delete>
-  <insert id="insert" parameterType="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveHistory">
-    <!--@mbg.generated-->
-    insert into rm_open_close_valve_history (id, client_id, client_name,
-      controller_id, intake_id,
-      rtu_addr, op_dt, op_type, 
-      op_total_amount, op_ic_card_no, op_ic_card_addr, 
-      op_remain_money, open_dt, op_order_no, 
-      op_ele_total_amount, op_water_remain_user, cl_dt, 
-      cl_type, cl_total_amount, cl_ic_card_no, 
-      cl_ic_card_addr, cl_remain_money, cl_this_amount, 
-      cl_this_money, cl_this_time, cl_open_dt, 
-      close_dt, cl_order_no, cl_ele_total_amount, 
-      cl_water_remain_user, cl_this_ele)
-    values (#{id,jdbcType=BIGINT}, #{clientId,jdbcType=BIGINT}, #{clientName,jdbcType=VARCHAR},
-      #{controllerId,jdbcType=BIGINT}, #{intakeId,jdbcType=BIGINT},
-      #{rtuAddr,jdbcType=VARCHAR}, #{opDt,jdbcType=TIMESTAMP}, #{opType,jdbcType=TINYINT}, 
-      #{opTotalAmount,jdbcType=DOUBLE}, #{opIcCardNo,jdbcType=VARCHAR}, #{opIcCardAddr,jdbcType=VARCHAR}, 
-      #{opRemainMoney,jdbcType=DOUBLE}, #{openDt,jdbcType=TIMESTAMP}, #{opOrderNo,jdbcType=VARCHAR}, 
-      #{opEleTotalAmount,jdbcType=FLOAT}, #{opWaterRemainUser,jdbcType=FLOAT}, #{clDt,jdbcType=TIMESTAMP}, 
-      #{clType,jdbcType=TINYINT}, #{clTotalAmount,jdbcType=DOUBLE}, #{clIcCardNo,jdbcType=VARCHAR}, 
-      #{clIcCardAddr,jdbcType=VARCHAR}, #{clRemainMoney,jdbcType=DOUBLE}, #{clThisAmount,jdbcType=DOUBLE}, 
-      #{clThisMoney,jdbcType=DOUBLE}, #{clThisTime,jdbcType=INTEGER}, #{clOpenDt,jdbcType=TIMESTAMP}, 
-      #{closeDt,jdbcType=TIMESTAMP}, #{clOrderNo,jdbcType=VARCHAR}, #{clEleTotalAmount,jdbcType=FLOAT}, 
-      #{clWaterRemainUser,jdbcType=FLOAT}, #{clThisEle,jdbcType=FLOAT})
-  </insert>
-  <insert id="insertSelective" parameterType="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveHistory">
-    <!--@mbg.generated-->
-    insert into rm_open_close_valve_history
-    <trim prefix="(" suffix=")" suffixOverrides=",">
-      <if test="id != null">
+    <resultMap id="BaseResultMap" type="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveHistory">
+        <!--@mbg.generated-->
+        <!--@Table rm_open_close_valve_history-->
+        <id column="id" jdbcType="BIGINT" property="id"/>
+        <result column="client_id" jdbcType="BIGINT" property="clientId"/>
+        <result column="client_name" jdbcType="VARCHAR" property="clientName"/>
+        <result column="controller_id" jdbcType="BIGINT" property="controllerId"/>
+        <result column="intake_id" jdbcType="BIGINT" property="intakeId"/>
+        <result column="rtu_addr" jdbcType="VARCHAR" property="rtuAddr"/>
+        <result column="op_dt" jdbcType="TIMESTAMP" property="opDt"/>
+        <result column="op_type" jdbcType="TINYINT" property="opType"/>
+        <result column="op_total_amount" jdbcType="DOUBLE" property="opTotalAmount"/>
+        <result column="op_ic_card_no" jdbcType="VARCHAR" property="opIcCardNo"/>
+        <result column="op_ic_card_addr" jdbcType="VARCHAR" property="opIcCardAddr"/>
+        <result column="op_remain_money" jdbcType="DOUBLE" property="opRemainMoney"/>
+        <result column="open_dt" jdbcType="TIMESTAMP" property="openDt"/>
+        <result column="op_order_no" jdbcType="VARCHAR" property="opOrderNo"/>
+        <result column="op_ele_total_amount" jdbcType="FLOAT" property="opEleTotalAmount"/>
+        <result column="op_water_remain_user" jdbcType="FLOAT" property="opWaterRemainUser"/>
+        <result column="cl_dt" jdbcType="TIMESTAMP" property="clDt"/>
+        <result column="cl_type" jdbcType="TINYINT" property="clType"/>
+        <result column="cl_total_amount" jdbcType="DOUBLE" property="clTotalAmount"/>
+        <result column="cl_ic_card_no" jdbcType="VARCHAR" property="clIcCardNo"/>
+        <result column="cl_ic_card_addr" jdbcType="VARCHAR" property="clIcCardAddr"/>
+        <result column="cl_remain_money" jdbcType="DOUBLE" property="clRemainMoney"/>
+        <result column="cl_this_amount" jdbcType="DOUBLE" property="clThisAmount"/>
+        <result column="cl_this_money" jdbcType="DOUBLE" property="clThisMoney"/>
+        <result column="cl_this_time" jdbcType="INTEGER" property="clThisTime"/>
+        <result column="cl_open_dt" jdbcType="TIMESTAMP" property="clOpenDt"/>
+        <result column="close_dt" jdbcType="TIMESTAMP" property="closeDt"/>
+        <result column="cl_order_no" jdbcType="VARCHAR" property="clOrderNo"/>
+        <result column="cl_ele_total_amount" jdbcType="FLOAT" property="clEleTotalAmount"/>
+        <result column="cl_water_remain_user" jdbcType="FLOAT" property="clWaterRemainUser"/>
+        <result column="cl_this_ele" jdbcType="FLOAT" property="clThisEle"/>
+    </resultMap>
+    <sql id="Base_Column_List">
+        <!--@mbg.generated-->
         id,
-      </if>
-      <if test="clientId != null">
         client_id,
-      </if>
-      <if test="clientName != null">
         client_name,
-      </if>
-      <if test="controllerId != null">
         controller_id,
-      </if>
-      <if test="intakeId != null">
         intake_id,
-      </if>
-      <if test="rtuAddr != null">
         rtu_addr,
-      </if>
-      <if test="opDt != null">
         op_dt,
-      </if>
-      <if test="opType != null">
         op_type,
-      </if>
-      <if test="opTotalAmount != null">
         op_total_amount,
-      </if>
-      <if test="opIcCardNo != null">
         op_ic_card_no,
-      </if>
-      <if test="opIcCardAddr != null">
         op_ic_card_addr,
-      </if>
-      <if test="opRemainMoney != null">
         op_remain_money,
-      </if>
-      <if test="openDt != null">
         open_dt,
-      </if>
-      <if test="opOrderNo != null">
         op_order_no,
-      </if>
-      <if test="opEleTotalAmount != null">
         op_ele_total_amount,
-      </if>
-      <if test="opWaterRemainUser != null">
         op_water_remain_user,
-      </if>
-      <if test="clDt != null">
         cl_dt,
-      </if>
-      <if test="clType != null">
         cl_type,
-      </if>
-      <if test="clTotalAmount != null">
         cl_total_amount,
-      </if>
-      <if test="clIcCardNo != null">
         cl_ic_card_no,
-      </if>
-      <if test="clIcCardAddr != null">
         cl_ic_card_addr,
-      </if>
-      <if test="clRemainMoney != null">
         cl_remain_money,
-      </if>
-      <if test="clThisAmount != null">
         cl_this_amount,
-      </if>
-      <if test="clThisMoney != null">
         cl_this_money,
-      </if>
-      <if test="clThisTime != null">
         cl_this_time,
-      </if>
-      <if test="clOpenDt != null">
         cl_open_dt,
-      </if>
-      <if test="closeDt != null">
         close_dt,
-      </if>
-      <if test="clOrderNo != null">
         cl_order_no,
-      </if>
-      <if test="clEleTotalAmount != null">
         cl_ele_total_amount,
-      </if>
-      <if test="clWaterRemainUser != null">
         cl_water_remain_user,
-      </if>
-      <if test="clThisEle != null">
-        cl_this_ele,
-      </if>
-    </trim>
-    <trim prefix="values (" suffix=")" suffixOverrides=",">
-      <if test="id != null">
-        #{id,jdbcType=BIGINT},
-      </if>
-      <if test="clientId != null">
-        #{clientId,jdbcType=BIGINT},
-      </if>
-      <if test="clientName != null">
-        #{clientName,jdbcType=VARCHAR},
-      </if>
-      <if test="controllerId != null">
-        #{controllerId,jdbcType=BIGINT},
-      </if>
-      <if test="intakeId != null">
-        #{intakeId,jdbcType=BIGINT},
-      </if>
-      <if test="rtuAddr != null">
-        #{rtuAddr,jdbcType=VARCHAR},
-      </if>
-      <if test="opDt != null">
-        #{opDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="opType != null">
-        #{opType,jdbcType=TINYINT},
-      </if>
-      <if test="opTotalAmount != null">
-        #{opTotalAmount,jdbcType=DOUBLE},
-      </if>
-      <if test="opIcCardNo != null">
-        #{opIcCardNo,jdbcType=VARCHAR},
-      </if>
-      <if test="opIcCardAddr != null">
-        #{opIcCardAddr,jdbcType=VARCHAR},
-      </if>
-      <if test="opRemainMoney != null">
-        #{opRemainMoney,jdbcType=DOUBLE},
-      </if>
-      <if test="openDt != null">
-        #{openDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="opOrderNo != null">
-        #{opOrderNo,jdbcType=VARCHAR},
-      </if>
-      <if test="opEleTotalAmount != null">
-        #{opEleTotalAmount,jdbcType=FLOAT},
-      </if>
-      <if test="opWaterRemainUser != null">
-        #{opWaterRemainUser,jdbcType=FLOAT},
-      </if>
-      <if test="clDt != null">
-        #{clDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="clType != null">
-        #{clType,jdbcType=TINYINT},
-      </if>
-      <if test="clTotalAmount != null">
-        #{clTotalAmount,jdbcType=DOUBLE},
-      </if>
-      <if test="clIcCardNo != null">
-        #{clIcCardNo,jdbcType=VARCHAR},
-      </if>
-      <if test="clIcCardAddr != null">
-        #{clIcCardAddr,jdbcType=VARCHAR},
-      </if>
-      <if test="clRemainMoney != null">
-        #{clRemainMoney,jdbcType=DOUBLE},
-      </if>
-      <if test="clThisAmount != null">
-        #{clThisAmount,jdbcType=DOUBLE},
-      </if>
-      <if test="clThisMoney != null">
-        #{clThisMoney,jdbcType=DOUBLE},
-      </if>
-      <if test="clThisTime != null">
-        #{clThisTime,jdbcType=INTEGER},
-      </if>
-      <if test="clOpenDt != null">
-        #{clOpenDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="closeDt != null">
-        #{closeDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="clOrderNo != null">
-        #{clOrderNo,jdbcType=VARCHAR},
-      </if>
-      <if test="clEleTotalAmount != null">
-        #{clEleTotalAmount,jdbcType=FLOAT},
-      </if>
-      <if test="clWaterRemainUser != null">
-        #{clWaterRemainUser,jdbcType=FLOAT},
-      </if>
-      <if test="clThisEle != null">
-        #{clThisEle,jdbcType=FLOAT},
-      </if>
-    </trim>
-  </insert>
-  <update id="updateByPrimaryKeySelective" parameterType="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveHistory">
-    <!--@mbg.generated-->
-    update rm_open_close_valve_history
-    <set>
-      <if test="clientId != null">
-        client_id = #{clientId,jdbcType=BIGINT},
-      </if>
-      <if test="clientName != null">
-        client_name = #{clientName,jdbcType=VARCHAR},
-      </if>
-      <if test="controllerId != null">
-        controller_id = #{controllerId,jdbcType=BIGINT},
-      </if>
-      <if test="intakeId != null">
-        intake_id = #{intakeId,jdbcType=BIGINT},
-      </if>
-      <if test="rtuAddr != null">
-        rtu_addr = #{rtuAddr,jdbcType=VARCHAR},
-      </if>
-      <if test="opDt != null">
-        op_dt = #{opDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="opType != null">
-        op_type = #{opType,jdbcType=TINYINT},
-      </if>
-      <if test="opTotalAmount != null">
-        op_total_amount = #{opTotalAmount,jdbcType=DOUBLE},
-      </if>
-      <if test="opIcCardNo != null">
-        op_ic_card_no = #{opIcCardNo,jdbcType=VARCHAR},
-      </if>
-      <if test="opIcCardAddr != null">
-        op_ic_card_addr = #{opIcCardAddr,jdbcType=VARCHAR},
-      </if>
-      <if test="opRemainMoney != null">
-        op_remain_money = #{opRemainMoney,jdbcType=DOUBLE},
-      </if>
-      <if test="openDt != null">
-        open_dt = #{openDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="opOrderNo != null">
-        op_order_no = #{opOrderNo,jdbcType=VARCHAR},
-      </if>
-      <if test="opEleTotalAmount != null">
-        op_ele_total_amount = #{opEleTotalAmount,jdbcType=FLOAT},
-      </if>
-      <if test="opWaterRemainUser != null">
-        op_water_remain_user = #{opWaterRemainUser,jdbcType=FLOAT},
-      </if>
-      <if test="clDt != null">
-        cl_dt = #{clDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="clType != null">
-        cl_type = #{clType,jdbcType=TINYINT},
-      </if>
-      <if test="clTotalAmount != null">
-        cl_total_amount = #{clTotalAmount,jdbcType=DOUBLE},
-      </if>
-      <if test="clIcCardNo != null">
-        cl_ic_card_no = #{clIcCardNo,jdbcType=VARCHAR},
-      </if>
-      <if test="clIcCardAddr != null">
-        cl_ic_card_addr = #{clIcCardAddr,jdbcType=VARCHAR},
-      </if>
-      <if test="clRemainMoney != null">
-        cl_remain_money = #{clRemainMoney,jdbcType=DOUBLE},
-      </if>
-      <if test="clThisAmount != null">
-        cl_this_amount = #{clThisAmount,jdbcType=DOUBLE},
-      </if>
-      <if test="clThisMoney != null">
-        cl_this_money = #{clThisMoney,jdbcType=DOUBLE},
-      </if>
-      <if test="clThisTime != null">
-        cl_this_time = #{clThisTime,jdbcType=INTEGER},
-      </if>
-      <if test="clOpenDt != null">
-        cl_open_dt = #{clOpenDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="closeDt != null">
-        close_dt = #{closeDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="clOrderNo != null">
-        cl_order_no = #{clOrderNo,jdbcType=VARCHAR},
-      </if>
-      <if test="clEleTotalAmount != null">
-        cl_ele_total_amount = #{clEleTotalAmount,jdbcType=FLOAT},
-      </if>
-      <if test="clWaterRemainUser != null">
-        cl_water_remain_user = #{clWaterRemainUser,jdbcType=FLOAT},
-      </if>
-      <if test="clThisEle != null">
-        cl_this_ele = #{clThisEle,jdbcType=FLOAT},
-      </if>
-    </set>
-    where id = #{id,jdbcType=BIGINT}
-  </update>
-  <update id="updateByPrimaryKey" parameterType="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveHistory">
-    <!--@mbg.generated-->
-    update rm_open_close_valve_history
-    set client_id = #{clientId,jdbcType=BIGINT},
-      client_name = #{clientName,jdbcType=VARCHAR},
-      controller_id = #{controllerId,jdbcType=BIGINT},
-      intake_id = #{intakeId,jdbcType=BIGINT},
-      rtu_addr = #{rtuAddr,jdbcType=VARCHAR},
-      op_dt = #{opDt,jdbcType=TIMESTAMP},
-      op_type = #{opType,jdbcType=TINYINT},
-      op_total_amount = #{opTotalAmount,jdbcType=DOUBLE},
-      op_ic_card_no = #{opIcCardNo,jdbcType=VARCHAR},
-      op_ic_card_addr = #{opIcCardAddr,jdbcType=VARCHAR},
-      op_remain_money = #{opRemainMoney,jdbcType=DOUBLE},
-      open_dt = #{openDt,jdbcType=TIMESTAMP},
-      op_order_no = #{opOrderNo,jdbcType=VARCHAR},
-      op_ele_total_amount = #{opEleTotalAmount,jdbcType=FLOAT},
-      op_water_remain_user = #{opWaterRemainUser,jdbcType=FLOAT},
-      cl_dt = #{clDt,jdbcType=TIMESTAMP},
-      cl_type = #{clType,jdbcType=TINYINT},
-      cl_total_amount = #{clTotalAmount,jdbcType=DOUBLE},
-      cl_ic_card_no = #{clIcCardNo,jdbcType=VARCHAR},
-      cl_ic_card_addr = #{clIcCardAddr,jdbcType=VARCHAR},
-      cl_remain_money = #{clRemainMoney,jdbcType=DOUBLE},
-      cl_this_amount = #{clThisAmount,jdbcType=DOUBLE},
-      cl_this_money = #{clThisMoney,jdbcType=DOUBLE},
-      cl_this_time = #{clThisTime,jdbcType=INTEGER},
-      cl_open_dt = #{clOpenDt,jdbcType=TIMESTAMP},
-      close_dt = #{closeDt,jdbcType=TIMESTAMP},
-      cl_order_no = #{clOrderNo,jdbcType=VARCHAR},
-      cl_ele_total_amount = #{clEleTotalAmount,jdbcType=FLOAT},
-      cl_water_remain_user = #{clWaterRemainUser,jdbcType=FLOAT},
-      cl_this_ele = #{clThisEle,jdbcType=FLOAT}
-    where id = #{id,jdbcType=BIGINT}
-  </update>
+        cl_this_ele
+    </sql>
+    <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
+        <!--@mbg.generated-->
+        select
+        <include refid="Base_Column_List"/>
+        from rm_open_close_valve_history
+        where id = #{id,jdbcType=BIGINT}
+    </select>
+    <delete id="deleteByPrimaryKey" parameterType="java.lang.Long">
+        <!--@mbg.generated-->
+        delete
+        from rm_open_close_valve_history
+        where id = #{id,jdbcType=BIGINT}
+    </delete>
+    <insert id="insert" parameterType="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveHistory">
+        <!--@mbg.generated-->
+        insert into rm_open_close_valve_history (id, client_id, client_name,
+                                                 controller_id, intake_id,
+                                                 rtu_addr, op_dt, op_type,
+                                                 op_total_amount, op_ic_card_no, op_ic_card_addr,
+                                                 op_remain_money, open_dt, op_order_no,
+                                                 op_ele_total_amount, op_water_remain_user, cl_dt,
+                                                 cl_type, cl_total_amount, cl_ic_card_no,
+                                                 cl_ic_card_addr, cl_remain_money, cl_this_amount,
+                                                 cl_this_money, cl_this_time, cl_open_dt,
+                                                 close_dt, cl_order_no, cl_ele_total_amount,
+                                                 cl_water_remain_user, cl_this_ele)
+        values (#{id,jdbcType=BIGINT}, #{clientId,jdbcType=BIGINT}, #{clientName,jdbcType=VARCHAR},
+                #{controllerId,jdbcType=BIGINT}, #{intakeId,jdbcType=BIGINT},
+                #{rtuAddr,jdbcType=VARCHAR}, #{opDt,jdbcType=TIMESTAMP}, #{opType,jdbcType=TINYINT},
+                #{opTotalAmount,jdbcType=DOUBLE}, #{opIcCardNo,jdbcType=VARCHAR}, #{opIcCardAddr,jdbcType=VARCHAR},
+                #{opRemainMoney,jdbcType=DOUBLE}, #{openDt,jdbcType=TIMESTAMP}, #{opOrderNo,jdbcType=VARCHAR},
+                #{opEleTotalAmount,jdbcType=FLOAT}, #{opWaterRemainUser,jdbcType=FLOAT}, #{clDt,jdbcType=TIMESTAMP},
+                #{clType,jdbcType=TINYINT}, #{clTotalAmount,jdbcType=DOUBLE}, #{clIcCardNo,jdbcType=VARCHAR},
+                #{clIcCardAddr,jdbcType=VARCHAR}, #{clRemainMoney,jdbcType=DOUBLE}, #{clThisAmount,jdbcType=DOUBLE},
+                #{clThisMoney,jdbcType=DOUBLE}, #{clThisTime,jdbcType=INTEGER}, #{clOpenDt,jdbcType=TIMESTAMP},
+                #{closeDt,jdbcType=TIMESTAMP}, #{clOrderNo,jdbcType=VARCHAR}, #{clEleTotalAmount,jdbcType=FLOAT},
+                #{clWaterRemainUser,jdbcType=FLOAT}, #{clThisEle,jdbcType=FLOAT})
+    </insert>
+    <insert id="insertSelective" parameterType="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveHistory">
+        <!--@mbg.generated-->
+        insert into rm_open_close_valve_history
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="id != null">
+                id,
+            </if>
+            <if test="clientId != null">
+                client_id,
+            </if>
+            <if test="clientName != null">
+                client_name,
+            </if>
+            <if test="controllerId != null">
+                controller_id,
+            </if>
+            <if test="intakeId != null">
+                intake_id,
+            </if>
+            <if test="rtuAddr != null">
+                rtu_addr,
+            </if>
+            <if test="opDt != null">
+                op_dt,
+            </if>
+            <if test="opType != null">
+                op_type,
+            </if>
+            <if test="opTotalAmount != null">
+                op_total_amount,
+            </if>
+            <if test="opIcCardNo != null">
+                op_ic_card_no,
+            </if>
+            <if test="opIcCardAddr != null">
+                op_ic_card_addr,
+            </if>
+            <if test="opRemainMoney != null">
+                op_remain_money,
+            </if>
+            <if test="openDt != null">
+                open_dt,
+            </if>
+            <if test="opOrderNo != null">
+                op_order_no,
+            </if>
+            <if test="opEleTotalAmount != null">
+                op_ele_total_amount,
+            </if>
+            <if test="opWaterRemainUser != null">
+                op_water_remain_user,
+            </if>
+            <if test="clDt != null">
+                cl_dt,
+            </if>
+            <if test="clType != null">
+                cl_type,
+            </if>
+            <if test="clTotalAmount != null">
+                cl_total_amount,
+            </if>
+            <if test="clIcCardNo != null">
+                cl_ic_card_no,
+            </if>
+            <if test="clIcCardAddr != null">
+                cl_ic_card_addr,
+            </if>
+            <if test="clRemainMoney != null">
+                cl_remain_money,
+            </if>
+            <if test="clThisAmount != null">
+                cl_this_amount,
+            </if>
+            <if test="clThisMoney != null">
+                cl_this_money,
+            </if>
+            <if test="clThisTime != null">
+                cl_this_time,
+            </if>
+            <if test="clOpenDt != null">
+                cl_open_dt,
+            </if>
+            <if test="closeDt != null">
+                close_dt,
+            </if>
+            <if test="clOrderNo != null">
+                cl_order_no,
+            </if>
+            <if test="clEleTotalAmount != null">
+                cl_ele_total_amount,
+            </if>
+            <if test="clWaterRemainUser != null">
+                cl_water_remain_user,
+            </if>
+            <if test="clThisEle != null">
+                cl_this_ele,
+            </if>
+        </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="id != null">
+                #{id,jdbcType=BIGINT},
+            </if>
+            <if test="clientId != null">
+                #{clientId,jdbcType=BIGINT},
+            </if>
+            <if test="clientName != null">
+                #{clientName,jdbcType=VARCHAR},
+            </if>
+            <if test="controllerId != null">
+                #{controllerId,jdbcType=BIGINT},
+            </if>
+            <if test="intakeId != null">
+                #{intakeId,jdbcType=BIGINT},
+            </if>
+            <if test="rtuAddr != null">
+                #{rtuAddr,jdbcType=VARCHAR},
+            </if>
+            <if test="opDt != null">
+                #{opDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="opType != null">
+                #{opType,jdbcType=TINYINT},
+            </if>
+            <if test="opTotalAmount != null">
+                #{opTotalAmount,jdbcType=DOUBLE},
+            </if>
+            <if test="opIcCardNo != null">
+                #{opIcCardNo,jdbcType=VARCHAR},
+            </if>
+            <if test="opIcCardAddr != null">
+                #{opIcCardAddr,jdbcType=VARCHAR},
+            </if>
+            <if test="opRemainMoney != null">
+                #{opRemainMoney,jdbcType=DOUBLE},
+            </if>
+            <if test="openDt != null">
+                #{openDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="opOrderNo != null">
+                #{opOrderNo,jdbcType=VARCHAR},
+            </if>
+            <if test="opEleTotalAmount != null">
+                #{opEleTotalAmount,jdbcType=FLOAT},
+            </if>
+            <if test="opWaterRemainUser != null">
+                #{opWaterRemainUser,jdbcType=FLOAT},
+            </if>
+            <if test="clDt != null">
+                #{clDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="clType != null">
+                #{clType,jdbcType=TINYINT},
+            </if>
+            <if test="clTotalAmount != null">
+                #{clTotalAmount,jdbcType=DOUBLE},
+            </if>
+            <if test="clIcCardNo != null">
+                #{clIcCardNo,jdbcType=VARCHAR},
+            </if>
+            <if test="clIcCardAddr != null">
+                #{clIcCardAddr,jdbcType=VARCHAR},
+            </if>
+            <if test="clRemainMoney != null">
+                #{clRemainMoney,jdbcType=DOUBLE},
+            </if>
+            <if test="clThisAmount != null">
+                #{clThisAmount,jdbcType=DOUBLE},
+            </if>
+            <if test="clThisMoney != null">
+                #{clThisMoney,jdbcType=DOUBLE},
+            </if>
+            <if test="clThisTime != null">
+                #{clThisTime,jdbcType=INTEGER},
+            </if>
+            <if test="clOpenDt != null">
+                #{clOpenDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="closeDt != null">
+                #{closeDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="clOrderNo != null">
+                #{clOrderNo,jdbcType=VARCHAR},
+            </if>
+            <if test="clEleTotalAmount != null">
+                #{clEleTotalAmount,jdbcType=FLOAT},
+            </if>
+            <if test="clWaterRemainUser != null">
+                #{clWaterRemainUser,jdbcType=FLOAT},
+            </if>
+            <if test="clThisEle != null">
+                #{clThisEle,jdbcType=FLOAT},
+            </if>
+        </trim>
+    </insert>
+    <update id="updateByPrimaryKeySelective" parameterType="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveHistory">
+        <!--@mbg.generated-->
+        update rm_open_close_valve_history
+        <set>
+            <if test="clientId != null">
+                client_id = #{clientId,jdbcType=BIGINT},
+            </if>
+            <if test="clientName != null">
+                client_name = #{clientName,jdbcType=VARCHAR},
+            </if>
+            <if test="controllerId != null">
+                controller_id = #{controllerId,jdbcType=BIGINT},
+            </if>
+            <if test="intakeId != null">
+                intake_id = #{intakeId,jdbcType=BIGINT},
+            </if>
+            <if test="rtuAddr != null">
+                rtu_addr = #{rtuAddr,jdbcType=VARCHAR},
+            </if>
+            <if test="opDt != null">
+                op_dt = #{opDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="opType != null">
+                op_type = #{opType,jdbcType=TINYINT},
+            </if>
+            <if test="opTotalAmount != null">
+                op_total_amount = #{opTotalAmount,jdbcType=DOUBLE},
+            </if>
+            <if test="opIcCardNo != null">
+                op_ic_card_no = #{opIcCardNo,jdbcType=VARCHAR},
+            </if>
+            <if test="opIcCardAddr != null">
+                op_ic_card_addr = #{opIcCardAddr,jdbcType=VARCHAR},
+            </if>
+            <if test="opRemainMoney != null">
+                op_remain_money = #{opRemainMoney,jdbcType=DOUBLE},
+            </if>
+            <if test="openDt != null">
+                open_dt = #{openDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="opOrderNo != null">
+                op_order_no = #{opOrderNo,jdbcType=VARCHAR},
+            </if>
+            <if test="opEleTotalAmount != null">
+                op_ele_total_amount = #{opEleTotalAmount,jdbcType=FLOAT},
+            </if>
+            <if test="opWaterRemainUser != null">
+                op_water_remain_user = #{opWaterRemainUser,jdbcType=FLOAT},
+            </if>
+            <if test="clDt != null">
+                cl_dt = #{clDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="clType != null">
+                cl_type = #{clType,jdbcType=TINYINT},
+            </if>
+            <if test="clTotalAmount != null">
+                cl_total_amount = #{clTotalAmount,jdbcType=DOUBLE},
+            </if>
+            <if test="clIcCardNo != null">
+                cl_ic_card_no = #{clIcCardNo,jdbcType=VARCHAR},
+            </if>
+            <if test="clIcCardAddr != null">
+                cl_ic_card_addr = #{clIcCardAddr,jdbcType=VARCHAR},
+            </if>
+            <if test="clRemainMoney != null">
+                cl_remain_money = #{clRemainMoney,jdbcType=DOUBLE},
+            </if>
+            <if test="clThisAmount != null">
+                cl_this_amount = #{clThisAmount,jdbcType=DOUBLE},
+            </if>
+            <if test="clThisMoney != null">
+                cl_this_money = #{clThisMoney,jdbcType=DOUBLE},
+            </if>
+            <if test="clThisTime != null">
+                cl_this_time = #{clThisTime,jdbcType=INTEGER},
+            </if>
+            <if test="clOpenDt != null">
+                cl_open_dt = #{clOpenDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="closeDt != null">
+                close_dt = #{closeDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="clOrderNo != null">
+                cl_order_no = #{clOrderNo,jdbcType=VARCHAR},
+            </if>
+            <if test="clEleTotalAmount != null">
+                cl_ele_total_amount = #{clEleTotalAmount,jdbcType=FLOAT},
+            </if>
+            <if test="clWaterRemainUser != null">
+                cl_water_remain_user = #{clWaterRemainUser,jdbcType=FLOAT},
+            </if>
+            <if test="clThisEle != null">
+                cl_this_ele = #{clThisEle,jdbcType=FLOAT},
+            </if>
+        </set>
+        where id = #{id,jdbcType=BIGINT}
+    </update>
+    <update id="updateByPrimaryKey" parameterType="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveHistory">
+        <!--@mbg.generated-->
+        update rm_open_close_valve_history
+        set client_id            = #{clientId,jdbcType=BIGINT},
+            client_name          = #{clientName,jdbcType=VARCHAR},
+            controller_id        = #{controllerId,jdbcType=BIGINT},
+            intake_id            = #{intakeId,jdbcType=BIGINT},
+            rtu_addr             = #{rtuAddr,jdbcType=VARCHAR},
+            op_dt                = #{opDt,jdbcType=TIMESTAMP},
+            op_type              = #{opType,jdbcType=TINYINT},
+            op_total_amount      = #{opTotalAmount,jdbcType=DOUBLE},
+            op_ic_card_no        = #{opIcCardNo,jdbcType=VARCHAR},
+            op_ic_card_addr      = #{opIcCardAddr,jdbcType=VARCHAR},
+            op_remain_money      = #{opRemainMoney,jdbcType=DOUBLE},
+            open_dt              = #{openDt,jdbcType=TIMESTAMP},
+            op_order_no          = #{opOrderNo,jdbcType=VARCHAR},
+            op_ele_total_amount  = #{opEleTotalAmount,jdbcType=FLOAT},
+            op_water_remain_user = #{opWaterRemainUser,jdbcType=FLOAT},
+            cl_dt                = #{clDt,jdbcType=TIMESTAMP},
+            cl_type              = #{clType,jdbcType=TINYINT},
+            cl_total_amount      = #{clTotalAmount,jdbcType=DOUBLE},
+            cl_ic_card_no        = #{clIcCardNo,jdbcType=VARCHAR},
+            cl_ic_card_addr      = #{clIcCardAddr,jdbcType=VARCHAR},
+            cl_remain_money      = #{clRemainMoney,jdbcType=DOUBLE},
+            cl_this_amount       = #{clThisAmount,jdbcType=DOUBLE},
+            cl_this_money        = #{clThisMoney,jdbcType=DOUBLE},
+            cl_this_time         = #{clThisTime,jdbcType=INTEGER},
+            cl_open_dt           = #{clOpenDt,jdbcType=TIMESTAMP},
+            close_dt             = #{closeDt,jdbcType=TIMESTAMP},
+            cl_order_no          = #{clOrderNo,jdbcType=VARCHAR},
+            cl_ele_total_amount  = #{clEleTotalAmount,jdbcType=FLOAT},
+            cl_water_remain_user = #{clWaterRemainUser,jdbcType=FLOAT},
+            cl_this_ele          = #{clThisEle,jdbcType=FLOAT}
+        where id = #{id,jdbcType=BIGINT}
+    </update>
 
-  <!--鏍规嵁鎸囧畾鏉′欢鑾峰彇寮�鍏抽榾鎶ュ巻鍙茶褰曟暟閲�-->
-  <select id="getOpenCloseValveReportsCount_history" resultType="java.lang.Long">
-    SELECT
-        COUNT(*) AS recordCount
-    FROM rm_open_close_valve_history oh
-    INNER JOIN pr_intake inta ON inta.id = oh.intake_id
-    <where>
-      <if test="intakeId != null and intakeId >0">
-        AND oh.intake_id = #{intakeId}
-      </if>
-      <if test = "intakeNum != null and intakeNum !=''">
-        AND inta.name LIKE CONCAT('%',#{intakeNum},'%')
-      </if>
-      <if test = "rtuAddr != null and rtuAddr !=''">
-        AND oh.rtu_addr LIKE CONCAT('%',#{rtuAddr},'%')
-      </if>
-      <if test = "timeStart_open != null and timeStop_open != null">
-        AND oh.op_dt BETWEEN #{timeStart_open} AND #{timeStop_open}
-      </if>
-      <if test = "timeStart_close != null and timeStop_close != null">
-        AND oh.cl_dt BETWEEN #{timeStart_close} AND #{timeStop_close}
-      </if>
-    </where>
-  </select>
+    <!--鏍规嵁鎸囧畾鏉′欢鑾峰彇寮�鍏抽榾鎶ュ巻鍙茶褰曟暟閲�-->
+    <select id="getOpenCloseValveReportsCount_history" resultType="java.lang.Long">
+        SELECT COUNT(*) AS recordCount
+        FROM rm_open_close_valve_history oh
+                 INNER JOIN pr_intake inta ON inta.id = oh.intake_id
+        <where>
+            <if test="intakeId != null and intakeId > 0">
+                AND oh.intake_id = #{intakeId}
+            </if>
+            <if test="intakeNum != null and intakeNum != ''">
+                AND inta.name LIKE CONCAT('%', #{intakeNum}, '%')
+            </if>
+            <if test="rtuAddr != null and rtuAddr != ''">
+                AND oh.rtu_addr LIKE CONCAT('%', #{rtuAddr}, '%')
+            </if>
+            <if test="timeStart_open != null and timeStop_open != null">
+                AND oh.op_dt BETWEEN #{timeStart_open} AND #{timeStop_open}
+            </if>
+            <if test="timeStart_close != null and timeStop_close != null">
+                AND oh.cl_dt BETWEEN #{timeStart_close} AND #{timeStop_close}
+            </if>
+        </where>
+    </select>
 
-  <!--鏍规嵁鎸囧畾鏉′欢鑾峰彇寮�鍏抽榾鎶ュ巻鍙茶褰�-->
-  <select id="getOpenCloseValveReports_history" resultType="com.dy.pipIrrGlobal.voRm.VoOpenCloseValve">
-    SELECT
-      oh.intake_id AS intakeId,
-      inta.name AS intakenum,
-      oh.rtu_addr AS rtuAddr,
-      oh.client_name AS clientName,
-      oh.op_ic_card_no AS openIcNum,
-      oh.op_ic_card_addr AS openIcAddr,
-      oh.op_dt AS openTime,
-    CASE
-      WHEN oh.op_type = 1 THEN "鍒峰崱寮�闃�"
-      WHEN oh.op_type = 3 THEN "涓績绔欏紑闃�"
-      WHEN oh.op_type = 5 THEN "娆犺垂鍏抽榾"
-      WHEN oh.op_type = 8 THEN "鐢ㄦ埛杩滅▼寮�闃�"
-      WHEN oh.op_type = 11 THEN "寮�鍏抽榾鍗″紑闃�"
-      ELSE "鏈煡"
-    END AS openType,
-      oh.op_order_no AS openOrderNo,
-      oh.op_total_amount AS openTotalAmount,
-      oh.op_remain_money AS openRemainMoney,
-      oh.op_water_remain_user AS openWaterRemain,
-      oh.op_ele_total_amount AS openEleTotalAmount,
-      oh.cl_ic_card_no AS closeIcNum,
-      oh.cl_ic_card_addr AS closeIcAddr,
-      oh.cl_dt AS closeTime,
-    CASE
-      WHEN oh.cl_type = 2 THEN "鍒峰崱鍏抽榾"
-      WHEN oh.cl_type = 4 THEN "涓績绔欏叧闃�"
-      WHEN oh.cl_type = 5 THEN "娆犺垂鍏抽榾"
-      WHEN oh.cl_type = 6 THEN "娴侀噺璁℃晠闅滃叧闃�"
-      WHEN oh.cl_type = 7 THEN "绱ф�ュ叧闂�"
-      WHEN oh.cl_type = 9 THEN "鐢ㄦ埛杩滅▼鍏抽榾"
-      WHEN oh.cl_type = 10 THEN "寮�鍏抽榾鍗″叧闃�"
-      WHEN oh.cl_type = 12 THEN "榛戝悕鍗曞懡浠ゅ叧闃�"
-      WHEN oh.cl_type = 13 THEN "鐢ㄦ埛杩滅▼瀹氭椂鍏抽榾"
-      WHEN oh.cl_type = 14 THEN "鐢ㄦ埛杩滅▼瀹氶噺鍏抽榾"
-      ELSE "鏈煡"
-    END AS closeType,
-      oh.cl_this_amount AS closeThisAmount,
-      oh.cl_this_time AS thisTime,
-      oh.cl_this_money AS thisMoney,
-      oh.cl_remain_money AS closeRemainMoney,
-      oh.cl_total_amount AS closeTotalAmount
-    FROM rm_open_close_valve_history oh
-    INNER JOIN pr_intake inta ON inta.id = oh.intake_id
-    <where>
-      <if test="intakeId != null and intakeId >0">
-        AND oh.intake_id = #{intakeId}
-      </if>
-      <if test = "intakeNum != null and intakeNum !=''">
-        AND inta.name LIKE CONCAT('%',#{intakeNum},'%')
-      </if>
-      <if test = "rtuAddr != null and rtuAddr !=''">
-        AND oh.rtu_addr LIKE CONCAT('%',#{rtuAddr},'%')
-      </if>
-      <if test = "timeStart_open != null and timeStop_open != null">
-        AND oh.op_dt BETWEEN #{timeStart_open} AND #{timeStop_open}
-      </if>
-      <if test = "timeStart_close != null and timeStop_close != null">
-        AND oh.cl_dt BETWEEN #{timeStart_close} AND #{timeStop_close}
-      </if>
-    </where>
-    ORDER BY oh.op_dt DESC
-    <trim prefix="limit " >
-      <if test="start != null and count != null">
-        #{start,javaType=Integer,jdbcType=INTEGER}, #{count,javaType=Integer,jdbcType=INTEGER}
-      </if>
-    </trim>
-  </select>
+    <!--鏍规嵁鎸囧畾鏉′欢鑾峰彇寮�鍏抽榾鎶ュ巻鍙茶褰�-->
+    <select id="getOpenCloseValveReports_history" resultType="com.dy.pipIrrGlobal.voRm.VoOpenCloseValve">
+        SELECT oh.intake_id            AS intakeId,
+               inta.name               AS intakenum,
+               oh.rtu_addr             AS rtuAddr,
+               oh.client_name          AS clientName,
+               oh.op_ic_card_no        AS openIcNum,
+               oh.op_ic_card_addr      AS openIcAddr,
+               oh.op_dt                AS openTime,
+               CASE
+                   WHEN oh.op_type = 1 THEN '鍒峰崱寮�闃�'
+                   WHEN oh.op_type = 3 THEN '涓績绔欏紑闃�'
+                   WHEN oh.op_type = 5 THEN '娆犺垂鍏抽榾'
+                   WHEN oh.op_type = 8 THEN '鐢ㄦ埛杩滅▼寮�闃�'
+                   WHEN oh.op_type = 11 THEN '寮�鍏抽榾鍗″紑闃�'
+                   ELSE '鏈煡'
+                   END                 AS openType,
+               oh.op_order_no          AS openOrderNo,
+               oh.op_total_amount      AS openTotalAmount,
+               oh.op_remain_money      AS openRemainMoney,
+               oh.op_water_remain_user AS openWaterRemain,
+               oh.op_ele_total_amount  AS openEleTotalAmount,
+               oh.cl_ic_card_no        AS closeIcNum,
+               oh.cl_ic_card_addr      AS closeIcAddr,
+               oh.cl_dt                AS closeTime,
+               CASE
+                   WHEN oh.cl_type = 2 THEN '鍒峰崱鍏抽榾'
+                   WHEN oh.cl_type = 4 THEN '涓績绔欏叧闃�'
+                   WHEN oh.cl_type = 5 THEN '娆犺垂鍏抽榾'
+                   WHEN oh.cl_type = 6 THEN '娴侀噺璁℃晠闅滃叧闃�'
+                   WHEN oh.cl_type = 7 THEN '绱ф�ュ叧闃�'
+                   WHEN oh.cl_type = 9 THEN '鐢ㄦ埛杩滅▼鍏抽榾'
+                   WHEN oh.cl_type = 10 THEN '寮�鍏抽榾鍗″叧闃�'
+                   WHEN oh.cl_type = 12 THEN '榛戝悕鍗曞懡浠ゅ叧闃�'
+                   WHEN oh.cl_type = 13 THEN '杩滅▼瀹氭椂鍏抽榾'
+                   WHEN oh.cl_type = 14 THEN '杩滅▼瀹氶噺鍏抽榾'
+                   ELSE '鏈煡'
+                   END                 AS closeType,
+               oh.cl_this_amount       AS closeThisAmount,
+               oh.cl_this_time         AS thisTime,
+               oh.cl_this_money        AS thisMoney,
+               oh.cl_remain_money      AS closeRemainMoney,
+               oh.cl_total_amount      AS closeTotalAmount
+        FROM rm_open_close_valve_history oh
+                 INNER JOIN pr_intake inta ON inta.id = oh.intake_id
+        <where>
+            <if test="intakeId != null and intakeId > 0">
+                AND oh.intake_id = #{intakeId}
+            </if>
+            <if test="intakeNum != null and intakeNum != ''">
+                AND inta.name LIKE CONCAT('%', #{intakeNum}, '%')
+            </if>
+            <if test="rtuAddr != null and rtuAddr != ''">
+                AND oh.rtu_addr LIKE CONCAT('%', #{rtuAddr}, '%')
+            </if>
+            <if test="timeStart_open != null and timeStop_open != null">
+                AND oh.op_dt BETWEEN #{timeStart_open} AND #{timeStop_open}
+            </if>
+            <if test="timeStart_close != null and timeStop_close != null">
+                AND oh.cl_dt BETWEEN #{timeStart_close} AND #{timeStop_close}
+            </if>
+        </where>
+        ORDER BY oh.op_dt DESC
+        <trim prefix="limit ">
+            <if test="start != null and count != null">
+                #{start,javaType=Integer,jdbcType=INTEGER}, #{count,javaType=Integer,jdbcType=INTEGER}
+            </if>
+        </trim>
+    </select>
 </mapper>
\ No newline at end of file
diff --git a/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOpenCloseValveLastMapper.xml b/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOpenCloseValveLastMapper.xml
index 61890c6..dba5edd 100644
--- a/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOpenCloseValveLastMapper.xml
+++ b/pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOpenCloseValveLastMapper.xml
@@ -1,527 +1,575 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.dy.pipIrrGlobal.daoRm.RmOpenCloseValveLastMapper">
-  <resultMap id="BaseResultMap" type="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveLast">
-    <!--@mbg.generated-->
-    <!--@Table rm_open_close_valve_last-->
-    <id column="id" jdbcType="BIGINT" property="id" />
-    <result column="last_history_id" jdbcType="BIGINT" property="lastHistoryId" />
-    <result column="client_id" jdbcType="BIGINT" property="clientId" />
-    <result column="client_name" jdbcType="VARCHAR" property="clientName" />
-    <result column="controller_id" jdbcType="BIGINT" property="controllerId" />
-    <result column="intake_id" jdbcType="BIGINT" property="intakeId" />
-    <result column="rtu_addr" jdbcType="VARCHAR" property="rtuAddr" />
-    <result column="op_dt" jdbcType="TIMESTAMP" property="opDt" />
-    <result column="op_type" jdbcType="TINYINT" property="opType" />
-    <result column="op_total_amount" jdbcType="DOUBLE" property="opTotalAmount" />
-    <result column="op_ic_card_no" jdbcType="VARCHAR" property="opIcCardNo" />
-    <result column="op_ic_card_addr" jdbcType="VARCHAR" property="opIcCardAddr" />
-    <result column="op_remain_money" jdbcType="DOUBLE" property="opRemainMoney" />
-    <result column="open_dt" jdbcType="TIMESTAMP" property="openDt" />
-    <result column="op_order_no" jdbcType="VARCHAR" property="opOrderNo" />
-    <result column="op_ele_total_amount" jdbcType="FLOAT" property="opEleTotalAmount" />
-    <result column="op_water_remain_user" jdbcType="FLOAT" property="opWaterRemainUser" />
-    <result column="cl_dt" jdbcType="TIMESTAMP" property="clDt" />
-    <result column="cl_type" jdbcType="TINYINT" property="clType" />
-    <result column="cl_total_amount" jdbcType="DOUBLE" property="clTotalAmount" />
-    <result column="cl_ic_card_no" jdbcType="VARCHAR" property="clIcCardNo" />
-    <result column="cl_ic_card_addr" jdbcType="VARCHAR" property="clIcCardAddr" />
-    <result column="cl_remain_money" jdbcType="DOUBLE" property="clRemainMoney" />
-    <result column="cl_this_amount" jdbcType="DOUBLE" property="clThisAmount" />
-    <result column="cl_this_money" jdbcType="DOUBLE" property="clThisMoney" />
-    <result column="cl_this_time" jdbcType="INTEGER" property="clThisTime" />
-    <result column="cl_open_dt" jdbcType="TIMESTAMP" property="clOpenDt" />
-    <result column="close_dt" jdbcType="TIMESTAMP" property="closeDt" />
-    <result column="cl_order_no" jdbcType="VARCHAR" property="clOrderNo" />
-    <result column="cl_ele_total_amount" jdbcType="FLOAT" property="clEleTotalAmount" />
-    <result column="cl_water_remain_user" jdbcType="FLOAT" property="clWaterRemainUser" />
-    <result column="cl_this_ele" jdbcType="FLOAT" property="clThisEle" />
-  </resultMap>
-  <sql id="Base_Column_List">
-    <!--@mbg.generated-->
-    id, last_history_id, client_id, client_name,
-    controller_id, intake_id, rtu_addr, op_dt, op_type, op_total_amount,
-    op_ic_card_no, op_ic_card_addr, op_remain_money, open_dt, op_order_no, op_ele_total_amount, 
-    op_water_remain_user, cl_dt, cl_type, cl_total_amount, cl_ic_card_no, cl_ic_card_addr, 
-    cl_remain_money, cl_this_amount, cl_this_money, cl_this_time, cl_open_dt, close_dt, 
-    cl_order_no, cl_ele_total_amount, cl_water_remain_user, cl_this_ele
-  </sql>
-  <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
-    <!--@mbg.generated-->
-    select 
-    <include refid="Base_Column_List" />
-    from rm_open_close_valve_last
-    where id = #{id,jdbcType=BIGINT}
-  </select>
-  <select id="selectByIntakeId" parameterType="java.lang.Long" resultMap="BaseResultMap">
-    <!--@mbg.generated-->
-    select
-    <include refid="Base_Column_List" />
-    from rm_open_close_valve_last
-    where intake_id = #{intakeId,jdbcType=BIGINT}
-  </select>
-  <delete id="deleteByPrimaryKey" parameterType="java.lang.Long">
-    <!--@mbg.generated-->
-    delete from rm_open_close_valve_last
-    where id = #{id,jdbcType=BIGINT}
-  </delete>
-  <insert id="insert" parameterType="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveLast">
-    <!--@mbg.generated-->
-    insert into rm_open_close_valve_last (id, last_history_id,
-      client_id, client_name, controller_id,
-      intake_id, rtu_addr, op_dt, 
-      op_type, op_total_amount, op_ic_card_no, 
-      op_ic_card_addr, op_remain_money, open_dt, 
-      op_order_no, op_ele_total_amount, op_water_remain_user, 
-      cl_dt, cl_type, cl_total_amount, 
-      cl_ic_card_no, cl_ic_card_addr, cl_remain_money, 
-      cl_this_amount, cl_this_money, cl_this_time, 
-      cl_open_dt, close_dt, cl_order_no, 
-      cl_ele_total_amount, cl_water_remain_user, cl_this_ele
-      )
-    values (#{id,jdbcType=BIGINT}, #{lastHistoryId,jdbcType=BIGINT},
-      #{clientId,jdbcType=BIGINT}, #{clientName,jdbcType=VARCHAR}, #{controllerId,jdbcType=BIGINT},
-      #{intakeId,jdbcType=BIGINT}, #{rtuAddr,jdbcType=VARCHAR}, #{opDt,jdbcType=TIMESTAMP}, 
-      #{opType,jdbcType=TINYINT}, #{opTotalAmount,jdbcType=DOUBLE}, #{opIcCardNo,jdbcType=VARCHAR}, 
-      #{opIcCardAddr,jdbcType=VARCHAR}, #{opRemainMoney,jdbcType=DOUBLE}, #{openDt,jdbcType=TIMESTAMP}, 
-      #{opOrderNo,jdbcType=VARCHAR}, #{opEleTotalAmount,jdbcType=FLOAT}, #{opWaterRemainUser,jdbcType=FLOAT}, 
-      #{clDt,jdbcType=TIMESTAMP}, #{clType,jdbcType=TINYINT}, #{clTotalAmount,jdbcType=DOUBLE}, 
-      #{clIcCardNo,jdbcType=VARCHAR}, #{clIcCardAddr,jdbcType=VARCHAR}, #{clRemainMoney,jdbcType=DOUBLE}, 
-      #{clThisAmount,jdbcType=DOUBLE}, #{clThisMoney,jdbcType=DOUBLE}, #{clThisTime,jdbcType=INTEGER}, 
-      #{clOpenDt,jdbcType=TIMESTAMP}, #{closeDt,jdbcType=TIMESTAMP}, #{clOrderNo,jdbcType=VARCHAR}, 
-      #{clEleTotalAmount,jdbcType=FLOAT}, #{clWaterRemainUser,jdbcType=FLOAT}, #{clThisEle,jdbcType=FLOAT}
-      )
-  </insert>
-  <insert id="insertSelective" parameterType="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveLast">
-    <!--@mbg.generated-->
-    insert into rm_open_close_valve_last
-    <trim prefix="(" suffix=")" suffixOverrides=",">
-      <if test="id != null">
+    <resultMap id="BaseResultMap" type="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveLast">
+        <!--@mbg.generated-->
+        <!--@Table rm_open_close_valve_last-->
+        <id column="id" jdbcType="BIGINT" property="id"/>
+        <result column="last_history_id" jdbcType="BIGINT" property="lastHistoryId"/>
+        <result column="client_id" jdbcType="BIGINT" property="clientId"/>
+        <result column="client_name" jdbcType="VARCHAR" property="clientName"/>
+        <result column="controller_id" jdbcType="BIGINT" property="controllerId"/>
+        <result column="intake_id" jdbcType="BIGINT" property="intakeId"/>
+        <result column="rtu_addr" jdbcType="VARCHAR" property="rtuAddr"/>
+        <result column="op_dt" jdbcType="TIMESTAMP" property="opDt"/>
+        <result column="op_type" jdbcType="TINYINT" property="opType"/>
+        <result column="op_total_amount" jdbcType="DOUBLE" property="opTotalAmount"/>
+        <result column="op_ic_card_no" jdbcType="VARCHAR" property="opIcCardNo"/>
+        <result column="op_ic_card_addr" jdbcType="VARCHAR" property="opIcCardAddr"/>
+        <result column="op_remain_money" jdbcType="DOUBLE" property="opRemainMoney"/>
+        <result column="open_dt" jdbcType="TIMESTAMP" property="openDt"/>
+        <result column="op_order_no" jdbcType="VARCHAR" property="opOrderNo"/>
+        <result column="op_ele_total_amount" jdbcType="FLOAT" property="opEleTotalAmount"/>
+        <result column="op_water_remain_user" jdbcType="FLOAT" property="opWaterRemainUser"/>
+        <result column="cl_dt" jdbcType="TIMESTAMP" property="clDt"/>
+        <result column="cl_type" jdbcType="TINYINT" property="clType"/>
+        <result column="cl_total_amount" jdbcType="DOUBLE" property="clTotalAmount"/>
+        <result column="cl_ic_card_no" jdbcType="VARCHAR" property="clIcCardNo"/>
+        <result column="cl_ic_card_addr" jdbcType="VARCHAR" property="clIcCardAddr"/>
+        <result column="cl_remain_money" jdbcType="DOUBLE" property="clRemainMoney"/>
+        <result column="cl_this_amount" jdbcType="DOUBLE" property="clThisAmount"/>
+        <result column="cl_this_money" jdbcType="DOUBLE" property="clThisMoney"/>
+        <result column="cl_this_time" jdbcType="INTEGER" property="clThisTime"/>
+        <result column="cl_open_dt" jdbcType="TIMESTAMP" property="clOpenDt"/>
+        <result column="close_dt" jdbcType="TIMESTAMP" property="closeDt"/>
+        <result column="cl_order_no" jdbcType="VARCHAR" property="clOrderNo"/>
+        <result column="cl_ele_total_amount" jdbcType="FLOAT" property="clEleTotalAmount"/>
+        <result column="cl_water_remain_user" jdbcType="FLOAT" property="clWaterRemainUser"/>
+        <result column="cl_this_ele" jdbcType="FLOAT" property="clThisEle"/>
+    </resultMap>
+    <sql id="Base_Column_List">
+        <!--@mbg.generated-->
         id,
-      </if>
-      <if test="lastHistoryId != null">
         last_history_id,
-      </if>
-      <if test="clientId != null">
         client_id,
-      </if>
-     <if test="clientName != null">
         client_name,
-      </if>
-      <if test="controllerId != null">
         controller_id,
-      </if>
-      <if test="intakeId != null">
         intake_id,
-      </if>
-      <if test="rtuAddr != null">
         rtu_addr,
-      </if>
-      <if test="opDt != null">
         op_dt,
-      </if>
-      <if test="opType != null">
         op_type,
-      </if>
-      <if test="opTotalAmount != null">
         op_total_amount,
-      </if>
-      <if test="opIcCardNo != null">
         op_ic_card_no,
-      </if>
-      <if test="opIcCardAddr != null">
         op_ic_card_addr,
-      </if>
-      <if test="opRemainMoney != null">
         op_remain_money,
-      </if>
-      <if test="openDt != null">
         open_dt,
-      </if>
-      <if test="opOrderNo != null">
         op_order_no,
-      </if>
-      <if test="opEleTotalAmount != null">
         op_ele_total_amount,
-      </if>
-      <if test="opWaterRemainUser != null">
         op_water_remain_user,
-      </if>
-      <if test="clDt != null">
         cl_dt,
-      </if>
-      <if test="clType != null">
         cl_type,
-      </if>
-      <if test="clTotalAmount != null">
         cl_total_amount,
-      </if>
-      <if test="clIcCardNo != null">
         cl_ic_card_no,
-      </if>
-      <if test="clIcCardAddr != null">
         cl_ic_card_addr,
-      </if>
-      <if test="clRemainMoney != null">
         cl_remain_money,
-      </if>
-      <if test="clThisAmount != null">
         cl_this_amount,
-      </if>
-      <if test="clThisMoney != null">
         cl_this_money,
-      </if>
-      <if test="clThisTime != null">
         cl_this_time,
-      </if>
-      <if test="clOpenDt != null">
         cl_open_dt,
-      </if>
-      <if test="closeDt != null">
         close_dt,
-      </if>
-      <if test="clOrderNo != null">
         cl_order_no,
-      </if>
-      <if test="clEleTotalAmount != null">
         cl_ele_total_amount,
-      </if>
-      <if test="clWaterRemainUser != null">
         cl_water_remain_user,
-      </if>
-      <if test="clThisEle != null">
-        cl_this_ele,
-      </if>
-    </trim>
-    <trim prefix="values (" suffix=")" suffixOverrides=",">
-      <if test="id != null">
-        #{id,jdbcType=BIGINT},
-      </if>
-      <if test="lastHistoryId != null">
-        #{lastHistoryId,jdbcType=BIGINT},
-      </if>
-      <if test="clientId != null">
-        #{clientId,jdbcType=BIGINT},
-      </if>
-      <if test="clientName != null">
-        #{clientName,jdbcType=VARCHAR},
-      </if>
-      <if test="controllerId != null">
-        #{controllerId,jdbcType=BIGINT},
-      </if>
-      <if test="intakeId != null">
-        #{intakeId,jdbcType=BIGINT},
-      </if>
-      <if test="rtuAddr != null">
-        #{rtuAddr,jdbcType=VARCHAR},
-      </if>
-      <if test="opDt != null">
-        #{opDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="opType != null">
-        #{opType,jdbcType=TINYINT},
-      </if>
-      <if test="opTotalAmount != null">
-        #{opTotalAmount,jdbcType=DOUBLE},
-      </if>
-      <if test="opIcCardNo != null">
-        #{opIcCardNo,jdbcType=VARCHAR},
-      </if>
-      <if test="opIcCardAddr != null">
-        #{opIcCardAddr,jdbcType=VARCHAR},
-      </if>
-      <if test="opRemainMoney != null">
-        #{opRemainMoney,jdbcType=DOUBLE},
-      </if>
-      <if test="openDt != null">
-        #{openDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="opOrderNo != null">
-        #{opOrderNo,jdbcType=VARCHAR},
-      </if>
-      <if test="opEleTotalAmount != null">
-        #{opEleTotalAmount,jdbcType=FLOAT},
-      </if>
-      <if test="opWaterRemainUser != null">
-        #{opWaterRemainUser,jdbcType=FLOAT},
-      </if>
-      <if test="clDt != null">
-        #{clDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="clType != null">
-        #{clType,jdbcType=TINYINT},
-      </if>
-      <if test="clTotalAmount != null">
-        #{clTotalAmount,jdbcType=DOUBLE},
-      </if>
-      <if test="clIcCardNo != null">
-        #{clIcCardNo,jdbcType=VARCHAR},
-      </if>
-      <if test="clIcCardAddr != null">
-        #{clIcCardAddr,jdbcType=VARCHAR},
-      </if>
-      <if test="clRemainMoney != null">
-        #{clRemainMoney,jdbcType=DOUBLE},
-      </if>
-      <if test="clThisAmount != null">
-        #{clThisAmount,jdbcType=DOUBLE},
-      </if>
-      <if test="clThisMoney != null">
-        #{clThisMoney,jdbcType=DOUBLE},
-      </if>
-      <if test="clThisTime != null">
-        #{clThisTime,jdbcType=INTEGER},
-      </if>
-      <if test="clOpenDt != null">
-        #{clOpenDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="closeDt != null">
-        #{closeDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="clOrderNo != null">
-        #{clOrderNo,jdbcType=VARCHAR},
-      </if>
-      <if test="clEleTotalAmount != null">
-        #{clEleTotalAmount,jdbcType=FLOAT},
-      </if>
-      <if test="clWaterRemainUser != null">
-        #{clWaterRemainUser,jdbcType=FLOAT},
-      </if>
-      <if test="clThisEle != null">
-        #{clThisEle,jdbcType=FLOAT},
-      </if>
-    </trim>
-  </insert>
-  <update id="updateByPrimaryKeySelective" parameterType="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveLast">
-    <!--@mbg.generated-->
-    update rm_open_close_valve_last
-    <set>
-      <if test="lastHistoryId != null">
-        last_history_id = #{lastHistoryId,jdbcType=BIGINT},
-      </if>
-      <if test="clientId != null">
-        client_id = #{clientId,jdbcType=BIGINT},
-      </if>
-      <if test="clientName != null">
-        client_name = #{clientName,jdbcType=VARCHAR},
-      </if>
-      <if test="controllerId != null">
-        controller_id = #{controllerId,jdbcType=BIGINT},
-      </if>
-      <if test="intakeId != null">
-        intake_id = #{intakeId,jdbcType=BIGINT},
-      </if>
-      <if test="rtuAddr != null">
-        rtu_addr = #{rtuAddr,jdbcType=VARCHAR},
-      </if>
-      <if test="opDt != null">
-        op_dt = #{opDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="opType != null">
-        op_type = #{opType,jdbcType=TINYINT},
-      </if>
-      <if test="opTotalAmount != null">
-        op_total_amount = #{opTotalAmount,jdbcType=DOUBLE},
-      </if>
-      <if test="opIcCardNo != null">
-        op_ic_card_no = #{opIcCardNo,jdbcType=VARCHAR},
-      </if>
-      <if test="opIcCardAddr != null">
-        op_ic_card_addr = #{opIcCardAddr,jdbcType=VARCHAR},
-      </if>
-      <if test="opRemainMoney != null">
-        op_remain_money = #{opRemainMoney,jdbcType=DOUBLE},
-      </if>
-      <if test="openDt != null">
-        open_dt = #{openDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="opOrderNo != null">
-        op_order_no = #{opOrderNo,jdbcType=VARCHAR},
-      </if>
-      <if test="opEleTotalAmount != null">
-        op_ele_total_amount = #{opEleTotalAmount,jdbcType=FLOAT},
-      </if>
-      <if test="opWaterRemainUser != null">
-        op_water_remain_user = #{opWaterRemainUser,jdbcType=FLOAT},
-      </if>
-      <if test="clDt != null">
-        cl_dt = #{clDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="clType != null">
-        cl_type = #{clType,jdbcType=TINYINT},
-      </if>
-      <if test="clTotalAmount != null">
-        cl_total_amount = #{clTotalAmount,jdbcType=DOUBLE},
-      </if>
-      <if test="clIcCardNo != null">
-        cl_ic_card_no = #{clIcCardNo,jdbcType=VARCHAR},
-      </if>
-      <if test="clIcCardAddr != null">
-        cl_ic_card_addr = #{clIcCardAddr,jdbcType=VARCHAR},
-      </if>
-      <if test="clRemainMoney != null">
-        cl_remain_money = #{clRemainMoney,jdbcType=DOUBLE},
-      </if>
-      <if test="clThisAmount != null">
-        cl_this_amount = #{clThisAmount,jdbcType=DOUBLE},
-      </if>
-      <if test="clThisMoney != null">
-        cl_this_money = #{clThisMoney,jdbcType=DOUBLE},
-      </if>
-      <if test="clThisTime != null">
-        cl_this_time = #{clThisTime,jdbcType=INTEGER},
-      </if>
-      <if test="clOpenDt != null">
-        cl_open_dt = #{clOpenDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="closeDt != null">
-        close_dt = #{closeDt,jdbcType=TIMESTAMP},
-      </if>
-      <if test="clOrderNo != null">
-        cl_order_no = #{clOrderNo,jdbcType=VARCHAR},
-      </if>
-      <if test="clEleTotalAmount != null">
-        cl_ele_total_amount = #{clEleTotalAmount,jdbcType=FLOAT},
-      </if>
-      <if test="clWaterRemainUser != null">
-        cl_water_remain_user = #{clWaterRemainUser,jdbcType=FLOAT},
-      </if>
-      <if test="clThisEle != null">
-        cl_this_ele = #{clThisEle,jdbcType=FLOAT},
-      </if>
-    </set>
-    where id = #{id,jdbcType=BIGINT}
-  </update>
-  <update id="updateByPrimaryKey" parameterType="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveLast">
-    <!--@mbg.generated-->
-    update rm_open_close_valve_last
-    set last_history_id = #{lastHistoryId,jdbcType=BIGINT},
-      client_id = #{clientId,jdbcType=BIGINT},
-      client_name = #{clientName,jdbcType=VARCHAR},
-      controller_id = #{controllerId,jdbcType=BIGINT},
-      intake_id = #{intakeId,jdbcType=BIGINT},
-      rtu_addr = #{rtuAddr,jdbcType=VARCHAR},
-      op_dt = #{opDt,jdbcType=TIMESTAMP},
-      op_type = #{opType,jdbcType=TINYINT},
-      op_total_amount = #{opTotalAmount,jdbcType=DOUBLE},
-      op_ic_card_no = #{opIcCardNo,jdbcType=VARCHAR},
-      op_ic_card_addr = #{opIcCardAddr,jdbcType=VARCHAR},
-      op_remain_money = #{opRemainMoney,jdbcType=DOUBLE},
-      open_dt = #{openDt,jdbcType=TIMESTAMP},
-      op_order_no = #{opOrderNo,jdbcType=VARCHAR},
-      op_ele_total_amount = #{opEleTotalAmount,jdbcType=FLOAT},
-      op_water_remain_user = #{opWaterRemainUser,jdbcType=FLOAT},
-      cl_dt = #{clDt,jdbcType=TIMESTAMP},
-      cl_type = #{clType,jdbcType=TINYINT},
-      cl_total_amount = #{clTotalAmount,jdbcType=DOUBLE},
-      cl_ic_card_no = #{clIcCardNo,jdbcType=VARCHAR},
-      cl_ic_card_addr = #{clIcCardAddr,jdbcType=VARCHAR},
-      cl_remain_money = #{clRemainMoney,jdbcType=DOUBLE},
-      cl_this_amount = #{clThisAmount,jdbcType=DOUBLE},
-      cl_this_money = #{clThisMoney,jdbcType=DOUBLE},
-      cl_this_time = #{clThisTime,jdbcType=INTEGER},
-      cl_open_dt = #{clOpenDt,jdbcType=TIMESTAMP},
-      close_dt = #{closeDt,jdbcType=TIMESTAMP},
-      cl_order_no = #{clOrderNo,jdbcType=VARCHAR},
-      cl_ele_total_amount = #{clEleTotalAmount,jdbcType=FLOAT},
-      cl_water_remain_user = #{clWaterRemainUser,jdbcType=FLOAT},
-      cl_this_ele = #{clThisEle,jdbcType=FLOAT}
-    where id = #{id,jdbcType=BIGINT}
-  </update>
+        cl_this_ele
+    </sql>
+    <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
+        <!--@mbg.generated-->
+        select
+        <include refid="Base_Column_List"/>
+        from rm_open_close_valve_last
+        where id = #{id,jdbcType=BIGINT}
+    </select>
+    <select id="selectByIntakeId" parameterType="java.lang.Long" resultMap="BaseResultMap">
+        <!--@mbg.generated-->
+        select
+        <include refid="Base_Column_List"/>
+        from rm_open_close_valve_last
+        where intake_id = #{intakeId,jdbcType=BIGINT}
+    </select>
+    <delete id="deleteByPrimaryKey" parameterType="java.lang.Long">
+        <!--@mbg.generated-->
+        delete
+        from rm_open_close_valve_last
+        where id = #{id,jdbcType=BIGINT}
+    </delete>
+    <insert id="insert" parameterType="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveLast">
+        <!--@mbg.generated-->
+        insert into rm_open_close_valve_last (id, last_history_id,
+                                              client_id, client_name, controller_id,
+                                              intake_id, rtu_addr, op_dt,
+                                              op_type, op_total_amount, op_ic_card_no,
+                                              op_ic_card_addr, op_remain_money, open_dt,
+                                              op_order_no, op_ele_total_amount, op_water_remain_user,
+                                              cl_dt, cl_type, cl_total_amount,
+                                              cl_ic_card_no, cl_ic_card_addr, cl_remain_money,
+                                              cl_this_amount, cl_this_money, cl_this_time,
+                                              cl_open_dt, close_dt, cl_order_no,
+                                              cl_ele_total_amount, cl_water_remain_user, cl_this_ele)
+        values (#{id,jdbcType=BIGINT}, #{lastHistoryId,jdbcType=BIGINT},
+                #{clientId,jdbcType=BIGINT}, #{clientName,jdbcType=VARCHAR}, #{controllerId,jdbcType=BIGINT},
+                #{intakeId,jdbcType=BIGINT}, #{rtuAddr,jdbcType=VARCHAR}, #{opDt,jdbcType=TIMESTAMP},
+                #{opType,jdbcType=TINYINT}, #{opTotalAmount,jdbcType=DOUBLE}, #{opIcCardNo,jdbcType=VARCHAR},
+                #{opIcCardAddr,jdbcType=VARCHAR}, #{opRemainMoney,jdbcType=DOUBLE}, #{openDt,jdbcType=TIMESTAMP},
+                #{opOrderNo,jdbcType=VARCHAR}, #{opEleTotalAmount,jdbcType=FLOAT}, #{opWaterRemainUser,jdbcType=FLOAT},
+                #{clDt,jdbcType=TIMESTAMP}, #{clType,jdbcType=TINYINT}, #{clTotalAmount,jdbcType=DOUBLE},
+                #{clIcCardNo,jdbcType=VARCHAR}, #{clIcCardAddr,jdbcType=VARCHAR}, #{clRemainMoney,jdbcType=DOUBLE},
+                #{clThisAmount,jdbcType=DOUBLE}, #{clThisMoney,jdbcType=DOUBLE}, #{clThisTime,jdbcType=INTEGER},
+                #{clOpenDt,jdbcType=TIMESTAMP}, #{closeDt,jdbcType=TIMESTAMP}, #{clOrderNo,jdbcType=VARCHAR},
+                #{clEleTotalAmount,jdbcType=FLOAT}, #{clWaterRemainUser,jdbcType=FLOAT}, #{clThisEle,jdbcType=FLOAT})
+    </insert>
+    <insert id="insertSelective" parameterType="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveLast">
+        <!--@mbg.generated-->
+        insert into rm_open_close_valve_last
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="id != null">
+                id,
+            </if>
+            <if test="lastHistoryId != null">
+                last_history_id,
+            </if>
+            <if test="clientId != null">
+                client_id,
+            </if>
+            <if test="clientName != null">
+                client_name,
+            </if>
+            <if test="controllerId != null">
+                controller_id,
+            </if>
+            <if test="intakeId != null">
+                intake_id,
+            </if>
+            <if test="rtuAddr != null">
+                rtu_addr,
+            </if>
+            <if test="opDt != null">
+                op_dt,
+            </if>
+            <if test="opType != null">
+                op_type,
+            </if>
+            <if test="opTotalAmount != null">
+                op_total_amount,
+            </if>
+            <if test="opIcCardNo != null">
+                op_ic_card_no,
+            </if>
+            <if test="opIcCardAddr != null">
+                op_ic_card_addr,
+            </if>
+            <if test="opRemainMoney != null">
+                op_remain_money,
+            </if>
+            <if test="openDt != null">
+                open_dt,
+            </if>
+            <if test="opOrderNo != null">
+                op_order_no,
+            </if>
+            <if test="opEleTotalAmount != null">
+                op_ele_total_amount,
+            </if>
+            <if test="opWaterRemainUser != null">
+                op_water_remain_user,
+            </if>
+            <if test="clDt != null">
+                cl_dt,
+            </if>
+            <if test="clType != null">
+                cl_type,
+            </if>
+            <if test="clTotalAmount != null">
+                cl_total_amount,
+            </if>
+            <if test="clIcCardNo != null">
+                cl_ic_card_no,
+            </if>
+            <if test="clIcCardAddr != null">
+                cl_ic_card_addr,
+            </if>
+            <if test="clRemainMoney != null">
+                cl_remain_money,
+            </if>
+            <if test="clThisAmount != null">
+                cl_this_amount,
+            </if>
+            <if test="clThisMoney != null">
+                cl_this_money,
+            </if>
+            <if test="clThisTime != null">
+                cl_this_time,
+            </if>
+            <if test="clOpenDt != null">
+                cl_open_dt,
+            </if>
+            <if test="closeDt != null">
+                close_dt,
+            </if>
+            <if test="clOrderNo != null">
+                cl_order_no,
+            </if>
+            <if test="clEleTotalAmount != null">
+                cl_ele_total_amount,
+            </if>
+            <if test="clWaterRemainUser != null">
+                cl_water_remain_user,
+            </if>
+            <if test="clThisEle != null">
+                cl_this_ele,
+            </if>
+        </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="id != null">
+                #{id,jdbcType=BIGINT},
+            </if>
+            <if test="lastHistoryId != null">
+                #{lastHistoryId,jdbcType=BIGINT},
+            </if>
+            <if test="clientId != null">
+                #{clientId,jdbcType=BIGINT},
+            </if>
+            <if test="clientName != null">
+                #{clientName,jdbcType=VARCHAR},
+            </if>
+            <if test="controllerId != null">
+                #{controllerId,jdbcType=BIGINT},
+            </if>
+            <if test="intakeId != null">
+                #{intakeId,jdbcType=BIGINT},
+            </if>
+            <if test="rtuAddr != null">
+                #{rtuAddr,jdbcType=VARCHAR},
+            </if>
+            <if test="opDt != null">
+                #{opDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="opType != null">
+                #{opType,jdbcType=TINYINT},
+            </if>
+            <if test="opTotalAmount != null">
+                #{opTotalAmount,jdbcType=DOUBLE},
+            </if>
+            <if test="opIcCardNo != null">
+                #{opIcCardNo,jdbcType=VARCHAR},
+            </if>
+            <if test="opIcCardAddr != null">
+                #{opIcCardAddr,jdbcType=VARCHAR},
+            </if>
+            <if test="opRemainMoney != null">
+                #{opRemainMoney,jdbcType=DOUBLE},
+            </if>
+            <if test="openDt != null">
+                #{openDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="opOrderNo != null">
+                #{opOrderNo,jdbcType=VARCHAR},
+            </if>
+            <if test="opEleTotalAmount != null">
+                #{opEleTotalAmount,jdbcType=FLOAT},
+            </if>
+            <if test="opWaterRemainUser != null">
+                #{opWaterRemainUser,jdbcType=FLOAT},
+            </if>
+            <if test="clDt != null">
+                #{clDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="clType != null">
+                #{clType,jdbcType=TINYINT},
+            </if>
+            <if test="clTotalAmount != null">
+                #{clTotalAmount,jdbcType=DOUBLE},
+            </if>
+            <if test="clIcCardNo != null">
+                #{clIcCardNo,jdbcType=VARCHAR},
+            </if>
+            <if test="clIcCardAddr != null">
+                #{clIcCardAddr,jdbcType=VARCHAR},
+            </if>
+            <if test="clRemainMoney != null">
+                #{clRemainMoney,jdbcType=DOUBLE},
+            </if>
+            <if test="clThisAmount != null">
+                #{clThisAmount,jdbcType=DOUBLE},
+            </if>
+            <if test="clThisMoney != null">
+                #{clThisMoney,jdbcType=DOUBLE},
+            </if>
+            <if test="clThisTime != null">
+                #{clThisTime,jdbcType=INTEGER},
+            </if>
+            <if test="clOpenDt != null">
+                #{clOpenDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="closeDt != null">
+                #{closeDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="clOrderNo != null">
+                #{clOrderNo,jdbcType=VARCHAR},
+            </if>
+            <if test="clEleTotalAmount != null">
+                #{clEleTotalAmount,jdbcType=FLOAT},
+            </if>
+            <if test="clWaterRemainUser != null">
+                #{clWaterRemainUser,jdbcType=FLOAT},
+            </if>
+            <if test="clThisEle != null">
+                #{clThisEle,jdbcType=FLOAT},
+            </if>
+        </trim>
+    </insert>
+    <update id="updateByPrimaryKeySelective" parameterType="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveLast">
+        <!--@mbg.generated-->
+        update rm_open_close_valve_last
+        <set>
+            <if test="lastHistoryId != null">
+                last_history_id = #{lastHistoryId,jdbcType=BIGINT},
+            </if>
+            <if test="clientId != null">
+                client_id = #{clientId,jdbcType=BIGINT},
+            </if>
+            <if test="clientName != null">
+                client_name = #{clientName,jdbcType=VARCHAR},
+            </if>
+            <if test="controllerId != null">
+                controller_id = #{controllerId,jdbcType=BIGINT},
+            </if>
+            <if test="intakeId != null">
+                intake_id = #{intakeId,jdbcType=BIGINT},
+            </if>
+            <if test="rtuAddr != null">
+                rtu_addr = #{rtuAddr,jdbcType=VARCHAR},
+            </if>
+            <if test="opDt != null">
+                op_dt = #{opDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="opType != null">
+                op_type = #{opType,jdbcType=TINYINT},
+            </if>
+            <if test="opTotalAmount != null">
+                op_total_amount = #{opTotalAmount,jdbcType=DOUBLE},
+            </if>
+            <if test="opIcCardNo != null">
+                op_ic_card_no = #{opIcCardNo,jdbcType=VARCHAR},
+            </if>
+            <if test="opIcCardAddr != null">
+                op_ic_card_addr = #{opIcCardAddr,jdbcType=VARCHAR},
+            </if>
+            <if test="opRemainMoney != null">
+                op_remain_money = #{opRemainMoney,jdbcType=DOUBLE},
+            </if>
+            <if test="openDt != null">
+                open_dt = #{openDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="opOrderNo != null">
+                op_order_no = #{opOrderNo,jdbcType=VARCHAR},
+            </if>
+            <if test="opEleTotalAmount != null">
+                op_ele_total_amount = #{opEleTotalAmount,jdbcType=FLOAT},
+            </if>
+            <if test="opWaterRemainUser != null">
+                op_water_remain_user = #{opWaterRemainUser,jdbcType=FLOAT},
+            </if>
+            <if test="clDt != null">
+                cl_dt = #{clDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="clType != null">
+                cl_type = #{clType,jdbcType=TINYINT},
+            </if>
+            <if test="clTotalAmount != null">
+                cl_total_amount = #{clTotalAmount,jdbcType=DOUBLE},
+            </if>
+            <if test="clIcCardNo != null">
+                cl_ic_card_no = #{clIcCardNo,jdbcType=VARCHAR},
+            </if>
+            <if test="clIcCardAddr != null">
+                cl_ic_card_addr = #{clIcCardAddr,jdbcType=VARCHAR},
+            </if>
+            <if test="clRemainMoney != null">
+                cl_remain_money = #{clRemainMoney,jdbcType=DOUBLE},
+            </if>
+            <if test="clThisAmount != null">
+                cl_this_amount = #{clThisAmount,jdbcType=DOUBLE},
+            </if>
+            <if test="clThisMoney != null">
+                cl_this_money = #{clThisMoney,jdbcType=DOUBLE},
+            </if>
+            <if test="clThisTime != null">
+                cl_this_time = #{clThisTime,jdbcType=INTEGER},
+            </if>
+            <if test="clOpenDt != null">
+                cl_open_dt = #{clOpenDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="closeDt != null">
+                close_dt = #{closeDt,jdbcType=TIMESTAMP},
+            </if>
+            <if test="clOrderNo != null">
+                cl_order_no = #{clOrderNo,jdbcType=VARCHAR},
+            </if>
+            <if test="clEleTotalAmount != null">
+                cl_ele_total_amount = #{clEleTotalAmount,jdbcType=FLOAT},
+            </if>
+            <if test="clWaterRemainUser != null">
+                cl_water_remain_user = #{clWaterRemainUser,jdbcType=FLOAT},
+            </if>
+            <if test="clThisEle != null">
+                cl_this_ele = #{clThisEle,jdbcType=FLOAT},
+            </if>
+        </set>
+        where id = #{id,jdbcType=BIGINT}
+    </update>
+    <update id="updateByPrimaryKey" parameterType="com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveLast">
+        <!--@mbg.generated-->
+        update rm_open_close_valve_last
+        set last_history_id      = #{lastHistoryId,jdbcType=BIGINT},
+            client_id            = #{clientId,jdbcType=BIGINT},
+            client_name          = #{clientName,jdbcType=VARCHAR},
+            controller_id        = #{controllerId,jdbcType=BIGINT},
+            intake_id            = #{intakeId,jdbcType=BIGINT},
+            rtu_addr             = #{rtuAddr,jdbcType=VARCHAR},
+            op_dt                = #{opDt,jdbcType=TIMESTAMP},
+            op_type              = #{opType,jdbcType=TINYINT},
+            op_total_amount      = #{opTotalAmount,jdbcType=DOUBLE},
+            op_ic_card_no        = #{opIcCardNo,jdbcType=VARCHAR},
+            op_ic_card_addr      = #{opIcCardAddr,jdbcType=VARCHAR},
+            op_remain_money      = #{opRemainMoney,jdbcType=DOUBLE},
+            open_dt              = #{openDt,jdbcType=TIMESTAMP},
+            op_order_no          = #{opOrderNo,jdbcType=VARCHAR},
+            op_ele_total_amount  = #{opEleTotalAmount,jdbcType=FLOAT},
+            op_water_remain_user = #{opWaterRemainUser,jdbcType=FLOAT},
+            cl_dt                = #{clDt,jdbcType=TIMESTAMP},
+            cl_type              = #{clType,jdbcType=TINYINT},
+            cl_total_amount      = #{clTotalAmount,jdbcType=DOUBLE},
+            cl_ic_card_no        = #{clIcCardNo,jdbcType=VARCHAR},
+            cl_ic_card_addr      = #{clIcCardAddr,jdbcType=VARCHAR},
+            cl_remain_money      = #{clRemainMoney,jdbcType=DOUBLE},
+            cl_this_amount       = #{clThisAmount,jdbcType=DOUBLE},
+            cl_this_money        = #{clThisMoney,jdbcType=DOUBLE},
+            cl_this_time         = #{clThisTime,jdbcType=INTEGER},
+            cl_open_dt           = #{clOpenDt,jdbcType=TIMESTAMP},
+            close_dt             = #{closeDt,jdbcType=TIMESTAMP},
+            cl_order_no          = #{clOrderNo,jdbcType=VARCHAR},
+            cl_ele_total_amount  = #{clEleTotalAmount,jdbcType=FLOAT},
+            cl_water_remain_user = #{clWaterRemainUser,jdbcType=FLOAT},
+            cl_this_ele          = #{clThisEle,jdbcType=FLOAT}
+        where id = #{id,jdbcType=BIGINT}
+    </update>
 
-  <!--鏍规嵁鎸囧畾鏉′欢鑾峰彇寮�鍏抽榾鎶ユ渶鏂拌褰曟暟閲�-->
-  <select id="getOpenCloseValveReportsCount_last" resultType="java.lang.Long">
-    SELECT
-        COUNT(*) AS recordCount
-    FROM rm_open_close_valve_last oh
-    INNER JOIN pr_intake inta ON inta.id = oh.intake_id
-    <where>
-      <if test="intakeId != null and intakeId >0">
-        AND oh.intake_id = #{intakeId}
-      </if>
-      <if test = "intakeNum != null and intakeNum !=''">
-        AND inta.name LIKE CONCAT('%',#{intakeNum},'%')
-      </if>
-      <if test = "rtuAddr != null and rtuAddr !=''">
-        AND oh.rtu_addr LIKE CONCAT('%',#{rtuAddr},'%')
-      </if>
-      <if test = "timeStart_open != null and timeStop_open != null">
-        AND oh.op_dt BETWEEN #{timeStart_open} AND #{timeStop_open}
-      </if>
-      <if test = "timeStart_close != null and timeStop_close != null">
-        AND oh.cl_dt BETWEEN #{timeStart_close} AND #{timeStop_close}
-      </if>
-    </where>
-  </select>
+    <!--鏍规嵁鎸囧畾鏉′欢鑾峰彇寮�鍏抽榾鎶ユ渶鏂拌褰曟暟閲�-->
+    <select id="getOpenCloseValveReportsCount_last" resultType="java.lang.Long">
+        SELECT COUNT(*) AS recordCount
+        FROM rm_open_close_valve_last oh
+                 INNER JOIN pr_intake inta ON inta.id = oh.intake_id
+        <where>
+            <if test="intakeId != null and intakeId > 0">
+                AND oh.intake_id = #{intakeId}
+            </if>
+            <if test="intakeNum != null and intakeNum != ''">
+                AND inta.name LIKE CONCAT('%', #{intakeNum}, '%')
+            </if>
+            <if test="rtuAddr != null and rtuAddr != ''">
+                AND oh.rtu_addr LIKE CONCAT('%', #{rtuAddr}, '%')
+            </if>
+            <if test="timeStart_open != null and timeStop_open != null">
+                AND oh.op_dt BETWEEN #{timeStart_open} AND #{timeStop_open}
+            </if>
+            <if test="timeStart_close != null and timeStop_close != null">
+                AND oh.cl_dt BETWEEN #{timeStart_close} AND #{timeStop_close}
+            </if>
+        </where>
+    </select>
 
-  <!--鏍规嵁鎸囧畾鏉′欢鑾峰彇寮�鍏抽榾鎶ユ渶鏂拌褰�-->
-  <select id="getOpenCloseValveReports_last" resultType="com.dy.pipIrrGlobal.voRm.VoOpenCloseValve">
-    SELECT
-      oh.intake_id AS intakeId,
-      inta.name AS intakeNum,
-      oh.rtu_addr AS rtuAddr,
-      oh.client_name AS clientName,
-      oh.op_ic_card_no AS openIcNum,
-      oh.op_ic_card_addr AS openIcAddr,
-      oh.op_dt AS openTime,
-    CASE
-      WHEN oh.op_type = 1 THEN "鍒峰崱寮�闃�"
-      WHEN oh.op_type = 3 THEN "涓績绔欏紑闃�"
-      WHEN oh.op_type = 5 THEN "娆犺垂鍏抽榾"
-      WHEN oh.op_type = 8 THEN "鐢ㄦ埛杩滅▼寮�闃�"
-      WHEN oh.op_type = 11 THEN "寮�鍏抽榾鍗″紑闃�"
-      ELSE "鏈煡"
-    END AS openType,
-      oh.op_order_no AS openOrderNo,
-      oh.op_total_amount AS openTotalAmount,
-      oh.op_remain_money AS openRemainMoney,
-      oh.op_water_remain_user AS openWaterRemain,
-      oh.op_ele_total_amount AS openEleTotalAmount,
-      oh.cl_ic_card_no AS closeIcNum,
-      oh.cl_ic_card_addr AS closeIcAddr,
-      oh.cl_dt AS closeTime,
-    CASE
-      WHEN oh.cl_type = 2 THEN "鍒峰崱鍏抽榾"
-      WHEN oh.cl_type = 4 THEN "涓績绔欏叧闃�"
-      WHEN oh.cl_type = 5 THEN "娆犺垂鍏抽榾"
-      WHEN oh.cl_type = 6 THEN "娴侀噺璁℃晠闅滃叧闃�"
-      WHEN oh.cl_type = 7 THEN "绱ф�ュ叧闂�"
-      WHEN oh.cl_type = 9 THEN "鐢ㄦ埛杩滅▼鍏抽榾"
-      WHEN oh.cl_type = 10 THEN "寮�鍏抽榾鍗″叧闃�"
-      WHEN oh.cl_type = 12 THEN "榛戝悕鍗曞懡浠ゅ叧闃�"
-      WHEN oh.cl_type = 13 THEN "鐢ㄦ埛杩滅▼瀹氭椂鍏抽榾"
-      WHEN oh.cl_type = 14 THEN "鐢ㄦ埛杩滅▼瀹氶噺鍏抽榾"
-      ELSE "鏈煡"
-    END AS closeType,
-      oh.cl_this_amount AS closeThisAmount,
-      oh.cl_this_time AS thisTime,
-      oh.cl_this_money AS thisMoney,
-      oh.cl_remain_money AS closeRemainMoney,
-      oh.cl_total_amount AS closeTotalAmount
-    FROM rm_open_close_valve_last oh
-    INNER JOIN pr_intake inta ON inta.id = oh.intake_id
-    <where>
-      <if test="intakeId != null and intakeId >0">
-        AND oh.intake_id = #{intakeId}
-      </if>
-      <if test = "intakeNum != null and intakeNum !=''">
-        AND inta.name LIKE CONCAT('%',#{intakeNum},'%')
-      </if>
-      <if test = "rtuAddr != null and rtuAddr !=''">
-        AND oh.rtu_addr LIKE CONCAT('%',#{rtuAddr},'%')
-      </if>
-      <if test = "timeStart_open != null and timeStop_open != null">
-        AND oh.op_dt BETWEEN #{timeStart_open} AND #{timeStop_open}
-      </if>
-      <if test = "timeStart_close != null and timeStop_close != null">
-        AND oh.cl_dt BETWEEN #{timeStart_close} AND #{timeStop_close}
-      </if>
-    </where>
-    ORDER BY oh.op_dt DESC
-    <trim prefix="limit " >
-      <if test="start != null and count != null">
-        #{start,javaType=Integer,jdbcType=INTEGER}, #{count,javaType=Integer,jdbcType=INTEGER}
-      </if>
-    </trim>
-  </select>
+    <!--鏍规嵁鎸囧畾鏉′欢鑾峰彇寮�鍏抽榾鎶ユ渶鏂拌褰�-->
+    <select id="getOpenCloseValveReports_last" resultType="com.dy.pipIrrGlobal.voRm.VoOpenCloseValve">
+        SELECT oh.intake_id            AS intakeId,
+               inta.name               AS intakeNum,
+               oh.rtu_addr             AS rtuAddr,
+               oh.client_name          AS clientName,
+               oh.op_ic_card_no        AS openIcNum,
+               oh.op_ic_card_addr      AS openIcAddr,
+               oh.op_dt                AS openTime,
+
+               CASE
+                   WHEN oh.op_type = 1 THEN '鍒峰崱寮�闃�'
+                   WHEN oh.op_type = 3 THEN '涓績绔欏紑闃�'
+                   WHEN oh.op_type = 5 THEN '娆犺垂鍏抽榾'
+                   WHEN oh.op_type = 8 THEN '鐢ㄦ埛杩滅▼寮�闃�'
+                   WHEN oh.op_type = 11 THEN '寮�鍏抽榾鍗″紑闃�'
+                   ELSE '鏈煡'
+                   END                 AS openType,
+               oh.op_order_no          AS openOrderNo,
+               oh.op_total_amount      AS openTotalAmount,
+               oh.op_remain_money      AS openRemainMoney,
+               oh.op_water_remain_user AS openWaterRemain,
+               oh.op_ele_total_amount  AS openEleTotalAmount,
+               oh.cl_ic_card_no        AS closeIcNum,
+               oh.cl_ic_card_addr      AS closeIcAddr,
+               oh.cl_dt                AS closeTime,
+               CASE
+                   WHEN oh.cl_type = 2 THEN '鍒峰崱鍏抽榾'
+                   WHEN oh.cl_type = 4 THEN '涓績绔欏叧闃�'
+                   WHEN oh.cl_type = 5 THEN '娆犺垂鍏抽榾'
+                   WHEN oh.cl_type = 6 THEN '娴侀噺璁℃晠闅滃叧闃�'
+                   WHEN oh.cl_type = 7 THEN '绱ф�ュ叧闃�'
+                   WHEN oh.cl_type = 9 THEN '鐢ㄦ埛杩滅▼鍏抽榾'
+                   WHEN oh.cl_type = 10 THEN '寮�鍏抽榾鍗″叧闃�'
+                   WHEN oh.cl_type = 12 THEN '榛戝悕鍗曞懡浠ゅ叧闃�'
+                   WHEN oh.cl_type = 13 THEN '杩滅▼瀹氭椂鍏抽榾'
+                   WHEN oh.cl_type = 14 THEN '杩滅▼瀹氶噺鍏抽榾'
+                   ELSE '鏈煡'
+                   END                 AS closeType,
+               oh.cl_this_amount       AS closeThisAmount,
+               oh.cl_this_time         AS thisTime,
+               oh.cl_this_money        AS thisMoney,
+               oh.cl_remain_money      AS closeRemainMoney,
+               oh.cl_total_amount      AS closeTotalAmount
+        FROM rm_open_close_valve_last oh
+                 INNER JOIN pr_intake inta ON inta.id = oh.intake_id
+        <where>
+            <if test="intakeId != null and intakeId > 0">
+                AND oh.intake_id = #{intakeId}
+            </if>
+            <if test="intakeNum != null and intakeNum != ''">
+                AND inta.name LIKE CONCAT('%', #{intakeNum}, '%')
+            </if>
+            <if test="rtuAddr != null and rtuAddr != ''">
+                AND oh.rtu_addr LIKE CONCAT('%', #{rtuAddr}, '%')
+            </if>
+            <if test="timeStart_open != null and timeStop_open != null">
+                AND oh.op_dt BETWEEN #{timeStart_open} AND #{timeStop_open}
+            </if>
+            <if test="timeStart_close != null and timeStop_close != null">
+                AND oh.cl_dt BETWEEN #{timeStart_close} AND #{timeStop_close}
+            </if>
+        </where>
+        ORDER BY oh.op_dt DESC
+        <trim prefix="limit ">
+            <if test="start != null and count != null">
+                #{start,javaType=Integer,jdbcType=INTEGER}, #{count,javaType=Integer,jdbcType=INTEGER}
+            </if>
+        </trim>
+    </select>
+
+    <!--鏍规嵁寮�闃�鏂瑰紡鑾峰彇鎿嶄綔娆℃暟-->
+    <select id="getCountByOpenType" resultType="java.lang.Integer">
+        SELECT COUNT(*) AS recordCount
+        FROM rm_open_close_valve_history
+        <where>
+            AND op_type = #{openType}
+            <if test="timeStart != null and timeStop != null">
+                AND op_dt BETWEEN #{timeStart} AND #{timeStop}
+            </if>
+        </where>
+    </select>
+
+    <!--鏍规嵁鍏抽榾鏂瑰紡鑾峰彇鎿嶄綔娆℃暟-->
+    <select id="getCountByCloseType" resultType="java.lang.Integer">
+        SELECT COUNT(*) AS recordCount
+        FROM rm_open_close_valve_history
+        <where>
+            AND cl_type = #{closeType}
+            <if test="timeStart != null and timeStop != null">
+                AND cl_dt BETWEEN #{timeStart} AND #{timeStop}
+            </if>
+        </where>
+    </select>
 </mapper>
\ No newline at end of file
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/IntakeSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/IntakeSv.java
index 099c25f..c248646 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/IntakeSv.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/IntakeSv.java
@@ -3,14 +3,9 @@
 import com.dy.common.webUtil.QueryResultVo;
 import com.dy.pipIrrGlobal.daoRm.RmOnHourReportHistoryMapper;
 import com.dy.pipIrrGlobal.daoRm.RmOnHourReportLastMapper;
-import com.dy.pipIrrGlobal.voSt.VoBatteryVolt;
-import com.dy.pipIrrGlobal.voSt.VoCumulativeFlow;
-import com.dy.pipIrrGlobal.voSt.VoIntake;
-import com.dy.pipIrrGlobal.voSt.VoSignalIntensity;
-import com.dy.pipIrrStatistics.intake.qo.BatteryVoltQO;
-import com.dy.pipIrrStatistics.intake.qo.CumulativeFlowQO;
-import com.dy.pipIrrStatistics.intake.qo.IntakeQO;
-import com.dy.pipIrrStatistics.intake.qo.SignalIntensityQO;
+import com.dy.pipIrrGlobal.daoRm.RmOpenCloseValveLastMapper;
+import com.dy.pipIrrGlobal.voSt.*;
+import com.dy.pipIrrStatistics.intake.qo.*;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.dubbo.common.utils.PojoUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -37,6 +32,9 @@
     private RmOnHourReportHistoryMapper rmOnHourReportHistoryMapper;
     @Autowired
     private RmOnHourReportLastMapper rmOnHourReportLastMapper;
+
+    @Autowired
+    private RmOpenCloseValveLastMapper rmOpenCloseValveLastMapper;
 
     @Value("${rtu.batteryVolt}")
     private Double batteryVolt;
@@ -178,4 +176,124 @@
         return rsVo ;
     }
 
+    /**
+     * 鏍规嵁寮�闃�绫诲瀷鑾峰彇鎿嶄綔娆℃暟
+     * @param qo
+     * @return
+     */
+    public VoCountOfOpenType getCountByOpenType(OpenTypeQO qo) {
+        /**
+         * 琛ラ綈璧锋鏃堕棿锛屽鏋滃紑濮嬫椂闂翠负绌猴紝鍒欓粯璁や负褰撳墠鏃ユ湡
+         */
+        String timeStart = qo.getTimeStart();
+        String timeStop = qo.getTimeStop();
+        if(timeStart != null) {
+            timeStart = timeStart + " 00:00:00";
+        }else {
+            timeStart = LocalDate.now() + " 00:00:00";
+        }
+        if(timeStop != null) {
+            timeStop = timeStop + " 23:59:59";
+        }
+        qo.setTimeStart(timeStart);
+        qo.setTimeStop(timeStop);
+
+        Integer openType = qo.getOpenType();
+        String openTypeName = "";
+        switch (openType) {
+            case 1:
+                openTypeName = "鍒峰崱寮�闃�";
+                break;
+            case 3:
+                openTypeName = "涓績绔欏紑闃�";
+                break;
+            case 8:
+                openTypeName = "鐢ㄦ埛杩滅▼寮�闃�";
+                break;
+            case 11:
+                openTypeName = "寮�鍏抽榾鍗″紑闃�";
+                break;
+            case 13:
+                openTypeName = "寮�鍏抽榾鍗″紑闃�";
+                break;
+        }
+
+        // 鐢熸垚鏌ヨ鍙傛暟
+        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo) ;
+
+        Integer openTypeCount = Optional.ofNullable(rmOpenCloseValveLastMapper.getCountByOpenType(params)).orElse(0);
+
+        VoCountOfOpenType vo = new VoCountOfOpenType();
+        vo.setOpenTypeName(openTypeName);
+        vo.setOpenTypeCount(openTypeCount);
+        return vo;
+    }
+
+    /**
+     * 鏍规嵁鍏抽榾绫诲瀷鑾峰彇鎿嶄綔娆℃暟
+     * @param qo
+     * @return
+     */
+    public VoCountOfCloseType getCountByCloseType(CloseTypeQo qo) {
+        /**
+         * 琛ラ綈璧锋鏃堕棿锛屽鏋滃紑濮嬫椂闂翠负绌猴紝鍒欓粯璁や负褰撳墠鏃ユ湡
+         */
+        String timeStart = qo.getTimeStart();
+        String timeStop = qo.getTimeStop();
+        if(timeStart != null) {
+            timeStart = timeStart + " 00:00:00";
+        }else {
+            timeStart = LocalDate.now() + " 00:00:00";
+        }
+        if(timeStop != null) {
+            timeStop = timeStop + " 23:59:59";
+        }
+        qo.setTimeStart(timeStart);
+        qo.setTimeStop(timeStop);
+
+        Integer closeType = qo.getCloseType();
+        String closeTypeName = "";
+        switch (closeType) {
+            case 2:
+                closeTypeName = "鍒峰崱鍏抽榾";
+                break;
+            case 4:
+                closeTypeName = "涓績绔欏叧闃�";
+                break;
+            case 5:
+                closeTypeName = "娆犺垂鍏抽榾";
+                break;
+            case 6:
+                closeTypeName = "娴侀噺璁℃晠闅滃叧闃�";
+                break;
+            case 7:
+                closeTypeName = "绱ф�ュ叧闃�";
+                break;
+            case 9:
+                closeTypeName = "鐢ㄦ埛杩滅▼鍏抽榾";
+                break;
+            case 10:
+                closeTypeName = "寮�鍏抽榾鍗″叧闃�";
+                break;
+            case 12:
+                closeTypeName = "榛戝悕鍗曞懡浠ゅ叧闃�";
+                break;
+            case 13:
+                closeTypeName = "杩滅▼瀹氭椂鍏抽榾";
+                break;
+            case 14:
+                closeTypeName = "杩滅▼瀹氶噺鍏抽榾";
+                break;
+        }
+
+        // 鐢熸垚鏌ヨ鍙傛暟
+        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo) ;
+        Integer closeTypeCount = Optional.ofNullable(rmOpenCloseValveLastMapper.getCountByCloseType(params)).orElse(0);
+
+        VoCountOfCloseType vo = new VoCountOfCloseType();
+        vo.setCloseTypeName(closeTypeName);
+        vo.setCloseTypeCount(closeTypeCount);
+        return vo;
+    }
+
 }
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/IntkeCtrl.java b/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/IntkeCtrl.java
index 8f06af2..57374a7 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/IntkeCtrl.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/IntkeCtrl.java
@@ -4,14 +4,8 @@
 import com.dy.common.webUtil.BaseResponse;
 import com.dy.common.webUtil.BaseResponseUtils;
 import com.dy.common.webUtil.QueryResultVo;
-import com.dy.pipIrrGlobal.voSt.VoBatteryVolt;
-import com.dy.pipIrrGlobal.voSt.VoCumulativeFlow;
-import com.dy.pipIrrGlobal.voSt.VoIntake;
-import com.dy.pipIrrGlobal.voSt.VoSignalIntensity;
-import com.dy.pipIrrStatistics.intake.qo.BatteryVoltQO;
-import com.dy.pipIrrStatistics.intake.qo.CumulativeFlowQO;
-import com.dy.pipIrrStatistics.intake.qo.IntakeQO;
-import com.dy.pipIrrStatistics.intake.qo.SignalIntensityQO;
+import com.dy.pipIrrGlobal.voSt.*;
+import com.dy.pipIrrStatistics.intake.qo.*;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -113,4 +107,36 @@
             return BaseResponseUtils.buildException(e.getMessage()) ;
         }
     }
+
+    /**
+     * 鏍规嵁寮�闃�绫诲瀷鑾峰彇鎿嶄綔娆℃暟
+     * @param qo
+     * @return
+     */
+    @GetMapping(path = "/getCountByOpenType")
+    @SsoAop()
+    public BaseResponse<QueryResultVo<VoCountOfOpenType>> getCountByOpenType(OpenTypeQO qo) {
+        try {
+            return BaseResponseUtils.buildSuccess(intakeSv.getCountByOpenType(qo));
+        } catch (Exception e) {
+            log.error("鑾峰彇寮�鍗¤褰曞紓甯�", e);
+            return BaseResponseUtils.buildException(e.getMessage()) ;
+        }
+    }
+
+    /**
+     * 鏍规嵁鍏抽榾绫诲瀷鑾峰彇鎿嶄綔娆℃暟
+     * @param qo
+     * @return
+     */
+    @GetMapping(path = "/getCountByCloseType")
+    @SsoAop()
+    public BaseResponse<QueryResultVo<VoCountOfCloseType>> getCountByCloseType(CloseTypeQo qo) {
+        try {
+            return BaseResponseUtils.buildSuccess(intakeSv.getCountByCloseType(qo));
+        } catch (Exception e) {
+            log.error("鑾峰彇寮�鍗¤褰曞紓甯�", e);
+            return BaseResponseUtils.buildException(e.getMessage()) ;
+        }
+    }
 }
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/qo/CloseTypeQo.java b/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/qo/CloseTypeQo.java
new file mode 100644
index 0000000..a41230e
--- /dev/null
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/qo/CloseTypeQo.java
@@ -0,0 +1,35 @@
+package com.dy.pipIrrStatistics.intake.qo;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+import lombok.Data;
+
+/**
+ * @author ZhuBaoMin
+ * @date 2024-08-05 16:22
+ * @LastEditTime 2024-08-05 16:22
+ * @Description 鍏抽榾绫诲瀷鏌ヨ瀵硅薄
+ */
+
+@Data
+public class CloseTypeQo {
+    /**
+     * 鍏抽榾绫诲瀷
+     */
+    @NotNull(message = "鍏抽榾绫诲瀷涓嶈兘涓虹┖")
+    private Integer closeType;
+
+    /**
+     * 寮�濮嬫椂闂�
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    private String timeStart;
+
+    /**
+     * 缁撴潫鏃堕棿
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    @NotBlank(message = "缁撴潫鏃堕棿涓嶈兘涓虹┖")
+    private String timeStop;
+}
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/qo/OpenTypeQO.java b/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/qo/OpenTypeQO.java
new file mode 100644
index 0000000..e9b97ec
--- /dev/null
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/qo/OpenTypeQO.java
@@ -0,0 +1,35 @@
+package com.dy.pipIrrStatistics.intake.qo;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+import lombok.Data;
+
+/**
+ * @author ZhuBaoMin
+ * @date 2024-08-05 16:19
+ * @LastEditTime 2024-08-05 16:19
+ * @Description 寮�闃�绫诲瀷鏌ヨ瀵硅薄
+ */
+
+@Data
+public class OpenTypeQO {
+    /**
+     * 寮�闃�绫诲瀷
+     */
+    @NotNull(message = "寮�闃�绫诲瀷涓嶈兘涓虹┖")
+    private Integer openType;
+
+    /**
+     * 寮�濮嬫椂闂�
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    private String timeStart;
+
+    /**
+     * 缁撴潫鏃堕棿
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    @NotBlank(message = "缁撴潫鏃堕棿涓嶈兘涓虹┖")
+    private String timeStop;
+}
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/qo/SignalIntensityQO.java b/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/qo/SignalIntensityQO.java
index 69a66a0..9fec6a2 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/qo/SignalIntensityQO.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/qo/SignalIntensityQO.java
@@ -1,6 +1,9 @@
 package com.dy.pipIrrStatistics.intake.qo;
 
 import com.dy.common.webUtil.QueryConditionVo;
+import jakarta.validation.constraints.Max;
+import jakarta.validation.constraints.Min;
+import jakarta.validation.constraints.NotNull;
 import lombok.Data;
 
 /**
@@ -16,6 +19,9 @@
     /**
      * 淇″彿寮哄害锛�1-寮憋紝2-涓�鑸紝3-寮�
      */
+    @NotNull(message = "淇″彿寮哄害涓嶈兘涓虹┖")
+    @Min(value = 1, message = "淇″彿寮哄害閫夋嫨閿欒")
+    @Max(value = 3, message = "淇″彿寮哄害閫夋嫨閿欒")
     private Integer signalIntensity;
 
     /**

--
Gitblit v1.8.0