server/game2006web3new
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-02 09:08:27 +08:00
parent 312e6b2da5
commit 0d84a32b64
1 changed files with 2 additions and 54 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
server/web3bcspider/tasks/bcspider.js
View File

@ -8,18 +8,7 @@ const C = require('../C');
const factory = require('./factory'); const factory = require('./factory');
const serviceFactory = require('../services/factory'); const serviceFactory = require('../services/factory');
class EventCenter extends BaseTask { class BcSpider extends BaseTask {
instances = [
{
'name': 'HERO',
'eventName': 'Transfer',
},
{
'name': 'WEAPON',
'eventName': 'Transfer',
},
];
async init() { async init() {
await this.initEventProcess(); await this.initEventProcess();
@ -33,49 +22,8 @@ class EventCenter extends BaseTask {
instance['toBlock'] = 0; instance['toBlock'] = 0;
instance['currBlock'] = 0; instance['currBlock'] = 0;
}; };
const allInstances = [];
{
this.instances.forEach((item) => {
allInstances.push(item);
});
console.log(allInstances);
{
const instanceHash = {};
allInstances.forEach((item) => {
const key = item['name'] + '.' + item['eventName'];
if (utils.hasKey(instanceHash, key)) {
console.log(key);
throw '!!!!duplicate instance';
}
instanceHash[key] = item;
});
}
allInstances.forEach((item) => {
initInstance(item);
});
{
let count = 0;
const outputLog = async () => {
while (true) {
log.info(++count + '-------------------------------------------------------------');
allInstances.forEach((item) => {
log.info(utils.jsonEncode(item));
});
await utils.sleep(1000 * 10);
}
};
setTimeout(outputLog, 1000 * 3);
}
}
{
allInstances.forEach(async (item) => {
serviceFactory.create('EventProcess', null)
.init(this.conn, item, async (event) => {
});
});
}
} }
} }
module.exports = EventCenter; module.exports = BcSpider;