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

1293 lines
46 KiB
TypeScript
Raw Normal View History

2024-01-30 15:10:11 +07:00
import {
Controller,
Get,
Post,
Put,
Delete,
Patch,
Route,
Security,
Tags,
Body,
Path,
Request,
Example,
SuccessResponse,
Response,
Query,
2024-01-30 15:10:11 +07:00
} from "tsoa";
import { AppDataSource } from "../database/data-source";
import HttpSuccess from "../interfaces/http-success";
import HttpStatusCode from "../interfaces/http-status";
import { PosExecutive } from "../entities/PosExecutive";
import { PosType } from "../entities/PosType";
import { PosLevel } from "../entities/PosLevel";
2024-01-30 16:47:39 +07:00
import { CreatePosDict, PosDict } from "../entities/PosDict";
2024-01-30 16:02:34 +07:00
import HttpError from "../interfaces/http-error";
import { Equal, ILike, In, IsNull, Like, Not } from "typeorm";
import { CreatePosMaster, PosMaster } from "../entities/PosMaster";
import { OrgRevision } from "../entities/OrgRevision";
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 { Position } from "../entities/Position";
import { Brackets } from "typeorm/browser";
2024-01-30 15:10:11 +07:00
@Route("api/v1/org/pos")
@Tags("Position")
@Security("bearerAuth")
@Response(
HttpStatusCode.INTERNAL_SERVER_ERROR,
"เกิดข้อผิดพลาด ไม่สามารถแสดงรายการได้ กรุณาลองใหม่ในภายหลัง",
)
@SuccessResponse(HttpStatusCode.OK, "สำเร็จ")
export class PositionController extends Controller {
private posExecutiveRepository = AppDataSource.getRepository(PosExecutive);
2024-01-30 16:02:34 +07:00
private posTypeRepository = AppDataSource.getRepository(PosType);
2024-01-30 15:10:11 +07:00
private posLevelRepository = AppDataSource.getRepository(PosLevel);
2024-01-30 16:47:39 +07:00
private posDictRepository = AppDataSource.getRepository(PosDict);
private posMasterRepository = AppDataSource.getRepository(PosMaster);
private positionRepository = AppDataSource.getRepository(Position);
private orgRevisionRepository = AppDataSource.getRepository(OrgRevision);
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);
2024-01-30 15:10:11 +07:00
2024-01-30 16:02:34 +07:00
/**
* API
*
* @summary ORG_030 - (ADMIN) #33
*
*/
@Post("position")
@Example([
{
positionName: "นักบริหาร",
positionField: "บริหาร",
posTypeId: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
posLevelId: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
posExecutiveId: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
positionExecutiveField: "นักบริหาร",
positionArea: "บริหาร",
2024-01-30 16:02:34 +07:00
},
])
async createPosition(
@Body()
requestBody: CreatePosDict,
@Request() request: { user: Record<string, any> },
) {
2024-01-30 16:47:39 +07:00
const posDict = Object.assign(new PosDict(), requestBody);
if (!posDict) {
2024-01-30 16:02:34 +07:00
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูล");
}
const checkPosTypeId = await this.posTypeRepository.findOne({
where: { id: requestBody.posTypeId },
});
2024-01-30 16:02:34 +07:00
if (!checkPosTypeId) {
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูล PosTypeId");
}
const checkPosLevelId = await this.posLevelRepository.findOne({
where: { id: requestBody.posLevelId },
});
2024-01-30 16:02:34 +07:00
if (!checkPosLevelId) {
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูล PosLevelId");
}
2024-02-01 17:31:55 +07:00
// const checkPosExecutiveId = await this.posExecutiveRepository.findOne({
// where: { id: requestBody.posExecutiveId },
// });
// if (!checkPosExecutiveId) {
// throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูล PosExecutiveId");
// }
2024-01-30 16:02:34 +07:00
try {
2024-01-30 16:47:39 +07:00
posDict.createdUserId = request.user.sub;
posDict.createdFullName = request.user.name;
posDict.lastUpdateUserId = request.user.sub;
posDict.lastUpdateFullName = request.user.name;
await this.posDictRepository.save(posDict);
return new HttpSuccess(posDict.id);
2024-01-30 16:02:34 +07:00
} catch (error) {
return error;
}
}
2024-01-30 16:47:39 +07:00
/**
* API
*
* @summary ORG_032 - (ADMIN) #40
*
* @param {string} id Id
*/
@Delete("position/{id}")
2024-01-30 16:47:39 +07:00
async delete(@Path() id: string) {
const delPosDict = await this.posDictRepository.findOne({ where: { id } });
if (!delPosDict) {
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลตำแหน่งตามไอดีนี้ : " + id);
}
try {
await this.posDictRepository.remove(delPosDict);
return new HttpSuccess();
} catch (error) {
return error;
}
}
/**
* API
*
* @summary ORG_029 - (ADMIN) #32
*
*/
@Get("position")
2024-01-31 15:02:54 +07:00
async findPosition(@Query("keyword") keyword?: string, @Query("type") type?: string) {
try {
let findPosDict: any;
2024-01-31 14:29:39 +07:00
switch (type) {
case "positionName":
2024-01-31 14:29:39 +07:00
findPosDict = await this.posDictRepository.find({
where: { posDictName: Like(`%${keyword}%`) },
2024-01-31 15:02:54 +07:00
relations: ["posType", "posLevel", "posExecutive"],
2024-01-31 14:29:39 +07:00
});
if (!findPosDict) {
2024-01-31 14:29:39 +07:00
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูล " + keyword);
}
break;
case "positionField":
2024-01-31 14:29:39 +07:00
findPosDict = await this.posDictRepository.find({
where: { posDictField: Like(`%${keyword}%`) },
2024-01-31 15:02:54 +07:00
relations: ["posType", "posLevel", "posExecutive"],
2024-01-31 14:29:39 +07:00
});
if (!findPosDict) {
2024-01-31 14:29:39 +07:00
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูล " + keyword);
}
break;
case "positionType":
2024-01-31 14:29:39 +07:00
const findTypes: PosType[] = await this.posTypeRepository.find({
where: { posTypeName: Like(`%${keyword}%`) },
2024-01-31 15:02:54 +07:00
select: ["id"],
});
findPosDict = await this.posDictRepository.find({
where: { posTypeId: In(findTypes.map((x) => x.id)) },
relations: ["posType", "posLevel", "posExecutive"],
2024-01-31 14:29:39 +07:00
});
break;
case "positionLevel":
2024-01-31 14:29:39 +07:00
const findLevel: PosLevel[] = await this.posLevelRepository.find({
where: { posLevelName: Like(`%${keyword}%`) },
2024-01-31 15:02:54 +07:00
select: ["id"],
});
findPosDict = await this.posDictRepository.find({
where: { posLevelId: In(findLevel.map((x) => x.id)) },
relations: ["posType", "posLevel", "posExecutive"],
2024-01-31 14:29:39 +07:00
});
break;
case "positionExecutive":
2024-01-31 14:29:39 +07:00
const findExecutive: PosExecutive[] = await this.posExecutiveRepository.find({
where: { posExecutiveName: Like(`%${keyword}%`) },
2024-01-31 15:02:54 +07:00
select: ["id"],
});
findPosDict = await this.posDictRepository.find({
where: { posExecutiveId: In(findExecutive.map((x) => x.id)) },
relations: ["posType", "posLevel", "posExecutive"],
2024-01-31 14:29:39 +07:00
});
break;
case "positionExecutiveField":
2024-01-31 14:29:39 +07:00
findPosDict = await this.posDictRepository.find({
where: { posDictExecutiveField: Like(`%${keyword}%`) },
2024-01-31 15:02:54 +07:00
relations: ["posType", "posLevel", "posExecutive"],
2024-01-31 14:29:39 +07:00
});
if (!findPosDict) {
2024-01-31 14:29:39 +07:00
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูล " + keyword);
}
break;
case "positionArea":
2024-01-31 14:29:39 +07:00
findPosDict = await this.posDictRepository.find({
where: { posDictArea: Like(`%${keyword}%`) },
2024-01-31 15:02:54 +07:00
relations: ["posType", "posLevel", "posExecutive"],
2024-01-31 14:29:39 +07:00
});
if (!findPosDict) {
2024-01-31 14:29:39 +07:00
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูล " + keyword);
}
break;
default:
2024-01-31 15:02:54 +07:00
findPosDict = await this.posDictRepository.find({
relations: ["posType", "posLevel", "posExecutive"],
});
if (!findPosDict) {
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูล");
}
break;
}
2024-01-31 14:29:39 +07:00
const mapDataPosDict = await Promise.all(
findPosDict.map(async (item: any) => {
return {
id: item.id,
positionName: item.posDictName,
positionField: item.posDictField,
posTypeId: item.posTypeId,
2024-01-31 15:02:54 +07:00
posTypeName: item.posType == null ? null : item.posType.posTypeName,
2024-01-31 14:29:39 +07:00
posLevelId: item.posLevelId,
2024-01-31 15:02:54 +07:00
posLevelName: item.posLevel == null ? null : item.posLevel.posLevelName,
2024-01-31 14:29:39 +07:00
posExecutiveId: item.posExecutiveId,
2024-01-31 15:02:54 +07:00
posExecutiveName: item.posExecutive == null ? null : item.posExecutive.posExecutiveName,
2024-01-31 14:29:39 +07:00
positionExecutiveField: item.posDictExecutiveField,
positionArea: item.posDictArea,
positionIsSelected: false,
};
}),
);
return new HttpSuccess(mapDataPosDict);
2024-01-31 14:29:39 +07:00
} catch (error) {
return error;
}
}
/**
* API
*
* @summary ORG_033 - (ADMIN) #35
*
*/
@Post("master")
@Example({
posMasterNoPrefix: "กบ.",
posMasterNo: 1,
posMasterNoSuffix: "ช",
posId: ["08db9e81-fc46-4e95-8b33-be4ca0016abf", "08db9e81-fc46-4e95-8b33-be4ca0016abf"],
orgRootId: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
orgChild1Id: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
orgChild2Id: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
orgChild3Id: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
orgChild4Id: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
positions: [
{
posDictName: "นักบริหาร",
posDictField: "บริหาร",
posTypeId: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
posLevelId: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
posExecutiveId: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
posDictExecutiveField: "นักบริหาร",
posDictArea: "บริหาร",
},
],
})
async createMaster(
@Body()
requestBody: CreatePosMaster,
@Request() request: { user: Record<string, any> },
) {
const posMaster = Object.assign(new PosMaster(), requestBody);
if (!posMaster) {
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูล");
}
2024-01-31 18:24:38 +07:00
let orgRoot: any = null;
if (requestBody.orgRootId != null)
orgRoot = await this.orgRootRepository.findOne({
where: { id: requestBody.orgRootId },
});
2024-01-31 18:24:38 +07:00
if (!orgRoot) {
let orgChild1: any = null;
if (requestBody.orgChild1Id != null)
orgChild1 = await this.child1Repository.findOne({
where: { id: requestBody.orgChild1Id },
});
2024-01-31 18:24:38 +07:00
if (!orgChild1) {
let orgChild2: any = null;
if (requestBody.orgChild2Id != null)
orgChild2 = await this.child2Repository.findOne({
where: { id: requestBody.orgChild2Id },
});
2024-01-31 18:24:38 +07:00
if (!orgChild2) {
let orgChild3: any = null;
if (requestBody.orgChild3Id != null)
orgChild3 = await this.child3Repository.findOne({
where: { id: requestBody.orgChild3Id },
});
2024-01-31 18:24:38 +07:00
if (!orgChild3) {
let orgChild4: any = null;
if (requestBody.orgChild4Id != null)
orgChild4 = await this.child4Repository.findOne({
where: { id: requestBody.orgChild4Id },
});
if (!orgChild4) {
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลโครงสร้าง");
} else {
posMaster.orgRootId = orgChild4.orgRootId;
posMaster.orgChild1Id = orgChild4.orgChild1Id;
posMaster.orgChild2Id = orgChild4.orgChild2Id;
posMaster.orgChild3Id = orgChild4.orgChild3Id;
posMaster.orgChild4Id = orgChild4.id;
posMaster.orgRevisionId = orgChild4.orgRevisionId;
}
} else {
posMaster.orgRootId = orgChild3.orgRootId;
posMaster.orgChild1Id = orgChild3.orgChild1Id;
posMaster.orgChild2Id = orgChild3.orgChild2Id;
posMaster.orgChild3Id = orgChild3.id;
posMaster.orgRevisionId = orgChild3.orgRevisionId;
}
} else {
posMaster.orgRootId = orgChild2.orgRootId;
posMaster.orgChild1Id = orgChild2.orgChild1Id;
posMaster.orgChild2Id = orgChild2.id;
posMaster.orgRevisionId = orgChild2.orgRevisionId;
}
} else {
posMaster.orgRootId = orgChild1.orgRootId;
posMaster.orgChild1Id = orgChild1.id;
posMaster.orgRevisionId = orgChild1.orgRevisionId;
}
} else {
posMaster.orgRootId = orgRoot.id;
posMaster.orgRevisionId = orgRoot.orgRevisionId;
}
posMaster.createdUserId = request.user.sub;
posMaster.createdFullName = request.user.name;
posMaster.lastUpdateUserId = request.user.sub;
posMaster.lastUpdateFullName = request.user.name;
await this.posMasterRepository.save(posMaster);
requestBody.positions.forEach(async (x: any) => {
const position = Object.assign(new Position());
position.positionName = x.posDictName;
position.positionField = x.posDictField;
position.posTypeId = x.posTypeId;
position.posLevelId = x.posLevelId;
position.posExecutiveId = x.posExecutiveId;
position.positionExecutiveField = x.posDictExecutiveField;
position.positionArea = x.posDictArea;
position.positionIsSelected = false;
position.posMasterId = posMaster.id;
position.createdUserId = request.user.sub;
position.createdFullName = request.user.name;
position.lastUpdateUserId = request.user.sub;
position.lastUpdateFullName = request.user.name;
await this.positionRepository.save(position);
});
return new HttpSuccess(posMaster.id);
}
/**
2024-02-01 13:29:15 +07:00
* API
*
2024-02-01 13:29:15 +07:00
* @summary ORG_034 - (ADMIN) #37
*
*/
@Put("master/{id}")
@Example({
posMasterNoPrefix: "กบ.",
2024-01-31 17:20:08 +07:00
posMasterNo: "1",
posMasterNoSuffix: "ช",
posId: ["08db9e81-fc46-4e95-8b33-be4ca0016abf", "08db9e81-fc46-4e95-8b33-be4ca0016abf"],
orgRootId: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
orgChild1Id: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
orgChild2Id: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
orgChild3Id: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
orgChild4Id: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
positions: [
{
posDictName: "นักบริหาร",
posDictField: "บริหาร",
posTypeId: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
posLevelId: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
posExecutiveId: "08db9e81-fc46-4e95-8b33-be4ca0016abf",
posDictExecutiveField: "นักบริหาร",
posDictArea: "บริหาร",
},
],
})
async updateMaster(
@Path() id: string,
@Body()
requestBody: CreatePosMaster,
@Request() request: { user: Record<string, any> },
) {
const posMaster = await this.posMasterRepository.findOne({ where: { id: id } });
if (!posMaster) {
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลอัตรากำลัง");
}
posMaster.orgRootId = null;
posMaster.orgChild1Id = null;
posMaster.orgChild2Id = null;
posMaster.orgChild3Id = null;
posMaster.orgChild4Id = null;
2024-01-31 18:24:38 +07:00
let orgRoot: any = null;
if (requestBody.orgRootId != null)
orgRoot = await this.orgRootRepository.findOne({
where: { id: requestBody.orgRootId },
});
2024-01-31 18:24:38 +07:00
if (!orgRoot) {
let orgChild1: any = null;
if (requestBody.orgChild1Id != null)
orgChild1 = await this.child1Repository.findOne({
where: { id: requestBody.orgChild1Id },
});
2024-01-31 18:24:38 +07:00
if (!orgChild1) {
let orgChild2: any = null;
if (requestBody.orgChild2Id != null)
orgChild2 = await this.child2Repository.findOne({
where: { id: requestBody.orgChild2Id },
});
2024-01-31 18:24:38 +07:00
if (!orgChild2) {
let orgChild3: any = null;
if (requestBody.orgChild3Id != null)
orgChild3 = await this.child3Repository.findOne({
where: { id: requestBody.orgChild3Id },
});
2024-01-31 18:24:38 +07:00
if (!orgChild3) {
let orgChild4: any = null;
if (requestBody.orgChild4Id != null)
orgChild4 = await this.child4Repository.findOne({
where: { id: requestBody.orgChild4Id },
});
if (!orgChild4) {
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลโครงสร้าง");
} else {
posMaster.orgRootId = orgChild4.orgRootId;
posMaster.orgChild1Id = orgChild4.orgChild1Id;
posMaster.orgChild2Id = orgChild4.orgChild2Id;
posMaster.orgChild3Id = orgChild4.orgChild3Id;
posMaster.orgChild4Id = orgChild4.id;
posMaster.orgRevisionId = orgChild4.orgRevisionId;
}
} else {
posMaster.orgRootId = orgChild3.orgRootId;
posMaster.orgChild1Id = orgChild3.orgChild1Id;
posMaster.orgChild2Id = orgChild3.orgChild2Id;
posMaster.orgChild3Id = orgChild3.id;
posMaster.orgRevisionId = orgChild3.orgRevisionId;
}
} else {
posMaster.orgRootId = orgChild2.orgRootId;
posMaster.orgChild1Id = orgChild2.orgChild1Id;
posMaster.orgChild2Id = orgChild2.id;
posMaster.orgRevisionId = orgChild2.orgRevisionId;
}
} else {
posMaster.orgRootId = orgChild1.orgRootId;
posMaster.orgChild1Id = orgChild1.id;
posMaster.orgRevisionId = orgChild1.orgRevisionId;
}
} else {
posMaster.orgRootId = orgRoot.id;
posMaster.orgRevisionId = orgRoot.orgRevisionId;
}
posMaster.createdUserId = request.user.sub;
posMaster.createdFullName = request.user.name;
posMaster.lastUpdateUserId = request.user.sub;
posMaster.lastUpdateFullName = request.user.name;
await this.posMasterRepository.save(posMaster);
await this.positionRepository.delete({ posMasterId: posMaster.id });
requestBody.positions.forEach(async (x: any) => {
const position = Object.assign(new Position());
position.positionName = x.posDictName;
position.positionField = x.posDictField;
position.posTypeId = x.posTypeId;
position.posLevelId = x.posLevelId;
position.posExecutiveId = x.posExecutiveId;
position.positionExecutiveField = x.posDictExecutiveField;
position.positionArea = x.posDictArea;
position.positionIsSelected = false;
position.posMasterId = posMaster.id;
position.createdUserId = request.user.sub;
position.createdFullName = request.user.name;
position.lastUpdateUserId = request.user.sub;
position.lastUpdateFullName = request.user.name;
await this.positionRepository.save(position);
});
return new HttpSuccess(posMaster.id);
}
2024-01-31 14:29:39 +07:00
/**
* API
*
* @summary ORG_037 - (ADMIN) #36
*
*/
2024-01-31 16:11:49 +07:00
@Get("position/{id}")
2024-01-31 16:12:07 +07:00
async detailPosition(@Path() id: string) {
2024-01-31 14:29:39 +07:00
try {
const posMaster = await this.posMasterRepository.findOne({
where: { id },
});
if (!posMaster) {
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูล");
}
const positions = await this.positionRepository.find({
2024-01-31 14:29:39 +07:00
where: { posMasterId: posMaster.id },
2024-02-01 15:44:32 +07:00
relations: ["posType", "posLevel", "posExecutive"],
2024-01-31 14:29:39 +07:00
});
const formattedData = {
id: posMaster.id,
posMasterNoPrefix: posMaster.posMasterNoPrefix,
posMasterNo: posMaster.posMasterNo,
posMasterNoSuffix: posMaster.posMasterNoSuffix,
positions: positions.map((position) => ({
id: position.id,
positionName: position.positionName,
positionField: position.positionField,
posTypeId: position.posTypeId,
posTypeName: position.posType == null ? null : position.posType.posTypeName,
posLevelId: position.posLevelId,
posLevelName: position.posLevel == null ? null : position.posLevel.posLevelName,
posExecutiveId: position.posExecutiveId,
posExecutiveName:
position.posExecutive == null ? null : position.posExecutive.posExecutiveName,
positionExecutiveField: position.positionExecutiveField,
positionArea: position.positionArea,
positionIsSelected: position.positionIsSelected,
})),
};
return new HttpSuccess(formattedData);
} catch (error) {
return error;
}
}
/**
* API
*
* @summary ORG_035 - (ADMIN) #38
*
* @param {string} id Id
*/
@Delete("master/{id}")
async deletePosMaster(@Path() id: string) {
const delPosMaster = await this.posMasterRepository.findOne({
where: { id },
// relations: ["position"],
});
if (!delPosMaster) {
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลตำแหน่งตามไอดีนี้ : " + id);
}
try {
await this.positionRepository.delete({ posMasterId: id });
await this.posMasterRepository.delete({ id });
return new HttpSuccess();
} catch (error) {
return error;
}
}
2024-01-31 17:22:45 +07:00
/**
* API
*
* @summary ORG_053 - (ADMIN) #56
*
*/
@Post("master/list")
async list(
@Body()
body: {
id: string;
type: number;
2024-01-31 17:51:49 +07:00
isAll: boolean;
page: number;
pageSize: number;
keyword?: string;
2024-01-31 17:22:45 +07:00
},
) {
try {
let typeCondition: any = {};
let checkChildConditions: any = {};
if (body.type === 0) {
typeCondition = {
orgRootId: body.id,
};
if (!body.isAll) {
checkChildConditions = {
orgChild1Id: IsNull(),
};
}
} else if (body.type === 1) {
typeCondition = {
orgChild1Id: body.id,
};
if (!body.isAll) {
checkChildConditions = {
orgChild2Id: IsNull(),
};
}
} else if (body.type === 2) {
typeCondition = {
orgChild2Id: body.id,
};
if (!body.isAll) {
checkChildConditions = {
orgChild3Id: IsNull(),
};
}
} else if (body.type === 3) {
typeCondition = {
orgChild3Id: body.id,
};
if (!body.isAll) {
checkChildConditions = {
orgChild4Id: IsNull(),
};
}
} else if (body.type === 4) {
typeCondition = {
orgChild4Id: body.id,
};
}
let findPosition: any;
let masterId = new Array();
const findTypes: PosType[] = await this.posTypeRepository.find({
where: { posTypeName: Like(`%${body.keyword}%`) },
select: ["id"],
});
findPosition = await this.positionRepository.find({
where: { posTypeId: In(findTypes.map((x) => x.id)) },
select: ["posMasterId"],
});
masterId = masterId.concat(findPosition.map((position: any) => position.posMasterId));
const findLevel: PosLevel[] = await this.posLevelRepository.find({
where: { posLevelName: Like(`%${body.keyword}%`) },
select: ["id"],
});
findPosition = await this.positionRepository.find({
where: { posLevelId: In(findLevel.map((x) => x.id)) },
select: ["posMasterId"],
});
masterId = masterId.concat(findPosition.map((position: any) => position.posMasterId));
const findExecutive: PosExecutive[] = await this.posExecutiveRepository.find({
where: { posExecutiveName: Like(`%${body.keyword}%`) },
select: ["id"],
});
findPosition = await this.positionRepository.find({
where: { posExecutiveId: In(findExecutive.map((x) => x.id)) },
select: ["posMasterId"],
});
masterId = masterId.concat(findPosition.map((position: any) => position.posMasterId));
findPosition = await this.positionRepository.find({
where: { positionName: Like(`%${body.keyword}%`) },
select: ["posMasterId"],
});
masterId = masterId.concat(findPosition.map((position: any) => position.posMasterId));
2024-02-03 13:09:44 +07:00
let keywordAsInt: any;
keywordAsInt = body.keyword == null ? null : parseInt(body.keyword, 10);
if (isNaN(keywordAsInt)) {
keywordAsInt = "";
}
masterId = [...new Set(masterId)];
const posMaster = await this.posMasterRepository.find({
2024-02-03 13:09:44 +07:00
where: [
{
...checkChildConditions,
...typeCondition,
},
{
...checkChildConditions,
...typeCondition,
id: In(masterId),
},
{
...checkChildConditions,
...typeCondition,
posMasterNo: Like(`%${keywordAsInt}%`),
},
],
order: { posMasterOrder: "ASC" },
relations: ["orgRoot", "orgChild1", "orgChild2", "orgChild3", "orgChild4"],
skip: (body.page - 1) * body.pageSize,
take: body.pageSize,
});
const total = posMaster.length;
const formattedData = await Promise.all(
posMaster.map(async (posMaster) => {
const positions = await this.positionRepository.find({
where: {
posMasterId: posMaster.id,
},
relations: ["posLevel", "posType", "posExecutive"],
});
2024-01-31 18:24:38 +07:00
return {
id: posMaster.id,
2024-02-03 13:09:44 +07:00
orgRootId: posMaster.orgRootId,
orgChild1Id: posMaster.orgChild1Id,
orgChild2Id: posMaster.orgChild2Id,
orgChild3Id: posMaster.orgChild3Id,
orgChild4Id: posMaster.orgChild4Id,
posMasterNoPrefix: posMaster.posMasterNoPrefix,
posMasterNo: posMaster.posMasterNo,
posMasterNoSuffix: posMaster.posMasterNoSuffix,
orgShortname:
body.type === 0
? posMaster.orgRoot.orgRootShortName
: body.type === 1
? posMaster.orgChild1.orgChild1ShortName
: body.type === 2
? posMaster.orgChild2.orgChild2ShortName
: body.type === 3
? posMaster.orgChild3.orgChild3ShortName
: body.type === 4
? posMaster.orgChild4.orgChild4ShortName
: "-",
positions: positions.map((position) => ({
id: position.id,
positionName: position.positionName,
positionField: position.positionField,
posTypeId: position.posTypeId,
posTypeName: position.posType == null ? null : position.posType.posTypeName,
posLevelId: position.posLevelId,
posLevelName: position.posLevel == null ? null : position.posLevel.posLevelName,
posExecutiveId: position.posExecutiveId,
posExecutiveName:
position.posExecutive == null ? null : position.posExecutive.posExecutiveName,
positionExecutiveField: position.positionExecutiveField,
positionArea: position.positionArea,
positionIsSelected: position.positionIsSelected,
})),
};
}),
);
return new HttpSuccess({ data: formattedData, total });
2024-01-31 17:22:45 +07:00
} catch (error) {
return error;
}
}
/**
2024-02-01 15:06:28 +07:00
* API
*
* @summary ORG_040 - (ADMIN) #43
*
*/
@Post("sort")
async Sort(@Body() requestBody: { id: string; type: number; sortId: string[] }) {
try {
switch (requestBody.type) {
case 0: {
const rootId = await this.posMasterRepository.findOne({
where: { orgRootId: requestBody.id },
});
if (!rootId?.id) {
2024-02-01 15:06:28 +07:00
throw new HttpError(HttpStatusCode.NOT_FOUND, "not found rootId: " + requestBody.id);
}
const listPosMasterId_0 = await this.posMasterRepository.find({
2024-02-01 15:06:28 +07:00
where: {
orgRootId: requestBody.id,
orgChild1Id: IsNull(),
orgChild2Id: IsNull(),
orgChild3Id: IsNull(),
orgChild4Id: IsNull(),
},
select: ["id", "posMasterOrder"],
});
if (!listPosMasterId_0) {
throw new HttpError(HttpStatusCode.NOT_FOUND, "not found masterId type 0.");
}
const sortData_0 = listPosMasterId_0.map((data) => ({
id: data.id,
posMasterOrder: requestBody.sortId.indexOf(data.id) + 1,
}));
await this.posMasterRepository.save(sortData_0);
break;
}
case 1: {
const child1Id = await this.posMasterRepository.findOne({
where: { orgChild1Id: requestBody.id },
});
if (!child1Id?.id) {
2024-02-01 15:06:28 +07:00
throw new HttpError(HttpStatusCode.NOT_FOUND, "not found child1Id: " + requestBody.id);
}
const listPosMasterId_1 = await this.posMasterRepository.find({
2024-02-01 15:06:28 +07:00
where: {
orgRootId: Not(IsNull()),
orgChild1Id: requestBody.id,
orgChild2Id: IsNull(),
orgChild3Id: IsNull(),
orgChild4Id: IsNull(),
},
select: ["id", "posMasterOrder"],
});
if (!listPosMasterId_1) {
throw new HttpError(HttpStatusCode.NOT_FOUND, "not found masterId type 1.");
}
const sortData_1 = listPosMasterId_1.map((data) => ({
id: data.id,
posMasterOrder: requestBody.sortId.indexOf(data.id) + 1,
}));
await this.posMasterRepository.save(sortData_1);
break;
}
case 2: {
const child2Id = await this.posMasterRepository.findOne({
where: { orgChild2Id: requestBody.id },
});
if (!child2Id?.id) {
2024-02-01 15:06:28 +07:00
throw new HttpError(HttpStatusCode.NOT_FOUND, "not found child2Id: " + requestBody.id);
}
const listPosMasterId_2 = await this.posMasterRepository.find({
2024-02-01 15:06:28 +07:00
where: {
orgRootId: Not(IsNull()),
orgChild1Id: Not(IsNull()),
orgChild2Id: requestBody.id,
orgChild3Id: IsNull(),
orgChild4Id: IsNull(),
},
select: ["id", "posMasterOrder"],
});
if (!listPosMasterId_2) {
throw new HttpError(HttpStatusCode.NOT_FOUND, "not found masterId type 2.");
}
const sortData_2 = listPosMasterId_2.map((data) => ({
id: data.id,
posMasterOrder: requestBody.sortId.indexOf(data.id) + 1,
}));
await this.posMasterRepository.save(sortData_2);
break;
}
case 3: {
const child3Id = await this.posMasterRepository.findOne({
where: { orgChild3Id: requestBody.id },
});
if (!child3Id?.id) {
2024-02-01 15:06:28 +07:00
throw new HttpError(HttpStatusCode.NOT_FOUND, "not found chil3Id: " + requestBody.id);
}
const listPosMasterId_3 = await this.posMasterRepository.find({
2024-02-01 15:06:28 +07:00
where: {
orgRootId: Not(IsNull()),
orgChild1Id: Not(IsNull()),
orgChild2Id: Not(IsNull()),
orgChild3Id: requestBody.id,
orgChild4Id: IsNull(),
},
select: ["id", "posMasterOrder"],
});
if (!listPosMasterId_3) {
throw new HttpError(HttpStatusCode.NOT_FOUND, "not found masterId type 3.");
}
const sortData_3 = listPosMasterId_3.map((data) => ({
id: data.id,
posMasterOrder: requestBody.sortId.indexOf(data.id) + 1,
}));
await this.posMasterRepository.save(sortData_3);
break;
}
case 4: {
const child4Id = await this.posMasterRepository.findOne({
where: { orgChild4Id: requestBody.id },
});
if (!child4Id?.id) {
2024-02-01 15:06:28 +07:00
throw new HttpError(HttpStatusCode.NOT_FOUND, "not found child4Id: " + requestBody.id);
}
const listPosMasterId_4 = await this.posMasterRepository.find({
2024-02-01 15:06:28 +07:00
where: {
orgRootId: Not(IsNull()),
orgChild1Id: Not(IsNull()),
orgChild2Id: Not(IsNull()),
orgChild3Id: Not(IsNull()),
orgChild4Id: requestBody.id,
},
select: ["id", "posMasterOrder"],
});
if (!listPosMasterId_4) {
throw new HttpError(HttpStatusCode.NOT_FOUND, "not found masterId type 4.");
}
const sortData_4 = listPosMasterId_4.map((data) => ({
id: data.id,
posMasterOrder: requestBody.sortId.indexOf(data.id) + 1,
}));
await this.posMasterRepository.save(sortData_4);
break;
}
default:
throw new HttpError(HttpStatusCode.NOT_FOUND, "not found type: " + requestBody.type);
}
return new HttpSuccess();
} catch (error) {
return error;
}
}
2024-02-01 15:21:23 +07:00
/**
* API
*
* @summary ORG_054 - (ADMIN) #58
*
* @param {string} id Id
*/
@Get("history/{id}")
async getHistoryPosMater(@Path() id: string) {
const posMaster = await this.posMasterRepository.findOne({
where: { id },
});
if (!posMaster) {
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลตำแหน่งตามไอดีนี้ : " + id);
}
const posMasters = await this.posMasterRepository.find({
where: { ancestorDNA: posMaster.ancestorDNA },
order: { lastUpdatedAt: "DESC" },
relations: ["orgRoot", "orgChild1", "orgChild2", "orgChild3", "orgChild4"],
});
const _data = posMasters.map((item) => ({
id: item.id,
orgShortName:
item.orgRoot == null
? "-"
: item.orgChild1 == null
? item.orgRoot.orgRootShortName
: item.orgChild2 == null
? item.orgChild1.orgChild1ShortName
: item.orgChild3 == null
? item.orgChild2.orgChild2ShortName
: item.orgChild4 == null
? item.orgChild3.orgChild3ShortName
: item.orgChild4.orgChild4ShortName,
lastUpdatedAt: item.lastUpdatedAt,
posMasterNoPrefix: item.posMasterNoPrefix,
posMasterNo: item.posMasterNo,
posMasterNoSuffix: item.posMasterNoSuffix,
}));
return new HttpSuccess(_data);
}
/**
* API
*
* @summary ORG_054 - (ADMIN) #59
*
*/
@Post("move")
async movePosMaster(
@Body() requestBody: { id: string; type: number; positionMaster: string[] },
@Request() request: { user: Record<string, any> },
) {
try {
const posMasters = await this.posMasterRepository.find({
where: { id: In(requestBody.positionMaster) },
});
posMasters.forEach(async (posMaster: any) => {
posMaster.orgRootId = null;
posMaster.orgChild1Id = null;
posMaster.orgChild2Id = null;
posMaster.orgChild3Id = null;
posMaster.orgChild4Id = null;
if (requestBody.type == 0) {
const org = await this.orgRootRepository.findOne({
where: { id: requestBody.id },
});
if (org != null) {
posMaster.orgRootId = org.id;
posMaster.orgRevisionId = org.orgRevisionId;
}
}
if (requestBody.type == 1) {
const org = await this.child1Repository.findOne({
where: { id: requestBody.id },
});
if (org != null) {
posMaster.orgRootId = org.orgRootId;
posMaster.orgChild1Id = org.id;
posMaster.orgRevisionId = org.orgRevisionId;
}
}
if (requestBody.type == 2) {
const org = await this.child2Repository.findOne({
where: { id: requestBody.id },
});
if (org != null) {
posMaster.orgRootId = org.orgRootId;
posMaster.orgChild1Id = org.orgChild1Id;
posMaster.orgChild2Id = org.id;
posMaster.orgRevisionId = org.orgRevisionId;
}
}
if (requestBody.type == 3) {
const org = await this.child3Repository.findOne({
where: { id: requestBody.id },
});
if (org != null) {
posMaster.orgRootId = org.orgRootId;
posMaster.orgChild1Id = org.orgChild1Id;
posMaster.orgChild2Id = org.orgChild2Id;
posMaster.orgChild3Id = org.id;
posMaster.orgRevisionId = org.orgRevisionId;
}
}
if (requestBody.type == 4) {
const org = await this.child4Repository.findOne({
where: { id: requestBody.id },
});
if (org != null) {
posMaster.orgRootId = org.orgRootId;
posMaster.orgChild1Id = org.orgChild1Id;
posMaster.orgChild2Id = org.orgChild2Id;
posMaster.orgChild3Id = org.orgChild3Id;
posMaster.orgChild4Id = org.id;
posMaster.orgRevisionId = org.orgRevisionId;
}
}
posMaster.createdUserId = request.user.sub;
posMaster.createdFullName = request.user.name;
posMaster.lastUpdateUserId = request.user.sub;
posMaster.lastUpdateFullName = request.user.name;
await this.posMasterRepository.save(posMaster);
});
return new HttpSuccess();
} catch (error) {
return error;
}
}
/**
* API
*
* @summary ORG_055 - (ADMIN) #60
*
*/
@Post("summary")
2024-02-03 13:09:44 +07:00
async PositionSummary(@Body() requestBody: { id: string; type: number }) {
try {
let summary: any;
let totalPosition: any;
let totalPositionCurrentUse: any;
let totalPositionCurrentVacant: any;
let totalPositionNextUse: any;
let totalPositionNextVacant: any;
2024-02-03 13:09:44 +07:00
switch (requestBody.type) {
case 0: {
2024-02-03 13:09:44 +07:00
const NodeId = await this.posMasterRepository.findOne({
where: { orgRootId: requestBody.id },
});
if (!NodeId) {
throw new HttpError(
HttpStatusCode.NOT_FOUND,
"ไม่พบข้อมูลตามไอดีนี้ : " + requestBody.id,
);
}
2024-02-03 13:09:44 +07:00
totalPosition = await this.posMasterRepository.count({
where: { orgRootId: requestBody.id },
});
2024-02-03 13:09:44 +07:00
totalPositionCurrentUse = await this.posMasterRepository.count({
where: {
orgRootId: requestBody.id,
profileIdCurrentHolder: Not(IsNull()) && Not(""),
},
});
2024-02-03 13:09:44 +07:00
totalPositionCurrentVacant = await this.posMasterRepository.count({
where: {
orgRootId: requestBody.id,
profileIdCurrentHolder: IsNull() && "",
},
});
2024-02-03 13:09:44 +07:00
totalPositionNextUse = await this.posMasterRepository.count({
where: {
orgRootId: requestBody.id,
profileIdNextHolder: Not(IsNull()) && Not(""),
},
});
2024-02-03 13:09:44 +07:00
totalPositionNextVacant = await this.posMasterRepository.count({
where: {
orgRootId: requestBody.id,
profileIdNextHolder: IsNull() && "",
},
});
break;
}
case 1: {
2024-02-03 13:09:44 +07:00
const NodeId = await this.posMasterRepository.findOne({
where: { orgChild1Id: requestBody.id },
});
if (!NodeId) {
throw new HttpError(
HttpStatusCode.NOT_FOUND,
"ไม่พบข้อมูลตามไอดีนี้ : " + requestBody.id,
);
}
totalPosition = await this.posMasterRepository.count({
where: { orgChild1Id: requestBody.id },
});
2024-02-03 13:09:44 +07:00
totalPositionCurrentUse = await this.posMasterRepository.count({
where: {
orgChild1Id: requestBody.id,
profileIdCurrentHolder: Not(IsNull()) && Not(""),
},
});
2024-02-03 13:09:44 +07:00
totalPositionCurrentVacant = await this.posMasterRepository.count({
where: {
orgChild1Id: requestBody.id,
profileIdCurrentHolder: IsNull() && "",
},
});
2024-02-03 13:09:44 +07:00
totalPositionNextUse = await this.posMasterRepository.count({
where: {
orgChild1Id: requestBody.id,
profileIdNextHolder: Not(IsNull()) && Not(""),
},
});
2024-02-03 13:09:44 +07:00
totalPositionNextVacant = await this.posMasterRepository.count({
where: {
orgChild1Id: requestBody.id,
profileIdNextHolder: IsNull() && "",
},
});
break;
}
case 2: {
2024-02-03 13:09:44 +07:00
const NodeId = await this.posMasterRepository.findOne({
where: { orgChild2Id: requestBody.id },
});
if (!NodeId) {
throw new HttpError(
HttpStatusCode.NOT_FOUND,
"ไม่พบข้อมูลตามไอดีนี้ : " + requestBody.id,
);
}
totalPosition = await this.posMasterRepository.count({
where: { orgChild2Id: requestBody.id },
});
2024-02-03 13:09:44 +07:00
totalPositionCurrentUse = await this.posMasterRepository.count({
where: {
orgChild2Id: requestBody.id,
profileIdCurrentHolder: Not(IsNull()) && Not(""),
},
});
2024-02-03 13:09:44 +07:00
totalPositionCurrentVacant = await this.posMasterRepository.count({
where: {
orgChild2Id: requestBody.id,
profileIdCurrentHolder: IsNull() && "",
},
});
2024-02-03 13:09:44 +07:00
totalPositionNextUse = await this.posMasterRepository.count({
where: {
orgChild2Id: requestBody.id,
profileIdNextHolder: Not(IsNull()) && Not(""),
},
});
2024-02-03 13:09:44 +07:00
totalPositionNextVacant = await this.posMasterRepository.count({
where: {
orgChild2Id: requestBody.id,
profileIdNextHolder: IsNull() && "",
},
});
break;
}
case 3: {
2024-02-03 13:09:44 +07:00
const NodeId = await this.posMasterRepository.findOne({
where: { orgChild3Id: requestBody.id },
});
if (!NodeId) {
throw new HttpError(
HttpStatusCode.NOT_FOUND,
"ไม่พบข้อมูลตามไอดีนี้ : " + requestBody.id,
);
}
totalPosition = await this.posMasterRepository.count({
where: { orgChild3Id: requestBody.id },
});
2024-02-03 13:09:44 +07:00
totalPositionCurrentUse = await this.posMasterRepository.count({
where: {
orgChild3Id: requestBody.id,
profileIdCurrentHolder: Not(IsNull()) && Not(""),
},
});
2024-02-03 13:09:44 +07:00
totalPositionCurrentVacant = await this.posMasterRepository.count({
where: {
orgChild3Id: requestBody.id,
profileIdCurrentHolder: IsNull() && "",
},
});
2024-02-03 13:09:44 +07:00
totalPositionNextUse = await this.posMasterRepository.count({
where: {
orgChild3Id: requestBody.id,
profileIdNextHolder: Not(IsNull()) && Not(""),
},
});
2024-02-03 13:09:44 +07:00
totalPositionNextVacant = await this.posMasterRepository.count({
where: {
orgChild3Id: requestBody.id,
profileIdNextHolder: IsNull() && "",
},
});
break;
}
case 4: {
2024-02-03 13:09:44 +07:00
const NodeId = await this.posMasterRepository.findOne({
where: { orgChild4Id: requestBody.id },
});
if (!NodeId) {
throw new HttpError(
HttpStatusCode.NOT_FOUND,
"ไม่พบข้อมูลตามไอดีนี้ : " + requestBody.id,
);
}
totalPosition = await this.posMasterRepository.count({
where: { orgChild4Id: requestBody.id },
});
2024-02-03 13:09:44 +07:00
totalPositionCurrentUse = await this.posMasterRepository.count({
where: {
orgChild4Id: requestBody.id,
profileIdCurrentHolder: Not(IsNull()) && Not(""),
},
});
2024-02-03 13:09:44 +07:00
totalPositionCurrentVacant = await this.posMasterRepository.count({
where: {
orgChild4Id: requestBody.id,
profileIdCurrentHolder: IsNull() && "",
},
});
2024-02-03 13:09:44 +07:00
totalPositionNextUse = await this.posMasterRepository.count({
where: {
orgChild4Id: requestBody.id,
profileIdNextHolder: Not(IsNull()) && Not(""),
},
});
2024-02-03 13:09:44 +07:00
totalPositionNextVacant = await this.posMasterRepository.count({
where: {
orgChild4Id: requestBody.id,
profileIdNextHolder: IsNull() && "",
},
});
break;
}
default:
break;
}
2024-02-03 13:09:44 +07:00
summary = {
totalPosition: totalPosition,
totalPositionCurrentUse: totalPositionCurrentUse,
totalPositionCurrentVacant: totalPositionCurrentVacant,
totalPositionNextUse: totalPositionNextUse,
2024-02-03 13:09:44 +07:00
totalPositionNextVacant: totalPositionNextVacant,
};
return new HttpSuccess(summary);
} catch (error) {
return error;
}
}
2024-01-30 15:10:11 +07:00
}