From 6c5963052282dfe4ae2f20d2e18012d1cff93c85 Mon Sep 17 00:00:00 2001
From: pjb <pjb123456>
Date: 星期一, 23 六月 2025 08:54:51 +0800
Subject: [PATCH] rgv调度优化

---
 src/main/java/com/zy/asrs/controller/RgvController.java |   17 ++++++++++-------
 1 files changed, 10 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/RgvController.java b/src/main/java/com/zy/asrs/controller/RgvController.java
index c9f1720..35fe0b3 100644
--- a/src/main/java/com/zy/asrs/controller/RgvController.java
+++ b/src/main/java/com/zy/asrs/controller/RgvController.java
@@ -7,7 +7,8 @@
 import com.core.exception.CoolException;
 import com.zy.asrs.domain.enums.RgvStatusType;
 import com.zy.asrs.domain.param.*;
-import com.zy.asrs.domain.vo.*;
+import com.zy.asrs.domain.vo.RgvMsgTableVo;
+import com.zy.asrs.domain.vo.RgvStateTableVo;
 import com.zy.asrs.entity.*;
 import com.zy.asrs.mapper.BasRgvErrMapper;
 import com.zy.asrs.service.BasCircularShuttleService;
@@ -15,7 +16,6 @@
 import com.zy.asrs.service.BasRgvService;
 import com.zy.asrs.service.WrkMastService;
 import com.zy.asrs.service.impl.MainServiceImpl;
-import com.zy.asrs.utils.NumUtils;
 import com.zy.asrs.utils.Utils;
 import com.zy.core.cache.MessageQueue;
 import com.zy.core.cache.OutputQueue;
@@ -39,8 +39,9 @@
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
-import javax.rmi.CORBA.Util;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
 
 /**
  * RGV鎺ュ彛
@@ -370,11 +371,11 @@
         List<RingThroughParam> result = new ArrayList<>();
         List<BasDevpPosition> basDevpPositions = basDevpPositionService.selectList(new EntityWrapper<>());
         for (BasDevpPosition basDevpPosition : basDevpPositions){
-            if (basDevpPosition.getDevNo() == 114){
+            if (basDevpPosition.getDevNo() == 134){
                 continue;
             }
             RingThroughParam ringThroughParam = new RingThroughParam();
-            ringThroughParam.setIndex(basDevpPosition.getDevNo()-100);
+            ringThroughParam.setIndex(basDevpPosition.getDevNo());
 //            double[] doubles = Utils.RingThroughXYSta(perimeter, perimeter-basDevpPosition.getPlcPosition());
 //            ringThroughParam.setValueX(doubles[0]>50? doubles[0]+6:doubles[0]-1);
 //            ringThroughParam.setValueY(doubles[1]>50? doubles[1]+6:doubles[1]-1);
@@ -429,7 +430,8 @@
 //    @ManagerAuth(memo = "浣滀笟淇℃伅")
     public R ringThroughTaskWrkMast(){
         List<RgvWrkMastParam> result = new ArrayList<>();
-        List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<>());
+        List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("wrk_sts",9,10).orderBy("wrk_sts",false)
+                .orderBy("rgv_no",true));
         for (WrkMast wrkMast : wrkMasts){
             RgvWrkMastParam rgvWrkMastParam = new RgvWrkMastParam(wrkMast);
             if (Cools.isEmpty(rgvWrkMastParam.getRgvNo())){
@@ -465,6 +467,7 @@
                     RgvProtocol rgvProtocol = rgvThread.getRgvProtocol();
                     if (rgvProtocol != null) {
                         rgvCircularShuttleParam.setPosition(rgvProtocol.getRgvPos());
+                        rgvCircularShuttleParam.setTaskNo(rgvProtocol.taskNo1);
                         if (rgvCircularShuttleParam.getStatus()==0){
                             rgvCircularShuttleParam.setStatus$(rgvProtocol.statusType.desc);
                         }

--
Gitblit v1.9.1