From df58373bf5b36ede78bfea9a4afa50da69093338 Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Thu, 13 Jul 2023 15:48:17 +0800
Subject: [PATCH] 1

---
 server/web3bcspider/services/erc721_refresher.js | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git a/server/web3bcspider/services/erc721_refresher.js b/server/web3bcspider/services/erc721_refresher.js
index 50396d2..4e2999e 100644
--- a/server/web3bcspider/services/erc721_refresher.js
+++ b/server/web3bcspider/services/erc721_refresher.js
@@ -3,6 +3,7 @@ const utils = require('j7/utils');
 const bcutils = require('j7/bcutils');
 const log = require('j7/log');
 const constant = require('common/constant');
+const dbpool = require('common/dbpool');
 const BaseService = require('./baseservice');
 
 const LIMIT_COUNT = 100;
@@ -10,8 +11,6 @@ const LIMIT_COUNT = 100;
 class Erc721Refresher extends BaseService {
 
   async init(bc, net, refresher) {
-    const {err, conn} = await app.getDbConn(constant.BCEVENTDB_NAME);
-    this.conn = conn;
     this.bc = bc;
     this.net = net;
     this.refresher = refresher;
@@ -31,8 +30,10 @@ class Erc721Refresher extends BaseService {
   async pullEvent() {
     const logHead = this.genLogHead('pullEvent ');
     try {
-      const {err, rows} = await this.conn.execQuery(
-        'SELECT * FROM t_erc721_refresh WHERE idx > ' + this.lastIdx.toString() + ' ' +
+      const {err, rows} = await dbpool.getBcEventConn(
+        app,
+        'execQuery',
+        ',SELECT * FROM t_erc721_refresh WHERE idx > ' + this.lastIdx.toString() + ' ' +
           'AND net_id = ? AND contract_address = ? AND status = 0 ' +
           'LIMIT ' + LIMIT_COUNT,
         [
@@ -207,7 +208,9 @@ class Erc721Refresher extends BaseService {
   }
 
   async update(row, fields) {
-    const {err} = await this.conn.update(
+    const {err} = await this.dbpool.getBcEventConn(
+      app,
+      'update',
       't_erc721_refresh',
       [
         ['idx', row['idx']],