|
|
|
@ -45,22 +45,27 @@ public abstract class ProcessAbstractService implements ProcessService {
|
|
|
|
|
@Override |
|
|
|
|
public R startFlow(String userId, String dictValue, String taskId, String processName, Map<String, Object> variables) { |
|
|
|
|
log.info("开启流程....."); |
|
|
|
|
R<BladeFlow> result = flowClient.startProcessInstanceContainNameByKey(dictValue, taskId, processName, variables); |
|
|
|
|
R r = new R(); |
|
|
|
|
r.setCode(result.getCode()); |
|
|
|
|
r.setMsg(result.getMsg()); |
|
|
|
|
// 更新任务流程Id
|
|
|
|
|
if (result.isSuccess()) { |
|
|
|
|
log.info("开启流程成功:{}",variables); |
|
|
|
|
BladeFlow flow = result.getData(); |
|
|
|
|
r.setData(flow.getProcessInstanceId()); |
|
|
|
|
} else { |
|
|
|
|
log.error("开启流程失败:{}",result); |
|
|
|
|
log.error("流程信息为{}",variables); |
|
|
|
|
r.setData(variables); |
|
|
|
|
pushStartFailMessage(dictValue,Long.valueOf(taskId),userId,processName,result.getMsg()); |
|
|
|
|
try { |
|
|
|
|
R<BladeFlow> result = flowClient.startProcessInstanceContainNameByKey(dictValue, taskId, processName, variables); |
|
|
|
|
r.setCode(result.getCode()); |
|
|
|
|
r.setMsg(result.getMsg()); |
|
|
|
|
// 更新任务流程Id
|
|
|
|
|
if (result.isSuccess()) { |
|
|
|
|
log.info("开启流程成功:{}",variables); |
|
|
|
|
BladeFlow flow = result.getData(); |
|
|
|
|
r.setData(flow.getProcessInstanceId()); |
|
|
|
|
} else { |
|
|
|
|
log.error("开启流程失败:{}",result); |
|
|
|
|
log.error("流程信息为{}",variables); |
|
|
|
|
r.setData(variables); |
|
|
|
|
pushStartFailMessage(dictValue,Long.valueOf(taskId),userId,processName,result.getMsg()); |
|
|
|
|
} |
|
|
|
|
return r; |
|
|
|
|
}catch (Exception e){ |
|
|
|
|
log.error(e.toString()) ; |
|
|
|
|
} |
|
|
|
|
return r; |
|
|
|
|
return R.fail("开启流程失败"); |
|
|
|
|
} |
|
|
|
|
// public R compensateFlow(String userId,String dictValue,String taskId,String processName,Map<String, Object> variables) {
|
|
|
|
|
// R<BladeFlow> result = flowClient.startProcessInstanceContainNameByKey(dictValue, taskId, processName, variables);
|
|
|
|
|