From 500f6ce071c0bc14d6720354ce148599ac3f35ee Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期五, 25 十月 2024 15:38:42 +0800
Subject: [PATCH] #

---
 zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java            |   53 +++++++++++++-------------
 zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/KernelScheduler.java      |    2 
 zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MissionAssignService.java   |   14 +++----
 zy-acs-manager/src/main/java/com/zy/acs/manager/manager/service/AgvService.java          |    4 -
 zy-acs-manager/src/main/java/com/zy/acs/manager/manager/service/impl/AgvServiceImpl.java |   30 +++++++++------
 version/logical-line.xmind                                                               |    0 
 6 files changed, 53 insertions(+), 50 deletions(-)

diff --git a/version/logical-line.xmind b/version/logical-line.xmind
index e948f5d..372d5e5 100644
--- a/version/logical-line.xmind
+++ b/version/logical-line.xmind
Binary files differ
diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/KernelScheduler.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/KernelScheduler.java
index 93c2025..1dfb30e 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/KernelScheduler.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/scheduler/KernelScheduler.java
@@ -58,7 +58,7 @@
         if (!this.lock.tryLock(LOCK_TIMEOUT, TimeUnit.SECONDS)) { return; }
         List<Bus> busList = busService.selectBySts(BusStsType.RECEIVE);
         for (Bus bus : busList) {
-            mainService.infuseAgvForTask(bus);
+            mainService.allocateTask(bus);
         }
         this.lock.unlock();
     }
diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java
index 9b3a1d8..8da6ca8 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java
@@ -194,7 +194,7 @@
      * 浠诲姟鍒嗛厤缁欒溅杈� ( 杞﹁締姝ゆ椂鏄┖闂蹭笖闈欐鐨� )
      */
     @Transactional
