DBA Data[Home] [Help]

APPS.OKI_LOAD_TERR_PVT dependencies on OKI_JTF_TERRITORIES

Line 103: l_sql_string := 'TRUNCATE TABLE '|| g_oki_schema ||'.OKI_JTF_TERRITORIES';

99: BEGIN
100:
101: IF g_load_type = 'INIT' THEN
102: -- truncate tables
103: l_sql_string := 'TRUNCATE TABLE '|| g_oki_schema ||'.OKI_JTF_TERRITORIES';
104: EXECUTE IMMEDIATE l_sql_string;
105: rlog( 'Truncated Table OKI_JTF_TERRITORIES',2);
106: END IF;
107:

Line 105: rlog( 'Truncated Table OKI_JTF_TERRITORIES',2);

101: IF g_load_type = 'INIT' THEN
102: -- truncate tables
103: l_sql_string := 'TRUNCATE TABLE '|| g_oki_schema ||'.OKI_JTF_TERRITORIES';
104: EXECUTE IMMEDIATE l_sql_string;
105: rlog( 'Truncated Table OKI_JTF_TERRITORIES',2);
106: END IF;
107:
108: l_sql_string := 'TRUNCATE TABLE '|| g_oki_schema ||'.OKI_JTF_TERRITORIES_STG';
109: EXECUTE IMMEDIATE l_sql_string;

Line 108: l_sql_string := 'TRUNCATE TABLE '|| g_oki_schema ||'.OKI_JTF_TERRITORIES_STG';

104: EXECUTE IMMEDIATE l_sql_string;
105: rlog( 'Truncated Table OKI_JTF_TERRITORIES',2);
106: END IF;
107:
108: l_sql_string := 'TRUNCATE TABLE '|| g_oki_schema ||'.OKI_JTF_TERRITORIES_STG';
109: EXECUTE IMMEDIATE l_sql_string;
110: rlog( 'Truncated Table OKI_JTF_TERRITORIES_STG',2);
111:
112: DELETE FROM OKI_DBI_WORKER_STATUS

Line 110: rlog( 'Truncated Table OKI_JTF_TERRITORIES_STG',2);

106: END IF;
107:
108: l_sql_string := 'TRUNCATE TABLE '|| g_oki_schema ||'.OKI_JTF_TERRITORIES_STG';
109: EXECUTE IMMEDIATE l_sql_string;
110: rlog( 'Truncated Table OKI_JTF_TERRITORIES_STG',2);
111:
112: DELETE FROM OKI_DBI_WORKER_STATUS
113: WHERE OBJECT_NAME = 'OKI_JTF_TERRITORIES';
114: COMMIT;

Line 113: WHERE OBJECT_NAME = 'OKI_JTF_TERRITORIES';

109: EXECUTE IMMEDIATE l_sql_string;
110: rlog( 'Truncated Table OKI_JTF_TERRITORIES_STG',2);
111:
112: DELETE FROM OKI_DBI_WORKER_STATUS
113: WHERE OBJECT_NAME = 'OKI_JTF_TERRITORIES';
114: COMMIT;
115:
116: If g_load_type ='INIT' THEN
117: BIS_COLLECTION_UTILITIES.DeleteLogForObject('OKIJTFTERR');

Line 239: UPDATE OKI_JTF_TERRITORIES_STG

235:
236:
237: FOR worker_no IN 1 .. l_no_of_workers LOOP
238:
239: UPDATE OKI_JTF_TERRITORIES_STG
240: SET worker_number = worker_no
241: WHERE worker_number IS NULL
242: AND ROWNUM <= CEIL(l_terr_count/l_no_of_workers);
243:

Line 252: 'OKI_JTF_TERRITORIES'

248: , status
249: , c_rows
250: )
251: VALUES(
252: 'OKI_JTF_TERRITORIES'
253: , worker_no
254: ,'UNASSIGNED'
255: , -1
256: );

Line 289: WHERE object_name = 'OKI_JTF_TERRITORIES';

285: l_wip_cnt,
286: l_failed_cnt,
287: l_tot_cnt
288: FROM OKI_DBI_WORKER_STATUS
289: WHERE object_name = 'OKI_JTF_TERRITORIES';
290:
291: IF ( l_failed_cnt > 0 ) THEN
292: rlog('One of the child workers Errored Out',2);
293: RAISE G_CHILD_PROCESS_ISSUE;

Line 307: l_sql_string := 'TRUNCATE TABLE '|| g_oki_schema ||'.OKI_JTF_TERRITORIES';

303: EXCEPTION
304:
305: WHEN G_CHILD_PROCESS_ISSUE then
306: IF g_load_type ='INIT' THEN
307: l_sql_string := 'TRUNCATE TABLE '|| g_oki_schema ||'.OKI_JTF_TERRITORIES';
308: EXECUTE IMMEDIATE l_sql_string;
309: END IF;
310: RAISE;
311:

