blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
fuliqi
2024-08-31 6221c8b5df5eb0ee62dce79048c9c3f0dc3d0fc1 
 ycl-server/src/main/java/com/ycl/task/VideoTask.java


@@ -3,22 +3,34 @@




import com.ycl.calculate.CalculationStrategy;


import com.ycl.factory.IndexCalculationFactory;


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


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


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


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


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


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


import com.ycl.platform.mapper.CheckIndexVideoMapper;


import com.ycl.platform.mapper.ImageResourceSecurityDetailMapper;


import com.ycl.platform.mapper.PlatformOnlineMapper;


import com.ycl.platform.mapper.TMonitorMapper;


import com.ycl.platform.service.IImageResourceSecurityService;


import com.ycl.utils.DateUtils;


import com.ycl.utils.DictUtils;


import constant.CalculationStrategyConstants;


import lombok.RequiredArgsConstructor;


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.transaction.annotation.Transactional;




import java.math.BigDecimal;


import java.util.ArrayList;


import java.util.Date;


import java.util.List;


import java.util.Objects;




/**


 * 视频计算考核指标任务


@@ -26,6 +38,7 @@


 */


@Slf4j


@Component("videoTask")


@RequiredArgsConstructor


public class VideoTask {


    @Autowired


    private MongoTemplate mongoTemplate;


@@ -33,6 +46,11 @@


    private PlatformOnlineMapper platformOnlineMapper;


    @Autowired


    private TMonitorMapper monitorMapper;




    private final IImageResourceSecurityService imageResourceSecurityService;


    private final CheckIndexVideoMapper checkIndexVideoMapper;


    private final ImageResourceSecurityDetailMapper imageResourceSecurityDetailMapper;


    private static final BigDecimal NUM = new BigDecimal("0.15");




    public void siteOnlineTask() {


        Date yesterday = DateUtils.addDays(new Date(), -1);


@@ -67,7 +85,6 @@


    public void oneMonitorQualifyTask(){


        //计算一机一档合格率


        Date yesterday = DateUtils.addDays(new Date(), -1);




        Query query = new Query();


        query.addCriteria(Criteria


                .where("mongoCreateTime").gte(DateUtils.getDayStart(yesterday)).lt(DateUtils.getDayEnd(yesterday)));


@@ -92,4 +109,46 @@


        calculator.calculate(results);


    }




    /**


     * 视频图像资源安全，需要排在平台在线率后面。


     */


    @Transactional


    public void videoSecurity() {


        ArrayList<ImageResourceSecurity> imageResourceSecurities = new ArrayList<>();


        List<CheckIndexVideo> list = checkIndexVideoMapper.selectAndDeptName();


        List<ImageResourceSecurityDetail> detail = imageResourceSecurityDetailMapper.getList();




        // 每个部门循环一次计算数据


        for (CheckIndexVideo checkIndexVideo : list) {


            ImageResourceSecurity imageResourceSecurity = new ImageResourceSecurity();


            imageResourceSecurity.setDeptId(checkIndexVideo.getDeptId());


            // 直接取指标


            imageResourceSecurity.setPlatformOnline(checkIndexVideo.getPlatformOnline());


            imageResourceSecurity.setPropertyAccuracy(checkIndexVideo.getMonitorQualification());


            // 获取当前部门的detail进行计算


            List<ImageResourceSecurityDetail> detailList = detail.stream().filter(imageResourceSecurityDetail -> Objects.equals(imageResourceSecurityDetail.getDeptId(), checkIndexVideo.getDeptId())).toList();


            int score = 100;


            int count = 0;


            // 循环detail计算


            for (ImageResourceSecurityDetail imageResourceSecurityDetail : detailList) {


                // 扣除分数


                score -= imageResourceSecurityDetail.getAlarmCategory().getScore();


                // 统计数量


                if (Integer.parseInt(imageResourceSecurityDetail.getAlarmLevel().getValue()) > 1) {


                    count++;


                }


            }


            imageResourceSecurity.setWeakPassword(BigDecimal.valueOf(score));


            // 获取字典值-总数


            int onlineAssetsTotal = Integer.parseInt(DictUtils.getDictValue("online_assets_total", checkIndexVideo.getDeptName()));


            imageResourceSecurity.setRiskProperty(BigDecimal.valueOf(count / onlineAssetsTotal));


            imageResourceSecurity.setCreateTime(DateUtils.getNowDate());


            imageResourceSecurities.add(imageResourceSecurity);


            // 更新指标数据


            checkIndexVideo.setImageResourceSecurity(imageResourceSecurity.getPlatformOnline().add(imageResourceSecurity.getPropertyAccuracy().add(imageResourceSecurity.getWeakPassword().add(imageResourceSecurity.getRiskProperty()))).multiply(NUM));


            checkIndexVideoMapper.updateById(checkIndexVideo);


        }


        imageResourceSecurityService.saveBatch(imageResourceSecurities);




    }


}