From 985c3a324a566f803ec83658680974a7f75b0b7d Mon Sep 17 00:00:00 2001
From: Anton Tananaev <anton.tananaev@gmail.com>
Date: Sun, 10 Nov 2019 17:15:19 -0800
Subject: Extend Plugin protocol support

---
 .../traccar/protocol/PluginProtocolDecoder.java    | 54 ++++++++++++++++++++--
 .../protocol/PluginProtocolDecoderTest.java        |  5 ++
 2 files changed, 55 insertions(+), 4 deletions(-)

diff --git a/src/main/java/org/traccar/protocol/PluginProtocolDecoder.java b/src/main/java/org/traccar/protocol/PluginProtocolDecoder.java
index b5d71854b..949c994ee 100644
--- a/src/main/java/org/traccar/protocol/PluginProtocolDecoder.java
+++ b/src/main/java/org/traccar/protocol/PluginProtocolDecoder.java
@@ -19,6 +19,7 @@ import io.netty.channel.Channel;
 import org.traccar.BaseProtocolDecoder;
 import org.traccar.DeviceSession;
 import org.traccar.Protocol;
+import org.traccar.helper.BitUtil;
 import org.traccar.helper.Parser;
 import org.traccar.helper.PatternBuilder;
 import org.traccar.helper.UnitsConverter;
@@ -47,10 +48,23 @@ public class PluginProtocolDecoder extends BaseProtocolDecoder {
             .number("d+,")                       // type
             .number("(d+.?d*),")                 // odometer
             .number("(d+),")                     // status
-            .expression("[^,]*,")
+            .number("(d+.?d*),")                 // fuel
             .expression("[^,]*,")
             .text("0")
             .groupBegin()
+            .number(",(-?d+.?d*)")               // temperature 1
+            .number(",(-?d+.?d*)")               // temperature 2
+            .number(",d+")                       // oil level
+            .number(",(d+)")                     // rpm
+            .number(",(d+)")                     // obd speed
+            .number(",d+")                       // people up
+            .number(",d+")                       // people down
+            .number(",d+")                       // obd status
+            .number(",d+")                       // fuel intake air temperature
+            .number(",(d+)")                     // throttle
+            .number(",(d+)")                     // battery
+            .groupEnd("?")
+            .groupBegin()
             .text(",+,")
             .number("(d+),")                     // event
             .groupEnd("?")
@@ -74,7 +88,6 @@ public class PluginProtocolDecoder extends BaseProtocolDecoder {
         Position position = new Position(getProtocolName());
         position.setDeviceId(deviceSession.getDeviceId());
 
-        position.setValid(true);
         position.setTime(parser.nextDateTime());
         position.setLongitude(parser.nextDouble());
         position.setLatitude(parser.nextDouble());
@@ -84,8 +97,41 @@ public class PluginProtocolDecoder extends BaseProtocolDecoder {
 
         position.set(Position.KEY_SATELLITES, parser.nextInt());
         position.set(Position.KEY_ODOMETER, (long) (parser.nextDouble() * 1000));
-        position.set(Position.KEY_STATUS, parser.nextInt());
-        position.set(Position.KEY_EVENT, parser.nextInt());
+
+        int status = parser.nextInt();
+        position.setValid(BitUtil.check(status, 0));
+        position.set(Position.KEY_IGNITION, BitUtil.check(status, 1));
+        for (int i = 0; i < 4; i++) {
+            position.set(Position.PREFIX_IN + (i + 1), BitUtil.check(status, 20 + i));
+        }
+        position.set(Position.KEY_STATUS, status);
+
+        position.set(Position.KEY_FUEL_LEVEL, parser.nextDouble());
+
+        if (parser.hasNext(6)) {
+            position.set(Position.PREFIX_TEMP + 1, parser.nextDouble());
+            position.set(Position.PREFIX_TEMP + 2, parser.nextDouble());
+            position.set(Position.KEY_RPM, parser.nextInt());
+            position.set(Position.KEY_OBD_SPEED, parser.nextInt());
+            position.set(Position.KEY_THROTTLE, parser.nextInt() * 0.1);
+            position.set(Position.KEY_POWER, parser.nextInt() * 0.1);
+        }
+
+        if (parser.hasNext()) {
+            int event = parser.nextInt();
+            switch (event) {
+                case 11317:
+                    position.set(Position.KEY_ALARM, Position.ALARM_ACCELERATION);
+                    break;
+                case 11319:
+                    position.set(Position.KEY_ALARM, Position.ALARM_BRAKING);
+                    break;
+                default:
+                    break;
+
+            }
+            position.set(Position.KEY_EVENT, event);
+        }
 
         return position;
     }
diff --git a/src/test/java/org/traccar/protocol/PluginProtocolDecoderTest.java b/src/test/java/org/traccar/protocol/PluginProtocolDecoderTest.java
index d5c5a3b78..0fe3a3a01 100644
--- a/src/test/java/org/traccar/protocol/PluginProtocolDecoderTest.java
+++ b/src/test/java/org/traccar/protocol/PluginProtocolDecoderTest.java
@@ -2,6 +2,7 @@ package org.traccar.protocol;
 
 import org.junit.Test;
 import org.traccar.ProtocolTest;
+import org.traccar.model.Position;
 
 public class PluginProtocolDecoderTest extends ProtocolTest {
 
@@ -10,6 +11,10 @@ public class PluginProtocolDecoderTest extends ProtocolTest {
 
         PluginProtocolDecoder decoder = new PluginProtocolDecoder(null);
 
+        verifyAttribute(decoder, text(
+                "$$STATUS,60925,20190829123115,28.254151,-25.860605,0.0,0,0,-1,2,0.000,13699,0.00,0,0,28.4,23.4,0,0,0,0,0,0,0,0,0"),
+                Position.PREFIX_TEMP + 1, 28.4);
+
         verifyPosition(decoder, text(
                 "$$STATUS,60550,20191014084650,28.254258,-25.860355,0.0,236,0,-1,2,7472.967,13697,0.00,0,0,0.0,0.0,0,0,0,0,0,0,0,0,0"));
 
-- 
cgit v1.2.3