cbjs-mvue-master/assistMg/src/main/java/com/hotent/project/manager/impl/CostProjectTaskManagerImpl.java

package com.hotent.project.manager.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.hotent.base.manager.impl.BaseManagerImpl;
import com.hotent.base.util.AuthenticationUtil;
import com.hotent.base.util.StringUtil;
import com.hotent.baseInfo.req.CostTaskSearchReq;
import com.hotent.constant.NodeConstant;
import com.hotent.constant.TaskStatusConstant;
import com.hotent.enterpriseDeclare.req.CostTaskPageReq;
import com.hotent.enterpriseDeclare.req.CostTaskReviewPageReq;
import com.hotent.project.dao.CostProjectTaskDao;
import com.hotent.project.manager.*;
import com.hotent.project.model.CostProjectApproval;
import com.hotent.project.model.CostProjectTask;
import com.hotent.project.model.CostProjectTaskMaterial;
import com.hotent.project.model.CostProjectTaskPreliminaryOpinion;
import com.hotent.project.resp.CostProjectApprovalDetailResp;
import com.hotent.surveyinfo.manager.CostSurveyTemplateUploadManager;
import com.hotent.surveyinfo.model.CostSurveyTemplateUpload;
import com.hotent.uc.api.model.IUser;
import com.hotent.uc.manager.UserManager;
import com.hotent.uc.model.User;
import com.hotent.uc.util.ContextUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;

/**
 * 项目任务表 服务实现类
 *
 * @author 超级管理员
 * @company 山西清众科技股份有限公司
 * @since 2025-10-03
 */
@Service
public class CostProjectTaskManagerImpl extends BaseManagerImpl<CostProjectTaskDao, CostProjectTask> implements CostProjectTaskManager {


    @Autowired
    private CostProjectTaskProccessManager costProjectTaskProccessManager;

    @Autowired
    private CostProjectTaskManager costProjectTaskManager;

    @Autowired
    private CostNoticeManager costNoticeManager;

    @Autowired
    private CostProjectApprovalManager costProjectApprovalManager;

    @Autowired
    private CostProjectTaskPreliminaryOpinionManager preliminaryOpinionManager;

    @Autowired
    private UserManager userService;

    @Autowired
    private CostProjectTaskMaterialManager costProjectTaskMaterialManager;

    @Autowired
    private CostSurveyTemplateUploadManager costSurveyTemplateUploadManager;

    @Autowired
    private CostProjectTaskLogManager costProjectTaskLogManager;



    @Override
    public List<CostProjectTask> getTaskList(CostTaskSearchReq req) throws Exception {
        IUser iUser = ContextUtil.getCurrentUser();
        User user = userService.getByAccount(iUser.getAccount());
        req.setDataScope(user.getDataScope());
        req.setProvinceCode(user.getProvinceCode());
        req.setCityCode(user.getCityCode());
        req.setCountyCode(user.getCountyCode());
        List<CostProjectTask> list = baseMapper.getCostProjectTaskList(req.getDataScope()
                , req.getProvinceCode()
                , req.getCityCode()
                , req.getCountyCode()
                , req.getYear()
                , req.getProjectName());
        /*LambdaQueryWrapper<CostProjectTask> queryWrapper = new LambdaQueryWrapper<>();
        if (ObjectUtil.isNotEmpty(req.getYear())) {
            queryWrapper.eq(CostProjectTask::getYear, req.getYear());
        }
        if (ObjectUtil.isNotEmpty(req.getProjectName())) {
            queryWrapper.like(CostProjectTask::getProjectName, req.getProjectName());
        }
        queryWrapper.eq(CostProjectTask::getIsDeleted, BaseConstant.NORMAL_STATUS);

        List<CostProjectTask> list = this.list(queryWrapper);*/

        return list;
    }

