提交 3bfd3f66 编写于 作者: sq3536's avatar sq3536

ehange

上级 4e9d884d
...@@ -180,7 +180,7 @@ ...@@ -180,7 +180,7 @@
<verbose>true</verbose> <verbose>true</verbose>
<logging>debug</logging> <logging>debug</logging>
<contexts>!test</contexts> <contexts>!test</contexts>
<diffExcludeObjects>Index:.*,table:IBZFILE,IBZUSER,IBZDATAAUDIT</diffExcludeObjects> <diffExcludeObjects>Index:.*,foreignKey:FK_RELATION_CHILD,FK_RELATION_PARENT,table:ibzpssystem,ibzfile,ibzuser,ibzdataaudit,act_de_databasechangelog,act_de_databasechangeloglock,act_de_model,act_de_model_history,act_de_model_relation,IBZPSSYSTEM,IBZFILE,IBZUSER,IBZDATAAUDIT,ACT_DE_DATABASECHANGELOG,ACT_DE_DATABASECHANGELOGLOCK,ACT_DE_MODEL,ACT_DE_MODEL_HISTORY,ACT_DE_MODEL_RELATION</diffExcludeObjects>
</configuration> </configuration>
<phase>process-resources</phase> <phase>process-resources</phase>
<goals> <goals>
......
...@@ -151,6 +151,13 @@ public class ProcessInstanceListener implements FlowableEventListener { ...@@ -151,6 +151,13 @@ public class ProcessInstanceListener implements FlowableEventListener {
event.getEntity(); event.getEntity();
System.out.println("流程异常结束"); System.out.println("流程异常结束");
} }
if(eventType == FlowableEngineEventType.TASK_COMPLETED){
TaskEntity taskEntity = (TaskEntity) event.getEntity();
event.getEntity();
System.out.println("流程异常结束");
}
} }
else if(evt instanceof FlowableActivityEventImpl) else if(evt instanceof FlowableActivityEventImpl)
{ {
......
...@@ -330,14 +330,30 @@ public class WFCoreService ...@@ -330,14 +330,30 @@ public class WFCoreService
String processInstanceBusinessKey=system+":"+entity+":k-"+businessKey; String processInstanceBusinessKey=system+":"+entity+":k-"+businessKey;
Map<String, Object> variables = new LinkedHashMap<>(); Map<String, Object> variables = new LinkedHashMap<>();
variables.put("sequenceFlowId",taskWay.getSequenceflowid()); variables.put("sequenceFlowId",taskWay.getSequenceflowid());
variables.put("sequenceFlowName",taskWay.getSequenceflowname());
variables.put("cloud-serviceid",system+"-"+appname); variables.put("cloud-serviceid",system+"-"+appname);
Map activedata=null;
if(taskWay.get("activedata")!=null && taskWay.get("activedata") instanceof Map)
{
activedata=(Map)taskWay.get("activedata");
}
else
{
activedata=new LinkedHashMap();
}
Map<String, Object> transientVariables = new LinkedHashMap<>(); Map<String, Object> transientVariables = new LinkedHashMap<>();
transientVariables.put("activedata",taskWay.get("activedata")); transientVariables.put("activedata",activedata);
transientVariables.put("curuser",getCurUser()); transientVariables.put("curuser",getCurUser());
//根据流程定义启动流程 //根据流程定义启动流程
Authentication.setAuthenticatedUserId(userId); Authentication.setAuthenticatedUserId(userId);
String wfprocdesc="";
if(activedata.get("wfprocdesc")!=null)
wfprocdesc=activedata.get("wfprocdesc").toString();
taskService.addComment(taskId,taskWay.getProcessinstanceid(),taskWay.getSequenceflowname(),wfprocdesc);
taskService.complete(taskId, variables,transientVariables); taskService.complete(taskId, variables,transientVariables);
WFProcessInstance instance = new WFProcessInstance(); WFProcessInstance instance = new WFProcessInstance();
instance.setBusinesskey(processInstanceBusinessKey); instance.setBusinesskey(processInstanceBusinessKey);
......
...@@ -39,7 +39,7 @@ public class WFCoreResource ...@@ -39,7 +39,7 @@ public class WFCoreResource
return ResponseEntity.status(HttpStatus.OK).body(wfCoreService.getWFStep(system,appname,entity)); return ResponseEntity.status(HttpStatus.OK).body(wfCoreService.getWFStep(system,appname,entity));
} }
@PreAuthorize("hasPermission(#entity,'WFSTART',this.getEntity())") //@PreAuthorize("hasPermission(#entity,'WFSTART',this.getEntity())")
@ApiOperation(value = "wfstart", tags = {"WFProcessInstance" }, notes = "启动工作流") @ApiOperation(value = "wfstart", tags = {"WFProcessInstance" }, notes = "启动工作流")
@RequestMapping(method = RequestMethod.POST, value = "/{system}-app-{appname}/{entity}/{businessKey}/process-instances") @RequestMapping(method = RequestMethod.POST, value = "/{system}-app-{appname}/{entity}/{businessKey}/process-instances")
public ResponseEntity<WFProcessInstance> wfstart(@PathVariable("system") String system,@PathVariable("appname") String appname, public ResponseEntity<WFProcessInstance> wfstart(@PathVariable("system") String system,@PathVariable("appname") String appname,
...@@ -65,7 +65,7 @@ public class WFCoreResource ...@@ -65,7 +65,7 @@ public class WFCoreResource
return ResponseEntity.status(HttpStatus.OK).body(wfCoreService.getTaskLink(system,appname,entity,businessKey,taskId)); return ResponseEntity.status(HttpStatus.OK).body(wfCoreService.getTaskLink(system,appname,entity,businessKey,taskId));
} }
@PreAuthorize("hasPermission(#entity,'WFSTART',this.getEntity())") //@PreAuthorize("hasPermission(#entity,'WFSTART',this.getEntity())")
@ApiOperation(value = "wfsubmit", tags = {"WFProcessInstance" }, notes = "工作流执行步骤") @ApiOperation(value = "wfsubmit", tags = {"WFProcessInstance" }, notes = "工作流执行步骤")
@RequestMapping(method = RequestMethod.POST, value = "/{system}-app-{appname}/{entity}/{businessKey}/tasks/{taskId}") @RequestMapping(method = RequestMethod.POST, value = "/{system}-app-{appname}/{entity}/{businessKey}/tasks/{taskId}")
public ResponseEntity<WFProcessInstance> wfsubmit(@PathVariable("system") String system,@PathVariable("appname") String appname, public ResponseEntity<WFProcessInstance> wfsubmit(@PathVariable("system") String system,@PathVariable("appname") String appname,
......
Markdown 格式
0% or
您添加了 0 到此讨论。请谨慎行事。
先完成此消息的编辑!
想要评论请 注册