From a4047b6048ebfe09e66a765b58ea12b5bd0e2e6e Mon Sep 17 00:00:00 2001 From: zhanghua <314079846@qq.com> Date: 星期一, 28 十一月 2022 16:18:10 +0800 Subject: [PATCH] 店铺管理优化 --- ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/CheckHandleServiceImpl.java | 97 +++++++++++++++++++++++++++++++++++++++++++----- 1 files changed, 87 insertions(+), 10 deletions(-) diff --git a/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/CheckHandleServiceImpl.java b/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/CheckHandleServiceImpl.java index 33f4d14..1ea1d9a 100644 --- a/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/CheckHandleServiceImpl.java +++ b/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/CheckHandleServiceImpl.java @@ -1,17 +1,25 @@ 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.controller.video.common.constant.BaseCaseStatus; +import com.ycl.controller.video.common.constant.CheckResult; +import com.ycl.controller.video.common.constant.StepName; import com.ycl.dto.caseHandler.ChechParam; import com.ycl.entity.caseHandler.BaseCase; 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.DisposeRecordMapper; +import com.ycl.mapper.caseHandler.WorkflowConfigStepMapper; import com.ycl.service.caseHandler.ICheckHandleService; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; +import java.time.LocalDateTime; /** * <p> @@ -28,21 +36,90 @@ @Resource BaseCaseMapper baseCaseMapper; + @Resource + DisposeRecordMapper disposeRecordMapper; + @Resource + WorkflowConfigStepMapper workflowConfigStepMapper; + @Override public Boolean check(ChechParam chechParam) { - //鏂板娴佺▼璁板綍淇℃伅 - DisposeRecord disposeRecord = new DisposeRecord(); - disposeRecord.setBaseCaseId(chechParam.getBaseCaseId()); - disposeRecord.setWorkflowConfigStepId(3); - disposeRecord.setState(chechParam.getStatus()); - disposeRecord.setCreateUser(chechParam.getCurrentUser()); - disposeRecord.setStepName("鏍告煡"); - baseMapper.insert(disposeRecord); - //淇敼妗堜欢鐘舵�佷负瀹℃牳 + + + 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.setAuditOpinion(chechParam.getCheckOpinion()); + //淇敼鏍告煡璁板綍 + DisposeRecord disposeRecord = new DisposeRecord(); + //椹冲洖澶勭悊 + if (CheckResult.REJECT.getName().equals(chechParam.getResult())) { + QueryWrapper<WorkflowConfigStep> lastNextqurey = new QueryWrapper<>(); + lastNextqurey.eq("workflow_config_id", workflowConfigStep.getWorkflowConfigId()); + lastNextqurey.eq("seq", workflowConfigStep.getSeq()-1); + WorkflowConfigStep lastStep = workflowConfigStepMapper.selectOne(lastNextqurey); + //鍒犻櫎涓婁竴姝ユ暟鎹� + UpdateWrapper<DisposeRecord> deleteWrapper = new UpdateWrapper<>(); + deleteWrapper.eq("base_case_id", chechParam.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()-2); + WorkflowConfigStep lastLastStep = workflowConfigStepMapper.selectOne(lastLastNextqurey); + + UpdateWrapper<DisposeRecord> updateWrapper = new UpdateWrapper<>(); + updateWrapper.eq("base_case_id", chechParam.getBaseCaseId()).eq("workflow_config_step_id",lastLastStep.getId()); + + disposeRecord.setHandlerId(chechParam.getCurrentUser()); + //鏍告煡宸茬粨鏉� + disposeRecord.setState(0); + disposeRecord.setEndTime(LocalDateTime.now()); + disposeRecordMapper.update(disposeRecord, updateWrapper); + //璋冨害 + baseCase.setState(BaseCaseStatus.DISPATCH); + baseCaseMapper.updateById(baseCase); + return true; + } + //鏍告煡 baseCase.setState(BaseCaseStatus.CHECK); baseCaseMapper.updateById(baseCase); + + + 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.setHandlerId(chechParam.getCurrentUser()); + //鏍告煡宸茬粨鏉� + disposeRecord.setState(1); + disposeRecord.setResult(chechParam.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); + 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(chechParam.getCurrentUser()); + stepNextRecord.setCreateTime(LocalDateTime.now()); + + disposeRecordMapper.insert(stepNextRecord); return true; } } -- Gitblit v1.8.0