From 89c7f6e5bcc21b0e8f83a2bc6d680e2ffe431e6f Mon Sep 17 00:00:00 2001
From: vincentlu <t1341870251@gmail.com>
Date: 星期一, 13 一月 2025 09:38:29 +0800
Subject: [PATCH] #
---
zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/astart/MapDataDispatcher.java | 45 ++-------------------------------------------
1 files changed, 2 insertions(+), 43 deletions(-)
diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/astart/MapDataDispatcher.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/astart/MapDataDispatcher.java
index 7d90822..0a2285c 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/astart/MapDataDispatcher.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/astart/MapDataDispatcher.java
@@ -6,7 +6,6 @@
import com.zy.acs.common.utils.RedisSupport;
import com.zy.acs.framework.common.Cools;
import com.zy.acs.framework.exception.CoolException;
-import com.zy.acs.manager.core.domain.SortCodeDto;
import com.zy.acs.manager.core.service.astart.domain.DynamicNode;
import com.zy.acs.manager.core.utils.RouteGenerator;
import com.zy.acs.manager.manager.entity.Code;
@@ -17,9 +16,6 @@
import lombok.extern.slf4j.Slf4j;
import java.util.*;
-import java.util.concurrent.ConcurrentLinkedQueue;
-import java.util.stream.Collectors;
-import java.util.stream.IntStream;
/**
* Created by vincent on 6/6/2024
@@ -255,7 +251,7 @@
cdaArr.add(yIdxList.get(i));
cdaMatrix[i][j] = JSON.toJSONString(cdaArr);
} else {
- Code currCode = codeService.selectByData(codeMatrix[i][j]);
+ Code currCode = codeService.getCacheByData(codeMatrix[i][j]);
if (null != currCode) {
List<Double> cdaArr = new ArrayList<>();
cdaArr.add(currCode.getX());
@@ -284,7 +280,7 @@
if (CodeNodeType.NONE.val.equals(codeMatrix[i][j])) {
turnMatrix[i][j] = TurnNodeType.NONE.val;
} else {
- Code currCode = codeService.selectByData(codeMatrix[i][j]);
+ Code currCode = codeService.getCacheByData(codeMatrix[i][j]);
List<String> neighborCodeList = routeService.findCodeDataOfSingle(currCode.getId());
switch (neighborCodeList.size()) {
@@ -481,43 +477,6 @@
}
}
return codeMatrixIdxList;
- }
-
- public List<String> queryCodeListFromDynamicNode(Integer lev, String nodeType) {
- if (Cools.isEmpty(nodeType)) {
- return new ArrayList<>();
- }
- lev = Optional.ofNullable(lev).orElse(MAP_DEFAULT_LEV);
-
- DynamicNode[][] dynamicMatrix = getDynamicMatrix(lev);
- String[][] codeMatrix = this.getCodeMatrix(lev);
-
- // concurrent
- ConcurrentLinkedQueue<SortCodeDto> codeList = new ConcurrentLinkedQueue<>();
- IntStream.range(0, codeMatrix.length).parallel().forEach(i -> {
- for (int j = 0; j < codeMatrix[i].length; j++) {
- DynamicNode dynamicNode = dynamicMatrix[i][j];
- if (nodeType.equals(dynamicNode.getVehicle())) {
- codeList.add(new SortCodeDto(codeMatrix[i][j], dynamicNode.getSerial()));
- }
- }
- });
-
- // synchronize
-// List<SortCodeDto> codeList = new ArrayList<>();
-// for (int i = 0; i < codeMatrix.length; i++) {
-// for (int j = 0; j < codeMatrix[i].length; j++) {
-// DynamicNode dynamicNode = dynamicMatrix[i][j];
-// if (nodeType.equals(dynamicNode.getVehicle())) {
-// codeList.add(new SortCodeDto(codeMatrix[i][j], dynamicNode.getSerial()));
-// }
-// }
-// }
-
- return codeList.stream()
- .sorted(Comparator.comparingInt(SortCodeDto::getSerial))
- .map(SortCodeDto::getCode)
- .collect(Collectors.toList());
}
public void modifyDynamicMatrix(Integer lev, List<int[]> codeIdxList, String vehicle) {
--
Gitblit v1.9.1