报备工单bug修改，定时任务在线问题修改新增导出扣分明细功能

zxl

2025-11-10 cb415813de667096290d6bd0f924f5b523104117

 ycl-server/src/main/java/com/ycl/platform/service/impl/TMonitorServiceImpl.java

@@ -3,14 +3,12 @@
import annotation.DataScope;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.mongodb.ExplainVerbosity;
import com.mongodb.client.AggregateIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.ycl.platform.domain.entity.MonitorConstruction;
import com.ycl.platform.domain.entity.TMonitor;
import com.ycl.platform.domain.excel.TMonitorExp;
import com.ycl.platform.domain.excel.VideoDailyExp;
import com.ycl.platform.domain.excel.VideoTotalExp;
import com.ycl.platform.domain.excel.*;
import com.ycl.platform.domain.form.VideoExportForm;
import com.ycl.platform.domain.query.DashboardQuery;
import com.ycl.platform.domain.query.DataCenterQuery;
@@ -30,14 +28,11 @@
import com.ycl.platform.domain.vo.home.HomeVideoVO;
import com.ycl.platform.domain.vo.screen.MonitorRateVO;
import com.ycl.platform.domain.vo.screen.MonitorTotalVO;
import com.ycl.platform.mapper.DynamicColumnMapper;
import com.ycl.platform.mapper.TMonitorMapper;
import com.ycl.platform.mapper.WorkOrderMapper;
import com.ycl.platform.mapper.YwPointMapper;
import com.ycl.platform.mapper.*;
import com.ycl.platform.service.IMonitorConstructionService;
import com.ycl.platform.service.ITMonitorService;
import com.ycl.system.Result;
import com.ycl.system.entity.SysDictData;
import com.ycl.system.mapper.SysConfigMapper;
import com.ycl.system.mapper.SysDictDataMapper;
import com.ycl.system.page.PageUtil;
import com.ycl.system.service.ISysConfigService;
@@ -45,13 +40,12 @@
import com.ycl.utils.StringUtils;
import com.ycl.utils.poi.ExcelUtil;
import constant.ApiConstants;
import constant.CheckConstants;
import enumeration.general.AreaDeptEnum;
import jakarta.servlet.http.HttpServletResponse;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.ObjectUtils;
import org.apache.commons.lang3.Validate;
import org.bson.Document;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
@@ -67,19 +61,19 @@
import java.lang.reflect.Field;
import java.lang.reflect.InvocationTargetException;
import java.math.BigDecimal;
import java.text.DecimalFormat;
import java.math.RoundingMode;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.time.LocalDate;
import java.time.YearMonth;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.time.temporal.TemporalAdjusters;
import java.util.*;
import java.util.concurrent.*;
import java.util.function.BinaryOperator;
import java.util.function.Function;
import java.util.regex.Pattern;
import java.util.stream.Collectors;

import static com.ycl.utils.PageUtils.startPage;

/**
 * 设备资产Service业务层处理
@@ -88,6 +82,7 @@
 * @date 2024-03-04
 */
@Service
@Slf4j
public class TMonitorServiceImpl extends ServiceImpl<TMonitorMapper, TMonitor> implements ITMonitorService {
    @Autowired
    private TMonitorMapper tMonitorMapper;
@@ -105,7 +100,8 @@
    private DynamicColumnMapper dynamicColumnMapper;
    @Autowired
    private ThreadPoolTaskExecutor threadPoolTaskExecutor;

