From 3ad49e3f281d52edd7f121a398b93b408251811d Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期三, 02 八月 2023 15:17:41 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   36 ++++++++++++++++++++++++++++++------
 1 files changed, 30 insertions(+), 6 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 3eda0a6..fc57a64 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -241,6 +241,22 @@
                                 String errorMsg = barcode + "鎵樼洏璇嗗埆寮傚父锛岃鍏堣繘琛岀粍鎵橈紒";
                                 MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(3, errorMsg));
                             }
+                        } else if (code == 1000){
+                            if (inSta.getStaNo().equals(103)){
+                                staProtocol.setWorkNo((short)9999);
+                                staProtocol.setStaNo((short)203);
+                            }else {
+                                staProtocol.setWorkNo((short)9999);
+                                staProtocol.setStaNo((short)103);
+                            }
+                            devpThread.setPakMk(staProtocol.getSiteId(), false);
+                            MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
+
+                            // led 寮傚父鏄剧ず
+                            if (ledThread != null) {
+                                String errorMsg = barcode + "闇�瑕佹崲鍏ュ簱绔欍�傜洰鏍囩珯锛�"+staProtocol.getStaNo();
+                                MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(3, errorMsg));
+                            }
                         }
                     } catch (Exception e) {
                         e.printStackTrace();
@@ -387,12 +403,17 @@
                     staProtocol.setWorkNo(wrkMast.getWrkNo().shortValue());
                     staProtocol.setStaNo(staNo);
                     devpThread.setPakMk(staProtocol.getSiteId(), false);
-                    BasDevp basDevp = basDevpMapper.selectByDevNo(300);
-                    basDevp.setWrkNo1(wrkMast.getWrkNo());
-                    basDevpService.selectById(basDevp);
+                    if (staProtocol.getStaNo().equals(300)){
+                        BasDevp basDevp = basDevpMapper.selectByDevNo(300);
+                        basDevp.setWrkNo1(wrkMast.getWrkNo());
+                        basDevpService.selectById(basDevp);
+                        News.info("300绔欏幓鍏ュ簱绔欎换鍔′笅鍙戯紝鏇存柊绔欑偣琛紝[浠诲姟鍙�:{}锛岀珯鐐瑰彿:{}]", wrkMast.getWrkNo().shortValue(), staNo);
+                    }
                     boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                     if (!result) {
                         News.error("鍙戝竷鍛戒护鑷宠緭閫佺嚎闃熷垪澶辫触锛侊紒锛� [plc缂栧彿锛歿}]", devp.getId());
+                    } else {
+                        News.info("300绔欏幓鍏ュ簱绔欎换鍔″凡涓嬪彂锛孾浠诲姟鍙�:{}锛岀珯鐐瑰彿:{}]", wrkMast.getWrkNo().shortValue(), staNo);
                     }
                 }
             }
@@ -569,6 +590,11 @@
                     staProtocol.setWorkNo(wrkMast.getWrkNo().shortValue());
                     staProtocol.setStaNo(wrkMast.getStaNo().shortValue());
                     devpThread.setPakMk(staProtocol.getSiteId(), false);
+                    if (staProtocol.getStaNo().equals(300)){
+                        BasDevp basDevp = basDevpMapper.selectByDevNo(300);
+                        basDevp.setWrkNo1(wrkMast.getWrkNo());
+                        basDevpService.selectById(basDevp);
+                    }
                     boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                     if (!result) {
                         News.error("鍙戝竷鍛戒护鑷宠緭閫佺嚎闃熷垪澶辫触锛侊紒锛� [plc缂栧彿锛歿}]", devp.getId());
@@ -1343,9 +1369,7 @@
                                         }else {
                                             waitWrkMast.setIoPri(9999d);
                                         }
-                                        if(wrkMast.getIoPri()>=9000.0){
-                                            wrkMast.setIoPri(9999d);
-                                        }else if (wrkMast.getIoPri()>20.0){
+                                        if (wrkMast.getIoPri()>23.0){
                                             wrkMast.setIoPri(wrkMast.getIoPri()-10.0);
                                         }else {
                                             wrkMast.setIoPri(13.0d);

--
Gitblit v1.9.1