feat：图像资源计算定时任务完善

龚焕茏

2024-08-27 fea89b769738f7db06281f244bc81135fc34ce76

feat：图像资源计算定时任务完善

 ycl-server/src/main/java/com/ycl/platform/mapper/CheckIndexVideoMapper.java

@@ -70,4 +70,10 @@
     * @return 数据
     */
    CheckIndexVideo dashboard(DashboardQuery dashboardQuery);

    /**
     * 查询视频指标概率数据带上部门名称
     * @return 视频指标概率数据集合
     */
    List<CheckIndexVideo> selectAndDeptName();
}

 ycl-server/src/main/java/com/ycl/task/ImageResourceSecurityTask.java

@@ -1,15 +1,15 @@
package com.ycl.task;

import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
import com.ycl.platform.base.CheckIndex;
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.mapper.CheckIndexVideoMapper;
import com.ycl.platform.mapper.ImageResourceSecurityDetailMapper;
import com.ycl.platform.service.IImageResourceSecurityService;
import jakarta.annotation.PostConstruct;
import com.ycl.utils.DateUtils;
import com.ycl.utils.DictUtils;
import lombok.RequiredArgsConstructor;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.math.BigDecimal;
@@ -29,19 +29,17 @@
    private final CheckIndexVideoMapper checkIndexVideoMapper;
    private final ImageResourceSecurityDetailMapper imageResourceSecurityDetailMapper;

    @PostConstruct
    /**
     * 每天晚上1点执行
     */
    @Scheduled(cron = "0 0 1 * * ?")
    public void calc() {
        ArrayList<ImageResourceSecurity> imageResourceSecurities = new ArrayList<>();
        List<CheckIndexVideo> list = new LambdaQueryChainWrapper<>(checkIndexVideoMapper)
                .select(CheckIndexVideo::getPlatformOnline, CheckIndexVideo::getMonitorQualification, CheckIndexVideo::getDeptId)
                // .eq(CheckIndex::getCreateTime, LocalDate.now().minusDays(1))
                .orderByDesc(CheckIndex::getCreateTime)
                .last("limit 7")
                .list();
        List<CheckIndexVideo> list = checkIndexVideoMapper.selectAndDeptName();
        List<ImageResourceSecurityDetail> detail = imageResourceSecurityDetailMapper.getList();

        // 每个部门循环一次
        list.forEach(checkIndexVideo -> {
        // 每个部门循环一次计算数据
        for (CheckIndexVideo checkIndexVideo : list) {
            ImageResourceSecurity imageResourceSecurity = new ImageResourceSecurity();
            imageResourceSecurity.setDeptId(checkIndexVideo.getDeptId());
            // 直接取指标
@@ -49,15 +47,24 @@
            imageResourceSecurity.setPropertyAccuracy(checkIndexVideo.getMonitorQualification());
            // 获取当前部门的detail进行计算
            List<ImageResourceSecurityDetail> detailList = detail.stream().filter(imageResourceSecurityDetail -> Objects.equals(imageResourceSecurityDetail.getDeptId(), checkIndexVideo.getDeptId())).toList();
            // 循环detail计算
            detailList.forEach(imageResourceSecurityDetail -> {
                int score = 100;
            int count = 0;
            // 循环detail计算
            for (ImageResourceSecurityDetail imageResourceSecurityDetail : detailList) {
                // 扣除分数
                score -= imageResourceSecurityDetail.getAlarmCategory().getScore();
                imageResourceSecurity.setWeakPassword(BigDecimal.valueOf(score));
            });
            // TODO 差一个
                // 统计数量
                if (Integer.parseInt(imageResourceSecurityDetail.getAlarmLevel().getValue()) > 1) {
                    count++;
                }
            }
            // 获取字典值-总数
            int onlineAssetsTotal = Integer.parseInt(DictUtils.getDictValue("online_assets_total", checkIndexVideo.getDeptName()));
            imageResourceSecurity.setRiskProperty(BigDecimal.valueOf((count * 100L) / onlineAssetsTotal));
            imageResourceSecurity.setCreateTime(DateUtils.getNowDate());
            imageResourceSecurities.add(imageResourceSecurity);
        });
        }
        imageResourceSecurityService.saveBatch(imageResourceSecurities);

    }

 ycl-server/src/main/resources/mapper/zgyw/CheckIndexVideoMapper.xml

@@ -181,4 +181,28 @@
            LIMIT 1
        </if>
    </select>

    <select id="selectAndDeptName" resultType="com.ycl.platform.domain.entity.CheckIndexVideo">
        WITH temp AS (
            SELECT
                r.dept_id,
                r.platform_online,
                r.monitor_qualification,
                d.area,
                ROW_NUMBER() OVER(PARTITION BY r.dept_id ORDER BY r.create_time DESC) AS rn
            FROM
                t_check_index_video r
                    JOIN
                sys_dept d ON r.dept_id = d.dept_id
        )
        SELECT
            dept_id,
            area as deptName,
            platform_online,
            monitor_qualification
        FROM
            temp
        WHERE
            rn = 1;
    </select>
</mapper>

 ycl-server/src/main/resources/mapper/zgyw/ImageResourceSecurityMapper.xml

@@ -71,7 +71,7 @@
    <insert id="saveBatch">
        insert into t_image_resource_security (dept_id, platform_online, property_accuracy, weak_password, risk_property, boundary_integrity, create_time) VALUES
        <foreach collection="list" item="item" separator=",">
            (#{item.deptId}, #{item.platformOnline}, #{item.propertyAccuracy}, #{item.weakPassword}, #{item.riskProperty}, #{item.boundaryIntegrity}, NOW())
            (#{item.deptId}, #{item.platformOnline}, #{item.propertyAccuracy}, #{item.weakPassword}, #{item.riskProperty}, #{item.boundaryIntegrity}, #{item.createTime})
        </foreach>
    </insert>