package com.ozs.plan.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import com.ozs.common.core.domain.AjaxResult; import com.ozs.common.core.domain.entity.SysDept; import com.ozs.common.core.domain.entity.SysDictData; import com.ozs.common.core.domain.model.LoginUser; import com.ozs.common.enums.DataIsDelete; import com.ozs.common.enums.PmProjectStatus; import com.ozs.common.enums.ProjectStatus; import com.ozs.common.enums.ProjectTypes; import com.ozs.common.enums.SysFileRefEnum; import com.ozs.common.exception.ServiceException; import com.ozs.common.utils.PageUtils; import com.ozs.common.utils.StringUtils; import com.ozs.common.utils.bean.BeanUtils; import com.ozs.plan.doman.PlanQuarter; import com.ozs.plan.doman.PlanYears; import com.ozs.plan.doman.vo.requestVo.PlanQuarterStandardVo; import com.ozs.plan.doman.vo.responseVo.PlanQuarterResponseVo; import com.ozs.plan.mapper.PlanQuarterMapper; import com.ozs.plan.mapper.PlanYearsMapper; import com.ozs.plan.service.PlanQuarterService; import com.ozs.pm.doman.PmDemand; import com.ozs.pm.mapper.PmDemandMapper; import com.ozs.system.domain.SysFileInfo; import com.ozs.system.domain.SysFileRef; import com.ozs.system.domain.vo.responseVo.SysDeptResponseVo; import com.ozs.system.mapper.SysDeptMapper; import com.ozs.system.mapper.SysFileRefMapper; import com.ozs.system.service.ISysDeptService; import com.ozs.system.service.ISysDictTypeService; import com.ozs.system.service.SysFileService; 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.ObjectUtils; import javax.validation.Validator; import java.math.BigDecimal; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; /** * @author buzhanyi */ @Service @Slf4j public class PlanQuarterServiceImpl implements PlanQuarterService { @Autowired PlanQuarterMapper planQuarterMapper; @Autowired PlanYearsMapper planYearsMapper; @Autowired protected Validator validator; @Autowired private ISysDictTypeService dictTypeService; @Autowired private ISysDeptService deptService; @Autowired SysFileRefMapper sysFileRefMapper; @Autowired private SysDeptMapper deptMapper; @Autowired private SysFileService fileService; @Autowired private PmDemandMapper pmDemandMapper; @Override public Page selectPlanQuarterList(PlanQuarterStandardVo vo) { PlanQuarter quarters = new PlanQuarter(); List planQuarter; List planQuarterList = new ArrayList<>(); try { BeanUtils.copyProperties(vo, quarters); planQuarter = planQuarterMapper.selectPlanQuarterList(quarters); planQuarterList = changeTo(planQuarter); } catch (Exception e) { e.printStackTrace(); } Page pages = PageUtils.getPages(vo.getPageNum().intValue(), vo.getPageSize().intValue(), planQuarterList); return pages; } @Override public List selectPlanQuarterListEXP(PlanQuarterStandardVo vo) { List list = new ArrayList<>(); List planQuarterList = new ArrayList<>(); try { int num = 1; int size = 200; while (size == 200) { LambdaQueryWrapper lw = new LambdaQueryWrapper(); if (!ObjectUtils.isEmpty(vo.getProjectName())) { lw.like(PlanQuarter::getProjectName, vo.getProjectName()); } if (!ObjectUtils.isEmpty(vo.getPurchaseServices())) { lw.eq(PlanQuarter::getPurchaseServices, vo.getPurchaseServices()); } if (!ObjectUtils.isEmpty(vo.getIsExcess())) { lw.eq(PlanQuarter::getIsExcess, vo.getIsExcess()); } if (!ObjectUtils.isEmpty(vo.getProjectStatus())) { lw.eq(PlanQuarter::getProjectStatus, vo.getProjectStatus()); } if (!ObjectUtils.isEmpty(vo.getBeginTime())) { lw.ge(PlanQuarter::getPlanDemandSubTime, vo.getBeginTime()); } if (!ObjectUtils.isEmpty(vo.getEndTime())) { lw.le(PlanQuarter::getPlanDemandSubTime, vo.getEndTime()); } lw.eq(PlanQuarter::getDelFlay, DataIsDelete.DataNOTDelete); Page page = planQuarterMapper.selectPage(new Page(num, size, false), lw); list.addAll(page.getRecords()); size = page.getRecords().size(); num++; } planQuarterList = changeTo(list); } catch (Exception e) { e.printStackTrace(); } return planQuarterList; } @Override public Page selectPlanQuarterExamineList(PlanQuarterStandardVo vo) { PlanQuarter quarters = new PlanQuarter(); List planQuarter; List planQuarterList = new ArrayList<>(); try { BeanUtils.copyProperties(vo, quarters); planQuarter = planQuarterMapper.selectPlanQuarterExamineList(quarters); planQuarterList = changeTo(planQuarter); } catch (Exception e) { e.printStackTrace(); } Page pages = PageUtils.getPages(vo.getPageNum().intValue(), vo.getPageSize().intValue(), planQuarterList); return pages; } @Override public List selectPlanQuarterExamineListEXP(PlanQuarterStandardVo vo) { List list = new ArrayList<>(); List planQuarterList = new ArrayList<>(); try { int num = 1; int size = 200; while (size == 200) { LambdaQueryWrapper lw = new LambdaQueryWrapper(); if (!ObjectUtils.isEmpty(vo.getProjectName())) { lw.like(PlanQuarter::getProjectName, vo.getProjectName()); } if (!ObjectUtils.isEmpty(vo.getPurchaseServices())) { lw.eq(PlanQuarter::getPurchaseServices, vo.getPurchaseServices()); } if (!ObjectUtils.isEmpty(vo.getIsExcess())) { lw.eq(PlanQuarter::getIsExcess, vo.getIsExcess()); } if (!ObjectUtils.isEmpty(vo.getProjectStatus())) { lw.eq(PlanQuarter::getProjectStatus, vo.getProjectStatus()); } else { lw.in(PlanQuarter::getProjectStatus, "1,3"); } if (!ObjectUtils.isEmpty(vo.getBeginTime())) { lw.ge(PlanQuarter::getPlanDemandSubTime, vo.getBeginTime()); } if (!ObjectUtils.isEmpty(vo.getEndTime())) { lw.le(PlanQuarter::getPlanDemandSubTime, vo.getEndTime()); } lw.eq(PlanQuarter::getDelFlay, DataIsDelete.DataNOTDelete); Page page = planQuarterMapper.selectPage(new Page(num, size, false), lw); list.addAll(page.getRecords()); size = page.getRecords().size(); num++; } planQuarterList = changeTo(list); } catch (Exception e) { e.printStackTrace(); } return planQuarterList; } @Transactional @Override public AjaxResult insertPlanQuarter(PlanQuarterStandardVo quarterStandardVo) { if (planQuarterMapper.countProjectName(quarterStandardVo.getProjectName()) > 0) { return AjaxResult.error("该项目名称已经存在"); } PlanQuarter quarters = new PlanQuarter(); try { BeanUtils.copyProperties(quarterStandardVo, quarters); } catch (Exception e) { e.printStackTrace(); } //判断是否为超额计划 quarters.setIsExcess(isExcessOrNo(quarters.getProjectType(), quarters.getEvaluation())); quarters.setProjectStatus(ProjectStatus.PLANWAITCOMMIT.getCode()); quarters.setCreateTime(new Date()); planQuarterMapper.insertPlanQuarter(quarters); log.info("id:{}", quarters.getPlanPracticalId()); List sysFileRefs = quarterStandardVo.getSysFileRefs(); if (!ObjectUtils.isEmpty(sysFileRefs)) { for (SysFileRef ref : sysFileRefs) { ref.setRedId(quarters.getPlanPracticalId()); ref.setType(SysFileRefEnum.PLAN_TEMPORARY.getType()); ref.setCreated(quarters.getCreated()); ref.setCreateTime(new Date()); ref.setUpdated(quarters.getCreated()); ref.setUpdateTime(new Date()); sysFileRefMapper.insert(ref); } } return AjaxResult.success(); } @Override public AjaxResult deletePlanQuarterByIds(Long[] planIds) { planQuarterMapper.deletePlanQuarterByIds(planIds); return AjaxResult.success(); } @Override public AjaxResult deletePlanQuarterById(Long planId) { planQuarterMapper.deletePlanQuarterById(planId); return AjaxResult.success(); } @Override public AjaxResult view(PlanQuarterStandardVo quarterStandardVo) { PlanQuarterResponseVo responseVo = new PlanQuarterResponseVo(); PlanQuarter byId = planQuarterMapper.getById(quarterStandardVo.getPlanPracticalId()); if (byId == null) { return AjaxResult.error("数据查询失败"); } SysDeptResponseVo sysDeptResponseVo = (SysDeptResponseVo) deptService.selectDeptById(Long.valueOf(byId.getPurchaseDeptId())).get("sysDept"); byId.setPurchaseDeptName(sysDeptResponseVo.getDeptName()); HashMap map = new HashMap<>(); map.put("red_id", byId.getPlanPracticalId()); map.put("type", SysFileRefEnum.PLAN_TEMPORARY.getType()); List fileRefs = sysFileRefMapper.selectByMap(map); List fileInfos = new ArrayList<>(); BeanUtils.copyProperties(byId, responseVo); if (!ObjectUtils.isEmpty(fileRefs)) { for (SysFileRef ref : fileRefs) { SysFileInfo fileInfo = fileService.getById(ref.getFileId()); fileInfos.add(fileInfo); } responseVo.setFileInfos(fileInfos); } return AjaxResult.success(responseVo); } @Transactional @Override public AjaxResult update(PlanQuarterStandardVo quarterStandardVo) { if (planQuarterMapper.countProjectNameOther(quarterStandardVo.getProjectName(), String.valueOf(quarterStandardVo.getPlanPracticalId())) > 0) { return AjaxResult.error("该项目名称已经存在"); } PlanQuarter quarters = new PlanQuarter(); try { BeanUtils.copyProperties(quarterStandardVo, quarters); } catch (Exception e) { e.printStackTrace(); } quarters.setIsExcess(isExcessOrNo(quarters.getProjectType(), quarters.getEvaluation())); quarters.setUpdateTime(new Date()); planQuarterMapper.updateInfoById(quarters); List sysFileRefs = quarterStandardVo.getSysFileRefs(); HashMap map = new HashMap<>(); map.put("red_id", quarters.getPlanPracticalId()); map.put("type", SysFileRefEnum.PLAN_TEMPORARY.getType()); sysFileRefMapper.deleteByMap(map); if (!ObjectUtils.isEmpty(sysFileRefs)) { for (SysFileRef ref : sysFileRefs) { ref.setRedId(quarters.getPlanPracticalId()); ref.setType(SysFileRefEnum.PLAN_TEMPORARY.getType()); ref.setCreated(quarterStandardVo.getUpdated()); ref.setCreateTime(new Date()); ref.setUpdated(quarterStandardVo.getUpdated()); ref.setUpdateTime(new Date()); sysFileRefMapper.insert(ref); } } return AjaxResult.success(); } @Override public String importPlanQuarter(List planQuarters, boolean isUpdateSupport, LoginUser loginUser) { if (StringUtils.isNull(planQuarters) || planQuarters.size() == 0) { throw new ServiceException("导入季度计划数据不能为空!"); } List list = new ArrayList<>(); for (PlanQuarterStandardVo standardVo : planQuarters) { PlanQuarter quarter = new PlanQuarter(); BeanUtils.copyProperties(standardVo, quarter); quarter.setPurchaseDeptName(standardVo.getPurchaseDeptId()); list.add(quarter); } HashMap> planEnums = dictTypeService.getAboutEnums(); HashMap projectTypesMap = planEnums.get("projectTypes"); HashMap planPurchaseModesMap = planEnums.get("planPurchaseModes"); HashMap projectAttributes = planEnums.get("projectAttributes"); HashMap purchaseServices = planEnums.get("purchaseServices"); int successNum = 0; int failureNum = 0; StringBuilder successMsg = new StringBuilder(); StringBuilder failureMsg = new StringBuilder(); //deptService for (PlanQuarter ofYear : list) { try { //验证项目名称是否重复导入 //将录入信息中的值更改为要保存的数据 if (planQuarterMapper.countProjectName(ofYear.getProjectName()) == 0) { //采购单位 SysDept info = deptMapper.checkDeptNameOnlyOne(ofYear.getPurchaseDeptName()); if (!ObjectUtils.isEmpty(info)) { ofYear.setPurchaseDeptId(info.getDeptId()); } else { ++failureNum; failureMsg.append("*" + failureNum + "*采购单位“" + ofYear.getPurchaseDeptName() + "”不存在"); } ofYear.setProjectType(projectTypesMap.get(ofYear.getProjectType())); ofYear.setProjectStatus(ProjectStatus.PLANWAITCOMMIT.getCode()); ofYear.setPurchaseMode(planPurchaseModesMap.get(ofYear.getPurchaseMode())); //项目属性是多选字段 StringBuilder builder = new StringBuilder(); if (ofYear.getProjectAttr().contains(",")) { String[] split = ofYear.getProjectAttr().split(","); for (String s : split) { builder.append(projectAttributes.get(s) + ","); } } else { builder.append(projectAttributes.get(ofYear.getProjectAttr())); } ofYear.setProjectAttr(builder.toString()); ofYear.setPurchaseServices(purchaseServices.get(ofYear.getPurchaseServices())); ofYear.setIsExcess(isExcessOrNo(ofYear.getProjectType(), ofYear.getEvaluation())); ofYear.setCreated(String.valueOf(loginUser.getUserId())); ofYear.setCreateTime(new Date()); planQuarterMapper.insertPlanQuarter(ofYear); successNum++; successMsg.append("*" + successNum + "、项目 " + ofYear.getProjectName() + " 导入成功!"); //} else if (isUpdateSupport) { // PlanQuarter quarter = plan.get(0); // BeanValidators.validateWithException(validator, ofYear); // quarter.setCreateTime(new Date()); // quarter.setProjectStatus(ProjectStatus.PLANWAITCOMMIT.getCode()); // planQuarterMapper.updateById(quarter); // successNum++; // successMsg.append("
" + successNum + "、项目 " + ofYear.getProjectName() + " 更新成功"); } else { failureNum++; failureMsg.append(failureNum + "*项目 " + ofYear.getProjectName() + " 已存在!/n"); } } catch (Exception exc) { failureNum++; String msg = "*" + successNum + "*项目 " + ofYear.getProjectName() + " 导入失败"; failureMsg.append(msg + exc.getMessage()); log.error(msg, exc); } } if (failureNum > 0) { failureMsg.insert(0, "导入失败!共 " + failureNum + " 条数据格式不正确:"); throw new ServiceException(failureMsg.toString()); } else { successMsg.insert(0, "导入成功!共 " + successNum + " 条。"); } return successMsg.toString(); } @Override public AjaxResult commit(PlanQuarterStandardVo quarterStandardVo) { //PlanQuarter byId = PlanQuarterMapper.getById(quarterStandardVo.getPlanPracticalId()); //BigDecimal evaluation = byId.getEvaluation(); //BigDecimal threshold = new BigDecimal(0); ////获取各个项目类型设定的概算金额阈值 //List data = dictTypeService.selectDictDataByType("sys_over_limit_threshold"); //HashMap thresholdMap = new LinkedHashMap<>(); ////各个类型的概算金额阈值 //for (SysDictData dictData : data) { // // 类型----阈值 // thresholdMap.put(dictData.getDictLabel(), dictData.getDictValue()); //} ////项目类型 //for (ProjectTypes value : ProjectTypes.values()) { // if (byId.getProjectType().equals(value.getCode())) { // threshold = BigDecimal.valueOf(Long.parseLong(thresholdMap.get(value.getInfo()))); // } // break; //} // //if (evaluation.compareTo(threshold) == 1) { // //是超额项目 //} int commit = planQuarterMapper.commit(quarterStandardVo.getPlanPracticalId()); if (commit != 1) { return AjaxResult.error("项目状态数据异常"); } return AjaxResult.success(); } @Override @Transactional public AjaxResult reviewTo(PlanQuarterStandardVo vo) { //季度计划审核通过后同步到年度计划和项目管理 PlanQuarter quarters = new PlanQuarter(); PmDemand demand = new PmDemand(); PlanQuarter byId = planQuarterMapper.getById(vo.getPlanPracticalId()); if (ObjectUtils.isEmpty(byId.getPlanYearId())) { PlanYears ofYears = new PlanYears(); BeanUtils.copyProperties(byId, ofYears); ofYears.setProjectStatus(ProjectStatus.PLANTOEXAMINE.getCode()); planYearsMapper.insertPlanYears(ofYears); quarters.setPlanYearId(ofYears.getPlanYearId()); } BeanUtils.copyProperties(byId, demand); demand.setPlanId(byId.getPlanPracticalId()); //同步到项目管理状态为需求待填制 demand.setProjectStatus(Long.valueOf(PmProjectStatus.DEMAND_WAIT_FILL.getCode())); demand.setCreateTime(new Date()); pmDemandMapper.insert(demand); //计划附件也进行同步---查询年度计划附件后复制一份改为项目需求附件 LambdaQueryWrapper sysFileRefLp = new LambdaQueryWrapper<>(); sysFileRefLp.eq(SysFileRef::getType, SysFileRefEnum.PLAN_YEAR.getType()); sysFileRefLp.eq(SysFileRef::getRedId, vo.getPlanYearId()); List sysFileRefs = sysFileRefMapper.selectList(sysFileRefLp); if (!ObjectUtils.isEmpty(sysFileRefs)) { for (SysFileRef ref : sysFileRefs) { ref.setRedId(demand.getDemandId()); ref.setType(SysFileRefEnum.PM_DEMAND.getType()); sysFileRefMapper.insert(ref); } } vo.setProjectStatus(ProjectStatus.PLANTOEXAMINE.getCode()); return review(vo); } @Override @Transactional public AjaxResult reviewReturn(PlanQuarterStandardVo vo) { vo.setProjectStatus(ProjectStatus.PLANTOBACK.getCode()); return review(vo); } private AjaxResult review(PlanQuarterStandardVo vo) { List sysFileRefs = vo.getSysFileRefs(); if (!ObjectUtils.isEmpty(sysFileRefs)) { for (SysFileRef ref : sysFileRefs) { ref.setRedId(vo.getPlanPracticalId()); ref.setType(SysFileRefEnum.PLAN_TEMPORARY.getType()); ref.setCreated(vo.getUpdated()); ref.setCreateTime(new Date()); ref.setUpdated(vo.getUpdated()); ref.setUpdateTime(new Date()); sysFileRefMapper.insert(ref); } } int review = planQuarterMapper.review(vo); if (review != 1) { return AjaxResult.error("项目状态数据异常"); } return AjaxResult.success(); } @Override public AjaxResult appUpdate(PlanQuarterStandardVo vo) { //如果项目管理中数据已填制,则不允许申请修改 LambdaQueryWrapper demandLp = new LambdaQueryWrapper<>(); demandLp.eq(PmDemand::getPlanId, vo.getPlanPracticalId()); PmDemand demand = pmDemandMapper.selectOne(demandLp); if (!String.valueOf(demand.getProjectStatus()).equals(PmProjectStatus.DEMAND_WAIT_FILL.getCode())) { return AjaxResult.error("项目信息已填制,不可更改"); } //申请后会成为未提交的状态,可以进行修改 vo.setProjectStatus(ProjectStatus.PLANWAITCOMMIT.getCode()); int review = planQuarterMapper.review(vo); if (review != 1) { return AjaxResult.error("项目状态数据异常"); } return AjaxResult.success(); } @Override public AjaxResult sendLetter(PlanQuarterStandardVo quarterStandardVo) { int review = planQuarterMapper.sendLetter(quarterStandardVo.getPlanPracticalId()); if (review != 1) { return AjaxResult.error("项目状态数据异常"); } return AjaxResult.success(); } @Override public AjaxResult upLoadPlanFile(PlanQuarterStandardVo quarterStandardVo) { List sysFileRefs = quarterStandardVo.getSysFileRefs(); if (!ObjectUtils.isEmpty(sysFileRefs)) { for (SysFileRef ref : sysFileRefs) { ref.setRedId(quarterStandardVo.getPlanPracticalId()); ref.setType(SysFileRefEnum.PLAN_TEMPORARY.getType()); sysFileRefMapper.insert(ref); } } return AjaxResult.success(); } @Override public AjaxResult downLoadPlanFile(PlanQuarterStandardVo quarterStandardVo) { return AjaxResult.success(); } //判断是否为超额计划 public String isExcessOrNo(String projectType, BigDecimal evaluation) { BigDecimal threshold = new BigDecimal(0); //获取各个项目类型设定的概算金额阈值 List data = dictTypeService.selectDictDataByType("sys_over_limit_threshold"); HashMap thresholdMap = new LinkedHashMap<>(); //各个类型的概算金额阈值 for (SysDictData dictData : data) { // 类型----阈值 thresholdMap.put(dictData.getDictLabel(), dictData.getDictValue()); } //项目类型 for (ProjectTypes value : ProjectTypes.values()) { if (projectType.equals(value.getCode())) { threshold = BigDecimal.valueOf(Long.parseLong(thresholdMap.get(value.getInfo()))); } break; } if (evaluation.compareTo(threshold) == 1) { //是超额计划 return ("1"); } else { return ("0"); } } //字段赋值对应的名称 public List changeTo(List planQuarter) { HashMap> planEnums = dictTypeService.getAboutEnums(); HashMap projectTypesMap = planEnums.get("projectTypes"); HashMap planPurchaseModesMap = planEnums.get("planPurchaseModes"); HashMap projectAttributes = planEnums.get("projectAttributes"); HashMap purchaseServices = planEnums.get("purchaseServices"); List list = new ArrayList(); for (PlanQuarter planYear : planQuarter) { SysDeptResponseVo sysDeptResponseVo = (SysDeptResponseVo) deptService.selectDeptById(Long.valueOf(planYear.getPurchaseDeptId())).get("sysDept"); planYear.setPurchaseDeptName(sysDeptResponseVo.getDeptName()); for (Map.Entry entry : projectTypesMap.entrySet()) { if (planYear.getProjectType().equals(entry.getValue())) { planYear.setProjectTypeStr(entry.getKey()); break; } } for (Map.Entry entry : planPurchaseModesMap.entrySet()) { if (planYear.getPurchaseMode().equals(entry.getValue())) { planYear.setPurchaseModeStr(entry.getKey()); break; } } //项目属性是拼接的 if (!ObjectUtils.isEmpty(planYear.getProjectAttr())) { if (planYear.getProjectAttr().length() > 1) { StringBuilder builder = new StringBuilder(); String[] split = planYear.getProjectAttr().split(","); for (String s : split) { for (Map.Entry entry : projectAttributes.entrySet()) { if (s.equals(entry.getValue())) { builder.append(entry.getKey() + ","); break; } } } planYear.setProjectAttrStr(builder.toString()); } else { for (Map.Entry entry : projectAttributes.entrySet()) { if (planYear.getProjectAttr().equals(entry.getValue())) { planYear.setProjectAttrStr(entry.getKey()); break; } } } } for (Map.Entry entry : purchaseServices.entrySet()) { if (planYear.getPurchaseServices().equals(entry.getValue())) { planYear.setPurchaseServicesStr(entry.getKey()); break; } } list.add(planYear); } return list; } }