The following lines contain the word 'select', 'insert', 'update' or 'delete':
PROCEDURE Insert_To_Errors_Table
( p_exposure_source_code IN VARCHAR2
, p_batch_id IN NUMBER
, p_exposure_interface_id IN NUMBER
, p_error_message_name IN VARCHAR2
, p_error_message_text IN VARCHAR2
)
IS
BEGIN
OE_DEBUG_PUB.Add('OEXVECEB: In Insert_To_Errors_Table');
INSERT INTO OE_EXP_INTERFACE_ERRORS (
EXPOSURE_SOURCE_CODE
, EXPOSURE_INTERFACE_ID
, BATCH_ID
, ERROR_MESSAGE_NAME
, ERROR_MESSAGE
, CREATED_BY
, CREATION_DATE
, LAST_UPDATED_BY
, LAST_UPDATE_DATE
, LAST_UPDATE_LOGIN
, PROGRAM_APPLICATION_ID
, PROGRAM_ID
, PROGRAM_UPDATE_DATE
, REQUEST_ID
)
VALUES (
p_exposure_source_code
, p_exposure_interface_id
, p_batch_id
, p_error_message_name
, p_error_message_text
, G_user_id
, SYSDATE
, G_user_id
, SYSDATE
, G_login_id
, G_appl_id
, G_program_id
, SYSDATE
, G_request_id
);
OE_DEBUG_PUB.Add('OEXVECEB: Out Insert_To_Errors_Table');
OE_DEBUG_PUB.Add('Insert_To_Errors_Table: Unexpected Error');
SELECT 1
INTO l_curr_valid
FROM fnd_currencies
WHERE currency_code = p_exposure_rec.currency_code
AND enabled_flag = 'Y'
AND NVL(start_date_active, TO_DATE('01/01/1000','DD/MM/YYYY'))
<= TRUNC(SYSDATE)
AND NVL(end_date_active, TO_DATE('31/12/9999','DD/MM/YYYY'))
>= TRUNC(SYSDATE) ;
Insert_To_Errors_Table(
p_exposure_source_code => p_exposure_rec.exposure_source_code
, p_exposure_interface_id => p_exposure_rec.exposure_interface_id
, p_batch_id => p_exposure_rec.batch_id
, p_error_message_name => 'OE_CC_IMP_CURRENCY_INVALID'
, p_error_message_text => l_message_text
);
SELECT ORGANIZATION_ID
FROM OE_INVOICE_TO_ORGS_V
WHERE ADDRESS_LINE_1 = p_exposure_rec.bill_to_address1
AND nvl( ADDRESS_LINE_2, fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_address2, fnd_api.g_miss_char)
AND nvl( ADDRESS_LINE_3, fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_address3,fnd_api.g_miss_char)
AND nvl( ADDRESS_LINE_4, fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_address4,fnd_api.g_miss_char)
AND nvl(TOWN_OR_CITY,fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_city, fnd_api.g_miss_char)
AND nvl(STATE,fnd_api.g_miss_char) =
nvl( p_bill_to_state, fnd_api.g_miss_char)
AND nvl(POSTAL_CODE,fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_postal_code, fnd_api.g_miss_char)
AND nvl(COUNTRY,fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_country, fnd_api.g_miss_char)
AND STATUS = 'A'
AND CUSTOMER_ID = p_exposure_rec.bill_to_customer_id
and address_status='A'; --2752321
SELECT /* MOAC_SQL_NO_CHANGE */ ORGANIZATION_ID
FROM OE_INVOICE_TO_ORGS_V
WHERE ADDRESS_LINE_1 = p_exposure_rec.bill_to_address1
AND nvl( ADDRESS_LINE_2, fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_address2, fnd_api.g_miss_char)
AND nvl( ADDRESS_LINE_3, fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_address3,fnd_api.g_miss_char)
AND nvl( ADDRESS_LINE_4, fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_address4,fnd_api.g_miss_char)
AND nvl(TOWN_OR_CITY,fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_city, fnd_api.g_miss_char)
AND nvl(STATE,fnd_api.g_miss_char) =
nvl( p_bill_to_state, fnd_api.g_miss_char)
AND nvl(POSTAL_CODE,fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_postal_code, fnd_api.g_miss_char)
AND nvl(COUNTRY,fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_country, fnd_api.g_miss_char)
AND STATUS = 'A'
and address_status='A' --2752321
AND CUSTOMER_ID IN
(
SELECT p_exposure_rec.bill_to_customer_id
FROM DUAL
UNION
SELECT CUST_ACCOUNT_ID
FROM HZ_CUST_ACCT_RELATE
WHERE RELATED_CUST_ACCOUNT_ID = p_exposure_rec.bill_to_customer_id
AND bill_to_flag = 'Y');
SELECT ORGANIZATION_ID
FROM OE_INVOICE_TO_ORGS_V
WHERE ADDRESS_LINE_1 = p_exposure_rec.bill_to_address1
AND nvl( ADDRESS_LINE_2, fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_address2, fnd_api.g_miss_char)
AND nvl( ADDRESS_LINE_3, fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_address3,fnd_api.g_miss_char)
AND nvl( ADDRESS_LINE_4, fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_address4,fnd_api.g_miss_char)
AND nvl(TOWN_OR_CITY,fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_city, fnd_api.g_miss_char)
AND nvl(STATE,fnd_api.g_miss_char) =
nvl( p_bill_to_state, fnd_api.g_miss_char)
AND nvl(POSTAL_CODE,fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_postal_code, fnd_api.g_miss_char)
AND nvl(COUNTRY,fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_country, fnd_api.g_miss_char)
AND STATUS = 'A'
and address_status='A'; --2752321
SELECT ORGANIZATION_ID
INTO l_bill_to_site_use_id
FROM OE_INVOICE_TO_ORGS_V
WHERE ADDRESS_LINE_1 = p_exposure_rec.bill_to_address1
AND nvl( ADDRESS_LINE_2, fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_address2, fnd_api.g_miss_char)
AND nvl( ADDRESS_LINE_3, fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_address3,fnd_api.g_miss_char)
AND DECODE(TOWN_OR_CITY,NULL,NULL,TOWN_OR_CITY||', ')||
DECODE(STATE, NULL, NULL, STATE || ', ')||
DECODE(POSTAL_CODE, NULL, NULL, POSTAL_CODE || ', ')||
DECODE(COUNTRY, NULL, NULL, COUNTRY) =
NVL( p_exposure_rec.bill_to_address4, fnd_api.g_miss_char)
AND STATUS = 'A'
AND CUSTOMER_ID = p_exposure_rec.bill_to_customer_id
and address_status='A'; --2752321
/*select userenv('CLIENT_INFO') into l_org from dual;
SELECT /* MOAC_SQL_NO_CHANGE */ ORGANIZATION_ID
INTO l_bill_to_site_use_id
FROM OE_INVOICE_TO_ORGS_V
WHERE ADDRESS_LINE_1 = p_exposure_rec.bill_to_address1
AND nvl( ADDRESS_LINE_2, fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_address2, fnd_api.g_miss_char)
AND nvl( ADDRESS_LINE_3, fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_address3,fnd_api.g_miss_char)
AND DECODE(TOWN_OR_CITY,NULL,NULL,TOWN_OR_CITY||', ')||
DECODE(STATE, NULL, NULL, STATE || ', ')||
DECODE(POSTAL_CODE, NULL, NULL, POSTAL_CODE || ', ')||
DECODE(COUNTRY, NULL, NULL, COUNTRY) =
nvl( p_exposure_rec.bill_to_address4, fnd_api.g_miss_char)
AND STATUS = 'A'
and address_status='A' --2752321
AND CUSTOMER_ID IN
(SELECT p_exposure_rec.bill_to_customer_id
FROM DUAL
UNION
SELECT CUST_ACCOUNT_ID
FROM HZ_CUST_ACCT_RELATE
WHERE RELATED_CUST_ACCOUNT_ID = p_exposure_rec.bill_to_customer_id
AND bill_to_flag = 'Y');
oe_debug_pub.add('after select found='||l_bill_to_site_use_id);
SELECT ORGANIZATION_ID
INTO l_bill_to_site_use_id
FROM OE_INVOICE_TO_ORGS_V
WHERE ADDRESS_LINE_1 = p_exposure_rec.bill_to_address1
AND nvl( ADDRESS_LINE_2, fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_address2, fnd_api.g_miss_char)
AND nvl( ADDRESS_LINE_3, fnd_api.g_miss_char) =
nvl( p_exposure_rec.bill_to_address3,fnd_api.g_miss_char)
AND DECODE(TOWN_OR_CITY,NULL,NULL,TOWN_OR_CITY||', ')||
DECODE(STATE, NULL, NULL, STATE || ', ')||
DECODE(POSTAL_CODE, NULL, NULL, POSTAL_CODE || ', ')||
DECODE(COUNTRY, NULL, NULL, COUNTRY) =
NVL( p_exposure_rec.bill_to_address4, fnd_api.g_miss_char)
AND STATUS = 'A'
and address_status='A'; --2752321
Insert_To_Errors_Table(
p_exposure_source_code => p_exposure_rec.exposure_source_code
, p_exposure_interface_id => p_exposure_rec.exposure_interface_id
, p_batch_id => p_exposure_rec.batch_id
, p_error_message_name => 'OE_CC_IMP_BILL_TO_ADDR_INVALID'
, p_error_message_text => l_message_text
);
Insert_To_Errors_Table(
p_exposure_source_code => p_exposure_rec.exposure_source_code
, p_exposure_interface_id => p_exposure_rec.exposure_interface_id
, p_batch_id => p_exposure_rec.batch_id
, p_error_message_name => 'OE_CC_IMP_BILL_TO_ADDR_MULTI'
, p_error_message_text => l_message_text
);
SELECT organization_id,
customer_id
INTO l_bill_to_site_use_id,
l_bill_to_customer_id
FROM oe_invoice_to_orgs_v
WHERE site_use_id=p_exposure_rec.bill_to_site_use_id;
Insert_To_Errors_Table(
p_exposure_source_code => p_exposure_rec.exposure_source_code
, p_exposure_interface_id => p_exposure_rec.exposure_interface_id
, p_batch_id => p_exposure_rec.batch_id
, p_error_message_name => 'OE_CC_IMP_SITE_USE_ID_INVALID'
, p_error_message_text => l_message_text
);
SELECT hca.cust_account_id
INTO l_bill_to_customer_id
FROM hz_cust_accounts hca,
hz_parties hp
WHERE hca.party_id = hp.party_id
AND hp.party_name = p_exposure_rec.bill_to_customer_name
AND hca.account_number = p_exposure_rec.bill_to_customer_number;
Insert_To_Errors_Table(
p_exposure_source_code => p_exposure_rec.exposure_source_code
, p_exposure_interface_id => p_exposure_rec.exposure_interface_id
, p_batch_id => p_exposure_rec.batch_id
, p_error_message_name => 'OE_CC_IMP_CUST_INFO_INVALID'
, p_error_message_text => l_message_text
);
Insert_To_Errors_Table(
p_exposure_source_code => p_exposure_rec.exposure_source_code
, p_exposure_interface_id => p_exposure_rec.exposure_interface_id
, p_batch_id => p_exposure_rec.batch_id
, p_error_message_name => 'OE_CC_IMP_CUST_INFO_MISSING'
, p_error_message_text => l_message_text
);
Insert_To_Errors_Table(
p_exposure_source_code => p_exposure_rec.exposure_source_code
, p_exposure_interface_id => p_exposure_rec.exposure_interface_id
, p_batch_id => p_exposure_rec.batch_id
, p_error_message_name => 'OE_CC_IMP_SITE_USE_INF_INVALID'
, p_error_message_text => l_message_text
);
SELECT distinct exposure_source_code
FROM oe_exposure_interface
WHERE request_id = G_request_id
AND import_status_code = G_PROCESSING;
SELECT COUNT(distinct operation_code)
FROM oe_exposure_interface
WHERE request_id = G_request_id
AND import_status_code = G_PROCESSING
AND exposure_source_code = p_exposure_source_code
HAVING COUNT(distinct operation_code) > 1;
SELECT distinct operation_code
FROM oe_exposure_interface
WHERE request_id = G_request_id
AND import_status_code = G_PROCESSING
AND operation_code NOT IN ('INSERT', 'UPDATE');
SELECT 1
INTO l_source_valid
FROM oe_lookups
WHERE lookup_type = 'EXTERNAL_EXPOSURE_SOURCE'
AND lookup_code = l_row.exposure_source_code
AND enabled_flag = 'Y'
AND NVL(start_date_active, TO_DATE('01/01/1000','DD/MM/YYYY'))
<= TRUNC(SYSDATE)
AND NVL(end_date_active, TO_DATE('31/12/9999','DD/MM/YYYY'))
>= TRUNC(SYSDATE) ;
Insert_To_Errors_Table(
p_exposure_source_code => l_row.exposure_source_code
, p_exposure_interface_id => NULL
, p_batch_id => NULL
, p_error_message_name => 'OE_CC_IMP_SOURCE_INVALID'
, p_error_message_text => l_message_text
);
UPDATE oe_exposure_interface
SET import_status_code = G_ERROR
WHERE exposure_source_code = l_row.exposure_source_code
AND request_id = G_request_id;
Insert_To_Errors_Table(
p_exposure_source_code => l_row.exposure_source_code
, p_exposure_interface_id => NULL
, p_batch_id => NULL
, p_error_message_name => 'OE_CC_IMP_OP_CODE_MULTIPLE'
, p_error_message_text => l_message_text
);
UPDATE oe_exposure_interface
SET import_status_code = G_ERROR
WHERE exposure_source_code = l_row.exposure_source_code
AND request_id = G_request_id;
SELECT *
FROM oe_exposure_interface
WHERE request_id = G_request_id
AND import_status_code = G_PROCESSING;
UPDATE oe_exposure_interface
SET import_status_code = G_ERROR
WHERE exposure_interface_id = l_exposure_rec.exposure_interface_id;
UPDATE oe_exposure_interface
SET import_status_code = G_VALIDATED,
bill_to_site_use_id = l_bill_to_site_use_id,
bill_to_customer_id = l_bill_to_customer_id,
last_update_login = G_login_id,
program_application_id = G_appl_id,
program_id = G_program_id,
program_update_date = TRUNC(sysdate),
-- org_id = G_org_id -- MOAC
org_id = l_org_id
WHERE exposure_interface_id = l_exposure_rec.exposure_interface_id;
PROCEDURE Insert_Exposure
( p_exposure_rec IN oe_exposure_interface%ROWTYPE
)
IS
CURSOR c_summary_row IS
SELECT rowid
FROM oe_credit_summaries
WHERE cust_account_id = p_exposure_rec.bill_to_customer_id
AND org_id = p_exposure_rec.org_id
AND site_use_id = p_exposure_rec.bill_to_site_use_id
AND currency_code = p_exposure_rec.currency_code
AND exposure_source_code = p_exposure_rec.exposure_source_code
AND balance_type = 18;
OE_DEBUG_PUB.Add('OEXVECEB: In Insert_Exposure', 4);
OE_DEBUG_PUB.Add('Row exist. Delete existing row', 5);
oe_credit_summaries_pkg.Delete_Row(
p_row_id => l_row_id
);
OE_DEBUG_PUB.Add('Insert the new exposure row', 5);
oe_credit_summaries_pkg.insert_row(
p_cust_account_id => p_exposure_rec.bill_to_customer_id
, p_org_id => p_exposure_rec.org_id
, p_site_use_id => p_exposure_rec.bill_to_site_use_id
, p_currency_code => p_exposure_rec.currency_code
, p_balance_type => 18
, p_balance => p_exposure_rec.exposure_amount
, p_creation_date => p_exposure_rec.creation_date
, p_created_by => p_exposure_rec.created_by
, p_last_update_date => p_exposure_rec.last_update_date
, p_last_updated_by => p_exposure_rec.last_updated_by
, p_last_update_login => p_exposure_rec.last_update_login
, p_program_application_id => p_exposure_rec.program_application_id
, p_program_id => p_exposure_rec.program_id
, p_program_update_date => p_exposure_rec.program_update_date
, p_request_id => p_exposure_rec.request_id
, p_exposure_source_code => p_exposure_rec.exposure_source_code
);
OE_DEBUG_PUB.Add('OEXVECEB: Out Insert_Exposure', 4);
END Insert_Exposure;
PROCEDURE Update_Exposure
( p_exposure_rec IN oe_exposure_interface%ROWTYPE
)
IS
CURSOR c_summary_exposure IS
SELECT rowid, balance
FROM oe_credit_summaries
WHERE cust_account_id = p_exposure_rec.bill_to_customer_id
AND org_id = p_exposure_rec.org_id
AND site_use_id = p_exposure_rec.bill_to_site_use_id
AND currency_code = p_exposure_rec.currency_code
AND exposure_source_code = p_exposure_rec.exposure_source_code
AND balance_type = 18;
OE_DEBUG_PUB.Add('OEXVECEB: In Update_Exposure', 4);
oe_credit_summaries_pkg.Update_Row(
p_row_id => l_row_id
, p_balance => p_exposure_rec.exposure_amount + l_balance
, p_last_update_date => p_exposure_rec.last_update_date
, p_last_updated_by => p_exposure_rec.last_updated_by
, p_last_update_login => p_exposure_rec.last_update_login
, p_program_application_id => p_exposure_rec.program_application_id
, p_program_id => p_exposure_rec.program_id
, p_program_update_date => p_exposure_rec.program_update_date
, p_request_id => p_exposure_rec.request_id
);
OE_DEBUG_PUB.Add('Inserting exposure row', 5);
oe_credit_summaries_pkg.Insert_Row(
p_cust_account_id => p_exposure_rec.bill_to_customer_id
, p_org_id => p_exposure_rec.org_id
, p_site_use_id => p_exposure_rec.bill_to_site_use_id
, p_currency_code => p_exposure_rec.currency_code
, p_balance_type => 18
, p_balance => p_exposure_rec.exposure_amount
, p_creation_date => p_exposure_rec.creation_date
, p_created_by => p_exposure_rec.created_by
, p_last_update_date => p_exposure_rec.last_update_date
, p_last_updated_by => p_exposure_rec.last_updated_by
, p_last_update_login => p_exposure_rec.last_update_login
, p_program_application_id => p_exposure_rec.program_application_id
, p_program_id => p_exposure_rec.program_id
, p_program_update_date => p_exposure_rec.program_update_date
, p_request_id => p_exposure_rec.request_id
, p_exposure_source_code => p_exposure_rec.exposure_source_code
);
OE_DEBUG_PUB.Add('OEXVECEB: Out Update_Exposure', 4);
END Update_Exposure;
SELECT *
FROM oe_exposure_interface
WHERE request_id = G_request_id
AND import_status_code = G_VALIDATED
ORDER BY exposure_source_code;
IF l_exposure_rec.operation_code = 'INSERT' THEN
Insert_Exposure(l_exposure_rec);
Update_Exposure(l_exposure_rec);
UPDATE oe_exposure_interface
SET import_status_code = 'COMPLETE'
WHERE exposure_interface_id = l_exposure_rec.exposure_interface_id;
SELECT ou.organization_id
FROM hr_operating_units ou
WHERE mo_global.check_access(ou.organization_id) = 'Y';
FND_MSG_PUB.Delete_Msg;
UPDATE oe_exposure_interface
SET exposure_interface_id = OE_EXPOSURE_INTERFACE_S.NextVal,
import_status_code = G_PROCESSING,
request_id = G_request_id
WHERE exposure_source_code = NVL(p_exposure_source_code, exposure_source_code)
AND NVL(batch_id, -99) = NVL(p_batch_id, NVL(batch_id,-99))
AND NVL(org_id, -99) = NVL(l_org_id, -99)
AND import_status_code IS NULL;
OE_DEBUG_PUB.Add(TO_CHAR(SQL%ROWCOUNT)||' rows updated');
UPDATE oe_exposure_interface
SET exposure_interface_id = OE_EXPOSURE_INTERFACE_S.NextVal,
import_status_code = G_PROCESSING,
request_id = G_request_id
WHERE exposure_source_code = NVL(p_exposure_source_code, exposure_source_code)
AND NVL(batch_id, -99) = NVL(p_batch_id, NVL(batch_id,-99))
AND NVL(org_id, -99) = NVL(l_org_id, -99)
AND import_status_code IS NULL;
OE_DEBUG_PUB.Add(TO_CHAR(SQL%ROWCOUNT)||' rows updated');
OE_DEBUG_PUB.Add('Selected rows for processing',2);
SELECT count(1)
INTO l_num_rows_to_process
FROM oe_exposure_interface
WHERE request_id = G_request_id
AND import_status_code = G_PROCESSING;
DELETE FROM oe_exp_interface_errors
WHERE exposure_source_code = NVL(p_exposure_source_code, exposure_source_code)
AND NVL(batch_id, -99) = NVL(p_batch_id, NVL(batch_id,-99));
SELECT count(1)
INTO l_num_rows_validated
FROM oe_exposure_interface
WHERE request_id = G_request_id
AND import_status_code = G_VALIDATED;
SELECT count(1)
INTO l_num_rows_failed
FROM oe_exposure_interface
WHERE request_id = G_request_id
AND import_status_code = G_ERROR;
UPDATE oe_exposure_interface
SET import_status_code = NULL
WHERE request_id = G_request_id
AND import_status_code = G_VALIDATED;
SELECT count(1)
INTO l_num_rows_imported
FROM oe_exposure_interface
WHERE request_id = G_request_id
AND import_status_code = G_COMPLETE;
DELETE
FROM oe_exposure_interface
WHERE request_id = G_request_id
AND import_status_code = G_COMPLETE;
SELECT ou.organization_id
FROM hr_operating_units ou
WHERE mo_global.check_access(ou.organization_id) = 'Y';
DELETE FROM oe_credit_summaries
WHERE exposure_source_code = NVL(p_exposure_source_code, exposure_source_code)
AND balance_type = 18
AND NVL(org_id, -99) = NVL(l_org_id, -99);
DELETE FROM oe_credit_summaries
WHERE exposure_source_code = NVL(p_exposure_source_code, exposure_source_code)
AND balance_type = 18
AND NVL(org_id, -99) = NVL(l_org_id, -99);