server/game2006web3
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2023-07-10 20:27:02 +08:00
parent d6ff05a27c
commit 9af75f978b
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
server/web3bcspider/services/erc721_refresher.js
View File

@ -115,9 +115,11 @@ class Erc721Refresher extends BaseService {
} }
async updateConfirmed(newOwner, blockNumber, row) { 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, nftDbConn} = await app.getDbConn(constant.BCNFTDB_NAME);
if (err) { if (err) {
log.error('updateConfirmed:' + this.tokenId + ' err:' + err); log.error(logHead + tokenId + ' err:' + err);
return false; return false;
} }
try { try {
@ -137,7 +139,7 @@ class Erc721Refresher extends BaseService {
['confirm_block_number', blockNumber] ['confirm_block_number', blockNumber]
]); ]);
if (err) { if (err) {
log.error('updateConfirmed:' + this.tokenId + ' err:' + err); log.error(logHead + tokenId + ' err:' + err);
return false; return false;
} }
} }
@ -148,9 +150,11 @@ class Erc721Refresher extends BaseService {
} }
async tokenIsExists(rawRow) { async tokenIsExists(rawRow) {
const logHead = this.genLogHead('tokenIsExists ');
const tokenId = rawRow['token_id'];
const {err, nftDbConn} = await app.getDbConn(constant.BCNFTDB_NAME); const {err, nftDbConn} = await app.getDbConn(constant.BCNFTDB_NAME);
if (err) { if (err) {
log.error('updateConfirmed:' + this.tokenId + ' err:' + err); log.error(logHead + tokenId + ' err:' + err);
return false; return false;
} }
try { try {
@ -163,7 +167,7 @@ class Erc721Refresher extends BaseService {
['contract_address', rawRow['contract_address']], ['contract_address', rawRow['contract_address']],
]); ]);
if (err) { if (err) {
log.error('updateConfirmed:' + this.tokenId + ' err:' + err); log.error(logHead + tokenId + ' err:' + err);
return false; return false;
} }
if (row) { if (row) {