From 63132a4f8e347375b1fbdc4bd1086ecde8ea812d Mon Sep 17 00:00:00 2001
From: yxFwq <1>
Date: 星期六, 23 十一月 2024 15:36:37 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/core/thread/SiemensDevpThread.java |  103 ++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 101 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/SiemensDevpThread.java b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
index f9ee3d8..6cc420d 100644
--- a/src/main/java/com/zy/core/thread/SiemensDevpThread.java
+++ b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
@@ -10,6 +10,8 @@
 import com.core.common.SpringUtils;
 import com.core.exception.CoolException;
 import com.zy.asrs.entity.BasDevp;
+import com.zy.asrs.entity.RgvOneSign;
+import com.zy.asrs.mapper.RgvOneSignMapper;
 import com.zy.asrs.service.BasDevpService;
 import com.zy.core.DevpThread;
 import com.zy.core.News;
@@ -345,6 +347,103 @@
                     }catch (Exception e){
                         log.error("璇诲彇RGV淇℃伅澶辫触"+e.getMessage());
                     }
+                }
+            }
+        } else if (slave.getId()==1){
+            try{
+                RgvOneSignMapper rgvOneSignMapper = SpringUtils.getBean(RgvOneSignMapper.class);
+
+                OperateResultExOne<byte[]> resultSignOne = siemensS7Net.Read("DB293.106", (short) (8));
+
+                int smallEmpty = siemensS7Net.getByteTransform().TransInt16(resultSignOne.Content, 0);// 灏忔枡绌烘墭
+                int bigEmpty = siemensS7Net.getByteTransform().TransInt16(resultSignOne.Content, 2);// 澶ф枡绌烘墭
+                int smallTurn = siemensS7Net.getByteTransform().TransInt16(resultSignOne.Content, 4);// 灏忔枡缈昏浆
+                int bigTurn = siemensS7Net.getByteTransform().TransInt16(resultSignOne.Content, 6);// 澶ф枡缈昏浆
+
+                try{
+                    RgvOneSign smallEmptySign = rgvOneSignMapper.selectOneSign("smallEmpty");
+                    if (!Cools.isEmpty(smallEmptySign)){
+                        smallEmptySign.setRgvOneSign(smallEmpty);
+                        rgvOneSignMapper.updateById(smallEmptySign);
+                    }
+                } catch (Exception e){
+                    RgvOneSign smallEmptySign = rgvOneSignMapper.selectOneSign("smallEmpty");
+                    if (!Cools.isEmpty(smallEmptySign)){
+                        smallEmptySign.setRgvOneSign(999);
+                        rgvOneSignMapper.updateById(smallEmptySign);
+                    }
+                }
+                try{
+                    RgvOneSign bigEmptySign = rgvOneSignMapper.selectOneSign("bigEmpty");
+                    if (!Cools.isEmpty(bigEmptySign)){
+                        bigEmptySign.setRgvOneSign(bigEmpty);
+                        rgvOneSignMapper.updateById(bigEmptySign);
+                    }
+                } catch (Exception e){
+                    RgvOneSign bigEmptySign = rgvOneSignMapper.selectOneSign("bigEmpty");
+                    if (!Cools.isEmpty(bigEmptySign)){
+                        bigEmptySign.setRgvOneSign(999);
+                        rgvOneSignMapper.updateById(bigEmptySign);
+                    }
+                }
+                try{
+                    RgvOneSign smallTurnSign = rgvOneSignMapper.selectOneSign("smallTurn");
+                    if (!Cools.isEmpty(smallTurnSign)){
+                        smallTurnSign.setRgvOneSign(smallTurn);
+                        rgvOneSignMapper.updateById(smallTurnSign);
+                    }
+                } catch (Exception e){
+                    RgvOneSign smallTurnSign = rgvOneSignMapper.selectOneSign("smallTurn");
+                    if (!Cools.isEmpty(smallTurnSign)){
+                        smallTurnSign.setRgvOneSign(999);
+                        rgvOneSignMapper.updateById(smallTurnSign);
+                    }
+                }
+                try{
+                    RgvOneSign bigTurnSign = rgvOneSignMapper.selectOneSign("bigTurn");
+                    if (!Cools.isEmpty(bigTurnSign)){
+                        bigTurnSign.setRgvOneSign(bigTurn);
+                        rgvOneSignMapper.updateById(bigTurnSign);
+                    }
+                } catch (Exception e){
+                    RgvOneSign bigTurnSign = rgvOneSignMapper.selectOneSign("bigTurn");
+                    if (!Cools.isEmpty(bigTurnSign)){
+                        bigTurnSign.setRgvOneSign(999);
+                        rgvOneSignMapper.updateById(bigTurnSign);
+                    }
+                }
+            } catch (Exception e){
+                log.error("璇诲彇杈撻�佺嚎鏁伴噺鏍囪鍑虹幇寮傚父锛�"+e);
+                try{
+                    RgvOneSignMapper rgvOneSignMapper = SpringUtils.getBean(RgvOneSignMapper.class);
+
+                    RgvOneSign smallEmptySign = rgvOneSignMapper.selectOneSign("smallEmpty");
+                    if (!Cools.isEmpty(smallEmptySign)){
+                        smallEmptySign.setRgvOneSign(999);
+                        rgvOneSignMapper.updateById(smallEmptySign);
+                    }
+
+
+                    RgvOneSign bigEmptySign = rgvOneSignMapper.selectOneSign("bigEmpty");
+                    if (!Cools.isEmpty(bigEmptySign)){
+                        bigEmptySign.setRgvOneSign(999);
+                        rgvOneSignMapper.updateById(bigEmptySign);
+                    }
+
+
+                    RgvOneSign smallTurnSign = rgvOneSignMapper.selectOneSign("smallTurn");
+                    if (!Cools.isEmpty(smallTurnSign)){
+                        smallTurnSign.setRgvOneSign(999);
+                        rgvOneSignMapper.updateById(smallTurnSign);
+                    }
+
+                    RgvOneSign bigTurnSign = rgvOneSignMapper.selectOneSign("bigTurn");
+                    if (!Cools.isEmpty(bigTurnSign)){
+                        bigTurnSign.setRgvOneSign(999);
+                        rgvOneSignMapper.updateById(bigTurnSign);
+                    }
+                } catch (Exception e2){
+                    log.error("璇诲彇杈撻�佺嚎鏁伴噺鏍囪鍑虹幇寮傚父锛�"+e2);
                 }
             }
         }
@@ -1040,10 +1139,10 @@
      * 璁剧疆鍏ュ簱鏍囪
      */
     @Override
-    public void setPakMk(Integer siteId, boolean pakMk) {
+    public void setPakMk(Integer siteId, boolean pakMk,Integer i) {
         StaProtocol staProtocol = station.get(siteId);
         if (null != staProtocol) {
-            log.info("閿佸畾鍏ュ簱鏍囪锛岀珯鐐瑰彿={};pakMk={};鏃堕棿={}",siteId,pakMk,new Date());
+            log.info("閿佸畾鍏ュ簱鏍囪锛岀珯鐐瑰彿={};pakMk={};鏃堕棿={};鏍囪={}",siteId,pakMk,new Date(),i);
             staProtocol.setPakMk(pakMk);
         }
     }

--
Gitblit v1.9.1