射洪市项目管理系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zhanghua
2025-02-22 ad6a05f2535c1f29a764f352d8ca666cae1b97d1 
 business/src/main/java/com/ycl/service/impl/ProjectInfoServiceImpl.java


@@ -1,6 +1,5 @@


package com.ycl.service.impl;




import cn.hutool.core.collection.CollUtil;


import cn.hutool.core.io.IORuntimeException;


import cn.hutool.core.util.CharsetUtil;


import cn.hutool.core.util.ObjectUtil;


@@ -8,19 +7,19 @@


import cn.hutool.core.util.ZipUtil;


import com.alibaba.excel.EasyExcel;


import com.baomidou.mybatisplus.core.conditions.Wrapper;


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


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


import com.baomidou.mybatisplus.core.metadata.IPage;


import com.baomidou.mybatisplus.core.toolkit.Wrappers;


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


import com.ycl.common.annotation.DataScope;


import com.ycl.common.base.Result;


import com.ycl.common.config.SysConfig;


import com.ycl.common.constant.Constants;


import com.ycl.common.core.domain.BaseEntity;


import com.ycl.common.core.domain.entity.SysDictData;


import com.ycl.common.enums.business.FileTypeEnum;


import com.ycl.common.enums.business.ImportanceTypeEnum;


import com.ycl.common.enums.business.ProjectCategoryEnum;


import com.ycl.common.enums.business.ProjectStatusEnum;


import com.ycl.common.exception.base.BaseException;


import com.ycl.common.utils.CopyUtils;


import com.ycl.common.utils.DateUtils;


@@ -31,7 +30,7 @@


import com.ycl.common.utils.file.FileUploadUtils;


import com.ycl.common.utils.file.FileUtils;


import com.ycl.common.utils.poi.ExcelUtil;


import com.ycl.controller.ProjectInfoController;


import com.ycl.constant.ProjectConstant;


import com.ycl.domain.entity.*;


import com.ycl.domain.excel.ProjectExcelTemplate;


import com.ycl.domain.form.*;


@@ -41,11 +40,13 @@


import com.ycl.framework.utils.PageUtil;


import com.ycl.listener.excel.ProjectImportListener;


import com.ycl.mapper.*;


import com.ycl.service.FileService;


import com.ycl.service.ProjectInfoService;


import com.ycl.service.*;


import com.ycl.system.mapper.SysDeptMapper;


import com.ycl.system.service.ISysDeptService;


import com.ycl.system.service.ISysDictDataService;


import lombok.RequiredArgsConstructor;


import org.apache.commons.codec.Charsets;


import org.springframework.aop.framework.AopContext;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.Assert;


@@ -61,15 +62,12 @@


import java.math.BigDecimal;


import java.math.RoundingMode;


import java.net.URLEncoder;


import java.nio.charset.StandardCharsets;


import java.nio.file.Files;


import java.nio.file.Path;


import java.nio.file.StandardCopyOption;


import java.text.SimpleDateFormat;


import java.util.*;


import java.util.stream.Collectors;


import java.util.stream.Stream;


import java.util.zip.ZipOutputStream;




