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

Merge branch 'develop' of github.com:Frappet/bma-ehr-organization into develop

Browse source
This commit is contained in:
kittapath 2024-10-30 16:25:43 +07:00
commit 4a933c79cd
2 changed files with 18 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

16
src/controllers/ViewWorkFlowController.ts
View file

@ -33,10 +33,22 @@ export class ViewWorkFlowController extends Controller {
const lists = await this.metaWorkflowRepository const lists = await this.metaWorkflowRepository
.createQueryBuilder("metaWorkflow") .createQueryBuilder("metaWorkflow")
.select(["metaWorkflow.name", "metaWorkflow.sysName"]) .select(["metaWorkflow.name", "metaWorkflow.sysName"])
.groupBy("metaWorkflow.name") // .groupBy("metaWorkflow.name")
.getMany(); .getMany();
return new HttpSuccess(lists); const sys: any = [];
for (let index = 0; index < lists.length; index++) {
const element = await lists[index];
if (sys.findIndex((x: any) => x.sysName === element.sysName) === -1) {
sys.push({
sysName: element.sysName,
name: element.name,
});
}
}
return new HttpSuccess(sys);
} }
@Get("") @Get("")

8
src/services/rabbitmq.ts
View file

@ -32,14 +32,14 @@ export async function init() {
}); });
}; };
// sendToQueueOrg = (payload: any, persistent = true) => { sendToQueueOrg = (payload: any, persistent = true) => {
// channel.sendToQueue(queue_org, Buffer.from(JSON.stringify(payload)), { persistent }); channel.sendToQueue(queue_org, Buffer.from(JSON.stringify(payload)), { persistent });
// }; };
console.log("[AMQ] Listening for message..."); console.log("[AMQ] Listening for message...");
createConsumer(queue, channel, handler); //----> (3) Process Consumer createConsumer(queue, channel, handler); //----> (3) Process Consumer
// createConsumer(queue_org, channel, handler_org); createConsumer(queue_org, channel, handler_org);
// createConsumer(queue2, channel, handler2); // createConsumer(queue2, channel, handler2);
} }