2024-07-25 朱宝民 完成8个报文查询结构（整点报、开关阀报、定时报、工作报）

Administrator

2024-07-25 1ed40ad4af53128228b93239be8f171f4e4e991a

2024-07-25 朱宝民 完成8个报文查询结构（整点报、开关阀报、定时报、工作报）

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoRm/RmOnHourReportHistoryMapper.java

@@ -70,4 +70,5 @@
     * @return
     */
    List<VoOnHour> getOnHourReports_history(Map<?, ?> params);

}

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoRm/RmOnHourReportLastMapper.java

@@ -2,10 +2,11 @@

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.dy.pipIrrGlobal.pojoRm.RmOnHourReportLast;
import com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveHistory;
import com.dy.pipIrrGlobal.voRm.VoOnHour;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;
import java.util.Map;

/**
 * @Author: liurunyu
@@ -64,4 +65,18 @@
     * @return
     */
    List<RmOnHourReportLast> getRmOnHourReportLast(Long intakeId);

    /**
     * 根据指定条件获取整点报最新记录数量
     * @param params
     * @return
     */
    Long getOnHourReportsCount_last(Map<?, ?> params);

    /**
     * 根据指定条件获取整点报最新记录
     * @param params
     * @return
     */
    List<VoOnHour> getOnHourReports_last(Map<?, ?> params);
}

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoRm/RmOpenCloseValveHistoryMapper.java

@@ -2,8 +2,11 @@

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveHistory;
import com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveLast;
import com.dy.pipIrrGlobal.voRm.VoOpenCloseValve;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;
import java.util.Map;

/**
 * @Author: liurunyu
@@ -59,4 +62,18 @@
     * @return update count
     */
    int updateByPrimaryKey(RmOpenCloseValveHistory record);

    /**
     * 根据指定条件获取开关阀报历史记录数量
     * @param params
     * @return
     */
    Long getOpenCloseValveReportsCount_history(Map<?, ?> params);

    /**
     * 根据指定条件获取开关阀报历史记录
     * @param params
     * @return
     */
    List<VoOpenCloseValve> getOpenCloseValveReports_history(Map<?, ?> params);
}

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoRm/RmOpenCloseValveLastMapper.java

@@ -2,10 +2,11 @@

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveLast;
import com.dy.pipIrrGlobal.pojoRm.RmWorkReportHistory;
import com.dy.pipIrrGlobal.voRm.VoOpenCloseValve;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;
import java.util.Map;

/**
 * @Author: liurunyu
@@ -69,4 +70,18 @@
     * @return object by rtuAddr
     */
    List<RmOpenCloseValveLast> selectByIntakeId(Long intakeId);

    /**
     * 根据指定条件获取开关阀报最新记录数量
     * @param params
     * @return
     */
    Long getOpenCloseValveReportsCount_last(Map<?, ?> params);

    /**
     * 根据指定条件获取开关阀报最新记录
     * @param params
     * @return
     */
    List<VoOpenCloseValve> getOpenCloseValveReports_last(Map<?, ?> params);
}

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoRm/RmTimingReportHistoryMapper.java

@@ -2,7 +2,11 @@

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.dy.pipIrrGlobal.pojoRm.RmTimingReportHistory;
import com.dy.pipIrrGlobal.voRm.VoTiming;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;
import java.util.Map;

/**
 * @author ZhuBaoMin
@@ -24,4 +28,18 @@
    int updateByPrimaryKeySelective(RmTimingReportHistory record);

    int updateByPrimaryKey(RmTimingReportHistory record);

    /**
     * 根据指定条件获取定时报历史记录数量
     * @param params
     * @return
     */
    Long getTimingReportsCount_history(Map<?, ?> params);

    /**
     * 根据指定条件获取定时报历史记录
     * @param params
     * @return
     */
    List<VoTiming> getTimingReports_history(Map<?, ?> params);
}

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoRm/RmTimingReportLastMapper.java

@@ -2,9 +2,11 @@

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.dy.pipIrrGlobal.pojoRm.RmTimingReportLast;
import com.dy.pipIrrGlobal.voRm.VoTiming;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;
import java.util.Map;

/**
 * @author ZhuBaoMin
@@ -33,4 +35,18 @@
     * @return
     */
    List<RmTimingReportLast> getRmTimingReportLast(Long intakeId);

    /**
     * 根据指定条件获取定时报最新记录数量
     * @param params
     * @return
     */
    Long getTimingReportsCount_last(Map<?, ?> params);

    /**
     * 根据指定条件获取定时报最新记录
     * @param params
     * @return
     */
    List<VoTiming> getTimingReports_last(Map<?, ?> params);
}

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoRm/RmWorkReportHistoryMapper.java

@@ -2,8 +2,11 @@

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.dy.pipIrrGlobal.pojoRm.RmWorkReportHistory;
import com.dy.pipIrrGlobal.pojoRm.RmWorkReportLast;
import com.dy.pipIrrGlobal.voRm.VoWork;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;
import java.util.Map;

/**
 * @Author: liurunyu
@@ -59,4 +62,18 @@
     * @return update count
     */
    int updateByPrimaryKey(RmWorkReportHistory record);

    /**
     * 根据指定条件获取工作报历史记录数量
     * @param params
     * @return
     */
    Long getWorkReportsCount_history(Map<?, ?> params);

    /**
     * 根据指定条件获取工作报历史记录
     * @param params
     * @return
     */
    List<VoWork> getWorkReports_history(Map<?, ?> params);
}

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoRm/RmWorkReportLastMapper.java

