eTRM uses javascript that opens and focuses a separate window to display reports. Your browser does not appear to support javascript. This should not prevent you from using eTRM but it does mean the window focus feature will not work. Please check the contents of other windows on your desktop if you click on a link that does not appear to do anything.

APPS.CN_COLLECTION_CUSTOM_GEN dependencies on CN_UTILS

Line 61: code IN OUT NOCOPY cn_utils.code_type,

57:
58: PROCEDURE insert_cn_not_trx (
59: x_table_map_id cn_table_maps.table_map_id%TYPE,
60: x_event_id cn_events.event_id%TYPE,
61: code IN OUT NOCOPY cn_utils.code_type,
62: x_org_id IN NUMBER)
63: IS
64:
65: l_return_status VARCHAR2(4000);

Line 123: cn_utils.set_org_id(p_org_id => l_org_id);

119: NVL(l_table_map_rec.header_table_alias,l_table_map_rec.header_table_name)||
120: '.'||l_table_map_rec.hdrpk_name);
121: END IF;
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.'');');

Line 124: cn_utils.appendcr(code);

120: '.'||l_table_map_rec.hdrpk_name);
121: END IF;
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);

Line 125: cn_utils.appendcr(code, '-- NOTIFICATION PROCESSING *-- ');

121: END IF;
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: --+

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 127: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserting new transactions into CN_NOT_TRX.'');');

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
131: -- for all pacakges (inclding OC and AR) at the start of the procedure by the cn_collection_gen

Line 128: cn_utils.appendcr(code);

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
131: -- for all pacakges (inclding OC and AR) at the start of the procedure by the cn_collection_gen
132: -- package. However, for the notification query of Custom data sources, we need local variables

Line 137: cn_utils.appindcr(code, 'DECLARE -- Notification Insert Block');

133: -- which have the names of the any parameters which have been specified by the user on the Queries
134: -- tab of the Collections form. To allow use to do this, we need to enclose the notification query
135: -- in its own block.
136: --+
137: cn_utils.appindcr(code, 'DECLARE -- Notification Insert Block');
138: --+
139: -- Generate Declarations of parameter variables
140: --+
141: cn_utils.indent(code, 1);

Line 141: cn_utils.indent(code, 1);

137: cn_utils.appindcr(code, 'DECLARE -- Notification Insert Block');
138: --+
139: -- Generate Declarations of parameter variables
140: --+
141: cn_utils.indent(code, 1);
142: cn_utils.appindcr(code, '--*** Declaring user-defined Notification Parameters');
143: FOR rec IN c_param
144: LOOP
145: cn_utils.appindcr(code, rec.object_name||' cn_objects.object_value%TYPE;');

Line 142: cn_utils.appindcr(code, '--*** Declaring user-defined Notification Parameters');

138: --+
139: -- Generate Declarations of parameter variables
140: --+
141: cn_utils.indent(code, 1);
142: cn_utils.appindcr(code, '--*** Declaring user-defined Notification Parameters');
143: FOR rec IN c_param
144: LOOP
145: cn_utils.appindcr(code, rec.object_name||' cn_objects.object_value%TYPE;');
146: END LOOP;

Line 145: cn_utils.appindcr(code, rec.object_name||' cn_objects.object_value%TYPE;');

141: cn_utils.indent(code, 1);
142: cn_utils.appindcr(code, '--*** Declaring user-defined Notification Parameters');
143: FOR rec IN c_param
144: LOOP
145: cn_utils.appindcr(code, rec.object_name||' cn_objects.object_value%TYPE;');
146: END LOOP;
147: cn_utils.unindent(code, 1);
148: cn_utils.appindcr(code, 'BEGIN');
149: --+

Line 147: cn_utils.unindent(code, 1);

143: FOR rec IN c_param
144: LOOP
145: cn_utils.appindcr(code, rec.object_name||' cn_objects.object_value%TYPE;');
146: END LOOP;
147: cn_utils.unindent(code, 1);
148: cn_utils.appindcr(code, 'BEGIN');
149: --+
150: -- Generate code to initialise parameter variables
151: --+

Line 148: cn_utils.appindcr(code, 'BEGIN');

144: LOOP
145: cn_utils.appindcr(code, rec.object_name||' cn_objects.object_value%TYPE;');
146: END LOOP;
147: cn_utils.unindent(code, 1);
148: cn_utils.appindcr(code, 'BEGIN');
149: --+
150: -- Generate code to initialise parameter variables
151: --+
152: cn_utils.indent(code, 1);

Line 152: cn_utils.indent(code, 1);

148: cn_utils.appindcr(code, 'BEGIN');
149: --+
150: -- Generate code to initialise parameter variables
151: --+
152: cn_utils.indent(code, 1);
153: cn_utils.appindcr(code, '--*** Initializing user-defined Notification Parameters');
154: FOR rec IN c_param
155: LOOP
156: cn_utils.appindcr(code, 'SELECT object_value');

Line 153: cn_utils.appindcr(code, '--*** Initializing user-defined Notification Parameters');

149: --+
150: -- Generate code to initialise parameter variables
151: --+
152: cn_utils.indent(code, 1);
153: cn_utils.appindcr(code, '--*** Initializing user-defined Notification Parameters');
154: FOR rec IN c_param
155: LOOP
156: cn_utils.appindcr(code, 'SELECT object_value');
157: cn_utils.appindcr(code, 'INTO '||rec.object_name);

Line 156: cn_utils.appindcr(code, 'SELECT object_value');

152: cn_utils.indent(code, 1);
153: cn_utils.appindcr(code, '--*** Initializing user-defined Notification Parameters');
154: FOR rec IN c_param
155: LOOP
156: cn_utils.appindcr(code, 'SELECT object_value');
157: cn_utils.appindcr(code, 'INTO '||rec.object_name);
158: cn_utils.appindcr(code, 'FROM cn_objects');
159: cn_utils.appindcr(code, 'WHERE object_id = '||rec.object_id||' --*** Object_Id for '||rec.object_name);
160: cn_utils.appindcr(code, 'AND org_id = '||l_org_id||';');

Line 157: cn_utils.appindcr(code, 'INTO '||rec.object_name);

153: cn_utils.appindcr(code, '--*** Initializing user-defined Notification Parameters');
154: FOR rec IN c_param
155: LOOP
156: cn_utils.appindcr(code, 'SELECT object_value');
157: cn_utils.appindcr(code, 'INTO '||rec.object_name);
158: cn_utils.appindcr(code, 'FROM cn_objects');
159: cn_utils.appindcr(code, 'WHERE object_id = '||rec.object_id||' --*** Object_Id for '||rec.object_name);
160: cn_utils.appindcr(code, 'AND org_id = '||l_org_id||';');
161: cn_utils.appendcr(code);

Line 158: cn_utils.appindcr(code, 'FROM cn_objects');

154: FOR rec IN c_param
155: LOOP
156: cn_utils.appindcr(code, 'SELECT object_value');
157: cn_utils.appindcr(code, 'INTO '||rec.object_name);
158: cn_utils.appindcr(code, 'FROM cn_objects');
159: cn_utils.appindcr(code, 'WHERE object_id = '||rec.object_id||' --*** Object_Id for '||rec.object_name);
160: cn_utils.appindcr(code, 'AND org_id = '||l_org_id||';');
161: cn_utils.appendcr(code);
162: END LOOP;

Line 159: cn_utils.appindcr(code, 'WHERE object_id = '||rec.object_id||' --*** Object_Id for '||rec.object_name);

155: LOOP
156: cn_utils.appindcr(code, 'SELECT object_value');
157: cn_utils.appindcr(code, 'INTO '||rec.object_name);
158: cn_utils.appindcr(code, 'FROM cn_objects');
159: cn_utils.appindcr(code, 'WHERE object_id = '||rec.object_id||' --*** Object_Id for '||rec.object_name);
160: cn_utils.appindcr(code, 'AND org_id = '||l_org_id||';');
161: cn_utils.appendcr(code);
162: END LOOP;
163:

Line 160: cn_utils.appindcr(code, 'AND org_id = '||l_org_id||';');

156: cn_utils.appindcr(code, 'SELECT object_value');
157: cn_utils.appindcr(code, 'INTO '||rec.object_name);
158: cn_utils.appindcr(code, 'FROM cn_objects');
159: cn_utils.appindcr(code, 'WHERE object_id = '||rec.object_id||' --*** Object_Id for '||rec.object_name);
160: cn_utils.appindcr(code, 'AND org_id = '||l_org_id||';');
161: cn_utils.appendcr(code);
162: END LOOP;
163:
164: -- Added For R12 MOAC Change

Line 161: cn_utils.appendcr(code);

157: cn_utils.appindcr(code, 'INTO '||rec.object_name);
158: cn_utils.appindcr(code, 'FROM cn_objects');
159: cn_utils.appindcr(code, 'WHERE object_id = '||rec.object_id||' --*** Object_Id for '||rec.object_name);
160: cn_utils.appindcr(code, 'AND org_id = '||l_org_id||';');
161: cn_utils.appendcr(code);
162: END LOOP;
163:
164: -- Added For R12 MOAC Change
165: cn_utils.appendcr(code);

Line 165: cn_utils.appendcr(code);

161: cn_utils.appendcr(code);
162: END LOOP;
163:
164: -- Added For R12 MOAC Change
165: cn_utils.appendcr(code);
166: --+
167: -- Insert any User Code specified for the 'Pre-Notification' location
168: --+
169: Generate_User_Code(

Line 205: cn_utils.set_org_id(l_org_id);

201: --+
202: -- Generate the INSERT INTO API .. SELECT portion of
203: -- the statement
204: --+
205: cn_utils.set_org_id(l_org_id);
206: cn_utils.appindcr(code, '--');
207: cn_utils.appindcr(code, '-- Insert new lines into cn_not_trx');
208: cn_utils.appindcr(code, '--');
209: cn_utils.appindcr(code, '--CN_DB_PARALLEL_ENABLE :'||fnd_profile.value('CN_DB_PARALLEL_ENABLE'));

Line 206: cn_utils.appindcr(code, '--');

202: -- Generate the INSERT INTO API .. SELECT portion of
203: -- the statement
204: --+
205: cn_utils.set_org_id(l_org_id);
206: cn_utils.appindcr(code, '--');
207: cn_utils.appindcr(code, '-- Insert new lines into cn_not_trx');
208: cn_utils.appindcr(code, '--');
209: cn_utils.appindcr(code, '--CN_DB_PARALLEL_ENABLE :'||fnd_profile.value('CN_DB_PARALLEL_ENABLE'));
210: IF CN_COLLECTION_GEN.isParallelEnabled THEN

Line 207: cn_utils.appindcr(code, '-- Insert new lines into cn_not_trx');

203: -- the statement
204: --+
205: cn_utils.set_org_id(l_org_id);
206: cn_utils.appindcr(code, '--');
207: cn_utils.appindcr(code, '-- Insert new lines into cn_not_trx');
208: cn_utils.appindcr(code, '--');
209: cn_utils.appindcr(code, '--CN_DB_PARALLEL_ENABLE :'||fnd_profile.value('CN_DB_PARALLEL_ENABLE'));
210: IF CN_COLLECTION_GEN.isParallelEnabled THEN
211: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_not_trx) */ INTO cn_not_trx (');

Line 208: cn_utils.appindcr(code, '--');

204: --+
205: cn_utils.set_org_id(l_org_id);
206: cn_utils.appindcr(code, '--');
207: cn_utils.appindcr(code, '-- Insert new lines into cn_not_trx');
208: cn_utils.appindcr(code, '--');
209: cn_utils.appindcr(code, '--CN_DB_PARALLEL_ENABLE :'||fnd_profile.value('CN_DB_PARALLEL_ENABLE'));
210: IF CN_COLLECTION_GEN.isParallelEnabled THEN
211: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_not_trx) */ INTO cn_not_trx (');
212: ELSE

Line 209: cn_utils.appindcr(code, '--CN_DB_PARALLEL_ENABLE :'||fnd_profile.value('CN_DB_PARALLEL_ENABLE'));

205: cn_utils.set_org_id(l_org_id);
206: cn_utils.appindcr(code, '--');
207: cn_utils.appindcr(code, '-- Insert new lines into cn_not_trx');
208: cn_utils.appindcr(code, '--');
209: cn_utils.appindcr(code, '--CN_DB_PARALLEL_ENABLE :'||fnd_profile.value('CN_DB_PARALLEL_ENABLE'));
210: IF CN_COLLECTION_GEN.isParallelEnabled THEN
211: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_not_trx) */ INTO cn_not_trx (');
212: ELSE
213: cn_utils.appindcr(code, 'INSERT INTO cn_not_trx (');

Line 211: cn_utils.appindcr(code, 'INSERT /'||'+ PARALLEL(cn_not_trx) / INTO cn_not_trx (');

207: cn_utils.appindcr(code, '-- Insert new lines into cn_not_trx');
208: cn_utils.appindcr(code, '--');
209: cn_utils.appindcr(code, '--CN_DB_PARALLEL_ENABLE :'||fnd_profile.value('CN_DB_PARALLEL_ENABLE'));
210: IF CN_COLLECTION_GEN.isParallelEnabled THEN
211: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_not_trx) */ INTO cn_not_trx (');
212: ELSE
213: cn_utils.appindcr(code, 'INSERT INTO cn_not_trx (');
214: END IF;
215: cn_utils.indent(code, 1);

Line 213: cn_utils.appindcr(code, 'INSERT INTO cn_not_trx (');

209: cn_utils.appindcr(code, '--CN_DB_PARALLEL_ENABLE :'||fnd_profile.value('CN_DB_PARALLEL_ENABLE'));
210: IF CN_COLLECTION_GEN.isParallelEnabled THEN
211: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_not_trx) */ INTO cn_not_trx (');
212: ELSE
213: cn_utils.appindcr(code, 'INSERT INTO cn_not_trx (');
214: END IF;
215: cn_utils.indent(code, 1);
216: cn_utils.appindcr(code, 'not_trx_id,');
217: cn_utils.appindcr(code, 'batch_id,');

Line 215: cn_utils.indent(code, 1);

211: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_not_trx) */ INTO cn_not_trx (');
212: ELSE
213: cn_utils.appindcr(code, 'INSERT INTO cn_not_trx (');
214: END IF;
215: cn_utils.indent(code, 1);
216: cn_utils.appindcr(code, 'not_trx_id,');
217: cn_utils.appindcr(code, 'batch_id,');
218: cn_utils.appindcr(code, 'notified_date,');
219: cn_utils.appindcr(code, 'notification_run_id,');

Line 216: cn_utils.appindcr(code, 'not_trx_id,');

212: ELSE
213: cn_utils.appindcr(code, 'INSERT INTO cn_not_trx (');
214: END IF;
215: cn_utils.indent(code, 1);
216: cn_utils.appindcr(code, 'not_trx_id,');
217: cn_utils.appindcr(code, 'batch_id,');
218: cn_utils.appindcr(code, 'notified_date,');
219: cn_utils.appindcr(code, 'notification_run_id,');
220: cn_utils.appindcr(code, 'collected_flag,');

Line 217: cn_utils.appindcr(code, 'batch_id,');

213: cn_utils.appindcr(code, 'INSERT INTO cn_not_trx (');
214: END IF;
215: cn_utils.indent(code, 1);
216: cn_utils.appindcr(code, 'not_trx_id,');
217: cn_utils.appindcr(code, 'batch_id,');
218: cn_utils.appindcr(code, 'notified_date,');
219: cn_utils.appindcr(code, 'notification_run_id,');
220: cn_utils.appindcr(code, 'collected_flag,');
221: cn_utils.appindcr(code, 'event_id,');

Line 218: cn_utils.appindcr(code, 'notified_date,');

214: END IF;
215: cn_utils.indent(code, 1);
216: cn_utils.appindcr(code, 'not_trx_id,');
217: cn_utils.appindcr(code, 'batch_id,');
218: cn_utils.appindcr(code, 'notified_date,');
219: cn_utils.appindcr(code, 'notification_run_id,');
220: cn_utils.appindcr(code, 'collected_flag,');
221: cn_utils.appindcr(code, 'event_id,');
222: cn_utils.appindcr(code, 'source_trx_id,');

Line 219: cn_utils.appindcr(code, 'notification_run_id,');

215: cn_utils.indent(code, 1);
216: cn_utils.appindcr(code, 'not_trx_id,');
217: cn_utils.appindcr(code, 'batch_id,');
218: cn_utils.appindcr(code, 'notified_date,');
219: cn_utils.appindcr(code, 'notification_run_id,');
220: cn_utils.appindcr(code, 'collected_flag,');
221: cn_utils.appindcr(code, 'event_id,');
222: cn_utils.appindcr(code, 'source_trx_id,');
223: cn_utils.appindcr(code, 'source_trx_line_id,');

Line 220: cn_utils.appindcr(code, 'collected_flag,');

216: cn_utils.appindcr(code, 'not_trx_id,');
217: cn_utils.appindcr(code, 'batch_id,');
218: cn_utils.appindcr(code, 'notified_date,');
219: cn_utils.appindcr(code, 'notification_run_id,');
220: cn_utils.appindcr(code, 'collected_flag,');
221: cn_utils.appindcr(code, 'event_id,');
222: cn_utils.appindcr(code, 'source_trx_id,');
223: cn_utils.appindcr(code, 'source_trx_line_id,');
224: cn_utils.appindcr(code, 'source_doc_type,');

Line 221: cn_utils.appindcr(code, 'event_id,');

217: cn_utils.appindcr(code, 'batch_id,');
218: cn_utils.appindcr(code, 'notified_date,');
219: cn_utils.appindcr(code, 'notification_run_id,');
220: cn_utils.appindcr(code, 'collected_flag,');
221: cn_utils.appindcr(code, 'event_id,');
222: cn_utils.appindcr(code, 'source_trx_id,');
223: cn_utils.appindcr(code, 'source_trx_line_id,');
224: cn_utils.appindcr(code, 'source_doc_type,');
225: cn_utils.appindcr(code, 'org_id)'); -- Added For R12 MOAC Change

Line 222: cn_utils.appindcr(code, 'source_trx_id,');

218: cn_utils.appindcr(code, 'notified_date,');
219: cn_utils.appindcr(code, 'notification_run_id,');
220: cn_utils.appindcr(code, 'collected_flag,');
221: cn_utils.appindcr(code, 'event_id,');
222: cn_utils.appindcr(code, 'source_trx_id,');
223: cn_utils.appindcr(code, 'source_trx_line_id,');
224: cn_utils.appindcr(code, 'source_doc_type,');
225: cn_utils.appindcr(code, 'org_id)'); -- Added For R12 MOAC Change
226: cn_utils.unindent(code, 1);

Line 223: cn_utils.appindcr(code, 'source_trx_line_id,');

219: cn_utils.appindcr(code, 'notification_run_id,');
220: cn_utils.appindcr(code, 'collected_flag,');
221: cn_utils.appindcr(code, 'event_id,');
222: cn_utils.appindcr(code, 'source_trx_id,');
223: cn_utils.appindcr(code, 'source_trx_line_id,');
224: cn_utils.appindcr(code, 'source_doc_type,');
225: cn_utils.appindcr(code, 'org_id)'); -- Added For R12 MOAC Change
226: cn_utils.unindent(code, 1);
227: --+

Line 224: cn_utils.appindcr(code, 'source_doc_type,');

220: cn_utils.appindcr(code, 'collected_flag,');
221: cn_utils.appindcr(code, 'event_id,');
222: cn_utils.appindcr(code, 'source_trx_id,');
223: cn_utils.appindcr(code, 'source_trx_line_id,');
224: cn_utils.appindcr(code, 'source_doc_type,');
225: cn_utils.appindcr(code, 'org_id)'); -- Added For R12 MOAC Change
226: cn_utils.unindent(code, 1);
227: --+
228: -- Generate the SELECT clause for the insert statement

Line 225: cn_utils.appindcr(code, 'org_id)'); -- Added For R12 MOAC Change

221: cn_utils.appindcr(code, 'event_id,');
222: cn_utils.appindcr(code, 'source_trx_id,');
223: cn_utils.appindcr(code, 'source_trx_line_id,');
224: cn_utils.appindcr(code, 'source_doc_type,');
225: cn_utils.appindcr(code, 'org_id)'); -- Added For R12 MOAC Change
226: cn_utils.unindent(code, 1);
227: --+
228: -- Generate the SELECT clause for the insert statement
229: --+

Line 226: cn_utils.unindent(code, 1);

222: cn_utils.appindcr(code, 'source_trx_id,');
223: cn_utils.appindcr(code, 'source_trx_line_id,');
224: cn_utils.appindcr(code, 'source_doc_type,');
225: cn_utils.appindcr(code, 'org_id)'); -- Added For R12 MOAC Change
226: cn_utils.unindent(code, 1);
227: --+
228: -- Generate the SELECT clause for the insert statement
229: --+
230: IF CN_COLLECTION_GEN.isParallelEnabled THEN

Line 231: cn_utils.appindcr(code, 'SELECT '||l_parallel_hint);

227: --+
228: -- Generate the SELECT clause for the insert statement
229: --+
230: IF CN_COLLECTION_GEN.isParallelEnabled THEN
231: cn_utils.appindcr(code, 'SELECT '||l_parallel_hint);
232: ELSE
233: cn_utils.appindcr(code, 'SELECT ');
234: END IF;
235: cn_utils.indent(code, 1);

Line 233: cn_utils.appindcr(code, 'SELECT ');

229: --+
230: IF CN_COLLECTION_GEN.isParallelEnabled THEN
231: cn_utils.appindcr(code, 'SELECT '||l_parallel_hint);
232: ELSE
233: cn_utils.appindcr(code, 'SELECT ');
234: END IF;
235: cn_utils.indent(code, 1);
236: cn_utils.appindcr(code, 'cn_not_trx_s.NEXTVAL,');
237:

Line 235: cn_utils.indent(code, 1);

231: cn_utils.appindcr(code, 'SELECT '||l_parallel_hint);
232: ELSE
233: cn_utils.appindcr(code, 'SELECT ');
234: END IF;
235: cn_utils.indent(code, 1);
236: cn_utils.appindcr(code, 'cn_not_trx_s.NEXTVAL,');
237:
238: -- Changed for Bug 6203234
239: --cn_utils.appindcr(code, 'FLOOR(cn_not_trx_s.CURRVAL/cn_global_var.g_system_batch_size),');

Line 236: cn_utils.appindcr(code, 'cn_not_trx_s.NEXTVAL,');

232: ELSE
233: cn_utils.appindcr(code, 'SELECT ');
234: END IF;
235: cn_utils.indent(code, 1);
236: cn_utils.appindcr(code, 'cn_not_trx_s.NEXTVAL,');
237:
238: -- Changed for Bug 6203234
239: --cn_utils.appindcr(code, 'FLOOR(cn_not_trx_s.CURRVAL/cn_global_var.g_system_batch_size),');
240: cn_utils.appindcr(code, 'x_proc_audit_id,');

Line 239: --cn_utils.appindcr(code, 'FLOOR(cn_not_trx_s.CURRVAL/cn_global_var.g_system_batch_size),');

235: cn_utils.indent(code, 1);
236: cn_utils.appindcr(code, 'cn_not_trx_s.NEXTVAL,');
237:
238: -- Changed for Bug 6203234
239: --cn_utils.appindcr(code, 'FLOOR(cn_not_trx_s.CURRVAL/cn_global_var.g_system_batch_size),');
240: cn_utils.appindcr(code, 'x_proc_audit_id,');
241:
242: cn_utils.appindcr(code, 'SYSDATE,');
243: cn_utils.appindcr(code, 'x_proc_audit_id,');

Line 240: cn_utils.appindcr(code, 'x_proc_audit_id,');

236: cn_utils.appindcr(code, 'cn_not_trx_s.NEXTVAL,');
237:
238: -- Changed for Bug 6203234
239: --cn_utils.appindcr(code, 'FLOOR(cn_not_trx_s.CURRVAL/cn_global_var.g_system_batch_size),');
240: cn_utils.appindcr(code, 'x_proc_audit_id,');
241:
242: cn_utils.appindcr(code, 'SYSDATE,');
243: cn_utils.appindcr(code, 'x_proc_audit_id,');
244: cn_utils.appindcr(code, '''N'',');

Line 242: cn_utils.appindcr(code, 'SYSDATE,');

238: -- Changed for Bug 6203234
239: --cn_utils.appindcr(code, 'FLOOR(cn_not_trx_s.CURRVAL/cn_global_var.g_system_batch_size),');
240: cn_utils.appindcr(code, 'x_proc_audit_id,');
241:
242: cn_utils.appindcr(code, 'SYSDATE,');
243: cn_utils.appindcr(code, 'x_proc_audit_id,');
244: cn_utils.appindcr(code, '''N'',');
245: cn_utils.appindcr(code, x_event_id||',');
246: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');

Line 243: cn_utils.appindcr(code, 'x_proc_audit_id,');

239: --cn_utils.appindcr(code, 'FLOOR(cn_not_trx_s.CURRVAL/cn_global_var.g_system_batch_size),');
240: cn_utils.appindcr(code, 'x_proc_audit_id,');
241:
242: cn_utils.appindcr(code, 'SYSDATE,');
243: cn_utils.appindcr(code, 'x_proc_audit_id,');
244: cn_utils.appindcr(code, '''N'',');
245: cn_utils.appindcr(code, x_event_id||',');
246: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');
247: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');

Line 244: cn_utils.appindcr(code, '''N'',');

240: cn_utils.appindcr(code, 'x_proc_audit_id,');
241:
242: cn_utils.appindcr(code, 'SYSDATE,');
243: cn_utils.appindcr(code, 'x_proc_audit_id,');
244: cn_utils.appindcr(code, '''N'',');
245: cn_utils.appindcr(code, x_event_id||',');
246: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');
247: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');
248: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');

Line 245: cn_utils.appindcr(code, x_event_id||',');

241:
242: cn_utils.appindcr(code, 'SYSDATE,');
243: cn_utils.appindcr(code, 'x_proc_audit_id,');
244: cn_utils.appindcr(code, '''N'',');
245: cn_utils.appindcr(code, x_event_id||',');
246: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');
247: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');
248: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');
249: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change

Line 246: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');

242: cn_utils.appindcr(code, 'SYSDATE,');
243: cn_utils.appindcr(code, 'x_proc_audit_id,');
244: cn_utils.appindcr(code, '''N'',');
245: cn_utils.appindcr(code, x_event_id||',');
246: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');
247: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');
248: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');
249: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change
250: cn_utils.unindent(code, 1);

Line 247: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');

243: cn_utils.appindcr(code, 'x_proc_audit_id,');
244: cn_utils.appindcr(code, '''N'',');
245: cn_utils.appindcr(code, x_event_id||',');
246: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');
247: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');
248: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');
249: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change
250: cn_utils.unindent(code, 1);
251: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');

Line 248: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');

244: cn_utils.appindcr(code, '''N'',');
245: cn_utils.appindcr(code, x_event_id||',');
246: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');
247: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');
248: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');
249: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change
250: cn_utils.unindent(code, 1);
251: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');
252: cn_utils.indent(code, 1);

Line 249: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change

245: cn_utils.appindcr(code, x_event_id||',');
246: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');
247: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');
248: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');
249: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change
250: cn_utils.unindent(code, 1);
251: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');
252: cn_utils.indent(code, 1);
253: cn_utils.appindcr(code, l_notify_from);

Line 250: cn_utils.unindent(code, 1);

246: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');
247: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');
248: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');
249: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change
250: cn_utils.unindent(code, 1);
251: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');
252: cn_utils.indent(code, 1);
253: cn_utils.appindcr(code, l_notify_from);
254: cn_utils.unindent(code, 1);

Line 251: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');

247: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');
248: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');
249: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change
250: cn_utils.unindent(code, 1);
251: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');
252: cn_utils.indent(code, 1);
253: cn_utils.appindcr(code, l_notify_from);
254: cn_utils.unindent(code, 1);
255: cn_utils.appindcr(code, 'WHERE --*** Header.Primary_Key = Line.Foreign_Key');

Line 252: cn_utils.indent(code, 1);

248: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');
249: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change
250: cn_utils.unindent(code, 1);
251: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');
252: cn_utils.indent(code, 1);
253: cn_utils.appindcr(code, l_notify_from);
254: cn_utils.unindent(code, 1);
255: cn_utils.appindcr(code, 'WHERE --*** Header.Primary_Key = Line.Foreign_Key');
256: cn_utils.indent(code, 1);

Line 253: cn_utils.appindcr(code, l_notify_from);

249: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change
250: cn_utils.unindent(code, 1);
251: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');
252: cn_utils.indent(code, 1);
253: cn_utils.appindcr(code, l_notify_from);
254: cn_utils.unindent(code, 1);
255: cn_utils.appindcr(code, 'WHERE --*** Header.Primary_Key = Line.Foreign_Key');
256: cn_utils.indent(code, 1);
257: cn_utils.appindcr(code, l_notify_where);

Line 254: cn_utils.unindent(code, 1);

250: cn_utils.unindent(code, 1);
251: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');
252: cn_utils.indent(code, 1);
253: cn_utils.appindcr(code, l_notify_from);
254: cn_utils.unindent(code, 1);
255: cn_utils.appindcr(code, 'WHERE --*** Header.Primary_Key = Line.Foreign_Key');
256: cn_utils.indent(code, 1);
257: cn_utils.appindcr(code, l_notify_where);
258: --+

Line 255: cn_utils.appindcr(code, 'WHERE --*** Header.Primary_Key = Line.Foreign_Key');

251: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');
252: cn_utils.indent(code, 1);
253: cn_utils.appindcr(code, l_notify_from);
254: cn_utils.unindent(code, 1);
255: cn_utils.appindcr(code, 'WHERE --*** Header.Primary_Key = Line.Foreign_Key');
256: cn_utils.indent(code, 1);
257: cn_utils.appindcr(code, l_notify_where);
258: --+
259: -- The generated WHERE clause does not include the supplementary

Line 256: cn_utils.indent(code, 1);

252: cn_utils.indent(code, 1);
253: cn_utils.appindcr(code, l_notify_from);
254: cn_utils.unindent(code, 1);
255: cn_utils.appindcr(code, 'WHERE --*** Header.Primary_Key = Line.Foreign_Key');
256: cn_utils.indent(code, 1);
257: cn_utils.appindcr(code, l_notify_where);
258: --+
259: -- The generated WHERE clause does not include the supplementary
260: -- WHERE clause information that the user may specified, so this

Line 257: cn_utils.appindcr(code, l_notify_where);

253: cn_utils.appindcr(code, l_notify_from);
254: cn_utils.unindent(code, 1);
255: cn_utils.appindcr(code, 'WHERE --*** Header.Primary_Key = Line.Foreign_Key');
256: cn_utils.indent(code, 1);
257: cn_utils.appindcr(code, l_notify_where);
258: --+
259: -- The generated WHERE clause does not include the supplementary
260: -- WHERE clause information that the user may specified, so this
261: -- needs to be added on.

Line 265: cn_utils.appindcr(code, '--*** Any extra user-defined WHERE statement lines');

261: -- needs to be added on.
262: -- Before doing so, strip off trailing ';' on the clause, if one
263: -- is present
264: --+
265: cn_utils.appindcr(code, '--*** Any extra user-defined WHERE statement lines');
266: IF l_table_map_rec.notify_where IS NOT NULL THEN
267: cn_utils.appindcr(code, 'AND '||RTRIM(l_table_map_rec.notify_where,';'));
268: END IF;
269: cn_utils.appindcr(code, '--*** End of user-defined WHERE statement lines');

Line 267: cn_utils.appindcr(code, 'AND '||RTRIM(l_table_map_rec.notify_where,';'));

263: -- is present
264: --+
265: cn_utils.appindcr(code, '--*** Any extra user-defined WHERE statement lines');
266: IF l_table_map_rec.notify_where IS NOT NULL THEN
267: cn_utils.appindcr(code, 'AND '||RTRIM(l_table_map_rec.notify_where,';'));
268: END IF;
269: cn_utils.appindcr(code, '--*** End of user-defined WHERE statement lines');
270:
271: --+

Line 269: cn_utils.appindcr(code, '--*** End of user-defined WHERE statement lines');

265: cn_utils.appindcr(code, '--*** Any extra user-defined WHERE statement lines');
266: IF l_table_map_rec.notify_where IS NOT NULL THEN
267: cn_utils.appindcr(code, 'AND '||RTRIM(l_table_map_rec.notify_where,';'));
268: END IF;
269: cn_utils.appindcr(code, '--*** End of user-defined WHERE statement lines');
270:
271: --+
272: -- Finish off the statement
273: --+

Line 275: cn_utils.appindcr(code, ' AND NOT EXISTS (');

271: --+
272: -- Finish off the statement
273: --+
274:
275: cn_utils.appindcr(code, ' AND NOT EXISTS (');
276: IF CN_COLLECTION_GEN.isParallelEnabled THEN
277: cn_utils.appindcr(code, ' SELECT /'||'*'||'+ PARALLEL(cn_not_trx) '||'*/ 1');
278: ELSE
279: cn_utils.appindcr(code, ' SELECT 1');

Line 277: cn_utils.appindcr(code, ' SELECT /'||''||'+ PARALLEL(cn_not_trx) '||'/ 1');

273: --+
274:
275: cn_utils.appindcr(code, ' AND NOT EXISTS (');
276: IF CN_COLLECTION_GEN.isParallelEnabled THEN
277: cn_utils.appindcr(code, ' SELECT /'||'*'||'+ PARALLEL(cn_not_trx) '||'*/ 1');
278: ELSE
279: cn_utils.appindcr(code, ' SELECT 1');
280: END IF;
281: cn_utils.appindcr(code, ' FROM cn_not_trx');

Line 279: cn_utils.appindcr(code, ' SELECT 1');

275: cn_utils.appindcr(code, ' AND NOT EXISTS (');
276: IF CN_COLLECTION_GEN.isParallelEnabled THEN
277: cn_utils.appindcr(code, ' SELECT /'||'*'||'+ PARALLEL(cn_not_trx) '||'*/ 1');
278: ELSE
279: cn_utils.appindcr(code, ' SELECT 1');
280: END IF;
281: cn_utils.appindcr(code, ' FROM cn_not_trx');
282: cn_utils.appindcr(code, ' WHERE source_trx_line_id = ' || l_line_key ||' --*** Line.Primary_Key');
283: cn_utils.appindcr(code, ' AND event_id = ' || x_event_id );

Line 281: cn_utils.appindcr(code, ' FROM cn_not_trx');

277: cn_utils.appindcr(code, ' SELECT /'||'*'||'+ PARALLEL(cn_not_trx) '||'*/ 1');
278: ELSE
279: cn_utils.appindcr(code, ' SELECT 1');
280: END IF;
281: cn_utils.appindcr(code, ' FROM cn_not_trx');
282: cn_utils.appindcr(code, ' WHERE source_trx_line_id = ' || l_line_key ||' --*** Line.Primary_Key');
283: cn_utils.appindcr(code, ' AND event_id = ' || x_event_id );
284: cn_utils.appindcr(code, ' AND org_id = ' || l_org_id || ');');
285: cn_utils.unindent(code, 1);

Line 282: cn_utils.appindcr(code, ' WHERE source_trx_line_id = ' || l_line_key ||' --*** Line.Primary_Key');

278: ELSE
279: cn_utils.appindcr(code, ' SELECT 1');
280: END IF;
281: cn_utils.appindcr(code, ' FROM cn_not_trx');
282: cn_utils.appindcr(code, ' WHERE source_trx_line_id = ' || l_line_key ||' --*** Line.Primary_Key');
283: cn_utils.appindcr(code, ' AND event_id = ' || x_event_id );
284: cn_utils.appindcr(code, ' AND org_id = ' || l_org_id || ');');
285: cn_utils.unindent(code, 1);
286:

Line 283: cn_utils.appindcr(code, ' AND event_id = ' || x_event_id );

279: cn_utils.appindcr(code, ' SELECT 1');
280: END IF;
281: cn_utils.appindcr(code, ' FROM cn_not_trx');
282: cn_utils.appindcr(code, ' WHERE source_trx_line_id = ' || l_line_key ||' --*** Line.Primary_Key');
283: cn_utils.appindcr(code, ' AND event_id = ' || x_event_id );
284: cn_utils.appindcr(code, ' AND org_id = ' || l_org_id || ');');
285: cn_utils.unindent(code, 1);
286:
287: cn_utils.appindcr(code, 'END; -- Notification Insert Block');

Line 284: cn_utils.appindcr(code, ' AND org_id = ' || l_org_id || ');');

280: END IF;
281: cn_utils.appindcr(code, ' FROM cn_not_trx');
282: cn_utils.appindcr(code, ' WHERE source_trx_line_id = ' || l_line_key ||' --*** Line.Primary_Key');
283: cn_utils.appindcr(code, ' AND event_id = ' || x_event_id );
284: cn_utils.appindcr(code, ' AND org_id = ' || l_org_id || ');');
285: cn_utils.unindent(code, 1);
286:
287: cn_utils.appindcr(code, 'END; -- Notification Insert Block');
288:

Line 285: cn_utils.unindent(code, 1);

281: cn_utils.appindcr(code, ' FROM cn_not_trx');
282: cn_utils.appindcr(code, ' WHERE source_trx_line_id = ' || l_line_key ||' --*** Line.Primary_Key');
283: cn_utils.appindcr(code, ' AND event_id = ' || x_event_id );
284: cn_utils.appindcr(code, ' AND org_id = ' || l_org_id || ');');
285: cn_utils.unindent(code, 1);
286:
287: cn_utils.appindcr(code, 'END; -- Notification Insert Block');
288:
289: cn_utils.appendcr(code);

Line 287: cn_utils.appindcr(code, 'END; -- Notification Insert Block');

283: cn_utils.appindcr(code, ' AND event_id = ' || x_event_id );
284: cn_utils.appindcr(code, ' AND org_id = ' || l_org_id || ');');
285: cn_utils.unindent(code, 1);
286:
287: cn_utils.appindcr(code, 'END; -- Notification Insert Block');
288:
289: cn_utils.appendcr(code);
290: cn_utils.appindcr(code, '-- Commit the notification inserts - they are permanent even if collection fails');
291: cn_utils.appindcr(code, 'COMMIT;');

Line 289: cn_utils.appendcr(code);

285: cn_utils.unindent(code, 1);
286:
287: cn_utils.appindcr(code, 'END; -- Notification Insert Block');
288:
289: cn_utils.appendcr(code);
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:

Line 290: cn_utils.appindcr(code, '-- Commit the notification inserts - they are permanent even if collection fails');

286:
287: cn_utils.appindcr(code, 'END; -- Notification Insert Block');
288:
289: cn_utils.appendcr(code);
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 ');

Line 291: cn_utils.appindcr(code, 'COMMIT;');

287: cn_utils.appindcr(code, 'END; -- Notification Insert Block');
288:
289: cn_utils.appendcr(code);
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 ');

Line 292: cn_utils.unset_org_id();

288:
289: cn_utils.appendcr(code);
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:

Line 297: cn_utils.set_org_id(p_org_id => l_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);
299:
300: cn_utils.appendcr(code, '--******** COLLECT AJUSTMENTS (NEGATE IN API) ********-- ');
301: cn_utils.appindcr(code, '-- This will negate those adjusted trx in the API table');

Line 298: cn_utils.appendcr(code);

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);
299:
300: cn_utils.appendcr(code, '--******** COLLECT AJUSTMENTS (NEGATE IN API) ********-- ');
301: cn_utils.appindcr(code, '-- This will negate those adjusted trx in the API table');
302: cn_utils.appindcr(code, 'cn_not_trx_grp.col_adjustments(p_api_version => 1.0,');

Line 300: cn_utils.appendcr(code, '-- COLLECT AJUSTMENTS (NEGATE IN API) -- ');

296:
297: cn_utils.set_org_id(p_org_id => l_org_id);
298: cn_utils.appendcr(code);
299:
300: cn_utils.appendcr(code, '--******** COLLECT AJUSTMENTS (NEGATE IN API) ********-- ');
301: cn_utils.appindcr(code, '-- This will negate those adjusted trx in the API table');
302: cn_utils.appindcr(code, 'cn_not_trx_grp.col_adjustments(p_api_version => 1.0,');
303: cn_utils.appindcr(code, ' x_return_status => x_return_status,');
304: cn_utils.appindcr(code, ' x_msg_count => x_msg_count,');

Line 301: cn_utils.appindcr(code, '-- This will negate those adjusted trx in the API table');

297: cn_utils.set_org_id(p_org_id => l_org_id);
298: cn_utils.appendcr(code);
299:
300: cn_utils.appendcr(code, '--******** COLLECT AJUSTMENTS (NEGATE IN API) ********-- ');
301: cn_utils.appindcr(code, '-- This will negate those adjusted trx in the API table');
302: cn_utils.appindcr(code, 'cn_not_trx_grp.col_adjustments(p_api_version => 1.0,');
303: cn_utils.appindcr(code, ' x_return_status => x_return_status,');
304: cn_utils.appindcr(code, ' x_msg_count => x_msg_count,');
305: cn_utils.appindcr(code, ' x_msg_data => x_msg_data,');

Line 302: cn_utils.appindcr(code, 'cn_not_trx_grp.col_adjustments(p_api_version => 1.0,');

298: cn_utils.appendcr(code);
299:
300: cn_utils.appendcr(code, '--******** COLLECT AJUSTMENTS (NEGATE IN API) ********-- ');
301: cn_utils.appindcr(code, '-- This will negate those adjusted trx in the API table');
302: cn_utils.appindcr(code, 'cn_not_trx_grp.col_adjustments(p_api_version => 1.0,');
303: cn_utils.appindcr(code, ' x_return_status => x_return_status,');
304: cn_utils.appindcr(code, ' x_msg_count => x_msg_count,');
305: cn_utils.appindcr(code, ' x_msg_data => x_msg_data,');
306:

Line 303: cn_utils.appindcr(code, ' x_return_status => x_return_status,');

299:
300: cn_utils.appendcr(code, '--******** COLLECT AJUSTMENTS (NEGATE IN API) ********-- ');
301: cn_utils.appindcr(code, '-- This will negate those adjusted trx in the API table');
302: cn_utils.appindcr(code, 'cn_not_trx_grp.col_adjustments(p_api_version => 1.0,');
303: cn_utils.appindcr(code, ' x_return_status => x_return_status,');
304: cn_utils.appindcr(code, ' x_msg_count => x_msg_count,');
305: cn_utils.appindcr(code, ' x_msg_data => x_msg_data,');
306:
307: cn_utils.appindcr(code, ' p_org_id => '|| l_org_id ||');');

Line 304: cn_utils.appindcr(code, ' x_msg_count => x_msg_count,');

300: cn_utils.appendcr(code, '--******** COLLECT AJUSTMENTS (NEGATE IN API) ********-- ');
301: cn_utils.appindcr(code, '-- This will negate those adjusted trx in the API table');
302: cn_utils.appindcr(code, 'cn_not_trx_grp.col_adjustments(p_api_version => 1.0,');
303: cn_utils.appindcr(code, ' x_return_status => x_return_status,');
304: cn_utils.appindcr(code, ' x_msg_count => x_msg_count,');
305: cn_utils.appindcr(code, ' x_msg_data => x_msg_data,');
306:
307: cn_utils.appindcr(code, ' p_org_id => '|| l_org_id ||');');
308: -- Added For R12 MOAC Changes

Line 305: cn_utils.appindcr(code, ' x_msg_data => x_msg_data,');

301: cn_utils.appindcr(code, '-- This will negate those adjusted trx in the API table');
302: cn_utils.appindcr(code, 'cn_not_trx_grp.col_adjustments(p_api_version => 1.0,');
303: cn_utils.appindcr(code, ' x_return_status => x_return_status,');
304: cn_utils.appindcr(code, ' x_msg_count => x_msg_count,');
305: cn_utils.appindcr(code, ' x_msg_data => x_msg_data,');
306:
307: cn_utils.appindcr(code, ' p_org_id => '|| l_org_id ||');');
308: -- Added For R12 MOAC Changes
309: cn_utils.appendcr(code);

Line 307: cn_utils.appindcr(code, ' p_org_id => '|| l_org_id ||');');

303: cn_utils.appindcr(code, ' x_return_status => x_return_status,');
304: cn_utils.appindcr(code, ' x_msg_count => x_msg_count,');
305: cn_utils.appindcr(code, ' x_msg_data => x_msg_data,');
306:
307: cn_utils.appindcr(code, ' p_org_id => '|| l_org_id ||');');
308: -- Added For R12 MOAC Changes
309: cn_utils.appendcr(code);
310:
311: cn_utils.unset_org_id();

Line 309: cn_utils.appendcr(code);

305: cn_utils.appindcr(code, ' x_msg_data => x_msg_data,');
306:
307: cn_utils.appindcr(code, ' p_org_id => '|| l_org_id ||');');
308: -- Added For R12 MOAC Changes
309: cn_utils.appendcr(code);
310:
311: cn_utils.unset_org_id();
312: END insert_cn_not_trx;
313:

Line 311: cn_utils.unset_org_id();

307: cn_utils.appindcr(code, ' p_org_id => '|| l_org_id ||');');
308: -- Added For R12 MOAC Changes
309: cn_utils.appendcr(code);
310:
311: cn_utils.unset_org_id();
312: END insert_cn_not_trx;
313:
314: --
315: -- Procedure Name

Line 328: code IN OUT NOCOPY cn_utils.code_type,

324: --
325: --
326: PROCEDURE insert_comm_lines_api_select(
327: x_table_map_id IN cn_table_maps_v.table_map_id%TYPE,
328: code IN OUT NOCOPY cn_utils.code_type,
329: x_org_id IN NUMBER,
330: x_parallel_hint IN VARCHAR2)
331: IS -- Added For R12 MOAC Changes
332:

Line 348: cn_utils.set_org_id(p_org_id => x_org_id);

344: ORDER BY dest_column;
345:
346: BEGIN
347:
348: cn_utils.set_org_id(p_org_id => x_org_id);
349: IF CN_COLLECTION_GEN.isParallelEnabled THEN
350: IF x_table_map_id > 0
351: THEN
352: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_comm_lines_api) */ INTO cn_comm_lines_api (');

Line 352: cn_utils.appindcr(code, 'INSERT /'||'+ PARALLEL(cn_comm_lines_api) / INTO cn_comm_lines_api (');

348: cn_utils.set_org_id(p_org_id => x_org_id);
349: IF CN_COLLECTION_GEN.isParallelEnabled THEN
350: IF x_table_map_id > 0
351: THEN
352: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_comm_lines_api) */ INTO cn_comm_lines_api (');
353: ELSE
354: cn_utils.appindcr(code, 'INSERT INTO cn_comm_lines_api (');
355: END IF;
356: ELSE

Line 354: cn_utils.appindcr(code, 'INSERT INTO cn_comm_lines_api (');

350: IF x_table_map_id > 0
351: THEN
352: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_comm_lines_api) */ INTO cn_comm_lines_api (');
353: ELSE
354: cn_utils.appindcr(code, 'INSERT INTO cn_comm_lines_api (');
355: END IF;
356: ELSE
357: cn_utils.appindcr(code, 'INSERT INTO cn_comm_lines_api (');
358: END IF;

Line 357: cn_utils.appindcr(code, 'INSERT INTO cn_comm_lines_api (');

353: ELSE
354: cn_utils.appindcr(code, 'INSERT INTO cn_comm_lines_api (');
355: END IF;
356: ELSE
357: cn_utils.appindcr(code, 'INSERT INTO cn_comm_lines_api (');
358: END IF;
359: cn_utils.indent(code, 1);
360:
361: cn_utils.appindcr(code, 'comm_lines_api_id,');

Line 359: cn_utils.indent(code, 1);

355: END IF;
356: ELSE
357: cn_utils.appindcr(code, 'INSERT INTO cn_comm_lines_api (');
358: END IF;
359: cn_utils.indent(code, 1);
360:
361: cn_utils.appindcr(code, 'comm_lines_api_id,');
362: cn_utils.appindcr(code, 'conc_batch_id,');
363: cn_utils.appindcr(code, 'process_batch_id,');

Line 361: cn_utils.appindcr(code, 'comm_lines_api_id,');

357: cn_utils.appindcr(code, 'INSERT INTO cn_comm_lines_api (');
358: END IF;
359: cn_utils.indent(code, 1);
360:
361: cn_utils.appindcr(code, 'comm_lines_api_id,');
362: cn_utils.appindcr(code, 'conc_batch_id,');
363: cn_utils.appindcr(code, 'process_batch_id,');
364: cn_utils.appindcr(code, 'org_id,');
365:

Line 362: cn_utils.appindcr(code, 'conc_batch_id,');

358: END IF;
359: cn_utils.indent(code, 1);
360:
361: cn_utils.appindcr(code, 'comm_lines_api_id,');
362: cn_utils.appindcr(code, 'conc_batch_id,');
363: cn_utils.appindcr(code, 'process_batch_id,');
364: cn_utils.appindcr(code, 'org_id,');
365:
366: -- Insert custom columns using api_direct_maps cursor

Line 363: cn_utils.appindcr(code, 'process_batch_id,');

359: cn_utils.indent(code, 1);
360:
361: cn_utils.appindcr(code, 'comm_lines_api_id,');
362: cn_utils.appindcr(code, 'conc_batch_id,');
363: cn_utils.appindcr(code, 'process_batch_id,');
364: cn_utils.appindcr(code, 'org_id,');
365:
366: -- Insert custom columns using api_direct_maps cursor
367: cn_utils.appindcr(code, '--*** Direct Mapping Destination Columns');

Line 364: cn_utils.appindcr(code, 'org_id,');

360:
361: cn_utils.appindcr(code, 'comm_lines_api_id,');
362: cn_utils.appindcr(code, 'conc_batch_id,');
363: cn_utils.appindcr(code, 'process_batch_id,');
364: cn_utils.appindcr(code, 'org_id,');
365:
366: -- Insert custom columns using api_direct_maps cursor
367: cn_utils.appindcr(code, '--*** Direct Mapping Destination Columns');
368: FOR l IN api_direct_maps LOOP

Line 367: cn_utils.appindcr(code, '--*** Direct Mapping Destination Columns');

363: cn_utils.appindcr(code, 'process_batch_id,');
364: cn_utils.appindcr(code, 'org_id,');
365:
366: -- Insert custom columns using api_direct_maps cursor
367: cn_utils.appindcr(code, '--*** Direct Mapping Destination Columns');
368: FOR l IN api_direct_maps LOOP
369: cn_utils.appindcr(code, l.dest_column || ',');
370: END LOOP;
371:

Line 369: cn_utils.appindcr(code, l.dest_column || ',');

365:
366: -- Insert custom columns using api_direct_maps cursor
367: cn_utils.appindcr(code, '--*** Direct Mapping Destination Columns');
368: FOR l IN api_direct_maps LOOP
369: cn_utils.appindcr(code, l.dest_column || ',');
370: END LOOP;
371:
372: --Changing the number of places to shift to 2 cos of introduction of new char
373: cn_utils.strip_prev(code, 1); -- remove trailing comma

Line 373: cn_utils.strip_prev(code, 1); -- remove trailing comma

369: cn_utils.appindcr(code, l.dest_column || ',');
370: END LOOP;
371:
372: --Changing the number of places to shift to 2 cos of introduction of new char
373: cn_utils.strip_prev(code, 1); -- remove trailing comma
374: cn_utils.appindcr(code, ')');
375: cn_utils.unindent(code, 1);
376:
377:

Line 374: cn_utils.appindcr(code, ')');

370: END LOOP;
371:
372: --Changing the number of places to shift to 2 cos of introduction of new char
373: cn_utils.strip_prev(code, 1); -- remove trailing comma
374: cn_utils.appindcr(code, ')');
375: cn_utils.unindent(code, 1);
376:
377:
378: -- Generate the SELECT clause for the insert statement

Line 375: cn_utils.unindent(code, 1);

371:
372: --Changing the number of places to shift to 2 cos of introduction of new char
373: cn_utils.strip_prev(code, 1); -- remove trailing comma
374: cn_utils.appindcr(code, ')');
375: cn_utils.unindent(code, 1);
376:
377:
378: -- Generate the SELECT clause for the insert statement
379: IF CN_COLLECTION_GEN.isParallelEnabled THEN

Line 380: cn_utils.appindcr(code, 'SELECT '||x_parallel_hint);

376:
377:
378: -- Generate the SELECT clause for the insert statement
379: IF CN_COLLECTION_GEN.isParallelEnabled THEN
380: cn_utils.appindcr(code, 'SELECT '||x_parallel_hint);
381: ELSE
382: cn_utils.appindcr(code, 'SELECT ');
383: END IF;
384:

Line 382: cn_utils.appindcr(code, 'SELECT ');

378: -- Generate the SELECT clause for the insert statement
379: IF CN_COLLECTION_GEN.isParallelEnabled THEN
380: cn_utils.appindcr(code, 'SELECT '||x_parallel_hint);
381: ELSE
382: cn_utils.appindcr(code, 'SELECT ');
383: END IF;
384:
385: cn_utils.indent(code, 1);
386:

Line 385: cn_utils.indent(code, 1);

381: ELSE
382: cn_utils.appindcr(code, 'SELECT ');
383: END IF;
384:
385: cn_utils.indent(code, 1);
386:
387: cn_utils.appindcr(code, 'cn_comm_lines_api_s.NEXTVAL,');
388: cn_utils.appindcr(code, 'x_conc_program_id,');
389: cn_utils.appindcr(code, 'x_proc_audit_id,');

Line 387: cn_utils.appindcr(code, 'cn_comm_lines_api_s.NEXTVAL,');

383: END IF;
384:
385: cn_utils.indent(code, 1);
386:
387: cn_utils.appindcr(code, 'cn_comm_lines_api_s.NEXTVAL,');
388: cn_utils.appindcr(code, 'x_conc_program_id,');
389: cn_utils.appindcr(code, 'x_proc_audit_id,');
390: cn_utils.appindcr(code, x_org_id||',');
391:

Line 388: cn_utils.appindcr(code, 'x_conc_program_id,');

384:
385: cn_utils.indent(code, 1);
386:
387: cn_utils.appindcr(code, 'cn_comm_lines_api_s.NEXTVAL,');
388: cn_utils.appindcr(code, 'x_conc_program_id,');
389: cn_utils.appindcr(code, 'x_proc_audit_id,');
390: cn_utils.appindcr(code, x_org_id||',');
391:
392: -- Select other columns using the api_direct_maps cursors. Note that

Line 389: cn_utils.appindcr(code, 'x_proc_audit_id,');

385: cn_utils.indent(code, 1);
386:
387: cn_utils.appindcr(code, 'cn_comm_lines_api_s.NEXTVAL,');
388: cn_utils.appindcr(code, 'x_conc_program_id,');
389: cn_utils.appindcr(code, 'x_proc_audit_id,');
390: cn_utils.appindcr(code, x_org_id||',');
391:
392: -- Select other columns using the api_direct_maps cursors. Note that
393: -- we fetch the records in the cursor in the same order as before due to

Line 390: cn_utils.appindcr(code, x_org_id||',');

386:
387: cn_utils.appindcr(code, 'cn_comm_lines_api_s.NEXTVAL,');
388: cn_utils.appindcr(code, 'x_conc_program_id,');
389: cn_utils.appindcr(code, 'x_proc_audit_id,');
390: cn_utils.appindcr(code, x_org_id||',');
391:
392: -- Select other columns using the api_direct_maps cursors. Note that
393: -- we fetch the records in the cursor in the same order as before due to
394: -- the order by column_id in the cursor where clause.

Line 396: cn_utils.appindcr(code, '--*** Direct Mapping Source Expressions');

392: -- Select other columns using the api_direct_maps cursors. Note that
393: -- we fetch the records in the cursor in the same order as before due to
394: -- the order by column_id in the cursor where clause.
395:
396: cn_utils.appindcr(code, '--*** Direct Mapping Source Expressions');
397:
398: FOR l IN api_direct_maps LOOP
399: -- R12 Related Changes
400: IF (l.column_map_id = -1083) THEN

Line 406: cn_utils.appindcr(code, l.expression || ',');

402: END IF;
403: IF (l.column_map_id = -1092 OR l.column_map_id = -1093) THEN
404: l.expression := RTRIM(l.expression,')},')||','||x_org_id||')';
405: END IF;
406: cn_utils.appindcr(code, l.expression || ',');
407: END LOOP;
408:
409: cn_utils.strip_prev(code, 1); -- remove trailing comma
410: cn_utils.appendcr(code);

Line 409: cn_utils.strip_prev(code, 1); -- remove trailing comma

405: END IF;
406: cn_utils.appindcr(code, l.expression || ',');
407: END LOOP;
408:
409: cn_utils.strip_prev(code, 1); -- remove trailing comma
410: cn_utils.appendcr(code);
411: cn_utils.unindent(code, 1);
412: cn_utils.unset_org_id();
413:

Line 410: cn_utils.appendcr(code);

406: cn_utils.appindcr(code, l.expression || ',');
407: END LOOP;
408:
409: cn_utils.strip_prev(code, 1); -- remove trailing comma
410: cn_utils.appendcr(code);
411: cn_utils.unindent(code, 1);
412: cn_utils.unset_org_id();
413:
414: END insert_comm_lines_api_select;

Line 411: cn_utils.unindent(code, 1);

407: END LOOP;
408:
409: cn_utils.strip_prev(code, 1); -- remove trailing comma
410: cn_utils.appendcr(code);
411: cn_utils.unindent(code, 1);
412: cn_utils.unset_org_id();
413:
414: END insert_comm_lines_api_select;
415:

Line 412: cn_utils.unset_org_id();

408:
409: cn_utils.strip_prev(code, 1); -- remove trailing comma
410: cn_utils.appendcr(code);
411: cn_utils.unindent(code, 1);
412: cn_utils.unset_org_id();
413:
414: END insert_comm_lines_api_select;
415:
416: --

Line 429: code IN OUT NOCOPY cn_utils.code_type,

425: --
426: PROCEDURE insert_comm_lines_api (
427: x_table_map_id cn_table_maps.table_map_id%TYPE,
428: x_event_id cn_events.event_id%TYPE,
429: code IN OUT NOCOPY cn_utils.code_type,
430: x_org_id IN NUMBER)
431: IS
432:
433: l_return_status VARCHAR2(4000);

Line 486: cn_utils.set_org_id(p_org_id => X_org_id);

482: END IF;
483: --+
484: -- Generate the Collection Process code
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.'');');

Line 487: cn_utils.appendcr(code);

483: --+
484: -- Generate the Collection Process code
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);

Line 488: cn_utils.appendcr(code, '-- INSERT CN_COMM_LINES_API *-- ');

484: -- Generate the Collection Process code
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: --+

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 490: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''Inserting into CN_COMM_LINES_API.'');');

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
494: -- the statement

Line 491: cn_utils.appendcr(code);

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
494: -- the statement
495: --+

Line 496: cn_utils.appindcr(code, '--');

492: --+
493: -- Generate the INSERT INTO API .. SELECT portion of
494: -- the statement
495: --+
496: cn_utils.appindcr(code, '--');
497: cn_utils.appindcr(code, '-- Insert new lines into CN_COMM_LINES_API');
498: cn_utils.appindcr(code, '--');
499:
500: cn_utils.unset_org_id();

Line 497: cn_utils.appindcr(code, '-- Insert new lines into CN_COMM_LINES_API');

493: -- Generate the INSERT INTO API .. SELECT portion of
494: -- the statement
495: --+
496: cn_utils.appindcr(code, '--');
497: cn_utils.appindcr(code, '-- Insert new lines into CN_COMM_LINES_API');
498: cn_utils.appindcr(code, '--');
499:
500: cn_utils.unset_org_id();
501: -- Change for Bug 6203234

Line 498: cn_utils.appindcr(code, '--');

494: -- the statement
495: --+
496: cn_utils.appindcr(code, '--');
497: cn_utils.appindcr(code, '-- Insert new lines into CN_COMM_LINES_API');
498: cn_utils.appindcr(code, '--');
499:
500: cn_utils.unset_org_id();
501: -- Change for Bug 6203234
502: insert_comm_lines_api_select(x_table_map_id, code, X_org_id, l_parallel_hint);

Line 500: cn_utils.unset_org_id();

496: cn_utils.appindcr(code, '--');
497: cn_utils.appindcr(code, '-- Insert new lines into CN_COMM_LINES_API');
498: cn_utils.appindcr(code, '--');
499:
500: cn_utils.unset_org_id();
501: -- Change for Bug 6203234
502: insert_comm_lines_api_select(x_table_map_id, code, X_org_id, l_parallel_hint);
503: cn_utils.set_org_id(p_org_id => l_org_id);
504:

Line 503: cn_utils.set_org_id(p_org_id => l_org_id);

499:
500: cn_utils.unset_org_id();
501: -- Change for Bug 6203234
502: insert_comm_lines_api_select(x_table_map_id, code, X_org_id, l_parallel_hint);
503: cn_utils.set_org_id(p_org_id => l_org_id);
504:
505: cn_utils.appindcr(code, 'FROM --*** Line, (optional) Header, and any Extra Collection Tables');
506: cn_utils.indent(code, 1);
507: cn_utils.appindcr(code, l_collect_from);

Line 505: cn_utils.appindcr(code, 'FROM --*** Line, (optional) Header, and any Extra Collection Tables');

501: -- Change for Bug 6203234
502: insert_comm_lines_api_select(x_table_map_id, code, X_org_id, l_parallel_hint);
503: cn_utils.set_org_id(p_org_id => l_org_id);
504:
505: cn_utils.appindcr(code, 'FROM --*** Line, (optional) Header, and any Extra Collection Tables');
506: cn_utils.indent(code, 1);
507: cn_utils.appindcr(code, l_collect_from);
508: cn_utils.unindent(code, 1);
509: cn_utils.appindcr(code, 'WHERE');

Line 506: cn_utils.indent(code, 1);

502: insert_comm_lines_api_select(x_table_map_id, code, X_org_id, l_parallel_hint);
503: cn_utils.set_org_id(p_org_id => l_org_id);
504:
505: cn_utils.appindcr(code, 'FROM --*** Line, (optional) Header, and any Extra Collection Tables');
506: cn_utils.indent(code, 1);
507: cn_utils.appindcr(code, l_collect_from);
508: cn_utils.unindent(code, 1);
509: cn_utils.appindcr(code, 'WHERE');
510: cn_utils.appindcr(code, '--*** Line.Primary_Key = cnt.source_trx_line_id AND (optional) Header.Primary_Key = cnt.source_trx_id');

Line 507: cn_utils.appindcr(code, l_collect_from);

503: cn_utils.set_org_id(p_org_id => l_org_id);
504:
505: cn_utils.appindcr(code, 'FROM --*** Line, (optional) Header, and any Extra Collection Tables');
506: cn_utils.indent(code, 1);
507: cn_utils.appindcr(code, l_collect_from);
508: cn_utils.unindent(code, 1);
509: cn_utils.appindcr(code, 'WHERE');
510: cn_utils.appindcr(code, '--*** Line.Primary_Key = cnt.source_trx_line_id AND (optional) Header.Primary_Key = cnt.source_trx_id');
511: cn_utils.indent(code, 1);

Line 508: cn_utils.unindent(code, 1);

504:
505: cn_utils.appindcr(code, 'FROM --*** Line, (optional) Header, and any Extra Collection Tables');
506: cn_utils.indent(code, 1);
507: cn_utils.appindcr(code, l_collect_from);
508: cn_utils.unindent(code, 1);
509: cn_utils.appindcr(code, 'WHERE');
510: cn_utils.appindcr(code, '--*** Line.Primary_Key = cnt.source_trx_line_id AND (optional) Header.Primary_Key = cnt.source_trx_id');
511: cn_utils.indent(code, 1);
512: cn_utils.appindcr(code, l_collect_where);

Line 509: cn_utils.appindcr(code, 'WHERE');

505: cn_utils.appindcr(code, 'FROM --*** Line, (optional) Header, and any Extra Collection Tables');
506: cn_utils.indent(code, 1);
507: cn_utils.appindcr(code, l_collect_from);
508: cn_utils.unindent(code, 1);
509: cn_utils.appindcr(code, 'WHERE');
510: cn_utils.appindcr(code, '--*** Line.Primary_Key = cnt.source_trx_line_id AND (optional) Header.Primary_Key = cnt.source_trx_id');
511: cn_utils.indent(code, 1);
512: cn_utils.appindcr(code, l_collect_where);
513:

Line 510: cn_utils.appindcr(code, '--*** Line.Primary_Key = cnt.source_trx_line_id AND (optional) Header.Primary_Key = cnt.source_trx_id');

506: cn_utils.indent(code, 1);
507: cn_utils.appindcr(code, l_collect_from);
508: cn_utils.unindent(code, 1);
509: cn_utils.appindcr(code, 'WHERE');
510: cn_utils.appindcr(code, '--*** Line.Primary_Key = cnt.source_trx_line_id AND (optional) Header.Primary_Key = cnt.source_trx_id');
511: cn_utils.indent(code, 1);
512: cn_utils.appindcr(code, l_collect_where);
513:
514: --+

Line 511: cn_utils.indent(code, 1);

507: cn_utils.appindcr(code, l_collect_from);
508: cn_utils.unindent(code, 1);
509: cn_utils.appindcr(code, 'WHERE');
510: cn_utils.appindcr(code, '--*** Line.Primary_Key = cnt.source_trx_line_id AND (optional) Header.Primary_Key = cnt.source_trx_id');
511: cn_utils.indent(code, 1);
512: cn_utils.appindcr(code, l_collect_where);
513:
514: --+
515: -- The generated WHERE clause does not include the supplementary

Line 512: cn_utils.appindcr(code, l_collect_where);

508: cn_utils.unindent(code, 1);
509: cn_utils.appindcr(code, 'WHERE');
510: cn_utils.appindcr(code, '--*** Line.Primary_Key = cnt.source_trx_line_id AND (optional) Header.Primary_Key = cnt.source_trx_id');
511: cn_utils.indent(code, 1);
512: cn_utils.appindcr(code, l_collect_where);
513:
514: --+
515: -- The generated WHERE clause does not include the supplementary
516: -- WHERE clause information that the user may specified, so this

Line 522: cn_utils.appindcr(code, '--*** Any extra user-defined WHERE statement lines');

518: -- Before doing so, strip off trailing ';' on the clause, if one
519: -- is present
520: --+
521:
522: cn_utils.appindcr(code, '--*** Any extra user-defined WHERE statement lines');
523:
524: IF l_table_map_rec.collect_where IS NOT NULL THEN
525: cn_utils.appindcr(code, 'AND '||RTRIM(l_table_map_rec.collect_where,';'));
526: END IF;

Line 525: cn_utils.appindcr(code, 'AND '||RTRIM(l_table_map_rec.collect_where,';'));

521:
522: cn_utils.appindcr(code, '--*** Any extra user-defined WHERE statement lines');
523:
524: IF l_table_map_rec.collect_where IS NOT NULL THEN
525: cn_utils.appindcr(code, 'AND '||RTRIM(l_table_map_rec.collect_where,';'));
526: END IF;
527:
528: cn_utils.appindcr(code, '--*** End of user-defined WHERE statement lines');
529:

Line 528: cn_utils.appindcr(code, '--*** End of user-defined WHERE statement lines');

524: IF l_table_map_rec.collect_where IS NOT NULL THEN
525: cn_utils.appindcr(code, 'AND '||RTRIM(l_table_map_rec.collect_where,';'));
526: END IF;
527:
528: cn_utils.appindcr(code, '--*** End of user-defined WHERE statement lines');
529:
530: --+
531: -- Finish off the statement
532: --+

Line 534: cn_utils.appindcr(code, ' AND cnt.event_id = ' || x_event_id);

530: --+
531: -- Finish off the statement
532: --+
533:
534: cn_utils.appindcr(code, ' AND cnt.event_id = ' || x_event_id);
535: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
536: cn_utils.appindcr(code, ' AND cnt.batch_id = x_proc_audit_id');
537: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id ||' ;');
538: cn_utils.unindent(code, 1);

Line 535: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');

531: -- Finish off the statement
532: --+
533:
534: cn_utils.appindcr(code, ' AND cnt.event_id = ' || x_event_id);
535: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
536: cn_utils.appindcr(code, ' AND cnt.batch_id = x_proc_audit_id');
537: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id ||' ;');
538: cn_utils.unindent(code, 1);
539:

Line 536: cn_utils.appindcr(code, ' AND cnt.batch_id = x_proc_audit_id');

532: --+
533:
534: cn_utils.appindcr(code, ' AND cnt.event_id = ' || x_event_id);
535: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
536: cn_utils.appindcr(code, ' AND cnt.batch_id = x_proc_audit_id');
537: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id ||' ;');
538: cn_utils.unindent(code, 1);
539:
540: cn_utils.appendcr(code);

Line 537: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id ||' ;');

533:
534: cn_utils.appindcr(code, ' AND cnt.event_id = ' || x_event_id);
535: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
536: cn_utils.appindcr(code, ' AND cnt.batch_id = x_proc_audit_id');
537: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id ||' ;');
538: cn_utils.unindent(code, 1);
539:
540: cn_utils.appendcr(code);
541: cn_utils.appindcr(code, 'comm_lines_api_count := SQL%ROWCOUNT;');

Line 538: cn_utils.unindent(code, 1);

534: cn_utils.appindcr(code, ' AND cnt.event_id = ' || x_event_id);
535: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
536: cn_utils.appindcr(code, ' AND cnt.batch_id = x_proc_audit_id');
537: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id ||' ;');
538: cn_utils.unindent(code, 1);
539:
540: cn_utils.appendcr(code);
541: cn_utils.appindcr(code, 'comm_lines_api_count := SQL%ROWCOUNT;');
542: cn_utils.appendcr(code);

Line 540: cn_utils.appendcr(code);

536: cn_utils.appindcr(code, ' AND cnt.batch_id = x_proc_audit_id');
537: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id ||' ;');
538: cn_utils.unindent(code, 1);
539:
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.'');');

Line 541: cn_utils.appindcr(code, 'comm_lines_api_count := SQL%ROWCOUNT;');

537: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id ||' ;');
538: cn_utils.unindent(code, 1);
539:
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.'');');

Line 542: cn_utils.appendcr(code);

538: cn_utils.unindent(code, 1);
539:
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:

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 545: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');

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);
549:

Line 547: 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);
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 .'');');

Line 548: cn_utils.appendcr(code);

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);
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 .'');');

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 552: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Updating collected_flag in CN_NOT_TRX .'');');

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:
556: IF CN_COLLECTION_GEN.isParallelEnabled THEN

Line 554: cn_utils.appendcr(code);

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:
556: IF CN_COLLECTION_GEN.isParallelEnabled THEN
557: cn_utils.appindcr(code, 'UPDATE /'||'*+ PARALLEL(cnt) */ cn_not_trx cnt');
558: ELSE

Line 557: cn_utils.appindcr(code, 'UPDATE /'||'+ PARALLEL(cnt) / cn_not_trx cnt');

553:
554: cn_utils.appendcr(code);
555:
556: IF CN_COLLECTION_GEN.isParallelEnabled THEN
557: cn_utils.appindcr(code, 'UPDATE /'||'*+ PARALLEL(cnt) */ cn_not_trx cnt');
558: ELSE
559: cn_utils.appindcr(code, 'UPDATE cn_not_trx cnt');
560: END IF;
561:

Line 559: cn_utils.appindcr(code, 'UPDATE cn_not_trx cnt');

555:
556: IF CN_COLLECTION_GEN.isParallelEnabled THEN
557: cn_utils.appindcr(code, 'UPDATE /'||'*+ PARALLEL(cnt) */ cn_not_trx cnt');
558: ELSE
559: cn_utils.appindcr(code, 'UPDATE cn_not_trx cnt');
560: END IF;
561:
562: cn_utils.appindcr(code, ' SET collected_flag = ''Y''');
563: cn_utils.appindcr(code, ' WHERE cnt.event_id = '|| x_event_id);

Line 562: cn_utils.appindcr(code, ' SET collected_flag = ''Y''');

558: ELSE
559: cn_utils.appindcr(code, 'UPDATE cn_not_trx cnt');
560: END IF;
561:
562: cn_utils.appindcr(code, ' SET collected_flag = ''Y''');
563: cn_utils.appindcr(code, ' WHERE cnt.event_id = '|| x_event_id);
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||' ;');

Line 563: cn_utils.appindcr(code, ' WHERE cnt.event_id = '|| x_event_id);

559: cn_utils.appindcr(code, 'UPDATE cn_not_trx cnt');
560: END IF;
561:
562: cn_utils.appindcr(code, ' SET collected_flag = ''Y''');
563: cn_utils.appindcr(code, ' WHERE cnt.event_id = '|| x_event_id);
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);

Line 564: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');

560: END IF;
561:
562: cn_utils.appindcr(code, ' SET collected_flag = ''Y''');
563: cn_utils.appindcr(code, ' WHERE cnt.event_id = '|| x_event_id);
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.'');');

Line 565: cn_utils.appindcr(code, ' AND cnt.batch_id = x_proc_audit_id');

561:
562: cn_utils.appindcr(code, ' SET collected_flag = ''Y''');
563: cn_utils.appindcr(code, ' WHERE cnt.event_id = '|| x_event_id);
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:

Line 566: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id||' ;');

562: cn_utils.appindcr(code, ' SET collected_flag = ''Y''');
563: cn_utils.appindcr(code, ' WHERE cnt.event_id = '|| x_event_id);
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

Line 567: cn_utils.appendcr(code);

563: cn_utils.appindcr(code, ' WHERE cnt.event_id = '|| x_event_id);
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;');

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 571: cn_utils.appindcr(code, 'COMMIT;');

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;
573:
574: cn_utils.appendcr(code);
575: cn_utils.unset_org_id();

Line 574: cn_utils.appendcr(code);

570: IF CN_COLLECTION_GEN.isParallelEnabled THEN
571: cn_utils.appindcr(code, 'COMMIT;');
572: END IF;
573:
574: cn_utils.appendcr(code);
575: cn_utils.unset_org_id();
576:
577: EXCEPTION
578: WHEN NO_DATA_FOUND THEN

Line 575: cn_utils.unset_org_id();

571: cn_utils.appindcr(code, 'COMMIT;');
572: END IF;
573:
574: cn_utils.appendcr(code);
575: cn_utils.unset_org_id();
576:
577: EXCEPTION
578: WHEN NO_DATA_FOUND THEN
579: cn_debug.print_msg('insert_lines: in exception handler for NO_DATA_FOUND',1);

Line 597: code IN OUT NOCOPY cn_utils.code_type,

593: -- 16-Mar-00 Dave Maskell Created
594: --
595: PROCEDURE update_comm_lines_api (
596: x_table_map_id cn_table_maps.table_map_id%TYPE,
597: code IN OUT NOCOPY cn_utils.code_type,
598: x_org_id IN NUMBER)
599: IS
600:
601: x_dest_table_name cn_obj_tables_v.name%TYPE;

Line 637: cn_utils.set_org_id(x_org_id);

633: ORDER BY destcol.name;
634:
635: BEGIN
636: -- MO_GLOBAL.INIT('CN');
637: cn_utils.set_org_id(x_org_id);
638: cn_utils.appendcr(code);
639: cn_utils.appendcr(code, '--******** UPDATE CN_COMM_LINES_API ********-- ');
640: cn_utils.appindcr(code, '--*** Update columns populated by all INDIRECT mappings');
641: --+

Line 638: cn_utils.appendcr(code);

634:
635: BEGIN
636: -- MO_GLOBAL.INIT('CN');
637: cn_utils.set_org_id(x_org_id);
638: cn_utils.appendcr(code);
639: cn_utils.appendcr(code, '--******** UPDATE CN_COMM_LINES_API ********-- ');
640: cn_utils.appindcr(code, '--*** Update columns populated by all INDIRECT mappings');
641: --+
642: -- Get name and alias of destination table (should be 'cn_comm_lines_api' and 'api')

Line 639: cn_utils.appendcr(code, '-- UPDATE CN_COMM_LINES_API -- ');

635: BEGIN
636: -- MO_GLOBAL.INIT('CN');
637: cn_utils.set_org_id(x_org_id);
638: cn_utils.appendcr(code);
639: cn_utils.appendcr(code, '--******** UPDATE CN_COMM_LINES_API ********-- ');
640: cn_utils.appindcr(code, '--*** Update columns populated by all INDIRECT mappings');
641: --+
642: -- Get name and alias of destination table (should be 'cn_comm_lines_api' and 'api')
643: --+

Line 640: cn_utils.appindcr(code, '--*** Update columns populated by all INDIRECT mappings');

636: -- MO_GLOBAL.INIT('CN');
637: cn_utils.set_org_id(x_org_id);
638: cn_utils.appendcr(code);
639: cn_utils.appendcr(code, '--******** UPDATE CN_COMM_LINES_API ********-- ');
640: cn_utils.appindcr(code, '--*** Update columns populated by all INDIRECT mappings');
641: --+
642: -- Get name and alias of destination table (should be 'cn_comm_lines_api' and 'api')
643: --+
644:

Line 688: cn_utils.appindcr(code, 'UPDATE ' || x_dest_table_name || ' ' || x_dest_alias);

684: IF x_row_count >0 THEN
685: --+
686: -- There are some mappings so generate the statement.
687: --+
688: cn_utils.appindcr(code, 'UPDATE ' || x_dest_table_name || ' ' || x_dest_alias);
689: cn_utils.appindcr(code, ' SET');
690: cn_utils.indent(code, 1);
691:
692: FOR indmap_rec IN indmap LOOP

Line 689: cn_utils.appindcr(code, ' SET');

685: --+
686: -- There are some mappings so generate the statement.
687: --+
688: cn_utils.appindcr(code, 'UPDATE ' || x_dest_table_name || ' ' || x_dest_alias);
689: cn_utils.appindcr(code, ' SET');
690: cn_utils.indent(code, 1);
691:
692: FOR indmap_rec IN indmap LOOP
693: cn_utils.appindcr(code, indmap_rec.dest_column || ' = ( --*** Indirect Mapping Destination Column');

Line 690: cn_utils.indent(code, 1);

686: -- There are some mappings so generate the statement.
687: --+
688: cn_utils.appindcr(code, 'UPDATE ' || x_dest_table_name || ' ' || x_dest_alias);
689: cn_utils.appindcr(code, ' SET');
690: cn_utils.indent(code, 1);
691:
692: FOR indmap_rec IN indmap LOOP
693: cn_utils.appindcr(code, indmap_rec.dest_column || ' = ( --*** Indirect Mapping Destination Column');
694: cn_utils.appindcr(code, ' SELECT ');

Line 693: cn_utils.appindcr(code, indmap_rec.dest_column || ' = ( --*** Indirect Mapping Destination Column');

689: cn_utils.appindcr(code, ' SET');
690: cn_utils.indent(code, 1);
691:
692: FOR indmap_rec IN indmap LOOP
693: cn_utils.appindcr(code, indmap_rec.dest_column || ' = ( --*** Indirect Mapping Destination Column');
694: cn_utils.appindcr(code, ' SELECT ');
695: cn_utils.appindcr(code, ' ' || indmap_rec.expression ||' --*** Indirect Mapping Source Expression');
696: IF indmap_rec.external_table_alias IS NOT NULL THEN
697: --+

Line 694: cn_utils.appindcr(code, ' SELECT ');

690: cn_utils.indent(code, 1);
691:
692: FOR indmap_rec IN indmap LOOP
693: cn_utils.appindcr(code, indmap_rec.dest_column || ' = ( --*** Indirect Mapping Destination Column');
694: cn_utils.appindcr(code, ' SELECT ');
695: cn_utils.appindcr(code, ' ' || indmap_rec.expression ||' --*** Indirect Mapping Source Expression');
696: IF indmap_rec.external_table_alias IS NOT NULL THEN
697: --+
698: -- This mapping is based on a defined foreign key relationship

Line 695: cn_utils.appindcr(code, ' ' || indmap_rec.expression ||' --*** Indirect Mapping Source Expression');

691:
692: FOR indmap_rec IN indmap LOOP
693: cn_utils.appindcr(code, indmap_rec.dest_column || ' = ( --*** Indirect Mapping Destination Column');
694: cn_utils.appindcr(code, ' SELECT ');
695: cn_utils.appindcr(code, ' ' || indmap_rec.expression ||' --*** Indirect Mapping Source Expression');
696: IF indmap_rec.external_table_alias IS NOT NULL THEN
697: --+
698: -- This mapping is based on a defined foreign key relationship
699: --+

Line 700: cn_utils.appindcr(code, ' --*** FROM/WHERE derived from Relationship: '||indmap_rec.relationship_name);

696: IF indmap_rec.external_table_alias IS NOT NULL THEN
697: --+
698: -- This mapping is based on a defined foreign key relationship
699: --+
700: cn_utils.appindcr(code, ' --*** FROM/WHERE derived from Relationship: '||indmap_rec.relationship_name);
701: cn_utils.appindcr(code, ' FROM '||indmap_rec.external_table_name||' '||indmap_rec.external_table_alias);
702: cn_utils.appindcr(code, ' WHERE');
703: x_count := 0;
704: --+

Line 701: cn_utils.appindcr(code, ' FROM '||indmap_rec.external_table_name||' '||indmap_rec.external_table_alias);

697: --+
698: -- This mapping is based on a defined foreign key relationship
699: --+
700: cn_utils.appindcr(code, ' --*** FROM/WHERE derived from Relationship: '||indmap_rec.relationship_name);
701: cn_utils.appindcr(code, ' FROM '||indmap_rec.external_table_name||' '||indmap_rec.external_table_alias);
702: cn_utils.appindcr(code, ' WHERE');
703: x_count := 0;
704: --+
705: -- Build where clause based on all join columns in the relationship

Line 702: cn_utils.appindcr(code, ' WHERE');

698: -- This mapping is based on a defined foreign key relationship
699: --+
700: cn_utils.appindcr(code, ' --*** FROM/WHERE derived from Relationship: '||indmap_rec.relationship_name);
701: cn_utils.appindcr(code, ' FROM '||indmap_rec.external_table_name||' '||indmap_rec.external_table_alias);
702: cn_utils.appindcr(code, ' WHERE');
703: x_count := 0;
704: --+
705: -- Build where clause based on all join columns in the relationship
706: --+

Line 723: cn_utils.appindcr(code, ' AND ');

719: LOOP
720: IF x_count = 0 THEN
721: x_count := 1;
722: ELSE
723: cn_utils.appindcr(code, ' AND ');
724: END IF;
725: cn_utils.appindcr(code, ' '||indmap_rec.external_table_alias||'.'||indmap_fk.pkcolumn_name||' = api.'||indmap_fk.fkcolumn_name);
726: END LOOP;
727: --Added by Ashley for MOAC

Line 725: cn_utils.appindcr(code, ' '||indmap_rec.external_table_alias||'.'||indmap_fk.pkcolumn_name||' = api.'||indmap_fk.fkcolumn_name);

721: x_count := 1;
722: ELSE
723: cn_utils.appindcr(code, ' AND ');
724: END IF;
725: cn_utils.appindcr(code, ' '||indmap_rec.external_table_alias||'.'||indmap_fk.pkcolumn_name||' = api.'||indmap_fk.fkcolumn_name);
726: END LOOP;
727: --Added by Ashley for MOAC
728: cn_utils.appindcr(code, ' AND api.org_id = '||x_org_id);
729: cn_utils.appindcr(code, '),');

Line 728: cn_utils.appindcr(code, ' AND api.org_id = '||x_org_id);

724: END IF;
725: cn_utils.appindcr(code, ' '||indmap_rec.external_table_alias||'.'||indmap_fk.pkcolumn_name||' = api.'||indmap_fk.fkcolumn_name);
726: END LOOP;
727: --Added by Ashley for MOAC
728: cn_utils.appindcr(code, ' AND api.org_id = '||x_org_id);
729: cn_utils.appindcr(code, '),');
730: ELSE
731: --+
732: -- This mapping is based on a free-form update clause

Line 729: cn_utils.appindcr(code, '),');

725: cn_utils.appindcr(code, ' '||indmap_rec.external_table_alias||'.'||indmap_fk.pkcolumn_name||' = api.'||indmap_fk.fkcolumn_name);
726: END LOOP;
727: --Added by Ashley for MOAC
728: cn_utils.appindcr(code, ' AND api.org_id = '||x_org_id);
729: cn_utils.appindcr(code, '),');
730: ELSE
731: --+
732: -- This mapping is based on a free-form update clause
733: --+

Line 734: cn_utils.appindcr(code, ' --*** FROM/WHERE taken from Update Clause');

730: ELSE
731: --+
732: -- This mapping is based on a free-form update clause
733: --+
734: cn_utils.appindcr(code, ' --*** FROM/WHERE taken from Update Clause');
735: cn_utils.appindcr(code, ' '||indmap_rec.update_clause||'),');
736: END IF;
737: END LOOP;
738: cn_utils.strip_prev(code, 1); -- remove trailing comma

Line 735: cn_utils.appindcr(code, ' '||indmap_rec.update_clause||'),');

731: --+
732: -- This mapping is based on a free-form update clause
733: --+
734: cn_utils.appindcr(code, ' --*** FROM/WHERE taken from Update Clause');
735: cn_utils.appindcr(code, ' '||indmap_rec.update_clause||'),');
736: END IF;
737: END LOOP;
738: cn_utils.strip_prev(code, 1); -- remove trailing comma
739: cn_utils.appendcr(code);

Line 738: cn_utils.strip_prev(code, 1); -- remove trailing comma

734: cn_utils.appindcr(code, ' --*** FROM/WHERE taken from Update Clause');
735: cn_utils.appindcr(code, ' '||indmap_rec.update_clause||'),');
736: END IF;
737: END LOOP;
738: cn_utils.strip_prev(code, 1); -- remove trailing comma
739: cn_utils.appendcr(code);
740: cn_utils.unindent(code, 1);
741: cn_utils.appindcr(code, 'WHERE ' || x_dest_alias || '.process_batch_id = x_proc_audit_id');
742: --Added by Ashley for MOAC

Line 739: cn_utils.appendcr(code);

735: cn_utils.appindcr(code, ' '||indmap_rec.update_clause||'),');
736: END IF;
737: END LOOP;
738: cn_utils.strip_prev(code, 1); -- remove trailing comma
739: cn_utils.appendcr(code);
740: cn_utils.unindent(code, 1);
741: cn_utils.appindcr(code, 'WHERE ' || x_dest_alias || '.process_batch_id = x_proc_audit_id');
742: --Added by Ashley for MOAC
743: cn_utils.appindcr(code, 'AND ' || x_dest_alias || '.org_id = ' || x_org_id || ';');

Line 740: cn_utils.unindent(code, 1);

736: END IF;
737: END LOOP;
738: cn_utils.strip_prev(code, 1); -- remove trailing comma
739: cn_utils.appendcr(code);
740: cn_utils.unindent(code, 1);
741: cn_utils.appindcr(code, 'WHERE ' || x_dest_alias || '.process_batch_id = x_proc_audit_id');
742: --Added by Ashley for MOAC
743: cn_utils.appindcr(code, 'AND ' || x_dest_alias || '.org_id = ' || x_org_id || ';');
744: cn_utils.appendcr(code);

Line 741: cn_utils.appindcr(code, 'WHERE ' || x_dest_alias || '.process_batch_id = x_proc_audit_id');

737: END LOOP;
738: cn_utils.strip_prev(code, 1); -- remove trailing comma
739: cn_utils.appendcr(code);
740: cn_utils.unindent(code, 1);
741: cn_utils.appindcr(code, 'WHERE ' || x_dest_alias || '.process_batch_id = x_proc_audit_id');
742: --Added by Ashley for MOAC
743: cn_utils.appindcr(code, 'AND ' || x_dest_alias || '.org_id = ' || x_org_id || ';');
744: cn_utils.appendcr(code);
745: END IF;

Line 743: cn_utils.appindcr(code, 'AND ' || x_dest_alias || '.org_id = ' || x_org_id || ';');

739: cn_utils.appendcr(code);
740: cn_utils.unindent(code, 1);
741: cn_utils.appindcr(code, 'WHERE ' || x_dest_alias || '.process_batch_id = x_proc_audit_id');
742: --Added by Ashley for MOAC
743: cn_utils.appindcr(code, 'AND ' || x_dest_alias || '.org_id = ' || x_org_id || ';');
744: cn_utils.appendcr(code);
745: END IF;
746: --+
747: -- Generate code to update the comm_lines_api_update_count variable

Line 744: cn_utils.appendcr(code);

740: cn_utils.unindent(code, 1);
741: cn_utils.appindcr(code, 'WHERE ' || x_dest_alias || '.process_batch_id = x_proc_audit_id');
742: --Added by Ashley for MOAC
743: cn_utils.appindcr(code, 'AND ' || x_dest_alias || '.org_id = ' || x_org_id || ';');
744: cn_utils.appendcr(code);
745: END IF;
746: --+
747: -- Generate code to update the comm_lines_api_update_count variable
748: --+

Line 749: cn_utils.appendcr(code);

745: END IF;
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();

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 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.'');');

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:
755: EXCEPTION

