Merge pull request 'nico/5-mar-26/fix-musik-fix-apbdes' (#75) from nico/5-mar-26/fix-musik-fix-apbdes into staggingweb
Reviewed-on: #75
This commit is contained in:
@@ -17,8 +17,8 @@ type FormCreate = {
|
||||
name?: string;
|
||||
deskripsi?: string;
|
||||
jumlah?: string;
|
||||
imageId: string;
|
||||
fileId: string;
|
||||
imageId?: string | null; // Opsional
|
||||
fileId?: string | null; // Opsional
|
||||
items: APBDesItemInput[];
|
||||
};
|
||||
|
||||
@@ -32,12 +32,7 @@ export default async function apbdesCreate(context: Context) {
|
||||
if (!body.tahun) {
|
||||
throw new Error('Tahun is required');
|
||||
}
|
||||
if (!body.imageId) {
|
||||
throw new Error('Image ID is required');
|
||||
}
|
||||
if (!body.fileId) {
|
||||
throw new Error('File ID is required');
|
||||
}
|
||||
// Image dan file sekarang opsional
|
||||
if (!body.items || body.items.length === 0) {
|
||||
throw new Error('At least one item is required');
|
||||
}
|
||||
@@ -50,8 +45,8 @@ export default async function apbdesCreate(context: Context) {
|
||||
name: body.name || `APBDes Tahun ${body.tahun}`,
|
||||
deskripsi: body.deskripsi,
|
||||
jumlah: body.jumlah,
|
||||
imageId: body.imageId,
|
||||
fileId: body.fileId,
|
||||
imageId: body.imageId || null, // null jika tidak ada
|
||||
fileId: body.fileId || null, // null jika tidak ada
|
||||
},
|
||||
});
|
||||
|
||||
|
||||
@@ -36,8 +36,8 @@ const APBDes = new Elysia({
|
||||
name: t.Optional(t.String()),
|
||||
deskripsi: t.Optional(t.String()),
|
||||
jumlah: t.Optional(t.String()),
|
||||
imageId: t.String(),
|
||||
fileId: t.String(),
|
||||
imageId: t.Optional(t.String()),
|
||||
fileId: t.Optional(t.String()),
|
||||
items: t.Array(ApbdesItemSchema),
|
||||
}),
|
||||
})
|
||||
@@ -50,8 +50,8 @@ const APBDes = new Elysia({
|
||||
name: t.Optional(t.String()),
|
||||
deskripsi: t.Optional(t.String()),
|
||||
jumlah: t.Optional(t.String()),
|
||||
imageId: t.String(),
|
||||
fileId: t.String(),
|
||||
imageId: t.Optional(t.String()),
|
||||
fileId: t.Optional(t.String()),
|
||||
items: t.Array(ApbdesItemSchema),
|
||||
}),
|
||||
})
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
import prisma from "@/lib/prisma";
|
||||
import { Context } from "elysia";
|
||||
import { assignParentIdsToApbdesItems } from "./lib/getParentsID";
|
||||
import { RealisasiItem } from "@prisma/client";
|
||||
|
||||
type APBDesItemInput = {
|
||||
kode: string;
|
||||
@@ -15,8 +16,8 @@ type FormUpdateBody = {
|
||||
name?: string;
|
||||
deskripsi?: string;
|
||||
jumlah?: string;
|
||||
imageId: string;
|
||||
fileId: string;
|
||||
imageId?: string | null;
|
||||
fileId?: string | null;
|
||||
items: APBDesItemInput[];
|
||||
};
|
||||
|
||||
@@ -28,6 +29,16 @@ export default async function apbdesUpdate(context: Context) {
|
||||
// 1. Pastikan APBDes ada
|
||||
const existing = await prisma.aPBDes.findUnique({
|
||||
where: { id },
|
||||
include: {
|
||||
items: {
|
||||
where: { isActive: true },
|
||||
include: {
|
||||
realisasiItems: {
|
||||
where: { isActive: true },
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
});
|
||||
|
||||
if (!existing) {
|
||||
@@ -38,17 +49,35 @@ export default async function apbdesUpdate(context: Context) {
|
||||
};
|
||||
}
|
||||
|
||||
// 2. Hapus semua item lama (cascade akan menghapus realisasiItems juga)
|
||||
// 2. Build map untuk preserve realisasiItems berdasarkan kode
|
||||
const existingItemsMap = new Map<string, {
|
||||
id: string;
|
||||
realisasiItems: RealisasiItem[];
|
||||
}>();
|
||||
|
||||
existing.items.forEach(item => {
|
||||
existingItemsMap.set(item.kode, {
|
||||
id: item.id,
|
||||
realisasiItems: item.realisasiItems,
|
||||
});
|
||||
});
|
||||
|
||||
// 3. Hapus semua item lama (cascade akan menghapus realisasiItems juga)
|
||||
// TAPI kita sudah save realisasiItems di map atas
|
||||
await prisma.aPBDesItem.deleteMany({
|
||||
where: { apbdesId: id },
|
||||
});
|
||||
|
||||
// 3. Buat item baru dengan auto-calculate fields
|
||||
// 4. Buat item baru dengan preserve realisasiItems
|
||||
await prisma.aPBDesItem.createMany({
|
||||
data: body.items.map((item) => {
|
||||
data: await Promise.all(body.items.map(async (item) => {
|
||||
const anggaran = item.anggaran;
|
||||
const totalRealisasi = 0; // Reset karena items baru
|
||||
const selisih = anggaran - totalRealisasi; // Sisa anggaran (positif = belum digunakan)
|
||||
|
||||
// Check apakah item ini punya realisasiItems lama
|
||||
const existingItem = existingItemsMap.get(item.kode);
|
||||
const realisasiItemsData = existingItem?.realisasiItems || [];
|
||||
const totalRealisasi = realisasiItemsData.reduce((sum, r) => sum + r.jumlah, 0);
|
||||
const selisih = anggaran - totalRealisasi;
|
||||
const persentase = anggaran > 0 ? (totalRealisasi / anggaran) * 100 : 0;
|
||||
|
||||
return {
|
||||
@@ -63,16 +92,68 @@ export default async function apbdesUpdate(context: Context) {
|
||||
persentase,
|
||||
isActive: true,
|
||||
};
|
||||
}),
|
||||
})),
|
||||
});
|
||||
|
||||
// 4. Dapatkan semua item yang baru dibuat untuk mendapatkan ID-nya
|
||||
// 5. Dapatkan semua item yang baru dibuat untuk mendapatkan ID-nya
|
||||
const allItems = await prisma.aPBDesItem.findMany({
|
||||
where: { apbdesId: id },
|
||||
select: { id: true, kode: true },
|
||||
});
|
||||
|
||||
// 5. Update parentId untuk setiap item
|
||||
// 6. Build map baru untuk item IDs
|
||||
const newItemIdsMap = new Map<string, string>();
|
||||
allItems.forEach(item => {
|
||||
newItemIdsMap.set(item.kode, item.id);
|
||||
});
|
||||
|
||||
// 7. Re-create realisasiItems dengan link ke item IDs yang baru
|
||||
for (const [oldKode, oldItemData] of existingItemsMap.entries()) {
|
||||
if (oldItemData.realisasiItems.length > 0) {
|
||||
const newItemId = newItemIdsMap.get(oldKode);
|
||||
if (newItemId) {
|
||||
// Re-create realisasiItems untuk item ini
|
||||
await prisma.realisasiItem.createMany({
|
||||
data: oldItemData.realisasiItems.map(r => ({
|
||||
apbdesItemId: newItemId,
|
||||
kode: r.kode,
|
||||
jumlah: r.jumlah,
|
||||
tanggal: r.tanggal,
|
||||
keterangan: r.keterangan,
|
||||
buktiFileId: r.buktiFileId,
|
||||
isActive: true,
|
||||
})),
|
||||
});
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// 8. Recalculate totalRealisasi setelah re-create realisasiItems
|
||||
for (const kode of existingItemsMap.keys()) {
|
||||
const newItemId = newItemIdsMap.get(kode);
|
||||
if (newItemId) {
|
||||
const realisasiItems = await prisma.realisasiItem.findMany({
|
||||
where: { apbdesItemId: newItemId, isActive: true },
|
||||
});
|
||||
const totalRealisasi = realisasiItems.reduce((sum, r) => sum + r.jumlah, 0);
|
||||
|
||||
const item = await prisma.aPBDesItem.findUnique({
|
||||
where: { id: newItemId },
|
||||
});
|
||||
|
||||
if (item) {
|
||||
const selisih = item.anggaran - totalRealisasi;
|
||||
const persentase = item.anggaran > 0 ? (totalRealisasi / item.anggaran) * 100 : 0;
|
||||
|
||||
await prisma.aPBDesItem.update({
|
||||
where: { id: newItemId },
|
||||
data: { totalRealisasi, selisih, persentase },
|
||||
});
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// 9. Update parentId untuk setiap item
|
||||
const itemsForParentUpdate = allItems.map(item => ({
|
||||
id: item.id,
|
||||
kode: item.kode,
|
||||
@@ -80,7 +161,7 @@ export default async function apbdesUpdate(context: Context) {
|
||||
|
||||
await assignParentIdsToApbdesItems(itemsForParentUpdate);
|
||||
|
||||
// 6. Update data APBDes
|
||||
// 10. Update data APBDes
|
||||
await prisma.aPBDes.update({
|
||||
where: { id },
|
||||
data: {
|
||||
@@ -88,12 +169,12 @@ export default async function apbdesUpdate(context: Context) {
|
||||
name: body.name || `APBDes Tahun ${body.tahun}`,
|
||||
deskripsi: body.deskripsi,
|
||||
jumlah: body.jumlah,
|
||||
imageId: body.imageId,
|
||||
fileId: body.fileId,
|
||||
imageId: body.imageId === '' ? null : body.imageId,
|
||||
fileId: body.fileId === '' ? null : body.fileId,
|
||||
},
|
||||
});
|
||||
|
||||
// 7. Ambil data lengkap untuk response (include realisasiItems)
|
||||
// 11. Ambil data lengkap untuk response (include realisasiItems)
|
||||
const result = await prisma.aPBDes.findUnique({
|
||||
where: { id },
|
||||
include: {
|
||||
|
||||
Reference in New Issue
Block a user