hrms-api-kpi/src/controllers/KpiCapacityController.ts

import {
  Controller,
  Get,
  Post,
  Put,
  Delete,
  Route,
  Security,
  Tags,
  Body,
  Path,
  Request,
  Example,
  SuccessResponse,
  Response,
  Query,
  ArrayValidator,
} from "tsoa";
import { AppDataSource } from "../database/data-source";
import HttpSuccess from "../interfaces/http-success";
import HttpError from "../interfaces/http-error";
import HttpStatusCode from "../interfaces/http-status";
import { KpiCapacity, createKpiCapacity, updateKpiCapacity } from "../entities/kpiCapacity";
import { Position } from "../entities/position";
import {
  KpiCapacityDetail,
  createKpiCapacityDetail,
  updateKpiCapacityDetail,
} from "../entities/kpiCapacityDetail";
import { Like, In } from "typeorm";

@Route("api/v1/kpi/capacity")
@Tags("kpiCapacity")
@Security("bearerAuth")
@Response(
  HttpStatusCode.INTERNAL_SERVER_ERROR,
  "เกิดข้อผิดพลาด ไม่สามารถแสดงรายการได้ กรุณาลองใหม่ในภายหลัง",
)
@SuccessResponse(HttpStatusCode.OK, "สำเร็จ")
export class kpiCapacityController extends Controller {
  private kpiCapacityRepository = AppDataSource.getRepository(KpiCapacity);
  private kpiCapacityDetailRepository = AppDataSource.getRepository(KpiCapacityDetail);
  private positionRepository = AppDataSource.getRepository(Position);

  /**
   * API สร้างรายการสมรรถนะ
   *
   * @summary สร้างรายการสมรรถนะ
   *
   */
  @Post()
  @Example({
    type: "HEAD",
    name: "ชื่อสมรรถนะ",
    description: "คำจำกัดความ",
    kpiCapacityDetails: [
      {
        level: "ระดับ",
        description: "คำอธิบายระดับ",
      },
    ],
  })
  async createKpiCapacity(
    @Body()
    requestBody: {
      type: string;
      name: string;
      description: string;
      capacityDetails: {
        level: string;
        description: string;
      }[];
    },
    @Request() request: { user: Record<string, any> },
  ) {
    const kpiCapacity = Object.assign(new KpiCapacity(), {
      type: requestBody.type,
      name: requestBody.name,
      description: requestBody.description,
    });
    kpiCapacity.createdUserId = request.user.sub;
    kpiCapacity.createdFullName = request.user.name;
    kpiCapacity.lastUpdateUserId = request.user.sub;
    kpiCapacity.lastUpdateFullName = request.user.name;
    await this.kpiCapacityRepository.save(kpiCapacity);

    let idx: number = 0;
    for (const data of requestBody.capacityDetails) {
      idx += 1;
      let _level =
        kpiCapacity.type === "HEAD" || kpiCapacity.type === "GROUP" ? idx.toString() : data.level;
      const kpiCapacityDetail = Object.assign(new KpiCapacityDetail(), {
        level: _level,
        description: data.description,
        kpiCapacityId: kpiCapacity.id,
      });
      kpiCapacityDetail.createdUserId = request.user.sub;
      kpiCapacityDetail.createdFullName = request.user.name;
      kpiCapacityDetail.lastUpdateUserId = request.user.sub;
      kpiCapacityDetail.lastUpdateFullName = request.user.name;
      await this.kpiCapacityDetailRepository.save(kpiCapacityDetail);
    }

    return new HttpSuccess(kpiCapacity.id);
  }

