接入中间件代码整理后

liurunyu

2023-11-20 fb31efc4c1efee99164dc83f6f67f1f609d1ba40

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
package com.dy.common.mw.protocol.pMeterV1_0_1;
 
import com.dy.common.mw.protocol.AnnotationOnLine;
import com.dy.common.mw.protocol.OnLine;
 
@AnnotationOnLine(
        protocolName = ProtocolConstantV1_0_1.protocolName,
        priority = ProtocolConstantV1_0_1.priority) 
public class OnLineV1_0_1 implements OnLine{
 
    /**
     * 对上线数据进行分析 
     * @param upBuf 上行数据
     * @return
     */
    @Override
    public OnLineResult parse(byte[] upBuf)throws Exception {
        OnLineResult olr = new OnLineResult() ;
        CommonV1_0_1 cp = new CommonV1_0_1() ;
        Boolean flag = cp.isThisProtocolHead(upBuf) ;
        if(flag == null){
            //出错
            olr.result = OnLine.OnLineAction_fail ;
            olr.rtuAddr = null ;
            olr.meterNo = null ;
        }else if(!flag.booleanValue()){
            //不是本协议数据
            olr.result = OnLine.OnLineAction_success_noMe ;
            olr.rtuAddr = null ;
            olr.meterNo = null ;
        }else{
            //是本协议数据
            olr.result = OnLine.OnLineAction_success ;
            olr.rtuAddr = cp.parseRtuAddr(upBuf) ;
            olr.meterNo = cp.parseMeterNo(upBuf) ;
            olr.protocolName = ProtocolConstantV1_0_1.protocolName ;
        }
        return olr;
    }
 
}