| | |
|---|
| | | package com.ycl.service.caseHandler.impl; |
|---|
| | | |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|---|
| | | 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; |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | * @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 |
|---|
| | | 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("未查询到该流程环节"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | //添加调度记录 |
|---|
| | | DisposeRecord disposeRecord = new DisposeRecord(); |
|---|
| | | disposeRecord.setBaseCaseId(baseCase.getId()); |
|---|
| | | disposeRecord.setWorkflowConfigStepId(workflowConfigStep.getId()); |
|---|
| | | disposeRecord.setStepName(workflowConfigStep.getName()); |
|---|
| | | disposeRecord.setHandlerRoleId(workflowConfigStep.getRoleId()); |
|---|
| | | disposeRecord.setHandlerId(dispatchInfo.getCreateUser()); |
|---|
| | | //调度已结束 |
|---|
| | | disposeRecord.setState(1); |
|---|
| | | disposeRecord.setStartTime(LocalDateTime.now()); |
|---|
| | | disposeRecord.setEndTime(LocalDateTime.now()); |
|---|
| | | disposeRecord.setCreateUser(dispatchInfo.getCreateUser()); |
|---|
| | | disposeRecord.setCreateTime(LocalDateTime.now()); |
|---|
| | | |
|---|
| | | disposeRecordMapper.insert(disposeRecord); |
|---|
| | | |
|---|
| | | 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.setHandlerId(dispatchInfo.getCreateUser()); |
|---|
| | | //上传处置未结束 |
|---|
| | | stepNextRecord.setState(0); |
|---|
| | | stepNextRecord.setStartTime(LocalDateTime.now()); |
|---|
| | | stepNextRecord.setCreateUser(dispatchInfo.getCreateUser()); |
|---|
| | | stepNextRecord.setCreateTime(LocalDateTime.now()); |
|---|
| | | |
|---|
| | | disposeRecordMapper.insert(stepNextRecord); |
|---|
| | | return dispatchInfo; |
|---|
| | | } |
|---|
| | | |
|---|
