修改营销模块, 增加平台利润表, 以及平台利润日志表

feifan-module-distri/feifan-module-distri-api/src/main/java/cn/newfeifan/mall/module/distri/enums/ErrorCodeConstants.java

@@ -16,5 +16,7 @@ public interface ErrorCodeConstants {
     ErrorCode DUSER_NOT_EXISTS = new ErrorCode(1_002_030_003, "分销用户不存在");
     ErrorCode IS_EXISTS = new ErrorCode(1_002_030_003, "当前推销人已经存在上级");
     ErrorCode PARTITION_CRASH_NOT_EXISTS = new ErrorCode(1_002_030_003, "碰撞分区不存在");
+    ErrorCode PT_PROFIT_NOT_EXISTS = new ErrorCode(1_002_030_003, "平台利润不存在");
+    ErrorCode PT_PROFIT_LOG_NOT_EXISTS = new ErrorCode(1_002_030_003, "平台利润日志表不存在");
 
 }

feifan-module-distri/feifan-module-distri-biz/src/main/java/cn/newfeifan/mall/module/distri/controller/admin/ptprofit/PtProfitController.java

@@ -0,0 +1,95 @@
+package cn.newfeifan.mall.module.distri.controller.admin.ptprofit;
+
+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 cn.newfeifan.mall.framework.common.pojo.PageParam;
+import cn.newfeifan.mall.framework.common.pojo.PageResult;
+import cn.newfeifan.mall.framework.common.pojo.CommonResult;
+import cn.newfeifan.mall.framework.common.util.object.BeanUtils;
+import static cn.newfeifan.mall.framework.common.pojo.CommonResult.success;
+
+import cn.newfeifan.mall.framework.excel.core.util.ExcelUtils;
+
+import cn.newfeifan.mall.framework.operatelog.core.annotations.OperateLog;
+import static cn.newfeifan.mall.framework.operatelog.core.enums.OperateTypeEnum.*;
+
+import cn.newfeifan.mall.module.distri.controller.admin.ptprofit.vo.*;
+import cn.newfeifan.mall.module.distri.dal.dataobject.ptprofit.PtProfitDO;
+import cn.newfeifan.mall.module.distri.service.ptprofit.PtProfitService;
+
+@Tag(name = "管理后台 - 平台利润")
+@RestController
+@RequestMapping("/distri/pt-profit")
+@Validated
+public class PtProfitController {
+
+    @Resource
+    private PtProfitService ptProfitService;
+
+    @PostMapping("/create")
+    @Operation(summary = "创建平台利润")
+    @PreAuthorize("@ss.hasPermission('distri:pt-profit:create')")
+    public CommonResult<Long> createPtProfit(@Valid @RequestBody PtProfitSaveReqVO createReqVO) {
+        return success(ptProfitService.createPtProfit(createReqVO));
+    }
+
+    @PutMapping("/update")
+    @Operation(summary = "更新平台利润")
+    @PreAuthorize("@ss.hasPermission('distri:pt-profit:update')")
+    public CommonResult<Boolean> updatePtProfit(@Valid @RequestBody PtProfitSaveReqVO updateReqVO) {
+        ptProfitService.updatePtProfit(updateReqVO);
+        return success(true);
+    }
+
+    @DeleteMapping("/delete")
+    @Operation(summary = "删除平台利润")
+    @Parameter(name = "id", description = "编号", required = true)
+    @PreAuthorize("@ss.hasPermission('distri:pt-profit:delete')")
+    public CommonResult<Boolean> deletePtProfit(@RequestParam("id") Long id) {
+        ptProfitService.deletePtProfit(id);
+        return success(true);
+    }
+
+    @GetMapping("/get")
+    @Operation(summary = "获得平台利润")
+    @Parameter(name = "id", description = "编号", required = true, example = "1024")
+    @PreAuthorize("@ss.hasPermission('distri:pt-profit:query')")
+    public CommonResult<PtProfitRespVO> getPtProfit(@RequestParam("id") Long id) {
+        PtProfitDO ptProfit = ptProfitService.getPtProfit(id);
+        return success(BeanUtils.toBean(ptProfit, PtProfitRespVO.class));
+    }
+
+    @GetMapping("/page")
+    @Operation(summary = "获得平台利润分页")
+    @PreAuthorize("@ss.hasPermission('distri:pt-profit:query')")
+    public CommonResult<PageResult<PtProfitRespVO>> getPtProfitPage(@Valid PtProfitPageReqVO pageReqVO) {
+        PageResult<PtProfitDO> pageResult = ptProfitService.getPtProfitPage(pageReqVO);
+        return success(BeanUtils.toBean(pageResult, PtProfitRespVO.class));
+    }
+
+    @GetMapping("/export-excel")
+    @Operation(summary = "导出平台利润 Excel")
+    @PreAuthorize("@ss.hasPermission('distri:pt-profit:export')")
+    @OperateLog(type = EXPORT)
+    public void exportPtProfitExcel(@Valid PtProfitPageReqVO pageReqVO,
+              HttpServletResponse response) throws IOException {
+        pageReqVO.setPageSize(PageParam.PAGE_SIZE_NONE);
+        List<PtProfitDO> list = ptProfitService.getPtProfitPage(pageReqVO).getList();
+        // 导出 Excel
+        ExcelUtils.write(response, "平台利润.xls", "数据", PtProfitRespVO.class,
+                        BeanUtils.toBean(list, PtProfitRespVO.class));
+    }
+
+}

feifan-module-distri/feifan-module-distri-biz/src/main/java/cn/newfeifan/mall/module/distri/controller/admin/ptprofit/vo/PtProfitPageReqVO.java

@@ -0,0 +1,31 @@
+package cn.newfeifan.mall.module.distri.controller.admin.ptprofit.vo;
+
+import lombok.*;
+import java.util.*;
+import io.swagger.v3.oas.annotations.media.Schema;
+import cn.newfeifan.mall.framework.common.pojo.PageParam;
+import org.springframework.format.annotation.DateTimeFormat;
+import java.time.LocalDateTime;
+
+import static cn.newfeifan.mall.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 PtProfitPageReqVO extends PageParam {
+
+    @Schema(description = "平台服务费(毛利下的百分比收益)")
+    private Integer ptAdd;
+
+    @Schema(description = "平台收益(0.3888 之外的收益)")
+    private Integer ptGrossAdd;
+
+    @Schema(description = "平台总收益")
+    private Integer ptTotalAdd;
+
+    @Schema(description = "创建时间")
+    @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
+    private LocalDateTime[] createTime;
+
+}

