|  |  | 
 |  |  | import com.dy.common.mw.protocol.*; | 
 |  |  | import com.dy.common.mw.protocol.p206V1_0_0.*; | 
 |  |  | import com.dy.common.mw.protocol.p206V1_0_0.parse.global.GlParse; | 
 |  |  | import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCd83CloseVo; | 
 |  |  | import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCd83OpenVo; | 
 |  |  | import com.dy.common.util.ByteUtil; | 
 |  |  | import org.apache.logging.log4j.LogManager; | 
 |  |  | import org.apache.logging.log4j.Logger; | 
 |  |  | 
 |  |  |      */ | 
 |  |  |     protected void doParse(byte[] bs, int bsLen, String dataCode, Data data) throws Exception { | 
 |  |  |         byte opType = bs[ProtocolConstantV206V1_0_0.dataIndex]; | 
 |  |  |         if(opType == 1 || opType == 3 || opType == 8){ | 
 |  |  |             this.doParseOpen(opType, bs, bsLen, dataCode, data); | 
 |  |  |         }else{ | 
 |  |  |         Boolean isCloseType = CommonV1_0_1.isCloseValveType(opType) ; | 
 |  |  |         if(isCloseType != null && isCloseType.booleanValue()){ | 
 |  |  |             this.doParseClose(opType, bs, bsLen, dataCode, data); | 
 |  |  |         }else if(isCloseType != null && !isCloseType.booleanValue()){ | 
 |  |  |             this.doParseOpen(opType, bs, bsLen, dataCode, data); | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |     private void doParseOpen(byte opType, byte[] bs, int bsLen, String dataCode, Data data) throws Exception { | 
 |  |  |         DataV1_0_1 dV1 = (DataV1_0_1)data.getSubData() ; | 
 |  |  |         DataCd83OpenVo cdData = new DataCd83OpenVo() ; | 
 |  |  |         dV1.dataCd83OpenVo = cdData ; | 
 |  |  |         dV1.subData = cdData ; | 
 |  |  |  | 
 |  |  |         cdData.type = opType ; | 
 |  |  |  | 
 |  |  | 
 |  |  |         cdData.totalAmount += tpInt * 100000000.0 ; | 
 |  |  |  | 
 |  |  |         //用水户号数据格式:5字节BCD码低位在前高位在后。 | 
 |  |  |         cdData.clientNum = ByteUtil.BCD2String_LE(bs, index, index + 4) ; | 
 |  |  |         cdData.icCardNo = ByteUtil.BCD2String_LE(bs, index, index + 4) ; | 
 |  |  |         index += 5 ; | 
 |  |  |  | 
 |  |  |         //IC卡号格式:4字节HEX码低位在前高位在后。 | 
 |  |  |         cdData.clientNum = ByteUtil.bytesToHex(bs, index, index + 3) ; | 
 |  |  |         cdData.icCardAddr = ByteUtil.bytesToHex(bs, index, index + 3) ; | 
 |  |  |         index += 4 ; | 
 |  |  |  | 
 |  |  |         //用水户余额:用户余额4字节BCD码,取值范围0.00~999999.99,单位为元。 | 
 |  |  | 
 |  |  |  | 
 |  |  |         //用水户用水开始时间:6字节BCD码,顺序是年月日时分秒,其中公元年=2000+年。 | 
 |  |  |         cdData.openDt = GlParse.parseTp(bs, index) ; | 
 |  |  |         index += 6 ; | 
 |  |  |  | 
 |  |  |         index += 6 ; | 
 |  |  |         /* 开阀时,此部分没有 | 
 |  |  |         cdData.priceType = bs[index] ; | 
 |  |  |  | 
 |  |  |         index++ ; | 
 |  |  |         cdData.price = 0.0D ; | 
 |  |  |         tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; | 
 |  |  |         index++ ; | 
 |  |  |         cdData.price += tpInt/100.0 ; | 
 |  |  |         tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; | 
 |  |  |         index++ ; | 
 |  |  |         cdData.price += tpInt; | 
 |  |  |  | 
 |  |  |         cdData.cardType = bs[index] ; | 
 |  |  |  | 
 |  |  |         index++ ; | 
 |  |  |          */ | 
 |  |  |         //控制器时钟 | 
 |  |  |         cdData.rtuDt = GlParse.parseTp(bs, index) ; | 
 |  |  |         //index += 6 ; | 
 |  |  | 
 |  |  |     private void doParseClose(byte opType, byte[] bs, int bsLen, String dataCode, Data data) throws Exception { | 
 |  |  |         DataV1_0_1 dV1 = (DataV1_0_1)data.getSubData() ; | 
 |  |  |         DataCd83CloseVo cdData = new DataCd83CloseVo() ; | 
 |  |  |         dV1.dataCd83CloseVo = cdData ; | 
 |  |  |         dV1.subData = cdData ; | 
 |  |  |  | 
 |  |  |         cdData.type = opType ; | 
 |  |  |  | 
 |  |  | 
 |  |  |         cdData.totalAmount += tpInt * 100000000.0 ; | 
 |  |  |  | 
 |  |  |         //用水户号数据格式:5字节BCD码低位在前高位在后。 | 
 |  |  |         cdData.clientNum = ByteUtil.BCD2String_LE(bs, index, index + 4) ; | 
 |  |  |         cdData.icCardNo = ByteUtil.BCD2String_LE(bs, index, index + 4) ; | 
 |  |  |         index += 5 ; | 
 |  |  |  | 
 |  |  |         //IC卡号格式:4字节HEX码低位在前高位在后。 | 
 |  |  |         cdData.clientNum = ByteUtil.bytesToHex(bs, index, index + 3) ; | 
 |  |  |         cdData.closeDt = ByteUtil.bytesToHex(bs, index, index + 3) ; | 
 |  |  |         index += 4 ; | 
 |  |  |  | 
 |  |  |         //用水户余额:用户余额4字节BCD码,取值范围0.00~999999.99,单位为元。 | 
 |  |  | 
 |  |  |         index++ ; | 
 |  |  |         cdData.thisTime += tpInt * 100 ; | 
 |  |  |  | 
 |  |  |  | 
 |  |  |         cdData.priceType = bs[index] ; | 
 |  |  |  | 
 |  |  |         index++ ; | 
 |  |  |         cdData.price = 0.0D ; | 
 |  |  |         tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; | 
 |  |  |         index++ ; | 
 |  |  |         cdData.price += tpInt/100.0 ; | 
 |  |  |         tpInt = ByteUtil.BCD2Int_LE(bs, index, index) ; | 
 |  |  |         index++ ; | 
 |  |  |         cdData.price += tpInt; | 
 |  |  |  | 
 |  |  |         cdData.cardType = bs[index] ; | 
 |  |  |  | 
 |  |  |         index++ ; | 
 |  |  |         //控制器时钟 | 
 |  |  |         cdData.rtuDt = GlParse.parseTp(bs, index) ; | 
 |  |  |         //index += 6 ; |