From 120fe7e0b2b93651d04b99fa94aff4747f28b97e Mon Sep 17 00:00:00 2001
From: "peng.peng" <peng.peng@free-sun.com.cn>
Date: Mon, 27 Mar 2023 14:30:32 +0800
Subject: [PATCH] =?UTF-8?q?(*)=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?=
 =?UTF-8?q?=E5=A4=84=E7=90=86=E6=8F=90=E4=BA=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../metadataAcquisition/taskHandle.js         | 23 ++++++++++++++++++-
 1 file changed, 22 insertions(+), 1 deletion(-)

diff --git a/api/app/lib/controllers/metadataAcquisition/taskHandle.js b/api/app/lib/controllers/metadataAcquisition/taskHandle.js
index c5ae7b3..fb1e5ee 100644
--- a/api/app/lib/controllers/metadataAcquisition/taskHandle.js
+++ b/api/app/lib/controllers/metadataAcquisition/taskHandle.js
@@ -1,5 +1,6 @@
 
 const Automate = require('sequelize-automate-freesun')
+const moment = require('moment');
 
 async function handleTask(app, task) {
     try {
@@ -14,7 +15,27 @@ async function handleTask(app, task) {
             const dbOptions = createDbOptions(dataSource.config);
             const automate = new Automate(dbOptions, {});
             const tables = await automate.getTables()
-            console.log(tables)
+
+            //创建或更新库元数据
+            const dataToSave = {
+                code: dataSource.config.database,
+                name: dataSource.config.database,
+                catalog: dataSource.mountPath,
+                parent: null,
+                description: null,
+                type: "库",
+                createBy: 1,
+                createAt: moment(),
+                updateAt: null,
+                user: { id: 1, name: "超级管理员", username: "SuperAdmin" },
+                attributesParam: null
+            }
+            // const databaseRslt = await models.MetadataDatabase.create(dataToSave)
+            //创建或更新表元数据
+            //创建或更新字段&索引&外键元数据
+            // MetadataDatabase
+
+            // console.log(databaseRslt)
         }
     } catch (error) {
         app.fs.logger.error(`sechedule: handleTask, error: ${error}`);