diff --git a/src/core/modules/domain/usecase/base.manager.ts b/src/core/modules/domain/usecase/base.manager.ts index 9900f13..edcf5b0 100644 --- a/src/core/modules/domain/usecase/base.manager.ts +++ b/src/core/modules/domain/usecase/base.manager.ts @@ -60,7 +60,7 @@ export abstract class BaseManager { try { this.setUser(); - // this.queryRunner.startTransaction(); + this.queryRunner.startTransaction(); this.baseLog.verbose('prepareData'); await this.prepareData(); @@ -80,11 +80,12 @@ export abstract class BaseManager { this.baseLog.verbose('afterProcess'); await this.afterProcess(); - // this.baseLog.verbose('commitTransaction'); - // await this.queryRunner.commitTransaction(); + this.baseLog.verbose('commitTransaction'); + await this.queryRunner.commitTransaction(); - // await this.queryRunner.release(); + await this.queryRunner.release(); } catch (e) { + await this.queryRunner.rollbackTransaction(); if (e.response) throw new Error(JSON.stringify(e.response)); else throw new Error(e.message); }