初始化提交

jiazx0107@163.com

2023-05-17 620eab6cca2bc9ef9ea6d3067a0a5ba1deadbd1c

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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
package com.ld.igds.protocol.gps;
 
import com.ld.igds.protocol.gps.analysis.AnalysisAuthInfo;
import com.ld.igds.protocol.gps.analysis.AnalysisLocationInfo;
import com.ld.igds.protocol.gps.analysis.AnalysisRegisterInfo;
import com.ld.igds.protocol.utl.GpsUtils;
import com.ld.igds.util.BytesUtil;
import com.ld.io.api.IoSession;
 
import lombok.extern.slf4j.Slf4j;
 
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
 
/***
 * 解析GPS信息类型
 *
 * @author:
 * @description:
 * @version:
 * @data:
 *
 */
@Slf4j
@Component(AnalysisInvoker.BEAN_ID)
public class AnalysisInvoker {
 
    public static final String BEAN_ID = "zxlk.gpsAnalysisInvoker";
 
    @Autowired
    private AnalysisRegisterInfo analysisRegisterInfo;
    @Autowired
    private AnalysisAuthInfo analysisAuthInfo;
    @Autowired
    private AnalysisLocationInfo analysisLocationInfo;
 
    /**
     * 注册：7E 0100 0031 013820036316 0002 0000000000000000004632303028464C592D44725370292D56322E3933303033363331363131332E3130362E39332E3530 3A 7E
     *      7E 0100 0021 015294626226 001B 002C012F37303131314135452D385720203030303030303001D4C1423838383838                                 C3 7E
     * 鉴权：7E 0102 0006 013820036316 0182 013820036316 86 7E
     *      7E 0102 0006 015294626226 001C 015294626226 19 7E
     * 心跳：7E 0002 0000 013820036316 0021 4C 7E
     *      7E 0002 0000 015294626226 002B C8 7E
     * 位置主动汇报：7E 0200 0022 013820036316 000A      00000000 00000002 0212EA33 06C46ED6 0000 0000 0131 200827150858 010400000001 8A 7E
     *              7E 0200 0073 015294626226 001E      00000000 00000003 018C4466 06BFB5E0 00B6 000A 015D 200829113327 010400000000EB4F0004002D100400060089FFFFFFFF000300A864002400A901CC0006E3D081DC10E3D0808F19E3D0AA3E16E3D081E615E3D03B4E14E3D06F7411000C00B289860444011890150426000600C5FFFFFFEFEC7E
     *
     * 位置查询应答：7E 0201 0024 013820036316 000F 0001 00000000 00000002 0212EA33 06C46ED6 0000 0000 003D 200827150953 010400000001 8E 7E
     *              7E 0201 00E7 015294626226 00A7 0001 00000000 00000003 018C4424 06BFB5C0 00B0 0000 00D1 200829115127 010400000000EBC10004002D0FFA00060089FFFFFFFF000300A863002400A901CC0006E3D081DC2AE3D06F741CE3D07FFA17E3D081DE12E3D081DD0FE3D080900D000C00B289860444011890150426007000B90530343A38383A35663A38343A32303A62352C2D36362C31383A36393A64613A37323A63613A39362C2D36372C64303A63373A63303A65633A39623A36652C2D37332C37383A61313A30363A33633A37383A34382C2D37382C39343A64393A62333A62663A35323A36652C2D3831000600C5FFFFFFEFFE7E
     *
     *  7E07040078015294626226002600010100730000000000000003018C442406BFB5C0000000000000200829124211010400000000EB4F0004002D102C00060089FFFFFFFF000300A864002400A901CC0006E3D081DC1AE3D06F7414E3D07FFA13E3D081E612E3D0AA3E0EE3D03B4E0E000C00B289860444011890150426000600C5FFFFFFEBCD7E
     */
    public void analysis(IoSession ioSession, String ip, Integer port, byte[] bytes) {
 
        try {
            //接收消息时：验证消息头尾标识-->转义还原-->验证校验码-->解析消息
            String strMsg = BytesUtil.bytesToString(bytes);
 
            //验证消息标识符
            if(! strMsg.substring(0,2).equals(GpsUtils.MSG) ||
                    ! strMsg.substring(strMsg.length()-2,strMsg.length()).equals(GpsUtils.MSG)){
                log.debug("消息标识符错误，消息不进行处理！");
                return;
            }
 
            //去除标识符
            strMsg = GpsUtils.delIdentifier(strMsg);
            //对消息转义还原：7D02-->7E,7D01-->7D
            strMsg = GpsUtils.escapeCode2(strMsg);
 
            //对消息校验码进行校验
            String msg = strMsg.substring(0, strMsg.length() - 2);
            String msgCheckCode = strMsg.substring(strMsg.length() - 2, strMsg.length());
            String checkCode = GpsUtils.checkCode(msg);
            if (!checkCode.equalsIgnoreCase(msgCheckCode)) {
                log.debug("消息校验码错误，消息不进行处理！");
                return;
            }
 
            //截取消息ID，并判断消息类型
            String msgId = strMsg.substring(0, 4);
            //注册
            if (GpsUtils.MSG_01.equals(msgId)) {
                analysisRegisterInfo.analysisRegisterInfo(ip, port, strMsg);
            }
            //鉴权
            if (GpsUtils.MSG_02.equals(msgId)) {
                analysisAuthInfo.analysisAuthInfo(ioSession, ip, port, strMsg);
                log.debug("GPS设备登录成功");
            }
            //位置信息
            if (GpsUtils.MSG_03.equals(msgId) || GpsUtils.MSG_333.equals(msgId)) {
                log.debug("开始解析位置信息：" + strMsg);
                analysisLocationInfo.analysisLocationInfo(ip, port, strMsg);
                log.debug("位置信息解析成功！");
            }
        } catch (Exception e) {
            log.error("GPS信息解析出现异常，异常信息：{}", e);
        }
    }
 
}