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

import {
  Controller,
  Get,
  Post,
  Put,
  Delete,
  Route,
  Security,
  Tags,
  Body,
  Path,
  Request,
  Example,
  SuccessResponse,
  Response,
  Query,
} 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 { KpiPlan, createKpiPlan, updateKpiPlan } from "../entities/kpiPlan";
import CallAPI from "../interfaces/call-api";
import { KpiPeriod } from "../entities/kpiPeriod";
import { Brackets, IsNull, Not } from "typeorm";
import { KpiPlanHistory } from "../entities/kpiPlanHistory";

@Route("api/v1/kpi/plan")
@Tags("kpiPlan")
@Security("bearerAuth")
@Response(
  HttpStatusCode.INTERNAL_SERVER_ERROR,
  "เกิดข้อผิดพลาด ไม่สามารถแสดงรายการได้ กรุณาลองใหม่ในภายหลัง",
)
@SuccessResponse(HttpStatusCode.OK, "สำเร็จ")
export class kpiPlanController extends Controller {
  private kpiPlanRepository = AppDataSource.getRepository(KpiPlan);
  private kpiPlanHistoryRepository = AppDataSource.getRepository(KpiPlanHistory);
  private kpiPeriodRepository = AppDataSource.getRepository(KpiPeriod);
  /**
   * สร้างตัวชี้วัดตามแผนฯ
   * @param requestBody
   * @param request
   */
  @Post()
  async createKpiPlan(
    @Body() requestBody: createKpiPlan,
    @Request() request: { user: Record<string, any> },
  ) {
    const kpiPlan = Object.assign(new KpiPlan(), requestBody);
    if (requestBody.kpiPeriodId != null) {
      const kpiPeriod = await this.kpiPeriodRepository.findOne({
        where: { id: requestBody.kpiPeriodId },
      });
      if (!kpiPeriod) {
        throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลตัวชี้วัดตามตำแหน่งนี้");
      }
    }
    await new CallAPI()
      .PostData(request, "org/find/all", {
        node: requestBody.node,
        nodeId: requestBody.nodeId,
      })
      .then((x) => {
        kpiPlan.root = x.root;
        kpiPlan.rootId = x.rootId;
        kpiPlan.rootShortName = x.rootShortName;
        kpiPlan.child1 = requestBody.node <= 0 ? null : x.child1;
        kpiPlan.child1Id = requestBody.node <= 0 ? null : x.child1Id;
        kpiPlan.child1ShortName = requestBody.node <= 0 ? null : x.child1ShortName;
        kpiPlan.child2 = requestBody.node <= 1 ? null : x.child2;
        kpiPlan.child2Id = requestBody.node <= 1 ? null : x.child2Id;
        kpiPlan.child2ShortName = requestBody.node <= 1 ? null : x.child2ShortName;
        kpiPlan.child3 = requestBody.node <= 2 ? null : x.child3;
        kpiPlan.child3Id = requestBody.node <= 2 ? null : x.child3Id;
        kpiPlan.child3ShortName = requestBody.node <= 2 ? null : x.child3ShortName;
        kpiPlan.child4 = requestBody.node <= 3 ? null : x.child4;
        kpiPlan.child4Id = requestBody.node <= 3 ? null : x.child4Id;
        kpiPlan.child4ShortName = requestBody.node <= 3 ? null : x.child4ShortName;
      })
      .catch((x) => {});
    await new CallAPI()
      .PostData(request, "development/strategy/find/all", {
        strategy: requestBody.strategy,
        strategyId: requestBody.strategyId,
      })
      .then((x) => {
        kpiPlan.strategyChild1 = x.strategyChild1;
        kpiPlan.strategyChild1Id = x.strategyChild1Id;
        kpiPlan.strategyChild2 = requestBody.strategy <= 1 ? null : x.strategyChild2;
        kpiPlan.strategyChild2Id = requestBody.strategy <= 1 ? null : x.strategyChild2Id;
        kpiPlan.strategyChild3 = requestBody.strategy <= 2 ? null : x.strategyChild3;
        kpiPlan.strategyChild3Id = requestBody.strategy <= 2 ? null : x.strategyChild3Id;
        kpiPlan.strategyChild4 = requestBody.strategy <= 3 ? null : x.strategyChild4;
        kpiPlan.strategyChild4Id = requestBody.strategy <= 3 ? null : x.strategyChild4Id;
        kpiPlan.strategyChild5 = requestBody.strategy <= 4 ? null : x.strategyChild5;
        kpiPlan.strategyChild5Id = requestBody.strategy <= 4 ? null : x.strategyChild5Id;
      })
      .catch((x) => {});

    let maxIncludingPlan: any;
    if (requestBody.node == 0) {
      maxIncludingPlan = await this.kpiPlanRepository
        .createQueryBuilder("kpiPlan")
        .select("MAX(kpiPlan.including)", "maxIncluding")
        .where("kpiPlan.rootId = :rootId AND kpiPlan.child1Id IS NULL", {
          rootId: requestBody.nodeId,
        })
        .andWhere("kpiPlan.kpiPeriodId = :kpiPeriodId", {
          kpiPeriodId: requestBody.kpiPeriodId,
        })
        .getRawOne();
    } else if (requestBody.node == 1) {
      maxIncludingPlan = await this.kpiPlanRepository
        .createQueryBuilder("kpiPlan")
        .select("MAX(kpiPlan.including)", "maxIncluding")
        .where("kpiPlan.child1Id = :child1Id AND kpiPlan.child2Id IS NULL", {
          child1Id: requestBody.nodeId,
        })
        .andWhere("kpiPlan.kpiPeriodId = :kpiPeriodId", {
          kpiPeriodId: requestBody.kpiPeriodId,
        })
        .getRawOne();
    } else if (requestBody.node == 2) {
      maxIncludingPlan = await this.kpiPlanRepository
        .createQueryBuilder("kpiPlan")
        .select("MAX(kpiPlan.including)", "maxIncluding")
        .where("kpiPlan.child2Id = :child2Id AND kpiPlan.child3Id IS NULL", {
          child2Id: requestBody.nodeId,
        })
        .andWhere("kpiPlan.kpiPeriodId = :kpiPeriodId", {
          kpiPeriodId: requestBody.kpiPeriodId,
        })
        .getRawOne();
    } else if (requestBody.node == 3) {
      maxIncludingPlan = await this.kpiPlanRepository
        .createQueryBuilder("kpiPlan")
        .select("MAX(kpiPlan.including)", "maxIncluding")
        .where("kpiPlan.child3Id = :child3Id AND kpiPlan.child4Id IS NULL", {
          child3Id: requestBody.nodeId,
        })
        .andWhere("kpiPlan.kpiPeriodId = :kpiPeriodId", {
          kpiPeriodId: requestBody.kpiPeriodId,
        })
        .getRawOne();
    } else if (requestBody.node == 4) {
      maxIncludingPlan = await this.kpiPlanRepository
        .createQueryBuilder("kpiPlan")
        .select("MAX(kpiPlan.including)", "maxIncluding")
        .where("kpiPlan.child4Id = :child4Id", {
          child4Id: requestBody.nodeId,
        })
        .andWhere("kpiPlan.kpiPeriodId = :kpiPeriodId", {
          kpiPeriodId: requestBody.kpiPeriodId,
        })
        .getRawOne();
    }
    kpiPlan.including = maxIncludingPlan.maxIncluding + 1;
    kpiPlan.createdUserId = request.user.sub;
    kpiPlan.createdFullName = request.user.name;
    kpiPlan.lastUpdateUserId = request.user.sub;
    kpiPlan.lastUpdateFullName = request.user.name;
    await this.kpiPlanRepository.save(kpiPlan);

    const history = new KpiPlanHistory();
    history.kpiPlanId = kpiPlan.id;
    history.createdUserId = request.user.sub;
    history.createdFullName = request.user.name;
    history.lastUpdateUserId = request.user.sub;
    history.lastUpdateFullName = request.user.name;
    await this.kpiPlanHistoryRepository.save(history);

    return new HttpSuccess(kpiPlan.id);
  }

  /**
   * API แก้ไขตัวชี้วัดตามแผนฯ
   * @param id
   * @param requestBody
   * @param request
   */
  @Put("{id}")
  async updateKpiPlan(
    @Path() id: string,
    @Body() requestBody: updateKpiPlan,
    @Request() request: { user: Record<string, any> },
  ) {
    const kpiPlan = await this.kpiPlanRepository.findOne({
      where: { id: id },
    });
    if (!kpiPlan) {
      throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลตัวชี้วัดตามแผนฯนี้");
    }

    if (requestBody.kpiPeriodId != null) {
      const kpiPeriod = await this.kpiPeriodRepository.findOne({
        where: { id: requestBody.kpiPeriodId },
      });
      if (!kpiPeriod) {
        throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลตัวชี้วัดตามตำแหน่งนี้");
      }
    }
    Object.assign(kpiPlan, requestBody);
    await new CallAPI()
      .PostData(request, "org/find/all", {
        node: requestBody.node,
        nodeId: requestBody.nodeId,
      })
      .then((x) => {
        kpiPlan.root = x.root;
        kpiPlan.rootId = x.rootId;
        kpiPlan.rootShortName = x.rootShortName;
        kpiPlan.child1 = requestBody.node <= 0 ? null : x.child1;
        kpiPlan.child1Id = requestBody.node <= 0 ? null : x.child1Id;
        kpiPlan.child1ShortName = requestBody.node <= 0 ? null : x.child1ShortName;
        kpiPlan.child2 = requestBody.node <= 1 ? null : x.child2;
        kpiPlan.child2Id = requestBody.node <= 1 ? null : x.child2Id;
        kpiPlan.child2ShortName = requestBody.node <= 1 ? null : x.child2ShortName;
        kpiPlan.child3 = requestBody.node <= 2 ? null : x.child3;
        kpiPlan.child3Id = requestBody.node <= 2 ? null : x.child3Id;
        kpiPlan.child3ShortName = requestBody.node <= 2 ? null : x.child3ShortName;
        kpiPlan.child4 = requestBody.node <= 3 ? null : x.child4;
        kpiPlan.child4Id = requestBody.node <= 3 ? null : x.child4Id;
        kpiPlan.child4ShortName = requestBody.node <= 3 ? null : x.child4ShortName;
      })
      .catch((x) => {});
    await new CallAPI()
      .PostData(request, "development/strategy/find/all", {
        strategy: requestBody.strategy,
        strategyId: requestBody.strategyId,
      })
      .then((x) => {
        kpiPlan.strategyChild1 = x.strategyChild1;
        kpiPlan.strategyChild1Id = x.strategyChild1Id;
        kpiPlan.strategyChild2 = requestBody.strategy <= 1 ? null : x.strategyChild2;
        kpiPlan.strategyChild2Id = requestBody.strategy <= 1 ? null : x.strategyChild2Id;
        kpiPlan.strategyChild3 = requestBody.strategy <= 2 ? null : x.strategyChild3;
        kpiPlan.strategyChild3Id = requestBody.strategy <= 2 ? null : x.strategyChild3Id;
        kpiPlan.strategyChild4 = requestBody.strategy <= 3 ? null : x.strategyChild4;
        kpiPlan.strategyChild4Id = requestBody.strategy <= 3 ? null : x.strategyChild4Id;
        kpiPlan.strategyChild5 = requestBody.strategy <= 4 ? null : x.strategyChild5;
        kpiPlan.strategyChild5Id = requestBody.strategy <= 4 ? null : x.strategyChild5Id;
      })
      .catch((x) => {});
    kpiPlan.createdUserId = request.user.sub;
    kpiPlan.createdFullName = request.user.name;
    kpiPlan.lastUpdateUserId = request.user.sub;
    kpiPlan.lastUpdateFullName = request.user.name;
    await this.kpiPlanRepository.save(kpiPlan);

    const history = new KpiPlanHistory();
    history.kpiPlanId = kpiPlan.id;
    history.createdUserId = request.user.sub;
    history.createdFullName = request.user.name;
    history.lastUpdateUserId = request.user.sub;
    history.lastUpdateFullName = request.user.name;
    await this.kpiPlanHistoryRepository.save(history);

    return new HttpSuccess(id);
  }

