DBA Data[Home] [Help]

APPS.JTF_IH_BULK dependencies on JTF_IH_BULK

Line 1: PACKAGE BODY JTF_IH_BULK AS

1: PACKAGE BODY JTF_IH_BULK AS
2: /* $Header: JTFIHBKB.pls 120.7 2006/06/13 14:56:27 rdday noship $*/
3:
4: -- profile option value that dictates stats data gathering and reporting
5: G_STATS_PROFILE_OPTION VARCHAR2(30);

Line 72: 'jtf.plsql.JTF_IH_BULK.SERVER_DATE_FROM_GMT_STR.begin', l_fnd_log_msg);

68: l_fnd_log_msg := 'FUNCTION SERVER_DATE_FROM_GMT_STR In Parameters'||
69: 'p_gmt_date_str = '|| p_gmt_date_str;
70: --dbms_output.put_line(l_fnd_log_msg);
71: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
72: 'jtf.plsql.JTF_IH_BULK.SERVER_DATE_FROM_GMT_STR.begin', l_fnd_log_msg);
73: END IF;
74:
75: IF (p_gmt_date_str IS NULL) THEN
76: RETURN NULL;

Line 103: 'jtf.plsql.JTF_IH_BULK.SERVER_DATE_FROM_GMT_STR.end', l_fnd_log_msg);

99: l_fnd_log_msg := 'FUNCTION SERVER_DATE_FROM_GMT_STR Return Parameter'||
100: 'l_server_date = '|| l_server_date;
101: --dbms_output.put_line(l_fnd_log_msg);
102: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
103: 'jtf.plsql.JTF_IH_BULK.SERVER_DATE_FROM_GMT_STR.end', l_fnd_log_msg);
104: END IF;
105:
106: RETURN l_server_date;
107:

Line 156: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC.begin', l_fnd_log_msg);

