APPS.HZ_EBI_CUST_LOAD dependencies on HZ_EBI_CUST_LOAD

Line 1: PACKAGE BODY HZ_EBI_CUST_LOAD AS

1: PACKAGE BODY HZ_EBI_CUST_LOAD AS
2: /* $Header: ARHEICSTLDB.pls 120.4 2009/07/20 10:31:32 aashah noship $ */
3:
4: PROCEDURE RAISE_CUST_LOAD_EVENT( p_event_name IN VARCHAR2
5: ,p_event_id IN NUMBER DEFAULT NULL

Line 13: DELETE FROM HZ_EBI_CUST_LOAD_LOG;

9:
10: PROCEDURE PURGE_EVENTLOG
11: IS
12: BEGIN
13: DELETE FROM HZ_EBI_CUST_LOAD_LOG;
14: COMMIT;
15:
16: END PURGE_EVENTLOG;
17:

Line 38: --get count from log(HZ_EBI_CUST_LOAD_LOG) table

34: l_logCustCount := 0;
35: l_batch_size := p_batch_size;
36: l_max_events :=p_max_events ;
37:
38: --get count from log(HZ_EBI_CUST_LOAD_LOG) table
39: SELECT count(*) INTO l_logCustCount FROM HZ_EBI_CUST_LOAD_LOG;
40:
41: --Insert records to Event Log table, if there are no records in the event log table.
42: IF(l_logCustCount = 0) THEN

Line 39: SELECT count(*) INTO l_logCustCount FROM HZ_EBI_CUST_LOAD_LOG;

35: l_batch_size := p_batch_size;
36: l_max_events :=p_max_events ;
37:
38: --get count from log(HZ_EBI_CUST_LOAD_LOG) table
39: SELECT count(*) INTO l_logCustCount FROM HZ_EBI_CUST_LOAD_LOG;
40:
41: --Insert records to Event Log table, if there are no records in the event log table.
42: IF(l_logCustCount = 0) THEN
43: --Insert required item records into event log table .

Line 47: INSERT INTO HZ_EBI_CUST_LOAD_LOG( PARTY_ID , EVENT_ID)

43: --Insert required item records into event log table .
44: x_err_msg := x_err_msg || '\n Inserting Records to Event log table';
45: -- Initialize Event Id to 0
46: l_eventId := 0;
47: INSERT INTO HZ_EBI_CUST_LOAD_LOG( PARTY_ID , EVENT_ID)
48: Select distinct party.PARTY_ID ,NULL
49: from HZ_PARTIES party, HZ_CUST_ACCOUNTS accnt where
50: accnt.status='A' and party.PARTY_ID = accnt.party_id;
51: --Commit records. To check commit frequency

Line 56: SELECT MAX(NVL(EVENT_ID,0)) into l_eventId FROM HZ_EBI_CUST_LOAD_LOG;

52: COMMIT;
53:
54: ELSE
55: -- Initialize Event Id to 0
56: SELECT MAX(NVL(EVENT_ID,0)) into l_eventId FROM HZ_EBI_CUST_LOAD_LOG;
57:
58: END IF;
59:
60: x_err_msg := 'Event Id Initialized to ' || TO_CHAR(l_eventId) ;

Line 62: SELECT count(*) INTO l_CustCount FROM HZ_EBI_CUST_LOAD_LOG WHERE EVENT_ID IS NULL;

58: END IF;
59:
60: x_err_msg := 'Event Id Initialized to ' || TO_CHAR(l_eventId) ;
61: --Get Count of Item for which the Event should be raised
62: SELECT count(*) INTO l_CustCount FROM HZ_EBI_CUST_LOAD_LOG WHERE EVENT_ID IS NULL;
63: WHILE (l_CustCount > 0 AND (l_max_events IS NULL OR l_eventsRaised < l_max_events))
64: LOOP
65: --Generate new
66: l_eventId := l_eventId +1;

Line 68: UPDATE HZ_EBI_CUST_LOAD_LOG

64: LOOP
65: --Generate new
66: l_eventId := l_eventId +1;
67: x_err_msg := 'Event Id ' ||TO_CHAR(l_eventId)|| ' updating';
68: UPDATE HZ_EBI_CUST_LOAD_LOG
69: SET EVENT_ID = l_eventId
70: WHERE EVENT_ID IS NULL AND ROWNUM < l_batch_size +1;
71: l_CustCount := l_CustCount - l_batch_size;
72: --Raise event

Line 73: Raise_CUST_LOAD_Event (HZ_EBI_CUST_LOAD.G_CUST_LOAD_EVENT, l_eventId, l_msg_data, l_return_status);

69: SET EVENT_ID = l_eventId
70: WHERE EVENT_ID IS NULL AND ROWNUM < l_batch_size +1;
71: l_CustCount := l_CustCount - l_batch_size;
72: --Raise event
73: Raise_CUST_LOAD_Event (HZ_EBI_CUST_LOAD.G_CUST_LOAD_EVENT, l_eventId, l_msg_data, l_return_status);
74: x_err_msg := 'Raised Event' || TO_CHAR(l_eventId) || ' with return status = ' || l_return_status ;
75: l_eventsRaised := l_eventsRaised +1;
76: COMMIT;
77:

Line 104: FROM HZ_EBI_CUST_LOAD_LOG

100: l_return_status := '';
101: l_msg_data := '';
102: -- Get the Item count in the event log for the event
103: SELECT count(*) INTO l_logCustCount
104: FROM HZ_EBI_CUST_LOAD_LOG
105: WHERE EVENT_ID = p_event_id;
106:
107: --if there are records in the event log table for the event, then update the batch and then raise the event.
108: IF (l_logCustCount > 0) THEN

Line 113: DELETE FROM HZ_EBI_CUST_LOAD_LOG

109: BEGIN
110:
111: x_err_msg := x_err_msg || 'Deleting recods from Event log table for the event ' || TO_CHAR(p_event_id) || ' that are not active';
112: --Deleting recods from Event log table for the event that are not active
113: DELETE FROM HZ_EBI_CUST_LOAD_LOG
114: WHERE EVENT_ID = p_event_id AND
115: PARTY_ID NOT IN(
116: SELECT DISTINCT party.PARTY_ID
117: FROM HZ_PARTIES party, HZ_CUST_ACCOUNTS accnt

Line 120: SELECT MAX(NVL(EVENT_ID,0))+1 into l_eventId FROM HZ_EBI_CUST_LOAD_LOG;

116: SELECT DISTINCT party.PARTY_ID
117: FROM HZ_PARTIES party, HZ_CUST_ACCOUNTS accnt
118: WHERE accnt.STATUS='A' and party.PARTY_ID = accnt.PARTY_ID);
119:
120: SELECT MAX(NVL(EVENT_ID,0))+1 into l_eventId FROM HZ_EBI_CUST_LOAD_LOG;
121:
122: UPDATE HZ_EBI_CUST_LOAD_LOG
123: SET EVENT_ID = l_eventId
124: WHERE EVENT_ID = p_event_id ;

Line 122: UPDATE HZ_EBI_CUST_LOAD_LOG

118: WHERE accnt.STATUS='A' and party.PARTY_ID = accnt.PARTY_ID);
119:
120: SELECT MAX(NVL(EVENT_ID,0))+1 into l_eventId FROM HZ_EBI_CUST_LOAD_LOG;
121:
122: UPDATE HZ_EBI_CUST_LOAD_LOG
123: SET EVENT_ID = l_eventId
124: WHERE EVENT_ID = p_event_id ;
125: --Raise event
126: Raise_CUST_LOAD_Event (HZ_EBI_CUST_LOAD.G_CUST_LOAD_EVENT, l_eventId, l_msg_data, l_return_status);

