62 impl post apis for organization team submodules

packages/api/src/feature/_example/controller/example.controller.ts

@@ -0,0 +1,8 @@
+import { Controller } from "@nestjs/common";
+
+import { ExampleService } from "../service/example.service";
+
+@Controller()
+export class ExampleController {
+  constructor(private readonly exampleService: ExampleService) {}
+}

packages/api/src/feature/_example/example.module.ts

@@ -0,0 +1,14 @@
+import { Module } from "@nestjs/common";
+
+import { DrizzleModule } from "src/drizzle/drizzle.module";
+import { ExampleService } from "./service/example.service";
+import { ExampleController } from "./controller/example.controller";
+import { ExampleRepository } from "./repository/example.repository";
+
+@Module({
+  imports: [DrizzleModule],
+  controllers: [ExampleController],
+  providers: [ExampleService, ExampleRepository],
+  exports: [],
+})
+export class ExampleModule {}

packages/api/src/feature/_example/repository/example.repository.ts

@@ -0,0 +1,11 @@
+import { Injectable, Inject } from "@nestjs/common";
+
+import { MySql2Database } from "drizzle-orm/mysql2";
+import { DrizzleAsyncProvider } from "src/drizzle/drizzle.provider";
+
+@Injectable()
+export class ExampleRepository {
+  constructor(
+    @Inject(DrizzleAsyncProvider) private readonly db: MySql2Database,
+  ) {}
+}

packages/api/src/feature/_example/service/example.service.ts

@@ -0,0 +1,7 @@
+import { Injectable } from "@nestjs/common";
+import { ExampleRepository } from "../repository/example.repository";
+
+@Injectable()
+export class ExampleService {
+  constructor(private readonly exampleRepository: ExampleRepository) {}
+}

packages/api/src/feature/organization/organization.module.ts

@@ -1,4 +1,4 @@
-import { Module } from "@nestjs/common";
+import { Module, forwardRef } from "@nestjs/common";
 
 import { DrizzleModule } from "src/drizzle/drizzle.module";
 import { SemesterModule } from "src/feature/semester/semester.module";
@@ -7,9 +7,17 @@ import { OrganizationService } from "./service/organization.service";
 import { OrganizationController } from "./controller/organization.controller";
 import { OrganizationPublicService } from "./service/organization.public.service";
 import { OrganizationRepository } from "./repository/organization.repository";
+/* eslint-disable import/no-cycle */
+import { TeamModule } from "./team/team.module";
+/* eslint-disable import/no-cycle */
 
 @Module({
-  imports: [DrizzleModule, SemesterModule, UserModule],
+  imports: [
+    DrizzleModule,
+    SemesterModule,
+    UserModule,
+    forwardRef(() => TeamModule),
+  ],
   controllers: [OrganizationController],
   providers: [
     OrganizationService,

packages/api/src/feature/organization/repository/organization.repository.ts

@@ -1,5 +1,4 @@
 import { Injectable, Inject } from "@nestjs/common";
-import logger from "@sparcs-students/api/common/util/logger";
 
 import {
   ApiOrg002RequestBody,
@@ -23,8 +22,6 @@ import {
   OrganizationPresidentT,
   UserT,
   UserStudentT,
-  TeamT,
-  Team,
   OrganizationMember,
   OrganizationManager,
   OrganizationMemberT,
@@ -122,11 +119,6 @@ export class OrganizationRepository {
     }));
   }
 
-  async getTeamById(id: number): Promise<TeamT[]> {
-    const res = await this.db.select().from(Team).where(eq(Team.id, id));
-    return res;
-  }
-
   async ckOrganizationBeforeCreate(
     body: ApiOrg002RequestBody,
   ): Promise<number> {
@@ -274,7 +266,6 @@ export class OrganizationRepository {
       )
       .orderBy(desc(OrganizationMember.createdAt))
       .limit(1);
-    logger.info(res);
     if (res.length === 0) {
       return 0;
     }
@@ -347,4 +338,51 @@ export class OrganizationRepository {
     const res = await this.ckOrganizationManagerBeforeCreate(body);
     return res;
   }
+
+  async selectOrganizationMember(target: Partial<OrganizationMemberT>) {
+    const { id, userId, startTerm, endTerm, organizationId } = target;
+    let query = this.db.select().from(OrganizationMember).$dynamic();
+
+    const whereConditions = [];
+
+    if (id) {
+      whereConditions.push(eq(OrganizationMember.id, id));
+    }
+
+    if (userId) {
+      whereConditions.push(eq(OrganizationMember.userId, userId));
+    }
+
+    if (startTerm) {
+      whereConditions.push(
+        or(
+          gte(OrganizationMember.endTerm, startTerm),
+          isNull(OrganizationMember.endTerm),
+        ),
+      );
+    }
+
+    if (endTerm) {
+      whereConditions.push(lte(OrganizationMember.startTerm, endTerm));
+    }
+
+    if (organizationId) {
+      whereConditions.push(
+        eq(OrganizationMember.organizationId, organizationId),
+      );
+    }
+
+    // 삭제된 항목 제외
+    whereConditions.push(isNull(OrganizationMember.deletedAt));
+
+    // 조건이 하나라도 있으면 AND로 묶어서 처리
+    if (whereConditions.length > 0) {
+      query = query.where(and(...whereConditions));
+    }
+
+    // 쿼리 실행
+    const res = await query.execute();
+
+    return res;
+  }
 }

packages/api/src/feature/organization/service/organization.public.service.ts

@@ -4,7 +4,7 @@ import {
   Injectable,
   NotFoundException,
 } from "@nestjs/common";
-import { OrganizationT, TeamT } from "src/drizzle/schema";
+import { OrganizationMemberT, OrganizationT } from "src/drizzle/schema";
 import { SemesterPublicService } from "src/feature/semester/semester.public.service";
 
 import {
@@ -79,20 +79,52 @@ export class OrganizationPublicService {
   }
 
   /**
-   * @param teamId
-   * @returns TeamT id에 해당하는 TeamT 객체를 리턴합니다.
-   * @description 해당 id의 Team이 없으면 404 exception을 throw 합니다.
+   * @param userId, organizationId, startTerm, endTerm
+   * @returns TeamMemeberT 해당 학기 해당 단체에 해당하는 TeamMemberT 객체를 리턴합니다.
+   * @description 해당 시기에 해당하는 OrganizationMember가 없으면 404 exception을 throw 합니다.
    */
-  async getTeamById(teamId: number): Promise<TeamT> {
-    const res = await this.organizationRepository.getTeamById(teamId);
+  async getOrganizationMemberByUserAndOrgAndDate(
+    userId: number,
+    organizationId: number,
+    startTerm: Date,
+    endTerm: Date,
+  ): Promise<OrganizationMemberT> {
+    const res = await this.organizationRepository.selectOrganizationMember({
+      userId,
+      startTerm,
+      endTerm,
+      organizationId,
+    });
     if (res.length === 0) {
-      throw new NotFoundException(`Team with ID ${teamId} not found.`);
+      throw new NotFoundException(
+        `OrganizationMember with userId ${userId} not found.`,
+      );
     } else if (res.length > 1) {
       throw new HttpException(
-        `Unreachable: Team with ID ${teamId} has multiple records.`,
+        `Unreachable: OrganizationMember with userId ${userId} has multiple records.`,
         HttpStatus.INTERNAL_SERVER_ERROR,
       );
     }
     return res[0];
   }
+
+  /**
+   * @param userId, organizationId, semesterId
+   * @returns TeamMemeberT 해당 학기 해당 단체에 해당하는 TeamMemberT 객체를 리턴합니다.
+   * @description 해당 시기에 해당하는 OrganizationMember가 없으면 404 exception을 throw 합니다.
+   */
+  async getOrganizationMemberByUserAndOrgAndSemester(
+    userId: number,
+    semesterId: number,
+    organizationId: number,
+  ): Promise<OrganizationMemberT> {
+    const { startTerm, endTerm } =
+      await this.semesterPublicService.getSemesterById(semesterId);
+    return this.getOrganizationMemberByUserAndOrgAndDate(
+      userId,
+      organizationId,
+      startTerm,
+      endTerm,
+    );
+  }
 }

packages/api/src/feature/organization/team/controller/team.controller.ts

@@ -0,0 +1,47 @@
+import { Body, Controller, Post, UsePipes } from "@nestjs/common";
+import {
+  ApiOrg007RequestBody,
+  ApiOrg007RequestUrl,
+  ApiOrg007ResponseCreated,
+  ApiOrg008RequestBody,
+  ApiOrg008RequestUrl,
+  ApiOrg008ResponseCreated,
+  ApiOrg009RequestBody,
+  ApiOrg009RequestUrl,
+  ApiOrg009ResponseCreated,
+  apiOrg007,
+  apiOrg008,
+  apiOrg009,
+} from "@sparcs-students/interface/api/organization/index";
+import { ZodPipe } from "@sparcs-students/api/common/pipes/zod-pipe";
+
+import { TeamService } from "../service/team.service";
+
+@Controller()
+export class TeamController {
+  constructor(private readonly teamService: TeamService) {}
+
+  @Post(ApiOrg007RequestUrl)
+  @UsePipes(new ZodPipe(apiOrg007))
+  async postTeam(
+    @Body() body: ApiOrg007RequestBody,
+  ): Promise<ApiOrg007ResponseCreated> {
+    return this.teamService.postTeam(body);
+  }
+
+  @Post(ApiOrg008RequestUrl)
+  @UsePipes(new ZodPipe(apiOrg008))
+  async postTeamMember(
+    @Body() body: ApiOrg008RequestBody,
+  ): Promise<ApiOrg008ResponseCreated> {
+    return this.teamService.postTeamMember(body);
+  }
+
+  @Post(ApiOrg009RequestUrl)
+  @UsePipes(new ZodPipe(apiOrg009))
+  async postTeamLeader(
+    @Body() body: ApiOrg009RequestBody,
+  ): Promise<ApiOrg009ResponseCreated> {
+    return this.teamService.postTeamLeader(body);
+  }
+}