From ef59ab85009d75fa74707d021a47951142aa1999 Mon Sep 17 00:00:00 2001
From: Magnus Wang <mingfengx.wang@intel.com>
Date: Tue, 8 Feb 2022 13:42:49 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=88=86=E5=8C=BA=E4=BF=A1?=
 =?UTF-8?q?=E6=81=AFmap&=E9=97=AE=E9=A2=98=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 web/src/common/service.js                     |  14 +++
 .../dataSourceManage/components/editModal.vue |   4 +-
 .../jobManagement/components/dataSource.vue   |   2 +
 .../jobManagement/components/dyncRender.vue   | 110 ++++++++++++++++--
 .../jobManagement/components/executionLog.vue |   8 +-
 .../jobManagement/components/jobDetail.vue    |   3 +
 .../components/selectDataSource.vue           |   4 +-
 7 files changed, 132 insertions(+), 13 deletions(-)

diff --git a/web/src/common/service.js b/web/src/common/service.js
index 18c10fd86..15cc624b7 100644
--- a/web/src/common/service.js
+++ b/web/src/common/service.js
@@ -1,5 +1,6 @@
 // 服务端接口管理
 import { request } from "@fesjs/fes";
+import { BASE_URL } from "@/common/constants";
 ////////////////////////////////////////////////////////////////////
 export const getProjectList = (name) => {
   return request("/projects", { name }, { method: "POST" });
@@ -378,4 +379,17 @@ export const getTaskExecLog = (params) => {
       method: "GET",
     }
   );
+}
+
+// 获取分区信息
+export const getPartitionInfo = (params) => {
+  if (!params.source) return
+  const url = params.source.split(BASE_URL)[1]
+  return request(
+    `${url}?dataSourceId=${params.dataSourceId}&database=${params.database}&table=${params.table}&_=${Math.random()}`,
+    {},
+    {
+      method: "GET",
+    }
+  );
 }
