kallesh/BE
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

holder modifying

Browse Source
This commit is contained in:
Kallesh B S 2025-07-08 17:56:39 +05:30
parent d1d0c09042
commit 2259d306b1
5 changed files with 35 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/dto/manage-clients/manage-clients.dto.ts
View File

@ -1,6 +1,6 @@
import { IntersectionType, PartialType } from "@nestjs/swagger"; import { IntersectionType, PartialType } from "@nestjs/swagger";
import { CONTACTSTABLE_DTO } from "../manage-holders/manage-holders-property.dto"; import { CONTACTSTABLE_DTO, LOCATIONID_DTO } from "../manage-holders/manage-holders-property.dto";
import { import {
DEFAULT_CONTACT_FLAG_DTO, EMAIL_ADDRESS_DTO, FAX_NO_DTO, FIRSTNAME_DTO, LASTNAME_DTO, DEFAULT_CONTACT_FLAG_DTO, EMAIL_ADDRESS_DTO, FAX_NO_DTO, FIRSTNAME_DTO, LASTNAME_DTO,
@ -102,7 +102,7 @@ export class UpdateClientLocationsDTO extends IntersectionType(
export class CreateClientContactsDTO extends IntersectionType( export class CreateClientContactsDTO extends IntersectionType(
SPID_DTO, SPID_DTO,
CLIENTID_DTO, LOCATIONID_DTO,
CONTACTSTABLE_DTO, CONTACTSTABLE_DTO,
DEFAULT_CONTACT_FLAG_DTO, DEFAULT_CONTACT_FLAG_DTO,
USERID_DTO USERID_DTO

2
src/mssql/manage-clients/manage-clients.service.ts
View File

@ -201,7 +201,7 @@ export class ManageClientsService {
connection = await this.mssqlDBService.getConnection(); connection = await this.mssqlDBService.getConnection();
const request = new Request(connection); const request = new Request(connection);
request.input('P_SPID', mssql.Int, finalBody.P_SPID); request.input('P_SPID', mssql.Int, finalBody.P_SPID);
request.input('P_CLIENTID', mssql.Int, finalBody.P_CLIENTID); request.input('P_LOCATIONID', mssql.Int, finalBody.P_LOCATIONID);
const contactTable = new mssql.Table('carnetsys.ContactsTable'); const contactTable = new mssql.Table('carnetsys.ContactsTable');
contactTable.create = true; contactTable.create = true;

18
src/oracle/carnet-application/carnet-application.service.ts
View File

@ -15,6 +15,7 @@ import {
GetCarnetControlCenterDTO GetCarnetControlCenterDTO
} from 'src/dto/property.dto'; } from 'src/dto/property.dto';
import { OracleService } from '../oracle.service'; import { OracleService } from '../oracle.service';
import { BadRequestException } from 'src/exceptions/badRequest.exception';
@Injectable() @Injectable()
export class CarnetApplicationService { export class CarnetApplicationService {
@ -272,7 +273,7 @@ export class CarnetApplicationService {
`BEGIN `BEGIN
CARNETAPPLICATION_PKG.CreateApplication( CARNETAPPLICATION_PKG.CreateApplication(
:P_SPID, :P_CLIENTID, :P_LOCATIONID, :P_USERID, :P_SPID, :P_CLIENTID, :P_LOCATIONID, :P_USERID,
:P_APPLICATIONNAME, :P_ORDERTYPE, :P_ERRORMESG :P_APPLICATIONNAME, :P_ORDERTYPE, :P_CURSOR
); );
END;`, END;`,
{ {
@ -282,8 +283,8 @@ export class CarnetApplicationService {
P_USERID: { val: body.P_USERID, type: oracledb.DB_TYPE_NVARCHAR }, P_USERID: { val: body.P_USERID, type: oracledb.DB_TYPE_NVARCHAR },
P_APPLICATIONNAME: { val: body.P_APPLICATIONNAME, type: oracledb.DB_TYPE_NVARCHAR }, P_APPLICATIONNAME: { val: body.P_APPLICATIONNAME, type: oracledb.DB_TYPE_NVARCHAR },
P_ORDERTYPE: { val: body.P_ORDERTYPE, type: oracledb.DB_TYPE_NVARCHAR }, P_ORDERTYPE: { val: body.P_ORDERTYPE, type: oracledb.DB_TYPE_NVARCHAR },
P_ERRORMESG: { dir: oracledb.BIND_OUT, type: oracledb.CURSOR }, // P_ERRORMESG: { dir: oracledb.BIND_OUT, type: oracledb.DB_TYPE_NVARCHAR },
// P_CURSOR: { type: oracledb.CURSOR, dir: oracledb.BIND_OUT } P_CURSOR: { type: oracledb.CURSOR, dir: oracledb.BIND_OUT }
}, },
{ outFormat: oracledb.OUT_FORMAT_OBJECT } { outFormat: oracledb.OUT_FORMAT_OBJECT }
); );
@ -291,12 +292,19 @@ export class CarnetApplicationService {
await connection.commit(); await connection.commit();
const outBinds = result.outBinds; const outBinds = result.outBinds;
if (!outBinds?.P_ERRORMESG) { if (!outBinds?.P_CURSOR) {
this.logger.error('One or more expected cursors are missing from stored procedure output.'); this.logger.error('One or more expected cursors are missing from stored procedure output.');
throw new InternalServerException("Incomplete data received from the database."); throw new InternalServerException("Incomplete data received from the database.");
} }
return await fetchCursor(outBinds.P_ERRORMESG, CarnetApplicationService.name); const fres: any = await fetchCursor(outBinds.P_CURSOR, CarnetApplicationService.name);
if (fres.length > 0 && fres[0].ERRORMESG) {
this.logger.warn(fres[0].ERRORMESG);
throw new BadRequestException(fres[0].ERRORMESG)
}
return { statusCode: 201, message: "Application created successfully", ...fres[0] };
} catch (error) { } catch (error) {
handleError(error, CarnetApplicationService.name) handleError(error, CarnetApplicationService.name)
} finally { } finally {

4
src/oracle/manage-clients/manage-clients.service.ts
View File

@ -351,12 +351,12 @@ export class ManageClientsService {
const result = await connection.execute( const result = await connection.execute(
`BEGIN `BEGIN
MANAGEPREPARER_PKG.CreateClientContact( MANAGEPREPARER_PKG.CreateClientContact(
:P_SPID, :P_CLIENTID, :P_CONTACTSTABLE, :P_DEFCONTACTFLAG, :P_USERID, :P_CURSOR :P_SPID, :P_LOCATIONID, :P_CONTACTSTABLE, :P_DEFCONTACTFLAG, :P_USERID, :P_CURSOR
); );
END;`, END;`,
{ {
P_SPID: { val: finalBody.P_SPID, type: oracledb.DB_TYPE_NUMBER }, P_SPID: { val: finalBody.P_SPID, type: oracledb.DB_TYPE_NUMBER },
P_CLIENTID: { val: finalBody.P_CLIENTID, type: oracledb.DB_TYPE_NUMBER }, P_LOCATIONID: { val: finalBody.P_LOCATIONID, type: oracledb.DB_TYPE_NUMBER },
P_CONTACTSTABLE: { val: CONTACTSTABLE_INSTANCE, type: oracledb.DB_TYPE_OBJECT }, P_CONTACTSTABLE: { val: CONTACTSTABLE_INSTANCE, type: oracledb.DB_TYPE_OBJECT },
P_DEFCONTACTFLAG: { val: finalBody.P_DEFCONTACTFLAG, type: oracledb.DB_TYPE_NVARCHAR }, P_DEFCONTACTFLAG: { val: finalBody.P_DEFCONTACTFLAG, type: oracledb.DB_TYPE_NVARCHAR },
P_USERID: { val: finalBody.P_USERID, type: oracledb.DB_TYPE_NVARCHAR }, P_USERID: { val: finalBody.P_USERID, type: oracledb.DB_TYPE_NVARCHAR },

33
src/oracle/manage-holders/manage-holders.service.ts
View File

@ -64,7 +64,7 @@ export class ManageHoldersService {
:P_USCIBMEMBERFLAG, :P_GOVAGENCYFLAG, :P_HOLDERNAME, :P_NAMEQUALIFIER, :P_USCIBMEMBERFLAG, :P_GOVAGENCYFLAG, :P_HOLDERNAME, :P_NAMEQUALIFIER,
:P_ADDLNAME, :P_ADDRESS1, :P_ADDRESS2, :P_CITY, :P_ADDLNAME, :P_ADDRESS1, :P_ADDRESS2, :P_CITY,
:P_STATE, :P_ZIP, :P_COUNTRY, :P_USERID, :P_STATE, :P_ZIP, :P_COUNTRY, :P_USERID,
:P_CONTACTSTABLE, :P_HOLDERCURSOR, :P_HOLDERCONTACTCURSOR :P_HOLDERCURSOR
); );
END;`, END;`,
{ {
@ -86,7 +86,7 @@ export class ManageHoldersService {
P_USERID: { val: finalBody.P_USERID, type: oracledb.DB_TYPE_NVARCHAR }, P_USERID: { val: finalBody.P_USERID, type: oracledb.DB_TYPE_NVARCHAR },
// P_CONTACTSTABLE: { val: CONTACTSTABLE_INSTANCE, type: oracledb.DB_TYPE_OBJECT }, // P_CONTACTSTABLE: { val: CONTACTSTABLE_INSTANCE, type: oracledb.DB_TYPE_OBJECT },
P_HOLDERCURSOR: { type: oracledb.CURSOR, dir: oracledb.BIND_OUT }, P_HOLDERCURSOR: { type: oracledb.CURSOR, dir: oracledb.BIND_OUT },
P_HOLDERCONTACTCURSOR: { type: oracledb.CURSOR, dir: oracledb.BIND_OUT } // P_HOLDERCONTACTCURSOR: { type: oracledb.CURSOR, dir: oracledb.BIND_OUT }
}, },
{ outFormat: oracledb.OUT_FORMAT_OBJECT } { outFormat: oracledb.OUT_FORMAT_OBJECT }
); );
@ -94,7 +94,7 @@ export class ManageHoldersService {
await connection.commit(); await connection.commit();
const outBinds: any = result.outBinds; const outBinds: any = result.outBinds;
if (!outBinds?.P_HOLDERCURSOR || !outBinds?.P_HOLDERCONTACTCURSOR) { if (!outBinds?.P_HOLDERCURSOR) {
this.logger.error('One or more expected cursors are missing from stored procedure output.'); this.logger.error('One or more expected cursors are missing from stored procedure output.');
throw new InternalServerException("Incomplete data received from the database."); throw new InternalServerException("Incomplete data received from the database.");
} }
@ -103,19 +103,21 @@ export class ManageHoldersService {
// throw new InternalServerException("Incomplete data received from the database."); // throw new InternalServerException("Incomplete data received from the database.");
// } // }
// const fres: any = await fetchCursor(outBinds.P_CURSOR, ParamTableService.name); const fres: any = await fetchCursor(outBinds.P_HOLDERCURSOR, ManageHoldersService.name);
// if (fres.length > 0 && fres[0].ERRORMESG) { if (fres.length > 0 && fres[0].ERRORMESG) {
// this.logger.warn(fres[0].ERRORMESG); this.logger.warn(fres[0].ERRORMESG);
// throw new BadRequestException(fres[0].ERRORMESG) throw new BadRequestException(fres[0].ERRORMESG)
// } }
// return { // return {
// holderDetails: await fetchCursor(outBinds.P_HOLDERCURSOR, ManageHoldersService.name), // holderDetails: await fetchCursor(outBinds.P_HOLDERCURSOR, ManageHoldersService.name),
// holderContactDetails: await fetchCursor(outBinds.P_HOLDERCONTACTCURSOR, ManageHoldersService.name), // holderContactDetails: await fetchCursor(outBinds.P_HOLDERCONTACTCURSOR, ManageHoldersService.name),
// } // }
return await fetchCursor(outBinds.P_HOLDERCURSOR, ManageHoldersService.name); // return await fetchCursor(outBinds.P_HOLDERCURSOR, ManageHoldersService.name);
return { statusCode: 201, message: "Created Successfully", ...fres[0] };
} catch (error) { } catch (error) {
handleError(error, ManageHoldersService.name) handleError(error, ManageHoldersService.name)
@ -149,7 +151,7 @@ export class ManageHoldersService {
const result = await connection.execute( const result = await connection.execute(
`BEGIN `BEGIN
MANAGEPREPARER_PKG.CreateClientContact( MANAGEHOLDER_PKG.CreateHoldercontact(
:P_SPID, :P_HOLDERID, :P_CONTACTSTABLE, :P_USERID, :P_CURSOR :P_SPID, :P_HOLDERID, :P_CONTACTSTABLE, :P_USERID, :P_CURSOR
); );
END;`, END;`,
@ -221,7 +223,7 @@ export class ManageHoldersService {
const result = await connection.execute( const result = await connection.execute(
`BEGIN `BEGIN
MANAGEHOLDER_PKG.UPDATEHOLDERS( MANAGEHOLDER_PKG.UPDATEHOLDER(
:P_HOLDERID, :P_SPID, :P_LOCATIONID, :P_HOLDERNO, :P_HOLDERID, :P_SPID, :P_LOCATIONID, :P_HOLDERNO,
:P_HOLDERTYPE, :P_USCIBMEMBERFLAG, :P_GOVAGENCYFLAG, :P_HOLDERNAME, :P_HOLDERTYPE, :P_USCIBMEMBERFLAG, :P_GOVAGENCYFLAG, :P_HOLDERNAME,
:P_NAMEQUALIFIER, :P_ADDLNAME, :P_ADDRESS1, :P_ADDRESS2, :P_NAMEQUALIFIER, :P_ADDLNAME, :P_ADDRESS1, :P_ADDRESS2,
@ -268,8 +270,7 @@ export class ManageHoldersService {
throw new BadRequestException(fres[0].ERRORMESG) throw new BadRequestException(fres[0].ERRORMESG)
} }
return { statusCode: 200, message: "Updated Successfully", ...fres[0] };
return { P_cursor: fres };
// return fres // return fres
} catch (error) { } catch (error) {
@ -315,7 +316,7 @@ export class ManageHoldersService {
throw new BadRequestException(fres[0].ERRORMESG) throw new BadRequestException(fres[0].ERRORMESG)
} }
return fres; return fres.length > 0 ? fres[0] : fres;
} catch (error) { } catch (error) {
handleError(error, ManageHoldersService.name) handleError(error, ManageHoldersService.name)
} finally { } finally {
@ -351,7 +352,7 @@ export class ManageHoldersService {
const result: Result<any> = await connection.execute( const result: Result<any> = await connection.execute(
`BEGIN `BEGIN
MANAGEHOLDER_PKG.UPDATEHOLDERS( MANAGEHOLDER_PKG.UpdateHolderContacts(
:P_HOLDERCONTACTID, :P_SPID, :P_FIRSTNAME, :P_LASTNAME, :P_HOLDERCONTACTID, :P_SPID, :P_FIRSTNAME, :P_LASTNAME,
:P_MIDDLEINITIAL, :P_TITLE, :P_PHONENO, :P_MOBILENO, :P_MIDDLEINITIAL, :P_TITLE, :P_PHONENO, :P_MOBILENO,
:P_FAXNO, :P_EMAILADDRESS, :P_USERID, :P_CURSOR :P_FAXNO, :P_EMAILADDRESS, :P_USERID, :P_CURSOR
@ -393,7 +394,7 @@ export class ManageHoldersService {
throw new BadRequestException(fres[0].ERRORMESG) throw new BadRequestException(fres[0].ERRORMESG)
} }
return { P_cursor: fres }; return { statusCode: 200, message: "Updated Successfully", ...fres[0] };
// return fres // return fres
} catch (error) { } catch (error) {