diff options
Diffstat (limited to 'src/org/traccar/protocol/FreematicsProtocolDecoder.java')
| -rw-r--r-- | src/org/traccar/protocol/FreematicsProtocolDecoder.java | 184 |
1 files changed, 0 insertions, 184 deletions
diff --git a/src/org/traccar/protocol/FreematicsProtocolDecoder.java b/src/org/traccar/protocol/FreematicsProtocolDecoder.java deleted file mode 100644 index ba47699c3..000000000 --- a/src/org/traccar/protocol/FreematicsProtocolDecoder.java +++ /dev/null @@ -1,184 +0,0 @@ -/* - * 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 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; - default: - position.set(data[0], 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; - } - -} |