From 4f90b2fcb6ad82ec6f5806da152447a38b406085 Mon Sep 17 00:00:00 2001 From: Anton Tananaev Date: Sat, 12 Jun 2021 15:14:15 -0700 Subject: Decode general information message --- .../org/traccar/protocol/UuxProtocolDecoder.java | 57 ++++++++++++++++++++-- 1 file changed, 53 insertions(+), 4 deletions(-) (limited to 'src/main/java/org/traccar/protocol') diff --git a/src/main/java/org/traccar/protocol/UuxProtocolDecoder.java b/src/main/java/org/traccar/protocol/UuxProtocolDecoder.java index cb8656545..28d5345b0 100644 --- a/src/main/java/org/traccar/protocol/UuxProtocolDecoder.java +++ b/src/main/java/org/traccar/protocol/UuxProtocolDecoder.java @@ -36,6 +36,7 @@ public class UuxProtocolDecoder extends BaseProtocolDecoder { super(protocol); } + public static final int MSG_GENERAL = 0x90; public static final int MSG_IMMOBILIZER = 0x9E; public static final int MSG_ACK = 0xD0; public static final int MSG_NACK = 0xF0; @@ -51,6 +52,14 @@ public class UuxProtocolDecoder extends BaseProtocolDecoder { } } + private int readInt(ByteBuf buf, int length) { + return Integer.parseInt(buf.readCharSequence(length, StandardCharsets.US_ASCII).toString()); + } + + private double readDouble(ByteBuf buf, int length) { + return Double.parseDouble(buf.readCharSequence(length, StandardCharsets.US_ASCII).toString()); + } + @Override protected Object decode( Channel channel, SocketAddress remoteAddress, Object msg) throws Exception { @@ -69,14 +78,54 @@ public class UuxProtocolDecoder extends BaseProtocolDecoder { return null; } - if (type == MSG_IMMOBILIZER) { + DateBuilder dateBuilder = new DateBuilder() + .setDate(Calendar.getInstance().get(Calendar.YEAR), buf.readUnsignedByte(), buf.readUnsignedByte()) + .setTime(buf.readUnsignedByte(), buf.readUnsignedByte(), buf.readUnsignedByte()); + + if (type == MSG_GENERAL) { Position position = new Position(getProtocolName()); position.setDeviceId(deviceSession.getDeviceId()); - DateBuilder dateBuilder = new DateBuilder() - .setDate(Calendar.getInstance().get(Calendar.YEAR), buf.readUnsignedByte(), buf.readUnsignedByte()) - .setTime(buf.readUnsignedByte(), buf.readUnsignedByte(), buf.readUnsignedByte()); + position.setTime(dateBuilder.getDate()); + + buf.skipBytes(10); // reason + buf.readUnsignedShort(); // flags + + buf.readUnsignedByte(); // position status + position.setValid(true); + + position.set(Position.KEY_SATELLITES, readInt(buf, 2)); + + double latitude = readInt(buf, 2); + latitude += readDouble(buf, 7); + position.setLatitude(buf.readUnsignedByte() == 'S' ? -latitude : latitude); + + double longitude = readInt(buf, 3); + longitude += readDouble(buf, 7); + position.setLongitude(buf.readUnsignedByte() == 'W' ? -longitude : longitude); + + position.setSpeed(readInt(buf, 3)); + position.setCourse(readInt(buf, 3)); + readInt(buf, 3); // alternative speed + + position.set(Position.KEY_ODOMETER, buf.readUnsignedByte() * 10000 + buf.readUnsignedByte() * 256 + + buf.readUnsignedByte() + buf.readUnsignedByte() * 0.1); + position.set(Position.KEY_HOURS, buf.readUnsignedInt()); + position.set(Position.KEY_RSSI, buf.readUnsignedByte()); + + position.set("companyId", buf.readCharSequence(6, StandardCharsets.US_ASCII).toString()); + + buf.skipBytes(10); // reason data + + position.set("tripId", buf.readUnsignedShort()); + + return position; + + } else if (type == MSG_IMMOBILIZER) { + + Position position = new Position(getProtocolName()); + position.setDeviceId(deviceSession.getDeviceId()); getLastLocation(position, dateBuilder.getDate()); -- cgit v1.2.3