| | |
| | | package com.dy.pipIrrProject.flowMonitoring; |
| | | |
| | | import com.dy.common.webUtil.QueryResultVo; |
| | | import com.dy.pipIrrGlobal.daoPr.PrFlowmeterMapper; |
| | | import com.dy.pipIrrGlobal.pojoPr.PrFlowmeter; |
| | | import com.dy.pipIrrGlobal.voPr.VoFlowMeter; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.dubbo.common.utils.PojoUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | |
| | | /** |
| | | * @author ZhuBaoMin |
| | |
| | | * @param flowmeterId |
| | | * @return |
| | | */ |
| | | public Integer getRecordCountOfFlowmeter(Long flowmeterId) { |
| | | return prFlowmeterMapper.getRecordCountOfFlowmeter(flowmeterId); |
| | | public Integer getRecordCountOfFlowmeterByCode(Long flowmeterId) { |
| | | return prFlowmeterMapper.getRecordCountOfFlowmeterByCode(flowmeterId); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 根据指定条件得到流量计实体记录 |
| | | * @param queryVo 给的条件 |
| | | * @return 流量计实体集合 |
| | | */ |
| | | public QueryResultVo<List<VoFlowMeter>> getFlowMeters(QueryVoFlowMeter queryVo){ |
| | | Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo) ; |
| | | |
| | | QueryResultVo<List<VoFlowMeter>> rsVo = new QueryResultVo<>() ; |
| | | rsVo.pageSize = queryVo.pageSize ; |
| | | rsVo.pageCurr = queryVo.pageCurr ; |
| | | |
| | | // 计算符合条件的记录数 |
| | | Integer itemTotal = prFlowmeterMapper.getRecordCountOfFlowMeterByOthers(params); |
| | | rsVo.calculateAndSet(itemTotal.longValue(), params); |
| | | rsVo.obj = prFlowmeterMapper.getFlowMeters(params); |
| | | |
| | | return rsVo ; |
| | | } |
| | | } |