152: BEGIN
153: IF( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
154: l_fnd_log_msg := 'BULK_PROCESSOR_CONC Begin:';
155: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
156: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC.begin', l_fnd_log_msg);
157: END IF;
158:
159: -- global variables initialization to remove GSCC warnings
160: -- G_STATS_PROFILE_OPTION := 'JTF_IH_BULK_STATS_ENABLED';

Line 160: -- G_STATS_PROFILE_OPTION := 'JTF_IH_BULK_STATS_ENABLED';

156: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC.begin', l_fnd_log_msg);
157: END IF;
158:
159: -- global variables initialization to remove GSCC warnings
160: -- G_STATS_PROFILE_OPTION := 'JTF_IH_BULK_STATS_ENABLED';
161: G_INT_PROC_TIME_MAX := -1;
162: G_NUM_INT_MAX := -1;
163: G_NUM_ACT_MAX := -1;
164: G_NUM_MED_MAX := -1;

Line 195: --FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NO_TZ');

191: -- time values from gmt. default to GMT if server time zone is not set.
192: G_SERVER_TZ := FND_PROFILE.VALUE('SERVER_TIMEZONE_ID');
193: IF (G_SERVER_TZ IS NULL) THEN
194:
195: --FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NO_TZ');
196: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
197:
198:
199: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN

Line 200: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NO_TZ');

196: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
197:
198:
199: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
200: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NO_TZ');
201: FND_LOG.MESSAGE(FND_LOG.LEVEL_STATEMENT,
202: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', TRUE);
203: END IF;
204: G_SERVER_TZ := 0;

Line 202: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', TRUE);

198:
199: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
200: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NO_TZ');
201: FND_LOG.MESSAGE(FND_LOG.LEVEL_STATEMENT,
202: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', TRUE);
203: END IF;
204: G_SERVER_TZ := 0;
205:
206: END IF;

Line 243: INSERT INTO jtf_ih_bulk_recovery

239:
240: -- Perf fix for literal usuage
241: l_msg_id_perf := '0';
242:
243: INSERT INTO jtf_ih_bulk_recovery
244: ( recovery_id, request_id, msg_id, bulk_interaction_request,
245: num_int_processed, created_by, creation_date, last_updated_by,
246: last_update_date, last_update_login, program_id, program_application_id,
247: program_update_date)

Line 249: (jtf_ih_bulk_recovery_s1.nextval, G_CONC_REQUEST_ID, l_msg_id_perf,

245: num_int_processed, created_by, creation_date, last_updated_by,
246: last_update_date, last_update_login, program_id, program_application_id,
247: program_update_date)
248: VALUES
249: (jtf_ih_bulk_recovery_s1.nextval, G_CONC_REQUEST_ID, l_msg_id_perf,
250: EMPTY_CLOB(), null, G_USER_ID, sysdate, G_USER_ID, sysdate, G_LOGIN_ID,
251: G_CONC_REQUEST_ID, G_PROG_APPL_ID, sysdate);
252:
253: g_hrt_beat := -50;

Line 280: queue_name => 'JTF_IH_BULK_Q',

276: -- log any bulk requests that are fetched but not processed
277: l_msg_id := null;
278:
279: DBMS_AQ.DEQUEUE (
280: queue_name => 'JTF_IH_BULK_Q',
281: dequeue_options => deq_options,
282: message_properties => msg_props,
283: payload => bulk_obj,
284: msgid => l_msg_id);

Line 296: FROM jtf_ih_bulk_qtbl

292: -- before beginning to process the bulk record, save it in the recovery
293: -- table
294: g_hrt_beat := -51;
295: SELECT user_data INTO saved_bulk_obj
296: FROM jtf_ih_bulk_qtbl
297: WHERE msgid = l_msg_id;
298:
299: g_hrt_beat := -51.50;
300: UPDATE jtf_ih_bulk_recovery

Line 300: UPDATE jtf_ih_bulk_recovery

296: FROM jtf_ih_bulk_qtbl
297: WHERE msgid = l_msg_id;
298:
299: g_hrt_beat := -51.50;
300: UPDATE jtf_ih_bulk_recovery
301: SET
302: bulk_writer_code = saved_bulk_obj.bulkWriterCode,
303: bulk_batch_type = saved_bulk_obj.bulkBatchType,
304: bulk_batch_id = saved_bulk_obj.bulkBatchId,

Line 318: queue_name => 'JTF_IH_BULK_Q',

314: -- Now delete the row from AQ
315: deq_del_option.msgid := l_msg_id;
316:
317: DBMS_AQ.DEQUEUE (
318: queue_name => 'JTF_IH_BULK_Q',
319: dequeue_options => deq_del_option,
320: message_properties => msg_props,
321: payload => l_dummy_payload,
322: msgid => l_dummy_msg_id);

Line 346: queue_name => 'JTF_IH_BULK_Q',

342: -- Now delete row from AQ
343: deq_del_option.msgid := l_msg_id;
344:
345: DBMS_AQ.DEQUEUE (
346: queue_name => 'JTF_IH_BULK_Q',
347: dequeue_options => deq_del_option,
348: message_properties => msg_props,
349: payload => l_dummy_payload,
350: msgid => l_dummy_msg_id);

Line 358: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ZERO_LEN_REQ');

354:
355: g_hrt_beat := -53;
356:
357: -- logging High Level: Found a bulk request of zero length
358: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ZERO_LEN_REQ');
359: FND_MESSAGE.SET_TOKEN('WRITER_CODE', bulk_obj.bulkWriterCode);
360: FND_MESSAGE.SET_TOKEN('BATCH_TYPE', bulk_obj.bulkBatchType);
361: FND_MESSAGE.SET_TOKEN('BATCH_ID', bulk_obj.bulkBatchId);
362: FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);

Line 367: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ZERO_LEN_REQ');

363:
364:
365: -- logging Detail Level: Found a bulk request of zero length
366: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
367: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ZERO_LEN_REQ');
368: FND_MESSAGE.SET_TOKEN('WRITER_CODE', bulk_obj.bulkWriterCode);
369: FND_MESSAGE.SET_TOKEN('BATCH_TYPE', bulk_obj.bulkBatchType);
370: FND_MESSAGE.SET_TOKEN('BATCH_ID', bulk_obj.bulkBatchId);
371: FND_LOG.MESSAGE(FND_LOG.LEVEL_STATEMENT,

Line 372: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', TRUE);

368: FND_MESSAGE.SET_TOKEN('WRITER_CODE', bulk_obj.bulkWriterCode);
369: FND_MESSAGE.SET_TOKEN('BATCH_TYPE', bulk_obj.bulkBatchType);
370: FND_MESSAGE.SET_TOKEN('BATCH_ID', bulk_obj.bulkBatchId);
371: FND_LOG.MESSAGE(FND_LOG.LEVEL_STATEMENT,
372: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', TRUE);
373: END IF;
374:
375: END IF;
376:

Line 400: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', l_fnd_log_msg);

396: ', writer code = ' || bulk_obj.bulkWriterCode ||
397: ', batch type = ' || bulk_obj.bulkBatchType ||
398: ', batch id = ' || bulk_obj.bulkBatchId;
399: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,
400: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', l_fnd_log_msg);
401: END IF;
402:
403: num_rec := num_rec + 1;
404:

Line 413: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_AQ_EOF');

409: l_not_eof := FALSE;
410:
411: -- logging Detail Level: End of records in Advanced Queue
412: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
413: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_AQ_EOF');
414: FND_MESSAGE.SET_TOKEN('NUM_REC', num_rec);
415: FND_LOG.MESSAGE(FND_LOG.LEVEL_STATEMENT,
416: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', TRUE);
417: END IF;

Line 416: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', TRUE);

412: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
413: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_AQ_EOF');
414: FND_MESSAGE.SET_TOKEN('NUM_REC', num_rec);
415: FND_LOG.MESSAGE(FND_LOG.LEVEL_STATEMENT,
416: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', TRUE);
417: END IF;
418:
419: -- logging High Level: End of records in Advanced Queue
420: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_AQ_EOF');

Line 420: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_AQ_EOF');

416: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', TRUE);
417: END IF;
418:
419: -- logging High Level: End of records in Advanced Queue
420: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_AQ_EOF');
421: FND_MESSAGE.SET_TOKEN('NUM_REC', num_rec);
422: FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
423:
424: -- output this irrespective of stats flag so that there is some

Line 427: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_AQ_EOF');

423:
424: -- output this irrespective of stats flag so that there is some
425: -- indication of work done.
426:
427: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_AQ_EOF');
428: FND_MESSAGE.SET_TOKEN('NUM_REC', num_rec);
429: FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
430:
431: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NUM_REC_PROC');

Line 431: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NUM_REC_PROC');

427: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_AQ_EOF');
428: FND_MESSAGE.SET_TOKEN('NUM_REC', num_rec);
429: FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
430:
431: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NUM_REC_PROC');
432: FND_MESSAGE.SET_TOKEN('NUM_REC', num_rec);
433: FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
434:
435: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NUM_TOTAL_INT');

Line 435: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NUM_TOTAL_INT');

431: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NUM_REC_PROC');
432: FND_MESSAGE.SET_TOKEN('NUM_REC', num_rec);
433: FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
434:
435: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NUM_TOTAL_INT');
436: FND_MESSAGE.SET_TOKEN('NUM_INT', G_NUM_INT_TOTAL);
437: FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
438:
439: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NUM_OK_INT');

Line 439: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NUM_OK_INT');

435: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NUM_TOTAL_INT');
436: FND_MESSAGE.SET_TOKEN('NUM_INT', G_NUM_INT_TOTAL);
437: FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
438:
439: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NUM_OK_INT');
440: FND_MESSAGE.SET_TOKEN('NUM_INT', G_NUM_INT_PROC_TOTAL);
441: FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
442:
443: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NUM_ERR_INT');

Line 443: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NUM_ERR_INT');

439: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NUM_OK_INT');
440: FND_MESSAGE.SET_TOKEN('NUM_INT', G_NUM_INT_PROC_TOTAL);
441: FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
442:
443: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_NUM_ERR_INT');
444: FND_MESSAGE.SET_TOKEN('NUM_INT', (G_NUM_INT_TOTAL-G_NUM_INT_PROC_TOTAL));
445: FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
446:
447: WHEN OTHERS THEN

Line 454: DELETE FROM jtf_ih_bulk_recovery

450: END LOOP;
451:
452: -- We are done processing bulk records, now get rid of the record in the
453: -- recovery table
454: DELETE FROM jtf_ih_bulk_recovery
455: WHERE request_id = G_CONC_REQUEST_ID;
456:
457: -- crazy, but if more than one record is ever deleted here something bad is
458: -- going on - so log the error (and don't commit ?)

Line 463: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_RECOV_DEL_WARN');

459: IF (SQL%ROWCOUNT > 1) THEN
460:
461: -- High level logging:The number of records deleted from
462: -- the recovery table during cleanup is not 1 as expected
463: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_RECOV_DEL_WARN');
464: FND_MESSAGE.SET_TOKEN('ROW_COUNT', SQL%ROWCOUNT);
465: FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
466:
467: IF( FND_LOG.LEVEL_UNEXPECTED >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN

Line 468: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_RECOV_DEL_WARN');

464: FND_MESSAGE.SET_TOKEN('ROW_COUNT', SQL%ROWCOUNT);
465: FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
466:
467: IF( FND_LOG.LEVEL_UNEXPECTED >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
468: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_RECOV_DEL_WARN');
469: FND_MESSAGE.SET_TOKEN('ROW_COUNT', SQL%ROWCOUNT);
470: FND_LOG.MESSAGE(FND_LOG.LEVEL_UNEXPECTED,
471: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', TRUE);
472: END IF;

Line 471: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', TRUE);

467: IF( FND_LOG.LEVEL_UNEXPECTED >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
468: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_RECOV_DEL_WARN');
469: FND_MESSAGE.SET_TOKEN('ROW_COUNT', SQL%ROWCOUNT);
470: FND_LOG.MESSAGE(FND_LOG.LEVEL_UNEXPECTED,
471: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', TRUE);
472: END IF;
473:
474: ELSE
475: --FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Deleted row from recovery table.');

Line 495: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', l_fnd_log_msg);

491: ', Total successfull interactions - ' || G_NUM_INT_PROC_TOTAL ||
492: ', Total number of activities - ' || G_NUM_ACT_TOTAL ||
493: ', Total number of media items - ' || G_NUM_MED_TOTAL;
494: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,
495: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', l_fnd_log_msg);
496: END IF;
497:
498: --Logging Detail Level
499: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN

Line 514: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', l_fnd_log_msg);

510: ', Minimum number of activities per interactions - ' || G_NUM_ACT_MIN ||
511: ', Maximum number of media items per interactions - ' || G_NUM_MED_MAX ||
512: ', Minimum number of media items per interactions - ' || G_NUM_MED_MIN;
513: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,
514: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', l_fnd_log_msg);
515: END IF;
516:
517: IF (num_rec > 0) THEN
518: average := l_time_cum/num_rec;

Line 525: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', l_fnd_log_msg);

521: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
522: l_fnd_log_msg := 'Averages - ' ||
523: 'Average record processing time - ' || average;
524: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,
525: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', l_fnd_log_msg);
526: END IF;
527: END IF;
528:
529:

Line 536: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', l_fnd_log_msg);

532: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
533: l_fnd_log_msg := 'Average interaction processing time - ' ||
534: G_INT_PROC_TIME_CUM/G_NUM_INT_PROC_TOTAL;
535: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,
536: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', l_fnd_log_msg);
537: END IF;
538: END IF;
539:
540:

Line 546: errbuf := FND_MESSAGE.GET_STRING('JTF', 'JTF_IH_BULK_OK');

542: -- set return values accordingly
543: -- per documentation - The parameter retcode returns 0 for success,
544: -- 1 for success with warnings, and 2 for error.
545: retcode := '0';
546: errbuf := FND_MESSAGE.GET_STRING('JTF', 'JTF_IH_BULK_OK');
547:
548: FND_FILE.PUT_LINE(FND_FILE.LOG, errbuf);
549:
550: IF( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN

Line 556: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC.end', l_fnd_log_msg);

552: ', errbuf = '|| errbuf ||
553: ', retcode = '|| retcode;
554: --dbms_output.put_line(l_fnd_log_msg);
555: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
556: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC.end', l_fnd_log_msg);
557: END IF;
558:
559: EXCEPTION
560: WHEN OTHERS THEN

Line 568: errm := FND_MESSAGE.GET_STRING('JTF', 'JTF_IH_BULK_NOERRM');

564: BEGIN
565:
566: errm := SQLERRM;
567: IF (errm IS NULL) THEN
568: errm := FND_MESSAGE.GET_STRING('JTF', 'JTF_IH_BULK_NOERRM');
569: END IF;
570:
571: LOG_EXC_OTHERS('BULK_PROCESSOR_CONC');
572:

Line 582: FND_MESSAGE.set_name('JTF', 'JTF_IH_BULK_FAIL');

578: END IF;*/
579:
580: retcode := '2';
581:
582: FND_MESSAGE.set_name('JTF', 'JTF_IH_BULK_FAIL');
583:
584:
585: FND_MESSAGE.set_token('ERR_MSG', SQLERRM);
586: errbuf := FND_MSG_PUB.GET();

Line 592: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', l_fnd_log_msg);

588:
589: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
590: l_fnd_log_msg := errbuf;
591: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,
592: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', l_fnd_log_msg);
593: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,
594: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC',errbuf);
595: END IF;
596:

Line 594: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC',errbuf);

590: l_fnd_log_msg := errbuf;
591: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,
592: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC', l_fnd_log_msg);
593: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,
594: 'jtf.plsql.JTF_IH_BULK.BULK_PROCESSOR_CONC',errbuf);
595: END IF;
596:
597: END;
598:

Line 671: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD.begin', l_fnd_log_msg);

667: ', p_bulk_batch_id = '|| p_bulk_batch_id||
668: ', p_bulk_interaction_request = '|| p_bulk_interaction_request ||
669: ', p_int_offset = '|| p_int_offset;
670: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
671: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD.begin', l_fnd_log_msg);
672: END IF;
673:
674: -- local variables initialization to remove GSCC warnings
675: l_num_int_done := -1;

Line 706: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', 'Calling ParseClob');

702: BEGIN
703:
704: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
705: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,
706: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', 'Calling ParseClob');
707: END IF;
708: dbms_xmlparser.parseClob(xml_p, p_bulk_interaction_request);
709: EXCEPTION
710: WHEN OTHERS THEN

Line 721: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD',errm);

717: END IF;
718: FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Error Message: ' || errm );
719: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
720: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,
721: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD',errm);
722: END IF;
723: l_ret_status := FND_API.G_RET_STS_ERROR;
724: END;
725: END;

Line 861: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', l_fnd_log_msg);

857: --Logging Detail Level
858: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
859: l_fnd_log_msg := l_error_msgLOG;
860: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,
861: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', l_fnd_log_msg);
862: END IF;
863: RAISE processing_error;
864: END;
865:

Line 883: l_error := 'JTF_IH_BULK_MEDIA_FAIL';

879: PROCESS_MEDIA_ITEMS(med_nl, l_bulk_interaction_id, p_bulk_writer_code,
880: p_bulk_batch_type, p_bulk_batch_id, l_user_id, med_id_tbl,
881: l_ret_status, l_ret_msg);
882: IF (l_ret_status <> FND_API.G_RET_STS_SUCCESS) THEN
883: l_error := 'JTF_IH_BULK_MEDIA_FAIL';
884: --FND_FILE.PUT_LINE(FND_FILE.OUTPUT, l_error || ', ' || l_ret_msg);
885: l_error_msgLOG := l_ret_msg;
886: RAISE processing_error;
887: -- raise exception or otherwise handle this

Line 914: l_error := 'JTF_IH_BULK_ACT_FAIL';

910: p_bulk_batch_type, p_bulk_batch_id, med_id_tbl,
911: act_tbl, l_ret_status, l_ret_msg);
912:
913: IF (l_ret_status <> FND_API.G_RET_STS_SUCCESS) THEN
914: l_error := 'JTF_IH_BULK_ACT_FAIL';
915:
916: --Logging Detail Level
917: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
918: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ACT_FAIL');

Line 918: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ACT_FAIL');

914: l_error := 'JTF_IH_BULK_ACT_FAIL';
915:
916: --Logging Detail Level
917: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
918: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ACT_FAIL');
919: FND_LOG.MESSAGE(FND_LOG.LEVEL_STATEMENT,
920: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', TRUE);
921: END IF;
922:

Line 920: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', TRUE);

916: --Logging Detail Level
917: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
918: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ACT_FAIL');
919: FND_LOG.MESSAGE(FND_LOG.LEVEL_STATEMENT,
920: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', TRUE);
921: END IF;
922:
923: l_error_msgLOG := l_ret_msg;
924: RAISE processing_error;

Line 939: l_error := 'JTF_IH_BULK_ACT_FAIL';

935: p_bulk_batch_type, p_bulk_batch_id, int_rec,
936: l_ret_status, l_ret_msg);
937:
938: IF (l_ret_status <> FND_API.G_RET_STS_SUCCESS) THEN
939: l_error := 'JTF_IH_BULK_ACT_FAIL';
940: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_INT_FAIL');
941: l_ret_msg := FND_MESSAGE.GET ||' '|| l_ret_msg;
942: --FND_FILE.PUT_LINE(FND_FILE.LOG, l_ret_msg);
943: l_error_msgLOG := l_ret_msg;

Line 940: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_INT_FAIL');

936: l_ret_status, l_ret_msg);
937:
938: IF (l_ret_status <> FND_API.G_RET_STS_SUCCESS) THEN
939: l_error := 'JTF_IH_BULK_ACT_FAIL';
940: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_INT_FAIL');
941: l_ret_msg := FND_MESSAGE.GET ||' '|| l_ret_msg;
942: --FND_FILE.PUT_LINE(FND_FILE.LOG, l_ret_msg);
943: l_error_msgLOG := l_ret_msg;
944: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN

Line 947: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', l_fnd_log_msg);

943: l_error_msgLOG := l_ret_msg;
944: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
945: l_fnd_log_msg := l_ret_msg;
946: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,
947: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', l_fnd_log_msg);
948: END IF;
949: RAISE processing_error;
950: END IF;
951:

Line 974: l_error := 'JTF_IH_BULK_INT_FAIL';

970: p_activities => act_tbl);
971:
972: --FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Create_Interaction returned - ' || l_ret_status);
973: IF (l_ret_status <> FND_API.G_RET_STS_SUCCESS) THEN
974: l_error := 'JTF_IH_BULK_INT_FAIL';
975: --FND_FILE.PUT_LINE(FND_FILE.OUTPUT, l_error || ', msg_count = ' || l_msg_count);
976:
977: --Logging Detail Level
978: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN

Line 979: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_INT_FAIL2');

975: --FND_FILE.PUT_LINE(FND_FILE.OUTPUT, l_error || ', msg_count = ' || l_msg_count);
976:
977: --Logging Detail Level
978: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
979: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_INT_FAIL2');
980: FND_MESSAGE.SET_TOKEN('RTN_NAME', 'Create_Interaction');
981: FND_MESSAGE.SET_TOKEN('MSG_COUNT', l_msg_count);
982: FND_LOG.MESSAGE(FND_LOG.LEVEL_STATEMENT,
983: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', TRUE);

Line 983: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', TRUE);

979: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_INT_FAIL2');
980: FND_MESSAGE.SET_TOKEN('RTN_NAME', 'Create_Interaction');
981: FND_MESSAGE.SET_TOKEN('MSG_COUNT', l_msg_count);
982: FND_LOG.MESSAGE(FND_LOG.LEVEL_STATEMENT,
983: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', TRUE);
984: END IF;
985:
986: FOR i in 1..l_msg_count LOOP
987: l_msg_data := FND_MSG_PUB.Get(i, 'F');

Line 988: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ERROR_MSG');

984: END IF;
985:
986: FOR i in 1..l_msg_count LOOP
987: l_msg_data := FND_MSG_PUB.Get(i, 'F');
988: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ERROR_MSG');
989: FND_MESSAGE.SET_TOKEN('MSG_NUM', i);
990: FND_MESSAGE.SET_TOKEN('MSG_TXT', l_msg_data);
991: l_error_msgLOG := l_error_msgLOG ||' '|| FND_MESSAGE.GET;
992: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN

Line 995: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', l_error_msgLOG);

991: l_error_msgLOG := l_error_msgLOG ||' '|| FND_MESSAGE.GET;
992: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
993: l_fnd_log_msg := l_error_msgLOG;
994: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,
995: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', l_error_msgLOG);
996: END IF;
997:
998: --FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Message number - ' || i || ', is - ' || l_msg_data);
999: l_ret_msg := l_ret_msg ||

Line 1014: UPDATE jtf_ih_bulk_recovery

1010:
1011: l_commit_int_num := i;
1012:
1013: -- update the crash recovery table too
1014: UPDATE jtf_ih_bulk_recovery
1015: SET num_int_processed = l_commit_int_num,
1016: last_update_date = sysdate,
1017: program_update_date = sysdate
1018: WHERE request_id = G_CONC_REQUEST_ID;

Line 1075: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_INT_NODE_ERR');

1071: -- bulk request.
1072: WHEN processing_error THEN
1073:
1074: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
1075: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_INT_NODE_ERR');
1076: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
1077: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', TRUE);
1078: END IF;
1079:

Line 1077: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', TRUE);

1073:
1074: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
1075: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_INT_NODE_ERR');
1076: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
1077: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', TRUE);
1078: END IF;
1079:
1080:
1081: g_hrt_beat := 11.5;

Line 1125: UPDATE jtf_ih_bulk_recovery

1121:
1122: -- commit any outstanding work.
1123: -- update the crash recovery table too - here the num int processed is diff
1124: -- from above
1125: UPDATE jtf_ih_bulk_recovery
1126: SET num_int_processed = l_num_int_done,
1127: last_update_date = sysdate,
1128: program_update_date = sysdate
1129: WHERE request_id = G_CONC_REQUEST_ID;

Line 1154: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD.end', l_fnd_log_msg);

1150: l_fnd_log_msg := 'FUNCTION PROCESS_BULK_RECORD return variable :'||
1151: 'l_ret_status = '|| l_ret_status;
1152: --dbms_output.put_line(l_fnd_log_msg);
1153: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
1154: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD.end', l_fnd_log_msg);
1155: END IF;
1156:
1157:
1158: RETURN l_ret_status;

Line 1186: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_REQ_FAIL2');

1182:
1183:
1184: FND_FILE.PUT_LINE(FND_FILE.LOG, errm);
1185:
1186: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_REQ_FAIL2');
1187: FND_MESSAGE.SET_TOKEN('NUM_INT_DONE', l_num_int_done);
1188: FND_MESSAGE.SET_TOKEN('NUM_INT_COMMIT', l_commit_int_num);
1189:
1190: FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);

Line 1193: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_REQ_FAIL2');

1189:
1190: FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
1191:
1192: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
1193: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_REQ_FAIL2');
1194: FND_MESSAGE.SET_TOKEN('NUM_INT_DONE', l_num_int_done);
1195: FND_MESSAGE.SET_TOKEN('NUM_INT_COMMIT', l_commit_int_num);
1196: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
1197: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', TRUE);

Line 1197: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', TRUE);

1193: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_REQ_FAIL2');
1194: FND_MESSAGE.SET_TOKEN('NUM_INT_DONE', l_num_int_done);
1195: FND_MESSAGE.SET_TOKEN('NUM_INT_COMMIT', l_commit_int_num);
1196: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
1197: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', TRUE);
1198: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,
1199: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD',errm);
1200: END IF;
1201:

Line 1199: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD',errm);

1195: FND_MESSAGE.SET_TOKEN('NUM_INT_COMMIT', l_commit_int_num);
1196: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
1197: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD', TRUE);
1198: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,
1199: 'jtf.plsql.JTF_IH_BULK.PROCESS_BULK_RECORD',errm);
1200: END IF;
1201:
1202: -- rollback work in the current bulk record
1203: ROLLBACK TO SAVEPOINT BULK_RECORD;

Line 1211: FND_MESSAGE.GET_STRING('JTF','JTF_IH_BULK_REQ_FAIL'),

1207: p_bulk_batch_type,
1208: p_bulk_batch_id,
1209: l_bulk_interaction_id,
1210: p_bulk_interaction_request,
1211: FND_MESSAGE.GET_STRING('JTF','JTF_IH_BULK_REQ_FAIL'),
1212: errm);
1213: l_ret_status := FND_API.G_RET_STS_ERROR;
1214: END;
1215:

Line 1288: 'jtf.plsql.JTF_IH_BULK.PROCESS_MEDIA_ITEMS.begin', l_fnd_log_msg);

1284: ', x_ret_status = '|| x_ret_status ||
1285: ', x_ret_msg = '|| x_ret_msg;
1286: --dbms_output.put_line(l_fnd_log_msg);
1287: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
1288: 'jtf.plsql.JTF_IH_BULK.PROCESS_MEDIA_ITEMS.begin', l_fnd_log_msg);
1289: END IF;
1290: -- to do
1291: /*
1292: ii.for each media node

Line 1540: 'jtf.plsql.JTF_IH_BULK.PROCESS_MEDIA_ITEMS.end', l_fnd_log_msg);

1536: 'x_ret_status = '|| x_ret_status ||
1537: 'x_ret_msg = '|| x_ret_msg;
1538: --dbms_output.put_line(l_fnd_log_msg);
1539: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
1540: 'jtf.plsql.JTF_IH_BULK.PROCESS_MEDIA_ITEMS.end', l_fnd_log_msg);
1541: END IF;
1542:
1543: EXCEPTION
1544: -- this exception is raised if any of the JTF_IH_PUB's media calls fail.

Line 1548: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_MEDIA_FAIL2');

1544: -- this exception is raised if any of the JTF_IH_PUB's media calls fail.
1545: WHEN media_exception THEN
1546:
1547: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
1548: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_MEDIA_FAIL2');
1549: FND_MESSAGE.SET_TOKEN('RTN_NAME', l_rtn_name);
1550: FND_MESSAGE.SET_TOKEN('MSG_COUNT', l_msg_count);
1551: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
1552: 'jtf.plsql.JTF_IH_BULK.PROCESS_MEDIA_ITEMS.end', TRUE);

Line 1552: 'jtf.plsql.JTF_IH_BULK.PROCESS_MEDIA_ITEMS.end', TRUE);

1548: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_MEDIA_FAIL2');
1549: FND_MESSAGE.SET_TOKEN('RTN_NAME', l_rtn_name);
1550: FND_MESSAGE.SET_TOKEN('MSG_COUNT', l_msg_count);
1551: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
1552: 'jtf.plsql.JTF_IH_BULK.PROCESS_MEDIA_ITEMS.end', TRUE);
1553: END IF;
1554:
1555: x_ret_msg := '';
1556: FOR i in 1..l_msg_count LOOP

Line 1559: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ERROR_MSG');

1555: x_ret_msg := '';
1556: FOR i in 1..l_msg_count LOOP
1557: l_msg_data := FND_MSG_PUB.Get(i, 'F');
1558:
1559: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ERROR_MSG');
1560: FND_MESSAGE.SET_TOKEN('MSG_NUM', i);
1561: FND_MESSAGE.SET_TOKEN('MSG_TXT', l_msg_data);
1562: l_err_media := FND_MESSAGE.GET;
1563: --FND_FILE.PUT_LINE(FND_FILE.LOG, l_err_media);

Line 1570: 'jtf.plsql.JTF_IH_BULK.PROCESS_MEDIA_ITEMS.end', l_fnd_log_msg);

1566:
1567: IF( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
1568: l_fnd_log_msg := l_err_media;
1569: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
1570: 'jtf.plsql.JTF_IH_BULK.PROCESS_MEDIA_ITEMS.end', l_fnd_log_msg);
1571: END IF;
1572: --x_ret_msg := x_ret_msg || substrb(l_msg_data, 0, (2000-lengthb(x_ret_msg))) ||
1573: -- substrb(l_msg_data, 0, (2000-lengthb(', ')));
1574: END LOOP;

Line 1585: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_MEDIA_FAIL_UNEXP');

1581: error NUMBER := SQLCODE;
1582: errm varchar2(300) := SQLERRM;
1583: BEGIN
1584: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
1585: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_MEDIA_FAIL_UNEXP');
1586: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
1587: 'jtf.plsql.JTF_IH_BULK.PROCESS_MEDIA_ITEMS', TRUE);
1588: END IF;
1589:

Line 1587: 'jtf.plsql.JTF_IH_BULK.PROCESS_MEDIA_ITEMS', TRUE);

1583: BEGIN
1584: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
1585: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_MEDIA_FAIL_UNEXP');
1586: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
1587: 'jtf.plsql.JTF_IH_BULK.PROCESS_MEDIA_ITEMS', TRUE);
1588: END IF;
1589:
1590: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
1591: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN

Line 1592: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ERR_CODE_MSG');

1588: END IF;
1589:
1590: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
1591: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
1592: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ERR_CODE_MSG');
1593: FND_MESSAGE.SET_TOKEN('ERR_CODE', error);
1594: FND_MESSAGE.SET_TOKEN('ERR_MSG', errm);
1595: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
1596: 'jtf.plsql.JTF_IH_BULK.PROCESS_MEDIA_ITEMS', TRUE);

Line 1596: 'jtf.plsql.JTF_IH_BULK.PROCESS_MEDIA_ITEMS', TRUE);

1592: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ERR_CODE_MSG');
1593: FND_MESSAGE.SET_TOKEN('ERR_CODE', error);
1594: FND_MESSAGE.SET_TOKEN('ERR_MSG', errm);
1595: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
1596: 'jtf.plsql.JTF_IH_BULK.PROCESS_MEDIA_ITEMS', TRUE);
1597: END IF;
1598:
1599: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
1600:

Line 1662: 'jtf.plsql.JTF_IH_BULK.GATHER_ACT_TBL.begin', l_fnd_log_msg);

1658: ', x_ret_status = '|| x_ret_status ||
1659: ', x_ret_msg = '|| x_ret_msg;
1660: --dbms_output.put_line(l_fnd_log_msg);
1661: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
1662: 'jtf.plsql.JTF_IH_BULK.GATHER_ACT_TBL.begin', l_fnd_log_msg);
1663: END IF;
1664: -- to do
1665: /*
1666: iv.for each activity node

Line 1755: 'jtf.plsql.JTF_IH_BULK.GATHER_ACT_TBL.end', l_fnd_log_msg);

1751: ', x_ret_status = '|| x_ret_status ||
1752: ', x_ret_msg = '|| x_ret_msg;
1753: --dbms_output.put_line(l_fnd_log_msg);
1754: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
1755: 'jtf.plsql.JTF_IH_BULK.GATHER_ACT_TBL.end', l_fnd_log_msg);
1756: END IF;
1757:
1758: EXCEPTION
1759: WHEN OTHERS THEN

Line 1766: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ACT_FAIL_UNEXP');

1762: errm varchar2(300) := SQLERRM;
1763: BEGIN
1764:
1765: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
1766: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ACT_FAIL_UNEXP');
1767: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
1768: 'jtf.plsql.JTF_IH_BULK.GATHER_ACT_TBL', TRUE);
1769: END IF;
1770:

Line 1768: 'jtf.plsql.JTF_IH_BULK.GATHER_ACT_TBL', TRUE);

1764:
1765: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
1766: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ACT_FAIL_UNEXP');
1767: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
1768: 'jtf.plsql.JTF_IH_BULK.GATHER_ACT_TBL', TRUE);
1769: END IF;
1770:
1771: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
1772:

Line 1774: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ERR_CODE_MSG');

1770:
1771: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
1772:
1773: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
1774: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ERR_CODE_MSG');
1775: FND_MESSAGE.SET_TOKEN('ERR_CODE', error);
1776: FND_MESSAGE.SET_TOKEN('ERR_MSG', errm);
1777: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
1778: 'jtf.plsql.JTF_IH_BULK.GATHER_ACT_TBL', TRUE);

Line 1778: 'jtf.plsql.JTF_IH_BULK.GATHER_ACT_TBL', TRUE);

1774: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ERR_CODE_MSG');
1775: FND_MESSAGE.SET_TOKEN('ERR_CODE', error);
1776: FND_MESSAGE.SET_TOKEN('ERR_MSG', errm);
1777: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
1778: 'jtf.plsql.JTF_IH_BULK.GATHER_ACT_TBL', TRUE);
1779: END IF;
1780:
1781: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
1782:

Line 1831: 'jtf.plsql.JTF_IH_BULK.GATHER_INT_ATTR.begin', l_fnd_log_msg);

1827: ', x_ret_status = '|| x_ret_status ||
1828: ', x_ret_msg = '|| x_ret_msg;
1829: --dbms_output.put_line(l_fnd_log_msg);
1830: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
1831: 'jtf.plsql.JTF_IH_BULK.GATHER_INT_ATTR.begin', l_fnd_log_msg);
1832: END IF;
1833:
1834: date_str := dbms_xmldom.getAttribute(int_elem, 'start_date_time');
1835: -- RDD - Bug 5330922 - Removed the call to convert GMT input to server date - Input now in Server Date

Line 1903: 'jtf.plsql.JTF_IH_BULK.GATHER_INT_ATTR.end', l_fnd_log_msg);

1899: 'x_ret_status = '|| x_ret_status ||
1900: 'x_ret_msg = '|| x_ret_msg;
1901: --dbms_output.put_line(l_fnd_log_msg);
1902: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
1903: 'jtf.plsql.JTF_IH_BULK.GATHER_INT_ATTR.end', l_fnd_log_msg);
1904: END IF;
1905: END GATHER_INT_ATTR;
1906:
1907: --

Line 1956: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR.begin', l_fnd_log_msg);

1952: ', p_error_msg = '|| p_error_msg ||
1953: ', p_ret_msg = '|| p_ret_msg;
1954: --dbms_output.put_line(l_fnd_log_msg);
1955: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
1956: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR.begin', l_fnd_log_msg);
1957: END IF;
1958: SAVEPOINT BULK_ERROR;
1959:
1960: -- this is a sort of complicated logic here - basically, we don't want to

Line 1973: SELECT JTF_IH_BULK_ERRORS_S1.NEXTVAL INTO rec_id FROM sys.dual;

1969: FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'p_ret_msg = ' || p_ret_msg);
1970: FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'error_msg_2 = ' || error_msg_2);
1971: */
1972:
1973: SELECT JTF_IH_BULK_ERRORS_S1.NEXTVAL INTO rec_id FROM sys.dual;
1974:
1975: --FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'BULK_ERROR_ID = ' || rec_id);
1976:
1977: -- Bug3781768 Perf issue with literal usage

Line 1980: INSERT INTO JTF_IH_BULK_ERRORS

1976:
1977: -- Bug3781768 Perf issue with literal usage
1978: l_obj_version_perf := 0;
1979:
1980: INSERT INTO JTF_IH_BULK_ERRORS
1981: (bulk_error_id, object_version_number, creation_date, created_by,
1982: last_update_date, last_updated_by, last_update_login, program_id,
1983: request_id, program_application_id, program_update_date,
1984: bulk_writer_code, bulk_batch_id, bulk_batch_type, bulk_interaction_id,

Line 1994: FROM jtf_ih_bulk_errors

1990: p_bulk_writer_code, p_bulk_batch_id, p_bulk_batch_type,
1991: p_bulk_interaction_id, error_msg_2, EMPTY_CLOB());
1992:
1993: SELECT inter_req_xml_doc INTO bad_int_clob
1994: FROM jtf_ih_bulk_errors
1995: WHERE bulk_error_id = rec_id;
1996:
1997: bad_int_clob := 'AAAA';
1998:

Line 2001: UPDATE jtf_ih_bulk_errors

1997: bad_int_clob := 'AAAA';
1998:
1999: dbms_xmldom.writeToClob(p_int_node, bad_int_clob);
2000:
2001: UPDATE jtf_ih_bulk_errors
2002: SET inter_req_xml_doc = bad_int_clob
2003: WHERE bulk_error_id = rec_id;
2004:
2005: IF( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN

Line 2010: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR.end', l_fnd_log_msg);

2006: l_fnd_log_msg := 'FUNCTION LOG_BULK_ERROR return variable :'||
2007: 'FND_API.G_RET_STS_SUCCESS = '|| FND_API.G_RET_STS_SUCCESS;
2008: --dbms_output.put_line(l_fnd_log_msg);
2009: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
2010: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR.end', l_fnd_log_msg);
2011: END IF;
2012:
2013: RETURN FND_API.G_RET_STS_SUCCESS;
2014:

Line 2019: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_LOG1_FAIL');

2015: EXCEPTION
2016: WHEN OTHERS THEN
2017:
2018: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2019: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_LOG1_FAIL');
2020: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
2021: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR', TRUE);
2022: END IF;
2023:

Line 2021: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR', TRUE);

2017:
2018: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2019: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_LOG1_FAIL');
2020: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
2021: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR', TRUE);
2022: END IF;
2023:
2024: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
2025:

Line 2027: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ERR_CODE_MSG');

2023:
2024: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
2025:
2026: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2027: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ERR_CODE_MSG');
2028: FND_MESSAGE.SET_TOKEN('ERR_CODE', SQLCODE);
2029: FND_MESSAGE.SET_TOKEN('ERR_MSG', SQLERRM);
2030: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
2031: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR', TRUE);

Line 2031: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR', TRUE);

2027: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ERR_CODE_MSG');
2028: FND_MESSAGE.SET_TOKEN('ERR_CODE', SQLCODE);
2029: FND_MESSAGE.SET_TOKEN('ERR_MSG', SQLERRM);
2030: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
2031: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR', TRUE);
2032: END IF;
2033:
2034: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
2035: -- because we got an error saving in the bulk errors, save the xml piece in

Line 2089: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR.begin', l_fnd_log_msg);

2085: ', p_error_msg = '|| p_error_msg ||
2086: ', p_ret_msg = '|| p_ret_msg;
2087: --dbms_output.put_line(l_fnd_log_msg);
2088: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
2089: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR.begin', l_fnd_log_msg);
2090: END IF;
2091: SAVEPOINT BULK_ERROR;
2092:
2093: -- this is a sort of complicated logic here - basically, we don't want to

Line 2100: SELECT JTF_IH_BULK_ERRORS_S1.NEXTVAL INTO rec_id FROM sys.dual;

2096: error_msg_2 := SUBSTRB(p_error_msg, 0, 2000);
2097: error_msg_2 := error_msg_2 || SUBSTRB(' - ', 0, (2000 - LENGTHB(error_msg_2)));
2098: error_msg_2 := error_msg_2 || SUBSTRB(p_ret_msg, 0, (2000 - LENGTHB(error_msg_2)));
2099:
2100: SELECT JTF_IH_BULK_ERRORS_S1.NEXTVAL INTO rec_id FROM sys.dual;
2101:
2102: --FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'BULK_ERROR_ID = ' || rec_id);
2103:
2104: -- Bug3781768 Perf issue with literal usage

Line 2107: INSERT INTO JTF_IH_BULK_ERRORS

2103:
2104: -- Bug3781768 Perf issue with literal usage
2105: l_obj_version_perf := 0;
2106:
2107: INSERT INTO JTF_IH_BULK_ERRORS
2108: (bulk_error_id, object_version_number, creation_date, created_by,
2109: last_update_date, last_updated_by, last_update_login, program_id,
2110: request_id, program_application_id, program_update_date,
2111: bulk_writer_code, bulk_batch_id, bulk_batch_type, bulk_interaction_id,

Line 2125: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR.end', l_fnd_log_msg);

2121: l_fnd_log_msg := 'FUNCTION LOG_BULK_ERROR return variable :'||
2122: 'FND_API.G_RET_STS_SUCCESS = '|| FND_API.G_RET_STS_SUCCESS;
2123: --dbms_output.put_line(l_fnd_log_msg);
2124: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
2125: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR.end', l_fnd_log_msg);
2126: END IF;
2127:
2128: RETURN FND_API.G_RET_STS_SUCCESS;
2129:

Line 2134: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_LOG2_FAIL');

2130: EXCEPTION
2131: WHEN OTHERS THEN
2132:
2133: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2134: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_LOG2_FAIL');
2135: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
2136: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR', TRUE);
2137: END IF;
2138:

Line 2136: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR', TRUE);

2132:
2133: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2134: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_LOG2_FAIL');
2135: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
2136: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR', TRUE);
2137: END IF;
2138:
2139: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
2140:

Line 2142: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ERR_CODE_MSG');

2138:
2139: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
2140:
2141: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2142: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ERR_CODE_MSG');
2143: FND_MESSAGE.SET_TOKEN('ERR_CODE', SQLCODE);
2144: FND_MESSAGE.SET_TOKEN('ERR_MSG', SQLERRM);
2145: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
2146: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR', TRUE);

Line 2146: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR', TRUE);

2142: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_ERR_CODE_MSG');
2143: FND_MESSAGE.SET_TOKEN('ERR_CODE', SQLCODE);
2144: FND_MESSAGE.SET_TOKEN('ERR_MSG', SQLERRM);
2145: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
2146: 'jtf.plsql.JTF_IH_BULK.LOG_BULK_ERROR', TRUE);
2147: END IF;
2148:
2149: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
2150:

Line 2163: l_rec_recd IN OUT NOCOPY JTF_IH_BULK_RECOVERY%ROWTYPE

2159: END LOG_BULK_ERROR;
2160:
2161: FUNCTION FIND_ONE_CRASH_RECD
2162: (
2163: l_rec_recd IN OUT NOCOPY JTF_IH_BULK_RECOVERY%ROWTYPE
2164: ) RETURN BOOLEAN IS
2165:
2166: TYPE BulkRecoveryCurTyp IS REF CURSOR RETURN JTF_IH_BULK_RECOVERY%ROWTYPE;
2167: l_rec_cv BulkRecoveryCurTyp;

Line 2166: TYPE BulkRecoveryCurTyp IS REF CURSOR RETURN JTF_IH_BULK_RECOVERY%ROWTYPE;

2162: (
2163: l_rec_recd IN OUT NOCOPY JTF_IH_BULK_RECOVERY%ROWTYPE
2164: ) RETURN BOOLEAN IS
2165:
2166: TYPE BulkRecoveryCurTyp IS REF CURSOR RETURN JTF_IH_BULK_RECOVERY%ROWTYPE;
2167: l_rec_cv BulkRecoveryCurTyp;
2168: l_call_status BOOLEAN;
2169: l_found_recd BOOLEAN;
2170: l_phase VARCHAR2(80);

Line 2179: 'l_rec_recd TYPE JTF_IH_BULK_RECOVERY%ROWTYPE';

2175:
2176: BEGIN
2177: IF( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2178: l_fnd_log_msg := 'FUNCTION FIND_ONE_CRASH_RECD In parameters :'||
2179: 'l_rec_recd TYPE JTF_IH_BULK_RECOVERY%ROWTYPE';
2180: --dbms_output.put_line(l_fnd_log_msg);
2181: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
2182: 'jtf.plsql.JTF_IH_BULK.FIND_ONE_CRASH_RECD.begin', l_fnd_log_msg);
2183: END IF;

Line 2182: 'jtf.plsql.JTF_IH_BULK.FIND_ONE_CRASH_RECD.begin', l_fnd_log_msg);

2178: l_fnd_log_msg := 'FUNCTION FIND_ONE_CRASH_RECD In parameters :'||
2179: 'l_rec_recd TYPE JTF_IH_BULK_RECOVERY%ROWTYPE';
2180: --dbms_output.put_line(l_fnd_log_msg);
2181: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
2182: 'jtf.plsql.JTF_IH_BULK.FIND_ONE_CRASH_RECD.begin', l_fnd_log_msg);
2183: END IF;
2184:
2185: g_hrt_beat := -70;
2186: --FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Entered find_one_crash_Recd');

Line 2188: OPEN l_rec_cv FOR SELECT * FROM JTF_IH_BULK_RECOVERY;

2184:
2185: g_hrt_beat := -70;
2186: --FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Entered find_one_crash_Recd');
2187:
2188: OPEN l_rec_cv FOR SELECT * FROM JTF_IH_BULK_RECOVERY;
2189:
2190: -- look for a crash victim in the RECORD_ID for each row in this table
2191:
2192: l_found_recd := FALSE;

Line 2233: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_CRASH_FND');

2229: IF (l_dev_phase = 'COMPLETE') THEN
2230: g_hrt_beat := -71;
2231:
2232: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2233: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_CRASH_FND');
2234: FND_MESSAGE.SET_TOKEN('REQ_ID', l_rec_recd.request_id);
2235: FND_MESSAGE.SET_TOKEN('WRITER_CODE', l_rec_recd.bulk_writer_code);
2236: FND_MESSAGE.SET_TOKEN('BATCH_TYPE', l_rec_recd.bulk_batch_type);
2237: FND_MESSAGE.SET_TOKEN('BATCH_ID', l_rec_recd.bulk_batch_id);

Line 2239: 'jtf.plsql.JTF_IH_BULK.FIND_ONE_CRASH_RECD', TRUE);

2235: FND_MESSAGE.SET_TOKEN('WRITER_CODE', l_rec_recd.bulk_writer_code);
2236: FND_MESSAGE.SET_TOKEN('BATCH_TYPE', l_rec_recd.bulk_batch_type);
2237: FND_MESSAGE.SET_TOKEN('BATCH_ID', l_rec_recd.bulk_batch_id);
2238: FND_LOG.MESSAGE(FND_LOG.LEVEL_STATEMENT,
2239: 'jtf.plsql.JTF_IH_BULK.FIND_ONE_CRASH_RECD', TRUE);
2240: END IF;
2241: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
2242:
2243: l_found_recd := TRUE;

Line 2256: UPDATE JTF_IH_BULK_RECOVERY

2252:
2253: IF (l_found_recd = TRUE) THEN
2254:
2255: -- 'grab' the record by changing the request_id to our own
2256: UPDATE JTF_IH_BULK_RECOVERY
2257: SET request_id = G_CONC_REQUEST_ID,
2258: program_id = G_CONC_REQUEST_ID,
2259: program_application_id = G_PROG_APPL_ID,
2260: last_update_date = sysdate,

Line 2276: 'jtf.plsql.JTF_IH_BULK.FIND_ONE_CRASH_RECD.end', l_fnd_log_msg);

2272: l_fnd_log_msg := 'FUNCTION FIND_ONE_CRASH_RECD Return parameters :'||
2273: 'return boolean = TRUE';
2274: --dbms_output.put_line(l_fnd_log_msg);
2275: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
2276: 'jtf.plsql.JTF_IH_BULK.FIND_ONE_CRASH_RECD.end', l_fnd_log_msg);
2277: END IF;
2278:
2279: RETURN TRUE;
2280: ELSE

Line 2289: 'jtf.plsql.JTF_IH_BULK.FIND_ONE_CRASH_RECD.end', l_fnd_log_msg);

2285: l_fnd_log_msg := 'FUNCTION FIND_ONE_CRASH_RECD Return parameters :'||
2286: 'return boolean = FALSE';
2287: --dbms_output.put_line(l_fnd_log_msg);
2288: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
2289: 'jtf.plsql.JTF_IH_BULK.FIND_ONE_CRASH_RECD.end', l_fnd_log_msg);
2290: END IF;
2291:
2292: RETURN FALSE;
2293: END IF;

Line 2298: PROCEDURE CLEAR_ONE_CRASH_RECD( l_rec_recd IN JTF_IH_BULK_RECOVERY%ROWTYPE) IS

2294:
2295: END FIND_ONE_CRASH_RECD;
2296:
2297:
2298: PROCEDURE CLEAR_ONE_CRASH_RECD( l_rec_recd IN JTF_IH_BULK_RECOVERY%ROWTYPE) IS
2299:
2300: l_ret_status VARCHAR2(5);
2301: BEGIN
2302:

Line 2308: 'jtf.plsql.JTF_IH_BULK.CLEAR_ONE_CRASH_RECD.begin', l_fnd_log_msg);

2304: l_fnd_log_msg := 'CLEAR_ONE_CRASH_RECD In parameters :'||
2305: 'l_rec_recd';
2306: --dbms_output.put_line(l_fnd_log_msg);
2307: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
2308: 'jtf.plsql.JTF_IH_BULK.CLEAR_ONE_CRASH_RECD.begin', l_fnd_log_msg);
2309: END IF;
2310:
2311: g_hrt_beat := -60;
2312: --FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Enter CLEAR_ONE_CRASH_RECD');

