From 815c3de43ee8943fddb916f27317c37a7a806d65 Mon Sep 17 00:00:00 2001 From: Anton Tananaev Date: Tue, 19 Jul 2016 15:11:35 +1200 Subject: Move device id to a session --- src/org/traccar/protocol/CalAmpProtocolDecoder.java | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) (limited to 'src/org/traccar/protocol/CalAmpProtocolDecoder.java') diff --git a/src/org/traccar/protocol/CalAmpProtocolDecoder.java b/src/org/traccar/protocol/CalAmpProtocolDecoder.java index 69fca3914..99edb9fb7 100644 --- a/src/org/traccar/protocol/CalAmpProtocolDecoder.java +++ b/src/org/traccar/protocol/CalAmpProtocolDecoder.java @@ -19,6 +19,7 @@ import org.jboss.netty.buffer.ChannelBuffer; import org.jboss.netty.buffer.ChannelBuffers; import org.jboss.netty.channel.Channel; import org.traccar.BaseProtocolDecoder; +import org.traccar.DeviceSession; import org.traccar.helper.BitUtil; import org.traccar.helper.UnitsConverter; import org.traccar.model.Position; @@ -63,10 +64,10 @@ public class CalAmpProtocolDecoder extends BaseProtocolDecoder { } } - private Position decodePosition(int type, ChannelBuffer buf) { + private Position decodePosition(DeviceSession deviceSession, int type, ChannelBuffer buf) { Position position = new Position(); - position.setDeviceId(getDeviceId()); + position.setDeviceId(deviceSession.getDeviceId()); position.setProtocol(getProtocolName()); position.setTime(new Date(buf.readUnsignedInt() * 1000)); @@ -157,7 +158,8 @@ public class CalAmpProtocolDecoder extends BaseProtocolDecoder { } } - identify(String.valueOf(id), channel, remoteAddress); + getDeviceSession(channel, remoteAddress, String.valueOf(id)); + } if (BitUtil.check(content, 1)) { @@ -182,7 +184,8 @@ public class CalAmpProtocolDecoder extends BaseProtocolDecoder { } - if (!hasDeviceId()) { + DeviceSession deviceSession = getDeviceSession(channel, remoteAddress); + if (deviceSession == null) { return null; } @@ -195,7 +198,7 @@ public class CalAmpProtocolDecoder extends BaseProtocolDecoder { } if (type == MSG_EVENT_REPORT || type == MSG_LOCATE_REPORT || type == MSG_MINI_EVENT_REPORT) { - return decodePosition(type, buf); + return decodePosition(deviceSession, type, buf); } return null; -- cgit v1.2.3