package org.jeecg.modules.apply.lisener;
|
|
import com.alibaba.fastjson.JSONObject;
|
import lombok.extern.slf4j.Slf4j;
|
import org.activiti.engine.RepositoryService;
|
import org.activiti.engine.delegate.event.ActivitiEntityEvent;
|
import org.activiti.engine.delegate.event.ActivitiEvent;
|
import org.activiti.engine.delegate.event.ActivitiEventListener;
|
import org.activiti.engine.delegate.event.ActivitiEventType;
|
import org.activiti.engine.impl.persistence.entity.TaskEntity;
|
import org.jeecg.common.Constant;
|
import org.jeecg.common.util.SpringContextUtils;
|
import org.jeecg.common.utils.StringUtils;
|
import org.jeecg.modules.approval.model.dto.ApprovalOpinionDTO;
|
import org.jeecg.modules.approval.service.ApprovalService;
|
|
import org.springframework.stereotype.Component;
|
|
import java.io.Serializable;
|
import java.util.HashSet;
|
import java.util.List;
|
import java.util.Set;
|
|
/**
|
* 全局事件监听
|
* <p>
|
* Create by YLL on 2020/1/2
|
*/
|
@Component
|
@Slf4j
|
public class CustomEventListener implements ActivitiEventListener, Serializable {
|
@Override
|
public void onEvent(ActivitiEvent event) {
|
|
// TODO: 2020/4/15 这段代码发布时需要注释掉!!
|
//测试,将所有流程审核人设成admin;
|
// if (event.getType().equals(ActivitiEventType.TASK_ASSIGNED)) {
|
// ActivitiEntityEvent entityEvent = (ActivitiEntityEvent) event;
|
// TaskEntity entity = (TaskEntity) entityEvent.getEntity();
|
// entity.setAssignee("e9ca23d68d884d4ebb19d07889727dae");
|
// }
|
|
if (event.getType().equals(ActivitiEventType.TASK_CREATED)) {
|
ActivitiEntityEvent entityEvent = (ActivitiEntityEvent) event;
|
TaskEntity entity = (TaskEntity) entityEvent.getEntity();
|
|
RepositoryService repositoryService = SpringContextUtils.getBean(RepositoryService.class);
|
Set<String> userIds = new HashSet<>();
|
|
//是否自己指定的办理人
|
Object opinionObject = entity.getVariable(Constant.ACT_APPLY_OPINION_LIST);
|
if (opinionObject != null) {
|
List<ApprovalOpinionDTO> approvalOpinionDTOS = JSONObject.parseArray(opinionObject.toString(), ApprovalOpinionDTO.class);
|
ApprovalOpinionDTO approvalOpinionDTO = approvalOpinionDTOS.get(approvalOpinionDTOS.size() - 1);
|
if (Constant.YES.equals(approvalOpinionDTO.getDefNextAssignee()) && approvalOpinionDTO.getNextAssignee() != null) {
|
entity.setAssignee(approvalOpinionDTO.getNextAssignee().getId());
|
}
|
}
|
|
if (StringUtils.isNotEmpty(entity.getAssignee())) {
|
userIds.add(entity.getAssignee());
|
} else if (StringUtils.isNotEmpty(entity.getCandidates())) {
|
ApprovalService approvalService = SpringContextUtils.getBean(ApprovalService.class);
|
userIds = approvalService.getCandiates(entity.getId());
|
}
|
}
|
}
|
|
@Override
|
public boolean isFailOnException() {
|
return false;
|
}
|
}
|
