From 1ce8c694a364916fa45c60cabedb7a9215003055 Mon Sep 17 00:00:00 2001
From: vincentlu <t1341870251@gmail.com>
Date: 星期四, 19 三月 2026 13:41:31 +0800
Subject: [PATCH] #
---
zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/GuaranteeRuntimeService.java | 104 +++++++++++++++++++++++++++++-----------------------
1 files changed, 58 insertions(+), 46 deletions(-)
diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/GuaranteeRuntimeService.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/GuaranteeRuntimeService.java
index 1817ed4..ba553f3 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/GuaranteeRuntimeService.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/GuaranteeRuntimeService.java
@@ -2,18 +2,17 @@
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.zy.acs.common.enums.AgvStatusType;
-import com.zy.acs.manager.manager.entity.Agv;
-import com.zy.acs.manager.manager.entity.AgvDetail;
-import com.zy.acs.manager.manager.entity.Guarantee;
-import com.zy.acs.manager.manager.entity.Task;
-import com.zy.acs.manager.manager.enums.StatusType;
-import com.zy.acs.manager.manager.enums.TaskStsType;
-import com.zy.acs.manager.manager.enums.TaskTypeType;
+import com.zy.acs.manager.manager.entity.*;
+import com.zy.acs.manager.manager.enums.*;
import com.zy.acs.manager.manager.service.AgvDetailService;
import com.zy.acs.manager.manager.service.AgvService;
+import com.zy.acs.manager.manager.service.SegmentService;
import com.zy.acs.manager.manager.service.TaskService;
+import lombok.Data;
import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import com.zy.acs.common.utils.News;
import java.time.LocalDateTime;
import java.util.ArrayList;
@@ -25,34 +24,33 @@
@Service
public class GuaranteeRuntimeService {
- private final AgvService agvService;
- private final AgvDetailService agvDetailService;
- private final TaskService taskService;
- private final MainLockWrapService mainLockWrapService;
-
- public GuaranteeRuntimeService(AgvService agvService,
- AgvDetailService agvDetailService,
- TaskService taskService,
- MainLockWrapService mainLockWrapService) {
- this.agvService = agvService;
- this.agvDetailService = agvDetailService;
- this.taskService = taskService;
- this.mainLockWrapService = mainLockWrapService;
- }
+ @Autowired
+ private SegmentService segmentService;
+ @Autowired
+ private AgvService agvService;
+ @Autowired
+ private AgvDetailService agvDetailService;
+ @Autowired
+ private TaskService taskService;
+ @Autowired
+ private MainLockWrapService mainLockWrapService;
public void prepare(Guarantee plan, LocalDateTime targetTime) {
int requiredCount = plan.getRequiredCount() == null ? 0 : plan.getRequiredCount();
if (requiredCount <= 0) {
- log.warn("Guarantee[{}] requiredCount is not configured, skip", plan.getName());
+ News.warn("Guarantee[{}] requiredCount is not configured, skip", plan.getName());
return;
}
- int minSoc = plan.getMinSoc() == null ? 50 : plan.getMinSoc();
- List<Agv> scopedAgvs = findScopedAgvs(plan);
+ int minSoc = plan.getMinSoc();
+ List<Agv> scopedAgvList = findScopedAgvList(plan);
int available = 0;
List<ChargeCandidate> candidates = new ArrayList<>();
- for (Agv agv : scopedAgvs) {
- AgvDetail detail = agvDetailService.selectByAgvId(agv.getId());
- if (detail == null || detail.getSoc() == null) {
+ for (Agv agv : scopedAgvList) {
+ AgvDetail detail = agvDetailService.selectMajorByAgvId(agv.getId());
+ if (null == detail || null == detail.getSoc() || null == detail.getAgvStatus()) {
+ continue;
+ }
+ if (detail.getAgvStatus().equals(AgvStatusType.CHARGE)) {
continue;
}
if (!isIdle(agv, detail)) {
@@ -66,23 +64,22 @@
}
}
if (available >= requiredCount) {
- log.debug("Guarantee[{}] already has {} vehicles >= {}% SOC for {}", plan.getName(), available, minSoc, targetTime);
return;
}
- int shortage = requiredCount - available;
+ int shortage = requiredCount - available; // 杩樺樊澶氬皯杈�
candidates.sort(Comparator.comparingInt(ChargeCandidate::getSoc));
- int scheduled = 0;
+ int scheduled = 0; // 宸茬粡瀹夋帓鍏呯數鐨凙GV鏁伴噺
for (ChargeCandidate candidate : candidates) {
if (scheduled >= shortage) {
break;
}
- log.info("Guarantee[{}] schedule AGV {} charging (soc={}%) for target {}",
+ News.info("Guarantee[{}] schedule AGV {} charging (soc={}%) for target {}",
plan.getName(), candidate.getAgv().getName(), candidate.getSoc(), targetTime);
mainLockWrapService.buildMinorTask(candidate.getAgv().getId(), TaskTypeType.TO_CHARGE, null, null);
scheduled++;
}
if (scheduled < shortage) {
- log.warn("Guarantee[{}] still short of {} vehicles for {} (only {} idle low-soc AGVs)",
+ News.warn("Guarantee[{}] still short of {} vehicles for {} (only {} idle low-soc AGVs)",
plan.getName(), shortage - scheduled, targetTime, candidates.size());
}
}
@@ -94,28 +91,50 @@
if (detail.getAgvStatus() != null && detail.getAgvStatus().equals(AgvStatusType.CHARGE)) {
return false;
}
- long busyCount = taskService.count(new LambdaQueryWrapper<Task>()
+ if (!agvService.judgeOnline(agv.getId())) {
+ return false;
+ }
+
+ if (0 < taskService.count(new LambdaQueryWrapper<Task>()
.eq(Task::getAgvId, agv.getId())
+// .and(i -> {
+// i.eq(Task::getTaskSts, TaskStsType.WAITING.val())
+// .or().eq(Task::getTaskSts, TaskStsType.ASSIGN.val())
+// .or().eq(Task::getTaskSts, TaskStsType.PROGRESS.val());
+// })
.in(Task::getTaskSts,
TaskStsType.WAITING.val(),
TaskStsType.ASSIGN.val(),
- TaskStsType.PROGRESS.val()));
- return busyCount == 0;
+ TaskStsType.PROGRESS.val())
+ )) {
+ return false;
+ }
+ if (0 < segmentService.count(new LambdaQueryWrapper<Segment>()
+ .eq(Segment::getAgvId, agv.getId())
+ .and( i -> {
+// i.eq(Segment::getState, SegmentStateType.WAITING.toString()).or()
+ i.eq(Segment::getState, SegmentStateType.RUNNING.toString());
+ })
+ )) {
+ return false;
+ }
+ return true;
}
- private List<Agv> findScopedAgvs(Guarantee plan) {
+ private List<Agv> findScopedAgvList(Guarantee plan) {
LambdaQueryWrapper<Agv> wrapper = new LambdaQueryWrapper<Agv>()
.eq(Agv::getStatus, StatusType.ENABLE.val);
- if ("MODEL".equalsIgnoreCase(plan.getScopeType()) && plan.getScopeValue() != null) {
+ if (GuaranteeScopeType.MODEL.toString().equalsIgnoreCase(plan.getScopeType()) && plan.getScopeValue() != null) {
try {
wrapper.eq(Agv::getAgvModel, Long.valueOf(plan.getScopeValue()));
} catch (NumberFormatException ignore) {
- log.warn("Guarantee[{}] invalid scopeValue {}", plan.getName(), plan.getScopeValue());
+ News.warn("Guarantee[{}] invalid scopeValue {}", plan.getName(), plan.getScopeValue());
}
}
return agvService.list(wrapper);
}
+ @Data
private static class ChargeCandidate {
private final Agv agv;
private final int soc;
@@ -125,12 +144,5 @@
this.soc = soc;
}
- public Agv getAgv() {
- return agv;
- }
-
- public int getSoc() {
- return soc;
- }
}
-}
+}
\ No newline at end of file
--
Gitblit v1.9.1