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.0.12000000.1 2007/01/25 16:15:16 amohamme noship $ */
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.0.12000000.1 2007/01/25 16:15:16 amohamme noship $ */
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 150: 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);

146: IF p_entity_updated_date >= l_last_sent_date OR
147: to_number(sysdate - l_last_sent_date) <= 1 THEN
148:
149: IF l_debug_on THEN
150: 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);
151: END IF;
152:
153: insert_row_sync_ref_data_log (p_sync_ref_id => l_sync_ref_id,
154: p_transmission_id => p_transmission_id,

Line 209: FROM wsh_otm_sync_ref_data_log

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

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

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

Line 217: FROM wsh_otm_sync_ref_data

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

Line 224: FROM wsh_otm_sync_ref_data_log

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

Line 289: UPDATE wsh_otm_sync_ref_data

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

Line 299: FROM wsh_otm_sync_ref_data_log

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

Line 319: FROM wsh_otm_sync_ref_data_log

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

Line 353: FROM wsh_otm_sync_ref_data

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

Line 420: INSERT INTO wsh_otm_sync_ref_data (sync_ref_id,

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

Line 436: VALUES (wsh_otm_sync_ref_data_s.NEXTVAL,

432: last_update_date,
433: last_updated_by,
434: last_update_login
435: )
436: VALUES (wsh_otm_sync_ref_data_s.NEXTVAL,
437: p_entity_id,
438: nvl(p_parent_entity_id,0),
439: p_entity_type,
440: l_substitute_entity,

Line 461: FROM wsh_otm_sync_ref_data

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

Line 513: INSERT INTO wsh_otm_sync_ref_data_log (transmission_id,

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

Line 551: END WSH_OTM_SYNC_REF_DATA_PKG;

547: END IF;
548:
549: END insert_row_sync_ref_data_log;
550:
551: END WSH_OTM_SYNC_REF_DATA_PKG;