批量审核和图片保存bug

zhanghua

2025-04-14 1cad14bca191807e18705c3a5526eda8151be439

 ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/CheckHandleServiceImpl.java

@@ -1,10 +1,12 @@
package com.ycl.service.caseHandler.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ycl.common.constant.BaseCaseStatus;
import com.ycl.common.constant.CheckResult;
import com.ycl.common.constant.StepName;
import com.ycl.dto.caseHandler.ChechParam;
import com.ycl.dto.caseHandler.CheckParam;
import com.ycl.entity.caseHandler.BaseCase;
import com.ycl.entity.caseHandler.DisposeRecord;
import com.ycl.entity.caseHandler.WorkflowConfigStep;
@@ -18,6 +20,7 @@

import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.util.List;

/**
 * <p>
@@ -40,37 +43,63 @@
    WorkflowConfigStepMapper workflowConfigStepMapper;

    @Override
    public Boolean check(ChechParam chechParam) {
         //修改案件状态为审核
    public Boolean check(CheckParam checkParam) {

        QueryWrapper<WorkflowConfigStep> stepQurey = new QueryWrapper<>();
        stepQurey.eq("name", StepName.CHECK.getName());
        WorkflowConfigStep workflowConfigStep = workflowConfigStepMapper.selectOne(stepQurey);
        //修改案件状态为审核
        BaseCase baseCase = new BaseCase();
        baseCase.setId(chechParam.getBaseCaseId());
        baseCase.setId(checkParam.getBaseCaseId());
        baseCase.setAuditOpinion(checkParam.getCheckOpinion());
        //修改核查记录
        DisposeRecord disposeRecord = new DisposeRecord();
        //驳回处理
        if (CheckResult.REJECT.getName().equals(checkParam.getResult())) {
            QueryWrapper<WorkflowConfigStep> lastNextqurey = new QueryWrapper<>();
            lastNextqurey.eq("workflow_config_id", workflowConfigStep.getWorkflowConfigId());
            lastNextqurey.eq("seq", workflowConfigStep.getSeq());
            WorkflowConfigStep lastStep = workflowConfigStepMapper.selectOne(lastNextqurey);
            //删除当前数据
            UpdateWrapper<DisposeRecord> deleteWrapper = new UpdateWrapper<>();
            deleteWrapper.eq("base_case_id", checkParam.getBaseCaseId()).eq("workflow_config_step_id", lastStep.getId());
            disposeRecordMapper.delete(deleteWrapper);
            //修改状态为上一步状态
            QueryWrapper<WorkflowConfigStep> lastLastNextqurey = new QueryWrapper<>();
            lastLastNextqurey.eq("workflow_config_id", workflowConfigStep.getWorkflowConfigId());
            lastLastNextqurey.eq("seq", workflowConfigStep.getSeq() - 1);
            WorkflowConfigStep lastLastStep = workflowConfigStepMapper.selectOne(lastLastNextqurey);

            UpdateWrapper<DisposeRecord> updateWrapper = new UpdateWrapper<>();
            updateWrapper.eq("base_case_id", checkParam.getBaseCaseId()).eq("workflow_config_step_id", lastLastStep.getId());

            //处理未开始
            disposeRecord.setState(0);
            disposeRecordMapper.update(disposeRecord, updateWrapper);
            //调度
            baseCase.setState(BaseCaseStatus.DISPATCH);
            baseCaseMapper.updateById(baseCase);
            return true;
        }
        //核查
        baseCase.setState(BaseCaseStatus.CHECK);
        baseCase.setAuditOpinion(chechParam.getCheckOpinion());
        baseCaseMapper.updateById(baseCase);


        QueryWrapper<WorkflowConfigStep> stepqurey = new QueryWrapper<>();
        stepqurey.eq("name", StepName.CHECK.getName());
        WorkflowConfigStep workflowConfigStep = workflowConfigStepMapper.selectOne(stepqurey);

        if (workflowConfigStep == null) {
            throw new ApiException("未查询到该流程环节");
        }
        //添加调度记录
        DisposeRecord disposeRecord = new DisposeRecord();
        disposeRecord.setBaseCaseId(baseCase.getId());
        disposeRecord.setWorkflowConfigStepId(workflowConfigStep.getId());
        disposeRecord.setStepName(workflowConfigStep.getName());
        disposeRecord.setHandlerRoleId(workflowConfigStep.getRoleId());
        disposeRecord.setHandlerId(chechParam.getCurrentUser());
        disposeRecord.setState(1);
        disposeRecord.setStartTime(LocalDateTime.now());
        disposeRecord.setEndTime(LocalDateTime.now());
        disposeRecord.setResult(chechParam.getResult());
        disposeRecord.setCreateUser(chechParam.getCurrentUser());
        disposeRecord.setCreateTime(LocalDateTime.now());

        disposeRecordMapper.insert(disposeRecord);
        UpdateWrapper<DisposeRecord> updateWrapper = new UpdateWrapper<>();
        updateWrapper.eq("base_case_id", baseCase.getId()).eq("workflow_config_step_id", workflowConfigStep.getId());

        disposeRecord.setHandlerId(checkParam.getCurrentUser());
        //核查已结束
        disposeRecord.setState(1);
        disposeRecord.setResult(checkParam.getResult());
        disposeRecord.setEndTime(LocalDateTime.now());
        disposeRecordMapper.update(disposeRecord, updateWrapper);

        QueryWrapper<WorkflowConfigStep> stepNextqurey = new QueryWrapper<>();
        stepNextqurey.eq("workflow_config_id", workflowConfigStep.getWorkflowConfigId());
        stepNextqurey.eq("seq", workflowConfigStep.getSeq() + 1);
@@ -82,14 +111,26 @@
        stepNextRecord.setWorkflowConfigStepId(stepNext.getId());
        stepNextRecord.setStepName(stepNext.getName());
        stepNextRecord.setHandlerRoleId(stepNext.getRoleId());
        stepNextRecord.setHandlerId(chechParam.getCurrentUser());
        //上传处置未结束
        stepNextRecord.setState(0);
        stepNextRecord.setStartTime(LocalDateTime.now());
        stepNextRecord.setCreateUser(chechParam.getCurrentUser());
        stepNextRecord.setCreateUser(checkParam.getCurrentUser());
        stepNextRecord.setCreateTime(LocalDateTime.now());

        disposeRecordMapper.insert(stepNextRecord);
        return true;
    }

    @Override
    public Boolean checkBatch(List<Long> ids, Long userId) {
        ids.forEach(id -> {
            CheckParam checkParam = new CheckParam();
            checkParam.setCurrentUser(userId);
            checkParam.setBaseCaseId(id);
            checkParam.setResult(CheckResult.PASS.getName());
            checkParam.setCheckOpinion("同意");
            this.check(checkParam);
        });
        return null;
    }
}