@@ -1,11 +1,12 @@
package com.dy.pipIrrGlobal.daoRm;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.dy.pipIrrGlobal.pojoRm.RmTimingReportHistory;
import com.dy.pipIrrGlobal.pojoRm.RmWorkReportLast;
import com.dy.pipIrrGlobal.voRm.VoWork;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;
import java.util.Map;

/**
 * @Author: liurunyu
@@ -69,4 +70,18 @@
     * @return object by rtuAddr
     */
    List<RmWorkReportLast> selectByIntakeId(Long intakeId);

    /**
     * 根据指定条件获取工作报最新记录数量
     * @param params
     * @return
     */
    Long getWorkReportsCount_last(Map<?, ?> params);

    /**
     * 根据指定条件获取工作报最新记录
     * @param params
     * @return
     */
    List<VoWork> getWorkReports_last(Map<?, ?> params);
}

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voRm/VoOnHour.java

@@ -5,6 +5,8 @@
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;

import java.util.Date;

/**
 * @author ZhuBaoMin
 * @date 2024-07-23 17:12
@@ -36,7 +38,7 @@
     * 数据接收时间
     */
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    private String receiveTime;
    private Date receiveTime;

    /**
     * 瞬时流量

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voRm/VoOpenCloseValve.java

New file
@@ -0,0 +1,133 @@
package com.dy.pipIrrGlobal.voRm;

import com.alibaba.fastjson2.annotation.JSONField;
import com.alibaba.fastjson2.writer.ObjectWriterImplToString;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;

import java.util.Date;

/**
 * @author ZhuBaoMin
 * @date 2024-07-24 15:55
 * @LastEditTime 2024-07-24 15:55
 * @Description 开关阀报视图对象
 */

@Data
public class VoOpenCloseValve {
    private static final long serialVersionUID = 202407241556001L;

    /**
     * 取水口ID
     */
    @JSONField(serializeUsing= ObjectWriterImplToString.class)
    private Long intakeId;

    /**
     * 取水口编号
     */
    private String intakeNum;

    /**
     * 阀控器地址
     */
    private String rtuAddr;

    /**
     * 农户姓名
     */
    private String clientName;

    /**
     * 开阀IC卡编号
     */
    private String openIcNum;

    /**
     * 开阀IC卡地址
     */
    private String openIcAddr;

    /**
     * 开阀数据接收时间
     */
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    private Date openTime;

    /**
     * 开阀类型
     */
    private Byte openType;

    /**
     * 开阀订单号
     */
    private String openOrderNo;

    /**
     * 开阀时累计流量
     */
    private Double openTotalAmount;

    /**
     * 开阀时剩余金额
     */
    private Double openRemainMoney;

    /**
     * 开阀时用户剩余剩余水量
     */
    private Double openWaterRemain;

    /**
     * 开阀电表累计电量
     */
    private Double openEleTotalAmount;

    /**
     * 关阀IC卡编号
     */
    private String closeIcNum;

    /**
     * 关阀IC卡地址
     */
    private String closeIcAddr;

    /**
     * 关阀数据接收时间
     */
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    private Date closeTime;

    /**
     * 关阀类型
     */
    private Byte closeType;

    /**
     * 关阀报中本地用水量
     */
    private Double closeThisAmount;

    /**
     * 关阀报中本地用水时长（分钟）
     */
    private Integer thisTime;

    /**
     * 关阀报中本地消费金额
     */
    private Double thisMoney;

    /**
     * 关阀时剩余金额
     */
    private Double closeRemainMoney;

    /**
     * 关阀时累计流量
     */
    private Double closeTotalAmount;
}

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voRm/VoTiming.java

New file
@@ -0,0 +1,78 @@
package com.dy.pipIrrGlobal.voRm;

import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;

import java.util.Date;

/**
 * @author ZhuBaoMin
 * @date 2024-07-25 9:45
 * @LastEditTime 2024-07-25 9:45
 * @Description 定时报视图对象
 */
@Data
public class VoTiming {
    private static final long serialVersionUID = 202407250946001L;

    /**
     * 取水口ID
     */
    private Long intakeId;

    /**
     * 取水口编号
     */
    private String intakeNum;

    /**
     * 阀控器地址
     */
    private String rtuAddr;

    /**
     * 数据接收时间
     */
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    private Date receiveTime;

    /**
     * 本年累计流量
     */
    private Double waterTotalAmountYear;

    /**
     * 水表累计流量
     */
    private Double waterTotalAmountMeter;

    /**
     * 本年累计电量
     */
    private Double eleTotalAmountYear;

    /**
     * 电表累计电量
     */
    private Double eleTotalAmountMeter;

    /**
     * 当日水表净流量
     */
    private Double waterTotalAmountDay;

    /**
     * 当日用户用水量
     */
    private Double waterUserTotalAmountDay;

    /**
     * 漏损水量
     */
    private Double lossTotalAmountDay;

    /**
     * 后备电池电压
     */
    private Double batteryVolt;
}

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voRm/VoWork.java

New file
@@ -0,0 +1,179 @@
package com.dy.pipIrrGlobal.voRm;

import com.alibaba.fastjson2.annotation.JSONField;
import com.alibaba.fastjson2.writer.ObjectWriterImplToString;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Data;

import java.util.Date;

/**
 * @author ZhuBaoMin
 * @date 2024-07-25 11:29
 * @LastEditTime 2024-07-25 11:29
 * @Description 工作报视图对象
 */

@Data
public class VoWork {
    private static final long serialVersionUID = 202407251130001L;

    /**
     * 取水口ID
     */
    @JSONField(serializeUsing= ObjectWriterImplToString.class)
    private Long intakeId;

    /**
     * 取水口编号
     */
    private String intakeNum;

    /**
     * 阀控器地址
     */
    private String rtuAddr;

    /**
     * 农户姓名
     */
    private String clientName;

    /**
     * IC卡编号
     */
    private String icNum;

    /**
     * IC卡地址
     */
    private String icAddr;

    /**
     * 数据接收时间
     */
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    private Date receiveTime;

    /**
     * 订单号
     */
    private String orderNo;

    /**
     * 水位（单位0.001米）
     */
    private Double waterLevel;

    /**
     * 水压（单位0.01千帕）
     */
    private Double waterPress;

    /**
     * 瞬时流量（单位0.01m3/小时）
     */
    private Double waterInstant;

    /**
     * 水表累计流量(单位0.01m3)
     */
    private Double waterTotal;

    /**
     * 电表累计电量(单位0.01度)
     */
    private Double ele_total;

    /**
     * 用户剩余金额(单位0.01元)
     */
    private Double moneyRemain;

    /**
     * 用户剩余水量(单位0.01m3)
     */
    private Double waterRemain;

    /**
     * 本次使用电量(单位0.01度)
     */
    private Double thisEle;

    /**
     * 本次使用水量(单位0.01m3)
     */
    private Double thisWater;

    /**
     * 本次使用金额(单位0.01元)
     */
    private Double thisMoney;

    /**
     * 本次使用时长(单位:分钟  最大9999分钟)
     */
    private Integer thisDuration;

    /**
     * 当前水量单价(单位0.01元 最大99.99元)
     */
    private Double waterPrice;

    /**
     * 当前电量单价(单位0.01元 最大99.99元)
     */
    private Double elePrice;

    /**
     * 交流A相电压(单位0.1伏特)
     */
    @JsonProperty("aVolt")
    private Double aVolt;

    /**
     * 交流B相电压(单位0.1伏特)
     */
    @JsonProperty("bVolt")
    private Double bVolt;

    /**
     * 交流C相电压(单位0.1伏特)
     */
    @JsonProperty("cVolt")
    private Double cVolt;

    /**
     * 交流A相电流(单位0.1安培)
     */
    @JsonProperty("aCurrent")
    private Double aCurrent;

    /**
     * 交流B相电流数据(单位0.1安培)
     */
    @JsonProperty("bCurrent")
    private Double bCurrent;

    /**
     * 交流C相电流(单位0.1安培)
     */
    @JsonProperty("cCurrent")
    private Double cCurrent;

    /**
     * 后备电池电压(单位0.01伏特)
     */
    private Double batteryVolt;

    /**
     * 水表远传电压(单位0.01伏特)
     */
    private Double waterMeterTransVolt;

    /**
     * 水表工作电压(单位0.01伏特)
     */
    private Double waterMeterWorkVolt;
}

 pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOnHourReportHistoryMapper.xml

@@ -202,6 +202,9 @@
    FROM rm_on_hour_report_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 = "intakeName != null and intakeName !=''">
        AND inta.name LIKE CONCAT('%',#{intakeName},'%')
      </if>
@@ -231,6 +234,9 @@
    FROM rm_on_hour_report_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>
@@ -248,4 +254,5 @@
      </if>
    </trim>
  </select>

</mapper>

 pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOnHourReportLastMapper.xml

@@ -202,4 +202,64 @@
        from rm_on_hour_report_last
        where intake_id = #{intakeId}
    </select>

  <!--根据指定条件获取整点报最新记录数量-->
  <select id="getOnHourReportsCount_last" resultType="java.lang.Long">
    SELECT
        COUNT(*) AS recordCount
    FROM rm_on_hour_report_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 != null and timeStop != null">
        AND oh.dt BETWEEN #{timeStart} AND #{timeStop}
      </if>
    </where>
  </select>

  <!--根据指定条件获取整点报最新记录-->
  <select id="getOnHourReports_last" resultType="com.dy.pipIrrGlobal.voRm.VoOnHour">
    SELECT
      oh.intake_id AS intakeId,
      inta.`name` AS intakeNum,
      oh.rtu_addr AS rtuAddr,
      oh.dt AS receiveTime,
      oh.instant_amount AS instantAmount,
      oh.total_amount AS totalAmount,
      oh.loss_amount AS lossAmount,
      oh.water_press AS waterPress,
      oh.battery_volt AS batteryVolt,
      oh.signal_value AS signalValue,
      oh.water_price AS waterPrice
    FROM rm_on_hour_report_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 != null and timeStop != null">
        AND oh.dt BETWEEN #{timeStart} AND #{timeStop}
      </if>
    </where>
    ORDER BY oh.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>

 pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOpenCloseValveHistoryMapper.xml

@@ -408,4 +408,81 @@
      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="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,
      oh.op_type 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,
      oh.cl_type 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>

 pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmOpenCloseValveLastMapper.xml

@@ -428,4 +428,81 @@
      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="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,
      oh.op_type 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,
      oh.cl_type 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>
</mapper>

 pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmTimingReportHistoryMapper.xml

@@ -219,4 +219,65 @@
      battery_volt = #{batteryVolt,jdbcType=FLOAT}
    where id = #{id,jdbcType=BIGINT}
  </update>

  <!--根据指定条件获取定时报历史记录数量-->
  <select id="getTimingReportsCount_history" resultType="java.lang.Long">
    SELECT
        COUNT(*) AS recordCount
    FROM rm_timing_report_history tim
        INNER JOIN pr_intake inta ON inta.id = tim.intake_id
    <where>
      <if test="intakeId != null and intakeId >0">
        AND tim.intake_id = #{intakeId}
      </if>
      <if test = "intakeNum != null and intakeNum !=''">
        AND inta.name LIKE CONCAT('%',#{intakeNum},'%')
      </if>
      <if test = "rtuAddr != null and rtuAddr !=''">
        AND tim.rtu_addr LIKE CONCAT('%',#{rtuAddr},'%')
      </if>
      <if test = "timeStart != null and timeStop != null">
        AND tim.dt BETWEEN #{timeStart} AND #{timeStop}
      </if>
    </where>
  </select>

  <!--根据指定条件获取定时报历史记录-->
  <select id="getTimingReports_history" resultType="com.dy.pipIrrGlobal.voRm.VoTiming">
    SELECT
      tim.intake_id AS intakeId,
      inta.name AS intakenum,
      tim.rtu_addr AS rtuAddr,
      tim.dt AS receiveTime,
      tim.water_total_amount_year AS waterTotalAmountYear,
      tim.water_total_amount_meter AS waterTotalAmountMeter,
      tim.ele_total_amount_year AS eleTotalAmountYear,
      tim.ele_total_amount_meter AS eleTotalAmountMeter,
      tim.water_total_amount_day AS waterTotalAmountDay,
      tim.water_user_total_amount_day AS waterUserTotalAmountDay,
      tim.loss_total_amount_day AS lossTotalAmountDay,
      tim.battery_volt AS batteryVolt
    FROM rm_timing_report_history tim
    INNER JOIN pr_intake inta ON inta.id = tim.intake_id
    <where>
      <if test="intakeId != null and intakeId >0">
        AND tim.intake_id = #{intakeId}
      </if>
      <if test = "intakeNum != null and intakeNum !=''">
        AND inta.name LIKE CONCAT('%',#{intakeNum},'%')
      </if>
      <if test = "rtuAddr != null and rtuAddr !=''">
        AND tim.rtu_addr LIKE CONCAT('%',#{rtuAddr},'%')
      </if>
      <if test = "timeStart != null and timeStop != null">
        AND tim.dt BETWEEN #{timeStart} AND #{timeStop}
      </if>
    </where>
    ORDER BY tim.dt DESC, tim.loss_total_amount_day 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>

 pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmTimingReportLastMapper.xml

@@ -227,4 +227,65 @@
    from rm_timing_report_last
    where intake_id = #{intakeId}
  </select>

  <!--根据指定条件获取定时报最新记录数量-->
  <select id="getTimingReportsCount_last" resultType="java.lang.Long">
    SELECT
        COUNT(*) AS recordCount
    FROM rm_timing_report_last tim
        INNER JOIN pr_intake inta ON inta.id = tim.intake_id
    <where>
      <if test="intakeId != null and intakeId >0">
        AND tim.intake_id = #{intakeId}
      </if>
      <if test = "intakeNum != null and intakeNum !=''">
        AND inta.name LIKE CONCAT('%',#{intakeNum},'%')
      </if>
      <if test = "rtuAddr != null and rtuAddr !=''">
        AND tim.rtu_addr LIKE CONCAT('%',#{rtuAddr},'%')
      </if>
      <if test = "timeStart != null and timeStop != null">
        AND tim.dt BETWEEN #{timeStart} AND #{timeStop}
      </if>
    </where>
  </select>

  <!--根据指定条件获取定时报最新记录-->
  <select id="getTimingReports_last" resultType="com.dy.pipIrrGlobal.voRm.VoTiming">
    SELECT
      tim.intake_id AS intakeId,
      inta.name AS intakenum,
      tim.rtu_addr AS rtuAddr,
      tim.dt AS receiveTime,
      tim.water_total_amount_year AS waterTotalAmountYear,
      tim.water_total_amount_meter AS waterTotalAmountMeter,
      tim.ele_total_amount_year AS eleTotalAmountYear,
      tim.ele_total_amount_meter AS eleTotalAmountMeter,
      tim.water_total_amount_day AS waterTotalAmountDay,
      tim.water_user_total_amount_day AS waterUserTotalAmountDay,
      tim.loss_total_amount_day AS lossTotalAmountDay,
      tim.battery_volt AS batteryVolt
    FROM rm_timing_report_last tim
    INNER JOIN pr_intake inta ON inta.id = tim.intake_id
    <where>
      <if test="intakeId != null and intakeId >0">
        AND tim.intake_id = #{intakeId}
      </if>
      <if test = "intakeNum != null and intakeNum !=''">
        AND inta.name LIKE CONCAT('%',#{intakeNum},'%')
      </if>
      <if test = "rtuAddr != null and rtuAddr !=''">
        AND tim.rtu_addr LIKE CONCAT('%',#{rtuAddr},'%')
      </if>
      <if test = "timeStart != null and timeStop != null">
        AND tim.dt BETWEEN #{timeStart} AND #{timeStop}
      </if>
    </where>
    ORDER BY tim.dt DESC, tim.loss_total_amount_day 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>

 pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmWorkReportHistoryMapper.xml

@@ -432,4 +432,83 @@
      water_meter_work_volt = #{waterMeterWorkVolt,jdbcType=FLOAT}
    where id = #{id,jdbcType=BIGINT}
  </update>

  <!--根据指定条件获取工作报历史记录数量-->
  <select id="getWorkReportsCount_history" resultType="java.lang.Long">
    SELECT
        COUNT(*) AS recordCount
    FROM rm_work_report_history wo
        INNER JOIN pr_intake inta ON inta.id = wo.intake_id
    <where>
      <if test="intakeId != null and intakeId >0">
        AND wo.intake_id = #{intakeId}
      </if>
      <if test = "intakeNum != null and intakeNum !=''">
        AND inta.name LIKE CONCAT('%',#{intakeNum},'%')
      </if>
      <if test = "rtuAddr != null and rtuAddr !=''">
        AND wo.rtu_addr LIKE CONCAT('%',#{rtuAddr},'%')
      </if>
      <if test = "timeStart != null and timeStop != null">
        AND wo.dt BETWEEN #{timeStart} AND #{timeStop}
      </if>
    </where>
  </select>

  <!--根据指定条件获取工作报历史记录-->
  <select id="getWorkReports_history" resultType="com.dy.pipIrrGlobal.voRm.VoWork">
    SELECT
      wo.intake_id AS intakeId,
      inta.name AS intakeNum,
      wo.rtu_addr AS rtuAddr,
      wo.client_name AS clientName,
      wo.ic_card_no AS icNum,
      wo.ic_card_addr AS icAddr,
      wo.dt AS receiveTime,
      wo.order_no AS orderNo,
      wo.water_level AS waterLevel,
      wo.water_press AS waterPress,
      wo.water_instant AS waterInstant,
      wo.water_total AS waterTotal,
      wo.ele_total AS ele_total,
      wo.money_remain AS moneyRemain,
      wo.water_remain AS waterRemain,
      wo.this_ele AS thisEle,
      wo.this_water AS thisWater,
      wo.this_money AS thisMoney,
      wo.this_duration AS thisDuration,
      wo.water_price AS waterPrice,
      wo.ele_price AS elePrice,
      wo.a_volt AS aVolt,
      wo.b_volt AS bVolt,
      wo.c_volt AS cVolt,
      wo.a_current AS aCurrent,
      wo.b_current AS bCurrent,
      wo.c_current AS cCurrent,
      wo.battery_volt AS batteryVolt,
      wo.water_meter_trans_volt AS waterMeterTransVolt,
      wo.water_meter_work_volt AS waterMeterWorkVolt
    FROM rm_work_report_history wo
    INNER JOIN pr_intake inta ON inta.id = wo.intake_id
    <where>
      <if test="intakeId != null and intakeId >0">
        AND wo.intake_id = #{intakeId}
      </if>
      <if test = "intakeNum != null and intakeNum !=''">
        AND inta.name LIKE CONCAT('%',#{intakeNum},'%')
      </if>
      <if test = "rtuAddr != null and rtuAddr !=''">
        AND wo.rtu_addr LIKE CONCAT('%',#{rtuAddr},'%')
      </if>
      <if test = "timeStart != null and timeStop != null">
        AND wo.dt BETWEEN #{timeStart} AND #{timeStop}
      </if>
    </where>
    ORDER BY wo.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>

 pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmWorkReportLastMapper.xml

@@ -439,4 +439,83 @@
        from rm_work_report_last
        where intake_id = #{intakeId,jdbcType=BIGINT}
    </select>

  <!--根据指定条件获取工作报最新记录数量-->
  <select id="getWorkReportsCount_last" resultType="java.lang.Long">
    SELECT
        COUNT(*) AS recordCount
    FROM rm_work_report_last wo
    INNER JOIN pr_intake inta ON inta.id = wo.intake_id
    <where>
      <if test="intakeId != null and intakeId >0">
        AND wo.intake_id = #{intakeId}
      </if>
      <if test = "intakeNum != null and intakeNum !=''">
        AND inta.name LIKE CONCAT('%',#{intakeNum},'%')
      </if>
      <if test = "rtuAddr != null and rtuAddr !=''">
        AND wo.rtu_addr LIKE CONCAT('%',#{rtuAddr},'%')
      </if>
      <if test = "timeStart != null and timeStop != null">
        AND wo.dt BETWEEN #{timeStart} AND #{timeStop}
      </if>
    </where>
  </select>

  <!--根据指定条件获取工作报最新记录-->
  <select id="getWorkReports_last" resultType="com.dy.pipIrrGlobal.voRm.VoWork">
    SELECT
      wo.intake_id AS intakeId,
      inta.name AS intakeNum,
      wo.rtu_addr AS rtuAddr,
      wo.client_name AS clientName,
      wo.ic_card_no AS icNum,
      wo.ic_card_addr AS icAddr,
      wo.dt AS receiveTime,
      wo.order_no AS orderNo,
      wo.water_level AS waterLevel,
      wo.water_press AS waterPress,
      wo.water_instant AS waterInstant,
      wo.water_total AS waterTotal,
      wo.ele_total AS ele_total,
      wo.money_remain AS moneyRemain,
      wo.water_remain AS waterRemain,
      wo.this_ele AS thisEle,
      wo.this_water AS thisWater,
      wo.this_money AS thisMoney,
      wo.this_duration AS thisDuration,
      wo.water_price AS waterPrice,
      wo.ele_price AS elePrice,
      wo.a_volt AS aVolt,
      wo.b_volt AS bVolt,
      wo.c_volt AS cVolt,
      wo.a_current AS aCurrent,
      wo.b_current AS bCurrent,
      wo.c_current AS cCurrent,
      wo.battery_volt AS batteryVolt,
      wo.water_meter_trans_volt AS waterMeterTransVolt,
      wo.water_meter_work_volt AS waterMeterWorkVolt
    FROM rm_work_report_last wo
    INNER JOIN pr_intake inta ON inta.id = wo.intake_id
    <where>
      <if test="intakeId != null and intakeId >0">
        AND wo.intake_id = #{intakeId}
      </if>
      <if test = "intakeNum != null and intakeNum !=''">
        AND inta.name LIKE CONCAT('%',#{intakeNum},'%')
      </if>
      <if test = "rtuAddr != null and rtuAddr !=''">
        AND wo.rtu_addr LIKE CONCAT('%',#{rtuAddr},'%')
      </if>
      <if test = "timeStart != null and timeStop != null">
        AND wo.dt BETWEEN #{timeStart} AND #{timeStop}
      </if>
    </where>
    ORDER BY wo.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>

 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/common/CommandSv.java

@@ -28,7 +28,6 @@
import org.springframework.core.env.Environment;
import org.springframework.stereotype.Service;

import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
@@ -212,7 +211,6 @@
     * @return
     */
    public QueryResultVo<List<VoCommand>> getCommandHistories(QoCommand query) {
        DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
        // 完善查询起止时间
        String timeStart = query.getTimeStart();
        String timeStop = query.getTimeStop();

 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/report/ReportCtrl.java

@@ -5,7 +5,11 @@
import com.dy.common.webUtil.BaseResponseUtils;
import com.dy.common.webUtil.QueryResultVo;
import com.dy.pipIrrGlobal.voRm.VoOnHour;
import com.dy.pipIrrRemote.report.qo.ReportQO;
import com.dy.pipIrrGlobal.voRm.VoOpenCloseValve;
import com.dy.pipIrrGlobal.voRm.VoTiming;
import com.dy.pipIrrGlobal.voRm.VoWork;
import com.dy.pipIrrRemote.report.qo.OnHourQO;
import com.dy.pipIrrRemote.report.qo.OpenCloseValveQO;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.GetMapping;
@@ -35,11 +39,116 @@
     */
    @GetMapping(path = "/on_hour_report_history")
    @SsoAop()
    public BaseResponse<QueryResultVo<List<VoOnHour>>> getOnHourReportHistory(ReportQO qo){
    public BaseResponse<QueryResultVo<List<VoOnHour>>> getOnHourReportHistory(OnHourQO qo){
        try {
            return BaseResponseUtils.buildSuccess(reportSv.getOnHourReportsHistory(qo));
        } catch (Exception e) {
            return BaseResponseUtils.buildException(e.getMessage()) ;
        }
    }

    /**
     * 根据指定条件获取整点报最新记录
     * @param qo
     * @return
     */
    @GetMapping(path = "/on_hour_report_last")
    @SsoAop()
    public BaseResponse<QueryResultVo<List<VoOnHour>>> getOnHourReportLast(OnHourQO qo){
        try {
            return BaseResponseUtils.buildSuccess(reportSv.getOnHourReportsLast(qo));
        } catch (Exception e) {
            return BaseResponseUtils.buildException(e.getMessage()) ;
        }
    }

    /**
     * 根据指定条件获取开关阀报历史记录
     * @param qo
     * @return
     */
    @GetMapping(path = "/opem_close_valve_report_history")
    @SsoAop()
    public BaseResponse<QueryResultVo<List<VoOpenCloseValve>>> getOpenCloseValveReportHistory(OpenCloseValveQO qo){
        try {
            return BaseResponseUtils.buildSuccess(reportSv.getOpenCloseValveReports_history(qo));
        } catch (Exception e) {
            return BaseResponseUtils.buildException(e.getMessage()) ;
        }
    }

    /**
     * 根据指定条件获取开关阀报最新记录
     * @param qo
     * @return
     */
    @GetMapping(path = "/opem_close_valve_report_last")
    @SsoAop()
    public BaseResponse<QueryResultVo<List<VoOpenCloseValve>>> getOpenCloseValveReportLast(OpenCloseValveQO qo){
        try {
            return BaseResponseUtils.buildSuccess(reportSv.getOpenCloseValveReports_last(qo));
        } catch (Exception e) {
            return BaseResponseUtils.buildException(e.getMessage()) ;
        }
    }

    /**
     * 根据指定条件获取定时报历史记录
     * @param qo
     * @return
     */
    @GetMapping(path = "/timing_report_history")
    @SsoAop()
    public BaseResponse<QueryResultVo<List<VoTiming>>> getTimingReportHistory(OnHourQO qo){
        try {
            return BaseResponseUtils.buildSuccess(reportSv.getTimingReportsHistory(qo));
        } catch (Exception e) {
            return BaseResponseUtils.buildException(e.getMessage()) ;
        }
    }

    /**
     * 根据指定条件获取定时报最新记录
     * @param qo
     * @return
     */
    @GetMapping(path = "/timing_report_last")
    @SsoAop()
    public BaseResponse<QueryResultVo<List<VoTiming>>> getTimingReportLast(OnHourQO qo){
        try {
            return BaseResponseUtils.buildSuccess(reportSv.getTimingReportsLast(qo));
        } catch (Exception e) {
            return BaseResponseUtils.buildException(e.getMessage()) ;
        }
    }

    /**
     * 根据指定条件获取工作报历史记录
     * @param qo
     * @return
     */
    @GetMapping(path = "/work_report_history")
    @SsoAop()
    public BaseResponse<QueryResultVo<List<VoWork>>> getWorkReportHistory(OnHourQO qo){
        try {
            return BaseResponseUtils.buildSuccess(reportSv.getWorkReportsHistory(qo));
        } catch (Exception e) {
            return BaseResponseUtils.buildException(e.getMessage()) ;
        }
    }

    /**
     * 根据指定条件获取工作报最新记录
     * @param qo
     * @return
     */
    @GetMapping(path = "/work_report_last")
    @SsoAop()
    public BaseResponse<QueryResultVo<List<VoWork>>> getWorkReportLast(OnHourQO qo){
        try {
            return BaseResponseUtils.buildSuccess(reportSv.getWorkReportsLast(qo));
        } catch (Exception e) {
            return BaseResponseUtils.buildException(e.getMessage()) ;
        }
    }
}

 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/report/ReportSv.java

@@ -3,7 +3,11 @@
import com.dy.common.webUtil.QueryResultVo;
import com.dy.pipIrrGlobal.daoRm.*;
import com.dy.pipIrrGlobal.voRm.VoOnHour;
import com.dy.pipIrrRemote.report.qo.ReportQO;
import com.dy.pipIrrGlobal.voRm.VoOpenCloseValve;
import com.dy.pipIrrGlobal.voRm.VoTiming;
import com.dy.pipIrrGlobal.voRm.VoWork;
import com.dy.pipIrrRemote.report.qo.OnHourQO;
import com.dy.pipIrrRemote.report.qo.OpenCloseValveQO;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.common.utils.PojoUtils;
@@ -44,7 +48,7 @@
     * @param qo
     * @return
     */
    public QueryResultVo<List<VoOnHour>> getOnHourReportsHistory(ReportQO qo) {
    public QueryResultVo<List<VoOnHour>> getOnHourReportsHistory(OnHourQO qo) {
        String timeStart = qo.getTimeStart();
        String timeStop = qo.getTimeStop();
        if(timeStart != null) {
@@ -68,5 +72,228 @@
        return rsVo ;
    }

    /**
     * 根据指定条件获取整点报最新记录
     * @param qo
     * @return
     */
    public QueryResultVo<List<VoOnHour>> getOnHourReportsLast(OnHourQO qo) {
        String timeStart = qo.getTimeStart();
        String timeStop = qo.getTimeStop();
        if(timeStart != null) {
            timeStart = timeStart + " 00:00:00";
            qo.setTimeStart(timeStart);
        }
        if(timeStop != null) {
            timeStop = timeStop + " 23:59:59";
            qo.setTimeStop(timeStop);
        }

        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo);
        Long itemTotal = rmOnHourReportLastMapper.getOnHourReportsCount_last(params);

        QueryResultVo<List<VoOnHour>> rsVo = new QueryResultVo<>() ;
        rsVo.pageSize = qo.pageSize ;
        rsVo.pageCurr = qo.pageCurr ;

        rsVo.calculateAndSet(itemTotal, params);
        rsVo.obj = rmOnHourReportLastMapper.getOnHourReports_last(params);
        return rsVo ;
    }

    /**
     * 根据指定条件获取开关阀报历史记录
     * @param qo
     * @return
     */
    public QueryResultVo<List<VoOpenCloseValve>> getOpenCloseValveReports_history(OpenCloseValveQO qo) {
        String timeStart_open = qo.getTimeStart_open();
        String timeStop_open = qo.getTimeStop_open();
        if(timeStart_open != null) {
            timeStart_open = timeStart_open + " 00:00:00";
            qo.setTimeStop_open(timeStart_open);
        }
        if(timeStop_open != null) {
            timeStop_open = timeStop_open + " 23:59:59";
            qo.setTimeStop_open(timeStop_open);
        }

        String timeStart_close = qo.getTimeStart_close();
        String timeStop_close = qo.getTimeStop_close();
        if(timeStart_close != null) {
            timeStart_close = timeStart_close + " 00:00:00";
            qo.setTimeStart_close(timeStart_close);
        }
        if(timeStop_close != null) {
            timeStop_close = timeStop_close + " 23:59:59";
            qo.setTimeStop_close(timeStop_close);
        }

        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo);
        Long itemTotal = rmOpenCloseValveHistoryMapper.getOpenCloseValveReportsCount_history(params);

        QueryResultVo<List<VoOpenCloseValve>> rsVo = new QueryResultVo<>() ;
        rsVo.pageSize = qo.pageSize ;
        rsVo.pageCurr = qo.pageCurr ;

        rsVo.calculateAndSet(itemTotal, params);
        rsVo.obj = rmOpenCloseValveHistoryMapper.getOpenCloseValveReports_history(params);
        return rsVo ;
    }

    /**
     * 根据指定条件获取开关阀报最新记录
     * @param qo
     * @return
     */
    public QueryResultVo<List<VoOpenCloseValve>> getOpenCloseValveReports_last(OpenCloseValveQO qo) {
        String timeStart_open = qo.getTimeStart_open();
        String timeStop_open = qo.getTimeStop_open();
        if(timeStart_open != null) {
            timeStart_open = timeStart_open + " 00:00:00";
            qo.setTimeStop_open(timeStart_open);
        }
        if(timeStop_open != null) {
            timeStop_open = timeStop_open + " 23:59:59";
            qo.setTimeStop_open(timeStop_open);
        }

        String timeStart_close = qo.getTimeStart_close();
        String timeStop_close = qo.getTimeStop_close();
        if(timeStart_close != null) {
            timeStart_close = timeStart_close + " 00:00:00";
            qo.setTimeStart_close(timeStart_close);
        }
        if(timeStop_close != null) {
            timeStop_close = timeStop_close + " 23:59:59";
            qo.setTimeStop_close(timeStop_close);
        }

        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo);
        Long itemTotal = rmOpenCloseValveLastMapper.getOpenCloseValveReportsCount_last(params);

        QueryResultVo<List<VoOpenCloseValve>> rsVo = new QueryResultVo<>() ;
        rsVo.pageSize = qo.pageSize ;
        rsVo.pageCurr = qo.pageCurr ;

        rsVo.calculateAndSet(itemTotal, params);
        rsVo.obj = rmOpenCloseValveLastMapper.getOpenCloseValveReports_last(params);
        return rsVo ;
    }

    /**
     * 根据指定条件获取定时报历史记录
     * @param qo
     * @return
     */
    public QueryResultVo<List<VoTiming>> getTimingReportsHistory(OnHourQO qo) {
        String timeStart = qo.getTimeStart();
        String timeStop = qo.getTimeStop();
        if(timeStart != null) {
            timeStart = timeStart + " 00:00:00";
            qo.setTimeStart(timeStart);
        }
        if(timeStop != null) {
            timeStop = timeStop + " 23:59:59";
            qo.setTimeStop(timeStop);
        }

        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo);
        Long itemTotal = rmTimingReportHistoryMapper.getTimingReportsCount_history(params);

        QueryResultVo<List<VoTiming>> rsVo = new QueryResultVo<>() ;
        rsVo.pageSize = qo.pageSize ;
        rsVo.pageCurr = qo.pageCurr ;

        rsVo.calculateAndSet(itemTotal, params);
        rsVo.obj = rmTimingReportHistoryMapper.getTimingReports_history(params);
        return rsVo ;
    }

    /**
     * 根据指定条件获取定时报最新记录
     * @param qo
     * @return
     */
    public QueryResultVo<List<VoTiming>> getTimingReportsLast(OnHourQO qo) {
        String timeStart = qo.getTimeStart();
        String timeStop = qo.getTimeStop();
        if(timeStart != null) {
            timeStart = timeStart + " 00:00:00";
            qo.setTimeStart(timeStart);
        }
        if(timeStop != null) {
            timeStop = timeStop + " 23:59:59";
            qo.setTimeStop(timeStop);
        }

        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo);
        Long itemTotal = rmTimingReportLastMapper.getTimingReportsCount_last(params);

        QueryResultVo<List<VoTiming>> rsVo = new QueryResultVo<>() ;
        rsVo.pageSize = qo.pageSize ;
        rsVo.pageCurr = qo.pageCurr ;

        rsVo.calculateAndSet(itemTotal, params);
        rsVo.obj = rmTimingReportLastMapper.getTimingReports_last(params);
        return rsVo ;
    }

    /**
     * 根据指定条件获取工作报历史记录
     * @param qo
     * @return
     */
    public QueryResultVo<List<VoWork>> getWorkReportsHistory(OnHourQO qo) {
        String timeStart = qo.getTimeStart();
        String timeStop = qo.getTimeStop();
        if(timeStart != null) {
            timeStart = timeStart + " 00:00:00";
            qo.setTimeStart(timeStart);
        }
        if(timeStop != null) {
            timeStop = timeStop + " 23:59:59";
            qo.setTimeStop(timeStop);
        }

        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo);
        Long itemTotal = rmWorkReportHistoryMapper.getWorkReportsCount_history(params);

        QueryResultVo<List<VoWork>> rsVo = new QueryResultVo<>() ;
        rsVo.pageSize = qo.pageSize ;
        rsVo.pageCurr = qo.pageCurr ;

        rsVo.calculateAndSet(itemTotal, params);
        rsVo.obj = rmWorkReportHistoryMapper.getWorkReports_history(params);
        return rsVo ;
    }

    /**
     * 根据指定条件获取工作报最新记录
     * @param qo
     * @return
     */
    public QueryResultVo<List<VoWork>> getWorkReportsLast(OnHourQO qo) {
        String timeStart = qo.getTimeStart();
        String timeStop = qo.getTimeStop();
        if(timeStart != null) {
            timeStart = timeStart + " 00:00:00";
            qo.setTimeStart(timeStart);
        }
        if(timeStop != null) {
            timeStop = timeStop + " 23:59:59";
            qo.setTimeStop(timeStop);
        }

        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo);
        Long itemTotal = rmWorkReportLastMapper.getWorkReportsCount_last(params);

        QueryResultVo<List<VoWork>> rsVo = new QueryResultVo<>() ;
        rsVo.pageSize = qo.pageSize ;
        rsVo.pageCurr = qo.pageCurr ;

        rsVo.calculateAndSet(itemTotal, params);
        rsVo.obj = rmWorkReportLastMapper.getWorkReports_last(params);
        return rsVo ;
    }
}

 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/report/qo/OnHourQO.java

File was renamed from pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/report/qo/ReportQO.java
@@ -7,7 +7,7 @@
 * @author ZhuBaoMin
 * @date 2024-07-23 16:31
 * @LastEditTime 2024-07-23 16:31
 * @Description
 * @Description 整点报查询对象
 */

@Data
@@ -16,7 +16,12 @@
@NoArgsConstructor
@AllArgsConstructor
@Builder
public class ReportQO extends QueryConditionVo {
public class OnHourQO extends QueryConditionVo {

    /**
     * 取水口ID，最新记录跳转历史记录时使用
     */
    private Long intakeId;

    /**
     * 取水口编号

 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/report/qo/OpenCloseValveQO.java

New file
@@ -0,0 +1,54 @@
package com.dy.pipIrrRemote.report.qo;

import com.dy.common.webUtil.QueryConditionVo;
import lombok.*;

/**
 * @author ZhuBaoMin
 * @date 2024-07-24 16:25
 * @LastEditTime 2024-07-24 16:25
 * @Description 开关阀报查询对象
 */

@Data
@EqualsAndHashCode(callSuper = false)
@ToString(callSuper = true)
@NoArgsConstructor
@AllArgsConstructor
@Builder
public class OpenCloseValveQO extends QueryConditionVo {
    /**
     * 取水口ID，最新记录跳转历史记录时使用
     */
    private Long intakeId;

    /**
     * 取水口编号
     */
    private String intakeNum;

    /**
     * 阀控器地址
     */
    private String rtuAddr;

    /**
     * 查询开始日期_开阀
     */
    private String timeStart_open;

    /**
     * 查询结束日期_开阀
     */
    private String timeStop_open;

    /**
     * 查询开始日期_关阀
     */
    private String timeStart_close;

    /**
     * 查询结束日期_关阀
     */
    private String timeStop_close;
}