fix-addedflinksqlenv-after-showbug

Zzm0809 · Dec 23, 2023 · 1188792 · 1188792
1 parent fd5cd9c
commit 1188792
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/dinky-web/src/pages/DataStudio/LeftContainer/Project/index.tsx b/dinky-web/src/pages/DataStudio/LeftContainer/Project/index.tsx
@@ -55,6 +55,7 @@ import { Modal, Typography } from 'antd';
 import { MenuInfo } from 'rc-menu/es/interface';
 import React, { Key, useEffect, useState } from 'react';
 import { connect } from 'umi';
+import {DIALECT} from "@/services/constants";
 
 const { Text } = Typography;
 
@@ -222,6 +223,9 @@ const Project: React.FC = (props: connect) => {
           ...prevState
         }));
         dispatch({ type: STUDIO_MODEL_ASYNC.queryProject });
+        if (values.type && values.type.toLowerCase() === DIALECT.FLINKSQLENV) {
+          dispatch({type: STUDIO_MODEL_ASYNC.queryEnv});
+        }
         if (projectState.isEdit) {
           const { id } = values;
           const currentTabs = getTabByTaskId(panes, id);

diff --git a/dinky-web/src/pages/DataStudio/model.ts b/dinky-web/src/pages/DataStudio/model.ts
@@ -20,6 +20,7 @@
 import { getFooterValue, isDataStudioTabsItemType } from '@/pages/DataStudio/function';
 import { getTaskData } from '@/pages/DataStudio/LeftContainer/Project/service';
 import {
+  getEnvData,
   getFlinkConfigs,
   querySuggessionData
 } from '@/pages/DataStudio/RightContainer/JobConfig/service';
@@ -303,6 +304,7 @@ export type ModelType = {
     queryProject: Effect;
     queryFlinkConfigOptions: Effect;
     querySuggestions: Effect;
+    queryEnv: Effect;
   };
   reducers: {
     updateToolContentHeight: Reducer<StateType>;
@@ -411,6 +413,14 @@ const Model: ModelType = {
         payload: response
       });
     },
+    *queryEnv({ payload }, { call, put }) {
+      const response: EnvType[] = yield call(getEnvData, payload);
+      console.log(response)
+      yield put({
+        type: 'saveEnv',
+        payload: response
+      });
+    },
     *queryFlinkConfigOptions({ payload }, { call, put }) {
       const response: [] = yield call(getFlinkConfigs, payload);
       yield put({