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

APPS.JTM_CON_QUERY_REQUEST_PKG dependencies on JTM_MESSAGE_LOG_PKG

Line 119: JTM_message_log_pkg.Log_Msg

115: /*** get debug level ***/
116: g_debug_level := JTM_HOOK_UTIL_PKG.Get_Debug_Level;
117:
118: IF g_debug_level = JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
119: JTM_message_log_pkg.Log_Msg
120: ( v_object_id => L_API_NAME
121: , v_object_name => G_PACKAGE_NAME
122: , v_message => 'The procedure begins execution.'
123: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL

Line 124: , v_module => 'jtm_message_log_pkg');

120: ( v_object_id => L_API_NAME
121: , v_object_name => G_PACKAGE_NAME
122: , v_message => 'The procedure begins execution.'
123: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
124: , v_module => 'jtm_message_log_pkg');
125: END IF;
126:
127: select u.user_id BULK COLLECT INTO l_csl_tab_user
128: from asg_user u, asg_user_Pub_resps r

Line 133: JTM_message_log_pkg.Log_Msg

129: where u.user_name = r.user_name
130: and r.pub_name = 'JTM';
131:
132: IF g_debug_level = JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
133: JTM_message_log_pkg.Log_Msg
134: ( v_object_id => L_API_NAME
135: , v_object_name => G_PACKAGE_NAME
136: , v_message => 'There are ' || l_csl_tab_user.count || ' mobile laptop users.'
137: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL

Line 138: , v_module => 'jtm_message_log_pkg');

134: ( v_object_id => L_API_NAME
135: , v_object_name => G_PACKAGE_NAME
136: , v_message => 'There are ' || l_csl_tab_user.count || ' mobile laptop users.'
137: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
138: , v_module => 'jtm_message_log_pkg');
139: END IF;
140:
141: select u.user_id BULK COLLECT INTO l_csm_tab_user
142: from asg_user u, asg_user_Pub_resps r

Line 147: JTM_message_log_pkg.Log_Msg

143: where u.user_name = r.user_name
144: and r.pub_name = 'JTM_HANDHELD';
145:
146: IF g_debug_level = JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
147: JTM_message_log_pkg.Log_Msg
148: ( v_object_id => L_API_NAME
149: , v_object_name => G_PACKAGE_NAME
150: , v_message => 'There are ' || l_csm_tab_user.count || ' mobile pocket pc users.'
151: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL

Line 152: , v_module => 'jtm_message_log_pkg');

148: ( v_object_id => L_API_NAME
149: , v_object_name => G_PACKAGE_NAME
150: , v_message => 'There are ' || l_csm_tab_user.count || ' mobile pocket pc users.'
151: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
152: , v_module => 'jtm_message_log_pkg');
153: END IF;
154:
155: FOR c_seed_date in get_dff_seed_date LOOP
156: /* Handle the DFF context */

Line 164: JTM_message_log_pkg.Log_Msg

160: c_seed_date.base_application_id,
161: c_seed_date.descriptive_flexfield_name) LOOP
162: BEGIN
163: IF g_debug_level = JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
164: JTM_message_log_pkg.Log_Msg
165: ( v_object_id => L_API_NAME
166: , v_object_name => G_PACKAGE_NAME
167: , v_message => 'Handling DFF '||
168: c_seed_date.descriptive_flexfield_name || ' context (acc id ='

Line 171: , v_module => 'jtm_message_log_pkg');

167: , v_message => 'Handling DFF '||
168: c_seed_date.descriptive_flexfield_name || ' context (acc id ='
169: || c_old_context_acc.access_id || ')'
170: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
171: , v_module => 'jtm_message_log_pkg');
172: END IF;
173: IF (c_seed_date.application_id = 883) THEN
174: l_tab_user := l_csm_tab_user;
175: l_pub_item := 'JTM_H_DESC_FLEX_CONTEXTS';

Line 202: JTM_message_log_pkg.Log_Msg

198: P_Message := 'Exception ocurrs with DFF ' ||
199: c_seed_date.descriptive_flexfield_name || ' context (acc id ='
200: || c_old_context_acc.access_id || '): ' || sqlerrm;
201: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR THEN
202: JTM_message_log_pkg.Log_Msg
203: ( v_object_id => L_API_NAME
204: , v_object_name => G_PACKAGE_NAME
205: , v_message => P_Message
206: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR

Line 207: , v_module => 'jtm_message_log_pkg');

203: ( v_object_id => L_API_NAME
204: , v_object_name => G_PACKAGE_NAME
205: , v_message => P_Message
206: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR
207: , v_module => 'jtm_message_log_pkg');
208: END IF;
209: END;
210: END LOOP;
211: EXCEPTION

Line 217: JTM_message_log_pkg.Log_Msg

213: P_Status := G_ERROR;
214: P_Message := 'Exception ocurrs with DFF ' ||
215: c_seed_date.descriptive_flexfield_name || ' context ' || sqlerrm;
216: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR THEN
217: JTM_message_log_pkg.Log_Msg
218: ( v_object_id => L_API_NAME
219: , v_object_name => G_PACKAGE_NAME
220: , v_message => P_Message
221: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR

Line 222: , v_module => 'jtm_message_log_pkg');

218: ( v_object_id => L_API_NAME
219: , v_object_name => G_PACKAGE_NAME
220: , v_message => P_Message
221: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR
222: , v_module => 'jtm_message_log_pkg');
223: END IF;
224: END; /* Handle the DFF context */
225:
226: BEGIN /* Handle the DFF column usage */

Line 233: JTM_message_log_pkg.Log_Msg

229: c_seed_date.base_application_id,
230: c_seed_date.descriptive_flexfield_name) LOOP
231: BEGIN
232: IF g_debug_level = JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
233: JTM_message_log_pkg.Log_Msg
234: ( v_object_id => L_API_NAME
235: , v_object_name => G_PACKAGE_NAME
236: , v_message => 'Handling DFF '||
237: c_seed_date.descriptive_flexfield_name || ' segment (acc id ='

Line 240: , v_module => 'jtm_message_log_pkg');

236: , v_message => 'Handling DFF '||
237: c_seed_date.descriptive_flexfield_name || ' segment (acc id ='
238: || c_old_col_usg_acc.access_id || ')'
239: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
240: , v_module => 'jtm_message_log_pkg');
241: END IF;
242: IF (c_seed_date.application_id = 883) THEN
243: l_tab_user := l_csm_tab_user;
244: l_pub_item := 'JTM_H_DESC_FLEX_COL_USGS';

Line 271: JTM_message_log_pkg.Log_Msg

