228 lines
11 KiB
TypeScript
228 lines
11 KiB
TypeScript
// import { Injectable, BadRequestException, NotFoundException, ConflictException } from "@nestjs/common";
|
|
// import { Prisma, Weekday } from "@prisma/client";
|
|
// import { PrismaService } from "src/prisma/prisma.service";
|
|
// import { BankCodesResolver } from "src/common/mappers/bank-type-id.mapper";
|
|
// import { EmailToIdResolver } from "src/common/mappers/email-id.mapper";
|
|
// import { Result } from "src/common/errors/result-error.factory";
|
|
// import { toHHmmFromDate, toDateFromString } from "src/common/utils/date-utils";
|
|
// import { SchedulePresetsDto } from "src/time-and-attendance/schedule-presets/dtos/create-schedule-presets.dto";
|
|
|
|
// @Injectable()
|
|
// export class SchedulePresetsUpsertService {
|
|
// constructor(
|
|
// private readonly prisma: PrismaService,
|
|
// private readonly typeResolver: BankCodesResolver,
|
|
// private readonly emailResolver: EmailToIdResolver,
|
|
// ) { }
|
|
// //_________________________________________________________________
|
|
// // CREATE
|
|
// //_________________________________________________________________
|
|
// async createPreset(email: string, dto: SchedulePresetsDto): Promise<Result<SchedulePresetsDto, string>> {
|
|
// try {
|
|
// const shifts_data = await this.normalizePresetShifts(dto);
|
|
// if (!shifts_data.success) return { success: false, error: `Employee with email: ${email} or dto not found` };
|
|
|
|
// const employee_id = await this.emailResolver.findIdByEmail(email);
|
|
// if (!employee_id.success) return { success: false, error: employee_id.error };
|
|
|
|
// const created = await this.prisma.$transaction(async (tx) => {
|
|
// if (dto.is_default) {
|
|
// await tx.schedulePresets.updateMany({
|
|
// where: { is_default: true, employee_id: employee_id.data },
|
|
// data: { is_default: false },
|
|
// });
|
|
// await tx.schedulePresets.create({
|
|
// data: {
|
|
// id: dto.id,
|
|
// employee_id: employee_id.data,
|
|
// name: dto.name,
|
|
// is_default: !!dto.is_default,
|
|
// shifts: { create: shifts_data.data },
|
|
// },
|
|
// });
|
|
// return { success: true, data: created }
|
|
// }
|
|
// });
|
|
// return { success: true, data: created }
|
|
// } catch (error) {
|
|
// return { success: false, error: ' An error occured during create. Invalid Schedule data' };
|
|
// }
|
|
// }
|
|
|
|
// //_________________________________________________________________
|
|
// // UPDATE
|
|
// //_________________________________________________________________
|
|
// async updatePreset(preset_id: number, dto: SchedulePresetsDto): Promise<Result<SchedulePresetsDto, string>> {
|
|
// try {
|
|
// const existing = await this.prisma.schedulePresets.findFirst({
|
|
// where: { id: preset_id },
|
|
// select: {
|
|
// id: true,
|
|
// is_default: true,
|
|
// employee_id: true,
|
|
// },
|
|
// });
|
|
// if (!existing) return { success: false, error: `Preset "${dto.name}" not found` };
|
|
|
|
// const shifts_data = await this.normalizePresetShifts(dto);
|
|
// if (!shifts_data.success) return { success: false, error: 'An error occured during normalization' }
|
|
|
|
// await this.prisma.$transaction(async (tx) => {
|
|
// if (typeof dto.is_default === 'boolean') {
|
|
// if (dto.is_default) {
|
|
// await tx.schedulePresets.updateMany({
|
|
// where: {
|
|
// employee_id: existing.employee_id,
|
|
// is_default: true,
|
|
// NOT: { id: existing.id },
|
|
// },
|
|
// data: { is_default: false },
|
|
// });
|
|
// }
|
|
// await tx.schedulePresets.update({
|
|
// where: { id: existing.id },
|
|
// data: {
|
|
// is_default: dto.is_default,
|
|
// name: dto.name,
|
|
// },
|
|
// });
|
|
// }
|
|
// if (shifts_data.data.length <= 0) return { success: false, error: 'Preset shifts to update not found' };
|
|
|
|
// await tx.schedulePresetShifts.deleteMany({ where: { preset_id: existing.id } });
|
|
|
|
// try {
|
|
// const create_many_data: Result<Prisma.SchedulePresetShiftsCreateManyInput[], string> =
|
|
// shifts_data.data.map((shift) => {
|
|
// if (!shift.bank_code || !('connect' in shift.bank_code) || typeof shift.bank_code.connect?.id !== 'number') {
|
|
// return { success: false, error: `Bank code is required for updates( ${shift.week_day}, ${shift.sort_order})`}
|
|
// }
|
|
// const bank_code_id = shift.bank_code.connect.id;
|
|
// return {
|
|
// preset_id: existing.id,
|
|
// week_day: shift.week_day,
|
|
// sort_order: shift.sort_order,
|
|
// start_time: shift.start_time,
|
|
// end_time: shift.end_time,
|
|
// is_remote: shift.is_remote ?? false,
|
|
// bank_code_id: bank_code_id,
|
|
// };
|
|
// });
|
|
// if(!create_many_data.success) return { success: false, error: 'Invalid data'}
|
|
// await tx.schedulePresetShifts.createMany({ data: create_many_data.data });
|
|
|
|
// return { success: true, data: create_many_data }
|
|
// } catch (error) {
|
|
// return { success: false, error: 'An error occured. Invalid data detected. ' };
|
|
// }
|
|
// });
|
|
|
|
// const saved = await this.prisma.schedulePresets.findUnique({
|
|
// where: { id: existing.id },
|
|
// include: {
|
|
// shifts: {
|
|
// orderBy: [{ week_day: 'asc' }, { sort_order: 'asc' }],
|
|
// include: { bank_code: { select: { type: true } } },
|
|
// }
|
|
// },
|
|
// });
|
|
// if (!saved) return { success: false, error: `Preset with id: ${existing.id} not found` };
|
|
|
|
// const response_dto: SchedulePresetsDto = {
|
|
// id: saved.id,
|
|
// name: saved.name,
|
|
// is_default: saved.is_default,
|
|
// preset_shifts: saved.shifts.map((shift) => ({
|
|
// preset_id: shift.preset_id,
|
|
// week_day: shift.week_day,
|
|
// sort_order: shift.sort_order,
|
|
// type: shift.bank_code.type,
|
|
// start_time: toHHmmFromDate(shift.start_time),
|
|
// end_time: toHHmmFromDate(shift.end_time),
|
|
// is_remote: shift.is_remote,
|
|
// })),
|
|
// };
|
|
|
|
// return { success: true, data: response_dto };
|
|
// } catch (error) {
|
|
// return { success: false, error: 'An error occured during update. Invalid data' }
|
|
// }
|
|
// }
|
|
|
|
// //_________________________________________________________________
|
|
// // DELETE
|
|
// //_________________________________________________________________
|
|
// async deletePreset(preset_id: number): Promise<Result<number, string>> {
|
|
// try {
|
|
// await this.prisma.$transaction(async (tx) => {
|
|
// const preset = await tx.schedulePresets.findFirst({
|
|
// where: { id: preset_id },
|
|
// select: { id: true },
|
|
// });
|
|
// if (!preset) return { success: false, error: `Preset with id ${preset_id} not found` };
|
|
// await tx.schedulePresets.delete({ where: { id: preset_id } });
|
|
|
|
// return { success: true };
|
|
// });
|
|
// return { success: true, data: preset_id };
|
|
|
|
// } catch (error) {
|
|
// return { success: false, error: `Preset schedule with id ${preset_id} not found` };
|
|
// }
|
|
// }
|
|
|
|
// //PRIVATE HELPERS
|
|
|
|
// //resolve bank_code_id using type and convert hours to TIME and valid shifts end/start
|
|
// private async normalizePresetShifts(
|
|
// dto: SchedulePresetsDto
|
|
// ): Promise<Result<Prisma.SchedulePresetShiftsCreateWithoutPresetInput[], string>> {
|
|
// if (!dto.preset_shifts?.length) return { success: false, error: `Empty or preset shifts not found` }
|
|
|
|
// const types = Array.from(new Set(dto.preset_shifts.map((shift) => shift.type)));
|
|
// const bank_code_set = new Map<string, number>();
|
|
|
|
// for (const type of types) {
|
|
// const bank_code = await this.typeResolver.findIdAndModifierByType(type);
|
|
// if (!bank_code.success) return { success: false, error: 'Bank_code not found' }
|
|
// bank_code_set.set(type, bank_code.data.id);
|
|
// }
|
|
|
|
// const pair_set = new Set<string>();
|
|
// for (const shift of dto.preset_shifts) {
|
|
// const key = `${shift.week_day}:${shift.sort_order}`;
|
|
// if (pair_set.has(key)) {
|
|
// return { success: false, error: `Duplicate shift for day/order (${shift.week_day}, ${shift.sort_order})` }
|
|
// }
|
|
// pair_set.add(key);
|
|
// }
|
|
|
|
// const items = await dto.preset_shifts.map((shift) => {
|
|
// try {
|
|
// const bank_code_id = bank_code_set.get(shift.type);
|
|
// if (!bank_code_id) return { success: false, error: `Bank code not found for type ${shift.type}` }
|
|
// if (!shift.start_time || !shift.end_time) {
|
|
// return { success: false, error: `start_time and end_time are required for (${shift.week_day}, ${shift.sort_order})` }
|
|
// }
|
|
// const start = toDateFromString(shift.start_time);
|
|
// const end = toDateFromString(shift.end_time);
|
|
// if (end.getTime() <= start.getTime()) {
|
|
// return { success: false, error: `end_time must be > start_time ( day: ${shift.week_day}, order: ${shift.sort_order})` }
|
|
// }
|
|
// return {
|
|
// sort_order: shift.sort_order,
|
|
// start_time: start,
|
|
// end_time: end,
|
|
// is_remote: !!shift.is_remote,
|
|
// week_day: shift.week_day as Weekday,
|
|
// bank_code: { connect: { id: bank_code_id } },
|
|
// }
|
|
|
|
// } catch (error) {
|
|
// return { success: false, error: '' }
|
|
// }
|
|
// });
|
|
// return { success: true, data: items};
|
|
// }
|
|
// }
|