blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xiangpei
2024-09-06 d49b037cd6d42cff6e8a15b3590a3edac2c4568b 
 ycl-server/src/main/java/com/ycl/platform/service/impl/CheckScoreServiceImpl.java


@@ -2,13 +2,15 @@




import annotation.DataScope;


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


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


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


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.domain.vo.*;


import com.ycl.platform.mapper.CheckRuleMapper;


import com.ycl.platform.mapper.CheckScoreMapper;


import com.ycl.platform.mapper.CheckTemplateMapper;


@@ -17,6 +19,7 @@


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;


@@ -29,14 +32,18 @@


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.text.SimpleDateFormat;


import java.time.LocalDateTime;


import java.util.*;


import java.util.function.Function;


import java.util.stream.Collectors;




/**


@@ -65,6 +72,7 @@


    @Autowired


    private ISysDeptService deptService;






    /**


     * 查询考核积分指标


     *


@@ -82,10 +90,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 +128,8 @@


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


        }




        //权限控制


        roleControl(scoreIndexDTO);


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




        scoreMap.put("tableData", checkRules);


@@ -163,7 +173,9 @@


                checkScores = scoreMapper.selectCheckScoreMap(checkScore);


            }


        }


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


        //分数保留一位小数


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


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


    }




    private void getCheckScore(CheckScore checkScore, Calendar calendar) {


@@ -183,7 +195,7 @@


    }




    /**


     * 查询考核积分卡片列表


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


     *


     * @param checkScore 考核积分


     * @return 考核积分


@@ -207,6 +219,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 +235,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 +247,7 @@


     * @return 结果


     */


    @Override


    @Transactional(rollbackFor = Exception.class)


    public int publishCheckScore(CheckScoreDTO checkScoreDTO) {


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


            return 0;


@@ -243,8 +260,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 +296,193 @@


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


//        checkIndexCar.setDate(date);


        checkIndexCar.setQuarter(exportDTO.getQuarter());


        checkIndexCar.setDeptId(exportDTO.getDeptId());


        checkIndexCar.setDeptIds(exportDTO.getDeptIds());


        checkIndexCar.setExamineTags(exportDTO.getExamineTags());


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


        roleControl(checkIndexCar);


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


        for (CheckIndexCar indexCar : checkIndexCars) {


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


        //计算平均值放在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()));


            }


        }


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


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


//        checkIndexFace.setDate(date);


        checkIndexFace.setQuarter(exportDTO.getQuarter());


        checkIndexFace.setDeptId(exportDTO.getDeptId());


        checkIndexFace.setDeptIds(exportDTO.getDeptIds());


        checkIndexFace.setExamineTags(exportDTO.getExamineTags());


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


        roleControl(checkIndexFace);


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


        for (CheckIndexFace indexFace : checkIndexFaces) {


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


        //计算平均值放在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()));


            }


        }


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


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


//        checkIndexVideo.setDate(date);


        checkIndexVideo.setQuarter(exportDTO.getQuarter());


        checkIndexVideo.setDeptId(exportDTO.getDeptId());


        checkIndexVideo.setDeptIds(exportDTO.getDeptIds());


        checkIndexVideo.setExamineTags(exportDTO.getExamineTags());


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


        roleControl(checkIndexVideo);


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


        for (CheckIndexVideo indexVideo : checkIndexVideos) {


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


        //计算平均值放在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()));


            }


        }


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


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