zgyw.git - Gitblit

			@@ -4,11 +4,15 @@
			import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
			import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
			import com.google.common.util.concurrent.AtomicDouble;
			import com.ycl.platform.domain.entity.DailyMonitorDemeritRecord;
			import com.ycl.platform.domain.entity.DemeritRecord;
			import com.ycl.platform.domain.entity.MonitorConstruction;
			import com.ycl.platform.domain.entity.Report;
			import com.ycl.platform.domain.result.UY.RecordMetaDSumResult;
			import com.ycl.platform.mapper.DemeritRecordMapper;
			import com.ycl.platform.mapper.IMonitorConstructionMapper;
			import com.ycl.platform.mapper.ReportMapper;
			import com.ycl.platform.service.IDailyMonitorDemeritRecordService;
			import com.ycl.platform.service.IDemeritRecordService;
			import com.ycl.utils.DateUtils;
			import enumeration.ConstructionTypeEnum;
			@@ -50,6 +54,10 @@

			private final ReportMapper reportMapper;

			private final IMonitorConstructionMapper monitorConstructionMapper;

			private final IDailyMonitorDemeritRecordService dailyMonitorDemeritRecordService;

			private static final ExecutorService executorService = new ThreadPoolExecutor(16,
			128,
			5000,
			@@ -59,24 +67,29 @@
			);
			private final IDemeritRecordService demeritRecordService;

			// 提取公共过滤方法
			private Predicate<RecordMetaDSumResult> deviceNameStartsWith(String prefix) {
			return result -> result.getDeviceName() != null && result.getDeviceName().startsWith(prefix);
			}
			private final IDailyMonitorDemeritRecordService iDailyMonitorDemeritRecordService;

			private Predicate<RecordMetaDSumResult> deviceNameStartsWithAny(String... prefixes) {
			return result -> result.getDeviceName() != null &&
			Arrays.stream(prefixes).anyMatch(prefix -> result.getDeviceName().startsWith(prefix));
			}

			private DemeritRecord buildDemeritRecord(String constructionType,BigDecimal demerit,Integer deptId) {
			private DemeritRecord buildDemeritRecord(String constructionType,BigDecimal demerit,Integer deptId,Date recordTime) {
			DemeritRecord record = new DemeritRecord();
			record.setConstructionType(constructionType);
			record.setDemerit(demerit);
			record.setDeptId(deptId);
			record.setRecordTime(recordTime);
			return record;
			}
			private BigDecimal calculateTotalDeduction(List<RecordMetaDSumResult> records) {
			private DailyMonitorDemeritRecord buildDailyMonitorDemeritRecord(Date recordTime,String deviceId,String constructionType,BigDecimal demerit,Integer deptId,Boolean isReport,String deviceName) {
			DailyMonitorDemeritRecord demeritRecord = new DailyMonitorDemeritRecord();
			demeritRecord.setRecordTime(recordTime);
			demeritRecord.setDemerit(demerit);
			demeritRecord.setConstructionType(constructionType);
			demeritRecord.setSerialNumber(deviceId);
			demeritRecord.setIsReport(isReport);
			demeritRecord.setDeptId(deptId);
			demeritRecord.setDeviceName(deviceName);
			return demeritRecord;
			}

			private BigDecimal calculateTotalDeduction(List<RecordMetaDSumResult> records,Date recordTime,Integer deptId,List<DailyMonitorDemeritRecord> dailyMonitorDemeritRecords) {
			BigDecimal total = BigDecimal.ZERO; // 单线程循环，无需AtomicReference

			for (RecordMetaDSumResult record : records) {
			@@ -99,6 +112,8 @@
			} else {
			deduction = BigDecimal.ZERO;
			}
			dailyMonitorDemeritRecords.add(buildDailyMonitorDemeritRecord(recordTime,record.getDeviceId()
			,record.getConstructionType(),deduction,deptId,false,record.getDeviceName()));

			// 累加总扣分（最后统一处理精度，避免中间四舍五入误差）
			total = total.add(deduction);
			@@ -126,7 +141,7 @@

			log.info("日期:{},查询出的设备录像记录数{}",today,results.size());
			//过滤掉非全景的设备且 1则为细节，如果是0则为全景
			results.stream().filter(obj ->
			results = results.stream().filter(obj ->
			{
			String deviceId = obj.getDeviceId();
			if (deviceId == null \|\| deviceId.length() < 7) {
			@@ -135,7 +150,7 @@
			// 获取倒数第七位的字符
			char seventhFromEnd = deviceId.charAt(deviceId.length() - 7);
			return seventhFromEnd != '1'; //为1 则会 false 去除掉
			});
			}).collect(Collectors.toList());

			log.info("过滤后剩余全景设备数{}",results.size());
			//只考核LT_、(三期)
			@@ -143,28 +158,62 @@
			// DX_R、（四区人脸）
			// DX_RS、（四区人脸）
			// （需要排除DX_R2、DX_RD、J_、T1、T3以及没有前缀的设备）
			List<String> prefixes = Arrays.asList("LT_", "DX_", "DX_R", "DX_RS");
			// List<String> prefixes = Arrays.asList("LT_", "DX_", "DX_R", "DX_RS");
			//查询设备标签表中的MonitorConstruction列表
			List<MonitorConstruction> monitorConstructionList = new LambdaQueryChainWrapper<>(monitorConstructionMapper)
			.eq(MonitorConstruction::getDeleted, Boolean.FALSE)
			.list();

			results.stream()
			//按编号分组，值为设备对应标签
			Map<String, String> serialTagMap = monitorConstructionList.stream()
			.filter(mc -> mc.getSerialNumber() != null) // 过滤序列号为空的无效数据
			.collect(Collectors.toMap(
			MonitorConstruction::getSerialNumber,
			MonitorConstruction::getTag,
			(oldVal, newVal) -> newVal
			));
			//过滤掉没有标签的集合并将标签赋值给录像情况集合
			results = results.stream()
			.filter(result -> {
			String deviceName = result.getDeviceName();
			if (deviceName == null) {
			return false;
			String sn = result.getNo();
			// 过滤条件：序列号非空 + 在标签Map中存在（即有对应标签）
			boolean isMatch = sn != null && serialTagMap.containsKey(sn);
			if (isMatch) {
			// 匹配成功，将标签赋值给result（需确保RecordMetaDSumResult有setTag()方法）
			String tag = serialTagMap.get(sn);
			result.setConstructionType(tag); // 关键：赋值标签
			}
			return prefixes.stream().anyMatch(deviceName::startsWith);
			return isMatch; // 只保留有标签的result
			})
			.collect(Collectors.toList());

			log.info("剩余考核设备过滤后设备数{}",results.size());

			log.info("有标签的设备记录集合大小:{}",results.size());//这是需要计算扣分的录像数据



			//过滤掉报备的设备
			//查询在当前时间有报备的所有设备，
			//因为录像数据的时间
			List<String> deviceIds = new LambdaQueryChainWrapper<>(reportMapper)
			Date yesterday =new Date();
			Calendar calendar = Calendar.getInstance();
			calendar.setTime(yesterday);
			calendar.add(Calendar.DAY_OF_YEAR, -1); // 减去1天测试用
			yesterday = calendar.getTime();
			log.info("测试时间:{}",yesterday);

			List<Report> list = new LambdaQueryChainWrapper<>(reportMapper)
			.eq(Report::getStatus, 1)
			.ge(Report::getBeginCreateTime, today)
			.le(Report::getEndCreateTime, today)
			.list().stream()
			// getEndCreateTime getEndCreateTime 01 00:00:00 - 30 11:59:59
			.le(Report::getBeginCreateTime,
			DateUtils.getDayStart(yesterday))
			//>=
			.ge(Report::getEndCreateTime, DateUtils.getDayEnd(yesterday))

			.list();

			log.info("报备记录：{}",list);
			List<String> deviceIds = list.stream()
			.collect(Collectors.toMap(
			Report::getSerialNumber, // key: serialNumber
			Function.identity(), // value: Report对象本身
			@@ -176,19 +225,14 @@
			.map(Report::getSerialNumber).collect(Collectors.toList());

			Set<String> deviceIdSet = new HashSet<>(deviceIds);

			log.info("报备设备数{}",deviceIdSet.size());
			results.stream()
			.filter(result -> {
			// 获取当前对象的deviceId
			String resultDeviceId = result.getDeviceId();
			// 过滤条件：deviceId不在集合中（注意处理null值，避免NPE）
			return resultDeviceId != null && !deviceIdSet.contains(resultDeviceId);
			})
			.collect(Collectors.toList());

			log.info("剩余过滤报备后设备数{}",results.size());

			// 按区域划分组装成map
			List<DailyMonitorDemeritRecord> dailyMonitorDemeritRecords = new ArrayList<>();
			Date yesterdayBegin = DateUtils.getDayStart(yesterday);
			// 遍历区分对象的报备状态
			// 因为下面会过滤覆盖掉考核设备，需要已报备的设备录像情况信息，
			// 所以此处应该将已报备的设备录像情况信息添加到每日扣分详情记录中并初始化好后续不在处理直接添加数据库中
			// 将区域信息放入集合中
			results.forEach(item -> {
			String areaCode = item.getArealayername().substring(0, 6);
			AreaDeptEnum areaDeptEnum = AreaDeptEnum.fromCode(areaCode);
			@@ -196,12 +240,63 @@
			item.setArealayerno(areaDeptEnum.getCode());
			}
			});
			results.forEach(result ->{
			String deviceId = result.getDeviceId();
			if (StringUtils.isNotBlank(deviceId)) {
			if (deviceIdSet.contains(deviceId)) {
			//已报备设备记录
			AreaDeptEnum areaDeptEnum = AreaDeptEnum.fromCode(result.getArealayerno());
			if (areaDeptEnum == null) {
			log.info("区域数据异常，异常区域键值：{}",result.getArealayerno());
			return;
			}
			DailyMonitorDemeritRecord demeritRecord = buildDailyMonitorDemeritRecord(
			yesterdayBegin,deviceId,
			result.getConstructionType(),
			BigDecimal.ZERO,
			areaDeptEnum.getDeptId(),
			true,
			result.getDeviceName()
			);
			dailyMonitorDemeritRecords.add(demeritRecord);
			}
			}
			});
			// 过滤获得未报备集合
			results = results.stream()
			.filter(result -> {
			String resultDeviceId = result.getDeviceId();
			return resultDeviceId != null && !deviceIdSet.contains(resultDeviceId);
			})
			.collect(Collectors.toList());

			log.info("剩余过滤报备后设备数{}",results.size());


			//需要添加数据库的数据集合
			List<DemeritRecord> demeritRecords = new ArrayList<>();

			// 按区域划分组装成map
			Map<String,List<RecordMetaDSumResult>> groupByArealayerno = results.stream()
			.collect(Collectors.groupingBy(RecordMetaDSumResult::getArealayerno));

			//按建设类型标签分组设备NO monitorConstructionList
			//按标签分组
			Map<String, List<String>> groupByTag = monitorConstructionList.stream()
			// 分组键：提取每个对象的 tag（注意处理 tag 为 null 的情况，避免键为 null）
			.collect(Collectors.groupingBy(
			mc -> mc.getTag() != null ? mc.getTag() : "DEFAULT_TAG",
			Collectors.mapping(MonitorConstruction::getSerialNumber, Collectors.toList())

			));
			List<String> phaseOneTwoSerials = groupByTag.getOrDefault(ConstructionTypeEnum.PHASE_ONE_TWO.getDesc(), Collections.emptyList());
			List<String> phaseThreeSerials = groupByTag.getOrDefault(ConstructionTypeEnum.PHASE_THREE.getDesc(), Collections.emptyList());
			List<String> phaseFourthSerials = groupByTag.getOrDefault(ConstructionTypeEnum.PHASE_FOURTH.getDesc(), Collections.emptyList());

			List<String> checkEnterSichuan = groupByTag.getOrDefault(ConstructionTypeEnum.CHECK_ENTER_SICHUAN.getDesc(), Collections.emptyList());

			List<String> easternNewCity= groupByTag.getOrDefault(ConstructionTypeEnum.EASTERN_NEW_CITY.getDesc(), Collections.emptyList());

			List<String> yanTanPhaseTwoFace = groupByTag.getOrDefault(ConstructionTypeEnum.YAN_TAN_PHASE_TWO_FACE.getDesc(), Collections.emptyList());
			//循环分组后的map
			for (Map.Entry<String, List<RecordMetaDSumResult>> entry : groupByArealayerno.entrySet()) {
			String arealayerno = entry.getKey();
			@@ -218,78 +313,103 @@
			if (CollectionUtils.isNotEmpty(resultList)) {
			// 对每个List进行处理分建类型处理集合
			List<RecordMetaDSumResult> phase_one_two = resultList.stream()
			.filter(deviceNameStartsWith("DX_"))
			.filter(result -> {
			String no = result.getNo();
			return no != null && phaseOneTwoSerials.contains(no);
			})
			.collect(Collectors.toList());
			log.info("一二期考核记录数{}",phase_one_two.size());
			log.info("一二期考核记录数{}", phase_one_two.size());
			List<RecordMetaDSumResult> phase_three = resultList.stream()
			.filter(deviceNameStartsWith("LT_"))
			.filter(result -> {
			String no = result.getNo();
			return no != null && phaseThreeSerials.contains(no);
			})
			.collect(Collectors.toList());
			log.info("三期考核记录数{}",phase_three.size());
			log.info("三期考核记录数{}", phase_three.size());
			List<RecordMetaDSumResult> phase_fourth = resultList.stream()
			.filter(deviceNameStartsWithAny("DX_R", "DX_RS"))
			.filter(result -> {
			String no = result.getNo();
			return no != null && phaseFourthSerials.contains(no);
			})
			.collect(Collectors.toList());
			log.info("四期考核记录数{}",phase_fourth.size());
			if (CollectionUtils.isNotEmpty(phase_one_two)){
			BigDecimal phaseOneTwoDeduction = calculateTotalDeduction(phase_one_two);
			DemeritRecord demeritRecordPhaseOneTwo = buildDemeritRecord(
			ConstructionTypeEnum.PHASE_ONE_TWO.name(),
			phaseOneTwoDeduction,
			areaDeptEnum.getDeptId());
			demeritRecords.add(demeritRecordPhaseOneTwo);
			}else{
			DemeritRecord phaseOneTwoDeduction = buildDemeritRecord(
			ConstructionTypeEnum.PHASE_ONE_TWO.name(),
			BigDecimal.ZERO,
			areaDeptEnum.getDeptId());
			demeritRecords.add(phaseOneTwoDeduction);
			}
			log.info("四期考核记录数{}", phase_fourth.size());

			List<RecordMetaDSumResult> check_enter_sichuan = resultList.stream()
			.filter(result ->{
			String no = result.getNo();
			return no != null && checkEnterSichuan.contains(no);
			})
			.collect(Collectors.toList());
			log.info("入川即检{}", check_enter_sichuan.size());

			if (CollectionUtils.isNotEmpty(phase_three)){
			BigDecimal phaseThreeDeduction = calculateTotalDeduction(phase_three);
			DemeritRecord demeritRecordPhaseThree = buildDemeritRecord(
			ConstructionTypeEnum.PHASE_THREE.name(),
			phaseThreeDeduction,
			areaDeptEnum.getDeptId());
			demeritRecords.add(demeritRecordPhaseThree);
			}else {
			DemeritRecord phaseThreeDeduction = buildDemeritRecord(
			ConstructionTypeEnum.PHASE_THREE.name(),
			BigDecimal.ZERO,
			areaDeptEnum.getDeptId());
			demeritRecords.add(phaseThreeDeduction);
			}
			if (CollectionUtils.isNotEmpty(phase_fourth)){
			BigDecimal phaseFourthDeduction = calculateTotalDeduction(phase_fourth);
			DemeritRecord demeritRecordPhaseFourth = buildDemeritRecord(
			ConstructionTypeEnum.PHASE_FOURTH.name(),
			phaseFourthDeduction,
			areaDeptEnum.getDeptId());
			demeritRecords.add(demeritRecordPhaseFourth);
			}else{
			DemeritRecord phaseFourthDeduction = buildDemeritRecord(
			ConstructionTypeEnum.PHASE_FOURTH.name(),
			BigDecimal.ZERO,
			areaDeptEnum.getDeptId());
			demeritRecords.add(phaseFourthDeduction);
			}

			List<RecordMetaDSumResult> eastern_new_city = resultList.stream()
			.filter(result ->{
			String no = result.getNo();
			return no != null && easternNewCity.contains(no);
			})
			.collect(Collectors.toList());
			log.info("东部新城{}", eastern_new_city.size());
			List<RecordMetaDSumResult> yan_tan_phase_two_face = resultList.stream()
			.filter(result ->{
			String no = result.getNo();
			return no != null && yanTanPhaseTwoFace.contains(no);
			})
			.collect(Collectors.toList());
			log.info("沿滩二期人脸{}", yan_tan_phase_two_face.size());
			//一二期
			buildAndAddDemeritRecords(phase_one_two, ConstructionTypeEnum.PHASE_ONE_TWO.name(), areaDeptEnum.getDeptId(),yesterdayBegin,demeritRecords,dailyMonitorDemeritRecords);
			//三期
			buildAndAddDemeritRecords(phase_three, ConstructionTypeEnum.PHASE_THREE.name(), areaDeptEnum.getDeptId(),yesterdayBegin,demeritRecords,dailyMonitorDemeritRecords);
			//四期
			buildAndAddDemeritRecords(phase_fourth, ConstructionTypeEnum.PHASE_FOURTH.name(), areaDeptEnum.getDeptId(),yesterdayBegin,demeritRecords,dailyMonitorDemeritRecords);
			//入川即检
			buildAndAddDemeritRecords(check_enter_sichuan, ConstructionTypeEnum.CHECK_ENTER_SICHUAN.name(), areaDeptEnum.getDeptId(),yesterdayBegin,demeritRecords,dailyMonitorDemeritRecords);
			//东部新城
			buildAndAddDemeritRecords(eastern_new_city, ConstructionTypeEnum.EASTERN_NEW_CITY.name(), areaDeptEnum.getDeptId(),yesterdayBegin,demeritRecords,dailyMonitorDemeritRecords);
			//沿滩二期人脸
			buildAndAddDemeritRecords(yan_tan_phase_two_face, ConstructionTypeEnum.YAN_TAN_PHASE_TWO_FACE.name(), areaDeptEnum.getDeptId(),yesterdayBegin,demeritRecords,dailyMonitorDemeritRecords);
			}



			}

			//处理完数据插入数据库中
			//先删除需要插入时间是否存在数据

			LambdaQueryWrapper<DemeritRecord> queryWrapper = new LambdaQueryWrapper<>();
			queryWrapper.ge(DemeritRecord::getCreateTime,DateUtils.getDayStart(today))
			LambdaQueryWrapper<DemeritRecord> demeritRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();
			demeritRecordLambdaQueryWrapper.ge(DemeritRecord::getCreateTime,DateUtils.getDayStart(today))
			.le(DemeritRecord::getCreateTime,DateUtils.getDayEnd(today));
			demeritRecordService.remove(queryWrapper);
			demeritRecordService.remove(demeritRecordLambdaQueryWrapper);
			demeritRecordService.saveBatch(demeritRecords);

			log.info("结束计算每日扣分记录情况：插入数据量{},数据信息:{}",demeritRecords.size(),demeritRecords);
			//填充设备录像情况扣分详情结果
			LambdaQueryWrapper<DailyMonitorDemeritRecord> dailyMonitorDemeritRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();
			dailyMonitorDemeritRecordLambdaQueryWrapper.ge(DailyMonitorDemeritRecord::getCreateTime,DateUtils.getDayStart(today))
			.le(DailyMonitorDemeritRecord::getCreateTime,DateUtils.getDayEnd(today));
			iDailyMonitorDemeritRecordService.remove(dailyMonitorDemeritRecordLambdaQueryWrapper);
			iDailyMonitorDemeritRecordService.saveBatch(dailyMonitorDemeritRecords);
			log.info("结束计算每日扣分记录详情情况：插入数据量{},数据信息:{}",dailyMonitorDemeritRecords.size(),dailyMonitorDemeritRecords);

			}
			public void buildAndAddDemeritRecords(List<RecordMetaDSumResult> constructionByRecordMetaList,
			String constructionType,Integer areaDeptId,Date recordTime,
			List<DemeritRecord> demeritRecords,
			List<DailyMonitorDemeritRecord> dailyMonitorDemeritRecords) {
			if (CollectionUtils.isNotEmpty(constructionByRecordMetaList)) {
			BigDecimal deduction = calculateTotalDeduction(constructionByRecordMetaList,recordTime,areaDeptId,dailyMonitorDemeritRecords);
			DemeritRecord demeritRecord = buildDemeritRecord(
			constructionType,
			deduction,
			areaDeptId,
			recordTime);
			demeritRecords.add(demeritRecord);
			}else{
			DemeritRecord demeritRecord = buildDemeritRecord(
			constructionType,
			BigDecimal.ZERO,
			areaDeptId,
			recordTime);
			demeritRecords.add(demeritRecord);
			}
			}

			}