jt808/req.go at master · back0893/jt808 · GitHub

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
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
package jt808

import "fmt"

type MsgHead struct {
	MsgID    uint16
	Property uint16
	PhoneNo  string
	FlowID   uint16

	Crypto     bool
	BodyLength uint16
	Mux        bool

	PhoneNoBCD []byte
}

type LocMsg struct {
	Warn   uint32
	Status uint32

	Lat       uint32
	Lng       uint32
	Elevation uint16
	Speed     uint16
	Direction uint16

	UploadTime string
}

type AuthMsg struct {
	AuthCode string
}

type LoginMsg struct {
	ProvinceID uint16
	CityID     uint16

	ManufacturerID string
	TerminalType   string
	TerminalID     string

	VehicleColor uint16
	VehicleNo    string
}

type TerminalCommonRespBody struct {
	FlowID     uint16
	ResponseID uint16
	Result     byte
}

const (
	MsgHeadMuxMask        = 0x2000
	MsgHeadCryptoMask     = 0x0400
	MsgHeadBodyLengthMask = 0x03ff
)

var (
	ErrNotSupport = fmt.Errorf("Not Support")
)

func DecodeMsgHead(bd *BufDecoder) (*MsgHead, error) {

	head := new(MsgHead)

	var err error

	if head.MsgID, err = bd.Uint16(); err != nil {
		return nil, err
	}

	if head.Property, err = bd.Uint16(); err != nil {
		return nil, err
	}

	head.PhoneNoBCD = make([]byte, 6, 6)
	if _, err = bd.Read(head.PhoneNoBCD); err != nil {
		return nil, err
	}
	head.PhoneNo = bcd2str(head.PhoneNoBCD)

	if head.FlowID, err = bd.Uint16(); err != nil {
		return nil, err
	}

	head.BodyLength = head.Property & MsgHeadBodyLengthMask
	head.Crypto = (head.Property & MsgHeadCryptoMask) != 0
	head.Mux = (head.Property & MsgHeadMuxMask) != 0

	if head.Mux {
		return nil, ErrNotSupport
	}

	return head, nil
}

func DecodeLocMsg(head *MsgHead, bd *BufDecoder) (*LocMsg, error) {

	msg := new(LocMsg)
	var err error

	if msg.Warn, err = bd.Uint32(); err != nil {
		return nil, err
	}

	if msg.Status, err = bd.Uint32(); err != nil {
		return nil, err
	}

	if msg.Lat, err = bd.Uint32(); err != nil {
		return nil, err
	}

	if msg.Lng, err = bd.Uint32(); err != nil {
		return nil, err
	}

	if msg.Elevation, err = bd.Uint16(); err != nil {
		return nil, err
	}

	if msg.Speed, err = bd.Uint16(); err != nil {
		return nil, err
	}

	if msg.Direction, err = bd.Uint16(); err != nil {
		return nil, err
	}

	if msg.UploadTime, err = bd.BCD(6); err != nil {
		return nil, err
	}

	return msg, nil
}

func DecodeLoginMsg(head *MsgHead, bd *BufDecoder) (*LoginMsg, error) {
	msg := new(LoginMsg)
	var err error

	if msg.ProvinceID, err = bd.Uint16(); err != nil {
		return nil, err
	}

	if msg.CityID, err = bd.Uint16(); err != nil {
		return nil, err
	}

	if msg.ManufacturerID, err = bd.BCD(5); err != nil {
		return nil, err
	}

	if msg.TerminalType, err = bd.BCD(20); err != nil {
		return nil, err
	}

	if msg.TerminalID, err = bd.BCD(7); err != nil {
		return nil, err
	}

	return msg, nil
}

func DecodeAuthMsg(head *MsgHead, bd *BufDecoder) (*AuthMsg, error) {
	return &AuthMsg{AuthCode: "7777777"}, nil
}

func DecodeTerminalCommonRespBody(head *MsgHead, bd *BufDecoder) (*TerminalCommonRespBody, error) {
	msg := new(TerminalCommonRespBody)
	var err error
	if msg.FlowID, err = bd.Uint16(); err != nil {
		return nil, err
	}
	if msg.ResponseID, err = bd.Uint16(); err != nil {
		return nil, err
	}
	if msg.Result, err = bd.ReadByte(); err != nil {
		return nil, err
	}
	return nil, nil
}

const (
	// 终端通用应答
	MsgIdTerminalCommonResp uint16 = 0x0001
	// 终端心跳
	MsgIdTerminalHeartBeat uint16 = 0x0002
	// 终端注册
	MsgIdTerminalLogin uint16 = 0x0100
	// 终端注销
	MsgIdTerminalLogOut uint16 = 0x0003
	// 终端鉴权
	MsgIdTerminalAuthentication uint16 = 0x0102
	// 位置信息汇报
	MsgIdTerminalLocationInfoUpload uint16 = 0x0200
	// 胎压数据透传
	MsgIdTerminalTransmissionTyrePressure uint16 = 0x0600
	// 查询终端参数应答
	MsgIdTerminalParamQueryResp uint16 = 0x0104
)