From 3a1d32e5e512f68ab5a613ae19997bbbcbbe0f98 Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Thu, 16 Jan 2025 21:23:42 +0800
Subject: [PATCH] 增加手台配置
---
src/main/java/org/springblade/modules/netty/handle/UdpServerHandler.java | 20 +++++++++-----------
1 files changed, 9 insertions(+), 11 deletions(-)
diff --git a/src/main/java/org/springblade/modules/netty/handle/UdpServerHandler.java b/src/main/java/org/springblade/modules/netty/handle/UdpServerHandler.java
index 6d69431..fc96f8d 100644
--- a/src/main/java/org/springblade/modules/netty/handle/UdpServerHandler.java
+++ b/src/main/java/org/springblade/modules/netty/handle/UdpServerHandler.java
@@ -7,8 +7,8 @@
import io.netty.util.CharsetUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.springblade.modules.netty.business.entity.PoliceCarEquipment;
-import org.springblade.modules.netty.business.service.PoliceCarEquipmentService;
+import org.springblade.modules.netty.business.entity.TalkBackEquipment;
+import org.springblade.modules.netty.business.service.TalkBackEquipmentService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;
@@ -32,12 +32,12 @@
private static UdpServerHandler udpServerHandler;
@Autowired
- private PoliceCarEquipmentService policeCarEquipmentService;
+ private TalkBackEquipmentService talkBackEquipmentService;
@PostConstruct
public void init() {
udpServerHandler = this;
- udpServerHandler.policeCarEquipmentService = this.policeCarEquipmentService;
+ udpServerHandler.talkBackEquipmentService = this.talkBackEquipmentService;
}
@Override
@@ -50,7 +50,7 @@
// 字节转16进制字符串
String s = bytesToHexString(req);
//获取字符串的长度
-// int length = s.length();
+ int length = s.length();
// System.out.println("数据长度>>>>>> = " + length);
//数据解析
dataHandler(s);
@@ -63,7 +63,7 @@
private void dataHandler(String s) {
// s = "AAAACCCC220000000033373933343732393100000000000000000000000052D50451F77D5D406C04E275FD723C400000015F0000000507E70306103B0A";
//创建设备对象
- PoliceCarEquipment backEquipment = new PoliceCarEquipment();
+ TalkBackEquipment backEquipment = new TalkBackEquipment();
if (s.substring(4,8).equals("CCCC")) {
backEquipment.setStatus(1);
}
@@ -72,10 +72,7 @@
backEquipment.setStatus(0);
}
//截取字符串
- String terminalNumber = hexStr2Str(s.substring(20, 60));
- // char[20] 后面跟了 \0000 空字符串
-// String trim = terminalNumber.trim();
- backEquipment.setTerminalNumber(terminalNumber);
+ backEquipment.setTerminalNumber(hexStr2Str(s.substring(20, 60)));
backEquipment.setLongitude(Double.toString(getDouble(s.substring(60, 76))));
@@ -117,7 +114,7 @@
}
backEquipment.setUpdateTime(new Date());
// 新增
- udpServerHandler.policeCarEquipmentService.save(backEquipment);
+ udpServerHandler.talkBackEquipmentService.save(backEquipment);
}
/**
@@ -137,6 +134,7 @@
return sb.toString();
}
+
/**
* 捕获异常
* @param ctx
--
Gitblit v1.9.3