refactor: Add validation for merge table node constraints

- Add locale messages for merge table node validation errors
- Implement validation to prevent JS nodes after merge table node
- Check target table capabilities for master-slave merge support

Author: cn-xufei

packages/dag/src/locale/lang/en.js

@@ -829,5 +829,7 @@ export default {
   packages_dag_join_keys_empty: 'Association conditions for {tableName} cannot be empty',
   packages_dag_join_keys_field_empty: 'Field in association condition #{index} for {tableName} cannot be empty.',
   packages_dag_field_path: 'Field Path',
-  packages_dag_email_receivers: 'Email Receivers'
+  packages_dag_email_receivers: 'Email Receivers',
+  packages_dag_merge_table_js_node_error: 'Merge table node cannot have JS node after it',
+  packages_dag_merge_table_table_not_allow_target: 'Merge table does not support writing to {val}'
 }

packages/dag/src/locale/lang/zh-CN.js

@@ -773,5 +773,7 @@ export default {
   packages_dag_join_keys_empty: '{tableName} 的关联条件不能为空',
   packages_dag_join_keys_field_empty: '{tableName} 的关联条件第 {index} 项的字段不能为空',
   packages_dag_field_path: '字段路径',
-  packages_dag_email_receivers: '邮件接收人'
+  packages_dag_email_receivers: '邮件接收人',
+  packages_dag_merge_table_js_node_error: '主从合并节点后不允许存在 JS 节点',
+  packages_dag_merge_table_table_not_allow_target: '主从合并后不支持将 {val} 作为写入目标'
 }

packages/dag/src/locale/lang/zh-TW.js

@@ -768,5 +768,7 @@ export default {
   packages_dag_join_keys_empty: '{tableName} 的關聯條件不能為空',
   packages_dag_join_keys_field_empty: '{tableName} 的關聯條件第 {index} 項的字段不能為空',
   packages_dag_field_path: '字段路徑',
-  packages_dag_email_receivers: '郵件接收人'
+  packages_dag_email_receivers: '郵件接收人',
+  packages_dag_merge_table_js_node_error: '主從合併節點後不允許存在 JS 節點',
+  packages_dag_merge_table_table_not_allow_target: '主從合併後不支持將 {val} 作為寫入目標'
 }

packages/dag/src/mixins/editor.js

@@ -1088,6 +1088,26 @@ export default {
       return nodes
     },
 
+    findAllChildNodes(id) {
+      let node = this.scope.findNodeById(id)
+      const nodes = []
+      let ids = node.$outputs || []
+
+      ids.forEach(id => {
+        let child = this.scope.findNodeById(id)
+
+        if (!child) return
+
+        nodes.push(child)
+
+        if (child.$outputs?.length) {
+          nodes.push(...this.findChildNodes(id))
+        }
+      })
+
+      return nodes
+    },
+
     handleDisableNode(node, value = true) {
       this.$set(node, 'disabled', value)
       this.$set(node.attrs, 'disabled', value)
@@ -1728,38 +1748,26 @@ export default {
           })
           return error
         }
-      }
 
-      // const handle = async input => {
-      //   const fields = await this.scope.loadNodeFieldOptions(input)
-
-      //   if (
-      //     fields?.length &&
-      //     !fields.some(item => {
-      //       return item.isPrimaryKey || item.indicesUnique
-      //     })
-      //   ) {
-      //     // 缺少主键或唯一索引
-      //     return Promise.reject(input)
-      //   }
-      // }
-
-      // for (let node of nodes) {
-      //   for (let input of node.$inputs) {
-      //     allPromise.push(handle(input))
-      //   }
-      // }
-
-      // try {
-      //   await Promise.all(allPromise)
-      // } catch (id) {
-      //   this.setNodeErrorMsg({
-      //     id,
-      //     msg: i18n.t('packages_dag_missing_primary_key_or_index')
-      //   })
-      //   this.handleLocateNode(this.nodeById(id))
-      //   return i18n.t('packages_dag_merge_table_missing_key_or_index')
-      // }
+        // 校验主从合并后面是否有js节点
+        const nextNodes = this.findAllChildNodes(node.id)
+
+        if (nextNodes.some(nextNode => nextNode.type === 'js_processor' || nextNode.type === 'standard_js_processor')) {
+          return i18n.t('packages_dag_merge_table_js_node_error')
+        }
+
+        // 目标需要有 master_slave_merge 能力
+        const targetNode = nextNodes.find(
+          nextNode =>
+            nextNode.type === 'table' && !nextNode.attrs?.capabilities?.find(({ id }) => id === 'master_slave_merge')
+        )
+
+        if (targetNode) {
+          return i18n.t('packages_dag_merge_table_table_not_allow_target', {
+            val: targetNode.databaseType
+          })
+        }
+      }
     },
 
     async eachValidate(...fns) {