重新定义并优化RTU上行数据接口

liurunyu

2024-10-23 2e624b0b3df6bf8e8d6e09992941d4a0e9116a96

重新定义并优化RTU上行数据接口

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

File was renamed from pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/upVos/ComResVo.java
@@ -1,11 +1,11 @@
package com.dy.common.mw.protocol.p206V1_0_0.upVos;
package com.dy.common.mw.protocol;

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

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

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

/**
 * @Author: liurunyu
 * @Date: 2024/10/23 8:26
 * @Description
 */
public interface UpDataVo {
    public String toString() ;
}

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

@@ -1,9 +1,10 @@
package com.dy.common.mw.protocol.p206V1_0_0.upVos;

import com.dy.common.mw.protocol.UpDataVo;
import lombok.Data;

@Data
public class DataAlarmVo {
public class DataAlarmVo implements UpDataVo {
    public Byte batteryVolt ;// 蓄电池电压
    public Byte loss ;//漏损
    public Byte meter ;//流量计故障

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

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

import com.dy.common.mw.protocol.UpDataVo;
import lombok.Data;

//链路检测
@Data
public class DataCd02Vo {
public class DataCd02Vo implements UpDataVo {

    public String status ;//F0 登录，F1 退出登录，F2 在线保持


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

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

import com.dy.common.mw.protocol.UpComResVo;
import lombok.Data;

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

    public String toString(){

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

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

import com.dy.common.mw.protocol.UpComResVo;
import lombok.Data;

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


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

@@ -1,9 +1,10 @@
package com.dy.common.mw.protocol.p206V1_0_0.upVos;

import com.dy.common.mw.protocol.UpComResVo;
import lombok.Data;

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


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

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

import com.dy.common.mw.protocol.UpComResVo;
import com.dy.common.mw.protocol.p206V1_0_0.CodeV1_0_1;
import lombok.Data;

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

    public String toString(){

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

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

import com.dy.common.mw.protocol.UpComResVo;
import com.dy.common.mw.protocol.p206V1_0_0.CodeV1_0_1;
import lombok.Data;

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

    public String toString(){

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

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

import com.dy.common.mw.protocol.UpComResVo;
import com.dy.common.mw.protocol.p206V1_0_0.CodeV1_0_1;
import lombok.Data;

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

    public String toString(){

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

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

import com.dy.common.mw.protocol.UpComResVo;
import com.dy.common.mw.protocol.p206V1_0_0.CodeV1_0_1;
import lombok.Data;

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

    public String toString(){

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

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

import com.dy.common.mw.protocol.UpComResVo;
import com.dy.common.mw.protocol.p206V1_0_0.CodeV1_0_1;
import lombok.Data;

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

    public String toString(){

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

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

import com.dy.common.mw.protocol.UpComResVo;
import com.dy.common.mw.protocol.p206V1_0_0.CodeV1_0_1;
import lombok.Data;

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

    public String toString(){

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

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

import com.dy.common.mw.protocol.UpComResVo;
import lombok.Data;

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

    public String toString(){

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

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

import com.dy.common.mw.protocol.UpComResVo;
import lombok.Data;

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

    public String toString(){

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

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

import com.dy.common.mw.protocol.UpComResVo;
import lombok.Data;

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

    public String toString(){

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

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

import com.dy.common.mw.protocol.UpComResVo;
import lombok.Data;

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


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

@@ -1,9 +1,10 @@
package com.dy.common.mw.protocol.p206V1_0_0.upVos;

import com.dy.common.mw.protocol.UpComResVo;
import lombok.Data;

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


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

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

import com.dy.common.mw.protocol.UpComResVo;
import lombok.Data;

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

    public String toString(){

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

@@ -1,9 +1,10 @@
package com.dy.common.mw.protocol.p206V1_0_0.upVos;

import com.dy.common.mw.protocol.UpComResVo;
import lombok.Data;

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

    public Byte state ;//阀门状态码（0：阀门关闭状态；1：阀门打开状态）
    public String stateName ;

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

@@ -1,12 +1,13 @@
package com.dy.common.mw.protocol.p206V1_0_0.upVos;

import com.dy.common.mw.protocol.UpDataVo;
import lombok.Data;

/**
 * 随机自报报
 */
@Data
public class DataCd81Vo {
public class DataCd81Vo implements UpDataVo {
    public DataAlarmVo alarmVo ;//报警
    public DataStateVo stateVo ;//状态
    public String rtuDt ;//控制器时钟

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

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

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

@Data
public class DataCd83CloseVo {
public class DataCd83CloseVo implements UpDataVo {
    // 开关阀类型：见CommonV1_0_1.openCloseValveType()
    public Byte type ;
    public Double totalAmount; //累计流量：5字节BCD码，取值范围0~9999999999，单位为m3。

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

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


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

@Data
public class DataCd83OpenVo {
public class DataCd83OpenVo implements UpDataVo {
    // 开关阀类型：见CommonV1_0_1.openCloseValveType()
    public Byte type ;
    public Double totalAmount; //累计流量：5字节BCD码，取值范围0~9999999999，单位为m3。

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

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

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

@@ -7,7 +8,7 @@
 * 阀开工作报（每几十秒上报一次，上报间隔可设置）
 */
@Data
public class DataCd84Vo {
public class DataCd84Vo implements UpDataVo {

    public Byte opType;
    public Byte cardType ;//卡类型(0:无卡；1:用户卡；2：管理员卡；3：调试卡；4：开关阀卡；5：清空卡)

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

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

import com.dy.common.mw.protocol.UpComResVo;
import lombok.Data;

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

    public String toString(){

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

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

import com.dy.common.mw.protocol.UpComResVo;
import lombok.Data;

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

    public String toString(){

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

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

import com.dy.common.mw.protocol.UpComResVo;
import lombok.Data;

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


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

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

import com.dy.common.mw.protocol.UpComResVo;
import lombok.Data;

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


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

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

import com.dy.common.mw.protocol.UpComResVo;
import lombok.Data;

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


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

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

import com.dy.common.mw.protocol.UpComResVo;
import lombok.Data;

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


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

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

import com.dy.common.mw.protocol.UpComResVo;
import lombok.Data;

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


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

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

import com.dy.common.mw.protocol.UpComResVo;
import lombok.Data;

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


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

@@ -1,12 +1,13 @@
package com.dy.common.mw.protocol.p206V1_0_0.upVos;

import com.dy.common.mw.protocol.UpDataVo;
import lombok.Data;

/**
 * 遥测站自报(整点)实时数据
 */
@Data
public class DataCdC0Vo {
public class DataCdC0Vo implements UpDataVo {
    public Double instantAmount; //瞬时流量：5字节BCD码，取值范围0~9999999.999，单位为m3/h。
    public Double totalAmount; //累计流量：5字节BCD码，取值范围0~9999999999，单位为m3。
    public Double lossAmount; //损失流量(从0时到当前的漏损累计流量，24时一个周期，0时归0)：5字节BCD码，取值范围0~9999999999，单位为m3。

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

@@ -1,9 +1,10 @@
package com.dy.common.mw.protocol.p206V1_0_0.upVos;

import com.dy.common.mw.protocol.UpDataVo;
import lombok.Data;

@Data
public class DataStateVo  {
public class DataStateVo implements UpDataVo {
    public static final byte ValveOpenState = 0 ;
    public static final byte ValveCloseState = 1 ;


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

@@ -1,5 +1,6 @@
package com.dy.rtuMw.server.rtuData.p206V1_0_0;

import com.dy.common.mw.protocol.UpComResVo;
import com.dy.common.mw.protocol.Data;
import com.dy.common.mw.protocol.p206V1_0_0.DataV1_0_1;
import com.dy.common.mw.protocol.p206V1_0_0.upVos.*;
@@ -74,8 +75,8 @@
            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 ;
        }else if(obj instanceof UpComResVo){
            UpComResVo vo = (UpComResVo)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)));