From 2e1676aa36075f17dee2eb31374ec92f0aafc15c Mon Sep 17 00:00:00 2001
From: luyya <luya0519>
Date: Thu, 16 Oct 2025 11:08:22 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BA=B3=E5=B7=9E=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../org/dromara/system/schedule/DeviceRedisSchedule.java    | 2 +-
 .../src/main/java/org/dromara/udp/config/AsyncUtils.java    | 4 ++--
 .../org/dromara/udp/controller/OriginalUdpReceiver.java     | 6 +++---
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/stwzhj-modules/wzhj-system/src/main/java/org/dromara/system/schedule/DeviceRedisSchedule.java b/stwzhj-modules/wzhj-system/src/main/java/org/dromara/system/schedule/DeviceRedisSchedule.java
index 98169d3a..66799efc 100644
--- a/stwzhj-modules/wzhj-system/src/main/java/org/dromara/system/schedule/DeviceRedisSchedule.java
+++ b/stwzhj-modules/wzhj-system/src/main/java/org/dromara/system/schedule/DeviceRedisSchedule.java
@@ -39,7 +39,7 @@ public class DeviceRedisSchedule {
     /*
     * 把Redis中 online_user数据存入t_device_redis表中
     * */
-//    @Scheduled(cron = "0/30 * * * * ?")
+    @Scheduled(cron = "0/30 * * * * ?")
     public void handleDeviceRedis(){
         List<JSONObject> jlist = RedisUtils.searchAndGetKeysValues("online_users:*");
         redisService.insertBatch(BeanUtil.copyToList(jlist, DeviceRedis.class));
diff --git a/stwzhj-modules/wzhj-udp/src/main/java/org/dromara/udp/config/AsyncUtils.java b/stwzhj-modules/wzhj-udp/src/main/java/org/dromara/udp/config/AsyncUtils.java
index 526e758b..a7250555 100644
--- a/stwzhj-modules/wzhj-udp/src/main/java/org/dromara/udp/config/AsyncUtils.java
+++ b/stwzhj-modules/wzhj-udp/src/main/java/org/dromara/udp/config/AsyncUtils.java
@@ -112,10 +112,10 @@ public class AsyncUtils {
         byte[] sfm = Arrays.copyOfRange(copyByte, 46, 51);
         String time = singleByteToString2(sfm);
         String time2 =  singleByteToString2(sfm);
-        logger.error("time2:"+time2);
+        logger.error("time2:"+year+time2);
         logger.error("time:"+year+time);
 
-        return BuilderEsGpsInfo(gpsId, lonD, latD, speed, angle, height, jingdu, (year + time));
+        return BuilderEsGpsInfo(gpsId, lonD, latD, speed, angle, height, jingdu, (year + time2));
 
 
     }
diff --git a/stwzhj-modules/wzhj-udp/src/main/java/org/dromara/udp/controller/OriginalUdpReceiver.java b/stwzhj-modules/wzhj-udp/src/main/java/org/dromara/udp/controller/OriginalUdpReceiver.java
index 10084e60..3843c591 100644
--- a/stwzhj-modules/wzhj-udp/src/main/java/org/dromara/udp/controller/OriginalUdpReceiver.java
+++ b/stwzhj-modules/wzhj-udp/src/main/java/org/dromara/udp/controller/OriginalUdpReceiver.java
@@ -73,8 +73,8 @@ public class OriginalUdpReceiver implements ApplicationListener<ApplicationReady
     public void onApplicationEvent(ApplicationReadyEvent event) {
         logger.info("原生方式启动");
         try {
-//            Executors.newSingleThreadExecutor().execute(new UDPProcess("10.129.221.10",Integer.parseInt("10033")));
-            Executors.newSingleThreadExecutor().execute(new UDPProcess("10.129.221.10",Integer.parseInt("10034")));
+            Executors.newSingleThreadExecutor().execute(new UDPProcess("10.129.221.10",Integer.parseInt("10033")));
+//            Executors.newSingleThreadExecutor().execute(new UDPProcess("10.129.221.10",Integer.parseInt("10034")));
         } catch (SocketException e) {
             e.printStackTrace();
         }
@@ -103,7 +103,7 @@ public class OriginalUdpReceiver implements ApplicationListener<ApplicationReady
                     String unSendData = new String(buffer,0,data.length);
                     //String sendData = bytes2hexStr(data);
                     logger.error("接收到了数据"+data);
-                    asyncUtils.saveData(data,"3");
+                    asyncUtils.saveData(data,"2");
                 } catch (Exception e) {
                     e.printStackTrace();
                 }