Files
service-master-data-revenue/src/controllers/room.ts
2026-05-15 09:14:48 +07:00

571 lines
20 KiB
TypeScript

import { Room, Paging, Service } from "entity";
import { NextFunction, Response } from "express";
import { Request } from "express-jwt";
import Joi from "joi";
import { ILogObj, Logger } from "tslog";
import CommonHelper from "../helpers/common";
import { ReturnHelper } from "../helpers/express/return";
import { Language } from "../langs/lang";
import { RoomModel } from "../model/room";
import { DepartmentModel } from "../model/department";
import { ServiceClassModel } from "../model/service_class";
import { OrmHelper } from "../helpers/orm";
import moment from "moment";
import fileUpload from "express-fileupload";
import { v4 as uuidv4 } from "uuid";
import fs from "fs";
import path from "path";
import { Brackets } from "typeorm";
const log: Logger<ILogObj> = new Logger({
name: "[RoomController]",
type: "pretty",
});
interface FileUploadRequest extends Request {
files?: fileUpload.FileArray | null;
body: any;
}
export class RoomController {
static async list(req: Request, res: Response, next: NextFunction): Promise<void | Response> {
/*
#swagger.tags = ['Room']
#swagger.security = [{ "bearerAuth": [] }]
#swagger.parameters['filter'] = { description: 'Filter: plain text or JSON object (status, code, departmentId, etc.)', in: 'query', type: 'string' }
#swagger.parameters['limit'] = { in: 'query', required: true, type: 'number' }
#swagger.parameters['page'] = { in: 'query', required: true, type: 'number' }
#swagger.parameters['with_deleted'] = { in: 'query', required: true, type: 'boolean' }
#swagger.parameters['order_field'] = { in: 'query', required: true, type: 'string' }
#swagger.parameters['order_direction'] = { in: 'query', required: true, schema: { '@enum': ['ASC', 'DESC'] } }
*/
try {
const schema = Joi.object().keys({
filter: Joi.string().allow("").optional().label("Filter"),
page: Joi.number().required().min(1).label("Page"),
limit: Joi.number().required().min(1).label("Limit"),
with_deleted: Joi.bool().required().label("With Deleted"),
order_field: Joi.string().required().label("Order Field"),
order_direction: Joi.string().allow("asc", "desc").required().label("Order Direction"),
});
let param: Paging = await schema.validateAsync(req.query);
let filter = param.filter && param.filter !== "" ? JSON.parse(param.filter) : {};
const filterAny = filter.any && filter.any !== "" ? String(filter.any) : "";
let filterObj = { ...filter } as any;
delete filterObj.any;
var query = await RoomModel.list(filterObj);
if (filterAny !== "") {
const anyVal = filterAny.includes("%") ? filterAny : `%${filterAny}%`;
query.andWhere(
new Brackets((qb) => {
qb.where("Room.code ILIKE :any", { any: anyVal }).orWhere("Room.room ILIKE :any", { any: anyVal });
}),
);
query.andWhere(
new Brackets((qb) => {
qb.where("department.name ILIKE :any", { any: anyVal }).orWhere("department.name ILIKE :any", { any: anyVal });
}),
);
}
const offset = (param.page - 1) * param.limit;
const res_count = query;
const res_list = query
.leftJoinAndSelect("Room.department", "department")
.leftJoinAndSelect("Room.serviceclass", "serviceclass")
.orderBy("Room." + param.order_field, param.order_direction)
.offset(offset)
.limit(param.limit);
if (param.with_deleted) {
res_count.withDeleted();
res_list.withDeleted();
}
const photoBaseUrl = "https://his.shiblysolution.id/service-master-data/uploads/room-picture/";
const current_page = param.page;
const total_count_data = await res_count.getCount();
const list_data = await res_list.getMany();
const mapped_data = list_data.map((item: any) => ({
...item,
picture: item.picture ? photoBaseUrl + item.picture : null,
}));
const count_data = CommonHelper.countObject(list_data);
return ReturnHelper.successResponselist(res, 200, Language.lang.success_view, count_data, current_page, total_count_data, mapped_data);
} catch (e: unknown) {
log.error(e);
const err = e as Error;
return ReturnHelper.errorResponse(res, 400, 401, Language.lang.failed_view, err.message);
}
}
static async option(req: Request, res: Response, next: NextFunction): Promise<void | Response> {
/*
#swagger.tags = ['Room']
#swagger.security = [{ "bearerAuth": [] }]
#swagger.parameters['id'] = {
in: 'query',
type: 'string',
required: false,
description: 'Department Id (optional)'
}
*/
try {
const schema = Joi.object().keys({
id: Joi.string().uuid().optional().label("Department Id"),
});
let param: any = await schema.validateAsync(req.query);
const query = await RoomModel.list();
query.select(["Room.id", "Room.room"]).orderBy("Room.room", "ASC");
// ✅ optional filter by departmentId
if (param.id) {
query.andWhere("Room.departmentId = :departmentId", {
departmentId: param.id,
});
}
const total_count_data = await query.getCount();
const list_data = await query.getMany();
const count_data = CommonHelper.countObject(list_data);
return ReturnHelper.successResponselist(res, 200, Language.lang.success_view, count_data, 1, total_count_data, list_data);
} catch (e: unknown) {
log.error(e);
const err = e as Error;
return ReturnHelper.errorResponse(res, 400, 401, Language.lang.failed_view, err.message);
}
}
static async create(req: Request, res: Response, next: NextFunction): Promise<void | Response> {
/*
#swagger.tags = ['Room']
#swagger.security = [{ "bearerAuth": [] }]
#swagger.requestBody = { required: true, content: { "application/json": { schema: { $ref: "#/components/schemas/room" } } } }
*/
const queryRunner = OrmHelper.DB.createQueryRunner();
await queryRunner.startTransaction();
try {
const schema = Joi.object().keys({
room: Joi.string().max(256).required().label("Room"),
code: Joi.string().max(128).required().label("Code"),
description: Joi.string().allow("").max(512).optional().label("Description"),
department_id: Joi.string().uuid().required().label("Department ID"),
serviceclass: Joi.string().uuid().required().label("Service Class ID"),
status: Joi.string().required().label("Status"),
location: Joi.string().required().label("Location"),
floor: Joi.number().required().label("Floor"),
picture: Joi.string().required().label("picture"),
});
let param: any = await schema.validateAsync(req.body);
let exist = await RoomModel.list({ code: param.code }).then((q) => q.getOne());
if (exist) throw { message: "Room " + Language.lang.failed_duplicate };
let department = await DepartmentModel.list({ id: param.department_id }).then((q) => q.getOne());
if (!department) throw { message: "Department not found" };
let serviceclass = await ServiceClassModel.list({ id: param.serviceclass }).then((q) => q.getOne());
if (!serviceclass) throw { message: "Class not found" };
let room = new Room();
room.room = param.room;
room.code = param.code;
room.description = param.description || null;
room.department = department;
room.serviceclass = param.serviceclass;
room.status = param.status;
room.location = param.location;
room.picture = param.picture;
room.floor = param.floor;
room.created_by = req.auth?.data.name;
room.updated_by = req.auth?.data.name;
await queryRunner.manager.save(room);
await queryRunner.commitTransaction();
return ReturnHelper.successResponseAny(res, 200, Language.lang.success_insert, room);
} catch (e: unknown) {
await queryRunner.rollbackTransaction();
log.error(e);
const err = e as Error;
return ReturnHelper.errorResponse(res, 400, 401, Language.lang.failed_view, err.message);
} finally {
await queryRunner.release();
}
}
static async detail(req: Request, res: Response, next: NextFunction): Promise<void | Response> {
/*
#swagger.tags = ['Room']
#swagger.security = [{ "bearerAuth": [] }]
#swagger.parameters['id'] = { in: 'path', type: 'string' }
*/
try {
const schema = Joi.object().keys({
id: Joi.string().uuid().required().label("Room Id"),
});
let param: any = await schema.validateAsync(req.params);
let room = await RoomModel.list({ "Room.id": param.id }).then((q) => q.leftJoinAndSelect("Room.department", "department").leftJoinAndSelect("Room.serviceclass", "serviceclass").getOne());
if (!room) throw { message: "Room Not Found" };
return ReturnHelper.successResponseAny(res, 200, Language.lang.success_view, room);
} catch (e: unknown) {
log.error(e);
const err = e as Error;
return ReturnHelper.errorResponse(res, 400, 401, Language.lang.failed_not_found, err.message);
}
}
static async update(req: Request, res: Response, next: NextFunction): Promise<void | Response> {
/*
#swagger.tags = ['Room']
#swagger.security = [{ "bearerAuth": [] }]
#swagger.parameters['id'] = { in: 'path', type: 'string' }
#swagger.requestBody = { required: true, content: { "application/json": { schema: { $ref: "#/components/schemas/room" } } } }
*/
const queryRunner = OrmHelper.DB.createQueryRunner();
await queryRunner.startTransaction();
try {
req.body.id = req.params["id"];
const schema = Joi.object().keys({
id: Joi.string().uuid().required().label("Room ID"),
room: Joi.string().max(256).required().label("Room"),
code: Joi.string().max(128).required().label("Code"),
description: Joi.string().allow("").max(512).optional().label("Description"),
department_id: Joi.string().uuid().required().label("Department ID"),
serviceclass: Joi.string().uuid().required().label("Service Class ID"),
floor: Joi.number().required().label("Floor"),
status: Joi.string().required().label("Status"),
location: Joi.string().required().label("Location"),
picture: Joi.string().required().label("picture"),
});
let param: any = await schema.validateAsync(req.body);
let exist = await RoomModel.list({ code: param.code }).then((q) => q.getOne());
if (exist && exist.id != param.id) throw { message: "Room " + Language.lang.failed_duplicate };
let department = await DepartmentModel.list({ id: param.department_id }).then((q) => q.getOne());
if (!department) throw { message: "Department not found" };
let serviceclass = await ServiceClassModel.list({ id: param.serviceclass }).then((q) => q.getOne());
if (!serviceclass) throw { message: "Class not found" };
let room = await RoomModel.list({ "Room.id": param.id }).then((q) => q.getOne());
if (!room) throw { message: "Room " + Language.lang.failed_not_found };
room.room = param.room;
room.code = param.code;
room.description = param.description || null;
room.serviceclass = param.serviceclass;
room.department = department;
room.status = param.status;
room.floor = param.floor;
room.location = param.location;
room.picture = param.picture;
room.updated_by = req.auth?.data.name;
await queryRunner.manager.save(room);
await queryRunner.commitTransaction();
return ReturnHelper.successResponseAny(res, 200, Language.lang.success_update, room);
} catch (e: unknown) {
await queryRunner.rollbackTransaction();
log.error(e);
const err = e as Error;
return ReturnHelper.errorResponse(res, 400, 401, Language.lang.failed_view, err.message);
} finally {
await queryRunner.release();
}
}
static async delete(req: Request, res: Response, next: NextFunction): Promise<Response> {
/*
#swagger.tags = ['Room']
#swagger.security = [{ "bearerAuth": [] }]
#swagger.parameters['id'] = { in: 'path', required: true, type: 'string' }
#swagger.parameters['hard'] = { in: 'path', required: false, type: 'boolean' }
*/
try {
const schema = Joi.object().keys({
id: Joi.string().uuid().required().label("ID"),
hard: Joi.bool().optional().allow("").label("Is hard delete?"),
});
const param: { id: string; hard: boolean } = await schema.validateAsync(req.params);
let affected = 0;
if (!param.hard) {
let room: Room = await RoomModel.list({ "Room.id": param.id }).then((q) => q.getOne());
if (!room) throw { message: "Room " + Language.lang.failed_not_found };
room.deleted_by = req.auth?.data.name;
room.deleted_at = moment().toDate();
await OrmHelper.DB.manager.save(room);
affected = 1;
} else {
const repo = OrmHelper.DB.getRepository(Room);
affected = (await repo.delete({ id: param.id })).affected ?? 0;
}
if (affected > 0) {
return ReturnHelper.successResponseAny(res, 200, Language.lang.success_delete, {});
} else {
return ReturnHelper.errorResponse(res, 404, 401, Language.lang.failed_not_found, "");
}
} catch (e: unknown) {
log.error(e);
const err = e as Error;
return ReturnHelper.errorResponse(res, 500, 402, Language.lang.failed_delete, err.message);
}
}
static async restore(req: Request, res: Response, next: NextFunction): Promise<Response> {
/*
#swagger.tags = ['Room']
#swagger.security = [{ "bearerAuth": [] }]
#swagger.parameters['id'] = { in: 'path', required: true, type: 'string' }
*/
try {
const schema = Joi.object().keys({
id: Joi.string().uuid().required().label("ID"),
});
const param: any = await schema.validateAsync(req.params);
const repo = OrmHelper.DB.getRepository(Room);
const affected = (await repo.restore({ id: param.id })).affected ?? 0;
if (affected > 0) {
return ReturnHelper.successResponseAny(res, 200, Language.lang.success_restore, {});
} else {
return ReturnHelper.errorResponse(res, 404, 401, Language.lang.failed_not_found, "");
}
} catch (e: unknown) {
log.error(e);
const err = e as Error;
return ReturnHelper.errorResponse(res, 500, 402, Language.lang.failed_restore, err.message);
}
}
static async uploadpicture(req: FileUploadRequest, res: Response, next: NextFunction): Promise<Response> {
/* #swagger.tags = ['Room']
#swagger.security = [{ "bearerAuth": [] }]
#swagger.consumes = ['multipart/form-data']
#swagger.requestBody = {
required: true,
content: {
"multipart/form-data": {
schema: {
type: "object",
properties: {
file: {
type: "string",
format: "binary",
description: "Image file (max 1MB, jpg/png/webp)"
},
},
required: ["file"]
}
}
}
}
*/
try {
// Validation schema
const schema = Joi.object().keys({
// path: Joi.string().label('File Path'),
// application: Joi.string().label('Application'),
});
log.info("body", req.body);
// const param: { path: string, application: string } = await schema.validateAsync(req.body);
// Check if file exists
if (!req.files || !req.files.file) {
return ReturnHelper.errorResponse(res, 400, 404, Language.lang.failed_insert, "File not found");
}
const file = req.files.file as fileUpload.UploadedFile;
// Validate file size (max 1MB)
const maxSize = 1024 * 1024; // 1MB
if (file.size > maxSize) {
return ReturnHelper.errorResponse(res, 400, 400, Language.lang.failed_insert, "File size exceeds 1MB limit");
}
// Validate file type
const allowedMimes = ["image/jpeg", "image/jpg", "image/png", "image/webp"];
if (!allowedMimes.includes(file.mimetype)) {
return ReturnHelper.errorResponse(res, 400, 400, Language.lang.failed_insert, "Invalid file type. Only JPG, PNG, and WEBP are allowed");
}
// Normalize path
// param.path = param.path[param.path.length - 1] !== '/' ? param.path + '/' : param.path;
// if (param.path == undefined || param.path == null) param.path = 'uploads/room-picture/';
// Generate unique filename
const ext = file.name.split(".");
const name = uuidv4() + "." + ext[ext.length - 1];
const result: { file: string } = {
// url: "",
// path: "",
file: "",
// mime: file.mimetype,
// size: file.size,
// md5: file.md5
};
const folder_path = "uploads/room-picture/";
const file_path = path.join(folder_path, name);
// Create directory if it doesn't exist
if (!fs.existsSync(folder_path)) {
fs.mkdirSync(folder_path, { recursive: true });
}
// Move file to destination
await file.mv(file_path);
// result.path = param.path[param.path.length - 1] === '/' ? param.path.substring(0, param.path.length - 1) : param.path;
result.file = name;
// result.url = `${result.path}/${name}`; // Generate URL
log.info(`File uploaded successfully: ${file_path}`);
return ReturnHelper.successResponseAny(res, 200, Language.lang.success_insert, result);
} catch (e: unknown) {
// Proper error logging to avoid tslog serialization issues
if (e instanceof Error) {
log.error("File upload failed:", {
message: e.message,
stack: e.stack,
name: e.name,
});
return ReturnHelper.errorResponse(res, 500, 500, Language.lang.failed_insert, e.message);
} else {
log.error("File upload failed with unknown error:", String(e));
return ReturnHelper.errorResponse(res, 500, 500, Language.lang.failed_insert, "Unknown error occurred");
}
}
}
static async deletepicture(req: Request, res: Response, next: NextFunction): Promise<Response> {
/*
#swagger.tags = ['Room']
#swagger.security = [{ "bearerAuth": [] }]
#swagger.requestBody = { required: true, content: { "application/json": { schema: { $ref: "#/components/schemas/files" } } } }
*/
try {
const schema = Joi.object().keys({
file_name: Joi.string().required().label("File Name"),
});
const param: { file_name: string } = await schema.validateAsync(req.body);
// Prevent deletion of files starting with "template_"
if (param.file_name.startsWith("template_")) {
return ReturnHelper.errorResponse(res, 403, 403, Language.lang.failed_delete, "Cannot delete files that start with 'template_'");
}
// const env = process.env.NODE_ENV + '/'
const fixedPath = "uploads/room-picture/";
const file_path = fixedPath + param.file_name;
// Check if file exists
if (!fs.existsSync(file_path)) {
return ReturnHelper.errorResponse(res, 404, 404, Language.lang.failed_not_found, "File not found");
}
// Delete file
fs.unlinkSync(file_path);
return ReturnHelper.successResponseAny(res, 200, Language.lang.success_delete, {});
} catch (e: unknown) {
log.error(e);
const err = e as Error;
return ReturnHelper.errorResponse(res, 500, 402, Language.lang.failed_delete, err.message);
}
}
static async gettemplatepicture(req: Request, res: Response, next: NextFunction): Promise<Response> {
/*
#swagger.tags = ['Room']
#swagger.security = [{ "bearerAuth": [] }]
#swagger.description = 'Get all room pictures from uploads/room-picture/template directory".'
*/
try {
const filePath = "uploads/room-picture/template/";
if (!fs.existsSync(filePath)) {
return ReturnHelper.successResponseAny(res, 200, Language.lang.success_view, []);
}
const files = fs.readdirSync(filePath);
const photoBaseUrl = "https://his.shiblysolution.id/service-master-data/uploads/room-picture/template/";
const filesWithUrl = files.map((filename, index) => ({
id: index,
name: `template/${filename}`,
url: photoBaseUrl + filename,
}));
return ReturnHelper.successResponseAny(res, 200, Language.lang.success_view, filesWithUrl);
} catch (e: unknown) {
log.error(e);
const err = e as Error;
return ReturnHelper.errorResponse(res, 500, 401, Language.lang.failed_view, err.message);
}
}
static async listLocation(req: Request, res: Response, next: NextFunction): Promise<void | Response> {
/*
#swagger.tags = ['Room']
#swagger.security = [{ "bearerAuth": [] }]
*/
try {
const query = await RoomModel.list();
const list_data = await query
.select(["Room.id AS id", "Room.room AS room", "Room.location AS location"])
.orderBy("Room.location", "ASC")
.addOrderBy("Room.room", "ASC")
.getRawMany();
const grouped_data = list_data.reduce(
(acc: Record<string, Array<{ id: string; room: string }>>, item: { id: string; room: string; location: string }) => {
const locationKey = item.location || "unknown";
if (!acc[locationKey]) {
acc[locationKey] = [];
}
acc[locationKey].push({
id: item.id,
room: item.room,
});
return acc;
},
{},
);
const formatted_data = Object.entries(grouped_data).map(([location, rooms]) => ({
location,
rooms,
}));
return ReturnHelper.successResponseAny(res, 200, Language.lang.success_view, formatted_data);
} catch (e: unknown) {
log.error(e);
const err = e as Error;
return ReturnHelper.errorResponse(res, 400, 401, Language.lang.failed_view, err.message);
}
}
}