diff --git a/database/bcevent.sql b/database/bcevent.sql
index 0a3b767..a3d36ce 100644
--- a/database/bcevent.sql
+++ b/database/bcevent.sql
@@ -148,7 +148,7 @@ CREATE TABLE `t_erc721_refresh` (
   `contract_address` varchar(60) NOT NULL DEFAULT '' COMMENT 'contract_address',
   `contract_name` varchar(60) NOT NULL DEFAULT '' COMMENT 'contract_name',
   `token_id` varchar(60) NOT NULL DEFAULT '' COMMENT 'token_id',
-  `state` int(11) NOT NULL DEFAULT '0' COMMENT 'state',
+  `status` int(11) NOT NULL DEFAULT '0' COMMENT '0: dirty',
   `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 0617435..34ef169 100644
--- a/server/web3bcspider/services/erc721_refresher.js
+++ b/server/web3bcspider/services/erc721_refresher.js
@@ -5,6 +5,8 @@ const log = require('j7/log');
 const constant = require('common/constant');
 const BaseService = require('./baseservice');
 
+const LIMIT_COUNT = 100;
+
 class Erc721Refresher extends BaseService {
 
   async init(bc, net, refresher) {
@@ -27,6 +29,22 @@ 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 ' +
+          'AND net_id = ? AND contract_address = ? ' +
+          'LIMIT ' + LIMIT_COUNT,
+        [
+          this.getNetId(),
+          this.getContractAddress()
+        ]);
+      if (err) {
+        throw err;
+      }
+    } catch (err) {
+        log.error(logHead + err);
+        await utils.sleep(5000 + utils.randRange(1000, 3000));
+    }
   }
 
   getNetId() {