1

server/web3dbspider/services/dbevent_process.js

@@ -40,14 +40,15 @@ class DbEventProcess extends BaseService {
   }
 
   async init(net, event) {
-    const {err, conn} = await app.getDbConn('BcEventDb0');
-    this.conn = conn;
+    console.log(event);
     this.net = net;
     this.event = event;
     this.lastIdx = BigInt(0);
     this.eventConf = this.event['eventConf'];
     this.progInfo = this.event['progressInfo'];
     this.contractAddress = this.net.getContractAddressByName(this.getContractName());
+    const {err, conn} = await app.getDbConn('BcEventDb0');
+    this.conn = conn;
     this.lastIdx = await this.getLastIdx();
     this.progInfo['proclastIdx'] = this.lastIdx.toString();
     await this.start();

server/web3dbspider/tasks/dbspider.js

@@ -41,6 +41,7 @@ class DbSpider extends BaseTask {
         this.createPullDbEventService(net, event);
         this.createDbEventProcessService(net, event);
       });
+    await utils.sleep(1000 * 10);
     this.outputProgressInfo(net, events);
   }
 
@@ -52,14 +53,13 @@ class DbSpider extends BaseTask {
   }
 
   createDbEventProcessService(net, event) {
-    const DbEventProcessService = serviceFactory.create('DbEventProcess');
-    event['dbEventProcessService'] = DbEventProcessService;
-    DbEventProcessService.init(net, event);
-    return DbEventProcessService;
+    const dbEventProcessService = serviceFactory.create('DbEventProcess');
+    event['dbEventProcessService'] = dbEventProcessService;
+    dbEventProcessService.init(net, event);
+    return dbEventProcessService;
   }
 
   async outputProgressInfo(net, events) {
-    await utils.sleep(1000 * 10);
     let count = 0;
     while (true) {
       log.info('----------------------------------------------------------');