DBA Data[Home] [Help]

APPS.HZ_IMP_LOAD_WRAPPER dependencies on HZ_IMP_WORK_UNITS

Line 1389: hz_imp_work_units

1385: and party_orig_system = P_ORIG_SYSTEM
1386: and interface_status = 'C'
1387: and exists (
1388: select 1 from
1389: hz_imp_work_units
1390: where party_orig_system_reference
1391: between from_orig_system_ref and to_orig_system_ref
1392: and batch_id = P_BATCH_ID
1393: and stage in (2, 3)

Line 1403: hz_imp_work_units

1399: and party_orig_system = P_ORIG_SYSTEM
1400: and interface_status = 'C'
1401: and exists (
1402: select 1 from
1403: hz_imp_work_units
1404: where party_orig_system_reference
1405: between from_orig_system_ref and to_orig_system_ref
1406: and batch_id = P_BATCH_ID
1407: and stage = 3

Line 1417: hz_imp_work_units

1413: and party_orig_system = P_ORIG_SYSTEM
1414: and interface_status = 'C'
1415: and exists (
1416: select 1 from
1417: hz_imp_work_units
1418: where party_orig_system_reference
1419: between from_orig_system_ref and to_orig_system_ref
1420: and batch_id = P_BATCH_ID
1421: and stage = 3

Line 1431: hz_imp_work_units

1427: and party_orig_system = P_ORIG_SYSTEM
1428: and interface_status = 'C'
1429: and exists (
1430: select 1 from
1431: hz_imp_work_units
1432: where party_orig_system_reference
1433: between from_orig_system_ref and to_orig_system_ref
1434: and batch_id = P_BATCH_ID
1435: and stage = 3

Line 1445: hz_imp_work_units

1441: and party_orig_system = P_ORIG_SYSTEM
1442: and interface_status = 'C'
1443: and exists (
1444: select 1 from
1445: hz_imp_work_units
1446: where party_orig_system_reference
1447: between from_orig_system_ref and to_orig_system_ref
1448: and batch_id = P_BATCH_ID
1449: and stage = 3

Line 1459: hz_imp_work_units

1455: and party_orig_system = P_ORIG_SYSTEM
1456: and interface_status = 'C'
1457: and exists (
1458: select 1 from
1459: hz_imp_work_units
1460: where party_orig_system_reference
1461: between from_orig_system_ref and to_orig_system_ref
1462: and batch_id = P_BATCH_ID
1463: and stage = 3

Line 1473: hz_imp_work_units

1469: and party_orig_system = P_ORIG_SYSTEM
1470: and interface_status = 'C'
1471: and exists (
1472: select 1 from
1473: hz_imp_work_units
1474: where party_orig_system_reference
1475: between from_orig_system_ref and to_orig_system_ref
1476: and batch_id = P_BATCH_ID
1477: and stage = 3

Line 1487: hz_imp_work_units

1483: and sub_orig_system = P_ORIG_SYSTEM
1484: and interface_status = 'C'
1485: and exists (
1486: select 1 from
1487: hz_imp_work_units
1488: where sub_orig_system_reference
1489: between from_orig_system_ref and to_orig_system_ref
1490: and batch_id = P_BATCH_ID
1491: and stage = 3

Line 1501: hz_imp_work_units

1497: and sub_orig_system = P_ORIG_SYSTEM
1498: and interface_status = 'C'
1499: and exists (
1500: select 1 from
1501: hz_imp_work_units
1502: where sub_orig_system_reference
1503: between from_orig_system_ref and to_orig_system_ref
1504: and batch_id = P_BATCH_ID
1505: and stage = 3

Line 1515: hz_imp_work_units

1511: and sub_orig_system = P_ORIG_SYSTEM
1512: and interface_status = 'C'
1513: and exists (
1514: select 1 from
1515: hz_imp_work_units
1516: where sub_orig_system_reference
1517: between from_orig_system_ref and to_orig_system_ref
1518: and batch_id = P_BATCH_ID
1519: and stage = 3

Line 1529: hz_imp_work_units

1525: and party_orig_system = P_ORIG_SYSTEM
1526: and interface_status = 'C'
1527: and exists (
1528: select 1 from
1529: hz_imp_work_units
1530: where party_orig_system_reference
1531: between from_orig_system_ref and to_orig_system_ref
1532: and batch_id = P_BATCH_ID
1533: and stage = 3

Line 3337: FROM hz_imp_work_units

3333: where batch_id = p_batch_id);
3334:
3335: CURSOR c_wu(p_batch_id number) IS
3336: SELECT 'Y'
3337: FROM hz_imp_work_units
3338: WHERE batch_id = p_batch_id
3339: AND rownum = 1;
3340: --l_debug_prefix VARCHAR2(30) := '';
3341: BEGIN

Line 3392: delete hz_imp_work_units

3388: /* Generate work units */
3389: IF l_rerun = 'N' OR l_rerun = 'E' THEN
3390:
3391: IF l_wu_exists = 'Y' THEN
3392: delete hz_imp_work_units
3393: where batch_id = P_BATCH_ID;
3394: END IF;
3395:
3396: GENERATE_ENTITIES_WORK_UNITS(P_BATCH_ID, P_ORIG_SYSTEM);

Line 3415: select 'Y' from hz_imp_work_units

3411: PROCEDURE RESET_PP_WU(
3412: P_BATCH_ID IN NUMBER
3413: ) IS
3414: CURSOR c_unfinished_pp(p_batch_id number) IS
3415: select 'Y' from hz_imp_work_units
3416: where batch_id = p_batch_id
3417: and (postprocess_status is null or postprocess_status <> 'C')
3418: and rownum = 1;
3419: l_unfinished_pp_exists VARCHAR2(1);

Line 3435: update hz_imp_work_units

3431: IF l_unfinished_pp_exists = 'N' THEN
3432: /* If all WUs were processed successfully in previous run,
3433: update postprocess_status to NULL so that PP will be
3434: done for the current request_id */
3435: update hz_imp_work_units
3436: set postprocess_status = NULL
3437: where batch_id = P_BATCH_ID;
3438: ELSE
3439: /* For WUs with NULL postprocess_status, they were not processed

Line 3448: update hz_imp_work_units

3444: For WUs with 'U' postprocess_status, they will be left as is
3445: because they were not processed in some previous runs and
3446: also had errors in the last run. PP will be done for the
3447: current request_id and all previous request_ids*/
3448: update hz_imp_work_units
3449: set postprocess_status = 'U'
3450: where batch_id = P_BATCH_ID
3451: and (postprocess_status is NULL or postprocess_status <> 'C');
3452:

Line 3456: update hz_imp_work_units

3452:
3453: /* For WUs with 'C' postprocess_status, they were processed
3454: successfully in previous run. Update postprocess_status to NULL
3455: so that PP will be done for the current request_id */
3456: update hz_imp_work_units
3457: set postprocess_status = NULL
3458: where batch_id = P_BATCH_ID
3459: and postprocess_status = 'C';
3460: END IF;

Line 3550: FROM HZ_IMP_WORK_UNITS

3546: l_chk_cnts_flag VARCHAR2(1);
3547:
3548: CURSOR c_check_counts IS
3549: SELECT 'Y'
3550: FROM HZ_IMP_WORK_UNITS
3551: WHERE batch_id=p_batch_id
3552: AND
3553: ((stage>=2
3554: AND status='C')

Line 3661: FROM hz_imp_work_units

3657: AND rownum = 1;
3658:
3659: CURSOR c_wu(p_batch_id number) IS
3660: SELECT 'Y'
3661: FROM hz_imp_work_units
3662: WHERE batch_id = p_batch_id
3663: AND rownum = 1;
3664:
3665: --l_debug_prefix VARCHAR2(30) := '';

Line 3961: UPDATE hz_imp_work_units

3957: /* Stage 1 preprocess before calling parties matching */
3958: IF P_RERUN_FLAG = 'U' OR P_RERUN_FLAG = 'L' THEN
3959:
3960: /* Clean up any processing work units */
3961: UPDATE hz_imp_work_units
3962: SET status = 'C', stage = stage - 1
3963: WHERE batch_id = P_BATCH_ID
3964: and status = 'P';
3965:

Line 3970: UPDATE hz_imp_work_units

3966: /* Keep track of the high water mark stage such that when we do V+DML,
3967: the appropriate records are picked up. Stage 2 workers check if stage <
3968: hwm stage, if so it will pick up the corrected records ("C" interface status).
3969: Else it will pick up the null interface status records. */
3970: UPDATE hz_imp_work_units
3971: SET hwm_stage = case when nvl(hwm_stage, 0) > stage
3972: then hwm_stage else stage end
3973: WHERE batch_id = P_BATCH_ID;
3974:

Line 3977: UPDATE hz_imp_work_units

3973: WHERE batch_id = P_BATCH_ID;
3974:
3975: /* Reset all stage to 0 to redo all matching because the staging tables are
3976: always cleaned up except for resume of what-if */
3977: UPDATE hz_imp_work_units
3978: SET stage = 0
3979: WHERE batch_id = P_BATCH_ID;
3980:
3981: /* If previous run is not successful, reset the postprocessing status

Line 4002: UPDATE hz_imp_work_units

3998: Else go to stage 1 to redo matching.
3999: */
4000: IF STAGING_DATA_EXISTS(P_BATCH_ID, P_BATCH_MODE_FLAG, 1) = 'Y' THEN
4001:
4002: UPDATE hz_imp_work_units
4003: SET stage = 1, status = 'C'
4004: WHERE batch_id = P_BATCH_ID;
4005:
4006: stage := 2; /* Skip stage 1 matching */

Line 4009: UPDATE hz_imp_work_units

4005:
4006: stage := 2; /* Skip stage 1 matching */
4007: ELSE
4008:
4009: UPDATE hz_imp_work_units
4010: SET stage = 0, status = 'C'
4011: WHERE batch_id = P_BATCH_ID;
4012:
4013: /* If this is batch mode, clean up staging tables to handle the case of:

Line 4133: /* delete hz_imp_work_units where batch_id = P_BATCH_ID;

4129: p_prefix =>'',
4130: p_msg_level=>fnd_log.level_statement);
4131: END IF;
4132: /* Delete Work Unit */
4133: /* delete hz_imp_work_units where batch_id = P_BATCH_ID;
4134:
4135: IF fnd_log.level_statement>=fnd_log.g_current_runtime_level THEN
4136: hz_utility_v2pub.debug(p_message=>'WRP:work united deleted',
4137: p_prefix =>'',

Line 4363: UPDATE HZ_IMP_WORK_UNITS

4359: P_HWM_STAGE OUT NOCOPY NUMBER,
4360: P_PP_STATUS OUT NOCOPY VARCHAR2
4361: ) IS
4362: BEGIN
4363: UPDATE HZ_IMP_WORK_UNITS
4364: SET STATUS = 'P',
4365: STAGE = P_STAGE
4366: WHERE STATUS = 'C'
4367: AND BATCH_ID = P_BATCH_ID

Line 4389: UPDATE HZ_IMP_WORK_UNITS

4385: P_FROM_OSR IN OUT NOCOPY VARCHAR2,
4386: P_TO_OSR IN OUT NOCOPY VARCHAR2
4387: ) IS
4388: BEGIN
4389: UPDATE HZ_IMP_WORK_UNITS
4390: SET POSTPROCESS_STATUS = 'P'
4391: WHERE STATUS = 'C'
4392: AND BATCH_ID = P_BATCH_ID
4393: AND STAGE IN (2, 3)

Line 4409: 'begin INSERT into hz_imp_work_units

4405: P_ORIG_SYSTEM IN VARCHAR2
4406: ) IS
4407:
4408: ENTITIES_WORK_UNIT_H_DML VARCHAR2(32767) :=
4409: 'begin INSERT into hz_imp_work_units
4410: ( batch_id,
4411: orig_system,
4412: from_orig_system_ref,
4413: to_orig_system_ref,

Line 4506: 'begin INSERT into hz_imp_work_units

4502: group by wu
4503: ); end;';
4504:
4505: ENTITIES_WORK_UNIT_L_DML VARCHAR2(32767) :=
4506: 'begin INSERT into hz_imp_work_units
4507: ( batch_id,
4508: orig_system,
4509: from_orig_system_ref,
4510: to_orig_system_ref,