Line 752: cn_utils.appendcr(code);

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:
755: EXCEPTION
756: WHEN NO_DATA_FOUND THEN

Line 753: cn_utils.unset_org_id();

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:
755: EXCEPTION
756: WHEN NO_DATA_FOUND THEN
757: cn_debug.print_msg('update_lines: in exception handler for NO_DATA_FOUND', 1);

Line 774: code IN OUT NOCOPY cn_utils.code_type,

770: --
771: --
772: PROCEDURE filter_comm_lines_api(
773: x_table_map_id cn_table_maps.table_map_id%TYPE,
774: code IN OUT NOCOPY cn_utils.code_type,
775: x_org_id IN NUMBER)
776: IS
777:
778: l_delete_flag VARCHAR2(1);

Line 803: cn_utils.set_org_id(x_org_id);

799: l_statement := 'DELETE FROM cn_comm_lines_api api';
800: ELSE
801: l_statement := 'UPDATE cn_comm_lines_api api SET load_status = ''FILTERED''';
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.'');');

Line 804: cn_utils.appendcr(code);

800: ELSE
801: l_statement := 'UPDATE cn_comm_lines_api api SET load_status = ''FILTERED''';
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);

Line 805: cn_utils.appendcr(code, '-- FILTER PROCESSING *-- ');

