1

docs/db/phase2/init-phase2.sql

@@ -858,7 +858,7 @@ CREATE TABLE IF NOT EXISTS `eval_project_waring` (
                                        PRIMARY KEY (`id`),
                                        KEY `idx_project_id` (`project_id`),
                                        KEY `idx_waring_start_time` (`waring_start_time`)
-) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='项目预警';
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='项目预警-归档后预警';
 set foreign_key_checks = 1;
 
 -- =============================================

safety-eval-adapter/src/main/java/org/qinan/safetyeval/adapter/web/EvalProjectProcessWaringController.java

@@ -0,0 +1,74 @@
+package org.qinan.safetyeval.adapter.web;
+
+import com.alibaba.cola.dto.PageResponse;
+import com.alibaba.cola.dto.Response;
+import com.alibaba.cola.dto.SingleResponse;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import org.qinan.safetyeval.app.waring.service.EvalProjectProcessWaringServiceI;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringAddCmd;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringPageQry;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringUpdateCmd;
+import org.qinan.safetyeval.client.waring.response.EvalProjectProcessWaringCo;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+import java.io.Serializable;
+
+/**
+ * 项目预警-归档前预警
+ *
+ * @Author: ltq
+ * @Date: 2026-07-27 14:59:38
+ */
+@RestController
+@AllArgsConstructor
+@Api(tags = "项目预警-归档前预警")
+@RequestMapping("/safetyEval/eval-project-process-waring")
+public class EvalProjectProcessWaringController implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    private final EvalProjectProcessWaringServiceI evalProjectProcessWaringServiceI;
+
+    @GetMapping
+    @ApiOperation("查询项目预警-归档前预警列表-分页")
+    public PageResponse<EvalProjectProcessWaringCo> list(@Validated EvalProjectProcessWaringPageQry qry) {
+        return evalProjectProcessWaringServiceI.listEvalProjectProcessWaringPage(qry);
+    }
+
+    @GetMapping("/{id}")
+    @ApiOperation("查询项目预警-归档前预警详情页面")
+    public SingleResponse<EvalProjectProcessWaringCo> getInfo(@PathVariable("id") Long id) {
+        return SingleResponse.of(evalProjectProcessWaringServiceI.getEvalProjectProcessWaringById(id));
+    }
+
+    @PostMapping
+    @ApiOperation("新增项目预警-归档前预警")
+    public Response save(@Validated @RequestBody EvalProjectProcessWaringAddCmd evalProjectProcessWaringAddCmd) {
+        evalProjectProcessWaringServiceI.saveEvalProjectProcessWaring(evalProjectProcessWaringAddCmd);
+        return Response.buildSuccess();
+    }
+
+    @PutMapping
+    @ApiOperation("修改项目预警-归档前预警")
+    public Response update(@Validated @RequestBody EvalProjectProcessWaringUpdateCmd evalProjectProcessWaringUpdateCmd) {
+        evalProjectProcessWaringServiceI.updateEvalProjectProcessWaring(evalProjectProcessWaringUpdateCmd);
+        return Response.buildSuccess();
+    }
+
+    @DeleteMapping("/{id}")
+    @ApiOperation("删除项目预警-归档前预警（单个）")
+    public Response deletedById(@PathVariable("id") Long id) {
+        evalProjectProcessWaringServiceI.deletedEvalProjectProcessWaringById(id);
+        return Response.buildSuccess();
+    }
+
+    @DeleteMapping("/ids")
+    @ApiOperation("删除项目预警-归档前预警（多个）")
+    public Response deletedByIds(@RequestParam Long[] ids) {
+        evalProjectProcessWaringServiceI.deletedEvalProjectProcessWaringByIds(ids);
+        return Response.buildSuccess();
+    }
+
+}

safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/convertor/EvalProjectProcessWaringCmdConvertor.java

@@ -0,0 +1,34 @@
+package org.qinan.safetyeval.app.waring.convertor;
+
+import org.mapstruct.Mapper;
+import org.mapstruct.Mapping;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringAddCmd;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringUpdateCmd;
+import org.qinan.safetyeval.domain.waring.model.EvalProjectProcessWaringE;
+
+/**
+ * 项目预警-归档前预警转换
+ *
+ * @Author: ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Mapper(componentModel = "spring")
+public interface EvalProjectProcessWaringCmdConvertor {
+    /**
+     * cmd_add转领域模型
+     *
+     * @param evalProjectProcessWaringAddCmd
+     * @return
+     */
+    @Mapping(target = "evalProjectProcessWaringGateway", ignore = true)
+    EvalProjectProcessWaringE convertCmdToE(EvalProjectProcessWaringAddCmd evalProjectProcessWaringAddCmd);
+
+    /**
+     * cmd_update转领域模型
+     *
+     * @param evalProjectProcessWaringUpdateCmd
+     * @return
+     */
+    @Mapping(target = "evalProjectProcessWaringGateway", ignore = true)
+    EvalProjectProcessWaringE convertCmdToE(EvalProjectProcessWaringUpdateCmd evalProjectProcessWaringUpdateCmd);
+}

safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/executor/command/EvalProjectProcessWaringAddCmdExe.java

