From 4749a641514d86a7fd6b369e8d4467e253ca517f Mon Sep 17 00:00:00 2001
From: Anton Tananaev <anton.tananaev@gmail.com>
Date: Thu, 6 Aug 2015 15:55:08 +1200
Subject: Implement GVT-800 decoding (fix #1334)

---
 src/org/traccar/model/Event.java                   |   1 +
 src/org/traccar/protocol/ApelProtocolDecoder.java  |   2 +-
 .../traccar/protocol/MegastekProtocolDecoder.java  | 126 ++++++++++++++++++---
 .../traccar/protocol/ProgressProtocolDecoder.java  |   2 +-
 .../protocol/MegastekProtocolDecoderTest.java      |   3 +
 5 files changed, 117 insertions(+), 17 deletions(-)

diff --git a/src/org/traccar/model/Event.java b/src/org/traccar/model/Event.java
index fba5619d2..df9a9a8e5 100644
--- a/src/org/traccar/model/Event.java
+++ b/src/org/traccar/model/Event.java
@@ -77,6 +77,7 @@ public abstract class Event {
     public static final String KEY_FLAGS = "flags";
     public static final String KEY_CHARGE = "charge";
     public static final String KEY_IP = "ip";
+    public static final String KEY_ARCHIVE = "archive";
 
     // Starts with 1 not 0
     public static final String PREFIX_TEMP = "temp";
diff --git a/src/org/traccar/protocol/ApelProtocolDecoder.java b/src/org/traccar/protocol/ApelProtocolDecoder.java
index 6ce823a29..09c1a79f1 100644
--- a/src/org/traccar/protocol/ApelProtocolDecoder.java
+++ b/src/org/traccar/protocol/ApelProtocolDecoder.java
@@ -146,7 +146,7 @@ public class ApelProtocolDecoder extends BaseProtocolDecoder {
                 // Message index
                 int subtype = type;
                 if (type == MSG_TYPE_LOG_RECORDS) {
-                    position.set("archive", true);
+                    position.set(Event.KEY_ARCHIVE, true);
                     lastIndex = buf.readUnsignedInt() + 1;
                     position.set(Event.KEY_INDEX, lastIndex);
 
diff --git a/src/org/traccar/protocol/MegastekProtocolDecoder.java b/src/org/traccar/protocol/MegastekProtocolDecoder.java
index e35b75869..866e92465 100644
--- a/src/org/traccar/protocol/MegastekProtocolDecoder.java
+++ b/src/org/traccar/protocol/MegastekProtocolDecoder.java
@@ -22,7 +22,6 @@ import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 
 import org.jboss.netty.channel.Channel;
-import org.jboss.netty.channel.ChannelHandlerContext;
 
 import org.traccar.BaseProtocolDecoder;
 import org.traccar.model.Event;
@@ -127,13 +126,8 @@ public class MegastekProtocolDecoder extends BaseProtocolDecoder {
 
         return true;
     }
-    
-    @Override
-    protected Object decode(
-            Channel channel, SocketAddress remoteAddress, Object msg)
-            throws Exception {
 
-        String sentence = (String) msg;
+    private Position decodeOld(Channel channel, String sentence) {
 
         // Detect type
         boolean simple = (sentence.charAt(3) == ',' || sentence.charAt(6) == ',');
@@ -154,7 +148,7 @@ public class MegastekProtocolDecoder extends BaseProtocolDecoder {
 
             beginIndex = endIndex + 1;
             status = sentence.substring(beginIndex);
-        
+
         } else {
 
             int beginIndex = 3;
@@ -167,7 +161,7 @@ public class MegastekProtocolDecoder extends BaseProtocolDecoder {
 
             beginIndex = endIndex + 1;
             status = sentence.substring(beginIndex);
-        
+
         }
 
         // Create new position
@@ -178,7 +172,7 @@ public class MegastekProtocolDecoder extends BaseProtocolDecoder {
         if (!parseGPRMC(gprmc, position)) {
             return null;
         }
-        
+
         if (simple) {
 
             // Parse status
@@ -186,7 +180,7 @@ public class MegastekProtocolDecoder extends BaseProtocolDecoder {
             if (!parser.matches()) {
                 return null;
             }
-            
+
             int index = 1;
 
             // Alarm
@@ -221,7 +215,7 @@ public class MegastekProtocolDecoder extends BaseProtocolDecoder {
             position.set(Event.KEY_MCC, parser.group(index++));
             position.set(Event.KEY_MNC, parser.group(index++));
             position.set(Event.KEY_LAC, parser.group(index++));
-            
+
         } else {
 
             // Parse status
@@ -229,7 +223,7 @@ public class MegastekProtocolDecoder extends BaseProtocolDecoder {
             if (!parser.matches()) {
                 return null;
             }
-            
+
             int index = 1;
 
             if (!identify(id, channel)) {
@@ -244,7 +238,7 @@ public class MegastekProtocolDecoder extends BaseProtocolDecoder {
 
             // Battery
             position.set(Event.KEY_BATTERY, Double.valueOf(parser.group(index++)));
-            
+
             position.set(Event.KEY_FLAGS, parser.group(index++));
             position.set(Event.KEY_INPUT, parser.group(index++));
             position.set(Event.KEY_OUTPUT, parser.group(index++));
@@ -252,9 +246,111 @@ public class MegastekProtocolDecoder extends BaseProtocolDecoder {
             position.set(Event.PREFIX_ADC + 2, parser.group(index++));
             position.set(Event.PREFIX_ADC + 3, parser.group(index++));
             position.set(Event.KEY_ALARM, parser.group(index++));
-            
+
+        }
+
+        return position;
+    }
+
+    private static final Pattern patternNew = Pattern.compile(
+            "\\$MGV\\d{3}," +
+            "(\\d+)," +                    // IMEI
+            "[^,]*," +                     // Name
+            "([RS])," +
+            "(\\d{2})(\\d{2})(\\d{2})," +  // Date (DDMMYY)
+            "(\\d{2})(\\d{2})(\\d{2})," +  // Time (HHMMSS)
+            "([AV])," +                    // Validity
+            "(\\d+)(\\d{2}\\.\\d+)," +     // Latitude (DDMM.MMMM)
+            "([NS])," +
+            "(\\d+)(\\d{2}\\.\\d+)," +     // Longitude (DDDMM.MMMM)
+            "([EW])," +
+            "\\d{2}," +
+            "(\\d{2})," +                  // Satellites
+            "\\d{2}," +
+            "(\\d+\\.\\d+)," +             // HDOP
+            "(\\d+\\.\\d+)," +             // Speed
+            "(\\d+\\.\\d+)," +             // Course
+            "(\\d+\\.\\d+)," +             // Altitude
+            "(\\d+\\.\\d+)," +             // Odometer
+            ".*");
+
+    //$MGV002,013777007536434,,R,010114,000057,V,0000.0000,N,00000.0000,E,00,00,00,99.9,0.000,0.00,0.0,80.263,510,89,2342,030B,,0000,0000,200,96,0, , ,,,,Timer;!
+    //<data head><protocol version>,<device IMEI>,<device name>,
+    // <GPRS real-time/stored data flag>,<date>,<time>,<GPS fixed flag>,
+    // <latitude>,<N/S>,<longitude>,<W/E>,<used satellite number of BDS>,<used satellite number of GPS>,<used satellite number of GLONASS>,
+    // <HDOP>,<speed>,<course>,<altitude>,<mileage>,<MCC>,<MNC>,<LAC>,<Cell ID>,<GSM signal strength>,<digital input>,<digital output>,
+    // <analog input 1>,<analog input 2>,<analog input 3>,<temperature sensor 1>,<temperature sensor 2>,<RFID>,<external accessories status>,
+    // <battery level>,<alert event type>;<checksum><data tail>
+    private Position decodeNew(Channel channel, String sentence) {
+
+        Matcher parser = patternNew.matcher(sentence);
+        if (!parser.matches()) {
+            return null;
+        }
+        int index = 1;
+
+        Position position = new Position();
+        position.setProtocol(getProtocolName());
+
+        if (!identify(parser.group(index++), channel)) {
+            return null;
         }
+        position.setDeviceId(getDeviceId());
+
+        if (parser.group(index++).equals("S")) {
+            position.set(Event.KEY_ARCHIVE, true);
+        }
+
+        // Date and Time
+        Calendar time = Calendar.getInstance(TimeZone.getTimeZone("UTC"));
+        time.clear();
+        time.set(Calendar.DAY_OF_MONTH, Integer.valueOf(parser.group(index++)));
+        time.set(Calendar.MONTH, Integer.valueOf(parser.group(index++)) - 1);
+        time.set(Calendar.YEAR, 2000 + Integer.valueOf(parser.group(index++)));
+        time.set(Calendar.HOUR_OF_DAY, Integer.valueOf(parser.group(index++)));
+        time.set(Calendar.MINUTE, Integer.valueOf(parser.group(index++)));
+        time.set(Calendar.SECOND, Integer.valueOf(parser.group(index++)));
+        position.setTime(time.getTime());
+
+        // Validity
+        position.setValid(parser.group(index++).equals("A"));
+
+        // Latitude
+        double latitude = Double.valueOf(parser.group(index++));
+        latitude += Double.valueOf(parser.group(index++)) / 60;
+        if (parser.group(index++).equals("S")) latitude = -latitude;
+        position.setLatitude(latitude);
+
+        // Longitude
+        double longitude = Double.valueOf(parser.group(index++));
+        longitude += Double.valueOf(parser.group(index++)) / 60;
+        if (parser.group(index++).equals("W")) longitude = -longitude;
+        position.setLongitude(longitude);
+
+        position.set(Event.KEY_SATELLITES, Integer.parseInt(parser.group(index++)));
+        position.set(Event.KEY_HDOP, Double.parseDouble(parser.group(index++)));
+
+        position.setSpeed(Double.parseDouble(parser.group(index++)));
+        position.setCourse(Double.parseDouble(parser.group(index++)));
+        position.setAltitude(Double.parseDouble(parser.group(index++)));
+
+        position.set(Event.KEY_ODOMETER, Double.parseDouble(parser.group(index++)));
+
         return position;
     }
+    
+    @Override
+    protected Object decode(
+            Channel channel, SocketAddress remoteAddress, Object msg)
+            throws Exception {
+
+        String sentence = (String) msg;
+
+        if (sentence.startsWith("$MG")) {
+            return decodeNew(channel, sentence);
+        } else {
+            return decodeOld(channel, sentence);
+        }
+    }
 
 }
diff --git a/src/org/traccar/protocol/ProgressProtocolDecoder.java b/src/org/traccar/protocol/ProgressProtocolDecoder.java
index 8b57f52d0..8613a760b 100644
--- a/src/org/traccar/protocol/ProgressProtocolDecoder.java
+++ b/src/org/traccar/protocol/ProgressProtocolDecoder.java
@@ -101,7 +101,7 @@ public class ProgressProtocolDecoder extends BaseProtocolDecoder {
 
                 // Message index
                 if (type == MSG_LOGMSG) {
-                    position.set("archive", true);
+                    position.set(Event.KEY_ARCHIVE, true);
                     int subtype = buf.readUnsignedShort();
                     if (subtype == MSG_ALARM) {
                         position.set(Event.KEY_ALARM, true);
diff --git a/test/org/traccar/protocol/MegastekProtocolDecoderTest.java b/test/org/traccar/protocol/MegastekProtocolDecoderTest.java
index f6810558c..a9b7c4f0a 100644
--- a/test/org/traccar/protocol/MegastekProtocolDecoderTest.java
+++ b/test/org/traccar/protocol/MegastekProtocolDecoderTest.java
@@ -11,6 +11,9 @@ public class MegastekProtocolDecoderTest extends ProtocolDecoderTest {
 
         MegastekProtocolDecoder decoder = new MegastekProtocolDecoder(new MegastekProtocol());
 
+        verify(decoder.decode(null, null,
+                "$MGV002,013777007536434,,R,010114,000057,V,0000.0000,N,00000.0000,E,00,00,00,99.9,0.000,0.00,0.0,80.263,510,89,2342,030B,,0000,0000,200,96,0, , ,,,,Timer;!"));
+
         verify(decoder.decode(null, null,
                 "STX,GerAL22,$GPRMC,174752.000,A,3637.060059,S,6416.2354,W,0.00,0.00,030812,,,A*55,F,,imei:861785000249353,05,180.6,Battery=100%,,1,722,310,0FA6,39D0;8F"));
 
-- 
cgit v1.2.3