uppercase all response keys

adding carnet api
2025-09-22 11:27:01 +05:30 · 2025-09-20 16:52:38 +05:30
13 changed files with 548 additions and 163 deletions
--- a/src/pg/carnet-application/carnet-application.controller.ts
+++ b/src/pg/carnet-application/carnet-application.controller.ts
@ -53,40 +53,40 @@ export class CarnetApplicationController {
        return this.carnetApplicationService.UpdateHolder(body);
    }

-    // @Patch('UpdateExpGoodsAuthRep')
-    // UpdateExpGoodsAuthRep(@Body() body: UpdateExpGoodsAuthRepDTO) {
-    //     return this.carnetApplicationService.UpdateExpGoodsAuthRep(body);
-    // }
+    @Patch('UpdateExpGoodsAuthRep')
+    UpdateExpGoodsAuthRep(@Body() body: UpdateExpGoodsAuthRepDTO) {
+        return this.carnetApplicationService.UpdateExpGoodsAuthRep(body);
+    }

-    // @Post('AddGenerallistItems')
-    // AddGenerallistItems(@Body() body: AddGenerallistItemsDTO) {
-    //     return this.carnetApplicationService.AddGenerallistItems(body);
-    // }
+    @Post('AddGenerallistItems')
+    AddGenerallistItems(@Body() body: AddGenerallistItemsDTO) {
+        return this.carnetApplicationService.AddGenerallistItems(body);
+    }

-    // @Post('AddCountries')
-    // AddCountries(@Body() body: AddCountriesDTO) {
-    //     return this.carnetApplicationService.AddCountries(body);
-    // }
+    @Post('AddCountries')
+    AddCountries(@Body() body: AddCountriesDTO) {
+        return this.carnetApplicationService.AddCountries(body);
+    }

-    // @Put('EditGenerallistItems')
-    // EditGenerallistItems(@Body() body: EditGenerallistItemsDTO) {
-    //     return this.carnetApplicationService.EditGenerallistItems(body);
-    // }
+    @Put('EditGenerallistItems')
+    EditGenerallistItems(@Body() body: EditGenerallistItemsDTO) {
+        return this.carnetApplicationService.EditGenerallistItems(body);
+    }

-    // @Delete('DeleteGenerallistItems')
-    // DeleteGenerallistItems(@Body() body: DeleteGenerallistItemsDTO) {
-    //     return this.carnetApplicationService.DeleteGenerallistItems(body);
-    // }
+    @Delete('DeleteGenerallistItems')
+    DeleteGenerallistItems(@Body() body: DeleteGenerallistItemsDTO) {
+        return this.carnetApplicationService.DeleteGenerallistItems(body);
+    }

-    // @Patch('UpdateShippingDetails')
-    // UpdateShippingDetails(@Body() body: UpdateShippingDetailsDTO) {
-    //     return this.carnetApplicationService.UpdateShippingDetails(body);
-    // }
+    @Patch('UpdateShippingDetails')
+    UpdateShippingDetails(@Body() body: UpdateShippingDetailsDTO) {
+        return this.carnetApplicationService.UpdateShippingDetails(body);
+    }

-    // @Get('EstimatedFees/:P_SPID/:P_USERID/:P_HEADERID')
-    // EstimatedFees(@Param() body: GetCarnetControlCenterDTO) {
-    //     return this.carnetApplicationService.EstimatedFees(body);
-    // }
+    @Get('EstimatedFees/:P_SPID/:P_USERID/:P_HEADERID')
+    EstimatedFees(@Param() body: GetCarnetControlCenterDTO) {
+        return this.carnetApplicationService.EstimatedFees(body);
+    }

    // // processing [ PROCESSINGCENTER_PKG ]

--- a/src/pg/carnet-application/carnet-application.service.ts
+++ b/src/pg/carnet-application/carnet-application.service.ts
@ -26,7 +26,7 @@ import {
 import { BadRequestException } from 'src/exceptions/badRequest.exception';
 import { PoolClient } from 'pg';
 import { PgDBService } from 'src/db/db.service';
-import { checkPgUserDefinedErrors, handlePgError, releasePgClient, ResponseStatus } from 'src/utils/helper';
+import { checkPgUserDefinedErrors, handlePgError, releasePgClient, ResponseStatus, toUpperCaseKeys } from 'src/utils/helper';

@Injectable()
 export class CarnetApplicationService {
@ -63,7 +63,7 @@ export class CarnetApplicationService {
            return {
                statusCode: 200,
                message: ResponseStatus.transmitted,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -101,7 +101,7 @@ export class CarnetApplicationService {
            return {
                statusCode: 201,
                message: ResponseStatus.created,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -123,7 +123,7 @@ export class CarnetApplicationService {
            await client.query('BEGIN');

            const callProcQuery = `
-                                    CALL "CARNETSYS".carnetapplication_pkg_createapplication($1, $2, $3)
+                                    CALL "CARNETSYS".carnetapplication_pkg_updateholder($1, $2, $3)
                                `;
            await client.query(callProcQuery, [body.P_HEADERID, body.P_HOLDERID, cursorName]);

@ -139,7 +139,7 @@ export class CarnetApplicationService {
            return {
                statusCode: 200,
                message: ResponseStatus.updated,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -150,13 +150,375 @@ export class CarnetApplicationService {
        }
    }

-    async UpdateExpGoodsAuthRep(body: UpdateExpGoodsAuthRepDTO) { }
-    async AddGenerallistItems(body: AddGenerallistItemsDTO) { }
-    async EditGenerallistItems(body: AddGenerallistItemsDTO) { }
-    async DeleteGenerallistItems(body: DeleteGenerallistItemsDTO) { }
-    async AddCountries(body: AddCountriesDTO) { }
-    async UpdateShippingDetails(body: UpdateShippingDetailsDTO) { }
-    async EstimatedFees(body: GetCarnetControlCenterDTO) { }
+    async UpdateExpGoodsAuthRep(body: UpdateExpGoodsAuthRepDTO) {
+        let client: PoolClient | null = null;
+
+        const cursorName = 'p_cursor';
+
+        try {
+            client = await this.pgDBService.getConnection();
+
+            await client.query('BEGIN');
+
+            const callProcQuery = `
+                                    CALL "CARNETSYS".carnetapplication_pkg_updateexpgoodsauthrep($1, $2, $3, $4, $5, $6, $7, $8)
+                                `;
+            await client.query(callProcQuery, [body.P_HEADERID, body.P_COMMERCIALSAMPLEFLAG, body.P_PROFEQUIPMENTFLAG, body.P_EXHIBITIONSFAIRFLAG, body.P_AUTOFLAG, body.P_HORSEFLAG, body.P_AUTHREP, cursorName]);
+
+            // 🚫 DON'T quote the cursor name in FETCH
+            const fetchResult = await client.query(`FETCH ALL FROM ${cursorName}`);
+
+            // 🚫 DON'T quote the cursor name in CLOSE
+            await client.query(`CLOSE ${cursorName}`);
+            await client.query('COMMIT');
+
+            checkPgUserDefinedErrors(fetchResult);
+
+            return {
+                statusCode: 200,
+                message: ResponseStatus.updated,
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
+            };
+
+        } catch (error) {
+            if (client) await client.query('ROLLBACK');
+            handlePgError(error, CarnetApplicationService.name)
+        } finally {
+            releasePgClient(client)
+        }
+    }
+
+    async AddGenerallistItems(body: AddGenerallistItemsDTO) {
+        let client: PoolClient | null = null;
+
+        const cursorName = 'p_cursor';
+
+        try {
+            client = await this.pgDBService.getConnection();
+
+            await client.query('BEGIN');
+
+            function escapePostgresString(str: string): string {
+                if (str == null) return '';
+                return `"${str.replace(/\\/g, '\\\\').replace(/"/g, '\\"')}"`;
+            }
+
+            function escapePostgresValue(val: any): string {
+                if (val == null || val === '') return ''; // NULL or empty becomes empty string
+                if (typeof val === 'number') return String(val); // pass numbers as-is
+                return escapePostgresString(String(val)); // quote and escape strings
+            }
+
+            const contactLiterals = body.P_GLTABLE.map(c => {
+                const fields = [
+                    escapePostgresValue(c.ITEMNO),               // integer
+                    escapePostgresValue(c.ITEMDESCRIPTION),      // varchar
+                    escapePostgresValue(c.ITEMVALUE),            // numeric
+                    escapePostgresValue(c.NOOFPIECES),           // integer
+                    escapePostgresValue(c.ITEMWEIGHT),           // numeric
+                    escapePostgresValue(c.ITEMWEIGHTUOM),        // varchar
+                    escapePostgresValue(c.GOODSORIGINCOUNTRY),   // varchar
+                ];
+
+                return `(${fields.join(',')})`; // composite literal without outer double quotes
+            });
+
+            const pgArrayLiteral = `{${contactLiterals.join(',')}}`;
+
+            const callProcQuery = `
+                                    CALL "CARNETSYS".carnetapplication_pkg_addgenerallistitems($1, $2::"CARNETSYS".gltable[], $3, $4)
+                                `;
+            await client.query(callProcQuery, [body.P_HEADERID, pgArrayLiteral, body.P_USERID, cursorName]);
+
+            // 🚫 DON'T quote the cursor name in FETCH
+            const fetchResult = await client.query(`FETCH ALL FROM ${cursorName}`);
+
+            // 🚫 DON'T quote the cursor name in CLOSE
+            await client.query(`CLOSE ${cursorName}`);
+            await client.query('COMMIT');
+
+            checkPgUserDefinedErrors(fetchResult);
+
+            return {
+                statusCode: 200,
+                message: ResponseStatus.added,
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
+            };
+
+        } catch (error) {
+            if (client) await client.query('ROLLBACK');
+            handlePgError(error, CarnetApplicationService.name)
+        } finally {
+            releasePgClient(client)
+        }
+    }
+
+    async EditGenerallistItems(body: AddGenerallistItemsDTO) {
+        let client: PoolClient | null = null;
+
+        const cursorName = 'p_cursor';
+
+        try {
+            client = await this.pgDBService.getConnection();
+
+            await client.query('BEGIN');
+
+            function escapePostgresString(str: string): string {
+                if (str == null) return '';
+                return `"${str.replace(/\\/g, '\\\\').replace(/"/g, '\\"')}"`;
+            }
+
+            function escapePostgresValue(val: any): string {
+                if (val == null || val === '') return ''; // NULL or empty becomes empty string
+                if (typeof val === 'number') return String(val); // pass numbers as-is
+                return escapePostgresString(String(val)); // quote and escape strings
+            }
+
+            const contactLiterals = body.P_GLTABLE.map(c => {
+                const fields = [
+                    escapePostgresValue(c.ITEMNO),               // integer
+                    escapePostgresValue(c.ITEMDESCRIPTION),      // varchar
+                    escapePostgresValue(c.ITEMVALUE),            // numeric
+                    escapePostgresValue(c.NOOFPIECES),           // integer
+                    escapePostgresValue(c.ITEMWEIGHT),           // numeric
+                    escapePostgresValue(c.ITEMWEIGHTUOM),        // varchar
+                    escapePostgresValue(c.GOODSORIGINCOUNTRY),   // varchar
+                ];
+
+                return `(${fields.join(',')})`; // composite literal without outer double quotes
+            });
+
+            const pgArrayLiteral = `{${contactLiterals.join(',')}}`;
+
+            const callProcQuery = `
+                                    CALL "CARNETSYS".carnetapplication_pkg_editgenerallistitems($1, $2::"CARNETSYS".gltable[], $3, $4)
+                                `;
+            await client.query(callProcQuery, [body.P_HEADERID, pgArrayLiteral, body.P_USERID, cursorName]);
+
+            // 🚫 DON'T quote the cursor name in FETCH
+            const fetchResult = await client.query(`FETCH ALL FROM ${cursorName}`);
+
+            // 🚫 DON'T quote the cursor name in CLOSE
+            await client.query(`CLOSE ${cursorName}`);
+            await client.query('COMMIT');
+
+            checkPgUserDefinedErrors(fetchResult);
+
+            return {
+                statusCode: 200,
+                message: ResponseStatus.updated,
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
+            };
+
+        } catch (error) {
+            if (client) await client.query('ROLLBACK');
+            handlePgError(error, CarnetApplicationService.name)
+        } finally {
+            releasePgClient(client)
+        }
+    }
+
+    async DeleteGenerallistItems(body: DeleteGenerallistItemsDTO) {
+        let client: PoolClient | null = null;
+
+        const cursorName = 'p_cursor';
+
+        try {
+            client = await this.pgDBService.getConnection();
+
+            await client.query('BEGIN');
+
+            const callProcQuery = `
+                                    CALL "CARNETSYS".carnetapplication_pkg_deletegenerallistitems($1, $2, $3, $4)
+                                `;
+            await client.query(callProcQuery, [body.P_HEADERID, body.P_ITEMNO, body.P_USERID, cursorName]);
+
+            // 🚫 DON'T quote the cursor name in FETCH
+            const fetchResult = await client.query(`FETCH ALL FROM ${cursorName}`);
+
+            // 🚫 DON'T quote the cursor name in CLOSE
+            await client.query(`CLOSE ${cursorName}`);
+            await client.query('COMMIT');
+
+            checkPgUserDefinedErrors(fetchResult);
+
+            return {
+                statusCode: 200,
+                message: ResponseStatus.deleted,
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
+            };
+
+        } catch (error) {
+            if (client) await client.query('ROLLBACK');
+            handlePgError(error, CarnetApplicationService.name)
+        } finally {
+            releasePgClient(client)
+        }
+    }
+
+    async AddCountries(body: AddCountriesDTO) {
+        let client: PoolClient | null = null;
+
+        const cursorName = 'p_cursor';
+
+        try {
+            client = await this.pgDBService.getConnection();
+
+            await client.query('BEGIN');
+
+            function escapePostgresString(str: string): string {
+                if (str == null) return '';
+                return `"${str.replace(/\\/g, '\\\\').replace(/"/g, '\\"')}"`;
+            }
+
+            function escapePostgresValue(val: any): string {
+                if (val == null || val === '') return ''; // NULL or empty becomes empty string
+                if (typeof val === 'number') return String(val); // pass numbers as-is
+                return escapePostgresString(String(val)); // quote and escape strings
+            }
+
+            const contactLiterals = body.P_COUNTRYTABLE.map(c => {
+                const fields = [
+                    escapePostgresValue(c.P_VISISTTRANSITIND),               // integer
+                    escapePostgresValue(c.COUNTRYCODE),      // varchar
+                    escapePostgresValue(c.NOOFTIMESENTLEAVE),            // numeric
+                ];
+
+                return `(${fields.join(',')})`; // composite literal without outer double quotes
+            });
+
+            const pgArrayLiteral = `{${contactLiterals.join(',')}}`;
+
+            const callProcQuery = `
+                                    CALL "CARNETSYS".carnetapplication_pkg_addcountries($1, $2, $3::"CARNETSYS".carnetcountrytable[], $4, $5)
+                                `;
+            await client.query(callProcQuery, [body.P_HEADERID, body.P_USSETS, pgArrayLiteral, body.P_USERID, cursorName]);
+
+            // 🚫 DON'T quote the cursor name in FETCH
+            const fetchResult = await client.query(`FETCH ALL FROM ${cursorName}`);
+
+            // 🚫 DON'T quote the cursor name in CLOSE
+            await client.query(`CLOSE ${cursorName}`);
+            await client.query('COMMIT');
+
+            checkPgUserDefinedErrors(fetchResult);
+
+            return {
+                statusCode: 200,
+                message: ResponseStatus.added,
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
+            };
+
+        } catch (error) {
+            if (client) await client.query('ROLLBACK');
+            handlePgError(error, CarnetApplicationService.name)
+        } finally {
+            releasePgClient(client)
+        }
+    }
+
+    async UpdateShippingDetails(body: UpdateShippingDetailsDTO) {
+        let client: PoolClient | null = null;
+
+        const cursorName = 'p_cursor';
+
+        try {
+            client = await this.pgDBService.getConnection();
+
+            await client.query('BEGIN');
+
+            const callProcQuery = `
+                                    CALL "CARNETSYS".carnetapplication_pkg_updateshippingdetails($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15, $16, $17, $18, $19, $20, $21, $22, $23, $24, $25, $26, $27, $28, $29)
+                                `;
+            await client.query(callProcQuery,
+                [
+                    body.P_HEADERID,
+                    body.P_SHIPTOTYPE,
+                    body.P_SHIPCONTACTID,
+                    body.P_SHIPNAME,
+                    body.P_ADDRESS1,
+                    body.P_ADDRESS2,
+                    body.P_CITY,
+                    body.P_STATE,
+                    body.P_ZIP,
+                    body.P_COUNTRY,
+                    body.P_FIRSTNAME,
+                    body.P_LASTNAME,
+                    body.P_TITLE,
+                    body.P_PHONENO,
+                    body.P_MOBILENO,
+                    body.P_FAXNO,
+                    body.P_EMAILADDRESS,
+                    body.P_MIDDLEINITIAL,
+                    body.P_FORMOFSECURITY,
+                    body.P_INSPROTECTION,
+                    body.P_LDIPROTECTION,
+                    body.P_DELIVERYTYPE,
+                    body.P_DELIVERYMETHOD,
+                    body.P_PAYMENTMETHOD,
+                    body.P_CUSTCOURIERNO,
+                    body.P_REFNO,
+                    body.P_NOTES,
+                    body.P_USERID,
+                    cursorName
+                ]);
+
+            // 🚫 DON'T quote the cursor name in FETCH
+            const fetchResult = await client.query(`FETCH ALL FROM ${cursorName}`);
+
+            // 🚫 DON'T quote the cursor name in CLOSE
+            await client.query(`CLOSE ${cursorName}`);
+            await client.query('COMMIT');
+
+            checkPgUserDefinedErrors(fetchResult);
+
+            return {
+                statusCode: 200,
+                message: ResponseStatus.updated,
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
+            };
+
+        } catch (error) {
+            if (client) await client.query('ROLLBACK');
+            handlePgError(error, CarnetApplicationService.name)
+        } finally {
+            releasePgClient(client)
+        }
+    }
+
+    async EstimatedFees(body: GetCarnetControlCenterDTO) {
+
+        let client: PoolClient | null = null;
+
+        const cursorName = 'p_cursor';
+
+        try {
+            client = await this.pgDBService.getConnection();
+
+            await client.query('BEGIN');
+
+            const callProcQuery = `
+                                CALL "CARNETSYS".carnetapplication_pkg_estimatedfees($1, $2, $3, $4)
+                            `;
+            await client.query(callProcQuery, [body.P_SPID, body.P_USERID, body.P_HEADERID, cursorName]);
+
+            // 🚫 DON'T quote the cursor name in FETCH
+            const fetchResult = await client.query(`FETCH ALL FROM ${cursorName}`);
+
+            // 🚫 DON'T quote the cursor name in CLOSE
+            await client.query(`CLOSE ${cursorName}`);
+            await client.query('COMMIT');
+
+            return toUpperCaseKeys(fetchResult.rows);
+
+        } catch (error) {
+            if (client) await client.query('ROLLBACK');
+            handlePgError(error, CarnetApplicationService.name)
+        } finally {
+            releasePgClient(client)
+        }
+
+    }

    // processing [ PROCESSINGCENTER_PKG ]

@ -199,7 +561,7 @@ export class CarnetApplicationService {
            await client.query(`CLOSE ${cursorName}`);
            await client.query('COMMIT');

-            return fetchResult.rows;
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -231,7 +593,7 @@ export class CarnetApplicationService {
            await client.query(`CLOSE ${cursorName}`);
            await client.query('COMMIT');

-            return fetchResult.rows;
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -263,7 +625,7 @@ export class CarnetApplicationService {
            await client.query(`CLOSE ${cursorName}`);
            await client.query('COMMIT');

-            return fetchResult.rows;
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -295,7 +657,7 @@ export class CarnetApplicationService {
            await client.query(`CLOSE ${cursorName}`);
            await client.query('COMMIT');

-            return fetchResult.rows;
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -327,7 +689,7 @@ export class CarnetApplicationService {
            await client.query(`CLOSE ${cursorName}`);
            await client.query('COMMIT');

-            return fetchResult.rows;
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
--- a/src/pg/manage-clients/manage-clients.service.ts
+++ b/src/pg/manage-clients/manage-clients.service.ts
@ -1,6 +1,6 @@
 import { Injectable } from '@nestjs/common';
 import { ClientContactControlsDTO, CreateClientContactsDTO, CreateClientDataDTO, CreateClientLocationsDTO, GetClientContactByLacationIdDTO, GetClientDTO, GetPreparersDTO, UpdateClientContactsDTO, UpdateClientDTO, UpdateClientLocationsDTO } from 'src/dto/property.dto';
-import { checkPgUserDefinedErrors, handlePgError, releasePgClient, ResponseStatus } from 'src/utils/helper';
+import { checkPgUserDefinedErrors, handlePgError, releasePgClient, ResponseStatus, toUpperCaseKeys } from 'src/utils/helper';
 import { PoolClient } from 'pg';
 import { PgDBService } from 'src/db/db.service';

@ -52,7 +52,7 @@ export class ManageClientsService {
            return {
                statusCode: 201,
                message: ResponseStatus.created,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -105,7 +105,7 @@ export class ManageClientsService {
            return {
                statusCode: 201,
                message: ResponseStatus.updated,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -157,7 +157,7 @@ export class ManageClientsService {
            return {
                statusCode: 201,
                message: ResponseStatus.updated,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -208,7 +208,7 @@ export class ManageClientsService {
            return {
                statusCode: 201,
                message: ResponseStatus.updated,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -278,7 +278,7 @@ export class ManageClientsService {
            return {
                statusCode: 201,
                message: ResponseStatus.created,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -316,7 +316,7 @@ export class ManageClientsService {
            return {
                statusCode: 200,
                message: ResponseStatus.updated,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -354,7 +354,7 @@ export class ManageClientsService {
            return {
                statusCode: 200,
                message: ResponseStatus.inActivate,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -392,7 +392,7 @@ export class ManageClientsService {
            return {
                statusCode: 200,
                message: ResponseStatus.reActivate,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -459,7 +459,7 @@ export class ManageClientsService {
            return {
                statusCode: 201,
                message: ResponseStatus.created,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -494,7 +494,7 @@ export class ManageClientsService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -528,7 +528,7 @@ export class ManageClientsService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -562,7 +562,7 @@ export class ManageClientsService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -596,7 +596,7 @@ export class ManageClientsService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -630,7 +630,7 @@ export class ManageClientsService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
--- a/src/pg/manage-fee/manage-fee.service.ts
+++ b/src/pg/manage-fee/manage-fee.service.ts
@ -3,7 +3,7 @@ import { PgDBService } from 'src/db/db.service';
 import { CreateBasicFeeDTO, CreateBondRateDTO, CreateCargoRateDTO, CreateCfFeeDTO, CreateCsFeeDTO, CreateEfFeeDTO, CreateFeeCommDTO, GetFeeGeneralDTO, UpdateBasicFeeDTO, UpdateBondRateDTO, UpdateCargoRateDTO, UpdateCfFeeDTO, UpdateCsFeeDTO, UpdateEfFeeDTO, UpdateFeeCommDTO } from 'src/dto/property.dto';

 import { PoolClient } from 'pg';
-import { checkPgUserDefinedErrors, handlePgError, releasePgClient, ResponseStatus } from 'src/utils/helper';
+import { checkPgUserDefinedErrors, handlePgError, releasePgClient, ResponseStatus, toUpperCaseKeys } from 'src/utils/helper';

@Injectable()
 export class ManageFeeService {
@ -35,7 +35,7 @@ export class ManageFeeService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -82,7 +82,7 @@ export class ManageFeeService {
            return {
                statusCode: 201,
                message: ResponseStatus.created,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -129,7 +129,7 @@ export class ManageFeeService {
            return {
                statusCode: 200,
                message: ResponseStatus.updated,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -168,7 +168,7 @@ export class ManageFeeService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -219,7 +219,7 @@ export class ManageFeeService {
            return {
                statusCode: 201,
                message: ResponseStatus.created,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -266,7 +266,7 @@ export class ManageFeeService {
            return {
                statusCode: 200,
                message: ResponseStatus.updated,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -305,7 +305,7 @@ export class ManageFeeService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -353,7 +353,7 @@ export class ManageFeeService {
            return {
                statusCode: 201,
                message: ResponseStatus.created,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -400,7 +400,7 @@ export class ManageFeeService {
            return {
                statusCode: 200,
                message: ResponseStatus.updated,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -438,7 +438,7 @@ export class ManageFeeService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -488,7 +488,7 @@ export class ManageFeeService {
            return {
                statusCode: 201,
                message: ResponseStatus.created,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -535,7 +535,7 @@ export class ManageFeeService {
            return {
                statusCode: 200,
                message: ResponseStatus.updated,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -575,7 +575,7 @@ export class ManageFeeService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -622,7 +622,7 @@ export class ManageFeeService {
            return {
                statusCode: 201,
                message: ResponseStatus.created,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -668,7 +668,7 @@ export class ManageFeeService {
            return {
                statusCode: 200,
                message: ResponseStatus.updated,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -707,7 +707,7 @@ export class ManageFeeService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -757,7 +757,7 @@ export class ManageFeeService {
            return {
                statusCode: 201,
                message: ResponseStatus.created,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -803,7 +803,7 @@ export class ManageFeeService {
            return {
                statusCode: 200,
                message: ResponseStatus.updated,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -842,7 +842,7 @@ export class ManageFeeService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -888,7 +888,7 @@ export class ManageFeeService {
            return {
                statusCode: 201,
                message: ResponseStatus.created,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -934,7 +934,7 @@ export class ManageFeeService {
            return {
                statusCode: 200,
                message: ResponseStatus.updated,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
--- a/src/pg/manage-holder/manage-holder.service.ts
+++ b/src/pg/manage-holder/manage-holder.service.ts
@ -2,7 +2,7 @@ import { Injectable } from '@nestjs/common';
 import { PgDBService } from 'src/db/db.service';
 import { CONTACTSTABLE_ROW_DTO, CreateHolderContactsDTO, CreateHoldersDTO, GetHolderDTO, HolderActivateOrInactivateDTO, HolderContactActivateOrInactivateDTO, UpdateHolderContactDTO, UpdateHolderDTO } from 'src/dto/property.dto';
 import { PoolClient } from 'pg';
-import { checkPgUserDefinedErrors, handlePgError, releasePgClient, ResponseStatus } from 'src/utils/helper';
+import { checkPgUserDefinedErrors, handlePgError, releasePgClient, ResponseStatus, toUpperCaseKeys } from 'src/utils/helper';

@Injectable()
 export class ManageHolderService {
@ -55,7 +55,7 @@ export class ManageHolderService {
            return {
                statusCode: 201,
                message: ResponseStatus.created,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -122,7 +122,7 @@ export class ManageHolderService {
            return {
                statusCode: 201,
                message: ResponseStatus.created,
-                ...fetchResult?.rows?.[0] || {},
+                ...toUpperCaseKeys(fetchResult?.rows)[0],
            };
        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -179,7 +179,7 @@ export class ManageHolderService {
            return {
                statusCode: 201,
                message: ResponseStatus.updated,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -214,7 +214,7 @@ export class ManageHolderService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -265,7 +265,7 @@ export class ManageHolderService {
            return {
                statusCode: 201,
                message: ResponseStatus.updated,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -300,7 +300,7 @@ export class ManageHolderService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -337,7 +337,7 @@ export class ManageHolderService {
            return {
                statusCode: 200,
                message: ResponseStatus.inActivate,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -375,7 +375,7 @@ export class ManageHolderService {
            return {
                statusCode: 200,
                message: ResponseStatus.reActivate,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -413,7 +413,7 @@ export class ManageHolderService {
            return {
                statusCode: 200,
                message: ResponseStatus.inActivate,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -451,7 +451,7 @@ export class ManageHolderService {
            return {
                statusCode: 200,
                message: ResponseStatus.reActivate,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -486,7 +486,7 @@ export class ManageHolderService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
--- a/src/pg/param-table/param-table.service.ts
+++ b/src/pg/param-table/param-table.service.ts
@ -2,7 +2,7 @@ import { Injectable, Logger } from '@nestjs/common';
 import { PoolClient } from 'pg';
 import { PgDBService } from 'src/db/db.service';
 import { ActivateOrInactivateParamRecordDTO, CreateParamRecordDTO, CreateTableRecordDTO, getParamValuesDTO, SPID_DTO, UpdateParamRecordDTO } from 'src/dto/property.dto';
-import { checkPgUserDefinedErrors, handlePgError, releasePgClient, ResponseStatus } from 'src/utils/helper';
+import { checkPgUserDefinedErrors, handlePgError, releasePgClient, ResponseStatus, toUpperCaseKeys } from 'src/utils/helper';

@Injectable()
 export class ParamTableService {
@ -32,7 +32,7 @@ export class ParamTableService {
            await client.query(`CLOSE ${cursorName}`);
            await client.query('COMMIT');

-            return fetchResult.rows;
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -64,7 +64,7 @@ export class ParamTableService {
            await client.query(`CLOSE ${cursorName}`);
            await client.query('COMMIT');

-            return fetchResult.rows;
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -95,7 +95,7 @@ export class ParamTableService {
            await client.query(`CLOSE ${cursorName}`);
            await client.query('COMMIT');

-            return fetchResult.rows;
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -129,8 +129,10 @@ export class ParamTableService {

            checkPgUserDefinedErrors(fetchResult);

+            let fr: any = toUpperCaseKeys(fetchResult?.rows)
+
            // return fetchResult.rows;
-            return { statusCode: 201, message: ResponseStatus.created, ...fetchResult?.rows[0] };
+            return { statusCode: 201, message: ResponseStatus.created, ...fr[0] };

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -181,11 +183,13 @@ export class ParamTableService {

            checkPgUserDefinedErrors(fetchResult);

+            let fr: any = toUpperCaseKeys(fetchResult?.rows)
+
            // Return response
            return {
                statusCode: 201,
                message: ResponseStatus.created,
-                ...fetchResult?.rows?.[0] || {}
+                ...fr[0] || {}
            };

        } catch (error) {
@ -239,7 +243,7 @@ export class ParamTableService {
            return {
                statusCode: 200,
                message: ResponseStatus.updated,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
--- a/src/pg/uscib-managed-sp/carnet-sequence/carnet-sequence.service.ts
+++ b/src/pg/uscib-managed-sp/carnet-sequence/carnet-sequence.service.ts
@ -4,7 +4,7 @@ import { CreateCarnetSequenceDTO, SPID_DTO } from 'src/dto/property.dto';
 import { InternalServerException } from 'src/exceptions/internalServerError.exception';

 import { PoolClient } from 'pg';
-import { checkPgUserDefinedErrors, handlePgError, releasePgClient, ResponseStatus } from 'src/utils/helper';
+import { checkPgUserDefinedErrors, handlePgError, releasePgClient, ResponseStatus, toUpperCaseKeys } from 'src/utils/helper';


@Injectable()
@ -37,7 +37,7 @@ export class CarnetSequenceService {

            checkPgUserDefinedErrors(fetchResult);

-            return { statusCode: 201, message: ResponseStatus.created, ...fetchResult?.rows[0] };
+            return { statusCode: 201, message: ResponseStatus.created, ...toUpperCaseKeys(fetchResult?.rows)[0] };

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -69,7 +69,7 @@ export class CarnetSequenceService {
            await client.query(`CLOSE ${cursorName}`);
            await client.query('COMMIT');

-            return fetchResult.rows;
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
--- a/src/pg/uscib-managed-sp/region/region.service.ts
+++ b/src/pg/uscib-managed-sp/region/region.service.ts
@ -4,7 +4,7 @@ import { InsertRegionsDto, SPID_DTO, UpdateRegionDto } from 'src/dto/property.dt
 import { InternalServerException } from 'src/exceptions/internalServerError.exception';

 import { PoolClient } from 'pg';
-import { checkPgUserDefinedErrors, handlePgError, releasePgClient, ResponseStatus } from 'src/utils/helper';
+import { checkPgUserDefinedErrors, handlePgError, releasePgClient, ResponseStatus, toUpperCaseKeys } from 'src/utils/helper';

@Injectable()
 export class RegionService {
@ -39,7 +39,7 @@ export class RegionService {
            return {
                statusCode: 201,
                message: ResponseStatus.created,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -74,7 +74,7 @@ export class RegionService {

            checkPgUserDefinedErrors(fetchResult);

-            return { statusCode: 200, message: ResponseStatus.updated, ...fetchResult?.rows[0] || {} };
+            return { statusCode: 200, message: ResponseStatus.updated, ...toUpperCaseKeys(fetchResult?.rows)[0] || {} };

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -107,7 +107,7 @@ export class RegionService {
            await client.query(`CLOSE ${cursorName}`);
            await client.query('COMMIT');

-            return fetchResult.rows;
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
--- a/src/pg/uscib-managed-sp/sp-contacts/sp-contacts.service.ts
+++ b/src/pg/uscib-managed-sp/sp-contacts/sp-contacts.service.ts
@ -4,7 +4,7 @@ import { InternalServerException } from 'src/exceptions/internalServerError.exce

 import { PoolClient } from 'pg';
 import { PgDBService } from 'src/db/db.service';
-import { checkPgUserDefinedErrors, handlePgError, releasePgClient, ResponseStatus } from 'src/utils/helper';
+import { checkPgUserDefinedErrors, handlePgError, releasePgClient, ResponseStatus, toUpperCaseKeys } from 'src/utils/helper';

@Injectable()
 export class SpContactsService {
@ -52,7 +52,7 @@ export class SpContactsService {
            return {
                statusCode: 201,
                message: ResponseStatus.created,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -128,7 +128,7 @@ export class SpContactsService {
            return {
                statusCode: 200,
                message: ResponseStatus.updated,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -194,7 +194,7 @@ export class SpContactsService {
            await client.query(`CLOSE ${cursorName}`);
            await client.query('COMMIT');

-            return fetchResult.rows;
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -228,7 +228,7 @@ export class SpContactsService {
            await client.query(`CLOSE ${cursorName}`);
            await client.query('COMMIT');

-            return fetchResult.rows;
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
--- a/src/pg/uscib-managed-sp/sp/sp.service.ts
+++ b/src/pg/uscib-managed-sp/sp/sp.service.ts
@ -4,7 +4,7 @@ import { InsertNewServiceProviderDTO, SPID_DTO, UpdateServiceProviderDTO } from
 import { InternalServerException } from 'src/exceptions/internalServerError.exception';

 import { PoolClient } from 'pg';
-import { checkPgUserDefinedErrors, handlePgError, releasePgClient, ResponseStatus } from 'src/utils/helper';
+import { checkPgUserDefinedErrors, handlePgError, releasePgClient, ResponseStatus, toUpperCaseKeys } from 'src/utils/helper';

@Injectable()
 export class SpService {
@ -67,12 +67,12 @@ export class SpService {

            checkPgUserDefinedErrors(fetchResult);

-            return { statusCode: 201, message: ResponseStatus.created, ...fetchResult?.rows[0] || {} };
+            return { statusCode: 201, message: ResponseStatus.created, ...toUpperCaseKeys(fetchResult?.rows)[0] || {} };

        } catch (error) {
            if (client) await client.query('ROLLBACK');
            console.log(" i went through here ... ");
-            
+
            handlePgError(error, SpService.name)
        } finally {
            releasePgClient(client)
@ -125,7 +125,7 @@ export class SpService {

            checkPgUserDefinedErrors(fetchResult);

-            return { statusCode: 201, message: ResponseStatus.created, ...fetchResult?.rows[0] || {} };
+            return { statusCode: 201, message: ResponseStatus.created, ...toUpperCaseKeys(fetchResult?.rows)[0] || {} };

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -158,7 +158,7 @@ export class SpService {
            await client.query(`CLOSE ${cursorName}`);
            await client.query('COMMIT');

-            return fetchResult.rows;
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -192,7 +192,7 @@ export class SpService {
            await client.query(`CLOSE ${cursorName}`);
            await client.query('COMMIT');

-            return fetchResult.rows;
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
--- a/src/pg/user-maintenance/user-maintenance.controller.ts
+++ b/src/pg/user-maintenance/user-maintenance.controller.ts
@ -16,7 +16,7 @@ export class UserMaintenanceController {

    // SP_USER_DETAILS

-    // @Get('GetUserDetails/:P_USERID')
+    @Get('GetUserDetails/:P_USERID')
    async GetPreparers(@Param() params: USERID_DTO) {
        return await this.userMaintenanceService.GetSPUserDetails(params);
    }
--- a/src/pg/user-maintenance/user-maintenance.service.ts
+++ b/src/pg/user-maintenance/user-maintenance.service.ts
@ -1,6 +1,6 @@
 import { forwardRef, Inject, Injectable, Logger } from '@nestjs/common';
 import { CreateClientLoginsDTO, CreateSPLoginsDTO, CreateUSCIBLoginsDTO, EMAIL_DTO, SPID_CLIENTID_DTO, SPID_DTO, SPID_EMAIL_DTO, USERID_DTO } from 'src/dto/property.dto';
-import { checkPgUserDefinedErrors, handlePgError, normalizeKeysToUpperCase, releasePgClient, ResponseStatus } from 'src/utils/helper';
+import { checkPgUserDefinedErrors, handlePgError, normalizeKeysToUpperCase, releasePgClient, ResponseStatus, toUpperCaseKeys } from 'src/utils/helper';

 import { PoolClient } from 'pg';
 import { PgDBService } from 'src/db/db.service';
@ -22,48 +22,53 @@ export class UserMaintenanceService {
    async GetSPUserDetails(body: USERID_DTO): Promise<any> {
        let client: PoolClient | null = null;

-        const cursorName = 'p_cursor';
+        // Assign unique names to each cursor
+        const roleCursor = 'role_cursor';
+        const menuCursor = 'menu_cursor';
+        const menuPageCursor = 'menu_page_cursor';
+        const userDetailsCursor = 'user_details_cursor';

        try {
            client = await this.pgDBService.getConnection();
-
            await client.query('BEGIN');

            const callProcQuery = `
-                                CALL "CARNETSYS".userlogin_pkg_createclientlogins($1, $2, $3, $4, $5)
-                            `;
-            await client.query(callProcQuery,
-                [
-                    body.P_USERID,
-                    cursorName
-                ]);
+            CALL "CARNETSYS".spclientuser_pkg_getspuserdetails($1, $2, $3, $4, $5)
+        `;

-            // 🚫 DON'T quote the cursor name in FETCH
-            const fetchResult = await client.query(`FETCH ALL FROM ${cursorName}`);
+            await client.query(callProcQuery, [
+                body.P_USERID,
+                roleCursor,
+                menuCursor,
+                menuPageCursor,
+                userDetailsCursor
+            ]);
+
+            // Fetch all data from each cursor
+            const roleResult = await client.query(`FETCH ALL FROM ${roleCursor}`);
+            const menuResult = await client.query(`FETCH ALL FROM ${menuCursor}`);
+            const menuPageResult = await client.query(`FETCH ALL FROM ${menuPageCursor}`);
+            const userDetailsResult = await client.query(`FETCH ALL FROM ${userDetailsCursor}`);
+
+            // Close all cursors
+            await client.query(`CLOSE ${roleCursor}`);
+            await client.query(`CLOSE ${menuCursor}`);
+            await client.query(`CLOSE ${menuPageCursor}`);
+            await client.query(`CLOSE ${userDetailsCursor}`);

-            // 🚫 DON'T quote the cursor name in CLOSE
-            await client.query(`CLOSE ${cursorName}`);
            await client.query('COMMIT');

-            checkPgUserDefinedErrors(fetchResult);
-
-            const mailRes = await this.authService.sendMail({ P_TO: body.P_USERID, P_MAIL_TYPE: MailTypeDTO.REGISTER_CLIENT })
-
-            if (mailRes.statusCode !== 200) {
-                throw new InternalServerException();
-            }
-
            return {
-                statusCode: 201,
-                message: ResponseStatus.clientRegistrationDone,
-                ...fetchResult?.rows?.[0] || {}
+                roleDetails: toUpperCaseKeys(roleResult.rows),
+                menuDetails: toUpperCaseKeys(menuResult.rows),
+                menuPageDetails: toUpperCaseKeys(menuPageResult.rows),
+                userDetails: toUpperCaseKeys(userDetailsResult.rows),
            };
-
        } catch (error) {
            if (client) await client.query('ROLLBACK');
-            handlePgError(error, UserMaintenanceService.name)
+            handlePgError(error, 'getSpUserDetails');
        } finally {
-            releasePgClient(client)
+            releasePgClient(client);
        }
    }

@ -100,7 +105,7 @@ export class UserMaintenanceService {
            return {
                statusCode: 201,
                message: ResponseStatus.lockedUserDone,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -138,7 +143,7 @@ export class UserMaintenanceService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -183,7 +188,7 @@ export class UserMaintenanceService {
            return {
                statusCode: 201,
                message: ResponseStatus.created,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -221,7 +226,7 @@ export class UserMaintenanceService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -269,7 +274,7 @@ export class UserMaintenanceService {
            return {
                statusCode: 201,
                message: ResponseStatus.created,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -307,7 +312,7 @@ export class UserMaintenanceService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -341,7 +346,7 @@ export class UserMaintenanceService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
@ -392,7 +397,7 @@ export class UserMaintenanceService {
            return {
                statusCode: 201,
                message: ResponseStatus.clientRegistrationDone,
-                ...fetchResult?.rows?.[0] || {}
+                ...toUpperCaseKeys(fetchResult?.rows)[0]
            };

        } catch (error) {
@ -431,7 +436,7 @@ export class UserMaintenanceService {
            checkPgUserDefinedErrors(fetchResult);

            if (fetchResult?.rows.length > 0) {
-                return [normalizeKeysToUpperCase(fetchResult?.rows[0])]
+                return toUpperCaseKeys(fetchResult.rows)[0]
            }
            else {
                return [];
@ -473,7 +478,7 @@ export class UserMaintenanceService {

            checkPgUserDefinedErrors(fetchResult);

-            return fetchResult?.rows ? fetchResult?.rows : []
+            return toUpperCaseKeys(fetchResult.rows);

        } catch (error) {
            if (client) await client.query('ROLLBACK');
--- a/src/utils/helper.ts
+++ b/src/utils/helper.ts
@ -25,16 +25,30 @@ export enum ResponseStatus {
    reActivate = 'Reactivated Successfully',
    clientRegistrationDone = 'Client registration initiated successfully',
    lockedUserDone = 'Locked Successfully',
-    transmitted = 'Transmitted Successfully'
+    transmitted = 'Transmitted Successfully',
+    added = 'Added Successfully',
+    deleted = 'Deleted Successfully',
+
 }

 export function normalizeKeysToUpperCase(obj) {
-  return Object.keys(obj).reduce((acc, key) => {
-    acc[key.toUpperCase()] = obj[key];
-    return acc;
-  }, {});
+    return Object.keys(obj).reduce((acc, key) => {
+        acc[key.toUpperCase()] = obj[key];
+        return acc;
+    }, {});
 }

+export function toUpperCaseKeys(rows: Record<string, any>[]): Record<string, any>[] {
+    return rows.map(row => {
+        const transformedRow: Record<string, any> = {};
+        for (const key in row) {
+            transformedRow[key.toUpperCase()] = row[key];
+        }
+        return transformedRow;
+    });
+}
+
+

 export const handleError = (error: any, context: string = 'UnknownService'): never => {
    if (error instanceof BadRequestException || error instanceof BR) {
Author	SHA1	Message	Date
Kallesh B S	d6286d98ba	uppercase all response keys	2025-09-22 11:27:01 +05:30
Kallesh B S	a1fd355171	adding carnet api	2025-09-20 16:52:38 +05:30