update:修改元数据采集任务

xukangle
Showing 2 changed files with 73 additions and 38 deletions
src/api/modules/dataMetaService.ts
src/views/data_meta/collectorTask.vue
--- a/src/api/modules/dataMetaService.ts
View file @eff4413
+++ b/src/api/modules/dataMetaService.ts
View file @eff4413
@@ -196,6 +196,11 @@ export const getDatabase = (params) => request({
  method: 'post',
  data: params
 })
+// 检验是否存在导入数据源
+export const checkDataSource = (params) => request({
+  url: `${import.meta.env.VITE_APP_PLAN_BASEURL}/meta-collect-task/check-exist-import-database?databaseNameEn=${params.databaseNameEn}`,
+  method: 'get',
+})
 /** 源数据分析报告 */
 /**查询列表 */
--- a/src/views/data_meta/collectorTask.vue
View file @eff4413
+++ b/src/views/data_meta/collectorTask.vue
View file @eff4413
@@ -14,9 +14,10 @@ import {
  checkMetaDataTask,
  executeMetaDataTask,
  getDatabase,
-  checkDatabaseIsExist
+  checkDatabaseIsExist,
+  checkDataSource
 } from '@/api/modules/dataMetaService';
-import  {
+import {
  getCronExecTime
 } from '@/api/modules/queryService';
 import { TableColumnWidth } from '@/utils/enum';
@@ -79,12 +80,12 @@ const page = ref({
 const tableInfo = ref({
  id: 'data-source-table',
- // multiple:true,
+  // multiple:true,
  fields: [
    { label: "序号", type: "index", width: TableColumnWidth.INDEX, align: "center" },
    { label: "采集任务名称", field: "collectTaskName", width: 140 },
    { label: "元模型", field: "metadataModelChName", width: 140 },
-    { label: "数据源名称", field: "datasourceName", width: 160,type: 'text_btn', value: 'datasourceName',columClass:"text_btn" },
+    { label: "数据源名称", field: "datasourceName", width: 160, type: 'text_btn', value: 'datasourceName', columClass: "text_btn" },
    { label: '任务状态', field: 'taskState', type: 'switch', activeText: '上线', inactiveText: '下线', activeValue: 1, inactiveValue: 0, switchWidth: 56, width: 100, align: 'center' },
    { label: "执行计划", field: "collectType", type: 'filter', width: 90 },
    { label: "同步策略", field: "collectMode", type: 'filter', width: 90 },
@@ -126,17 +127,17 @@ const tableInfo = ref({
 const collectType = ref(1)
 const formItems: any = ref([
-{
+  {
    label: '元模型',
    type: 'select',
    placeholder: '请选择',
    field: 'metadataModel',
    default: '1',
-    options:[
+    options: [
-      { label:"数据库表", value:'1' },
+      { label: "数据库表", value: '1' },
      // {label:"BI报表",value:2,},
      // {label:"数据服务",value:3,},
-      { label:"ETL工具",value:'4' },
+      { label: "ETL工具", value: '4' },
      // {label:"数据处理",value:5,}
    ],
    clearable: true,
@@ -425,25 +426,25 @@ const tableBtnClick = (scope, btn) => {
        }
      });
    })
-  } else if(type=="datasourceName"){
+  } else if (type == "datasourceName") {
    if (row.metadataModel == '4') {
      proxy.$ElMessage.warning("元模型为ETL工具的采集任务无元数据详情！")
      return;
    }
-    checkDatabaseIsExist(row.dataSourceGuid).then((res:any)=>{
+    checkDatabaseIsExist(row.dataSourceGuid).then((res: any) => {
-        if(res.code===proxy.$passCode){
+      if (res.code === proxy.$passCode) {
-          if(res.data){
+        if (res.data) {
-            router.push({
+          router.push({
-              name:"metadataQuery",
+            name: "metadataQuery",
-              query:{
+            query: {
-              dataSourceGuid:row.dataSourceGuid,
+              dataSourceGuid: row.dataSourceGuid,
-              datasourceName:row.datasourceName,
+              datasourceName: row.datasourceName,
-              }
+            }
-            })
+          })
-          } else {
+        } else {
-            proxy.$ElMessage.warning("该任务暂未执行成功过！")
+          proxy.$ElMessage.warning("该任务暂未执行成功过！")
-          }
        }
+      }
    })
  }
 };
@@ -498,6 +499,35 @@ const scheduleChange = (val, rowValue) => {
  formInfo.value.formInfo.items = formItems.value
 }
+const databaseNameEn = ref<any>('')
+const selectChange = (val, row, info) => {
+  //  dataSourceList.value
+  console.log(val, row, info)
+  let data: any = dataSourceList.value.find((item: any) => item.guid == val)
+  if (data) {
+    databaseNameEn.value = data.databaseNameEn
+    checkDataSource({
+      databaseNameEn: databaseNameEn.value,
+    }).then((res: any) => {
+      if (res.code == proxy.$passCode) {
+        if (!res.data) {
+          proxy.$ElMessage({
+            type: 'warning',
+            message: '已存在导入数据源,请确认是否覆盖!',
+          })
+        }
+      } else {
+        proxy.$ElMessage({
+          type: 'error',
+          message: res.msg,
+        })
+      }
+    })
+  }
+}
 // 切换结构类型 设置选项显隐
 const setGroup = () => {
  if (collectType.value == 2) {
@@ -518,8 +548,9 @@ const taskCreateDialogRef = ref();
 const dialogBtnClick = (btn, info) => {
  if (btn.value == 'submit') {
-    let params = { ...info ,}
+    let params = { ...info, }
-   // params.taskState = 1;
+    // params.taskState = 1;
+    params.databaseNameEn = databaseNameEn.value
    if (dialogInfo.value.type == 'add') {
      params.taskState = 1;
      addMetaDataTask(params).then((res: any) => {
@@ -552,7 +583,7 @@ const dialogBtnClick = (btn, info) => {
    }
  } else if (btn.value == 'cancel') {
    dialogInfo.value.visible = false;
-  }  else if (btn.value = 'cron') {
+  } else if (btn.value = 'cron') {
    let vInfo = taskCreateDialogRef.value.dialogFormRef[0].formInline;
    if (!vInfo.execCycle) {
      return;
@@ -573,13 +604,13 @@ const dialogBtnClick = (btn, info) => {
 const importMeta = () => {
  let query: any = {
-      isfileImport: '4'
+    isfileImport: '4'
-    }
+  }
-    // 打开导入文件.
+  // 打开导入文件.
-    router.push({
+  router.push({
-      name: 'importFileMeta',
+    name: 'importFileMeta',
-      query: query
+    query: query
-    });
+  });
 }
 onActivated(() => {
@@ -594,7 +625,7 @@ onBeforeMount(() => {
 <template>
  <div class="container_wrap">
    <div class="table_tool_wrap">
-     <!-- 头部搜索 -->
+      <!-- 头部搜索 -->
      <TableTools :searchItems="searchItemList" :searchId="'data-source-search'" @search="toSearch" :init="false" />
      <div class="tools_btns">
        <el-button type="primary" @click="loadDrawer">新建</el-button>
@@ -603,17 +634,16 @@ onBeforeMount(() => {
    </div>
    <div class="table_panel_wrap">
      <!-- 右侧采集任务表格 -->
-      <Table :tableInfo="tableInfo" @tableBtnClick="tableBtnClick"
+      <Table :tableInfo="tableInfo" @tableBtnClick="tableBtnClick" @tablePageChange="tablePageChange"
-        @tablePageChange="tablePageChange" @tableSwitchBeforeChange="tableSwitchBeforeChange" />
+        @tableSwitchBeforeChange="tableSwitchBeforeChange" />
    </div>
    <!-- 新建编辑采集任务对话框 -->
-    <Dialog ref="taskCreateDialogRef" :dialogInfo="dialogInfo" @btnClick="dialogBtnClick" @radioGroupChange="radioGroupChange"
+    <Dialog ref="taskCreateDialogRef" :dialogInfo="dialogInfo" @btnClick="dialogBtnClick"
-      @scheduleChange="scheduleChange" />
+      @radioGroupChange="radioGroupChange" @scheduleChange="scheduleChange" @selectChange="selectChange" />
  </div>
 </template>
 <style scoped lang="scss">
 .table_tool_wrap {
  width: 100%;
  height: 84px !important;