From a079fff1e7bae25a5e29f73709b8e9972216f7ef Mon Sep 17 00:00:00 2001
From: vincentlu <t1341870251@gmail.com>
Date: 星期二, 21 一月 2025 15:20:29 +0800
Subject: [PATCH] #
---
zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/AvoidWaveCalculator.java | 63 +++++--------------------------
1 files changed, 11 insertions(+), 52 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 9fcf125..73c5f10 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
@@ -20,7 +20,6 @@
import com.zy.acs.manager.manager.service.AgvService;
import com.zy.acs.manager.manager.service.CodeService;
import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.lang.time.StopWatch;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.io.ClassPathResource;
import org.springframework.core.io.Resource;
@@ -28,7 +27,10 @@
import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy;
-import java.io.*;
+import java.io.BufferedReader;
+import java.io.File;
+import java.io.InputStream;
+import java.io.InputStreamReader;
import java.nio.file.Files;
import java.nio.file.StandardCopyOption;
import java.util.List;
@@ -92,8 +94,7 @@
Integer lev = MapDataDispatcher.MAP_DEFAULT_LEV;
boolean lockAcquired = false;
- StopWatch stopWatch = new StopWatch();
- stopWatch.start();
+ long startTime = System.currentTimeMillis();
try {
if (!(lockAcquired = lock.tryLock(LOCK_TIMEOUT, TimeUnit.SECONDS))) {
@@ -114,11 +115,9 @@
lock.unlock();
}
- stopWatch.stop();
- if (stopWatch.getTime() > 0) {
- if (stopWatch.getTime() > 50) {
- log.info("婊ゆ尝鍑芥暟鑺辫垂鏃堕棿涓猴細{}姣......", stopWatch.getTime());
- }
+ long during = System.currentTimeMillis() - startTime;
+ if (during > 50) {
+ log.info("婊ゆ尝鍑芥暟鑺辫垂鏃堕棿涓猴細{}姣......", during);
}
}
}
@@ -188,16 +187,15 @@
String[][] waveMatrix = mapDataDispatcher.initWaveMatrix(lev);
// lock path
- long time = 0;
DynamicNode[][] dynamicMatrix = mapDataDispatcher.getDynamicMatrix(lev);
for (int i = 0; i < dynamicMatrix.length; i++) {
for (int j = 0; j < dynamicMatrix[i].length; j++) {
DynamicNode dynamicNode = dynamicMatrix[i][j];
String vehicle = dynamicNode.getVehicle();
if (!DynamicNodeType.ACCESS.val.equals(vehicle) && !DynamicNodeType.BLOCK.val.equals(vehicle)) {
- long startTime = System.currentTimeMillis();
+
List<NavigateNode> includeList = mapService.getWaveScopeByCode(lev, codeMatrix[i][j], avoidDistance);
- time += System.currentTimeMillis() - startTime;
+
for (NavigateNode navigateNode : includeList) {
String waveNode = waveMatrix[navigateNode.getX()][navigateNode.getY()]; // overlay
waveMatrix[navigateNode.getX()][navigateNode.getY()] = MapDataUtils.generateWaveNode(waveNode, vehicle);
@@ -208,7 +206,7 @@
// mapDataDispatcher.printMatrix(waveMatrix);
mapDataDispatcher.setWaveMatrix(lev, waveMatrix);
- System.out.println("calcWaveScopeByJava " + time);
+
return true;
}
@@ -228,45 +226,6 @@
throw new RuntimeException(e);
}
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.getByAgvNo(agvNo);
- 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() {
--
Gitblit v1.9.1