fv-sys-java/jeecg-module-gather/src/main/java/org/jeecg/modules/fpgJob/LeanModelStatistics.java

package org.jeecg.modules.fpgJob;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import lombok.extern.slf4j.Slf4j;
import org.jeecg.common.util.DateUtils;
import org.jeecg.common.util.oConvertUtils;
import org.jeecg.modules.device.entity.DeviceInformation;
import org.jeecg.modules.device.service.IDeviceInformationService;
import org.jeecg.modules.devicePoint.service.IDevicePointService;
import org.jeecg.modules.fpgJob.entity.FpgLeanModel;
import org.jeecg.modules.fpgJob.service.IFpgLeanModelService;
import org.jeecg.modules.gatherData.entity.*;
import org.jeecg.modules.gatherData.service.IFpgGatherDataService;
import org.jeecg.modules.peaksAndValleysTimeConfig.entity.PeaksAndValleysTimeConfig;
import org.jeecg.modules.peaksAndValleysTimeConfig.entity.SystemVariable;
import org.jeecg.modules.peaksAndValleysTimeConfig.service.IPeaksAndValleysTimeConfigService;
import org.jeecg.modules.peaksAndValleysTimeConfig.service.ISystemVariableService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Sort;
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.data.mongodb.core.query.Update;
import org.springframework.data.mongodb.core.query.UpdateDefinition;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.time.*;
import java.time.format.DateTimeFormatter;
import java.util.*;
import java.util.concurrent.atomic.AtomicReference;
import java.util.stream.Collectors;


@Slf4j
@EnableAsync
@Component
@EnableScheduling
public class LeanModelStatistics {

    @Autowired
    IFpgLeanModelService fpgLeanModelService;

    @Autowired
    IFpgGatherDataService fpgGatherDataService;

    @Autowired
    IDevicePointService devicePointService;

    @Autowired
    IDeviceInformationService deviceInformationService;

    @Autowired
    private IPeaksAndValleysTimeConfigService peaksAndValleysTimeConfigService;

    @Autowired
    private ISystemVariableService systemVariableService;

    @Autowired
    MongoTemplate mongoTemplate;


    /**
     * 精益模型统计数据
     * 执行完后，间隔1秒继续执行
     */
    @Scheduled(cron = "0 */1 * * * ?")
//    @Scheduled(cron = "*/30 * * * * ?")
    public void t1(){
        leanModel();
    }

    /**
     * 变更占比
     *  0 0 03 * * *     每日3点执行 测试期间1ms一次
     */
    @Scheduled(cron = "0 0 03 * * ?")
//    @Scheduled(fixedDelay = 1000)
    public void t2(){
        changeProportion();
    }

    /**
     * 设备启停统计数据
     */
    @Scheduled(cron = "0 */1 * * * ?")
//    @Scheduled(cron = "*/30 * * * * ?")
    public void t3(){
        deviceStatistics();
    }


    public void changeProportion(){
        log.info("变更占比");
        // 峰平谷精益模型配置获取
        LambdaQueryWrapper<FpgLeanModel> leanmodelQuery = new LambdaQueryWrapper<FpgLeanModel>().eq(FpgLeanModel::getStatus, "1");
        List<FpgLeanModel> fpgLeanModellist = fpgLeanModelService.list(leanmodelQuery);
        LocalDate yesterday = LocalDate.now().minusDays(1); // 获取今天的日期 减去一天，得到昨天的日期
        // 处理数据业务逻辑
        fpgLeanModellist.forEach(fpgLeanModeInfo -> {
            Query query = new Query();
            query.addCriteria(Criteria.where("proportion").is(1))
                    .addCriteria(Criteria.where("dates").is(yesterday.toString()));
            List<FpgStatiscsModelMongodb> fpgStatiscsModelMongoList = mongoTemplate.find(query, FpgStatiscsModelMongodb.class, "leanmodel_" + fpgLeanModeInfo.getLeanModelCode());
            BigDecimal zb = new BigDecimal("100");
            fpgStatiscsModelMongoList.forEach(fpgStatiscsModelMongoInfo -> { // 循环处理采集数据处理
                BigDecimal proportion = fpgStatiscsModelMongoInfo.getPower();
                BigDecimal topsProportion = fpgStatiscsModelMongoInfo.getTopsPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongoInfo.getTopsPower();
                BigDecimal peaksProportion = fpgStatiscsModelMongoInfo.getPeaksPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongoInfo.getPeaksPower();
                BigDecimal flatProportion = fpgStatiscsModelMongoInfo.getFlatPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongoInfo.getPeaksPower();
                BigDecimal valleysProportion = fpgStatiscsModelMongoInfo.getValleysPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongoInfo.getPeaksPower();
                // 核算占比
                UpdateDefinition update = new Update();
                ((Update) update).set("proportion", 2);
                if(topsProportion.compareTo(new BigDecimal("0.00")) > 0) { // 尖
                    ((Update) update).set("topsProportion", topsProportion.divide(proportion, 4, RoundingMode.HALF_UP).multiply(zb));
                }
                if(peaksProportion.compareTo(new BigDecimal("0.00")) > 0) { // 峰
                    ((Update) update).set("peaksProportion", peaksProportion.divide(proportion, 4, RoundingMode.HALF_UP).multiply(zb));
                }
                if(flatProportion.compareTo(new BigDecimal("0.00")) > 0) { // 平
                    ((Update) update).set("flatProportion", flatProportion.divide(proportion, 4, RoundingMode.HALF_UP).multiply(zb));
                }
                if(valleysProportion.compareTo(new BigDecimal("0.00")) > 0) { // 谷
                    ((Update) update).set("valleysProportion", valleysProportion.divide(proportion, 4, RoundingMode.HALF_UP).multiply(zb));
                }
                // 保存
                mongoTemplate.updateFirst(query, update, FpgStatiscsModelMongodb.class, "leanmodel_" + fpgLeanModeInfo.getLeanModelCode());
            });
        });
    }

    // 设备启停统计数据
    public void deviceStatistics() {
        log.info("设备日常统计");
        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        // 获取当前时间
        LocalDateTime newTime = LocalDateTime.now().plusHours(8);
        Date curentDate = Date.from(newTime.atZone(ZoneId.systemDefault()).toInstant());
        // 峰平谷设备列表
        LambdaQueryWrapper<DeviceInformation> objectLambdaQueryWrapper = new LambdaQueryWrapper<>();
        List<DeviceInformation> deviceInformationllist = deviceInformationService.list(objectLambdaQueryWrapper);
        // 尖峰平谷时段配置
        List<PeaksAndValleysTimeConfig>  peaksAndValleysTimeConfiglist = peaksAndValleysTimeConfigService.list();
        BigDecimal zb = new BigDecimal("100");
        //遍历设备集合
        deviceInformationllist.forEach(deviceInformationlinfo -> {
            // 查询设备对应数据
            LambdaQueryWrapper<FpgGatherData> fpgGatherQuery = new LambdaQueryWrapper<FpgGatherData>().isNull(FpgGatherData::getFpgTotalUpdatetime).eq(FpgGatherData::getDeviceInformationId, deviceInformationlinfo.getId()).isNotNull(FpgGatherData::getRunCurrent).isNotNull(FpgGatherData::getActivePower).orderByAsc(FpgGatherData::getCreateTime).last("limit 1000");
            List<FpgGatherData> fpgGatherList = fpgGatherDataService.list(fpgGatherQuery);
            // 系统变量查询
            QueryWrapper<SystemVariable> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("variable_address", "sys_run_current_limit");
            queryWrapper.eq("status",  0);
            SystemVariable systemVariable = systemVariableService.getOne(queryWrapper);

            LambdaQueryWrapper<FpgGatherData> dataLambdaQueryWrapper = new LambdaQueryWrapper<>();
            dataLambdaQueryWrapper.eq(FpgGatherData::getDeviceInformationId,deviceInformationlinfo.getId());
            dataLambdaQueryWrapper.orderByDesc(FpgGatherData::getCreateTime).last("LIMIT 1");
            List<FpgGatherData> list = fpgGatherDataService.list(dataLambdaQueryWrapper);

            if (!list.isEmpty()) {
                FpgGatherData latestRecord = list.get(0);
                // 使用 latestRecord
                DeviceInformation deviceInformation = deviceInformationService.getOne(
                        new LambdaQueryWrapper<DeviceInformation>()
                                .eq(DeviceInformation::getId, latestRecord.getDeviceInformationId())
                );
                // 比较大小
                int result = compareStringWithBigDecimal(systemVariable.getDefaultValue(), latestRecord.getRunCurrent());
                if (result > 0) {
                    deviceInformation.setStatus("1");
                } else if (result < 0) {
                    deviceInformation.setStatus("0");
                }
                // 只有在 systemVariable 不为空时才进行更新操作
                deviceInformationService.updateById(deviceInformation);
            }


            // 处理数据业务逻辑
            fpgGatherList.forEach(fpgGatherData -> { // 循环处理采集数据处理
                try {
                    fpgGatherData.setFpgTotalUpdatetime(new Date());
                    // 采集时间
                    Instant instant = fpgGatherData.getCreateTime().toInstant();
                    LocalDateTime localDateTime = LocalDateTime.ofInstant(instant, ZoneId.systemDefault());
                    // 上报日期
                    String dayDate = new SimpleDateFormat("yyyy-MM-dd").format(fpgGatherData.getCreateTime());
                    String classs = "";
                    // 班次处理
                    if (containsCreateTime(localDateTime, dayDate + " 00:00:00", dayDate + " 07:59:59")) { // 夜班
                        classs = "night";
                    } else if (containsCreateTime(localDateTime, dayDate + " 08:00:00", dayDate + " 15:59:59")) { // 白班
                        classs = "white";
                    } else if (containsCreateTime(localDateTime, dayDate + " 16:00:00", dayDate + " 23:59:59")) { // 中班
                        classs = "center";
                    }
                    // 定义尖峰平谷
                    AtomicReference<String> jfpgStr = new AtomicReference<>("");
                    // 判断尖峰平谷时段
                    peaksAndValleysTimeConfiglist.forEach(peaksAndValleysTimeConfig -> {
                        if (containsCreateTime(localDateTime, dayDate + " " + peaksAndValleysTimeConfig.getStartTime(), dayDate + " " + peaksAndValleysTimeConfig.getEndTime())) {
                            jfpgStr.set(peaksAndValleysTimeConfig.getType());
                        }
                    });
                    // 功率
                    BigDecimal runPower = fpgGatherData.getActivePower().compareTo(new BigDecimal("0.00")) > 0 ? fpgGatherData.getActivePower().divide(new BigDecimal(12), 8, RoundingMode.HALF_UP) : new BigDecimal("0.00");
                    // 占比
                    BigDecimal proportion = new BigDecimal("0.00");
                    // 运行时常
                    BigDecimal runTime = new BigDecimal("300");
                    // 电流
                    BigDecimal selectricCurrent = fpgGatherData.getRunCurrent();
                    // 设备启停统计 start
                    String startStopMonKey = "total_startstop";
                    DeviceStatiscsModelData startStopStatiscsData = new DeviceStatiscsModelData(fpgGatherData, startStopMonKey, dayDate, classs, curentDate, curentDate);
                    // 组合mongodb条件
                    Query queryStartStop = new Query()
                            .addCriteria(Criteria.where("deviceRegionId").is(fpgGatherData.getDeviceRegionId()))
                            .addCriteria(Criteria.where("deviceInformationId").is(fpgGatherData.getDeviceInformationId()))
                            .with(Sort.by(Sort.Order.desc("deviceStartTime"))).limit(1);
                    // 查找设备运行记录
                    DeviceStatiscsModelMongodb startStopMongo = mongoTemplate.findOne(queryStartStop, DeviceStatiscsModelMongodb.class, startStopMonKey);
                    if(startStopMongo != null){ // 存在该设备记录
                        Date deviceStopTimeEnd = DateUtils.addHours(fpgGatherData.getCreateTime(), 0);
                        if (fpgGatherData.getRunCurrent().compareTo(new BigDecimal(systemVariable.getDefaultValue())) < 0 && "1".equals(startStopMongo.getDeviceStopTimeBank())) {
                            // 设备正常运行的 直接停止更新启停时间
                            Date startDate = dateFormat.parse(startStopMongo.getDeviceStartTime());
                            // 将 Date 转换为 Instant
                            Instant oldInstant = startDate.toInstant();
                            Instant newInstant = fpgGatherData.getCreateTime().toInstant();
                            // 计算时间差
                            Duration duration = Duration.between(oldInstant, newInstant);
                            // 获取时间差的秒数
                            long diffInSeconds = duration.getSeconds();
                            BigDecimal timeDifference = new BigDecimal(diffInSeconds);
                            UpdateDefinition updateStartStop = new Update()
                                    .set("updateTime", curentDate).set("deviceStopTime", DateUtils.date2Str(deviceStopTimeEnd, DateUtils.datetimeFormat.get()))
                                    .set("deviceStopTimeBank", "2").set("ingTime", timeDifference);
                            Query modifyStartStop = new Query()
                                    .addCriteria(Criteria.where("deviceRegionId").is(fpgGatherData.getDeviceRegionId()))
                                    .addCriteria(Criteria.where("deviceInformationId").is(fpgGatherData.getDeviceInformationId()))
                                    .addCriteria(Criteria.where("_id").is(startStopMongo.get_id()));
                            mongoTemplate.findAndModify(modifyStartStop, updateStartStop, DeviceStatiscsModelMongodb.class, startStopMonKey);
                        } else if(fpgGatherData.getRunCurrent().compareTo(new BigDecimal(systemVariable.getDefaultValue())) > 0  && "1".equals(startStopMongo.getDeviceStopTimeBank())){
                            // 设备运行累加运行记录
                            BigDecimal oldPower = startStopMongo.getPower() == null ? new BigDecimal("0.00") : startStopMongo.getPower();
                            BigDecimal oldSelectricCurrent = startStopMongo.getSelectricCurrent() == null ? new BigDecimal("0.00") : startStopMongo.getSelectricCurrent();
                            // 更新启动运行数据
                            Date deviceStopTime = DateUtils.addHours(fpgGatherData.getCreateTime(), 0);
                            Date startDate = dateFormat.parse(startStopMongo.getDeviceStartTime());
                            // 将Date转换为Instant
                            Instant oldInstant = startDate.toInstant();
                            Instant newInstant = fpgGatherData.getCreateTime().toInstant();
                            // 计算时间差
                            Duration duration = Duration.between(oldInstant, newInstant);
                            // 获取时间差的秒数
                            long diffInSeconds = duration.getSeconds();
                            BigDecimal timeDifference = new BigDecimal(diffInSeconds);
                            UpdateDefinition updateStartStop = new Update()
                                    .set("power", oldPower.add(runPower))
                                    .set("selectricCurrent", oldSelectricCurrent.add(selectricCurrent))
                                    .set("ingTime", timeDifference)
                                    .set("deviceStopTime", DateUtils.date2Str(deviceStopTime, DateUtils.datetimeFormat.get()))
                                    .set("updateTime", curentDate);
                            Query modifyStartStop = new Query()
                                    .addCriteria(Criteria.where("deviceRegionId").is(fpgGatherData.getDeviceRegionId()))
                                    .addCriteria(Criteria.where("deviceInformationId").is(fpgGatherData.getDeviceInformationId()))
                                    .addCriteria(Criteria.where("_id").is(startStopMongo.get_id()));
                            mongoTemplate.findAndModify(modifyStartStop, updateStartStop, DeviceStatiscsModelMongodb.class, startStopMonKey);
                            mongoTemplate.updateFirst(modifyStartStop, updateStartStop, FpgStatiscsModelMongodb.class, startStopMonKey);
                        } else if(fpgGatherData.getRunCurrent().compareTo(new BigDecimal(systemVariable.getDefaultValue())) > 0  && "2".equals(startStopMongo.getDeviceStopTimeBank())){
                            // 上一个设备停止，重新记录启停记录
                            startStopStatiscsData.setPower(runPower);
                            startStopStatiscsData.setIngTime(runTime);
                            startStopStatiscsData.setSelectricCurrent(selectricCurrent);
                            mongoTemplate.insert(startStopStatiscsData, startStopMonKey);
                        }
                    } else { // 直接插入
                        if(fpgGatherData.getRunCurrent().compareTo(new BigDecimal(systemVariable.getDefaultValue())) > 0){ // 运行中计入启停记录
                            startStopStatiscsData.setPower(runPower);
                            startStopStatiscsData.setIngTime(runTime);
                            startStopStatiscsData.setSelectricCurrent(selectricCurrent);
                            mongoTemplate.insert(startStopStatiscsData, startStopMonKey);
                        }
                    }
                    // 设备启停统计 end
                    // 设备停止运行不统计
                    if (fpgGatherData.getRunCurrent().compareTo(new BigDecimal(systemVariable.getDefaultValue())) < 0) { // 设备停止运行
                        // 执行完成数据 标记已处理
                        fpgGatherData.setId(fpgGatherData.getId());
                        fpgGatherDataService.updateById(fpgGatherData);
                        return;
                    }
                     // 日统计尖峰平谷数据（功率+占比+电流+运行时长） start
                    String dayPowerproportioncurrentRunMonKey = "total_day_powerproportioncurrent";
                    DeviceStatiscsModelData dayPowerproportioncurrentRunData = new DeviceStatiscsModelData(fpgGatherData, dayPowerproportioncurrentRunMonKey, dayDate, classs, curentDate, curentDate);
                    // 组合mongodb条件
                    Query queryDayPowerproportioncurrentRun = new Query()
                            .addCriteria(Criteria.where("deviceRegionId").is(fpgGatherData.getDeviceRegionId())).addCriteria(Criteria.where("deviceInformationId").is(fpgGatherData.getDeviceInformationId())).addCriteria(Criteria.where("dates").is(dayDate));
                    DeviceStatiscsModelMongodb dayPowerproportioncurrentMongo = mongoTemplate.findOne(queryDayPowerproportioncurrentRun, DeviceStatiscsModelMongodb.class, dayPowerproportioncurrentRunMonKey);
                    if(dayPowerproportioncurrentMongo != null){ // 不为空更新
                        // 历史数据
                        BigDecimal runNewPower = dayPowerproportioncurrentMongo.getPower() == null ? new BigDecimal("0.00") : dayPowerproportioncurrentMongo.getPower().add(runPower);
                        BigDecimal oldRunTime = dayPowerproportioncurrentMongo.getIngTime() == null ? new BigDecimal("0.00") : dayPowerproportioncurrentMongo.getIngTime();
                        BigDecimal oldSelectricCurrent = dayPowerproportioncurrentMongo.getSelectricCurrent() == null ? new BigDecimal("0.00") : dayPowerproportioncurrentMongo.getSelectricCurrent();
                        // 更新运行数据
                        UpdateDefinition update = new Update();
                        ((Update) update).set("power", runNewPower);
                        ((Update) update).set("selectricCurrent", oldSelectricCurrent.add(selectricCurrent));
                        ((Update) update).set("ingTime", oldRunTime.add(runTime));
                        ((Update) update).set("updateTime", curentDate);
                        // 占比
                        BigDecimal topsProportion = dayPowerproportioncurrentMongo.getTopsPower().compareTo(new BigDecimal("0.00")) > 0 ? dayPowerproportioncurrentMongo.getTopsPower().divide(runNewPower, 4, RoundingMode.HALF_UP).multiply(zb) : proportion;
                        // 其他三个重新核算
                        BigDecimal flatProportion = dayPowerproportioncurrentMongo.getFlatPower().compareTo(new BigDecimal("0.00")) > 0 ? dayPowerproportioncurrentMongo.getFlatPower().divide(runNewPower, 4, RoundingMode.HALF_UP).multiply(zb) : proportion;
                        BigDecimal peaksProportion = dayPowerproportioncurrentMongo.getPeaksPower().compareTo(new BigDecimal("0.00")) > 0 ? dayPowerproportioncurrentMongo.getPeaksPower().divide(runNewPower, 4, RoundingMode.HALF_UP).multiply(zb) : proportion;
                        BigDecimal valleysProportion = dayPowerproportioncurrentMongo.getValleysPower().compareTo(new BigDecimal("0.00")) > 0 ? dayPowerproportioncurrentMongo.getValleysPower().divide(runNewPower, 4, RoundingMode.HALF_UP).multiply(zb) : proportion;
                        // 尖峰平谷判定
                        if("tops".equals(jfpgStr.get())){ // 尖
                            // 功率处理
                            BigDecimal oldtopsPower = dayPowerproportioncurrentMongo.getTopsPower() == null ? new BigDecimal("0.00") : dayPowerproportioncurrentMongo.getTopsPower();
                            BigDecimal topsPower = oldtopsPower.add(runPower);
                            ((Update) update).set("topsPower", topsPower);
                            // 运行时常处理
                            BigDecimal oldtopsIngTime = dayPowerproportioncurrentMongo.getTopsIngTime() == null ? new BigDecimal("0.00") : dayPowerproportioncurrentMongo.getTopsIngTime();
                            ((Update) update).set("topsIngTime", oldtopsIngTime.add(runTime));
                            // 占比
                            topsProportion = topsPower.compareTo(new BigDecimal("0.00")) > 0 ? topsPower.divide(runNewPower, 4, RoundingMode.HALF_UP).multiply(zb) : topsProportion;
                        } else if("peaks".equals(jfpgStr.get())){ // 峰
                            // 功率处理
                            BigDecimal oldpeaksPower = dayPowerproportioncurrentMongo.getPeaksPower() == null ? new BigDecimal("0.00") : dayPowerproportioncurrentMongo.getPeaksPower();
                            BigDecimal peaksPower = oldpeaksPower.add(runPower);
                            ((Update) update).set("peaksPower", peaksPower);
                            // 运行时常处理
                            BigDecimal oldpeaksIngTime = dayPowerproportioncurrentMongo.getPeaksIngTime() == null ? new BigDecimal("0.00") : dayPowerproportioncurrentMongo.getPeaksIngTime();
                            ((Update) update).set("peaksIngTime", oldpeaksIngTime.add(runTime));
                            // 占比
                            peaksProportion = peaksPower.compareTo(new BigDecimal("0.00")) > 0 ? peaksPower.divide(runNewPower, 4, RoundingMode.HALF_UP).multiply(zb) : peaksProportion;
                        } else if("flat".equals(jfpgStr.get())){ // 平
                            // 功率处理
                            BigDecimal oldflatPower = dayPowerproportioncurrentMongo.getFlatPower() == null ? new BigDecimal("0.00") : dayPowerproportioncurrentMongo.getFlatPower();
                            BigDecimal flatPower = oldflatPower.add(runPower);
                            ((Update) update).set("flatPower", flatPower);
                            // 运行时常处理
                            BigDecimal oldflatIngTime = dayPowerproportioncurrentMongo.getFlatIngTime() == null ? new BigDecimal("0.00") : dayPowerproportioncurrentMongo.getFlatIngTime();
                            ((Update) update).set("flatIngTime", oldflatIngTime.add(runTime));
                            // 占比
                            flatProportion = flatPower.compareTo(new BigDecimal("0.00")) > 0 ? flatPower.divide(runNewPower, 4, RoundingMode.HALF_UP).multiply(zb) : flatProportion;
                        } else if("valleys".equals(jfpgStr.get())){ // 谷
                            // 功率处理
                            BigDecimal oldvalleysPower = dayPowerproportioncurrentMongo.getValleysPower() == null ? new BigDecimal("0.00") : dayPowerproportioncurrentMongo.getValleysPower();
                            BigDecimal valleysPower = oldvalleysPower.add(runPower);
                            ((Update) update).set("valleysPower", oldvalleysPower.add(runPower));
                            // 运行时常处理
                            BigDecimal oldvalleysIngTime = dayPowerproportioncurrentMongo.getValleysIngTime() == null ? new BigDecimal("0.00") : dayPowerproportioncurrentMongo.getValleysIngTime();
                            ((Update) update).set("valleysIngTime", oldvalleysIngTime.add(runTime));
                            // 占比
                            valleysProportion = valleysPower.compareTo(new BigDecimal("0.00")) > 0 ? valleysPower.divide(runNewPower, 4, RoundingMode.HALF_UP).multiply(zb) : valleysProportion;
                        }
                        // 占比
                        ((Update) update).set("topsProportion", topsProportion);
                        ((Update) update).set("peaksProportion", peaksProportion);
                        ((Update) update).set("flatProportion", flatProportion);
                        ((Update) update).set("valleysProportion", valleysProportion);
                        mongoTemplate.updateFirst(queryDayPowerproportioncurrentRun, update, DeviceStatiscsModelMongodb.class, dayPowerproportioncurrentRunMonKey);
                    } else { // 为空直接插入
                        // 尖峰平谷判定
                        if("tops".equals(jfpgStr.get())){ // 尖
                            // 功率处理
                            dayPowerproportioncurrentRunData.setTopsPower(runPower);
                            dayPowerproportioncurrentRunData.setTopsIngTime(runTime);
                        } else if("peaks".equals(jfpgStr.get())){ // 峰
                            // 功率处理
                            dayPowerproportioncurrentRunData.setPeaksPower(runPower);
                            dayPowerproportioncurrentRunData.setPeaksIngTime(runTime);
                        } else if("flat".equals(jfpgStr.get())){ // 平
                            // 功率处理
                            dayPowerproportioncurrentRunData.setFlatPower(runPower);
                            dayPowerproportioncurrentRunData.setFlatIngTime(runTime);
                        } else if("valleys".equals(jfpgStr.get())){ // 谷
                            dayPowerproportioncurrentRunData.setValleysPower(runPower);
                            dayPowerproportioncurrentRunData.setValleysIngTime(runTime);
                        }
                        dayPowerproportioncurrentRunData.setPower(runPower);
                        dayPowerproportioncurrentRunData.setIngTime(runTime);
                        mongoTemplate.insert(dayPowerproportioncurrentRunData, dayPowerproportioncurrentRunMonKey);
                    }
                    // 日统计尖峰平谷数据（功率+占比+电流+运行时长） end
                    // 执行完成数据 标记已处理
                    fpgGatherData.setId(fpgGatherData.getId());
                    fpgGatherDataService.updateById(fpgGatherData);
                } catch (Exception e) {
                    log.error(e.getMessage());
                }
            });
        });
    }


    //精益模型统计数据
    public void leanModel(){
        log.info("峰平谷模型");
        // 峰平谷精益模型配置获取
        LambdaQueryWrapper<FpgLeanModel> leanmodelQuery = new LambdaQueryWrapper<FpgLeanModel>().eq(FpgLeanModel::getStatus, "1");
        List<FpgLeanModel> fpgLeanModellist = fpgLeanModelService.list(leanmodelQuery);
        // 获取当前时间
        LocalDateTime newTime = LocalDateTime.now().plusHours(8);

        // 尖峰平谷时段配置
        List<PeaksAndValleysTimeConfig>  peaksAndValleysTimeConfiglist = peaksAndValleysTimeConfigService.list();
        // 存储fpgGather数据id集合
        List<FpgGatherData> fpgGatherUpdateList= new ArrayList<>();

        // 系统变量查询
        QueryWrapper<SystemVariable> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("variable_address", "sys_run_current_limit");
        queryWrapper.eq("status",  0);
        SystemVariable systemVariable = systemVariableService.getOne(queryWrapper);

        // 遍历设备集合
        fpgLeanModellist.forEach(fpgLeanModeInfo -> {
            LambdaQueryWrapper<FpgGatherData> fpgGatherQuery = new LambdaQueryWrapper<FpgGatherData>().isNull(FpgGatherData::getFpgModelUpdatetime).isNotNull(FpgGatherData::getRunCurrent).isNotNull(FpgGatherData::getActivePower).orderByAsc(FpgGatherData::getCreateTime);
            // 检测是否配置设备特殊条件
            if(oConvertUtils.isNotEmpty(fpgLeanModeInfo.getDeviceInformationIds()) && oConvertUtils.isNotEmpty(fpgLeanModeInfo.getDeviceInformationIds())){
                fpgGatherQuery.in(FpgGatherData::getDeviceInformationId, Arrays.asList(fpgLeanModeInfo.getDeviceInformationIds().split(",")));
            }
            fpgGatherQuery.orderByAsc(FpgGatherData::getCreateTime).last("limit 1000");
            List<FpgGatherData> fpgGatherList = fpgGatherDataService.list(fpgGatherQuery);
            // 处理数据业务逻辑
            fpgGatherList.forEach(fpgGatherData -> { // 循环处理采集数据处理
                fpgGatherData.setFpgModelUpdatetime(new Date());
                // -数情况直接退出
                if (fpgGatherData.getActivePower().compareTo(BigDecimal.ZERO) < 0) {
                    fpgGatherUpdateList.add(fpgGatherData);
                    return;
                }
                try {
                    String finalDatestr = "";
                    // 统计单位
                    if("minute".equals(fpgLeanModeInfo.getTotalUnit())){ // 分钟
                        finalDatestr = new SimpleDateFormat("HH:mm").format(fpgGatherData.getCreateTime());
                    } else if("hour".equals(fpgLeanModeInfo.getTotalUnit())){ // 小时
                        finalDatestr = new SimpleDateFormat("HH:00").format(fpgGatherData.getCreateTime());
                    } else if("day".equals(fpgLeanModeInfo.getTotalUnit())){ //
                        finalDatestr = new SimpleDateFormat("yyyy-MM-dd").format(fpgGatherData.getCreateTime());
                    }else if("week".equals(fpgLeanModeInfo.getTotalUnit())){ //
                        Calendar calendar = Calendar.getInstance();
                        finalDatestr = String.valueOf(calendar.get(Calendar.WEEK_OF_MONTH));
                    } else if("month".equals(fpgLeanModeInfo.getTotalUnit())){ //
                        finalDatestr = new SimpleDateFormat("yyyy-MM").format(fpgGatherData.getCreateTime());
                    } else if("real_time". equals(fpgLeanModeInfo.getTotalUnit())){ // 实时
                        fpgLeanModeInfo.setProportion(2);
                        fpgLeanModeInfo.setElectricCurrent(2);
                        fpgLeanModeInfo.setRunTime(2);
                        finalDatestr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(fpgGatherData.getCreateTime());
                    }
                    String dayDate = new SimpleDateFormat("yyyy-MM-dd").format(fpgGatherData.getCreateTime());
                    String classs = "";
                    // 采集时间
                    Instant instant = fpgGatherData.getCreateTime().toInstant();
                    LocalDateTime localDateTime = LocalDateTime.ofInstant(instant, ZoneId.systemDefault());
                    // 班次处理
                    if (fpgLeanModeInfo.getClassUnit() != null && fpgLeanModeInfo.getClassUnit() == 1) { // 开启了班次统计
                        if (containsCreateTime(localDateTime, dayDate + " 00:00:00", dayDate + " 07:59:59")) { // 夜班
                            classs = "night";
                        } else if (containsCreateTime(localDateTime, dayDate + " 08:00:00", dayDate + " 15:59:59")) { // 白班
                            classs = "white";
                        } else if (containsCreateTime(localDateTime, dayDate + " 16:00:00", dayDate + " 23:59:59")) { // 中班
                            classs = "center";
                        }
                    }
                    Date curentDate = Date.from(newTime.atZone(ZoneId.systemDefault()).toInstant());
                    // 重组对象
                    FpgStatiscsModelData fpgStatiscsModelData = new FpgStatiscsModelData(fpgGatherData, fpgLeanModeInfo, finalDatestr, dayDate, classs, curentDate, curentDate);
                    // 实时统计直接插入
                    if("real_time". equals(fpgLeanModeInfo.getTotalUnit())){
                        fpgStatiscsModelData.setSelectricCurrent(fpgGatherData.getRunCurrent());
                        fpgStatiscsModelData.setPower(fpgGatherData.getActivePower());
                        fpgStatiscsModelData.setIngTime(new BigDecimal("300"));
                        mongoTemplate.insert(fpgStatiscsModelData, "leanmodel_" + fpgLeanModeInfo.getLeanModelCode());
                        fpgGatherUpdateList.add(fpgGatherData);
                        return;
                    }
                    // 设备停止运行不统计
                    if (fpgGatherData.getRunCurrent().compareTo(new BigDecimal(systemVariable.getDefaultValue())) < 0) { // 设备停止运行
                        fpgGatherUpdateList.add(fpgGatherData);
                        return;
                    }
                    // 定义尖峰平谷
                    AtomicReference<String> jfpgStr = new AtomicReference<>("");
                    // 判断尖峰平谷时段
                    peaksAndValleysTimeConfiglist.forEach(peaksAndValleysTimeConfig -> {
                        if (containsCreateTime(localDateTime, dayDate + " " + peaksAndValleysTimeConfig.getStartTime(), dayDate + " " + peaksAndValleysTimeConfig.getEndTime())) {
                            jfpgStr.set(peaksAndValleysTimeConfig.getType());
                        }
                    });
                    // 组合mongodb条件
                    Query query = new Query();
                    query.addCriteria(Criteria.where("devicePointId").is(fpgGatherData.getDevicePointId()))
                            .addCriteria(Criteria.where("dates").is(dayDate))
                            .addCriteria(Criteria.where("datestr").is(finalDatestr));
                    if(fpgGatherData.getDeviceRegionId() != null && !fpgGatherData.getDeviceRegionId().isEmpty()){ // 区域特殊处理
                        query.addCriteria(Criteria.where("deviceRegionId").is(fpgGatherData.getDeviceRegionId()));
                    }
                    if(fpgGatherData.getDeviceInformationId() != null && !fpgGatherData.getDeviceInformationId().isEmpty()){ // 设备特殊处理
                        query.addCriteria(Criteria.where("deviceInformationId").is(fpgGatherData.getDeviceInformationId()));
                    }
                    if(!classs.isEmpty()){ // 增加班次条件
                        query.addCriteria(Criteria.where("classs").is(classs));
                    }

                    String leanModelCode = fpgLeanModeInfo.getLeanModelCode();
                    String collectionName;

                    // 判断 leanModelCode 是否包含 "_report"
                    if (leanModelCode.endsWith("_report")) {
                        collectionName = leanModelCode;
                    } else {
                        collectionName = "leanmodel_" + leanModelCode;
                    }

                    FpgStatiscsModelMongodb fpgStatiscsModelMongo = mongoTemplate.findOne(query, FpgStatiscsModelMongodb.class, collectionName);
                    // 功率
                    BigDecimal activePower =  fpgGatherData.getActivePower().compareTo(new BigDecimal("0.00")) > 0 ? fpgGatherData.getActivePower().divide(new BigDecimal("12"), 8, RoundingMode.HALF_UP) : new BigDecimal("0.00");
                    // 电流
                    BigDecimal selectricCurrent = fpgGatherData.getRunCurrent() == null ? new BigDecimal("0.00") : fpgGatherData.getRunCurrent();
                    // 运行时常
                    BigDecimal runTime = new BigDecimal("300");
                    if(fpgStatiscsModelMongo != null){ // 不为空处理
                        // 基础数据变更不受条件影响
                        UpdateDefinition update = new Update();
                        ((Update) update).set("updateTime", curentDate);
                        // 功率 5 分钟上报一次  除以 12
                        activePower = fpgGatherData.getActivePower() == null ? new BigDecimal("0.00") : activePower;
                        BigDecimal oldPower = fpgStatiscsModelMongo.getPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getPower();
                        BigDecimal oldingTime = fpgStatiscsModelMongo.getIngTime() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getIngTime();
                        BigDecimal oldSelectricCurrent = fpgStatiscsModelMongo.getSelectricCurrent() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getSelectricCurrent();
                        // 总运行时间处理
                        if(fpgLeanModeInfo.getRunTime() != null && fpgLeanModeInfo.getRunTime() == 1) { // 运行时长统计
                            ((  Update) update).set("ingTime", oldingTime.add(runTime));
                        }
                        // 电流处理
                        if(fpgLeanModeInfo.getElectricCurrent() != null && fpgLeanModeInfo.getElectricCurrent() == 1){
                            if("tops".equals(jfpgStr.get())) { // 尖
                                BigDecimal oldtopsSelectricCurrent = fpgStatiscsModelMongo.getTopsSelectricCurrent() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getTopsSelectricCurrent();
                                ((Update) update).set("topSelectricCurrent", oldtopsSelectricCurrent.add(selectricCurrent));
                            } else if("peaks".equals(jfpgStr.get())){ // 峰
                                BigDecimal oldpeaksSelectricCurrent = fpgStatiscsModelMongo.getPeaksSelectricCurrent() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getPeaksSelectricCurrent();
                                ((Update) update).set("peaksSelectricCurrent", oldpeaksSelectricCurrent.add(selectricCurrent));
                            } else if("flat".equals(jfpgStr.get())) { // 平
                                BigDecimal oldtflatSelectricCurrent = fpgStatiscsModelMongo.getFlatSelectricCurrent() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getFlatSelectricCurrent();
                                ((Update) update).set("flatSelectricCurrent", oldtflatSelectricCurrent.add(selectricCurrent));
                            } else if("valleys".equals(jfpgStr.get())) { // 谷
                                BigDecimal oldvalleysSelectricCurrent = fpgStatiscsModelMongo.getValleysSelectricCurrent() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getValleysSelectricCurrent();
                                ((Update) update).set("valleysSelectricCurrent", oldvalleysSelectricCurrent.add(selectricCurrent));
                            }
                        }

                        BigDecimal zb = new BigDecimal("100");
                        // 总功率处理
                        ((Update) update).set("power", oldPower.add(activePower));
                        //总电流处理
                        ((Update) update).set("selectricCurrent", oldSelectricCurrent.add(selectricCurrent));
                        // 尖峰平谷判定
                        if("tops".equals(jfpgStr.get())){ // 尖
                            // 功率处理
                            BigDecimal oldtopsPower = fpgStatiscsModelMongo.getTopsPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getTopsPower();
                            BigDecimal oldPeaksPower = fpgStatiscsModelMongo.getPeaksPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getPeaksPower();
                            BigDecimal oldFlatPower = fpgStatiscsModelMongo.getFlatPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getFlatPower();
                            BigDecimal oldValleysPower = fpgStatiscsModelMongo.getValleysPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getValleysPower();
                            ((Update) update).set("topsPower", oldtopsPower.add(activePower));
                            // 运行时常处理
                            if(fpgLeanModeInfo.getRunTime() != null && fpgLeanModeInfo.getRunTime() == 1){ // 运行时长统计
                                BigDecimal oldtopsIngTime = fpgStatiscsModelMongo.getTopsIngTime() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getTopsIngTime();
                                BigDecimal newTopsIngTime = oldtopsIngTime.add(runTime).stripTrailingZeros();
                                DecimalFormat df = new DecimalFormat("0.##################");
                                String topFormatted = df.format(newTopsIngTime);
                                ((Update) update).set("topsIngTime", new BigDecimal(topFormatted));
                            }
                            // 金额处理
                            if(fpgLeanModeInfo.getTopsPrice() != null && fpgLeanModeInfo.getTopsPrice().compareTo(new BigDecimal("0.00")) > 0) {
                                // 总金额
                                BigDecimal totalAmount = fpgStatiscsModelMongo.getAmount() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getAmount();
                                ((Update) update).set("amount", activePower.multiply(fpgLeanModeInfo.getTopsPrice()).add(totalAmount));
                                ((Update) update).set("topsAmount", oldtopsPower.add(activePower).multiply(fpgLeanModeInfo.getTopsPrice()));
                            }
                            if(fpgLeanModeInfo.getProportion() !=null && fpgLeanModeInfo.getProportion() == 1){ //占比统计

                                ((Update) update).set("topsProportion", oldtopsPower.add(activePower).divide(fpgStatiscsModelMongo.getPower().add(activePower), 2, RoundingMode.HALF_UP).multiply(zb));

                                if(fpgStatiscsModelMongo.getPeaksPower().compareTo(new BigDecimal("0.00")) > 0) {
                                    ((Update) update).set("peaksProportion", oldPeaksPower.divide(fpgStatiscsModelMongo.getPower().add(activePower), 2, RoundingMode.HALF_UP).multiply(zb));
                                }
                                if(fpgStatiscsModelMongo.getFlatPower().compareTo(new BigDecimal("0.00")) > 0) {
                                    ((Update) update).set("flatProportion", oldFlatPower.divide(fpgStatiscsModelMongo.getPower().add(activePower), 2, RoundingMode.HALF_UP).multiply(zb));
                                }

                                if(fpgStatiscsModelMongo.getValleysPower().compareTo(new BigDecimal("0.00")) > 0) {
                                    ((Update) update).set("valleysProportion", oldValleysPower.divide(fpgStatiscsModelMongo.getPower().add(activePower), 2, RoundingMode.HALF_UP).multiply(zb));
                                }


                            }
                        } else if("peaks".equals(jfpgStr.get())){ // 峰
                            // 功率处理
                            BigDecimal oldpeaksPower = fpgStatiscsModelMongo.getPeaksPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getPeaksPower();
                            BigDecimal oldtopsPower = fpgStatiscsModelMongo.getTopsPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getTopsPower();
                            BigDecimal oldFlatPower = fpgStatiscsModelMongo.getFlatPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getFlatPower();
                            BigDecimal oldValleysPower = fpgStatiscsModelMongo.getValleysPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getValleysPower();
                            ((Update) update).set("peaksPower", oldpeaksPower.add(activePower));
                            // 运行时常处理
                            if(fpgLeanModeInfo.getRunTime() != null && fpgLeanModeInfo.getRunTime() == 1){ // 运行时长统计
                                BigDecimal oldpeaksIngTime = fpgStatiscsModelMongo.getPeaksIngTime() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getPeaksIngTime();
                                BigDecimal newPeaksIngTime = oldpeaksIngTime.add(runTime).stripTrailingZeros();
                                DecimalFormat df = new DecimalFormat("0.##################");
                                String peaksFormatted = df.format(newPeaksIngTime);
                                ((Update) update).set("peaksIngTime", new BigDecimal(peaksFormatted));
                            }
                            // 金额处理
                            if(fpgLeanModeInfo.getPeaksPrice() != null && fpgLeanModeInfo.getPeaksPrice().compareTo(new BigDecimal("0.00")) > 0) {
                                // 总金额
                                BigDecimal totalAmount = fpgStatiscsModelMongo.getAmount() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getAmount();
                                ((Update) update).set("amount", activePower.multiply(fpgLeanModeInfo.getPeaksPrice()).add(totalAmount));
                                ((Update) update).set("peaksAmount", oldpeaksPower.add(activePower).multiply(fpgLeanModeInfo.getPeaksPrice()));
                            }
                            if(fpgLeanModeInfo.getProportion() !=null && fpgLeanModeInfo.getProportion() == 1){ //占比统计

                                ((Update) update).set("peaksProportion", oldpeaksPower.add(activePower).divide(fpgStatiscsModelMongo.getPower().add(activePower), 2, RoundingMode.HALF_UP).multiply(zb));

                                if(fpgStatiscsModelMongo.getTopsPower().compareTo(new BigDecimal("0.00")) > 0) {
                                    ((Update) update).set("topsProportion", oldtopsPower.divide(fpgStatiscsModelMongo.getPower().add(activePower), 2, RoundingMode.HALF_UP).multiply(zb));
                                }
                                if(fpgStatiscsModelMongo.getFlatPower().compareTo(new BigDecimal("0.00")) > 0) {
                                    ((Update) update).set("flatProportion", oldFlatPower.divide(fpgStatiscsModelMongo.getPower().add(activePower), 2, RoundingMode.HALF_UP).multiply(zb));
                                }
                                if(fpgStatiscsModelMongo.getValleysPower().compareTo(new BigDecimal("0.00")) > 0) {
                                    ((Update) update).set("valleysProportion", oldValleysPower.divide(fpgStatiscsModelMongo.getPower().add(activePower), 2, RoundingMode.HALF_UP).multiply(zb));

                                }
                            }
                        } else if("flat".equals(jfpgStr.get())){ // 平
                            // 功率处理
                            BigDecimal oldflatPower = fpgStatiscsModelMongo.getFlatPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getFlatPower();
                            BigDecimal oldpeaksPower = fpgStatiscsModelMongo.getPeaksPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getPeaksPower();
                            BigDecimal oldtopsPower = fpgStatiscsModelMongo.getTopsPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getTopsPower();
                            BigDecimal oldValleysPower = fpgStatiscsModelMongo.getValleysPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getValleysPower();
                            ((Update) update).set("flatPower", oldflatPower.add(activePower));
                            // 运行时常处理
                            if(fpgLeanModeInfo.getRunTime() != null && fpgLeanModeInfo.getRunTime() == 1){
                                BigDecimal oldflatIngTime = fpgStatiscsModelMongo.getFlatIngTime() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getFlatIngTime();
                                BigDecimal newFlatIngTime = oldflatIngTime.add(runTime).stripTrailingZeros();
                                DecimalFormat df = new DecimalFormat("0.##################");
                                String formatted = df.format(newFlatIngTime);
                                ((Update) update).set("flatIngTime", new BigDecimal(formatted));
                            }
                            // 金额处理
                            if(fpgLeanModeInfo.getFlatPrice() != null && fpgLeanModeInfo.getFlatPrice().compareTo(new BigDecimal("0.00")) > 0) {
                                // 总金额
                                BigDecimal totalAmount = fpgStatiscsModelMongo.getAmount() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getAmount();
                                ((Update) update).set("amount", activePower.multiply(fpgLeanModeInfo.getFlatPrice()).add(totalAmount));
                                ((Update) update).set("flatAmount", oldflatPower.add(activePower).multiply(fpgLeanModeInfo.getFlatPrice()));
                            }
                            if(fpgLeanModeInfo.getProportion() !=null && fpgLeanModeInfo.getProportion() == 1){ //占比统计

                                ((Update) update).set("flatProportion", oldflatPower.add(activePower).divide(fpgStatiscsModelMongo.getPower().add(activePower), 2, RoundingMode.HALF_UP).multiply(zb));

                                if(fpgStatiscsModelMongo.getTopsPower().compareTo(new BigDecimal("0.00")) > 0) {
                                    ((Update) update).set("topsProportion", oldtopsPower.divide(fpgStatiscsModelMongo.getPower().add(activePower), 2, RoundingMode.HALF_UP).multiply(zb));

                                }
                                if(fpgStatiscsModelMongo.getPeaksPower().compareTo(new BigDecimal("0.00")) > 0) {
                                    ((Update) update).set("peaksProportion", oldpeaksPower.divide(fpgStatiscsModelMongo.getPower().add(activePower), 2, RoundingMode.HALF_UP).multiply(zb));

                                }
                                if(fpgStatiscsModelMongo.getValleysPower().compareTo(new BigDecimal("0.00")) > 0) {
                                    ((Update) update).set("valleysProportion", oldValleysPower.divide(fpgStatiscsModelMongo.getPower().add(activePower), 2, RoundingMode.HALF_UP).multiply(zb));

                                }

                            }
                        } else if("valleys".equals(jfpgStr.get())){ // 谷
                            // 功率处理
                            BigDecimal oldvalleysPower = fpgStatiscsModelMongo.getValleysPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getValleysPower();
                            BigDecimal oldflatPower = fpgStatiscsModelMongo.getFlatPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getFlatPower();
                            BigDecimal oldpeaksPower = fpgStatiscsModelMongo.getPeaksPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getPeaksPower();
                            BigDecimal oldtopsPower = fpgStatiscsModelMongo.getTopsPower() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getTopsPower();

                            ((Update) update).set("valleysPower", oldvalleysPower.add(activePower));
                            // 运行时常处理
                            if(fpgLeanModeInfo.getRunTime() != null && fpgLeanModeInfo.getRunTime() == 1){
                                BigDecimal oldvalleysIngTime = fpgStatiscsModelMongo.getValleysIngTime() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getValleysIngTime();
                                BigDecimal newValleysIngTime = oldvalleysIngTime.add(runTime).stripTrailingZeros();
                                DecimalFormat df = new DecimalFormat("0.##################");
                                String valleysFormatted = df.format(newValleysIngTime);
                                ((Update) update).set("valleysIngTime", new BigDecimal(valleysFormatted));
                            }
                            // 金额处理
                            if(fpgLeanModeInfo.getValleysPrice() != null && fpgLeanModeInfo.getValleysPrice().compareTo(new BigDecimal("0.00")) > 0) {
                                // 总金额
                                BigDecimal totalAmount = fpgStatiscsModelMongo.getAmount() == null ? new BigDecimal("0.00") : fpgStatiscsModelMongo.getAmount();
                                ((Update) update).set("amount", activePower.multiply(fpgLeanModeInfo.getValleysPrice()).add(totalAmount));
                                ((Update) update).set("valleysAmount", oldvalleysPower.add(activePower).multiply(fpgLeanModeInfo.getValleysPrice()));
                            }

                            if(fpgLeanModeInfo.getProportion() !=null && fpgLeanModeInfo.getProportion() == 1){ //占比统计

                                ((Update) update).set("valleysProportion", oldvalleysPower.add(activePower).divide(fpgStatiscsModelMongo.getPower().add(activePower), 2, RoundingMode.HALF_UP).multiply(zb));

                                if(fpgStatiscsModelMongo.getTopsPower().compareTo(new BigDecimal("0.00")) > 0) {
                                    ((Update) update).set("topsProportion", oldtopsPower.divide(fpgStatiscsModelMongo.getPower().add(activePower), 2, RoundingMode.HALF_UP).multiply(zb));

                                }
                                if(fpgStatiscsModelMongo.getPeaksPower().compareTo(new BigDecimal("0.00")) > 0) {
                                    ((Update) update).set("peaksProportion", oldpeaksPower.divide(fpgStatiscsModelMongo.getPower().add(activePower), 2, RoundingMode.HALF_UP).multiply(zb));

                                }
                                if(fpgStatiscsModelMongo.getFlatPower().compareTo(new BigDecimal("0.00")) > 0) {
                                    ((Update) update).set("flatProportion", oldflatPower.divide(fpgStatiscsModelMongo.getPower().add(activePower), 2, RoundingMode.HALF_UP).multiply(zb));

                                }

                            }
                        }
                        fpgGatherUpdateList.add(fpgGatherData);
                        query.addCriteria(Criteria.where("_id").is(fpgStatiscsModelMongo.get_id()));
                        mongoTemplate.updateFirst(query, update, FpgStatiscsModelMongodb.class, collectionName);

                    } else { // 为空直接插入
                        fpgGatherUpdateList.add(fpgGatherData);
                        fpgStatiscsModelData.setPower(activePower); // 总功率处理
                        fpgStatiscsModelData.setSelectricCurrent(selectricCurrent); // 总电流处理
                        if(fpgLeanModeInfo.getRunTime() != null && fpgLeanModeInfo.getRunTime() == 1) { // 运行时长统计
                            fpgStatiscsModelData.setIngTime(runTime);   // 运行时常
                        }
                        // 电流处理
                        if(fpgLeanModeInfo.getElectricCurrent() != null && fpgLeanModeInfo.getElectricCurrent() == 1){
                            if("tops".equals(jfpgStr.get())) { // 尖
                                fpgStatiscsModelData.setTopSelectricCurrent(selectricCurrent);
                            } else if("peaks".equals(jfpgStr.get())){ // 峰
                                fpgStatiscsModelData.setPeaksSelectricCurrent(selectricCurrent);
                            } else if("flat".equals(jfpgStr.get())) { // 平
                                fpgStatiscsModelData.setFlatSelectricCurrent(selectricCurrent);
                            } else if("valleys".equals(jfpgStr.get())) { // 谷
                                fpgStatiscsModelData.setValleysSelectricCurrent(selectricCurrent);
                            }
                        }
                        // 尖峰平谷判定
                        if("tops".equals(jfpgStr.get())){ // 尖
                            fpgStatiscsModelData.setTopsPower(activePower);
                            fpgStatiscsModelData.setTopsProportion(new BigDecimal("100"));// 功率
                            // 运行时常处理
                            if(fpgLeanModeInfo.getRunTime() != null && fpgLeanModeInfo.getRunTime() == 1){ // 运行时长统计
                                fpgStatiscsModelData.setTopsPower(runTime);
                            }
                            // 金额处理
                            if(fpgLeanModeInfo.getTopsPrice() != null && fpgLeanModeInfo.getTopsPrice().compareTo(new BigDecimal("0.00")) > 0) {
                                BigDecimal amount = activePower.multiply(fpgLeanModeInfo.getTopsPrice()); // 金额处理
                                fpgStatiscsModelData.setAmount(amount);
                                fpgStatiscsModelData.setTopsAmount(amount);
                            }
                        } else if("peaks".equals(jfpgStr.get())){ // 峰
                            // 功率处理
                            fpgStatiscsModelData.setPeaksPower(activePower); // 功率
                            fpgStatiscsModelData.setPeaksProportion(new BigDecimal("100"));
                            // 运行时常处理
                            if(fpgLeanModeInfo.getRunTime() != null && fpgLeanModeInfo.getRunTime() == 1){ // 运行时长统计
                                fpgStatiscsModelData.setPeaksIngTime(runTime);
                            }
                            // 金额处理
                            if(fpgLeanModeInfo.getPeaksPrice() != null && fpgLeanModeInfo.getPeaksPrice().compareTo(new BigDecimal("0.00")) > 0) {
                                BigDecimal amount = activePower.multiply(fpgLeanModeInfo.getPeaksPrice()); // 金额处理
                                fpgStatiscsModelData.setAmount(amount);
                                fpgStatiscsModelData.setPeaksAmount(amount);
                            }
                        } else if("flat".equals(jfpgStr.get())){ // 平
                            // 功率处理
                            fpgStatiscsModelData.setFlatPower(activePower); // 功率
                            fpgStatiscsModelData.setFlatProportion(new BigDecimal("100"));
                            // 运行时常处理
                            if(fpgLeanModeInfo.getRunTime() != null && fpgLeanModeInfo.getRunTime() == 1){ // 运行时长统计
                                fpgStatiscsModelData.setFlatIngTime(runTime);
                            }
                            // 金额处理
                            if(fpgLeanModeInfo.getFlatPrice() != null && fpgLeanModeInfo.getFlatPrice().compareTo(new BigDecimal("0.00")) > 0) {
                                BigDecimal amount = activePower.multiply(fpgLeanModeInfo.getFlatPrice()); // 金额处理
                                fpgStatiscsModelData.setAmount(amount);
                                fpgStatiscsModelData.setFlatAmount(amount);
                            }
                        } else if("valleys".equals(jfpgStr.get())){ // 谷
                            // 功率处理
                            fpgStatiscsModelData.setValleysPower(activePower); // 功率
                            fpgStatiscsModelData.setValleysProportion(new BigDecimal("100"));

                            // 运行时常处理
                            if(fpgLeanModeInfo.getRunTime() != null && fpgLeanModeInfo.getRunTime() == 1){ // 运行时长统计
                                fpgStatiscsModelData.setValleysIngTime(runTime);
                            }
                            // 金额处理
                            if(fpgLeanModeInfo.getValleysPrice() != null && fpgLeanModeInfo.getValleysPrice().compareTo(new BigDecimal("0.00")) > 0) {
                                BigDecimal amount = activePower.multiply(fpgLeanModeInfo.getValleysPrice()); // 金额处理
                                fpgStatiscsModelData.setAmount(amount);
                                fpgStatiscsModelData.setValleysAmount(amount);
                            }
                        }
                        // 将点位数据存入mongo中
                        mongoTemplate.insert(fpgStatiscsModelData, collectionName);
                    }
                }catch (Exception e) {
                    log.error(e.getMessage());
                }
            });
        });
        // 数据处理完成标记已完成信息，以免重复处理
        fpgGatherDataService.updateBatchById(fpgGatherUpdateList);
    }

    /**
     * 判断创建时间是否在开始时间和结束时间范围内
     * @param createTime
     * @param startTime
     * @param endTime
     * @return
     */
    public static boolean containsCreateTime(LocalDateTime createTime, String startTime, String endTime) {
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");

        // 将字符串转换为 LocalDateTime
        LocalDateTime start_time = LocalDateTime.parse(startTime, formatter);
        LocalDateTime end_time = LocalDateTime.parse(endTime, formatter);

        // 判断是否跨天
        boolean isCrossDay = end_time.isBefore(start_time);

        // 根据 createTime 调整 start_time 和 end_time
        if (isCrossDay) {
            // 如果 createTime 在 startTime 后且在 endTime 前，且跨天，endTime 应该加一天
            if (createTime.isAfter(start_time) && createTime.isAfter(end_time)) {
                end_time = end_time.plusDays(1); // 加一天到第二天
            }
            // 如果 createTime 在 startTime 之前且在 endTime 后，startTime 应该减去一天
            if (createTime.isBefore(start_time) && createTime.isBefore(end_time)) {
                start_time = start_time.minusDays(1); // 减一天
            }
        }

        // 检查 createTime 是否在调整后的区间内
        return createTime != null && (createTime.isAfter(start_time) || createTime.equals(start_time)) &&
                (createTime.isBefore(end_time) || createTime.equals(end_time));
    }

    public static int compareStringWithBigDecimal(String str, BigDecimal bd) {
        // 将 String 转换为 BigDecimal
        BigDecimal strAsBigDecimal = new BigDecimal(str);

        // 使用 BigDecimal 的 compareTo 方法比较
        return strAsBigDecimal.compareTo(bd);
    }

}