APPS.CN_COLLECTION_CUSTOM_GEN dependencies on CN_COLLECTION_GEN

Line 102: -- for all pacakges (inclding OC and AR) at the start of the procedure by the cn_collection_gen

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
102: -- for all pacakges (inclding OC and AR) at the start of the procedure by the cn_collection_gen
103: -- package. However, for the notification query of Custom data sources, we need local variables
104: -- which have the names of the any parameters which have been specified by the user on the Queries
105: -- tab of the Collections form. To allow use to do this, we need to enclose the notification query
106: -- in its own block.

Line 160: IF CN_COLLECTION_GEN.isParallelEnabled THEN

156: --+
157: -- Changed to fix Bug 6203234 to include PDML in Notification Query
158: --
159: --+
160: IF CN_COLLECTION_GEN.isParallelEnabled THEN
161: create_parallel_hint(x_source_string => l_notify_from, x_parallel_hint => l_parallel_hint );
162: END IF;
163: --+
164: -- Generate the INSERT INTO API .. SELECT portion of

Line 172: IF CN_COLLECTION_GEN.isParallelEnabled THEN

168: cn_utils.appindcr(code, '--');
169: cn_utils.appindcr(code, '-- Insert new lines into cn_not_trx');
170: cn_utils.appindcr(code, '--');
171: cn_utils.appindcr(code, '--CN_DB_PARALLEL_ENABLE :'||fnd_profile.value('CN_DB_PARALLEL_ENABLE'));
172: IF CN_COLLECTION_GEN.isParallelEnabled THEN
173: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_not_trx) */ INTO cn_not_trx (');
174: ELSE
175: cn_utils.appindcr(code, 'INSERT INTO cn_not_trx (');
176: END IF;

Line 192: IF CN_COLLECTION_GEN.isParallelEnabled THEN

188: cn_utils.unindent(code, 1);
189: --+
190: -- Generate the SELECT clause for the insert statement
191: --+
192: IF CN_COLLECTION_GEN.isParallelEnabled THEN
193: cn_utils.appindcr(code, 'SELECT '||l_parallel_hint);
194: ELSE
195: cn_utils.appindcr(code, 'SELECT ');
196: END IF;

Line 234: IF CN_COLLECTION_GEN.isParallelEnabled THEN

230: --+
231: -- Finish off the statement
232: --+
233: cn_utils.appindcr(code, ' AND NOT EXISTS (');
234: IF CN_COLLECTION_GEN.isParallelEnabled THEN
235: cn_utils.appindcr(code, ' SELECT /'||'*'||'+ PARALLEL(cn_not_trx) '||'*/ 1');
236: ELSE
237: cn_utils.appindcr(code, ' SELECT 1');
238: END IF;

Line 300: IF CN_COLLECTION_GEN.isParallelEnabled THEN

296: -- Added For R12 MOAC Changes
297: ORDER BY dest_column;
298: BEGIN
299: cn_utils.set_org_id(p_org_id => x_org_id);
300: IF CN_COLLECTION_GEN.isParallelEnabled THEN
301: IF x_table_map_id > 0 THEN
302: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_comm_lines_api) */ INTO cn_comm_lines_api (');
303: ELSE
304: cn_utils.appindcr(code, 'INSERT INTO cn_comm_lines_api (');

Line 325: IF CN_COLLECTION_GEN.isParallelEnabled THEN

321: cn_utils.strip_prev(code, 1); -- remove trailing comma
322: cn_utils.appindcr(code, ')');
323: cn_utils.unindent(code, 1);
324: -- Generate the SELECT clause for the insert statement
325: IF CN_COLLECTION_GEN.isParallelEnabled THEN
326: cn_utils.appindcr(code, 'SELECT '||x_parallel_hint);
327: ELSE
328: cn_utils.appindcr(code, 'SELECT ');
329: END IF;

Line 408: IF CN_COLLECTION_GEN.isParallelEnabled THEN

404: --+
405: -- Changed to fix Bug 6203234 to include PDML in Collection Query
406: --
407: --+
408: IF CN_COLLECTION_GEN.isParallelEnabled THEN
409: create_parallel_hint(x_source_string => l_collect_from,
410: x_parallel_hint => l_parallel_hint );
411: END IF;
412: --+

Line 471: IF CN_COLLECTION_GEN.isParallelEnabled THEN

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');
473: ELSE
474: cn_utils.appindcr(code, 'UPDATE cn_not_trx cnt');
475: END IF;

Line 483: IF CN_COLLECTION_GEN.isParallelEnabled THEN

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);
487: cn_utils.unset_org_id();