feifan-module-distri/feifan-module-distri-biz/src/main/java/cn/newfeifan/mall/module/distri/controller/admin/ptprofit/vo/PtProfitRespVO.java

@@ -0,0 +1,36 @@
+package cn.newfeifan.mall.module.distri.controller.admin.ptprofit.vo;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.*;
+import java.util.*;
+import java.util.*;
+import org.springframework.format.annotation.DateTimeFormat;
+import java.time.LocalDateTime;
+import com.alibaba.excel.annotation.*;
+
+@Schema(description = "管理后台 - 平台利润 Response VO")
+@Data
+@ExcelIgnoreUnannotated
+public class PtProfitRespVO {
+
+    @Schema(description = "用户编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "24754")
+    @ExcelProperty("用户编号")
+    private Long id;
+
+    @Schema(description = "平台服务费(毛利下的百分比收益)")
+    @ExcelProperty("平台服务费(毛利下的百分比收益)")
+    private Integer ptAdd;
+
+    @Schema(description = "平台收益(0.3888 之外的收益)")
+    @ExcelProperty("平台收益(0.3888 之外的收益)")
+    private Integer ptGrossAdd;
+
+    @Schema(description = "平台总收益")
+    @ExcelProperty("平台总收益")
+    private Integer ptTotalAdd;
+
+    @Schema(description = "创建时间", requiredMode = Schema.RequiredMode.REQUIRED)
+    @ExcelProperty("创建时间")
+    private LocalDateTime createTime;
+
+}

feifan-module-distri/feifan-module-distri-biz/src/main/java/cn/newfeifan/mall/module/distri/controller/admin/ptprofit/vo/PtProfitSaveReqVO.java

@@ -0,0 +1,24 @@
+package cn.newfeifan.mall.module.distri.controller.admin.ptprofit.vo;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.*;
+import java.util.*;
+import javax.validation.constraints.*;
+
+@Schema(description = "管理后台 - 平台利润新增/修改 Request VO")
+@Data
+public class PtProfitSaveReqVO {
+
+    @Schema(description = "用户编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "24754")
+    private Long id;
+
+    @Schema(description = "平台服务费(毛利下的百分比收益)")
+    private Integer ptAdd;
+
+    @Schema(description = "平台收益(0.3888 之外的收益)")
+    private Integer ptGrossAdd;
+
+    @Schema(description = "平台总收益")
+    private Integer ptTotalAdd;
+
+}

feifan-module-distri/feifan-module-distri-biz/src/main/java/cn/newfeifan/mall/module/distri/controller/admin/ptprofitlog/PtProfitLogController.java

@@ -0,0 +1,95 @@
+package cn.newfeifan.mall.module.distri.controller.admin.ptprofitlog;
+
+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 cn.newfeifan.mall.framework.common.pojo.PageParam;
+import cn.newfeifan.mall.framework.common.pojo.PageResult;
+import cn.newfeifan.mall.framework.common.pojo.CommonResult;
+import cn.newfeifan.mall.framework.common.util.object.BeanUtils;
+import static cn.newfeifan.mall.framework.common.pojo.CommonResult.success;
+
+import cn.newfeifan.mall.framework.excel.core.util.ExcelUtils;
+
+import cn.newfeifan.mall.framework.operatelog.core.annotations.OperateLog;
+import static cn.newfeifan.mall.framework.operatelog.core.enums.OperateTypeEnum.*;
+
+import cn.newfeifan.mall.module.distri.controller.admin.ptprofitlog.vo.*;
+import cn.newfeifan.mall.module.distri.dal.dataobject.ptprofitlog.PtProfitLogDO;
+import cn.newfeifan.mall.module.distri.service.ptprofitlog.PtProfitLogService;
+
+@Tag(name = "管理后台 - 平台利润记录")
+@RestController
+@RequestMapping("/distri/pt-profit-log")
+@Validated
+public class PtProfitLogController {
+
+    @Resource
+    private PtProfitLogService ptProfitLogService;
+
+    @PostMapping("/create")
+    @Operation(summary = "创建平台利润记录")
+    @PreAuthorize("@ss.hasPermission('distri:pt-profit-log:create')")
+    public CommonResult<Long> createPtProfitLog(@Valid @RequestBody PtProfitLogSaveReqVO createReqVO) {
+        return success(ptProfitLogService.createPtProfitLog(createReqVO));
+    }
+
+    @PutMapping("/update")
+    @Operation(summary = "更新平台利润记录")
+    @PreAuthorize("@ss.hasPermission('distri:pt-profit-log:update')")
+    public CommonResult<Boolean> updatePtProfitLog(@Valid @RequestBody PtProfitLogSaveReqVO updateReqVO) {
+        ptProfitLogService.updatePtProfitLog(updateReqVO);
+        return success(true);
+    }
+
+    @DeleteMapping("/delete")
+    @Operation(summary = "删除平台利润记录")
+    @Parameter(name = "id", description = "编号", required = true)
+    @PreAuthorize("@ss.hasPermission('distri:pt-profit-log:delete')")
+    public CommonResult<Boolean> deletePtProfitLog(@RequestParam("id") Long id) {
+        ptProfitLogService.deletePtProfitLog(id);
+        return success(true);
+    }
+
+    @GetMapping("/get")
+    @Operation(summary = "获得平台利润记录")
+    @Parameter(name = "id", description = "编号", required = true, example = "1024")
+    @PreAuthorize("@ss.hasPermission('distri:pt-profit-log:query')")
+    public CommonResult<PtProfitLogRespVO> getPtProfitLog(@RequestParam("id") Long id) {
+        PtProfitLogDO ptProfitLog = ptProfitLogService.getPtProfitLog(id);
+        return success(BeanUtils.toBean(ptProfitLog, PtProfitLogRespVO.class));
+    }
+
+    @GetMapping("/page")
+    @Operation(summary = "获得平台利润记录分页")
+    @PreAuthorize("@ss.hasPermission('distri:pt-profit-log:query')")
+    public CommonResult<PageResult<PtProfitLogRespVO>> getPtProfitLogPage(@Valid PtProfitLogPageReqVO pageReqVO) {
+        PageResult<PtProfitLogDO> pageResult = ptProfitLogService.getPtProfitLogPage(pageReqVO);
+        return success(BeanUtils.toBean(pageResult, PtProfitLogRespVO.class));
+    }
+
+    @GetMapping("/export-excel")
+    @Operation(summary = "导出平台利润记录 Excel")
+    @PreAuthorize("@ss.hasPermission('distri:pt-profit-log:export')")
+    @OperateLog(type = EXPORT)
+    public void exportPtProfitLogExcel(@Valid PtProfitLogPageReqVO pageReqVO,
+              HttpServletResponse response) throws IOException {
+        pageReqVO.setPageSize(PageParam.PAGE_SIZE_NONE);
+        List<PtProfitLogDO> list = ptProfitLogService.getPtProfitLogPage(pageReqVO).getList();
+        // 导出 Excel
+        ExcelUtils.write(response, "平台利润记录.xls", "数据", PtProfitLogRespVO.class,
+                        BeanUtils.toBean(list, PtProfitLogRespVO.class));
+    }
+
+}

feifan-module-distri/feifan-module-distri-biz/src/main/java/cn/newfeifan/mall/module/distri/controller/admin/ptprofitlog/vo/PtProfitLogPageReqVO.java

@@ -0,0 +1,37 @@
+package cn.newfeifan.mall.module.distri.controller.admin.ptprofitlog.vo;
+
+import lombok.*;
+import java.util.*;
+import io.swagger.v3.oas.annotations.media.Schema;
+import cn.newfeifan.mall.framework.common.pojo.PageParam;
+import org.springframework.format.annotation.DateTimeFormat;
+import java.time.LocalDateTime;
+
+import static cn.newfeifan.mall.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 PtProfitLogPageReqVO extends PageParam {
+
+    @Schema(description = "增加金额")
+    private Integer amount;
+
+    @Schema(description = "增加后金额")
+    private Integer afterAmount;
+
+    @Schema(description = "收益类型 1:平台服务器费 2:平台收益", example = "2")
+    private Integer profitStatus;
+
+    @Schema(description = "订单号", example = "15682")
+    private Long orderId;
+
+    @Schema(description = "计算百分比模板")
+    private String percentTemplate;
+
+    @Schema(description = "创建时间")
+    @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
+    private LocalDateTime[] createTime;
+
+}

feifan-module-distri/feifan-module-distri-biz/src/main/java/cn/newfeifan/mall/module/distri/controller/admin/ptprofitlog/vo/PtProfitLogRespVO.java

@@ -0,0 +1,44 @@
+package cn.newfeifan.mall.module.distri.controller.admin.ptprofitlog.vo;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.*;
+import java.util.*;
+import java.util.*;
+import org.springframework.format.annotation.DateTimeFormat;
+import java.time.LocalDateTime;
+import com.alibaba.excel.annotation.*;
+
+@Schema(description = "管理后台 - 平台利润记录 Response VO")
+@Data
+@ExcelIgnoreUnannotated
+public class PtProfitLogRespVO {
+
+    @Schema(description = "用户编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "12046")
+    @ExcelProperty("用户编号")
+    private Long id;
+
+    @Schema(description = "增加金额")
+    @ExcelProperty("增加金额")
+    private Integer amount;
+
+    @Schema(description = "增加后金额")
+    @ExcelProperty("增加后金额")
+    private Integer afterAmount;
+
+    @Schema(description = "收益类型 1:平台服务器费 2:平台收益", example = "2")
+    @ExcelProperty("收益类型 1:平台服务器费 2:平台收益")
+    private Integer profitStatus;
+
+    @Schema(description = "订单号", example = "15682")
+    @ExcelProperty("订单号")
+    private Long orderId;
+
+    @Schema(description = "计算百分比模板")
+    @ExcelProperty("计算百分比模板")
+    private String percentTemplate;
+
+    @Schema(description = "创建时间", requiredMode = Schema.RequiredMode.REQUIRED)
+    @ExcelProperty("创建时间")
+    private LocalDateTime createTime;
+
+}

feifan-module-distri/feifan-module-distri-biz/src/main/java/cn/newfeifan/mall/module/distri/controller/admin/ptprofitlog/vo/PtProfitLogSaveReqVO.java

@@ -0,0 +1,30 @@
+package cn.newfeifan.mall.module.distri.controller.admin.ptprofitlog.vo;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.*;
+import java.util.*;
+import javax.validation.constraints.*;
+
+@Schema(description = "管理后台 - 平台利润记录新增/修改 Request VO")
+@Data
+public class PtProfitLogSaveReqVO {
+
+    @Schema(description = "用户编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "12046")
+    private Long id;
+
+    @Schema(description = "增加金额")
+    private Integer amount;
+
+    @Schema(description = "增加后金额")
+    private Integer afterAmount;
+
+    @Schema(description = "收益类型 1:平台服务器费 2:平台收益", example = "2")
+    private Integer profitStatus;
+
+    @Schema(description = "订单号", example = "15682")
+    private Long orderId;
+
+    @Schema(description = "计算百分比模板")
+    private String percentTemplate;
+
+}

feifan-module-distri/feifan-module-distri-biz/src/main/java/cn/newfeifan/mall/module/distri/dal/dataobject/ptprofit/PtProfitDO.java

@@ -0,0 +1,43 @@
+package cn.newfeifan.mall.module.distri.dal.dataobject.ptprofit;
+
+import lombok.*;
+import java.util.*;
+import java.time.LocalDateTime;
+import java.time.LocalDateTime;
+import com.baomidou.mybatisplus.annotation.*;
+import cn.newfeifan.mall.framework.mybatis.core.dataobject.BaseDO;
+
+/**
+ * 平台利润 DO
+ *
+ * @author 非繁人
+ */
+@TableName("distri_pt_profit")
+@KeySequence("distri_pt_profit_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库，可不写。
+@Data
+@EqualsAndHashCode(callSuper = true)
+@ToString(callSuper = true)
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class PtProfitDO extends BaseDO {
+
+    /**
+     * 用户编号
+     */
+    @TableId
+    private Long id;
+    /**
+     * 平台服务费(毛利下的百分比收益)
+     */
+    private Integer ptAdd;
+    /**
+     * 平台收益(0.3888 之外的收益)
+     */
+    private Integer ptGrossAdd;
+    /**
+     * 平台总收益
+     */
+    private Integer ptTotalAdd;
+
+}

feifan-module-distri/feifan-module-distri-biz/src/main/java/cn/newfeifan/mall/module/distri/dal/dataobject/ptprofitlog/PtProfitLogDO.java

@@ -0,0 +1,51 @@
+package cn.newfeifan.mall.module.distri.dal.dataobject.ptprofitlog;
+
+import lombok.*;
+import java.util.*;
+import java.time.LocalDateTime;
+import java.time.LocalDateTime;
+import com.baomidou.mybatisplus.annotation.*;
+import cn.newfeifan.mall.framework.mybatis.core.dataobject.BaseDO;
+
+/**
+ * 平台利润记录 DO
+ *
+ * @author 非繁人
+ */
+@TableName("distri_pt_profit_log")
+@KeySequence("distri_pt_profit_log_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库，可不写。
+@Data
+@EqualsAndHashCode(callSuper = true)
+@ToString(callSuper = true)
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class PtProfitLogDO extends BaseDO {
+
+    /**
+     * 用户编号
+     */
+    @TableId
+    private Long id;
+    /**
+     * 增加金额
+     */
+    private Integer amount;
+    /**
+     * 增加后金额
+     */
+    private Integer afterAmount;
+    /**
+     * 收益类型 1:平台服务器费 2:平台收益
+     */
+    private Integer profitStatus;
+    /**
+     * 订单号
+     */
+    private Long orderId;
+    /**
+     * 计算百分比模板
+     */
+    private String percentTemplate;
+
+}

feifan-module-distri/feifan-module-distri-biz/src/main/java/cn/newfeifan/mall/module/distri/dal/mysql/ptprofit/PtProfitMapper.java

@@ -0,0 +1,29 @@
+package cn.newfeifan.mall.module.distri.dal.mysql.ptprofit;
+
+import java.util.*;
+
+import cn.newfeifan.mall.framework.common.pojo.PageResult;
+import cn.newfeifan.mall.framework.mybatis.core.query.LambdaQueryWrapperX;
+import cn.newfeifan.mall.framework.mybatis.core.mapper.BaseMapperX;
+import cn.newfeifan.mall.module.distri.dal.dataobject.ptprofit.PtProfitDO;
+import org.apache.ibatis.annotations.Mapper;
+import cn.newfeifan.mall.module.distri.controller.admin.ptprofit.vo.*;
+
+/**
+ * 平台利润 Mapper
+ *
+ * @author 非繁人
+ */
+@Mapper
+public interface PtProfitMapper extends BaseMapperX<PtProfitDO> {
+
+    default PageResult<PtProfitDO> selectPage(PtProfitPageReqVO reqVO) {
+        return selectPage(reqVO, new LambdaQueryWrapperX<PtProfitDO>()
+                .eqIfPresent(PtProfitDO::getPtAdd, reqVO.getPtAdd())
+                .eqIfPresent(PtProfitDO::getPtGrossAdd, reqVO.getPtGrossAdd())
+                .eqIfPresent(PtProfitDO::getPtTotalAdd, reqVO.getPtTotalAdd())
+                .betweenIfPresent(PtProfitDO::getCreateTime, reqVO.getCreateTime())
+                .orderByDesc(PtProfitDO::getId));
+    }
+
+}

feifan-module-distri/feifan-module-distri-biz/src/main/java/cn/newfeifan/mall/module/distri/dal/mysql/ptprofitlog/PtProfitLogMapper.java

@@ -0,0 +1,31 @@
+package cn.newfeifan.mall.module.distri.dal.mysql.ptprofitlog;
+
+import java.util.*;
+
+import cn.newfeifan.mall.framework.common.pojo.PageResult;
+import cn.newfeifan.mall.framework.mybatis.core.query.LambdaQueryWrapperX;
+import cn.newfeifan.mall.framework.mybatis.core.mapper.BaseMapperX;
+import cn.newfeifan.mall.module.distri.dal.dataobject.ptprofitlog.PtProfitLogDO;
+import org.apache.ibatis.annotations.Mapper;
+import cn.newfeifan.mall.module.distri.controller.admin.ptprofitlog.vo.*;
+
+/**
+ * 平台利润记录 Mapper
+ *
+ * @author 非繁人
+ */
+@Mapper
+public interface PtProfitLogMapper extends BaseMapperX<PtProfitLogDO> {
+
+    default PageResult<PtProfitLogDO> selectPage(PtProfitLogPageReqVO reqVO) {
+        return selectPage(reqVO, new LambdaQueryWrapperX<PtProfitLogDO>()
+                .eqIfPresent(PtProfitLogDO::getAmount, reqVO.getAmount())
+                .eqIfPresent(PtProfitLogDO::getAfterAmount, reqVO.getAfterAmount())
+                .eqIfPresent(PtProfitLogDO::getProfitStatus, reqVO.getProfitStatus())
+                .eqIfPresent(PtProfitLogDO::getOrderId, reqVO.getOrderId())
+                .eqIfPresent(PtProfitLogDO::getPercentTemplate, reqVO.getPercentTemplate())
+                .betweenIfPresent(PtProfitLogDO::getCreateTime, reqVO.getCreateTime())
+                .orderByDesc(PtProfitLogDO::getId));
+    }
+
+}

feifan-module-distri/feifan-module-distri-biz/src/main/java/cn/newfeifan/mall/module/distri/service/ptprofit/PtProfitService.java

@@ -0,0 +1,55 @@
+package cn.newfeifan.mall.module.distri.service.ptprofit;
+
+import java.util.*;
+import javax.validation.*;
+import cn.newfeifan.mall.module.distri.controller.admin.ptprofit.vo.*;
+import cn.newfeifan.mall.module.distri.dal.dataobject.ptprofit.PtProfitDO;
+import cn.newfeifan.mall.framework.common.pojo.PageResult;
+import cn.newfeifan.mall.framework.common.pojo.PageParam;
+
+/**
+ * 平台利润 Service 接口
+ *
+ * @author 非繁人
+ */
+public interface PtProfitService {
+
+    /**
+     * 创建平台利润
+     *
+     * @param createReqVO 创建信息
+     * @return 编号
+     */
+    Long createPtProfit(@Valid PtProfitSaveReqVO createReqVO);
+
+    /**
+     * 更新平台利润
+     *
+     * @param updateReqVO 更新信息
+     */
+    void updatePtProfit(@Valid PtProfitSaveReqVO updateReqVO);
+
+    /**
+     * 删除平台利润
+     *
+     * @param id 编号
+     */
+    void deletePtProfit(Long id);
+
+    /**
+     * 获得平台利润
+     *
+     * @param id 编号
+     * @return 平台利润
+     */
+    PtProfitDO getPtProfit(Long id);
+
+    /**
+     * 获得平台利润分页
+     *
+     * @param pageReqVO 分页查询
+     * @return 平台利润分页
+     */
+    PageResult<PtProfitDO> getPtProfitPage(PtProfitPageReqVO pageReqVO);
+
+}

feifan-module-distri/feifan-module-distri-biz/src/main/java/cn/newfeifan/mall/module/distri/service/ptprofit/PtProfitServiceImpl.java

@@ -0,0 +1,74 @@
+package cn.newfeifan.mall.module.distri.service.ptprofit;
+
+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 cn.newfeifan.mall.module.distri.controller.admin.ptprofit.vo.*;
+import cn.newfeifan.mall.module.distri.dal.dataobject.ptprofit.PtProfitDO;
+import cn.newfeifan.mall.framework.common.pojo.PageResult;
+import cn.newfeifan.mall.framework.common.pojo.PageParam;
+import cn.newfeifan.mall.framework.common.util.object.BeanUtils;
+
+import cn.newfeifan.mall.module.distri.dal.mysql.ptprofit.PtProfitMapper;
+
+import static cn.newfeifan.mall.framework.common.exception.util.ServiceExceptionUtil.exception;
+import static cn.newfeifan.mall.module.distri.enums.ErrorCodeConstants.*;
+
+/**
+ * 平台利润 Service 实现类
+ *
+ * @author 非繁人
+ */
+@Service
+@Validated
+public class PtProfitServiceImpl implements PtProfitService {
+
+    @Resource
+    private PtProfitMapper ptProfitMapper;
+
+    @Override
+    public Long createPtProfit(PtProfitSaveReqVO createReqVO) {
+        // 插入
+        PtProfitDO ptProfit = BeanUtils.toBean(createReqVO, PtProfitDO.class);
+        ptProfitMapper.insert(ptProfit);
+        // 返回
+        return ptProfit.getId();
+    }
+
+    @Override
+    public void updatePtProfit(PtProfitSaveReqVO updateReqVO) {
+        // 校验存在
+        validatePtProfitExists(updateReqVO.getId());
+        // 更新
+        PtProfitDO updateObj = BeanUtils.toBean(updateReqVO, PtProfitDO.class);
+        ptProfitMapper.updateById(updateObj);
+    }
+
+    @Override
+    public void deletePtProfit(Long id) {
+        // 校验存在
+        validatePtProfitExists(id);
+        // 删除
+        ptProfitMapper.deleteById(id);
+    }
+
+    private void validatePtProfitExists(Long id) {
+        if (ptProfitMapper.selectById(id) == null) {
+            throw exception(PT_PROFIT_NOT_EXISTS);
+        }
+    }
+
+    @Override
+    public PtProfitDO getPtProfit(Long id) {
+        return ptProfitMapper.selectById(id);
+    }
+
+    @Override
+    public PageResult<PtProfitDO> getPtProfitPage(PtProfitPageReqVO pageReqVO) {
+        return ptProfitMapper.selectPage(pageReqVO);
+    }
+
+}

feifan-module-distri/feifan-module-distri-biz/src/main/java/cn/newfeifan/mall/module/distri/service/ptprofitlog/PtProfitLogService.java

@@ -0,0 +1,55 @@
+package cn.newfeifan.mall.module.distri.service.ptprofitlog;
+
+import java.util.*;
+import javax.validation.*;
+import cn.newfeifan.mall.module.distri.controller.admin.ptprofitlog.vo.*;
+import cn.newfeifan.mall.module.distri.dal.dataobject.ptprofitlog.PtProfitLogDO;
+import cn.newfeifan.mall.framework.common.pojo.PageResult;
+import cn.newfeifan.mall.framework.common.pojo.PageParam;
+
+/**
+ * 平台利润记录 Service 接口
+ *
+ * @author 非繁人
+ */
+public interface PtProfitLogService {
+
+    /**
+     * 创建平台利润记录
+     *
+     * @param createReqVO 创建信息
+     * @return 编号
+     */
+    Long createPtProfitLog(@Valid PtProfitLogSaveReqVO createReqVO);
+
+    /**
+     * 更新平台利润记录
+     *
+     * @param updateReqVO 更新信息
+     */
+    void updatePtProfitLog(@Valid PtProfitLogSaveReqVO updateReqVO);
+
+    /**
+     * 删除平台利润记录
+     *
+     * @param id 编号
+     */
+    void deletePtProfitLog(Long id);
+
+    /**
+     * 获得平台利润记录
+     *
+     * @param id 编号
+     * @return 平台利润记录
+     */
+    PtProfitLogDO getPtProfitLog(Long id);
+
+    /**
+     * 获得平台利润记录分页
+     *
+     * @param pageReqVO 分页查询
+     * @return 平台利润记录分页
+     */
+    PageResult<PtProfitLogDO> getPtProfitLogPage(PtProfitLogPageReqVO pageReqVO);
+
+}

feifan-module-distri/feifan-module-distri-biz/src/main/java/cn/newfeifan/mall/module/distri/service/ptprofitlog/PtProfitLogServiceImpl.java

@@ -0,0 +1,74 @@
+package cn.newfeifan.mall.module.distri.service.ptprofitlog;
+
+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 cn.newfeifan.mall.module.distri.controller.admin.ptprofitlog.vo.*;
+import cn.newfeifan.mall.module.distri.dal.dataobject.ptprofitlog.PtProfitLogDO;
+import cn.newfeifan.mall.framework.common.pojo.PageResult;
+import cn.newfeifan.mall.framework.common.pojo.PageParam;
+import cn.newfeifan.mall.framework.common.util.object.BeanUtils;
+
+import cn.newfeifan.mall.module.distri.dal.mysql.ptprofitlog.PtProfitLogMapper;
+
+import static cn.newfeifan.mall.framework.common.exception.util.ServiceExceptionUtil.exception;
+import static cn.newfeifan.mall.module.distri.enums.ErrorCodeConstants.*;
+
+/**
+ * 平台利润记录 Service 实现类
+ *
+ * @author 非繁人
+ */
+@Service
+@Validated
+public class PtProfitLogServiceImpl implements PtProfitLogService {
+
+    @Resource
+    private PtProfitLogMapper ptProfitLogMapper;
+
+    @Override
+    public Long createPtProfitLog(PtProfitLogSaveReqVO createReqVO) {
+        // 插入
+        PtProfitLogDO ptProfitLog = BeanUtils.toBean(createReqVO, PtProfitLogDO.class);
+        ptProfitLogMapper.insert(ptProfitLog);
+        // 返回
+        return ptProfitLog.getId();
+    }
+
+    @Override
+    public void updatePtProfitLog(PtProfitLogSaveReqVO updateReqVO) {
+        // 校验存在
+        validatePtProfitLogExists(updateReqVO.getId());
+        // 更新
+        PtProfitLogDO updateObj = BeanUtils.toBean(updateReqVO, PtProfitLogDO.class);
+        ptProfitLogMapper.updateById(updateObj);
+    }
+
+    @Override
+    public void deletePtProfitLog(Long id) {
+        // 校验存在
+        validatePtProfitLogExists(id);
+        // 删除
+        ptProfitLogMapper.deleteById(id);
+    }
+
+    private void validatePtProfitLogExists(Long id) {
+        if (ptProfitLogMapper.selectById(id) == null) {
+            throw exception(PT_PROFIT_LOG_NOT_EXISTS);
+        }
+    }
+
+    @Override
+    public PtProfitLogDO getPtProfitLog(Long id) {
+        return ptProfitLogMapper.selectById(id);
+    }
+
+    @Override
+    public PageResult<PtProfitLogDO> getPtProfitLogPage(PtProfitLogPageReqVO pageReqVO) {
+        return ptProfitLogMapper.selectPage(pageReqVO);
+    }
+
+}

feifan-module-distri/feifan-module-distri-biz/src/main/resources/mapper/ptprofit/PtProfitMapper.xml

@@ -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="cn.newfeifan.mall.module.distri.dal.mysql.ptprofit.PtProfitMapper">
+
+    <!--
+        一般情况下，尽可能使用 Mapper 进行 CRUD 增删改查即可。
+        无法满足的场景，例如说多表关联查询，才使用 XML 编写 SQL。
+        代码生成器暂时只生成 Mapper XML 文件本身，更多推荐 MybatisX 快速开发插件来生成查询。
+        文档可见：https://www.zhongxing.cn/MyBatis/x-plugins/
+     -->
+
+</mapper>

feifan-module-distri/feifan-module-distri-biz/src/main/resources/mapper/ptprofitlog/PtProfitLogMapper.xml

@@ -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="cn.newfeifan.mall.module.distri.dal.mysql.ptprofitlog.PtProfitLogMapper">
+
+    <!--
+        一般情况下，尽可能使用 Mapper 进行 CRUD 增删改查即可。
+        无法满足的场景，例如说多表关联查询，才使用 XML 编写 SQL。
+        代码生成器暂时只生成 Mapper XML 文件本身，更多推荐 MybatisX 快速开发插件来生成查询。
+        文档可见：https://www.zhongxing.cn/MyBatis/x-plugins/
+     -->
+
+</mapper>

feifan-module-distri/feifan-module-distri-biz/src/test/java/cn/newfeifan/mall/module/distri/service/duser/DuserServiceImplTest.java

@@ -1,162 +0,0 @@
-package cn.newfeifan.mall.module.distri.service.duser;
-
-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 cn.newfeifan.mall.framework.test.core.ut.BaseDbUnitTest;
-
-import cn.newfeifan.mall.module.distri.controller.admin.duser.vo.*;
-import cn.newfeifan.mall.module.distri.dal.dataobject.duser.DuserDO;
-import cn.newfeifan.mall.module.distri.dal.mysql.duser.DuserMapper;
-import cn.newfeifan.mall.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 cn.newfeifan.mall.module.distri.enums.ErrorCodeConstants.*;
-import static cn.newfeifan.mall.framework.test.core.util.AssertUtils.*;
-import static cn.newfeifan.mall.framework.test.core.util.RandomUtils.*;
-import static cn.newfeifan.mall.framework.common.util.date.LocalDateTimeUtils.*;
-import static cn.newfeifan.mall.framework.common.util.object.ObjectUtils.*;
-import static cn.newfeifan.mall.framework.common.util.date.DateUtils.*;
-import static org.junit.jupiter.api.Assertions.*;
-import static org.mockito.Mockito.*;
-
-/**
- * {@link DuserServiceImpl} 的单元测试类
- *
- * @author 非繁人
- */
-@Import(DuserServiceImpl.class)
-public class DuserServiceImplTest extends BaseDbUnitTest {
-
-    @Resource
-    private DuserServiceImpl duserService;
-
-    @Resource
-    private DuserMapper duserMapper;
-
-    @Test
-    public void testCreateDuser_success() {
-        // 准备参数
-        DuserSaveReqVO createReqVO = randomPojo(DuserSaveReqVO.class).setId(null);
-
-        // 调用
-        Long duserId = duserService.createDuser(createReqVO);
-        // 断言
-        assertNotNull(duserId);
-        // 校验记录的属性是否正确
-        DuserDO duser = duserMapper.selectById(duserId);
-        assertPojoEquals(createReqVO, duser, "id");
-    }
-
-    @Test
-    public void testUpdateDuser_success() {
-        // mock 数据
-        DuserDO dbDuser = randomPojo(DuserDO.class);
-        duserMapper.insert(dbDuser);// @Sql: 先插入出一条存在的数据
-        // 准备参数
-        DuserSaveReqVO updateReqVO = randomPojo(DuserSaveReqVO.class, o -> {
-            o.setId(dbDuser.getId()); // 设置更新的 ID
-        });
-
-        // 调用
-        duserService.updateDuser(updateReqVO);
-        // 校验是否更新正确
-        DuserDO duser = duserMapper.selectById(updateReqVO.getId()); // 获取最新的
-        assertPojoEquals(updateReqVO, duser);
-    }
-
-    @Test
-    public void testUpdateDuser_notExists() {
-        // 准备参数
-        DuserSaveReqVO updateReqVO = randomPojo(DuserSaveReqVO.class);
-
-        // 调用, 并断言异常
-        assertServiceException(() -> duserService.updateDuser(updateReqVO), DUSER_NOT_EXISTS);
-    }
-
-    @Test
-    public void testDeleteDuser_success() {
-        // mock 数据
-        DuserDO dbDuser = randomPojo(DuserDO.class);
-        duserMapper.insert(dbDuser);// @Sql: 先插入出一条存在的数据
-        // 准备参数
-        Long id = dbDuser.getId();
-
-        // 调用
-        duserService.deleteDuser(id);
-       // 校验数据不存在了
-       assertNull(duserMapper.selectById(id));
-    }
-
-    @Test
-    public void testDeleteDuser_notExists() {
-        // 准备参数
-        Long id = randomLongId();
-
-        // 调用, 并断言异常
-        assertServiceException(() -> duserService.deleteDuser(id), DUSER_NOT_EXISTS);
-    }
-
-    @Test
-    @Disabled  // TODO 请修改 null 为需要的值，然后删除 @Disabled 注解
-    public void testGetDuserPage() {
-       // mock 数据
-       DuserDO dbDuser = randomPojo(DuserDO.class, o -> { // 等会查询到
-           o.setUserId(null);
-           o.setName(null);
-           o.setMobile(null);
-           o.setSource(null);
-           o.setIntegralId(null);
-           o.setSocialStatus(null);
-           o.setSocialStatusPoint(null);
-           o.setCategoryId(null);
-           o.setCreateTime(null);
-       });
-       duserMapper.insert(dbDuser);
-       // 测试 userId 不匹配
-       duserMapper.insert(cloneIgnoreId(dbDuser, o -> o.setUserId(null)));
-       // 测试 name 不匹配
-       duserMapper.insert(cloneIgnoreId(dbDuser, o -> o.setName(null)));
-       // 测试 mobile 不匹配
-       duserMapper.insert(cloneIgnoreId(dbDuser, o -> o.setMobile(null)));
-       // 测试 source 不匹配
-       duserMapper.insert(cloneIgnoreId(dbDuser, o -> o.setSource(null)));
-       // 测试 integralId 不匹配
-       duserMapper.insert(cloneIgnoreId(dbDuser, o -> o.setIntegralId(null)));
-       // 测试 socialStatus 不匹配
-       duserMapper.insert(cloneIgnoreId(dbDuser, o -> o.setSocialStatus(null)));
-       // 测试 socialStatusPoint 不匹配
-       duserMapper.insert(cloneIgnoreId(dbDuser, o -> o.setSocialStatusPoint(null)));
-       // 测试 categoryId 不匹配
-       duserMapper.insert(cloneIgnoreId(dbDuser, o -> o.setCategoryId(null)));
-       // 测试 createTime 不匹配
-       duserMapper.insert(cloneIgnoreId(dbDuser, o -> o.setCreateTime(null)));
-       // 准备参数
-       DuserPageReqVO reqVO = new DuserPageReqVO();
-       reqVO.setUserId(null);
-       reqVO.setName(null);
-       reqVO.setMobile(null);
-       reqVO.setSource(null);
-       reqVO.setIntegralId(null);
-       reqVO.setSocialStatus(null);
-       reqVO.setSocialStatusPoint(null);
-       reqVO.setCategoryId(null);
-       reqVO.setCreateTime(buildBetweenTime(2023, 2, 1, 2023, 2, 28));
-
-       // 调用
-       PageResult<DuserDO> pageResult = duserService.getDuserPage(reqVO);
-       // 断言
-       assertEquals(1, pageResult.getTotal());
-       assertEquals(1, pageResult.getList().size());
-       assertPojoEquals(dbDuser, pageResult.getList().get(0));
-    }
-
-}

feifan-module-distri/feifan-module-distri-biz/src/test/java/cn/newfeifan/mall/module/distri/service/partitioncrash/PartitionCrashServiceImplTest.java

@@ -1,150 +0,0 @@
-package cn.newfeifan.mall.module.distri.service.partitioncrash;
-
-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 cn.newfeifan.mall.framework.test.core.ut.BaseDbUnitTest;
-
-import cn.newfeifan.mall.module.distri.controller.admin.partitioncrash.vo.*;
-import cn.newfeifan.mall.module.distri.dal.dataobject.partitioncrash.PartitionCrashDO;
-import cn.newfeifan.mall.module.distri.dal.mysql.partitioncrash.PartitionCrashMapper;
-import cn.newfeifan.mall.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 cn.newfeifan.mall.module.distri.enums.ErrorCodeConstants.*;
-import static cn.newfeifan.mall.framework.test.core.util.AssertUtils.*;
-import static cn.newfeifan.mall.framework.test.core.util.RandomUtils.*;
-import static cn.newfeifan.mall.framework.common.util.date.LocalDateTimeUtils.*;
-import static cn.newfeifan.mall.framework.common.util.object.ObjectUtils.*;
-import static cn.newfeifan.mall.framework.common.util.date.DateUtils.*;
-import static org.junit.jupiter.api.Assertions.*;
-import static org.mockito.Mockito.*;
-
-/**
- * {@link PartitionCrashServiceImpl} 的单元测试类
- *
- * @author 非繁人
- */
-@Import(PartitionCrashServiceImpl.class)
-public class PartitionCrashServiceImplTest extends BaseDbUnitTest {
-
-    @Resource
-    private PartitionCrashServiceImpl partitionCrashService;
-
-    @Resource
-    private PartitionCrashMapper partitionCrashMapper;
-
-    @Test
-    public void testCreatePartitionCrash_success() {
-        // 准备参数
-        PartitionCrashSaveReqVO createReqVO = randomPojo(PartitionCrashSaveReqVO.class).setId(null);
-
-        // 调用
-        Long partitionCrashId = partitionCrashService.createPartitionCrash(createReqVO);
-        // 断言
-        assertNotNull(partitionCrashId);
-        // 校验记录的属性是否正确
-        PartitionCrashDO partitionCrash = partitionCrashMapper.selectById(partitionCrashId);
-        assertPojoEquals(createReqVO, partitionCrash, "id");
-    }
-
-    @Test
-    public void testUpdatePartitionCrash_success() {
-        // mock 数据
-        PartitionCrashDO dbPartitionCrash = randomPojo(PartitionCrashDO.class);
-        partitionCrashMapper.insert(dbPartitionCrash);// @Sql: 先插入出一条存在的数据
-        // 准备参数
-        PartitionCrashSaveReqVO updateReqVO = randomPojo(PartitionCrashSaveReqVO.class, o -> {
-            o.setId(dbPartitionCrash.getId()); // 设置更新的 ID
-        });
-
-        // 调用
-        partitionCrashService.updatePartitionCrash(updateReqVO);
-        // 校验是否更新正确
-        PartitionCrashDO partitionCrash = partitionCrashMapper.selectById(updateReqVO.getId()); // 获取最新的
-        assertPojoEquals(updateReqVO, partitionCrash);
-    }
-
-    @Test
-    public void testUpdatePartitionCrash_notExists() {
-        // 准备参数
-        PartitionCrashSaveReqVO updateReqVO = randomPojo(PartitionCrashSaveReqVO.class);
-
-        // 调用, 并断言异常
-        assertServiceException(() -> partitionCrashService.updatePartitionCrash(updateReqVO), PARTITION_CRASH_NOT_EXISTS);
-    }
-
-    @Test
-    public void testDeletePartitionCrash_success() {
-        // mock 数据
-        PartitionCrashDO dbPartitionCrash = randomPojo(PartitionCrashDO.class);
-        partitionCrashMapper.insert(dbPartitionCrash);// @Sql: 先插入出一条存在的数据
-        // 准备参数
-        Long id = dbPartitionCrash.getId();
-
-        // 调用
-        partitionCrashService.deletePartitionCrash(id);
-       // 校验数据不存在了
-       assertNull(partitionCrashMapper.selectById(id));
-    }
-
-    @Test
-    public void testDeletePartitionCrash_notExists() {
-        // 准备参数
-        Long id = randomLongId();
-
-        // 调用, 并断言异常
-        assertServiceException(() -> partitionCrashService.deletePartitionCrash(id), PARTITION_CRASH_NOT_EXISTS);
-    }
-
-    @Test
-    @Disabled  // TODO 请修改 null 为需要的值，然后删除 @Disabled 注解
-    public void testGetPartitionCrashPage() {
-       // mock 数据
-       PartitionCrashDO dbPartitionCrash = randomPojo(PartitionCrashDO.class, o -> { // 等会查询到
-           o.setUserId(null);
-           o.setPartNo(null);
-           o.setBrotherPrice(null);
-           o.setSonPrice(null);
-           o.setAfterHitQuota(null);
-           o.setCreateTime(null);
-       });
-       partitionCrashMapper.insert(dbPartitionCrash);
-       // 测试 userId 不匹配
-       partitionCrashMapper.insert(cloneIgnoreId(dbPartitionCrash, o -> o.setUserId(null)));
-       // 测试 partNo 不匹配
-       partitionCrashMapper.insert(cloneIgnoreId(dbPartitionCrash, o -> o.setPartNo(null)));
-       // 测试 brotherPrice 不匹配
-       partitionCrashMapper.insert(cloneIgnoreId(dbPartitionCrash, o -> o.setBrotherPrice(null)));
-       // 测试 sonPrice 不匹配
-       partitionCrashMapper.insert(cloneIgnoreId(dbPartitionCrash, o -> o.setSonPrice(null)));
-       // 测试 afterHitQuota 不匹配
-       partitionCrashMapper.insert(cloneIgnoreId(dbPartitionCrash, o -> o.setAfterHitQuota(null)));
-       // 测试 createTime 不匹配
-       partitionCrashMapper.insert(cloneIgnoreId(dbPartitionCrash, o -> o.setCreateTime(null)));
-       // 准备参数
-       PartitionCrashPageReqVO reqVO = new PartitionCrashPageReqVO();
-       reqVO.setUserId(null);
-       reqVO.setPartNo(null);
-       reqVO.setBrotherPrice(null);
-       reqVO.setSonPrice(null);
-       reqVO.setAfterHitQuota(null);
-       reqVO.setCreateTime(buildBetweenTime(2023, 2, 1, 2023, 2, 28));
-
-       // 调用
-       PageResult<PartitionCrashDO> pageResult = partitionCrashService.getPartitionCrashPage(reqVO);
-       // 断言
-       assertEquals(1, pageResult.getTotal());
-       assertEquals(1, pageResult.getList().size());
-       assertPojoEquals(dbPartitionCrash, pageResult.getList().get(0));
-    }
-
-}