import {
  Controller,
  Post,
  Route,
  Security,
  Tags,
  Body,
  Request,
  SuccessResponse,
  Response,
  Get,
  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 { RequestWithUser } from "../middlewares/user";
import { setLogDataDiff } from "../interfaces/utils";
import { Personal, PostPersonal } from "../entities/Personal";
import permission from "../interfaces/permission";
import { Assign } from "../entities/Assign";

@Route("api/v1/probation/personal")
@Tags("Personal")
@Security("bearerAuth")
@Response(
  HttpStatusCode.INTERNAL_SERVER_ERROR,
  "เกิดข้อผิดพลาด ไม่สามารถแสดงรายการได้ กรุณาลองใหม่ในภายหลัง"
)
@SuccessResponse(HttpStatusCode.OK, "สำเร็จ")
export class PersonalController extends Controller {
  private personalRepository = AppDataSource.getRepository(Personal);
  private assignRepository = AppDataSource.getRepository(Assign);

  /**
   * API ข้อมูลบุคคลในระบบทดลองงาน
   *
   * @summary เพิ่มคนเข้าระบบทดลองงาน
   *
   */
  @Post("add")
  async AddPersonal(
    @Body() requestBody: PostPersonal,
    @Request() request: RequestWithUser
  ) {
    await new permission().PermissionCreate(request, "SYS_PROBATION");

    const checkPersonal: number = await this.personalRepository.count({
      where: { personal_id: requestBody.id },
    });
    if (checkPersonal > 0) {
      throw new HttpError(
        HttpStatusCode.BAD_REQUEST,
        "ผู้ทดลองปฏิบัติหน้าที่ราชการนี้มีอยู่แล้ว"
      );
    }

    let organization = await (requestBody.orgChild4Name
      ? requestBody.orgChild4Name + "/"
      : "");
    organization += await (requestBody.orgChild3Name
      ? requestBody.orgChild3Name + "/"
      : "");
    organization += await (requestBody.orgChild2Name
      ? requestBody.orgChild2Name + "/"
      : "");
    organization += await (requestBody.orgChild1Name
      ? requestBody.orgChild1Name + "/"
      : "");
    organization += await (requestBody.orgRootName
      ? requestBody.orgRootName
      : "");

    const personalData = Object.assign(new Personal());
    personalData.personal_id = requestBody.id;
    personalData.order_number = requestBody.order_number
      ? requestBody.order_number
      : "";
    personalData.probation_status = 1;
    personalData.createdUserId = request.user.sub;
    personalData.createdFullName = request.user.name;
    personalData.updateUserId = request.user.sub;
    personalData.updateFullName = request.user.name;

    personalData.idcard = requestBody.idcard;
    personalData.prefixName = requestBody.prefix;
    personalData.firstName = requestBody.firstName;
    personalData.lastName = requestBody.lastName;
    personalData.isProbation = requestBody.isProbation ? 1 : 0;
    personalData.positionLevelName = requestBody.posLevelName
      ? requestBody.posLevelName
      : "";
    personalData.positionName = requestBody.position
      ? requestBody.position
      : "";
    personalData.positionLineName = requestBody.posLineName;
    personalData.positionTypeName = requestBody.posTypeName;
    personalData.posNo = requestBody.posNo ? requestBody.posNo : "";
    personalData.orgRootName = requestBody.orgRootName;
    personalData.organization = organization;

    const before = null;
    const personal = await this.personalRepository.save(personalData, {
      data: request,
    });
    setLogDataDiff(request, { before, after: personal });

    return new HttpSuccess();
  }

  /**
   * API รายการบุคคลในระบบทดลองงาน
   *
   * @summary รายชื่อคนที่อยู่ในระบบทดลองงาน
   *
   */
  @Get("list")
  async ListPersonal(
    @Query() status: string = "",
    @Query("page") page: number = 1,
    @Query("pageSize") pageSize: number = 10,
    @Request() request: RequestWithUser
  ) {
    await new permission().PermissionList(request, "SYS_PROBATION");
    const conditions: any = {};
    if (status) {
      conditions.probation_status = status;
    }

    const [lists, total] = await this.personalRepository.findAndCount({
      order: { createdAt: "DESC" },
      where: conditions,
      skip: (page - 1) * pageSize,
      take: pageSize,
    });

    if (!lists) {
      throw new HttpError(
        HttpStatusCode.INTERNAL_SERVER_ERROR,
        "ไม่สามารถแสดงข้อมูลได้"
      );
    }

    let result: any = [];

    await Promise.all(
      lists.map(async (item, index) => {
        const probation_no = await this.assignRepository.count({
          where: {
            personal_id: item.personal_id,
          },
        });

        await result.push({
          personal_id: item.personal_id,
          ordering: index + 1,
          name: item.prefixName + item.firstName + " " + item.lastName,
          idcard: item.idcard,
          prefixName: item.prefixName,
          firstName: item.firstName,
          lastName: item.lastName,
          position_line: item.positionName,
          position_level: item.positionLevelName,
          position_type: item.positionTypeName,
          organization: item.organization,
          probation_no: probation_no,
          order_number: item.order_number,
          probation_status: item.probation_status,
        });
      })
    );

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

  /**
   * API ข้อมูลบุคคลในระบบทดลองงาน
   *
   * @summary ข้อมูลคนที่อยูาในระบบทดลองงาน
   *
   */
  @Get("")
  async GetPersonal(
    @Request() request: RequestWithUser,
    @Query() personal_id: string
  ) {
    await new permission().PermissionGet(request, "SYS_PROBATION");
    const person = await this.personalRepository.findOne({
      where: { personal_id: personal_id },
    });

    if (!person) {
      throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลบุคคล");
    }

    const probation_no = await this.assignRepository.count({
      where: { personal_id: person.personal_id },
    });

    const result = await {
      personal_id: person.personal_id,
      name: person.prefixName + person.firstName + " " + person.lastName,
      position_line: person.positionName,
      position_level: person.positionLevelName,
      position_type: person.positionTypeName,
      organization: person.organization,
      probation_no: probation_no,
      order_number: person.order_number,
      probation_status: person.probation_status,
    };

    return new HttpSuccess(result);
  }
}