提交 8cd3a747 编写于 作者: sq3536's avatar sq3536

工作流编程

上级 47963078
...@@ -162,7 +162,7 @@ public class WFCoreService ...@@ -162,7 +162,7 @@ public class WFCoreService
variables.put("businessKey",businessKey); variables.put("businessKey",businessKey);
variables.put("activedata",instance.get("activedata")); variables.put("activedata",instance.get("activedata"));
variables.put("curuser",AuthenticationUser.getAuthenticationUser()); variables.put("curuser",AuthenticationUser.getAuthenticationUser());
variables.put("cloud-serviceid",system+"-app-"+appname); variables.put("cloud-serviceid",system+"-"+appname);
variables.put("system",system); variables.put("system",system);
variables.put("appname",appname); variables.put("appname",appname);
variables.put("entitys",entity); variables.put("entitys",entity);
...@@ -288,7 +288,7 @@ public class WFCoreService ...@@ -288,7 +288,7 @@ 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("cloud-serviceid",system+"-app-"+appname); variables.put("cloud-serviceid",system+"-"+appname);
Map<String, Object> transientVariables = new LinkedHashMap<>(); Map<String, Object> transientVariables = new LinkedHashMap<>();
transientVariables.put("activedata",taskWay.get("activedata")); transientVariables.put("activedata",taskWay.get("activedata"));
...@@ -395,23 +395,14 @@ public class WFCoreService ...@@ -395,23 +395,14 @@ public class WFCoreService
InputStream inputStream2 = null; InputStream inputStream2 = null;
String bmpmfileId=""; String bmpmfileId="";
String fileFullPath =""; String fileFullPath ="";
try try {
{
inputStream2=new FileInputStream(bpmnFile); inputStream2=new FileInputStream(bpmnFile);
reader2 = factory.createXMLStreamReader(inputStream2); reader2 = factory.createXMLStreamReader(inputStream2);
BpmnModel entitymodel=bpmnXMLConverter.convertToBpmnModel(reader2); BpmnModel entitymodel=bpmnXMLConverter.convertToBpmnModel(reader2);
entitymodel.getProcesses().get(0).setId(processDefinitionKey); entitymodel.getProcesses().get(0).setId(processDefinitionKey);
byte[] bs= bpmnXMLConverter.convertToXML(entitymodel); byte[] bs= bpmnXMLConverter.convertToXML(entitymodel);
bmpmfileId=DigestUtils.md5DigestAsHex(bs); bmpmfileId=DigestUtils.md5DigestAsHex(bs);
fileFullPath = this.fileRoot+"ibizutil"+File.separator+bmpmfileId+File.separator+processDefinitionKey+".bpmn20.xml"; fileFullPath = this.fileRoot+"ibizutil"+File.separator+bmpmfileId+File.separator+processDefinitionKey+".bpmn20.xml";
is = new ByteArrayInputStream(bs); is = new ByteArrayInputStream(bs);
File file = new File(fileFullPath); File file = new File(fileFullPath);
File parent = new File(file.getParent()); File parent = new File(file.getParent());
...@@ -446,14 +437,11 @@ public class WFCoreService ...@@ -446,14 +437,11 @@ public class WFCoreService
inputStream=new FileInputStream(new File(fileFullPath)); inputStream=new FileInputStream(new File(fileFullPath));
DeploymentBuilder deploymentBuilder = repositoryService.createDeployment().name(curProcess.getName()).key(processDefinitionKey) DeploymentBuilder deploymentBuilder = repositoryService.createDeployment().name(curProcess.getName()).key(processDefinitionKey)
.addInputStream(fileFullPath,inputStream); .addInputStream(fileFullPath,inputStream);
Deployment deployment= deploymentBuilder.deploy(); Deployment deployment= deploymentBuilder.deploy();
wfProcessDefinition.setBpmnfile("[{\"id\":\""+bmpmfileId+"\",\"name\":\""+processDefinitionKey+".bpmn20.xml\"}]"); wfProcessDefinition.setBpmnfile("[{\"id\":\""+bmpmfileId+"\",\"name\":\""+processDefinitionKey+".bpmn20.xml\"}]");
wfProcessDefinition.setMd5check(bmpmfileId); wfProcessDefinition.setMd5check(bmpmfileId);
iwfProcessDefinitionService.save(wfProcessDefinition); iwfProcessDefinitionService.save(wfProcessDefinition);
// wfProcessDefinition.setMd5check(md5);
// iwfProcessDefinitionService.update(wfProcessDefinition);
log.warn("部署流程 name:"+curProcess.getName()+" key "+deployment.getKey() + " deploy "+deployment); log.warn("部署流程 name:"+curProcess.getName()+" key "+deployment.getKey() + " deploy "+deployment);
......
Markdown 格式
0% or
您添加了 0 到此讨论。请谨慎行事。
先完成此消息的编辑!
想要评论请 注册