267: P_Message := 'Exception ocurrs with DFF ' ||
268: c_seed_date.descriptive_flexfield_name || ' segment (acc id ='
269: || c_old_col_usg_acc.access_id || '): ' || sqlerrm;
270: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR THEN
271: JTM_message_log_pkg.Log_Msg
272: ( v_object_id => L_API_NAME
273: , v_object_name => G_PACKAGE_NAME
274: , v_message => P_Message
275: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR

Line 276: , v_module => 'jtm_message_log_pkg');

272: ( v_object_id => L_API_NAME
273: , v_object_name => G_PACKAGE_NAME
274: , v_message => P_Message
275: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR
276: , v_module => 'jtm_message_log_pkg');
277: END IF;
278: END;
279: END LOOP;
280: EXCEPTION

Line 286: JTM_message_log_pkg.Log_Msg

282: P_Status := G_ERROR;
283: P_Message := 'Exception ocurrs with DFF ' ||
284: c_seed_date.descriptive_flexfield_name || ' segments: ' || sqlerrm;
285: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR THEN
286: JTM_message_log_pkg.Log_Msg
287: ( v_object_id => L_API_NAME
288: , v_object_name => G_PACKAGE_NAME
289: , v_message => P_Message
290: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR

Line 291: , v_module => 'jtm_message_log_pkg');

287: ( v_object_id => L_API_NAME
288: , v_object_name => G_PACKAGE_NAME
289: , v_message => P_Message
290: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR
291: , v_module => 'jtm_message_log_pkg');
292: END IF;
293: END; /* Handle the DFF column usage */
294:
295: BEGIN /* Handle the DFF value */

Line 302: JTM_message_log_pkg.Log_Msg

298: c_seed_date.base_application_id,
299: c_seed_date.descriptive_flexfield_name) LOOP
300: BEGIN
301: IF g_debug_level = JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
302: JTM_message_log_pkg.Log_Msg
303: ( v_object_id => L_API_NAME
304: , v_object_name => G_PACKAGE_NAME
305: , v_message => 'Handling DFF '||
306: c_seed_date.descriptive_flexfield_name || ' value (acc id ='

Line 309: , v_module => 'jtm_message_log_pkg');

305: , v_message => 'Handling DFF '||
306: c_seed_date.descriptive_flexfield_name || ' value (acc id ='
307: || c_old_value_acc.access_id || ')'
308: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
309: , v_module => 'jtm_message_log_pkg');
310: END IF;
311: IF (c_seed_date.application_id = 883) THEN
312: l_tab_user := l_csm_tab_user;
313: l_pub_item := 'JTM_H_FLEX_VALUES';

Line 340: JTM_message_log_pkg.Log_Msg

336: P_Message := 'Exception ocurrs with DFF ' ||
337: c_seed_date.descriptive_flexfield_name || ' values (acc id ='
338: || c_old_value_acc.access_id || '): ' || sqlerrm;
339: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR THEN
340: JTM_message_log_pkg.Log_Msg
341: ( v_object_id => L_API_NAME
342: , v_object_name => G_PACKAGE_NAME
343: , v_message => P_Message
344: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR

Line 345: , v_module => 'jtm_message_log_pkg');

341: ( v_object_id => L_API_NAME
342: , v_object_name => G_PACKAGE_NAME
343: , v_message => P_Message
344: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR
345: , v_module => 'jtm_message_log_pkg');
346: END IF;
347: END;
348: END LOOP;
349: EXCEPTION

Line 355: JTM_message_log_pkg.Log_Msg

351: P_Status := G_ERROR;
352: P_Message := 'Exception ocurrs with DFF value: ' ||
353: c_seed_date.descriptive_flexfield_name || ' values: ' || sqlerrm;
354: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR THEN
355: JTM_message_log_pkg.Log_Msg
356: ( v_object_id => L_API_NAME
357: , v_object_name => G_PACKAGE_NAME
358: , v_message => P_Message
359: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR

Line 360: , v_module => 'jtm_message_log_pkg');

356: ( v_object_id => L_API_NAME
357: , v_object_name => G_PACKAGE_NAME
358: , v_message => P_Message
359: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR
360: , v_module => 'jtm_message_log_pkg');
361: END IF;
362: END; /* Handle the DFF value */
363:
364: BEGIN /* Handle the DFF value set */

Line 371: JTM_message_log_pkg.Log_Msg

367: c_seed_date.base_application_id,
368: c_seed_date.descriptive_flexfield_name) LOOP
369: BEGIN
370: IF g_debug_level = JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
371: JTM_message_log_pkg.Log_Msg
372: ( v_object_id => L_API_NAME
373: , v_object_name => G_PACKAGE_NAME
374: , v_message => 'Handling DFF '||
375: c_seed_date.descriptive_flexfield_name || ' value set (acc id ='

Line 378: , v_module => 'jtm_message_log_pkg');

374: , v_message => 'Handling DFF '||
375: c_seed_date.descriptive_flexfield_name || ' value set (acc id ='
376: || c_old_value_set_acc.access_id || ')'
377: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
378: , v_module => 'jtm_message_log_pkg');
379: END IF;
380: IF (c_seed_date.application_id = 883) THEN
381: l_tab_user := l_csm_tab_user;
382: l_pub_item := 'JTM_H_FLEX_VALUE_SETS';

Line 409: JTM_message_log_pkg.Log_Msg

405: P_Message := 'Exception ocurrs with DFF ' ||
406: c_seed_date.descriptive_flexfield_name || ' value set(acc id ='
407: || c_old_value_set_acc.access_id || '): ' || sqlerrm;
408: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR THEN
409: JTM_message_log_pkg.Log_Msg
410: ( v_object_id => L_API_NAME
411: , v_object_name => G_PACKAGE_NAME
412: , v_message => P_Message
413: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR

Line 414: , v_module => 'jtm_message_log_pkg');

410: ( v_object_id => L_API_NAME
411: , v_object_name => G_PACKAGE_NAME
412: , v_message => P_Message
413: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR
414: , v_module => 'jtm_message_log_pkg');
415: END IF;
416: END;
417: END LOOP;
418: EXCEPTION

Line 424: JTM_message_log_pkg.Log_Msg

420: P_Status := G_ERROR;
421: P_Message := 'Exception ocurrs with DFF ' ||
422: c_seed_date.descriptive_flexfield_name || ' values: ' || sqlerrm;
423: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR THEN
424: JTM_message_log_pkg.Log_Msg
425: ( v_object_id => L_API_NAME
426: , v_object_name => G_PACKAGE_NAME
427: , v_message => P_Message
428: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR

Line 429: , v_module => 'jtm_message_log_pkg');

