From 80e76e23dab7021ef7410f384bf552038bbd5225 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Mon, 10 Jul 2023 14:46:48 +0800 Subject: [PATCH] 1 --- database/bcevent.sql | 1 + .../web3bcspider/services/erc721_refresher.js | 18 +++++++++++++++++- 2 files changed, 18 insertions(+), 1 deletion(-) diff --git a/database/bcevent.sql b/database/bcevent.sql index a3d36ce..77305a7 100644 --- a/database/bcevent.sql +++ b/database/bcevent.sql @@ -149,6 +149,7 @@ CREATE TABLE `t_erc721_refresh` ( `contract_name` varchar(60) NOT NULL DEFAULT '' COMMENT 'contract_name', `token_id` varchar(60) NOT NULL DEFAULT '' COMMENT 'token_id', `status` int(11) NOT NULL DEFAULT '0' COMMENT '0: dirty', + `refresh_count` bigint NOT NULL DEFAULT '0' COMMENT 'refresh_count', `createtime` int(11) NOT NULL DEFAULT '0' COMMENT '创建时间', `modifytime` int(11) NOT NULL DEFAULT '0' COMMENT '修改时间', PRIMARY KEY (`idx`), diff --git a/server/web3bcspider/services/erc721_refresher.js b/server/web3bcspider/services/erc721_refresher.js index 4b19f90..a71e58b 100644 --- a/server/web3bcspider/services/erc721_refresher.js +++ b/server/web3bcspider/services/erc721_refresher.js @@ -113,7 +113,9 @@ class Erc721Refresher extends BaseService { ], [ ['owner_address', bcutils.toNormalAddress(newOwner)], - ['confirm_count', this.nftDb['confirm_count'] + 1], + ['confirm_count', () => { + return 'confirm_count + 1'; + }], ['confirm_block_number', blockNumber] ]); if (err) { @@ -127,6 +129,20 @@ class Erc721Refresher extends BaseService { return true; } + async update(row, fields) { + const {err} = await this.conn.update( + 't_erc721_refresh', + [ + ['idx', row['idx']], + ['net_id', row['net_id']], + ['token_id', row['token_id']], + ['contract_address', row['contract_address']], + ['refresh_count', row['refresh_count']], + ], + fields, + ); + } + } module.exports = Erc721Refresher;