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