    @Override
    public IPage<CostProjectTask> pageListForReviewTask(CostTaskReviewPageReq req) {
        // 获取当前用户
        IUser currentUser = ContextUtil.getCurrentUser();
        String currentUserId = currentUser.getUserId();

        // 1. 先查询当前用户有权限的立项（负责人或项目组成员）
        LambdaQueryWrapper<CostProjectApproval> approvalQueryWrapper = new LambdaQueryWrapper<>();
        approvalQueryWrapper.eq(CostProjectApproval::getIsDeleted, "0");
        approvalQueryWrapper.and(wrapper -> wrapper
                .eq(CostProjectApproval::getLeaderId, currentUserId)
                .or(projectMembersWrapper -> {
                    projectMembersWrapper.like(CostProjectApproval::getProjectMembers, currentUserId);
                })
        );

        List<CostProjectApproval> accessibleApprovals = costProjectApprovalManager.list(approvalQueryWrapper);

        // 如果没有权限的立项，返回空结果
        if (accessibleApprovals.isEmpty()) {
            return new Page<>(req.getPageNum(), req.getPageSize());
        }

        // 提取有权限的立项ID列表
        List<String> accessibleProjectIds = accessibleApprovals.stream()
                .map(CostProjectApproval::getProjectId)
                .distinct()
                .collect(java.util.stream.Collectors.toList());

        // 2. 构建任务查询条件
        LambdaQueryWrapper<CostProjectTask> queryWrapper = new LambdaQueryWrapper<>();

        // 查询未删除的记录
        queryWrapper.eq(CostProjectTask::getIsDeleted, "0");

        // 查询根任务（pid为0）
        queryWrapper.eq(CostProjectTask::getPid, "0");

        // 只查询当前用户有权限的立项对应的任务
        queryWrapper.in(CostProjectTask::getProjectId, accessibleProjectIds);

        // 根据请求参数添加查询条件
        if (StringUtil.isNotEmpty(req.getProjectName())) {
            queryWrapper.like(CostProjectTask::getProjectName, req.getProjectName());
        }
        if (StringUtil.isNotEmpty(req.getAuditedUnitName())) {
            queryWrapper.like(CostProjectTask::getAuditedUnitName, req.getAuditedUnitName());
        }
        if (StringUtil.isNotEmpty(req.getStatus())) {
            queryWrapper.eq(CostProjectTask::getStatus, req.getStatus());
        }
        if (StringUtil.isNotEmpty(req.getCurrentNode())) {
            // 如果指定了节点，按节点查询
            queryWrapper.eq(CostProjectTask::getCurrentNode, req.getCurrentNode());
        } else {
            // 如果没有指定节点，默认排除归档节点（待审核列表）
            queryWrapper.ne(CostProjectTask::getCurrentNode, NodeConstant.guidang.getNodeKey());
        }

        // 按创建时间倒序排列
        queryWrapper.orderByDesc(CostProjectTask::getCreateTime);

        // 创建分页对象并执行查询
        Page<CostProjectTask> page = new Page<>(req.getPageNum(), req.getPageSize());
        IPage<CostProjectTask> result = costProjectTaskManager.page(page, queryWrapper);

        // 填充根任务的子任务列表和流程信息
        for (CostProjectTask rootTask : result.getRecords()) {
            // 查询子任务列表
            LambdaQueryWrapper<CostProjectTask> childQueryWrapper = new LambdaQueryWrapper<>();
            childQueryWrapper.eq(CostProjectTask::getPid, rootTask.getId())
                    .eq(CostProjectTask::getIsDeleted, "0")
                    .orderByAsc(CostProjectTask::getOrderNum);

            List<CostProjectTask> childTasks = costProjectTaskManager.list(childQueryWrapper);
            for (CostProjectTask childTask : childTasks) {
                childTask.setStatusName(TaskStatusConstant.getStatusNameByCode(childTask.getStatus()));
                CostProjectApprovalDetailResp detail = costProjectApprovalManager.getDetail(childTask.getProjectId());
                childTask.setCatalogId(detail.getCatalogId());
            }
            rootTask.setStatusName(TaskStatusConstant.getStatusNameByCode(rootTask.getStatus()));
            rootTask.setChildTasks(childTasks);
            rootTask.setCurrentNodeName(NodeConstant.getNodeValueByKey(rootTask.getCurrentNode()));
            CostProjectApprovalDetailResp detail = costProjectApprovalManager.getDetail(rootTask.getProjectId());
            rootTask.setCatalogId(detail.getCatalogId());
        }

        return result;
    }

