|  |  |  | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.daoPr.PrFlowmeterMapper; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.pojoPr.PrFlowmeter; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voPr.VoFlowMeter; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voPr.VoFlowMonitoring; | 
|---|
|  |  |  | import lombok.extern.slf4j.Slf4j; | 
|---|
|  |  |  | import org.apache.dubbo.common.utils.PojoUtils; | 
|---|
|  |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
|---|
|  |  |  | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public QueryResultVo<List<VoFlowMeter>> getFlowMeters(QueryVoFlowMeter queryVo){ | 
|---|
|  |  |  | Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo) ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Integer itemTotal = prFlowmeterMapper.getRecordCountOfFlowMeterByOthers(params); | 
|---|
|  |  |  | QueryResultVo<List<VoFlowMeter>> rsVo = new QueryResultVo<>() ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Integer pageCurr = 0; | 
|---|
|  |  |  | Integer pageSize = 10000; | 
|---|
|  |  |  | rsVo.pageCurr = 1; | 
|---|
|  |  |  | rsVo.pageSize = 10000; | 
|---|
|  |  |  | if(queryVo.pageSize != null && queryVo.pageCurr != null) { | 
|---|
|  |  |  | rsVo.pageSize = queryVo.pageSize ; | 
|---|
|  |  |  | rsVo.pageCurr = queryVo.pageCurr; | 
|---|
|  |  |  | pageSize = queryVo.pageSize ; | 
|---|
|  |  |  | pageCurr = (Integer.parseInt(params.get("pageCurr").toString()) - 1) * Integer.parseInt(params.get("pageSize").toString()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | params.put("pageCurr", pageCurr); | 
|---|
|  |  |  | params.put("pageSize", pageSize); | 
|---|
|  |  |  | 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 ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 得到全部流量计 | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public List<PrFlowmeter> getFlowMeterAll(){ | 
|---|
|  |  |  | List<PrFlowmeter> all = prFlowmeterMapper.selectAll(); | 
|---|
|  |  |  | return all; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 给流量计表加监测站ID外键 | 
|---|
|  |  |  | * @param | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public Integer flowmeterAddMonId(PrFlowmeter record){ | 
|---|
|  |  |  | return prFlowmeterMapper.flowmeterAddMonId(record); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|