#

luxiaotao1123

2024-09-21 42b108daf16fd969696a23638481111432ae8ebe

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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
package com.zy.acs.gateway.utils;
 
import com.zy.acs.common.domain.AgvProtocol;
import com.zy.acs.common.domain.protocol.IMessageBody;
import com.zy.acs.gateway.constant.ProtocolPojoType;
import com.zy.acs.gateway.constant.ProtocolType;
import com.zy.acs.gateway.domain.AgvPackage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
 
/**
 * Created by vincent on 2019-04-03
 */
public class ProtocolUtils {
 
    private static final Logger log = LoggerFactory.getLogger(ProtocolUtils.class);
 
    // 下行协议报文组装
    public static AgvPackage installDownProtocol(AgvProtocol protocol){
 
 
        ProtocolPojoType protocolPojo = ProtocolPojoType.query(protocol.getMessageBody().getClass());
 
        assert protocolPojo !=   null;
 
        AgvPackage ackPackage = AgvPackage.valueOfEmpty();
        ackPackage.getHeader()
                .setStartSymbol((byte)0xEE)
                .setContentLength(0)
                .setUniqueNo(protocol.getAgvNo())
                .setTimestamp(protocol.getTimestamp())
                .setProtocolType(protocolPojo.protocolType)
        ;
 
        ackPackage.getBody().setMessageBody(protocol.getMessageBody());
 
        return ackPackage;
 
    }
 
    // 下行协议报文组装
    public static AgvPackage installDownProtocol(String uniqueNo, ProtocolType protocolType){
 
 
        AgvPackage ackPackage = AgvPackage.valueOfEmpty();
        ackPackage.getHeader()
                .setStartSymbol((byte)0xEE)
                .setContentLength(0)
                .setUniqueNo(uniqueNo)
                .setTimestamp((int)System.currentTimeMillis()/1000)
                .setProtocolType(protocolType)
        ;
 
        ProtocolPojoType protocolPojo = ProtocolPojoType.query(protocolType);
 
 
        assert protocolPojo != null;
 
 
        IMessageBody iMessageBody = null;
 
        try {
 
            iMessageBody = protocolPojo.clazz.newInstance();
        } catch (ReflectiveOperationException reflectiveOperationException) {
 
 
            log.error("MessageBodyHandler ReflectiveOperationException", reflectiveOperationException);
 
            log.error("java反射创建实例失败：{}", protocolPojo.clazz.getName());
 
            return null;
        }
 
 
 
        ackPackage.getBody().setMessageBody(iMessageBody);
 
 
 
        return ackPackage;
    }
 
 
 
}