@@ -0,0 +1,42 @@
+package org.qinan.safetyeval.app.waring.executor.command;
+
+import com.alibaba.cola.exception.BizException;
+import lombok.AllArgsConstructor;
+import org.qinan.safetyeval.app.waring.convertor.EvalProjectProcessWaringCmdConvertor;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringAddCmd;
+import org.qinan.safetyeval.domain.waring.ability.EvalProjectProcessWaringAbility;
+import org.qinan.safetyeval.domain.waring.model.EvalProjectProcessWaringE;
+import org.qinan.safetyeval.infrastructure.persistence.queryservice.EvalProjectProcessWaringQueryService;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * 新增项目预警-归档前预警执行器
+ *
+ * @author ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Component
+@AllArgsConstructor
+public class EvalProjectProcessWaringAddCmdExe {
+
+    private final EvalProjectProcessWaringQueryService evalProjectProcessWaringQueryService;
+    private final EvalProjectProcessWaringCmdConvertor evalProjectProcessWaringCmdConvertor;
+    private final EvalProjectProcessWaringAbility evalProjectProcessWaringAbility;
+
+    /**
+     * 新增项目预警-归档前预警
+     *
+     * @param evalProjectProcessWaringAddCmd 新增项目预警-归档前预警对象
+     * @return
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public boolean execute(EvalProjectProcessWaringAddCmd evalProjectProcessWaringAddCmd) {
+        EvalProjectProcessWaringE evalProjectProcessWaringE = evalProjectProcessWaringCmdConvertor.convertCmdToE(evalProjectProcessWaringAddCmd);
+        boolean res = evalProjectProcessWaringE.add();
+        if (!res) {
+            throw new BizException("保存失败");
+        }
+        return true;
+    }
+}

safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/executor/command/EvalProjectProcessWaringDelCmdExe.java

@@ -0,0 +1,55 @@
+package org.qinan.safetyeval.app.waring.executor.command;
+
+import cn.hutool.core.util.ObjectUtil;
+import com.alibaba.cola.exception.BizException;
+import lombok.AllArgsConstructor;
+import org.qinan.safetyeval.domain.waring.ability.EvalProjectProcessWaringAbility;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * 删除项目预警-归档前预警询执行器
+ *
+ * @author ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Component
+@AllArgsConstructor
+public class EvalProjectProcessWaringDelCmdExe {
+    private final EvalProjectProcessWaringAbility evalProjectProcessWaringAbility;
+
+    /**
+     * 根据IDS删除项目预警-归档前预警对象
+     *
+     * @param ids 项目预警-归档前预警ID数组
+     * @return
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public boolean execute(Long[] ids) {
+        if (ObjectUtil.isEmpty(ids)) {
+            throw new BizException("请传入正确的ID");
+        }
+        boolean deleteRes = evalProjectProcessWaringAbility.deletedEvalProjectProcessWaringByIds(ids);
+        if (!deleteRes) {
+            throw new BizException("删除失败");
+        }
+        return true;
+    }
+
+    /**
+     * 根据ID删除项目预警-归档前预警对象
+     *
+     * @param id 删除项目预警-归档前预警对象ID
+     * @return
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public boolean execute(Long id) {
+        boolean deleteRes = evalProjectProcessWaringAbility.deletedEvalProjectProcessWaringById(id);
+        if (!deleteRes) {
+            throw new BizException("删除失败");
+        }
+        return true;
+    }
+
+
+}

safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/executor/command/EvalProjectProcessWaringUpdateCmdExe.java

@@ -0,0 +1,41 @@
+package org.qinan.safetyeval.app.waring.executor.command;
+
+import com.alibaba.cola.exception.BizException;
+import lombok.AllArgsConstructor;
+import org.qinan.safetyeval.app.waring.convertor.EvalProjectProcessWaringCmdConvertor;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringUpdateCmd;
+import org.qinan.safetyeval.domain.waring.ability.EvalProjectProcessWaringAbility;
+import org.qinan.safetyeval.domain.waring.model.EvalProjectProcessWaringE;
+import org.qinan.safetyeval.infrastructure.persistence.queryservice.EvalProjectProcessWaringQueryService;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * 修改项目预警-归档前预警资源执行器
+ *
+ * @author ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Component
+@AllArgsConstructor
+public class EvalProjectProcessWaringUpdateCmdExe {
+    private final EvalProjectProcessWaringQueryService evalProjectProcessWaringQueryService;
+    private final EvalProjectProcessWaringCmdConvertor evalProjectProcessWaringCmdConvertor;
+    private final EvalProjectProcessWaringAbility evalProjectProcessWaringAbility;
+
+    /**
+     * 修改项目预警-归档前预警
+     *
+     * @param evalProjectProcessWaringUpdateCmd 修改项目预警-归档前预警对象
+     * @return
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public boolean execute(EvalProjectProcessWaringUpdateCmd evalProjectProcessWaringUpdateCmd) {
+        EvalProjectProcessWaringE evalProjectProcessWaringE = evalProjectProcessWaringCmdConvertor.convertCmdToE(evalProjectProcessWaringUpdateCmd);
+        Boolean updateRes = evalProjectProcessWaringE.update();
+        if (!updateRes) {
+            throw new BizException("数据已被更新，请刷新重试");
+        }
+        return true;
+    }
+}

safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/executor/query/EvalProjectProcessWaringListQueryExe.java

@@ -0,0 +1,34 @@
+package org.qinan.safetyeval.app.waring.executor.query;
+
+import lombok.AllArgsConstructor;
+import org.qinan.safetyeval.client.waring.response.EvalProjectProcessWaringCo;
+import org.qinan.safetyeval.infrastructure.convertor.EvalProjectProcessWaringDoConvertor;
+import org.qinan.safetyeval.infrastructure.persistence.domainobject.EvalProjectProcessWaringDO;
+import org.qinan.safetyeval.infrastructure.persistence.queryservice.EvalProjectProcessWaringQueryService;
+import org.springframework.stereotype.Component;
+
+/**
+ * 项目预警-归档前预警查询执行器
+ *
+ * @author ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Component
+@AllArgsConstructor
+public class EvalProjectProcessWaringListQueryExe {
+
+    private final EvalProjectProcessWaringQueryService evalProjectProcessWaringQueryService;
+    private final EvalProjectProcessWaringDoConvertor evalProjectProcessWaringDoConvertor;
+
+    /**
+     * 根据ID查找项目预警-归档前预警对象
+     *
+     * @param id 项目预警-归档前预警ID
+     * @return
+     */
+    public EvalProjectProcessWaringCo execute(Long id) {
+        EvalProjectProcessWaringDO evalProjectProcessWaringDO = evalProjectProcessWaringQueryService.getById(id);
+        return evalProjectProcessWaringDoConvertor.converDoToCo(evalProjectProcessWaringDO);
+    }
+
+}

safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/executor/query/EvalProjectProcessWaringPageQueryExe.java

@@ -0,0 +1,32 @@
+package org.qinan.safetyeval.app.waring.executor.query;
+
+import com.alibaba.cola.dto.PageResponse;
+import lombok.AllArgsConstructor;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringPageQry;
+import org.qinan.safetyeval.client.waring.response.EvalProjectProcessWaringCo;
+import org.qinan.safetyeval.infrastructure.persistence.queryservice.EvalProjectProcessWaringQueryService;
+import org.springframework.stereotype.Component;
+
+/**
+ * 项目预警-归档前预警分页查询执行器
+ *
+ * @author ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Component
+@AllArgsConstructor
+public class EvalProjectProcessWaringPageQueryExe {
+
+    private final EvalProjectProcessWaringQueryService evalProjectProcessWaringQueryService;
+
+    /**
+     * 分页查找项目预警-归档前预警
+     *
+     * @param evalProjectProcessWaringPageQry
+     * @return
+     */
+    public PageResponse<EvalProjectProcessWaringCo> execute(EvalProjectProcessWaringPageQry evalProjectProcessWaringPageQry) {
+        return evalProjectProcessWaringQueryService.listEvalProjectProcessWaringPage(evalProjectProcessWaringPageQry);
+    }
+
+}

safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/service/EvalProjectProcessWaringServiceI.java

@@ -0,0 +1,65 @@
+package org.qinan.safetyeval.app.waring.service;
+
+import com.alibaba.cola.dto.PageResponse;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringAddCmd;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringPageQry;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringUpdateCmd;
+import org.qinan.safetyeval.client.waring.response.EvalProjectProcessWaringCo;
+
+/**
+ * 项目预警-归档前预警
+ *
+ * @Author: ltq
+ * @date 2026-07-27 14:59:38
+ */
+public interface EvalProjectProcessWaringServiceI {
+    /**
+     * 分页获取项目预警-归档前预警列表
+     *
+     * @param evalProjectProcessWaringPageQry 查找条件对象
+     * @return 结果集
+     */
+    PageResponse<EvalProjectProcessWaringCo> listEvalProjectProcessWaringPage(EvalProjectProcessWaringPageQry evalProjectProcessWaringPageQry);
+
+    /**
+     * 根据ID获取项目预警-归档前预警详情
+     *
+     * @param id 项目预警-归档前预警ID
+     * @return 结果集
+     */
+    EvalProjectProcessWaringCo getEvalProjectProcessWaringById(Long id);
+
+    /**
+     * 新增项目预警-归档前预警
+     *
+     * @param evalProjectProcessWaringAddCmd 项目预警-归档前预警
+     * @return 结果
+     */
+    boolean saveEvalProjectProcessWaring(EvalProjectProcessWaringAddCmd evalProjectProcessWaringAddCmd);
+
+    /**
+     * 修改项目预警-归档前预警
+     *
+     * @param evalProjectProcessWaringUpdateCmd 项目预警-归档前预警
+     * @return 结果
+     */
+    boolean updateEvalProjectProcessWaring(EvalProjectProcessWaringUpdateCmd evalProjectProcessWaringUpdateCmd);
+
+    /**
+     * 删除项目预警-归档前预警
+     *
+     * @param id 项目预警-归档前预警ID
+     * @return 结果
+     */
+    boolean deletedEvalProjectProcessWaringById(Long id);
+
+    /**
+     * 删除项目预警-归档前预警
+     *
+     * @param ids 项目预警-归档前预警IDs
+     * @return 结果
+     */
+    boolean deletedEvalProjectProcessWaringByIds(Long[] ids);
+
+
+}

safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/service/impl/EvalProjectProcessWaringServiceImpl.java

@@ -0,0 +1,63 @@
+package org.qinan.safetyeval.app.waring.service.impl;
+
+import com.alibaba.cola.dto.PageResponse;
+import lombok.AllArgsConstructor;
+import org.qinan.safetyeval.app.waring.executor.command.EvalProjectProcessWaringAddCmdExe;
+import org.qinan.safetyeval.app.waring.executor.command.EvalProjectProcessWaringDelCmdExe;
+import org.qinan.safetyeval.app.waring.executor.command.EvalProjectProcessWaringUpdateCmdExe;
+import org.qinan.safetyeval.app.waring.executor.query.EvalProjectProcessWaringListQueryExe;
+import org.qinan.safetyeval.app.waring.executor.query.EvalProjectProcessWaringPageQueryExe;
+import org.qinan.safetyeval.app.waring.service.EvalProjectProcessWaringServiceI;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringAddCmd;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringPageQry;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringUpdateCmd;
+import org.qinan.safetyeval.client.waring.response.EvalProjectProcessWaringCo;
+import org.springframework.stereotype.Service;
+
+/**
+ * 项目预警-归档前预警
+ *
+ * @Author: ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Service
+@AllArgsConstructor
+public class EvalProjectProcessWaringServiceImpl implements EvalProjectProcessWaringServiceI {
+
+    private final EvalProjectProcessWaringListQueryExe evalProjectProcessWaringListQueryExe;
+    private final EvalProjectProcessWaringUpdateCmdExe evalProjectProcessWaringUpdateCommandExe;
+    private final EvalProjectProcessWaringAddCmdExe evalProjectProcessWaringAddCommandExe;
+    private final EvalProjectProcessWaringDelCmdExe evalProjectProcessWaringDelCommandExe;
+    private final EvalProjectProcessWaringPageQueryExe evalProjectProcessWaringPageQueryExe;
+
+    @Override
+    public PageResponse<EvalProjectProcessWaringCo> listEvalProjectProcessWaringPage(EvalProjectProcessWaringPageQry evalProjectProcessWaringPageQry) {
+        return evalProjectProcessWaringPageQueryExe.execute(evalProjectProcessWaringPageQry);
+    }
+
+    @Override
+    public EvalProjectProcessWaringCo getEvalProjectProcessWaringById(Long id) {
+        return evalProjectProcessWaringListQueryExe.execute(id);
+    }
+
+    @Override
+    public boolean saveEvalProjectProcessWaring(EvalProjectProcessWaringAddCmd evalProjectProcessWaringAddCmd) {
+        return evalProjectProcessWaringAddCommandExe.execute(evalProjectProcessWaringAddCmd);
+    }
+
+    @Override
+    public boolean updateEvalProjectProcessWaring(EvalProjectProcessWaringUpdateCmd evalProjectProcessWaringUpdateCmd) {
+        return evalProjectProcessWaringUpdateCommandExe.execute(evalProjectProcessWaringUpdateCmd);
+    }
+
+    @Override
+    public boolean deletedEvalProjectProcessWaringById(Long id) {
+        return evalProjectProcessWaringDelCommandExe.execute(id);
+    }
+
+    @Override
+    public boolean deletedEvalProjectProcessWaringByIds(Long[] ids) {
+        return evalProjectProcessWaringDelCommandExe.execute(ids);
+    }
+
+}

safety-eval-client/src/main/java/org/qinan/safetyeval/client/waring/request/EvalProjectProcessWaringAddCmd.java

@@ -0,0 +1,60 @@
+package org.qinan.safetyeval.client.waring.request;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+
+/**
+ * 项目预警-归档前预警新增Cmd
+ *
+ * @Author: ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Data
+public class EvalProjectProcessWaringAddCmd implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 项目id
+     */
+    @ApiModelProperty(value = "项目id", required = true)
+    @NotNull(message = "项目id不能为空")
+    private Long projectId;
+    /**
+     * 预警状态 normal:正常；abnormal 异常
+     */
+    @ApiModelProperty(value = "预警状态 normal:正常；abnormal 异常", required = true)
+    @NotBlank(message = "预警状态 normal:正常；abnormal 异常不能为空")
+    private String waringStatus;
+    /**
+     * 人员预警异常 normal:正常；abnormal 异常
+     */
+    @ApiModelProperty(value = "人员预警异常 normal:正常；abnormal 异常", required = true)
+    @NotBlank(message = "人员预警异常 normal:正常；abnormal 异常不能为空")
+    private String processWaringStatus;
+    /**
+     * ${column.columnComment}
+     */
+    @ApiModelProperty(value = "人员预警异常 normal:正常；abnormal 异常")
+    private String processWaringMsg;
+    /**
+     * 人员预警 normal:正常；abnormal 异常
+     */
+    @ApiModelProperty(value = "人员预警 normal:正常；abnormal 异常", required = true)
+    @NotBlank(message = "人员预警 normal:正常；abnormal 异常不能为空")
+    private String personnelWaringStatus;
+    /**
+     * ${column.columnComment}
+     */
+    @ApiModelProperty(value = "人员预警 normal:正常；abnormal 异常")
+    private String personnelWaringMsg;
+    /**
+     * 环境
+     */
+    @ApiModelProperty(value = "环境")
+    private String env;
+
+}

