From fdc97773d1b3fb1da69ecc624e31888b7b46fac5 Mon Sep 17 00:00:00 2001
From: whyour <imwhyour@gmail.com>
Date: Fri, 14 Jan 2022 23:17:16 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=95=B0=E6=8D=AE=E8=BF=81?=
 =?UTF-8?q?=E7=A7=BB=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 back/loaders/db.ts | 54 ++++++++++++++++++++++------------------------
 1 file changed, 26 insertions(+), 28 deletions(-)

diff --git a/back/loaders/db.ts b/back/loaders/db.ts
index dae77958..13edfdc2 100644
--- a/back/loaders/db.ts
+++ b/back/loaders/db.ts
@@ -66,35 +66,33 @@ export default async () => {
     }
 
     // migrate db to sqlite
-    setTimeout(async () => {
-      try {
-        const count = await CrontabModel.count();
-        if (count !== 0) {
-          return;
-        }
-        db.cronDb.find({}).exec(async (err, docs) => {
-          await CrontabModel.bulkCreate(docs);
-        });
-
-        db.dependenceDb.find({}).exec(async (err, docs) => {
-          await DependenceModel.bulkCreate(docs);
-        });
-
-        db.envDb.find({}).exec(async (err, docs) => {
-          await EnvModel.bulkCreate(docs);
-        });
-
-        db.appDb.find({}).exec(async (err, docs) => {
-          await AppModel.bulkCreate(docs);
-        });
-
-        db.authDb.find({}).exec(async (err, docs) => {
-          await AuthModel.bulkCreate(docs);
-        });
-      } catch (error) {
-        console.log(error);
+    try {
+      const count = await CrontabModel.count();
+      if (count !== 0) {
+        return;
       }
-    }, 5000);
+      db.cronDb.find({}).exec(async (err, docs) => {
+        await CrontabModel.bulkCreate(docs, { ignoreDuplicates: true });
+      });
+
+      db.dependenceDb.find({}).exec(async (err, docs) => {
+        await DependenceModel.bulkCreate(docs, { ignoreDuplicates: true });
+      });
+
+      db.envDb.find({}).exec(async (err, docs) => {
+        await EnvModel.bulkCreate(docs, { ignoreDuplicates: true });
+      });
+
+      db.appDb.find({}).exec(async (err, docs) => {
+        await AppModel.bulkCreate(docs, { ignoreDuplicates: true });
+      });
+
+      db.authDb.find({}).exec(async (err, docs) => {
+        await AuthModel.bulkCreate(docs, { ignoreDuplicates: true });
+      });
+    } catch (error) {
+      console.log(error);
+    }
 
     Logger.info('✌️ DB loaded');
   } catch (error) {