801: l_statement := 'UPDATE cn_comm_lines_api api SET load_status = ''FILTERED''';
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: --+

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

Line 807: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''Filtering unwanted transactions from cn_comm_lines_api.'');');

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
811: --+

Line 808: cn_utils.appendcr(code);

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
811: --+
812: cn_utils.appindcr(code, '--*** User-defined filter statements');

Line 812: cn_utils.appindcr(code, '--*** User-defined filter statements');

808: cn_utils.appendcr(code);
809: --+
810: -- Generate deletion code
811: --+
812: cn_utils.appindcr(code, '--*** User-defined filter statements');
813: FOR rec IN c_filter
814: LOOP
815: --+
816: -- Before doing so, strip off trailing ';' on the clause, if one

Line 822: cn_utils.appindcr(code, l_statement);

818: --+
819: IF SUBSTR(rec.object_value,LENGTH(rec.object_value),1) = ';' THEN
820: rec.object_value := SUBSTR(rec.object_value,1,LENGTH(rec.object_value)-1);
821: END IF;
822: cn_utils.appindcr(code, l_statement);
823: cn_utils.appindcr(code, 'WHERE');
824: cn_utils.appindcr(code, ' '||rec.object_value);
825: cn_utils.appindcr(code, ' AND api.process_batch_id = x_proc_audit_id;');
826: cn_utils.appendcr(code);

Line 823: cn_utils.appindcr(code, 'WHERE');

819: IF SUBSTR(rec.object_value,LENGTH(rec.object_value),1) = ';' THEN
820: rec.object_value := SUBSTR(rec.object_value,1,LENGTH(rec.object_value)-1);
821: END IF;
822: cn_utils.appindcr(code, l_statement);
823: cn_utils.appindcr(code, 'WHERE');
824: cn_utils.appindcr(code, ' '||rec.object_value);
825: cn_utils.appindcr(code, ' AND api.process_batch_id = x_proc_audit_id;');
826: cn_utils.appendcr(code);
827: END LOOP;

Line 824: cn_utils.appindcr(code, ' '||rec.object_value);

820: rec.object_value := SUBSTR(rec.object_value,1,LENGTH(rec.object_value)-1);
821: END IF;
822: cn_utils.appindcr(code, l_statement);
823: cn_utils.appindcr(code, 'WHERE');
824: cn_utils.appindcr(code, ' '||rec.object_value);
825: cn_utils.appindcr(code, ' AND api.process_batch_id = x_proc_audit_id;');
826: cn_utils.appendcr(code);
827: END LOOP;
828: cn_utils.appindcr(code, '--*** End of User-defined filter statements');

Line 825: cn_utils.appindcr(code, ' AND api.process_batch_id = x_proc_audit_id;');

821: END IF;
822: cn_utils.appindcr(code, l_statement);
823: cn_utils.appindcr(code, 'WHERE');
824: cn_utils.appindcr(code, ' '||rec.object_value);
825: cn_utils.appindcr(code, ' AND api.process_batch_id = x_proc_audit_id;');
826: cn_utils.appendcr(code);
827: END LOOP;
828: cn_utils.appindcr(code, '--*** End of User-defined filter statements');
829: cn_utils.unset_org_id();

Line 826: cn_utils.appendcr(code);

822: cn_utils.appindcr(code, l_statement);
823: cn_utils.appindcr(code, 'WHERE');
824: cn_utils.appindcr(code, ' '||rec.object_value);
825: cn_utils.appindcr(code, ' AND api.process_batch_id = x_proc_audit_id;');
826: cn_utils.appendcr(code);
827: END LOOP;
828: cn_utils.appindcr(code, '--*** End of User-defined filter statements');
829: cn_utils.unset_org_id();
830: END filter_comm_lines_api;

Line 828: cn_utils.appindcr(code, '--*** End of User-defined filter statements');

824: cn_utils.appindcr(code, ' '||rec.object_value);
825: cn_utils.appindcr(code, ' AND api.process_batch_id = x_proc_audit_id;');
826: cn_utils.appendcr(code);
827: END LOOP;
828: cn_utils.appindcr(code, '--*** End of User-defined filter statements');
829: cn_utils.unset_org_id();
830: END filter_comm_lines_api;
831:
832: --

Line 829: cn_utils.unset_org_id();

825: cn_utils.appindcr(code, ' AND api.process_batch_id = x_proc_audit_id;');
826: cn_utils.appendcr(code);
827: END LOOP;
828: cn_utils.appindcr(code, '--*** End of User-defined filter statements');
829: cn_utils.unset_org_id();
830: END filter_comm_lines_api;
831:
832: --
833: -- Procedure Name

Line 843: code IN OUT NOCOPY cn_utils.code_type,

839: --
840: PROCEDURE Generate_User_Code(
841: p_table_map_id IN NUMBER,
842: p_location_name IN VARCHAR2,
843: code IN OUT NOCOPY cn_utils.code_type,
844: x_org_id IN NUMBER)
845: IS
846: BEGIN
847: cn_utils.set_org_id(x_org_id);

Line 847: cn_utils.set_org_id(x_org_id);

843: code IN OUT NOCOPY cn_utils.code_type,
844: x_org_id IN NUMBER)
845: IS
846: BEGIN
847: cn_utils.set_org_id(x_org_id);
848: cn_utils.appendcr(code);
849: cn_utils.appindcr(code, '--*** User Code, Location: '||p_location_name);
850: --+
851: -- For every line of User Code registered for this location

Line 848: cn_utils.appendcr(code);

