hrms-api-org/src/controllers/ChangePositionController.ts

import {
  Controller,
  Get,
  Post,
  Put,
  Delete,
  Patch,
  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 HttpStatusCode from "../interfaces/http-status";
import HttpError from "../interfaces/http-error";
import { Equal, ILike, In, IsNull, Like, Not, Brackets, MoreThan } from "typeorm";
import { RequestWithUser } from "../middlewares/user";
import { 
  ChangePosition, 
  CreateChangePosition, 
  UpdateChangePosition 
} from "../entities/ChangePosition";
import { 
  ProfileChangePosition, 
  CreateProfileChangePosition, 
  UpdateProfileChangePosition,
  SelectProfileChangePosition 
} from "../entities/ProfileChangePosition";
import { OrgRoot } from "../entities/OrgRoot";
import { OrgChild1 } from "../entities/OrgChild1";
import { OrgChild2 } from "../entities/OrgChild2";
import { OrgChild3 } from "../entities/OrgChild3";
import { OrgChild4 } from "../entities/OrgChild4";

@Route("api/v1/org/placement/change-position")
@Tags("Placement")
@Security("bearerAuth")
@Response(
  HttpStatusCode.INTERNAL_SERVER_ERROR,
  "เกิดข้อผิดพลาด ไม่สามารถแสดงรายการได้ กรุณาลองใหม่ในภายหลัง",
)
@SuccessResponse(HttpStatusCode.OK, "สำเร็จ")
export class ChangePositionController extends Controller {
  private changePositionRepository = AppDataSource.getRepository(ChangePosition); 
  private profileChangePositionRepository = AppDataSource.getRepository(ProfileChangePosition); 
  private orgRootRepository = AppDataSource.getRepository(OrgRoot);
  private child1Repository = AppDataSource.getRepository(OrgChild1);
  private child2Repository = AppDataSource.getRepository(OrgChild2);
  private child3Repository = AppDataSource.getRepository(OrgChild3);
  private child4Repository = AppDataSource.getRepository(OrgChild4);

  /**
   * API เพิ่มรอบย้ายสับเปลี่ยนตำแหน่ง
   *
   * @summary เพิ่มรอบย้ายสับเปลี่ยนตำแหน่ง (ADMIN)
   *
   */
  @Post()
  async CreateChangePosition(
    @Body() body: CreateChangePosition,
    @Request() request: RequestWithUser,
  ) {
    const _changePosition = await this.changePositionRepository.findOne({
      where: { name: body.name },
    });
    if(_changePosition){
      throw new HttpError(
        HttpStatusCode.INTERNAL_SERVER_ERROR,
        "ชื่อรอบการย้ายสับเปลี่ยนตำแหน่งนี้มีอยู่ในระบบแล้ว",
      );
    }

    const changePosition = new ChangePosition();
    Object.assign(changePosition, body);
    changePosition.date = new Date,
    changePosition.status = "WAITTING",
    changePosition.createdUserId = request.user.sub;
    changePosition.createdFullName = request.user.name;
    changePosition.lastUpdateUserId = request.user.sub;
    changePosition.lastUpdateFullName = request.user.name;
    await this.changePositionRepository.save(changePosition);
    return new HttpSuccess();
  }

  /**
   * API ลบรอบย้ายสับเปลี่ยนตำแหน่ง
   *
   * @summary ลบรอบย้ายสับเปลี่ยนตำแหน่ง (ADMIN)
   *
   * @param {string} id  Id รอบย้ายสับเปลี่ยนตำแหน่ง
   */
  @Delete("{id}")
  async DeleteChangePosition(@Path() id: string) {
    let result: any;
    try {
      result = await this.changePositionRepository.delete({ id: id });
    } catch {
      throw new HttpError(
        HttpStatusCode.NOT_FOUND,
        "ไม่สามารถลบได้เนื่องจากมีการใช้งานรอบย้ายสับเปลี่ยนตำแหน่งนี้อยู่",
      );
    }
    if (result.affected == undefined || result.affected <= 0) {
      throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูล");
    }
    return new HttpSuccess();
  }

  /**
   * API แก้ไขรอบย้ายสับเปลี่ยนตำแหน่ง
   *
   * @summary แก้ไขรอบย้ายสับเปลี่ยนตำแหน่ง (ADMIN)
   *
   * @param {string} id  Id รอบย้ายสับเปลี่ยนตำแหน่ง
   */
  @Put("{id}")
  async UpdateChangePosition(
    @Request() request: RequestWithUser,
    @Path() id: string,
    @Body() body: UpdateChangePosition,
  ) {

    const changePosition = await this.changePositionRepository.findOneBy({ id });
    if (!changePosition) throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลรอบย้ายสับเปลี่ยนตำแหน่ง");

    const checkDuplicate = await this.changePositionRepository.find({
      where: { 
        id: Not(id),
        name: body.name 
      },
    });
    if(checkDuplicate.length > 0){
      throw new HttpError(
        HttpStatusCode.INTERNAL_SERVER_ERROR,
        "ชื่อรอบการย้ายสับเปลี่ยนตำแหน่งนี้มีอยู่ในระบบแล้ว",
      );
    }
    Object.assign(changePosition, body);
    changePosition.lastUpdateUserId = request.user.sub;
    changePosition.lastUpdateFullName = request.user.name;
    await this.changePositionRepository.save(changePosition);
    return new HttpSuccess();
  }

  /**
   * API รายการรอบย้ายสับเปลี่ยนตำแหน่ง
   *
   * @summary API รายการรอบย้ายสับเปลี่ยนตำแหน่ง (ADMIN)
   *
   */
  @Get()
  async GetChangePositionLists(
    @Query("page") page: number = 1,
    @Query("pageSize") pageSize: number = 10,
    @Query() searchKeyword: string = "",
  ) {
    const [changePosition, total] = await AppDataSource.getRepository(ChangePosition)
      .createQueryBuilder("changePosition")
      .where(
        searchKeyword ? 
          "changePosition.name LIKE :keyword OR changePosition.date LIKE :keyword OR changePosition.status LIKE :keyword" 
          : "1=1",
        { keyword: `%${searchKeyword}%` }
      )
      .orderBy("changePosition.date", "ASC")
      .skip((page - 1) * pageSize)
      .take(pageSize)
      .getManyAndCount();

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

  /**
   * API รายละเอียดรอบย้ายสับเปลี่ยนตำแหน่ง
   *
   * @summary API รายละเอียดรอบย้ายสับเปลี่ยนตำแหน่ง (ADMIN)
   * 
   * @param {string} id  Id รอบย้ายสับเปลี่ยนตำแหน่ง
   */
  @Get("{id}")
  async GetChangePositionById( @Path() id: string ) {

    const data = await this.changePositionRepository.findOne({ where: { id: id }});
    if (!data) throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลรอบย้ายสับเปลี่ยนตำแหน่ง");
    return new HttpSuccess(data);
  }

  /**
   * API เพิ่มเพิ่มรายชื่อผู้ที่ย้ายสับเปลี่ยนตำแหน่ง
   *
   * @summary เพิ่มเพิ่มรายชื่อผู้ที่ย้ายสับเปลี่ยนตำแหน่ง (ADMIN)
   *
   * @param {string} changePositionId  changePositionId รอบย้ายสับเปลี่ยนตำแหน่ง
   */
  @Post("profile/{changePositionId}")
  async CreateProfileChangePosition(
    @Path() changePositionId: string,
    @Body() body: CreateProfileChangePosition,
    @Request() request: RequestWithUser,
  ) {
    const changePosition = await this.changePositionRepository.findOneBy({ id: changePositionId });
    if (!changePosition) throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลรอบย้ายสับเปลี่ยนตำแหน่ง");

    const profileChangePositions: ProfileChangePosition[] = [];
    const profiles = new ProfileChangePosition();
    for (const data of body.profiles) {
      Object.assign(profiles, data); 
      let positionOld = data.positionOld ? `${data.positionOld}` : "";
      let rootOld = data.rootOld ? data.positionOld ? `/${data.rootOld}` : `${data.rootOld}` : "";
      profiles.changePositionId = changePositionId;
      profiles.organizationPositionOld = `${positionOld}${rootOld}`,
      profiles.status = "WAITTING",  
      profiles.createdUserId = request.user.sub;
      profiles.createdFullName = request.user.name;
      profiles.lastUpdateUserId = request.user.sub;
      profiles.lastUpdateFullName = request.user.name;
      profileChangePositions.push(profiles);
    }
    await this.profileChangePositionRepository.save(profileChangePositions);
    return new HttpSuccess();
  }

  /**
   * API ลบรายชื่อผู้ที่ย้ายสับเปลี่ยนตำแหน่ง
   *
   * @summary ลบรายชื่อผู้ที่ย้ายสับเปลี่ยนตำแหน่ง (ADMIN)
   *
   * @param {string} id  Id รายชื่อผู้ที่ย้ายสับเปลี่ยนตำแหน่ง
   */
  @Delete("profile/{id}")
  async DeleteProfileChangePosition(@Path() id: string) {
    const result = await this.profileChangePositionRepository.delete({ id: id });
    if (result.affected == undefined || result.affected <= 0) {
      throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูล");
    }
    return new HttpSuccess();
  }

  /**
   * API รายการรายชื่อผู้ที่ย้ายสับเปลี่ยนตำแหน่ง
   *
   * @summary API รายการรายชื่อผู้ที่ย้ายสับเปลี่ยนตำแหน่ง (ADMIN)
   * 
   * @param {string} changePositionId  Id รอบย้ายสับเปลี่ยนตำแหน่ง
   */
  @Get("profile-all/{changePositionId}")
  async GetProfileChangePositionLists( 
    @Path() changePositionId: string,
    @Query("page") page: number = 1,
    @Query("pageSize") pageSize: number = 10,
    @Query() searchKeyword: string = "",

  ) {
    const findData = await this.profileChangePositionRepository.find({
      where: { changePositionId: changePositionId }
    });
    if (!findData) throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลรอบย้ายสับเปลี่ยนตำแหน่ง");

    const [profileChangePosition, total] = await AppDataSource.getRepository(ProfileChangePosition)
      .createQueryBuilder("profileChangePosition")
      .where("profileChangePosition.changePositionId LIKE :id", { id: changePositionId })
      .andWhere(
        searchKeyword ?
          "CONCAT(profileChangePosition.prefix, profileChangePosition.firstName, ' ', profileChangePosition.lastName) LIKE :keyword"
          : "1=1",
        {
          keyword: `%${searchKeyword}%`,
        },
      )
      .andWhere(
        searchKeyword ? 
          "profileChangePosition.citizenId LIKE :keyword OR profileChangePosition.status LIKE :keyword" 
          : "1=1",
        { keyword: `%${searchKeyword}%` }
      )
      .andWhere(
        searchKeyword ? 
          "profileChangePosition.birthDate LIKE :keyword OR profileChangePosition.lastUpdatedAt LIKE :keyword"
          : "1=1",
        { keyword: `%${searchKeyword}%` }
      )
      .orderBy("profileChangePosition.createdAt", "ASC")
      .skip((page - 1) * pageSize)
      .take(pageSize)
      .getManyAndCount();

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

  /**
   * API รายละเอียดรายชื่อผู้ที่ย้ายสับเปลี่ยนตำแหน่ง
   *
   * @summary API รายละเอียดรายชื่อผู้ที่ย้ายสับเปลี่ยนตำแหน่ง (ADMIN)
   * 
   * @param {string} id  Id รายชื่อผู้ที่ย้ายสับเปลี่ยนตำแหน่ง
   */
  @Get("profile/{id}")
  async GetProfileChangePositionById( 
    @Path() id: string
  ) {
    const profileChangePos = await this.profileChangePositionRepository.findOne({
      where: { id: id }
    });
    if (!profileChangePos) throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลรายชื่อผู้ที่ย้ายสับเปลี่ยนตำแหน่ง");
    return new HttpSuccess(profileChangePos);
  }

  /**
   * API แก้ไขข้อมูลเพื่อลงบัญชีแนบท้าย
   *
   * @summary แก้ไขข้อมูลเพื่อลงบัญชีแนบท้าย (ADMIN)
   *
   * @param {string} id  Id รายชื่อผู้ที่ย้ายสับเปลี่ยนตำแหน่ง
   */
  @Put("profile/{id}")
  async UpdateProfileChangePositionById(
    @Request() request: RequestWithUser,
    @Path() id: string,
    @Body() body: UpdateProfileChangePosition,
  ) {

    const profileChangePos = await this.profileChangePositionRepository.findOneBy({ id });
    if (!profileChangePos) throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลรายชื่อผู้ที่ย้ายสับเปลี่ยนตำแหน่งนี้");

    profileChangePos.lastUpdateUserId = request.user.sub;
    profileChangePos.lastUpdateFullName = request.user.name;
    profileChangePos.educationOld = body.educationOld;
    profileChangePos.posMasterNoOld = body.posMasterNoOld;
    profileChangePos.positionTypeOld = body.positionTypeOld;
    profileChangePos.positionLevelOld = body.positionLevelOld;
    profileChangePos.positionNumberOld = body.positionNumberOld;
    profileChangePos.amountOld = body.amountOld;
    profileChangePos.reason = body.reason? String(body.reason) : "";
    await this.profileChangePositionRepository.save(profileChangePos);
    return new HttpSuccess();
  }

  /**
   * API บันทึก เลือกหน่วยงานที่รับย้าย
   *
   * @summary บันทึก เลือกหน่วยงานที่รับย้าย (ADMIN)
   *
   * @param {string} id  Id รายชื่อผู้ที่ย้ายสับเปลี่ยนตำแหน่ง
   */
  @Put("profile/position/{id}")
  async positionProfileEmployee(
    @Request() request: RequestWithUser,
    @Path() id: string,
    @Body() body: SelectProfileChangePosition,
  ) {

    const profileChangePos = await this.profileChangePositionRepository.findOneBy({ id });
    if (!profileChangePos) throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลรายชื่อผู้ที่ย้ายสับเปลี่ยนตำแหน่งนี้");

    switch (body.node) {
      case 0: {
        const data = await this.orgRootRepository.findOne({
          where: { id: body.nodeId },
        });
        if (data != null) {
          profileChangePos.rootId = data.id;
          profileChangePos.root = data.orgRootName;
          profileChangePos.rootShortName = data.orgRootShortName;
        }
      }
      case 1: {
        const data = await this.child1Repository.findOne({
          where: { id: body.nodeId },
          relations: ["orgRoot"],
        });
        if (data != null) {
          profileChangePos.rootId = data.orgRoot.id;
          profileChangePos.root = data.orgRoot.orgRootName;
          profileChangePos.rootShortName = data.orgRoot.orgRootShortName;
          profileChangePos.child1Id = data.id;
          profileChangePos.child1 = data.orgChild1Name;
          profileChangePos.child1ShortName = data.orgChild1ShortName;
        }
      }
      case 2: {
        const data = await this.child2Repository.findOne({
          where: { id: body.nodeId },
          relations: ["orgRoot", "orgChild1"],
        });
        if (data != null) {
          profileChangePos.rootId = data.orgRoot.id;
          profileChangePos.root = data.orgRoot.orgRootName;
          profileChangePos.rootShortName = data.orgRoot.orgRootShortName;
          profileChangePos.child1Id = data.orgChild1.id;
          profileChangePos.child1 = data.orgChild1.orgChild1Name;
          profileChangePos.child1ShortName = data.orgChild1.orgChild1ShortName;
          profileChangePos.child2Id = data.id;
          profileChangePos.child2 = data.orgChild2Name;
          profileChangePos.child2ShortName = data.orgChild2ShortName;
        }
      }
      case 3: {
        const data = await this.child3Repository.findOne({
          where: { id: body.nodeId },
          relations: ["orgRoot", "orgChild1", "orgChild2"],
        });
        if (data != null) {
          profileChangePos.rootId = data.orgRoot.id;
          profileChangePos.root = data.orgRoot.orgRootName;
          profileChangePos.rootShortName = data.orgRoot.orgRootShortName;
          profileChangePos.child1Id = data.orgChild1.id;
          profileChangePos.child1 = data.orgChild1.orgChild1Name;
          profileChangePos.child1ShortName = data.orgChild1.orgChild1ShortName;
          profileChangePos.child2Id = data.orgChild2.id;
          profileChangePos.child2 = data.orgChild2.orgChild2Name;
          profileChangePos.child2ShortName = data.orgChild2.orgChild2ShortName;
          profileChangePos.child3Id = data.id;
          profileChangePos.child3 = data.orgChild3Name;
          profileChangePos.child3ShortName = data.orgChild3ShortName;
        }
      }
      case 4: {
        const data = await this.child4Repository.findOne({
          where: { id: body.nodeId },
          relations: ["orgRoot", "orgChild1", "orgChild2", "orgChild3"],
        });
        if (data != null) {
          profileChangePos.rootId = data.orgRoot.id;
          profileChangePos.root = data.orgRoot.orgRootName;
          profileChangePos.rootShortName = data.orgRoot.orgRootShortName;
          profileChangePos.child1Id = data.orgChild1.id;
          profileChangePos.child1 = data.orgChild1.orgChild1Name;
          profileChangePos.child1ShortName = data.orgChild1.orgChild1ShortName;
          profileChangePos.child2Id = data.orgChild2.id;
          profileChangePos.child2 = data.orgChild2.orgChild2Name;
          profileChangePos.child2ShortName = data.orgChild2.orgChild2ShortName;
          profileChangePos.child3Id = data.orgChild3.id;
          profileChangePos.child3 = data.orgChild3.orgChild3Name;
          profileChangePos.child3ShortName = data.orgChild3.orgChild3ShortName;
          profileChangePos.child4Id = data.id;
          profileChangePos.child4 = data.orgChild4Name;
          profileChangePos.child4ShortName = data.orgChild4ShortName;
        }
      }
    }

    profileChangePos.lastUpdateUserId = request.user.sub;
    profileChangePos.lastUpdateFullName = request.user.name;
    profileChangePos.node  = body.node;
    profileChangePos.nodeId  = body.nodeId;
    profileChangePos.orgRevisionId  = body.orgRevisionId;
    profileChangePos.posmasterId  = body.posmasterId;
    profileChangePos.posMasterNo  = body.posMasterNo;
    profileChangePos.positionId  = body.positionId;
    profileChangePos.position  = body.position;
    profileChangePos.positionField  = body.positionField;
    profileChangePos.posTypeId  = String(body.posTypeId);
    profileChangePos.posTypeName  = body.posTypeName;
    profileChangePos.posLevelId  = String(body.posLevelId);
    profileChangePos.posLevelName  = body.posLevelName;
    profileChangePos.status = "PENDING";
    await this.profileChangePositionRepository.save(profileChangePos);
    return new HttpSuccess();
  }


}