|
@@ -1,4 +1,4 @@
|
|
|
-package cn.iocoder.yudao.module.bpm.service.oa.dimission;
|
|
|
+package cn.iocoder.yudao.module.bpm.service.oa.turnover;
|
|
|
|
|
|
import cn.hutool.core.collection.CollectionUtil;
|
|
|
import cn.hutool.core.util.IdUtil;
|
|
@@ -6,12 +6,12 @@ import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
|
|
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
|
|
|
import cn.iocoder.yudao.module.bpm.api.task.BpmProcessInstanceApi;
|
|
|
import cn.iocoder.yudao.module.bpm.api.task.dto.BpmProcessInstanceCreateReqDTO;
|
|
|
-import cn.iocoder.yudao.module.bpm.controller.admin.oa.dimission.vo.OaDimissionPageReqVO;
|
|
|
-import cn.iocoder.yudao.module.bpm.controller.admin.oa.dimission.vo.OaDimissionSaveReqVO;
|
|
|
+import cn.iocoder.yudao.module.bpm.controller.admin.oa.turnover.vo.OaTurnoverPageReqVO;
|
|
|
+import cn.iocoder.yudao.module.bpm.controller.admin.oa.turnover.vo.OaTurnoverSaveReqVO;
|
|
|
import cn.iocoder.yudao.module.bpm.controller.admin.task.vo.task.BpmTaskApproveReqVO;
|
|
|
import cn.iocoder.yudao.module.bpm.controller.admin.task.vo.task.BpmTaskReturnReqVO;
|
|
|
-import cn.iocoder.yudao.module.bpm.dal.dataobject.oa.dimission.OaDimissionDO;
|
|
|
-import cn.iocoder.yudao.module.bpm.dal.mysql.oa.dimission.OaDimissionMapper;
|
|
|
+import cn.iocoder.yudao.module.bpm.dal.dataobject.oa.turnover.OaTurnoverDO;
|
|
|
+import cn.iocoder.yudao.module.bpm.dal.mysql.oa.turnover.OaTurnOverMapper;
|
|
|
import cn.iocoder.yudao.module.bpm.service.task.BpmTaskService;
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
@@ -39,17 +39,17 @@ import static cn.iocoder.yudao.module.bpm.enums.ErrorCodeConstants.OA_DIMISSION_
|
|
|
*/
|
|
|
@Service
|
|
|
@Validated
|
|
|
-public class OaDimissionServiceImpl extends ServiceImpl<OaDimissionMapper, OaDimissionDO> implements OaDimissionService {
|
|
|
+public class OaTurnoverServiceImpl extends ServiceImpl<OaTurnOverMapper, OaTurnoverDO> implements OaTurnoverService {
|
|
|
|
|
|
|
|
|
/**
|
|
|
* OA 离职对应的流程定义 KEY
|
|
|
*/
|
|
|
- public static final String PROCESS_KEY = "oa_dimission";
|
|
|
+ public static final String PROCESS_KEY = "oa_turnover";
|
|
|
|
|
|
|
|
|
@Resource
|
|
|
- private OaDimissionMapper oaDimissionMapper;
|
|
|
+ private OaTurnOverMapper oaTurnOverMapper;
|
|
|
|
|
|
@Resource
|
|
|
private BpmProcessInstanceApi processInstanceApi;
|
|
@@ -62,17 +62,17 @@ public class OaDimissionServiceImpl extends ServiceImpl<OaDimissionMapper, OaDim
|
|
|
|
|
|
@Override
|
|
|
@Transactional
|
|
|
- public Long startOaDimission(Long userId, OaDimissionSaveReqVO createReqVO) {
|
|
|
+ public Long startOaTurnover(Long userId, OaTurnoverSaveReqVO createReqVO) {
|
|
|
//判断是否已经发起流程
|
|
|
Boolean auditPass = createReqVO.getAuditPass();
|
|
|
// 创建单据uuid
|
|
|
String uuid = IdUtil.fastSimpleUUID();
|
|
|
- OaDimissionDO oaDimission = BeanUtils.toBean(createReqVO, OaDimissionDO.class);
|
|
|
- if (StringUtils.isBlank(oaDimission.getDimissionId())) {
|
|
|
- oaDimission.setDimissionId(uuid);
|
|
|
+ OaTurnoverDO oaTurnover = BeanUtils.toBean(createReqVO, OaTurnoverDO.class);
|
|
|
+ if (StringUtils.isBlank(oaTurnover.getTurnoverId())) {
|
|
|
+ oaTurnover.setTurnoverId(uuid);
|
|
|
}
|
|
|
// 保存或更新表单信息
|
|
|
- this.saveOrUpdate(oaDimission);
|
|
|
+ this.saveOrUpdate(oaTurnover);
|
|
|
|
|
|
// 提交
|
|
|
if (auditPass) {
|
|
@@ -87,18 +87,18 @@ public class OaDimissionServiceImpl extends ServiceImpl<OaDimissionMapper, OaDim
|
|
|
new BpmProcessInstanceCreateReqDTO()
|
|
|
.setProcessDefinitionKey(PROCESS_KEY)
|
|
|
.setVariables(processInstanceVariables)
|
|
|
- .setBusinessKey(String.valueOf(oaDimission.getId()))
|
|
|
+ .setBusinessKey(String.valueOf(oaTurnover.getId()))
|
|
|
.setStartUserSelectAssignees(startUserSelectAssignees));
|
|
|
|
|
|
//获取下一个审批人
|
|
|
Task task = taskService.createTaskQuery().processInstanceId(processInstanceId).singleResult();
|
|
|
|
|
|
// 将工作流的编号,单据状态 最后一次审批时间 当前审批人 更新到 OA 转正中
|
|
|
- oaDimissionMapper.updateById(new OaDimissionDO()
|
|
|
- .setId(oaDimission.getId())
|
|
|
+ oaTurnOverMapper.updateById(new OaTurnoverDO()
|
|
|
+ .setId(oaTurnover.getId())
|
|
|
.setProcInstId(processInstanceId)
|
|
|
.setAuditStatus("1")
|
|
|
- .setDimissionId(uuid)
|
|
|
+ .setTurnoverId(uuid)
|
|
|
.setFinalAuditDate(LocalDateTime.now())
|
|
|
.setCurrentAuditEmployeeId(Long.valueOf(task.getAssignee())));
|
|
|
|
|
@@ -107,8 +107,8 @@ public class OaDimissionServiceImpl extends ServiceImpl<OaDimissionMapper, OaDim
|
|
|
}else {
|
|
|
// 暂存,不发起流程
|
|
|
// 将单据状态 更新到 OA转正中
|
|
|
- oaDimissionMapper.updateById(new OaDimissionDO()
|
|
|
- .setId(oaDimission.getId())
|
|
|
+ oaTurnOverMapper.updateById(new OaTurnoverDO()
|
|
|
+ .setId(oaTurnover.getId())
|
|
|
.setAuditStatus("0"));
|
|
|
}
|
|
|
|
|
@@ -117,29 +117,29 @@ public class OaDimissionServiceImpl extends ServiceImpl<OaDimissionMapper, OaDim
|
|
|
}
|
|
|
|
|
|
// 返回
|
|
|
- return oaDimission.getId();
|
|
|
+ return oaTurnover.getId();
|
|
|
}
|
|
|
@Override
|
|
|
- public Long completeTrueOaDimission(Long userId, BpmTaskApproveReqVO reqVO) {
|
|
|
+ public Long completeTrueOaTurnover(Long userId, BpmTaskApproveReqVO reqVO) {
|
|
|
Task currentTask = bpmTaskService.getTask(reqVO.getId());
|
|
|
// 审批同意
|
|
|
bpmTaskService.approveTask(userId, reqVO);
|
|
|
|
|
|
Task nextTask = taskService.createTaskQuery().processInstanceId(currentTask.getProcessInstanceId()).singleResult();
|
|
|
if (nextTask != null) {
|
|
|
- LambdaUpdateWrapper<OaDimissionDO> updateWrapper = new LambdaUpdateWrapper<>();
|
|
|
- updateWrapper.set(OaDimissionDO::getAuditStatus, "2")
|
|
|
- .set(OaDimissionDO::getCurrentAuditEmployeeId, nextTask.getAssignee())
|
|
|
- .set(OaDimissionDO::getFinalAuditDate, new Date())
|
|
|
- .eq(OaDimissionDO::getProcInstId, currentTask.getProcessInstanceId());
|
|
|
- oaDimissionMapper.update(updateWrapper);
|
|
|
+ LambdaUpdateWrapper<OaTurnoverDO> updateWrapper = new LambdaUpdateWrapper<>();
|
|
|
+ updateWrapper.set(OaTurnoverDO::getAuditStatus, "2")
|
|
|
+ .set(OaTurnoverDO::getCurrentAuditEmployeeId, nextTask.getAssignee())
|
|
|
+ .set(OaTurnoverDO::getFinalAuditDate, new Date())
|
|
|
+ .eq(OaTurnoverDO::getProcInstId, currentTask.getProcessInstanceId());
|
|
|
+ oaTurnOverMapper.update(updateWrapper);
|
|
|
} else {
|
|
|
- LambdaUpdateWrapper<OaDimissionDO> updateWrapper = new LambdaUpdateWrapper<>();
|
|
|
- updateWrapper.set(OaDimissionDO::getAuditStatus, "3")
|
|
|
- .set(OaDimissionDO::getCurrentAuditEmployeeId, null)
|
|
|
- .set(OaDimissionDO::getFinalAuditDate, new Date())
|
|
|
- .eq(OaDimissionDO::getProcInstId, currentTask.getProcessInstanceId());
|
|
|
- oaDimissionMapper.update(updateWrapper);
|
|
|
+ LambdaUpdateWrapper<OaTurnoverDO> updateWrapper = new LambdaUpdateWrapper<>();
|
|
|
+ updateWrapper.set(OaTurnoverDO::getAuditStatus, "3")
|
|
|
+ .set(OaTurnoverDO::getCurrentAuditEmployeeId, null)
|
|
|
+ .set(OaTurnoverDO::getFinalAuditDate, new Date())
|
|
|
+ .eq(OaTurnoverDO::getProcInstId, currentTask.getProcessInstanceId());
|
|
|
+ oaTurnOverMapper.update(updateWrapper);
|
|
|
|
|
|
// TODO 复制业务单据信息到业务模块单据表
|
|
|
|
|
@@ -151,7 +151,7 @@ public class OaDimissionServiceImpl extends ServiceImpl<OaDimissionMapper, OaDim
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public Long completeFalseOaDimission(Long userId, BpmTaskApproveReqVO reqVO) {
|
|
|
+ public Long completeFalseOaTurnover(Long userId, BpmTaskApproveReqVO reqVO) {
|
|
|
|
|
|
Task currentTask = bpmTaskService.getTask(reqVO.getId());
|
|
|
|
|
@@ -162,12 +162,12 @@ public class OaDimissionServiceImpl extends ServiceImpl<OaDimissionMapper, OaDim
|
|
|
Task nextTask = taskService.createTaskQuery().processInstanceId(currentTask.getProcessInstanceId()).singleResult();
|
|
|
|
|
|
// 更新单据状态,当前处理人,最后处理时间
|
|
|
- LambdaUpdateWrapper<OaDimissionDO> updateWrapper = new LambdaUpdateWrapper<>();
|
|
|
- updateWrapper.set(OaDimissionDO::getCurrentAuditEmployeeId, nextTask.getAssignee())
|
|
|
- .set(OaDimissionDO::getFinalAuditDate, new Date())
|
|
|
- .set(OaDimissionDO::getAuditStatus, "0")
|
|
|
- .eq(OaDimissionDO::getProcInstId, currentTask.getProcessInstanceId());
|
|
|
- oaDimissionMapper.update(updateWrapper);
|
|
|
+ LambdaUpdateWrapper<OaTurnoverDO> updateWrapper = new LambdaUpdateWrapper<>();
|
|
|
+ updateWrapper.set(OaTurnoverDO::getCurrentAuditEmployeeId, nextTask.getAssignee())
|
|
|
+ .set(OaTurnoverDO::getFinalAuditDate, new Date())
|
|
|
+ .set(OaTurnoverDO::getAuditStatus, "0")
|
|
|
+ .eq(OaTurnoverDO::getProcInstId, currentTask.getProcessInstanceId());
|
|
|
+ oaTurnOverMapper.update(updateWrapper);
|
|
|
|
|
|
// 发送通知
|
|
|
|
|
@@ -176,13 +176,13 @@ public class OaDimissionServiceImpl extends ServiceImpl<OaDimissionMapper, OaDim
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public Long updateCompleteOaDimission(Long userId, OaDimissionSaveReqVO createReqVO, BpmTaskApproveReqVO reqVO) {
|
|
|
+ public Long updateCompleteOaTurnover(Long userId, OaTurnoverSaveReqVO createReqVO, BpmTaskApproveReqVO reqVO) {
|
|
|
// 判断是否已经发起流程
|
|
|
Boolean auditPass = createReqVO.getAuditPass();
|
|
|
|
|
|
- OaDimissionDO oaDimission = BeanUtils.toBean(createReqVO, OaDimissionDO.class);
|
|
|
+ OaTurnoverDO oaTurnover = BeanUtils.toBean(createReqVO, OaTurnoverDO.class);
|
|
|
|
|
|
- Task currentTask = taskService.createTaskQuery().processInstanceId(oaDimission.getProcInstId()).singleResult();
|
|
|
+ Task currentTask = taskService.createTaskQuery().processInstanceId(oaTurnover.getProcInstId()).singleResult();
|
|
|
|
|
|
//审批通过
|
|
|
bpmTaskService.approveTask(userId, reqVO);
|
|
@@ -191,64 +191,64 @@ public class OaDimissionServiceImpl extends ServiceImpl<OaDimissionMapper, OaDim
|
|
|
if (auditPass) {
|
|
|
Task nextTask = taskService.createTaskQuery().processInstanceId(currentTask.getProcessInstanceId()).singleResult();
|
|
|
|
|
|
- oaDimission.setAuditStatus("1");
|
|
|
- oaDimission.setCurrentAuditEmployeeId(Long.valueOf(nextTask.getAssignee()));
|
|
|
- oaDimission.setFinalAuditDate(LocalDateTime.now());
|
|
|
- oaDimissionMapper.updateById(oaDimission);
|
|
|
+ oaTurnover.setAuditStatus("1");
|
|
|
+ oaTurnover.setCurrentAuditEmployeeId(Long.valueOf(nextTask.getAssignee()));
|
|
|
+ oaTurnover.setFinalAuditDate(LocalDateTime.now());
|
|
|
+ oaTurnOverMapper.updateById(oaTurnover);
|
|
|
|
|
|
} else {
|
|
|
- OaDimissionDO oaDimissionClose = new OaDimissionDO();
|
|
|
- oaDimissionClose.setId(oaDimission.getId());
|
|
|
- oaDimissionClose.setAuditStatus("4");
|
|
|
- oaDimissionClose.setCurrentAuditEmployeeId(null);
|
|
|
- oaDimissionClose.setFinalAuditDate(LocalDateTime.now());
|
|
|
- oaDimissionMapper.updateById(oaDimissionClose);
|
|
|
+ OaTurnoverDO oaTurnoverClose = new OaTurnoverDO();
|
|
|
+ oaTurnoverClose.setId(oaTurnover.getId());
|
|
|
+ oaTurnoverClose.setAuditStatus("4");
|
|
|
+ oaTurnoverClose.setCurrentAuditEmployeeId(null);
|
|
|
+ oaTurnoverClose.setFinalAuditDate(LocalDateTime.now());
|
|
|
+ oaTurnOverMapper.updateById(oaTurnoverClose);
|
|
|
}
|
|
|
|
|
|
- return oaDimission.getId();
|
|
|
+ return oaTurnover.getId();
|
|
|
}
|
|
|
|
|
|
|
|
|
@Override
|
|
|
- public Long createOaDimission(OaDimissionSaveReqVO createReqVO) {
|
|
|
+ public Long createOaTurnover(OaTurnoverSaveReqVO createReqVO) {
|
|
|
// 插入
|
|
|
- OaDimissionDO oaDimission = BeanUtils.toBean(createReqVO, OaDimissionDO.class);
|
|
|
- oaDimissionMapper.insert(oaDimission);
|
|
|
+ OaTurnoverDO oaTurnover = BeanUtils.toBean(createReqVO, OaTurnoverDO.class);
|
|
|
+ oaTurnOverMapper.insert(oaTurnover);
|
|
|
// 返回
|
|
|
- return oaDimission.getId();
|
|
|
+ return oaTurnover.getId();
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public void updateOaDimission(OaDimissionSaveReqVO updateReqVO) {
|
|
|
+ public void updateOaTurnover(OaTurnoverSaveReqVO updateReqVO) {
|
|
|
// 校验存在
|
|
|
- validateOaDimissionExists(updateReqVO.getId());
|
|
|
+ validateOaTurnoverExists(updateReqVO.getId());
|
|
|
// 更新
|
|
|
- OaDimissionDO updateObj = BeanUtils.toBean(updateReqVO, OaDimissionDO.class);
|
|
|
- oaDimissionMapper.updateById(updateObj);
|
|
|
+ OaTurnoverDO updateObj = BeanUtils.toBean(updateReqVO, OaTurnoverDO.class);
|
|
|
+ oaTurnOverMapper.updateById(updateObj);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public void deleteOaDimission(Long id) {
|
|
|
+ public void deleteOaTurnover(Long id) {
|
|
|
// 校验存在
|
|
|
- validateOaDimissionExists(id);
|
|
|
+ validateOaTurnoverExists(id);
|
|
|
// 删除
|
|
|
- oaDimissionMapper.deleteById(id);
|
|
|
+ oaTurnOverMapper.deleteById(id);
|
|
|
}
|
|
|
|
|
|
- private void validateOaDimissionExists(Long id) {
|
|
|
- if (oaDimissionMapper.selectById(id) == null) {
|
|
|
+ private void validateOaTurnoverExists(Long id) {
|
|
|
+ if (oaTurnOverMapper.selectById(id) == null) {
|
|
|
throw exception(OA_DIMISSION_NOT_EXISTS);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public OaDimissionDO getOaDimission(Long id) {
|
|
|
- return oaDimissionMapper.selectById(id);
|
|
|
+ public OaTurnoverDO getOaTurnover(Long id) {
|
|
|
+ return oaTurnOverMapper.selectById(id);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public PageResult<OaDimissionDO> getOaDimissionPage(OaDimissionPageReqVO pageReqVO) {
|
|
|
- return oaDimissionMapper.selectPage(pageReqVO);
|
|
|
+ public PageResult<OaTurnoverDO> getOaTurnoverPage(OaTurnoverPageReqVO pageReqVO) {
|
|
|
+ return oaTurnOverMapper.selectPage(pageReqVO);
|
|
|
}
|
|
|
|
|
|
}
|