DBA Data[Home] [Help]

APPS.PO_PDOI_MAINPROC_PVT dependencies on PO_PDOI_CONSTANTS

Line 103: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_MAIN_PROCESSING);

99: PO_LOG.proc_begin(d_module, 'start main process for header group',
100: PO_PDOI_PARAMS.g_current_round_num);
101: END IF;
102:
103: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_MAIN_PROCESSING);
104:
105: -- clean up cache before each group processing
106: PO_PDOI_MAINPROC_UTL_PVT.cleanup;
107:

Line 120: (PO_PDOI_CONSTANTS.g_DOC_TYPE_BLANKET, PO_PDOI_CONSTANTS.g_DOC_TYPE_QUOTATION)) THEN

116:
117: d_position := 20;
118:
119: IF (PO_PDOI_PARAMS.g_request.document_type IN
120: (PO_PDOI_CONSTANTS.g_DOC_TYPE_BLANKET, PO_PDOI_CONSTANTS.g_DOC_TYPE_QUOTATION)) THEN
121: process_attributes;
122: END IF;
123:
124: d_position := 30;

Line 131: PO_PDOI_CONSTANTS.g_DOC_TYPE_STANDARD) THEN

127:
128: d_position := 40;
129:
130: IF (PO_PDOI_PARAMS.g_request.document_type =
131: PO_PDOI_CONSTANTS.g_DOC_TYPE_STANDARD) THEN
132: process_distributions;
133: END IF;
134:
135: d_position := 50;

Line 144: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND

140:
141: -- Bug 5215781:
142: -- Remove all unprocessed records if error threshold is hit for CATALOG UPLOAD
143: IF (PO_PDOI_PARAMS.g_request.calling_module =
144: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
145: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
146: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
147: IF (PO_LOG.d_stmt) THEN
148: PO_LOG.stmt(d_module, d_position, 'Unprocessed records will be removed for header ',

Line 158: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_MAIN_PROCESSING);

154: p_intf_header_id => PO_PDOI_PARAMS.g_request.interface_header_id
155: );
156: END IF;
157:
158: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_MAIN_PROCESSING);
159:
160: IF (PO_LOG.d_proc) THEN
161: PO_LOG.proc_end(d_module);
162: END IF;

Line 229: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_HEADER_PROCESS);

225: IF (PO_LOG.d_proc) THEN
226: PO_LOG.proc_begin(d_module);
227: END IF;
228:
229: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_HEADER_PROCESS);
230:
231: -- open cursor for the query which retrieve the header info
232: PO_PDOI_HEADER_PROCESS_PVT.open_headers
233: (

Line 318: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_HEADER_ID,

314: END IF;
315: END LOOP;
316: PO_PDOI_UTL.reject_headers_intf
317: (
318: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_HEADER_ID,
319: p_id_tbl => l_rej_intf_header_id_tbl,
320: p_cascade => FND_API.g_TRUE
321: );
322: l_rej_intf_header_id_tbl.DELETE;

Line 333: IF (l_headers.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN

329: -- set maximal intf_header_id read so far(used in next batch read)
330: l_max_intf_header_id := l_headers.intf_header_id_tbl(l_headers.rec_count);
331:
332: -- exit if this is the last batch
333: IF (l_headers.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
334: EXIT;
335: END IF;
336: EXCEPTION
337: WHEN g_snap_shot_too_old THEN

Line 394: PO_PDOI_CONSTANTS.g_call_mod_CATALOG_UPLOAD)

390:
391: d_position := 100;
392:
393: IF (PO_PDOI_PARAMS.g_request.calling_module =
394: PO_PDOI_CONSTANTS.g_call_mod_CATALOG_UPLOAD)
395: THEN
396:
397: l_cat_upload_head_exists :=TRUE;
398:

Line 414: AND action = PO_PDOI_CONSTANTS.g_ACTION_UPDATE

410: FROM po_headers_interface
411: WHERE processing_id = PO_PDOI_PARAMS.g_processing_id
412: AND processing_round_num = PO_PDOI_PARAMS.g_current_round_num
413: AND interface_header_id > l_max_intf_header_id
414: AND action = PO_PDOI_CONSTANTS.g_ACTION_UPDATE
415: ORDER by interface_header_id;
416:
417: IF (PO_LOG.d_stmt) THEN
418: PO_LOG.stmt(d_module, d_position, 'l_headers.draft_id_tbl.count',

Line 467: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_HEADER_PROCESS);

463: END IF;
464:
465: -- Bug:16730873 End
466:
467: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_HEADER_PROCESS);
468:
469: IF (PO_LOG.d_proc) THEN
470: PO_LOG.proc_end(d_module);
471: END IF;

Line 531: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_LINE_PROCESS);

