APPS.ENI_DBI_PCO_LOAD_PKG dependencies on ENI_DBI_PCO_LOAD_PKG

Line 1: PACKAGE BODY ENI_DBI_PCO_LOAD_PKG AS

1: PACKAGE BODY ENI_DBI_PCO_LOAD_PKG AS
2: /* $Header: ENIPCOLB.pls 120.3 2006/03/31 01:11:38 lparihar noship $ */
3:
4: -- Global variables
5: g_eni_schema VARCHAR2(30);

Line 251: ENI_DBI_PCO_LOAD_PKG.collect_modified_bills;

247:
248: SELECT sysdate into g_collection_date from dual;
249:
250: ELSIF (p_collect_mode = 'INCR') THEN
251: ENI_DBI_PCO_LOAD_PKG.collect_modified_bills;
252: -- procedure collects all the modified bills' information for incremental collection.
253: END IF;
254:
255: end assign_worker_ids;

Line 485: ENI_DBI_PCO_LOAD_PKG.assign_worker_ids(p_collect_mode);

481: END IF;
482: END IF;
483:
484: -- Assign worker ids to the interface table records
485: ENI_DBI_PCO_LOAD_PKG.assign_worker_ids(p_collect_mode);
486: FND_FILE.PUT_LINE(FND_FILE.LOG, 'assign worker ids');
487: FND_FILE.PUT_LINE(FND_FILE.LOG, 'Started Execution...............');
488:
489: SELECT count(*)

Line 501: ENI_DBI_PCO_LOAD_PKG.validate_set_parameters(p_num_workers,p_batch_size);

497: FND_FILE.PUT_LINE(FND_FILE.LOG, 'Number of Bills to work upon is:' || l_num_recs_to_process);
498: END IF;
499:
500: -- Validate the parameters and reset them if required
501: ENI_DBI_PCO_LOAD_PKG.validate_set_parameters(p_num_workers,p_batch_size);
502: FND_FILE.PUT_LINE(FND_FILE.LOG, 'validate_set_parameters');
503: FND_FILE.PUT_LINE(FND_FILE.LOG, 'after validate Batch size = ' || g_batch_size);
504:
505:

Line 507: ENI_DBI_PCO_LOAD_PKG.launch_workers(p_collect_mode);

503: FND_FILE.PUT_LINE(FND_FILE.LOG, 'after validate Batch size = ' || g_batch_size);
504:
505:
506: -- Launch workers
507: ENI_DBI_PCO_LOAD_PKG.launch_workers(p_collect_mode);
508: FND_FILE.PUT_LINE(FND_FILE.LOG, 'launch workers..');
509:
510: -- Wait for the workers to complete the collection.
511: IF (p_collect_mode = 'INCR') THEN

Line 512: ENI_DBI_PCO_LOAD_PKG.wait_for_workers('INCR');

508: FND_FILE.PUT_LINE(FND_FILE.LOG, 'launch workers..');
509:
510: -- Wait for the workers to complete the collection.
511: IF (p_collect_mode = 'INCR') THEN
512: ENI_DBI_PCO_LOAD_PKG.wait_for_workers('INCR');
513: ENI_DBI_PCO_LOAD_PKG.cleanup;
514: FND_FILE.PUT_LINE(FND_FILE.LOG, 'wait for workers is complete');
515: BIS_COLLECTION_UTILITIES.WRAPUP(
516: p_status => true,

Line 513: ENI_DBI_PCO_LOAD_PKG.cleanup;

509:
510: -- Wait for the workers to complete the collection.
511: IF (p_collect_mode = 'INCR') THEN
512: ENI_DBI_PCO_LOAD_PKG.wait_for_workers('INCR');
513: ENI_DBI_PCO_LOAD_PKG.cleanup;
514: FND_FILE.PUT_LINE(FND_FILE.LOG, 'wait for workers is complete');
515: BIS_COLLECTION_UTILITIES.WRAPUP(
516: p_status => true,
517: p_period_from => sysdate,

Line 520: ENI_DBI_PCO_LOAD_PKG.wait_for_workers('INIT');

516: p_status => true,
517: p_period_from => sysdate,
518: p_period_to => g_collection_date);
519: ELSE
520: ENI_DBI_PCO_LOAD_PKG.wait_for_workers('INIT');
521: IF ((p_purge_fact = 'YES') OR (p_organization_id IS NULL)) THEN
522: BIS_COLLECTION_UTILITIES.WRAPUP(
523: p_status => true,
524: p_period_from => sysdate,

Line 577: ENI_DBI_PCO_LOAD_PKG.part_count_collect(p_worker_id,p_collect_mode,p_error_occured);

573: IF (SQL%ROWCOUNT = 0) THEN
574: EXIT;
575: ELSE
576: COMMIT;
577: ENI_DBI_PCO_LOAD_PKG.part_count_collect(p_worker_id,p_collect_mode,p_error_occured);
578:
579: -- Updating the status of the rows worked upon to 0.
580: UPDATE eni_dbi_pco_worker_assignments
581: SET incr_status = 0

Line 807: END ENI_DBI_PCO_LOAD_PKG;

803: ENI_DBI_UTIL_PKG.LOG(l_error_code||':'||l_error_msg);
804:
805: END PART_COUNT_COLLECT; -- End of the procedure definition
806:
807: END ENI_DBI_PCO_LOAD_PKG;