hrms-api-org/src/controllers/ChangePositionController.ts
2024-10-18 11:33:04 +07:00

605 lines
24 KiB
TypeScript

import {
Controller,
Get,
Post,
Put,
Delete,
Route,
Security,
Tags,
Body,
Path,
Request,
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 { In, Not, Brackets } 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";
import CallAPI from "../interfaces/call-api";
@Route("api/v1/org/placement/change-position")
@Tags("Placement")
@Security("bearerAuth")
@Response(
HttpStatusCode.INTERNAL_SERVER_ERROR,
"เกิดข้อผิดพลาด ไม่สามารถแสดงรายการได้ กรุณาลองใหม่ในภายหลัง",
)
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.createdAt = new Date();
changePosition.lastUpdateUserId = request.user.sub;
changePosition.lastUpdateFullName = request.user.name;
changePosition.lastUpdatedAt = new Date();
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;
changePosition.lastUpdatedAt = new Date();
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")
.leftJoinAndSelect("changePosition.profileChangePosition", "profileChangePosition")
.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 รายการรายชื่อผู้ที่ย้ายสับเปลี่ยนตำแหน่ง สถานะเลือกตำแหน่งแล้ว (ADMIN)
*
*/
@Get("pending")
async getProfilePending() {
const profiles = await this.changePositionRepository.find({
relations: ["profileChangePosition"],
where: {
profileChangePosition: {
status: "PENDING",
},
},
});
return new HttpSuccess(profiles);
}
/**
* API รายละเอียดรอบย้ายสับเปลี่ยนตำแหน่ง
*
* @summary API รายละเอียดรอบย้ายสับเปลี่ยนตำแหน่ง (ADMIN)
*
* @param {string} id Id รอบย้ายสับเปลี่ยนตำแหน่ง
*/
@Get("{id}")
async GetChangePositionById(@Path() id: string) {
const data = await this.changePositionRepository.findOne({
relations: ["profileChangePosition"],
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.createdAt = new Date();
profiles.lastUpdateUserId = request.user.sub;
profiles.lastUpdateFullName = request.user.name;
profiles.lastUpdatedAt = new Date();
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 [profileChangePosition, total] = await AppDataSource.getRepository(ProfileChangePosition)
.createQueryBuilder("profileChangePosition")
.where({ changePositionId: changePositionId })
.andWhere(
new Brackets((qb) => {
qb.where(
searchKeyword != undefined && searchKeyword != null && searchKeyword != ""
? "profileChangePosition.prefix LIKE :keyword"
: "1=1",
{
keyword: `%${searchKeyword}%`,
},
)
.orWhere(
searchKeyword != undefined && searchKeyword != null && searchKeyword != ""
? "profileChangePosition.firstName LIKE :keyword"
: "1=1",
{
keyword: `%${searchKeyword}%`,
},
)
.orWhere(
searchKeyword != undefined && searchKeyword != null && searchKeyword != ""
? "profileChangePosition.lastName LIKE :keyword"
: "1=1",
{
keyword: `%${searchKeyword}%`,
},
)
.orWhere(
searchKeyword != undefined && searchKeyword != null && searchKeyword != ""
? "profileChangePosition.citizenId LIKE :keyword"
: "1=1",
{
keyword: `%${searchKeyword}%`,
},
)
.orWhere(
searchKeyword != undefined && searchKeyword != null && searchKeyword != ""
? "profileChangePosition.birthDate LIKE :keyword"
: "1=1",
{
keyword: `%${searchKeyword}%`,
},
)
.orWhere(
searchKeyword != undefined && searchKeyword != null && searchKeyword != ""
? "profileChangePosition.lastUpdatedAt LIKE :keyword"
: "1=1",
{
keyword: `%${searchKeyword}%`,
},
)
.orWhere(
searchKeyword != undefined && searchKeyword != null && searchKeyword != ""
? "profileChangePosition.status 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.lastUpdatedAt = new Date();
profileChangePos.educationOld = body.educationOld;
profileChangePos.posMasterNoOld = body.posMasterNoOld;
profileChangePos.positionTypeOld = body.positionTypeOld;
profileChangePos.positionLevelOld = body.positionLevelOld;
profileChangePos.organizationPositionOld = body.organizationPositionOld;
profileChangePos.amountOld = body.amountOld;
profileChangePos.reason = body.reason ? String(body.reason) : "";
profileChangePos.dateCurrent = body.dateCurrent;
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.lastUpdatedAt = new Date();
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();
}
/**
* API ออกคำสั่งย้ายสับเปลี่ยนตำแหน่ง REPORT
*
* @summary API ออกคำสั่งย้ายสับเปลี่ยนตำแหน่ง REPORT (ADMIN)
*
*/
@Post("report")
async sendReport(@Request() request: RequestWithUser, @Body() requestBody: { id: string[] }) {
const profilechangePositions = await this.changePositionRepository.find({
relations: ["profileChangePosition"],
where: { id: In(requestBody.id) },
});
for (const item of profilechangePositions) {
item.status = "REPORT";
item.lastUpdateUserId = request.user.sub;
item.lastUpdateFullName = request.user.name;
item.lastUpdatedAt = new Date();
if (item.profileChangePosition) {
for (const profile of item.profileChangePosition) {
profile.status = "REPORT";
profile.lastUpdateUserId = request.user.sub;
profile.lastUpdateFullName = request.user.name;
profile.lastUpdatedAt = new Date();
await this.profileChangePositionRepository.save(profile);
}
}
await this.changePositionRepository.save(item);
}
return new HttpSuccess();
}
/**
* API ออกคำสั่งย้ายสับเปลี่ยนตำแหน่ง DONE
*
* @summary API ออกคำสั่งย้ายสับเปลี่ยนตำแหน่ง DONE (ADMIN)
*
*/
@Post("report/resume")
async doneReport(
@Body()
body: {
result: {
id: string;
}[];
},
@Request() request: { user: Record<string, any> },
) {
await Promise.all(
body.result.map(async (v) => {
const profile = await this.profileChangePositionRepository.findOne({
where: { id: v.id },
});
if (profile != null) {
await new CallAPI()
.PostData(request, "/org/profile/salary", {
profileId: profile.id,
date: new Date(),
})
.then(async (x) => {
profile.status = "DONE";
await this.profileChangePositionRepository.save(profile);
});
}
}),
);
return new HttpSuccess();
}
}