[Home] [Help]
766: -- if accounted data already exists for secondary ledger, take min accounting date less one, else infinity
767: /*
768: SELECT nvl(min(accounting_date-1), to_date('31/12/9999', 'DD/MM/YYYY'))
769: INTO g_sec_alc_end_date
770: FROM xla_ae_headers
771: WHERE application_id = g_application_id
772: AND ledger_id = g_secondary_alc_ledger_id
773: AND accounting_entry_status_code = 'F';
774: */
774: */
775:
776: SELECT min(accounting_batch_id)-1
777: INTO g_sec_alc_min_acctng_batch_id
778: FROM xla_ae_headers
779: WHERE application_id = g_application_id
780: AND ledger_id = g_secondary_alc_ledger_id
781: AND accounting_entry_status_code = 'F';
782:
840:
841: SELECT 1
842: INTO g_untransferred_headers
843: FROM DUAL
844: WHERE EXISTS (SELECT /*+ parallel (xla_ae_headers) */ 1
845: FROM xla_ae_headers
846: WHERE ledger_id = g_primary_ledger_id
847: AND accounting_entry_status_code = 'F'
848: AND application_id = g_application_id
841: SELECT 1
842: INTO g_untransferred_headers
843: FROM DUAL
844: WHERE EXISTS (SELECT /*+ parallel (xla_ae_headers) */ 1
845: FROM xla_ae_headers
846: WHERE ledger_id = g_primary_ledger_id
847: AND accounting_entry_status_code = 'F'
848: AND application_id = g_application_id
849: AND balance_type_code in ('A', 'E')
1291:
1292: CURSOR c_entered_currencies
1293: IS
1294: SELECT /*+ parallel(xah) parallel(xal) leading(xah) */ distinct(XAL.currency_code)
1295: FROM xla_ae_headers XAH,
1296: xla_historic_control XHC,
1297: xla_ae_lines XAL
1298: WHERE XHC.primary_ledger = g_primary_ledger_id
1299: AND XHC.secondary_alc_ledger = g_secondary_alc_ledger_id
2037:
2038: END;
2039:
2040:
2041: l_table_name := 'XLA_AE_HEADERS';
2042:
2043:
2044: ad_parallel_updates_pkg.initialize_rowid_range(
2045: ad_parallel_updates_pkg.ROWID_RANGE,
2106:
2107: END IF;
2108:
2109:
2110: INSERT INTO XLA_AE_HEADERS
2111: (
2112: AE_HEADER_ID
2113: , APPLICATION_ID
2114: , LEDGER_ID
2180: , PARENT_AE_LINE_NUM
2181: , ACCRUAL_REVERSAL_FLAG
2182: , MERGE_EVENT_ID )
2183: SELECT /*+ rowid(xah) leading(xah) */
2184: XLA_AE_HEADERS_S.nextval
2185: , XAH.APPLICATION_ID
2186: , XHC.secondary_alc_ledger
2187: , XAH.ENTITY_ID
2188: , XAH.EVENT_ID
2254: , XAH.PARENT_AE_HEADER_ID
2255: , XAH.PARENT_AE_LINE_NUM
2256: , XAH.ACCRUAL_REVERSAL_FLAG
2257: , XAH.MERGE_EVENT_ID
2258: FROM xla_ae_headers XAH,
2259: xla_historic_control XHC
2260: WHERE XHC.primary_ledger = p_primary_ledger_id -- worker input
2261: AND XHC.secondary_alc_ledger = p_sec_alc_ledger_id -- worker input
2262: AND XHC.upgrade_id = p_ugprade_id -- worker input
2281:
2282: IF (C_LEVEL_PROCEDURE >= g_log_level) THEN
2283:
2284: trace
2285: (p_msg => 'Rows inserted into xla_ae_headers: ' || l_rows_processed || ' at ' || to_char(sysdate, 'DD-MON-YYYY HH:MI:SS')
2286: ,p_level => C_LEVEL_PROCEDURE
2287: ,p_module => l_log_module);
2288:
2289: END IF;
2294:
2295:
2296:
2297: INSERT INTO xla_historic_mapping_gt(primary_header_id, new_header_id)
2298: SELECT /*+ rowid(xah) leading(xah) index(xahnew xla_ae_headers_n2)*/
2299: XAH.ae_header_id, XAHNEW.ae_header_id
2300: FROM xla_ae_headers XAH,
2301: xla_historic_control XHC,
2302: xla_ae_headers XAHNEW
2296:
2297: INSERT INTO xla_historic_mapping_gt(primary_header_id, new_header_id)
2298: SELECT /*+ rowid(xah) leading(xah) index(xahnew xla_ae_headers_n2)*/
2299: XAH.ae_header_id, XAHNEW.ae_header_id
2300: FROM xla_ae_headers XAH,
2301: xla_historic_control XHC,
2302: xla_ae_headers XAHNEW
2303: WHERE XHC.primary_ledger = p_primary_ledger_id -- worker input
2304: AND XHC.secondary_alc_ledger = p_sec_alc_ledger_id -- worker input
2298: SELECT /*+ rowid(xah) leading(xah) index(xahnew xla_ae_headers_n2)*/
2299: XAH.ae_header_id, XAHNEW.ae_header_id
2300: FROM xla_ae_headers XAH,
2301: xla_historic_control XHC,
2302: xla_ae_headers XAHNEW
2303: WHERE XHC.primary_ledger = p_primary_ledger_id -- worker input
2304: AND XHC.secondary_alc_ledger = p_sec_alc_ledger_id -- worker input
2305: AND XHC.upgrade_id = p_ugprade_id -- worker input
2306: AND XHC.application_id = p_application_id -- worker input
2902:
2903:
2904: IF p_calendar_convert = 'Y' THEN
2905:
2906: UPDATE xla_ae_headers XAH
2907: SET period_name = (SELECT GLS.period_name
2908: FROM gl_period_statuses GLS
2909: WHERE GLS.ledger_id = p_sec_alc_ledger_id
2910: AND GLS.application_id = 101
2921:
2922: IF (C_LEVEL_PROCEDURE >= g_log_level) THEN
2923:
2924: trace
2925: (p_msg => 'Rows updated in xla_ae_headers with new period and null upgbatchid = ' || SQL%ROWCOUNT || ' at ' || to_char(sysdate, 'DD-MON-YYYY HH:MI:SS') -- to_char(sysdate, 'DD-MON-YYYY HH:MI:SS')
2926: ,p_level => C_LEVEL_PROCEDURE
2927: ,p_module => l_log_module);
2928:
2929: END IF;
2929: END IF;
2930:
2931:
2932: ELSE
2933: UPDATE xla_ae_headers XAH
2934: SET XAH.upg_batch_id = NULL
2935: WHERE XAH.application_id = p_application_id
2936: AND XAH.ledger_id = p_sec_alc_ledger_id
2937: AND XAH.upg_batch_id IS NOT NULL
2940: WHERE GT.new_header_id = XAH.ae_header_id);
2941:
2942: IF (C_LEVEL_PROCEDURE >= g_log_level) THEN
2943: trace
2944: (p_msg => 'Rows updated in xla_ae_headers with null upgbatchid: ' || SQL%ROWCOUNT || ' at ' || to_char(sysdate, 'DD-MON-YYYY HH:MI:SS')
2945: ,p_level => C_LEVEL_PROCEDURE
2946: ,p_module => l_log_module);
2947: END IF;
2948: