aboutsummaryrefslogtreecommitdiff
path: root/src/org
diff options
context:
space:
mode:
authorAnton Tananaev <anton.tananaev@gmail.com>2013-01-09 20:21:30 +1300
committerAnton Tananaev <anton.tananaev@gmail.com>2013-01-09 20:21:30 +1300
commit3c93192e8a2a392fe9ddf7bdcd512a7d6cceb3a9 (patch)
treeefe13db5bd9939b36ad104d4445e8d006efab7ca /src/org
parenta7100fa9749a343a77c747a2cca8ae9e2faf91cb (diff)
downloadtraccar-server-3c93192e8a2a392fe9ddf7bdcd512a7d6cceb3a9.tar.gz
traccar-server-3c93192e8a2a392fe9ddf7bdcd512a7d6cceb3a9.tar.bz2
traccar-server-3c93192e8a2a392fe9ddf7bdcd512a7d6cceb3a9.zip
Fix GT06 protocol
Diffstat (limited to 'src/org')
-rw-r--r--src/org/traccar/protocol/Gps103ProtocolDecoder.java3
-rw-r--r--src/org/traccar/protocol/Gt06ProtocolDecoder.java36
2 files changed, 20 insertions, 19 deletions
diff --git a/src/org/traccar/protocol/Gps103ProtocolDecoder.java b/src/org/traccar/protocol/Gps103ProtocolDecoder.java
index 9c9f56b2f..935697c51 100644
--- a/src/org/traccar/protocol/Gps103ProtocolDecoder.java
+++ b/src/org/traccar/protocol/Gps103ProtocolDecoder.java
@@ -61,6 +61,7 @@ public class Gps103ProtocolDecoder extends GenericProtocolDecoder {
/**
* Decode message
*/
+ @Override
protected Object decode(
ChannelHandlerContext ctx, Channel channel, Object msg)
throws Exception {
@@ -143,7 +144,7 @@ public class Gps103ProtocolDecoder extends GenericProtocolDecoder {
// Speed
position.setSpeed(Double.valueOf(parser.group(index++)));
-
+
// Course
String course = parser.group(index++);
if (course != null) {
diff --git a/src/org/traccar/protocol/Gt06ProtocolDecoder.java b/src/org/traccar/protocol/Gt06ProtocolDecoder.java
index 1daf6c4ec..0005df19b 100644
--- a/src/org/traccar/protocol/Gt06ProtocolDecoder.java
+++ b/src/org/traccar/protocol/Gt06ProtocolDecoder.java
@@ -31,7 +31,7 @@ import org.traccar.model.Position;
* T55 tracker protocol decoder
*/
public class Gt06ProtocolDecoder extends GenericProtocolDecoder {
-
+
private Long deviceId;
/**
@@ -40,7 +40,7 @@ public class Gt06ProtocolDecoder extends GenericProtocolDecoder {
public Gt06ProtocolDecoder(DataManager dataManager) {
super(dataManager);
}
-
+
private String readImei(ChannelBuffer buf) {
int b = buf.readUnsignedByte();
StringBuilder imei = new StringBuilder();
@@ -58,9 +58,9 @@ public class Gt06ProtocolDecoder extends GenericProtocolDecoder {
private static final int MSG_HEARTBEAT = 0x13;
private static final int MSG_STRING = 0x15;
private static final int MSG_ALARM = 0x16;
-
+
private static void sendResponse(Channel channel, int type, int index) {
- if (channel == null) {
+ if (channel != null) {
ChannelBuffer response = ChannelBuffers.directBuffer(10);
response.writeByte(0x78); response.writeByte(0x78); // header
response.writeByte(0x05); // size
@@ -71,7 +71,7 @@ public class Gt06ProtocolDecoder extends GenericProtocolDecoder {
channel.write(response);
}
}
-
+
/**
* Decode message
*/
@@ -81,12 +81,12 @@ public class Gt06ProtocolDecoder extends GenericProtocolDecoder {
throws Exception {
ChannelBuffer buf = (ChannelBuffer) msg;
-
+
buf.skipBytes(2); // header
buf.readByte(); // size
-
+
int type = buf.readUnsignedByte();
-
+
if (type == MSG_LOGIN) {
String imei = readImei(buf);
try {
@@ -96,18 +96,18 @@ public class Gt06ProtocolDecoder extends GenericProtocolDecoder {
Log.warning("Unknown device - " + imei);
}
}
-
+
else if (type == MSG_HEARTBEAT) {
buf.skipBytes(5);
sendResponse(channel, type, buf.readUnsignedShort());
}
-
+
else if (type == MSG_DATA) {
// Create new position
Position position = new Position();
position.setDeviceId(deviceId);
StringBuilder extendedInfo = new StringBuilder("<protocol>gt06</protocol>");
-
+
// Date and time
Calendar time = Calendar.getInstance(TimeZone.getTimeZone("UTC"));
time.clear();
@@ -118,18 +118,18 @@ public class Gt06ProtocolDecoder extends GenericProtocolDecoder {
time.set(Calendar.MINUTE, buf.readUnsignedByte());
time.set(Calendar.SECOND, buf.readUnsignedByte());
position.setTime(time.getTime());
-
+
// Satellites count
extendedInfo.append("<satellites>");
extendedInfo.append(buf.readUnsignedByte());
extendedInfo.append("</satellites>");
-
+
// Latitude
double latitude = buf.readUnsignedInt() / (60.0 * 30000.0);
-
+
// Longitude
double longitude = buf.readUnsignedInt() / (60.0 * 30000.0);
-
+
// Speed
position.setSpeed((double) buf.readUnsignedByte());
@@ -139,11 +139,11 @@ public class Gt06ProtocolDecoder extends GenericProtocolDecoder {
position.setValid((union & 0x1000) != 0);
if ((union & 0x0400) == 0) latitude = -latitude;
if ((union & 0x0800) == 0) longitude = -longitude;
-
+
position.setLatitude(latitude);
position.setLongitude(longitude);
position.setAltitude(0.0);
-
+
// Cell information
extendedInfo.append("<mcc>");
extendedInfo.append(buf.readUnsignedShort());
@@ -157,7 +157,7 @@ public class Gt06ProtocolDecoder extends GenericProtocolDecoder {
extendedInfo.append("<cell>");
extendedInfo.append(buf.readUnsignedShort() << 8 + buf.readUnsignedByte());
extendedInfo.append("</cell>");
-
+
// Index
position.setId((long) buf.readUnsignedShort());