    @Override
    public IPage<CostProjectTask> pageListForArchive(CostTaskReviewPageReq req) {
        // 获取当前用户
        IUser currentUser = ContextUtil.getCurrentUser();
        String currentUserId = currentUser.getUserId();

        // 1. 先查询当前用户有权限的立项（负责人或项目组成员）
        LambdaQueryWrapper<CostProjectApproval> approvalQueryWrapper = new LambdaQueryWrapper<>();
        approvalQueryWrapper.eq(CostProjectApproval::getIsDeleted, "0");
        approvalQueryWrapper.and(wrapper -> wrapper
                .eq(CostProjectApproval::getLeaderId, currentUserId)
                .or(projectMembersWrapper -> {
                    projectMembersWrapper.like(CostProjectApproval::getProjectMembers, currentUserId);
                })
        );

        List<CostProjectApproval> accessibleApprovals = costProjectApprovalManager.list(approvalQueryWrapper);

        // 如果没有权限的立项，返回空结果
        if (accessibleApprovals.isEmpty()) {
            return new Page<>(req.getPageNum(), req.getPageSize());
        }

        // 提取有权限的立项ID列表
        List<String> accessibleProjectIds = accessibleApprovals.stream()
                .map(CostProjectApproval::getProjectId)
                .distinct()
                .collect(java.util.stream.Collectors.toList());

        // 2. 构建任务查询条件
        LambdaQueryWrapper<CostProjectTask> queryWrapper = new LambdaQueryWrapper<>();

        // 查询未删除的记录
        queryWrapper.eq(CostProjectTask::getIsDeleted, "0");

        // 查询主任务（pid为0）
        queryWrapper.eq(CostProjectTask::getPid, "0");

        // 只查询当前用户有权限的立项对应的任务
        queryWrapper.in(CostProjectTask::getProjectId, accessibleProjectIds);

        // 根据请求参数添加查询条件
        if (StringUtil.isNotEmpty(req.getProjectName())) {
            queryWrapper.like(CostProjectTask::getProjectName, req.getProjectName());
        }
        if (StringUtil.isNotEmpty(req.getAuditedUnitName())) {
            queryWrapper.like(CostProjectTask::getAuditedUnitName, req.getAuditedUnitName());
        }
        if (StringUtil.isNotEmpty(req.getStatus())) {
            queryWrapper.eq(CostProjectTask::getStatus, req.getStatus());
        }
        // 根据是否归档字段过滤
        if (StringUtil.isNotEmpty(req.getIsGd())) {
            queryWrapper.eq(CostProjectTask::getIsGd, req.getIsGd());
        }

        // 按创建时间倒序排列
        queryWrapper.orderByDesc(CostProjectTask::getCreateTime);

        // 创建分页对象并执行查询
        Page<CostProjectTask> page = new Page<>(req.getPageNum(), req.getPageSize());
        IPage<CostProjectTask> result = costProjectTaskManager.page(page, queryWrapper);

        // 只填充节点名称，不查询子任务
        for (CostProjectTask rootTask : result.getRecords()) {
            rootTask.setCurrentNodeName(NodeConstant.getNodeValueByKey(rootTask.getCurrentNode()));
        }

        return result;
    }

    @Override
    @Transactional
    public void createOrUpdate(CostProjectTask costProjectTask) {
        //新建或更新
        this.saveOrUpdate(costProjectTask);
    }

