DBA Data[Home] [Help]

APPS.BIV_DBI_COLLECTION_INC dependencies on BIS_COLLECTION_UTILITIES

Line 323: bis_collection_utilities.log('Truncating table staging table');

319: if biv_dbi_collection_util.get_schema_name(l_biv_schema, l_error_message) <> 0 then
320: raise l_exception;
321: end if;
322:
323: bis_collection_utilities.log('Truncating table staging table');
324:
325: if biv_dbi_collection_util.truncate_table
326: (l_biv_schema, 'BIV_DBI_COLLECTION_STG', l_error_message) <> 0 then
327: raise l_exception;

Line 330: bis_collection_utilities.log('Populating staging table');

326: (l_biv_schema, 'BIV_DBI_COLLECTION_STG', l_error_message) <> 0 then
327: raise l_exception;
328: end if;
329:
330: bis_collection_utilities.log('Populating staging table');
331:
332: /* this is a temporary workaround to bad audit data cause by:
333: - bug 3050727 - fixed
334: */

Line 340: bis_collection_utilities.log('insert rows for previous backlog into staging table',1);

336: if biv_dbi_collection_util.correct_bad_audit(l_error_message) <> 0 then
337: raise l_exception;
338: end if;
339:
340: bis_collection_utilities.log('insert rows for previous backlog into staging table',1);
341: /*
342: insert rows for previous backlog into staging table
343: insert current audit activity rows into staging table
344: apply values from the incidents table to staging table

Line 347: bis_collection_utilities.log('insert current audit activity rows into staging table',1);

343: insert current audit activity rows into staging table
344: apply values from the incidents table to staging table
345: */
346:
347: bis_collection_utilities.log('insert current audit activity rows into staging table',1);
348:
349: bis_collection_utilities.log('apply values from the incidents table to staging table',1);
350:
351:

Line 349: bis_collection_utilities.log('apply values from the incidents table to staging table',1);

345: */
346:
347: bis_collection_utilities.log('insert current audit activity rows into staging table',1);
348:
349: bis_collection_utilities.log('apply values from the incidents table to staging table',1);
350:
351:
352: insert into biv_dbi_collection_stg
353: (incident_id

Line 582: bis_collection_utilities.log('Inserted ' || l_rowcount || ' rows',2);

578: --End bug#4932634
579:
580: l_rowcount := sql%rowcount;
581:
582: bis_collection_utilities.log('Inserted ' || l_rowcount || ' rows',2);
583:
584: commit;
585:
586:

Line 598: bis_collection_utilities.log('Inserted ' || l_temp_rowcount || ' rows',2);

594: ) <> 0 then
595: raise l_exception;
596: end if;
597:
598: bis_collection_utilities.log('Inserted ' || l_temp_rowcount || ' rows',2);
599:
600: l_rowcount := l_rowcount + l_temp_rowcount;
601:
602: commit;

Line 604: bis_collection_utilities.log('hide ''duplicate'' rows from backlog query',1);

600: l_rowcount := l_rowcount + l_temp_rowcount;
601:
602: commit;
603:
604: bis_collection_utilities.log('hide ''duplicate'' rows from backlog query',1);
605: /*
606: hide 'duplicate' rows from backlog query
607: */
608: update biv_dbi_collection_stg

Line 660: bis_collection_utilities.log('Updated ' || l_temp_rowcount || ' rows',2);

656: );
657:
658: l_temp_rowcount := sql%rowcount;
659:
660: bis_collection_utilities.log('Updated ' || l_temp_rowcount || ' rows',2);
661:
662: commit;
663:
664: bis_collection_utilities.log('Gathering Statistics for staging table');

Line 664: bis_collection_utilities.log('Gathering Statistics for staging table');

660: bis_collection_utilities.log('Updated ' || l_temp_rowcount || ' rows',2);
661:
662: commit;
663:
664: bis_collection_utilities.log('Gathering Statistics for staging table');
665:
666: if biv_dbi_collection_util.gather_statistics
667: (l_biv_schema, 'BIV_DBI_COLLECTION_STG', l_error_message) <> 0 then
668: raise l_exception;

