diff --git a/docs/db/phase2/init-phase2.sql b/docs/db/phase2/init-phase2.sql index 94df832..ddf4bfa 100644 --- a/docs/db/phase2/init-phase2.sql +++ b/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; -- ============================================= diff --git a/safety-eval-adapter/src/main/java/org/qinan/safetyeval/adapter/web/EvalProjectProcessWaringController.java b/safety-eval-adapter/src/main/java/org/qinan/safetyeval/adapter/web/EvalProjectProcessWaringController.java new file mode 100644 index 0000000..76f34e2 --- /dev/null +++ b/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 list(@Validated EvalProjectProcessWaringPageQry qry) { + return evalProjectProcessWaringServiceI.listEvalProjectProcessWaringPage(qry); + } + + @GetMapping("/{id}") + @ApiOperation("查询项目预警-归档前预警详情页面") + public SingleResponse 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(); + } + +} diff --git a/safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/convertor/EvalProjectProcessWaringCmdConvertor.java b/safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/convertor/EvalProjectProcessWaringCmdConvertor.java new file mode 100644 index 0000000..ca5fddc --- /dev/null +++ b/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); +} diff --git a/safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/executor/command/EvalProjectProcessWaringAddCmdExe.java b/safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/executor/command/EvalProjectProcessWaringAddCmdExe.java new file mode 100644 index 0000000..9aa7168 --- /dev/null +++ b/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; + } +} diff --git a/safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/executor/command/EvalProjectProcessWaringDelCmdExe.java b/safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/executor/command/EvalProjectProcessWaringDelCmdExe.java new file mode 100644 index 0000000..5c5252e --- /dev/null +++ b/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; + } + + +} diff --git a/safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/executor/command/EvalProjectProcessWaringUpdateCmdExe.java b/safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/executor/command/EvalProjectProcessWaringUpdateCmdExe.java new file mode 100644 index 0000000..cfee601 --- /dev/null +++ b/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; + } +} diff --git a/safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/executor/query/EvalProjectProcessWaringListQueryExe.java b/safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/executor/query/EvalProjectProcessWaringListQueryExe.java new file mode 100644 index 0000000..4fcae52 --- /dev/null +++ b/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); + } + +} diff --git a/safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/executor/query/EvalProjectProcessWaringPageQueryExe.java b/safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/executor/query/EvalProjectProcessWaringPageQueryExe.java new file mode 100644 index 0000000..5e2c670 --- /dev/null +++ b/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 execute(EvalProjectProcessWaringPageQry evalProjectProcessWaringPageQry) { + return evalProjectProcessWaringQueryService.listEvalProjectProcessWaringPage(evalProjectProcessWaringPageQry); + } + +} diff --git a/safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/service/EvalProjectProcessWaringServiceI.java b/safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/service/EvalProjectProcessWaringServiceI.java new file mode 100644 index 0000000..10b80ef --- /dev/null +++ b/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 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); + + +} diff --git a/safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/service/impl/EvalProjectProcessWaringServiceImpl.java b/safety-eval-app/src/main/java/org/qinan/safetyeval/app/waring/service/impl/EvalProjectProcessWaringServiceImpl.java new file mode 100644 index 0000000..41cc305 --- /dev/null +++ b/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 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); + } + +} diff --git a/safety-eval-client/src/main/java/org/qinan/safetyeval/client/waring/request/EvalProjectProcessWaringAddCmd.java b/safety-eval-client/src/main/java/org/qinan/safetyeval/client/waring/request/EvalProjectProcessWaringAddCmd.java new file mode 100644 index 0000000..81491d5 --- /dev/null +++ b/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; + +} diff --git a/safety-eval-client/src/main/java/org/qinan/safetyeval/client/waring/request/EvalProjectProcessWaringPageQry.java b/safety-eval-client/src/main/java/org/qinan/safetyeval/client/waring/request/EvalProjectProcessWaringPageQry.java new file mode 100644 index 0000000..51e180a --- /dev/null +++ b/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; + +} diff --git a/safety-eval-client/src/main/java/org/qinan/safetyeval/client/waring/request/EvalProjectProcessWaringUpdateCmd.java b/safety-eval-client/src/main/java/org/qinan/safetyeval/client/waring/request/EvalProjectProcessWaringUpdateCmd.java new file mode 100644 index 0000000..8e6a064 --- /dev/null +++ b/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; +} diff --git a/safety-eval-client/src/main/java/org/qinan/safetyeval/client/waring/response/EvalProjectProcessWaringCo.java b/safety-eval-client/src/main/java/org/qinan/safetyeval/client/waring/response/EvalProjectProcessWaringCo.java new file mode 100644 index 0000000..435c2dd --- /dev/null +++ b/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; +} diff --git a/safety-eval-domain/src/main/java/org/qinan/safetyeval/domain/waring/ability/EvalProjectProcessWaringAbility.java b/safety-eval-domain/src/main/java/org/qinan/safetyeval/domain/waring/ability/EvalProjectProcessWaringAbility.java new file mode 100644 index 0000000..c2ca7e4 --- /dev/null +++ b/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); + } +} diff --git a/safety-eval-domain/src/main/java/org/qinan/safetyeval/domain/waring/gateway/EvalProjectProcessWaringGateway.java b/safety-eval-domain/src/main/java/org/qinan/safetyeval/domain/waring/gateway/EvalProjectProcessWaringGateway.java new file mode 100644 index 0000000..699a80b --- /dev/null +++ b/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); +} diff --git a/safety-eval-domain/src/main/java/org/qinan/safetyeval/domain/waring/model/EvalProjectProcessWaringE.java b/safety-eval-domain/src/main/java/org/qinan/safetyeval/domain/waring/model/EvalProjectProcessWaringE.java new file mode 100644 index 0000000..0c9f100 --- /dev/null +++ b/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); + } +} diff --git a/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/convertor/EvalProjectProcessWaringDoConvertor.java b/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/convertor/EvalProjectProcessWaringDoConvertor.java new file mode 100644 index 0000000..8713803 --- /dev/null +++ b/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 converDosToCos(List evalProjectProcessWaringDos); +} diff --git a/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/gateway/EvalProjectProcessWaringGatewayImpl.java b/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/gateway/EvalProjectProcessWaringGatewayImpl.java new file mode 100644 index 0000000..f8b1158 --- /dev/null +++ b/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); + } +} diff --git a/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/domainobject/EvalProjectProcessWaringDO.java b/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/domainobject/EvalProjectProcessWaringDO.java new file mode 100644 index 0000000..b606a16 --- /dev/null +++ b/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; +} diff --git a/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/mapper/EvalProjectProcessWaringMapper.java b/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/mapper/EvalProjectProcessWaringMapper.java new file mode 100644 index 0000000..c1b7903 --- /dev/null +++ b/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 { +} diff --git a/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/queryservice/EvalProjectProcessWaringQueryService.java b/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/queryservice/EvalProjectProcessWaringQueryService.java new file mode 100644 index 0000000..11ef073 --- /dev/null +++ b/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 listEvalProjectProcessWaringPage(EvalProjectProcessWaringPageQry evalProjectProcessWaringPageQry); +} diff --git a/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/queryservice/impl/EvalProjectProcessWaringQueryServiceImpl.java b/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/queryservice/impl/EvalProjectProcessWaringQueryServiceImpl.java new file mode 100644 index 0000000..441ed1e --- /dev/null +++ b/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 listEvalProjectProcessWaringPage(EvalProjectProcessWaringPageQry evalProjectProcessWaringPageQry) { + IPage evalProjectProcessWaringDoPage = evalProjectProcessWaringRepository.listEvalProjectProcessWaringPage(PageHelper.queryToPage(evalProjectProcessWaringPageQry), evalProjectProcessWaringPageQry); + List evalProjectProcessWaringCoS = evalProjectProcessWaringDoConvertor.converDosToCos(evalProjectProcessWaringDoPage.getRecords()); + return PageHelper.pageToResponse(evalProjectProcessWaringDoPage, evalProjectProcessWaringCoS); + } + +} diff --git a/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/repository/EvalProjectProcessWaringRepository.java b/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/repository/EvalProjectProcessWaringRepository.java new file mode 100644 index 0000000..a54a0a4 --- /dev/null +++ b/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 { + /** + * 根据ID查找 + * + * @param id 项目预警-归档前预警ID + * @return + */ + EvalProjectProcessWaringDO getById(Long id); + + /** + * 分页查找项目预警-归档前预警对象 + * + * @param iPage 分页对象 + * @param evalProjectProcessWaringPageQry 条件对象 + * @return ipage + */ + IPage 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); + +} diff --git a/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/repository/impl/EvalProjectProcessWaringRepositoryImpl.java b/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/persistence/repository/impl/EvalProjectProcessWaringRepositoryImpl.java new file mode 100644 index 0000000..f90fa2e --- /dev/null +++ b/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 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 listEvalProjectProcessWaringPage(IPage iPage, EvalProjectProcessWaringPageQry evalProjectProcessWaringPageQry) { + QueryWrapper 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)); + } +} diff --git a/safety-eval-infrastructure/src/main/resources/mapper/EvalProjectProcessWaringMapper.xml b/safety-eval-infrastructure/src/main/resources/mapper/EvalProjectProcessWaringMapper.xml new file mode 100644 index 0000000..bf28f69 --- /dev/null +++ b/safety-eval-infrastructure/src/main/resources/mapper/EvalProjectProcessWaringMapper.xml @@ -0,0 +1,51 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + 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 + + \ No newline at end of file