DBA Data[Home] [Help]

APPS.CN_COLLECTION_CUSTOM_GEN dependencies on CN_MESSAGE_PKG

Line 126: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserting new transactions into CN_NOT_TRX.'');');

122:
123: cn_utils.set_org_id(p_org_id => l_org_id);
124: cn_utils.appendcr(code);
125: cn_utils.appendcr(code, '--******** NOTIFICATION PROCESSING *********-- ');
126: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserting new transactions into CN_NOT_TRX.'');');
127: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserting new transactions into CN_NOT_TRX.'');');
128: cn_utils.appendcr(code);
129: --+
130: -- Most local variables for the collect procedure are part of a static set, which is generated

Line 294: cn_message_pkg.debug('*** Finished notification run ');

290: cn_utils.appindcr(code, '-- Commit the notification inserts - they are permanent even if collection fails');
291: cn_utils.appindcr(code, 'COMMIT;');
292: cn_utils.unset_org_id();
293:
294: cn_message_pkg.debug('*** Finished notification run ');
295: fnd_file.put_line(fnd_file.Log,'*** Finished notification run ');
296:
297: cn_utils.set_org_id(p_org_id => l_org_id);
298: cn_utils.appendcr(code);

Line 489: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserting into CN_COMM_LINES_API.'');');

485: --+
486: cn_utils.set_org_id(p_org_id => X_org_id);
487: cn_utils.appendcr(code);
488: cn_utils.appendcr(code, '--******** INSERT CN_COMM_LINES_API *********-- ');
489: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserting into CN_COMM_LINES_API.'');');
490: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''Inserting into CN_COMM_LINES_API.'');');
491: cn_utils.appendcr(code);
492: --+
493: -- Generate the INSERT INTO API .. SELECT portion of

Line 544: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');

540: cn_utils.appendcr(code);
541: cn_utils.appindcr(code, 'comm_lines_api_count := SQL%ROWCOUNT;');
542: cn_utils.appendcr(code);
543:
544: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
545: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
546:
547: cn_utils.appendcr(code);
548: cn_utils.appendcr(code);

Line 551: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updating collected_flag in CN_NOT_TRX .'');');

547: cn_utils.appendcr(code);
548: cn_utils.appendcr(code);
549:
550: -- Update the collected_flag in CN_NOT_TRX
551: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updating collected_flag in CN_NOT_TRX .'');');
552: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Updating collected_flag in CN_NOT_TRX .'');');
553:
554: cn_utils.appendcr(code);
555:

Line 568: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updated collected_flag in cn_not_trx.'');');

564: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
565: cn_utils.appindcr(code, ' AND cnt.batch_id = x_proc_audit_id');
566: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id||' ;');
567: cn_utils.appendcr(code);
568: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updated collected_flag in cn_not_trx.'');');
569:
570: IF CN_COLLECTION_GEN.isParallelEnabled THEN
571: cn_utils.appindcr(code, 'COMMIT;');
572: END IF;

Line 750: cn_utils.appindcr(code, 'cn_message_pkg.debug(''For all INDIRECT mappings updated '' || SQL%ROWCOUNT || '' rows in cn_comm_lines_api.'');');

746: --+
747: -- Generate code to update the comm_lines_api_update_count variable
748: --+
749: cn_utils.appendcr(code);
750: cn_utils.appindcr(code, 'cn_message_pkg.debug(''For all INDIRECT mappings updated '' || SQL%ROWCOUNT || '' rows in cn_comm_lines_api.'');');
751: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''For all INDIRECT mappings updated '' || SQL%ROWCOUNT || '' rows in cn_comm_lines_api.'');');
752: cn_utils.appendcr(code);
753: cn_utils.unset_org_id();
754:

Line 806: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Filtering unwanted transactions from cn_comm_lines_api.'');');

802: END IF;
803: cn_utils.set_org_id(x_org_id);
804: cn_utils.appendcr(code);
805: cn_utils.appendcr(code, '--******** FILTER PROCESSING *********-- ');
806: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Filtering unwanted transactions from cn_comm_lines_api.'');');
807: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''Filtering unwanted transactions from cn_comm_lines_api.'');');
808: cn_utils.appendcr(code);
809: --+
810: -- Generate deletion code