[Home] [Help]
20:
21: BEGIN
22: CSM_UTIL_PKG.LOG
23: ( 'Entering GET_XML_PAYLOAD for TAble Name : ' || p_TABLE_NAME ,
24: FND_LOG.LEVEL_PROCEDURE);
25:
26: --Query Execution status update
27: l_QUERY_TEXT1 := 'SELECT * FROM ' || p_TABLE_NAME ||' WHERE ';
28:
55: x_return_status := FND_API.G_RET_STS_SUCCESS;
56: x_error_message := 'XML Retrieving Successfully completed ';
57: CSM_UTIL_PKG.LOG
58: ( 'Leaving GET_XML_PAYLOAD after successfully Executing Query-> ' || l_QUERY_TEXT1 , 'CSM_HA_EVENT_PKG.GET_XML_PAYLOAD',
59: FND_LOG.LEVEL_PROCEDURE);
60:
61:
62: EXCEPTION WHEN OTHERS THEN
63: /*** catch and log exceptions ***/
62: EXCEPTION WHEN OTHERS THEN
63: /*** catch and log exceptions ***/
64: CSM_UTIL_PKG.LOG
65: ( 'Exception occurred in GET_XML_PAYLOAD for Query : ' || l_QUERY_TEXT1 || SUBSTR(SQLERRM,1,3000), 'CSM_HA_EVENT_PKG.GET_XML_PAYLOAD',
66: FND_LOG.LEVEL_EXCEPTION);
67: x_return_status := FND_API.G_RET_STS_ERROR;
68: x_error_message := 'XML Retrieve Failed With Message : ' || SUBSTR(SQLERRM,1,3000) ;
69: END GET_XML_PAYLOAD;
70:
98:
99: BEGIN
100:
101: CSM_UTIL_PKG.LOG
102: ( 'Tracking entire table : '|| p_TABLE_NAME , 'CSM_HA_EVENT_PKG.TRACK_TABLE', FND_LOG.LEVEL_PROCEDURE);
103:
104: l_pk_names:=get_stringfrom_list(p_PK_NAME_LIST);
105: l_cnt := p_PK_NAME_LIST.COUNT;
106:
159: BEGIN
160:
161: /**************CSM_AUTO_SYNC_NFN *************/
162: CSM_UTIL_PKG.LOG
163: ( 'Record CSM_AUTO_SYNC_NFN' , 'CSM_HA_EVENT_PKG.RECORD_CSM_TABLES', FND_LOG.LEVEL_PROCEDURE);
164:
165: l_pk_name_list(1):= 'NOTIFICATION_ID'; l_pk_type_list(1):= 'NUMBER';
166:
167: FOR rec IN (SELECT NOTIFICATION_ID FROM CSM_AUTO_SYNC_NFN
173:
174:
175: /**************CSM_DEFERRED_NFN_INFO *************/
176: CSM_UTIL_PKG.LOG
177: ( 'Record CSM_DEFERRED_NFN_INFO' , 'CSM_HA_EVENT_PKG.RECORD_CSM_TABLES', FND_LOG.LEVEL_PROCEDURE);
178:
179: l_pk_name_list(1):= 'TRACKING_ID'; l_pk_type_list(1):= 'NUMBER';
180:
181: FOR rec IN (SELECT TRACKING_ID FROM CSM_DEFERRED_NFN_INFO
186: END LOOP;
187:
188: /**************CSM_SYNC_ERROR_NFN_INFO *************/
189: CSM_UTIL_PKG.LOG
190: ( 'Record CSM_SYNC_ERROR_NFN_INFO' , 'CSM_HA_EVENT_PKG.RECORD_CSM_TABLES', FND_LOG.LEVEL_PROCEDURE);
191:
192: l_pk_name_list(1):= 'NOTIFICATION_ID'; l_pk_type_list(1):= 'NUMBER';
193:
194: OPEN cur FOR ' SELECT NOTIFICATION_ID FROM CSM_SYNC_ERROR_NFN_INFO '||
206: --Copy ALL INQ DATA that are DEFERRED in Standby- 3-PK
207:
208: CSM_UTIL_PKG.LOG
209: ( 'Tracking ALL INQ HA records' ,
210: 'CSM_HA_EVENT_PKG.RECORD_CSM_TABLES', FND_LOG.LEVEL_PROCEDURE);
211:
212: l_pk_name_list.extend(2);l_pk_type_list.extend(2);l_pk_value_list.extend(2);
213: l_pk_name_list(1):= 'CLID$$CS'; l_pk_name_list(2):= 'TRANID$$'; l_pk_name_list(3):= 'SEQNO$$';
214: l_pk_type_list(1):= 'VARCHAR'; l_pk_type_list(2):= 'NUMBER'; l_pk_type_list(3):= 'NUMBER';
248: l_PK_NAME_LIST.EXTEND(1); l_pk_type_list.EXTEND(1);
249:
250: /*C$ALL_CLIENTS 1-PK */
251: CSM_UTIL_PKG.LOG
252: ( 'Record MOBILEADMIN.C$ALL_CLIENTS' , 'CSM_HA_EVENT_PKG.RECORD_MFS_DATA', FND_LOG.LEVEL_PROCEDURE);
253: l_pk_name_list(1):= 'CLIENTID'; l_pk_type_list(1):= 'VARCHAR';
254: TRACK_TABLE('MOBILEADMIN.C$ALL_CLIENTS',l_pk_name_list,l_pk_type_list,'Y');
255:
256:
255:
256:
257: /* ASG_USER 1-PK */
258: CSM_UTIL_PKG.LOG
259: ( 'Record ASG_USER' , 'CSM_HA_EVENT_PKG.RECORD_MFS_DATA', FND_LOG.LEVEL_PROCEDURE);
260: l_pk_name_list(1):= 'USER_NAME'; l_pk_type_list(1):= 'VARCHAR';
261: TRACK_TABLE('ASG_USER',l_pk_name_list,l_pk_type_list,'Y');
262:
263:
264: /* ASG_SEQUENCE_PARTITIONS 2-PK */
265:
266: l_PK_NAME_LIST.EXTEND(1); l_pk_type_list.EXTEND(1);
267: CSM_UTIL_PKG.LOG
268: ( 'Record ASG_SEQUENCE_PARTITIONS' , 'CSM_HA_EVENT_PKG.RECORD_MFS_DATA', FND_LOG.LEVEL_PROCEDURE);
269: l_pk_name_list(1):= 'CLIENTID'; l_pk_name_list(2):= 'NAME';
270: l_pk_type_list(1):= 'VARCHAR'; l_pk_type_list(2):= 'VARCHAR';
271: TRACK_TABLE('ASG_SEQUENCE_PARTITIONS',l_pk_name_list,l_pk_type_list,'Y');
272:
275:
276: /*Track Specific MFS records in ASG_DEFERRED_TRANINFO, ASG_USERS_INQINFO,ASG_USERS_INQARCHIVE */
277: CSM_UTIL_PKG.LOG
278: ( 'Track ASG_DEFERRED_TRANINFO HA records' ,
279: 'CSM_HA_EVENT_PKG.RECORD_MFS_DATA', FND_LOG.LEVEL_PROCEDURE);
280:
281:
282:
283: --ASG_DEFERRED_TRANINFO -- 3PKS
301: --ASG_USERS_INQINFO and ASG_USERS_INQARCHIVE --2 PKS
302:
303: CSM_UTIL_PKG.LOG
304: ( 'Track ASG_USERS_INQINFO and ASG_USERS_INQARCHIVE HA records' ,
305: 'CSM_HA_EVENT_PKG.RECORD_MFS_DATA', FND_LOG.LEVEL_PROCEDURE);
306:
307: l_pk_name_list.DELETE;l_pk_type_list.DELETE; l_pk_value_list.DELETE;
308: l_pk_name_list.extend(2);l_pk_type_list.extend(2);l_pk_value_list.extend(2);
309:
323: --MOBILEADMIN.C$SYNC_HISTORY 1-PK
324:
325: CSM_UTIL_PKG.LOG
326: ( 'Tracking MOBILEADMIN.C$SYNC_HISTORY HA records' ,
327: 'CSM_HA_EVENT_PKG.RECORD_MFS_DATA', FND_LOG.LEVEL_PROCEDURE);
328:
329: l_pk_name_list.DELETE;l_pk_type_list.DELETE; l_pk_value_list.DELETE;
330: l_pk_name_list.EXTEND(1);l_pk_type_list.EXTEND(1); l_pk_value_list.EXTEND(1);
331:
345: --MOBILEADMIN.C$SYNC_HIS_PUB_ITEMS 3-PK
346:
347: CSM_UTIL_PKG.LOG
348: ( 'Tracking MOBILEADMIN.C$SYNC_HIS_PUB_ITEMS HA records' ,
349: 'CSM_HA_EVENT_PKG.RECORD_MFS_DATA', FND_LOG.LEVEL_PROCEDURE);
350:
351: l_pk_name_list.DELETE;l_pk_type_list.DELETE; l_pk_value_list.DELETE;
352: l_pk_name_list.EXTEND(3);l_pk_type_list.EXTEND(3); l_pk_value_list.EXTEND(3);
353:
365: CLOSE cur;
366:
367: -- Process ASG_SYSTEM_DIRTY_QUEUE - pending download data
368: CSM_UTIL_PKG.LOG
369: ( 'No Pld Track of ASG_SYSTEM_DIRTY_QUEUE' , 'CSM_HA_EVENT_PKG.RECORD_MFS_DATA', FND_LOG.LEVEL_PROCEDURE);
370:
371: FOR rec IN (SELECT DISTINCT USER_ID,HA_PARENT_PAYLOAD_ID
372: FROM ASG_SYSTEM_DIRTY_QUEUE a, ASG_USER b
373: WHERE HA_PARENT_PAYLOAD_ID IS NOT NULL
648: x boolean;
649: BEGIN
650:
651: CSM_UTIL_PKG.LOG('Setting HA Profile to value :'||p_value,
652: 'CSM_HA_EVENT_PKG.SET_HA_PROFILE', FND_LOG.LEVEL_PROCEDURE);
653:
654: x:=FND_PROFILE.SAVE('CSM_HA_MODE',p_value,'SITE');
655: COMMIT;
656: END SET_HA_PROFILE;
672: l_prf:=NULL;
673: END;
674:
675: CSM_UTIL_PKG.LOG('Current HA Profile value :'||l_prf,
676: 'CSM_HA_EVENT_PKG.GET_HA_PROFILE_VALUE', FND_LOG.LEVEL_PROCEDURE);
677:
678: return l_prf;
679: END GET_HA_PROFILE_VALUE;
680:
687: l_ha_session_id NUMBER;
688: BEGIN
689:
690: CSM_UTIL_PKG.LOG('Setting Date format to DD-MON-RR HH24:MI:SS',
691: 'CSM_HA_EVENT_PKG.SET_SESSION', FND_LOG.LEVEL_PROCEDURE);
692: EXECUTE IMMEDIATE 'ALTER SESSION SET NLS_DATE_FORMAT=''DD-MON-RR HH24:MI:SS''';
693:
694:
695:
702:
703: IF p_create_flag THEN -- concurrent request case : to reuse existing session
704:
705: CSM_UTIL_PKG.LOG('Re-Using session id '||G_HA_SESSION_SEQUENCE||' created by a concurrent race condition.',
706: 'CSM_HA_EVENT_PKG.SET_SESSION', FND_LOG.LEVEL_PROCEDURE);
707:
708: G_HA_START_TIME := SYSTIMESTAMP;
709: SELECT CSM_HA_PAYLOAD_DATA_S.nextval INTO G_HA_PAYLOAD_SEQUENCE_START FROM DUAL;
710:
714: WHERE SESSION_ID=G_HA_SESSION_SEQUENCE;
715: END IF;
716:
717: CSM_UTIL_PKG.LOG('Current Session set to Id :'||G_HA_SESSION_SEQUENCE,
718: 'CSM_HA_EVENT_PKG.SET_SESSION', FND_LOG.LEVEL_PROCEDURE);
719:
720: RETURN;
721: EXCEPTION
722: WHEN NO_DATA_FOUND THEN
724: END;
725:
726: IF NOT p_create_flag THEN
727: CSM_UTIL_PKG.LOG('No open session found.Leaving without creating session since session creation is switched OFF',
728: 'CSM_HA_EVENT_PKG.SET_SESSION', FND_LOG.LEVEL_PROCEDURE);
729: RETURN;
730: END IF;
731:
732: OPEN c_get_session;
733: FETCH c_get_session INTO l_ha_session_id;
734: CLOSE c_get_session;
735:
736: CSM_UTIL_PKG.LOG('Creating new Session with Id :'||l_ha_session_id,
737: 'CSM_HA_EVENT_PKG.SET_SESSION', FND_LOG.LEVEL_PROCEDURE);
738:
739: --Set Session Variables
740: G_HA_SESSION_SEQUENCE := l_ha_session_id;
741: G_HA_START_TIME := SYSTIMESTAMP;
807:
808:
809: IF l_seq_map_list.COUNT = 0 THEN
810: CSM_UTIL_PKG.log( 'No Business Object Sequence seems to have been updated in this recording session',
811: 'CSM_HA_EVENT_PKG.SAVE_SEQUENCE', FND_LOG.LEVEL_STATEMENT);
812: RETURN;
813: END IF;
814:
815: FOR j in 1..l_seq_map_list.COUNT
820: INTO l_curr_seq_value;
821:
822: CSM_UTIL_PKG.log( 'RECORD: SESSION_ID: ' || P_SESSION_ID || ' SEQUENCE_NAME: '
823: ||l_sequence_list(j) || ' Sequence Value: ' || l_curr_seq_value,
824: 'CSM_HA_EVENT_PKG.SAVE_SEQUENCE', FND_LOG.LEVEL_STATEMENT);
825:
826: BEGIN
827: INSERT INTO CSM_HA_SESSION_SEQ_VALUES(SESSION_ID,SEQ_MAPPING_ID,
828: RECORDED_SEQUENCE,CREATION_DATE,CREATED_BY,LAST_UPDATE_DATE,LAST_UPDATED_BY,LAST_UPDATE_LOGIN)
829: VALUES(p_session_id,l_seq_map_list(j),l_curr_seq_value,sysdate,1,sysdate,1,1);
830: EXCEPTION
831: WHEN Others THEN
832: CSM_UTIL_PKG.log('Rare Case: Caused by concurrent calls - mostly reported by QA'
833: ,'CSM_HA_EVENT_PKG.SAVE_SEQUENCE', FND_LOG.LEVEL_STATEMENT);
834: UPDATE CSM_HA_SESSION_SEQ_VALUES
835: SET RECORDED_SEQUENCE = l_curr_seq_value
836: WHERE SESSION_ID=p_session_id
837: AND SEQ_MAPPING_ID = L_SEQ_MAP_LIST(J)
843: INTO l_curr_seq_value;
844:
845: CSM_UTIL_PKG.log( 'APPLY: SESSION_ID: ' || P_SESSION_ID || ' SEQUENCE_NAME: '
846: ||l_sequence_list(j) || ' Sequence Value: ' || l_curr_seq_value,
847: 'CSM_HA_EVENT_PKG.SAVE_SEQUENCE', FND_LOG.LEVEL_STATEMENT);
848:
849: UPDATE CSM_HA_SESSION_SEQ_VALUES
850: SET APPLY_SEQUENCE = l_curr_seq_value
851: WHERE SESSION_ID=p_session_id
855: l_inc_by_value := l_end_seq_value - l_start_seq_value;
856:
857: IF(l_inc_by_value > 0) THEN
858: L_SQL_QUERY := 'ALTER SEQUENCE '||L_SEQUENCE_LIST(J) ||' INCREMENT BY ' || l_inc_by_value;
859: CSM_UTIL_PKG.log(L_SQL_QUERY, 'CSM_HA_EVENT_PKG.SAVE_SEQUENCE', FND_LOG.LEVEL_STATEMENT);
860: execute immediate L_SQL_QUERY;
861:
862: /* This select actually increments the sequence value */
863: execute immediate 'SELECT ' ||L_SEQUENCE_LIST(J) || '.NEXTVAL FROM dual'
864: into L_APPLIED_SEQUENCE_VALUE;
865:
866: CSM_UTIL_PKG.log('Sequence: ' || L_SEQUENCE_LIST(J) ||
867: ' Modified Sequence Value: ' || l_applied_sequence_value,
868: 'CSM_HA_EVENT_PKG.SAVE_SEQUENCE', FND_LOG.LEVEL_STATEMENT);
869:
870: UPDATE CSM_HA_SESSION_SEQ_VALUES
871: set AFTER_APPLY_SEQUENCE = L_APPLIED_SEQUENCE_VALUE
872: WHERE SESSION_ID=p_session_id
873: and SEQ_MAPPING_ID = L_SEQ_MAP_LIST(J);
874:
875: /* Set the increment_by back to what it was */
876: L_SQL_QUERY := 'ALTER SEQUENCE '||L_SEQUENCE_LIST(J) ||' INCREMENT BY ' || l_inc_list(J);
877: CSM_UTIL_PKG.log(L_SQL_QUERY, 'CSM_HA_EVENT_PKG.SAVE_SEQUENCE',FND_LOG.LEVEL_STATEMENT);
878: execute immediate L_SQL_QUERY;
879:
880: end if;
881: END IF;
885: EXCEPTION WHEN OTHERS THEN
886: /*** catch and log exceptions ***/
887: CSM_UTIL_PKG.LOG
888: ( 'Exception occurred in SAVE_SEQUENCE : ' || SUBSTR(SQLERRM,1,3000), 'CSM_HA_EVENT_PKG.SAVE_SEQUENCE',
889: FND_LOG.LEVEL_EXCEPTION);
890: RAISE;
891: END SAVE_SEQUENCE;
892:
893: PROCEDURE MANAGE_MFS_CONC
910: l_pk_value_list CSM_VARCHAR_LIST:=CSM_VARCHAR_LIST('');
911:
912: BEGIN
913:
914: CSM_UTIL_PKG.LOG('Recording Incident Links','CSM_HA_EVENT_PKG.RECORD_MISC_DATA', FND_LOG.LEVEL_PROCEDURE);
915: --CS_INCIDENT_LINKS
916:
917: l_pk_name_list(1):= 'LINK_ID';
918: l_pk_type_list(1):= 'NUMBER';
933: l_pk_value_list(1):=rec.LINK_ID;
934: TRACK_HA_RECORD('CS_INCIDENT_LINKS',l_pk_name_list,l_pk_type_list,l_pk_value_list,'U','N');
935: END LOOP;
936:
937: CSM_UTIL_PKG.LOG('Recording Related Objects','CSM_HA_EVENT_PKG.RECORD_MISC_DATA', FND_LOG.LEVEL_PROCEDURE);
938: --CS_INCIDENT_LINKS_EXT
939:
940: l_pk_name_list(1):= 'LINK_ID';
941: l_pk_type_list(1):= 'NUMBER';
957: TRACK_HA_RECORD('CS_INCIDENT_LINKS_EXT',l_pk_name_list,l_pk_type_list,l_pk_value_list,'U','N');
958: END LOOP;
959:
960:
961: CSM_UTIL_PKG.LOG('Recording CUG INCIDENT ATTRIBUTES Data','CSM_HA_EVENT_PKG.RECORD_MISC_DATA', FND_LOG.LEVEL_PROCEDURE);
962: -- CUG_INCIDNT_ATTR_VALS_B
963: l_pk_name_list(1):= 'INCIDNT_ATTR_VAL_ID';
964: l_pk_type_list(1):= 'NUMBER';
965:
979: l_pk_value_list(1):=rec.INCIDNT_ATTR_VAL_ID;
980: TRACK_HA_RECORD('CUG_INCIDNT_ATTR_VALS_B',l_pk_name_list,l_pk_type_list,l_pk_value_list,'U','N');
981: END LOOP;
982:
983: CSM_UTIL_PKG.LOG('Recording Access Hours','CSM_HA_EVENT_PKG.RECORD_MISC_DATA', FND_LOG.LEVEL_PROCEDURE);
984: --CSF_ACCESS_HOURS_B
985:
986: l_pk_name_list(1):= 'ACCESS_HOUR_ID';
987: l_pk_type_list(1):= 'NUMBER';
1002: l_pk_value_list(1):=rec.ACCESS_HOUR_ID;
1003: TRACK_HA_RECORD('CSF_ACCESS_HOURS_B',l_pk_name_list,l_pk_type_list,l_pk_value_list,'U','N');
1004: END LOOP;
1005:
1006: CSM_UTIL_PKG.LOG('Recording Required Skills','CSM_HA_EVENT_PKG.RECORD_MISC_DATA', FND_LOG.LEVEL_PROCEDURE);
1007: --CSF_REQUIRED_SKILLS_B
1008:
1009: l_pk_name_list(1):= 'REQUIRED_SKILL_ID';
1010: l_pk_type_list(1):= 'NUMBER';
1025: l_pk_value_list(1):=rec.REQUIRED_SKILL_ID;
1026: TRACK_HA_RECORD('CSF_REQUIRED_SKILLS_B',l_pk_name_list,l_pk_type_list,l_pk_value_list,'U','N');
1027: END LOOP;
1028:
1029: CSM_UTIL_PKG.LOG('Recording MFS Data','CSM_HA_EVENT_PKG.RECORD_MISC_DATA', FND_LOG.LEVEL_PROCEDURE);
1030:
1031: RECORD_MFS_DATA;
1032:
1033: END RECORD_MISC_DATA;
1058: x_ERROR_MESSAGE := 'HA Recording Successfully Started';
1059:
1060: IF GET_HA_PROFILE_VALUE = 'HA_RECORD' THEN
1061: CSM_UTIL_PKG.LOG( 'Call End HA Tracking to end existing session.',
1062: 'CSM_HA_EVENT_PKG.BEGIN_HA_TRACKING', FND_LOG.LEVEL_PROCEDURE);
1063: x_RETURN_STATUS := FND_API.G_RET_STS_ERROR;
1064: x_ERROR_MESSAGE := 'Another Start HA Recording session is already in progress.';
1065: RETURN;
1066: END IF;
1070: SET_HA_PROFILE('HA_RECORD');
1071:
1072: /* SetUp recording*/
1073: CSM_UTIL_PKG.LOG( 'Assigning HA Responsibilities to FND Users with non-HA responsibilities',
1074: 'CSM_HA_EVENT_PKG.BEGIN_HA_TRACKING', FND_LOG.LEVEL_PROCEDURE);
1075: l_module := 'Assigning HA Responsibilities';
1076:
1077: ASSIGN_HA_RESPONSIBILITIES;
1078: COMMIT;
1078: COMMIT;
1079:
1080:
1081: CSM_UTIL_PKG.LOG( 'Deactivating non-HA and non-FND Responsibilities',
1082: 'CSM_HA_EVENT_PKG.BEGIN_HA_TRACKING', FND_LOG.LEVEL_PROCEDURE);
1083: l_module := 'Deactivating non-HA Responsibilities';
1084:
1085: DEACTIVATE_NON_HA_RESPS;
1086: COMMIT;
1085: DEACTIVATE_NON_HA_RESPS;
1086: COMMIT;
1087:
1088: CSM_UTIL_PKG.LOG('Managing Concurrent Programs',
1089: 'CSM_HA_EVENT_PKG.BEGIN_HA_TRACKING', FND_LOG.LEVEL_PROCEDURE);
1090: l_module := 'Managing HA Concurrent Programs';
1091:
1092: MANAGE_CONCURRENT_PROGRAMS;
1093: COMMIT;
1092: MANAGE_CONCURRENT_PROGRAMS;
1093: COMMIT;
1094:
1095: CSM_UTIL_PKG.LOG('Deactivating non-HA WF Components',
1096: 'CSM_HA_EVENT_PKG.BEGIN_HA_TRACKING', FND_LOG.LEVEL_PROCEDURE);
1097: l_module := 'Deactivating non-HA WF Components';
1098:
1099: DEACTIVATE_WF_COMPONENTS;
1100: COMMIT;
1100: COMMIT;
1101:
1102:
1103: CSM_UTIL_PKG.LOG('Managing JTM Concurrent Programs',
1104: 'CSM_HA_EVENT_PKG.BEGIN_HA_TRACKING', FND_LOG.LEVEL_PROCEDURE);
1105: l_module := 'Managing MFS Concurrent Programs';
1106:
1107: MANAGE_MFS_CONC;
1108: COMMIT;
1115: WHEN OTHERS THEN
1116: /*** catch and log exceptions ***/
1117: CSM_UTIL_PKG.LOG
1118: ( 'Exception occurred in BEGIN_HA_TRACKING while '||l_module||':'|| SUBSTR(SQLERRM,1,3000), 'CSM_HA_EVENT_PKG.BEGIN_HA_TRACKING',
1119: FND_LOG.LEVEL_EXCEPTION);
1120: x_return_status := FND_API.G_RET_STS_ERROR;
1121: x_error_message := 'BEGIN_HA_TRACKING failed while '||l_module||' with error:' || SUBSTR(SQLERRM,1,3000) ;
1122: ROLLBACK;
1123: SET_HA_PROFILE('HA_STOP');
1136:
1137: /*to limit concurrent requests: setting profile first */
1138: IF GET_HA_PROFILE_VALUE = 'HA_STOP' THEN
1139: CSM_UTIL_PKG.LOG('Another End recording is already in progress..',
1140: 'CSM_HA_EVENT_PKG.END_HA_TRACKING', FND_LOG.LEVEL_PROCEDURE);
1141: x_RETURN_STATUS := FND_API.G_RET_STS_ERROR;
1142: x_ERROR_MESSAGE := 'Another Stop HA Recording is already in progress..';
1143: RETURN;
1144: END IF;
1148:
1149: SET_SESSION(false); -- to set global variables if not set in this DB session
1150:
1151: CSM_UTIL_PKG.LOG('Tracking FND attachments missed by LOOKUP program',
1152: 'CSM_HA_EVENT_PKG.END_HA_TRACKING', FND_LOG.LEVEL_PROCEDURE);
1153: l_module := 'Tracking FND attachments missed by LOOKUP program';
1154:
1155: TRACK_HA_ATTACHMENTS; --it commits while end_tracking to improve perf
1156:
1154:
1155: TRACK_HA_ATTACHMENTS; --it commits while end_tracking to improve perf
1156:
1157: CSM_UTIL_PKG.LOG('Recording Miscellaneous Data',
1158: 'CSM_HA_EVENT_PKG.END_HA_TRACKING', FND_LOG.LEVEL_PROCEDURE);
1159: l_module := 'Tracking Miscellaneous Data';
1160:
1161: RECORD_MISC_DATA;
1162:
1167: SAVE_SEQUENCE(G_HA_SESSION_SEQUENCE,'R',G_HA_PAYLOAD_SEQUENCE_START,G_HA_PAYLOAD_SEQUENCE_END);
1168:
1169:
1170: CSM_UTIL_PKG.LOG('End Session with Id: '||G_HA_SESSION_SEQUENCE,
1171: 'CSM_HA_EVENT_PKG.END_HA_TRACKING', FND_LOG.LEVEL_PROCEDURE);
1172: l_module := 'Terminating Current Session';
1173: END_SESSION;
1174:
1175: G_IS_END_TRACKING_CALL := FALSE;
1178: WHEN OTHERS THEN
1179: /*** catch and log exceptions ***/
1180: CSM_UTIL_PKG.LOG
1181: ( 'Exception occurred in END_HA_TRACKING while '||l_module||':'|| SUBSTR(SQLERRM,1,3000), 'CSM_HA_EVENT_PKG.END_HA_TRACKING',
1182: FND_LOG.LEVEL_EXCEPTION);
1183: x_return_status := FND_API.G_RET_STS_ERROR;
1184: x_error_message := 'END_HA_TRACKING failed while '||l_module||' with error:' || SUBSTR(SQLERRM,1,3000) ;
1185: ROLLBACK;
1186: G_IS_END_TRACKING_CALL := FALSE;
1316:
1317: CSM_UTIL_PKG.LOG
1318: ( 'Check for aux with parent payload Id:'||p_parent_payload_id
1319: ||' of TAB/PK:'||l_bo_name||'/'||l_pk_value,
1320: 'CSM_HA_EVENT_PKG.TRACK_AUX_TABLE_RECORDS', FND_LOG.LEVEL_PROCEDURE);
1321:
1322: FOR rec IN (SELECT AO_TABLE_NAME,FETCH_SQL
1323: FROM CSM_HA_AUX_MAPPINGS
1324: WHERE BO_TABLE_NAME=l_bo_name
1343: EXIT WHEN CUR%NOTFOUND;
1344:
1345: CSM_UTIL_PKG.LOG
1346: ( 'Tracking Aux table:'||rec.AO_TABLE_NAME||' with ('||l_ax_pk_column||')=('||l_ax_pk_value||')',
1347: 'CSM_HA_EVENT_PKG.TRACK_AUX_TABLE_RECORDS', FND_LOG.LEVEL_PROCEDURE);
1348:
1349: l_pk_value_list := get_listfrom_String(l_ax_pk_value);
1350:
1351: TRACK_HA_RECORD(rec.AO_TABLE_NAME ,l_pk_name_list,l_pk_type_list,l_pk_value_list,'I','N',p_parent_payload_id);
1371: l_pk_values:=get_stringfrom_list(p_PK_VALUE_LIST);
1372:
1373: CSM_UTIL_PKG.LOG
1374: ( 'Entering TRACK_HA_RECORD with '||p_TABLE_NAME||'-'||l_pk_values||'-'||p_dml_type||'-'||p_mobile_data||'-'||p_parent_payload_id ,
1375: 'CSM_HA_EVENT_PKG.TRACK_HA_RECORD', FND_LOG.LEVEL_PROCEDURE);
1376:
1377:
1378: l_tracking_ON := GET_HA_PROFILE_VALUE;
1379:
1378: l_tracking_ON := GET_HA_PROFILE_VALUE;
1379:
1380: IF (NOT G_IS_END_TRACKING_CALL) AND (l_tracking_ON IS NULL OR l_tracking_ON <> 'HA_RECORD') THEN
1381: CSM_UTIL_PKG.LOG
1382: ( 'Leaving TRACK_HA_RECORD as tracking is switched OFF' , 'CSM_HA_EVENT_PKG.TRACK_HA_RECORD', FND_LOG.LEVEL_PROCEDURE);
1383: RETURN;
1384: END IF;
1385:
1386: SET_SESSION(false);
1387:
1388: IF(G_HA_SESSION_SEQUENCE IS NULL) THEN -- never happens
1389: CSM_UTIL_PKG.LOG
1390: ( 'No Open session found. Leaving without tracking.' ,
1391: 'CSM_HA_EVENT_PKG.TRACK_HA_RECORD', FND_LOG.LEVEL_PROCEDURE);
1392: RETURN;
1393: END IF;
1394:
1395: GET_XML_PAYLOAD(p_TABLE_NAME,p_PK_NAME_LIST,p_PK_TYPE_LIST,p_PK_VALUE_LIST,l_XML_PAYLOAD,l_XML_CONTEXT,l_RETURN_STATUS,l_ERROR_MESSAGE);
1397: IF(l_RETURN_STATUS <> FND_API.G_RET_STS_SUCCESS) THEN
1398: RAISE_APPLICATION_ERROR(-20222,'HA Tracking failed :'||l_ERROR_MESSAGE);
1399: ELSE
1400: IF (l_XML_PAYLOAD IS NULL) THEN
1401: CSM_UTIL_PKG.LOG('PAYLOAD IS NULL', 'CSM_HA_EVENT_PKG.TRACK_HA_RECORD',FND_LOG.LEVEL_PROCEDURE);
1402: RAISE_APPLICATION_ERROR(-20222,'HA Tracking failed : XML Payload is null');
1403: END IF;
1404:
1405:
1422:
1423: EXCEPTION
1424: WHEN OTHERS THEN
1425: CSM_UTIL_PKG.LOG
1426: ( 'Exception occurred in TRACK_HA_RECORD -' || SUBSTR(SQLERRM,1,3000), 'CSM_HA_EVENT_PKG.TRACK_HA_RECORD',FND_LOG.LEVEL_EXCEPTION);
1427: RAISE;
1428: END TRACK_HA_RECORD;
1429:
1430: PROCEDURE TRACK_HA_ATTACHMENTS