完善代码

liurunyu

2025-08-18 867370234299c79b56c6088b2fe7d2c15da22f38

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

@@ -1,16 +1,20 @@
package com.dy.common.mw.protocol.p206V1;

import com.dy.common.mw.channel.tcp.TcpIoSessionAttrIdIsRtuAddr;
import com.dy.common.util.ByteUtil;
import com.dy.common.util.ByteUtilUnsigned;
import com.dy.common.util.CRC16;
import com.dy.common.util.CRC8_for_2_0;
import org.apache.mina.core.session.IoSession;


public class CommonV1 {


   /**
    * 检查头
    * @param bs 上行字节数组
    * @return [rt1->true:是本协议P206，false:不是本协议;  rt2->true:是水资源协议，false:是升级协议]
    * @return [【0】->true:是本协议P206，false:不是本协议;  【1】->true:是水资源协议，false:是升级协议]
    * @throws Exception  异常
    */
   public Boolean[] isThisProtocolHead(byte[] bs) throws Exception{
@@ -176,8 +180,9 @@
            return "计算CRC是:" + crcCompute + "，上传CRC是" + crcInBs ;
         }
      }else{
         int crcCompute = (byte)new CRC16().CRC(bs, ProtocolConstantV206V1.ctrlIndex, bs.length - 3) ;
         int crcInBs = ByteUtilUnsigned.bytes2Short_BE(bs, bs.length - 3) ;
         short crcCompute = new CRC16().CRC(bs, 0, bs.length - 4) ;
         short crcInBs = ByteUtil.bytes2Short_BE(bs,bs.length - 3) ;
         //int crcInBs = ByteUtilUnsigned.bytes2Short_BE(bs, bs.length - 3) ;
         if(crcCompute == crcInBs){
            return null ;
         }else{