Line 2333: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_RECOV_FAIL');

2329:
2330: IF (l_ret_status <> FND_API.G_RET_STS_SUCCESS) THEN
2331: g_hrt_beat := -61;
2332: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2333: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_RECOV_FAIL');
2334: FND_MESSAGE.SET_TOKEN('MSG_ID', l_rec_recd.msg_id);
2335: FND_LOG.MESSAGE(FND_LOG.LEVEL_STATEMENT,
2336: 'jtf.plsql.JTF_IH_BULK.CLEAR_ONE_CRASH_RECD', TRUE);
2337: END IF;

Line 2336: 'jtf.plsql.JTF_IH_BULK.CLEAR_ONE_CRASH_RECD', TRUE);

2332: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2333: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_RECOV_FAIL');
2334: FND_MESSAGE.SET_TOKEN('MSG_ID', l_rec_recd.msg_id);
2335: FND_LOG.MESSAGE(FND_LOG.LEVEL_STATEMENT,
2336: 'jtf.plsql.JTF_IH_BULK.CLEAR_ONE_CRASH_RECD', TRUE);
2337: END IF;
2338: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
2339: END IF;
2340:

Line 2342: DELETE FROM jtf_ih_bulk_recovery

2338: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
2339: END IF;
2340:
2341: -- now that the crash victim has been taken care of, get rid of it
2342: DELETE FROM jtf_ih_bulk_recovery
2343: WHERE request_id = G_CONC_REQUEST_ID;
2344:
2345: COMMIT;
2346:

Line 2353: 'jtf.plsql.JTF_IH_BULK.CLEAR_ONE_CRASH_RECD.end', l_fnd_log_msg);

2349: IF( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2350: l_fnd_log_msg := 'CLEAR_ONE_CRASH_RECD no Out Parameters';
2351: --dbms_output.put_line(l_fnd_log_msg);
2352: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
2353: 'jtf.plsql.JTF_IH_BULK.CLEAR_ONE_CRASH_RECD.end', l_fnd_log_msg);
2354: END IF;
2355:
2356: END CLEAR_ONE_CRASH_RECD;
2357:

Line 2366: l_rec_recd JTF_IH_BULK_RECOVERY%ROWTYPE;

2362: -- Parameters - none
2363: --
2364: PROCEDURE PERFORM_CRASH_RECOVERY is
2365:
2366: l_rec_recd JTF_IH_BULK_RECOVERY%ROWTYPE;
2367:
2368: BEGIN
2369:
2370: IF( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN

Line 2374: 'jtf.plsql.JTF_IH_BULK.PERFORM_CRASH_RECOVERY.begin', l_fnd_log_msg);

2370: IF( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2371: l_fnd_log_msg := 'PERFORM_CRASH_RECOVERY No In parameters';
2372: --dbms_output.put_line(l_fnd_log_msg);
2373: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
2374: 'jtf.plsql.JTF_IH_BULK.PERFORM_CRASH_RECOVERY.begin', l_fnd_log_msg);
2375: END IF;
2376: /*
2377: To do -
2378:

Line 2400: 'jtf.plsql.JTF_IH_BULK.PERFORM_CRASH_RECOVERY.end', l_fnd_log_msg);

2396: IF( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2397: l_fnd_log_msg := 'PERFORM_CRASH_RECOVERY No Out parameters';
2398: --dbms_output.put_line(l_fnd_log_msg);
2399: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
2400: 'jtf.plsql.JTF_IH_BULK.PERFORM_CRASH_RECOVERY.end', l_fnd_log_msg);
2401: END IF;
2402:
2403: RETURN;
2404:

Line 2417: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_RECOV_UNEXP');

2413: END IF;
2414: FND_FILE.PUT_LINE(FND_FILE.LOG, 'Error Message: ' || errm );
2415: g_hrt_beat := -98;
2416: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2417: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_RECOV_UNEXP');
2418: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
2419: 'jtf.plsql.JTF_IH_BULK.PERFORM_CRASH_RECOVERY', TRUE);
2420: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,
2421: 'jtf.plsql.JTF_IH_BULK.PERFORM_CRASH_RECOVERY',errm);

Line 2419: 'jtf.plsql.JTF_IH_BULK.PERFORM_CRASH_RECOVERY', TRUE);

2415: g_hrt_beat := -98;
2416: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2417: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_RECOV_UNEXP');
2418: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
2419: 'jtf.plsql.JTF_IH_BULK.PERFORM_CRASH_RECOVERY', TRUE);
2420: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,
2421: 'jtf.plsql.JTF_IH_BULK.PERFORM_CRASH_RECOVERY',errm);
2422: END IF;
2423: END;

Line 2421: 'jtf.plsql.JTF_IH_BULK.PERFORM_CRASH_RECOVERY',errm);

2417: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_RECOV_UNEXP');
2418: FND_LOG.MESSAGE(FND_LOG.LEVEL_EXCEPTION,
2419: 'jtf.plsql.JTF_IH_BULK.PERFORM_CRASH_RECOVERY', TRUE);
2420: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,
2421: 'jtf.plsql.JTF_IH_BULK.PERFORM_CRASH_RECOVERY',errm);
2422: END IF;
2423: END;
2424:
2425: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);

Line 2449: 'jtf.plsql.JTF_IH_BULK.LOG_EXC_OTHERS.begin', l_fnd_log_msg);

2445: l_fnd_log_msg := 'LOG_EXC_OTHERS In parameters : '||
2446: 'p_proc_name =' || p_proc_name;
2447: --dbms_output.put_line(l_fnd_log_msg);
2448: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
2449: 'jtf.plsql.JTF_IH_BULK.LOG_EXC_OTHERS.begin', l_fnd_log_msg);
2450: END IF;
2451:
2452: error := SQLCODE;
2453: IF (error IS NULL) THEN

Line 2459: errm := FND_MESSAGE.GET_STRING('JTF', 'JTF_IH_BULK_NOERRM');

2455: END IF;
2456:
2457: errm := SQLERRM;
2458: IF (errm IS NULL) THEN
2459: errm := FND_MESSAGE.GET_STRING('JTF', 'JTF_IH_BULK_NOERRM');
2460: END IF;
2461:
2462: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2463: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_PROC_EXCP');

Line 2463: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_PROC_EXCP');

2459: errm := FND_MESSAGE.GET_STRING('JTF', 'JTF_IH_BULK_NOERRM');
2460: END IF;
2461:
2462: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2463: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_PROC_EXCP');
2464: FND_MESSAGE.SET_TOKEN('PROC_NAME', p_proc_name);
2465: FND_LOG.MESSAGE(FND_LOG.LEVEL_STATEMENT,
2466: 'jtf.plsql.JTF_IH_BULK.LOG_EXC_OTHERS', TRUE);
2467: END IF;

Line 2466: 'jtf.plsql.JTF_IH_BULK.LOG_EXC_OTHERS', TRUE);

2462: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2463: FND_MESSAGE.SET_NAME('JTF', 'JTF_IH_BULK_PROC_EXCP');
2464: FND_MESSAGE.SET_TOKEN('PROC_NAME', p_proc_name);
2465: FND_LOG.MESSAGE(FND_LOG.LEVEL_STATEMENT,
2466: 'jtf.plsql.JTF_IH_BULK.LOG_EXC_OTHERS', TRUE);
2467: END IF;
2468:
2469: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
2470:

Line 2475: 'jtf.plsql.JTF_IH_BULK.LOG_EXC_OTHERS.begin', l_fnd_log_msg);

2471: IF( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2472: l_fnd_log_msg := 'LOG_EXC_OTHERS No Out parameters';
2473: --dbms_output.put_line(l_fnd_log_msg);
2474: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
2475: 'jtf.plsql.JTF_IH_BULK.LOG_EXC_OTHERS.begin', l_fnd_log_msg);
2476: END IF;
2477:
2478: RETURN;
2479:

Line 2483: END JTF_IH_BULK;

2479:
2480: END LOG_EXC_OTHERS;
2481:
2482:
2483: END JTF_IH_BULK;