zgyw.git - Gitblit

			@@ -3,7 +3,6 @@
			import com.alibaba.fastjson2.JSONObject;
			import com.mongodb.client.result.DeleteResult;
			import com.ycl.feign.UYClient;
			import com.ycl.platform.domain.entity.TMonitor;
			import com.ycl.platform.domain.entity.WorkOrder;
			import com.ycl.platform.domain.param.UY.ImageDetectionParam;
			import com.ycl.platform.domain.param.UY.MonitorQualifyParam;
			@@ -28,9 +27,6 @@
			import com.ycl.utils.DateUtils;
			import constant.ApiConstants;
			import constant.CheckConstants;
			import constant.RedisConstant;
			import enumeration.ErrorType;
			import enumeration.general.WorkOrderStatusEnum;
			import lombok.RequiredArgsConstructor;
			import lombok.extern.slf4j.Slf4j;
			import org.apache.commons.lang3.StringUtils;
			@@ -46,6 +42,7 @@
			import java.text.SimpleDateFormat;
			import java.util.*;
			import java.util.concurrent.*;
			import java.util.concurrent.atomic.AtomicReference;
			import java.util.function.Function;
			import java.util.stream.Collectors;

			@@ -196,7 +193,6 @@
			log.error("请配置离线次数，此次设置为默认值2");
			}


			// 先查出设备IP集合,剔除掉在线情况是未知的,并且只检测正在考核的设备避免多余工单
			List<TMonitorResult> monitorList = monitorMapper.getDistinctIP();
			//补充错误时间点
			@@ -255,6 +251,10 @@
			//查出数据库纯车辆或纯人脸设备
			// List<String> serialNumbers = monitorMapper.selectCarOrFace().stream().map(TMonitor::getSerialNumber).collect(Collectors.toList());
			dataList.forEach(item->{
			// if ("DX_长征大道贡兴路路口东南方向_枪机_细节".equals(item.getName())){
			// log.info("2.数据流入:{}",item);
			// log.info("打印状态pingOnline：{}",item.getPingOnline());
			// }
			if(item.getPingOnline()) {
			onLineList.add(item.getIp());
			} else if(!item.getPingOnline()) {
			@@ -264,14 +264,17 @@
			unKnownList.add(item.getIp());
			}
			});
			log.error("unKnownList:{}",unKnownList);

			log.error("通过pingOnline未知点位的集合大小:{}",unKnownList.size());
			log.error("通过pingOnline修改离线线的点位集合大小:{}",offLineList.size());
			log.error("通过pingOnline修改在线的点位集合大小:{}",onLineList.size());
			if(!CollectionUtils.isEmpty(offLineList)) {
			log.error("修改离线的点位集合:{}",offLineList);
			monitorMapper.batchUpdateOnline(offLineList, now, ApiConstants.UY_OnlineSite_Offline);
			monitorMapper.batchUpdatePingOnline(offLineList, now, ApiConstants.UY_OnlineSite_Offline);
			}
			if(!CollectionUtils.isEmpty(onLineList)) {
			log.error("修改在线的点位集合:{}",onLineList);
			monitorMapper.batchUpdateOnline(onLineList, now, ApiConstants.UY_OnlineSite_Online);
			monitorMapper.batchUpdatePingOnline(onLineList, now, ApiConstants.UY_OnlineSite_Online);
			}
			//存放到mongo
			if (!CollectionUtils.isEmpty(dataList)) {
			@@ -291,6 +294,10 @@
			mongoData.setProvinceTag(mongoData.getProvinceTagCar());
			}else if("3".equals(type)){
			mongoData.setProvinceTag(mongoData.getProvinceTagFace());
			}
			//修改线上
			if(mongoData.getPingOnline()){
			mongoData.setOnline(1);
			}
			mongoList.add(mongoData);
			}
			@@ -354,6 +361,7 @@
			}
			});
			pointService.setDeviceTagByGB(records,CheckConstants.Rule_Category_Video);
			log.error("点位在线率插入数据大小{}",records.size());
			//存放在mongo中
			mongoTemplate.insertAll(records);
			//更新point表在线状态
			@@ -365,6 +373,31 @@
			vo.setUpdateTime(now);
			return vo;
			}).collect(Collectors.toList());
			log.info("打印点位在线(优云)需要修改的状态:{}",willUpdateList);
			log.info("打印点位在线(优云)需要修改的大小:{}",willUpdateList.size());
			Map<Integer, Long> statusCountMap = willUpdateList.stream()
			.collect(Collectors.groupingBy(
			item -> {
			int online = item.getOnline();
			// 自定义分组规则：-1、1 单独分组，其他归为 0（或其他标识）
			if (online == -1) {
			return -1;
			} else if (online == 1) {
			return 1;
			} else {
			return 0; // 用 0 代表其他状态
			}
			},
			Collectors.counting() // 统计每个分组的数量
			));

			// 从map中获取各状态的数量（默认值为0，避免空指针）
			long offlineCount = statusCountMap.getOrDefault(-1, 0L); // -1状态的数量
			long onlineCount = statusCountMap.getOrDefault(1, 0L); // 1状态的数量
			long otherCount = statusCountMap.getOrDefault(0, 0L); // 其他状态的数量
			log.info("打印点位在线(优云)需要修改离线大小:{}",offlineCount);
			log.info("打印点位在线(优云)需要修改在线大小:{}",onlineCount);
			log.info("打印点位在线(优云)需要修改其他状态大小:{}",otherCount);
			monitorMapper.updateOnlineFromUyOrHk(willUpdateList);
			//离线生成工单,一个ip只生成一个工单
			List<VideoOnlineResult> workOrders = new ArrayList<>(records.stream()
			@@ -418,10 +451,13 @@
			instance.setTime(new Date());
			instance.add(Calendar.DAY_OF_MONTH, -1);
			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");

			String yesterday = format.format(instance.getTime());
			param.setStatTime(yesterday);
			log.error("开始同步mongodb录像可用数据日期为{}",yesterday);
			JSONObject jsonObject = uyClient.recordMetaDSumList(param);
			double minTime = getSySMinTime();
			AtomicReference<Integer> count = new AtomicReference<>(0);
			if (jsonObject != null) {
			if (ApiConstants.UYSuccessCodeStr.equals(jsonObject.getString("code"))) {
			List<RecordMetaDSumResult> records = jsonObject.getList("data", RecordMetaDSumResult.class);
			@@ -434,8 +470,11 @@
			if (Objects.nonNull(item.getDeviceId())) {
			item.setNo(item.getDeviceId());
			}

			//判断并修改录像缺少状态
			if (item.getRecordStatus() != -1){

			count.getAndSet(count.get() + 1);
			if (item.getMissDuration() > minTime){
			item.setRecordStatus(0);
			}else if (item.getMissDuration() < minTime){
			@@ -445,7 +484,9 @@
			});
			//打标签
			pointService.setDeviceTagByGB(records,CheckConstants.Rule_Category_Video);
			log.error("发生状态改变数量:{}",count);
			//存放在mongo中
			log.error("新增mongodb数据大小：{}",records.size());
			mongoTemplate.insertAll(records);
			// // 工单生成
			// uyErrorTypeCheckService.recordMetaDSumCheck(records);