1、优化代码；2、修改长级测试中发现的bug；3、通信中间件配置文件配置项修改

liurunyu

2024-11-20 14d7f0df63340ede75458c0e91b902376ef4dd64

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/upgrade/UpgradeManager.java

@@ -192,15 +192,24 @@
            }else{
                if(!this.task.taskIsOver){
                    //升级任务未完成
                    //工作1：统计当前正在升级的RTU数量，为受限同时升级数量做准备
                    this.task.statisticsRunningRtuCount() ;
                    //工作1：判断是否无任何一个RTU进行过升级，并且达到时限，则认为当前升级任务完成
                    int temp = this.task.countNoOneRtuUpgrade() ;
                    if(temp == -1){
                        this.task.taskIsOver = true ;
                        //任务已经完成
                        this.stop();
                    }else if(temp == 1){
                        //工作2：统计当前正在升级的RTU数量，为同时升级数量限制做准备
                        this.task.statisticsRunningRtuCount() ;

                    //工作2：统计需要升级但当前离线RTU的情况
                    this.task.statisticsOffRtuCountAndSet() ;
                        //工作3：统计需要升级但当前离线RTU的情况
                        this.task.statisticsOffRtuCountAndSet() ;

                    //工作3：统计是否全部升级完成
                    this.task.taskIsOver = this.task.statisticsIsAllOver() ;

                        //工作4：统计是否全部升级完成
                        this.task.taskIsOver = this.task.statisticsIsAllOver() ;
                    }else if(temp == 0){
                        //不作为
                    }
                    if(this.task.taskIsOver){
                        if(!this.task.taskOverType.equals(UpgradeTask.TaskOverType_Force)){
                            //任务不是强制结束的
@@ -208,16 +217,20 @@
                            this.task.taskOverDt = DateTime.yyyy_MM_dd_HH_mm_ss() ;//任务完成时间(yyyy-mm-dd HH:MM:SS)
                        }
                        //任务完成，执行最后一次升级状态通知
                        //工作4：升级状态通知
                        if(!first){
                            this.notifyUpgradeStatus() ;
                        }
                        //工作5：升级状态通知
                        //if(!first){
                        //    this.notifyUpgradeStatus() ;
                        //}
                    }else{
                        //任务未完成，继续执行升级状态通知
                        //工作4： 升级状态通知
                        if(!first){
                            this.notifyUpgradeStatus() ;
                        }
                        //工作5： 升级状态通知
                        //if(!first){
                        //    this.notifyUpgradeStatus() ;
                        //}
                    }
                    //工作5：升级状态通知
                    if(!first){
                        this.notifyUpgradeStatus() ;
                    }
                }else{
                    //任务已经完成