425: ( v_object_id => L_API_NAME
426: , v_object_name => G_PACKAGE_NAME
427: , v_message => P_Message
428: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR
429: , v_module => 'jtm_message_log_pkg');
430: END IF;
431: END; /* Handle the DFF value set */
432:
433: END LOOP;

Line 439: JTM_message_log_pkg.Log_Msg

435: WHEN OTHERS THEN
436: P_Status := G_ERROR;
437: P_Message := 'Exception ocurrs: ' || sqlerrm;
438: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR THEN
439: JTM_message_log_pkg.Log_Msg
440: ( v_object_id => L_API_NAME
441: , v_object_name => G_PACKAGE_NAME
442: , v_message => P_Message
443: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR

Line 444: , v_module => 'jtm_message_log_pkg');

440: ( v_object_id => L_API_NAME
441: , v_object_name => G_PACKAGE_NAME
442: , v_message => P_Message
443: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR
444: , v_module => 'jtm_message_log_pkg');
445: END IF;
446:
447: END FIX_DFF_ACC;
448:

Line 548: JTM_message_log_pkg.Log_Msg

544: EXCEPTION
545: WHEN OTHERS THEN
546: CLOSE c_item_resources;
547: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR THEN
548: JTM_message_log_pkg.Log_Msg
549: ( v_object_id => l_publication_item_name(j)
550: , v_object_name => G_PACKAGE_NAME
551: , v_message => 'exception thrown in '||G_PACKAGE_NAME||'.markdirty_helper.'
552: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR

Line 553: , v_module => 'jtm_message_log_pkg');

549: ( v_object_id => l_publication_item_name(j)
550: , v_object_name => G_PACKAGE_NAME
551: , v_message => 'exception thrown in '||G_PACKAGE_NAME||'.markdirty_helper.'
552: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR
553: , v_module => 'jtm_message_log_pkg');
554: END IF;
555: RAISE;
556: RETURN FALSE;
557:

Line 589: JTM_MESSAGE_LOG_PKG.INSERT_CONC_STATUS_LOG

585: p_message := 'OK';
586: l_query_start := sysdate;
587:
588:
589: JTM_MESSAGE_LOG_PKG.INSERT_CONC_STATUS_LOG
590: (v_package_name => NULL
591: ,v_procedure_name => NULL
592: ,v_con_query_id => r_query_request.con_query_id
593: ,v_query_stmt => G_CATEGORY

Line 603: RAISE JTM_MESSAGE_LOG_PKG.G_EXC_ERROR;

599: ,x_status => l_status
600: ,x_msg_data => l_message);
601:
602: IF (l_status = 'E') THEN
603: RAISE JTM_MESSAGE_LOG_PKG.G_EXC_ERROR;
604: END IF;
605:
606: IF g_debug_level = JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
607: JTM_message_log_pkg.Log_Msg

Line 607: JTM_message_log_pkg.Log_Msg

603: RAISE JTM_MESSAGE_LOG_PKG.G_EXC_ERROR;
604: END IF;
605:
606: IF g_debug_level = JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
607: JTM_message_log_pkg.Log_Msg
608: ( v_object_id => null
609: , v_object_name => G_PACKAGE_NAME
610: , v_message => 'Entering '||G_PACKAGE_NAME||'.PROCESS_REQUEST'
611: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL

Line 612: , v_module => 'jtm_message_log_pkg');

608: ( v_object_id => null
609: , v_object_name => G_PACKAGE_NAME
610: , v_message => 'Entering '||G_PACKAGE_NAME||'.PROCESS_REQUEST'
611: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
612: , v_module => 'jtm_message_log_pkg');
613: END IF;
614:
615: /** get primary_key of corresponding publication item **/
616: OPEN c_primary_key(r_query_request.con_query_id);

Line 632: JTM_message_log_pkg.Log_Msg

628:
629: IF c_primary_key%ROWCOUNT = 0 THEN
630: /*** no application subscribed -> ignore this query ***/
631: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM THEN
632: JTM_message_log_pkg.Log_Msg
633: ( v_object_id => r_query_request.acc_table_name
634: , v_object_name => G_PACKAGE_NAME
635: , v_message => 'No application subscribed to query ' ||
636: r_query_request.con_query_id || '.' ||

Line 639: , v_module => 'jtm_message_log_pkg');

635: , v_message => 'No application subscribed to query ' ||
636: r_query_request.con_query_id || '.' ||
637: fnd_global.local_chr(10) || 'Ignoring this query.'
638: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM
639: , v_module => 'jtm_message_log_pkg');
640: END IF;
641:
642: p_status := G_ERROR;
643: p_message := 'No primary key found for pub item related to query id ' ||

Line 649: JTM_message_log_pkg.Log_Msg

645: ELSE
646:
647: /*** one or more resources subscribed -> process publication item ***/
648: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM THEN
649: JTM_message_log_pkg.Log_Msg
650: ( v_object_id => r_query_request.acc_table_name
651: , v_object_name => G_PACKAGE_NAME
652: , v_message => 'There is at lesst one application regiesterd to this query'
653: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM

Line 654: , v_module => 'jtm_message_log_pkg');

650: ( v_object_id => r_query_request.acc_table_name
651: , v_object_name => G_PACKAGE_NAME
652: , v_message => 'There is at lesst one application regiesterd to this query'
653: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM
654: , v_module => 'jtm_message_log_pkg');
655: END IF;
656:
657: /*** PROCESS UPDATES ***/
658:

Line 660: JTM_message_log_pkg.Log_Msg

656:
657: /*** PROCESS UPDATES ***/
658:
659: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
660: JTM_message_log_pkg.Log_Msg
661: ( v_object_id => r_query_request.acc_table_name
662: , v_object_name => G_PACKAGE_NAME
663: , v_message => 'Processing UPDATES'
664: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL

Line 665: , v_module => 'jtm_message_log_pkg');

661: ( v_object_id => r_query_request.acc_table_name
662: , v_object_name => G_PACKAGE_NAME
663: , v_message => 'Processing UPDATES'
664: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
665: , v_module => 'jtm_message_log_pkg');
666: END IF;
667:
668: /*** Check if query ran before ***/
669: IF r_query_request.last_run_date IS NOT NULL THEN

Line 676: JTM_message_log_pkg.Log_Msg

