This commit is contained in:
aozhiwei 2023-07-11 14:27:16 +08:00
parent 9886063bb3
commit f40f12e5d8
2 changed files with 3 additions and 3 deletions

View File

@ -216,7 +216,7 @@ class DbEventProcess extends BaseService {
if (!this.eventHandle) { if (!this.eventHandle) {
return false; return false;
} }
const handle = eventsFactory.createEventHandle(this); const handle = eventsFactory.createEventHandle(this, this.conn, row);
await handle.start(); await handle.start();
return true; return true;
} }

View File

@ -33,9 +33,9 @@ function getEventHandle(eventProc) {
return utils.hasKey(events, clsName) ? events[clsName] : null; return utils.hasKey(events, clsName) ? events[clsName] : null;
} }
function createEventHandle(eventProc) { function createEventHandle(eventProc, conn, eventDb) {
const clsName = eventProc.getContractName() + '.' + eventProc.getEventName(); const clsName = eventProc.getContractName() + '.' + eventProc.getEventName();
return new events[clsName]['class'](); return new events[clsName]['class'](eventProc, conn, eventDb);
} }
exports.init = init; exports.init = init;