TIMOR-TELECOM/service-master-data-revenue
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update: list in user to room

Browse Source
This commit is contained in:
wayanrivan
2026-04-09 15:04:01 +07:00
parent a67078580f
commit b02a7f966e
1 changed files with 150 additions and 106 deletions
Download Patch File Download Diff File Expand all files Collapse all files

256
src/controllers/user_to_room.ts
View File

@ -44,7 +44,7 @@ export class UserToRoomController {
const offset = (param.page - 1) * param.limit; const offset = (param.page - 1) * param.limit;
let limit = param.limit; let limit = param.limit;
const res_count = query; const res_count = query.clone();
const res_list = query const res_list = query
.orderBy("user_to_room." + param.order_field, param.order_direction) .orderBy("user_to_room." + param.order_field, param.order_direction)
.offset(offset) .offset(offset)
@ -58,9 +58,53 @@ export class UserToRoomController {
const current_page = param.page; const current_page = param.page;
const total_count_data = await res_count.getCount(); const total_count_data = await res_count.getCount();
const list_data = await res_list.getMany(); const list_data = await res_list.getMany();
const count_data = CommonHelper.countObject(list_data);
return ReturnHelper.successResponselist(res, 200, Language.lang.success_view, count_data, current_page, total_count_data, list_data); // Transform data: Group by user, room dijadikan object berindeks
const grouped: Record<string, any> = {};
list_data.forEach(item => {
if (!item.user) return;
const userId = item.user.id;
// Inisialisasi user jika belum ada
if (!grouped[userId]) {
grouped[userId] = {
id: item.user.id,
name: item.user.name,
username: item.user.username,
email: item.user.email,
status: item.user.status,
rooms: {}
};
}
// Hitung index room berikutnya
const roomIndex = Object.keys(grouped[userId].rooms).length + 1;
// Tambahkan room ke user
if (item.room) {
grouped[userId].rooms[`room_${roomIndex}`] = {
id: item.room.id,
room: item.room.room,
code: item.room.code,
};
}
});
const list_data_return = Object.values(grouped);
const count_data = CommonHelper.countObject(list_data_return);
return ReturnHelper.successResponselist(
res,
200,
Language.lang.success_view,
count_data,
current_page,
total_count_data,
list_data_return
);
} catch (e: unknown) { } catch (e: unknown) {
log.error(e); log.error(e);
const err = e as Error; const err = e as Error;
@ -110,7 +154,7 @@ export class UserToRoomController {
var query = await UserToRoomModel.list(filter); var query = await UserToRoomModel.list(filter);
const data = await query.getMany(); const data = await query.getMany();
const filename = "user_to_room.csv"; const filename = "user_to_room.csv";
res.setHeader('Content-Type', 'text/csv'); res.setHeader('Content-Type', 'text/csv');
@ -173,15 +217,15 @@ export class UserToRoomController {
try { try {
const schema = Joi.object().keys({ const schema = Joi.object().keys({
user_id: Joi.string() user_id: Joi.string()
.uuid() .uuid()
.required() .required()
.label("User ID"), .label("User ID"),
room_id: Joi.string() room_id: Joi.string()
.uuid() .uuid()
.required() .required()
.label("Room ID"), .label("Room ID"),
// room_ids: Joi.array() // room_ids: Joi.array()
// .items(Joi.string().uuid().required()) // .items(Joi.string().uuid().required())
// .min(1) // .min(1)
@ -205,7 +249,7 @@ export class UserToRoomController {
const data = new UserToRoom() const data = new UserToRoom()
data.user = param.user_id; data.user = param.user_id;
data.room = param.room_id; data.room = param.room_id;
data.created_by = req.auth.data.name; data.created_by = req.auth?.data.name;
await OrmHelper.DB.manager.save(data); await OrmHelper.DB.manager.save(data);
@ -234,117 +278,117 @@ export class UserToRoomController {
} }
static async update(req: Request, res: Response, next: NextFunction): Promise<Response> { static async update(req: Request, res: Response, next: NextFunction): Promise<Response> {
/* /*
#swagger.tags = ['UserToRoom'] #swagger.tags = ['UserToRoom']
#swagger.security = [{ #swagger.security = [{
"bearerAuth": [] "bearerAuth": []
}] }]
#swagger.parameters['user_id'] = { #swagger.parameters['user_id'] = {
in: 'path', in: 'path',
description: 'User ID.', description: 'User ID.',
required: true, required: true,
type: 'string' type: 'string'
} }
#swagger.requestBody = { #swagger.requestBody = {
required: true, required: true,
content: { content: {
"application/json": { "application/json": {
schema: { schema: {
$ref: "#/components/schemas/user_to_room_update" $ref: "#/components/schemas/user_to_room_update"
} }
}
} }
} }
*/ }
*/
try {
const schema = Joi.object().keys({ try {
user_id: Joi.string().uuid().required().label('User ID'), const schema = Joi.object().keys({
room_ids: Joi.array() user_id: Joi.string().uuid().required().label('User ID'),
room_ids: Joi.array()
.items(Joi.string().uuid().required()) .items(Joi.string().uuid().required())
.min(1) .min(1)
.required() .required()
.label("Factory IDs") .label("Factory IDs")
// room_id: Joi.string().uuid().required().label('Room ID'), // room_id: Joi.string().uuid().required().label('Room ID'),
}); });
req.body.user_id = req.params['user_id'];
const param: any = await schema.validateAsync(req.body);
const userToRoomRepo = OrmHelper.DB.getRepository(UserToRoom); req.body.user_id = req.params['user_id'];
const userRepo = OrmHelper.DB.getRepository(User);
const roomRepo = OrmHelper.DB.getRepository(Room);
await userToRoomRepo const param: any = await schema.validateAsync(req.body);
.createQueryBuilder()
.delete()
.from(UserToRoom)
.where("service_id = :userId", { userId: param.user_id })
.execute();
let relation : UserToRoom; const userToRoomRepo = OrmHelper.DB.getRepository(UserToRoom);
for (const roomId of param.room_ids) { const userRepo = OrmHelper.DB.getRepository(User);
relation = new UserToRoom(); const roomRepo = OrmHelper.DB.getRepository(Room);
relation.user = await userRepo.findOneBy({ id: param.user_id });
relation.room = await roomRepo.findOneBy({ id: roomId });
relation.created_by = req.auth.data.name;
await userToRoomRepo.save(relation); await userToRoomRepo
} .createQueryBuilder()
.delete()
.from(UserToRoom)
.where("service_id = :userId", { userId: param.user_id })
.execute();
const data = await userToRoomRepo.createQueryBuilder("user_to_room") let relation: UserToRoom;
for (const roomId of param.room_ids) {
relation = new UserToRoom();
relation.user = await userRepo.findOneBy({ id: param.user_id });
relation.room = await roomRepo.findOneBy({ id: roomId });
relation.created_by = req.auth.data.name;
await userToRoomRepo.save(relation);
}
const data = await userToRoomRepo.createQueryBuilder("user_to_room")
.leftJoinAndSelect("user_to_room.user", "user") .leftJoinAndSelect("user_to_room.user", "user")
.leftJoinAndSelect("user_to_room.room", "room") .leftJoinAndSelect("user_to_room.room", "room")
.where("user_to_room.service_id = :userId", { userId: param.user_id }).getMany(); .where("user_to_room.service_id = :userId", { userId: param.user_id }).getMany();
return ReturnHelper.successResponseAny(res, 200, Language.lang.success_update, data); return ReturnHelper.successResponseAny(res, 200, Language.lang.success_update, data);
// const repo = OrmHelper.DB.getRepository(UserToRoom); // const repo = OrmHelper.DB.getRepository(UserToRoom);
// const data = await repo.findOneBy({ id: param.id }); // const data = await repo.findOneBy({ id: param.id });
// if (data != null) { // if (data != null) {
// data.user = param.user_id; // data.user = param.user_id;
// data.room = param.room_id; // data.room = param.room_id;
// data.updated_by = req.auth.data.name; // data.updated_by = req.auth.data.name;
// await repo.save(data); // await repo.save(data);
// return ReturnHelper.successResponseAny(res, 200, Language.lang.success_update, data); // return ReturnHelper.successResponseAny(res, 200, Language.lang.success_update, data);
// } else { // } else {
// return ReturnHelper.errorResponse(res, 404, 401, Language.lang.failed_not_found, ""); // return ReturnHelper.errorResponse(res, 404, 401, Language.lang.failed_not_found, "");
// } // }
} catch (e: unknown) { } catch (e: unknown) {
log.error(e); log.error(e);
const err = e as Error; const err = e as Error;
return ReturnHelper.errorResponse(res, 500, 402, Language.lang.failed_update, err.message); return ReturnHelper.errorResponse(res, 500, 402, Language.lang.failed_update, err.message);
}
} }
}
static async detail(req: Request, res: Response, next: NextFunction): Promise<void | Response> { static async detail(req: Request, res: Response, next: NextFunction): Promise<void | Response> {
/* /*
#swagger.tags = ['UserToRoom'] #swagger.tags = ['UserToRoom']
#swagger.security = [{ "bearerAuth": [] }] #swagger.security = [{ "bearerAuth": [] }]
#swagger.parameters['id'] = { description: '', in: 'path', type: 'string' } #swagger.parameters['id'] = { description: '', in: 'path', type: 'string' }
*/ */
try { try {
const schema = Joi.object().keys({ const schema = Joi.object().keys({
id: Joi.string().uuid().required().label("UserToRoom Id"), id: Joi.string().uuid().required().label("UserToRoom Id"),
}); });
let param: any = await schema.validateAsync(req.params); let param: any = await schema.validateAsync(req.params);
let data = await UserToRoomModel.list({ "id": param.id }).then((q) => q.getOne()); let data = await UserToRoomModel.list({ "id": param.id }).then((q) => q.getOne());
if (!data) throw { message: "UserToRoom Not Found" }; if (!data) throw { message: "UserToRoom Not Found" };
return ReturnHelper.successResponseAny(res, 200, Language.lang.success_view, data); return ReturnHelper.successResponseAny(res, 200, Language.lang.success_view, data);
} catch (e: unknown) { } catch (e: unknown) {
log.error(e); log.error(e);
const err = e as Error; const err = e as Error;
return ReturnHelper.errorResponse(res, 400, 401, Language.lang.failed_not_found, err.message); return ReturnHelper.errorResponse(res, 400, 401, Language.lang.failed_not_found, err.message);
}
} }
}
} }