feat: Add Statistics module with controller and service for system statistics retrieval

Author: letnull19A

src/app.module.ts

@@ -17,6 +17,7 @@ import { QuestUpdateModule } from './quest-update/quest-update.module';
 import { OrganizationUpdateModule } from './organization-update/organization-update.module';
 import { AppController } from './app.controller';
 import { PrometheusModule } from './prometheus/prometheus.module';
+import { StatisticsModule } from './statistics/statistics.module';
 
 @Module({
   imports: [
@@ -41,6 +42,7 @@ import { PrometheusModule } from './prometheus/prometheus.module';
     QuestUpdateModule,
     OrganizationUpdateModule,
     PrometheusModule,
+    StatisticsModule,
   ],
   controllers: [AppController],
 })

src/statistics/statistics.controller.ts

@@ -0,0 +1,36 @@
+import { Controller, Get, Version } from '@nestjs/common';
+import { ApiTags, ApiOperation, ApiResponse } from '@nestjs/swagger';
+import { StatisticsService } from './statistics.service';
+import { UseGuards } from '@nestjs/common';
+import { JwtAuthGuard } from '../auth/guards/jwt-auth.guard';
+
+@ApiTags('Статистика')
+@Controller('statistics')
+export class StatisticsController {
+  constructor(private readonly statisticsService: StatisticsService) {}
+
+  @Get()
+  @UseGuards(JwtAuthGuard)
+  @ApiOperation({ summary: 'Получить статистику системы' })
+  @ApiResponse({
+    status: 200,
+    description: 'Статистика успешно получена',
+    schema: {
+      type: 'object',
+      properties: {
+        citiesCount: { type: 'number', description: 'Количество городов' },
+        regionsCount: { type: 'number', description: 'Количество регионов' },
+        usersCount: { type: 'number', description: 'Количество пользователей' },
+        organizationsCount: { type: 'number', description: 'Количество организаций' },
+        totalQuests: { type: 'number', description: 'Всего квестов' },
+        activeQuests: { type: 'number', description: 'Активные квесты' },
+        completedQuests: { type: 'number', description: 'Завершённые квесты' },
+      },
+    },
+  })
+  @ApiResponse({ status: 401, description: 'Не авторизован' })
+  async getStatistics() {
+    return this.statisticsService.getStatistics();
+  }
+}
+

src/statistics/statistics.module.ts

@@ -0,0 +1,13 @@
+import { Module } from '@nestjs/common';
+import { StatisticsController } from './statistics.controller';
+import { StatisticsService } from './statistics.service';
+import { DatabaseModule } from '../database/database.module';
+
+@Module({
+  imports: [DatabaseModule],
+  controllers: [StatisticsController],
+  providers: [StatisticsService],
+  exports: [StatisticsService],
+})
+export class StatisticsModule {}
+

src/statistics/statistics.service.ts

@@ -0,0 +1,116 @@
+import { Injectable, Inject } from '@nestjs/common';
+import { DATABASE_CONNECTION } from '../database/database.module';
+import { NodePgDatabase } from 'drizzle-orm/node-postgres';
+import { cities, regions, users, organizations, quests } from '../database/schema';
+import { eq, and, ne, count } from 'drizzle-orm';
+
+export interface StatisticsDto {
+  citiesCount: number;
+  regionsCount: number;
+  usersCount: number;
+  organizationsCount: number;
+  totalQuests: number;
+  activeQuests: number;
+  completedQuests: number;
+}
+
+@Injectable()
+export class StatisticsService {
+  private cache: StatisticsDto | null = null;
+  private cacheTime: number = 0;
+  private readonly CACHE_TTL = 60 * 1000; // 1 минута в миллисекундах
+
+  constructor(
+    @Inject(DATABASE_CONNECTION)
+    private db: NodePgDatabase,
+  ) {}
+
+  async getStatistics(): Promise<StatisticsDto> {
+    const now = Date.now();
+
+    // Проверяем кеш
+    if (this.cache && (now - this.cacheTime) < this.CACHE_TTL) {
+      return this.cache;
+    }
+
+    // Выполняем все запросы параллельно для оптимизации
+    const [
+      citiesResult,
+      regionsResult,
+      usersResult,
+      organizationsResult,
+      totalQuestsResult,
+      activeQuestsResult,
+      completedQuestsResult,
+    ] = await Promise.all([
+      // Количество городов (исключая удаленные)
+      this.db
+        .select({ count: count(cities.id) })
+        .from(cities)
+        .where(ne(cities.recordStatus, 'DELETED')),
+
+      // Количество регионов (исключая удаленные)
+      this.db
+        .select({ count: count(regions.id) })
+        .from(regions)
+        .where(ne(regions.recordStatus, 'DELETED')),
+
+      // Количество пользователей (исключая удаленные)
+      this.db
+        .select({ count: count(users.id) })
+        .from(users)
+        .where(ne(users.recordStatus, 'DELETED')),
+
+      // Количество организаций (исключая удаленные)
+      this.db
+        .select({ count: count(organizations.id) })
+        .from(organizations)
+        .where(ne(organizations.recordStatus, 'DELETED')),
+
+      // Всего квестов (исключая удаленные)
+      this.db
+        .select({ count: count(quests.id) })
+        .from(quests)
+        .where(ne(quests.recordStatus, 'DELETED')),
+
+      // Активные квесты (status = 'active', исключая удаленные)
+      this.db
+        .select({ count: count(quests.id) })
+        .from(quests)
+        .where(
+          and(
+            eq(quests.status, 'active'),
+            ne(quests.recordStatus, 'DELETED'),
+          ),
+        ),
+
+      // Завершённые квесты (status = 'completed', исключая удаленные)
+      this.db
+        .select({ count: count(quests.id) })
+        .from(quests)
+        .where(
+          and(
+            eq(quests.status, 'completed'),
+            ne(quests.recordStatus, 'DELETED'),
+          ),
+        ),
+    ]);
+
+    const statistics: StatisticsDto = {
+      citiesCount: citiesResult[0]?.count ?? 0,
+      regionsCount: regionsResult[0]?.count ?? 0,
+      usersCount: usersResult[0]?.count ?? 0,
+      organizationsCount: organizationsResult[0]?.count ?? 0,
+      totalQuests: totalQuestsResult[0]?.count ?? 0,
+      activeQuests: activeQuestsResult[0]?.count ?? 0,
+      completedQuests: completedQuestsResult[0]?.count ?? 0,
+    };
+
+    // Обновляем кеш
+    this.cache = statistics;
+    this.cacheTime = now;
+
+    return statistics;
+  }
+}
+