From f05e2fef55e5959e6c90735cd90f2b9ef1881caf Mon Sep 17 00:00:00 2001 From: AdisakKanthawilang Date: Mon, 25 Aug 2025 16:05:39 +0700 Subject: [PATCH] =?UTF-8?q?=E0=B8=9B=E0=B8=B4=E0=B8=94=20validate?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/controllers/OrganizationController.ts | 54 +++++++++++------------ 1 file changed, 27 insertions(+), 27 deletions(-) diff --git a/src/controllers/OrganizationController.ts b/src/controllers/OrganizationController.ts index c4c5740f..cd400837 100644 --- a/src/controllers/OrganizationController.ts +++ b/src/controllers/OrganizationController.ts @@ -124,20 +124,20 @@ export class OrganizationController extends Controller { @Request() request: RequestWithUser, ) { try { - // CheckQueueInProgress - const [isBusyDraft, isBusyPublish] = await Promise.all([ - checkQueueInProgress(`${process.env.AMQ_QUEUE_ORG_DRAFT}`), - checkQueueInProgress(`${process.env.AMQ_QUEUE_ORG}`), - ]); - // console.log("✅ ตรวจสอบแล้ว Draft Busy:", isBusyDraft); - // console.log("✅ ตรวจสอบแล้ว Publish Busy:", isBusyPublish); - if (isBusyDraft || isBusyPublish) { - // console.log("🚫 พบว่ามีงานอยู่ในคิว — error") - throw new HttpError( - HttpStatusCode.CONFLICT, - "ไม่สามารถดำเนินการได้ หากกำลังเผยแพร่หรือสร้างแบบร่างโครงสร้างหน่วยงาน", - ); - } + // // CheckQueueInProgress + // const [isBusyDraft, isBusyPublish] = await Promise.all([ + // checkQueueInProgress(`${process.env.AMQ_QUEUE_ORG_DRAFT}`), + // checkQueueInProgress(`${process.env.AMQ_QUEUE_ORG}`), + // ]); + // // console.log("✅ ตรวจสอบแล้ว Draft Busy:", isBusyDraft); + // // console.log("✅ ตรวจสอบแล้ว Publish Busy:", isBusyPublish); + // if (isBusyDraft || isBusyPublish) { + // // console.log("🚫 พบว่ามีงานอยู่ในคิว — error") + // throw new HttpError( + // HttpStatusCode.CONFLICT, + // "ไม่สามารถดำเนินการได้ หากกำลังเผยแพร่หรือสร้างแบบร่างโครงสร้างหน่วยงาน", + // ); + // } //new main revision const before = null; const revision = Object.assign(new OrgRevision(), requestBody) as OrgRevision; @@ -3209,19 +3209,19 @@ export class OrganizationController extends Controller { try { // CheckQueueInProgress // console.log("🚀 ตรวจสอบว่ามีงานอยู่ในคิว"); - const [isBusyDraft, isBusyPublish] = await Promise.all([ - checkQueueInProgress(`${process.env.AMQ_QUEUE_ORG_DRAFT}`), - checkQueueInProgress(`${process.env.AMQ_QUEUE_ORG}`), - ]); - // console.log("✅ ตรวจสอบแล้ว Draft Busy:", isBusyDraft); - // console.log("✅ ตรวจสอบแล้ว Publish Busy:", isBusyPublish); - if (isBusyDraft || isBusyPublish) { - // console.log("🚫 พบว่ามีงานอยู่ในคิว — error") - throw new HttpError( - HttpStatusCode.CONFLICT, - "ไม่สามารถดำเนินการได้ หากกำลังเผยแพร่หรือสร้างแบบร่างโครงสร้างหน่วยงาน", - ); - } + // const [isBusyDraft, isBusyPublish] = await Promise.all([ + // checkQueueInProgress(`${process.env.AMQ_QUEUE_ORG_DRAFT}`), + // checkQueueInProgress(`${process.env.AMQ_QUEUE_ORG}`), + // ]); + // // console.log("✅ ตรวจสอบแล้ว Draft Busy:", isBusyDraft); + // // console.log("✅ ตรวจสอบแล้ว Publish Busy:", isBusyPublish); + // if (isBusyDraft || isBusyPublish) { + // // console.log("🚫 พบว่ามีงานอยู่ในคิว — error") + // throw new HttpError( + // HttpStatusCode.CONFLICT, + // "ไม่สามารถดำเนินการได้ หากกำลังเผยแพร่หรือสร้างแบบร่างโครงสร้างหน่วยงาน", + // ); + // } const today = new Date(); today.setHours(0, 0, 0, 0); // Set time to the beginning of the day