2021: l_proc varchar2(80) := c_package||'qualify_hi_smr_data';
2022: --
2023: l_valid_delete varchar2(1) := 'N';
2024: --
2025: l_ass_info hr_jp_data_migration_pkg.t_ass_hi_smr_rec;
2026: --
2027: begin
2028: --
2029: if g_debug then
2030: hr_utility.set_location(l_proc,0);
2031: hr_utility.trace('p_assignment_id : '||to_char(p_assignment_id));
2032: end if;
2033: --
2034: hr_jp_data_migration_pkg.init_def_hi_smr_data;
2035: --
2036: if g_debug then
2037: hr_utility.set_location(l_proc,10);
2038: hr_utility.trace('hr_jp_data_migration_pkg.g_skip_qualify : '||hr_jp_data_migration_pkg.g_skip_qualify);
2034: hr_jp_data_migration_pkg.init_def_hi_smr_data;
2035: --
2036: if g_debug then
2037: hr_utility.set_location(l_proc,10);
2038: hr_utility.trace('hr_jp_data_migration_pkg.g_skip_qualify : '||hr_jp_data_migration_pkg.g_skip_qualify);
2039: hr_utility.trace('hr_jp_data_migration_pkg.g_upd_mode : '||hr_jp_data_migration_pkg.g_upd_mode);
2040: hr_utility.trace('hr_jp_data_migration_pkg.g_mig_date : '||to_char(hr_jp_data_migration_pkg.g_mig_date,'YYYY/MM/DD'));
2041: end if;
2042: --
2035: --
2036: if g_debug then
2037: hr_utility.set_location(l_proc,10);
2038: hr_utility.trace('hr_jp_data_migration_pkg.g_skip_qualify : '||hr_jp_data_migration_pkg.g_skip_qualify);
2039: hr_utility.trace('hr_jp_data_migration_pkg.g_upd_mode : '||hr_jp_data_migration_pkg.g_upd_mode);
2040: hr_utility.trace('hr_jp_data_migration_pkg.g_mig_date : '||to_char(hr_jp_data_migration_pkg.g_mig_date,'YYYY/MM/DD'));
2041: end if;
2042: --
2043: if hr_jp_data_migration_pkg.g_skip_qualify = 'N' then
2036: if g_debug then
2037: hr_utility.set_location(l_proc,10);
2038: hr_utility.trace('hr_jp_data_migration_pkg.g_skip_qualify : '||hr_jp_data_migration_pkg.g_skip_qualify);
2039: hr_utility.trace('hr_jp_data_migration_pkg.g_upd_mode : '||hr_jp_data_migration_pkg.g_upd_mode);
2040: hr_utility.trace('hr_jp_data_migration_pkg.g_mig_date : '||to_char(hr_jp_data_migration_pkg.g_mig_date,'YYYY/MM/DD'));
2041: end if;
2042: --
2043: if hr_jp_data_migration_pkg.g_skip_qualify = 'N' then
2044: --
2039: hr_utility.trace('hr_jp_data_migration_pkg.g_upd_mode : '||hr_jp_data_migration_pkg.g_upd_mode);
2040: hr_utility.trace('hr_jp_data_migration_pkg.g_mig_date : '||to_char(hr_jp_data_migration_pkg.g_mig_date,'YYYY/MM/DD'));
2041: end if;
2042: --
2043: if hr_jp_data_migration_pkg.g_skip_qualify = 'N' then
2044: --
2045: if g_debug then
2046: hr_utility.set_location(l_proc,20);
2047: end if;
2046: hr_utility.set_location(l_proc,20);
2047: end if;
2048: --
2049: -- print header for each threads but it is ok because just log.
2050: hr_jp_data_migration_pkg.qualify_hi_smr_hd(
2051: p_assignment_id => p_assignment_id);
2052: --
2053: if g_debug then
2054: hr_utility.set_location(l_proc,30);
2053: if g_debug then
2054: hr_utility.set_location(l_proc,30);
2055: end if;
2056: --
2057: l_ass_info := hr_jp_data_migration_pkg.get_ass_info(
2058: p_assignment_id => p_assignment_id,
2059: p_effective_date => hr_jp_data_migration_pkg.g_mig_date);
2060: --
2061: if g_debug then
2055: end if;
2056: --
2057: l_ass_info := hr_jp_data_migration_pkg.get_ass_info(
2058: p_assignment_id => p_assignment_id,
2059: p_effective_date => hr_jp_data_migration_pkg.g_mig_date);
2060: --
2061: if g_debug then
2062: hr_utility.set_location(l_proc,40);
2063: hr_utility.trace('l_ass_info.ass_id : '||to_char(l_ass_info.ass_id));
2062: hr_utility.set_location(l_proc,40);
2063: hr_utility.trace('l_ass_info.ass_id : '||to_char(l_ass_info.ass_id));
2064: end if;
2065: --
2066: hr_jp_data_migration_pkg.val_mig_smr_assact(
2067: p_business_group_id => l_ass_info.bg_id,
2068: p_business_group_name => l_ass_info.bg_name,
2069: p_assignment_id => p_assignment_id,
2070: p_assignment_number => l_ass_info.ass_num,
2067: p_business_group_id => l_ass_info.bg_id,
2068: p_business_group_name => l_ass_info.bg_name,
2069: p_assignment_id => p_assignment_id,
2070: p_assignment_number => l_ass_info.ass_num,
2071: p_session_date => hr_jp_data_migration_pkg.g_mig_date,
2072: p_valid_delete => l_valid_delete);
2073: --
2074: if g_debug then
2075: hr_utility.set_location(l_proc,50);
2111: is
2112: --
2113: l_proc varchar2(80) := c_package||'migrate_hi_smr_data';
2114: --
2115: l_ass_info hr_jp_data_migration_pkg.t_ass_hi_smr_rec;
2116: --
2117: begin
2118: --
2119: if g_debug then
2121: hr_utility.trace('p_assignment_id : '||to_char(p_assignment_id));
2122: end if;
2123: --
2124: -- need to reset for retry, qualify_obs_data is not called in retry process.
2125: hr_jp_data_migration_pkg.init_def_hi_smr_data;
2126: --
2127: if g_debug then
2128: hr_utility.set_location(l_proc,10);
2129: hr_utility.trace('hr_jp_data_migration_pkg.g_skip_qualify : '||hr_jp_data_migration_pkg.g_skip_qualify);
2125: hr_jp_data_migration_pkg.init_def_hi_smr_data;
2126: --
2127: if g_debug then
2128: hr_utility.set_location(l_proc,10);
2129: hr_utility.trace('hr_jp_data_migration_pkg.g_skip_qualify : '||hr_jp_data_migration_pkg.g_skip_qualify);
2130: hr_utility.trace('hr_jp_data_migration_pkg.g_upd_mode : '||hr_jp_data_migration_pkg.g_upd_mode);
2131: hr_utility.trace('hr_jp_data_migration_pkg.g_mig_date : '||to_char(hr_jp_data_migration_pkg.g_mig_date,'YYYY/MM/DD'));
2132: end if;
2133: --
2126: --
2127: if g_debug then
2128: hr_utility.set_location(l_proc,10);
2129: hr_utility.trace('hr_jp_data_migration_pkg.g_skip_qualify : '||hr_jp_data_migration_pkg.g_skip_qualify);
2130: hr_utility.trace('hr_jp_data_migration_pkg.g_upd_mode : '||hr_jp_data_migration_pkg.g_upd_mode);
2131: hr_utility.trace('hr_jp_data_migration_pkg.g_mig_date : '||to_char(hr_jp_data_migration_pkg.g_mig_date,'YYYY/MM/DD'));
2132: end if;
2133: --
2134: -- print header for each threads but it is ok because just log.
2127: if g_debug then
2128: hr_utility.set_location(l_proc,10);
2129: hr_utility.trace('hr_jp_data_migration_pkg.g_skip_qualify : '||hr_jp_data_migration_pkg.g_skip_qualify);
2130: hr_utility.trace('hr_jp_data_migration_pkg.g_upd_mode : '||hr_jp_data_migration_pkg.g_upd_mode);
2131: hr_utility.trace('hr_jp_data_migration_pkg.g_mig_date : '||to_char(hr_jp_data_migration_pkg.g_mig_date,'YYYY/MM/DD'));
2132: end if;
2133: --
2134: -- print header for each threads but it is ok because just log.
2135: hr_jp_data_migration_pkg.migrate_hi_smr_hd(
2131: hr_utility.trace('hr_jp_data_migration_pkg.g_mig_date : '||to_char(hr_jp_data_migration_pkg.g_mig_date,'YYYY/MM/DD'));
2132: end if;
2133: --
2134: -- print header for each threads but it is ok because just log.
2135: hr_jp_data_migration_pkg.migrate_hi_smr_hd(
2136: p_assignment_id => p_assignment_id);
2137: --
2138: if g_debug then
2139: hr_utility.set_location(l_proc,20);
2138: if g_debug then
2139: hr_utility.set_location(l_proc,20);
2140: end if;
2141: --
2142: l_ass_info := hr_jp_data_migration_pkg.get_ass_info(
2143: p_assignment_id => p_assignment_id,
2144: p_effective_date => hr_jp_data_migration_pkg.g_mig_date);
2145: --
2146: if g_debug then
2140: end if;
2141: --
2142: l_ass_info := hr_jp_data_migration_pkg.get_ass_info(
2143: p_assignment_id => p_assignment_id,
2144: p_effective_date => hr_jp_data_migration_pkg.g_mig_date);
2145: --
2146: if g_debug then
2147: hr_utility.set_location(l_proc,30);
2148: hr_utility.trace('l_ass_info.ass_id : '||to_char(l_ass_info.ass_id));
2148: hr_utility.trace('l_ass_info.ass_id : '||to_char(l_ass_info.ass_id));
2149: end if;
2150: --
2151: -- for api use
2152: hr_jp_data_migration_pkg.insert_session(
2153: p_effective_date => hr_jp_data_migration_pkg.g_mig_date);
2154: --
2155: hr_jp_data_migration_pkg.mig_smr_assact(
2156: p_business_group_id => l_ass_info.bg_id,
2149: end if;
2150: --
2151: -- for api use
2152: hr_jp_data_migration_pkg.insert_session(
2153: p_effective_date => hr_jp_data_migration_pkg.g_mig_date);
2154: --
2155: hr_jp_data_migration_pkg.mig_smr_assact(
2156: p_business_group_id => l_ass_info.bg_id,
2157: p_business_group_name => l_ass_info.bg_name,
2151: -- for api use
2152: hr_jp_data_migration_pkg.insert_session(
2153: p_effective_date => hr_jp_data_migration_pkg.g_mig_date);
2154: --
2155: hr_jp_data_migration_pkg.mig_smr_assact(
2156: p_business_group_id => l_ass_info.bg_id,
2157: p_business_group_name => l_ass_info.bg_name,
2158: p_assignment_id => p_assignment_id,
2159: p_assignment_number => l_ass_info.ass_num,
2156: p_business_group_id => l_ass_info.bg_id,
2157: p_business_group_name => l_ass_info.bg_name,
2158: p_assignment_id => p_assignment_id,
2159: p_assignment_number => l_ass_info.ass_num,
2160: p_session_date => hr_jp_data_migration_pkg.g_mig_date,
2161: p_hi_mr => null);
2162: --
2163: -- delete session is invalid, cause no data found.
2164: --hr_jp_data_migration_pkg.delete_session;
2160: p_session_date => hr_jp_data_migration_pkg.g_mig_date,
2161: p_hi_mr => null);
2162: --
2163: -- delete session is invalid, cause no data found.
2164: --hr_jp_data_migration_pkg.delete_session;
2165: --
2166: -- commit is invalid in archive loop for ORA-01002
2167: -- automatically commit will be executed for each assignment in archive process.
2168: -- commit;