hrms-api-development/src/controllers/DevelopmentController.ts

import {
  Controller,
  Get,
  Post,
  Put,
  Delete,
  Route,
  Security,
  Tags,
  Body,
  Path,
  Request,
  Query,
  Example,
} from "tsoa";
import { AppDataSource } from "../database/data-source";
import { Not } from "typeorm";
import HttpSuccess from "../interfaces/http-success";
import HttpError from "../interfaces/http-error";
import HttpStatusCode from "../interfaces/http-status";
import { Development, CreateDevelopment, UpdateDevelopment } from "../entities/Development";
import { ActualPeople } from "../entities/ActualPeople";
import { PlannedPeople } from "../entities/PlannedPeople";
import { ActualGoal } from "../entities/ActualGoal";
import { PlannedGoal } from "../entities/PlannedGoal";
import { Province } from "../entities/Province";
import { PosType } from "../entities/PosType";
import { PosLevel } from "../entities/PosLevel";

@Route("api/v1/development/main")
@Tags("Development")
@Security("bearerAuth")
export class DevelopmentController extends Controller {
  private developmentRepository = AppDataSource.getRepository(Development);
  private actualPeopleRepository = AppDataSource.getRepository(ActualPeople);
  private plannedPeopleRepository = AppDataSource.getRepository(PlannedPeople);
  private actualGoalRepository = AppDataSource.getRepository(ActualGoal);
  private plannedGoalRepository = AppDataSource.getRepository(PlannedGoal);
  private provinceRepository = AppDataSource.getRepository(Province);
  private posTypeRepository = AppDataSource.getRepository(PosType);
  private posLevelRepository = AppDataSource.getRepository(PosLevel);

  /**
   * API เพิ่มโครงการ/หลักสูตรการฝึกอบรม
   *
   * @summary DEV_001 - เพิ่มโครงการ/หลักสูตรการฝึกอบรม#1
   *
   */
  @Post()
  async CreateDevelopment(
    @Body() requestBody: CreateDevelopment,
    @Request() request: { user: Record<string, any> },
  ) {
    const chk_name = await this.developmentRepository.find({
      where: {
        projectName: requestBody.projectName,
        year: requestBody.year,
      },
    });
    if (chk_name.length > 0) {
      throw new HttpError(
        HttpStatusCode.NOT_FOUND,
        "โครงการ/หลักสูตรการฝึกอบรม: " +
          requestBody.projectName +
          " ปีงบประมาณ: " +
          (requestBody.year + 543) +
          " มีอยู่ในระบบแล้ว",
      );
    }

    if (requestBody.provinceId != null) {
      const checkId = await this.provinceRepository.findOne({
        where: { id: requestBody.provinceId },
      });
      if (!checkId) {
        throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลจังหวัดสถานที่ดำเนินการ");
      }
    }
    if (requestBody.provinceActualId != null) {
      const checkId = await this.provinceRepository.findOne({
        where: { id: requestBody.provinceActualId },
      });
      if (!checkId) {
        throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลจังหวัดข้อมูลด้านวิชาการ");
      }
    }

    const development = Object.assign(new Development(), requestBody);

    development.createdUserId = request.user.sub;
    development.createdFullName = request.user.name;
    development.lastUpdateUserId = request.user.sub;
    development.lastUpdateFullName = request.user.name;
    await this.developmentRepository.save(development);
    await Promise.all(
      requestBody.actualPeoples.map(async (x) => {
        const data = Object.assign(new ActualPeople(), x);
        data.createdUserId = request.user.sub;
        data.createdFullName = request.user.name;
        data.lastUpdateUserId = request.user.sub;
        data.lastUpdateFullName = request.user.name;
        data.developmentActualPeopleId = development.id;
        await this.actualPeopleRepository.save(data);
      }),
    );
    await Promise.all(
      requestBody.plannedPeoples.map(async (x) => {
        const data = Object.assign(new PlannedPeople(), x);
        data.createdUserId = request.user.sub;
        data.createdFullName = request.user.name;
        data.lastUpdateUserId = request.user.sub;
        data.lastUpdateFullName = request.user.name;
        data.developmentPlannedPeopleId = development.id;
        await this.plannedPeopleRepository.save(data);
      }),
    );
    await Promise.all(
      requestBody.actualGoals.map(async (x) => {
        if (x.posTypeActualId != null) {
          const checkId = await this.posTypeRepository.findOne({
            where: { id: x.posTypeActualId },
          });
          if (!checkId) {
            throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลประเภทตำแหน่ง");
          }
        }
        if (x.posLevelActualId != null) {
          const checkId = await this.posLevelRepository.findOne({
            where: { id: x.posLevelActualId },
          });
          if (!checkId) {
            throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลระดับตำแหน่ง");
          }
        }
        const data = Object.assign(new ActualGoal(), x);
        data.createdUserId = request.user.sub;
        data.createdFullName = request.user.name;
        data.lastUpdateUserId = request.user.sub;
        data.lastUpdateFullName = request.user.name;
        data.developmentActualGoalId = development.id;
        await this.actualGoalRepository.save(data);
      }),
    );
    await Promise.all(
      requestBody.plannedGoals.map(async (x) => {
        if (x.posTypePlannedId != null) {
          const checkId = await this.posTypeRepository.findOne({
            where: { id: x.posTypePlannedId },
          });
          if (!checkId) {
            throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลประเภทตำแหน่ง");
          }
        }
        if (x.posLevelPlannedId != null) {
          const checkId = await this.posLevelRepository.findOne({
            where: { id: x.posLevelPlannedId },
          });
          if (!checkId) {
            throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลระดับตำแหน่ง");
          }
        }
        const data = Object.assign(new PlannedGoal(), x);
        data.createdUserId = request.user.sub;
        data.createdFullName = request.user.name;
        data.lastUpdateUserId = request.user.sub;
        data.lastUpdateFullName = request.user.name;
        data.developmentPlannedGoalId = development.id;
        await this.plannedGoalRepository.save(data);
      }),
    );
    return new HttpSuccess(development.id);
  }

