diff options
author | Anton Tananaev <anton.tananaev@gmail.com> | 2012-10-11 19:52:27 +1300 |
---|---|---|
committer | Anton Tananaev <anton.tananaev@gmail.com> | 2012-10-11 19:52:27 +1300 |
commit | 7ca3514fe59d876e2b91c52c100014b84962ee5b (patch) | |
tree | eb6e7b5ebd1b0940ce02c94fdaaa98f020b684f9 /src/org/traccar | |
parent | cd29641995e256e82828dd6eef44bb83186463c3 (diff) | |
download | traccar-server-7ca3514fe59d876e2b91c52c100014b84962ee5b.tar.gz traccar-server-7ca3514fe59d876e2b91c52c100014b84962ee5b.tar.bz2 traccar-server-7ca3514fe59d876e2b91c52c100014b84962ee5b.zip |
Finished progress protocol
Diffstat (limited to 'src/org/traccar')
-rw-r--r-- | src/org/traccar/protocol/ProgressProtocolDecoder.java | 52 |
1 files changed, 50 insertions, 2 deletions
diff --git a/src/org/traccar/protocol/ProgressProtocolDecoder.java b/src/org/traccar/protocol/ProgressProtocolDecoder.java index 15cffbbda..173dd083a 100644 --- a/src/org/traccar/protocol/ProgressProtocolDecoder.java +++ b/src/org/traccar/protocol/ProgressProtocolDecoder.java @@ -15,8 +15,11 @@ */ package org.traccar.protocol; +import java.util.Calendar; +import java.util.TimeZone; import java.nio.charset.Charset; import org.jboss.netty.buffer.ChannelBuffer; +import org.jboss.netty.buffer.ChannelBuffers; import org.jboss.netty.channel.Channel; import org.jboss.netty.channel.ChannelHandlerContext; import org.traccar.GenericProtocolDecoder; @@ -77,11 +80,56 @@ public class ProgressProtocolDecoder extends GenericProtocolDecoder { // Position else if (type == MSG_POINT || type == MSG_ALARM) { Position position = new Position(); + StringBuilder extendedInfo = new StringBuilder("<protocol>progress</protocol>"); position.setDeviceId(deviceId); - // TODO: parse messages here + // Message index + buf.readUnsignedInt(); + + // Time + Calendar time = Calendar.getInstance(TimeZone.getTimeZone("UTC")); + time.clear(); + time.setTimeInMillis(buf.readUnsignedInt() * 1000); + position.setTime(time.getTime()); + + // Latitude + position.setLatitude(((double) buf.readInt()) / 0x7FFFFFFF * 180.0); + + // Longitude + position.setLongitude(((double) buf.readInt()) / 0x7FFFFFFF * 180.0); + + // Speed + position.setSpeed(((double) buf.readUnsignedInt()) / 100); + + // Course + position.setCourse(((double) buf.readUnsignedShort()) / 100); + + // Altitude + position.setAltitude(((double) buf.readUnsignedShort()) / 100); + + // Satellites + int satellitesNumber = buf.readUnsignedByte(); + extendedInfo.append("<sat>"); + extendedInfo.append(satellitesNumber); + extendedInfo.append("</sat>"); + position.setValid(satellitesNumber >= 3); // TODO: probably wrong + + // Cell signal + extendedInfo.append("<gsm>"); + extendedInfo.append(buf.readUnsignedByte()); + extendedInfo.append("</gsm>"); + + // TODO: process other data + + // Extended info + position.setExtendedInfo(extendedInfo.toString()); + + // Send response for alarm message if (type == MSG_ALARM) { - // TODO: send MSG_ALARM_RECIEVED / channel.write(...); + byte[] response = {(byte)0xC9,0x00,0x00,0x00,0x00,0x00,0x00,0x00}; + channel.write(ChannelBuffers.wrappedBuffer(response)); + + extendedInfo.append("<alarm>true</alarm>"); } return position; |