  /**
   * API ตัวชี้วัดตามแผนฯ
   * @param id  Guid, *Id ตัวชี้วัดตามแผนฯ
   */
  @Get("{id}")
  async GetKpiPlanById(@Path() id: string) {
    const kpiPlan = await this.kpiPlanRepository.findOne({
      where: { id: id },
      relations: { kpiPeriod: true },
    });
    if (!kpiPlan) {
      throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลตัวชี้วัดตามแผนฯนี้");
    }
    let node = null;
    let nodeId = null;
    let nodeName = null;
    if (kpiPlan.child4Id != null) {
      node = 4;
      nodeId = kpiPlan.child4Id;
      nodeName = kpiPlan.child4;
    } else if (kpiPlan.child3Id != null) {
      node = 3;
      nodeId = kpiPlan.child3Id;
      nodeName = kpiPlan.child3;
    } else if (kpiPlan.child2Id != null) {
      node = 2;
      nodeId = kpiPlan.child2Id;
      nodeName = kpiPlan.child2;
    } else if (kpiPlan.child1Id != null) {
      node = 1;
      nodeId = kpiPlan.child1Id;
      nodeName = kpiPlan.child1;
    } else if (kpiPlan.rootId != null) {
      node = 0;
      nodeId = kpiPlan.rootId;
      nodeName = kpiPlan.root;
    }
    let strategy = null;
    let strategyId = null;
    let strategyName = null;
    if (kpiPlan.strategyChild5Id != null) {
      strategy = 5;
      strategyId = kpiPlan.strategyChild5Id;
    } else if (kpiPlan.strategyChild4Id != null) {
      strategy = 4;
      strategyId = kpiPlan.strategyChild4Id;
      strategyName = kpiPlan.strategyChild4;
    } else if (kpiPlan.strategyChild3Id != null) {
      strategy = 3;
      strategyId = kpiPlan.strategyChild3Id;
      strategyName = kpiPlan.strategyChild3;
    } else if (kpiPlan.strategyChild2Id != null) {
      strategy = 2;
      strategyId = kpiPlan.strategyChild2Id;
      strategyName = kpiPlan.strategyChild2;
    } else if (kpiPlan.strategyChild1Id != null) {
      strategy = 1;
      strategyId = kpiPlan.strategyChild1Id;
      strategyName = kpiPlan.strategyChild1;
    }
    const formattedData = {
      id: kpiPlan.id,
      year: kpiPlan.kpiPeriod == null ? null : kpiPlan.kpiPeriod.year,
      round: kpiPlan.kpiPeriod == null ? null : kpiPlan.kpiPeriod.durationKPI,
      kpiPeriodId: kpiPlan.kpiPeriodId,
      including: kpiPlan.including,
      includingName: kpiPlan.includingName,
      target: kpiPlan.target,
      unit: kpiPlan.unit,
      weight: kpiPlan.weight,
      achievement1: kpiPlan.achievement1,
      achievement2: kpiPlan.achievement2,
      achievement3: kpiPlan.achievement3,
      achievement4: kpiPlan.achievement4,
      achievement5: kpiPlan.achievement5,
      meaning: kpiPlan.meaning,
      formula: kpiPlan.formula,
      root: kpiPlan.rootId,
      child1: kpiPlan.child1Id,
      child2: kpiPlan.child2Id,
      child3: kpiPlan.child3Id,
      child4: kpiPlan.child4Id,
      node: node,
      nodeId: nodeId,
      nodeName: nodeName,
      orgRevisionId: kpiPlan.orgRevisionId,
      strategy: strategy,
      strategyId: strategyId,
      strategyName: strategyName,
      strategyChild1: kpiPlan.strategyChild1Id,
      strategyChild2: kpiPlan.strategyChild2Id,
      strategyChild3: kpiPlan.strategyChild3Id,
      strategyChild4: kpiPlan.strategyChild4Id,
      strategyChild5: kpiPlan.strategyChild5Id,
    };
    return new HttpSuccess(formattedData);
  }

