From 33ac43071ebf618ea453ece724d05eb239b39593 Mon Sep 17 00:00:00 2001
From: AdisakKanthawilang <adisak@frappet.com>
Date: Tue, 18 Mar 2025 17:39:55 +0700
Subject: [PATCH] fix draft rabbitMq

---
 src/services/rabbitmq.ts | 13 +++++++++++--
 1 file changed, 11 insertions(+), 2 deletions(-)

diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts
index c48d2cfe..dab09767 100644
--- a/src/services/rabbitmq.ts
+++ b/src/services/rabbitmq.ts
@@ -1684,7 +1684,6 @@ async function handler_org_draft(msg: amqp.ConsumeMessage): Promise<boolean> {
         }
       }
     }
-    console.log("ssssssssss");
     const _orgRevisions = await orgRevisionRepository.find({
       where: [{ orgRevisionIsDraft: true, id: Not(revision.id) }],
     });
@@ -1712,7 +1711,17 @@ async function handler_org_draft(msg: amqp.ConsumeMessage): Promise<boolean> {
     await posMasterActRepository.delete({
       posMasterChildId: In(_posMasters.map((x) => x.id)),
     });
-    await posMasterRepository.remove(_posMasters);
+    // await posMasterRepository.remove(_posMasters);
+    const batchSize = 1000;
+    for (let i = 0; i < _posMasters.length; i += batchSize) {
+      const batch = _posMasters.slice(i, i + batchSize);
+      try {
+        await posMasterRepository.remove(batch);
+        console.log(`Removed PosMaster batch ${i / batchSize + 1}`);
+      } catch (error) {
+        console.log(`Failed to remove batch ${i / batchSize + 1}`);
+      }
+    }
     await employeePosMasterRepository.remove(_employeePosMasters);
     await employeeTempPosMasterRepository.remove(_employeeTempPosMasters);
     await child4Repository.delete({ orgRevisionId: In(_orgRevisions.map((x) => x.id)) });