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

zhubaomin

2024-10-22 ae844683ede273edad59085227e36ae3ce02de06

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/upVos/ComResVo.java

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

/**
 * @Author: liurunyu
 * @Date: 2024/10/21 16:29
 * @Description
 */
public interface ComResVo {
    public String comLog() ;
    public String comLog(String code) ;
}

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

@@ -9,7 +9,7 @@
 * @Description
 */
@Data
public class DataCd10Vo {
public class DataCd10Vo implements ComResVo {
    public String newRtuAddr ;

    public String toString(){
@@ -30,4 +30,9 @@
        sb.append("\n");
        return sb.toString() ;
    }

    @Override
    public String comLog(String code) {
        return null;
    }
}

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

@@ -9,7 +9,7 @@
 * @Description
 */
@Data
public class DataCd21Vo {
public class DataCd21Vo implements ComResVo {
    public String ip ;
    public Integer port ;

@@ -35,4 +35,9 @@
        sb.append("\n");
        return sb.toString() ;
    }

    @Override
    public String comLog(String code) {
        return null;
    }
}

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

@@ -3,7 +3,7 @@
import lombok.Data;

@Data
public class DataCd36Vo {
public class DataCd36Vo implements ComResVo {
    public String ip ;//IP地址
    public Integer port ;//端口号

@@ -29,4 +29,9 @@
        sb.append("\n");
        return sb.toString() ;
    }

    @Override
    public String comLog(String code) {
        return null;
    }
}

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

@@ -10,7 +10,7 @@
 * @Description
 */
@Data
public class DataCd37And67Vo {
public class DataCd37And67Vo implements ComResVo {
    public Integer second ;

    public String toString(){
@@ -22,6 +22,12 @@

        return sb.toString() ;
    }

    @Override
    public String comLog() {
        return null;
    }

