1、完善协议实现代码； 2、模拟向控制器发送命令，实现所有可下发的命令代码。

liurunyu

2024-05-17 be9748853c664402d88480167cd88bd781cf6b17

1、完善协议实现代码；
2、模拟向控制器发送命令，实现所有可下发的命令代码。

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

@@ -44,11 +44,6 @@
     * 功能码
     */
    public String code ; 
	
    /**
     * 不返回中间件对命令处理结果（true：不返回处理结果，false或null：返回处理结果）
     */
    public Boolean noRtMwDealRes ;

    /**
     * rtu返回命令结果 发向目的地web URL
@@ -71,7 +66,7 @@
        s += (rtuAddr == null ? "" : ("Rtu地址=" + rtuAddr + "\n"));
        s += "命令类型=" + (type.equals(CommandType.innerCommand)?"内部命令":"RTU命令") + "\n" ;
        s += (code == null ? "" : ("功能码=" + code + "\n")) ;
        s += "是否返回中间件对命令处理结果=" + (noRtMwDealRes == null?"是":(noRtMwDealRes?"是":"否") + "\n") ;
        s += (rtuResultSendWebUrl == null ? "" : ("回调网址=" + rtuResultSendWebUrl + "\n"));
        if(param != null){
            s += "参数:" + param  ;
        }
@@ -205,14 +200,6 @@
    public Command setCode(String code) {
        this.code = code;
        return this ;
    }
    @SuppressWarnings("unused")
    public Boolean getNoRtMwDealRes() {
        return noRtMwDealRes;
    }
    @SuppressWarnings("unused")
    public void setNoRtMwDealRes(Boolean noRtMwDealRes) {
        this.noRtMwDealRes = noRtMwDealRes;
    }
    public Object getParam() {
        return param;

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_55_Up.java

@@ -70,6 +70,7 @@
        if(hasRecord == 1){
            //有记录
            List<DataCd55Vo> list = new ArrayList<>() ;
            index++ ;
            DataCd55Vo vo = this.doParseData(bs, index, bsLen, dataCode, controllerType, projectNo) ;
            while(vo != null){
                index += 35 ;
@@ -83,7 +84,7 @@
    }

    private DataCd55Vo doParseData(byte[] bs, int index, int bsLen, String dataCode, String controllerType,Integer projectNo) throws Exception{
        //每条数据占39字节
        //每条数据占35字节
        if(bsLen - index > 35){
            DataCd55Vo cdData = new DataCd55Vo(CodeV202404.getCodeName(dataCode)) ;


 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_5C_Up.java

@@ -70,6 +70,7 @@
        if(hasRecord == 1){
            //有记录
            List<DataCd5CVo> list = new ArrayList<>() ;
            index++ ;
            DataCd5CVo vo = this.doParseData(bs, index, bsLen, dataCode, controllerType, projectNo) ;
            while(vo != null){
                index += 16 ;
@@ -83,7 +84,7 @@
    }

    private DataCd5CVo doParseData(byte[] bs, int index, int bsLen, String dataCode, String controllerType,Integer projectNo) throws Exception{
        //每条数据占39字节
        //每条数据占16字节
        if(bsLen - index > 16){
            DataCd5CVo cdData = new DataCd5CVo(CodeV202404.getCodeName(dataCode)) ;


 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_65_Up.java

@@ -70,9 +70,10 @@
        if(hasRecord == 1){
            //有记录
            List<DataCd65Vo> list = new ArrayList<>() ;
            index++ ;
            DataCd65Vo vo = this.doParseData(bs, index, bsLen, dataCode, controllerType, projectNo) ;
            while(vo != null){
                index += 39 ;
                index += 43 ;
                list.add(vo) ;
                vo = this.doParseData(bs, index, bsLen, dataCode, controllerType, projectNo) ;
            }
@@ -83,8 +84,8 @@
    }

    private DataCd65Vo doParseData(byte[] bs, int index, int bsLen, String dataCode, String controllerType,Integer projectNo) throws Exception{
        //每条数据占39字节
        if(bsLen - index > 39){
        //每条数据占43字节
        if(bsLen - index > 43){
            DataCd65Vo cdData = new DataCd65Vo(CodeV202404.getCodeName(dataCode)) ;

            cdData.controllerType = controllerType ;

 pipIrr-platform/pipIrr-web/pipIrr-mwTest-web/src/main/java/com/dy/pipIrrMwTestWeb/test/Test.java

@@ -1,9 +1,7 @@
package com.dy.pipIrrMwTestWeb.test;

import com.dy.common.mw.protocol.p206V202404.CodeV202404;
import com.dy.common.mw.protocol.p206V202404.downVos.ComCd10Vo;
import com.dy.common.mw.protocol.p206V202404.downVos.ComCd15Vo;
import com.dy.common.mw.protocol.p206V202404.downVos.ComCd65Vo;
import com.dy.common.mw.protocol.p206V202404.downVos.*;
import com.dy.common.webUtil.BaseResponse;
import org.springframework.stereotype.Component;

@@ -20,8 +18,9 @@
     * @return
     */
    public BaseResponse test(){
        //return this.connect() ;
        return this.cd50() ;
        //return this.connect() ;//连接通信中间件测试
        //return this.cdXY(CodeV202404.cd_50) ;//发送固定参数的命令
        return this.cd65(2) ;
    }

    /**
@@ -32,6 +31,11 @@
        return this.sendTest() ;
    }

    //发送固定参数的命令
    private BaseResponse cdXY(String code){
        return this.sendCom2Mw(this.command(code, this.comCdXyVo(), null)) ;
    }

    //设置终端地址(AFN=0x10H)
    private BaseResponse cd10(){
        ComCd10Vo comVo = new ComCd10Vo() ;
@@ -40,38 +44,173 @@
        comVo.rtuNewAddr = Test.rtuAddr ;
        return this.sendCom2Mw(this.command(CodeV202404.cd_10, comVo, null)) ;
    }
    //查询设备终端地址(AFN=0x50H)
    private BaseResponse cd50(){
        return this.sendCom2Mw(this.command(CodeV202404.cd_50, this.comCdXyVo(), null)) ;
    }
    //查询设备终端实时值(AFN=0x5BH)
    private BaseResponse cd5B(){
        return this.sendCom2Mw(this.command(CodeV202404.cd_5B, this.comCdXyVo(), null)) ;
    }
    //查询设备终端用户用水记录(AFN=0x65H)
    private BaseResponse cd65(){
        ComCd65Vo comVo = new ComCd65Vo() ;
        comVo.controllerType = Test.controllerType ;
        comVo.projectNo = Test.projectNo  ;
        comVo.page = 1 ;
        return this.sendCom2Mw(this.command(CodeV202404.cd_65, comVo, null)) ;
    }
    //清除设备终端用户用水记录 (AFN=0x97H)
    private BaseResponse cd97(){
        return this.sendCom2Mw(this.command(CodeV202404.cd_97, this.comCdXyVo(), null)) ;
    }
    //远程用户充值 (AFN=0x15H)
     //远程用户充值 (AFN=0x15H)
    private BaseResponse cd15(){
        ComCd15Vo comVo = new ComCd15Vo() ;
        comVo.controllerType = Test.controllerType ;
        comVo.projectNo = Test.projectNo  ;
        comVo.icCardAddr = "" ;//IC卡地址(8位数字或字母)
        comVo.icCardNo = "" ;//用户卡序列号（17位数字）（6字节BCD，2字节HEX）
        comVo.icCardAddr = Test.icCardAddr ;//IC卡地址(8位数字或字母)
        comVo.icCardNo = Test.icCardNo ;//用户卡序列号（17位数字）（6字节BCD，2字节HEX）
        comVo.chargeMoney = 123.45 ;//单位:元  2位小数点(最大值 99999999.99)
        comVo.chargeWater = 123.45 ;//单位:m3  2位小数点(最大值 99999999.99)
        comVo.flowNo = "" ;//流水号（12位数字）
        comVo.chargeWater = 234.56 ;//单位:m3  2位小数点(最大值 99999999.99)
        comVo.flowNo = "123456789012" ;//流水号（12位数字）

        return this.sendCom2Mw(this.command(CodeV202404.cd_15, comVo, null)) ;
    }
    //设置设备终端剩余水量和剩余金额报警值 (AFN=0x16H)
    private BaseResponse cd16(){
        ComCd16Vo comVo = new ComCd16Vo() ;
        comVo.controllerType = Test.controllerType ;
        comVo.projectNo = Test.projectNo  ;
        comVo.waterAlarm = 10 ;//剩余水量报警值,单位:m3。整数，取值范围0~9999
        comVo.moneyAlarm = 11 ;//剩余金额报警值,单位:元。整数，取值范围0~9999

        return this.sendCom2Mw(this.command(CodeV202404.cd_16, comVo, null)) ;
    }
    //设置设备终端IP地址 (AFN=0x21H)
    private BaseResponse cd21(){
        ComCd21Vo comVo = new ComCd21Vo() ;
        comVo.controllerType = Test.controllerType ;
        comVo.projectNo = Test.projectNo  ;
        comVo.channel = 1 ;//IP通道号(取值范围 1、2).
        comVo.ip = "111.222.123.321" ;//IP（例如 125.235.35.89）
        comVo.port = 60000 ;///端口号（0~65536）

        return this.sendCom2Mw(this.command(CodeV202404.cd_21, comVo, null)) ;
    }
    //设置机井年最大开采量和水位下限 (AFN=0x22H)
    private BaseResponse cd22(){
        ComCd22Vo comVo = new ComCd22Vo() ;
        comVo.controllerType = Test.controllerType ;
        comVo.projectNo = Test.projectNo  ;
        comVo.maxAmountYear = 12345 ;//机井年最大用水量单位：m3 整数，取值范围0~99999999
        comVo.limitLevel = 123.4; //水位下限 单位：m 取值范围:0~9999.99

        return this.sendCom2Mw(this.command(CodeV202404.cd_22, comVo, null)) ;
    }
    //设置设备终端域名(AFN=0x23H)
    private BaseResponse cd23(){
        ComCd23Vo comVo = new ComCd23Vo() ;
        comVo.controllerType = Test.controllerType ;
        comVo.projectNo = Test.projectNo  ;
        comVo.channel = 1 ;//IP通道号(取值范围 1、2).
        comVo.domain = "www.baidu.com" ;//域名（例如 dayuyanjiuyuan.to），最大长度42字符
        comVo.port = 60000 ;///端口号（0~65536）

        return this.sendCom2Mw(this.command(CodeV202404.cd_23, comVo, null)) ;
    }
    //设置设备终端注册号(AFN=0x24H)
    private BaseResponse cd24(){
        ComCd24Vo comVo = new ComCd24Vo() ;
        comVo.controllerType = Test.controllerType ;
        comVo.projectNo = Test.projectNo  ;
        comVo.registerNo = "102030405060708090" ;//域名（例如 dayuyanjiuyuan.to），最大长度42字符

        return this.sendCom2Mw(this.command(CodeV202404.cd_24, comVo, null)) ;
    }
    //设置设备终端年用水量(AFN=0x24H)
    private BaseResponse cd26(){
        ComCd26Vo comVo = new ComCd26Vo() ;
        comVo.controllerType = Test.controllerType ;
        comVo.projectNo = Test.projectNo  ;
        comVo.ipChannel = 1  ;//IP通道号 0x01:1通道 0x02:2通道.
        comVo.maxAmountYear = 123456  ;//设备终端年用水量 单位：m3 整数，取值范围0~99999999

        return this.sendCom2Mw(this.command(CodeV202404.cd_26, comVo, null)) ;
    }
    //设置设备终端用水有效(AFN=0x31H)
    private BaseResponse cd31(){
        ComCd31Vo comVo = new ComCd31Vo() ;
        comVo.controllerType = Test.controllerType ;
        comVo.projectNo = Test.projectNo  ;
        comVo.valid = false ;//有效性

        return this.sendCom2Mw(this.command(CodeV202404.cd_31, comVo, null)) ;
    }
    //查询遥测终端充值记录 (AFN=0x55H)
    private BaseResponse cd55(int page){
        ComCd55Vo comVo = new ComCd55Vo() ;
        comVo.controllerType = Test.controllerType ;
        comVo.projectNo = Test.projectNo  ;
        comVo.page = page ;//分页（取值范围1、2、3、4、5、6、7、8、9）

        return this.sendCom2Mw(this.command(CodeV202404.cd_55, comVo, null)) ;
    }
    //查询设备终端用户用水记录(AFN=0x65H)
    private BaseResponse cd65(int page){
        ComCd65Vo comVo = new ComCd65Vo() ;
        comVo.controllerType = Test.controllerType ;
        comVo.projectNo = Test.projectNo  ;
        comVo.page = page ;
        return this.sendCom2Mw(this.command(CodeV202404.cd_65, comVo, null)) ;
    }
    //查询控制器IP地址(AFN=0x86H)
    private BaseResponse cd86(){
        ComCd86Vo comVo = new ComCd86Vo() ;
        comVo.controllerType = Test.controllerType ;
        comVo.projectNo = Test.projectNo  ;
        comVo.channel = 1 ;//IP通道号(取值范围 1、2).
        return this.sendCom2Mw(this.command(CodeV202404.cd_86, comVo, null)) ;
    }
    //查询控制器域名(AFN=0x87H)
    private BaseResponse cd87(){
        ComCd87Vo comVo = new ComCd87Vo() ;
        comVo.controllerType = Test.controllerType ;
        comVo.projectNo = Test.projectNo  ;
        comVo.channel = 1 ;//IP通道号(取值范围 1、2).
        return this.sendCom2Mw(this.command(CodeV202404.cd_87, comVo, null)) ;
    }
    //平台/APP远程开启水泵/阀门(AFN=0x92H/AFN=0xA2H)
    private BaseResponse cd92(){
        ComCd92_A2Vo comVo = new ComCd92_A2Vo() ;
        comVo.controllerType = Test.controllerType ;
        comVo.projectNo = Test.projectNo  ;
        //comVo.icCardAddr = Test.icCardAddr ;//IC卡地址(8位数字或字母)
        comVo.icCardNo = Test.icCardNo ;//用户卡序列号（17位数字）（6字节BCD，2字节HEX）
        comVo.waterRemain = 123.45 ;//单位:元  2位小数点(最大值 99999999.99)
        comVo.moneyRemain = 234.56 ;//单位:m3  2位小数点(最大值 99999999.99)
        comVo.waterPrice = 0.8 ;//水量单价 单位:元, 2个小数点
        comVo.elePrice = 1.2 ;//电量单价 单位:元, 2个小数点
        comVo.orderNo = "1234567890123456" ;//订单号（16位数字）

        return this.sendCom2Mw(this.command(CodeV202404.cd_92, comVo, null)) ;
    }
    //平台/APP远程开启水泵/阀门(AFN=0x92H/AFN=0xA2H)
    private BaseResponse cdA2(){
        ComCd92_A2Vo comVo = new ComCd92_A2Vo() ;
        comVo.controllerType = Test.controllerType ;
        comVo.projectNo = Test.projectNo  ;
        //comVo.icCardAddr = Test.icCardAddr ;//IC卡地址(8位数字或字母)
        comVo.icCardNo = Test.icCardNo ;//用户卡序列号（17位数字）（6字节BCD，2字节HEX）
        comVo.waterRemain = 123.45 ;//单位:元  2位小数点(最大值 99999999.99)
        comVo.moneyRemain = 234.56 ;//单位:m3  2位小数点(最大值 99999999.99)
        comVo.waterPrice = 0.8 ;//水量单价 单位:元, 2个小数点
        comVo.elePrice = 1.2 ;//电量单价 单位:元, 2个小数点
        comVo.orderNo = "1234567890123456" ;//订单号（16位数字）

        return this.sendCom2Mw(this.command(CodeV202404.cd_A2, comVo, null)) ;
    }

   //平台/APP远程关闭水泵/阀门(AFN=0x93H/AFN=0xA3H)
    private BaseResponse cd93(){
        ComCd93_A3Vo comVo = new ComCd93_A3Vo() ;
        comVo.controllerType = Test.controllerType ;
        comVo.projectNo = Test.projectNo  ;
        comVo.icCardNo = Test.icCardNo ;//用户卡序列号（17位数字）（6字节BCD，2字节HEX）
        comVo.orderNo = "1234567890123456" ;//订单号（16位数字）

        return this.sendCom2Mw(this.command(CodeV202404.cd_93, comVo, null)) ;
    }
    //平台/APP远程关闭水泵/阀门(AFN=0x93H/AFN=0xA3H)
    private BaseResponse cdA3(){
        ComCd93_A3Vo comVo = new ComCd93_A3Vo() ;
        comVo.controllerType = Test.controllerType ;
        comVo.projectNo = Test.projectNo  ;
        comVo.icCardNo = Test.icCardNo ;//用户卡序列号（17位数字）（6字节BCD，2字节HEX）
        comVo.orderNo = "1234567890123456" ;//订单号（16位数字）

        return this.sendCom2Mw(this.command(CodeV202404.cd_A3, comVo, null)) ;
    }


}

 pipIrr-platform/pipIrr-web/pipIrr-mwTest-web/src/main/java/com/dy/pipIrrMwTestWeb/test/TestSupport.java

@@ -26,19 +26,16 @@
    protected static String rtuAddr = "37142501020100215" ;
    protected static String rtuResultSendWebUrl = "http://127.0.0.1:8080/test" ;

    protected static String controllerType = "57" ;
    protected static Integer projectNo = 10 ;
    protected static String controllerType = "57" ;//控制器类型
    protected static Integer projectNo = 10 ;//项目编码

    protected static String icCardAddr = "04BEA5BB" ;
    protected static String icCardNo = "04BEA5BB" ;
    protected static String icCardAddr = "04BEA5BB" ;//IC卡地址
    protected static String icCardNo = "37142501020500001" ;//IC卡编号（用户卡序列号）


    private RestTemplate restTemplate;

    @Autowired
    public void setRestTemplate(RestTemplate restTemplate){
        this.restTemplate = restTemplate ;
    }
    private RestTemplate restTemplate;


    protected ComCdXyVo comCdXyVo(){
        ComCdXyVo comVo = new ComCdXyVo() ;
@@ -54,7 +51,6 @@
        com.code = code ;
        com.rtuAddr = rtuAddr ;
        com.type = CommandType.outerCommand ;
        com.noRtMwDealRes = false ;
        com.rtuResultSendWebUrl = rtuResultSendWebUrl ;

        com.param = param ;
@@ -79,7 +75,6 @@
        } catch (Exception e) {
            e.printStackTrace();
        }
        assert response != null;
        return response.getBody();
    }

@@ -100,7 +95,6 @@
        } catch (Exception e) {
            e.printStackTrace();
        }
        assert response != null;
        return response.getBody();
    }