77: result IN OUT NOCOPY varchar2)
78: IS
79:
80: l_entities_to_process VARCHAR2(30) := 'FALSE';
81: cons_entity_wf_info gcs_cons_eng_utility_pkg.r_cons_entity_wf_info;
82: l_xlate_entry_id NUMBER(15);
83: l_run_detail_id NUMBER(15);
84: l_xlate_request_error_code VARCHAR2(30);
85: l_bp_xlate_request_error_code VARCHAR2(30);
138: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
139: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.PREPARE_IMMEDIATE_CHILDREN.begin', '<
140: END IF;
141:
142: gcs_cons_eng_utility_pkg.get_cons_entity_wf_info(itemtype, itemkey, cons_entity_wf_info);
143:
144: FOR v_immediate_children IN c_immediate_children(cons_entity_wf_info.consolidation_hierarchy,
145: cons_entity_wf_info.consolidation_entity,
146: cons_entity_wf_info.cal_period_end_date)
233: l_childkey_list t_childkey_list := t_childkey_list(null);
234: l_child_key VARCHAR2(200);
235: counter NUMBER(15) := 0;
236: l_entities_to_process BOOLEAN := FALSE;
237: cons_entity_wf_info gcs_cons_eng_utility_pkg.r_cons_entity_wf_info;
238: l_workflow_item_key VARCHAR2(200);
239: l_translated_required VARCHAR2(1);
240:
241: CURSOR c_operating_entities (p_run_name IN VARCHAR2,
271: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
272: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.SPAWN_OPER_ENTITY_PROCESS', '<
273: END IF;
274:
275: gcs_cons_eng_utility_pkg.get_cons_entity_wf_info(itemtype, itemkey, cons_entity_wf_info);
276:
277: FOR v_operating_entity IN c_operating_entities(cons_entity_wf_info.run_identifier, cons_entity_wf_info.consolidation_entity)
278: LOOP
279:
323:
324: x_errbuf VARCHAR2(2000);
325: x_retcode VARCHAR2(2000);
326: l_execution_mode VARCHAR2(30) := 'FULL';
327: cons_entity_wf_info gcs_cons_eng_utility_pkg.r_cons_entity_wf_info;
328: oper_entity_wf_info gcs_cons_eng_utility_pkg.r_oper_entity_wf_info;
329: l_data_exists_flag VARCHAR2(1) := 'N';
330: l_entry_id NUMBER(15);
331: l_stat_entry_id NUMBER(15);
324: x_errbuf VARCHAR2(2000);
325: x_retcode VARCHAR2(2000);
326: l_execution_mode VARCHAR2(30) := 'FULL';
327: cons_entity_wf_info gcs_cons_eng_utility_pkg.r_cons_entity_wf_info;
328: oper_entity_wf_info gcs_cons_eng_utility_pkg.r_oper_entity_wf_info;
329: l_data_exists_flag VARCHAR2(1) := 'N';
330: l_entry_id NUMBER(15);
331: l_stat_entry_id NUMBER(15);
332: l_parameter_list gcs_cons_eng_utility_pkg.r_module_parameters;
328: oper_entity_wf_info gcs_cons_eng_utility_pkg.r_oper_entity_wf_info;
329: l_data_exists_flag VARCHAR2(1) := 'N';
330: l_entry_id NUMBER(15);
331: l_stat_entry_id NUMBER(15);
332: l_parameter_list gcs_cons_eng_utility_pkg.r_module_parameters;
333: l_request_error_code VARCHAR2(2000);
334:
335: BEGIN
336:
341:
342: l_execution_mode := WF_ENGINE.GetActivityAttrText(itemtype, itemkey, actid, 'EXECUTION_MODE', FALSE);
343:
344:
345: gcs_cons_eng_utility_pkg.get_oper_entity_wf_info (itemtype,
346: itemkey,
347: cons_entity_wf_info,
348: oper_entity_wf_info);
349:
359: l_parameter_list.balance_type_code := cons_entity_wf_info.balance_type_code;
360: --Bugfix 5017120: Added support for additional data types
361: l_parameter_list.source_dataset_code := cons_entity_wf_info.source_dataset_code;
362:
363: gcs_cons_eng_utility_pkg.execute_module ( module_code => 'DATAPREPARATION',
364: p_parameter_list => l_parameter_list,
365: p_item_key => itemkey);
366:
367:
379: x_retcode => l_parameter_list.retcode);
380: IF (l_parameter_list.errbuf IS NULL) THEN
381: result := 'COMPLETE:T';
382: --Bugfix 4874306: Eliminate calls to XML Generation in order to leverage data templates
383: --gcs_cons_eng_utility_pkg.submit_xml_ntf_program( p_run_name => cons_entity_wf_info.run_identifier,
384: -- p_cons_entity_id => cons_entity_wf_info.consolidation_entity,
385: -- p_category_code => 'DATAPREPARATION',
386: -- p_run_detail_id => oper_entity_wf_info.run_detail_id);
387: ELSE
449: x_errbuf VARCHAR2(2000);
450: x_retcode VARCHAR2(2000);
451: l_process_code VARCHAR2(30);
452: l_prior_dataprep_exists VARCHAR2(1) := 'X';
453: cons_entity_wf_info gcs_cons_eng_utility_pkg.r_cons_entity_wf_info;
454: oper_entity_wf_info gcs_cons_eng_utility_pkg.r_oper_entity_wf_info;
455: l_entry_id NUMBER(15);
456: l_stat_entry_id NUMBER(15);
457: l_request_error_code VARCHAR2(200);
450: x_retcode VARCHAR2(2000);
451: l_process_code VARCHAR2(30);
452: l_prior_dataprep_exists VARCHAR2(1) := 'X';
453: cons_entity_wf_info gcs_cons_eng_utility_pkg.r_cons_entity_wf_info;
454: oper_entity_wf_info gcs_cons_eng_utility_pkg.r_oper_entity_wf_info;
455: l_entry_id NUMBER(15);
456: l_stat_entry_id NUMBER(15);
457: l_request_error_code VARCHAR2(200);
458:
461: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
462: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.INIT_OPER_ENTITY_PROCESS.end', '<
463: END IF;
464:
465: gcs_cons_eng_utility_pkg.get_oper_entity_wf_info (itemtype,
466: itemkey,
467: cons_entity_wf_info,
468: oper_entity_wf_info);
469:
538: l_run_identifier VARCHAR2(200);
539: l_entity_id NUMBER(15);
540: l_entry_count NUMBER(15);
541:
542: cons_entity_wf_info gcs_cons_eng_utility_pkg.r_cons_entity_wf_info;
543: l_run_detail_id NUMBER(15);
544:
545: BEGIN
546:
550:
551: l_entity_id := WF_ENGINE.GetItemAttrNumber(itemtype, itemkey, 'CONS_ENTITY', FALSE);
552: l_run_identifier := WF_ENGINE.GetItemAttrText(itemtype, itemkey, 'RUN_IDENTIFIER', FALSE);
553:
554: gcs_cons_eng_utility_pkg.get_cons_entity_wf_info(itemtype, itemkey, cons_entity_wf_info);
555:
556: SELECT COUNT(entry_id)
557: INTO l_entry_count
558: FROM gcs_cons_eng_run_dtls
598: l_run_detail_id NUMBER(15);
599: x_errbuf VARCHAR2(200);
600: x_retcode VARCHAR2(200);
601:
602: cons_entity_wf_info gcs_cons_eng_utility_pkg.r_cons_entity_wf_info;
603: l_parameter_list gcs_cons_eng_utility_pkg.r_module_parameters;
604:
605: BEGIN
606:
599: x_errbuf VARCHAR2(200);
600: x_retcode VARCHAR2(200);
601:
602: cons_entity_wf_info gcs_cons_eng_utility_pkg.r_cons_entity_wf_info;
603: l_parameter_list gcs_cons_eng_utility_pkg.r_module_parameters;
604:
605: BEGIN
606:
607: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
608: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.EXECUTE_AGGREGATION', '<
609: END IF;
610:
611:
612: gcs_cons_eng_utility_pkg.get_cons_entity_wf_info(itemtype, itemkey, cons_entity_wf_info);
613:
614: BEGIN
615: SELECT cons_relationship_id
616: INTO l_cons_relationship_id
651: l_parameter_list.balance_type_code := cons_entity_wf_info.balance_type_code;
652: --Bugfix 5017120: Added support for additional data types
653: l_parameter_list.hierarchy_dataset_code := cons_entity_wf_info.hierarchy_dataset_code;
654:
655: gcs_cons_eng_utility_pkg.execute_module('AGGREGATION', l_parameter_list, itemkey);
656:
657: WF_ENGINE.SetItemAttrNumber(itemtype, itemkey, 'RUN_DETAIL_ID', l_run_detail_id);
658:
659: --Bugfix 4874306: Eliminate calls to XML Generation in order to leverage data templates
656:
657: WF_ENGINE.SetItemAttrNumber(itemtype, itemkey, 'RUN_DETAIL_ID', l_run_detail_id);
658:
659: --Bugfix 4874306: Eliminate calls to XML Generation in order to leverage data templates
660: --gcs_cons_eng_utility_pkg.submit_xml_ntf_program(
661: -- p_run_name => cons_entity_wf_info.run_identifier,
662: -- p_cons_entity_id => cons_entity_wf_info.consolidation_entity,
663: -- p_category_code => 'AGGREGATION',
664: -- p_run_detail_id => l_run_detail_id);
670: END IF;
671:
672: END execute_aggregation;
673:
674: PROCEDURE delete_flattened_relns(cons_entity_wf_info IN gcs_cons_eng_utility_pkg.r_cons_entity_wf_info)
675:
676: IS PRAGMA AUTONOMOUS_TRANSACTION;
677:
678: BEGIN
709: l_parent_entity_id NUMBER(15);
710: l_dependent_count NUMBER(15);
711: l_entry_id NUMBER(15);
712: l_stat_entry_id NUMBER(15);
713: cons_entity_wf_info gcs_cons_eng_utility_pkg.r_cons_entity_wf_info;
714: l_warning_exists VARCHAR2(1) := 'N';
715: l_status_code VARCHAR2(30);
716: l_run_detail_id NUMBER(15);
717: l_top_entity_id NUMBER;
720: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
721: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.RAISE_COMPLETION_EVENT', '<
722: END IF;
723:
724: gcs_cons_eng_utility_pkg.get_cons_entity_wf_info(itemtype, itemkey, cons_entity_wf_info);
725:
726:
727: BEGIN
728: SELECT 'Y'
840: END IF;
841:
842: END raise_completion_event;
843:
844: PROCEDURE create_flattened_relns(cons_entity_wf_info IN gcs_cons_eng_utility_pkg.r_cons_entity_wf_info,
845: cons_entity_id IN NUMBER)
846:
847: IS PRAGMA AUTONOMOUS_TRANSACTION;
848:
913: l_childkey_list t_childkey_list := t_childkey_list(NULL);
914: l_child_key VARCHAR2(200);
915: counter NUMBER(15) := 0;
916: l_entities_to_process BOOLEAN := FALSE;
917: cons_entity_wf_info gcs_cons_eng_utility_pkg.r_cons_entity_wf_info;
918:
919: CURSOR c_cons_entities (p_run_name IN VARCHAR2,
920: p_cons_entity_id IN NUMBER) IS
921: SELECT gcerd.child_entity_id,
952: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.SPAWN_CONS_ENTITY_PROCESS', '<
953: END IF;
954:
955:
956: gcs_cons_eng_utility_pkg.get_cons_entity_wf_info(itemtype, itemkey, cons_entity_wf_info);
957:
958: FOR v_cons_entity IN c_cons_entities(cons_entity_wf_info.run_identifier, cons_entity_wf_info.consolidation_entity)
959: LOOP
960:
1030: funcmode IN varchar2,
1031: result IN OUT NOCOPY varchar2)
1032:
1033: IS
1034: cons_entity_wf_info gcs_cons_eng_utility_pkg.r_cons_entity_wf_info;
1035: l_run_detail_id NUMBER(15);
1036:
1037: CURSOR c_categories_to_process IS
1038: SELECT cons_entity_wf_info.run_identifier,
1048: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
1049: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.INITIALIZE_CONS_PROCESS', '<
1050: END IF;
1051:
1052: gcs_cons_eng_utility_pkg.get_cons_entity_wf_info(itemtype, itemkey, cons_entity_wf_info);
1053:
1054: FOR v_categories_to_process IN c_categories_to_process LOOP
1055: gcs_cons_eng_run_dtls_pkg.insert_row(
1056: p_run_name => cons_entity_wf_info.run_identifier,
1075: result IN OUT NOCOPY varchar2)
1076:
1077: IS
1078:
1079: cons_entity_wf_info gcs_cons_eng_utility_pkg.r_cons_entity_wf_info;
1080: l_prior_run_name VARCHAR2(240);
1081: l_status_code VARCHAR2(30);
1082: l_locked_flag VARCHAR2(1);
1083: l_impacted_flag VARCHAr2(1);
1087: IF (FND_LOG.G_CURRENT_RUNTIME_LEVEL <= FND_LOG.LEVEL_PROCEDURE) THEN
1088: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.CHECK_CONS_ENTITY_STATUS', '<
1089: END IF;
1090:
1091: gcs_cons_eng_utility_pkg.get_cons_entity_wf_info(itemtype, itemkey, cons_entity_wf_info);
1092:
1093: SELECT run_name,
1094: status_code,
1095: locked_flag,
1139: p_run_entity_id => cons_entity_wf_info.consolidation_entity);
1140: result := 'COMPLETE:F';
1141: END check_cons_entity_status;
1142:
1143: PROCEDURE update_run_information( cons_entity_wf_info IN gcs_cons_eng_utility_pkg.r_cons_entity_wf_info,
1144: p_run_detail_id IN OUT NOCOPY NUMBER)
1145:
1146: IS PRAGMA AUTONOMOUS_TRANSACTION;
1147:
1230: result IN OUT NOCOPY varchar2)
1231:
1232: IS
1233:
1234: cons_entity_wf_info gcs_cons_eng_utility_pkg.r_cons_entity_wf_info;
1235: l_prior_run_name VARCHAR2(200);
1236: l_status_code VARCHAR2(30);
1237: l_run_detail_id NUMBER(15);
1238:
1242: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE, g_api || '.RETRIEVE_PRIOR_RUNS', '<
1243: END IF;
1244:
1245:
1246: gcs_cons_eng_utility_pkg.get_cons_entity_wf_info(itemtype, itemkey, cons_entity_wf_info);
1247:
1248: update_run_information(cons_entity_wf_info,
1249: l_run_detail_id);
1250: