射洪市项目管理系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
fuliqi
2025-02-19 178b4ee9f38a8b38b1cb5321fee25a6038b39df9 
 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,12 +7,10 @@


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;


@@ -21,6 +18,7 @@


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 +29,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.*;


@@ -43,6 +41,8 @@


import com.ycl.mapper.*;


import com.ycl.service.FileService;


import com.ycl.service.ProjectInfoService;


import com.ycl.service.ProjectInfoWinUnitService;


import com.ycl.service.ProjectInfoYearPlanService;


import com.ycl.system.mapper.SysDeptMapper;


import lombok.RequiredArgsConstructor;


import org.apache.commons.codec.Charsets;


@@ -61,15 +61,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 +79,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;


@@ -111,6 +110,10 @@


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


        }


        baseMapper.insert(entity);


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


        //添加文件


@@ -120,8 +123,15 @@


            item.setType(FileTypeEnum.PROJECT_INFO);


        });


        fileService.saveBatch(fileList);




        //添加项目中标单位


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


        //添加年度投资计划


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


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


    }








    public void addPlan(Long projectInfoId) {


        Plan plan = new Plan();


@@ -164,9 +174,50 @@


        fileMapper.delete(fileQueryWrapper);


        //替换成现有


        fileService.saveBatch(fileList);




        //修改项目中标单位


        //删除原数据


        List<ProjectInfoWinUnitForm> projectInfoWinUnitForm = form.getWinUnitList();


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


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


        projectInfoWinUnitService.remove(unitWrapper);


        //添加项目中标单位


        saveUnit(entity.getId(),projectInfoWinUnitForm);




        //修改年度投资计划


        //删除原数据


//        List<ProjectInfoYearPlanForm> projectInfoYearPlanForm = form.getYearPlanList();


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


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


        projectInfoWinUnitService.remove(unitWrapper);


        //添加年度投资计划


        saveUnit(entity.getId(),projectInfoWinUnitForm);


        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.setProjectInfoId(id);


            projectInfoYearPlans.add(yearPlan);


        }


        if (!CollectionUtils.isEmpty(projectInfoYearPlans)) {


            projectInfoYearPlanService.saveBatch(projectInfoYearPlans);


        }


    }


    /**


     * 批量删除


     *


@@ -192,6 +243,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());


@@ -297,8 +350,19 @@


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


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


    }