  /**
   * API แก้ไขรายการสมรรถนะ
   *
   * @summary แก้ไขรายการสมรรถนะ
   *
   * @param {string} id  Guid, *Id รายการสมรรถนะ
   */
  @Put("{id}")
  @Example({
    type: "HEAD",
    name: "ชื่อสมรรถนะ",
    description: "คำจำกัดความ",
    kpiCapacityDetails: [
      {
        level: "ระดับ",
        description: "คำอธิบายระดับ",
      },
    ],
  })
  async updateKpiCapacity(
    @Path() id: string,
    @Body()
    requestBody: {
      type: string;
      name: string;
      description: string;
      capacityDetails: {
        level: string;
        description: string;
      }[];
    },
    @Request() request: { user: Record<string, any> },
  ) {
    const kpiCapacity = await this.kpiCapacityRepository.findOne({
      where: { id: id },
    });
    if (!kpiCapacity) {
      throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลรายการสมรรถนะนี้");
    }
    const _kpiCapacity = Object.assign(new KpiCapacity(), {
      type: requestBody.type,
      name: requestBody.name,
      description: requestBody.description,
    });
    kpiCapacity.lastUpdateUserId = request.user.sub;
    kpiCapacity.lastUpdateFullName = request.user.name;
    this.kpiCapacityRepository.merge(kpiCapacity, _kpiCapacity);
    await this.kpiCapacityRepository.save(kpiCapacity);

    const _kpiCapacityDetailsOld = await this.kpiCapacityDetailRepository.find({
      where: { kpiCapacityId: kpiCapacity.id },
    });
    await this.kpiCapacityDetailRepository.remove(_kpiCapacityDetailsOld);

    let idx: number = 0;
    for (const data of requestBody.capacityDetails) {
      idx += 1;
      let _level =
        kpiCapacity.type === "HEAD" || kpiCapacity.type === "GROUP" ? idx.toString() : data.level;
      const kpiCapacityDetail = Object.assign(new KpiCapacityDetail(), {
        level: _level,
        description: data.description,
        kpiCapacityId: kpiCapacity.id,
      });
      kpiCapacityDetail.createdUserId = request.user.sub;
      kpiCapacityDetail.createdFullName = request.user.name;
      kpiCapacityDetail.lastUpdateUserId = request.user.sub;
      kpiCapacityDetail.lastUpdateFullName = request.user.name;
      await this.kpiCapacityDetailRepository.save(kpiCapacityDetail);
    }

    return new HttpSuccess(kpiCapacity.id);
  }

  /**
   * API รายละเอียดรายการสมรรถนะ "สมรรถนะหลัก"
   *
   * @summary รายละเอียดดรายการสมรรถนะ "สมรรถนะหลัก"
   *
   */
  @Get("head")
  async GetKpiCapacityTypeHEAD() {
    const kpiCapacity = await this.kpiCapacityRepository.find({
      where: { 
        type: In(["HEAD"]), 
        kpiCapacityDetails: { level: "1" } 
      },
      select: ["id", "name"],
      relations: ["kpiCapacityDetails"],
    });

    const mapData = kpiCapacity.map((x) => ({
      id: x.id,
      name: x.name,
      level: x.kpiCapacityDetails.length > 0 ? x.kpiCapacityDetails[0].level : null,
      description: x.kpiCapacityDetails.length > 0 ?  x.kpiCapacityDetails[0].description : null,
    }));

    return new HttpSuccess(mapData);
  }

  /**
   * API รายละเอียดรายการสมรรถนะ "สมรรถนะประจำกลุ่มงาน"
   *
   * @summary รายละเอียดดรายการสมรรถนะ "สมรรถนะประจำกลุ่มงาน"
   *
   */
  @Get("group")
  async GetKpiCapacityTypeGROUP(
    @Query("positionName") positionName: string
  ) {

    let position = await this.positionRepository.findOne({
      where: { name: Like(`%${positionName}%`) },
      relations: ["kpiLink.kpiCapacitys"]
    })
    
    if (position == null) {
       position = await this.positionRepository.findOne({
        where: { name: "นักจัดการงานทั่วไป" },
        relations: ["kpiLink.kpiCapacitys"]
      })
    }

    let positionLinkId: any
    positionLinkId = position != null ? position : null
    const kpiCapacityIds = positionLinkId.kpiLink.kpiCapacitys.map((kpiCapacity:any) => kpiCapacity.id)

    const kpiCapacity = await this.kpiCapacityRepository.find({
      where: { 
        id: In(kpiCapacityIds),
        type: In(["GROUP"]), 
        kpiCapacityDetails: { level: "2" } 
      },
      select: ["id", "name"],
      relations: ["kpiCapacityDetails",],
    });

    const mapData = kpiCapacity.map((x) => ({
      id: x.id,
      name: x.name,
      level: x.kpiCapacityDetails.length > 0 ? x.kpiCapacityDetails[0].level : null,
      description: x.kpiCapacityDetails.length > 0 ? x.kpiCapacityDetails[0].description : null,
    }));
    return new HttpSuccess(mapData);
  }

