/* * Copyright 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 org.traccar.BaseProtocolDecoder; import org.traccar.DeviceSession; import org.traccar.NetworkMessage; import org.traccar.Protocol; import org.traccar.helper.Checksum; import org.traccar.helper.DateBuilder; import org.traccar.helper.UnitsConverter; import org.traccar.model.Position; import java.net.SocketAddress; import java.util.Date; import java.util.LinkedList; import java.util.List; public class FreematicsProtocolDecoder extends BaseProtocolDecoder { public FreematicsProtocolDecoder(Protocol protocol) { super(protocol); } private Object decodeEvent( Channel channel, SocketAddress remoteAddress, String sentence) { DeviceSession deviceSession = null; String event = null; String time = null; for (String pair : sentence.split(",")) { String[] data = pair.split("="); String key = data[0]; String value = data[1]; switch (key) { case "ID": case "VIN": if (deviceSession == null) { deviceSession = getDeviceSession(channel, remoteAddress, value); } break; case "EV": event = value; break; case "TS": time = value; break; default: break; } } if (channel != null && deviceSession != null && event != null && time != null) { String message = String.format("1#EV=%s,RX=1,TS=%s", event, time); message += '*' + Checksum.sum(message); channel.writeAndFlush(new NetworkMessage(message, remoteAddress)); } return null; } private Object decodePosition( Channel channel, SocketAddress remoteAddress, String sentence) throws Exception { DeviceSession deviceSession = getDeviceSession(channel, remoteAddress); if (deviceSession == null) { return null; } List<Position> positions = new LinkedList<>(); Position position = null; DateBuilder dateBuilder = null; for (String pair : sentence.split(",")) { String[] data = pair.split("[=:]"); int key = Integer.parseInt(data[0], 16); String value = data[1]; switch (key) { case 0x0: if (position != null) { position.setTime(dateBuilder.getDate()); positions.add(position); } position = new Position(getProtocolName()); position.setDeviceId(deviceSession.getDeviceId()); position.setValid(true); dateBuilder = new DateBuilder(new Date()); break; case 0x11: value = ("000000" + value).substring(value.length()); dateBuilder.setDateReverse( Integer.parseInt(value.substring(0, 2)), Integer.parseInt(value.substring(2, 4)), Integer.parseInt(value.substring(4))); break; case 0x10: value = ("00000000" + value).substring(value.length()); dateBuilder.setTime( Integer.parseInt(value.substring(0, 2)), Integer.parseInt(value.substring(2, 4)), Integer.parseInt(value.substring(4, 6)), Integer.parseInt(value.substring(6)) * 10); break; case 0xA: position.setLatitude(Double.parseDouble(value)); break; case 0xB: position.setLongitude(Double.parseDouble(value)); break; case 0xC: position.setAltitude(Double.parseDouble(value)); break; case 0xD: position.setSpeed(UnitsConverter.knotsFromKph(Double.parseDouble(value))); break; case 0xE: position.setCourse(Integer.parseInt(value)); break; case 0xF: position.set(Position.KEY_SATELLITES, Integer.parseInt(value)); break; case 0x12: position.set(Position.KEY_HDOP, Integer.parseInt(value)); break; case 0x20: position.set(Position.KEY_ACCELERATION, value); break; case 0x24: position.set(Position.KEY_BATTERY, Integer.parseInt(value) * 0.01); break; case 0x81: position.set(Position.KEY_RSSI, Integer.parseInt(value)); break; case 0x82: position.set(Position.KEY_DEVICE_TEMP, Integer.parseInt(value) * 0.1); break; case 0x104: position.set(Position.KEY_ENGINE_LOAD, Integer.parseInt(value)); break; case 0x105: position.set(Position.KEY_COOLANT_TEMP, Integer.parseInt(value)); break; case 0x10c: position.set(Position.KEY_RPM, Integer.parseInt(value)); break; case 0x10d: position.set(Position.KEY_OBD_SPEED, UnitsConverter.knotsFromKph(Integer.parseInt(value))); break; case 0x111: position.set(Position.KEY_THROTTLE, Integer.parseInt(value)); break; default: position.set(Position.PREFIX_IO + key, value); break; } } if (position != null) { position.setTime(dateBuilder.getDate()); positions.add(position); } return positions; } @Override protected Object decode( Channel channel, SocketAddress remoteAddress, Object msg) throws Exception { String sentence = (String) msg; int startIndex = sentence.indexOf('#'); int endIndex = sentence.indexOf('*'); if (startIndex > 0 && endIndex > 0) { sentence = sentence.substring(startIndex + 1, endIndex); if (sentence.startsWith("EV")) { return decodeEvent(channel, remoteAddress, sentence); } else { return decodePosition(channel, remoteAddress, sentence); } } return null; } }