diff options
author | Anton Tananaev <anton.tananaev@gmail.com> | 2014-12-30 15:38:35 +1300 |
---|---|---|
committer | Anton Tananaev <anton.tananaev@gmail.com> | 2014-12-30 15:38:35 +1300 |
commit | faeecdffcf78783ee030d0f9060e1f7656f9f707 (patch) | |
tree | 2d6ae3686a71afde0af11ff56b02b68062c2fe5a /src/org | |
parent | 2d7a970cc4b49f68b3fbb56d5903bb91b38f3798 (diff) | |
download | traccar-server-faeecdffcf78783ee030d0f9060e1f7656f9f707.tar.gz traccar-server-faeecdffcf78783ee030d0f9060e1f7656f9f707.tar.bz2 traccar-server-faeecdffcf78783ee030d0f9060e1f7656f9f707.zip |
Start Tramigo implementation
Diffstat (limited to 'src/org')
-rw-r--r-- | src/org/traccar/ServerManager.java | 16 | ||||
-rw-r--r-- | src/org/traccar/protocol/Gt02ProtocolDecoder.java | 1 | ||||
-rw-r--r-- | src/org/traccar/protocol/TramigoProtocolDecoder.java | 107 |
3 files changed, 124 insertions, 0 deletions
diff --git a/src/org/traccar/ServerManager.java b/src/org/traccar/ServerManager.java index 71b71975e..f6504fd27 100644 --- a/src/org/traccar/ServerManager.java +++ b/src/org/traccar/ServerManager.java @@ -177,6 +177,7 @@ public class ServerManager { initOrionServer("orion"); initRitiServer("riti"); initUlbotechServer("ulbotech"); + initTramigoServer("tramigo"); // Initialize web server if (Boolean.valueOf(properties.getProperty("http.enable"))) { @@ -1273,6 +1274,9 @@ public class ServerManager { } private void initUlbotechServer(final String protocol) throws SQLException { + + // TODO: Waiting for feedback from manufacturer + if (isProtocolEnabled(properties, protocol)) { serverList.add(new TrackerServer(this, new ServerBootstrap(), protocol) { @Override @@ -1284,4 +1288,16 @@ public class ServerManager { } } + private void initTramigoServer(final String protocol) throws SQLException { + if (isProtocolEnabled(properties, protocol)) { + serverList.add(new TrackerServer(this, new ServerBootstrap(), protocol) { + @Override + protected void addSpecificHandlers(ChannelPipeline pipeline) { + pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(1024, 6, 2, -8, 0)); + pipeline.addLast("objectDecoder", new TramigoProtocolDecoder(dataManager, protocol, properties)); + } + }); + } + } + } diff --git a/src/org/traccar/protocol/Gt02ProtocolDecoder.java b/src/org/traccar/protocol/Gt02ProtocolDecoder.java index 546f7dc56..3857766c7 100644 --- a/src/org/traccar/protocol/Gt02ProtocolDecoder.java +++ b/src/org/traccar/protocol/Gt02ProtocolDecoder.java @@ -88,6 +88,7 @@ public class Gt02ProtocolDecoder extends BaseProtocolDecoder { position.setDeviceId(getDataManager().getDeviceByImei(imei).getId()); } catch(Exception error) { Log.warning("Unknown device - " + imei); + return null; } // Date and time diff --git a/src/org/traccar/protocol/TramigoProtocolDecoder.java b/src/org/traccar/protocol/TramigoProtocolDecoder.java new file mode 100644 index 000000000..9bc8a5ae8 --- /dev/null +++ b/src/org/traccar/protocol/TramigoProtocolDecoder.java @@ -0,0 +1,107 @@ +/* + * Copyright 2014 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.buffer.ChannelBuffer; +import org.jboss.netty.channel.Channel; +import org.jboss.netty.channel.ChannelHandlerContext; +import org.traccar.BaseProtocolDecoder; +import org.traccar.database.DataManager; +import org.traccar.helper.Log; +import org.traccar.model.ExtendedInfoFormatter; +import org.traccar.model.Position; + +import java.util.Date; +import java.util.Properties; + +public class TramigoProtocolDecoder extends BaseProtocolDecoder { + + public TramigoProtocolDecoder(DataManager dataManager, String protocol, Properties properties) { + super(dataManager, protocol, properties); + } + + private static final int MSG_COMPACT = 0x0100; + private static final int MSG_FULL = 0x00FE; + + @Override + protected Object decode( + ChannelHandlerContext ctx, Channel channel, Object msg) + throws Exception { + + ChannelBuffer buf = (ChannelBuffer) msg; + + if (buf.readUnsignedByte() != 1) { + return null; // wrong protocol version + } + + buf.readUnsignedByte(); // version id + int index = buf.readUnsignedShort(); + int type = buf.readUnsignedShort(); + buf.readUnsignedShort(); // length + buf.readUnsignedShort(); // mask + buf.readUnsignedShort(); // checksum + long id = buf.readUnsignedInt(); + buf.readUnsignedInt(); // time + + if (type == MSG_COMPACT || type == MSG_FULL) { + + // Create new position + Position position = new Position(); + ExtendedInfoFormatter extendedInfo = new ExtendedInfoFormatter(getProtocol()); + extendedInfo.set("index", index); + + // Get device id + try { + position.setDeviceId(getDataManager().getDeviceByImei(String.valueOf(id)).getId()); + } catch(Exception error) { + Log.warning("Unknown device - " + id); + return null; + } + + buf.readUnsignedShort(); // report trigger + buf.readUnsignedShort(); // state flag + + position.setValid(true); + position.setLatitude(buf.readUnsignedInt() * 0.0000001); + position.setLongitude(buf.readUnsignedInt() * 0.0000001); + position.setAltitude(0.0); + + buf.readUnsignedShort(); // GSM signal quality + buf.readUnsignedShort(); // satellites in fix + buf.readUnsignedShort(); // satellites in track + buf.readUnsignedShort(); // GPS antenna state + + position.setSpeed(buf.readUnsignedShort() * 0.194384); + position.setCourse((double )buf.readUnsignedShort()); + + buf.readUnsignedInt(); // distance + + extendedInfo.set("battery", buf.readUnsignedShort()); + + buf.readUnsignedShort(); // battery charger status + + position.setTime(new Date(buf.readUnsignedInt() * 1000)); + + // TODO: parse other data + + position.setExtendedInfo(extendedInfo.toString()); + return position; + } + + return null; + } + +} |