From 73fd9aecc97d33f51ae7fe0350f3423cf8fd824f Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期一, 10 二月 2025 08:11:31 +0800
Subject: [PATCH] *

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   86 ++++++++++++++++++++++++++++++++++---------
 1 files changed, 68 insertions(+), 18 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 4451bad..2185eff 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -3096,6 +3096,13 @@
             }
 
             Integer turnBigInt = 0;
+            if (wrkMast.booleanStaNoSign() && wrkMast.getIoPri()<99D){
+                Date now = new Date();
+                long differenceInSeconds =  now.getTime() - wrkMast.getModiTime().getTime();
+                if (differenceInSeconds<=2000){
+                    continue;
+                }
+            }
 //            if (wrkMast.booleanStaNoSign()){
 //                RgvOneSign rgvOneSign = rgvOneSignMapper.selectOneSign("LineUp"+wrkMast.getStaNo());
 //                if (Cools.isEmpty(rgvOneSign)){
@@ -5904,6 +5911,42 @@
             if (basJarMastList.isEmpty()){
                 return false;
             }
+
+            StaProtocol staProtocolEnd = new StaProtocol();
+            staProtocolEnd.setAutoing(false);
+            for (DevpSlave devp : slaveProperties.getDevp()) {
+                if (devp.getId() == 1){
+                    continue;
+                }
+                // 閬嶅巻鍏ュ簱鍙�
+                for (DevpSlave.Sta inSta : devp.getOutJarInSta()) {
+                    if (jarSlave.getId() == 1 || jarSlave.getId() == 2){
+                        if (inSta.getStaNo() == 627){
+                            SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
+                            StaProtocol staProtocol = devpThread.getStation().get(inSta.getStaNo());
+                            if (staProtocol == null) {
+                                break;
+                            }
+                            staProtocolEnd = staProtocol;
+                            break;
+                        }
+                    } else if (jarSlave.getId() == 3 || jarSlave.getId() == 4){
+                        if (inSta.getStaNo() == 628){
+                            SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
+                            StaProtocol staProtocol = devpThread.getStation().get(inSta.getStaNo());
+                            if (staProtocol == null) {
+                                break;
+                            }
+                            staProtocolEnd = staProtocol;
+                            break;
+                        }
+                    }
+
+                }
+            }
+            if (!staProtocolEnd.isAutoing() || staProtocolEnd.isLoading()){
+                return false;
+            }
             List<BasJarMast> basJarMastList10 = basJarMastService.getJarMastByJarIdAndStatusList(jarSlave.getId(), new ArrayList<Integer>() {{
                 add(10);
             }});
@@ -8047,6 +8090,7 @@
 //
 //                    }
                     List<WrkMastExecute> wrkMastExecuteByWrkNoList = wrkMastExecuteService.getWrkMastExecuteByWrkNoList(steProtocol.getTaskNo().longValue());
+                    steReturn:
                     for (WrkMastExecute wrkMastExecute : wrkMastExecuteByWrkNoList){
                         if (!Cools.isEmpty(wrkMastExecute)){
                             switch (wrkMastExecute.getIoType()){
@@ -8063,12 +8107,14 @@
                                                             wrkMastExecute.getSteId(), JSON.toJSONString(wrkMastExecute), JSON.toJSON(steProtocol),sign);
                                                 }
 //                                                Thread.sleep(500);
-                                                return true;
+//                                                return true;
+                                                break steReturn;
                                             }
                                         }
-                                        log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>涓嬪彂寮傚父锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}",
-                                                wrkMastExecute.getSteId(), JSON.toJSONString(wrkMastExecute), JSON.toJSONString(steProtocol),sign);
-                                        return true;
+//                                        log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>涓嬪彂寮傚父锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}",
+//                                                wrkMastExecute.getSteId(), JSON.toJSONString(wrkMastExecute), JSON.toJSONString(steProtocol),sign);
+//                                      return true;
+                                        break steReturn;
                                     }
                                 case 5:
                                     if (wrkMastExecute.getWrkSts()==5){
@@ -8082,12 +8128,14 @@
                                                     log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>鏇存柊wrkMastExecute澶辫触锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}",
                                                             wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(steProtocol),sign);
                                                 }
-                                                return true;
+//                                              return true;
+                                                break steReturn;
                                             }
                                         }
-                                        log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>涓嬪彂寮傚父锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}",
-                                                wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(steProtocol),sign);
-                                        return true;
+//                                        log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>涓嬪彂寮傚父锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}",
+//                                                wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(steProtocol),sign);
+//                                      return true;
+                                        break steReturn;
                                     }
                                     continue;
                                 case 7:
@@ -8105,12 +8153,14 @@
                                                     log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>鏇存柊wrkMastExecute澶辫触锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}",
                                                             wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(steProtocol),sign);
                                                 }
-                                                return true;
+//                                              return true;
+                                                break steReturn;
                                             }
                                         }
-                                        log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>涓嬪彂寮傚父锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}",
-                                                wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(steProtocol),sign);
-                                        return true;
+//                                        log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>涓嬪彂寮傚父锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}",
+//                                                wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(steProtocol),sign);
+//                                      return true;
+                                        break steReturn;
                                     }
                                     continue;
                                 case 9:
@@ -8125,17 +8175,17 @@
                                                     log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>鏇存柊wrkMastExecute澶辫触锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}",
                                                             wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(steProtocol),sign);
                                                 }
-                                                return true;
+//                                              return true;
+                                                break steReturn;
                                             }
                                         }
-                                        log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>涓嬪彂寮傚父锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}",
-                                                wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(steProtocol),sign);
+//                                        log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>涓嬪彂寮傚父锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}",
+//                                                wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(steProtocol),sign);
                                         continue;
                                     }
                                 default: continue;
                             }
                         }
-
                     }
                 }
             }
@@ -8272,7 +8322,7 @@
                             log.error("纭寲缃怞ar鍛戒护涓嬪彂澶辫触锛宩ar鍙�={},浠诲姟鏁版嵁={},纭寲缃愭暟鎹�={},sign={}",
                                     execute.getJarId(), JSON.toJSON(execute), JSON.toJSON(jarProtocol),sign);
                         }
-                        return true;
+                        continue;
                     }
                     for (WrkMastExecute wrkMastExecute : wrkMastExecuteList){
                         if (wrkMastExecute.getIoType() == 2 || wrkMastExecute.getIoType() == 4){
@@ -8287,7 +8337,7 @@
                                         wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(jarProtocol),sign);
                                 return false;
                             }
-                            return true;
+                            continue;
                         }
                     }
                 }

--
Gitblit v1.9.1