package org.yzh.client;
|
|
import org.yzh.client.netty.ClientConfig;
|
import org.yzh.client.netty.HandlerMapping;
|
import org.yzh.client.netty.TCPClient;
|
import org.yzh.commons.util.DateUtils;
|
import org.yzh.commons.util.StrUtils;
|
import org.yzh.protocol.codec.JTMessageAdapter;
|
import org.yzh.protocol.commons.JT808;
|
import org.yzh.protocol.commons.transform.attribute.AlarmADAS;
|
import org.yzh.protocol.commons.transform.attribute.AlarmBSD;
|
import org.yzh.protocol.commons.transform.attribute.AlarmDSM;
|
import org.yzh.protocol.commons.transform.attribute.AlarmTPMS;
|
import org.yzh.protocol.t808.T0100;
|
import org.yzh.protocol.t808.T0200;
|
|
import java.time.LocalDateTime;
|
import java.util.Map;
|
import java.util.TreeMap;
|
import java.util.concurrent.ThreadLocalRandom;
|
|
public class ClientTest {
|
|
public static final JTMessageAdapter messageAdapter = new JTMessageAdapter("org.yzh.protocol");
|
|
public static final ClientConfig jtConfig = new ClientConfig.Builder()
|
.setIp("127.0.0.1")
|
.setPort(7000)
|
.setMaxFrameLength(2 + 21 + 1023 * 2 + 1 + 2)
|
.setDelimiters(new byte[]{0x7e})
|
.setDecoder(messageAdapter)
|
.setEncoder(messageAdapter)
|
.setHandlerMapping(new HandlerMapping("org.yzh.client"))
|
.build();
|
|
public static void main(String[] args) {
|
TCPClient tcpClient = new TCPClient("0", jtConfig).start();
|
tcpClient.writeObject(T0100("1"));
|
for (int i = 0; i < 1; i++) {
|
try {
|
Thread.sleep(3000L);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
boolean alarm = i % 10 == 0;
|
tcpClient.writeObject(T0200("1", true));
|
}
|
}
|
|
public static T0100 T0100(String id) {
|
String deviceId = "T" + StrUtils.leftPad(id, 6, '0');
|
String clientId = "1" + StrUtils.leftPad(id, 10, '0');
|
String plateNo = "测A" + StrUtils.leftPad(id, 5, '0');
|
|
T0100 message = new T0100();
|
message.setMessageId(JT808.终端注册);
|
message.setProtocolVersion(1);
|
message.setVersion(true);
|
message.setClientId(clientId);
|
|
message.setProvinceId(31);
|
message.setCityId(115);
|
message.setMakerId("yzh");
|
message.setDeviceModel("www.jtt808.cn");
|
message.setDeviceId(deviceId);
|
message.setPlateColor(1);
|
message.setPlateNo(plateNo);
|
return message;
|
}
|
|
private static ThreadLocalRandom random = ThreadLocalRandom.current();
|
|
public static T0200 T0200(String id) {
|
return T0200(id, true);
|
}
|
|
public static T0200 T0200(String id, boolean alarm) {
|
String clientId = "1" + StrUtils.leftPad(id, 10, '0');
|
|
T0200 message = new T0200();
|
message.setMessageId(JT808.位置信息汇报);
|
message.setProtocolVersion(1);
|
message.setVersion(true);
|
message.setClientId(clientId);
|
|
message.setWarnBit(1024);
|
message.setStatusBit(2048);
|
message.setLatitude(39915931);
|
message.setLongitude(116403829);
|
message.setAltitude(312);
|
message.setSpeed(111);
|
message.setDirection(99);
|
LocalDateTime dateTime = LocalDateTime.now();
|
message.setDeviceTime(dateTime);
|
|
if (alarm) {
|
AlarmADAS alarmADAS = new AlarmADAS();
|
alarmADAS.setId(64);
|
alarmADAS.setState(1);
|
//alarmADAS.setType(random.nextInt(1, 11));
|
alarmADAS.setType(6);
|
alarmADAS.setLevel(1);
|
alarmADAS.setFrontSpeed(10);
|
alarmADAS.setFrontDistance(10);
|
alarmADAS.setDeviateType(1);
|
alarmADAS.setRoadSign(1);
|
alarmADAS.setRoadSignValue(10);
|
alarmADAS.setSpeed(10);
|
alarmADAS.setAltitude(100);
|
alarmADAS.setLatitude(32111111);
|
alarmADAS.setLongitude(123111111);
|
alarmADAS.setAlarmTime(dateTime);
|
alarmADAS.setStatusBit(1);
|
alarmADAS.setDeviceId(clientId);
|
alarmADAS.setDateTime(dateTime);
|
alarmADAS.setSequenceNo(1);
|
alarmADAS.setFileTotal(1);
|
alarmADAS.setReserved(1);
|
|
AlarmDSM alarmDSM = new AlarmDSM();
|
alarmDSM.setId(65);
|
alarmDSM.setState(2);
|
// alarmADAS.setType(random.nextInt(1, 11));
|
alarmADAS.setType(5);
|
alarmDSM.setLevel(2);
|
alarmDSM.setFatigueDegree(20);
|
alarmDSM.setReserved(20);
|
alarmDSM.setSpeed(20);
|
alarmDSM.setAltitude(200);
|
alarmDSM.setLatitude(32222222);
|
alarmDSM.setLongitude(123222222);
|
alarmDSM.setAlarmTime(dateTime);
|
alarmDSM.setStatusBit(2);
|
alarmDSM.setDeviceId(clientId);
|
alarmDSM.setDateTime(dateTime);
|
alarmDSM.setSequenceNo(2);
|
alarmDSM.setFileTotal(2);
|
alarmDSM.setReserved(2);
|
|
AlarmTPMS alarmTPMS = new AlarmTPMS();
|
alarmTPMS.setId(66);
|
alarmTPMS.setState(3);
|
alarmTPMS.setSpeed(30);
|
alarmTPMS.setAltitude(300);
|
alarmTPMS.setLatitude(32333333);
|
alarmTPMS.setLongitude(123333333);
|
alarmTPMS.setAlarmTime(dateTime);
|
alarmTPMS.setStatusBit(3);
|
alarmTPMS.setDeviceId(clientId);
|
alarmTPMS.setDateTime(dateTime);
|
alarmTPMS.setSequenceNo(3);
|
alarmTPMS.setFileTotal(3);
|
alarmTPMS.setReserved(3);
|
|
AlarmBSD alarmBSD = new AlarmBSD();
|
alarmBSD.setId(67);
|
alarmBSD.setState(4);
|
alarmBSD.setType(random.nextInt(1, 3));
|
alarmBSD.setSpeed(40);
|
alarmBSD.setAltitude(400);
|
alarmBSD.setLatitude(32444444);
|
alarmBSD.setLongitude(123444444);
|
alarmBSD.setAlarmTime(dateTime);
|
alarmBSD.setStatusBit(4);
|
alarmBSD.setDeviceId(clientId);
|
alarmBSD.setDateTime(dateTime);
|
alarmBSD.setSequenceNo(4);
|
alarmBSD.setFileTotal(4);
|
alarmBSD.setReserved(4);
|
|
|
Map<Integer, Object> attributes = new TreeMap<>();
|
// attributes.put(AlarmADAS.key, alarmADAS);
|
attributes.put(AlarmDSM.key, alarmDSM);
|
// attributes.put(AlarmTPMS.key, alarmTPMS);
|
// attributes.put(AlarmBSD.key, alarmBSD);
|
|
message.setAttributes(attributes);
|
}
|
return message;
|
}
|
}
|
