From e15fc388ff7280a9423fc1ac8c326f448e97bafb Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期四, 14 十一月 2024 16:48:04 +0800
Subject: [PATCH] 升级监视,修改重置逻辑错误

---
 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/rtuUpgrage/RtuUpgradeCtrl.java |   49 +++++++++++++++++++++++++++----------------------
 1 files changed, 27 insertions(+), 22 deletions(-)

diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/rtuUpgrage/RtuUpgradeCtrl.java b/pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/rtuUpgrage/RtuUpgradeCtrl.java
index 3646149..3398f3a 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/rtuUpgrage/RtuUpgradeCtrl.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/rtuUpgrage/RtuUpgradeCtrl.java
@@ -130,7 +130,7 @@
     @GetMapping(path = "/demoReset")
     @SsoAop()
     public BaseResponse<Boolean> demoReset(){
-        if(RtuUpgradeStateReceiverCtrl.cache == null){
+        if(RtuUpgradeStateReceiverCtrl.cache != null){
             //return BaseResponseUtils.buildError("褰撳墠娌℃湁鍗囩骇浠诲姟") ;
             //姝e紡杩愯鏃讹紝涓嬮潰涓よ鍘绘帀锛屼笂闈竴琛屾墦寮�
             RtuUpgradeStateReceiverCtrl ctrl = SpringContextUtil.getBean(RtuUpgradeStateReceiverCtrl.class);
@@ -159,6 +159,8 @@
     public BaseResponse<QueryResultVo<VoWatch> > curUpgradeState(QueryVo qvo){
         if(qvo == null){
             qvo = new QueryVo();
+            qvo.pageCurr = 1 ;
+            qvo.pageSize = 50 ;
         }
         if(RtuUpgradeStateReceiverCtrl.cache == null){
             //return BaseResponseUtils.buildError("褰撳墠娌℃湁鍗囩骇浠诲姟") ;
@@ -169,32 +171,35 @@
 
         QueryResultVo<VoWatch> rsVo = new QueryResultVo();
         VoWatch vo = new VoWatch() ;
-        vo.upgrade = this.sv.selectTaskDetail(RtuUpgradeStateReceiverCtrl.cache.ugTaskId);
-        vo.overall = RtuUpgradeStateReceiverCtrl.cache.ugOverallState ;
-        vo.rtus = new ArrayList<>() ;
         List<UpgradeRtu> listFiltered = null ;
-        if(RtuUpgradeStateReceiverCtrl.cache.ugRtuStateList != null && RtuUpgradeStateReceiverCtrl.cache.ugRtuStateList.size() > 0) {
-            listFiltered = filterByQuery(qvo) ;
-            if (listFiltered.size() > 0) {
-                if(qvo.pageCurr < 1){
-                    qvo.pageCurr = 1 ;
-                }
-                int start = (qvo.pageCurr - 1) * qvo.pageSize ;
-                if(start >= listFiltered.size()){
-                    if(listFiltered.size()%qvo.pageSize > 0){
-                        start = listFiltered.size() - listFiltered.size()%qvo.pageSize ;
-                    }else{
-                        start = listFiltered.size() - qvo.pageSize ;
+        if(RtuUpgradeStateReceiverCtrl.cache != null && RtuUpgradeStateReceiverCtrl.cache.ugTaskId != null){
+            vo.upgrade = this.sv.selectTaskDetail(RtuUpgradeStateReceiverCtrl.cache.ugTaskId);
+            vo.overall = RtuUpgradeStateReceiverCtrl.cache.ugOverallState ;
+            vo.rtus = new ArrayList<>() ;
+            if(RtuUpgradeStateReceiverCtrl.cache.ugRtuStateList != null && RtuUpgradeStateReceiverCtrl.cache.ugRtuStateList.size() > 0) {
+                listFiltered = filterByQuery(qvo) ;
+                if (listFiltered.size() > 0) {
+                    if(qvo.pageCurr < 1){
+                        qvo.pageCurr = 1 ;
                     }
-                }
-                for(int i = start; i < (start + qvo.pageSize) && i < listFiltered.size(); i++){
-                    UpgradeRtu ugRtu = listFiltered.get(i) ;
-                    VoWatch.VoWatchRtu rtu = new VoWatch.VoWatchRtu() ;
-                    rtu.fromCache(ugRtu) ;
-                    vo.rtus.add(rtu) ;
+                    int start = (qvo.pageCurr - 1) * qvo.pageSize ;
+                    if(start >= listFiltered.size()){
+                        if(listFiltered.size()%qvo.pageSize > 0){
+                            start = listFiltered.size() - listFiltered.size()%qvo.pageSize ;
+                        }else{
+                            start = listFiltered.size() - qvo.pageSize ;
+                        }
+                    }
+                    for(int i = start; i < (start + qvo.pageSize) && i < listFiltered.size(); i++){
+                        UpgradeRtu ugRtu = listFiltered.get(i) ;
+                        VoWatch.VoWatchRtu rtu = new VoWatch.VoWatchRtu() ;
+                        rtu.fromCache(ugRtu) ;
+                        vo.rtus.add(rtu) ;
+                    }
                 }
             }
         }
+
         rsVo.obj = vo ;
         rsVo.pageSize = qvo.pageSize ;
         rsVo.pageCurr = qvo.pageCurr ;

--
Gitblit v1.8.0