From 675db903cd534aa16b59f5e9bf87da3e699e5d30 Mon Sep 17 00:00:00 2001
From: 野心家 <1051256694@qq.com>
Date: 星期六, 29 七月 2023 16:36:46 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/jxfywcs' into jxfywcs

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |  100 +++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 98 insertions(+), 2 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 353d491..525a375 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -1,5 +1,7 @@
 package com.zy.asrs.service.impl;
 
+import HslCommunication.Core.Types.OperateResultExOne;
+import HslCommunication.Profinet.Siemens.SiemensS7Net;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
@@ -89,7 +91,6 @@
     private BasCrnErrorMapper basCrnErrorMapper;
     @Autowired
     private WrkMastService wrkMastService;
-
     @Value("${wms.url}")
     private String wmsUrl;
 
@@ -146,9 +147,44 @@
 //                        continue;
 //                    }
 //                }
+                //瓒呭瓒呴珮娌℃壂鍒版潯鐮佹姤璀�
+                boolean fig=false;
+                for(int i=0;i<8;i++){
+                    switch (i){
+                        case 0: if(devpThread.startSignal[i]){
+                            log.error("鍓嶈秴鎶ヨ");
+                            fig=true;
+                        };
+                        case 1: if(devpThread.startSignal[i]){
+                            log.error("鍚庤秴鎶ヨ");
+                            fig=true;
+                        };
+                        case 2: if(devpThread.startSignal[i]){
+                            log.error("楂樿秴鎶ヨ");
+                            fig=true;
+                        };
+                        case 3: if(devpThread.startSignal[i]){
+                            log.error("宸﹁秴鎶ヨ");
+                            fig=true;
+                        };
+                        case 4: if(devpThread.startSignal[i]){
+                            log.error("鍙宠秴鎶ヨ");
+                            fig=true;
+                        };
+                        case 5: if(devpThread.startSignal[i]){
+                            log.error("瓒呴噸鎶ヨ");
+                            fig=true;
+                        };
+                        case 6: if(devpThread.startSignal[i]){
+                            log.error("鏈壂鍒扮爜鎶ヨ");
+                            fig=true;
+                        };
+
+                    }
+                }
                 if (staProtocol.isAutoing() && staProtocol.isInEnable()
                         && !staProtocol.isEmptyMk() && (staProtocol.getWorkNo() == 0 || staProtocol.getWorkNo() > 9990)
-                        && staProtocol.isPakMk()) { //&& staProtocol.getStamp()>=2) {// && !Cools.isEmpty(barcode)) {
+                        && staProtocol.isPakMk() && !fig) { //&& staProtocol.getStamp()>=2) {// && !Cools.isEmpty(barcode)) {
                     News.warnNoLog(""+mark+" - 0"+" - 寮�濮嬫墽琛�");
 //                    try {
 //                        Thread.sleep(300);
@@ -2233,4 +2269,64 @@
             }
         }
     }
+
+    /**
+     *  鎺ユ敹瓒呭瓒呴珮娌℃壂鍒版潯鐮佹姤璀�
+     * @param mark
+     */
+    public synchronized void DevpCallThePolice(Integer mark){
+        // 鏍规嵁杈撻�佺嚎plc閬嶅巻
+        for (DevpSlave devp : slaveProperties.getDevp()) { //閬嶅巻杈撻�佺嚎
+            // 閬嶅巻鍏ュ簱鍙�
+            for (DevpSlave.Sta inSta : devp.getInSta()) {  // 閬嶅巻鍏ュ簱鍙�
+                // 鑾峰彇鍏ュ簱绔欎俊鎭�
+                SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
+                StaProtocol staProtocol = devpThread.getStation().get(inSta.getStaNo());
+                if(null != devpThread){
+                    boolean fig=false;
+                    for (int i=0;i<8;i++){
+                        switch (i){
+                            case 0: if(devpThread.startSignal[i]){
+                                        log.error("鍓嶈秴鎶ヨ");
+                                        fig=true;
+                                    };
+                            case 1: if(devpThread.startSignal[i]){
+                                log.error("鍚庤秴鎶ヨ");
+                                fig=true;
+                            };
+                            case 2: if(devpThread.startSignal[i]){
+                                log.error("楂樿秴鎶ヨ");
+                                fig=true;
+                            };
+                            case 3: if(devpThread.startSignal[i]){
+                                log.error("宸﹁秴鎶ヨ");
+                                fig=true;
+                            };
+                            case 4: if(devpThread.startSignal[i]){
+                                log.error("鍙宠秴鎶ヨ");
+                                fig=true;
+                            };
+                            case 5: if(devpThread.startSignal[i]){
+                                log.error("瓒呴噸鎶ヨ");
+                                fig=true;
+                            };
+                            case 6: if(devpThread.startSignal[i]){
+                                log.error("鏈壂鍒扮爜鎶ヨ");
+                                fig=true;
+                            };
+
+                        }
+                    }
+                    //鍙戠敓鎶ヨ锛岄��鍥炲叆搴撳彛
+                    if(fig){
+                        staProtocol.setWorkNo((short)9991);
+                        staProtocol.setStaNo((short)100);
+                        devpThread.setPakMk(staProtocol.getSiteId(), false);
+                        boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
+                    }
+                }
+            }
+        }
+    }
+
 }

--
Gitblit v1.9.1