blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
fuliqi
2024-09-23 7a33c5b558e7e4ab5760261accbd32c7f2056c4a 
 ycl-server/src/main/java/com/ycl/platform/service/impl/CheckScoreServiceImpl.java


@@ -2,21 +2,23 @@




import annotation.DataScope;


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


import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;


import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.ycl.platform.base.CheckIndex;


import com.ycl.platform.domain.dto.CheckResultExportDTO;


import com.ycl.platform.domain.dto.CheckScoreDTO;


import com.ycl.platform.domain.dto.CheckScoreIndexDTO;


import com.ycl.platform.domain.dto.ScoreIndexDTO;


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


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


import com.ycl.platform.mapper.CheckRuleMapper;


import com.ycl.platform.mapper.CheckScoreMapper;


import com.ycl.platform.mapper.CheckTemplateMapper;


import com.ycl.platform.mapper.CheckTemplateRuleMapper;


import com.ycl.platform.domain.query.DashboardQuery;


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


import com.ycl.platform.mapper.*;


import com.ycl.platform.service.ICheckIndexCarService;


import com.ycl.platform.service.ICheckIndexFaceService;


import com.ycl.platform.service.ICheckIndexVideoService;


import com.ycl.platform.service.ICheckScoreService;


import com.ycl.system.entity.BaseEntity;


import com.ycl.system.entity.SysRole;


import com.ycl.system.entity.SysUser;


import com.ycl.system.service.ISysDeptService;


@@ -24,19 +26,25 @@


import com.ycl.utils.SecurityUtils;


import com.ycl.utils.StringUtils;


import constant.CheckConstants;


import enumeration.general.AreaDeptEnum;


import enumeration.general.PublishType;


import jakarta.servlet.http.HttpServletResponse;


import lombok.extern.slf4j.Slf4j;


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


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.CollectionUtils;


import pojo.ExcelExp;


import utils.poi.ExcelUtilManySheet;




import java.io.IOException;


import java.math.BigDecimal;


import java.math.RoundingMode;


import java.net.InetAddress;


import java.text.SimpleDateFormat;


import java.time.LocalDateTime;


import java.util.*;


import java.util.function.Function;


import java.util.stream.Collectors;




