[Home] [Help]
310: -- SQL Join: processing_id, process_code, po_header_id
311: CURSOR load_err_headers_csr(request_processing_id NUMBER) IS
312: SELECT intf_headers.interface_header_id,
313: intf_headers.po_header_id
314: FROM PO_HEADERS_INTERFACE intf_headers,
315: PO_HEADERS_ALL POH
316: WHERE intf_headers.processing_id = request_processing_id
317: AND intf_headers.process_code <> g_PROCESS_CODE_REJECTED
318: AND POH.po_header_id = intf_headers.po_header_id
401: PO_R12_CAT_UPG_UTL.add_fatal_error(
402: p_interface_header_id => l_interface_header_ids(i),
403: --p_error_message_name => 'PO_CAT_UPG_ALL_LINES_FAILED',
404: p_error_message_name => 'ICX_CAT_UPG_ALL_LINES_FAILED',
405: p_table_name => 'PO_HEADERS_INTERFACE',
406: p_column_name => 'PO_HEADER_ID',
407: p_column_value => l_err_po_header_ids(i)
408: );
409: END LOOP;
412: -- SQL What: Update process_code and processing_id in interface_table
413: -- SQL Why : To mark them as error rows
414: -- SQL Join: interface_header_id
415: FORALL i IN 1.. l_interface_header_ids.COUNT
416: UPDATE po_headers_interface headers
417: SET process_code = g_PROCESS_CODE_REJECTED,
418: processing_id = -processing_id,
419: po_header_id = NULL -- Bug 4865553: Null out the PO_HEADER_ID before calling IP's API
420: WHERE interface_header_id = l_interface_header_ids(i);
937: NULL, --headers.original_po_header_id, TODO: Not present in 11.5.9
938: headers.created_language,
939: headers.cpa_reference,
940: 'N' -- has_errors
941: FROM po_headers_interface headers
942: WHERE headers.processing_id = request_processing_id
943: AND headers.process_code = PO_R12_CAT_UPG_PVT.g_PROCESS_CODE_NEW
944: AND headers.action IN (PO_R12_CAT_UPG_PVT.g_action_header_create, 'UPDATE', 'DELETE');
945:
1386: -- "An error occurred in the call to API_NAME while copying attachments."
1387: PO_R12_CAT_UPG_UTL.add_fatal_error(
1388: p_interface_header_id => p_valid_intf_hdr_ids(i),
1389: p_error_message_name => 'ICX_CAT_ERR_IN_COPY_ATTCHMNTS',
1390: p_table_name => 'PO_HEADERS_INTERFACE',
1391: p_column_name => 'INTERFACE_HEADER_ID',
1392: p_column_value => x_doc_headers_rec.interface_header_id(j),
1393: p_token1_name => 'API_NAME',
1394: p_token1_value => 'FND_ATTACHED_DOCUMENTS2_PKG.copy_attachments'
1446: -- new GBPA.
1447: -- 1. It copies the attchments from the CPA Header to the new GBPA header.
1448: -- 2. It copies some of the extra attributes from the CPA Header to GBPA
1449: -- header. These are those attributes that are not present in the
1450: -- PO_HEADERS_INTERFACE table. So IP has not mechanism to provide
1451: -- these values during catalog migration. Therefore, we directly copy
1452: -- these values during a CPA-GBPA flow.
1453: --
1454: -- This API should be called during the upgrade phase only.
2379: -- successfull header creation
2380: -- SQL Why : To make it available to the calling program of the migration API.
2381: -- SQL Join: interface_header_id
2382: FORALL i IN 1 .. l_remaining_val_intf_hdr_ids.COUNT
2383: UPDATE PO_HEADERS_INTERFACE
2384: SET PO_HEADER_ID = l_remaining_val_po_hdr_ids(i),
2385: PROCESS_CODE = g_PROCESS_CODE_PROCESSED
2386: WHERE interface_header_id = l_remaining_val_intf_hdr_ids(i);
2387:
2467: -- for all the headers that were successfully updated.
2468: -- SQL Why : To mark them as successfully processed
2469: -- SQL Join: interface_header_id
2470: FORALL i IN 1.. p_doc_headers_rec.po_header_id.COUNT
2471: UPDATE po_headers_interface
2472: SET PROCESS_CODE = g_PROCESS_CODE_PROCESSED
2473: WHERE interface_header_id = p_doc_headers_rec.interface_header_id(i)
2474: AND p_doc_headers_rec.has_errors(i) = 'N'
2475: AND p_doc_headers_rec.action(i) = 'UPDATE';
2577:
2578: l_progress := '100';
2579: -- Mark headers interface as PROCESSED
2580: FORALL i IN 1.. p_doc_headers_rec.po_header_id.COUNT
2581: UPDATE po_headers_interface
2582: SET process_code = g_PROCESS_CODE_PROCESSED
2583: WHERE interface_header_id = p_doc_headers_rec.interface_header_id(i)
2584: AND p_doc_headers_rec.has_errors(i) = 'N'
2585: AND p_doc_headers_rec.action(i) = 'DELETE';
3286: char1)
3287: SELECT l_key,
3288: l_subscript_array(i),
3289: POHI.process_code
3290: FROM PO_HEADERS_INTERFACE POHI
3291: WHERE interface_header_id = p_doc_lines_rec.interface_header_id(i);
3292:
3293: IF g_debug THEN PO_R12_CAT_UPG_DEBUG.log_stmt(l_log_head,l_progress,'Number of rows insert into GT table='||SQL%rowcount); END IF;
3294:
7829:
7830: IF g_debug THEN PO_R12_CAT_UPG_DEBUG.log_stmt(l_log_head,l_progress,'Number of LinesInterface rows marked PROCESSED='||SQL%rowcount); END IF;
7831:
7832: FORALL i IN 1..p_rt_lines_rec.interface_attr_values_tlp_id.COUNT
7833: UPDATE PO_HEADERS_INTERFACE
7834: SET PROCESS_CODE = g_PROCESS_CODE_PROCESSED
7835: WHERE interface_header_id = p_rt_lines_rec.interface_header_id(i);
7836:
7837: IF g_debug THEN PO_R12_CAT_UPG_DEBUG.log_stmt(l_log_head,l_progress,'Number of HeadersInterface rows marked PROCESSED='||SQL%rowcount); END IF;
7890: -- SQL Why : It will be used to migrate data per org.
7891: -- SQL Join: batch_id
7892: SELECT distinct org_id
7893: BULK COLLECT INTO x_org_id_list
7894: FROM po_headers_interface
7895: WHERE batch_id = p_batch_id
7896: AND process_code = g_PROCESS_CODE_NEW;
7897:
7898: l_progress := '020';