Marco/infoalloggi-monorepo
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 6 Wiki Activity Actions

refactor: comment out unused timeserie queries in stats router

Browse source
This commit is contained in:
Marco Pedone 2026-02-26 12:26:56 +01:00
parent 068f4b0c01
commit 9782cde917
1 changed files with 68 additions and 74 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

142
apps/infoalloggi/src/server/api/routers/stats.ts
View file

@ -1,81 +1,78 @@
import { sql } from "kysely";
import type { StackedTimeserie } from "~/components/timeserieBarChartStacked";
import TipologiaPosizioneEnum from "~/schemas/public/TipologiaPosizioneEnum";
import { adminProcedure, createTRPCRouter } from "~/server/api/trpc";
import { db } from "~/server/db";
export const statsRouter = createTRPCRouter({
adminDashStats: adminProcedure.query(async () => {
const userTimeserie = (
await db
.selectFrom("users")
.select((eb) => [
sql<Date>`date_trunc('day', created_at)`.as("date"),
eb.fn.count<number>("id").as("value"),
])
.where("isAdmin", "=", false)
.groupBy("date")
.orderBy("date")
.execute()
).map((item) => ({
date: item.date,
value: parseInt(String(item.value)),
}));
// const userTimeserie = (
// await db
// .selectFrom("users")
// .select((eb) => [
// sql<Date>`date_trunc('day', created_at)`.as("date"),
// eb.fn.count<number>("id").as("value"),
// ])
// .where("isAdmin", "=", false)
// .groupBy("date")
// .orderBy("date")
// .execute()
// ).map((item) => ({
// date: item.date,
// value: parseInt(String(item.value)),
// }));
const serviziTimeserie = {
data: Object.values(
(
await db
.selectFrom("servizio")
.select((eb) => [
sql<Date>`date_trunc('day', created_at)`.as("date"),
eb.fn.count<number>("servizio_id").as("value"),
"tipologia",
])
.groupBy(["date", "tipologia"])
.orderBy("date")
.execute()
).reduce(
(acc, item) => {
const dateStr = item.date.toISOString().slice(0, 10);
if (!acc[dateStr]) {
acc[dateStr] = {
date: item.date,
valueA: 0,
valueB: 0,
};
}
if (item.tipologia === TipologiaPosizioneEnum.Transitorio) {
acc[dateStr].valueA = parseInt(String(item.value));
} else if (item.tipologia === TipologiaPosizioneEnum.Stabile) {
acc[dateStr].valueB = parseInt(String(item.value));
}
return acc;
},
{} as Record<string, StackedTimeserie>,
),
),
valueALabel: "Transitorio",
valueBLabel: "Stabile",
};
// const serviziTimeserie = {
// data: Object.values(
// (
// await db
// .selectFrom("servizio")
// .select((eb) => [
// sql<Date>`date_trunc('day', created_at)`.as("date"),
// eb.fn.count<number>("servizio_id").as("value"),
// "tipologia",
// ])
// .groupBy(["date", "tipologia"])
// .orderBy("date")
// .execute()
// ).reduce(
// (acc, item) => {
// const dateStr = item.date.toISOString().slice(0, 10);
// if (!acc[dateStr]) {
// acc[dateStr] = {
// date: item.date,
// valueA: 0,
// valueB: 0,
// };
// }
// if (item.tipologia === TipologiaPosizioneEnum.Transitorio) {
// acc[dateStr].valueA = parseInt(String(item.value));
// } else if (item.tipologia === TipologiaPosizioneEnum.Stabile) {
// acc[dateStr].valueB = parseInt(String(item.value));
// }
// return acc;
// },
// {} as Record<string, StackedTimeserie>,
// ),
// ),
// valueALabel: "Transitorio",
// valueBLabel: "Stabile",
// };
const contattiTimeserie = (
await db
.selectFrom("servizio_annunci")
.select((eb) => [
sql<Date>`date_trunc('day', created_at)`.as("date"),
eb.fn
.count<number>(eb.fn("concat", ["servizio_id", "annunci_id"]))
.as("value"),
])
.where("open_contatti_at", "is not", null)
.groupBy("date")
.orderBy("date")
.execute()
).map((item) => ({
date: item.date,
value: parseInt(String(item.value)),
}));
// const contattiTimeserie = (
// await db
// .selectFrom("servizio_annunci")
// .select((eb) => [
// sql<Date>`date_trunc('day', created_at)`.as("date"),
// eb.fn
// .count<number>(eb.fn("concat", ["servizio_id", "annunci_id"]))
// .as("value"),
// ])
// .where("open_contatti_at", "is not", null)
// .groupBy("date")
// .orderBy("date")
// .execute()
// ).map((item) => ({
// date: item.date,
// value: parseInt(String(item.value)),
// }));
const userCount =
(
@ -86,10 +83,7 @@ export const statsRouter = createTRPCRouter({
)?.count || 0;
return {
contattiTimeserie,
serviziTimeserie,
userCount,
userTimeserie,
};
}),
});