|
|
@@ -0,0 +1,237 @@
|
|
|
+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);
|
|
|
+};
|
gssong