From 13c2b426704d4ec12e4c263d054cec2f1416be39 Mon Sep 17 00:00:00 2001
From: TQS <56479841@qq.com>
Date: 星期二, 22 十一月 2022 12:28:24 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   44 +++++++++++++++++++++++++++++++++++++++++++-
 src/main/java/com/zy/asrs/mapper/WrkMastMapper.java         |    7 +++++++
 src/main/resources/mapper/WrkMastMapper.xml                 |    4 ++++
 3 files changed, 54 insertions(+), 1 deletions(-)

diff --git a/src/main/java/com/zy/asrs/mapper/WrkMastMapper.java b/src/main/java/com/zy/asrs/mapper/WrkMastMapper.java
index 36b4585..0e815ed 100644
--- a/src/main/java/com/zy/asrs/mapper/WrkMastMapper.java
+++ b/src/main/java/com/zy/asrs/mapper/WrkMastMapper.java
@@ -105,4 +105,11 @@
      * @return
      */
     WrkMast selectLocMoveData(@Param("crnNo")Integer crnNo);
+
+    /**
+     * 鏌ユ壘宸ヤ綔妗f槸鍚﹀凡瀛樺湪缁戝畾灏忚溅鍙风殑浠诲姟锛岀姸鎬�17鐨勯櫎澶�
+     * @param steNo
+     * @return
+     */
+    WrkMast selectSteNoData(@Param("steNo")Integer steNo);
 }
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 ca4c351..9e28c38 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -1070,6 +1070,12 @@
                             if (steProtocol == null) { continue; }
                             if (steProtocol.isIdle()) {
 
+                                //灏忚溅鍙兘缁戝畾涓�绗斾綔涓氫腑浠诲姟
+                                WrkMast wrkMast1 = wrkMastMapper.selectSteNoData(steNo);
+                                if(wrkMast1 != null){
+                                    continue;
+                                }
+
                                 // 鍛戒护涓嬪彂鍖� --------------------------------------------------------------------------
                                 SteCommand steCommand = new SteCommand();
                                 steCommand.setSteNo(steNo); // 绌挎杞︾紪鍙�
@@ -1261,6 +1267,12 @@
                     SteProtocol steProtocol = steThread.getSteProtocol();
                     if (steProtocol == null) { return; }
                     if (steProtocol.isIdle()) {
+
+                        //灏忚溅鍙兘缁戝畾涓�绗斾綔涓氫腑浠诲姟
+                        WrkMast wrkMast1 = wrkMastMapper.selectSteNoData(steNo);
+                        if(wrkMast1 != null){
+                            return;
+                        }
 
                         // 鍛戒护涓嬪彂鍖� --------------------------------------------------------------------------
                         SteCommand steCommand = new SteCommand();
@@ -1689,6 +1701,12 @@
                     if (steProtocol == null) { return; }
                     if (steProtocol.isIdle()) {
 
+                        //灏忚溅鍙兘缁戝畾涓�绗斾綔涓氫腑浠诲姟
+                        WrkMast wrkMast1 = wrkMastMapper.selectSteNoData(steNo);
+                        if(wrkMast1 != null){
+                            return;
+                        }
+
                         // 鍛戒护涓嬪彂鍖� --------------------------------------------------------------------------
                         SteCommand steCommand = new SteCommand();
                         steCommand.setSteNo(steNo); // 绌挎杞︾紪鍙�
@@ -1884,6 +1902,12 @@
         if (steProtocol == null) { return; }
         if (steProtocol.isIdle()) {
 
+            //灏忚溅鍙兘缁戝畾涓�绗斾綔涓氫腑浠诲姟
+            WrkMast wrkMast1 = wrkMastMapper.selectSteNoData(steNo);
+            if(wrkMast1 != null){
+                return;
+            }
+
             // 鍛戒护涓嬪彂鍖� --------------------------------------------------------------------------
             SteCommand steCommand = new SteCommand();
             steCommand.setSteNo(steNo); // 绌挎杞︾紪鍙�
@@ -1897,7 +1921,7 @@
             if (!MessageQueue.offer(SlaveType.Ste, steNo, new Task(2, steCommand))) {
                 log.error("绌挎杞﹀懡浠や笅鍙戝け璐ワ紝绌挎杞﹀彿={}锛屼换鍔℃暟鎹�={}", steNo, JSON.toJSON(steCommand));
             } else {
-                log.error("绌挎杞﹀懡浠や笅鍙戞垚鍔熻灏忚溅浠� 杩滅偣 ====>> 寰呮満浣嶏紝IoType={}, 绌挎杞﹀彿={}锛屼换鍔℃暟鎹�={}", wrkMast.getIoType(), steNo, JSON.toJSON(steCommand));
+                log.error("绌挎杞﹀懡浠や笅鍙戞垚鍔熻灏忚溅浠� 杩滅偣 ====>> 寰呮満浣�,缁戝畾绌挎杞�,IoType={}, 绌挎杞﹀彿={}锛屼换鍔℃暟鎹�={}", wrkMast.getIoType(), steNo, JSON.toJSON(steCommand));
                 // 淇敼宸ヤ綔妗g姸鎬� 缁戝畾绌挎杞�
                 wrkMast.setSteNo(steNo);
                 wrkMast.setModiTime(new Date());
@@ -1916,6 +1940,12 @@
 
         if (!basSteService.updatePakMk(steNo, "Y")) {
             log.error("淇敼绌挎杞︿綔涓氱姸鎬� 澶辫触锛侊紒锛岀┛姊溅={}", steNo);
+            return;
+        }
+
+        //灏忚溅鍙兘缁戝畾涓�绗斾綔涓氫腑浠诲姟
+        WrkMast wrkMast1 = wrkMastMapper.selectSteNoData(steNo);
+        if(wrkMast1 != null){
             return;
         }
 
@@ -1952,6 +1982,12 @@
         if (steProtocol == null) { return; }
         if (steProtocol.isIdle()) {
 
+            //灏忚溅鍙兘缁戝畾涓�绗斾綔涓氫腑浠诲姟
+            WrkMast wrkMast1 = wrkMastMapper.selectSteNoData(steNo);
+            if(wrkMast1 != null){
+                return;
+            }
+
             // 鍛戒护涓嬪彂鍖� --------------------------------------------------------------------------
             SteCommand steCommand = new SteCommand();
             steCommand.setSteNo(steNo); // 绌挎杞︾紪鍙�
@@ -1988,6 +2024,12 @@
         if (steProtocol == null) { return; }
         if (steProtocol.isIdle()) {
 
+            //灏忚溅鍙兘缁戝畾涓�绗斾綔涓氫腑浠诲姟
+            WrkMast wrkMast1 = wrkMastMapper.selectSteNoData(steNo);
+            if(wrkMast1 != null){
+                return;
+            }
+
             // 鍛戒护涓嬪彂鍖� --------------------------------------------------------------------------
             SteCommand steCommand = new SteCommand();
             steCommand.setSteNo(steNo); // 绌挎杞︾紪鍙�
diff --git a/src/main/resources/mapper/WrkMastMapper.xml b/src/main/resources/mapper/WrkMastMapper.xml
index 5959ba6..3d1b6f4 100644
--- a/src/main/resources/mapper/WrkMastMapper.xml
+++ b/src/main/resources/mapper/WrkMastMapper.xml
@@ -180,4 +180,8 @@
     <select id="selectLocMoveData" resultMap="BaseResultMap">
         select top 1 * from dbo.asr_wrk_mast where crn_no=#{crnNo} and io_type=11 order by io_pri desc,io_time,wrk_no asc
     </select>
+
+    <select id="selectSteNoData" resultMap="BaseResultMap">
+        select top 1 * from dbo.asr_wrk_mast where ste_no=#{steNo} and wrk_sts!=17 order by io_pri desc,io_time,wrk_no asc
+    </select>
 </mapper>

--
Gitblit v1.9.1