aboutsummaryrefslogtreecommitdiff
path: root/src/org/traccar/processing
diff options
context:
space:
mode:
authorAnton Tananaev <anton.tananaev@gmail.com>2019-02-23 12:12:31 -0800
committerAnton Tananaev <anton.tananaev@gmail.com>2019-02-23 12:12:31 -0800
commit7e239583698a169971f5bd817adbabdacba8dc56 (patch)
tree0914e1641733961352401b7d629542f23b8d6fb3 /src/org/traccar/processing
parentbd909426d24832e42a63503c338bbd8c37176caa (diff)
downloadtrackermap-server-7e239583698a169971f5bd817adbabdacba8dc56.tar.gz
trackermap-server-7e239583698a169971f5bd817adbabdacba8dc56.tar.bz2
trackermap-server-7e239583698a169971f5bd817adbabdacba8dc56.zip
Update filter handler
Diffstat (limited to 'src/org/traccar/processing')
-rw-r--r--src/org/traccar/processing/FilterHandler.java210
1 files changed, 210 insertions, 0 deletions
diff --git a/src/org/traccar/processing/FilterHandler.java b/src/org/traccar/processing/FilterHandler.java
new file mode 100644
index 000000000..df62b1e6d
--- /dev/null
+++ b/src/org/traccar/processing/FilterHandler.java
@@ -0,0 +1,210 @@
+/*
+ * Copyright 2014 - 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.processing;
+
+import io.netty.channel.ChannelHandler;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.traccar.BaseDataHandler;
+import org.traccar.Context;
+import org.traccar.config.Config;
+import org.traccar.config.Keys;
+import org.traccar.helper.UnitsConverter;
+import org.traccar.model.Position;
+
+@ChannelHandler.Sharable
+public class FilterHandler extends BaseDataHandler {
+
+ private static final Logger LOGGER = LoggerFactory.getLogger(FilterHandler.class);
+
+ private boolean filterInvalid;
+ private boolean filterZero;
+ private boolean filterDuplicate;
+ private long filterFuture;
+ private boolean filterApproximate;
+ private int filterAccuracy;
+ private boolean filterStatic;
+ private int filterDistance;
+ private int filterMaxSpeed;
+ private long filterMinPeriod;
+ private long skipLimit;
+ private boolean skipAttributes;
+
+ public FilterHandler(Config config) {
+ filterInvalid = config.getBoolean(Keys.FILTER_INVALID);
+ filterZero = config.getBoolean(Keys.FILTER_ZERO);
+ filterDuplicate = config.getBoolean(Keys.FILTER_DUPLICATE);
+ filterFuture = config.getLong(Keys.FILTER_FUTURE) * 1000;
+ filterAccuracy = config.getInteger(Keys.FILTER_ACCURACY);
+ filterApproximate = config.getBoolean(Keys.FILTER_APPROXIMATE);
+ filterStatic = config.getBoolean(Keys.FILTER_STATIC);
+ filterDistance = config.getInteger(Keys.FILTER_DISTANCE);
+ filterMaxSpeed = config.getInteger(Keys.FILTER_MAX_SPEED);
+ filterMinPeriod = config.getInteger(Keys.FILTER_MIN_PERIOD) * 1000;
+ skipLimit = config.getLong(Keys.FILTER_SKIP_LIMIT) * 1000;
+ skipAttributes = config.getBoolean(Keys.FILTER_SKIP_ATTRIBUTES_ENABLE);
+ }
+
+ private boolean filterInvalid(Position position) {
+ return filterInvalid && (!position.getValid()
+ || position.getLatitude() > 90 || position.getLongitude() > 180
+ || position.getLatitude() < -90 || position.getLongitude() < -180);
+ }
+
+ private boolean filterZero(Position position) {
+ return filterZero && position.getLatitude() == 0.0 && position.getLongitude() == 0.0;
+ }
+
+ private boolean filterDuplicate(Position position, Position last) {
+ if (filterDuplicate && last != null && position.getFixTime().equals(last.getFixTime())) {
+ for (String key : position.getAttributes().keySet()) {
+ if (!last.getAttributes().containsKey(key)) {
+ return false;
+ }
+ }
+ return true;
+ }
+ return false;
+ }
+
+ private boolean filterFuture(Position position) {
+ return filterFuture != 0 && position.getFixTime().getTime() > System.currentTimeMillis() + filterFuture;
+ }
+
+ private boolean filterAccuracy(Position position) {
+ return filterAccuracy != 0 && position.getAccuracy() > filterAccuracy;
+ }
+
+ private boolean filterApproximate(Position position) {
+ return filterApproximate && position.getBoolean(Position.KEY_APPROXIMATE);
+ }
+
+ private boolean filterStatic(Position position) {
+ return filterStatic && position.getSpeed() == 0.0;
+ }
+
+ private boolean filterDistance(Position position, Position last) {
+ if (filterDistance != 0 && last != null) {
+ return position.getDouble(Position.KEY_DISTANCE) < filterDistance;
+ }
+ return false;
+ }
+
+ private boolean filterMaxSpeed(Position position, Position last) {
+ if (filterMaxSpeed != 0 && last != null) {
+ double distance = position.getDouble(Position.KEY_DISTANCE);
+ double time = position.getFixTime().getTime() - last.getFixTime().getTime();
+ return UnitsConverter.knotsFromMps(distance / (time / 1000)) > filterMaxSpeed;
+ }
+ return false;
+ }
+
+ private boolean filterMinPeriod(Position position, Position last) {
+ if (filterMinPeriod != 0 && last != null) {
+ long time = position.getFixTime().getTime() - last.getFixTime().getTime();
+ return time > 0 && time < filterMinPeriod;
+ }
+ return false;
+ }
+
+ private boolean skipLimit(Position position, Position last) {
+ if (skipLimit != 0 && last != null) {
+ return (position.getServerTime().getTime() - last.getServerTime().getTime()) > skipLimit;
+ }
+ return false;
+ }
+
+ private boolean skipAttributes(Position position) {
+ if (skipAttributes) {
+ String attributesString = Context.getIdentityManager().lookupAttributeString(
+ position.getDeviceId(), "filter.skipAttributes", "", true);
+ for (String attribute : attributesString.split("[ ,]")) {
+ if (position.getAttributes().containsKey(attribute)) {
+ return true;
+ }
+ }
+ }
+ return false;
+ }
+
+ private boolean filter(Position position) {
+
+ StringBuilder filterType = new StringBuilder();
+
+ Position last = null;
+ if (Context.getIdentityManager() != null) {
+ last = Context.getIdentityManager().getLastPosition(position.getDeviceId());
+ }
+
+ if (skipLimit(position, last) || skipAttributes(position)) {
+ return false;
+ }
+
+ if (filterInvalid(position)) {
+ filterType.append("Invalid ");
+ }
+ if (filterZero(position)) {
+ filterType.append("Zero ");
+ }
+ if (filterDuplicate(position, last)) {
+ filterType.append("Duplicate ");
+ }
+ if (filterFuture(position)) {
+ filterType.append("Future ");
+ }
+ if (filterAccuracy(position)) {
+ filterType.append("Accuracy ");
+ }
+ if (filterApproximate(position)) {
+ filterType.append("Approximate ");
+ }
+ if (filterStatic(position)) {
+ filterType.append("Static ");
+ }
+ if (filterDistance(position, last)) {
+ filterType.append("Distance ");
+ }
+ if (filterMaxSpeed(position, last)) {
+ filterType.append("MaxSpeed ");
+ }
+ if (filterMinPeriod(position, last)) {
+ filterType.append("MinPeriod ");
+ }
+
+ if (filterType.length() > 0) {
+
+ StringBuilder message = new StringBuilder();
+ message.append("Position filtered by ");
+ message.append(filterType.toString());
+ message.append("filters from device: ");
+ message.append(Context.getIdentityManager().getById(position.getDeviceId()).getUniqueId());
+
+ LOGGER.info(message.toString());
+ return true;
+ }
+
+ return false;
+ }
+
+ @Override
+ protected Position handlePosition(Position position) {
+ if (filter(position)) {
+ return null;
+ }
+ return position;
+ }
+
+}