[Home] [Help]
84: PO_LOG.proc_begin(d_module, 'start main process for header group',
85: PO_PDOI_PARAMS.g_current_round_num);
86: END IF;
87:
88: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_MAIN_PROCESSING);
89:
90: -- clean up cache before each group processing
91: PO_PDOI_MAINPROC_UTL_PVT.cleanup;
92:
101:
102: d_position := 20;
103:
104: IF (PO_PDOI_PARAMS.g_request.document_type IN
105: (PO_PDOI_CONSTANTS.g_DOC_TYPE_BLANKET, PO_PDOI_CONSTANTS.g_DOC_TYPE_QUOTATION)) THEN
106: process_attributes;
107: END IF;
108:
109: d_position := 30;
112:
113: d_position := 40;
114:
115: IF (PO_PDOI_PARAMS.g_request.document_type =
116: PO_PDOI_CONSTANTS.g_DOC_TYPE_STANDARD) THEN
117: process_distributions;
118: END IF;
119:
120: d_position := 50;
125:
126: -- Bug 5215781:
127: -- Remove all unprocessed records if error threshold is hit for CATALOG UPLOAD
128: IF (PO_PDOI_PARAMS.g_request.calling_module =
129: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
130: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
131: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
132: IF (PO_LOG.d_stmt) THEN
133: PO_LOG.stmt(d_module, d_position, 'Unprocessed records will be removed for header ',
139: p_intf_header_id => PO_PDOI_PARAMS.g_request.interface_header_id
140: );
141: END IF;
142:
143: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_MAIN_PROCESSING);
144:
145: IF (PO_LOG.d_proc) THEN
146: PO_LOG.proc_end(d_module);
147: END IF;
205: IF (PO_LOG.d_proc) THEN
206: PO_LOG.proc_begin(d_module);
207: END IF;
208:
209: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_HEADER_PROCESS);
210:
211: -- open cursor for the query which retrieve the header info
212: PO_PDOI_HEADER_PROCESS_PVT.open_headers
213: (
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
301: );
302: l_rej_intf_header_id_tbl.DELETE;
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:
312: -- exit if this is the last batch
313: IF (l_headers.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
314: EXIT;
315: END IF;
316: EXCEPTION
317: WHEN g_snap_shot_too_old THEN
343: IF (l_headers_csr%ISOPEN) THEN
344: CLOSE l_headers_csr;
345: END IF;
346:
347: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_HEADER_PROCESS);
348:
349: IF (PO_LOG.d_proc) THEN
350: PO_LOG.proc_end(d_module);
351: END IF;
407: IF (PO_LOG.d_proc) THEN
408: PO_LOG.proc_begin(d_module);
409: END IF;
410:
411: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_LINE_PROCESS);
412:
413: -- reject lines with existing line_num when updating standard PO
414: IF (PO_PDOI_PARAMS.g_request.document_type =
415: PO_PDOI_CONSTANTS.g_DOC_TYPE_STANDARD) THEN
411: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_LINE_PROCESS);
412:
413: -- reject lines with existing line_num when updating standard PO
414: IF (PO_PDOI_PARAMS.g_request.document_type =
415: PO_PDOI_CONSTANTS.g_DOC_TYPE_STANDARD) THEN
416: PO_PDOI_LINE_PROCESS_PVT.reject_dup_lines_for_spo;
417: END IF;
418:
419: -- reject lines with invalid line level action.
422: -- the notified lines, the system has set the line
423: -- level action to either 'ADD' or 'UPADTE', we don't
424: -- need to check line level action for NOTOFIED lines
425: IF (PO_PDOI_PARAMS.g_request.process_code <>
426: PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED) THEN
427: PO_PDOI_LINE_PROCESS_PVT.reject_invalid_action_lines;
428: END IF;
429:
430: d_position := 10;
431:
432: -- first data set
433: process_lines_add
434: (
435: p_data_set_type => PO_PDOI_CONSTANTS.g_LINE_CSR_ADD
436: );
437:
438: d_position := 20;
439:
439:
440: -- second data set
441: process_lines_add
442: (
443: p_data_set_type => PO_PDOI_CONSTANTS.g_LINE_CSR_FORCE_ADD
444: );
445:
446: d_position := 30;
447:
447:
448: -- third data set
449: process_lines_sync
450: (
451: p_data_set_type => PO_PDOI_CONSTANTS.g_LINE_CSR_SYNC
452: );
453:
454: d_position := 40;
455:
455:
456: -- Fourth data set
457: process_lines_sync
458: (
459: p_data_set_type => PO_PDOI_CONSTANTS.g_LINE_CSR_SYNC_ON_DESC
460: );
461:
462: d_position := 50;
463:
462: d_position := 50;
463:
464: -- delete all locations from po_line_locations_interface that are obsoleted
465: DELETE FROM po_line_locations_interface
466: WHERE process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_OBSOLETE
467: AND processing_id = PO_PDOI_PARAMS.g_processing_id;
468:
469: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_LINE_PROCESS);
470:
465: DELETE FROM po_line_locations_interface
466: WHERE process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_OBSOLETE
467: AND processing_id = PO_PDOI_PARAMS.g_processing_id;
468:
469: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_LINE_PROCESS);
470:
471: IF (PO_LOG.d_proc) THEN
472: PO_LOG.proc_end(d_module);
473: END IF;
496: --Parameters:
497: --IN:
498: --p_data_set_type
499: -- the value determines which data set is going to be processed:
500: -- PO_PDOI_CONSTANTS.g_LINE_CSR_ADD: first data set
501: -- PO_PDOI_CONSTANTS.g_LINE_CSR_FORCE_ADD: second data set
502: --IN OUT:
503: --OUT:
504: --End of Comments
497: --IN:
498: --p_data_set_type
499: -- the value determines which data set is going to be processed:
500: -- PO_PDOI_CONSTANTS.g_LINE_CSR_ADD: first data set
501: -- PO_PDOI_CONSTANTS.g_LINE_CSR_FORCE_ADD: second data set
502: --IN OUT:
503: --OUT:
504: --End of Comments
505: ------------------------------------------------------------------------
543:
544: -- Bug 5215781:
545: -- exit immediately if error threshold is hit for CATALOG UPLOAD
546: IF (PO_PDOI_PARAMS.g_request.calling_module =
547: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
548: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
549: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
550: IF (PO_LOG.d_stmt) THEN
551: PO_LOG.stmt(d_module, d_position, 'Exit from process_lines_add since' ||
573: -- Bug 5215781:
574: -- check whether num of error lines exceeds the error
575: -- threshold for each batch
576: IF (PO_PDOI_PARAMS.g_request.calling_module =
577: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
578: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
579: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
580: IF (PO_LOG.d_stmt) THEN
581: PO_LOG.stmt(d_module, d_position, 'error tolerance exceeded for',
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
719: );
720: l_rej_intf_line_id_tbl.DELETE;
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:
730: IF (l_lines.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
731: EXIT;
732: END IF;
733: EXCEPTION
734: WHEN g_snap_shot_too_old THEN
775: SELECT 'Y'
776: FROM po_lines_interface intf_line2
777: WHERE intf_line1.interface_header_id = intf_line2.interface_header_id
778: AND intf_line1.po_line_id = intf_line2.po_line_id
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
776: FROM po_lines_interface intf_line2
777: WHERE intf_line1.interface_header_id = intf_line2.interface_header_id
778: AND intf_line1.po_line_id = intf_line2.po_line_id
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: (
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
788: );
789:
790: d_position := 160;
791:
792: -- set status to NOTIFIED for price break lines if main po line is NOTIFIED
793: UPDATE po_lines_interface intf_line1
794: SET intf_line1.process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED
795: WHERE intf_line1.processing_id = PO_PDOI_PARAMS.g_processing_id
796: AND intf_line1.price_break_flag = 'Y'
797: AND EXISTS(
798: SELECT 'Y'
798: SELECT 'Y'
799: FROM po_lines_interface intf_line2
800: WHERE intf_line2.interface_header_id = intf_line1.interface_header_id
801: AND intf_line2.po_line_id = intf_line1.po_line_id
802: AND NVL(intf_line2.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)
803: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED
804: AND NVL(intf_line2.price_break_flag, 'N') = 'N');
805:
806: IF (PO_LOG.d_proc) THEN
799: FROM po_lines_interface intf_line2
800: WHERE intf_line2.interface_header_id = intf_line1.interface_header_id
801: AND intf_line2.po_line_id = intf_line1.po_line_id
802: AND NVL(intf_line2.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)
803: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED
804: AND NVL(intf_line2.price_break_flag, 'N') = 'N');
805:
806: IF (PO_LOG.d_proc) THEN
807: PO_LOG.proc_end(d_module);
836: --Parameters:
837: --IN:
838: -- p_data_set_type
839: -- the value determines which data set is going to be processed:
840: -- PO_PDOI_CONSTANTS.g_LINE_CSR_SYNC: third data set
841: -- PO_PDOI_CONSTANTS.g_LINE_CSR_SYNC_ON_DESC: fourth data set
842: --IN OUT:
843: --OUT:
844: --End of Comments
837: --IN:
838: -- p_data_set_type
839: -- the value determines which data set is going to be processed:
840: -- PO_PDOI_CONSTANTS.g_LINE_CSR_SYNC: third data set
841: -- PO_PDOI_CONSTANTS.g_LINE_CSR_SYNC_ON_DESC: fourth data set
842: --IN OUT:
843: --OUT:
844: --End of Comments
845: ------------------------------------------------------------------------
890:
891: -- Bug 5215781:
892: -- exit immediately if error threshold is hit for CATALOG UPLOAD
893: IF (PO_PDOI_PARAMS.g_request.calling_module =
894: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
895: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
896: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
897: IF (PO_LOG.d_stmt) THEN
898: PO_LOG.stmt(d_module, d_position, 'Exit from process_lines_sync since' ||
920: -- Bug 5215781:
921: -- check whether num of error lines exceeds the error
922: -- threshold for the previous batch
923: IF (PO_PDOI_PARAMS.g_request.calling_module =
924: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
925: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
926: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
927: d_position := 20;
928:
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:
1070: IF (l_lines.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
1071: EXIT;
1072: END IF;
1073: EXCEPTION
1074: WHEN g_snap_shot_too_old THEN
1122: AND NVL(intf_line3.price_break_flag, 'N') = 'N'
1123: AND intf_line3.interface_line_id < intf_line2.interface_line_id
1124: GROUP BY intf_line2.interface_line_id) v
1125: WHERE intf_line1.interface_line_id = v.match_intf_line_id
1126: AND NVL(intf_line1.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)
1127: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_REJECTED;
1128:
1129: d_position := 130;
1130:
1123: AND intf_line3.interface_line_id < intf_line2.interface_line_id
1124: GROUP BY intf_line2.interface_line_id) v
1125: WHERE intf_line1.interface_line_id = v.match_intf_line_id
1126: AND NVL(intf_line1.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)
1127: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_REJECTED;
1128:
1129: d_position := 130;
1130:
1131: PO_PDOI_UTL.reject_lines_intf
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
1136: );
1137:
1154: AND NVL(intf_line3.price_break_flag, 'N') = 'N'
1155: AND intf_line3.interface_line_id < intf_line2.interface_line_id
1156: GROUP BY intf_line2.interface_line_id) v
1157: WHERE intf_line1.interface_line_id = v.match_intf_line_id
1158: AND NVL(intf_line1.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)
1159: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED;
1160:
1161: d_position := 150;
1162:
1155: AND intf_line3.interface_line_id < intf_line2.interface_line_id
1156: GROUP BY intf_line2.interface_line_id) v
1157: WHERE intf_line1.interface_line_id = v.match_intf_line_id
1158: AND NVL(intf_line1.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)
1159: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED;
1160:
1161: d_position := 150;
1162:
1163: FORALL i IN 1..l_notified_intf_line_id_tbl.COUNT
1161: d_position := 150;
1162:
1163: FORALL i IN 1..l_notified_intf_line_id_tbl.COUNT
1164: UPDATE po_lines_interface
1165: SET process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED
1166: WHERE interface_line_id = l_notified_intf_line_id_tbl(i);
1167:
1168: d_position := 160;
1169:
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
1324: );
1325: l_rej_intf_line_id_tbl.DELETE;
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
1469: );
1470: l_rej_intf_line_id_tbl.DELETE;
1537:
1538: -- Bug 5215781:
1539: -- exit immediately if error threshold is hit for CATALOG UPLOAD
1540: IF (PO_PDOI_PARAMS.g_request.calling_module =
1541: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
1542: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
1543: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
1544: IF (PO_LOG.d_stmt) THEN
1545: PO_LOG.stmt(d_module, d_position, 'Exit from process_line_locations since' ||
1551: END IF;
1552:
1553: d_position := 5;
1554:
1555: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_LINE_LOC_PROCESS);
1556:
1557: -- open cursor for the correct query
1558: PO_PDOI_LINE_LOC_PROCESS_PVT.open_line_locs
1559: (
1568: -- Bug 5215781:
1569: -- check whether num of error lines exceeds the error
1570: -- threshold for the previous batch
1571: IF (PO_PDOI_PARAMS.g_request.calling_module =
1572: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
1573: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
1574: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
1575: d_position := 20;
1576:
1623: -- check whether provided shipment_num is unqiue across interface,
1624: -- draft and txn tables.
1625: -- logic is performed for Standard PO only
1626: IF (PO_PDOI_PARAMS.g_request.document_type =
1627: PO_PDOI_CONSTANTS.g_DOC_TYPE_STANDARD) THEN
1628: PO_PDOI_MAINPROC_UTL_PVT.check_shipment_num_unique
1629: (
1630: p_po_line_id_tbl => l_line_locs.ln_po_line_id_tbl,
1631: p_draft_id_tbl => l_line_locs.draft_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
1715: );
1716: l_rej_intf_line_loc_id_tbl.DELETE;
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;
1739:
1740: l_max_intf_line_loc_id := l_line_locs.intf_line_loc_id_tbl(l_line_locs.rec_count);
1771: END IF;
1772:
1773: -- line location post processing
1774: IF (PO_PDOI_PARAMS.g_request.document_type =
1775: PO_PDOI_CONSTANTS.g_DOC_TYPE_STANDARD) THEN
1776: d_position := 130;
1777:
1778: -- update amount or quantity value on po_lines_draft_all based
1779: -- on the values on shipment for Standard PO.
1782: p_po_line_id_tbl => l_processed_line_id_tbl,
1783: p_draft_id_tbl => l_processed_draft_id_tbl
1784: );
1785: ELSIF (PO_PDOI_PARAMS.g_request.document_type =
1786: PO_PDOI_CONSTANTS.g_DOC_TYPE_QUOTATION) THEN
1787: d_position := 140;
1788:
1789: -- delete all existing price breaks for quotation update
1790: PO_PDOI_LINE_LOC_PROCESS_PVT.delete_exist_price_breaks
1799: -- on price and price break. The logic is removed in R12.
1800: NULL;
1801: END IF;
1802:
1803: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_LINE_LOC_PROCESS);
1804:
1805: IF (PO_LOG.d_proc) THEN
1806: PO_LOG.proc_end(d_module);
1807: END IF;
1860: IF (PO_LOG.d_proc) THEN
1861: PO_LOG.proc_begin(d_module);
1862: END IF;
1863:
1864: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_DIST_PROCESS);
1865:
1866: -- open cursor for the correct query
1867: PO_PDOI_DIST_PROCESS_PVT.open_dists
1868: (
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: );
1973: l_rej_intf_dist_id_tbl.DELETE;
1974:
1976:
1977: -- set status to ACCEPTED for records without errors on intf table
1978: FORALL i IN 1..l_dists.intf_dist_id_tbl.COUNT
1979: UPDATE po_distributions_interface
1980: SET process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_ACCEPTED
1981: WHERE interface_distribution_id = l_dists.intf_dist_id_tbl(i)
1982: AND l_dists.error_flag_tbl(i) = FND_API.g_FALSE;
1983:
1984: d_position := 110;
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;
1991:
1992: l_max_intf_dist_id := l_dists.intf_dist_id_tbl(l_dists.rec_count);
2021: IF (l_dists_csr%ISOPEN) THEN
2022: CLOSE l_dists_csr;
2023: END IF;
2024:
2025: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_DIST_PROCESS);
2026:
2027: IF (PO_LOG.d_proc) THEN
2028: PO_LOG.proc_end(d_module);
2029: END IF;
2085:
2086: -- Bug 5215781:
2087: -- exit immediately if error threshold is hit for CATALOG UPLOAD
2088: IF (PO_PDOI_PARAMS.g_request.calling_module =
2089: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
2090: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
2091: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
2092: IF (PO_LOG.d_stmt) THEN
2093: PO_LOG.stmt(d_module, d_position, 'Exit from process_price_diffs since' ||
2099: END IF;
2100:
2101: d_position := 5;
2102:
2103: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_PRICE_DIFF_PROCESS);
2104:
2105: -- open cursor for the correct query
2106: PO_PDOI_PRICE_DIFF_PROCESS_PVT.open_price_diffs
2107: (
2116: -- Bug 5215781:
2117: -- check whether num of error lines exceeds the error
2118: -- threshold for the previous batch
2119: IF (PO_PDOI_PARAMS.g_request.calling_module =
2120: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
2121: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
2122: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
2123: d_position := 20;
2124:
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: );
2195: l_rej_intf_price_diff_id_tbl.DELETE;
2196:
2198:
2199: -- set status to ACCEPTED for records without errors on intf table
2200: FORALL i IN 1..l_price_diffs.intf_price_diff_id_tbl.COUNT
2201: UPDATE po_price_diff_interface
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;
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;
2211:
2212: l_max_intf_price_diff_id := l_price_diffs.intf_price_diff_id_tbl(l_price_diffs.rec_count);
2241: IF (l_price_diffs_csr%ISOPEN) THEN
2242: CLOSE l_price_diffs_csr;
2243: END IF;
2244:
2245: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_PRICE_DIFF_PROCESS);
2246:
2247: IF (PO_LOG.d_proc) THEN
2248: PO_LOG.proc_end(d_module);
2249: END IF;
2293:
2294: -- Bug 5215781:
2295: -- exit immediately if error threshold is hit for CATALOG UPLOAD
2296: IF (PO_PDOI_PARAMS.g_request.calling_module =
2297: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
2298: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
2299: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
2300: IF (PO_LOG.d_stmt) THEN
2301: PO_LOG.stmt(d_module, d_position, 'Exit from process_attributes since' ||
2307: END IF;
2308:
2309: d_position := 10;
2310:
2311: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_ATTR_PROCESS);
2312:
2313: -- process all lines in po_attr_values_interface table
2314: process_attr_values;
2315:
2324: PO_PDOI_ATTR_PROCESS_PVT.add_default_attrs;
2325:
2326: d_position := 40;
2327:
2328: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_ATTR_PROCESS);
2329:
2330: IF (PO_LOG.d_proc) THEN
2331: PO_LOG.proc_end(d_module);
2332: END IF;
2478:
2479: -- set status to ACCEPTED for all records
2480: FORALL i IN 1..l_attr_values.intf_attr_values_id_tbl.COUNT
2481: UPDATE po_attr_values_interface
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;
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;
2491:
2492: l_max_intf_attr_values_id := l_attr_values.intf_attr_values_id_tbl(l_attr_values.rec_count);
2669:
2670: -- set status to ACCEPTED for all records
2671: FORALL i IN 1..l_attr_values_tlp.intf_attr_values_tlp_id_tbl.COUNT
2672: UPDATE po_attr_values_tlp_interface
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;
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;
2682:
2683: l_max_intf_attr_values_tlp_id := l_attr_values_tlp.intf_attr_values_tlp_id_tbl(l_attr_values_tlp.rec_count);