From d5a24d68b0ddb3faade00504dabc0643db7d056c Mon Sep 17 00:00:00 2001
From: zhubaomin <zhubaomin>
Date: 星期二, 26 十一月 2024 11:26:18 +0800
Subject: [PATCH] Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

---
 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/upgrade/UpgradeManager.java |   44 +++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 39 insertions(+), 5 deletions(-)

diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/upgrade/UpgradeManager.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/upgrade/UpgradeManager.java
index af7d7fa..678d2f2 100644
--- a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/upgrade/UpgradeManager.java
+++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/upgrade/UpgradeManager.java
@@ -64,6 +64,11 @@
                 this.task = new UpgradeTask();
                 this.task.initOption(this.failTryTimes, this.ugMaxRtuSameTime);
                 this.task.setTask(vo);
+                log.error("==================================================") ;
+                log.error("=                                                =") ;
+                log.error("=褰撳墠璁剧疆浜嗗崌绾т换鍔★紝鍏朵腑RTU鏈�" + vo.rtuAddrList.size() + "涓�                    =") ;
+                log.error("=                                                =") ;
+                log.error("==================================================") ;
             }catch (Exception e){
                 ex = e ;
             }finally {
@@ -182,22 +187,51 @@
                 //鍗囩骇浠诲姟鏈畬鎴�
                 //宸ヤ綔1锛氬垽鏂槸鍚︽棤浠讳綍涓�涓猂TU杩涜杩囧崌绾э紝骞朵笖杈惧埌鏃堕檺锛屽垯璁や负褰撳墠鍗囩骇浠诲姟瀹屾垚
                 //-1:鏃犱竴RTU鍗囩骇涓旇秴鏃讹紝0锛氭棤RTU鍗囩骇浣嗘湭瓒呮椂绛夊緟锛�1鏈塕TU鍗囩骇姝e父鎵ц
+                //int temp = 1 ;
                 int temp = this.task.countNoOneRtuUpgradeInDuration() ;
                 if(temp == -1){
+                    //褰撳墠娌℃湁RTU杩涜杩囧崌绾э紝鑰屼笖瓒呮椂浜嗭紝璁や负浠诲姟宸茬粡瀹屾垚
+                    log.error("==================================================") ;
+                    log.error("=                                                =") ;
+                    log.error("=褰撳墠娌℃湁RTU杩涜杩囧崌绾э紝鑰屼笖瓒呮椂浜嗭紝璁や负浠诲姟宸茬粡瀹屾垚      =") ;
+                    log.error("=                                                =") ;
+                    log.error("==================================================") ;
                     this.task.taskIsOver = true ;
-                    //浠诲姟宸茬粡瀹屾垚
                     this.stop();
                 }else if(temp == 1){
+                    //褰撳墠鏈塕TU杩涜杩囧崌绾�
                     //宸ヤ綔2锛氱粺璁″綋鍓嶆鍦ㄥ崌绾х殑RTU鏁伴噺锛屼负鍚屾椂鍗囩骇鏁伴噺闄愬埗鍋氬噯澶�
                     this.task.countRunningRtuCount() ;
 
-                    //宸ヤ綔3锛氱粺璁¢渶瑕佸崌绾т絾褰撳墠绂荤嚎RTU鐨勬儏鍐碉紝瓒呰繃鏃堕檺鐨勮澶囦负鍗囩骇瀹屾垚
-                    this.task.countOffRtuAndSetIfOver() ;
-
+                    //宸ヤ綔3锛氱粺璁¢渶瑕佸崌绾т絾褰撳墠绂荤嚎RTU鐨勬儏鍐碉紝瓒呰繃鏃堕檺鐨勮缃负鍗囩骇瀹屾垚
+                    int tmp = this.task.countOffRtuAndSetIfOver() ;
+                    if(tmp >= 1){
+                        //瓒呮椂锛屽己鍒惰缃竴浜汻TU鍗囩骇澶辫触骞朵笖鍗囩骇瀹屾垚锛�
+                        log.error("==================================================") ;
+                        log.error("=                                                =") ;
+                        log.error("=瓒呮椂锛屽己鍒惰缃�" + tmp + "涓猂TU鍗囩骇澶辫触骞朵笖鍗囩骇瀹屾垚     =") ;
+                        log.error("=                                                =") ;
+                        log.error("==================================================") ;
+                    }else if(tmp == 0){
+                        log.error("==================================================") ;
+                        log.error("=                                                =") ;
+                        log.error("=瓒呮椂锛屽己鍒惰缃�0涓猂TU鍗囩骇澶辫触骞朵笖鍗囩骇瀹屾垚               =") ;
+                        log.error("=                                                =") ;
+                        log.error("==================================================") ;
+                    }else{//tmp = -1
+                        //鏃犱换鍔¢�昏緫
+                    }
                     //宸ヤ綔4锛氱粺璁℃槸鍚﹀叏閮ㄥ崌绾у畬鎴�
                     this.task.taskIsOver = this.task.countIsAllOver() ;
+                    if(this.task.taskIsOver){
+                        log.error("==================================================") ;
+                        log.error("=                                                =") ;
+                        log.error("=鍗囩骇鍏ㄩ儴缁撴潫锛岃缃崌绾т换鍔″畬鎴�                       =") ;
+                        log.error("=                                                =") ;
+                        log.error("==================================================") ;
+                    }
                 }else if(temp == 0){
-                    //涓嶄綔涓�
+                    //褰撳墠娌℃湁涓�涓猂TU杩涜杩囧崌绾э紝涔熸病鏈夎秴鏃讹紝涓嶄綔涓�
                 }
                 if(this.task.taskIsOver){
                     if(!this.task.taskOverType.equals(UpgradeTask.TaskOverType_Force)){

--
Gitblit v1.8.0