| package com.dy.pipIrrIrrigate.project; | 
|   | 
|   | 
| import com.dy.common.webUtil.QueryResultVo; | 
| import com.dy.pipIrrGlobal.daoIr.IrProjectMapper; | 
| import com.dy.pipIrrGlobal.pojoIr.IrProject; | 
| import com.dy.pipIrrGlobal.voIr.VoProject; | 
| import com.dy.pipIrrGlobal.voIr.VoProjectOne; | 
| import com.dy.pipIrrGlobal.voPr.VoIntake; | 
| 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.Date; | 
| import java.util.List; | 
| import java.util.Map; | 
|   | 
| /** | 
|  * @author :WuZeYu | 
|  * @Date :2024/5/14  13:56 | 
|  * @LastEditTime :2024/5/14  13:56 | 
|  * @Description | 
|  */ | 
| @Slf4j | 
| @Service | 
| public class ProjectSv { | 
|     @Autowired | 
|     private IrProjectMapper irProjectMapper; | 
|   | 
|     /** | 
|      * 添加项目 | 
|      * | 
|      * @param po | 
|      * @return | 
|      */ | 
|     public Integer addProject(IrProject po) { | 
|         po.setOperateDt(new Date()); | 
|         po.setDeleted((byte) 0); | 
|         if (po.getVillageId() != null) { | 
|             po.setTownId(irProjectMapper.getSupperByVillageId(po.getVillageId())); | 
|             po.setCountyId(irProjectMapper.getSupperByVillageId(po.getTownId())); | 
|             po.setCityId(irProjectMapper.getSupperByVillageId(po.getCountyId())); | 
|             po.setProvinceId(irProjectMapper.getSupperByVillageId(po.getCityId())); | 
|         } | 
|         if (po.getTownId() != null) { | 
|             po.setCountyId(irProjectMapper.getSupperByVillageId(po.getTownId())); | 
|             po.setCityId(irProjectMapper.getSupperByVillageId(po.getCountyId())); | 
|             po.setProvinceId(irProjectMapper.getSupperByVillageId(po.getCityId())); | 
|         } | 
|         if (po.getCountyId() != null) { | 
|             po.setCityId(irProjectMapper.getSupperByVillageId(po.getCountyId())); | 
|             po.setProvinceId(irProjectMapper.getSupperByVillageId(po.getCityId())); | 
|         } | 
|         if (po.getCityId() != null) { | 
|             po.setProvinceId(irProjectMapper.getSupperByVillageId(po.getCityId())); | 
|         } | 
|         int rows = irProjectMapper.insertSelective(po); | 
|         if (rows == 0) { | 
|             return 0; | 
|         } | 
|         return 1; | 
|     } | 
|   | 
|     /** | 
|      * 删除项目 | 
|      * | 
|      * @param id | 
|      */ | 
|     public Integer deleteProject(Long id) { | 
|         int rows = irProjectMapper.deleteLogicById(id); | 
|         if (rows == 0) { | 
|             return 0; | 
|         } | 
|             return 1; | 
|     } | 
|   | 
|     /** | 
|      * 修改项目信息 | 
|      * @param po | 
|      * @return | 
|      */ | 
|     public Integer updateProject(IrProject po){ | 
|         po.setOperateDt(new Date()); | 
|         if (po.getVillageId() != null) { | 
|             po.setTownId(irProjectMapper.getSupperByVillageId(po.getVillageId())); | 
|             po.setCountyId(irProjectMapper.getSupperByVillageId(po.getTownId())); | 
|             po.setCityId(irProjectMapper.getSupperByVillageId(po.getCountyId())); | 
|             po.setProvinceId(irProjectMapper.getSupperByVillageId(po.getCityId())); | 
|         } | 
|         if (po.getTownId() != null) { | 
|             po.setCountyId(irProjectMapper.getSupperByVillageId(po.getTownId())); | 
|             po.setCityId(irProjectMapper.getSupperByVillageId(po.getCountyId())); | 
|             po.setProvinceId(irProjectMapper.getSupperByVillageId(po.getCityId())); | 
|         } | 
|         if (po.getCountyId() != null) { | 
|             po.setCityId(irProjectMapper.getSupperByVillageId(po.getCountyId())); | 
|             po.setProvinceId(irProjectMapper.getSupperByVillageId(po.getCityId())); | 
|         } | 
|         if (po.getCityId() != null) { | 
|             po.setProvinceId(irProjectMapper.getSupperByVillageId(po.getCityId())); | 
|         } | 
|         int rows = irProjectMapper.updateByPrimaryKeySelective(po); | 
|         if (rows == 0){ | 
|             return 0; | 
|         } | 
|         return 1; | 
|     } | 
|   | 
|     /** | 
|      * 修改项目状态 | 
|      * @param po | 
|      * @return | 
|      */ | 
|     public Integer updateProjectState(IrProject po){ | 
|         po.setOperateDt(new Date()); | 
|         int rows = irProjectMapper.updateProjectState(po); | 
|         if (rows == 0){ | 
|             return 0; | 
|         } | 
|         return 1; | 
|     } | 
|   | 
|     /** | 
|      * 获取一个项目数据 | 
|      * @param id | 
|      * @return | 
|      */ | 
|     public VoProjectOne selectById(Long id){ | 
|         VoProjectOne irProject = irProjectMapper.selectById(id); | 
|         return irProject; | 
|     } | 
|   | 
|     /** | 
|      * 分页查询项目 | 
|      * @param queryVo | 
|      * @return | 
|      */ | 
|     public QueryResultVo<List<VoProject>> getProjects(QueryVo queryVo){ | 
|         Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo); | 
|         Long itemTotal = irProjectMapper.getRecordCount(params); | 
|   | 
|         QueryResultVo<List<VoProject>> rsVo = new QueryResultVo<>(); | 
|         rsVo.pageSize = queryVo.pageSize; | 
|         rsVo.pageCurr = queryVo.pageCurr; | 
|         rsVo.calculateAndSet(itemTotal, params); | 
|         rsVo.obj = irProjectMapper.getProjects(params); | 
|         return rsVo; | 
|     } | 
| } |