|  |  |  | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.daoPr.PrDivideMapper; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.pojoPr.PrDivide; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voPr.VoDivide; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voPr.VoDivideDetails; | 
|---|
|  |  |  | import lombok.extern.slf4j.Slf4j; | 
|---|
|  |  |  | import org.apache.dubbo.common.utils.PojoUtils; | 
|---|
|  |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
|---|
|  |  |  | 
|---|
|  |  |  | public QueryResultVo<List<VoDivide>> getDivides(QueryVo queryVo) { | 
|---|
|  |  |  | Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 计算符合条件的记录数 | 
|---|
|  |  |  | Long itemTotal = prDivideMapper.getRecordCount(params); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | QueryResultVo<List<VoDivide>> rsVo = new QueryResultVo<>() ; | 
|---|
|  |  |  | rsVo.pageSize = queryVo.pageSize ; | 
|---|
|  |  |  | //rsVo.pageCurr = queryVo.pageCurr ; | 
|---|
|  |  |  | Integer pageCurr = (Integer.parseInt(params.get("pageCurr").toString()) - 1) * Integer.parseInt(params.get("pageSize").toString()); | 
|---|
|  |  |  | params.put("pageCurr", pageCurr); | 
|---|
|  |  |  | rsVo.pageCurr = pageCurr; | 
|---|
|  |  |  | rsVo.pageCurr = queryVo.pageCurr ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | rsVo.calculateAndSet(itemTotal, params); | 
|---|
|  |  |  | rsVo.obj = prDivideMapper.getDivides(params); | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 根据分水房主键获取分水房对象 | 
|---|
|  |  |  | * 2025-01-21 废弃 | 
|---|
|  |  |  | * @param id | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public PrDivide getOneDivide(Long id) { | 
|---|
|  |  |  | return prDivideMapper.selectByPrimaryKey(id); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public VoDivideDetails getDivideDetails(Long id) { | 
|---|
|  |  |  | return prDivideMapper.getDivideDetails(id); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | * @return 修改记录条数 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public Integer updateByPrimaryKey(PrDivide po) { | 
|---|
|  |  |  | return prDivideMapper.updateByPrimaryKey(po); | 
|---|
|  |  |  | //return prDivideMapper.updateByPrimaryKey(po); | 
|---|
|  |  |  | return prDivideMapper.updateByPrimaryKeySelective(po); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 根据分水房编号获取所属片区编号 | 
|---|
|  |  |  | * @param divideId 分水房ID | 
|---|
|  |  |  | * @return 所属片区ID | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public Long getBlockIdById(Long divideId) { | 
|---|
|  |  |  | return prDivideMapper.getBlockIdById(divideId); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|