From 380e60cdf492df507eee1596aa9b0713d38c919f Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期四, 20 六月 2024 14:23:18 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |  134 ++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 127 insertions(+), 7 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 a853100..f1ba6b3 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -427,9 +427,10 @@
 //                // 鍏ュ嚭搴撴ā寮忓垽鏂�
 //                if (devpThread.ioMode != IoModeType.PAKIN_MODE) { continue; }
 
-                if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isInEnable() && staProtocol.isPakMk()) {
+                if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isInEnable() && staProtocol.isPakMk() && staProtocol.getWorkNo()!=0) {
 //                    WrkMast wrkMast = wrkMastMapper.selectPickStep(barcode);
-                    WrkMast wrkMast = wrkMastMapper.selectPakInStep5(staProtocol.getSiteId(),"7");
+//                    WrkMast wrkMast = wrkMastMapper.selectPakInStep5(staProtocol.getSiteId(),"7");
+                    WrkMast wrkMast = wrkMastMapper.selectPakInStep3(staProtocol.getWorkNo());
                     if (wrkMast == null) {
                         // 鏃犳嫞鏂欐暟鎹�
                         continue;
@@ -482,7 +483,7 @@
                                     staProtocol.setStaNo(dto.getStaNo());
                                     devpThread.setPakMk(staProtocol.getSiteId(), false);
 //                                    ledThread.errorReset();
-                                    boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
+                                    boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(5, staProtocol));
                                     if (!result) {
                                         log.error("鍙戝竷鍛戒护鑷宠緭閫佺嚎闃熷垪澶辫触锛侊紒锛� [plc缂栧彿锛歿}]", devp.getId());
                                     }
@@ -3344,6 +3345,14 @@
                 if (basDevp135.getReportSign()!=0){
                     continue;
                 }
+                BasDevp basDevp121 = basDevpService.selectById(121);
+                if (basDevp121.getReportSign()!=0){
+                    continue;
+                }
+                BasDevp basDevp120 = basDevpService.selectById(120);
+                if (basDevp120.getReportSign()!=0){
+                    continue;
+                }
                 WrkMast wrkMast131 = wrkMastMapper.selectWrkMastUnstackingOne202Two(131);
                 if (Cools.isEmpty(wrkMast131)){
                     continue;
@@ -3696,12 +3705,38 @@
                         if (!basDevp.getAutoing().equals("Y") || basDevp.getLoading().equals("Y") || basDevp.getWrkNo()!=0){
                             continue;
                         }
+                        if (basDevp.getDevNo()>117 && basDevp.getDevNo()<124){
+                            if (basDevp.getLoadingSuper().equals("Y")){
+                                continue;
+                            }
+                        }
                         if (basDevp.getDevNo()>=118 && basDevp.getDevNo()<=123){
                             if (!basDevp.getEmptyMk().equals("Y")){
                                 continue;
                             }
                         }
                         Date date = new Date();
+
+                        SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, rgvSlave.getDevpPlcId());
+                        StaProtocol staProtocol = devpThread.getStation().get(basDevp.getDevNo());
+                        if (staProtocol == null) {
+                            log.info(date+"鍙栨斁浠诲姟涓嬪彂锛氭湭鏌ヨ鍒扮珯鐐逛俊鎭細"+wrkMastSta);
+                            continue;
+                        }
+                        if (!staProtocol.isAutoing() || staProtocol.isLoading() || staProtocol.getWorkNo() != 0){
+                            continue;
+                        }
+                        if (basDevp.getDevNo()>117 && basDevp.getDevNo()<124){
+                            if (staProtocol.isLoadingSuper()){
+                                continue;
+                            }
+                        }
+                        if (basDevp.getDevNo()>=118 && basDevp.getDevNo()<=123){
+                            if (!staProtocol.isEmptyMk()){
+                                continue;
+                            }
+                        }
+
                         log.info(date+"鍙栨斁浠诲姟涓嬪彂锛氬皬杞﹀伐浣滄。锛�"+wrkMastSta);
                         log.info(date+"鍙栨斁浠诲姟涓嬪彂锛氱洰鏍囩珯鐘舵�侊細"+basDevp);
                         boolean sign = rgvTakeFullAll(basRgvMap.getRgvNo(), wrkMastSta);
@@ -3774,12 +3809,38 @@
                             if (!basDevp.getAutoing().equals("Y") || basDevp.getLoading().equals("Y") || basDevp.getWrkNo()!=0){
                                 continue;
                             }
+                            if (basDevp.getDevNo()>117 && basDevp.getDevNo()<124){
+                                if (basDevp.getLoadingSuper().equals("Y")){
+                                    continue;
+                                }
+                            }
                             if (basDevp.getDevNo()>=118 && basDevp.getDevNo()<=123){
                                 if (!basDevp.getEmptyMk().equals("Y")){
                                     continue;
                                 }
                             }
                             Date date = new Date();
+
+                            SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, rgvSlave.getDevpPlcId());
+                            StaProtocol staProtocol = devpThread.getStation().get(basDevp.getDevNo());
+                            if (staProtocol == null) {
+                                log.info(date+"鎷嗙洏浠诲姟涓嬪彂锛氭湭鏌ヨ鍒扮珯鐐逛俊鎭細"+wrkMastSta);
+                                continue;
+                            }
+                            if (!staProtocol.isAutoing() || staProtocol.isLoading() || staProtocol.getWorkNo() != 0){
+                                continue;
+                            }
+                            if (basDevp.getDevNo()>117 && basDevp.getDevNo()<124){
+                                if (staProtocol.isLoadingSuper()){
+                                    continue;
+                                }
+                            }
+                            if (basDevp.getDevNo()>=118 && basDevp.getDevNo()<=123){
+                                if (!staProtocol.isEmptyMk()){
+                                    continue;
+                                }
+                            }
+
                             log.info(date+"鎷嗙洏浠诲姟涓嬪彂锛氬皬杞﹀伐浣滄。锛�"+wrkMastSta);
                             log.info(date+"鎷嗙洏浠诲姟涓嬪彂锛氱洰鏍囩珯鐘舵�侊細"+basDevp);
                             sign = rgvPutEmpty(rgvProtocol.getRgvNo(),wrkMastSta);//鎷嗙洏
@@ -3856,12 +3917,38 @@
                             if (!basDevp.getAutoing().equals("Y") || basDevp.getLoading().equals("Y") || basDevp.getWrkNo()!=0){
                                 continue;
                             }
+                            if (basDevp.getDevNo()>117 && basDevp.getDevNo()<124){
+                                if (basDevp.getLoadingSuper().equals("Y")){
+                                    continue;
+                                }
+                            }
                             if (basDevp.getDevNo()>=118 && basDevp.getDevNo()<=123){
                                 if (!basDevp.getEmptyMk().equals("Y")){
                                     continue;
                                 }
                             }
                             Date date = new Date();
+
+                            SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, rgvSlave.getDevpPlcId());
+                            StaProtocol staProtocol = devpThread.getStation().get(basDevp.getDevNo());
+                            if (staProtocol == null) {
+                                log.info(date+"婊℃斁浠诲姟涓嬪彂锛氭湭鏌ヨ鍒扮珯鐐逛俊鎭細"+wrkMastSta);
+                                continue;
+                            }
+                            if (!staProtocol.isAutoing() || staProtocol.isLoading() || staProtocol.getWorkNo() != 0){
+                                continue;
+                            }
+                            if (basDevp.getDevNo()>117 && basDevp.getDevNo()<124){
+                                if (staProtocol.isLoadingSuper()){
+                                    continue;
+                                }
+                            }
+                            if (basDevp.getDevNo()>=118 && basDevp.getDevNo()<=123){
+                                if (!staProtocol.isEmptyMk()){
+                                    continue;
+                                }
+                            }
+
                             log.info(date+"婊℃斁浠诲姟涓嬪彂锛氬皬杞﹀伐浣滄。锛�"+wrkMastSta);
                             log.info(date+"婊℃斁浠诲姟涓嬪彂锛氱洰鏍囩珯鐘舵�侊細"+basDevp);
                             sign = rgvPutEmptyFull(rgvProtocol.getRgvNo(),wrkMastSta);
