Merge pull request 'amalia/08-apr-26' (#31) from amalia/08-apr-26 into join

Reviewed-on: #31
This commit is contained in:
2026-04-08 17:27:06 +08:00
2 changed files with 1071 additions and 310 deletions

View File

@@ -1,4 +1,5 @@
import formatDateTime from "@/lib/formatDateTime"; import formatDateTime from "@/lib/formatDateTime";
import timeAgo from "@/lib/timeAgo";
import { prisma } from "@/module/_global"; import { prisma } from "@/module/_global";
import cors from "@elysiajs/cors"; import cors from "@elysiajs/cors";
import { swagger } from "@elysiajs/swagger"; import { swagger } from "@elysiajs/swagger";
@@ -24,9 +25,7 @@ const MonitoringServer = new Elysia({ prefix: "/api/monitoring" })
} }
})) }))
.get( .get("/grid-overview", async ({ query, set }) => {
"/grid-overview",
async ({ query, set }) => {
try { try {
const version = await prisma.setting.findMany({ const version = await prisma.setting.findMany({
select: { select: {
@@ -103,9 +102,7 @@ const MonitoringServer = new Elysia({ prefix: "/api/monitoring" })
}, },
} }
) )
.get( .get("/daily-activity", async ({ query, set }) => {
"/daily-activity",
async ({ query, set }) => {
try { try {
// const data = await prisma.userLog.findMany({ // const data = await prisma.userLog.findMany({
// where: { // where: {
@@ -180,9 +177,7 @@ const MonitoringServer = new Elysia({ prefix: "/api/monitoring" })
}, },
} }
) )
.get( .get("/comparison-activity", async ({ query, set }) => {
"/comparison-activity",
async ({ query, set }) => {
try { try {
const data = await prisma.$queryRaw` const data = await prisma.$queryRaw`
SELECT SELECT
@@ -226,9 +221,67 @@ const MonitoringServer = new Elysia({ prefix: "/api/monitoring" })
}, },
} }
) )
.get( .post("/version-update", async ({ body, set }) => {
"/get-villages", try {
async ({ query, set }) => { const { mobile_latest_version, mobile_minimum_version, mobile_maintenance, mobile_message_update } = body
await prisma.$transaction([
prisma.setting.update({
where: { id: "mobile_latest_version" },
data: { value: mobile_latest_version },
}),
prisma.setting.update({
where: { id: "mobile_minimum_version" },
data: { value: mobile_minimum_version },
}),
prisma.setting.update({
where: { id: "mobile_maintenance" },
data: { value: mobile_maintenance.toString() },
}),
prisma.setting.update({
where: { id: "mobile_message_update" },
data: { value: mobile_message_update },
}),
]);
return {
success: true,
message: "Berhasil update data",
};
} catch (error) {
console.error("[overview] version-update error:", error);
set.status = 500;
return {
success: false,
message: "Terjadi kesalahan pada server",
};
}
},
{
body: t.Object({
mobile_latest_version: t.String({
error: "mobile latest version harus diisi",
description: "mobile latest version yang ingin diupdate"
}),
mobile_minimum_version: t.String({
error: "mobile minimum version harus diisi",
description: "mobile minimum version yang ingin diupdate"
}),
mobile_maintenance: t.Boolean({
description: "status maintenance mobile app"
}),
mobile_message_update: t.String({
description: "pesan update mobile app"
}),
}),
detail: {
summary: "Version Update",
description: "Menu Overview - Mengupdate data versi aplikasi.",
tags: ["overview"],
},
}
)
.get("/get-villages", async ({ query, set }) => {
const { search, page } = query; const { search, page } = query;
const pageNum = Number(page ?? 1); const pageNum = Number(page ?? 1);
try { try {
@@ -291,9 +344,119 @@ const MonitoringServer = new Elysia({ prefix: "/api/monitoring" })
}, },
} }
) )
.get( .post("/create-villages", async ({ body, set }) => {
"/info-villages", const { name, desc, username, phone, nik, email, gender } = body;
async ({ query, set }) => { try {
const create_village = await prisma.village.create({
data: {
name: name,
desc: desc,
isDummy: false,
},
select: {
id: true
}
})
if (create_village) {
const create_group = await prisma.group.create({
data: {
idVillage: create_village.id,
name: "Dinas",
},
select: {
id: true
}
})
const create_position = await prisma.position.create({
data: {
idGroup: create_group.id,
name: "Perbekel",
},
select: {
id: true
}
})
const cek_user = await prisma.user.count({
where: {
OR: [
{ nik: nik },
{ phone: phone },
{ email: email },
]
},
});
if (cek_user > 0) {
return {
success: true,
message: "Desa berhasil ditambahkan, namun user sudah terdaftar. Silahkan daftar user pada menu list user.",
};
}
const create_user = await prisma.user.create({
data: {
idUserRole: "supadmin",
idVillage: create_village.id,
idGroup: create_group.id,
idPosition: create_position.id,
nik: nik,
name: username,
phone: phone,
email: email,
gender: gender
},
select: {
id: true
}
})
if (create_user) {
return {
success: true,
message: "Desa dan user berhasil ditambahkan.",
};
} else {
return {
success: true,
message: "Desa berhasil ditambahkan, namun user gagal ditambahkan. Silahkan daftar user pada menu list user.",
};
}
} else {
return {
success: false,
message: "Gagal menambahkan data",
};
}
} catch (error) {
console.error("[villages] create-villages error:", error);
set.status = 500;
return {
success: false,
message: "Terjadi kesalahan pada server",
};
}
},
{
body: t.Object({
name: t.String({ description: "Nama desa" }),
desc: t.String({ description: "Deskripsi desa" }),
username: t.String({ description: "Username" }),
phone: t.String({ description: "Nomor telepon" }),
nik: t.String({ description: "Nomor Induk Kependudukan" }),
email: t.String({ description: "Email" }),
gender: t.String({ description: "Jenis Kelamin" }),
}),
detail: {
summary: "Create Villages",
description: "Menu Villages - Membuat data desa.",
tags: ["villages"],
},
}
)
.get("/info-villages", async ({ query, set }) => {
const { id } = query; const { id } = query;
try { try {
const data = await prisma.village.findUnique({ const data = await prisma.village.findUnique({
@@ -360,9 +523,7 @@ const MonitoringServer = new Elysia({ prefix: "/api/monitoring" })
}, },
} }
) )
.get( .get("/grid-villages", async ({ query, set }) => {
"/grid-villages",
async ({ query, set }) => {
const { id } = query; const { id } = query;
try { try {
@@ -452,7 +613,7 @@ const MonitoringServer = new Elysia({ prefix: "/api/monitoring" })
}, },
} }
) )
.get("/log-villages", async ({ query, set }) => { .get("/graph-log-villages", async ({ query, set }) => {
const { id, time } = query; const { id, time } = query;
try { try {
@@ -589,7 +750,7 @@ const MonitoringServer = new Elysia({ prefix: "/api/monitoring" })
data: result, data: result,
}; };
} catch (error) { } catch (error) {
console.error("[log-villages] error:", error); console.error("[graph-log-villages] error:", error);
set.status = 500; set.status = 500;
return { return {
success: false, success: false,
@@ -613,13 +774,575 @@ const MonitoringServer = new Elysia({ prefix: "/api/monitoring" })
), ),
}), }),
detail: { detail: {
summary: "Log Villages", summary: "Graph Log Villages",
description: description:
"Mendapatkan data log aktivitas desa berdasarkan rentang waktu (harian, bulanan, tahunan)", "Mendapatkan data grafik log aktivitas desa berdasarkan rentang waktu (harian, bulanan, tahunan)",
tags: ["detail-villages"], tags: ["detail-villages"],
}, },
} }
); )
.post("/edit-villages", async ({ body, set }) => {
const { id, name, desc } = body;
try {
const village = await prisma.village.findUnique({
where: { id },
});
if (!village) {
set.status = 404;
return {
success: false,
message: "Desa tidak ditemukan",
};
}
const upd = await prisma.village.update({
where: { id },
data: {
name,
desc,
},
});
return {
success: true,
message: "Berhasil mengupdate data",
};
} catch (error) {
console.error("[edit-villages] error:", error);
set.status = 500;
return {
success: false,
message: "Terjadi kesalahan pada server",
};
}
},
{
body: t.Object({
id: t.String({ description: "ID desa" }),
name: t.String({ description: "Nama desa" }),
desc: t.String({ description: "Deskripsi desa" }),
}),
detail: {
summary: "Edit Villages",
description:
"Mengupdate data desa",
tags: ["detail-villages"],
},
}
)
.post("/update-status-villages", async ({ body, set }) => {
const { id, active } = body;
try {
const village = await prisma.village.findUnique({
where: { id },
});
if (!village) {
set.status = 404;
return {
success: false,
message: "Desa tidak ditemukan",
};
}
const upd = await prisma.village.update({
where: { id },
data: {
isActive: active,
},
});
return {
success: true,
message: "Berhasil mengupdate data",
};
} catch (error) {
console.error("[update-status-villages] error:", error);
set.status = 500;
return {
success: false,
message: "Terjadi kesalahan pada server",
};
}
},
{
body: t.Object({
id: t.String({ description: "ID desa" }),
active: t.Boolean({ description: "Status desa" }),
}),
detail: {
summary: "Update Status Villages",
description:
"Mengupdate status desa",
tags: ["detail-villages"],
},
}
)
.get("/log-all-villages", async ({ query, set }) => {
const { page = 1, search } = query;
const pageNum = Number(page) || 1;
const take = 15;
const skip = (pageNum - 1) * take;
try {
const dataLog = await prisma.userLog.findMany({
where: {
...(search && {
OR: [
{
User: {
name: {
contains: search,
mode: "insensitive",
},
},
},
{
User: {
Village: {
name: {
contains: search,
mode: "insensitive",
},
},
},
},
],
}),
},
select: {
id: true,
createdAt: true,
action: true,
desc: true,
User: {
select: {
name: true,
Village: {
select: {
name: true,
},
},
},
},
},
orderBy: {
createdAt: "desc",
},
skip,
take,
});
const total = await prisma.userLog.count({
where: {
...(search && {
OR: [
{
User: {
name: {
contains: search,
mode: "insensitive",
},
},
},
{
User: {
Village: {
name: {
contains: search,
mode: "insensitive",
},
},
},
},
],
}),
},
});
const result = dataLog.map((item) => ({
id: item.id,
createdAt: timeAgo(item.createdAt),
action: item.action,
desc: item.desc,
username: item.User.name,
village: item.User.Village.name,
}));
return {
success: true,
message: "Berhasil mendapatkan data",
data: {
log: result,
total,
totalPage: Math.ceil(total / take),
currentPage: pageNum,
},
};
} catch (error) {
console.error("[log-villages] error:", error);
set.status = 500;
return {
success: false,
message: "Terjadi kesalahan pada server",
data: null,
};
}
},
{
query: t.Object({
page: t.Optional(t.String({ description: "Halaman" })),
search: t.Optional(t.String({ description: "Pencarian" })),
}),
detail: {
summary: "Log Villages",
description:
"Mendapatkan data log aktivitas desa berdasarkan halaman dan pencarian",
tags: ["log-activity"],
},
}
)
.get("/user", async ({ query, set }) => {
const { page = 1, search } = query;
const pageNum = Number(page) || 1;
const take = 25;
const skip = (pageNum - 1) * take;
try {
const data = await prisma.user.findMany({
where: {
...(search && {
OR: [
{
name: {
contains: search,
mode: "insensitive",
},
},
{
phone: {
contains: search,
mode: "insensitive",
},
},
{
email: {
contains: search,
mode: "insensitive",
},
},
{
nik: {
contains: search,
mode: "insensitive",
},
},
{
Village: {
name: {
contains: search,
mode: "insensitive",
},
},
},
{
idUserRole: search,
},
],
}),
},
select: {
id: true,
name: true,
nik: true,
phone: true,
email: true,
isWithoutOTP: true,
isActive: true,
UserRole: {
select: {
name: true,
},
},
Village: {
select: {
name: true,
},
},
Group: {
select: {
name: true,
},
},
Position: {
select: {
name: true,
},
},
},
orderBy: {
createdAt: "desc",
},
skip,
take,
});
const total = await prisma.user.count({
where: {
...(search && {
OR: [
{
name: {
contains: search,
mode: "insensitive",
},
},
{
phone: {
contains: search,
mode: "insensitive",
},
},
{
email: {
contains: search,
mode: "insensitive",
},
},
{
nik: {
contains: search,
mode: "insensitive",
},
},
{
Village: {
name: {
contains: search,
mode: "insensitive",
},
},
},
{
idUserRole: search,
},
],
}),
},
});
const result = data.map((item) => ({
id: item.id,
name: item.name,
nik: item.nik,
phone: item.phone,
email: item.email,
isWithoutOTP: item.isWithoutOTP,
isActive: item.isActive,
role: item.UserRole?.name,
village: item.Village?.name,
group: item.Group?.name,
position: item.Position?.name,
}));
return {
success: true,
message: "Berhasil mendapatkan data",
data: {
user: result,
total,
totalPage: Math.ceil(total / take),
currentPage: pageNum,
},
};
} catch (error) {
console.error("[user] error:", error);
set.status = 500;
return {
success: false,
message: "Terjadi kesalahan pada server",
data: null,
};
}
},
{
query: t.Object({
page: t.Optional(t.String({ description: "Halaman" })),
search: t.Optional(t.String({ description: "Pencarian" })),
}),
detail: {
summary: "User",
description:
"Mendapatkan data user berdasarkan halaman dan pencarian",
tags: ["user"],
},
}
)
.post("/create-user", async ({ body, set }) => {
const { name, nik, phone, email, gender, idUserRole, idVillage, idGroup, idPosition } = body;
try {
const cekUser = await prisma.user.findFirst({
where: {
OR: [
{ nik },
{ phone },
{ email },
],
},
});
if (cekUser) {
return {
success: false,
message: "User sudah ada",
};
}
const user = await prisma.user.create({
data: {
name,
nik,
phone,
email,
gender,
idUserRole,
idVillage,
idGroup,
idPosition,
},
});
return {
success: true,
message: "Berhasil membuat user",
};
} catch (error) {
console.error("[create-user] error:", error);
set.status = 500;
return {
success: false,
message: "Terjadi kesalahan pada server",
};
}
},
{
body: t.Object({
name: t.String({ description: "Nama" }),
nik: t.String({ description: "NIK" }),
phone: t.String({ description: "Nomor Telepon" }),
email: t.String({ description: "Email" }),
gender: t.String({ description: "Jenis Kelamin" }),
idUserRole: t.String({ description: "ID Role" }),
idVillage: t.String({ description: "ID Desa" }),
idGroup: t.String({ description: "ID Group" }),
idPosition: t.Optional(t.String({ description: "ID Posisi" })),
}),
detail: {
summary: "Create User",
description:
"Membuat user",
tags: ["user"],
},
}
)
.post("/edit-user", async ({ body, set }) => {
const { id, name, nik, phone, email, gender, idUserRole, idVillage, idGroup, idPosition, isActive, isWithoutOTP } = body;
try {
const cekId = await prisma.user.findFirst({
where: {
id,
},
});
if (!cekId) {
return {
success: false,
message: "User tidak ditemukan",
};
}
const cekUser = await prisma.user.findFirst({
where: {
id: {
not: id,
},
OR: [
{ nik },
{ phone },
{ email },
],
},
});
if (cekUser) {
return {
success: false,
message: "User sudah ada",
};
}
const user = await prisma.user.update({
where: {
id,
},
data: {
name,
nik,
phone,
email,
gender,
idUserRole,
idVillage,
idGroup,
idPosition,
isActive,
isWithoutOTP,
},
});
return {
success: true,
message: "Berhasil mengedit user",
};
} catch (error) {
console.error("[edit-user] error:", error);
set.status = 500;
return {
success: false,
message: "Terjadi kesalahan pada server",
};
}
},
{
body: t.Object({
id: t.String({ description: "ID" }),
name: t.String({ description: "Nama" }),
nik: t.String({ description: "NIK" }),
phone: t.String({ description: "Nomor Telepon" }),
email: t.String({ description: "Email" }),
gender: t.String({ description: "Jenis Kelamin" }),
idUserRole: t.String({ description: "ID Role" }),
idVillage: t.String({ description: "ID Desa" }),
idGroup: t.String({ description: "ID Group" }),
idPosition: t.Optional(t.String({ description: "ID Posisi" })),
isActive: t.Boolean({ description: "Aktif" }),
isWithoutOTP: t.Boolean({ description: "Tanpa OTP" }),
}),
detail: {
summary: "Edit User",
description:
"Mengedit user",
tags: ["user"],
},
}
)
;
; ;

38
src/lib/timeAgo.ts Normal file
View File

@@ -0,0 +1,38 @@
function timeAgo(date: Date) {
const now = new Date();
const d = new Date(date);
const diffMs = now.getTime() - d.getTime();
const seconds = Math.floor(diffMs / 1000);
const minutes = Math.floor(seconds / 60);
const hours = Math.floor(minutes / 60);
// 🔥 cek apakah masih hari yang sama
const isToday =
now.getDate() === d.getDate() &&
now.getMonth() === d.getMonth() &&
now.getFullYear() === d.getFullYear();
if (isToday) {
if (seconds < 60) return `${seconds} detik lalu`;
if (minutes < 60) return `${minutes} menit lalu`;
return `${hours} jam lalu`;
}
// 🔥 kalau bukan hari ini → tampil tanggal + jam
const time = d.toLocaleTimeString("id-ID", {
hour: "2-digit",
minute: "2-digit",
});
const datePart = d.toLocaleDateString("id-ID", {
day: "2-digit",
month: "short",
year: "numeric",
});
return `${time} ${datePart}`;
}
export default timeAgo