From c5c511a61891ee6e7cd1d0528dff509a93c723dd Mon Sep 17 00:00:00 2001 From: wuzeyu <1223318623@qq.com> Date: 星期六, 25 五月 2024 09:35:50 +0800 Subject: [PATCH] 田间灌溉项目管理 作物模块 4个接口实现 --- pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoIr/IrCrop.java | 57 ++++++ pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/crop/CropSv.java | 87 +++++++++ pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/crop/QueryVo.java | 23 ++ pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoIr/IrCropMapper.java | 44 ++++ pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voIr/VoCrop.java | 22 ++ pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/crop/CropCtrl.java | 177 +++++++++++++++++++ pipIrr-platform/pipIrr-global/src/main/resources/mapper/IrCropMapper.xml | 99 +++++++++++ 7 files changed, 509 insertions(+), 0 deletions(-) diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoIr/IrCropMapper.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoIr/IrCropMapper.java new file mode 100644 index 0000000..7526e3d --- /dev/null +++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoIr/IrCropMapper.java @@ -0,0 +1,44 @@ +package com.dy.pipIrrGlobal.daoIr; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.dy.pipIrrGlobal.pojoIr.IrCrop; +import com.dy.pipIrrGlobal.pojoIr.IrProject; +import com.dy.pipIrrGlobal.voIr.VoCrop; +import com.dy.pipIrrGlobal.voIr.VoProject; +import org.apache.ibatis.annotations.Mapper; + +import java.util.List; +import java.util.Map; + +/** + * @author :WuZeYu + * @Date :2024/5/24 13:55 + * @LastEditTime :2024/5/24 13:55 + * @Description + */ +@Mapper +public interface IrCropMapper extends BaseMapper<IrCrop> { + //澧� + int insertSelective(IrCrop record); + + //鍒� + int deleteLogicById(Long id); + + //鏀� + int updateByPrimaryKeySelective(IrCrop record); + /** + * 鏍规嵁鎸囧畾鏉′欢鑾峰彇椤圭洰璁板綍鏁� + * + * @param params + * @return + */ + Long getRecordCount(Map<?, ?> params); + + /** + * 鏍规嵁鎸囧畾鏉′欢鑾峰彇椤圭洰璁板綍 + * + * @param params + * @return + */ + List<VoCrop> getCrops(Map<?, ?> params); +} diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoIr/IrCrop.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoIr/IrCrop.java new file mode 100644 index 0000000..1626cca --- /dev/null +++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoIr/IrCrop.java @@ -0,0 +1,57 @@ +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 lombok.*; +import org.apache.logging.log4j.core.config.plugins.validation.constraints.NotBlank; + +/** + * @author :WuZeYu + * @Date :2024/5/24 9:43 + * @LastEditTime :2024/5/24 9:43 + * @Description + */ + +/** + * 浣滅墿琛� + */ +@TableName(value="ir_crop", autoResultMap = true) +@Data +@ToString +@Builder +@NoArgsConstructor +@AllArgsConstructor +@Schema(name = "浣滅墿瀹炰綋") +public class IrCrop implements BaseEntity { + /** + * 涓婚敭 + */ + @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 = "浣滅墿鍚嶇О涓嶈兘涓虹┖") + private String cropName; + + /** + * 澶囨敞 + */ + @Schema(description = "澶囨敞", requiredMode = Schema.RequiredMode.REQUIRED) + private String remarks; + + /** + * 閫昏緫鍒犻櫎鏍囪瘑;0-鏈垹闄わ紝1-鍒犻櫎 + */ + @Schema(description = "鍒犻櫎鏍囪瘑", requiredMode = Schema.RequiredMode.NOT_REQUIRED) + private Byte deleted; +} diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voIr/VoCrop.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voIr/VoCrop.java new file mode 100644 index 0000000..14f8e45 --- /dev/null +++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voIr/VoCrop.java @@ -0,0 +1,22 @@ +package com.dy.pipIrrGlobal.voIr; + +import com.dy.common.po.BaseEntity; +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; +import org.apache.logging.log4j.core.config.plugins.validation.constraints.NotBlank; + +/** + * @author :WuZeYu + * @Date :2024/5/25 9:29 + * @LastEditTime :2024/5/25 9:29 + * @Description + */ +@Data +@Schema(name = "浣滅墿瑙嗗浘") +public class VoCrop implements BaseEntity { + @Schema(description = "瀹炰綋id") + private Long id; + + @Schema(description = "浣滅墿鍚嶇О") + private String cropName; +} diff --git a/pipIrr-platform/pipIrr-global/src/main/resources/mapper/IrCropMapper.xml b/pipIrr-platform/pipIrr-global/src/main/resources/mapper/IrCropMapper.xml new file mode 100644 index 0000000..5da8e78 --- /dev/null +++ b/pipIrr-platform/pipIrr-global/src/main/resources/mapper/IrCropMapper.xml @@ -0,0 +1,99 @@ +<?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.IrCropMapper"> + <resultMap id="BaseResultMap" type="com.dy.pipIrrGlobal.pojoIr.IrCrop"> + <!--@mbg.generated--> + <!--@Table ir_crop--> + <id column="id" jdbcType="BIGINT" property="id" /> + <result column="crop_name" jdbcType="VARCHAR" property="cropName" /> + <result column="remarks" jdbcType="VARCHAR" property="remarks" /> + <result column="deleted" jdbcType="TINYINT" property="deleted" /> + </resultMap> + <sql id="Base_Column_List"> + <!--@mbg.generated--> + id, crop_name, remarks, deleted + </sql> + <!--娣诲姞--> + <insert id="insertSelective" parameterType="com.dy.pipIrrGlobal.pojoIr.IrCrop"> + insert into ir_crop + <trim prefix="(" suffix=")" suffixOverrides=","> + <if test="id != null"> + id, + </if> + <if test="cropName != null"> + crop_name, + </if> + <if test="remarks != null"> + remarks, + </if> + <if test="deleted != null"> + deleted, + </if> + </trim> + <trim prefix="values (" suffix=")" suffixOverrides=","> + <if test="id != null"> + #{id,jdbcType=BIGINT}, + </if> + <if test="cropName != null"> + #{cropName,jdbcType=VARCHAR}, + </if> + <if test="remarks != null"> + #{remarks,jdbcType=VARCHAR}, + </if> + <if test="deleted != null"> + #{deleted,jdbcType=TINYINT}, + </if> + </trim> + </insert> + <!--閫昏緫鍒犻櫎--> + <delete id="deleteLogicById" parameterType="java.lang.Long"> + <!--@mbg.generated--> + update ir_crop + set deleted = 1 + where id = #{id,jdbcType=BIGINT} + </delete> + + <!--淇敼淇℃伅--> + <update id="updateByPrimaryKeySelective" parameterType="com.dy.pipIrrGlobal.pojoIr.IrCrop"> + update ir_crop + <set> + <if test="cropName != null"> + crop_name = #{cropName,jdbcType=VARCHAR}, + </if> + <if test="remarks != null"> + remarks = #{remarks,jdbcType=VARCHAR}, + </if> + <if test="deleted != null"> + deleted = #{deleted,jdbcType=TINYINT}, + </if> + </set> + where id = #{id,jdbcType=BIGINT} + </update> + + <select id="getRecordCount" resultType="java.lang.Long"> + SELECT COUNT(*) AS recordCount + FROM ir_crop cro + <where> + cro.deleted = 0 + <if test="cropName != null and cropName != ''"> + AND cro.crop_name LIKE CONCAT('%', #{cropName}, '%') + </if> + </where> + </select> + + <select id="getCrops" resultType="com.dy.pipIrrGlobal.voIr.VoCrop"> + SELECT + CAST(cro.id AS char)AS id, + cro.crop_name AS cropName + FROM ir_crop cro + <where> + cro.deleted = 0 + <if test="cropName != null and cropName != ''"> + AND cro.crop_name LIKE CONCAT('%', #{cropName}, '%') + </if> + </where> + <if test="pageCurr != null and pageSize != null"> + LIMIT ${(pageCurr-1)*pageSize}, ${pageSize} + </if> + </select> +</mapper> \ No newline at end of file diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/crop/CropCtrl.java b/pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/crop/CropCtrl.java new file mode 100644 index 0000000..9634945 --- /dev/null +++ b/pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/crop/CropCtrl.java @@ -0,0 +1,177 @@ +package com.dy.pipIrrIrrigate.crop; + +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.IrCrop; +import com.dy.pipIrrGlobal.pojoIr.IrProject; +import com.dy.pipIrrGlobal.voIr.VoCrop; +import com.dy.pipIrrGlobal.voIr.VoProject; +import com.dy.pipIrrGlobal.voSe.VoActiveCard; +import com.dy.pipIrrIrrigate.crop.QueryVo; +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.springframework.http.MediaType; +import org.springframework.transaction.annotation.Transactional; +import org.springframework.validation.BindingResult; +import org.springframework.web.bind.annotation.*; + +import java.util.List; +import java.util.Map; +import java.util.Objects; +import java.util.Optional; + +/** + * @author :WuZeYu + * @Date :2024/5/24 19:38 + * @LastEditTime :2024/5/24 19:38 + * @Description + */ +@Slf4j +@Tag(name = "浣滅墿绠$悊", description = "浣滅墿鎿嶄綔") +@RestController +@RequestMapping(path = "crop") +@RequiredArgsConstructor +public class CropCtrl { + + private final CropSv cropSv; + + /** + * 娣诲姞浣滅墿 + * + * @param po 浣滅墿瀹炰綋瀵硅薄 + * @param bindingResult + * @return 娣诲姞鏄惁鎴愬姛 + */ + @Operation(summary = "娣诲姞浣滅墿璁板綍", description = "娣诲姞浣滅墿璁板綍") + @ApiResponses(value = { + @ApiResponse( + responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, + description = "鎿嶄綔缁撴灉锛歵rue锛氭垚鍔燂紝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 IrCrop po, BindingResult bindingResult) { + if (bindingResult != null && bindingResult.hasErrors()) { + return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); + } + try { + Integer rec = Optional.ofNullable(cropSv.addCrop(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 = "鎿嶄綔缁撴灉锛歵rue锛氭垚鍔燂紝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 cropId = Long.parseLong(map.get("id").toString()); + try { + Integer rows = cropSv.deleteCrop(cropId); + 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 = "鎿嶄綔缁撴灉锛歵rue锛氭垚鍔燂紝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 IrCrop po, BindingResult bindingResult){ + if (bindingResult != null && bindingResult.hasErrors()) { + return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); + } + try { + Integer rec = Optional.ofNullable(cropSv.updateCrop(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 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<VoCrop>>> getCrops(QueryVo vo) { + try { + QueryResultVo<List<VoCrop>> res = cropSv.getCrops(vo); + return BaseResponseUtils.buildSuccess(res); + } catch (Exception e) { + log.error("鑾峰彇浣滅墿璁板綍寮傚父", e); + return BaseResponseUtils.buildException(e.getMessage()); + } + } +} diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/crop/CropSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/crop/CropSv.java new file mode 100644 index 0000000..7c3ac67 --- /dev/null +++ b/pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/crop/CropSv.java @@ -0,0 +1,87 @@ +package com.dy.pipIrrIrrigate.crop; + +import com.dy.common.webUtil.QueryResultVo; +import com.dy.pipIrrGlobal.daoIr.IrCropMapper; + +import com.dy.pipIrrGlobal.pojoIr.IrCrop; +import com.dy.pipIrrGlobal.voIr.VoCrop; +import com.dy.pipIrrIrrigate.crop.QueryVo; +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/24 19:38 + * @LastEditTime :2024/5/24 19:38 + * @Description + */ +@Slf4j +@Service +public class CropSv { + + @Autowired + private IrCropMapper irCropMapper; + + /** + * 娣诲姞椤圭洰 + * + * @param po + * @return + */ + public Integer addCrop(IrCrop po) { + po.setDeleted((byte) 0); + int rows = irCropMapper.insertSelective(po); + if (rows == 0) { + return 0; + } + return 1; + } + /** + * 鍒犻櫎椤圭洰 + * + * @param id + */ + public Integer deleteCrop(Long id) { + int rows = irCropMapper.deleteLogicById(id); + if (rows == 0) { + return 0; + } + return 1; + } + + /** + * 淇敼椤圭洰淇℃伅 + * @param po + * @return + */ + public Integer updateCrop(IrCrop po){ + int rows = irCropMapper.updateByPrimaryKeySelective(po); + if (rows == 0){ + return 0; + } + return 1; + } + + /** + * 鍒嗛〉鏌ヨ椤圭洰 + * @param queryVo + * @return + */ + public QueryResultVo<List<VoCrop>> getCrops(QueryVo queryVo){ + Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo); + Long itemTotal = irCropMapper.getRecordCount(params); + + QueryResultVo<List<VoCrop>> rsVo = new QueryResultVo<>(); + rsVo.pageSize = queryVo.pageSize; + rsVo.pageCurr = queryVo.pageCurr; + rsVo.calculateAndSet(itemTotal, params); + rsVo.obj = irCropMapper.getCrops(params); + return rsVo; + } +} diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/crop/QueryVo.java b/pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/crop/QueryVo.java new file mode 100644 index 0000000..86217ff --- /dev/null +++ b/pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/java/com/dy/pipIrrIrrigate/crop/QueryVo.java @@ -0,0 +1,23 @@ +package com.dy.pipIrrIrrigate.crop; + +import com.dy.common.webUtil.QueryConditionVo; +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.*; + +/** + * @author :WuZeYu + * @Date :2024/5/24 19:53 + * @LastEditTime :2024/5/24 19:53 + * @Description + */ +@Data +@EqualsAndHashCode(callSuper = false) +@ToString(callSuper = true) +@NoArgsConstructor +@AllArgsConstructor +@Builder +@Schema(name = "浣滅墿鏌ヨ鏉′欢") +public class QueryVo extends QueryConditionVo { + @Schema(description = "浣滅墿鍚嶇О") + public String cropName; +} -- Gitblit v1.8.0