diff options
Diffstat (limited to 'src/org/traccar/protocol/FlespiProtocolDecoder.java')
| -rw-r--r-- | src/org/traccar/protocol/FlespiProtocolDecoder.java | 246 |
1 files changed, 0 insertions, 246 deletions
diff --git a/src/org/traccar/protocol/FlespiProtocolDecoder.java b/src/org/traccar/protocol/FlespiProtocolDecoder.java deleted file mode 100644 index 86da3943e..000000000 --- a/src/org/traccar/protocol/FlespiProtocolDecoder.java +++ /dev/null @@ -1,246 +0,0 @@ -/* - * Copyright 2017 - 2018 Anton Tananaev (anton@traccar.org) - * - * 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 io.netty.channel.Channel; -import io.netty.handler.codec.http.FullHttpRequest; -import io.netty.handler.codec.http.HttpResponseStatus; -import org.traccar.BaseHttpProtocolDecoder; -import org.traccar.DeviceSession; -import org.traccar.Protocol; -import org.traccar.model.Position; - -import javax.json.Json; -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; - -public class FlespiProtocolDecoder extends BaseHttpProtocolDecoder { - - public FlespiProtocolDecoder(Protocol protocol) { - super(protocol); - } - - @Override - protected Object decode( - Channel channel, SocketAddress remoteAddress, Object msg) throws Exception { - - FullHttpRequest request = (FullHttpRequest) msg; - JsonArray result = Json.createReader(new StringReader(request.content().toString(StandardCharsets.UTF_8))) - .readArray(); - List<Position> positions = new LinkedList<>(); - for (int i = 0; i < result.size(); i++) { - JsonObject message = result.getJsonObject(i); - JsonString ident = message.getJsonString("ident"); - if (ident == null) { - continue; - } - DeviceSession deviceSession = getDeviceSession(channel, remoteAddress, ident.getString()); - if (deviceSession == null) { - continue; - } - Position position = new Position(getProtocolName()); - position.setDeviceId(deviceSession.getDeviceId()); - decodePosition(message, position); - positions.add(position); - } - - sendResponse(channel, HttpResponseStatus.OK); - return positions; - } - - private void decodePosition(JsonObject object, Position position) { - for (Map.Entry<String, JsonValue> param : object.entrySet()) { - String paramName = param.getKey(); - JsonValue paramValue = param.getValue(); - int index = -1; - if (paramName.contains("#")) { - String[] parts = paramName.split("#"); - paramName = parts[0]; - index = Integer.parseInt(parts[1]); - } - if (!decodeParam(paramName, index, paramValue, position)) { - decodeUnknownParam(param.getKey(), param.getValue(), position); - } - } - if (position.getLatitude() == 0 && position.getLongitude() == 0) { - getLastLocation(position, position.getDeviceTime()); - } - } - - private boolean decodeParam(String name, int index, JsonValue value, Position position) { - switch (name) { - case "timestamp": - position.setTime(new Date(((JsonNumber) value).longValue() * 1000)); - return true; - case "position.latitude": - position.setLatitude(((JsonNumber) value).doubleValue()); - return true; - case "position.longitude": - position.setLongitude(((JsonNumber) value).doubleValue()); - return true; - case "position.speed": - position.setSpeed(((JsonNumber) value).doubleValue()); - return true; - case "position.direction": - position.setCourse(((JsonNumber) value).doubleValue()); - return true; - case "position.altitude": - position.setAltitude(((JsonNumber) value).doubleValue()); - return true; - case "position.satellites": - position.set(Position.KEY_SATELLITES, ((JsonNumber) value).intValue()); - return true; - case "position.valid": - position.setValid(value == JsonValue.TRUE); - return true; - case "position.hdop": - position.set(Position.KEY_HDOP, ((JsonNumber) value).doubleValue()); - return true; - case "position.pdop": - position.set(Position.KEY_PDOP, ((JsonNumber) value).doubleValue()); - return true; - case "din": - case "dout": - position.set(name.equals("din") ? Position.KEY_INPUT : Position.KEY_OUTPUT, - ((JsonNumber) value).intValue()); - return true; - case "gps.vehicle.mileage": - position.set(Position.KEY_ODOMETER, ((JsonNumber) value).doubleValue()); - return true; - case "external.powersource.voltage": - position.set(Position.KEY_POWER, ((JsonNumber) value).doubleValue()); - return true; - case "battery.voltage": - position.set(Position.KEY_BATTERY, ((JsonNumber) value).doubleValue()); - return true; - case "fuel.level": - case "can.fuel.level": - position.set(Position.KEY_FUEL_LEVEL, ((JsonNumber) value).doubleValue()); - return true; - case "engine.rpm": - case "can.engine.rpm": - position.set(Position.KEY_RPM, ((JsonNumber) value).doubleValue()); - return true; - case "can.engine.temperature": - position.set(Position.PREFIX_TEMP + (index > 0 ? index : 0), ((JsonNumber) value).doubleValue()); - return true; - case "engine.ignition.status": - position.set(Position.KEY_IGNITION, value == JsonValue.TRUE); - return true; - case "movement.status": - position.set(Position.KEY_MOTION, value == JsonValue.TRUE); - return true; - case "device.temperature": - position.set(Position.KEY_DEVICE_TEMP, ((JsonNumber) value).doubleValue()); - return true; - case "ibutton.code": - position.set(Position.KEY_DRIVER_UNIQUE_ID, ((JsonString) value).getString()); - return true; - case "vehicle.vin": - position.set(Position.KEY_VIN, ((JsonString) value).getString()); - return true; - case "alarm.event.trigger": - if (value == JsonValue.TRUE) { - position.set(Position.KEY_ALARM, Position.ALARM_GENERAL); - } - return true; - case "towing.event.trigger": - case "towing.alarm.status": - if (value == JsonValue.TRUE) { - position.set(Position.KEY_ALARM, Position.ALARM_TOW); - } - return true; - case "geofence.event.enter": - if (value == JsonValue.TRUE) { - position.set(Position.KEY_ALARM, Position.ALARM_GEOFENCE_ENTER); - } - return true; - case "geofence.event.exit": - if (value == JsonValue.TRUE) { - position.set(Position.KEY_ALARM, Position.ALARM_GEOFENCE_EXIT); - } - return true; - case "shock.event.trigger": - if (value == JsonValue.TRUE) { - position.set(Position.KEY_ALARM, Position.ALARM_SHOCK); - } - return true; - case "overspeeding.event.trigger": - if (value == JsonValue.TRUE) { - position.set(Position.KEY_ALARM, Position.ALARM_OVERSPEED); - } - return true; - case "harsh.acceleration.event.trigger": - if (value == JsonValue.TRUE) { - position.set(Position.KEY_ALARM, Position.ALARM_ACCELERATION); - } - return true; - case "harsh.braking.event.trigger": - if (value == JsonValue.TRUE) { - position.set(Position.KEY_ALARM, Position.ALARM_BRAKING); - } - return true; - case "harsh.cornering.event.trigger": - if (value == JsonValue.TRUE) { - position.set(Position.KEY_ALARM, Position.ALARM_CORNERING); - } - return true; - case "gnss.antenna.cut.status": - if (value == JsonValue.TRUE) { - position.set(Position.KEY_ALARM, Position.ALARM_GPS_ANTENNA_CUT); - } - return true; - case "gsm.jamming.event.trigger": - if (value == JsonValue.TRUE) { - position.set(Position.KEY_ALARM, Position.ALARM_JAMMING); - } - return true; - case "hood.open.status": - if (value == JsonValue.TRUE) { - position.set(Position.KEY_ALARM, Position.ALARM_BONNET); - } - return true; - default: - return false; - } - } - - private void decodeUnknownParam(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); - } - } - -} |