From bfeb513f7afa4e2cb7d51e2316edf0c5a9a51da3 Mon Sep 17 00:00:00 2001
From: guoshengxiong <1923636941@qq.com>
Date: Thu, 7 Nov 2024 15:18:43 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9C=A8=E5=9E=92Ai=E6=8E=A8=E9=80=81=E6=98=AF?=
 =?UTF-8?q?=E5=90=A6=E7=AE=A1=E7=90=86=E5=91=98bug=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/zhgd/xmgl/modules/project/entity/Project.java | 4 ++--
 .../impl/AiAnalyseHardWareAlarmRecordServiceImpl.java      | 7 ++++++-
 2 files changed, 8 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/zhgd/xmgl/modules/project/entity/Project.java b/src/main/java/com/zhgd/xmgl/modules/project/entity/Project.java
index ea879027e..c5e5cc335 100644
--- a/src/main/java/com/zhgd/xmgl/modules/project/entity/Project.java
+++ b/src/main/java/com/zhgd/xmgl/modules/project/entity/Project.java
@@ -325,8 +325,8 @@ public class Project implements Serializable {
     private Integer enableWorkerSafeWatch;
     @ApiModelProperty(value = "安全履职报警推送时间")
     private String workerSafeWatchTime;
-
-
+    @ApiModelProperty(value = "是否需要项目管理员做AI抓拍初筛")
+    private Integer aiAlarmNeedManageApprove;
     /**
      * runde平台token
      */
diff --git a/src/main/java/com/zhgd/xmgl/modules/video/service/impl/AiAnalyseHardWareAlarmRecordServiceImpl.java b/src/main/java/com/zhgd/xmgl/modules/video/service/impl/AiAnalyseHardWareAlarmRecordServiceImpl.java
index 804d2c338..2f5aeb6a8 100644
--- a/src/main/java/com/zhgd/xmgl/modules/video/service/impl/AiAnalyseHardWareAlarmRecordServiceImpl.java
+++ b/src/main/java/com/zhgd/xmgl/modules/video/service/impl/AiAnalyseHardWareAlarmRecordServiceImpl.java
@@ -17,7 +17,6 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.zhgd.jeecg.common.api.vo.Result;
 import com.zhgd.jeecg.common.execption.OpenAlertException;
 import com.zhgd.xmgl.async.AsyncAiAnalyse;
 import com.zhgd.xmgl.base.entity.vo.SectorOneVo;
@@ -137,6 +136,9 @@ public class AiAnalyseHardWareAlarmRecordServiceImpl extends ServiceImpl<AiAnaly
     @Lazy
     @Autowired
     private UserEnterpriseServiceImpl userEnterpriseService;
+    @Lazy
+    @Autowired
+    private IAiAnalyseHardWareAlarmRecordService aiAnalyseHardWareAlarmRecordService;
 
     @Override
     public IPage<AiAnalyseHardWareAlarmRecord> queryAiAnalyseHardWareAlarmPageList(Map<String, Object> map) {
@@ -267,6 +269,9 @@ public class AiAnalyseHardWareAlarmRecordServiceImpl extends ServiceImpl<AiAnaly
         aiAnalyseHardWareAlarmRecordMapper.insert(aiAnalyseHardWareAlarmRecord);
         //将数据通过MQTT转发到前台
         asyncAiAnalyse.sendAiAnalyse(aiAnalyseHardWareAlarmRecord, Cts.PROJECT_LEVEL);
+        if (Objects.equals(projectInfoBySn.getAiAlarmNeedManageApprove(), 0)) {
+            aiAnalyseHardWareAlarmRecordService.violationPush(aiAnalyseHardWareAlarmRecord.getId());
+        }
     }
 
     @Override