feat(stats): seller stat api completed

2026-04-29 20:18:49 +06:00
parent 86b2292272
commit 7d89f3f4ea
7 changed files with 424 additions and 0 deletions
@@ -0,0 +1,151 @@
+// import { Request } from "express";
+// import { prisma } from "../../lib/prisma";
+
+import { prisma } from "../../lib/prisma";
+
+type Range = "7d" | "30d" | "all";
+
+const get_seller_stats_fromDb = async (shopAccountId: string, range: Range) => {
+  let createdAtFilter: any = {};
+
+  if (range !== "all") {
+    const days = range === "7d" ? 7 : 30;
+    const from = new Date();
+    from.setDate(from.getDate() - days);
+
+    createdAtFilter = { gte: from };
+  }
+
+  const baseWhere: any = {
+    shopAccountId,
+    ...(range !== "all" && { createdAt: createdAtFilter }),
+  };
+
+  const [
+    totalOrders,
+    completedOrders,
+    pendingOrders,
+    rejectedOrders,
+    revenueResult,
+    last7DaysRejected,
+    ordersForChart,
+  ] = await Promise.all([
+    prisma.order.count({ where: baseWhere }),
+
+    prisma.order.count({
+      where: { ...baseWhere, status: "DELIVERED" },
+    }),
+
+    prisma.order.count({
+      where: {
+        ...baseWhere,
+        status: { in: ["INITIATED", "CONFIRMED", "ONGOING"] },
+      },
+    }),
+
+    prisma.order.count({
+      where: { ...baseWhere, status: "CANCELLED" },
+    }),
+
+    prisma.order.aggregate({
+      where: { ...baseWhere, status: "DELIVERED" },
+      _sum: { productPrice: true },
+    }),
+
+    prisma.order.count({
+      where: {
+        shopAccountId,
+        status: "CANCELLED",
+        createdAt: {
+          gte: new Date(Date.now() - 7 * 24 * 60 * 60 * 1000),
+        },
+      },
+    }),
+
+    range !== "all"
+      ? prisma.order.findMany({
+          where: {
+            shopAccountId,
+            status: "DELIVERED",
+            createdAt: createdAtFilter,
+          },
+          select: {
+            productPrice: true,
+            createdAt: true,
+          },
+        })
+      : Promise.resolve([]),
+  ]);
+
+  const totalRevenue = revenueResult._sum.productPrice || 0;
+
+  const avgOrderValue =
+    completedOrders > 0 ? totalRevenue / completedOrders : 0;
+
+  const dailyMap: Record<string, number> = {};
+
+  for (const o of ordersForChart) {
+    const date = o.createdAt.toISOString().split("T")[0];
+    if (!dailyMap[date]) dailyMap[date] = 0;
+    dailyMap[date] += o.productPrice;
+  }
+
+  const dailyRevenue = Object.entries(dailyMap).map(([date, revenue]) => ({
+    date,
+    revenue,
+  }));
+
+  return {
+    totalOrders,
+    completedOrders,
+    pendingOrders,
+    rejectedOrders,
+    totalRevenue,
+    avgOrderValue,
+    last7DaysRejected,
+    dailyRevenue,
+  };
+};
+
+// const get_all_statictics_from_db = async (req: Request) => {
+//   // define your own login here
+//   const result = await prisma.statictics.findMany();
+//   return result;
+// };
+
+// const get_single_statictics_from_db = async (req: Request) => {
+//   // define your own login here
+//   const { id } = req.params;
+//   const result = await prisma.statictics.findUnique({where:{id}});
+//   return result;
+// };
+
+// const create_statictics_into_db = async (req: Request) => {
+//   // define your own login here
+//   const result = await prisma.statictics.create({data:req.body});
+//   return result;
+// };
+
+// const update_statictics_into_db = async (req: Request) => {
+//   // define your own login here
+//   const { id } = req.params;
+//   const result = await prisma.statictics.update({where:{id},data:req.body});
+//   return result;
+// };
+
+// const delete_statictics_from_db = async (req: Request) => {
+//   // define your own login here
+//   const { id } = req.params;
+//   const result = await prisma.statictics.delete({where:{id}});
+//   return result;
+// };
+
+export const statictics_service = {
+  get_seller_stats_fromDb,
+
+  // get_all_statictics_from_db,
+  // get_single_statictics_from_db,
+  // create_statictics_into_db,
+  // update_statictics_into_db,
+  // delete_statictics_from_db,
+};