fix(plugin-workflow-manual): fix value block in todo block (#3400)

packages/plugins/@nocobase/plugin-workflow-manual/src/client/instruction/SchemaConfig.tsx

@@ -416,7 +416,6 @@ export function SchemaConfig({ value, onChange }) {
   const nodeComponents = {};
   nodes.forEach((item) => {
     const instruction = workflowPlugin.instructions.get(item.type);
-    Object.assign(nodeInitializers, instruction.initializers);
     Object.assign(nodeComponents, instruction.components);
   });
 

packages/plugins/@nocobase/plugin-workflow/src/client/components/ValueBlock.tsx

@@ -53,7 +53,7 @@ function Result({ dataSource }) {
   }
   const result = parse(dataSource)({
     $jobsMapByNodeKey: (execution.jobs ?? []).reduce(
-      (map, job) => Object.assign(map, { [job.nodeId]: job.result }),
+      (map, job) => Object.assign(map, { [job.nodeKey]: job.result }),
       {},
     ),
   });

packages/plugins/@nocobase/plugin-workflow/src/server/collections/jobs.ts

@@ -16,6 +16,10 @@ export default {
       name: 'node',
       target: 'flow_nodes',
     },
+    {
+      type: 'string',
+      name: 'nodeKey',
+    },
     {
       type: 'belongsTo',
       name: 'upstream',

packages/plugins/@nocobase/plugin-workflow/src/server/migrations/20240115220721-add-node-key-to-job.ts

@@ -0,0 +1,35 @@
+import { Migration } from '@nocobase/server';
+
+export default class extends Migration {
+  appVersion = '<0.19.0-alpha.4';
+  on = 'afterSync';
+  async up() {
+    const { db } = this.context;
+
+    const PluginModel = db.getModel('applicationPlugins');
+    const JobRepo = db.getRepository('jobs');
+    await db.sequelize.transaction(async (transaction) => {
+      const jobs = await JobRepo.find({
+        appends: ['node.key'],
+      });
+      await jobs.reduce(
+        (promise, job) =>
+          promise.then(() => {
+            if (job.nodeKey) {
+              return;
+            }
+            return job.update(
+              {
+                nodeKey: job.node.key,
+              },
+              {
+                silent: true,
+                transaction,
+              },
+            );
+          }),
+        Promise.resolve(),
+      );
+    });
+  }
+}