| | |
| | | @GetMapping(path = "/curUpgradeState") |
| | | @SsoAop() |
| | | public BaseResponse<QueryResultVo<VoWatch> > curUpgradeState(QueryVo qvo){ |
| | | if(qvo == null){ |
| | | qvo = new QueryVo(); |
| | | } |
| | | if(RtuUpgradeStateReceiverCtrl.cache == null){ |
| | | //return BaseResponseUtils.buildError("当前没有升级任务") ; |
| | | //正式运行时,下面两行去掉,上面一行打开 |
| | |
| | | if(RtuUpgradeStateReceiverCtrl.cache.ugRtuStateList != null && RtuUpgradeStateReceiverCtrl.cache.ugRtuStateList.size() > 0){ |
| | | if(qvo.rtuAddr != null && !qvo.rtuAddr.trim().equals("")){ |
| | | qvo.pageCurr = 1 ; |
| | | RtuUpgradeStateReceiverCtrl.cache.ugRtuStateList.stream().filter(rtu -> rtu.rtuAddr.equals(qvo.rtuAddr)).forEach(ugRtu -> { |
| | | final String queryAddr = qvo.rtuAddr ; |
| | | RtuUpgradeStateReceiverCtrl.cache.ugRtuStateList.stream().filter(rtu -> rtu.rtuAddr.equals(queryAddr)).forEach(ugRtu -> { |
| | | VoWatch.VoWatchRtu rtu = new VoWatch.VoWatchRtu() ; |
| | | rtu.fromCache(ugRtu) ; |
| | | vo.rtus.add(rtu) ; |