DBA Data[Home] [Help]

APPS.PO_PDOI_MAINPROC_PVT dependencies on PO_PDOI_UTL

Line 137: PO_PDOI_UTL.reject_unprocessed_intf

133: PO_LOG.stmt(d_module, d_position, 'Unprocessed records will be removed for header ',
134: PO_PDOI_PARAMS.g_request.interface_header_id);
135: END IF;
136:
137: PO_PDOI_UTL.reject_unprocessed_intf
138: (
139: p_intf_header_id => PO_PDOI_PARAMS.g_request.interface_header_id
140: );
141: END IF;

Line 296: PO_PDOI_UTL.reject_headers_intf

292: l_count := l_count + 1;
293: l_rej_intf_header_id_tbl(l_count) := l_headers.intf_header_id_tbl(i);
294: END IF;
295: END LOOP;
296: PO_PDOI_UTL.reject_headers_intf
297: (
298: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_HEADER_ID,
299: p_id_tbl => l_rej_intf_header_id_tbl,
300: p_cascade => FND_API.g_TRUE

Line 307: PO_PDOI_UTL.commit_work;

303:
304: d_position := 70;
305:
306: -- conditional commit
307: PO_PDOI_UTL.commit_work;
308:
309: -- set maximal intf_header_id read so far(used in next batch read)
310: l_max_intf_header_id := l_headers.intf_header_id_tbl(l_headers.rec_count);
311:

Line 327: PO_PDOI_UTL.commit_work;

323: p_procedure_name => d_api_name || '.' || d_position
324: );
325:
326: -- commit changes
327: PO_PDOI_UTL.commit_work;
328:
329: IF (l_headers_csr%ISOPEN) THEN
330: CLOSE l_headers_csr;
331: PO_PDOI_HEADER_PROCESS_PVT.open_headers

Line 714: PO_PDOI_UTL.reject_lines_intf

710: l_rej_intf_line_id_tbl.EXTEND;
711: l_rej_intf_line_id_tbl(l_rej_intf_line_id_tbl.COUNT) := l_lines.intf_line_id_tbl(i);
712: END IF;
713: END LOOP;
714: PO_PDOI_UTL.reject_lines_intf
715: (
716: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_ID,
717: p_id_tbl => l_rej_intf_line_id_tbl,
718: p_cascade => FND_API.g_TRUE

Line 725: PO_PDOI_UTL.commit_work;

721:
722: d_position := 110;
723:
724: -- commit changes
725: PO_PDOI_UTL.commit_work;
726:
727: -- set the maximal interface_line_id processed in this batch
728: l_max_intf_line_id := l_lines.intf_line_id_tbl(l_lines.rec_count);
729:

Line 745: PO_PDOI_UTL.commit_work;

741: p_procedure_name => d_api_name || '.' || d_position
742: );
743:
744: -- commit changes
745: PO_PDOI_UTL.commit_work;
746:
747: IF (l_lines_csr%ISOPEN) THEN
748: CLOSE l_lines_csr;
749: PO_PDOI_LINE_PROCESS_PVT.open_lines

Line 783: PO_PDOI_UTL.reject_lines_intf

779: AND NVL(intf_line2.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)
780: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_REJECTED
781: AND NVL(intf_line2.price_break_flag, 'N') = 'N');
782: d_position := 150;
783: PO_PDOI_UTL.reject_lines_intf
784: (
785: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_ID,
786: p_id_tbl => l_rej_intf_line_id_tbl,
787: p_cascade => FND_API.g_TRUE

Line 994: PO_PDOI_UTL.generate_ordered_num_list

990:
991: d_position := 50;
992:
993: -- setup table to track rows that have not been processed
994: PO_PDOI_UTL.generate_ordered_num_list
995: (
996: p_size => l_lines.rec_count,
997: x_num_list => l_processing_row_tbl
998: );

Line 1065: PO_PDOI_UTL.commit_work;

1061: x_lines => l_update_lines
1062: );
1063: END LOOP;
1064:
1065: PO_PDOI_UTL.commit_work;
1066:
1067: -- set the maximal interface_line_id processed in this batch
1068: l_max_intf_line_id := l_lines.intf_line_id_tbl(l_lines.rec_count);
1069:

