|  |  |  | 
|---|
|  |  |  | @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) ; | 
|---|