From cc42d79563a119ffb37302092c445e73ab76e274 Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期四, 28 十二月 2023 15:08:17 +0800
Subject: [PATCH] #小车锁路径载入其他小车节点

---
 src/main/java/com/zy/core/thread/NyShuttleThread.java |   18 +++++++++++++++++-
 1 files changed, 17 insertions(+), 1 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/NyShuttleThread.java b/src/main/java/com/zy/core/thread/NyShuttleThread.java
index 20e48e7..cab5c90 100644
--- a/src/main/java/com/zy/core/thread/NyShuttleThread.java
+++ b/src/main/java/com/zy/core/thread/NyShuttleThread.java
@@ -242,6 +242,22 @@
 //                    log.info(MessageFormat.format("銆恵0}銆慬id:{1}] <<<<< 瀹炴椂鏁版嵁鏇存柊鎴愬姛",DateUtils.convert(new Date()), slave.getId()));
                 }
 //                log.warn(JSON.toJSONString(shuttleProtocol));//杈撳嚭灏忚溅鐘舵��
+
+                if (System.currentTimeMillis() - shuttleProtocol.getDeviceDataLog() > 1000 * 5) {
+                    //閲囬泦鏃堕棿瓒呰繃5s锛屼繚瀛樹竴娆℃暟鎹褰�
+                    //淇濆瓨鏁版嵁璁板綍
+                    DeviceDataLogService deviceDataLogService = SpringUtils.getBean(DeviceDataLogService.class);
+                    DeviceDataLog deviceDataLog = new DeviceDataLog();
+                    deviceDataLog.setOriginData(JSON.toJSONString(jsonObject));
+                    deviceDataLog.setWcsData(JSON.toJSONString(shuttleProtocol));
+                    deviceDataLog.setType("shuttle");
+                    deviceDataLog.setDeviceNo(shuttleProtocol.getShuttleNo().intValue());
+                    deviceDataLog.setCreateTime(new Date());
+                    deviceDataLogService.insert(deviceDataLog);
+
+                    //鏇存柊閲囬泦鏃堕棿
+                    shuttleProtocol.setDeviceDataLog(System.currentTimeMillis());
+                }
             }
         } catch (Exception e) {
             e.printStackTrace();
@@ -419,7 +435,7 @@
                         if (!(targetNode.getX() == node.getX() && targetNode.getY() == node.getY())) {
                             nodes.remove(nodes.size() - 1);//鍓旈櫎灏捐妭鐐�
                         }
-                        boolean result = navigateMapUtils.writeNavigateNodeToRedisMap(Utils.getLev(shuttleProtocol.getCurrentLocNo()), nodes, false);//瑙i攣璺緞
+                        boolean result = navigateMapUtils.writeNavigateNodeToRedisMap(Utils.getLev(shuttleProtocol.getCurrentLocNo()), shuttleProtocol.getShuttleNo().intValue(), nodes, false);//瑙i攣璺緞
                         if (!result) {
                             return false;//瑙i攣澶辫触
                         }

--
Gitblit v1.9.1