pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoIr/IrProjectMapper.java
New file @@ -0,0 +1,58 @@ package com.dy.pipIrrGlobal.daoIr; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.dy.pipIrrGlobal.pojoIr.IrProject; import com.dy.pipIrrGlobal.pojoPr.PrController; import com.dy.pipIrrGlobal.pojoPr.PrIntake; import com.dy.pipIrrGlobal.voIr.VoProject; import com.dy.pipIrrGlobal.voPr.VoIntake; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; import java.util.List; import java.util.Map; /** * @author :WuZeYu * @Date :2024/5/14 15:04 * @LastEditTime :2024/5/14 15:04 * @Description */ @Mapper public interface IrProjectMapper extends BaseMapper<IrProject> { //增 int insertSelective(IrProject record); //删 int deleteLogicById(Long id); //改 int updateByPrimaryKeySelective(IrProject record); //查一个 IrProject selectById(Long id); /** * 修改项目状态 * @return */ int updateProjectState(IrProject record); /** * 根据下级Id获取上一级地址Id * @param vaId 下一级Id * @return */ Long getSupperByVillageId(long vaId); /** * 根据指定条件获取取水口记录数 * @param params * @return */ Long getRecordCount(Map<?, ?> params); /** * 根据指定条件获取取水口记录 * @param params * @return */ List<VoProject> getProjects(Map<?, ?> params); } pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoIr/IrProject.java
New file @@ -0,0 +1,111 @@ package com.dy.pipIrrGlobal.pojoIr; import com.alibaba.fastjson2.annotation.JSONField; import com.alibaba.fastjson2.writer.ObjectWriterImplToString; import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; import com.dy.common.po.BaseEntity; import io.swagger.v3.oas.annotations.media.Schema; import jakarta.validation.constraints.NotBlank; import jakarta.validation.constraints.NotNull; import lombok.*; import org.hibernate.validator.constraints.Length; import java.util.Date; /** * @author :WuZeYu * @Date :2024/5/14 13:53 * @LastEditTime :2024/5/14 13:53 * @Description */ /** * 项目表 */ @TableName(value="ir_project", autoResultMap = true) @Data @Builder @ToString @NoArgsConstructor @AllArgsConstructor @Schema(name = "项目实体") public class IrProject implements BaseEntity { public static final long serialVersionUID = 202405141427001L; /** * 主键 */ @JSONField(serializeUsing= ObjectWriterImplToString.class) @TableId(type = IdType.INPUT) @Schema(description = "实体id", requiredMode = Schema.RequiredMode.NOT_REQUIRED) private Long id; /** * 项目名称 */ @Schema(description = "项目名称", requiredMode = Schema.RequiredMode.REQUIRED) @NotBlank(message = "项目名称不能为空") @Length(message = "项目名称不大于{max}字",max = 50) private String projectName; /** * 省ID */ @Schema(description = "省ID", requiredMode = Schema.RequiredMode.REQUIRED) private Long provinceId; /** * 市ID */ @Schema(description = "市ID", requiredMode = Schema.RequiredMode.REQUIRED) private Long cityId; /** * 县ID */ @Schema(description = "县ID", requiredMode = Schema.RequiredMode.REQUIRED) private Long countyId; /** * 镇ID */ @Schema(description = "镇ID", requiredMode = Schema.RequiredMode.REQUIRED) private Long townId; /** * 村ID */ @Schema(description = "村ID", requiredMode = Schema.RequiredMode.REQUIRED) private Long villageId; /** * 项目状态;1-启动，2-停止 */ @Schema(description = "项目状态", requiredMode = Schema.RequiredMode.NOT_REQUIRED) private Byte projectState; /** * 操作人ID */ @Schema(description = "操作人ID", requiredMode = Schema.RequiredMode.NOT_REQUIRED) private Long operator; /** * 操作时间 */ @Schema(description = "操作时间", requiredMode = Schema.RequiredMode.NOT_REQUIRED) private Date operateDt; /** * 备注 */ @Schema(description = "备注", requiredMode = Schema.RequiredMode.REQUIRED) private String remarks; /** * 逻辑删除标识;0-未删除，1-删除 */ @Schema(description = "删除标识", requiredMode = Schema.RequiredMode.NOT_REQUIRED) private Byte deleted; } pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voIr/VoProject.java
New file @@ -0,0 +1,46 @@ package com.dy.pipIrrGlobal.voIr; import com.alibaba.excel.annotation.ExcelProperty; import com.alibaba.excel.annotation.write.style.ColumnWidth; import com.dy.common.po.BaseEntity; import io.swagger.v3.oas.annotations.media.Schema; import lombok.Data; /** * @author :WuZeYu * @Date :2024/5/15 21:02 * @LastEditTime :2024/5/15 21:02 * @Description */ @Data @Schema(title = "项目视图对象") public class VoProject implements BaseEntity { @Schema(title = "项目ID") @ExcelProperty("项目ID") @ColumnWidth(15) private String projectId; @Schema(title = "项目名称") @ExcelProperty("项目名称") @ColumnWidth(15) private String projectName; @Schema(title = "项目状态") @ExcelProperty("项目状态") @ColumnWidth(2) private String projectState; @Schema(title = "项目地址") @ExcelProperty("项目地址") @ColumnWidth(25) private String address; @Schema(title = "项目备注") @ExcelProperty("项目备注") @ColumnWidth(250) private String remarks; } pipIrr-platform/pipIrr-global/src/main/resources/mapper/IrProjectMapper.xml
New file @@ -0,0 +1,213 @@ <?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.dy.pipIrrGlobal.daoIr.IrProjectMapper"> <resultMap id="BaseResultMap" type="com.dy.pipIrrGlobal.pojoIr.IrProject"> <!--@mbg.generated--> <!--@Table ir_project--> <id column="id" jdbcType="BIGINT" property="id" /> <result column="project_name" jdbcType="VARCHAR" property="projectName" /> <result column="province_id" jdbcType="BIGINT" property="provinceId" /> <result column="city_id" jdbcType="BIGINT" property="cityId" /> <result column="county_id" jdbcType="BIGINT" property="countyId" /> <result column="town_id" jdbcType="BIGINT" property="townId" /> <result column="village_id" jdbcType="BIGINT" property="villageId" /> <result column="project_state" jdbcType="TINYINT" property="projectState" /> <result column="remarks" jdbcType="VARCHAR" property="remarks" /> <result column="operator" jdbcType="BIGINT" property="operator" /> <result column="operate_time" jdbcType="TIMESTAMP" property="operateDt" /> <result column="deleted" jdbcType="TINYINT" property="deleted" /> </resultMap> <sql id="Base_Column_List"> <!--@mbg.generated--> id, project_name, province_id, city_id, county_id, town_id, `village_id`, project_state, remarks, `operator`, operate_time, deleted </sql> <!--添加--> <insert id="insertSelective" parameterType="com.dy.pipIrrGlobal.pojoIr.IrProject"> <!--@mbg.generated--> insert into ir_project <trim prefix="(" suffix=")" suffixOverrides=","> <if test="id != null"> id, </if> <if test="projectName != null"> project_name, </if> <if test="provinceId != null"> province_id, </if> <if test="cityId != null"> city_id, </if> <if test="countyId != null"> county_id, </if> <if test="townId != null"> town_id, </if> <if test="villageId != null"> village_id, </if> <if test="projectState != null"> project_state, </if> <if test="remarks != null"> remarks, </if> <if test="operator != null"> `operator`, </if> <if test="operateDt != null"> operate_time, </if> <if test="deleted != null"> deleted, </if> </trim> <trim prefix="values (" suffix=")" suffixOverrides=","> <if test="id != null"> #{id,jdbcType=BIGINT}, </if> <if test="projectName != null"> #{projectName,jdbcType=VARCHAR}, </if> <if test="provinceId != null"> #{provinceId,jdbcType=BIGINT}, </if> <if test="cityId != null"> #{cityId,jdbcType=BIGINT}, </if> <if test="countyId != null"> #{countyId,jdbcType=BIGINT}, </if> <if test="townId != null"> #{townId,jdbcType=BIGINT}, </if> <if test="villageId != null"> #{villageId,jdbcType=BIGINT}, </if> <if test="projectState != null"> #{projectState,jdbcType=TINYINT}, </if> <if test="remarks != null"> #{remarks,jdbcType=VARCHAR}, </if> <if test="operator != null"> #{operator,jdbcType=BIGINT}, </if> <if test="operateDt != null"> #{operateDt,jdbcType=TIMESTAMP}, </if> <if test="deleted != null"> #{deleted,jdbcType=TINYINT}, </if> </trim> </insert> <!--根据下级获取上一级地址--> <select id="getSupperByVillageId" parameterType="_long" resultType="java.lang.Long"> select dis_tow.* from ba_district dis_vil inner join ba_district dis_tow on dis_vil.supperId = dis_tow.id where dis_vil.id = #{vaId,jdbcType=BIGINT} </select> <!--逻辑删除--> <delete id="deleteLogicById" parameterType="java.lang.Long"> <!--@mbg.generated--> update ir_project set deleted = 1 where id = #{id,jdbcType=BIGINT} </delete> <!--修改信息--> <update id="updateByPrimaryKeySelective" parameterType="com.dy.pipIrrGlobal.pojoIr.IrProject"> update ir_project <set> <if test="projectName != null"> project_name = #{projectName,jdbcType=VARCHAR}, </if> <if test="provinceId != null"> province_id = #{provinceId,jdbcType=BIGINT}, </if> <if test="cityId != null"> city_id = #{cityId,jdbcType=BIGINT}, </if> <if test="countyId != null"> county_id = #{countyId,jdbcType=BIGINT}, </if> <if test="townId != null"> town_id = #{townId,jdbcType=BIGINT}, </if> <if test="villageId != null"> village_id = #{villageId,jdbcType=BIGINT}, </if> <if test="projectState != null"> project_state = #{projectState,jdbcType=TINYINT}, </if> <if test="remarks != null"> remarks = #{remarks,jdbcType=VARCHAR}, </if> <if test="operator != null"> operator = #{operator,jdbcType=BIGINT}, </if> <if test="operateDt != null"> operate_time = #{operateDt,jdbcType=TIMESTAMP}, </if> <if test="deleted != null"> deleted = #{deleted,jdbcType=TINYINT}, </if> </set> where id = #{id,jdbcType=BIGINT} </update> <!--修改状态--> <update id="updateProjectState"> update ir_project set project_state = #{projectState,jdbcType=TINYINT}, operator = #{operator,jdbcType=BIGINT}, operate_time = #{operateDt,jdbcType=TIMESTAMP} where id = #{id,jdbcType=BIGINT} </update> <!--查询一个信息--> <select id="selectById" resultMap="BaseResultMap"> select <include refid="Base_Column_List" /> from ir_project where id = #{id,jdbcType=BIGINT} and deleted = 0 </select> <!--分页查询数量--> <select id="getRecordCount" resultType="java.lang.Long"> SELECT COUNT(*) AS recordCount FROM ir_project pro <where> pro.deleted = 0 <if test="projectName != null and projectName != ''"> AND pro.project_name LIKE CONCAT('%', #{projectName}, '%') </if> <if test = "projectState != null and projectState != ''"> AND pro.project_state = #{projectState} </if> </where> </select> <!--分页查询数据--> <select id="getProjects" resultType="com.dy.pipIrrGlobal.voIr.VoProject"> SELECT CAST(pro.id AS char)AS projectId, pro.project_name AS projectName, pro.project_state AS projectState, CONCAT(province.`name`,city.`name`,country.`name`, town.`name`, village.`name`) AS address, pro.remarks FROM ir_project pro LEFT JOIN ba_district province ON pro.province_id = province.id LEFT JOIN ba_district city ON pro.city_id = city.id LEFT JOIN ba_district country ON pro.county_id = country.id LEFT JOIN ba_district town ON pro.town_id = town.id LEFT JOIN ba_district village ON pro.village_id = village.id <where> pro.deleted = 0 <if test="projectName != null and projectName != ''"> AND pro.project_name LIKE CONCAT('%', #{projectName}, '%') </if> <if test = "projectState != null and projectState != ''"> AND pro.project_state = #{projectState} </if> </where> </select> </mapper> pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/project/ProjectCtrl.java
New file @@ -0,0 +1,261 @@ package com.dy.pipIrrIrrigate.project; import com.dy.common.aop.SsoAop; import com.dy.common.webUtil.BaseResponse; import com.dy.common.webUtil.BaseResponseUtils; import com.dy.common.webUtil.QueryResultVo; import com.dy.common.webUtil.ResultCodeMsg; import com.dy.pipIrrGlobal.pojoIr.IrProject; import com.dy.pipIrrGlobal.pojoPr.PrIntake; import com.dy.pipIrrGlobal.voIr.VoProject; import com.dy.pipIrrGlobal.voPr.VoIntake; import com.dy.pipIrrGlobal.voSe.VoActiveCard; import com.dy.pipIrrIrrigate.result.IrrigateResultCode; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.media.Content; import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.responses.ApiResponse; import io.swagger.v3.oas.annotations.responses.ApiResponses; import io.swagger.v3.oas.annotations.tags.Tag; import jakarta.validation.Valid; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.apache.ibatis.annotations.Param; import org.springframework.http.MediaType; import org.springframework.transaction.annotation.Transactional; import org.springframework.validation.BindingResult; import org.springframework.web.bind.annotation.*; import java.lang.reflect.Array; import java.util.*; /** * @author :WuZeYu * @Date :2024/5/14 13:53 * @LastEditTime :2024/5/14 13:53 * @Description */ @Slf4j @Tag(name = "项目管理", description = "项目操作") @RestController @RequestMapping(path = "project") @RequiredArgsConstructor public class ProjectCtrl { private final ProjectSv projectSv; /** * 添加项目 * * @param po 项目实体对象 * @param bindingResult * @return 添加是否成功 */ @Operation(summary = "添加项目记录", description = "添加项目记录") @ApiResponses(value = { @ApiResponse( responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, description = "操作结果：true：成功，false：失败（BaseResponse.content）", content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, schema = @Schema(implementation = Boolean.class))} ) }) @PostMapping(path = "add", consumes = MediaType.APPLICATION_JSON_VALUE) @Transactional(rollbackFor = Exception.class) @SsoAop() public BaseResponse<Boolean> add(@RequestBody @Valid IrProject po, BindingResult bindingResult) { if (bindingResult != null && bindingResult.hasErrors()) { return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); } try { Integer rec = Optional.ofNullable(projectSv.addProject(po)).orElse(0); if (rec == 0) { return BaseResponseUtils.buildFail(IrrigateResultCode.ADD_PROJECT_FAIL.getMessage()); } } catch (Exception e) { log.error("添加项目异常", e); return BaseResponseUtils.buildException(e.getMessage()); } return BaseResponseUtils.buildSuccess(true); } /** * 逻辑删除项目 * @param map * @return */ @Operation(summary = "逻辑删除项目", description = "逻辑删除项目") @ApiResponses(value = { @ApiResponse( responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, description = "操作结果：true：成功，false：失败（BaseResponse.content）", content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, schema = @Schema(implementation = Boolean.class))} ) }) @PostMapping(path = "delete", consumes = MediaType.APPLICATION_JSON_VALUE) @Transactional(rollbackFor = Exception.class) @SsoAop() public BaseResponse<Boolean> delete(@RequestBody Map map) { if (map == null || map.size() <= 0) { BaseResponseUtils.buildFail(IrrigateResultCode.PLEASE_INPUT_PROJECT_ID.getMessage()); } Long projectId = Long.parseLong(map.get("id").toString()); try { Integer rows = projectSv.deleteProject(projectId); if (rows == 0) { return BaseResponseUtils.buildFail(IrrigateResultCode.DELETE_PROJECT_FAIL.getMessage()); } } catch (Exception e) { log.error("删除项目异常", e); return BaseResponseUtils.buildException(e.getMessage()); } return BaseResponseUtils.buildSuccess(true); } /** * 批量删除 * @param projectIds * @return */ @PostMapping(path = "delete_batch", consumes = MediaType.APPLICATION_JSON_VALUE) @Transactional(rollbackFor = Exception.class) @SsoAop() public BaseResponse<Boolean> delete_batch(@RequestBody Map<String,List> projectIds) { if (projectIds == null || projectIds.size() <= 0) { BaseResponseUtils.buildFail(IrrigateResultCode.PLEASE_INPUT_PROJECT_ID.getMessage()); } List ids = projectIds.get("projectIds"); for (int i = 0; i < ids.size(); i++) { long projectId = Long.parseLong(ids.get(i).toString()); try { Integer rows = projectSv.deleteProject(projectId); if (rows == 0) { return BaseResponseUtils.buildFail(IrrigateResultCode.DELETE_PROJECT_FAIL.getMessage()); } } catch (Exception e) { log.error("删除项目异常", e); return BaseResponseUtils.buildException(e.getMessage()); } } return BaseResponseUtils.buildSuccess(true); } /** * 修改项目信息 * @param po * @param bindingResult * @return */ @Operation(summary = "修改项目信息", description = "修改项目信息") @ApiResponses(value = { @ApiResponse( responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, description = "操作结果：true：成功，false：失败（BaseResponse.content）", content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, schema = @Schema(implementation = Boolean.class))} ) }) @PostMapping(path = "update", consumes = MediaType.APPLICATION_JSON_VALUE) @Transactional(rollbackFor = Exception.class) @SsoAop() public BaseResponse<Boolean> update(@RequestBody @Valid IrProject po, BindingResult bindingResult){ if (bindingResult != null && bindingResult.hasErrors()) { return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); } try { Integer rec = Optional.ofNullable(projectSv.updateProject(po)).orElse(0); if (rec == 0) { return BaseResponseUtils.buildFail(IrrigateResultCode.UPDATE_PROJECT_FAIL.getMessage()); } } catch (Exception e) { log.error("修改项目异常", e); return BaseResponseUtils.buildException(e.getMessage()); } return BaseResponseUtils.buildSuccess(true); } /** * 修改项目状态 * @param po * @param * @return */ @Operation(summary = "修改项目状态", description = "修改项目状态") @ApiResponses(value = { @ApiResponse( responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, description = "操作结果：true：成功，false：失败（BaseResponse.content）", content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, schema = @Schema(implementation = Boolean.class))} ) }) @PostMapping(path = "update_state", consumes = MediaType.APPLICATION_JSON_VALUE) @Transactional(rollbackFor = Exception.class) @SsoAop() public BaseResponse<Boolean> update_state(@RequestBody IrProject po){ try { Integer rec = Optional.ofNullable(projectSv.updateProjectState(po)).orElse(0); if (rec == 0) { return BaseResponseUtils.buildFail(IrrigateResultCode.UPDATE_PROJECT_FAIL.getMessage()); } } catch (Exception e) { log.error("修改项目异常", e); return BaseResponseUtils.buildException(e.getMessage()); } return BaseResponseUtils.buildSuccess(true); } /** * 获取一个项目数据 * * @return 获取一个项目数据 */ @Operation(summary = "获取一个项目数据", description = "获取一个项目数据") @ApiResponses(value = { @ApiResponse( responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, description = "获取一个项目数据（BaseResponse.content:{}）", content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, schema = @Schema(implementation = IrProject.class))} ) }) @GetMapping(path = "one") @SsoAop() public BaseResponse<IrProject> one(@RequestParam Long id) { IrProject irProject = this.projectSv.selectById(id); if (irProject == null) { return BaseResponseUtils.buildFail(IrrigateResultCode.NO_PROJECT.getMessage()); } else { return BaseResponseUtils.buildSuccess(irProject); } } /** * 分页查询 * @param vo * @return */ @Operation(summary = "获得一页项目记录", description = "获得一页项目记录") @ApiResponses(value = { @ApiResponse( responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, description = "获得一页项目记录（BaseResponse.content:QueryResultVo[{}]）", content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, schema = @Schema(implementation = VoActiveCard.class))} ) }) @GetMapping(path = "some") @SsoAop() public BaseResponse<QueryResultVo<List<VoProject>>> getIntakes(QueryVo vo) { try { QueryResultVo<List<VoProject>> res = projectSv.getProjects(vo); if (res == null) { return BaseResponseUtils.buildFail(IrrigateResultCode.NO_PROJECT.getMessage()); } return BaseResponseUtils.buildSuccess(res); } catch (Exception e) { log.error("获取项目记录异常", e); return BaseResponseUtils.buildException(e.getMessage()); } } } pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/project/ProjectSv.java
New file @@ -0,0 +1,149 @@ 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.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 IrProject selectById(Long id){ IrProject 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; } } pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/project/QueryVo.java
New file @@ -0,0 +1,26 @@ package com.dy.pipIrrIrrigate.project; import com.dy.common.webUtil.QueryConditionVo; import io.swagger.v3.oas.annotations.media.Schema; import lombok.*; /** * @author :WuZeYu * @Date :2024/5/15 21:11 * @LastEditTime :2024/5/15 21:11 * @Description */ @Data @EqualsAndHashCode(callSuper = false) @ToString(callSuper = true) @NoArgsConstructor @AllArgsConstructor @Builder @Schema(name = "项目查询条件") public class QueryVo extends QueryConditionVo { @Schema(description = "项目名称") public String projectName; @Schema(description = "项目状态") public String projectState; } pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/result/IrrigateResultCode.java
@@ -14,11 +14,13 @@ @AllArgsConstructor public enum IrrigateResultCode { /** * 田间灌溉项目 * 项目 */ DIVIDE_FAIL(10001, "分水房添加失败"), DELETE_DIVIDE_FAIL(10001, "分水房删除失败"), NO_DIVIDES(10001, "无符合条件的分水房记录"); ADD_PROJECT_FAIL(10001, "项目添加失败"), PLEASE_INPUT_PROJECT_ID(10002, "请输入项目ID"), DELETE_PROJECT_FAIL(10003, "项目删除失败"), UPDATE_PROJECT_FAIL(10004, "项目修改失败"), NO_PROJECT(10005, "无符合条件的项目记录"); private final Integer code;
