feat: Add OrganizationUpdate module with CRUD operations and validation for organization updates

Author: letnull19A

src/app.module.ts

@@ -14,6 +14,7 @@ import { QuestModule } from './quest/quest.module';
 import { UploadModule } from './upload/upload.module';
 import { CategoryModule } from './category/category.module';
 import { QuestUpdateModule } from './quest-update/quest-update.module';
+import { OrganizationUpdateModule } from './organization-update/organization-update.module';
 import { AppController } from './app.controller';
 
 @Module({
@@ -37,6 +38,7 @@ import { AppController } from './app.controller';
     UploadModule,
     CategoryModule,
     QuestUpdateModule,
+    OrganizationUpdateModule,
   ],
   controllers: [AppController],
 })

src/database/schema.ts

@@ -192,6 +192,20 @@ export const questUpdates = pgTable('quest_updates', {
   updatedAt: timestamp('updated_at').defaultNow(),
 });
 
+// Обновления организаций
+export const organizationUpdates = pgTable('organization_updates', {
+  id: serial('id').primaryKey(),
+  organizationId: integer('organization_id')
+    .references(() => organizations.id)
+    .notNull(),
+  title: varchar('title', { length: 255 }).notNull(),
+  text: text('text').notNull(),
+  photos: jsonb('photos').$type<string[]>(),
+  recordStatus: varchar('record_status', { length: 20 }).default('CREATED').notNull(),
+  createdAt: timestamp('created_at').defaultNow(),
+  updatedAt: timestamp('updated_at').defaultNow(),
+});
+
 // Связующая таблица: выполнение квестов пользователями
 export const userQuests = pgTable('user_quests', {
   id: serial('id').primaryKey(),
@@ -257,6 +271,7 @@ export const organizationsRelations = relations(organizations, ({ one, many }) =
   }),
   owners: many(organizationOwners),
   helpTypes: many(organizationHelpTypes),
+  updates: many(organizationUpdates),
 }));
 
 export const organizationOwnersRelations = relations(organizationOwners, ({ one }) => ({
@@ -340,6 +355,13 @@ export const questUpdatesRelations = relations(questUpdates, ({ one }) => ({
   }),
 }));
 
+export const organizationUpdatesRelations = relations(organizationUpdates, ({ one }) => ({
+  organization: one(organizations, {
+    fields: [organizationUpdates.organizationId],
+    references: [organizations.id],
+  }),
+}));
+
 export const userQuestsRelations = relations(userQuests, ({ one }) => ({
   user: one(users, {
     fields: [userQuests.userId],

src/organization-update/dto/create-organization-update.dto.ts

@@ -0,0 +1,32 @@
+import { ApiProperty } from '@nestjs/swagger';
+import { z } from 'zod/v4';
+
+export const createOrganizationUpdateSchema = z.object({
+  organizationId: z.number().int().positive('ID организации должен быть положительным числом'),
+  title: z.string().min(1, 'Название обновления обязательно').max(255, 'Название не должно превышать 255 символов'),
+  text: z.string().min(1, 'Текст обновления обязателен'),
+  photos: z.array(z.string().url('Элемент должен быть валидным URL')).max(5, 'Максимум 5 фотографий').optional(),
+});
+
+export type CreateOrganizationUpdateDto = z.infer<typeof createOrganizationUpdateSchema>;
+
+export class CreateOrganizationUpdateDtoClass {
+  @ApiProperty({ description: 'ID организации', example: 1 })
+  organizationId: number;
+
+  @ApiProperty({ description: 'Название обновления', example: 'Новые проекты организации' })
+  title: string;
+
+  @ApiProperty({ description: 'Текст обновления', example: 'Запущен новый проект помощи бездомным' })
+  text: string;
+
+  @ApiProperty({ 
+    description: 'Фотографии обновления (максимум 5)', 
+    example: ['https://example.com/photo1.jpg', 'https://example.com/photo2.jpg'],
+    type: [String],
+    maxItems: 5,
+    required: false 
+  })
+  photos?: string[];
+}
+

src/organization-update/dto/update-organization-update.dto.ts

@@ -0,0 +1,32 @@
+import { ApiProperty } from '@nestjs/swagger';
+import { z } from 'zod/v4';
+
+export const updateOrganizationUpdateSchema = z.object({
+  organizationId: z.number().int().positive('ID организации должен быть положительным числом').optional(),
+  title: z.string().max(255, 'Название не должно превышать 255 символов').optional(),
+  text: z.string().optional(),
+  photos: z.array(z.string().url('Элемент должен быть валидным URL')).max(5, 'Максимум 5 фотографий').optional(),
+});
+
+export type UpdateOrganizationUpdateDto = z.infer<typeof updateOrganizationUpdateSchema>;
+
+export class UpdateOrganizationUpdateDtoClass {
+  @ApiProperty({ description: 'ID организации', example: 1, required: false })
+  organizationId?: number;
+
+  @ApiProperty({ description: 'Название обновления', example: 'Новые проекты организации', required: false })
+  title?: string;
+
+  @ApiProperty({ description: 'Текст обновления', example: 'Запущен новый проект помощи бездомным', required: false })
+  text?: string;
+
+  @ApiProperty({ 
+    description: 'Фотографии обновления (максимум 5)', 
+    example: ['https://example.com/photo1.jpg'],
+    type: [String],
+    maxItems: 5,
+    required: false 
+  })
+  photos?: string[];
+}
+

src/organization-update/organization-update.controller.ts

@@ -0,0 +1,92 @@
+import {
+  Controller,
+  Get,
+  Post,
+  Body,
+  Patch,
+  Param,
+  Delete,
+  Query,
+  ParseIntPipe,
+  UseGuards,
+} from '@nestjs/common';
+import { ApiTags, ApiOperation, ApiResponse, ApiQuery, ApiBody, ApiBearerAuth } from '@nestjs/swagger';
+import { JwtAuthGuard } from '../auth/guards/jwt-auth.guard';
+import { OrganizationUpdateService } from './organization-update.service';
+import { CreateOrganizationUpdateDto, createOrganizationUpdateSchema, CreateOrganizationUpdateDtoClass } from './dto/create-organization-update.dto';
+import { UpdateOrganizationUpdateDto, updateOrganizationUpdateSchema, UpdateOrganizationUpdateDtoClass } from './dto/update-organization-update.dto';
+import { ZodValidation } from '../common/decorators/zod-validation.decorator';
+
+@ApiTags('Обновления организаций')
+@Controller('organization-updates')
+export class OrganizationUpdateController {
+  constructor(private readonly organizationUpdateService: OrganizationUpdateService) {}
+
+  @Post()
+  @ZodValidation(createOrganizationUpdateSchema)
+  @ApiOperation({ summary: 'Создать обновление организации' })
+  @ApiBody({ type: CreateOrganizationUpdateDtoClass })
+  @ApiResponse({ status: 201, description: 'Обновление организации успешно создано', type: CreateOrganizationUpdateDtoClass })
+  @ApiResponse({ status: 400, description: 'Ошибка валидации' })
+  @ApiResponse({ status: 404, description: 'Организация не найдена' })
+  @ApiBearerAuth()
+  @UseGuards(JwtAuthGuard)
+  create(@Body() createOrganizationUpdateDto: CreateOrganizationUpdateDto) {
+    return this.organizationUpdateService.create(createOrganizationUpdateDto);
+  }
+
+  @Get()
+  @UseGuards(JwtAuthGuard)
+  @ApiBearerAuth()
+  @ApiOperation({ summary: 'Получить все обновления организаций' })
+  @ApiQuery({ 
+    name: 'organizationId', 
+    required: false, 
+    type: Number,
+    description: 'ID организации для фильтрации' 
+  })
+  @ApiResponse({ status: 200, description: 'Список обновлений организаций' })
+  @ApiResponse({ status: 401, description: 'Не авторизован' })
+  findAll(@Query('organizationId', new ParseIntPipe({ optional: true })) organizationId?: number) {
+    return this.organizationUpdateService.findAll(organizationId);
+  }
+
+  @Get(':id')
+  @UseGuards(JwtAuthGuard)
+  @ApiBearerAuth()
+  @ApiOperation({ summary: 'Получить обновление организации по ID' })
+  @ApiResponse({ status: 200, description: 'Обновление организации найдено' })
+  @ApiResponse({ status: 404, description: 'Обновление организации не найдено' })
+  @ApiResponse({ status: 401, description: 'Не авторизован' })
+  findOne(@Param('id', ParseIntPipe) id: number) {
+    return this.organizationUpdateService.findOne(id);
+  }
+
+  @Patch(':id')
+  @ApiBearerAuth()
+  @UseGuards(JwtAuthGuard)
+  @ZodValidation(updateOrganizationUpdateSchema)
+  @ApiOperation({ summary: 'Обновить обновление организации' })
+  @ApiBody({ type: UpdateOrganizationUpdateDtoClass })
+  @ApiResponse({ status: 200, description: 'Обновление организации обновлено', type: UpdateOrganizationUpdateDtoClass })
+  @ApiResponse({ status: 400, description: 'Ошибка валидации' })
+  @ApiResponse({ status: 404, description: 'Обновление организации или организация не найдены' })
+  update(
+    @Param('id', ParseIntPipe) id: number,
+    @Body() updateOrganizationUpdateDto: UpdateOrganizationUpdateDto,
+  ) {
+    return this.organizationUpdateService.update(id, updateOrganizationUpdateDto);
+  }
+
+  @Delete(':id')
+  @UseGuards(JwtAuthGuard)
+  @ApiBearerAuth()
+  @ApiOperation({ summary: 'Удалить обновление организации' })
+  @ApiResponse({ status: 200, description: 'Обновление организации удалено' })
+  @ApiResponse({ status: 404, description: 'Обновление организации не найдено' })
+  @ApiResponse({ status: 401, description: 'Не авторизован' })
+  remove(@Param('id', ParseIntPipe) id: number) {
+    return this.organizationUpdateService.remove(id);
+  }
+}
+

src/organization-update/organization-update.module.ts

@@ -0,0 +1,13 @@
+import { Module } from '@nestjs/common';
+import { OrganizationUpdateService } from './organization-update.service';
+import { OrganizationUpdateController } from './organization-update.controller';
+import { DatabaseModule } from '../database/database.module';
+
+@Module({
+  imports: [DatabaseModule],
+  controllers: [OrganizationUpdateController],
+  providers: [OrganizationUpdateService],
+  exports: [OrganizationUpdateService],
+})
+export class OrganizationUpdateModule {}
+

src/organization-update/organization-update.service.ts

@@ -0,0 +1,120 @@
+import { Injectable, Inject, NotFoundException, BadRequestException } from '@nestjs/common';
+import { DATABASE_CONNECTION } from '../database/database.module';
+import { NodePgDatabase } from 'drizzle-orm/node-postgres';
+import { organizationUpdates, organizations } from '../database/schema';
+import { eq, ne, and } from 'drizzle-orm';
+import { CreateOrganizationUpdateDto } from './dto/create-organization-update.dto';
+import { UpdateOrganizationUpdateDto } from './dto/update-organization-update.dto';
+
+@Injectable()
+export class OrganizationUpdateService {
+  constructor(
+    @Inject(DATABASE_CONNECTION)
+    private db: NodePgDatabase,
+  ) {}
+
+  async create(createOrganizationUpdateDto: CreateOrganizationUpdateDto) {
+    // Проверяем существование организации (исключая удаленные)
+    const [organization] = await this.db
+      .select()
+      .from(organizations)
+      .where(and(
+        eq(organizations.id, createOrganizationUpdateDto.organizationId),
+        ne(organizations.recordStatus, 'DELETED')
+      ));
+    if (!organization) {
+      throw new NotFoundException(`Организация с ID ${createOrganizationUpdateDto.organizationId} не найдена`);
+    }
+
+    // Валидация фотографий (максимум 5 элементов)
+    if (createOrganizationUpdateDto.photos && createOrganizationUpdateDto.photos.length > 5) {
+      throw new BadRequestException('Максимум 5 фотографий');
+    }
+
+    const [organizationUpdate] = await this.db
+      .insert(organizationUpdates)
+      .values({
+        organizationId: createOrganizationUpdateDto.organizationId,
+        title: createOrganizationUpdateDto.title,
+        text: createOrganizationUpdateDto.text,
+        photos: createOrganizationUpdateDto.photos || [],
+      })
+      .returning();
+    return organizationUpdate;
+  }
+
+  async findAll(organizationId?: number) {
+    const conditions = [ne(organizationUpdates.recordStatus, 'DELETED')];
+    if (organizationId) {
+      conditions.push(eq(organizationUpdates.organizationId, organizationId));
+    }
+    return this.db
+      .select()
+      .from(organizationUpdates)
+      .where(and(...conditions));
+  }
+
+  async findOne(id: number) {
+    const [organizationUpdate] = await this.db
+      .select()
+      .from(organizationUpdates)
+      .where(and(
+        eq(organizationUpdates.id, id),
+        ne(organizationUpdates.recordStatus, 'DELETED')
+      ));
+    if (!organizationUpdate) {
+      throw new NotFoundException(`Обновление организации с ID ${id} не найдено`);
+    }
+    return organizationUpdate;
+  }
+
+  async update(id: number, updateOrganizationUpdateDto: UpdateOrganizationUpdateDto) {
+    // Если обновляется organizationId, проверяем существование организации (исключая удаленные)
+    if (updateOrganizationUpdateDto.organizationId !== undefined) {
+      const [organization] = await this.db
+        .select()
+        .from(organizations)
+        .where(and(
+          eq(organizations.id, updateOrganizationUpdateDto.organizationId),
+          ne(organizations.recordStatus, 'DELETED')
+        ));
+      if (!organization) {
+        throw new NotFoundException(`Организация с ID ${updateOrganizationUpdateDto.organizationId} не найдена`);
+      }
+    }
+
+    // Валидация фотографий (максимум 5 элементов)
+    if (updateOrganizationUpdateDto.photos && updateOrganizationUpdateDto.photos.length > 5) {
+      throw new BadRequestException('Максимум 5 фотографий');
+    }
+
+    const [organizationUpdate] = await this.db
+      .update(organizationUpdates)
+      .set({ ...updateOrganizationUpdateDto, updatedAt: new Date() })
+      .where(and(
+        eq(organizationUpdates.id, id),
+        ne(organizationUpdates.recordStatus, 'DELETED')
+      ))
+      .returning();
+    if (!organizationUpdate) {
+      throw new NotFoundException(`Обновление организации с ID ${id} не найдено`);
+    }
+    return organizationUpdate;
+  }
+
+  async remove(id: number) {
+    const [organizationUpdate] = await this.db
+      .update(organizationUpdates)
+      .set({ recordStatus: 'DELETED', updatedAt: new Date() })
+      .where(and(
+        eq(organizationUpdates.id, id),
+        ne(organizationUpdates.recordStatus, 'DELETED')
+      ))
+      .returning();
+    if (!organizationUpdate) {
+      throw new NotFoundException(`Обновление организации с ID ${id} не найдено`);
+    }
+    return organizationUpdate;
+  }
+}
+