35:
36: l_api_name CONSTANT VARCHAR2(30) := 'Load_Asset_Numbers';
37:
38: l_module varchar2(200);
39: l_log_level CONSTANT NUMBER := fnd_log.g_current_runtime_level;
40: l_uLog CONSTANT BOOLEAN := fnd_log.level_unexpected >= l_log_level;
41: l_pLog CONSTANT BOOLEAN := l_uLog AND fnd_log.level_procedure >= l_log_level;
42: l_sLog CONSTANT BOOLEAN := l_pLog AND fnd_log.level_statement >= l_log_level;
43:
36: l_api_name CONSTANT VARCHAR2(30) := 'Load_Asset_Numbers';
37:
38: l_module varchar2(200);
39: l_log_level CONSTANT NUMBER := fnd_log.g_current_runtime_level;
40: l_uLog CONSTANT BOOLEAN := fnd_log.level_unexpected >= l_log_level;
41: l_pLog CONSTANT BOOLEAN := l_uLog AND fnd_log.level_procedure >= l_log_level;
42: l_sLog CONSTANT BOOLEAN := l_pLog AND fnd_log.level_statement >= l_log_level;
43:
44:
37:
38: l_module varchar2(200);
39: l_log_level CONSTANT NUMBER := fnd_log.g_current_runtime_level;
40: l_uLog CONSTANT BOOLEAN := fnd_log.level_unexpected >= l_log_level;
41: l_pLog CONSTANT BOOLEAN := l_uLog AND fnd_log.level_procedure >= l_log_level;
42: l_sLog CONSTANT BOOLEAN := l_pLog AND fnd_log.level_statement >= l_log_level;
43:
44:
45: BEGIN
38: l_module varchar2(200);
39: l_log_level CONSTANT NUMBER := fnd_log.g_current_runtime_level;
40: l_uLog CONSTANT BOOLEAN := fnd_log.level_unexpected >= l_log_level;
41: l_pLog CONSTANT BOOLEAN := l_uLog AND fnd_log.level_procedure >= l_log_level;
42: l_sLog CONSTANT BOOLEAN := l_pLog AND fnd_log.level_statement >= l_log_level;
43:
44:
45: BEGIN
46: if(l_ulog) then
50:
51: if l_retcode = 1 then
52:
53: IF (l_slog) THEN
54: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Completed Successfully.');
55: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,Current_Error_Code);
56: END IF;
57:
58: RETCODE := 'Success';
51: if l_retcode = 1 then
52:
53: IF (l_slog) THEN
54: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Completed Successfully.');
55: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,Current_Error_Code);
56: END IF;
57:
58: RETCODE := 'Success';
59:
64: CONC_STATUS := FND_CONCURRENT.SET_COMPLETION_STATUS('NORMAL',Current_Error_Code);
65: elsif l_retcode = 3 then
66:
67: IF (l_slog) THEN
68: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Completed with Warning.');
69: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,Current_Error_Code);
70: END IF;
71:
72: RETCODE := 'Warning';
65: elsif l_retcode = 3 then
66:
67: IF (l_slog) THEN
68: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Completed with Warning.');
69: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,Current_Error_Code);
70: END IF;
71:
72: RETCODE := 'Warning';
73: CONC_STATUS := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',Current_Error_Code);
73: CONC_STATUS := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',Current_Error_Code);
74: else
75:
76: IF (l_slog) THEN
77: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Completed with Error.');
78: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,Current_Error_Code);
79: END IF;
80:
81: RETCODE := 'Error';
74: else
75:
76: IF (l_slog) THEN
77: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Completed with Error.');
78: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,Current_Error_Code);
79: END IF;
80:
81: RETCODE := 'Error';
82: CONC_STATUS := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',Current_Error_Code);
95: l_request_id NUMBER := 0;
96: l_api_name CONSTANT VARCHAR2(30) := 'Launch_Worker';
97:
98: l_module varchar2(200);
99: l_log_level CONSTANT NUMBER := fnd_log.g_current_runtime_level;
100: l_uLog CONSTANT BOOLEAN := fnd_log.level_unexpected >= l_log_level;
101: l_pLog CONSTANT BOOLEAN := l_uLog AND fnd_log.level_procedure >= l_log_level;
102: l_sLog CONSTANT BOOLEAN := l_pLog AND fnd_log.level_statement >= l_log_level;
103:
96: l_api_name CONSTANT VARCHAR2(30) := 'Launch_Worker';
97:
98: l_module varchar2(200);
99: l_log_level CONSTANT NUMBER := fnd_log.g_current_runtime_level;
100: l_uLog CONSTANT BOOLEAN := fnd_log.level_unexpected >= l_log_level;
101: l_pLog CONSTANT BOOLEAN := l_uLog AND fnd_log.level_procedure >= l_log_level;
102: l_sLog CONSTANT BOOLEAN := l_pLog AND fnd_log.level_statement >= l_log_level;
103:
104: BEGIN
97:
98: l_module varchar2(200);
99: l_log_level CONSTANT NUMBER := fnd_log.g_current_runtime_level;
100: l_uLog CONSTANT BOOLEAN := fnd_log.level_unexpected >= l_log_level;
101: l_pLog CONSTANT BOOLEAN := l_uLog AND fnd_log.level_procedure >= l_log_level;
102: l_sLog CONSTANT BOOLEAN := l_pLog AND fnd_log.level_statement >= l_log_level;
103:
104: BEGIN
105: if(l_ulog) then
98: l_module varchar2(200);
99: l_log_level CONSTANT NUMBER := fnd_log.g_current_runtime_level;
100: l_uLog CONSTANT BOOLEAN := fnd_log.level_unexpected >= l_log_level;
101: l_pLog CONSTANT BOOLEAN := l_uLog AND fnd_log.level_procedure >= l_log_level;
102: l_sLog CONSTANT BOOLEAN := l_pLog AND fnd_log.level_statement >= l_log_level;
103:
104: BEGIN
105: if(l_ulog) then
106: l_module := 'eam.plsql.'||g_pkg_name|| '.' || l_api_name;
106: l_module := 'eam.plsql.'||g_pkg_name|| '.' || l_api_name;
107: end if;
108:
109: IF (l_slog) THEN
110: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Submitting Import Worker '||p_group_id
111: || ' to process ' || p_count || ' assets');
112: END IF;
113:
114: --have to commit here so that worker process sees the changes
135: COMMIT;
136:
137:
138: IF (l_slog) THEN
139: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Failed to submit worker '||p_group_id);
140: END IF;
141:
142:
143: RAISE fnd_api.g_exc_error;
143: RAISE fnd_api.g_exc_error;
144: ELSE
145:
146: IF (l_slog) THEN
147: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Request id '|| l_request_id
148: || ' for Import Worker '||p_group_id||' successfully submitted');
149: END IF;
150:
151: END IF;
150:
151: END IF;
152:
153: IF (l_slog) THEN
154: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'');
155: END IF;
156:
157: END Launch_Worker;
158:
177:
178: l_api_name CONSTANT VARCHAR2(30) := 'Import_Asset_Numbers';
179:
180: l_module varchar2(200);
181: l_log_level CONSTANT NUMBER := fnd_log.g_current_runtime_level;
182: l_uLog CONSTANT BOOLEAN := fnd_log.level_unexpected >= l_log_level ;
183: l_exLog CONSTANT BOOLEAN := l_uLog AND fnd_log.level_exception >= l_log_level;
184: l_pLog CONSTANT BOOLEAN := l_uLog AND fnd_log.level_procedure >= l_log_level;
185: l_sLog CONSTANT BOOLEAN := l_pLog AND fnd_log.level_statement >= l_log_level;
178: l_api_name CONSTANT VARCHAR2(30) := 'Import_Asset_Numbers';
179:
180: l_module varchar2(200);
181: l_log_level CONSTANT NUMBER := fnd_log.g_current_runtime_level;
182: l_uLog CONSTANT BOOLEAN := fnd_log.level_unexpected >= l_log_level ;
183: l_exLog CONSTANT BOOLEAN := l_uLog AND fnd_log.level_exception >= l_log_level;
184: l_pLog CONSTANT BOOLEAN := l_uLog AND fnd_log.level_procedure >= l_log_level;
185: l_sLog CONSTANT BOOLEAN := l_pLog AND fnd_log.level_statement >= l_log_level;
186:
179:
180: l_module varchar2(200);
181: l_log_level CONSTANT NUMBER := fnd_log.g_current_runtime_level;
182: l_uLog CONSTANT BOOLEAN := fnd_log.level_unexpected >= l_log_level ;
183: l_exLog CONSTANT BOOLEAN := l_uLog AND fnd_log.level_exception >= l_log_level;
184: l_pLog CONSTANT BOOLEAN := l_uLog AND fnd_log.level_procedure >= l_log_level;
185: l_sLog CONSTANT BOOLEAN := l_pLog AND fnd_log.level_statement >= l_log_level;
186:
187: CURSOR asset_rows_cur IS
180: l_module varchar2(200);
181: l_log_level CONSTANT NUMBER := fnd_log.g_current_runtime_level;
182: l_uLog CONSTANT BOOLEAN := fnd_log.level_unexpected >= l_log_level ;
183: l_exLog CONSTANT BOOLEAN := l_uLog AND fnd_log.level_exception >= l_log_level;
184: l_pLog CONSTANT BOOLEAN := l_uLog AND fnd_log.level_procedure >= l_log_level;
185: l_sLog CONSTANT BOOLEAN := l_pLog AND fnd_log.level_statement >= l_log_level;
186:
187: CURSOR asset_rows_cur IS
188: SELECT meani.current_organization_id,
181: l_log_level CONSTANT NUMBER := fnd_log.g_current_runtime_level;
182: l_uLog CONSTANT BOOLEAN := fnd_log.level_unexpected >= l_log_level ;
183: l_exLog CONSTANT BOOLEAN := l_uLog AND fnd_log.level_exception >= l_log_level;
184: l_pLog CONSTANT BOOLEAN := l_uLog AND fnd_log.level_procedure >= l_log_level;
185: l_sLog CONSTANT BOOLEAN := l_pLog AND fnd_log.level_statement >= l_log_level;
186:
187: CURSOR asset_rows_cur IS
188: SELECT meani.current_organization_id,
189: meani.inventory_item_id,
240: l_module := 'eam.plsql.'||g_pkg_name|| '.' || l_api_name;
241: end if;
242:
243: IF (l_slog) THEN
244: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Batch Id = '||p_batch_id);
245: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Purge Option = '||p_purge_option);
246: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Max Rows to process = '||l_max_rows_to_process);
247: END IF;
248:
241: end if;
242:
243: IF (l_slog) THEN
244: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Batch Id = '||p_batch_id);
245: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Purge Option = '||p_purge_option);
246: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Max Rows to process = '||l_max_rows_to_process);
247: END IF;
248:
249:
242:
243: IF (l_slog) THEN
244: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Batch Id = '||p_batch_id);
245: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Purge Option = '||p_purge_option);
246: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Max Rows to process = '||l_max_rows_to_process);
247: END IF;
248:
249:
250:
254: -- 2: Attributes Only
255:
256:
257: IF (l_slog) THEN
258: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Validating Scope Values.');
259: END IF;
260:
261:
262: -- Use Cursor to pick out rows with invalid Scope to synchronize the conditions
300: -- 1: Update
301:
302:
303: IF (l_slog) THEN
304: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Validating Mode Values.');
305: END IF;
306:
307:
308: -- Use Cursor to pick out rows with invalid Mode to synchronize the conditions
345: -- Validate Organization Code:
346: -- If both organization_code and organization_id is provided, organization_id will be used.
347:
348: IF (l_slog) THEN
349: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Validating Organization Code.');
350: END IF;
351:
352:
353: UPDATE mtl_eam_asset_num_interface meani
408:
409: -- ===== Start Processing ======
410:
411: IF (l_slog) THEN
412: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Start record pre-processing. Time now is ' ||
413: to_char(sysdate, 'Month DD, YYYY HH24:MI:SS'));
414: END IF;
415:
416:
453: l_num_workers := l_num_workers + 1;
454: end if;
455:
456: IF (l_slog) THEN
457: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'Stop record pre-processing. Time now is ' ||
458: to_char(sysdate, 'Month DD, YYYY HH24:MI:SS'));
459: END IF;
460:
461: IF (l_slog) THEN
458: to_char(sysdate, 'Month DD, YYYY HH24:MI:SS'));
459: END IF;
460:
461: IF (l_slog) THEN
462: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module, l_num_workers ||' Import Workers are processing '
463: ||l_num_assets_to_workers || ' Assets');
464: END IF;
465:
466: if not (l_num_assets_to_workers = l_num_assets) then
465:
466: if not (l_num_assets_to_workers = l_num_assets) then
467:
468: IF (l_slog) THEN
469: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'WARNING: There is a discrepancy. Total Assets ('
470: || l_num_assets || ') does not match total given to workers ('
471: || l_num_assets_to_workers || ')');
472: END IF;
473:
473:
474: end if;
475:
476: IF (l_slog) THEN
477: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT, l_module,'');
478: END IF;
479:
480:
481: COMMIT;
503: CLOSE null_org_asset_cur;
504: END IF;
505:
506: IF (l_exlog) THEN
507: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION, l_module,error_number);
508: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION, l_module,error_message);
509: END IF;
510:
511: COMMIT;
504: END IF;
505:
506: IF (l_exlog) THEN
507: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION, l_module,error_number);
508: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION, l_module,error_message);
509: END IF;
510:
511: COMMIT;
512: Return l_success;
531: CLOSE null_org_asset_cur;
532: END IF;
533:
534: IF (l_exlog) THEN
535: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION, l_module,error_number);
536: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION, l_module,error_message);
537: END IF;
538:
539: COMMIT;
532: END IF;
533:
534: IF (l_exlog) THEN
535: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION, l_module,error_number);
536: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION, l_module,error_message);
537: END IF;
538:
539: COMMIT;
540: Return l_success;