672: ' ACC WHERE (' || l_primary_key || ') IN (SELECT ' ||
673: l_primary_key || ' FROM (' || r_query_request.con_query || ') B ' ||
674: 'WHERE B.LAST_UPDATE_DATE >= :last_run_date)';
675: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL THEN
676: JTM_message_log_pkg.Log_Msg
677: ( v_object_id => r_query_request.acc_table_name
678: , v_object_name => G_PACKAGE_NAME
679: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt || fnd_global.local_chr(10) ||
680: 'LAST_RUN_DATE = ' || to_char(r_query_request.last_run_date)

Line 682: , v_module => 'jtm_message_log_pkg');

678: , v_object_name => G_PACKAGE_NAME
679: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt || fnd_global.local_chr(10) ||
680: 'LAST_RUN_DATE = ' || to_char(r_query_request.last_run_date)
681: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL
682: , v_module => 'jtm_message_log_pkg');
683: END IF;
684: l_cursor := dbms_sql.open_cursor;
685: dbms_sql.parse( l_cursor, l_dynamic_stmt, dbms_sql.v7);
686: dbms_sql.bind_variable( l_cursor, 'last_run_date', r_query_request.last_run_date);

Line 701: JTM_message_log_pkg.Log_Msg

697:
698: IF l_tab_access_id.COUNT > 0 THEN
699: /*** 1 or more acc rows retrieved -> push to resources ***/
700: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM THEN
701: JTM_message_log_pkg.Log_Msg
702: ( v_object_id => r_query_request.acc_table_name
703: , v_object_name => G_PACKAGE_NAME
704: , v_message => 'Pushing ' || l_tab_access_id.COUNT || ' updated record(s) to subscribed resources.'
705: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM

Line 706: , v_module => 'jtm_message_log_pkg');

702: ( v_object_id => r_query_request.acc_table_name
703: , v_object_name => G_PACKAGE_NAME
704: , v_message => 'Pushing ' || l_tab_access_id.COUNT || ' updated record(s) to subscribed resources.'
705: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM
706: , v_module => 'jtm_message_log_pkg');
707: END IF;
708:
709: FOR i IN l_tab_access_id.FIRST..l_tab_access_id.LAST LOOP
710: m_tab_access_id(i) := l_tab_access_id(i);

Line 732: JTM_message_log_pkg.Log_Msg

728: mobile users.
729: ***/
730:
731: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
732: JTM_message_log_pkg.Log_Msg
733: ( v_object_id => r_query_request.acc_table_name
734: , v_object_name => G_PACKAGE_NAME
735: , v_message => 'Processing INSERTS'
736: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL

Line 737: , v_module => 'jtm_message_log_pkg');

733: ( v_object_id => r_query_request.acc_table_name
734: , v_object_name => G_PACKAGE_NAME
735: , v_message => 'Processing INSERTS'
736: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
737: , v_module => 'jtm_message_log_pkg');
738: END IF;
739:
740: IF (r_query_request.acc_table_name = 'JTM_FND_PROF_OPTIONS_VAL_ACC') THEN
741: l_dynamic_stmt :=

Line 772: JTM_message_log_pkg.Log_Msg

768: ' (' || l_primary_key || ') NOT IN ' ||
769: '(SELECT ' || l_primary_key || ' FROM ' || r_query_request.acc_table_name || ')';
770: END IF;
771: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL THEN
772: JTM_message_log_pkg.Log_Msg
773: ( v_object_id => r_query_request.acc_table_name
774: , v_object_name => G_PACKAGE_NAME
775: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt
776: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL

Line 777: , v_module => 'jtm_message_log_pkg');

773: ( v_object_id => r_query_request.acc_table_name
774: , v_object_name => G_PACKAGE_NAME
775: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt
776: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL
777: , v_module => 'jtm_message_log_pkg');
778:
779: END IF;
780: EXECUTE IMMEDIATE l_dynamic_stmt;
781:

Line 786: JTM_message_log_pkg.Log_Msg

782: /*** Retrieve ACCESS_IDs for any inserted records ***/
783: l_dynamic_stmt := 'SELECT ACCESS_ID FROM ' || r_query_request.acc_table_name ||
784: ' WHERE COUNTER = 0';
785: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL THEN
786: JTM_message_log_pkg.Log_Msg
787: ( v_object_id => r_query_request.acc_table_name
788: , v_object_name => G_PACKAGE_NAME
789: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt
790: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL

Line 791: , v_module => 'jtm_message_log_pkg');

787: ( v_object_id => r_query_request.acc_table_name
788: , v_object_name => G_PACKAGE_NAME
789: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt
790: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL
791: , v_module => 'jtm_message_log_pkg');
792: END IF;
793: l_cursor := dbms_sql.open_cursor;
794: dbms_sql.parse( l_cursor, l_dynamic_stmt, dbms_sql.v7);
795: l_index := 1;

Line 809: JTM_message_log_pkg.Log_Msg

805:
806: IF l_tab_access_id.COUNT > 0 THEN
807: /*** 1 or more acc rows retrieved -> push to resources ***/
808: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM THEN
809: JTM_message_log_pkg.Log_Msg
810: ( v_object_id => r_query_request.acc_table_name
811: , v_object_name => G_PACKAGE_NAME
812: , v_message => 'Pushing ' || l_tab_access_id.COUNT || ' inserted record(s) to subscribed resources.'
813: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM

Line 814: , v_module => 'jtm_message_log_pkg');

810: ( v_object_id => r_query_request.acc_table_name
811: , v_object_name => G_PACKAGE_NAME
812: , v_message => 'Pushing ' || l_tab_access_id.COUNT || ' inserted record(s) to subscribed resources.'
813: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM
814: , v_module => 'jtm_message_log_pkg');
815: END IF;
816:
817: /*** push to oLite using asg_download ***/
818:

Line 831: JTM_message_log_pkg.Log_Msg

827:
828: /*** set COUNTER to 1 in ACC table ***/
829: l_dynamic_stmt := 'UPDATE ' || r_query_request.acc_table_name || ' SET COUNTER=1 WHERE COUNTER=0';
830: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL THEN
831: JTM_message_log_pkg.Log_Msg
832: ( v_object_id => r_query_request.acc_table_name
833: , v_object_name => G_PACKAGE_NAME
834: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt
835: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL

Line 836: , v_module => 'jtm_message_log_pkg');

832: ( v_object_id => r_query_request.acc_table_name
833: , v_object_name => G_PACKAGE_NAME
834: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt
835: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL
836: , v_module => 'jtm_message_log_pkg');
837: END IF;
838: EXECUTE IMMEDIATE l_dynamic_stmt;
839: END IF; -- process INSERTS
840:

Line 844: JTM_message_log_pkg.Log_Msg

