114 lines
3.0 KiB
JavaScript
114 lines
3.0 KiB
JavaScript
const {
|
|
getAllUserScheduleDb,
|
|
getUserScheduleByIdDb,
|
|
getUserScheduleById,
|
|
insertUserScheduleDb,
|
|
updateUserScheduleDb,
|
|
deleteUserScheduleDb
|
|
} = require('../db/user_schedule.db');
|
|
const { ErrorHandler } = require('../helpers/error');
|
|
|
|
class UserScheduleService {
|
|
// Get all devices
|
|
static async getAllUserScheduleDb(param) {
|
|
try {
|
|
const results = await getAllUserScheduleDb(param);
|
|
|
|
results.data.map(element => {
|
|
});
|
|
|
|
return results
|
|
} catch (error) {
|
|
throw new ErrorHandler(error.statusCode, error.message);
|
|
}
|
|
}
|
|
|
|
// Get device by ID
|
|
static async getUserScheduleByID(id) {
|
|
try {
|
|
const result = await getUserScheduleByIdDb(id);
|
|
|
|
if (result.length < 1) throw new ErrorHandler(404, 'User Schedule not found');
|
|
|
|
return result;
|
|
} catch (error) {
|
|
throw new ErrorHandler(error.statusCode, error.message);
|
|
}
|
|
}
|
|
|
|
static async createUserSchedules(data) {
|
|
try {
|
|
if (!data || typeof data !== 'object') data = {};
|
|
|
|
const exist = await getUserScheduleById(
|
|
data.user_id,
|
|
data.shift_id
|
|
);
|
|
|
|
if (exist.length > 0) {
|
|
throw new ErrorHandler(
|
|
400,
|
|
`User dengan ID ${data.user_id} sudah terdaftar pada shift ${data.shift_id}`
|
|
);
|
|
}
|
|
|
|
const result = await insertUserScheduleDb(data);
|
|
return result;
|
|
} catch (error) {
|
|
throw new ErrorHandler(error.statusCode, error.message);
|
|
}
|
|
}
|
|
|
|
// Update user schedule
|
|
static async updateUserSchedules(id, data) {
|
|
try {
|
|
if (!data || typeof data !== 'object') data = {};
|
|
|
|
const dataExist = await getUserScheduleByIdDb(id);
|
|
|
|
if (dataExist.length < 1) {
|
|
throw new ErrorHandler(404, 'UserSchedules not found');
|
|
}
|
|
|
|
// 🧩 VALIDASI SAAT UPDATE
|
|
if (data.user_id && data.shift_id) {
|
|
const exist = await getUserScheduleById(
|
|
data.user_id,
|
|
data.shift_id
|
|
);
|
|
|
|
if (exist.length > 0 && exist[0].id !== Number(id)) {
|
|
throw new ErrorHandler(
|
|
400,
|
|
`User dengan ID ${data.user_id} sudah terdaftar pada shift ${data.shift_id}`
|
|
);
|
|
}
|
|
}
|
|
|
|
const result = await updateUserScheduleDb(id, data);
|
|
return result;
|
|
} catch (error) {
|
|
throw new ErrorHandler(error.statusCode, error.message);
|
|
}
|
|
}
|
|
|
|
// Soft delete device
|
|
static async deleteUserSchedules(id, userId) {
|
|
try {
|
|
const dataExist = await getUserScheduleByIdDb(id);
|
|
|
|
if (dataExist.length < 1) {
|
|
throw new ErrorHandler(404, 'UserSchedules not found');
|
|
}
|
|
|
|
const result = await deleteUserScheduleDb(id, userId);
|
|
|
|
return result;
|
|
} catch (error) {
|
|
throw new ErrorHandler(error.statusCode, error.message);
|
|
}
|
|
}
|
|
}
|
|
|
|
module.exports = UserScheduleService;
|
|
|