DBA Data[Home] [Help]

APPS.RCV_NORMALIZE_DATA_PKG dependencies on ASN_DEBUG

Line 67: asn_debug.put_line('count of running rtis'|| x_rti_count);

63: WHERE header_interface_id = p_rhi_row.header_interface_id
64: AND processing_status_code in ('PENDING','RUNNING')
65: AND transaction_status_code = 'PENDING';
66:
67: asn_debug.put_line('count of running rtis'|| x_rti_count);
68:
69: IF x_rti_count = 0 THEN -- error out orphan rhi
70: asn_debug.put_line('Erroring out orphan RHI: ' ||
71: p_rhi_row.header_interface_id);

Line 70: asn_debug.put_line('Erroring out orphan RHI: ' ||

66:
67: asn_debug.put_line('count of running rtis'|| x_rti_count);
68:
69: IF x_rti_count = 0 THEN -- error out orphan rhi
70: asn_debug.put_line('Erroring out orphan RHI: ' ||
71: p_rhi_row.header_interface_id);
72:
73: p_rhi_row.processing_status_code := 'ERROR';
74: p_rhi_row.processing_request_id := g_request_id;

Line 165: asn_debug.put_line('Processing row INTERFACE_TRANSACTION_ID = ' || p_rti_row.interface_transaction_id);

161: BEGIN
162: l_true := TRUE; -- BugFix 5078706
163:
164: BEGIN
165: asn_debug.put_line('Processing row INTERFACE_TRANSACTION_ID = ' || p_rti_row.interface_transaction_id);
166:
167: -- Following code is added for BugFix 5078706
168: BEGIN
169: select transaction_id,

Line 254: asn_debug.put_line('Setting current row to status LC_PENDING');

250: AND p_rti_row.auto_transact_code in ('RECEIVE','DELIVER')))
251: AND rcv_table_functions.is_lcm_shipment (p_rti_row.po_line_location_id) = 'Y'
252: AND p_rti_row.lcm_shipment_line_id is null) THEN
253: --
254: asn_debug.put_line('Setting current row to status LC_PENDING');
255: p_rti_row.processing_status_code := 'LC_PENDING';
256: --
257: -- Bug 8343811: Start
258: IF (x_rhi_row.receipt_num IS NULL) THEN

Line 266: asn_debug.put_line('Generated new receipt_num for rhi : ' || x_rhi_row.receipt_num, null,14);

262: x_rhi_row.processing_status_code := 'ERROR';
263: ELSE
264: x_rhi_row.processing_status_code := 'LC_PENDING';
265: x_rhi_row.receipt_num := x_header_record.header_record.receipt_num;
266: asn_debug.put_line('Generated new receipt_num for rhi : ' || x_rhi_row.receipt_num, null,14);
267: END IF;
268: rcv_table_functions.update_rhi_row(x_rhi_row);
269: END IF;
270: -- Bug 8343811: End

Line 291: asn_debug.put_line('LPN Group check : l_lpn_group_rti_count = ' ||l_lpn_group_rti_count, null,14);

287: where pll.line_location_id = rti.po_line_location_id
288: and lcm_flag = 'Y')
289: and (rti.lcm_shipment_line_id is null or rti.unit_landed_cost is null);
290: --
291: asn_debug.put_line('LPN Group check : l_lpn_group_rti_count = ' ||l_lpn_group_rti_count, null,14);
292: --
293: END IF;
294: --
295: IF (x_rhi_row.asn_type = 'ASN'

Line 313: asn_debug.put_line('ASN check : l_lpn_group_rti_count = ' ||l_lpn_group_rti_count, null,14);

309: where pll.line_location_id = rti.po_line_location_id
310: and lcm_flag = 'Y')
311: and (rti.lcm_shipment_line_id is null or rti.unit_landed_cost is null);
312: --
313: asn_debug.put_line('ASN check : l_lpn_group_rti_count = ' ||l_lpn_group_rti_count, null,14);
314: --
315: END IF;
316: IF (l_lpn_group_rti_count > 0) THEN
317: asn_debug.put_line('Setting current row to status WLC_PENDING');

Line 317: asn_debug.put_line('Setting current row to status WLC_PENDING');

