From d2c0bccd2e6dde4cf2a614a67bbf0ed45e2bcbaf Mon Sep 17 00:00:00 2001
From: whycq <913841844@qq.com>
Date: 星期五, 29 十一月 2024 13:59:22 +0800
Subject: [PATCH] # 213

---
 src/main/java/com/zy/core/thread/SiemensDevpThread.java |  164 ++++++++++++++++++------------------------------------
 1 files changed, 55 insertions(+), 109 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/SiemensDevpThread.java b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
index 6cc420d..f7690df 100644
--- a/src/main/java/com/zy/core/thread/SiemensDevpThread.java
+++ b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
@@ -351,100 +351,28 @@
             }
         } else if (slave.getId()==1){
             try{
-                RgvOneSignMapper rgvOneSignMapper = SpringUtils.getBean(RgvOneSignMapper.class);
-
-                OperateResultExOne<byte[]> resultSignOne = siemensS7Net.Read("DB293.106", (short) (8));
+                OperateResultExOne<byte[]> resultSignOne = siemensS7Net.Read("DB293.106", (short) (16));
 
                 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);// 澶ф枡缈昏浆
+                int LineUp131 = siemensS7Net.getByteTransform().TransInt16(resultSignOne.Content, 8);// 131鎺掗槦
+                int LineUp126 = siemensS7Net.getByteTransform().TransInt16(resultSignOne.Content, 10);// 126鎺掗槦
+                int LineUp312 = siemensS7Net.getByteTransform().TransInt16(resultSignOne.Content, 12);// 312鎺掗槦
+                int LineUp310 = siemensS7Net.getByteTransform().TransInt16(resultSignOne.Content, 14);// 310鎺掗槦
 
-                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);
-                    }
-                }
+                updateRgvOneSign("smallEmpty",smallEmpty);
+                updateRgvOneSign("bigEmpty",bigEmpty);
+                updateRgvOneSign("smallTurn",smallTurn);
+                updateRgvOneSign("bigTurn",bigTurn);
+                updateRgvOneSign("LineUp131",LineUp131);
+                updateRgvOneSign("LineUp126",LineUp126);
+                updateRgvOneSign("LineUp312",LineUp312);
+                updateRgvOneSign("LineUp310",LineUp310);
+
             } 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);
-                }
             }
         }
 
@@ -718,7 +646,7 @@
         do {
             try{
                 if(!result1.IsSuccess){
-                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
+                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�1  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
                     result1 = siemensS7Net.Write(resultV1, resultS1);
                     Thread.sleep(100);
                     writeCount++;
@@ -730,14 +658,14 @@
                     if (status == 1){
                         break;
                     } else {
-                        log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
+                        log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�2  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
                         result1 = siemensS7Net.Write(resultV1, resultS1);
                         Thread.sleep(100);
                         writeCount++;
                         continue;
                     }
                 } else {
-                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
+                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�3  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
                     result1 = siemensS7Net.Write(resultV1, resultS1);
                     Thread.sleep(100);
                     writeCount++;
@@ -762,7 +690,7 @@
         do {
             try{
                 if(!result2.IsSuccess){
-                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
+                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�4  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
                     result2 = siemensS7Net.Write(resultV1, resultS2);
 
                     Thread.sleep(100);
@@ -775,14 +703,14 @@
                     if (status == resultS2){
                         break;
                     } else {
-                        log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
+                        log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�5  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
                         result2 = siemensS7Net.Write(resultV1, resultS2);
                         Thread.sleep(100);
                         writeCount++;
                         continue;
                     }
                 } else {
-                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
+                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�6  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
                     result2 = siemensS7Net.Write(resultV1, resultS2);
                     Thread.sleep(100);
                     writeCount++;
@@ -864,7 +792,7 @@
         do {
             try{
                 if(!result1.IsSuccess){
-                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
+                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�7  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
                     result1 = siemensS7Net.Write(resultV1, resultS1);
                     Thread.sleep(100);
                     writeCount++;
@@ -877,14 +805,14 @@
                     if (statusR1 == resultS1){
                         break;
                     } else {
-                        log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
+                        log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�8  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
                         result1 = siemensS7Net.Write(resultV1, resultS1);
                         Thread.sleep(100);
                         writeCount++;
                         continue;
                     }
                 } else {
-                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
+                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�9  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
                     result1 = siemensS7Net.Write(resultV1, resultS1);
                     Thread.sleep(100);
                     writeCount++;
@@ -903,7 +831,7 @@
         do {
             try{
                 if(!result2.IsSuccess){
-                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
+                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�10  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
                     result2 = siemensS7Net.Write(resultV1, resultS2);
                     Thread.sleep(100);
                     writeCount++;
@@ -916,7 +844,7 @@
                     if (statusR1 == resultS2){
                         break;
                     } else {
-                        log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
+                        log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�11  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
                         result2 = siemensS7Net.Write(resultV1, resultS2);
 
                         Thread.sleep(100);
@@ -924,7 +852,7 @@
                         continue;
                     }
                 } else {
-                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
+                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�12  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
                     result2 = siemensS7Net.Write(resultV1, resultS2);
                     Thread.sleep(100);
                     writeCount++;
@@ -981,7 +909,7 @@
         do {
             try{
                 if(!result1.IsSuccess){
-                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
+                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�13  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
                     result1 = siemensS7Net.Write(resultV1, resultS1);
                     Thread.sleep(100);
                     writeCount++;
@@ -993,14 +921,14 @@
                     if (transInt16 == resultS1){
                         break;
                     } else {
-                        log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
+                        log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�14  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
                         result1 = siemensS7Net.Write(resultV1, resultS1);
                         Thread.sleep(100);
                         writeCount++;
                         continue;
                     }
                 } else {
-                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
+                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�15  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
                     result1 = siemensS7Net.Write(resultV1, resultS1);
                     Thread.sleep(100);
                     writeCount++;
@@ -1016,7 +944,7 @@
         do {
             try{
                 if(!result2.IsSuccess){
-                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
+                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�16  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
                     result2 = siemensS7Net.Write(resultV2, resultS1);
                     Thread.sleep(100);
                     writeCount++;
@@ -1028,14 +956,14 @@
                     if (transInt16 == resultS1){
                         break;
                     } else {
-                        log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
+                        log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�17  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
                         result2 = siemensS7Net.Write(resultV2, resultS1);
                         Thread.sleep(100);
                         writeCount++;
                         continue;
                     }
                 } else {
-                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
+                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�18  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(staProtocol),writeCount);
                     result2 = siemensS7Net.Write(resultV2, resultS1);
                     Thread.sleep(100);
                     writeCount++;
@@ -1077,33 +1005,33 @@
         do {
             try{
                 if(!result.IsSuccess){
-                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(devNo),writeCount);
+                    log.error("鍐欏叆澶ф枡绠辫緭閫佺嚎椤跺崌涓嬮檷淇″彿澶辫触锛岄噸鏂颁笅鍙戜换鍔�19  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(devNo),writeCount);
                     result = siemensS7Net.Write(resultV1, true);
                     Thread.sleep(100);
                     writeCount++;
                     continue;
                 }
-                OperateResultExOne<byte[]> resultRead1 = siemensS7Net.Read("resultV1", (short) 1);
+                OperateResultExOne<byte[]> resultRead1 = siemensS7Net.Read("DB500.0", (byte) 1);
                 if (resultRead1.IsSuccess) {
                     boolean[] status = siemensS7Net.getByteTransform().TransBool(resultRead1.Content, 0, 1);
                     if (status[devNo-1]){
                         break;
                     } else {
-                        log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(devNo),writeCount);
+                        log.error("鍐欏叆澶ф枡绠辫緭閫佺嚎椤跺崌涓嬮檷淇″彿澶辫触锛岄噸鏂颁笅鍙戜换鍔�20  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(devNo),writeCount);
                         result = siemensS7Net.Write(resultV1, true);
                         Thread.sleep(100);
                         writeCount++;
                         continue;
                     }
                 } else {
-                    log.error("鍐欏叆RGV鏁版嵁澶辫触锛岄噸鏂颁笅鍙戜换鍔�  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(devNo),writeCount);
+                    log.error("鍐欏叆澶ф枡绠辫緭閫佺嚎椤跺崌涓嬮檷淇″彿澶辫触锛岄噸鏂颁笅鍙戜换鍔�21  鍐欏叆鐩存帴澶辫触 ===>> [id:{}],{},[鍐欏叆娆℃暟:{}]", slave.getId(), JSON.toJSONString(devNo),writeCount);
                     result = siemensS7Net.Write(resultV1, true);
                     Thread.sleep(100);
                     writeCount++;
                     continue;
                 }
             }catch (Exception e){
-                log.error("鍐欏叆鏁版嵁鍚庡洖璇诲嚭閿�,寮傚父锛�"+e);
+                log.error("鍐欏叆澶ф枡绠辫緭閫佺嚎椤跺崌涓嬮檷淇″彿鍥炶鍑洪敊,寮傚父锛�"+e);
             }
             writeCount++;
         } while (writeCount<6);
@@ -1147,6 +1075,24 @@
         }
     }
 
+    public void updateRgvOneSign(String signType,Integer oneSign){
+        RgvOneSignMapper rgvOneSignMapper = SpringUtils.getBean(RgvOneSignMapper.class);
+
+        try{
+            RgvOneSign rgvOneSign = rgvOneSignMapper.selectOneSign(signType);
+            if (!Cools.isEmpty(rgvOneSign)){
+                rgvOneSign.setRgvOneSign(oneSign);
+                rgvOneSignMapper.updateById(rgvOneSign);
+            }
+        } catch (Exception e){
+            RgvOneSign rgvOneSign = rgvOneSignMapper.selectOneSign(signType);
+            if (!Cools.isEmpty(rgvOneSign)){
+                rgvOneSign.setRgvOneSign(999);
+                rgvOneSignMapper.updateById(rgvOneSign);
+            }
+        }
+    }
+
     @Override
     public void close() {
         siemensS7Net.ConnectClose();

--
Gitblit v1.9.1