-import { inspectApi, taskApi } from '@tap/api'
+import { Check } from '@element-plus/icons-vue'
+import { databaseTypesApi, inspectApi, taskApi } from '@tap/api'
import { AsyncSelect } from '@tap/form'
import i18n from '@tap/i18n'
import Time from '@tap/shared/src/time'
import { ElMessage, ElMessageBox } from 'element-plus'
import { cloneDeep } from 'lodash-es'
-import { computed, onMounted, provide, reactive, ref } from 'vue'
+import {
+ computed,
+ onMounted,
+ provide,
+ reactive,
+ ref,
+ useTemplateRef,
+} from 'vue'
import { useRoute, useRouter } from 'vue-router'
import PageContainer from '../../components/PageContainer.vue'
@@ -79,6 +87,8 @@ const defaultTime = ref([
new Date(2025, 2, 1, 23, 59, 59),
])
+const taskSelect = useTemplateRef('taskSelect')
+
const form = reactive({
flowId: '',
name: '',
@@ -202,6 +212,7 @@ const autoAddTableLoading = ref(false)
const taskOptionCache = ref(null)
const baseForm = ref(null)
const conditionBox = ref(null)
+const activePanel = ref('condition')
const saveDisabled = computed(() => {
return (
@@ -279,21 +290,10 @@ const getData = async (id: string) => {
applyTask(data.taskDto)
}
- // 任务一致性/任意表 都走异步获取 capabilities/tags
- const capabilitiesMap = await conditionBox.value.getCapabilities([
- ...new Set([
- ...data.tasks.map((t) => t.source.connectionId),
- ...data.tasks.map((t) => t.target.connectionId),
- ]),
- ])
-
data.tasks = data.tasks.map((t) => {
t.source = Object.assign({}, TABLE_PARAMS, t.source)
t.target = Object.assign({}, TABLE_PARAMS, t.target)
- t.source.capabilities =
- capabilitiesMap[t.source.connectionId]?.capabilities || []
- t.target.capabilities =
- capabilitiesMap[t.target.connectionId]?.capabilities || []
+
if (t.source.nodeId) {
t.source.currentLabel = `${t.source.nodeName} / ${t.source.connectionName}`
t.target.currentLabel = `${t.target.nodeName} / ${t.target.connectionName}`
@@ -476,12 +476,34 @@ const save = async (saveOnly = false) => {
if (webScript && webScript !== '') {
script = `function validate(sourceRow){${webScript}}`
}
+
+ if (
+ source.enableCustomCommand &&
+ source.databaseType.toLowerCase().includes('mongo')
+ ) {
+ source.customCommand.params.collection = source.tableName
+
+ if (source.customCommand.command === 'executeQuery') {
+ source.customCommand.params.op = 'find'
+ }
+ }
+
+ if (
+ target.enableCustomCommand &&
+ target.databaseType.toLowerCase().includes('mongo')
+ ) {
+ target.customCommand.params.collection = target.tableName
+
+ if (target.customCommand.command === 'executeQuery') {
+ target.customCommand.params.op = 'find'
+ }
+ }
+
const newSource = cloneDeep(source)
const newTarget = cloneDeep(target)
newSource.fields = []
newTarget.fields = []
- newSource.capabilities = []
- newTarget.capabilities = []
+
return {
taskId,
source: newSource,
@@ -543,487 +565,493 @@ const handleSelectTask = (task: any, byClick: boolean) => {
}
}
+const ConnectorMap = ref({})
+
+const fetchDatabaseTypes = async () => {
+ const databaseItems = await databaseTypesApi.get()
+
+ ConnectorMap.value = databaseItems.reduce((map, item) => {
+ map[item.type] = {
+ pdkHash: item.pdkHash,
+ isNullsLast: item.tags?.includes('NullsLast'),
+ capabilityMap:
+ item.capabilities?.reduce((map, item) => {
+ map[item.id] = true
+ return map
+ }, {}) || {},
+ }
+ return map
+ }, {})
+}
+
+const openTaskSelect = () => {
+ taskSelect.value.focus()
+ taskSelect.value.$el.querySelector('input').click()
+}
+
+fetchDatabaseTypes()
+
provide('formData', form)
+provide('ConnectorMap', ConnectorMap)
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ Lightning
+ {{ inspectMethodMap['row_count'] }}
+
+
+
+
+ LucideTable
+ {{ inspectMethodMap['field'] }}
+
+
+
+
+ LucideLink
+ {{ inspectMethodMap['jointField'] }}
+
+
+
+
+ LucideHash
+ {{ inspectMethodMap['hash'] }}
+
+
+
+
+ info
+ {{
+ typTipMap[form.inspectMethod]
+ }}
+
+
-
- {{
- inspectMethodMap['row_count']
- }}
- {{
- inspectMethodMap['field']
- }}
- {{
- inspectMethodMap['jointField']
- }}
- {{
- inspectMethodMap['hash']
- }}
-
-
- info
- {{
- typTipMap[form.inspectMethod]
- }}
-
-
+ {{
- $t('packages_business_verification_form_zhengzaijiyuren')
- }}
- loading-circle
-
-
-
-
- {{
+ $t(
+ 'packages_business_verification_form_task_alarm_when_diff_result_over_count1',
+ )
+ }}
+
- {{
+ $t(
+ 'packages_business_verification_form_task_alarm_when_result_table_over_count1',
+ )
+ }}
+
-
-
+ {{
+ $t(
+ 'packages_business_verification_form_task_alarm_when_diff_result_over_count2',
+ )
+ }}
+
+
+
+
+ {{ $t('packages_business_verification_form_xitongtongzhi') }}
+
+ {{
+ $t('packages_business_verification_form_youjiantongzhi')
+ }}
+
+
+
+ {{ $t('packages_business_verification_form_xitongtongzhi') }}
+
+ {{
+ $t('packages_business_verification_form_youjiantongzhi')
+ }}
+
+
+
+ {{ $t('packages_business_verification_form_xitongtongzhi') }}
+
+ {{
+ $t('packages_business_verification_form_youjiantongzhi')
+ }}
+
+
+
+
-
+
+
+
+
+
+
+
+
+
+ {{ $t('packages_business_ignoreTimePrecision') }}
+
- info
-
-
-
-
-
+ :
+
+
+
+
+
+
+ {{ $t('packages_business_checkTableThreadNum') }}
+
-
-
-
-
-
-
- info
-
-
-
-
-
-
-
-
-
-
-
-
-
- {{
- $t(
- 'packages_business_verification_form_task_alarm_when_error',
- )
- }}
-
-
-
- {{
- $t(
- 'packages_business_verification_form_task_alarm_when_diff_result_over_count1',
- )
- }}
-
- {{
- $t(
- 'packages_business_verification_form_task_alarm_when_diff_result_over_count2',
- )
- }}
-
- {{
- $t(
- 'packages_business_verification_form_task_alarm_when_result_table_over_count1',
- )
- }}
-
- {{
- $t(
- 'packages_business_verification_form_task_alarm_when_diff_result_over_count2',
- )
- }}
-
-
-
-
- {{
- $t('packages_business_verification_form_xitongtongzhi')
- }}
-
- {{
- $t('packages_business_verification_form_youjiantongzhi')
- }}
-
-
-
- {{
- $t('packages_business_verification_form_xitongtongzhi')
- }}
-
- {{
- $t('packages_business_verification_form_youjiantongzhi')
- }}
-
-
-
- {{
- $t('packages_business_verification_form_xitongtongzhi')
- }}
-
- {{
- $t('packages_business_verification_form_youjiantongzhi')
- }}
-
-
-
-
-
-
+ :
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
- {{ $t('packages_business_ignoreTimePrecision') }}
-
- info
-
- :
-
-
-
-
-
-
- {{ $t('packages_business_checkTableThreadNum') }}
-
- info
-
- :
-
-
-
-
-
-
-
-
- {{ $t('public_time_m') }}
-
-
-
-
-
-
-
-
-
-
-
-
- {{ $t('public_time_m') }}
+
+
+
+
+
+
+
+
+
-
-
-
-
-