55: , last_updated_by = g_user_id
56: , last_update_login = g_login_id
57: where current of c_wrapup;
58:
59: bis_collection_utilities.put_line('Initial Load complete');
60:
61: end if;
62:
63: close c_wrapup;
96: l_rowcount number;
97:
98:
99: begin
100: if not bis_collection_utilities.setup( 'BIV_DBI_COLLECT_INIT_SETUP' ) then
101: raise g_bis_setup_exception;
102: end if;
103:
104: /* this is a temporary workaround to bad audit data cause by:
124: if nvl(l_success_flag,'Y') = 'N' then
125:
126: if p_force = 'Y' then
127: l_success_flag := 'Y';
128: bis_collection_utilities.log('Last collection did not complete successfully, forcing new initial load');
129: end if;
130:
131: end if;
132:
185: -- For marking escalated_flag and escalation date
186: IF( g_process_type = 'INITIAL_LOAD')
187: THEN
188:
189: bis_collection_utilities.log('Starting Escalations Staging table population ');
190:
191: bis_collection_utilities.log('Truncating table '||l_biv_schema||'.'||'BIV_DBI_ESCALATIONS_STG');
192:
193: if biv_dbi_collection_util.truncate_table
187: THEN
188:
189: bis_collection_utilities.log('Starting Escalations Staging table population ');
190:
191: bis_collection_utilities.log('Truncating table '||l_biv_schema||'.'||'BIV_DBI_ESCALATIONS_STG');
192:
193: if biv_dbi_collection_util.truncate_table
194: (l_biv_schema, 'BIV_DBI_ESCALATIONS_STG', l_error_message) <> 0 then
195: raise l_exception;
194: (l_biv_schema, 'BIV_DBI_ESCALATIONS_STG', l_error_message) <> 0 then
195: raise l_exception;
196: end if;
197:
198: bis_collection_utilities.log('Inserting rows into BIV_DBI_ESCALATIONS_STG');
199:
200: insert into biv_dbi_escalations_stg
201: (
202: incident_id,
231: group by object_id));
232:
233: l_rowcount := sql%rowcount;
234:
235: bis_collection_utilities.log('Inserted ' || l_rowcount || ' rows');
236: commit;
237:
238: BEGIN
239:
278: , g_user_id
279: , g_login_id
280: );
281:
282: bis_collection_utilities.log('Starting new Initial Load');
283: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
284: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
285:
286: else
279: , g_login_id
280: );
281:
282: bis_collection_utilities.log('Starting new Initial Load');
283: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
284: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
285:
286: else
287:
280: );
281:
282: bis_collection_utilities.log('Starting new Initial Load');
283: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
284: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
285:
286: else
287:
288: bis_collection_utilities.log('Resuming previous incomplete Initial Load');
284: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
285:
286: else
287:
288: bis_collection_utilities.log('Resuming previous incomplete Initial Load');
289: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
290: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
291:
292: end if;
285:
286: else
287:
288: bis_collection_utilities.log('Resuming previous incomplete Initial Load');
289: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
290: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
291:
292: end if;
293:
286: else
287:
288: bis_collection_utilities.log('Resuming previous incomplete Initial Load');
289: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
290: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
291:
292: end if;
293:
294: commit;
292: end if;
293:
294: commit;
295:
296: bis_collection_utilities.wrapup( p_status => true
297: , p_period_from => l_collect_from_date
298: , p_period_to => l_collect_to_date
299: );
300:
300:
301: exception
302: when g_bis_setup_exception then
303: rollback;
304: errbuf := 'Error in BIS_COLLECTION_UTILITIES.Setup';
305: retcode := '2';
306:
307: when others then
308: rollback;
308: rollback;
309: if l_error_message is null then
310: l_error_message := substr(sqlerrm,1,4000);
311: end if;
312: bis_collection_utilities.log('Error:');
313: bis_collection_utilities.log(l_error_message,1);
314: bis_collection_utilities.wrapup( p_status => false
315: , p_message => l_error_message
316: , p_period_from => l_collect_from_date
309: if l_error_message is null then
310: l_error_message := substr(sqlerrm,1,4000);
311: end if;
312: bis_collection_utilities.log('Error:');
313: bis_collection_utilities.log(l_error_message,1);
314: bis_collection_utilities.wrapup( p_status => false
315: , p_message => l_error_message
316: , p_period_from => l_collect_from_date
317: , p_period_to => l_collect_to_date
310: l_error_message := substr(sqlerrm,1,4000);
311: end if;
312: bis_collection_utilities.log('Error:');
313: bis_collection_utilities.log(l_error_message,1);
314: bis_collection_utilities.wrapup( p_status => false
315: , p_message => l_error_message
316: , p_period_from => l_collect_from_date
317: , p_period_to => l_collect_to_date
318: );
351: l_missing_organization_id number := biv_dbi_collection_util.get_missing_organization_id;
352:
353: begin
354:
355: if not bis_collection_utilities.setup( 'BIV_DBI_COLLECT_INIT_ACTIVITY' ) then
356: raise g_bis_setup_exception;
357: end if;
358:
359: biv_dbi_collection_util.get_last_log( l_log_rowid
386: (l_biv_schema, l_error_message) <> 0 then
387: raise l_exception;
388: end if;
389:
390: bis_collection_utilities.log('Starting Activity Initial Load');
391: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
392: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
393:
394: bis_collection_utilities.log('Truncating table '||l_biv_schema||'.'||'BIV_DBI_ACTIVITY_SUM_F');
387: raise l_exception;
388: end if;
389:
390: bis_collection_utilities.log('Starting Activity Initial Load');
391: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
392: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
393:
394: bis_collection_utilities.log('Truncating table '||l_biv_schema||'.'||'BIV_DBI_ACTIVITY_SUM_F');
395:
388: end if;
389:
390: bis_collection_utilities.log('Starting Activity Initial Load');
391: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
392: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
393:
394: bis_collection_utilities.log('Truncating table '||l_biv_schema||'.'||'BIV_DBI_ACTIVITY_SUM_F');
395:
396: if biv_dbi_collection_util.truncate_table
390: bis_collection_utilities.log('Starting Activity Initial Load');
391: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
392: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
393:
394: bis_collection_utilities.log('Truncating table '||l_biv_schema||'.'||'BIV_DBI_ACTIVITY_SUM_F');
395:
396: if biv_dbi_collection_util.truncate_table
397: (l_biv_schema, 'BIV_DBI_ACTIVITY_SUM_F', l_error_message) <> 0 then
398: raise l_exception;
397: (l_biv_schema, 'BIV_DBI_ACTIVITY_SUM_F', l_error_message) <> 0 then
398: raise l_exception;
399: end if;
400:
401: bis_collection_utilities.log('Inserting rows into BIV_DBI_ACTIVITY_SUM_F');
402:
403: insert /*+ APPEND parallel(biv_dbi_activity_sum_f) */
404: into biv_dbi_activity_sum_f
405: ( activity_date
486: , case when e.escalated_date <= a.creation_date then 'Y' else 'N' end;
487:
488: l_rowcount := sql%rowcount;
489:
490: bis_collection_utilities.log('Inserted ' || l_rowcount || ' rows');
491:
492: update biv_dbi_collection_log
493: set activity_flag = 'Y'
494: , activity_count = l_rowcount
498: , last_updated_by = g_user_id
499: , last_update_login = g_login_id
500: where rowid = l_log_rowid;
501:
502: bis_collection_utilities.log('Activity initial load complete');
503:
504: else
505:
506: bis_collection_utilities.log('Activity initial load already complete, skipping');
502: bis_collection_utilities.log('Activity initial load complete');
503:
504: else
505:
506: bis_collection_utilities.log('Activity initial load already complete, skipping');
507:
508: end if;
509:
510: if internal_wrapup(l_log_rowid, l_error_message) <> 0 then
512: end if;
513:
514: commit;
515:
516: bis_collection_utilities.wrapup( p_status => true
517: , p_period_from => l_collect_from_date
518: , p_period_to => l_collect_to_date
519: , p_count => l_rowcount
520: );
521:
522: exception
523: when g_bis_setup_exception then
524: rollback;
525: errbuf := 'Error in BIS_COLLECTION_UTILITIES.Setup';
526: retcode := '2';
527: biv_dbi_collection_util.set_log_error
528: ( p_rowid => l_log_rowid
529: , p_activity_error => errbuf
539: ( p_rowid => l_log_rowid
540: , p_activity_error => l_error_message
541: );
542: commit;
543: bis_collection_utilities.wrapup( p_status => false
544: , p_message => l_error_message
545: , p_period_from => l_collect_from_date
546: , p_period_to => l_collect_to_date
547: );
580: l_missing_organization_id number := biv_dbi_collection_util.get_missing_organization_id;
581:
582: begin
583:
584: if not bis_collection_utilities.setup( 'BIV_DBI_COLLECT_INIT_CLOSED' ) then
585: raise g_bis_setup_exception;
586: end if;
587:
588: biv_dbi_collection_util.get_last_log( l_log_rowid
615: (l_biv_schema, l_error_message) <> 0 then
616: raise l_exception;
617: end if;
618:
619: bis_collection_utilities.log('Starting Closed Initial Load');
620: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
621: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
622:
623: bis_collection_utilities.log('Truncating table '||l_biv_schema||'.'||'BIV_DBI_CLOSED_SUM_F');
616: raise l_exception;
617: end if;
618:
619: bis_collection_utilities.log('Starting Closed Initial Load');
620: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
621: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
622:
623: bis_collection_utilities.log('Truncating table '||l_biv_schema||'.'||'BIV_DBI_CLOSED_SUM_F');
624:
617: end if;
618:
619: bis_collection_utilities.log('Starting Closed Initial Load');
620: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
621: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
622:
623: bis_collection_utilities.log('Truncating table '||l_biv_schema||'.'||'BIV_DBI_CLOSED_SUM_F');
624:
625: if biv_dbi_collection_util.truncate_table
619: bis_collection_utilities.log('Starting Closed Initial Load');
620: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
621: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
622:
623: bis_collection_utilities.log('Truncating table '||l_biv_schema||'.'||'BIV_DBI_CLOSED_SUM_F');
624:
625: if biv_dbi_collection_util.truncate_table
626: (l_biv_schema, 'BIV_DBI_CLOSED_SUM_F', l_error_message) <> 0 then
627: raise l_exception;
626: (l_biv_schema, 'BIV_DBI_CLOSED_SUM_F', l_error_message) <> 0 then
627: raise l_exception;
628: end if;
629:
630: bis_collection_utilities.log('Inserting rows into BIV_DBI_CLOSED_SUM_F');
631:
632: insert /*+ APPEND parallel(csf)*/
633: into biv_dbi_closed_sum_f csf
634: (
753: end <= l_collect_to_date;
754:
755: l_rowcount := sql%rowcount;
756:
757: bis_collection_utilities.log('Inserted ' || l_rowcount || ' rows');
758:
759: update biv_dbi_collection_log
760: set closed_flag = 'Y'
761: , closed_count = l_rowcount
765: , last_updated_by = g_user_id
766: , last_update_login = g_login_id
767: where rowid = l_log_rowid;
768:
769: bis_collection_utilities.log('Closed initial load complete');
770:
771: else
772:
773: bis_collection_utilities.log('Closed initial load already complete, skipping');
769: bis_collection_utilities.log('Closed initial load complete');
770:
771: else
772:
773: bis_collection_utilities.log('Closed initial load already complete, skipping');
774:
775: end if;
776:
777: if internal_wrapup(l_log_rowid, l_error_message) <> 0 then
779: end if;
780:
781: commit;
782:
783: bis_collection_utilities.wrapup( p_status => true
784: , p_period_from => l_collect_from_date
785: , p_period_to => l_collect_to_date
786: , p_count => l_rowcount
787: );
788:
789: exception
790: when g_bis_setup_exception then
791: rollback;
792: errbuf := 'Error in BIS_COLLECTION_UTILITIES.Setup';
793: retcode := '2';
794: biv_dbi_collection_util.set_log_error
795: ( p_rowid => l_log_rowid
796: , p_closed_error => errbuf
806: ( p_rowid => l_log_rowid
807: , p_closed_error => l_error_message
808: );
809: commit;
810: bis_collection_utilities.wrapup( p_status => false
811: , p_message => l_error_message
812: , p_period_from => l_collect_from_date
813: , p_period_to => l_collect_to_date
814: );
849: l_max_date date := to_date('4712/12/31','yyyy/mm/dd');
850:
851: begin
852:
853: if not bis_collection_utilities.setup( 'BIV_DBI_COLLECT_INIT_BACKLOG' ) then
854: raise g_bis_setup_exception;
855: end if;
856:
857: biv_dbi_collection_util.get_last_log( l_log_rowid
884: (l_biv_schema, l_error_message) <> 0 then
885: raise l_exception;
886: end if;
887:
888: bis_collection_utilities.log('Starting Backlog Initial Load');
889: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
890: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
891:
892: bis_collection_utilities.log('Truncating table '||l_biv_schema||'.'||'BIV_DBI_BACKLOG_SUM_F');
885: raise l_exception;
886: end if;
887:
888: bis_collection_utilities.log('Starting Backlog Initial Load');
889: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
890: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
891:
892: bis_collection_utilities.log('Truncating table '||l_biv_schema||'.'||'BIV_DBI_BACKLOG_SUM_F');
893:
886: end if;
887:
888: bis_collection_utilities.log('Starting Backlog Initial Load');
889: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
890: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
891:
892: bis_collection_utilities.log('Truncating table '||l_biv_schema||'.'||'BIV_DBI_BACKLOG_SUM_F');
893:
894: if biv_dbi_collection_util.truncate_table
888: bis_collection_utilities.log('Starting Backlog Initial Load');
889: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
890: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
891:
892: bis_collection_utilities.log('Truncating table '||l_biv_schema||'.'||'BIV_DBI_BACKLOG_SUM_F');
893:
894: if biv_dbi_collection_util.truncate_table
895: (l_biv_schema, 'BIV_DBI_BACKLOG_SUM_F', l_error_message) <> 0 then
896: raise l_exception;
895: (l_biv_schema, 'BIV_DBI_BACKLOG_SUM_F', l_error_message) <> 0 then
896: raise l_exception;
897: end if;
898:
899: bis_collection_utilities.log('Inserting rows into BIV_DBI_BACKLOG_SUM_F');
900:
901: insert /*+ APPEND parallel(biv_dbi_backlog_sum_f) */
902: first
903: when status_flag = 'O' then
1268: ) b;
1269:
1270: l_rowcount := sql%rowcount;
1271:
1272: bis_collection_utilities.log('Inserted ' || l_rowcount || ' rows');
1273:
1274: update biv_dbi_collection_log
1275: set backlog_flag = 'Y'
1276: , backlog_count = l_rowcount
1280: , last_updated_by = g_user_id
1281: , last_update_login = g_login_id
1282: where rowid = l_log_rowid;
1283:
1284: bis_collection_utilities.log('Backlog initial load complete');
1285:
1286: else
1287:
1288: bis_collection_utilities.log('Backlog initial load already complete, skipping');
1284: bis_collection_utilities.log('Backlog initial load complete');
1285:
1286: else
1287:
1288: bis_collection_utilities.log('Backlog initial load already complete, skipping');
1289:
1290: end if;
1291:
1292: if internal_wrapup(l_log_rowid, l_error_message) <> 0 then
1294: end if;
1295:
1296: commit;
1297:
1298: bis_collection_utilities.wrapup( p_status => true
1299: , p_period_from => l_collect_from_date
1300: , p_period_to => l_collect_to_date
1301: , p_count => l_rowcount
1302: );
1303:
1304: exception
1305: when g_bis_setup_exception then
1306: rollback;
1307: errbuf := 'Error in BIS_COLLECTION_UTILITIES.Setup';
1308: retcode := '2';
1309: biv_dbi_collection_util.set_log_error
1310: ( p_rowid => l_log_rowid
1311: , p_backlog_error => errbuf
1321: ( p_rowid => l_log_rowid
1322: , p_backlog_error => l_error_message
1323: );
1324: commit;
1325: bis_collection_utilities.wrapup( p_status => false
1326: , p_message => l_error_message
1327: , p_period_from => l_collect_from_date
1328: , p_period_to => l_collect_to_date
1329: );
1362: l_missing_organization_id number := biv_dbi_collection_util.get_missing_organization_id;
1363:
1364: begin
1365:
1366: if not bis_collection_utilities.setup( 'BIV_DBI_COLLECT_INIT_RESOLUTION' ) then
1367: raise g_bis_setup_exception;
1368: end if;
1369:
1370: biv_dbi_collection_util.get_last_log( l_log_rowid
1397: (l_biv_schema, l_error_message) <> 0 then
1398: raise l_exception;
1399: end if;
1400:
1401: bis_collection_utilities.log('Starting Resolution Initial Load');
1402: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
1403: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
1404:
1405: bis_collection_utilities.log('Truncating table '||l_biv_schema||'.'||'BIV_DBI_RESOLUTION_SUM_F');
1398: raise l_exception;
1399: end if;
1400:
1401: bis_collection_utilities.log('Starting Resolution Initial Load');
1402: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
1403: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
1404:
1405: bis_collection_utilities.log('Truncating table '||l_biv_schema||'.'||'BIV_DBI_RESOLUTION_SUM_F');
1406:
1399: end if;
1400:
1401: bis_collection_utilities.log('Starting Resolution Initial Load');
1402: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
1403: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
1404:
1405: bis_collection_utilities.log('Truncating table '||l_biv_schema||'.'||'BIV_DBI_RESOLUTION_SUM_F');
1406:
1407: if biv_dbi_collection_util.truncate_table
1401: bis_collection_utilities.log('Starting Resolution Initial Load');
1402: bis_collection_utilities.log('From ' || fnd_date.date_to_displaydt(l_collect_from_date),1);
1403: bis_collection_utilities.log('To ' || fnd_date.date_to_displaydt(l_collect_to_date),1);
1404:
1405: bis_collection_utilities.log('Truncating table '||l_biv_schema||'.'||'BIV_DBI_RESOLUTION_SUM_F');
1406:
1407: if biv_dbi_collection_util.truncate_table
1408: (l_biv_schema, 'BIV_DBI_RESOLUTION_SUM_F', l_error_message) <> 0 then
1409: raise l_exception;
1408: (l_biv_schema, 'BIV_DBI_RESOLUTION_SUM_F', l_error_message) <> 0 then
1409: raise l_exception;
1410: end if;
1411:
1412: bis_collection_utilities.log('Inserting rows into BIV_DBI_RESOLUTION_SUM_F');
1413:
1414: insert /*+ APPEND parallel(rsf)*/
1415: into biv_dbi_resolution_sum_f rsf
1416: (
1597: )
1598: );
1599: l_rowcount := sql%rowcount;
1600:
1601: bis_collection_utilities.log('Inserted ' || l_rowcount || ' rows');
1602:
1603: update biv_dbi_collection_log
1604: set resolution_flag = 'Y'
1605: , resolution_count = l_rowcount
1609: , last_updated_by = g_user_id
1610: , last_update_login = g_login_id
1611: where rowid = l_log_rowid;
1612:
1613: bis_collection_utilities.log('Resolution initial load complete');
1614:
1615: else
1616:
1617: bis_collection_utilities.log('Resolution initial load already complete, skipping');
1613: bis_collection_utilities.log('Resolution initial load complete');
1614:
1615: else
1616:
1617: bis_collection_utilities.log('Resolution initial load already complete, skipping');
1618:
1619: end if;
1620:
1621: if internal_wrapup(l_log_rowid, l_error_message) <> 0 then
1623: end if;
1624:
1625: commit;
1626:
1627: bis_collection_utilities.wrapup( p_status => true
1628: , p_period_from => l_collect_from_date
1629: , p_period_to => l_collect_to_date
1630: , p_count => l_rowcount
1631: );
1632:
1633: exception
1634: when g_bis_setup_exception then
1635: rollback;
1636: errbuf := 'Error in BIS_COLLECTION_UTILITIES.Setup';
1637: retcode := '2';
1638: biv_dbi_collection_util.set_log_error
1639: ( p_rowid => l_log_rowid
1640: , p_resolution_error => errbuf
1650: ( p_rowid => l_log_rowid
1651: , p_resolution_error => l_error_message
1652: );
1653: commit;
1654: bis_collection_utilities.wrapup( p_status => false
1655: , p_message => l_error_message
1656: , p_period_from => l_collect_from_date
1657: , p_period_to => l_collect_to_date
1658: );