safety-eval-client/src/main/java/org/qinan/safetyeval/client/waring/request/EvalProjectProcessWaringPageQry.java

@@ -0,0 +1,53 @@
+package org.qinan.safetyeval.client.waring.request;
+
+import com.alibaba.cola.dto.PageQuery;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * 项目预警-归档前预警分页查询Qry
+ *
+ * @Author: ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Data
+public class EvalProjectProcessWaringPageQry extends PageQuery {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 项目id
+     */
+    @ApiModelProperty(value = "项目id")
+    private Long projectId;
+    /**
+     * 预警状态 normal:正常；abnormal 异常
+     */
+    @ApiModelProperty(value = "预警状态 normal:正常；abnormal 异常")
+    private String waringStatus;
+    /**
+     * 人员预警异常 normal:正常；abnormal 异常
+     */
+    @ApiModelProperty(value = "人员预警异常 normal:正常；abnormal 异常")
+    private String processWaringStatus;
+    /**
+     * $column.columnComment
+     */
+    @ApiModelProperty(value = "人员预警异常 normal:正常；abnormal 异常")
+    private String processWaringMsg;
+    /**
+     * 人员预警 normal:正常；abnormal 异常
+     */
+    @ApiModelProperty(value = "人员预警 normal:正常；abnormal 异常")
+    private String personnelWaringStatus;
+    /**
+     * $column.columnComment
+     */
+    @ApiModelProperty(value = "人员预警 normal:正常；abnormal 异常")
+    private String personnelWaringMsg;
+    /**
+     * 环境
+     */
+    @ApiModelProperty(value = "环境")
+    private String env;
+
+}

safety-eval-client/src/main/java/org/qinan/safetyeval/client/waring/request/EvalProjectProcessWaringUpdateCmd.java

@@ -0,0 +1,64 @@
+package org.qinan.safetyeval.client.waring.request;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+
+/**
+ * 项目预警-归档前预警修改Cmd
+ *
+ * @Author: ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Data
+public class EvalProjectProcessWaringUpdateCmd implements Serializable {
+    private static final long serialVersionUID = 1L;
+    @JsonFormat(shape = JsonFormat.Shape.STRING)
+    private Long id;
+    /**
+     * 项目id
+     */
+    @ApiModelProperty(value = "项目id", required = true)
+    @NotNull(message = "项目id不能为空")
+    private Long projectId;
+    /**
+     * 预警状态 normal:正常；abnormal 异常
+     */
+    @ApiModelProperty(value = "预警状态 normal:正常；abnormal 异常", required = true)
+    @NotBlank(message = "预警状态 normal:正常；abnormal 异常不能为空")
+    private String waringStatus;
+    /**
+     * 人员预警异常 normal:正常；abnormal 异常
+     */
+    @ApiModelProperty(value = "人员预警异常 normal:正常；abnormal 异常", required = true)
+    @NotBlank(message = "人员预警异常 normal:正常；abnormal 异常不能为空")
+    private String processWaringStatus;
+    /**
+     * ${column.columnComment}
+     */
+    @ApiModelProperty(value = "人员预警异常 normal:正常；abnormal 异常")
+    private String processWaringMsg;
+    /**
+     * 人员预警 normal:正常；abnormal 异常
+     */
+    @ApiModelProperty(value = "人员预警 normal:正常；abnormal 异常", required = true)
+    @NotBlank(message = "人员预警 normal:正常；abnormal 异常不能为空")
+    private String personnelWaringStatus;
+    /**
+     * ${column.columnComment}
+     */
+    @ApiModelProperty(value = "人员预警 normal:正常；abnormal 异常")
+    private String personnelWaringMsg;
+    /**
+     * 环境
+     */
+    @ApiModelProperty(value = "环境")
+    private String env;
+    @NotNull(message = "version不能为空")
+    @ApiModelProperty(value = "version")
+    private Integer version;
+}

safety-eval-client/src/main/java/org/qinan/safetyeval/client/waring/response/EvalProjectProcessWaringCo.java

@@ -0,0 +1,56 @@
+package org.qinan.safetyeval.client.waring.response;
+
+import com.alibaba.cola.dto.ClientObject;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * 项目预警-归档前预警Co
+ *
+ * @Author: ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Data
+public class EvalProjectProcessWaringCo extends ClientObject {
+    private static final long serialVersionUID = 1L;
+    @JsonFormat(shape = JsonFormat.Shape.STRING)
+    private Long id;
+    /**
+     * 项目id
+     */
+    @ApiModelProperty(value = "项目id")
+    private Long projectId;
+    /**
+     * 预警状态 normal:正常；abnormal 异常
+     */
+    @ApiModelProperty(value = "预警状态 normal:正常；abnormal 异常")
+    private String waringStatus;
+    /**
+     * 人员预警异常 normal:正常；abnormal 异常
+     */
+    @ApiModelProperty(value = "人员预警异常 normal:正常；abnormal 异常")
+    private String processWaringStatus;
+    /**
+     * ${column.columnComment}
+     */
+    @ApiModelProperty(value = "${column.columnComment}")
+    private String processWaringMsg;
+    /**
+     * 人员预警 normal:正常；abnormal 异常
+     */
+    @ApiModelProperty(value = "人员预警 normal:正常；abnormal 异常")
+    private String personnelWaringStatus;
+    /**
+     * ${column.columnComment}
+     */
+    @ApiModelProperty(value = "${column.columnComment}")
+    private String personnelWaringMsg;
+    /**
+     * 环境
+     */
+    @ApiModelProperty(value = "环境")
+    private String env;
+    @ApiModelProperty(value = "version")
+    private Integer version;
+}

safety-eval-domain/src/main/java/org/qinan/safetyeval/domain/waring/ability/EvalProjectProcessWaringAbility.java

@@ -0,0 +1,29 @@
+package org.qinan.safetyeval.domain.waring.ability;
+
+import lombok.AllArgsConstructor;
+import org.qinan.safetyeval.domain.waring.gateway.EvalProjectProcessWaringGateway;
+import org.springframework.stereotype.Service;
+
+/**
+ * 项目预警-归档前预警
+ *
+ * @Author: ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Service
+@AllArgsConstructor
+public class EvalProjectProcessWaringAbility {
+    /**
+     * 网关
+     **/
+    private final EvalProjectProcessWaringGateway evalProjectProcessWaringGateway;
+
+
+    public boolean deletedEvalProjectProcessWaringById(Long id) {
+        return evalProjectProcessWaringGateway.deletedEvalProjectProcessWaringById(id);
+    }
+
+    public boolean deletedEvalProjectProcessWaringByIds(Long[] ids) {
+        return evalProjectProcessWaringGateway.deletedEvalProjectProcessWaringByIds(ids);
+    }
+}

safety-eval-domain/src/main/java/org/qinan/safetyeval/domain/waring/gateway/EvalProjectProcessWaringGateway.java

@@ -0,0 +1,44 @@
+package org.qinan.safetyeval.domain.waring.gateway;
+
+import org.qinan.safetyeval.domain.waring.model.EvalProjectProcessWaringE;
+
+/**
+ * 项目预警-归档前预警网关
+ *
+ * @Author: WGG
+ * @Date: 2022/3/22 16:49
+ */
+public interface EvalProjectProcessWaringGateway {
+
+    /**
+     * 新增项目预警-归档前预警
+     *
+     * @param evalProjectProcessWaringE 项目预警-归档前预警
+     * @return 结果
+     */
+    Boolean add(EvalProjectProcessWaringE evalProjectProcessWaringE);
+
+    /**
+     * 修改项目预警-归档前预警
+     *
+     * @param evalProjectProcessWaringE 项目预警-归档前预警
+     * @return 结果
+     */
+    Boolean update(EvalProjectProcessWaringE evalProjectProcessWaringE);
+
+    /**
+     * 删除项目预警-归档前预警
+     *
+     * @param id
+     * @return 结果
+     */
+    Boolean deletedEvalProjectProcessWaringById(Long id);
+
+    /**
+     * 删除项目预警-归档前预警
+     *
+     * @param ids
+     * @return 结果
+     */
+    Boolean deletedEvalProjectProcessWaringByIds(Long[] ids);
+}

safety-eval-domain/src/main/java/org/qinan/safetyeval/domain/waring/model/EvalProjectProcessWaringE.java

@@ -0,0 +1,68 @@
+package org.qinan.safetyeval.domain.waring.model;
+
+import cn.hutool.extra.spring.SpringUtil;
+import com.alibaba.cola.domain.DomainFactory;
+import com.alibaba.cola.domain.Entity;
+import com.jjb.saas.framework.domain.model.BaseE;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.qinan.safetyeval.domain.waring.gateway.EvalProjectProcessWaringGateway;
+
+/**
+ * 项目预警-归档前预警领域模型
+ *
+ * @Author: ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Data
+@Entity
+@EqualsAndHashCode(callSuper = true)
+public class EvalProjectProcessWaringE extends BaseE {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 项目id
+     */
+    private Long projectId;
+    /**
+     * 预警状态 normal:正常；abnormal 异常
+     */
+    private String waringStatus;
+    /**
+     * 人员预警异常 normal:正常；abnormal 异常
+     */
+    private String processWaringStatus;
+    /**
+     * ${column.columnComment}
+     */
+    private String processWaringMsg;
+    /**
+     * 人员预警 normal:正常；abnormal 异常
+     */
+    private String personnelWaringStatus;
+    /**
+     * ${column.columnComment}
+     */
+    private String personnelWaringMsg;
+    /**
+     * 环境
+     */
+    private String env;
+    private transient EvalProjectProcessWaringGateway evalProjectProcessWaringGateway;
+
+    public EvalProjectProcessWaringE() {
+        this.evalProjectProcessWaringGateway = SpringUtil.getBean(EvalProjectProcessWaringGateway.class);
+    }
+
+    public static EvalProjectProcessWaringE of() {
+        return DomainFactory.create(EvalProjectProcessWaringE.class);
+    }
+
+    public boolean add() {
+        return evalProjectProcessWaringGateway.add(this);
+    }
+
+    public boolean update() {
+        return evalProjectProcessWaringGateway.update(this);
+    }
+}

safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/convertor/EvalProjectProcessWaringDoConvertor.java

@@ -0,0 +1,53 @@
+package org.qinan.safetyeval.infrastructure.convertor;
+
+import org.mapstruct.Mapper;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringPageQry;
+import org.qinan.safetyeval.client.waring.response.EvalProjectProcessWaringCo;
+import org.qinan.safetyeval.domain.waring.model.EvalProjectProcessWaringE;
+import org.qinan.safetyeval.infrastructure.persistence.domainobject.EvalProjectProcessWaringDO;
+
+import java.util.List;
+
+
+/**
+ * 项目预警-归档前预警对象转换
+ *
+ * @Author: ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Mapper(componentModel = "spring")
+public interface EvalProjectProcessWaringDoConvertor {
+    /**
+     * 领域对象转DO
+     *
+     * @param evalProjectProcessWaringE
+     * @return
+     */
+    EvalProjectProcessWaringDO convertEeToDo(EvalProjectProcessWaringE evalProjectProcessWaringE);
+
+    /**
+     * DO转Co
+     *
+     * @param evalProjectProcessWaringDo DO
+     * @return
+     */
+
+    EvalProjectProcessWaringCo converDoToCo(EvalProjectProcessWaringDO evalProjectProcessWaringDo);
+
+    /**
+     * qry TO DO
+     *
+     * @param evalProjectProcessWaringPageQry
+     * @return
+     */
+
+    EvalProjectProcessWaringDO convertQryToDo(EvalProjectProcessWaringPageQry evalProjectProcessWaringPageQry);
+
+    /**
+     * DOs转Cos
+     *
+     * @param evalProjectProcessWaringDos dos
+     * @return
+     */
+    List<EvalProjectProcessWaringCo> converDosToCos(List<EvalProjectProcessWaringDO> evalProjectProcessWaringDos);
+}

safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/gateway/EvalProjectProcessWaringGatewayImpl.java

@@ -0,0 +1,48 @@
+package org.qinan.safetyeval.infrastructure.gateway;
+
+import lombok.AllArgsConstructor;
+import org.qinan.safetyeval.domain.waring.gateway.EvalProjectProcessWaringGateway;
+import org.qinan.safetyeval.domain.waring.model.EvalProjectProcessWaringE;
+import org.qinan.safetyeval.infrastructure.convertor.EvalProjectProcessWaringDoConvertor;
+import org.qinan.safetyeval.infrastructure.persistence.domainobject.EvalProjectProcessWaringDO;
+import org.qinan.safetyeval.infrastructure.persistence.repository.EvalProjectProcessWaringRepository;
+import org.springframework.stereotype.Service;
+
+/**
+ * 项目预警-归档前预警网关实现
+ *
+ * @Author: ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Service
+@AllArgsConstructor
+public class EvalProjectProcessWaringGatewayImpl implements EvalProjectProcessWaringGateway {
+    private final EvalProjectProcessWaringRepository evalProjectProcessWaringRepository;
+    private final EvalProjectProcessWaringDoConvertor evalProjectProcessWaringDoConvertor;
+
+    @Override
+    public Boolean add(EvalProjectProcessWaringE evalProjectProcessWaringE) {
+        EvalProjectProcessWaringDO evalProjectProcessWaringDO = evalProjectProcessWaringDoConvertor.convertEeToDo(evalProjectProcessWaringE);
+        boolean res = evalProjectProcessWaringRepository.addEvalProjectProcessWaring(evalProjectProcessWaringDO);
+        if (res) {
+            evalProjectProcessWaringE.setId(evalProjectProcessWaringDO.getId());
+        }
+        return res;
+    }
+
+    @Override
+    public Boolean update(EvalProjectProcessWaringE evalProjectProcessWaringE) {
+        boolean res = evalProjectProcessWaringRepository.updateEvalProjectProcessWaring(evalProjectProcessWaringDoConvertor.convertEeToDo(evalProjectProcessWaringE));
+        return res;
+    }
+
+    @Override
+    public Boolean deletedEvalProjectProcessWaringById(Long id) {
+        return evalProjectProcessWaringRepository.deletedEvalProjectProcessWaringById(id);
+    }
+
+    @Override
+    public Boolean deletedEvalProjectProcessWaringByIds(Long[] ids) {
+        return evalProjectProcessWaringRepository.deletedEvalProjectProcessWaringByIds(ids);
+    }
+}

safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/domainobject/EvalProjectProcessWaringDO.java

@@ -0,0 +1,48 @@
+package org.qinan.safetyeval.infrastructure.persistence.domainobject;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.jjb.saas.framework.repository.basedo.BaseDO;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * 项目预警-归档前预警领域模型
+ *
+ * @Author: ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("eval_project_process_waring")
+public class EvalProjectProcessWaringDO extends BaseDO {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 项目id
+     */
+    private Long projectId;
+    /**
+     * 预警状态 normal:正常；abnormal 异常
+     */
+    private String waringStatus;
+    /**
+     * 人员预警异常 normal:正常；abnormal 异常
+     */
+    private String processWaringStatus;
+    /**
+     * ${column.columnComment}
+     */
+    private String processWaringMsg;
+    /**
+     * 人员预警 normal:正常；abnormal 异常
+     */
+    private String personnelWaringStatus;
+    /**
+     * ${column.columnComment}
+     */
+    private String personnelWaringMsg;
+    /**
+     * 环境
+     */
+    private String env;
+}

safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/mapper/EvalProjectProcessWaringMapper.java