    @Override
    @Transactional
    public String saveTask(CostTaskPageReq costTaskPageReq) {
        // 1.校验内容是否填写完毕！t
        List<CostProjectTaskMaterial> costProjectTaskMaterials = costProjectTaskMaterialManager.listByTaskId(costTaskPageReq.getTaskId());
        boolean c = costProjectTaskMaterials.stream()
                .filter(item ->"1".equals(item.getIsRequired()))
                .allMatch(
                item -> "1".equals(item.getIsUpload())
        );
        if (!c) {
            throw new RuntimeException("报送资料必填文件未全部填写完成！");
        }
        List<CostSurveyTemplateUpload> costSurveyTemplateUploads = costSurveyTemplateUploadManager.listByTaskId(costTaskPageReq.getTaskId());
        boolean d = costSurveyTemplateUploads.stream()
                .filter(item ->"1".equals(item.getIsRequired()))
                .allMatch(
                        item -> "1".equals(item.getIsUpload())
        );
        if (!d) {
            throw new RuntimeException("成本调查必填文件未全部填写完成！");
        }
        // 2. 子流程状态改为审核中
        CostProjectTask task = this.getById(costTaskPageReq.getTaskId());
        task.setCurrentNode(NodeConstant.clcs.getNodeKey());
        task.setStatus(TaskStatusConstant.AUDITING.getStatusCode());
        this.updateById(task);

        return "任务提交成功，已进入材料初审阶段";
    }

    @Override
    public String saveYjTask(CostProjectTaskPreliminaryOpinion costProjectTaskPreliminaryOpinion) {
        // 1.校验内容是否填写完毕！todo

        preliminaryOpinionManager.createOrUpdate(costProjectTaskPreliminaryOpinion);
        // 3. 子流程状态改为已反馈
        CostProjectTask task = this.getById(costProjectTaskPreliminaryOpinion.getTaskId());
        task.setStatus(TaskStatusConstant.FEEDBACKED.getStatusCode());
        this.updateById(task);

        return "意见反馈完成";

    }

    @Override
    public String doProcessBtn(CostTaskPageReq req) {

        CostProjectTask task = costProjectTaskManager.getById(req.getTaskId());
        String resultMessage = "";
        switch (req.getKey()) {
            case "1":
                // 补充材料
                resultMessage = supplementMaterial(task, req);
                break;
            case "2":
                // 中止/恢复
                resultMessage = suspendTask(task, req);
                break;
            case "3":
                // 通过
                resultMessage = completeTask(task);
                break;
            case "4":
                // 退回
                resultMessage = returnToSubmit(task, req);
                break;
            case "6":
                // 退回上一步
                resultMessage = backPreToSubmit(task, req);
                break;
            case "7":
                // 扭转下一步
                resultMessage = toNextSubmit(task, req);
                break;
            default:
                return "未知的操作类型";
        }
        return resultMessage;
    }

    /**
     * 通过，填写原因 修改状态
     */
    private String completeTask(CostProjectTask task) {
        CostProjectTask nTask = costProjectTaskManager.getById(task.getId());
        if (nTask == null) {
            return "任务不存在";
        }

        List<CostProjectTask> children = costProjectTaskManager.list(
                new LambdaQueryWrapper<CostProjectTask>()
                        .eq(CostProjectTask::getPid, nTask.getId())
        );
        if (children.isEmpty()) {
            // 子任务 所有“是否必填”为“是”的资料“初审结果”均为“通过”.
            List<CostProjectTaskMaterial> costProjectTaskMaterials = costProjectTaskMaterialManager.listByTaskId(nTask.getId());
            boolean c = costProjectTaskMaterials.stream()
                    .filter(item -> "1".equals(item.getIsRequired()))
                    .allMatch(
                    item -> "1".equals(item.getAuditedStatus())
            );
            if (!c) {
                throw new RuntimeException("报送资料未全部通过！");
            }
            List<CostSurveyTemplateUpload> costSurveyTemplateUploads = costSurveyTemplateUploadManager.listByTaskId(nTask.getId());
            boolean d = costSurveyTemplateUploads.stream()
                    .filter(item -> "1".equals(item.getIsRequired()))
                    .allMatch(
                            item -> "1".equals(item.getAuditedStatus())
            );
            if (!d) {
                throw new RuntimeException("成本调查表未全部通过！");
            }
        } else {
            // 主任务
            boolean b = children.stream().noneMatch(child ->
                    child.getStatus().equals(TaskStatusConstant.AUDITING.getStatusCode()));
            if (!b) {
                throw new RuntimeException("子任务未全部办理，主任务无法办结");
            }
        }
        task.setStatus(TaskStatusConstant.COMPLETED.getStatusCode());
        costProjectTaskManager.updateById(task);

        // 发送通知
        String title = NodeConstant.getNodeValueByKey(task.getCurrentNode()) + "通过";
        // 操作人
        String content = "[" + NodeConstant.getNodeValueByKey(task.getCurrentNode()) + "]" + AuthenticationUtil.getCurrentUserFullname() + "已通过" + task.getAuditedUnitName() + "的项目(" + task.getProjectName() + ")";
        String enterpriseId = task.getAuditedUnitId() == null ? "" : task.getAuditedUnitId();
        String noticeSource = "系统";
        String sendTarget = task.getCreateBy() == null ? "" : task.getCreateBy();
        costNoticeManager.sendNotice(task.getProjectId(), task.getId(), "1", title, content, enterpriseId, noticeSource, sendTarget);

        return title;
    }