Line 126: Raise_CUST_LOAD_Event (HZ_EBI_CUST_LOAD.G_CUST_LOAD_EVENT, l_eventId, l_msg_data, l_return_status);

122: UPDATE HZ_EBI_CUST_LOAD_LOG
123: SET EVENT_ID = l_eventId
124: WHERE EVENT_ID = p_event_id ;
125: --Raise event
126: Raise_CUST_LOAD_Event (HZ_EBI_CUST_LOAD.G_CUST_LOAD_EVENT, l_eventId, l_msg_data, l_return_status);
127: x_err_msg := 'Raised Event' || TO_CHAR(l_eventId) || ' with return status = ' || l_return_status ;
128: COMMIT;
129: END;
130: ELSE

Line 180: SELECT party_id from HZ_EBI_CUST_LOAD_LOG where event_id = p_event_id;

176: party_id NUMBER;
177: l_count NUMBER ;
178:
179: CURSOR cust_cur IS
180: SELECT party_id from HZ_EBI_CUST_LOAD_LOG where event_id = p_event_id;
181:
182: BEGIN
183: x_org_cust_objs := HZ_ORG_CUST_BO_TBL();
184: x_messages := HZ_MESSAGE_OBJ_TBL();

Line 217: END HZ_EBI_CUST_LOAD;

213:
214:
215: END Get_Org_Custs_BO;
216:
217: END HZ_EBI_CUST_LOAD;