package com.vci.ubcs.flow.engine.envent;
|
|
import com.vci.ubcs.flow.core.constant.ProcessConstant;
|
import com.vci.ubcs.flow.core.dto.FlowStatusDTO;
|
import com.vci.ubcs.flow.engine.constant.FlowEngineConstant;
|
import com.vci.ubcs.flow.engine.utils.FlowableUtils;
|
import com.vci.ubcs.starter.exception.VciBaseException;
|
import com.vci.ubcs.starter.web.util.LangBaseUtil;
|
import com.vci.ubcs.starter.web.util.VciBaseUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.flowable.engine.HistoryService;
|
import org.flowable.engine.TaskService;
|
import org.flowable.engine.delegate.TaskListener;
|
import org.flowable.engine.impl.el.FixedValue;
|
import org.flowable.task.service.delegate.DelegateTask;
|
import org.springblade.core.jwt.JwtUtil;
|
import org.springblade.core.launch.constant.TokenConstant;
|
import org.springblade.core.tool.utils.WebUtil;
|
import org.springframework.beans.BeansException;
|
import org.springframework.context.ApplicationContext;
|
import org.springframework.context.ApplicationContextAware;
|
import org.springframework.http.HttpEntity;
|
import org.springframework.http.HttpHeaders;
|
import org.springframework.http.MediaType;
|
import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
|
import org.springframework.stereotype.Component;
|
import org.springframework.util.CollectionUtils;
|
import org.springframework.web.client.HttpClientErrorException;
|
import org.springframework.web.client.RestTemplate;
|
|
import java.util.List;
|
import java.util.Map;
|
|
@Slf4j
|
@Component
|
public class FlowStatusListener implements TaskListener, ApplicationContextAware {
|
|
/**
|
* 远程调用地址。切记：名称要与流程中定义的一样
|
*/
|
private FixedValue remoteMethod;
|
|
/**
|
* 状态值。切记：名称要与流程中定义的一样
|
*/
|
private FixedValue statusValue;
|
|
private static ApplicationContext applicationContext;
|
|
@Override
|
public void setApplicationContext(ApplicationContext arg0) throws BeansException {
|
applicationContext = arg0;
|
}
|
|
@Override
|
public void notify(DelegateTask delegateTask) {
|
Map taskVariable = delegateTask.getVariables();
|
boolean pass = (boolean) taskVariable.get(ProcessConstant.PASS_KEY);
|
|
//获取状态修改信息
|
if(pass){
|
String restURL = remoteMethod.getExpressionText();
|
String status = statusValue.getExpressionText();
|
//获取业务数据信息
|
List<String> oids = (List<String>) taskVariable.get(FlowEngineConstant.OIDS);
|
String btmType = (String) taskVariable.get(FlowEngineConstant.BTMTYPE);
|
|
taskVariable.put(FlowEngineConstant.REMOTE_METHOD,restURL);
|
taskVariable.put(FlowEngineConstant.STATUS_VALUE,status);
|
|
if(CollectionUtils.isEmpty(oids)){
|
throw new VciBaseException("执行状态修改事件时，业务数据oid为空！");
|
}
|
if(StringUtils.isEmpty(btmType)){
|
throw new VciBaseException("执行状态修改事件时，业务类型btmType为空！");
|
}
|
if(StringUtils.isEmpty(restURL)){
|
throw new VciBaseException("执行状态修改事件时，远程调用地址为空！");
|
}
|
if(StringUtils.isEmpty(status)){
|
throw new VciBaseException("执行状态修改事件时，状态为空！");
|
}
|
|
HistoryService historyService = applicationContext.getBean(HistoryService.class);
|
TaskService taskService = applicationContext.getBean(TaskService.class);
|
|
FlowStatusDTO flowStatusDTO = new FlowStatusDTO();
|
flowStatusDTO.setBtmType(btmType);
|
flowStatusDTO.setOids(oids);
|
flowStatusDTO.setVariableMap(taskVariable);
|
flowStatusDTO.setTaskHisVOList(FlowableUtils.listTaskHistory(delegateTask.getProcessInstanceId(),historyService,taskService));
|
|
String token = JwtUtil.getToken(WebUtil.getRequest().getHeader(TokenConstant.HEADER));
|
|
HttpComponentsClientHttpRequestFactory requestFactory=new HttpComponentsClientHttpRequestFactory();
|
requestFactory.setReadTimeout(300000);
|
requestFactory.setConnectionRequestTimeout(300000);
|
requestFactory.setConnectTimeout(300000);
|
RestTemplate restTemplate = new RestTemplate(requestFactory);
|
HttpHeaders headers = new HttpHeaders();
|
headers.add(TokenConstant.HEADER,token);
|
headers.setContentType(MediaType.APPLICATION_JSON);
|
HttpEntity httpEntity = new HttpEntity<>(flowStatusDTO,headers);
|
Map<String, Object> result = null;
|
try {
|
result = restTemplate.postForObject(restURL, httpEntity, Map.class);
|
} catch (HttpClientErrorException e) {
|
throw new VciBaseException(LangBaseUtil.getErrorMsg(e),new String[]{},e);
|
}catch (Throwable e){
|
throw new VciBaseException(LangBaseUtil.getErrorMsg(e),new String[]{},e);
|
}
|
if(result == null){
|
throw new VciBaseException("业务事件时候没有返回值，不确定是否执行成功");
|
}
|
if(CollectionUtils.isEmpty(result) && !(Boolean) result.get("success")){
|
throw new VciBaseException((String) result.get("message"));
|
}
|
}
|
}
|
|
|
}
|
