purchase/purchase-system/src/main/java/com/ozs/pm/service/impl/PmDemandServiceImpl.java

package com.ozs.pm.service.impl;

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.BaseAgency;
import com.ozs.base.domain.BaseExpert;
import com.ozs.base.domain.BaseNotice;
import com.ozs.base.domain.BaseNoticeType;
import com.ozs.base.domain.BaseUnitInformation;
import com.ozs.base.domain.vo.BaseExpertVo;
import com.ozs.base.mapper.BaseExpertMapper;
import com.ozs.base.service.BaseAgencyService;
import com.ozs.base.service.BaseExpertService;
import com.ozs.base.service.BaseNoticeService;
import com.ozs.base.service.BaseNoticeTypeService;
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.SysUser;
import com.ozs.common.core.domain.model.LoginUser;
import com.ozs.common.enums.BidWinningStatus;
import com.ozs.common.enums.ExpertType;
import com.ozs.common.enums.IsExcess;
import com.ozs.common.enums.NameListType;
import com.ozs.common.enums.PlanPurchaseMode;
import com.ozs.common.enums.PmProjectStatus;
import com.ozs.common.enums.ProcurementMethodSuggest;
import com.ozs.common.enums.ProjectAttribute;
import com.ozs.common.enums.ProjectTypes;
import com.ozs.common.enums.SysFileRefEnum;
import com.ozs.common.enums.WarnStatus;
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.ProvisionalPlan;
import com.ozs.plan.doman.vo.responseVo.PlanQuarterResponseVo;
import com.ozs.plan.mapper.ProvisionalPlanMapper;
import com.ozs.plan.service.PlanYearsService;
import com.ozs.pm.doman.PmAuditDeptRef;
import com.ozs.pm.doman.PmBidFailure;
import com.ozs.pm.doman.PmBidOpening;
import com.ozs.pm.doman.PmBidWinning;
import com.ozs.pm.doman.PmBidWinningOpeningRef;
import com.ozs.pm.doman.PmBookBuilding;
import com.ozs.pm.doman.PmCallQuestion;
import com.ozs.pm.doman.PmContractInfo;
import com.ozs.pm.doman.PmDemand;
import com.ozs.pm.doman.PmDemandExpertRef;
import com.ozs.pm.doman.PmExpertFeedback;
import com.ozs.pm.doman.PmProcurementDocumentsReview;
import com.ozs.pm.doman.PmProjectConstruction;
import com.ozs.pm.doman.PmReleaseAnnouncement;
import com.ozs.pm.doman.vo.requestVo.PmBaseExpertExtractReqVo;
import com.ozs.pm.doman.vo.requestVo.PmBaseExpertFillReqVo;
import com.ozs.pm.doman.vo.requestVo.PmBidFailureReqVo;
import com.ozs.pm.doman.vo.requestVo.PmBidOpeningFillReqVo;
import com.ozs.pm.doman.vo.requestVo.PmBidWinningReqVo;
import com.ozs.pm.doman.vo.requestVo.PmBookBuildingReqVo;
import com.ozs.pm.doman.vo.requestVo.PmContractInfoReqVo;
import com.ozs.pm.doman.vo.requestVo.PmDemandReqVo;
import com.ozs.pm.doman.vo.requestVo.PmProjectConstructionReqVo;
import com.ozs.pm.doman.vo.requestVo.PmReleaseAnnouncementReqVo;
import com.ozs.pm.doman.vo.responseVo.PmBaseExpertResVo;
import com.ozs.pm.doman.vo.responseVo.PmBidFailureResVo;
import com.ozs.pm.doman.vo.responseVo.PmBidOpeningResVo;
import com.ozs.pm.doman.vo.responseVo.PmBidWinningResVo;
import com.ozs.pm.doman.vo.responseVo.PmBookBuildingResVo;
import com.ozs.pm.doman.vo.responseVo.PmCallQuestionResVo;
import com.ozs.pm.doman.vo.responseVo.PmContractInfoResVo;
import com.ozs.pm.doman.vo.responseVo.PmDemandResVo;
import com.ozs.pm.doman.vo.responseVo.PmExpertFeedbackResVo;
import com.ozs.pm.doman.vo.responseVo.PmProcurementDocumentsReviewResVo;
import com.ozs.pm.doman.vo.responseVo.PmProjectConstructionResVo;
import com.ozs.pm.doman.vo.responseVo.PmPurchaseExecutionResVo;
import com.ozs.pm.doman.vo.responseVo.PmReleaseAnnouncementResVo;
import com.ozs.pm.doman.vo.responseVo.StatisticalChartsResVo;
import com.ozs.pm.mapper.PmDemandMapper;
import com.ozs.pm.service.IPmDemandService;
import com.ozs.pm.service.PmAuditDeptRefService;
import com.ozs.pm.service.PmBidFailureService;
import com.ozs.pm.service.PmBidOpeningService;
import com.ozs.pm.service.PmBidWinningOpeningRefService;
import com.ozs.pm.service.PmBidWinningService;
import com.ozs.pm.service.PmBookBuildingService;
import com.ozs.pm.service.PmCallQuestionHisService;
import com.ozs.pm.service.PmCallQuestionService;
import com.ozs.pm.service.PmContractInfoService;
import com.ozs.pm.service.PmDemandExpertRefService;
import com.ozs.pm.service.PmExpertFeedbackService;
import com.ozs.pm.service.PmProcurementDocumentsReviewService;
import com.ozs.pm.service.PmProjectConstructionService;
import com.ozs.pm.service.PmReleaseAnnouncementService;
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.SysFileRefMapper;
import com.ozs.system.service.ISysDeptService;
import com.ozs.system.service.ISysDictDataService;
import com.ozs.system.service.ISysDictTypeService;
import com.ozs.system.service.ISysRegionService;
import com.ozs.system.service.ISysUserService;
import com.ozs.system.service.SysFileRefService;
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 java.math.BigDecimal;
import java.text.DecimalFormat;
import java.text.ParseException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Calendar;
import java.util.Date;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;


/**
 * 采购需求Service业务层处理
 *
 * @author ruoyi
 * @date 2023-01-16
 */
@Service
@Slf4j
public class PmDemandServiceImpl extends ServiceImpl<PmDemandMapper, PmDemand> implements IPmDemandService {

    @Autowired
    private PmDemandMapper pmDemandMapper;
    @Autowired
    private ISysDeptService deptService;

    @Autowired
    private ISysDictDataService dictDataService;
    @Autowired
    private ISysDictTypeService dictTypeService;
    @Autowired
    private SysFileService fileService;
    @Autowired
    private SysFileRefService sysFileRefService;

    @Autowired
    private PmReleaseAnnouncementService pmReleaseAnnouncementService;
    @Autowired
    private BaseExpertService baseExpertService;
    @Autowired
    private PmDemandExpertRefService pmDemandExpertRefService;
    @Autowired
    private PmBidOpeningService pmBidOpeningService;
    @Autowired
    private SysFileRefMapper sysFileRefMapper;
    @Autowired
    private PmBookBuildingService pmBookBuildingService;
    @Autowired
    private PmCallQuestionService pmCallQuestionService;
    @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 ISysUserService userService;

    @Autowired
    private SysDeptMapper deptMapper;
    @Autowired
    private BaseExpertMapper baseExpertMapper;

    @Autowired
    private PmAuditDeptRefService pmAuditDeptRefService;
    @Autowired
    private ProvisionalPlanMapper provisionalPlanMapper;
    @Autowired
    private PmExpertFeedbackService pmExpertFeedbackService;
    @Autowired
    private PmProcurementDocumentsReviewService pmProcurementDocumentsReviewService;
    @Autowired
    private PmCallQuestionHisService questionHisService;