840:
841:
842: /*** PROCESS DELETES ***/
843: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
844: JTM_message_log_pkg.Log_Msg
845: ( v_object_id => r_query_request.acc_table_name
846: , v_object_name => G_PACKAGE_NAME
847: , v_message => 'Processing DELETES'
848: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL

Line 849: , v_module => 'jtm_message_log_pkg');

845: ( v_object_id => r_query_request.acc_table_name
846: , v_object_name => G_PACKAGE_NAME
847: , v_message => 'Processing DELETES'
848: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
849: , v_module => 'jtm_message_log_pkg');
850: END IF;
851:
852: IF (r_query_request.acc_table_name = 'JTM_FND_PROF_OPTIONS_VAL_ACC') THEN
853: l_dynamic_stmt :=

Line 891: JTM_message_log_pkg.Log_Msg

887:
888: IF l_tab_access_id.COUNT > 0 THEN
889: /*** 1 or more acc rows retrieved -> push to resources ***/
890: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM THEN
891: JTM_message_log_pkg.Log_Msg
892: ( v_object_id => r_query_request.acc_table_name
893: , v_object_name => G_PACKAGE_NAME
894: , v_message => 'Pushing ' || l_tab_access_id.COUNT || ' deleted record(s) to subscribed resources.'
895: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM

Line 896: , v_module => 'jtm_message_log_pkg');

892: ( v_object_id => r_query_request.acc_table_name
893: , v_object_name => G_PACKAGE_NAME
894: , v_message => 'Pushing ' || l_tab_access_id.COUNT || ' deleted record(s) to subscribed resources.'
895: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM
896: , v_module => 'jtm_message_log_pkg');
897: END IF;
898: /*** push to oLite using asg_download ***/
899:
900: FOR i IN l_tab_access_id.FIRST..l_tab_access_id.LAST LOOP

Line 918: JTM_message_log_pkg.Log_Msg

914: EXECUTE IMMEDIATE l_dynamic_stmt USING m_tab_access_id(i);
915: END LOOP;
916:
917: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL THEN
918: JTM_message_log_pkg.Log_Msg
919: ( v_object_id => r_query_request.acc_table_name
920: , v_object_name => G_PACKAGE_NAME
921: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt
922: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL

Line 923: , v_module => 'jtm_message_log_pkg');

919: ( v_object_id => r_query_request.acc_table_name
920: , v_object_name => G_PACKAGE_NAME
921: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt
922: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL
923: , v_module => 'jtm_message_log_pkg');
924: END IF;
925:
926:
927: END IF; -- process DELETES

Line 934: JTM_MESSAGE_LOG_PKG.UPDATE_CONC_STATUS_LOG

930: r_query_request.con_query_id;
931: END IF;
932: CLOSE c_primary_key;
933:
934: JTM_MESSAGE_LOG_PKG.UPDATE_CONC_STATUS_LOG
935: (v_log_id =>l_start_log_id
936: ,v_query_stmt => G_Category
937: ,v_start_time => l_query_start
938: ,v_end_time => sysdate

Line 945: JTM_message_log_pkg.Log_Msg

941: ,x_status => l_status
942: ,x_msg_data => l_message);
943:
944: IF g_debug_level = JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
945: JTM_message_log_pkg.Log_Msg
946: ( v_object_id => r_query_request.acc_table_name
947: , v_object_name => G_PACKAGE_NAME
948: , v_message => 'Leaving '||G_PACKAGE_NAME||'.Process_Request'
949: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL

Line 950: , v_module => 'jtm_message_log_pkg');

946: ( v_object_id => r_query_request.acc_table_name
947: , v_object_name => G_PACKAGE_NAME
948: , v_message => 'Leaving '||G_PACKAGE_NAME||'.Process_Request'
949: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
950: , v_module => 'jtm_message_log_pkg');
951: END IF;
952:
953: EXCEPTION
954: WHEN OTHERS THEN

Line 957: JTM_message_log_pkg.Log_Msg

953: EXCEPTION
954: WHEN OTHERS THEN
955: CLOSE c_primary_key;
956: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR THEN
957: JTM_message_log_pkg.Log_Msg
958: ( v_object_id => r_query_request.acc_table_name
959: , v_object_name => G_PACKAGE_NAME
960: , v_message => 'Leaving '||G_PACKAGE_NAME||'.Process_Request after exception.'
961: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR

Line 962: , v_module => 'jtm_message_log_pkg');

958: ( v_object_id => r_query_request.acc_table_name
959: , v_object_name => G_PACKAGE_NAME
960: , v_message => 'Leaving '||G_PACKAGE_NAME||'.Process_Request after exception.'
961: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR
962: , v_module => 'jtm_message_log_pkg');
963: END IF;
964:
965: p_status := G_ERROR;
966: p_message := 'Exception ocurrs while processing query with id ' ||

Line 968: JTM_MESSAGE_LOG_PKG.UPDATE_CONC_STATUS_LOG

964:
965: p_status := G_ERROR;
966: p_message := 'Exception ocurrs while processing query with id ' ||
967: r_query_request.con_query_id || ': ' || sqlerrm;
968: JTM_MESSAGE_LOG_PKG.UPDATE_CONC_STATUS_LOG
969: (v_log_id =>l_start_log_id
970: ,v_query_stmt => G_Category
971: ,v_start_time => l_query_start
972: ,v_end_time => sysdate

Line 1014: JTM_MESSAGE_LOG_PKG.INSERT_CONC_STATUS_LOG

1010: p_status := G_FINE;
1011: p_message := 'OK';
1012: l_query_start := sysdate;
1013:
1014: JTM_MESSAGE_LOG_PKG.INSERT_CONC_STATUS_LOG
1015: (v_package_name => NULL
1016: ,v_procedure_name => NULL
1017: ,v_con_query_id => r_query_request.con_query_id
1018: ,v_query_stmt => G_CATEGORY

Line 1028: RAISE JTM_MESSAGE_LOG_PKG.G_EXC_ERROR;

1024: ,x_status => l_status
1025: ,x_msg_data => l_message);
1026:
1027: IF (l_status = 'E') THEN
1028: RAISE JTM_MESSAGE_LOG_PKG.G_EXC_ERROR;
1029: END IF;
1030:
1031: IF g_debug_level = JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
1032: JTM_message_log_pkg.Log_Msg

Line 1032: JTM_message_log_pkg.Log_Msg

1028: RAISE JTM_MESSAGE_LOG_PKG.G_EXC_ERROR;
1029: END IF;
1030:
1031: IF g_debug_level = JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
1032: JTM_message_log_pkg.Log_Msg
1033: ( v_object_id => null
1034: , v_object_name => G_PACKAGE_NAME
1035: , v_message => 'Entering ' || G_PACKAGE_NAME ||'.Process_Request_v2'
1036: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL

Line 1037: , v_module => 'jtm_message_log_pkg');

1033: ( v_object_id => null
1034: , v_object_name => G_PACKAGE_NAME
1035: , v_message => 'Entering ' || G_PACKAGE_NAME ||'.Process_Request_v2'
1036: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
1037: , v_module => 'jtm_message_log_pkg');
1038: END IF;
1039:
1040: /** get primary_key of corresponding publication item **/
1041: OPEN c_primary_key(r_query_request.con_query_id);

Line 1047: JTM_message_log_pkg.Log_Msg

1043:
1044: IF c_primary_key%ROWCOUNT = 0 THEN
1045: /*** no application subscribed -> ignore this query ***/
1046: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM THEN
1047: JTM_message_log_pkg.Log_Msg
1048: ( v_object_id => r_query_request.acc_table_name
1049: , v_object_name => G_PACKAGE_NAME
1050: , v_message => 'No application subscribed to query ' || r_query_request.con_query_id || '.' ||
1051: fnd_global.local_chr(10) || 'Ignoring this query.'

Line 1053: , v_module => 'jtm_message_log_pkg');

1049: , v_object_name => G_PACKAGE_NAME
1050: , v_message => 'No application subscribed to query ' || r_query_request.con_query_id || '.' ||
1051: fnd_global.local_chr(10) || 'Ignoring this query.'
1052: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM
1053: , v_module => 'jtm_message_log_pkg');
1054: END IF;
1055:
1056: p_status := G_ERROR;
1057: p_message := 'No primary key found for pub item related to query id ' ||

