From e150f2c426fe2bdfd86be1fe0c27215efaacdc83 Mon Sep 17 00:00:00 2001
From: 1 <1>
Date: 星期二, 16 十二月 2025 09:09:05 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/core/MainProcess.java |   49 +++++++++++++++++++++----------------------------
 1 files changed, 21 insertions(+), 28 deletions(-)

diff --git a/src/main/java/com/zy/core/MainProcess.java b/src/main/java/com/zy/core/MainProcess.java
index 30150c6..61d0842 100644
--- a/src/main/java/com/zy/core/MainProcess.java
+++ b/src/main/java/com/zy/core/MainProcess.java
@@ -26,9 +26,9 @@
     private Thread thread;
     private Thread armThread;
     private Thread agvThread;
+    private Thread rgvTread;
     // 棰戠巼
     private int i = 0;
-    private int k = 0;
     private int q = 0;
     private boolean rgcWrk = true;
 
@@ -44,36 +44,32 @@
 
         agvThread = new Thread(this::agvDispatch);
         agvThread.start();
+
+        rgvTread = new Thread(this::rgvDispatch);
+        rgvTread.start();
     }
     private void crnAndDevRun() {
         while (!Thread.currentThread().isInterrupted()) {
             try {
-
                 // 闂撮殧
                 Thread.sleep(1000);
-
                 // 绯荤粺杩愯鐘舵�佸垽鏂�
                 if (!SystemProperties.WCS_RUNNING_STATUS.get()) {
                     continue;
                 }
-
                 // 婕旂ず
 //                    mainService.crnDemoOfLocMove1();
                 //鍒锋柊RGV鍦板浘
                 mainService.refreshRgvMap();
-
                 // 鍏ュ嚭搴撴ā寮忓垏鎹㈠嚱鏁�
 //                    mainService.ioConvert();
-
                 // 鎷f枡銆佸苟鏉裤�佺洏鐐瑰啀鍏ュ簱
                 mainService.stnToCrnStnPick(3);
 //                    mainService.stnToCrnStnPick2();
-
                 // 鍏ュ簱  ===>> 鍏ュ簱绔欏埌鍫嗗灈鏈虹珯锛屾牴鎹潯鐮佹壂鎻忕敓鎴愬叆搴撳伐浣滄。
                 mainService.generateStoreWrkFile(1); // 缁勬墭
 //                    mainService.generateStoreWrkFile0(2); // WMS鍏ュ簱
                 Thread.sleep(50);
-
                 // 鍑哄簱  ===>>  鍫嗗灈鏈哄嚭搴撶珯鍒板嚭搴撶珯
                 mainService.crnStnToOutStn(4);
                 // 鍏ュ嚭搴�  ===>>  鍫嗗灈鏈哄叆鍑哄簱浣滀笟涓嬪彂
@@ -92,9 +88,7 @@
                 mainService.ledReset();
                 //鍫嗗灈鏈鸿鎺ヤ换鍔$敓鎴�
                 mainService.connectWrk(10);
-
 //                    mainService.outOfDevp(11);
-
                 if (i>10){
                     //绌烘墭鐩樿嚜鍔ㄥ嚭搴�
                     mainService.autoEmptyOut();
@@ -108,28 +102,27 @@
                 }
                 q++;
                 i++;
-
-                /////////////////////////////////////RGV璋冨害/////////////////////////////////////
-                k++;
-
-                // RGV  ===>>  灏忚溅浠诲姟浣滀笟涓嬪彂
-                try{
-                    //RGV灏忚溅鍑哄叆搴撳彇璐т笅鍙�
-                    mainService.rgvIoExecute(11);
-                    if(k > 2){
-                        mainService.rgvOutExecute();
-                        k = 0;
-                    }
-                }catch (Exception e){
-                    e.printStackTrace();
-                    log.error("RGV  ===>>  灏忚溅浠诲姟浣滀笟涓嬪彂寮傚父"+e);
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+    }
+    private void rgvDispatch() {
+        while (!Thread.currentThread().isInterrupted()) {
+            try {
+                // 闂撮殧
+                Thread.sleep(400);
+                // 绯荤粺杩愯鐘舵�佸垽鏂�
+                if (!SystemProperties.WCS_RUNNING_STATUS.get()) {
+                    continue;
                 }
-//                //瀹屾垚灏忚溅浠诲姟
-                mainService.rgvTaskComplete();
-
+                mainService.rgvIoExecute(11);//鍙栬揣
+                mainService.rgvOutExecute();//鏀捐揣
+                mainService.rgvTaskComplete();//浠诲姟瀹屾垚
 
             } catch (Exception e) {
                 e.printStackTrace();
+                log.error("RGV  ===>>  灏忚溅浠诲姟浣滀笟涓嬪彂寮傚父"+e);
             }
         }
     }

--
Gitblit v1.9.1