Line 685: bis_collection_utilities.log('Staging table complete');

681: commit;
682:
683: l_total_rowcount := l_total_rowcount + l_rowcount;
684:
685: bis_collection_utilities.log('Staging table complete');
686:
687: else
688:
689: bis_collection_utilities.log('Staging table already complete, skipping');

Line 689: bis_collection_utilities.log('Staging table already complete, skipping');

685: bis_collection_utilities.log('Staging table complete');
686:
687: else
688:
689: bis_collection_utilities.log('Staging table already complete, skipping');
690:
691: end if;
692:
693: bis_collection_utilities.log('Checking for party merge');

Line 693: bis_collection_utilities.log('Checking for party merge');

689: bis_collection_utilities.log('Staging table already complete, skipping');
690:
691: end if;
692:
693: bis_collection_utilities.log('Checking for party merge');
694:
695: select distinct
696: old_customer_id from_party
697: , customer_id to_party

Line 705: bis_collection_utilities.log('found ' || l_from_party_tab.count || ' distinct party merges', 1);

701: biv_dbi_collection_stg stg
702: where
703: party_merge_flag = 'Y';
704:
705: bis_collection_utilities.log('found ' || l_from_party_tab.count || ' distinct party merges', 1);
706:
707: if p_activity_flag = 'N' then
708:
709: l_phase := 2;

Line 713: bis_collection_utilities.log('Starting Activity Incremental Load');

709: l_phase := 2;
710: l_timer := dbms_utility.get_time;
711: l_rowcount := 0;
712:
713: bis_collection_utilities.log('Starting Activity Incremental Load');
714:
715: if l_from_party_tab.count > 0 then
716:
717: forall i in 1..l_from_party_tab.count

Line 729: bis_collection_utilities.log('Party Merge updated ' || l_rowcount || ' rows',1);

725: customer_id = l_from_party_tab(i);
726:
727: l_rowcount := sql%rowcount;
728:
729: bis_collection_utilities.log('Party Merge updated ' || l_rowcount || ' rows',1);
730:
731: end if;
732:
733: if p_collect_from_date <> trunc(p_collect_from_date) then

Line 735: bis_collection_utilities.log('Merge activity from ' ||

731: end if;
732:
733: if p_collect_from_date <> trunc(p_collect_from_date) then
734:
735: bis_collection_utilities.log('Merge activity from ' ||
736: fnd_date.date_to_displaydt(p_collect_from_date) ||
737: ' to ' ||
738: fnd_date.date_to_displaydt(least(p_collect_to_date
739: ,trunc(p_collect_from_date)+(86399/86400)))

Line 852: bis_collection_utilities.log('Merged ' || l_temp_rowcount || ' rows',2);

848: l_temp_rowcount := sql%rowcount;
849:
850: l_rowcount := l_rowcount + l_temp_rowcount;
851:
852: bis_collection_utilities.log('Merged ' || l_temp_rowcount || ' rows',2);
853:
854: end if;
855:
856: if trunc(p_collect_to_date) >= trunc(p_collect_from_date) and

Line 859: bis_collection_utilities.log('Insert activity from ' ||

855:
856: if trunc(p_collect_to_date) >= trunc(p_collect_from_date) and
857: trunc(p_collect_from_date-(1/86400))+1 <= p_collect_to_date then
858:
859: bis_collection_utilities.log('Insert activity from ' ||
860: fnd_date.date_to_displaydt(trunc(p_collect_from_date-(1/86400))+1) ||
861: ' to ' ||
862: fnd_date.date_to_displaydt(p_collect_to_date)
863: ,1);

Line 930: bis_collection_utilities.log('Inserted ' || l_temp_rowcount || ' rows',2);

926: l_temp_rowcount := sql%rowcount;
927:
928: l_rowcount := l_rowcount + l_temp_rowcount;
929:
930: bis_collection_utilities.log('Inserted ' || l_temp_rowcount || ' rows',2);
931:
932: end if;
933:
934: update biv_dbi_collection_log

Line 948: bis_collection_utilities.log('Activity incremental load complete');

944: commit;
945:
946: l_total_rowcount := l_total_rowcount + l_rowcount;
947:
948: bis_collection_utilities.log('Activity incremental load complete');
949:
950: else
951:
952: bis_collection_utilities.log('Activity incremental load already complete, skipping');

Line 952: bis_collection_utilities.log('Activity incremental load already complete, skipping');

948: bis_collection_utilities.log('Activity incremental load complete');
949:
950: else
951:
952: bis_collection_utilities.log('Activity incremental load already complete, skipping');
953:
954: end if;
955:
956: if p_closed_flag = 'N' then

Line 962: bis_collection_utilities.log('Starting Closed Incremental Load');

958: l_phase := 3;
959: l_timer := dbms_utility.get_time;
960: l_rowcount := 0;
961:
962: bis_collection_utilities.log('Starting Closed Incremental Load');
963:
964: if l_from_party_tab.count > 0 then
965:
966: forall i in 1..l_from_party_tab.count

Line 977: bis_collection_utilities.log('Party Merge updated ' || l_rowcount || ' rows',1);

973: customer_id = l_from_party_tab(i);
974:
975: l_rowcount := sql%rowcount;
976:
977: bis_collection_utilities.log('Party Merge updated ' || l_rowcount || ' rows',1);
978:
979: end if;
980:
981: merge

Line 1096: bis_collection_utilities.log('Merged ' || l_temp_rowcount || ' rows',1);

1092: l_temp_rowcount := sql%rowcount;
1093:
1094: l_rowcount := l_rowcount + l_temp_rowcount;
1095:
1096: bis_collection_utilities.log('Merged ' || l_temp_rowcount || ' rows',1);
1097:
1098: update biv_dbi_collection_log
1099: set closed_flag = 'Y'
1100: , closed_count = l_rowcount

Line 1112: bis_collection_utilities.log('Closed incremental load complete');

1108: commit;
1109:
1110: l_total_rowcount := l_total_rowcount + l_rowcount;
1111:
1112: bis_collection_utilities.log('Closed incremental load complete');
1113:
1114: else
1115:
1116: bis_collection_utilities.log('Closed incremental load already complete, skipping');

Line 1116: bis_collection_utilities.log('Closed incremental load already complete, skipping');

1112: bis_collection_utilities.log('Closed incremental load complete');
1113:
1114: else
1115:
1116: bis_collection_utilities.log('Closed incremental load already complete, skipping');
1117:
1118: end if;
1119:
1120: if p_backlog_flag = 'N' then

Line 1126: bis_collection_utilities.log('Starting Backlog Incremental Load');

1122: l_phase := 4;
1123: l_timer := dbms_utility.get_time;
1124: l_rowcount := 0;
1125:
1126: bis_collection_utilities.log('Starting Backlog Incremental Load');
1127:
1128: if l_from_party_tab.count > 0 then
1129:
1130: forall i in 1..l_from_party_tab.count

Line 1141: bis_collection_utilities.log('Party merge updated ' || l_rowcount || ' rows',1);

1137: customer_id = l_from_party_tab(i);
1138:
1139: l_rowcount := sql%rowcount;
1140:
1141: bis_collection_utilities.log('Party merge updated ' || l_rowcount || ' rows',1);
1142:
1143: end if;
1144:
1145: bis_collection_utilities.log('Updating existing backlog rows',1);

Line 1145: bis_collection_utilities.log('Updating existing backlog rows',1);

1141: bis_collection_utilities.log('Party merge updated ' || l_rowcount || ' rows',1);
1142:
1143: end if;
1144:
1145: bis_collection_utilities.log('Updating existing backlog rows',1);
1146:
1147: /* identify all existing backlog rows and determine there new end dates
1148: */
1149: select

Line 1186: bis_collection_utilities.log('Updated ' || l_temp_rowcount || ' rows',2);

1182: l_temp_rowcount := sql%rowcount;
1183:
1184: l_rowcount := l_rowcount + l_temp_rowcount;
1185:
1186: bis_collection_utilities.log('Updated ' || l_temp_rowcount || ' rows',2);
1187:
1188: bis_collection_utilities.log('Inserting new backlog rows',1);
1189:
1190: /* insert new backlog rows

Line 1188: bis_collection_utilities.log('Inserting new backlog rows',1);

1184: l_rowcount := l_rowcount + l_temp_rowcount;
1185:
1186: bis_collection_utilities.log('Updated ' || l_temp_rowcount || ' rows',2);
1187:
1188: bis_collection_utilities.log('Inserting new backlog rows',1);
1189:
1190: /* insert new backlog rows
1191: */
1192: insert

Line 1286: bis_collection_utilities.log('Inserted ' || l_temp_rowcount || ' rows',2);

1282: l_temp_rowcount := sql%rowcount;
1283:
1284: l_rowcount := l_rowcount + l_temp_rowcount;
1285:
1286: bis_collection_utilities.log('Inserted ' || l_temp_rowcount || ' rows',2);
1287:
1288: update biv_dbi_collection_log
1289: set backlog_flag = 'Y'
1290: , backlog_count = l_rowcount

Line 1302: bis_collection_utilities.log('Backlog incremental load complete');

1298: commit;
1299:
1300: l_total_rowcount := l_total_rowcount + l_rowcount;
1301:
1302: bis_collection_utilities.log('Backlog incremental load complete');
1303:
1304: else
1305:
1306: bis_collection_utilities.log('Backlog incremental load already complete, skipping');

Line 1306: bis_collection_utilities.log('Backlog incremental load already complete, skipping');

1302: bis_collection_utilities.log('Backlog incremental load complete');
1303:
1304: else
1305:
1306: bis_collection_utilities.log('Backlog incremental load already complete, skipping');
1307: end if;
1308:
1309: if p_resolution_flag = 'N' then
1310:

Line 1315: bis_collection_utilities.log('Starting Resolution Incremental Load');

1311: l_phase := 5;
1312: l_timer := dbms_utility.get_time;
1313: l_rowcount := 0;
1314:
1315: bis_collection_utilities.log('Starting Resolution Incremental Load');
1316:
1317: if l_from_party_tab.count > 0 then
1318:
1319: forall i in 1..l_from_party_tab.count

Line 1330: bis_collection_utilities.log('Party Merge updated ' || l_rowcount || ' rows',1);

1326: customer_id = l_from_party_tab(i);
1327:
1328: l_rowcount := sql%rowcount;
1329:
1330: bis_collection_utilities.log('Party Merge updated ' || l_rowcount || ' rows',1);
1331:
1332: end if;
1333:
1334: merge

Line 1598: bis_collection_utilities.log('Merged ' || l_temp_rowcount || ' rows',1);

1594: l_temp_rowcount := sql%rowcount;
1595:
1596: l_rowcount := l_rowcount + l_temp_rowcount;
1597:
1598: bis_collection_utilities.log('Merged ' || l_temp_rowcount || ' rows',1);
1599:
1600: update biv_dbi_collection_log
1601: set resolution_flag = 'Y'
1602: , resolution_count = l_rowcount

Line 1614: bis_collection_utilities.log('Resolution incremental load complete');

1610: commit;
1611:
1612: l_total_rowcount := l_total_rowcount + l_rowcount;
1613:
1614: bis_collection_utilities.log('Resolution incremental load complete');
1615:
1616: else
1617:
1618: bis_collection_utilities.log('Resolution incremental load already complete, skipping');

Line 1618: bis_collection_utilities.log('Resolution incremental load already complete, skipping');

1614: bis_collection_utilities.log('Resolution incremental load complete');
1615:
1616: else
1617:
1618: bis_collection_utilities.log('Resolution incremental load already complete, skipping');
1619:
1620: end if;
1621:
1622:

Line 1684: if not bis_collection_utilities.setup( 'BIV_DBI_COLLECTION' ) then

1680: l_rowcount number;
1681:
1682: begin
1683:
1684: if not bis_collection_utilities.setup( 'BIV_DBI_COLLECTION' ) then
1685: raise g_bis_setup_exception;
1686: end if;
1687:
1688: biv_dbi_collection_util.get_last_log

Line 1714: bis_collection_utilities.log('Resuming previous incomplete Incremental Load');

1710: end if;
1711:
1712: if l_success_flag = 'N' then
1713:
1714: bis_collection_utilities.log('Resuming previous incomplete Incremental Load');
1715: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
1716: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
1717:
1718: l_process_success := process_incremental( l_log_rowid

Line 1715: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);

1711:
1712: if l_success_flag = 'N' then
1713:
1714: bis_collection_utilities.log('Resuming previous incomplete Incremental Load');
1715: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
1716: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
1717:
1718: l_process_success := process_incremental( l_log_rowid
1719: , l_collect_from_date

Line 1716: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);

1712: if l_success_flag = 'N' then
1713:
1714: bis_collection_utilities.log('Resuming previous incomplete Incremental Load');
1715: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
1716: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
1717:
1718: l_process_success := process_incremental( l_log_rowid
1719: , l_collect_from_date
1720: , l_collect_to_date

Line 1742: bis_collection_utilities.wrapup( p_status => true

1738: where rowid = l_log_rowid;
1739:
1740: commit;
1741:
1742: bis_collection_utilities.wrapup( p_status => true
1743: , p_period_from => l_collect_from_date
1744: , p_period_to => l_collect_to_date
1745: , p_count => l_rowcount
1746: );

Line 1748: if not bis_collection_utilities.setup( 'BIV_DBI_COLLECTION' ) then

1744: , p_period_to => l_collect_to_date
1745: , p_count => l_rowcount
1746: );
1747:
1748: if not bis_collection_utilities.setup( 'BIV_DBI_COLLECTION' ) then
1749: raise g_bis_setup_exception;
1750: end if;
1751:
1752: end if;

Line 1800: bis_collection_utilities.log('Starting new Initial Load');

1796: , g_login_id
1797: )
1798: returning rowid into l_log_rowid;
1799:
1800: bis_collection_utilities.log('Starting new Initial Load');
1801: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
1802: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
1803:
1804: commit;

Line 1801: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);

1797: )
1798: returning rowid into l_log_rowid;
1799:
1800: bis_collection_utilities.log('Starting new Initial Load');
1801: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
1802: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
1803:
1804: commit;
1805:

Line 1802: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);

