blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xiangpei
2024-08-16 9d30f3aba92b1fe90eaecd486113f544f0f18b7c 
 ycl-server/src/main/java/com/ycl/calculate/IndexCalculationServe.java


@@ -1,19 +1,23 @@


package com.ycl.calculate;






import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.ycl.platform.base.CheckIndex;


import com.ycl.platform.domain.entity.CheckIndexCar;


import com.ycl.platform.domain.entity.TMonitor;


import com.ycl.platform.domain.entity.YwPoint;


import com.ycl.platform.domain.result.HK.SnapshotDataMonitorResult;


import com.ycl.platform.domain.result.UY.MonitorQualifyResult;


import com.ycl.platform.domain.vo.TMonitorVO;


import com.ycl.platform.mapper.TMonitorMapper;


import com.ycl.platform.mapper.YwPointMapper;


import com.ycl.platform.service.ITMonitorService;


import com.ycl.utils.DateUtils;


import constant.ApiConstants;


import constant.CheckConstants;


import lombok.extern.slf4j.Slf4j;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.data.mongodb.core.MongoTemplate;


import org.springframework.data.mongodb.core.query.Criteria;


import org.springframework.data.mongodb.core.query.Query;


import org.springframework.stereotype.Component;


import org.springframework.stereotype.Service;


import org.springframework.util.CollectionUtils;




import java.math.BigDecimal;


import java.math.RoundingMode;


@@ -30,6 +34,32 @@


    @Autowired


    private YwPointMapper pointMapper;




    @Autowired


    private TMonitorMapper monitorMapper;




    @Autowired


    private MongoTemplate mongoTemplate;




    //一机一档合格率


    public BigDecimal monitorQualify(Map<String, Object> param) {


        BigDecimal totalMonitors = new BigDecimal((Integer) param.get("totalMonitors"));


        BigDecimal qualifyMonitor = new BigDecimal((Integer) param.get("qualifyMonitor"));


        return qualifyMonitor.divide(totalMonitors, 4, RoundingMode.HALF_UP);


    }


    //一机一档注册率率


    public BigDecimal monitorRegistration(Map<String, Object> param) {


        //新+正在用的档案数


        BigDecimal totalSites = new BigDecimal((Integer) param.get("totalSites"));


        //正在用的档案数


        BigDecimal useSites = new BigDecimal((Integer) param.get("totalSites") - (Integer) param.get("newSites"));


        return useSites.divide(totalSites, 4, RoundingMode.HALF_UP);


    }


    //档案考核比


    public BigDecimal archivesRate(Map<String, Object> param) {


        BigDecimal allFiles = new BigDecimal((Integer) param.get("allFiles"));


        BigDecimal todayFiles = new BigDecimal((Integer) param.get("todayFiles"));


        return todayFiles.divide(allFiles, 4, RoundingMode.HALF_UP);


    }


    //点位在线率


    public BigDecimal siteOnline(Map<String, Object> param) {


        BigDecimal totalSites = new BigDecimal((Integer) param.get("totalSites"));


@@ -37,6 +67,31 @@


        return onlineSites.divide(totalSites, 4, RoundingMode.HALF_UP);


    }




    //视频Osd准确率


    public BigDecimal osdAccuracy(Map<String, Object> param) {


        BigDecimal totalSites = new BigDecimal((Integer) param.get("totalSites"));


        BigDecimal osdAccuracySites = new BigDecimal((Integer) param.get("osdAccuracySites"));


        return osdAccuracySites.divide(totalSites, 4, RoundingMode.HALF_UP);


    }


    //视频时间合格率


    public BigDecimal osdTimeAccuracy(Map<String, Object> param) {


        BigDecimal totalSites = new BigDecimal((Integer) param.get("totalSites"));


        BigDecimal timeAccuracySites = new BigDecimal((Integer) param.get("timeAccuracySites"));


        return timeAccuracySites.divide(totalSites, 4, RoundingMode.HALF_UP);


    }




    //目录一致率，每超过百分之1扣10%


    public BigDecimal directoryConstant(Map<String, Object> param) {


        BigDecimal totalSites = new BigDecimal((Integer) param.get("totalSites"));


        BigDecimal newSites = new BigDecimal((Integer) param.get("newSites"));


        // 计算newSites占totalSites的百分比倍数


        BigDecimal percentage = newSites.divide(totalSites, 2, RoundingMode.DOWN).multiply(BigDecimal.valueOf(100));


        BigDecimal result = BigDecimal.ONE;


        if(BigDecimal.ONE.compareTo(percentage) <= 0 ){


            result = result.subtract(percentage.multiply(new BigDecimal("0.1")));


        }


        return result.max(BigDecimal.ZERO);


    }


    //视图库对接稳定性


    public BigDecimal viewConnectStability(Map<String, Object> param) {


        BigDecimal totalDataSum = new BigDecimal((Integer) param.get("totalDataSum"));


@@ -123,16 +178,39 @@




    //返回省厅国标码集合


    public List<String> getProvince() {


        List<YwPoint> province = pointMapper.selectByTag(null, "province");


        return province.stream().map(YwPoint::getSerialNumber).collect(Collectors.toList());


        List<YwPoint> province = pointMapper.selectByTag(null, Boolean.TRUE, null);


        return CollectionUtils.isEmpty(province) ? new ArrayList<>() : province.stream().map(YwPoint::getSerialNumber).collect(Collectors.toList());


    }




    //返回重点点位集合


    public List<String> getImportant() {


        List<YwPoint> important = pointMapper.selectByTag("important", null);


        return important.stream().map(YwPoint::getSerialNumber).collect(Collectors.toList());


        List<YwPoint> important = pointMapper.selectByTag(Boolean.TRUE, null, null);


        return CollectionUtils.isEmpty(important) ? new ArrayList<>() : important.stream().map(YwPoint::getSerialNumber).collect(Collectors.toList());


    }




    //返回重点指挥图像集合


    public List<String> getCommandImage() {


        List<YwPoint> commandImages = pointMapper.selectByTag(null, null, Boolean.TRUE);


        return CollectionUtils.isEmpty(commandImages) ? new ArrayList<>() : commandImages.stream().map(YwPoint::getSerialNumber).collect(Collectors.toList());


    }


    //返回monitor


    public List<String> getMonitorFromMongo() {


        // 获取Calendar实例，默认使用当前时区和语言环境


        Calendar calendar = Calendar.getInstance();


        // 清除Calendar中的所有字段值，以避免它们对当前日期时间有影响


        calendar.clear();


        // 设置年份、月份（注意：月份是从0开始的，所以8月是7）、日期


        calendar.set(Calendar.YEAR, 2024);


        calendar.set(Calendar.MONTH, Calendar.AUGUST);


        calendar.set(Calendar.DAY_OF_MONTH, 13);


        // Calendar.getTime()方法返回一个表示此Calendar时间值的Date对象


        Date date = calendar.getTime();


        Query query = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(date)).lt(DateUtils.getDayEnd(date)));


//        Query query = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));


        List<MonitorQualifyResult> oneMachineFileResults = mongoTemplate.find(query, MonitorQualifyResult.class);




        return CollectionUtils.isEmpty(oneMachineFileResults) ? new ArrayList<>() : oneMachineFileResults.stream().map(result -> result.getSerialNumber().getValue()).collect(Collectors.toList());


    }


    //检查是否存在当日数据


    public <T extends CheckIndex> T getCheckIndex(String key, List<T> checkIndexList, Class<T> clazz) {


        T checkIndex;


@@ -140,7 +218,7 @@


        // 检查是否已存在今日数据


        Optional<T> existingIndex = checkIndexList.stream()


                .filter(index -> key.equals(index.getDeptId().toString()) &&


                        (key.startsWith("Province_") ? CheckConstants.Examine_Tag_City.equals(index.getExamineTag())


                        (key.startsWith(ApiConstants.Province) ? CheckConstants.Examine_Tag_Province.equals(index.getExamineTag())


                                : CheckConstants.Examine_Tag_County.equals(index.getExamineTag())))


                .findFirst();




@@ -149,8 +227,8 @@


        } else {


            try {


                checkIndex = clazz.getDeclaredConstructor().newInstance();


                checkIndex.setDeptId(key.startsWith("Province_") ? Long.parseLong(key.split("_")[1]) : Long.parseLong(key));


                checkIndex.setExamineTag(key.startsWith("Province_") ? CheckConstants.Examine_Tag_City : CheckConstants.Examine_Tag_County);


                checkIndex.setDeptId(key.startsWith(ApiConstants.Province) ? Long.parseLong(key.split("_")[1]) : Long.parseLong(key));


                checkIndex.setExamineTag(key.startsWith(ApiConstants.Province) ? CheckConstants.Examine_Tag_Province : CheckConstants.Examine_Tag_County);


                checkIndex.setCreateTime(new Date());


            } catch (Exception e) {


                checkIndex = null;