DBA Data[Home] [Help]

APPS.XDP_PURGE dependencies on XNP_MSGS

Line 153: SELECT COUNT(*) INTO l_no_records FROM XNP_MSGS

149:
150: RECORDS_PURGED_MSGS(l_no_records ,'XDP_ORDER_RELATIONSHIPS WHERE ORDER_ID = '||p_order_id,
151: 'XDP_FOUND_REC',0);
152:
153: SELECT COUNT(*) INTO l_no_records FROM XNP_MSGS
154: WHERE ORDER_ID = p_order_id;
155:
156: RECORDS_PURGED_MSGS(l_no_records,'XNP_MSGS WHERE ORDER_ID = '||p_order_id,
157: 'XDP_FOUND_REC',0);

Line 156: RECORDS_PURGED_MSGS(l_no_records,'XNP_MSGS WHERE ORDER_ID = '||p_order_id,

152:
153: SELECT COUNT(*) INTO l_no_records FROM XNP_MSGS
154: WHERE ORDER_ID = p_order_id;
155:
156: RECORDS_PURGED_MSGS(l_no_records,'XNP_MSGS WHERE ORDER_ID = '||p_order_id,
157: 'XDP_FOUND_REC',0);
158:
159: SELECT COUNT(*) INTO l_no_records FROM XDP_ORDER_PARAMETERS
160: WHERE ORDER_ID = p_order_id;

Line 791: SELECT COUNT(*) INTO l_temp FROM XNP_MSGS

787: -- else, only purge internal messages which are identified
788: -- the the protected flag in xnp_msg_type_b
789:
790: IF p_purge_msg THEN
791: SELECT COUNT(*) INTO l_temp FROM XNP_MSGS
792: WHERE order_id = p_order_id;
793: ELSE
794: SELECT COUNT(*) INTO l_temp FROM XNP_MSGS
795: WHERE order_id = p_order_id

Line 794: SELECT COUNT(*) INTO l_temp FROM XNP_MSGS

790: IF p_purge_msg THEN
791: SELECT COUNT(*) INTO l_temp FROM XNP_MSGS
792: WHERE order_id = p_order_id;
793: ELSE
794: SELECT COUNT(*) INTO l_temp FROM XNP_MSGS
795: WHERE order_id = p_order_id
796: AND msg_code IN
797: (SELECT MSG_CODE FROM XNP_MSG_TYPES_B
798: WHERE PROTECTED_FLAG='Y');

Line 801: RECORDS_PURGED_MSGS(l_temp,'XNP_MSGS WHERE ORDER_ID = '||p_order_id

797: (SELECT MSG_CODE FROM XNP_MSG_TYPES_B
798: WHERE PROTECTED_FLAG='Y');
799: END IF;
800:
801: RECORDS_PURGED_MSGS(l_temp,'XNP_MSGS WHERE ORDER_ID = '||p_order_id
802: ,l_rec_name,0);
803: SELECT COUNT(*) INTO l_temp FROM XNP_CALLBACK_EVENTS
804: WHERE order_id = p_order_id;
805: RECORDS_PURGED_MSGS(l_temp,'XNP_CALLBACK_EVENTS WHERE ORDER_ID = '

Line 830: DELETE FROM XNP_MSGS

826: -- else we will only delete internal messages that are associated with this order
827: -- This operation will not delete any messages whose order id field is null.
828: --
829: IF p_purge_msg THEN
830: DELETE FROM XNP_MSGS
831: WHERE order_id = p_order_id;
832: ELSE
833: DELETE FROM XNP_MSGS
834: WHERE order_id = p_order_id

Line 833: DELETE FROM XNP_MSGS

829: IF p_purge_msg THEN
830: DELETE FROM XNP_MSGS
831: WHERE order_id = p_order_id;
832: ELSE
833: DELETE FROM XNP_MSGS
834: WHERE order_id = p_order_id
835: AND msg_code IN
836: (SELECT MSG_CODE FROM XNP_MSG_TYPES_B
837: WHERE PROTECTED_FLAG='Y');

Line 1062: CURSOR c_xnp_msgs_1 IS

1058: ) IS
1059:
1060: -- delete all messages that are not associated with an order
1061: -- 03/30/2001. Modified. Replaced CREATION_DATE with MSG_CREATION_DATE. rnyberg
1062: CURSOR c_xnp_msgs_1 IS
1063: SELECT MSG_ID FROM XNP_MSGS M
1064: WHERE
1065: (M.MSG_STATUS IN ('PROCESSED','TIME_OUT'))
1066: AND MSG_CREATION_DATE < p_time_to

Line 1063: SELECT MSG_ID FROM XNP_MSGS M

1059:
1060: -- delete all messages that are not associated with an order
1061: -- 03/30/2001. Modified. Replaced CREATION_DATE with MSG_CREATION_DATE. rnyberg
1062: CURSOR c_xnp_msgs_1 IS
1063: SELECT MSG_ID FROM XNP_MSGS M
1064: WHERE
1065: (M.MSG_STATUS IN ('PROCESSED','TIME_OUT'))
1066: AND MSG_CREATION_DATE < p_time_to
1067: AND MSG_CREATION_DATE > p_time_from

Line 1071: CURSOR c_xnp_msgs_2 IS

1067: AND MSG_CREATION_DATE > p_time_from
1068: FOR UPDATE OF MSG_ID NOWAIT;
1069:
1070: -- 03/30/2001. Modified. Replaced CREATION_DATE with MSG_CREATION_DATE. rnyberg
1071: CURSOR c_xnp_msgs_2 IS
1072: SELECT MSG_ID FROM XNP_MSGS M
1073: WHERE
1074: (M.MSG_STATUS IN ('PROCESSED','TIME_OUT'))
1075: AND MSG_CREATION_DATE < p_time_to

Line 1072: SELECT MSG_ID FROM XNP_MSGS M

1068: FOR UPDATE OF MSG_ID NOWAIT;
1069:
1070: -- 03/30/2001. Modified. Replaced CREATION_DATE with MSG_CREATION_DATE. rnyberg
1071: CURSOR c_xnp_msgs_2 IS
1072: SELECT MSG_ID FROM XNP_MSGS M
1073: WHERE
1074: (M.MSG_STATUS IN ('PROCESSED','TIME_OUT'))
1075: AND MSG_CREATION_DATE < p_time_to
1076: AND MSG_CREATION_DATE > p_time_from

Line 1080: l_xnp_msg XNP_MSGS.MSG_ID%TYPE;

1076: AND MSG_CREATION_DATE > p_time_from
1077: AND NOT Exists (SELECT ORDER_ID from xdp_order_headers where (order_id=m.order_id))
1078: FOR UPDATE OF MSG_ID NOWAIT;
1079:
1080: l_xnp_msg XNP_MSGS.MSG_ID%TYPE;
1081:
1082: l_counter NUMBER := 0;
1083: l_no_msgs NUMBER := 0;
1084: l_temp NUMBER := 0;

Line 1094: SELECT COUNT(*) INTO l_no_msgs FROM XNP_MSGS

1090: PURGE_ERRORS('==== '||p_run_mode|| ' Messages ' ||' ===================');
1091: IF(p_run_mode = 'CHECK') THEN
1092: IF(P_ORDER_PURGE_MODE) THEN
1093: -- 03/30/2001. Modified. Replaced CREATION_DATE with MSG_CREATION_DATE. rnyberg
1094: SELECT COUNT(*) INTO l_no_msgs FROM XNP_MSGS
1095: WHERE
1096: MSG_STATUS IN ('PROCESSED','TIME_OUT')
1097: AND MSG_CREATION_DATE < p_time_to
1098: AND MSG_CREATION_DATE > p_time_from;

Line 1100: SELECT COUNT(*) INTO l_no_msgs FROM XNP_MSGS M

1096: MSG_STATUS IN ('PROCESSED','TIME_OUT')
1097: AND MSG_CREATION_DATE < p_time_to
1098: AND MSG_CREATION_DATE > p_time_from;
1099: ELSE
1100: SELECT COUNT(*) INTO l_no_msgs FROM XNP_MSGS M
1101: WHERE
1102: -- 03/30/2001. Modified. Replaced CREATION_DATE with MSG_CREATION_DATE. rnyberg
1103: MSG_STATUS IN ('PROCESSED','TIME_OUT')
1104: AND MSG_CREATION_DATE < p_time_to

Line 1108: RECORDS_PURGED_MSGS(l_no_msgs,'XNP_MSGS',l_rec_name,-1);

1104: AND MSG_CREATION_DATE < p_time_to
1105: AND MSG_CREATION_DATE > p_time_from
1106: AND NOT Exists (SELECT ORDER_ID from xdp_order_headers where (order_id=m.order_id));
1107: END IF;
1108: RECORDS_PURGED_MSGS(l_no_msgs,'XNP_MSGS',l_rec_name,-1);
1109: RETURN;
1110: END IF;
1111:
1112: IF(p_run_mode = 'PURGE') THEN

Line 1124: OPEN c_xnp_msgs_1;

1120: LOOP
1121: SAVEPOINT MSG_RLBK;
1122: -- REOPEN IT AFTER COMMIT
1123: IF(P_ORDER_PURGE_MODE) THEN
1124: OPEN c_xnp_msgs_1;
1125: ELSE
1126: OPEN c_xnp_msgs_2;
1127: END IF;
1128: <>

Line 1126: OPEN c_xnp_msgs_2;

1122: -- REOPEN IT AFTER COMMIT
1123: IF(P_ORDER_PURGE_MODE) THEN
1124: OPEN c_xnp_msgs_1;
1125: ELSE
1126: OPEN c_xnp_msgs_2;
1127: END IF;
1128: <>
1129: LOOP
1130: IF(P_ORDER_PURGE_MODE) THEN

Line 1131: FETCH c_xnp_msgs_1 INTO l_xnp_msg;

1127: END IF;
1128: <>
1129: LOOP
1130: IF(P_ORDER_PURGE_MODE) THEN
1131: FETCH c_xnp_msgs_1 INTO l_xnp_msg;
1132: IF c_xnp_msgs_1%notfound THEN
1133: EXIT OUTER_XNP_MSG; -- we are done
1134: END IF;
1135:

Line 1132: IF c_xnp_msgs_1%notfound THEN

1128: <>
1129: LOOP
1130: IF(P_ORDER_PURGE_MODE) THEN
1131: FETCH c_xnp_msgs_1 INTO l_xnp_msg;
1132: IF c_xnp_msgs_1%notfound THEN
1133: EXIT OUTER_XNP_MSG; -- we are done
1134: END IF;
1135:
1136: IF p_run_mode = 'PURGE' THEN

Line 1139: DELETE FROM XNP_MSGS WHERE CURRENT OF c_xnp_msgs_1;

1135:
1136: IF p_run_mode = 'PURGE' THEN
1137: XDP_PRUGE_TIMER(l_xnp_msg);
1138:
1139: DELETE FROM XNP_MSGS WHERE CURRENT OF c_xnp_msgs_1;
1140: END IF;
1141: ELSE
1142: FETCH c_xnp_msgs_2 INTO l_xnp_msg;
1143: IF c_xnp_msgs_2%notfound THEN

Line 1142: FETCH c_xnp_msgs_2 INTO l_xnp_msg;

1138:
1139: DELETE FROM XNP_MSGS WHERE CURRENT OF c_xnp_msgs_1;
1140: END IF;
1141: ELSE
1142: FETCH c_xnp_msgs_2 INTO l_xnp_msg;
1143: IF c_xnp_msgs_2%notfound THEN
1144: EXIT OUTER_XNP_MSG; -- we are done
1145: END IF;
1146:

Line 1143: IF c_xnp_msgs_2%notfound THEN

1139: DELETE FROM XNP_MSGS WHERE CURRENT OF c_xnp_msgs_1;
1140: END IF;
1141: ELSE
1142: FETCH c_xnp_msgs_2 INTO l_xnp_msg;
1143: IF c_xnp_msgs_2%notfound THEN
1144: EXIT OUTER_XNP_MSG; -- we are done
1145: END IF;
1146:
1147: IF p_run_mode = 'PURGE' THEN

Line 1150: DELETE FROM XNP_MSGS WHERE CURRENT OF c_xnp_msgs_2;

1146:
1147: IF p_run_mode = 'PURGE' THEN
1148: XDP_PRUGE_TIMER(l_xnp_msg);
1149: --
1150: DELETE FROM XNP_MSGS WHERE CURRENT OF c_xnp_msgs_2;
1151: END IF;
1152: END IF;
1153:
1154: l_no_msgs := l_no_msgs + 1;

Line 1166: IF (c_xnp_msgs_1%ISOPEN) THEN

1162:
1163: END LOOP INNER_XNP_MSG;
1164:
1165: IF(P_ORDER_PURGE_MODE) THEN
1166: IF (c_xnp_msgs_1%ISOPEN) THEN
1167: CLOSE c_xnp_msgs_1;
1168: END IF;
1169: ELSE
1170: IF (c_xnp_msgs_2%ISOPEN) THEN

Line 1167: CLOSE c_xnp_msgs_1;

1163: END LOOP INNER_XNP_MSG;
1164:
1165: IF(P_ORDER_PURGE_MODE) THEN
1166: IF (c_xnp_msgs_1%ISOPEN) THEN
1167: CLOSE c_xnp_msgs_1;
1168: END IF;
1169: ELSE
1170: IF (c_xnp_msgs_2%ISOPEN) THEN
1171: CLOSE c_xnp_msgs_2;

Line 1170: IF (c_xnp_msgs_2%ISOPEN) THEN

1166: IF (c_xnp_msgs_1%ISOPEN) THEN
1167: CLOSE c_xnp_msgs_1;
1168: END IF;
1169: ELSE
1170: IF (c_xnp_msgs_2%ISOPEN) THEN
1171: CLOSE c_xnp_msgs_2;
1172: END IF;
1173: END IF;
1174: END LOOP OUTER_XNP_MSG;

Line 1171: CLOSE c_xnp_msgs_2;

1167: CLOSE c_xnp_msgs_1;
1168: END IF;
1169: ELSE
1170: IF (c_xnp_msgs_2%ISOPEN) THEN
1171: CLOSE c_xnp_msgs_2;
1172: END IF;
1173: END IF;
1174: END LOOP OUTER_XNP_MSG;
1175:

Line 1177: RECORDS_PURGED_MSGS(l_no_msgs,'XNP_MSGS',l_rec_name,-1);

1173: END IF;
1174: END LOOP OUTER_XNP_MSG;
1175:
1176: COMMIT;
1177: RECORDS_PURGED_MSGS(l_no_msgs,'XNP_MSGS',l_rec_name,-1);
1178: EXCEPTION
1179: WHEN OTHERS THEN
1180: ROLLBACK TO MSG_RLBK;
1181: FND_MESSAGE.SET_NAME('XDP','XDP_PURGE_ERROR');