From b9e7a0261443ca41b80108b9fef555093f20bb8b Mon Sep 17 00:00:00 2001 From: mg <maokecheng@163.com> Date: 星期五, 14 十月 2022 16:48:13 +0800 Subject: [PATCH] Merge branch 'master' of http://42.193.1.25:9521/r/sccg_server --- ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/IDispatchHandleServiceImpl.java | 51 +++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 51 insertions(+), 0 deletions(-) diff --git a/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/IDispatchHandleServiceImpl.java b/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/IDispatchHandleServiceImpl.java index d5e4334..306be5b 100644 --- a/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/IDispatchHandleServiceImpl.java +++ b/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/IDispatchHandleServiceImpl.java @@ -1,18 +1,27 @@ 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.StepName; import com.ycl.dto.caseHandler.DispatchInfoParam; import com.ycl.entity.caseHandler.BaseCase; import com.ycl.entity.caseHandler.DispatchInfo; +import com.ycl.entity.caseHandler.DisposeRecord; +import com.ycl.entity.caseHandler.WorkflowConfigStep; +import com.ycl.exception.ApiException; import com.ycl.mapper.caseHandler.BaseCaseMapper; import com.ycl.mapper.caseHandler.DispatchInfoMapper; +import com.ycl.mapper.caseHandler.DisposeRecordMapper; +import com.ycl.mapper.caseHandler.WorkflowConfigStepMapper; import com.ycl.service.caseHandler.IDispatchHandleService; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; +import java.time.LocalDateTime; import java.util.Date; /** @@ -29,6 +38,10 @@ @Resource BaseCaseMapper baseCaseMapper; + @Resource + DisposeRecordMapper disposeRecordMapper; + @Resource + WorkflowConfigStepMapper workflowConfigStepMapper; @Override public DispatchInfo dispatch(DispatchInfoParam dispatchInfoParam) { //鏂板璋冨害淇℃伅 @@ -41,6 +54,44 @@ baseCase.setId(dispatchInfoParam.getBaseCaseId()); baseCase.setState(BaseCaseStatus.DISPATCH); baseCaseMapper.updateById(baseCase); + + QueryWrapper<WorkflowConfigStep> stepqurey = new QueryWrapper<>(); + stepqurey.eq("name", StepName.DISPATCH.getName()); + WorkflowConfigStep workflowConfigStep = workflowConfigStepMapper.selectOne(stepqurey); + + if (workflowConfigStep == null) { + throw new ApiException("鏈煡璇㈠埌璇ユ祦绋嬬幆鑺�"); + } + + UpdateWrapper<DisposeRecord> updateWrapper = new UpdateWrapper<>(); + updateWrapper.eq("base_case_id", baseCase.getId()).eq("workflow_config_step_id",workflowConfigStep.getId()); + + //淇敼璋冨害璁板綍 + DisposeRecord disposeRecord = new DisposeRecord(); + disposeRecord.setHandlerId(dispatchInfo.getCreateUser()); + //璋冨害宸茬粨鏉� + disposeRecord.setState(1); + 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); + WorkflowConfigStep stepNext = workflowConfigStepMapper.selectOne(stepNextqurey); + + //娣诲姞涓嬩竴姝ヨ褰� + DisposeRecord stepNextRecord = new DisposeRecord(); + stepNextRecord.setBaseCaseId(baseCase.getId()); + stepNextRecord.setWorkflowConfigStepId(stepNext.getId()); + stepNextRecord.setStepName(stepNext.getName()); + stepNextRecord.setHandlerRoleId(stepNext.getRoleId()); + //涓婁紶澶勭疆鏈粨鏉� + stepNextRecord.setState(0); + stepNextRecord.setStartTime(LocalDateTime.now()); + stepNextRecord.setCreateUser(dispatchInfo.getCreateUser()); + stepNextRecord.setCreateTime(LocalDateTime.now()); + + disposeRecordMapper.insert(stepNextRecord); return dispatchInfo; } -- Gitblit v1.8.0