|
@@ -4,9 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
|
|
|
import com.platform.activiti.dao.entity.ActApplyInfo;
|
|
|
import com.platform.activiti.dao.entity.ActAuditRecord;
|
|
|
import com.platform.activiti.dao.entity.ActAuditRequest;
|
|
|
-import com.platform.activiti.enums.ActApplyEnum;
|
|
|
import com.platform.common.constant.CommonConstants;
|
|
|
-import com.platform.common.enums.ResultCode;
|
|
|
import com.platform.common.exception.BusinessException;
|
|
|
import com.platform.common.model.UserInfo;
|
|
|
import com.platform.common.util.SecurityUtils;
|
|
@@ -15,8 +13,6 @@ import com.platform.dao.entity.upms.SysUser;
|
|
|
import com.platform.service.activiti.ActivitiAssignStrategy;
|
|
|
import com.platform.service.activiti.ActivitiUserModelService;
|
|
|
import com.platform.service.business.ActivitiBaseService;
|
|
|
-import com.platform.service.sb.SbInfoService;
|
|
|
-import com.platform.service.sb.SbScrapFormService;
|
|
|
import com.platform.service.upms.SysUserService;
|
|
|
import lombok.AllArgsConstructor;
|
|
|
import org.activiti.engine.*;
|
|
@@ -86,7 +82,7 @@ public abstract class ActivitiBaseServiceAbstract implements ActivitiBaseService
|
|
|
UserInfo user = SecurityUtils.getUserInfo();
|
|
|
// 设置发起对象,保存到流程实例中
|
|
|
ActApplyInfo applyInfo = new ActApplyInfo(actAuditRequest.getId(),
|
|
|
- ActApplyEnum.SB_INFO_SCRAP.getName(), ActApplyEnum.SB_INFO_SCRAP.getKey(),
|
|
|
+ actAuditRequest.getAuditModelName(), actAuditRequest.getAuditModelKey(),
|
|
|
0,
|
|
|
LocalDateTime.now());
|
|
|
Map<String, Object> map = new HashMap<>(1);
|
|
@@ -99,13 +95,13 @@ public abstract class ActivitiBaseServiceAbstract implements ActivitiBaseService
|
|
|
if (StringUtils.isBlank(actAuditRequest.getProcessInstanceId())) {
|
|
|
// 第一次启动,设置流程启动人信息,为了后面查询我的发起列表
|
|
|
identityService.setAuthenticatedUserId(user.getUserId());
|
|
|
- instance = runtimeService.startProcessInstanceByKey(ActApplyEnum.SB_INFO_SCRAP.getKey(), actAuditRequest.getId(), map);
|
|
|
+ instance = runtimeService.startProcessInstanceByKey(actAuditRequest.getAuditModelKey(), actAuditRequest.getId(), map);
|
|
|
actAuditRequest.setProcessInstanceId(instance.getId());
|
|
|
} else { // 再次提交审批的,之前被拒绝的
|
|
|
ProcessInstance instanceExsit = runtimeService.createProcessInstanceQuery()
|
|
|
.processInstanceId(actAuditRequest.getProcessInstanceId()).singleResult();
|
|
|
if (instanceExsit == null) {
|
|
|
- instance = runtimeService.startProcessInstanceByKey(ActApplyEnum.SB_INFO_SCRAP.getKey(), actAuditRequest.getId(), map);
|
|
|
+ instance = runtimeService.startProcessInstanceByKey(actAuditRequest.getAuditModelKey(), actAuditRequest.getId(), map);
|
|
|
actAuditRequest.setProcessInstanceId(instance.getId());
|
|
|
} else {
|
|
|
instance = runtimeService.startProcessInstanceById(actAuditRequest.getProcessInstanceId(), actAuditRequest.getId(), map);
|
|
@@ -128,7 +124,7 @@ public abstract class ActivitiBaseServiceAbstract implements ActivitiBaseService
|
|
|
taskService.complete(task.getId(), data);
|
|
|
// 分配下一个节点的审批人信息
|
|
|
// 设置各个节点审批人员信息
|
|
|
- Model model = repositoryService.createModelQuery().modelKey(ActApplyEnum.SB_INFO_SCRAP.getKey()).singleResult();
|
|
|
+ Model model = repositoryService.createModelQuery().modelKey(actAuditRequest.getAuditModelKey()).singleResult();
|
|
|
List<ActivitiUserModel> list = activitiUserModelService.getModelByModelId(model.getId());
|
|
|
if (CollectionUtil.isEmpty(list)) {
|
|
|
throw new BusinessException("审批节点未设置,请先设置");
|
|
@@ -152,7 +148,7 @@ public abstract class ActivitiBaseServiceAbstract implements ActivitiBaseService
|
|
|
if (doAudit(actAuditRequest)) {
|
|
|
if (!doCheckLast(actAuditRequest)) {
|
|
|
// 分配下一个节点的审批人信息
|
|
|
- Model model = repositoryService.createModelQuery().modelKey(ActApplyEnum.SB_INFO_SCRAP.getKey()).singleResult();
|
|
|
+ Model model = repositoryService.createModelQuery().modelKey(actAuditRequest.getAuditModelKey()).singleResult();
|
|
|
List<ActivitiUserModel> list = activitiUserModelService.getModelByModelId(model.getId());
|
|
|
if (CollectionUtil.isEmpty(list)) {
|
|
|
throw new BusinessException("审批节点未设置,请先设置");
|