/**


@@ -64,6 +72,8 @@


    private ICheckIndexVideoService indexVideoService;


    @Autowired


    private ISysDeptService deptService;


    @Autowired


    private PlatformMapper platformMapper;




    /**


     * 查询考核积分指标


@@ -82,10 +92,10 @@


        Integer templateId = 0;


        //方便切换改为：根据score考核类别和dto考核标签查模板规则和权重,注意同种类同标签只能有一个模板


        QueryWrapper<CheckTemplate> wrapper = new QueryWrapper<>();


        wrapper.eq("examine_tag",checkScoreIndexDTO.getExamineTag());


        wrapper.eq("examine_category",checkScore.getExamineCategory());


        wrapper.eq("examine_tag", checkScoreIndexDTO.getExamineTag());


        wrapper.eq("examine_category", checkScore.getExamineCategory());


        Optional<CheckTemplate> first = templateMapper.selectList(wrapper).stream().findFirst();


        if(first.isPresent()){


        if (first.isPresent()) {


            CheckTemplate checkTemplate = first.get();


            templateId = checkTemplate.getId();


        }


@@ -120,6 +130,8 @@


            scoreIndexDTO.setDate(formatter.format(createTime));


        }




        //权限控制


        roleControl(scoreIndexDTO);


        List<Map> map = scoreMapper.selectScoreIndex(scoreIndexDTO);




        scoreMap.put("tableData", checkRules);


@@ -163,6 +175,8 @@


                checkScores = scoreMapper.selectCheckScoreMap(checkScore);


            }


        }


        //分数保留一位小数


        checkScores.stream().forEach(item -> item.setScore(item.getScore().setScale(1, RoundingMode.HALF_UP)));


        return checkScores.stream().collect(Collectors.groupingBy(CheckScore::getDeptId));


    }




@@ -183,7 +197,7 @@


    }




    /**


     * 查询考核积分卡片列表


     * 查询考核积分卡片折线图


     *


     * @param checkScore 考核积分


     * @return 考核积分


@@ -207,6 +221,8 @@


            checkScore.setDate(date);


        }


        List<CheckScore> checkScores = scoreMapper.selectCheckScoreList(checkScore);


        //分数保留一位小数


        checkScores.stream().forEach(item -> item.setScore(item.getScore().setScale(1, RoundingMode.HALF_UP)));


        return checkScores.stream().collect(Collectors.groupingBy(CheckScore::getDeptId));


    }




@@ -221,7 +237,9 @@


    public List<CheckScore> page(CheckScore checkScore) {


        //区县只能看已发布


        roleControl(checkScore);


        return scoreMapper.selectCheckScoreList(checkScore);


        List<CheckScore> scoreList = scoreMapper.selectCheckScoreList(checkScore);


        scoreList.stream().forEach(item -> item.setScore(item.getScore().setScale(1, RoundingMode.HALF_UP)));


        return scoreList;


    }




    /**


@@ -231,6 +249,7 @@


     * @return 结果


     */


    @Override


    @Transactional(rollbackFor = Exception.class)


    public int publishCheckScore(CheckScoreDTO checkScoreDTO) {


        if (CollectionUtils.isEmpty(checkScoreDTO.getId())) {


            return 0;


@@ -243,8 +262,33 @@


        }


        String code = publishType.getCode();


        checkScoreDTO.setPublish(code);




        return scoreMapper.publishCheckScore(checkScoreDTO);


        int i = scoreMapper.publishCheckScore(checkScoreDTO);


        //控制index表的发布状态


        List<Integer> ids = checkScoreDTO.getId();


        QueryWrapper<CheckScore> queryWrapper = new QueryWrapper<>();


        queryWrapper.in("id", ids);


        List<CheckScore> scoreList = scoreMapper.selectList(queryWrapper);


        //最多为3次循环


        for (CheckScore checkScore : scoreList) {


            Short examineCategory = checkScore.getExamineCategory();


            if (CheckConstants.Rule_Category_Video.equals(examineCategory)) {


                UpdateWrapper<CheckIndexVideo> updateWrapper = new UpdateWrapper<>();


                updateWrapper.set("publish", code);


                updateWrapper.eq("id", checkScore.getIndexId());


                indexVideoService.update(updateWrapper);


            } else if (CheckConstants.Rule_Category_Car.equals(examineCategory)) {


                UpdateWrapper<CheckIndexCar> updateWrapper = new UpdateWrapper<>();


                updateWrapper.set("publish", code);


                updateWrapper.eq("id", checkScore.getIndexId());


                indexCarService.update(updateWrapper);


            } else if (CheckConstants.Rule_Category_Face.equals(examineCategory)) {


                UpdateWrapper<CheckIndexFace> updateWrapper = new UpdateWrapper<>();


                updateWrapper.set("publish", code);


                updateWrapper.eq("id", checkScore.getIndexId());


                indexFaceService.update(updateWrapper);


            }


        }


        return i;


    }




    /**


@@ -254,60 +298,211 @@


     * @return 考核积分


     */


    @Override


    public void exportIndex(HttpServletResponse response, CheckScore checkScoreDTO) throws IOException {


        String date = checkScoreDTO.getDate();


    public void exportIndex(HttpServletResponse response, CheckResultExportDTO exportDTO) throws IOException {


//        String date = exportDTO.getDate();


        //如果请求参数时间为空，查这条记录的时间


        if (StringUtils.isEmpty(checkScoreDTO.getDate()) && CollectionUtils.isEmpty(checkScoreDTO.getQuarter())) {


            CheckScore checkScore = getById(checkScoreDTO.getId());


            Date createTime = checkScore.getCreateTime();


            SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM");


            date = formatter.format(createTime);


        }


//        if (StringUtils.isEmpty(exportDTO.getDate()) && CollectionUtils.isEmpty(exportDTO.getQuarter())) {


//            SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM");


//            if (exportDTO.getId() != null) {


//                CheckScore checkScore = getById(exportDTO.getId());


//                Date createTime = checkScore.getCreateTime();


//                date = formatter.format(createTime);


//            } else {


//                //防止卡片页面导出不传scoreId，导致报错


//                date = formatter.format(new Date());


//            }


//        }




        /** 导三张sheet */


        //车辆


        CheckIndexCar checkIndexCar = new CheckIndexCar();


        checkIndexCar.setDate(date);


        checkIndexCar.setQuarter(checkScoreDTO.getQuarter());


        List<CheckIndexCar> checkIndexCars = indexCarService.selectCheckIndexCarList(checkIndexCar);


        for (CheckIndexCar indexCar : checkIndexCars) {


            indexCar.setExamineTagStr(CheckConstants.Examine_Tag_Province.equals(indexCar.getExamineTag()) ? "省厅考核" : "区县考核");


//        checkIndexCar.setDate(date);


        checkIndexCar.setQuarter(exportDTO.getQuarter());


        checkIndexCar.setDeptId(exportDTO.getDeptId());


        checkIndexCar.setDeptIds(exportDTO.getDeptIds());


        //权限控制 只能查看已发布


        roleControl(checkIndexCar);


        List<CheckIndexCar> checkIndexCars = new ArrayList<>();


        for (Integer examineTag : exportDTO.getExamineTags()) {


            checkIndexCar.setExamineTag(Short.valueOf(examineTag + ""));


            if (examineTag == 0) {


                checkIndexCar.setExamineTagQuery(1);


            }


            checkIndexCars.addAll(indexCarService.selectCheckIndexCarList(checkIndexCar));


        }


        ExcelExp e1 = new ExcelExp("车辆考核指标数据", checkIndexCars, CheckIndexCar.class);


        //计算平均值放在excel最后


        if (exportDTO.getAverage() != null && exportDTO.getAverage() && !CollectionUtils.isEmpty(checkIndexCars)) {


            //先区分考核标签，再区分区县


            List<CheckIndexCar> countyList = checkIndexCars.stream().filter(car -> CheckConstants.Examine_Tag_County.equals(car.getExamineTag())).collect(Collectors.toList());


            if (!CollectionUtils.isEmpty(countyList)) {


                Map<Long, List<CheckIndexCar>> carMap = countyList.stream().collect(Collectors.groupingBy(CheckIndexCar::getDeptId));


                List<CheckIndexCar> cars = new ArrayList<>();


                carMap.forEach((deptId, list) -> {


                    CheckIndexCar car = CheckIndexCar.calculateAverage(list);


                    cars.add(car);


                });


                //根据积分降序


                checkIndexCars.addAll(cars.stream().sorted(Comparator.comparing(CheckIndexCar::getScore).reversed()).collect(Collectors.toList()));


            }


            List<CheckIndexCar> provinceList = checkIndexCars.stream().filter(car -> CheckConstants.Examine_Tag_Province.equals(car.getExamineTag())).collect(Collectors.toList());


            if (!CollectionUtils.isEmpty(provinceList)) {


                Map<Long, List<CheckIndexCar>> carMap = provinceList.stream().collect(Collectors.groupingBy(CheckIndexCar::getDeptId));


                List<CheckIndexCar> cars = new ArrayList<>();


                carMap.forEach((deptId, list) -> {


                    CheckIndexCar car = CheckIndexCar.calculateAverage(list);


                    cars.add(car);


                });


                //根据积分降序


                checkIndexCars.addAll(cars.stream().sorted(Comparator.comparing(CheckIndexCar::getScore).reversed()).collect(Collectors.toList()));


            }


        }


        List<CheckIndexCarVO> checkIndexCarVOS = new ArrayList<>();


        for (CheckIndexCar indexCar : checkIndexCars) {


            CheckIndexCarVO excelVo = CheckIndexCar.getExcelVo(indexCar);


            checkIndexCarVOS.add(excelVo);


        }


        ExcelExp e1 = new ExcelExp("车辆考核指标数据", checkIndexCarVOS, CheckIndexCarVO.class);


        //人脸


        CheckIndexFace checkIndexFace = new CheckIndexFace();


        checkIndexFace.setDate(date);


        checkIndexFace.setQuarter(checkScoreDTO.getQuarter());


        List<CheckIndexFace> checkIndexFaces = indexFaceService.selectCheckIndexFaceList(checkIndexFace);


        for (CheckIndexFace indexFace : checkIndexFaces) {


            indexFace.setExamineTagStr(CheckConstants.Examine_Tag_Province.equals(indexFace.getExamineTag()) ? "省厅考核" : "区县考核");


//        checkIndexFace.setDate(date);


        checkIndexFace.setQuarter(exportDTO.getQuarter());


        checkIndexFace.setDeptId(exportDTO.getDeptId());


        checkIndexFace.setDeptIds(exportDTO.getDeptIds());


        //权限控制 只能查看已发布


        roleControl(checkIndexFace);


        List<CheckIndexFace> checkIndexFaces = new ArrayList<>();


        for (Integer examineTag : exportDTO.getExamineTags()) {


            checkIndexFace.setExamineTag(Short.valueOf(examineTag + ""));


            if (examineTag == 0) {


                checkIndexFace.setExamineTagQuery(1);


            }


            checkIndexFaces.addAll(indexFaceService.selectCheckIndexFaceList(checkIndexFace));


        }


        ExcelExp e2 = new ExcelExp("人脸考核指标数据", checkIndexFaces, CheckIndexFace.class);


        //计算平均值放在excel最后


        if (exportDTO.getAverage() != null && exportDTO.getAverage() && !CollectionUtils.isEmpty(checkIndexFaces)) {


            //先区分考核标签，再区分区县


            List<CheckIndexFace> countyList = checkIndexFaces.stream().filter(face -> CheckConstants.Examine_Tag_County.equals(face.getExamineTag())).collect(Collectors.toList());


            if (!CollectionUtils.isEmpty(countyList)) {


                Map<Long, List<CheckIndexFace>> faceMap = countyList.stream().collect(Collectors.groupingBy(CheckIndexFace::getDeptId));


                List<CheckIndexFace> faces = new ArrayList<>();


                faceMap.forEach((deptId, list) -> {


                    CheckIndexFace face = CheckIndexFace.calculateAverage(list);


                    faces.add(face);


                });


                //根据积分降序


                checkIndexFaces.addAll(faces.stream().sorted(Comparator.comparing(CheckIndexFace::getScore).reversed()).collect(Collectors.toList()));


            }


            List<CheckIndexFace> provinceList = checkIndexFaces.stream().filter(face -> CheckConstants.Examine_Tag_Province.equals(face.getExamineTag())).collect(Collectors.toList());


            if (!CollectionUtils.isEmpty(provinceList)) {


                Map<Long, List<CheckIndexFace>> faceMap = provinceList.stream().collect(Collectors.groupingBy(CheckIndexFace::getDeptId));


                List<CheckIndexFace> faces = new ArrayList<>();


                faceMap.forEach((deptId, list) -> {


                    CheckIndexFace face = CheckIndexFace.calculateAverage(list);


                    faces.add(face);


                });


                //根据积分降序


                checkIndexFaces.addAll(faces.stream().sorted(Comparator.comparing(CheckIndexFace::getScore).reversed()).collect(Collectors.toList()));


            }


        }


        List<CheckIndexFaceVO> checkIndexFaceVOS = new ArrayList<>();


        for (CheckIndexFace indexFace : checkIndexFaces) {


            CheckIndexFaceVO excelVo = CheckIndexFace.getExcelVo(indexFace);


            checkIndexFaceVOS.add(excelVo);


        }


        ExcelExp e2 = new ExcelExp("人脸考核指标数据", checkIndexFaceVOS, CheckIndexFaceVO.class);


        //视频


        CheckIndexVideo checkIndexVideo = new CheckIndexVideo();


        checkIndexVideo.setDate(date);


        checkIndexVideo.setQuarter(checkScoreDTO.getQuarter());


        List<CheckIndexVideo> checkIndexVideos = indexVideoService.selectCheckIndexVideoList(checkIndexVideo);


        for (CheckIndexVideo indexVideo : checkIndexVideos) {


            indexVideo.setExamineTagStr(CheckConstants.Examine_Tag_Province.equals(indexVideo.getExamineTag()) ? "省厅考核" : "区县考核");


//        checkIndexVideo.setDate(date);


        checkIndexVideo.setQuarter(exportDTO.getQuarter());


        checkIndexVideo.setDeptId(exportDTO.getDeptId());


        checkIndexVideo.setDeptIds(exportDTO.getDeptIds());


        //权限控制 只能查看已发布


        roleControl(checkIndexVideo);


        List<CheckIndexVideo> checkIndexVideos = new ArrayList<>();


        for (Integer examineTag : exportDTO.getExamineTags()) {


            checkIndexVideo.setExamineTag(Short.valueOf(examineTag + ""));


            if (examineTag == 0) {


                checkIndexVideo.setExamineTagQuery(1);


            }


            checkIndexVideos.addAll(indexVideoService.selectCheckIndexVideoList(checkIndexVideo));


        }


        ExcelExp e3 = new ExcelExp("视频考核指标数据", checkIndexVideos, CheckIndexVideo.class);


        //计算平均值放在excel最后


        if (exportDTO.getAverage() != null && exportDTO.getAverage() && !CollectionUtils.isEmpty(checkIndexVideos)) {


            //先区分考核标签，再区分区县


            List<CheckIndexVideo> countyList = checkIndexVideos.stream().filter(video -> CheckConstants.Examine_Tag_County.equals(video.getExamineTag())).collect(Collectors.toList());


            if (!CollectionUtils.isEmpty(countyList)) {


                Map<Long, List<CheckIndexVideo>> videoMap = countyList.stream().collect(Collectors.groupingBy(CheckIndexVideo::getDeptId));


                List<CheckIndexVideo> videos = new ArrayList<>();


                videoMap.forEach((deptId, list) -> {


                    CheckIndexVideo video = CheckIndexVideo.calculateAverage(list);


                    videos.add(video);


                });


                //根据积分降序


                checkIndexVideos.addAll(videos.stream().sorted(Comparator.comparing(CheckIndexVideo::getScore).reversed()).collect(Collectors.toList()));


            }


            List<CheckIndexVideo> provinceList = checkIndexVideos.stream().filter(video -> CheckConstants.Examine_Tag_Province.equals(video.getExamineTag())).collect(Collectors.toList());


            if (!CollectionUtils.isEmpty(provinceList)) {


                Map<Long, List<CheckIndexVideo>> videoMap = provinceList.stream().collect(Collectors.groupingBy(CheckIndexVideo::getDeptId));


                List<CheckIndexVideo> videos = new ArrayList<>();


                videoMap.forEach((deptId, list) -> {


                    CheckIndexVideo video = CheckIndexVideo.calculateAverage(list);


                    videos.add(video);


                });


                //根据积分降序


                checkIndexVideos.addAll(videos.stream().sorted(Comparator.comparing(CheckIndexVideo::getScore).reversed()).collect(Collectors.toList()));


            }


        }


        List<CheckIndexVideoVO> checkIndexVideoVOS = new ArrayList<>();


        for (CheckIndexVideo indexVideo : checkIndexVideos) {


            CheckIndexVideoVO excelVo = CheckIndexVideo.getExcelVo(indexVideo);


            checkIndexVideoVOS.add(excelVo);


        }


        ExcelExp e3 = new ExcelExp("视频考核指标数据", checkIndexVideoVOS, CheckIndexVideoVO.class);




        List<ExcelExp> mysheet = new ArrayList<>();


        mysheet.add(e1);


        mysheet.add(e2);


        mysheet.add(e3);


        //规则明细


        List<RuleExcelVO> allRuleTemplate = templateRuleMapper.getAllRuleTemplate();


        //整合数据


        List<RuleExcelVO> countyRuleList = allRuleTemplate.stream().filter(vo -> vo.getExamineTag().equals(Integer.parseInt(CheckConstants.Examine_Tag_County + ""))).collect(Collectors.toList());


        List<RuleExcelVO> provinceRuleList = allRuleTemplate.stream().filter(vo -> vo.getExamineTag().equals(Integer.parseInt(CheckConstants.Examine_Tag_Province + ""))).collect(Collectors.toList());


        //用区县规则做主体展示


        for (RuleExcelVO countyRule : countyRuleList) {


            countyRule.setCountyWeight(countyRule.getWeight());


            //筛选同种规则权重


            for (RuleExcelVO provinceRule : provinceRuleList) {


                if (provinceRule.getRuleId().equals(countyRule.getRuleId()) && provinceRule.getExamineCategory().equals(countyRule.getExamineCategory())) {


                    countyRule.setProvinceWeight(provinceRule.getWeight());


                }


            }


        }


        ExcelExp e4 = new ExcelExp("规则明细", countyRuleList, RuleExcelVO.class);


        mysheet.add(e4);


        ExcelUtilManySheet<List<ExcelExp>> util = new ExcelUtilManySheet<>(mysheet);


        util.exportExcelManySheet(response, mysheet);




    }




    private void roleControl(CheckScore checkScore) {


    private void roleControl(CheckIndex checkIndex) {


        List<SysRole> roles = SecurityUtils.getLoginUser().getUser().getRoles();


        SysUser user = SecurityUtils.getLoginUser().getUser();


        if (!user.isAdmin()) {


            for (SysRole role : roles) {


                //TODO：本地库修改


                if (role.getPermissions().contains("check:score:role:publish")) {


                    Map<String, Object> params = checkIndex.getParams();


                    params.put("publish", PublishType.PUBLISHED.getCode());


                }


            }


        }


    }




    private void roleControl(BaseEntity checkScore) {


        List<SysRole> roles = SecurityUtils.getLoginUser().getUser().getRoles();


        SysUser user = SecurityUtils.getLoginUser().getUser();


        if (!user.isAdmin()) {


            for (SysRole role : roles) {


                if (role.getPermissions().contains("check:score:role:publish")) {


                    Map<String, Object> params = checkScore.getParams();


                    params.put("publish", PublishType.PUBLISHED.getCode());


@@ -331,6 +526,23 @@


        return scoreMapper.calculate(startDate, endDate, category);


    }




    //大屏展示考核得分


    @Override


    public Map<String, Map<String, Object>> dashboard(DashboardQuery dashboardQuery) {


        Date now = new Date();


        dashboardQuery.setStartTime(DateUtils.getMouthStart(now));


        dashboardQuery.setEndTime(DateUtils.getMouthEnd(now));


        List<CheckScore> dashboard = scoreMapper.dashboard(dashboardQuery);


        Map<String, Map<String, Object>> resultMap = new HashMap<>();




        for (CheckScore checkScore : dashboard) {


            Map<String, Object> map = new HashMap<>();


            map.put("score", checkScore.getScore().setScale(2,RoundingMode.HALF_UP));


            resultMap.put(checkScore.getDeptName(), map);


        }


        return resultMap;


    }




    //    /**


//     * 新增考核积分


//     *