527: IF (PO_LOG.d_proc) THEN
528: PO_LOG.proc_begin(d_module);
529: END IF;
530:
531: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_LINE_PROCESS);
532:
533: -- reject lines with existing line_num when updating standard PO
534: IF (PO_PDOI_PARAMS.g_request.document_type =
535: PO_PDOI_CONSTANTS.g_DOC_TYPE_STANDARD) THEN

Line 535: PO_PDOI_CONSTANTS.g_DOC_TYPE_STANDARD) THEN

531: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_LINE_PROCESS);
532:
533: -- reject lines with existing line_num when updating standard PO
534: IF (PO_PDOI_PARAMS.g_request.document_type =
535: PO_PDOI_CONSTANTS.g_DOC_TYPE_STANDARD) THEN
536: PO_PDOI_LINE_PROCESS_PVT.reject_dup_lines_for_spo;
537: END IF;
538:
539: -- reject lines with invalid line level action.

Line 546: PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED) THEN

542: -- the notified lines, the system has set the line
543: -- level action to either 'ADD' or 'UPADTE', we don't
544: -- need to check line level action for NOTOFIED lines
545: IF (PO_PDOI_PARAMS.g_request.process_code <>
546: PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED) THEN
547: PO_PDOI_LINE_PROCESS_PVT.reject_invalid_action_lines;
548: END IF;
549:
550: d_position := 10;

Line 555: p_data_set_type => PO_PDOI_CONSTANTS.g_LINE_CSR_ADD

551:
552: -- first data set
553: process_lines_add
554: (
555: p_data_set_type => PO_PDOI_CONSTANTS.g_LINE_CSR_ADD
556: );
557:
558: d_position := 20;
559:

Line 563: p_data_set_type => PO_PDOI_CONSTANTS.g_LINE_CSR_FORCE_ADD

559:
560: -- second data set
561: process_lines_add
562: (
563: p_data_set_type => PO_PDOI_CONSTANTS.g_LINE_CSR_FORCE_ADD
564: );
565:
566: d_position := 30;
567:

Line 571: p_data_set_type => PO_PDOI_CONSTANTS.g_LINE_CSR_SYNC

567:
568: -- third data set
569: process_lines_sync
570: (
571: p_data_set_type => PO_PDOI_CONSTANTS.g_LINE_CSR_SYNC
572: );
573:
574: d_position := 40;
575:

Line 579: p_data_set_type => PO_PDOI_CONSTANTS.g_LINE_CSR_SYNC_ON_DESC

575:
576: -- Fourth data set
577: process_lines_sync
578: (
579: p_data_set_type => PO_PDOI_CONSTANTS.g_LINE_CSR_SYNC_ON_DESC
580: );
581:
582: d_position := 50;
583:

Line 588: p_data_set_type => PO_PDOI_CONSTANTS.g_LINE_CSR_INFO_LINE_ADD

584: -- PDOI CLM Integration
585: -- Adding a fifth data set to process the info lines
586: process_info_lines
587: (
588: p_data_set_type => PO_PDOI_CONSTANTS.g_LINE_CSR_INFO_LINE_ADD
589: );
590: --Bug13343886
591: if PO_PDOI_CONSTANTS.g_GATHER_STATS = 'Y' THEN
592: d_position := 55;

Line 591: if PO_PDOI_CONSTANTS.g_GATHER_STATS = 'Y' THEN

587: (
588: p_data_set_type => PO_PDOI_CONSTANTS.g_LINE_CSR_INFO_LINE_ADD
589: );
590: --Bug13343886
591: if PO_PDOI_CONSTANTS.g_GATHER_STATS = 'Y' THEN
592: d_position := 55;
593: gather_stats('PO_LINES_DRAFT_ALL',d_api_name,d_position);
594: END IF;
595: --Bug13343886

Line 599: WHERE process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_OBSOLETE

595: --Bug13343886
596:
597: -- delete all locations from po_line_locations_interface that are obsoleted
598: DELETE FROM po_line_locations_interface
599: WHERE process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_OBSOLETE
600: AND processing_id = PO_PDOI_PARAMS.g_processing_id;
601:
602: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_LINE_PROCESS);
603:

