800 lines
30 KiB
TypeScript
800 lines
30 KiB
TypeScript
import {
|
|
Body,
|
|
Controller,
|
|
Delete,
|
|
Get,
|
|
Patch,
|
|
Path,
|
|
Post,
|
|
Request,
|
|
Route,
|
|
Security,
|
|
Tags,
|
|
} from "tsoa";
|
|
import { AppDataSource } from "../database/data-source";
|
|
import { CreateProfileSalary, ProfileSalary, UpdateProfileSalary } from "../entities/ProfileSalary";
|
|
import HttpSuccess from "../interfaces/http-success";
|
|
import HttpStatus from "../interfaces/http-status";
|
|
import HttpError from "../interfaces/http-error";
|
|
import { ProfileSalaryHistory } from "../entities/ProfileSalaryHistory";
|
|
import { RequestWithUser } from "../middlewares/user";
|
|
import { Profile } from "../entities/Profile";
|
|
import { ProfileEmployee } from "../entities/ProfileEmployee";
|
|
import { In, IsNull, LessThan, MoreThan, Not } from "typeorm";
|
|
import permission from "../interfaces/permission";
|
|
import { setLogDataDiff } from "../interfaces/utils";
|
|
import { TenurePositionOfficer } from "../entities/TenurePositionOfficer";
|
|
import { TenureLevelOfficer } from "../entities/TenureLevelOfficer";
|
|
import { TenurePositionEmployee } from "../entities/TenurePositionEmployee";
|
|
import { TenureLevelEmployee } from "../entities/TenureLevelEmployee";
|
|
@Route("api/v1/org/profile/salary")
|
|
@Tags("ProfileSalary")
|
|
@Security("bearerAuth")
|
|
export class ProfileSalaryController extends Controller {
|
|
private profileRepo = AppDataSource.getRepository(Profile);
|
|
private profileEmployeeRepo = AppDataSource.getRepository(ProfileEmployee);
|
|
private salaryRepo = AppDataSource.getRepository(ProfileSalary);
|
|
private salaryHistoryRepo = AppDataSource.getRepository(ProfileSalaryHistory);
|
|
private positionOfficerRepo = AppDataSource.getRepository(TenurePositionOfficer);
|
|
private positionEmployeeRepo = AppDataSource.getRepository(TenurePositionEmployee);
|
|
private levelOfficerRepo = AppDataSource.getRepository(TenureLevelOfficer);
|
|
private levelEmployeeRepo = AppDataSource.getRepository(TenureLevelEmployee);
|
|
|
|
@Get("TenurePositionOfficer")
|
|
public async cronjobTenurePositionOfficer() {
|
|
let data: any = [];
|
|
await this.positionOfficerRepo.clear();
|
|
const profile = await this.profileRepo.find();
|
|
for await (const x of profile) {
|
|
const position = await AppDataSource.query("CALL GetProfileSalaryPosition(?)", [x.id]);
|
|
const _position = position.length > 0 ? position[0] : [];
|
|
const mapPosition =
|
|
_position.length > 1
|
|
? _position.slice(1).map((curr: any, index: number) => ({
|
|
days_diff: curr.days_diff,
|
|
positionName: _position[index]?.positionName,
|
|
}))
|
|
: [];
|
|
const calDayDiff = mapPosition
|
|
.filter((curr: any) => curr.positionName == x.position)
|
|
.reduce(
|
|
(acc: any, curr: any) => {
|
|
acc.days_diff += Number(curr.days_diff) || 0;
|
|
acc.positionName = curr.positionName;
|
|
return acc;
|
|
},
|
|
{ days_diff: 0, positionName: null },
|
|
);
|
|
const mapData: any = {
|
|
profileId: x.id,
|
|
positionName: calDayDiff.positionName,
|
|
days_diff: calDayDiff.days_diff,
|
|
Years: (calDayDiff.days_diff / 365.2524).toFixed(4),
|
|
Months: ((calDayDiff.days_diff / 30.4375) % 12).toFixed(4),
|
|
Days: (calDayDiff.days_diff % 30.4375).toFixed(4),
|
|
};
|
|
// data.push(_mapData);
|
|
await this.positionOfficerRepo.save(mapData);
|
|
}
|
|
// await this.positionOfficerRepo.save(data);
|
|
|
|
return new HttpSuccess();
|
|
}
|
|
@Get("TenurePositionEmployee")
|
|
public async cronjobTenurePositionEmployee() {
|
|
let data: any = [];
|
|
await this.positionEmployeeRepo.clear();
|
|
const profile = await this.profileEmployeeRepo.find();
|
|
for await (const x of profile) {
|
|
const position = await AppDataSource.query("CALL GetProfileEmployeeSalaryPosition(?)", [
|
|
x.id,
|
|
]);
|
|
const _position = position.length > 0 ? position[0] : [];
|
|
const mapPosition =
|
|
_position.length > 1
|
|
? _position.slice(1).map((curr: any, index: number) => ({
|
|
days_diff: curr.days_diff,
|
|
positionName: _position[index]?.positionName,
|
|
}))
|
|
: [];
|
|
const calDayDiff = mapPosition
|
|
.filter((curr: any) => curr.positionName == x.position)
|
|
.reduce(
|
|
(acc: any, curr: any) => {
|
|
acc.days_diff += Number(curr.days_diff) || 0;
|
|
acc.positionName = curr.positionName;
|
|
return acc;
|
|
},
|
|
{ days_diff: 0, positionName: null },
|
|
);
|
|
const mapData: any = {
|
|
profileEmployeeId: x.id,
|
|
positionName: calDayDiff.positionName,
|
|
days_diff: calDayDiff.days_diff,
|
|
Years: (calDayDiff.days_diff / 365.2524).toFixed(4),
|
|
Months: ((calDayDiff.days_diff / 30.4375) % 12).toFixed(4),
|
|
Days: (calDayDiff.days_diff % 30.4375).toFixed(4),
|
|
};
|
|
// data.push(_mapData);
|
|
await this.positionEmployeeRepo.save(mapData);
|
|
}
|
|
// await this.positionEmployeeRepo.save(data);
|
|
|
|
return new HttpSuccess();
|
|
}
|
|
@Get("TenureLevelOfficer")
|
|
public async cronjobTenureLevelOfficer() {
|
|
let data: any = [];
|
|
await this.levelOfficerRepo.clear();
|
|
const profile = await this.profileRepo.find({ relations: ["posLevel", "posType"] });
|
|
for await (const x of profile) {
|
|
const positionLevel = await AppDataSource.query("CALL GetProfileSalaryLevel(?)", [x.id]);
|
|
const _positionLevel = positionLevel.length > 0 ? positionLevel[0] : [];
|
|
const mapPositionLevel =
|
|
_positionLevel.length > 1
|
|
? _positionLevel.slice(1).map((curr: any, index: number) => ({
|
|
days_diff: curr.days_diff,
|
|
positionType: _positionLevel[index]?.positionType,
|
|
positionLevel: _positionLevel[index]?.positionLevel,
|
|
positionCee: _positionLevel[index]?.positionCee,
|
|
}))
|
|
: [];
|
|
const calDayDiff = mapPositionLevel
|
|
.filter(
|
|
(curr: any) =>
|
|
curr.positionLevel == (x.posLevel?.posLevelName ?? null) &&
|
|
curr.positionType == (x.posType?.posTypeName ?? null),
|
|
)
|
|
.reduce(
|
|
(acc: any, curr: any) => {
|
|
acc.days_diff += Number(curr.days_diff) || 0;
|
|
acc.positionType = curr.positionType;
|
|
acc.positionLevel = curr.positionLevel;
|
|
acc.positionCee = curr.positionCee;
|
|
return acc;
|
|
},
|
|
{ days_diff: 0, positionType: null, positionLevel: null, positionCee: null },
|
|
);
|
|
const mapData: any = {
|
|
profileId: x.id,
|
|
positionType: calDayDiff.positionType,
|
|
positionLevel: calDayDiff.positionLevel,
|
|
positionCee: calDayDiff.positionCee,
|
|
days_diff: calDayDiff.days_diff,
|
|
Years: x.posLevel == null ? 0 : (calDayDiff.days_diff / 365.2524).toFixed(4),
|
|
Months: x.posLevel == null ? 0 : ((calDayDiff.days_diff / 30.4375) % 12).toFixed(4),
|
|
Days: x.posLevel == null ? 0 : (calDayDiff.days_diff % 30.4375).toFixed(4),
|
|
};
|
|
// data.push(_mapData);
|
|
await this.levelOfficerRepo.save(mapData);
|
|
}
|
|
// await this.levelOfficerRepo.save(data);
|
|
|
|
return new HttpSuccess();
|
|
}
|
|
@Get("TenureLevelEmployee")
|
|
public async cronjobTenureLevelEmployee() {
|
|
let data: any = [];
|
|
await this.levelEmployeeRepo.clear();
|
|
const profile = await this.profileEmployeeRepo.find({ relations: ["posLevel", "posType"] });
|
|
for await (const x of profile) {
|
|
const positionLevel = await AppDataSource.query("CALL GetProfileEmployeeSalaryLevel(?)", [
|
|
x.id,
|
|
]);
|
|
const _positionLevel = positionLevel.length > 0 ? positionLevel[0] : [];
|
|
const mapPositionLevel =
|
|
_positionLevel.length > 1
|
|
? _positionLevel.slice(1).map((curr: any, index: number) => ({
|
|
days_diff: curr.days_diff,
|
|
positionType: _positionLevel[index]?.positionType,
|
|
positionLevel: _positionLevel[index]?.positionLevel,
|
|
positionCee: _positionLevel[index]?.positionCee,
|
|
}))
|
|
: [];
|
|
const calDayDiff = mapPositionLevel
|
|
.filter(
|
|
(curr: any) =>
|
|
curr.positionLevel == (x.posLevel?.posLevelName ?? null) &&
|
|
curr.positionType == (x.posType?.posTypeName ?? null),
|
|
)
|
|
.reduce(
|
|
(acc: any, curr: any) => {
|
|
acc.days_diff += Number(curr.days_diff) || 0;
|
|
acc.positionType = curr.positionType;
|
|
acc.positionLevel = curr.positionLevel;
|
|
acc.positionCee = curr.positionCee;
|
|
return acc;
|
|
},
|
|
{ days_diff: 0, positionType: null, positionLevel: null, positionCee: null },
|
|
);
|
|
const mapData: any = {
|
|
profileEmployeeId: x.id,
|
|
positionType: calDayDiff.positionType,
|
|
positionLevel: calDayDiff.positionLevel,
|
|
positionCee: calDayDiff.positionCee,
|
|
days_diff: calDayDiff.days_diff,
|
|
Years: x.posLevel == null ? 0 : (calDayDiff.days_diff / 365.2524).toFixed(4),
|
|
Months: x.posLevel == null ? 0 : ((calDayDiff.days_diff / 30.4375) % 12).toFixed(4),
|
|
Days: x.posLevel == null ? 0 : (calDayDiff.days_diff % 30.4375).toFixed(4),
|
|
};
|
|
// data.push(_mapData);
|
|
await this.levelEmployeeRepo.save(mapData);
|
|
}
|
|
// await this.levelEmployeeRepo.save(data);
|
|
|
|
return new HttpSuccess();
|
|
}
|
|
|
|
@Get("user")
|
|
public async getSalaryUser(@Request() request: { user: Record<string, any> }) {
|
|
const profile = await this.profileRepo.findOneBy({ keycloak: request.user.sub });
|
|
if (!profile) {
|
|
throw new HttpError(HttpStatus.BAD_REQUEST, "ไม่พบ profile ดังกล่าว");
|
|
}
|
|
const record = await this.salaryRepo.find({
|
|
where: { profileId: profile.id, commandCode: In(["5", "6", "7"]) },
|
|
order: { order: "ASC" },
|
|
});
|
|
return new HttpSuccess(record);
|
|
}
|
|
|
|
@Get("position/user")
|
|
public async getSalaryPositionUser(@Request() request: { user: Record<string, any> }) {
|
|
const profile = await this.profileRepo.findOneBy({ keycloak: request.user.sub });
|
|
if (!profile) {
|
|
throw new HttpError(HttpStatus.BAD_REQUEST, "ไม่พบ profile ดังกล่าว");
|
|
}
|
|
const record = await this.salaryRepo.find({
|
|
where: [
|
|
{
|
|
profileId: profile.id,
|
|
commandCode: In([
|
|
"0",
|
|
"9",
|
|
"1",
|
|
"2",
|
|
"3",
|
|
"4",
|
|
"8",
|
|
"10",
|
|
"11",
|
|
"12",
|
|
"13",
|
|
"14",
|
|
"15",
|
|
"16",
|
|
]),
|
|
},
|
|
{ profileId: profile.id, commandCode: IsNull() },
|
|
],
|
|
order: { order: "ASC" },
|
|
// order: { commandDateAffect: "ASC" },
|
|
});
|
|
return new HttpSuccess(record);
|
|
}
|
|
|
|
@Get("{profileId}")
|
|
public async getSalary(@Path() profileId: string, @Request() req: RequestWithUser) {
|
|
let _workflow = await new permission().Workflow(req, profileId, "SYS_REGISTRY_OFFICER");
|
|
if (_workflow == false)
|
|
await new permission().PermissionOrgUserGet(req, "SYS_REGISTRY_OFFICER", profileId);
|
|
const record = await this.salaryRepo.find({
|
|
where: { profileId: profileId, commandCode: In(["5", "6", "7"]) },
|
|
order: { order: "ASC" },
|
|
});
|
|
return new HttpSuccess(record);
|
|
}
|
|
|
|
@Get("position/{profileId}")
|
|
public async getPositionSalary(@Path() profileId: string, @Request() req: RequestWithUser) {
|
|
let _workflow = await new permission().Workflow(req, profileId, "SYS_REGISTRY_OFFICER");
|
|
if (_workflow == false)
|
|
await new permission().PermissionOrgUserGet(req, "SYS_REGISTRY_OFFICER", profileId);
|
|
const record = await this.salaryRepo.find({
|
|
where: [
|
|
{
|
|
profileId: profileId,
|
|
commandCode: In([
|
|
"0",
|
|
"9",
|
|
"1",
|
|
"2",
|
|
"3",
|
|
"4",
|
|
"8",
|
|
"10",
|
|
"11",
|
|
"12",
|
|
"13",
|
|
"14",
|
|
"15",
|
|
"16",
|
|
]),
|
|
},
|
|
{ profileId: profileId, commandCode: IsNull() },
|
|
],
|
|
order: { order: "ASC" },
|
|
// order: { commandDateAffect: "ASC" },
|
|
});
|
|
return new HttpSuccess(record);
|
|
}
|
|
|
|
@Get("tenure/user")
|
|
public async getPositionTenureUser(@Request() request: { user: Record<string, any> }) {
|
|
// const sql_mode = await AppDataSource.query(
|
|
// "SET SESSION sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY',''));",
|
|
// );
|
|
const profile = await this.profileRepo.findOneBy({ keycloak: request.user.sub });
|
|
if (!profile) {
|
|
throw new HttpError(HttpStatus.BAD_REQUEST, "ไม่พบ profile ดังกล่าว");
|
|
}
|
|
const position = await AppDataSource.query("CALL GetProfileSalaryPosition(?)", [profile.id]);
|
|
const _position = position.length > 0 ? position[0] : [];
|
|
|
|
const mapPosition =
|
|
_position.length > 1
|
|
? _position.slice(1).map((curr: any, index: number) => ({
|
|
days: curr.days_diff ? Number(curr.days_diff) : 0,
|
|
name: _position[index]?.positionName,
|
|
}))
|
|
: [];
|
|
|
|
const groupMapPosition = mapPosition.reduce(
|
|
(acc: any, curr: any) => {
|
|
let existing = acc.find((item: any) => item.name === curr.name);
|
|
|
|
if (existing) {
|
|
existing.days += curr.days;
|
|
} else {
|
|
existing = { name: curr.name, days: curr.days };
|
|
acc.push(existing);
|
|
}
|
|
|
|
// Recalculate year, month, and day
|
|
existing.year = Math.floor(existing.days / 365.2524);
|
|
existing.month = Math.floor((existing.days / 30.4375) % 12);
|
|
existing.day = Math.floor(existing.days % 30.4375);
|
|
|
|
return acc;
|
|
},
|
|
[] as { name: string; days: number; year: number; month: number; day: number }[],
|
|
);
|
|
|
|
const posLevel = await AppDataSource.query("CALL GetProfileSalaryLevel(?)", [profile.id]);
|
|
const _posLevel = posLevel.length > 0 ? posLevel[0] : [];
|
|
const mapPosLevel =
|
|
_posLevel.length > 1
|
|
? _posLevel.slice(1).map((curr: any, index: number) => ({
|
|
days: curr.days_diff ? Number(curr.days_diff) : 0,
|
|
name:
|
|
!_posLevel[index]?.positionType && _posLevel[index]?.positionCee
|
|
? `ระดับ ${_posLevel[index]?.positionCee.trim()}`
|
|
: _posLevel[index]?.positionType == "บริหาร" ||
|
|
_posLevel[index]?.positionType == "อำนวยการ"
|
|
? `${_posLevel[index]?.positionType}${_posLevel[index]?.positionLevel}`
|
|
: _posLevel[index]?.positionLevel,
|
|
}))
|
|
: [];
|
|
|
|
const groupMapPosLevel = mapPosLevel.reduce(
|
|
(acc: any, curr: any) => {
|
|
let existing = acc.find((item: any) => item.name === curr.name);
|
|
|
|
if (existing) {
|
|
existing.days += curr.days;
|
|
} else {
|
|
existing = { name: curr.name, days: curr.days };
|
|
acc.push(existing);
|
|
}
|
|
|
|
// Recalculate year, month, and day
|
|
existing.year = Math.floor(existing.days / 365.2524);
|
|
existing.month = Math.floor((existing.days / 30.4375) % 12);
|
|
existing.day = Math.floor(existing.days % 30.4375);
|
|
|
|
return acc;
|
|
},
|
|
[] as { name: string; days: number; year: number; month: number; day: number }[],
|
|
);
|
|
|
|
const posExecutive = await AppDataSource.query("CALL GetProfileSalaryExecutive(?)", [
|
|
profile.id,
|
|
]);
|
|
const _posExecutive = posExecutive.length > 0 ? posExecutive[0] : [];
|
|
const mapPosExecutive =
|
|
_posExecutive.length > 1
|
|
? _posExecutive.slice(1).map((curr: any, index: number) => ({
|
|
days: curr.days_diff ? Number(curr.days_diff) : 0,
|
|
name: _posExecutive[index]?.positionExecutive,
|
|
}))
|
|
: [];
|
|
|
|
const groupMapPosExecutive = mapPosExecutive.reduce(
|
|
(acc: any, curr: any) => {
|
|
let existing = acc.find((item: any) => item.name === curr.name);
|
|
|
|
if (existing) {
|
|
existing.days += curr.days;
|
|
} else {
|
|
existing = { name: curr.name, days: curr.days };
|
|
acc.push(existing);
|
|
}
|
|
|
|
// Recalculate year, month, and day
|
|
existing.year = Math.floor(existing.days / 365.2524);
|
|
existing.month = Math.floor((existing.days / 30.4375) % 12);
|
|
existing.day = Math.floor(existing.days % 30.4375);
|
|
|
|
return acc;
|
|
},
|
|
[] as { name: string; days: number; year: number; month: number; day: number }[],
|
|
);
|
|
|
|
return new HttpSuccess({
|
|
position: groupMapPosition,
|
|
posLevel: groupMapPosLevel,
|
|
posExecutive: groupMapPosExecutive,
|
|
});
|
|
}
|
|
|
|
@Get("tenure/{profileId}")
|
|
public async getPositionTenure(@Path() profileId: string, @Request() req: RequestWithUser) {
|
|
// const sql_mode = await AppDataSource.query(
|
|
// "SET SESSION sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY',''));",
|
|
// );
|
|
const position = await AppDataSource.query("CALL GetProfileSalaryPosition(?)", [profileId]);
|
|
const _position = position.length > 0 ? position[0] : [];
|
|
|
|
const mapPosition =
|
|
_position.length > 1
|
|
? _position.slice(1).map((curr: any, index: number) => ({
|
|
days: curr.days_diff ? Number(curr.days_diff) : 0,
|
|
// year: curr.Years ? Math.floor(Number(curr.Years)) : 0,
|
|
// month: curr.Months ? Math.floor(Number(curr.Months)) : 0,
|
|
// day: curr.Days ? Math.floor(Number(curr.Days)) : 0,
|
|
name: _position[index]?.positionName,
|
|
}))
|
|
: [];
|
|
|
|
const groupMapPosition = mapPosition.reduce(
|
|
(acc: any, curr: any) => {
|
|
let existing = acc.find((item: any) => item.name === curr.name);
|
|
|
|
if (existing) {
|
|
existing.days += curr.days;
|
|
} else {
|
|
existing = { name: curr.name, days: curr.days };
|
|
acc.push(existing);
|
|
}
|
|
|
|
// Recalculate year, month, and day
|
|
existing.year = Math.floor(existing.days / 365.2524);
|
|
existing.month = Math.floor((existing.days / 30.4375) % 12);
|
|
existing.day = Math.floor(existing.days % 30.4375);
|
|
|
|
return acc;
|
|
},
|
|
[] as { name: string; days: number; year: number; month: number; day: number }[],
|
|
);
|
|
|
|
const posLevel = await AppDataSource.query("CALL GetProfileSalaryLevel(?)", [profileId]);
|
|
const _posLevel = posLevel.length > 0 ? posLevel[0] : [];
|
|
const mapPosLevel =
|
|
_posLevel.length > 1
|
|
? _posLevel.slice(1).map((curr: any, index: number) => ({
|
|
days: curr.days_diff ? Number(curr.days_diff) : 0,
|
|
// year: curr.Years ? Math.floor(Number(curr.Years)) : 0,
|
|
// month: curr.Months ? Math.floor(Number(curr.Months)) : 0,
|
|
// day: curr.Days ? Math.floor(Number(curr.Days)) : 0,
|
|
name:
|
|
!_posLevel[index]?.positionType && _posLevel[index]?.positionCee
|
|
? `ระดับ ${_posLevel[index]?.positionCee.trim()}`
|
|
: _posLevel[index]?.positionType == "บริหาร" ||
|
|
_posLevel[index]?.positionType == "อำนวยการ"
|
|
? `${_posLevel[index]?.positionType}${_posLevel[index]?.positionLevel}`
|
|
: _posLevel[index]?.positionLevel,
|
|
}))
|
|
: [];
|
|
|
|
const groupMapPosLevel = mapPosLevel.reduce(
|
|
(acc: any, curr: any) => {
|
|
let existing = acc.find((item: any) => item.name === curr.name);
|
|
|
|
if (existing) {
|
|
existing.days += curr.days;
|
|
} else {
|
|
existing = { name: curr.name, days: curr.days };
|
|
acc.push(existing);
|
|
}
|
|
|
|
// Recalculate year, month, and day
|
|
existing.year = Math.floor(existing.days / 365.2524);
|
|
existing.month = Math.floor((existing.days / 30.4375) % 12);
|
|
existing.day = Math.floor(existing.days % 30.4375);
|
|
|
|
return acc;
|
|
},
|
|
[] as { name: string; days: number; year: number; month: number; day: number }[],
|
|
);
|
|
|
|
const posExecutive = await AppDataSource.query("CALL GetProfileSalaryExecutive(?)", [
|
|
profileId,
|
|
]);
|
|
const _posExecutive = posExecutive.length > 0 ? posExecutive[0] : [];
|
|
const mapPosExecutive =
|
|
_posExecutive.length > 1
|
|
? _posExecutive.slice(1).map((curr: any, index: number) => ({
|
|
// year: curr.Years ? Math.floor(Number(curr.Years)) : 0,
|
|
// month: curr.Months ? Math.floor(Number(curr.Months)) : 0,
|
|
// day: curr.Days ? Math.floor(Number(curr.Days)) : 0,
|
|
days: curr.days_diff ? Number(curr.days_diff) : 0,
|
|
name: _posExecutive[index]?.positionExecutive,
|
|
}))
|
|
: [];
|
|
|
|
const groupMapPosExecutive = mapPosExecutive.reduce(
|
|
(acc: any, curr: any) => {
|
|
let existing = acc.find((item: any) => item.name === curr.name);
|
|
|
|
if (existing) {
|
|
existing.days += curr.days;
|
|
} else {
|
|
existing = { name: curr.name, days: curr.days };
|
|
acc.push(existing);
|
|
}
|
|
|
|
// Recalculate year, month, and day
|
|
existing.year = Math.floor(existing.days / 365.2524);
|
|
existing.month = Math.floor((existing.days / 30.4375) % 12);
|
|
existing.day = Math.floor(existing.days % 30.4375);
|
|
|
|
return acc;
|
|
},
|
|
[] as { name: string; days: number; year: number; month: number; day: number }[],
|
|
);
|
|
|
|
return new HttpSuccess({
|
|
position: groupMapPosition,
|
|
posLevel: groupMapPosLevel,
|
|
posExecutive: groupMapPosExecutive,
|
|
});
|
|
}
|
|
|
|
@Get("admin/{profileId}")
|
|
public async getSalaryAdmin(@Path() profileId: string, @Request() req: RequestWithUser) {
|
|
let _workflow = await new permission().Workflow(req, profileId, "SYS_SALARY_OFFICER");
|
|
if (_workflow == false) await new permission().PermissionGet(req, "SYS_SALARY_OFFICER");
|
|
const record = await this.salaryRepo.find({
|
|
where: { profileId: profileId, commandCode: In(["5", "6", "7"]) },
|
|
order: { order: "ASC" },
|
|
});
|
|
return new HttpSuccess(record);
|
|
}
|
|
|
|
@Get("admin/history/{salaryId}")
|
|
public async salaryAdminHistory(@Path() salaryId: string, @Request() req: RequestWithUser) {
|
|
const _record = await this.salaryRepo.findOneBy({ id: salaryId });
|
|
if (_record) {
|
|
let _workflow = await new permission().Workflow(req, salaryId, "SYS_REGISTRY_OFFICER");
|
|
if (_workflow == false)
|
|
await new permission().PermissionOrgUserGet(req, "SYS_REGISTRY_OFFICER", _record.profileId);
|
|
}
|
|
const record = await this.salaryHistoryRepo.find({
|
|
where: {
|
|
profileSalaryId: salaryId,
|
|
},
|
|
order: { createdAt: "DESC" },
|
|
});
|
|
return new HttpSuccess(record);
|
|
}
|
|
|
|
@Get("history/{salaryId}")
|
|
public async salaryHistory(@Path() salaryId: string) {
|
|
const record = await this.salaryHistoryRepo.find({
|
|
where: {
|
|
profileSalaryId: salaryId,
|
|
},
|
|
order: { createdAt: "DESC" },
|
|
});
|
|
return new HttpSuccess(record);
|
|
}
|
|
|
|
@Post()
|
|
public async newSalary(@Request() req: RequestWithUser, @Body() body: CreateProfileSalary) {
|
|
if (!body.profileId) {
|
|
throw new HttpError(HttpStatus.BAD_REQUEST, "กรุณากรอก profileId");
|
|
}
|
|
|
|
const profile = await this.profileRepo.findOneBy({ id: body.profileId });
|
|
if (!profile) {
|
|
throw new HttpError(HttpStatus.BAD_REQUEST, "ไม่พบ profile ดังกล่าว");
|
|
}
|
|
await new permission().PermissionOrgUserUpdate(req, "SYS_REGISTRY_OFFICER", profile.id);
|
|
|
|
const dest_item = await this.salaryRepo.findOne({
|
|
where: { profileId: body.profileId },
|
|
order: { order: "DESC" },
|
|
});
|
|
const before = null;
|
|
const data = new ProfileSalary();
|
|
|
|
const meta = {
|
|
order: dest_item == null ? 1 : dest_item.order + 1,
|
|
createdUserId: req.user.sub,
|
|
createdFullName: req.user.name,
|
|
lastUpdateUserId: req.user.sub,
|
|
lastUpdateFullName: req.user.name,
|
|
createdAt: new Date(),
|
|
lastUpdatedAt: new Date(),
|
|
};
|
|
const _null: any = null;
|
|
Object.assign(data, { ...body, ...meta });
|
|
const history = new ProfileSalaryHistory();
|
|
Object.assign(history, { ...data, id: undefined });
|
|
await this.salaryRepo.save(data, { data: req });
|
|
setLogDataDiff(req, { before, after: data });
|
|
history.profileSalaryId = data.id;
|
|
await this.salaryHistoryRepo.save(history, { data: req });
|
|
|
|
profile.amount = body?.amount ?? _null;
|
|
profile.amountSpecial = body.amountSpecial ?? _null;
|
|
profile.positionSalaryAmount = body?.positionSalaryAmount ?? _null;
|
|
profile.mouthSalaryAmount = body.mouthSalaryAmount ?? _null;
|
|
await this.profileRepo.save(profile, { data: req });
|
|
|
|
return new HttpSuccess();
|
|
}
|
|
|
|
@Post("update")
|
|
public async updateSalary(@Request() req: RequestWithUser, @Body() body: CreateProfileSalary) {
|
|
if (!body.profileId) {
|
|
throw new HttpError(HttpStatus.BAD_REQUEST, "กรุณากรอก profileId");
|
|
}
|
|
|
|
const profile = await this.profileRepo.findOneBy({ id: body.profileId });
|
|
if (!profile) {
|
|
throw new HttpError(HttpStatus.BAD_REQUEST, "ไม่พบ profile ดังกล่าว");
|
|
}
|
|
await new permission().PermissionOrgUserUpdate(req, "SYS_REGISTRY_OFFICER", profile.id);
|
|
|
|
const dest_item = await this.salaryRepo.findOne({
|
|
where: { profileId: body.profileId },
|
|
order: { order: "DESC" },
|
|
});
|
|
const before = null;
|
|
const data = new ProfileSalary();
|
|
|
|
const meta = {
|
|
order: dest_item == null ? 1 : dest_item.order + 1,
|
|
createdUserId: req.user.sub,
|
|
createdFullName: req.user.name,
|
|
lastUpdateUserId: req.user.sub,
|
|
lastUpdateFullName: req.user.name,
|
|
createdAt: new Date(),
|
|
lastUpdatedAt: new Date(),
|
|
};
|
|
|
|
Object.assign(data, { ...body, ...meta });
|
|
const history = new ProfileSalaryHistory();
|
|
Object.assign(history, { ...data, id: undefined });
|
|
await this.salaryRepo.save(data, { data: req });
|
|
setLogDataDiff(req, { before, after: data });
|
|
history.profileSalaryId = data.id;
|
|
await this.salaryHistoryRepo.save(history, { data: req });
|
|
|
|
let _null: any = null;
|
|
profile.amount = body.amount ?? _null;
|
|
profile.amountSpecial = body.amountSpecial ?? _null;
|
|
profile.positionSalaryAmount = body.positionSalaryAmount ?? _null;
|
|
profile.mouthSalaryAmount = body.mouthSalaryAmount ?? _null;
|
|
await this.profileRepo.save(profile);
|
|
return new HttpSuccess();
|
|
}
|
|
|
|
@Patch("{salaryId}")
|
|
public async editSalary(
|
|
@Request() req: RequestWithUser,
|
|
@Body() body: UpdateProfileSalary,
|
|
@Path() salaryId: string,
|
|
) {
|
|
const record = await this.salaryRepo.findOneBy({ id: salaryId });
|
|
if (!record) throw new HttpError(HttpStatus.NOT_FOUND, "ไม่พบข้อมูล");
|
|
await new permission().PermissionOrgUserUpdate(req, "SYS_REGISTRY_OFFICER", record.profileId);
|
|
const before = structuredClone(record);
|
|
const history = new ProfileSalaryHistory();
|
|
|
|
Object.assign(record, body);
|
|
Object.assign(history, { ...record, id: undefined });
|
|
|
|
history.profileSalaryId = salaryId;
|
|
record.lastUpdateUserId = req.user.sub;
|
|
record.lastUpdateFullName = req.user.name;
|
|
record.lastUpdatedAt = new Date();
|
|
history.lastUpdateUserId = req.user.sub;
|
|
history.lastUpdateFullName = req.user.name;
|
|
history.createdUserId = req.user.sub;
|
|
history.createdFullName = req.user.name;
|
|
history.createdAt = new Date();
|
|
history.lastUpdatedAt = new Date();
|
|
|
|
await Promise.all([
|
|
this.salaryRepo.save(record, { data: req }),
|
|
setLogDataDiff(req, { before, after: record }),
|
|
this.salaryHistoryRepo.save(history, { data: req }),
|
|
]);
|
|
|
|
return new HttpSuccess();
|
|
}
|
|
|
|
@Delete("{salaryId}")
|
|
public async deleteSalary(@Path() salaryId: string, @Request() req: RequestWithUser) {
|
|
const _record = await this.salaryRepo.findOneBy({ id: salaryId });
|
|
if (_record) {
|
|
await new permission().PermissionOrgUserDelete(
|
|
req,
|
|
"SYS_REGISTRY_OFFICER",
|
|
_record.profileId,
|
|
);
|
|
}
|
|
const data = await this.salaryRepo.findOneBy({ id: salaryId });
|
|
if (!data) throw new HttpError(HttpStatus.NOT_FOUND, "ไม่พบข้อมูล");
|
|
if (data == null) throw new HttpError(HttpStatus.NOT_FOUND, "ไม่พบข้อมูล");
|
|
const profileId = data.profileId;
|
|
await this.salaryHistoryRepo.delete({
|
|
profileSalaryId: salaryId,
|
|
});
|
|
|
|
const result = await this.salaryRepo.delete({ id: salaryId });
|
|
|
|
const salaryList = await this.salaryRepo.find({
|
|
where: {
|
|
profileId: profileId,
|
|
},
|
|
});
|
|
salaryList.forEach(async (p, i) => {
|
|
p.order = i + 1;
|
|
await this.salaryRepo.save(p);
|
|
});
|
|
if (result.affected == undefined || result.affected <= 0) {
|
|
throw new HttpError(HttpStatus.NOT_FOUND, "ไม่พบข้อมูล");
|
|
}
|
|
|
|
return new HttpSuccess();
|
|
}
|
|
|
|
@Get("swap/{direction}/{salaryId}")
|
|
public async swapSalary(
|
|
@Path() direction: string,
|
|
salaryId: string,
|
|
@Request() req: RequestWithUser,
|
|
) {
|
|
const source_item = await this.salaryRepo.findOne({ where: { id: salaryId } });
|
|
// if (source_item) {
|
|
//await new permission().PermissionOrgUserGet(req,"SYS_REGISTRY_OFFICER",source_item.profileId,); //ไม่แน่ใจOFFปิดไว้ก่อน
|
|
// }
|
|
if (source_item == null) throw new HttpError(HttpStatus.NOT_FOUND, "ไม่พบข้อมูล");
|
|
const sourceOrder = source_item.order;
|
|
if (direction.trim().toUpperCase() == "UP") {
|
|
const dest_item = await this.salaryRepo.findOne({
|
|
where: { profileId: source_item.profileId, order: LessThan(sourceOrder) },
|
|
order: { order: "DESC" },
|
|
});
|
|
if (dest_item == null) return new HttpSuccess();
|
|
var destOrder = dest_item.order;
|
|
dest_item.order = sourceOrder;
|
|
source_item.order = destOrder;
|
|
await Promise.all([this.salaryRepo.save(source_item), this.salaryRepo.save(dest_item)]);
|
|
} else {
|
|
const dest_item = await this.salaryRepo.findOne({
|
|
where: { profileId: source_item.profileId, order: MoreThan(sourceOrder) },
|
|
order: { order: "ASC" },
|
|
});
|
|
if (dest_item == null) return new HttpSuccess();
|
|
var destOrder = dest_item.order;
|
|
dest_item.order = sourceOrder;
|
|
source_item.order = destOrder;
|
|
await Promise.all([this.salaryRepo.save(source_item), this.salaryRepo.save(dest_item)]);
|
|
}
|
|
return new HttpSuccess();
|
|
}
|
|
}
|