|  |  | 
 |  |  | 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; | 
 |  |  | import com.dy.common.mw.protocol.p206V202404.downVos.ComCd22Vo; | 
 |  |  | import com.dy.common.mw.protocol.p206V202404.downVos.ComCd92_A2Vo; | 
 |  |  | import com.dy.common.mw.protocol.p206V202404.parse.global.GlCreate; | 
 |  |  | import com.dy.common.util.ByteUtil; | 
 |  |  | 
 |  |  |  | 
 |  |  |         MidResultToRtu midRs = new MidResultToRtu() ; | 
 |  |  |         midRs.protocolName = para.protocolName ;//协议名称 | 
 |  |  |         midRs.protocolVersion = para.protocolVersion ;//协议版本号 | 
 |  |  |         midRs.rtuResultSendWebUrl = para.rtuResultSendWebUrl ; | 
 |  |  |         midRs.rtuAddr = para.rtuAddr ;//Rtu地址 | 
 |  |  |         midRs.commandId = para.commandId ;//命令ID,发起命令的客户端(web端)生成,以匹配命令结果 | 
 |  |  |         midRs.downCode = para.commandCode ;//下行命令功能码; | 
 |  |  |         midRs.downCodeName = CodeV202404.getCodeName(para.commandCode) ;//下行命令功能码名称; | 
 |  |  |         midRs.downBuffer = bs ;//下行命令数据 | 
 |  |  |         midRs.downBufHex = ByteUtil.bytes2Hex(bs, true) ;//下行命令数据十六进制形式 | 
 |  |  |         midRs.hasResponse = true ;//是否有应答 | 
 |  |  | 
 |  |  |     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") ; | 
 |  |  | 
 |  |  |             if(!NumUtil.isPlusIntNumber(cvo.orderNo)){ | 
 |  |  |                 throw new Exception("订单号必须是16位数字") ; | 
 |  |  |             } | 
 |  |  |             if(cvo.orderNo.length() != 12){ | 
 |  |  |             if(cvo.orderNo.length() != 16){ | 
 |  |  |                 throw new Exception("订单号必须是16位数字") ; | 
 |  |  |             } | 
 |  |  |  | 
 |  |  | 
 |  |  |             bs[index] = cvo.projectNo.byteValue() ; | 
 |  |  |  | 
 |  |  |             index ++ ; | 
 |  |  |             if(cvo.controllerType.equals("01")){ | 
 |  |  |                 bs[index] = (byte)0xF0 ; | 
 |  |  |             }else{ | 
 |  |  |                 bs[index] = (byte)0x00 ; | 
 |  |  |             } | 
 |  |  |             GlCreate.createValveOrPump(cvo.controllerType, bs, index) ; | 
 |  |  |  | 
 |  |  |             index ++ ; | 
 |  |  |             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() ; | 
 |  |  | 
 |  |  |             for(int i = 0 ; i < bTempLen; i++){ | 
 |  |  |                 bs[index++] = bTemp[i] ; | 
 |  |  |                 count ++ ; | 
 |  |  |                 if(count >= 4){ | 
 |  |  |                 if(count >= 5){ | 
 |  |  |                     break ; | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  |             for(; count < 4; count++){ | 
 |  |  |             for(; count < 5; count++){ | 
 |  |  |                 bs[index++] = 0 ; | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |             if(cvo.moneyRemain != null){ | 
 |  |  |             if(cvo.moneyRemain == null){ | 
 |  |  |                 cvo.moneyRemain = 0.0 ; | 
 |  |  |             } | 
 |  |  |             strTemp = "" + (Double.valueOf(cvo.moneyRemain * 100)).intValue() ; | 
 |  |  |             strTemp = "" + (Double.valueOf(cvo.moneyRemain * 10000)).intValue() ; | 
 |  |  |             bTemp = ByteUtil.string2BCD_LE(strTemp) ; | 
 |  |  |             bTempLen = bTemp.length ; | 
 |  |  |             count = 0 ; | 
 |  |  | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |             if(cvo.waterPrice != null){ | 
 |  |  |             if(cvo.waterPrice == null){ | 
 |  |  |                 cvo.waterPrice = 0.0 ; | 
 |  |  |             } | 
 |  |  |             strTemp = "" + (Double.valueOf(cvo.waterPrice * 100)).intValue() ; | 
 |  |  | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |             if(cvo.elePrice != null){ | 
 |  |  |             if(cvo.elePrice == null){ | 
 |  |  |                 cvo.elePrice = 0.0 ; | 
 |  |  |             } | 
 |  |  |             strTemp = "" + (Double.valueOf(cvo.elePrice * 100)).intValue() ; |