更多ruoyi-nbcio功能请看演示系统
gitee源代码地址
前后端代码： https://gitee.com/nbacheng/ruoyi-nbcio
演示地址：RuoYi-Nbcio后台管理系统
今天初步完成仿钉钉流程转bpmn设计的工作，当然还有不少bug，以后有需要或者网友也帮忙改进。
1、前端
前端主要部分如下：
previewJson() {
const getCmpData = name => this.$refs[name].getData()
// processDesign 返回的是Promise 因为要做校验
console.log("publish getCmpData",getCmpData)
const p3 = getCmpData('processDesign')
console.log("publish p3",p3)
Promise.all([p3])
.then(res => {
const param = {
processData: res[0].formData
}
this.previewResult = JSON.stringify(param, null, 2);//json格式化
this.previewType = "json";
this.previewModelVisible = true;
})
.catch(err => {
err.target && (this.activeStep = err.target)
err.msg && this.$message.warning(err.msg)
})
},
previewXml() {
const getCmpData = name => this.$refs[name].getData()
// processDesign 返回的是Promise 因为要做校验
console.log("publish getCmpData",getCmpData)
const p3 = getCmpData('processDesign')
console.log("publish p3",p3)
Promise.all([p3])
.then(res => {
const param = {
processData: res[0].formData
}
var convert = require('xml-js');
var json = JSON.stringify(param, null, 2);//json格式化
// 启动流程并将表单数据加入流程变量
dingdingToBpmn(json).then(res => {
console.log("dingdingToBpmn res",res)
if(res.code == 200) {
this.previewResult = res.msg;
this.previewType = "xml";
this.previewModelVisible = true
}
})
})
.catch(err => {
err.target && (this.activeStep = err.target)
err.msg && this.$message.warning(err.msg)
})
},
previewBpmn() {
const getCmpData = name => this.$refs[name].getData()
// processDesign 返回的是Promise 因为要做校验
console.log("publish getCmpData",getCmpData)
const p3 = getCmpData('processDesign')
console.log("publish p3",p3)
Promise.all([p3])
.then(res => {
const param = {
processData: res[0].formData
}
var convert = require('xml-js');
var json = JSON.stringify(param, null, 2);//json格式化
// 钉钉流程转为bpmn格式
dingdingToBpmn(json).then(reponse => {
console.log("dingdingToBpmn reponse",reponse)
if(reponse.code == 200) {
this.processView.title = "Bpmn流程图预览";
this.processView.xmlData = reponse.msg;
}
})
this.processView.open = true;
})
.catch(err => {
err.target && (this.activeStep = err.target)
err.msg && this.$message.warning(err.msg)
})
},2、后端主要部分如下：
@Override
public R<Void> dingdingToBpmn(String ddjson) {
try {
JSONObject object = JSON.parseObject(ddjson, JSONObject.class);
//JSONObject workflow = object.getJSONObject("process");
//ddBpmnModel.addProcess(ddProcess);
//ddProcess.setName (workflow.getString("name"));
//ddProcess.setId(workflow.getString("processId"));
ddProcess = new Process();
ddBpmnModel = new BpmnModel();
ddSequenceFlows = Lists.newArrayList();
ddBpmnModel.addProcess(ddProcess);
ddProcess.setId("Process_"+UUID.randomUUID());
ddProcess.setName ("dingding演示流程");
JSONObject flowNode = object.getJSONObject("processData");
StartEvent startEvent = createStartEvent(flowNode);
ddProcess.addFlowElement(startEvent);
String lastNode = create(startEvent.getId(), flowNode);
EndEvent endEvent = createEndEvent();
ddProcess.addFlowElement(endEvent);
ddProcess.addFlowElement(connect(lastNode, endEvent.getId()));
new BpmnAutoLayout(ddBpmnModel).execute();
return R.ok(new String(new BpmnXMLConverter().convertToXML(ddBpmnModel)));
} catch (Exception e) {
e.printStackTrace();
throw new RuntimeException("创建失败: e=" + e.getMessage());
}
}
String id(String prefix) {
return prefix + "_" + UUID.randomUUID().toString().replace("-", "").toLowerCase();
}
ServiceTask serviceTask(String name) {
ServiceTask serviceTask = new ServiceTask();
serviceTask.setName(name);
return serviceTask;
}
SequenceFlow connect(String from, String to) {
SequenceFlow flow = new SequenceFlow();
flow.setId(id("sequenceFlow"));
flow.setSourceRef(from);
flow.setTargetRef(to);
ddSequenceFlows.add(flow);
return flow;
}
StartEvent createStartEvent(JSONObject flowNode) {
String nodeType = flowNode.getString("type");
StartEvent startEvent = new StartEvent();
startEvent.setId(id("start"));
if (Type.INITIATOR_TASK.isEqual(nodeType)) {
JSONObject properties = flowNode.getJSONObject("properties");
if(StringUtils.isNotEmpty(properties.getString("formKey"))) {
startEvent.setFormKey(properties.getString("formKey"));
}
}
return startEvent;
}
EndEvent createEndEvent() {
EndEvent endEvent = new EndEvent();
endEvent.setId(id("end"));
return endEvent;
}
String create(String fromId, JSONObject flowNode) throws InvocationTargetException, IllegalAccessException {
String nodeType = flowNode.getString("type");
if (Type.INITIATOR_TASK.isEqual(nodeType)) {
flowNode.put("incoming", Collections.singletonList(fromId));
String id = createUserTask(flowNode,nodeType);
if(flowNode.containsKey("concurrentNodes")) { //并行网关
return createConcurrentGatewayBuilder(id, flowNode);
}
if(flowNode.containsKey("conditionNodes")) { //排它网关或叫条件网关
return createExclusiveGatewayBuilder(id, flowNode);
}
// 如果当前任务还有后续任务，则遍历创建后续任务
JSONObject nextNode = flowNode.getJSONObject("childNode");
if (Objects.nonNull(nextNode)) {
FlowElement flowElement = ddBpmnModel.getFlowElement(id);
return create(id, nextNode);
} else {
return id;
}
} else if (Type.USER_TASK.isEqual(nodeType) || Type.APPROVER_TASK.isEqual(nodeType)) {
flowNode.put("incoming", Collections.singletonList(fromId));
String id = createUserTask(flowNode,nodeType);
if(flowNode.containsKey("concurrentNodes")) { //并行网关
return createConcurrentGatewayBuilder(id, flowNode);
}
if(flowNode.containsKey("conditionNodes")) { //排它网关或叫条件网关
return createExclusiveGatewayBuilder(id, flowNode);
}
// 如果当前任务还有后续任务，则遍历创建后续任务
JSONObject nextNode = flowNode.getJSONObject("childNode");
if (Objects.nonNull(nextNode)) {
FlowElement flowElement = ddBpmnModel.getFlowElement(id);
return create(id, nextNode);
} else {
return id;
}
} else if (Type.SERVICE_TASK.isEqual(nodeType)) {
flowNode.put("incoming", Collections.singletonList(fromId));
String id = createServiceTask(flowNode);
if(flowNode.containsKey("concurrentNodes")) { //并行网关
return createConcurrentGatewayBuilder(id, flowNode);
}
if(flowNode.containsKey("conditionNodes")) { //排它网关或叫条件网关
return createExclusiveGatewayBuilder(id, flowNode);
}
// 如果当前任务还有后续任务，则遍历创建后续任务
JSONObject nextNode = flowNode.getJSONObject("childNode");
if (Objects.nonNull(nextNode)) {
FlowElement flowElement = ddBpmnModel.getFlowElement(id);
return create(id, nextNode);
} else {
return id;
}
}
else {
throw new RuntimeException("未知节点类型: nodeType=" + nodeType);
}
}
String createExclusiveGatewayBuilder(String formId, JSONObject flowNode) throws InvocationTargetException, IllegalAccessException {
//String name = flowNode.getString("nodeName");
String exclusiveGatewayId = id("exclusiveGateway");
ExclusiveGateway exclusiveGateway = new ExclusiveGateway();
exclusiveGateway.setId(exclusiveGatewayId);
exclusiveGateway.setName("排它条件网关");
ddProcess.addFlowElement(exclusiveGateway);
ddProcess.addFlowElement(connect(formId, exclusiveGatewayId));
if (Objects.isNull(flowNode.getJSONArray("conditionNodes")) && Objects.isNull(flowNode.getJSONObject("childNode"))) {
return exclusiveGatewayId;
}
List<JSONObject> flowNodes = Optional.ofNullable(flowNode.getJSONArray("conditionNodes")).map(e -> e.toJavaList(JSONObject.class)).orElse(Collections.emptyList());
List<String> incoming = Lists.newArrayListWithCapacity(flowNodes.size());
List<JSONObject> conditions = Lists.newCopyOnWriteArrayList();
for (JSONObject element : flowNodes) {
JSONObject childNode = element.getJSONObject("childNode");
JSONObject properties = element.getJSONObject("properties");
String nodeName = properties.getString("title");
String expression = properties.getString("conditions");
if (Objects.isNull(childNode)) {
incoming.add(exclusiveGatewayId);
JSONObject condition = new JSONObject();
condition.fluentPut("nodeName", nodeName)
.fluentPut("expression", expression);
conditions.add(condition);
continue;
}
// 只生成一个任务，同时设置当前任务的条件
childNode.put("incoming", Collections.singletonList(exclusiveGatewayId));
String identifier = create(exclusiveGatewayId, childNode);
List<SequenceFlow> flows = ddSequenceFlows.stream().filter(flow -> StringUtils.equals(exclusiveGatewayId, flow.getSourceRef()))
.collect(Collectors.toList());
flows.stream().forEach(
e -> {
if (StringUtils.isBlank(e.getName()) && StringUtils.isNotBlank(nodeName)) {
e.setName(nodeName);
}
// 设置条件表达式
if (Objects.isNull(e.getConditionExpression()) && StringUtils.isNotBlank(expression)) {
e.setConditionExpression(expression);
}
}
);
if (Objects.nonNull(identifier)) {
incoming.add(identifier);
}
}
JSONObject childNode = flowNode.getJSONObject("childNode");
if (Objects.nonNull(childNode)) {
if (incoming == null || incoming.isEmpty()) {
return create(exclusiveGatewayId, childNode);
} else {
// 所有 service task 连接 end exclusive gateway
childNode.put("incoming", incoming);
FlowElement flowElement = ddBpmnModel.getFlowElement(incoming.get(0));
// 1.0 先进行边连接, 暂存 nextNode
JSONObject nextNode = childNode.getJSONObject("childNode");
childNode.put("childNode", null);
String identifier = create(flowElement.getId(), childNode);
for (int i = 1; i < incoming.size(); i++) {
ddProcess.addFlowElement(connect(incoming.get(i), identifier));
}
// 针对 gateway 空任务分支 添加条件表达式
if (!conditions.isEmpty()) {
FlowElement flowElement1 = ddBpmnModel.getFlowElement(identifier);
// 获取从 gateway 到目标节点 未设置条件表达式的节点
List<SequenceFlow> flows = ddSequenceFlows.stream().filter(flow -> StringUtils.equals(flowElement1.getId(), flow.getTargetRef()))
.filter(flow -> StringUtils.equals(flow.getSourceRef(), exclusiveGatewayId))
.collect(Collectors.toList());
flows.stream().forEach(sequenceFlow -> {
if (!conditions.isEmpty()) {
JSONObject condition = conditions.get(0);
String nodeName = condition.getString("content");
String expression = condition.getString("expression");
if (StringUtils.isBlank(sequenceFlow.getName()) && StringUtils.isNotBlank(nodeName)) {
sequenceFlow.setName(nodeName);
}
// 设置条件表达式
if (Objects.isNull(sequenceFlow.getConditionExpression()) && StringUtils.isNotBlank(expression)) {
sequenceFlow.setConditionExpression(expression);
}
conditions.remove(0);
}
});
}
// 1.1 边连接完成后，在进行 nextNode 创建
if (Objects.nonNull(nextNode)) {
return create(identifier, nextNode);
} else {
return identifier;
}
}
}
return exclusiveGatewayId;
}
String createConcurrentGatewayBuilder(String fromId, JSONObject flowNode) throws InvocationTargetException, IllegalAccessException {
//String name = flowNode.getString("nodeName");
//下面创建并行网关并进行连线
ParallelGateway parallelGateway = new ParallelGateway();
String parallelGatewayId = id("parallelGateway");
parallelGateway.setId(parallelGatewayId);
parallelGateway.setName("并行网关");
ddProcess.addFlowElement(parallelGateway);
ddProcess.addFlowElement(connect(fromId, parallelGatewayId));
if (Objects.isNull(flowNode.getJSONArray("concurrentNodes"))
&& Objects.isNull(flowNode.getJSONObject("childNode"))) {
return parallelGatewayId;
}
//获取并行列表数据
List<JSONObject> flowNodes = Optional.ofNullable(flowNode.getJSONArray("concurrentNodes")).map(e -> e.toJavaList(JSONObject.class)).orElse(Collections.emptyList());
List<String> incoming = Lists.newArrayListWithCapacity(flowNodes.size());
for (JSONObject element : flowNodes) {
JSONObject childNode = element.getJSONObject("childNode");
if (Objects.isNull(childNode)) {//没子节点,就把并行id加入入口队列
incoming.add(parallelGatewayId);
continue;
}
String identifier = create(parallelGatewayId, childNode);
if (Objects.nonNull(identifier)) {//否则加入有子节点的用户id
incoming.add(identifier);
}
}
JSONObject childNode = flowNode.getJSONObject("childNode");
if (Objects.nonNull(childNode)) {
// 普通结束网关
if (CollectionUtils.isEmpty(incoming)) {
return create(parallelGatewayId, childNode);
} else {
// 所有 user task 连接 end parallel gateway
childNode.put("incoming", incoming);
FlowElement flowElement = ddBpmnModel.getFlowElement(incoming.get(0));
// 1.0 先进行边连接, 暂存 nextNode
JSONObject nextNode = childNode.getJSONObject("childNode");
childNode.put("childNode", null); //不加这个,下面创建子节点会进入递归了
String identifier = create(incoming.get(0), childNode);
for (int i = 1; i < incoming.size(); i++) {//其中0之前创建的时候已经连接过了，所以从1开始补另外一条
FlowElement flowElementIncoming = ddBpmnModel.getFlowElement(incoming.get(i));
ddProcess.addFlowElement(connect(flowElementIncoming.getId(), identifier));
}
// 1.1 边连接完成后，在进行 nextNode 创建
if (Objects.nonNull(nextNode)) {
return create(identifier, nextNode);
} else {
return identifier;
}
}
}
if(incoming.size()>0) {
return incoming.get(1);
}
else {
return parallelGatewayId;
}
}
String createUserTask(JSONObject flowNode, String nodeType) {
List<String> incoming = flowNode.getJSONArray("incoming").toJavaList(String.class);
// 自动生成id
String id = id("userTask");
if (incoming != null && !incoming.isEmpty()) {
UserTask userTask = new UserTask();
JSONObject properties = flowNode.getJSONObject("properties");
userTask.setName(properties.getString("title"));
userTask.setId(id);
List<ExtensionAttribute> attributes = new ArrayList<ExtensionAttribute>();
if (Type.INITIATOR_TASK.isEqual(nodeType)) {
ExtensionAttribute extAttribute = new ExtensionAttribute();
extAttribute.setNamespace(ProcessConstants.NAMASPASE);
extAttribute.setName("dataType");
extAttribute.setValue("INITIATOR");
attributes.add(extAttribute);
userTask.addAttribute(extAttribute);
userTask.setAssignee("${initiator}");
} else if (Type.USER_TASK.isEqual(nodeType) || Type.APPROVER_TASK.isEqual(nodeType)) {
JSONArray approvers = properties.getJSONArray("approvers");
JSONObject approver = approvers.getJSONObject(0);
ExtensionAttribute extDataTypeAttribute = new ExtensionAttribute();
extDataTypeAttribute.setNamespace(ProcessConstants.NAMASPASE);
extDataTypeAttribute.setName("dataType");
extDataTypeAttribute.setValue("USERS");
userTask.addAttribute(extDataTypeAttribute);
ExtensionAttribute extTextAttribute = new ExtensionAttribute();
extTextAttribute.setNamespace(ProcessConstants.NAMASPASE);
extTextAttribute.setName("text");
extTextAttribute.setValue(approver.getString("nickName"));
userTask.addAttribute(extTextAttribute);
userTask.setFormKey(properties.getString("formKey"));
userTask.setAssignee(approver.getString("userName"));
}
ddProcess.addFlowElement(userTask);
ddProcess.addFlowElement(connect(incoming.get(0), id));
}
return id;
}
String createServiceTask(JSONObject flowNode) {
List<String> incoming = flowNode.getJSONArray("incoming").toJavaList(String.class);
// 自动生成id
String id = id("serviceTask");
if (incoming != null && !incoming.isEmpty()) {
ServiceTask serviceTask = new ServiceTask();
serviceTask.setName(flowNode.getString("nodeName"));
serviceTask.setId(id);
ddProcess.addFlowElement(serviceTask);
ddProcess.addFlowElement(connect(incoming.get(0), id));
}
return id;
}
enum Type {
/**
* 并行事件
*/
CONCURRENT("concurrent", ParallelGateway.class),
/**
* 排他事件
*/
EXCLUSIVE("exclusive", ExclusiveGateway.class),
/**
* 服务任务
*/
SERVICE_TASK("serviceTask", ServiceTask.class),
/**
* 发起人任务
*/
INITIATOR_TASK("start", ServiceTask.class),
/**
* 审批任务
*/
APPROVER_TASK("approver", ServiceTask.class),
/**
* 用户任务
*/
USER_TASK("userTask", UserTask.class);
private String type;
private Class<?> typeClass;
Type(String type, Class<?> typeClass) {
this.type = type;
this.typeClass = typeClass;
}
public final static Map<String, Class<?>> TYPE_MAP = Maps.newHashMap();
static {
for (Type element : Type.values()) {
TYPE_MAP.put(element.type, element.typeClass);
}
}
public boolean isEqual(String type) {
return this.type.equals(type);
}
}3、效果图如下：
