From b4e0f827567f8d5ad4a1ff5caa22675cbc165b88 Mon Sep 17 00:00:00 2001
From: lsh <lsh123456>
Date: 星期三, 11 六月 2025 10:27:31 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   18 +++++++++++++++++-
 1 files changed, 17 insertions(+), 1 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
index 36cecc3..4b83d4a 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -1561,7 +1561,15 @@
      */
     public synchronized void locToCrnStn1(CrnSlave slave, CrnProtocol crnProtocol) {
         List<WrkMast> wrkMasts = wrkMastMapper.selectPakOutStep12(slave.getId());
+        Double pri = 0.0;
         for (WrkMast wrkMast : wrkMasts) {
+            if (wrkMast.getIoType() != 110){
+                if (wrkMast.getIoPri()>=pri){
+                    pri = wrkMast.getIoPri();
+                } else {
+                    continue;
+                }
+            }
             if (wrkMast == null) {
                 continue;
             }
@@ -1640,7 +1648,11 @@
                             log.error("{}搴撲綅寮傚父锛屾湭妫�绱㈠埌鐩稿簲宸ヤ綔妗o紒", shallowLocNo);
                         } else {
                             if (waitWrkMast.getWrkSts() == 11) {
-                                waitWrkMast.setIoPri(15D);
+                                if (waitWrkMast.getIoPri() + 100000D < 99999999) {
+                                    waitWrkMast.setIoPri(waitWrkMast.getIoPri()+100000D);
+                                } else {
+                                    waitWrkMast.setIoPri(99999999D);
+                                }
                                 waitWrkMast.setModiTime(new Date());
                                 if (wrkMastMapper.updateById(waitWrkMast) == 0) {
                                     log.error("璋冩暣宸ヤ綔妗d紭鍏堢骇澶辫触锛佸伐浣滃彿={}", waitWrkMast.getWrkNo());
@@ -1676,6 +1688,9 @@
                         if (null != waitWrkMast && waitWrkMast.getWrkSts() == 4) {
                             continue;
                         }
+                    } else if (!shallowLoc.getLocSts().equals("O") ){
+                        log.error("{}浠诲姟鍑哄簱澶辫触锛屾祬搴撲綅鍫靛锛佹祬搴撲綅鍙�:{},娴呭簱浣嶇姸鎬�:{}", wrkMast.getWrkNo(), shallowLocNo,shallowLoc.getLocSts());
+                        continue;
                     }
                 }
 
@@ -3185,6 +3200,7 @@
                     staProtocolnew.setWorkNo(wrkMast.getWrkNo());
                     staProtocolnew.setStaNo(144);
                     devpThread.setPakMk(staProtocolnew.getSiteId(), false);
+                    devpThread.setReportSign(staProtocolnew.getSiteId(), true);
                     boolean result = MessageQueue.offer(SlaveType.Devp, devpThread.getSlave().getId(), new Task(2, staProtocolnew));
                     if (!result) {
                         throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触==>椹卞姩鐮佸灈浣嶆墭鐩樺墠杩涘け璐ワ紒");

--
Gitblit v1.9.1