1、完善协议实现代码； 2、实体协议数据处理自动任务（报警及状态+定时上报数据）； 3、数据库实体id自动付值插件优化。

liurunyu

2024-05-20 7a76aa4311c86413ff964ed882f592edec5dc470

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

@@ -1,6 +1,7 @@
package com.dy.common.mw.protocol.p206V202404.parse;

import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.dy.common.mw.protocol.*;
import com.dy.common.mw.protocol.p206V202404.CodeV202404;
import com.dy.common.mw.protocol.p206V202404.ParseParamsForDownV202404;
@@ -23,6 +24,7 @@

        MidResultToRtu midRs = new MidResultToRtu() ;
        midRs.protocolName = para.protocolName ;//协议名称
        midRs.rtuResultSendWebUrl = para.rtuResultSendWebUrl ;
        midRs.rtuAddr = para.rtuAddr ;//Rtu地址
        midRs.commandId = para.commandId ;//命令ID，发起命令的客户端(web端)生成，以匹配命令结果
        midRs.downCode = para.commandCode ;//下行命令功能码;
@@ -49,7 +51,8 @@
    public byte[] doParse(ParseParamsForDownV202404 para) throws Exception {
        byte[] bytes = GlCreate.createStart2Cd(para.rtuAddr, para.commandCode);
        if(para.param != null){
            String json = (String)para.param;
            JSONObject obj = (JSONObject)para.param;
            String json = obj.toJSONString();
            ComCd92_A2Vo cvo = JSON.parseObject(json, ComCd92_A2Vo.class) ;
            if(cvo == null){
                throw new Exception("json转ComCd92_A2Vo为null") ;
@@ -77,12 +80,12 @@
            if(!NumUtil.isPlusIntNumber(cvo.orderNo)){
                throw new Exception("订单号必须是16位数字") ;
            }
            if(cvo.orderNo.length() != 12){
            if(cvo.orderNo.length() != 16){
                throw new Exception("订单号必须是16位数字") ;
            }


            byte[] bs = new byte[39] ;
            byte[] bs = new byte[45] ;
            int index = 0 ;
            bs[index] = (byte)(Integer.parseInt(cvo.controllerType, 16));

@@ -100,7 +103,7 @@
            GlCreate.createIcCardNo(cvo.icCardNo, bs, index);

            index += 8 ;
            if(cvo.waterRemain != null){
            if(cvo.waterRemain == null){
                cvo.waterRemain = 0.0 ;
            }
            String strTemp = "" + Double.valueOf(cvo.waterRemain * 100).intValue() ;
@@ -118,7 +121,7 @@
                bs[index++] = 0 ;
            }

            if(cvo.moneyRemain != null){
            if(cvo.moneyRemain == null){
                cvo.moneyRemain = 0.0 ;
            }
            strTemp = "" + (Double.valueOf(cvo.moneyRemain * 100)).intValue() ;
@@ -137,7 +140,7 @@
            }


            if(cvo.waterPrice != null){
            if(cvo.waterPrice == null){
                cvo.waterPrice = 0.0 ;
            }
            strTemp = "" + (Double.valueOf(cvo.waterPrice * 100)).intValue() ;
@@ -156,7 +159,7 @@
            }


            if(cvo.elePrice != null){
            if(cvo.elePrice == null){
                cvo.elePrice = 0.0 ;
            }
            strTemp = "" + (Double.valueOf(cvo.elePrice * 100)).intValue() ;
@@ -178,6 +181,9 @@
            ByteUtil.string2BCD_BE(bs, cvo.orderNo, index) ;

            index += 8 ;
            GlCreate.createDt(bs, index);

            index += 6 ;
            GlCreate.createPw(bs, index);

            index += 2 ;