    /**
     * 查询采购需求
     *
     * @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);

                //project_type,evaluation 从原来计划里取
                ProvisionalPlan provisionalPlan = provisionalPlanMapper.seletById(pmDemand.getPlanId());
                if (provisionalPlan != null) {
                    vo.setProjectType(provisionalPlan.getProjectType());
                    vo.setEvaluation(provisionalPlan.getEvaluation().doubleValue());
                }

                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<SysFileInfo> demandFileInfos = getSysFileInfoList(vo.getDemandId(), SysFileRefEnum.PM_DEMAND.getType());
                if (!ObjectUtils.isEmpty(demandFileInfos)) {
                    vo.setDemandFileInfos(demandFileInfos);
                }

                //项目类型
                String projectTypeName = dictDataService.selectDictLabel("sys_project_type", vo.getProjectType());
                if (StringUtils.isNotEmpty(projectTypeName)) {
                    vo.setProjectTypeName(projectTypeName);
                }

                //是否为超限额计划
                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<SysFileInfo> auditFileInfos = getSysFileInfoList(vo.getDemandId(), SysFileRefEnum.PM_DEMAND_EXAMINE.getType());
                if (!ObjectUtils.isEmpty(auditFileInfos)) {
                    vo.setAuditFileInfos(auditFileInfos);
                }

                LambdaQueryWrapper<PmBookBuilding> 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<SysFileInfo> fileInfos = getSysFileInfoList(pmBookBuilding.getId(), SysFileRefEnum.PM_BOOK_BUILDING.getType());
                    if (!ObjectUtils.isEmpty(fileInfos)) {
                        if (!ObjectUtils.isEmpty(auditFileInfos)) {
                            fileInfos.addAll(auditFileInfos);
                        }
                        responseVo.setFileInfos(fileInfos);
                    }
                    vo.setPmBookBuildingResVo(responseVo);
                }
            } else if ("3".equals(detailType)) { //任务下达
                vo.setTaskReleaseTime(pmDemand.getTaskReleaseTime());
                //任务下达文件
                List<SysFileInfo> taskReleaseFileInfos = getSysFileInfoList(vo.getDemandId(), SysFileRefEnum.PM_TAST_RELEASE.getType());
                if (!ObjectUtils.isEmpty(taskReleaseFileInfos)) {
                    vo.setTaskReleaseFileInfos(taskReleaseFileInfos);
                }
            } else if ("4".equals(detailType)) { //中标信息
                setPmPurchaseExecutionResVo(vo, pmDemand);
            } else if ("5".equals(detailType)) { //合同信息
                setPmPurchaseExecutionResVo(vo, pmDemand);
                LambdaQueryWrapper<PmContractInfo> 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<SysFileInfo> 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<PmProjectConstruction> 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<SysFileInfo> fileInfos = getSysFileInfoList(pmProjectConstruction.getId(), SysFileRefEnum.PM_PROJECT_CONSTRUCTION.getType());
                    if (!ObjectUtils.isEmpty(fileInfos)) {
                        pmProjectConstructionResVo.setFileInfos(fileInfos);
                    }
                    vo.setPmProjectConstructionResVo(pmProjectConstructionResVo);
                }

            }

            return vo;
        } else {
            return null;
        }
    }

    private void setPmPurchaseExecutionResVo(PmDemandResVo vo, PmDemand pmDemand) {
        Long demandId = pmDemand.getDemandId();
        PmPurchaseExecutionResVo pmPurchaseExecutionResVo = new PmPurchaseExecutionResVo();

        //代理商信息
        BaseAgency baseAgency = this.baseAgencyService.getById(pmDemand.getAgencyId());
        pmPurchaseExecutionResVo.setBaseAgency(baseAgency);
        vo.setPurchaseTaskDocumentNumber(pmDemand.getPurchaseTaskDocumentNumber());
        //专家意见反馈
        LambdaQueryWrapper<PmExpertFeedback> pmExpertFeedbackLambdaQueryWrapper = new LambdaQueryWrapper<>();
        pmExpertFeedbackLambdaQueryWrapper.eq(PmExpertFeedback::getDemandId, demandId);
        PmExpertFeedback pmExpertFeedback = pmExpertFeedbackService.getOne(pmExpertFeedbackLambdaQueryWrapper);
        if (!ObjectUtils.isEmpty(pmExpertFeedback)) {
            PmExpertFeedbackResVo pmExpertFeedbackResVo = new PmExpertFeedbackResVo();
            BeanUtils.copyProperties(pmExpertFeedback, pmExpertFeedbackResVo);

            List<SysFileInfo> fileInfos = getSysFileInfoList(pmExpertFeedbackResVo.getId(), SysFileRefEnum.PM_EXPERT_FEEDBACK.getType());
            if (!ObjectUtils.isEmpty(fileInfos)) {
                pmExpertFeedbackResVo.setFileInfos(fileInfos);
            }
            pmPurchaseExecutionResVo.setPmExpertFeedbackResVo(pmExpertFeedbackResVo);
        }

        //采购文件编制审核
        LambdaQueryWrapper<PmProcurementDocumentsReview> pmProcurementDocumentsReviewLambdaQueryWrapper = new LambdaQueryWrapper<>();
        pmProcurementDocumentsReviewLambdaQueryWrapper.eq(PmProcurementDocumentsReview::getDemandId, demandId);
        PmProcurementDocumentsReview pmProcurementDocumentsReview = pmProcurementDocumentsReviewService.getOne(pmProcurementDocumentsReviewLambdaQueryWrapper);
        if (!ObjectUtils.isEmpty(pmProcurementDocumentsReview)) {
            PmProcurementDocumentsReviewResVo pmProcurementDocumentsReviewResVo = new PmProcurementDocumentsReviewResVo();
            BeanUtils.copyProperties(pmProcurementDocumentsReview, pmProcurementDocumentsReviewResVo);

            List<SysFileInfo> fileInfos = getSysFileInfoList(pmProcurementDocumentsReviewResVo.getId(), SysFileRefEnum.PM_BID_FILE.getType());
            if (!ObjectUtils.isEmpty(fileInfos)) {
                pmProcurementDocumentsReviewResVo.setFileInfos(fileInfos);
            }
            pmPurchaseExecutionResVo.setPmProcurementDocumentsReviewResVo(pmProcurementDocumentsReviewResVo);
        }

        //采购公告列表
        LambdaQueryWrapper<PmReleaseAnnouncement> lambdaQueryWrapper = new LambdaQueryWrapper<>();
        lambdaQueryWrapper.eq(PmReleaseAnnouncement::getDemandId, demandId).orderByDesc(PmReleaseAnnouncement::getReleaseTime);
        List<PmReleaseAnnouncement> pmReleaseAnnouncementList = this.pmReleaseAnnouncementService.list(lambdaQueryWrapper);
        if (!ObjectUtils.isEmpty(pmReleaseAnnouncementList)) {
            List<PmReleaseAnnouncementResVo> pmReleaseAnnouncementResVoList = new ArrayList<>();
            List<SysFileInfo> fileInfosAll = new ArrayList<>();
            for (PmReleaseAnnouncement pmReleaseAnnouncement : pmReleaseAnnouncementList) {
                PmReleaseAnnouncementResVo pmReleaseAnnouncementResVo = new PmReleaseAnnouncementResVo();
                BeanUtils.copyProperties(pmReleaseAnnouncement, pmReleaseAnnouncementResVo);

                List<SysFileInfo> fileInfos = getSysFileInfoList(pmReleaseAnnouncementResVo.getId(), SysFileRefEnum.PM_ANNOUNCEMENT_FILE.getType());
                if (!ObjectUtils.isEmpty(fileInfos)) {
                    fileInfosAll.addAll(fileInfos);
                }
                pmReleaseAnnouncementResVoList.add(pmReleaseAnnouncementResVo);
            }
            pmPurchaseExecutionResVo.setPmReleaseAnnouncementFileInfos(fileInfosAll);
            pmPurchaseExecutionResVo.setPmReleaseAnnouncementResVoList(pmReleaseAnnouncementResVoList);
        }

        //标前质疑投诉
        LambdaQueryWrapper<PmCallQuestion> pmCallQuestionLambdaQueryWrapper = new LambdaQueryWrapper<>();
        pmCallQuestionLambdaQueryWrapper.eq(PmCallQuestion::getDemandId, demandId)
                .eq(PmCallQuestion::getType, '0').orderByDesc(PmCallQuestion::getCallQuestionTime);
        List<PmCallQuestion> pmCallQuestionList = pmCallQuestionService.list(pmCallQuestionLambdaQueryWrapper);
        if (!ObjectUtils.isEmpty(pmCallQuestionList)) {
            List<PmCallQuestionResVo> pmCallQuestionResVoList = new ArrayList<>();
            List<SysFileInfo> fileInfosAll = new ArrayList<>();
            for (PmCallQuestion pmCallQuestion : pmCallQuestionList) {
                PmCallQuestionResVo pmCallQuestionResVo = new PmCallQuestionResVo();
                BeanUtils.copyProperties(pmCallQuestion, pmCallQuestionResVo);
                List<SysFileInfo> fileInfos = getSysFileInfoList(pmCallQuestionResVo.getId(), SysFileRefEnum.PM_PRE_BID_CALL_QUESTION.getType());
                if (!ObjectUtils.isEmpty(fileInfos)) {
                    fileInfosAll.addAll(fileInfos);
                }
                pmCallQuestionResVoList.add(pmCallQuestionResVo);
            }
            pmPurchaseExecutionResVo.setPmCallQuestionPreResVoList(pmCallQuestionResVoList);
            pmPurchaseExecutionResVo.setPmCallQuestionPreFileInfos(fileInfosAll);
        }

        //专家信息列表
        List<PmBaseExpertResVo> pmBaseExpertResVoList = this.pmDemandExpertRefService.getPmBaseExpertResVoList(demandId);
        pmPurchaseExecutionResVo.setPmBaseExpertResVoList(pmBaseExpertResVoList);

        //开标信息列表
        List<PmBidOpeningResVo> pmBidOpeningResVoList = this.pmBidOpeningService.getPmBidOpeningResVoList(demandId);
        pmPurchaseExecutionResVo.setPmBidOpeningResVoList(pmBidOpeningResVoList);

        //评标结果公告列表
        LambdaQueryWrapper<PmBidWinning> lambdaQueryWrapper1 = new LambdaQueryWrapper<>();
        lambdaQueryWrapper1.eq(PmBidWinning::getDemandId, demandId)
                .ne(PmBidWinning::getStatus, BidWinningStatus.BE_REPLACED.getCode()).orderByDesc(PmBidWinning::getBidAnnouncementTime);
        List<PmBidWinning> pmBidWinningList = this.pmBidWinningService.list(lambdaQueryWrapper1);
        if (!ObjectUtils.isEmpty(pmBidWinningList)) {
            List<PmBidWinningResVo> pmBidWinningResVoList = new ArrayList<>();
            List<SysFileInfo> fileInfosAll = new ArrayList<>();
            for (PmBidWinning pmBidWinning : pmBidWinningList) {
                PmBidWinningResVo pmBidWinningResVo = new PmBidWinningResVo();
                BeanUtils.copyProperties(pmBidWinning, pmBidWinningResVo);
                pmBidWinningResVoList.add(pmBidWinningResVo);

                List<SysFileInfo> fileInfos = getSysFileInfoList(pmBidWinningResVo.getId(), SysFileRefEnum.PM_BID_WINNING_FILE.getType());
                if (!ObjectUtils.isEmpty(fileInfos)) {
                    fileInfosAll.addAll(fileInfos);
                }

            }
            pmPurchaseExecutionResVo.setPmBidWinningResVoList(pmBidWinningResVoList);
            pmPurchaseExecutionResVo.setPmBidWinningFileInfos(fileInfosAll);
        }

        //标后质疑
        LambdaQueryWrapper<PmCallQuestion> pmCallQuestionLambdaQueryWrapper2 = new LambdaQueryWrapper<>();
        pmCallQuestionLambdaQueryWrapper2.eq(PmCallQuestion::getDemandId, demandId)
                .eq(PmCallQuestion::getType, '1').orderByDesc(PmCallQuestion::getCallQuestionTime);
        List<PmCallQuestion> pmCallQuestionList2 = pmCallQuestionService.list(pmCallQuestionLambdaQueryWrapper2);
        if (!ObjectUtils.isEmpty(pmCallQuestionList2)) {
            List<PmCallQuestionResVo> pmCallQuestionResVoList = new ArrayList<>();
            List<SysFileInfo> fileInfosAll = new ArrayList<>();
            for (PmCallQuestion pmCallQuestion : pmCallQuestionList2) {
                PmCallQuestionResVo pmCallQuestionResVo = new PmCallQuestionResVo();
                BeanUtils.copyProperties(pmCallQuestion, pmCallQuestionResVo);
                List<SysFileInfo> fileInfos = getSysFileInfoList(pmCallQuestionResVo.getId(), SysFileRefEnum.PM_BID_CALL_QEUSTION_FILE.getType());
                if (!ObjectUtils.isEmpty(fileInfos)) {
                    fileInfosAll.addAll(fileInfos);
                }
                pmCallQuestionResVoList.add(pmCallQuestionResVo);
            }
            pmPurchaseExecutionResVo.setPmCallQuestionPostResVoList(pmCallQuestionResVoList);
            pmPurchaseExecutionResVo.setPmCallRequestPostFileInfos(fileInfosAll);
        }

        //流标情况
        LambdaQueryWrapper<PmBidFailure> lambdaQueryWrapper2 = new LambdaQueryWrapper<>();
        lambdaQueryWrapper2.eq(PmBidFailure::getDemandId, demandId).orderByDesc(PmBidFailure::getBidFailureTime);
        List<PmBidFailure> pmBidFailureList = this.pmBidFailureService.list(lambdaQueryWrapper2);
        if (!ObjectUtils.isEmpty(pmBidFailureList)) {
            List<PmBidFailureResVo> pmBidFailureResVoList = new ArrayList<>();
            List<PmCallQuestionResVo> pmCallQuestionBidFailureResVoList = new ArrayList<>();
            List<SysFileInfo> pmBidFailureFileInfos = new ArrayList<>();
            List<SysFileInfo> pmCallRequestBidFailureFileInfos = new ArrayList<>();
            for (PmBidFailure pmBidFailure : pmBidFailureList) {
                PmBidFailureResVo pmBidFailureResVo = new PmBidFailureResVo();
                BeanUtils.copyProperties(pmBidFailure, pmBidFailureResVo);
                pmBidFailureResVoList.add(pmBidFailureResVo);

                //流标文件
                List<SysFileInfo> fileInfos = getSysFileInfoList(pmBidFailure.getId(), SysFileRefEnum.PM_BID_FAILURE_FILE.getType());
                if (!ObjectUtils.isEmpty(fileInfos)) {
                    pmBidFailureFileInfos.addAll(fileInfos);
                }


                if ("1".equals(pmBidFailure.getCallQuestion())) { //有质疑
                    PmCallQuestionResVo pmCallQuestionResVo = new PmCallQuestionResVo();
                    pmCallQuestionResVo.setCallQuestion(pmBidFailure.getCallQuestion());
                    pmCallQuestionResVo.setCallQuestionTime(pmBidFailure.getCallQuestionTime());
                    pmCallQuestionBidFailureResVoList.add(pmCallQuestionResVo);

                    //流废标质疑文件
                    List<SysFileInfo> fileInfos2 = getSysFileInfoList(pmBidFailure.getId(), SysFileRefEnum.PM_BID_FAILURE_CALL_QUESTION.getType());
                    if (!ObjectUtils.isEmpty(fileInfos2)) {
                        pmCallRequestBidFailureFileInfos.addAll(fileInfos2);
                    }
                }
            }

            pmPurchaseExecutionResVo.setPmBidFailureResVoList(pmBidFailureResVoList);
            pmPurchaseExecutionResVo.setPmBidFailureFileInfos(pmBidFailureFileInfos);

            //流废标处置
            pmPurchaseExecutionResVo.setPmCallQuestionBidFailureResVoList(pmCallQuestionBidFailureResVoList);
            pmPurchaseExecutionResVo.setPmCallRequestBidFailureFileInfos(pmCallRequestBidFailureFileInfos);
        }

        //中标通知书
        List<SysFileInfo> pmBidWinningNotificationFileInfos = getSysFileInfoList(vo.getDemandId(), SysFileRefEnum.PM_BID_WINNING_NOTIFICATION.getType());
        pmPurchaseExecutionResVo.setFileInfos(pmBidWinningNotificationFileInfos);

        vo.setPmPurchaseExecutionResVo(pmPurchaseExecutionResVo);

    }

    /**
     * 查询采购需求列表
     *
     * @param pmDemandReqVo
     * @return 采购需求
     */
    @Override
    public IPage<PmDemandResVo> selectPmDemandList(PmDemandReqVo pmDemandReqVo, int reqType) {
        LambdaQueryWrapper<PmDemand> lw = new LambdaQueryWrapper<>();
        //  4 (合同信息管理)、 0(需求单位管理) 、 5(项目建设管理)  需求单位
        //  1(需求需求审核) 、2 (任务下达管理)      采购管理部门
        //  3(采购执行管理)   采购办
        List<PmAuditDeptRef> list = new ArrayList<>();
        LambdaQueryWrapper<PmAuditDeptRef> l = new LambdaQueryWrapper<>();
        l.eq(PmAuditDeptRef::getDeptId, SecurityUtils.getDeptId());
        l.eq(PmAuditDeptRef::getRefType, "2");
        list = pmAuditDeptRefService.list(l);
        if (!pmDemandReqVo.getIsAdmin()) {
            if (Arrays.asList(1, 2, 3).contains(reqType)) {
                if (!ObjectUtils.isEmpty(list)) {
                    lw.in(PmDemand::getDemandId, list.stream().map(PmAuditDeptRef::getRefId).collect(Collectors.toList()));
                }
            } else {
                lw.eq(PmDemand::getPurchaseDeptId, SecurityUtils.getDeptId());
            }
        }

        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 in (9,10,11,12,13,14,15,16,17,19))");
        } else if (reqType == 4) { //合同信息列表
            lw.apply("(project_status = 19 or project_status = 20 )");
        } else if (reqType == 5) { //项目建设列表
            lw.apply("(project_status = 20 or project_status = 21 )");
        }

        lw.last(" order by project_status, plan_demand_sub_time");

        IPage<PmDemand> pageRes = this.page(new Page<>(pmDemandReqVo.getPageNum(), pmDemandReqVo.getPageSize()), lw);
        IPage<PmDemandResVo> results = new Page<>(pageRes.getCurrent(), pageRes.getSize(), pageRes.getTotal());
        if (pageRes.getRecords() != null && pageRes.getRecords().size() > 0) {
            List<PmDemandResVo> pmDemandResVos = demandChangeTo(pageRes.getRecords());

            for (PmDemandResVo vo : pmDemandResVos) {
                if (Arrays.asList(1, 2, 3).contains(reqType)) {
                    // 根据项目id 和 部门id 和 参数类型 获取 部门级别
                    List<PmAuditDeptRef> collect = list.stream()
                            .filter(o -> o.getRefId().equals(vo.getDemandId()))
                            .collect(Collectors.toList());

                    if (!ObjectUtils.isEmpty(collect)) {
                        String deptLevel = collect.get(0).getDeptLevel();

                        // 根据项目id  和 参数类型 获取 所有审核数据
                        LambdaQueryWrapper<PmAuditDeptRef> ll = new LambdaQueryWrapper<>();
                        ll.eq(PmAuditDeptRef::getRefId, vo.getDemandId());
                        ll.eq(PmAuditDeptRef::getRefType, "2");
                        List<PmAuditDeptRef> listl = pmAuditDeptRefService.list(l);

                        // 判断当前用户是否有审核权限
                        boolean flay = true;
                        List<PmAuditDeptRef> collect1 = listl.stream()
                                .filter(pmAuditDeptRef -> pmAuditDeptRef.getRefId().equals(vo.getDemandId()))
                                .collect(Collectors.toList());
                        for (PmAuditDeptRef pmAuditDeptRef : collect1) {
                            if (pmAuditDeptRef.getDeptLevel().compareTo(deptLevel) > 0
                                    && pmAuditDeptRef.getStatus().equals(Integer.parseInt("0"))) {
                                flay = false;
                            } else if (pmAuditDeptRef.getDeptLevel().compareTo(deptLevel) == 0
                                    && pmAuditDeptRef.getStatus().equals(Integer.parseInt("1"))) {
                                flay = false;

                            }
                        }
                        vo.setFlay(flay);
                    }
                }

                LambdaQueryWrapper<PmExpertFeedback> pmExpertFeedbackLambdaQueryWrapper = new LambdaQueryWrapper<>();
                pmExpertFeedbackLambdaQueryWrapper.eq(PmExpertFeedback::getDemandId, vo.getDemandId());
                PmExpertFeedback pmExpertFeedback = this.pmExpertFeedbackService.getOne(pmExpertFeedbackLambdaQueryWrapper);
                if (pmExpertFeedback != null) {
                    vo.setProjectNumber(pmExpertFeedback.getProjectNumber());
                    vo.setDocumentReviewTime(pmExpertFeedback.getDocumentReviewTime());
                }

                LambdaQueryWrapper<PmProcurementDocumentsReview> pmProcurementDocumentsReviewLambdaQueryWrapper = new LambdaQueryWrapper<>();
                pmProcurementDocumentsReviewLambdaQueryWrapper.eq(PmProcurementDocumentsReview::getDemandId, vo.getDemandId());
                PmProcurementDocumentsReview pmProcurementDocumentsReview = this.pmProcurementDocumentsReviewService.getOne(pmProcurementDocumentsReviewLambdaQueryWrapper);
                if (pmProcurementDocumentsReview != null) {
                    vo.setProcurementOfficeApprovalTime(pmProcurementDocumentsReview.getProcurementOfficeApprovalTime());
                }

                if (Integer.parseInt(vo.getProjectStatus()) > 12 && Integer.parseInt(vo.getProjectStatus()) != 18) {
                    LambdaQueryWrapper<PmReleaseAnnouncement> pmReleaseAnnouncementLambdaQueryWrapper = new LambdaQueryWrapper<>();
                    pmReleaseAnnouncementLambdaQueryWrapper.eq(PmReleaseAnnouncement::getDemandId, vo.getDemandId())
                            .orderByDesc(PmReleaseAnnouncement::getReleaseTime)
                            .last(" limit 1");
                    PmReleaseAnnouncement pmReleaseAnnouncement = this.pmReleaseAnnouncementService.getOne(pmReleaseAnnouncementLambdaQueryWrapper);
                    if (pmReleaseAnnouncement != null) {
                        vo.setAnnouncementReleaseTime(pmReleaseAnnouncement.getReleaseTime());
                        vo.setTenderOpenTime(pmReleaseAnnouncement.getTenderOpenTime());
                    }
                }

                if (Integer.parseInt(vo.getProjectStatus()) > 15 && Integer.parseInt(vo.getProjectStatus()) != 16 && Integer.parseInt(vo.getProjectStatus()) != 18) {
                    LambdaQueryWrapper<PmBidWinning> pmBidWinningLambdaQueryWrapper = new LambdaQueryWrapper<>();
                    pmBidWinningLambdaQueryWrapper.eq(PmBidWinning::getDemandId, vo.getDemandId()).eq(PmBidWinning::getStatus, BidWinningStatus.NORMAL.getCode())
                            .orderByDesc(PmBidWinning::getBidAnnouncementTime)
                            .last(" limit 1");
                    PmBidWinning pmBidWinning = this.pmBidWinningService.getOne(pmBidWinningLambdaQueryWrapper);
                    if (pmBidWinning != null) {
                        vo.setBidAnnouncementTime(pmBidWinning.getBidAnnouncementTime());
                    }
                }

            }
            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<PmBookBuilding> 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<SysFileRef> sysFileRefs = vo.getSysFileRefs();
            uploadFile(pmBookBuilding.getId(), SysFileRefEnum.PM_BOOK_BUILDING.getType(), sysFileRefs, vo.getUpdateBy());

            PmDemand pmDemandUpdate = new PmDemand();
            pmDemandUpdate.setDemandId(pmDemand.getDemandId());
            pmDemandUpdate.setProjectStatus(PmProjectStatus.DEMAND_WAIT_COMMIT.getCode());
            pmDemandUpdate.setEvaluation(vo.getBudgetAmount());
            pmDemandUpdate.setProjectType(vo.getProjectType());
            pmDemandUpdate.setPurchaseMode(vo.getPurchaseMode());
            pmDemandUpdate.setUpdateBy(vo.getUpdateBy());
            pmDemandUpdate.setUpdateTime(DateUtils.getNowDate());
            return this.updateById(pmDemandUpdate);
        } else {
            return false;
        }

    }

    private List<SysFileInfo> getSysFileInfoList(Long redId, Integer type) {
        HashMap<String, Object> map = new HashMap<>();
        map.put("red_id", redId);
        map.put("type", type);
        List<SysFileRef> fileRefs = sysFileRefService.listByMap(map);
        if (!ObjectUtils.isEmpty(fileRefs)) {
            List<SysFileInfo> fileInfos = new ArrayList<>();
            for (SysFileRef ref : fileRefs) {
                SysFileInfo fileInfo = fileService.getById(ref.getFileId());
                fileInfos.add(fileInfo);
            }

            return fileInfos;
        } else {
            return null;
        }

    }


    /**
     * 提交采购需求
     *
     * @param pmDemandReqVo
     * @return 结果
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public boolean commit(PmDemandReqVo pmDemandReqVo) {
        PmDemand pmDemand = this.getById(pmDemandReqVo.getDemandId());

        SysUser sysUser = userService.selectUserById(SecurityUtils.getUserId());
        Long deptId = sysUser.getDeptId();
        SysDept sysDept = deptMapper.selectDeptById(deptId);
        pmAuditDeptRefService.insertPmAuditDeptRefs(pmDemandReqVo.getDemandId()
                , "2"
                , deptId
                , BigDecimal.valueOf(pmDemand.getEvaluation())
                , sysUser.getUserId()
                , pmDemand.getProjectType());

        PmDemand pmDemandUpdate = new PmDemand();
        pmDemandUpdate.setDemandId(pmDemand.getDemandId());
        pmDemandUpdate.setProjectStatus(PmProjectStatus.DEMAND_WAIT_AUDIT.getCode());
        pmDemandUpdate.setWarnStatus(WarnStatus.NORMAL.getCode());
        pmDemandUpdate.setRealDemandCommitTime(DateUtils.getNowDate());
        pmDemandUpdate.setUpdateBy(pmDemandReqVo.getUpdateBy());
        pmDemandUpdate.setUpdateTime(DateUtils.getNowDate());
        return this.updateById(pmDemandUpdate);
    }

    /**
     * 查看流程图
     *
     * @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)
                || PmProjectStatus.WASTE_BID_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.PURCHASE_DEMAND_DOCKING.getCode().equals(projectStatus)) {
            moduleName = "选取代理";
        } else if (PmProjectStatus.EXPERT_FEEDBACK.getCode().equals(projectStatus)) {
            moduleName = "上传意见反馈单";
        } else if (PmProjectStatus.PROCUREMENT_DOCUMENTS_REVIEW.getCode().equals(projectStatus)) {
            moduleName = "上传招标文件审批表";
        } else if (PmProjectStatus.PROCUREMENT_ANNOUNCEMENT.getCode().equals(projectStatus)) {
            moduleName = "采购公告发布";
        } else if (PmProjectStatus.PRE_BID_QUERY.getCode().equals(projectStatus)) {
            moduleName = "标前质疑投诉";
        } else if (PmProjectStatus.WAIT_OPEN_BID.getCode().equals(projectStatus)) {
            moduleName = "填写专家信息,开评标";
        } else if (PmProjectStatus.BID_RESULT_ANNOUNCEMENT.getCode().equals(projectStatus) || PmProjectStatus.WASTE_BID_HANDLE.getCode().equals(projectStatus)) {
            moduleName = "评标结果公告";
        } else if (PmProjectStatus.POST_BID_QUERY.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;
    }


    /**
     * 审核采购需求通过
     *
     * @param pmDemandReqVo
     * @return 结果
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public boolean reviewTo(PmDemandReqVo pmDemandReqVo) {
        PmDemand pmDemand = this.getById(pmDemandReqVo.getDemandId());

        PmDemand pmDemandUpdate = new PmDemand();
        pmDemandUpdate.setDemandId(pmDemand.getDemandId());

        SysUser sysUser = userService.selectUserById(SecurityUtils.getUserId());
        Long deptId = sysUser.getDeptId();
        SysDept sysDept = deptMapper.selectDeptById(deptId);
        String[] ancestors = sysDept.getAncestors().split(",");
        String deptLevel = null;
        if (ancestors.length == 2) { //C级
            deptLevel = "C";
        } else if (ancestors.length == 3) { //B级
            deptLevel = "B";
        } else if (ancestors.length == 4) { //A级
            deptLevel = "A";
        }
        LambdaQueryWrapper<PmAuditDeptRef> lw = new LambdaQueryWrapper();
        lw.eq(PmAuditDeptRef::getRefId, pmDemandReqVo.getDemandId());
        lw.eq(PmAuditDeptRef::getRefType, "2");
        List<PmAuditDeptRef> list = pmAuditDeptRefService.list(lw);
        boolean flay = true;
        if (!ObjectUtils.isEmpty(list)) {
            for (PmAuditDeptRef pmAuditDeptRef : list) {
                // 判断 deptLevel 是否还有更高的 且是 待审核的数据
                if (pmAuditDeptRef.getDeptLevel().compareTo(deptLevel) > 0
                        && pmAuditDeptRef.getStatus().equals(Integer.parseInt("0"))) {
                    flay = false;
                }
                // 更新当前  deptLevel 级别的审核状态
                if (pmAuditDeptRef.getDeptLevel().compareTo(deptLevel) == 0) {
                    pmAuditDeptRef.setStatus(1);
                    pmAuditDeptRefService.updateById(pmAuditDeptRef);
                }
            }
        }
        if (flay) {
            pmDemandUpdate.setProjectStatus(PmProjectStatus.TASK_WAIT_RELEASE.getCode());
        }

        List<SysFileRef> sysFileRefs = pmDemandReqVo.getSysFileRefs();
        uploadFile(pmDemandReqVo.getDemandId(), SysFileRefEnum.PM_DEMAND_EXAMINE.getType(), sysFileRefs, pmDemandReqVo.getUpdateBy());

        pmDemandUpdate.setUpdateBy(pmDemandReqVo.getUpdateBy());
        pmDemandUpdate.setUpdateTime(DateUtils.getNowDate());
        pmDemandUpdate.setAuditTime(DateUtils.getNowDate());
        return this.updateById(pmDemandUpdate);
    }

    /**
     * 审核采购需求退回
     *
     * @param pmDemandReqVo
     * @return 结果
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public boolean reviewReturn(PmDemandReqVo pmDemandReqVo) {
        UpdateWrapper<PmDemand> 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());
        LambdaQueryWrapper<PmAuditDeptRef> lw = new LambdaQueryWrapper();
        lw.eq(PmAuditDeptRef::getRefId, pmDemandReqVo.getDemandId());
        lw.eq(PmAuditDeptRef::getRefType, "2");
        pmAuditDeptRefService.remove(lw);
        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.setTaskReleaseTime(pmDemandReqVo.getTaskReleaseTime());

        pmDemand.setProjectStatus(PmProjectStatus.PURCHASE_DEMAND_DOCKING.getCode());
        List<SysFileRef> 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<SysFileRef> sysFileRefs, String upateBy, boolean delOld) {


        if (!ObjectUtils.isEmpty(sysFileRefs)) {
            // 删关联
            LambdaQueryWrapper<SysFileRef> lw = new LambdaQueryWrapper<>();
            lw.eq(SysFileRef::getRedId, redId);
            lw.eq(SysFileRef::getType, fileType);
            sysFileRefMapper.delete(lw);

            //添加新的
            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 uploadFile(Long redId, Integer fileType, List<SysFileRef> sysFileRefs, String upateBy) {
        return uploadFile(redId, fileType, sysFileRefs, upateBy, 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.PRE_BID_QUERY.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<BaseNoticeType> lambdaQueryWrapper = new LambdaQueryWrapper<>();
                lambdaQueryWrapper.eq(BaseNoticeType::getName, "招标公告");
                BaseNoticeType baseNoticeType = baseNoticeTypeService.getOne(lambdaQueryWrapper);
                if (baseNoticeType == null) {
                    throw new Exception("招标公告 公告类型不存在");
                }
                baseNotice.setDemandId(pmDemand.getDemandId());
                baseNotice.setDeptId(pmDemand.getPurchaseDeptId());
                baseNotice.setIsExcess(pmDemand.getIsExcess());
                baseNotice.setType(baseNoticeType.getId());
                baseNotice.setReleaseTime(pmReleaseAnnouncement.getReleaseTime());
                baseNotice.setCreated(pmReleaseAnnouncementReqVo.getCreateBy());
                baseNotice.setCreateTime(pmReleaseAnnouncementReqVo.getCreateTime());
                baseNotice.setUpdated(pmReleaseAnnouncementReqVo.getUpdateBy());
                baseNotice.setUpdateTime(pmReleaseAnnouncementReqVo.getUpdateTime());
                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<BaseExpert> 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() + "）所属采购品种和项目类型不匹配");
            } else {
                baseExpert.setVarietyPurchase(pmDemand.getProjectType());
            }

            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 (ObjectUtils.isEmpty(baseExpert.getId())) {
                LambdaQueryWrapper<BaseExpert> lambdaQueryWrapper = new LambdaQueryWrapper<>();
                lambdaQueryWrapper.eq(BaseExpert::getIdNumber, baseExpert.getIdNumber());
                BaseExpert baseExpert1 = baseExpertService.getOne(lambdaQueryWrapper);
                if (!ObjectUtils.isEmpty(baseExpert1)) {
                    baseExpert.setId(baseExpert1.getId());
                }
            }
            if (baseExpertService.saveOrUpdate(baseExpert)) {
                LambdaQueryWrapper<PmDemandExpertRef> 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);

                //专家单位
                if (StringUtils.isNotNull(baseExpert.getUnitInformation())) {
                    List<BaseUnitInformation> baseUnitInformationList = baseExpertMapper.selectByUnitInformation(baseExpert.getUnitInformation());
                    if (baseUnitInformationList.size() <= 0) {
                        BaseUnitInformation baseUnitInformation = new BaseUnitInformation();
                        baseUnitInformation.setUnitName(baseExpert.getUnitInformation());
                        baseUnitInformation.setCreated(baseExpert.getExpertName());
                        baseUnitInformation.setCreateTime(new Date());
                        Integer i = baseExpertMapper.insertBaseUnitInformation(baseUnitInformation);
                    }
                }

            }
        }

        PmDemand pmDemandUpdate = new PmDemand();
        pmDemandUpdate.setDemandId(pmDemand.getDemandId());
        pmDemandUpdate.setHasExpert("1");
        this.updateById(pmDemandUpdate);

        return true;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public boolean extractExpertBatch(PmBaseExpertExtractReqVo pmBaseExpertExtractReqVo) throws Exception {
        PmDemand pmDemand = this.getById(pmBaseExpertExtractReqVo.getDemandId());
        if (ObjectUtils.isEmpty(pmDemand)) {
            throw new Exception("参数错误");
        }

        String professional = pmBaseExpertExtractReqVo.getProfessional();
        if (ObjectUtils.isEmpty(professional)) {
            throw new Exception("必须选择专家专业");
        }

        String localArea = pmBaseExpertExtractReqVo.getLocalArea();
        if (ObjectUtils.isEmpty(localArea)) {
            throw new Exception("必须选择地域");
        }
        if (!StringUtils.isNumeric(localArea)) {
            throw new 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;
        }

        if (technicalExpertNumber + economicExpertNumber + legalAffairsExpertNumber + spareExpertNumber == 0) {
            throw new Exception("必须至少填写一个数量");
        }

        String needAvoidUnit = pmBaseExpertExtractReqVo.getNeedAvoidUnit();
        List<String> needAvoidUnitList = null;
        if (!ObjectUtils.isEmpty(needAvoidUnit)) {
            String[] arr = needAvoidUnit.split(",");
            needAvoidUnitList = Arrays.asList(arr);
        }


        List<String> sysRegionCodeList = new ArrayList<>();
        if (!ObjectUtils.isEmpty(localArea)) {
            sysRegionCodeList.add(localArea);
            //找到该地域code对应的子列表
            List<SysRegionVO> sysRegionVOList = iSysRegionService.findChildDivisions(localArea);
            if (!ObjectUtils.isEmpty(sysRegionVOList)) {
                for (SysRegionVO vo : sysRegionVOList) {
                    sysRegionCodeList.add(vo.getCode());
                }
            }
        }

        //从专家库中查询符合项目类型的以及是白名单的全部列表
        LambdaQueryWrapper<BaseExpert> 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<BaseExpert> baseExpertList = baseExpertService.list(lw);
        if (ObjectUtils.isEmpty(baseExpertList)) {
            throw new Exception("没抽取到符合条件的专家");
        }

        //从列表中挑出来各个类型的子列表
        List<BaseExpert> technicalExpertList = new ArrayList<>();
        List<BaseExpert> economicExpertList = new ArrayList<>();
        List<BaseExpert> legalAffairsExpertList = new ArrayList<>();
        List<BaseExpert> spareExpertList = new ArrayList<>();

        String[] arr = professional.split(",");
        List<String> professionalList = Arrays.asList(arr);

        for (BaseExpert baseExpert : baseExpertList) {
            //专业类型判断
            String majorType = baseExpert.getMajorType();
            if (!ObjectUtils.isEmpty(majorType)) {
                String[] arr2 = majorType.split(",");
                List<String> majorTypeList = Arrays.asList(arr2);
                if (!hasIntersection(professionalList, majorTypeList)) { //不符合专业类型
                    continue;
                }
            }
            //备用专家
            if (spareExpertNumber > 0) { //都加进去
                spareExpertList.add(baseExpert);
            }

            if (technicalExpertNumber > 0) {
                if (baseExpert.getExpertType().contains(ExpertType.TECHNICAL_EXPERT.getCode())) {
                    technicalExpertList.add(baseExpert);
                    continue;
                }
            }

            if (economicExpertNumber > 0) {
                if (baseExpert.getExpertType().contains(ExpertType.ECONOMIC_EXPERT.getCode())) {
                    economicExpertList.add(baseExpert);
                    continue;
                }
            }

            if (legalAffairsExpertNumber > 0) {
                if (baseExpert.getExpertType().contains(ExpertType.LEGALAFFAIRS_EXPERT.getCode())) {
                    legalAffairsExpertList.add(baseExpert);
                    continue;
                }
            }
        }

        //从子列表中随机抽取符合数据量的

        List<BaseExpert> alltExpertList = new ArrayList<>();
        if (technicalExpertNumber > 0 && technicalExpertList.size() < technicalExpertNumber) {
            throw new Exception("抽取到符合条件的技术专家数量不够");
        }
        if (!ObjectUtils.isEmpty(technicalExpertList)) {
            alltExpertList.addAll(RandomUtil.getRandomList(technicalExpertList, technicalExpertNumber));
        }

        if (economicExpertNumber > 0 && economicExpertList.size() < economicExpertNumber) {
            throw new Exception("抽取到符合条件的经济专家数量不够");
        }
        if (!ObjectUtils.isEmpty(economicExpertList)) {
            alltExpertList.addAll(RandomUtil.getRandomList(economicExpertList, economicExpertNumber));
        }

        if (legalAffairsExpertNumber > 0 && legalAffairsExpertList.size() < legalAffairsExpertNumber) {
            throw new Exception("抽取到符合条件的法务专家数量不够");
        }
        if (!ObjectUtils.isEmpty(legalAffairsExpertList)) {
            alltExpertList.addAll(RandomUtil.getRandomList(legalAffairsExpertList, legalAffairsExpertNumber));
        }

        List<BaseExpert> spareExpertListNew = new ArrayList<>();
        if (!ObjectUtils.isEmpty(spareExpertList)) {
            //获取全部IDlist
            List<Integer> allExpertIdList = new ArrayList<>();
            if (!ObjectUtils.isEmpty(alltExpertList)) {
                for (BaseExpert baseExpert : alltExpertList) {
                    allExpertIdList.add(baseExpert.getId());
                }
            }
            //遍历全部IDlist
            if (!ObjectUtils.isEmpty(allExpertIdList)) { //去重
                for (BaseExpert baseExpert : spareExpertList) {
                    if (!allExpertIdList.contains(baseExpert.getId())) {
                        spareExpertListNew.add(baseExpert);
                    }
                }
            } else {
                spareExpertListNew = spareExpertList;
            }
            if (!ObjectUtils.isEmpty(spareExpertListNew)) {
                alltExpertList.addAll(RandomUtil.getRandomList(spareExpertListNew, spareExpertNumber));
            }
        }
        if (spareExpertNumber > 0 && spareExpertListNew.size() < spareExpertNumber) {
            throw new Exception("抽取到符合条件的备用专家数量不够");
        }

        if (ObjectUtils.isEmpty(alltExpertList)) {
            throw new Exception("没抽取到符合条件的专家");
        } else {
            List<PmDemandExpertRef> pmDemandExpertRefList = new ArrayList<>();
            for (BaseExpert baseExpert : alltExpertList) {

                LambdaQueryWrapper<PmDemandExpertRef> 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);
            }

            PmDemand pmDemandUpdate = new PmDemand();
            pmDemandUpdate.setDemandId(pmDemand.getDemandId());
            pmDemandUpdate.setHasExpert("1");
            this.updateById(pmDemandUpdate);

            return pmDemandExpertRefService.saveOrUpdateBatch(pmDemandExpertRefList);
        }
    }

    //二个列表是否有交集
    private boolean hasIntersection(List<String> professionalList, List<String> 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<PmReleaseAnnouncement> 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<PmBidOpening> 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.BID_RESULT_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<Long> pmBidOpeningIdList = pmBidWinningReqVo.getPmBidOpeningIdList();
        if (ObjectUtils.isEmpty(pmBidWinningReqVo.getBidWinningAmount()) && ObjectUtils.isEmpty(pmBidWinningReqVo.getRemarks())) {
            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<PmBidWinning> pmBidWinningLambdaQueryWrapper = new LambdaQueryWrapper<>();
            pmBidWinningLambdaQueryWrapper.eq(PmBidWinning::getDemandId, pmBidWinningReqVo.getDemandId())
                    .eq(PmBidWinning::getStatus, BidWinningStatus.NORMAL.getCode());
            List<PmBidWinning> pmBidWinninglist = pmBidWinningService.list(pmBidWinningLambdaQueryWrapper);
            if (!ObjectUtils.isEmpty(pmBidWinninglist)) {
                for (PmBidWinning item : pmBidWinninglist) {
                    UpdateWrapper<PmBidWinning> updateWrapper1 = new UpdateWrapper<>();
                    updateWrapper1.lambda().set(PmBidWinning::getStatus, BidWinningStatus.BE_REPLACED.getCode())
                            .eq(PmBidWinning::getId, item.getId());
                    pmBidWinningService.update(updateWrapper1);

                    UpdateWrapper<PmBidWinningOpeningRef> 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<PmBidWinningOpeningRef> pmBidWinningOpeningRefList = new ArrayList<>();
            for (Long pmBidOpeningId : pmBidOpeningIdList) {
                LambdaQueryWrapper<PmBidWinningOpeningRef> 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.setDemandId(pmBidWinning.getDemandId());
                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<BaseNoticeType> lambdaQueryWrapper = new LambdaQueryWrapper<>();
                lambdaQueryWrapper.eq(BaseNoticeType::getName, "预中标公告");
                BaseNoticeType baseNoticeType = baseNoticeTypeService.getOne(lambdaQueryWrapper);
                if (baseNoticeType == null) {
                    throw new Exception("预中标公告 公告类型不存在");
                }
                baseNotice.setDemandId(pmDemand.getDemandId());
                baseNotice.setDeptId(pmDemand.getPurchaseDeptId());
                baseNotice.setIsExcess(pmDemand.getIsExcess());
                baseNotice.setType(baseNoticeType.getId());
                baseNotice.setReleaseTime(pmBidWinningReqVo.getBidAnnouncementTime());
                baseNotice.setCreated(pmBidWinningReqVo.getCreateBy());
                baseNotice.setCreateTime(pmBidWinningReqVo.getCreateTime());
                baseNotice.setUpdated(pmBidWinningReqVo.getUpdateBy());
                baseNotice.setUpdateTime(pmBidWinningReqVo.getUpdateTime());
                this.baseNoticeService.saveOrUpdate(baseNotice);

                PmDemand pmDemandUpdate = new PmDemand();
                pmDemandUpdate.setDemandId(pmBidWinningReqVo.getDemandId());
                pmDemandUpdate.setProjectStatus(PmProjectStatus.POST_BID_QUERY.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<Long> 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<PmBidWinning> lw = new LambdaQueryWrapper<>();
        lw.eq(PmBidWinning::getDemandId, pmBidWinningReqVo.getDemandId()).eq(PmBidWinning::getStatus, BidWinningStatus.NORMAL.getCode());
        List<PmBidWinning> pmBidWinninglist = pmBidWinningService.list(lw);
        if (ObjectUtils.isEmpty(pmBidWinninglist)) {
            throw new Exception("原中标信息不存在");
        }
        //修改老的状态
        for (PmBidWinning item : pmBidWinninglist) {
            UpdateWrapper<PmBidWinning> updateWrapper1 = new UpdateWrapper<>();
            updateWrapper1.lambda().set(PmBidWinning::getStatus, BidWinningStatus.BE_REPLACED.getCode())
                    .eq(PmBidWinning::getId, item.getId());
            pmBidWinningService.update(updateWrapper1);

            UpdateWrapper<PmBidWinningOpeningRef> 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<PmBidWinningOpeningRef> pmBidWinningOpeningRefList = new ArrayList<>();
            for (Long pmBidOpeningId : pmBidOpeningIdList) {
                PmBidWinningOpeningRef pmBidWinningOpeningRef = new PmBidWinningOpeningRef();
                pmBidWinningOpeningRef.setDemandId(pmBidWinning.getDemandId());
                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<SysFileRef> sysFileRefLambdaQueryWrapper = new LambdaQueryWrapper<>();
            sysFileRefLambdaQueryWrapper.eq(SysFileRef::getType, SysFileRefEnum.PM_BID_WINNING_FILE.getType())
                    .eq(SysFileRef::getRedId, pmBidWinninglist.get(0));
            List<SysFileRef> 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<PmBidWinning> lw = new LambdaQueryWrapper<>();
            lw.eq(PmBidWinning::getDemandId, pmBidFailureReqVo.getDemandId()).eq(PmBidWinning::getStatus, BidWinningStatus.NORMAL.getCode());
            List<PmBidWinning> pmBidWinninglist = pmBidWinningService.list(lw);
            if (!ObjectUtils.isEmpty(pmBidWinninglist)) {
                for (PmBidWinning item : pmBidWinninglist) {
                    UpdateWrapper<PmBidWinning> updateWrapper1 = new UpdateWrapper<>();
                    updateWrapper1.lambda().set(PmBidWinning::getStatus, BidWinningStatus.BE_BID_FAILURE.getCode())
                            .eq(PmBidWinning::getId, item.getId());
                    pmBidWinningService.update(updateWrapper1);

                    UpdateWrapper<PmBidWinningOpeningRef> 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<BaseNoticeType> lambdaQueryWrapper = new LambdaQueryWrapper<>();
            lambdaQueryWrapper.eq(BaseNoticeType::getName, "流废标公告");
            BaseNoticeType baseNoticeType = baseNoticeTypeService.getOne(lambdaQueryWrapper);
            if (baseNoticeType == null) {
                throw new Exception("流废标公告 公告类型不存在");
            }
            baseNotice.setDemandId(pmDemand.getDemandId());
            baseNotice.setDeptId(pmDemand.getPurchaseDeptId());
            baseNotice.setIsExcess(pmDemand.getIsExcess());
            baseNotice.setType(baseNoticeType.getId());
            baseNotice.setReleaseTime(pmBidFailureReqVo.getBidFailureTime());
            baseNotice.setCreated(pmBidFailureReqVo.getCreateBy());
            baseNotice.setCreateTime(pmBidFailureReqVo.getCreateTime());
            baseNotice.setUpdated(pmBidFailureReqVo.getUpdateBy());
            baseNotice.setUpdateTime(pmBidFailureReqVo.getUpdateTime());
            this.baseNoticeService.saveOrUpdate(baseNotice);

            PmDemand pmDemandUpdate = new PmDemand();
            pmDemandUpdate.setDemandId(pmBidFailureReqVo.getDemandId());
            pmDemandUpdate.setProjectStatus(PmProjectStatus.WASTE_BID_HANDLE.getCode());
            pmDemandUpdate.setHasExpert("0");
            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<SysFileRef> sysFileRefs = pmContractInfoReqVo.getSysFileRefs();
        if (ObjectUtils.isEmpty(sysFileRefs)) {
            throw new Exception("上传附件不能为空");
        }

        LambdaQueryWrapper<PmContractInfo> 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<SysFileRef> sysFileRefs = pmProjectConstructionReqVo.getSysFileRefs();
        if (ObjectUtils.isEmpty(sysFileRefs)) {
            throw new Exception("上传附件不能为空");
        }

        LambdaQueryWrapper<PmProjectConstruction> 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.setWarnStatus(WarnStatus.NORMAL.getCode());
            pmDemandUpdate.setUpdateTime(pmProjectConstructionReqVo.getUpdateTime());
            pmDemandUpdate.setUpdateBy(pmProjectConstructionReqVo.getUpdateBy());
            return this.updateById(pmDemandUpdate);

        } else {
            return false;
        }
    }

    /**
     * 更新需求预警状态
     *
     * @param demnadId
     * @return
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void updateDemandWarnStatus(Long demnadId) {
        PmDemand pmDemand = this.getById(demnadId);
        List<SysDictData> data = iSysDictTypeService.selectDictDataByType("alert_time_setting");
        int setting1 = Integer.parseInt(data.stream().filter(item -> item.getDictLabel().equals("计划提报时间")).collect(Collectors.toList()).get(0).getDictValue());
        log.info("******** setting1 == " + setting1);
        //需求提报时间：根据数据阈值中设置的提报时间进行判断，进行预警
        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(pmDemandUpdate);
        }
    }


    /**
     * 通过需求ID列表 查询采购执行列表 sunhh
     *
     * @param demandIdList
     * @return
     */
    @Override
    public List<PmDemand> selectByDemandIdList(List<Integer> demandIdList) {
        return this.baseMapper.selectByDemandIdList(demandIdList);
    }

    /**
     * 专家库--查询抽取专家列表 非必传条件：专家名称，开始结束时间 sunhh
     *
     * @param baseExpertVo
     * @return
     */
    @Override
    public List<PmDemand> selectExtractionExpert(BaseExpertVo baseExpertVo) {
        return pmDemandMapper.selectExtractionExpert(baseExpertVo);
    }

    @Override
    public List<PmDemand> demandWaitCommit() {
        List<PmDemand> byStatus = getListByStatus(PmProjectStatus.DEMAND_WAIT_COMMIT.getCode());
        return (byStatus);
    }

    @Override
    public List<PmDemand> contractWaitFilled() {
        List<PmDemand> byStatus = getListByStatus(PmProjectStatus.CONTRACT_WAIT_FILL.getCode());
        return (byStatus);
    }

    @Override
    public List<PmDemand> projectWaitFinish() {
        List<PmDemand> byStatus = getListByStatus(PmProjectStatus.UNDER_CONSTRUCTION.getCode());
        return (byStatus);
    }

    @Override
    public List<PmDemand> demandWaitExamine() {
        return getListByStatus(PmProjectStatus.DEMAND_WAIT_AUDIT.getCode());
    }

    @Override
    public List<PmDemand> taskWaitRelease() {
        return getListByStatus(PmProjectStatus.TASK_WAIT_RELEASE.getCode());
    }

    @Override
    public List<PmDemandResVo> purchaseDemandDocking() {
        List<PmDemand> byStatus = getListByStatus(PmProjectStatus.PURCHASE_DEMAND_DOCKING.getCode());
        return listToVoList(byStatus);
    }

    @Override
    public List<PmDemandResVo> expertFeedback() {
        List<PmDemand> byStatus = getListByStatus(PmProjectStatus.EXPERT_FEEDBACK.getCode());
        return listToVoList(byStatus);
    }

    @Override
    public List<PmDemandResVo> procurementDocumentsReview() {
        List<PmDemand> byStatus = getListByStatus(PmProjectStatus.PROCUREMENT_DOCUMENTS_REVIEW.getCode());
        return listToVoList(byStatus);
    }

    @Override
    public List<PmDemandResVo> procurementAnnouncement() {
        List<PmDemand> byStatus = getListByStatus(PmProjectStatus.PROCUREMENT_ANNOUNCEMENT.getCode());
        return listToVoList(byStatus);
    }

    @Override
    public List<PmDemandResVo> preBidQuery() {
        List<PmDemand> byStatus = getListByStatus(PmProjectStatus.PRE_BID_QUERY.getCode());
        return listToVoList(byStatus);
    }

    @Override
    public List<PmDemandResVo> waitOpenBid() {
        List<PmDemand> byStatus = getListByStatus(PmProjectStatus.WAIT_OPEN_BID.getCode());
        return listToVoList(byStatus);
    }

    @Override
    public List<PmDemandResVo> bidResultAnnouncement() {
        List<PmDemand> byStatus = getListByStatus(PmProjectStatus.BID_RESULT_ANNOUNCEMENT.getCode());
        return listToVoList(byStatus);
    }

    @Override
    public List<PmDemandResVo> wasteBidHandle() {
        List<PmDemand> byStatus = getListByStatus(PmProjectStatus.WASTE_BID_HANDLE.getCode());
        return listToVoList(byStatus);
    }

    @Override
    public List<PmDemandResVo> postBidQuery() {
        List<PmDemand> byStatus = getListByStatus(PmProjectStatus.POST_BID_QUERY.getCode());
        return listToVoList(byStatus);
    }

    @Override
    public AjaxResult procurementOfficeWillManipulateTotal() {
        List<HomeToDoQueryResVo> homeRes = new ArrayList<>();
        // 采购需求对接,专家意见反馈,采购文件编制审核,采购公告发布,标前质疑投诉,待开标,评标结果公告,流废标处置,标后质疑
        List<PmDemandResVo> demandRes = new ArrayList<>();
        List<String> projectStatus = new ArrayList<>();
        projectStatus.add(PmProjectStatus.PURCHASE_DEMAND_DOCKING.getCode());
        projectStatus.add(PmProjectStatus.EXPERT_FEEDBACK.getCode());
        projectStatus.add(PmProjectStatus.PROCUREMENT_DOCUMENTS_REVIEW.getCode());
        projectStatus.add(PmProjectStatus.PROCUREMENT_ANNOUNCEMENT.getCode());
        projectStatus.add(PmProjectStatus.PRE_BID_QUERY.getCode());
        projectStatus.add(PmProjectStatus.WAIT_OPEN_BID.getCode());
        projectStatus.add(PmProjectStatus.BID_RESULT_ANNOUNCEMENT.getCode());
        projectStatus.add(PmProjectStatus.WASTE_BID_HANDLE.getCode());
        projectStatus.add(PmProjectStatus.POST_BID_QUERY.getCode());
        demandRes = listToVoList(getListByStatusTotal(projectStatus));

        //计划数据--发函催告
        List<PlanQuarterResponseVo> 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);
    }

    @Override
    public AjaxResult procurementOfficeWillManipulateTotalNum() {
        List<StatisticalChartsResVo> result = new ArrayList<>();
        // 采购需求对接,专家意见反馈,采购文件编制审核,采购公告发布,标前质疑投诉,待开标,评标结果公告,流废标处置,标后质疑
        Integer numByStatus = getNumByStatus(PmProjectStatus.PURCHASE_DEMAND_DOCKING.getCode());
        StatisticalChartsResVo chartsResVo = new StatisticalChartsResVo();
        chartsResVo.setNum(numByStatus);
        chartsResVo.setColumnName("采购需求对接");
        result.add(chartsResVo);

        Integer numByStatus1 = getNumByStatus(PmProjectStatus.EXPERT_FEEDBACK.getCode());
        StatisticalChartsResVo chartsResVo1 = new StatisticalChartsResVo();
        chartsResVo1.setColumnName("专家意见反馈");
        chartsResVo1.setNum(numByStatus1);
        result.add(chartsResVo1);

        Integer numByStatus2 = getNumByStatus(PmProjectStatus.PROCUREMENT_DOCUMENTS_REVIEW.getCode());
        StatisticalChartsResVo chartsResVo2 = new StatisticalChartsResVo();
        chartsResVo2.setColumnName("采购文件编制审核");
        chartsResVo2.setNum(numByStatus2);
        result.add(chartsResVo2);

        Integer numByStatus3 = getNumByStatus(PmProjectStatus.PROCUREMENT_ANNOUNCEMENT.getCode());
        StatisticalChartsResVo chartsResVo3 = new StatisticalChartsResVo();
        chartsResVo3.setColumnName("采购公告发布");
        chartsResVo3.setNum(numByStatus3);
        result.add(chartsResVo3);

        Integer numByStatus4 = getNumByStatus(PmProjectStatus.PRE_BID_QUERY.getCode());
        StatisticalChartsResVo chartsResVo4 = new StatisticalChartsResVo();
        chartsResVo4.setColumnName("标前质疑投诉");
        chartsResVo4.setNum(numByStatus4);
        result.add(chartsResVo4);

        Integer numByStatus5 = getNumByStatus(PmProjectStatus.WAIT_OPEN_BID.getCode());
        StatisticalChartsResVo chartsResVo5 = new StatisticalChartsResVo();
        chartsResVo5.setColumnName("待开标");
        chartsResVo5.setNum(numByStatus5);
        result.add(chartsResVo5);

        Integer numByStatus6 = getNumByStatus(PmProjectStatus.BID_RESULT_ANNOUNCEMENT.getCode());
        StatisticalChartsResVo chartsResVo6 = new StatisticalChartsResVo();
        chartsResVo6.setColumnName("评标结果公告");
        chartsResVo6.setNum(numByStatus6);
        result.add(chartsResVo6);

        Integer numByStatus7 = getNumByStatus(PmProjectStatus.WASTE_BID_HANDLE.getCode());
        StatisticalChartsResVo chartsResVo7 = new StatisticalChartsResVo();
        chartsResVo7.setColumnName("流废标处置");
        chartsResVo7.setNum(numByStatus7);
        result.add(chartsResVo7);

        Integer numByStatus8 = getNumByStatus(PmProjectStatus.POST_BID_QUERY.getCode());
        StatisticalChartsResVo chartsResVo8 = new StatisticalChartsResVo();
        chartsResVo8.setColumnName("标后质疑");
        chartsResVo8.setNum(numByStatus8);
        result.add(chartsResVo8);

        //计划数据--发函催告
        Integer letterNum = planYearsService.willSendLetterNum();
        StatisticalChartsResVo chartsResVo9 = new StatisticalChartsResVo();
        chartsResVo9.setColumnName("发函催告");
        chartsResVo9.setNum(letterNum);
        result.add(chartsResVo9);

        StatisticalChartsResVo chartsResVoT = new StatisticalChartsResVo();
        chartsResVoT.setColumnName("全部");
        chartsResVoT.setNum(willTotal(result));
        result.add(chartsResVoT);

        return AjaxResult.success(result);
    }

    public Integer willTotal(List<StatisticalChartsResVo> result) {
        Integer re = 0;
        if (!ObjectUtils.isEmpty(result)) {
            for (StatisticalChartsResVo resVo : result) {
                re += resVo.getNum();
            }
        }
        return re;
    }

    /**
     * 统计分析-采购项目信息统计
     *
     * @param pmDemandReqVo
     * @return
     */
    @Override
    public Map<String, Integer> purchaseProjectStatistical(PmDemandReqVo pmDemandReqVo) {
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        Map<String, Integer> mapReturn = new HashMap<>();
        // 查询项目总数量
        Map<String, Integer> mapCount = pmDemandMapper.purchaseProjectStatistical(pmDemandReqVo);
        // 查询已完成项目数量，预算(合同)金额数量
        Map<String, Integer> mapYWC = pmDemandMapper.purchaseProjectStatisticalYWC(pmDemandReqVo);
        // 查询新创建项目数量，预算金额数量
        Map<String, Integer> mapXCJ = pmDemandMapper.purchaseProjectStatisticalXCJ(pmDemandReqVo);
        // 查询去年完成项目数量，预算(合同)金额数量
        Map<String, Integer> mapQNWC = pmDemandMapper.purchaseProjectStatisticalQNWC(pmDemandReqVo);
        mapReturn.putAll(mapCount);
        mapReturn.putAll(mapYWC);
        mapReturn.putAll(mapXCJ);
        mapReturn.putAll(mapQNWC);
        return mapReturn;
    }

    @Override
    public List<StatisticalChartsResVo> countByProjectAttr(PmDemandReqVo pmDemandReqVo) {
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        List<StatisticalChartsResVo> resVos = new ArrayList<>();
        //直接获取每个属性的数量
        //重点采购项目
        pmDemandReqVo.setProjectAttr(ProjectAttribute.emergency.getCode());
        StatisticalChartsResVo vo1 = pmDemandMapper.countByProjectAttr(pmDemandReqVo);
        vo1.setColumnName("重点采购项目");
        resVos.add(vo1);
        //重大规划任务项目
        pmDemandReqVo.setProjectAttr(ProjectAttribute.majorPlan.getCode());
        StatisticalChartsResVo vo2 = pmDemandMapper.countByProjectAttr(pmDemandReqVo);
        vo2.setColumnName("重大规划任务项目");
        resVos.add(vo2);
        //规划任务项目
        pmDemandReqVo.setProjectAttr(ProjectAttribute.plan.getCode());
        StatisticalChartsResVo vo3 = pmDemandMapper.countByProjectAttr(pmDemandReqVo);
        vo3.setColumnName("规划任务项目");
        resVos.add(vo3);
        //一般采购项目
        pmDemandReqVo.setProjectAttr(ProjectAttribute.commonly.getCode());
        StatisticalChartsResVo vo4 = pmDemandMapper.countByProjectAttr(pmDemandReqVo);
        vo4.setColumnName("一般采购项目");
        resVos.add(vo4);

        return resVos;
    }

    @Override
    public List<StatisticalChartsResVo> countByTaskAttr(PmDemandReqVo pmDemandReqVo) {
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        //状态为“任务待下达”以后的数据
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.TASK_WAIT_RELEASE.getCode()));
        List<StatisticalChartsResVo> resVos = new ArrayList<>();
        //重点采购项目
        pmDemandReqVo.setProjectAttr(ProjectAttribute.emergency.getCode());
        StatisticalChartsResVo vo1 = pmDemandMapper.countByTaskAttr(pmDemandReqVo);
        vo1.setColumnName("重点采购项目");
        resVos.add(vo1);
        //重大规划任务项目
        pmDemandReqVo.setProjectAttr(ProjectAttribute.majorPlan.getCode());
        StatisticalChartsResVo vo2 = pmDemandMapper.countByTaskAttr(pmDemandReqVo);
        vo2.setColumnName("重大规划任务项目");
        resVos.add(vo2);
        //规划任务项目
        pmDemandReqVo.setProjectAttr(ProjectAttribute.plan.getCode());
        StatisticalChartsResVo vo3 = pmDemandMapper.countByTaskAttr(pmDemandReqVo);
        vo3.setColumnName("规划任务项目");
        resVos.add(vo3);
        //一般采购项目
        pmDemandReqVo.setProjectAttr(ProjectAttribute.commonly.getCode());
        StatisticalChartsResVo vo4 = pmDemandMapper.countByTaskAttr(pmDemandReqVo);
        vo4.setColumnName("一般采购项目");
        resVos.add(vo4);

        return resVos;
    }

    @Override
    public List<StatisticalChartsResVo> countByPurchaseMode(PmDemandReqVo pmDemandReqVo) {
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        //状态为“任务待下达”以后的数据
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.TASK_WAIT_RELEASE.getCode()));
        List<StatisticalChartsResVo> resVos = new ArrayList<>();
        //公开招标
        pmDemandReqVo.setPurchaseMode(ProcurementMethodSuggest.OPEN_BIDDING.getCode());
        StatisticalChartsResVo chartsR = pmDemandMapper.countByPurchaseMode(pmDemandReqVo);
        chartsR.setColumnName("公开招标");
        resVos.add(chartsR);
        //邀请招标
        pmDemandReqVo.setPurchaseMode(ProcurementMethodSuggest.SELECTED_BIDDING.getCode());
        StatisticalChartsResVo chartsR1 = pmDemandMapper.countByPurchaseMode(pmDemandReqVo);
        chartsR1.setColumnName("邀请招标");
        resVos.add(chartsR1);
        //竞争性谈判
        pmDemandReqVo.setPurchaseMode(ProcurementMethodSuggest.COMPETITIVE_NEGOTIATION.getCode());
        StatisticalChartsResVo chartsR2 = pmDemandMapper.countByPurchaseMode(pmDemandReqVo);
        chartsR2.setColumnName("竞争性谈判");
        resVos.add(chartsR2);
        //询价
        pmDemandReqVo.setPurchaseMode(ProcurementMethodSuggest.ENQUIRY.getCode());
        StatisticalChartsResVo chartsR3 = pmDemandMapper.countByPurchaseMode(pmDemandReqVo);
        chartsR3.setColumnName("询价");
        resVos.add(chartsR3);
        //单一来源
        pmDemandReqVo.setPurchaseMode(ProcurementMethodSuggest.SINGLE_SOURCE.getCode());
        StatisticalChartsResVo chartsR4 = pmDemandMapper.countByPurchaseMode(pmDemandReqVo);
        chartsR4.setColumnName("单一来源");
        resVos.add(chartsR4);

        return resVos;
    }

    @Override
    public List<StatisticalChartsResVo> countByEvaluation(PmDemandReqVo pmDemandReqVo) {
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        //状态为“任务待下达”以后的数据
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.TASK_WAIT_RELEASE.getCode()));
        List<StatisticalChartsResVo> resVos = new ArrayList<>();
        //概算金额包括：100万以下采购任务、100至500万元采购任务、500至1000万元采购任务、1000至5000万元采购任务、5000至1亿元采购任务、1亿元及以上采购任务
        pmDemandReqVo.setEvaluation(100);
        StatisticalChartsResVo resVo = pmDemandMapper.countByEvaluationLt(pmDemandReqVo);
        resVo.setColumnName("100万以下采购任务");
        resVos.add(resVo);
        pmDemandReqVo.setEvaluation(100);
        pmDemandReqVo.setEvaluationEnd(500);
        StatisticalChartsResVo resVo1 = pmDemandMapper.countByEvaluationBet(pmDemandReqVo);
        resVo1.setColumnName("100至500万元采购任务");
        resVos.add(resVo1);
        pmDemandReqVo.setEvaluation(500);
        pmDemandReqVo.setEvaluationEnd(1000);
        StatisticalChartsResVo resVo2 = pmDemandMapper.countByEvaluationBet(pmDemandReqVo);
        resVo2.setColumnName("500至1000万元采购任务");
        resVos.add(resVo2);
        pmDemandReqVo.setEvaluation(1000);
        pmDemandReqVo.setEvaluationEnd(5000);
        StatisticalChartsResVo resVo3 = pmDemandMapper.countByEvaluationBet(pmDemandReqVo);
        resVo3.setColumnName("1000至5000万元采购任务");
        resVos.add(resVo3);
        pmDemandReqVo.setEvaluation(5000);
        pmDemandReqVo.setEvaluationEnd(10000);
        StatisticalChartsResVo resVo4 = pmDemandMapper.countByEvaluationBet(pmDemandReqVo);
        resVo4.setColumnName("5000至1亿元采购任务");
        resVos.add(resVo4);
        pmDemandReqVo.setEvaluation(10000);
        StatisticalChartsResVo resVo5 = pmDemandMapper.countByEvaluationGt(pmDemandReqVo);
        resVo5.setColumnName("1亿元及以上采购任务");
        resVos.add(resVo5);
        return resVos;
    }

    @Override
    public AjaxResult countProjectExceed(PmDemandReqVo pmDemandReqVo) {
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        List<StatisticalChartsResVo> resVos = new ArrayList<>();
        //执行滞后采购项目：本年度所有的逾期项目数
        //预算金额：本年度所有逾期项目累加的预算金额
        StatisticalChartsResVo resVo = pmDemandMapper.countProjectExceedThisYear(pmDemandReqVo);
        resVo.setColumnName("本年度执行滞后任务");
        resVo.setColumnNamePlus("任务新增数量");
        resVos.add(resVo);
        StatisticalChartsResVo resVo2 = pmDemandMapper.countProjectExceedThisQua(pmDemandReqVo);
        resVo2.setColumnName("本季度执行滞后任务");
        resVo2.setColumnNamePlus("任务新增数量");
        resVos.add(resVo2);
        StatisticalChartsResVo resVo3 = pmDemandMapper.countProjectExceedThisMonth(pmDemandReqVo);
        resVo3.setColumnName("本月执行滞后任务");
        resVo3.setColumnNamePlus("任务新增数量");
        resVos.add(resVo3);
        StatisticalChartsResVo resVo4 = pmDemandMapper.countProjectExceedAllNum(pmDemandReqVo);
        resVo4.setColumnName("累计执行滞后采购任务");
        resVo4.setColumnNamePlus("采购任务数量");
        resVos.add(resVo4);
        //执行停滞采购任务数量--退回的采购任务数量
        List<String> tzrw = new ArrayList<>();
        tzrw.add(PmProjectStatus.DEMAND_AUDIT_RETURN.getCode());
        pmDemandReqVo.setProjectStatusList(tzrw);
        Map<String, Object> map = pmDemandMapper.purchaseProjectDistribution(pmDemandReqVo);
        StatisticalChartsResVo resVo5 = new StatisticalChartsResVo();
        resVo5.setColumnName("执行停滞");
        resVo5.setColumnNamePlus("采购任务数量");
        resVo5.setNum(Math.toIntExact((Long) map.get("countNumber")));
        resVo5.setEvaluationTotal((BigDecimal) map.get("evaluationTotal"));
        resVos.add(resVo5);
        return AjaxResult.success(resVos);
    }

    /**
     * 统计不同时间维度的逾期项目
     *
     * @return
     */
    @Override
    public AjaxResult exceedAnalysis(PmDemandReqVo pmDemandReqVo) {
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        HashMap<String, List<StatisticalChartsResVo>> resMap = new HashMap<>();
        List<StatisticalChartsResVo> byYear = pmDemandMapper.countProjectExceedYear(pmDemandReqVo);
        if (pmDemandReqVo.getTimeType().equals("1")) {
            resMap.put("年", byYear);
        } else if (pmDemandReqVo.getTimeType().equals("2")) {
            List<StatisticalChartsResVo> byQuarter = new LinkedList<>();
            for (StatisticalChartsResVo chartsResVo : byYear) {
                pmDemandReqVo.setYear(Integer.parseInt(chartsResVo.getColumnName()));
                for (int i = 1; i <= 4; i++) {
                    pmDemandReqVo.setQuarter(i);
                    StatisticalChartsResVo quarter = pmDemandMapper.countProjectExceedQuarter(pmDemandReqVo);
                    if (ObjectUtils.isEmpty(quarter)) {
                        StatisticalChartsResVo vo = new StatisticalChartsResVo("", "", 0, BigDecimal.valueOf(0), BigDecimal.valueOf(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<StatisticalChartsResVo> byMonth = new LinkedList<>();
            for (StatisticalChartsResVo chartsResVo : byYear) {
                pmDemandReqVo.setYear(Integer.parseInt(chartsResVo.getColumnName()));
                for (int i = 1; i <= 12; i++) {
                    pmDemandReqVo.setMonth(i);
                    StatisticalChartsResVo month = pmDemandMapper.countProjectExceedMonth(pmDemandReqVo);
                    if (ObjectUtils.isEmpty(month)) {
                        StatisticalChartsResVo vo = new StatisticalChartsResVo("", "", 0, BigDecimal.valueOf(0), BigDecimal.valueOf(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) {
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        HashMap<String, List<StatisticalChartsResVo>> resMap = new HashMap<>();
        //任务数量趋势分析：按照月、季度、年统计“项目属性”字段中“重大规划”属性的项目
        List<StatisticalChartsResVo> byYear = pmDemandMapper.countProjectMajorByYear(pmDemandReqVo);
        if (pmDemandReqVo.getTimeType().equals("1")) {
            resMap.put("年", byYear);
        } else if (pmDemandReqVo.getTimeType().equals("2")) {
            List<StatisticalChartsResVo> byQuarter = new LinkedList<>();
            for (StatisticalChartsResVo chartsResVo : byYear) {
                pmDemandReqVo.setYear(Integer.parseInt(chartsResVo.getColumnName()));
                for (int i = 1; i <= 4; i++) {
                    pmDemandReqVo.setQuarter(i);
                    StatisticalChartsResVo quarter = pmDemandMapper.countProjectMajorByQuarter(pmDemandReqVo);
                    quarter.setColumnName(chartsResVo.getColumnName() + "年第" + i + "季度");
                    byQuarter.add(quarter);
                }
            }
            resMap.put("季度", byQuarter);
        } else if (pmDemandReqVo.getTimeType().equals("3")) {
            List<StatisticalChartsResVo> byMonth = pmDemandMapper.countProjectMajorByMonth(pmDemandReqVo);
            resMap.put("月", byMonth);
        }
        return AjaxResult.success(resMap);
    }

    @Override
    public AjaxResult countEveryStatusNum(PmDemandReqVo pmDemandReqVo) {
        //阶段包括：采购需求对接,专家意见反馈,采购文件编制审核,采购公告发布,标前质疑投诉,待开标,评标结果公告,流废标处置,标后质疑
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        List<StatisticalChartsResVo> everyStatusNum = new ArrayList<>();

        //项目进行到各个阶段的数量
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.PURCHASE_DEMAND_DOCKING.getCode()));
        StatisticalChartsResVo everyStatusNum9 = pmDemandMapper.countEveryStatusNum(pmDemandReqVo);
        everyStatusNum9.setColumnName(PmProjectStatus.PURCHASE_DEMAND_DOCKING.getInfo());
        everyStatusNum.add(everyStatusNum9);

        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.EXPERT_FEEDBACK.getCode()));
        StatisticalChartsResVo everyStatusNum10 = pmDemandMapper.countEveryStatusNum(pmDemandReqVo);
        everyStatusNum10.setColumnName(PmProjectStatus.EXPERT_FEEDBACK.getInfo());
        everyStatusNum.add(everyStatusNum10);

        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.PROCUREMENT_DOCUMENTS_REVIEW.getCode()));
        StatisticalChartsResVo everyStatusNum11 = pmDemandMapper.countEveryStatusNum(pmDemandReqVo);
        everyStatusNum11.setColumnName(PmProjectStatus.PROCUREMENT_DOCUMENTS_REVIEW.getInfo());
        everyStatusNum.add(everyStatusNum11);

        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.PROCUREMENT_ANNOUNCEMENT.getCode()));
        StatisticalChartsResVo everyStatusNum12 = pmDemandMapper.countEveryStatusNum(pmDemandReqVo);
        everyStatusNum12.setColumnName(PmProjectStatus.PROCUREMENT_ANNOUNCEMENT.getInfo());
        everyStatusNum.add(everyStatusNum12);

        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.PRE_BID_QUERY.getCode()));
        StatisticalChartsResVo everyStatusNum13 = pmDemandMapper.countEveryStatusNum(pmDemandReqVo);
        everyStatusNum13.setColumnName(PmProjectStatus.PRE_BID_QUERY.getInfo());
        everyStatusNum.add(everyStatusNum13);

        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.WAIT_OPEN_BID.getCode()));
        StatisticalChartsResVo everyStatusNum14 = pmDemandMapper.countEveryStatusNum(pmDemandReqVo);
        everyStatusNum14.setColumnName(PmProjectStatus.WAIT_OPEN_BID.getInfo());
        everyStatusNum.add(everyStatusNum14);

        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.BID_RESULT_ANNOUNCEMENT.getCode()));
        StatisticalChartsResVo everyStatusNum15 = pmDemandMapper.countEveryStatusNum(pmDemandReqVo);
        everyStatusNum15.setColumnName(PmProjectStatus.BID_RESULT_ANNOUNCEMENT.getInfo());
        everyStatusNum.add(everyStatusNum15);

        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.WASTE_BID_HANDLE.getCode()));
        StatisticalChartsResVo everyStatusNum16 = pmDemandMapper.countEveryStatusNum(pmDemandReqVo);
        everyStatusNum16.setColumnName(PmProjectStatus.WASTE_BID_HANDLE.getInfo());
        everyStatusNum.add(everyStatusNum16);

        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.POST_BID_QUERY.getCode()));
        StatisticalChartsResVo everyStatusNum17 = pmDemandMapper.countEveryStatusNum(pmDemandReqVo);
        everyStatusNum17.setColumnName(PmProjectStatus.POST_BID_QUERY.getInfo());
        everyStatusNum.add(everyStatusNum17);

        return AjaxResult.success(everyStatusNum);
    }

    @Override
    public AjaxResult exceedMarketAnalysis(PmDemandReqVo pmDemandReqVo) {
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        //所有滞后
        List<PmDemand> demandList = pmDemandMapper.countProjectExceedAll(pmDemandReqVo);
        //滞后时长包括：滞后1个月以内的采购任务、滞后1至3个月采购任务、滞后3至6个月采购任务、滞后6个月至1年采购任务、滞后1年以上采购任务
        HashMap<String, Integer> 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) {
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        List<StatisticalChartsResVo> resVos = new ArrayList<>();
        //本月度新提报重大规划采购任务数量
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.DEMAND_WAIT_COMMIT.getCode()));
        StatisticalChartsResVo resVo = pmDemandMapper.majorProjectByStatusThisMonthNew(pmDemandReqVo);
        resVo.setColumnName("本月度新提报");
        resVo.setColumnNamePlus("重大规划采购任务数量");
        resVos.add(resVo);
        //本季度新提报重大规划采购任务数量
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.DEMAND_WAIT_COMMIT.getCode()));
        StatisticalChartsResVo resVo2 = pmDemandMapper.majorProjectByStatusThisQuaNew(pmDemandReqVo);
        resVo2.setColumnName("本季度新提报");
        resVo2.setColumnNamePlus("重大规划采购任务数量");
        resVos.add(resVo2);
        //本年度新提报重大规划采购任务数量
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.DEMAND_WAIT_COMMIT.getCode()));
        StatisticalChartsResVo resVo3 = pmDemandMapper.majorProjectByStatusThisYearNew(pmDemandReqVo);
        resVo3.setColumnName("本年度新提报");
        resVo3.setColumnNamePlus("重大规划采购任务数量");
        resVos.add(resVo3);
        //本月度完成重大规划采购任务数量
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.CONTRACT_WAIT_FILL.getCode()));
        StatisticalChartsResVo resVo4 = pmDemandMapper.majorProjectByStatusThisMonthFi(pmDemandReqVo);
        resVo4.setColumnName("本月度完成");
        resVo4.setColumnNamePlus("重大规划采购任务数量");
        resVos.add(resVo4);
        //本季度完成重大规划采购任务数量
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.CONTRACT_WAIT_FILL.getCode()));
        StatisticalChartsResVo resVo5 = pmDemandMapper.majorProjectByStatusThisQuaFi(pmDemandReqVo);
        resVo5.setColumnName("本季度完成");
        resVo5.setColumnNamePlus("重大规划采购任务数量");
        resVos.add(resVo5);
        //本年度完成重大规划采购任务数量
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.CONTRACT_WAIT_FILL.getCode()));
        StatisticalChartsResVo resVo6 = pmDemandMapper.majorProjectByStatusThisYearFi(pmDemandReqVo);
        resVo6.setColumnName("本年度完成");
        resVo6.setColumnNamePlus("重大规划采购任务数量");
        resVos.add(resVo6);
        //上年度结转和本年度新提报重大规划采购任务累计项目数量
        List<String> yearLastZ = new ArrayList<>();
        yearLastZ.add(PmProjectStatus.DEMAND_WAIT_AUDIT.getCode());
        yearLastZ.add(PmProjectStatus.DEMAND_AUDIT_RETURN.getCode());
        yearLastZ.add(PmProjectStatus.TASK_WAIT_RELEASE.getCode());
        yearLastZ.add(PmProjectStatus.PURCHASE_DEMAND_DOCKING.getCode());
        yearLastZ.add(PmProjectStatus.EXPERT_FEEDBACK.getCode());
        yearLastZ.add(PmProjectStatus.PROCUREMENT_DOCUMENTS_REVIEW.getCode());
        yearLastZ.add(PmProjectStatus.PROCUREMENT_ANNOUNCEMENT.getCode());
        yearLastZ.add(PmProjectStatus.PRE_BID_QUERY.getCode());
        yearLastZ.add(PmProjectStatus.WAIT_OPEN_BID.getCode());
        yearLastZ.add(PmProjectStatus.BID_RESULT_ANNOUNCEMENT.getCode());
        yearLastZ.add(PmProjectStatus.WASTE_BID_HANDLE.getCode());
        yearLastZ.add(PmProjectStatus.POST_BID_QUERY.getCode());
        yearLastZ.add(PmProjectStatus.WASTE_BID_RETURN.getCode());
        pmDemandReqVo.setProjectStatusList(yearLastZ);
        StatisticalChartsResVo resVo7 = pmDemandMapper.majorProjectByStatusLastYear(pmDemandReqVo);
        if (ObjectUtils.isEmpty(resVo7)) {
            resVo7 = new StatisticalChartsResVo();
            resVo7.setNum(0);
            resVo7.setEvaluationTotal(BigDecimal.ZERO);
            resVo7.setEvaluationContractTotal(BigDecimal.ZERO);
        }
        resVo7.setNum(resVo7.getNum() + resVo3.getNum());
        resVo7.setEvaluationTotal(resVo7.getEvaluationTotal().add(resVo3.getEvaluationTotal()));
        resVo7.setColumnName("上年度结转和本年度新提报");
        resVo7.setColumnNamePlus("重大规划采购任务累计数量");
        resVos.add(resVo7);
        //今年以来累计完成数量
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.CONTRACT_WAIT_FILL.getCode()));
        StatisticalChartsResVo resVo8 = pmDemandMapper.majorProjectByStatusToThisYear(pmDemandReqVo);
        resVo8.setColumnName("今年以来累计");
        resVo8.setColumnNamePlus("累计完成数量");
        resVos.add(resVo8);
        //正常推进周期内的重大规划采购任务数量
        StatisticalChartsResVo resVo9 = pmDemandMapper.majorProjectByStatusWei(pmDemandReqVo);
        resVo9.setColumnName("正常推进周期内");
        resVo9.setColumnNamePlus("重大规划采购任务数量");
        resVos.add(resVo9);
        //执行滞后的重大规划采购任务数量
        StatisticalChartsResVo resVo10 = pmDemandMapper.majorProjectByStatusChao(pmDemandReqVo);
        resVo10.setColumnName("执行滞后");
        resVo10.setColumnNamePlus("重大规划采购任务数量");
        resVos.add(resVo10);
        return AjaxResult.success(resVos);
    }

    @Override
    public AjaxResult countMajorProjectCGB(PmDemandReqVo pmDemandReqVo) {
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        List<StatisticalChartsResVo> resVos = new ArrayList<>();
        //本月度新受领重大规划采购任务数量
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.TASK_WAIT_RELEASE.getCode()));
        StatisticalChartsResVo resVo = pmDemandMapper.majorProjectByStatusThisMonthNew(pmDemandReqVo);
        resVo.setColumnName("本月度新受领");
        resVo.setColumnNamePlus("重大规划采购任务数量");
        resVos.add(resVo);
        //本季度新受领重大规划采购任务数量
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.TASK_WAIT_RELEASE.getCode()));
        StatisticalChartsResVo resVo2 = pmDemandMapper.majorProjectByStatusThisQuaNew(pmDemandReqVo);
        resVo2.setColumnName("本季度新受领");
        resVo2.setColumnNamePlus("重大规划采购任务数量");
        resVos.add(resVo2);
        //本年度新受领重大规划采购任务数量
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.TASK_WAIT_RELEASE.getCode()));
        StatisticalChartsResVo resVo3 = pmDemandMapper.majorProjectByStatusThisYearNew(pmDemandReqVo);
        resVo3.setColumnName("本年度新受领");
        resVo3.setColumnNamePlus("重大规划采购任务数量");
        resVos.add(resVo3);
        //上年度结转重大规划采购任务累计项目数量
        List<String> yearLastZ = new ArrayList<>();
        yearLastZ.add(PmProjectStatus.PURCHASE_DEMAND_DOCKING.getCode());
        yearLastZ.add(PmProjectStatus.EXPERT_FEEDBACK.getCode());
        yearLastZ.add(PmProjectStatus.PROCUREMENT_DOCUMENTS_REVIEW.getCode());
        yearLastZ.add(PmProjectStatus.PROCUREMENT_ANNOUNCEMENT.getCode());
        yearLastZ.add(PmProjectStatus.PRE_BID_QUERY.getCode());
        yearLastZ.add(PmProjectStatus.WAIT_OPEN_BID.getCode());
        yearLastZ.add(PmProjectStatus.BID_RESULT_ANNOUNCEMENT.getCode());
        yearLastZ.add(PmProjectStatus.WASTE_BID_HANDLE.getCode());
        yearLastZ.add(PmProjectStatus.POST_BID_QUERY.getCode());
        yearLastZ.add(PmProjectStatus.WASTE_BID_RETURN.getCode());
        pmDemandReqVo.setProjectStatusList(yearLastZ);
        StatisticalChartsResVo resVo7 = pmDemandMapper.majorProjectByStatusLastYear(pmDemandReqVo);
        if (ObjectUtils.isEmpty(resVo7)) {
            resVo7 = new StatisticalChartsResVo();
            resVo7.setNum(0);
            resVo7.setEvaluationTotal(BigDecimal.ZERO);
            resVo7.setEvaluationContractTotal(BigDecimal.ZERO);
        }
        resVo7.setColumnName("上年度结转和本年度新提报");
        resVo7.setColumnNamePlus("累计项目数量");
        //上年度结转和本月度新受领重大规划采购任务累计项目数量预算金额
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.DEMAND_WAIT_COMMIT.getCode()));
        StatisticalChartsResVo resVo4 = pmDemandMapper.majorProjectByStatusThisMonthFiCGB(pmDemandReqVo);
        if (ObjectUtils.isEmpty(resVo4)) {
            resVo4 = new StatisticalChartsResVo();
            resVo4.setNum(0);
            resVo4.setEvaluationTotal(BigDecimal.ZERO);
            resVo4.setEvaluationContractTotal(BigDecimal.ZERO);
        }
        resVo4.setNum(resVo4.getNum() + resVo7.getNum());
        resVo4.setEvaluationTotal(resVo4.getEvaluationTotal().add(resVo7.getEvaluationTotal()));
        resVo4.setColumnName("上年度结转和本月度新受领");
        resVo4.setColumnNamePlus("累计项目数量");
        resVos.add(resVo4);
        //上年度结转和本季度新受领重大规划采购任务累计项目数量预算金额
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.DEMAND_WAIT_COMMIT.getCode()));
        StatisticalChartsResVo resVo5 = pmDemandMapper.majorProjectByStatusThisQuaFiCGB(pmDemandReqVo);
        if (ObjectUtils.isEmpty(resVo5)) {
            resVo5 = new StatisticalChartsResVo();
            resVo5.setNum(0);
            resVo5.setEvaluationTotal(BigDecimal.ZERO);
            resVo5.setEvaluationContractTotal(BigDecimal.ZERO);
        }
        resVo5.setNum(resVo5.getNum() + resVo7.getNum());
        resVo5.setEvaluationTotal(resVo5.getEvaluationTotal().add(resVo7.getEvaluationTotal()));
        resVo5.setColumnName("上年度结转和本季度新受领");
        resVo5.setColumnNamePlus("累计项目数量");
        resVos.add(resVo5);
        //上年度结转和本年度新受领重大规划采购任务累计项目数量预算金额
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.DEMAND_WAIT_COMMIT.getCode()));
        StatisticalChartsResVo resVo6 = pmDemandMapper.majorProjectByStatusThisYearFiCGB(pmDemandReqVo);
        if (ObjectUtils.isEmpty(resVo6)) {
            resVo6 = new StatisticalChartsResVo();
            resVo6.setNum(0);
            resVo6.setEvaluationTotal(BigDecimal.ZERO);
            resVo6.setEvaluationContractTotal(BigDecimal.ZERO);
        }
        resVo6.setNum(resVo6.getNum() + resVo7.getNum());
        resVo6.setEvaluationTotal(resVo6.getEvaluationTotal().add(resVo7.getEvaluationTotal()));
        resVo6.setColumnName("上年度结转和本年度新受领");
        resVo6.setColumnNamePlus("累计项目数量");
        resVos.add(resVo6);
        //本月度完成重大规划采购任务数量
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.CONTRACT_WAIT_FILL.getCode()));
        StatisticalChartsResVo resVoA = pmDemandMapper.majorProjectByStatusThisMonthFi(pmDemandReqVo);
        resVoA.setColumnName("本月度完成");
        resVoA.setColumnNamePlus("重大规划采购任务数量");
        resVos.add(resVoA);
        //本季度完成重大规划采购任务数量
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.CONTRACT_WAIT_FILL.getCode()));
        StatisticalChartsResVo resVoB = pmDemandMapper.majorProjectByStatusThisQuaFi(pmDemandReqVo);
        resVoB.setColumnName("本季度完成");
        resVoB.setColumnNamePlus("重大规划采购任务数量");
        resVos.add(resVoB);
        //本年度完成重大规划采购任务数量
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.CONTRACT_WAIT_FILL.getCode()));
        StatisticalChartsResVo resVoC = pmDemandMapper.majorProjectByStatusThisYearFi(pmDemandReqVo);
        resVoC.setColumnName("本年度完成");
        resVoC.setColumnNamePlus("重大规划采购任务数量");
        resVos.add(resVoC);
        //今年以来累计完成数量
        pmDemandReqVo.setProjectStatus(Long.valueOf(PmProjectStatus.CONTRACT_WAIT_FILL.getCode()));
        StatisticalChartsResVo resVo8 = pmDemandMapper.majorProjectByStatusToThisYear(pmDemandReqVo);
        resVo8.setColumnName("今年以来累计");
        resVo8.setColumnNamePlus("累计完成数量");
        resVos.add(resVo8);
        //正常推进周期内的重大规划采购任务数量
        StatisticalChartsResVo resVo9 = pmDemandMapper.majorProjectByStatusWei(pmDemandReqVo);
        resVo9.setColumnName("正常推进周期内");
        resVo9.setColumnNamePlus("重大规划采购任务数量");
        resVos.add(resVo9);
        //执行滞后的重大规划采购任务数量
        StatisticalChartsResVo resVo10 = pmDemandMapper.majorProjectByStatusChao(pmDemandReqVo);
        resVo10.setColumnName("执行滞后");
        resVo10.setColumnNamePlus("重大规划采购任务数量");
        resVos.add(resVo10);
        return AjaxResult.success(resVos);
    }

    /**
     * 通过计划ID查询项目数据
     *
     * @param planId
     * @return
     */
    @Override
    public PmDemand selectByPlanId(Long planId) {
        return pmDemandMapper.selectByPlanId(planId);
    }

    /**
     * 项目执行进度统计
     * 1、正常推进项目数量：指未完成并且没有逾期的项目
     * 预算金额：指未完成并且没有逾期的项目累加的预算金额
     * 2、未完成采购任务：“合同待填制”状态之前的项目
     * 预算金额：“合同待填制”状态之前的项目累加的预算金额
     *
     * @param pmDemandReqVo
     * @return
     */
    @Override
    public List<StatisticalChartsResVo> purchaseProjectExecute(PmDemandReqVo pmDemandReqVo) {
        List<StatisticalChartsResVo> resVos = new ArrayList<>();
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        //累计完成采购任务数量    预算金额(万元)        合同金额(万元)
        StatisticalChartsResVo tThisYear = pmDemandMapper.selectFInishAll(pmDemandReqVo);
        tThisYear.setColumnName("累计完成采购任务数量");
        resVos.add(tThisYear);
        // 正常推进项目数量、预算金额
        StatisticalChartsResVo mapNormalPropulsion = pmDemandMapper.purchaseProjectExecuteNormalPropulsion(pmDemandReqVo);
        mapNormalPropulsion.setColumnName("正常推进项目数量");
        resVos.add(mapNormalPropulsion);
        // 未完成采购任务，预算金额
        StatisticalChartsResVo mapIncomplete = pmDemandMapper.purchaseProjectExecuteIncomplete(pmDemandReqVo);
        mapIncomplete.setColumnName("未完成采购任务");
        resVos.add(mapIncomplete);
        return resVos;
    }

    /**
     * 已完成项目数量统计
     *
     * @param pmDemandReqVo
     * @return
     */
    @Override
    public List<Map<String, Integer>> purchaseProjectCompleteNumber(PmDemandReqVo pmDemandReqVo) {
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        List<Map<String, Integer>> 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<Map<String, Integer>> listMap = pmDemandMapper.selectpurchaseProjectCompleteNumberYear(pmDemandReqVo);
            mapReturn.addAll(listMap);
            for (int i = minYear; i <= year; i++) {
                boolean isYear = false;
                for (Map<String, Integer> map : listMap) {
                    if (i == Integer.parseInt(String.valueOf(map.get("yy")))) {
                        isYear = true;
                    }
                }
                if (!isYear) {
                    Map<String, Integer> 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<Map<String, Integer>> listMap = pmDemandMapper.selectpurchaseProjectCompleteNumberQuarter(pmDemandReqVo);
            mapReturn.addAll(listMap);
            for (int i = 1; i <= 4; i++) {
                boolean isYear = false;
                for (Map<String, Integer> map : listMap) {
                    if (i == Integer.parseInt(String.valueOf(map.get("yy")))) {
                        isYear = true;
                    }
                }
                if (!isYear) {
                    Map<String, Integer> 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<Map<String, Integer>> listMap = pmDemandMapper.selectpurchaseProjectCompleteNumberMonth(pmDemandReqVo);
            mapReturn.addAll(listMap);
            for (int i = 1; i <= 12; i++) {
                boolean isYear = false;
                for (Map<String, Integer> map : listMap) {
                    if (i == Integer.parseInt(String.valueOf(map.get("yy")))) {
                        isYear = true;
                    }
                }
                if (!isYear) {
                    Map<String, Integer> 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<Map<String, Integer>> purchaseTaskFinish(PmDemandReqVo pmDemandReqVo) {
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        List<Map<String, Integer>> 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<Map<String, Integer>> listMap = pmDemandMapper.selectPurchaseTaskFinishYear(pmDemandReqVo);
            mapReturn.addAll(listMap);
            for (int i = minYear; i <= year; i++) {
                boolean isYear = false;
                for (Map<String, Integer> map : listMap) {
                    if (i == Integer.parseInt(String.valueOf(map.get("yy")))) {
                        isYear = true;
                        map.put("yy", i);
                    }
                }
                if (!isYear) {
                    Map<String, Integer> 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<Map<String, Integer>> listMap = pmDemandMapper.selectPurchaseTaskFinishQuarter(pmDemandReqVo);
            mapReturn.addAll(listMap);
            for (int i = 1; i <= 4; i++) {
                boolean isYear = false;
                for (Map<String, Integer> map : listMap) {
                    if (i == Integer.parseInt(String.valueOf(map.get("yy")))) {
                        isYear = true;
                    }
                }
                if (!isYear) {
                    Map<String, Integer> 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<Map<String, Integer>> listMap = pmDemandMapper.selectPurchaseTaskFinishMonth(pmDemandReqVo);
            mapReturn.addAll(listMap);
            for (int i = 1; i <= 12; i++) {
                boolean isYear = false;
                for (Map<String, Integer> map : listMap) {
                    if (i == Integer.parseInt(String.valueOf(map.get("yy")))) {
                        isYear = true;
                        map.put("yy", i);
                        map.put("countNum", 0);
                    }
                }
                if (!isYear) {
                    Map<String, Integer> 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<Map<String, String>> purchaseProjectNumberAnalysis(PmDemandReqVo pmDemandReqVo) {
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        List<Map<String, String>> 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<Map<String, String>> listMap = pmDemandMapper.purchaseProjectNumberAnalysisYear(pmDemandReqVo);
            mapReturn.addAll(listMap);
            for (int i = minYear; i <= year; i++) {
                boolean isYear = false;
                for (Map<String, String> map : listMap) {
                    if (i == Integer.parseInt(String.valueOf(map.get("yy")))) {
                        isYear = true;
                    }
                }
                if (!isYear) {
                    Map<String, String> map1 = new HashMap<>();
                    map1.put("yy", i + "");
                    map1.put("countNum", 0 + "");
                    map1.put("evaluationSum", 0 + "");
                    mapReturn.add(map1);
                }
            }
        } else if ("2".equals(pmDemandReqVo.getTimeType())) {
            // 当前年份季度统计
            // 获取统计数据
            List<Map<String, String>> listMap = pmDemandMapper.purchaseProjectNumberAnalysisQuarter(pmDemandReqVo);
            List<Map<String, String>> mapList = new ArrayList<>();
            mapList.addAll(listMap);
            for (int i = 1; i <= 4; i++) {
                boolean isYear = false;
                for (Map<String, String> map : listMap) {
                    if (i == Integer.parseInt(String.valueOf(map.get("yy")))) {
                        isYear = true;
                    }
                }
                if (!isYear) {
                    Map<String, String> map1 = new HashMap<>();
                    map1.put("yy", i + "");
                    map1.put("countNum", 0 + "");
                    map1.put("evaluationSum", 0 + "");
                    mapList.add(map1);
                }
            }
            Map<String, String> map1 = new HashMap<>();
            Map<String, String> map2 = new HashMap<>();
            Map<String, String> map3 = new HashMap<>();
            Map<String, String> map4 = new HashMap<>();
            for (Map<String, String> map : mapList) {
                String yy = String.valueOf(map.get("yy"));
                if ("1".equals(yy)) {
                    map1.putAll(map);
                } else if ("2".equals(yy)) {
                    map2.putAll(map);
                } else if ("3".equals(yy)) {
                    map3.putAll(map);
                } else if ("4".equals(yy)) {
                    map4.putAll(map);
                }
            }
            String countNum1 = String.valueOf(map1.get("countNum"));
            String countNum2 = String.valueOf(map2.get("countNum"));
            String countNum3 = String.valueOf(map3.get("countNum"));
            String countNum4 = String.valueOf(map4.get("countNum"));

            String evaluationSum1 = String.valueOf(map1.get("evaluationSum"));
            String evaluationSum2 = String.valueOf(map2.get("evaluationSum"));
            String evaluationSum3 = String.valueOf(map3.get("evaluationSum"));
            String evaluationSum4 = String.valueOf(map4.get("evaluationSum"));
            // 查询上一年四季度数据
            List<Map<String, String>> listMapOldYear = pmDemandMapper.purchaseProjectNumberAnalysisOldYearQuarter(pmDemandReqVo);
            List<Map<String, String>> mapListOld = new ArrayList<>();
            mapListOld.addAll(listMapOldYear);
            for (int i = 1; i <= 4; i++) {
                boolean isYear = false;
                for (Map<String, String> map : listMapOldYear) {
                    if (i == Integer.parseInt(String.valueOf(map.get("yy")))) {
                        isYear = true;
                    }
                }
                if (!isYear) {
                    Map<String, String> map11 = new HashMap<>();
                    map11.put("yy", i + "");
                    map11.put("countNum", 0 + "");
                    map11.put("evaluationSum", 0 + "");
                    mapListOld.add(map11);
                }
            }
            Map<String, String> mapOld1 = new HashMap<>();
            Map<String, String> mapOld2 = new HashMap<>();
            Map<String, String> mapOld3 = new HashMap<>();
            Map<String, String> mapOld4 = new HashMap<>();
            for (Map<String, String> mapOld : mapListOld) {
                String yy = String.valueOf(mapOld.get("yy"));
                if ("1".equals(yy)) {
                    mapOld1.putAll(mapOld);
                } else if ("2".equals(yy)) {
                    mapOld2.putAll(mapOld);
                } else if ("3".equals(yy)) {
                    mapOld3.putAll(mapOld);
                } else if ("4".equals(yy)) {
                    mapOld4.putAll(mapOld);
                }
            }
            String countNumOld1 = String.valueOf(mapOld1.get("countNum"));
            String countNumOld2 = String.valueOf(mapOld2.get("countNum"));
            String countNumOld3 = String.valueOf(mapOld3.get("countNum"));
            String countNumOld4 = String.valueOf(mapOld4.get("countNum"));
            String evaluationSumOld1 = String.valueOf(mapOld1.get("evaluationSum"));
            String evaluationSumOld2 = String.valueOf(mapOld2.get("evaluationSum"));
            String evaluationSumOld3 = String.valueOf(mapOld3.get("evaluationSum"));
            String evaluationSumOld4 = String.valueOf(mapOld4.get("evaluationSum"));

            BigDecimal countNum11 = new BigDecimal(countNum1);
            BigDecimal countNum22 = new BigDecimal(countNum2);
            BigDecimal countNum33 = new BigDecimal(countNum3);
            BigDecimal countNum44 = new BigDecimal(countNum4);
            BigDecimal countNumOld11 = new BigDecimal(countNumOld1);
            BigDecimal countNumOld22 = new BigDecimal(countNumOld2);
            BigDecimal countNumOld33 = new BigDecimal(countNumOld3);
            BigDecimal countNumOld44 = new BigDecimal(countNumOld4);

            BigDecimal evaluationSum11 = new BigDecimal(evaluationSum1);
            BigDecimal evaluationSum22 = new BigDecimal(evaluationSum2);
            BigDecimal evaluationSum33 = new BigDecimal(evaluationSum3);
            BigDecimal evaluationSum44 = new BigDecimal(evaluationSum4);
            BigDecimal evaluationSumOld11 = new BigDecimal(evaluationSumOld1);
            BigDecimal evaluationSumOld22 = new BigDecimal(evaluationSumOld2);
            BigDecimal evaluationSumOld33 = new BigDecimal(evaluationSumOld3);
            BigDecimal evaluationSumOld44 = new BigDecimal(evaluationSumOld4);

            // 项目数量环比 对比
            BigDecimal monthonmonthNum1 = new BigDecimal(0.00);
            BigDecimal monthonmonthNum2 = new BigDecimal(0.00);
            BigDecimal monthonmonthNum3 = new BigDecimal(0.00);
            BigDecimal monthonmonthNum4 = new BigDecimal(0.00);
            if (!"0".equals(countNumOld4)) {
                monthonmonthNum1 = (countNum11.subtract(countNumOld44)).divide(countNumOld44, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNum1)) {
                monthonmonthNum2 = (countNum22.subtract(countNum11)).divide(countNum11, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNum2)) {
                monthonmonthNum3 = (countNum33.subtract(countNum22)).divide(countNum22, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNum3)) {
                monthonmonthNum4 = (countNum44.subtract(countNum33)).divide(countNum33, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            map1.put("monthonmonthNum", monthonmonthNum1.toString());
            map2.put("monthonmonthNum", monthonmonthNum2.toString());
            map3.put("monthonmonthNum", monthonmonthNum3.toString());
            map4.put("monthonmonthNum", monthonmonthNum4.toString());
            // 项目数量同比 对比
            BigDecimal yearonyearNum1 = new BigDecimal(0.00);
            BigDecimal yearonyearNum2 = new BigDecimal(0.00);
            BigDecimal yearonyearNum3 = new BigDecimal(0.00);
            BigDecimal yearonyearNum4 = new BigDecimal(0.00);
            if (!"0".equals(countNumOld1)) {
                yearonyearNum1 = (countNum11.subtract(countNumOld11)).divide(countNumOld11, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNumOld2)) {
                yearonyearNum2 = (countNum22.subtract(countNumOld22)).divide(countNumOld22, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNumOld3)) {
                yearonyearNum3 = (countNum33.subtract(countNumOld33)).divide(countNumOld33, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNumOld4)) {
                yearonyearNum4 = (countNum44.subtract(countNumOld44)).divide(countNumOld44, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            map1.put("yearonyearNum", yearonyearNum1.toString());
            map2.put("yearonyearNum", yearonyearNum2.toString());
            map3.put("yearonyearNum", yearonyearNum3.toString());
            map4.put("yearonyearNum", yearonyearNum4.toString());
            // 预算金额环比 对比
            BigDecimal monthonmonthAmount1 = new BigDecimal(0.00);
            BigDecimal monthonmonthAmount2 = new BigDecimal(0.00);
            BigDecimal monthonmonthAmount3 = new BigDecimal(0.00);
            BigDecimal monthonmonthAmount4 = new BigDecimal(0.00);
            if (!"0".equals(evaluationSumOld4)) {
                monthonmonthAmount1 = (evaluationSum11.subtract(evaluationSumOld44)).divide(evaluationSumOld44, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSum1)) {
                monthonmonthAmount2 = (evaluationSum22.subtract(evaluationSum11)).divide(evaluationSum11, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSum2)) {
                monthonmonthAmount3 = (evaluationSum33.subtract(evaluationSum22)).divide(evaluationSum22, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSum3)) {
                monthonmonthAmount4 = (evaluationSum44.subtract(evaluationSum33)).divide(evaluationSum33, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            map1.put("monthonmonthAmount", monthonmonthAmount1.toString());
            map2.put("monthonmonthAmount", monthonmonthAmount2.toString());
            map3.put("monthonmonthAmount", monthonmonthAmount3.toString());
            map4.put("monthonmonthAmount", monthonmonthAmount4.toString());
            // 预算金额同比比 对比
            BigDecimal yearonyearAmount1 = new BigDecimal(0.00);
            BigDecimal yearonyearAmount2 = new BigDecimal(0.00);
            BigDecimal yearonyearAmount3 = new BigDecimal(0.00);
            BigDecimal yearonyearAmount4 = new BigDecimal(0.00);
            if (!"0".equals(evaluationSumOld1)) {
                yearonyearAmount1 = (evaluationSum11.subtract(evaluationSumOld11)).divide(evaluationSumOld11, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSumOld2)) {
                yearonyearAmount2 = (evaluationSum22.subtract(evaluationSumOld22)).divide(evaluationSumOld22, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSumOld3)) {
                yearonyearAmount3 = (evaluationSum33.subtract(evaluationSumOld33)).divide(evaluationSumOld33, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSumOld4)) {
                yearonyearAmount4 = (evaluationSum44.subtract(evaluationSumOld44)).divide(evaluationSumOld44, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            map1.put("yearonyearAmount", yearonyearAmount1.toString());
            map2.put("yearonyearAmount", yearonyearAmount2.toString());
            map3.put("yearonyearAmount", yearonyearAmount3.toString());
            map4.put("yearonyearAmount", yearonyearAmount4.toString());
            // 存入集合
            mapReturn.add(map1);
            mapReturn.add(map2);
            mapReturn.add(map3);
            mapReturn.add(map4);
        } else if ("3".equals(pmDemandReqVo.getTimeType())) {
            // 当前年份月份统计
            // 获取统计数据
            List<Map<String, String>> listMap = pmDemandMapper.purchaseProjectNumberAnalysisMonth(pmDemandReqVo);
            List<Map<String, String>> mapList = new ArrayList<>();
            mapList.addAll(listMap);
            for (int i = 1; i <= 12; i++) {
                boolean isYear = false;
                for (Map<String, String> map : listMap) {
                    String yy = String.valueOf(map.get("yy"));
                    String yyNew = yy.replaceAll("^0*", "");
                    if (i == Integer.valueOf(yyNew)) {
                        isYear = true;
                    }
                }
                if (!isYear) {
                    Map<String, String> map1 = new HashMap<>();
                    String yy = String.format("%02d", i);
                    map1.put("yy", yy);
                    map1.put("countNum", 0 + "");
                    map1.put("evaluationSum", 0 + "");
                    mapList.add(map1);
                }
            }
            Map<String, String> map1 = new HashMap<>();
            Map<String, String> map2 = new HashMap<>();
            Map<String, String> map3 = new HashMap<>();
            Map<String, String> map4 = new HashMap<>();
            Map<String, String> map5 = new HashMap<>();
            Map<String, String> map6 = new HashMap<>();
            Map<String, String> map7 = new HashMap<>();
            Map<String, String> map8 = new HashMap<>();
            Map<String, String> map9 = new HashMap<>();
            Map<String, String> map10 = new HashMap<>();
            Map<String, String> map11 = new HashMap<>();
            Map<String, String> map12 = new HashMap<>();
            for (Map<String, String> map : mapList) {
                String yy = String.valueOf(map.get("yy"));
                if ("01".equals(yy)) {
                    map1.putAll(map);
                } else if ("02".equals(yy)) {
                    map2.putAll(map);
                } else if ("03".equals(yy)) {
                    map3.putAll(map);
                } else if ("04".equals(yy)) {
                    map4.putAll(map);
                } else if ("05".equals(yy)) {
                    map5.putAll(map);
                } else if ("06".equals(yy)) {
                    map6.putAll(map);
                } else if ("07".equals(yy)) {
                    map7.putAll(map);
                } else if ("08".equals(yy)) {
                    map8.putAll(map);
                } else if ("09".equals(yy)) {
                    map9.putAll(map);
                } else if ("10".equals(yy)) {
                    map10.putAll(map);
                } else if ("11".equals(yy)) {
                    map11.putAll(map);
                } else if ("12".equals(yy)) {
                    map12.putAll(map);
                }
            }
            String countNum1 = String.valueOf(map1.get("countNum"));
            String countNum2 = String.valueOf(map2.get("countNum"));
            String countNum3 = String.valueOf(map3.get("countNum"));
            String countNum4 = String.valueOf(map4.get("countNum"));
            String countNum5 = String.valueOf(map5.get("countNum"));
            String countNum6 = String.valueOf(map6.get("countNum"));
            String countNum7 = String.valueOf(map7.get("countNum"));
            String countNum8 = String.valueOf(map8.get("countNum"));
            String countNum9 = String.valueOf(map9.get("countNum"));
            String countNum10 = String.valueOf(map10.get("countNum"));
            String countNum11 = String.valueOf(map11.get("countNum"));
            String countNum12 = String.valueOf(map12.get("countNum"));

            String evaluationSum1 = String.valueOf(map1.get("evaluationSum"));
            String evaluationSum2 = String.valueOf(map2.get("evaluationSum"));
            String evaluationSum3 = String.valueOf(map3.get("evaluationSum"));
            String evaluationSum4 = String.valueOf(map4.get("evaluationSum"));
            String evaluationSum5 = String.valueOf(map5.get("evaluationSum"));
            String evaluationSum6 = String.valueOf(map6.get("evaluationSum"));
            String evaluationSum7 = String.valueOf(map7.get("evaluationSum"));
            String evaluationSum8 = String.valueOf(map8.get("evaluationSum"));
            String evaluationSum9 = String.valueOf(map9.get("evaluationSum"));
            String evaluationSum10 = String.valueOf(map10.get("evaluationSum"));
            String evaluationSum11 = String.valueOf(map11.get("evaluationSum"));
            String evaluationSum12 = String.valueOf(map12.get("evaluationSum"));
            // 查询上一年月份数据
            List<Map<String, String>> listMapOldMonth = pmDemandMapper.purchaseProjectNumberAnalysisOldYearMonth(pmDemandReqVo);
            List<Map<String, String>> mapListOld = new ArrayList<>();
            mapListOld.addAll(listMapOldMonth);
            for (int i = 1; i <= 12; i++) {
                boolean isYear = false;
                for (Map<String, String> map : listMapOldMonth) {
                    String yy = String.valueOf(map.get("yy"));
                    String yyNew = yy.replaceAll("^0*", "");
                    if (i == Integer.valueOf(yyNew)) {
                        isYear = true;
                    }
                }
                if (!isYear) {
                    Map<String, String> map111 = new HashMap<>();
                    String yy = String.format("%02d", i);
                    map111.put("yy", yy);
                    map111.put("countNum", 0 + "");
                    map111.put("evaluationSum", 0 + "");
                    mapListOld.add(map111);
                }
            }
            Map<String, String> mapOld1 = new HashMap<>();
            Map<String, String> mapOld2 = new HashMap<>();
            Map<String, String> mapOld3 = new HashMap<>();
            Map<String, String> mapOld4 = new HashMap<>();
            Map<String, String> mapOld5 = new HashMap<>();
            Map<String, String> mapOld6 = new HashMap<>();
            Map<String, String> mapOld7 = new HashMap<>();
            Map<String, String> mapOld8 = new HashMap<>();
            Map<String, String> mapOld9 = new HashMap<>();
            Map<String, String> mapOld10 = new HashMap<>();
            Map<String, String> mapOld11 = new HashMap<>();
            Map<String, String> mapOld12 = new HashMap<>();
            for (Map<String, String> mapOld : mapListOld) {
                String yy = String.valueOf(mapOld.get("yy"));
                if ("01".equals(yy)) {
                    mapOld1.putAll(mapOld);
                } else if ("02".equals(yy)) {
                    mapOld2.putAll(mapOld);
                } else if ("03".equals(yy)) {
                    mapOld3.putAll(mapOld);
                } else if ("04".equals(yy)) {
                    mapOld4.putAll(mapOld);
                } else if ("05".equals(yy)) {
                    mapOld5.putAll(mapOld);
                } else if ("06".equals(yy)) {
                    mapOld6.putAll(mapOld);
                } else if ("07".equals(yy)) {
                    mapOld7.putAll(mapOld);
                } else if ("08".equals(yy)) {
                    mapOld8.putAll(mapOld);
                } else if ("09".equals(yy)) {
                    mapOld9.putAll(mapOld);
                } else if ("10".equals(yy)) {
                    mapOld10.putAll(mapOld);
                } else if ("11".equals(yy)) {
                    mapOld11.putAll(mapOld);
                } else if ("12".equals(yy)) {
                    mapOld12.putAll(mapOld);
                }
            }
            String countNumOld1 = String.valueOf(mapOld1.get("countNum"));
            String countNumOld2 = String.valueOf(mapOld2.get("countNum"));
            String countNumOld3 = String.valueOf(mapOld3.get("countNum"));
            String countNumOld4 = String.valueOf(mapOld4.get("countNum"));
            String countNumOld5 = String.valueOf(mapOld5.get("countNum"));
            String countNumOld6 = String.valueOf(mapOld6.get("countNum"));
            String countNumOld7 = String.valueOf(mapOld7.get("countNum"));
            String countNumOld8 = String.valueOf(mapOld8.get("countNum"));
            String countNumOld9 = String.valueOf(mapOld9.get("countNum"));
            String countNumOld10 = String.valueOf(mapOld10.get("countNum"));
            String countNumOld11 = String.valueOf(mapOld11.get("countNum"));
            String countNumOld12 = String.valueOf(mapOld12.get("countNum"));
            String evaluationSumOld1 = String.valueOf(mapOld1.get("evaluationSum"));
            String evaluationSumOld2 = String.valueOf(mapOld2.get("evaluationSum"));
            String evaluationSumOld3 = String.valueOf(mapOld3.get("evaluationSum"));
            String evaluationSumOld4 = String.valueOf(mapOld4.get("evaluationSum"));
            String evaluationSumOld5 = String.valueOf(mapOld5.get("evaluationSum"));
            String evaluationSumOld6 = String.valueOf(mapOld6.get("evaluationSum"));
            String evaluationSumOld7 = String.valueOf(mapOld7.get("evaluationSum"));
            String evaluationSumOld8 = String.valueOf(mapOld8.get("evaluationSum"));
            String evaluationSumOld9 = String.valueOf(mapOld9.get("evaluationSum"));
            String evaluationSumOld10 = String.valueOf(mapOld10.get("evaluationSum"));
            String evaluationSumOld11 = String.valueOf(mapOld11.get("evaluationSum"));
            String evaluationSumOld12 = String.valueOf(mapOld12.get("evaluationSum"));

            BigDecimal countNum111 = new BigDecimal(countNum1);
            BigDecimal countNum22 = new BigDecimal(countNum2);
            BigDecimal countNum33 = new BigDecimal(countNum3);
            BigDecimal countNum44 = new BigDecimal(countNum4);
            BigDecimal countNum55 = new BigDecimal(countNum5);
            BigDecimal countNum66 = new BigDecimal(countNum6);
            BigDecimal countNum77 = new BigDecimal(countNum7);
            BigDecimal countNum88 = new BigDecimal(countNum8);
            BigDecimal countNum99 = new BigDecimal(countNum9);
            BigDecimal countNum1010 = new BigDecimal(countNum10);
            BigDecimal countNum1111 = new BigDecimal(countNum11);
            BigDecimal countNum1212 = new BigDecimal(countNum12);
            BigDecimal countNumOld111 = new BigDecimal(countNumOld1);
            BigDecimal countNumOld22 = new BigDecimal(countNumOld2);
            BigDecimal countNumOld33 = new BigDecimal(countNumOld3);
            BigDecimal countNumOld44 = new BigDecimal(countNumOld4);
            BigDecimal countNumOld55 = new BigDecimal(countNumOld5);
            BigDecimal countNumOld66 = new BigDecimal(countNumOld6);
            BigDecimal countNumOld77 = new BigDecimal(countNumOld7);
            BigDecimal countNumOld88 = new BigDecimal(countNumOld8);
            BigDecimal countNumOld99 = new BigDecimal(countNumOld9);
            BigDecimal countNumOld1010 = new BigDecimal(countNumOld10);
            BigDecimal countNumOld1111 = new BigDecimal(countNumOld11);
            BigDecimal countNumOld1212 = new BigDecimal(countNumOld12);

            BigDecimal evaluationSum111 = new BigDecimal(evaluationSum1);
            BigDecimal evaluationSum22 = new BigDecimal(evaluationSum2);
            BigDecimal evaluationSum33 = new BigDecimal(evaluationSum3);
            BigDecimal evaluationSum44 = new BigDecimal(evaluationSum4);
            BigDecimal evaluationSum55 = new BigDecimal(evaluationSum5);
            BigDecimal evaluationSum66 = new BigDecimal(evaluationSum6);
            BigDecimal evaluationSum77 = new BigDecimal(evaluationSum7);
            BigDecimal evaluationSum88 = new BigDecimal(evaluationSum8);
            BigDecimal evaluationSum99 = new BigDecimal(evaluationSum9);
            BigDecimal evaluationSum1010 = new BigDecimal(evaluationSum10);
            BigDecimal evaluationSum1111 = new BigDecimal(evaluationSum11);
            BigDecimal evaluationSum1212 = new BigDecimal(evaluationSum12);
            BigDecimal evaluationSumOld111 = new BigDecimal(evaluationSumOld1);
            BigDecimal evaluationSumOld22 = new BigDecimal(evaluationSumOld2);
            BigDecimal evaluationSumOld33 = new BigDecimal(evaluationSumOld3);
            BigDecimal evaluationSumOld44 = new BigDecimal(evaluationSumOld4);
            BigDecimal evaluationSumOld55 = new BigDecimal(evaluationSumOld5);
            BigDecimal evaluationSumOld66 = new BigDecimal(evaluationSumOld6);
            BigDecimal evaluationSumOld77 = new BigDecimal(evaluationSumOld7);
            BigDecimal evaluationSumOld88 = new BigDecimal(evaluationSumOld8);
            BigDecimal evaluationSumOld99 = new BigDecimal(evaluationSumOld9);
            BigDecimal evaluationSumOld1010 = new BigDecimal(evaluationSumOld10);
            BigDecimal evaluationSumOld1111 = new BigDecimal(evaluationSumOld11);
            BigDecimal evaluationSumOld1212 = new BigDecimal(evaluationSumOld12);

            // 项目数量环比 对比
            BigDecimal monthonmonthNum1 = new BigDecimal(0.00);
            BigDecimal monthonmonthNum2 = new BigDecimal(0.00);
            BigDecimal monthonmonthNum3 = new BigDecimal(0.00);
            BigDecimal monthonmonthNum4 = new BigDecimal(0.00);
            BigDecimal monthonmonthNum5 = new BigDecimal(0.00);
            BigDecimal monthonmonthNum6 = new BigDecimal(0.00);
            BigDecimal monthonmonthNum7 = new BigDecimal(0.00);
            BigDecimal monthonmonthNum8 = new BigDecimal(0.00);
            BigDecimal monthonmonthNum9 = new BigDecimal(0.00);
            BigDecimal monthonmonthNum10 = new BigDecimal(0.00);
            BigDecimal monthonmonthNum11 = new BigDecimal(0.00);
            BigDecimal monthonmonthNum12 = new BigDecimal(0.00);
            if (!"0".equals(countNumOld12)) {
                monthonmonthNum1 = (countNum111.subtract(countNumOld1212)).divide(countNumOld1212, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNum1)) {
                monthonmonthNum2 = (countNum22.subtract(countNum111)).divide(countNum111, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNum2)) {
                monthonmonthNum3 = (countNum33.subtract(countNum22)).divide(countNum22, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNum3)) {
                monthonmonthNum4 = (countNum44.subtract(countNum33)).divide(countNum33, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNum4)) {
                monthonmonthNum5 = (countNum55.subtract(countNum44)).divide(countNum44, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNum5)) {
                monthonmonthNum6 = (countNum66.subtract(countNum55)).divide(countNum55, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNum6)) {
                monthonmonthNum7 = (countNum77.subtract(countNum66)).divide(countNum66, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNum7)) {
                monthonmonthNum8 = (countNum88.subtract(countNum77)).divide(countNum77, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNum8)) {
                monthonmonthNum9 = (countNum99.subtract(countNum88)).divide(countNum88, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNum9)) {
                monthonmonthNum10 = (countNum1010.subtract(countNum99)).divide(countNum99, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNum10)) {
                monthonmonthNum11 = (countNum1111.subtract(countNum1010)).divide(countNum1010, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNum11)) {
                monthonmonthNum12 = (countNum1212.subtract(countNum1111)).divide(countNum1111, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            map1.put("monthonmonthNum", monthonmonthNum1.toString());
            map2.put("monthonmonthNum", monthonmonthNum2.toString());
            map3.put("monthonmonthNum", monthonmonthNum3.toString());
            map4.put("monthonmonthNum", monthonmonthNum4.toString());
            map5.put("monthonmonthNum", monthonmonthNum5.toString());
            map6.put("monthonmonthNum", monthonmonthNum6.toString());
            map7.put("monthonmonthNum", monthonmonthNum7.toString());
            map8.put("monthonmonthNum", monthonmonthNum8.toString());
            map9.put("monthonmonthNum", monthonmonthNum9.toString());
            map10.put("monthonmonthNum", monthonmonthNum10.toString());
            map11.put("monthonmonthNum", monthonmonthNum11.toString());
            map12.put("monthonmonthNum", monthonmonthNum12.toString());
            // 项目数量同比 对比
            BigDecimal yearonyearNum1 = new BigDecimal(0.00);
            BigDecimal yearonyearNum2 = new BigDecimal(0.00);
            BigDecimal yearonyearNum3 = new BigDecimal(0.00);
            BigDecimal yearonyearNum4 = new BigDecimal(0.00);
            BigDecimal yearonyearNum5 = new BigDecimal(0.00);
            BigDecimal yearonyearNum6 = new BigDecimal(0.00);
            BigDecimal yearonyearNum7 = new BigDecimal(0.00);
            BigDecimal yearonyearNum8 = new BigDecimal(0.00);
            BigDecimal yearonyearNum9 = new BigDecimal(0.00);
            BigDecimal yearonyearNum10 = new BigDecimal(0.00);
            BigDecimal yearonyearNum11 = new BigDecimal(0.00);
            BigDecimal yearonyearNum12 = new BigDecimal(0.00);
            if (!"0".equals(countNumOld1)) {
                yearonyearNum1 = (countNum111.subtract(countNumOld111)).divide(countNumOld111, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNumOld2)) {
                yearonyearNum2 = (countNum22.subtract(countNumOld22)).divide(countNumOld22, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNumOld3)) {
                yearonyearNum3 = (countNum33.subtract(countNumOld33)).divide(countNumOld33, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNumOld4)) {
                yearonyearNum4 = (countNum44.subtract(countNumOld44)).divide(countNumOld44, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNumOld5)) {
                yearonyearNum5 = (countNum55.subtract(countNumOld55)).divide(countNumOld55, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNumOld6)) {
                yearonyearNum6 = (countNum66.subtract(countNumOld66)).divide(countNumOld66, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNumOld7)) {
                yearonyearNum7 = (countNum77.subtract(countNumOld77)).divide(countNumOld77, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNumOld8)) {
                yearonyearNum8 = (countNum88.subtract(countNumOld88)).divide(countNumOld88, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNumOld9)) {
                yearonyearNum9 = (countNum99.subtract(countNumOld99)).divide(countNumOld99, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNumOld10)) {
                yearonyearNum10 = (countNum1010.subtract(countNumOld1010)).divide(countNumOld1010, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNumOld11)) {
                yearonyearNum11 = (countNum1111.subtract(countNumOld1111)).divide(countNumOld1111, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(countNumOld12)) {
                yearonyearNum12 = (countNum1212.subtract(countNumOld1212)).divide(countNumOld1212, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            map1.put("yearonyearNum", yearonyearNum1.toString());
            map2.put("yearonyearNum", yearonyearNum2.toString());
            map3.put("yearonyearNum", yearonyearNum3.toString());
            map4.put("yearonyearNum", yearonyearNum4.toString());
            map5.put("yearonyearNum", yearonyearNum5.toString());
            map6.put("yearonyearNum", yearonyearNum6.toString());
            map7.put("yearonyearNum", yearonyearNum7.toString());
            map8.put("yearonyearNum", yearonyearNum8.toString());
            map9.put("yearonyearNum", yearonyearNum9.toString());
            map10.put("yearonyearNum", yearonyearNum10.toString());
            map11.put("yearonyearNum", yearonyearNum11.toString());
            map12.put("yearonyearNum", yearonyearNum12.toString());
            // 预算金额环比 对比
            BigDecimal monthonmonthAmount1 = new BigDecimal(0.00);
            BigDecimal monthonmonthAmount2 = new BigDecimal(0.00);
            BigDecimal monthonmonthAmount3 = new BigDecimal(0.00);
            BigDecimal monthonmonthAmount4 = new BigDecimal(0.00);
            BigDecimal monthonmonthAmount5 = new BigDecimal(0.00);
            BigDecimal monthonmonthAmount6 = new BigDecimal(0.00);
            BigDecimal monthonmonthAmount7 = new BigDecimal(0.00);
            BigDecimal monthonmonthAmount8 = new BigDecimal(0.00);
            BigDecimal monthonmonthAmount9 = new BigDecimal(0.00);
            BigDecimal monthonmonthAmount10 = new BigDecimal(0.00);
            BigDecimal monthonmonthAmount11 = new BigDecimal(0.00);
            BigDecimal monthonmonthAmount12 = new BigDecimal(0.00);
            if (!"0".equals(evaluationSumOld12)) {
                monthonmonthAmount1 = (evaluationSum111.subtract(evaluationSumOld1212)).divide(evaluationSumOld1212, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSum1)) {
                monthonmonthAmount2 = (evaluationSum22.subtract(evaluationSum111)).divide(evaluationSum111, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSum2)) {
                monthonmonthAmount3 = (evaluationSum33.subtract(evaluationSum22)).divide(evaluationSum22, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSum3)) {
                monthonmonthAmount4 = (evaluationSum44.subtract(evaluationSum33)).divide(evaluationSum33, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSum4)) {
                monthonmonthAmount5 = (evaluationSum55.subtract(evaluationSum44)).divide(evaluationSum44, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSum5)) {
                monthonmonthAmount6 = (evaluationSum66.subtract(evaluationSum55)).divide(evaluationSum55, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSum6)) {
                monthonmonthAmount7 = (evaluationSum77.subtract(evaluationSum66)).divide(evaluationSum66, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSum7)) {
                monthonmonthAmount8 = (evaluationSum88.subtract(evaluationSum77)).divide(evaluationSum77, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSum8)) {
                monthonmonthAmount9 = (evaluationSum99.subtract(evaluationSum88)).divide(evaluationSum88, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSum9)) {
                monthonmonthAmount10 = (evaluationSum1010.subtract(evaluationSum99)).divide(evaluationSum99, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSum10)) {
                monthonmonthAmount11 = (evaluationSum1111.subtract(evaluationSum1010)).divide(evaluationSum1010, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSum11)) {
                monthonmonthAmount12 = (evaluationSum1212.subtract(evaluationSum1111)).divide(evaluationSum1111, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            map1.put("monthonmonthAmount", monthonmonthAmount1.toString());
            map2.put("monthonmonthAmount", monthonmonthAmount2.toString());
            map3.put("monthonmonthAmount", monthonmonthAmount3.toString());
            map4.put("monthonmonthAmount", monthonmonthAmount4.toString());
            map5.put("monthonmonthAmount", monthonmonthAmount5.toString());
            map6.put("monthonmonthAmount", monthonmonthAmount6.toString());
            map7.put("monthonmonthAmount", monthonmonthAmount7.toString());
            map8.put("monthonmonthAmount", monthonmonthAmount8.toString());
            map9.put("monthonmonthAmount", monthonmonthAmount9.toString());
            map10.put("monthonmonthAmount", monthonmonthAmount10.toString());
            map11.put("monthonmonthAmount", monthonmonthAmount11.toString());
            map12.put("monthonmonthAmount", monthonmonthAmount12.toString());
            // 预算金额同比比 对比
            BigDecimal yearonyearAmount1 = new BigDecimal(0.00);
            BigDecimal yearonyearAmount2 = new BigDecimal(0.00);
            BigDecimal yearonyearAmount3 = new BigDecimal(0.00);
            BigDecimal yearonyearAmount4 = new BigDecimal(0.00);
            BigDecimal yearonyearAmount5 = new BigDecimal(0.00);
            BigDecimal yearonyearAmount6 = new BigDecimal(0.00);
            BigDecimal yearonyearAmount7 = new BigDecimal(0.00);
            BigDecimal yearonyearAmount8 = new BigDecimal(0.00);
            BigDecimal yearonyearAmount9 = new BigDecimal(0.00);
            BigDecimal yearonyearAmount10 = new BigDecimal(0.00);
            BigDecimal yearonyearAmount11 = new BigDecimal(0.00);
            BigDecimal yearonyearAmount12 = new BigDecimal(0.00);
            if (!"0".equals(evaluationSumOld1)) {
                yearonyearAmount1 = (evaluationSum111.subtract(evaluationSumOld111)).divide(evaluationSumOld1111, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSumOld2)) {
                yearonyearAmount2 = (evaluationSum22.subtract(evaluationSumOld22)).divide(evaluationSumOld22, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSumOld3)) {
                yearonyearAmount3 = (evaluationSum33.subtract(evaluationSumOld33)).divide(evaluationSumOld33, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSumOld4)) {
                yearonyearAmount4 = (evaluationSum44.subtract(evaluationSumOld44)).divide(evaluationSumOld44, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSumOld5)) {
                yearonyearAmount5 = (evaluationSum55.subtract(evaluationSumOld55)).divide(evaluationSumOld44, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSumOld6)) {
                yearonyearAmount6 = (evaluationSum66.subtract(evaluationSumOld66)).divide(evaluationSumOld44, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSumOld7)) {
                yearonyearAmount7 = (evaluationSum77.subtract(evaluationSumOld77)).divide(evaluationSumOld44, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSumOld8)) {
                yearonyearAmount8 = (evaluationSum88.subtract(evaluationSumOld88)).divide(evaluationSumOld44, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSumOld9)) {
                yearonyearAmount9 = (evaluationSum99.subtract(evaluationSumOld99)).divide(evaluationSumOld44, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSumOld10)) {
                yearonyearAmount10 = (evaluationSum1010.subtract(evaluationSumOld1010)).divide(evaluationSumOld44, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSumOld11)) {
                yearonyearAmount11 = (evaluationSum1111.subtract(evaluationSumOld1111)).divide(evaluationSumOld44, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            if (!"0".equals(evaluationSumOld12)) {
                yearonyearAmount12 = (evaluationSum1212.subtract(evaluationSumOld1212)).divide(evaluationSumOld44, 4, BigDecimal.ROUND_CEILING).multiply(new BigDecimal("100")).setScale(2, BigDecimal.ROUND_HALF_UP);
            }
            map1.put("yearonyearAmount", yearonyearAmount1.toString());
            map2.put("yearonyearAmount", yearonyearAmount2.toString());
            map3.put("yearonyearAmount", yearonyearAmount3.toString());
            map4.put("yearonyearAmount", yearonyearAmount4.toString());
            map5.put("yearonyearAmount", yearonyearAmount5.toString());
            map6.put("yearonyearAmount", yearonyearAmount6.toString());
            map7.put("yearonyearAmount", yearonyearAmount7.toString());
            map8.put("yearonyearAmount", yearonyearAmount8.toString());
            map9.put("yearonyearAmount", yearonyearAmount9.toString());
            map10.put("yearonyearAmount", yearonyearAmount10.toString());
            map11.put("yearonyearAmount", yearonyearAmount11.toString());
            map12.put("yearonyearAmount", yearonyearAmount12.toString());
            // 存入集合
            mapReturn.add(map1);
            mapReturn.add(map2);
            mapReturn.add(map3);
            mapReturn.add(map4);
            mapReturn.add(map5);
            mapReturn.add(map6);
            mapReturn.add(map7);
            mapReturn.add(map8);
            mapReturn.add(map9);
            mapReturn.add(map10);
            mapReturn.add(map11);
            mapReturn.add(map12);
        }
        return mapReturn;
    }

    @Override
    public List<StatisticalChartsResVo> demandSubCount(PmDemandReqVo pmDemandReqVo) {
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        List<StatisticalChartsResVo> resVos = new ArrayList<>();
        //本级和所属采购单位新提报采购需求数量--本年度中本级及下级审核的“需求待提交”之后状态的数据
        StatisticalChartsResVo selectSTS = pmDemandMapper.selectSTS(pmDemandReqVo);
        selectSTS.setColumnName("本级和所属采购单位新提报");
        selectSTS.setColumnNamePlus("采购需求数量");
        resVos.add(selectSTS);
        //上年度结转和本年度提报的采购需求累计数量
        //1.上年度结转：上年度“需求待提交”之后，“合同待填制”之前状态的数据
        //2.本年度提报：指本年度“需求待提交”之后状态的数据
        StatisticalChartsResVo lastYear = pmDemandMapper.selectSTSLastYear(pmDemandReqVo);
        StatisticalChartsResVo thisYear = pmDemandMapper.selectSTSThisYear(pmDemandReqVo);
        if (ObjectUtils.isEmpty(lastYear.getNum())) {
            lastYear = new StatisticalChartsResVo();
            lastYear.setNum(0);
            lastYear.setEvaluationTotal(BigDecimal.ZERO);
            lastYear.setEvaluationContractTotal(BigDecimal.ZERO);
        }
        if (ObjectUtils.isEmpty(thisYear.getNum())) {
            thisYear = new StatisticalChartsResVo();
            thisYear.setNum(0);
            thisYear.setEvaluationTotal(BigDecimal.ZERO);
            thisYear.setEvaluationContractTotal(BigDecimal.ZERO);
        }
        lastYear.setNum(lastYear.getNum() + thisYear.getNum());
        lastYear.setEvaluationTotal(lastYear.getEvaluationTotal().add(thisYear.getEvaluationTotal()));
        lastYear.setColumnName("上年度结转和本年度提报");
        lastYear.setColumnNamePlus("采购需求累计数量");
        resVos.add(lastYear);
        //未按季度采购明细计划提报或调整延迟的数量--超过计划需求提报时间的项目
        StatisticalChartsResVo meiJiDu = pmDemandMapper.selectmeiJiDu(pmDemandReqVo);
        meiJiDu.setColumnName("未按季度采购明细计划提报或调整延迟");
        meiJiDu.setColumnNamePlus("采购需求数量");
        resVos.add(meiJiDu);
        return resVos;
    }

    @Override
    public List<StatisticalChartsResVo> countByProjectType(PmDemandReqVo pmDemandReqVo) {
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        List<StatisticalChartsResVo> resultList = new ArrayList<>();
        //项目类型情况统计--根据项目类型：物资类、服务类、工程类、装备类统计项目数量及预算金额
        pmDemandReqVo.setProjectType(ProjectTypes.EQUIPMENTTYPE.getCode());
        StatisticalChartsResVo res1 = pmDemandMapper.selectByProjectType(pmDemandReqVo);
        res1.setColumnName(ProjectTypes.EQUIPMENTTYPE.getInfo());
        resultList.add(res1);
        pmDemandReqVo.setProjectType(ProjectTypes.MATERIALTYPE.getCode());
        StatisticalChartsResVo res2 = pmDemandMapper.selectByProjectType(pmDemandReqVo);
        res2.setColumnName(ProjectTypes.MATERIALTYPE.getInfo());
        resultList.add(res2);
        pmDemandReqVo.setProjectType(ProjectTypes.SERVICESTYPE.getCode());
        StatisticalChartsResVo res3 = pmDemandMapper.selectByProjectType(pmDemandReqVo);
        res3.setColumnName(ProjectTypes.SERVICESTYPE.getInfo());
        resultList.add(res3);
        pmDemandReqVo.setProjectType(ProjectTypes.PLANTOEXAMINETYPE.getCode());
        StatisticalChartsResVo res4 = pmDemandMapper.selectByProjectType(pmDemandReqVo);
        res4.setColumnName(ProjectTypes.PLANTOEXAMINETYPE.getInfo());
        resultList.add(res4);
        return resultList;
    }

    @Override
    public List<StatisticalChartsResVo> countByPurchaseChange(PmDemandReqVo pmDemandReqVo) {
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        List<StatisticalChartsResVo> byChange = new ArrayList<>();
        //本月相关采购机构完成采购任务--状态为“标后质疑”后的数据
        StatisticalChartsResVo thisMonth = pmDemandMapper.selectCGThisMonth(pmDemandReqVo);
        thisMonth.setColumnName("本月相关采购机构");
        thisMonth.setColumnNamePlus("完成采购任务数量");
        byChange.add(thisMonth);
        //本季度相关采购机构完成采购任务--状态为“标后质疑”后的数据
        StatisticalChartsResVo thisQua = pmDemandMapper.selectCGThisQua(pmDemandReqVo);
        thisQua.setColumnName("本季度相关采购机构");
        thisQua.setColumnNamePlus("完成采购任务数量");
        byChange.add(thisQua);
        //上年度结转和本年度提报的采购需求中累计已完成的采购任务
        //上年度结转：上年度“标后质疑”之后，“合同待填制”之前状态的数据
        //本年度提报：状态为“标后质疑”后的数据
        StatisticalChartsResVo zLastYear = pmDemandMapper.selectZJLastYear(pmDemandReqVo);
        StatisticalChartsResVo tThisYear = pmDemandMapper.selectTBThisYear(pmDemandReqVo);
        if (ObjectUtils.isEmpty(zLastYear.getNum())) {
            zLastYear = new StatisticalChartsResVo();
            zLastYear.setNum(0);
            zLastYear.setEvaluationTotal(BigDecimal.ZERO);
            zLastYear.setEvaluationContractTotal(BigDecimal.ZERO);
        }
        if (ObjectUtils.isEmpty(tThisYear.getNum())) {
            tThisYear = new StatisticalChartsResVo();
            tThisYear.setNum(0);
            tThisYear.setEvaluationTotal(BigDecimal.ZERO);
            tThisYear.setEvaluationContractTotal(BigDecimal.ZERO);
        }
        //tThisYear.setNum(ObjectUtils.isEmpty(tThisYear.getNum()) ? 0 : tThisYear.getNum() + (ObjectUtils.isEmpty(zLastYear.getNum()) ? 0 : zLastYear.getNum()));
        //tThisYear.setEvaluationTotal((ObjectUtils.isEmpty(tThisYear.getEvaluationTotal()) ? BigDecimal.ZERO : tThisYear.getEvaluationTotal()).add((ObjectUtils.isEmpty(zLastYear.getEvaluationTotal()) ? BigDecimal.ZERO : zLastYear.getEvaluationTotal())));
        //tThisYear.setEvaluationContractTotal((ObjectUtils.isEmpty(tThisYear.getEvaluationContractTotal()) ? BigDecimal.ZERO : tThisYear.getEvaluationContractTotal()).add(ObjectUtils.isEmpty(zLastYear.getEvaluationContractTotal()) ? BigDecimal.ZERO : zLastYear.getEvaluationContractTotal()));
        tThisYear.setColumnName("上年度结转和本年度提报的采购需求");
        tThisYear.setColumnNamePlus("累计完成采购任务数量");
        byChange.add(tThisYear);
        //正常推进周期内的采购任务--本年度项目未超过计划完成采购时间的数据
        StatisticalChartsResVo cThisYear = pmDemandMapper.selectCCThisYear(pmDemandReqVo);
        cThisYear.setColumnName("正常推进周期内");
        cThisYear.setColumnNamePlus("采购任务数量");
        byChange.add(cThisYear);
        return byChange;
    }

    @Override
    public AjaxResult exceedReason(PmDemandReqVo pmDemandReqVo) {
        List<StatisticalChartsResVo> resVos = new ArrayList<>();
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        //统计超过计划完成采购时间的项目中，处在各阶段的数据包括以下内容：
        //1、需求编制对接数量/涉及金额：状态为“采购需求对接”的数量及预算金额
        List<String> xqdj = new ArrayList<>();
        xqdj.add(PmProjectStatus.PURCHASE_DEMAND_DOCKING.getCode());
        pmDemandReqVo.setProjectStatusList(xqdj);
        StatisticalChartsResVo resVo = pmDemandMapper.countProjectExceedAndStatus(pmDemandReqVo);
        resVo.setColumnName("需求编制对接数量");
        resVos.add(resVo);
        //2、采购文件编制审核数量/涉及金额：状态为“采购文件编制审核“的数量及预算金额
        List<String> wjsh = new ArrayList<>();
        wjsh.add(PmProjectStatus.PROCUREMENT_DOCUMENTS_REVIEW.getCode());
        pmDemandReqVo.setProjectStatusList(wjsh);
        StatisticalChartsResVo resVo2 = pmDemandMapper.countProjectExceedAndStatus(pmDemandReqVo);
        resVo2.setColumnName("采购文件编制审核数量");
        resVos.add(resVo2);
        //3、质疑、投诉、复议、信访举报数量/涉及金额：按钮”质疑投诉”进行质疑过的项目及预算金额
        List<Long> demandIdAll = questionHisService.selectDemandIdAll();
        pmDemandReqVo.setDemandIdAll(demandIdAll);
        StatisticalChartsResVo resVo3 = pmDemandMapper.countProjectExceedAndStatus(pmDemandReqVo);
        resVo3.setColumnName("质疑、投诉、复议、信访举报数量");
        resVos.add(resVo3);
        //4、流标废标数量/涉及金额：状态为“流废标处置”的项目及预算金额
        List<String> fblb = new ArrayList<>();
        fblb.add(PmProjectStatus.WASTE_BID_HANDLE.getCode());
        pmDemandReqVo.setProjectStatusList(fblb);
        StatisticalChartsResVo resVo4 = pmDemandMapper.countProjectExceedAndStatus(pmDemandReqVo);
        resVo4.setColumnName("流标废标数量");
        resVos.add(resVo4);
        //5、其他原因项目数量/涉及金额：统计“专家意见反馈”、“采购公告发布”、”待开标“、”评标结果公告“、“标后质疑”状态的数据
        List<String> qtyy = new ArrayList<>();
        qtyy.add(PmProjectStatus.EXPERT_FEEDBACK.getCode());
        qtyy.add(PmProjectStatus.PROCUREMENT_ANNOUNCEMENT.getCode());
        qtyy.add(PmProjectStatus.WAIT_OPEN_BID.getCode());
        qtyy.add(PmProjectStatus.BID_RESULT_ANNOUNCEMENT.getCode());
        qtyy.add(PmProjectStatus.POST_BID_QUERY.getCode());
        pmDemandReqVo.setProjectStatusList(qtyy);
        StatisticalChartsResVo resVo5 = pmDemandMapper.countProjectExceedAndStatus(pmDemandReqVo);
        resVo5.setColumnName("其他原因项目数量");
        resVos.add(resVo5);
        return AjaxResult.success(resVos);
    }

    @Override
    public AjaxResult exceedReasonZj(PmDemandReqVo pmDemandReqVo) {
        List<StatisticalChartsResVo> resVos = new ArrayList<>();
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        //统计超过计划完成采购时间的项目中，处在各阶段的数据包括以下内容：
        //1、需求编制对接数量/涉及金额：状态为“采购需求对接”的数量及预算金额
        List<String> xqdj = new ArrayList<>();
        xqdj.add(PmProjectStatus.PURCHASE_DEMAND_DOCKING.getCode());
        pmDemandReqVo.setProjectStatusList(xqdj);
        StatisticalChartsResVo resVo = pmDemandMapper.countProjectExceedAndStatus(pmDemandReqVo);
        resVo.setColumnName("需求编制对接数量");
        resVos.add(resVo);
        //2、采购文件编制审核数量/涉及金额：状态为“采购文件编制审核“的数量及预算金额
        List<String> wjsh = new ArrayList<>();
        wjsh.add(PmProjectStatus.PROCUREMENT_DOCUMENTS_REVIEW.getCode());
        pmDemandReqVo.setProjectStatusList(wjsh);
        StatisticalChartsResVo resVo2 = pmDemandMapper.countProjectExceedAndStatus(pmDemandReqVo);
        resVo2.setColumnName("采购文件编制审核数量");
        resVos.add(resVo2);
        //3、质疑、投诉、复议、信访举报数量/涉及金额：按钮”质疑投诉”进行质疑过的项目及预算金额
        List<Long> demandIdAll = questionHisService.selectDemandIdAll();
        pmDemandReqVo.setDemandIdAll(demandIdAll);
        StatisticalChartsResVo resVo3 = pmDemandMapper.countProjectExceedAndStatus(pmDemandReqVo);
        resVo3.setColumnName("质疑、投诉、复议、信访举报数量");
        resVos.add(resVo3);
        //5、其他原因项目数量/涉及金额：统计“专家意见反馈”、“采购公告发布”、”待开标“、”评标结果公告“、“标后质疑”状态的数据
        List<String> qtyy = new ArrayList<>();
        qtyy.add(PmProjectStatus.EXPERT_FEEDBACK.getCode());
        qtyy.add(PmProjectStatus.PROCUREMENT_ANNOUNCEMENT.getCode());
        qtyy.add(PmProjectStatus.WAIT_OPEN_BID.getCode());
        qtyy.add(PmProjectStatus.BID_RESULT_ANNOUNCEMENT.getCode());
        qtyy.add(PmProjectStatus.POST_BID_QUERY.getCode());
        pmDemandReqVo.setProjectStatusList(qtyy);
        StatisticalChartsResVo resVo5 = pmDemandMapper.countProjectExceedAndStatus(pmDemandReqVo);
        resVo5.setColumnName("其他原因项目数量");
        resVos.add(resVo5);
        return AjaxResult.success(resVos);
    }

    @Override
    public AjaxResult exceedLink(PmDemandReqVo pmDemandReqVo) {
        List<StatisticalChartsResVo> resVos = new ArrayList<>();
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        //滞留环节
        //超过计划完成采购时间的各状态数量及占比统计，包括：采购需求对接、采购文件编制审核、标签质疑投诉、待开标、流废标处置、标后质疑
        //1、 状态为“采购需求对接”的数量及预算金额
        List<String> xqdj = new ArrayList<>();
        xqdj.add(PmProjectStatus.PURCHASE_DEMAND_DOCKING.getCode());
        pmDemandReqVo.setProjectStatusList(xqdj);
        StatisticalChartsResVo resVo = pmDemandMapper.countProjectExceedAndStatus(pmDemandReqVo);
        resVo.setColumnName("采购需求对接");
        resVos.add(resVo);
        //2、 状态为“采购文件编制审核“的数量及预算金额
        List<String> wjsh = new ArrayList<>();
        wjsh.add(PmProjectStatus.PROCUREMENT_DOCUMENTS_REVIEW.getCode());
        pmDemandReqVo.setProjectStatusList(wjsh);
        StatisticalChartsResVo resVo2 = pmDemandMapper.countProjectExceedAndStatus(pmDemandReqVo);
        resVo2.setColumnName("采购文件编制审核");
        resVos.add(resVo2);
        //3.标前质疑
        List<String> bqzy = new ArrayList<>();
        bqzy.add(PmProjectStatus.PRE_BID_QUERY.getCode());
        pmDemandReqVo.setProjectStatusList(bqzy);
        StatisticalChartsResVo resVo3 = pmDemandMapper.countProjectExceedAndStatus(pmDemandReqVo);
        resVo3.setColumnName("标前质疑投诉");
        resVos.add(resVo3);
        //4、 待开标
        List<String> dkb = new ArrayList<>();
        dkb.add(PmProjectStatus.WAIT_OPEN_BID.getCode());
        pmDemandReqVo.setProjectStatusList(dkb);
        StatisticalChartsResVo resVo4 = pmDemandMapper.countProjectExceedAndStatus(pmDemandReqVo);
        resVo4.setColumnName("待开标");
        resVos.add(resVo4);
        //5、 流废标处置
        List<String> lfb = new ArrayList<>();
        lfb.add(PmProjectStatus.WASTE_BID_HANDLE.getCode());
        pmDemandReqVo.setProjectStatusList(lfb);
        StatisticalChartsResVo resVo5 = pmDemandMapper.countProjectExceedAndStatus(pmDemandReqVo);
        resVo5.setColumnName("流废标处置");
        resVos.add(resVo5);
        //6、 标后质疑
        List<String> bhzy = new ArrayList<>();
        bhzy.add(PmProjectStatus.POST_BID_QUERY.getCode());
        pmDemandReqVo.setProjectStatusList(bhzy);
        StatisticalChartsResVo resVo6 = pmDemandMapper.countProjectExceedAndStatus(pmDemandReqVo);
        resVo6.setColumnName("标后质疑");
        resVos.add(resVo6);

        return AjaxResult.success(resVos);
    }

    @Override
    public AjaxResult countPurTask(PmDemandReqVo pmDemandReqVo) {
        List<StatisticalChartsResVo> resVos = new ArrayList<>();
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        //1、所属采购服务站数量
        //查询现有的采购服务站
        SysDictData dictData = new SysDictData();
        dictData.setDictType("purchase_services");
        List<SysDictData> servicesData = dictDataService.selectDictDataList(dictData);
        StatisticalChartsResVo resVo = new StatisticalChartsResVo();
        resVo.setColumnName("所属采购服务站数量");
        resVo.setNum(servicesData.size());
        resVos.add(resVo);
        //2、所属采购机构--根据招标代理机构管理中的白名单数据显示
        StatisticalChartsResVo resVo2 = pmDemandMapper.countBaseAgencyWithWhite();
        resVo2.setColumnName("所属采购机构");
        resVos.add(resVo2);
        //3、新受领集中采购数量--状态为“任务待下达”之后的数据
        StatisticalChartsResVo resVo3 = pmDemandMapper.JZCGnum(pmDemandReqVo);
        resVo3.setColumnName("新受领集中采购数量");
        resVos.add(resVo3);
        //4、上年度结转任务数量  上年度“任务待下达”之后，“合同待填制”之前的状态的数据
        List<String> snzj = new ArrayList<>();
        snzj.add(PmProjectStatus.TASK_WAIT_RELEASE.getCode());
        snzj.add(PmProjectStatus.PURCHASE_DEMAND_DOCKING.getCode());
        snzj.add(PmProjectStatus.EXPERT_FEEDBACK.getCode());
        snzj.add(PmProjectStatus.PROCUREMENT_DOCUMENTS_REVIEW.getCode());
        snzj.add(PmProjectStatus.PROCUREMENT_ANNOUNCEMENT.getCode());
        snzj.add(PmProjectStatus.PRE_BID_QUERY.getCode());
        snzj.add(PmProjectStatus.WAIT_OPEN_BID.getCode());
        snzj.add(PmProjectStatus.BID_RESULT_ANNOUNCEMENT.getCode());
        snzj.add(PmProjectStatus.WASTE_BID_HANDLE.getCode());
        pmDemandReqVo.setProjectStatusList(snzj);
        StatisticalChartsResVo resVo4 = pmDemandMapper.countProjecReaAndStatus(pmDemandReqVo);
        resVo4.setColumnName("上年度结转任务数量");
        resVos.add(resVo4);
        return AjaxResult.success(resVos);
    }

    @Override
    public AjaxResult countMajorProjectNumCGB(PmDemandReqVo pmDemandReqVo) {
        //新增执行滞后采购任务数量分析 所有的超过计划完成采购时间的数据
        //是-1就是查询自己及子孙级以下，否则只查询指定部门
        if (pmDemandReqVo.getPurchaseDeptId().equals(-1)) {
            pmDemandReqVo.setDeptList(isQueryAll(pmDemandReqVo.getPurchaseDeptId()));
        } else {
            pmDemandReqVo.setDemandIdAll(isQueryZD(pmDemandReqVo.getPurchaseDeptId()));
        }
        HashMap<String, List<StatisticalChartsResVo>> resMap = new HashMap<>();
        // 查询数据库中最小的年份
        int minYear = pmDemandMapper.selectMinYear();
        // 获取当前年份
        Calendar calendar = Calendar.getInstance();
        int thisYear = calendar.get(Calendar.YEAR);
        List<StatisticalChartsResVo> resVos = new LinkedList<>();
        for (int i = minYear; i <= thisYear; i++) {
            pmDemandReqVo.setYear(i);
            StatisticalChartsResVo byYear = pmDemandMapper.countProjectACT_Year(pmDemandReqVo);
            resVos.add(byYear);
        }
        if (pmDemandReqVo.getTimeType().equals("1")) {
            resMap.put("年", resVos);
        } else if (pmDemandReqVo.getTimeType().equals("2")) {
            List<StatisticalChartsResVo> byQuarter = new LinkedList<>();
            for (StatisticalChartsResVo chartsResVo : resVos) {
                pmDemandReqVo.setYear(Integer.parseInt(chartsResVo.getColumnName()));
                for (int i = 1; i <= 4; i++) {
                    pmDemandReqVo.setQuarter(i);
                    StatisticalChartsResVo quarter = pmDemandMapper.countProjectACT_Qua(pmDemandReqVo);
                    if (ObjectUtils.isEmpty(quarter)) {
                        StatisticalChartsResVo vo = new StatisticalChartsResVo("", "", 0, BigDecimal.valueOf(0), BigDecimal.valueOf(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<StatisticalChartsResVo> byMonth = new LinkedList<>();
            for (StatisticalChartsResVo chartsResVo : resVos) {
                pmDemandReqVo.setYear(Integer.parseInt(chartsResVo.getColumnName()));
                for (int i = 1; i <= 12; i++) {
                    pmDemandReqVo.setMonth(i);
                    StatisticalChartsResVo month = pmDemandMapper.countProjectACT_Mon(pmDemandReqVo);
                    if (ObjectUtils.isEmpty(month)) {
                        StatisticalChartsResVo vo = new StatisticalChartsResVo("", "", 0, BigDecimal.valueOf(0), BigDecimal.valueOf(0));
                        month = vo;
                        month.setColumnName(chartsResVo.getColumnName() + "年" + i + "月");
                    }
                    month.setColumnName(chartsResVo.getColumnName() + "年" + i + "月");
                    byMonth.add(month);
                }
            }
            resMap.put("月", byMonth);
        }
        return AjaxResult.success(resMap);
    }

    //查询不同状态下的项目数据
    public List<PmDemand> getListByStatus(String projectStatus) {
        LambdaQueryWrapper<PmDemand> lw = new LambdaQueryWrapper<PmDemand>();
        //需求待提交时不用查审核
        if (!projectStatus.equals("5")) {
            List<PmAuditDeptRef> list = new ArrayList<>();
            LambdaQueryWrapper<PmAuditDeptRef> l = new LambdaQueryWrapper<>();
            l.eq(PmAuditDeptRef::getDeptId, SecurityUtils.getDeptId());
            l.eq(PmAuditDeptRef::getRefType, "2");
            list = pmAuditDeptRefService.list(l);
            if (!ObjectUtils.isEmpty(list) && !SysUser.isAdmin(SecurityUtils.getUserId())) {
                lw.in(PmDemand::getDemandId, list.stream().map(PmAuditDeptRef::getRefId).collect(Collectors.toList()));
            }
        }
        lw.eq(PmDemand::getProjectStatus, projectStatus);
        lw.eq(PmDemand::getPurchaseDeptId, SecurityUtils.getDeptId());
        lw.last(" order by project_status, plan_demand_sub_time");
        return this.baseMapper.selectList(lw);
    }

    //查询不同状态下的项目数据
    public List<PmDemand> getListByStatusTotal(List<String> projectStatus) {
        LambdaQueryWrapper<PmDemand> lw = new LambdaQueryWrapper<PmDemand>();
        //  4 (合同信息管理)、 0(需求单位管理) 、 5(项目建设管理)  需求单位
        //  1(需求需求审核) 、2 (任务下达管理)      采购管理部门
        //  3(采购执行管理)   采购办
        List<PmAuditDeptRef> list = new ArrayList<>();
        LambdaQueryWrapper<PmAuditDeptRef> l = new LambdaQueryWrapper<>();
        l.eq(PmAuditDeptRef::getDeptId, SecurityUtils.getDeptId());
        l.eq(PmAuditDeptRef::getRefType, "2");
        list = pmAuditDeptRefService.list(l);
        if (!ObjectUtils.isEmpty(list) && !SysUser.isAdmin(SecurityUtils.getUserId())) {
            lw.in(PmDemand::getDemandId, list.stream().map(PmAuditDeptRef::getRefId).collect(Collectors.toList()));
        }
        lw.in(PmDemand::getProjectStatus, projectStatus);
        lw.eq(PmDemand::getPurchaseDeptId, SecurityUtils.getDeptId());
        lw.last(" order by project_status, plan_demand_sub_time");
        return this.baseMapper.selectList(lw);
    }

    //数据转换
    @Override
    public List<PmDemandResVo> listToVoList(List<PmDemand> demandList) {
        List<PmDemandResVo> pmDemandResponseVoList = new ArrayList<>();
        if (!ObjectUtils.isEmpty(demandList) && demandList.size() > 0) {
            pmDemandResponseVoList = demandChangeTo(demandList);
        }
        return pmDemandResponseVoList;
    }

    //查询不同状态下的项目数据的数量
    @Override
    public Integer getNumByStatus(String projectStatus) {
        LambdaQueryWrapper<PmDemand> lw = new LambdaQueryWrapper<PmDemand>();
        ///需求待提交时不用查审核
        if (!projectStatus.equals("5")) {
            List<PmAuditDeptRef> list = new ArrayList<>();
            LambdaQueryWrapper<PmAuditDeptRef> l = new LambdaQueryWrapper<>();
            l.eq(PmAuditDeptRef::getDeptId, SecurityUtils.getDeptId());
            l.eq(PmAuditDeptRef::getRefType, "2");
            list = pmAuditDeptRefService.list(l);
            if (!ObjectUtils.isEmpty(list) && !SysUser.isAdmin(SecurityUtils.getUserId())) {
                lw.in(PmDemand::getDemandId, list.stream().map(PmAuditDeptRef::getRefId).collect(Collectors.toList()));
            }
        }
        lw.eq(PmDemand::getProjectStatus, projectStatus);
        lw.eq(PmDemand::getPurchaseDeptId, SecurityUtils.getDeptId());
        lw.last(" order by project_status, plan_demand_sub_time");
        Long count = this.baseMapper.selectCount(lw);
        return Math.toIntExact(count);
    }

    //字段转换and赋值
    public List<PmDemandResVo> demandChangeTo(List<PmDemand> pmDemandList) {
        List<PmDemandResVo> pmDemandResponseVoList = new ArrayList<>();
        //获取字典数据
        HashMap<String, HashMap<String, String>> planEnums = dictTypeService.getAboutEnums();
        //项目属性
        HashMap<String, String> projectAttributes = planEnums.get("projectAttributes");
        //提前或延后*天进行提醒
        List<SysDictData> alertTime = dictTypeService.selectDictDataByType("alert_time_setting");
        HashMap<String, String> alertTimeMap = new LinkedHashMap<>();
        //根据时间类别设定的提醒时间
        for (SysDictData dictData : alertTime) {
            //    字段名称----阈值
            alertTimeMap.put(dictData.getDictLabel(), dictData.getDictValue());
        }
        for (PmDemand pmDemand1 : pmDemandList) {
            PmDemandResVo vo = new PmDemandResVo();
            BeanUtils.copyProperties(pmDemand1, vo);
            if (vo.getPurchaseDeptId() != null) {
                Map<String, Object> 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;
                }
            }
            //项目属性为value拼接
            if (!ObjectUtils.isEmpty(vo.getProjectAttr())) {
                if (vo.getProjectAttr().length() > 1) {
                    StringBuilder builder = new StringBuilder();
                    String[] split = vo.getProjectAttr().split(",");
                    for (String s : split) {
                        for (Map.Entry<String, String> entry : projectAttributes.entrySet()) {
                            if (s.equals(entry.getValue())) {
                                if (!vo.getProjectAttr().endsWith(s)) {
                                    builder.append(entry.getKey() + ",");
                                } else {
                                    builder.append(entry.getKey());
                                }
                                break;
                            }
                        }
                    }
                    vo.setProjectAttrName(builder.toString());
                } else {
                    for (Map.Entry<String, String> entry : projectAttributes.entrySet()) {
                        if (vo.getProjectAttr().equals(entry.getValue())) {
                            vo.setProjectAttrName(entry.getKey());
                            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, alertTimeMap));
                if (vo.getTipsMessage().contains("超过")) {
                    vo.setIsExceedProject("1");
                    if (ObjectUtils.isEmpty(pmDemand1.getDelayReason())) {
                        //没有原因就可以填写滞后原因
                        vo.setIsWriteExceed("1");
                    }
                }
            } catch (ParseException e) {
                e.printStackTrace();
            }
            pmDemandResponseVoList.add(vo);
        }
        return pmDemandResponseVoList;
    }

    /**
     * 根据年度计划提报时间的阈值进行提示
     *
     * @return
     */
    public String pmDemandGetTips(PmDemandResVo vo, HashMap<String, String> alertTimeMap) throws ParseException {
        //首页待办事项--计划完成采购时间提醒
        if (ObjectUtils.isEmpty(vo.getRealDemandCommitTime())) {
            int alertDay2 = Integer.parseInt(alertTimeMap.get("计划提报时间"));
            Integer alertTime = 1000 * 60 * 60 * 24 * alertDay2;
            double surplusTwo = vo.getPlanDemandSubTime().getTime() - System.currentTimeMillis();
            //少于设定阈值便提醒
            if (surplusTwo < alertTime) {
                //剩余天数(向上取整)
                int i = (int) Math.ceil(surplusTwo / 1000 / 60 / 60 / 24);
                if (i > 0) {
                    return "距离计划提报时间不足" + i + "天";
                } else {
                    return "已超过计划提报时间" + Math.abs(i) + "天";
                }
            }
        }
        //首页待办事项--计划完成采购时间提醒
        if (ObjectUtils.isEmpty(vo.getRealPurchaseFinishTime())) {
            int alertDay2 = Integer.parseInt(alertTimeMap.get("计划完成时间"));
            Integer alertTime = 1000 * 60 * 60 * 24 * alertDay2;
            double surplusTwo = vo.getPlanPurchaseFinishTime().getTime() - System.currentTimeMillis();
            //少于设定阈值便提醒
            if (surplusTwo < alertTime) {
                //剩余天数(向上取整)
                int i = (int) Math.ceil(surplusTwo / 1000 / 60 / 60 / 24);
                if (i > 0) {
                    return "距离计划完成采购时间不足" + i + "天";
                } else {
                    return "已超过计划完成采购时间" + Math.abs(i) + "天";
                }
            }
        }
        //首页待办事项--计划交付时间提醒
        if (ObjectUtils.isEmpty(vo.getRealDeliverTime())) {
            Date deliverTime = vo.getPlanDeliverTime();
            int alertDay = Integer.parseInt(alertTimeMap.get("计划交付(实施)时间"));
            Integer remindTine = 1000 * 60 * 60 * 24 * alertDay;
            double surplus = deliverTime.getTime() - System.currentTimeMillis();
            if (surplus < remindTine) {
                //剩余天数(向上取整)
                int i = (int) Math.ceil(surplus / 1000 / 60 / 60 / 24);
                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);
    }

    //查询本单位及本级一下全部
    public List<Long> isQueryAll(Integer queryAll) {
        List<Long> deptList = new ArrayList<>();
        Long deptId = SecurityUtils.getDeptId();
        //查询全部
        if (queryAll.equals(-1)) {
            //获取到子孙级部门id
            if (deptService.hasChildByDeptId(SecurityUtils.getDeptId())) {
                List<Long> children = deptService.getDeptChildren(deptId);
                System.err.println(children.size());
                deptList.addAll(children);
            }
            deptList.add(deptId);
        }
        return deptList;
    }

    //查询本单位还是本单位及子孙级----要查询子单位的超额数据
    @Override
    public List<Long> isQueryZD(Integer queryZd) {
        //指定部门--以及子单位的超额数据
        List<Long> demandId = new ArrayList<>();
        //先获取本部门的项目
        LambdaQueryWrapper<PmDemand> ld = new LambdaQueryWrapper<>();
        ld.eq(PmDemand::getPurchaseDeptId, queryZd);
        //本部门的项目
        List<PmDemand> deList = pmDemandMapper.selectList(ld);
        for (PmDemand demand : deList) {
            demandId.add(demand.getDemandId());
        }
        if (deptService.hasChildByDeptId(Long.valueOf(queryZd))) {
            //获取子级部门d
            List<Long> childByDeptId = deptService.getChildIdByDeptId(Long.valueOf(queryZd));
            //取出所有可以进行统计的项目id
            for (Long cid : childByDeptId) {
                LambdaQueryWrapper<PmAuditDeptRef> ll = new LambdaQueryWrapper<>();
                ll.eq(PmAuditDeptRef::getDeptId, cid);
                ll.eq(PmAuditDeptRef::getRefType, "2");
                //子部门参加审核的项目
                List<PmAuditDeptRef> refList = pmAuditDeptRefService.list(ll);
                //同一个数据有上级参与说明是超额
                for (PmAuditDeptRef ref : refList) {
                    //获取上级并查询是否参与审核
                    SysDept dept = deptService.selectByCid(ref.getDeptId());
                    //是否参与审核
                    LambdaQueryWrapper<PmAuditDeptRef> pp = new LambdaQueryWrapper<>();
                    ll.eq(PmAuditDeptRef::getDeptId, dept.getDeptId());
                    ll.eq(PmAuditDeptRef::getRefId, ref.getRefId());
                    //取出父级部门参加审核的项目（超额项目）
                    List<PmAuditDeptRef> refListP = pmAuditDeptRefService.list(pp);
                    if (!ObjectUtils.isEmpty(refListP)) {
                        demandId.add(ref.getRefId());
                    }
                }
            }
        }
        return demandId;
    }


}