eTRM uses javascript that opens and focuses a separate window to display reports. Your browser does not appear to support javascript. This should not prevent you from using eTRM but it does mean the window focus feature will not work. Please check the contents of other windows on your desktop if you click on a link that does not appear to do anything.

APPS.BEN_DM_MASTER dependencies on BEN_DM_UTILITY

Line 38: ben_dm_utility.r_migration_rec,

34:
35: --
36: PROCEDURE controller_init(p_migration_id IN NUMBER,
37: r_migration_data IN OUT nocopy
38: ben_dm_utility.r_migration_rec,
39: p_request_data IN VARCHAR2) IS
40: --
41:
42: l_current_phase_status VARCHAR2(30);

Line 86: ben_dm_utility.message('ROUT','entry:ben_dm_master.controller_init', 5);

82: --
83: BEGIN
84: --
85:
86: ben_dm_utility.message('ROUT','entry:ben_dm_master.controller_init', 5);
87: ben_dm_utility.message('PARA','(p_migration_id - ' || p_migration_id ||
88: ')(r_migration_data - record' ||
89: ')(p_request_data - ' || p_request_data || ')', 10);
90:

Line 87: ben_dm_utility.message('PARA','(p_migration_id - ' || p_migration_id ||

83: BEGIN
84: --
85:
86: ben_dm_utility.message('ROUT','entry:ben_dm_master.controller_init', 5);
87: ben_dm_utility.message('PARA','(p_migration_id - ' || p_migration_id ||
88: ')(r_migration_data - record' ||
89: ')(p_request_data - ' || p_request_data || ')', 10);
90:
91:

Line 158: ben_dm_utility.update_migrations(p_new_status => 'E',

154: l_valid_migration := ben_dm_business.validate_migration(r_migration_data);
155: IF (l_valid_migration = 'E') THEN
156: -- raise error
157: l_fatal_error_message := 'Invalid migration - business rule broken';
158: ben_dm_utility.update_migrations(p_new_status => 'E',
159: p_id => p_migration_id);
160: RAISE e_fatal_error;
161: END IF;
162: END IF;

Line 166: ben_dm_utility.update_migrations(p_new_status => 'S',

162: END IF;
163:
164: -- update status of migration to started (un-paused)
165: IF (NVL(p_request_data, '?') = '?') THEN
166: ben_dm_utility.update_migrations(p_new_status => 'S',
167: p_id => p_migration_id);
168: END IF;
169:
170:

Line 171: ben_dm_utility.message('INFO','Main controller initialized', 15);

167: p_id => p_migration_id);
168: END IF;
169:
170:
171: ben_dm_utility.message('INFO','Main controller initialized', 15);
172: ben_dm_utility.message('SUMM','Main controller initialized', 20);
173: ben_dm_utility.message('ROUT','exit:ben_dm_master.controller_init', 25);
174: ben_dm_utility.message('PARA','(none)', 30);
175:

Line 172: ben_dm_utility.message('SUMM','Main controller initialized', 20);

168: END IF;
169:
170:
171: ben_dm_utility.message('INFO','Main controller initialized', 15);
172: ben_dm_utility.message('SUMM','Main controller initialized', 20);
173: ben_dm_utility.message('ROUT','exit:ben_dm_master.controller_init', 25);
174: ben_dm_utility.message('PARA','(none)', 30);
175:
176:

Line 173: ben_dm_utility.message('ROUT','exit:ben_dm_master.controller_init', 25);

169:
170:
171: ben_dm_utility.message('INFO','Main controller initialized', 15);
172: ben_dm_utility.message('SUMM','Main controller initialized', 20);
173: ben_dm_utility.message('ROUT','exit:ben_dm_master.controller_init', 25);
174: ben_dm_utility.message('PARA','(none)', 30);
175:
176:
177:

Line 174: ben_dm_utility.message('PARA','(none)', 30);

170:
171: ben_dm_utility.message('INFO','Main controller initialized', 15);
172: ben_dm_utility.message('SUMM','Main controller initialized', 20);
173: ben_dm_utility.message('ROUT','exit:ben_dm_master.controller_init', 25);
174: ben_dm_utility.message('PARA','(none)', 30);
175:
176:
177:
178: -- error handling

Line 181: ben_dm_utility.error(SQLCODE,'hr_dm_range.main_controller',

177:
178: -- error handling
179: EXCEPTION
180: WHEN e_fatal_error THEN
181: ben_dm_utility.error(SQLCODE,'hr_dm_range.main_controller',
182: l_fatal_error_message,'R');
183: report_error(l_phase_name, p_migration_id,
184: l_fatal_error_message ||
185: ' in ben_dm_master.main_controller', 'M');

Line 188: ben_dm_utility.error(SQLCODE,'ben_dm_master.main_controller',

184: l_fatal_error_message ||
185: ' in ben_dm_master.main_controller', 'M');
186: RAISE;
187: WHEN OTHERS THEN
188: ben_dm_utility.error(SQLCODE,'ben_dm_master.main_controller',
189: '(none)','R');
190: report_error(l_phase_name, p_migration_id,
191: 'Untrapped error in ben_dm_master.main_controller', 'M');
192: RAISE;

Line 269: ben_dm_utility.message('ROUT','entry:ben_dm_master.insert_request', 5);

265: --
266: BEGIN
267: --
268:
269: ben_dm_utility.message('ROUT','entry:ben_dm_master.insert_request', 5);
270: ben_dm_utility.message('PARA','(p_phase - ' || p_phase ||
271: ')(p_request_id - ' || p_request_id ||
272: ')(p_master_slave - ' || p_master_slave ||
273: ')(p_migration_id - ' || p_migration_id ||

Line 270: ben_dm_utility.message('PARA','(p_phase - ' || p_phase ||

266: BEGIN
267: --
268:
269: ben_dm_utility.message('ROUT','entry:ben_dm_master.insert_request', 5);
270: ben_dm_utility.message('PARA','(p_phase - ' || p_phase ||
271: ')(p_request_id - ' || p_request_id ||
272: ')(p_master_slave - ' || p_master_slave ||
273: ')(p_migration_id - ' || p_migration_id ||
274: ')(p_phase_id - ' || p_phase_id ||

Line 309: ben_dm_utility.message('INFO','Inserted into ben_dm_migration_requests', 15);

305: WHERE request_id = p_request_id);
306:
307: COMMIT;
308:
309: ben_dm_utility.message('INFO','Inserted into ben_dm_migration_requests', 15);
310: ben_dm_utility.message('SUMM','Inserted into ben_dm_migration_requests', 20);
311: ben_dm_utility.message('ROUT','exit:ben_dm_master.insert_request', 25);
312: ben_dm_utility.message('PARA','(none)', 30);
313:

Line 310: ben_dm_utility.message('SUMM','Inserted into ben_dm_migration_requests', 20);

306:
307: COMMIT;
308:
309: ben_dm_utility.message('INFO','Inserted into ben_dm_migration_requests', 15);
310: ben_dm_utility.message('SUMM','Inserted into ben_dm_migration_requests', 20);
311: ben_dm_utility.message('ROUT','exit:ben_dm_master.insert_request', 25);
312: ben_dm_utility.message('PARA','(none)', 30);
313:
314: -- error handling

Line 311: ben_dm_utility.message('ROUT','exit:ben_dm_master.insert_request', 25);

307: COMMIT;
308:
309: ben_dm_utility.message('INFO','Inserted into ben_dm_migration_requests', 15);
310: ben_dm_utility.message('SUMM','Inserted into ben_dm_migration_requests', 20);
311: ben_dm_utility.message('ROUT','exit:ben_dm_master.insert_request', 25);
312: ben_dm_utility.message('PARA','(none)', 30);
313:
314: -- error handling
315: EXCEPTION

Line 312: ben_dm_utility.message('PARA','(none)', 30);

308:
309: ben_dm_utility.message('INFO','Inserted into ben_dm_migration_requests', 15);
310: ben_dm_utility.message('SUMM','Inserted into ben_dm_migration_requests', 20);
311: ben_dm_utility.message('ROUT','exit:ben_dm_master.insert_request', 25);
312: ben_dm_utility.message('PARA','(none)', 30);
313:
314: -- error handling
315: EXCEPTION
316: WHEN OTHERS THEN

Line 317: ben_dm_utility.error(SQLCODE,'ben_dm_master.insert_request','(none)','R');

313:
314: -- error handling
315: EXCEPTION
316: WHEN OTHERS THEN
317: ben_dm_utility.error(SQLCODE,'ben_dm_master.insert_request','(none)','R');
318: RAISE;
319:
320:
321: --

Line 345: r_migration_data IN ben_dm_utility.r_migration_rec) IS

341: -- ------------------------------------------------------------------------
342:
343: --
344: PROCEDURE spawn_slaves(p_current_phase IN VARCHAR2,
345: r_migration_data IN ben_dm_utility.r_migration_rec) IS
346: --
347:
348: l_counter NUMBER;
349: l_request_id NUMBER;

Line 370: ben_dm_utility.message('ROUT','entry:ben_dm_master.spawn_slaves', 5);

366: --
367: BEGIN
368: --
369:
370: ben_dm_utility.message('ROUT','entry:ben_dm_master.spawn_slaves', 5);
371: ben_dm_utility.message('PARA','(p_current_phase - ' || p_current_phase ||
372: ')(r_migration_data - record)', 10);
373:
374:

Line 371: ben_dm_utility.message('PARA','(p_current_phase - ' || p_current_phase ||

367: BEGIN
368: --
369:
370: ben_dm_utility.message('ROUT','entry:ben_dm_master.spawn_slaves', 5);
371: ben_dm_utility.message('PARA','(p_current_phase - ' || p_current_phase ||
372: ')(r_migration_data - record)', 10);
373:
374:
375: -- set up name for appropriate concurrent slave

Line 380: l_phase_id := ben_dm_utility.get_phase_id(p_current_phase,

376: l_slave_program := 'BENDMSLV' || p_current_phase;
377:
378: -- get the current phase_id
379: if p_current_phase <> 'UF' then
380: l_phase_id := ben_dm_utility.get_phase_id(p_current_phase,
381: r_migration_data.migration_id);
382: else
383: l_phase_id := -1;
384: end if;

Line 387: l_threads := ben_dm_utility.number_of_threads(fnd_profile.value('PER_BUSINESS_GROUP_ID'));

383: l_phase_id := -1;
384: end if;
385:
386: -- find the number of threads to use
387: l_threads := ben_dm_utility.number_of_threads(fnd_profile.value('PER_BUSINESS_GROUP_ID'));
388:
389: if l_threads is null then
390: l_threads := 3;
391: end if;

Line 405: ben_dm_utility.message('INFO','p_no_of_files ' || l_argument5, 17);

401: (p_dir_name => l_argument2,
402: p_data_file => g_data_file_name,
403: p_no_of_files => l_argument5);
404:
405: ben_dm_utility.message('INFO','p_no_of_files ' || l_argument5, 17);
406: IF nvl(l_argument5,0) = 0 THEN
407: l_fatal_error_message := 'Unable to find input data files';
408: report_error(p_current_phase, r_migration_data.migration_id,
409: l_fatal_error_message, 'P');

Line 467: ben_dm_utility.message('INFO','p_no_of_files ' || l_threads, 17);

463: p_data_file => g_data_file_name,
464: p_no_of_files => l_threads);
465:
466: l_threads := nvl(l_threads,0);
467: ben_dm_utility.message('INFO','p_no_of_files ' || l_threads, 17);
468: IF nvl(l_threads,0) = 0 THEN
469: l_fatal_error_message := 'Unable to find input data files';
470: report_error(p_current_phase, r_migration_data.migration_id,
471: l_fatal_error_message, 'P');

Line 481: ben_dm_utility.message('INFO','Spawning slave #' || l_counter, 16);

477: END IF;
478:
479:
480: FOR l_counter IN 1..l_threads LOOP
481: ben_dm_utility.message('INFO','Spawning slave #' || l_counter, 16);
482: ben_dm_utility.message('INFO','submiting request for ' || l_slave_program , 5);
483:
484: l_request_id := fnd_request.submit_request(
485: application => 'BEN',

Line 482: ben_dm_utility.message('INFO','submiting request for ' || l_slave_program , 5);

478:
479:
480: FOR l_counter IN 1..l_threads LOOP
481: ben_dm_utility.message('INFO','Spawning slave #' || l_counter, 16);
482: ben_dm_utility.message('INFO','submiting request for ' || l_slave_program , 5);
483:
484: l_request_id := fnd_request.submit_request(
485: application => 'BEN',
486: program => l_slave_program,

Line 507: ben_dm_utility.message('INFO','Slave request ID#' || l_request_id, 17);

503: p_phase_id => l_phase_id);
504:
505: COMMIT;
506:
507: ben_dm_utility.message('INFO','Slave request ID#' || l_request_id, 17);
508: IF (l_request_id = 0) THEN
509: l_fatal_error_message := 'Unable to start slave process';
510: report_error(p_current_phase, r_migration_data.migration_id,
511: l_fatal_error_message, 'P');

Line 516: ben_dm_utility.message('INFO','Spawned slaves', 15);

512: RAISE e_fatal_error;
513: END IF;
514: END LOOP;
515:
516: ben_dm_utility.message('INFO','Spawned slaves', 15);
517: ben_dm_utility.message('SUMM','Spawned slaves', 20);
518: ben_dm_utility.message('ROUT','exit:ben_dm_master.spawn_slaves', 25);
519: ben_dm_utility.message('PARA','(none)', 30);
520:

Line 517: ben_dm_utility.message('SUMM','Spawned slaves', 20);

513: END IF;
514: END LOOP;
515:
516: ben_dm_utility.message('INFO','Spawned slaves', 15);
517: ben_dm_utility.message('SUMM','Spawned slaves', 20);
518: ben_dm_utility.message('ROUT','exit:ben_dm_master.spawn_slaves', 25);
519: ben_dm_utility.message('PARA','(none)', 30);
520:
521: EXCEPTION

Line 518: ben_dm_utility.message('ROUT','exit:ben_dm_master.spawn_slaves', 25);

514: END LOOP;
515:
516: ben_dm_utility.message('INFO','Spawned slaves', 15);
517: ben_dm_utility.message('SUMM','Spawned slaves', 20);
518: ben_dm_utility.message('ROUT','exit:ben_dm_master.spawn_slaves', 25);
519: ben_dm_utility.message('PARA','(none)', 30);
520:
521: EXCEPTION
522: WHEN e_fatal_error THEN

Line 519: ben_dm_utility.message('PARA','(none)', 30);

515:
516: ben_dm_utility.message('INFO','Spawned slaves', 15);
517: ben_dm_utility.message('SUMM','Spawned slaves', 20);
518: ben_dm_utility.message('ROUT','exit:ben_dm_master.spawn_slaves', 25);
519: ben_dm_utility.message('PARA','(none)', 30);
520:
521: EXCEPTION
522: WHEN e_fatal_error THEN
523: ben_dm_utility.error(SQLCODE,'ben_dm_master.spawn_slaves',

Line 523: ben_dm_utility.error(SQLCODE,'ben_dm_master.spawn_slaves',

519: ben_dm_utility.message('PARA','(none)', 30);
520:
521: EXCEPTION
522: WHEN e_fatal_error THEN
523: ben_dm_utility.error(SQLCODE,'ben_dm_master.spawn_slaves',
524: l_fatal_error_message,'R');
525: report_error(p_current_phase, r_migration_data.migration_id,
526: 'Error in ben_dm_master.spawn_slaves', 'P');
527: RAISE;

Line 529: ben_dm_utility.error(SQLCODE,'ben_dm_master.spawn_slaves','(none)','R');

525: report_error(p_current_phase, r_migration_data.migration_id,
526: 'Error in ben_dm_master.spawn_slaves', 'P');
527: RAISE;
528: WHEN OTHERS THEN
529: ben_dm_utility.error(SQLCODE,'ben_dm_master.spawn_slaves','(none)','R');
530: report_error(p_current_phase, r_migration_data.migration_id,
531: 'Untrapped error in ben_dm_master.spawn_slaves', 'P');
532: RAISE;
533:

Line 559: r_migration_data IN ben_dm_utility.r_migration_rec)

555: -- ------------------------------------------------------------------------
556:
557: --
558: FUNCTION slave_status(p_current_phase IN VARCHAR2,
559: r_migration_data IN ben_dm_utility.r_migration_rec)
560: RETURN VARCHAR2 IS
561: --
562:
563: l_slave_status VARCHAR2(1);

Line 586: ben_dm_utility.message('ROUT','entry:ben_dm_master.slave_status', 5);

582: --
583: BEGIN
584: --
585:
586: ben_dm_utility.message('ROUT','entry:ben_dm_master.slave_status', 5);
587: ben_dm_utility.message('PARA','(p_current_phase - ' || p_current_phase ||
588: ')(r_migration_data - record)', 10);
589:
590: -- get the current phase_id

Line 587: ben_dm_utility.message('PARA','(p_current_phase - ' || p_current_phase ||

583: BEGIN
584: --
585:
586: ben_dm_utility.message('ROUT','entry:ben_dm_master.slave_status', 5);
587: ben_dm_utility.message('PARA','(p_current_phase - ' || p_current_phase ||
588: ')(r_migration_data - record)', 10);
589:
590: -- get the current phase_id
591: if p_current_phase <> 'UF' then

Line 592: l_phase_id := ben_dm_utility.get_phase_id(p_current_phase,

588: ')(r_migration_data - record)', 10);
589:
590: -- get the current phase_id
591: if p_current_phase <> 'UF' then
592: l_phase_id := ben_dm_utility.get_phase_id(p_current_phase,
593: r_migration_data.migration_id);
594: else
595: l_phase_id := -1;
596: end if;

Line 617: ben_dm_utility.message('INFO','Slave status request', 15);

613: END LOOP;
614: CLOSE csr_requests;
615:
616:
617: ben_dm_utility.message('INFO','Slave status request', 15);
618: ben_dm_utility.message('SUMM','Slave status request', 20);
619: ben_dm_utility.message('ROUT','exit:ben_dm_master.spawn_slaves', 25);
620: ben_dm_utility.message('PARA','(l_slave_error - ' || l_slave_error ||
621: ')', 30);

Line 618: ben_dm_utility.message('SUMM','Slave status request', 20);

614: CLOSE csr_requests;
615:
616:
617: ben_dm_utility.message('INFO','Slave status request', 15);
618: ben_dm_utility.message('SUMM','Slave status request', 20);
619: ben_dm_utility.message('ROUT','exit:ben_dm_master.spawn_slaves', 25);
620: ben_dm_utility.message('PARA','(l_slave_error - ' || l_slave_error ||
621: ')', 30);
622:

Line 619: ben_dm_utility.message('ROUT','exit:ben_dm_master.spawn_slaves', 25);

615:
616:
617: ben_dm_utility.message('INFO','Slave status request', 15);
618: ben_dm_utility.message('SUMM','Slave status request', 20);
619: ben_dm_utility.message('ROUT','exit:ben_dm_master.spawn_slaves', 25);
620: ben_dm_utility.message('PARA','(l_slave_error - ' || l_slave_error ||
621: ')', 30);
622:
623:

Line 620: ben_dm_utility.message('PARA','(l_slave_error - ' || l_slave_error ||

616:
617: ben_dm_utility.message('INFO','Slave status request', 15);
618: ben_dm_utility.message('SUMM','Slave status request', 20);
619: ben_dm_utility.message('ROUT','exit:ben_dm_master.spawn_slaves', 25);
620: ben_dm_utility.message('PARA','(l_slave_error - ' || l_slave_error ||
621: ')', 30);
622:
623:
624: RETURN(l_slave_error);

Line 629: ben_dm_utility.error(SQLCODE,'ben_dm_master.slave_status','(none)','R');

625:
626: -- error handling
627: EXCEPTION
628: WHEN OTHERS THEN
629: ben_dm_utility.error(SQLCODE,'ben_dm_master.slave_status','(none)','R');
630: report_error(p_current_phase, r_migration_data.migration_id,
631: 'Untrapped error in ben_dm_master.slave_status', 'P');
632: RAISE;
633:

Line 672: ben_dm_utility.message('ROUT','entry:ben_dm_master.report_error', 5);

668: --
669: BEGIN
670: --
671:
672: ben_dm_utility.message('ROUT','entry:ben_dm_master.report_error', 5);
673: ben_dm_utility.message('PARA','(p_current_phase - ' || p_current_phase ||
674: ')(p_migration - ' || p_migration ||
675: ')(p_error_message - ' || p_error_message ||
676: ')(p_stage - ' || p_stage || ')', 10);

Line 673: ben_dm_utility.message('PARA','(p_current_phase - ' || p_current_phase ||

669: BEGIN
670: --
671:
672: ben_dm_utility.message('ROUT','entry:ben_dm_master.report_error', 5);
673: ben_dm_utility.message('PARA','(p_current_phase - ' || p_current_phase ||
674: ')(p_migration - ' || p_migration ||
675: ')(p_error_message - ' || p_error_message ||
676: ')(p_stage - ' || p_stage || ')', 10);
677:

Line 682: ben_dm_utility.update_phases(p_new_status => 'E',

678:
679: -- update status to show error (E)
680: -- update approriate phase, migration, etc.
681: IF (p_stage = 'P') THEN
682: ben_dm_utility.update_phases(p_new_status => 'E',
683: p_id => ben_dm_utility.get_phase_id(
684: p_current_phase, p_migration));
685: END IF;
686:

Line 683: p_id => ben_dm_utility.get_phase_id(

679: -- update status to show error (E)
680: -- update approriate phase, migration, etc.
681: IF (p_stage = 'P') THEN
682: ben_dm_utility.update_phases(p_new_status => 'E',
683: p_id => ben_dm_utility.get_phase_id(
684: p_current_phase, p_migration));
685: END IF;
686:
687: IF (p_stage = 'M') THEN

Line 688: ben_dm_utility.update_migrations(p_new_status => 'E', p_id => p_migration);

684: p_current_phase, p_migration));
685: END IF;
686:
687: IF (p_stage = 'M') THEN
688: ben_dm_utility.update_migrations(p_new_status => 'E', p_id => p_migration);
689: END IF;
690:
691:
692: ben_dm_utility.message('INFO','Error reported', 15);

Line 692: ben_dm_utility.message('INFO','Error reported', 15);

688: ben_dm_utility.update_migrations(p_new_status => 'E', p_id => p_migration);
689: END IF;
690:
691:
692: ben_dm_utility.message('INFO','Error reported', 15);
693: ben_dm_utility.message('SUMM','Error reported', 20);
694: ben_dm_utility.message('ROUT','exit:ben_dm_master.report_error', 25);
695: ben_dm_utility.message('PARA','(none)', 30);
696:

Line 693: ben_dm_utility.message('SUMM','Error reported', 20);

689: END IF;
690:
691:
692: ben_dm_utility.message('INFO','Error reported', 15);
693: ben_dm_utility.message('SUMM','Error reported', 20);
694: ben_dm_utility.message('ROUT','exit:ben_dm_master.report_error', 25);
695: ben_dm_utility.message('PARA','(none)', 30);
696:
697:

Line 694: ben_dm_utility.message('ROUT','exit:ben_dm_master.report_error', 25);

690:
691:
692: ben_dm_utility.message('INFO','Error reported', 15);
693: ben_dm_utility.message('SUMM','Error reported', 20);
694: ben_dm_utility.message('ROUT','exit:ben_dm_master.report_error', 25);
695: ben_dm_utility.message('PARA','(none)', 30);
696:
697:
698: --

Line 695: ben_dm_utility.message('PARA','(none)', 30);

691:
692: ben_dm_utility.message('INFO','Error reported', 15);
693: ben_dm_utility.message('SUMM','Error reported', 20);
694: ben_dm_utility.message('ROUT','exit:ben_dm_master.report_error', 25);
695: ben_dm_utility.message('PARA','(none)', 30);
696:
697:
698: --
699: END report_error;

Line 725: r_migration_data IN ben_dm_utility.r_migration_rec)

721: -- ------------------------------------------------------------------------
722:
723: --
724: FUNCTION work_required(p_current_phase IN VARCHAR2,
725: r_migration_data IN ben_dm_utility.r_migration_rec)
726: RETURN VARCHAR2 IS
727: --
728:
729: l_work VARCHAR2(1);

Line 751: ben_dm_utility.message('ROUT','entry:ben_dm_master.work_required', 5);

747: --
748: BEGIN
749: --
750:
751: ben_dm_utility.message('ROUT','entry:ben_dm_master.work_required', 5);
752: ben_dm_utility.message('PARA','(p_current_phase - ' || p_current_phase ||
753: ')(r_migration_data - record)', 10);
754:
755: ben_dm_utility.message('INFO','Migration Id ' || r_migration_data.migration_id, 17);

Line 752: ben_dm_utility.message('PARA','(p_current_phase - ' || p_current_phase ||

748: BEGIN
749: --
750:
751: ben_dm_utility.message('ROUT','entry:ben_dm_master.work_required', 5);
752: ben_dm_utility.message('PARA','(p_current_phase - ' || p_current_phase ||
753: ')(r_migration_data - record)', 10);
754:
755: ben_dm_utility.message('INFO','Migration Id ' || r_migration_data.migration_id, 17);
756:

Line 755: ben_dm_utility.message('INFO','Migration Id ' || r_migration_data.migration_id, 17);

751: ben_dm_utility.message('ROUT','entry:ben_dm_master.work_required', 5);
752: ben_dm_utility.message('PARA','(p_current_phase - ' || p_current_phase ||
753: ')(r_migration_data - record)', 10);
754:
755: ben_dm_utility.message('INFO','Migration Id ' || r_migration_data.migration_id, 17);
756:
757: -- get the current phase_id
758: l_phase_id := ben_dm_utility.get_phase_id(p_current_phase,
759: r_migration_data.migration_id);

Line 758: l_phase_id := ben_dm_utility.get_phase_id(p_current_phase,

754:
755: ben_dm_utility.message('INFO','Migration Id ' || r_migration_data.migration_id, 17);
756:
757: -- get the current phase_id
758: l_phase_id := ben_dm_utility.get_phase_id(p_current_phase,
759: r_migration_data.migration_id);
760:
761: l_work := 'Y';
762:

Line 763: ben_dm_utility.message('INFO','Phase Id ' || l_phase_id, 19);

759: r_migration_data.migration_id);
760:
761: l_work := 'Y';
762:
763: ben_dm_utility.message('INFO','Phase Id ' || l_phase_id, 19);
764:
765: -- check if any phase items to process
766: IF (p_current_phase IN ('G', 'DP', 'CF', 'UP','RC')) THEN
767: OPEN csr_phase_items;

Line 770: ben_dm_utility.message('INFO','No work required for phase ' ||

766: IF (p_current_phase IN ('G', 'DP', 'CF', 'UP','RC')) THEN
767: OPEN csr_phase_items;
768: FETCH csr_phase_items INTO l_required;
769: IF (csr_phase_items%NOTFOUND) THEN
770: ben_dm_utility.message('INFO','No work required for phase ' ||
771: p_current_phase, 11);
772: l_work := 'N';
773: ben_dm_utility.update_phases(p_new_status => 'C',
774: p_id => l_phase_id);

Line 773: ben_dm_utility.update_phases(p_new_status => 'C',

769: IF (csr_phase_items%NOTFOUND) THEN
770: ben_dm_utility.message('INFO','No work required for phase ' ||
771: p_current_phase, 11);
772: l_work := 'N';
773: ben_dm_utility.update_phases(p_new_status => 'C',
774: p_id => l_phase_id);
775: END IF;
776: CLOSE csr_phase_items;
777: END IF;

Line 779: IF (ben_dm_utility.get_phase_status(p_current_phase,

775: END IF;
776: CLOSE csr_phase_items;
777: END IF;
778:
779: IF (ben_dm_utility.get_phase_status(p_current_phase,
780: r_migration_data.migration_id) = 'C') THEN
781: l_work := 'N';
782: END IF;
783:

Line 785: ben_dm_utility.message('INFO','Check work required for phase', 15);

781: l_work := 'N';
782: END IF;
783:
784:
785: ben_dm_utility.message('INFO','Check work required for phase', 15);
786: ben_dm_utility.message('SUMM','Check work required for phase', 20);
787: ben_dm_utility.message('ROUT','exit:ben_dm_master.work_required', 25);
788: ben_dm_utility.message('PARA','(l_work - ' || l_work || ')', 30);
789:

Line 786: ben_dm_utility.message('SUMM','Check work required for phase', 20);

782: END IF;
783:
784:
785: ben_dm_utility.message('INFO','Check work required for phase', 15);
786: ben_dm_utility.message('SUMM','Check work required for phase', 20);
787: ben_dm_utility.message('ROUT','exit:ben_dm_master.work_required', 25);
788: ben_dm_utility.message('PARA','(l_work - ' || l_work || ')', 30);
789:
790:

Line 787: ben_dm_utility.message('ROUT','exit:ben_dm_master.work_required', 25);

783:
784:
785: ben_dm_utility.message('INFO','Check work required for phase', 15);
786: ben_dm_utility.message('SUMM','Check work required for phase', 20);
787: ben_dm_utility.message('ROUT','exit:ben_dm_master.work_required', 25);
788: ben_dm_utility.message('PARA','(l_work - ' || l_work || ')', 30);
789:
790:
791: RETURN(l_work);

Line 788: ben_dm_utility.message('PARA','(l_work - ' || l_work || ')', 30);

784:
785: ben_dm_utility.message('INFO','Check work required for phase', 15);
786: ben_dm_utility.message('SUMM','Check work required for phase', 20);
787: ben_dm_utility.message('ROUT','exit:ben_dm_master.work_required', 25);
788: ben_dm_utility.message('PARA','(l_work - ' || l_work || ')', 30);
789:
790:
791: RETURN(l_work);
792:

Line 796: ben_dm_utility.error(SQLCODE,'ben_dm_master.work_required','(none)','R');

792:
793: -- error handling
794: EXCEPTION
795: WHEN OTHERS THEN
796: ben_dm_utility.error(SQLCODE,'ben_dm_master.work_required','(none)','R');
797: report_error(p_current_phase, r_migration_data.migration_id,
798: 'Untrapped error in ben_dm_master.work_required', 'P');
799: RAISE;
800:

Line 861: r_migration_data IN ben_dm_utility.r_migration_rec) IS

857:
858: --
859: PROCEDURE master(p_current_phase IN VARCHAR2,
860: p_previous_phase IN VARCHAR2,
861: r_migration_data IN ben_dm_utility.r_migration_rec) IS
862: --
863:
864: l_current_phase_status VARCHAR2(30);
865: e_fatal_error EXCEPTION;

Line 875: ben_dm_utility.message('ROUT','entry:ben_dm_master.master', 5);

871: --
872: BEGIN
873: --
874:
875: ben_dm_utility.message('ROUT','entry:ben_dm_master.master', 5);
876: ben_dm_utility.message('PARA','(p_current_phase - ' || p_current_phase ||
877: ')(p_previous_phase - ' || p_previous_phase ||
878: ')(r_migration_data - record)', 10);
879:

Line 876: ben_dm_utility.message('PARA','(p_current_phase - ' || p_current_phase ||

872: BEGIN
873: --
874:
875: ben_dm_utility.message('ROUT','entry:ben_dm_master.master', 5);
876: ben_dm_utility.message('PARA','(p_current_phase - ' || p_current_phase ||
877: ')(p_previous_phase - ' || p_previous_phase ||
878: ')(r_migration_data - record)', 10);
879:
880: -- see if this is the first run? (l_request_data = NULL or '?')

Line 886: ben_dm_utility.message('INFO','l_request_data ' || l_request_data, 11);

882: -- is it a restart after slaves have finished? (l_request_data =
883: -- paused phase code)
884: l_request_data := fnd_conc_global.request_data;
885:
886: ben_dm_utility.message('INFO','l_request_data ' || l_request_data, 11);
887: IF (NVL(l_request_data, '?') = '?') THEN
888: -- first run processing...
889:
890: ben_dm_utility.message('INFO','First run processing (pre-pause)', 12);

Line 890: ben_dm_utility.message('INFO','First run processing (pre-pause)', 12);

886: ben_dm_utility.message('INFO','l_request_data ' || l_request_data, 11);
887: IF (NVL(l_request_data, '?') = '?') THEN
888: -- first run processing...
889:
890: ben_dm_utility.message('INFO','First run processing (pre-pause)', 12);
891:
892: -- get status of previous phase, is previous phase completed?
893: -- for the first phase there is no previous phase, so check for
894: -- a NULL previous to bypass this check

Line 895: IF ((ben_dm_utility.get_phase_status(p_previous_phase,

891:
892: -- get status of previous phase, is previous phase completed?
893: -- for the first phase there is no previous phase, so check for
894: -- a NULL previous to bypass this check
895: IF ((ben_dm_utility.get_phase_status(p_previous_phase,
896: r_migration_data.migration_id) <> 'C')
897: AND (p_previous_phase <> 'START') ) THEN
898: l_fatal_error_message := 'Previous phase has not completed';
899: report_error(p_current_phase, r_migration_data.migration_id,

Line 905: l_current_phase_status := ben_dm_utility.get_phase_status(p_current_phase,

901: RAISE e_fatal_error;
902: END IF;
903:
904: -- get status of current phase
905: l_current_phase_status := ben_dm_utility.get_phase_status(p_current_phase,
906: r_migration_data.migration_id);
907:
908: -- is phase complete?
909: IF (l_current_phase_status <> 'C') THEN

Line 914: ben_dm_utility.rollback(p_phase => p_current_phase,

910: -- do we need to explicitly rollback using rollback utility?
911: IF ( (l_current_phase_status IN('S', 'E')) AND
912: (p_current_phase IN('I', 'G', 'DP',
913: 'UP', 'CF', 'D','DE')) ) THEN
914: ben_dm_utility.rollback(p_phase => p_current_phase,
915: p_masterslave => 'MASTER',
916: p_migration_id =>
917: r_migration_data.migration_id);
918: END IF;

Line 921: ben_dm_utility.update_phases(p_new_status => 'S',

917: r_migration_data.migration_id);
918: END IF;
919:
920: -- update status to started
921: ben_dm_utility.update_phases(p_new_status => 'S',
922: p_id => ben_dm_utility.get_phase_id(
923: p_current_phase,
924: r_migration_data.migration_id));
925: COMMIT;

Line 922: p_id => ben_dm_utility.get_phase_id(

918: END IF;
919:
920: -- update status to started
921: ben_dm_utility.update_phases(p_new_status => 'S',
922: p_id => ben_dm_utility.get_phase_id(
923: p_current_phase,
924: r_migration_data.migration_id));
925: COMMIT;
926:

Line 943: ben_dm_utility.message('INFO','Unpaused processing', 13);

939: END IF;
940:
941: ELSE
942: -- processing after being woken up
943: ben_dm_utility.message('INFO','Unpaused processing', 13);
944: -- set request data to indicate un-paused phase
945: fnd_conc_global.set_req_globals(request_data => '?');
946:
947:

Line 960: ben_dm_utility.update_phases(p_new_status => l_current_phase_status,

956: l_current_phase_status := 'E';
957: else
958: l_current_phase_status := 'C';
959: end if;
960: ben_dm_utility.update_phases(p_new_status => l_current_phase_status,
961: p_id => ben_dm_utility.get_phase_id(p_current_phase, r_migration_data.migration_id));
962: else
963: l_current_phase_status := ben_dm_utility.get_phase_status(p_current_phase,
964: r_migration_data.migration_id);

Line 961: p_id => ben_dm_utility.get_phase_id(p_current_phase, r_migration_data.migration_id));

957: else
958: l_current_phase_status := 'C';
959: end if;
960: ben_dm_utility.update_phases(p_new_status => l_current_phase_status,
961: p_id => ben_dm_utility.get_phase_id(p_current_phase, r_migration_data.migration_id));
962: else
963: l_current_phase_status := ben_dm_utility.get_phase_status(p_current_phase,
964: r_migration_data.migration_id);
965: end if;

Line 963: l_current_phase_status := ben_dm_utility.get_phase_status(p_current_phase,

959: end if;
960: ben_dm_utility.update_phases(p_new_status => l_current_phase_status,
961: p_id => ben_dm_utility.get_phase_id(p_current_phase, r_migration_data.migration_id));
962: else
963: l_current_phase_status := ben_dm_utility.get_phase_status(p_current_phase,
964: r_migration_data.migration_id);
965: end if;
966:
967: -- is it completed?

Line 978: ben_dm_utility.message('INFO', 'Warning - ' || p_current_phase ||

974:
975: -- has any slave errored?
976: -- if so, add warning message to log
977: IF (l_slave_errored = 'Y') THEN
978: ben_dm_utility.message('INFO', 'Warning - ' || p_current_phase ||
979: ' phase slave process errored', 13);
980: END IF;
981:
982:

Line 990: ben_dm_utility.message('INFO','Master concurrent program', 15);

986: END IF;
987:
988: END IF;
989:
990: ben_dm_utility.message('INFO','Master concurrent program', 15);
991: ben_dm_utility.message('SUMM','Master concurrent program', 20);
992: ben_dm_utility.message('ROUT','exit:ben_dm_master.master', 25);
993: ben_dm_utility.message('PARA','(none)', 30);
994:

Line 991: ben_dm_utility.message('SUMM','Master concurrent program', 20);

987:
988: END IF;
989:
990: ben_dm_utility.message('INFO','Master concurrent program', 15);
991: ben_dm_utility.message('SUMM','Master concurrent program', 20);
992: ben_dm_utility.message('ROUT','exit:ben_dm_master.master', 25);
993: ben_dm_utility.message('PARA','(none)', 30);
994:
995:

Line 992: ben_dm_utility.message('ROUT','exit:ben_dm_master.master', 25);

988: END IF;
989:
990: ben_dm_utility.message('INFO','Master concurrent program', 15);
991: ben_dm_utility.message('SUMM','Master concurrent program', 20);
992: ben_dm_utility.message('ROUT','exit:ben_dm_master.master', 25);
993: ben_dm_utility.message('PARA','(none)', 30);
994:
995:
996:

Line 993: ben_dm_utility.message('PARA','(none)', 30);

989:
990: ben_dm_utility.message('INFO','Master concurrent program', 15);
991: ben_dm_utility.message('SUMM','Master concurrent program', 20);
992: ben_dm_utility.message('ROUT','exit:ben_dm_master.master', 25);
993: ben_dm_utility.message('PARA','(none)', 30);
994:
995:
996:
997: -- error handling

Line 1000: ben_dm_utility.error(SQLCODE,'hr_dm_range.master',

996:
997: -- error handling
998: EXCEPTION
999: WHEN e_fatal_error THEN
1000: ben_dm_utility.error(SQLCODE,'hr_dm_range.master',
1001: l_fatal_error_message,'R');
1002: report_error(p_current_phase, r_migration_data.migration_id,
1003: 'Untrapped error in ben_dm_master.master', 'P');
1004: RAISE;

Line 1006: ben_dm_utility.error(SQLCODE,'ben_dm_master.master','(none)','R');

1002: report_error(p_current_phase, r_migration_data.migration_id,
1003: 'Untrapped error in ben_dm_master.master', 'P');
1004: RAISE;
1005: WHEN OTHERS THEN
1006: ben_dm_utility.error(SQLCODE,'ben_dm_master.master','(none)','R');
1007: report_error(p_current_phase, r_migration_data.migration_id,
1008: 'Untrapped error in ben_dm_master.master', 'P');
1009: RAISE;
1010: --

Line 1093: r_migration_data ben_dm_utility.r_migration_rec;

1089: l_previous_phase VARCHAR2(30);
1090: l_previous VARCHAR2(30);
1091: e_fatal_error EXCEPTION;
1092: l_fatal_error_message VARCHAR2(200);
1093: r_migration_data ben_dm_utility.r_migration_rec;
1094: l_database_location VARCHAR2(30);
1095: l_request_data VARCHAR2(60);
1096: l_mig_status VARCHAR2(30);
1097: l_loader_lct_file VARCHAR2(100);

Line 1136: ben_dm_utility.message_init;

1132: l_db_loc := '%S%';
1133: END IF;
1134:
1135: -- initialize messaging
1136: ben_dm_utility.message_init;
1137: --
1138: -- see if this is a migration run (l_request_data = NULL)
1139: -- OR
1140: -- is it a restart after slaves have finished? (l_request_data =

Line 1143: ben_dm_utility.message('INFO','Request data - ' || l_request_data, 12);

1139: -- OR
1140: -- is it a restart after slaves have finished? (l_request_data =
1141: -- paused phase code)
1142: l_request_data := fnd_conc_global.request_data;
1143: ben_dm_utility.message('INFO','Request data - ' || l_request_data, 12);
1144: IF (l_request_data IS NULL) THEN
1145:
1146: If p_migration_type = 'SD' then
1147: ben_dm_utility.message('INFO','Start of Truncate from ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 15);

Line 1147: ben_dm_utility.message('INFO','Start of Truncate from ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 15);

1143: ben_dm_utility.message('INFO','Request data - ' || l_request_data, 12);
1144: IF (l_request_data IS NULL) THEN
1145:
1146: If p_migration_type = 'SD' then
1147: ben_dm_utility.message('INFO','Start of Truncate from ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 15);
1148: ben_dm_utility.message('SUMM','Start of Truncate from ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 20);
1149:
1150: -- Truncate From ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables.
1151:

Line 1148: ben_dm_utility.message('SUMM','Start of Truncate from ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 20);

1144: IF (l_request_data IS NULL) THEN
1145:
1146: If p_migration_type = 'SD' then
1147: ben_dm_utility.message('INFO','Start of Truncate from ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 15);
1148: ben_dm_utility.message('SUMM','Start of Truncate from ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 20);
1149:
1150: -- Truncate From ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables.
1151:
1152: execute immediate 'truncate table '||getTableSchema||'.ben_dm_entity_results';

Line 1158: ben_dm_utility.message('INFO','End Truncate of ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 15);

1154: execute immediate 'truncate table '||getTableSchema||'.ben_dm_input_file';
1155:
1156: commit;
1157:
1158: ben_dm_utility.message('INFO','End Truncate of ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 15);
1159: ben_dm_utility.message('SUMM','End Truncate of ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 20);
1160:
1161: --
1162: -- We are ready to do the insert, so pull the next

Line 1159: ben_dm_utility.message('SUMM','End Truncate of ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 20);

1155:
1156: commit;
1157:
1158: ben_dm_utility.message('INFO','End Truncate of ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 15);
1159: ben_dm_utility.message('SUMM','End Truncate of ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 20);
1160:
1161: --
1162: -- We are ready to do the insert, so pull the next
1163: -- sequence number from ben_dm_migrations_s.

Line 1219: ben_dm_utility.message('INFO','Problem with Inserting into BEN_DM_MIGRATION_REQUESTS', 15);

1215: into l_request_id
1216: from dual;
1217:
1218: IF l_request_id = 0 THEN
1219: ben_dm_utility.message('INFO','Problem with Inserting into BEN_DM_MIGRATION_REQUESTS', 15);
1220: ben_dm_utility.message('SUMM','Problem with Inserting into BEN_DM_MIGRATION_REQUESTS', 20);
1221: ELSE
1222: --
1223: -- The request submission was successful - insert

Line 1220: ben_dm_utility.message('SUMM','Problem with Inserting into BEN_DM_MIGRATION_REQUESTS', 20);

1216: from dual;
1217:
1218: IF l_request_id = 0 THEN
1219: ben_dm_utility.message('INFO','Problem with Inserting into BEN_DM_MIGRATION_REQUESTS', 15);
1220: ben_dm_utility.message('SUMM','Problem with Inserting into BEN_DM_MIGRATION_REQUESTS', 20);
1221: ELSE
1222: --
1223: -- The request submission was successful - insert
1224: -- a row into ben_dm_migration_requests so that

Line 1270: ben_dm_utility.message('INFO','Start Of Process Input File', 15);

1266:
1267: -- p_migration_id := l_migration_id;
1268:
1269: -- Read the Input File and Process the Data
1270: ben_dm_utility.message('INFO','Start Of Process Input File', 15);
1271: ben_dm_utility.message('SUMM','Start Of Process Input File', 20);
1272:
1273: ben_dm_input_file_pkg.read_file(r_migration_data);
1274:

Line 1271: ben_dm_utility.message('SUMM','Start Of Process Input File', 20);

1267: -- p_migration_id := l_migration_id;
1268:
1269: -- Read the Input File and Process the Data
1270: ben_dm_utility.message('INFO','Start Of Process Input File', 15);
1271: ben_dm_utility.message('SUMM','Start Of Process Input File', 20);
1272:
1273: ben_dm_input_file_pkg.read_file(r_migration_data);
1274:
1275: ben_dm_utility.message('INFO','End Of Process Input File', 15);

Line 1275: ben_dm_utility.message('INFO','End Of Process Input File', 15);

1271: ben_dm_utility.message('SUMM','Start Of Process Input File', 20);
1272:
1273: ben_dm_input_file_pkg.read_file(r_migration_data);
1274:
1275: ben_dm_utility.message('INFO','End Of Process Input File', 15);
1276: ben_dm_utility.message('SUMM','End Of Process Input File', 20);
1277:
1278:
1279:

Line 1276: ben_dm_utility.message('SUMM','End Of Process Input File', 20);

1272:
1273: ben_dm_input_file_pkg.read_file(r_migration_data);
1274:
1275: ben_dm_utility.message('INFO','End Of Process Input File', 15);
1276: ben_dm_utility.message('SUMM','End Of Process Input File', 20);
1277:
1278:
1279:
1280: end if;

Line 1284: ben_dm_utility.message('INFO','Start of the SU Phase', 15);

1280: end if;
1281:
1282: -- New code
1283: If p_migration_type = 'SU' then
1284: ben_dm_utility.message('INFO','Start of the SU Phase', 15);
1285: ben_dm_utility.message('SUMM','Start of the SU Phase', 20);
1286: ben_dm_utility.message('INFO','Start of Truncate from ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 15);
1287: ben_dm_utility.message('SUMM','Start of Truncate from ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 20);
1288:

Line 1285: ben_dm_utility.message('SUMM','Start of the SU Phase', 20);

1281:
1282: -- New code
1283: If p_migration_type = 'SU' then
1284: ben_dm_utility.message('INFO','Start of the SU Phase', 15);
1285: ben_dm_utility.message('SUMM','Start of the SU Phase', 20);
1286: ben_dm_utility.message('INFO','Start of Truncate from ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 15);
1287: ben_dm_utility.message('SUMM','Start of Truncate from ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 20);
1288:
1289: -- Truncate From ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables.

Line 1286: ben_dm_utility.message('INFO','Start of Truncate from ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 15);

1282: -- New code
1283: If p_migration_type = 'SU' then
1284: ben_dm_utility.message('INFO','Start of the SU Phase', 15);
1285: ben_dm_utility.message('SUMM','Start of the SU Phase', 20);
1286: ben_dm_utility.message('INFO','Start of Truncate from ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 15);
1287: ben_dm_utility.message('SUMM','Start of Truncate from ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 20);
1288:
1289: -- Truncate From ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables.
1290:

Line 1287: ben_dm_utility.message('SUMM','Start of Truncate from ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 20);

1283: If p_migration_type = 'SU' then
1284: ben_dm_utility.message('INFO','Start of the SU Phase', 15);
1285: ben_dm_utility.message('SUMM','Start of the SU Phase', 20);
1286: ben_dm_utility.message('INFO','Start of Truncate from ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 15);
1287: ben_dm_utility.message('SUMM','Start of Truncate from ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 20);
1288:
1289: -- Truncate From ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables.
1290:
1291: execute immediate 'truncate table '||getTableSchema||'.ben_dm_entity_results';

Line 1297: ben_dm_utility.message('INFO','End Truncate of ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 15);

1293: execute immediate 'truncate table '||getTableSchema||'.ben_dm_input_file';
1294:
1295: commit;
1296:
1297: ben_dm_utility.message('INFO','End Truncate of ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 15);
1298: ben_dm_utility.message('SUMM','End Truncate of ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 20);
1299:
1300: --
1301: -- We are ready to do the insert, so pull the next

Line 1298: ben_dm_utility.message('SUMM','End Truncate of ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 20);

1294:
1295: commit;
1296:
1297: ben_dm_utility.message('INFO','End Truncate of ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 15);
1298: ben_dm_utility.message('SUMM','End Truncate of ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 20);
1299:
1300: --
1301: -- We are ready to do the insert, so pull the next
1302: -- sequence number from ben_dm_migrations_s.

Line 1358: ben_dm_utility.message('INFO','Problem with Inserting into BEN_DM_MIGRATION_REQUESTS', 15);

1354: into l_request_id
1355: from dual;
1356:
1357: IF l_request_id = 0 THEN
1358: ben_dm_utility.message('INFO','Problem with Inserting into BEN_DM_MIGRATION_REQUESTS', 15);
1359: ben_dm_utility.message('SUMM','Problem with Inserting into BEN_DM_MIGRATION_REQUESTS', 20);
1360: ELSE
1361: --
1362: -- The request submission was successful - insert

Line 1359: ben_dm_utility.message('SUMM','Problem with Inserting into BEN_DM_MIGRATION_REQUESTS', 20);

1355: from dual;
1356:
1357: IF l_request_id = 0 THEN
1358: ben_dm_utility.message('INFO','Problem with Inserting into BEN_DM_MIGRATION_REQUESTS', 15);
1359: ben_dm_utility.message('SUMM','Problem with Inserting into BEN_DM_MIGRATION_REQUESTS', 20);
1360: ELSE
1361: --
1362: -- The request submission was successful - insert
1363: -- a row into ben_dm_migration_requests so that

Line 1418: ben_dm_utility.message('INFO','Migration Type detected'||p_migration_type, 15);

1414: end if;
1415:
1416:
1417: If (p_migration_type = 'RD' or p_migration_type = 'RU') then
1418: ben_dm_utility.message('INFO','Migration Type detected'||p_migration_type, 15);
1419: ben_dm_utility.message('SUMM','Migration Type detected'||p_migration_type, 20);
1420: ben_dm_utility.message('SUMM','Re Start Migration ID : '||p_restart_migration_id, 20);
1421:
1422: l_migration_id := p_restart_migration_id;

Line 1419: ben_dm_utility.message('SUMM','Migration Type detected'||p_migration_type, 20);

1415:
1416:
1417: If (p_migration_type = 'RD' or p_migration_type = 'RU') then
1418: ben_dm_utility.message('INFO','Migration Type detected'||p_migration_type, 15);
1419: ben_dm_utility.message('SUMM','Migration Type detected'||p_migration_type, 20);
1420: ben_dm_utility.message('SUMM','Re Start Migration ID : '||p_restart_migration_id, 20);
1421:
1422: l_migration_id := p_restart_migration_id;
1423:

Line 1420: ben_dm_utility.message('SUMM','Re Start Migration ID : '||p_restart_migration_id, 20);

1416:
1417: If (p_migration_type = 'RD' or p_migration_type = 'RU') then
1418: ben_dm_utility.message('INFO','Migration Type detected'||p_migration_type, 15);
1419: ben_dm_utility.message('SUMM','Migration Type detected'||p_migration_type, 20);
1420: ben_dm_utility.message('SUMM','Re Start Migration ID : '||p_restart_migration_id, 20);
1421:
1422: l_migration_id := p_restart_migration_id;
1423:
1424: select fnd_global.conc_request_id

Line 1467: ben_dm_utility.message_init;

1463:
1464: end if;
1465:
1466: -- initialize messaging
1467: ben_dm_utility.message_init;
1468:
1469: select migration_id
1470: into l_migration_id
1471: from ben_dm_migration_requests

Line 1474: ben_dm_utility.message('INFO','l_migration_id : '||l_migration_id, 15);

1470: into l_migration_id
1471: from ben_dm_migration_requests
1472: where request_id = fnd_global.conc_request_id;
1473:
1474: ben_dm_utility.message('INFO','l_migration_id : '||l_migration_id, 15);
1475: ben_dm_utility.message('SUMM','l_migration_id : '||l_migration_id, 15);
1476:
1477: -- p_migration_id := l_migration_id;
1478:

Line 1475: ben_dm_utility.message('SUMM','l_migration_id : '||l_migration_id, 15);

1471: from ben_dm_migration_requests
1472: where request_id = fnd_global.conc_request_id;
1473:
1474: ben_dm_utility.message('INFO','l_migration_id : '||l_migration_id, 15);
1475: ben_dm_utility.message('SUMM','l_migration_id : '||l_migration_id, 15);
1476:
1477: -- p_migration_id := l_migration_id;
1478:
1479: ben_dm_utility.message('ROUT','entry:ben_dm_master.main_controller', 5);

Line 1479: ben_dm_utility.message('ROUT','entry:ben_dm_master.main_controller', 5);

1475: ben_dm_utility.message('SUMM','l_migration_id : '||l_migration_id, 15);
1476:
1477: -- p_migration_id := l_migration_id;
1478:
1479: ben_dm_utility.message('ROUT','entry:ben_dm_master.main_controller', 5);
1480: ben_dm_utility.message('PARA','(p_migration_id - ' ||
1481: l_migration_id || ')', 10);
1482:
1483:

Line 1480: ben_dm_utility.message('PARA','(p_migration_id - ' ||

1476:
1477: -- p_migration_id := l_migration_id;
1478:
1479: ben_dm_utility.message('ROUT','entry:ben_dm_master.main_controller', 5);
1480: ben_dm_utility.message('PARA','(p_migration_id - ' ||
1481: l_migration_id || ')', 10);
1482:
1483:
1484: -- see if this is a migration run (l_request_data = NULL)

Line 1489: ben_dm_utility.message('INFO','Request data - ' || l_request_data, 12);

1485: -- OR
1486: -- is it a restart after slaves have finished? (l_request_data =
1487: -- paused phase code)
1488: l_request_data := fnd_conc_global.request_data;
1489: ben_dm_utility.message('INFO','Request data - ' || l_request_data, 12);
1490:
1491: -- initialize main controller data
1492: controller_init(l_migration_id,
1493: r_migration_data,

Line 1520: ben_dm_utility.message('INFO','Start of Main Loop 2', 11);

1516: OPEN csr_phase_rule;
1517: FETCH csr_phase_rule INTO l_phase_name, l_next_phase,
1518: l_database_location;
1519: EXIT WHEN csr_phase_rule%NOTFOUND;
1520: ben_dm_utility.message('INFO','Start of Main Loop 2', 11);
1521: ben_dm_utility.message('INFO','Start of Main Loop 2 - l_phase_name '|| l_phase_name, 11);
1522: ben_dm_utility.message('INFO','Start of Main Loop 2 - l_next_phase '|| l_next_phase, 11);
1523: ben_dm_utility.message('INFO','Start of Main Loop 2 - l_database_location '|| l_database_location, 11);
1524:

Line 1521: ben_dm_utility.message('INFO','Start of Main Loop 2 - l_phase_name '|| l_phase_name, 11);

1517: FETCH csr_phase_rule INTO l_phase_name, l_next_phase,
1518: l_database_location;
1519: EXIT WHEN csr_phase_rule%NOTFOUND;
1520: ben_dm_utility.message('INFO','Start of Main Loop 2', 11);
1521: ben_dm_utility.message('INFO','Start of Main Loop 2 - l_phase_name '|| l_phase_name, 11);
1522: ben_dm_utility.message('INFO','Start of Main Loop 2 - l_next_phase '|| l_next_phase, 11);
1523: ben_dm_utility.message('INFO','Start of Main Loop 2 - l_database_location '|| l_database_location, 11);
1524:
1525: -- does it apply?

Line 1522: ben_dm_utility.message('INFO','Start of Main Loop 2 - l_next_phase '|| l_next_phase, 11);

1518: l_database_location;
1519: EXIT WHEN csr_phase_rule%NOTFOUND;
1520: ben_dm_utility.message('INFO','Start of Main Loop 2', 11);
1521: ben_dm_utility.message('INFO','Start of Main Loop 2 - l_phase_name '|| l_phase_name, 11);
1522: ben_dm_utility.message('INFO','Start of Main Loop 2 - l_next_phase '|| l_next_phase, 11);
1523: ben_dm_utility.message('INFO','Start of Main Loop 2 - l_database_location '|| l_database_location, 11);
1524:
1525: -- does it apply?
1526: IF (INSTR(l_database_location, r_migration_data.database_location) >0) THEN

Line 1523: ben_dm_utility.message('INFO','Start of Main Loop 2 - l_database_location '|| l_database_location, 11);

1519: EXIT WHEN csr_phase_rule%NOTFOUND;
1520: ben_dm_utility.message('INFO','Start of Main Loop 2', 11);
1521: ben_dm_utility.message('INFO','Start of Main Loop 2 - l_phase_name '|| l_phase_name, 11);
1522: ben_dm_utility.message('INFO','Start of Main Loop 2 - l_next_phase '|| l_next_phase, 11);
1523: ben_dm_utility.message('INFO','Start of Main Loop 2 - l_database_location '|| l_database_location, 11);
1524:
1525: -- does it apply?
1526: IF (INSTR(l_database_location, r_migration_data.database_location) >0) THEN
1527:

Line 1528: ben_dm_utility.message('INFO','Current phase is ' || l_phase_name, 11);

1524:
1525: -- does it apply?
1526: IF (INSTR(l_database_location, r_migration_data.database_location) >0) THEN
1527:
1528: ben_dm_utility.message('INFO','Current phase is ' || l_phase_name, 11);
1529: ben_dm_utility.message('INFO','Request data - ' ||
1530: NVL(l_request_data, '?'), 12);
1531:
1532: -- store the previous phase that applies

Line 1529: ben_dm_utility.message('INFO','Request data - ' ||

1525: -- does it apply?
1526: IF (INSTR(l_database_location, r_migration_data.database_location) >0) THEN
1527:
1528: ben_dm_utility.message('INFO','Current phase is ' || l_phase_name, 11);
1529: ben_dm_utility.message('INFO','Request data - ' ||
1530: NVL(l_request_data, '?'), 12);
1531:
1532: -- store the previous phase that applies
1533: l_previous_phase := l_previous;

Line 1534: ben_dm_utility.message('INFO','Previous phase is ' || l_previous_phase, 11);

1530: NVL(l_request_data, '?'), 12);
1531:
1532: -- store the previous phase that applies
1533: l_previous_phase := l_previous;
1534: ben_dm_utility.message('INFO','Previous phase is ' || l_previous_phase, 11);
1535: --
1536: -- is it completed or not awoken?
1537: -- if not, then run appropriate phase code
1538: --

Line 1539: IF ((ben_dm_utility.get_phase_status(l_phase_name, l_migration_id) <> 'C')

1535: --
1536: -- is it completed or not awoken?
1537: -- if not, then run appropriate phase code
1538: --
1539: IF ((ben_dm_utility.get_phase_status(l_phase_name, l_migration_id) <> 'C')
1540: OR (NVL(l_request_data, '?') <> '?')) THEN
1541:
1542: -- call generic master code
1543: IF (l_phase_name IN ('G', 'DP', 'UP','DE','UF','LF')) THEN

Line 1548: ben_dm_utility.message('INFO','Start of Derive Target ID', 11);

1544: --
1545: -- Derive The Target ID from Developer Keys
1546: --
1547: If l_phase_name = 'UP' THEN
1548: ben_dm_utility.message('INFO','Start of Derive Target ID', 11);
1549: ben_dm_upload_dk.get_dk_frm_all;
1550: ben_dm_utility.message('INFO','End of Derive Target ID', 11);
1551: end if;
1552:

Line 1550: ben_dm_utility.message('INFO','End of Derive Target ID', 11);

1546: --
1547: If l_phase_name = 'UP' THEN
1548: ben_dm_utility.message('INFO','Start of Derive Target ID', 11);
1549: ben_dm_upload_dk.get_dk_frm_all;
1550: ben_dm_utility.message('INFO','End of Derive Target ID', 11);
1551: end if;
1552:
1553: master(l_phase_name, l_previous_phase, r_migration_data);
1554: ELSE

Line 1559: ben_dm_utility.update_phases(p_new_status => 'S',

1555: -- call non-generic master code
1556: IF (l_phase_name = 'I') THEN
1557: ben_dm_init.main(r_migration_data);
1558: ELSIF (l_phase_name = 'CF') THEN
1559: ben_dm_utility.update_phases(p_new_status => 'S',
1560: p_id => ben_dm_utility.get_phase_id('CF'
1561: , r_migration_data.migration_id));
1562: ben_dm_create_transfer_file.main
1563: (p_dir_name => r_migration_data.input_parameter_file_path,

Line 1560: p_id => ben_dm_utility.get_phase_id('CF'

1556: IF (l_phase_name = 'I') THEN
1557: ben_dm_init.main(r_migration_data);
1558: ELSIF (l_phase_name = 'CF') THEN
1559: ben_dm_utility.update_phases(p_new_status => 'S',
1560: p_id => ben_dm_utility.get_phase_id('CF'
1561: , r_migration_data.migration_id));
1562: ben_dm_create_transfer_file.main
1563: (p_dir_name => r_migration_data.input_parameter_file_path,
1564: p_file_name => g_transfer_file_name,

Line 1567: ben_dm_utility.update_phases(p_new_status => 'C',

1563: (p_dir_name => r_migration_data.input_parameter_file_path,
1564: p_file_name => g_transfer_file_name,
1565: p_delimiter => g_delimiter);
1566:
1567: ben_dm_utility.update_phases(p_new_status => 'C',
1568: p_id => ben_dm_utility.get_phase_id('CF'
1569: , r_migration_data.migration_id));
1570:
1571: ELSIF (l_phase_name = 'RC') THEN

Line 1568: p_id => ben_dm_utility.get_phase_id('CF'

1564: p_file_name => g_transfer_file_name,
1565: p_delimiter => g_delimiter);
1566:
1567: ben_dm_utility.update_phases(p_new_status => 'C',
1568: p_id => ben_dm_utility.get_phase_id('CF'
1569: , r_migration_data.migration_id));
1570:
1571: ELSIF (l_phase_name = 'RC') THEN
1572: ben_dm_utility.update_phases(p_new_status => 'S',

Line 1572: ben_dm_utility.update_phases(p_new_status => 'S',

1568: p_id => ben_dm_utility.get_phase_id('CF'
1569: , r_migration_data.migration_id));
1570:
1571: ELSIF (l_phase_name = 'RC') THEN
1572: ben_dm_utility.update_phases(p_new_status => 'S',
1573: p_id => ben_dm_utility.get_phase_id('RC'
1574: , r_migration_data.migration_id));
1575:
1576: ben_dm_utility.message('INFO','Start of Custom Code - RC', 11);

Line 1573: p_id => ben_dm_utility.get_phase_id('RC'

1569: , r_migration_data.migration_id));
1570:
1571: ELSIF (l_phase_name = 'RC') THEN
1572: ben_dm_utility.update_phases(p_new_status => 'S',
1573: p_id => ben_dm_utility.get_phase_id('RC'
1574: , r_migration_data.migration_id));
1575:
1576: ben_dm_utility.message('INFO','Start of Custom Code - RC', 11);
1577: ben_dm_custom_code.handle_custom_data(r_migration_data);

Line 1576: ben_dm_utility.message('INFO','Start of Custom Code - RC', 11);

1572: ben_dm_utility.update_phases(p_new_status => 'S',
1573: p_id => ben_dm_utility.get_phase_id('RC'
1574: , r_migration_data.migration_id));
1575:
1576: ben_dm_utility.message('INFO','Start of Custom Code - RC', 11);
1577: ben_dm_custom_code.handle_custom_data(r_migration_data);
1578: ben_dm_utility.message('INFO','Start of Custom Code - RC', 11);
1579:
1580: ben_dm_utility.update_phases(p_new_status => 'C',

Line 1578: ben_dm_utility.message('INFO','Start of Custom Code - RC', 11);

1574: , r_migration_data.migration_id));
1575:
1576: ben_dm_utility.message('INFO','Start of Custom Code - RC', 11);
1577: ben_dm_custom_code.handle_custom_data(r_migration_data);
1578: ben_dm_utility.message('INFO','Start of Custom Code - RC', 11);
1579:
1580: ben_dm_utility.update_phases(p_new_status => 'C',
1581: p_id => ben_dm_utility.get_phase_id('RC'
1582: ,r_migration_data.migration_id));

Line 1580: ben_dm_utility.update_phases(p_new_status => 'C',

1576: ben_dm_utility.message('INFO','Start of Custom Code - RC', 11);
1577: ben_dm_custom_code.handle_custom_data(r_migration_data);
1578: ben_dm_utility.message('INFO','Start of Custom Code - RC', 11);
1579:
1580: ben_dm_utility.update_phases(p_new_status => 'C',
1581: p_id => ben_dm_utility.get_phase_id('RC'
1582: ,r_migration_data.migration_id));
1583:
1584: -- processing after being woken up

Line 1581: p_id => ben_dm_utility.get_phase_id('RC'

1577: ben_dm_custom_code.handle_custom_data(r_migration_data);
1578: ben_dm_utility.message('INFO','Start of Custom Code - RC', 11);
1579:
1580: ben_dm_utility.update_phases(p_new_status => 'C',
1581: p_id => ben_dm_utility.get_phase_id('RC'
1582: ,r_migration_data.migration_id));
1583:
1584: -- processing after being woken up
1585: ben_dm_utility.message('INFO','Unpaused processing', 13);

Line 1585: ben_dm_utility.message('INFO','Unpaused processing', 13);

1581: p_id => ben_dm_utility.get_phase_id('RC'
1582: ,r_migration_data.migration_id));
1583:
1584: -- processing after being woken up
1585: ben_dm_utility.message('INFO','Unpaused processing', 13);
1586: -- set request data to indicate un-paused phase
1587: fnd_conc_global.set_req_globals(request_data => '?');
1588:
1589: END IF;

Line 1600: (ben_dm_utility.get_phase_status(l_phase_name, l_migration_id)

1596: EXIT WHEN NVL(l_request_data, '?') <> '?';
1597:
1598: -- did it complete? if not then update status and raise an error
1599: IF l_phase_name <> 'UF' and
1600: (ben_dm_utility.get_phase_status(l_phase_name, l_migration_id)
1601: <> 'C') THEN
1602: -- update status of migration to error
1603: ben_dm_utility.update_migrations(p_new_status => 'E',
1604: p_id => l_migration_id);

Line 1603: ben_dm_utility.update_migrations(p_new_status => 'E',

1599: IF l_phase_name <> 'UF' and
1600: (ben_dm_utility.get_phase_status(l_phase_name, l_migration_id)
1601: <> 'C') THEN
1602: -- update status of migration to error
1603: ben_dm_utility.update_migrations(p_new_status => 'E',
1604: p_id => l_migration_id);
1605: COMMIT;
1606: -- raise error
1607: l_fatal_error_message := 'Error in ' || l_phase_name || ' phase';

Line 1646: ben_dm_utility.message('INFO','Main controller', 15);

1642: l_fatal_error_message := 'The migration is in error.';
1643: RAISE e_fatal_error;
1644: END IF;
1645:
1646: ben_dm_utility.message('INFO','Main controller', 15);
1647: ben_dm_utility.message('SUMM','Main controller', 20);
1648: ben_dm_utility.message('ROUT','exit:ben_dm_master.main_controller', 25);
1649: ben_dm_utility.message('PARA','(retcode - ' || retcode ||
1650: ')(errbuf - ' || errbuf || ')', 30);

Line 1647: ben_dm_utility.message('SUMM','Main controller', 20);

1643: RAISE e_fatal_error;
1644: END IF;
1645:
1646: ben_dm_utility.message('INFO','Main controller', 15);
1647: ben_dm_utility.message('SUMM','Main controller', 20);
1648: ben_dm_utility.message('ROUT','exit:ben_dm_master.main_controller', 25);
1649: ben_dm_utility.message('PARA','(retcode - ' || retcode ||
1650: ')(errbuf - ' || errbuf || ')', 30);
1651:

Line 1648: ben_dm_utility.message('ROUT','exit:ben_dm_master.main_controller', 25);

1644: END IF;
1645:
1646: ben_dm_utility.message('INFO','Main controller', 15);
1647: ben_dm_utility.message('SUMM','Main controller', 20);
1648: ben_dm_utility.message('ROUT','exit:ben_dm_master.main_controller', 25);
1649: ben_dm_utility.message('PARA','(retcode - ' || retcode ||
1650: ')(errbuf - ' || errbuf || ')', 30);
1651:
1652: EXCEPTION

Line 1649: ben_dm_utility.message('PARA','(retcode - ' || retcode ||

1645:
1646: ben_dm_utility.message('INFO','Main controller', 15);
1647: ben_dm_utility.message('SUMM','Main controller', 20);
1648: ben_dm_utility.message('ROUT','exit:ben_dm_master.main_controller', 25);
1649: ben_dm_utility.message('PARA','(retcode - ' || retcode ||
1650: ')(errbuf - ' || errbuf || ')', 30);
1651:
1652: EXCEPTION
1653: WHEN e_fatal_error THEN

Line 1657: ben_dm_utility.error(SQLCODE,'hr_dm_range.main_controller',

1653: WHEN e_fatal_error THEN
1654: retcode := 2;
1655: errbuf := 'An error occurred during the migration - examine logfiles' ||
1656: ' for detailed reports.';
1657: ben_dm_utility.error(SQLCODE,'hr_dm_range.main_controller',
1658: l_fatal_error_message,'R');
1659: report_error(l_phase_name, l_migration_id,
1660: l_fatal_error_message || ' in ben_dm_master.main_controller',
1661: 'M');

Line 1666: ben_dm_utility.error(SQLCODE,'ben_dm_master.main_controller','(none)','R');

1662: WHEN OTHERS THEN
1663: retcode := 2;
1664: errbuf := 'An error occurred during the migration - examine logfiles' ||
1665: ' for detailed reports.';
1666: ben_dm_utility.error(SQLCODE,'ben_dm_master.main_controller','(none)','R');
1667: report_error(l_phase_name, l_migration_id,
1668: 'Untrapped error in ben_dm_master.main_controller', 'M');
1669:
1670: --