\ No newline at end of file
diff --git a/web/src/pages/dataSourceManage/components/editModal.vue b/web/src/pages/dataSourceManage/components/editModal.vue
index d20147cf0..01e80e47e 100644
--- a/web/src/pages/dataSourceManage/components/editModal.vue
+++ b/web/src/pages/dataSourceManage/components/editModal.vue
@@ -172,7 +172,7 @@ export default {
             dataSourceName: formState.dataSourceName,
             dataSourceDesc: formState.dataSourceDesc || "",
             labels: formState.labels || "",
-            comment: formState.comment || "",
+            comment: formState.comment || "更新",
             connectParams: {
               ...connectParams
             }
@@ -187,7 +187,7 @@ export default {
             dataSourceName: formState.dataSourceName,
             dataSourceDesc: formState.dataSourceDesc || "",
             labels: formState.labels || "",
-            comment: formState.comment || "",
+            comment: formState.comment || "更新",
             connectParams: {
               ...connectParams
             }
diff --git a/web/src/pages/jobManagement/components/dataSource.vue b/web/src/pages/jobManagement/components/dataSource.vue
index 90241d36c..708a9573c 100644
--- a/web/src/pages/jobManagement/components/dataSource.vue
+++ b/web/src/pages/jobManagement/components/dataSource.vue
@@ -62,6 +62,7 @@
                   v-bind:param="item"
                   @updateInfo="updateSourceParams"
                   :style="styleObject"
+                  :data="dataSource.dataSourceIds.source"
                 />
               </a-form-item>
             </a-form>
@@ -108,6 +109,7 @@
                   v-bind:param="item"
                   @updateInfo="updateSinkParams"
                   :style="styleObject"
+                  :data="dataSource.dataSourceIds.sink"
                 />
               </a-form-item>
             </a-form>
diff --git a/web/src/pages/jobManagement/components/dyncRender.vue b/web/src/pages/jobManagement/components/dyncRender.vue
index 7d604f032..1b87893b5 100644
--- a/web/src/pages/jobManagement/components/dyncRender.vue
+++ b/web/src/pages/jobManagement/components/dyncRender.vue
@@ -9,7 +9,31 @@
       :style="style"
     >
     </a-select>
-    <template v-else>
+    <template v-if="type === 'MAP'">
+      <div style="margin-bottom: 5px" v-for="item in partitionArr">
+        <a-input
+          style="width: 100px"
+          disabled
+          v-model:value = item.label
+        />
+        <a-input
+          v-if="item.type === 'INPUT'"
+          v-model:value="item.value"
+          @change="handleChange"
+          style="margin-left: 10px;width: 220px"
+        />
+        <a-select
+          v-if="item.type === 'OPTION'"
+          mode="tags"
+          v-model:value="item.value"
+          :maxTagCount="1"
+          @change="handleChange(item.value, item)"
+          :options="item.options"
+          style="margin-left: 10px;width: 220px"
+        />
+      </div>
+    </template>
+    <template v-if="type === 'INPUT'">
       <a-input
         v-model:value="value"
         @change="emitData(value)"
@@ -22,6 +46,8 @@
 </template>
 <script>
 import { defineComponent, h, toRaw, watch, computed, reactive, ref } from "vue";
+import { getPartitionInfo } from "@/common/service";
+import { message } from "ant-design-vue";
 
 export default defineComponent({
   props: {
@@ -29,13 +55,14 @@ export default defineComponent({
     style: {
       type: Object,
       default: () => {
-        return { width: '200px',  }
+        return { width: '200px' }
       }
-    }
+    },
+    data: Object
   },
   emits: ["updateInfo"],
   setup(props, context) {
-    let { type, field, value, unit} = props.param;
+    let { type, field, value, unit, source} = props.param;
     let tmlName = field.split(".").pop();
     const newProps = computed(() => JSON.parse(JSON.stringify(props.param)));
     watch(newProps, (val, oldVal) => {
@@ -50,18 +77,87 @@ export default defineComponent({
         })
       })
     }
+    let partitionArr = ref([])
+    if (type === 'MAP') {
+      let url = source.split('?')[0]
+      getPartitionInfo({
+        source: url,
+        dataSourceId: props.data.id,
+        database: props.data.db,
+        table: props.data.table
+      })
+        .then(res => {
+          for (let i in res.render) {
+            if (typeof(res.render[i]) === 'string') {
+              partitionArr.value.push({
+                type: 'INPUT',
+                label: i,
+                value: value && value[i] ? value[i] : ''//res.render[i]
+              })
+            } else {
+              let checkOptions = []
+              res.render[i].map((item) => {
+                checkOptions.push({
+                  value: item,
+                  label: item
+                })
+              })
+              partitionArr.value.push({
+                type: 'OPTION',
+                label: i,
+                options: checkOptions,
+                value: value && value[i] ? [value[i]] : []
+              })
+            }
+          }
+        })
+        .catch(err => {
+          message.error("或许分区信息失败");
+        })
+    }
     const emitData = (value) => {
       let res = toRaw(props.param)
       res.value = value
-      context.emit("updateInfo", res);
-    };
+      context.emit("updateInfo", res)
+    }
+
+    const handleChange = (value, item) => {
+      if (item.type === 'OPTION') {
+        if (value) {
+          item.value = [value.pop()]
+        }
+      }
+      let res = toRaw(props.param)
+      if (!res.value) {
+        res.value = {}
+      }
+      partitionArr.value.map(part => {
+        if (part.type === 'OPTION') {
+          if (part.value && part.value.length) {
+            res.value[part.label] = part.value.join()
+          } else {
+            delete res.value[part.label]
+          }
+        } else {
+          if (part.value) {
+            res.value[part.label] = part.value
+          } else {
+            delete res.value[part.label]
+          }
+        }
+      })
+      context.emit("updateInfo", res)
+    }
 
     return {
       checkOptions: ref(checkOptions),
       type,
       value: ref(value),
       emitData,
-      unit
+      unit,
+      source,
+      partitionArr,
+      handleChange
     }
 
     /*if (type === "OPTION") {
diff --git a/web/src/pages/jobManagement/components/executionLog.vue b/web/src/pages/jobManagement/components/executionLog.vue
index 14b0aae5a..39103858f 100644
--- a/web/src/pages/jobManagement/components/executionLog.vue
+++ b/web/src/pages/jobManagement/components/executionLog.vue
@@ -114,11 +114,15 @@ export default defineComponent({
         logs.logs = res.logs
         logs.isEnd = res.isEnd
         const buildLog = (key) => {
-          let arr = logs.logs[key].split('\n')
+          let arr = logs.logs[key] ? logs.logs[key].split('\n') : []
           for (let i = 0; i < arr.length; i++) {
             arr[i] = `${logs.endLine + i + 1}.   ${arr[i]}`
           }
-          return curLog[key] ? curLog[key] + '\n' + arr.join('\n') : arr.join('\n')
+          if (logs.logs[key]) {
+            return curLog[key] ? curLog[key] + '\n' + arr.join('\n') : arr.join('\n')
+          } else {
+            return curLog[key] ? curLog[key] : ''
+          }
         }
         curLog.all = buildLog('all')
         curLog.error = buildLog('error')
diff --git a/web/src/pages/jobManagement/components/jobDetail.vue b/web/src/pages/jobManagement/components/jobDetail.vue
index 25f08ab24..692fed9a0 100644
--- a/web/src/pages/jobManagement/components/jobDetail.vue
+++ b/web/src/pages/jobManagement/components/jobDetail.vue
@@ -1289,6 +1289,9 @@ export default {
   display: flex;
   flex-wrap: wrap;
   padding-bottom: 30px;
+  :deep(.ant-spin-nested-loading) {
+    width: 100%;
+  }
   .emptyTab {
     font-size: 16px;
     height: calc(100vh - 130px);
diff --git a/web/src/pages/jobManagement/components/selectDataSource.vue b/web/src/pages/jobManagement/components/selectDataSource.vue
index d14303e24..42d80595b 100644
--- a/web/src/pages/jobManagement/components/selectDataSource.vue
+++ b/web/src/pages/jobManagement/components/selectDataSource.vue
@@ -57,7 +57,7 @@
           <span>搜索库表</span>
           <a-input
             placeholder="按回车搜库表"
-            style="width: 300px;margin-top: 10px;margin-left:10px"
+            style="width: 300px;margin-top: 10px;margin-left:0"
             v-model:value="searchWord"
             @keyup.enter="filterTree(dsId)"
           ></a-input>
@@ -406,7 +406,7 @@ export default defineComponent({
 }
 .sds-wrap-b {
   min-height: 300px;
-  max-height: 500px;
+  max-height: 400px;
   overflow-y: auto;
 }