APPS.CN_COLLECTION_CUSTOM_GEN dependencies on CN_MESSAGE_PKG

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

93: END IF;
94: cn_utils.set_org_id(p_org_id => l_org_id);
95: cn_utils.appendcr(code);
96: cn_utils.appendcr(code, '--******** NOTIFICATION PROCESSING *********-- ');
97: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserting new transactions into CN_NOT_TRX.'');');
98: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserting new transactions into CN_NOT_TRX.'');');
99: cn_utils.appendcr(code);
100: --+
101: -- Most local variables for the collect procedure are part of a static set, which is generated

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

245: cn_utils.appendcr(code);
246: cn_utils.appindcr(code, '-- Commit the notification inserts - they are permanent even if collection fails');
247: cn_utils.appindcr(code, 'COMMIT;');
248: cn_utils.unset_org_id();
249: cn_message_pkg.debug('*** Finished notification run ');
250: fnd_file.put_line(fnd_file.Log,'*** Finished notification run ');
251: cn_utils.set_org_id(p_org_id => l_org_id);
252: cn_utils.appendcr(code);
253: cn_utils.appendcr(code, '--******** COLLECT AJUSTMENTS (NEGATE IN API) ********-- ');

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

414: --+
415: cn_utils.set_org_id(p_org_id => X_org_id);
416: cn_utils.appendcr(code);
417: cn_utils.appendcr(code, '--******** INSERT CN_COMM_LINES_API *********-- ');
418: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserting into CN_COMM_LINES_API.'');');
419: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''Inserting into CN_COMM_LINES_API.'');');
420: cn_utils.appendcr(code);
421: --+
422: -- Generate the INSERT INTO API .. SELECT portion of

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

459: cn_utils.unindent(code, 1);
460: cn_utils.appendcr(code);
461: cn_utils.appindcr(code, 'comm_lines_api_count := SQL%ROWCOUNT;');
462: cn_utils.appendcr(code);
463: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
464: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
465: cn_utils.appendcr(code);
466: cn_utils.appendcr(code);
467: -- Update the collected_flag in CN_NOT_TRX

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

464: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
465: cn_utils.appendcr(code);
466: cn_utils.appendcr(code);
467: -- Update the collected_flag in CN_NOT_TRX
468: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updating collected_flag in CN_NOT_TRX .'');');
469: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Updating collected_flag in CN_NOT_TRX .'');');
470: cn_utils.appendcr(code);
471: IF CN_COLLECTION_GEN.isParallelEnabled THEN
472: cn_utils.appindcr(code, 'UPDATE /'||'*+ PARALLEL(cnt) */ cn_not_trx cnt');

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

478: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
479: cn_utils.appindcr(code, ' AND cnt.batch_id = x_batch_id');
480: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id||' ;');
481: cn_utils.appendcr(code);
482: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updated collected_flag in cn_not_trx.'');');
483: IF CN_COLLECTION_GEN.isParallelEnabled THEN
484: cn_utils.appindcr(code, 'COMMIT;');
485: END IF;
486: cn_utils.appendcr(code);

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

655: --+
656: -- Generate code to update the comm_lines_api_update_count variable
657: --+
658: cn_utils.appendcr(code);
659: cn_utils.appindcr(code, 'cn_message_pkg.debug(''For all INDIRECT mappings updated '' || SQL%ROWCOUNT || '' rows in cn_comm_lines_api.'');');
660: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''For all INDIRECT mappings updated '' || SQL%ROWCOUNT || '' rows in cn_comm_lines_api.'');');
661: cn_utils.appendcr(code);
662: cn_utils.unset_org_id();
663: EXCEPTION

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

709: END IF;
710: cn_utils.set_org_id(x_org_id);
711: cn_utils.appendcr(code);
712: cn_utils.appendcr(code, '--******** FILTER PROCESSING *********-- ');
713: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Filtering unwanted transactions from cn_comm_lines_api.'');');
714: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''Filtering unwanted transactions from cn_comm_lines_api.'');');
715: cn_utils.appendcr(code);
716: --+
717: -- Generate deletion code