wibu/hipmi
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

mobile-notification invesment #44

Merged
bagasbanuna merged 2 commits from mobile-notification/21-jan-26 into staging 2026-01-21 15:41:19 +08:00
Conversation 0 Commits 2 Files Changed 6 +273 -27
6 changed files with 273 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

79
src/app/api/mobile/admin/investment/[id]/invoice/route.ts
View File

@@ -1,5 +1,11 @@
import { NextResponse } from "next/server";
import { prisma } from "@/lib";
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, PUT };
@@ -65,19 +71,39 @@ async function PUT(req: Request, { params }: { params: { id: string } }) {
data: {
statusInvoiceId: "4",
},
// select: {
// StatusInvoice: true,
// authorId: true,
// },
select: {
Investasi: {
select: {
title: true,
},
},
authorId: true,
},
});
// SEND NOTIFICAtION
await sendNotificationMobileToOneUser({
recipientId: updt?.authorId as string,
senderId: data?.senderId || "",
payload: {
title: "Transaksi Tertolak" as NotificationMobileTitleType,
body: `Maaf transaksi kamu telah ditolak ! ${updt?.Investasi?.title}` as NotificationMobileBodyType,
type: "announcement",
kategoriApp: "INVESTASI",
deepLink: routeUserMobile.investasiTransaction,
},
});
fixData = updt;
} else if (category === "accept") {
const dataInvestasi: any = await prisma.investasi.findFirst({
const findInvestasi = await prisma.investasi.findFirst({
where: {
id: data.investasiId,
},
select: {
id: true,
title: true,
authorId: true,
totalLembar: true,
sisaLembar: true,
lembarTerbeli: true,
@@ -85,30 +111,33 @@ async function PUT(req: Request, { params }: { params: { id: string } }) {
});
// Hitung TOTAL SISA LEMBAR
const investasi_sisaLembar = Number(dataInvestasi?.sisaLembar);
const investasi_sisaLembar = Number(findInvestasi?.sisaLembar);
const invoice_lembarTerbeli = Number(data.lembarTerbeli);
const resultSisaLembar = investasi_sisaLembar - invoice_lembarTerbeli;
// TAMBAH LEMBAR TERBELI
const investasi_lembarTerbeli = Number(dataInvestasi?.lembarTerbeli);
const investasi_lembarTerbeli = Number(findInvestasi?.lembarTerbeli);
const resultLembarTerbeli =
investasi_lembarTerbeli + invoice_lembarTerbeli;
// Progress
const investasi_totalLembar = Number(dataInvestasi?.totalLembar);
const investasi_totalLembar = Number(findInvestasi?.totalLembar);
const progress = (resultLembarTerbeli / investasi_totalLembar) * 100;
const resultProgres = Number(progress).toFixed(2);
const updt = await prisma.investasi_Invoice.update({
const updateInvoice = await prisma.investasi_Invoice.update({
where: {
id: id,
},
data: {
statusInvoiceId: "1",
},
select: {
authorId: true,
},
});
if (!updt) {
if (!updateInvoice) {
return NextResponse.json(
{
success: false,
@@ -144,7 +173,35 @@ async function PUT(req: Request, { params }: { params: { id: string } }) {
);
}
fixData = updt;
// SEND NOTIFICATION: to investor
await sendNotificationMobileToOneUser({
recipientId: updateInvoice?.authorId as string,
senderId: data?.senderId || "",
payload: {
title: "Transaksi Berhasil" as NotificationMobileTitleType,
body: `Selamat anda menjadi investor pada investasi ${findInvestasi?.title}` as NotificationMobileBodyType,
type: "announcement",
kategoriApp: "INVESTASI",
deepLink: routeUserMobile.investasiTransaction,
},
});
// SEND NOTIFICATION: to creator
await sendNotificationMobileToOneUser({
recipientId: findInvestasi?.authorId as any,
senderId: data?.senderId || "",
payload: {
title: "Ada Investor Baru !" as NotificationMobileTitleType,
body: `Cek daftar investor pada ${findInvestasi?.title}` as NotificationMobileBodyType,
type: "announcement",
kategoriApp: "INVESTASI",
deepLink: routeUserMobile.investasiDetailPublish({
id: findInvestasi?.id as string,
}),
},
});
fixData = updateInvoice;
} else {
return NextResponse.json(
{

78
src/app/api/mobile/admin/investment/[id]/route.ts
View File

@@ -1,11 +1,20 @@
import { NextResponse } from "next/server";
import { prisma } from "@/lib";
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 };
async function GET(request: Request, { params }: { params: { id: string } }) {
const { id } = params;
try {
const data = await prisma.investasi.findUnique({
where: {
@@ -78,14 +87,19 @@ async function GET(request: Request, { params }: { params: { id: string } }) {
async function PUT(request: Request, { params }: { params: { id: string } }) {
const { id } = params;
const { data } = await request.json();
const { catatan, senderId } = data;
console.log("[DATA]", data);
console.log("[CATATAN]", catatan);
console.log("[SENDER ID]", senderId);
const { searchParams } = new URL(request.url);
const status = searchParams.get("status");
console.log("[=======Start Investment console=======]");
console.log("[ID]", id);
console.log("[DATA]", data);
console.log("[STATUS]", status);
console.log("[=======End Investment console=======]");
// console.log("[=======Start Investment console=======]");
// console.log("[ID]", id);
// console.log("[STATUS]", status);
// console.log("[=======End Investment console=======]");
const publishTime = new Date();
@@ -96,9 +110,26 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
id: id,
},
data: {
catatan: data,
catatan: catatan,
masterStatusInvestasiId: "4",
},
select: {
authorId: true,
title: true,
},
});
// SEND NOTIFICATION
await sendNotificationMobileToOneUser({
recipientId: updatedData.authorId as any,
senderId: senderId,
payload: {
title: "Pengajuan Review Ditolak",
body: "Mohon perbaiki data sesuai catatan penolakan !",
type: "announcement",
kategoriApp: "INVESTASI",
deepLink: routeUserMobile.investmentPortofolioByStatus({ status: "reject" }),
},
});
console.log("[UPDATE REJECT]", updatedData);
@@ -114,6 +145,39 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
},
});
// SEND NOTIFICAtION
await sendNotificationMobileToOneUser({
recipientId: updatedData.authorId as any,
senderId: senderId,
payload: {
title: "Review Selesai",
body: `Investasi kamu telah dipublikasikan ! ${updatedData.title}` as NotificationMobileBodyType,
type: "announcement",
kategoriApp: "INVESTASI",
deepLink: routeUserMobile.investmentPortofolioByStatus({ status: "publish" }),
},
});
const allUsers = await prisma.user.findMany({
where: {
NOT: { id: updatedData.authorId as any },
active: true,
},
select: { id: true },
});
await sendNotificationMobileToManyUser({
recipientIds: allUsers.map((user) => user.id),
senderId: senderId,
payload: {
title: "Ayo Cek Investasi Terbaru" as NotificationMobileTitleType,
body: `${updatedData.title}` as NotificationMobileBodyType,
type: "announcement",
kategoriApp: "INVESTASI",
deepLink: routeUserMobile.investasiDetailPublish({ id: id }),
},
});
console.log("[UPDATE PUBLISH]", updatedData);
}

48
src/app/api/mobile/investment/[id]/document/route.ts
View File

@@ -1,5 +1,10 @@
import { NextResponse } from "next/server";
import { prisma } from "@/lib";
import { sendNotificationMobileToManyUser } from "@/lib/mobile/notification/send-notification";
import {
NotificationMobileBodyType,
NotificationMobileTitleType,
} from "../../../../../../../types/type-mobile-notification";
export { POST, GET, DELETE };
@@ -10,7 +15,7 @@ async function POST(request: Request, { params }: { params: { id: string } }) {
console.log("[POST DOCUMENT DATA]", data);
try {
const create = await prisma.dokumenInvestasi.upsert({
const createdDocs = await prisma.dokumenInvestasi.upsert({
where: {
id: id,
},
@@ -23,9 +28,42 @@ async function POST(request: Request, { params }: { params: { id: string } }) {
title: data.title,
fileId: data.fileId,
},
select: {
investasiId: true,
investasi: {
select: {
title: true,
},
},
},
});
if (!create)
const findInvestor = await prisma.investasi_Invoice.findMany({
where: {
investasiId: id,
StatusInvoice: {
name: "Berhasil",
},
},
});
// SEND NOTIFICATION
// await sendNotificationMobileToManyUser({
// recipientIds: findInvestor.map((user) => user.id),
// senderId: data.authorId,
// payload: {
// title: "Cek Dokumen" as NotificationMobileTitleType,
// body: `Ada informasi dokumen yang di\\\ ${createdDocs.investasi?.title}` as NotificationMobileBodyType,
// type: "announcement",
// kategoriApp: "INVESTASI",
// deepLink: routeAdminMobile.investmentDetailPublish({
// id: update.investasiId as string,
// status: "publish",
// }),
// },
// });
if (!createdDocs)
return NextResponse.json({
status: 201,
success: true,
@@ -93,7 +131,7 @@ async function GET(request: Request, { params }: { params: { id: string } }) {
async function DELETE(
request: Request,
{ params }: { params: { id: string } }
{ params }: { params: { id: string } },
) {
const { id } = params;
@@ -111,9 +149,9 @@ async function DELETE(
headers: {
Authorization: `Bearer ${process.env.WS_APIKEY}`,
},
}
},
);
return NextResponse.json({
status: 200,
success: true,

48
src/app/api/mobile/investment/[id]/invoice/route.ts
View File

@@ -1,6 +1,12 @@
import { prisma } from "@/lib";
import { sendNotificationMobileToManyUser } from "@/lib/mobile/notification/send-notification";
import { routeAdminMobile } from "@/lib/mobile/route-page-mobile";
import _ from "lodash";
import { NextResponse } from "next/server";
import {
NotificationMobileTitleType,
NotificationMobileBodyType,
} from "../../../../../../../types/type-mobile-notification";
export { POST, GET, PUT };
@@ -49,7 +55,6 @@ async function GET(request: Request, { params }: { params: { id: string } }) {
const authorId = searchParams.get("authorId");
console.log("[ID INVOICE]", id);
let fixData;
@@ -198,8 +203,49 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
statusInvoiceId: checkStatus.id,
imageId: data.imageId,
},
select: {
investasiId: true,
},
});
if (fixStatus === "Proses") {
// kirim notif ke author investasi
const findInvestasi = await prisma.investasi.findUnique({
where: {
id: update.investasiId as any,
},
select: {
title: true,
authorId: true,
},
});
const findUsers = await prisma.user.findMany({
where: {
masterUserRoleId: "2",
active: true,
NOT: { id: findInvestasi?.authorId as any },
},
select: { id: true },
});
// SEND NOTIFICATION
await sendNotificationMobileToManyUser({
recipientIds: findUsers.map((user) => user.id),
senderId: data.authorId,
payload: {
title: "Ada Investor Baru !" as NotificationMobileTitleType,
body: `Cek data investor pada ${findInvestasi?.title}` as NotificationMobileBodyType,
type: "announcement",
kategoriApp: "INVESTASI",
deepLink: routeAdminMobile.investmentDetailPublish({
id: update.investasiId as string,
status: "publish",
}),
},
});
}
console.log("[UPDATE]", update);
return NextResponse.json({

25
src/app/api/mobile/investment/route.ts
View File

@@ -2,6 +2,9 @@ import _ from "lodash";
import { NextResponse } from "next/server";
import prisma from "@/lib/prisma";
import moment from "moment";
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 };
@@ -9,12 +12,14 @@ async function POST(request: Request) {
const { data } = await request.json();
console.log(["DATA INVESTASI"], data);
const fixTitle = _.startCase(data.title)
try {
const create = await prisma.investasi.create({
data: {
masterStatusInvestasiId: "2",
authorId: data.authorId,
title: _.startCase(data.title),
title: fixTitle,
targetDana: data.targetDana,
hargaLembar: data.hargaLembar,
totalLembar: data.totalLembar,
@@ -30,6 +35,24 @@ async function POST(request: Request) {
console.log("[CREATE INVESTASI]", create);
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: fixTitle as NotificationMobileBodyType,
type: "announcement",
deepLink: routeAdminMobile.investmentByStatus({ status: "review" }),
kategoriApp: "INVESTASI",
},
});
return NextResponse.json({
status: 201,
success: true,

22
src/lib/mobile/route-page-mobile.ts
View File

@@ -19,6 +19,16 @@ const routeAdminMobile = {
// FORUM
forumPreviewReportPosting: `/admin/forum/report-posting`,
forumPreviewReportComment: `/admin/forum/report-comment`,
// INVESTMENT
investmentByStatus: ({ status }: { status: StatusApp }) => `/admin/investment/${status}/status`,
investmentDetailPublish: ({
id,
status,
}: {
id: string;
status: StatusApp;
}) => `/admin/investment/${id}/${status}`,
};
const routeUserMobile = {
@@ -41,6 +51,14 @@ const routeUserMobile = {
// FORUM
forumBeranda: `/forum`,
forumDetail: ({ id }: { id: string }) => `/forum/${id}`,
forumPreviewReportPosting: ({ id }: { id: string }) => `/forum/${id}/preview-report-posting`,
forumPreviewReportComment: ({ id }: { id: string }) => `/forum/${id}/preview-report-comment`,
forumPreviewReportPosting: ({ id }: { id: string }) =>
`/forum/${id}/preview-report-posting`,
forumPreviewReportComment: ({ id }: { id: string }) =>
`/forum/${id}/preview-report-comment`,
// INVESTMENT
investmentPortofolioByStatus: ({ status }: { status?: StatusApp }) =>
`/investment/(tabs)/portofolio?status=${status}`,
investasiDetailPublish: ({ id }: { id: string }) => `/investment/${id}`,
investasiTransaction: `/investment/(tabs)/transaction`
};