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

update service fare

Browse Source
This commit is contained in:
wayanrivan
2026-03-31 09:01:17 +07:00
parent 81004a6c7d
commit 8cca8afe83
2 changed files with 153 additions and 145 deletions
Download Patch File Download Diff File Expand all files Collapse all files

292
src/controllers/service_fare.ts
View File

@ -48,19 +48,19 @@ export class ServiceFareController {
var query = await ServiceModel.list(filter); var query = await ServiceModel.list(filter);
const res_count = query.clone(); const res_count = query.clone();
const res_list = query const res_list = query
.select([ .select([
"Service.id", "Service.id",
"Service.name", "Service.name",
]) ])
.leftJoin("Service.servicefare", "servicefare") .leftJoin("Service.servicefare", "servicefare")
.addSelect("MIN(servicefare.fare)", "min_fare") .addSelect("MIN(servicefare.fare)", "min_fare")
.addSelect("MAX(servicefare.fare)", "max_fare") .addSelect("MAX(servicefare.fare)", "max_fare")
.groupBy("Service.id") .groupBy("Service.id")
.orderBy("Service." + param.order_field, param.order_direction) .orderBy("Service." + param.order_field, param.order_direction)
.skip(offset) .skip(offset)
.take(limit); .take(limit);
if (param.with_deleted) { if (param.with_deleted) {
res_count.withDeleted(); res_count.withDeleted();
@ -190,19 +190,27 @@ export class ServiceFareController {
.getOne(); .getOne();
if (!fareType) throw { message: `Fare Type ID ${ft.faretype_id} not found` }; if (!fareType) throw { message: `Fare Type ID ${ft.faretype_id} not found` };
// Loop tiap service_class dalam faretype ini
for (const sc of ft.service_class) { for (const sc of ft.service_class) {
// Validasi ServiceClass
let serviceClass = await ServiceClassModel.list({ "ServiceClass.id": sc.service_class_id }).then((q) => q.getOne()); let serviceClass = await ServiceClassModel.list({ "ServiceClass.id": sc.service_class_id }).then((q) => q.getOne());
if (!serviceClass) throw { message: `Service Class ID ${sc.service_class_id} not found` }; if (!serviceClass) throw { message: `Service Class ID ${sc.service_class_id} not found` };
let serviceFare = new ServiceFare(); let serviceFare = await ServiceFareModel.list({
serviceFare.service = service; "ServiceFare.serviceId": param.service_id,
serviceFare.faretype = ft.faretype_id; "ServiceFare.faretype": ft.faretype_id,
serviceFare.serviceClass = serviceClass; "ServiceFare.serviceClassId": sc.service_class_id,
}).then((q) => q.getOne());
if (!serviceFare) {
serviceFare = new ServiceFare();
serviceFare.service = service;
serviceFare.faretype = ft.faretype_id;
serviceFare.serviceClass = serviceClass;
serviceFare.created_by = req.auth.data.name;
}
serviceFare.fare = String(sc.fare ?? 0); serviceFare.fare = String(sc.fare ?? 0);
serviceFare.created_by = req.auth.data.name;
serviceFare.updated_by = req.auth.data.name; serviceFare.updated_by = req.auth.data.name;
const saved = await queryRunner.manager.save(serviceFare); const saved = await queryRunner.manager.save(serviceFare);
@ -252,158 +260,158 @@ export class ServiceFareController {
} }
} }
static async update(req: Request, res: Response, next: NextFunction): Promise<void | Response> { // static async update(req: Request, res: Response, next: NextFunction): Promise<void | Response> {
/* // /*
#swagger.tags = ['Service Fare'] // #swagger.tags = ['Service Fare']
#swagger.security = [{ "bearerAuth": [] }] // #swagger.security = [{ "bearerAuth": [] }]
#swagger.parameters['id'] = { description: '', in: 'path', type: 'string' } // #swagger.parameters['id'] = { description: '', in: 'path', type: 'string' }
#swagger.requestBody = { required: true, content: { "application/json": { schema: { $ref: "#/components/schemas/serviceFare" } } } } // #swagger.requestBody = { required: true, content: { "application/json": { schema: { $ref: "#/components/schemas/serviceFare" } } } }
*/ // */
const queryRunner = OrmHelper.DB.createQueryRunner(); // const queryRunner = OrmHelper.DB.createQueryRunner();
await queryRunner.startTransaction(); // await queryRunner.startTransaction();
try { // try {
const schema = Joi.object().keys({ // const schema = Joi.object().keys({
service_id: Joi.string().uuid().required().label("Service ID"), // service_id: Joi.string().uuid().required().label("Service ID"),
faretype: Joi.array().items( // faretype: Joi.array().items(
Joi.object().keys({ // Joi.object().keys({
faretype_id: Joi.string().uuid().required().label("Fare Type ID"), // faretype_id: Joi.string().uuid().required().label("Fare Type ID"),
service_class: Joi.array().items( // service_class: Joi.array().items(
Joi.object().keys({ // Joi.object().keys({
service_class_id: Joi.string().uuid().required().label("Service Class ID"), // service_class_id: Joi.string().uuid().required().label("Service Class ID"),
fare: Joi.number().min(0).allow(null).label("Fare"), // fare: Joi.number().min(0).allow(null).label("Fare"),
}) // })
).min(1).required().label("Service Class"), // ).min(1).required().label("Service Class"),
}) // })
).min(1).required().label("Fare Type"), // ).min(1).required().label("Fare Type"),
}); // });
let param: any = await schema.validateAsync(req.body); // let param: any = await schema.validateAsync(req.body);
// Validasi Service // // Validasi Service
let service = await ServiceModel.list({ "Service.id": param.service_id }).then((q) => q.getOne()); // let service = await ServiceModel.list({ "Service.id": param.service_id }).then((q) => q.getOne());
if (!service) throw { message: "Service not found" }; // if (!service) throw { message: "Service not found" };
// Hapus semua row lama berdasarkan service_id // // Hapus semua row lama berdasarkan service_id
const existingFares = await ServiceFareModel.list({ "ServiceFare.serviceId": param.service_id }).then((q) => q.getMany()); // const existingFares = await ServiceFareModel.list({ "ServiceFare.serviceId": param.service_id }).then((q) => q.getMany());
if (existingFares.length > 0) { // if (existingFares.length > 0) {
await queryRunner.manager.remove(existingFares); // await queryRunner.manager.remove(existingFares);
} // }
const savedServiceFares: ServiceFare[] = []; // const savedServiceFares: ServiceFare[] = [];
// Loop tiap faretype // // Loop tiap faretype
for (const ft of param.faretype) { // for (const ft of param.faretype) {
// Validasi FareType // // Validasi FareType
let fareType = await OrmHelper.DB.getRepository("FareType") // let fareType = await OrmHelper.DB.getRepository("FareType")
.createQueryBuilder("FareType") // .createQueryBuilder("FareType")
.where("FareType.id = :id", { id: ft.faretype_id }) // .where("FareType.id = :id", { id: ft.faretype_id })
.getOne(); // .getOne();
if (!fareType) throw { message: `Fare Type ID ${ft.faretype_id} not found` }; // if (!fareType) throw { message: `Fare Type ID ${ft.faretype_id} not found` };
// Loop tiap service_class dalam faretype ini // // Loop tiap service_class dalam faretype ini
for (const sc of ft.service_class) { // for (const sc of ft.service_class) {
// Validasi ServiceClass // // Validasi ServiceClass
let serviceClass = await ServiceClassModel.list({ "ServiceClass.id": sc.service_class_id }).then((q) => q.getOne()); // let serviceClass = await ServiceClassModel.list({ "ServiceClass.id": sc.service_class_id }).then((q) => q.getOne());
if (!serviceClass) throw { message: `Service Class ID ${sc.service_class_id} not found` }; // if (!serviceClass) throw { message: `Service Class ID ${sc.service_class_id} not found` };
let serviceFare = new ServiceFare(); // let serviceFare = new ServiceFare();
serviceFare.service = service; // serviceFare.service = service;
serviceFare.faretype = ft.faretype_id; // serviceFare.faretype = ft.faretype_id;
serviceFare.serviceClass = serviceClass; // serviceFare.serviceClass = serviceClass;
serviceFare.fare = String(sc.fare ?? 0); // serviceFare.fare = String(sc.fare ?? 0);
serviceFare.created_by = req.auth.data.name; // serviceFare.created_by = req.auth.data.name;
serviceFare.updated_by = req.auth.data.name; // serviceFare.updated_by = req.auth.data.name;
const saved = await queryRunner.manager.save(serviceFare); // const saved = await queryRunner.manager.save(serviceFare);
savedServiceFares.push(saved); // savedServiceFares.push(saved);
} // }
} // }
await queryRunner.commitTransaction(); // await queryRunner.commitTransaction();
return ReturnHelper.successResponseAny(res, 200, Language.lang.success_update, savedServiceFares); // return ReturnHelper.successResponseAny(res, 200, Language.lang.success_update, savedServiceFares);
} catch (e: unknown) { // } catch (e: unknown) {
await queryRunner.rollbackTransaction(); // await queryRunner.rollbackTransaction();
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_view, err.message); // return ReturnHelper.errorResponse(res, 400, 401, Language.lang.failed_view, err.message);
} finally { // } finally {
await queryRunner.release(); // await queryRunner.release();
} // }
} // }
static async delete(req: Request, res: Response, next: NextFunction): Promise<Response> { // static async delete(req: Request, res: Response, next: NextFunction): Promise<Response> {
/* // /*
#swagger.tags = ['Service Fare'] // #swagger.tags = ['Service Fare']
#swagger.security = [{ "bearerAuth": [] }] // #swagger.security = [{ "bearerAuth": [] }]
#swagger.parameters['id'] = { in: 'path', required: true, type: 'string' } // #swagger.parameters['id'] = { in: 'path', required: true, type: 'string' }
#swagger.parameters['hard'] = { in: 'path', description: 'Is Hard Delete', required: false, type: 'boolean' } // #swagger.parameters['hard'] = { in: 'path', description: 'Is Hard Delete', required: false, type: 'boolean' }
*/ // */
try { // try {
const schema = Joi.object().keys({ // const schema = Joi.object().keys({
id: Joi.string().uuid().required().label("ID"), // id: Joi.string().uuid().required().label("ID"),
hard: Joi.bool().optional().allow("").label("Is hard delete?"), // hard: Joi.bool().optional().allow("").label("Is hard delete?"),
}); // });
const param: { id: string; hard: boolean } = await schema.validateAsync(req.params); // const param: { id: string; hard: boolean } = await schema.validateAsync(req.params);
let affected = 0; // let affected = 0;
if (!param.hard) { // if (!param.hard) {
let serviceFare: ServiceFare = await ServiceFareModel.list({ "ServiceFare.id": param.id }).then((q) => q.getOne()); // let serviceFare: ServiceFare = await ServiceFareModel.list({ "ServiceFare.id": param.id }).then((q) => q.getOne());
if (!serviceFare) throw { message: "Service Fare " + Language.lang.failed_not_found }; // if (!serviceFare) throw { message: "Service Fare " + Language.lang.failed_not_found };
serviceFare.deleted_by = req.auth.data.name; // serviceFare.deleted_by = req.auth.data.name;
serviceFare.deleted_at = moment().toDate(); // serviceFare.deleted_at = moment().toDate();
await OrmHelper.DB.manager.save(serviceFare); // await OrmHelper.DB.manager.save(serviceFare);
affected = 1; // affected = 1;
} else { // } else {
const repo = OrmHelper.DB.getRepository(ServiceFare); // const repo = OrmHelper.DB.getRepository(ServiceFare);
affected = (await repo.delete({ id: param.id })).affected ?? 0; // affected = (await repo.delete({ id: param.id })).affected ?? 0;
} // }
if (affected > 0) { // if (affected > 0) {
return ReturnHelper.successResponseAny(res, 200, Language.lang.success_delete, {}); // return ReturnHelper.successResponseAny(res, 200, Language.lang.success_delete, {});
} 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_delete, err.message); // return ReturnHelper.errorResponse(res, 500, 402, Language.lang.failed_delete, err.message);
} // }
} // }
static async restore(req: Request, res: Response, next: NextFunction): Promise<Response> { // static async restore(req: Request, res: Response, next: NextFunction): Promise<Response> {
/* // /*
#swagger.tags = ['Service Fare'] // #swagger.tags = ['Service Fare']
#swagger.security = [{ "bearerAuth": [] }] // #swagger.security = [{ "bearerAuth": [] }]
#swagger.parameters['id'] = { in: 'path', required: true, type: 'string' } // #swagger.parameters['id'] = { in: 'path', required: true, type: 'string' }
*/ // */
try { // try {
const schema = Joi.object().keys({ // const schema = Joi.object().keys({
id: Joi.string().uuid().required().label("ID"), // id: Joi.string().uuid().required().label("ID"),
}); // });
const param: any = await schema.validateAsync(req.params); // const param: any = await schema.validateAsync(req.params);
const repo = OrmHelper.DB.getRepository(ServiceFare); // const repo = OrmHelper.DB.getRepository(ServiceFare);
const affected = (await repo.restore({ id: param.id })).affected ?? 0; // const affected = (await repo.restore({ id: param.id })).affected ?? 0;
if (affected > 0) { // if (affected > 0) {
return ReturnHelper.successResponseAny(res, 200, Language.lang.success_restore, {}); // return ReturnHelper.successResponseAny(res, 200, Language.lang.success_restore, {});
} 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_restore, err.message); // return ReturnHelper.errorResponse(res, 500, 402, Language.lang.failed_restore, err.message);
} // }
} // }
} }

6
src/routes/private.ts
View File

@ -186,9 +186,9 @@ export class RoutePrivate {
app.get('/api/service-fare/option', ServiceFareController.option) app.get('/api/service-fare/option', ServiceFareController.option)
app.post('/api/service-fare/create', ServiceFareController.create) app.post('/api/service-fare/create', ServiceFareController.create)
app.get('/api/service-fare/detail/:id', ServiceFareController.detail) app.get('/api/service-fare/detail/:id', ServiceFareController.detail)
app.put('/api/service-fare/update/:id', ServiceFareController.update) // app.put('/api/service-fare/update/:id', ServiceFareController.update)
app.delete('/api/service-fare/delete/:id/:hard', ServiceFareController.delete) // app.delete('/api/service-fare/delete/:id/:hard', ServiceFareController.delete)
app.put('/api/service-fare/restore/:id', ServiceFareController.restore) // app.put('/api/service-fare/restore/:id', ServiceFareController.restore)
app.get('/api/service-package/list', ServicePackageController.list) app.get('/api/service-package/list', ServicePackageController.list)
app.post('/api/service-package/create', ServicePackageController.create) app.post('/api/service-package/create', ServicePackageController.create)