    public String comLog(String code){
        StringBuilder sb = new StringBuilder() ;
        if(code.equals(CodeV1_0_1.cd_37)){

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

@@ -10,7 +10,7 @@
 * @Description
 */
@Data
public class DataCd38And68Vo {
public class DataCd38And68Vo implements ComResVo {
    public Double remainMoneyAlarm ;

    public String toString(){
@@ -23,6 +23,11 @@
        return sb.toString() ;
    }

    @Override
    public String comLog() {
        return null;
    }

    public String comLog(String code){
        StringBuilder sb = new StringBuilder() ;
        if(code.equals(CodeV1_0_1.cd_38)){

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

@@ -10,7 +10,7 @@
 * @Description
 */
@Data
public class DataCd39And69Vo {
public class DataCd39And69Vo implements ComResVo {
    public Double batteryVoltAlarm ;

    public String toString(){
@@ -24,6 +24,11 @@
    }


    @Override
    public String comLog() {
        return null;
    }

    public String comLog(String code){
        StringBuilder sb = new StringBuilder() ;
        if(code.equals(CodeV1_0_1.cd_39)){

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

@@ -10,7 +10,7 @@
 * @Description
 */
@Data
public class DataCd3AAnd6AVo {
public class DataCd3AAnd6AVo implements ComResVo {
    public Double current ;

    public String toString(){
@@ -24,6 +24,11 @@
    }


    @Override
    public String comLog() {
        return null ;
    }

    public String comLog(String code){
        StringBuilder sb = new StringBuilder() ;
        if(code.equals(CodeV1_0_1.cd_3A)){

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

@@ -10,7 +10,7 @@
 * @Description
 */
@Data
public class DataCd3BAnd6BVo {
public class DataCd3BAnd6BVo implements ComResVo {
    public Integer second ;

    public String toString(){
@@ -24,6 +24,11 @@
    }


    @Override
    public String comLog() {
        return null;
    }

    public String comLog(String code){
        StringBuilder sb = new StringBuilder() ;
        if(code.equals(CodeV1_0_1.cd_3B)){

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

@@ -10,7 +10,7 @@
 * @Description
 */
@Data
public class DataCd3CAnd65Vo {
public class DataCd3CAnd65Vo implements ComResVo {
    public Integer minute ;

    public String toString(){
@@ -22,6 +22,12 @@

        return sb.toString() ;
    }

    @Override
    public String comLog() {
        return null;
    }

    public String comLog(String code){
        StringBuilder sb = new StringBuilder() ;
        if(code.equals(CodeV1_0_1.cd_3C)){

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

@@ -9,7 +9,7 @@
 * @Description
 */
@Data
public class DataCd3DVo {
public class DataCd3DVo implements ComResVo {
    public Double price ;

    public String toString(){
@@ -32,4 +32,9 @@

        return sb.toString() ;
    }

    @Override
    public String comLog(String code) {
        return null;
    }
}

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

@@ -9,7 +9,7 @@
 * @Description
 */
@Data
public class DataCd3EVo {
public class DataCd3EVo  implements ComResVo {
    public String icCardNo ;

    public String toString(){
@@ -31,4 +31,9 @@

        return sb.toString() ;
    }

    @Override
    public String comLog(String code) {
        return null;
    }
}

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

@@ -9,7 +9,7 @@
 * @Description
 */
@Data
public class DataCd51Vo {
public class DataCd51Vo implements ComResVo {
    public String rtuDt ;

    public String toString(){
@@ -32,4 +32,9 @@
        return sb.toString() ;
    }

    @Override
    public String comLog(String code) {
        return null;
    }

}

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

@@ -1,6 +1,5 @@
package com.dy.common.mw.protocol.p206V1_0_0.upVos;

import com.dy.common.mw.protocol.p206V1_0_0.CommonV1_0_1;
import lombok.Data;

/**
@@ -10,7 +9,7 @@
 * @Description
 */
@Data
public class DataCd5EVo {
public class DataCd5EVo implements ComResVo {
    public DataAlarmVo alarmVo ;
    public DataStateVo stateVo ;

@@ -41,4 +40,9 @@
        }
        return sb.toString() ;
    }

    @Override
    public String comLog(String code) {
        return null;
    }
}

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

@@ -3,7 +3,7 @@
import lombok.Data;

@Data
public class DataCd66Vo {
public class DataCd66Vo implements ComResVo {
    public String ip ;//IP地址
    public Integer port ;//端口号

@@ -30,4 +30,9 @@
        sb.append("\n");
        return sb.toString() ;
    }

    @Override
    public String comLog(String code) {
        return null;
    }
}

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

@@ -9,7 +9,7 @@
 * @Description
 */
@Data
public class DataCd6CVo {
public class DataCd6CVo implements ComResVo {
    public Double price ;

    public String toString(){
@@ -30,4 +30,9 @@
        sb.append("\n");
        return sb.toString() ;
    }

    @Override
    public String comLog(String code) {
        return null;
    }
}

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

@@ -3,7 +3,7 @@
import lombok.Data;

@Data
public class DataCd71Vo {
public class DataCd71Vo implements ComResVo {

    public Byte state ;//阀门状态码（0：阀门关闭状态；1：阀门打开状态）
    public String stateName ;
@@ -28,4 +28,9 @@
        sb.append("\n");
        return sb.toString() ;
    }

    @Override
    public String comLog(String code) {
        return null;
    }
}

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

@@ -9,7 +9,7 @@
 * @Description
 */
@Data
public class DataCd92Vo {
public class DataCd92Vo implements ComResVo {
    public boolean success;

    public String toString(){
@@ -31,4 +31,9 @@

        return sb.toString() ;
    }

    @Override
    public String comLog(String code) {
        return null;
    }
}

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

@@ -9,7 +9,7 @@
 * @Description
 */
@Data
public class DataCd93Vo {
public class DataCd93Vo implements ComResVo {
    public boolean success;

    public String toString(){
@@ -29,4 +29,9 @@

        return sb.toString() ;
    }

    @Override
    public String comLog(String code) {
        return null;
    }
}

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

@@ -9,7 +9,7 @@
 * @Description
 */
@Data
public class DataCd97Vo {
public class DataCd97Vo implements ComResVo {
    public String cardNo ;//虚拟卡号
    public boolean success;

@@ -37,4 +37,9 @@

        return sb.toString() ;
    }

    @Override
    public String comLog(String code) {
        return null;
    }
}

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

@@ -9,7 +9,7 @@
 * @Description
 */
@Data
public class DataCd98Vo {
public class DataCd98Vo implements ComResVo {
    public String cardNo ;//虚拟卡号
    public boolean success;

@@ -39,4 +39,9 @@

        return sb.toString() ;
    }

    @Override
    public String comLog(String code) {
        return null;
    }
}

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

@@ -9,7 +9,7 @@
 * @Description
 */
@Data
public class DataCd99Vo {
public class DataCd99Vo  implements ComResVo{
    public String cardNo ;//虚拟卡号
    public boolean success;

@@ -38,4 +38,9 @@
        sb.append("\n");
        return sb.toString() ;
    }

    @Override
    public String comLog(String code) {
        return null;
    }
}

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

@@ -9,7 +9,7 @@
 * @Description
 */
@Data
public class DataCdA0Vo {
public class DataCdA0Vo implements ComResVo {
    public String cardNo ;//虚拟卡号
    public boolean success;

@@ -38,4 +38,9 @@
        sb.append("\n");
        return sb.toString() ;
    }

    @Override
    public String comLog(String code) {
        return null;
    }
}

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

@@ -9,7 +9,7 @@
 * @Description
 */
@Data
public class DataCdA1Vo {
public class DataCdA1Vo implements ComResVo {
    public String cardNo ;//虚拟卡号
    public boolean success;

@@ -38,4 +38,9 @@
        sb.append("\n");
        return sb.toString() ;
    }

    @Override
    public String comLog(String code) {
        return null;
    }
}

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

@@ -9,7 +9,7 @@
 * @Description
 */
@Data
public class DataCdA2Vo {
public class DataCdA2Vo implements ComResVo {
    public String cardNo ;//虚拟卡号
    public boolean success;

@@ -38,4 +38,9 @@
        sb.append("\n");
        return sb.toString() ;
    }

    @Override
    public String comLog(String code) {
        return null;
    }
}

 pipIrr-platform/pipIrr-global/src/main/resources/application-global(test²âÊÔϵͳ).yml

@@ -73,6 +73,8 @@
    global:
        dev: false  #是否开发阶段，true或false
        dsName: ym  #开发阶段，设置临时的数据库名称
    nginx:
        webPort: 54321
    mw:
        webPort: 8072
        actutorPort: 9072
@@ -129,45 +131,44 @@
        actutorPort: 9089
        idSuffix: 11


    file:
        idSuffix: 99
    file1:
        webPort: 8180
        actutorPort: 9180
    file2:
        webPort: 8181
        actutorPort: 9181
        webPort: 8180
        actutorPort: 9180
    file3:
        webPort: 8182
        actutorPort: 9182
        webPort: 8180
        actutorPort: 9180
    file4:
        webPort: 8183
        actutorPort: 9183
        webPort: 8180
        actutorPort: 9180
    file5:
        webPort: 8184
        actutorPort: 9184
        webPort: 8180
        actutorPort: 9180
    file6:
        webPort: 8185
        actutorPort: 9185
        webPort: 8180
        actutorPort: 9180
    file7:
        webPort: 8186
        actutorPort: 9186
        webPort: 8180
        actutorPort: 9180
    file8:
        webPort: 8187
        actutorPort: 9187
        webPort: 8180
        actutorPort: 9180
    file9:
        webPort: 8188
        actutorPort: 9188
        webPort: 8180
        actutorPort: 9180
    file10:
        webPort: 8189
        actutorPort: 9189
        webPort: 8180
        actutorPort: 9180
    file11:
        webPort: 8190
        actutorPort: 9190
        webPort: 8180
        actutorPort: 9180
    file12:
        webPort: 8191
        actutorPort: 9191
        webPort: 8180
        actutorPort: 9180


#web分布式文件系统
@@ -175,7 +176,7 @@
    photoZipWidth: 400 #缩略图尺寸
    webFile:
        fmUrl: http://127.0.0.1:${pipIrr.file1.webPort}/file # fm的web上下文 URL
        supportedFileTypes: docx,xlsx,doc,xls,pdf #支持的文档（非照片、录音、录像）文件类型
        supportedFileTypes: docx,xlsx,doc,xls,pdf #支持的文档（非媒体文件，如照片、录音、录像）文件类型
        sv1:
            id: dyFile1
            absolutePath: E:/java/nginx-1.24.0/html/webfiles/
@@ -285,7 +286,6 @@
            webUrl: http://127.0.0.1:${pipIrr.nginx.webPort}/webfiles/
            webDownloadPath: http://127.0.0.1:${pipIrr.file12.webPort}/file/download/down?id=


#项目编号
#projectCode:
#    ym: 100
@@ -301,7 +301,7 @@
    divisionCode: 120114403100


#通讯协议
#通讯中间件相关配置
#protocol: DYJS_2023,DYJS_2024
mw:
    #命令发送地址(中缀是机构tag，其也是数据源后缀名称)
@@ -329,6 +329,8 @@
        - /remote/comRes/receive
        - /wx/comRes/receive
        - /app/captcha/get
        - /file/file #web分布式文件系统

#自动统计配置，自动统计定时任务会每天定时进行
auto-statistics:
    startHour: 0 #开始小时 0
@@ -360,6 +362,7 @@
            secret: SEC6042bc964d08899a5853eb321eb5a4d842a395982777f815bd07451c879228b7
        at-all: true
        mobile: 18602657034

#阀控器参数
rtu:
    batteryVolt: 17

 pipIrr-platform/pipIrr-global/src/main/resources/application-global(ymԪıϵͳ).yml

@@ -73,6 +73,8 @@
    global:
        dev: false  #是否开发阶段，true或false
        dsName: ym  #开发阶段，设置临时的数据库名称
    nginx:
        webPort: 54321
    mw:
        webPort: 8070
        actutorPort: 9070
@@ -129,45 +131,44 @@
        actutorPort: 9089
        idSuffix: 11


    file:
        idSuffix: 99
    file1:
        webPort: 8180
        actutorPort: 9180
    file2:
        webPort: 8181
        actutorPort: 9181
        webPort: 8180
        actutorPort: 9180
    file3:
        webPort: 8182
        actutorPort: 9182
        webPort: 8180
        actutorPort: 9180
    file4:
        webPort: 8183
        actutorPort: 9183
        webPort: 8180
        actutorPort: 9180
    file5:
        webPort: 8184
        actutorPort: 9184
        webPort: 8180
        actutorPort: 9180
    file6:
        webPort: 8185
        actutorPort: 9185
        webPort: 8180
        actutorPort: 9180
    file7:
        webPort: 8186
        actutorPort: 9186
        webPort: 8180
        actutorPort: 9180
    file8:
        webPort: 8187
        actutorPort: 9187
        webPort: 8180
        actutorPort: 9180
    file9:
        webPort: 8188
        actutorPort: 9188
        webPort: 8180
        actutorPort: 9180
    file10:
        webPort: 8189
        actutorPort: 9189
        webPort: 8180
        actutorPort: 9180
    file11:
        webPort: 8190
        actutorPort: 9190
        webPort: 8180
        actutorPort: 9180
    file12:
        webPort: 8191
        actutorPort: 9191
        webPort: 8180
        actutorPort: 9180


#web分布式文件系统
@@ -175,7 +176,7 @@
    photoZipWidth: 400 #缩略图尺寸
    webFile:
        fmUrl: http://127.0.0.1:${pipIrr.file1.webPort}/file # fm的web上下文 URL
        supportedFileTypes: docx,xlsx,doc,xls,pdf #支持的文档（非照片、录音、录像）文件类型
        supportedFileTypes: docx,xlsx,doc,xls,pdf #支持的文档（非媒体文件，如照片、录音、录像）文件类型
        sv1:
            id: dyFile1
            absolutePath: E:/java/nginx-1.24.0/html/webfiles/
@@ -285,7 +286,6 @@
            webUrl: http://127.0.0.1:${pipIrr.nginx.webPort}/webfiles/
            webDownloadPath: http://127.0.0.1:${pipIrr.file12.webPort}/file/download/down?id=


#项目编号
#projectCode:
#    ym: 100
@@ -301,7 +301,7 @@
    divisionCode: 120114403100


#通讯协议
#通讯中间件相关配置
#protocol: DYJS_2023,DYJS_2024
mw:
    #命令发送地址(中缀是机构tag，其也是数据源后缀名称)
@@ -329,6 +329,8 @@
        - /remote/comRes/receive
        - /wx/comRes/receive
        - /app/captcha/get
        - /file/file #web分布式文件系统

#自动统计配置，自动统计定时任务会每天定时进行
auto-statistics:
    startHour: 0 #开始小时 0

 pipIrr-platform/pipIrr-global/src/main/resources/application-global(¿ª·¢²âÊÔ---166PC»ú).yml

@@ -73,6 +73,8 @@
    global:
        dev: true  #是否开发阶段，true或false
        dsName: ym  #开发阶段，设置临时的数据库名称
    nginx:
        webPort: 54321
    mw:
        webPort: 8070
        actutorPort: 9070
@@ -136,38 +138,38 @@
        webPort: 8180
        actutorPort: 9180
    file2:
        webPort: 8181
        actutorPort: 9181
        webPort: 8180
        actutorPort: 9180
    file3:
        webPort: 8182
        actutorPort: 9182
        webPort: 8180
        actutorPort: 9180
    file4:
        webPort: 8183
        actutorPort: 9183
        webPort: 8180
        actutorPort: 9180
    file5:
        webPort: 8184
        actutorPort: 9184
        webPort: 8180
        actutorPort: 9180
    file6:
        webPort: 8185
        actutorPort: 9185
        webPort: 8180
        actutorPort: 9180
    file7:
        webPort: 8186
        actutorPort: 9186
        webPort: 8180
        actutorPort: 9180
    file8:
        webPort: 8187
        actutorPort: 9187
        webPort: 8180
        actutorPort: 9180
    file9:
        webPort: 8188
        actutorPort: 9188
        webPort: 8180
        actutorPort: 9180
    file10:
        webPort: 8189
        actutorPort: 9189
        webPort: 8180
        actutorPort: 9180
    file11:
        webPort: 8190
        actutorPort: 9190
        webPort: 8180
        actutorPort: 9180
    file12:
        webPort: 8191
        actutorPort: 9191
        webPort: 8180
        actutorPort: 9180


#web分布式文件系统
@@ -175,7 +177,7 @@
    photoZipWidth: 400 #缩略图尺寸
    webFile:
        fmUrl: http://127.0.0.1:${pipIrr.file1.webPort}/file # fm的web上下文 URL
        supportedFileTypes: docx,xlsx,doc,xls,pdf #支持的文档（非照片、录音、录像）文件类型
        supportedFileTypes: docx,xlsx,doc,xls,pdf #支持的文档（非媒体文件，如照片、录音、录像）文件类型
        sv1:
            id: dyFile1
            absolutePath: E:/java/nginx-1.24.0/html/webfiles/
@@ -329,6 +331,8 @@
        - /remote/comRes/receive
        - /wx/comRes/receive
        - /app/captcha/get
        - /file/file #web分布式文件系统

#自动统计配置，自动统计定时任务会每天定时进行
auto-statistics:
    startHour: 0 #开始小时 0

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkRtuDealCommandResponse.java

@@ -53,96 +53,32 @@
    }

    public RmCommandHistory updateCommandLogPo(RmCommandHistory po, String code, DataV1_0_1 dV1_0_1, Object obj) throws Exception{
        po.setResult((byte)1);
        po.setResultTime(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt)) ;
        if(obj instanceof DataCd97Vo){
            DataCd97Vo vo = (DataCd97Vo)obj ;
            po.setResultText(vo.comLog());
            log.info("----------------------------------\n" + vo.comLog());
            po.setResult(vo.success?(byte)1:(byte)0);
            po.setResultText(vo.comLog()!=null?vo.comLog():vo.comLog(code));
            log.info("----------------------------------\n" + (vo.comLog()!=null?vo.comLog():vo.comLog(code)));
        }else if(obj instanceof DataCd98Vo){
            DataCd98Vo vo = (DataCd98Vo)obj ;
            po.setResultText(vo.comLog());
            log.info("----------------------------------\n" + vo.comLog());
            po.setResult(vo.success?(byte)1:(byte)0);
            po.setResultText(vo.comLog()!=null?vo.comLog():vo.comLog(code));
            log.info("----------------------------------\n" + (vo.comLog()!=null?vo.comLog():vo.comLog(code)));
        }else if(obj instanceof DataCd92Vo){
            DataCd92Vo vo = (DataCd92Vo)obj ;
            po.setResultText(vo.comLog());
            log.info("----------------------------------\n" + vo.comLog());
            po.setResult(vo.success?(byte)1:(byte)0);
            po.setResultText(vo.comLog()!=null?vo.comLog():vo.comLog(code));
            log.info("----------------------------------\n" + (vo.comLog()!=null?vo.comLog():vo.comLog(code)));
        }else if(obj instanceof DataCd93Vo){
            DataCd93Vo vo = (DataCd93Vo)obj ;
            po.setResultText(vo.comLog());
            log.info("----------------------------------\n" + vo.comLog());
        }else if(obj instanceof DataCd3AAnd6AVo){
            DataCd3AAnd6AVo vo = (DataCd3AAnd6AVo)obj ;
            po.setResultText(vo.comLog(code));
            log.info("----------------------------------\n" + vo.comLog(code));
        }else if(obj instanceof DataCd3BAnd6BVo){
            DataCd3BAnd6BVo vo = (DataCd3BAnd6BVo)obj ;
            po.setResultText(vo.comLog(code));
            log.info("----------------------------------\n" + vo.comLog(code));
        }else if(obj instanceof DataCd3BAnd6BVo){
            DataCd3CAnd65Vo vo = (DataCd3CAnd65Vo)obj ;
            po.setResultText(vo.comLog(code));
            log.info("----------------------------------\n" + vo.comLog(code));
        }else if(obj instanceof DataCd3DVo){
            DataCd3DVo vo = (DataCd3DVo)obj ;
            po.setResultText(vo.comLog());
            log.info("----------------------------------\n" + vo.comLog());
        }else if(obj instanceof DataCd3EVo){
            DataCd3EVo vo = (DataCd3EVo)obj ;
            po.setResultText(vo.comLog());
            log.info("----------------------------------\n" + vo.comLog());
        }else if(obj instanceof DataCd5EVo){
            DataCd5EVo vo = (DataCd5EVo)obj ;
            po.setResultText(vo.comLog());
            log.info("----------------------------------\n" + vo.comLog());
        }else if(obj instanceof DataCd6CVo){
            DataCd6CVo vo = (DataCd6CVo)obj ;
            po.setResultText(vo.comLog());
            log.info("----------------------------------\n" + vo.comLog());
        }else if(obj instanceof DataCd10Vo){
            DataCd10Vo vo = (DataCd10Vo)obj ;
            po.setResultText(vo.comLog());
            log.info("----------------------------------\n" + vo.comLog());
        }else if(obj instanceof DataCd21Vo){
            DataCd21Vo vo = (DataCd21Vo)obj ;
            po.setResultText(vo.comLog());
            log.info("----------------------------------\n" + vo.comLog());
        }else if(obj instanceof DataCd36Vo){
            DataCd36Vo vo = (DataCd36Vo)obj ;
            po.setResultText(vo.comLog());
            log.info("----------------------------------\n" + vo.comLog());
        }else if(obj instanceof DataCd37And67Vo){
            DataCd37And67Vo vo = (DataCd37And67Vo)obj ;
            po.setResultText(vo.comLog(code));
            log.info("----------------------------------\n" + vo.comLog(code));
        }else if(obj instanceof DataCd38And68Vo){
            DataCd38And68Vo vo = (DataCd38And68Vo)obj ;
            po.setResultText(vo.comLog(code));
            log.info("----------------------------------\n" + vo.comLog(code));
        }else if(obj instanceof DataCd39And69Vo){
            DataCd39And69Vo vo = (DataCd39And69Vo)obj ;
            po.setResultText(vo.comLog(code));
            log.info("----------------------------------\n" + vo.comLog(code));
        }else if(obj instanceof DataCd51Vo){
            DataCd51Vo vo = (DataCd51Vo)obj ;
            po.setResultText(vo.comLog());
            log.info("----------------------------------\n" + vo.comLog());
        }else if(obj instanceof DataCd66Vo){
            DataCd66Vo vo = (DataCd66Vo)obj ;
            po.setResultText(vo.comLog());
            log.info("----------------------------------\n" + vo.comLog());
        }else if(obj instanceof DataCd71Vo){
            DataCd71Vo vo = (DataCd71Vo)obj ;
            po.setResultText(vo.comLog());
            log.info("----------------------------------\n" + vo.comLog());
        }else if(obj instanceof DataCd99Vo){
            DataCd99Vo vo = (DataCd99Vo)obj ;
            po.setResultText(vo.comLog());
            log.info("----------------------------------\n" + vo.comLog());
        }else if(obj instanceof DataCdA0Vo){
            DataCdA0Vo vo = (DataCdA0Vo)obj ;
            po.setResultText(vo.comLog());
            log.info("----------------------------------\n" + vo.comLog());
            po.setResult(vo.success?(byte)1:(byte)0);
            po.setResultText(vo.comLog()!=null?vo.comLog():vo.comLog(code));
            log.info("----------------------------------\n" + (vo.comLog()!=null?vo.comLog():vo.comLog(code)));
        }else if(obj instanceof ComResVo){
            ComResVo vo = (ComResVo)obj ;
            po.setResult((byte)1);
            po.setResultText(vo.comLog()!=null?vo.comLog():vo.comLog(code));
            log.info("----------------------------------\n" + (vo.comLog()!=null?vo.comLog():vo.comLog(code)));
        }
        return po ;
    }

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/resources/config(test²âÊÔ).xml

@@ -20,7 +20,7 @@
    cacheUpDownDataMaxCount：上下行数据缓存队列中缓存数据个数的最大值，这个与现实项目所接水表数相关
    disconnectedByNoUpDataMinutes：没有上行数据的分钟数，达到这个分钟数，认为RTU断网了，取值范围是2-100
    workReportDealOneByTimes: å·¥ä½œæŠ¥å¤ªé¢‘繁，N次上报处理1次，取值范围是1-100
    intakeAlarmLossMinValue: è§¦å‘发送钉钉报警消息的取水口日漏损量的最小值（包括）
    intakeAlarmLossMinValue: è§¦å‘发送钉钉报警消息的取水口日漏损量的最小值（包括但除0.0外）（小数）
    sendDingDingAlarmMsInterval: æœ‰æŠ¥è­¦å‘生时，向钉钉发送消息的间隔时长（分钟）
     -->
    <base
@@ -38,7 +38,7 @@
        cacheUpDownDataMaxCount="110000"
        disconnectedByNoUpDataMinutes="3"
        workReportDealOneByTimes="5"
        intakeAlarmLossMinValue="1"
        intakeAlarmLossMinValue="1.0"
        sendDingDingAlarmMsInterval="60"
    />

@@ -97,14 +97,14 @@
    <!--
    èµ„源模块
    rtuLogDir：RTU日志文件存储目录(相对目录)
    rtuLogFileMaxSize：RTU日志文件最大字节数(KB)
    rtuLogFileMaxSize：RTU日志文件最大字节数(B)
    rtuLogFileMaxCount：RTU日志文件最大文件数
    monitorInterval：Rtu状态监视间隔(分钟)
    saveDbInterval：Rtu状态存数据库间隔(分钟)
     -->
    <resource
        rtuLogDir="rtuLogs/"
        rtuLogFileMaxSize="1000"
        rtuLogFileMaxSize="100000"
        rtuLogFileMaxCount="2"
        monitorInterval="2"
        saveDbInterval="10"

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/resources/config(ymԪı).xml

@@ -20,7 +20,7 @@
        cacheUpDownDataMaxCount：上下行数据缓存队列中缓存数据个数的最大值，这个与现实项目所接水表数相关
        disconnectedByNoUpDataMinutes：没有上行数据的分钟数，达到这个分钟数，认为RTU断网了，取值范围是2-100
        workReportDealOneByTimes: å·¥ä½œæŠ¥å¤ªé¢‘繁，N次上报处理1次，取值范围是1-100
        intakeAlarmLossMinValue: è§¦å‘发送钉钉报警消息的取水口日漏损量的最小值（包括）
    intakeAlarmLossMinValue: è§¦å‘发送钉钉报警消息的取水口日漏损量的最小值（包括但除0.0外）（小数）
        sendDingDingAlarmMsInterval: æœ‰æŠ¥è­¦å‘生时，向钉钉发送消息的间隔时长（分钟）
         -->
        <base
@@ -38,7 +38,7 @@
            cacheUpDownDataMaxCount="110000"
            disconnectedByNoUpDataMinutes="3"
            workReportDealOneByTimes="5"
            intakeAlarmLossMinValue="1"
        intakeAlarmLossMinValue="1.0"
            sendDingDingAlarmMsInterval="60"
        />