238 lines
7.7 KiB
JavaScript
238 lines
7.7 KiB
JavaScript
const NODE_TYPE_MAP = { 0: 'start', 1: 'between', 2: 'end', 3: 'serial', 4: 'parallel' };
|
||
|
||
/**
|
||
* 将warm-flow的定义json数据转成LogicFlow支持的数据格式
|
||
* @param {*} json
|
||
* @returns LogicFlow的数据
|
||
*/
|
||
export const json2LogicFlowJson = (definition) => {
|
||
const graphData = {
|
||
nodes: [],
|
||
edges: []
|
||
};
|
||
// 解析definition属性
|
||
graphData.flowCode = definition.flowCode;
|
||
graphData.flowName = definition.flowName;
|
||
graphData.version = definition.version;
|
||
graphData.fromCustom = definition.fromCustom;
|
||
graphData.fromPath = definition.fromPath;
|
||
// 解析节点
|
||
const allSkips = definition.nodeList.reduce((acc, node) => {
|
||
if (node.skipList && Array.isArray(node.skipList)) {
|
||
acc.push(...node.skipList);
|
||
}
|
||
return acc;
|
||
}, []);
|
||
const allNodes = definition.nodeList;
|
||
// 解析节点
|
||
if (allNodes.length) {
|
||
for (var i = 0, len = allNodes.length; i < len; i++) {
|
||
let node = allNodes[i];
|
||
let lfNode = {
|
||
text: {},
|
||
properties: {}
|
||
};
|
||
// 处理节点
|
||
lfNode.type = NODE_TYPE_MAP[node.nodeType];
|
||
lfNode.id = node.nodeCode;
|
||
let coordinate = node.coordinate;
|
||
if (coordinate) {
|
||
const attr = coordinate.split('|');
|
||
const nodeXy = attr[0].split(',');
|
||
lfNode.x = parseInt(nodeXy[0]);
|
||
lfNode.y = parseInt(nodeXy[1]);
|
||
if (attr.length === 2) {
|
||
const textXy = attr[1].split(',');
|
||
lfNode.text.x = parseInt(textXy[0]);
|
||
lfNode.text.y = parseInt(textXy[1]);
|
||
}
|
||
}
|
||
lfNode.text.value = node.nodeName;
|
||
lfNode.properties.nodeRatio = node.nodeRatio.toString();
|
||
lfNode.properties.permissionFlag = node.permissionFlag;
|
||
lfNode.properties.anyNodeSkip = node.anyNodeSkip;
|
||
lfNode.properties.listenerType = node.listenerType;
|
||
lfNode.properties.listenerPath = node.listenerPath;
|
||
lfNode.properties.formCustom = node.formCustom;
|
||
lfNode.properties.formPath = node.formPath;
|
||
lfNode.properties.ext = {};
|
||
if (node.ext && typeof node.ext === 'string') {
|
||
try {
|
||
node.ext = JSON.parse(node.ext);
|
||
node.ext.forEach((e) => {
|
||
lfNode.properties.ext[e.code] = String(e.value).includes(',') ? e.value.split(',') : String(e.value);
|
||
});
|
||
} catch (error) {
|
||
console.error('Error parsing JSON:', error);
|
||
}
|
||
}
|
||
lfNode.properties.style = {};
|
||
if (node.status === 2) {
|
||
lfNode.properties.style.fill = '#F0FFD9';
|
||
lfNode.properties.style.stroke = '#9DFF00';
|
||
}
|
||
if (node.status === 1) {
|
||
lfNode.properties.style.fill = '#FFF8DC';
|
||
lfNode.properties.style.stroke = '#FFCD17';
|
||
}
|
||
graphData.nodes.push(lfNode);
|
||
}
|
||
}
|
||
if (allSkips.length) {
|
||
// 处理边
|
||
let skipEle = null;
|
||
let edge = {};
|
||
for (var j = 0, lenn = allSkips.length; j < lenn; j++) {
|
||
skipEle = allSkips[j];
|
||
edge = {
|
||
text: {},
|
||
properties: {}
|
||
};
|
||
edge.id = skipEle.id;
|
||
edge.type = 'skip';
|
||
edge.sourceNodeId = skipEle.nowNodeCode;
|
||
edge.targetNodeId = skipEle.nextNodeCode;
|
||
edge.text = { value: skipEle.skipName };
|
||
edge.properties.skipCondition = skipEle.skipCondition;
|
||
edge.properties.skipName = skipEle.skipName;
|
||
edge.properties.skipType = skipEle.skipType;
|
||
const expr = skipEle.expr;
|
||
if (expr) {
|
||
edge.properties.expr = skipEle.expr;
|
||
}
|
||
const coordinate = skipEle.coordinate;
|
||
if (coordinate) {
|
||
const coordinateXy = coordinate.split('|');
|
||
edge.pointsList = [];
|
||
coordinateXy[0].split(';').forEach((item) => {
|
||
const pointArr = item.split(',');
|
||
edge.pointsList.push({
|
||
x: parseInt(pointArr[0]),
|
||
y: parseInt(pointArr[1])
|
||
});
|
||
});
|
||
edge.startPoint = edge.pointsList[0];
|
||
edge.endPoint = edge.pointsList[edge.pointsList.length - 1];
|
||
if (coordinateXy.length > 1) {
|
||
let textXy = coordinateXy[1].split(',');
|
||
edge.text.x = parseInt(textXy[0]);
|
||
edge.text.y = parseInt(textXy[1]);
|
||
}
|
||
}
|
||
graphData.edges.push(edge);
|
||
}
|
||
}
|
||
console.log(graphData);
|
||
return graphData;
|
||
};
|
||
|
||
/**
|
||
* 将LogicFlow的数据转成warm-flow的json定义文件
|
||
* @param {*} data(...definitionInfo,nodes,edges)
|
||
* @returns
|
||
*/
|
||
export const logicFlowJsonToWarmFlow = (data) => {
|
||
// 先构建成流程对象
|
||
const definition = {
|
||
nodeList: []
|
||
};
|
||
|
||
/**
|
||
* 根据节点的类型值，获取key
|
||
* @param {*} mapValue 节点类型映射
|
||
* @returns
|
||
*/
|
||
const getNodeTypeValue = (mapValue) => {
|
||
for (const key in NODE_TYPE_MAP) {
|
||
if (NODE_TYPE_MAP[key] === mapValue) {
|
||
return key;
|
||
}
|
||
}
|
||
};
|
||
/**
|
||
* 根据节点的编码，获取节点的类型
|
||
* @param {*} nodeCode 当前节点名称
|
||
* @returns
|
||
*/
|
||
const getNodeType = (nodeCode) => {
|
||
for (const node of definition.nodeList) {
|
||
if (nodeCode === node.nodeCode) {
|
||
return node.nodeType;
|
||
}
|
||
}
|
||
};
|
||
/**
|
||
* 拼接skip坐标
|
||
* @param {*} edge logicFlow的edge
|
||
* @returns
|
||
*/
|
||
const getCoordinate = (edge) => {
|
||
let coordinate = '';
|
||
for (let i = 0; i < edge.pointsList.length; i++) {
|
||
coordinate = coordinate + parseInt(edge.pointsList[i].x) + ',' + parseInt(edge.pointsList[i].y);
|
||
if (i !== edge.pointsList.length - 1) {
|
||
coordinate = coordinate + ';';
|
||
}
|
||
}
|
||
if (edge.text) {
|
||
coordinate = coordinate + '|' + parseInt(edge.text.x) + ',' + parseInt(edge.text.y);
|
||
}
|
||
return coordinate;
|
||
};
|
||
// 流程定义
|
||
definition.id = data.id;
|
||
definition.flowCode = data.flowCode;
|
||
definition.flowName = data.flowName;
|
||
definition.version = data.version;
|
||
definition.fromCustom = data.fromCustom;
|
||
definition.fromPath = data.fromPath;
|
||
// 流程节点
|
||
data.nodes.forEach((anyNode) => {
|
||
let node = {};
|
||
node.nodeType = getNodeTypeValue(anyNode.type);
|
||
node.nodeCode = anyNode.id;
|
||
if (anyNode.text) {
|
||
node.nodeName = anyNode.text.value;
|
||
}
|
||
node.permissionFlag = anyNode.properties.permissionFlag;
|
||
node.nodeRatio = anyNode.properties.nodeRatio;
|
||
node.anyNodeSkip = anyNode.properties.anyNodeSkip;
|
||
node.listenerType = anyNode.properties.listenerType;
|
||
node.listenerPath = anyNode.properties.listenerPath;
|
||
node.formCustom = anyNode.properties.formCustom;
|
||
node.formPath = anyNode.properties.formPath;
|
||
node.ext = [];
|
||
for (const key in anyNode.properties.ext) {
|
||
if (Object.prototype.hasOwnProperty.call(anyNode.properties.ext, key)) {
|
||
let e = anyNode.properties.ext[key];
|
||
node.ext.push({ code: key, value: Array.isArray(e) ? e.join(',') : e });
|
||
}
|
||
}
|
||
node.ext = JSON.stringify(node.ext);
|
||
node.coordinate = anyNode.x + ',' + anyNode.y;
|
||
if (anyNode.text && anyNode.text.x && anyNode.text.y) {
|
||
node.coordinate = node.coordinate + '|' + anyNode.text.x + ',' + anyNode.text.y;
|
||
}
|
||
node.handlerType = anyNode.properties.handlerType;
|
||
node.handlerPath = anyNode.properties.handlerPath;
|
||
node.version = definition.version;
|
||
node.skipList = [];
|
||
data.edges.forEach((anyEdge) => {
|
||
if (anyEdge.sourceNodeId === anyNode.id) {
|
||
let skip = {};
|
||
skip.skipType = anyEdge.properties.skipType;
|
||
skip.skipCondition = anyEdge.properties.skipCondition;
|
||
skip.skipName = anyEdge?.text?.value || anyEdge.properties.skipName;
|
||
skip.nowNodeCode = anyEdge.sourceNodeId;
|
||
skip.nowNodeType = getNodeType(skip.nowNodeCode);
|
||
skip.nextNodeCode = anyEdge.targetNodeId;
|
||
skip.nextNodeType = getNodeType(skip.nextNodeCode);
|
||
skip.coordinate = getCoordinate(anyEdge);
|
||
node.skipList.push(skip);
|
||
}
|
||
});
|
||
definition.nodeList.push(node);
|
||
});
|
||
return JSON.stringify(definition);
|
||
};
|