From fd6d26f8ffe6a37533e741337f3eca9134d934c7 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期三, 15 一月 2025 10:42:59 +0800
Subject: [PATCH] #

---
 zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/AvoidWaveCalculator.java |   57 +++++++++++----------------------------------------------
 1 files changed, 11 insertions(+), 46 deletions(-)

diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/AvoidWaveCalculator.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/AvoidWaveCalculator.java
index 99fae76..58a941b 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/AvoidWaveCalculator.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/AvoidWaveCalculator.java
@@ -101,8 +101,8 @@
                 return false;
             }
 
-            return this.calcWaveScopeByPython(lev);
-//            return this.calcWaveScopeByJava(lev);
+//            return this.calcWaveScopeByPython(lev);
+            return this.calcWaveScopeByJava(lev);
 
         } catch (Exception e) {
 
@@ -115,8 +115,10 @@
             }
 
             stopWatch.stop();
-            if (stopWatch.getTime() > 100) {
-                log.info("婊ゆ尝鍑芥暟鑺辫垂鏃堕棿涓猴細{}姣......", stopWatch.getTime());
+            if (stopWatch.getTime() > 0) {
+                if (stopWatch.getTime() > 50) {
+                    log.info("婊ゆ尝鍑芥暟鑺辫垂鏃堕棿涓猴細{}姣......", stopWatch.getTime());
+                }
             }
         }
     }
@@ -177,6 +179,10 @@
     }
 
     private boolean calcWaveScopeByJava(Integer lev) throws Exception {
+
+        AgvModel agvModel = agvModelService.selectByType(AgvModelType.CTU_BOX_TRANSPORT_AGV.toString());    // can be optimized
+        Double avoidDistance = MapDataUtils.getVehicleWaveSafeDistance(agvModel.getDiameter(), MapDataConstant.MAX_DISTANCE_BETWEEN_ADJACENT_AGV_FACTOR);
+
         // java
         String[][] codeMatrix = mapDataDispatcher.getCodeMatrix(lev);
         String[][] waveMatrix = mapDataDispatcher.initWaveMatrix(lev);
@@ -188,9 +194,7 @@
                 DynamicNode dynamicNode = dynamicMatrix[i][j];
                 String vehicle = dynamicNode.getVehicle();
                 if (!DynamicNodeType.ACCESS.val.equals(vehicle) && !DynamicNodeType.BLOCK.val.equals(vehicle)) {
-                    AgvModel agvModel = agvModelService.getById(agvService.selectByUuid(vehicle).getAgvModel());    // can be optimized
 
-                    Double avoidDistance = MapDataUtils.getVehicleWaveSafeDistance(agvModel.getDiameter(), MapDataConstant.MAX_DISTANCE_BETWEEN_ADJACENT_AGV_FACTOR);
                     List<NavigateNode> includeList = mapService.getWaveScopeByCode(lev, codeMatrix[i][j], avoidDistance);
 
                     for (NavigateNode navigateNode : includeList) {
@@ -225,45 +229,6 @@
         return scriptFile;
     }
 
-    public void syncWaveBySingleVeh(String agvNo, String codeData) {
-        if (Cools.isEmpty(agvNo, codeData)) {
-            return;
-        }
-
-        boolean lockAcquired = false;
-        Integer lev = MapDataDispatcher.MAP_DEFAULT_LEV;
-
-        try {
-            if (!(lockAcquired = lock.tryLock(LOCK_TIMEOUT, TimeUnit.SECONDS))) {
-                log.warn("AvoidWaveCalculator syncWaveBySingleVeh fail, cause can not acquire lock ...");
-                return;
-            }
-
-            Agv agv = agvService.selectByUuid(agvNo);
-            AgvModel agvModel = agvModelService.getById(agv.getAgvModel());
-            Double avoidDistance = MapDataUtils.getVehicleWaveSafeDistance(agvModel.getDiameter(), MapDataConstant.MAX_DISTANCE_BETWEEN_ADJACENT_AGV_FACTOR);
-
-            String[][] waveMatrix = mapDataDispatcher.getWaveMatrix(lev);
-
-            List<NavigateNode> includeList = mapService.getWaveScopeByCode(lev, codeData, avoidDistance);
-
-            for (NavigateNode navigateNode : includeList) {
-                String waveNode = waveMatrix[navigateNode.getX()][navigateNode.getY()];
-                waveMatrix[navigateNode.getX()][navigateNode.getY()] = MapDataUtils.generateWaveNode(waveNode, agv.getUuid());
-            }
-
-            mapDataDispatcher.setWaveMatrix(lev, waveMatrix);
-
-        } catch (Exception e) {
-            log.error("AvoidWaveCalculator.syncWaveBySingleVeh fail", e);
-        } finally {
-
-            if (lockAcquired) {
-                lock.unlock();
-            }
-        }
-    }
-
     public void calcDynamicNodeWhenBoot() {
         List<Agv> agvList = agvService.list(new LambdaQueryWrapper<>());
         DynamicNode[][] dynamicMatrix = mapDataDispatcher.getDynamicMatrix(null);
@@ -296,7 +261,7 @@
         DynamicNode dynamicNode = dynamicMatrix[codeMatrixIdx[0]][codeMatrixIdx[1]];
         String vehicle = dynamicNode.getVehicle();
         if (vehicle.equals(DynamicNodeType.ACCESS.val)) {
-            mapDataDispatcher.modifyDynamicMatrix(null, Utils.singletonList(code.getData()), agv.getUuid());
+            mapDataDispatcher.modifyDynamicMatrix(null, Utils.singletonList(codeMatrixIdx), agv.getUuid());
         }
     }
 

--
Gitblit v1.9.1