DBA Data[Home] [Help]

APPS.WSH_OTM_SYNC_REF_DATA_PKG dependencies on WSH_OTM_SYNC_REF_DATA

Line 1: PACKAGE BODY WSH_OTM_SYNC_REF_DATA_PKG AS

1: PACKAGE BODY WSH_OTM_SYNC_REF_DATA_PKG AS
2: /* $Header: WSHTMTHB.pls 120.1.12020000.2 2013/03/12 12:54:27 sunilku ship $ */
3:
4: G_PKG_NAME CONSTANT VARCHAR2(50) := 'WSH_OTM_SYNC_REF_DATA_PKG';
5:

Line 4: G_PKG_NAME CONSTANT VARCHAR2(50) := 'WSH_OTM_SYNC_REF_DATA_PKG';

1: PACKAGE BODY WSH_OTM_SYNC_REF_DATA_PKG AS
2: /* $Header: WSHTMTHB.pls 120.1.12020000.2 2013/03/12 12:54:27 sunilku ship $ */
3:
4: G_PKG_NAME CONSTANT VARCHAR2(50) := 'WSH_OTM_SYNC_REF_DATA_PKG';
5:
6: PROCEDURE is_ref_data_send_reqd(p_entity_id IN NUMBER,
7: p_parent_entity_id IN VARCHAR2,
8: p_entity_type IN VARCHAR2,

Line 21: FROM wsh_otm_sync_ref_data

17: CURSOR c_entity_exists(p_id NUMBER, p_type VARCHAR2, p_parent_id NUMBER) IS
18: SELECT sync_ref_id,
19: substitute_entity,
20: last_sent_date
21: FROM wsh_otm_sync_ref_data
22: WHERE entity_id = p_id
23: AND entity_type = p_type
24: AND parent_entity_id = nvl(p_parent_id,0);
25:

Line 33: wsh_otm_sync_ref_data wosrd

29: SELECT msi.last_update_date,
30: wosrd.sync_ref_id,
31: wosrd.substitute_entity
32: FROM mtl_system_items msi,
33: wsh_otm_sync_ref_data wosrd
34: WHERE msi.inventory_item_id = p_item_id
35: AND wosrd.entity_type = p_entity_type
36: AND wosrd.entity_id = msi.inventory_item_id
37: AND msi.last_update_date > wosrd.last_sent_date;

Line 45: wsh_otm_sync_ref_data wosrd

41: SELECT wl.last_update_date,
42: wosrd.sync_ref_id,
43: wosrd.substitute_entity
44: FROM wsh_locations wl,
45: wsh_otm_sync_ref_data wosrd
46: WHERE wl.wsh_location_id = p_location_id
47: AND wosrd.entity_type = p_entity_type
48: AND wosrd.entity_id = wl.wsh_location_id
49: AND wl.last_update_date > wosrd.last_sent_date;

Line 104: WSH_DEBUG_SV.logmsg(l_module_name,'Calling program unit WSH_OTM_SYNC_REF_DATA_PKG.INSERT_ROW_SYNC_REF_DATA',WSH_DEBUG_SV.C_PROC_LEVEL);

100: WSH_DEBUG_SV.log(l_module_name,'l_sync_ref_id IS NULL');
101: END IF;
102:
103: IF l_debug_on THEN
104: WSH_DEBUG_SV.logmsg(l_module_name,'Calling program unit WSH_OTM_SYNC_REF_DATA_PKG.INSERT_ROW_SYNC_REF_DATA',WSH_DEBUG_SV.C_PROC_LEVEL);
105: END IF;
106: insert_row_sync_ref_data(p_entity_id => p_entity_id ,
107: p_parent_entity_id => p_parent_entity_id,
108: p_entity_type => p_entity_type,

Line 124: WSH_DEBUG_SV.logmsg(l_module_name,'Calling program unit WSH_OTM_SYNC_REF_DATA_PKG.INSERT_ROW_SYNC_REF_DATA_LOG',WSH_DEBUG_SV.C_PROC_LEVEL);

120: x_num_warnings => l_num_warnings,
121: x_num_errors => l_num_errors);
122:
123: IF l_debug_on THEN
124: WSH_DEBUG_SV.logmsg(l_module_name,'Calling program unit WSH_OTM_SYNC_REF_DATA_PKG.INSERT_ROW_SYNC_REF_DATA_LOG',WSH_DEBUG_SV.C_PROC_LEVEL);
125: END IF;
126: insert_row_sync_ref_data_log (p_sync_ref_id => l_sync_ref_id,
127: p_transmission_id => p_transmission_id,
128: p_entity_type => p_entity_type,

Line 152: WSH_DEBUG_SV.logmsg(l_module_name,'Calling program unit WSH_OTM_SYNC_REF_DATA_PKG.INSERT_ROW_SYNC_REF_DATA_LOG',WSH_DEBUG_SV.C_PROC_LEVEL);

148: IF p_entity_updated_date >= l_last_sent_date THEN
149: -- OR to_number(sysdate - l_last_sent_date) <= 1 THEN -- Bugfix 14526032
150:
151: IF l_debug_on THEN
152: WSH_DEBUG_SV.logmsg(l_module_name,'Calling program unit WSH_OTM_SYNC_REF_DATA_PKG.INSERT_ROW_SYNC_REF_DATA_LOG',WSH_DEBUG_SV.C_PROC_LEVEL);
153: END IF;
154:
155: insert_row_sync_ref_data_log (p_sync_ref_id => l_sync_ref_id,
156: p_transmission_id => p_transmission_id,

Line 211: FROM wsh_otm_sync_ref_data_log

207:
208: --Cursor to get sync_ref_id's for given transmission_id
209: CURSOR c_get_sync_ref_id(p_trans_id NUMBER) IS
210: SELECT distinct entity_type, sync_ref_id
211: FROM wsh_otm_sync_ref_data_log
212: WHERE transmission_id = p_trans_id
213: ORDER BY entity_type, sync_ref_id;
214:
215:

Line 216: --Cursor to lock the record in wsh_otm_sync_ref_data

212: WHERE transmission_id = p_trans_id
213: ORDER BY entity_type, sync_ref_id;
214:
215:
216: --Cursor to lock the record in wsh_otm_sync_ref_data
217: CURSOR c_lock_parent_table(p_sync_ref_id NUMBER) IS
218: SELECT 1
219: FROM wsh_otm_sync_ref_data
220: WHERE sync_ref_id = p_sync_ref_id

Line 219: FROM wsh_otm_sync_ref_data

215:
216: --Cursor to lock the record in wsh_otm_sync_ref_data
217: CURSOR c_lock_parent_table(p_sync_ref_id NUMBER) IS
218: SELECT 1
219: FROM wsh_otm_sync_ref_data
220: WHERE sync_ref_id = p_sync_ref_id
221: FOR UPDATE NOWAIT;
222:
223: --Cursor to obtain the first sent_date

Line 226: FROM wsh_otm_sync_ref_data_log

222:
223: --Cursor to obtain the first sent_date
224: CURSOR c_get_sent_date(p_sync_id NUMBER) IS
225: SELECT sent_date
226: FROM wsh_otm_sync_ref_data_log
227: WHERE sync_ref_id = p_sync_id
228: AND rownum = 1;
229:
230:

Line 291: UPDATE wsh_otm_sync_ref_data

287: WSH_DEBUG_SV.log(l_module_name,'sent_date', l_sent_date);
288: END IF;
289:
290: --Update last_sent_date of WOSRD with sent_date of WOSRDL.sent_date
291: UPDATE wsh_otm_sync_ref_data
292: SET last_sent_date = l_sent_date
293: WHERE sync_ref_id = l_sync_ref_id;
294:
295: IF l_debug_on THEN

Line 301: FROM wsh_otm_sync_ref_data_log

297: END IF;
298:
299: --Delete data from WOSRDL for l_sync_ref_id
300: DELETE
301: FROM wsh_otm_sync_ref_data_log
302: WHERE sync_ref_id = l_sync_ref_id;
303:
304: EXCEPTION
305: WHEN OTHERS THEN

Line 321: FROM wsh_otm_sync_ref_data_log

317: WSH_DEBUG_SV.log(l_module_name,'Error case. So deleting all the data from WOSRDL for transmission_id ', p_transmission_id);
318: END IF;
319:
320: DELETE
321: FROM wsh_otm_sync_ref_data_log
322: WHERE transmission_id = p_transmission_id;
323: END IF;
324:
325: x_return_status := WSH_UTIL_CORE.G_RET_STS_SUCCESS;

Line 355: FROM wsh_otm_sync_ref_data

351: PRAGMA AUTONOMOUS_TRANSACTION; --since its an autonomous transaction
352:
353: CURSOR c_entity_exists(p_id NUMBER, p_type VARCHAR2) IS
354: SELECT entity_id, parent_entity_id
355: FROM wsh_otm_sync_ref_data
356: WHERE entity_id = p_id
357: AND entity_type = p_type
358: AND substitute_entity IS NULL;
359:

Line 423: INSERT INTO wsh_otm_sync_ref_data (sync_ref_id,

419: END IF;
420:
421: --Insert data into the table
422: BEGIN
423: INSERT INTO wsh_otm_sync_ref_data (sync_ref_id,
424: entity_id,
425: parent_entity_id,
426: entity_type,
427: substitute_entity,

Line 439: VALUES (wsh_otm_sync_ref_data_s.NEXTVAL,

435: last_update_date,
436: last_updated_by,
437: last_update_login
438: )
439: VALUES (wsh_otm_sync_ref_data_s.NEXTVAL,
440: p_entity_id,
441: nvl(p_parent_entity_id,0),
442: p_entity_type,
443: l_substitute_entity,

Line 464: FROM wsh_otm_sync_ref_data

460: END IF;
461:
462: SELECT substitute_entity
463: INTO l_substitute_entity
464: FROM wsh_otm_sync_ref_data
465: WHERE entity_id = p_entity_id
466: AND parent_entity_id = nvl(p_parent_entity_id,0)
467: AND entity_type = p_entity_type;
468: END;

Line 516: INSERT INTO wsh_otm_sync_ref_data_log (transmission_id,

512: WSH_DEBUG_SV.log(l_module_name,'P_ENTITY_TYPE ',P_ENTITY_TYPE);
513: END IF;
514:
515: --Inset data into the table
516: INSERT INTO wsh_otm_sync_ref_data_log (transmission_id,
517: sync_ref_id,
518: entity_type,
519: sent_date,
520: creation_date,

Line 554: END WSH_OTM_SYNC_REF_DATA_PKG;

550: END IF;
551:
552: END insert_row_sync_ref_data_log;
553:
554: END WSH_OTM_SYNC_REF_DATA_PKG;