/* * Copyright 2013 - 2016 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 org.jboss.netty.channel.Channel; import org.jboss.netty.handler.codec.http.DefaultHttpResponse; import org.jboss.netty.handler.codec.http.HttpHeaders; import org.jboss.netty.handler.codec.http.HttpRequest; import org.jboss.netty.handler.codec.http.HttpResponse; import org.jboss.netty.handler.codec.http.HttpResponseStatus; import org.jboss.netty.handler.codec.http.HttpVersion; import org.jboss.netty.handler.codec.http.QueryStringDecoder; import org.joda.time.format.ISODateTimeFormat; import org.traccar.BaseProtocolDecoder; import org.traccar.DeviceSession; import org.traccar.model.Position; import java.net.SocketAddress; import java.nio.charset.StandardCharsets; import java.text.DateFormat; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; import java.util.Map; public class OsmAndProtocolDecoder extends BaseProtocolDecoder { public OsmAndProtocolDecoder(OsmAndProtocol protocol) { super(protocol); } private void sendResponse(Channel channel, HttpResponseStatus status) { if (channel != null) { HttpResponse response = new DefaultHttpResponse(HttpVersion.HTTP_1_1, status); response.headers().add(HttpHeaders.Names.CONTENT_LENGTH, 0); channel.write(response); } } @Override protected Object decode( Channel channel, SocketAddress remoteAddress, Object msg) throws Exception { HttpRequest request = (HttpRequest) msg; QueryStringDecoder decoder = new QueryStringDecoder(request.getUri()); Map<String, List<String>> params = decoder.getParameters(); if (params.isEmpty()) { decoder = new QueryStringDecoder(request.getContent().toString(StandardCharsets.US_ASCII), false); params = decoder.getParameters(); } Position position = new Position(); position.setProtocol(getProtocolName()); position.setValid(true); for (Map.Entry<String, List<String>> entry : params.entrySet()) { String value = entry.getValue().get(0); switch (entry.getKey()) { case "id": case "deviceid": DeviceSession deviceSession = getDeviceSession(channel, remoteAddress, value); if (deviceSession == null) { sendResponse(channel, HttpResponseStatus.BAD_REQUEST); return null; } position.setDeviceId(deviceSession.getDeviceId()); break; case "valid": position.setValid(Boolean.parseBoolean(value)); break; case "timestamp": try { long timestamp = Long.parseLong(value); if (timestamp < Integer.MAX_VALUE) { timestamp *= 1000; } position.setTime(new Date(timestamp)); } catch (NumberFormatException error) { if (value.contains("T")) { position.setTime(new Date( ISODateTimeFormat.dateTimeParser().parseMillis(value))); } else { DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); position.setTime(dateFormat.parse(value)); } } break; case "lat": position.setLatitude(Double.parseDouble(value)); break; case "lon": position.setLongitude(Double.parseDouble(value)); break; case "location": String[] location = value.split(","); position.setLatitude(Double.parseDouble(location[0])); position.setLongitude(Double.parseDouble(location[1])); break; case "speed": position.setSpeed(Double.parseDouble(value)); break; case "bearing": case "heading": position.setCourse(Double.parseDouble(value)); break; case "altitude": position.setAltitude(Double.parseDouble(value)); break; case "accuracy": position.setAccuracy(Double.parseDouble(value)); break; case "hdop": position.set(Position.KEY_HDOP, Double.parseDouble(value)); break; case "batt": position.set(Position.KEY_BATTERY_LEVEL, Double.parseDouble(value)); break; case "driverUniqueId": position.set(Position.KEY_DRIVER_UNIQUE_ID, value); break; default: try { position.set(entry.getKey(), Double.parseDouble(value)); } catch (NumberFormatException e) { position.set(entry.getKey(), value); } break; } } if (position.getFixTime() == null) { position.setTime(new Date()); } if (position.getDeviceId() != 0) { sendResponse(channel, HttpResponseStatus.OK); return position; } else { sendResponse(channel, HttpResponseStatus.BAD_REQUEST); return null; } } }