package com.ycl.task;
|
|
import com.alibaba.fastjson2.JSONObject;
|
import com.mongodb.client.result.DeleteResult;
|
import com.ycl.platform.domain.param.HK.*;
|
import com.ycl.platform.domain.result.HK.*;
|
import com.ycl.platform.service.ICheckIndexCarService;
|
import com.ycl.platform.service.ICheckIndexFaceService;
|
import com.ycl.platform.service.ICheckIndexVideoService;
|
import com.ycl.platform.service.IYwThresholdService;
|
import com.ycl.utils.DateUtils;
|
import constant.ApiConstants;
|
import com.ycl.feign.HKClient;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.mongodb.core.MongoTemplate;
|
import org.springframework.data.mongodb.core.query.Criteria;
|
import org.springframework.data.mongodb.core.query.Query;
|
import org.springframework.stereotype.Component;
|
import org.springframework.util.CollectionUtils;
|
import org.springframework.util.unit.DataUnit;
|
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.List;
|
|
|
@Slf4j
|
@Component("HKTask")
|
public class HKTask {
|
|
@Autowired
|
private MongoTemplate mongoTemplate;
|
@Autowired
|
private HKClient hkClient;
|
@Autowired
|
private IYwThresholdService ywThresholdService;
|
@Autowired
|
private ICheckIndexFaceService checkIndexFaceService;
|
@Autowired
|
private ICheckIndexCarService checkIndexCarService;
|
@Autowired
|
private ICheckIndexVideoService checkIndexVideoService;
|
|
//车辆设备全检指标监测结果
|
public void VehicleDeviceInspectionTask() {
|
log.info("开始执行车辆设备全检指标监测结果数据同步");
|
VehicleDeviceInspectionParam param = new VehicleDeviceInspectionParam();
|
param.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate());
|
JSONObject jsonObject = hkClient.VehicleDeviceInspection(param);
|
List<VehicleDeviceInspectionResult> list = getDataList(jsonObject, VehicleDeviceInspectionResult.class, "车辆设备全检指标监测结果数据为空");
|
if (!CollectionUtils.isEmpty(list)) {
|
//如果存在之前的数据先删除
|
Query query = new Query(Criteria.where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
|
DeleteResult result = mongoTemplate.remove(query, VehicleDeviceInspectionResult.class);
|
//存放在mongo中
|
mongoTemplate.insert(list);
|
//同步的数据进行工单阈值处理
|
ywThresholdService.carCheck(list);
|
}
|
log.info("结束车辆设备全检指标监测结果数据同步");
|
}
|
|
//人脸设备全检指标监测结果
|
public void FaceDeviceInspectionTask() {
|
log.info("开始执行人脸设备全检指标监测结果数据同步");
|
FaceDeviceInspectionParam param = new FaceDeviceInspectionParam();
|
param.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate());
|
JSONObject jsonObject = hkClient.FaceDeviceInspection(param);
|
List<FaceDeviceInspectionResult> list = getDataList(jsonObject, FaceDeviceInspectionResult.class, "人脸设备全检指标监测结果数据为空");
|
if (!CollectionUtils.isEmpty(list)) {
|
//如果存在之前的数据先删除
|
Query query = new Query(Criteria.where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
|
DeleteResult result = mongoTemplate.remove(query, FaceDeviceInspectionResult.class);
|
//存放在mongo中
|
mongoTemplate.insert(list);
|
//同步的数据进行工单阈值处理
|
//TODO:可能有重复工单
|
ywThresholdService.faceCheck(list);
|
}
|
log.info("结束人脸设备全检指标监测结果数据同步");
|
}
|
|
|
//抓拍数据量监测结果
|
public void SnapshotDataMonitorTask() {
|
log.info("开始执行抓拍数据量检测结果数据同步");
|
/** 车辆数据 */
|
SnapshotDataMonitorParam carParam = new SnapshotDataMonitorParam();
|
carParam.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DATATYPE_CAR);
|
JSONObject carJsonObject = hkClient.SnapshotDataMonitor(carParam);
|
List<SnapshotDataMonitorResult> carList = getDataList(carJsonObject, SnapshotDataMonitorResult.class, "车辆抓拍数据量检测结果数据");
|
if (!CollectionUtils.isEmpty(carList)) {
|
//如果今天存在之前的数据先删除
|
Query query = new Query(Criteria
|
.where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))
|
.and("dataType").is(ApiConstants.HK_DATATYPE_CAR));
|
DeleteResult result = mongoTemplate.remove(query, SnapshotDataMonitorResult.class);
|
//存放在mongo中
|
carList.forEach(item->item.setDataType(ApiConstants.HK_DATATYPE_CAR));
|
mongoTemplate.insert(carList);
|
}
|
|
/** 人脸数据 */
|
SnapshotDataMonitorParam faceParam = new SnapshotDataMonitorParam();
|
faceParam.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate()).setDataType(ApiConstants.HK_DATATYPE_FACE);
|
JSONObject faceJsonObject = hkClient.SnapshotDataMonitor(carParam);
|
List<SnapshotDataMonitorResult> faceList = getDataList(faceJsonObject, SnapshotDataMonitorResult.class, "人脸抓拍数据量检测结果数据为空");
|
if (!CollectionUtils.isEmpty(faceList)) {
|
//如果今天存在之前的数据先删除
|
Query query = new Query(Criteria
|
.where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date()))
|
.and("dataType").is(ApiConstants.HK_DATATYPE_FACE));
|
DeleteResult result = mongoTemplate.remove(query, SnapshotDataMonitorResult.class);
|
//存放在mongo中
|
carList.forEach(item->item.setDataType(ApiConstants.HK_DATATYPE_FACE));
|
mongoTemplate.insert(faceList);
|
}
|
//TODO:工单
|
log.info("结束抓拍数据量检测结果数据同步");
|
}
|
|
|
//一机一档
|
public void task2() {
|
//联网卡口设备目录一致率
|
|
}
|
|
//采集设备属性监测结果(人脸)
|
public void monitorDetailTask() {
|
log.info("开始执行采集设备属性监测结果数据同步");
|
//采集设备属性监测结果
|
MonitoringDetailParam param = new MonitoringDetailParam();
|
param.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate());
|
JSONObject jsonObject = hkClient.monitorDetail(param);
|
List<MonitoringDetailResult> faceList = getDataList(jsonObject, MonitoringDetailResult.class, "采集设备属性监测结果数据为空");
|
if (!CollectionUtils.isEmpty(faceList)) {
|
//如果今天存在之前的数据先删除
|
Query query = new Query(Criteria
|
.where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
|
DeleteResult result = mongoTemplate.remove(query, SnapshotDataMonitorResult.class);
|
//存放在mongo中
|
mongoTemplate.insert(faceList);
|
}
|
//TODO:工单处理
|
log.info("结束采集设备属性监测结果数据同步");
|
}
|
|
//卡口属性监测结果
|
public void crossDetailTask() {
|
log.info("开始执行卡口属性监测结果数据同步");
|
//车辆卡口信息采集准确率
|
CrossDetailParam param = new CrossDetailParam();
|
param.setPageNO(ApiConstants.pageNo).setPageSize(ApiConstants.pageSize).setDate(DateUtils.getDate());
|
JSONObject jsonObject = hkClient.crossDetail(param);
|
List<CrossDetailResult> faceList = getDataList(jsonObject, CrossDetailResult.class, "卡口属性监测结果数据为空");
|
if (!CollectionUtils.isEmpty(faceList)) {
|
//如果今天存在之前的数据先删除
|
Query query = new Query(Criteria
|
.where("createTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
|
DeleteResult result = mongoTemplate.remove(query, SnapshotDataMonitorResult.class);
|
//存放在mongo中
|
mongoTemplate.insert(faceList);
|
}
|
//TODO:工单处理
|
log.info("结束卡口属性监测结果数据同步");
|
}
|
|
//数据完整性监测结果
|
public void task4() {
|
//车辆卡口设备抓拍数据完整性
|
}
|
|
//属性识别准确监测结果
|
public void task5() {
|
//车辆卡口设备抓拍数据完整性
|
}
|
|
//车辆设备全检指标监测结果
|
public void task6() {
|
//车辆卡口设备时钟准确性
|
}
|
|
//抓拍数据时延监测结果
|
public void task7() {
|
//车辆卡口设备抓拍数据上传及时性
|
}
|
|
//图片访问监测结果
|
public void task8() {
|
//车辆卡口信息采集准确率
|
|
//车辆卡口设备url可用性
|
}
|
|
//解析数据
|
private <T> List<T> getDataList(JSONObject faceJsonObject, Class<T> resultClass, String message) {
|
if (faceJsonObject != null && ApiConstants.successCode.equals(faceJsonObject.getString("code"))) {
|
JSONObject data = faceJsonObject.getJSONObject("data");
|
if (data == null) {
|
log.error(message, faceJsonObject);
|
return null;
|
}
|
List<T> list = data.getList("list", resultClass);
|
if (CollectionUtils.isEmpty(list)) {
|
log.error(message, data);
|
return null;
|
}
|
for (T t : list) {
|
if (t instanceof BaseResult) {
|
((BaseResult) t).setCreateTime(new Date());
|
}
|
}
|
return list;
|
} else {
|
log.error(message);
|
}
|
return null;
|
}
|
}
|
