[Home] [Help]
237: l_available_list CSP_SCH_INT_PVT.CSP_AVAILABILITY_TBL_TYPE ;
238: l_final_available_list CSP_SCH_INT_PVT.CSP_AVAILABILITY_TBL_TYPE ;
239: l_eligible_resources_list CSP_SCH_INT_PVT.CSP_AVAILABILITY_TBL_TYPE ;
240: l_final_unavailable_list CSP_SCH_INT_PVT.CSP_UNAVAILABILITY_TBL_TYPE ;
241: l_return_status VARCHAR2(128) := FND_API.G_RET_STS_SUCCESS;
242: l_del_date VARCHAR2(50);
243: l_api_name VARCHAR2(60) := 'CSP_SCH_INT_PVT.GET_AVAILABILITY_OPTIONS';
244: l_temp_line_id NUMBER;
245: l_total_parts NUMBER := 0;
311: l_available_list := CSP_SCH_INT_PVT.CSP_AVAILABILITY_TBL_TYPE ();
312: l_eligible_resources_list := CSP_SCH_INT_PVT.CSP_AVAILABILITY_TBL_TYPE() ;
313: l_final_unavailable_list := CSP_SCH_INT_PVT.CSP_UNAVAILABILITY_TBL_TYPE();
314: x_options := CSP_SCH_INT_PVT.csp_sch_options_tbl_typ();
315: x_return_status := FND_API.G_RET_STS_SUCCESS;
316: g_interval := p_interval;
317:
318: -- bug # 12618325
319: -- need to clear old requirement
359: 'l_partial_line = ' || l_partial_line);
360: end if;
361:
362: if l_partial_line > 0 then
363: x_return_status := FND_API.G_RET_STS_ERROR;
364: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
365: FND_MSG_PUB.ADD;
366: fnd_msg_pub.count_and_get
367: ( p_count => x_msg_count
418: and dio.source_id = oola.line_id
419: and oola.header_id = ooha.header_id
420: AND rownum = 1;
421:
422: x_return_status := FND_API.G_RET_STS_ERROR;
423: FND_MESSAGE.SET_NAME('CSP', 'CSP_TSK_ASSGN_NO_IO_CAN');
424: FND_MESSAGE.SET_TOKEN('ORDER_NUMBER',l_order_number, FALSE);
425: FND_MSG_PUB.ADD;
426: fnd_msg_pub.count_and_get
495: 'l_fl_rcvd_multi_source = ' || l_fl_rcvd_multi_source);
496: end if;
497:
498: if l_fl_rcvd_multi_source > 0 then
499: x_return_status := FND_API.G_RET_STS_ERROR;
500: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
501: FND_MSG_PUB.ADD;
502: fnd_msg_pub.count_and_get
503: ( p_count => x_msg_count
548: 'l_oth_req_line = ' || l_oth_req_line);
549: end if;
550:
551: if l_oth_req_line > 0 then
552: x_return_status := FND_API.G_RET_STS_ERROR;
553: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
554: FND_MSG_PUB.ADD;
555: fnd_msg_pub.count_and_get
556: ( p_count => x_msg_count
677: AND oola.header_id = ooha.header_id
678: AND csp_pick_utils.get_order_status(oola.line_id,oola.flow_status_code) IN ('SHIPPED', 'EXPECTED')
679: AND rownum = 1;
680:
681: x_return_status := FND_API.G_RET_STS_ERROR;
682: FND_MESSAGE.SET_NAME('CSP', 'CSP_TSK_ASSGN_NO_IO_CAN');
683: FND_MESSAGE.SET_TOKEN('ORDER_NUMBER',l_order_number, FALSE);
684: FND_MSG_PUB.ADD;
685: fnd_msg_pub.count_and_get
713: 'l_ship_multi_src = ' || l_ship_multi_src);
714: end if;
715:
716: if l_ship_multi_src > 0 then
717: x_return_status := FND_API.G_RET_STS_ERROR;
718: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
719: FND_MSG_PUB.ADD;
720: fnd_msg_pub.count_and_get
721: ( p_count => x_msg_count
757: 'l_oth_req_line = ' || l_oth_req_line);
758: end if;
759:
760: if l_oth_req_line > 0 then
761: x_return_status := FND_API.G_RET_STS_ERROR;
762: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
763: FND_MSG_PUB.ADD;
764: fnd_msg_pub.count_and_get
765: ( p_count => x_msg_count
876: 'csp.plsql.CSP_SCH_INT_PVT.GET_AVAILABILITY_OPTIONS',
877: 'after making call to CLEAN_REQUIREMENT... x_return_status = ' || x_return_status);
878: end if;
879:
880: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
881: -- bug # 14084319
882: -- handle a case where cancellation of an order is failed
883: -- due to OM processing constraints
884: if x_return_status = 'C' then
936: x_options(x_options.count).ship_method := '';
937: x_options(x_options.count).distance_str := '';
938: end if;
939: end loop;
940: x_return_status := FND_API.G_RET_STS_SUCCESS;
941: return;
942: end if;
943: return;
944: END IF;
980: 'csp.plsql.CSP_SCH_INT_PVT.GET_AVAILABILITY_OPTIONS',
981: 'l_resource_org_subinv.count=' || l_resource_org_subinv.count);
982: end if;
983:
984: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
985: RETURN;
986: END IF;
987:
988: CSP_SCH_INT_PVT.GET_PARTS_LIST(p_task_id,p_likelihood,l_parts_list,x_return_status,x_msg_data,x_msg_count);
995: 'csp.plsql.CSP_SCH_INT_PVT.GET_AVAILABILITY_OPTIONS',
996: 'l_parts_list.count=' || l_parts_list.count);
997: end if;
998:
999: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1000: RETURN;
1001: END IF;
1002:
1003: IF l_parts_list.count = 0 THEN
1000: RETURN;
1001: END IF;
1002:
1003: IF l_parts_list.count = 0 THEN
1004: x_return_status := FND_API.G_RET_STS_SUCCESS;
1005: for i in 1..l_parts_list.count loop
1006: l_total_parts := l_total_parts + l_parts_list(i).quantity;
1007: end loop;
1008: FOR I IN 1..p_resources.count LOOP
1031: 'csp.plsql.CSP_SCH_INT_PVT.GET_AVAILABILITY_OPTIONS',
1032: 'l_final_available_list.count=' || l_final_available_list.count);
1033: end if;
1034:
1035: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1036: RETURN;
1037: END IF ;
1038:
1039: if p_trunk and not p_mandatory then
1103: ELSE
1104: l_final_unavailable_list := l_unavailable_list;
1105: END IF;
1106:
1107: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1108: RETURN;
1109: END IF;
1110:
1111: If l_available_list.count > 0 THEN
1141: 'csp.plsql.CSP_SCH_INT_PVT.GET_AVAILABILITY_OPTIONS',
1142: 'l_eligible_resources_list.count=' || l_eligible_resources_list.count);
1143: end if;
1144:
1145: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1146: RETURN;
1147: END IF;
1148:
1149: IF l_eligible_resources_list.count > 0 THEN
1161: 'csp.plsql.CSP_SCH_INT_PVT.GET_AVAILABILITY_OPTIONS',
1162: 'x_options.count=' || x_options.count);
1163: end if;
1164:
1165: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1166: RETURN;
1167: /*ELSE
1168: IF x_options.count = 0 THEN
1169: x_return_status := FND_API.G_RET_STS_ERROR;
1165: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1166: RETURN;
1167: /*ELSE
1168: IF x_options.count = 0 THEN
1169: x_return_status := FND_API.G_RET_STS_ERROR;
1170: l_del_date := to_char(g_earliest_delivery_date,'MM-DD-YYYY HH24:MI:SS');
1171: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_DEL');
1172: FND_MESSAGE.SET_TOKEN('DDATE', l_del_date, TRUE);
1173: FND_MSG_PUB.ADD;
1176: , p_data => x_msg_data);
1177: END IF;*/
1178: END IF;
1179: ELSE
1180: x_return_status := FND_API.G_RET_STS_ERROR;
1181: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NO_PARTS');
1182: FND_MSG_PUB.ADD;
1183: fnd_msg_pub.count_and_get
1184: ( p_count => x_msg_count
1203: FND_MSG_PUB.ADD;
1204: fnd_msg_pub.count_and_get
1205: ( p_count => x_msg_count
1206: , p_data => x_msg_data);
1207: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1208: return;
1209: END GET_AVAILABILITY_OPTIONS;
1210:
1211: PROCEDURE CHOOSE_OPTION(p_api_version_number IN NUMBER
1370: FND_MESSAGE.SET_TOKEN('RESOURCE_NAME',l_resource_name, FALSE);
1371: FND_MSG_PUB.ADD;
1372: fnd_msg_pub.count_and_get( p_count => x_msg_count
1373: , p_data => x_msg_data);
1374: x_return_status := FND_API.G_RET_STS_ERROR;
1375: return;
1376: end if;
1377:
1378: for r_asgn in get_asgn_id loop
1424: x_msg_count => x_msg_count,
1425: x_msg_data => x_msg_data
1426: );
1427: log('choose_option', 'after calling move_parts_on_reassign...x_return_status=' || x_return_status);
1428: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
1429: x_return_status := FND_API.G_RET_STS_ERROR;
1430: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
1431: FND_MSG_PUB.ADD;
1432: fnd_msg_pub.count_and_get
1425: x_msg_data => x_msg_data
1426: );
1427: log('choose_option', 'after calling move_parts_on_reassign...x_return_status=' || x_return_status);
1428: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
1429: x_return_status := FND_API.G_RET_STS_ERROR;
1430: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
1431: FND_MSG_PUB.ADD;
1432: fnd_msg_pub.count_and_get
1433: ( p_count => x_msg_count
1479:
1480: log('choose_option', 'before calling Update_requirement_headers...');
1481: CSP_Requirement_Headers_PVT.Update_requirement_headers(
1482: P_Api_Version_Number => 1.0,
1483: P_Init_Msg_List => FND_API.G_FALSE,
1484: P_Commit => FND_API.G_FALSE,
1485: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
1486: P_REQUIREMENT_HEADER_Rec => l_requirement_header,
1487: X_Return_Status => x_return_status,
1480: log('choose_option', 'before calling Update_requirement_headers...');
1481: CSP_Requirement_Headers_PVT.Update_requirement_headers(
1482: P_Api_Version_Number => 1.0,
1483: P_Init_Msg_List => FND_API.G_FALSE,
1484: P_Commit => FND_API.G_FALSE,
1485: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
1486: P_REQUIREMENT_HEADER_Rec => l_requirement_header,
1487: X_Return_Status => x_return_status,
1488: X_Msg_Count => x_msg_count,
1481: CSP_Requirement_Headers_PVT.Update_requirement_headers(
1482: P_Api_Version_Number => 1.0,
1483: P_Init_Msg_List => FND_API.G_FALSE,
1484: P_Commit => FND_API.G_FALSE,
1485: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
1486: P_REQUIREMENT_HEADER_Rec => l_requirement_header,
1487: X_Return_Status => x_return_status,
1488: X_Msg_Count => x_msg_count,
1489: x_msg_data => x_msg_data
1489: x_msg_data => x_msg_data
1490: );
1491: log('choose_option', 'before calling Update_requirement_headers...x_return_status=' || x_return_status);
1492:
1493: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
1494: x_return_status := FND_API.G_RET_STS_ERROR;
1495: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
1496: FND_MSG_PUB.ADD;
1497: fnd_msg_pub.count_and_get
1490: );
1491: log('choose_option', 'before calling Update_requirement_headers...x_return_status=' || x_return_status);
1492:
1493: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
1494: x_return_status := FND_API.G_RET_STS_ERROR;
1495: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
1496: FND_MSG_PUB.ADD;
1497: fnd_msg_pub.count_and_get
1498: ( p_count => x_msg_count
1516: );
1517:
1518: log('choose_option', 'after making call to CLEAN_REQUIREMENT... x_return_status = ' || x_return_status);
1519:
1520: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1521: if x_return_status = 'C' then
1522: for cr in c_parts_req(p_task_id, r_asgn.task_assignment_id)
1523: loop
1524: l_requirement_header := CSP_Requirement_headers_PVT.G_MISS_REQUIREMENT_HEADER_REC;
1540:
1541: log('choose_option', 'before calling Update_requirement_headers...');
1542: CSP_Requirement_Headers_PVT.Update_requirement_headers(
1543: P_Api_Version_Number => 1.0,
1544: P_Init_Msg_List => FND_API.G_FALSE,
1545: P_Commit => FND_API.G_FALSE,
1546: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
1547: P_REQUIREMENT_HEADER_Rec => l_requirement_header,
1548: X_Return_Status => x_return_status,
1541: log('choose_option', 'before calling Update_requirement_headers...');
1542: CSP_Requirement_Headers_PVT.Update_requirement_headers(
1543: P_Api_Version_Number => 1.0,
1544: P_Init_Msg_List => FND_API.G_FALSE,
1545: P_Commit => FND_API.G_FALSE,
1546: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
1547: P_REQUIREMENT_HEADER_Rec => l_requirement_header,
1548: X_Return_Status => x_return_status,
1549: X_Msg_Count => x_msg_count,
1542: CSP_Requirement_Headers_PVT.Update_requirement_headers(
1543: P_Api_Version_Number => 1.0,
1544: P_Init_Msg_List => FND_API.G_FALSE,
1545: P_Commit => FND_API.G_FALSE,
1546: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
1547: P_REQUIREMENT_HEADER_Rec => l_requirement_header,
1548: X_Return_Status => x_return_status,
1549: X_Msg_Count => x_msg_count,
1550: x_msg_data => x_msg_data
1550: x_msg_data => x_msg_data
1551: );
1552: log('choose_option', 'before calling Update_requirement_headers...x_return_status=' || x_return_status);
1553:
1554: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
1555: x_return_status := FND_API.G_RET_STS_ERROR;
1556: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
1557: FND_MSG_PUB.ADD;
1558: fnd_msg_pub.count_and_get
1551: );
1552: log('choose_option', 'before calling Update_requirement_headers...x_return_status=' || x_return_status);
1553:
1554: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
1555: x_return_status := FND_API.G_RET_STS_ERROR;
1556: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
1557: FND_MSG_PUB.ADD;
1558: fnd_msg_pub.count_and_get
1559: ( p_count => x_msg_count
1560: , p_data => x_msg_data);
1561: return;
1562: end if;
1563: end loop;
1564: x_return_status := FND_API.G_RET_STS_SUCCESS;
1565: return;
1566: end if;
1567: return;
1568: END IF;
1568: END IF;
1569:
1570: end loop;
1571:
1572: x_return_status := FND_API.G_RET_STS_SUCCESS ;
1573: l_resources := CSP_SCH_INT_PVT.csp_sch_resource_tbl_typ();
1574: l_resource_org_subinv := CSP_SCH_INT_PVT.CSP_RESOURCE_ORG_tbl_TYP();
1575: --l_parts_list := CSP_SCH_INT_PVT.CSP_PARTS_TBL_TYPE();
1576: l_unavailable_list := CSP_SCH_INT_PVT.CSP_UNAVAILABILITY_TBL_TYPE();
1620: x_msg_count => x_msg_count);
1621:
1622:
1623: if(x_options.count = 0) then
1624: x_return_status := FND_API.G_RET_STS_ERROR;
1625: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_OPTION_NOT_VALIED');
1626: FND_MSG_PUB.ADD;
1627: fnd_msg_pub.count_and_get
1628: ( p_count => x_msg_count
1675: l_reservation_parts.sub_inventory_code := cap.subinventory_code;
1676: l_reservation_parts.line_id := cap.requirement_line_id;
1677: l_reservation_parts.revision := cap.supplied_item_rev;
1678: l_reservation_id := CSP_SCH_INT_PVT.CREATE_RESERVATION(l_reservation_parts,x_return_status,x_msg_data);
1679: if x_return_status = FND_API.G_RET_STS_SUCCESS then
1680: l_req_line_details_id := null;
1681: csp_req_line_details_pkg.insert_row(
1682: l_req_line_details_id
1683: ,cap.requirement_line_id
1690: ,l_reservation_id);
1691: else
1692: log('choose_option','Reservation Creation failed');
1693: ROLLBACK TO CHOOSE_OPTIONS;
1694: x_return_status := FND_API.G_RET_STS_ERROR;
1695: return;
1696: end if;
1697: log('choose_option','Reservation_id:'||l_reservation_id);
1698: else
1698: else
1699: if cap.operating_unit <> nvl(l_old_operating_unit,cap.operating_unit) then
1700: CSP_PARTS_ORDER.process_order(
1701: p_api_version => 1.0
1702: ,p_Init_Msg_List => FND_API.G_FALSE
1703: ,p_commit => FND_API.G_FALSE
1704: ,p_book_order => l_book_order
1705: ,px_header_rec => l_parts_header
1706: ,px_line_table => l_parts_lines
1699: if cap.operating_unit <> nvl(l_old_operating_unit,cap.operating_unit) then
1700: CSP_PARTS_ORDER.process_order(
1701: p_api_version => 1.0
1702: ,p_Init_Msg_List => FND_API.G_FALSE
1703: ,p_commit => FND_API.G_FALSE
1704: ,p_book_order => l_book_order
1705: ,px_header_rec => l_parts_header
1706: ,px_line_table => l_parts_lines
1707: ,x_return_status => x_return_status
1707: ,x_return_status => x_return_status
1708: ,x_msg_count => x_msg_count
1709: ,x_msg_data => x_msg_data
1710: );
1711: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1712: log('choose_option','Order Creation failed');
1713: ROLLBACK TO CHOOSE_OPTIONS;
1714: x_return_status := FND_API.G_RET_STS_ERROR;
1715: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_UNABLE_TO_ORDER');
1710: );
1711: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1712: log('choose_option','Order Creation failed');
1713: ROLLBACK TO CHOOSE_OPTIONS;
1714: x_return_status := FND_API.G_RET_STS_ERROR;
1715: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_UNABLE_TO_ORDER');
1716: FND_MSG_PUB.ADD;
1717: fnd_msg_pub.count_and_get
1718: ( p_count => x_msg_count
1773: if rec_count > 1 then
1774: log('choose_option','Creating last order');
1775: CSP_PARTS_ORDER.process_order(
1776: p_api_version => 1.0
1777: ,p_Init_Msg_List => FND_API.G_FALSE
1778: ,p_commit => FND_API.G_FALSE
1779: ,p_book_order => l_book_order
1780: ,px_header_rec => l_parts_header
1781: ,px_line_table => l_parts_lines
1774: log('choose_option','Creating last order');
1775: CSP_PARTS_ORDER.process_order(
1776: p_api_version => 1.0
1777: ,p_Init_Msg_List => FND_API.G_FALSE
1778: ,p_commit => FND_API.G_FALSE
1779: ,p_book_order => l_book_order
1780: ,px_header_rec => l_parts_header
1781: ,px_line_table => l_parts_lines
1782: ,x_return_status => x_return_status
1782: ,x_return_status => x_return_status
1783: ,x_msg_count => x_msg_count
1784: ,x_msg_data => x_msg_data
1785: );
1786: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1787: log('choose_option','Order Creation failed');
1788: ROLLBACK TO CHOOSE_OPTIONS;
1789: x_return_status := FND_API.G_RET_STS_ERROR;
1790: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_UNABLE_TO_ORDER');
1785: );
1786: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1787: log('choose_option','Order Creation failed');
1788: ROLLBACK TO CHOOSE_OPTIONS;
1789: x_return_status := FND_API.G_RET_STS_ERROR;
1790: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_UNABLE_TO_ORDER');
1791: FND_MSG_PUB.ADD;
1792: fnd_msg_pub.count_and_get
1793: ( p_count => x_msg_count
1839: end if;
1840: end if;
1841: CSP_Requirement_Headers_PVT.Update_requirement_headers(
1842: P_Api_Version_Number => 1.0,
1843: P_Init_Msg_List => FND_API.G_FALSE,
1844: P_Commit => FND_API.G_FALSE,
1845: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
1846: P_REQUIREMENT_HEADER_Rec => l_requirement_header,
1847: X_Return_Status => x_return_status,
1840: end if;
1841: CSP_Requirement_Headers_PVT.Update_requirement_headers(
1842: P_Api_Version_Number => 1.0,
1843: P_Init_Msg_List => FND_API.G_FALSE,
1844: P_Commit => FND_API.G_FALSE,
1845: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
1846: P_REQUIREMENT_HEADER_Rec => l_requirement_header,
1847: X_Return_Status => x_return_status,
1848: X_Msg_Count => x_msg_count,
1841: CSP_Requirement_Headers_PVT.Update_requirement_headers(
1842: P_Api_Version_Number => 1.0,
1843: P_Init_Msg_List => FND_API.G_FALSE,
1844: P_Commit => FND_API.G_FALSE,
1845: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
1846: P_REQUIREMENT_HEADER_Rec => l_requirement_header,
1847: X_Return_Status => x_return_status,
1848: X_Msg_Count => x_msg_count,
1849: x_msg_data => x_msg_data
1849: x_msg_data => x_msg_data
1850: );
1851:
1852: else
1853: x_return_status := FND_API.G_RET_STS_ERROR;
1854: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_OPTION_NOT_VALIED');
1855: FND_MSG_PUB.ADD;
1856: fnd_msg_pub.count_and_get
1857: ( p_count => x_msg_count
1863: return;
1864: end if;
1865: log('choose_option','get_organization_subinv');
1866: CSP_SCH_INT_PVT.GET_ORGANIZATION_SUBINV(l_resources, l_resource_org_subinv , x_return_status,x_msg_data,x_msg_count);
1867: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1868: RETURN;
1869: END IF;
1870: CSP_SCH_INT_PVT.GET_PARTS_LIST(p_task_id,p_likelihood,l_parts_list,x_return_status,x_msg_data,x_msg_count);
1871: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1867: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1868: RETURN;
1869: END IF;
1870: CSP_SCH_INT_PVT.GET_PARTS_LIST(p_task_id,p_likelihood,l_parts_list,x_return_status,x_msg_data,x_msg_count);
1871: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1872: RETURN;
1873: END IF;
1874: IF x_return_status = FND_API.G_RET_STS_SUCCESS THEN
1875: CSP_SCH_INT_PVT.CHECK_LOCAL_INVENTORY(l_resource_org_subinv,l_parts_list,p_trunk,l_unavailable_list,l_final_available_list,x_return_status,x_msg_data,x_msg_count);
1870: CSP_SCH_INT_PVT.GET_PARTS_LIST(p_task_id,p_likelihood,l_parts_list,x_return_status,x_msg_data,x_msg_count);
1871: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1872: RETURN;
1873: END IF;
1874: IF x_return_status = FND_API.G_RET_STS_SUCCESS THEN
1875: CSP_SCH_INT_PVT.CHECK_LOCAL_INVENTORY(l_resource_org_subinv,l_parts_list,p_trunk,l_unavailable_list,l_final_available_list,x_return_status,x_msg_data,x_msg_count);
1876: ELSE
1877: return;
1878: END IF;
1882: CSP_SCH_INT_PVT.SPARES_CHECK(l_unavailable_list,l_interval,l_available_list,l_final_unavailable_list,x_return_status,x_msg_data,x_msg_count);
1883: elsif l_unavailable_list.count >= 1 and p_warehouse THEN
1884: CSP_SCH_INT_PVT.DO_ATP_CHECK(l_unavailable_list,l_interval,l_available_list,l_final_unavailable_list,x_return_status,x_msg_data,x_msg_count);
1885: END IF;
1886: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1887: RETURN;
1888: END IF;
1889: IF l_available_list.count > 0 THEN
1890: l_temp_line_id := l_available_list(1).line_id;
1899: END IF;
1900: END LOOP;
1901: if p_mandatory then
1902: CSP_SCH_INT_PVT.ELIGIBLE_RESOURCES(l_resources,l_final_available_list,l_final_unavailable_list,l_eligible_resources_list,x_return_status,x_msg_data,x_msg_count);
1903: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1904: RETURN;
1905: END IF;
1906: else
1907: FOR K IN 1..l_final_available_list.count LOOP
1922: IF l_eligible_resources_list.count > 0 THEN
1923: --CSP_SCH_INT_PVT.GET_TIME_COST(l_eligible_resources_list,l_options,x_return_status);
1924: CSP_SCH_INT_PVT.OPTIMIZE_OPTIONS(l_eligible_resources_list,l_options,l_ship_count,l_res_ship_parameters,x_return_status,x_msg_data,x_msg_count);
1925: ELSE
1926: x_return_status := FND_API.G_RET_STS_ERROR;
1927: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_OPTION_NOT_VALIED');
1928: FND_MSG_PUB.ADD;
1929: fnd_msg_pub.count_and_get
1930: ( p_count => x_msg_count
1944: l_temp_options(l_temp_options.count).arrival_date := l_options(I).arrival_date ;
1945: END IF;
1946: END LOOP;
1947: IF l_temp_options.count = 0 then
1948: x_return_status := FND_API.G_RET_STS_ERROR;
1949: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_OPTION_NOT_VALIED');
1950: FND_MSG_PUB.ADD;
1951: fnd_msg_pub.count_and_get
1952: ( p_count => x_msg_count
2068: l_reservation_parts.revision := l_eligible_resources_list(I).revision;
2069: l_reservation_id := CSP_SCH_INT_PVT.CREATE_RESERVATION(l_reservation_parts,x_return_status,x_msg_data);
2070: IF l_reservation_id <= 0 THEN
2071: ROLLBACK TO choose_options;
2072: x_return_status := FND_API.G_RET_STS_ERROR;
2073: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_COULD_NOT_RESERVE');
2074: FND_MSG_PUB.ADD;
2075: fnd_msg_pub.count_and_get
2076: ( p_count => x_msg_count
2118: l_parts_header.OPERATION := 'CREATE';
2119: l_parts_header.need_by_date :=g_arrival_date;
2120: CSP_PARTS_ORDER.process_order(
2121: p_api_version => 1.0
2122: ,p_Init_Msg_List => FND_API.G_FALSE
2123: ,p_commit => FND_API.G_FALSE
2124: ,px_header_rec => l_parts_header
2125: ,px_line_table => l_parts_lines
2126: ,x_return_status => x_return_status
2119: l_parts_header.need_by_date :=g_arrival_date;
2120: CSP_PARTS_ORDER.process_order(
2121: p_api_version => 1.0
2122: ,p_Init_Msg_List => FND_API.G_FALSE
2123: ,p_commit => FND_API.G_FALSE
2124: ,px_header_rec => l_parts_header
2125: ,px_line_table => l_parts_lines
2126: ,x_return_status => x_return_status
2127: ,x_msg_count => x_msg_count
2127: ,x_msg_count => x_msg_count
2128: ,x_msg_data => x_msg_data
2129: );
2130: END IF;
2131: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2132: ROLLBACK TO CHOOSE_OPTIONS;
2133: x_return_status := FND_API.G_RET_STS_ERROR;
2134: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_UNABLE_TO_ORDER');
2135: FND_MSG_PUB.ADD;
2129: );
2130: END IF;
2131: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2132: ROLLBACK TO CHOOSE_OPTIONS;
2133: x_return_status := FND_API.G_RET_STS_ERROR;
2134: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_UNABLE_TO_ORDER');
2135: FND_MSG_PUB.ADD;
2136: fnd_msg_pub.count_and_get
2137: ( p_count => x_msg_count
2153: END LOOP;
2154: END LOOP;
2155: --CSP_Requirement_Lines_PVT.Update_requirement_lines(
2156: --P_Api_Version_Number => 1.0,
2157: --P_Init_Msg_List => FND_API.G_FALSE,
2158: --P_Commit => FND_API.G_FALSE,
2159: --p_validation_level => FND_API.G_VALID_LEVEL_FULL,
2160: --P_Requirement_Line_Tbl => l_Requirement_Line_Tbl,
2161: --X_Return_Status => x_return_status,
2154: END LOOP;
2155: --CSP_Requirement_Lines_PVT.Update_requirement_lines(
2156: --P_Api_Version_Number => 1.0,
2157: --P_Init_Msg_List => FND_API.G_FALSE,
2158: --P_Commit => FND_API.G_FALSE,
2159: --p_validation_level => FND_API.G_VALID_LEVEL_FULL,
2160: --P_Requirement_Line_Tbl => l_Requirement_Line_Tbl,
2161: --X_Return_Status => x_return_status,
2162: --X_Msg_Count => x_msg_count,
2155: --CSP_Requirement_Lines_PVT.Update_requirement_lines(
2156: --P_Api_Version_Number => 1.0,
2157: --P_Init_Msg_List => FND_API.G_FALSE,
2158: --P_Commit => FND_API.G_FALSE,
2159: --p_validation_level => FND_API.G_VALID_LEVEL_FULL,
2160: --P_Requirement_Line_Tbl => l_Requirement_Line_Tbl,
2161: --X_Return_Status => x_return_status,
2162: --X_Msg_Count => x_msg_count,
2163: --X_Msg_Data => x_msg_data
2161: --X_Return_Status => x_return_status,
2162: --X_Msg_Count => x_msg_count,
2163: --X_Msg_Data => x_msg_data
2164: --);
2165: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2166: ROLLBACK TO choose_options;
2167: return;
2168: END IF;
2169: FOR K IN 1..l_req_line_details_tbl.count LOOP
2190: END IF;
2191: l_requirement_header.ORDER_TYPE_ID := FND_PROFILE.value(name => 'CSP_ORDER_TYPE');
2192: CSP_Requirement_Headers_PVT.Update_requirement_headers(
2193: P_Api_Version_Number => 1.0,
2194: P_Init_Msg_List => FND_API.G_FALSE,
2195: P_Commit => FND_API.G_FALSE,
2196: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
2197: P_REQUIREMENT_HEADER_Rec => l_requirement_header,
2198: X_Return_Status => x_return_status,
2191: l_requirement_header.ORDER_TYPE_ID := FND_PROFILE.value(name => 'CSP_ORDER_TYPE');
2192: CSP_Requirement_Headers_PVT.Update_requirement_headers(
2193: P_Api_Version_Number => 1.0,
2194: P_Init_Msg_List => FND_API.G_FALSE,
2195: P_Commit => FND_API.G_FALSE,
2196: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
2197: P_REQUIREMENT_HEADER_Rec => l_requirement_header,
2198: X_Return_Status => x_return_status,
2199: X_Msg_Count => x_msg_count,
2192: CSP_Requirement_Headers_PVT.Update_requirement_headers(
2193: P_Api_Version_Number => 1.0,
2194: P_Init_Msg_List => FND_API.G_FALSE,
2195: P_Commit => FND_API.G_FALSE,
2196: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
2197: P_REQUIREMENT_HEADER_Rec => l_requirement_header,
2198: X_Return_Status => x_return_status,
2199: X_Msg_Count => x_msg_count,
2200: X_Msg_Data => x_msg_data
2198: X_Return_Status => x_return_status,
2199: X_Msg_Count => x_msg_count,
2200: X_Msg_Data => x_msg_data
2201: );
2202: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2203: ROLLBACK TO choose_options;
2204: return;
2205: END IF;
2206: END IF;
2214: FND_MSG_PUB.ADD;
2215: fnd_msg_pub.count_and_get
2216: ( p_count => x_msg_count
2217: , p_data => x_msg_data);
2218: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
2219: END CHOOSE_OPTION;
2220:
2221: /* PROCEDURE CLEAN_MATERIAL_TRANSACTION(p_api_version_number IN NUMBER
2222: ,p_task_assignment_id IN NUMBER
2255: req_loop NUMBER := 0 ;
2256: reservation_present BOOLEAN := FALSE;
2257: order_present BOOLEAN := FALSE;
2258: BEGIN
2259: x_return_status := FND_API.G_RET_STS_SUCCESS;
2260: SAVEPOINT CLEAN_MATERIAL_TRANSACTION;
2261: OPEN cancel_reserv ;
2262: LOOP
2263: FETCH cancel_reserv INTO l_reserv_id,l_local_reserv_id,l_requirement_line_id;
2267: END IF;
2268: IF l_local_reserv_id IS NOT NULL THEN
2269: CSP_SCH_INT_PVT.CANCEL_RESERVATION(l_local_reserv_id,x_return_status,x_msg_data,x_msg_count);
2270: END IF;
2271: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2272: ROLLBACK TO CLEAN_MATERIAL_TRANSACTION;
2273: x_return_status := FND_API.G_RET_STS_ERROR;
2274: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_RESERV');
2275: FND_MSG_PUB.ADD;
2269: CSP_SCH_INT_PVT.CANCEL_RESERVATION(l_local_reserv_id,x_return_status,x_msg_data,x_msg_count);
2270: END IF;
2271: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2272: ROLLBACK TO CLEAN_MATERIAL_TRANSACTION;
2273: x_return_status := FND_API.G_RET_STS_ERROR;
2274: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_RESERV');
2275: FND_MSG_PUB.ADD;
2276: fnd_msg_pub.count_and_get
2277: ( p_count => x_msg_count
2289: END IF;
2290: l_reserv_id := NULL ;
2291: END LOOP;
2292: CLOSE cancel_reserv;
2293: IF x_return_status = FND_API.G_RET_STS_ERROR THEN
2294: ROLLBACK TO CLEAN_MATERIAL_TRANSACTION;
2295: return;
2296: ELSE
2297: IF reservation_present THEN
2296: ELSE
2297: IF reservation_present THEN
2298: CSP_Requirement_Lines_PVT.Update_requirement_lines(
2299: P_Api_Version_Number => 1.0,
2300: P_Init_Msg_List => FND_API.G_FALSE,
2301: P_Commit => FND_API.G_FALSE,
2302: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
2303: P_Requirement_Line_Tbl => l_Requirement_Line_Tbl,
2304: X_Return_Status => x_return_status,
2297: IF reservation_present THEN
2298: CSP_Requirement_Lines_PVT.Update_requirement_lines(
2299: P_Api_Version_Number => 1.0,
2300: P_Init_Msg_List => FND_API.G_FALSE,
2301: P_Commit => FND_API.G_FALSE,
2302: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
2303: P_Requirement_Line_Tbl => l_Requirement_Line_Tbl,
2304: X_Return_Status => x_return_status,
2305: X_Msg_Count => x_msg_count,
2298: CSP_Requirement_Lines_PVT.Update_requirement_lines(
2299: P_Api_Version_Number => 1.0,
2300: P_Init_Msg_List => FND_API.G_FALSE,
2301: P_Commit => FND_API.G_FALSE,
2302: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
2303: P_Requirement_Line_Tbl => l_Requirement_Line_Tbl,
2304: X_Return_Status => x_return_status,
2305: X_Msg_Count => x_msg_count,
2306: X_Msg_Data => x_msg_data
2304: X_Return_Status => x_return_status,
2305: X_Msg_Count => x_msg_count,
2306: X_Msg_Data => x_msg_data
2307: );
2308: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2309: ROLLBACK TO CLEAN_MATERIAL_TRANSACTION;
2310: return;
2311: END IF;
2312: END IF;
2319: IF l_order_id <> l_previous_order_id THEN
2320: CSP_SCH_INT_PVT.CANCEL_ORDER(l_order_id,x_return_status,x_msg_data,x_msg_count);
2321: l_previous_order_id := l_order_id;
2322: ELSE
2323: x_return_status := FND_API.G_RET_STS_SUCCESS;
2324: END IF;
2325: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2326: x_return_status := FND_API.G_RET_STS_ERROR;
2327: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
2321: l_previous_order_id := l_order_id;
2322: ELSE
2323: x_return_status := FND_API.G_RET_STS_SUCCESS;
2324: END IF;
2325: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2326: x_return_status := FND_API.G_RET_STS_ERROR;
2327: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
2328: FND_MSG_PUB.ADD;
2329: fnd_msg_pub.count_and_get
2322: ELSE
2323: x_return_status := FND_API.G_RET_STS_SUCCESS;
2324: END IF;
2325: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2326: x_return_status := FND_API.G_RET_STS_ERROR;
2327: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
2328: FND_MSG_PUB.ADD;
2329: fnd_msg_pub.count_and_get
2330: ( p_count => x_msg_count
2345: l_requirement_line_id := null;
2346: END IF;
2347: END LOOP;
2348: CLOSE cancel_order;
2349: IF x_return_status = FND_API.G_RET_STS_ERROR THEN
2350: ROLLBACK TO CLEAN_MATERIAL_TRANSACTION;
2351: return;
2352: ELSE
2353: IF order_present then
2352: ELSE
2353: IF order_present then
2354: CSP_Requirement_Lines_PVT.Update_requirement_lines(
2355: P_Api_Version_Number => 1.0,
2356: P_Init_Msg_List => FND_API.G_FALSE,
2357: P_Commit => FND_API.G_FALSE,
2358: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
2359: P_Requirement_Line_Tbl => l_Requirement_Line_Tbl,
2360: X_Return_Status => x_return_status,
2353: IF order_present then
2354: CSP_Requirement_Lines_PVT.Update_requirement_lines(
2355: P_Api_Version_Number => 1.0,
2356: P_Init_Msg_List => FND_API.G_FALSE,
2357: P_Commit => FND_API.G_FALSE,
2358: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
2359: P_Requirement_Line_Tbl => l_Requirement_Line_Tbl,
2360: X_Return_Status => x_return_status,
2361: X_Msg_Count => x_msg_count,
2354: CSP_Requirement_Lines_PVT.Update_requirement_lines(
2355: P_Api_Version_Number => 1.0,
2356: P_Init_Msg_List => FND_API.G_FALSE,
2357: P_Commit => FND_API.G_FALSE,
2358: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
2359: P_Requirement_Line_Tbl => l_Requirement_Line_Tbl,
2360: X_Return_Status => x_return_status,
2361: X_Msg_Count => x_msg_count,
2362: X_Msg_Data => x_msg_data
2360: X_Return_Status => x_return_status,
2361: X_Msg_Count => x_msg_count,
2362: X_Msg_Data => x_msg_data
2363: );
2364: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2365: ROLLBACK TO CLEAN_MATERIAL_TRANSACTION;
2366: return;
2367: END IF;
2368: END IF;
2366: return;
2367: END IF;
2368: END IF;
2369: END IF;
2370: IF x_return_status = FND_API.G_RET_STS_SUCCESS THEN
2371: COMMIT WORK;
2372: END IF;
2373: EXCEPTION
2374: WHEN OTHERS THEN
2379: FND_MSG_PUB.ADD;
2380: fnd_msg_pub.count_and_get
2381: ( p_count => x_msg_count
2382: , p_data => x_msg_data);
2383: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
2384:
2385: END CLEAN_MATERIAL_TRANSACTION;*/
2386:
2387: PROCEDURE CLEAN_MATERIAL_TRANSACTION(p_api_version_number IN NUMBER
2398: fnd_log.string(fnd_log.level_statement,
2399: 'csp.plsql.csp_sch_int_pvt.clean_material_transaction',
2400: 'p_task_assignment_id = ' || p_task_assignment_id);
2401: end if;
2402: x_return_status := FND_API.G_RET_STS_SUCCESS;
2403:
2404: /*
2405: CLEAN_REQUIREMENT(
2406: p_api_version_number => p_api_version_number,
2486: fnd_log.string(fnd_log.level_statement, l_module_name,
2487: 'begin...');
2488: end if;
2489:
2490: x_return_status := FND_API.G_RET_STS_SUCCESS;
2491:
2492: -- check for the fully rcvd case
2493: -- if yes then do not clear this
2494: -- choose option will take care of it
2570: fnd_log.string(fnd_log.level_statement, l_module_name,
2571: 'after cancelling reservation... x_return_status = ' || x_return_status);
2572: end if;
2573:
2574: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2575: --x_return_status := FND_API.G_RET_STS_SUCCESS;
2576: rollback to CLEAN_MATERIAL_TRANSACTION;
2577: return;
2578: ELSE
2571: 'after cancelling reservation... x_return_status = ' || x_return_status);
2572: end if;
2573:
2574: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2575: --x_return_status := FND_API.G_RET_STS_SUCCESS;
2576: rollback to CLEAN_MATERIAL_TRANSACTION;
2577: return;
2578: ELSE
2579: CSP_REQ_LINE_DETAILS_PKG.Delete_Row(l_req_details_line_id);
2585: fnd_log.string(fnd_log.level_statement, l_module_name,
2586: 'after reservation loop... x_return_status = ' || x_return_status);
2587: end if;
2588:
2589: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2590: --x_return_status := FND_API.G_RET_STS_SUCCESS;
2591: rollback to CLEAN_MATERIAL_TRANSACTION;
2592: return;
2593: ELSE
2586: 'after reservation loop... x_return_status = ' || x_return_status);
2587: end if;
2588:
2589: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2590: --x_return_status := FND_API.G_RET_STS_SUCCESS;
2591: rollback to CLEAN_MATERIAL_TRANSACTION;
2592: return;
2593: ELSE
2594: OPEN get_orders;
2640: fnd_log.string(fnd_log.level_statement, l_module_name,
2641: 'after CANCEL_ORDER... x_return_status = ' || x_return_status);
2642: end if;
2643:
2644: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2645: --x_return_status := FND_API.G_RET_STS_SUCCESS;
2646: rollback to CLEAN_MATERIAL_TRANSACTION;
2647:
2648: -- bug # 14084319
2641: 'after CANCEL_ORDER... x_return_status = ' || x_return_status);
2642: end if;
2643:
2644: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2645: --x_return_status := FND_API.G_RET_STS_SUCCESS;
2646: rollback to CLEAN_MATERIAL_TRANSACTION;
2647:
2648: -- bug # 14084319
2649: -- we assume the error is due to the custom OM constraints
2672:
2673: END LOOP;
2674: close get_orders;
2675:
2676: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2677: rollback to CLEAN_MATERIAL_TRANSACTION;
2678: return;
2679: END IF;
2680:
2708: end if;
2709:
2710: CSP_Requirement_Headers_PVT.Update_requirement_headers(
2711: P_Api_Version_Number => 1.0,
2712: P_Init_Msg_List => FND_API.G_FALSE,
2713: P_Commit => FND_API.G_FALSE,
2714: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
2715: P_REQUIREMENT_HEADER_Rec => l_requirement_header,
2716: X_Return_Status => x_return_status,
2709:
2710: CSP_Requirement_Headers_PVT.Update_requirement_headers(
2711: P_Api_Version_Number => 1.0,
2712: P_Init_Msg_List => FND_API.G_FALSE,
2713: P_Commit => FND_API.G_FALSE,
2714: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
2715: P_REQUIREMENT_HEADER_Rec => l_requirement_header,
2716: X_Return_Status => x_return_status,
2717: X_Msg_Count => x_msg_count,
2710: CSP_Requirement_Headers_PVT.Update_requirement_headers(
2711: P_Api_Version_Number => 1.0,
2712: P_Init_Msg_List => FND_API.G_FALSE,
2713: P_Commit => FND_API.G_FALSE,
2714: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
2715: P_REQUIREMENT_HEADER_Rec => l_requirement_header,
2716: X_Return_Status => x_return_status,
2717: X_Msg_Count => x_msg_count,
2718: X_Msg_Data => x_msg_data
2723: 'after updating req header... x_return_status = ' || x_return_status);
2724: end if;
2725:
2726: END IF;
2727: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2728: --x_return_status := FND_API.G_RET_STS_SUCCESS;
2729: rollback to CLEAN_MATERIAL_TRANSACTION;
2730: return;
2731: END IF;
2724: end if;
2725:
2726: END IF;
2727: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2728: --x_return_status := FND_API.G_RET_STS_SUCCESS;
2729: rollback to CLEAN_MATERIAL_TRANSACTION;
2730: return;
2731: END IF;
2732:
2740: l_api_name varchar2(60) := 'CSP_SCH_INT_PVT.CANCEL_RESERVATION';
2741: l_api_version_number NUMBER := 1.0;
2742: l_return_status VARCHAR2(3);
2743: l_msg_count NUMBER;
2744: l_init_msg_lst VARCHAR2(1) := fnd_api.g_true;
2745: l_msg_data VARCHAR2(2000);
2746: l_rsv_rec inv_reservation_global.mtl_reservation_rec_type;
2747: l_serial_number inv_reservation_global.serial_number_tbl_type;
2748: BEGIN
2745: l_msg_data VARCHAR2(2000);
2746: l_rsv_rec inv_reservation_global.mtl_reservation_rec_type;
2747: l_serial_number inv_reservation_global.serial_number_tbl_type;
2748: BEGIN
2749: x_return_status := FND_API.G_RET_STS_SUCCESS;
2750: l_rsv_rec.reservation_id := p_reserv_id ;
2751: INV_RESERVATION_PUB.delete_reservation(l_api_version_number
2752: ,l_init_msg_lst
2753: ,x_return_status
2764: FND_MSG_PUB.ADD;
2765: fnd_msg_pub.count_and_get
2766: ( p_count => x_msg_count
2767: , p_data => x_msg_data);
2768: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
2769:
2770: END CANCEL_RESERVATION;
2771:
2772: PROCEDURE CANCEL_ORDER(p_order_id IN NUMBER
2777: l_parts_lines csp_parts_requirement.Line_Tbl_type;
2778: l_api_version NUMBER := 1.0;
2779: l_api_name varchar2(60) := 'CSP_SCH_INT_PVT.CANCEL_ORDER';
2780: BEGIN
2781: x_return_status := FND_API.G_RET_STS_SUCCESS;
2782: l_parts_header.order_header_id := p_order_id;
2783: --l_parts_header.operation := 'CANCEL';
2784: fnd_profile.get('CSP_CANCEL_REASON', l_parts_header.change_Reason);
2785:
2801: FND_MSG_PUB.ADD;
2802: fnd_msg_pub.count_and_get
2803: ( p_count => x_msg_count
2804: , p_data => x_msg_data);
2805: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
2806: END CANCEL_ORDER;
2807: PROCEDURE CREATE_ORDERS(p_api_version_number IN NUMBER
2808: ,p_task_assignment_id IN NUMBER
2809: ,x_return_status OUT NOCOPY VARCHAR2
2847: l_parts_header.OPERATION := 'UPDATE';
2848: l_parts_header.order_header_id := l_previous_header_id;
2849: CSP_PARTS_ORDER.process_order(
2850: p_api_version => 1.0
2851: ,p_Init_Msg_List => FND_API.G_FALSE
2852: ,p_commit => FND_API.G_FALSE
2853: ,px_header_rec => l_parts_header
2854: ,px_line_table => l_parts_lines
2855: ,p_process_type => 'ORDER'
2848: l_parts_header.order_header_id := l_previous_header_id;
2849: CSP_PARTS_ORDER.process_order(
2850: p_api_version => 1.0
2851: ,p_Init_Msg_List => FND_API.G_FALSE
2852: ,p_commit => FND_API.G_FALSE
2853: ,px_header_rec => l_parts_header
2854: ,px_line_table => l_parts_lines
2855: ,p_process_type => 'ORDER'
2856: ,x_return_status => x_return_status
2856: ,x_return_status => x_return_status
2857: ,x_msg_count => x_msg_count
2858: ,x_msg_data => x_msg_data
2859: );
2860: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2861: ROLLBACK TO CREATE_ORDERS;
2862: x_return_status := FND_API.G_RET_STS_ERROR;
2863: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_UNABLE_TO_ORDER');
2864: FND_MSG_PUB.ADD;
2858: ,x_msg_data => x_msg_data
2859: );
2860: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2861: ROLLBACK TO CREATE_ORDERS;
2862: x_return_status := FND_API.G_RET_STS_ERROR;
2863: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_UNABLE_TO_ORDER');
2864: FND_MSG_PUB.ADD;
2865: fnd_msg_pub.count_and_get
2866: ( p_count => x_msg_count
2873: l_parts_lines(rec_count).booked_flag := 'Y';
2874: rec_count := rec_count + 1;
2875: END LOOP;
2876: CLOSE get_orders;
2877: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2878: RETURN;
2879: END IF;
2880: END CREATE_ORDERS;
2881:
2952: l_reservation_id NUMBER;
2953: x_reservation_id NUMBER;
2954: l_header_id NUMBER;
2955: BEGIN
2956: x_return_status := FND_API.G_RET_STS_SUCCESS;
2957: SAVEPOINT CREATE_ORDERS;
2958: OPEN get_resource(p_task_assignment_id);
2959: LOOP
2960: FETCH get_resource INTO l_resource_id,l_resource_type;
3041: l_parts_header.DEST_ORGANIZATION_ID := l_destination_org_id;
3042: l_parts_header.OPERATION := 'CREATE';
3043: CSP_PARTS_ORDER.process_order(
3044: p_api_version => 1.0
3045: ,p_Init_Msg_List => FND_API.G_FALSE
3046: ,p_commit => FND_API.G_FALSE
3047: ,px_header_rec => l_parts_header
3048: ,px_line_table => l_parts_lines
3049: ,x_return_status => l_return_status
3042: l_parts_header.OPERATION := 'CREATE';
3043: CSP_PARTS_ORDER.process_order(
3044: p_api_version => 1.0
3045: ,p_Init_Msg_List => FND_API.G_FALSE
3046: ,p_commit => FND_API.G_FALSE
3047: ,px_header_rec => l_parts_header
3048: ,px_line_table => l_parts_lines
3049: ,x_return_status => l_return_status
3050: ,x_msg_count => l_msg_count
3049: ,x_return_status => l_return_status
3050: ,x_msg_count => l_msg_count
3051: ,x_msg_data => l_msg_data
3052: );
3053: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
3054: ROLLBACK TO CREATE_ORDERS;
3055: x_return_status := FND_API.G_RET_STS_ERROR;
3056: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_UNABLE_TO_ORDER');
3057: FND_MSG_PUB.ADD;
3051: ,x_msg_data => l_msg_data
3052: );
3053: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
3054: ROLLBACK TO CREATE_ORDERS;
3055: x_return_status := FND_API.G_RET_STS_ERROR;
3056: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_UNABLE_TO_ORDER');
3057: FND_MSG_PUB.ADD;
3058: fnd_msg_pub.count_and_get
3059: ( p_count => x_msg_count
3069: ,x_return_status => x_return_status
3070: ,x_reservation_id => x_reservation_id
3071: ,x_msg_data => x_msg_data
3072: ,x_msg_count => x_msg_count);
3073: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
3074: Rollback to CREATE_ORDERS;
3075: x_msg_data := ' Unable to Transfer Reservations';
3076: x_return_status := FND_API.G_RET_STS_ERROR;
3077: return;
3072: ,x_msg_count => x_msg_count);
3073: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
3074: Rollback to CREATE_ORDERS;
3075: x_msg_data := ' Unable to Transfer Reservations';
3076: x_return_status := FND_API.G_RET_STS_ERROR;
3077: return;
3078: ELSE
3079: l_requrements_lines(I).reservation_id := x_reservation_id;
3080: END IF;
3080: END IF;
3081: END LOOP;
3082: CSP_Requirement_Lines_PVT.Update_requirement_lines(
3083: P_Api_Version_Number => 1.0,
3084: P_Init_Msg_List => FND_API.G_FALSE,
3085: P_Commit => FND_API.G_FALSE,
3086: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
3087: P_Requirement_Line_Tbl => l_requrements_lines,
3088: X_Return_Status => l_return_status,
3081: END LOOP;
3082: CSP_Requirement_Lines_PVT.Update_requirement_lines(
3083: P_Api_Version_Number => 1.0,
3084: P_Init_Msg_List => FND_API.G_FALSE,
3085: P_Commit => FND_API.G_FALSE,
3086: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
3087: P_Requirement_Line_Tbl => l_requrements_lines,
3088: X_Return_Status => l_return_status,
3089: X_Msg_Count => l_msg_count,
3082: CSP_Requirement_Lines_PVT.Update_requirement_lines(
3083: P_Api_Version_Number => 1.0,
3084: P_Init_Msg_List => FND_API.G_FALSE,
3085: P_Commit => FND_API.G_FALSE,
3086: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
3087: P_Requirement_Line_Tbl => l_requrements_lines,
3088: X_Return_Status => l_return_status,
3089: X_Msg_Count => l_msg_count,
3090: X_Msg_Data => l_msg_data
3088: X_Return_Status => l_return_status,
3089: X_Msg_Count => l_msg_count,
3090: X_Msg_Data => l_msg_data
3091: ) ;
3092: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
3093: ROLLBACK TO CREATE_ORDERS;
3094: return;
3095: END IF;
3096: END IF;
3102: FND_MSG_PUB.ADD;
3103: fnd_msg_pub.count_and_get
3104: ( p_count => x_msg_count
3105: , p_data => x_msg_data);
3106: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
3107: END CREATE_ORDERS;*/
3108:
3109: PROCEDURE GET_ORGANIZATION_SUBINV( p_resources IN CSP_SCH_INT_PVT.csp_sch_resource_tbl_typ
3110: ,x_resource_org_subinv OUT NOCOPY CSP_SCH_INT_PVT.csp_resource_org_tbl_typ
3130: l_msg_data number;
3131: l_resource_name varchar2(1000);
3132: l_resource_type_name varchar2(1000);
3133: BEGIN
3134: x_return_status := FND_API.G_RET_STS_SUCCESS;
3135: x_resource_org_subinv := CSP_SCH_INT_PVT.csp_resource_org_tbl_typ();
3136: FOR I IN 1..p_resources.count
3137: LOOP
3138: OPEN csp_resource_org(p_resources(I).resource_id, p_resources(I).resource_type);
3158: FND_MSG_PUB.ADD;
3159: fnd_msg_pub.count_and_get( p_count => x_msg_count
3160: , p_data => x_msg_data);
3161: -- x_msg_data := 'Default organization and subinventory not defined for ' || l_resource_type_name || ' ' || l_resource_name ;
3162: x_return_status := FND_API.G_RET_STS_ERROR;
3163: return;
3164: END IF;
3165: CLOSE csp_resource_org;
3166: x_resource_org_subinv.extend;
3177: FND_MSG_PUB.ADD;
3178: fnd_msg_pub.count_and_get
3179: ( p_count => x_msg_count
3180: , p_data => x_msg_data);
3181: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
3182: END GET_ORGANIZATION_SUBINV;
3183:
3184: PROCEDURE GET_PARTS_LIST(p_task_id IN NUMBER
3185: ,p_likelihood IN NUMBER
3209: l_line_id NUMBER;
3210:
3211: BEGIN
3212: -- savepoint GET_PARTS_LIST;
3213: x_return_status := FND_API.G_RET_STS_SUCCESS ;
3214: --x_parts_list := CSP_SCH_INT_PVT.csp_parts_tbl_typ1();
3215: OPEN parts_list(p_task_id, p_likelihood);
3216: LOOP
3217: FETCH parts_list INTO part_number, part_quantity , part_uom , l_ship_complet,l_revision , l_line_id;
3234: FND_MSG_PUB.ADD;
3235: fnd_msg_pub.count_and_get
3236: ( p_count => x_msg_count
3237: , p_data => x_msg_data);
3238: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
3239: return;
3240: END GET_PARTS_LIST;
3241: PROCEDURE CHECK_LOCAl_INVENTORY(p_resource_org_subinv IN CSP_SCH_INT_PVT.CSP_RESOURCE_ORG_tbl_TYP
3242: ,p_parts_list IN CSP_SCH_INT_PVT.CSP_PARTS_TBL_TYP1
3288: l_reservation_id NUMBER;
3289: l_res_ids CSP_SUPERSESSIONS_PVT.NUMBER_ARR;
3290: BEGIN
3291: savepoint csp_check_local_inv;
3292: x_return_status := FND_API.G_RET_STS_SUCCESS;
3293: x_unavailable_list:= CSP_SCH_INT_PVT.CSP_UNAVAILABILITY_TBL_TYPE();
3294: x_available_list := CSP_SCH_INT_PVT.CSP_AVAILABILITY_TBL_TYPE();
3295: if l_res_ids.count > 0 THEN
3296: l_res_ids.delete;
3343: , p_inventory_item_id => p_parts_list(J).item_id
3344: , p_subinventory_code => p_resource_org_subinv(I).sub_inv_code
3345: , x_qoh => l_onhand
3346: , x_atr => l_available
3347: , p_init_msg_lst => fnd_api.g_false
3348: , p_tree_mode => inv_quantity_tree_pvt.g_transaction_mode
3349: , p_is_revision_control => l_revision_controlled
3350: , p_is_lot_control => NULL
3351: , p_is_serial_control => NULL
3359: , x_return_status => l_return_status
3360: , x_msg_count => l_msg_count
3361: , x_msg_data => l_msg_data
3362: );
3363: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
3364: l_att := 0;
3365: END IF;
3366: /*OPEN reservation_check(p_resource_org_subinv(I).organization_id, p_resource_org_subinv(I).sub_inv_code,p_parts_list(J).item_id);
3367: LOOP
3460: , p_inventory_item_id => l_alternate_parts(k)
3461: , p_subinventory_code => p_resource_org_subinv(I).sub_inv_code
3462: , x_qoh => l_onhand
3463: , x_atr => l_available
3464: , p_init_msg_lst => fnd_api.g_false
3465: , p_tree_mode => inv_quantity_tree_pvt.g_transaction_mode
3466: , p_is_revision_control => NULL
3467: , p_is_lot_control => NULL
3468: , p_is_serial_control => NULL
3600: FND_MSG_PUB.ADD;
3601: fnd_msg_pub.count_and_get
3602: ( p_count => x_msg_count
3603: , p_data => x_msg_data);
3604: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
3605: return;
3606: END CHECK_LOCAl_INVENTORY;
3607: --hehxxx
3608: PROCEDURE SPARES_CHECK(p_unavailable_list IN CSP_SCH_INT_PVT.CSP_UNAVAILABILITY_TBL_TYPE
4143: log('spares_check2','l_transfer_cost:'||l_transfer_cost);
4144: end if;*/
4145: end loop;
4146: if p_mandatory and l_available <> 'Y' then
4147: x_return_status := fnd_api.g_ret_sts_error;
4148: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NO_PARTS');
4149: FND_MSG_PUB.ADD;
4150: fnd_msg_pub.count_and_get
4151: ( p_count => x_msg_count
4220: l_assignment_set_id NUMBER;
4221: l_unavailable varchar2(1);
4222: BEGIN
4223: log('do_atp_check', 'Begin');
4224: x_return_status := FND_API.G_RET_STS_SUCCESS;
4225: x_final_unavailable_list := CSP_SCH_INT_PVT.CSP_UNAVAILABILITY_TBL_TYPE();
4226: OPEN instance;
4227: FETCH instance INTO l_instance_id;
4228: CLOSE instance;
4287: log('do_atp_check', 'after MRP_ATP_PUB.CALL_ATP');
4288: log('do_atp_check', 'x_return_status: '||x_return_status);
4289: log('do_atp_check', 'x_msg_data: '||x_msg_data);
4290: log('do_atp_check', 'x_msg_count: '||x_msg_count);
4291: l_msg := FND_MSG_PUB.Get(1,FND_API.G_FALSE) ;
4292:
4293: rollback to csp_msc_atp_check;
4294: IF x_return_status = FND_API.G_RET_STS_SUCCESS THEN
4295: l_unavailable := 'Y';
4290: log('do_atp_check', 'x_msg_count: '||x_msg_count);
4291: l_msg := FND_MSG_PUB.Get(1,FND_API.G_FALSE) ;
4292:
4293: rollback to csp_msc_atp_check;
4294: IF x_return_status = FND_API.G_RET_STS_SUCCESS THEN
4295: l_unavailable := 'Y';
4296: log('do_atp_check', 'begin l_atp_rec_out.Inventory_Item_Id loop. count: '||l_atp_rec_out.Inventory_Item_Id.count);
4297: FOR I IN 1..l_atp_rec_out.Inventory_Item_Id.count LOOP
4298: log('do_atp_check', 'l_atp_rec_out.Error_Code('||I||'): '||l_atp_rec_out.Error_Code(I));
4319: ( p_count => x_msg_count
4320: , p_data => x_msg_data);
4321:
4322: END IF;
4323: x_return_status := FND_API.G_RET_STS_ERROR;
4324: OPEN error_message(l_atp_rec_out.Error_Code(I));
4325: FETCH error_message INTO l_message;
4326: CLOSE error_message;
4327: l_item_segments := null;
4351: ( p_count => x_msg_count
4352: , p_data => x_msg_data);
4353:
4354: END IF;
4355: x_return_status := FND_API.G_RET_STS_ERROR;
4356: OPEN error_message(l_atp_rec_out.Error_Code(I));
4357: FETCH error_message INTO l_message;
4358: CLOSE error_message;
4359: l_item_segments := null;
4462: FND_MSG_PUB.ADD;
4463: fnd_msg_pub.count_and_get
4464: ( p_count => x_msg_count
4465: , p_data => x_msg_data);
4466: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
4467: return;
4468:
4469: END DO_ATP_CHECK;
4470:
4480:
4481: resource_eligible BOOLEAN := TRUE;
4482: l_api_name VARCHAR2(60) := 'CSP_SCH_INT_PVT.ELIGIBLE_RESOURCES';
4483: BEGIN
4484: x_return_status := FND_API.G_RET_STS_SUCCESS;
4485: x_eligible_resources_list := CSP_SCH_INT_PVT.CSP_AVAILABILITY_TBL_TYPE();
4486:
4487: FOR I IN 1..p_resource_list.count LOOP
4488:
4522: FND_MSG_PUB.ADD;
4523: fnd_msg_pub.count_and_get
4524: ( p_count => x_msg_count
4525: , p_data => x_msg_data);
4526: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
4527: return;
4528: END ELIGIBLE_RESOURCES;
4529:
4530: PROCEDURE GET_TIME_COST(p_eligible_resources_list IN CSP_SCH_INT_PVT.CSP_AVAILABILITY_TBL_TYPE
4546: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,
4547: 'csp.plsql.CSP_SCH_INT_PVT.GET_TIME_COST',
4548: 'begin...');
4549: end if;
4550: x_return_status := FND_API.G_RET_STS_SUCCESS;
4551: l_temp_options := CSP_SCH_INT_PVT.CSP_SHIP_PARAMETERS_TBL_TYPE();
4552: l_temp_resources_list := CSP_SCH_INT_PVT.CSP_AVAILABILITY_TBL_TYPE();
4553: l_options := CSP_SCH_INT_PVT.CSP_SHIP_PARAMETERS_TBL_TYPE();
4554: l_resources := CSP_SCH_INT_PVT.CSP_AVAILABILITY_TBL_TYPE();
4580: l_temp_resources_list(l_temp_resources_list.count).sub_inventory := p_eligible_resources_list(loop_count).sub_inventory;
4581: l_temp_resources_list(l_temp_resources_list.count).available_date := p_eligible_resources_list(loop_count).available_date;
4582: IF loop_count = p_eligible_resources_list.count THEN
4583: CSP_SCH_INT_PVT.OPTIMIZE_OPTIONS(l_temp_resources_list,l_temp_options,l_ship_count,l_res_ship_parameters,x_return_status,x_msg_data,x_msg_count);
4584: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4585: RETURN;
4586: END IF;
4587: CSP_SCH_INT_PVT.BUILD_FINAL_LIST(l_temp_options,x_options,x_return_status,x_msg_data,x_msg_count);
4588: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4584: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4585: RETURN;
4586: END IF;
4587: CSP_SCH_INT_PVT.BUILD_FINAL_LIST(l_temp_options,x_options,x_return_status,x_msg_data,x_msg_count);
4588: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4589: RETURN;
4590: END IF;
4591: l_temp_options.trim(l_temp_options.count);
4592: l_temp_resources_list.trim(l_temp_resources_list.count);
4592: l_temp_resources_list.trim(l_temp_resources_list.count);
4593: END IF;
4594: ELSE
4595: CSP_SCH_INT_PVT.OPTIMIZE_OPTIONS(l_temp_resources_list,l_temp_options,l_ship_count,l_res_ship_parameters,x_return_status,x_msg_data,x_msg_count);
4596: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4597: RETURN;
4598: END IF;
4599: CSP_SCH_INT_PVT.BUILD_FINAL_LIST(l_temp_options,x_options,x_return_status,x_msg_data,x_msg_count);
4600: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4596: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4597: RETURN;
4598: END IF;
4599: CSP_SCH_INT_PVT.BUILD_FINAL_LIST(l_temp_options,x_options,x_return_status,x_msg_data,x_msg_count);
4600: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4601: RETURN;
4602: END IF;
4603: l_temp_options.trim(l_temp_options.count);
4604: l_temp_resources_list.trim(l_temp_resources_list.count);
4612: l_temp_resources_list(l_temp_resources_list.count).available_date := p_eligible_resources_list(loop_count).available_date;
4613: END IF;
4614: IF loop_count = p_eligible_resources_list.count THEN
4615: CSP_SCH_INT_PVT.OPTIMIZE_OPTIONS(l_temp_resources_list,l_temp_options,l_ship_count,l_res_ship_parameters,x_return_status,x_msg_data,x_msg_count);
4616: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4617: RETURN;
4618: END IF;
4619: CSP_SCH_INT_PVT.BUILD_FINAL_LIST(l_temp_options,x_options,x_return_status,x_msg_data,x_msg_count);
4620: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4616: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4617: RETURN;
4618: END IF;
4619: CSP_SCH_INT_PVT.BUILD_FINAL_LIST(l_temp_options,x_options,x_return_status,x_msg_data,x_msg_count);
4620: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4621: RETURN;
4622: END IF;
4623: l_temp_options.trim(l_temp_options.count);
4624: l_temp_resources_list.trim(l_temp_resources_list.count);
4658: 'csp.plsql.CSP_SCH_INT_PVT.GET_TIME_COST',
4659: 'After calling CSP_SCH_INT_PVT.OPTIMIZE_OPTIONS... l_temp_options.count=' || l_temp_options.count);
4660: end if;
4661:
4662: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4663: RETURN;
4664: END IF;
4665:
4666: if(FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
4679: 'csp.plsql.CSP_SCH_INT_PVT.GET_TIME_COST',
4680: 'After calling BUILD_FINAL_LIST... x_options.count=' || x_options.count);
4681: end if;
4682:
4683: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4684: RETURN;
4685: END IF;
4686:
4687: l_temp_options.trim(l_temp_options.count);
4706: FND_MSG_PUB.ADD;
4707: fnd_msg_pub.count_and_get
4708: ( p_count => x_msg_count
4709: , p_data => x_msg_data);
4710: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
4711: return;
4712: END GET_TIME_COST;
4713: PROCEDURE BUILD_FINAL_LIST(p_temp_options IN CSP_SCH_INT_PVT.CSP_SHIP_PARAMETERS_TBL_TYPE
4714: ,px_options IN OUT NOCOPY CSP_SCH_INT_PVT.csp_sch_options_tbl_typ
4723: l_need_by_date := g_interval.latest_time;
4724: ELSE
4725: l_need_by_date := g_interval.earliest_time;
4726: END IF;
4727: x_return_status := FND_API.G_RET_STS_SUCCESS;
4728: FOR I IN 1..p_temp_options.count LOOP
4729: -- IF round(p_temp_options(I).arrival_date,'MI') <= round(l_need_by_date,'MI') THEN
4730: px_options.extend;
4731: px_options(px_options.count).resource_type := p_temp_options(I).resource_type;
4747: FND_MSG_PUB.ADD;
4748: fnd_msg_pub.count_and_get
4749: ( p_count => x_msg_count
4750: , p_data => x_msg_data);
4751: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
4752: return;
4753: END BUILD_FINAL_LIST;
4754:
4755: PROCEDURE OPTIMIZE_OPTIONS(p_eligible_resources IN CSP_SCH_INT_PVT.CSP_AVAILABILITY_TBL_TYPE
4797: l_shipping_methods varchar2(2000);
4798: l_to_org_id NUMBER;
4799: l_loc_ship_method_count NUMBER := 0;
4800: BEGIN
4801: x_return_status := FND_API.G_RET_STS_SUCCESS ;
4802: l_resource_shipping_parameters := CSP_SCH_INT_PVT.CSP_ORGS_SHIP_PARAM_TBL_TYPE() ;
4803: l_temp_rec := CSP_SCH_INT_PVT.CSP_ORGS_SHIP_PARAM_TBL_TYPE() ;
4804: x_ship_count := CSP_SCH_INT_PVT.CSP_SHIP_METHOD_COUNT_TBL_TYP() ;
4805: l_ship_quantity := CSP_SCH_INT_PVT.CSP_SHIP_QUANTITY_TBL_TYPE() ;
4856: 'csp.plsql.CSP_SCH_INT_PVT.OPTIMIZE_OPTIONS',
4857: 'After calling CONSOLIDATE_QUANTITIES...l_ship_quantity.count=' || l_ship_quantity.count);
4858: end if;
4859:
4860: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4861: return;
4862: END IF;
4863:
4864: if(FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
4880: 'csp.plsql.CSP_SCH_INT_PVT.OPTIMIZE_OPTIONS',
4881: 'After calling GET_SHIPPING_PARAMETERS...x_ship_count.count=' || x_ship_count.count);
4882: end if;
4883:
4884: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4885: return;
4886: END IF;
4887:
4888: x_ship_parameters := l_resource_shipping_parameters;
5230: FND_MSG_PUB.ADD;
5231: fnd_msg_pub.count_and_get
5232: ( p_count => x_msg_count
5233: , p_data => x_msg_data);
5234: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
5235: return;
5236: END OPTIMIZE_OPTIONS;
5237:
5238: PROCEDURE CONSOLIDATE_QUANTITIES(p_eligible_resources_list IN CSP_SCH_INT_PVT.CSP_AVAILABILITY_TBL_TYPE
5244: J NUMBER;
5245: available BOOLEAN;
5246: l_api_name VARCHAR2(60) := 'CSP_SCH_INT_PVT.CONSOLIDATE_QUANTITIES';
5247: BEGIN
5248: x_return_status := FND_API.G_RET_STS_SUCCESS ;
5249: x_ship_quantity := CSP_SCH_INT_PVT.CSP_SHIP_QUANTITY_TBL_TYPE();
5250: x_ship_quantity.trim(x_ship_quantity.count);
5251: FOR I IN 1..p_eligible_resources_list.count LOOP
5252: IF p_eligible_resources_list(I).sub_inventory IS NULL THEN
5292: FND_MSG_PUB.ADD;
5293: fnd_msg_pub.count_and_get
5294: ( p_count => x_msg_count
5295: , p_data => x_msg_data);
5296: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
5297: return;
5298: END CONSOLIDATE_QUANTITIES;
5299:
5300: PROCEDURE GET_SHIPPING_PARAMETERS(p_ship_quantity IN CSP_SCH_INT_PVT.CSP_SHIP_QUANTITY_TBL_TYPE,
5378: l_ship_method_present_for_loc boolean := false;
5379: l_ship_method_present_for_reg boolean :=false;
5380: BEGIN
5381: l_server_sys_date := sysdate;
5382: x_return_status := FND_API.G_RET_STS_SUCCESS;
5383: l_default_unit_for_hour := FND_PROFILE.VALUE(NAME => 'CSF_UOM_HOURS');
5384: l_server_time_zone_id := FND_PROFILE.VALUE(NAME => 'SERVER_TIMEZONE_ID');
5385:
5386: IF g_interval.latest_time IS NOT NULL
5405: CLOSE C2;
5406: END IF;
5407: IF l_shipto_timezone_id <> l_server_time_zone_id THEN
5408: HZ_TIMEZONE_PUB.Get_Time( p_api_version => 1.0,
5409: p_init_msg_list => FND_API.G_FALSE,
5410: p_source_tz_id => l_server_time_zone_id,
5411: p_dest_tz_id => l_shipto_timezone_id,
5412: p_source_day_time => sysdate,
5413: x_dest_day_time => l_sysdate,
5446: END IF;
5447: l_delivery_date := trunc(l_sysdate + l_lead_time);
5448: IF l_shipto_timezone_id <> l_server_time_zone_id THEN
5449: HZ_TIMEZONE_PUB.Get_Time( p_api_version => 1.0,
5450: p_init_msg_list => FND_API.G_FALSE,
5451: p_source_tz_id => l_shipto_timezone_id,
5452: p_dest_tz_id => l_server_time_zone_id,
5453: p_source_day_time => l_delivery_date,
5454: x_dest_day_time => l_server_delivery_date,
5531: END IF;
5532:
5533: IF l_shipto_timezone_id <> l_server_time_zone_id THEN
5534: HZ_TIMEZONE_PUB.Get_Time( p_api_version => 1.0,
5535: p_init_msg_list => FND_API.G_FALSE,
5536: p_source_tz_id => l_shipto_timezone_id,
5537: p_dest_tz_id => l_server_time_zone_id,
5538: p_source_day_time => l_delivery_date,
5539: x_dest_day_time => l_server_delivery_date,
5545: END IF;
5546:
5547: IF l_cutoff_time is not null then
5548: HZ_TIMEZONE_PUB.Get_Time( p_api_version => 1.0,
5549: p_init_msg_list => FND_API.G_FALSE,
5550: p_source_tz_id => l_timezone_id,
5551: p_dest_tz_id => l_server_time_zone_id,
5552: p_source_day_time => l_cutoff_time,
5553: x_dest_day_time => l_server_cutoff_time,
5616: FND_MSG_PUB.ADD;
5617: fnd_msg_pub.count_and_get
5618: ( p_count => x_msg_count
5619: , p_data => x_msg_data);
5620: x_return_status := FND_API.G_RET_STS_ERROR;
5621: return;
5622: END IF;
5623: IF csp_ship_methodes%ISOPEN THEN
5624: CLOSE csp_ship_methodes;
5643: FND_MSG_PUB.ADD;
5644: fnd_msg_pub.count_and_get
5645: ( p_count => x_msg_count
5646: , p_data => x_msg_data);
5647: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
5648: return;
5649: END GET_SHIPPING_PARAMETERS;
5650: PROCEDURE GET_DELIVERY_DATE(p_relation_ship_id IN NUMBER,
5651: x_delivery_date OUT NOCOPY DATE,
5670: l_delivery_date DATE;
5671: l_default_unit_for_hour varchar2(3);
5672: l_api_name varchar2(60) := 'CSP_SCH_INT_PVT.GET_DELIVERY_DATE' ;
5673: BEGIN
5674: x_return_status := FND_API.G_RET_STS_SUCCESS ;
5675: l_default_unit_for_hour := FND_PROFILE.VALUE(NAME => 'CSF_UOM_HOURS');
5676: OPEN C1(p_relation_ship_id);
5677: LOOP
5678: FETCH C1 INTO l_lead_time,l_lead_time_uom,l_delivery_time,l_cutoff_time, l_timezone_id, l_saftey_zone;
5719: FND_MSG_PUB.ADD;
5720: fnd_msg_pub.count_and_get
5721: ( p_count => x_msg_count
5722: , p_data => x_msg_data);
5723: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
5724: return;
5725: END GET_DELIVERY_DATE;
5726:
5727: PROCEDURE EXTEND_ATP_REC(p_atp_rec IN OUT NOCOPY mrp_atp_pub.atp_rec_typ
5727: PROCEDURE EXTEND_ATP_REC(p_atp_rec IN OUT NOCOPY mrp_atp_pub.atp_rec_typ
5728: ,x_return_status OUT NOCOPY VARCHAR2) IS
5729:
5730: BEGIN
5731: x_return_status := FND_API.G_RET_STS_SUCCESS;
5732: p_atp_rec.Row_Id.Extend;
5733: p_atp_rec.Instance_Id.Extend;
5734: p_atp_rec.Inventory_Item_Id.Extend;
5735: p_atp_rec.Inventory_Item_Name.Extend;
5778: p_atp_rec.Old_Source_Organization_Id.EXTEND;
5779: p_atp_rec.Old_Demand_Class.EXTEND;
5780: EXCEPTION
5781: WHEN OTHERS THEN
5782: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
5783: return;
5784: END EXTEND_ATP_REC;
5785:
5786: FUNCTION CREATE_RESERVATION(p_reservation_parts IN CSP_SCH_INT_PVT.RESERVATION_REC_TYP
5793: FROM MTL_TXN_SOURCE_TYPES
5794: WHERE transaction_source_type_id = 13;
5795: I NUMBER;
5796: l_api_version_number number :=1;
5797: l_init_msg_lst varchar2(1) := fnd_api.g_true;
5798: x_msg_count number;
5799: -- x_msg_data varchar2(128);
5800: l_rsv_rec inv_reservation_global.mtl_reservation_rec_type;
5801: l_serial_number inv_reservation_global.serial_number_tbl_type;
5799: -- x_msg_data varchar2(128);
5800: l_rsv_rec inv_reservation_global.mtl_reservation_rec_type;
5801: l_serial_number inv_reservation_global.serial_number_tbl_type;
5802: x_serial_number inv_reservation_global.serial_number_tbl_type;
5803: l_partial_reservation_flag varchar2(1):= fnd_api.g_false;
5804: l_force_reservation_flag varchar2(1) := fnd_api.g_true;
5805: l_validation_flag varchar2(1) := fnd_api.g_true;
5806: l_source_type_id NUMBER;
5807: l_source_name varchar2(30);
5800: l_rsv_rec inv_reservation_global.mtl_reservation_rec_type;
5801: l_serial_number inv_reservation_global.serial_number_tbl_type;
5802: x_serial_number inv_reservation_global.serial_number_tbl_type;
5803: l_partial_reservation_flag varchar2(1):= fnd_api.g_false;
5804: l_force_reservation_flag varchar2(1) := fnd_api.g_true;
5805: l_validation_flag varchar2(1) := fnd_api.g_true;
5806: l_source_type_id NUMBER;
5807: l_source_name varchar2(30);
5808: x_quantity_reserved number;
5801: l_serial_number inv_reservation_global.serial_number_tbl_type;
5802: x_serial_number inv_reservation_global.serial_number_tbl_type;
5803: l_partial_reservation_flag varchar2(1):= fnd_api.g_false;
5804: l_force_reservation_flag varchar2(1) := fnd_api.g_true;
5805: l_validation_flag varchar2(1) := fnd_api.g_true;
5806: l_source_type_id NUMBER;
5807: l_source_name varchar2(30);
5808: x_quantity_reserved number;
5809: x_reservation_id number;
5811: l_msg varchar2(2000);
5812: --x_return_status varchar(128);
5813: BEGIN
5814: log('create_reservation','In function Create_reservation');
5815: x_return_status := FND_API.G_RET_STS_SUCCESS;
5816: OPEN csp_transactions;
5817: LOOP
5818: FETCH csp_transactions INTO l_source_type_id, l_source_name;
5819: EXIT WHEN csp_transactions%NOTFOUND;
5828: FND_MSG_PUB.ADD;
5829: fnd_msg_pub.count_and_get
5830: ( p_count => x_msg_count
5831: , p_data => x_msg_data);
5832: x_return_status := FND_API.G_RET_STS_ERROR;
5833: RETURN 0;
5834: END IF; */
5835: begin
5836: select LOT INTO l_rsv_rec.lot_number
5926: , p_validation_flag => l_validation_flag
5927: , x_quantity_reserved => x_quantity_reserved
5928: , x_reservation_id => x_reservation_id
5929: );
5930: IF x_return_status <> FND_API.G_RET_STS_SUCCESS and x_reservation_id <= 0 THEN
5931: return 0;
5932: ELSE
5933: log('create_reservation','Created reservation ID:'||x_reservation_id);
5934: return x_reservation_id;
5939: FND_MSG_PUB.ADD;
5940: fnd_msg_pub.count_and_get
5941: ( p_count => x_msg_count
5942: , p_data => x_msg_data);
5943: x_return_status := FND_API.G_RET_STS_ERROR;
5944: return 0;
5945: END IF;
5946: EXCEPTION
5947: WHEN NO_DATA_FOUND THEN
5949: FND_MSG_PUB.ADD;
5950: fnd_msg_pub.count_and_get
5951: ( p_count => x_msg_count
5952: , p_data => x_msg_data);
5953: x_return_status := FND_API.G_RET_STS_ERROR;
5954: return 0;
5955: WHEN OTHERS THEN
5956: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
5957: return 0;
5952: , p_data => x_msg_data);
5953: x_return_status := FND_API.G_RET_STS_ERROR;
5954: return 0;
5955: WHEN OTHERS THEN
5956: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
5957: return 0;
5958: END CREATE_RESERVATION;
5959: PROCEDURE TRANSFER_RESERVATION(p_reservation_id IN NUMBER
5960: ,p_order_header_id IN NUMBER
5965: ,x_msg_count OUT NOCOPY NUMBER) IS
5966:
5967: I NUMBER;
5968: l_api_version_number number :=1;
5969: l_init_msg_lst varchar2(1) := fnd_api.g_true;
5970: -- x_msg_data varchar2(128);
5971: l_old_rsv_rec inv_reservation_global.mtl_reservation_rec_type;
5972: l_new_rsv_rec inv_reservation_global.mtl_reservation_rec_type;
5973: l_old_serial_number inv_reservation_global.serial_number_tbl_type;
5971: l_old_rsv_rec inv_reservation_global.mtl_reservation_rec_type;
5972: l_new_rsv_rec inv_reservation_global.mtl_reservation_rec_type;
5973: l_old_serial_number inv_reservation_global.serial_number_tbl_type;
5974: l_new_serial_number inv_reservation_global.serial_number_tbl_type;
5975: l_partial_reservation_flag varchar2(1):= fnd_api.g_false;
5976: l_is_transfer_supply varchar2(1) := fnd_api.g_true;
5977: l_validation_flag varchar2(1) := fnd_api.g_true;
5978: l_source_type_id NUMBER;
5979: l_source_name varchar2(30);
5972: l_new_rsv_rec inv_reservation_global.mtl_reservation_rec_type;
5973: l_old_serial_number inv_reservation_global.serial_number_tbl_type;
5974: l_new_serial_number inv_reservation_global.serial_number_tbl_type;
5975: l_partial_reservation_flag varchar2(1):= fnd_api.g_false;
5976: l_is_transfer_supply varchar2(1) := fnd_api.g_true;
5977: l_validation_flag varchar2(1) := fnd_api.g_true;
5978: l_source_type_id NUMBER;
5979: l_source_name varchar2(30);
5980: x_quantity_reserved number;
5973: l_old_serial_number inv_reservation_global.serial_number_tbl_type;
5974: l_new_serial_number inv_reservation_global.serial_number_tbl_type;
5975: l_partial_reservation_flag varchar2(1):= fnd_api.g_false;
5976: l_is_transfer_supply varchar2(1) := fnd_api.g_true;
5977: l_validation_flag varchar2(1) := fnd_api.g_true;
5978: l_source_type_id NUMBER;
5979: l_source_name varchar2(30);
5980: x_quantity_reserved number;
5981: l_msg varchar2(2000);
5980: x_quantity_reserved number;
5981: l_msg varchar2(2000);
5982: --x_return_status varchar(128);
5983: BEGIN
5984: x_return_status := FND_API.G_RET_STS_SUCCESS;
5985:
5986: l_old_rsv_rec.reservation_id := p_reservation_id;
5987:
5988: l_new_rsv_rec.reservation_id := NULL;
6003: , p_to_serial_number => l_new_serial_number
6004: , p_validation_flag => l_validation_flag
6005: , x_to_reservation_id => x_reservation_id
6006: );
6007: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
6008: X_return_status := FND_API.G_RET_STS_ERROR;
6009: return;
6010: END IF;
6011: EXCEPTION
6004: , p_validation_flag => l_validation_flag
6005: , x_to_reservation_id => x_reservation_id
6006: );
6007: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
6008: X_return_status := FND_API.G_RET_STS_ERROR;
6009: return;
6010: END IF;
6011: EXCEPTION
6012: WHEN NO_DATA_FOUND THEN
6009: return;
6010: END IF;
6011: EXCEPTION
6012: WHEN NO_DATA_FOUND THEN
6013: X_return_status := FND_API.G_RET_STS_ERROR;
6014: return;
6015: WHEN OTHERS THEN
6016: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
6017: return;
6012: WHEN NO_DATA_FOUND THEN
6013: X_return_status := FND_API.G_RET_STS_ERROR;
6014: return;
6015: WHEN OTHERS THEN
6016: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
6017: return;
6018: END TRANSFER_RESERVATION;
6019: PROCEDURE GET_SHIPPING_METHODE(p_from_org_id IN NUMBER,
6020: p_to_org_id IN NUMBER,
6052: l_min_leadtime NUMBER := 100000000;
6053: l_shipping_methode varchar2(30);
6054: l_api_name varchar2(60) := 'CSP_SCH_INT_PVT.GET_SHIPPING_METHODE' ;
6055: BEGIN
6056: x_return_status := FND_API.G_RET_STS_SUCCESS ;
6057: l_server_time_zone_id := FND_PROFILE.VALUE(NAME => 'SERVER_TIMEZONE_ID');
6058: OPEN C3(p_from_org_id,p_to_org_id);
6059: LOOP
6060: FETCH C3 INTO l_cost,l_relation_ship_id ,l_cutoff_time,l_timezone_id,l_shipping_methode ;
6061: EXIT WHEN C3%NOTFOUND;
6062: CSP_SCH_INT_PVT.GET_DELIVERY_DATE(l_relation_ship_id, x_delivery_date,x_shipping_option,x_return_status,x_msg_data,x_msg_count);
6063: IF p_timezone_id <> l_server_time_zone_id THEN
6064: HZ_TIMEZONE_PUB.Get_Time( p_api_version => 1.0,
6065: p_init_msg_list => FND_API.G_FALSE,
6066: p_source_tz_id => p_timezone_id,
6067: p_dest_tz_id => l_server_time_zone_id,
6068: p_source_day_time => x_delivery_date,
6069: x_dest_day_time => l_server_delivery_date,
6074: l_server_delivery_date := x_delivery_date;
6075: END IF;
6076: IF l_cutoff_time is not null then
6077: HZ_TIMEZONE_PUB.Get_Time( p_api_version => 1.0,
6078: p_init_msg_list => FND_API.G_FALSE,
6079: p_source_tz_id => l_timezone_id,
6080: p_dest_tz_id => l_server_time_zone_id,
6081: p_source_day_time => l_cutoff_time,
6082: x_dest_day_time => l_server_cutoff_time,
6108: FND_MSG_PUB.ADD;
6109: fnd_msg_pub.count_and_get
6110: ( p_count => x_msg_count
6111: , p_data => x_msg_data);
6112: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
6113: return;
6114: END GET_SHIPPING_METHODE;
6115:
6116: PROCEDURE CHECK_PARTS_AVAILABILITY(
6299: /* l_subinv_unavailable_list := CSP_SCH_INT_PVT.CSP_UNAVAILABILITY_TBL_TYPE() ;
6300: l_subinv_available_list := CSP_SCH_INT_PVT.CSP_AVAILABILITY_TBL_TYPE();*/
6301: -- x_availability := CSP_SCH_INT_PVT.AVAILABLE_PARTS_TBL_TYP1();
6302: l_interval.latest_time := p_need_by_date;
6303: x_return_status := FND_API.G_RET_STS_SUCCESS;
6304: l_alternate_items_list := alternate_items_table_type();
6305: l_final_available_list := CSP_SCH_INT_PVT.CSP_AVAILABILITY_TBL_TYPE() ;
6306: l_temp_avail_list := CSP_SCH_INT_PVT.CSP_AVAILABILITY_TBL_TYPE() ;
6307: l_timezone_id := p_timezone_id ;
6361: IF p_parts_list.count > 1 THEN
6362: log('check_parts_availability', 'l_temp_org_id: '||l_temp_org_id);
6363: csp_supersessions_pvt.check_for_duplicate_parts(p_parts_list,l_temp_org_id,x_return_status,x_msg_data,x_msg_count);
6364: END IF;
6365: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
6366: RETURN;
6367: END IF;
6368: log('check_parts_availability', 'begin p_parts_list loop');
6369: FOR I IN 1..p_parts_list.count
6447: l_reservation_parts.revision := l_final_available_list(l_final_available_list.count).revision;
6448: l_reservation_id := csp_sch_int_pvt.create_reservation(l_reservation_parts,x_return_status,x_msg_data);
6449: log('check_parts_availability', 'l_reservation_id: '||l_reservation_id);
6450: IF l_reservation_id <= 0 THEN
6451: x_return_status := FND_API.G_RET_STS_ERROR;
6452: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_COULD_NOT_RESERVE');
6453: FND_MSG_PUB.ADD;
6454: fnd_msg_pub.count_and_get ( p_count => x_msg_count , p_data => x_msg_data);
6455: ELSE
6601: l_reservation_parts.line_id := l_final_available_list(l_final_available_list.count).line_id ;
6602: l_reservation_parts.revision := l_final_available_list(l_final_available_list.count).revision;
6603: l_reservation_id := CSP_SCH_INT_PVT.CREATE_RESERVATION(l_reservation_parts,x_return_status,x_msg_data);
6604: IF l_reservation_id <= 0 THEN
6605: x_return_status := FND_API.G_RET_STS_ERROR;
6606: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_COULD_NOT_RESERVE');
6607: FND_MSG_PUB.ADD;
6608: fnd_msg_pub.count_and_get ( p_count => x_msg_count , p_data => x_msg_data);
6609: ELSE
6980: FND_MESSAGE.SET_TOKEN('ROUTINE', l_api_name, FALSE);
6981: FND_MESSAGE.SET_TOKEN('SQLERRM', sqlerrm, FALSE);
6982: FND_MSG_PUB.ADD;
6983: fnd_msg_pub.count_and_get ( p_count => x_msg_count , p_data => x_msg_data);
6984: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
6985: RETURN;
6986: END check_parts_availability;
6987:
6988: PROCEDURE CHECK_LOCAL_INVENTORY( p_org_id IN NUMBER
7020: BEGIN
7021: IF p_revision IS NOT NULL THEN
7022: l_is_revision_control := TRUE;
7023: END IF;
7024: x_return_status := FND_API.G_RET_STS_SUCCESS ;
7025: x_att := 0;
7026: inv_quantity_tree_pub.clear_quantity_cache;
7027: inv_quantity_tree_pub.query_quantities(p_api_version_number => 1.0
7028: , p_organization_id => p_org_id
7029: , p_inventory_item_id => p_item_id
7030: , p_subinventory_code => p_subinv_code
7031: , x_qoh => x_onhand
7032: , x_atr => l_available
7033: , p_init_msg_lst => fnd_api.g_false
7034: , p_tree_mode => inv_quantity_tree_pvt.g_transaction_mode
7035: , p_is_revision_control => l_is_revision_control
7036: , p_is_lot_control => NULL
7037: , p_is_serial_control => NULL
7062: FND_MSG_PUB.ADD;
7063: fnd_msg_pub.count_and_get
7064: ( p_count => x_msg_count
7065: , p_data => x_msg_data);
7066: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
7067: return;
7068: END CHECK_LOCAL_INVENTORY;
7069: PROCEDURE TASKS_POST_INSERT( x_return_status out nocopy varchar2) IS
7070: p_task_id NUMBER;
7075: BEGIN
7076: p_task_id := jtf_tasks_pub.p_task_user_hooks.task_id;
7077: CSP_REQUIREMENT_POPULATE_PVT.POPULATE_REQUIREMENTS(p_task_id => p_task_id
7078: ,p_api_version => 1.0
7079: ,p_Init_Msg_List => FND_API.G_FALSE
7080: ,p_commit => FND_API.G_FALSE
7081: ,x_return_status => x_return_status
7082: ,x_msg_data => l_msg_data
7083: ,x_msg_count => l_msg_count
7076: p_task_id := jtf_tasks_pub.p_task_user_hooks.task_id;
7077: CSP_REQUIREMENT_POPULATE_PVT.POPULATE_REQUIREMENTS(p_task_id => p_task_id
7078: ,p_api_version => 1.0
7079: ,p_Init_Msg_List => FND_API.G_FALSE
7080: ,p_commit => FND_API.G_FALSE
7081: ,x_return_status => x_return_status
7082: ,x_msg_data => l_msg_data
7083: ,x_msg_count => l_msg_count
7084: ,px_header_id => l_header_id
7995: FETCH get_cutoff_time INTO l_cutoff_time , l_timezone_id;
7996: CLOSE get_cutoff_time;
7997: IF l_cutoff_time IS NOT NULL and l_server_time_zone_id IS NOT NULL THEN
7998: HZ_TIMEZONE_PUB.Get_Time( p_api_version => 1.0,
7999: p_init_msg_list => FND_API.G_FALSE,
8000: p_source_tz_id => l_timezone_id,
8001: p_dest_tz_id => l_server_time_zone_id,
8002: p_source_day_time => l_cutoff_time,
8003: x_dest_day_time => l_server_cutoff_time,
8089: and crld.source_type = 'IO'
8090: and oel.header_id = c_order_header_id;
8091:
8092: BEGIN
8093: x_return_status := FND_API.G_RET_STS_SUCCESS;
8094: l_return_status := FND_API.G_RET_STS_SUCCESS;
8095: l_task_id := jtf_tasks_pub.p_task_user_hooks.task_id;
8096: l_task_status_id := jtf_tasks_pub.p_task_user_hooks.task_status_id;
8097: OPEN cleanup_needed;
8090: and oel.header_id = c_order_header_id;
8091:
8092: BEGIN
8093: x_return_status := FND_API.G_RET_STS_SUCCESS;
8094: l_return_status := FND_API.G_RET_STS_SUCCESS;
8095: l_task_id := jtf_tasks_pub.p_task_user_hooks.task_id;
8096: l_task_status_id := jtf_tasks_pub.p_task_user_hooks.task_status_id;
8097: OPEN cleanup_needed;
8098: FETCH cleanup_needed INTO l_cleanup_needed;
8102: LOOP
8103: FETCH get_reservations INTO l_reserv_id,l_req_details_line_id;
8104: EXIT WHEN get_reservations%NOTFOUND;
8105: CSP_SCH_INT_PVT.CANCEL_RESERVATION(l_reserv_id,l_return_status,x_msg_data,x_msg_count);
8106: IF l_return_status = FND_API.G_RET_STS_UNEXP_ERROR THEN
8107: x_return_status := FND_API.G_RET_STS_SUCCESS;
8108: ELSIF l_return_status = FND_API.G_RET_STS_SUCCESS THEN
8109: delete from csp_req_line_details where req_line_detail_id = l_req_details_line_id;
8110: END IF;
8103: FETCH get_reservations INTO l_reserv_id,l_req_details_line_id;
8104: EXIT WHEN get_reservations%NOTFOUND;
8105: CSP_SCH_INT_PVT.CANCEL_RESERVATION(l_reserv_id,l_return_status,x_msg_data,x_msg_count);
8106: IF l_return_status = FND_API.G_RET_STS_UNEXP_ERROR THEN
8107: x_return_status := FND_API.G_RET_STS_SUCCESS;
8108: ELSIF l_return_status = FND_API.G_RET_STS_SUCCESS THEN
8109: delete from csp_req_line_details where req_line_detail_id = l_req_details_line_id;
8110: END IF;
8111: END LOOP;
8104: EXIT WHEN get_reservations%NOTFOUND;
8105: CSP_SCH_INT_PVT.CANCEL_RESERVATION(l_reserv_id,l_return_status,x_msg_data,x_msg_count);
8106: IF l_return_status = FND_API.G_RET_STS_UNEXP_ERROR THEN
8107: x_return_status := FND_API.G_RET_STS_SUCCESS;
8108: ELSIF l_return_status = FND_API.G_RET_STS_SUCCESS THEN
8109: delete from csp_req_line_details where req_line_detail_id = l_req_details_line_id;
8110: END IF;
8111: END LOOP;
8112: close get_reservations;
8118: FETCH get_order_status INTO l_status;
8119: CLOSE get_order_status;
8120: IF l_status <> 'CANCELLED' THEN
8121: CSP_SCH_INT_PVT.CANCEL_ORDER(l_order_id,l_return_status,x_msg_data,x_msg_count);
8122: IF l_return_status = FND_API.G_RET_STS_UNEXP_ERROR THEN
8123: x_return_status := FND_API.G_RET_STS_SUCCESS;
8124: ELSIF l_return_status = FND_API.G_RET_STS_SUCCESS THEN
8125: open get_line_details(l_order_id);
8126: LOOP
8119: CLOSE get_order_status;
8120: IF l_status <> 'CANCELLED' THEN
8121: CSP_SCH_INT_PVT.CANCEL_ORDER(l_order_id,l_return_status,x_msg_data,x_msg_count);
8122: IF l_return_status = FND_API.G_RET_STS_UNEXP_ERROR THEN
8123: x_return_status := FND_API.G_RET_STS_SUCCESS;
8124: ELSIF l_return_status = FND_API.G_RET_STS_SUCCESS THEN
8125: open get_line_details(l_order_id);
8126: LOOP
8127: FETCH get_line_details INTO l_req_details_line_id;
8120: IF l_status <> 'CANCELLED' THEN
8121: CSP_SCH_INT_PVT.CANCEL_ORDER(l_order_id,l_return_status,x_msg_data,x_msg_count);
8122: IF l_return_status = FND_API.G_RET_STS_UNEXP_ERROR THEN
8123: x_return_status := FND_API.G_RET_STS_SUCCESS;
8124: ELSIF l_return_status = FND_API.G_RET_STS_SUCCESS THEN
8125: open get_line_details(l_order_id);
8126: LOOP
8127: FETCH get_line_details INTO l_req_details_line_id;
8128: EXIT WHEN get_line_details% NOTFOUND;
8237: FROM MTL_TXN_SOURCE_TYPES
8238: WHERE transaction_source_type_id = 13;
8239: I NUMBER;
8240: l_api_version_number number :=1;
8241: l_init_msg_lst varchar2(1) := fnd_api.g_true;
8242: x_msg_count number;
8243: -- x_msg_data varchar2(128);
8244: l_rsv_rec inv_reservation_global.mtl_reservation_rec_type;
8245: l_serial_number inv_reservation_global.serial_number_tbl_type;
8243: -- x_msg_data varchar2(128);
8244: l_rsv_rec inv_reservation_global.mtl_reservation_rec_type;
8245: l_serial_number inv_reservation_global.serial_number_tbl_type;
8246: x_serial_number inv_reservation_global.serial_number_tbl_type;
8247: l_partial_reservation_flag varchar2(1):= fnd_api.g_false;
8248: l_force_reservation_flag varchar2(1) := fnd_api.g_true;
8249: l_validation_flag varchar2(1) := fnd_api.g_true;
8250: l_source_type_id NUMBER;
8251: l_source_name varchar2(30);
8244: l_rsv_rec inv_reservation_global.mtl_reservation_rec_type;
8245: l_serial_number inv_reservation_global.serial_number_tbl_type;
8246: x_serial_number inv_reservation_global.serial_number_tbl_type;
8247: l_partial_reservation_flag varchar2(1):= fnd_api.g_false;
8248: l_force_reservation_flag varchar2(1) := fnd_api.g_true;
8249: l_validation_flag varchar2(1) := fnd_api.g_true;
8250: l_source_type_id NUMBER;
8251: l_source_name varchar2(30);
8252: x_quantity_reserved number;
8245: l_serial_number inv_reservation_global.serial_number_tbl_type;
8246: x_serial_number inv_reservation_global.serial_number_tbl_type;
8247: l_partial_reservation_flag varchar2(1):= fnd_api.g_false;
8248: l_force_reservation_flag varchar2(1) := fnd_api.g_true;
8249: l_validation_flag varchar2(1) := fnd_api.g_true;
8250: l_source_type_id NUMBER;
8251: l_source_name varchar2(30);
8252: x_quantity_reserved number;
8253: x_reservation_id number;
8253: x_reservation_id number;
8254: l_msg varchar2(2000);
8255: --x_return_status varchar(128);
8256: BEGIN
8257: x_return_status := FND_API.G_RET_STS_SUCCESS;
8258: OPEN csp_transactions;
8259: LOOP
8260: FETCH csp_transactions INTO l_source_type_id, l_source_name;
8261: EXIT WHEN csp_transactions%NOTFOUND;
8326: FND_MSG_PUB.ADD;
8327: fnd_msg_pub.count_and_get
8328: ( p_count => x_msg_count
8329: , p_data => x_msg_data);
8330: x_return_status := FND_API.G_RET_STS_ERROR;
8331: WHEN OTHERS THEN
8332: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
8333:
8334: END DELETE_RESERVATION;
8328: ( p_count => x_msg_count
8329: , p_data => x_msg_data);
8330: x_return_status := FND_API.G_RET_STS_ERROR;
8331: WHEN OTHERS THEN
8332: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
8333:
8334: END DELETE_RESERVATION;
8335:
8336: -- first find out all RES created after receiving
8416: log('move_parts_on_reassign', 'p_new_need_by_date=' || to_char(p_new_need_by_date, 'dd-MON-YYYY HH24:MI'));
8417: log('move_parts_on_reassign', 'p_new_resource_id=' || p_new_resource_id);
8418: log('move_parts_on_reassign', 'p_new_resource_type=' || p_new_resource_type);
8419:
8420: x_return_status := FND_API.G_RET_STS_SUCCESS;
8421:
8422: open resource_org;
8423: fetch resource_org into l_new_dest_org, l_new_dest_subinv;
8424: close resource_org;
8426: log('move_parts_on_reassign', 'l_new_dest_org=' || l_new_dest_org);
8427: log('move_parts_on_reassign', 'l_new_dest_subinv=' || l_new_dest_subinv);
8428:
8429: if l_new_dest_org = -999 then
8430: x_return_status := FND_API.G_RET_STS_ERROR;
8431: l_resource_name := csp_pick_utils.get_object_name(p_new_resource_type, p_new_resource_id);
8432: SELECT NAME
8433: into l_resource_type_name
8434: FROM JTF_OBJECTS_VL
8458: CSP_SCH_INT_PVT.CANCEL_RESERVATION(old_res_record.source_id, x_return_status, x_msg_data, x_msg_count);
8459:
8460: log('move_parts_on_reassign', 'x_return_status=' || x_return_status);
8461:
8462: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
8463: x_return_status := FND_API.G_RET_STS_ERROR;
8464: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
8465: FND_MSG_PUB.ADD;
8466: fnd_msg_pub.count_and_get
8459:
8460: log('move_parts_on_reassign', 'x_return_status=' || x_return_status);
8461:
8462: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
8463: x_return_status := FND_API.G_RET_STS_ERROR;
8464: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
8465: FND_MSG_PUB.ADD;
8466: fnd_msg_pub.count_and_get
8467: ( p_count => x_msg_count
8488: X_Msg_Count => x_msg_count,
8489: X_Msg_Data => x_msg_data
8490: );
8491: log('move_parts_on_reassign', 'after calling transact_intorg_transfer... x_return_status=' || x_return_status);
8492: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
8493: x_return_status := FND_API.G_RET_STS_ERROR;
8494: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
8495: FND_MSG_PUB.ADD;
8496: fnd_msg_pub.count_and_get
8489: X_Msg_Data => x_msg_data
8490: );
8491: log('move_parts_on_reassign', 'after calling transact_intorg_transfer... x_return_status=' || x_return_status);
8492: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
8493: x_return_status := FND_API.G_RET_STS_ERROR;
8494: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
8495: FND_MSG_PUB.ADD;
8496: fnd_msg_pub.count_and_get
8497: ( p_count => x_msg_count
8507: X_Msg_Count => x_msg_count,
8508: X_Msg_Data => x_msg_data
8509: );
8510: log('move_parts_on_reassign', 'after calling transact_subinv_transfer... x_return_status=' || x_return_status);
8511: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
8512: x_return_status := FND_API.G_RET_STS_ERROR;
8513: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
8514: FND_MSG_PUB.ADD;
8515: fnd_msg_pub.count_and_get
8508: X_Msg_Data => x_msg_data
8509: );
8510: log('move_parts_on_reassign', 'after calling transact_subinv_transfer... x_return_status=' || x_return_status);
8511: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
8512: x_return_status := FND_API.G_RET_STS_ERROR;
8513: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
8514: FND_MSG_PUB.ADD;
8515: fnd_msg_pub.count_and_get
8516: ( p_count => x_msg_count
8536:
8537: log('move_parts_on_reassign', 'after creating a new reservation...x_return_status=' || x_return_status);
8538: log('move_parts_on_reassign', 'l_new_reservation_id=' || l_new_reservation_id);
8539:
8540: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
8541: x_return_status := FND_API.G_RET_STS_ERROR;
8542: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
8543: FND_MSG_PUB.ADD;
8544: fnd_msg_pub.count_and_get
8537: log('move_parts_on_reassign', 'after creating a new reservation...x_return_status=' || x_return_status);
8538: log('move_parts_on_reassign', 'l_new_reservation_id=' || l_new_reservation_id);
8539:
8540: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
8541: x_return_status := FND_API.G_RET_STS_ERROR;
8542: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
8543: FND_MSG_PUB.ADD;
8544: fnd_msg_pub.count_and_get
8545: ( p_count => x_msg_count
8584:
8585: log('move_parts_on_reassign', 'before calling Update_requirement_headers...');
8586: CSP_Requirement_Headers_PVT.Update_requirement_headers(
8587: P_Api_Version_Number => 1.0,
8588: P_Init_Msg_List => FND_API.G_FALSE,
8589: P_Commit => FND_API.G_FALSE,
8590: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
8591: P_REQUIREMENT_HEADER_Rec => l_requirement_header,
8592: X_Return_Status => x_return_status,
8585: log('move_parts_on_reassign', 'before calling Update_requirement_headers...');
8586: CSP_Requirement_Headers_PVT.Update_requirement_headers(
8587: P_Api_Version_Number => 1.0,
8588: P_Init_Msg_List => FND_API.G_FALSE,
8589: P_Commit => FND_API.G_FALSE,
8590: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
8591: P_REQUIREMENT_HEADER_Rec => l_requirement_header,
8592: X_Return_Status => x_return_status,
8593: X_Msg_Count => x_msg_count,
8586: CSP_Requirement_Headers_PVT.Update_requirement_headers(
8587: P_Api_Version_Number => 1.0,
8588: P_Init_Msg_List => FND_API.G_FALSE,
8589: P_Commit => FND_API.G_FALSE,
8590: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
8591: P_REQUIREMENT_HEADER_Rec => l_requirement_header,
8592: X_Return_Status => x_return_status,
8593: X_Msg_Count => x_msg_count,
8594: x_msg_data => x_msg_data
8594: x_msg_data => x_msg_data
8595: );
8596: log('move_parts_on_reassign', 'before calling Update_requirement_headers...x_return_status=' || x_return_status);
8597:
8598: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
8599: x_return_status := FND_API.G_RET_STS_ERROR;
8600: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
8601: FND_MSG_PUB.ADD;
8602: fnd_msg_pub.count_and_get
8595: );
8596: log('move_parts_on_reassign', 'before calling Update_requirement_headers...x_return_status=' || x_return_status);
8597:
8598: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
8599: x_return_status := FND_API.G_RET_STS_ERROR;
8600: FND_MESSAGE.SET_NAME('CSP', 'CSP_SCH_NOT_CANCEL_ORDER');
8601: FND_MSG_PUB.ADD;
8602: fnd_msg_pub.count_and_get
8603: ( p_count => x_msg_count