视频告警事件

yudao-module-pms/yudao-module-pms-biz/src/main/java/cn/iocoder/yudao/module/pms/hik/HikIsapiController.java

@@ -29,13 +29,10 @@ public class HikIsapiController {
     @PermitAll
     public ResponseEntity<Map<String, Object>> handleAlarmCallback(
             @RequestBody String jsonPayload) {
-        
         log.info("接收到告警回调请求: {}", jsonPayload);
-        
         try {
             // 处理告警
             hikIsapiService.handleAlarmCallback(jsonPayload);
-            
             Map<String, Object> response = ImmutableMap.of(
                 "code", 0,
                 "message", "success",
@@ -43,16 +40,13 @@ public class HikIsapiController {
             );
             
             return ResponseEntity.ok(response);
-            
         } catch (Exception e) {
             log.error("处理告警回调失败", e);
-            
             Map<String, Object> response = ImmutableMap.of(
                 "code", -1,
                 "message", e.getMessage(),
                 "timestamp", System.currentTimeMillis()
             );
-            
             return ResponseEntity.badRequest().body(response);
         }
     }

yudao-module-pms/yudao-module-pms-biz/src/main/java/cn/iocoder/yudao/module/pms/hik/HikIsapiService.java

@@ -134,11 +134,11 @@ public class HikIsapiService {
     public void handleAlarmCallback(String jsonPayload) {
         try {
             log.info("收到告警回调: {}", jsonPayload);
-
             // 解析JSON
             IotVideoAlarmSaveReqVO alarmEvent = objectMapper.readValue(
                 jsonPayload, IotVideoAlarmSaveReqVO.class);
-            if (!"AIOP_Video".equals(alarmEvent.getEventType())) {
+            //安全帽检测与抽烟打电话
+            if ("safetyHelmetDetection".equals(alarmEvent.getEventType()) || "抽烟打电话".equals(alarmEvent.getMpName())) {
                 // 保存到数据库
                 iotVideoAlarmService.createIotVideoAlarm(alarmEvent);
                 // 触发告警处理流程