Line 1063: JTM_message_log_pkg.Log_Msg

1059: ELSE
1060:
1061: /*** one or more resources subscribed -> process publication item ***/
1062: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM THEN
1063: JTM_message_log_pkg.Log_Msg
1064: ( v_object_id => r_query_request.acc_table_name
1065: , v_object_name => G_PACKAGE_NAME
1066: , v_message => 'There is at lesst one application regiesterd to this query'
1067: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM

Line 1068: , v_module => 'jtm_message_log_pkg');

1064: ( v_object_id => r_query_request.acc_table_name
1065: , v_object_name => G_PACKAGE_NAME
1066: , v_message => 'There is at lesst one application regiesterd to this query'
1067: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM
1068: , v_module => 'jtm_message_log_pkg');
1069: END IF;
1070:
1071: /*************************** PROCESS UPDATES ***************************/
1072:

Line 1074: JTM_message_log_pkg.Log_Msg

1070:
1071: /*************************** PROCESS UPDATES ***************************/
1072:
1073: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
1074: JTM_message_log_pkg.Log_Msg
1075: ( v_object_id => r_query_request.acc_table_name
1076: , v_object_name => G_PACKAGE_NAME
1077: , v_message => 'Processing UPDATES'
1078: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL

Line 1079: , v_module => 'jtm_message_log_pkg');

1075: ( v_object_id => r_query_request.acc_table_name
1076: , v_object_name => G_PACKAGE_NAME
1077: , v_message => 'Processing UPDATES'
1078: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
1079: , v_module => 'jtm_message_log_pkg');
1080: END IF;
1081:
1082: -- Check if query ran before
1083: IF r_query_request.last_run_date IS NOT NULL THEN

Line 1091: JTM_message_log_pkg.Log_Msg

1087: 'WHERE B.LAST_UPDATE_DATE <> ACC.LAST_UPDATE_DATE ' ||
1088: 'AND ' || GET_CONDITION(l_primary_key,'ACC','B');
1089:
1090: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL THEN
1091: JTM_message_log_pkg.Log_Msg
1092: ( v_object_id => r_query_request.acc_table_name
1093: , v_object_name => G_PACKAGE_NAME
1094: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt || fnd_global.local_chr(10) ||
1095: 'LAST_RUN_DATE = ' || to_char(r_query_request.last_run_date)

Line 1097: , v_module => 'jtm_message_log_pkg');

1093: , v_object_name => G_PACKAGE_NAME
1094: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt || fnd_global.local_chr(10) ||
1095: 'LAST_RUN_DATE = ' || to_char(r_query_request.last_run_date)
1096: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL
1097: , v_module => 'jtm_message_log_pkg');
1098: END IF;
1099:
1100: l_update_count := 0;
1101: OPEN update_cursor for l_dynamic_stmt;

Line 1115: JTM_message_log_pkg.Log_Msg

1111:
1112: IF l_update_count > 0 THEN
1113: -- 1 or more acc rows retrieved -> push to resources
1114: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM THEN
1115: JTM_message_log_pkg.Log_Msg
1116: ( v_object_id => r_query_request.acc_table_name
1117: , v_object_name => G_PACKAGE_NAME
1118: , v_message => 'Pushing ' || l_update_count || ' updated record(s) to subscribed resources.'
1119: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM

Line 1120: , v_module => 'jtm_message_log_pkg');