  /**
   * API list ตัวชี้วัดตามแผนฯ
   * @param page
   * @param pageSize
   * @param keyword
   */
  @Get()
  async listKpiPlan(
    @Query("page") page: number = 1,
    @Query("pageSize") pageSize: number = 10,
    @Query("kpiPeriodId") kpiPeriodId?: string,
    @Query("nodeId") nodeId?: string | null,
    @Query("node") node?: number | null,
    @Query("keyword") keyword?: string,
  ) {
    const [kpiPlan, total] = await AppDataSource.getRepository(KpiPlan)
      .createQueryBuilder("kpiPlan")
      .leftJoinAndSelect("kpiPlan.kpiPeriod", "kpiPeriod")
      .andWhere(
        node != undefined && node != null
          ? node == 4
            ? "kpiPlan.child4Id LIKE :nodeId"
            : node == 3
              ? "kpiPlan.child3Id LIKE :nodeId"
              : node == 2
                ? "kpiPlan.child2Id LIKE :nodeId"
                : node == 1
                  ? "kpiPlan.child1Id LIKE :nodeId"
                  : "kpiPlan.rootId LIKE :nodeId"
          : "1=1",
        {
          nodeId: nodeId,
        },
      )
      .andWhere(
        kpiPeriodId != undefined && kpiPeriodId != null && kpiPeriodId != ""
          ? "kpiPlan.kpiPeriodId LIKE :kpiPeriodId"
          : "1=1",
        {
          kpiPeriodId: kpiPeriodId,
        },
      )
      .andWhere(
        new Brackets((qb) => {
          qb.orWhere("kpiPlan.including LIKE :keyword", { keyword: `%${keyword}%` }).orWhere(
            "kpiPlan.includingName LIKE :keyword",
            { keyword: `%${keyword}%` },
          );
        }),
      )
      .select([
        "kpiPlan.id",
        "kpiPeriod.year",
        "kpiPeriod.durationKPI",
        "kpiPlan.including",
        "kpiPlan.includingName",
        "kpiPlan.createdAt",
      ])
      .orderBy("kpiPlan.createdAt", "DESC")
      .skip((page - 1) * pageSize)
      .take(pageSize)
      .getManyAndCount();

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

  /**
   * API ลบตัวชี้วัดตามแผนฯ
   * @param id
   */
  @Delete("{id}")
  async deleteKpiPlan(@Path() id: string) {
    const kpiPlan = await this.kpiPlanRepository.findOne({
      where: { id: id },
    });
    if (!kpiPlan) {
      throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลตัวชี้วัดตามแผนฯนี้");
    }
    let type = 0;
    if (kpiPlan.child1Id != null) {
      type = 1;
    } else if (kpiPlan.child2Id != null) {
      type = 2;
    } else if (kpiPlan.child3Id != null) {
      type = 3;
    } else if (kpiPlan.child4Id != null) {
      type = 4;
    }
    await this.kpiPlanHistoryRepository.delete({ kpiPlanId: id });
    await this.kpiPlanRepository.remove(kpiPlan);
    
    if (kpiPlan) {
      let remainingKpiPlans: any;
      if (type == 0) {
        remainingKpiPlans = await this.kpiPlanRepository.find({
          where: {
            rootId: kpiPlan.rootId,
            child1Id: IsNull(),
          },
          order: {
            including: "ASC",
          },
        });
      } else if (type == 1) {
        remainingKpiPlans = await this.kpiPlanRepository.find({
          where: {
            child1Id: kpiPlan.child1Id,
            child2Id: IsNull(),
          },
          order: {
            including: "ASC",
          },
        });
      } else if (type == 2) {
        remainingKpiPlans = await this.kpiPlanRepository.find({
          where: {
            child2Id: kpiPlan.child2Id,
            child3Id: IsNull(),
          },
          order: {
            including: "ASC",
          },
        });
      } else if (type == 3) {
        remainingKpiPlans = await this.kpiPlanRepository.find({
          where: {
            child3Id: kpiPlan.child3Id,
            child4Id: IsNull(),
          },
          order: {
            including: "ASC",
          },
        });
      } else if (type == 4) {
        remainingKpiPlans = await this.kpiPlanRepository.find({
          where: {
            child4Id: kpiPlan.child4Id,
          },
          order: {
            including: "ASC",
          },
        });
      }
      remainingKpiPlans.forEach((kpiPlan: any, index: any) => {
        kpiPlan.including = index + 1;
      });
      await this.kpiPlanRepository.save(remainingKpiPlans);
    }

    return new HttpSuccess();
  }
}