Browse Source

feat: init at server.js

ryanemax 8 months ago
parent
commit
0c256001e6
3 changed files with 12 additions and 6 deletions
  1. 4 1
      server/db/func/import-data.js
  2. 2 2
      server/db/func/import-schemas.js
  3. 6 3
      server/server.js

+ 4 - 1
server/db/func/import-data.js

@@ -10,9 +10,12 @@ const db = pgp({
     database: 'postgres'
 });
 
-let initDataSQL = fs.readFileSync("../data/init-data.sql").toString()
+let initDataSQL
+try{initDataSQL = fs.readFileSync("../data/init-data.sql").toString()}catch(err){}
+try{initDataSQL = fs.readFileSync("./db/data/init-data.sql").toString()}catch(err){}
 // 执行SELECT语句并返回结果的函数
 async function main() {
+    console.log("加载初始化数据")
     try {
         // 查询:数据库版本信息
         const data = await db.any(initDataSQL);

+ 2 - 2
server/db/func/import-schemas.js

@@ -26,8 +26,8 @@ async function importAllSchemas(){
           let schema = new Parse.Schema(schemaJson?.className);
   
         schemaJson.fields["isDeleted"] = {
-        "type": "Boolean",
-        "required": false
+          "type": "Boolean",
+          "required": false
         }
         schemaJson.fields["company"] = {
             "type": "Pointer",

+ 6 - 3
server/server.js

@@ -145,13 +145,16 @@ async function initParseAndDatabase(){
     /**
      * Listen on provided port, on all network interfaces.
      */
-    app.listen(global.parseConfig?.port, function() {
+    app.listen(global.parseConfig?.port, async function() {
       console.log('微服务已运行,端口 ' + global.parseConfig?.port + '.');
       // 迁移数据范式 Schemas
-      importAllSchemas();
+      await importAllSchemas();
+      // 导入初始化数据
+      setTimeout(() => {
+        require("./db/func/import-data")
+      }, 500);
     });
  
-    
     console.log("正在启动管理看板...")
     console.log("浏览器管理看板:","http://localhost:61337/dashboard")
   }catch(err){