    /**
     * 退回，填写原因 修改状态
     */
    private String returnToSubmit(CostProjectTask task, CostTaskPageReq req) {
        switch (req.getProcessNodeKey()) {
            case "sdsh":
                throw new RuntimeException("当前节点无法退回");
            default:
                // 通知内容组装
                String title = NodeConstant.getNodeValueByKey(task.getCurrentNode()) + "退回";
                String enterpriseId = task.getAuditedUnitId() == null ? "" : task.getAuditedUnitId();
                String noticeSource = "系统";
                String sendTarget = task.getCreateBy() == null ? "" : task.getCreateBy();

                String content = "[" + NodeConstant.getNodeValueByKey(task.getCurrentNode()) + "]" + AuthenticationUtil.getCurrentUserFullname() + "已退回" + task.getAuditedUnitName() + "的项目(" + task.getProjectName() + ")";
                costNoticeManager.sendNotice(task.getProjectId(), task.getId(), "1", title, content, enterpriseId, noticeSource, sendTarget);

                // 更新任务的当前节点和状态
                task.setStatus(TaskStatusConstant.NOT_PASSED.getStatusCode());
                costProjectTaskManager.updateById(task);

                return title;
        }

    }

    /**
     * 中止，填写原因 修改状态
     */
    private String suspendTask(CostProjectTask task, CostTaskPageReq req) {

        // 更新任务状态为中止/恢复
        String status = req.getStatus() == null ? TaskStatusConstant.SUSPENDED.getStatusCode() : TaskStatusConstant.AUDITING.getStatusCode();
        task.setStatus(status);
        costProjectTaskManager.updateById(task);

        // 通知内容组装
        String title = NodeConstant.getNodeValueByKey(task.getCurrentNode()) + TaskStatusConstant.getStatusNameByCode(status);
        String content = "[" + NodeConstant.getNodeValueByKey(task.getCurrentNode()) + "]" + AuthenticationUtil.getCurrentUserFullname() + "已" + TaskStatusConstant.getStatusNameByCode(status) + task.getAuditedUnitName() + "的项目(" + task.getProjectName() + ")";
        String enterpriseId = task.getAuditedUnitId() == null ? "" : task.getAuditedUnitId();
        String noticeSource = "系统";
        String sendTarget = task.getCreateBy() == null ? "" : task.getCreateBy();
        costNoticeManager.sendNotice(task.getProjectId(), task.getId(), "1", title, content, enterpriseId, noticeSource, sendTarget);

        return title;
    }