@@ -0,0 +1,15 @@
+package org.qinan.safetyeval.infrastructure.persistence.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.qinan.safetyeval.infrastructure.persistence.domainobject.EvalProjectProcessWaringDO;
+
+/**
+ * 项目预警-归档前预警Mapper
+ *
+ * @Author: ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Mapper
+public interface EvalProjectProcessWaringMapper extends BaseMapper<EvalProjectProcessWaringDO> {
+}

safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/queryservice/EvalProjectProcessWaringQueryService.java

@@ -0,0 +1,31 @@
+package org.qinan.safetyeval.infrastructure.persistence.queryservice;
+
+import com.alibaba.cola.dto.PageResponse;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringPageQry;
+import org.qinan.safetyeval.client.waring.response.EvalProjectProcessWaringCo;
+import org.qinan.safetyeval.infrastructure.persistence.domainobject.EvalProjectProcessWaringDO;
+
+/**
+ * 项目预警-归档前预警
+ *
+ * @Author: ltq
+ * @date 2026-07-27 14:59:38
+ */
+public interface EvalProjectProcessWaringQueryService {
+
+    /**
+     * 根据ID查找
+     *
+     * @param id 项目预警-归档前预警ID
+     * @return
+     */
+    EvalProjectProcessWaringDO getById(Long id);
+
+    /**
+     * 分页查询项目预警-归档前预警
+     *
+     * @param evalProjectProcessWaringPageQry 分页Qry
+     * @return
+     */
+    PageResponse<EvalProjectProcessWaringCo> listEvalProjectProcessWaringPage(EvalProjectProcessWaringPageQry evalProjectProcessWaringPageQry);
+}

safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/queryservice/impl/EvalProjectProcessWaringQueryServiceImpl.java

@@ -0,0 +1,42 @@
+package org.qinan.safetyeval.infrastructure.persistence.queryservice.impl;
+
+import com.alibaba.cola.dto.PageResponse;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.jjb.saas.framework.repository.common.PageHelper;
+import lombok.AllArgsConstructor;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringPageQry;
+import org.qinan.safetyeval.client.waring.response.EvalProjectProcessWaringCo;
+import org.qinan.safetyeval.infrastructure.convertor.EvalProjectProcessWaringDoConvertor;
+import org.qinan.safetyeval.infrastructure.persistence.domainobject.EvalProjectProcessWaringDO;
+import org.qinan.safetyeval.infrastructure.persistence.queryservice.EvalProjectProcessWaringQueryService;
+import org.qinan.safetyeval.infrastructure.persistence.repository.EvalProjectProcessWaringRepository;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 项目预警-归档前预警
+ *
+ * @Author: ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Service
+@AllArgsConstructor
+public class EvalProjectProcessWaringQueryServiceImpl implements EvalProjectProcessWaringQueryService {
+
+    private final EvalProjectProcessWaringRepository evalProjectProcessWaringRepository;
+    private final EvalProjectProcessWaringDoConvertor evalProjectProcessWaringDoConvertor;
+
+    @Override
+    public EvalProjectProcessWaringDO getById(Long id) {
+        return evalProjectProcessWaringRepository.getById(id);
+    }
+
+    @Override
+    public PageResponse<EvalProjectProcessWaringCo> listEvalProjectProcessWaringPage(EvalProjectProcessWaringPageQry evalProjectProcessWaringPageQry) {
+        IPage<EvalProjectProcessWaringDO> evalProjectProcessWaringDoPage = evalProjectProcessWaringRepository.listEvalProjectProcessWaringPage(PageHelper.queryToPage(evalProjectProcessWaringPageQry), evalProjectProcessWaringPageQry);
+        List<EvalProjectProcessWaringCo> evalProjectProcessWaringCoS = evalProjectProcessWaringDoConvertor.converDosToCos(evalProjectProcessWaringDoPage.getRecords());
+        return PageHelper.pageToResponse(evalProjectProcessWaringDoPage, evalProjectProcessWaringCoS);
+    }
+
+}

safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/repository/EvalProjectProcessWaringRepository.java

@@ -0,0 +1,65 @@
+package org.qinan.safetyeval.infrastructure.persistence.repository;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.jjb.saas.framework.repository.repo.BaseRepository;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringPageQry;
+import org.qinan.safetyeval.infrastructure.persistence.domainobject.EvalProjectProcessWaringDO;
+
+/**
+ * 项目预警-归档前预警
+ *
+ * @Author: ltq
+ * @date 2026-07-27 14:59:38
+ */
+public interface EvalProjectProcessWaringRepository extends BaseRepository<EvalProjectProcessWaringDO> {
+    /**
+     * 根据ID查找
+     *
+     * @param id 项目预警-归档前预警ID
+     * @return
+     */
+    EvalProjectProcessWaringDO getById(Long id);
+
+    /**
+     * 分页查找项目预警-归档前预警对象
+     *
+     * @param iPage                           分页对象
+     * @param evalProjectProcessWaringPageQry 条件对象
+     * @return ipage
+     */
+    IPage<EvalProjectProcessWaringDO> listEvalProjectProcessWaringPage(IPage iPage, EvalProjectProcessWaringPageQry evalProjectProcessWaringPageQry);
+
+    /**
+     * 新增项目预警-归档前预警
+     *
+     * @param evalProjectProcessWaringDO 项目预警-归档前预警
+     * @return 结果
+     */
+    Boolean addEvalProjectProcessWaring(EvalProjectProcessWaringDO evalProjectProcessWaringDO);
+
+    /**
+     * 修改项目预警-归档前预警
+     *
+     * @param evalProjectProcessWaringDO 项目预警-归档前预警
+     * @return 结果
+     */
+    Boolean updateEvalProjectProcessWaring(EvalProjectProcessWaringDO evalProjectProcessWaringDO);
+
+
+    /**
+     * 删除项目预警-归档前预警
+     *
+     * @param id
+     * @return 结果
+     */
+    Boolean deletedEvalProjectProcessWaringById(Long id);
+
+    /**
+     * 删除项目预警-归档前预警
+     *
+     * @param ids
+     * @return 结果
+     */
+    Boolean deletedEvalProjectProcessWaringByIds(Long[] ids);
+
+}

safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/repository/impl/EvalProjectProcessWaringRepositoryImpl.java

