diff --git a/server/web3bcspider/services/erc721_refresher.js b/server/web3bcspider/services/erc721_refresher.js
index 5f3ae01..cce5c36 100644
--- a/server/web3bcspider/services/erc721_refresher.js
+++ b/server/web3bcspider/services/erc721_refresher.js
@@ -117,11 +117,12 @@ class Erc721Refresher extends BaseService {
   async updateConfirmed(newOwner, blockNumber, row) {
     const logHead = this.genLogHead('updateConfirmed ');
     const tokenId = row['token_id'];
-    const {err, nftDbConn} = await app.getDbConn(constant.BCNFTDB_NAME);
+    const {err, conn} = await app.getDbConn(constant.BCNFTDB_NAME);
     if (err) {
       log.error(logHead + tokenId + ' err:' + err);
       return false;
     }
+    const nftDbConn = conn;
     try {
       {
         const {err} = await nftDbConn.update(
@@ -152,11 +153,12 @@ class Erc721Refresher extends BaseService {
   async tokenIsExists(rawRow) {
     const logHead = this.genLogHead('tokenIsExists ');
     const tokenId = rawRow['token_id'];
-    const {err, nftDbConn} = await app.getDbConn(constant.BCNFTDB_NAME);
+    const {err, conn} = await app.getDbConn(constant.BCNFTDB_NAME);
     if (err) {
       log.error(logHead + tokenId + ' err:' + err);
       return false;
     }
+    const nftDbConn = conn;
     try {
       {
         const {err, row} = await nftDbConn.ormSelectOne(
diff --git a/server/web3bcspider/services/pull_bcevent.js b/server/web3bcspider/services/pull_bcevent.js
index e9cf3dc..2cc64b5 100644
--- a/server/web3bcspider/services/pull_bcevent.js
+++ b/server/web3bcspider/services/pull_bcevent.js
@@ -9,11 +9,11 @@ let g_bcevent_conn = null;
 let lock_times = 0;
 async function getGBcEventConn() {
   if (!g_bcevent_conn) {
+    while (lock_times > 0) {
+      await utils.sleep(1);
+    }
     ++lock_times;
     try {
-      while (lock_times > 1) {
-        await utils.sleep(1);
-      }
       const {err, conn} = await app.getDbConn(constant.BCEVENTDB_NAME);
       if (err) {
         throw new Error('getGBcEventConn error:' + err);