Line 1085: PO_PDOI_UTL.commit_work;

1081: p_procedure_name => d_api_name || '.' || d_position
1082: );
1083:
1084: -- commit changes
1085: PO_PDOI_UTL.commit_work;
1086:
1087: IF (l_lines_csr%ISOPEN) THEN
1088: CLOSE l_lines_csr;
1089: PO_PDOI_LINE_PROCESS_PVT.open_lines

Line 1131: PO_PDOI_UTL.reject_lines_intf

1127: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_REJECTED;
1128:
1129: d_position := 130;
1130:
1131: PO_PDOI_UTL.reject_lines_intf
1132: (
1133: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_ID,
1134: p_id_tbl => l_rej_intf_line_id_tbl,
1135: p_cascade => FND_API.g_TRUE

Line 1319: PO_PDOI_UTL.reject_lines_intf

1315: l_count := l_count + 1;
1316: l_rej_intf_line_id_tbl(l_count) := x_lines.intf_line_id_tbl(i);
1317: END IF;
1318: END LOOP;
1319: PO_PDOI_UTL.reject_lines_intf
1320: (
1321: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_ID,
1322: p_id_tbl => l_rej_intf_line_id_tbl,
1323: p_cascade => FND_API.g_TRUE

Line 1464: PO_PDOI_UTL.reject_lines_intf

1460: l_count := l_count + 1;
1461: l_rej_intf_line_id_tbl(l_count) := x_lines.intf_line_id_tbl(i);
1462: END IF;
1463: END LOOP;
1464: PO_PDOI_UTL.reject_lines_intf
1465: (
1466: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_ID,
1467: p_id_tbl => l_rej_intf_line_id_tbl,
1468: p_cascade => FND_API.g_TRUE

Line 1710: PO_PDOI_UTL.reject_line_locations_intf

1706: PO_LOG.stmt(d_module, d_position, 'to-be-rejected locs',
1707: l_rej_intf_line_loc_id_tbl);
1708: END IF;
1709:
1710: PO_PDOI_UTL.reject_line_locations_intf
1711: (
1712: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_LOCATION_ID,
1713: p_id_tbl => l_rej_intf_line_loc_id_tbl,
1714: p_cascade => FND_API.g_TRUE

Line 1734: PO_PDOI_UTL.commit_work;

1730: END IF;
1731: END LOOP;
1732:
1733: -- commit
1734: PO_PDOI_UTL.commit_work;
1735:
1736: IF (l_line_locs.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
1737: EXIT;
1738: END IF;

Line 1753: PO_PDOI_UTL.commit_work;

1749: p_procedure_name => d_api_name || '.' || d_position
1750: );
1751:
1752: -- commit changes
1753: PO_PDOI_UTL.commit_work;
1754:
1755: IF (l_line_locs_csr%ISOPEN) THEN
1756: CLOSE l_line_locs_csr;
1757: PO_PDOI_LINE_LOC_PROCESS_PVT.open_line_locs

Line 1968: PO_PDOI_UTL.reject_distributions_intf

1964: END IF;
1965:
1966: d_position := 90;
1967:
1968: PO_PDOI_UTL.reject_distributions_intf
1969: (
1970: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_DISTRIBUTION_ID,
1971: p_id_tbl => l_rej_intf_dist_id_tbl
1972: );

Line 1986: PO_PDOI_UTL.commit_work;

1982: AND l_dists.error_flag_tbl(i) = FND_API.g_FALSE;
1983:
1984: d_position := 110;
1985:
1986: PO_PDOI_UTL.commit_work;
1987:
1988: IF (l_dists.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
1989: EXIT;
1990: END IF;

Line 2005: PO_PDOI_UTL.commit_work;

2001: p_procedure_name => d_api_name || '.' || d_position
2002: );
2003:
2004: -- commit changes
2005: PO_PDOI_UTL.commit_work;
2006:
2007: IF (l_dists_csr%ISOPEN) THEN
2008: CLOSE l_dists_csr;
2009: PO_PDOI_DIST_PROCESS_PVT.open_dists

Line 2190: PO_PDOI_UTL.reject_price_diff_intf

2186: PO_LOG.stmt(d_module, d_position, 'to-be-rejected price diffs',
2187: l_rej_intf_price_diff_id_tbl);
2188: END IF;
2189:
2190: PO_PDOI_UTL.reject_price_diff_intf
2191: (
2192: p_id_param_type => PO_PDOI_CONSTANTS.g_PRICE_DIFF_INTERFACE_ID,
2193: p_id_tbl => l_rej_intf_price_diff_id_tbl
2194: );

Line 2206: PO_PDOI_UTL.commit_work;

2202: SET process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_ACCEPTED
2203: WHERE price_diff_interface_id = l_price_diffs.intf_price_diff_id_tbl(i)
2204: AND l_price_diffs.error_flag_tbl(i) = FND_API.g_FALSE;
2205:
2206: PO_PDOI_UTL.commit_work;
2207:
2208: IF (l_price_diffs.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
2209: EXIT;
2210: END IF;

Line 2225: PO_PDOI_UTL.commit_work;

2221: p_procedure_name => d_api_name || '.' || d_position
2222: );
2223:
2224: -- commit changes
2225: PO_PDOI_UTL.commit_work;
2226:
2227: IF (l_price_diffs_csr%ISOPEN) THEN
2228: CLOSE l_price_diffs_csr;
2229: PO_PDOI_PRICE_DIFF_PROCESS_PVT.open_price_diffs

Line 2436: PO_PDOI_UTL.generate_ordered_num_list

2432: -- po_line_id, the record will be processed
2433: -- in different groups
2434:
2435: -- first setup table to track rows that have not been processed
2436: PO_PDOI_UTL.generate_ordered_num_list
2437: (
2438: p_size => l_attr_values.rec_count,
2439: x_num_list => l_processing_row_tbl
2440: );

Line 2486: PO_PDOI_UTL.commit_work;

2482: SET process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_ACCEPTED
2483: WHERE interface_attr_values_id = l_attr_values.intf_attr_values_id_tbl(i)
2484: AND l_attr_values.error_flag_tbl(i) = FND_API.g_FALSE;
2485:
2486: PO_PDOI_UTL.commit_work;
2487:
2488: IF (l_attr_values.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
2489: EXIT;
2490: END IF;

Line 2505: PO_PDOI_UTL.commit_work;

2501: p_procedure_name => d_api_name || '.' || d_position
2502: );
2503:
2504: -- commit changes
2505: PO_PDOI_UTL.commit_work;
2506:
2507: IF (l_attr_values_csr%ISOPEN) THEN
2508: CLOSE l_attr_values_csr;
2509: PO_PDOI_ATTR_PROCESS_PVT.open_attr_values

Line 2627: PO_PDOI_UTL.generate_ordered_num_list

2623: -- po_line_id and language, the record will be processed
2624: -- in different groups
2625:
2626: -- first setup table to track rows that have not been processed
2627: PO_PDOI_UTL.generate_ordered_num_list
2628: (
2629: p_size => l_attr_values_tlp.rec_count,
2630: x_num_list => l_processing_row_tbl
2631: );

Line 2677: PO_PDOI_UTL.commit_work;

2673: SET process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_ACCEPTED
2674: WHERE interface_attr_values_tlp_id = l_attr_values_tlp.intf_attr_values_tlp_id_tbl(i)
2675: AND l_attr_values_tlp.error_flag_tbl(i) = FND_API.g_FALSE;
2676:
2677: PO_PDOI_UTL.commit_work;
2678:
2679: IF (l_attr_values_tlp.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
2680: EXIT;
2681: END IF;

Line 2696: PO_PDOI_UTL.commit_work;

2692: p_procedure_name => d_api_name || '.' || d_position
2693: );
2694:
2695: -- commit changes
2696: PO_PDOI_UTL.commit_work;
2697:
2698: IF (l_attr_values_tlp_csr%ISOPEN) THEN
2699: CLOSE l_attr_values_tlp_csr;
2700: PO_PDOI_ATTR_PROCESS_PVT.open_attr_values_tlp