修改bug

src/views/dataIntegration/dataLoading/dataEntryLake/importModal.vue

@@ -37,10 +37,12 @@
   import { BasicForm, useForm } from '@/components/Form';
   import { importFormSchema } from './dataEntry.data';
   import { Alert } from 'ant-design-vue';
+  import {useMessage} from "@/hooks/web/useMessage";
 
   const emit = defineEmits(['success', 'register']);
   const isUpdate = ref(true);
   const isMove = ref(false);
+  const { createMessage } = useMessage();
   const rowId = ref('');
   //获取接口数据并放在下拉框里（这里是打开了一个弹框）
   //初始化表单
@@ -75,6 +77,7 @@
 
   /**确定按钮*/
   async function handleSubmit() {
+    createMessage.success('导入成功');
     closeModal();
   }
 </script>

src/views/realTimeSync/dataBaseToDataBase/data.ts

@@ -395,9 +395,9 @@ export const sourceSideConfigurationFormSchema: FormSchema[] = [
     ifShow: ({ model }) => model.sourceType === '2' && model.analysisType === '1',
   },
   {
-    field: 'analysisAlter1',
+    field: 'analysisAlter2',
     label: '',
-    slot: 'analysisAlter1',
+    slot: 'analysisAlter2',
     ifShow: ({ model }) => model.sourceType === '2' && model.analysisType === '2',
   },
   {
@@ -450,6 +450,7 @@ export const sourceSideConfigurationFormSchema: FormSchema[] = [
     field: 'xstreaName',
     label: 'xstream服务名称',
     component: 'Input',
+    required: true,
     ifShow: ({ model }) => model.sourceType === '2' && model.analysisType === '2',
   },
   {
@@ -530,7 +531,7 @@ export const kafkaOptionsFormSchema: FormSchema[] = [
       min: 1,
       max: 50,
     },
-    defaultValue: 1,
+    defaultValue: 3,
     required: true,
     colProps: { lg: 4, md: 4 },
   },
@@ -561,6 +562,7 @@ export const mappingRulesTopicTableColumns: BasicColumn[] = [
     editable: true,
     editComponent: 'Select',
     editComponentProps: {
+      maxTagCount: 1,
       showArrow: true,
       mode: 'multiple',
       options: [

src/views/realTimeSync/dataBaseToDataBase/optionPage.vue

@@ -268,6 +268,14 @@
                   />
                 </template>
                 <template #mappingRules2>
+                  <Alert
+                    show-icon
+                    message="当前默认情况按照表数量平均分配到设置的Topic中，若Topic数量大于表数量，则无映射关系的Topic不会被创建。"
+                    type="warning"
+                    style="font-size: 14px"
+                  />
+                </template>
+                <template #mappingRules3>
                   <Alert
                     show-icon
                     message="源端表没有匹配的topic，会按照默认策略进行匹配topic。不支持用户在发布版本并运行任务后在修改topic映射规则，可能会导致数据去失。"
@@ -716,6 +724,14 @@
       label: '',
       slot: 'mappingRules2',
       colProps: { lg: 24, md: 24 },
+      ifShow: ({ model }) => model.topicMappingType === '1',
+    },
+    {
+      field: 'mappingRules3',
+      label: '',
+      slot: 'mappingRules3',
+      colProps: { lg: 24, md: 24 },
+      ifShow: ({ model }) => model.topicMappingType === '2',
     },
     {
       field: 'mappingRulesTable',
@@ -1139,18 +1155,25 @@
     }
   }
   function handleDeleteRules() {
-    const selectedKeys = getRowSelection().selectedRowKeys;
-    if (selectedKeys !== undefined) {
-      selectedKeys.forEach((key) => {
-        const index = mappingRuleConfigurationTable.value.findIndex(
-          (item) => item.businessId === key,
-        );
-        if (index !== -1) {
-          mappingRuleConfigurationTable.value.splice(index, 1);
+    createConfirm({
+      iconType: 'warning',
+      title: '确认删除',
+      content: '确认批量删除选中数据吗？',
+      onOk() {
+        const selectedKeys = getRowSelection().selectedRowKeys;
+        if (selectedKeys !== undefined) {
+          selectedKeys.forEach((key) => {
+            const index = mappingRuleConfigurationTable.value.findIndex(
+              (item) => item.businessId === key,
+            );
+            if (index !== -1) {
+              mappingRuleConfigurationTable.value.splice(index, 1);
+            }
+          });
+          createMessage.success('批量删除数据转换规则成功');
         }
-      });
-      createMessage.success('批量删除数据转换规则成功');
-    }
+      },
+    });
   }
 
   /**新增属性*/