/* * Copyright 2012 - 2015 Anton Tananaev (anton.tananaev@gmail.com) * Copyright 2012 Luis Parada (luis.parada@gmail.com) * * 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 java.net.SocketAddress; import java.util.regex.Pattern; import org.jboss.netty.channel.Channel; import org.traccar.BaseProtocolDecoder; import org.traccar.helper.DateBuilder; import org.traccar.helper.Parser; import org.traccar.helper.PatternBuilder; import org.traccar.model.Event; import org.traccar.model.Position; public class Pt502ProtocolDecoder extends BaseProtocolDecoder { public Pt502ProtocolDecoder(Pt502Protocol protocol) { super(protocol); } private static final Pattern PATTERN = new PatternBuilder() .any().text("$") .expression("[A-Z]{3}") .number("d?,") // type .number("(d+),") // id .number("(dd)(dd)(dd).(ddd),") // time .expression("([AV]),") // validity .number("(dd)(dd.dddd),") // latitude .expression("([NS]),") .number("(ddd)(dd.dddd),") // longitude .expression("([EW]),") .number("(d+.d+)?,") // speed .number("(d+.d+)?,") // course .number("(dd)(dd)(dd),,,") // date .expression("./") .expression("([01])+,") // input .expression("([01])+/") // output .expression("([^/]+)?/") // adc .number("(d+)") // odometer .expression("/([^/]+)?/") // rfid .number("(xxx)").optional(2) // state .any() .compile(); @Override protected Object decode( Channel channel, SocketAddress remoteAddress, Object msg) throws Exception { Parser parser = new Parser(PATTERN, (String) msg); if (!parser.matches()) { return null; } Position position = new Position(); position.setProtocol(getProtocolName()); if (!identify(parser.next(), channel, remoteAddress)) { return null; } position.setDeviceId(getDeviceId()); DateBuilder dateBuilder = new DateBuilder() .setTime(parser.nextInt(), parser.nextInt(), parser.nextInt(), parser.nextInt()); position.setValid(parser.next().equals("A")); position.setLatitude(parser.nextCoordinate()); position.setLongitude(parser.nextCoordinate()); position.setSpeed(parser.nextDouble()); position.setCourse(parser.nextDouble()); dateBuilder.setDateReverse(parser.nextInt(), parser.nextInt(), parser.nextInt()); position.setTime(dateBuilder.getDate()); position.set(Event.KEY_INPUT, parser.next()); position.set(Event.KEY_OUTPUT, parser.next()); if (parser.hasNext()) { String[] values = parser.next().split(","); for (int i = 0; i < values.length; i++) { position.set(Event.PREFIX_ADC + (i + 1), Integer.parseInt(values[i], 16)); } } position.set(Event.KEY_ODOMETER, parser.next()); position.set(Event.KEY_RFID, parser.next()); if (parser.hasNext()) { int value = parser.nextInt(16); position.set(Event.KEY_BATTERY, value >> 8); position.set(Event.KEY_GSM, (value >> 4) & 0xf); position.set(Event.KEY_SATELLITES, value & 0xf); } return position; } }