Line 602: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_LINE_PROCESS);

598: DELETE FROM po_line_locations_interface
599: WHERE process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_OBSOLETE
600: AND processing_id = PO_PDOI_PARAMS.g_processing_id;
601:
602: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_LINE_PROCESS);
603:
604: IF (PO_LOG.d_proc) THEN
605: PO_LOG.proc_end(d_module);
606: END IF;

Line 633: -- PO_PDOI_CONSTANTS.g_LINE_CSR_ADD: first data set

629: --Parameters:
630: --IN:
631: --p_data_set_type
632: -- the value determines which data set is going to be processed:
633: -- PO_PDOI_CONSTANTS.g_LINE_CSR_ADD: first data set
634: -- PO_PDOI_CONSTANTS.g_LINE_CSR_FORCE_ADD: second data set
635: --IN OUT:
636: --OUT:
637: --End of Comments

Line 634: -- PO_PDOI_CONSTANTS.g_LINE_CSR_FORCE_ADD: second data set

630: --IN:
631: --p_data_set_type
632: -- the value determines which data set is going to be processed:
633: -- PO_PDOI_CONSTANTS.g_LINE_CSR_ADD: first data set
634: -- PO_PDOI_CONSTANTS.g_LINE_CSR_FORCE_ADD: second data set
635: --IN OUT:
636: --OUT:
637: --End of Comments
638: ------------------------------------------------------------------------

Line 684: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND

680:
681: -- Bug 5215781:
682: -- exit immediately if error threshold is hit for CATALOG UPLOAD
683: IF (PO_PDOI_PARAMS.g_request.calling_module =
684: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
685: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
686: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
687: IF (PO_LOG.d_stmt) THEN
688: PO_LOG.stmt(d_module, d_position, 'Exit from process_lines_add since' ||

Line 714: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND

710: -- Bug 5215781:
711: -- check whether num of error lines exceeds the error
712: -- threshold for each batch
713: IF (PO_PDOI_PARAMS.g_request.calling_module =
714: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
715: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
716: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
717: IF (PO_LOG.d_stmt) THEN
718: PO_LOG.stmt(d_module, d_position, 'error tolerance exceeded for',

Line 868: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_ID,

864: END IF;
865: END LOOP;
866: PO_PDOI_UTL.reject_lines_intf
867: (
868: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_ID,
869: p_id_tbl => l_rej_intf_line_id_tbl,
870: p_cascade => FND_API.g_TRUE
871: );
872: l_rej_intf_line_id_tbl.DELETE;

Line 892: -- IF (l_lines.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN

888: -- bug#13367649- use local variable l_lines_count instead as
889: -- l_lines.rec_count now contains number of po_lines to be created
890: -- for this fetch, which can be less than the batch size
891:
892: -- IF (l_lines.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
893:
894: IF (l_lines_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
895: EXIT;
896: END IF;

Line 894: IF (l_lines_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN

890: -- for this fetch, which can be less than the batch size
891:
892: -- IF (l_lines.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
893:
894: IF (l_lines_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
895: EXIT;
896: END IF;
897: EXCEPTION
898: WHEN g_snap_shot_too_old THEN

Line 942: AND NVL(intf_line2.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)

938: SELECT 'Y'
939: FROM po_lines_interface intf_line2
940: WHERE intf_line1.interface_header_id = intf_line2.interface_header_id
941: AND intf_line1.po_line_id = intf_line2.po_line_id
942: AND NVL(intf_line2.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)
943: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_REJECTED
944: AND NVL(intf_line2.price_break_flag, 'N') = 'N');
945: d_position := 150;
946: PO_PDOI_UTL.reject_lines_intf

Line 943: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_REJECTED

939: FROM po_lines_interface intf_line2
940: WHERE intf_line1.interface_header_id = intf_line2.interface_header_id
941: AND intf_line1.po_line_id = intf_line2.po_line_id
942: AND NVL(intf_line2.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)
943: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_REJECTED
944: AND NVL(intf_line2.price_break_flag, 'N') = 'N');
945: d_position := 150;
946: PO_PDOI_UTL.reject_lines_intf
947: (

Line 948: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_ID,

944: AND NVL(intf_line2.price_break_flag, 'N') = 'N');
945: d_position := 150;
946: PO_PDOI_UTL.reject_lines_intf
947: (
948: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_ID,
949: p_id_tbl => l_rej_intf_line_id_tbl,
950: p_cascade => FND_API.g_TRUE
951: );
952:

Line 957: SET intf_line1.process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED

953: d_position := 160;
954:
955: -- set status to NOTIFIED for price break lines if main po line is NOTIFIED
956: UPDATE po_lines_interface intf_line1
957: SET intf_line1.process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED
958: WHERE intf_line1.processing_id = PO_PDOI_PARAMS.g_processing_id
959: AND intf_line1.price_break_flag = 'Y'
960: AND EXISTS(
961: SELECT 'Y'

Line 965: AND NVL(intf_line2.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)

961: SELECT 'Y'
962: FROM po_lines_interface intf_line2
963: WHERE intf_line2.interface_header_id = intf_line1.interface_header_id
964: AND intf_line2.po_line_id = intf_line1.po_line_id
965: AND NVL(intf_line2.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)
966: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED
967: AND NVL(intf_line2.price_break_flag, 'N') = 'N');
968:
969: IF (PO_LOG.d_proc) THEN

Line 966: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED

962: FROM po_lines_interface intf_line2
963: WHERE intf_line2.interface_header_id = intf_line1.interface_header_id
964: AND intf_line2.po_line_id = intf_line1.po_line_id
965: AND NVL(intf_line2.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)
966: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED
967: AND NVL(intf_line2.price_break_flag, 'N') = 'N');
968:
969: IF (PO_LOG.d_proc) THEN
970: PO_LOG.proc_end(d_module);

Line 1003: -- PO_PDOI_CONSTANTS.g_LINE_CSR_SYNC: third data set

999: --Parameters:
1000: --IN:
1001: -- p_data_set_type
1002: -- the value determines which data set is going to be processed:
1003: -- PO_PDOI_CONSTANTS.g_LINE_CSR_SYNC: third data set
1004: -- PO_PDOI_CONSTANTS.g_LINE_CSR_SYNC_ON_DESC: fourth data set
1005: --IN OUT:
1006: --OUT:
1007: --End of Comments

Line 1004: -- PO_PDOI_CONSTANTS.g_LINE_CSR_SYNC_ON_DESC: fourth data set

1000: --IN:
1001: -- p_data_set_type
1002: -- the value determines which data set is going to be processed:
1003: -- PO_PDOI_CONSTANTS.g_LINE_CSR_SYNC: third data set
1004: -- PO_PDOI_CONSTANTS.g_LINE_CSR_SYNC_ON_DESC: fourth data set
1005: --IN OUT:
1006: --OUT:
1007: --End of Comments
1008: ------------------------------------------------------------------------

Line 1057: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND

1053:
1054: -- Bug 5215781:
1055: -- exit immediately if error threshold is hit for CATALOG UPLOAD
1056: IF (PO_PDOI_PARAMS.g_request.calling_module =
1057: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
1058: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
1059: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
1060: IF (PO_LOG.d_stmt) THEN
1061: PO_LOG.stmt(d_module, d_position, 'Exit from process_lines_sync since' ||

Line 1087: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND

1083: -- Bug 5215781:
1084: -- check whether num of error lines exceeds the error
1085: -- threshold for the previous batch
1086: IF (PO_PDOI_PARAMS.g_request.calling_module =
1087: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
1088: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
1089: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
1090: d_position := 20;
1091:

Line 1233: IF (l_lines.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN

1229:
1230: -- set the maximal interface_line_id processed in this batch
1231: l_max_intf_line_id := l_lines.intf_line_id_tbl(l_lines.rec_count);
1232:
1233: IF (l_lines.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
1234: EXIT;
1235: END IF;
1236: EXCEPTION
1237: WHEN g_snap_shot_too_old THEN

Line 1289: AND NVL(intf_line1.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)

1285: AND NVL(intf_line3.price_break_flag, 'N') = 'N'
1286: AND intf_line3.interface_line_id < intf_line2.interface_line_id
1287: GROUP BY intf_line2.interface_line_id) v
1288: WHERE intf_line1.interface_line_id = v.match_intf_line_id
1289: AND NVL(intf_line1.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)
1290: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_REJECTED;
1291:
1292: d_position := 130;
1293:

Line 1290: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_REJECTED;

1286: AND intf_line3.interface_line_id < intf_line2.interface_line_id
1287: GROUP BY intf_line2.interface_line_id) v
1288: WHERE intf_line1.interface_line_id = v.match_intf_line_id
1289: AND NVL(intf_line1.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)
1290: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_REJECTED;
1291:
1292: d_position := 130;
1293:
1294: PO_PDOI_UTL.reject_lines_intf

Line 1296: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_ID,

1292: d_position := 130;
1293:
1294: PO_PDOI_UTL.reject_lines_intf
1295: (
1296: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_ID,
1297: p_id_tbl => l_rej_intf_line_id_tbl,
1298: p_cascade => FND_API.g_TRUE
1299: );
1300:

Line 1321: AND NVL(intf_line1.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)

1317: AND NVL(intf_line3.price_break_flag, 'N') = 'N'
1318: AND intf_line3.interface_line_id < intf_line2.interface_line_id
1319: GROUP BY intf_line2.interface_line_id) v
1320: WHERE intf_line1.interface_line_id = v.match_intf_line_id
1321: AND NVL(intf_line1.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)
1322: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED;
1323:
1324: d_position := 150;
1325:

Line 1322: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED;

1318: AND intf_line3.interface_line_id < intf_line2.interface_line_id
1319: GROUP BY intf_line2.interface_line_id) v
1320: WHERE intf_line1.interface_line_id = v.match_intf_line_id
1321: AND NVL(intf_line1.process_code, PO_PDOI_CONSTANTS.g_PROCESS_CODE_PENDING)
1322: = PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED;
1323:
1324: d_position := 150;
1325:
1326: FORALL i IN 1..l_notified_intf_line_id_tbl.COUNT

Line 1328: SET process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED

1324: d_position := 150;
1325:
1326: FORALL i IN 1..l_notified_intf_line_id_tbl.COUNT
1327: UPDATE po_lines_interface
1328: SET process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_NOTIFIED
1329: WHERE interface_line_id = l_notified_intf_line_id_tbl(i);
1330:
1331: d_position := 160;
1332:

Line 1484: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_ID,

1480: END IF;
1481: END LOOP;
1482: PO_PDOI_UTL.reject_lines_intf
1483: (
1484: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_ID,
1485: p_id_tbl => l_rej_intf_line_id_tbl,
1486: p_cascade => FND_API.g_TRUE
1487: );
1488: l_rej_intf_line_id_tbl.DELETE;

Line 1629: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_ID,

1625: END IF;
1626: END LOOP;
1627: PO_PDOI_UTL.reject_lines_intf
1628: (
1629: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_ID,
1630: p_id_tbl => l_rej_intf_line_id_tbl,
1631: p_cascade => FND_API.g_TRUE
1632: );
1633: l_rej_intf_line_id_tbl.DELETE;

Line 1704: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND

1700:
1701: -- Bug 5215781:
1702: -- exit immediately if error threshold is hit for CATALOG UPLOAD
1703: IF (PO_PDOI_PARAMS.g_request.calling_module =
1704: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
1705: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
1706: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
1707: IF (PO_LOG.d_stmt) THEN
1708: PO_LOG.stmt(d_module, d_position, 'Exit from process_line_locations since' ||

Line 1718: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_LINE_LOC_PROCESS);

1714: END IF;
1715:
1716: d_position := 5;
1717:
1718: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_LINE_LOC_PROCESS);
1719:
1720: -- open cursor for the correct query
1721: PO_PDOI_LINE_LOC_PROCESS_PVT.open_line_locs
1722: (

Line 1735: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND

1731: -- Bug 5215781:
1732: -- check whether num of error lines exceeds the error
1733: -- threshold for the previous batch
1734: IF (PO_PDOI_PARAMS.g_request.calling_module =
1735: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
1736: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
1737: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
1738: d_position := 20;
1739:

Line 1790: PO_PDOI_CONSTANTS.g_DOC_TYPE_STANDARD) THEN

1786: -- check whether provided shipment_num is unqiue across interface,
1787: -- draft and txn tables.
1788: -- logic is performed for Standard PO only
1789: IF (PO_PDOI_PARAMS.g_request.document_type =
1790: PO_PDOI_CONSTANTS.g_DOC_TYPE_STANDARD) THEN
1791: PO_PDOI_MAINPROC_UTL_PVT.check_shipment_num_unique
1792: (
1793: p_po_line_id_tbl => l_line_locs.ln_po_line_id_tbl,
1794: p_draft_id_tbl => l_line_locs.draft_id_tbl,

Line 1875: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_LOCATION_ID,

1871: END IF;
1872:
1873: PO_PDOI_UTL.reject_line_locations_intf
1874: (
1875: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_LOCATION_ID,
1876: p_id_tbl => l_rej_intf_line_loc_id_tbl,
1877: p_cascade => FND_API.g_TRUE
1878: );
1879: l_rej_intf_line_loc_id_tbl.DELETE;

Line 1899: IF (l_line_locs.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN

1895:
1896: -- commit
1897: PO_PDOI_UTL.commit_work;
1898:
1899: IF (l_line_locs.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
1900: EXIT;
1901: END IF;
1902:
1903: l_max_intf_line_loc_id := l_line_locs.intf_line_loc_id_tbl(l_line_locs.rec_count);

Line 1938: PO_PDOI_CONSTANTS.g_DOC_TYPE_STANDARD) THEN

1934: END IF;
1935:
1936: -- line location post processing
1937: IF (PO_PDOI_PARAMS.g_request.document_type =
1938: PO_PDOI_CONSTANTS.g_DOC_TYPE_STANDARD) THEN
1939: d_position := 130;
1940:
1941: -- update amount or quantity value on po_lines_draft_all based
1942: -- on the values on shipment for Standard PO.

Line 1949: PO_PDOI_CONSTANTS.g_DOC_TYPE_QUOTATION) THEN

1945: p_po_line_id_tbl => l_processed_line_id_tbl,
1946: p_draft_id_tbl => l_processed_draft_id_tbl
1947: );
1948: ELSIF (PO_PDOI_PARAMS.g_request.document_type =
1949: PO_PDOI_CONSTANTS.g_DOC_TYPE_QUOTATION) THEN
1950: d_position := 140;
1951:
1952: -- delete all existing price breaks for quotation update
1953: PO_PDOI_LINE_LOC_PROCESS_PVT.delete_exist_price_breaks

Line 1966: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_LINE_LOC_PROCESS);

1962: -- on price and price break. The logic is removed in R12.
1963: NULL;
1964: END IF;
1965:
1966: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_LINE_LOC_PROCESS);
1967:
1968: IF (PO_LOG.d_proc) THEN
1969: PO_LOG.proc_end(d_module);
1970: END IF;

Line 2027: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_DIST_PROCESS);

2023: IF (PO_LOG.d_proc) THEN
2024: PO_LOG.proc_begin(d_module);
2025: END IF;
2026:
2027: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_DIST_PROCESS);
2028:
2029: -- open cursor for the correct query
2030: PO_PDOI_DIST_PROCESS_PVT.open_dists
2031: (

Line 2133: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_DISTRIBUTION_ID,

2129: d_position := 90;
2130:
2131: PO_PDOI_UTL.reject_distributions_intf
2132: (
2133: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_DISTRIBUTION_ID,
2134: p_id_tbl => l_rej_intf_dist_id_tbl
2135: );
2136: l_rej_intf_dist_id_tbl.DELETE;
2137:

Line 2143: SET process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_ACCEPTED

2139:
2140: -- set status to ACCEPTED for records without errors on intf table
2141: FORALL i IN 1..l_dists.intf_dist_id_tbl.COUNT
2142: UPDATE po_distributions_interface
2143: SET process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_ACCEPTED
2144: WHERE interface_distribution_id = l_dists.intf_dist_id_tbl(i)
2145: AND l_dists.error_flag_tbl(i) = FND_API.g_FALSE;
2146:
2147: d_position := 110;

Line 2151: IF (l_dists.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN

2147: d_position := 110;
2148:
2149: PO_PDOI_UTL.commit_work;
2150:
2151: IF (l_dists.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
2152: EXIT;
2153: END IF;
2154:
2155: l_max_intf_dist_id := l_dists.intf_dist_id_tbl(l_dists.rec_count);

Line 2188: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_DIST_PROCESS);

2184: IF (l_dists_csr%ISOPEN) THEN
2185: CLOSE l_dists_csr;
2186: END IF;
2187:
2188: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_DIST_PROCESS);
2189:
2190: IF (PO_LOG.d_proc) THEN
2191: PO_LOG.proc_end(d_module);
2192: END IF;

Line 2252: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND

2248:
2249: -- Bug 5215781:
2250: -- exit immediately if error threshold is hit for CATALOG UPLOAD
2251: IF (PO_PDOI_PARAMS.g_request.calling_module =
2252: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
2253: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
2254: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
2255: IF (PO_LOG.d_stmt) THEN
2256: PO_LOG.stmt(d_module, d_position, 'Exit from process_price_diffs since' ||

Line 2266: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_PRICE_DIFF_PROCESS);

2262: END IF;
2263:
2264: d_position := 5;
2265:
2266: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_PRICE_DIFF_PROCESS);
2267:
2268: -- open cursor for the correct query
2269: PO_PDOI_PRICE_DIFF_PROCESS_PVT.open_price_diffs
2270: (

Line 2283: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND

2279: -- Bug 5215781:
2280: -- check whether num of error lines exceeds the error
2281: -- threshold for the previous batch
2282: IF (PO_PDOI_PARAMS.g_request.calling_module =
2283: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
2284: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
2285: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
2286: d_position := 20;
2287:

Line 2355: p_id_param_type => PO_PDOI_CONSTANTS.g_PRICE_DIFF_INTERFACE_ID,

2351: END IF;
2352:
2353: PO_PDOI_UTL.reject_price_diff_intf
2354: (
2355: p_id_param_type => PO_PDOI_CONSTANTS.g_PRICE_DIFF_INTERFACE_ID,
2356: p_id_tbl => l_rej_intf_price_diff_id_tbl
2357: );
2358: l_rej_intf_price_diff_id_tbl.DELETE;
2359:

Line 2365: SET process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_ACCEPTED

2361:
2362: -- set status to ACCEPTED for records without errors on intf table
2363: FORALL i IN 1..l_price_diffs.intf_price_diff_id_tbl.COUNT
2364: UPDATE po_price_diff_interface
2365: SET process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_ACCEPTED
2366: WHERE price_diff_interface_id = l_price_diffs.intf_price_diff_id_tbl(i)
2367: AND l_price_diffs.error_flag_tbl(i) = FND_API.g_FALSE;
2368:
2369: PO_PDOI_UTL.commit_work;

Line 2371: IF (l_price_diffs.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN

2367: AND l_price_diffs.error_flag_tbl(i) = FND_API.g_FALSE;
2368:
2369: PO_PDOI_UTL.commit_work;
2370:
2371: IF (l_price_diffs.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
2372: EXIT;
2373: END IF;
2374:
2375: l_max_intf_price_diff_id := l_price_diffs.intf_price_diff_id_tbl(l_price_diffs.rec_count);

Line 2408: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_PRICE_DIFF_PROCESS);

2404: IF (l_price_diffs_csr%ISOPEN) THEN
2405: CLOSE l_price_diffs_csr;
2406: END IF;
2407:
2408: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_PRICE_DIFF_PROCESS);
2409:
2410: IF (PO_LOG.d_proc) THEN
2411: PO_LOG.proc_end(d_module);
2412: END IF;

Line 2460: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND

2456:
2457: -- Bug 5215781:
2458: -- exit immediately if error threshold is hit for CATALOG UPLOAD
2459: IF (PO_PDOI_PARAMS.g_request.calling_module =
2460: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
2461: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
2462: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
2463: IF (PO_LOG.d_stmt) THEN
2464: PO_LOG.stmt(d_module, d_position, 'Exit from process_attributes since' ||

Line 2474: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_ATTR_PROCESS);

2470: END IF;
2471:
2472: d_position := 10;
2473:
2474: PO_TIMING_UTL.start_time(PO_PDOI_CONSTANTS.g_T_ATTR_PROCESS);
2475:
2476: -- process all lines in po_attr_values_interface table
2477: process_attr_values;
2478:

Line 2491: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_ATTR_PROCESS);

2487: PO_PDOI_ATTR_PROCESS_PVT.add_default_attrs;
2488:
2489: d_position := 40;
2490:
2491: PO_TIMING_UTL.stop_time(PO_PDOI_CONSTANTS.g_T_ATTR_PROCESS);
2492:
2493: IF (PO_LOG.d_proc) THEN
2494: PO_LOG.proc_end(d_module);
2495: END IF;

Line 2645: SET process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_ACCEPTED

2641:
2642: -- set status to ACCEPTED for all records
2643: FORALL i IN 1..l_attr_values.intf_attr_values_id_tbl.COUNT
2644: UPDATE po_attr_values_interface
2645: SET process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_ACCEPTED
2646: WHERE interface_attr_values_id = l_attr_values.intf_attr_values_id_tbl(i)
2647: AND l_attr_values.error_flag_tbl(i) = FND_API.g_FALSE;
2648:
2649: --Bug13343886

Line 2650: if PO_PDOI_CONSTANTS.g_GATHER_STATS = 'Y' THEN

2646: WHERE interface_attr_values_id = l_attr_values.intf_attr_values_id_tbl(i)
2647: AND l_attr_values.error_flag_tbl(i) = FND_API.g_FALSE;
2648:
2649: --Bug13343886
2650: if PO_PDOI_CONSTANTS.g_GATHER_STATS = 'Y' THEN
2651: d_position := 55;
2652: gather_stats('PO_ATTRIBUTE_VALUES_DRAFT',d_api_name,d_position);
2653: END IF;
2654: --Bug13343886

Line 2657: IF (l_attr_values.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN

2653: END IF;
2654: --Bug13343886
2655: PO_PDOI_UTL.commit_work;
2656:
2657: IF (l_attr_values.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
2658: EXIT;
2659: END IF;
2660:
2661: l_max_intf_attr_values_id := l_attr_values.intf_attr_values_id_tbl(l_attr_values.rec_count);

Line 2842: SET process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_ACCEPTED

2838:
2839: -- set status to ACCEPTED for all records
2840: FORALL i IN 1..l_attr_values_tlp.intf_attr_values_tlp_id_tbl.COUNT
2841: UPDATE po_attr_values_tlp_interface
2842: SET process_code = PO_PDOI_CONSTANTS.g_PROCESS_CODE_ACCEPTED
2843: WHERE interface_attr_values_tlp_id = l_attr_values_tlp.intf_attr_values_tlp_id_tbl(i)
2844: AND l_attr_values_tlp.error_flag_tbl(i) = FND_API.g_FALSE;
2845:
2846: --Bug13343886

Line 2847: if PO_PDOI_CONSTANTS.g_GATHER_STATS = 'Y' THEN

2843: WHERE interface_attr_values_tlp_id = l_attr_values_tlp.intf_attr_values_tlp_id_tbl(i)
2844: AND l_attr_values_tlp.error_flag_tbl(i) = FND_API.g_FALSE;
2845:
2846: --Bug13343886
2847: if PO_PDOI_CONSTANTS.g_GATHER_STATS = 'Y' THEN
2848: d_position := 45;
2849: gather_stats('PO_ATTRIBUTE_VALUES_TLP_DRAFT',d_api_name,d_position);
2850: END IF;
2851: --Bug13343886

Line 2855: IF (l_attr_values_tlp.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN

2851: --Bug13343886
2852:
2853: PO_PDOI_UTL.commit_work;
2854:
2855: IF (l_attr_values_tlp.rec_count < PO_PDOI_CONSTANTS.g_DEF_BATCH_SIZE) THEN
2856: EXIT;
2857: END IF;
2858:
2859: l_max_intf_attr_values_tlp_id := l_attr_values_tlp.intf_attr_values_tlp_id_tbl(l_attr_values_tlp.rec_count);

Line 2954: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND

2950: LOOP
2951: -- check whether num of error lines exceeds the error
2952: -- threshold for each batch
2953: IF (PO_PDOI_PARAMS.g_request.calling_module =
2954: PO_PDOI_CONSTANTS.g_CALL_MOD_CATALOG_UPLOAD AND
2955: PO_PDOI_PARAMS.g_docs_info(PO_PDOI_PARAMS.g_request.interface_header_id)
2956: .err_tolerance_exceeded = FND_API.g_TRUE) THEN
2957: IF (PO_LOG.d_stmt) THEN
2958: PO_LOG.stmt(d_module, d_position, 'error tolerance exceeded for',

Line 3095: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_ID,

3091: END IF;
3092: END LOOP;
3093: PO_PDOI_UTL.reject_lines_intf
3094: (
3095: p_id_param_type => PO_PDOI_CONSTANTS.g_INTERFACE_LINE_ID,
3096: p_id_tbl => l_rej_intf_line_id_tbl,
3097: p_cascade => FND_API.g_TRUE
3098: );
3099: l_rej_intf_line_id_tbl.DELETE;