From a98da690a7b0ded1dfff980cd922542b62d29b6d Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Tue, 11 Jul 2023 18:07:14 +0800
Subject: [PATCH] 1

---
 .../events/common/BaseEventProcess.js         | 27 ++++++++++++++-----
 1 file changed, 20 insertions(+), 7 deletions(-)

diff --git a/server/web3dbspider/services/events/common/BaseEventProcess.js b/server/web3dbspider/services/events/common/BaseEventProcess.js
index 2a70d7a..06ffad3 100644
--- a/server/web3dbspider/services/events/common/BaseEventProcess.js
+++ b/server/web3dbspider/services/events/common/BaseEventProcess.js
@@ -158,18 +158,27 @@ class BaseEventProcess {
   }
 
   async bcEventDbConn(method, ...args) {
-    const conn = await this.recreateConn('bcEventConn', constant.BCEVENTDB_NAME);
-    return await this.internalDbConn(conn, method, ...args);
+    const ret = await this.recreateConn('bcEventConn', constant.BCEVENTDB_NAME);
+    if (ret.err) {
+      return ret;
+    }
+    return await this.internalDbConn(ret.conn, method, ...args);
   }
 
   async bcNftDbConn(method, ...args) {
-    const conn = await this.recreateConn('bcNftConn', constant.BCNFTDB_NAME);
-    return await this.internalDbConn(conn, method, ...args);
+    const ret = await this.recreateConn('bcNftConn', constant.BCNFTDB_NAME);
+    if (ret.err) {
+      return ret;
+    }
+    return await this.internalDbConn(ret.conn, method, ...args);
   }
 
   async gameDbConn(method, ...args) {
-    const conn = await this.recreateConn('gameConn', constant.GAMEDB_NAME);
-    return await this.internalDbConn(conn, method, ...args);
+    const ret = await this.recreateConn('gameConn', constant.GAMEDB_NAME);
+    if (ret.err) {
+      return ret;
+    }
+    return await this.internalDbConn(ret.conn, method, ...args);
   }
 
   async recreateConn(connName, dbName) {
@@ -178,13 +187,17 @@ class BaseEventProcess {
       if (err) {
         return {
           'err': err,
+          'conn': null,
           'row': null,
           'rows': null
         };
       }
       this[connName] = conn;
     }
-    return this[connName];
+    return {
+      'err': null,
+      'conn': this[connName]
+    };
   }
 
   async internalDbConn(conn, method, ...args) {