数据源管理功能提交

api/app/lib/routes/metadataAcquisition/adapter.js

@@ -8,7 +8,7 @@ module.exports = function (app, router, opts, AuthCode) {
     router.post('/adapter/check/connect', adapter.checkConnect(opts))
 
     app.fs.api.logAttr['POST/adapter'] = { content: '增加适配器', visible: true };
-    router.post('/adapter', adapter.addAdapter(opts))
+    router.post('/meta/acq/adapter', adapter.addAdapter(opts))
 
 
 };

web/client/src/sections/metadataAcquisition/actions/adapter.js

@@ -15,3 +15,17 @@ export function checkPostgreConnect(params) {
         },
     });
 }
+
+export function addAdapter(params) {
+    return (dispatch) => basicAction({
+        type: 'post',
+        data: params,
+        dispatch,
+        actionType: 'ADD_ADAPTER',
+        url: ApiTable.addAdapter,
+        msg: {
+            option: '新增适配器',
+        },
+    });
+}
+

web/client/src/sections/metadataAcquisition/actions/dataSource.js

@@ -0,0 +1,18 @@
+'use strict';
+
+import { basicAction } from '@peace/utils'
+import { ApiTable } from '$utils'
+
+export function addDataSource(params, msg) {
+    return (dispatch) => basicAction({
+        type: 'post',
+        data: params,
+        dispatch,
+        actionType: 'ADD_ADAPTER',
+        url: ApiTable.addDataSource,
+        msg: {
+            option: msg || '新增数据源',
+        },
+    });
+}
+

web/client/src/sections/metadataAcquisition/actions/index.js

@@ -2,8 +2,10 @@
 
 import * as example from './example'
 import * as adapter from './adapter'
+import * as dataSource from './dataSource'
 
 export default {
     ...example,
     ...adapter,
+    ...dataSource
 }

web/client/src/sections/metadataAcquisition/components/adapterStep.js

@@ -23,6 +23,12 @@ const AdapterStep = (props) => {
     const stepTwoValuesFinish = (values) => {
         setStepTwoValues(values)
     }
+    const onFinish = () => {
+        props.onFinish({
+            stepOneValues,
+            stepTwoValues
+        })
+    }
 
     const steps = [
         {
@@ -35,7 +41,7 @@ const AdapterStep = (props) => {
         },
         {
             title: '配置计划任务',
-            content: <StepThree prev={prev} next={next} />,
+            content: <StepThree prev={prev} next={onFinish} />,
         },
     ];
 

web/client/src/sections/metadataAcquisition/components/steps/postgre/stepOne.js

@@ -41,6 +41,7 @@ function StepOne(props) {
                 },
             }}
         >
+            
             <ProFormText
                 rules={[{ required: true, message: '请输入数据源名称' },
                 { max: 255, message: '数据源名称长度不能大于255个字符' },

web/client/src/sections/metadataAcquisition/components/steps/postgre/stepThree.js

@@ -10,9 +10,9 @@ import {
 
 import '../../style.less';
 function StepThree(props) {
-    const { prev, next, stepOneValues, stepOneValuesFinish } = props;
+    const { prev, next, } = props;
     const formRef = React.createRef();
-    const initialValues = stepOneValues ? stepOneValues : {
+    const initialValues = {
 
     }
     const formItemLayout = { labelCol: { span: 4 }, wrapperCol: { span: 10 } };
@@ -29,7 +29,6 @@ function StepThree(props) {
             }}
             onFinish={async (values) => {
                 next()
-                stepOneValuesFinish(values)
                 return true;
             }}
             style={{ marginTop: 20 }}

web/client/src/sections/metadataAcquisition/containers/adapter.js

@@ -33,6 +33,13 @@ const LatestMetadata = (props) => {
         { label: '关系型数据库', key: '关系型数据库', children: renderRelationalDatabase() },
     ];
 
+    const onFinish = (values) => {
+        const { stepOneValues, stepTwoValues } = values;
+        dispatch(actions.metadataAcquisition.addDataSource({
+           
+        }))
+    }
+
     return <>
         <Tabs items={items} />
         <Modal
@@ -45,6 +52,7 @@ const LatestMetadata = (props) => {
         >
             <AdapterStep
                 type={isModalOpen} //当前卡片的key （目前只有postgre,支持后续扩展）
+                onFinish={onFinish}
                 {...props}
             />
         </Modal>

web/client/src/utils/webapi.js

@@ -20,6 +20,8 @@ export const ApiTable = {
 
     //元数据采集
     pgCheckConnect: 'adapter/check/connect',
+    addDataSource: 'meta/acq/dataSource',
+
 };
 
 export const RouteTable = {