1798: returning rowid into l_log_rowid;
1799:
1800: bis_collection_utilities.log('Starting new Initial Load');
1801: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
1802: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
1803:
1804: commit;
1805:
1806: l_process_success := process_incremental( l_log_rowid

Line 1830: bis_collection_utilities.wrapup( p_status => true

1826: where rowid = l_log_rowid;
1827:
1828: commit;
1829:
1830: bis_collection_utilities.wrapup( p_status => true
1831: , p_period_from => l_collect_from_date
1832: , p_period_to => l_collect_to_date
1833: , p_count => l_rowcount
1834: );

Line 1836: bis_collection_utilities.log('Incremental Load complete');

1832: , p_period_to => l_collect_to_date
1833: , p_count => l_rowcount
1834: );
1835:
1836: bis_collection_utilities.log('Incremental Load complete');
1837:
1838: exception
1839: when g_bis_setup_exception then
1840: rollback;

Line 1841: errbuf := 'Error in BIS_COLLECTION_UTILITIES.Setup';

1837:
1838: exception
1839: when g_bis_setup_exception then
1840: rollback;
1841: errbuf := 'Error in BIS_COLLECTION_UTILITIES.Setup';
1842: retcode := '2';
1843:
1844: when others then
1845: rollback;

Line 1849: bis_collection_utilities.wrapup( p_status => false

1845: rollback;
1846: if l_error_message is null then
1847: l_error_message := substr(sqlerrm,1,4000);
1848: end if;
1849: bis_collection_utilities.wrapup( p_status => false
1850: , p_message => l_error_message
1851: , p_period_from => l_collect_from_date
1852: , p_period_to => l_collect_to_date
1853: );