package publicsWay;
|
|
import java.util.concurrent.ConcurrentLinkedQueue;
|
import java.util.concurrent.atomic.AtomicBoolean;
|
import java.util.regex.Pattern;
|
import dell55AAData.DellGngga;
|
import dell55AAData.XTB;
|
|
import java.util.regex.Matcher;
|
import dell_system.MessageViewPanel;
|
import dell_targets.Dell_tag;
|
import targets.LocationTag;
|
|
import java.util.concurrent.ExecutorService;
|
import java.util.concurrent.Executors;
|
|
public class PacketProcessingSystemB {
|
// Ḭ̈߳²È«µÄ±¨ÎÄ´æ´¢¶ÓÁУ¨¼¯ºÏA£©
|
private static final ConcurrentLinkedQueue<HexPacket> packetQueue = new ConcurrentLinkedQueue<>();
|
private static final AtomicBoolean isRunning = new AtomicBoolean(false);
|
private static final ExecutorService parserExecutor = Executors.newSingleThreadExecutor();
|
private static Thread parserThread;
|
private static boolean a1 = true;
|
|
// ¿ÉÖØÓõÄDellGnggaʵÀý£¨Ḭ̈߳²È«£©
|
private static final ThreadLocal<DellGngga> dellGnggaParser = ThreadLocal.withInitial(DellGngga::new);
|
private static final ThreadLocal<XTB> dellXTB = ThreadLocal.withInitial(XTB::new);
|
// ±¨ÎÄ´æ´¢½á¹¹
|
public static class HexPacket {
|
public final String ip;
|
public final int port;
|
public final String hexData;
|
public final long timestamp;
|
|
public HexPacket(String ip, int port, String hexData, long timestamp) {
|
this.ip = ip;
|
this.port = port;
|
this.hexData = hexData;
|
this.timestamp = timestamp;
|
}
|
|
public String getIp() {
|
return ip;
|
}
|
|
public int getPort() {
|
return port;
|
}
|
|
public String getHexData() {
|
return hexData;
|
}
|
|
public long getTimestamp() {
|
return timestamp;
|
}
|
}
|
|
// ½ÓÊն˴洢±¨ÎÄ£¨UDPPortAReceiverÖе÷Óã©
|
public static void storePacket(String ip, int port, String hexData) {
|
if (a1) {
|
startProcessing();
|
a1 = false;
|
}
|
if (packetQueue.size() < 100000) { // ÏÞÖƶÓÁдóС·ÀÖ¹OOM
|
packetQueue.offer(new HexPacket(ip, port, hexData, System.currentTimeMillis()));
|
}
|
}
|
|
// Æô¶¯½âÎöϵͳ
|
public static void startProcessing() {
|
if (isRunning.get()) return;
|
|
isRunning.set(true);
|
parserThread = new Thread(() -> {
|
while (isRunning.get()) {
|
HexPacket packet = packetQueue.poll();
|
if (packet == null) {
|
Thread.yield(); // ¶ÓÁÐΪ¿ÕʱÈóöCPU
|
continue;
|
}
|
|
try {
|
String receivedata = packet.hexData;
|
String ip = packet.getIp();
|
int port = packet.getPort();
|
processData(receivedata, ip, port);
|
|
} catch (Exception e) {
|
System.err.println("½âÎö´íÎó: " + e.getMessage());
|
}
|
}
|
});
|
|
parserThread.setDaemon(true);
|
parserThread.start();
|
}
|
|
// Í£Ö¹½âÎöϵͳ
|
public static void stopProcessing() {
|
isRunning.set(false);
|
parserExecutor.shutdownNow();
|
if (parserThread != null) {
|
parserThread.interrupt();
|
}
|
}
|
|
public static void processData(String receivedata, String ip, int port) {
|
// È¥µô»Ø³µ»»Ðзû
|
receivedata = receivedata.replaceAll("[\\r\\n]+", "");
|
// ת´óд
|
receivedata = receivedata.toUpperCase();
|
|
// ¶¨ÒåÕýÔò±í´ïʽ£¬Æ¥ÅäÒÔ $GNGGA¡¢$XTB¡¢$SSGGA¡¢$GBGGA »ò 55AA ¿ªÍ·µÄÊý¾Ý
|
String regex = "(\\$GNGGA[^$]*|\\$XTB[^$]*|\\$SSGGA[^$]*|\\$GBGGA[^$]*|55AA[^$]*)";
|
|
// ʹÓÃÕýÔò±í´ïʽ·Ö¸î×Ö·û´®
|
Pattern pattern = Pattern.compile(regex);
|
Matcher matcher = pattern.matcher(receivedata);
|
|
// ±éÀúÆ¥Åäµ½µÄÊý¾Ý
|
while (matcher.find()) {
|
String data = matcher.group(1);
|
|
if (data.startsWith("$GNGGA")) {
|
handleGNGGA(data, ip, port);
|
} else if (data.startsWith("$XTB")) {
|
handleXTB(data, ip, port);
|
} else if (data.startsWith("$SSGGA")) {
|
handleSSGGA(data, ip, port);
|
} else if (data.startsWith("$GBGGA")) {
|
handleGBGGA(data, ip, port);
|
} else if (data.startsWith("55AA")) {
|
handle55AA(data, ip, port);
|
}
|
}
|
}
|
|
private static void handleGNGGA(String data, String ip, int port) {// ´¦Àí$GNGGAÊý¾Ý
|
MessageViewPanel.showData(data, ip, port, 0, "UDPB", "GNGGA", "ALL");
|
// ʹÓÿÉÖØÓõĽâÎöÆ÷ʵÀý½âÎöÊý¾Ý
|
dellGGA(data, ip,port);
|
|
}
|
|
private static void handleXTB(String data, String ip, int port) {
|
// ´¦Àí$XTBÊý¾Ý
|
MessageViewPanel.showData(data, ip, port, 0, "UDPB", "XTB", "ALL");
|
// ¾ßÌå½âÎöÂß¼
|
dellXTB(data,ip,port) ;
|
}
|
|
private static void handleSSGGA(String data, String ip, int port) {
|
// ´¦Àí$SSGGAÊý¾Ý
|
MessageViewPanel.showData(data, ip, port, 0, "UDPB", "SSGGA", "ALL");
|
dellGGA(data, ip,port);
|
// ¾ßÌå½âÎöÂß¼
|
}
|
|
private static void handleGBGGA(String data, String ip, int port) {
|
// ´¦Àí$GBGGAÊý¾Ý
|
MessageViewPanel.showData(data, ip, port, 0, "UDPB", "GBGGA", "ALL");
|
// ¾ßÌå½âÎöÂß¼
|
dellGGA(data, ip,port);
|
}
|
|
private static void handle55AA(String data, String ip, int port) {
|
// ´¦Àí55AAÊý¾Ý
|
System.out.println("Handling 55AA: " + data);
|
// ¾ßÌå½âÎöÂß¼
|
}
|
|
private static void dellGGA(String data, String ip, int port) {
|
DellGngga parser = dellGnggaParser.get();
|
parser.parse(data);
|
String utcTime= parser.getUtcTime();
|
String latitude = parser.getLatitude(); // »ñȡγ¶ÈÖµ
|
String latHemisphere = parser.getLatHemisphere(); // »ñȡγ¶È°ëÇò£¨N»òS£©
|
String longitude = parser.getLongitude(); // »ñÈ¡¾¶ÈÖµ
|
String lonHemisphere = parser.getLonHemisphere(); // »ñÈ¡¾¶È°ëÇò£¨E»òW£©
|
String quality = parser.getQuality(); // »ñÈ¡GPS¶¨Î»ÖÊÁ¿
|
String satellites = parser.getSatellites(); // »ñȡʹÓõÄÎÀÐÇÊýÁ¿
|
String hdop = parser.getHdop(); // »ñȡˮƽ¾«¶ÈÒò×Ó
|
String altitude = parser.getAltitude(); // »ñÈ¡º£°Î¸ß¶È
|
String altitudeUnit = parser.getAltitudeUnit(); // »ñÈ¡º£°Îµ¥Î»
|
String geoidHeight = parser.getGeoidHeight(); // »ñÈ¡´óµØË®×¼Ãæ¸ß¶È
|
String geoidHeightUnit = parser.getGeoidHeightUnit(); // »ñÈ¡´óµØË®×¼Ãæ¸ß¶Èµ¥Î»
|
String differentialTime = parser.getDifferentialTime(); // »ñÈ¡²î·Öʱ¼ä
|
String checksum = parser.getChecksum(); // »ñȡУÑéºÍ
|
String deviceId = parser.getDeviceId(); // »ñÈ¡É豸ID
|
String battery = parser.getBattery(); // »ñÈ¡µç³ØµçÁ¿
|
String signalStrength = parser.getSignalStrength(); // »ñÈ¡ÐźÅÇ¿¶È
|
String reserve1 = parser.getReserve1(); // »ñÈ¡±£Áô×Ö¶Î1
|
String reserve2 = parser.getReserve2(); // »ñÈ¡±£Áô×Ö¶Î2
|
String reserve3 = parser.getReserve3(); // »ñÈ¡±£Áô×Ö¶Î3
|
|
String portStr = String.valueOf(port); // ½«¶Ë¿ÚºÅת»»Îª×Ö·û´®
|
String time = EfficientTimeFormatter.getCurrentTimeFormatted();
|
Dell_tag.updateLocationTagProperty(deviceId, "utcTime",utcTime);
|
Dell_tag.updateLocationTagProperty(deviceId, "deviceBattery",time);
|
Dell_tag.updateLocationTagProperty(deviceId, "lastSatelliteSignalTime",time);
|
Dell_tag.updateLocationTagProperty(deviceId, "gnGgaDataTime",time);
|
Dell_tag.updateLocationTagProperty(deviceId, "latitude",latitude);
|
Dell_tag.updateLocationTagProperty(deviceId, "longitude",longitude);
|
Dell_tag.updateLocationTagProperty(deviceId, "satelliteQuality",quality);
|
Dell_tag.updateLocationTagProperty(deviceId, "satelliteCount",satellites);
|
Dell_tag.updateLocationTagProperty(deviceId, "altitude",altitude);
|
Dell_tag.updateLocationTagProperty(deviceId, "ipAddress",ip);
|
Dell_tag.updateLocationTagProperty(deviceId, "ipPort",portStr);
|
Dell_tag.updateLocationTagProperty(deviceId, "onlineStatus","1");
|
Dell_tag.updateLocationTagProperty(deviceId, "isSatelliteDevice","1");
|
Dell_tag.updateLocationTagProperty(deviceId, "differentialTime",differentialTime);
|
|
// ´´½¨TrackData¶ÔÏó²¢Ìí¼Óµ½ÅúÁ¿²åÈëÆ÷
|
LocationTag tag = Dell_tag.getTagByDeviceId(deviceId);
|
String deviceName = tag != null ? tag.getDeviceName() : "";
|
String company = tag != null ? tag.getCompany() : "";
|
TrackData trackData = new TrackData(
|
deviceId,
|
deviceName,
|
"",
|
"",
|
"",
|
"",
|
battery,
|
utcTime,
|
longitude,
|
latitude,
|
quality,
|
satellites,
|
hdop,
|
altitude,
|
geoidHeight,
|
differentialTime,
|
"GNGGA",
|
company,
|
time
|
);
|
TrackDataBatchInserter.addTrackData(trackData);
|
|
}
|
private static void dellXTB(String data, String ip, int port) {
|
String portStr = String.valueOf(port); // ½«¶Ë¿ÚºÅת»»Îª×Ö·û´®
|
XTB parser = dellXTB.get();
|
parser.parse(data);
|
String deviceId=parser.getDeviceId();// É豸±àºÅ
|
String battery=parser.getBattery();// µçÁ¿
|
String version=parser.getVersion();// °æ±¾ºÅ
|
String ccid=parser.getCcid(); // CCID
|
String button=parser.getButton(); // °´¼ü
|
String rtcmSource=parser.getRtcmSource();
|
Dell_tag.updateLocationTagProperty(deviceId, "ipAddress",ip);
|
Dell_tag.updateLocationTagProperty(deviceId, "ipPort",portStr);
|
Dell_tag.updateLocationTagProperty(deviceId, "RTKsource",rtcmSource);
|
Dell_tag.updateLocationTagProperty(deviceId, "sosStatus",button);
|
Dell_tag.updateLocationTagProperty(deviceId, "deviceCardNumber",ccid);
|
Dell_tag.updateLocationTagProperty(deviceId, "deviceVersion",version);
|
|
}
|
|
|
|
}
|