313: asn_debug.put_line('ASN check : l_lpn_group_rti_count = ' ||l_lpn_group_rti_count, null,14);
314: --
315: END IF;
316: IF (l_lpn_group_rti_count > 0) THEN
317: asn_debug.put_line('Setting current row to status WLC_PENDING');
318: p_rti_row.processing_status_code := 'WLC_PENDING';
319: p_rti_row.processing_request_id := g_request_id;
320: IF (x_rhi_row.processing_status_code = 'ERROR') THEN
321: asn_debug.put_line('Setting header row status HEADER_INTERFACE_ID=' || x_rhi_row.header_interface_id);

Line 321: asn_debug.put_line('Setting header row status HEADER_INTERFACE_ID=' || x_rhi_row.header_interface_id);

317: asn_debug.put_line('Setting current row to status WLC_PENDING');
318: p_rti_row.processing_status_code := 'WLC_PENDING';
319: p_rti_row.processing_request_id := g_request_id;
320: IF (x_rhi_row.processing_status_code = 'ERROR') THEN
321: asn_debug.put_line('Setting header row status HEADER_INTERFACE_ID=' || x_rhi_row.header_interface_id);
322: x_rhi_row.processing_status_code := 'PENDING';
323: x_rhi_row.processing_request_id := g_request_id;
324: rcv_table_functions.update_rhi_row(x_rhi_row);
325: END IF;

Line 327: asn_debug.put_line('Setting current row to status RUNNING');

323: x_rhi_row.processing_request_id := g_request_id;
324: rcv_table_functions.update_rhi_row(x_rhi_row);
325: END IF;
326: ELSE
327: asn_debug.put_line('Setting current row to status RUNNING');
328: p_rti_row.processing_status_code := 'RUNNING';
329: p_rti_row.processing_request_id := g_request_id;
330: IF (x_rhi_row.processing_status_code IN ('PENDING', 'ERROR')) THEN
331: asn_debug.put_line('Setting header row status HEADER_INTERFACE_ID=' || x_rhi_row.header_interface_id);

Line 331: asn_debug.put_line('Setting header row status HEADER_INTERFACE_ID=' || x_rhi_row.header_interface_id);

327: asn_debug.put_line('Setting current row to status RUNNING');
328: p_rti_row.processing_status_code := 'RUNNING';
329: p_rti_row.processing_request_id := g_request_id;
330: IF (x_rhi_row.processing_status_code IN ('PENDING', 'ERROR')) THEN
331: asn_debug.put_line('Setting header row status HEADER_INTERFACE_ID=' || x_rhi_row.header_interface_id);
332: x_rhi_row.processing_status_code := 'RUNNING';
333: x_rhi_row.processing_request_id := g_request_id;
334: rcv_table_functions.update_rhi_row(x_rhi_row);
335: END IF;

Line 341: asn_debug.put_line('Setting current row to status RUNNING');

337: --
338: END IF;
339: --
340: ELSE
341: asn_debug.put_line('Setting current row to status RUNNING');
342: p_rti_row.processing_status_code := 'RUNNING';
343: p_rti_row.processing_request_id := g_request_id;
344:
345: IF (x_rhi_row.processing_status_code IN('PENDING', 'ERROR')) THEN

Line 346: asn_debug.put_line('Setting header row status HEADER_INTERFACE_ID=' || x_rhi_row.header_interface_id);

342: p_rti_row.processing_status_code := 'RUNNING';
343: p_rti_row.processing_request_id := g_request_id;
344:
345: IF (x_rhi_row.processing_status_code IN('PENDING', 'ERROR')) THEN
346: asn_debug.put_line('Setting header row status HEADER_INTERFACE_ID=' || x_rhi_row.header_interface_id);
347: x_rhi_row.processing_status_code := 'RUNNING';
348: x_rhi_row.processing_request_id := g_request_id;
349: rcv_table_functions.update_rhi_row(x_rhi_row);
350: END IF;

Line 364: asn_debug.put_line('in explode_all_lpn');

360: l_ret_status VARCHAR2(20);
361: l_msg_count NUMBER;
362: l_msg_data VARCHAR2(100);
363: BEGIN
364: asn_debug.put_line('in explode_all_lpn');
365:
366: -- Bug 14370850
367: IF (g_org_id = -1) THEN
368: UPDATE rcv_transactions_interface

Line 421: asn_debug.put_line('finished explode_all_lpn');

