aboutsummaryrefslogtreecommitdiff
path: root/src/org/traccar/protocol
diff options
context:
space:
mode:
authorAnton Tananaev <anton.tananaev@gmail.com>2013-08-16 00:20:05 +1200
committerAnton Tananaev <anton.tananaev@gmail.com>2013-08-16 00:20:05 +1200
commit123544ebec47b6d418980ff2da6033de1fe0ea45 (patch)
tree84dfe31644e8979a9d3c7669cac6f166292b3ac2 /src/org/traccar/protocol
parent7c56e30b389f06713272532c10bac68ec108a29c (diff)
downloadtraccar-server-123544ebec47b6d418980ff2da6033de1fe0ea45.tar.gz
traccar-server-123544ebec47b6d418980ff2da6033de1fe0ea45.tar.bz2
traccar-server-123544ebec47b6d418980ff2da6033de1fe0ea45.zip
Support alternative megastek format
Diffstat (limited to 'src/org/traccar/protocol')
-rw-r--r--src/org/traccar/protocol/MegastekProtocolDecoder.java203
1 files changed, 153 insertions, 50 deletions
diff --git a/src/org/traccar/protocol/MegastekProtocolDecoder.java b/src/org/traccar/protocol/MegastekProtocolDecoder.java
index f863df153..d014869d8 100644
--- a/src/org/traccar/protocol/MegastekProtocolDecoder.java
+++ b/src/org/traccar/protocol/MegastekProtocolDecoder.java
@@ -33,9 +33,7 @@ public class MegastekProtocolDecoder extends BaseProtocolDecoder {
super(serverManager);
}
- static private Pattern pattern = Pattern.compile(
- "STX," +
- "[^,]+," + // Identifier (not IMEI)
+ static private Pattern patternGPRMC = Pattern.compile(
"\\$GPRMC," +
"(\\d{2})(\\d{2})(\\d{2})\\.\\d+," + // Time (HHMMSS.SSS)
"([AV])," + // Validity
@@ -43,10 +41,12 @@ public class MegastekProtocolDecoder extends BaseProtocolDecoder {
"([NS])," +
"(\\d+)(\\d{2}\\.\\d+)," + // Longitude (DDDMM.MMMM)
"([EW])," +
- "(\\d+\\.\\d{2})?," + // Speed
- "(\\d+\\.\\d{2})?," + // Course
+ "(\\d+\\.\\d+)?," + // Speed
+ "(\\d+\\.\\d+)?," + // Course
"(\\d{2})(\\d{2})(\\d{2})" + // Date (DDMMYY)
- "[^\\*]+\\*[0-9a-fA-F]{2}," + // Checksumm
+ "[^\\*]+\\*[0-9a-fA-F]{2}"); // Checksum
+
+ static private Pattern patternSimple = Pattern.compile(
"[FL]," + // Flag
"([^,]*)," + // Alarm
"imei:(\\d+)," + // IMEI
@@ -56,25 +56,32 @@ public class MegastekProtocolDecoder extends BaseProtocolDecoder {
"(\\d)?," + // Charger
"(\\d+)," + // MCC
"(\\d+)," + // MNC
- "([0-9a-fA-F]+,[0-9a-fA-F]+);" + // Location code
- ".+"); // Checksumm
-
- @Override
- protected Object decode(
- ChannelHandlerContext ctx, Channel channel, Object msg)
- throws Exception {
+ "(\\p{XDigit}{4},\\p{XDigit}{4});" + // Location code
+ ".+"); // Checksum
- String sentence = (String) msg;
+ static private Pattern patternAlternative = Pattern.compile(
+ "(\\d+)," + // MCC
+ "(\\d+)," + // MNC
+ "(\\p{XDigit}{4},\\p{XDigit}{4})," + // Location code
+ "(\\d+)," + // GSM signal
+ "(\\d+)," + // Battery
+ "(\\d+)," + // Flags
+ "(\\d+)," + // Inputs
+ "(\\d+)," + // Outputs
+ "(\\d\\.\\d{2})," + // ADC 1
+ "(\\d\\.\\d{2})," + // ADC 2
+ "(\\d\\.\\d{2})," + // ADC 3
+ "([^;]+);" + // Alarm
+ ".+"); // Checksum
+ private boolean parseGPRMC(String gprmc, Position position) {
+
// Parse message
- Matcher parser = pattern.matcher(sentence);
+ Matcher parser = patternGPRMC.matcher(gprmc);
if (!parser.matches()) {
- return null;
+ return false;
}
- // Create new position
- Position position = new Position();
- ExtendedInfoFormatter extendedInfo = new ExtendedInfoFormatter("megastek");
int index = 1;
// Time
@@ -119,50 +126,146 @@ public class MegastekProtocolDecoder extends BaseProtocolDecoder {
time.set(Calendar.DAY_OF_MONTH, Integer.valueOf(parser.group(index++)));
time.set(Calendar.MONTH, Integer.valueOf(parser.group(index++)) - 1);
time.set(Calendar.YEAR, 2000 + Integer.valueOf(parser.group(index++)));
- position.setTime(time.getTime());
+ position.setTime(time.getTime());
- // Alarm
- extendedInfo.set("alarm", parser.group(index++));
+ return true;
+ }
+
+ @Override
+ protected Object decode(
+ ChannelHandlerContext ctx, Channel channel, Object msg)
+ throws Exception {
- // IMEI
- String imei = parser.group(index++);
- try {
- position.setDeviceId(getDataManager().getDeviceByImei(imei).getId());
- } catch(Exception error) {
- Log.warning("Unknown device - " + imei);
- return null;
+ String sentence = (String) msg;
+
+ // Detect type
+ boolean simple = (sentence.charAt(3) == ',');
+
+ // Split message
+ String id;
+ String gprmc;
+ String status;
+ if (simple) {
+
+ int beginIndex = 4;
+ int endIndex = sentence.indexOf(',', beginIndex);
+ id = sentence.substring(beginIndex, endIndex);
+
+ beginIndex = endIndex + 1;
+ endIndex = sentence.indexOf('*', beginIndex) + 3;
+ gprmc = sentence.substring(beginIndex, endIndex);
+
+ beginIndex = endIndex + 1;
+ status = sentence.substring(beginIndex);
+
+ } else {
+
+ int beginIndex = 3;
+ int endIndex = beginIndex + 16;
+ id = sentence.substring(beginIndex, endIndex).trim();
+
+ beginIndex = endIndex + 2;
+ endIndex = sentence.indexOf('*', beginIndex) + 3;
+ gprmc = sentence.substring(beginIndex, endIndex);
+
+ beginIndex = endIndex + 1;
+ status = sentence.substring(beginIndex);
+
}
- // Satellites
- String satellites = parser.group(index++);
- if (satellites != null) {
- extendedInfo.set("satellites", satellites);
+ // Create new position
+ Position position = new Position();
+ ExtendedInfoFormatter extendedInfo = new ExtendedInfoFormatter("megastek");
+
+ // Parse location data
+ if (!parseGPRMC(gprmc, position)) {
+ return null;
}
+
+ if (simple) {
- // Altitude
- position.setAltitude(Double.valueOf(parser.group(index++)));
+ // Parse status
+ Matcher parser = patternSimple.matcher(status);
+ if (!parser.matches()) {
+ return null;
+ }
+
+ int index = 1;
- // Battery
- position.setPower(Double.valueOf(parser.group(index++)));
+ // Alarm
+ extendedInfo.set("alarm", parser.group(index++));
- // Charger
- String charger = parser.group(index++);
- if (charger != null) {
- extendedInfo.set("charger", Integer.valueOf(charger) == 1);
- }
+ // IMEI
+ String imei = parser.group(index++);
+ try {
+ position.setDeviceId(getDataManager().getDeviceByImei(imei).getId());
+ } catch(Exception firstError) {
+ try {
+ position.setDeviceId(getDataManager().getDeviceByImei(id).getId());
+ } catch(Exception secondError) {
+ Log.warning("Unknown device - " + imei + "(id - " + id + ")");
+ return null;
+ }
+ }
- // MCC
- extendedInfo.set("mcc", parser.group(index++));
+ // Satellites
+ String satellites = parser.group(index++);
+ if (satellites != null) {
+ extendedInfo.set("satellites", satellites);
+ }
- // MNC
- extendedInfo.set("mnc", parser.group(index++));
+ // Altitude
+ position.setAltitude(Double.valueOf(parser.group(index++)));
- // LAC
- extendedInfo.set("lac", parser.group(index++));
+ // Battery
+ position.setPower(Double.valueOf(parser.group(index++)));
- // Extended info
- position.setExtendedInfo(extendedInfo.toString());
+ // Charger
+ String charger = parser.group(index++);
+ if (charger != null) {
+ extendedInfo.set("charger", Integer.valueOf(charger) == 1);
+ }
+
+ extendedInfo.set("mcc", parser.group(index++));
+ extendedInfo.set("mnc", parser.group(index++));
+ extendedInfo.set("lac", parser.group(index++));
+
+ } else {
+ // Parse status
+ Matcher parser = patternAlternative.matcher(status);
+ if (!parser.matches()) {
+ return null;
+ }
+
+ int index = 1;
+
+ try {
+ position.setDeviceId(getDataManager().getDeviceByImei(id).getId());
+ } catch(Exception error) {
+ Log.warning("Unknown device - " + id);
+ return null;
+ }
+
+ extendedInfo.set("mcc", parser.group(index++));
+ extendedInfo.set("mnc", parser.group(index++));
+ extendedInfo.set("lac", parser.group(index++));
+ extendedInfo.set("gsm", parser.group(index++));
+
+ // Battery
+ position.setPower(Double.valueOf(parser.group(index++)));
+
+ extendedInfo.set("flags", parser.group(index++));
+ extendedInfo.set("input", parser.group(index++));
+ extendedInfo.set("output", parser.group(index++));
+ extendedInfo.set("adc1", parser.group(index++));
+ extendedInfo.set("adc2", parser.group(index++));
+ extendedInfo.set("adc3", parser.group(index++));
+ extendedInfo.set("alarm", parser.group(index++));
+
+ }
+
+ position.setExtendedInfo(extendedInfo.toString());
return position;
}