From f98bdee91f1c5e6a913cdd12da5d2ebe63eafc7d Mon Sep 17 00:00:00 2001
From: huwei <3313749341@qq.com>
Date: Fri, 31 Jul 2026 15:41:58 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E7=9B=91=E7=AE=A1=E7=AB=AF?=
 =?UTF-8?q?=E5=92=8C=E6=9C=BA=E6=9E=84=E7=AB=AF=E9=A6=96=E9=A1=B5=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../app/executor/regulator/RegulatorCockpitExecutor.java  | 2 +-
 .../waring/gateway/EvalProjectProcessWaringGateway.java   | 8 ++++++++
 .../gateway/EvalProjectProcessWaringGatewayImpl.java      | 5 +++++
 .../repository/EvalProjectProcessWaringRepository.java    | 8 ++++++++
 .../impl/EvalProjectProcessWaringRepositoryImpl.java      | 8 ++++++++
 5 files changed, 30 insertions(+), 1 deletion(-)

diff --git a/safety-eval-app/src/main/java/org/qinan/safetyeval/app/executor/regulator/RegulatorCockpitExecutor.java b/safety-eval-app/src/main/java/org/qinan/safetyeval/app/executor/regulator/RegulatorCockpitExecutor.java
index 8efa89e..795aeb3 100644
--- a/safety-eval-app/src/main/java/org/qinan/safetyeval/app/executor/regulator/RegulatorCockpitExecutor.java
+++ b/safety-eval-app/src/main/java/org/qinan/safetyeval/app/executor/regulator/RegulatorCockpitExecutor.java
@@ -21,7 +21,7 @@ import org.qinan.safetyeval.domain.entity.InspNoticeEntity;
 import org.qinan.safetyeval.domain.entity.OrgInfoEntity;
 import org.qinan.safetyeval.domain.entity.OrgPersonnelEntity;
 import org.qinan.safetyeval.domain.gateway.EvalProjectGateway;
-import org.qinan.safetyeval.domain.gateway.EvalProjectProcessWaringGateway;
+import org.qinan.safetyeval.domain.waring.gateway.EvalProjectProcessWaringGateway;
 import org.qinan.safetyeval.domain.gateway.EvalRiskAnalysisGateway;
 import org.qinan.safetyeval.domain.gateway.InspNoticeGateway;
 import org.qinan.safetyeval.domain.gateway.OrgInfoGateway;
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
index 699a80b..4475be9 100644
--- 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
@@ -41,4 +41,12 @@ public interface EvalProjectProcessWaringGateway {
      * @return 结果
      */
     Boolean deletedEvalProjectProcessWaringByIds(Long[] ids);
+
+    /**
+     * 检查项目是否存在过程预警
+     *
+     * @param projectId 项目ID
+     * @return 结果
+     */
+    Boolean checkProjectHasWaring(Long projectId);
 }
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
index f8b1158..7bb8796 100644
--- 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
@@ -45,4 +45,9 @@ public class EvalProjectProcessWaringGatewayImpl implements EvalProjectProcessWa
     public Boolean deletedEvalProjectProcessWaringByIds(Long[] ids) {
         return evalProjectProcessWaringRepository.deletedEvalProjectProcessWaringByIds(ids);
     }
+
+    @Override
+    public Boolean checkProjectHasWaring(Long projectId) {
+        return evalProjectProcessWaringRepository.checkProjectHasWaring(projectId);
+    }
 }
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
index a54a0a4..431565a 100644
--- 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
@@ -62,4 +62,12 @@ public interface EvalProjectProcessWaringRepository extends BaseRepository<EvalP
      */
     Boolean deletedEvalProjectProcessWaringByIds(Long[] ids);
 
+    /**
+     * 检查项目是否存在过程预警
+     *
+     * @param projectId 项目ID
+     * @return 结果
+     */
+    Boolean checkProjectHasWaring(Long projectId);
+
 }
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
index f90fa2e..088c187 100644
--- 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
@@ -78,4 +78,12 @@ public class EvalProjectProcessWaringRepositoryImpl extends BaseRepositoryImpl<E
     public Boolean deletedEvalProjectProcessWaringByIds(Long[] ids) {
         return super.removeBatchEnByIds(Arrays.asList(ids));
     }
+
+    @Override
+    public Boolean checkProjectHasWaring(Long projectId) {
+        return super.lambdaQuery()
+                .eq(EvalProjectProcessWaringDO::getProjectId, projectId)
+                .eq(EvalProjectProcessWaringDO::getDeleteEnum, BooleanEnum.FALSE.getValue())
+                .count() > 0;
+    }
 }