844: x_org_id IN NUMBER)
845: IS
846: BEGIN
847: cn_utils.set_org_id(x_org_id);
848: cn_utils.appendcr(code);
849: cn_utils.appindcr(code, '--*** User Code, Location: '||p_location_name);
850: --+
851: -- For every line of User Code registered for this location
852: --+

Line 849: cn_utils.appindcr(code, '--*** User Code, Location: '||p_location_name);

845: IS
846: BEGIN
847: cn_utils.set_org_id(x_org_id);
848: cn_utils.appendcr(code);
849: cn_utils.appindcr(code, '--*** User Code, Location: '||p_location_name);
850: --+
851: -- For every line of User Code registered for this location
852: --+
853: FOR rec IN

Line 868: cn_utils.appindcr(code, rec.object_value);

864: --+
865: -- Add a terminal ';' if none was registered
866: --+
867: IF rec.object_value LIKE '%;' THEN
868: cn_utils.appindcr(code, rec.object_value);
869: ELSE
870: cn_utils.appindcr(code, rec.object_value||';');
871: END IF;
872: END LOOP;

Line 870: cn_utils.appindcr(code, rec.object_value||';');

866: --+
867: IF rec.object_value LIKE '%;' THEN
868: cn_utils.appindcr(code, rec.object_value);
869: ELSE
870: cn_utils.appindcr(code, rec.object_value||';');
871: END IF;
872: END LOOP;
873: cn_utils.appindcr(code, '--*** End of User Code, Location: '||p_location_name);
874: cn_utils.appendcr(code);

Line 873: cn_utils.appindcr(code, '--*** End of User Code, Location: '||p_location_name);

869: ELSE
870: cn_utils.appindcr(code, rec.object_value||';');
871: END IF;
872: END LOOP;
873: cn_utils.appindcr(code, '--*** End of User Code, Location: '||p_location_name);
874: cn_utils.appendcr(code);
875: cn_utils.unset_org_id();
876: END Generate_User_Code;
877:

Line 874: cn_utils.appendcr(code);

870: cn_utils.appindcr(code, rec.object_value||';');
871: END IF;
872: END LOOP;
873: cn_utils.appindcr(code, '--*** End of User Code, Location: '||p_location_name);
874: cn_utils.appendcr(code);
875: cn_utils.unset_org_id();
876: END Generate_User_Code;
877:
878:

Line 875: cn_utils.unset_org_id();

871: END IF;
872: END LOOP;
873: cn_utils.appindcr(code, '--*** End of User Code, Location: '||p_location_name);
874: cn_utils.appendcr(code);
875: cn_utils.unset_org_id();
876: END Generate_User_Code;
877:
878:
879: END cn_collection_custom_gen;