-    public synchronized void infuseAgvForTask(Bus bus) {
+    public synchronized void allocateTask(Bus bus) {
         try {
             Date now = new Date();
             List<Task> taskList = taskService.list(new LambdaQueryWrapper<Task>()
@@ -212,6 +212,7 @@
                 return;
             }
 
+            List<Long> taskIds = taskList.stream().map(Task::getId).distinct().collect(Collectors.toList());
             for (Task task : taskList) {
                 Agv agv = missionAssignService.execute(task);
                 if (null == agv) {
@@ -230,31 +231,31 @@
 
             // ------------------------------------------
 
-            List<Long> taskIds = taskList.stream().map(Task::getId).distinct().collect(Collectors.toList());
 
-            Map<String, List<Long>> taskAllot = new HashMap<>();
-            for (Task task : taskList) {
-                Agv agv = missionAssignService.execute(task, taskAllot, taskIds);
-                if (null == agv) {
-                    log.warn("Task[{}] has an issue锛� because it failed to checkout agv which is idle...", task.getSeqNum());
-                    continue;
-                }
-
-
-                task.setAgvId(agv.getId());
-                task.setTaskSts(TaskStsType.WAITING.val());
-                task.setIoTime(now);
-                task.setUpdateTime(now);
-                if (!taskService.updateById(task)) {
-                    throw new BusinessException("seqNum: " + task.getSeqNum() + " failed to update");
-                }
-
-                if (taskAllot.containsKey(agv.getUuid())) {
-                    taskAllot.get(agv.getUuid()).add(task.getId());
-                } else {
-                    taskAllot.put(agv.getUuid(), Utils.singletonList(task.getId()));
-                }
-            }
+//
+//            Map<String, List<Long>> taskAllot = new HashMap<>();
+//            for (Task task : taskList) {
+//                Agv agv = missionAssignService.execute(task, taskAllot, taskIds);
+//                if (null == agv) {
+//                    log.warn("Task[{}] has an issue锛� because it failed to checkout agv which is idle...", task.getSeqNum());
+//                    continue;
+//                }
+//
+//
+//                task.setAgvId(agv.getId());
+//                task.setTaskSts(TaskStsType.WAITING.val());
+//                task.setIoTime(now);
+//                task.setUpdateTime(now);
+//                if (!taskService.updateById(task)) {
+//                    throw new BusinessException("seqNum: " + task.getSeqNum() + " failed to update");
+//                }
+//
+//                if (taskAllot.containsKey(agv.getUuid())) {
+//                    taskAllot.get(agv.getUuid()).add(task.getId());
+//                } else {
+//                    taskAllot.put(agv.getUuid(), Utils.singletonList(task.getId()));
+//                }
+//            }
         } catch (Exception e) {
             log.error("mainService.infuseAgvForTask", e);
             TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
@@ -275,7 +276,7 @@
 
             // valid -----------------------------------------------
             Agv agv = agvService.getById(agvId);
-            if (!agvService.judgeEnable(agv.getId(), agvDetail -> agvDetail.getVol() > agv.getChargeLine())) {
+            if (!agvService.judgeEnable(agv.getId(), true)) {
                 throw new CoolException("AGV[" + agv.getUuid() + "]褰撳墠涓嶅彲鐢�...");
             }
             if (!Cools.isEmpty(taskService.selectInSts(agvId, TaskStsType.ASSIGN, TaskStsType.PROGRESS))) {
diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MissionAssignService.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MissionAssignService.java
index 5ab9c71..cc5973b 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MissionAssignService.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MissionAssignService.java
@@ -59,8 +59,7 @@
             }
 
             // 2. in idle status
-            final Agv finalAgv = agv;
-            if (!agvService.judgeEnable(finalAgv.getId(), agvDetail -> agvDetail.getVol() > finalAgv.getChargeLine())) {
+            if (!agvService.judgeEnable(agv.getId(), true)) {
                 continue;
             }
 
@@ -75,6 +74,7 @@
         if (Cools.isEmpty(availableAgvList)) {
             return null;
         }
+
 
         return null;
     }
@@ -110,9 +110,8 @@
                 log.info(agv.getUuid() + "鍙稟GV涓嶅彲鐢紝宸茬粡瀛樺湪杩涜涓殑浠诲姟...");
                 continue;
             }
-            final Agv finalAgv = agv;
-            if (!agvService.judgeEnable(finalAgv.getId(), agvDetail -> agvDetail.getVol() > finalAgv.getChargeLine())) {
-                log.info(finalAgv.getUuid() + "鍙稟GV涓嶅彲鐢紝" + task.getSeqNum() + "浠诲姟鏃犳硶璁$畻...");
+            if (!agvService.judgeEnable(agv.getId(), true)) {
+                log.info(agv.getUuid() + "鍙稟GV涓嶅彲鐢紝" + task.getSeqNum() + "浠诲姟鏃犳硶璁$畻...");
                 continue;
             }
 
@@ -157,9 +156,8 @@
             log.info(agv.getUuid() + "鍙稟GV涓嶅彲鐢紝宸茬粡瀛樺湪杩涜涓殑浠诲姟...");
             return null;
         }
-        final Agv finalAgv = agv;
-        if (!agvService.judgeEnable(finalAgv.getId(), agvDetail -> agvDetail.getVol() > finalAgv.getChargeLine())) {
-            log.info(finalAgv.getUuid() + "鍙稟GV涓嶅彲鐢紝" + task.getSeqNum() + "浠诲姟鏃犳硶璁$畻...");
+        if (!agvService.judgeEnable(agv.getId(), true)) {
+            log.info(agv.getUuid() + "鍙稟GV涓嶅彲鐢紝" + task.getSeqNum() + "浠诲姟鏃犳硶璁$畻...");
             return null;
         }
 
diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/manager/service/AgvService.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/manager/service/AgvService.java
index 76d8afc..638bd43 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/manager/service/AgvService.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/manager/service/AgvService.java
@@ -1,14 +1,12 @@
 package com.zy.acs.manager.manager.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
-import com.zy.acs.common.utils.JudgeSupport;
 import com.zy.acs.manager.common.domain.BaseParam;
 import com.zy.acs.manager.common.domain.PageParam;
 import com.zy.acs.manager.common.domain.PageResult;
 import com.zy.acs.manager.core.domain.VehicleDto;
 import com.zy.acs.manager.manager.controller.result.AgvResult;
 import com.zy.acs.manager.manager.entity.Agv;
-import com.zy.acs.manager.manager.entity.AgvDetail;
 import com.zy.acs.manager.manager.entity.Task;
 
 import java.util.List;
@@ -29,7 +27,7 @@
 
     Boolean judgeEnable(Long agvId);
 
-    Boolean judgeEnable(Long agvId, JudgeSupport<AgvDetail> support);
+    Boolean judgeEnable(Long agvId, Boolean withBattery);
 
     Boolean judgeOnline(Long agvId);
 
diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/manager/service/impl/AgvServiceImpl.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/manager/service/impl/AgvServiceImpl.java
index 59e06fd..336317f 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/manager/service/impl/AgvServiceImpl.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/manager/service/impl/AgvServiceImpl.java
@@ -4,7 +4,6 @@
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.zy.acs.common.constant.RedisConstant;
 import com.zy.acs.common.enums.AgvStatusType;
-import com.zy.acs.common.utils.JudgeSupport;
 import com.zy.acs.common.utils.RedisSupport;
 import com.zy.acs.framework.common.Cools;
 import com.zy.acs.manager.common.domain.BaseParam;
@@ -67,19 +66,19 @@
 
     @Override
     public Boolean judgeEnable(Long agvId) {
-        return this.judgeEnable(agvId, null);
+        return this.judgeEnable(agvId, false);
     }
 
     @Override
-    public Boolean judgeEnable(Long agvId, JudgeSupport<AgvDetail> support) {
+    public Boolean judgeEnable(Long agvId, Boolean withBattery) {
         Agv agv = this.getById(agvId);
         AgvModel agvModel = agvModelService.getById(agv.getAgvModel());
         if (segmentService.count(new LambdaQueryWrapper<Segment>()
-                .eq(Segment::getAgvId, agvId)
-                .and( i -> {
+                        .eq(Segment::getAgvId, agvId)
+                        .and( i -> {
 //                    i.eq(Segment::getState, SegmentStateType.WAITING.toString()).or()
-                    i.eq(Segment::getState, SegmentStateType.RUNNING.toString());
-                })
+                            i.eq(Segment::getState, SegmentStateType.RUNNING.toString());
+                        })
         ) > 0) {
             log.warn("[{}]鍙稟gv姝e湪蹇欑 -segment......", agv.getUuid());
             return false;
@@ -105,17 +104,24 @@
                 return false;
             }
         }
-        if (support != null) {
-            if (!support.execute(agvDetail)) {
-                return false;
-            }
-        }
         if (!agvDetail.getAgvStatus().equals(AgvStatusType.CHARGE)) {
             if (agvDetail.getPos() != 1) {
                 log.warn("[{}]鍙稟gv褰撳墠涓嶅湪瀹氫綅......", agv.getUuid());
                 return false;
             }
         }
+        // with battery
+        if (withBattery) {
+            if (agvDetail.getVol() < agv.getChargeLine()) {
+                log.warn("[{}]鍙稟gv鐢甸噺涓嶈冻......", agv.getUuid());
+                return false;
+            }
+            if (agvDetail.getVol() < agvModel.getLowBattery()) {
+                log.warn("[{}]鍙稟gv鐢甸噺涓嶈冻......", agv.getUuid());
+                return false;
+            }
+        }
+
         return true;
     }
 

--
Gitblit v1.9.1