package org.traccar.protocol; import org.jboss.netty.bootstrap.ServerBootstrap; import org.jboss.netty.buffer.ChannelBuffer; import org.jboss.netty.buffer.ChannelBuffers; import org.jboss.netty.channel.ChannelPipeline; import org.traccar.BaseProtocol; import org.traccar.TrackerServer; import org.traccar.database.ActiveDevice; import org.traccar.helper.Crc; import org.traccar.http.commands.CommandType; import org.traccar.http.commands.NoParameterCommand; import org.traccar.protocol.commands.CommandTemplate; import java.util.List; import java.util.Map; public class Gt06Protocol extends BaseProtocol { public Gt06Protocol() { super("gt06"); } @Override protected void loadCommandsTemplates(Map templates) { templates.put(CommandType.STOP_ENGINE, new Gt06CommandTemplate("DYD#")); templates.put(CommandType.RESUME_ENGINE, new Gt06CommandTemplate("HFYD#")); } @Override public void addTrackerServersTo(List serverList) { serverList.add(new TrackerServer(new ServerBootstrap(), this.getName()) { @Override protected void addSpecificHandlers(ChannelPipeline pipeline) { pipeline.addLast("frameDecoder", new Gt06FrameDecoder()); pipeline.addLast("objectDecoder", new Gt06ProtocolDecoder(Gt06Protocol.this)); } }); } class Gt06CommandTemplate implements CommandTemplate { private String commandContent; public Gt06CommandTemplate(String commandContent) { this.commandContent = commandContent; } @Override public Object applyTo(ActiveDevice activeDevice, NoParameterCommand command) { int serverFlagBit = 0x0; int commandLength = serverFlagBit + commandContent.length(); int packetLength = 0x80 /*Protocol Number */ + commandContent.length() /* Information Content */ + 2 /*Information Serial Number */+ 2 /*Error Check */; int informationSerialNumber = 1; ChannelBuffer response = ChannelBuffers.directBuffer(10); response.writeBytes(new byte[]{0x78, 0x78}); // Start Bit response.writeByte(packetLength); // Packet Length response.writeByte(0x80); // Protocol Number // Information Content response.writeByte(commandLength); // Length of command response.writeByte(serverFlagBit); // Server Flag Bit response.writeBytes(commandContent.getBytes()); // Command Content response.writeBytes(new byte[]{0x00, 0x02}); // Language response.writeShort(informationSerialNumber); // Information Serial Number int crc = Crc.crc16Ccitt(response.toByteBuffer(2, response.writerIndex())); response.writeShort(crc); // Error Check response.writeBytes(new byte[] {0x0D, 0x0A}); // Stop Bit return response; } } }