diff --git a/src/mssql/uscib-managed-sp/carnet-sequence/carnet-sequence.controller.ts b/src/mssql/uscib-managed-sp/carnet-sequence/carnet-sequence.controller.ts index c8601b9..24863df 100644 --- a/src/mssql/uscib-managed-sp/carnet-sequence/carnet-sequence.controller.ts +++ b/src/mssql/uscib-managed-sp/carnet-sequence/carnet-sequence.controller.ts @@ -1,7 +1,7 @@ -import { Controller, Get, Query } from '@nestjs/common'; +import { Body, Controller, Get, Post, Query } from '@nestjs/common'; import { CarnetSequenceService } from './carnet-sequence.service'; import { ApiTags } from '@nestjs/swagger'; -import { GetCarnetSequenceDTO } from 'src/oracle/uscib-managed-sp/carnet-sequence/carnet-sequence.dto'; +import { CreateCarnetSequenceDTO, GetCarnetSequenceDTO } from 'src/oracle/uscib-managed-sp/carnet-sequence/carnet-sequence.dto'; @Controller('mssql') export class CarnetSequenceController { @@ -13,4 +13,10 @@ export class CarnetSequenceController { getCarnetSequence(@Query() body: GetCarnetSequenceDTO) { return this.carnetSequenceService.getCarnetSequence(body); } + + @ApiTags('Carnet Sequence - Oracle') + @Post('/CreateCarnetSequence/') + createCarnetSequence(@Body() body: CreateCarnetSequenceDTO) { + return this.carnetSequenceService.createCarnetSequence(body); + } } diff --git a/src/mssql/uscib-managed-sp/carnet-sequence/carnet-sequence.service.ts b/src/mssql/uscib-managed-sp/carnet-sequence/carnet-sequence.service.ts index a235df7..a93e498 100644 --- a/src/mssql/uscib-managed-sp/carnet-sequence/carnet-sequence.service.ts +++ b/src/mssql/uscib-managed-sp/carnet-sequence/carnet-sequence.service.ts @@ -2,14 +2,14 @@ import { Injectable } from '@nestjs/common'; import { Connection, Request } from 'mssql'; import { MssqlDBService } from 'src/db/db.service'; import * as mssql from 'mssql' -import { GetCarnetSequenceDTO } from 'src/oracle/uscib-managed-sp/carnet-sequence/carnet-sequence.dto'; +import { CreateCarnetSequenceDTO, GetCarnetSequenceDTO } from 'src/oracle/uscib-managed-sp/carnet-sequence/carnet-sequence.dto'; @Injectable() export class CarnetSequenceService { constructor(private readonly mssqlDBService: MssqlDBService) { } - async getCarnetSequence(body:GetCarnetSequenceDTO) { + async getCarnetSequence(body: GetCarnetSequenceDTO) { let connection: Connection; try { @@ -27,4 +27,27 @@ export class CarnetSequenceService { } } } + + async createCarnetSequence(body: CreateCarnetSequenceDTO) { + let connection: Connection; + try { + connection = await this.mssqlDBService.getConnection(); + const request = new Request(connection); + request.input('P_SPID', mssql.Int, body.p_spid); + request.input('P_REGIONID', mssql.Float, body.p_regionid); + request.input('P_STARTNUMBER', mssql.Int, body.p_startnumber); + request.input('P_ENDNUMBER', mssql.Int, body.p_endnumber); + request.input('P_CARNETTYPE', mssql.VarChar(4000), body.p_carnettype); + const result = await request.execute('carnetsys.CREATECARNETSEQUENCE'); + return { data: result.recordset }; + + } catch (error) { + console.error('Error executing stored procedure:', error); + return { error: error.message } + } finally { + if (connection) { + connection.close(); + } + } + } } diff --git a/src/mssql/uscib-managed-sp/region/region.service.ts b/src/mssql/uscib-managed-sp/region/region.service.ts index 4d5aee7..3be8a9c 100644 --- a/src/mssql/uscib-managed-sp/region/region.service.ts +++ b/src/mssql/uscib-managed-sp/region/region.service.ts @@ -32,8 +32,8 @@ export class RegionService { try { connection = await this.mssqlDBService.getConnection(); const request = new Request(connection); - request.input('P_REGION', mssql.VarChar(30), body.p_region); - request.input('P_NAME', mssql.VarChar(30), body.p_name); + request.input('P_REGION', mssql.VarChar(mssql.MAX), body.p_region); + request.input('P_NAME', mssql.VarChar(mssql.MAX), body.p_name); const result = await request.execute('carnetsys.INSERTNEWREGION'); return { data: result.recordset }; diff --git a/src/mssql/uscib-managed-sp/sp-contacts/sp-contacts.controller.ts b/src/mssql/uscib-managed-sp/sp-contacts/sp-contacts.controller.ts index 08e95c0..9d0f2d5 100644 --- a/src/mssql/uscib-managed-sp/sp-contacts/sp-contacts.controller.ts +++ b/src/mssql/uscib-managed-sp/sp-contacts/sp-contacts.controller.ts @@ -1,7 +1,7 @@ -import { Body, Controller, Get, Post, Query } from '@nestjs/common'; +import { Body, Controller, Get, Post, Put, Query } from '@nestjs/common'; import { SpContactsService } from './sp-contacts.service'; import { ApiTags } from '@nestjs/swagger'; -import { getSPAllContactsDTO, getSPDefaultcontactDTO, inactivateSPContactDTO } from 'src/oracle/uscib-managed-sp/sp-contacts/sp-contacts.dto'; +import { getSPAllContactsDTO, getSPDefaultcontactDTO, inactivateSPContactDTO, InsertSPContactsDTO, setSPDefaultcontactDTO, UpdateSPContactsDTO } from 'src/oracle/uscib-managed-sp/sp-contacts/sp-contacts.dto'; @Controller('mssql') export class SpContactsController { @@ -26,4 +26,22 @@ export class SpContactsController { getSPAllContacts(@Query() body: getSPAllContactsDTO) { return this.spContactsService.getSpAllContacts(body); } + + @ApiTags('SPContacts - Oracle') + @Post('/InsertSPContacts') + insertSPContacts(@Body() body: InsertSPContactsDTO) { + return this.spContactsService.insertSPContacts(body); + } + + @ApiTags('SPContacts - Oracle') + @Post('/SetSPDefaultContact') + setSPDefaultcontact(@Query() body: setSPDefaultcontactDTO) { + return this.spContactsService.setSPDefaultcontact(body); + } + + @ApiTags('SPContacts - Oracle') + @Put('/UpdateSPContacts') + updateSPContacts(@Body() body: UpdateSPContactsDTO) { + return this.spContactsService.updateSPContacts(body); + } } diff --git a/src/mssql/uscib-managed-sp/sp-contacts/sp-contacts.service.ts b/src/mssql/uscib-managed-sp/sp-contacts/sp-contacts.service.ts index a0a0137..91078f4 100644 --- a/src/mssql/uscib-managed-sp/sp-contacts/sp-contacts.service.ts +++ b/src/mssql/uscib-managed-sp/sp-contacts/sp-contacts.service.ts @@ -1,15 +1,15 @@ import { Injectable } from '@nestjs/common'; import { MssqlDBService } from 'src/db/db.service'; import * as mssql from 'mssql' -import { Connection , Request} from 'mssql'; -import { getSPAllContactsDTO, getSPDefaultcontactDTO, inactivateSPContactDTO } from 'src/oracle/uscib-managed-sp/sp-contacts/sp-contacts.dto'; +import { Connection, Request } from 'mssql'; +import { getSPAllContactsDTO, getSPDefaultcontactDTO, inactivateSPContactDTO, InsertSPContactsDTO, setSPDefaultcontactDTO, UpdateSPContactsDTO } from 'src/oracle/uscib-managed-sp/sp-contacts/sp-contacts.dto'; @Injectable() export class SpContactsService { constructor(private readonly mssqlDBService: MssqlDBService) { } - async getSpAllContacts(body:getSPAllContactsDTO) { + async getSpAllContacts(body: getSPAllContactsDTO) { let connection: Connection; try { @@ -28,7 +28,7 @@ export class SpContactsService { } } - async getSPDefaultcontacts(body:getSPDefaultcontactDTO) { + async getSPDefaultcontacts(body: getSPDefaultcontactDTO) { let connection: Connection; try { @@ -47,7 +47,7 @@ export class SpContactsService { } } - async inactivateSPContact(body:inactivateSPContactDTO) { + async inactivateSPContact(body: inactivateSPContactDTO) { let connection: Connection; try { @@ -65,4 +65,80 @@ export class SpContactsService { } } } + + async insertSPContacts(body: InsertSPContactsDTO) { + let connection: Connection; + try { + connection = await this.mssqlDBService.getConnection(); + const request = new Request(connection); + request.input('P_SPID', mssql.Int, body.p_spid); + request.input('P_DEFCONTACTFLAG', mssql.VarChar(4000), body.p_defcontactflag); + request.input('P_FIRSTNAME', mssql.VarChar(4000), body.p_firstname); + request.input('P_LASTNAME', mssql.VarChar(4000), body.p_lastname); + request.input('P_MIDDLEINITIAL', mssql.VarChar(4000), body.P_MIDDLEINITIAL); + request.input('P_TITLE', mssql.VarChar(4000), body.p_title); + request.input('P_PHONENO', mssql.VarChar(4000), body.p_phoneno); + request.input('P_MOBILENO', mssql.VarChar(4000), body.p_mobileno); + request.input('P_FAXNO', mssql.VarChar(4000), body.p_faxno); + request.input('P_EMAILADDRESS', mssql.VarChar(4000), body.p_emailaddress); + request.input('P_USER_ID', mssql.VarChar(4000), body.p_user_id); + const result = await request.execute('carnetsys.INSERTSPCONTACTS'); + return { data: result.recordset }; + + } catch (error) { + console.error('Error executing stored procedure:', error); + return { error: error.message } + } finally { + if (connection) { + connection.close(); + } + } + } + + async setSPDefaultcontact(body: setSPDefaultcontactDTO) { + let connection: Connection; + try { + connection = await this.mssqlDBService.getConnection(); + const request = new Request(connection); + request.input('p_spContactid', mssql.Int, body.p_spcontactid); + const result = await request.execute('carnetsys.SETDEFAULTCONTACT'); + return { data: result.recordset }; + + } catch (error) { + console.error('Error executing stored procedure:', error); + return { error: error.message } + } finally { + if (connection) { + connection.close(); + } + } + } + + async updateSPContacts(body: UpdateSPContactsDTO) { + let connection: Connection; + try { + connection = await this.mssqlDBService.getConnection(); + const request = new Request(connection); + request.input('P_SPCONTACTID', mssql.Int, body.p_spcontactid); + request.input('P_FIRSTNAME', mssql.VarChar(4000), body.p_firstname); + request.input('P_LASTNAME', mssql.VarChar(4000), body.p_lastname); + request.input('P_MIDDLEINITIAL', mssql.VarChar(4000), body.P_MIDDLEINITIAL); + request.input('P_TITLE', mssql.VarChar(4000), body.p_title); + request.input('P_PHONENO', mssql.VarChar(4000), body.p_phoneno); + request.input('P_MOBILENO', mssql.VarChar(4000), body.p_mobileno); + request.input('P_FAXNO', mssql.VarChar(4000), body.p_faxno); + request.input('P_EMAILADDRESS', mssql.VarChar(4000), body.p_emailaddress); + request.input('P_USER_ID', mssql.VarChar(4000), body.p_user_id); + const result = await request.execute('carnetsys.INSERTNEWREGION'); + return { data: result.recordset }; + + } catch (error) { + console.error('Error executing stored procedure:', error); + return { error: error.message } + } finally { + if (connection) { + connection.close(); + } + } + } } diff --git a/src/mssql/uscib-managed-sp/sp/sp.controller.ts b/src/mssql/uscib-managed-sp/sp/sp.controller.ts index 87952a9..7565bd0 100644 --- a/src/mssql/uscib-managed-sp/sp/sp.controller.ts +++ b/src/mssql/uscib-managed-sp/sp/sp.controller.ts @@ -1,7 +1,7 @@ -import { Controller, Get, Query } from '@nestjs/common'; +import { Body, Controller, Get, Post, Put, Query } from '@nestjs/common'; import { ApiTags } from '@nestjs/swagger'; import { SpService } from './sp.service'; -import { getSelectedServiceproviderDTO } from 'src/oracle/uscib-managed-sp/sp/sp.dto'; +import { getSelectedServiceproviderDTO, InsertNewServiceProviderDTO, UpdateServiceProviderDTO } from 'src/oracle/uscib-managed-sp/sp/sp.dto'; @Controller('mssql') export class SpController { @@ -19,4 +19,16 @@ export class SpController { getSelectedServiceprovider(@Query() body: getSelectedServiceproviderDTO) { return this.spService.getSpBySpid(body); } + + @ApiTags('SP - Oracle') + @Post('/InsertNewServiceProvider') + insertNewServiceProvider(@Body() body: InsertNewServiceProviderDTO) { + return this.spService.insertNewServiceProvider(body); + } + + @ApiTags('SP - Oracle') + @Put('/UpdateServiceProvider') + updateServiceProider(@Body() body: UpdateServiceProviderDTO) { + return this.spService.updateServiceProvider(body); + } } diff --git a/src/mssql/uscib-managed-sp/sp/sp.service.ts b/src/mssql/uscib-managed-sp/sp/sp.service.ts index c512258..6acae53 100644 --- a/src/mssql/uscib-managed-sp/sp/sp.service.ts +++ b/src/mssql/uscib-managed-sp/sp/sp.service.ts @@ -1,7 +1,7 @@ import { Injectable } from '@nestjs/common'; import { Connection, Request } from 'mssql'; import { MssqlDBService } from 'src/db/db.service'; -import { getSelectedServiceproviderDTO } from 'src/oracle/uscib-managed-sp/sp/sp.dto'; +import { getSelectedServiceproviderDTO, InsertNewServiceProviderDTO, UpdateServiceProviderDTO } from 'src/oracle/uscib-managed-sp/sp/sp.dto'; import * as mssql from 'mssql' @Injectable() @@ -27,7 +27,7 @@ export class SpService { } } - async getSpBySpid(body:getSelectedServiceproviderDTO) { + async getSpBySpid(body: getSelectedServiceproviderDTO) { let connection: Connection; try { @@ -45,4 +45,73 @@ export class SpService { } } } + + async insertNewServiceProvider(body: InsertNewServiceProviderDTO) { + let connection: Connection; + try { + connection = await this.mssqlDBService.getConnection(); + const request = new Request(connection); + request.input('P_NAME', mssql.VarChar(4000), body.p_name); + request.input('P_LOOKUPCODE', mssql.VarChar(4000), body.p_lookupcode); + request.input('P_ADDRESS1', mssql.VarChar(4000), body.p_address1); + request.input('P_ADDRESS2', mssql.VarChar(4000), body.p_address2); + request.input('P_CITY', mssql.VarChar(4000), body.p_city); + request.input('P_STATE', mssql.VarChar(4000), body.p_state); + request.input('P_ZIP', mssql.VarChar(4000), body.p_zip); + request.input('P_COUNTRY', mssql.VarChar(4000), body.p_country); + request.input('P_ISSUINGREGION', mssql.VarChar(4000), body.p_issuingregion); + request.input('P_REPLACEMENTREGION', mssql.VarChar(4000), body.p_replacementregion); + request.input('P_BONDSURETY', mssql.VarChar(4000), body.p_bondsurety); + request.input('P_CARGOPOLICYNO', mssql.VarChar(4000), body.p_cargopolicyno); + request.input('P_CARGOSURETY', mssql.VarChar(4000), body.p_cargosurety); + request.input('P_USER_ID', mssql.VarChar(4000), body.p_user_id); + request.input('P_NOTES', mssql.VarChar(4000), body.P_NOTES); + request.input('P_FILEIDS', mssql.VarChar(4000), body.P_FILEIDS); + const result = await request.execute('carnetsys.INSERTNEWSP'); + return { data: result.recordset }; + + } catch (error) { + console.error('Error executing stored procedure:', error); + return { error: error.message } + } finally { + if (connection) { + connection.close(); + } + } + } + + async updateServiceProvider(body: UpdateServiceProviderDTO) { + let connection: Connection; + try { + connection = await this.mssqlDBService.getConnection(); + const request = new Request(connection); + request.input('P_SPID', mssql.Int, body.p_spid); + request.input('P_NAME', mssql.VarChar(4000), body.p_name); + request.input('P_LOOKUPCODE', mssql.VarChar(4000), body.p_lookupcode); + request.input('P_ADDRESS1', mssql.VarChar(4000), body.p_address1); + request.input('P_ADDRESS2', mssql.VarChar(4000), body.p_address2); + request.input('P_CITY', mssql.VarChar(4000), body.p_city); + request.input('P_STATE', mssql.VarChar(4000), body.p_state); + request.input('P_ZIP', mssql.VarChar(4000), body.p_zip); + request.input('P_COUNTRY', mssql.VarChar(4000), body.p_country); + request.input('P_BONDSURETY', mssql.VarChar(4000), body.p_bondsurety); + request.input('P_CARGOPOLICYNO', mssql.VarChar(4000), body.p_cargopolicyno); + request.input('P_CARGOSURETY', mssql.VarChar(4000), body.p_cargosurety); + request.input('P_REPLACEMENTREGION', mssql.VarChar(4000), body.p_replacementregion); + request.input('P_ISSUINGREGION', mssql.VarChar(4000), body.p_issuingregion); + request.input('P_USER_ID', mssql.VarChar(4000), body.p_user_id); + request.input('P_NOTES', mssql.VarChar(4000), body.P_NOTES); + request.input('P_FILEIDS', mssql.VarChar(4000), body.P_FILEIDS); + const result = await request.execute('carnetsys.UPDATESP'); + return { data: result.recordset }; + + } catch (error) { + console.error('Error executing stored procedure:', error); + return { error: error.message } + } finally { + if (connection) { + connection.close(); + } + } + } }