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

update: add create for service examination

Browse Source
This commit is contained in:
wayanrivan
2026-04-15 15:56:14 +07:00
parent 134f1bbf8f
commit c660856638
2 changed files with 99 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

113
src/controllers/service_examination.ts
View File

@ -18,15 +18,15 @@ const log: Logger<ILogObj> = new Logger({
export class ServiceExaminationController {
static async list(req: Request, res: Response, next: NextFunction): Promise<void | Response> {
/*
#swagger.tags = ['Service Examination']
#swagger.security = [{ "bearerAuth": [] }]
#swagger.parameters['filter'] = { description: 'Filter: plain text or JSON object (service_id, 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'] } }
*/
#swagger.tags = ['Service Examination']
#swagger.security = [{ "bearerAuth": [] }]
#swagger.parameters['filter'] = { description: 'Filter: plain text or JSON object (service_id, 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"),
@ -74,13 +74,96 @@ export class ServiceExaminationController {
}
}
static async create(req: Request, res: Response, next: NextFunction): Promise<void | Response> {
/*
#swagger.tags = ['Service Examination']
#swagger.security = [{ "bearerAuth": [] }]
#swagger.requestBody = {
required: true,
content: {
"application/json": {
schema: { $ref: "#/components/schemas/serviceExamination" }
}
}
}
*/
const queryRunner = OrmHelper.DB.createQueryRunner();
await queryRunner.startTransaction();
try {
const schema = Joi.object().keys({
service_id: Joi.string().uuid().required().label("Service ID"),
examination_detail_ids: Joi.array()
.items(Joi.string().uuid())
.optional()
.label("Examination Detail IDs"),
});
let param: any = await schema.validateAsync(req.body);
// ✅ ambil service
let service = await ServiceModel.list({ "Service.id": param.service_id })
.then((q) => q.leftJoinAndSelect("Service.serviceType", "st")
.leftJoinAndSelect("Service.examination_details", "ed")
.getOne());
if (!service) throw { message: "Service " + Language.lang.failed_not_found };
// ✅ ambil examination details
let examinationDetails: any[] = [];
if (param.examination_detail_ids && param.examination_detail_ids.length > 0) {
for (const examinationDetailId of param.examination_detail_ids) {
const examinationDetail = await ExaminationDetailModel
.list({ "ExaminationDetail.id": examinationDetailId })
.then((q) => q.getOne());
if (examinationDetail) {
examinationDetails.push(examinationDetail);
}
}
}
// ✅ assign (CREATE behavior)
service.examination_details = examinationDetails;
service.created_by = req.auth?.data.name;
service.updated_by = req.auth?.data.name;
await queryRunner.manager.save(service);
await queryRunner.commitTransaction();
return ReturnHelper.successResponseAny(
res,
200,
Language.lang.success_insert,
service
);
} 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 update(req: Request, res: Response, next: NextFunction): Promise<void | Response> {
/*
#swagger.tags = ['Service Examination']
#swagger.security = [{ "bearerAuth": [] }]
#swagger.parameters['id'] = { in: 'path', type: 'string' }
#swagger.requestBody = { required: true, content: { "application/json": { schema: { $ref: "#/components/schemas/serviceExamination" } } } }
*/
#swagger.tags = ['Service Examination']
#swagger.security = [{ "bearerAuth": [] }]
#swagger.parameters['id'] = { in: 'path', type: 'string' }
#swagger.requestBody = { required: true, content: { "application/json": { schema: { $ref: "#/components/schemas/serviceExamination" } } } }
*/
const queryRunner = OrmHelper.DB.createQueryRunner();
await queryRunner.startTransaction();
@ -108,7 +191,7 @@ export class ServiceExaminationController {
}
service.examination_details = examinationDetails;
service.updated_by = req.auth.data.name;
service.updated_by = req.auth?.data.name;
await queryRunner.manager.save(service);
await queryRunner.commitTransaction();