Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

Administrator

2024-07-26 af61e5f6de17791b5f8a07d3324c272a62eca5bf

Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/CommonV1_0_1.java

@@ -99,7 +99,7 @@
    public String parseRtuAddr(byte[] bs, int index)throws Exception{
        String rtuAddrBCD = "" + ByteUtil.BCD2Long_BE(bs, index, index + 2) ;//地址是大端模式
        String rtuAddrStr = "" + ByteUtilUnsigned.bytes2Short_LE(bs, index + 3) ;
        while(rtuAddrStr.length() < 5){
        while(rtuAddrStr.length() <= 5){
            rtuAddrStr = "0" + rtuAddrStr ;
        }
        return rtuAddrBCD + rtuAddrStr ;
@@ -165,7 +165,22 @@

    /**
     * å¾—到关开阀类型名称
     * å¼€å…³é˜€ç±»åž‹(1:刷卡开阀；2:刷卡关阀；3:中心站开阀；4:中心站关阀；5:欠费关阀；6:流量计故障关阀；7:紧急关闭；8:用户远程开阀；9:用户远程关阀；10:开关阀卡关阀；11:开关阀卡刷卡卡开阀；)
     * å¼€å…³é˜€ç±»åž‹(
     * 1:刷卡开阀；
     * 2:刷卡关阀；
     * 3:中心站开阀；
     * 4:中心站关阀；
     * 5:欠费关阀；
     * 6:流量计故障关阀；
     * 7:紧急关闭；
     * 8:用户远程开阀；
     * 9:用户远程关阀；
     * 10:开关阀卡关阀；
     * 11:开关阀卡刷卡卡开阀；
     * 12:黑名单命令关阀；
     * 13:用户远程定时关阀；
     * 14:用户远程定量关阀；
     * )
     * @param type å­—节
     * @return åç§°
     */
@@ -182,64 +197,19 @@
            case 9 -> "用户远程关阀";
            case 10 -> "开关阀卡关阀";
            case 11 -> "开关阀卡开阀";
            case 12 -> "黑名单命令关阀";
            case 13 -> "用户远程定时关阀";
            case 14 -> "用户远程定量关阀";
            default -> "未知";
        };
    }
    public static Boolean isCloseValveType(byte type){
        return switch (type) {
            case 1 -> false ;
            case 2 -> true ;
            case 3 -> false ;
            case 4 -> true ;
            case 5 -> true ;
            case 6 -> true ;
            case 7 -> true ;
            case 8 -> false ;
            case 9 -> true ;
            case 10 -> true ;
            case 11 -> false ;
            case 1, 3, 8, 11 -> false ;
            case 2, 4, 5, 6, 7, 9, 10, 12, 13, 14 -> true ;
            default -> null ;
        };
    }

//    /**
//     * å¤„理IC卡编号，靳总制定的协议要求10位IC卡编号
//     * @param icCardNo
//     * @return
//     */
//    public static String[] dealIcCardNo(String icCardNo){
//        if(icCardNo.length() > 10){
//            String tail = icCardNo.substring(icCardNo.length() - 10) ;
//            String head = icCardNo.substring(0, icCardNo.length() - 10) ;
//            return new String[]{head , tail} ;
//        }else if(icCardNo.length() < 10){
//            while(icCardNo.length() != 10){
//                icCardNo = "0" + icCardNo ;
//            }
//            return new String[]{null , icCardNo} ;
//        }else{
//            return new String[]{null , icCardNo} ;
//        }
//    }
	
    /*
     * åˆ†æžç‰ˆæœ¬å·
     * @param bs  ä¸Šè¡Œå­—节数组
     * @return ç‰ˆæœ¬å·
     * @throws Exception å¼‚常
    public String parseVersion(byte[] bs)throws Exception{
        short ver = ByteUtilUnsigned.byte2Byte(bs, ProtocolConstantV206V1_0_0.versionIndex) ;
        char[] cs = ("" + ver).toCharArray() ;
        StringBuilder vs = new StringBuilder() ;
        for(byte i = 0 ; i < cs.length; i++){
            if(i == 0){
                vs.append(cs[i]) ;
            }else{
                vs.append(".").append(cs[i]) ;
            }
        }
        return vs.toString() ;
    }
    */

}

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/downVos/Com10Vo.java

New file
@@ -0,0 +1,10 @@
package com.dy.common.mw.protocol.p206V1_0_0.downVos;

/**
 * @Author: liurunyu
 * @Date: 2024/7/25 15:27
 * @Description
 */
public class Com10Vo {
    public String rtuAddr ;
}

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_10_Down.java

@@ -1,10 +1,14 @@
package com.dy.common.mw.protocol.p206V1_0_0.parse;

import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.dy.common.mw.protocol.*;
import com.dy.common.mw.protocol.p206V1_0_0.CodeV1_0_1;
import com.dy.common.mw.protocol.p206V1_0_0.CommonV1_0_1;
import com.dy.common.mw.protocol.p206V1_0_0.ParseParamsForDownV1_0_1;
import com.dy.common.mw.protocol.p206V1_0_0.ProtocolConstantV206V1_0_0;
import com.dy.common.mw.protocol.p206V1_0_0.downVos.Com10Vo;
import com.dy.common.mw.protocol.p206V1_0_0.downVos.Com3AVo;
import com.dy.common.mw.protocol.p206V1_0_0.parse.global.GlCreate;
import com.dy.common.util.ByteUtil;

@@ -51,6 +55,19 @@
     * @throws Exception å¼‚常
     */
    public byte[] doParse(ParseParamsForDownV1_0_1 para) throws Exception {
        if(para.param == null) {
            throw new Exception("命令参数为null") ;
        }else {
            JSONObject obj = (JSONObject) para.param;
            String json = obj.toJSONString();
            Com10Vo cvo = JSON.parseObject(json, Com10Vo.class);
            if (cvo == null) {
                throw new Exception("json转Com10Vo为null");
            }
            if (cvo.rtuAddr == null) {
                throw new Exception("测试新地址不能为空");
            }

        CommonV1_0_1 commonV1_0_1 = new CommonV1_0_1() ;
        byte[] bytes ;
        byte[] bsHead = new byte[ProtocolConstantV206V1_0_0.lenHead2Code] ;
@@ -72,19 +89,15 @@

        ByteUtil.hex2Bytes(para.commandCode, bsHead, index) ;

        if(para.param == null){
            throw new Exception("未提供命令参数数据，不能构造功能码为" + para.commandCode + "的下行命令") ;
        }else{
            index = 0 ;
            byte[] bs = new byte[13] ;
            String newRtuAddr = (String)para.param ;
            GlCreate.createRtuAddr(newRtuAddr, bs, index);

            GlCreate.createRtuAddr(cvo.rtuAddr, bs, index);
            index += 5 ;
            GlCreate.createPw(bs, index);
            index += 2 ;
            GlCreate.createTp(bs, index);
            bytes = ByteUtil.bytesMerge(bsHead, bs) ;
        }

        GlCreate.createLen(bytes);//长度放字节数组中

@@ -94,5 +107,6 @@

        return bytes ;
    }
    }

}

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_99_Down.java

@@ -79,7 +79,7 @@
        String json = obj.toJSONString();
        Com99Vo cvo = JSON.parseObject(json, Com99Vo.class) ;
        if(cvo == null){
            throw new Exception("json转Com97Vo为null") ;
            throw new Exception("json转Com99Vo为null") ;
        }
        if(cvo.icCardNo == null){
            throw new Exception("虚拟IC卡编号不能为空") ;
@@ -106,9 +106,11 @@
        //ByteUtil.string2BCD_LE(bs, icCardNoGrp[1], index) ;
        byte[] bs = new byte[8] ;
        GlCreate.createIcCardNo(cvo.icCardNo, bs, 0);
        bytes = ByteUtil.bytesMerge(bsHead, bs) ;


        index += 5 ;
        bs = new byte[4] ;
        index = 0 ;
        Integer money = Double.valueOf(cvo.moneyRemain * 100.0D).intValue() ;
        byte[] bTemp = ByteUtil.int2BCD_LE(money) ;
        int bTempLen = bTemp.length ;
@@ -123,7 +125,10 @@
        for(; count < 4; count++){
            bs[index++] = 0 ;
        }
        bytes = ByteUtil.bytesMerge(bytes, bs) ;

        bs = new byte[2] ;
        index = 0 ;
        Integer price = Double.valueOf(cvo.waterPrice * 100.0D).intValue() ;
        bTemp = ByteUtil.int2BCD_LE(price) ;
        bTempLen = bTemp.length ;
@@ -138,8 +143,11 @@
        for(; count < 2; count++){
            bs[index++] = 0 ;
        }
        bytes = ByteUtil.bytesMerge(bytes, bs) ;


        bs = new byte[2] ;
        index = 0 ;
        bTemp = ByteUtil.int2BCD_LE(cvo.minutes) ;
        bTempLen = bTemp.length ;
        count = 0 ;
@@ -153,8 +161,7 @@
        for(; count < 2; count++){
            bs[index++] = 0 ;
        }

        bytes = ByteUtil.bytesMerge(bsHead, bs) ;
        bytes = ByteUtil.bytesMerge(bytes, bs) ;

        GlCreate.createLen(bytes);//长度放字节数组中


 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_A0_Down.java

@@ -79,7 +79,7 @@
        String json = obj.toJSONString();
        ComA0Vo cvo = JSON.parseObject(json, ComA0Vo.class) ;
        if(cvo == null){
            throw new Exception("json转Com97Vo为null") ;
            throw new Exception("json转ComA0Vo为null") ;
        }
        if(cvo.icCardNo == null){
            throw new Exception("虚拟IC卡编号不能为空") ;
@@ -101,12 +101,14 @@
        //if(icCardNoGrp[0] != null){
        //    midRs.param = icCardNoGrp[0] ;
        //}
        //ByteUtil.string2BCD_LE(bs, icCardNoGrp[1], index) ;
        byte[] bs = new byte[16] ;
        index = 0 ;
        //ByteUtil.string2BCD_LE(bs, icCardNoGrp[1], index) ;
        GlCreate.createIcCardNo(cvo.icCardNo, bs, 0);
        bytes = ByteUtil.bytesMerge(bsHead, bs) ;

        index += 5 ;
        bs = new byte[4] ;
        index = 0 ;
        Integer money = Double.valueOf(cvo.moneyRemain * 100.0D).intValue() ;
        byte[] bTemp = ByteUtil.int2BCD_LE(money) ;
        int bTempLen = bTemp.length ;
@@ -121,7 +123,10 @@
        for(; count < 4; count++){
            bs[index++] = 0 ;
        }
        bytes = ByteUtil.bytesMerge(bytes, bs) ;

        bs = new byte[2] ;
        index = 0 ;
        Integer price = Double.valueOf(cvo.waterPrice * 100.0D).intValue() ;
        bTemp = ByteUtil.int2BCD_LE(price) ;
        bTempLen = bTemp.length ;
@@ -136,8 +141,11 @@
        for(; count < 2; count++){
            bs[index++] = 0 ;
        }
        bytes = ByteUtil.bytesMerge(bytes, bs) ;


        bs = new byte[2] ;
        index = 0 ;
        bTemp = ByteUtil.int2BCD_LE(cvo.waterAmount) ;
        bTempLen = bTemp.length ;
        count = 0 ;
@@ -151,8 +159,7 @@
        for(; count < 2; count++){
            bs[index++] = 0 ;
        }

        bytes = ByteUtil.bytesMerge(bsHead, bs) ;
        bytes = ByteUtil.bytesMerge(bytes, bs) ;

        GlCreate.createLen(bytes);//长度放字节数组中


 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/global/GlParse.java

@@ -48,12 +48,12 @@
     * @throws Exception å¼‚常
     */
    public static String parseIcCardNo(byte[] bs, int index)throws Exception{
        String rtuAddrStr = "" + ByteUtilUnsigned.bytes2Short_LE(bs, index) ;
        String rtuAddrBCD = "" + ByteUtil.BCD2Long_LE(bs, index + 2, index + 7) ;
        while(rtuAddrStr.length() < 5){
            rtuAddrStr = "0" + rtuAddrStr ;
        String icNoStr = "" + ByteUtilUnsigned.bytes2Short_LE(bs, index) ;
        String icNoBCD = "" + ByteUtil.BCD2Long_LE(bs, index + 2, index + 7) ;
        while(icNoStr.length() < 5){
            icNoStr = "0" + icNoStr ;
        }
        return rtuAddrBCD + rtuAddrStr ;
        return icNoBCD + icNoStr ;
    }



 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/upVos/DataCd83CloseVo.java

@@ -5,9 +5,7 @@

@Data
public class DataCd83CloseVo {
    // å¼€å…³é˜€ç±»åž‹ï¼š
    // 1、刷卡开阀；2刷卡关阀；3、中心站开阀；4、中心站关阀；5、欠费关阀；
    // 6、流量计故障关阀；7、紧急关阀；8、用户远程开阀；9、用户远程关阀；
    // å¼€å…³é˜€ç±»åž‹ï¼šè§CommonV1_0_1.openCloseValveType()
    public Byte type ;
    public Double totalAmount; //累计流量：5字节BCD码，取值范围0~9999999999，单位为m3。
    public String icCardNo;//IC卡编号
@@ -35,7 +33,7 @@
        sb.append("      IC卡编号：");
        sb.append(icCardNo);
        sb.append("\n");
        sb.append("      ic卡地址：");
        sb.append("      IC卡地址：");
        sb.append(icCardAddr);
        sb.append("\n");
        sb.append("      å‰©ä½™é‡‘额（元）：");

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/upVos/DataCd83OpenVo.java

@@ -6,10 +6,7 @@

@Data
public class DataCd83OpenVo {
    // å¼€å…³é˜€ç±»åž‹ï¼š
    // 1、刷卡开阀；2刷卡关阀；3、中心站开阀；4、中心站关阀；5、欠费关阀；
    // 6、流量计故障关阀；7、紧急关阀；8、用户远程开阀；9、用户远程关阀；
    // 16，用户开阀后管道内没有水，自动关阀。管道不出水自动关阀
    // å¼€å…³é˜€ç±»åž‹ï¼šè§CommonV1_0_1.openCloseValveType()
    public Byte type ;
    public Double totalAmount; //累计流量：5字节BCD码，取值范围0~9999999999，单位为m3。
    public String icCardNo;//IC卡编号
@@ -30,7 +27,7 @@
        sb.append("      IC卡编号：");
        sb.append(icCardNo);
        sb.append("\n");
        sb.append("      ic卡地址：");
        sb.append("      IC卡地址：");
        sb.append(icCardAddr);
        sb.append("\n");
        sb.append("      å‰©ä½™é‡‘额（元）：");

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoSt/StClientAmountMonth.java

@@ -15,7 +15,7 @@
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.*;

@TableName(value="rm_client_amount_month", autoResultMap = true)
@TableName(value="st_client_amount_month", autoResultMap = true)
@Data
@Builder
@ToString

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoSt/StClientAmountYear.java

@@ -15,7 +15,7 @@
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.*;

@TableName(value="rm_client_amount_year", autoResultMap = true)
@TableName(value="st_client_amount_year", autoResultMap = true)
@Data
@Builder
@ToString

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoSt/StIntakeAmountMonth.java

@@ -15,7 +15,7 @@
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.*;

@TableName(value="rm_intake_amount_month", autoResultMap = true)
@TableName(value="st_intake_amount_month", autoResultMap = true)
@Data
@Builder
@ToString

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoSt/StIntakeAmountYear.java

@@ -15,7 +15,7 @@
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.*;

@TableName(value="rm_intake_amount_year", autoResultMap = true)
@TableName(value="st_intake_amount_year", autoResultMap = true)
@Data
@Builder
@ToString

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoSt/StLossMonth.java

@@ -15,7 +15,7 @@
 * @Description å–水口漏损月统计
 */

@TableName(value="rm_loss_month", autoResultMap = true)
@TableName(value="st_loss_month", autoResultMap = true)
@Data
@Builder
@ToString

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoSt/StLossYear.java

@@ -15,7 +15,7 @@
 * @Description å–水口漏损年统计
 */

@TableName(value="rm_loss_year", autoResultMap = true)
@TableName(value="st_loss_year", autoResultMap = true)
@Data
@Builder
@ToString

 pipIrr-platform/pipIrr-global/src/main/resources/application-global.yml

@@ -161,5 +161,5 @@
        - /wx/comRes/receive
#自动统计配置，自动统计定时任务会每天定时进行
auto-statistics:
    startHour: 9 #开始小时 0
    startMinute: 51 #开始分钟 5
    startHour: 17 #开始小时 0
    startMinute: 19 #开始分钟 5

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

@@ -396,6 +396,9 @@
        <if test="valveState != null">
            and rash.valve_state = #{valveState,jdbcType=TINYINT}
        </if>
        <if test="intakeId != null">
            and rash.intake_id = #{intakeId}
        </if>
        <if test="intakeName != null">
            and pint.name like CONCAT('%',#{intakeName,jdbcType=VARCHAR},'%')
        </if>
@@ -477,6 +480,9 @@
            <if test="valveState != null">
                and rash.valve_state = #{valveState,jdbcType=TINYINT}
            </if>
            <if test="intakeId != null">
                and rash.intake_id = #{intakeId}
            </if>
            <if test="intakeName != null">
                and pint.name like CONCAT('%',#{intakeName,jdbcType=VARCHAR},'%')
            </if>

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

@@ -378,6 +378,9 @@
      <if test="valveState != null">
        and rasl.valve_state = #{valveState,jdbcType=TINYINT}
      </if>
      <if test="intakeId != null">
        and rasl.intake_id = #{intakeId}
      </if>
      <if test="intakeName != null">
        and pint.name like CONCAT('%',#{intakeName,jdbcType=VARCHAR},'%')
      </if>
@@ -459,6 +462,9 @@
      <if test="valveState != null">
        and rasl.valve_state = #{valveState,jdbcType=TINYINT}
      </if>
      <if test="intakeId != null">
        and rasl.intake_id = #{intakeId}
      </if>
      <if test="intakeName != null">
        and pint.name like CONCAT('%',#{intakeName,jdbcType=VARCHAR},'%')
      </if>

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

@@ -197,6 +197,9 @@
      <if test="clientName != null">
        and sc.name like CONCAT('%',#{clientName,jdbcType=VARCHAR},'%')
      </if>
      <if test="clientId != null">
        and rcadl.client_id = #{clientId}
      </if>
      <if test="startDt != null">
        and rcadl.dt &gt;= #{startDt,jdbcType=DATE}
      </if>
@@ -225,6 +228,9 @@
      <if test="clientName != null">
        and sc.name like CONCAT('%',#{clientName,jdbcType=VARCHAR},'%')
      </if>
      <if test="clientId != null">
        and rcadl.client_id = #{clientId}
      </if>
      <if test="startDt != null">
        and rcadl.dt &gt;= #{startDt,jdbcType=DATE}
      </if>

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

@@ -187,6 +187,9 @@
      <if test="clientName != null">
        and sc.name like CONCAT('%',#{clientName,jdbcType=VARCHAR},'%')
      </if>
      <if test="clientId != null">
        and rcad.client_id = #{clientId}
      </if>
      <if test="startDt != null">
        and rcad.dt &gt;= #{startDt,jdbcType=DATE}
      </if>
@@ -215,6 +218,9 @@
      <if test="clientName != null">
        and sc.name like CONCAT('%',#{clientName,jdbcType=VARCHAR},'%')
      </if>
      <if test="clientId != null">
        and rcad.client_id = #{clientId}
      </if>
      <if test="startDt != null">
        and rcad.dt &gt;= #{startDt,jdbcType=DATE}
      </if>

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

@@ -176,6 +176,9 @@
      <if test="intakeName != null">
        and pint.name like CONCAT('%',#{intakeName,jdbcType=VARCHAR},'%')
      </if>
      <if test="intakeId != null">
        and riadl.intake_id = #{intakeId}
      </if>
      <if test="startDt != null">
        and riadl.dt &gt;= #{startDt,jdbcType=DATE}
      </if>
@@ -202,6 +205,9 @@
      <if test="intakeName != null">
        and pint.name like CONCAT('%',#{intakeName,jdbcType=VARCHAR},'%')
      </if>
      <if test="intakeId != null">
        and riadl.intake_id = #{intakeId}
      </if>
      <if test="startDt != null">
        and riadl.dt &gt;= #{startDt,jdbcType=DATE}
      </if>

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

@@ -164,6 +164,9 @@
      <if test="intakeName != null">
        and pint.name like CONCAT('%',#{intakeName,jdbcType=VARCHAR},'%')
      </if>
      <if test="intakeId != null">
        and riad.intake_id = #{intakeId}
      </if>
      <if test="startDt != null">
        and riad.dt &gt;= #{startDt,jdbcType=DATE}
      </if>
@@ -190,6 +193,9 @@
      <if test="intakeName != null">
        and pint.name like CONCAT('%',#{intakeName,jdbcType=VARCHAR},'%')
      </if>
      <if test="intakeId != null">
        and riad.intake_id = #{intakeId}
      </if>
      <if test="startDt != null">
        and riad.dt &gt;= #{startDt,jdbcType=DATE}
      </if>

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

@@ -168,6 +168,9 @@
      <if test="intakeName != null">
        and pint.name like CONCAT('%',#{intakeName,jdbcType=VARCHAR},'%')
      </if>
      <if test="intakeId != null">
        and rldl.intake_id = #{intakeId}
      </if>
      <if test="startDt != null">
        and rldl.dt &gt;= #{startDt,jdbcType=DATE}
      </if>
@@ -193,6 +196,9 @@
      <if test="intakeName != null">
        and pint.name like CONCAT('%',#{intakeName,jdbcType=VARCHAR},'%')
      </if>
      <if test="intakeId != null">
        and rldl.intake_id = #{intakeId}
      </if>
      <if test="startDt != null">
        and rldl.dt &gt;= #{startDt,jdbcType=DATE}
      </if>

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

@@ -158,6 +158,9 @@
      <if test="intakeName != null">
        and pint.name like CONCAT('%',#{intakeName,jdbcType=VARCHAR},'%')
      </if>
      <if test="intakeId != null">
        and rld.intake_id = #{intakeId}
      </if>
      <if test="startDt != null">
        and rld.dt &gt;= #{startDt,jdbcType=DATE}
      </if>
@@ -183,6 +186,9 @@
      <if test="intakeName != null">
        and pint.name like CONCAT('%',#{intakeName,jdbcType=VARCHAR},'%')
      </if>
      <if test="intakeId != null">
        and rld.intake_id = #{intakeId}
      </if>
      <if test="startDt != null">
        and rld.dt &gt;= #{startDt,jdbcType=DATE}
      </if>

 pipIrr-platform/pipIrr-web/pipIrr-mwTest-web/src/main/java/com/dy/pipIrrMwTestWeb/p206V1_0_0/CommandP206V1_0_0Ctrl.java

@@ -29,7 +29,9 @@
        if(com == null){
            rt = this.connect() ;//连接通信中间件测试
        }else{
            if(com.equals("21")){
            if(com.equals("10")){
                rt = this.cd10() ;
            }else if(com.equals("21")){
                rt = this.cd21() ;
            }else if(com.equals("37")){
                rt = this.cd37() ;
@@ -65,6 +67,10 @@
                rt = this.cd97() ;
            }else if(com.equals("98")){
                rt = this.cd98() ;
            }else if(com.equals("99")){
                rt = this.cd99() ;
            }else if(com.equals("A0")){
                rt = this.cdA0() ;
            }else if(com.equals("B0")){
                rt = this.cdB0() ;
            }
@@ -79,6 +85,12 @@
     */
    private BaseResponse connect(){
        return this.sendTest() ;
    }

    private BaseResponse cd10(){
        Com10Vo comVo = new Com10Vo() ;
        comVo.rtuAddr = "532328059995" ;//前6位是行政区划码，后6位是序列号最大是065535
        return this.sendCom2Mw(this.command(CodeV1_0_1.cd_10, comVo, null)) ;
    }

    private BaseResponse cd21(){
@@ -140,7 +152,7 @@

    private BaseResponse cd3C(){
        Com3CVo comVo = new Com3CVo() ;
        comVo.minute = 60 ;
        comVo.minute = 5 ;
        return this.sendCom2Mw(this.command(CodeV1_0_1.cd_3C, comVo, null)) ;
    }

@@ -175,6 +187,26 @@
        return this.sendCom2Mw(this.command(CodeV1_0_1.cd_98, comVo, null)) ;
    }

    //定时关阀开阀
    private BaseResponse cd99(){
        Com99Vo comVo = new Com99Vo() ;
        comVo.icCardNo = CommandP206V1_0_0Ctrl.vsIcCardNo;
        comVo.moneyRemain = 234.56 ;
        comVo.waterPrice = 1.2 ;
        comVo.minutes = 5 ;
        return this.sendCom2Mw(this.command(CodeV1_0_1.cd_99, comVo, null)) ;
    }

    //定量关阀开阀
    private BaseResponse cdA0(){
        ComA0Vo comVo = new ComA0Vo() ;
        comVo.icCardNo = CommandP206V1_0_0Ctrl.vsIcCardNo;
        comVo.moneyRemain = 234.56 ;
        comVo.waterPrice = 1.2 ;
        comVo.waterAmount = 10 ;
        return this.sendCom2Mw(this.command(CodeV1_0_1.cd_98, comVo, null)) ;
    }

    private BaseResponse cdB0(){
        return this.sendCom2Mw(this.command(CodeV1_0_1.cd_B0, null, null)) ;
    }

 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/records/clientAmountDay/ClientAmountDayQueryVo.java

@@ -1,6 +1,8 @@
package com.dy.pipIrrRemote.records.clientAmountDay;

import com.dy.common.webUtil.QueryConditionVo;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.*;

@@ -21,6 +23,9 @@
@Schema(name = "农户日用水量统计查询条件")
public class ClientAmountDayQueryVo extends QueryConditionVo {

    @Schema(description = "农户ID", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
    private String clientId;

    @Schema(description = "农户姓名", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
    private String clientName;


 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/records/controllerAlarmState/ControllerAlarmStateQueryVo.java

@@ -26,6 +26,9 @@
    @Schema(description = "取水口名称", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
    private String intakeName;

    @Schema(description = "取水口ID")
    private String intakeId;

    @Schema(description = "阀门状态", requiredMode = Schema.RequiredMode.NOT_REQUIRED)//（0打开、1关闭）
    private Byte valveState;


 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/records/intakeAmountDay/IntakeAmountDayQueryVo.java

@@ -24,6 +24,9 @@
    @Schema(description = "取水口名称", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
    private String intakeName;

    @Schema(description = "取水口ID")
    private String intakeId;

    @Schema(description = "统计开始日期", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
    private Date startDt;


 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/records/lossDay/LossDayQueryVo.java

@@ -25,6 +25,9 @@
    @Schema(description = "取水口名称", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
    private String intakeName;

    @Schema(description = "取水口ID")
    private String intakeId;

    @Schema(description = "统计开始日期", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
    private Date startDt;


 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/resources/log4j2.yml

@@ -65,7 +65,7 @@
        # ä¸ºåŒ…配置特殊的Log级别，方便调试，
        # ä¸å—Loggers.Root.level限制
        Logger:
            - name: com.dy.pipIrrGlobal.daoBa
            - name: com.dy.pipIrrGlobal.daoRm
              additivity: false #去除重复的log
              level: debug #输出日志级别
              AppenderRef:

 pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/PipIrrStatisticsApplication.java

@@ -18,7 +18,11 @@
                })
        }
)
@MapperScan(basePackages={"com.dy.pipIrrGlobal.daoRm", "com.dy.pipIrrGlobal.daoPr", "com.dy.pipIrrGlobal.daoSe", "com.dy.pipIrrGlobal.daoBa"})
@MapperScan(basePackages={"com.dy.pipIrrGlobal.daoRm",
        "com.dy.pipIrrGlobal.daoPr",
        "com.dy.pipIrrGlobal.daoSe",
        "com.dy.pipIrrGlobal.daoBa",
        "com.dy.pipIrrGlobal.daoSt"})
public class PipIrrStatisticsApplication {

    public static void main(String[] args) {

 pipIrr-platform/Îĵµ/Ôö¼ÓÒ»¸öÓ¦Óûú¹¹.docx

Binary files differ