From 6c56f35bef519265b4e7ae98fda6ca87855daf9f Mon Sep 17 00:00:00 2001 From: zhanghua <314079846@qq.com> Date: 星期四, 15 十二月 2022 11:29:08 +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 | 73 ++++++++++++++++++++++++++++++++++++ 1 files changed, 72 insertions(+), 1 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 dd4d8fe..18fb476 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,31 +1,102 @@ 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.controller.video.common.constant.BaseCaseStatus; +import com.ycl.controller.video.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; /** * <p> - * 璋冨害澶勭悊 鏈嶅姟瀹炵幇绫� + * 璋冨害澶勭悊 鏈嶅姟瀹炵幇绫� * </p> * * @author mg * @since 2022-09-28 */ @Service +@Transactional public class IDispatchHandleServiceImpl extends ServiceImpl<DispatchInfoMapper, DispatchInfo> implements IDispatchHandleService { + + @Resource + BaseCaseMapper baseCaseMapper; + @Resource + DisposeRecordMapper disposeRecordMapper; + @Resource + WorkflowConfigStepMapper workflowConfigStepMapper; + @Override + @Transactional public DispatchInfo dispatch(DispatchInfoParam dispatchInfoParam) { + //鏂板璋冨害淇℃伅 DispatchInfo dispatchInfo = new DispatchInfo(); BeanUtils.copyProperties(dispatchInfoParam, dispatchInfo); dispatchInfo.setCreateTime(new Date()); baseMapper.insert(dispatchInfo); + //淇敼妗堜欢鐘舵�佷负璋冨害 + BaseCase baseCase = new BaseCase(); + 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.setResult(dispatchInfo.getDispatchOpinion()); + //璋冨害宸茬粨鏉� + 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.setLimitTime(dispatchInfoParam.getDisposeDate()); + stepNextRecord.setHandlerId(dispatchInfoParam.getLawEnforcer()); + 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