parent
092144e35d
commit
6e6e88904e
@ -0,0 +1,95 @@ |
|||||||
|
package com.cjy.traceability.module.traceability.controller.admin.growrecord; |
||||||
|
|
||||||
|
import org.springframework.web.bind.annotation.*; |
||||||
|
import javax.annotation.Resource; |
||||||
|
import org.springframework.validation.annotation.Validated; |
||||||
|
import org.springframework.security.access.prepost.PreAuthorize; |
||||||
|
import io.swagger.v3.oas.annotations.tags.Tag; |
||||||
|
import io.swagger.v3.oas.annotations.Parameter; |
||||||
|
import io.swagger.v3.oas.annotations.Operation; |
||||||
|
|
||||||
|
import javax.validation.constraints.*; |
||||||
|
import javax.validation.*; |
||||||
|
import javax.servlet.http.*; |
||||||
|
import java.util.*; |
||||||
|
import java.io.IOException; |
||||||
|
|
||||||
|
import com.cjy.traceability.framework.common.pojo.PageParam; |
||||||
|
import com.cjy.traceability.framework.common.pojo.PageResult; |
||||||
|
import com.cjy.traceability.framework.common.pojo.CommonResult; |
||||||
|
import com.cjy.traceability.framework.common.util.object.BeanUtils; |
||||||
|
import static com.cjy.traceability.framework.common.pojo.CommonResult.success; |
||||||
|
|
||||||
|
import com.cjy.traceability.framework.excel.core.util.ExcelUtils; |
||||||
|
|
||||||
|
import com.cjy.traceability.framework.operatelog.core.annotations.OperateLog; |
||||||
|
import static com.cjy.traceability.framework.operatelog.core.enums.OperateTypeEnum.*; |
||||||
|
|
||||||
|
import com.cjy.traceability.module.traceability.controller.admin.growrecord.vo.*; |
||||||
|
import com.cjy.traceability.module.traceability.dal.dataobject.growrecord.GrowRecordDO; |
||||||
|
import com.cjy.traceability.module.traceability.service.growrecord.GrowRecordService; |
||||||
|
|
||||||
|
@Tag(name = "管理后台 - 种植历史") |
||||||
|
@RestController |
||||||
|
@RequestMapping("/traceability/grow-record") |
||||||
|
@Validated |
||||||
|
public class GrowRecordController { |
||||||
|
|
||||||
|
@Resource |
||||||
|
private GrowRecordService growRecordService; |
||||||
|
|
||||||
|
@PostMapping("/create") |
||||||
|
@Operation(summary = "创建种植历史") |
||||||
|
@PreAuthorize("@ss.hasPermission('traceability:grow-record:create')") |
||||||
|
public CommonResult<Integer> createGrowRecord(@Valid @RequestBody GrowRecordSaveReqVO createReqVO) { |
||||||
|
return success(growRecordService.createGrowRecord(createReqVO)); |
||||||
|
} |
||||||
|
|
||||||
|
@PutMapping("/update") |
||||||
|
@Operation(summary = "更新种植历史") |
||||||
|
@PreAuthorize("@ss.hasPermission('traceability:grow-record:update')") |
||||||
|
public CommonResult<Boolean> updateGrowRecord(@Valid @RequestBody GrowRecordSaveReqVO updateReqVO) { |
||||||
|
growRecordService.updateGrowRecord(updateReqVO); |
||||||
|
return success(true); |
||||||
|
} |
||||||
|
|
||||||
|
@DeleteMapping("/delete") |
||||||
|
@Operation(summary = "删除种植历史") |
||||||
|
@Parameter(name = "id", description = "编号", required = true) |
||||||
|
@PreAuthorize("@ss.hasPermission('traceability:grow-record:delete')") |
||||||
|
public CommonResult<Boolean> deleteGrowRecord(@RequestParam("id") Integer id) { |
||||||
|
growRecordService.deleteGrowRecord(id); |
||||||
|
return success(true); |
||||||
|
} |
||||||
|
|
||||||
|
@GetMapping("/get") |
||||||
|
@Operation(summary = "获得种植历史") |
||||||
|
@Parameter(name = "id", description = "编号", required = true, example = "1024") |
||||||
|
@PreAuthorize("@ss.hasPermission('traceability:grow-record:query')") |
||||||
|
public CommonResult<GrowRecordRespVO> getGrowRecord(@RequestParam("id") Integer id) { |
||||||
|
GrowRecordDO growRecord = growRecordService.getGrowRecord(id); |
||||||
|
return success(BeanUtils.toBean(growRecord, GrowRecordRespVO.class)); |
||||||
|
} |
||||||
|
|
||||||
|
@GetMapping("/page") |
||||||
|
@Operation(summary = "获得种植历史分页") |
||||||
|
@PreAuthorize("@ss.hasPermission('traceability:grow-record:query')") |
||||||
|
public CommonResult<PageResult<GrowRecordRespVO>> getGrowRecordPage(@Valid GrowRecordPageReqVO pageReqVO) { |
||||||
|
PageResult<GrowRecordDO> pageResult = growRecordService.getGrowRecordPage(pageReqVO); |
||||||
|
return success(BeanUtils.toBean(pageResult, GrowRecordRespVO.class)); |
||||||
|
} |
||||||
|
|
||||||
|
@GetMapping("/export-excel") |
||||||
|
@Operation(summary = "导出种植历史 Excel") |
||||||
|
@PreAuthorize("@ss.hasPermission('traceability:grow-record:export')") |
||||||
|
@OperateLog(type = EXPORT) |
||||||
|
public void exportGrowRecordExcel(@Valid GrowRecordPageReqVO pageReqVO, |
||||||
|
HttpServletResponse response) throws IOException { |
||||||
|
pageReqVO.setPageSize(PageParam.PAGE_SIZE_NONE); |
||||||
|
List<GrowRecordDO> list = growRecordService.getGrowRecordPage(pageReqVO).getList(); |
||||||
|
// 导出 Excel
|
||||||
|
ExcelUtils.write(response, "种植历史.xls", "数据", GrowRecordRespVO.class, |
||||||
|
BeanUtils.toBean(list, GrowRecordRespVO.class)); |
||||||
|
} |
||||||
|
|
||||||
|
} |
@ -0,0 +1,46 @@ |
|||||||
|
package com.cjy.traceability.module.traceability.controller.admin.growrecord.vo; |
||||||
|
|
||||||
|
import lombok.*; |
||||||
|
import java.util.*; |
||||||
|
import io.swagger.v3.oas.annotations.media.Schema; |
||||||
|
import com.cjy.traceability.framework.common.pojo.PageParam; |
||||||
|
import java.math.BigDecimal; |
||||||
|
import org.springframework.format.annotation.DateTimeFormat; |
||||||
|
import java.time.LocalDateTime; |
||||||
|
|
||||||
|
import static com.cjy.traceability.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND; |
||||||
|
|
||||||
|
@Schema(description = "管理后台 - 种植历史分页 Request VO") |
||||||
|
@Data |
||||||
|
@EqualsAndHashCode(callSuper = true) |
||||||
|
@ToString(callSuper = true) |
||||||
|
public class GrowRecordPageReqVO extends PageParam { |
||||||
|
|
||||||
|
@Schema(description = "农作物ID", example = "14721") |
||||||
|
private Integer cropperId; |
||||||
|
|
||||||
|
@Schema(description = "产品名称", example = "李四") |
||||||
|
private String productName; |
||||||
|
|
||||||
|
@Schema(description = "品种") |
||||||
|
private String variety; |
||||||
|
|
||||||
|
@Schema(description = "种植时间") |
||||||
|
@DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND) |
||||||
|
private LocalDateTime[] plantTime; |
||||||
|
|
||||||
|
@Schema(description = "结束时间") |
||||||
|
@DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND) |
||||||
|
private LocalDateTime[] endTime; |
||||||
|
|
||||||
|
@Schema(description = "采收次数") |
||||||
|
private Integer harvestNum; |
||||||
|
|
||||||
|
@Schema(description = "累计产量") |
||||||
|
private BigDecimal production; |
||||||
|
|
||||||
|
@Schema(description = "创建时间") |
||||||
|
@DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND) |
||||||
|
private LocalDateTime[] createTime; |
||||||
|
|
||||||
|
} |
@ -0,0 +1,53 @@ |
|||||||
|
package com.cjy.traceability.module.traceability.controller.admin.growrecord.vo; |
||||||
|
|
||||||
|
import io.swagger.v3.oas.annotations.media.Schema; |
||||||
|
import lombok.*; |
||||||
|
import java.util.*; |
||||||
|
import java.util.*; |
||||||
|
import java.math.BigDecimal; |
||||||
|
import org.springframework.format.annotation.DateTimeFormat; |
||||||
|
import java.time.LocalDateTime; |
||||||
|
import com.alibaba.excel.annotation.*; |
||||||
|
|
||||||
|
@Schema(description = "管理后台 - 种植历史 Response VO") |
||||||
|
@Data |
||||||
|
@ExcelIgnoreUnannotated |
||||||
|
public class GrowRecordRespVO { |
||||||
|
|
||||||
|
@Schema(description = "主键ID", requiredMode = Schema.RequiredMode.REQUIRED, example = "3271") |
||||||
|
@ExcelProperty("主键ID") |
||||||
|
private Integer id; |
||||||
|
|
||||||
|
@Schema(description = "农作物ID", example = "14721") |
||||||
|
@ExcelProperty("农作物ID") |
||||||
|
private Integer cropperId; |
||||||
|
|
||||||
|
@Schema(description = "产品名称", example = "李四") |
||||||
|
@ExcelProperty("产品名称") |
||||||
|
private String productName; |
||||||
|
|
||||||
|
@Schema(description = "品种") |
||||||
|
@ExcelProperty("品种") |
||||||
|
private String variety; |
||||||
|
|
||||||
|
@Schema(description = "种植时间") |
||||||
|
@ExcelProperty("种植时间") |
||||||
|
private LocalDateTime plantTime; |
||||||
|
|
||||||
|
@Schema(description = "结束时间") |
||||||
|
@ExcelProperty("结束时间") |
||||||
|
private LocalDateTime endTime; |
||||||
|
|
||||||
|
@Schema(description = "采收次数") |
||||||
|
@ExcelProperty("采收次数") |
||||||
|
private Integer harvestNum; |
||||||
|
|
||||||
|
@Schema(description = "累计产量") |
||||||
|
@ExcelProperty("累计产量") |
||||||
|
private BigDecimal production; |
||||||
|
|
||||||
|
@Schema(description = "创建时间", requiredMode = Schema.RequiredMode.REQUIRED) |
||||||
|
@ExcelProperty("创建时间") |
||||||
|
private LocalDateTime createTime; |
||||||
|
|
||||||
|
} |
@ -0,0 +1,39 @@ |
|||||||
|
package com.cjy.traceability.module.traceability.controller.admin.growrecord.vo; |
||||||
|
|
||||||
|
import io.swagger.v3.oas.annotations.media.Schema; |
||||||
|
import lombok.*; |
||||||
|
import java.util.*; |
||||||
|
import javax.validation.constraints.*; |
||||||
|
import java.math.BigDecimal; |
||||||
|
import org.springframework.format.annotation.DateTimeFormat; |
||||||
|
import java.time.LocalDateTime; |
||||||
|
|
||||||
|
@Schema(description = "管理后台 - 种植历史新增/修改 Request VO") |
||||||
|
@Data |
||||||
|
public class GrowRecordSaveReqVO { |
||||||
|
|
||||||
|
@Schema(description = "主键ID", requiredMode = Schema.RequiredMode.REQUIRED, example = "3271") |
||||||
|
private Integer id; |
||||||
|
|
||||||
|
@Schema(description = "农作物ID", example = "14721") |
||||||
|
private Integer cropperId; |
||||||
|
|
||||||
|
@Schema(description = "产品名称", example = "李四") |
||||||
|
private String productName; |
||||||
|
|
||||||
|
@Schema(description = "品种") |
||||||
|
private String variety; |
||||||
|
|
||||||
|
@Schema(description = "种植时间") |
||||||
|
private LocalDateTime plantTime; |
||||||
|
|
||||||
|
@Schema(description = "结束时间") |
||||||
|
private LocalDateTime endTime; |
||||||
|
|
||||||
|
@Schema(description = "采收次数") |
||||||
|
private Integer harvestNum; |
||||||
|
|
||||||
|
@Schema(description = "累计产量") |
||||||
|
private BigDecimal production; |
||||||
|
|
||||||
|
} |
@ -0,0 +1,62 @@ |
|||||||
|
package com.cjy.traceability.module.traceability.dal.dataobject.growrecord; |
||||||
|
|
||||||
|
import lombok.*; |
||||||
|
import java.util.*; |
||||||
|
import java.time.LocalDateTime; |
||||||
|
import java.time.LocalDateTime; |
||||||
|
import java.math.BigDecimal; |
||||||
|
import java.time.LocalDateTime; |
||||||
|
import java.time.LocalDateTime; |
||||||
|
import com.baomidou.mybatisplus.annotation.*; |
||||||
|
import com.cjy.traceability.framework.mybatis.core.dataobject.BaseDO; |
||||||
|
|
||||||
|
/** |
||||||
|
* 种植历史 DO |
||||||
|
* |
||||||
|
* @author qfzj |
||||||
|
*/ |
||||||
|
@TableName("traceability_grow_record") |
||||||
|
@KeySequence("traceability_grow_record_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库,可不写。
|
||||||
|
@Data |
||||||
|
@EqualsAndHashCode(callSuper = true) |
||||||
|
@ToString(callSuper = true) |
||||||
|
@Builder |
||||||
|
@NoArgsConstructor |
||||||
|
@AllArgsConstructor |
||||||
|
public class GrowRecordDO extends BaseDO { |
||||||
|
|
||||||
|
/** |
||||||
|
* 主键ID |
||||||
|
*/ |
||||||
|
@TableId |
||||||
|
private Integer id; |
||||||
|
/** |
||||||
|
* 农作物ID |
||||||
|
*/ |
||||||
|
private Integer cropperId; |
||||||
|
/** |
||||||
|
* 产品名称 |
||||||
|
*/ |
||||||
|
private String productName; |
||||||
|
/** |
||||||
|
* 品种 |
||||||
|
*/ |
||||||
|
private String variety; |
||||||
|
/** |
||||||
|
* 种植时间 |
||||||
|
*/ |
||||||
|
private LocalDateTime plantTime; |
||||||
|
/** |
||||||
|
* 结束时间 |
||||||
|
*/ |
||||||
|
private LocalDateTime endTime; |
||||||
|
/** |
||||||
|
* 采收次数 |
||||||
|
*/ |
||||||
|
private Integer harvestNum; |
||||||
|
/** |
||||||
|
* 累计产量 |
||||||
|
*/ |
||||||
|
private BigDecimal production; |
||||||
|
|
||||||
|
} |
@ -0,0 +1,33 @@ |
|||||||
|
package com.cjy.traceability.module.traceability.dal.mysql.growrecord; |
||||||
|
|
||||||
|
import java.util.*; |
||||||
|
|
||||||
|
import com.cjy.traceability.framework.common.pojo.PageResult; |
||||||
|
import com.cjy.traceability.framework.mybatis.core.query.LambdaQueryWrapperX; |
||||||
|
import com.cjy.traceability.framework.mybatis.core.mapper.BaseMapperX; |
||||||
|
import com.cjy.traceability.module.traceability.dal.dataobject.growrecord.GrowRecordDO; |
||||||
|
import org.apache.ibatis.annotations.Mapper; |
||||||
|
import com.cjy.traceability.module.traceability.controller.admin.growrecord.vo.*; |
||||||
|
|
||||||
|
/** |
||||||
|
* 种植历史 Mapper |
||||||
|
* |
||||||
|
* @author qfzj |
||||||
|
*/ |
||||||
|
@Mapper |
||||||
|
public interface GrowRecordMapper extends BaseMapperX<GrowRecordDO> { |
||||||
|
|
||||||
|
default PageResult<GrowRecordDO> selectPage(GrowRecordPageReqVO reqVO) { |
||||||
|
return selectPage(reqVO, new LambdaQueryWrapperX<GrowRecordDO>() |
||||||
|
.eqIfPresent(GrowRecordDO::getCropperId, reqVO.getCropperId()) |
||||||
|
.likeIfPresent(GrowRecordDO::getProductName, reqVO.getProductName()) |
||||||
|
.eqIfPresent(GrowRecordDO::getVariety, reqVO.getVariety()) |
||||||
|
.betweenIfPresent(GrowRecordDO::getPlantTime, reqVO.getPlantTime()) |
||||||
|
.betweenIfPresent(GrowRecordDO::getEndTime, reqVO.getEndTime()) |
||||||
|
.eqIfPresent(GrowRecordDO::getHarvestNum, reqVO.getHarvestNum()) |
||||||
|
.eqIfPresent(GrowRecordDO::getProduction, reqVO.getProduction()) |
||||||
|
.betweenIfPresent(GrowRecordDO::getCreateTime, reqVO.getCreateTime()) |
||||||
|
.orderByDesc(GrowRecordDO::getId)); |
||||||
|
} |
||||||
|
|
||||||
|
} |
@ -0,0 +1,55 @@ |
|||||||
|
package com.cjy.traceability.module.traceability.service.growrecord; |
||||||
|
|
||||||
|
import java.util.*; |
||||||
|
import javax.validation.*; |
||||||
|
import com.cjy.traceability.module.traceability.controller.admin.growrecord.vo.*; |
||||||
|
import com.cjy.traceability.module.traceability.dal.dataobject.growrecord.GrowRecordDO; |
||||||
|
import com.cjy.traceability.framework.common.pojo.PageResult; |
||||||
|
import com.cjy.traceability.framework.common.pojo.PageParam; |
||||||
|
|
||||||
|
/** |
||||||
|
* 种植历史 Service 接口 |
||||||
|
* |
||||||
|
* @author qfzj |
||||||
|
*/ |
||||||
|
public interface GrowRecordService { |
||||||
|
|
||||||
|
/** |
||||||
|
* 创建种植历史 |
||||||
|
* |
||||||
|
* @param createReqVO 创建信息 |
||||||
|
* @return 编号 |
||||||
|
*/ |
||||||
|
Integer createGrowRecord(@Valid GrowRecordSaveReqVO createReqVO); |
||||||
|
|
||||||
|
/** |
||||||
|
* 更新种植历史 |
||||||
|
* |
||||||
|
* @param updateReqVO 更新信息 |
||||||
|
*/ |
||||||
|
void updateGrowRecord(@Valid GrowRecordSaveReqVO updateReqVO); |
||||||
|
|
||||||
|
/** |
||||||
|
* 删除种植历史 |
||||||
|
* |
||||||
|
* @param id 编号 |
||||||
|
*/ |
||||||
|
void deleteGrowRecord(Integer id); |
||||||
|
|
||||||
|
/** |
||||||
|
* 获得种植历史 |
||||||
|
* |
||||||
|
* @param id 编号 |
||||||
|
* @return 种植历史 |
||||||
|
*/ |
||||||
|
GrowRecordDO getGrowRecord(Integer id); |
||||||
|
|
||||||
|
/** |
||||||
|
* 获得种植历史分页 |
||||||
|
* |
||||||
|
* @param pageReqVO 分页查询 |
||||||
|
* @return 种植历史分页 |
||||||
|
*/ |
||||||
|
PageResult<GrowRecordDO> getGrowRecordPage(GrowRecordPageReqVO pageReqVO); |
||||||
|
|
||||||
|
} |
@ -0,0 +1,74 @@ |
|||||||
|
package com.cjy.traceability.module.traceability.service.growrecord; |
||||||
|
|
||||||
|
import org.springframework.stereotype.Service; |
||||||
|
import javax.annotation.Resource; |
||||||
|
import org.springframework.validation.annotation.Validated; |
||||||
|
import org.springframework.transaction.annotation.Transactional; |
||||||
|
|
||||||
|
import java.util.*; |
||||||
|
import com.cjy.traceability.module.traceability.controller.admin.growrecord.vo.*; |
||||||
|
import com.cjy.traceability.module.traceability.dal.dataobject.growrecord.GrowRecordDO; |
||||||
|
import com.cjy.traceability.framework.common.pojo.PageResult; |
||||||
|
import com.cjy.traceability.framework.common.pojo.PageParam; |
||||||
|
import com.cjy.traceability.framework.common.util.object.BeanUtils; |
||||||
|
|
||||||
|
import com.cjy.traceability.module.traceability.dal.mysql.growrecord.GrowRecordMapper; |
||||||
|
|
||||||
|
import static com.cjy.traceability.framework.common.exception.util.ServiceExceptionUtil.exception; |
||||||
|
import static com.cjy.traceability.module.traceability.enums.ErrorCodeConstants.*; |
||||||
|
|
||||||
|
/** |
||||||
|
* 种植历史 Service 实现类 |
||||||
|
* |
||||||
|
* @author qfzj |
||||||
|
*/ |
||||||
|
@Service |
||||||
|
@Validated |
||||||
|
public class GrowRecordServiceImpl implements GrowRecordService { |
||||||
|
|
||||||
|
@Resource |
||||||
|
private GrowRecordMapper growRecordMapper; |
||||||
|
|
||||||
|
@Override |
||||||
|
public Integer createGrowRecord(GrowRecordSaveReqVO createReqVO) { |
||||||
|
// 插入
|
||||||
|
GrowRecordDO growRecord = BeanUtils.toBean(createReqVO, GrowRecordDO.class); |
||||||
|
growRecordMapper.insert(growRecord); |
||||||
|
// 返回
|
||||||
|
return growRecord.getId(); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public void updateGrowRecord(GrowRecordSaveReqVO updateReqVO) { |
||||||
|
// 校验存在
|
||||||
|
validateGrowRecordExists(updateReqVO.getId()); |
||||||
|
// 更新
|
||||||
|
GrowRecordDO updateObj = BeanUtils.toBean(updateReqVO, GrowRecordDO.class); |
||||||
|
growRecordMapper.updateById(updateObj); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public void deleteGrowRecord(Integer id) { |
||||||
|
// 校验存在
|
||||||
|
validateGrowRecordExists(id); |
||||||
|
// 删除
|
||||||
|
growRecordMapper.deleteById(id); |
||||||
|
} |
||||||
|
|
||||||
|
private void validateGrowRecordExists(Integer id) { |
||||||
|
if (growRecordMapper.selectById(id) == null) { |
||||||
|
throw exception(GROW_RECORD_NOT_EXISTS); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public GrowRecordDO getGrowRecord(Integer id) { |
||||||
|
return growRecordMapper.selectById(id); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public PageResult<GrowRecordDO> getGrowRecordPage(GrowRecordPageReqVO pageReqVO) { |
||||||
|
return growRecordMapper.selectPage(pageReqVO); |
||||||
|
} |
||||||
|
|
||||||
|
} |
@ -0,0 +1,12 @@ |
|||||||
|
<?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.cjy.traceability.module.traceability.dal.mysql.growrecord.GrowRecordMapper"> |
||||||
|
|
||||||
|
<!-- |
||||||
|
一般情况下,尽可能使用 Mapper 进行 CRUD 增删改查即可。 |
||||||
|
无法满足的场景,例如说多表关联查询,才使用 XML 编写 SQL。 |
||||||
|
代码生成器暂时只生成 Mapper XML 文件本身,更多推荐 MybatisX 快速开发插件来生成查询。 |
||||||
|
文档可见:https://www.iocoder.cn/MyBatis/x-plugins/ |
||||||
|
--> |
||||||
|
|
||||||
|
</mapper> |
@ -1,182 +0,0 @@ |
|||||||
package com.cjy.traceability.module.traceability.service.processingworkshop; |
|
||||||
|
|
||||||
import org.junit.jupiter.api.Disabled; |
|
||||||
import org.junit.jupiter.api.Test; |
|
||||||
import org.springframework.boot.test.mock.mockito.MockBean; |
|
||||||
|
|
||||||
import javax.annotation.Resource; |
|
||||||
|
|
||||||
import com.cjy.traceability.framework.test.core.ut.BaseDbUnitTest; |
|
||||||
|
|
||||||
import com.cjy.traceability.module.traceability.controller.admin.processingworkshop.vo.*; |
|
||||||
import com.cjy.traceability.module.traceability.dal.dataobject.processingworkshop.ProcessingWorkshopDO; |
|
||||||
import com.cjy.traceability.module.traceability.dal.mysql.processingworkshop.ProcessingWorkshopMapper; |
|
||||||
import com.cjy.traceability.framework.common.pojo.PageResult; |
|
||||||
|
|
||||||
import javax.annotation.Resource; |
|
||||||
import org.springframework.context.annotation.Import; |
|
||||||
import java.util.*; |
|
||||||
import java.time.LocalDateTime; |
|
||||||
|
|
||||||
import static cn.hutool.core.util.RandomUtil.*; |
|
||||||
import static com.cjy.traceability.module.traceability.enums.ErrorCodeConstants.*; |
|
||||||
import static com.cjy.traceability.framework.test.core.util.AssertUtils.*; |
|
||||||
import static com.cjy.traceability.framework.test.core.util.RandomUtils.*; |
|
||||||
import static com.cjy.traceability.framework.common.util.date.LocalDateTimeUtils.*; |
|
||||||
import static com.cjy.traceability.framework.common.util.object.ObjectUtils.*; |
|
||||||
import static com.cjy.traceability.framework.common.util.date.DateUtils.*; |
|
||||||
import static org.junit.jupiter.api.Assertions.*; |
|
||||||
import static org.mockito.Mockito.*; |
|
||||||
|
|
||||||
/** |
|
||||||
* {@link ProcessingWorkshopServiceImpl} 的单元测试类 |
|
||||||
* |
|
||||||
* @author 芋道源码 |
|
||||||
*/ |
|
||||||
@Import(ProcessingWorkshopServiceImpl.class) |
|
||||||
public class ProcessingWorkshopServiceImplTest extends BaseDbUnitTest { |
|
||||||
|
|
||||||
@Resource |
|
||||||
private ProcessingWorkshopServiceImpl processingWorkshopService; |
|
||||||
|
|
||||||
@Resource |
|
||||||
private ProcessingWorkshopMapper processingWorkshopMapper; |
|
||||||
|
|
||||||
@Test |
|
||||||
public void testCreateProcessingWorkshop_success() { |
|
||||||
// 准备参数
|
|
||||||
ProcessingWorkshopSaveReqVO createReqVO = randomPojo(ProcessingWorkshopSaveReqVO.class).setId(null); |
|
||||||
|
|
||||||
// 调用
|
|
||||||
Long processingWorkshopId = processingWorkshopService.createProcessingWorkshop(createReqVO); |
|
||||||
// 断言
|
|
||||||
assertNotNull(processingWorkshopId); |
|
||||||
// 校验记录的属性是否正确
|
|
||||||
ProcessingWorkshopDO processingWorkshop = processingWorkshopMapper.selectById(processingWorkshopId); |
|
||||||
assertPojoEquals(createReqVO, processingWorkshop, "id"); |
|
||||||
} |
|
||||||
|
|
||||||
@Test |
|
||||||
public void testUpdateProcessingWorkshop_success() { |
|
||||||
// mock 数据
|
|
||||||
ProcessingWorkshopDO dbProcessingWorkshop = randomPojo(ProcessingWorkshopDO.class); |
|
||||||
processingWorkshopMapper.insert(dbProcessingWorkshop);// @Sql: 先插入出一条存在的数据
|
|
||||||
// 准备参数
|
|
||||||
ProcessingWorkshopSaveReqVO updateReqVO = randomPojo(ProcessingWorkshopSaveReqVO.class, o -> { |
|
||||||
o.setId(dbProcessingWorkshop.getId()); // 设置更新的 ID
|
|
||||||
}); |
|
||||||
|
|
||||||
// 调用
|
|
||||||
processingWorkshopService.updateProcessingWorkshop(updateReqVO); |
|
||||||
// 校验是否更新正确
|
|
||||||
ProcessingWorkshopDO processingWorkshop = processingWorkshopMapper.selectById(updateReqVO.getId()); // 获取最新的
|
|
||||||
assertPojoEquals(updateReqVO, processingWorkshop); |
|
||||||
} |
|
||||||
|
|
||||||
@Test |
|
||||||
public void testUpdateProcessingWorkshop_notExists() { |
|
||||||
// 准备参数
|
|
||||||
ProcessingWorkshopSaveReqVO updateReqVO = randomPojo(ProcessingWorkshopSaveReqVO.class); |
|
||||||
|
|
||||||
// 调用, 并断言异常
|
|
||||||
assertServiceException(() -> processingWorkshopService.updateProcessingWorkshop(updateReqVO), PROCESSING_WORKSHOP_NOT_EXISTS); |
|
||||||
} |
|
||||||
|
|
||||||
@Test |
|
||||||
public void testDeleteProcessingWorkshop_success() { |
|
||||||
// mock 数据
|
|
||||||
ProcessingWorkshopDO dbProcessingWorkshop = randomPojo(ProcessingWorkshopDO.class); |
|
||||||
processingWorkshopMapper.insert(dbProcessingWorkshop);// @Sql: 先插入出一条存在的数据
|
|
||||||
// 准备参数
|
|
||||||
Long id = dbProcessingWorkshop.getId(); |
|
||||||
|
|
||||||
// 调用
|
|
||||||
processingWorkshopService.deleteProcessingWorkshop(id); |
|
||||||
// 校验数据不存在了
|
|
||||||
assertNull(processingWorkshopMapper.selectById(id)); |
|
||||||
} |
|
||||||
|
|
||||||
@Test |
|
||||||
public void testDeleteProcessingWorkshop_notExists() { |
|
||||||
// 准备参数
|
|
||||||
Long id = randomLongId(); |
|
||||||
|
|
||||||
// 调用, 并断言异常
|
|
||||||
assertServiceException(() -> processingWorkshopService.deleteProcessingWorkshop(id), PROCESSING_WORKSHOP_NOT_EXISTS); |
|
||||||
} |
|
||||||
|
|
||||||
@Test |
|
||||||
@Disabled // TODO 请修改 null 为需要的值,然后删除 @Disabled 注解
|
|
||||||
public void testGetProcessingWorkshopPage() { |
|
||||||
// mock 数据
|
|
||||||
ProcessingWorkshopDO dbProcessingWorkshop = randomPojo(ProcessingWorkshopDO.class, o -> { // 等会查询到
|
|
||||||
o.setWorkshopName(null); |
|
||||||
o.setAreaProvince(null); |
|
||||||
o.setAreaCity(null); |
|
||||||
o.setAreaCounty(null); |
|
||||||
o.setAddress(null); |
|
||||||
o.setLon(null); |
|
||||||
o.setLat(null); |
|
||||||
o.setWorkshopArea(null); |
|
||||||
o.setPrincipal(null); |
|
||||||
o.setContactNumber(null); |
|
||||||
o.setState(null); |
|
||||||
o.setWorkshopImage(null); |
|
||||||
o.setDelFlag(null); |
|
||||||
o.setCreateTime(null); |
|
||||||
}); |
|
||||||
processingWorkshopMapper.insert(dbProcessingWorkshop); |
|
||||||
// 测试 workshopName 不匹配
|
|
||||||
processingWorkshopMapper.insert(cloneIgnoreId(dbProcessingWorkshop, o -> o.setWorkshopName(null))); |
|
||||||
// 测试 areaProvince 不匹配
|
|
||||||
processingWorkshopMapper.insert(cloneIgnoreId(dbProcessingWorkshop, o -> o.setAreaProvince(null))); |
|
||||||
// 测试 areaCity 不匹配
|
|
||||||
processingWorkshopMapper.insert(cloneIgnoreId(dbProcessingWorkshop, o -> o.setAreaCity(null))); |
|
||||||
// 测试 areaCounty 不匹配
|
|
||||||
processingWorkshopMapper.insert(cloneIgnoreId(dbProcessingWorkshop, o -> o.setAreaCounty(null))); |
|
||||||
// 测试 address 不匹配
|
|
||||||
processingWorkshopMapper.insert(cloneIgnoreId(dbProcessingWorkshop, o -> o.setAddress(null))); |
|
||||||
// 测试 lon 不匹配
|
|
||||||
processingWorkshopMapper.insert(cloneIgnoreId(dbProcessingWorkshop, o -> o.setLon(null))); |
|
||||||
// 测试 lat 不匹配
|
|
||||||
processingWorkshopMapper.insert(cloneIgnoreId(dbProcessingWorkshop, o -> o.setLat(null))); |
|
||||||
// 测试 workshopArea 不匹配
|
|
||||||
processingWorkshopMapper.insert(cloneIgnoreId(dbProcessingWorkshop, o -> o.setWorkshopArea(null))); |
|
||||||
// 测试 principal 不匹配
|
|
||||||
processingWorkshopMapper.insert(cloneIgnoreId(dbProcessingWorkshop, o -> o.setPrincipal(null))); |
|
||||||
// 测试 contactNumber 不匹配
|
|
||||||
processingWorkshopMapper.insert(cloneIgnoreId(dbProcessingWorkshop, o -> o.setContactNumber(null))); |
|
||||||
// 测试 state 不匹配
|
|
||||||
processingWorkshopMapper.insert(cloneIgnoreId(dbProcessingWorkshop, o -> o.setState(null))); |
|
||||||
// 测试 workshopImage 不匹配
|
|
||||||
processingWorkshopMapper.insert(cloneIgnoreId(dbProcessingWorkshop, o -> o.setWorkshopImage(null))); |
|
||||||
// 测试 delFlag 不匹配
|
|
||||||
processingWorkshopMapper.insert(cloneIgnoreId(dbProcessingWorkshop, o -> o.setDelFlag(null))); |
|
||||||
// 测试 createTime 不匹配
|
|
||||||
processingWorkshopMapper.insert(cloneIgnoreId(dbProcessingWorkshop, o -> o.setCreateTime(null))); |
|
||||||
// 准备参数
|
|
||||||
ProcessingWorkshopPageReqVO reqVO = new ProcessingWorkshopPageReqVO(); |
|
||||||
reqVO.setWorkshopName(null); |
|
||||||
reqVO.setAreaProvince(null); |
|
||||||
reqVO.setAreaCity(null); |
|
||||||
reqVO.setAreaCounty(null); |
|
||||||
reqVO.setAddress(null); |
|
||||||
reqVO.setLon(null); |
|
||||||
reqVO.setLat(null); |
|
||||||
reqVO.setWorkshopArea(null); |
|
||||||
reqVO.setPrincipal(null); |
|
||||||
reqVO.setContactNumber(null); |
|
||||||
reqVO.setState(null); |
|
||||||
reqVO.setWorkshopImage(null); |
|
||||||
reqVO.setDelFlag(null); |
|
||||||
reqVO.setCreateTime(buildBetweenTime(2023, 2, 1, 2023, 2, 28)); |
|
||||||
|
|
||||||
// 调用
|
|
||||||
PageResult<ProcessingWorkshopDO> pageResult = processingWorkshopService.getProcessingWorkshopPage(reqVO); |
|
||||||
// 断言
|
|
||||||
assertEquals(1, pageResult.getTotal()); |
|
||||||
assertEquals(1, pageResult.getList().size()); |
|
||||||
assertPojoEquals(dbProcessingWorkshop, pageResult.getList().get(0)); |
|
||||||
} |
|
||||||
|
|
||||||
} |
|
Loading…
Reference in new issue