[Home] [Help]
379:
380: -- Fix for Prev. Maint. performance bug# 5093064.
381: -- instead of calling procedure AHL_FMP_PVT.GET_MR_AFFECTED_ITEMS,
382: -- write PM effectivity logic in this procedure.
383: PROCEDURE Process_PM_MR_Affected_Items(p_commit IN VARCHAR2 := FND_API.G_FALSE,
384: x_msg_count OUT NOCOPY NUMBER,
385: x_msg_data OUT NOCOPY VARCHAR2,
386: x_return_status OUT NOCOPY VARCHAR2,
387: p_mr_header_id IN NUMBER,
645: -- Unit's Effectivity will be built for the input item instance.
646: --
647:
648: PROCEDURE Process_Unit (
649: p_commit IN VARCHAR2 := FND_API.G_FALSE,
650: p_init_msg_list IN VARCHAR2 := FND_API.G_FALSE,
651: x_msg_count OUT NOCOPY NUMBER,
652: x_msg_data OUT NOCOPY VARCHAR2,
653: x_return_status OUT NOCOPY VARCHAR2,
646: --
647:
648: PROCEDURE Process_Unit (
649: p_commit IN VARCHAR2 := FND_API.G_FALSE,
650: p_init_msg_list IN VARCHAR2 := FND_API.G_FALSE,
651: x_msg_count OUT NOCOPY NUMBER,
652: x_msg_data OUT NOCOPY VARCHAR2,
653: x_return_status OUT NOCOPY VARCHAR2,
654: p_csi_item_instance_id IN NUMBER,
684: -- Standard start of API savepoint
685: SAVEPOINT Process_Unit_PVT;
686:
687: -- Initialize message list if p_init_msg_list is set to TRUE
688: IF FND_API.To_Boolean(p_init_msg_list) THEN
689: FND_MSG_PUB.Initialize;
690: END IF;
691:
692: -- Initialize Procedure return status to success
689: FND_MSG_PUB.Initialize;
690: END IF;
691:
692: -- Initialize Procedure return status to success
693: x_return_status := FND_API.G_RET_STS_SUCCESS;
694:
695: -- Enable Debug.
696: IF G_DEBUG = 'Y' THEN
697: AHL_DEBUG_PUB.enable_debug;
734: Validate_item_instance(p_csi_item_instance_id, l_inventory_item_id,
735: l_inv_master_organization_id);
736:
737: IF FND_MSG_PUB.Count_msg > 0 THEN
738: RAISE FND_API.G_EXC_ERROR;
739: END IF;
740:
741: -- Log success message if called by concurrent program.
742: IF (p_concurrent_flag = 'Y') THEN
759: Validate_item_instance(l_csi_item_instance_id, l_inventory_item_id,
760: l_inv_master_organization_id, l_expired_flag);
761:
762: IF FND_MSG_PUB.Count_msg > 0 THEN
763: RAISE FND_API.G_EXC_ERROR;
764: END IF;
765:
766: -- Log success message if called by concurrent program.
767: IF (p_concurrent_flag = 'Y') THEN
776: G_UC_HEADER_ID := l_uc_header_id;
777:
778: -- Check for errors.
779: IF FND_MSG_PUB.Count_msg > 0 THEN
780: RAISE FND_API.G_EXC_ERROR;
781: END IF;
782:
783: -- Build the Configuration tree structure.(G_config_node_tbl).
784: Build_Config_Tree(l_csi_item_instance_id, G_master_config_id, G_CONFIG_NODE_TBL);
790: Validate_item_instance(p_csi_item_instance_id, l_inventory_item_id,
791: l_inv_master_organization_id, l_expired_flag);
792:
793: IF FND_MSG_PUB.Count_msg > 0 THEN
794: RAISE FND_API.G_EXC_ERROR;
795: END IF;
796:
797: -- Log success message if called by concurrent program.
798: IF (p_concurrent_flag = 'Y') THEN
835: x_return_status => x_return_status,
836: x_msg_count => x_msg_count,
837: x_msg_data => x_msg_data );
838:
839: IF (x_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
840: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
841: ELSIF (x_return_status = FND_API.G_RET_STS_ERROR) THEN
842: RAISE FND_API.G_EXC_ERROR;
843: END IF;
836: x_msg_count => x_msg_count,
837: x_msg_data => x_msg_data );
838:
839: IF (x_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
840: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
841: ELSIF (x_return_status = FND_API.G_RET_STS_ERROR) THEN
842: RAISE FND_API.G_EXC_ERROR;
843: END IF;
844:
837: x_msg_data => x_msg_data );
838:
839: IF (x_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
840: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
841: ELSIF (x_return_status = FND_API.G_RET_STS_ERROR) THEN
842: RAISE FND_API.G_EXC_ERROR;
843: END IF;
844:
845: -- Build applicability for group MRs.
838:
839: IF (x_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
840: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
841: ELSIF (x_return_status = FND_API.G_RET_STS_ERROR) THEN
842: RAISE FND_API.G_EXC_ERROR;
843: END IF;
844:
845: -- Build applicability for group MRs.
846: AHL_UMP_UTIL_PKG.Process_Group_MRs;
856: x_msg_count => x_msg_count,
857: x_msg_data => x_msg_data,
858: x_UnSch_programs_tbl => l_UnSch_programs_tbl);
859:
860: IF (x_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
861: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
862: ELSIF (x_return_status = FND_API.G_RET_STS_ERROR) THEN
863: RAISE FND_API.G_EXC_ERROR;
864: END IF;
857: x_msg_data => x_msg_data,
858: x_UnSch_programs_tbl => l_UnSch_programs_tbl);
859:
860: IF (x_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
861: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
862: ELSIF (x_return_status = FND_API.G_RET_STS_ERROR) THEN
863: RAISE FND_API.G_EXC_ERROR;
864: END IF;
865:
858: x_UnSch_programs_tbl => l_UnSch_programs_tbl);
859:
860: IF (x_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
861: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
862: ELSIF (x_return_status = FND_API.G_RET_STS_ERROR) THEN
863: RAISE FND_API.G_EXC_ERROR;
864: END IF;
865:
866: END IF; -- pm_install check.
859:
860: IF (x_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
861: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
862: ELSIF (x_return_status = FND_API.G_RET_STS_ERROR) THEN
863: RAISE FND_API.G_EXC_ERROR;
864: END IF;
865:
866: END IF; -- pm_install check.
867:
886:
887: IF (l_ret_code = -54) THEN
888: FND_MESSAGE.Set_Name('AHL','AHL_UMP_PUE_ALREADY_RUNNING');
889: FND_MSG_PUB.ADD;
890: RAISE FND_API.G_EXC_ERROR;
891: END IF;
892:
893: /*
894: -- Log success message if called by concurrent program.
920: END IF;
921:
922: -- Check for errors.
923: IF FND_MSG_PUB.Count_msg > 0 THEN
924: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
925: END IF;
926:
927: /* -- commented for performance fix - bug# 6893404
928: IF (G_IS_PM_INSTALLED = 'N') THEN
931: --call for material requirement forecst
932: AHL_UMP_FORECAST_REQ_PVT.process_mrl_req_forecast
933: (
934: p_api_version => 1.0,
935: p_init_msg_list => FND_API.G_TRUE,
936: p_commit => FND_API.G_FALSE,
937: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
938: x_return_status => x_return_status,
939: x_msg_count => x_msg_count,
932: AHL_UMP_FORECAST_REQ_PVT.process_mrl_req_forecast
933: (
934: p_api_version => 1.0,
935: p_init_msg_list => FND_API.G_TRUE,
936: p_commit => FND_API.G_FALSE,
937: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
938: x_return_status => x_return_status,
939: x_msg_count => x_msg_count,
940: x_msg_data => x_msg_data,
933: (
934: p_api_version => 1.0,
935: p_init_msg_list => FND_API.G_TRUE,
936: p_commit => FND_API.G_FALSE,
937: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
938: x_return_status => x_return_status,
939: x_msg_count => x_msg_count,
940: x_msg_data => x_msg_data,
941: p_applicable_instances_tbl => G_config_node_tbl
941: p_applicable_instances_tbl => G_config_node_tbl
942: );
943:
944: -- Check for errors.
945: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
946: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
947: END IF;
948:
949: END IF;
942: );
943:
944: -- Check for errors.
945: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
946: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
947: END IF;
948:
949: END IF;
950: */
949: END IF;
950: */
951:
952: -- Standard check of p_commit
953: IF FND_API.TO_BOOLEAN(p_commit) THEN
954: COMMIT WORK;
955: END IF;
956:
957: -- Log success message if called by concurrent program.
962: -- Standard call to get message count and if count is 1, get message info
963: FND_MSG_PUB.Count_And_Get
964: ( p_count => x_msg_count,
965: p_data => x_msg_data,
966: p_encoded => fnd_api.g_false
967: );
968:
969: --
970: EXCEPTION
967: );
968:
969: --
970: EXCEPTION
971: WHEN FND_API.G_EXC_ERROR THEN
972: x_return_status := FND_API.G_RET_STS_ERROR;
973: Rollback to Process_Unit_PVT;
974: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
975: p_data => x_msg_data,
968:
969: --
970: EXCEPTION
971: WHEN FND_API.G_EXC_ERROR THEN
972: x_return_status := FND_API.G_RET_STS_ERROR;
973: Rollback to Process_Unit_PVT;
974: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
975: p_data => x_msg_data,
976: p_encoded => fnd_api.g_false);
972: x_return_status := FND_API.G_RET_STS_ERROR;
973: Rollback to Process_Unit_PVT;
974: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
975: p_data => x_msg_data,
976: p_encoded => fnd_api.g_false);
977:
978: IF (p_concurrent_flag = 'Y') THEN
979:
980: fnd_file.put_line(fnd_file.log, 'Process Unit failed for item instance: '|| p_csi_item_instance_id);
983:
984: -- Disable debug
985: AHL_DEBUG_PUB.disable_debug;
986:
987: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
988: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
989: Rollback to Process_Unit_PVT;
990: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
991: p_data => x_msg_data,
984: -- Disable debug
985: AHL_DEBUG_PUB.disable_debug;
986:
987: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
988: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
989: Rollback to Process_Unit_PVT;
990: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
991: p_data => x_msg_data,
992: p_encoded => fnd_api.g_false);
988: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
989: Rollback to Process_Unit_PVT;
990: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
991: p_data => x_msg_data,
992: p_encoded => fnd_api.g_false);
993:
994: IF (p_concurrent_flag = 'Y') THEN
995: fnd_file.put_line(fnd_file.log, 'Process Unit failed for item instance: '|| p_csi_item_instance_id);
996: log_error_messages;
1000: AHL_DEBUG_PUB.disable_debug;
1001:
1002: WHEN OTHERS THEN
1003:
1004: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1005: Rollback to Process_Unit_PVT;
1006: IF FND_MSG_PUB.check_msg_level(FND_MSG_PUB.G_MSG_LVL_UNEXP_ERROR) THEN
1007: fnd_msg_pub.add_exc_msg(p_pkg_name => G_PKG_NAME,
1008: p_procedure_name => 'Process_Unit_PVT',
1009: p_error_text => SUBSTR(SQLERRM,1,240));
1010: END IF;
1011: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
1012: p_data => x_msg_data,
1013: p_encoded => fnd_api.g_false);
1014:
1015:
1016: IF (p_concurrent_flag = 'Y') THEN
1017: fnd_file.put_line(fnd_file.log, 'Process Unit failed for item instance: '|| p_csi_item_instance_id);
1042: -- and informational messages will be logged into the log file.
1043: --
1044:
1045: PROCEDURE Process_MRAffected_Units (
1046: p_commit IN VARCHAR2 := FND_API.G_FALSE,
1047: x_msg_count OUT NOCOPY NUMBER,
1048: x_msg_data OUT NOCOPY VARCHAR2,
1049: x_return_status OUT NOCOPY VARCHAR2,
1050: p_mr_header_id IN NUMBER,
1070:
1071: BEGIN
1072:
1073: -- Initialize Procedure return status to success
1074: x_return_status := FND_API.G_RET_STS_SUCCESS;
1075:
1076: -- Enable Debug.
1077: IF G_DEBUG = 'Y' THEN
1078: AHL_DEBUG_PUB.enable_debug;
1084: AHL_DEBUG_PUB.debug('Application Usage Profile:' || fnd_profile.value('AHL_APPLN_USAGE'));
1085: END IF;
1086:
1087: IF (p_concurrent_flag = 'Y') THEN
1088: l_commit := FND_API.G_TRUE;
1089: l_conc_request_id := fnd_global.conc_request_id;
1090: IF (l_conc_request_id = -1) OR (l_conc_request_id IS NULL) OR (l_conc_request_id <= 0) THEN
1091: -- this will happen only when called from UMP Terminate_MR_Instances api.
1092: l_conc_request_id := fnd_global.login_id;
1124: p_mtl_category_id => p_mtl_category_id,
1125: p_process_option => p_process_option,
1126: x_return_status => x_return_status);
1127:
1128: IF (x_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
1129: RETURN;
1130: END IF;
1131:
1132: IF (p_old_mr_header_id IS NOT NULL AND p_old_mr_header_id <> FND_API.G_MISS_NUM) THEN
1128: IF (x_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
1129: RETURN;
1130: END IF;
1131:
1132: IF (p_old_mr_header_id IS NOT NULL AND p_old_mr_header_id <> FND_API.G_MISS_NUM) THEN
1133: -- Call FMP API to get all items instances which have old mr_id in its applicability.
1134: Populate_BUE_Worker_for_MR(p_conc_request_id => l_conc_request_id,
1135: p_mr_header_id => p_old_mr_header_id,
1136: p_concurrent_flag => p_concurrent_flag,
1136: p_concurrent_flag => p_concurrent_flag,
1137: p_mtl_category_id => p_mtl_category_id,
1138: p_process_option => p_process_option,
1139: x_return_status => x_return_status);
1140: IF (x_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
1141: RETURN;
1142: END IF;
1143: END IF; -- p_old_mr_header_id I
1144:
1151: AHL_DEBUG_PUB.debug('Tried to submit concurrent request but failed');
1152: END IF;
1153: fnd_file.put_line(FND_FILE.LOG, 'Failed submit concurrent request');
1154: fnd_file.new_line(FND_FILE.LOG,1);
1155: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1156: EXIT; -- abort and return to calling pgm.
1157:
1158: ELSE
1159: fnd_file.put_line(FND_FILE.LOG, 'Concurrent request ID:' || l_req_id);
1168: Cleanup_BUE_Worker(p_parent_conc_request_id => l_conc_request_id,
1169: p_child_conc_request_id => NULL,
1170: x_return_status => l_return_status,
1171: x_errbuf => l_err_mesg);
1172: IF (l_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
1173: -- ignore error returned from this procedure
1174: -- log message in concurrent request log.
1175: fnd_file.put_line(FND_FILE.LOG, 'Warning: Error from Cleanup_BUE_Worker:' || l_err_mesg);
1176: END IF;
1177:
1178: ELSE
1179: LOOP
1180: -- initialize return status.
1181: x_return_status := FND_API.G_RET_STS_SUCCESS;
1182:
1183: -- process each unit from worker table.
1184: Get_Next_BUE_Row(p_parent_conc_pgm_id => l_conc_request_id,
1185: p_conc_child_req_id => l_conc_request_id,
1186: errbuf => x_msg_data,
1187: x_return_status => x_return_status,
1188: x_item_instance_id => l_instance_id);
1189:
1190: IF (x_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
1191: EXIT; -- abort and return to calling pgm.
1192: END IF;
1193:
1194: EXIT WHEN (l_instance_id IS NULL);
1199:
1200: -- Call Process Unit for the item instance.
1201: Process_Unit (
1202: p_commit => l_commit,
1203: p_init_msg_list => FND_API.G_TRUE,
1204: x_msg_count => x_msg_count,
1205: x_msg_data => x_msg_data,
1206: x_return_status => x_return_status,
1207: p_csi_item_instance_id => l_instance_id,
1206: x_return_status => x_return_status,
1207: p_csi_item_instance_id => l_instance_id,
1208: p_concurrent_flag => p_concurrent_flag);
1209:
1210: IF (x_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
1211: EXIT; -- abort and return to calling pgm.
1212: END IF;
1213:
1214: END LOOP;
1217: Cleanup_BUE_Worker(p_parent_conc_request_id => l_conc_request_id,
1218: p_child_conc_request_id => l_conc_request_id,
1219: x_return_status => l_return_status,
1220: x_errbuf => l_err_mesg);
1221: IF (l_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
1222: -- ignore error returned from this procedure
1223: IF G_DEBUG = 'Y' THEN
1224: AHL_DEBUG_PUB.debug('Warning: Error from Cleanup_BUE_Worker:' || l_err_mesg);
1225: END IF;
1249: -- The contract number modifier for above contract number
1250:
1251: PROCEDURE Process_PM_Contracts
1252: (
1253: p_commit IN VARCHAR2 := FND_API.G_FALSE,
1254: p_init_msg_list IN VARCHAR2 := FND_API.G_FALSE,
1255: x_msg_count OUT NOCOPY NUMBER,
1256: x_msg_data OUT NOCOPY VARCHAR2,
1257: x_return_status OUT NOCOPY VARCHAR2,
1250:
1251: PROCEDURE Process_PM_Contracts
1252: (
1253: p_commit IN VARCHAR2 := FND_API.G_FALSE,
1254: p_init_msg_list IN VARCHAR2 := FND_API.G_FALSE,
1255: x_msg_count OUT NOCOPY NUMBER,
1256: x_msg_data OUT NOCOPY VARCHAR2,
1257: x_return_status OUT NOCOPY VARCHAR2,
1258: p_contract_number IN VARCHAR2 := NULL,
1292: -- Standard start of API savepoint
1293: SAVEPOINT Process_PM_Contracts_PVT;
1294:
1295: -- Initialize message list if p_init_msg_list is set to TRUE
1296: IF FND_API.To_Boolean(p_init_msg_list) THEN
1297: FND_MSG_PUB.Initialize;
1298: END IF;
1299:
1300: -- Initialize Procedure return status to success
1297: FND_MSG_PUB.Initialize;
1298: END IF;
1299:
1300: -- Initialize Procedure return status to success
1301: x_return_status := FND_API.G_RET_STS_SUCCESS;
1302:
1303: -- Enable Debug.
1304: IF G_DEBUG = 'Y' THEN
1305: AHL_DEBUG_PUB.enable_debug;
1317:
1318: IF (p_concurrent_flag = 'Y') THEN
1319: fnd_file.put_line(fnd_file.log, 'Starting processing for contract Number '|| p_contract_number || ' and contract modifier' || p_contract_modifier);
1320: -- If the call is from concurrent program, then commit should default to TRUE
1321: l_commit := FND_API.G_TRUE;
1322: END IF;
1323:
1324: l_inp_cont_rec.contract_number := p_contract_number;
1325: l_inp_cont_rec.contract_number_modifier := p_contract_modifier;
1350:
1351: OKS_ENTITLEMENTS_PUB.get_contracts
1352: (
1353: p_api_version => 1.0,
1354: p_init_msg_list => FND_API.G_FALSE,
1355: p_inp_rec => l_inp_cont_rec,
1356: x_return_status => x_return_status,
1357: x_msg_count => x_msg_count,
1358: x_msg_data => x_msg_data,
1360: );
1361:
1362: -- Check Error Message stack.
1363: l_msg_count := FND_MSG_PUB.count_msg;
1364: IF (l_msg_count > 0 or x_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
1365: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
1366: END IF;
1367:
1368: IF (l_ent_cont_tbl.count > 0)
1361:
1362: -- Check Error Message stack.
1363: l_msg_count := FND_MSG_PUB.count_msg;
1364: IF (l_msg_count > 0 or x_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
1365: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
1366: END IF;
1367:
1368: IF (l_ent_cont_tbl.count > 0)
1369: THEN
1382: x_return_status => x_return_status,
1383: p_csi_item_instance_id => l_ent_cont_tbl(i).coverage_level_id,
1384: p_concurrent_flag => p_concurrent_flag
1385: );
1386: IF (p_concurrent_flag = 'Y' and (FND_MSG_PUB.count_msg > 0 or x_return_status <> FND_API.G_RET_STS_SUCCESS)) THEN
1387: fnd_file.put_line(fnd_file.log, 'Process_Unit failed for instance: ' || l_ent_cont_tbl(i).coverage_level_id);
1388: END IF;
1389: END IF;
1390: END LOOP;
1391: END IF;
1392:
1393: -- Check Error Message stack.
1394: l_msg_count := FND_MSG_PUB.count_msg;
1395: IF (l_msg_count > 0 or x_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
1396: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
1397: END IF;
1398:
1399: -- Standard check of p_commit
1392:
1393: -- Check Error Message stack.
1394: l_msg_count := FND_MSG_PUB.count_msg;
1395: IF (l_msg_count > 0 or x_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
1396: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
1397: END IF;
1398:
1399: -- Standard check of p_commit
1400: IF FND_API.TO_BOOLEAN(p_commit) THEN
1396: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
1397: END IF;
1398:
1399: -- Standard check of p_commit
1400: IF FND_API.TO_BOOLEAN(p_commit) THEN
1401: COMMIT WORK;
1402: END IF;
1403:
1404: -- Log success message if called by concurrent program.
1410: FND_MSG_PUB.Count_And_Get
1411: (
1412: p_count => x_msg_count,
1413: p_data => x_msg_data,
1414: p_encoded => fnd_api.g_false
1415: );
1416:
1417: EXCEPTION
1418: WHEN FND_API.G_EXC_ERROR THEN
1414: p_encoded => fnd_api.g_false
1415: );
1416:
1417: EXCEPTION
1418: WHEN FND_API.G_EXC_ERROR THEN
1419: x_return_status := FND_API.G_RET_STS_ERROR;
1420: Rollback to Process_PM_Contracts_PVT;
1421: FND_MSG_PUB.count_and_get
1422: (
1415: );
1416:
1417: EXCEPTION
1418: WHEN FND_API.G_EXC_ERROR THEN
1419: x_return_status := FND_API.G_RET_STS_ERROR;
1420: Rollback to Process_PM_Contracts_PVT;
1421: FND_MSG_PUB.count_and_get
1422: (
1423: p_count => x_msg_count,
1421: FND_MSG_PUB.count_and_get
1422: (
1423: p_count => x_msg_count,
1424: p_data => x_msg_data,
1425: p_encoded => fnd_api.g_false
1426: );
1427: IF (p_concurrent_flag = 'Y') THEN
1428: fnd_file.put_line(fnd_file.log, 'Process_PM_Contracts failed for: contract Number '|| p_contract_number || ' and contract modifier' || p_contract_modifier);
1429: log_error_messages;
1429: log_error_messages;
1430: END IF;
1431: AHL_DEBUG_PUB.disable_debug;
1432:
1433: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
1434: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1435: Rollback to Process_PM_Contracts_PVT;
1436: FND_MSG_PUB.count_and_get
1437: (
1430: END IF;
1431: AHL_DEBUG_PUB.disable_debug;
1432:
1433: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
1434: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1435: Rollback to Process_PM_Contracts_PVT;
1436: FND_MSG_PUB.count_and_get
1437: (
1438: p_count => x_msg_count,
1436: FND_MSG_PUB.count_and_get
1437: (
1438: p_count => x_msg_count,
1439: p_data => x_msg_data,
1440: p_encoded => fnd_api.g_false
1441: );
1442: IF (p_concurrent_flag = 'Y') THEN
1443: fnd_file.put_line(fnd_file.log, 'Process_PM_Contracts failed for: contract Number '|| p_contract_number || ' and contract modifier' || p_contract_modifier);
1444: log_error_messages;
1445: END IF;
1446: AHL_DEBUG_PUB.disable_debug;
1447:
1448: WHEN OTHERS THEN
1449: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1450: Rollback to Process_PM_Contracts_PVT;
1451: IF FND_MSG_PUB.check_msg_level(FND_MSG_PUB.G_MSG_LVL_UNEXP_ERROR) THEN
1452: fnd_msg_pub.add_exc_msg
1453: (
1459: FND_MSG_PUB.count_and_get
1460: (
1461: p_count => x_msg_count,
1462: p_data => x_msg_data,
1463: p_encoded => fnd_api.g_false
1464: );
1465: IF (p_concurrent_flag = 'Y') THEN
1466: fnd_file.put_line(fnd_file.log, 'Process_PM_Contracts failed for: contract Number '|| p_contract_number || ' and contract modifier' || p_contract_modifier);
1467: log_error_messages;
1482: -- This flag will be 'Y' if called from a concurrent program. Based on this flag, the error
1483: -- and informational messages will be logged into the log file by Process_Unit.
1484:
1485: PROCEDURE Process_All_Units (
1486: p_commit IN VARCHAR2 := FND_API.G_FALSE,
1487: x_msg_count OUT NOCOPY NUMBER,
1488: x_msg_data OUT NOCOPY VARCHAR2,
1489: x_return_status OUT NOCOPY VARCHAR2,
1490: p_concurrent_flag IN VARCHAR2 := 'N',
1517:
1518: BEGIN
1519:
1520: -- Initialize Procedure return status to success
1521: x_return_status := FND_API.G_RET_STS_SUCCESS;
1522:
1523: -- Enable Debug.
1524: -- Add api start debug mesg.
1525: IF G_DEBUG = 'Y' THEN
1528: END IF;
1529:
1530: -- For concurrent program.
1531: IF (p_concurrent_flag = 'Y') THEN
1532: l_commit := FND_API.G_TRUE;
1533: END IF;
1534:
1535: -- JKJain, NR Analysis and Forecasting
1536: IF(p_simulation_plan_id IS NULL) THEN
1564: x_msg_count => x_msg_count,
1565: x_msg_data => x_msg_data,
1566: x_return_status => x_return_status);
1567:
1568: IF (x_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
1569: RETURN;
1570: END IF;
1571:
1572: ELSE
1623: FND_MESSAGE.Set_Token('INST_ID', p_csi_item_instance_id);
1624: FND_MSG_PUB.ADD;
1625: CLOSE csi_item_instances_csr;
1626: --dbms_output.put_line('Instance not found');
1627: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
1628: ELSIF l_active_end_date <= sysdate THEN
1629: /* Bypass error to fix bug# 8567880. For expired
1630: instances we will delete open UMPs.
1631: FND_MESSAGE.Set_Name('AHL','AHL_UMP_PUE_INST_EXPIRED');
2118: x_uf_details_tbl => l_uf_details_tbl,
2119: x_return_status => l_return_status);
2120: /* This will give forecast defined item/pc_node level. */
2121:
2122: IF (l_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
2123: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
2124: ELSIF (l_return_status = FND_API.G_RET_STS_ERROR) THEN
2125: RAISE FND_API.G_EXC_ERROR;
2126: END IF;
2119: x_return_status => l_return_status);
2120: /* This will give forecast defined item/pc_node level. */
2121:
2122: IF (l_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
2123: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
2124: ELSIF (l_return_status = FND_API.G_RET_STS_ERROR) THEN
2125: RAISE FND_API.G_EXC_ERROR;
2126: END IF;
2127:
2120: /* This will give forecast defined item/pc_node level. */
2121:
2122: IF (l_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
2123: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
2124: ELSIF (l_return_status = FND_API.G_RET_STS_ERROR) THEN
2125: RAISE FND_API.G_EXC_ERROR;
2126: END IF;
2127:
2128: -- populate l_forecast_details_tbl based on l_uf_details_tbl.
2121:
2122: IF (l_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
2123: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
2124: ELSIF (l_return_status = FND_API.G_RET_STS_ERROR) THEN
2125: RAISE FND_API.G_EXC_ERROR;
2126: END IF;
2127:
2128: -- populate l_forecast_details_tbl based on l_uf_details_tbl.
2129: IF (l_uf_details_tbl.COUNT) > 0 THEN
2173: p_onward_end_date => trunc(sysdate),
2174: x_uf_details_tbl => l_uf_details_tbl,
2175: x_return_status => l_return_status);
2176:
2177: IF (l_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
2178: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
2179: ELSIF (l_return_status = FND_API.G_RET_STS_ERROR) THEN
2180: RAISE FND_API.G_EXC_ERROR;
2181: END IF;
2174: x_uf_details_tbl => l_uf_details_tbl,
2175: x_return_status => l_return_status);
2176:
2177: IF (l_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
2178: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
2179: ELSIF (l_return_status = FND_API.G_RET_STS_ERROR) THEN
2180: RAISE FND_API.G_EXC_ERROR;
2181: END IF;
2182:
2175: x_return_status => l_return_status);
2176:
2177: IF (l_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
2178: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
2179: ELSIF (l_return_status = FND_API.G_RET_STS_ERROR) THEN
2180: RAISE FND_API.G_EXC_ERROR;
2181: END IF;
2182:
2183: -- Bug# 6749351:Removed duplicate check which is now taken care by get_uf_from_pc.
2176:
2177: IF (l_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
2178: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
2179: ELSIF (l_return_status = FND_API.G_RET_STS_ERROR) THEN
2180: RAISE FND_API.G_EXC_ERROR;
2181: END IF;
2182:
2183: -- Bug# 6749351:Removed duplicate check which is now taken care by get_uf_from_pc.
2184: IF (l_uf_details_tbl.count > 0) THEN
2634: WHEN OTHERS THEN
2635: IF (SQLCODE = -54) THEN
2636: --FND_MESSAGE.Set_Name('AHL','AHL_UMP_PUE_ALREADY_RUNNING');
2637: --FND_MSG_PUB.ADD;
2638: --RAISE FND_API.G_EXC_ERROR;
2639: x_ret_code := '-54';
2640: ELSE
2641: IF FND_MSG_PUB.check_msg_level(FND_MSG_PUB.G_MSG_LVL_UNEXP_ERROR) THEN
2642: fnd_msg_pub.add_exc_msg(p_pkg_name => G_PKG_NAME,
2642: fnd_msg_pub.add_exc_msg(p_pkg_name => G_PKG_NAME,
2643: p_procedure_name => 'Lock_UnitEffectivity_Records',
2644: p_error_text => SUBSTR(SQLERRM,1,240));
2645: END IF;
2646: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
2647: END IF;
2648:
2649: END Lock_UnitEffectivity_Records;
2650:
7521: FND_MESSAGE.Set_Token('UE_ID',l_ue_relns_rec.ue_id);
7522: FND_MESSAGE.Set_Token('RELATED_UE_ID', l_ue_relns_rec.related_ue_id);
7523: FND_MSG_PUB.ADD;
7524: CLOSE ahl_ue_csr;
7525: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
7526: END IF;
7527: --dbms_output.put_line ('found ue relns');
7528:
7529: l_ue_details_tbl(i).match_flag := 'N';
8138:
8139: FOR i IN 1..l_msg_count LOOP
8140: FND_MSG_PUB.get (
8141: p_msg_index => i,
8142: p_encoded => FND_API.G_FALSE,
8143: p_data => l_msg_data,
8144: p_msg_index_out => l_msg_index_out );
8145:
8146: fnd_file.put_line(FND_FILE.LOG, 'Err message-'||l_msg_index_out||':' || l_msg_data);
8196:
8197: -- call api to fetch all applicable mrs for PM installation.
8198: AHL_FMP_PVT.get_pm_applicable_mrs(
8199: p_api_version => l_api_version,
8200: p_init_msg_list => FND_API.G_FALSE,
8201: p_commit => FND_API.G_FALSE,
8202: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
8203: x_return_status => x_return_status,
8204: x_msg_count => x_msg_count,
8197: -- call api to fetch all applicable mrs for PM installation.
8198: AHL_FMP_PVT.get_pm_applicable_mrs(
8199: p_api_version => l_api_version,
8200: p_init_msg_list => FND_API.G_FALSE,
8201: p_commit => FND_API.G_FALSE,
8202: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
8203: x_return_status => x_return_status,
8204: x_msg_count => x_msg_count,
8205: x_msg_data => x_msg_data,
8198: AHL_FMP_PVT.get_pm_applicable_mrs(
8199: p_api_version => l_api_version,
8200: p_init_msg_list => FND_API.G_FALSE,
8201: p_commit => FND_API.G_FALSE,
8202: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
8203: x_return_status => x_return_status,
8204: x_msg_count => x_msg_count,
8205: x_msg_data => x_msg_data,
8206: p_item_instance_id => p_csi_ii_id,
8208: x_applicable_programs_tbl => l_appl_programs_tbl);
8209:
8210:
8211: -- Raise errors if exceptions occur
8212: IF (x_return_status = FND_API.G_RET_STS_ERROR) THEN
8213: RAISE FND_API.G_EXC_ERROR;
8214: ELSIF (x_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
8215: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
8216: END IF;
8209:
8210:
8211: -- Raise errors if exceptions occur
8212: IF (x_return_status = FND_API.G_RET_STS_ERROR) THEN
8213: RAISE FND_API.G_EXC_ERROR;
8214: ELSIF (x_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
8215: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
8216: END IF;
8217:
8210:
8211: -- Raise errors if exceptions occur
8212: IF (x_return_status = FND_API.G_RET_STS_ERROR) THEN
8213: RAISE FND_API.G_EXC_ERROR;
8214: ELSIF (x_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
8215: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
8216: END IF;
8217:
8218: -- initialize.
8211: -- Raise errors if exceptions occur
8212: IF (x_return_status = FND_API.G_RET_STS_ERROR) THEN
8213: RAISE FND_API.G_EXC_ERROR;
8214: ELSIF (x_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
8215: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
8216: END IF;
8217:
8218: -- initialize.
8219: l_pgm_index := 0;
8759: FND_MESSAGE.Set_Name('AHL','AHL_UMP_PUE_PMPROGRAM_NOTFOUND');
8760: FND_MESSAGE.Set_Token('PMPROGRAM',sch_activity_rec.mr_header_id);
8761: FND_MSG_PUB.ADD;
8762: CLOSE ahl_cont_scheduled_csr;
8763: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
8764: END IF;
8765:
8766: -- check for existence of accomplishments.
8767:
8840: x_msg_count => l_msg_count,
8841: x_msg_data => l_msg_data,
8842: x_pm_schedule => l_pm_schedule_tbl);
8843:
8844: IF (l_return_status = FND_API.G_RET_STS_ERROR) THEN
8845: RAISE FND_API.G_EXC_ERROR;
8846: ELSIF (l_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
8847: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
8848: END IF;
8841: x_msg_data => l_msg_data,
8842: x_pm_schedule => l_pm_schedule_tbl);
8843:
8844: IF (l_return_status = FND_API.G_RET_STS_ERROR) THEN
8845: RAISE FND_API.G_EXC_ERROR;
8846: ELSIF (l_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
8847: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
8848: END IF;
8849:
8842: x_pm_schedule => l_pm_schedule_tbl);
8843:
8844: IF (l_return_status = FND_API.G_RET_STS_ERROR) THEN
8845: RAISE FND_API.G_EXC_ERROR;
8846: ELSIF (l_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
8847: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
8848: END IF;
8849:
8850: IF G_DEBUG = 'Y' THEN
8843:
8844: IF (l_return_status = FND_API.G_RET_STS_ERROR) THEN
8845: RAISE FND_API.G_EXC_ERROR;
8846: ELSIF (l_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
8847: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
8848: END IF;
8849:
8850: IF G_DEBUG = 'Y' THEN
8851: AHL_DEBUG_PUB.debug('Service Line ID: ' || l_inp_sch_rec.service_line_id);
8876: l_due_date := NULL;
8877: l_temp_unit_effectivity_rec := l_temp_ue_initrec;
8878:
8879: IF (l_pm_schedule_tbl(i).schedule_on IS NOT NULL) AND
8880: (l_pm_schedule_tbl(i).schedule_on <> FND_API.G_MISS_DATE) THEN
8881: l_due_date := l_pm_schedule_tbl(i).schedule_on;
8882: ELSIF (l_pm_schedule_tbl(i).schedule_to IS NOT NULL) AND
8883: (l_pm_schedule_tbl(i).schedule_to <> FND_API.G_MISS_DATE) THEN
8884: l_due_date := l_pm_schedule_tbl(i).schedule_to;
8879: IF (l_pm_schedule_tbl(i).schedule_on IS NOT NULL) AND
8880: (l_pm_schedule_tbl(i).schedule_on <> FND_API.G_MISS_DATE) THEN
8881: l_due_date := l_pm_schedule_tbl(i).schedule_on;
8882: ELSIF (l_pm_schedule_tbl(i).schedule_to IS NOT NULL) AND
8883: (l_pm_schedule_tbl(i).schedule_to <> FND_API.G_MISS_DATE) THEN
8884: l_due_date := l_pm_schedule_tbl(i).schedule_to;
8885: END IF;
8886:
8887: -- write into temporary table if due date is not null.
8894: l_temp_unit_effectivity_rec.program_mr_header_id := sch_activity_rec.program_mr_header_id;
8895: l_temp_unit_effectivity_rec.service_line_id := sch_activity_rec.service_line_id;
8896: -- Added for ER# 2636001.
8897: IF (l_pm_schedule_tbl(i).schedule_from IS NOT NULL AND
8898: l_pm_schedule_tbl(i).schedule_from <> FND_API.G_MISS_DATE) THEN
8899: l_temp_unit_effectivity_rec.earliest_due_date := l_pm_schedule_tbl(i).schedule_from;
8900: END IF;
8901: IF (l_pm_schedule_tbl(i).schedule_to IS NOT NULL AND
8902: l_pm_schedule_tbl(i).schedule_to <> FND_API.G_MISS_DATE) THEN
8898: l_pm_schedule_tbl(i).schedule_from <> FND_API.G_MISS_DATE) THEN
8899: l_temp_unit_effectivity_rec.earliest_due_date := l_pm_schedule_tbl(i).schedule_from;
8900: END IF;
8901: IF (l_pm_schedule_tbl(i).schedule_to IS NOT NULL AND
8902: l_pm_schedule_tbl(i).schedule_to <> FND_API.G_MISS_DATE) THEN
8903: l_temp_unit_effectivity_rec.latest_due_date := l_pm_schedule_tbl(i).schedule_to;
8904: END IF;
8905:
8906: -- increment forecast sequence.
9653:
9654: BEGIN
9655:
9656: -- Set return status.
9657: x_return_status := FND_API.G_RET_STS_SUCCESS;
9658:
9659: -- Enable Debug.
9660: IF G_DEBUG = 'Y' THEN
9661: AHL_DEBUG_PUB.enable_debug;
9669: AHL_DEBUG_PUB.debug('Count on p_deferral_threshold_tbl:' || p_deferral_threshold_tbl.COUNT);
9670: END IF;
9671:
9672: -- Validate input parameters.
9673: IF (p_unit_effectivity_id IS NULL OR p_unit_effectivity_id = FND_API.G_MISS_NUM) THEN
9674: FND_MESSAGE.Set_Name('AHL','AHL_UMP_DEF_UE_NULL');
9675: FND_MSG_PUB.ADD;
9676: RAISE FND_API.G_EXC_ERROR;
9677: ELSE
9672: -- Validate input parameters.
9673: IF (p_unit_effectivity_id IS NULL OR p_unit_effectivity_id = FND_API.G_MISS_NUM) THEN
9674: FND_MESSAGE.Set_Name('AHL','AHL_UMP_DEF_UE_NULL');
9675: FND_MSG_PUB.ADD;
9676: RAISE FND_API.G_EXC_ERROR;
9677: ELSE
9678: OPEN ahl_unit_effectivity_csr (p_unit_effectivity_id);
9679: FETCH ahl_unit_effectivity_csr INTO l_csi_item_instance_id, l_mr_header_id,
9680: l_inventory_item_id, l_inv_master_organization_id;
9681: IF (ahl_unit_effectivity_csr%NOTFOUND) THEN
9682: FND_MESSAGE.Set_Name('AHL','AHL_UMP_DEF_UE_INVALID');
9683: FND_MESSAGE.Set_Token('UE_ID', p_unit_effectivity_id);
9684: FND_MSG_PUB.ADD;
9685: RAISE FND_API.G_EXC_ERROR;
9686: END IF;
9687: END IF;
9688:
9689: IF (l_mr_header_id IS NOT NULL) THEN
9693: IF (ahl_mr_headers_csr%NOTFOUND) THEN
9694: FND_MESSAGE.Set_Name('AHL','AHL_UMP_DEF_MR_INVALID');
9695: FND_MESSAGE.Set_Token('UE_ID', p_unit_effectivity_id);
9696: FND_MSG_PUB.ADD;
9697: RAISE FND_API.G_EXC_ERROR;
9698: END IF;
9699: CLOSE ahl_mr_headers_csr;
9700: ELSE
9701: -- SR case.
9723: END IF;
9724:
9725: -- Check for errors.
9726: IF FND_MSG_PUB.Count_msg > 0 THEN
9727: RAISE FND_API.G_EXC_ERROR;
9728: END IF;
9729:
9730: IF G_DEBUG = 'Y' THEN
9731: AHL_DEBUG_PUB.debug('Step 3');
9823: -- Standard call to get message count and if count is 1, get message info
9824: FND_MSG_PUB.Count_And_Get
9825: ( p_count => x_msg_count,
9826: p_data => x_msg_data,
9827: p_encoded => fnd_api.g_false
9828: );
9829:
9830: --
9831: EXCEPTION
9828: );
9829:
9830: --
9831: EXCEPTION
9832: WHEN FND_API.G_EXC_ERROR THEN
9833: x_return_status := FND_API.G_RET_STS_ERROR;
9834: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
9835: p_data => x_msg_data,
9836: p_encoded => fnd_api.g_false);
9829:
9830: --
9831: EXCEPTION
9832: WHEN FND_API.G_EXC_ERROR THEN
9833: x_return_status := FND_API.G_RET_STS_ERROR;
9834: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
9835: p_data => x_msg_data,
9836: p_encoded => fnd_api.g_false);
9837:
9832: WHEN FND_API.G_EXC_ERROR THEN
9833: x_return_status := FND_API.G_RET_STS_ERROR;
9834: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
9835: p_data => x_msg_data,
9836: p_encoded => fnd_api.g_false);
9837:
9838: -- Disable debug
9839: AHL_DEBUG_PUB.disable_debug;
9840:
9837:
9838: -- Disable debug
9839: AHL_DEBUG_PUB.disable_debug;
9840:
9841: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
9842: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
9843: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
9844: p_data => x_msg_data,
9845: p_encoded => fnd_api.g_false);
9838: -- Disable debug
9839: AHL_DEBUG_PUB.disable_debug;
9840:
9841: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
9842: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
9843: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
9844: p_data => x_msg_data,
9845: p_encoded => fnd_api.g_false);
9846:
9841: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
9842: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
9843: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
9844: p_data => x_msg_data,
9845: p_encoded => fnd_api.g_false);
9846:
9847: -- Disable debug
9848: AHL_DEBUG_PUB.disable_debug;
9849:
9848: AHL_DEBUG_PUB.disable_debug;
9849:
9850: WHEN OTHERS THEN
9851:
9852: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
9853: IF FND_MSG_PUB.check_msg_level(FND_MSG_PUB.G_MSG_LVL_UNEXP_ERROR) THEN
9854: fnd_msg_pub.add_exc_msg(p_pkg_name => G_PKG_NAME,
9855: p_procedure_name => 'Get_Deferred_Due_Date',
9856: p_error_text => SUBSTR(SQLERRM,1,240));
9856: p_error_text => SUBSTR(SQLERRM,1,240));
9857: END IF;
9858: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
9859: p_data => x_msg_data,
9860: p_encoded => fnd_api.g_false);
9861:
9862:
9863: -- Disable debug
9864: AHL_DEBUG_PUB.disable_debug;
10218: CLOSE ahl_unit_deferral_csr;
10219: FND_MESSAGE.Set_Name('AHL','AHL_UMP_DEF_NOTFOUND');
10220: FND_MESSAGE.Set_Token('UE_ID',unit_effectivity_rec.defer_from_ue_id);
10221: FND_MSG_PUB.ADD;
10222: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
10223: END IF;
10224:
10225: CLOSE ahl_unit_deferral_csr;
10226: */
10377: --l_calc_due_date := NULL;
10378: FND_MESSAGE.Set_Name('AHL','AHL_PUE_INCIDENT_ID_MISSING');
10379: FND_MESSAGE.Set_Token('CS_INC_ID',unit_effectivity_rec.cs_incident_id);
10380: FND_MSG_PUB.ADD;
10381: RAISE FND_API.G_EXC_ERROR;
10382: ELSE
10383:
10384: IF l_repair_time <> 0 AND
10385: unit_effectivity_rec.DEFERRAL_EFFECTIVE_ON IS NOT NULL
10913: FND_MESSAGE.Set_Name('AHL','AHL_UMP_PUE_RELN_NOTFOUND');
10914: FND_MESSAGE.Set_Token('UE_ID',ahl_ue_relns_rec.ue_id);
10915: FND_MESSAGE.Set_Token('RELATED_UE_ID', ahl_ue_relns_rec.related_ue_id);
10916: FND_MSG_PUB.ADD;
10917: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
10918: END IF;
10919:
10920: l_ue_details_tbl(i).level := ahl_ue_relns_rec.level;
10921: l_ue_details_tbl(i).unit_effectivity_id := ahl_ue_relns_rec.related_ue_id;
11197: FND_MESSAGE.Set_Token('UE_ID',l_ue_rec.unit_effectivity_id);
11198: FND_MSG_PUB.ADD;
11199: -- dbms_output.put_line('unit effectivity not found for ue id' ||l_ue_rec.unit_effectivity_id );
11200: ClOSE ahl_unit_effectivity_csr;
11201: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
11202: ELSE
11203: -- set UE attributes.
11204: IF (ahl_unplanned_ue_rec.status_code IS NULL) AND (l_exception_flag = TRUE) THEN
11205: IF G_DEBUG = 'Y' THEN
11347: FND_MESSAGE.Set_Token('UE_ID',l_ue_rec.unit_effectivity_id);
11348: FND_MSG_PUB.ADD;
11349: -- dbms_output.put_line('descendent mr not found for ue id');
11350: ClOSE ahl_unit_effectivity_csr;
11351: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
11352: END IF;
11353: ClOSE ahl_unit_effectivity_csr;
11354: END LOOP; -- decendent_csr
11355:
11406: PROCEDURE Get_Forecasted_Counter_Values(
11407: x_return_status OUT NOCOPY VARCHAR2,
11408: x_msg_data OUT NOCOPY VARCHAR2,
11409: x_msg_count OUT NOCOPY NUMBER,
11410: p_init_msg_list IN VARCHAR2 := FND_API.G_FALSE,
11411: p_csi_item_instance_id IN NUMBER, -- Instance Id
11412: p_forecasted_date IN DATE,
11413: x_counter_values_tbl OUT NOCOPY counter_values_tbl_type) -- Forecasted Counter Vals.
11414: IS
11437: AHL_DEBUG_PUB.Debug('Start API Get_Forecasted_Counter_Values');
11438: END IF;
11439:
11440: -- Initialize message list if p_init_msg_list is set to TRUE
11441: IF FND_API.To_Boolean(p_init_msg_list) THEN
11442: FND_MSG_PUB.Initialize;
11443: END IF;
11444:
11445: -- Initialize Procedure return status to success
11442: FND_MSG_PUB.Initialize;
11443: END IF;
11444:
11445: -- Initialize Procedure return status to success
11446: x_return_status := FND_API.G_RET_STS_SUCCESS;
11447:
11448: -- Enable Debug.
11449: IF G_DEBUG = 'Y' THEN
11450: AHL_DEBUG_PUB.enable_debug;
11472: --dbms_output.put_line('Instance has expired');
11473: END IF;
11474:
11475: IF FND_MSG_PUB.Count_msg > 0 THEN
11476: RAISE FND_API.G_EXC_ERROR;
11477: END IF;
11478:
11479: -- set instance variable.
11480: l_csi_item_instance_id := p_csi_item_instance_id;
11489: l_uc_header_id, G_master_config_id);
11490:
11491: -- Check for errors.
11492: IF FND_MSG_PUB.Count_msg > 0 THEN
11493: RAISE FND_API.G_EXC_ERROR;
11494: END IF;
11495:
11496: -- Build the Configuration tree structure.(G_config_node_tbl).
11497: Build_Config_Tree(l_csi_item_instance_id, G_master_config_id, G_CONFIG_NODE_TBL);
11550: END IF; -- count.
11551: END IF; -- Debug = Y
11552:
11553: IF NOT(l_return_value) THEN
11554: RAISE FND_API.G_EXC_ERROR; /* no forecast available */
11555: ELSE
11556: x_counter_values_tbl := l_due_at_counter_val_tbl;
11557: END IF;
11558:
11559: -- Standard call to get message count and if count is 1, get message info
11560: FND_MSG_PUB.Count_And_Get
11561: ( p_count => x_msg_count,
11562: p_data => x_msg_data,
11563: p_encoded => fnd_api.g_false
11564: );
11565:
11566: IF G_DEBUG = 'Y' THEN
11567: AHL_DEBUG_PUB.Debug('End API Get_Forecasted_Counter_Values');
11568: END IF;
11569:
11570: --
11571: EXCEPTION
11572: WHEN FND_API.G_EXC_ERROR THEN
11573: x_return_status := FND_API.G_RET_STS_ERROR;
11574: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
11575: p_data => x_msg_data,
11576: p_encoded => fnd_api.g_false);
11569:
11570: --
11571: EXCEPTION
11572: WHEN FND_API.G_EXC_ERROR THEN
11573: x_return_status := FND_API.G_RET_STS_ERROR;
11574: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
11575: p_data => x_msg_data,
11576: p_encoded => fnd_api.g_false);
11577:
11572: WHEN FND_API.G_EXC_ERROR THEN
11573: x_return_status := FND_API.G_RET_STS_ERROR;
11574: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
11575: p_data => x_msg_data,
11576: p_encoded => fnd_api.g_false);
11577:
11578: -- Disable debug
11579: AHL_DEBUG_PUB.disable_debug;
11580:
11577:
11578: -- Disable debug
11579: AHL_DEBUG_PUB.disable_debug;
11580:
11581: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
11582: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
11583: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
11584: p_data => x_msg_data,
11585: p_encoded => fnd_api.g_false);
11578: -- Disable debug
11579: AHL_DEBUG_PUB.disable_debug;
11580:
11581: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
11582: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
11583: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
11584: p_data => x_msg_data,
11585: p_encoded => fnd_api.g_false);
11586:
11581: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
11582: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
11583: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
11584: p_data => x_msg_data,
11585: p_encoded => fnd_api.g_false);
11586:
11587: -- Disable debug
11588: AHL_DEBUG_PUB.disable_debug;
11589:
11587: -- Disable debug
11588: AHL_DEBUG_PUB.disable_debug;
11589:
11590: WHEN OTHERS THEN
11591: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
11592: IF FND_MSG_PUB.check_msg_level(FND_MSG_PUB.G_MSG_LVL_UNEXP_ERROR) THEN
11593: fnd_msg_pub.add_exc_msg(p_pkg_name => G_PKG_NAME,
11594: p_procedure_name => 'Get_Forecasted_Counter_Values',
11595: p_error_text => SUBSTR(SQLERRM,1,240));
11595: p_error_text => SUBSTR(SQLERRM,1,240));
11596: END IF;
11597: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
11598: p_data => x_msg_data,
11599: p_encoded => fnd_api.g_false);
11600:
11601: -- Disable debug
11602: AHL_DEBUG_PUB.disable_debug;
11603:
11756: -- Added procedure to replace call to ahl_fmp_pvt.get_mr_affected_items for Prev. Maint
11757: -- Called when processing based on MR invoked through concurrent program.
11758: -- Perf fix for bug# 5093064.
11759: PROCEDURE Process_PM_MR_Affected_Items(
11760: p_commit IN VARCHAR2 := FND_API.G_FALSE,
11761: x_msg_count OUT NOCOPY NUMBER,
11762: x_msg_data OUT NOCOPY VARCHAR2,
11763: x_return_status OUT NOCOPY VARCHAR2,
11764: p_mr_header_id IN NUMBER,
11854: IF check_mr_exists%NOTFOUND THEN
11855: CLOSE check_mr_exists;
11856: FND_MESSAGE.SET_NAME('AHL','AHL_FMP_INVALID_MR');
11857: FND_MSG_PUB.ADD;
11858: RAISE FND_API.G_EXC_ERROR;
11859: END IF;
11860: CLOSE check_mr_exists;
11861:
11862: IF l_debug = 'Y' THEN
11901: FND_MESSAGE.Set_Token('INV_ID',l_mr_effect.inventory_item_id);
11902: FND_MSG_PUB.ADD;
11903: --DBMS_OUTPUT.put_line('Master org not found for inventory item:' || l_mr_effect.inventory_item_id);
11904: ClOSE get_master_org_id_csr;
11905: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
11906: END IF;
11907: CLOSE get_master_org_id_csr;
11908:
11909: OPEN get_minmax_inst_csr(l_mr_effect.inventory_item_id,l_master_org_id);
11956:
11957: FOR i IN l_csi_inst_tbl.FIRST..l_csi_inst_tbl.LAST LOOP
11958: -- Call Process Unit for the item instance.
11959: Process_Unit (
11960: p_commit => FND_API.G_TRUE,
11961: p_init_msg_list => FND_API.G_TRUE,
11962: x_msg_count => x_msg_count,
11963: x_msg_data => x_msg_data,
11964: x_return_status => x_return_status,
11957: FOR i IN l_csi_inst_tbl.FIRST..l_csi_inst_tbl.LAST LOOP
11958: -- Call Process Unit for the item instance.
11959: Process_Unit (
11960: p_commit => FND_API.G_TRUE,
11961: p_init_msg_list => FND_API.G_TRUE,
11962: x_msg_count => x_msg_count,
11963: x_msg_data => x_msg_data,
11964: x_return_status => x_return_status,
11965: p_csi_item_instance_id => l_csi_inst_tbl(i),
11964: x_return_status => x_return_status,
11965: p_csi_item_instance_id => l_csi_inst_tbl(i),
11966: p_concurrent_flag => 'N');
11967:
11968: IF (x_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
11969: EXIT;
11970: END IF;
11971:
11972: END LOOP; -- l_csi_inst_tbl.FIRST
11970: END IF;
11971:
11972: END LOOP; -- l_csi_inst_tbl.FIRST
11973: END IF; -- l_csi_inst_tbl.count
11974: IF (x_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
11975: EXIT;
11976: END IF;
11977:
11978: EXIT WHEN get_inst%NOTFOUND;
12043: AHL_DEBUG_PUB.debug('Tried to submit concurrent request but failed');
12044: END IF;
12045: fnd_file.put_line(FND_FILE.LOG, 'Failed submit concurrent request');
12046: fnd_file.new_line(FND_FILE.LOG,1);
12047: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
12048:
12049: ELSE
12050: fnd_file.put_line(FND_FILE.LOG, 'Concurrent request ID:' || l_req_id || ' launched to process instances between:' || l_start_csi_id || ' and ' || l_end_csi_id);
12051:
12119: AHL_DEBUG_PUB.debug('Tried to submit concurrent request but failed');
12120: END IF;
12121: fnd_file.put_line(FND_FILE.LOG, 'Failed submit concurrent request');
12122: fnd_file.new_line(FND_FILE.LOG,1);
12123: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
12124:
12125: ELSE
12126: fnd_file.put_line(FND_FILE.LOG, 'Concurrent request ID:' || l_req_id || ' launched to process instances between:' || p_csi_min_id || ' and ' || p_csi_min_id);
12127:
12199: AHL_DEBUG_PUB.debug('Tried to submit concurrent request but failed');
12200: END IF;
12201: fnd_file.put_line(FND_FILE.LOG, 'Failed submit concurrent request');
12202: fnd_file.new_line(FND_FILE.LOG,1);
12203: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
12204:
12205: ELSE
12206: fnd_file.put_line(FND_FILE.LOG, 'Concurrent request ID:' || l_req_id ||
12207: ' launched to process instances between:' || l_begin_count_csi_id || ' and ' ||
12225: AHL_DEBUG_PUB.debug('Tried to submit concurrent request but failed');
12226: END IF;
12227: fnd_file.put_line(FND_FILE.LOG, 'Failed submit concurrent request');
12228: fnd_file.new_line(FND_FILE.LOG,1);
12229: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
12230:
12231: ELSE
12232: fnd_file.put_line(FND_FILE.LOG, 'Concurrent request ID:' || l_req_id ||
12233: ' launched to process instances between:' || l_begin_count_csi_id || ' and ' ||
12352: --FOR inst_rec IN get_inst(p_mr_header_id, p_start_instance_id, p_end_instance_id) LOOP
12353: FOR i IN l_csi_inst_tbl.FIRST..l_csi_inst_tbl.LAST LOOP
12354: -- Call Process Unit for the item instance.
12355: Process_Unit (
12356: p_commit => FND_API.G_TRUE,
12357: p_init_msg_list => FND_API.G_TRUE,
12358: x_msg_count => l_msg_count,
12359: x_msg_data => l_msg_data,
12360: x_return_status => l_return_status,
12353: FOR i IN l_csi_inst_tbl.FIRST..l_csi_inst_tbl.LAST LOOP
12354: -- Call Process Unit for the item instance.
12355: Process_Unit (
12356: p_commit => FND_API.G_TRUE,
12357: p_init_msg_list => FND_API.G_TRUE,
12358: x_msg_count => l_msg_count,
12359: x_msg_data => l_msg_data,
12360: x_return_status => l_return_status,
12361: p_csi_item_instance_id => l_csi_inst_tbl(i),
12362: --inst_rec.instance_id,
12363: p_concurrent_flag => 'Y');
12364:
12365: l_msg_count := FND_MSG_PUB.Count_Msg;
12366: IF (l_return_status <> FND_API.G_RET_STS_SUCCESS)
12367: THEN
12368: retcode := 2; -- error based only on return status
12369: ELSIF (l_msg_count > 0 AND l_return_status = FND_API.G_RET_STS_SUCCESS)
12370: THEN
12365: l_msg_count := FND_MSG_PUB.Count_Msg;
12366: IF (l_return_status <> FND_API.G_RET_STS_SUCCESS)
12367: THEN
12368: retcode := 2; -- error based only on return status
12369: ELSIF (l_msg_count > 0 AND l_return_status = FND_API.G_RET_STS_SUCCESS)
12370: THEN
12371: retcode := 1; -- warning based on return status + msg count
12372: END IF;
12373:
12434: AHL_DEBUG_PUB.debug('Input p_num_of_workers:' || p_num_of_workers);
12435: END IF;
12436:
12437: -- initialize return status.
12438: x_return_status := FND_API.G_RET_STS_SUCCESS;
12439:
12440: IF (p_concurrent_flag = 'Y') THEN
12441: l_conc_req_id := fnd_global.conc_request_id;
12442: ELSE
12458: p_process_option => p_process_option,
12459: errbuf => x_msg_data,
12460: x_return_status => x_return_status);
12461:
12462: IF (x_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
12463: RETURN;
12464: END IF;
12465:
12466: -- launch worker programs.
12473: AHL_DEBUG_PUB.debug('Tried to submit concurrent request but failed');
12474: END IF;
12475: fnd_file.put_line(FND_FILE.LOG, 'Failed submit concurrent request');
12476: fnd_file.new_line(FND_FILE.LOG,1);
12477: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
12478:
12479: ELSE
12480: fnd_file.put_line(FND_FILE.LOG, 'Concurrent request ID:' || l_req_id );
12481: IF G_debug = 'Y' THEN
12489: Cleanup_BUE_Worker(p_parent_conc_request_id => l_conc_req_id,
12490: p_child_conc_request_id => NULL,
12491: x_return_status => l_return_status,
12492: x_errbuf => l_err_mesg);
12493: IF (l_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
12494: -- ignore error returned from this procedure
12495: -- log message in concurrent request log.
12496: fnd_file.put_line(FND_FILE.LOG, 'Warning: Error from Cleanup_BUE_Worker:' || l_err_mesg);
12497: END IF;
12498: ELSE
12499:
12500: LOOP
12501: -- initialize return status.
12502: x_return_status := FND_API.G_RET_STS_SUCCESS;
12503:
12504: Get_Next_BUE_Row(p_parent_conc_pgm_id => l_conc_req_id,
12505: p_conc_child_req_id => l_conc_req_id,
12506: x_return_status => x_return_status,
12506: x_return_status => x_return_status,
12507: errbuf => x_msg_data,
12508: x_item_instance_id => l_instance_id);
12509:
12510: IF (x_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
12511: EXIT;
12512: END IF;
12513:
12514: EXIT WHEN (l_instance_id IS NULL);
12519:
12520: -- Call Process Unit for the item instance.
12521: Process_Unit (
12522: p_commit => p_commit_flag,
12523: p_init_msg_list => FND_API.G_TRUE,
12524: x_msg_count => x_msg_count,
12525: x_msg_data => x_msg_data,
12526: x_return_status => x_return_status,
12527: p_csi_item_instance_id => l_instance_id,
12528: p_concurrent_flag => p_concurrent_flag,
12529: -- added sim plan for NR Analysis Enh.
12530: p_simulation_plan_id => G_SIMULATION_PLAN_ID);
12531:
12532: IF ( x_return_status <> FND_API.G_RET_STS_SUCCESS) AND (p_commit_flag = FND_API.G_FALSE) THEN
12533: EXIT;
12534: END IF;
12535:
12536: END LOOP;
12539: Cleanup_BUE_Worker(p_parent_conc_request_id => l_conc_req_id,
12540: p_child_conc_request_id => l_conc_req_id,
12541: x_return_status => l_return_status,
12542: x_errbuf => l_err_mesg);
12543: IF (l_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
12544: -- ignore error returned from this procedure
12545: IF G_DEBUG = 'Y' THEN
12546: AHL_DEBUG_PUB.debug('Warning: Error from Cleanup_BUE_Worker:' || l_err_mesg);
12547: END IF;
12609:
12610: -- AHL processing.
12611: LOOP
12612: -- initialize return status.
12613: l_return_status := FND_API.G_RET_STS_SUCCESS;
12614:
12615: G_DEBUG_LINE_NUM := 10;
12616:
12617: -- get next unit to process.
12620: x_return_status => l_return_status,
12621: errbuf => errbuf,
12622: x_item_instance_id => l_instance_id);
12623:
12624: IF (l_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
12625: EXIT;
12626: END IF;
12627:
12628: EXIT WHEN (l_instance_id IS NULL);
12634: G_DEBUG_LINE_NUM := 20;
12635:
12636: -- Call Process Unit for the item instance.
12637: Process_Unit (
12638: p_commit => FND_API.G_TRUE,
12639: p_init_msg_list => FND_API.G_TRUE,
12640: x_msg_count => l_msg_count,
12641: x_msg_data => l_msg_data,
12642: x_return_status => l_return_status,
12635:
12636: -- Call Process Unit for the item instance.
12637: Process_Unit (
12638: p_commit => FND_API.G_TRUE,
12639: p_init_msg_list => FND_API.G_TRUE,
12640: x_msg_count => l_msg_count,
12641: x_msg_data => l_msg_data,
12642: x_return_status => l_return_status,
12643: p_csi_item_instance_id => l_instance_id,
12647:
12648: fnd_file.put_line(FND_FILE.LOG,'End time:' || to_char(sysdate, 'Month DD, YYYY HH24:MI:SS'));
12649:
12650: l_msg_count := FND_MSG_PUB.Count_Msg;
12651: IF (retcode <> 2 AND l_return_status <> FND_API.G_RET_STS_SUCCESS)
12652: THEN
12653: retcode := 2; -- error based only on return status
12654: ELSIF (retcode = 0 AND l_msg_count > 0 AND l_return_status = FND_API.G_RET_STS_SUCCESS)
12655: THEN
12650: l_msg_count := FND_MSG_PUB.Count_Msg;
12651: IF (retcode <> 2 AND l_return_status <> FND_API.G_RET_STS_SUCCESS)
12652: THEN
12653: retcode := 2; -- error based only on return status
12654: ELSIF (retcode = 0 AND l_msg_count > 0 AND l_return_status = FND_API.G_RET_STS_SUCCESS)
12655: THEN
12656: retcode := 1; -- warning based on return status + msg count
12657: END IF;
12658:
12664: Cleanup_BUE_Worker(p_parent_conc_request_id => p_parent_conc_pgm_id,
12665: p_child_conc_request_id => l_conc_child_req_id,
12666: x_return_status => l_return_status,
12667: x_errbuf => l_msg_data);
12668: IF (l_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
12669: -- ignore error returned from this procedure
12670: -- log message in concurrent request log.
12671: fnd_file.put_line(FND_FILE.LOG, 'Warning: Error from Cleanup_BUE_Worker:' || l_msg_data);
12672: retcode := 1; -- warning based on return status
12680: END IF;
12681:
12682: --
12683: EXCEPTION
12684: WHEN FND_API.G_EXC_ERROR THEN
12685: retcode := 2;
12686: errbuf := 'Process_Unit_Range:EXC:' || G_DEBUG_LINE_NUM || ':' || substrb(sqlerrm,1,60);
12687:
12688: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
12684: WHEN FND_API.G_EXC_ERROR THEN
12685: retcode := 2;
12686: errbuf := 'Process_Unit_Range:EXC:' || G_DEBUG_LINE_NUM || ':' || substrb(sqlerrm,1,60);
12687:
12688: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
12689: retcode := 2;
12690: errbuf := 'Process_Unit_Range:UNEXP:' || G_DEBUG_LINE_NUM || ':' || substrb(sqlerrm,1,60);
12691:
12692: WHEN OTHERS THEN
12728: retcode := 0;
12729:
12730: -- After commit call UMP BUE api to build UEs.
12731: AHL_UMP_PROCESSUNIT_PVT.Process_MRAffected_Units (
12732: p_commit => FND_API.G_TRUE,
12733: x_msg_count => l_msg_count,
12734: x_msg_data => l_msg_data,
12735: x_return_status => l_return_status, -- ignore status returned by this api.
12736: p_old_mr_header_id => p_old_mr_header_id,
12738: p_concurrent_flag => 'Y',
12739: p_num_of_workers => 5);
12740:
12741: l_msg_count := FND_MSG_PUB.Count_Msg;
12742: IF (l_return_status <> FND_API.G_RET_STS_SUCCESS)
12743: THEN
12744: retcode := 2; -- error based only on return status
12745: log_error_messages;
12746: ELSIF (l_msg_count > 0 AND l_return_status = FND_API.G_RET_STS_SUCCESS)
12742: IF (l_return_status <> FND_API.G_RET_STS_SUCCESS)
12743: THEN
12744: retcode := 2; -- error based only on return status
12745: log_error_messages;
12746: ELSIF (l_msg_count > 0 AND l_return_status = FND_API.G_RET_STS_SUCCESS)
12747: THEN
12748: retcode := 1; -- warning based on return status + msg count
12749: log_error_messages;
12750: END IF;
12754: END IF;
12755:
12756: --
12757: EXCEPTION
12758: WHEN FND_API.G_EXC_ERROR THEN
12759: retcode := 2;
12760: errbuf := 'Process_Unit_Range:MR:EXC:' || G_DEBUG_LINE_NUM || ':' || substrb(sqlerrm,1,60);
12761:
12762: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
12758: WHEN FND_API.G_EXC_ERROR THEN
12759: retcode := 2;
12760: errbuf := 'Process_Unit_Range:MR:EXC:' || G_DEBUG_LINE_NUM || ':' || substrb(sqlerrm,1,60);
12761:
12762: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
12763: retcode := 2;
12764: errbuf := 'Process_Unit_Range:MR:UNEXP:' || G_DEBUG_LINE_NUM || ':' || substrb(sqlerrm,1,60);
12765:
12766: WHEN OTHERS THEN
13050: AHL_DEBUG_PUB.debug('Concurrent flag:' || p_concurrent_flag);
13051: END IF;
13052:
13053: -- initialize return status.
13054: x_return_status := FND_API.G_RET_STS_SUCCESS;
13055:
13056: IF (p_process_option = 'AHL_BUE_ALL_COMPONENTS') THEN
13057: l_opt_uc := 2;
13058: -- JKJain, NR Analysis and Forecasting
13423: ROLLBACK;
13424: l_status := SQLCODE;
13425: errbuf := 'Get_Next_BUE_Row:' || substrb(sqlerrm,1,60);
13426: l_instance_id := NULL;
13427: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
13428: IF (bue_lock_row%ISOPEN) THEN
13429: CLOSE bue_lock_row;
13430: END IF;
13431: END;
13447: END IF;
13448:
13449: EXCEPTION
13450: WHEN OTHERS THEN
13451: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
13452: errbuf := 'AHL_UMP_ProcessUnit_Pvt.Process.Get_Next_BUE_Row:' || SUBSTR(SQLERRM,1,240);
13453: x_item_instance_id := NULL;
13454:
13455: END Get_Next_BUE_Row;
13645: -- dbms_output.put_line('Record Locked');
13646:
13647: WHEN OTHERS THEN
13648: ROLLBACK;
13649: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
13650: x_errbuf := 'AHL_UMP_ProcessUnit_Pvt.Process.Cleanup_BUE_Worker:line:' || G_DEBUG_LINE_NUM || ':' || SUBSTR(SQLERRM,1,240);
13651:
13652: END Cleanup_BUE_Worker;
13653:
13854: AHL_DEBUG_PUB.debug('Input Conc Request ID:' || p_concurrent_flag);
13855: END IF;
13856:
13857: -- initialize return status.
13858: x_return_status := FND_API.G_RET_STS_SUCCESS;
13859:
13860: -- get instances applicable to the MR.
13861: -- this API will insert the applicable MRs into temp table ahl_mr_instances_temp
13862: AHL_FMP_PVT.GET_MR_AFFECTED_ITEMS (
13860: -- get instances applicable to the MR.
13861: -- this API will insert the applicable MRs into temp table ahl_mr_instances_temp
13862: AHL_FMP_PVT.GET_MR_AFFECTED_ITEMS (
13863: p_api_version => 1.0,
13864: p_init_msg_list => FND_API.G_TRUE,
13865: x_return_status => x_return_status,
13866: x_msg_count => l_msg_count,
13867: x_msg_data => l_msg_data,
13868: p_mr_header_id => p_mr_header_id,
13871: -- JKJain, NR Analysis and Forecasting
13872: p_consider_fleet_flag => 'N',
13873: x_mr_item_inst_tbl => l_mr_item_instances_tbl );
13874:
13875: IF (x_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
13876: ROLLBACK;
13877: RETURN;
13878: END IF;
13879:
14323: FND_MESSAGE.Set_Token('UE_ID',l_ue_relns_rec.ue_id);
14324: FND_MESSAGE.Set_Token('RELATED_UE_ID', l_ue_relns_rec.related_ue_id);
14325: FND_MSG_PUB.ADD;
14326: CLOSE ahl_ue_csr;
14327: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
14328: END IF;
14329: CLOSE ahl_ue_csr;
14330:
14331: l_new_unit_effectivity_rec := l_initialize_ue_rec;
14444:
14445: FOR j IN l_mr_id_tbl.FIRST..l_mr_id_tbl.LAST LOOP
14446: -- call FMP API to get MR effectivities
14447: AHL_FMP_PVT.GET_MR_APPLICABILITY(p_api_version => 1.0,
14448: p_init_msg_list => FND_API.G_FALSE,
14449: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
14450: x_return_status => l_return_status,
14451: x_msg_count => l_msg_count,
14452: x_msg_data => l_msg_data,
14445: FOR j IN l_mr_id_tbl.FIRST..l_mr_id_tbl.LAST LOOP
14446: -- call FMP API to get MR effectivities
14447: AHL_FMP_PVT.GET_MR_APPLICABILITY(p_api_version => 1.0,
14448: p_init_msg_list => FND_API.G_FALSE,
14449: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
14450: x_return_status => l_return_status,
14451: x_msg_count => l_msg_count,
14452: x_msg_data => l_msg_data,
14453: p_item_instance_id => G_config_node_tbl(i).csi_item_instance_id,
14457: x_applicable_mr_tbl => l_appl_mrs_tbl);
14458:
14459:
14460: -- Raise errors if exceptions occur
14461: IF (l_return_status = FND_API.G_RET_STS_ERROR) THEN
14462: RAISE FND_API.G_EXC_ERROR;
14463: ELSIF (l_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
14464: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
14465: END IF;
14458:
14459:
14460: -- Raise errors if exceptions occur
14461: IF (l_return_status = FND_API.G_RET_STS_ERROR) THEN
14462: RAISE FND_API.G_EXC_ERROR;
14463: ELSIF (l_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
14464: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
14465: END IF;
14466:
14459:
14460: -- Raise errors if exceptions occur
14461: IF (l_return_status = FND_API.G_RET_STS_ERROR) THEN
14462: RAISE FND_API.G_EXC_ERROR;
14463: ELSIF (l_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
14464: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
14465: END IF;
14466:
14467: -- Populate temporary table ahl_applicable_mrs.
14460: -- Raise errors if exceptions occur
14461: IF (l_return_status = FND_API.G_RET_STS_ERROR) THEN
14462: RAISE FND_API.G_EXC_ERROR;
14463: ELSIF (l_return_status = FND_API.G_RET_STS_UNEXP_ERROR) THEN
14464: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
14465: END IF;
14466:
14467: -- Populate temporary table ahl_applicable_mrs.
14468: IF (l_appl_mrs_tbl.COUNT > 0) THEN
14560:
14561: BEGIN
14562:
14563: -- Set return status.
14564: x_return_status := FND_API.G_RET_STS_SUCCESS;
14565:
14566: -- Enable Debug.
14567: IF G_DEBUG = 'Y' THEN
14568: AHL_DEBUG_PUB.enable_debug;
14576: AHL_DEBUG_PUB.debug('Count on p_x_warranty_counter_tbl:' || p_x_warranty_counter_tbl.COUNT);
14577: END IF;
14578:
14579: -- Validate input parameters.
14580: IF (p_item_instance_id IS NULL OR p_item_instance_id = FND_API.G_MISS_NUM) THEN
14581: FND_MESSAGE.Set_Name('AHL','AHL_UMP_CONT_ITEM_ID_NULL');
14582: FND_MSG_PUB.ADD;
14583: RAISE FND_API.G_EXC_ERROR;
14584: ELSE
14579: -- Validate input parameters.
14580: IF (p_item_instance_id IS NULL OR p_item_instance_id = FND_API.G_MISS_NUM) THEN
14581: FND_MESSAGE.Set_Name('AHL','AHL_UMP_CONT_ITEM_ID_NULL');
14582: FND_MSG_PUB.ADD;
14583: RAISE FND_API.G_EXC_ERROR;
14584: ELSE
14585: OPEN ahl_item_instance_csr (p_item_instance_id);
14586: FETCH ahl_item_instance_csr INTO l_inventory_item_id, l_inv_master_organization_id;
14587: IF (ahl_item_instance_csr%NOTFOUND) THEN
14588: FND_MESSAGE.Set_Name('AHL','AHL_UMP_CONT_ITEM_ID_INVALID');
14589: FND_MESSAGE.Set_Token('Item_Instance_ID', p_item_instance_id);
14590: FND_MSG_PUB.ADD;
14591: CLOSE ahl_item_instance_csr;
14592: RAISE FND_API.G_EXC_ERROR;
14593: END IF;
14594: CLOSE ahl_item_instance_csr;
14595: END IF;
14596:
14611:
14612:
14613: -- Check for errors.
14614: IF FND_MSG_PUB.Count_msg > 0 THEN
14615: RAISE FND_API.G_EXC_ERROR;
14616: END IF;
14617:
14618: -- Get utilization forecast for the unit/part.
14619: Get_Utilization_Forecast (l_root_csi_instance_id,
14701: -- Standard call to get message count and if count is 1, get message info
14702: FND_MSG_PUB.Count_And_Get
14703: ( p_count => x_msg_count,
14704: p_data => x_msg_data,
14705: p_encoded => fnd_api.g_false
14706: );
14707:
14708: --
14709: EXCEPTION
14706: );
14707:
14708: --
14709: EXCEPTION
14710: WHEN FND_API.G_EXC_ERROR THEN
14711: x_return_status := FND_API.G_RET_STS_ERROR;
14712: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
14713: p_data => x_msg_data,
14714: p_encoded => fnd_api.g_false);
14707:
14708: --
14709: EXCEPTION
14710: WHEN FND_API.G_EXC_ERROR THEN
14711: x_return_status := FND_API.G_RET_STS_ERROR;
14712: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
14713: p_data => x_msg_data,
14714: p_encoded => fnd_api.g_false);
14715:
14710: WHEN FND_API.G_EXC_ERROR THEN
14711: x_return_status := FND_API.G_RET_STS_ERROR;
14712: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
14713: p_data => x_msg_data,
14714: p_encoded => fnd_api.g_false);
14715:
14716: -- Disable debug
14717: AHL_DEBUG_PUB.disable_debug;
14718:
14715:
14716: -- Disable debug
14717: AHL_DEBUG_PUB.disable_debug;
14718:
14719: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
14720: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
14721: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
14722: p_data => x_msg_data,
14723: p_encoded => fnd_api.g_false);
14716: -- Disable debug
14717: AHL_DEBUG_PUB.disable_debug;
14718:
14719: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
14720: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
14721: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
14722: p_data => x_msg_data,
14723: p_encoded => fnd_api.g_false);
14724:
14719: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
14720: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
14721: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
14722: p_data => x_msg_data,
14723: p_encoded => fnd_api.g_false);
14724:
14725: -- Disable debug
14726: AHL_DEBUG_PUB.disable_debug;
14727:
14726: AHL_DEBUG_PUB.disable_debug;
14727:
14728: WHEN OTHERS THEN
14729:
14730: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
14731: IF FND_MSG_PUB.check_msg_level(FND_MSG_PUB.G_MSG_LVL_UNEXP_ERROR) THEN
14732: fnd_msg_pub.add_exc_msg(p_pkg_name => G_PKG_NAME,
14733: p_procedure_name => 'Get_Cont_Ctr_Expiration_Date',
14734: p_error_text => SUBSTR(SQLERRM,1,240));
14734: p_error_text => SUBSTR(SQLERRM,1,240));
14735: END IF;
14736: FND_MSG_PUB.count_and_get( p_count => x_msg_count,
14737: p_data => x_msg_data,
14738: p_encoded => fnd_api.g_false);
14739:
14740:
14741: -- Disable debug
14742: AHL_DEBUG_PUB.disable_debug;
15051: x_deferral_flag => l_lc_acc_deferral_flag,
15052: x_status_code => l_lc_acc_status_code,
15053: x_return_val => l_lc_return_val);
15054: IF (NOT(l_lc_return_val)) THEN
15055: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
15056: ELSE
15057: IF (l_lc_acc_ue_id IS NOT NULL) THEN
15058: l_loop_chain_MR_tbl(i).accomplishment_exists := 'Y';
15059: l_loop_chain_MR_tbl(i).accomplished_ue_id := l_lc_acc_ue_id;
15089: FND_MESSAGE.Set_Name('AHL','AHL_UMP_UE_INVALID');
15090: FND_MESSAGE.Set_Token('UE_ID',l_last_acc_ue_id );
15091: FND_MSG_PUB.ADD;
15092: CLOSE ahl_ue_csr;
15093: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
15094: END IF;
15095: CLOSE ahl_ue_csr;
15096: END IF;
15097:
15396: x_deferral_flag => l_lc_acc_deferral_flag,
15397: x_status_code => l_lc_acc_status_code,
15398: x_return_val => l_lc_return_val);
15399: IF (NOT(l_lc_return_val)) THEN
15400: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
15401: ELSE
15402: IF (l_lc_acc_ue_id IS NOT NULL) THEN
15403: l_loop_chain_MR_tbl(i).accomplishment_exists := 'Y';
15404: l_loop_chain_MR_tbl(i).accomplished_ue_id := l_lc_acc_ue_id;
15433: FND_MESSAGE.Set_Token('START_LC_UE_ID',l_chain_start_lc_ue_tbl(h));
15434: FND_MESSAGE.Set_Token('CHAIN_SEQ', l_chain_seq_num_tbl(h)+1);
15435: FND_MSG_PUB.ADD;
15436: CLOSE get_chain_ue_csr;
15437: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
15438: END IF;
15439: CLOSE get_chain_ue_csr;
15440:
15441: IF G_DEBUG = 'Y' THEN
15486: FND_MESSAGE.Set_Token('START_LC_UE_ID',l_chain_start_lc_ue_tbl(h));
15487: FND_MESSAGE.Set_Token('CHAIN_SEQ', l_chain_seq_num_tbl(h));
15488: FND_MSG_PUB.ADD;
15489: CLOSE get_acc_chain_seq;
15490: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
15491: END IF;
15492: END IF;
15493: CLOSE get_acc_chain_seq;
15494:
16120: x_return_status OUT NOCOPY VARCHAR2,
16121: x_msg_data OUT NOCOPY VARCHAR2,
16122: x_msg_count OUT NOCOPY NUMBER,
16123: x_due_date OUT NOCOPY DATE,
16124: p_init_msg_list IN VARCHAR2 := FND_API.G_FALSE,
16125: p_unit_effectivity_id IN NUMBER)
16126: IS
16127:
16128: l_due_date DATE;
16129: l_due_counter_value NUMBER;
16130: l_counter_id NUMBER;
16131:
16132: BEGIN
16133: x_return_status := FND_API.G_RET_STS_SUCCESS;
16134:
16135: -- Enable Debug.
16136: IF G_DEBUG = 'Y' THEN
16137: AHL_DEBUG_PUB.enable_debug;
16144: AHL_DEBUG_PUB.debug('Unit Effectivity ID:' || p_unit_effectivity_id);
16145: END IF;
16146:
16147: -- Validate input parameters.
16148: IF (p_unit_effectivity_id IS NULL OR p_unit_effectivity_id = FND_API.G_MISS_NUM) THEN
16149: FND_MESSAGE.Set_Name('AHL','AHL_UMP_DEF_UE_NULL');
16150: FND_MSG_PUB.ADD;
16151: RAISE FND_API.G_EXC_ERROR;
16152: END IF;
16147: -- Validate input parameters.
16148: IF (p_unit_effectivity_id IS NULL OR p_unit_effectivity_id = FND_API.G_MISS_NUM) THEN
16149: FND_MESSAGE.Set_Name('AHL','AHL_UMP_DEF_UE_NULL');
16150: FND_MSG_PUB.ADD;
16151: RAISE FND_API.G_EXC_ERROR;
16152: END IF;
16153:
16154: IF G_DEBUG = 'Y' THEN
16155: AHL_DEBUG_PUB.debug('Before call to Calculate_NR_due_date');
16199: WHEN OTHERS THEN
16200: IF (SQLCODE = -54) THEN
16201: FND_MESSAGE.Set_Name('AHL','AHL_UMP_PUE_ALREADY_RUNNING');
16202: FND_MSG_PUB.ADD;
16203: RAISE FND_API.G_EXC_ERROR;
16204: ELSE
16205: IF FND_MSG_PUB.check_msg_level(FND_MSG_PUB.G_MSG_LVL_UNEXP_ERROR) THEN
16206: fnd_msg_pub.add_exc_msg(p_pkg_name => G_PKG_NAME,
16207: p_procedure_name => 'Calculate_Init_DueDate',
16206: fnd_msg_pub.add_exc_msg(p_pkg_name => G_PKG_NAME,
16207: p_procedure_name => 'Calculate_Init_DueDate',
16208: p_error_text => SUBSTR(SQLERRM,1,240));
16209: END IF;
16210: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
16211: END IF;
16212:
16213: END Calculate_Init_DueDate;
16214: ---------------------------
16301: IF (ahl_unit_effectivity_csr%NOTFOUND) THEN
16302: FND_MESSAGE.Set_Name('AHL','AHL_UMP_DEF_UE_INVALID');
16303: FND_MESSAGE.Set_Token('UE_ID', p_unit_effectivity_id);
16304: FND_MSG_PUB.ADD;
16305: RAISE FND_API.G_EXC_ERROR;
16306: END IF;
16307:
16308: IF G_DEBUG = 'Y' THEN
16309: AHL_DEBUG_PUB.debug('Step 1');
16325: END IF;
16326:
16327: -- Check for errors.
16328: IF FND_MSG_PUB.Count_msg > 0 THEN
16329: RAISE FND_API.G_EXC_ERROR;
16330: END IF;
16331:
16332: IF G_DEBUG = 'Y' THEN
16333: AHL_DEBUG_PUB.debug('Step 3');