    /**
     * 补充材料，发送通知+修改任务状态
     */
    private String supplementMaterial(CostProjectTask task, CostTaskPageReq req) {
        String currentNode = task.getCurrentNode();
        String title = NodeConstant.getNodeValueByKey(currentNode) + TaskStatusConstant.BCCL.getStatusName();
        String noticeSource = "系统";

        switch (currentNode) {
            // 集体审议节点：支持指定多个子任务补充材料
            case "jtsy":
                if (StringUtil.isNotEmpty(req.getChildTaskId())) {
                    String[] childTaskIdArray = req.getChildTaskId().split(",");
                    List<String> unitNames = new java.util.ArrayList<>();

                    for (String childTaskId : childTaskIdArray) {
                        CostProjectTask childTask = costProjectTaskManager.getById(childTaskId);
                        if (childTask == null) {
                            throw new RuntimeException("子任务不存在：" + childTaskId);
                        }
                        // 验证子任务是否属于当前主任务
                        if (!childTask.getPid().equals(task.getId())) {
                            throw new RuntimeException("子任务不属于当前主任务：" + childTaskId);
                        }
                        // 更新子任务状态为补充材料
                        childTask.setStatus(TaskStatusConstant.BCCL.getStatusCode());
                        costProjectTaskManager.updateById(childTask);
                        // 通知内容组装（针对子任务对应的单位）
                        String childContent = "[" + NodeConstant.getNodeValueByKey(task.getCurrentNode()) + "]" + AuthenticationUtil.getCurrentUserFullname() + "要求" + childTask.getAuditedUnitName() + "补充材料，项目(" + task.getProjectName() + ")";
                        String childEnterpriseId = childTask.getAuditedUnitId() == null ? "" : childTask.getAuditedUnitId();
                        String childSendTarget = childTask.getCreateBy() == null ? "" : childTask.getCreateBy();
                        costNoticeManager.sendNotice(task.getProjectId(), task.getId(), "1", title, childContent, childEnterpriseId, noticeSource, childSendTarget);
                        // 收集单位名称
                        if (StringUtil.isNotEmpty(childTask.getAuditedUnitName())) {
                            unitNames.add(childTask.getAuditedUnitName());
                        }
                    }
                    // 返回结果，包含所有单位名称
                    String unitNamesStr = unitNames.isEmpty() ? "" : String.join("、", unitNames);
                    return title + "（单位：" + unitNamesStr + "）";
                }
            default:
                task.setStatus(TaskStatusConstant.BCCL.getStatusCode());
                costProjectTaskManager.updateById(task);
                String content = "[" + NodeConstant.getNodeValueByKey(task.getCurrentNode()) + "]" + AuthenticationUtil.getCurrentUserFullname() + "要求" + task.getAuditedUnitName() + "补充材料，项目(" + task.getProjectName() + ")";
                String enterpriseId = task.getAuditedUnitId() == null ? "" : task.getAuditedUnitId();
                String sendTarget = task.getCreateBy() == null ? "" : task.getCreateBy();
                costNoticeManager.sendNotice(task.getProjectId(), task.getId(), "1", title, content, enterpriseId, noticeSource, sendTarget);
                return title;
        }
    }

    /**
     * 退回上一步，填写原因 修改状态和节点
     */
    private String backPreToSubmit(CostProjectTask task, CostTaskPageReq req) {
        CostProjectTask nTask = costProjectTaskManager.getById(task.getId());
        if (nTask == null || !nTask.getPid().equals("0")) {
            throw new RuntimeException("当前节点无法退回");
        }

        // 获取退回后的上一节点
        NodeConstant prevNode = NodeConstant.getPrevNode(nTask.getCurrentNode());
        if (prevNode == null) {
            throw new RuntimeException("当前节点已是第一步，无法退回");
        }
        String prevNodeStatus = prevNode.getNodeKey();

        // 主任务退回上一步
        nTask.setStatus(TaskStatusConstant.AUDITING.getStatusCode());
        nTask.setCurrentNode(prevNodeStatus);
        costProjectTaskManager.updateById(nTask);

        // 子任务都要退回，并根据退回后的节点设置正确的状态
        List<CostProjectTask> children = costProjectTaskManager.list(
                new LambdaQueryWrapper<CostProjectTask>()
                        .eq(CostProjectTask::getPid, nTask.getId())
                        .eq(CostProjectTask::getIsDeleted, "0")
        );

        // 根据退回后的节点，设置子任务状态（参考completeTask的逻辑）
        String childStatus = "";
        switch (prevNodeStatus) {
            case "yjfk":
                childStatus = TaskStatusConstant.WAIT_FEEDBACK.getStatusCode();
                break;
            case "cjbg":
            case "jtsy":
                childStatus = TaskStatusConstant.COMPLETED.getStatusCode();
                break;
            default:
                childStatus = TaskStatusConstant.AUDITING.getStatusCode();
                break;
        }

        for (CostProjectTask child : children) {
            child.setStatus(childStatus);
            child.setCurrentNode(prevNodeStatus);
            costProjectTaskManager.updateById(child);
        }

        // 通知内容组装
        String title = NodeConstant.getNodeValueByKey(prevNodeStatus) + "退回上一步";
        String enterpriseId = task.getAuditedUnitId() == null ? "" : task.getAuditedUnitId();
        String noticeSource = "系统";
        String sendTarget = task.getCreateBy() == null ? "" : task.getCreateBy();
        costNoticeManager.sendNotice(task.getProjectId(), task.getId(), "1", title, req.getContent(), enterpriseId, noticeSource, sendTarget);

        return title;
    }