  /**
   * API รายละเอียดรายการสมรรถนะ
   *
   * @summary รายละเอียดดรายการสมรรถนะ
   *
   * @param {string} id  Guid, *Id รายการสมรรถนะ
   */
  @Get("{id}")
  @Example({
    type: "HEAD",
    name: "ชื่อสมรรถนะ",
    description: "คำจำกัดความ",
    kpiCapacityDetails: [
      {
        level: 1,
        description: "คำอธิบายระดับ",
      },
    ],
  })
  async GetKpiCapacityById(@Path() id: string) {
    const kpiCapacity = await this.kpiCapacityRepository.findOne({
      where: { id: id },
      select: ["type", "name", "description"],
    });
    if (!kpiCapacity) {
      throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลรายการสมรรถนะนี้");
    }
    const kpiCapacityDetails = await this.kpiCapacityDetailRepository.find({
      where: { kpiCapacityId: id },
      select: ["level", "description"],
      order: { level: "ASC" },
    });
    const mapData = {
      type: kpiCapacity.type,
      name: kpiCapacity.name,
      description: kpiCapacity.description,
      capacityDetails: kpiCapacityDetails,
    };
    return new HttpSuccess(mapData);
  }

  /**
   * API รายการสมรรถนะ
   *
   * @summary รายการสมรรถนะ
   *
   */
  @Get()
  async listKpiCapacity(
    @Query("page") page: number = 1,
    @Query("pageSize") pageSize: number = 10,
    @Query("type") type?: string,
    @Query("keyword") keyword?: string,
  ) {
    const [kpiCapacity, total] = await AppDataSource.getRepository(KpiCapacity)
      .createQueryBuilder("kpiCapacity")
      .leftJoinAndSelect("kpiCapacity.kpiCapacityDetails", "kpiCapacityDetail")
      .andWhere(
        keyword == undefined
          ? "1=1"
          : [{ name: Like(`%${keyword}%`) }, { description: Like(`%${keyword}%`) }],
      )
      .andWhere(type == undefined ? "1=1" : { type: type })
      .orderBy("kpiCapacity.createdAt", "ASC")
      .skip((page - 1) * pageSize)
      .take(pageSize)
      .getManyAndCount();

    const mapFormula = kpiCapacity.map((item) => ({
      id: item.id,
      type: item.type,
      name: item.name,
      description: item.description,
      capacityDetails: item.kpiCapacityDetails.map((detail) => {
        return {
          id: detail.id,
          description: detail.description,
          level: detail.level,
          capacityId: detail.kpiCapacityId,
        };
      }),
    }));
    return new HttpSuccess({ data: mapFormula, total });
  }

  /**
   * API ลบรายการสมรรถนะ
   *
   * @summary ลบรายการสมรรถนะ
   *
   * @param {string} id  Guid, *Id รายการสมรรถนะ
   */
  @Delete("{id}")
  async deleteKpiCapacity(@Path() id: string) {
    const kpiCapacity = await this.kpiCapacityRepository.findOne({
      where: { id: id },
    });
    if (!kpiCapacity) {
      throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลรายการสมรรถนะนี้");
    }
    const kpiCapacityDetails = await this.kpiCapacityDetailRepository.find({
      where: { kpiCapacityId: id },
    });
    if (kpiCapacityDetails.length > 0) {
      await this.kpiCapacityDetailRepository.remove(kpiCapacityDetails);
    }
    await this.kpiCapacityRepository.remove(kpiCapacity);
    return new HttpSuccess();
  }
}