@@ -0,0 +1,81 @@
+package org.qinan.safetyeval.infrastructure.persistence.repository.impl;
+
+import cn.hutool.core.util.ObjectUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.jjb.saas.framework.enums.enums.BooleanEnum;
+import com.jjb.saas.framework.repository.repo.impl.BaseRepositoryImpl;
+import lombok.AllArgsConstructor;
+import org.qinan.safetyeval.client.waring.request.EvalProjectProcessWaringPageQry;
+import org.qinan.safetyeval.infrastructure.persistence.domainobject.EvalProjectProcessWaringDO;
+import org.qinan.safetyeval.infrastructure.persistence.mapper.EvalProjectProcessWaringMapper;
+import org.qinan.safetyeval.infrastructure.persistence.repository.EvalProjectProcessWaringRepository;
+import org.springframework.stereotype.Service;
+
+import java.util.Arrays;
+
+/**
+ * 项目预警-归档前预警
+ *
+ * @Author: ltq
+ * @date 2026-07-27 14:59:38
+ */
+@Service
+@AllArgsConstructor
+public class EvalProjectProcessWaringRepositoryImpl extends BaseRepositoryImpl<EvalProjectProcessWaringMapper, EvalProjectProcessWaringDO> implements EvalProjectProcessWaringRepository {
+
+    private final EvalProjectProcessWaringMapper evalProjectProcessWaringMapper;
+
+    @Override
+    public EvalProjectProcessWaringDO getById(Long id) {
+        return super.lambdaQuery().eq(EvalProjectProcessWaringDO::getId, id).eq(EvalProjectProcessWaringDO::getDeleteEnum, BooleanEnum.FALSE.getValue()).one();
+    }
+
+    @Override
+    public IPage<EvalProjectProcessWaringDO> listEvalProjectProcessWaringPage(IPage iPage, EvalProjectProcessWaringPageQry evalProjectProcessWaringPageQry) {
+        QueryWrapper<EvalProjectProcessWaringDO> evalProjectProcessWaringDoQueryWrapper = new QueryWrapper<>();
+        if (ObjectUtil.isNotEmpty(evalProjectProcessWaringPageQry.getProjectId())) {
+            evalProjectProcessWaringDoQueryWrapper.eq("project_id", evalProjectProcessWaringPageQry.getProjectId());
+        }
+        if (ObjectUtil.isNotEmpty(evalProjectProcessWaringPageQry.getWaringStatus())) {
+            evalProjectProcessWaringDoQueryWrapper.eq("waring_status", evalProjectProcessWaringPageQry.getWaringStatus());
+        }
+        if (ObjectUtil.isNotEmpty(evalProjectProcessWaringPageQry.getProcessWaringStatus())) {
+            evalProjectProcessWaringDoQueryWrapper.eq("process_waring_status", evalProjectProcessWaringPageQry.getProcessWaringStatus());
+        }
+        if (ObjectUtil.isNotEmpty(evalProjectProcessWaringPageQry.getProcessWaringMsg())) {
+            evalProjectProcessWaringDoQueryWrapper.eq("process_waring_msg", evalProjectProcessWaringPageQry.getProcessWaringMsg());
+        }
+        if (ObjectUtil.isNotEmpty(evalProjectProcessWaringPageQry.getPersonnelWaringStatus())) {
+            evalProjectProcessWaringDoQueryWrapper.eq("personnel_waring_status", evalProjectProcessWaringPageQry.getPersonnelWaringStatus());
+        }
+        if (ObjectUtil.isNotEmpty(evalProjectProcessWaringPageQry.getPersonnelWaringMsg())) {
+            evalProjectProcessWaringDoQueryWrapper.eq("personnel_waring_msg", evalProjectProcessWaringPageQry.getPersonnelWaringMsg());
+        }
+        if (ObjectUtil.isNotEmpty(evalProjectProcessWaringPageQry.getEnv())) {
+            evalProjectProcessWaringDoQueryWrapper.eq("env", evalProjectProcessWaringPageQry.getEnv());
+        }
+        evalProjectProcessWaringDoQueryWrapper.eq("delete_enum", BooleanEnum.FALSE.getValue());
+        return evalProjectProcessWaringMapper.selectPage(iPage, evalProjectProcessWaringDoQueryWrapper);
+    }
+
+    @Override
+    public Boolean addEvalProjectProcessWaring(EvalProjectProcessWaringDO evalProjectProcessWaringDO) {
+        return super.save(evalProjectProcessWaringDO);
+    }
+
+    @Override
+    public Boolean updateEvalProjectProcessWaring(EvalProjectProcessWaringDO evalProjectProcessWaringDO) {
+        return super.updateById(evalProjectProcessWaringDO);
+    }
+
+    @Override
+    public Boolean deletedEvalProjectProcessWaringById(Long id) {
+        return super.removeEnById(id);
+    }
+
+    @Override
+    public Boolean deletedEvalProjectProcessWaringByIds(Long[] ids) {
+        return super.removeBatchEnByIds(Arrays.asList(ids));
+    }
+}

safety-eval-infrastructure/src/main/resources/mapper/EvalProjectProcessWaringMapper.xml

@@ -0,0 +1,51 @@
+<?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="org.qinan.safetyeval.infrastructure.persistence.mapper.EvalProjectProcessWaringMapper">
+    <resultMap type="org.qinan.safetyeval.infrastructure.persistence.domainobject.EvalProjectProcessWaringDO"
+               id="EvalProjectProcessWaringResult">
+        <id property="id" column="id"/>
+        <result property="orgId" column="org_id"/>
+        <result property="projectId" column="project_id"/>
+        <result property="waringStatus" column="waring_status"/>
+        <result property="processWaringStatus" column="process_waring_status"/>
+        <result property="processWaringMsg" column="process_waring_msg"/>
+        <result property="personnelWaringStatus" column="personnel_waring_status"/>
+        <result property="personnelWaringMsg" column="personnel_waring_msg"/>
+        <result property="deleteEnum" column="delete_enum"/>
+        <result property="remarks" column="remarks"/>
+        <result property="createName" column="create_name"/>
+        <result property="updateName" column="update_name"/>
+        <result property="tenantId" column="tenant_id"/>
+        <result property="version" column="version"/>
+        <result property="createTime" column="create_time"/>
+        <result property="updateTime" column="update_time"/>
+        <result property="createId" column="create_id"/>
+        <result property="updateId" column="update_id"/>
+        <result property="env" column="env"/>
+    </resultMap>
+
+    <sql id="selectEvalProjectProcessWaring">
+        select id,
+               org_id,
+               project_id,
+               waring_status,
+               process_waring_status,
+               process_waring_msg,
+               personnel_waring_status,
+               personnel_waring_msg,
+               delete_enum,
+               remarks,
+               create_name,
+               update_name,
+               tenant_id,
+               version,
+               create_time,
+               update_time,
+               create_id,
+               update_id,
+               env
+        from eval_project_process_waring
+    </sql>
+</mapper>