blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xiangpei
2024-08-29 3e9a6da99aae968123ee7bca352fc08becd7f1f2 
 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,35 @@


    @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,10 +70,37 @@


        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"));


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


        BigDecimal avgCount = (BigDecimal) param.get("avgCount");


        return avgCount.divide(totalDataSum, 4, RoundingMode.HALF_UP);


    }




@@ -58,9 +118,9 @@


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


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




        BigDecimal result = delayCount1.divide(totalCount, 10, RoundingMode.HALF_UP).multiply(BigDecimal.ONE)


        BigDecimal result = BigDecimal.ONE.subtract(delayCount1.divide(totalCount, 10, RoundingMode.HALF_UP).multiply(BigDecimal.ONE)


                .add(delayCount2.divide(totalCount, 10, RoundingMode.HALF_UP).multiply(new BigDecimal("0.8")))


                .add(delayCount3.divide(totalCount, 10, RoundingMode.HALF_UP).multiply(new BigDecimal("0.6")));


                .add(delayCount3.divide(totalCount, 10, RoundingMode.HALF_UP).multiply(new BigDecimal("0.6"))));


        return result.setScale(4, RoundingMode.HALF_UP);


    }




@@ -71,7 +131,7 @@


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


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


        BigDecimal result = integritySites.divide(totalSites, 10, RoundingMode.HALF_UP)


                .add(importantIntegritySites.divide(importantTotalSites, 10, RoundingMode.HALF_UP));


                .multiply(importantIntegritySites.divide(importantTotalSites, 10, RoundingMode.HALF_UP));


        return result.setScale(4, RoundingMode.HALF_UP);


    }




@@ -123,14 +183,28 @@




    //返回省厅国标码集合


    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() {


        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());


    }




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


@@ -139,9 +213,9 @@




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


        Optional<T> existingIndex = checkIndexList.stream()


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


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


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


                .filter(index -> key.startsWith(ApiConstants.Province) ?


                        CheckConstants.Examine_Tag_Province.equals(index.getExamineTag()) && key.split("_")[1].equals(index.getDeptId().toString())


                        : CheckConstants.Examine_Tag_County.equals(index.getExamineTag()) && key.equals(index.getDeptId().toString()))


                .findFirst();




        if (existingIndex.isPresent()) {


@@ -149,8 +223,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;


@@ -159,4 +233,5 @@


        }


        return checkIndex;


    }




}