package com.ozs.pm.service.impl; import java.math.BigDecimal; import java.text.DecimalFormat; import java.text.ParseException; import java.util.*; import java.util.stream.Collectors; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ozs.base.domain.*; import com.ozs.base.domain.vo.BaseExpertVo; import com.ozs.base.service.*; 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.entity.SysRole; import com.ozs.common.core.domain.entity.SysUser; import com.ozs.common.enums.*; import com.ozs.common.utils.DateUtils; import com.ozs.common.utils.RandomUtil; import com.ozs.common.utils.SecurityUtils; import com.ozs.common.utils.StringUtils; import com.ozs.common.utils.bean.BeanUtils; import com.ozs.home.domain.vo.HomeToDoQueryResVo; import com.ozs.plan.doman.vo.responseVo.PlanQuarterResponseVo; import com.ozs.plan.service.PlanYearsService; import com.ozs.pm.doman.*; import com.ozs.pm.doman.vo.requestVo.*; import com.ozs.pm.doman.vo.responseVo.*; import com.ozs.pm.mapper.PmDemandMapper; import com.ozs.pm.service.*; import com.ozs.system.domain.SysFileInfo; import com.ozs.system.domain.SysFileRef; import com.ozs.system.domain.vo.SysRegionVO; import com.ozs.system.domain.vo.responseVo.SysDeptResponseVo; import com.ozs.system.mapper.SysDeptMapper; import com.ozs.system.mapper.SysRoleMapper; import com.ozs.system.service.*; import io.swagger.models.auth.In; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; import org.springframework.util.ObjectUtils; /** * 采购需求Service业务层处理 * * @author ruoyi * @date 2023-01-16 */ @Service public class PmDemandServiceImpl extends ServiceImpl implements IPmDemandService { @Autowired private PmDemandMapper pmDemandMapper; @Autowired private ISysDeptService deptService; @Autowired private ISysDictDataService dictDataService; @Autowired private SysFileService fileService; @Autowired private SysFileRefService sysFileRefService; @Autowired private IPmFlowChartService iPmFlowChartService; @Autowired private PmReleaseAnnouncementService pmReleaseAnnouncementService; @Autowired private BaseExpertService baseExpertService; @Autowired private PmDemandExpertRefService pmDemandExpertRefService; @Autowired private PmBidOpeningService pmBidOpeningService; @Autowired private PmBookBuildingService pmBookBuildingService; @Autowired private PmBidWinningService pmBidWinningService; @Autowired private ISysDictTypeService iSysDictTypeService; @Autowired private PmBidFailureService pmBidFailureService; @Autowired private PmBidWinningOpeningRefService pmBidWinningOpeningRefService; @Autowired private PmContractInfoService pmContractInfoService; @Autowired private BaseAgencyService baseAgencyService; @Autowired private PmProjectConstructionService pmProjectConstructionService; @Autowired private BaseNoticeTypeService baseNoticeTypeService; @Autowired private BaseNoticeService baseNoticeService; @Autowired private PlanYearsService planYearsService; @Autowired private ISysRegionService iSysRegionService; @Autowired private SysRoleMapper sysRoleMapper; @Autowired private ISysUserService userService; @Autowired private SysDeptMapper deptMapper; /** * 查询采购需求 * * @param demandId 采购需求主键 * @return 采购需求 */ @Override public PmDemandResVo selectPmDemandByDemandId(Long demandId, String detailType) { PmDemand pmDemand = this.getById(demandId); if (pmDemand != null) { PmDemandResVo vo = new PmDemandResVo(); vo.setProjectName(pmDemand.getProjectName()); vo.setDemandId(demandId); if ("1".equals(detailType)) { //项目计划 BeanUtils.copyProperties(pmDemand, vo); SysDeptResponseVo sysDeptResponseVo = (SysDeptResponseVo) deptService.selectDeptById(vo.getPurchaseDeptId()).get("sysDept"); if (sysDeptResponseVo != null) { vo.setPurchaseDeptName(sysDeptResponseVo.getDeptName()); } String purchaseServicesName = dictDataService.selectDictLabel("purchase_services", vo.getPurchaseServices()); if (StringUtils.isNotEmpty(purchaseServicesName)) { vo.setPurchaseServicesName(purchaseServicesName); } //采购需求附件 List demandFileInfos = getSysFileInfoList(vo.getDemandId(), SysFileRefEnum.PM_DEMAND.getType()); if (!ObjectUtils.isEmpty(demandFileInfos)) { vo.setDemandFileInfos(demandFileInfos); } //项目类型 for (ProjectTypes value : ProjectTypes.values()) { if (vo.getProjectType() != null && vo.getProjectType().equals(value.getCode())) { vo.setProjectTypeName(value.getInfo()); break; } } //是否为超限额计划 for (IsExcess value : IsExcess.values()) { if (vo.getIsExcess() != null && vo.getIsExcess().equals(value.getCode())) { vo.setIsExcessName(value.getInfo()); break; } } //采购方式 for (PlanPurchaseMode value : PlanPurchaseMode.values()) { if (vo.getPurchaseMode() != null && vo.getPurchaseMode().equals(value.getCode())) { vo.setPurchaseModeName(value.getInfo()); break; } } //项目属性 for (ProjectAttribute value : ProjectAttribute.values()) { if (vo.getProjectAttr() != null && vo.getProjectAttr().equals(value.getCode())) { vo.setProjectAttrName(value.getInfo()); break; } } //预警状态 for (WarnStatus value : WarnStatus.values()) { if (vo.getWarnStatus() != null && vo.getWarnStatus().equals(value.getCode())) { vo.setWarnStatusName(value.getInfo()); break; } } //项目状态 for (PmProjectStatus value : PmProjectStatus.values()) { if (vo.getProjectStatus() != null && vo.getProjectStatus().equals(value.getCode())) { vo.setProjectStatusName(value.getInfo()); break; } } } else if ("2".equals(detailType)) { //需求建档 //采购需求审核文件 List auditFileInfos = getSysFileInfoList(vo.getDemandId(), SysFileRefEnum.PM_DEMAND_EXAMINE.getType()); if (!ObjectUtils.isEmpty(auditFileInfos)) { vo.setAuditFileInfos(auditFileInfos); } LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); lambdaQueryWrapper.eq(PmBookBuilding::getDemandId, demandId); PmBookBuilding pmBookBuilding = pmBookBuildingService.getOne(lambdaQueryWrapper); if (pmBookBuilding != null) { PmBookBuildingResVo responseVo = new PmBookBuildingResVo(); BeanUtils.copyProperties(pmBookBuilding, responseVo); List fileInfos = getSysFileInfoList(pmBookBuilding.getId(), SysFileRefEnum.PM_BOOK_BUILDING.getType()); if (!ObjectUtils.isEmpty(fileInfos)) { responseVo.setFileInfos(fileInfos); } vo.setPmBookBuildingResVo(responseVo); } } else if ("3".equals(detailType)) { //任务下达 //任务下达文件 List taskReleaseFileInfos = getSysFileInfoList(vo.getDemandId(), SysFileRefEnum.PM_TAST_RELEASE.getType()); if (!ObjectUtils.isEmpty(taskReleaseFileInfos)) { vo.setTaskReleaseFileInfos(taskReleaseFileInfos); } } else if ("4".equals(detailType)) { //中标信息 PmPurchaseExecutionResVo pmPurchaseExecutionResVo = new PmPurchaseExecutionResVo(); //代理商信息 BaseAgency baseAgency = this.baseAgencyService.getById(pmDemand.getAgencyId()); pmPurchaseExecutionResVo.setBaseAgency(baseAgency); //发布公告列表 LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); lambdaQueryWrapper.eq(PmReleaseAnnouncement::getDemandId, demandId); List pmReleaseAnnouncementList = this.pmReleaseAnnouncementService.list(lambdaQueryWrapper); if (!ObjectUtils.isEmpty(pmReleaseAnnouncementList)) { List pmReleaseAnnouncementResVoList = new ArrayList<>(); for (PmReleaseAnnouncement pmReleaseAnnouncement : pmReleaseAnnouncementList) { PmReleaseAnnouncementResVo pmReleaseAnnouncementResVo = new PmReleaseAnnouncementResVo(); BeanUtils.copyProperties(pmReleaseAnnouncement, pmReleaseAnnouncementResVo); List fileInfos = getSysFileInfoList(pmReleaseAnnouncement.getId(), SysFileRefEnum.PM_ANNOUNCEMENT_FILE.getType()); if (!ObjectUtils.isEmpty(fileInfos)) { pmReleaseAnnouncementResVo.setFileInfos(fileInfos); } pmReleaseAnnouncementResVoList.add(pmReleaseAnnouncementResVo); } pmPurchaseExecutionResVo.setPmReleaseAnnouncementResVoList(pmReleaseAnnouncementResVoList); } //专家信息列表 List pmBaseExpertResVoList = this.pmDemandExpertRefService.getPmBaseExpertResVoList(demandId); pmPurchaseExecutionResVo.setPmBaseExpertResVoList(pmBaseExpertResVoList); //开标信息列表 List pmBidOpeningResVoList = this.pmBidOpeningService.getPmBidOpeningResVoList(demandId); pmPurchaseExecutionResVo.setPmBidOpeningResVoList(pmBidOpeningResVoList); //中标信息列表 LambdaQueryWrapper lambdaQueryWrapper1 = new LambdaQueryWrapper<>(); lambdaQueryWrapper1.eq(PmBidWinning::getDemandId, demandId) .eq(PmBidWinning::getStatus, BidWinningStatus.NORMAL.getCode()); PmBidWinning pmBidWinning = this.pmBidWinningService.getOne(lambdaQueryWrapper1); if (!ObjectUtils.isEmpty(pmBidWinning)) { LambdaQueryWrapper lambdaQueryWrapper2 = new LambdaQueryWrapper<>(); lambdaQueryWrapper2.eq(PmBidWinningOpeningRef::getWinningId, pmBidWinning.getId()) .eq(PmBidWinningOpeningRef::getStatus, BidWinningStatus.NORMAL.getCode()); List pmBidWinningOpeningRefList = this.pmBidWinningOpeningRefService.list(lambdaQueryWrapper2); if (!ObjectUtils.isEmpty(pmBidWinningOpeningRefList)) { List pmBidWinningResVoList = new ArrayList<>(); for (PmBidWinningOpeningRef pmBidWinningOpeningRef : pmBidWinningOpeningRefList) { PmBidOpening pmBidOpening = this.pmBidOpeningService.getById(pmBidWinningOpeningRef.getOpeningId()); if (pmBidOpening != null) { PmBidWinningResVo pmBidWinningResVo = new PmBidWinningResVo(); BeanUtils.copyProperties(pmBidWinning, pmBidWinningResVo); pmBidWinningResVo.setBidWinningName(pmBidOpening.getBidderName()); List fileInfos = getSysFileInfoList(pmBidWinning.getId(), SysFileRefEnum.PM_BID_WINNING_FILE.getType()); if (!ObjectUtils.isEmpty(fileInfos)) { pmBidWinningResVo.setFileInfos(fileInfos); } pmBidWinningResVoList.add(pmBidWinningResVo); } } pmPurchaseExecutionResVo.setPmBidWinningResVoList(pmBidWinningResVoList); } } pmPurchaseExecutionResVo.setCallQuestion(pmDemand.getCallQuestion()); //质疑情况 List callRequestFileInfos = getSysFileInfoList(vo.getDemandId(), SysFileRefEnum.PM_BID_CALL_QEUSTION_FILE.getType()); if (!ObjectUtils.isEmpty(callRequestFileInfos)) { pmPurchaseExecutionResVo.setCallRequestFileInfos(callRequestFileInfos); } //流标情况 LambdaQueryWrapper lambdaQueryWrapper2 = new LambdaQueryWrapper<>(); lambdaQueryWrapper2.eq(PmBidFailure::getDemandId, demandId).orderByDesc(PmBidFailure::getBidFailureTime); List pmBidFailureList = this.pmBidFailureService.list(lambdaQueryWrapper2); if (!ObjectUtils.isEmpty(pmBidFailureList)) { List pmBidFailureResVoList = new ArrayList<>(); for (PmBidFailure pmBidFailure : pmBidFailureList) { PmBidFailureResVo pmBidFailureResVo = new PmBidFailureResVo(); BeanUtils.copyProperties(pmBidFailure, pmBidFailureResVo); List fileInfos = getSysFileInfoList(pmBidFailure.getId(), SysFileRefEnum.PM_BID_FAILURE_FILE.getType()); if (!ObjectUtils.isEmpty(fileInfos)) { pmPurchaseExecutionResVo.setFileInfos(fileInfos); } pmBidFailureResVoList.add(pmBidFailureResVo); } pmPurchaseExecutionResVo.setPmBidFailureResVoList(pmBidFailureResVoList); } //中标通知书 List pmBidWinningNotificationFileInfos = getSysFileInfoList(vo.getDemandId(), SysFileRefEnum.PM_BID_WINNING_NOTIFICATION.getType()); if (!ObjectUtils.isEmpty(pmBidWinningNotificationFileInfos)) { pmPurchaseExecutionResVo.setPmBidWinningNotificationFileInfos(pmBidWinningNotificationFileInfos); } vo.setPmPurchaseExecutionResVo(pmPurchaseExecutionResVo); } else if ("5".equals(detailType)) { //合同信息 LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); lambdaQueryWrapper.eq(PmContractInfo::getDemandId, demandId); PmContractInfo pmContractInfo = pmContractInfoService.getOne(lambdaQueryWrapper); if (pmContractInfo != null) { PmContractInfoResVo pmContractInfoResVo = new PmContractInfoResVo(); BeanUtils.copyProperties(pmContractInfo, pmContractInfoResVo); //合同信息文件 List fileInfos = getSysFileInfoList(pmContractInfo.getId(), SysFileRefEnum.PM_CONTRACT_INFO.getType()); if (!ObjectUtils.isEmpty(fileInfos)) { pmContractInfoResVo.setFileInfos(fileInfos); } vo.setPmContractInfoResVo(pmContractInfoResVo); } } else if ("6".equals(detailType)) { //建设情况 LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); lambdaQueryWrapper.eq(PmProjectConstruction::getDemandId, demandId); PmProjectConstruction pmProjectConstruction = pmProjectConstructionService.getOne(lambdaQueryWrapper); if (pmProjectConstruction != null) { PmProjectConstructionResVo pmProjectConstructionResVo = new PmProjectConstructionResVo(); BeanUtils.copyProperties(pmProjectConstruction, pmProjectConstructionResVo); //建设情况文件 List fileInfos = getSysFileInfoList(pmProjectConstruction.getId(), SysFileRefEnum.PM_PROJECT_CONSTRUCTION.getType()); if (!ObjectUtils.isEmpty(fileInfos)) { pmProjectConstructionResVo.setFileInfos(fileInfos); } vo.setPmProjectConstructionResVo(pmProjectConstructionResVo); } } return vo; } else { return null; } } /** * 查询采购需求列表 * * @param pmDemandReqVo * @return 采购需求 */ @Override public IPage selectPmDemandList(PmDemandReqVo pmDemandReqVo, int reqType) { LambdaQueryWrapper lw = new LambdaQueryWrapper<>(); /*******************权限代码***********************/ SysUser sysUser = userService.selectUserById(SecurityUtils.getUserId()); Long deptId = sysUser.getDeptId(); //获取登录用户的角色 List sysRoles = sysRoleMapper.selectRolePermissionByUserId(SecurityUtils.getUserId()); //获取属于求单位管理员的列表 List sysRoleList2 = sysRoles.stream().filter(tdto -> tdto.getRoleKey().equals(SysRoleKey.DEMAND_UNIT.getCode())).collect(Collectors.toList()); if (!ObjectUtils.isEmpty(sysRoleList2)) { //属于需求单位管理员 lw.apply("(purchase_dept_id = " + deptId + ")"); } else { //获取属于采购管理部门管理员 或 采购办管理员的列表 List sysRoleList = sysRoles.stream().filter(tdto -> (tdto.getRoleKey().equals(SysRoleKey.PURCHASING_MANAGEMENT.getCode()) || tdto.getRoleKey().equals(SysRoleKey.PROCUREMENT_OFFICE.getCode()))).collect(Collectors.toList()); if (!ObjectUtils.isEmpty(sysRoleList)) { //属于采购管理部门管理员 或 采购办管理员 //获取子部门列表 List sysDeptSubs = deptMapper.selectChildrenDeptById(sysUser.getDeptId()); String sysDeptSubStr = null; if (!ObjectUtils.isEmpty(sysDeptSubs)) { List sysDeptSubIds = sysDeptSubs.stream().map(SysDept::getDeptId).collect(Collectors.toList()) .stream().map(x -> x + "").collect(Collectors.toList()); sysDeptSubStr = String.join(",", sysDeptSubIds); } String condtionSql = null; if (ObjectUtils.isEmpty(sysDeptSubStr)) { condtionSql = "(purchase_dept_id = " + deptId + " AND is_excess = 0) "; } else { condtionSql = "((purchase_dept_id = " + deptId + " AND is_excess = 0) " + " OR (purchase_dept_id IN (" + sysDeptSubStr + ") AND is_excess = 1))"; } lw.apply(condtionSql); } } /*******************权限代码end***********************/ if (!StringUtils.isBlank(pmDemandReqVo.getProjectName())) { lw.like(PmDemand::getProjectName, "%" + pmDemandReqVo.getProjectName() + "%"); } if (!StringUtils.isBlank(pmDemandReqVo.getPurchaseServices())) { lw.eq(PmDemand::getPurchaseServices, pmDemandReqVo.getPurchaseServices()); } if (!ObjectUtils.isEmpty(pmDemandReqVo.getProjectStatus())) { lw.eq(PmDemand::getProjectStatus, pmDemandReqVo.getProjectStatus()); } if (!ObjectUtils.isEmpty(pmDemandReqVo.getWarnStatus())) { lw.eq(PmDemand::getWarnStatus, pmDemandReqVo.getWarnStatus()); } if (!ObjectUtils.isEmpty(pmDemandReqVo.getIsExcess())) { lw.eq(PmDemand::getIsExcess, pmDemandReqVo.getIsExcess()); } if (!StringUtils.isBlank(pmDemandReqVo.getBeginDate())) { lw.apply("(plan_demand_sub_time >= '" + pmDemandReqVo.getBeginDate() + "' or plan_purchase_finish_time >= '" + pmDemandReqVo.getBeginDate() + "' or plan_deliver_time >= '" + pmDemandReqVo.getBeginDate() + "' )"); } if (!StringUtils.isBlank(pmDemandReqVo.getEndDate())) { lw.apply("(plan_demand_sub_time <= '" + pmDemandReqVo.getEndDate() + "' or plan_purchase_finish_time <= '" + pmDemandReqVo.getEndDate() + "' or plan_deliver_time <= '" + pmDemandReqVo.getEndDate() + "' )"); } if (reqType == 1) { //需求审核单位列表 lw.apply("(project_status = 6 or project_status = 8 )"); } else if (reqType == 2) { //任务下达列表 lw.apply("(project_status = 8 or project_status = 9 )"); } else if (reqType == 3) { //采购执行列表 lw.apply("(project_status = 9 or project_status = 10 or project_status = 11 or project_status = 12 or project_status = 13 or project_status = 14 or project_status = 15)"); } else if (reqType == 4) { //合同信息列表 lw.apply("(project_status = 15 or project_status = 16 )"); } else if (reqType == 5) { //项目建设列表 lw.apply("(project_status = 16 or project_status = 17 )"); } lw.last(" order by project_status, plan_demand_sub_time"); IPage pageRes = this.page(new Page<>(pmDemandReqVo.getPageNum(), pmDemandReqVo.getPageSize()), lw); IPage results = new Page<>(pageRes.getCurrent(), pageRes.getSize(), pageRes.getTotal()); if (pageRes.getRecords() != null && pageRes.getRecords().size() > 0) { List pmDemandResVos = demandChangeTo(pageRes.getRecords()); results.setRecords(pmDemandResVos); } return results; } /** * 需求建档 * * @param vo 采购需求 * @return 结果 */ @Override @Transactional(rollbackFor = Exception.class) public boolean bookBuilding(PmBookBuildingReqVo vo) throws Exception { PmDemand pmDemand = this.getById(vo.getDemandId()); LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); lambdaQueryWrapper.eq(PmBookBuilding::getDemandId, vo.getDemandId()); PmBookBuilding pmBookBuilding = pmBookBuildingService.getOne(lambdaQueryWrapper); if (pmBookBuilding != null) { vo.setId(pmBookBuilding.getId()); BeanUtils.copyProperties(vo, pmBookBuilding); pmBookBuilding.setUpdateBy(vo.getUpdateBy()); pmBookBuilding.setUpdateTime(new Date()); } else { pmBookBuilding = new PmBookBuilding(); BeanUtils.copyProperties(vo, pmBookBuilding); pmBookBuilding.setCreateBy(vo.getUpdateBy()); pmBookBuilding.setCreateTime(new Date()); pmBookBuilding.setUpdateBy(vo.getUpdateBy()); pmBookBuilding.setUpdateTime(pmBookBuilding.getCreateTime()); } if (pmBookBuildingService.saveOrUpdate(pmBookBuilding)) { List sysFileRefs = vo.getSysFileRefs(); uploadFile(pmBookBuilding.getId(), SysFileRefEnum.PM_BOOK_BUILDING.getType(), sysFileRefs, vo.getUpdateBy()); pmDemand.setProjectStatus(PmProjectStatus.DEMAND_WAIT_COMMIT.getCode()); pmDemand.setUpdateBy(vo.getUpdateBy()); pmDemand.setUpdateTime(DateUtils.getNowDate()); return this.updateById(pmDemand); } else { return false; } } private List getSysFileInfoList(Long redId, Integer type) { HashMap map = new HashMap<>(); map.put("red_id", redId); map.put("type", type); List fileRefs = sysFileRefService.listByMap(map); if (!ObjectUtils.isEmpty(fileRefs)) { List fileInfos = new ArrayList<>(); for (SysFileRef ref : fileRefs) { SysFileInfo fileInfo = fileService.getById(ref.getFileId()); fileInfos.add(fileInfo); } return fileInfos; } else { return null; } } /** * 查看流程图 * * @param demandId 采购需求主键 * @return 采购需求 */ @Override public Object viewFlowChart(Long demandId) { PmDemand pmDemand = this.getById(demandId); String projectStatus = String.valueOf(pmDemand.getProjectStatus()); String moduleName = null; if (PmProjectStatus.DEMAND_WAIT_FILL.getCode().equals(projectStatus) || PmProjectStatus.DEMAND_AUDIT_RETURN.getCode().equals(projectStatus)) { moduleName = "需求填制"; } else if (PmProjectStatus.DEMAND_WAIT_COMMIT.getCode().equals(projectStatus)) { moduleName = "需求提交"; } else if (PmProjectStatus.DEMAND_WAIT_AUDIT.getCode().equals(projectStatus)) { moduleName = "需求审核"; } else if (PmProjectStatus.TASK_WAIT_RELEASE.getCode().equals(projectStatus)) { moduleName = "任务下达"; } else if (PmProjectStatus.WAIT_SELECT_AGENT.getCode().equals(projectStatus)) { moduleName = "选取代理"; } else if (PmProjectStatus.WAIT_UPLOAD_BID_FILE.getCode().equals(projectStatus)) { moduleName = "上传招标文件"; } else if (PmProjectStatus.WAIT_ANNOUNCEMENT.getCode().equals(projectStatus)) { moduleName = "发布公告"; } else if (PmProjectStatus.WAIT_OPEN_BID.getCode().equals(projectStatus)) { moduleName = "填写专家信息,填写开标信息"; } else if (PmProjectStatus.WAIT_BID_ANNOUNCEMENT.getCode().equals(projectStatus)) { moduleName = "填写中标信息"; } else if (PmProjectStatus.BIDDING_PUBLICITY.getCode().equals(projectStatus)) { moduleName = "质疑处理,上传中标通知书"; } else if (PmProjectStatus.CONTRACT_WAIT_FILL.getCode().equals(projectStatus)) { moduleName = "合同填制"; } else if (PmProjectStatus.UNDER_CONSTRUCTION.getCode().equals(projectStatus)) { moduleName = "建设文档填制"; } else if (PmProjectStatus.COMPLETION_CONSTRUCTION.getCode().equals(projectStatus)) { moduleName = "项目归档"; } return moduleName; } @Override public PmFlowChartResVo getModuleInfo(Long demandId, String moduleName) { LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); lambdaQueryWrapper.eq(PmFlowChart::getModuleName, moduleName); PmFlowChart pmFlowChart = iPmFlowChartService.getOne(lambdaQueryWrapper); if (pmFlowChart == null) { return null; } PmFlowChartResVo vo = new PmFlowChartResVo(); BeanUtils.copyProperties(pmFlowChart, vo); if ("需求填制".equals(moduleName)) { List fileInfos = getSysFileInfoList(demandId, SysFileRefEnum.PM_DEMAND.getType()); if (!ObjectUtils.isEmpty(fileInfos)) { vo.setFileInfos(fileInfos); } } else if ("需求提交".equals(moduleName)) { LambdaQueryWrapper pmBookBuildingLambdaQueryWrapper = new LambdaQueryWrapper<>(); pmBookBuildingLambdaQueryWrapper.eq(PmBookBuilding::getDemandId, demandId); PmBookBuilding pmBookBuilding = pmBookBuildingService.getOne(pmBookBuildingLambdaQueryWrapper); if (pmBookBuilding != null) { List fileInfos = getSysFileInfoList(pmBookBuilding.getId(), SysFileRefEnum.PM_BOOK_BUILDING.getType()); if (!ObjectUtils.isEmpty(fileInfos)) { vo.setFileInfos(fileInfos); } } } else if ("需求审核".equals(moduleName)) { List fileInfos = getSysFileInfoList(demandId, SysFileRefEnum.PM_DEMAND_EXAMINE.getType()); if (!ObjectUtils.isEmpty(fileInfos)) { vo.setFileInfos(fileInfos); } } else if ("任务下达".equals(moduleName)) { List fileInfos = getSysFileInfoList(demandId, SysFileRefEnum.PM_TAST_RELEASE.getType()); if (!ObjectUtils.isEmpty(fileInfos)) { vo.setFileInfos(fileInfos); } } else if ("选取代理".equals(moduleName)) { //do nothing } else if ("上传招标文件".equals(moduleName)) { List fileInfos = getSysFileInfoList(demandId, SysFileRefEnum.PM_BID_FILE.getType()); if (!ObjectUtils.isEmpty(fileInfos)) { vo.setFileInfos(fileInfos); } } else if ("发布公告".equals(moduleName)) { LambdaQueryWrapper pmReleaseAnnouncementLambdaQueryWrapper = new LambdaQueryWrapper<>(); pmReleaseAnnouncementLambdaQueryWrapper.eq(PmReleaseAnnouncement::getDemandId, demandId); List pmReleaseAnnouncementList = pmReleaseAnnouncementService.list(pmReleaseAnnouncementLambdaQueryWrapper); if (!ObjectUtils.isEmpty(pmReleaseAnnouncementList)) { List listAll = new ArrayList<>(); for (PmReleaseAnnouncement pmReleaseAnnouncement : pmReleaseAnnouncementList) { List fileInfos = getSysFileInfoList(pmReleaseAnnouncement.getId(), SysFileRefEnum.PM_ANNOUNCEMENT_FILE.getType()); if (!ObjectUtils.isEmpty(fileInfos)) { listAll.addAll(fileInfos); } } if (!ObjectUtils.isEmpty(listAll)) { vo.setFileInfos(listAll); } } } else if ("填写专家信息".equals(moduleName)) { //do nothing } else if ("填写开标信息".equals(moduleName)) { //do nothing } else if ("填写中标信息".equals(moduleName)) { List listAll = new ArrayList<>(); LambdaQueryWrapper pmBidWinningLambdaQueryWrapper = new LambdaQueryWrapper<>(); pmBidWinningLambdaQueryWrapper.eq(PmBidWinning::getDemandId, demandId); List pmBidWinningList = pmBidWinningService.list(pmBidWinningLambdaQueryWrapper); if (!ObjectUtils.isEmpty(pmBidWinningList)) { for (PmBidWinning pmBidWinning : pmBidWinningList) { List fileInfos = getSysFileInfoList(pmBidWinning.getId(), SysFileRefEnum.PM_BID_WINNING_FILE.getType()); if (!ObjectUtils.isEmpty(fileInfos)) { listAll.addAll(fileInfos); } } } LambdaQueryWrapper pmBidFailureLambdaQueryWrapper = new LambdaQueryWrapper<>(); pmBidFailureLambdaQueryWrapper.eq(PmBidFailure::getDemandId, demandId); List pmBidFailureList = pmBidFailureService.list(pmBidFailureLambdaQueryWrapper); if (!ObjectUtils.isEmpty(pmBidFailureService)) { for (PmBidFailure pmBidFailure : pmBidFailureList) { List fileInfos = getSysFileInfoList(pmBidFailure.getId(), SysFileRefEnum.PM_BID_FAILURE_FILE.getType()); if (!ObjectUtils.isEmpty(fileInfos)) { listAll.addAll(fileInfos); } } } if (!ObjectUtils.isEmpty(listAll)) { vo.setFileInfos(listAll); } } else if ("质疑处理".equals(moduleName)) { List fileInfos = getSysFileInfoList(demandId, SysFileRefEnum.PM_BID_CALL_QEUSTION_FILE.getType()); if (!ObjectUtils.isEmpty(fileInfos)) { vo.setFileInfos(fileInfos); } } else if ("上传中标通知书".equals(moduleName)) { List fileInfos = getSysFileInfoList(demandId, SysFileRefEnum.PM_BID_WINNING_NOTIFICATION.getType()); if (!ObjectUtils.isEmpty(fileInfos)) { vo.setFileInfos(fileInfos); } } else if ("合同填制".equals(moduleName)) { LambdaQueryWrapper pmContractInfoLambdaQueryWrapper = new LambdaQueryWrapper<>(); pmContractInfoLambdaQueryWrapper.eq(PmContractInfo::getDemandId, demandId); PmContractInfo pmContractInfo = pmContractInfoService.getOne(pmContractInfoLambdaQueryWrapper); if (pmContractInfo != null) { List fileInfos = getSysFileInfoList(pmContractInfo.getId(), SysFileRefEnum.PM_CONTRACT_INFO.getType()); if (!ObjectUtils.isEmpty(fileInfos)) { vo.setFileInfos(fileInfos); } } } else if ("建设文档填制".equals(moduleName)) { LambdaQueryWrapper pmProjectConstructionLambdaQueryWrapper = new LambdaQueryWrapper<>(); pmProjectConstructionLambdaQueryWrapper.eq(PmProjectConstruction::getDemandId, demandId); PmProjectConstruction pmProjectConstruction = pmProjectConstructionService.getOne(pmProjectConstructionLambdaQueryWrapper); if (pmProjectConstruction != null) { List fileInfos = getSysFileInfoList(pmProjectConstruction.getId(), SysFileRefEnum.PM_PROJECT_CONSTRUCTION.getType()); if (!ObjectUtils.isEmpty(fileInfos)) { vo.setFileInfos(fileInfos); } } } else if ("项目归档".equals(moduleName)) { //do nothing } return vo; } /** * 提交采购需求 * * @param pmDemandReqVo * @return 结果 */ @Override @Transactional(rollbackFor = Exception.class) public boolean commit(PmDemandReqVo pmDemandReqVo) { PmDemand pmDemand = new PmDemand(); pmDemand.setDemandId(pmDemandReqVo.getDemandId()); pmDemand.setProjectStatus(PmProjectStatus.DEMAND_WAIT_AUDIT.getCode()); pmDemand.setRealDemandCommitTime(DateUtils.getNowDate()); pmDemand.setUpdateBy(pmDemandReqVo.getUpdateBy()); pmDemand.setUpdateTime(DateUtils.getNowDate()); return this.updateById(pmDemand); } /** * 审核采购需求通过 * * @param pmDemandReqVo * @return 结果 */ @Override @Transactional(rollbackFor = Exception.class) public boolean reviewTo(PmDemandReqVo pmDemandReqVo) { PmDemand pmDemand = new PmDemand(); pmDemand.setDemandId(pmDemandReqVo.getDemandId()); pmDemand.setProjectStatus(PmProjectStatus.TASK_WAIT_RELEASE.getCode()); List sysFileRefs = pmDemandReqVo.getSysFileRefs(); uploadFile(pmDemandReqVo.getDemandId(), SysFileRefEnum.PM_DEMAND_EXAMINE.getType(), sysFileRefs, pmDemandReqVo.getUpdateBy()); pmDemand.setUpdateBy(pmDemandReqVo.getUpdateBy()); pmDemand.setUpdateTime(DateUtils.getNowDate()); pmDemand.setAuditTime(DateUtils.getNowDate()); return this.updateById(pmDemand); } /** * 审核采购需求退回 * * @param pmDemandReqVo * @return 结果 */ @Override @Transactional(rollbackFor = Exception.class) public boolean reviewReturn(PmDemandReqVo pmDemandReqVo) { UpdateWrapper updateWrapper = new UpdateWrapper<>(); updateWrapper.lambda().eq(PmDemand::getDemandId, pmDemandReqVo.getDemandId()) .set(PmDemand::getProjectStatus, PmProjectStatus.DEMAND_AUDIT_RETURN.getCode()) .set(PmDemand::getAdjustReason, pmDemandReqVo.getRefuseReason()) .set(PmDemand::getRealDemandCommitTime, null) .set(PmDemand::getUpdateBy, pmDemandReqVo.getUpdateBy()) .set(PmDemand::getUpdateTime, DateUtils.getNowDate()) .set(PmDemand::getAuditTime, DateUtils.getNowDate()); return this.update(updateWrapper); } /** * 下达任务 * * @param pmDemandReqVo * @return 结果 */ @Override @Transactional(rollbackFor = Exception.class) public boolean releaseTask(PmDemandReqVo pmDemandReqVo) { PmDemand pmDemand = new PmDemand(); pmDemand.setDemandId(pmDemandReqVo.getDemandId()); pmDemand.setProjectStatus(PmProjectStatus.WAIT_SELECT_AGENT.getCode()); List sysFileRefs = pmDemandReqVo.getSysFileRefs(); uploadFile(pmDemandReqVo.getDemandId(), SysFileRefEnum.PM_TAST_RELEASE.getType(), sysFileRefs, pmDemandReqVo.getUpdateBy()); pmDemand.setUpdateBy(pmDemandReqVo.getUpdateBy()); pmDemand.setUpdateTime(DateUtils.getNowDate()); pmDemand.setAuditTime(DateUtils.getNowDate()); return this.updateById(pmDemand); } @Override @Transactional(rollbackFor = Exception.class) public boolean uploadFile(Long redId, Integer fileType, List sysFileRefs, String upateBy) { if (!ObjectUtils.isEmpty(sysFileRefs)) { //删除老的 QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.lambda().eq(SysFileRef::getRedId, redId) .eq(SysFileRef::getType, fileType); List sysFileRefList = sysFileRefService.list(queryWrapper); if (!CollectionUtils.isEmpty(sysFileRefList)) { sysFileRefService.remove(queryWrapper); } //添加新的 for (SysFileRef ref : sysFileRefs) { if (ref.getFileId() == null) { continue; } ref.setRedId(redId); ref.setType(fileType); ref.setCreated(upateBy); ref.setCreateTime(new Date()); ref.setUpdated(upateBy); ref.setUpdateTime(ref.getCreateTime()); sysFileRefService.save(ref); } return true; } else { return false; } } @Override @Transactional(rollbackFor = Exception.class) public boolean insertPmReleaseAnnouncement(PmReleaseAnnouncementReqVo pmReleaseAnnouncementReqVo) throws Exception { PmDemand pmDemand = this.getById(pmReleaseAnnouncementReqVo.getDemandId()); if (ObjectUtils.isEmpty(pmDemand)) { throw new Exception("参数错误"); } if (ObjectUtils.isEmpty(pmReleaseAnnouncementReqVo.getSysFileRefs())) { throw new Exception("上传附件不能为空"); } PmReleaseAnnouncement pmReleaseAnnouncement = new PmReleaseAnnouncement(); BeanUtils.copyProperties(pmReleaseAnnouncementReqVo, pmReleaseAnnouncement); if (pmReleaseAnnouncementService.saveOrUpdate(pmReleaseAnnouncement)) { uploadFile(pmReleaseAnnouncement.getId(), SysFileRefEnum.PM_ANNOUNCEMENT_FILE.getType(), pmReleaseAnnouncementReqVo.getSysFileRefs(), pmReleaseAnnouncementReqVo.getUpdateBy()); PmDemand pmDemandUpdate = new PmDemand(); pmDemandUpdate.setDemandId(pmReleaseAnnouncementReqVo.getDemandId()); pmDemandUpdate.setProjectStatus(PmProjectStatus.WAIT_OPEN_BID.getCode()); pmDemandUpdate.setUpdateTime(pmReleaseAnnouncementReqVo.getUpdateTime()); pmDemandUpdate.setUpdateBy(pmReleaseAnnouncementReqVo.getUpdateBy()); if (this.updateById(pmDemandUpdate)) { //发布公告生成后，会默认将该数据同步到公告管理和首页中 BaseNotice baseNotice = new BaseNotice(); baseNotice.setName(pmDemand.getProjectName()); baseNotice.setTitle(pmDemand.getProjectName() + "招标公告"); LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); lambdaQueryWrapper.eq(BaseNoticeType::getName, "招标公告"); BaseNoticeType baseNoticeType = baseNoticeTypeService.getOne(lambdaQueryWrapper); if (baseNoticeType == null) { throw new Exception("招标公告 公告类型不存在"); } baseNotice.setType(baseNoticeType.getId()); baseNotice.setReleaseTime(pmReleaseAnnouncement.getReleaseTime()); return this.baseNoticeService.saveOrUpdate(baseNotice); } else { return false; } } else { return false; } } @Override @Transactional(rollbackFor = Exception.class) public boolean insertExpertBatch(PmBaseExpertFillReqVo pmBaseExpertFillReqVo) throws Exception { PmDemand pmDemand = this.getById(pmBaseExpertFillReqVo.getDemandId()); if (ObjectUtils.isEmpty(pmDemand)) { throw new Exception("参数错误"); } List baseExpertList = pmBaseExpertFillReqVo.getBaseExpertList(); if (ObjectUtils.isEmpty(baseExpertList)) { throw new Exception("参数错误"); } Date now = new Date(); for (BaseExpert baseExpert : baseExpertList) { if (NameListType.BLACK.getCode().equals(baseExpert.getStatus())) { throw new Exception("该专家(身份证号：" + baseExpert.getIdNumber() + "）属于黑名单"); } else { if (ObjectUtils.isEmpty(baseExpert.getStatus())) { baseExpert.setStatus(NameListType.WHITE.getCode()); } } if (ObjectUtils.isEmpty(baseExpert.getVarietyPurchase()) || !baseExpert.getVarietyPurchase().contains(pmDemand.getProjectType())) { throw new Exception("该专家(身份证号：" + baseExpert.getIdNumber() + "）所属采购品种和项目类型不匹配"); } if (ObjectUtils.isEmpty(baseExpert.getCreated())) { baseExpert.setCreated(pmBaseExpertFillReqVo.getCreateBy()); baseExpert.setCreateTime(now); } if (ObjectUtils.isEmpty(baseExpert.getUpdated())) { baseExpert.setUpdated(pmBaseExpertFillReqVo.getUpdateBy()); baseExpert.setUpdateTime(now); } if (baseExpertService.saveOrUpdate(baseExpert)) { LambdaQueryWrapper pmDemandExpertRefLambdaQueryWrapper = new LambdaQueryWrapper<>(); pmDemandExpertRefLambdaQueryWrapper.eq(PmDemandExpertRef::getDemandId, pmDemand.getDemandId()) .eq(PmDemandExpertRef::getExpertId, baseExpert.getId().longValue()) .eq(PmDemandExpertRef::getAccessTime, pmBaseExpertFillReqVo.getAccessTime()); PmDemandExpertRef pmDemandExpertRef = pmDemandExpertRefService.getOne(pmDemandExpertRefLambdaQueryWrapper); if (pmDemandExpertRef == null) { pmDemandExpertRef = new PmDemandExpertRef(); pmDemandExpertRef.setCreateBy(pmBaseExpertFillReqVo.getCreateBy()); pmDemandExpertRef.setCreateTime(now); } pmDemandExpertRef.setDemandId(pmDemand.getDemandId()); pmDemandExpertRef.setExpertId(baseExpert.getId().longValue()); pmDemandExpertRef.setAccessTime(DateUtils.parseDate(pmBaseExpertFillReqVo.getAccessTime())); pmDemandExpertRef.setUpdateBy(pmBaseExpertFillReqVo.getCreateBy()); pmDemandExpertRef.setUpdateTime(pmDemandExpertRef.getCreateTime()); pmDemandExpertRefService.saveOrUpdate(pmDemandExpertRef); } } return true; } @Override @Transactional(rollbackFor = Exception.class) public boolean extractExpertBatch(PmBaseExpertExtractReqVo pmBaseExpertExtractReqVo) throws Exception { Integer technicalExpertNumber = pmBaseExpertExtractReqVo.getTechnicalExpertNumber(); if (technicalExpertNumber == null) { technicalExpertNumber = 0; } Integer economicExpertNumber = pmBaseExpertExtractReqVo.getEconomicExpertNumber(); if (economicExpertNumber == null) { economicExpertNumber = 0; } Integer legalAffairsExpertNumber = pmBaseExpertExtractReqVo.getLegalAffairsExpertNumber(); if (legalAffairsExpertNumber == null) { legalAffairsExpertNumber = 0; } Integer spareExpertNumber = pmBaseExpertExtractReqVo.getSpareExpertNumber(); if (spareExpertNumber == null) { spareExpertNumber = 0; } String professional = pmBaseExpertExtractReqVo.getProfessional(); if (spareExpertNumber > 0 && ObjectUtils.isEmpty(professional)) { throw new Exception("抽取备用专家必须选择专家专业"); } PmDemand pmDemand = this.getById(pmBaseExpertExtractReqVo.getDemandId()); if (ObjectUtils.isEmpty(pmDemand)) { throw new Exception("参数错误"); } String needAvoidUnit = pmBaseExpertExtractReqVo.getNeedAvoidUnit(); List needAvoidUnitList = null; if (!ObjectUtils.isEmpty(needAvoidUnit)) { String[] arr = needAvoidUnit.split(","); needAvoidUnitList = Arrays.asList(arr); } String localArea = pmBaseExpertExtractReqVo.getLocalArea(); List sysRegionCodeList = new ArrayList<>(); if (!ObjectUtils.isEmpty(localArea)) { if (!StringUtils.isNumeric(localArea)) { throw new Exception("地域必须传数字代码"); } sysRegionCodeList.add(localArea); //找到该地域code对应的子列表 List sysRegionVOList = iSysRegionService.findChildDivisions(localArea); if (!ObjectUtils.isEmpty(sysRegionVOList)) { for (SysRegionVO vo : sysRegionVOList) { sysRegionCodeList.add(vo.getCode()); } } } //从专家库中查询符合项目类型的以及是白名单的全部列表 LambdaQueryWrapper lw = new LambdaQueryWrapper<>(); lw.eq(BaseExpert::getVarietyPurchase, pmDemand.getProjectType()) .eq(BaseExpert::getStatus, NameListType.WHITE.getCode()) .notIn(!ObjectUtils.isEmpty(needAvoidUnitList), BaseExpert::getUnitInformation, needAvoidUnitList) .in(!ObjectUtils.isEmpty(sysRegionCodeList), BaseExpert::getLocalArea, sysRegionCodeList); List baseExpertList = baseExpertService.list(lw); if (ObjectUtils.isEmpty(baseExpertList)) { throw new Exception("没抽取到符合条件的专家"); } //从列表中挑出来各个类型的子列表 List technicalExpertList = new ArrayList<>(); List economicExpertList = new ArrayList<>(); List legalAffairsExpertList = new ArrayList<>(); List spareExpertList = new ArrayList<>(); for (BaseExpert baseExpert : baseExpertList) { if (technicalExpertNumber > 0) { if (baseExpert.getExpertType().contains(ExpertType.TECHNICAL_EXPERT.getCode())) { technicalExpertList.add(baseExpert); } } if (economicExpertNumber > 0) { if (baseExpert.getExpertType().contains(ExpertType.ECONOMIC_EXPERT.getCode())) { economicExpertList.add(baseExpert); } } if (legalAffairsExpertNumber > 0) { if (baseExpert.getExpertType().contains(ExpertType.LEGALAFFAIRS_EXPERT.getCode())) { legalAffairsExpertList.add(baseExpert); } } if (spareExpertNumber > 0) { String[] arr = professional.split(","); List professionalList = Arrays.asList(arr); String majorType = baseExpert.getMajorType(); if (!ObjectUtils.isEmpty(majorType)) { String[] arr2 = majorType.split(","); List majorTypeList = Arrays.asList(arr2); if (hasIntersection(professionalList, majorTypeList)) { spareExpertList.add(baseExpert); } } } } //从子列表中随机抽取符合数据量的 List alltExpertList = new ArrayList<>(); if (!ObjectUtils.isEmpty(technicalExpertList)) { alltExpertList.addAll(RandomUtil.getRandomList(technicalExpertList, technicalExpertNumber)); } if (!ObjectUtils.isEmpty(economicExpertList)) { alltExpertList.addAll(RandomUtil.getRandomList(economicExpertList, economicExpertNumber)); } if (!ObjectUtils.isEmpty(legalAffairsExpertList)) { alltExpertList.addAll(RandomUtil.getRandomList(legalAffairsExpertList, legalAffairsExpertNumber)); } if (!ObjectUtils.isEmpty(spareExpertList)) { alltExpertList.addAll(RandomUtil.getRandomList(spareExpertList, spareExpertNumber)); } if (ObjectUtils.isEmpty(alltExpertList)) { throw new Exception("没抽取到符合条件的专家"); } else { List pmDemandExpertRefList = new ArrayList<>(); for (BaseExpert baseExpert : alltExpertList) { LambdaQueryWrapper baseExpertLambdaQueryWrapper = new LambdaQueryWrapper<>(); baseExpertLambdaQueryWrapper.eq(PmDemandExpertRef::getExpertId, baseExpert.getId().longValue()) .eq(PmDemandExpertRef::getDemandId, pmDemand.getDemandId()) .eq(PmDemandExpertRef::getAccessTime, pmBaseExpertExtractReqVo.getAccessTime()); PmDemandExpertRef pmDemandExpertRef = pmDemandExpertRefService.getOne(baseExpertLambdaQueryWrapper); if (pmDemandExpertRef == null) { pmDemandExpertRef = new PmDemandExpertRef(); pmDemandExpertRef.setCreateBy(pmBaseExpertExtractReqVo.getCreateBy()); pmDemandExpertRef.setCreateTime(new Date()); } pmDemandExpertRef.setDemandId(pmDemand.getDemandId()); pmDemandExpertRef.setExpertId(baseExpert.getId().longValue()); pmDemandExpertRef.setAccessTime(DateUtils.parseDate(pmBaseExpertExtractReqVo.getAccessTime())); pmDemandExpertRef.setUpdateBy(pmBaseExpertExtractReqVo.getCreateBy()); pmDemandExpertRef.setUpdateTime(pmDemandExpertRef.getCreateTime()); pmDemandExpertRefList.add(pmDemandExpertRef); } return pmDemandExpertRefService.saveOrUpdateBatch(pmDemandExpertRefList); } } //二个列表是否有交集 private boolean hasIntersection(List professionalList, List majorTypeList) { for (String professiona : professionalList) { for (String majorType : majorTypeList) { if (professiona.equals(majorType)) { return true; } } } return false; } @Override @Transactional(rollbackFor = Exception.class) public boolean insertBidOpeningBatch(PmBidOpeningFillReqVo pmBidOpeningFillReqVo) throws Exception { PmDemand pmDemand = this.getById(pmBidOpeningFillReqVo.getDemandId()); if (ObjectUtils.isEmpty(pmDemand)) { throw new Exception("参数错误"); } //从发布公告里获取开标时间 LambdaQueryWrapper lw = new LambdaQueryWrapper<>(); lw.eq(PmReleaseAnnouncement::getDemandId, pmDemand.getDemandId()).orderByDesc(PmReleaseAnnouncement::getReleaseTime) .last(" limit 1 "); PmReleaseAnnouncement pmReleaseAnnouncement = this.pmReleaseAnnouncementService.getOne(lw); if (pmReleaseAnnouncement == null) { throw new Exception("发布公告不存在"); } Date tenderOpenTime = pmReleaseAnnouncement.getTenderOpenTime(); Date now = new Date(); List pmBidOpeningList = pmBidOpeningFillReqVo.getPmBidOpeningList(); for (PmBidOpening pmBidOpening : pmBidOpeningList) { if (ObjectUtils.isEmpty(pmBidOpening.getBidderName())) { throw new Exception("投标人名称不能为空"); } if (ObjectUtils.isEmpty(pmBidOpening.getScore())) { throw new Exception("分数不能为空"); } pmBidOpening.setOpenBidTime(tenderOpenTime); pmBidOpening.setDemandId(pmBidOpeningFillReqVo.getDemandId()); pmBidOpening.setCreateBy(pmBidOpeningFillReqVo.getCreateBy()); pmBidOpening.setCreateTime(now); pmBidOpening.setUpdateBy(pmBidOpeningFillReqVo.getUpdateBy()); pmBidOpening.setUpdateTime(now); } if (pmBidOpeningService.saveOrUpdateBatch(pmBidOpeningList)) { PmDemand pmDemandUpdate = new PmDemand(); pmDemandUpdate.setDemandId(pmDemand.getDemandId()); pmDemandUpdate.setProjectStatus(PmProjectStatus.WAIT_BID_ANNOUNCEMENT.getCode()); pmDemandUpdate.setUpdateTime(now); pmDemandUpdate.setUpdateBy(pmBidOpeningFillReqVo.getUpdateBy()); return this.updateById(pmDemandUpdate); } else { return false; } } /** * 填写中标 * * @param pmBidWinningReqVo * @return * @throws Exception */ @Override @Transactional(rollbackFor = Exception.class) public boolean insertPmBidWinning(PmBidWinningReqVo pmBidWinningReqVo) throws Exception { List pmBidOpeningIdList = pmBidWinningReqVo.getPmBidOpeningIdList(); if (ObjectUtils.isEmpty(pmBidWinningReqVo.getBidWinningAmount())) { throw new Exception("中标金额不能为空"); } if (ObjectUtils.isEmpty(pmBidOpeningIdList)) { throw new Exception("中标单位信息列表不能为空"); } if (ObjectUtils.isEmpty(pmBidWinningReqVo.getSysFileRefs())) { throw new Exception("上传附件不能为空"); } PmBidWinning pmBidWinning = new PmBidWinning(); BeanUtils.copyProperties(pmBidWinningReqVo, pmBidWinning); //修改老的中标信息状态 if (ObjectUtils.isEmpty(pmBidWinningReqVo.getId())) { //属于新增 LambdaQueryWrapper pmBidWinningLambdaQueryWrapper = new LambdaQueryWrapper<>(); pmBidWinningLambdaQueryWrapper.eq(PmBidWinning::getDemandId, pmBidWinningReqVo.getDemandId()) .eq(PmBidWinning::getStatus, BidWinningStatus.NORMAL.getCode()); List pmBidWinninglist = pmBidWinningService.list(pmBidWinningLambdaQueryWrapper); if (!ObjectUtils.isEmpty(pmBidWinninglist)) { for (PmBidWinning item : pmBidWinninglist) { UpdateWrapper updateWrapper1 = new UpdateWrapper<>(); updateWrapper1.lambda().set(PmBidWinning::getStatus, BidWinningStatus.BE_REPLACED.getCode()) .eq(PmBidWinning::getId, item.getId()); pmBidWinningService.update(updateWrapper1); UpdateWrapper updateWrapper2 = new UpdateWrapper<>(); updateWrapper2.lambda().set(PmBidWinningOpeningRef::getStatus, BidWinningStatus.BE_REPLACED.getCode()) .eq(PmBidWinningOpeningRef::getWinningId, item.getId()) .eq(PmBidWinningOpeningRef::getStatus, BidWinningStatus.NORMAL.getCode()); pmBidWinningOpeningRefService.update(updateWrapper2); } } } if (pmBidWinningService.saveOrUpdate(pmBidWinning)) { List pmBidWinningOpeningRefList = new ArrayList<>(); for (Long pmBidOpeningId : pmBidOpeningIdList) { LambdaQueryWrapper pmBidWinningOpeningRefLambdaQueryWrapper = new LambdaQueryWrapper<>(); pmBidWinningOpeningRefLambdaQueryWrapper.eq(PmBidWinningOpeningRef::getOpeningId, pmBidOpeningId) .eq(PmBidWinningOpeningRef::getWinningId, pmBidWinning.getId()); PmBidWinningOpeningRef pmBidWinningOpeningRef = pmBidWinningOpeningRefService.getOne(pmBidWinningOpeningRefLambdaQueryWrapper); if (pmBidWinningOpeningRef == null) { pmBidWinningOpeningRef = new PmBidWinningOpeningRef(); pmBidWinningOpeningRef.setCreateBy(pmBidWinningReqVo.getCreateBy()); pmBidWinningOpeningRef.setCreateTime(pmBidWinningReqVo.getCreateTime()); } pmBidWinningOpeningRef.setOpeningId(pmBidOpeningId); pmBidWinningOpeningRef.setWinningId(pmBidWinning.getId()); pmBidWinningOpeningRef.setUpdateBy(pmBidWinningReqVo.getUpdateBy()); pmBidWinningOpeningRef.setUpdateTime(pmBidWinningReqVo.getUpdateTime()); pmBidWinningOpeningRefList.add(pmBidWinningOpeningRef); } if (pmBidWinningOpeningRefService.saveOrUpdateBatch(pmBidWinningOpeningRefList)) { uploadFile(pmBidWinning.getId(), SysFileRefEnum.PM_BID_WINNING_FILE.getType(), pmBidWinningReqVo.getSysFileRefs(), pmBidWinningReqVo.getUpdateBy()); //发布公告生成后，会默认将该数据同步到公告管理和首页中 PmDemand pmDemand = this.getById(pmBidWinningReqVo.getDemandId()); BaseNotice baseNotice = new BaseNotice(); baseNotice.setName(pmDemand.getProjectName()); baseNotice.setTitle(pmDemand.getProjectName() + "中标公告"); LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); lambdaQueryWrapper.eq(BaseNoticeType::getName, "中标公告"); BaseNoticeType baseNoticeType = baseNoticeTypeService.getOne(lambdaQueryWrapper); if (baseNoticeType == null) { throw new Exception("中标公告 公告类型不存在"); } baseNotice.setType(baseNoticeType.getId()); baseNotice.setReleaseTime(pmBidWinningReqVo.getBidAnnouncementTime()); this.baseNoticeService.saveOrUpdate(baseNotice); PmDemand pmDemandUpdate = new PmDemand(); pmDemandUpdate.setDemandId(pmBidWinningReqVo.getDemandId()); pmDemandUpdate.setProjectStatus(PmProjectStatus.BIDDING_PUBLICITY.getCode()); pmDemandUpdate.setUpdateTime(pmBidWinningReqVo.getUpdateTime()); pmDemandUpdate.setUpdateBy(pmBidWinningReqVo.getUpdateBy()); return this.updateById(pmDemandUpdate); } else { return false; } } else { return false; } } @Override @Transactional(rollbackFor = Exception.class) public boolean updatePmBidWinning(PmBidWinningReqVo pmBidWinningReqVo) throws Exception { List pmBidOpeningIdList = pmBidWinningReqVo.getPmBidOpeningIdList(); if (ObjectUtils.isEmpty(pmBidOpeningIdList)) { throw new Exception("中标单位信息列表不能为空"); } if (ObjectUtils.isEmpty(pmBidWinningReqVo.getBidWinningAmount())) { throw new Exception("中标金额不能为空"); } if (ObjectUtils.isEmpty(pmBidWinningReqVo.getSysFileRefs())) { throw new Exception("上传附件不能为空"); } LambdaQueryWrapper lw = new LambdaQueryWrapper<>(); lw.eq(PmBidWinning::getDemandId, pmBidWinningReqVo.getDemandId()).eq(PmBidWinning::getStatus, BidWinningStatus.NORMAL.getCode()); List pmBidWinninglist = pmBidWinningService.list(lw); if (ObjectUtils.isEmpty(pmBidWinninglist)) { throw new Exception("原中标信息不存在"); } //修改老的状态 for (PmBidWinning item : pmBidWinninglist) { UpdateWrapper updateWrapper1 = new UpdateWrapper<>(); updateWrapper1.lambda().set(PmBidWinning::getStatus, BidWinningStatus.BE_REPLACED.getCode()) .eq(PmBidWinning::getId, item.getId()); pmBidWinningService.update(updateWrapper1); UpdateWrapper updateWrapper2 = new UpdateWrapper<>(); updateWrapper2.lambda().set(PmBidWinningOpeningRef::getStatus, BidWinningStatus.BE_REPLACED.getCode()) .eq(PmBidWinningOpeningRef::getWinningId, item.getId()) .eq(PmBidWinningOpeningRef::getStatus, BidWinningStatus.NORMAL.getCode()); pmBidWinningOpeningRefService.update(updateWrapper2); } //新增 PmBidWinning pmBidWinning = new PmBidWinning(); BeanUtils.copyProperties(pmBidWinninglist.get(0), pmBidWinning); pmBidWinning.setId(null); pmBidWinning.setBidWinningAmount(pmBidWinningReqVo.getBidWinningAmount()); pmBidWinning.setStatus(BidWinningStatus.NORMAL.getCode()); pmBidWinning.setUpdateBy(pmBidWinningReqVo.getUpdateBy()); pmBidWinning.setUpdateTime(pmBidWinningReqVo.getUpdateTime()); if (pmBidWinningService.save(pmBidWinning)) { List pmBidWinningOpeningRefList = new ArrayList<>(); for (Long pmBidOpeningId : pmBidOpeningIdList) { PmBidWinningOpeningRef pmBidWinningOpeningRef = new PmBidWinningOpeningRef(); pmBidWinningOpeningRef.setOpeningId(pmBidOpeningId); pmBidWinningOpeningRef.setWinningId(pmBidWinning.getId()); pmBidWinningOpeningRef.setStatus(BidWinningStatus.NORMAL.getCode()); pmBidWinningOpeningRef.setCreateBy(pmBidWinningReqVo.getCreateBy()); pmBidWinningOpeningRef.setCreateTime(pmBidWinningReqVo.getCreateTime()); pmBidWinningOpeningRef.setUpdateBy(pmBidWinningReqVo.getUpdateBy()); pmBidWinningOpeningRef.setUpdateTime(pmBidWinningReqVo.getUpdateTime()); pmBidWinningOpeningRefList.add(pmBidWinningOpeningRef); } LambdaQueryWrapper sysFileRefLambdaQueryWrapper = new LambdaQueryWrapper<>(); sysFileRefLambdaQueryWrapper.eq(SysFileRef::getType, SysFileRefEnum.PM_BID_WINNING_FILE.getType()) .eq(SysFileRef::getRedId, pmBidWinninglist.get(0)); List sysFileRefs = sysFileRefService.list(sysFileRefLambdaQueryWrapper); uploadFile(pmBidWinning.getId(), SysFileRefEnum.PM_BID_WINNING_FILE.getType(), sysFileRefs, pmBidWinningReqVo.getUpdateBy()); return pmBidWinningOpeningRefService.saveBatch(pmBidWinningOpeningRefList); } else { return false; } } /** * 流标 * * @param pmBidFailureReqVo * @return * @throws Exception */ @Override @Transactional(rollbackFor = Exception.class) public boolean insertPmBidFailure(PmBidFailureReqVo pmBidFailureReqVo) throws Exception { PmBidFailure pmBidFailure = new PmBidFailure(); BeanUtils.copyProperties(pmBidFailureReqVo, pmBidFailure); if (pmBidFailureService.saveOrUpdate(pmBidFailure)) { //把中标信息修改状态 LambdaQueryWrapper lw = new LambdaQueryWrapper<>(); lw.eq(PmBidWinning::getDemandId, pmBidFailureReqVo.getDemandId()).eq(PmBidWinning::getStatus, BidWinningStatus.NORMAL.getCode()); List pmBidWinninglist = pmBidWinningService.list(lw); if (!ObjectUtils.isEmpty(pmBidWinninglist)) { for (PmBidWinning item : pmBidWinninglist) { UpdateWrapper updateWrapper1 = new UpdateWrapper<>(); updateWrapper1.lambda().set(PmBidWinning::getStatus, BidWinningStatus.BE_BID_FAILURE.getCode()) .eq(PmBidWinning::getId, item.getId()); pmBidWinningService.update(updateWrapper1); UpdateWrapper updateWrapper2 = new UpdateWrapper<>(); updateWrapper2.lambda().set(PmBidWinningOpeningRef::getStatus, BidWinningStatus.BE_BID_FAILURE.getCode()) .eq(PmBidWinningOpeningRef::getWinningId, item.getId()) .eq(PmBidWinningOpeningRef::getStatus, BidWinningStatus.NORMAL.getCode()); pmBidWinningOpeningRefService.update(updateWrapper2); } } uploadFile(pmBidFailure.getId(), SysFileRefEnum.PM_BID_FAILURE_FILE.getType(), pmBidFailureReqVo.getSysFileRefs(), pmBidFailureReqVo.getUpdateBy()); //发布公告生成后，会默认将该数据同步到公告管理和首页中 PmDemand pmDemand = this.getById(pmBidFailureReqVo.getDemandId()); BaseNotice baseNotice = new BaseNotice(); baseNotice.setName(pmDemand.getProjectName()); baseNotice.setTitle(pmDemand.getProjectName() + "流标公告"); LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); lambdaQueryWrapper.eq(BaseNoticeType::getName, "流标公告"); BaseNoticeType baseNoticeType = baseNoticeTypeService.getOne(lambdaQueryWrapper); if (baseNoticeType == null) { throw new Exception("流标公告 公告类型不存在"); } baseNotice.setType(baseNoticeType.getId()); baseNotice.setReleaseTime(pmBidFailureReqVo.getBidFailureTime()); this.baseNoticeService.saveOrUpdate(baseNotice); PmDemand pmDemandUpdate = new PmDemand(); pmDemandUpdate.setDemandId(pmBidFailureReqVo.getDemandId()); pmDemandUpdate.setProjectStatus(PmProjectStatus.WAIT_ANNOUNCEMENT.getCode()); pmDemandUpdate.setUpdateTime(pmBidFailureReqVo.getUpdateTime()); pmDemandUpdate.setUpdateBy(pmBidFailureReqVo.getUpdateBy()); return this.updateById(pmDemandUpdate); } else { return false; } } @Override @Transactional(rollbackFor = Exception.class) public boolean insertContractInfo(PmContractInfoReqVo pmContractInfoReqVo) throws Exception { Long demandId = pmContractInfoReqVo.getDemandId(); if (ObjectUtils.isEmpty(demandId)) { throw new Exception("采购需求ID不能为空"); } PmDemand pmDemand = this.getById(demandId); if (ObjectUtils.isEmpty(pmDemand)) { throw new Exception("采购需求ID错误"); } List sysFileRefs = pmContractInfoReqVo.getSysFileRefs(); if (ObjectUtils.isEmpty(sysFileRefs)) { throw new Exception("上传附件不能为空"); } LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); lambdaQueryWrapper.eq(PmContractInfo::getDemandId, demandId); PmContractInfo pmContractInfo = pmContractInfoService.getOne(lambdaQueryWrapper); if (pmContractInfo != null) { pmContractInfoReqVo.setId(pmContractInfo.getId()); BeanUtils.copyProperties(pmContractInfoReqVo, pmContractInfo); pmContractInfo.setUpdateTime(pmContractInfoReqVo.getUpdateTime()); pmContractInfo.setUpdateBy(pmContractInfoReqVo.getUpdateBy()); } else { pmContractInfo = new PmContractInfo(); BeanUtils.copyProperties(pmContractInfoReqVo, pmContractInfo); pmContractInfo.setCreateBy(pmContractInfoReqVo.getCreateBy()); pmContractInfo.setCreateTime(pmContractInfoReqVo.getCreateTime()); pmContractInfo.setUpdateTime(pmContractInfoReqVo.getUpdateTime()); pmContractInfo.setUpdateBy(pmContractInfoReqVo.getUpdateBy()); } if (pmContractInfoService.saveOrUpdate(pmContractInfo)) { this.uploadFile(pmContractInfo.getId(), SysFileRefEnum.PM_CONTRACT_INFO.getType(), sysFileRefs, pmContractInfoReqVo.getUpdateBy()); PmDemand pmDemandUpdate = new PmDemand(); pmDemandUpdate.setDemandId(demandId); pmDemandUpdate.setProjectStatus(PmProjectStatus.UNDER_CONSTRUCTION.getCode()); pmDemandUpdate.setUpdateTime(pmContractInfoReqVo.getUpdateTime()); pmDemandUpdate.setUpdateBy(pmContractInfoReqVo.getUpdateBy()); return this.updateById(pmDemandUpdate); } else { return false; } } @Override @Transactional(rollbackFor = Exception.class) public boolean insertProjectConstruction(PmProjectConstructionReqVo pmProjectConstructionReqVo) throws Exception { Long demandId = pmProjectConstructionReqVo.getDemandId(); if (ObjectUtils.isEmpty(demandId)) { throw new Exception("采购需求ID不能为空"); } PmDemand pmDemand = this.getById(demandId); if (ObjectUtils.isEmpty(pmDemand)) { throw new Exception("采购需求ID错误"); } List sysFileRefs = pmProjectConstructionReqVo.getSysFileRefs(); if (ObjectUtils.isEmpty(sysFileRefs)) { throw new Exception("上传附件不能为空"); } LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); lambdaQueryWrapper.eq(PmProjectConstruction::getDemandId, demandId); PmProjectConstruction pmProjectConstruction = pmProjectConstructionService.getOne(lambdaQueryWrapper); if (pmProjectConstruction != null) { pmProjectConstructionReqVo.setId(pmProjectConstruction.getId()); BeanUtils.copyProperties(pmProjectConstructionReqVo, pmProjectConstruction); pmProjectConstruction.setUpdateBy(pmProjectConstructionReqVo.getUpdateBy()); pmProjectConstruction.setUpdateTime(pmProjectConstructionReqVo.getUpdateTime()); } else { pmProjectConstruction = new PmProjectConstruction(); BeanUtils.copyProperties(pmProjectConstructionReqVo, pmProjectConstruction); pmProjectConstruction.setCreateBy(pmProjectConstructionReqVo.getCreateBy()); pmProjectConstruction.setCreateTime(pmProjectConstructionReqVo.getCreateTime()); pmProjectConstruction.setUpdateBy(pmProjectConstructionReqVo.getUpdateBy()); pmProjectConstruction.setUpdateTime(pmProjectConstructionReqVo.getUpdateTime()); } if (pmProjectConstructionService.saveOrUpdate(pmProjectConstruction)) { this.uploadFile(pmProjectConstruction.getId(), SysFileRefEnum.PM_PROJECT_CONSTRUCTION.getType(), sysFileRefs, pmProjectConstructionReqVo.getUpdateBy()); PmDemand pmDemandUpdate = new PmDemand(); pmDemandUpdate.setDemandId(demandId); pmDemandUpdate.setProjectStatus(PmProjectStatus.COMPLETION_CONSTRUCTION.getCode()); pmDemandUpdate.setRealDeliverTime(pmProjectConstructionReqVo.getUpdateTime()); pmDemandUpdate.setUpdateTime(pmProjectConstructionReqVo.getUpdateTime()); pmDemandUpdate.setUpdateBy(pmProjectConstructionReqVo.getUpdateBy()); return this.updateById(pmDemandUpdate); } else { return false; } } /** * 更新需求预警状态 * * @param demnadId * @return */ @Override public void updateDemandWarnStatus(Long demnadId) { PmDemand pmDemand = this.getById(demnadId); List data = iSysDictTypeService.selectDictDataByType("alert_time_setting"); int setting1 = Integer.parseInt(data.stream().filter(item -> item.getDictLabel().equals("计划提报时间")).collect(Collectors.toList()).get(0).getDictValue()); //需求提报时间：根据数据阈值中设置的提报时间进行判断，进行预警 int diff1 = DateUtils.differentDaysByMillisecond(pmDemand.getPlanDemandSubTime(), DateUtils.parseDate(DateUtils.getDate())); if (ObjectUtils.isEmpty(pmDemand.getRealDemandCommitTime()) && diff1 >= setting1) { PmDemand pmDemandUpdate = new PmDemand(); pmDemandUpdate.setDemandId(demnadId); pmDemandUpdate.setWarnStatus(WarnStatus.DEMAND_COMMT_WARNING.getCode()); this.updateById(pmDemand); } } /** * 通过需求ID列表 查询采购执行列表 sunhh * * @param demandIdList * @return */ @Override public List selectByDemandIdList(List demandIdList) { return this.baseMapper.selectByDemandIdList(demandIdList); } /** * 专家库--查询抽取专家列表 非必传条件：专家名称，开始结束时间 sunhh * * @param baseExpertVo * @return */ @Override public List selectExtractionExpert(BaseExpertVo baseExpertVo) { return this.baseMapper.selectExtractionExpert(baseExpertVo); } @Override public List demandWaitCommit() { return getListByStatus(PmProjectStatus.DEMAND_WAIT_COMMIT.getCode()); } @Override public List contractWaitFilled() { return getListByStatus(PmProjectStatus.CONTRACT_WAIT_FILL.getCode()); } @Override public List projectWaitFinish() { return getListByStatus(PmProjectStatus.UNDER_CONSTRUCTION.getCode()); } @Override public List demandWaitExamine() { return getListByStatus(PmProjectStatus.DEMAND_WAIT_AUDIT.getCode()); } @Override public List taskWaitRelease() { return getListByStatus(PmProjectStatus.TASK_WAIT_RELEASE.getCode()); } @Override public List waitSelectAgent() { return getListByStatus(PmProjectStatus.WAIT_SELECT_AGENT.getCode()); } @Override public List waitUpBidFile() { return getListByStatus(PmProjectStatus.WAIT_UPLOAD_BID_FILE.getCode()); } @Override public List waitAnnouncement() { return getListByStatus(PmProjectStatus.WAIT_ANNOUNCEMENT.getCode()); } @Override public List waitOpenBid() { return getListByStatus(PmProjectStatus.WAIT_OPEN_BID.getCode()); } @Override public List waitBidAnnouncement() { return getListByStatus(PmProjectStatus.WAIT_BID_ANNOUNCEMENT.getCode()); } @Override public List biddingPublicity() { return getListByStatus(PmProjectStatus.BIDDING_PUBLICITY.getCode()); } @Override public AjaxResult procurementOfficeWillManipulateTotal() { List homeRes = new ArrayList<>(); // 待选取代理, 待上传招标文件, 待发布公告, 待开标, 待发布中标公告, 中标公示中 List demandRes = new ArrayList<>(); demandRes.addAll(getListByStatus(PmProjectStatus.WAIT_SELECT_AGENT.getCode())); demandRes.addAll(getListByStatus(PmProjectStatus.WAIT_UPLOAD_BID_FILE.getCode())); demandRes.addAll(getListByStatus(PmProjectStatus.WAIT_ANNOUNCEMENT.getCode())); demandRes.addAll(getListByStatus(PmProjectStatus.WAIT_OPEN_BID.getCode())); demandRes.addAll(getListByStatus(PmProjectStatus.WAIT_BID_ANNOUNCEMENT.getCode())); demandRes.addAll(getListByStatus(PmProjectStatus.BIDDING_PUBLICITY.getCode())); //计划数据--发函催告 List planRes = planYearsService.willSendLetter(); //转为首页table展示数据 if (!ObjectUtils.isEmpty(demandRes) && demandRes.size() > 0) { for (PmDemandResVo demandResVo : demandRes) { HomeToDoQueryResVo home = new HomeToDoQueryResVo(); home.setEvaluation(BigDecimal.valueOf(demandResVo.getEvaluation())); BeanUtils.copyProperties(demandResVo, home); homeRes.add(home); } } if (!ObjectUtils.isEmpty(planRes) && planRes.size() > 0) { for (PlanQuarterResponseVo planVo : planRes) { HomeToDoQueryResVo home = new HomeToDoQueryResVo(); BeanUtils.copyProperties(planVo, home); homeRes.add(home); } } return AjaxResult.success(homeRes); } /** * 统计分析-采购项目信息统计 * * @param pmDemandReqVo * @return */ @Override public Map purchaseProjectStatistical(PmDemandReqVo pmDemandReqVo) { Map mapReturn = new HashMap<>(); // 查询项目总数量 Map mapCount = pmDemandMapper.purchaseProjectStatistical(pmDemandReqVo); // 查询已完成项目数量，预算金额数量 Map mapYWC = pmDemandMapper.purchaseProjectStatisticalYWC(pmDemandReqVo); // 查询新创建项目数量，预算金额数量 Map mapXCJ = pmDemandMapper.purchaseProjectStatisticalXCJ(pmDemandReqVo); // 查询去年完成项目数量，预算金额数量 Map mapQNWC = pmDemandMapper.purchaseProjectStatisticalQNWC(pmDemandReqVo); mapReturn.putAll(mapCount); mapReturn.putAll(mapYWC); mapReturn.putAll(mapXCJ); mapReturn.putAll(mapQNWC); return mapReturn; } @Override public List countByProjectAttr() { List resVos = pmDemandMapper.countByProjectAttr(); for (StatisticalChartsResVo chartsResVo : resVos) { for (PmProjectStatus value : PmProjectStatus.values()) { if (value.getCode().equals(chartsResVo.getColumnName())) { chartsResVo.setColumnName(value.getInfo()); break; } } } return resVos; } @Override public List countByPurchaseMode() { List resVos = pmDemandMapper.countByPurchaseMode(); for (StatisticalChartsResVo chartsResVo : resVos) { for (ProcurementMethodSuggest value : ProcurementMethodSuggest.values()) { if (value.getCode().equals(chartsResVo.getColumnName())) { chartsResVo.setColumnName(value.getInfo()); break; } } } return resVos; } @Override public List countByEvaluation(PmDemandReqVo pmDemandReqVo) { List resVos = new ArrayList<>(); //概算金额包括：100万以下采购任务、100至500万元采购任务、500至1000万元采购任务、1000至5000万元采购任务、5000至1亿元采购任务、1亿元及以上采购任务 StatisticalChartsResVo resVo = pmDemandMapper.countByEvaluationLt(100); resVo.setColumnName("100万以下采购任务"); resVos.add(resVo); StatisticalChartsResVo resVo1 = pmDemandMapper.countByEvaluationBet(100, 500); resVo1.setColumnName("100至500万元采购任务"); resVos.add(resVo1); StatisticalChartsResVo resVo2 = pmDemandMapper.countByEvaluationBet(500, 1000); resVo2.setColumnName("500至1000万元采购任务"); resVos.add(resVo2); StatisticalChartsResVo resVo3 = pmDemandMapper.countByEvaluationBet(1000, 5000); resVo3.setColumnName("1000至5000万元采购任务"); resVos.add(resVo3); StatisticalChartsResVo resVo4 = pmDemandMapper.countByEvaluationBet(5000, 10000); resVo4.setColumnName("5000至1亿元采购任务"); resVos.add(resVo4); StatisticalChartsResVo resVo5 = pmDemandMapper.countByEvaluationGt(10000); resVo5.setColumnName("1亿元及以上采购任务"); resVos.add(resVo5); return resVos; } @Override public AjaxResult countProjectExceed(PmDemandReqVo pmDemandReqVo) { HashMap resMap = new HashMap<>(); //执行滞后采购项目：本年度所有的逾期项目数 //预算金额：本年度所有逾期项目累加的预算金额 StatisticalChartsResVo resVo = pmDemandMapper.countProjectExceed(); resMap.put("执行滞后采购项目", resVo.getNum()); resMap.put("预算金额", resVo.getEvaluationTotal()); //滞后项目数量占比：指本年度逾期项目数量/本年度所有项目数量 Integer thisYear = pmDemandMapper.countThisYear(); resMap.put("滞后项目数量占比", getPercent(Integer.parseInt(resVo.getNum()), thisYear)); return AjaxResult.success(resMap); } /** * 统计不同时间维度的逾期项目 * * @return */ @Override public AjaxResult exceedAnalysis(PmDemandReqVo pmDemandReqVo) { HashMap> resMap = new HashMap<>(); List byYear = pmDemandMapper.countProjectExceedYear(); if (pmDemandReqVo.getTimeType().equals("1")) { resMap.put("年", byYear); } else if (pmDemandReqVo.getTimeType().equals("2")) { List byQuarter = new LinkedList<>(); for (StatisticalChartsResVo chartsResVo : byYear) { for (int i = 1; i <= 4; i++) { StatisticalChartsResVo quarter = pmDemandMapper.countProjectExceedQuarter(i, Integer.parseInt(chartsResVo.getColumnName())); if (ObjectUtils.isEmpty(quarter)) { StatisticalChartsResVo vo = new StatisticalChartsResVo("", "0", "0"); quarter = vo; quarter.setColumnName(chartsResVo.getColumnName() + "年第" + i + "季度"); } quarter.setColumnName(chartsResVo.getColumnName() + "年第" + i + "季度"); byQuarter.add(quarter); } } resMap.put("季度", byQuarter); } else if (pmDemandReqVo.getTimeType().equals("3")) { List byMonth = new LinkedList<>(); for (StatisticalChartsResVo chartsResVo : byYear) { for (int i = 1; i <= 12; i++) { StatisticalChartsResVo month = pmDemandMapper.countProjectExceedMonth(i, Integer.parseInt(chartsResVo.getColumnName())); if (ObjectUtils.isEmpty(month)) { StatisticalChartsResVo vo = new StatisticalChartsResVo("", "0", "0"); month = vo; month.setColumnName(chartsResVo.getColumnName() + "年" + i + "月"); } month.setColumnName(chartsResVo.getColumnName() + "年" + i + "月"); byMonth.add(month); } } resMap.put("月", byMonth); } return AjaxResult.success(resMap); } @Override public AjaxResult taskQuantityAnalysis(PmDemandReqVo pmDemandReqVo) { HashMap> resMap = new HashMap<>(); //任务数量趋势分析：按照月、季度、年统计“项目属性”字段中“重大规划”属性的项目 List byYear = pmDemandMapper.countProjectMajorByYear(); if (pmDemandReqVo.getTimeType().equals("1")) { resMap.put("年", byYear); } else if (pmDemandReqVo.getTimeType().equals("2")) { List byQuarter = new LinkedList<>(); for (StatisticalChartsResVo chartsResVo : byYear) { for (int i = 1; i <= 4; i++) { StatisticalChartsResVo quarter = pmDemandMapper.countProjectMajorByQuarter(i, Integer.parseInt(chartsResVo.getColumnName())); quarter.setColumnName(chartsResVo.getColumnName() + "年第" + i + "季度"); byQuarter.add(quarter); } } resMap.put("季度", byQuarter); } else if (pmDemandReqVo.getTimeType().equals("3")) { List byMonth = pmDemandMapper.countProjectMajorByMonth(); resMap.put("月", byMonth); } return AjaxResult.success(resMap); } @Override public AjaxResult countEveryStatusNum(PmDemandReqVo pmDemandReqVo) { //指项目进行到各个阶段的数量 //阶段包括：待选取代理、待上传招标文件、待发布公告、待开标、待发布中标公告、中标公式中 List everyStatusNum = pmDemandMapper.countEveryStatusNum(); if (!ObjectUtils.isEmpty(everyStatusNum) && everyStatusNum.size() > 0) { for (StatisticalChartsResVo vo : everyStatusNum) { switch (vo.getColumnName()) { case "9": vo.setColumnName(PmProjectStatus.WAIT_SELECT_AGENT.getInfo()); case "10": vo.setColumnName(PmProjectStatus.WAIT_UPLOAD_BID_FILE.getInfo()); case "11": vo.setColumnName(PmProjectStatus.WAIT_ANNOUNCEMENT.getInfo()); case "12": vo.setColumnName(PmProjectStatus.WAIT_OPEN_BID.getInfo()); case "13": vo.setColumnName(PmProjectStatus.WAIT_BID_ANNOUNCEMENT.getInfo()); case "14": vo.setColumnName(PmProjectStatus.BIDDING_PUBLICITY.getInfo()); } } } return AjaxResult.success(everyStatusNum); } @Override public AjaxResult exceedMarketAnalysis(PmDemandReqVo pmDemandReqVo) { //所有滞后 List demandList = pmDemandMapper.countProjectExceedAll(); //滞后时长包括：滞后1个月以内的采购任务、滞后1至3个月采购任务、滞后3至6个月采购任务、滞后6个月至1年采购任务、滞后1年以上采购任务 HashMap map = new LinkedHashMap<>(); map.put("滞后1个月以内的采购任务", 0); map.put("滞后1至3个月采购任务", 0); map.put("滞后3至6个月采购任务", 0); map.put("滞后6个月至1年采购任务", 0); map.put("滞后1年以上采购任务", 0); if (!ObjectUtils.isEmpty(demandList) && demandList.size() > 0) { for (PmDemand demand : demandList) { //滞后时间 Long exTime = null; if (!ObjectUtils.isEmpty(demand.getRealDemandCommitTime()) && demand.getRealDemandCommitTime().getTime() - demand.getPlanDemandSubTime().getTime() > 0) { exTime = demand.getRealDemandCommitTime().getTime() - demand.getPlanDemandSubTime().getTime(); } else if (!ObjectUtils.isEmpty(demand.getRealPurchaseFinishTime()) && demand.getRealPurchaseFinishTime().getTime() - demand.getPlanPurchaseFinishTime().getTime() > 0) { exTime = demand.getRealPurchaseFinishTime().getTime() - demand.getPlanPurchaseFinishTime().getTime(); } else if (!ObjectUtils.isEmpty(demand.getRealDeliverTime()) && demand.getRealDeliverTime().getTime() - demand.getPlanDeliverTime().getTime() > 0) { exTime = demand.getRealDeliverTime().getTime() - demand.getPlanDeliverTime().getTime(); } if (exTime < Long.valueOf("2592000000")) { map.put("滞后1个月以内的采购任务", map.get("滞后1个月以内的采购任务") + 1); } if (exTime >= Long.valueOf("2592000000") && exTime < Long.valueOf("7776000000")) { map.put("滞后1至3个月采购任务", map.get("滞后1至3个月采购任务") + 1); } if (exTime >= Long.valueOf("7776000000") && exTime < Long.valueOf("15552000000")) { map.put("滞后3至6个月采购任务", map.get("滞后3至6个月采购任务") + 1); } if (exTime >= Long.valueOf("15552000000") && exTime < Long.valueOf("31104000000")) { map.put("滞后6个月至1年采购任务", map.get("滞后6个月至1年采购任务") + 1); } if (exTime > Long.valueOf("31104000000")) { map.put("滞后1年以上采购任务", map.get("滞后1年以上采购任务") + 1); } } } return AjaxResult.success(map); } @Override public AjaxResult countMajorProject(PmDemandReqVo pmDemandReqVo) { List resVos = new ArrayList<>(); //数量：指本年度状态为“项目建设完成”的项目属性为“重大规划”的项目数 //预算金额：指本年度状态为“项目建设完成”的项目属性为“重大规划”的项目累加的预算金额 StatisticalChartsResVo resVo = new StatisticalChartsResVo(); resVo = pmDemandMapper.majorProjectByStatus(PmProjectStatus.COMPLETION_CONSTRUCTION.getCode()); resVo.setColumnName("今年已完成数量"); resVos.add(resVo); //正常推进项目：指本年度正在进行中的项目属性为“重大规划”的项目数 //预算金额：指本年度正在进行中的项目属性为“重大规划”的项目累加的预算金额 StatisticalChartsResVo resVo1 = new StatisticalChartsResVo(); resVo1 = pmDemandMapper.majorProjectByStatus(PmProjectStatus.UNDER_CONSTRUCTION.getCode()); resVo1.setColumnName("正常推进数量"); resVos.add(resVo1); //执行滞后数量：指本年度逾期项目中，项目属性为“重大规划”的项目数 //预算金额：指本年度正在进行中的项目属性为“重大规划”的项目累加的预算金额 StatisticalChartsResVo resVo2 = new StatisticalChartsResVo(); resVo2 = pmDemandMapper.countMajorProjectExceed(); resVo2.setColumnName("执行滞后数量"); resVos.add(resVo2); //上年度重大规划采购任务数量：指上年度项目中，项目属性为“重大规划”的项目数 //预算金额：指上年度项目中，项目属性为“重大规划”的项目累加的预算金额 StatisticalChartsResVo resVo3 = new StatisticalChartsResVo(); resVo3 = pmDemandMapper.countMajorProjectLastYear(); resVo3.setColumnName("上年度重大规划采购任务数量"); resVos.add(resVo3); //resVo2=pmDemandMapper.majorProjectByStatus(PmProjectStatus.COMPLETION_CONSTRUCTION.getCode()); return AjaxResult.success(resVos); } /** * 通过计划ID查询项目数据 * * @param planId * @return */ @Override public PmDemand selectByPlanId(Integer planId) { return pmDemandMapper.selectByPlanId(planId); } /** * 采购项目--项目数量分析 * * @param pmDemandReqVo * @return */ @Override public Map purchaseProjectNumber(PmDemandReqVo pmDemandReqVo) { return null; } /** * 项目执行进度统计 * 1、正常推进项目数量：指未完成并且没有逾期的项目 * 预算金额：指未完成并且没有逾期的项目累加的预算金额 * 2、未完成采购任务：“合同待填制”状态之前的项目 * 预算金额：“合同待填制”状态之前的项目累加的预算金额 * * @param pmDemandReqVo * @return */ @Override public Map purchaseProjectExecute(PmDemandReqVo pmDemandReqVo) { Map mapReturn = new HashMap<>(); // 正常推进项目数量、预算金额 Map mapNormalPropulsion = pmDemandMapper.purchaseProjectExecuteNormalPropulsion(pmDemandReqVo); // 未完成采购任务，预算金额 Map mapIncomplete = pmDemandMapper.purchaseProjectExecuteIncomplete(pmDemandReqVo); mapReturn.putAll(mapNormalPropulsion); mapReturn.putAll(mapIncomplete); return mapReturn; } /** * 已完成项目数量统计 * * @param pmDemandReqVo * @return */ @Override public List> purchaseProjectCompleteNumber(PmDemandReqVo pmDemandReqVo) { List> mapReturn = new ArrayList<>(); // 统计时间类型 1：年度，2：季度，3：月份 if ("1".equals(pmDemandReqVo.getTimeType())) { // 查询数据库中最小的年份 int minYear = pmDemandMapper.selectMinYear(); // 获取当前年份 Calendar calendar = Calendar.getInstance(); int year = calendar.get(Calendar.YEAR); // 获取统计数据 List> listMap = pmDemandMapper.selectpurchaseProjectCompleteNumberYear(pmDemandReqVo); mapReturn.addAll(listMap); for (int i = minYear; i <= year; i++) { for (Map map : listMap) { if (i != Integer.valueOf(map.get("yy"))) { Map map1 = new HashMap<>(); map1.put("yy", i); map1.put("evaluation", 0); map1.put("contractAmount", 0); map1.put("countNum", 0); mapReturn.add(map1); } } } } else if ("2".equals(pmDemandReqVo.getTimeType())) { // 当前年份季度统计 // 获取统计数据 List> listMap = pmDemandMapper.selectpurchaseProjectCompleteNumberQuarter(pmDemandReqVo); mapReturn.addAll(listMap); for (int i = 1; i <= 4; i++) { for (Map map : listMap) { if (i != map.get("yy")) { Map map1 = new HashMap<>(); map1.put("yy", i); map1.put("evaluation", 0); map1.put("contractAmount", 0); map1.put("countNum", 0); mapReturn.add(map1); } } } } else if ("3".equals(pmDemandReqVo.getTimeType())) { // 当前年份月份统计 // 获取统计数据 List> listMap = pmDemandMapper.selectpurchaseProjectCompleteNumberMonth(pmDemandReqVo); mapReturn.addAll(listMap); for (int i = 1; i <= 12; i++) { for (Map map : listMap) { int ii = Integer.parseInt(String.valueOf(map.get("yy"))); map.put("yy", ii); if (i != ii) { Map map1 = new HashMap<>(); map1.put("yy", i); map1.put("evaluation", 0); map1.put("contractAmount", 0); map1.put("countNum", 0); mapReturn.add(map1); } } } } return mapReturn; } /** * 已完成采购任务数量统计 * * @param pmDemandReqVo * @return */ @Override public List> purchaseTaskFinish(PmDemandReqVo pmDemandReqVo) { List> mapReturn = new ArrayList<>(); // 统计时间类型 1：年度，2：季度，3：月份 if ("1".equals(pmDemandReqVo.getTimeType())) { // 查询数据库中最小的年份 int minYear = pmDemandMapper.selectMinYear(); // 获取当前年份 Calendar calendar = Calendar.getInstance(); int year = calendar.get(Calendar.YEAR); // 获取统计数据 List> listMap = pmDemandMapper.selectPurchaseTaskFinishYear(pmDemandReqVo); mapReturn.addAll(listMap); for (int i = minYear; i <= year; i++) { for (Map map : listMap) { if (i != Integer.valueOf(map.get("yy"))) { Map map1 = new HashMap<>(); map1.put("yy", i); map1.put("evaluation", 0); map1.put("contractAmount", 0); map1.put("countNum", 0); mapReturn.add(map1); } } } } else if ("2".equals(pmDemandReqVo.getTimeType())) { // 当前年份季度统计 // 获取统计数据 List> listMap = pmDemandMapper.selectPurchaseTaskFinishQuarter(pmDemandReqVo); mapReturn.addAll(listMap); for (int i = 1; i <= 4; i++) { for (Map map : listMap) { if (i != map.get("yy")) { Map map1 = new HashMap<>(); map1.put("yy", i); map1.put("evaluation", 0); map1.put("contractAmount", 0); map1.put("countNum", 0); mapReturn.add(map1); } } } } else if ("3".equals(pmDemandReqVo.getTimeType())) { // 当前年份月份统计 // 获取统计数据 List> listMap = pmDemandMapper.selectPurchaseTaskFinishMonth(pmDemandReqVo); mapReturn.addAll(listMap); for (int i = 1; i <= 12; i++) { for (Map map : listMap) { int ii = Integer.parseInt(String.valueOf(map.get("yy"))); map.put("yy", ii); if (i != ii) { Map map1 = new HashMap<>(); map1.put("yy", i); map1.put("evaluation", 0); map1.put("contractAmount", 0); map1.put("countNum", 0); mapReturn.add(map1); } } } } return mapReturn; } /** * 各阶段项目数量分布 * * @param pmDemandReqVo * @return */ @Override public List> purchaseProjectDistribution(PmDemandReqVo pmDemandReqVo) { // 项目计划 4之前（包括4） List xmjh = new ArrayList<>(); xmjh.add("4"); pmDemandReqVo.setProjectStatusList(xmjh); Map returnMapxmjh = pmDemandMapper.purchaseProjectDistribution(pmDemandReqVo); returnMapxmjh.put("name", "计划管理"); // 需求建党 4之后（不包括4） List xqjd = new ArrayList<>(); xqjd.add("5"); xqjd.add("6"); xqjd.add("7"); xqjd.add("8"); pmDemandReqVo.setProjectStatusList(xqjd); Map returnMapxqjd = pmDemandMapper.purchaseProjectDistribution(pmDemandReqVo); returnMapxqjd.put("name", "需求管理"); // 任务下达 8之后（不包括8） List rwxd = new ArrayList<>(); rwxd.add("9"); pmDemandReqVo.setProjectStatusList(rwxd); Map returnMaprwxd = pmDemandMapper.purchaseProjectDistribution(pmDemandReqVo); returnMaprwxd.put("name", "任务下达"); // 采购执行 9之后（不包括9） List cgzx = new ArrayList<>(); cgzx.add("10"); cgzx.add("11"); cgzx.add("12"); cgzx.add("13"); cgzx.add("14"); cgzx.add("15"); pmDemandReqVo.setProjectStatusList(cgzx); Map returnMapcgzx = pmDemandMapper.purchaseProjectDistribution(pmDemandReqVo); returnMapcgzx.put("name", "采购执行"); // 合同管理 15之后（不包括15） List htxx = new ArrayList<>(); htxx.add("16"); pmDemandReqVo.setProjectStatusList(htxx); Map returnMaphtxx = pmDemandMapper.purchaseProjectDistribution(pmDemandReqVo); returnMaphtxx.put("name", "合同管理"); // 项目建设 17 List xmjs = new ArrayList<>(); xmjs.add("16"); pmDemandReqVo.setProjectStatusList(xmjs); Map returnMapxmjs = pmDemandMapper.purchaseProjectDistribution(pmDemandReqVo); returnMapxmjs.put("name", "合同管理"); List> returnMap = new ArrayList<>(); returnMap.add(returnMapxmjh); returnMap.add(returnMapxqjd); returnMap.add(returnMaprwxd); returnMap.add(returnMapcgzx); returnMap.add(returnMaphtxx); returnMap.add(returnMapxmjs); return returnMap; } /** * 项目数量分析 * * @param pmDemandReqVo * @return */ @Override public List> purchaseProjectNumberAnalysis(PmDemandReqVo pmDemandReqVo) { List> mapReturn = new ArrayList<>(); // 统计时间类型 1：年度，2：季度，3：月份 if ("1".equals(pmDemandReqVo.getTimeType())) { // *** 年度的同比和环比不展示 *** // // 查询数据库中最小的年份 int minYear = pmDemandMapper.selectMinYear(); // 获取当前年份 Calendar calendar = Calendar.getInstance(); int year = calendar.get(Calendar.YEAR); // 获取统计数据 // 获取项目统计 List> listMap = pmDemandMapper.purchaseProjectNumberAnalysisYear(pmDemandReqVo); mapReturn.addAll(listMap); for (int i = minYear; i <= year; i++) { for (Map map : listMap) { if (i != Integer.valueOf(map.get("yy"))) { Map map1 = new HashMap<>(); map1.put("yy", i + ""); map1.put("countNum", 0 + ""); mapReturn.add(map1); } } } } else if ("2".equals(pmDemandReqVo.getTimeType())) { // 当前年份季度统计 // 获取统计数据 List> listMap = pmDemandMapper.purchaseProjectNumberAnalysisQuarter(pmDemandReqVo); mapReturn.addAll(listMap); for (int i = 1; i <= 4; i++) { for (Map map : listMap) { int ii = Integer.parseInt(String.valueOf(map.get("yy"))); map.put("yy", ii + ""); if (i != ii) { Map map1 = new HashMap<>(); map1.put("yy", i + ""); map1.put("countNum", 0 + ""); mapReturn.add(map1); } } } } else if ("3".equals(pmDemandReqVo.getTimeType())) { // 当前年份月份统计 // 获取统计数据 List> listMap = pmDemandMapper.purchaseProjectNumberAnalysisMonth(pmDemandReqVo); mapReturn.addAll(listMap); for (int i = 1; i <= 12; i++) { for (Map map : listMap) { int ii = Integer.parseInt(String.valueOf(map.get("yy"))); map.put("yy", ii + ""); if (i != ii) { Map map1 = new HashMap<>(); map1.put("yy", i + ""); map1.put("countNum", 0 + ""); mapReturn.add(map1); } } } } return mapReturn; } //查询不同状态下的项目数据 public List getListByStatus(String projectStatus) { LambdaQueryWrapper lw = new LambdaQueryWrapper(); lw.eq(PmDemand::getProjectStatus, projectStatus); List demandList = this.baseMapper.selectList(lw); //数据转换 List pmDemandResponseVoList = new ArrayList<>(); if (!ObjectUtils.isEmpty(demandList) && demandList.size() > 0) { pmDemandResponseVoList = demandChangeTo(demandList); } return pmDemandResponseVoList; } //字段转换and赋值 public List demandChangeTo(List pmDemandList) { List pmDemandResponseVoList = new ArrayList<>(); for (PmDemand pmDemand1 : pmDemandList) { PmDemandResVo vo = new PmDemandResVo(); BeanUtils.copyProperties(pmDemand1, vo); if (vo.getPurchaseDeptId() != null) { Map deptMap = deptService.selectDeptById(vo.getPurchaseDeptId()); if (deptMap != null) { SysDeptResponseVo sysDeptResponseVo = (SysDeptResponseVo) deptMap.get("sysDept"); if (sysDeptResponseVo != null) { vo.setPurchaseDeptName(sysDeptResponseVo.getDeptName()); } } } String purchaseServicesName = dictDataService.selectDictLabel("purchase_services", vo.getPurchaseServices()); if (StringUtils.isNotEmpty(purchaseServicesName)) { vo.setPurchaseServicesName(purchaseServicesName); } //项目类型 for (ProjectTypes value : ProjectTypes.values()) { if (vo.getProjectType() != null && vo.getProjectType().equals(value.getCode())) { vo.setProjectTypeName(value.getInfo()); break; } } //是否为超限额计划 for (IsExcess value : IsExcess.values()) { if (vo.getIsExcess() != null && vo.getIsExcess().equals(value.getCode())) { vo.setIsExcessName(value.getInfo()); break; } } //采购方式 for (PlanPurchaseMode value : PlanPurchaseMode.values()) { if (vo.getPurchaseMode() != null && vo.getPurchaseMode().equals(value.getCode())) { vo.setPurchaseModeName(value.getInfo()); break; } } //项目属性 for (ProjectAttribute value : ProjectAttribute.values()) { if (vo.getProjectAttr() != null && vo.getProjectAttr().equals(value.getCode())) { vo.setProjectAttrName(value.getInfo()); break; } } //预警状态 for (WarnStatus value : WarnStatus.values()) { if (vo.getWarnStatus() != null && vo.getWarnStatus().equals(value.getCode())) { vo.setWarnStatusName(value.getInfo()); break; } } //项目状态 for (PmProjectStatus value : PmProjectStatus.values()) { if (vo.getProjectStatus() != null && vo.getProjectStatus().equals(value.getCode())) { vo.setProjectStatusName(value.getInfo()); break; } } try { vo.setTipsMessage(pmDemandGetTips(vo.getPlanDeliverTime())); if (vo.getTipsMessage().contains("超过")) { vo.setIsExceedProject("1"); } } catch (ParseException e) { e.printStackTrace(); } pmDemandResponseVoList.add(vo); } return pmDemandResponseVoList; } /** * 根据年度计划提报时间的阈值进行提示 * * @return */ public String pmDemandGetTips(Date planDeliverTime) throws ParseException { if (!ObjectUtils.isEmpty(planDeliverTime)) { //提示信息：定义距离结束时间一周内提示 Integer remindTine = 1000 * 60 * 60 * 24 * 7; //少于一周便提醒 double surplus = planDeliverTime.getTime() - System.currentTimeMillis(); if (surplus < remindTine) { int i = new Double(Math.ceil(surplus / 1000 / 60 / 60 / 24)).intValue(); //剩余天数(向上取整) if (i > 0) { return "距离计划交付时间不足" + i + "天"; } else { return "已超过计划完成时间" + Math.abs(i) + "天"; } } } return ""; } /** * 计算百分比：使用java.text.DecimalFormat实现 * * @param x * @param y * @return */ public static String getPercent(int x, int y) { double d1 = x * 1.0; double d2 = y * 1.0; // 设置保留几位小数， “.”后面几个零就保留几位小数，这里设置保留2位小数 DecimalFormat decimalFormat = new DecimalFormat("##.00%"); return decimalFormat.format(d1 / d2); } }