|
@@ -151,6 +151,9 @@ export class PrintTaskService extends GenericCrudService<FeiePrintTaskMt> {
|
|
|
await queryRunner.connect();
|
|
await queryRunner.connect();
|
|
|
await queryRunner.startTransaction();
|
|
await queryRunner.startTransaction();
|
|
|
|
|
|
|
|
|
|
+ await this.logger.info("tenantId", { tenantId });
|
|
|
|
|
+ await this.logger.info("taskId", { taskId });
|
|
|
|
|
+
|
|
|
try {
|
|
try {
|
|
|
// 在事务中获取任务,使用SELECT FOR UPDATE锁定行
|
|
// 在事务中获取任务,使用SELECT FOR UPDATE锁定行
|
|
|
const task = await queryRunner.manager.findOne(FeiePrintTaskMt, {
|
|
const task = await queryRunner.manager.findOne(FeiePrintTaskMt, {
|
|
@@ -158,6 +161,8 @@ export class PrintTaskService extends GenericCrudService<FeiePrintTaskMt> {
|
|
|
lock: { mode: 'pessimistic_write' }
|
|
lock: { mode: 'pessimistic_write' }
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
|
|
+ await this.logger.info("task", { task });
|
|
|
|
|
+
|
|
|
if (!task) {
|
|
if (!task) {
|
|
|
await queryRunner.rollbackTransaction();
|
|
await queryRunner.rollbackTransaction();
|
|
|
throw new Error('打印任务不存在');
|
|
throw new Error('打印任务不存在');
|
|
@@ -282,7 +287,7 @@ export class PrintTaskService extends GenericCrudService<FeiePrintTaskMt> {
|
|
|
} else {
|
|
} else {
|
|
|
const message = `[租户${tenantId}] 打印任务 ${taskId} 失败,已达到最大重试次数 ${maxRetries},任务标记为失败`;
|
|
const message = `[租户${tenantId}] 打印任务 ${taskId} 失败,已达到最大重试次数 ${maxRetries},任务标记为失败`;
|
|
|
console.log(message);
|
|
console.log(message);
|
|
|
- await this.logger.info(message);
|
|
|
|
|
|
|
+ await this.logger.info("打印任务:",message);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
throw error;
|
|
throw error;
|