    @Autowired
    private IMonitorConstructionService monitorConstructionService;
    /**
     * 查询设备资产
     *
@@ -135,156 +131,173 @@
            }
            tMonitor.setTime(time);
        }
        List<TMonitorVO> monitors = tMonitorMapper.selectTMonitorList(tMonitor);
        // 异常恢复监控
        if (Objects.equals(tMonitor.getRecovery(), 1L)) {
            //工单号
            List<String> orders = monitors.stream().map(TMonitorVO::getWorkOrderNo).collect(Collectors.toList());
            if (CollectionUtils.isEmpty(orders)) {
        List<TMonitorVO> monitors = new ArrayList<>();
        if (StringUtils.isNotBlank(tMonitor.getConstructionType())){
            List<MonitorConstruction> list =
                    monitorConstructionService.getSerialNumberListByConstructionType(tMonitor.getConstructionType());
            log.info("打印查询设备标签数:{},建设类型标签:{}",list.size(), tMonitor.getConstructionType() );
            //获得设备编号集合 通过建设类型标签
            if(!CollectionUtils.isEmpty(list)){
                tMonitor.setIds(
                        list.stream().map(MonitorConstruction::getSerialNumber).collect(Collectors.toList()));

                startPage();
                monitors = tMonitorMapper.selectTMonitorListAndIds(tMonitor);
            }

        }else{
            startPage();
            monitors = tMonitorMapper.selectTMonitorList(tMonitor);
        }
            // 异常恢复监控
            if (Objects.equals(tMonitor.getRecovery(), 1L)) {
                //工单号
                List<String> orders = monitors.stream().map(TMonitorVO::getWorkOrderNo).collect(Collectors.toList());
                if (CollectionUtils.isEmpty(orders)) {
                    return monitors;
                }
                List<WorkOrderVO> voList = workOrderMapper.getRecoveryInfo(orders);
                for (TMonitorVO monitor : monitors) {
                    if (!CollectionUtils.isEmpty(voList)) {
                        for (WorkOrderVO workOrderVO : voList) {
                            if (monitor.getWorkOrderNo() != null && monitor.getWorkOrderNo().equals(workOrderVO.getWorkOrderNo())) {
                                monitor.setUnitContact(workOrderVO.getUnitContact());
                                monitor.setUnitContactPhone(workOrderVO.getUnitContactPhone());
                                monitor.setYwPeopleName(workOrderVO.getYwPeopleName());
                                monitor.setErrorType(workOrderVO.getErrorType());
                            }
                        }
                    }
                }
                return monitors;
            }
            List<WorkOrderVO> voList = workOrderMapper.getRecoveryInfo(orders);
            for (TMonitorVO monitor : monitors) {
                if (!CollectionUtils.isEmpty(voList)) {
                    for (WorkOrderVO workOrderVO : voList) {
                        if (monitor.getWorkOrderNo() != null && monitor.getWorkOrderNo().equals(workOrderVO.getWorkOrderNo())) {
                            monitor.setUnitContact(workOrderVO.getUnitContact());
                            monitor.setUnitContactPhone(workOrderVO.getUnitContactPhone());
                            monitor.setYwPeopleName(workOrderVO.getYwPeopleName());
                            monitor.setErrorType(workOrderVO.getErrorType());
            //设备编号
            List<String> numbers = monitors.stream().map(TMonitorVO::getSerialNumber).collect(Collectors.toList());
            Query query = new Query();
            Date now = new Date();
            query.addCriteria(Criteria.where("no").in(numbers)
                    .and("mongoCreateTime").gte(DateUtils.getDayStart(now)).lt(DateUtils.getDayEnd(now))
            );
            //一机一档信息
            List<MonitorQualifyResult> monitorQualifyResults = mongoTemplate.find(query, MonitorQualifyResult.class);
            // 视频监控设备
            if (Objects.equals(tMonitor.getCameraFunType(), "1")) {
                //OSD信息
                List<OsdCheckResult> osdCheckResults = mongoTemplate.find(query, OsdCheckResult.class);
                //录像可用信息
                List<RecordMetaDSumResult> videoResults = mongoTemplate.find(query, RecordMetaDSumResult.class);
                for (TMonitorVO monitor : monitors) {
                    monitor.setMongoCreateTime(now);
                    //一机一档
                    setOneFile(monitorQualifyResults, monitor);
                    //录像
                    if (!CollectionUtils.isEmpty(videoResults)) {
                        for (RecordMetaDSumResult videoResult : videoResults) {
                            if (monitor.getSerialNumber().equals(videoResult.getNo())) {
                                monitor.setVideoComplete(videoResult.getRecordStatus());
                                monitor.setVideoLoseTime(videoResult.getMissDuration());
                            }
                        }
                    }
                    //OSD
                    if (!CollectionUtils.isEmpty(osdCheckResults)) {
                        for (OsdCheckResult osdCheckResult : osdCheckResults) {
                            if (monitor.getSerialNumber().equals(osdCheckResult.getNo())) {
                                monitor.setOSD(OsdCheckResult.checkOsd(osdCheckResult));
                                monitor.setOSDTime(OsdCheckResult.checkTime(osdCheckResult));
                            }
                        }
                    }
                }
            }
            return monitors;
        }
        //设备编号
        List<String> numbers = monitors.stream().map(TMonitorVO::getSerialNumber).collect(Collectors.toList());
        Query query = new Query();
        Date now = new Date();
        query.addCriteria(Criteria.where("no").in(numbers)
                .and("mongoCreateTime").gte(DateUtils.getDayStart(now)).lt(DateUtils.getDayEnd(now))
        );
        //一机一档信息
        List<MonitorQualifyResult> monitorQualifyResults = mongoTemplate.find(query, MonitorQualifyResult.class);
        // 视频监控设备
        if (Objects.equals(tMonitor.getCameraFunType(), "1")) {
            //OSD信息
            List<OsdCheckResult> osdCheckResults = mongoTemplate.find(query, OsdCheckResult.class);
            //录像可用信息
            List<RecordMetaDSumResult> videoResults = mongoTemplate.find(query, RecordMetaDSumResult.class);
            for (TMonitorVO monitor : monitors) {
                monitor.setMongoCreateTime(now);
                //一机一档
                setOneFile(monitorQualifyResults, monitor);
                //录像
                if (!CollectionUtils.isEmpty(videoResults)) {
                    for (RecordMetaDSumResult videoResult : videoResults) {
                        if (monitor.getSerialNumber().equals(videoResult.getNo())) {
                            monitor.setVideoComplete(videoResult.getRecordStatus());
                            monitor.setVideoLoseTime(videoResult.getMissDuration());
                        }
                    }
                }
                //OSD
                if (!CollectionUtils.isEmpty(osdCheckResults)) {
                    for (OsdCheckResult osdCheckResult : osdCheckResults) {
                        if (monitor.getSerialNumber().equals(osdCheckResult.getNo())) {
                            monitor.setOSD(OsdCheckResult.checkOsd(osdCheckResult));
                            monitor.setOSDTime(OsdCheckResult.checkTime(osdCheckResult));
                        }
                    }
                }
            }
        }
        // 车辆监控设备
        if (Objects.equals(tMonitor.getCameraFunType(), "2")) {
            //属性一致率、大图
            List<VehicleDeviceSamplingResult> sampleResults = mongoTemplate.find(query, VehicleDeviceSamplingResult.class);
            List<PicAccessResult> picAccessResults = mongoTemplate.find(query, PicAccessResult.class);
            //抓拍量、时钟、上传
            List<VehicleDeviceInspectionResult> inspectResults = mongoTemplate.find(query, VehicleDeviceInspectionResult.class);
            for (TMonitorVO monitor : monitors) {
                monitor.setMongoCreateTime(now);
                //一机一档
                setOneFile(monitorQualifyResults, monitor);
                //url
                if (!CollectionUtils.isEmpty(sampleResults)) {
                    for (PicAccessResult picAccessResult : picAccessResults) {
                        if (monitor.getSerialNumber().equals(picAccessResult.getNo())) {
                            BigDecimal bigDecimal = PicAccessResult.calUrl(picAccessResult);
                            monitor.setUrlPercent(bigDecimal);
                        }
                    }
                }
            // 车辆监控设备
            if (Objects.equals(tMonitor.getCameraFunType(), "2")) {
                //属性一致率、大图
                if (!CollectionUtils.isEmpty(sampleResults)) {
                    for (VehicleDeviceSamplingResult sampleResult : sampleResults) {
                        if (monitor.getSerialNumber().equals(sampleResult.getNo())) {
                            if (sampleResult.getBigUseful() != null) {
                                monitor.setBigUsefulPercent(sampleResult.getBigUseful().getBigUsefulPercent());
                            }
                            if (sampleResult.getVehDiff() != null) {
                                monitor.setImportantConPercent(sampleResult.getVehDiff().getImportantConPercent());
                                monitor.setMajorConPercent(sampleResult.getVehDiff().getMajorConPercent());
                            }
                        }
                    }
                }
                List<VehicleDeviceSamplingResult> sampleResults = mongoTemplate.find(query, VehicleDeviceSamplingResult.class);
                List<PicAccessResult> picAccessResults = mongoTemplate.find(query, PicAccessResult.class);
                //抓拍量、时钟、上传
                if (!CollectionUtils.isEmpty(inspectResults)) {
                    for (VehicleDeviceInspectionResult inspectResult : inspectResults) {
                        if (monitor.getSerialNumber().equals(inspectResult.getNo())) {
                            monitor.setSnapResult(inspectResult.getSnapResult());
                            monitor.setSnapCount(inspectResult.getDataCount());
                            if (inspectResult.getSnapClock() != null)
                                monitor.setClockPercent(inspectResult.getSnapClock().getClockPercent());
                            if (inspectResult.getSnapTimely() != null)
                                monitor.setUploadPercent(inspectResult.getSnapTimely().getTimelyPercent());
                        }
                    }
                }
            }
        }
        // 人脸监控设备
        if (Objects.equals(tMonitor.getCameraFunType(), "3")) {
            //人脸合格、大图、url访问异常
            List<FaceDeviceSamplingResult> sampleResults = mongoTemplate.find(query, FaceDeviceSamplingResult.class);
            //抓拍量、时钟、上传
            List<FaceDeviceInspectionResult> inspectResults = mongoTemplate.find(query, FaceDeviceInspectionResult.class);
            for (TMonitorVO monitor : monitors) {
                monitor.setMongoCreateTime(now);
                //一机一档
                setOneFile(monitorQualifyResults, monitor);
                //人脸合格、大图
                if (!CollectionUtils.isEmpty(sampleResults)) {
                    for (FaceDeviceSamplingResult sampleResult : sampleResults) {
                        if (monitor.getSerialNumber().equals(sampleResult.getNo())) {
                            if (sampleResult.getBigUseful() != null) {
                                monitor.setBigUsefulPercent(sampleResult.getBigUseful().getBigUsefulPercent());
                List<VehicleDeviceInspectionResult> inspectResults = mongoTemplate.find(query, VehicleDeviceInspectionResult.class);
                for (TMonitorVO monitor : monitors) {
                    monitor.setMongoCreateTime(now);
                    //一机一档
                    setOneFile(monitorQualifyResults, monitor);
                    //url
                    if (!CollectionUtils.isEmpty(sampleResults)) {
                        for (PicAccessResult picAccessResult : picAccessResults) {
                            if (monitor.getSerialNumber().equals(picAccessResult.getNo())) {
                                BigDecimal bigDecimal = PicAccessResult.calUrl(picAccessResult);
                                monitor.setUrlPercent(bigDecimal);
                            }
                            if (sampleResult.getFaceEligibility() != null)
                                monitor.setFacePercent(sampleResult.getFaceEligibility().getFaceEligPercent());
                        }
                    }
                }
                //抓拍量、时钟、上传、建模失败率
                if (!CollectionUtils.isEmpty(inspectResults)) {
                    for (FaceDeviceInspectionResult inspectResult : inspectResults) {
                        if (monitor.getSerialNumber().equals(inspectResult.getNo())) {
                            monitor.setSnapResult(inspectResult.getSnapResult());
                            monitor.setSnapCount(inspectResult.getDataCount());
                            if (inspectResult.getSnapClock() != null)
                                monitor.setClockPercent(inspectResult.getSnapClock().getClockPercent());
                            if (inspectResult.getSnapTimely() != null)
                                monitor.setUploadPercent(inspectResult.getSnapTimely().getTimelyPercent());
                            if (inspectResult.getSnapValidity() != null)
                                monitor.setFailPercent(inspectResult.getSnapValidity().getFailPercent());
                    //属性一致率、大图
                    if (!CollectionUtils.isEmpty(sampleResults)) {
                        for (VehicleDeviceSamplingResult sampleResult : sampleResults) {
                            if (monitor.getSerialNumber().equals(sampleResult.getNo())) {
                                if (sampleResult.getBigUseful() != null) {
                                    monitor.setBigUsefulPercent(sampleResult.getBigUseful().getBigUsefulPercent());
                                }
                                if (sampleResult.getVehDiff() != null) {
                                    monitor.setImportantConPercent(sampleResult.getVehDiff().getImportantConPercent());
                                    monitor.setMajorConPercent(sampleResult.getVehDiff().getMajorConPercent());
                                }
                            }
                        }
                    }
                    //抓拍量、时钟、上传
                    if (!CollectionUtils.isEmpty(inspectResults)) {
                        for (VehicleDeviceInspectionResult inspectResult : inspectResults) {
                            if (monitor.getSerialNumber().equals(inspectResult.getNo())) {
                                monitor.setSnapResult(inspectResult.getSnapResult());
                                monitor.setSnapCount(inspectResult.getDataCount());
                                if (inspectResult.getSnapClock() != null)
                                    monitor.setClockPercent(inspectResult.getSnapClock().getClockPercent());
                                if (inspectResult.getSnapTimely() != null)
                                    monitor.setUploadPercent(inspectResult.getSnapTimely().getTimelyPercent());
                            }
                        }
                    }
                }
            }
        }
            // 人脸监控设备
            if (Objects.equals(tMonitor.getCameraFunType(), "3")) {
                //人脸合格、大图、url访问异常
                List<FaceDeviceSamplingResult> sampleResults = mongoTemplate.find(query, FaceDeviceSamplingResult.class);
                //抓拍量、时钟、上传
                List<FaceDeviceInspectionResult> inspectResults = mongoTemplate.find(query, FaceDeviceInspectionResult.class);
                for (TMonitorVO monitor : monitors) {
                    monitor.setMongoCreateTime(now);
                    //一机一档
                    setOneFile(monitorQualifyResults, monitor);
                    //人脸合格、大图
                    if (!CollectionUtils.isEmpty(sampleResults)) {
                        for (FaceDeviceSamplingResult sampleResult : sampleResults) {
                            if (monitor.getSerialNumber().equals(sampleResult.getNo())) {
                                if (sampleResult.getBigUseful() != null) {
                                    monitor.setBigUsefulPercent(sampleResult.getBigUseful().getBigUsefulPercent());
                                }
                                if (sampleResult.getFaceEligibility() != null)
                                    monitor.setFacePercent(sampleResult.getFaceEligibility().getFaceEligPercent());
                            }
                        }
                    }
                    //抓拍量、时钟、上传、建模失败率
                    if (!CollectionUtils.isEmpty(inspectResults)) {
                        for (FaceDeviceInspectionResult inspectResult : inspectResults) {
                            if (monitor.getSerialNumber().equals(inspectResult.getNo())) {
                                monitor.setSnapResult(inspectResult.getSnapResult());
                                monitor.setSnapCount(inspectResult.getDataCount());
                                if (inspectResult.getSnapClock() != null)
                                    monitor.setClockPercent(inspectResult.getSnapClock().getClockPercent());
                                if (inspectResult.getSnapTimely() != null)
                                    monitor.setUploadPercent(inspectResult.getSnapTimely().getTimelyPercent());
                                if (inspectResult.getSnapValidity() != null)
                                    monitor.setFailPercent(inspectResult.getSnapValidity().getFailPercent());
                            }
                        }
                    }
                }
            }
        return monitors;
    }

@@ -352,6 +365,13 @@
    @Override
    @DataScope(deptAlias = "d", userAlias = "u")
    public Map<String, String> getVideoCount(TMonitorVO tMonitor) {

        List<MonitorConstruction> list =
                monitorConstructionService.getSerialNumberListByConstructionType(tMonitor.getConstructionType());
        //获得设备编号集合 通过建设类型标签
        tMonitor.setIds(
                list.stream().map(MonitorConstruction::getSerialNumber).collect(Collectors.toList()));

        return tMonitorMapper.getVideoCount(tMonitor);
    }

@@ -372,16 +392,21 @@
     */
    @Override
    public Map<String, Object> home(HomeQuery monitorQuery) {

        System.out.println(monitorQuery + "~~~~~~~~~~~~~打印");
        Map<String, Object> dataMap = new HashMap<>();
        Map<String, Object> monthMap1 = new HashMap<>();
        Map<String, Object> monthMap2 = new HashMap<>();
        List<Map<String, Object>> home = baseMapper.home(monitorQuery);
        if (ObjectUtils.isNotEmpty(home)) {
            //拿到数据库 循环查询
            System.out.println(home + "~~~~~~~~~~~~~打印");
            for (Map<String, Object> map : home) {
                //得到map的 months键的值  num1键的值 组装为新对象
                monthMap1.put(map.get("months").toString(), map.get("num1"));
                //得到map的 months键的值  num2键的值 组装为新对象
                monthMap2.put(map.get("months").toString(), map.get("num2"));
            }
            //home 的下标0的 map的 name键的值
            dataMap.put("name", home.get(0).get("name"));
            dataMap.put("state", monthMap1);
            dataMap.put("state2", monthMap2);
@@ -557,119 +582,518 @@
        ExcelUtilManySheet<List<ExcelExp>> util = new ExcelUtilManySheet<>(mysheet);
        util.exportExcelManySheet(response, mysheet);
    }


    /**
     * 导出每日在线数据
     */
    @Override
    public void exportVideoOnline(HttpServletResponse response, VideoExportForm exportForm) throws IOException, NoSuchFieldException, IllegalAccessException {
        //默认查所有部门
        log.info("开始导出数据");
        log.info("传入的月份:{}", exportForm.getMonth());

        // 默认查所有部门
        if (CollectionUtils.isEmpty(exportForm.getDeptIds())) {
            List<Integer> deptIds = new ArrayList<>();
            List<Integer> deptIds = new ArrayList<>(AreaDeptEnum.values().length);
            for (AreaDeptEnum value : AreaDeptEnum.values()) {
                deptIds.add(value.getDeptId());
            }
            exportForm.setDeptIds(deptIds);
        }
        List<ExcelExp> sheet = new ArrayList<>();
        //通过Collections静态方法，把list转为线程安全的list
        List mysheet = Collections.synchronizedList(sheet);

        // 使用线程安全的List，预先指定容量
        List<ExcelExp> mysheet = Collections.synchronizedList(new ArrayList<>());
        VideoExportForm.convertTags(exportForm);
        Query query = getQuery(exportForm);
        //月份每日在线数据
        Query query = getQuery(exportForm);//装配条件
        // 月份每日在线数据

        List<TMonitorResult> onlineResult = mongoTemplate.find(query, TMonitorResult.class);
        // 使用 Collectors.toMap 去重，保留每个 No 的第一个遇到的元素
        log.info("大小:{}",onlineResult.size());
        //此处需要过滤掉设备全景在线 细节不在线的情况  可以按 point分组 分我许多组之后再做处理
        Map<String, List<TMonitorResult>> ipToDevices = onlineResult.stream()
                .collect(Collectors.groupingBy(TMonitorResult::getIp));

//        onlineResult = ipToDevices.values().stream()
//                .map(devices -> {
//                    // 检查分组中是否有 online = true 的设备
//                    List<TMonitorResult> onlineDevices = devices.stream()
//                            .filter(monitor -> monitor.getOnline() == 1) // 假设online字段的getter是isOnline()
//                            .collect(Collectors.toList());
//
//                    if (!onlineDevices.isEmpty()) {
//                        // 若存在online=true的设备，只保留第一个（或取任意一个，按需调整）
//                        return onlineDevices.get(0);
//                    } else {
//                        // 若全为online=false，只保留第一个
//                        return devices.get(0);
//                    }
//                })
//                .collect(Collectors.toList());



        log.info("月份在线数据:{}条数", onlineResult.size());
        // 使用Collectors.toMap去重，保留每个No的第一个遇到的元素
        Map<String, TMonitorResult> uniqueResultsMap = onlineResult.stream()
                .collect(Collectors.toMap(
                        TMonitorResult::getNo, // keyMapper，这里假设 getNo() 返回 No 字段
                        Function.identity(),  // valueMapper，直接使用对象本身
                        (existing, replacement) -> existing // mergeFunction，如果有重复，保留第一个
                ));


        // 将 Map 转换为 List
        List<TMonitorResult> tMonitorResults = new ArrayList<>(uniqueResultsMap.values());
        //获取动态列数据
        List<Integer> pointIds = tMonitorResults.stream().map(TMonitorResult::getPointId).collect(Collectors.toList());
        List<DynamicColumnVO> dynamics = dynamicColumnMapper.getDynamicsByIds("t_yw_point", pointIds);
        //补充动态列数据
        if (!CollectionUtils.isEmpty(dynamics)) {
            Map<Integer, List<DynamicColumnVO>> map = dynamics.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefId));
            for (TMonitorResult tMonitorResult : tMonitorResults) {
                Integer pointId = tMonitorResult.getPointId();
                tMonitorResult.setDynamicColumnList(map.get(pointId));
        log.info("去重后大小:{}", tMonitorResults.size());



        // 获取动态列数据并构建缓存Map
        Map<Integer, List<DynamicColumnVO>> dynamicColumnMap = new HashMap<>();
        if (!tMonitorResults.isEmpty()) {
            //获取点位集合
            List<Integer> pointIds = tMonitorResults.stream()
                    .map(TMonitorResult::getPointId)
                    .distinct() // 去重，减少数据库查询
                    .collect(Collectors.toList());


            //获取集合点位的补充列信息
            List<DynamicColumnVO> dynamics = dynamicColumnMapper.getDynamicsByIds("t_yw_point", pointIds);
            if (!CollectionUtils.isEmpty(dynamics)) {
                dynamicColumnMap = dynamics.stream()
                        .collect(Collectors.groupingBy(DynamicColumnVO::getRefId));
            }

            // 补充动态列数据
            for (TMonitorResult result : tMonitorResults) {
                result.setDynamicColumnList(dynamicColumnMap.getOrDefault(result.getPointId(), Collections.emptyList()));
            }
        }
        List<CompletableFuture<List<VideoDailyExp>>> futures = new ArrayList<>();

        // 按部门分组，减少后续循环中的过滤操作
        Map<Integer, List<TMonitorResult>> deptMonitorMap = tMonitorResults.stream()
                .collect(Collectors.groupingBy(TMonitorResult::getDeptId));

        // 按设备编号分组onlineResult，加速后续查找
        Map<String, List<TMonitorResult>> noToOnlineMap = onlineResult.stream()
                .collect(Collectors.groupingBy(TMonitorResult::getNo));

        // 并行处理各部门数据
        List<CompletableFuture<ExcelExp>> futures = new ArrayList<>(exportForm.getDeptIds().size());
        Map<Integer, List<VideoDailyExp>> deptExpMap = new ConcurrentHashMap<>();

        for (Integer deptId : exportForm.getDeptIds()) {
            CompletableFuture<List<VideoDailyExp>> future = CompletableFuture.supplyAsync(() -> {
                List<VideoDailyExp> videoDailyExps = new ArrayList<>();
                //筛选部门数据
                List<TMonitorResult> monitors = tMonitorResults.stream()
                        .filter(tMonitorResult -> deptId.equals(tMonitorResult.getDeptId()))
                        .collect(Collectors.toList());
                if (CollectionUtils.isEmpty(monitors)) return videoDailyExps;
            // 使用部门ID的最终变量
            final Integer currentDeptId = deptId;
            CompletableFuture<ExcelExp> future = CompletableFuture.supplyAsync(() -> {
                // 直接从预分组的Map中获取，避免每次过滤
                List<TMonitorResult> monitors = deptMonitorMap.getOrDefault(currentDeptId, Collections.emptyList());

                List<String> ids = monitors.stream()
                        .map(BaseResult::getNo)
                        .collect(Collectors.toList());
                //筛选mongo区县数据
                List<TMonitorResult> onlines = onlineResult.stream()
                        .filter(result -> ids.contains(result.getNo()))
                        .collect(Collectors.toList());

                AreaDeptEnum areaDeptEnum = AreaDeptEnum.fromDept(deptId);

                if (monitors.isEmpty()) {
                    return null;
                }

                List<VideoDailyExp> videoDailyExps = new ArrayList<>(monitors.size());
                AreaDeptEnum areaDeptEnum = AreaDeptEnum.fromDept(currentDeptId);
                String areaName = areaDeptEnum == null ? "未知" : areaDeptEnum.getName();

                for (TMonitorResult result : monitors) {
                    VideoDailyExp videoDailyExp = new VideoDailyExp();
                    videoDailyExp.setSerialNumber(result.getNo());
                    videoDailyExp.setDeviceName(result.getName());
                    videoDailyExp.setArea(areaDeptEnum == null ? "未知" : areaDeptEnum.getName());
                    videoDailyExp.setType(result.getMonitorType());
                    videoDailyExp.setArea(areaName);

                    StringBuilder tag = new StringBuilder("" +
                            (result.getProvinceTag() ? "省厅、" : "") +
                            (result.getImportantTag() ? "重点点位、" : "") +
                            (result.getImportantCommandImageTag() ? "重点指挥图像、" : "") +
                            (result.getDeptTag() ? "部级、" : ""));
                    // 构建标签字符串
                    StringBuilder tag = new StringBuilder();
                    if (result.getProvinceTag()) tag.append("省厅、");
                    if (result.getImportantTag()) tag.append("重点点位、");
                    if (result.getImportantCommandImageTag()) tag.append("重点指挥图像、");
                    if (result.getDeptTag()) tag.append("部级、");

                    //动态列处理加在标签里
                    if (!CollectionUtils.isEmpty(result.getDynamicColumnList())) {
                        for (DynamicColumnVO dynamicColumnVO : result.getDynamicColumnList()) {
                    // 处理动态列
                    List<DynamicColumnVO> dynamicColumns = result.getDynamicColumnList();
                    if (!dynamicColumns.isEmpty()) {
                        for (DynamicColumnVO dynamicColumnVO : dynamicColumns) {
                            tag.append(dynamicColumnVO.getColumnValue()).append("、");
                        }
                    }
                    // 删除字符串末尾的"、"
                    if (tag.toString().endsWith("、")) {
                        tag = new StringBuilder(tag.substring(0, tag.length() - 1));

                    // 移除末尾的"、"
                    if (tag.length() > 0) {
                        tag.setLength(tag.length() - 1);
                    }
                    videoDailyExp.setTag(tag.toString());

                    // 设置在线数据
                    try {
                        // 从预构建的Map中获取，避免每次过滤
                        List<TMonitorResult> onlines = noToOnlineMap.getOrDefault(result.getNo(), Collections.emptyList());
                        setOnlineDaily(videoDailyExp, result, onlines);
                    } catch (Exception e) {
                        log.error(e.getMessage());
                        log.error("设置在线数据异常", e);
                    }

                    videoDailyExps.add(videoDailyExp);
                }

                ExcelExp excelExp = new ExcelExp(
                        areaDeptEnum == null ? "未知" : areaDeptEnum.getName(),
                        videoDailyExps,
                        VideoDailyExp.class
                );
                mysheet.add(excelExp);
                // 存储结果到线程安全的Map
                deptExpMap.put(currentDeptId, videoDailyExps);

                return videoDailyExps;
                return new ExcelExp(areaName, videoDailyExps, VideoDailyExp.class);
            }, threadPoolTaskExecutor);

            futures.add(future);
        }
        // 获取全量数据
        List<VideoDailyExp> totalExps = futures.stream()
                .map(CompletableFuture::join)

        // 等待所有并行任务完成
        CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join();

        // 收集所有部门的ExcelExp结果
        for (CompletableFuture<ExcelExp> future : futures) {
            ExcelExp excelExp = future.join();
            if (excelExp != null) {
                mysheet.add(excelExp);
            }
        }

        // 获取全量数据并添加"全量"sheet
        List<VideoDailyExp> totalExps = deptExpMap.values().stream()
                .flatMap(List::stream)
                .collect(Collectors.toList());
        ExcelExp excelExp = new ExcelExp("全量", totalExps, VideoDailyExp.class);
        mysheet.add(excelExp);

        mysheet.add(new ExcelExp("全量", totalExps, VideoDailyExp.class));

        // 统计各类型设备数量
        long face = 0, car = 0, video = 0;
        for (VideoDailyExp exp : totalExps) {
            String type = exp.getType();
            if (type.contains("1")) face++;
            if (type.contains("2")) car++;
            if (type.contains("3")) video++;
        }

        log.info("人脸数:{}", face);
        log.info("car数:{}", car);
        log.info("video数:{}", video);

        // 处理离线数统计和在线率统计
        List<VideoTypeOffOnlineExp> videoTypeOffOnlineExps = new ArrayList<>();
        List<VideoOnlineRateExp> videoOnlineRateExps = new ArrayList<>();

        for (Map.Entry<Integer, List<VideoDailyExp>> entry : deptExpMap.entrySet()) {
            Integer deptId = entry.getKey();
            List<VideoDailyExp> list = entry.getValue();
            AreaDeptEnum areaDeptEnum = AreaDeptEnum.fromDept(deptId);

            // 批量处理三种设备类型
            addDeviceStats(list, areaDeptEnum, "1", "人脸", videoTypeOffOnlineExps, videoOnlineRateExps);
            addDeviceStats(list, areaDeptEnum, "2", "卡口", videoTypeOffOnlineExps, videoOnlineRateExps);
            addDeviceStats(list, areaDeptEnum, "3", "视频", videoTypeOffOnlineExps, videoOnlineRateExps);
        }

        // 计算合计数据
        addTotalStats(videoTypeOffOnlineExps, videoOnlineRateExps, face, car, video);

        // 添加统计sheet
        mysheet.add(new ExcelExp("离线数统计", videoTypeOffOnlineExps, VideoTypeOffOnlineExp.class));
        mysheet.add(new ExcelExp("在线率统计", videoOnlineRateExps, VideoOnlineRateExp.class));

        // 导出Excel
        ExcelUtilManySheet<List<ExcelExp>> util = new ExcelUtilManySheet<>(mysheet);
        util.exportExcelManySheet(response, mysheet);
        log.info("导出结束");
    }

    // 新增辅助方法：批量添加设备统计信息
    private void addDeviceStats(List<VideoDailyExp> list, AreaDeptEnum areaDeptEnum,
                                String typeCode, String typeName,
                                List<VideoTypeOffOnlineExp> offLineList,
                                List<VideoOnlineRateExp> onlineList) {
        offLineList.add(getListOfflineCountInfo(list, typeCode, areaDeptEnum));
        onlineList.add(getListOnLineCountInfo(list, typeCode, areaDeptEnum));
    }

    // 新增辅助方法：添加合计统计
    private void addTotalStats(List<VideoTypeOffOnlineExp> offLineList,
                               List<VideoOnlineRateExp> onlineList,
                               long face, long car, long video) throws NoSuchFieldException, IllegalAccessException {
        // 离线统计合计
        VideoTypeOffOnlineExp allFaceVideosOffline = new VideoTypeOffOnlineExp();
        setAllVideoTypeOffOnlineExpCount(offLineList, allFaceVideosOffline, "人脸");

        VideoTypeOffOnlineExp allCarVideosOffline = new VideoTypeOffOnlineExp();
        setAllVideoTypeOffOnlineExpCount(offLineList, allCarVideosOffline, "卡口");

        VideoTypeOffOnlineExp allVideosOffline = new VideoTypeOffOnlineExp();
        setAllVideoTypeOffOnlineExpCount(offLineList, allVideosOffline, "视频");

        offLineList.add(allFaceVideosOffline);
        offLineList.add(allCarVideosOffline);
        offLineList.add(allVideosOffline);

        // 在线统计合计
        VideoOnlineRateExp allFaceVideosOnline = new VideoOnlineRateExp();
        setAllVideoTypeOnlineExpCount(face, onlineList, allFaceVideosOnline, "人脸");

        VideoOnlineRateExp allCarVideosOnline = new VideoOnlineRateExp();
        setAllVideoTypeOnlineExpCount(car, onlineList, allCarVideosOnline, "卡口");

        VideoOnlineRateExp allVideosOnline = new VideoOnlineRateExp();
        setAllVideoTypeOnlineExpCount(video, onlineList, allVideosOnline, "视频");

        onlineList.add(allFaceVideosOnline);
        onlineList.add(allCarVideosOnline);
        onlineList.add(allVideosOnline);
    }



    //离线设备数据，合计对象，信息装配
    public void setAllVideoTypeOffOnlineExpCount(List<VideoTypeOffOnlineExp> videoTypeOffOnlineExps,
                                                                  VideoTypeOffOnlineExp videoTypeOffOnlineExp,
                                                                  String type) throws NoSuchFieldException, IllegalAccessException {
        List<VideoTypeOffOnlineExp> filterExps = videoTypeOffOnlineExps.stream().filter(exp -> type.equals(exp.getType())).collect(Collectors.toList());
        long allCount = 0;
        for (VideoTypeOffOnlineExp obj :filterExps){
            //obj 对象代表了该区 筛选了的指定type的设备的对象
            //计算总的设备离线总数
            long count  = Long.parseLong(obj.getOfflineCount());
            allCount += count;
            //计算每日
            for (int i =1 ;i <= 31; i++){
                String fieldName = "day" + i;
                Field dayField = obj.getClass().getDeclaredField(fieldName);
                dayField.setAccessible(true);
                Object value = dayField.get(obj); //获取字段值
                if (value != null) {
                    long newFieldValue = Long.parseLong(value.toString());
                    //获取需要填充的字段
                    Field videoTypeOffOnlineExpField = videoTypeOffOnlineExp.getClass().getDeclaredField(fieldName);
                    videoTypeOffOnlineExpField.setAccessible(true);
                    //先获取一次
                    Object oldValue = videoTypeOffOnlineExpField.get(videoTypeOffOnlineExp);

                    //为null 第一次直接诶赋值
                    if (oldValue == null){
                        videoTypeOffOnlineExpField.set(videoTypeOffOnlineExp,newFieldValue + "");
                    }else {
                        //存在旧值 相加覆盖
                        videoTypeOffOnlineExpField.set(videoTypeOffOnlineExp, (Long.parseLong(oldValue.toString()) + newFieldValue) + "");
                    }
                }



            }

        }
        videoTypeOffOnlineExp.setOfflineCount(String.valueOf(allCount));
        videoTypeOffOnlineExp.setArea("自贡市");
        videoTypeOffOnlineExp.setType(type + "合计");
    }
    //在线设备数据，合计对象，信息装配
    public void setAllVideoTypeOnlineExpCount(
            long allVideoCount,List<VideoOnlineRateExp> videoOnlineRateExps,
                                              VideoOnlineRateExp videoOnlineRateExp,
                                              String type) throws NoSuchFieldException, IllegalAccessException{
        List<VideoOnlineRateExp> filterExps = videoOnlineRateExps.stream().filter(item -> type.equals(item.getType())).collect(Collectors.toList());

        for (VideoOnlineRateExp obj :filterExps){
            for (int i = 1;i <= 31; i++){
                String countFileName = "count" +i;
                Field countField = obj.getClass().getDeclaredField(countFileName);
                countField.setAccessible(true);
                long newFieldValue = countField.getLong(obj);
                Field videoOnlineRateExpField = obj.getClass().getDeclaredField(countFileName);
                videoOnlineRateExpField.setAccessible(true);
                Object oldValue = videoOnlineRateExpField.get(videoOnlineRateExp);
                if (oldValue == null){
                    videoOnlineRateExpField.setLong(videoOnlineRateExp,newFieldValue);
                }else {
                    //存在旧值 相加覆盖
                    videoOnlineRateExpField.setLong(videoOnlineRateExp, Long.parseLong(oldValue.toString()) + newFieldValue);
                }
            }
        }
        //计算完每日在线设备数
        //循环一个月
        for (int i = 1;i <= 31 ;i++){
            //在线率计算
            String countFileName = "count" +i;
            Field countField = videoOnlineRateExp.getClass().getDeclaredField(countFileName);
            countField.setAccessible(true);
            long newFieldValue = countField.getLong(videoOnlineRateExp);
            String fieldName = "day" + i;
            //每日在线率
            double rate = (double) newFieldValue / allVideoCount;
            //反射添加到对象属性中
            Field field = videoOnlineRateExp.getClass().getDeclaredField(fieldName);
            //设置每日在线设备设备数
            field.setAccessible(true);
            String rateStr = String.format("%.2f", rate * 100) +"%";
            if (!"0.00%".equals(rateStr)){
                field.set(videoOnlineRateExp, rateStr);
            }

        }


        videoOnlineRateExp.setArea("自贡市");
        videoOnlineRateExp.setType(type + "合计");
    }





    /**
     * 计算离线设备excel对象信息
     * @param videoDailyExps 传入的设备集合信息
     * @param type 设备类型 1人脸 2车辆 3视频
     * @param areaDeptEnum 区域
     * @return
     */
    public VideoTypeOffOnlineExp getListOfflineCountInfo(List<VideoDailyExp> videoDailyExps,
                                                         String type,
                                                         AreaDeptEnum areaDeptEnum
                                                        ){
        VideoTypeOffOnlineExp videoTypeOffOnlineExp = new VideoTypeOffOnlineExp();

        List<VideoDailyExp> list = videoDailyExps.stream()
                .filter(device ->device.getType() != null && device.getType().contains(type)).collect(Collectors.toList());
        log.error("筛选完设备类型 ：{} 后集合的大小：{}",type,list.size());
        //离线数量
        try {
            //设置离线数量 以及每日离线数量
            setVideoTypeOffOnlineExpCountAndDays(list,videoTypeOffOnlineExp);
        } catch (Exception e) {
            log.error(e.getMessage());
        }
        //设备类型
        if ("1".equals(type)){
            videoTypeOffOnlineExp.setType("人脸");
        }else if ("2".equals(type)){
            videoTypeOffOnlineExp.setType("卡口");
        }
        else if ("3".equals(type)){
            videoTypeOffOnlineExp.setType("视频");
        }

        //修改区域
        videoTypeOffOnlineExp.setArea(areaDeptEnum == null ? "未知" : areaDeptEnum.getName());
        return videoTypeOffOnlineExp;
    }

    private void setVideoTypeOffOnlineExpCountAndDays(List<VideoDailyExp> videoDailyExps,VideoTypeOffOnlineExp videoTypeOffOnlineExp)throws NoSuchFieldException, IllegalAccessException {
        //循环一个月
        //离线总数
        long AllOffLineCount = 0;
        for (VideoDailyExp videoDailyExp : videoDailyExps) {
            if (videoDailyExp.isAllOfflineByMonth()) {
                AllOffLineCount++;
            }
        }
        //是合计数据不需要下方数据

            for (int i = 1; i <= 31; i++) {
                //每日离线数
                long count = 0;
                String fieldName = "day" + i;
                for (VideoDailyExp videoDailyExp : videoDailyExps) {
                    // 构造字段名
                    Field field = videoDailyExp.getClass().getDeclaredField(fieldName);
                    // 确保字段是私有的可以访问
                    field.setAccessible(true);
                    // 获取字段值
                    String value = (String) field.get(videoDailyExp);
                    if ("离线".equals(value)) {
                        count++;
                    }
                }
                //反射添加到对象属性中
                Field field = videoTypeOffOnlineExp.getClass().getDeclaredField(fieldName);
                field.setAccessible(true);
                String rateStr = count + "";
                if (!"0".equals(rateStr)) {
                    field.set(videoTypeOffOnlineExp, rateStr);
                }

            }
//        }
        videoTypeOffOnlineExp.setOfflineCount(String.valueOf(AllOffLineCount));
    }

    /**
     * 计算在线设备excel对象信息
     * @param videoDailyExps 传入的设备集合信息
     * @param type 设备类型 1人脸 2车辆 3视频
     * @param areaDeptEnum 区域
     * @return
     */
    public VideoOnlineRateExp getListOnLineCountInfo(List<VideoDailyExp> videoDailyExps,
                                                         String type,
                                                         AreaDeptEnum areaDeptEnum
                                                         ){
        VideoOnlineRateExp videoOnlineRateExp = new VideoOnlineRateExp();

        List<VideoDailyExp> list = videoDailyExps.stream()
                .filter(device ->device.getType() != null && device.getType().contains(type)).collect(Collectors.toList());
        log.error("筛选完设备类型 ：{} 后集合的大小：{}",type,list.size());
        //离线数量
        try {
            setVideoOnlineRateExpCountAndDays(list,videoOnlineRateExp);
        } catch (Exception e) {
            log.error(e.getMessage());
        }
        //设备类型
        if ("1".equals(type)) {
             videoOnlineRateExp.setType("人脸");
        } else if ("2".equals(type)) {
            videoOnlineRateExp.setType("卡口");
        } else if ("3".equals(type)) {
            videoOnlineRateExp.setType("视频");
        }
        //修改区域
        videoOnlineRateExp.setArea(areaDeptEnum == null ? "未知" : areaDeptEnum.getName());
        return videoOnlineRateExp;
    }


    private void setVideoOnlineRateExpCountAndDays(List<VideoDailyExp> videoDailyExps,VideoOnlineRateExp videoOnlineRateExp)throws NoSuchFieldException, IllegalAccessException {
        //循环一个月
        for (int i = 1;i <= 31 ;i++){
            //在线率计算
            long count = 0;
            String fieldName = "day" + i;
            String countName = "count" + i;
            for(VideoDailyExp videoDailyExp: videoDailyExps){
                // 构造字段名
                Field field = videoDailyExp.getClass().getDeclaredField(fieldName);
                // 确保字段是私有的可以访问
                field.setAccessible(true);
                // 获取字段值
                String value = (String) field.get(videoDailyExp);
                if ("在线".equals(value)) {
                    count ++;
                }
            }
            //每日在线率
            double rate = (double) count / videoDailyExps.size();
            //反射添加到对象属性中
            Field field = videoOnlineRateExp.getClass().getDeclaredField(fieldName);
            Field countField = videoOnlineRateExp.getClass().getDeclaredField(countName);
            countField.setAccessible(true);
            //设置每日在线设备设备数
            countField.setLong(videoOnlineRateExp, count);
            field.setAccessible(true);
            String rateStr = String.format("%.2f", rate * 100) +"%";
            if (!"0.00%".equals(rateStr)){
                field.set(videoOnlineRateExp, rateStr);
            }

        }
    }


@@ -811,6 +1235,8 @@
            exportForm.setDeptIds(deptIds);
        }
        Query query = getQuery(exportForm);


        //月份每日在线数据
        List<TMonitorResult> onlineResult = mongoTemplate.find(query, TMonitorResult.class);
        // 使用 Collectors.toMap 去重，保留每个 No 的第一个遇到的元素
@@ -820,6 +1246,7 @@
                        Function.identity(),  // valueMapper，直接使用对象本身
                        (existing, replacement) -> existing // mergeFunction，如果有重复，保留第一个
                ));

        // 将 Map 转换为 List
        List<TMonitorResult> tMonitorResults = new ArrayList<>(uniqueResultsMap.values());
        //获取动态列数据
@@ -919,6 +1346,7 @@
    @Override
    public Map<String, Object> videoHome(HomeQuery monitorQuery) throws ParseException, InvocationTargetException, NoSuchMethodException, InstantiationException, IllegalAccessException {
        List<HomeVideoVO> results = new ArrayList<>();

        String month = monitorQuery.getDate();
        if (StringUtils.isEmpty(month)) {
            //如果为空查本月的数据
@@ -935,23 +1363,60 @@
        calendar.set(Calendar.DAY_OF_MONTH, 1);
        // 获取月份第一天的Date
        Date startDate = calendar.getTime();
        log.info("首页查询开始日期:{}",startDate);
        // 设置Calendar为月份的最后一天（通过增加一个月份然后减去一天）
        calendar.add(Calendar.MONTH, 1);
        calendar.add(Calendar.DAY_OF_MONTH, -1);
        // 获取月份最后一天的Date
        Date endDate = calendar.getTime();

        log.info("首页查询结束日期:{}",endDate);
        String constructionType = monitorQuery.getConstructionType();
        List<String> deviceNoList = new ArrayList<>();
        if (StringUtils.isNotBlank(constructionType)){
            List<MonitorConstruction> serialNumberListByConstructionType = monitorConstructionService.getSerialNumberListByConstructionType(constructionType);
            if (!CollectionUtils.isEmpty(serialNumberListByConstructionType)){
                deviceNoList = serialNumberListByConstructionType.stream().map(MonitorConstruction::getSerialNumber).collect(Collectors.toList());
            }
        }
        if (StringUtils.isNotBlank(constructionType) && deviceNoList.isEmpty()) {
            // 当constructionType有值但无对应设备时，返回包含空列表的Map
            Map<String, Object> emptyResult = new HashMap<>();
            emptyResult.put("list", results); // results此时为空列表
            emptyResult.put("baseLine", 0); // 可根据业务默认基准线值调整
            return emptyResult;
        }
        //mongo查录像状态
        MongoDatabase database = mongoTemplate.getDb();
        MongoCollection<Document> collection = database.getCollection("uy_record_meta_d_sum");
        Integer examineTag = monitorQuery.getExamineTag();
        String arealayerno = monitorQuery.getArea();
        Document matchConditions = new Document("statTime", new Document("$gte", startDate).append("$lte", endDate));
        if (!deviceNoList.isEmpty()) {
            log.info("打印分建类型no集合:{}",deviceNoList);
            matchConditions.append("no", new Document("$in", deviceNoList));
        }
        // 根据examineTag的值动态添加额外的条件
        if (examineTag != null && examineTag.equals(1)) {
            matchConditions.append("provinceTag", true);
        } else if (examineTag != null && examineTag.equals(2)) {
            matchConditions.append("deptTag", true);
        } else if(StringUtils.isNotBlank(arealayerno)){
            matchConditions.append("arealayerno",
                    new Document("$regex", "^" + arealayerno));
        }
        Document noExpr = new Document("$and", Arrays.asList(
                new Document("$gte", Arrays.asList(new Document("$strLenCP", "$no"), 3)),
                new Document("$ne", Arrays.asList(
                        new Document("$substrCP", Arrays.asList(
                                "$no",
                                new Document("$subtract", Arrays.asList(new Document("$strLenCP", "$no"), 3)),
                                1
                        )),
                        "3"
                ))
        ));
// 正确添加$expr条件（键为"$expr"，值为上面定义的条件）
        matchConditions.append("$expr", noExpr);
        // 构建聚合管道
        List<Document> pipeline = Arrays.asList(
                new Document("$match", matchConditions),
@@ -965,7 +1430,14 @@
                        ))
                        .append("loseCount", new Document("$sum",
                                new Document("$cond", Arrays.asList(
                                        new Document("$in", Arrays.asList("$recordStatus", Arrays.asList(-1, 0))),
                                        new Document("$eq", Arrays.asList("$recordStatus", 0)),
                                        1,
                                        0
                                ))
                        ))
                        .append("errCount", new Document("$sum",
                                new Document("$cond", Arrays.asList(
                                        new Document("$eq", Arrays.asList("$recordStatus", -1)),
                                        1,
                                        0
                                ))
@@ -979,6 +1451,8 @@
            homeVideoVO.setCreateDate(doc.getDate("_id"));
            homeVideoVO.setIntegrityNum(doc.getInteger("normalCount"));
            homeVideoVO.setLoseNum(doc.getInteger("loseCount"));
            homeVideoVO.setErrNum(doc.getInteger("errCount"));

            results.add(homeVideoVO);
        }

@@ -988,12 +1462,31 @@
        List<Document> onlineMatch = new ArrayList<>();
        onlineMatch.add(new Document("mongoCreateTime", new Document("$gte", startDate).append("$lte", endDate)));
        onlineMatch.add(new Document("monitorType", new Document("$regex", "1")));
        if (!deviceNoList.isEmpty()) {
            onlineMatch.add(new Document("no", new Document("$in", deviceNoList)));
        }
        if (examineTag != null && examineTag.equals(1)) {
            onlineMatch.add(new Document("provinceTag", true));
        } else if (examineTag != null && examineTag.equals(2)) {
            onlineMatch.add(new Document("deptTag", true));
        }
        } else if(StringUtils.isNotBlank(arealayerno)){
            Document noStartsWith = new Document("no", new Document("$regex", "^" + arealayerno));

            // 构建倒数第三位不是3的条件
            Document noThirdLastNot3 = new Document("$expr", new Document("$and", Arrays.asList(
                    new Document("$gte", Arrays.asList(new Document("$strLenCP", "$no"), 3)),
                    new Document("$ne", Arrays.asList(
                            new Document("$substrCP", Arrays.asList(
                                    "$no",
                                    new Document("$subtract", Arrays.asList(new Document("$strLenCP", "$no"), 3)),
                                    1
                            )),
                            "3"
                    ))
            )));
            // 将两个条件用$and组合后添加到条件列表
            onlineMatch.add(new Document("$and", Arrays.asList(noStartsWith, noThirdLastNot3)));
        }
        // 构建聚合管道
        List<Document> onlinePipeline = Arrays.asList(
                new Document("$match", new Document("$and", onlineMatch)),
@@ -1007,6 +1500,10 @@
                        ))
                )
        );
        //排除卡口集合



        // 执行聚合查询并获取结果
        AggregateIterable<Document> onlineResult = onlineCollection.aggregate(onlinePipeline);
        for (Document doc : onlineResult) {
@@ -1043,6 +1540,22 @@
    @Override
    public void export(HttpServletResponse response, TMonitorVO tMonitor) {
        List<TMonitorExp> monitors = tMonitorMapper.exportTMonitorList(tMonitor);
        //过滤出设备建设类型
        if (StringUtils.isNotBlank(tMonitor.getConstructionType())){
            List<MonitorConstruction> list =
                    monitorConstructionService.getSerialNumberListByConstructionType(tMonitor.getConstructionType());
            //获得设备编号集合 通过建设类型标签
            List<String> serialNumberList = list.stream().map(MonitorConstruction::getSerialNumber).collect(Collectors.toList());
            monitors = monitors.stream()
                    .filter(result -> {
                        String sn = result.getSerialNumber();
                        // 任一字段非空且在集合中即可
                        return (sn != null && serialNumberList.contains(sn));
                    })
                    .collect(Collectors.toList());
        }


        //获取动态列数据
        List<Integer> pointIds = monitors.stream().map(TMonitorExp::getPointId).collect(Collectors.toList());
        List<DynamicColumnVO> dynamics = dynamicColumnMapper.getDynamicsByIds("t_yw_point", pointIds);
@@ -1138,10 +1651,13 @@
        Integer examineTag = monitorQuery.getExamineTag();
        // 构建基本的$match条件
        List<Document> matchConditions = new ArrayList<>();
        String arealayerno = monitorQuery.getArea();
        matchConditions.add(new Document("mongoCreateTime", new Document("$gte", startDate).append("$lte", endDate)));
        matchConditions.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR)));
        if (examineTag != null && examineTag.equals(1)) {
            matchConditions.add(new Document("provinceTag", true));
        }else if(StringUtils.isNotBlank(arealayerno)){
            matchConditions.add(new Document("orgCode",new Document("$eq", arealayerno)));
        }
        // 构建聚合管道
        List<Document> pipeline = Arrays.asList(
@@ -1166,6 +1682,8 @@
        onlineMatch.add(new Document("monitorType", new Document("$regex", "2")));
        if (examineTag != null && examineTag.equals(1)) {
            onlineMatch.add(new Document("provinceTag", true));
        }else if(StringUtils.isNotBlank(arealayerno)){
            onlineMatch.add(new Document("no", new Document("$regex", "^" + arealayerno)));
        }
        // 构建聚合管道
        List<Document> onlinePipeline = Arrays.asList(
@@ -1244,6 +1762,7 @@
        calendar.add(Calendar.DAY_OF_MONTH, -1);
        // 获取月份最后一天的Date
        Date endDate = calendar.getTime();
        String arealayerno = monitorQuery.getArea();
        //mongo查抓拍量
        MongoDatabase database = mongoTemplate.getDb();
        MongoCollection<Document> collection = database.getCollection("hk_snapshot_data_monitor");
@@ -1254,6 +1773,8 @@
        matchConditions.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_FACE)));
        if (examineTag != null && examineTag.equals(1)) {
            matchConditions.add(new Document("provinceTag", true));
        }else if(StringUtils.isNotBlank(arealayerno)){
            matchConditions.add(new Document("orgCode",new Document("$eq", arealayerno)));
        }
        // 构建聚合管道
        List<Document> pipeline = Arrays.asList(
@@ -1280,6 +1801,8 @@
        onlineMatch.add(new Document("monitorType", new Document("$regex", "3")));
        if (examineTag != null && examineTag.equals(1)) {
            onlineMatch.add(new Document("provinceTag", true));
        }else if(StringUtils.isNotBlank(arealayerno)){
            onlineMatch.add(new Document("no", new Document("$regex", "^" + arealayerno)));
        }
        // 构建聚合管道
        List<Document> onlinePipeline = Arrays.asList(
@@ -1373,6 +1896,7 @@
    private void setOnlineDaily(VideoDailyExp videoDailyExp, TMonitorResult result, List<TMonitorResult> onlines) throws NoSuchFieldException, IllegalAccessException {
        //一个设备当月在线情况
        List<TMonitorResult> onlineResult = onlines.stream().filter(online -> online.getNo().equals(result.getNo())).collect(Collectors.toList());
        videoDailyExp.setOnlineStateList(onlineResult);
        for (TMonitorResult monitorResult : onlineResult) {
            int dayOfMonth = monitorResult.getMongoCreateTime().getDayOfMonth();
            String online = "";
@@ -1388,6 +1912,8 @@
            field.setAccessible(true);
            field.set(videoDailyExp, online);
        }


    }

    //设置每日录像数据
@@ -1414,13 +1940,13 @@
    private void setLoseDaily(VideoDailyExp videoDailyExp, List<RecordMetaDSumResult> recordResults) throws NoSuchFieldException, IllegalAccessException {
        //一个设备当月在线情况
        for (RecordMetaDSumResult recordResult : recordResults) {
            int dayOfMonth = DateUtils.getDayOfMonth(recordResult.getStatTime());
            int dayOfMonth = DateUtils.getDayOfMonth(recordResult.getStatTime());  //获取启动日期是当月第几天
            //反射赋值，字段统一定义为day+1，2，3...
            Field field = videoDailyExp.getClass().getDeclaredField("day" + dayOfMonth);
            field.setAccessible(true);
            //防止转换为科学计数法
            BigDecimal bigDecimal = BigDecimal.valueOf(recordResult.getMissDuration() == null ? 0 : recordResult.getMissDuration());
            field.set(videoDailyExp, bigDecimal.toString());
            BigDecimal bigDecimal = BigDecimal.valueOf(recordResult.getMissDuration() == null ? 0 : (recordResult.getMissDuration()) * 60);
            field.set(videoDailyExp, bigDecimal.setScale(2, RoundingMode.HALF_UP).toString());
        }
    }
}