APPS.OKI_LOAD_TERR_PVT dependencies on OKI_DBI_WORKER_STATUS

Line 112: DELETE FROM OKI_DBI_WORKER_STATUS

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;
115:
116: If g_load_type ='INIT' THEN

Line 245: INSERT INTO OKI_DBI_WORKER_STATUS (

241: WHERE worker_number IS NULL
242: AND ROWNUM <= CEIL(l_terr_count/l_no_of_workers);
243:
244: IF ( SQL%ROWCOUNT > 0 ) THEN
245: INSERT INTO OKI_DBI_WORKER_STATUS (
246: object_name
247: , worker_number
248: , status
249: , c_rows

Line 288: FROM OKI_DBI_WORKER_STATUS

284: l_completed_cnt,
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);

Line 520: FROM OKI_DBI_WORKER_STATUS

516: l_failed_cnt,
517: l_wip_cnt,
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

Line 533: UPDATE OKI_DBI_WORKER_STATUS

529: rlog('All jobs completed, no more job. Terminating',1);
530: ELSIF (l_unassigned_cnt > 0) THEN
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';

Line 544: UPDATE OKI_DBI_WORKER_STATUS

540: -- Calling the procedure for loading the jtf table!
541:
542: load_jtf_terr (p_worker_no, l_count);
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'

Line 637: FROM OKI_DBI_WORKER_STATUS

633: , percent => 10);
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:

Line 977: UPDATE OKI_DBI_WORKER_STATUS

973: EXCEPTION
974: WHEN OTHERS THEN
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;