Implement full Ulbotech protocol

1 files changed, 69 insertions, 1 deletions

diff --git a/src/org/traccar/protocol/UlbotechProtocolDecoder.java b/src/org/traccar/protocol/UlbotechProtocolDecoder.java
index 9c08264b5..b44e1d850 100644
--- a/src/org/traccar/protocol/UlbotechProtocolDecoder.java
+++ b/src/org/traccar/protocol/UlbotechProtocolDecoder.java
@@ -16,8 +16,10 @@
 package org.traccar.protocol;
 
 import java.net.SocketAddress;
+import java.nio.charset.Charset;
 import java.util.Date;
 import org.jboss.netty.buffer.ChannelBuffer;
+import org.jboss.netty.buffer.ChannelBuffers;
 import org.jboss.netty.channel.Channel;
 import org.traccar.BaseProtocolDecoder;
 import org.traccar.Context;
@@ -47,6 +49,10 @@ public class UlbotechProtocolDecoder extends BaseProtocolDecoder {
     private static final short DATA_OBD2_ALARM = 0x09;
     private static final short DATA_HARSH_DRIVER = 0x0A;
     private static final short DATA_CANBUS = 0x0B;
+    private static final short DATA_J1708 = 0x0C;
+    private static final short DATA_VIN = 0x0D;
+    private static final short DATA_RFID = 0x0E;
+    private static final short DATA_EVENT = 0x10;
 
     @Override
     protected Object decode(
@@ -95,11 +101,73 @@ public class UlbotechProtocolDecoder extends BaseProtocolDecoder {
                     position.set(Event.KEY_HDOP, buf.readUnsignedShort());
                     break;
 
+                case DATA_LBS:
+                    position.set(Event.KEY_MCC, buf.readUnsignedShort());
+                    position.set(Event.KEY_MNC, buf.readUnsignedByte());
+                    position.set(Event.KEY_LAC, buf.readUnsignedShort());
+                    position.set(Event.KEY_CELL, buf.readUnsignedShort());
+                    position.set(Event.KEY_GSM, -buf.readUnsignedByte());
+                    break;
+
                 case DATA_STATUS:
                     int status = buf.readUnsignedShort();
                     position.set(Event.KEY_IGNITION, BitUtil.check(status, 6));
+                    position.set(Event.KEY_STATUS, status);
+                    position.set(Event.KEY_ALARM, buf.readUnsignedShort());
+                    break;
+
+                case DATA_ODOMETER:
+                    position.set(Event.KEY_ODOMETER, buf.readUnsignedInt());
+                    break;
+
+                case DATA_ADC:
+                    for (int i = 0; i < length / 2; i++) {
+                        int value = buf.readUnsignedShort();
+                        position.set(Event.PREFIX_ADC + BitUtil.range(value, 12), BitUtil.range(value, 0, 12));
+                    }
+                    break;
+
+                case DATA_GEOFENCE:
+                    position.set("geofence-in", buf.readUnsignedInt());
+                    position.set("geofence-alarm", buf.readUnsignedInt());
+                    break;
+
+                case DATA_OBD2:
+                    position.set("obd", ChannelBuffers.hexDump(buf.readBytes(length)));
+                    break;
+
+                case DATA_FUEL:
+                    position.set("fuel-consumption", buf.readUnsignedInt() / 10000.0);
+                    break;
+
+                case DATA_OBD2_ALARM:
+                    position.set("obd-alarm", ChannelBuffers.hexDump(buf.readBytes(length)));
+                    break;
+
+                case DATA_HARSH_DRIVER:
+                    position.set("driver-behavior", buf.readUnsignedByte());
+                    break;
+
+                case DATA_CANBUS:
+                    position.set("can", ChannelBuffers.hexDump(buf.readBytes(length)));
+                    break;
+
+                case DATA_J1708:
+                    position.set("j1708", ChannelBuffers.hexDump(buf.readBytes(length)));
+                    break;
+
+                case DATA_VIN:
+                    position.set("vin", buf.readBytes(length).toString(Charset.defaultCharset()));
+                    break;
+
+                case DATA_RFID:
+                    position.set(Event.KEY_RFID, buf.readBytes(length - 1).toString(Charset.defaultCharset()));
+                    position.set("authorized", buf.readUnsignedByte() != 0);
+                    break;
 
-                    buf.readUnsignedShort(); // alarm
+                case DATA_EVENT:
+                    position.set(Event.KEY_EVENT, buf.readUnsignedByte());
+                    position.set("event-mask", buf.readUnsignedInt());
                     break;
 
                 default: