aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorAnton Tananaev <anton.tananaev@gmail.com>2015-09-25 11:00:38 +1200
committerAnton Tananaev <anton.tananaev@gmail.com>2015-09-25 11:10:02 +1200
commit5e97d2fd54ee9a29839f08501fc4e90088f896c9 (patch)
treeb09a318a0893348ceebd68f23509f9b76b585742 /src
parent187fae2778a6b072d0fbf325d50d5d5df9fd2f01 (diff)
downloadtraccar-server-5e97d2fd54ee9a29839f08501fc4e90088f896c9.tar.gz
traccar-server-5e97d2fd54ee9a29839f08501fc4e90088f896c9.tar.bz2
traccar-server-5e97d2fd54ee9a29839f08501fc4e90088f896c9.zip
Implement Flextrack protocol
Diffstat (limited to 'src')
-rw-r--r--src/org/traccar/protocol/FlextrackProtocol.java48
-rw-r--r--src/org/traccar/protocol/FlextrackProtocolDecoder.java167
2 files changed, 215 insertions, 0 deletions
diff --git a/src/org/traccar/protocol/FlextrackProtocol.java b/src/org/traccar/protocol/FlextrackProtocol.java
new file mode 100644
index 000000000..43e81dd5f
--- /dev/null
+++ b/src/org/traccar/protocol/FlextrackProtocol.java
@@ -0,0 +1,48 @@
+/*
+ * Copyright 2015 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.
+ * 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 org.jboss.netty.bootstrap.ServerBootstrap;
+import org.jboss.netty.channel.ChannelPipeline;
+import org.jboss.netty.handler.codec.frame.LineBasedFrameDecoder;
+import org.jboss.netty.handler.codec.string.StringDecoder;
+import org.jboss.netty.handler.codec.string.StringEncoder;
+import org.traccar.BaseProtocol;
+import org.traccar.CharacterDelimiterFrameDecoder;
+import org.traccar.TrackerServer;
+
+import java.util.List;
+
+public class FlextrackProtocol extends BaseProtocol {
+
+ public FlextrackProtocol() {
+ super("flextrack");
+ }
+
+ @Override
+ public void initTrackerServers(List<TrackerServer> serverList) {
+ serverList.add(new TrackerServer(new ServerBootstrap(), this.getName()) {
+ @Override
+ protected void addSpecificHandlers(ChannelPipeline pipeline) {
+ pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, "\r"));
+ pipeline.addLast("stringDecoder", new StringDecoder());
+ pipeline.addLast("stringEncoder", new StringEncoder());
+ pipeline.addLast("objectDecoder", new FlextrackProtocolDecoder(FlextrackProtocol.this));
+ }
+ });
+ }
+
+}
diff --git a/src/org/traccar/protocol/FlextrackProtocolDecoder.java b/src/org/traccar/protocol/FlextrackProtocolDecoder.java
new file mode 100644
index 000000000..e55324db4
--- /dev/null
+++ b/src/org/traccar/protocol/FlextrackProtocolDecoder.java
@@ -0,0 +1,167 @@
+/*
+ * Copyright 2015 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.
+ * 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 org.jboss.netty.channel.Channel;
+import org.traccar.BaseProtocolDecoder;
+import org.traccar.helper.Crc;
+import org.traccar.helper.PatternUtil;
+import org.traccar.helper.UnitsConverter;
+import org.traccar.model.Event;
+import org.traccar.model.Position;
+
+import java.net.SocketAddress;
+import java.util.Calendar;
+import java.util.TimeZone;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+public class FlextrackProtocolDecoder extends BaseProtocolDecoder {
+
+ public FlextrackProtocolDecoder(FlextrackProtocol protocol) {
+ super(protocol);
+ }
+
+ private static final Pattern patternLogon = Pattern.compile(
+ "(-?\\d+)," + // Index
+ "LOGON," +
+ "(\\d+)," + // Node ID
+ "(\\d+)"); // ICCID
+
+ private static final Pattern pattern = Pattern.compile(
+ "(-?\\d+)," + // Index
+ "UNITSTAT," +
+ "(\\d{4})(\\d{2})(\\d{2})," + // Date (YYYYMMDD)
+ "(\\d{2})(\\d{2})(\\d{2})," + // Time (HHMMSS)
+ "\\d+," + // Node ID
+ "([NS])(\\d+)\\.(\\d+\\.\\d+)," + // Longitude
+ "([EW])(\\d+)\\.(\\d+\\.\\d+)," + // Latitude
+ "(\\d+)," + // Speed
+ "(\\d+)," + // Course
+ "(\\d+)," + // Satellites
+ "(\\d+)," + // Battery
+ "(-?\\d+)," + // GSM
+ "(\\p{XDigit}+)," + // State
+ "(\\d{3})" + // MCC
+ "(\\d{2})," + // MNC
+ "(-?\\d+)," + // Altitude
+ "(\\d+)," + // HDOP
+ "(\\p{XDigit}+)," + // Cell
+ "\\d+," + // GPS fix time
+ "(\\d+)," + // LAC
+ "(\\d+)"); // Odometer
+
+ private void sendAcknowledgement(Channel channel, String index) {
+ if (channel != null) {
+ channel.write(index + ",ACK\r");
+ }
+ }
+
+ @Override
+ protected Object decode(
+ Channel channel, SocketAddress remoteAddress, Object msg)
+ throws Exception {
+
+ String sentence = (String) msg;
+
+ String x = PatternUtil.checkPattern(pattern.pattern(), sentence);
+
+ if (sentence.contains("LOGON")) {
+
+ Matcher parser = patternLogon.matcher(sentence);
+ if (parser.matches()) {
+ return null;
+ }
+
+ int index = 1;
+
+ sendAcknowledgement(channel, parser.group(index++));
+
+ String id = parser.group(index++);
+ String iccid = parser.group(index++);
+
+ if (!identify(iccid, channel, null, false)) {
+ if (!identify(id, channel)) {
+ return null;
+ }
+ }
+
+ } else if (sentence.contains("UNITSTAT")) {
+
+ Matcher parser = pattern.matcher(sentence);
+ if (!parser.matches()) {
+ return null;
+ }
+
+ Position position = new Position();
+ position.setProtocol(getProtocolName());
+ int index = 1;
+
+ sendAcknowledgement(channel, parser.group(index++));
+
+ // Time
+ Calendar time = Calendar.getInstance(TimeZone.getTimeZone("UTC"));
+ time.clear();
+ time.set(Calendar.YEAR, Integer.valueOf(parser.group(index++)));
+ time.set(Calendar.MONTH, Integer.valueOf(parser.group(index++)) - 1);
+ time.set(Calendar.DAY_OF_MONTH, 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());
+
+ // Latitude
+ String hemisphere = parser.group(index++);
+ double lat = Integer.parseInt(parser.group(index++));
+ lat += Double.parseDouble(parser.group(index++)) / 60;
+ if (hemisphere.equals("S")) {
+ lat = -lat;
+ }
+ position.setLatitude(lat);
+
+ // Longitude
+ hemisphere = parser.group(index++);
+ double lon = Integer.parseInt(parser.group(index++));
+ lon += Double.parseDouble(parser.group(index++)) / 60;
+ if (hemisphere.equals("W")) {
+ lon = -lon;
+ }
+ position.setLongitude(lon);
+
+ position.setSpeed(UnitsConverter.knotsFromKph(Integer.parseInt(parser.group(index++))));
+ position.setCourse(Integer.parseInt(parser.group(index++)));
+
+ position.set(Event.KEY_SATELLITES, Integer.parseInt(parser.group(index++)));
+ position.set(Event.KEY_BATTERY, Integer.parseInt(parser.group(index++)));
+ position.set(Event.KEY_GSM, Integer.parseInt(parser.group(index++)));
+ position.set(Event.KEY_STATUS, Integer.parseInt(parser.group(index++), 16));
+ position.set(Event.KEY_MCC, Integer.parseInt(parser.group(index++)));
+ position.set(Event.KEY_MNC, Integer.parseInt(parser.group(index++)));
+
+ position.setAltitude(Integer.parseInt(parser.group(index++)));
+
+ position.set(Event.KEY_HDOP, Integer.parseInt(parser.group(index++)) / 10.0);
+ position.set(Event.KEY_CELL, parser.group(index++));
+ position.set(Event.KEY_LAC, parser.group(index++));
+ position.set(Event.KEY_ODOMETER, Integer.parseInt(parser.group(index++)));
+
+ return position;
+ }
+
+ return null;
+ }
+
+}