checkpoint
This commit is contained in:
parent
b70f447174
commit
85f39a55a6
3 changed files with 260 additions and 166 deletions
|
|
@ -1,159 +1,236 @@
|
|||
// 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 { Like, Not } from "typeorm";
|
||||
// import HttpStatusCode from "../interfaces/http-status";
|
||||
// import { KpiLink, createKpiLink, updateKpiLink } from "../entities/kpiLink";
|
||||
// @Route("api/v1/kpi/link")
|
||||
// @Tags("kpiLink")
|
||||
// @Security("bearerAuth")
|
||||
// @Response(
|
||||
// HttpStatusCode.INTERNAL_SERVER_ERROR,
|
||||
// "เกิดข้อผิดพลาด ไม่สามารถแสดงรายการได้ กรุณาลองใหม่ในภายหลัง",
|
||||
// )
|
||||
// @SuccessResponse(HttpStatusCode.OK, "สำเร็จ")
|
||||
// export class kpiLinkController extends Controller {
|
||||
// private kpiLinkRepository = AppDataSource.getRepository(KpiLink);
|
||||
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 { Like, Not, In } from "typeorm";
|
||||
import HttpStatusCode from "../interfaces/http-status";
|
||||
import { KpiLink, createKpiLink, updateKpiLink } from "../entities/kpiLink";
|
||||
import { KpiGroup } from "../entities/kpiGroup";
|
||||
import { KpiCapacity } from "../entities/kpiCapacity";
|
||||
import { Position } from "../entities/position";
|
||||
@Route("api/v1/kpi/link")
|
||||
@Tags("kpiLink")
|
||||
@Security("bearerAuth")
|
||||
@Response(
|
||||
HttpStatusCode.INTERNAL_SERVER_ERROR,
|
||||
"เกิดข้อผิดพลาด ไม่สามารถแสดงรายการได้ กรุณาลองใหม่ในภายหลัง",
|
||||
)
|
||||
@SuccessResponse(HttpStatusCode.OK, "สำเร็จ")
|
||||
export class kpiLinkController extends Controller {
|
||||
private kpiGroupRepository = AppDataSource.getRepository(KpiGroup);
|
||||
private kpiLinkRepository = AppDataSource.getRepository(KpiLink);
|
||||
private kpiCapacityRepository = AppDataSource.getRepository(KpiCapacity);
|
||||
private positionRepository = AppDataSource.getRepository(Position);
|
||||
|
||||
// /**
|
||||
// * API สร้างเชื่อมโยง
|
||||
// * @param requestBody
|
||||
// * @returns
|
||||
// */
|
||||
// @Post()
|
||||
// @Example({
|
||||
// nameLinkKPI: "string", //ชื่อเชื่อมโยง
|
||||
// })
|
||||
// async createKpiLink(
|
||||
// @Body() requestBody: createKpiLink,
|
||||
// @Request() request: { user: Record<string, any> },
|
||||
// ) {
|
||||
// const kpiLink = Object.assign(new KpiLink(), requestBody);
|
||||
// const chkkpinameLink = await this.kpiLinkRepository.findOne({
|
||||
// where: {
|
||||
// nameLinkKPI: requestBody.nameLinkKPI,
|
||||
// },
|
||||
// });
|
||||
// if (chkkpinameLink) {
|
||||
// throw new HttpError(HttpStatusCode.NOT_FOUND, "ชื่อเชื่อมโยงนี้มีอยู่ในระบบแล้ว");
|
||||
// }
|
||||
// kpiLink.createdUserId = request.user.sub;
|
||||
// kpiLink.createdFullName = request.user.name;
|
||||
// kpiLink.lastUpdateUserId = request.user.sub;
|
||||
// kpiLink.lastUpdateFullName = request.user.name;
|
||||
// await this.kpiLinkRepository.save(kpiLink);
|
||||
// return new HttpSuccess(kpiLink.id);
|
||||
// }
|
||||
/**
|
||||
* API สร้างเชื่อมโยง
|
||||
* @param requestBody
|
||||
* @returns
|
||||
*/
|
||||
@Post()
|
||||
async createKpiLink(
|
||||
@Body() requestBody: createKpiLink,
|
||||
@Request() request: { user: Record<string, any> },
|
||||
) {
|
||||
const chkkpiGroup = await this.kpiGroupRepository.findOne({
|
||||
where: {
|
||||
id: requestBody.kpiGroupId,
|
||||
},
|
||||
});
|
||||
|
||||
if (!chkkpiGroup) {
|
||||
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลการเชื่อมโยง");
|
||||
}
|
||||
|
||||
const kpiLink = Object.assign(new KpiLink(), requestBody, {
|
||||
createdUserId: request.user.sub,
|
||||
createdFullName: request.user.name,
|
||||
lastUpdateUserId: request.user.sub,
|
||||
lastUpdateFullName: request.user.name,
|
||||
kpiGroup: chkkpiGroup,
|
||||
});
|
||||
await this.kpiLinkRepository.save(kpiLink);
|
||||
|
||||
if (requestBody.positions != null) {
|
||||
Promise.all(
|
||||
requestBody.positions.map(async (positionName) => {
|
||||
let position = new Position();
|
||||
position.name = positionName;
|
||||
position.kpiLinkId = kpiLink.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);
|
||||
}),
|
||||
);
|
||||
}
|
||||
|
||||
// /**
|
||||
// * API แก้ไขชื่อเชื่อมโยง
|
||||
// * @param id ไอดีของเชื่อมโยง
|
||||
// */
|
||||
// @Put("{id}")
|
||||
// async updateKpiLink(
|
||||
// @Path() id: string,
|
||||
// @Body() requestBody: updateKpiLink,
|
||||
// @Request() request: { user: Record<string, any> },
|
||||
// ) {
|
||||
// const kpiLink = await this.kpiLinkRepository.findOne({
|
||||
// where: { id: id },
|
||||
// });
|
||||
// if (!kpiLink) {
|
||||
// throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลเชื่อมโยงนี้");
|
||||
// }
|
||||
const chkCapacity = await this.kpiCapacityRepository.find({
|
||||
where: {
|
||||
id: In(requestBody.kpiCapacityIds),
|
||||
},
|
||||
});
|
||||
if (!chkCapacity) {
|
||||
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลการเชื่อมโยง");
|
||||
}
|
||||
kpiLink.kpiCapacitys = chkCapacity;
|
||||
|
||||
await this.kpiLinkRepository.save(kpiLink);
|
||||
|
||||
// const chkkpinameLink = await this.kpiLinkRepository.findOne({
|
||||
// where: {
|
||||
// nameLinkKPI: requestBody.nameLinkKPI,
|
||||
// },
|
||||
// });
|
||||
// if (chkkpinameLink) {
|
||||
// throw new HttpError(HttpStatusCode.NOT_FOUND, "ชื่อเชื่อมโยงนี้มีอยู่ในระบบแล้ว");
|
||||
// }
|
||||
// this.kpiLinkRepository.merge(kpiLink, requestBody);
|
||||
// kpiLink.lastUpdateUserId = request.user.sub;
|
||||
// kpiLink.lastUpdateFullName = request.user.name;
|
||||
// await this.kpiLinkRepository.save(kpiLink);
|
||||
// return new HttpSuccess(id);
|
||||
// }
|
||||
return new HttpSuccess(kpiLink.id);
|
||||
}
|
||||
|
||||
|
||||
// /**
|
||||
// * API ชื่อเชื่อมโยง
|
||||
// * @param id
|
||||
// */
|
||||
// @Get("{id}")
|
||||
// @Example({
|
||||
// nameLinkKPI: "string", //ชื่อเชื่อมโยง
|
||||
// })
|
||||
// async KpiLinkById(@Path() id: string) {
|
||||
// const kpiLink = await this.kpiLinkRepository.findOne({
|
||||
// where: { id: id },
|
||||
// select: ["nameLinkKPI"],
|
||||
// });
|
||||
// if (!kpiLink) {
|
||||
// throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลเชื่อมโยงนี้");
|
||||
// }
|
||||
// return new HttpSuccess(kpiLink);
|
||||
// }
|
||||
/**
|
||||
* API แก้ไขเชื่อมโยง
|
||||
* @param id ไอดีของเชื่อมโยง
|
||||
*/
|
||||
@Put("{id}")
|
||||
async updateKpiLink(
|
||||
@Path() id: string,
|
||||
@Body() requestBody: createKpiLink,
|
||||
@Request() request: { user: Record<string, any> },
|
||||
) {
|
||||
const chkKpiLink = await this.kpiLinkRepository.findOne({
|
||||
where: {
|
||||
id: id,
|
||||
},
|
||||
relations: {
|
||||
positions: true,
|
||||
kpiCapacitys: true,
|
||||
},
|
||||
})
|
||||
if (!chkKpiLink) {
|
||||
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลการเชื่อมโยง");
|
||||
}
|
||||
|
||||
// /**
|
||||
// * API ลบเชื่อมโยง
|
||||
// * @param id
|
||||
// */
|
||||
// @Delete("{id}")
|
||||
// async deleteKpiLink(@Path() id: string) {
|
||||
// const kpiLink = await this.kpiLinkRepository.findOne({
|
||||
// where: { id: id },
|
||||
// });
|
||||
// if (!kpiLink) {
|
||||
// throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลเชื่อมโยงนี้");
|
||||
// }
|
||||
await this.positionRepository.remove(chkKpiLink.positions);
|
||||
Object.assign(chkKpiLink, {
|
||||
...requestBody,
|
||||
positions: [],
|
||||
kpiCapacitys: [],
|
||||
});
|
||||
chkKpiLink.kpiGroupId = requestBody.kpiGroupId,
|
||||
chkKpiLink.lastUpdateUserId = request.user.sub;
|
||||
chkKpiLink.lastUpdateFullName = request.user.name;
|
||||
|
||||
if (requestBody.positions != null) {
|
||||
Promise.all(
|
||||
requestBody.positions.map(async (positionName) => {
|
||||
let position = new Position();
|
||||
position.name = positionName;
|
||||
position.kpiLinkId = chkKpiLink.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);
|
||||
}),
|
||||
);
|
||||
}
|
||||
|
||||
// await this.kpiLinkRepository.remove(kpiLink);
|
||||
// return new HttpSuccess();
|
||||
// }
|
||||
const chkCapacity = await this.kpiCapacityRepository.find({
|
||||
where: {
|
||||
id: In(requestBody.kpiCapacityIds),
|
||||
},
|
||||
});
|
||||
if (!chkCapacity) {
|
||||
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลการเชื่อมโยง");
|
||||
}
|
||||
chkKpiLink.kpiCapacitys = chkCapacity;
|
||||
|
||||
await this.kpiLinkRepository.save(chkKpiLink);
|
||||
|
||||
// /**
|
||||
// * API list เชื่อมโยง
|
||||
// * @param page
|
||||
// * @param pageSize
|
||||
// */
|
||||
// @Get()
|
||||
// async listKpiLink(
|
||||
// @Query("page") page: number = 1,
|
||||
// @Query("pageSize") pageSize: number = 10,
|
||||
// @Query("keyword") keyword?: string,
|
||||
// ) {
|
||||
// let whereClause: any = {};
|
||||
return new HttpSuccess(chkKpiLink.id);
|
||||
}
|
||||
|
||||
// if (keyword !== undefined && keyword !== "") {
|
||||
// whereClause = {
|
||||
// where: [{ nameLinkKPI: Like(`%${keyword}%`) }],
|
||||
// };
|
||||
// }
|
||||
/**
|
||||
* API เชื่อมโยง
|
||||
* @param id
|
||||
*/
|
||||
@Get("{id}")
|
||||
async KpiLinkById(@Path() id: string) {
|
||||
const kpiLink = await this.kpiLinkRepository.findOne({
|
||||
where: { id: id },
|
||||
relations:["positions","kpiCapacitys"]
|
||||
});
|
||||
if (!kpiLink) {
|
||||
throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลการเชื่อมโยง");
|
||||
}
|
||||
const formattedResponse = {
|
||||
id: kpiLink.id,
|
||||
positions: kpiLink.positions.map(position => ({
|
||||
id: position.id,
|
||||
name: position.name
|
||||
})),
|
||||
kpiCapacitys: kpiLink.kpiCapacitys.map(capacity => ({
|
||||
id: capacity.id ,
|
||||
name: capacity.name,
|
||||
type: capacity.type,
|
||||
description: capacity.description
|
||||
}))
|
||||
};
|
||||
return new HttpSuccess(kpiLink);
|
||||
}
|
||||
|
||||
// const [kpiLink, total] = await this.kpiLinkRepository.findAndCount({
|
||||
// ...whereClause,
|
||||
// ...(keyword ? {} : { skip: (page - 1) * pageSize, take: pageSize }),
|
||||
// });
|
||||
// /**
|
||||
// * API ลบเชื่อมโยง
|
||||
// * @param id
|
||||
// */
|
||||
// @Delete("{id}")
|
||||
// async deleteKpiLink(@Path() id: string) {
|
||||
// const kpiLink = await this.kpiLinkRepository.findOne({
|
||||
// where: { id: id },
|
||||
// });
|
||||
// if (!kpiLink) {
|
||||
// throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบข้อมูลการเชื่อมโยง");
|
||||
// }
|
||||
|
||||
// return new HttpSuccess({ data: kpiLink, total });
|
||||
// }
|
||||
// }
|
||||
// await this.kpiLinkRepository.remove(kpiLink);
|
||||
// return new HttpSuccess();
|
||||
// }
|
||||
|
||||
// /**
|
||||
// * API list เชื่อมโยง
|
||||
// * @param page
|
||||
// * @param pageSize
|
||||
// */
|
||||
// @Get()
|
||||
// async listKpiLink(
|
||||
// @Query("page") page: number = 1,
|
||||
// @Query("pageSize") pageSize: number = 10,
|
||||
// @Query("keyword") keyword?: string,
|
||||
// ) {
|
||||
// let whereClause: any = {};
|
||||
|
||||
// if (keyword !== undefined && keyword !== "") {
|
||||
// whereClause = {
|
||||
// where: [{ nameLinkKPI: Like(`%${keyword}%`) }],
|
||||
// };
|
||||
// }
|
||||
|
||||
// const [kpiLink, total] = await this.kpiLinkRepository.findAndCount({
|
||||
// ...whereClause,
|
||||
// ...(keyword ? {} : { skip: (page - 1) * pageSize, take: pageSize }),
|
||||
// });
|
||||
|
||||
// return new HttpSuccess({ data: kpiLink, total });
|
||||
// }
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue