Fix : 교육 페이지 추가 생성 시 알림 등록

Author: AnDev77

src/controllers/stores-edu.controller.ts

@@ -43,6 +43,7 @@ export const createEducation = async (req: Request, res: Response) => {
   if (result.numInsertedOrUpdatedRows === BigInt(0)) {
     throw new Error("Failed to create education");
   }
+  await services.createEduNoti(req.params.storeId);
 
   res.status(201).json({ message: "강의 자료가 생성되었습니다." });
 };
@@ -57,7 +58,7 @@ export const updateEducation = async (req: Request, res: Response) => {
   if (result.numUpdatedRows === BigInt(0)) {
     throw new HttpException(404, "강의 자료가 존재하지 않습니다.");
   }
-
+  await services.updateEduNoti(req.params.storeId);
   res.status(200).json({ message: "강의 자료가 수정되었습니다." });
 };
 

src/services/stores-edu.service.ts

@@ -4,6 +4,8 @@ import { nanoid } from "nanoid";
 import { db } from "@/db";
 import { CreateEducationPayload } from "@/interfaces/edu.interface";
 
+import { createNotification, getStoreNameById } from "./notifications.service";
+
 export const isStoreMember = async (storeId: string, userId: string) => {
   return db
     .selectFrom("storeMember")
@@ -51,3 +53,37 @@ export const getEducationById = async (storeId: string, eduId: string) => {
     .where("storeId", "=", storeId)
     .executeTakeFirst();
 };
+
+const getStoreMembers = async (storeId: string) => {
+  return db.selectFrom("storeMember").select("userId").where("storeId", "=", storeId).execute();
+};
+
+export const createEduNoti = async (storeId: string) => {
+  const members = await getStoreMembers(storeId);
+  const notiTitle = await getStoreNameById(storeId);
+  const owner = await db.selectFrom("store").select("ownerId").where("id", "=", storeId).executeTakeFirst();
+  for (let i = 0; i < members.length; i++) {
+    if (members[i].userId == owner?.ownerId) continue;
+    await createNotification({
+      content: `게시물이 생성 됐습니다.`,
+      target: "/edupost/staff",
+      title: notiTitle ?? "알 수 없는 가게",
+      userId: members[i].userId,
+    });
+  }
+};
+
+export const updateEduNoti = async (storeId: string) => {
+  const members = await getStoreMembers(storeId);
+  const title = await getStoreNameById(storeId);
+  const owner = await db.selectFrom("store").select("ownerId").where("id", "=", storeId).executeTakeFirst();
+  for (let i = 0; i < members.length; i++) {
+    if (members[i].userId == owner?.ownerId) continue;
+    await createNotification({
+      content: `게시물이 수정 됐습니다.`,
+      target: `/edupost/staff`,
+      title: title ?? "알 수 없는 가게",
+      userId: members[i].userId,
+    });
+  }
+};