    /**
     * 扭转下一步，填写原因 修改状态和节点
     */
    private String toNextSubmit(CostProjectTask task, CostTaskPageReq req) {
        CostProjectTask nTask = costProjectTaskManager.getById(task.getId());
        if (nTask == null || !nTask.getPid().equals("0")) {
            throw new RuntimeException("当前节点无法扭转");
        }
        if (!task.getStatus().equals(TaskStatusConstant.COMPLETED.getStatusCode())) {
            throw new RuntimeException("请办结任务后，在进行扭转下一步");
        }
        // 子任务都办结才可以扭转
        List<CostProjectTask> children = costProjectTaskManager.list(
                new LambdaQueryWrapper<CostProjectTask>()
                        .eq(CostProjectTask::getPid, nTask.getId())
        );
        boolean b = children.stream().noneMatch(
                child -> child.getStatus().equals(TaskStatusConstant.AUDITING.getStatusCode()));
        if (!b) {
            throw new RuntimeException("子任务未全部办结，主任务无法扭转");
        }
        // 将当前任务置为办结
        String nextNodeStatus = NodeConstant.getNextNode(nTask.getCurrentNode()).getNodeKey();
        task.setStatus(TaskStatusConstant.AUDITING.getStatusCode());
        task.setCurrentNode(nextNodeStatus);
        nTask.setIsGd("0");
        costProjectTaskManager.updateById(task);
        // 如果所有子任务都办结，则将父子任务都扭转
        String status = "";
        switch (nextNodeStatus) {
            case "yjfk":
                status = TaskStatusConstant.WAIT_FEEDBACK.getStatusCode();
                break;
            case "jtsy":
                status = TaskStatusConstant.COMPLETED.getStatusCode();
                break;
            default:
                status = TaskStatusConstant.AUDITING.getStatusCode();
                break;
        }
        for (CostProjectTask child : children) {
            if (!child.getStatus().equals(TaskStatusConstant.SUSPENDED.getStatusCode())) {
                child.setStatus(status);
                child.setCurrentNode(nextNodeStatus);
                costProjectTaskManager.updateById(child);
            }

        }
        // 通知内容组装
        String title = NodeConstant.getNodeValueByKey(task.getCurrentNode()) + "扭转至下一步";
        String enterpriseId = task.getAuditedUnitId() == null ? "" : task.getAuditedUnitId();
        String noticeSource = "系统";
        String sendTarget = task.getCreateBy() == null ? "" : task.getCreateBy();
        costNoticeManager.sendNotice(task.getProjectId(), task.getId(), "1", title, req.getContent(), enterpriseId, noticeSource, sendTarget);

        return title;
    }

    @Override
    public Integer countForReviewTask(CostTaskReviewPageReq req) {

        LambdaQueryWrapper<CostProjectTask> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.eq(CostProjectTask::getIsDeleted, "0")
                .eq(CostProjectTask::getPid, "0")
        ;

        if (StringUtil.isNotEmpty(req.getCurrentNode())) {
            queryWrapper.eq(CostProjectTask::getCurrentNode, req.getCurrentNode());
        } else {
            queryWrapper.ne(CostProjectTask::getCurrentNode, NodeConstant.guidang.getNodeKey());
        }

        return costProjectTaskManager.count(queryWrapper);
    }

}