aboutsummaryrefslogtreecommitdiff
path: root/src/org/traccar
diff options
context:
space:
mode:
Diffstat (limited to 'src/org/traccar')
-rw-r--r--src/org/traccar/Server.java20
-rw-r--r--src/org/traccar/TrackerEventHandler.java11
-rw-r--r--src/org/traccar/helper/NamedParameterStatement.java6
-rw-r--r--src/org/traccar/http/WebServer.java194
-rw-r--r--src/org/traccar/model/DataManager.java9
-rw-r--r--src/org/traccar/model/DatabaseDataManager.java130
6 files changed, 73 insertions, 297 deletions
diff --git a/src/org/traccar/Server.java b/src/org/traccar/Server.java
index d4e4a94cb..e1d9efa3d 100644
--- a/src/org/traccar/Server.java
+++ b/src/org/traccar/Server.java
@@ -111,17 +111,11 @@ public class Server {
initMeitrackServer(properties);
initSkypatrolServer(properties);
initGt02Server(properties);
- initGt06Server(properties);
+ initGt06Server(properties);
// Initialize web server
if (Boolean.valueOf(properties.getProperty("http.enable"))) {
- Integer port = Integer.valueOf(properties.getProperty("http.port", "8082"));
- String address = properties.getProperty("http.address");
- if (address != null) {
- webServer = new WebServer(address, port, dataManager);
- } else {
- webServer = new WebServer(port, dataManager);
- }
+ webServer = new WebServer(properties);
}
}
@@ -144,11 +138,11 @@ public class Server {
for (Object server: serverList) {
((TrackerServer) server).stop();
}
-
+
// Release resources
GlobalChannelFactory.release();
GlobalTimer.release();
-
+
if (webServer != null) {
webServer.stop();
}
@@ -638,7 +632,7 @@ public class Server {
serverList.add(server);
}
}
-
+
/**
* Init EV603 server
*/
@@ -666,7 +660,7 @@ public class Server {
serverList.add(server);
}
}
-
+
/**
* Init V680 server
*/
@@ -694,7 +688,7 @@ public class Server {
serverList.add(server);
}
}
-
+
/**
* Init PT502 server
*/
diff --git a/src/org/traccar/TrackerEventHandler.java b/src/org/traccar/TrackerEventHandler.java
index 11cf41fad..538e71cdf 100644
--- a/src/org/traccar/TrackerEventHandler.java
+++ b/src/org/traccar/TrackerEventHandler.java
@@ -38,7 +38,7 @@ public class TrackerEventHandler extends IdleStateAwareChannelHandler {
super();
dataManager = newDataManager;
}
-
+
private void processSinglePosition(Position position) {
if (position == null) {
Log.info("null message");
@@ -58,7 +58,10 @@ public class TrackerEventHandler extends IdleStateAwareChannelHandler {
// Write position to database
try {
- dataManager.addPosition(position);
+ Long id = dataManager.addPosition(position);
+ if (id != null) {
+ dataManager.updateLatestPosition(position.getDeviceId(), id);
+ }
} catch (Exception error) {
Log.info("Exception during query execution");
Log.warning(error.getMessage());
@@ -82,7 +85,7 @@ public class TrackerEventHandler extends IdleStateAwareChannelHandler {
Log.info("Closing connection by disconnect");
e.getChannel().close();
}
-
+
@Override
public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) {
Log.info("Closing connection by exception");
@@ -94,5 +97,5 @@ public class TrackerEventHandler extends IdleStateAwareChannelHandler {
Log.info("Closing connection by timeout");
e.getChannel().close();
}
-
+
}
diff --git a/src/org/traccar/helper/NamedParameterStatement.java b/src/org/traccar/helper/NamedParameterStatement.java
index cbbc187da..500fbe4b3 100644
--- a/src/org/traccar/helper/NamedParameterStatement.java
+++ b/src/org/traccar/helper/NamedParameterStatement.java
@@ -16,8 +16,8 @@
package org.traccar.helper;
import java.sql.*;
-import java.util.Date;
import java.util.*;
+import java.util.Date;
public class NamedParameterStatement {
@@ -40,7 +40,7 @@ public class NamedParameterStatement {
* Database connection
*/
private AdvancedConnection connection;
-
+
private int autoGeneratedKeys;
/**
@@ -108,7 +108,7 @@ public class NamedParameterStatement {
return parsedQuery.toString();
}
-
+
public void reset(boolean resetConnection) throws SQLException {
if (statement != null) {
statement.close();
diff --git a/src/org/traccar/http/WebServer.java b/src/org/traccar/http/WebServer.java
index aac334cc6..59c212d01 100644
--- a/src/org/traccar/http/WebServer.java
+++ b/src/org/traccar/http/WebServer.java
@@ -21,14 +21,19 @@ import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.InetSocketAddress;
import java.util.Iterator;
+import java.util.Properties;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
+import javax.naming.Context;
+import javax.naming.InitialContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
+import javax.sql.DataSource;
import org.eclipse.jetty.server.Request;
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.server.handler.AbstractHandler;
+import org.eclipse.jetty.webapp.WebAppContext;
import org.traccar.helper.Log;
import org.traccar.model.DataManager;
import org.traccar.model.Device;
@@ -41,183 +46,40 @@ public class WebServer {
private Server server;
- public class WebHandler extends AbstractHandler {
-
- private DataManager dataManager;
-
- public static final int BUFFER_SIZE = 1024;
-
- public WebHandler(DataManager dataManager) {
- this.dataManager = dataManager;
- }
-
- public void handleIndex(String target,Request baseRequest,HttpServletRequest request,HttpServletResponse response)
- throws IOException, ServletException {
-
- response.setContentType("text/html");
-
- InputStream in = this.getClass().getClassLoader().getResourceAsStream("web/index.html");
- OutputStream out = response.getOutputStream();
-
- byte[] buffer = new byte[BUFFER_SIZE];
- int count;
- while ((count = in.read(buffer)) != -1) {
- out.write(buffer, 0, count);
- }
- out.flush();
- }
-
- public void handleIcon(String target,Request baseRequest,HttpServletRequest request,HttpServletResponse response)
- throws IOException, ServletException {
-
- response.setContentType("image/x-icon");
-
- InputStream in = this.getClass().getClassLoader().getResourceAsStream("web/favicon.ico");
- OutputStream out = response.getOutputStream();
-
- byte[] buffer = new byte[BUFFER_SIZE];
- int count;
- while ((count = in.read(buffer)) != -1) {
- out.write(buffer, 0, count);
- }
- out.flush();
- }
-
- private Device parseDevice(String json) {
-
- Pattern pattern = Pattern.compile("\\{\"id\":(\\d+),\"imei\":\"(.*)\"\\}");
- Matcher parser = pattern.matcher(json);
- if (parser.matches()) {
- Device device = new Device();
- device.setId(Long.valueOf(parser.group(1)));
- device.setImei(parser.group(2));
- return device;
- }
-
- return null;
- }
-
- // TODO: separate method into small parts
- public void handleData(String target,Request baseRequest,HttpServletRequest request,HttpServletResponse response)
- throws IOException, ServletException {
-
- response.setContentType("application/json");
-
- PrintWriter out = response.getWriter();
-
- try {
- if (target.equals("/devices.json")) {
-
- String action = request.getParameter("action");
- if (action == null) {
- Iterator<Device> i = dataManager.getDevices().iterator();
- out.print("{'success':true,'results':[");
- while (i.hasNext()) {
- Device device = i.next();
- out.format("{'id':%d,'imei':'%s'}",
- device.getId(),
- device.getImei());
- if (i.hasNext()) out.print(",");
- }
- } else if (action.equals("create")) {
- Device device = parseDevice(request.getReader().readLine());
- dataManager.addDevice(device);
- out.print("{'success':true,'results':[");
- out.format("{'id':%d,'imei':'%s'}",
- device.getId(),
- device.getImei());
- } else if (action.equals("update")) {
- Device device = parseDevice(request.getReader().readLine());
- dataManager.updateDevice(device);
- out.print("{'success':true,'results':[");
- out.format("{'id':%d,'imei':'%s'}",
- device.getId(),
- device.getImei());
- } else if (action.equals("destroy")) {
- Device device = parseDevice(request.getReader().readLine());
- dataManager.removeDevice(device);
- out.print("{'success':true,'results':[");
- }
-
- } else if (target.equals("/positions.json")) {
-
- out.print("{'success':true,'results':[");
- String deviceId = request.getParameter("deviceId");
- if (deviceId != null) {
- Iterator<Position> i = dataManager.getPositions(Long.valueOf(deviceId)).iterator();
- while (i.hasNext()) {
- Position position = i.next();
- out.format("{'device_id':%d,'time':'%tF %tT','valid':%b,'latitude':%f,'longitude':%f,'speed':%f,'course':%f}",
- position.getDeviceId(),
- position.getTime(), position.getTime(),
- position.getValid(),
- position.getLatitude(),
- position.getLongitude(),
- position.getSpeed(),
- position.getCourse());
- if (i.hasNext()) out.print(",");
- }
- }
-
- }
- } catch (Exception error) {
- out.print("{'success':false,'results':[");
- Log.warning(error.getMessage());
- }
-
- out.print("]}");
- out.flush();
- }
-
- public void handleOther(String target,Request baseRequest,HttpServletRequest request,HttpServletResponse response)
- throws IOException, ServletException {
- response.sendRedirect(response.encodeRedirectURL("/"));
- }
+ private void initDataSource(Properties properties) {
+ try {
- @Override
- public void handle(String target,Request baseRequest,HttpServletRequest request,HttpServletResponse response)
- throws IOException, ServletException
- {
- if (target.equals("/") || target.equals("/index.html")) {
- handleIndex(target, baseRequest, request, response);
- } else if (target.equals("/favicon.ico")) {
- handleIcon(target, baseRequest, request, response);
- } else if (target.matches("/.+\\.json")) {
- handleData(target, baseRequest, request, response);
- } else {
- handleOther(target, baseRequest, request, response);
- }
- }
- }
+ Context context = new InitialContext();
- public WebServer(Integer port, DataManager dataManager) {
- server = new Server(port);
- server.setHandler(new WebHandler(dataManager));
+ Class clazz = Class.forName(properties.getProperty("database.dataSource"));
- /*WebAppContext webapp = new WebAppContext();
- webapp.setContextPath("/");
- webapp.setWar("/home/user/Documents/traccar-web/target/traccar-web-1.0-SNAPSHOT.war");
- try {
-
- Context context = new InitialContext();
-
- Class clazz = Class.forName("org.h2.jdbcx.JdbcDataSource");
-
DataSource ds = (DataSource) clazz.newInstance();
- clazz.getMethod("setURL", String.class).invoke(ds, "jdbc:h2:/home/user/Documents/traccar/target/database2");
- clazz.getMethod("setUser", String.class).invoke(ds, "sa");
- //clazz.getMethod("setPassword", String.class).invoke(ds, "");
+ clazz.getMethod("setURL", String.class).invoke(ds, properties.getProperty("database.url"));
+ clazz.getMethod("setUser", String.class).invoke(ds, properties.getProperty("database.user"));
+ clazz.getMethod("setPassword", String.class).invoke(ds, properties.getProperty("database.password"));
context.bind("java:/DefaultDS", ds);
} catch (Exception error) {
+ Log.warning(error.getMessage());
}
- server.setHandler(webapp);*/
}
- public WebServer(String address, Integer port, DataManager dataManager) {
- server = new Server(new InetSocketAddress(address, port));
- server.setHandler(new WebHandler(dataManager));
+ public WebServer(Properties properties) {
+ String address = properties.getProperty("http.address");
+ Integer port = Integer.valueOf(properties.getProperty("http.port", "8082"));
+ if (address == null) {
+ server = new Server(port);
+ } else {
+ server = new Server(new InetSocketAddress(address, port));
+ }
+
+ initDataSource(properties);
+
+ WebAppContext webapp = new WebAppContext();
+ webapp.setContextPath("/");
+ webapp.setWar(properties.getProperty("http.application"));
+ server.setHandler(webapp);
}
public void start() {
diff --git a/src/org/traccar/model/DataManager.java b/src/org/traccar/model/DataManager.java
index 423c540da..4a5aaa348 100644
--- a/src/org/traccar/model/DataManager.java
+++ b/src/org/traccar/model/DataManager.java
@@ -26,17 +26,12 @@ public interface DataManager {
* Manage devices
*/
public List<Device> getDevices() throws Exception;
- public void addDevice(Device device) throws Exception;
- public void updateDevice(Device device) throws Exception;
- public void removeDevice(Device device) throws Exception;
public Device getDeviceByImei(String imei) throws Exception;
- public Device getDeviceByPhoneNumber(String phoneNumber) throws Exception;
- public Device getDeviceByUniqueId(String uniqueId) throws Exception;
/**
* Manage positions
*/
- public void addPosition(Position position) throws Exception;
- public List<Position> getPositions(Long deviceId) throws Exception;
+ public Long addPosition(Position position) throws Exception;
+ public void updateLatestPosition(Long deviceId, Long positionId) throws Exception;
}
diff --git a/src/org/traccar/model/DatabaseDataManager.java b/src/org/traccar/model/DatabaseDataManager.java
index 073d6ef71..ee86e6370 100644
--- a/src/org/traccar/model/DatabaseDataManager.java
+++ b/src/org/traccar/model/DatabaseDataManager.java
@@ -18,7 +18,6 @@ package org.traccar.model;
import java.sql.*;
import java.util.*;
import org.traccar.helper.AdvancedConnection;
-import org.traccar.helper.Log;
import org.traccar.helper.NamedParameterStatement;
/**
@@ -35,11 +34,8 @@ public class DatabaseDataManager implements DataManager {
* Database statements
*/
private NamedParameterStatement queryGetDevices;
- private NamedParameterStatement queryAddDevice;
- private NamedParameterStatement queryUpdateDevice;
- private NamedParameterStatement queryRemoveDevice;
- private NamedParameterStatement queryGetPositions;
private NamedParameterStatement queryAddPosition;
+ private NamedParameterStatement queryUpdateLatestPosition;
/**
* Initialize database
@@ -75,42 +71,18 @@ public class DatabaseDataManager implements DataManager {
queryGetDevices = new NamedParameterStatement(connection, query);
}
- query = properties.getProperty("database.insertDevice");
- if (query != null) {
- queryAddDevice = new NamedParameterStatement(connection, query);
- }
-
- query = properties.getProperty("database.updateDevice");
- if (query != null) {
- queryUpdateDevice = new NamedParameterStatement(connection, query);
- }
-
- query = properties.getProperty("database.deleteDevice");
- if (query != null) {
- queryRemoveDevice = new NamedParameterStatement(connection, query);
- }
-
- query = properties.getProperty("database.selectPosition");
- if (query != null) {
- queryGetPositions = new NamedParameterStatement(connection, query);
- }
-
query = properties.getProperty("database.insertPosition");
if (query != null) {
queryAddPosition = new NamedParameterStatement(connection, query);
}
- // Create database schema
- query = properties.getProperty("database.initialize");
- if (query != null) try {
- NamedParameterStatement initializeQuery = new NamedParameterStatement(connection, query);
- initializeQuery.prepare();
- initializeQuery.executeUpdate();
- } catch (Exception error) {
- Log.warning(error.getMessage());
+ query = properties.getProperty("database.updateLatestPosition");
+ if (query != null) {
+ queryUpdateLatestPosition = new NamedParameterStatement(connection, query);
}
}
+ @Override
public synchronized List<Device> getDevices() throws SQLException {
List<Device> deviceList = new LinkedList<Device>();
@@ -127,40 +99,6 @@ public class DatabaseDataManager implements DataManager {
return deviceList;
}
- public synchronized void addDevice(Device device) throws SQLException {
-
- queryAddDevice.prepare(Statement.RETURN_GENERATED_KEYS);
- queryAddDevice.setString("imei", device.getImei());
- queryAddDevice.executeUpdate();
-
- // Find generated id
- ResultSet result = queryAddDevice.getGeneratedKeys();
- if (result.next()) {
- device.setId(result.getLong(1));
- }
-
- devices = null;
- }
-
- public synchronized void updateDevice(Device device) throws SQLException {
-
- queryUpdateDevice.prepare();
- queryUpdateDevice.setLong("id", device.getId());
- queryUpdateDevice.setString("imei", device.getImei());
- queryUpdateDevice.executeUpdate();
-
- devices = null;
- }
-
- public synchronized void removeDevice(Device device) throws SQLException {
-
- queryRemoveDevice.prepare();
- queryRemoveDevice.setLong("id", device.getId());
- queryRemoveDevice.executeUpdate();
-
- devices = null;
- }
-
/**
* Devices cache
*/
@@ -168,6 +106,7 @@ public class DatabaseDataManager implements DataManager {
private Calendar devicesLastUpdate;
private Long devicesRefreshDelay;
+ @Override
public Device getDeviceByImei(String imei) throws SQLException {
if ((devices == null) || (Calendar.getInstance().getTimeInMillis() - devicesLastUpdate.getTimeInMillis() > devicesRefreshDelay)) {
@@ -182,43 +121,10 @@ public class DatabaseDataManager implements DataManager {
return devices.get(imei);
}
- public Device getDeviceByPhoneNumber(String phoneNumber) {
- // TODO: implement getDeviceByPhoneNumber
- return null;
- }
-
- public Device getDeviceByUniqueId(String uniqueId) {
- // TODO: implement getDeviceByUniqueId
- return null;
- }
-
- public synchronized List<Position> getPositions(Long deviceId) throws SQLException {
-
- List<Position> positionList = new LinkedList<Position>();
-
- queryGetPositions.prepare();
- queryGetPositions.setLong("device_id", deviceId);
- ResultSet result = queryGetPositions.executeQuery();
- while (result.next()) {
- // TODO: include other parameters
- Position position = new Position();
- position.setDeviceId(result.getLong("device_id"));
- position.setTime(result.getTimestamp("time"));
- position.setValid(result.getBoolean("valid"));
- position.setLatitude(result.getDouble("latitude"));
- position.setLongitude(result.getDouble("longitude"));
- position.setSpeed(result.getDouble("speed"));
- position.setCourse(result.getDouble("course"));
- position.setPower(result.getDouble("power"));
- positionList.add(position);
- }
-
- return positionList;
- }
-
- public synchronized void addPosition(Position position) throws SQLException {
+ @Override
+ public synchronized Long addPosition(Position position) throws SQLException {
- queryAddPosition.prepare();
+ queryAddPosition.prepare(Statement.RETURN_GENERATED_KEYS);
queryAddPosition.setLong("id", position.getId());
queryAddPosition.setLong("device_id", position.getDeviceId());
@@ -235,7 +141,23 @@ public class DatabaseDataManager implements DataManager {
queryAddPosition.executeUpdate();
- // TODO: probably return row id
+ ResultSet result = queryAddPosition.getGeneratedKeys();
+ if (result != null && result.next()) {
+ return result.getLong(1);
+ }
+
+ return null;
+ }
+
+ @Override
+ public void updateLatestPosition(Long deviceId, Long positionId) throws SQLException {
+
+ queryUpdateLatestPosition.prepare();
+
+ queryUpdateLatestPosition.setLong("device_id", deviceId);
+ queryUpdateLatestPosition.setLong("id", positionId);
+
+ queryUpdateLatestPosition.executeUpdate();
}
}
generated by cgit v1.2.3 (git 2.39.1) at 2024-11-05 04:36:11 +0000