1116: ( v_object_id => r_query_request.acc_table_name
1117: , v_object_name => G_PACKAGE_NAME
1118: , v_message => 'Pushing ' || l_update_count || ' updated record(s) to subscribed resources.'
1119: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM
1120: , v_module => 'jtm_message_log_pkg');
1121: END IF;
1122:
1123: l_dummy := markdirty_helper(
1124: p_con_query_id => r_query_request.con_query_id

Line 1143: JTM_message_log_pkg.Log_Msg

1139: mobile users.
1140: ***/
1141:
1142: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
1143: JTM_message_log_pkg.Log_Msg
1144: ( v_object_id => r_query_request.acc_table_name
1145: , v_object_name => G_PACKAGE_NAME
1146: , v_message => 'Processing INSERTS'
1147: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL

Line 1148: , v_module => 'jtm_message_log_pkg');

1144: ( v_object_id => r_query_request.acc_table_name
1145: , v_object_name => G_PACKAGE_NAME
1146: , v_message => 'Processing INSERTS'
1147: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
1148: , v_module => 'jtm_message_log_pkg');
1149: END IF;
1150:
1151: l_dynamic_stmt := 'INSERT INTO ' || r_query_request.acc_table_name ||
1152: '(' || l_primary_key || ', ACCESS_ID, COUNTER,' ||

Line 1160: JTM_message_log_pkg.Log_Msg

1156: ' (' || l_primary_key || ') NOT IN ' ||
1157: '(SELECT ' || l_primary_key || ' FROM ' || r_query_request.acc_table_name || ')';
1158:
1159: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL THEN
1160: JTM_message_log_pkg.Log_Msg
1161: ( v_object_id => r_query_request.acc_table_name
1162: , v_object_name => G_PACKAGE_NAME
1163: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt
1164: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL

Line 1165: , v_module => 'jtm_message_log_pkg');

1161: ( v_object_id => r_query_request.acc_table_name
1162: , v_object_name => G_PACKAGE_NAME
1163: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt
1164: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL
1165: , v_module => 'jtm_message_log_pkg');
1166:
1167: END IF;
1168: EXECUTE IMMEDIATE l_dynamic_stmt;
1169:

Line 1174: JTM_message_log_pkg.Log_Msg

1170: /*** Retrieve ACCESS_IDs for any inserted records ***/
1171: l_dynamic_stmt := 'SELECT ACCESS_ID FROM ' || r_query_request.acc_table_name ||
1172: ' WHERE COUNTER = 0';
1173: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL THEN
1174: JTM_message_log_pkg.Log_Msg
1175: ( v_object_id => r_query_request.acc_table_name
1176: , v_object_name => G_PACKAGE_NAME
1177: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt
1178: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL

Line 1179: , v_module => 'jtm_message_log_pkg');

1175: ( v_object_id => r_query_request.acc_table_name
1176: , v_object_name => G_PACKAGE_NAME
1177: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt
1178: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL
1179: , v_module => 'jtm_message_log_pkg');
1180: END IF;
1181: l_cursor := dbms_sql.open_cursor;
1182: dbms_sql.parse( l_cursor, l_dynamic_stmt, dbms_sql.v7);
1183: l_index := 1;

Line 1197: JTM_message_log_pkg.Log_Msg

1193:
1194: IF l_tab_access_id.COUNT > 0 THEN
1195: /*** 1 or more acc rows retrieved -> push to resources ***/
1196: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM THEN
1197: JTM_message_log_pkg.Log_Msg
1198: ( v_object_id => r_query_request.acc_table_name
1199: , v_object_name => G_PACKAGE_NAME
1200: , v_message => 'Pushing ' || l_tab_access_id.COUNT || ' inserted record(s) to subscribed resources.'
1201: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM

Line 1202: , v_module => 'jtm_message_log_pkg');

1198: ( v_object_id => r_query_request.acc_table_name
1199: , v_object_name => G_PACKAGE_NAME
1200: , v_message => 'Pushing ' || l_tab_access_id.COUNT || ' inserted record(s) to subscribed resources.'
1201: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM
1202: , v_module => 'jtm_message_log_pkg');
1203: END IF;
1204:
1205: /*** push to oLite using asg_download ***/
1206:

Line 1221: JTM_message_log_pkg.Log_Msg

1217:
1218: /*** set COUNTER to 1 in ACC table ***/
1219: l_dynamic_stmt := 'UPDATE ' || r_query_request.acc_table_name || ' SET COUNTER=1 WHERE COUNTER=0';
1220: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL THEN
1221: JTM_message_log_pkg.Log_Msg
1222: ( v_object_id => r_query_request.acc_table_name
1223: , v_object_name => G_PACKAGE_NAME
1224: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt
1225: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL

Line 1226: , v_module => 'jtm_message_log_pkg');

1222: ( v_object_id => r_query_request.acc_table_name
1223: , v_object_name => G_PACKAGE_NAME
1224: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt
1225: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL
1226: , v_module => 'jtm_message_log_pkg');
1227: END IF;
1228: EXECUTE IMMEDIATE l_dynamic_stmt;
1229: END IF; -- process INSERTS
1230:

Line 1233: JTM_message_log_pkg.Log_Msg

1229: END IF; -- process INSERTS
1230:
1231: /*************************** 3. PROCESS DELETES ***************************/
1232: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
1233: JTM_message_log_pkg.Log_Msg
1234: ( v_object_id => r_query_request.acc_table_name
1235: , v_object_name => G_PACKAGE_NAME
1236: , v_message => 'Processing DELETES'
1237: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL

Line 1238: , v_module => 'jtm_message_log_pkg');

1234: ( v_object_id => r_query_request.acc_table_name
1235: , v_object_name => G_PACKAGE_NAME
1236: , v_message => 'Processing DELETES'
1237: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
1238: , v_module => 'jtm_message_log_pkg');
1239: END IF;
1240:
1241: /*** Check if query ran before ***/
1242: IF r_query_request.last_run_date IS NOT NULL THEN

Line 1264: JTM_message_log_pkg.Log_Msg

1260:
1261: IF l_tab_access_id.COUNT > 0 THEN
1262: /*** 1 or more acc rows retrieved -> push to resources ***/
1263: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM THEN
1264: JTM_message_log_pkg.Log_Msg
1265: ( v_object_id => r_query_request.acc_table_name
1266: , v_object_name => G_PACKAGE_NAME
1267: , v_message => 'Pushing ' || l_tab_access_id.COUNT || ' deleted record(s) to subscribed resources.'
1268: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM

Line 1269: , v_module => 'jtm_message_log_pkg');

1265: ( v_object_id => r_query_request.acc_table_name
1266: , v_object_name => G_PACKAGE_NAME
1267: , v_message => 'Pushing ' || l_tab_access_id.COUNT || ' deleted record(s) to subscribed resources.'
1268: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM
1269: , v_module => 'jtm_message_log_pkg');
1270: END IF;
1271: /*** push to oLite using asg_download ***/
1272:
1273: FOR i IN l_tab_access_id.FIRST..l_tab_access_id.LAST LOOP

Line 1292: JTM_message_log_pkg.Log_Msg

1288: ' WHERE (' || l_primary_key || ') NOT IN (SELECT ' ||
1289: l_primary_key || ' FROM (' || r_query_request.con_query || '))';
1290:
1291: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL THEN
1292: JTM_message_log_pkg.Log_Msg
1293: ( v_object_id => r_query_request.acc_table_name
1294: , v_object_name => G_PACKAGE_NAME
1295: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt
1296: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL

Line 1297: , v_module => 'jtm_message_log_pkg');

1293: ( v_object_id => r_query_request.acc_table_name
1294: , v_object_name => G_PACKAGE_NAME
1295: , v_message => 'Executing:' || fnd_global.local_chr(10) || l_dynamic_stmt
1296: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_SQL
1297: , v_module => 'jtm_message_log_pkg');
1298: END IF;
1299:
1300: l_cursor := dbms_sql.open_cursor;
1301: dbms_sql.parse( l_cursor, l_dynamic_stmt, dbms_sql.v7);

Line 1312: JTM_MESSAGE_LOG_PKG.UPDATE_CONC_STATUS_LOG

1308: r_query_request.con_query_id;
1309: END IF;
1310: CLOSE c_primary_key;
1311:
1312: JTM_MESSAGE_LOG_PKG.UPDATE_CONC_STATUS_LOG
1313: (v_log_id =>l_start_log_id
1314: ,v_query_stmt => G_Category
1315: ,v_start_time => l_query_start
1316: ,v_end_time => sysdate

Line 1323: JTM_message_log_pkg.Log_Msg

1319: ,x_status => l_status
1320: ,x_msg_data => l_message);
1321:
1322: IF g_debug_level = JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
1323: JTM_message_log_pkg.Log_Msg
1324: ( v_object_id => r_query_request.acc_table_name
1325: , v_object_name => G_PACKAGE_NAME
1326: , v_message => 'Leaving ' || G_PACKAGE_NAME ||'.Process_Request_v2'
1327: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL

Line 1328: , v_module => 'jtm_message_log_pkg');

1324: ( v_object_id => r_query_request.acc_table_name
1325: , v_object_name => G_PACKAGE_NAME
1326: , v_message => 'Leaving ' || G_PACKAGE_NAME ||'.Process_Request_v2'
1327: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
1328: , v_module => 'jtm_message_log_pkg');
1329: END IF;
1330:
1331: EXCEPTION
1332: WHEN OTHERS THEN

Line 1336: JTM_message_log_pkg.Log_Msg

1332: WHEN OTHERS THEN
1333: CLOSE c_primary_key;
1334:
1335: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR THEN
1336: JTM_message_log_pkg.Log_Msg
1337: ( v_object_id => r_query_request.acc_table_name
1338: , v_object_name => G_PACKAGE_NAME
1339: , v_message => 'Leaving ' || G_PACKAGE_NAME ||'.Process_Request_v2 after exception.'
1340: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR

Line 1341: , v_module => 'jtm_message_log_pkg');

1337: ( v_object_id => r_query_request.acc_table_name
1338: , v_object_name => G_PACKAGE_NAME
1339: , v_message => 'Leaving ' || G_PACKAGE_NAME ||'.Process_Request_v2 after exception.'
1340: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR
1341: , v_module => 'jtm_message_log_pkg');
1342: END IF;
1343:
1344: p_status := G_ERROR;
1345: p_message := 'Exception ocurrs while processing query with id ' ||

Line 1348: JTM_MESSAGE_LOG_PKG.UPDATE_CONC_STATUS_LOG

1344: p_status := G_ERROR;
1345: p_message := 'Exception ocurrs while processing query with id ' ||
1346: r_query_request.con_query_id || ': ' || sqlerrm;
1347:
1348: JTM_MESSAGE_LOG_PKG.UPDATE_CONC_STATUS_LOG
1349: (v_log_id =>l_start_log_id
1350: ,v_query_stmt => G_Category
1351: ,v_start_time => l_query_start
1352: ,v_end_time => sysdate

Line 1391: JTM_message_log_pkg.Log_Msg

1387: /*** get debug level ***/
1388: g_debug_level := JTM_HOOK_UTIL_PKG.Get_Debug_Level;
1389:
1390: IF g_debug_level = JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
1391: JTM_message_log_pkg.Log_Msg
1392: ( v_object_id => null
1393: , v_object_name => G_PACKAGE_NAME
1394: , v_message => 'Entering '||G_PACKAGE_NAME||'.' || L_API_NAME
1395: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL

Line 1396: , v_module => 'jtm_message_log_pkg');

1392: ( v_object_id => null
1393: , v_object_name => G_PACKAGE_NAME
1394: , v_message => 'Entering '||G_PACKAGE_NAME||'.' || L_API_NAME
1395: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
1396: , v_module => 'jtm_message_log_pkg');
1397: END IF;
1398:
1399: -- loop over query requests
1400: FOR r_query_request IN c_query_requests LOOP

Line 1444: JTM_message_log_pkg.Log_Msg

1440: ROLLBACK;
1441: --**** todo: return FND_NEW_MESSAGE error
1442: l_retcode := -1;
1443: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR THEN
1444: JTM_message_log_pkg.Log_Msg
1445: ( v_object_id => r_query_request.acc_table_name
1446: , v_object_name => G_PACKAGE_NAME
1447: , v_message => 'Unexpected error encountered in Process_Request: ' || fnd_global.local_chr(10) || sqlerrm
1448: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR

Line 1449: , v_module => 'jtm_message_log_pkg');

1445: ( v_object_id => r_query_request.acc_table_name
1446: , v_object_name => G_PACKAGE_NAME
1447: , v_message => 'Unexpected error encountered in Process_Request: ' || fnd_global.local_chr(10) || sqlerrm
1448: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR
1449: , v_module => 'jtm_message_log_pkg');
1450: END IF;
1451: END;
1452:
1453: IF (l_status = G_ERROR) THEN

Line 1481: JTM_message_log_pkg.Log_Msg

1477: AND UPPER(PROCEDURE_NAME) = L_API_NAME;
1478: COMMIT;
1479:
1480: IF g_debug_level = JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
1481: JTM_message_log_pkg.Log_Msg
1482: ( v_object_id => null
1483: , v_object_name => G_PACKAGE_NAME
1484: , v_message => 'Leaving '||G_PACKAGE_NAME||'.RUN_QUERY_REQUESTS'
1485: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL

Line 1486: , v_module => 'jtm_message_log_pkg');

1482: ( v_object_id => null
1483: , v_object_name => G_PACKAGE_NAME
1484: , v_message => 'Leaving '||G_PACKAGE_NAME||'.RUN_QUERY_REQUESTS'
1485: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL
1486: , v_module => 'jtm_message_log_pkg');
1487: END IF;
1488:
1489: if l_retcode = -1 then
1490: RAISE run_query_error;

Line 1501: JTM_message_log_pkg.Log_Msg

1497: WHEN OTHERS THEN
1498: ROLLBACK;
1499:
1500: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR THEN
1501: JTM_message_log_pkg.Log_Msg
1502: (v_object_id => null
1503: ,v_object_name => G_PACKAGE_NAME
1504: ,v_message => 'Unexpected error encountered in RUN_QUERY_REQUESTS:'
1505: || fnd_global.local_chr(10) || sqlerrm

Line 1507: ,v_module => 'jtm_message_log_pkg');

1503: ,v_object_name => G_PACKAGE_NAME
1504: ,v_message => 'Unexpected error encountered in RUN_QUERY_REQUESTS:'
1505: || fnd_global.local_chr(10) || sqlerrm
1506: ,v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR
1507: ,v_module => 'jtm_message_log_pkg');
1508: END IF;
1509:
1510: END RUN_QUERY_REQUESTS;
1511: