Convert project to gradle

1 files changed, 184 insertions, 0 deletions

diff --git a/src/main/java/org/traccar/protocol/FreematicsProtocolDecoder.java b/src/main/java/org/traccar/protocol/FreematicsProtocolDecoder.java
new file mode 100644
index 000000000..ba47699c3
--- /dev/null
+++ b/src/main/java/org/traccar/protocol/FreematicsProtocolDecoder.java
@@ -0,0 +1,184 @@
+/*
+ * Copyright 2018 Anton Tananaev (anton@traccar.org)
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.traccar.protocol;
+
+import io.netty.channel.Channel;
+import org.traccar.BaseProtocolDecoder;
+import org.traccar.DeviceSession;
+import org.traccar.NetworkMessage;
+import org.traccar.Protocol;
+import org.traccar.helper.Checksum;
+import org.traccar.helper.DateBuilder;
+import org.traccar.helper.UnitsConverter;
+import org.traccar.model.Position;
+
+import java.net.SocketAddress;
+import java.util.Date;
+import java.util.LinkedList;
+import java.util.List;
+
+public class FreematicsProtocolDecoder extends BaseProtocolDecoder {
+
+    public FreematicsProtocolDecoder(Protocol protocol) {
+        super(protocol);
+    }
+
+    private Object decodeEvent(
+            Channel channel, SocketAddress remoteAddress, String sentence) {
+
+        DeviceSession deviceSession = null;
+        String event = null;
+        String time = null;
+
+        for (String pair : sentence.split(",")) {
+            String[] data = pair.split("=");
+            String key = data[0];
+            String value = data[1];
+            switch (key) {
+                case "ID":
+                case "VIN":
+                    if (deviceSession == null) {
+                        deviceSession = getDeviceSession(channel, remoteAddress, value);
+                    }
+                    break;
+                case "EV":
+                    event = value;
+                    break;
+                case "TS":
+                    time = value;
+                    break;
+                default:
+                    break;
+            }
+        }
+
+        if (channel != null && deviceSession != null && event != null && time != null) {
+            String message = String.format("1#EV=%s,RX=1,TS=%s", event, time);
+            message += '*' + Checksum.sum(message);
+            channel.writeAndFlush(new NetworkMessage(message, remoteAddress));
+        }
+
+        return null;
+    }
+
+    private Object decodePosition(
+            Channel channel, SocketAddress remoteAddress, String sentence) throws Exception {
+
+        DeviceSession deviceSession = getDeviceSession(channel, remoteAddress);
+        if (deviceSession == null) {
+            return null;
+        }
+
+        List<Position> positions = new LinkedList<>();
+        Position position = null;
+        DateBuilder dateBuilder = null;
+
+        for (String pair : sentence.split(",")) {
+            String[] data = pair.split("[=:]");
+            int key = Integer.parseInt(data[0], 16);
+            String value = data[1];
+            switch (key) {
+                case 0x0:
+                    if (position != null) {
+                        position.setTime(dateBuilder.getDate());
+                        positions.add(position);
+                    }
+                    position = new Position(getProtocolName());
+                    position.setDeviceId(deviceSession.getDeviceId());
+                    position.setValid(true);
+                    dateBuilder = new DateBuilder(new Date());
+                    break;
+                case 0x11:
+                    value = ("000000" + value).substring(value.length());
+                    dateBuilder.setDateReverse(
+                            Integer.parseInt(value.substring(0, 2)),
+                            Integer.parseInt(value.substring(2, 4)),
+                            Integer.parseInt(value.substring(4)));
+                    break;
+                case 0x10:
+                    value = ("00000000" + value).substring(value.length());
+                    dateBuilder.setTime(
+                            Integer.parseInt(value.substring(0, 2)),
+                            Integer.parseInt(value.substring(2, 4)),
+                            Integer.parseInt(value.substring(4, 6)),
+                            Integer.parseInt(value.substring(6)) * 10);
+                    break;
+                case 0xA:
+                    position.setLatitude(Double.parseDouble(value));
+                    break;
+                case 0xB:
+                    position.setLongitude(Double.parseDouble(value));
+                    break;
+                case 0xC:
+                    position.setAltitude(Double.parseDouble(value));
+                    break;
+                case 0xD:
+                    position.setSpeed(UnitsConverter.knotsFromKph(Double.parseDouble(value)));
+                    break;
+                case 0xE:
+                    position.setCourse(Integer.parseInt(value));
+                    break;
+                case 0xF:
+                    position.set(Position.KEY_SATELLITES, Integer.parseInt(value));
+                    break;
+                case 0x20:
+                    position.set(Position.KEY_ACCELERATION, value);
+                    break;
+                case 0x24:
+                    position.set(Position.KEY_BATTERY, Integer.parseInt(value) * 0.01);
+                    break;
+                case 0x81:
+                    position.set(Position.KEY_RSSI, Integer.parseInt(value));
+                    break;
+                case 0x82:
+                    position.set(Position.KEY_DEVICE_TEMP, Integer.parseInt(value) * 0.1);
+                    break;
+                default:
+                    position.set(data[0], value);
+                    break;
+            }
+        }
+
+        if (position != null) {
+            position.setTime(dateBuilder.getDate());
+            positions.add(position);
+        }
+
+        return positions;
+    }
+
+    @Override
+    protected Object decode(
+            Channel channel, SocketAddress remoteAddress, Object msg) throws Exception {
+
+        String sentence = (String) msg;
+        int startIndex = sentence.indexOf('#');
+        int endIndex = sentence.indexOf('*');
+
+        if (startIndex > 0 && endIndex > 0) {
+            sentence = sentence.substring(startIndex + 1, endIndex);
+
+            if (sentence.startsWith("EV")) {
+                return decodeEvent(channel, remoteAddress, sentence);
+            } else {
+                return decodePosition(channel, remoteAddress, sentence);
+            }
+        }
+
+        return null;
+    }
+
+}