Support Ruptela extended format (fix #2460)

1 files changed, 22 insertions, 10 deletions

diff --git a/src/org/traccar/protocol/RuptelaProtocolDecoder.java b/src/org/traccar/protocol/RuptelaProtocolDecoder.java
index 224c027f3..84cc0e101 100644
--- a/src/org/traccar/protocol/RuptelaProtocolDecoder.java
+++ b/src/org/traccar/protocol/RuptelaProtocolDecoder.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2013 - 2014 Anton Tananaev (anton.tananaev@gmail.com)
+ * Copyright 2013 - 2016 Anton Tananaev (anton.tananaev@gmail.com)
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -35,6 +35,7 @@ public class RuptelaProtocolDecoder extends BaseProtocolDecoder {
     }
 
     public static final int MSG_RECORDS = 1;
+    public static final int MSG_EXTENDED_RECORDS = 68;
     public static final int MSG_SMS_VIA_GPRS = 108;
 
     @Override
@@ -53,7 +54,7 @@ public class RuptelaProtocolDecoder extends BaseProtocolDecoder {
 
         int type = buf.readUnsignedByte();
 
-        if (type == MSG_RECORDS) {
+        if (type == MSG_RECORDS || type == MSG_EXTENDED_RECORDS) {
             List<Position> positions = new LinkedList<>();
 
             buf.readUnsignedByte(); // records left
@@ -67,45 +68,56 @@ public class RuptelaProtocolDecoder extends BaseProtocolDecoder {
                 position.setTime(new Date(buf.readUnsignedInt() * 1000));
                 buf.readUnsignedByte(); // timestamp extension
 
+                if (type == MSG_EXTENDED_RECORDS) {
+                    buf.readUnsignedByte(); // record extension
+                }
+
                 buf.readUnsignedByte(); // priority (reserved)
 
+                position.setValid(true);
                 position.setLongitude(buf.readInt() / 10000000.0);
                 position.setLatitude(buf.readInt() / 10000000.0);
                 position.setAltitude(buf.readUnsignedShort() / 10.0);
                 position.setCourse(buf.readUnsignedShort() / 100.0);
 
-                int satellites = buf.readUnsignedByte();
-                position.set(Position.KEY_SATELLITES, satellites);
-                position.setValid(satellites >= 3);
+                position.set(Position.KEY_SATELLITES, buf.readUnsignedByte());
 
                 position.setSpeed(UnitsConverter.knotsFromKph(buf.readUnsignedShort()));
 
                 position.set(Position.KEY_HDOP, buf.readUnsignedByte() / 10.0);
 
-                buf.readUnsignedByte();
+                if (type == MSG_EXTENDED_RECORDS) {
+                    buf.readUnsignedShort(); // event
+                } else {
+                    buf.readUnsignedByte(); // event
+                }
 
                 // Read 1 byte data
                 int cnt = buf.readUnsignedByte();
                 for (int j = 0; j < cnt; j++) {
-                    position.set(Position.PREFIX_IO + buf.readUnsignedByte(), buf.readUnsignedByte());
+                    int id = type == MSG_EXTENDED_RECORDS ? buf.readUnsignedShort() : buf.readUnsignedByte();
+                    position.set(Position.PREFIX_IO + id, buf.readUnsignedByte());
                 }
 
                 // Read 2 byte data
                 cnt = buf.readUnsignedByte();
                 for (int j = 0; j < cnt; j++) {
-                    position.set(Position.PREFIX_IO + buf.readUnsignedByte(), buf.readUnsignedShort());
+                    int id = type == MSG_EXTENDED_RECORDS ? buf.readUnsignedShort() : buf.readUnsignedByte();
+                    position.set(Position.PREFIX_IO + id, buf.readUnsignedShort());
                 }
 
                 // Read 4 byte data
                 cnt = buf.readUnsignedByte();
                 for (int j = 0; j < cnt; j++) {
-                    position.set(Position.PREFIX_IO + buf.readUnsignedByte(), buf.readUnsignedInt());
+                    int id = type == MSG_EXTENDED_RECORDS ? buf.readUnsignedShort() : buf.readUnsignedByte();
+                    position.set(Position.PREFIX_IO + id, buf.readUnsignedInt());
                 }
 
                 // Read 8 byte data
                 cnt = buf.readUnsignedByte();
                 for (int j = 0; j < cnt; j++) {
-                    position.set(Position.PREFIX_IO + buf.readUnsignedByte(), buf.readLong());
+                    int id = type == MSG_EXTENDED_RECORDS ? buf.readUnsignedShort() : buf.readUnsignedByte();
+                    position.set(Position.PREFIX_IO + id, buf.readLong());
                 }
 
                 positions.add(position);