每日录像可用指标添加日志，修改大屏为查看当前月平均

zxl

16 小时以前 3b0516a2959e25576e4f3fda697a3b025d06c8c9

 ycl-server/src/main/java/com/ycl/calculate/PlatformOnlineCalculation.java

@@ -1,13 +1,17 @@
package com.ycl.calculate;

import com.fasterxml.jackson.databind.ser.Serializers;
import com.ycl.platform.domain.entity.CheckIndexVideo;
import com.ycl.platform.domain.result.BaseResult;
import com.ycl.platform.domain.result.UY.QueryVqdResult;
import com.ycl.platform.domain.result.UY.VideoOnlineResult;
import com.ycl.platform.domain.vo.PlatformOnlineVO;
import com.ycl.platform.mapper.CheckIndexVideoMapper;
import com.ycl.platform.service.ICheckIndexVideoService;
import com.ycl.system.mapper.SysDeptMapper;
import constant.ApiConstants;
import constant.CheckConstants;
import enumeration.general.AreaDeptEnum;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -27,7 +31,7 @@
 */
@Component
@Slf4j
public class PlatformOnlineCalculation extends IndexCalculationServe implements CalculationStrategy<PlatformOnlineVO> {
public class PlatformOnlineCalculation extends IndexCalculationUtils implements CalculationStrategy<PlatformOnlineVO> {
    @Autowired
    private SysDeptMapper deptMapper;
    @Autowired
@@ -37,24 +41,29 @@

    @Override
    public void calculate(List<PlatformOnlineVO> list) {
        //list 对象是查询 t_platform_online 昨天时段的集合对象
        Map<String,Double> map = new HashMap<>();
        if (!CollectionUtils.isEmpty(list)) {
            //总离线时长
            int time = list.stream().map(PlatformOnlineVO::getTodayOutlineSed).reduce(0, Integer::sum);
            //离线时长转换位分钟然后取模
            int num = (time / 60) % 30;
            double score = Math.max(1 - num * 0.1, 0);
            for (PlatformOnlineVO platformOnlineVO : list) {
                String[] areas = platformOnlineVO.getArea().split(",");
                for (String area : areas) {
                    Integer deptId = AreaDeptEnum.fromCode(area).getDeptId();
                    //离线时长
                    Integer time = platformOnlineVO.getTodayOutlineSed();
                    //离线时长转换为分钟
                    int num = (time / 60) / 30;
                    double score = Math.max(1 - num * 0.1, 0);
                    map.put(deptId+"",score);
                    map.put(ApiConstants.Province + deptId,score);
                    map.put(ApiConstants.Dept + deptId,score);
                }
            }

            //是否已经存在当日数据
            List<CheckIndexVideo> checkIndexVideos = videoMapper.selectToday(DateUtils.getDate());
            //所有区域部门
            List<Long> deptIds = deptMapper.selectByParentId(207L);
            List<String> keys = new ArrayList<>();
            //准备区分省厅、区域的deptId list
            for (Long deptId : deptIds) {
                keys.add(deptId + "");
                keys.add(ApiConstants.Province + deptId);
            }

            List<CheckIndexVideo> videos = new ArrayList<>();
            keys.forEach(key -> {
            map.forEach((key,score) -> {
                //如果不存在就新增如果存在则复用
                CheckIndexVideo checkIndex = getCheckIndex(key, checkIndexVideos, CheckIndexVideo.class);
                if (checkIndex != null) {
@@ -67,4 +76,5 @@
            log.info("数据为空");
        }
    }

}