/**


 * 项目管理基础信息表 服务实现类


@@ -82,6 +80,8 @@


public class ProjectInfoServiceImpl extends ServiceImpl<ProjectInfoMapper, ProjectInfo> implements ProjectInfoService {




    private final ProjectInfoMapper projectInfoMapper;


    private final ProjectInfoWinUnitService projectInfoWinUnitService;


    private final ProjectInfoYearPlanService projectInfoYearPlanService;


    private final ProjectInvestmentFundingMapper investmentFundingMapper;


    private final ProjectInvestmentInfoMapper investmentInfoMapper;


    private final ProjectInvestmentPolicyComplianceMapper policyMapper;


@@ -94,6 +94,8 @@


    private final ProjectInvestmentPolicyComplianceServiceImpl projectInvestmentPolicyComplianceServiceImpl;


    private final ProjectUnitRegistrationInfoServiceImpl projectUnitRegistrationInfoServiceImpl;


    private final SysDeptMapper sysDeptMapper;


    private final ISysDictDataService dictDataService;






    /**


     * 添加


@@ -102,15 +104,21 @@


     * @return


     */


    @Override


    @Transactional(rollbackFor = Exception.class)


    public Result add(ProjectInfoForm form) {


        //添加基本信息


        ProjectInfo entity = ProjectInfoForm.getEntityByForm(form, null);


        Long userId = SecurityUtils.getUserId();


        Long deptId = SecurityUtils.getDeptId();


        entity.setProjectOwnerUnit(deptId);


//        Long deptId = SecurityUtils.getDeptId();


//        entity.setProjectOwnerUnit(deptId);


        entity.setCreateBy(userId);


        entity.setUpdateBy(userId);


        //如果是储备项目(未开工项目)不需要审核


        if (ProjectConstant.COMMIT.equals(entity.getUsedStatus()) && ProjectStatusEnum.PENDDING.getType().equals(entity.getProjectStatus())) {


            entity.setUsedStatus(ProjectConstant.PASS);


        }


        if(!checkProjectNameAndIdIsUnique(entity,null)){


            return Result.error("项目名或项目码已存在");


        }


        baseMapper.insert(entity);


        addPlan(entity.getId()); //添加计划表


        //添加文件


@@ -120,7 +128,40 @@


            item.setType(FileTypeEnum.PROJECT_INFO);


        });


        fileService.saveBatch(fileList);




        //添加项目中标单位


        saveUnit(entity.getId(), form.getWinUnitList());


        //添加年度投资计划


        saveYearPlan(entity.getId(), form.getYearPlanList());


        return Result.ok("添加成功").data(entity.getId());


    }




    /**


     * 判断项目名和项目码是否唯一


     * @param entity from true 来自add() false 来自edit()


     * @return


     */


    public boolean  checkProjectNameAndIdIsUnique(ProjectInfo entity,Long updateId){


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


        if (updateId == null) {




            queryWrapper.eq("project_name", entity.getProjectName());




            if (StringUtils.isNotEmpty(entity.getProjectCode())) {


                queryWrapper.or();


                queryWrapper.eq("project_code", entity.getProjectCode());


            }




            List<ProjectInfo> project = projectInfoMapper.selectList(queryWrapper);




            return project == null || project.isEmpty();


        }else {




            List<ProjectInfo> project = projectInfoMapper.checkProjectNameAndIdIsUnique(updateId,entity.getProjectName(),entity.getProjectCode());




            return project == null || project.isEmpty();


        }




    }




    public void addPlan(Long projectInfoId) {


@@ -141,14 +182,21 @@


     * @return


     */


    @Override


    @Transactional(rollbackFor = Exception.class)


    public Result update(ProjectInfoForm form) {


        ProjectInfo entity = baseMapper.selectById(form.getId());




        // 为空抛IllegalArgumentException，做全局异常处理


        Assert.notNull(entity, "记录不存在");


        ProjectInfoForm.getEntityByForm(form, entity);


        Long userId = SecurityUtils.getUserId();


        entity.setUpdateBy(userId);


        //如果是储备项目(未开工项目)不需要审核


        if (ProjectConstant.COMMIT.equals(entity.getUsedStatus()) && ProjectStatusEnum.PENDDING.getType().equals(entity.getProjectStatus())) {


            entity.setUsedStatus(ProjectConstant.PASS);


        }


        if(!checkProjectNameAndIdIsUnique(entity,form.getId())){


            return Result.error("项目名或项目码已存在");


        }


        //更新项目信息


        baseMapper.updateById(entity);


        List<File> fileList = form.getFileList();


@@ -164,7 +212,49 @@


        fileMapper.delete(fileQueryWrapper);


        //替换成现有


        fileService.saveBatch(fileList);




        //修改项目中标单位


        //删除原数据


        QueryWrapper<ProjectInfoWinUnit> unitWrapper = new QueryWrapper<>();


        unitWrapper.eq("project_info_id", form.getId());


        projectInfoWinUnitService.remove(unitWrapper);


        //添加项目中标单位


        saveUnit(entity.getId(), form.getWinUnitList());




        //修改年度投资计划


        //删除原数据


        QueryWrapper<ProjectInfoYearPlan> yearPlanWrapper = new QueryWrapper<>();


        unitWrapper.eq("project_info_id", form.getId());


        projectInfoYearPlanService.remove(yearPlanWrapper);


        //添加年度投资计划


        saveYearPlan(entity.getId(), form.getYearPlanList());


        return Result.ok("修改成功");


    }




    private void saveUnit(Long id, List<ProjectInfoWinUnitForm> projectInfoWinUnitForm) {


        List<ProjectInfoWinUnit> projectInfoWinUnits = new ArrayList<>();


        for (ProjectInfoWinUnitForm winUnitForm : projectInfoWinUnitForm) {


            ProjectInfoWinUnit projectInfoWinUnit = ProjectInfoWinUnitForm.getEntityByForm(winUnitForm, null);


            projectInfoWinUnit.setId(null);


            projectInfoWinUnit.setProjectInfoId(id);


            projectInfoWinUnits.add(projectInfoWinUnit);


        }


        if (!CollectionUtils.isEmpty(projectInfoWinUnits)) {


            projectInfoWinUnitService.saveBatch(projectInfoWinUnits);


        }


    }




    private void saveYearPlan(Long id, List<ProjectInfoYearPlanForm> yearPlanList) {


        List<ProjectInfoYearPlan> projectInfoYearPlans = new ArrayList<>();


        for (ProjectInfoYearPlanForm yearPlanForm : yearPlanList) {


            ProjectInfoYearPlan yearPlan = ProjectInfoYearPlanForm.getEntityByForm(yearPlanForm, null);


            yearPlan.setId(null);


            yearPlan.setProjectInfoId(id);


            projectInfoYearPlans.add(yearPlan);


        }


        if (!CollectionUtils.isEmpty(projectInfoYearPlans)) {


            projectInfoYearPlanService.saveBatch(projectInfoYearPlans);


        }


    }




    /**


@@ -192,6 +282,8 @@


        investmentInfoMapper.delete(new QueryWrapper<ProjectInvestmentInfo>().eq("project_id", id));


        policyMapper.delete(new QueryWrapper<ProjectInvestmentPolicyCompliance>().eq("project_id", id));


        unitRegistrationInfoMapper.delete(new QueryWrapper<ProjectUnitRegistrationInfo>().eq("project_id", id));


        projectInfoWinUnitService.remove(new QueryWrapper<ProjectInfoWinUnit>().eq("project_info_id", id));


        projectInfoYearPlanService.remove(new QueryWrapper<ProjectInfoYearPlan>().eq("project_info_id", id));




        List<String> types = new ArrayList<>();


        types.add(FileTypeEnum.PROJECT_INFO.getType());


@@ -203,7 +295,7 @@


    }




    /**


     * 分页查询


     * 分页查询，TODO 项目中心的分页使用单独的接口，去掉写死的逻辑换成dept or查询


     *


     * @param query


     * @return


@@ -239,12 +331,12 @@


        String ancestors = sysDeptMapper.selectAncestors(userId);


        String[] ancestorArr = ancestors.split(",");


        List<String> ancestorList = Arrays.stream(ancestorArr).collect(Collectors.toList());


        ancestorList.add(SecurityUtils.getDeptId()+"");


        if(!CollectionUtils.isEmpty(ancestorList) && ancestorList.contains("101")){


        ancestorList.add(SecurityUtils.getDeptId() + "");


        if (!CollectionUtils.isEmpty(ancestorList) && ancestorList.contains("101")) {


            query.setProjectOwnerUnit(SecurityUtils.getDeptId());


            //业主


            query.setRole(0);


        }else if(!CollectionUtils.isEmpty(ancestorList) && ancestorList.contains("102")){


        } else if (!CollectionUtils.isEmpty(ancestorList) && ancestorList.contains("102")) {


            query.setCompetentDepartment(SecurityUtils.getDeptId());


            //审批 对应主管部门


            query.setRole(1);


@@ -258,9 +350,18 @@


            ProjectInfoVO.transform(vo);


            ProjectVO projectVO = new ProjectVO();


            copyToProjectVO(vo, projectVO);


            //翻译项目阶段


            List<Long> departmentList = vo.getCompetentDepartmentList();


            projectVO.setAuditRole(SecurityUtils.isAdmin(SecurityUtils.getUserId()) || (!CollectionUtils.isEmpty(departmentList) && departmentList.contains(SecurityUtils.getDeptId())));


            // 翻译项目阶段


            String phase = ProjectCategoryEnum.getPhaseByProjectStatus(projectVO.getProjectStatus(), projectVO.getProcessId() != null);


            projectVO.setProjectPhase(phase);


            if (StringUtils.isNotEmpty(projectVO.getProjectSubType())) {


                // 翻译项目子类型


                SysDictData dictData = dictDataService.selectDictDataByValue(projectVO.getProjectType(), projectVO.getProjectSubType(), "sys_project_type");


                if (Objects.nonNull(dictData)) {


                    projectVO.setProjectSubType(dictData.getDictLabel());


                }


            }


            list.add(projectVO);


        });


        return Result.ok().data(list).total(page.getTotal());


@@ -290,11 +391,33 @@


        ProjectInfo entity = baseMapper.getById(id);


        Assert.notNull(entity, "记录不存在");


        ProjectInfoVO vo = ProjectInfoVO.getVoByEntity(entity, null);


        List<Long> departmentList = vo.getCompetentDepartmentList();


        vo.setAuditRole(SecurityUtils.isAdmin(SecurityUtils.getUserId()) || (!CollectionUtils.isEmpty(departmentList) && departmentList.contains(SecurityUtils.getDeptId())));


        QueryWrapper<File> fileQueryWrapper = new QueryWrapper<>();


        fileQueryWrapper.eq("type", FileTypeEnum.PROJECT_INFO.getType());


        fileQueryWrapper.eq("bus_id", vo.getId());




        List<File> files = fileMapper.selectList(fileQueryWrapper);


        vo.setFileList(files);




        //中标单位


        List<ProjectInfoWinUnitVO> unitVOS = new ArrayList<>();


        List<ProjectInfoWinUnit> unitList = projectInfoWinUnitService.list(new QueryWrapper<ProjectInfoWinUnit>().eq("project_info_id", id));


        for (ProjectInfoWinUnit projectInfoWinUnit : unitList) {


            ProjectInfoWinUnitVO unitVO = ProjectInfoWinUnitVO.getVoByEntity(projectInfoWinUnit, null);


            unitVO.setId(null);


            unitVOS.add(unitVO);


        }


        vo.setWinUnitList(unitVOS);


        //年度投资计划


        List<ProjectInfoYearPlanVO> yearPlanVOS = new ArrayList<>();


        List<ProjectInfoYearPlan> yearPlaList = projectInfoYearPlanService.list(new QueryWrapper<ProjectInfoYearPlan>().eq("project_info_id", id));


        for (ProjectInfoYearPlan yearPlan : yearPlaList) {


            ProjectInfoYearPlanVO yearPlanVO = ProjectInfoYearPlanVO.getVoByEntity(yearPlan, null);


            yearPlanVO.setId(null);


            yearPlanVOS.add(yearPlanVO);


        }


        vo.setYearPlanList(yearPlanVOS);


        return Result.ok().data(vo);


    }




@@ -348,7 +471,8 @@


                city.add(item);


            } else if (ImportanceTypeEnum.SHEHONG_KEY.getType().equals(item.getImportanceType())) {


                county.add(item);


            } else if (ImportanceTypeEnum.NORMAL.getType().equals(item.getImportanceType())) {


            } else // if  (ImportanceTypeEnum.NORMAL.getType().equals(item.getImportanceType()))


            {


                normal.add(item);


            }


        });


@@ -356,22 +480,22 @@


        proPhaseCountVO.add(new IndexProPhaseCountVO("储备规划阶段", reserve.size(), reserve.stream().


                filter(item -> !StringUtils.isEmpty(item.getTotalInvestment()))


                .map(item -> new BigDecimal(item.getTotalInvestment()).setScale(2, RoundingMode.HALF_UP))


                .reduce(BigDecimal.ZERO, BigDecimal::add).divide(new BigDecimal("100000000"), 2, RoundingMode.HALF_UP).toString(), "储"));


                .reduce(BigDecimal.ZERO, BigDecimal::add).divide(new BigDecimal("10000"), 2, RoundingMode.HALF_UP).toString(), "储"));




        proPhaseCountVO.add(new IndexProPhaseCountVO("项目前期阶段", previous.size(), previous.stream().


                filter(item -> !StringUtils.isEmpty(item.getTotalInvestment()))


                .map(item -> new BigDecimal(item.getTotalInvestment()).setScale(2, RoundingMode.HALF_UP))


                .reduce(BigDecimal.ZERO, BigDecimal::add).divide(new BigDecimal("100000000"), 2, RoundingMode.HALF_UP).toString(), "新"));


                .reduce(BigDecimal.ZERO, BigDecimal::add).divide(new BigDecimal("10000"), 2, RoundingMode.HALF_UP).toString(), "新"));




        proPhaseCountVO.add(new IndexProPhaseCountVO("实施阶段", implement.size(), implement.stream().


                filter(item -> !StringUtils.isEmpty(item.getTotalInvestment()))


                .map(item -> new BigDecimal(item.getTotalInvestment()).setScale(2, RoundingMode.HALF_UP))


                .reduce(BigDecimal.ZERO, BigDecimal::add).divide(new BigDecimal("100000000"), 2, RoundingMode.HALF_UP).toString(), "建"));


                .reduce(BigDecimal.ZERO, BigDecimal::add).divide(new BigDecimal("10000"), 2, RoundingMode.HALF_UP).toString(), "建"));




        proPhaseCountVO.add(new IndexProPhaseCountVO("竣工投用阶段", finish.size(), finish.stream().


                filter(item -> !StringUtils.isEmpty(item.getTotalInvestment()))


                .map(item -> new BigDecimal(item.getTotalInvestment()).setScale(2, RoundingMode.HALF_UP))


                .reduce(BigDecimal.ZERO, BigDecimal::add).divide(new BigDecimal("100000000"), 2, RoundingMode.HALF_UP).toString(), "竣"));


                .reduce(BigDecimal.ZERO, BigDecimal::add).divide(new BigDecimal("10000"), 2, RoundingMode.HALF_UP).toString(), "竣"));




        indexCountVO.setProPhaseCountVO(proPhaseCountVO);




@@ -379,22 +503,22 @@


        impTypeCountVO.add(new IndexImpTypeCountVO("一般项目", normal.size(), normal.stream().


                filter(item -> !StringUtils.isEmpty(item.getTotalInvestment()))


                .map(item -> new BigDecimal(item.getTotalInvestment()).setScale(2, RoundingMode.HALF_UP))


                .reduce(BigDecimal.ZERO, BigDecimal::add).divide(new BigDecimal("100000000"), 2, RoundingMode.HALF_UP).toString(), "普"));


                .reduce(BigDecimal.ZERO, BigDecimal::add).divide(new BigDecimal("10000"), 2, RoundingMode.HALF_UP).toString(), "普"));




        impTypeCountVO.add(new IndexImpTypeCountVO("县重点项目", county.size(), county.stream().


                filter(item -> !StringUtils.isEmpty(item.getTotalInvestment()))


                .map(item -> new BigDecimal(item.getTotalInvestment()).setScale(2, RoundingMode.HALF_UP))


                .reduce(BigDecimal.ZERO, BigDecimal::add).divide(new BigDecimal("100000000"), 2, RoundingMode.HALF_UP).toString(), "县"));


                .reduce(BigDecimal.ZERO, BigDecimal::add).divide(new BigDecimal("10000"), 2, RoundingMode.HALF_UP).toString(), "县"));




        impTypeCountVO.add(new IndexImpTypeCountVO("市重点项目", city.size(), city.stream().


                filter(item -> !StringUtils.isEmpty(item.getTotalInvestment()))


                .map(item -> new BigDecimal(item.getTotalInvestment()).setScale(2, RoundingMode.HALF_UP))


                .reduce(BigDecimal.ZERO, BigDecimal::add).divide(new BigDecimal("100000000"), 2, RoundingMode.HALF_UP).toString(), "市"));


                .reduce(BigDecimal.ZERO, BigDecimal::add).divide(new BigDecimal("10000"), 2, RoundingMode.HALF_UP).toString(), "市"));




        impTypeCountVO.add(new IndexImpTypeCountVO("省重点项目", province.size(), province.stream().


                filter(item -> !StringUtils.isEmpty(item.getTotalInvestment()))


                .map(item -> new BigDecimal(item.getTotalInvestment()).setScale(2, RoundingMode.HALF_UP))


                .reduce(BigDecimal.ZERO, BigDecimal::add).divide(new BigDecimal("100000000"), 2, RoundingMode.HALF_UP).toString(), "省"));


                .reduce(BigDecimal.ZERO, BigDecimal::add).divide(new BigDecimal("10000"), 2, RoundingMode.HALF_UP).toString(), "省"));


        indexCountVO.setImpTypeCountVO(impTypeCountVO);


        return indexCountVO;


    }


@@ -682,14 +806,17 @@


    }




    @Override


    @Transactional(rollbackFor = Exception.class)


    public Result editProject(ProjectForm form) {


        if (ObjectUtil.isNotNull(form.getProjectInfoForm())) {




            if (ObjectUtil.isNull(form.getProjectInfoForm().getId())) {


                //新增


                add(form.getProjectInfoForm());


                return ((ProjectInfoServiceImpl) AopContext.currentProxy()).add(form.getProjectInfoForm());




            } else {


                //更新


                update(form.getProjectInfoForm());


                return ((ProjectInfoServiceImpl) AopContext.currentProxy()).update(form.getProjectInfoForm());


            }


        }


        if (ObjectUtil.isNotNull(form.getProjectInvestmentInfoForm())) {