aboutsummaryrefslogtreecommitdiff
path: root/src/org/traccar
diff options
context:
space:
mode:
authornamo <namo@gurtam.com>2017-12-04 13:48:43 +0300
committernamo <namo@gurtam.com>2017-12-04 13:48:43 +0300
commita067ab0240b0ac68c97f61fdadb53e7e063c8594 (patch)
tree8656c2d094aca2fbe4bd714dac437f1abc16d436 /src/org/traccar
parentaa4a01126f9724dece194c9543927d60934ec2a6 (diff)
downloadtrackermap-server-a067ab0240b0ac68c97f61fdadb53e7e063c8594.tar.gz
trackermap-server-a067ab0240b0ac68c97f61fdadb53e7e063c8594.tar.bz2
trackermap-server-a067ab0240b0ac68c97f61fdadb53e7e063c8594.zip
flespi protocol remastered to receive data from stream; more parameters are converted into internal representation
Diffstat (limited to 'src/org/traccar')
-rw-r--r--src/org/traccar/protocol/FlespiProtocolDecoder.java278
1 files changed, 252 insertions, 26 deletions
diff --git a/src/org/traccar/protocol/FlespiProtocolDecoder.java b/src/org/traccar/protocol/FlespiProtocolDecoder.java
index d122df383..71f67b552 100644
--- a/src/org/traccar/protocol/FlespiProtocolDecoder.java
+++ b/src/org/traccar/protocol/FlespiProtocolDecoder.java
@@ -18,6 +18,10 @@ package org.traccar.protocol;
import org.jboss.netty.channel.Channel;
import org.jboss.netty.handler.codec.http.HttpRequest;
import org.jboss.netty.handler.codec.http.HttpResponseStatus;
+import org.jboss.netty.handler.codec.http.multipart.Attribute;
+import org.jboss.netty.handler.codec.http.multipart.DefaultHttpDataFactory;
+import org.jboss.netty.handler.codec.http.multipart.HttpPostRequestDecoder;
+import org.jboss.netty.handler.codec.http.multipart.InterfaceHttpData;
import org.traccar.BaseHttpProtocolDecoder;
import org.traccar.DeviceSession;
import org.traccar.model.Position;
@@ -27,12 +31,15 @@ import javax.json.JsonArray;
import javax.json.JsonNumber;
import javax.json.JsonObject;
import javax.json.JsonString;
+import javax.json.JsonValue;
import java.io.StringReader;
import java.net.SocketAddress;
-import java.nio.charset.StandardCharsets;
import java.util.Date;
import java.util.LinkedList;
import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.Iterator;
public class FlespiProtocolDecoder extends BaseHttpProtocolDecoder {
@@ -45,8 +52,16 @@ public class FlespiProtocolDecoder extends BaseHttpProtocolDecoder {
Channel channel, SocketAddress remoteAddress, Object msg) throws Exception {
HttpRequest request = (HttpRequest) msg;
- JsonArray result = Json.createReader(new StringReader(request.getContent().toString(StandardCharsets.UTF_8)))
- .readArray();
+ HttpPostRequestDecoder decoder = new HttpPostRequestDecoder(new DefaultHttpDataFactory(false), request);
+ InterfaceHttpData data = decoder.getBodyHttpData("data");
+ if (data.getHttpDataType() != InterfaceHttpData.HttpDataType.Attribute) {
+ sendResponse(channel, HttpResponseStatus.BAD_REQUEST);
+ return null;
+ }
+
+ Attribute attribute = (Attribute) data;
+ String value = attribute.getValue();
+ JsonArray result = Json.createReader(new StringReader(value)).readArray();
List<Position> positions = new LinkedList<>();
for (int i = 0; i < result.size(); i++) {
JsonObject message = result.getJsonObject(i);
@@ -60,6 +75,7 @@ public class FlespiProtocolDecoder extends BaseHttpProtocolDecoder {
}
Position position = new Position();
position.setDeviceId(deviceSession.getDeviceId());
+ position.setProtocol(getProtocolName());
decodePosition(message, position);
positions.add(position);
}
@@ -69,36 +85,246 @@ public class FlespiProtocolDecoder extends BaseHttpProtocolDecoder {
}
private void decodePosition(JsonObject object, Position position) {
- position.setProtocol(getProtocolName());
+ // store all params in position
+ Set<Map.Entry<String, JsonValue>> params = object.entrySet();
+ Iterator<Map.Entry<String, JsonValue>> it = params.iterator();
+ while (it.hasNext()) {
+ Map.Entry<String, JsonValue> param = it.next();
+ String paramName = param.getKey();
+ JsonValue paramValue = param.getValue();
+ if ("timestamp".equals(paramName)) {
+ Date deviceTime = new Date((long) (((JsonNumber) paramValue).doubleValue() * 1000));
+ position.setTime(deviceTime);
+ } else if (paramName.startsWith("position.")) {
+ savePosition(paramName, paramValue, position);
+ } else if (paramName.matches("din#[\\d]{1,2}")) {
+ saveInput(paramName, paramValue, position);
+ } else if (paramName.matches("dout#[\\d]{1,2}")) {
+ saveOutput(paramName, paramValue, position);
+ } else if (saveAlarm(paramName, paramValue, position) == 0
+ && saveParam(paramName, paramValue, position) == 0) {
+ saveUnknownParam(param.getKey(), param.getValue(), position);
+ }
+ }
+ if (position.getLatitude() == 0 && position.getLongitude() == 0) {
+ getLastLocation(position, position.getDeviceTime());
+ }
+ }
- Date deviceTime = new Date((long) object.getJsonNumber("timestamp").doubleValue() * 1000);
- position.setTime(deviceTime);
- JsonNumber lat = object.getJsonNumber("position.latitude");
- JsonNumber lon = object.getJsonNumber("position.longitude");
- if (lat != null && lon != null) {
- position.setLatitude(lat.doubleValue());
- position.setLongitude(lon.doubleValue());
- } else {
- getLastLocation(position, deviceTime);
+ private void savePosition(String name, JsonValue value, Position position) {
+ switch (name) {
+ case "position.latitude":
+ position.setLatitude(((JsonNumber) value).doubleValue());
+ break;
+ case "position.longitude":
+ position.setLongitude(((JsonNumber) value).doubleValue());
+ break;
+ case "position.speed":
+ position.setSpeed(((JsonNumber) value).doubleValue());
+ break;
+ case "position.direction":
+ position.setCourse(((JsonNumber) value).doubleValue());
+ break;
+ case "position.altitude":
+ position.setAltitude(((JsonNumber) value).doubleValue());
+ break;
+ case "position.satellites":
+ position.set(Position.KEY_SATELLITES, ((JsonNumber) value).intValue());
+ break;
+ case "position.valid":
+ position.setValid(value == JsonValue.TRUE);
+ break;
+ case "position.hdop":
+ position.set(Position.KEY_HDOP, ((JsonNumber) value).doubleValue());
+ break;
+ case "position.pdop":
+ position.set(Position.KEY_PDOP, ((JsonNumber) value).doubleValue());
+ break;
+ default:
+ saveUnknownParam(name, value, position);
+ break;
+ }
+ }
+
+ private int saveParam(String name, JsonValue value, Position position) {
+ if (name == null) {
+ return 0;
+ }
+ if (name.equals("gps.vehicle.mileage") || name.startsWith("gps.vehicle.mileage#")) {
+ position.set(Position.KEY_ODOMETER, ((JsonNumber) value).doubleValue());
+ return 1;
+ }
+ if (name.equals("external.powersource.voltage") || name.startsWith("external.powersource.voltage#")) {
+ position.set(Position.KEY_POWER, ((JsonNumber) value).doubleValue());
+ return 1;
+ }
+ if (name.equals("battery.voltage") || name.startsWith("battery.voltage#")) {
+ position.set(Position.KEY_BATTERY, ((JsonNumber) value).doubleValue());
+ return 1;
+ }
+ if (name.equals("fuel.level") || name.equals("can.fuel.level")
+ || name.startsWith("fuel.level#") || name.startsWith("can.fuel.level#")) {
+ position.set(Position.KEY_FUEL_LEVEL, ((JsonNumber) value).doubleValue());
+ return 1;
+ }
+ if (name.equals("engine.rpm") || name.equals("can.engine.rpm")
+ || name.startsWith("engine.rpm#") || name.startsWith("can.engine.rpm#")) {
+ position.set(Position.KEY_RPM, ((JsonNumber) value).doubleValue());
+ return 1;
+ }
+ if (name.equals("can.engine.temperature") || name.startsWith("can.engine.temperature#")) {
+ int seqNum = 0;
+ if (name.contains("#")) {
+ try {
+ seqNum = Integer.parseInt(name.replaceAll("can\\.engine\\.temperature#", ""));
+ } catch (NumberFormatException e) {
+ seqNum = 0;
+ }
+ }
+ position.set(Position.PREFIX_TEMP + seqNum, ((JsonNumber) value).doubleValue());
+ return 1;
+ }
+ if (name.equals("engine.ignition.status")) {
+ position.set(Position.KEY_IGNITION, value == JsonValue.TRUE);
+ return 1;
+ }
+ if (name.equals("movement.status")) {
+ position.set(Position.KEY_MOTION, value == JsonValue.TRUE);
+ return 1;
+ }
+ if (name.equals("device.temperature")) {
+ position.set(Position.KEY_DEVICE_TEMP, ((JsonNumber) value).doubleValue());
+ return 1;
+ }
+ if (name.equals("ibutton.code")) {
+ position.set(Position.KEY_DRIVER_UNIQUE_ID, ((JsonString) value).getString());
+ return 1;
+ }
+ if (name.equals("vehicle.vin")) {
+ position.set(Position.KEY_VIN, ((JsonString) value).getString());
+ return 1;
+ }
+ return 0;
+ }
+
+ private int saveAlarm(String name, JsonValue value, Position position) {
+ if ("alarm.event.trigger".equals(name)) {
+ if (value == JsonValue.TRUE) {
+ position.set(Position.KEY_ALARM, Position.ALARM_GENERAL);
+ }
+ return 1;
+ }
+ if ("towing.event.trigger".equals(name) || "towing.alarm.status".equals(name)) {
+ if (value == JsonValue.TRUE) {
+ position.set(Position.KEY_ALARM, Position.ALARM_TOW);
+ }
+ return 1;
+ }
+ if ("geofence.event.enter".equals(name)) {
+ if (value == JsonValue.TRUE) {
+ position.set(Position.KEY_ALARM, Position.ALARM_GEOFENCE_ENTER);
+ }
+ return 1;
+ }
+ if ("geofence.event.exit".equals(name)) {
+ if (value == JsonValue.TRUE) {
+ position.set(Position.KEY_ALARM, Position.ALARM_GEOFENCE_EXIT);
+ }
+ return 1;
+ }
+ if ("shock.event.trigger".equals(name)) {
+ if (value == JsonValue.TRUE) {
+ position.set(Position.KEY_ALARM, Position.ALARM_SHOCK);
+ }
+ return 1;
}
- JsonNumber speed = object.getJsonNumber("position.speed");
- if (speed != null) {
- position.setSpeed(speed.doubleValue());
+ if ("overspeeding.event.trigger".equals(name)) {
+ if (value == JsonValue.TRUE) {
+ position.set(Position.KEY_ALARM, Position.ALARM_OVERSPEED);
+ }
+ return 1;
}
- JsonNumber course = object.getJsonNumber("position.direction");
- if (course != null) {
- position.setCourse(course.doubleValue());
+ if ("harsh.acceleration.event.trigger".equals(name)) {
+ if (value == JsonValue.TRUE) {
+ position.set(Position.KEY_ALARM, Position.ALARM_ACCELERATION);
+ }
+ return 1;
}
- JsonNumber altitude = object.getJsonNumber("position.altitude");
- if (altitude != null) {
- position.setAltitude(altitude.doubleValue());
+ if ("harsh.braking.event.trigger".equals(name)) {
+ if (value == JsonValue.TRUE) {
+ position.set(Position.KEY_ALARM, Position.ALARM_BRAKING);
+ }
+ return 1;
}
+ if ("harsh.cornering.event.trigger".equals(name)) {
+ if (value == JsonValue.TRUE) {
+ position.set(Position.KEY_ALARM, Position.ALARM_CORNERING);
+ }
+ return 1;
+ }
+ if ("gnss.antenna.cut.status".equals(name)) {
+ if (value == JsonValue.TRUE) {
+ position.set(Position.KEY_ALARM, Position.ALARM_GPS_ANTENNA_CUT);
+ }
+ return 1;
+ }
+ if ("gsm.jamming.event.trigger".equals(name)) {
+ if (value == JsonValue.TRUE) {
+ position.set(Position.KEY_ALARM, Position.ALARM_JAMMING);
+ }
+ return 1;
+ }
+ if ("hood.open.status".equals(name)) {
+ if (value == JsonValue.TRUE) {
+ position.set(Position.KEY_ALARM, Position.ALARM_BONNET);
+ }
+ return 1;
+ }
+ return 0;
+ }
+
+ private void saveInput(String name, JsonValue value, Position position) {
+ if (value != JsonValue.TRUE) {
+ return;
+ }
+ int in = Integer.parseInt(name.replaceAll("^din#", ""));
+ if (in > 32 || in < 1) {
+ return;
+ }
+ if (position.getInteger(Position.KEY_INPUT) == 0) {
+ position.set(Position.KEY_INPUT, 1 << (in - 1));
+ } else {
+ position.set(Position.KEY_INPUT, (position.getInteger(Position.KEY_INPUT) | 1 << (in - 1)));
+ }
+ }
- position.setValid(object.getBoolean("position.valid", true));
- position.set(Position.KEY_SATELLITES, object.getInt("position.satellites", 0));
+ private void saveOutput(String name, JsonValue value, Position position) {
+ if (value != JsonValue.TRUE) {
+ return;
+ }
+ int out = Integer.parseInt(name.replaceAll("^dout#", ""));
+ if (out > 32 || out < 1) {
+ return;
+ }
+ if (position.getInteger(Position.KEY_OUTPUT) == 0) {
+ position.set(Position.KEY_OUTPUT, 1 << (out - 1));
+ } else {
+ position.set(Position.KEY_OUTPUT, (position.getInteger(Position.KEY_OUTPUT) | 1 << (out - 1)));
+ }
+ }
- if (object.getBoolean("alarm.event.trigger", false)) {
- position.set(Position.KEY_ALARM, Position.ALARM_GENERAL);
+ private void saveUnknownParam(String name, JsonValue value, Position position) {
+ if (value instanceof JsonNumber) {
+ if (((JsonNumber) value).isIntegral()) {
+ position.set(name, ((JsonNumber) value).longValue());
+ } else {
+ position.set(name, ((JsonNumber) value).doubleValue());
+ }
+ position.set(name, ((JsonNumber) value).doubleValue());
+ } else if (value instanceof JsonString) {
+ position.set(name, ((JsonString) value).getString());
+ } else if (value == JsonValue.TRUE || value == JsonValue.FALSE) {
+ position.set(name, value == JsonValue.TRUE);
}
}
}