| | |
| | | this.task = new UpgradeTask(); |
| | | this.task.initOption(this.failTryTimes, this.ugMaxRtuSameTime); |
| | | this.task.setTask(vo); |
| | | log.info("======================================================") ; |
| | | log.info("= =") ; |
| | | log.info("=设置了升级任务,涉及RTU" + vo.rtuAddrList.size() + "台 =") ; |
| | | log.info("= =") ; |
| | | log.info("======================================================") ; |
| | | }catch (Exception e){ |
| | | ex = e ; |
| | | }finally { |
| | |
| | | //升级任务未完成 |
| | | //工作1:判断是否无任何一个RTU进行过升级,并且达到时限,则认为当前升级任务完成 |
| | | //-1:无一RTU升级且超时,0:无RTU升级但未超时等待,1有RTU升级正常执行 |
| | | //int temp = 1 ; |
| | | int temp = this.task.countNoOneRtuUpgradeInDuration() ; |
| | | if(temp == -1){ |
| | | //当前没有RTU进行过升级,而且超时了,认为任务已经完成 |
| | | this.task.taskIsOver = true ; |
| | | //任务已经完成 |
| | | this.stop(); |
| | | log.info("===========================================================") ; |
| | | log.info("= =") ; |
| | | log.info("=无RTU升级超时,因无一台RTU进行升级,并且等待超时,强制设置升级完成 =") ; |
| | | log.info("= =") ; |
| | | log.info("===========================================================") ; |
| | | }else if(temp == 1){ |
| | | //当前有RTU进行过升级 |
| | | //工作2:统计当前正在升级的RTU数量,为同时升级数量限制做准备 |
| | | this.task.countRunningRtuCount() ; |
| | | |
| | | //工作3:统计需要升级但当前离线RTU的情况,超过时限的设备为升级完成 |
| | | this.task.countOffRtuAndSetIfOver() ; |
| | | |
| | | //工作3:统计需要升级但当前离线RTU的情况,超过时限的设置为升级完成 |
| | | int tmp = this.task.countOffRtuAndSetIfOver() ; |
| | | if(tmp >= 1){ |
| | | //超时,强制设置一些RTU升级失败并且升级完成) |
| | | log.info("======================================================") ; |
| | | log.info("= =") ; |
| | | log.info("=因离线超时,强制设置" + tmp + "台RTU升级失败并且升级完成 =") ; |
| | | log.info("= =") ; |
| | | log.info("======================================================") ; |
| | | }else if(tmp == 0){ |
| | | log.info("======================================================") ; |
| | | log.info("= =") ; |
| | | log.info("=离线超时,但无一台RTU因离线而被设置成升级失败并且升级完成 =") ; |
| | | log.info("= =") ; |
| | | log.info("======================================================") ; |
| | | }else{//tmp = -1 |
| | | //无任务逻辑 |
| | | } |
| | | //工作4:统计是否全部升级完成 |
| | | this.task.taskIsOver = this.task.countIsAllOver() ; |
| | | if(this.task.taskIsOver){ |
| | | log.info("==================================================") ; |
| | | log.info("= =") ; |
| | | log.info("= 升级全部结束,设置升级任务完成,涉及RTU" + this.task.taskVo.rtuAddrList.size() + "台 =") ; |
| | | log.info("= =") ; |
| | | log.info("==================================================") ; |
| | | } |
| | | }else if(temp == 0){ |
| | | //不作为 |
| | | //当前没有一个RTU进行过升级,也没有超时,不作为 |
| | | } |
| | | if(this.task.taskIsOver){ |
| | | if(!this.task.taskOverType.equals(UpgradeTask.TaskOverType_Force)){ |