+
{label}
+ {payload.map((entry, index: number) => (
+
+ {t("bookings")}: {entry.value}
+
+ ))}
+
+
{children}
{count !== undefined &&
{count}
}
diff --git a/packages/features/insights/components/LoadingInsights.tsx b/packages/features/insights/components/LoadingInsights.tsx
index 4d9605bf38d07a..0a937154104a11 100644
--- a/packages/features/insights/components/LoadingInsights.tsx
+++ b/packages/features/insights/components/LoadingInsights.tsx
@@ -1,5 +1,5 @@
-import { SkeletonText } from "@calcom/ui/components/skeleton";
import classNames from "@calcom/ui/classNames";
+import { SkeletonText } from "@calcom/ui/components/skeleton";
import { CardInsights } from "./Card";
diff --git a/packages/features/insights/components/TotalBookingUsersTable.tsx b/packages/features/insights/components/TotalBookingUsersTable.tsx
index 0f9d1f9db16151..eb740cfaace18c 100644
--- a/packages/features/insights/components/TotalBookingUsersTable.tsx
+++ b/packages/features/insights/components/TotalBookingUsersTable.tsx
@@ -21,8 +21,8 @@ export const TotalBookingUsersTable = ({
return (
{filteredData.length > 0 ? (
- filteredData.map((item) => (
-
+ filteredData.map((item, index) => (
+
{
+ const { scope, selectedTeamId, startDate, endDate, eventTypeId, memberUserId, timeZone } = input;
+
+ const insightsBookingService = new InsightsBookingService({
+ prisma: ctx.insightsDb,
+ options: {
+ scope,
+ userId: ctx.user.id,
+ orgId: ctx.user.organizationId ?? 0,
+ ...(selectedTeamId && { teamId: selectedTeamId }),
+ },
+ filters: {
+ ...(eventTypeId && { eventTypeId }),
+ ...(memberUserId && { memberUserId }),
+ },
+ });
+
+ try {
+ return await insightsBookingService.getBookingsByHourStats({
+ startDate,
+ endDate,
+ timeZone,
+ });
+ } catch (e) {
+ throw new TRPCError({ code: "INTERNAL_SERVER_ERROR" });
+ }
+ }),
});
async function getEventTypeList({
diff --git a/packages/lib/server/service/__tests__/insightsRouting.integration-test.ts b/packages/lib/server/service/__tests__/insightsRouting.integration-test.ts
index 13be9b42b8491b..db0d70294c188c 100644
--- a/packages/lib/server/service/__tests__/insightsRouting.integration-test.ts
+++ b/packages/lib/server/service/__tests__/insightsRouting.integration-test.ts
@@ -554,7 +554,7 @@ describe("InsightsRoutingService Integration Tests", () => {
const results = await service.getBaseConditions();
expect(results).toEqual(
- Prisma.sql`("formUserId" = ${testData.user.id} AND "formTeamId" IS NULL) AND (${dateCondition})`
+ Prisma.sql`(("formUserId" = ${testData.user.id} AND "formTeamId" IS NULL) AND (${dateCondition}))`
);
await testData.cleanup();
diff --git a/packages/lib/server/service/insightsBooking.ts b/packages/lib/server/service/insightsBooking.ts
index f0858f4142bfc7..5e841d20861005 100644
--- a/packages/lib/server/service/insightsBooking.ts
+++ b/packages/lib/server/service/insightsBooking.ts
@@ -65,16 +65,60 @@ export class InsightsBookingService {
this.filters = filters;
}
+ async getBookingsByHourStats({
+ startDate,
+ endDate,
+ timeZone,
+ }: {
+ startDate: string;
+ endDate: string;
+ timeZone: string;
+ }) {
+ // Validate date formats
+ if (isNaN(Date.parse(startDate)) || isNaN(Date.parse(endDate))) {
+ throw new Error(`Invalid date format: ${startDate} - ${endDate}`);
+ }
+
+ const baseConditions = await this.getBaseConditions();
+
+ const results = await this.prisma.$queryRaw<
+ Array<{
+ hour: string;
+ count: number;
+ }>
+ >`
+ SELECT
+ EXTRACT(HOUR FROM ("startTime" AT TIME ZONE 'UTC' AT TIME ZONE ${timeZone}))::int as "hour",
+ COUNT(*)::int as "count"
+ FROM "BookingTimeStatusDenormalized"
+ WHERE ${baseConditions}
+ AND "startTime" >= ${startDate}::timestamp
+ AND "startTime" <= ${endDate}::timestamp
+ AND "status" = 'accepted'
+ GROUP BY 1
+ ORDER BY 1
+ `;
+
+ // Create a map of results by hour for easy lookup
+ const resultsMap = new Map(results.map((row) => [Number(row.hour), row.count]));
+
+ // Return all 24 hours (0-23), filling with 0 values for missing data
+ return Array.from({ length: 24 }, (_, hour) => ({
+ hour,
+ count: resultsMap.get(hour) || 0,
+ }));
+ }
+
async getBaseConditions(): Promise {
const authConditions = await this.getAuthorizationConditions();
const filterConditions = await this.getFilterConditions();
if (authConditions && filterConditions) {
- return Prisma.sql`(${authConditions}) AND (${filterConditions})`;
+ return Prisma.sql`((${authConditions}) AND (${filterConditions}))`;
} else if (authConditions) {
- return authConditions;
+ return Prisma.sql`(${authConditions})`;
} else if (filterConditions) {
- return filterConditions;
+ return Prisma.sql`(${filterConditions})`;
} else {
return NOTHING_CONDITION;
}
diff --git a/packages/lib/server/service/insightsRouting.ts b/packages/lib/server/service/insightsRouting.ts
index 435df66bbae686..4ae1e299e1e92a 100644
--- a/packages/lib/server/service/insightsRouting.ts
+++ b/packages/lib/server/service/insightsRouting.ts
@@ -169,11 +169,11 @@ export class InsightsRoutingService {
const filterConditions = await this.getFilterConditions();
if (authConditions && filterConditions) {
- return Prisma.sql`(${authConditions}) AND (${filterConditions})`;
+ return Prisma.sql`((${authConditions}) AND (${filterConditions}))`;
} else if (authConditions) {
- return authConditions;
+ return Prisma.sql`(${authConditions})`;
} else if (filterConditions) {
- return filterConditions;
+ return Prisma.sql`(${filterConditions})`;
} else {
return NOTHING_CONDITION;
}