Line 313: rlog( 'Error while loading table OKI_JTF_TERRITORIES table : ' || SQLERRM, 2 );

309: END IF;
310: RAISE;
311:
312: WHEN OTHERS THEN
313: rlog( 'Error while loading table OKI_JTF_TERRITORIES table : ' || SQLERRM, 2 );
314: RAISE;
315:
316: END; -- Monitor child process Ends here.
317:

Line 342: INSERT /* + APPEND */ INTO OKI_JTF_TERRITORIES_STG

338: rlog('Loading of Staging Table Started - ' || fnd_date.date_to_displayDT(sysdate),1);
339:
340: IF g_load_type ='INIT' THEN
341:
342: INSERT /* + APPEND */ INTO OKI_JTF_TERRITORIES_STG
343: ( authoring_org_id
344: , party_id
345: , party_name
346: , country_code

Line 395: INSERT /* + APPEND */ INTO OKI_JTF_TERRITORIES_STG

391: AND ro.rle_code IN ('CUSTOMER','LICENSEE','BUYER')
392: AND NVL(ro.primary_yn,'Y') = 'Y'
393: );
394: ELSE
395: INSERT /* + APPEND */ INTO OKI_JTF_TERRITORIES_STG
396: ( authoring_org_id
397: , party_id
398: , party_name
399: , country_code

Line 451: l_tab_name := 'OKI_JTF_TERRITORIES_STG';

447: p_terr_count := SQL%ROWCOUNT;
448: COMMIT;
449: rlog('No of records inserted into Staging table - ' || p_terr_count,1);
450:
451: l_tab_name := 'OKI_JTF_TERRITORIES_STG';
452: fnd_stats.gather_table_stats( ownname=> g_table_owner
453: , tabname=> l_tab_name
454: , percent=> 10);
455: rlog('Loading of Staging Table Completed - ' || fnd_date.date_to_displayDT(sysdate),1);

Line 522: AND object_name = 'OKI_JTF_TERRITORIES';

518: l_completed_cnt,
519: l_total_cnt
520: FROM OKI_DBI_WORKER_STATUS
521: WHERE 1=1
522: AND object_name = 'OKI_JTF_TERRITORIES';
523:
524: IF (l_failed_cnt > 0) THEN
525: rlog('Another subworker have errored out. Stop processing.',1);
526: ELSIF (l_unassigned_cnt = 0) THEN

Line 535: WHERE object_name = 'OKI_JTF_TERRITORIES'

531: rlog('Subworker ' || p_worker_no ||' Starts: - ' ||fnd_date.date_to_displayDT(SYSDATE),1);
532:
533: UPDATE OKI_DBI_WORKER_STATUS
534: SET status = 'IN PROCESS'
535: WHERE object_name = 'OKI_JTF_TERRITORIES'
536: AND worker_number = p_worker_no
537: AND STATUS ='UNASSIGNED';
538:
539: COMMIT;

Line 547: WHERE object_name = 'OKI_JTF_TERRITORIES'

543:
544: UPDATE OKI_DBI_WORKER_STATUS
545: SET status = 'COMPLETED'
546: , c_rows = l_count
547: WHERE object_name = 'OKI_JTF_TERRITORIES'
548: AND status = 'IN PROCESS'
549: AND worker_number = p_worker_no;
550: COMMIT;
551:

Line 598: l_tab_name := 'OKI_JTF_TERRITORIES';

594: RAISE_APPLICATION_ERROR (-20000, 'Error in SETUP: ' || errbuf);
595: END IF;
596:
597: l_errpos := 1;
598: l_tab_name := 'OKI_JTF_TERRITORIES';
599:
600: IF g_load_type ='INIT' THEN
601: l_string := 'INITIAL';
602: ELSE

Line 623: rlog('Launching Sub-Workers to load/update OKI_JTF_TERRITORIES table ' || fnd_date.date_to_displayDT(SYSDATE),1);

619: load_staging(l_count);
620:
621: l_errpos := 4;
622: IF l_count > 0 THEN
623: rlog('Launching Sub-Workers to load/update OKI_JTF_TERRITORIES table ' || fnd_date.date_to_displayDT(SYSDATE),1);
624: spawn_workers( p_number_of_workers
625: , l_count);
626: END IF;
627: l_errpos := 5;

Line 638: WHERE object_name ='OKI_JTF_TERRITORIES';

634: l_errpos := 7;
635:
636: SELECT NVL(SUM(c_rows),0) INTO l_count
637: FROM OKI_DBI_WORKER_STATUS
638: WHERE object_name ='OKI_JTF_TERRITORIES';
639:
640: rlog('No of records inserted/updated in OKI_JTF_TERRITORIES table - ' || l_count , 1);
641:
642: BIS_COLLECTION_UTILITIES.wrapup( TRUE

Line 640: rlog('No of records inserted/updated in OKI_JTF_TERRITORIES table - ' || l_count , 1);

636: SELECT NVL(SUM(c_rows),0) INTO l_count
637: FROM OKI_DBI_WORKER_STATUS
638: WHERE object_name ='OKI_JTF_TERRITORIES';
639:
640: rlog('No of records inserted/updated in OKI_JTF_TERRITORIES table - ' || l_count , 1);
641:
642: BIS_COLLECTION_UTILITIES.wrapup( TRUE
643: , l_count
644: , 'OKI TERRITORY ' || l_string || ' LOAD COMPLETED SUCCESSFULLY'

Line 788: from OKI_JTF_TERRITORIES_STG t

784: , party_name
785: , country_code
786: , state_code
787: , record_id
788: from OKI_JTF_TERRITORIES_STG t
789: where worker_number = l_worker_number
790: ;
791:
792: get_org_customer_codes_rec get_org_customer_codes%ROWTYPE;

Line 866: UPDATE OKI_JTF_TERRITORIES_STG

862: --FOR i IN l_gen_return_rec.trans_object_id.FIRST .. l_gen_return_rec.trans_object_id.LAST
863: FOR i IN 1 .. l_gen_return_rec.trans_object_id.COUNT
864: LOOP
865: BEGIN
866: UPDATE OKI_JTF_TERRITORIES_STG
867: SET terr_id = l_gen_return_rec.terr_id(i),
868: resource_id = l_gen_return_rec.resource_id(i)
869: WHERE authoring_org_id = l_gen_return_rec.trans_detail_object_id(i)
870: AND record_id = l_gen_return_rec.trans_object_id(i);

Line 877: rlog('Loading of table OKI_JTF_TERRITORIES using subworker '|| p_worker_number ||' started - '

873: NULL;
874: END;
875: END LOOP;
876:
877: rlog('Loading of table OKI_JTF_TERRITORIES using subworker '|| p_worker_number ||' started - '
878: || fnd_date.date_to_displayDT(SYSDATE),2);
879:
880: IF(l_gen_return_rec.trans_object_id.FIRST IS NULL) THEN
881: rlog('Empty output from jtf function call' , 2);

Line 885: INSERT INTO oki_jtf_territories

881: rlog('Empty output from jtf function call' , 2);
882: ELSE
883: IF g_load_type ='INIT' THEN
884:
885: INSERT INTO oki_jtf_territories
886: (
887: authoring_org_id
888: , customer_party_id
889: , terr_id

Line 907: FROM OKI_JTF_TERRITORIES_STG

903: , g_user_id
904: , l_sysdate
905: , g_user_id
906: , g_login_id
907: FROM OKI_JTF_TERRITORIES_STG
908: WHERE worker_number = p_worker_number
909: AND terr_id IS NOT NULL;
910:
911: ELSE

Line 913: MERGE INTO oki_jtf_territories b

909: AND terr_id IS NOT NULL;
910:
911: ELSE
912:
913: MERGE INTO oki_jtf_territories b
914: USING
915: ( SELECT authoring_org_id
916: , party_id
917: , terr_id

Line 919: FROM OKI_JTF_TERRITORIES_STG

915: ( SELECT authoring_org_id
916: , party_id
917: , terr_id
918: , resource_id
919: FROM OKI_JTF_TERRITORIES_STG
920: WHERE worker_number = p_worker_number
921: AND terr_id IS NOT NULL
922: ) s
923: ON

Line 965: rlog('No of records inserted/updated in OKI_JTF_TERRITORIES table using subworker '

961: x_rec_count := NVL(l_rec_count,0);
962: ELSE
963: RAISE l_no_update_refresh;
964: END IF;
965: rlog('No of records inserted/updated in OKI_JTF_TERRITORIES table using subworker '
966: || p_worker_number ||' - ' || x_rec_count,2);
967: rlog('Loading of table OKI_JTF_TERRITORIES using subworker '|| p_worker_number ||' completed - '
968: || fnd_date.date_to_displayDT(SYSDATE),2);
969: END IF;

Line 967: rlog('Loading of table OKI_JTF_TERRITORIES using subworker '|| p_worker_number ||' completed - '

963: RAISE l_no_update_refresh;
964: END IF;
965: rlog('No of records inserted/updated in OKI_JTF_TERRITORIES table using subworker '
966: || p_worker_number ||' - ' || x_rec_count,2);
967: rlog('Loading of table OKI_JTF_TERRITORIES using subworker '|| p_worker_number ||' completed - '
968: || fnd_date.date_to_displayDT(SYSDATE),2);
969: END IF;
970:
971: COMMIT;

Line 979: WHERE object_name = 'OKI_JTF_TERRITORIES'

975: retcode := 2;
976:
977: UPDATE OKI_DBI_WORKER_STATUS
978: SET status = 'FAILED'
979: WHERE object_name = 'OKI_JTF_TERRITORIES'
980: AND status = 'IN PROCESS'
981: AND worker_number = p_worker_number;
982: COMMIT;
983: