DBA Data[Home] [Help]

APPS.OKL_K_LINE_FIN_EXT_MASTER_PVT dependencies on OKL_PARALLEL_PROCESSES

Line 80: FROM OKL_PARALLEL_PROCESSES

76:
77:
78: CURSOR l_parallel_worker_csr(cp_assigned_process IN VARCHAR2) IS
79: SELECT object_value, khr_id, assigned_process
80: FROM OKL_PARALLEL_PROCESSES
81: WHERE object_type = 'CONTRACT_FIN_LINE_EXT-CONTRACT'
82: AND assigned_process = cp_assigned_process
83: AND process_status = 'PENDING_ASSIGNMENT';
84:

Line 129: l_last_updated_by okl_parallel_processes.last_updated_by%TYPE := Fnd_Global.USER_ID;

125: l_this_row NUMBER;
126: l_max_worker_used NUMBER;
127:
128: -- Org Id and standard who columns
129: l_last_updated_by okl_parallel_processes.last_updated_by%TYPE := Fnd_Global.USER_ID;
130: l_last_update_login okl_parallel_processes.last_update_login%TYPE := Fnd_Global.LOGIN_ID;
131: l_request_id okl_parallel_processes.request_id%TYPE := Fnd_Global.CONC_REQUEST_ID;
132: l_program_id okl_parallel_processes.program_id%TYPE := Fnd_Global.CONC_PROGRAM_ID;
133: l_org_id okl_parallel_processes.org_id%type;

Line 130: l_last_update_login okl_parallel_processes.last_update_login%TYPE := Fnd_Global.LOGIN_ID;

126: l_max_worker_used NUMBER;
127:
128: -- Org Id and standard who columns
129: l_last_updated_by okl_parallel_processes.last_updated_by%TYPE := Fnd_Global.USER_ID;
130: l_last_update_login okl_parallel_processes.last_update_login%TYPE := Fnd_Global.LOGIN_ID;
131: l_request_id okl_parallel_processes.request_id%TYPE := Fnd_Global.CONC_REQUEST_ID;
132: l_program_id okl_parallel_processes.program_id%TYPE := Fnd_Global.CONC_PROGRAM_ID;
133: l_org_id okl_parallel_processes.org_id%type;
134:

Line 131: l_request_id okl_parallel_processes.request_id%TYPE := Fnd_Global.CONC_REQUEST_ID;

127:
128: -- Org Id and standard who columns
129: l_last_updated_by okl_parallel_processes.last_updated_by%TYPE := Fnd_Global.USER_ID;
130: l_last_update_login okl_parallel_processes.last_update_login%TYPE := Fnd_Global.LOGIN_ID;
131: l_request_id okl_parallel_processes.request_id%TYPE := Fnd_Global.CONC_REQUEST_ID;
132: l_program_id okl_parallel_processes.program_id%TYPE := Fnd_Global.CONC_PROGRAM_ID;
133: l_org_id okl_parallel_processes.org_id%type;
134:
135: l_child_in_error NUMBER;

Line 132: l_program_id okl_parallel_processes.program_id%TYPE := Fnd_Global.CONC_PROGRAM_ID;

128: -- Org Id and standard who columns
129: l_last_updated_by okl_parallel_processes.last_updated_by%TYPE := Fnd_Global.USER_ID;
130: l_last_update_login okl_parallel_processes.last_update_login%TYPE := Fnd_Global.LOGIN_ID;
131: l_request_id okl_parallel_processes.request_id%TYPE := Fnd_Global.CONC_REQUEST_ID;
132: l_program_id okl_parallel_processes.program_id%TYPE := Fnd_Global.CONC_PROGRAM_ID;
133: l_org_id okl_parallel_processes.org_id%type;
134:
135: l_child_in_error NUMBER;
136: l_child_in_warn NUMBER;

Line 133: l_org_id okl_parallel_processes.org_id%type;

129: l_last_updated_by okl_parallel_processes.last_updated_by%TYPE := Fnd_Global.USER_ID;
130: l_last_update_login okl_parallel_processes.last_update_login%TYPE := Fnd_Global.LOGIN_ID;
131: l_request_id okl_parallel_processes.request_id%TYPE := Fnd_Global.CONC_REQUEST_ID;
132: l_program_id okl_parallel_processes.program_id%TYPE := Fnd_Global.CONC_PROGRAM_ID;
133: l_org_id okl_parallel_processes.org_id%type;
134:
135: l_child_in_error NUMBER;
136: l_child_in_warn NUMBER;
137:

Line 243: DELETE OKL_PARALLEL_PROCESSES

239:
240: write_to_log('Request submission failed. ');
241: write_to_log('Exiting with error... ');
242:
243: DELETE OKL_PARALLEL_PROCESSES
244: WHERE assigned_process like l_char_seq_num||'%' ;
245:
246: l_row_count := sql%rowcount;
247: IF l_row_count > 0 THEN

Line 248: write_to_log('Deleted '||l_row_count||' rows from OKL_PARALLEL_PROCESSES.');

244: WHERE assigned_process like l_char_seq_num||'%' ;
245:
246: l_row_count := sql%rowcount;
247: IF l_row_count > 0 THEN
248: write_to_log('Deleted '||l_row_count||' rows from OKL_PARALLEL_PROCESSES.');
249: END IF;
250:
251: COMMIT;
252:

Line 364: INSERT INTO OKL_PARALLEL_PROCESSES

360:
361: l_org_id := mo_global.get_current_org_id();
362: WRITE_TO_LOG('org id:: '||l_org_id);
363:
364: INSERT INTO OKL_PARALLEL_PROCESSES
365: (
366: object_type,
367: object_value,
368: object_status,

Line 415: FROM OKL_PARALLEL_PROCESSES opp

411: AND chr.sts_code = nvl(P_CONTRACT_STATUS, chr.sts_code)
412: AND CHR.CONTRACT_NUMBER like NVL(P_CONTRACT_NUMBER, CHR.CONTRACT_NUMBER)
413: AND NOT EXISTS
414: (SELECT '1'
415: FROM OKL_PARALLEL_PROCESSES opp
416: WHERE chr.contract_number = opp.object_value
417: AND opp.object_type = 'CONTRACT_FIN_EXTRACT'
418: AND opp.process_status in ('PENDING_ASSIGNMENT', 'ASSIGNED'));
419:

Line 423: write_to_log('Number of rows inserted in OKL_PARALLEL_PROCESSES :'||l_row_count);

419:
420:
421: l_row_count := SQL%ROWCOUNT;
422:
423: write_to_log('Number of rows inserted in OKL_PARALLEL_PROCESSES :'||l_row_count);
424:
425: IF l_row_count > 0 THEN
426: l_data_found := TRUE;
427:

Line 499: UPDATE OKL_PARALLEL_PROCESSES

495: FOR k IN l_parallel_worker_tbl.FIRST..l_parallel_worker_tbl.LAST LOOP
496:
497:
498: write_to_log('contract # : '||l_parallel_worker_tbl(k).object_value||': worker # '||l_parallel_worker_tbl(k).assigned_process);
499: UPDATE OKL_PARALLEL_PROCESSES
500: SET assigned_process = l_parallel_worker_tbl(k).assigned_process,
501: process_status = 'ASSIGNED'
502: WHERE object_Type = 'CONTRACT_FIN_LINE_EXT-CONTRACT'
503: AND object_value = l_parallel_worker_tbl(k).object_value

Line 509: write_to_log('OKL_PARALLEL_PROCESSES Updated with worker assignment');

505:
506: COMMIT;
507: END LOOP;
508:
509: write_to_log('OKL_PARALLEL_PROCESSES Updated with worker assignment');
510:
511: FOR j in 1..l_max_worker_used LOOP
512:
513: l_req_data := fnd_conc_global.request_data;

Line 561: DELETE OKL_PARALLEL_PROCESSES

557:
558: write_to_log('Request submission failed.');
559: write_to_log('Exiting with error... ');
560:
561: DELETE OKL_PARALLEL_PROCESSES
562: WHERE assigned_process like l_char_seq_num||'%' ;
563:
564: l_row_count := sql%rowcount;
565: IF l_row_count > 0 THEN

Line 566: write_to_log('Deleted '||l_row_count||' rows from OKL_PARALLEL_PROCESSES.');

562: WHERE assigned_process like l_char_seq_num||'%' ;
563:
564: l_row_count := sql%rowcount;
565: IF l_row_count > 0 THEN
566: write_to_log('Deleted '||l_row_count||' rows from OKL_PARALLEL_PROCESSES.');
567: END IF;
568:
569: COMMIT;
570: -- If request submission failed, exit with error

Line 597: DELETE OKL_PARALLEL_PROCESSES

593: exception
594: when others then
595: write_to_log('Unhandled Exception '||sqlcode||':'||sqlerrm);
596:
597: DELETE OKL_PARALLEL_PROCESSES
598: WHERE assigned_process like l_char_seq_num||'%' ;
599:
600: l_row_count := sql%rowcount;
601:

Line 603: write_to_log('Deleted '||sql%rowcount||' rows from OKL_PARALLEL_PROCESSES.');

599:
600: l_row_count := sql%rowcount;
601:
602: IF l_row_count > 0 THEN
603: write_to_log('Deleted '||sql%rowcount||' rows from OKL_PARALLEL_PROCESSES.');
604: END IF;
605:
606: COMMIT;
607: