hrms-bangkok/hrms-api-org
7
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

Linear Flow (C-PM-01, C-PM-02, C-PM-14) #224
All checks were successful
Build & Deploy on Dev / build (push) Successful in 1m11s
Details

Browse source
This commit is contained in:
harid 2026-06-18 15:48:52 +07:00
parent c26fb19c1c
commit 9dddaf40db
1 changed files with 10 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

17
src/services/rabbitmq.ts
View file

@ -323,11 +323,13 @@ async function handler(msg: amqp.ConsumeMessage): Promise<boolean> {
// ───────────────────────────────────────────────────────────── // ─────────────────────────────────────────────────────────────
// Linear Flow // Linear Flow
// ทดสอบเฉพาะ C-PM-01 รับ resultData จาก .NET แล้วเรียก OfficerProfileService ตรงๆ ไม่ผ่าน HTTP loopback // ทดสอบคำสั่ง "C-PM-01", "C-PM-02", "C-PM-14"
// รับ resultData จาก .NET แล้วเรียก OfficerProfileService ตรงๆ ไม่ผ่าน HTTP loopback
// ───────────────────────────────────────────────────────────── // ─────────────────────────────────────────────────────────────
const isLinearFlow = command.commandType?.code === "C-PM-01"; const isLinearFlow = ["C-PM-01", "C-PM-02", "C-PM-14"].includes(command.commandType?.code);
if (isLinearFlow) { if (isLinearFlow) {
console.log(`[AMQ] Linear Flow`);
let resultData: any[] = []; let resultData: any[] = [];
for (const chunk of chunks) { for (const chunk of chunks) {
@ -337,13 +339,14 @@ async function handler(msg: amqp.ConsumeMessage): Promise<boolean> {
{ refIds: chunk }, { refIds: chunk },
false, false,
); );
// CallAPI.PostData คืน response.data.result (ตาม call-api.ts) // response (resultData) จาก .NET
if (res?.result && Array.isArray(res.result)) { if (Array.isArray(res)) {
resultData.push(...res.result); console.log(`[AMQ] Push result data`);
resultData.push(...res);
} }
} }
console.log(`[AMQ] Received ${resultData.length} profiles from .NET (C-PM-01)`); console.log(`[AMQ] Received ${resultData.length} profiles from .NET (${command.commandType?.code})`);
// เรียก OfficerProfileService // เรียก OfficerProfileService
if (resultData.length > 0) { if (resultData.length > 0) {
@ -361,7 +364,7 @@ async function handler(msg: amqp.ConsumeMessage): Promise<boolean> {
console.log(`[AMQ] Processed ${resultData.length} profiles via OfficerProfileService`); console.log(`[AMQ] Processed ${resultData.length} profiles via OfficerProfileService`);
} }
} else { } else {
// Flow เดิม console.log(`[AMQ] Circular Flow`);
for (const chunk of chunks) { for (const chunk of chunks) {
await new CallAPI().PostData( await new CallAPI().PostData(
{ headers: { authorization: token } }, { headers: { authorization: token } },