diff --git a/src/main/java/com/zhgd/xmgl/call/HikvisionCall.java b/src/main/java/com/zhgd/xmgl/call/HikvisionCall.java index e6f69cdc5..2f61c3dc2 100644 --- a/src/main/java/com/zhgd/xmgl/call/HikvisionCall.java +++ b/src/main/java/com/zhgd/xmgl/call/HikvisionCall.java @@ -10,6 +10,7 @@ import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; +import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.zhgd.jeecg.common.api.vo.Result; import com.zhgd.jeecg.common.execption.OpenAlertException; import com.zhgd.redis.lock.RedisRepository; @@ -24,9 +25,17 @@ import com.zhgd.xmgl.modules.car.mapper.CarInfoMapper; import com.zhgd.xmgl.modules.car.mapper.CarPassRecordMapper; import com.zhgd.xmgl.modules.car.mapper.CarTypeMapper; import com.zhgd.xmgl.modules.car.service.impl.CarPassRecordServiceImpl; +import com.zhgd.xmgl.modules.frontier.entity.FrontierProtectionDev; +import com.zhgd.xmgl.modules.frontier.entity.FrontierProtectionDevAlarm; +import com.zhgd.xmgl.modules.frontier.service.FrontierProtectionDevService; +import com.zhgd.xmgl.modules.frontier.service.IFrontierProtectionDevAlarmService; import com.zhgd.xmgl.modules.project.entity.Project; import com.zhgd.xmgl.modules.project.entity.ProjectVideoConfig; import com.zhgd.xmgl.modules.project.mapper.ProjectMapper; +import com.zhgd.xmgl.modules.video.entity.AiAnalyseHardWareAlarmRecord; +import com.zhgd.xmgl.modules.video.entity.AiAnalyseHardWareRecord; +import com.zhgd.xmgl.modules.video.service.IAiAnalyseHardWareAlarmRecordService; +import com.zhgd.xmgl.modules.video.service.IAiAnalyseHardWareRecordService; import com.zhgd.xmgl.modules.worker.entity.*; import com.zhgd.xmgl.modules.worker.mapper.EnterpriseInfoMapper; import com.zhgd.xmgl.modules.worker.mapper.UfaceDevMapper; @@ -116,6 +125,18 @@ public class HikvisionCall { @Autowired private XzHikvisionSyncMapper xzHikvisionSyncMapper; + @Autowired + private IAiAnalyseHardWareRecordService aiAnalyseHardWareRecordService; + + @Autowired + private IAiAnalyseHardWareAlarmRecordService aiAnalyseHardWareAlarmRecordService; + + @Autowired + private IFrontierProtectionDevAlarmService frontierProtectionDevAlarmService; + + @Autowired + private FrontierProtectionDevService frontierProtectionDevService; + @Lazy @Autowired HikvisionCall hikvisionCall; @@ -304,6 +325,35 @@ public class HikvisionCall { } } } + } else if (Objects.equals(ability, "event_ias")) { + log.info("红外对射预警事件========" + paramsJo); +// JSONArray eventsJa = paramsJo.getJSONArray("events"); +// List frontierProtectionDevAlarmList = new ArrayList<>(); +// for (int i = 0; i < eventsJa.size(); i++) { +// JSONObject obj = eventsJa.getJSONObject(i); +// String devCode = obj.getString("srcIndex"); +// FrontierProtectionDev frontierProtectionDev = frontierProtectionDevService.getOne(Wrappers.lambdaQuery().eq(FrontierProtectionDev::getDevSn, devCode)); +// FrontierProtectionDevAlarm frontierProtectionDevAlarm = new FrontierProtectionDevAlarm(); +// frontierProtectionDevAlarm.setDevSn(frontierProtectionDev.getDevSn()); +// frontierProtectionDevAlarmList.add(frontierProtectionDevAlarm); +// } +// frontierProtectionDevAlarmService.saveBatch(frontierProtectionDevAlarmList); + + } else if (Objects.equals(ability, "event_vss")) { + log.info("AI识别告警=======" + paramsJo); +// JSONArray eventsJa = paramsJo.getJSONArray("events"); +// List aiAnalyseHardWareAlarmRecords = new ArrayList<>(); +// for (int i = 0; i < eventsJa.size(); i++) { +// JSONObject obj = eventsJa.getJSONObject(i); +// String devCode = obj.getString("srcIndex"); +// AiAnalyseHardWareRecord aiAnalyseHardWareRecord = aiAnalyseHardWareRecordService.getOne(Wrappers.lambdaQuery().eq(AiAnalyseHardWareRecord::getHardwareId, devCode)); +// AiAnalyseHardWareAlarmRecord aiAnalyseHardWareAlarmRecord = new AiAnalyseHardWareAlarmRecord(); +// aiAnalyseHardWareAlarmRecord.setHardwareId(aiAnalyseHardWareRecord.getHardwareId()); +// aiAnalyseHardWareAlarmRecord.setStatus(1); +// aiAnalyseHardWareAlarmRecord.setProjectSn(aiAnalyseHardWareRecord.getProjectSn()); +// aiAnalyseHardWareAlarmRecords.add(aiAnalyseHardWareAlarmRecord); +// } +// aiAnalyseHardWareAlarmRecordService.saveBatch(aiAnalyseHardWareAlarmRecords); } } return Result.ok();