package com.dy.pipIrrWechat.irrigation; import com.dy.common.webUtil.QueryResultVo; import com.dy.pipIrrGlobal.daoIr.IrGroupClientMapper; import com.dy.pipIrrGlobal.daoIr.IrUnitClientMapper; import com.dy.pipIrrGlobal.voIr.VoGroupSimple; import com.dy.pipIrrGlobal.voIr.VoUnitSimple; import com.dy.pipIrrWechat.irrigation.qo.QoClient; 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 * @date 2025-02-20 8:59 * @LastEditTime 2025-02-20 8:59 * @Description */ @Slf4j @Service public class IrrigationSv { @Autowired private IrGroupClientMapper irGroupClientMapper; @Autowired private IrUnitClientMapper irUnitClientMapper; /** * 根据农户编号获取轮灌组列表 * @param queryVo * @return */ public QueryResultVo> getGroupsByClientId(QoClient queryVo) { Map params = (Map) PojoUtils.generalize(queryVo); Long itemTotal = irGroupClientMapper.getGroupCountByClientId(params); QueryResultVo> rsVo = new QueryResultVo<>(); rsVo.pageSize = queryVo.pageSize; rsVo.pageCurr = queryVo.pageCurr; rsVo.calculateAndSet(itemTotal, params); rsVo.obj = irGroupClientMapper.getGroupsByClientId(params); return rsVo; } /** * 根据农户编号获取灌溉单元列表 * @param queryVo * @return */ public QueryResultVo> getUnitsByClientId(QoClient queryVo) { Map params = (Map) PojoUtils.generalize(queryVo); Long itemTotal = irUnitClientMapper.getUnitCountByClientId(params); QueryResultVo> rsVo = new QueryResultVo<>(); rsVo.pageSize = queryVo.pageSize; rsVo.pageCurr = queryVo.pageCurr; rsVo.calculateAndSet(itemTotal, params); rsVo.obj = irUnitClientMapper.getUnitsByClientId(params); return rsVo; } }