|
|
@@ -16,6 +16,7 @@ import {
|
|
|
alignDayStart,
|
|
|
alignHourStart,
|
|
|
} from './stats-reporting.time';
|
|
|
+import { toJsonSafe } from '../../common/json/bigint-json';
|
|
|
|
|
|
interface PaginatedResult<T> {
|
|
|
page: number;
|
|
|
@@ -75,7 +76,7 @@ export class StatsReportingService {
|
|
|
this.prisma.adsHourlyStats.count({ where }),
|
|
|
]);
|
|
|
|
|
|
- return { page, size, total, items };
|
|
|
+ return { page, size, total, items: toJsonSafe(items) };
|
|
|
}
|
|
|
|
|
|
async getAdsDaily(dto: AdsStatsQueryDto): Promise<any> {
|
|
|
@@ -109,7 +110,7 @@ export class StatsReportingService {
|
|
|
this.prisma.adsDailyStats.count({ where }),
|
|
|
]);
|
|
|
|
|
|
- return { page, size, total, items };
|
|
|
+ return { page, size, total, items: toJsonSafe(items) };
|
|
|
}
|
|
|
|
|
|
async getChannelHourlyUsers(dto: ChannelStatsQueryDto): Promise<any> {
|
|
|
@@ -143,7 +144,7 @@ export class StatsReportingService {
|
|
|
this.prisma.channelHourlyUserStats.count({ where }),
|
|
|
]);
|
|
|
|
|
|
- return { page, size, total, items };
|
|
|
+ return { page, size, total, items: toJsonSafe(items) };
|
|
|
}
|
|
|
|
|
|
async getChannelDailyUsers(dto: ChannelStatsQueryDto): Promise<any> {
|
|
|
@@ -177,7 +178,7 @@ export class StatsReportingService {
|
|
|
this.prisma.channelDailyUserStats.count({ where }),
|
|
|
]);
|
|
|
|
|
|
- return { page, size, total, items };
|
|
|
+ return { page, size, total, items: toJsonSafe(items) };
|
|
|
}
|
|
|
|
|
|
private normalizePagination({
|