|
|
|
|
@ -1249,6 +1249,7 @@ export const useFlowCallbacks = (
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
nodes.forEach(node => {
|
|
|
|
|
|
|
|
|
|
appFlowParams.appEventList[node.id] = {
|
|
|
|
|
x: node.position.x,
|
|
|
|
|
y: node.position.y
|
|
|
|
|
@ -1274,7 +1275,7 @@ export const useFlowCallbacks = (
|
|
|
|
|
// 应用组件的桩点id就是事件id
|
|
|
|
|
const sourceId = edge.sourceHandle;
|
|
|
|
|
const targetId = edge.targetHandle;
|
|
|
|
|
const topic = edge.data.displayData.topic;
|
|
|
|
|
const topic = edge.data.displayData?.topic;
|
|
|
|
|
|
|
|
|
|
if (eventMap.has(topic)) {
|
|
|
|
|
// 如果topic已存在,将eventId添加到数组中
|
|
|
|
|
@ -1298,8 +1299,10 @@ export const useFlowCallbacks = (
|
|
|
|
|
updateAppFlowData(appFlowParams);
|
|
|
|
|
if (appEventParams.length > 0) {
|
|
|
|
|
for (const item of appEventParams) {
|
|
|
|
|
await sleep(500);
|
|
|
|
|
await updateAppEventChannel(item);
|
|
|
|
|
if (item.topic) {
|
|
|
|
|
await sleep(500);
|
|
|
|
|
await updateAppEventChannel(item);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|