DBA Data[Home] [Help]

APPS.OKL_CNTRCT_FIN_EXT_MASTER_PVT dependencies on OKL_PARALLEL_PROCESSES

Line 88: FROM OKL_PARALLEL_PROCESSES

84:
85:
86: CURSOR l_parallel_worker_csr(cp_assigned_process IN VARCHAR2) IS
87: SELECT object_value, khr_id, assigned_process
88: FROM OKL_PARALLEL_PROCESSES
89: WHERE object_type = 'CONTRACT_FIN_EXTRACT'
90: AND assigned_process = cp_assigned_process
91: AND process_status = 'PENDING_ASSIGNMENT';
92:

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

133: l_this_row NUMBER;
134: l_max_worker_used NUMBER;
135:
136: -- Org Id and standard who columns
137: l_last_updated_by okl_parallel_processes.last_updated_by%TYPE := Fnd_Global.USER_ID;
138: l_last_update_login okl_parallel_processes.last_update_login%TYPE := Fnd_Global.LOGIN_ID;
139: l_request_id okl_parallel_processes.request_id%TYPE := Fnd_Global.CONC_REQUEST_ID;
140: l_program_id okl_parallel_processes.program_id%TYPE := Fnd_Global.CONC_PROGRAM_ID;
141: l_org_id okl_parallel_processes.org_id%type;

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

134: l_max_worker_used NUMBER;
135:
136: -- Org Id and standard who columns
137: l_last_updated_by okl_parallel_processes.last_updated_by%TYPE := Fnd_Global.USER_ID;
138: l_last_update_login okl_parallel_processes.last_update_login%TYPE := Fnd_Global.LOGIN_ID;
139: l_request_id okl_parallel_processes.request_id%TYPE := Fnd_Global.CONC_REQUEST_ID;
140: l_program_id okl_parallel_processes.program_id%TYPE := Fnd_Global.CONC_PROGRAM_ID;
141: l_org_id okl_parallel_processes.org_id%type;
142:

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

135:
136: -- Org Id and standard who columns
137: l_last_updated_by okl_parallel_processes.last_updated_by%TYPE := Fnd_Global.USER_ID;
138: l_last_update_login okl_parallel_processes.last_update_login%TYPE := Fnd_Global.LOGIN_ID;
139: l_request_id okl_parallel_processes.request_id%TYPE := Fnd_Global.CONC_REQUEST_ID;
140: l_program_id okl_parallel_processes.program_id%TYPE := Fnd_Global.CONC_PROGRAM_ID;
141: l_org_id okl_parallel_processes.org_id%type;
142:
143: l_child_in_error NUMBER;

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

136: -- Org Id and standard who columns
137: l_last_updated_by okl_parallel_processes.last_updated_by%TYPE := Fnd_Global.USER_ID;
138: l_last_update_login okl_parallel_processes.last_update_login%TYPE := Fnd_Global.LOGIN_ID;
139: l_request_id okl_parallel_processes.request_id%TYPE := Fnd_Global.CONC_REQUEST_ID;
140: l_program_id okl_parallel_processes.program_id%TYPE := Fnd_Global.CONC_PROGRAM_ID;
141: l_org_id okl_parallel_processes.org_id%type;
142:
143: l_child_in_error NUMBER;
144: l_child_in_warn NUMBER;

Line 141: l_org_id okl_parallel_processes.org_id%type;

137: l_last_updated_by okl_parallel_processes.last_updated_by%TYPE := Fnd_Global.USER_ID;
138: l_last_update_login okl_parallel_processes.last_update_login%TYPE := Fnd_Global.LOGIN_ID;
139: l_request_id okl_parallel_processes.request_id%TYPE := Fnd_Global.CONC_REQUEST_ID;
140: l_program_id okl_parallel_processes.program_id%TYPE := Fnd_Global.CONC_PROGRAM_ID;
141: l_org_id okl_parallel_processes.org_id%type;
142:
143: l_child_in_error NUMBER;
144: l_child_in_warn NUMBER;
145:

Line 378: INSERT INTO OKL_PARALLEL_PROCESSES

374: l_org_id := mo_global.get_current_org_id();
375: WRITE_TO_LOG('org id:: '||l_org_id);
376:
377:
378: INSERT INTO OKL_PARALLEL_PROCESSES
379: (
380: object_type, object_value, assigned_process, process_status, start_date, khr_id,
381: ORG_ID,CREATED_BY,CREATION_DATE,LAST_UPDATE_DATE,LAST_UPDATED_BY,LAST_UPDATE_LOGIN,
382: REQUEST_ID,PROGRAM_ID,PROGRAM_UPDATE_DATE

Line 403: FROM OKL_PARALLEL_PROCESSES opp

399: AND ( (lp_k_end_date_from IS NULL) OR (chr.END_DATE IS NOT NULL AND chr.END_DATE >= lp_k_end_date_from) )
400: AND ( (lp_k_end_date_to IS NULL ) OR (chr.END_DATE IS NOT NULL AND chr.END_DATE <= lp_k_end_date_to) )
401: AND NOT EXISTS
402: (SELECT '1'
403: FROM OKL_PARALLEL_PROCESSES opp
404: WHERE chr.contract_number = opp.object_value
405: AND opp.object_type = 'CONTRACT_FIN_EXTRACT'
406: AND opp.process_status in ('PENDING_ASSIGNMENT', 'ASSIGNED'));
407:

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

406: AND opp.process_status in ('PENDING_ASSIGNMENT', 'ASSIGNED'));
407:
408: l_row_count := SQL%ROWCOUNT;
409:
410: write_to_log('Number of rows inserted in OKL_PARALLEL_PROCESSES :'||l_row_count);
411:
412: IF l_row_count > 0 THEN
413: l_data_found := TRUE;
414:

Line 486: UPDATE OKL_PARALLEL_PROCESSES

482: FOR k IN l_parallel_worker_tbl.FIRST..l_parallel_worker_tbl.LAST LOOP
483:
484:
485: write_to_log('contract # : '||l_parallel_worker_tbl(k).object_value||': worker # '||l_parallel_worker_tbl(k).assigned_process);
486: UPDATE OKL_PARALLEL_PROCESSES
487: SET assigned_process = l_parallel_worker_tbl(k).assigned_process,
488: process_status = 'ASSIGNED'
489: WHERE object_Type = 'CONTRACT_FIN_EXTRACT'
490: AND object_value = l_parallel_worker_tbl(k).object_value

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

492:
493: COMMIT;
494: END LOOP;
495:
496: write_to_log('OKL_PARALLEL_PROCESSES Updated with worker assignment');
497:
498: FOR j in 1..l_max_worker_used LOOP
499:
500: l_req_data := fnd_conc_global.request_data;

Line 551: DELETE OKL_PARALLEL_PROCESSES

547:
548: write_to_log('Request submission failed.');
549: write_to_log('Exiting with error... ');
550:
551: DELETE OKL_PARALLEL_PROCESSES
552: WHERE assigned_process like l_char_seq_num||'%' ;
553:
554: l_row_count := sql%rowcount;
555: IF l_row_count > 0 THEN

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

552: WHERE assigned_process like l_char_seq_num||'%' ;
553:
554: l_row_count := sql%rowcount;
555: IF l_row_count > 0 THEN
556: write_to_log('Deleted '||l_row_count||' rows from OKL_PARALLEL_PROCESSES.');
557: END IF;
558:
559: COMMIT;
560: -- If request submission failed, exit with error

Line 587: DELETE OKL_PARALLEL_PROCESSES

583: exception
584: when others then
585: write_to_log('Unhandled Exception '||sqlcode||':'||sqlerrm);
586:
587: DELETE OKL_PARALLEL_PROCESSES
588: WHERE assigned_process like l_char_seq_num||'%' ;
589:
590: l_row_count := sql%rowcount;
591:

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

589:
590: l_row_count := sql%rowcount;
591:
592: IF l_row_count > 0 THEN
593: write_to_log('Deleted '||sql%rowcount||' rows from OKL_PARALLEL_PROCESSES.');
594: END IF;
595:
596: COMMIT;
597: