ZteitsCmdProcess.java
3.3 KB
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
package com.zteits.nbiot.decoder;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.node.ObjectNode;
import java.util.Arrays;
import java.util.Date;
public class ZteitsCmdProcess {
private String msgType = "cloudRsp";
private String serviceId = "VehicleDetectorInfo";
private String cmd = "SET_DEVICE_LEVEL";
private int hasMore = 1;
//请求处理的结果码,0表示成功，1表示失败
private int errcode = 1;
private int mid = 0;
private byte[] requests;
private JsonNode paras;
public ZteitsCmdProcess() {
}
public ZteitsCmdProcess(ObjectNode input) {
try {
this.msgType = input.get("msgType").asText();
this.requests = input.get("request").binaryValue();
/*
平台收到设备上报消息，编码ACK
{
"msgType":"cloudRsp",
"request": ***,//设备上报的码流
"errcode":0,
"hasMore":0
}
* */
if (msgType.equals("cloudRsp")) {
//在此组装ACK的值
this.errcode = input.get("errcode").asInt();
this.hasMore = input.get("hasMore").asInt();
}
} catch (Exception e) {
this.errcode = 1;
e.printStackTrace();
}
}
public byte[] toByte() {
try {
/*
平台收到设备的上报数据，根据需要编码ACK，对设备进行响应，如果此处返回null，表示不需要对设备响应。
* */
if (this.msgType.equals("cloudRsp")) {
byte[] ack = new byte[28];
ack[0] = (byte) 0x77;
ack[1] = (byte)0x00;
//请求处理的结果码。
//0表示成功，1表示失败
if(errcode == 0){
ack[2] = (byte)0x70;
}else if(errcode == 1){
ack[2] = (byte)0x30;
}
//packCount 2H
ack[3] = requests[18];
ack[4] = requests[19];
//magId 4H
ack[5] = requests[22];
ack[6] = requests[23];
ack[7] = requests[24];
ack[8] = requests[25];
//command 2H
ack[9] = (byte)0x00;
ack[10] = (byte)0x00;
//时间8H
ack[11] = (byte)0x00;
ack[12] = (byte)0x00;
ack[13] = (byte)0x00;
ack[14] = (byte)0x00;
Long time = new Date().getTime()/1000;
byte[] timeByte = Utilty.int2Bytes(time.intValue(), 4);
ack[15] = timeByte[0];
ack[16] = timeByte[1];
ack[17] = timeByte[2];
ack[18] = timeByte[3];
ack[19] = (byte)errcode;
ack[20] = (byte)0x00;
ack[21] = (byte)0x00;
ack[22] = (byte)0x00;
ack[23] = (byte)0x00;
ack[24] = (byte)0x00;
ack[25] = (byte)0x00;
return CRC16Util.appendCrc16(ack);
}
return null;
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
}