项目管理系统+springboot+权限管理+大屏

package com.cf.pm.services.facade.impl; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.date.DateUtil; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.TypeReference; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.cf.pm.dao.mapper.DataAuthMapper; import com.cf.pm.dao.mapper.ProjectTeamMapper; import com.cf.pm.dao.po.*; import com.cf.pm.facade.bo.*; import com.cf.pm.facade.constant.BasicConstant; import com.cf.pm.facade.constant.BelongConstant; import com.cf.pm.facade.constant.BusinessReqConstant; import com.cf.pm.facade.constant.ProBaseConstant; import com.cf.pm.facade.dto.*; import com.cf.pm.facade.enums.*; import com.cf.pm.facade.facade.ProjectFacade; import com.cf.pm.services.service.*; import com.cf.pm.services.utils.AssertUtil; import com.cf.pm.services.utils.PageUtils; import com.cf.support.bean.IdWorker; import com.cf.support.exception.BusinessException; import com.cf.support.result.PageResponse; import com.cf.support.utils.BeanConvertorUtils; import com.cf.support.utils.DingAlarmUtils; import com.cf.support.utils.ExcelUtiles; import com.cf.support.utils.RedisUtil; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.lang3.ObjectUtils; import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.time.DateFormatUtils; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import javax.servlet.http.HttpServletResponse; import java.math.BigDecimal; import java.util.*; import java.util.concurrent.atomic.AtomicReference; import java.util.stream.Collectors; @Slf4j @Service public class ProjectFacadeImpl implements ProjectFacade { @Value("${bpm.url}") private String bpmUrl; @Resource private ProjectService projectService; @Resource private ProjectTeamMapper projectTeamMapper; @Resource private IdWorker idWorker; @Resource private RedisUtil redisUtil; @Resource private TemplateService templateService; @Resource private TemplateStageService templateStageService; @Resource private TemplateStageDeliverablesService templateStageDeliverablesService; @Resource private StageService stageService; @Resource private ProjectTeamService projectTeamService; @Resource private DataAuthService dataAuthService; @Resource private DataAuthMapper dataAuthMapper; @Resource private UsersRolesService usersRolesService; @Resource private DeliveryTeamService deliveryTeamService; @Resource private EmployeeService employeeService; @Resource private ProjectGoalService projectGoalService; @Resource private FormService formService; @Resource private DeliveryService deliveryService; @Resource private InventoryService inventoryService; @Resource private DepartmentService departmentService; @Resource private ProjectBudgetService projectBudgetService; @Resource private TaskFileService taskFileService; @Resource private TaskService taskService; @Resource private RolesService rolesService; @Resource private MonthlySummaryService monthlySummaryService; @Override @Transactional(rollbackFor = Exception.class) public String create(CreateProjectDTO param) { Long templateId = param.getTemplateId(); TemplatePO templatePO = templateService.getById(templateId); if (templatePO == null || !templatePO.getState().equals(TemplateStateEnum.COMPLETED.getCode())) { throw new RuntimeException("模板不存在"); } if (templatePO.getTemplateType().equals(ProjectTypeEnum.IT.getCode()) && ObjectUtils.isEmpty(param.getItProType())) { throw new BusinessException("it项目 信息化项目类型为必填"); } EmployeePO manager = employeeService.getEmployeeByEmpNo(param.getManagerEmplNo()); String projectNo = null; //项目团队 List<ProjectTeamPO> projectTeamPOArrayList = new ArrayList<>(); if (StringUtils.isNotEmpty(param.getParentProjectNo())) { //父项目编号不为空代表当前操作是创建子项目 //子项目编号规则 = 父项目编号 + 2位顺序号 projectNo = param.getParentProjectNo() + getSubProjectNum(param.getParentProjectNo()); // 子项目的话把原本父项目项目经理加入到项目团队 ProjectTeamPO originManager = projectTeamService.getManager(param.getParentProjectNo()); // 判断，如果父项目项目经理等于子项目经理，就不进行添加 if (!originManager.getEmplNo().equals(manager.getEmplNo())) { projectTeamPOArrayList.add(new ProjectTeamPO() .setCreateUser(param.getCreateUser()) .setUpdateUser(param.getUpdateUser()) .setIsManager(0) .setProjectNo(projectNo) .setEmplNo(originManager.getEmplNo()) .setEmplName(originManager.getEmplName()) .setDepartmentFullName(originManager.getDepartmentFullName())); } // 如果父项目编号不为空，则父项目的子项目数量 +1, 目前只有加操作 projectService.update(new LambdaUpdateWrapper<ProjectPO>() .eq(ProjectPO::getProjectNo, param.getParentProjectNo()) .setSql(ProjectPO.SUB_PROJECT_COUNT + "=" + ProjectPO.SUB_PROJECT_COUNT + " + 1")); } else { //手动创建项目 projectNo = buildProjectNo(param, templatePO.getTemplateType()); } //默认项目经理插入项目团队表 projectTeamPOArrayList.add(new ProjectTeamPO() .setCreateUser(param.getCreateUser()) .setUpdateUser(param.getUpdateUser()) .setIsManager(1) .setProjectNo(projectNo) .setEmplNo(manager.getEmplNo()) .setEmplName(manager.getName()) .setDepartmentFullName(manager.getDepartmentFullName())); //1.保存项目团队 projectTeamService.saveBatch(projectTeamPOArrayList); //是否需要创建清单 boolean isAddInventory = false; List<TemplateStagePO> stageTemplateList = templateStageService.getStageByTemplateId(templateId); List<StagePO> stageList = new ArrayList<>(); List<Long> templateStageIdList = new ArrayList<>(); Map<Long, StagePO> stageMap = new HashMap<>(); for (TemplateStagePO templateStagePO : stageTemplateList) { templateStageIdList.add(templateStagePO.getTemplateStageId()); StagePO stagePO = new StagePO(); stagePO.setStageId(idWorker.nextId()); stagePO.setProjectNo(projectNo); stagePO.setProjectTitle(param.getProjectTitle()); stagePO.setStageTitle(templateStagePO.getStageTitle()); stagePO.setStageDesc(templateStagePO.getStageDesc()); stagePO.setStageIndex(templateStagePO.getTemplateStageIndex()); stagePO.setFormType(templateStagePO.getFormType()); stagePO.setCreateUser(param.getCreateUser()); stagePO.setUpdateUser(param.getUpdateUser()); stageList.add(stagePO); if (templateStagePO.getFormType().equals(FormTypeEnum.FORM_TT_INVENTORY.getCode())) { isAddInventory = true; } stageMap.put(templateStagePO.getTemplateStageId(), stagePO); } //2.保存项目阶段