417: AND processing_request_id = g_request_id
418: AND org_id = g_org_id;
419: END IF;
420:
421: asn_debug.put_line('finished explode_all_lpn');
422: EXCEPTION
423: WHEN OTHERS THEN
424: asn_debug.put_line('encountered an error in explode_all_lpn');
425: END explode_all_lpn;

Line 424: asn_debug.put_line('encountered an error in explode_all_lpn');

420:
421: asn_debug.put_line('finished explode_all_lpn');
422: EXCEPTION
423: WHEN OTHERS THEN
424: asn_debug.put_line('encountered an error in explode_all_lpn');
425: END explode_all_lpn;
426:
427: PROCEDURE explode_lpn IS
428: l_ret_status VARCHAR2(20);

Line 432: asn_debug.put_line('in explode_lpn');

428: l_ret_status VARCHAR2(20);
429: l_msg_count NUMBER;
430: l_msg_data VARCHAR2(100);
431: BEGIN
432: asn_debug.put_line('in explode_lpn');
433:
434: -- Bug 14370850
435: IF (g_org_id = -1) THEN
436: UPDATE rcv_transactions_interface

Line 492: asn_debug.put_line('finished explode_lpn');

488: AND group_id = g_group_id
489: AND org_id = g_org_id;
490: END IF;
491:
492: asn_debug.put_line('finished explode_lpn');
493: EXCEPTION
494: WHEN OTHERS THEN
495: asn_debug.put_line('encountered an error in explode_lpn');
496: END explode_lpn;

Line 495: asn_debug.put_line('encountered an error in explode_lpn');

