mobile-notification event dan voting #42
@@ -2,6 +2,8 @@
|
|||||||
|
|
||||||
All notable changes to this project will be documented in this file. See [commit-and-tag-version](https://github.com/absolute-version/commit-and-tag-version) for commit guidelines.
|
All notable changes to this project will be documented in this file. See [commit-and-tag-version](https://github.com/absolute-version/commit-and-tag-version) for commit guidelines.
|
||||||
|
|
||||||
|
## [1.5.36](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.5.35...v1.5.36) (2026-01-13)
|
||||||
|
|
||||||
## [1.5.35](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.5.34...v1.5.35) (2026-01-12)
|
## [1.5.35](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.5.34...v1.5.35) (2026-01-12)
|
||||||
|
|
||||||
## [1.5.34](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.5.33...v1.5.34) (2026-01-09)
|
## [1.5.34](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.5.33...v1.5.34) (2026-01-09)
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "hipmi",
|
"name": "hipmi",
|
||||||
"version": "1.5.35",
|
"version": "1.5.36",
|
||||||
"private": true,
|
"private": true,
|
||||||
"prisma": {
|
"prisma": {
|
||||||
"seed": "bun prisma/seed.ts"
|
"seed": "bun prisma/seed.ts"
|
||||||
|
|||||||
@@ -1,6 +1,15 @@
|
|||||||
import { NextResponse } from "next/server";
|
import { NextResponse } from "next/server";
|
||||||
import prisma from "@/lib/prisma";
|
import prisma from "@/lib/prisma";
|
||||||
import _ from "lodash";
|
import _ from "lodash";
|
||||||
|
import {
|
||||||
|
sendNotificationMobileToManyUser,
|
||||||
|
sendNotificationMobileToOneUser,
|
||||||
|
} from "@/lib/mobile/notification/send-notification";
|
||||||
|
import {
|
||||||
|
NotificationMobileBodyType,
|
||||||
|
NotificationMobileTitleType,
|
||||||
|
} from "../../../../../../../types/type-mobile-notification";
|
||||||
|
import { routeUserMobile } from "@/lib/mobile/route-page-mobile";
|
||||||
|
|
||||||
export { GET, PUT };
|
export { GET, PUT };
|
||||||
|
|
||||||
@@ -57,6 +66,8 @@ async function GET(request: Request, { params }: { params: { id: string } }) {
|
|||||||
async function PUT(request: Request, { params }: { params: { id: string } }) {
|
async function PUT(request: Request, { params }: { params: { id: string } }) {
|
||||||
const { id } = params;
|
const { id } = params;
|
||||||
const { data } = await request.json();
|
const { data } = await request.json();
|
||||||
|
const { catatan, senderId } = data;
|
||||||
|
|
||||||
const { searchParams } = new URL(request.url);
|
const { searchParams } = new URL(request.url);
|
||||||
const status = searchParams.get("status");
|
const status = searchParams.get("status");
|
||||||
const fixStatus = _.startCase(status as string);
|
const fixStatus = _.startCase(status as string);
|
||||||
@@ -89,11 +100,23 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
|
|||||||
id: id,
|
id: id,
|
||||||
},
|
},
|
||||||
data: {
|
data: {
|
||||||
catatan: data,
|
catatan: catatan,
|
||||||
eventMaster_StatusId: checkStatus.id,
|
eventMaster_StatusId: checkStatus.id,
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
|
await sendNotificationMobileToOneUser({
|
||||||
|
recipientId: updateData.authorId as any,
|
||||||
|
senderId: senderId,
|
||||||
|
payload: {
|
||||||
|
title: "Pengajuan Review Ditolak",
|
||||||
|
body: "Mohon perbaiki data sesuai catatan penolakan !",
|
||||||
|
type: "announcement",
|
||||||
|
kategoriApp: "EVENT",
|
||||||
|
deepLink: routeUserMobile.eventByStatus({status: "reject"}),
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
fixData = updateData;
|
fixData = updateData;
|
||||||
} else if (fixStatus === "Publish") {
|
} else if (fixStatus === "Publish") {
|
||||||
const updateData = await prisma.event.update({
|
const updateData = await prisma.event.update({
|
||||||
@@ -105,6 +128,38 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
|
|||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
|
await sendNotificationMobileToOneUser({
|
||||||
|
recipientId: updateData.authorId as any,
|
||||||
|
senderId: senderId,
|
||||||
|
payload: {
|
||||||
|
title: "Review Selesai",
|
||||||
|
body: "Event kamu telah dipublikasikan !" as NotificationMobileBodyType,
|
||||||
|
type: "announcement",
|
||||||
|
kategoriApp: "EVENT",
|
||||||
|
deepLink: routeUserMobile.eventByStatus({status: "publish"}),
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
const adminUsers = await prisma.user.findMany({
|
||||||
|
where: {
|
||||||
|
masterUserRoleId: "1",
|
||||||
|
NOT: { id: updateData.authorId as any },
|
||||||
|
},
|
||||||
|
select: { id: true },
|
||||||
|
});
|
||||||
|
|
||||||
|
await sendNotificationMobileToManyUser({
|
||||||
|
recipientIds: adminUsers.map((user) => user.id),
|
||||||
|
senderId: senderId,
|
||||||
|
payload: {
|
||||||
|
title: "Event Baru" as NotificationMobileTitleType,
|
||||||
|
body: `${updateData.title}` as NotificationMobileBodyType,
|
||||||
|
type: "announcement",
|
||||||
|
kategoriApp: "EVENT",
|
||||||
|
deepLink: routeUserMobile.eventDetailPublised({ id: id }),
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
fixData = updateData;
|
fixData = updateData;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -6,7 +6,7 @@ import {
|
|||||||
sendNotificationMobileToOneUser,
|
sendNotificationMobileToOneUser,
|
||||||
} from "@/lib/mobile/notification/send-notification";
|
} from "@/lib/mobile/notification/send-notification";
|
||||||
import { routeUserMobile } from "@/lib/mobile/route-page-mobile";
|
import { routeUserMobile } from "@/lib/mobile/route-page-mobile";
|
||||||
import { NotificationMobileBodyType } from "../../../../../../../types/type-mobile-notification";
|
import { NotificationMobileBodyType, NotificationMobileTitleType } from "../../../../../../../types/type-mobile-notification";
|
||||||
|
|
||||||
export { GET, PUT };
|
export { GET, PUT };
|
||||||
|
|
||||||
@@ -110,8 +110,8 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
|
|||||||
recipientId: updt.authorId as any,
|
recipientId: updt.authorId as any,
|
||||||
senderId: senderId,
|
senderId: senderId,
|
||||||
payload: {
|
payload: {
|
||||||
title: "Pengajuan Review",
|
title: "Pengajuan Review Ditolak",
|
||||||
body: "Pengajuan data anda telah di tolak !",
|
body: "Mohon perbaiki data sesuai catatan penolakan !",
|
||||||
type: "announcement",
|
type: "announcement",
|
||||||
kategoriApp: "JOB",
|
kategoriApp: "JOB",
|
||||||
deepLink: routeUserMobile.jobByStatus({ status: "reject" }),
|
deepLink: routeUserMobile.jobByStatus({ status: "reject" }),
|
||||||
@@ -143,7 +143,7 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
|
|||||||
recipientId: updt.authorId as any,
|
recipientId: updt.authorId as any,
|
||||||
senderId: senderId,
|
senderId: senderId,
|
||||||
payload: {
|
payload: {
|
||||||
title: "Pengajuan Review",
|
title: "Review Selesai",
|
||||||
body: "Selamat data anda telah terpublikasi",
|
body: "Selamat data anda telah terpublikasi",
|
||||||
type: "announcement",
|
type: "announcement",
|
||||||
kategoriApp: "JOB",
|
kategoriApp: "JOB",
|
||||||
@@ -160,7 +160,7 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
|
|||||||
recipientIds: adminUsers.map((user) => user.id),
|
recipientIds: adminUsers.map((user) => user.id),
|
||||||
senderId: data.authorId,
|
senderId: data.authorId,
|
||||||
payload: {
|
payload: {
|
||||||
title: "Ada lowongan kerja baru",
|
title: "Ada Lowongan Kerja Baru" as NotificationMobileTitleType,
|
||||||
body: `${updt.title}` as NotificationMobileBodyType,
|
body: `${updt.title}` as NotificationMobileBodyType,
|
||||||
type: "announcement",
|
type: "announcement",
|
||||||
deepLink: routeUserMobile.jobDetailPublised({ id: id }),
|
deepLink: routeUserMobile.jobDetailPublised({ id: id }),
|
||||||
|
|||||||
@@ -1,8 +1,17 @@
|
|||||||
import { NextResponse } from "next/server";
|
import { NextResponse } from "next/server";
|
||||||
import { prisma } from "@/lib";
|
import { prisma } from "@/lib";
|
||||||
import _ from "lodash";
|
import _ from "lodash";
|
||||||
|
import {
|
||||||
|
sendNotificationMobileToManyUser,
|
||||||
|
sendNotificationMobileToOneUser,
|
||||||
|
} from "@/lib/mobile/notification/send-notification";
|
||||||
|
import { routeUserMobile } from "@/lib/mobile/route-page-mobile";
|
||||||
|
import {
|
||||||
|
NotificationMobileBodyType,
|
||||||
|
NotificationMobileTitleType,
|
||||||
|
} from "../../../../../../../types/type-mobile-notification";
|
||||||
|
|
||||||
export { GET , PUT};
|
export { GET, PUT };
|
||||||
|
|
||||||
async function GET(request: Request, { params }: { params: { id: string } }) {
|
async function GET(request: Request, { params }: { params: { id: string } }) {
|
||||||
const { id } = params;
|
const { id } = params;
|
||||||
@@ -41,12 +50,16 @@ async function GET(request: Request, { params }: { params: { id: string } }) {
|
|||||||
async function PUT(request: Request, { params }: { params: { id: string } }) {
|
async function PUT(request: Request, { params }: { params: { id: string } }) {
|
||||||
const { id } = params;
|
const { id } = params;
|
||||||
const { data } = await request.json();
|
const { data } = await request.json();
|
||||||
|
const { catatan, senderId } = data;
|
||||||
|
|
||||||
|
console.log("catatan", catatan);
|
||||||
|
console.log("senderId", senderId);
|
||||||
|
|
||||||
const { searchParams } = new URL(request.url);
|
const { searchParams } = new URL(request.url);
|
||||||
const status = searchParams.get("status");
|
const status = searchParams.get("status");
|
||||||
const fixStatus = _.startCase(status as string);
|
const fixStatus = _.startCase(status as string);
|
||||||
let fixData;
|
let fixData;
|
||||||
|
|
||||||
|
|
||||||
try {
|
try {
|
||||||
const checkStatus = await prisma.voting_Status.findFirst({
|
const checkStatus = await prisma.voting_Status.findFirst({
|
||||||
where: {
|
where: {
|
||||||
@@ -71,9 +84,23 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
|
|||||||
},
|
},
|
||||||
data: {
|
data: {
|
||||||
voting_StatusId: checkStatus.id,
|
voting_StatusId: checkStatus.id,
|
||||||
catatan: data,
|
catatan: catatan,
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
|
// SEND NOTIFICATION
|
||||||
|
await sendNotificationMobileToOneUser({
|
||||||
|
recipientId: updateStatus.authorId as any,
|
||||||
|
senderId: senderId,
|
||||||
|
payload: {
|
||||||
|
title: "Pengajuan Review Ditolak",
|
||||||
|
body: "Mohon perbaiki data sesuai catatan penolakan !",
|
||||||
|
type: "announcement",
|
||||||
|
kategoriApp: "VOTING",
|
||||||
|
deepLink: routeUserMobile.votingByStatus({ status: "reject" }),
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
fixData = updateStatus;
|
fixData = updateStatus;
|
||||||
} else if (fixStatus === "Publish") {
|
} else if (fixStatus === "Publish") {
|
||||||
const updateStatus = await prisma.voting.update({
|
const updateStatus = await prisma.voting.update({
|
||||||
@@ -84,6 +111,39 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
|
|||||||
voting_StatusId: checkStatus.id,
|
voting_StatusId: checkStatus.id,
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
|
await sendNotificationMobileToOneUser({
|
||||||
|
recipientId: updateStatus.authorId as any,
|
||||||
|
senderId: senderId,
|
||||||
|
payload: {
|
||||||
|
title: "Review Selesai",
|
||||||
|
body: "Voting kamu telah dipublikasikan !" as NotificationMobileBodyType,
|
||||||
|
type: "announcement",
|
||||||
|
kategoriApp: "VOTING",
|
||||||
|
deepLink: routeUserMobile.votingByStatus({ status: "publish" }),
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
const adminUsers = await prisma.user.findMany({
|
||||||
|
where: {
|
||||||
|
masterUserRoleId: "1",
|
||||||
|
NOT: { id: updateStatus.authorId as any },
|
||||||
|
},
|
||||||
|
select: { id: true },
|
||||||
|
});
|
||||||
|
|
||||||
|
await sendNotificationMobileToManyUser({
|
||||||
|
recipientIds: adminUsers.map((user) => user.id),
|
||||||
|
senderId: senderId,
|
||||||
|
payload: {
|
||||||
|
title: "Cek Voting Baru Terpublikasi" as NotificationMobileTitleType,
|
||||||
|
body: `${updateStatus.title}` as NotificationMobileBodyType,
|
||||||
|
type: "announcement",
|
||||||
|
kategoriApp: "VOTING",
|
||||||
|
deepLink: routeUserMobile.votingDetailPublised({ id: id }),
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
fixData = updateStatus;
|
fixData = updateStatus;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,11 @@
|
|||||||
|
import { sendNotificationMobileToOneUser } from "@/lib/mobile/notification/send-notification";
|
||||||
import prisma from "@/lib/prisma";
|
import prisma from "@/lib/prisma";
|
||||||
import { NextResponse } from "next/server";
|
import { NextResponse } from "next/server";
|
||||||
|
import {
|
||||||
|
NotificationMobileBodyType,
|
||||||
|
NotificationMobileTitleType,
|
||||||
|
} from "../../../../../../../types/type-mobile-notification";
|
||||||
|
import { routeUserMobile } from "@/lib/mobile/route-page-mobile";
|
||||||
|
|
||||||
export { GET, POST };
|
export { GET, POST };
|
||||||
|
|
||||||
@@ -13,18 +19,28 @@ async function POST(request: Request, { params }: { params: { id: string } }) {
|
|||||||
eventId: id,
|
eventId: id,
|
||||||
userId: userId,
|
userId: userId,
|
||||||
},
|
},
|
||||||
|
|
||||||
// select: {
|
|
||||||
// Event: {
|
|
||||||
// select: {
|
|
||||||
// id: true,
|
|
||||||
// title: true,
|
|
||||||
// authorId: true,
|
|
||||||
// },
|
|
||||||
// },
|
|
||||||
// },
|
|
||||||
});
|
});
|
||||||
|
|
||||||
|
const findEvent = await prisma.event.findUnique({
|
||||||
|
where: { id: id },
|
||||||
|
select: { authorId: true, title: true },
|
||||||
|
});
|
||||||
|
|
||||||
|
// SEND NOTIFICATION
|
||||||
|
if (userId !== findEvent?.authorId) {
|
||||||
|
await sendNotificationMobileToOneUser({
|
||||||
|
recipientId: findEvent?.authorId as string,
|
||||||
|
senderId: userId,
|
||||||
|
payload: {
|
||||||
|
title: "Peserta Baru Join" as NotificationMobileTitleType,
|
||||||
|
body: `Ada peserta baru dalam event: ${findEvent?.title}` as NotificationMobileBodyType,
|
||||||
|
type: "announcement",
|
||||||
|
deepLink: routeUserMobile.eventDetailPublised({ id: id }),
|
||||||
|
kategoriApp: "EVENT",
|
||||||
|
},
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
return NextResponse.json(
|
return NextResponse.json(
|
||||||
{
|
{
|
||||||
success: true,
|
success: true,
|
||||||
|
|||||||
@@ -1,7 +1,10 @@
|
|||||||
|
import { sendNotificationMobileToManyUser } from "@/lib/mobile/notification/send-notification";
|
||||||
|
import { routeAdminMobile } from "@/lib/mobile/route-page-mobile";
|
||||||
import prisma from "@/lib/prisma";
|
import prisma from "@/lib/prisma";
|
||||||
import _ from "lodash";
|
import _ from "lodash";
|
||||||
import moment from "moment";
|
import moment from "moment";
|
||||||
import { NextResponse } from "next/server";
|
import { NextResponse } from "next/server";
|
||||||
|
import { NotificationMobileBodyType } from "../../../../../types/type-mobile-notification";
|
||||||
|
|
||||||
export { GET, POST };
|
export { GET, POST };
|
||||||
|
|
||||||
@@ -30,6 +33,24 @@ async function POST(request: Request) {
|
|||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
|
const adminUsers = await prisma.user.findMany({
|
||||||
|
where: { masterUserRoleId: "2", NOT: { id: data.authorId } },
|
||||||
|
select: { id: true },
|
||||||
|
});
|
||||||
|
|
||||||
|
// SEND NOTIFICATION
|
||||||
|
await sendNotificationMobileToManyUser({
|
||||||
|
recipientIds: adminUsers.map((user) => user.id),
|
||||||
|
senderId: data.authorId,
|
||||||
|
payload: {
|
||||||
|
title: "Pengajuan Review Baru",
|
||||||
|
body: create.title as NotificationMobileBodyType,
|
||||||
|
type: "announcement",
|
||||||
|
deepLink: routeAdminMobile.eventByStatus({ status: "review" }),
|
||||||
|
kategoriApp: "EVENT",
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
return NextResponse.json(
|
return NextResponse.json(
|
||||||
{
|
{
|
||||||
success: true,
|
success: true,
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ import { sendNotificationMobileToManyUser } from "@/lib/mobile/notification/send
|
|||||||
import { routeAdminMobile } from "@/lib/mobile/route-page-mobile";
|
import { routeAdminMobile } from "@/lib/mobile/route-page-mobile";
|
||||||
import prisma from "@/lib/prisma";
|
import prisma from "@/lib/prisma";
|
||||||
import { NextResponse } from "next/server";
|
import { NextResponse } from "next/server";
|
||||||
|
import { NotificationMobileBodyType } from "../../../../../types/type-mobile-notification";
|
||||||
|
|
||||||
export { POST, GET };
|
export { POST, GET };
|
||||||
|
|
||||||
@@ -30,8 +31,8 @@ async function POST(request: Request) {
|
|||||||
recipientIds: adminUsers.map((user) => user.id),
|
recipientIds: adminUsers.map((user) => user.id),
|
||||||
senderId: data.authorId,
|
senderId: data.authorId,
|
||||||
payload: {
|
payload: {
|
||||||
title: "Pengajuan Review",
|
title: "Pengajuan Review Baru",
|
||||||
body: "Terdapat pengajuan baru yang perlu direview",
|
body: `${create.title}` as NotificationMobileBodyType,
|
||||||
type: "announcement",
|
type: "announcement",
|
||||||
deepLink: routeAdminMobile.jobByStatus({ status: "review" }),
|
deepLink: routeAdminMobile.jobByStatus({ status: "review" }),
|
||||||
kategoriApp: "JOB",
|
kategoriApp: "JOB",
|
||||||
|
|||||||
@@ -45,23 +45,38 @@ export async function PUT(
|
|||||||
{ params }: { params: { id: string } }
|
{ params }: { params: { id: string } }
|
||||||
) {
|
) {
|
||||||
const { id } = params;
|
const { id } = params;
|
||||||
|
const { searchParams } = new URL(request.url);
|
||||||
|
const category = searchParams.get("category");
|
||||||
|
|
||||||
try {
|
try {
|
||||||
await prisma.notifikasi.update({
|
if (category === "one") {
|
||||||
where: {
|
await prisma.notifikasi.update({
|
||||||
id: id,
|
where: {
|
||||||
},
|
id: id,
|
||||||
data: {
|
},
|
||||||
isRead: true,
|
data: {
|
||||||
readAt: new Date(),
|
isRead: true,
|
||||||
},
|
readAt: new Date(),
|
||||||
});
|
},
|
||||||
|
});
|
||||||
|
} else if (category === "all") {
|
||||||
|
await prisma.notifikasi.updateMany({
|
||||||
|
where: {
|
||||||
|
recipientId: id,
|
||||||
|
},
|
||||||
|
data: {
|
||||||
|
isRead: true,
|
||||||
|
readAt: new Date(),
|
||||||
|
},
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
return NextResponse.json({
|
return NextResponse.json({
|
||||||
success: true,
|
success: true,
|
||||||
message: "Notifications marked as read",
|
message: "Notifications marked as read",
|
||||||
});
|
});
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
|
console.error("Error marking notifications as read:", error);
|
||||||
return NextResponse.json(
|
return NextResponse.json(
|
||||||
{ error: (error as Error).message },
|
{ error: (error as Error).message },
|
||||||
{ status: 500 }
|
{ status: 500 }
|
||||||
@@ -69,129 +84,129 @@ export async function PUT(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
export async function POST(
|
// export async function POST(
|
||||||
request: NextRequest,
|
// request: NextRequest,
|
||||||
{ params }: { params: { id: string } }
|
// { params }: { params: { id: string } }
|
||||||
) {
|
// ) {
|
||||||
const { id } = params;
|
// const { id } = params;
|
||||||
|
|
||||||
const { data } = await request.json();
|
// const { data } = await request.json();
|
||||||
|
|
||||||
const {
|
// const {
|
||||||
title,
|
// title,
|
||||||
body: notificationBody,
|
// body: notificationBody,
|
||||||
userLoginId,
|
// userLoginId,
|
||||||
type,
|
// type,
|
||||||
kategoriApp,
|
// kategoriApp,
|
||||||
appId,
|
// appId,
|
||||||
status,
|
// status,
|
||||||
deepLink,
|
// deepLink,
|
||||||
} = data as NotificationProp;
|
// } = data as NotificationProp;
|
||||||
|
|
||||||
console.log("Notification Send >>", data);
|
// console.log("Notification Send >>", data);
|
||||||
|
|
||||||
try {
|
// try {
|
||||||
// Cari user yang login
|
// // Cari user yang login
|
||||||
const findUserLogin = await prisma.user.findUnique({
|
// const findUserLogin = await prisma.user.findUnique({
|
||||||
where: {
|
// where: {
|
||||||
id: userLoginId,
|
// id: userLoginId,
|
||||||
},
|
// },
|
||||||
});
|
// });
|
||||||
|
|
||||||
if (!findUserLogin) {
|
// if (!findUserLogin) {
|
||||||
return NextResponse.json({ error: "User not found" }, { status: 404 });
|
// return NextResponse.json({ error: "User not found" }, { status: 404 });
|
||||||
}
|
// }
|
||||||
|
|
||||||
// Cari token fcm user yang login
|
// // Cari token fcm user yang login
|
||||||
const checkFcmToken = await prisma.tokenUserDevice.findFirst({
|
// const checkFcmToken = await prisma.tokenUserDevice.findFirst({
|
||||||
where: {
|
// where: {
|
||||||
userId: findUserLogin.id,
|
// userId: findUserLogin.id,
|
||||||
},
|
// },
|
||||||
});
|
// });
|
||||||
|
|
||||||
if (!checkFcmToken) {
|
// if (!checkFcmToken) {
|
||||||
return NextResponse.json(
|
// return NextResponse.json(
|
||||||
{ error: "FCM Token not found" },
|
// { error: "FCM Token not found" },
|
||||||
{ status: 404 }
|
// { status: 404 }
|
||||||
);
|
// );
|
||||||
}
|
// }
|
||||||
|
|
||||||
const created = await prisma.notifikasi.create({
|
// const created = await prisma.notifikasi.create({
|
||||||
data: {
|
// data: {
|
||||||
title,
|
// title,
|
||||||
type,
|
// type,
|
||||||
createdAt: new Date(),
|
// createdAt: new Date(),
|
||||||
appId,
|
// appId,
|
||||||
kategoriApp,
|
// kategoriApp,
|
||||||
pesan: notificationBody || "",
|
// pesan: notificationBody || "",
|
||||||
userRoleId: findUserLogin.masterUserRoleId,
|
// userRoleId: findUserLogin.masterUserRoleId,
|
||||||
status,
|
// status,
|
||||||
deepLink,
|
// deepLink,
|
||||||
senderId: findUserLogin.id,
|
// senderId: findUserLogin.id,
|
||||||
recipientId: id,
|
// recipientId: id,
|
||||||
},
|
// },
|
||||||
});
|
// });
|
||||||
|
|
||||||
if (created) {
|
// if (created) {
|
||||||
const deviceToken = await prisma.tokenUserDevice.findMany({
|
// const deviceToken = await prisma.tokenUserDevice.findMany({
|
||||||
where: {
|
// where: {
|
||||||
userId: id,
|
// userId: id,
|
||||||
isActive: true,
|
// isActive: true,
|
||||||
},
|
// },
|
||||||
});
|
// });
|
||||||
|
|
||||||
for (let i of deviceToken) {
|
// for (let i of deviceToken) {
|
||||||
const message = {
|
// const message = {
|
||||||
token: i.token,
|
// token: i.token,
|
||||||
notification: {
|
// notification: {
|
||||||
title,
|
// title,
|
||||||
body: notificationBody || "",
|
// body: notificationBody || "",
|
||||||
},
|
// },
|
||||||
data: {
|
// data: {
|
||||||
sentAt: new Date().toISOString(), // ✅ Simpan metadata di data
|
// sentAt: new Date().toISOString(), // ✅ Simpan metadata di data
|
||||||
id: created.id,
|
// id: created.id,
|
||||||
deepLink: deepLink || "",
|
// deepLink: deepLink || "",
|
||||||
},
|
// },
|
||||||
// Konfigurasi Android untuk prioritas tinggi
|
// // Konfigurasi Android untuk prioritas tinggi
|
||||||
android: {
|
// android: {
|
||||||
priority: "high" as const, // Kirim secepatnya, bahkan di doze mode untuk notifikasi penting
|
// priority: "high" as const, // Kirim secepatnya, bahkan di doze mode untuk notifikasi penting
|
||||||
notification: {
|
// notification: {
|
||||||
channelId: "default", // Sesuaikan dengan channel yang kamu buat di Android
|
// channelId: "default", // Sesuaikan dengan channel yang kamu buat di Android
|
||||||
},
|
// },
|
||||||
|
|
||||||
ttl: 0 as const, // Kirim secepatnya, jangan tunda
|
// ttl: 0 as const, // Kirim secepatnya, jangan tunda
|
||||||
},
|
// },
|
||||||
// Opsional: tambahkan untuk iOS juga
|
// // Opsional: tambahkan untuk iOS juga
|
||||||
apns: {
|
// apns: {
|
||||||
payload: {
|
// payload: {
|
||||||
aps: {
|
// aps: {
|
||||||
sound: "default" as const,
|
// sound: "default" as const,
|
||||||
// 'content-available': 1 as const, // jika butuh silent push
|
// // 'content-available': 1 as const, // jika butuh silent push
|
||||||
},
|
// },
|
||||||
},
|
// },
|
||||||
},
|
// },
|
||||||
};
|
// };
|
||||||
|
|
||||||
try {
|
// try {
|
||||||
const response = await adminMessaging.send(message);
|
// const response = await adminMessaging.send(message);
|
||||||
console.log("✅ FCM sent successfully", "Response:", response);
|
// console.log("✅ FCM sent successfully", "Response:", response);
|
||||||
} catch (error: any) {
|
// } catch (error: any) {
|
||||||
console.error("❌ FCM send failed:", error);
|
// console.error("❌ FCM send failed:", error);
|
||||||
// Lanjutkan ke token berikutnya meski satu gagal
|
// // Lanjutkan ke token berikutnya meski satu gagal
|
||||||
}
|
// }
|
||||||
}
|
// }
|
||||||
}
|
// }
|
||||||
|
|
||||||
return NextResponse.json({
|
// return NextResponse.json({
|
||||||
success: true,
|
// success: true,
|
||||||
message: "Notification sent successfully",
|
// message: "Notification sent successfully",
|
||||||
});
|
// });
|
||||||
} catch (error) {
|
// } catch (error) {
|
||||||
console.error("❌ FCM error:", error);
|
// console.error("❌ FCM error:", error);
|
||||||
|
|
||||||
return NextResponse.json(
|
// return NextResponse.json(
|
||||||
{ error: (error as Error).message },
|
// { error: (error as Error).message },
|
||||||
{ status: 500 }
|
// { status: 500 }
|
||||||
);
|
// );
|
||||||
}
|
// }
|
||||||
}
|
// }
|
||||||
|
|||||||
@@ -1,6 +1,12 @@
|
|||||||
import { NextResponse } from "next/server";
|
import { NextResponse } from "next/server";
|
||||||
import prisma from "@/lib/prisma";
|
import prisma from "@/lib/prisma";
|
||||||
import _ from "lodash";
|
import _ from "lodash";
|
||||||
|
import { sendNotificationMobileToOneUser } from "@/lib/mobile/notification/send-notification";
|
||||||
|
import {
|
||||||
|
NotificationMobileBodyType,
|
||||||
|
NotificationMobileTitleType,
|
||||||
|
} from "../../../../../../types/type-mobile-notification";
|
||||||
|
import { routeUserMobile } from "@/lib/mobile/route-page-mobile";
|
||||||
|
|
||||||
export { GET, DELETE, PUT, POST };
|
export { GET, DELETE, PUT, POST };
|
||||||
|
|
||||||
@@ -39,7 +45,6 @@ async function GET(request: Request, { params }: { params: { id: string } }) {
|
|||||||
const listNamaVote = data?.Voting_DaftarNamaVote || [];
|
const listNamaVote = data?.Voting_DaftarNamaVote || [];
|
||||||
|
|
||||||
for (let v of listNamaVote) {
|
for (let v of listNamaVote) {
|
||||||
|
|
||||||
const kontributor = await prisma.voting_Kontributor.findMany({
|
const kontributor = await prisma.voting_Kontributor.findMany({
|
||||||
where: {
|
where: {
|
||||||
voting_DaftarNamaVoteId: v.id,
|
voting_DaftarNamaVoteId: v.id,
|
||||||
@@ -90,7 +95,6 @@ async function DELETE(
|
|||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
||||||
return NextResponse.json({
|
return NextResponse.json({
|
||||||
success: true,
|
success: true,
|
||||||
message: "Berhasil menghapus data",
|
message: "Berhasil menghapus data",
|
||||||
@@ -171,7 +175,6 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
|
|||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
||||||
if (!updateVoting)
|
if (!updateVoting)
|
||||||
return NextResponse.json({ status: 400, message: "Gagal Update" });
|
return NextResponse.json({ status: 400, message: "Gagal Update" });
|
||||||
}
|
}
|
||||||
@@ -193,11 +196,12 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
|
|||||||
async function POST(request: Request, { params }: { params: { id: string } }) {
|
async function POST(request: Request, { params }: { params: { id: string } }) {
|
||||||
const { id } = params;
|
const { id } = params;
|
||||||
const { data } = await request.json();
|
const { data } = await request.json();
|
||||||
|
const { chooseId, userId } = data;
|
||||||
|
|
||||||
try {
|
try {
|
||||||
const findData = await prisma.voting_DaftarNamaVote.findFirst({
|
const findDatapilihan = await prisma.voting_DaftarNamaVote.findFirst({
|
||||||
where: {
|
where: {
|
||||||
id: data.chooseId,
|
id: chooseId,
|
||||||
},
|
},
|
||||||
select: {
|
select: {
|
||||||
jumlah: true,
|
jumlah: true,
|
||||||
@@ -205,28 +209,32 @@ async function POST(request: Request, { params }: { params: { id: string } }) {
|
|||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
if (!findData)
|
if (!findDatapilihan)
|
||||||
return NextResponse.json({
|
return NextResponse.json({
|
||||||
success: false,
|
success: false,
|
||||||
message: "Data tidak ditemukan",
|
message: "Data tidak ditemukan",
|
||||||
});
|
});
|
||||||
|
|
||||||
const updateData = await prisma.voting_DaftarNamaVote.update({
|
const updateDataPilihan = await prisma.voting_DaftarNamaVote.update({
|
||||||
where: {
|
where: {
|
||||||
id: data.chooseId,
|
id: data.chooseId,
|
||||||
},
|
},
|
||||||
data: {
|
data: {
|
||||||
jumlah: findData.jumlah + 1,
|
jumlah: findDatapilihan.jumlah + 1,
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
|
if (!updateDataPilihan)
|
||||||
if (!updateData)
|
|
||||||
return NextResponse.json({
|
return NextResponse.json({
|
||||||
success: false,
|
success: false,
|
||||||
message: "Gagal Update Data",
|
message: "Gagal Update Data",
|
||||||
});
|
});
|
||||||
|
|
||||||
|
const findVotingData = await prisma.voting.findUnique({
|
||||||
|
where: { id: id },
|
||||||
|
select: { authorId: true, title: true },
|
||||||
|
});
|
||||||
|
|
||||||
const createKontributor = await prisma.voting_Kontributor.create({
|
const createKontributor = await prisma.voting_Kontributor.create({
|
||||||
data: {
|
data: {
|
||||||
votingId: id,
|
votingId: id,
|
||||||
@@ -250,6 +258,21 @@ async function POST(request: Request, { params }: { params: { id: string } }) {
|
|||||||
message: "Gagal Menjadi Kontributor",
|
message: "Gagal Menjadi Kontributor",
|
||||||
});
|
});
|
||||||
|
|
||||||
|
// SEND NOTIFICATION
|
||||||
|
if (userId !== findVotingData?.authorId) {
|
||||||
|
await sendNotificationMobileToOneUser({
|
||||||
|
recipientId: findVotingData?.authorId as string,
|
||||||
|
senderId: userId,
|
||||||
|
payload: {
|
||||||
|
title: "User Melakukan Vote" as NotificationMobileTitleType,
|
||||||
|
body: `Salah satu user telah melakukan voting pada: ${findVotingData?.title}` as NotificationMobileBodyType,
|
||||||
|
type: "announcement",
|
||||||
|
deepLink: routeUserMobile.votingDetailPublised({ id: id }),
|
||||||
|
kategoriApp: "VOTING",
|
||||||
|
},
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
return NextResponse.json({
|
return NextResponse.json({
|
||||||
success: true,
|
success: true,
|
||||||
message: "Berhasil Voting",
|
message: "Berhasil Voting",
|
||||||
|
|||||||
@@ -1,6 +1,9 @@
|
|||||||
import { NextResponse } from "next/server";
|
import { NextResponse } from "next/server";
|
||||||
import prisma from "@/lib/prisma";
|
import prisma from "@/lib/prisma";
|
||||||
import _ from "lodash";
|
import _ from "lodash";
|
||||||
|
import { sendNotificationMobileToManyUser } from "@/lib/mobile/notification/send-notification";
|
||||||
|
import { NotificationMobileBodyType } from "../../../../../types/type-mobile-notification";
|
||||||
|
import { routeAdminMobile } from "@/lib/mobile/route-page-mobile";
|
||||||
|
|
||||||
export { POST, GET };
|
export { POST, GET };
|
||||||
|
|
||||||
@@ -41,6 +44,24 @@ async function POST(request: Request) {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const adminUsers = await prisma.user.findMany({
|
||||||
|
where: { masterUserRoleId: "2", NOT: { id: data.authorId } },
|
||||||
|
select: { id: true },
|
||||||
|
});
|
||||||
|
|
||||||
|
// SEND NOTIFICATION
|
||||||
|
await sendNotificationMobileToManyUser({
|
||||||
|
recipientIds: adminUsers.map((user) => user.id),
|
||||||
|
senderId: data.authorId,
|
||||||
|
payload: {
|
||||||
|
title: "Pengajuan Review Baru",
|
||||||
|
body: create.title as NotificationMobileBodyType,
|
||||||
|
type: "announcement",
|
||||||
|
deepLink: routeAdminMobile.votingByStatus({ status: "review" }),
|
||||||
|
kategoriApp: "VOTING",
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
return NextResponse.json(
|
return NextResponse.json(
|
||||||
{
|
{
|
||||||
success: true,
|
success: true,
|
||||||
@@ -125,8 +146,6 @@ async function GET(request: Request) {
|
|||||||
});
|
});
|
||||||
|
|
||||||
fixData = data;
|
fixData = data;
|
||||||
|
|
||||||
|
|
||||||
} else if (category === "contribution") {
|
} else if (category === "contribution") {
|
||||||
const data = await prisma.voting_Kontributor.findMany({
|
const data = await prisma.voting_Kontributor.findMany({
|
||||||
orderBy: {
|
orderBy: {
|
||||||
|
|||||||
@@ -1,13 +1,13 @@
|
|||||||
[
|
[
|
||||||
{
|
{
|
||||||
"name": "default_user",
|
"name": "demo_user",
|
||||||
"nomor": "6282340374412",
|
"nomor": "6282340374412",
|
||||||
"masterUserRoleId": "1",
|
"masterUserRoleId": "1",
|
||||||
"active": true,
|
"active": true,
|
||||||
"termsOfServiceAccepted": false
|
"termsOfServiceAccepted": false
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"name": "admin_911",
|
"name": "demo_admin",
|
||||||
"nomor": "6281339158911",
|
"nomor": "6281339158911",
|
||||||
"masterUserRoleId": "3",
|
"masterUserRoleId": "3",
|
||||||
"active": true,
|
"active": true,
|
||||||
|
|||||||
@@ -43,7 +43,7 @@ export async function sendNotificationMobileToOneUser({
|
|||||||
|
|
||||||
// 2. Ambil semua token aktif milik penerima
|
// 2. Ambil semua token aktif milik penerima
|
||||||
const tokens = await prisma.tokenUserDevice.findMany({
|
const tokens = await prisma.tokenUserDevice.findMany({
|
||||||
where: { userId: recipientId, isActive: true },
|
where: { userId: recipientId },
|
||||||
select: { token: true, id: true },
|
select: { token: true, id: true },
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -53,7 +53,6 @@ export async function sendNotificationMobileToOneUser({
|
|||||||
}
|
}
|
||||||
|
|
||||||
// 3. Kirim FCM ke semua token
|
// 3. Kirim FCM ke semua token
|
||||||
|
|
||||||
await Promise.allSettled(
|
await Promise.allSettled(
|
||||||
tokens.map(async ({ token, id }) => {
|
tokens.map(async ({ token, id }) => {
|
||||||
try {
|
try {
|
||||||
@@ -80,12 +79,11 @@ export async function sendNotificationMobileToOneUser({
|
|||||||
});
|
});
|
||||||
} catch (fcmError: any) {
|
} catch (fcmError: any) {
|
||||||
// Hapus token jika invalid
|
// Hapus token jika invalid
|
||||||
console.log("fcmError", fcmError);
|
if (fcmError.code === "messaging/registration-token-not-registered") {
|
||||||
if (fcmError.code === "messaging/invalid-registration-token") {
|
// Hapus token dari DB
|
||||||
await prisma.tokenUserDevice.delete({ where: { id: id } });
|
await prisma.tokenUserDevice.delete({ where: { id } });
|
||||||
console.log(`❌ Invalid token removed: ${token}`);
|
console.log(`🗑️ Invalid token removed: ${id}`);
|
||||||
}
|
}
|
||||||
console.error(`FCM failed for token ${token}:`, fcmError.message);
|
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
);
|
);
|
||||||
|
|||||||
@@ -5,16 +5,32 @@ type StatusApp = "review" | "draft" | "reject" | "publish";
|
|||||||
const routeAdminMobile = {
|
const routeAdminMobile = {
|
||||||
userAccess: ({ id }: { id: string }) => `/admin/user-access/${id}`,
|
userAccess: ({ id }: { id: string }) => `/admin/user-access/${id}`,
|
||||||
// JOB
|
// JOB
|
||||||
jobDetail: ({ id, status }: { id: string; status: StatusApp }) =>
|
|
||||||
`/admin/job/${id}/${status}`,
|
|
||||||
jobByStatus: ({ status }: { status: StatusApp }) =>
|
jobByStatus: ({ status }: { status: StatusApp }) =>
|
||||||
`/admin/job/${status}/status`,
|
`/admin/job/${status}/status`,
|
||||||
|
|
||||||
|
// EVENT
|
||||||
|
eventByStatus: ({ status }: { status: StatusApp }) =>
|
||||||
|
`/admin/event/${status}/status`,
|
||||||
|
|
||||||
|
// VOTING
|
||||||
|
votingByStatus: ({ status }: { status: StatusApp }) =>
|
||||||
|
`/admin/voting/${status}/status`,
|
||||||
};
|
};
|
||||||
|
|
||||||
const routeUserMobile = {
|
const routeUserMobile = {
|
||||||
home: `/(user)/home`,
|
home: `/(user)/home`,
|
||||||
// JOB
|
// JOB
|
||||||
jobDetailPublised: ({ id }: { id: string }) => `/job/${id}`,
|
|
||||||
jobByStatus: ({ status }: { status?: StatusApp }) =>
|
jobByStatus: ({ status }: { status?: StatusApp }) =>
|
||||||
`/job/(tabs)/status?status=${status}`,
|
`/job/(tabs)/status?status=${status}`,
|
||||||
|
jobDetailPublised: ({ id }: { id: string }) => `/job/${id}`,
|
||||||
|
|
||||||
|
// EVENT
|
||||||
|
eventByStatus: ({ status }: { status?: StatusApp }) =>
|
||||||
|
`/event/(tabs)/status?status=${status}`,
|
||||||
|
eventDetailPublised: ({ id }: { id: string }) => `/event/${id}/publish`,
|
||||||
|
|
||||||
|
// VOTING
|
||||||
|
votingByStatus: ({ status }: { status?: StatusApp }) =>
|
||||||
|
`/voting/(tabs)/status?status=${status}`,
|
||||||
|
votingDetailPublised: ({ id }: { id: string }) => `/voting/${id}`,
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -13,18 +13,20 @@ export type NotificationMobilePayload = {
|
|||||||
|
|
||||||
export type NotificationMobileTitleType =
|
export type NotificationMobileTitleType =
|
||||||
| (string & { __type: "NotificationMobileTitleType" })
|
| (string & { __type: "NotificationMobileTitleType" })
|
||||||
| "Pengajuan Review"
|
// Admin
|
||||||
|
| "Pengajuan Review Baru"
|
||||||
|
// USER
|
||||||
|
| "Pengajuan Review Ditolak"
|
||||||
| "Review Selesai"
|
| "Review Selesai"
|
||||||
// to ALL user
|
// to ALL user
|
||||||
| "Ada lowongan kerja baru"
|
|
||||||
|
|
||||||
export type NotificationMobileBodyType =
|
export type NotificationMobileBodyType =
|
||||||
// USER
|
// USER
|
||||||
| (string & { __type: "NotificationMobileBodyType" })
|
| (string & { __type: "NotificationMobileBodyType" })
|
||||||
| "Terdapat pengajuan baru yang perlu direview"
|
| "Ada pengajuan review" // tambah title
|
||||||
|
|
||||||
// ADMIN
|
// ADMIN
|
||||||
| "Pengajuan data anda telah di tolak !"
|
| "Mohon perbaiki data sesuai catatan penolakan !"
|
||||||
| "Selamat data anda telah terpublikasi"
|
| "Selamat data anda telah terpublikasi"
|
||||||
|
|
||||||
export type TypeNotificationCategoryApp =
|
export type TypeNotificationCategoryApp =
|
||||||
|
|||||||
Reference in New Issue
Block a user