feat:Implement Stock Movement Ledger and UI refinements

app/api/portal/client/browse-meta/route.ts

@@ -53,8 +53,8 @@ export async function GET(request: NextRequest) {
       prisma.supplier.count({ where: { status: false } }),
       prisma.category.count({ where: { status: true } }),
       prisma.category.count({ where: { status: false } }),
-      prisma.warehouse.count({ where: { status: true } }),
-      prisma.warehouse.count({ where: { status: false } }),
+      prisma.warehouse.count({ where: { isActive: true } }),
+      prisma.warehouse.count({ where: { isActive: false } }),
     ]);
 
     const meta: ClientBrowseMeta = {

app/api/stock-movements/route.ts

@@ -0,0 +1,59 @@
+import { NextRequest, NextResponse } from "next/server";
+import { getSession } from "next-auth/react"; // Assuming next-auth is used
+import { StockMovementService } from "@/modules/stock-movement/api/stock-movement.service";
+import { StockMovementType } from "@prisma/client";
+
+/**
+ * Handle GET requests for stock movements.
+ */
+export async function GET(req: NextRequest) {
+  try {
+    const { searchParams } = new URL(req.url);
+    const productId = searchParams.get("productId") || undefined;
+    const warehouseId = searchParams.get("warehouseId") || undefined;
+    const movementType = searchParams.get("movementType") as StockMovementType | undefined;
+    const startDate = searchParams.get("startDate") ? new Date(searchParams.get("startDate")!) : undefined;
+    const endDate = searchParams.get("endDate") ? new Date(searchParams.get("endDate")!) : undefined;
+
+    const movements = await StockMovementService.getAllMovements({
+      productId,
+      warehouseId,
+      movementType,
+      startDate,
+      endDate,
+    });
+
+    return NextResponse.json(movements);
+  } catch (error: any) {
+    console.error("Error fetching stock movements:", error);
+    return NextResponse.json(
+      { error: error.message || "Internal Server Error" },
+      { status: 500 }
+    );
+  }
+}
+
+/**
+ * Handle POST requests for manual stock movements (e.g., Adjustments).
+ */
+export async function POST(req: NextRequest) {
+  try {
+    // In a real app, you'd get the user ID from the session
+    // const session = await getSession({ req });
+    const userId = "manual_admin"; // Placeholder
+
+    const body = await req.json();
+    const movement = await StockMovementService.createMovement({
+      ...body,
+      userId,
+    });
+
+    return NextResponse.json(movement, { status: 201 });
+  } catch (error: any) {
+    console.error("Error creating stock movement:", error);
+    return NextResponse.json(
+      { error: error.message || "Internal Server Error" },
+      { status: 500 }
+    );
+  }
+}

app/api/stocks/[id]/route.ts

@@ -0,0 +1,54 @@
+import { NextRequest, NextResponse } from "next/server";
+import { getSessionFromRequest } from "@/utils/auth";
+import { StockService } from "@/modules/stock/api/stock.service";
+
+/**
+ * PUT: Update stock quantity or reserved quantity by ID
+ */
+export async function PUT(
+  req: NextRequest,
+  { params }: { params: Promise<{ id: string }> }
+) {
+  let id: string | null = null;
+  try {
+    const user = await getSessionFromRequest(req);
+    if (!user) {
+      return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
+    }
+
+    id = (await params).id;
+    if (!id) {
+      return NextResponse.json(
+        { success: false, error: "Stock ID is required." },
+        { status: 400 }
+      );
+    }
+
+    const body = await req.json();
+    const { quantity, reservedQuantity } = body;
+
+    const dataToUpdate: any = {};
+    if (quantity !== undefined) {
+      dataToUpdate.quantity = parseInt(String(quantity), 10);
+    }
+    if (reservedQuantity !== undefined) {
+      dataToUpdate.reservedQuantity = parseInt(String(reservedQuantity), 10);
+    }
+
+    const updatedStock = await StockService.updateStock(id, dataToUpdate);
+
+    return NextResponse.json({ success: true, data: updatedStock });
+  } catch (error: any) {
+    console.error("Error updating stock:", error);
+    if (error.message?.includes("not found")) {
+      return NextResponse.json(
+        { success: false, error: "Stock record not found" },
+        { status: 404 }
+      );
+    }
+    return NextResponse.json(
+      { success: false, error: error.message || "Failed to update stock" },
+      { status: 500 }
+    );
+  }
+}

app/api/stocks/product/[productId]/route.ts

@@ -0,0 +1,36 @@
+import { NextRequest, NextResponse } from "next/server";
+import { getSessionFromRequest } from "@/utils/auth";
+import { StockService } from "@/modules/stock/api/stock.service";
+
+/**
+ * GET: Retrieve stock records for a specific product across all warehouses
+ */
+export async function GET(
+  req: NextRequest,
+  { params }: { params: Promise<{ productId: string }> }
+) {
+  let productId: string | null = null;
+  try {
+    const user = await getSessionFromRequest(req);
+    if (!user) {
+      return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
+    }
+
+    productId = (await params).productId;
+    if (!productId) {
+      return NextResponse.json(
+        { success: false, error: "Product ID is required." },
+        { status: 400 }
+      );
+    }
+
+    const stocks = await StockService.getStockByProduct(productId);
+    return NextResponse.json({ success: true, data: stocks });
+  } catch (error: any) {
+    console.error(`Error fetching stock for product ${productId || 'unknown'}:`, error);
+    return NextResponse.json(
+      { success: false, error: error.message || "Failed to fetch stock for product" },
+      { status: 500 }
+    );
+  }
+}