From c177639aaeae84f1e8c86c959f5a98057da313a6 Mon Sep 17 00:00:00 2001
From: pengjie <17373303529@163.com>
Date: Thu, 25 Apr 2024 13:58:13 +0800
Subject: [PATCH] =?UTF-8?q?AI=E6=8E=A5=E5=8F=A3=E5=AF=B9=E6=8E=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../basicdata/controller/APIController.java   |  7 ++++++
 .../entity/AiAnalyseHardWareAlarmRecord.java  | 15 ++++++++++++
 .../IAiAnalyseHardWareAlarmRecordService.java |  2 ++
 ...AnalyseHardWareAlarmRecordServiceImpl.java | 24 +++++++++++++++++++
 4 files changed, 48 insertions(+)

diff --git a/src/main/java/com/zhgd/xmgl/modules/basicdata/controller/APIController.java b/src/main/java/com/zhgd/xmgl/modules/basicdata/controller/APIController.java
index 10558a511..6b9bf5e71 100644
--- a/src/main/java/com/zhgd/xmgl/modules/basicdata/controller/APIController.java
+++ b/src/main/java/com/zhgd/xmgl/modules/basicdata/controller/APIController.java
@@ -125,6 +125,13 @@ public class APIController {
         return Result.ok();
     }
 
+    @ApiOperation(value = "保存AI分析硬件设备报警记录", notes = "保存AI分析硬件设备报警记录", httpMethod = "POST")
+    @PostMapping(value = "/saveXzHardWareAlarm", produces = {"application/json;charset=UTF-8"})
+    public Result saveXzAiAnalyseHardWareAlarmRecord(@RequestBody final com.alibaba.fastjson.JSONObject json) {
+        aiAnalyseHardWareAlarmRecordService.saveXzAiAnalyseHardWareAlarmRecord(json);
+        return Result.ok();
+    }
+
     @ApiOperation(value = "保存视频分析结果", notes = "保存视频分析结果", httpMethod = "POST")
     @PostMapping(value = "/saveVideoAnalysisResult", produces = {"application/json;charset=UTF-8"})
     public Result saveVideoAnalysisResult(@RequestBody com.alibaba.fastjson.JSONObject json) {
diff --git a/src/main/java/com/zhgd/xmgl/modules/video/entity/AiAnalyseHardWareAlarmRecord.java b/src/main/java/com/zhgd/xmgl/modules/video/entity/AiAnalyseHardWareAlarmRecord.java
index 3a436c8f2..261f8d9cf 100644
--- a/src/main/java/com/zhgd/xmgl/modules/video/entity/AiAnalyseHardWareAlarmRecord.java
+++ b/src/main/java/com/zhgd/xmgl/modules/video/entity/AiAnalyseHardWareAlarmRecord.java
@@ -57,6 +57,21 @@ public class AiAnalyseHardWareAlarmRecord implements Serializable {
     @Excel(name = "图片路径", width = 15)
     @ApiModelProperty(value = "图片路径")
     private java.lang.String imageUrl;
+
+    /**
+     * 录播视频
+     */
+    @Excel(name = "录播视频", width = 15)
+    @ApiModelProperty(value = "录播视频")
+    private java.lang.String alarmVideo;
+
+    /**
+     * 告警描述
+     */
+    @Excel(name = "告警描述", width = 15)
+    @ApiModelProperty(value = "告警描述")
+    private java.lang.String alarmDesc;
+
     /**
      * 类型 1-烟感报警，2-明火报警，3-人员到底报警，4-未带安全帽报警，5-区域入侵报警，6-越界入侵报警，7-人员聚集报警， 8-反光衣、9-裸土覆盖,13口罩识别,14徘徊预警,15物体滞留监测,16绊线监测
      */
diff --git a/src/main/java/com/zhgd/xmgl/modules/video/service/IAiAnalyseHardWareAlarmRecordService.java b/src/main/java/com/zhgd/xmgl/modules/video/service/IAiAnalyseHardWareAlarmRecordService.java
index 6b24dab3f..1c7b7e835 100644
--- a/src/main/java/com/zhgd/xmgl/modules/video/service/IAiAnalyseHardWareAlarmRecordService.java
+++ b/src/main/java/com/zhgd/xmgl/modules/video/service/IAiAnalyseHardWareAlarmRecordService.java
@@ -27,6 +27,8 @@ public interface IAiAnalyseHardWareAlarmRecordService extends IService<AiAnalyse
 
     void saveAiAnalyseHardWareAlarmRecord(JSONObject body);
 
+    void saveXzAiAnalyseHardWareAlarmRecord(JSONObject body);
+
     List<AiAnalyseHardWareAlarmTrendVo> selectAiAnalyseHardWareAlarmTrendList(Map<String, Object> map);
 
     List<AiAnalyseHardWareAlarmRecord> selectAiAnalyseHardWareAlarmList(Map<String, Object> map);
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 da65e33b2..cd099e37b 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
@@ -147,6 +147,30 @@ public class AiAnalyseHardWareAlarmRecordServiceImpl extends ServiceImpl<AiAnaly
         asyncAiAnalyse.sendAiAnalyse(aiAnalyseHardWareAlarmRecord);
     }
 
+    @Override
+    public void saveXzAiAnalyseHardWareAlarmRecord(JSONObject body) {
+        log.info("调用AiAnalyseHardWareAlarmRecordServiceImpl#saveXzAiAnalyseHardWareAlarmRecord，参数为：{}", body);
+        QueryWrapper<AiAnalyseHardWareRecord> queryWrapper = new QueryWrapper<>();
+        queryWrapper.lambda().eq(AiAnalyseHardWareRecord::getHardwareId, body.getString("deviceCode"));
+        AiAnalyseHardWareRecord aiAnalyseHardWareRecord = aiAnalyseHardWareRecordMapper.selectOne(queryWrapper);
+        if (aiAnalyseHardWareRecord == null) {
+            throw new OpenAlertException(MessageUtil.get("EquipmentNumIncorrectErr"));
+        }
+        AiAnalyseHardWareAlarmRecord aiAnalyseHardWareAlarmRecord = new AiAnalyseHardWareAlarmRecord();
+        aiAnalyseHardWareAlarmRecord.setCreateTime(body.getString("alarmTime"));
+        aiAnalyseHardWareAlarmRecord.setAlarmType(Integer.parseInt(body.getString("eventId")));
+        aiAnalyseHardWareAlarmRecord.setHardwareId(aiAnalyseHardWareRecord.getHardwareId());
+        aiAnalyseHardWareAlarmRecord.setHardwareName(aiAnalyseHardWareRecord.getHardwareName());
+        aiAnalyseHardWareAlarmRecord.setAlarmVideo(body.getString("alarmVideo"));
+        aiAnalyseHardWareAlarmRecord.setProjectSn(aiAnalyseHardWareRecord.getProjectSn());
+        aiAnalyseHardWareAlarmRecord.setStatus(1);
+        aiAnalyseHardWareAlarmRecord.setImageUrl(body.getString("alarmImage"));
+        aiAnalyseHardWareAlarmRecord.setAlarmDesc(body.getString("alarmDesc"));
+        aiAnalyseHardWareAlarmRecordMapper.insert(aiAnalyseHardWareAlarmRecord);
+        //将数据通过MQTT转发到前台
+        asyncAiAnalyse.sendAiAnalyse(aiAnalyseHardWareAlarmRecord);
+    }
+
 
     @Override
     public List<AiAnalyseHardWareAlarmTrendVo> selectAiAnalyseHardWareAlarmTrendList(Map<String, Object> map) {