EPESS/epess-web-backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: unify logging messages in CronService for consistency

Browse Source 
- Updated log messages in the CronService to use a consistent logger context ('CronService') across all scheduled tasks.
- Improved traceability and readability of log outputs by standardizing the log context, enhancing debugging capabilities.
This commit is contained in:
Ly Tuan Kiet
2024-12-05 22:56:22 +07:00
parent eb05610b23
commit 6d28d74351
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/Cron/cron.service.ts
View File

@@ -16,7 +16,7 @@ export class CronService {
// cron every 1 minute to check schedule date status // cron every 1 minute to check schedule date status
@Cron(CronExpression.EVERY_MINUTE) @Cron(CronExpression.EVERY_MINUTE)
async checkScheduleDateStatus() { async checkScheduleDateStatus() {
Logger.log('Checking schedule date status', 'checkScheduleDateStatus') Logger.log('Checking schedule date status', 'CronService')
const schedules = await this.prisma.scheduleDate.findMany({ const schedules = await this.prisma.scheduleDate.findMany({
where: { where: {
end: { end: {
@@ -27,7 +27,7 @@ export class CronService {
}, },
}, },
}) })
Logger.log(`Found ${schedules.length} schedules to update`, 'checkScheduleDateStatus') Logger.log(`Found ${schedules.length} schedules to update`, 'CronService')
// get all collaboration sessions // get all collaboration sessions
const collaborationSessions = await this.prisma.collaborationSession.findMany({ const collaborationSessions = await this.prisma.collaborationSession.findMany({
where: { where: {
@@ -77,7 +77,7 @@ export class CronService {
// cron every 1 minute to check payment status where created_at is more than 15 minutes // cron every 1 minute to check payment status where created_at is more than 15 minutes
@Cron(CronExpression.EVERY_MINUTE) @Cron(CronExpression.EVERY_MINUTE)
async checkPaymentStatus() { async checkPaymentStatus() {
Logger.log('Checking payment status', 'checkPaymentStatus') Logger.log('Checking payment status', 'CronService')
const payments = await this.prisma.payment.findMany({ const payments = await this.prisma.payment.findMany({
where: { where: {
status: PaymentStatus.PENDING, status: PaymentStatus.PENDING,
@@ -86,7 +86,7 @@ export class CronService {
}, },
}, },
}) })
Logger.log(`Found ${payments.length} payments to update`, 'checkPaymentStatus') Logger.log(`Found ${payments.length} payments to update`, 'CronService')
for (const payment of payments) { for (const payment of payments) {
await this.prisma.payment.update({ await this.prisma.payment.update({
where: { id: payment.id }, where: { id: payment.id },
@@ -102,7 +102,7 @@ export class CronService {
// handle refund ticket by order, if order status is refunded, disable schedule and remove schedule date in future // handle refund ticket by order, if order status is refunded, disable schedule and remove schedule date in future
@Cron(CronExpression.EVERY_MINUTE) @Cron(CronExpression.EVERY_MINUTE)
async taskRefundTicket() { async taskRefundTicket() {
Logger.log('Handling refund ticket', 'handleRefundTicket') Logger.log('Handling refund ticket', 'CronService')
const now = DateTimeUtils.now().toJSDate() const now = DateTimeUtils.now().toJSDate()
// get all orders where status is REFUNDED and has schedule.dates in future // get all orders where status is REFUNDED and has schedule.dates in future
const orders = await this.prisma.order.findMany({ const orders = await this.prisma.order.findMany({
@@ -126,7 +126,7 @@ export class CronService {
}, },
}, },
}) })
Logger.log(`Found ${orders.length} orders to handle`, 'handleRefundTicket') Logger.log(`Found ${orders.length} orders to handle`, 'CronService')
for (const order of orders) { for (const order of orders) {
await this.prisma.schedule.update({ await this.prisma.schedule.update({
where: { id: order.scheduleId }, where: { id: order.scheduleId },
@@ -147,7 +147,7 @@ export class CronService {
// cron every 1 minute to check if there is any schedule date start in less than 30 minutes // cron every 1 minute to check if there is any schedule date start in less than 30 minutes
@Cron(CronExpression.EVERY_MINUTE) @Cron(CronExpression.EVERY_MINUTE)
async taskCheckScheduleDateStart() { async taskCheckScheduleDateStart() {
Logger.log('Checking schedule date start', 'taskCheckScheduleDateStart') Logger.log('Checking schedule date start', 'CronService')
const schedules = await this.prisma.schedule.findMany({ const schedules = await this.prisma.schedule.findMany({
where: { where: {
AND: [ AND: [
@@ -162,7 +162,7 @@ export class CronService {
], ],
}, },
}) })
Logger.log(`Found ${schedules.length} schedules to check`, 'taskCheckScheduleDateStart') Logger.log(`Found ${schedules.length} schedules to check`, 'CronService')
for (const schedule of schedules) { for (const schedule of schedules) {
await this.prisma.scheduleDate.updateMany({ await this.prisma.scheduleDate.updateMany({
where: { scheduleId: schedule.id }, where: { scheduleId: schedule.id },
@@ -192,7 +192,7 @@ export class CronService {
// cron every day to disable service without any schedule in the past 30 days // cron every day to disable service without any schedule in the past 30 days
@Cron(CronExpression.EVERY_DAY_AT_1AM) @Cron(CronExpression.EVERY_DAY_AT_1AM)
async taskDisableServiceWithoutSchedule() { async taskDisableServiceWithoutSchedule() {
Logger.log('Disabling service without any schedule', 'taskDisableServiceWithoutSchedule') Logger.log('Disabling service without any schedule', 'CronService')
const services = await this.prisma.managedService.findMany({ const services = await this.prisma.managedService.findMany({
where: { where: {
NOT: { NOT: {
@@ -216,7 +216,7 @@ export class CronService {
}, },
}, },
}) })
Logger.log(`Service ${service.id} has been disabled`, 'taskDisableServiceWithoutSchedule') Logger.log(`Service ${service.id} has been disabled`, 'CronService')
} }
} }
} }