491:
492: asn_debug.put_line('finished explode_lpn');
493: EXCEPTION
494: WHEN OTHERS THEN
495: asn_debug.put_line('encountered an error in explode_lpn');
496: END explode_lpn;
497:
498: PROCEDURE process_pending_rows(
499: p_processing_mode IN VARCHAR2,

Line 718: asn_debug.put_line ('No access allowed. Returning');

714: g_org_id := p_org_id;
715:
716: IF (g_org_id <> -1) THEN
717: IF (NVL(mo_global.check_access(g_org_id),'N') = 'N') THEN
718: asn_debug.put_line ('No access allowed. Returning');
719: RETURN;
720: END IF;
721:
722: SELECT name

Line 734: asn_debug.put_line('Process Pending Rows: p_processing_mode=' || p_processing_mode || ' g_group_id=' || g_group_id || ' g_request_id=' || g_request_id || ' p_org_id=' || p_org_id);

730: FETCH c_get_group_id INTO g_group_id;
731: CLOSE c_get_group_id;
732: END IF;
733:
734: asn_debug.put_line('Process Pending Rows: p_processing_mode=' || p_processing_mode || ' g_group_id=' || g_group_id || ' g_request_id=' || g_request_id || ' p_org_id=' || p_org_id);
735:
736: /* we cannot use bulk collects because we are using the tablespace as working memory */
737: -- Bug 14370850 : Start
738: IF (p_org_id <> -1) THEN

Line 740: asn_debug.put_line('Processing multiple groups when p_org_id is passed...');

736: /* we cannot use bulk collects because we are using the tablespace as working memory */
737: -- Bug 14370850 : Start
738: IF (p_org_id <> -1) THEN
739: IF (g_multiple_groups = TRUE) THEN
740: asn_debug.put_line('Processing multiple groups when p_org_id is passed...');
741: explode_all_lpn;
742:
743: UPDATE rcv_headers_interface
744: SET org_id = p_org_id

Line 756: asn_debug.put_line('Derived org_id');

752: AND validation_flag = 'Y'
753: AND org_id IS NULL
754: AND operating_unit = g_ou_name;
755:
756: asn_debug.put_line('Derived org_id');
757:
758: FOR x_rhi_row IN c_get_all_pending_rhi_row2 LOOP
759: -- bug 16393104 start
760: SELECT *

Line 797: asn_debug.put_line('Orphan records are left untouched as locks could not be obtained.');

793: END LOOP;
794: -- Bug 13587955 New BEGIN
795: EXCEPTION
796: WHEN row_locked THEN
797: asn_debug.put_line('Orphan records are left untouched as locks could not be obtained.');
798: RETURN;
799: END;
800: -- Bug 13587955 New END
801: ELSE

Line 802: asn_debug.put_line('Processing single group when p_org_id is passed...');

798: RETURN;
799: END;
800: -- Bug 13587955 New END
801: ELSE
802: asn_debug.put_line('Processing single group when p_org_id is passed...');
803: explode_lpn;
804:
805: UPDATE rcv_headers_interface
806: SET org_id = p_org_id

Line 820: asn_debug.put_line('Derived org_id');

816: AND validation_flag = 'Y'
817: AND org_id IS NULL
818: AND operating_unit = g_ou_name;
819:
820: asn_debug.put_line('Derived org_id');
821:
822: FOR x_rhi_row IN c_get_pending_rhi_row2 LOOP
823: -- bug 16393104 start
824: SELECT *

Line 861: asn_debug.put_line('Orphan records are left untouched as locks could not be obtained.');

857: END LOOP;
858: -- Bug 13587955 New BEGIN
859: EXCEPTION
860: WHEN row_locked THEN
861: asn_debug.put_line('Orphan records are left untouched as locks could not be obtained.');
862: RETURN;
863: END;
864: -- Bug 13587955 New END
865:

Line 878: asn_debug.put_line('Check orphan RHI');

874: process_row(x_rti_row);
875: END LOOP;
876: END IF;
877:
878: asn_debug.put_line('Check orphan RHI');
879: IF (g_multiple_groups = TRUE) THEN
880: FOR x_rhi_row IN c_get_all_pending_rhi_row2 LOOP
881: check_orphan_rhi(x_rhi_row);
882: END LOOP;

Line 891: asn_debug.put_line('Processing multiple groups...');

887: END IF;
888:
889: ELSE
890: IF (g_multiple_groups = TRUE) THEN
891: asn_debug.put_line('Processing multiple groups...');
892: explode_all_lpn;
893:
894: FOR x_rhi_row IN c_get_all_pending_rhi_row LOOP
895: -- bug 16393104 start

Line 933: asn_debug.put_line('Orphan records are left untouched as locks could not be obtained.');

929: END LOOP;
930: -- Bug 13587955 New BEGIN
931: EXCEPTION
932: WHEN row_locked THEN
933: asn_debug.put_line('Orphan records are left untouched as locks could not be obtained.');
934: RETURN;
935: END;
936: -- Bug 13587955 New END
937:

Line 939: asn_debug.put_line('Processing single group...');

935: END;
936: -- Bug 13587955 New END
937:
938: ELSE
939: asn_debug.put_line('Processing single group...');
940: explode_lpn;
941:
942: FOR x_rhi_row IN c_get_pending_rhi_row LOOP
943: -- bug 16393104 start

Line 981: asn_debug.put_line('Orphan records are left untouched as locks could not be obtained.');

977: END LOOP;
978: -- Bug 13587955 New BEGIN
979: EXCEPTION
980: WHEN row_locked THEN
981: asn_debug.put_line('Orphan records are left untouched as locks could not be obtained.');
982: RETURN;
983: END;
984: -- Bug 13587955 New END
985:

Line 1000: asn_debug.put_line('Check orphan RHI');

996: END LOOP;
997: END IF;
998:
999: /* rhi could be without any pending rti at this point. */
1000: asn_debug.put_line('Check orphan RHI');
1001: IF (g_multiple_groups = TRUE) THEN
1002: FOR x_rhi_row IN c_get_all_pending_rhi_row LOOP
1003: check_orphan_rhi(x_rhi_row);
1004: END LOOP;

Line 1015: asn_debug.put_line('Calling RCV_LCM_WEB_SERVICE.Get_Landed_Cost');

1011: END IF;
1012: -- Bug 14370850 : End
1013:
1014: /* lcm changes */
1015: asn_debug.put_line('Calling RCV_LCM_WEB_SERVICE.Get_Landed_Cost');
1016: RCV_LCM_WEB_SERVICE.Get_Landed_Cost (p_group_id, p_processing_mode);
1017:
1018: -- Bug 13587955 New BEGIN
1019: EXCEPTION

Line 1021: asn_debug.put_line('ROI records to be processed are locked by another session. Failing current run.');

1017:
1018: -- Bug 13587955 New BEGIN
1019: EXCEPTION
1020: WHEN row_locked THEN
1021: asn_debug.put_line('ROI records to be processed are locked by another session. Failing current run.');
1022: raise_application_error(-20101, 'Records are found locked by another session.');
1023: -- Bug 13587955 New END
1024:
1025: END process_pending_rows;