mirror of
https://github.com/traccar/traccar.git
synced 2025-01-09 04:07:38 +08:00
commit
47274f7387
129
src/org/traccar/protocol/Ev603ProtocolDecoder.java
Normal file
129
src/org/traccar/protocol/Ev603ProtocolDecoder.java
Normal file
@ -0,0 +1,129 @@
|
||||
/*
|
||||
* Copyright 2012 Anton Tananaev (anton.tananaev@gmail.com)
|
||||
* Enhancement done by 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.util.Calendar;
|
||||
import java.util.TimeZone;
|
||||
import java.util.regex.Matcher;
|
||||
import java.util.regex.Pattern;
|
||||
import org.jboss.netty.channel.Channel;
|
||||
import org.jboss.netty.channel.ChannelHandlerContext;
|
||||
import org.traccar.GenericProtocolDecoder;
|
||||
import org.traccar.model.DataManager;
|
||||
import org.traccar.model.Position;
|
||||
|
||||
/**
|
||||
*
|
||||
* Ev603 Protocol Decoder
|
||||
*/
|
||||
public class Ev603ProtocolDecoder extends GenericProtocolDecoder{
|
||||
|
||||
/**
|
||||
* Initialize
|
||||
*/
|
||||
public Ev603ProtocolDecoder(DataManager dataManager, Integer resetDelay) {
|
||||
super(dataManager, resetDelay);
|
||||
}
|
||||
|
||||
/**
|
||||
* Regular expressions pattern
|
||||
*/
|
||||
static private Pattern pattern = Pattern.compile(
|
||||
"!A," + // Start Character
|
||||
"([\\d]{2})\\/([\\d]{2})\\/([\\d]{2})," + // Date dd/mm/YY
|
||||
"([\\d]{2}):([\\d]{2}):([\\d]{2})," + // Time hh:mm:ss
|
||||
"(-?[\\d]{2})([\\d]{2}.[\\d]{4})," + // Latitude (DDMM.MMMM)
|
||||
"(-?[\\d]{3})([\\d]{2}.[\\d]{4})," + // Longitude (DDDMM.MMMM)
|
||||
"([\\d]+.[\\d]{2})," + // Speed
|
||||
"([\\d]{2-3}+.[\\d]{1-3})," + // degrees
|
||||
".*");
|
||||
|
||||
static private Pattern deviceImei = Pattern.compile("([\\d]+);");
|
||||
|
||||
/**
|
||||
* Decode message
|
||||
*/
|
||||
protected Object decode(
|
||||
ChannelHandlerContext ctx, Channel channel, Object msg)
|
||||
throws Exception {
|
||||
|
||||
String sentence = (String) msg;
|
||||
|
||||
// Parse message
|
||||
Matcher parser = pattern.matcher(sentence);
|
||||
if (!parser.matches()) {
|
||||
return null;
|
||||
}
|
||||
|
||||
// Create new position
|
||||
Position position = new Position();
|
||||
StringBuilder extendedInfo = new StringBuilder("<protocol>ev603</protocol>");
|
||||
|
||||
// Get imei from First message
|
||||
if (sentence.contains("!1,")) {
|
||||
Matcher imeiparser = deviceImei.matcher(sentence);
|
||||
if (!imeiparser.matches()){
|
||||
return null;
|
||||
}else{
|
||||
String imei = imeiparser.group(1);
|
||||
position.setDeviceId(getDataManager().getDeviceByImei(imei).getId());
|
||||
}
|
||||
}
|
||||
|
||||
Integer index = 1;
|
||||
|
||||
// Date
|
||||
Calendar time = Calendar.getInstance(TimeZone.getTimeZone("UTC"));
|
||||
time.clear();
|
||||
time.set(Calendar.DAY_OF_MONTH, Integer.valueOf(parser.group(index++)));
|
||||
time.set(Calendar.MONTH, Integer.valueOf(parser.group(index++)) - 1);
|
||||
time.set(Calendar.YEAR, 2000 + Integer.valueOf(parser.group(index++)));
|
||||
|
||||
// Time
|
||||
time.set(Calendar.HOUR, Integer.valueOf(parser.group(index++)));
|
||||
time.set(Calendar.MINUTE, Integer.valueOf(parser.group(index++)));
|
||||
time.set(Calendar.SECOND, Integer.valueOf(parser.group(index++)));
|
||||
position.setTime(time.getTime());
|
||||
|
||||
// Validity
|
||||
position.setValid(true);
|
||||
|
||||
// Latitude
|
||||
Double latitude = Double.valueOf(parser.group(index++));
|
||||
latitude += Double.valueOf(parser.group(index++)) / 60;
|
||||
position.setLatitude(latitude);
|
||||
|
||||
// Longitude
|
||||
Double lonlitude = Double.valueOf(parser.group(index++));
|
||||
lonlitude += Double.valueOf(parser.group(index++)) / 60;
|
||||
position.setLongitude(lonlitude);
|
||||
|
||||
// Altitude
|
||||
position.setAltitude(0.0);
|
||||
|
||||
// Speed
|
||||
position.setSpeed(Double.valueOf(parser.group(index++)));
|
||||
position.setCourse(0.0);
|
||||
|
||||
// Extended info
|
||||
extendedInfo.append("<course>");
|
||||
extendedInfo.append(parser.group(index++));
|
||||
extendedInfo.append("</course>");
|
||||
|
||||
return position;
|
||||
}
|
||||
}
|
Loading…
Reference in New Issue
Block a user