@@ -3941,6 +4028,22 @@
                                 }
                             }
                             Date date = new Date();
+
+                            SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, rgvSlave.getDevpPlcId());
+                            StaProtocol staProtocol = devpThread.getStation().get(basDevp.getDevNo());
+                            if (staProtocol == null) {
+                                log.info(date+"鍙犵洏浠诲姟涓嬪彂锛氭湭鏌ヨ鍒扮珯鐐逛俊鎭細"+wrkMastSta);
+                                continue;
+                            }
+                            if (!staProtocol.isAutoing() || !staProtocol.isLoading()){
+                                continue;
+                            }
+                            if (basDevp.getDevNo()>=118 && basDevp.getDevNo()<=123){
+                                if (!staProtocol.isEmptyMk()){
+                                    continue;
+                                }
+                            }
+
                             log.info(date+"鍙犵洏浠诲姟涓嬪彂锛氬皬杞﹀伐浣滄。锛�"+wrkMastSta);
                             log.info(date+"鍙犵洏浠诲姟涓嬪彂锛氱洰鏍囩珯鐘舵�侊細"+basDevp);
                             sign = rgvTakeEmpty(rgvProtocol.getRgvNo(),wrkMastSta);//鍙犵洏
@@ -4022,6 +4125,17 @@
                                 continue;
                             }
                             Date date = new Date();
+
+                            SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, rgvSlave.getDevpPlcId());
+                            StaProtocol staProtocol = devpThread.getStation().get(basDevp.getDevNo());
+                            if (staProtocol == null) {
+                                log.info(date+"婊″彇浠诲姟涓嬪彂锛氭湭鏌ヨ鍒扮珯鐐逛俊鎭細"+wrkMastSta);
+                                continue;
+                            }
+                            if (!staProtocol.isAutoing() || staProtocol.isLoading()){
+                                continue;
+                            }
+
                             log.info(date+"婊″彇浠诲姟涓嬪彂锛氬皬杞﹀伐浣滄。锛�"+wrkMastSta);
                             log.info(date+"婊″彇浠诲姟涓嬪彂锛氱洰鏍囩珯鐘舵�侊細"+basDevp);
                             sign = rgvTakeEmptyFull(rgvProtocol.getRgvNo(),wrkMastSta);
@@ -4103,11 +4217,11 @@
                         }
                     }
                     if (rgvProtocol.getRgvNo()==1 && (rgvProtocol.getRgvPosI().equals(101) || rgvProtocol.getRgvPosI().equals(102) )){
-                        signRgv = false;
-                        break;
+                        signRgv1 = false;
+                        continue;
                     } else if (rgvProtocol.getRgvNo()==2 && (rgvProtocol.getRgvPosI().equals(116) || rgvProtocol.getRgvPosI().equals(117) ) ){
-                        signRgv = false;
-                        break;
+                        signRgv2 = false;
+                        continue;
                     }
                 }else {
                     signRgv = false;
@@ -4131,9 +4245,15 @@
                             && rgvProtocol.getStatusType1() == RgvStatusType.IDLE
                             && rgvProtocol.getStatusType2() == RgvStatusType.IDLE
                     ) {
+                        if (rgvProtocol.getRgvNo()==1 && (rgvProtocol.getRgvPosI().equals(101) || rgvProtocol.getRgvPosI().equals(102) )){
+                            continue;
+                        } else if (rgvProtocol.getRgvNo()==2 && (rgvProtocol.getRgvPosI().equals(116) || rgvProtocol.getRgvPosI().equals(117) ) ){
+                            continue;
+                        }
                         BasRgvMap basRgvMap = basRgvMapMapper.selectById(rgvProtocol.getRgvNo());
                         rgvAvoidanceXY(rgvProtocol.getRgvNo());
                         rgvMapUpdate(basRgvMap,basRgvMap.getStartRoute(),basRgvMap.getStartRoute());
+
                     }
                 }
             }

--
Gitblit v1.9.1