| | |
| | | package com.ycl.service.caseHandler.impl; |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| | | import com.baomidou.mybatisplus.core.toolkit.StringUtils; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.ycl.common.constant.StepName; |
| | | import com.ycl.entity.caseHandler.BaseCase; |
| | | import com.ycl.entity.caseHandler.DisposeRecord; |
| | | import com.ycl.entity.caseHandler.WorkflowConfigStep; |
| | | import com.ycl.entity.user.UmsAdminRoleRelation; |
| | | 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.mapper.user.UmsAdminRoleRelationMapper; |
| | | import com.ycl.service.caseHandler.IDisposeRecordService; |
| | | import com.ycl.vo.MyBacklogVO; |
| | | import org.springframework.beans.BeanUtils; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.time.LocalDateTime; |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | import java.util.stream.Collectors; |
| | | |
| | |
| | | |
| | | @Resource |
| | | DisposeRecordMapper disposeRecordMapper; |
| | | @Resource |
| | | WorkflowConfigStepMapper workflowConfigStepMapper; |
| | | |
| | | @Resource |
| | | UmsAdminRoleRelationMapper umsAdminRoleRelationMapper; |
| | | |
| | | @Override |
| | | public List<MyBacklogVO> listMyTask(Integer caseId, Long userId) { |
| | | return disposeRecordMapper.selectList( |
| | | new LambdaQueryWrapper<DisposeRecord>() |
| | | .eq(DisposeRecord::getHandlerId, userId.intValue()) |
| | | .isNull(DisposeRecord::getEndTime)) |
| | | .stream() |
| | | .map(item -> { |
| | | MyBacklogVO myBacklogVO = new MyBacklogVO(); |
| | | BeanUtils.copyProperties(item, myBacklogVO); |
| | | BaseCase baseCase = baseCaseMapper.selectById(caseId); |
| | | myBacklogVO.setCategory(baseCase.getCategory()); |
| | | myBacklogVO.setEventSource(baseCase.getEventSource()); |
| | | myBacklogVO.setCode(baseCase.getCode()); |
| | | return myBacklogVO; |
| | | }).collect(Collectors.toList()); |
| | | public List<MyBacklogVO> listMyTask(String num, Long userId) { |
| | | return disposeRecordMapper.selectMyBackList(userId,num); |
| | | } |
| | | |
| | | @Override |
| | | public Boolean addRecord(DisposeRecord disposeRecord) { |
| | | |
| | | //结束上传处置流程 |
| | | String stepName = StepName.DISPOSE.getName(); |
| | | QueryWrapper<WorkflowConfigStep> qureyDispatch = new QueryWrapper<>(); |
| | | qureyDispatch.eq("name", stepName); |
| | | WorkflowConfigStep dispatchStep = workflowConfigStepMapper.selectOne(qureyDispatch); |
| | | |
| | | UpdateWrapper<DisposeRecord> updateWrapper = new UpdateWrapper<>(); |
| | | updateWrapper.eq("base_case_id", disposeRecord.getBaseCaseId()).eq("workflow_config_step_id", dispatchStep.getId()); |
| | | |
| | | DisposeRecord updateRecord = new DisposeRecord(); |
| | | updateRecord.setState(1); |
| | | updateRecord.setEndTime(LocalDateTime.now()); |
| | | updateRecord.setHandlerId(disposeRecord.getCreateUser()); |
| | | baseMapper.update(updateRecord, updateWrapper); |
| | | |
| | | QueryWrapper<WorkflowConfigStep> stepQurey = new QueryWrapper<>(); |
| | | stepQurey.eq("name", disposeRecord.getStepName()); |
| | | WorkflowConfigStep workflowConfigStep = workflowConfigStepMapper.selectOne(stepQurey); |
| | | if (workflowConfigStep == null) { |
| | | throw new ApiException("未查询到该流程环节"); |
| | | } |
| | | //设置流程环节数据 |
| | | disposeRecord.setWorkflowConfigStepId(workflowConfigStep.getId()); |
| | | disposeRecord.setHandlerRoleId(workflowConfigStep.getRoleId()); |
| | | baseMapper.insert(disposeRecord); |
| | | return true; |
| | | } |
| | | } |