测试红外对射和AI识别告警
This commit is contained in:
parent
4321cbd179
commit
7e6ca8110f
@ -10,6 +10,7 @@ import com.alibaba.fastjson.JSONObject;
|
|||||||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
||||||
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
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.api.vo.Result;
|
||||||
import com.zhgd.jeecg.common.execption.OpenAlertException;
|
import com.zhgd.jeecg.common.execption.OpenAlertException;
|
||||||
import com.zhgd.redis.lock.RedisRepository;
|
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.CarPassRecordMapper;
|
||||||
import com.zhgd.xmgl.modules.car.mapper.CarTypeMapper;
|
import com.zhgd.xmgl.modules.car.mapper.CarTypeMapper;
|
||||||
import com.zhgd.xmgl.modules.car.service.impl.CarPassRecordServiceImpl;
|
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.Project;
|
||||||
import com.zhgd.xmgl.modules.project.entity.ProjectVideoConfig;
|
import com.zhgd.xmgl.modules.project.entity.ProjectVideoConfig;
|
||||||
import com.zhgd.xmgl.modules.project.mapper.ProjectMapper;
|
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.entity.*;
|
||||||
import com.zhgd.xmgl.modules.worker.mapper.EnterpriseInfoMapper;
|
import com.zhgd.xmgl.modules.worker.mapper.EnterpriseInfoMapper;
|
||||||
import com.zhgd.xmgl.modules.worker.mapper.UfaceDevMapper;
|
import com.zhgd.xmgl.modules.worker.mapper.UfaceDevMapper;
|
||||||
@ -116,6 +125,18 @@ public class HikvisionCall {
|
|||||||
@Autowired
|
@Autowired
|
||||||
private XzHikvisionSyncMapper xzHikvisionSyncMapper;
|
private XzHikvisionSyncMapper xzHikvisionSyncMapper;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private IAiAnalyseHardWareRecordService aiAnalyseHardWareRecordService;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private IAiAnalyseHardWareAlarmRecordService aiAnalyseHardWareAlarmRecordService;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private IFrontierProtectionDevAlarmService frontierProtectionDevAlarmService;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private FrontierProtectionDevService frontierProtectionDevService;
|
||||||
|
|
||||||
@Lazy
|
@Lazy
|
||||||
@Autowired
|
@Autowired
|
||||||
HikvisionCall hikvisionCall;
|
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<FrontierProtectionDevAlarm> 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.<FrontierProtectionDev>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<AiAnalyseHardWareAlarmRecord> 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.<AiAnalyseHardWareRecord>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();
|
return Result.ok();
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user