  /**
   * API แก้ไขโครงการ/หลักสูตรการฝึกอบรม
   *
   * @summary DEV_002 - แก้ไขโครงการ/หลักสูตรการฝึกอบรม #2
   *
   * @param {string} id  Id โครงการ
   */
  @Put("{id}")
  async UpdateDevelopment(
    @Path() id: string,
    @Body() requestBody: UpdateDevelopment,
    @Request() request: { user: Record<string, any> },
  ) {
    const development = await this.developmentRepository.findOne({
      where: { id },
      relations: {
        developmentActualPeoples: true,
        developmentPlannedPeoples: true,
        developmentActualGoals: true,
        developmentPlannedGoals: true,
      },
    });
    if (!development) {
      throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลโครงการ/หลักสูตรการฝึกอบรมนี้");
    }
    if (requestBody.provinceId != null) {
      const checkId = await this.provinceRepository.findOne({
        where: { id: requestBody.provinceId },
      });
      if (!checkId) {
        throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลจังหวัดสถานที่ดำเนินการ");
      }
    }
    if (requestBody.provinceActualId != null) {
      const checkId = await this.provinceRepository.findOne({
        where: { id: requestBody.provinceActualId },
      });
      if (!checkId) {
        throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลจังหวัดข้อมูลด้านวิชาการ");
      }
    }
    const chk_name = await this.developmentRepository.find({
      where: {
        projectName: requestBody.projectName,
        year: requestBody.year,
        id: Not(id),
      },
    });
    if (chk_name.length > 0) {
      throw new HttpError(
        HttpStatusCode.NOT_FOUND,
        "โครงการ/หลักสูตรการฝึกอบรม: " +
          requestBody.projectName +
          " ปีงบประมาณ: " +
          (requestBody.year + 543) +
          " มีอยู่ในระบบแล้ว",
      );
    }
    Object.assign(development, requestBody);
    development.lastUpdateUserId = request.user.sub;
    development.lastUpdateFullName = request.user.name;
    await this.developmentRepository.save(development);
    await this.actualPeopleRepository.remove(development.developmentActualPeoples);
    await this.plannedPeopleRepository.remove(development.developmentPlannedPeoples);
    await this.actualGoalRepository.remove(development.developmentActualGoals);
    await this.plannedGoalRepository.remove(development.developmentPlannedGoals);
    await Promise.all(
      requestBody.actualPeoples.map(async (x) => {
        const data = Object.assign(new ActualPeople(), x);
        data.createdUserId = request.user.sub;
        data.createdFullName = request.user.name;
        data.lastUpdateUserId = request.user.sub;
        data.lastUpdateFullName = request.user.name;
        data.developmentActualPeopleId = development.id;
        await this.actualPeopleRepository.save(data);
      }),
    );
    await Promise.all(
      requestBody.plannedPeoples.map(async (x) => {
        const data = Object.assign(new PlannedPeople(), x);
        data.createdUserId = request.user.sub;
        data.createdFullName = request.user.name;
        data.lastUpdateUserId = request.user.sub;
        data.lastUpdateFullName = request.user.name;
        data.developmentPlannedPeopleId = development.id;
        await this.plannedPeopleRepository.save(data);
      }),
    );
    await Promise.all(
      requestBody.actualGoals.map(async (x) => {
        if (x.posTypeActualId != null) {
          const checkId = await this.posTypeRepository.findOne({
            where: { id: x.posTypeActualId },
          });
          if (!checkId) {
            throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลประเภทตำแหน่ง");
          }
        }
        if (x.posLevelActualId != null) {
          const checkId = await this.posLevelRepository.findOne({
            where: { id: x.posLevelActualId },
          });
          if (!checkId) {
            throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลระดับตำแหน่ง");
          }
        }
        const data = Object.assign(new ActualGoal(), x);
        data.createdUserId = request.user.sub;
        data.createdFullName = request.user.name;
        data.lastUpdateUserId = request.user.sub;
        data.lastUpdateFullName = request.user.name;
        data.developmentActualGoalId = development.id;
        await this.actualGoalRepository.save(data);
      }),
    );
    await Promise.all(
      requestBody.plannedGoals.map(async (x) => {
        if (x.posTypePlannedId != null) {
          const checkId = await this.posTypeRepository.findOne({
            where: { id: x.posTypePlannedId },
          });
          if (!checkId) {
            throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลประเภทตำแหน่ง");
          }
        }
        if (x.posLevelPlannedId != null) {
          const checkId = await this.posLevelRepository.findOne({
            where: { id: x.posLevelPlannedId },
          });
          if (!checkId) {
            throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลระดับตำแหน่ง");
          }
        }
        const data = Object.assign(new PlannedGoal(), x);
        data.createdUserId = request.user.sub;
        data.createdFullName = request.user.name;
        data.lastUpdateUserId = request.user.sub;
        data.lastUpdateFullName = request.user.name;
        data.developmentPlannedGoalId = development.id;
        await this.plannedGoalRepository.save(data);
      }),
    );
    return new HttpSuccess(development.id);
  }

  /**
   * API ค้นหาโครงการ
   *
   * @summary DEV_00 - ค้นหาโครงการ #
   *
   * @param {string} id  Id โครงการ
   */
  @Get("search")
  async ListDevelopemt(
    @Query("page") page: number = 1,
    @Query("pageSize") pageSize: number = 10,
    @Query() searchField?: "year" | "projectName",
    @Query() searchKeyword: string = "",
  ) {
    let queryLike = "developer.projectName LIKE :keyword";
    if (searchField == "year") {
      queryLike = "developer.year LIKE :keyword";
    }
    const [record, total] = await this.developmentRepository
      .createQueryBuilder("developer")
      .andWhere(
        searchKeyword != undefined && searchKeyword != null && searchKeyword != ""
          ? queryLike
          : "1=1",
        {
          keyword: `%${searchKeyword}%`,
        },
      )
      .skip((page - 1) * pageSize)
      .take(pageSize)
      .getManyAndCount();

    const data = await Promise.all(
      record.map((_data) => {
        return {
          id: _data.id,
          year: _data.year,
          projectName: _data.projectName,
          dateStart: _data.dateStart,
          dateEnd: _data.dateEnd,
          totalDate: _data.totalDate,
          addressAcademic: _data.addressAcademic,
          topicAcademic: _data.topicAcademic,
        };
      }),
    );
    return new HttpSuccess({ data: data, total });
  }

  /**
   * API ลบโครงการ/หลักสูตรการฝึกอบรม
   *
   * @summary DEV_003 - ลบโครงการ/หลักสูตรการฝึกอบรม #3
   *
   * @param {string} id  Id โครงการ
   */
  @Delete("{id}")
  async DeleteDevelopment(@Path() id: string) {
    const development = await this.developmentRepository.findOne({
      where: { id },
      relations: {
        developmentActualPeoples: true,
        developmentPlannedPeoples: true,
        developmentActualGoals: true,
        developmentPlannedGoals: true,
      },
    });
    if (!development) {
      throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลโครงการ/หลักสูตรการฝึกอบรมนี้");
    }

    await this.actualPeopleRepository.remove(development.developmentActualPeoples);
    await this.plannedPeopleRepository.remove(development.developmentPlannedPeoples);
    await this.actualGoalRepository.remove(development.developmentActualGoals);
    await this.plannedGoalRepository.remove(development.developmentPlannedGoals);
    await this.developmentRepository.remove(development);
    return new HttpSuccess();
  }

  /**
   * API รายการโครงการ/หลักสูตรการฝึกอบรม
   *
   * @summary DEV_004 - รายการโครงการ/หลักสูตรการฝึกอบรม #4
   *
   */
  @Get()
  async GetDevelopmentLists(
    @Query("page") page: number = 1,
    @Query("pageSize") pageSize: number = 10,
    @Query("keyword") keyword?: string,
    @Query("year") year?: number,
  ) {
    const [development, total] = await AppDataSource.getRepository(Development)
      .createQueryBuilder("development")
      .andWhere(year == null ? "development.year LIKE :year" : "1=1", { year: `${year}` })
      .orWhere("development.projectName LIKE :keyword", { keyword: `${keyword}` })
      .select(["development.id", "development.projectName", "development.year"])
      .orderBy("development.year", "DESC")
      .orderBy("development.createdAt", "DESC")
      .skip((page - 1) * pageSize)
      .take(pageSize)
      .getManyAndCount();

    return new HttpSuccess({ data: development, total });
  }

  /**
   * API รายละเอียดโครงการ/หลักสูตรการฝึกอบรม
   *
   * @summary DEV_005 - รายละเอียดโครงการ/หลักสูตรการฝึกอบรม #5
   *
   * @param {string} id  Id โครงการ
   */
  @Get("{id}")
  async GetDevelopemtById(@Path() id: string) {
    const getDevelopment = await this.developmentRepository.findOne({
      where: { id: id },
      relations: {
        developmentActualPeoples: true,
        developmentPlannedPeoples: true,
        developmentActualGoals: true,
        developmentPlannedGoals: true,
      },
    });
    if (!getDevelopment) {
      throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลโครงการ/หลักสูตรการฝึกอบรมนี้");
    }
    let _getDevelopment: any = getDevelopment;
    _getDevelopment.actualPeoples = getDevelopment.developmentActualPeoples;
    _getDevelopment.plannedPeoples = getDevelopment.developmentPlannedPeoples;
    _getDevelopment.actualGoals = getDevelopment.developmentActualGoals;
    _getDevelopment.plannedGoals = getDevelopment.developmentPlannedGoals;
    delete _getDevelopment.developmentActualPeoples;
    delete _getDevelopment.developmentPlannedPeoples;
    delete _getDevelopment.developmentActualGoals;
    delete _getDevelopment.developmentPlannedGoals;
    return new HttpSuccess(_getDevelopment);
  }
}