From 049a0299de7e933836f763cc775fa61681602e76 Mon Sep 17 00:00:00 2001 From: kittapath Date: Tue, 29 Oct 2024 09:38:06 +0700 Subject: [PATCH] no message --- src/controllers/WorkflowController.ts | 33 +++++++++++++++++++++++++++ 1 file changed, 33 insertions(+) diff --git a/src/controllers/WorkflowController.ts b/src/controllers/WorkflowController.ts index 8b334a83..2d60eed2 100644 --- a/src/controllers/WorkflowController.ts +++ b/src/controllers/WorkflowController.ts @@ -156,6 +156,39 @@ export class WorkflowController extends Controller { }), ); + const _workflow = await this.workflowRepo.findOne({ + where: { id: workflow.id }, + relations: ["stateOperatorUsers"], + }); + if (!_workflow) throw new HttpError(HttpStatus.NOT_FOUND, "ไม่สามารถดำเนินการกระบวนการนี้ได้"); + + const _state = await this.stateRepo.findOne({ + where: { + id: _workflow.stateId, + }, + relations: ["stateOperators"], + }); + if (!_state) throw new HttpError(HttpStatus.NOT_FOUND, "ไม่พบข้อมูลขั้นตอนการอนุมัติ"); + let profileNow = _workflow.stateOperatorUsers + .filter((x) => _state.stateOperators.map((s) => s.operator).includes(x.operator)) + .map((x) => ({ + receiverUserId: x.profile, + notiLink: "", + })); + await new CallAPI() + .PostData(req, "/placement/noti/profiles", { + subject: `รายการถูกส่ง`, + body: `รายการถูกส่ง`, + receiverUserIds: profileNow, + payload: "", //แนบไฟล์ + isSendMail: true, + isSendInbox: true, + isSendNotification: true, + }) + .catch((error) => { + console.error("Error calling API:", error); + }); + return new HttpSuccess(); }