[Home] [Help]
37: -- 03-17-00 Dave Maskell Created for Release 11i2.
38: PROCEDURE insert_cn_not_trx(
39: x_table_map_id cn_table_maps.table_map_id%TYPE,
40: x_event_id cn_events.event_id%TYPE,
41: code IN OUT NOCOPY cn_utils.code_type,
42: x_org_id IN NUMBER)
43: IS
44: l_return_status VARCHAR2(4000);
45: l_msg_count NUMBER;
90: l_header_key := 'NULL';
91: ELSE
92: l_header_key := LOWER( NVL(l_table_map_rec.header_table_alias,l_table_map_rec.header_table_name)|| '.'||l_table_map_rec.hdrpk_name);
93: END IF;
94: cn_utils.set_org_id(p_org_id => l_org_id);
95: cn_utils.appendcr(code);
96: cn_utils.appendcr(code, '--******** NOTIFICATION PROCESSING *********-- ');
97: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserting new transactions into CN_NOT_TRX.'');');
98: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserting new transactions into CN_NOT_TRX.'');');
91: ELSE
92: l_header_key := LOWER( NVL(l_table_map_rec.header_table_alias,l_table_map_rec.header_table_name)|| '.'||l_table_map_rec.hdrpk_name);
93: END IF;
94: cn_utils.set_org_id(p_org_id => l_org_id);
95: cn_utils.appendcr(code);
96: cn_utils.appendcr(code, '--******** NOTIFICATION PROCESSING *********-- ');
97: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserting new transactions into CN_NOT_TRX.'');');
98: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserting new transactions into CN_NOT_TRX.'');');
99: cn_utils.appendcr(code);
92: l_header_key := LOWER( NVL(l_table_map_rec.header_table_alias,l_table_map_rec.header_table_name)|| '.'||l_table_map_rec.hdrpk_name);
93: END IF;
94: cn_utils.set_org_id(p_org_id => l_org_id);
95: cn_utils.appendcr(code);
96: cn_utils.appendcr(code, '--******** NOTIFICATION PROCESSING *********-- ');
97: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserting new transactions into CN_NOT_TRX.'');');
98: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserting new transactions into CN_NOT_TRX.'');');
99: cn_utils.appendcr(code);
100: --+
93: END IF;
94: cn_utils.set_org_id(p_org_id => l_org_id);
95: cn_utils.appendcr(code);
96: cn_utils.appendcr(code, '--******** NOTIFICATION PROCESSING *********-- ');
97: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserting new transactions into CN_NOT_TRX.'');');
98: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserting new transactions into CN_NOT_TRX.'');');
99: cn_utils.appendcr(code);
100: --+
101: -- Most local variables for the collect procedure are part of a static set, which is generated
94: cn_utils.set_org_id(p_org_id => l_org_id);
95: cn_utils.appendcr(code);
96: cn_utils.appendcr(code, '--******** NOTIFICATION PROCESSING *********-- ');
97: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserting new transactions into CN_NOT_TRX.'');');
98: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserting new transactions into CN_NOT_TRX.'');');
99: cn_utils.appendcr(code);
100: --+
101: -- Most local variables for the collect procedure are part of a static set, which is generated
102: -- for all pacakges (inclding OC and AR) at the start of the procedure by the cn_collection_gen
95: cn_utils.appendcr(code);
96: cn_utils.appendcr(code, '--******** NOTIFICATION PROCESSING *********-- ');
97: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserting new transactions into CN_NOT_TRX.'');');
98: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserting new transactions into CN_NOT_TRX.'');');
99: cn_utils.appendcr(code);
100: --+
101: -- Most local variables for the collect procedure are part of a static set, which is generated
102: -- for all pacakges (inclding OC and AR) at the start of the procedure by the cn_collection_gen
103: -- package. However, for the notification query of Custom data sources, we need local variables
104: -- which have the names of the any parameters which have been specified by the user on the Queries
105: -- tab of the Collections form. To allow use to do this, we need to enclose the notification query
106: -- in its own block.
107: --+
108: cn_utils.appindcr(code, 'DECLARE -- Notification Insert Block');
109: --+
110: -- Generate Declarations of parameter variables
111: --+
112: cn_utils.indent(code, 1);
108: cn_utils.appindcr(code, 'DECLARE -- Notification Insert Block');
109: --+
110: -- Generate Declarations of parameter variables
111: --+
112: cn_utils.indent(code, 1);
113: cn_utils.appindcr(code, '--*** Declaring user-defined Notification Parameters');
114: FOR rec IN c_param
115: LOOP
116: cn_utils.appindcr(code, rec.object_name||' cn_objects.object_value%TYPE;');
109: --+
110: -- Generate Declarations of parameter variables
111: --+
112: cn_utils.indent(code, 1);
113: cn_utils.appindcr(code, '--*** Declaring user-defined Notification Parameters');
114: FOR rec IN c_param
115: LOOP
116: cn_utils.appindcr(code, rec.object_name||' cn_objects.object_value%TYPE;');
117: END LOOP;
112: cn_utils.indent(code, 1);
113: cn_utils.appindcr(code, '--*** Declaring user-defined Notification Parameters');
114: FOR rec IN c_param
115: LOOP
116: cn_utils.appindcr(code, rec.object_name||' cn_objects.object_value%TYPE;');
117: END LOOP;
118: cn_utils.unindent(code, 1);
119: cn_utils.appindcr(code, 'BEGIN');
120: --+
114: FOR rec IN c_param
115: LOOP
116: cn_utils.appindcr(code, rec.object_name||' cn_objects.object_value%TYPE;');
117: END LOOP;
118: cn_utils.unindent(code, 1);
119: cn_utils.appindcr(code, 'BEGIN');
120: --+
121: -- Generate code to initialise parameter variables
122: --+
115: LOOP
116: cn_utils.appindcr(code, rec.object_name||' cn_objects.object_value%TYPE;');
117: END LOOP;
118: cn_utils.unindent(code, 1);
119: cn_utils.appindcr(code, 'BEGIN');
120: --+
121: -- Generate code to initialise parameter variables
122: --+
123: cn_utils.indent(code, 1);
119: cn_utils.appindcr(code, 'BEGIN');
120: --+
121: -- Generate code to initialise parameter variables
122: --+
123: cn_utils.indent(code, 1);
124: cn_utils.appindcr(code, '--*** Initializing user-defined Notification Parameters');
125: FOR rec IN c_param
126: LOOP
127: cn_utils.appindcr(code, 'SELECT object_value');
120: --+
121: -- Generate code to initialise parameter variables
122: --+
123: cn_utils.indent(code, 1);
124: cn_utils.appindcr(code, '--*** Initializing user-defined Notification Parameters');
125: FOR rec IN c_param
126: LOOP
127: cn_utils.appindcr(code, 'SELECT object_value');
128: cn_utils.appindcr(code, 'INTO '||rec.object_name);
123: cn_utils.indent(code, 1);
124: cn_utils.appindcr(code, '--*** Initializing user-defined Notification Parameters');
125: FOR rec IN c_param
126: LOOP
127: cn_utils.appindcr(code, 'SELECT object_value');
128: cn_utils.appindcr(code, 'INTO '||rec.object_name);
129: cn_utils.appindcr(code, 'FROM cn_objects');
130: cn_utils.appindcr(code, 'WHERE object_id = '||rec.object_id||' --*** Object_Id for '||rec.object_name);
131: cn_utils.appindcr(code, 'AND org_id = '||l_org_id||';');
124: cn_utils.appindcr(code, '--*** Initializing user-defined Notification Parameters');
125: FOR rec IN c_param
126: LOOP
127: cn_utils.appindcr(code, 'SELECT object_value');
128: cn_utils.appindcr(code, 'INTO '||rec.object_name);
129: cn_utils.appindcr(code, 'FROM cn_objects');
130: cn_utils.appindcr(code, 'WHERE object_id = '||rec.object_id||' --*** Object_Id for '||rec.object_name);
131: cn_utils.appindcr(code, 'AND org_id = '||l_org_id||';');
132: cn_utils.appendcr(code);
125: FOR rec IN c_param
126: LOOP
127: cn_utils.appindcr(code, 'SELECT object_value');
128: cn_utils.appindcr(code, 'INTO '||rec.object_name);
129: cn_utils.appindcr(code, 'FROM cn_objects');
130: cn_utils.appindcr(code, 'WHERE object_id = '||rec.object_id||' --*** Object_Id for '||rec.object_name);
131: cn_utils.appindcr(code, 'AND org_id = '||l_org_id||';');
132: cn_utils.appendcr(code);
133: END LOOP;
126: LOOP
127: cn_utils.appindcr(code, 'SELECT object_value');
128: cn_utils.appindcr(code, 'INTO '||rec.object_name);
129: cn_utils.appindcr(code, 'FROM cn_objects');
130: cn_utils.appindcr(code, 'WHERE object_id = '||rec.object_id||' --*** Object_Id for '||rec.object_name);
131: cn_utils.appindcr(code, 'AND org_id = '||l_org_id||';');
132: cn_utils.appendcr(code);
133: END LOOP;
134: -- Added For R12 MOAC Change
127: cn_utils.appindcr(code, 'SELECT object_value');
128: cn_utils.appindcr(code, 'INTO '||rec.object_name);
129: cn_utils.appindcr(code, 'FROM cn_objects');
130: cn_utils.appindcr(code, 'WHERE object_id = '||rec.object_id||' --*** Object_Id for '||rec.object_name);
131: cn_utils.appindcr(code, 'AND org_id = '||l_org_id||';');
132: cn_utils.appendcr(code);
133: END LOOP;
134: -- Added For R12 MOAC Change
135: cn_utils.appendcr(code);
128: cn_utils.appindcr(code, 'INTO '||rec.object_name);
129: cn_utils.appindcr(code, 'FROM cn_objects');
130: cn_utils.appindcr(code, 'WHERE object_id = '||rec.object_id||' --*** Object_Id for '||rec.object_name);
131: cn_utils.appindcr(code, 'AND org_id = '||l_org_id||';');
132: cn_utils.appendcr(code);
133: END LOOP;
134: -- Added For R12 MOAC Change
135: cn_utils.appendcr(code);
136: --+
131: cn_utils.appindcr(code, 'AND org_id = '||l_org_id||';');
132: cn_utils.appendcr(code);
133: END LOOP;
134: -- Added For R12 MOAC Change
135: cn_utils.appendcr(code);
136: --+
137: -- Insert any User Code specified for the 'Pre-Notification' location
138: --+
139: Generate_User_Code( p_table_map_id => x_table_map_id,
163: --+
164: -- Generate the INSERT INTO API .. SELECT portion of
165: -- the statement
166: --+
167: cn_utils.set_org_id(l_org_id);
168: cn_utils.appindcr(code, '--');
169: cn_utils.appindcr(code, '-- Insert new lines into cn_not_trx');
170: cn_utils.appindcr(code, '--');
171: cn_utils.appindcr(code, '--CN_DB_PARALLEL_ENABLE :'||fnd_profile.value('CN_DB_PARALLEL_ENABLE'));
164: -- Generate the INSERT INTO API .. SELECT portion of
165: -- the statement
166: --+
167: cn_utils.set_org_id(l_org_id);
168: cn_utils.appindcr(code, '--');
169: cn_utils.appindcr(code, '-- Insert new lines into cn_not_trx');
170: cn_utils.appindcr(code, '--');
171: cn_utils.appindcr(code, '--CN_DB_PARALLEL_ENABLE :'||fnd_profile.value('CN_DB_PARALLEL_ENABLE'));
172: IF CN_COLLECTION_GEN.isParallelEnabled THEN
165: -- the statement
166: --+
167: cn_utils.set_org_id(l_org_id);
168: cn_utils.appindcr(code, '--');
169: cn_utils.appindcr(code, '-- Insert new lines into cn_not_trx');
170: cn_utils.appindcr(code, '--');
171: cn_utils.appindcr(code, '--CN_DB_PARALLEL_ENABLE :'||fnd_profile.value('CN_DB_PARALLEL_ENABLE'));
172: IF CN_COLLECTION_GEN.isParallelEnabled THEN
173: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_not_trx) */ INTO cn_not_trx (');
166: --+
167: cn_utils.set_org_id(l_org_id);
168: cn_utils.appindcr(code, '--');
169: cn_utils.appindcr(code, '-- Insert new lines into cn_not_trx');
170: cn_utils.appindcr(code, '--');
171: cn_utils.appindcr(code, '--CN_DB_PARALLEL_ENABLE :'||fnd_profile.value('CN_DB_PARALLEL_ENABLE'));
172: IF CN_COLLECTION_GEN.isParallelEnabled THEN
173: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_not_trx) */ INTO cn_not_trx (');
174: ELSE
167: cn_utils.set_org_id(l_org_id);
168: cn_utils.appindcr(code, '--');
169: cn_utils.appindcr(code, '-- Insert new lines into cn_not_trx');
170: cn_utils.appindcr(code, '--');
171: cn_utils.appindcr(code, '--CN_DB_PARALLEL_ENABLE :'||fnd_profile.value('CN_DB_PARALLEL_ENABLE'));
172: IF CN_COLLECTION_GEN.isParallelEnabled THEN
173: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_not_trx) */ INTO cn_not_trx (');
174: ELSE
175: cn_utils.appindcr(code, 'INSERT INTO cn_not_trx (');
169: cn_utils.appindcr(code, '-- Insert new lines into cn_not_trx');
170: cn_utils.appindcr(code, '--');
171: cn_utils.appindcr(code, '--CN_DB_PARALLEL_ENABLE :'||fnd_profile.value('CN_DB_PARALLEL_ENABLE'));
172: IF CN_COLLECTION_GEN.isParallelEnabled THEN
173: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_not_trx) */ INTO cn_not_trx (');
174: ELSE
175: cn_utils.appindcr(code, 'INSERT INTO cn_not_trx (');
176: END IF;
177: cn_utils.indent(code, 1);
171: cn_utils.appindcr(code, '--CN_DB_PARALLEL_ENABLE :'||fnd_profile.value('CN_DB_PARALLEL_ENABLE'));
172: IF CN_COLLECTION_GEN.isParallelEnabled THEN
173: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_not_trx) */ INTO cn_not_trx (');
174: ELSE
175: cn_utils.appindcr(code, 'INSERT INTO cn_not_trx (');
176: END IF;
177: cn_utils.indent(code, 1);
178: cn_utils.appindcr(code, 'not_trx_id,');
179: cn_utils.appindcr(code, 'batch_id,');
173: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_not_trx) */ INTO cn_not_trx (');
174: ELSE
175: cn_utils.appindcr(code, 'INSERT INTO cn_not_trx (');
176: END IF;
177: cn_utils.indent(code, 1);
178: cn_utils.appindcr(code, 'not_trx_id,');
179: cn_utils.appindcr(code, 'batch_id,');
180: cn_utils.appindcr(code, 'notified_date,');
181: cn_utils.appindcr(code, 'notification_run_id,');
174: ELSE
175: cn_utils.appindcr(code, 'INSERT INTO cn_not_trx (');
176: END IF;
177: cn_utils.indent(code, 1);
178: cn_utils.appindcr(code, 'not_trx_id,');
179: cn_utils.appindcr(code, 'batch_id,');
180: cn_utils.appindcr(code, 'notified_date,');
181: cn_utils.appindcr(code, 'notification_run_id,');
182: cn_utils.appindcr(code, 'collected_flag,');
175: cn_utils.appindcr(code, 'INSERT INTO cn_not_trx (');
176: END IF;
177: cn_utils.indent(code, 1);
178: cn_utils.appindcr(code, 'not_trx_id,');
179: cn_utils.appindcr(code, 'batch_id,');
180: cn_utils.appindcr(code, 'notified_date,');
181: cn_utils.appindcr(code, 'notification_run_id,');
182: cn_utils.appindcr(code, 'collected_flag,');
183: cn_utils.appindcr(code, 'event_id,');
176: END IF;
177: cn_utils.indent(code, 1);
178: cn_utils.appindcr(code, 'not_trx_id,');
179: cn_utils.appindcr(code, 'batch_id,');
180: cn_utils.appindcr(code, 'notified_date,');
181: cn_utils.appindcr(code, 'notification_run_id,');
182: cn_utils.appindcr(code, 'collected_flag,');
183: cn_utils.appindcr(code, 'event_id,');
184: cn_utils.appindcr(code, 'source_trx_id,');
177: cn_utils.indent(code, 1);
178: cn_utils.appindcr(code, 'not_trx_id,');
179: cn_utils.appindcr(code, 'batch_id,');
180: cn_utils.appindcr(code, 'notified_date,');
181: cn_utils.appindcr(code, 'notification_run_id,');
182: cn_utils.appindcr(code, 'collected_flag,');
183: cn_utils.appindcr(code, 'event_id,');
184: cn_utils.appindcr(code, 'source_trx_id,');
185: cn_utils.appindcr(code, 'source_trx_line_id,');
178: cn_utils.appindcr(code, 'not_trx_id,');
179: cn_utils.appindcr(code, 'batch_id,');
180: cn_utils.appindcr(code, 'notified_date,');
181: cn_utils.appindcr(code, 'notification_run_id,');
182: cn_utils.appindcr(code, 'collected_flag,');
183: cn_utils.appindcr(code, 'event_id,');
184: cn_utils.appindcr(code, 'source_trx_id,');
185: cn_utils.appindcr(code, 'source_trx_line_id,');
186: cn_utils.appindcr(code, 'source_doc_type,');
179: cn_utils.appindcr(code, 'batch_id,');
180: cn_utils.appindcr(code, 'notified_date,');
181: cn_utils.appindcr(code, 'notification_run_id,');
182: cn_utils.appindcr(code, 'collected_flag,');
183: cn_utils.appindcr(code, 'event_id,');
184: cn_utils.appindcr(code, 'source_trx_id,');
185: cn_utils.appindcr(code, 'source_trx_line_id,');
186: cn_utils.appindcr(code, 'source_doc_type,');
187: cn_utils.appindcr(code, 'org_id)'); -- Added For R12 MOAC Change
180: cn_utils.appindcr(code, 'notified_date,');
181: cn_utils.appindcr(code, 'notification_run_id,');
182: cn_utils.appindcr(code, 'collected_flag,');
183: cn_utils.appindcr(code, 'event_id,');
184: cn_utils.appindcr(code, 'source_trx_id,');
185: cn_utils.appindcr(code, 'source_trx_line_id,');
186: cn_utils.appindcr(code, 'source_doc_type,');
187: cn_utils.appindcr(code, 'org_id)'); -- Added For R12 MOAC Change
188: cn_utils.unindent(code, 1);
181: cn_utils.appindcr(code, 'notification_run_id,');
182: cn_utils.appindcr(code, 'collected_flag,');
183: cn_utils.appindcr(code, 'event_id,');
184: cn_utils.appindcr(code, 'source_trx_id,');
185: cn_utils.appindcr(code, 'source_trx_line_id,');
186: cn_utils.appindcr(code, 'source_doc_type,');
187: cn_utils.appindcr(code, 'org_id)'); -- Added For R12 MOAC Change
188: cn_utils.unindent(code, 1);
189: --+
182: cn_utils.appindcr(code, 'collected_flag,');
183: cn_utils.appindcr(code, 'event_id,');
184: cn_utils.appindcr(code, 'source_trx_id,');
185: cn_utils.appindcr(code, 'source_trx_line_id,');
186: cn_utils.appindcr(code, 'source_doc_type,');
187: cn_utils.appindcr(code, 'org_id)'); -- Added For R12 MOAC Change
188: cn_utils.unindent(code, 1);
189: --+
190: -- Generate the SELECT clause for the insert statement
183: cn_utils.appindcr(code, 'event_id,');
184: cn_utils.appindcr(code, 'source_trx_id,');
185: cn_utils.appindcr(code, 'source_trx_line_id,');
186: cn_utils.appindcr(code, 'source_doc_type,');
187: cn_utils.appindcr(code, 'org_id)'); -- Added For R12 MOAC Change
188: cn_utils.unindent(code, 1);
189: --+
190: -- Generate the SELECT clause for the insert statement
191: --+
184: cn_utils.appindcr(code, 'source_trx_id,');
185: cn_utils.appindcr(code, 'source_trx_line_id,');
186: cn_utils.appindcr(code, 'source_doc_type,');
187: cn_utils.appindcr(code, 'org_id)'); -- Added For R12 MOAC Change
188: cn_utils.unindent(code, 1);
189: --+
190: -- Generate the SELECT clause for the insert statement
191: --+
192: IF CN_COLLECTION_GEN.isParallelEnabled THEN
189: --+
190: -- Generate the SELECT clause for the insert statement
191: --+
192: IF CN_COLLECTION_GEN.isParallelEnabled THEN
193: cn_utils.appindcr(code, 'SELECT '||l_parallel_hint);
194: ELSE
195: cn_utils.appindcr(code, 'SELECT ');
196: END IF;
197: cn_utils.indent(code, 1);
191: --+
192: IF CN_COLLECTION_GEN.isParallelEnabled THEN
193: cn_utils.appindcr(code, 'SELECT '||l_parallel_hint);
194: ELSE
195: cn_utils.appindcr(code, 'SELECT ');
196: END IF;
197: cn_utils.indent(code, 1);
198: cn_utils.appindcr(code, 'cn_not_trx_s.NEXTVAL,');
199: -- Changed for Bug 6203234
193: cn_utils.appindcr(code, 'SELECT '||l_parallel_hint);
194: ELSE
195: cn_utils.appindcr(code, 'SELECT ');
196: END IF;
197: cn_utils.indent(code, 1);
198: cn_utils.appindcr(code, 'cn_not_trx_s.NEXTVAL,');
199: -- Changed for Bug 6203234
200: --cn_utils.appindcr(code, 'FLOOR(cn_not_trx_s.CURRVAL/cn_global_var.g_system_batch_size),');
201: cn_utils.appindcr(code, 'x_proc_audit_id,');
194: ELSE
195: cn_utils.appindcr(code, 'SELECT ');
196: END IF;
197: cn_utils.indent(code, 1);
198: cn_utils.appindcr(code, 'cn_not_trx_s.NEXTVAL,');
199: -- Changed for Bug 6203234
200: --cn_utils.appindcr(code, 'FLOOR(cn_not_trx_s.CURRVAL/cn_global_var.g_system_batch_size),');
201: cn_utils.appindcr(code, 'x_proc_audit_id,');
202: cn_utils.appindcr(code, 'SYSDATE,');
196: END IF;
197: cn_utils.indent(code, 1);
198: cn_utils.appindcr(code, 'cn_not_trx_s.NEXTVAL,');
199: -- Changed for Bug 6203234
200: --cn_utils.appindcr(code, 'FLOOR(cn_not_trx_s.CURRVAL/cn_global_var.g_system_batch_size),');
201: cn_utils.appindcr(code, 'x_proc_audit_id,');
202: cn_utils.appindcr(code, 'SYSDATE,');
203: cn_utils.appindcr(code, 'x_proc_audit_id,');
204: cn_utils.appindcr(code, '''N'',');
197: cn_utils.indent(code, 1);
198: cn_utils.appindcr(code, 'cn_not_trx_s.NEXTVAL,');
199: -- Changed for Bug 6203234
200: --cn_utils.appindcr(code, 'FLOOR(cn_not_trx_s.CURRVAL/cn_global_var.g_system_batch_size),');
201: cn_utils.appindcr(code, 'x_proc_audit_id,');
202: cn_utils.appindcr(code, 'SYSDATE,');
203: cn_utils.appindcr(code, 'x_proc_audit_id,');
204: cn_utils.appindcr(code, '''N'',');
205: cn_utils.appindcr(code, x_event_id||',');
198: cn_utils.appindcr(code, 'cn_not_trx_s.NEXTVAL,');
199: -- Changed for Bug 6203234
200: --cn_utils.appindcr(code, 'FLOOR(cn_not_trx_s.CURRVAL/cn_global_var.g_system_batch_size),');
201: cn_utils.appindcr(code, 'x_proc_audit_id,');
202: cn_utils.appindcr(code, 'SYSDATE,');
203: cn_utils.appindcr(code, 'x_proc_audit_id,');
204: cn_utils.appindcr(code, '''N'',');
205: cn_utils.appindcr(code, x_event_id||',');
206: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');
199: -- Changed for Bug 6203234
200: --cn_utils.appindcr(code, 'FLOOR(cn_not_trx_s.CURRVAL/cn_global_var.g_system_batch_size),');
201: cn_utils.appindcr(code, 'x_proc_audit_id,');
202: cn_utils.appindcr(code, 'SYSDATE,');
203: cn_utils.appindcr(code, 'x_proc_audit_id,');
204: cn_utils.appindcr(code, '''N'',');
205: cn_utils.appindcr(code, x_event_id||',');
206: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');
207: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');
200: --cn_utils.appindcr(code, 'FLOOR(cn_not_trx_s.CURRVAL/cn_global_var.g_system_batch_size),');
201: cn_utils.appindcr(code, 'x_proc_audit_id,');
202: cn_utils.appindcr(code, 'SYSDATE,');
203: cn_utils.appindcr(code, 'x_proc_audit_id,');
204: cn_utils.appindcr(code, '''N'',');
205: cn_utils.appindcr(code, x_event_id||',');
206: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');
207: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');
208: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');
201: cn_utils.appindcr(code, 'x_proc_audit_id,');
202: cn_utils.appindcr(code, 'SYSDATE,');
203: cn_utils.appindcr(code, 'x_proc_audit_id,');
204: cn_utils.appindcr(code, '''N'',');
205: cn_utils.appindcr(code, x_event_id||',');
206: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');
207: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');
208: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');
209: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change
202: cn_utils.appindcr(code, 'SYSDATE,');
203: cn_utils.appindcr(code, 'x_proc_audit_id,');
204: cn_utils.appindcr(code, '''N'',');
205: cn_utils.appindcr(code, x_event_id||',');
206: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');
207: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');
208: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');
209: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change
210: cn_utils.unindent(code, 1);
203: cn_utils.appindcr(code, 'x_proc_audit_id,');
204: cn_utils.appindcr(code, '''N'',');
205: cn_utils.appindcr(code, x_event_id||',');
206: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');
207: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');
208: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');
209: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change
210: cn_utils.unindent(code, 1);
211: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');
204: cn_utils.appindcr(code, '''N'',');
205: cn_utils.appindcr(code, x_event_id||',');
206: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');
207: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');
208: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');
209: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change
210: cn_utils.unindent(code, 1);
211: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');
212: cn_utils.indent(code, 1);
205: cn_utils.appindcr(code, x_event_id||',');
206: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');
207: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');
208: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');
209: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change
210: cn_utils.unindent(code, 1);
211: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');
212: cn_utils.indent(code, 1);
213: cn_utils.appindcr(code, l_notify_from);
206: cn_utils.appindcr(code, l_header_key||', --*** Header Table Key Column');
207: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');
208: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');
209: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change
210: cn_utils.unindent(code, 1);
211: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');
212: cn_utils.indent(code, 1);
213: cn_utils.appindcr(code, l_notify_from);
214: cn_utils.unindent(code, 1);
207: cn_utils.appindcr(code, l_line_key||', --*** Line Table Key Column');
208: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');
209: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change
210: cn_utils.unindent(code, 1);
211: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');
212: cn_utils.indent(code, 1);
213: cn_utils.appindcr(code, l_notify_from);
214: cn_utils.unindent(code, 1);
215: cn_utils.appindcr(code, 'WHERE --*** Header.Primary_Key = Line.Foreign_Key');
208: cn_utils.appindcr(code, ''''||l_table_map_rec.mapping_type||''', --*** Source Type');
209: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change
210: cn_utils.unindent(code, 1);
211: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');
212: cn_utils.indent(code, 1);
213: cn_utils.appindcr(code, l_notify_from);
214: cn_utils.unindent(code, 1);
215: cn_utils.appindcr(code, 'WHERE --*** Header.Primary_Key = Line.Foreign_Key');
216: cn_utils.indent(code, 1);
209: cn_utils.appindcr(code, l_org_id); -- Added For R12 MOAC Change
210: cn_utils.unindent(code, 1);
211: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');
212: cn_utils.indent(code, 1);
213: cn_utils.appindcr(code, l_notify_from);
214: cn_utils.unindent(code, 1);
215: cn_utils.appindcr(code, 'WHERE --*** Header.Primary_Key = Line.Foreign_Key');
216: cn_utils.indent(code, 1);
217: cn_utils.appindcr(code, l_notify_where);
210: cn_utils.unindent(code, 1);
211: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');
212: cn_utils.indent(code, 1);
213: cn_utils.appindcr(code, l_notify_from);
214: cn_utils.unindent(code, 1);
215: cn_utils.appindcr(code, 'WHERE --*** Header.Primary_Key = Line.Foreign_Key');
216: cn_utils.indent(code, 1);
217: cn_utils.appindcr(code, l_notify_where);
218: --+
211: cn_utils.appindcr(code, 'FROM --*** Line and (optional) Header Table');
212: cn_utils.indent(code, 1);
213: cn_utils.appindcr(code, l_notify_from);
214: cn_utils.unindent(code, 1);
215: cn_utils.appindcr(code, 'WHERE --*** Header.Primary_Key = Line.Foreign_Key');
216: cn_utils.indent(code, 1);
217: cn_utils.appindcr(code, l_notify_where);
218: --+
219: -- The generated WHERE clause does not include the supplementary
212: cn_utils.indent(code, 1);
213: cn_utils.appindcr(code, l_notify_from);
214: cn_utils.unindent(code, 1);
215: cn_utils.appindcr(code, 'WHERE --*** Header.Primary_Key = Line.Foreign_Key');
216: cn_utils.indent(code, 1);
217: cn_utils.appindcr(code, l_notify_where);
218: --+
219: -- The generated WHERE clause does not include the supplementary
220: -- WHERE clause information that the user may specified, so this
213: cn_utils.appindcr(code, l_notify_from);
214: cn_utils.unindent(code, 1);
215: cn_utils.appindcr(code, 'WHERE --*** Header.Primary_Key = Line.Foreign_Key');
216: cn_utils.indent(code, 1);
217: cn_utils.appindcr(code, l_notify_where);
218: --+
219: -- The generated WHERE clause does not include the supplementary
220: -- WHERE clause information that the user may specified, so this
221: -- needs to be added on.
221: -- needs to be added on.
222: -- Before doing so, strip off trailing ';' on the clause, if one
223: -- is present
224: --+
225: cn_utils.appindcr(code, '--*** Any extra user-defined WHERE statement lines');
226: IF l_table_map_rec.notify_where IS NOT NULL THEN
227: cn_utils.appindcr(code, 'AND '||RTRIM(l_table_map_rec.notify_where,';'));
228: END IF;
229: cn_utils.appindcr(code, '--*** End of user-defined WHERE statement lines');
223: -- is present
224: --+
225: cn_utils.appindcr(code, '--*** Any extra user-defined WHERE statement lines');
226: IF l_table_map_rec.notify_where IS NOT NULL THEN
227: cn_utils.appindcr(code, 'AND '||RTRIM(l_table_map_rec.notify_where,';'));
228: END IF;
229: cn_utils.appindcr(code, '--*** End of user-defined WHERE statement lines');
230: --+
231: -- Finish off the statement
225: cn_utils.appindcr(code, '--*** Any extra user-defined WHERE statement lines');
226: IF l_table_map_rec.notify_where IS NOT NULL THEN
227: cn_utils.appindcr(code, 'AND '||RTRIM(l_table_map_rec.notify_where,';'));
228: END IF;
229: cn_utils.appindcr(code, '--*** End of user-defined WHERE statement lines');
230: --+
231: -- Finish off the statement
232: --+
233: cn_utils.appindcr(code, ' AND NOT EXISTS (');
229: cn_utils.appindcr(code, '--*** End of user-defined WHERE statement lines');
230: --+
231: -- Finish off the statement
232: --+
233: cn_utils.appindcr(code, ' AND NOT EXISTS (');
234: IF CN_COLLECTION_GEN.isParallelEnabled THEN
235: cn_utils.appindcr(code, ' SELECT /'||'*'||'+ PARALLEL(cn_not_trx) '||'*/ 1');
236: ELSE
237: cn_utils.appindcr(code, ' SELECT 1');
231: -- Finish off the statement
232: --+
233: cn_utils.appindcr(code, ' AND NOT EXISTS (');
234: IF CN_COLLECTION_GEN.isParallelEnabled THEN
235: cn_utils.appindcr(code, ' SELECT /'||'*'||'+ PARALLEL(cn_not_trx) '||'*/ 1');
236: ELSE
237: cn_utils.appindcr(code, ' SELECT 1');
238: END IF;
239: cn_utils.appindcr(code, ' FROM cn_not_trx');
233: cn_utils.appindcr(code, ' AND NOT EXISTS (');
234: IF CN_COLLECTION_GEN.isParallelEnabled THEN
235: cn_utils.appindcr(code, ' SELECT /'||'*'||'+ PARALLEL(cn_not_trx) '||'*/ 1');
236: ELSE
237: cn_utils.appindcr(code, ' SELECT 1');
238: END IF;
239: cn_utils.appindcr(code, ' FROM cn_not_trx');
240: cn_utils.appindcr(code, ' WHERE source_trx_line_id = ' || l_line_key ||' --*** Line.Primary_Key');
241: cn_utils.appindcr(code, ' AND event_id = ' || x_event_id );
235: cn_utils.appindcr(code, ' SELECT /'||'*'||'+ PARALLEL(cn_not_trx) '||'*/ 1');
236: ELSE
237: cn_utils.appindcr(code, ' SELECT 1');
238: END IF;
239: cn_utils.appindcr(code, ' FROM cn_not_trx');
240: cn_utils.appindcr(code, ' WHERE source_trx_line_id = ' || l_line_key ||' --*** Line.Primary_Key');
241: cn_utils.appindcr(code, ' AND event_id = ' || x_event_id );
242: cn_utils.appindcr(code, ' AND org_id = ' || l_org_id || ');');
243: cn_utils.unindent(code, 1);
236: ELSE
237: cn_utils.appindcr(code, ' SELECT 1');
238: END IF;
239: cn_utils.appindcr(code, ' FROM cn_not_trx');
240: cn_utils.appindcr(code, ' WHERE source_trx_line_id = ' || l_line_key ||' --*** Line.Primary_Key');
241: cn_utils.appindcr(code, ' AND event_id = ' || x_event_id );
242: cn_utils.appindcr(code, ' AND org_id = ' || l_org_id || ');');
243: cn_utils.unindent(code, 1);
244: cn_utils.appindcr(code, 'END; -- Notification Insert Block');
237: cn_utils.appindcr(code, ' SELECT 1');
238: END IF;
239: cn_utils.appindcr(code, ' FROM cn_not_trx');
240: cn_utils.appindcr(code, ' WHERE source_trx_line_id = ' || l_line_key ||' --*** Line.Primary_Key');
241: cn_utils.appindcr(code, ' AND event_id = ' || x_event_id );
242: cn_utils.appindcr(code, ' AND org_id = ' || l_org_id || ');');
243: cn_utils.unindent(code, 1);
244: cn_utils.appindcr(code, 'END; -- Notification Insert Block');
245: cn_utils.appendcr(code);
238: END IF;
239: cn_utils.appindcr(code, ' FROM cn_not_trx');
240: cn_utils.appindcr(code, ' WHERE source_trx_line_id = ' || l_line_key ||' --*** Line.Primary_Key');
241: cn_utils.appindcr(code, ' AND event_id = ' || x_event_id );
242: cn_utils.appindcr(code, ' AND org_id = ' || l_org_id || ');');
243: cn_utils.unindent(code, 1);
244: cn_utils.appindcr(code, 'END; -- Notification Insert Block');
245: cn_utils.appendcr(code);
246: cn_utils.appindcr(code, '-- Commit the notification inserts - they are permanent even if collection fails');
239: cn_utils.appindcr(code, ' FROM cn_not_trx');
240: cn_utils.appindcr(code, ' WHERE source_trx_line_id = ' || l_line_key ||' --*** Line.Primary_Key');
241: cn_utils.appindcr(code, ' AND event_id = ' || x_event_id );
242: cn_utils.appindcr(code, ' AND org_id = ' || l_org_id || ');');
243: cn_utils.unindent(code, 1);
244: cn_utils.appindcr(code, 'END; -- Notification Insert Block');
245: cn_utils.appendcr(code);
246: cn_utils.appindcr(code, '-- Commit the notification inserts - they are permanent even if collection fails');
247: cn_utils.appindcr(code, 'COMMIT;');
240: cn_utils.appindcr(code, ' WHERE source_trx_line_id = ' || l_line_key ||' --*** Line.Primary_Key');
241: cn_utils.appindcr(code, ' AND event_id = ' || x_event_id );
242: cn_utils.appindcr(code, ' AND org_id = ' || l_org_id || ');');
243: cn_utils.unindent(code, 1);
244: cn_utils.appindcr(code, 'END; -- Notification Insert Block');
245: cn_utils.appendcr(code);
246: cn_utils.appindcr(code, '-- Commit the notification inserts - they are permanent even if collection fails');
247: cn_utils.appindcr(code, 'COMMIT;');
248: cn_utils.unset_org_id();
241: cn_utils.appindcr(code, ' AND event_id = ' || x_event_id );
242: cn_utils.appindcr(code, ' AND org_id = ' || l_org_id || ');');
243: cn_utils.unindent(code, 1);
244: cn_utils.appindcr(code, 'END; -- Notification Insert Block');
245: cn_utils.appendcr(code);
246: cn_utils.appindcr(code, '-- Commit the notification inserts - they are permanent even if collection fails');
247: cn_utils.appindcr(code, 'COMMIT;');
248: cn_utils.unset_org_id();
249: cn_message_pkg.debug('*** Finished notification run ');
242: cn_utils.appindcr(code, ' AND org_id = ' || l_org_id || ');');
243: cn_utils.unindent(code, 1);
244: cn_utils.appindcr(code, 'END; -- Notification Insert Block');
245: cn_utils.appendcr(code);
246: cn_utils.appindcr(code, '-- Commit the notification inserts - they are permanent even if collection fails');
247: cn_utils.appindcr(code, 'COMMIT;');
248: cn_utils.unset_org_id();
249: cn_message_pkg.debug('*** Finished notification run ');
250: fnd_file.put_line(fnd_file.Log,'*** Finished notification run ');
243: cn_utils.unindent(code, 1);
244: cn_utils.appindcr(code, 'END; -- Notification Insert Block');
245: cn_utils.appendcr(code);
246: cn_utils.appindcr(code, '-- Commit the notification inserts - they are permanent even if collection fails');
247: cn_utils.appindcr(code, 'COMMIT;');
248: cn_utils.unset_org_id();
249: cn_message_pkg.debug('*** Finished notification run ');
250: fnd_file.put_line(fnd_file.Log,'*** Finished notification run ');
251: cn_utils.set_org_id(p_org_id => l_org_id);
244: cn_utils.appindcr(code, 'END; -- Notification Insert Block');
245: cn_utils.appendcr(code);
246: cn_utils.appindcr(code, '-- Commit the notification inserts - they are permanent even if collection fails');
247: cn_utils.appindcr(code, 'COMMIT;');
248: cn_utils.unset_org_id();
249: cn_message_pkg.debug('*** Finished notification run ');
250: fnd_file.put_line(fnd_file.Log,'*** Finished notification run ');
251: cn_utils.set_org_id(p_org_id => l_org_id);
252: cn_utils.appendcr(code);
247: cn_utils.appindcr(code, 'COMMIT;');
248: cn_utils.unset_org_id();
249: cn_message_pkg.debug('*** Finished notification run ');
250: fnd_file.put_line(fnd_file.Log,'*** Finished notification run ');
251: cn_utils.set_org_id(p_org_id => l_org_id);
252: cn_utils.appendcr(code);
253: cn_utils.appendcr(code, '--******** COLLECT AJUSTMENTS (NEGATE IN API) ********-- ');
254: cn_utils.appindcr(code, '-- This will negate those adjusted trx in the API table');
255: cn_utils.appindcr(code, 'cn_not_trx_grp.col_adjustments(p_api_version => 1.0,');
248: cn_utils.unset_org_id();
249: cn_message_pkg.debug('*** Finished notification run ');
250: fnd_file.put_line(fnd_file.Log,'*** Finished notification run ');
251: cn_utils.set_org_id(p_org_id => l_org_id);
252: cn_utils.appendcr(code);
253: cn_utils.appendcr(code, '--******** COLLECT AJUSTMENTS (NEGATE IN API) ********-- ');
254: cn_utils.appindcr(code, '-- This will negate those adjusted trx in the API table');
255: cn_utils.appindcr(code, 'cn_not_trx_grp.col_adjustments(p_api_version => 1.0,');
256: cn_utils.appindcr(code, ' x_return_status => x_return_status,');
249: cn_message_pkg.debug('*** Finished notification run ');
250: fnd_file.put_line(fnd_file.Log,'*** Finished notification run ');
251: cn_utils.set_org_id(p_org_id => l_org_id);
252: cn_utils.appendcr(code);
253: cn_utils.appendcr(code, '--******** COLLECT AJUSTMENTS (NEGATE IN API) ********-- ');
254: cn_utils.appindcr(code, '-- This will negate those adjusted trx in the API table');
255: cn_utils.appindcr(code, 'cn_not_trx_grp.col_adjustments(p_api_version => 1.0,');
256: cn_utils.appindcr(code, ' x_return_status => x_return_status,');
257: cn_utils.appindcr(code, ' x_msg_count => x_msg_count,');
250: fnd_file.put_line(fnd_file.Log,'*** Finished notification run ');
251: cn_utils.set_org_id(p_org_id => l_org_id);
252: cn_utils.appendcr(code);
253: cn_utils.appendcr(code, '--******** COLLECT AJUSTMENTS (NEGATE IN API) ********-- ');
254: cn_utils.appindcr(code, '-- This will negate those adjusted trx in the API table');
255: cn_utils.appindcr(code, 'cn_not_trx_grp.col_adjustments(p_api_version => 1.0,');
256: cn_utils.appindcr(code, ' x_return_status => x_return_status,');
257: cn_utils.appindcr(code, ' x_msg_count => x_msg_count,');
258: cn_utils.appindcr(code, ' x_msg_data => x_msg_data,');
251: cn_utils.set_org_id(p_org_id => l_org_id);
252: cn_utils.appendcr(code);
253: cn_utils.appendcr(code, '--******** COLLECT AJUSTMENTS (NEGATE IN API) ********-- ');
254: cn_utils.appindcr(code, '-- This will negate those adjusted trx in the API table');
255: cn_utils.appindcr(code, 'cn_not_trx_grp.col_adjustments(p_api_version => 1.0,');
256: cn_utils.appindcr(code, ' x_return_status => x_return_status,');
257: cn_utils.appindcr(code, ' x_msg_count => x_msg_count,');
258: cn_utils.appindcr(code, ' x_msg_data => x_msg_data,');
259: cn_utils.appindcr(code, ' p_org_id => '|| l_org_id ||');');
252: cn_utils.appendcr(code);
253: cn_utils.appendcr(code, '--******** COLLECT AJUSTMENTS (NEGATE IN API) ********-- ');
254: cn_utils.appindcr(code, '-- This will negate those adjusted trx in the API table');
255: cn_utils.appindcr(code, 'cn_not_trx_grp.col_adjustments(p_api_version => 1.0,');
256: cn_utils.appindcr(code, ' x_return_status => x_return_status,');
257: cn_utils.appindcr(code, ' x_msg_count => x_msg_count,');
258: cn_utils.appindcr(code, ' x_msg_data => x_msg_data,');
259: cn_utils.appindcr(code, ' p_org_id => '|| l_org_id ||');');
260: -- Added For R12 MOAC Changes
253: cn_utils.appendcr(code, '--******** COLLECT AJUSTMENTS (NEGATE IN API) ********-- ');
254: cn_utils.appindcr(code, '-- This will negate those adjusted trx in the API table');
255: cn_utils.appindcr(code, 'cn_not_trx_grp.col_adjustments(p_api_version => 1.0,');
256: cn_utils.appindcr(code, ' x_return_status => x_return_status,');
257: cn_utils.appindcr(code, ' x_msg_count => x_msg_count,');
258: cn_utils.appindcr(code, ' x_msg_data => x_msg_data,');
259: cn_utils.appindcr(code, ' p_org_id => '|| l_org_id ||');');
260: -- Added For R12 MOAC Changes
261: cn_utils.appendcr(code);
254: cn_utils.appindcr(code, '-- This will negate those adjusted trx in the API table');
255: cn_utils.appindcr(code, 'cn_not_trx_grp.col_adjustments(p_api_version => 1.0,');
256: cn_utils.appindcr(code, ' x_return_status => x_return_status,');
257: cn_utils.appindcr(code, ' x_msg_count => x_msg_count,');
258: cn_utils.appindcr(code, ' x_msg_data => x_msg_data,');
259: cn_utils.appindcr(code, ' p_org_id => '|| l_org_id ||');');
260: -- Added For R12 MOAC Changes
261: cn_utils.appendcr(code);
262: cn_utils.unset_org_id();
255: cn_utils.appindcr(code, 'cn_not_trx_grp.col_adjustments(p_api_version => 1.0,');
256: cn_utils.appindcr(code, ' x_return_status => x_return_status,');
257: cn_utils.appindcr(code, ' x_msg_count => x_msg_count,');
258: cn_utils.appindcr(code, ' x_msg_data => x_msg_data,');
259: cn_utils.appindcr(code, ' p_org_id => '|| l_org_id ||');');
260: -- Added For R12 MOAC Changes
261: cn_utils.appendcr(code);
262: cn_utils.unset_org_id();
263: END insert_cn_not_trx;
257: cn_utils.appindcr(code, ' x_msg_count => x_msg_count,');
258: cn_utils.appindcr(code, ' x_msg_data => x_msg_data,');
259: cn_utils.appindcr(code, ' p_org_id => '|| l_org_id ||');');
260: -- Added For R12 MOAC Changes
261: cn_utils.appendcr(code);
262: cn_utils.unset_org_id();
263: END insert_cn_not_trx;
264: --
265: -- Procedure Name
258: cn_utils.appindcr(code, ' x_msg_data => x_msg_data,');
259: cn_utils.appindcr(code, ' p_org_id => '|| l_org_id ||');');
260: -- Added For R12 MOAC Changes
261: cn_utils.appendcr(code);
262: cn_utils.unset_org_id();
263: END insert_cn_not_trx;
264: --
265: -- Procedure Name
266: -- insert_comm_lines_api_select
274: --
275: --
276: PROCEDURE insert_comm_lines_api_select(
277: x_table_map_id IN cn_table_maps_v.table_map_id%TYPE,
278: code IN OUT NOCOPY cn_utils.code_type,
279: x_org_id IN NUMBER,
280: x_parallel_hint IN VARCHAR2)
281: IS -- Added For R12 MOAC Changes
282: CURSOR api_direct_maps
295: AND ccmv.org_id = cno.org_id
296: -- Added For R12 MOAC Changes
297: ORDER BY dest_column;
298: BEGIN
299: cn_utils.set_org_id(p_org_id => x_org_id);
300: IF CN_COLLECTION_GEN.isParallelEnabled THEN
301: IF x_table_map_id > 0 THEN
302: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_comm_lines_api) */ INTO cn_comm_lines_api (');
303: ELSE
298: BEGIN
299: cn_utils.set_org_id(p_org_id => x_org_id);
300: IF CN_COLLECTION_GEN.isParallelEnabled THEN
301: IF x_table_map_id > 0 THEN
302: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_comm_lines_api) */ INTO cn_comm_lines_api (');
303: ELSE
304: cn_utils.appindcr(code, 'INSERT INTO cn_comm_lines_api (');
305: END IF;
306: ELSE
300: IF CN_COLLECTION_GEN.isParallelEnabled THEN
301: IF x_table_map_id > 0 THEN
302: cn_utils.appindcr(code, 'INSERT /'||'*+ PARALLEL(cn_comm_lines_api) */ INTO cn_comm_lines_api (');
303: ELSE
304: cn_utils.appindcr(code, 'INSERT INTO cn_comm_lines_api (');
305: END IF;
306: ELSE
307: cn_utils.appindcr(code, 'INSERT INTO cn_comm_lines_api (');
308: END IF;
303: ELSE
304: cn_utils.appindcr(code, 'INSERT INTO cn_comm_lines_api (');
305: END IF;
306: ELSE
307: cn_utils.appindcr(code, 'INSERT INTO cn_comm_lines_api (');
308: END IF;
309: cn_utils.indent(code, 1);
310: cn_utils.appindcr(code, 'comm_lines_api_id,');
311: cn_utils.appindcr(code, 'conc_batch_id,');
305: END IF;
306: ELSE
307: cn_utils.appindcr(code, 'INSERT INTO cn_comm_lines_api (');
308: END IF;
309: cn_utils.indent(code, 1);
310: cn_utils.appindcr(code, 'comm_lines_api_id,');
311: cn_utils.appindcr(code, 'conc_batch_id,');
312: cn_utils.appindcr(code, 'process_batch_id,');
313: cn_utils.appindcr(code, 'org_id,');
306: ELSE
307: cn_utils.appindcr(code, 'INSERT INTO cn_comm_lines_api (');
308: END IF;
309: cn_utils.indent(code, 1);
310: cn_utils.appindcr(code, 'comm_lines_api_id,');
311: cn_utils.appindcr(code, 'conc_batch_id,');
312: cn_utils.appindcr(code, 'process_batch_id,');
313: cn_utils.appindcr(code, 'org_id,');
314: -- Insert custom columns using api_direct_maps cursor
307: cn_utils.appindcr(code, 'INSERT INTO cn_comm_lines_api (');
308: END IF;
309: cn_utils.indent(code, 1);
310: cn_utils.appindcr(code, 'comm_lines_api_id,');
311: cn_utils.appindcr(code, 'conc_batch_id,');
312: cn_utils.appindcr(code, 'process_batch_id,');
313: cn_utils.appindcr(code, 'org_id,');
314: -- Insert custom columns using api_direct_maps cursor
315: cn_utils.appindcr(code, '--*** Direct Mapping Destination Columns');
308: END IF;
309: cn_utils.indent(code, 1);
310: cn_utils.appindcr(code, 'comm_lines_api_id,');
311: cn_utils.appindcr(code, 'conc_batch_id,');
312: cn_utils.appindcr(code, 'process_batch_id,');
313: cn_utils.appindcr(code, 'org_id,');
314: -- Insert custom columns using api_direct_maps cursor
315: cn_utils.appindcr(code, '--*** Direct Mapping Destination Columns');
316: FOR l IN api_direct_maps
309: cn_utils.indent(code, 1);
310: cn_utils.appindcr(code, 'comm_lines_api_id,');
311: cn_utils.appindcr(code, 'conc_batch_id,');
312: cn_utils.appindcr(code, 'process_batch_id,');
313: cn_utils.appindcr(code, 'org_id,');
314: -- Insert custom columns using api_direct_maps cursor
315: cn_utils.appindcr(code, '--*** Direct Mapping Destination Columns');
316: FOR l IN api_direct_maps
317: LOOP
311: cn_utils.appindcr(code, 'conc_batch_id,');
312: cn_utils.appindcr(code, 'process_batch_id,');
313: cn_utils.appindcr(code, 'org_id,');
314: -- Insert custom columns using api_direct_maps cursor
315: cn_utils.appindcr(code, '--*** Direct Mapping Destination Columns');
316: FOR l IN api_direct_maps
317: LOOP
318: cn_utils.appindcr(code, l.dest_column || ',');
319: END LOOP;
314: -- Insert custom columns using api_direct_maps cursor
315: cn_utils.appindcr(code, '--*** Direct Mapping Destination Columns');
316: FOR l IN api_direct_maps
317: LOOP
318: cn_utils.appindcr(code, l.dest_column || ',');
319: END LOOP;
320: --Changing the number of places to shift to 2 cos of introduction of new char
321: cn_utils.strip_prev(code, 1); -- remove trailing comma
322: cn_utils.appindcr(code, ')');
317: LOOP
318: cn_utils.appindcr(code, l.dest_column || ',');
319: END LOOP;
320: --Changing the number of places to shift to 2 cos of introduction of new char
321: cn_utils.strip_prev(code, 1); -- remove trailing comma
322: cn_utils.appindcr(code, ')');
323: cn_utils.unindent(code, 1);
324: -- Generate the SELECT clause for the insert statement
325: IF CN_COLLECTION_GEN.isParallelEnabled THEN
318: cn_utils.appindcr(code, l.dest_column || ',');
319: END LOOP;
320: --Changing the number of places to shift to 2 cos of introduction of new char
321: cn_utils.strip_prev(code, 1); -- remove trailing comma
322: cn_utils.appindcr(code, ')');
323: cn_utils.unindent(code, 1);
324: -- Generate the SELECT clause for the insert statement
325: IF CN_COLLECTION_GEN.isParallelEnabled THEN
326: cn_utils.appindcr(code, 'SELECT '||x_parallel_hint);
319: END LOOP;
320: --Changing the number of places to shift to 2 cos of introduction of new char
321: cn_utils.strip_prev(code, 1); -- remove trailing comma
322: cn_utils.appindcr(code, ')');
323: cn_utils.unindent(code, 1);
324: -- Generate the SELECT clause for the insert statement
325: IF CN_COLLECTION_GEN.isParallelEnabled THEN
326: cn_utils.appindcr(code, 'SELECT '||x_parallel_hint);
327: ELSE
322: cn_utils.appindcr(code, ')');
323: cn_utils.unindent(code, 1);
324: -- Generate the SELECT clause for the insert statement
325: IF CN_COLLECTION_GEN.isParallelEnabled THEN
326: cn_utils.appindcr(code, 'SELECT '||x_parallel_hint);
327: ELSE
328: cn_utils.appindcr(code, 'SELECT ');
329: END IF;
330: cn_utils.indent(code, 1);
324: -- Generate the SELECT clause for the insert statement
325: IF CN_COLLECTION_GEN.isParallelEnabled THEN
326: cn_utils.appindcr(code, 'SELECT '||x_parallel_hint);
327: ELSE
328: cn_utils.appindcr(code, 'SELECT ');
329: END IF;
330: cn_utils.indent(code, 1);
331: cn_utils.appindcr(code, 'cn_comm_lines_api_s.NEXTVAL,');
332: cn_utils.appindcr(code, 'x_conc_program_id,');
326: cn_utils.appindcr(code, 'SELECT '||x_parallel_hint);
327: ELSE
328: cn_utils.appindcr(code, 'SELECT ');
329: END IF;
330: cn_utils.indent(code, 1);
331: cn_utils.appindcr(code, 'cn_comm_lines_api_s.NEXTVAL,');
332: cn_utils.appindcr(code, 'x_conc_program_id,');
333: cn_utils.appindcr(code, 'x_batch_id,');
334: cn_utils.appindcr(code, x_org_id||',');
327: ELSE
328: cn_utils.appindcr(code, 'SELECT ');
329: END IF;
330: cn_utils.indent(code, 1);
331: cn_utils.appindcr(code, 'cn_comm_lines_api_s.NEXTVAL,');
332: cn_utils.appindcr(code, 'x_conc_program_id,');
333: cn_utils.appindcr(code, 'x_batch_id,');
334: cn_utils.appindcr(code, x_org_id||',');
335: -- Select other columns using the api_direct_maps cursors. Note that
328: cn_utils.appindcr(code, 'SELECT ');
329: END IF;
330: cn_utils.indent(code, 1);
331: cn_utils.appindcr(code, 'cn_comm_lines_api_s.NEXTVAL,');
332: cn_utils.appindcr(code, 'x_conc_program_id,');
333: cn_utils.appindcr(code, 'x_batch_id,');
334: cn_utils.appindcr(code, x_org_id||',');
335: -- Select other columns using the api_direct_maps cursors. Note that
336: -- we fetch the records in the cursor in the same order as before due to
329: END IF;
330: cn_utils.indent(code, 1);
331: cn_utils.appindcr(code, 'cn_comm_lines_api_s.NEXTVAL,');
332: cn_utils.appindcr(code, 'x_conc_program_id,');
333: cn_utils.appindcr(code, 'x_batch_id,');
334: cn_utils.appindcr(code, x_org_id||',');
335: -- Select other columns using the api_direct_maps cursors. Note that
336: -- we fetch the records in the cursor in the same order as before due to
337: -- the order by column_id in the cursor where clause.
330: cn_utils.indent(code, 1);
331: cn_utils.appindcr(code, 'cn_comm_lines_api_s.NEXTVAL,');
332: cn_utils.appindcr(code, 'x_conc_program_id,');
333: cn_utils.appindcr(code, 'x_batch_id,');
334: cn_utils.appindcr(code, x_org_id||',');
335: -- Select other columns using the api_direct_maps cursors. Note that
336: -- we fetch the records in the cursor in the same order as before due to
337: -- the order by column_id in the cursor where clause.
338: cn_utils.appindcr(code, '--*** Direct Mapping Source Expressions');
334: cn_utils.appindcr(code, x_org_id||',');
335: -- Select other columns using the api_direct_maps cursors. Note that
336: -- we fetch the records in the cursor in the same order as before due to
337: -- the order by column_id in the cursor where clause.
338: cn_utils.appindcr(code, '--*** Direct Mapping Source Expressions');
339: FOR l IN api_direct_maps
340: LOOP
341: -- R12 Related Changes
342: IF (l.column_map_id = -1083) THEN
344: END IF;
345: IF (l.column_map_id = -1092 OR l.column_map_id = -1093) THEN
346: l.expression := RTRIM(l.expression,')},')||','||x_org_id||')';
347: END IF;
348: cn_utils.appindcr(code, l.expression || ',');
349: END LOOP;
350: cn_utils.strip_prev(code, 1); -- remove trailing comma
351: cn_utils.appendcr(code);
352: cn_utils.unindent(code, 1);
346: l.expression := RTRIM(l.expression,')},')||','||x_org_id||')';
347: END IF;
348: cn_utils.appindcr(code, l.expression || ',');
349: END LOOP;
350: cn_utils.strip_prev(code, 1); -- remove trailing comma
351: cn_utils.appendcr(code);
352: cn_utils.unindent(code, 1);
353: cn_utils.unset_org_id();
354: END insert_comm_lines_api_select;
347: END IF;
348: cn_utils.appindcr(code, l.expression || ',');
349: END LOOP;
350: cn_utils.strip_prev(code, 1); -- remove trailing comma
351: cn_utils.appendcr(code);
352: cn_utils.unindent(code, 1);
353: cn_utils.unset_org_id();
354: END insert_comm_lines_api_select;
355: --
348: cn_utils.appindcr(code, l.expression || ',');
349: END LOOP;
350: cn_utils.strip_prev(code, 1); -- remove trailing comma
351: cn_utils.appendcr(code);
352: cn_utils.unindent(code, 1);
353: cn_utils.unset_org_id();
354: END insert_comm_lines_api_select;
355: --
356: -- Procedure Name
349: END LOOP;
350: cn_utils.strip_prev(code, 1); -- remove trailing comma
351: cn_utils.appendcr(code);
352: cn_utils.unindent(code, 1);
353: cn_utils.unset_org_id();
354: END insert_comm_lines_api_select;
355: --
356: -- Procedure Name
357: -- insert_comm_lines_api
364: --
365: PROCEDURE insert_comm_lines_api(
366: x_table_map_id cn_table_maps.table_map_id%TYPE,
367: x_event_id cn_events.event_id%TYPE,
368: code IN OUT NOCOPY cn_utils.code_type,
369: x_org_id IN NUMBER)
370: IS
371: l_return_status VARCHAR2(4000);
372: l_msg_count NUMBER;
411: END IF;
412: --+
413: -- Generate the Collection Process code
414: --+
415: cn_utils.set_org_id(p_org_id => X_org_id);
416: cn_utils.appendcr(code);
417: cn_utils.appendcr(code, '--******** INSERT CN_COMM_LINES_API *********-- ');
418: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserting into CN_COMM_LINES_API.'');');
419: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''Inserting into CN_COMM_LINES_API.'');');
412: --+
413: -- Generate the Collection Process code
414: --+
415: cn_utils.set_org_id(p_org_id => X_org_id);
416: cn_utils.appendcr(code);
417: cn_utils.appendcr(code, '--******** INSERT CN_COMM_LINES_API *********-- ');
418: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserting into CN_COMM_LINES_API.'');');
419: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''Inserting into CN_COMM_LINES_API.'');');
420: cn_utils.appendcr(code);
413: -- Generate the Collection Process code
414: --+
415: cn_utils.set_org_id(p_org_id => X_org_id);
416: cn_utils.appendcr(code);
417: cn_utils.appendcr(code, '--******** INSERT CN_COMM_LINES_API *********-- ');
418: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserting into CN_COMM_LINES_API.'');');
419: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''Inserting into CN_COMM_LINES_API.'');');
420: cn_utils.appendcr(code);
421: --+
414: --+
415: cn_utils.set_org_id(p_org_id => X_org_id);
416: cn_utils.appendcr(code);
417: cn_utils.appendcr(code, '--******** INSERT CN_COMM_LINES_API *********-- ');
418: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserting into CN_COMM_LINES_API.'');');
419: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''Inserting into CN_COMM_LINES_API.'');');
420: cn_utils.appendcr(code);
421: --+
422: -- Generate the INSERT INTO API .. SELECT portion of
415: cn_utils.set_org_id(p_org_id => X_org_id);
416: cn_utils.appendcr(code);
417: cn_utils.appendcr(code, '--******** INSERT CN_COMM_LINES_API *********-- ');
418: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserting into CN_COMM_LINES_API.'');');
419: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''Inserting into CN_COMM_LINES_API.'');');
420: cn_utils.appendcr(code);
421: --+
422: -- Generate the INSERT INTO API .. SELECT portion of
423: -- the statement
416: cn_utils.appendcr(code);
417: cn_utils.appendcr(code, '--******** INSERT CN_COMM_LINES_API *********-- ');
418: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserting into CN_COMM_LINES_API.'');');
419: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''Inserting into CN_COMM_LINES_API.'');');
420: cn_utils.appendcr(code);
421: --+
422: -- Generate the INSERT INTO API .. SELECT portion of
423: -- the statement
424: --+
421: --+
422: -- Generate the INSERT INTO API .. SELECT portion of
423: -- the statement
424: --+
425: cn_utils.appindcr(code, '--');
426: cn_utils.appindcr(code, '-- Insert new lines into CN_COMM_LINES_API');
427: cn_utils.appindcr(code, '--');
428: cn_utils.unset_org_id();
429: -- Change for Bug 6203234
422: -- Generate the INSERT INTO API .. SELECT portion of
423: -- the statement
424: --+
425: cn_utils.appindcr(code, '--');
426: cn_utils.appindcr(code, '-- Insert new lines into CN_COMM_LINES_API');
427: cn_utils.appindcr(code, '--');
428: cn_utils.unset_org_id();
429: -- Change for Bug 6203234
430: insert_comm_lines_api_select(x_table_map_id, code, X_org_id, l_parallel_hint);
423: -- the statement
424: --+
425: cn_utils.appindcr(code, '--');
426: cn_utils.appindcr(code, '-- Insert new lines into CN_COMM_LINES_API');
427: cn_utils.appindcr(code, '--');
428: cn_utils.unset_org_id();
429: -- Change for Bug 6203234
430: insert_comm_lines_api_select(x_table_map_id, code, X_org_id, l_parallel_hint);
431: cn_utils.set_org_id(p_org_id => l_org_id);
424: --+
425: cn_utils.appindcr(code, '--');
426: cn_utils.appindcr(code, '-- Insert new lines into CN_COMM_LINES_API');
427: cn_utils.appindcr(code, '--');
428: cn_utils.unset_org_id();
429: -- Change for Bug 6203234
430: insert_comm_lines_api_select(x_table_map_id, code, X_org_id, l_parallel_hint);
431: cn_utils.set_org_id(p_org_id => l_org_id);
432: cn_utils.appindcr(code, 'FROM --*** Line, (optional) Header, and any Extra Collection Tables');
427: cn_utils.appindcr(code, '--');
428: cn_utils.unset_org_id();
429: -- Change for Bug 6203234
430: insert_comm_lines_api_select(x_table_map_id, code, X_org_id, l_parallel_hint);
431: cn_utils.set_org_id(p_org_id => l_org_id);
432: cn_utils.appindcr(code, 'FROM --*** Line, (optional) Header, and any Extra Collection Tables');
433: cn_utils.indent(code, 1);
434: cn_utils.appindcr(code, l_collect_from);
435: cn_utils.unindent(code, 1);
428: cn_utils.unset_org_id();
429: -- Change for Bug 6203234
430: insert_comm_lines_api_select(x_table_map_id, code, X_org_id, l_parallel_hint);
431: cn_utils.set_org_id(p_org_id => l_org_id);
432: cn_utils.appindcr(code, 'FROM --*** Line, (optional) Header, and any Extra Collection Tables');
433: cn_utils.indent(code, 1);
434: cn_utils.appindcr(code, l_collect_from);
435: cn_utils.unindent(code, 1);
436: cn_utils.appindcr(code, 'WHERE');
429: -- Change for Bug 6203234
430: insert_comm_lines_api_select(x_table_map_id, code, X_org_id, l_parallel_hint);
431: cn_utils.set_org_id(p_org_id => l_org_id);
432: cn_utils.appindcr(code, 'FROM --*** Line, (optional) Header, and any Extra Collection Tables');
433: cn_utils.indent(code, 1);
434: cn_utils.appindcr(code, l_collect_from);
435: cn_utils.unindent(code, 1);
436: cn_utils.appindcr(code, 'WHERE');
437: cn_utils.appindcr(code, '--*** Line.Primary_Key = cnt.source_trx_line_id AND (optional) Header.Primary_Key = cnt.source_trx_id');
430: insert_comm_lines_api_select(x_table_map_id, code, X_org_id, l_parallel_hint);
431: cn_utils.set_org_id(p_org_id => l_org_id);
432: cn_utils.appindcr(code, 'FROM --*** Line, (optional) Header, and any Extra Collection Tables');
433: cn_utils.indent(code, 1);
434: cn_utils.appindcr(code, l_collect_from);
435: cn_utils.unindent(code, 1);
436: cn_utils.appindcr(code, 'WHERE');
437: cn_utils.appindcr(code, '--*** Line.Primary_Key = cnt.source_trx_line_id AND (optional) Header.Primary_Key = cnt.source_trx_id');
438: cn_utils.indent(code, 1);
431: cn_utils.set_org_id(p_org_id => l_org_id);
432: cn_utils.appindcr(code, 'FROM --*** Line, (optional) Header, and any Extra Collection Tables');
433: cn_utils.indent(code, 1);
434: cn_utils.appindcr(code, l_collect_from);
435: cn_utils.unindent(code, 1);
436: cn_utils.appindcr(code, 'WHERE');
437: cn_utils.appindcr(code, '--*** Line.Primary_Key = cnt.source_trx_line_id AND (optional) Header.Primary_Key = cnt.source_trx_id');
438: cn_utils.indent(code, 1);
439: cn_utils.appindcr(code, l_collect_where);
432: cn_utils.appindcr(code, 'FROM --*** Line, (optional) Header, and any Extra Collection Tables');
433: cn_utils.indent(code, 1);
434: cn_utils.appindcr(code, l_collect_from);
435: cn_utils.unindent(code, 1);
436: cn_utils.appindcr(code, 'WHERE');
437: cn_utils.appindcr(code, '--*** Line.Primary_Key = cnt.source_trx_line_id AND (optional) Header.Primary_Key = cnt.source_trx_id');
438: cn_utils.indent(code, 1);
439: cn_utils.appindcr(code, l_collect_where);
440: --+
433: cn_utils.indent(code, 1);
434: cn_utils.appindcr(code, l_collect_from);
435: cn_utils.unindent(code, 1);
436: cn_utils.appindcr(code, 'WHERE');
437: cn_utils.appindcr(code, '--*** Line.Primary_Key = cnt.source_trx_line_id AND (optional) Header.Primary_Key = cnt.source_trx_id');
438: cn_utils.indent(code, 1);
439: cn_utils.appindcr(code, l_collect_where);
440: --+
441: -- The generated WHERE clause does not include the supplementary
434: cn_utils.appindcr(code, l_collect_from);
435: cn_utils.unindent(code, 1);
436: cn_utils.appindcr(code, 'WHERE');
437: cn_utils.appindcr(code, '--*** Line.Primary_Key = cnt.source_trx_line_id AND (optional) Header.Primary_Key = cnt.source_trx_id');
438: cn_utils.indent(code, 1);
439: cn_utils.appindcr(code, l_collect_where);
440: --+
441: -- The generated WHERE clause does not include the supplementary
442: -- WHERE clause information that the user may specified, so this
435: cn_utils.unindent(code, 1);
436: cn_utils.appindcr(code, 'WHERE');
437: cn_utils.appindcr(code, '--*** Line.Primary_Key = cnt.source_trx_line_id AND (optional) Header.Primary_Key = cnt.source_trx_id');
438: cn_utils.indent(code, 1);
439: cn_utils.appindcr(code, l_collect_where);
440: --+
441: -- The generated WHERE clause does not include the supplementary
442: -- WHERE clause information that the user may specified, so this
443: -- needs to be added on.
443: -- needs to be added on.
444: -- Before doing so, strip off trailing ';' on the clause, if one
445: -- is present
446: --+
447: cn_utils.appindcr(code, '--*** Any extra user-defined WHERE statement lines');
448: IF l_table_map_rec.collect_where IS NOT NULL THEN
449: cn_utils.appindcr(code, 'AND '||RTRIM(l_table_map_rec.collect_where,';'));
450: END IF;
451: cn_utils.appindcr(code, '--*** End of user-defined WHERE statement lines');
445: -- is present
446: --+
447: cn_utils.appindcr(code, '--*** Any extra user-defined WHERE statement lines');
448: IF l_table_map_rec.collect_where IS NOT NULL THEN
449: cn_utils.appindcr(code, 'AND '||RTRIM(l_table_map_rec.collect_where,';'));
450: END IF;
451: cn_utils.appindcr(code, '--*** End of user-defined WHERE statement lines');
452: --+
453: -- Finish off the statement
447: cn_utils.appindcr(code, '--*** Any extra user-defined WHERE statement lines');
448: IF l_table_map_rec.collect_where IS NOT NULL THEN
449: cn_utils.appindcr(code, 'AND '||RTRIM(l_table_map_rec.collect_where,';'));
450: END IF;
451: cn_utils.appindcr(code, '--*** End of user-defined WHERE statement lines');
452: --+
453: -- Finish off the statement
454: --+
455: cn_utils.appindcr(code, ' AND cnt.event_id = ' || x_event_id);
451: cn_utils.appindcr(code, '--*** End of user-defined WHERE statement lines');
452: --+
453: -- Finish off the statement
454: --+
455: cn_utils.appindcr(code, ' AND cnt.event_id = ' || x_event_id);
456: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
457: cn_utils.appindcr(code, ' AND cnt.batch_id = x_batch_id');
458: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id ||' ;');
459: cn_utils.unindent(code, 1);
452: --+
453: -- Finish off the statement
454: --+
455: cn_utils.appindcr(code, ' AND cnt.event_id = ' || x_event_id);
456: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
457: cn_utils.appindcr(code, ' AND cnt.batch_id = x_batch_id');
458: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id ||' ;');
459: cn_utils.unindent(code, 1);
460: cn_utils.appendcr(code);
453: -- Finish off the statement
454: --+
455: cn_utils.appindcr(code, ' AND cnt.event_id = ' || x_event_id);
456: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
457: cn_utils.appindcr(code, ' AND cnt.batch_id = x_batch_id');
458: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id ||' ;');
459: cn_utils.unindent(code, 1);
460: cn_utils.appendcr(code);
461: cn_utils.appindcr(code, 'comm_lines_api_count := SQL%ROWCOUNT;');
454: --+
455: cn_utils.appindcr(code, ' AND cnt.event_id = ' || x_event_id);
456: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
457: cn_utils.appindcr(code, ' AND cnt.batch_id = x_batch_id');
458: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id ||' ;');
459: cn_utils.unindent(code, 1);
460: cn_utils.appendcr(code);
461: cn_utils.appindcr(code, 'comm_lines_api_count := SQL%ROWCOUNT;');
462: cn_utils.appendcr(code);
455: cn_utils.appindcr(code, ' AND cnt.event_id = ' || x_event_id);
456: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
457: cn_utils.appindcr(code, ' AND cnt.batch_id = x_batch_id');
458: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id ||' ;');
459: cn_utils.unindent(code, 1);
460: cn_utils.appendcr(code);
461: cn_utils.appindcr(code, 'comm_lines_api_count := SQL%ROWCOUNT;');
462: cn_utils.appendcr(code);
463: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
456: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
457: cn_utils.appindcr(code, ' AND cnt.batch_id = x_batch_id');
458: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id ||' ;');
459: cn_utils.unindent(code, 1);
460: cn_utils.appendcr(code);
461: cn_utils.appindcr(code, 'comm_lines_api_count := SQL%ROWCOUNT;');
462: cn_utils.appendcr(code);
463: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
464: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
457: cn_utils.appindcr(code, ' AND cnt.batch_id = x_batch_id');
458: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id ||' ;');
459: cn_utils.unindent(code, 1);
460: cn_utils.appendcr(code);
461: cn_utils.appindcr(code, 'comm_lines_api_count := SQL%ROWCOUNT;');
462: cn_utils.appendcr(code);
463: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
464: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
465: cn_utils.appendcr(code);
458: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id ||' ;');
459: cn_utils.unindent(code, 1);
460: cn_utils.appendcr(code);
461: cn_utils.appindcr(code, 'comm_lines_api_count := SQL%ROWCOUNT;');
462: cn_utils.appendcr(code);
463: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
464: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
465: cn_utils.appendcr(code);
466: cn_utils.appendcr(code);
459: cn_utils.unindent(code, 1);
460: cn_utils.appendcr(code);
461: cn_utils.appindcr(code, 'comm_lines_api_count := SQL%ROWCOUNT;');
462: cn_utils.appendcr(code);
463: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
464: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
465: cn_utils.appendcr(code);
466: cn_utils.appendcr(code);
467: -- Update the collected_flag in CN_NOT_TRX
460: cn_utils.appendcr(code);
461: cn_utils.appindcr(code, 'comm_lines_api_count := SQL%ROWCOUNT;');
462: cn_utils.appendcr(code);
463: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
464: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
465: cn_utils.appendcr(code);
466: cn_utils.appendcr(code);
467: -- Update the collected_flag in CN_NOT_TRX
468: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updating collected_flag in CN_NOT_TRX .'');');
461: cn_utils.appindcr(code, 'comm_lines_api_count := SQL%ROWCOUNT;');
462: cn_utils.appendcr(code);
463: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
464: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
465: cn_utils.appendcr(code);
466: cn_utils.appendcr(code);
467: -- Update the collected_flag in CN_NOT_TRX
468: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updating collected_flag in CN_NOT_TRX .'');');
469: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Updating collected_flag in CN_NOT_TRX .'');');
462: cn_utils.appendcr(code);
463: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
464: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
465: cn_utils.appendcr(code);
466: cn_utils.appendcr(code);
467: -- Update the collected_flag in CN_NOT_TRX
468: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updating collected_flag in CN_NOT_TRX .'');');
469: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Updating collected_flag in CN_NOT_TRX .'');');
470: cn_utils.appendcr(code);
464: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Inserted '' || comm_lines_api_count || '' line records into CN_COMM_LINES_API.'');');
465: cn_utils.appendcr(code);
466: cn_utils.appendcr(code);
467: -- Update the collected_flag in CN_NOT_TRX
468: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updating collected_flag in CN_NOT_TRX .'');');
469: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Updating collected_flag in CN_NOT_TRX .'');');
470: cn_utils.appendcr(code);
471: IF CN_COLLECTION_GEN.isParallelEnabled THEN
472: cn_utils.appindcr(code, 'UPDATE /'||'*+ PARALLEL(cnt) */ cn_not_trx cnt');
465: cn_utils.appendcr(code);
466: cn_utils.appendcr(code);
467: -- Update the collected_flag in CN_NOT_TRX
468: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updating collected_flag in CN_NOT_TRX .'');');
469: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Updating collected_flag in CN_NOT_TRX .'');');
470: cn_utils.appendcr(code);
471: IF CN_COLLECTION_GEN.isParallelEnabled THEN
472: cn_utils.appindcr(code, 'UPDATE /'||'*+ PARALLEL(cnt) */ cn_not_trx cnt');
473: ELSE
466: cn_utils.appendcr(code);
467: -- Update the collected_flag in CN_NOT_TRX
468: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updating collected_flag in CN_NOT_TRX .'');');
469: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Updating collected_flag in CN_NOT_TRX .'');');
470: cn_utils.appendcr(code);
471: IF CN_COLLECTION_GEN.isParallelEnabled THEN
472: cn_utils.appindcr(code, 'UPDATE /'||'*+ PARALLEL(cnt) */ cn_not_trx cnt');
473: ELSE
474: cn_utils.appindcr(code, 'UPDATE cn_not_trx cnt');
468: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updating collected_flag in CN_NOT_TRX .'');');
469: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log,''Updating collected_flag in CN_NOT_TRX .'');');
470: cn_utils.appendcr(code);
471: IF CN_COLLECTION_GEN.isParallelEnabled THEN
472: cn_utils.appindcr(code, 'UPDATE /'||'*+ PARALLEL(cnt) */ cn_not_trx cnt');
473: ELSE
474: cn_utils.appindcr(code, 'UPDATE cn_not_trx cnt');
475: END IF;
476: cn_utils.appindcr(code, ' SET collected_flag = ''Y''');
470: cn_utils.appendcr(code);
471: IF CN_COLLECTION_GEN.isParallelEnabled THEN
472: cn_utils.appindcr(code, 'UPDATE /'||'*+ PARALLEL(cnt) */ cn_not_trx cnt');
473: ELSE
474: cn_utils.appindcr(code, 'UPDATE cn_not_trx cnt');
475: END IF;
476: cn_utils.appindcr(code, ' SET collected_flag = ''Y''');
477: cn_utils.appindcr(code, ' WHERE cnt.event_id = '|| x_event_id);
478: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
472: cn_utils.appindcr(code, 'UPDATE /'||'*+ PARALLEL(cnt) */ cn_not_trx cnt');
473: ELSE
474: cn_utils.appindcr(code, 'UPDATE cn_not_trx cnt');
475: END IF;
476: cn_utils.appindcr(code, ' SET collected_flag = ''Y''');
477: cn_utils.appindcr(code, ' WHERE cnt.event_id = '|| x_event_id);
478: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
479: cn_utils.appindcr(code, ' AND cnt.batch_id = x_batch_id');
480: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id||' ;');
473: ELSE
474: cn_utils.appindcr(code, 'UPDATE cn_not_trx cnt');
475: END IF;
476: cn_utils.appindcr(code, ' SET collected_flag = ''Y''');
477: cn_utils.appindcr(code, ' WHERE cnt.event_id = '|| x_event_id);
478: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
479: cn_utils.appindcr(code, ' AND cnt.batch_id = x_batch_id');
480: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id||' ;');
481: cn_utils.appendcr(code);
474: cn_utils.appindcr(code, 'UPDATE cn_not_trx cnt');
475: END IF;
476: cn_utils.appindcr(code, ' SET collected_flag = ''Y''');
477: cn_utils.appindcr(code, ' WHERE cnt.event_id = '|| x_event_id);
478: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
479: cn_utils.appindcr(code, ' AND cnt.batch_id = x_batch_id');
480: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id||' ;');
481: cn_utils.appendcr(code);
482: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updated collected_flag in cn_not_trx.'');');
475: END IF;
476: cn_utils.appindcr(code, ' SET collected_flag = ''Y''');
477: cn_utils.appindcr(code, ' WHERE cnt.event_id = '|| x_event_id);
478: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
479: cn_utils.appindcr(code, ' AND cnt.batch_id = x_batch_id');
480: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id||' ;');
481: cn_utils.appendcr(code);
482: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updated collected_flag in cn_not_trx.'');');
483: IF CN_COLLECTION_GEN.isParallelEnabled THEN
476: cn_utils.appindcr(code, ' SET collected_flag = ''Y''');
477: cn_utils.appindcr(code, ' WHERE cnt.event_id = '|| x_event_id);
478: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
479: cn_utils.appindcr(code, ' AND cnt.batch_id = x_batch_id');
480: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id||' ;');
481: cn_utils.appendcr(code);
482: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updated collected_flag in cn_not_trx.'');');
483: IF CN_COLLECTION_GEN.isParallelEnabled THEN
484: cn_utils.appindcr(code, 'COMMIT;');
477: cn_utils.appindcr(code, ' WHERE cnt.event_id = '|| x_event_id);
478: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
479: cn_utils.appindcr(code, ' AND cnt.batch_id = x_batch_id');
480: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id||' ;');
481: cn_utils.appendcr(code);
482: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updated collected_flag in cn_not_trx.'');');
483: IF CN_COLLECTION_GEN.isParallelEnabled THEN
484: cn_utils.appindcr(code, 'COMMIT;');
485: END IF;
478: cn_utils.appindcr(code, ' AND cnt.collected_flag = ''N''');
479: cn_utils.appindcr(code, ' AND cnt.batch_id = x_batch_id');
480: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id||' ;');
481: cn_utils.appendcr(code);
482: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updated collected_flag in cn_not_trx.'');');
483: IF CN_COLLECTION_GEN.isParallelEnabled THEN
484: cn_utils.appindcr(code, 'COMMIT;');
485: END IF;
486: cn_utils.appendcr(code);
480: cn_utils.appindcr(code, ' AND cnt.org_id = '||l_org_id||' ;');
481: cn_utils.appendcr(code);
482: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updated collected_flag in cn_not_trx.'');');
483: IF CN_COLLECTION_GEN.isParallelEnabled THEN
484: cn_utils.appindcr(code, 'COMMIT;');
485: END IF;
486: cn_utils.appendcr(code);
487: cn_utils.unset_org_id();
488: EXCEPTION
482: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Updated collected_flag in cn_not_trx.'');');
483: IF CN_COLLECTION_GEN.isParallelEnabled THEN
484: cn_utils.appindcr(code, 'COMMIT;');
485: END IF;
486: cn_utils.appendcr(code);
487: cn_utils.unset_org_id();
488: EXCEPTION
489: WHEN NO_DATA_FOUND THEN
490: cn_debug.print_msg('insert_lines: in exception handler for NO_DATA_FOUND',1);
483: IF CN_COLLECTION_GEN.isParallelEnabled THEN
484: cn_utils.appindcr(code, 'COMMIT;');
485: END IF;
486: cn_utils.appendcr(code);
487: cn_utils.unset_org_id();
488: EXCEPTION
489: WHEN NO_DATA_FOUND THEN
490: cn_debug.print_msg('insert_lines: in exception handler for NO_DATA_FOUND',1);
491: fnd_file.put_line(fnd_file.Log, 'insert_lines: in exception handler for NO_DATA_FOUND');
502: -- 16-Mar-00 Dave Maskell Created
503: --
504: PROCEDURE update_comm_lines_api(
505: x_table_map_id cn_table_maps.table_map_id%TYPE,
506: code IN OUT NOCOPY cn_utils.code_type,
507: x_org_id IN NUMBER,
508: x_event_id IN NUMBER DEFAULT NULL,
509: x_generic IN BOOLEAN DEFAULT NULL)
510: IS
540: AND obj.org_id(+) = ext.org_id
541: ORDER BY destcol.name;
542: BEGIN
543: -- MO_GLOBAL.INIT('CN');
544: cn_utils.set_org_id(x_org_id);
545: cn_utils.appendcr(code);
546: cn_utils.appendcr(code, '--******** UPDATE CN_COMM_LINES_API ********-- ');
547: cn_utils.appindcr(code, '--*** Update columns populated by all INDIRECT mappings');
548: --+
541: ORDER BY destcol.name;
542: BEGIN
543: -- MO_GLOBAL.INIT('CN');
544: cn_utils.set_org_id(x_org_id);
545: cn_utils.appendcr(code);
546: cn_utils.appendcr(code, '--******** UPDATE CN_COMM_LINES_API ********-- ');
547: cn_utils.appindcr(code, '--*** Update columns populated by all INDIRECT mappings');
548: --+
549: -- Get name and alias of destination table (should be 'cn_comm_lines_api' and 'api')
542: BEGIN
543: -- MO_GLOBAL.INIT('CN');
544: cn_utils.set_org_id(x_org_id);
545: cn_utils.appendcr(code);
546: cn_utils.appendcr(code, '--******** UPDATE CN_COMM_LINES_API ********-- ');
547: cn_utils.appindcr(code, '--*** Update columns populated by all INDIRECT mappings');
548: --+
549: -- Get name and alias of destination table (should be 'cn_comm_lines_api' and 'api')
550: --+
543: -- MO_GLOBAL.INIT('CN');
544: cn_utils.set_org_id(x_org_id);
545: cn_utils.appendcr(code);
546: cn_utils.appendcr(code, '--******** UPDATE CN_COMM_LINES_API ********-- ');
547: cn_utils.appindcr(code, '--*** Update columns populated by all INDIRECT mappings');
548: --+
549: -- Get name and alias of destination table (should be 'cn_comm_lines_api' and 'api')
550: --+
551: -- SELECT
585: IF x_row_count >0 THEN
586: --+
587: -- There are some mappings so generate the statement.
588: --+
589: cn_utils.appindcr(code, 'UPDATE ' || x_dest_table_name || ' ' || x_dest_alias);
590: cn_utils.appindcr(code, ' SET');
591: cn_utils.indent(code, 1);
592: FOR indmap_rec IN indmap
593: LOOP
586: --+
587: -- There are some mappings so generate the statement.
588: --+
589: cn_utils.appindcr(code, 'UPDATE ' || x_dest_table_name || ' ' || x_dest_alias);
590: cn_utils.appindcr(code, ' SET');
591: cn_utils.indent(code, 1);
592: FOR indmap_rec IN indmap
593: LOOP
594: cn_utils.appindcr(code, indmap_rec.dest_column || ' = ( --*** Indirect Mapping Destination Column');
587: -- There are some mappings so generate the statement.
588: --+
589: cn_utils.appindcr(code, 'UPDATE ' || x_dest_table_name || ' ' || x_dest_alias);
590: cn_utils.appindcr(code, ' SET');
591: cn_utils.indent(code, 1);
592: FOR indmap_rec IN indmap
593: LOOP
594: cn_utils.appindcr(code, indmap_rec.dest_column || ' = ( --*** Indirect Mapping Destination Column');
595: cn_utils.appindcr(code, ' SELECT ');
590: cn_utils.appindcr(code, ' SET');
591: cn_utils.indent(code, 1);
592: FOR indmap_rec IN indmap
593: LOOP
594: cn_utils.appindcr(code, indmap_rec.dest_column || ' = ( --*** Indirect Mapping Destination Column');
595: cn_utils.appindcr(code, ' SELECT ');
596: cn_utils.appindcr(code, ' ' || indmap_rec.expression ||' --*** Indirect Mapping Source Expression');
597: IF indmap_rec.external_table_alias IS NOT NULL THEN
598: --+
591: cn_utils.indent(code, 1);
592: FOR indmap_rec IN indmap
593: LOOP
594: cn_utils.appindcr(code, indmap_rec.dest_column || ' = ( --*** Indirect Mapping Destination Column');
595: cn_utils.appindcr(code, ' SELECT ');
596: cn_utils.appindcr(code, ' ' || indmap_rec.expression ||' --*** Indirect Mapping Source Expression');
597: IF indmap_rec.external_table_alias IS NOT NULL THEN
598: --+
599: -- This mapping is based on a defined foreign key relationship
592: FOR indmap_rec IN indmap
593: LOOP
594: cn_utils.appindcr(code, indmap_rec.dest_column || ' = ( --*** Indirect Mapping Destination Column');
595: cn_utils.appindcr(code, ' SELECT ');
596: cn_utils.appindcr(code, ' ' || indmap_rec.expression ||' --*** Indirect Mapping Source Expression');
597: IF indmap_rec.external_table_alias IS NOT NULL THEN
598: --+
599: -- This mapping is based on a defined foreign key relationship
600: --+
597: IF indmap_rec.external_table_alias IS NOT NULL THEN
598: --+
599: -- This mapping is based on a defined foreign key relationship
600: --+
601: cn_utils.appindcr(code, ' --*** FROM/WHERE derived from Relationship: '||indmap_rec.relationship_name);
602: cn_utils.appindcr(code, ' FROM '||indmap_rec.external_table_name||' '||indmap_rec.external_table_alias);
603: cn_utils.appindcr(code, ' WHERE');
604: x_count := 0;
605: --+
598: --+
599: -- This mapping is based on a defined foreign key relationship
600: --+
601: cn_utils.appindcr(code, ' --*** FROM/WHERE derived from Relationship: '||indmap_rec.relationship_name);
602: cn_utils.appindcr(code, ' FROM '||indmap_rec.external_table_name||' '||indmap_rec.external_table_alias);
603: cn_utils.appindcr(code, ' WHERE');
604: x_count := 0;
605: --+
606: -- Build where clause based on all join columns in the relationship
599: -- This mapping is based on a defined foreign key relationship
600: --+
601: cn_utils.appindcr(code, ' --*** FROM/WHERE derived from Relationship: '||indmap_rec.relationship_name);
602: cn_utils.appindcr(code, ' FROM '||indmap_rec.external_table_name||' '||indmap_rec.external_table_alias);
603: cn_utils.appindcr(code, ' WHERE');
604: x_count := 0;
605: --+
606: -- Build where clause based on all join columns in the relationship
607: --+
621: LOOP
622: IF x_count = 0 THEN
623: x_count := 1;
624: ELSE
625: cn_utils.appindcr(code, ' AND ');
626: END IF;
627: cn_utils.appindcr(code, ' '||indmap_rec.external_table_alias||'.'||indmap_fk.pkcolumn_name||' = api.'||indmap_fk.fkcolumn_name);
628: END LOOP;
629: --Added by Ashley for MOAC
623: x_count := 1;
624: ELSE
625: cn_utils.appindcr(code, ' AND ');
626: END IF;
627: cn_utils.appindcr(code, ' '||indmap_rec.external_table_alias||'.'||indmap_fk.pkcolumn_name||' = api.'||indmap_fk.fkcolumn_name);
628: END LOOP;
629: --Added by Ashley for MOAC
630: cn_utils.appindcr(code, ' AND api.org_id = '||x_org_id);
631: cn_utils.appindcr(code, '),');
626: END IF;
627: cn_utils.appindcr(code, ' '||indmap_rec.external_table_alias||'.'||indmap_fk.pkcolumn_name||' = api.'||indmap_fk.fkcolumn_name);
628: END LOOP;
629: --Added by Ashley for MOAC
630: cn_utils.appindcr(code, ' AND api.org_id = '||x_org_id);
631: cn_utils.appindcr(code, '),');
632: ELSE
633: --+
634: -- This mapping is based on a free-form update clause
627: cn_utils.appindcr(code, ' '||indmap_rec.external_table_alias||'.'||indmap_fk.pkcolumn_name||' = api.'||indmap_fk.fkcolumn_name);
628: END LOOP;
629: --Added by Ashley for MOAC
630: cn_utils.appindcr(code, ' AND api.org_id = '||x_org_id);
631: cn_utils.appindcr(code, '),');
632: ELSE
633: --+
634: -- This mapping is based on a free-form update clause
635: --+
632: ELSE
633: --+
634: -- This mapping is based on a free-form update clause
635: --+
636: cn_utils.appindcr(code, ' --*** FROM/WHERE taken from Update Clause');
637: cn_utils.appindcr(code, ' '||indmap_rec.update_clause||'),');
638: END IF;
639: END LOOP;
640: cn_utils.strip_prev(code, 1); -- remove trailing comma
633: --+
634: -- This mapping is based on a free-form update clause
635: --+
636: cn_utils.appindcr(code, ' --*** FROM/WHERE taken from Update Clause');
637: cn_utils.appindcr(code, ' '||indmap_rec.update_clause||'),');
638: END IF;
639: END LOOP;
640: cn_utils.strip_prev(code, 1); -- remove trailing comma
641: cn_utils.appendcr(code);
636: cn_utils.appindcr(code, ' --*** FROM/WHERE taken from Update Clause');
637: cn_utils.appindcr(code, ' '||indmap_rec.update_clause||'),');
638: END IF;
639: END LOOP;
640: cn_utils.strip_prev(code, 1); -- remove trailing comma
641: cn_utils.appendcr(code);
642: cn_utils.unindent(code, 1);
643:
644: IF (x_generic OR x_event_id = cn_global.ord_event_id )
637: cn_utils.appindcr(code, ' '||indmap_rec.update_clause||'),');
638: END IF;
639: END LOOP;
640: cn_utils.strip_prev(code, 1); -- remove trailing comma
641: cn_utils.appendcr(code);
642: cn_utils.unindent(code, 1);
643:
644: IF (x_generic OR x_event_id = cn_global.ord_event_id )
645: THEN
638: END IF;
639: END LOOP;
640: cn_utils.strip_prev(code, 1); -- remove trailing comma
641: cn_utils.appendcr(code);
642: cn_utils.unindent(code, 1);
643:
644: IF (x_generic OR x_event_id = cn_global.ord_event_id )
645: THEN
646: cn_utils.appindcr(code, 'WHERE ' || x_dest_alias || '.process_batch_id = x_batch_id');
642: cn_utils.unindent(code, 1);
643:
644: IF (x_generic OR x_event_id = cn_global.ord_event_id )
645: THEN
646: cn_utils.appindcr(code, 'WHERE ' || x_dest_alias || '.process_batch_id = x_batch_id');
647: ELSE
648: cn_utils.appindcr(code, 'WHERE ' || x_dest_alias || '.process_batch_id = x_proc_audit_id');
649: END IF;
650:
644: IF (x_generic OR x_event_id = cn_global.ord_event_id )
645: THEN
646: cn_utils.appindcr(code, 'WHERE ' || x_dest_alias || '.process_batch_id = x_batch_id');
647: ELSE
648: cn_utils.appindcr(code, 'WHERE ' || x_dest_alias || '.process_batch_id = x_proc_audit_id');
649: END IF;
650:
651: --Added by Ashley for MOAC
652: cn_utils.appindcr(code, 'AND ' || x_dest_alias || '.org_id = ' || x_org_id || ';');
648: cn_utils.appindcr(code, 'WHERE ' || x_dest_alias || '.process_batch_id = x_proc_audit_id');
649: END IF;
650:
651: --Added by Ashley for MOAC
652: cn_utils.appindcr(code, 'AND ' || x_dest_alias || '.org_id = ' || x_org_id || ';');
653: cn_utils.appendcr(code);
654: END IF;
655: --+
656: -- Generate code to update the comm_lines_api_update_count variable
649: END IF;
650:
651: --Added by Ashley for MOAC
652: cn_utils.appindcr(code, 'AND ' || x_dest_alias || '.org_id = ' || x_org_id || ';');
653: cn_utils.appendcr(code);
654: END IF;
655: --+
656: -- Generate code to update the comm_lines_api_update_count variable
657: --+
654: END IF;
655: --+
656: -- Generate code to update the comm_lines_api_update_count variable
657: --+
658: cn_utils.appendcr(code);
659: cn_utils.appindcr(code, 'cn_message_pkg.debug(''For all INDIRECT mappings updated '' || SQL%ROWCOUNT || '' rows in cn_comm_lines_api.'');');
660: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''For all INDIRECT mappings updated '' || SQL%ROWCOUNT || '' rows in cn_comm_lines_api.'');');
661: cn_utils.appendcr(code);
662: cn_utils.unset_org_id();
655: --+
656: -- Generate code to update the comm_lines_api_update_count variable
657: --+
658: cn_utils.appendcr(code);
659: cn_utils.appindcr(code, 'cn_message_pkg.debug(''For all INDIRECT mappings updated '' || SQL%ROWCOUNT || '' rows in cn_comm_lines_api.'');');
660: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''For all INDIRECT mappings updated '' || SQL%ROWCOUNT || '' rows in cn_comm_lines_api.'');');
661: cn_utils.appendcr(code);
662: cn_utils.unset_org_id();
663: EXCEPTION
656: -- Generate code to update the comm_lines_api_update_count variable
657: --+
658: cn_utils.appendcr(code);
659: cn_utils.appindcr(code, 'cn_message_pkg.debug(''For all INDIRECT mappings updated '' || SQL%ROWCOUNT || '' rows in cn_comm_lines_api.'');');
660: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''For all INDIRECT mappings updated '' || SQL%ROWCOUNT || '' rows in cn_comm_lines_api.'');');
661: cn_utils.appendcr(code);
662: cn_utils.unset_org_id();
663: EXCEPTION
664: WHEN NO_DATA_FOUND THEN
657: --+
658: cn_utils.appendcr(code);
659: cn_utils.appindcr(code, 'cn_message_pkg.debug(''For all INDIRECT mappings updated '' || SQL%ROWCOUNT || '' rows in cn_comm_lines_api.'');');
660: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''For all INDIRECT mappings updated '' || SQL%ROWCOUNT || '' rows in cn_comm_lines_api.'');');
661: cn_utils.appendcr(code);
662: cn_utils.unset_org_id();
663: EXCEPTION
664: WHEN NO_DATA_FOUND THEN
665: cn_debug.print_msg('update_lines: in exception handler for NO_DATA_FOUND', 1);
658: cn_utils.appendcr(code);
659: cn_utils.appindcr(code, 'cn_message_pkg.debug(''For all INDIRECT mappings updated '' || SQL%ROWCOUNT || '' rows in cn_comm_lines_api.'');');
660: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''For all INDIRECT mappings updated '' || SQL%ROWCOUNT || '' rows in cn_comm_lines_api.'');');
661: cn_utils.appendcr(code);
662: cn_utils.unset_org_id();
663: EXCEPTION
664: WHEN NO_DATA_FOUND THEN
665: cn_debug.print_msg('update_lines: in exception handler for NO_DATA_FOUND', 1);
666: fnd_file.put_line(fnd_file.Log, 'update_lines: in exception handler for NO_DATA_FOUND');
677: --
678: --
679: PROCEDURE filter_comm_lines_api(
680: x_table_map_id cn_table_maps.table_map_id%TYPE,
681: code IN OUT NOCOPY cn_utils.code_type,
682: x_org_id IN NUMBER)
683: IS
684: l_delete_flag VARCHAR2(1);
685: l_statement VARCHAR2(100);
706: l_statement := 'DELETE FROM cn_comm_lines_api api';
707: ELSE
708: l_statement := 'UPDATE cn_comm_lines_api api SET load_status = ''FILTERED''';
709: END IF;
710: cn_utils.set_org_id(x_org_id);
711: cn_utils.appendcr(code);
712: cn_utils.appendcr(code, '--******** FILTER PROCESSING *********-- ');
713: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Filtering unwanted transactions from cn_comm_lines_api.'');');
714: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''Filtering unwanted transactions from cn_comm_lines_api.'');');
707: ELSE
708: l_statement := 'UPDATE cn_comm_lines_api api SET load_status = ''FILTERED''';
709: END IF;
710: cn_utils.set_org_id(x_org_id);
711: cn_utils.appendcr(code);
712: cn_utils.appendcr(code, '--******** FILTER PROCESSING *********-- ');
713: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Filtering unwanted transactions from cn_comm_lines_api.'');');
714: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''Filtering unwanted transactions from cn_comm_lines_api.'');');
715: cn_utils.appendcr(code);
708: l_statement := 'UPDATE cn_comm_lines_api api SET load_status = ''FILTERED''';
709: END IF;
710: cn_utils.set_org_id(x_org_id);
711: cn_utils.appendcr(code);
712: cn_utils.appendcr(code, '--******** FILTER PROCESSING *********-- ');
713: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Filtering unwanted transactions from cn_comm_lines_api.'');');
714: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''Filtering unwanted transactions from cn_comm_lines_api.'');');
715: cn_utils.appendcr(code);
716: --+
709: END IF;
710: cn_utils.set_org_id(x_org_id);
711: cn_utils.appendcr(code);
712: cn_utils.appendcr(code, '--******** FILTER PROCESSING *********-- ');
713: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Filtering unwanted transactions from cn_comm_lines_api.'');');
714: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''Filtering unwanted transactions from cn_comm_lines_api.'');');
715: cn_utils.appendcr(code);
716: --+
717: -- Generate deletion code
710: cn_utils.set_org_id(x_org_id);
711: cn_utils.appendcr(code);
712: cn_utils.appendcr(code, '--******** FILTER PROCESSING *********-- ');
713: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Filtering unwanted transactions from cn_comm_lines_api.'');');
714: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''Filtering unwanted transactions from cn_comm_lines_api.'');');
715: cn_utils.appendcr(code);
716: --+
717: -- Generate deletion code
718: --+
711: cn_utils.appendcr(code);
712: cn_utils.appendcr(code, '--******** FILTER PROCESSING *********-- ');
713: cn_utils.appindcr(code, 'cn_message_pkg.debug(''Filtering unwanted transactions from cn_comm_lines_api.'');');
714: cn_utils.appindcr(code, 'fnd_file.put_line(fnd_file.Log, ''Filtering unwanted transactions from cn_comm_lines_api.'');');
715: cn_utils.appendcr(code);
716: --+
717: -- Generate deletion code
718: --+
719: cn_utils.appindcr(code, '--*** User-defined filter statements');
715: cn_utils.appendcr(code);
716: --+
717: -- Generate deletion code
718: --+
719: cn_utils.appindcr(code, '--*** User-defined filter statements');
720: FOR rec IN c_filter
721: LOOP
722: --+
723: -- Before doing so, strip off trailing ';' on the clause, if one
725: --+
726: IF SUBSTR(rec.object_value,LENGTH(rec.object_value),1) = ';' THEN
727: rec.object_value := SUBSTR(rec.object_value,1,LENGTH(rec.object_value)-1);
728: END IF;
729: cn_utils.appindcr(code, l_statement);
730: cn_utils.appindcr(code, 'WHERE');
731: cn_utils.appindcr(code, ' '||rec.object_value);
732: cn_utils.appindcr(code, ' AND api.process_batch_id = x_batch_id;');
733: cn_utils.appendcr(code);
726: IF SUBSTR(rec.object_value,LENGTH(rec.object_value),1) = ';' THEN
727: rec.object_value := SUBSTR(rec.object_value,1,LENGTH(rec.object_value)-1);
728: END IF;
729: cn_utils.appindcr(code, l_statement);
730: cn_utils.appindcr(code, 'WHERE');
731: cn_utils.appindcr(code, ' '||rec.object_value);
732: cn_utils.appindcr(code, ' AND api.process_batch_id = x_batch_id;');
733: cn_utils.appendcr(code);
734: END LOOP;
727: rec.object_value := SUBSTR(rec.object_value,1,LENGTH(rec.object_value)-1);
728: END IF;
729: cn_utils.appindcr(code, l_statement);
730: cn_utils.appindcr(code, 'WHERE');
731: cn_utils.appindcr(code, ' '||rec.object_value);
732: cn_utils.appindcr(code, ' AND api.process_batch_id = x_batch_id;');
733: cn_utils.appendcr(code);
734: END LOOP;
735: cn_utils.appindcr(code, '--*** End of User-defined filter statements');
728: END IF;
729: cn_utils.appindcr(code, l_statement);
730: cn_utils.appindcr(code, 'WHERE');
731: cn_utils.appindcr(code, ' '||rec.object_value);
732: cn_utils.appindcr(code, ' AND api.process_batch_id = x_batch_id;');
733: cn_utils.appendcr(code);
734: END LOOP;
735: cn_utils.appindcr(code, '--*** End of User-defined filter statements');
736: cn_utils.unset_org_id();
729: cn_utils.appindcr(code, l_statement);
730: cn_utils.appindcr(code, 'WHERE');
731: cn_utils.appindcr(code, ' '||rec.object_value);
732: cn_utils.appindcr(code, ' AND api.process_batch_id = x_batch_id;');
733: cn_utils.appendcr(code);
734: END LOOP;
735: cn_utils.appindcr(code, '--*** End of User-defined filter statements');
736: cn_utils.unset_org_id();
737: END filter_comm_lines_api;
731: cn_utils.appindcr(code, ' '||rec.object_value);
732: cn_utils.appindcr(code, ' AND api.process_batch_id = x_batch_id;');
733: cn_utils.appendcr(code);
734: END LOOP;
735: cn_utils.appindcr(code, '--*** End of User-defined filter statements');
736: cn_utils.unset_org_id();
737: END filter_comm_lines_api;
738: --
739: -- Procedure Name
732: cn_utils.appindcr(code, ' AND api.process_batch_id = x_batch_id;');
733: cn_utils.appendcr(code);
734: END LOOP;
735: cn_utils.appindcr(code, '--*** End of User-defined filter statements');
736: cn_utils.unset_org_id();
737: END filter_comm_lines_api;
738: --
739: -- Procedure Name
740: -- Generate_user_code
745: --
746: PROCEDURE Generate_User_Code(
747: p_table_map_id IN NUMBER,
748: p_location_name IN VARCHAR2,
749: code IN OUT NOCOPY cn_utils.code_type,
750: x_org_id IN NUMBER)
751: IS
752: l_location_name VARCHAR2(250);
753: CURSOR c_lookup
757: WHERE lookup_type ='CN_COLL_TRIGGER_EVENTS'
758: AND enabled_flag ='Y'
759: AND lookup_code = 'PRN';
760: BEGIN
761: cn_utils.set_org_id(x_org_id);
762: cn_utils.appendcr(code);
763: cn_utils.appindcr(code, '--*** User Code, Location: '||p_location_name);
764: --+
765: -- For every line of User Code registered for this location
758: AND enabled_flag ='Y'
759: AND lookup_code = 'PRN';
760: BEGIN
761: cn_utils.set_org_id(x_org_id);
762: cn_utils.appendcr(code);
763: cn_utils.appindcr(code, '--*** User Code, Location: '||p_location_name);
764: --+
765: -- For every line of User Code registered for this location
766: --+
759: AND lookup_code = 'PRN';
760: BEGIN
761: cn_utils.set_org_id(x_org_id);
762: cn_utils.appendcr(code);
763: cn_utils.appindcr(code, '--*** User Code, Location: '||p_location_name);
764: --+
765: -- For every line of User Code registered for this location
766: --+
767: IF (upper(p_location_name) = 'PRE-NOTIFICATION') THEN
788: --+
789: -- Add a terminal ';' if none was registered
790: --+
791: IF rec.object_value LIKE '%;' THEN
792: cn_utils.appindcr(code, rec.object_value);
793: ELSE
794: cn_utils.appindcr(code, rec.object_value||';');
795: END IF;
796: END LOOP;
790: --+
791: IF rec.object_value LIKE '%;' THEN
792: cn_utils.appindcr(code, rec.object_value);
793: ELSE
794: cn_utils.appindcr(code, rec.object_value||';');
795: END IF;
796: END LOOP;
797: cn_utils.appindcr(code, '--*** End of User Code, Location: '||p_location_name);
798: cn_utils.appendcr(code);
793: ELSE
794: cn_utils.appindcr(code, rec.object_value||';');
795: END IF;
796: END LOOP;
797: cn_utils.appindcr(code, '--*** End of User Code, Location: '||p_location_name);
798: cn_utils.appendcr(code);
799: cn_utils.unset_org_id();
800: END Generate_User_Code;
801: END cn_collection_custom_gen;
794: cn_utils.appindcr(code, rec.object_value||';');
795: END IF;
796: END LOOP;
797: cn_utils.appindcr(code, '--*** End of User Code, Location: '||p_location_name);
798: cn_utils.appendcr(code);
799: cn_utils.unset_org_id();
800: END Generate_User_Code;
801: END cn_collection_custom_gen;
795: END IF;
796: END LOOP;
797: cn_utils.appindcr(code, '--*** End of User Code, Location: '||p_location_name);
798: cn_utils.appendcr(code);
799: cn_utils.unset_org_id();
800: END Generate_User_Code;
801: END cn_collection_custom_gen;