From 2e5837667e60378a06c7d8d1a4b095c4ba6e2d06 Mon Sep 17 00:00:00 2001
From: pjb <pjb123456>
Date: 星期一, 17 十一月 2025 09:29:08 +0800
Subject: [PATCH] 限制优化

---
 src/main/java/com/zy/service/impl/MainServiceImpl.java |   13 ++++++++++---
 src/main/java/com/zy/core/MainProcess.java             |   10 ++++++++--
 2 files changed, 18 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/zy/core/MainProcess.java b/src/main/java/com/zy/core/MainProcess.java
index 8aaa693..6f9a51a 100644
--- a/src/main/java/com/zy/core/MainProcess.java
+++ b/src/main/java/com/zy/core/MainProcess.java
@@ -1,13 +1,15 @@
 package com.zy.core;
 
-import com.zy.service.impl.MainServiceImpl;
 import com.zy.core.properties.SystemProperties;
+import com.zy.service.impl.MainServiceImpl;
+import com.zy.utils.News;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.PreDestroy;
+import java.util.Date;
 
 /**
  * WCS涓绘祦绋�
@@ -34,6 +36,7 @@
             // 鍒濆鍖栫綈瑁呯嚎鍑哄簱鍙f槸鍚﹀彲鍑�
             while (!Thread.currentThread().isInterrupted()) {
                 try {
+                    long startTime = System.currentTimeMillis();
                     Thread.sleep(1000);
 
                     // 绯荤粺杩愯鐘舵�佸垽鏂�
@@ -104,7 +107,10 @@
 
                     //鎵嬪姩绔欎綅杞Щ
                     mainService.manualStationTransfer();
-
+                    long endTime = System.currentTimeMillis();
+                    if (endTime-startTime > 4000) {
+                        News.info("--------------------WCS寰幆{}->{}锛岃�楁椂锛歿}------------------------",new Date(startTime),new Date(endTime),endTime-startTime);
+                    }
                 } catch (Exception e) {
                     e.printStackTrace();
                 }
diff --git a/src/main/java/com/zy/service/impl/MainServiceImpl.java b/src/main/java/com/zy/service/impl/MainServiceImpl.java
index aaeb04e..f5ac54f 100644
--- a/src/main/java/com/zy/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/service/impl/MainServiceImpl.java
@@ -326,7 +326,7 @@
     /**
      * 缃愯绾胯妗舵暟閲忓噺灏�
      */
-    private void decreaseWantBucketCount(int site, int decrease) throws InterruptedException {
+    private synchronized void decreaseWantBucketCount(int site, int decrease) throws InterruptedException {
 
         int siteNew;
         switch (site) {
@@ -363,6 +363,7 @@
         }
 
         log.info("鑷姩鍑虹┖妗跺噺灏戠綈瑁呯嚎瑕佹《鏁版垚鍔燂紝绔欑偣锛歿}锛屽噺灏戝墠锛歿}锛屽噺灏戞暟锛歿}锛屽墿浣欒妗舵暟锛歿}", site, count, decrease, remaining);
+        Thread.sleep(700);
     }
 
     /**
@@ -1339,6 +1340,7 @@
                     wrkMast.setWorkNoOther(0); // 娓呯┖鍙︿竴涓换鍔″彿
                     // 淇敼鎴愬姛鍚庡浣嶅爢鍨涙満
                     if (wrkMastMapper.updateById(wrkMast) > 0) {
+                        log.info("{}鍙峰爢鍨涙満浠诲姟瀹屾垚锛岀敵璇峰浣嶏紝浠诲姟鍙凤細{}",crnProtocol.getCrnNo(),crnProtocol.getTaskNo());
                         // 鍫嗗灈鏈哄浣�
                         News.warnNoLog(""+mark+" - 2"+" - 淇敼鎴愬姛鍚庡浣嶅爢鍨涙満 : 鍫嗗灈鏈哄彿={}",crnThread.getCrnProtocol().getCrnNo());
                         crnThread.setResetFlag(true);
@@ -2215,7 +2217,8 @@
                     wrkMast.setWrkSts(15L);
                     wrkMast.setModiTime(new Date());
                     wrkMastService.updateById(wrkMast);
-                } else if(wrkMast.getIoType() == 110 && (wrkMast.getStaNo() == 1002 || wrkMast.getStaNo() == 1020 ||wrkMast.getStaNo() == 1035 || wrkMast.getStaNo() == 1024)) {
+                } else if(wrkMast.getIoType() == 110 && (wrkMast.getStaNo() == 1002 || wrkMast.getStaNo() == 1020 ||wrkMast.getStaNo() == 1035
+                        || wrkMast.getStaNo() == 1024 || wrkMast.getStaNo() == 1016|| wrkMast.getStaNo() == 1043)) {
                     if(wrkMast.getWrkSts() != 2 ){
                         log.warn("rgv鏀捐揣瀹屾垚110锛宺gv鏈浣�:rgv鍙穥}锛屼换鍔″彿锛歿}锛屼换鍔$姸鎬亄}",wrkMast.getRgvNo(),wrkMast.getWrkNo(),wrkMast.getWrkSts());
                         continue;
@@ -2319,7 +2322,7 @@
                 }
 
                 // 绔欑偣鏉′欢鍒ゆ柇
-                if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isInEnable() && staProtocol.getWorkNo() == 0) {
+                if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isInEnable() && staProtocol.getWorkNo() == 0 && staProtocol.isHigh()) {
                     if(site == 1019 && staProtocol.getHideWorkNo() != 0) {
                         WrkMast wrkMast1 = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", staProtocol.getHideWorkNo()));
                         if(wrkMast1 != null && wrkMast1.getWrkSts() != 15) {
@@ -2327,6 +2330,10 @@
                             continue;
                         }
                     }
+                    int count = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("io_type", 10).eq("source_sta_no", site));
+                    if (count >= 2) {
+                        News.warn("闄愬埗{}绌烘瘝鎵樺彔鐩樺叆搴撴暟灏忎簬2锛屽綋鍓嶏細{}", site, count);
+                    }
                     try {
                         SearchLocParam param = new SearchLocParam();
                         param.setIoType(10);

--
Gitblit v1.9.1