| | |
|---|
| | | package com.dy.pipIrrProject.controller; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson2.JSON; |
|---|
| | | import com.alibaba.fastjson2.JSONArray; |
|---|
| | | import com.dy.common.webUtil.QueryResultVo; |
|---|
| | | import com.dy.pipIrrGlobal.daoPr.PrControllerMapper; |
|---|
| | | import com.dy.pipIrrGlobal.daoPr.PrIntakeMapper; |
|---|
| | | import com.dy.pipIrrGlobal.pojoPr.PrController; |
|---|
| | | import com.dy.pipIrrGlobal.voPr.VoController; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | |
|---|
| | | import java.util.ArrayList; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Map; |
|---|
| | | import java.util.Optional; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @author ZhuBaoMin |
|---|
| | |
|---|
| | | @Autowired |
|---|
| | | private PrControllerMapper prControllerMapper; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private PrIntakeMapper prIntakeMapper; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 根据指定获取控制器记录 |
|---|
| | | * @param queryVo |
|---|
| | |
|---|
| | | Long itemTotal = prControllerMapper.getRecordCount(params); |
|---|
| | | |
|---|
| | | QueryResultVo<List<VoController>> 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 ; |
|---|
| | | |
|---|
| | | rsVo.calculateAndSet(itemTotal, params); |
|---|
| | | rsVo.obj = prControllerMapper.getControllers(params); |
|---|
| | |
|---|
| | | public Integer deleteIntakeId(Long controllerId) { |
|---|
| | | return prControllerMapper.deleteIntakeId(controllerId); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 获取未绑控制器的取水口列表 |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | public JSONArray getNoBindingIntakes() { |
|---|
| | | List<Map<String, Object>> list = Optional.ofNullable(prIntakeMapper.getNoBindingIntakes()).orElse(new ArrayList<>()); |
|---|
| | | JSONArray array= null; |
|---|
| | | if(list.size() > 0) { |
|---|
| | | array= JSONArray.parseArray(JSON.toJSONString(list)); |
|---|
| | | } |
|---|
| | | return array; |
|---|
| | | } |
|---|
| | | } |
|---|
