电力电表376.1协议java版

package com.sx.frontend.protocal376_1.internal.wrap; import com.sx.frontend.protocal376_1.CodecConfig; import com.sx.frontend.protocal376_1.Packet; import com.sx.frontend.protocal376_1.exception.DecodingException; import com.sx.frontend.protocal376_1.exception.EncodingException; import com.sx.frontend.protocal376_1.exception.InvalidConfigException; import com.sx.frontend.protocal376_1.internal.ConfigParse.*; import com.sx.frontend.protocal376_1.internal.ProtocalTemplate; import com.sx.frontend.protocal376_1.internal.fieldGroupFormater.FormatterImpl; import com.sx.frontend.protocal376_1.internal.fieldGroupFormater.IFormatter; import com.sx.frontend.protocal376_1.internal.fieldType.Da; import com.sx.frontend.protocal376_1.internal.fieldType.Dt; import com.sx.frontend.protocal376_1.internal.fieldType.FieldTypeContext; import com.sx.frontend.protocal376_1.internal.fieldType.IFieldType; import com.sx.frontend.protocal376_1.internal.packetSegment.Data; import com.sx.frontend.protocal376_1.internal.packetSegment.PacketSegmentContext; import com.sx.frontend.protocal376_1.internal.packetSegment.SegmentEnum; import com.sx.frontend.protocal376_1.internal.validator.IValidator; import com.sx.frontend.protocal376_1.internal.validator.ValidatorContext; import org.springframework.expression.EvaluationContext; import org.springframework.expression.ExpressionParser; import org.springframework.expression.spel.standard.SpelExpressionParser; import org.springframework.expression.spel.support.StandardEvaluationContext; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; /** * Created by PETER on 2015/3/25. */ public class DataWrapper extends Wrapper implements Constants{ private static final String MULTIPLECOMMAND="multipleCommand"; private Da da=new Da(); private Dt dt=new Dt(); private FieldTypeParam dadtParam=new FieldTypeParam(2); private FieldTypeContext fieldTypeContext=new FieldTypeContext(); private ValidatorContext validatorContext=new ValidatorContext(); private IFormatter formatter=new FormatterImpl(); private Map<String,EncodeFieldGroup> encodeFieldGroupMap=new HashMap<>(); public DataWrapper(){ init(); } private void init(){ encodeFieldGroupMap.put(LIST, new EncodeFieldGroup() { /** * 编码list类型group * @param fieldGroup * @param dataContentMap * @param buffer * @param protocalTemplate * @throws Exception */ @Override public void execute(FieldGroup fieldGroup,Map<String,Object> dataContentMap, List<byte[]> buffer,ProtocalTemplate protocalTemplate) throws Exception{ ExpressionParser parser = new SpelExpressionParser(); EvaluationContext context = new StandardEvaluationContext(); context.setVariable("data", dataContentMap); int numRef; try { numRef = parser.parseExpression(fieldGroup.getRefNum()). getValue(context, Integer.class); }catch (Exception e){ e.printStackTrace(); throw new DecodingException(1111,"list数量解析失败:"+fieldGroup.getRefNum()); } List<Object> list = (List) dataContentMap.get(LIST); for (int i = 0; i < numRef; i++) { Object manyIndex = list.get(i); if(fieldGroup.getFormater()!=null && manyIndex instanceof String){ Map manyMapIndex=formatter.division(fieldGroup.getFormater(),manyIndex.toString()); encodeData(fieldGroup, manyMapIndex,buffer,protocalTemplate); }else if(manyIndex instanceof Map){ encodeData(fieldGroup, (Map)manyIndex,buffer,protocalTemplate); }else{ throw new EncodingException(1111,"数据格式错误"+manyIndex); } } } }); encodeFieldGroupMap.put(FIELDGROUP, new EncodeFieldGroup() { /** * 编码一般类型group * @param fieldGroup * @param dataContentMap * @param buffer * @param protocalTemplate * @throws Exception */ @Override public void execute(FieldGroup fieldGroup, Map<String, Object> dataContentMap, List<byte[]> buffer, ProtocalTemplate protocalTemplate) throws Exception { Object value=dataContentMap.get(fieldGroup.getName()); if(fieldGroup.getFormater()!=null && value instanceof String){ Map valueMap=formatter.division(fieldGroup.getFormater(),value.toString()); encodeData(fieldGroup, valueMap , buffer,protocalTemplate); }else if(value instanceof Map){ encodeData(fieldGroup, (Map)value , buffer,protocalTemplate); }else{ throw new EncodingException(1111,"数据格式错误"+value); } } }); encodeFieldGroupMap.put(REFFIELDGROUP, new EncodeFieldGroup() { /** * 编码引用类型group * @param fieldGroup * @param dataContentMap * @param buffer * @param protocalTemplate * @throws Exception */ @Override public void execute(FieldGroup fieldGroup, Map<String, Object> dataContentMap, List<byte[]> buffer, ProtocalTemplate protocalTemplate) throws Exception { String refType = fieldGroup.getRefType(); FieldGroup refGroup = protocalTemplate.getFieldGroupMap().get(refType); if (refGroup == null) { throw new InvalidConfigException(1111, "找不到refGroup:" + refType); } Object value = dataContentMap.get(fieldGroup.getName()); if (refGroup.getFormater() != null) { if (value instanceof String) { Map valueMap = formatter.division(refGroup.getFormater(), value.toString()); encodeData(refGroup, valueMap, buffer, protocalTemplate); } else { throw new EncodingException(1111, "数据格式错误" + value); } } else { encodeData(refGroup, dataContentMap, buffer, protocalTemplate); } } }); } /** * 编码数据区 * @param in * @param packetSegmentContext * @param protocalTemplate * @param codecConfig * @throws Exception */ @Override public void encode(Packet in, PacketSegmentContext packetSegmentContext, ProtocalTemplate protocalTemplate,CodecConfig codecConfig) throws Exception { Data dataSeg=(Data)packetSegmentContext.getSegment(SegmentEnum.data); Map<String,Object> dataContentMap=in.getData(); List<byte[]> buffer=dataSeg.getBuffer(); if(in.getCommand().equals(MULTIPLECOMMAND)){ Iterator commandIter=in.getData().keySet().iterator(); while (commandIter.hasNext()){ String command=commandIter.next().toString(); FieldGroup dataGroup=protocalTemplate.getDataMapByName().get(command); dataSeg.setFn(dataGroup.getFn()); buffer.add(da.encode(dataSeg.getPn(), dadtParam)); buffer.add(dt.encode(dataSeg.getFn(),dadtParam)); if(dataGroup==null){ throw new EncodingException(1111,"不支持命令号:"+in.getCommand()); } encodeData(dataGroup, (Map)dataContentMap.get(command), buffer, protocalTemplate);