From ad1ae13afa0efda9d122e279a62c1e0cc6793171 Mon Sep 17 00:00:00 2001
From: morteza-mortezai <mrtz.mrtzi.1989@gmail.com>
Date: Wed, 24 Dec 2025 23:11:55 +0330
Subject: [PATCH] send noti after order status completed

---
 src/modules/orders/crone/order.crone.ts | 30 ++++++++++++-------------
 1 file changed, 15 insertions(+), 15 deletions(-)

diff --git a/src/modules/orders/crone/order.crone.ts b/src/modules/orders/crone/order.crone.ts
index 028c6fd..b183cc9 100644
--- a/src/modules/orders/crone/order.crone.ts
+++ b/src/modules/orders/crone/order.crone.ts
@@ -7,7 +7,7 @@ import { PaymentMethodEnum, PaymentStatusEnum } from '../../payments/interface/p
 import { InventoryService } from '../../inventory/inventory.service';
 import { OrderStatus } from '../interface/order.interface';
 import { Order } from '../entities/order.entity';
-// import { OrderStatusChangedEvent } from '../events/order.events';
+import { OrderStatusChangedEvent } from '../events/order.events';
 
 @Injectable()
 export class OrdersCrone {
@@ -16,7 +16,7 @@ export class OrdersCrone {
   constructor(
     private readonly em: EntityManager,
     private readonly inventoryService: InventoryService,
-    // private readonly eventEmitter: EventEmitter2,
+    private readonly eventEmitter: EventEmitter2,
   ) { }
 
   // run every minute and fail pending online payments older than 15 minutes
@@ -24,7 +24,7 @@ export class OrdersCrone {
     name: 'failOldOnlinePayments',
     timeZone: 'UTC',
   })
-  async handleCron() {
+  async cancelOldOnlinePendingOrders() {
     try {
       const cutoff = new Date(Date.now() - 15 * 60 * 1000);
 
@@ -161,18 +161,18 @@ export class OrdersCrone {
             await em.flush();
 
             // // Emit event after transaction completes
-            // this.eventEmitter.emit(
-            //   OrderStatusChangedEvent.name,
-            //   new OrderStatusChangedEvent(
-            //     reloadedOrder.id,
-            //     reloadedOrder.user?.id || '',
-            //     String(reloadedOrder.orderNumber) || '',
-            //     restaurantId,
-            //     previousStatus,
-            //     OrderStatus.COMPLETED,
-            //     'admin',
-            //   ),
-            // );
+            this.eventEmitter.emit(
+              OrderStatusChangedEvent.name,
+              new OrderStatusChangedEvent(
+                reloadedOrder.id,
+                reloadedOrder.user?.id || '',
+                String(reloadedOrder.orderNumber) || '',
+                restaurantId,
+                previousStatus,
+                OrderStatus.COMPLETED,
+                'admin',
+              ),
+            );
 
             this.logger.log(`Marked order ${reloadedOrder.id} as completed`);
           });