12: mseaa.ORGANIZATION_ID,
13: mseaa.ASSET_REBUILD_ITEM_ID,
14: mseaa.SR_INSTANCE_ID
15: FROM MSC_ST_EAM_ACT_ASSOCIATIONS mseaa
16: WHERE mseaa.deleted_flag = MSC_UTIL.SYS_YES
17: AND mseaa.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
18:
19: CURSOR c_del2 IS
20: SELECT mseaa.ASSET_GROUP_ITEM_ID,
22: mseaa.ASSET_ACTIVITY_ID,
23: mseaa.EQUIPMENT_ITEM_ID,
24: mseaa.SR_INSTANCE_ID
25: FROM MSC_ST_EAM_ASSET_EQUIP_DTLS mseaa
26: WHERE mseaa.deleted_flag = MSC_UTIL.SYS_YES
27: AND mseaa.SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id;
28: lv_errbuf VARCHAR2(240);
29: lv_retcode NUMBER;
30: lv_tbl VARCHAR2(30);
53: lv_DEPARTMENT_ID NUMBER;
54: lv_RESOURCE_CODE VARCHAR2(10);
55: lv_SCHEDULE_TO_INSTANCE NUMBER;
56: BEGIN
57: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'In Procedure LOAD_EAM_INFO ');
58:
59: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR
60: MSC_CL_COLLECTION.v_is_partial_refresh) THEN
61: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag =
58:
59: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR
60: MSC_CL_COLLECTION.v_is_partial_refresh) THEN
61: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag =
62: MSC_UTIL.G_ALL_ORGANIZATIONS THEN
63: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_EAM_ACT_ASSOCIATIONS',
64: MSC_CL_COLLECTION.v_instance_id,
65: -1);
66: ELSE
64: MSC_CL_COLLECTION.v_instance_id,
65: -1);
66: ELSE
67: MSC_CL_COLLECTION.v_sub_str :=
68: ' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
69: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_EAM_ACT_ASSOCIATIONS',
70: MSC_CL_COLLECTION.v_instance_id,
71: null,
72: MSC_CL_COLLECTION.v_sub_str);
73: END IF;
74: END IF;
75:
76: -- ========= Prepare the Cursor Statement ==========
77: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
78: lv_tbl:= 'EAM_ACT_ASSOCIATIONS_'||MSC_CL_COLLECTION.v_instance_code;
79: ELSE
80: lv_tbl:= 'MSC_EAM_ACT_ASSOCIATIONS';
81: END IF;
98: ||' AND mseaa.SR_INSTANCE_ID= m1.SR_INSTANCE_ID'
99: ||' AND m1.SR_INVENTORY_ITEM_ID= mseaa.ASSET_ACTIVITY_ID'
100: ||' AND mseaa.SR_INSTANCE_ID= m2.SR_INSTANCE_ID'
101: ||' AND m2.SR_INVENTORY_ITEM_ID= mseaa.ASSET_REBUILD_ITEM_ID'
102: ||' AND mseaa.DELETED_FLAG= '||MSC_UTIL.SYS_NO;
103:
104: -- ========= Prepare SQL Statement for INSERT ==========
105: lv_sql_stmt:= 'insert into '||lv_tbl
106: ||' ( ASSET_ACTIVITY_ID,'
132: ||' :v_current_user)';
133:
134: IF (MSC_CL_COLLECTION.v_is_complete_refresh
135: OR MSC_CL_COLLECTION.v_is_partial_refresh)
136: AND MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
137:
138: BEGIN
139: lv_sql_ins:= 'insert into '||lv_tbl
140: ||' ( ASSET_ACTIVITY_ID,'
174: ||' AND m1.SR_INVENTORY_ITEM_ID= mseaa.ASSET_ACTIVITY_ID'
175: ||' AND mseaa.SR_INSTANCE_ID= m2.SR_INSTANCE_ID'
176: ||' AND m2.SR_INVENTORY_ITEM_ID= '
177: ||' mseaa.ASSET_REBUILD_ITEM_ID'
178: ||' AND mseaa.DELETED_FLAG= '||MSC_UTIL.SYS_NO;
179:
180:
181: EXECUTE IMMEDIATE lv_sql_ins
182: USING MSC_CL_COLLECTION.v_last_collection_id,
184: MSC_CL_COLLECTION.v_current_user,
185: MSC_CL_COLLECTION.v_current_date,
186: MSC_CL_COLLECTION.v_current_user;
187: COMMIT;
188: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
189: 'Eam activity associations loaded');
190: EXCEPTION
191: WHEN OTHERS THEN
192: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
189: 'Eam activity associations loaded');
190: EXCEPTION
191: WHEN OTHERS THEN
192: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
193: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
194: '========================================');
195: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
196: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
197: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ACT_ASSOCIATIONS');
194: '========================================');
195: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
196: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
197: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ACT_ASSOCIATIONS');
198: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
199: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
200: RAISE;
201: ELSE
202: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
195: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
196: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
197: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ACT_ASSOCIATIONS');
198: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
199: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
200: RAISE;
201: ELSE
202: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
203: '========================================');
198: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
199: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
200: RAISE;
201: ELSE
202: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
203: '========================================');
204: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
205: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
206: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ACT_ASSOCIATIONS');
203: '========================================');
204: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
205: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
206: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ACT_ASSOCIATIONS');
207: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
208: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
209: END IF;
210: END;
211:
204: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
205: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
206: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ACT_ASSOCIATIONS');
207: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
208: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
209: END IF;
210: END;
211:
212: END IF; -- MSC_CL_COLLECTION.v_is_complete_refresh
249: WHERE SR_INSTANCE_ID= MSC_CL_COLLECTION.v_instance_id
250: AND ASSET_ACTIVITY_ID = lv_asset_activity_id
251: AND ORGANIZATION_ID = lv_organization_id
252: AND ASSET_REBUILD_ITEM_ID = lv_asset_rebuild_item_id;
253: --AND DELETED_FLAG = MSC_UTIL.SYS_NO;
254:
255:
256: IF (MSC_CL_COLLECTION.v_is_complete_refresh
257: OR MSC_CL_COLLECTION.v_is_partial_refresh)
286:
287: EXCEPTION
288: WHEN OTHERS THEN
289: IF SQLCODE IN (-01683,-01653,-01650,-01562) THEN
290: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
291: '========================================');
292: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
293: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
294: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ACT_ASSOCIATIONS');
291: '========================================');
292: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
293: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
294: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ACT_ASSOCIATIONS');
295: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
296: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
297: RAISE;
298:
299: ELSE
292: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
293: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
294: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ACT_ASSOCIATIONS');
295: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
296: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
297: RAISE;
298:
299: ELSE
300: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
296: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
297: RAISE;
298:
299: ELSE
300: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
301:
302: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
303: '========================================');
304: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
298:
299: ELSE
300: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
301:
302: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
303: '========================================');
304: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
305: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
306: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ACT_ASSOCIATIONS');
303: '========================================');
304: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
305: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
306: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ACT_ASSOCIATIONS');
307: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
308:
309: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
310: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
311: FND_MESSAGE.SET_TOKEN('VALUE',
310: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
311: FND_MESSAGE.SET_TOKEN('VALUE',
312: MSC_GET_NAME.ORG_CODE( lv_ORGANIZATION_ID,
313: MSC_CL_COLLECTION.v_instance_id));
314: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
315:
316: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
317: FND_MESSAGE.SET_TOKEN('COLUMN', 'ASSET_ACTIVITY_ID');
318: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR(lv_ASSET_ACTIVITY_ID));
315:
316: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
317: FND_MESSAGE.SET_TOKEN('COLUMN', 'ASSET_ACTIVITY_ID');
318: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR(lv_ASSET_ACTIVITY_ID));
319: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
320:
321: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
322: FND_MESSAGE.SET_TOKEN('COLUMN', 'ASSET_REBUILD_ITEM_ID');
323: FND_MESSAGE.SET_TOKEN('VALUE',
321: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
322: FND_MESSAGE.SET_TOKEN('COLUMN', 'ASSET_REBUILD_ITEM_ID');
323: FND_MESSAGE.SET_TOKEN('VALUE',
324: TO_CHAR(lv_ASSET_REBUILD_ITEM_ID));
325: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
326:
327: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
328: END IF;
329: END;
323: FND_MESSAGE.SET_TOKEN('VALUE',
324: TO_CHAR(lv_ASSET_REBUILD_ITEM_ID));
325: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
326:
327: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
328: END IF;
329: END;
330: END LOOP;
331: END IF; -- MSC_CL_COLLECTION.v_is_incremental_refresh
336: END IF;
337:
338: BEGIN
339: IF ((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <>
340: MSC_UTIL.G_ALL_ORGANIZATIONS )
341: AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
342:
343: lv_tbl:= 'EAM_ACT_ASSOCIATIONS_'||MSC_CL_COLLECTION.v_instance_code;
344: lv_sql_stmt:= 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
337:
338: BEGIN
339: IF ((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <>
340: MSC_UTIL.G_ALL_ORGANIZATIONS )
341: AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
342:
343: lv_tbl:= 'EAM_ACT_ASSOCIATIONS_'||MSC_CL_COLLECTION.v_instance_code;
344: lv_sql_stmt:= 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
345: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_EAM_ACT_ASSOCIATIONS'
340: MSC_UTIL.G_ALL_ORGANIZATIONS )
341: AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
342:
343: lv_tbl:= 'EAM_ACT_ASSOCIATIONS_'||MSC_CL_COLLECTION.v_instance_code;
344: lv_sql_stmt:= 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
345: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_EAM_ACT_ASSOCIATIONS'
346: ||' WHERE sr_instance_id = '
347: ||MSC_CL_COLLECTION.v_instance_id
348: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
341: AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
342:
343: lv_tbl:= 'EAM_ACT_ASSOCIATIONS_'||MSC_CL_COLLECTION.v_instance_code;
344: lv_sql_stmt:= 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
345: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_EAM_ACT_ASSOCIATIONS'
346: ||' WHERE sr_instance_id = '
347: ||MSC_CL_COLLECTION.v_instance_id
348: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
349:
344: lv_sql_stmt:= 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
345: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_EAM_ACT_ASSOCIATIONS'
346: ||' WHERE sr_instance_id = '
347: ||MSC_CL_COLLECTION.v_instance_id
348: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
349:
350: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The sql statement is '
351: ||lv_sql_stmt);
352: EXECUTE IMMEDIATE lv_sql_stmt;
346: ||' WHERE sr_instance_id = '
347: ||MSC_CL_COLLECTION.v_instance_id
348: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
349:
350: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The sql statement is '
351: ||lv_sql_stmt);
352: EXECUTE IMMEDIATE lv_sql_stmt;
353: COMMIT;
354: END IF;
354: END IF;
355:
356: EXCEPTION
357: WHEN OTHERS THEN
358: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
359: RAISE;
360: END;
361:
362: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
358: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
359: RAISE;
360: END;
361:
362: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
363: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
364: lv_retcode,
365: 'MSC_EAM_ACT_ASSOCIATIONS',
366: MSC_CL_COLLECTION.v_instance_code,
363: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
364: lv_retcode,
365: 'MSC_EAM_ACT_ASSOCIATIONS',
366: MSC_CL_COLLECTION.v_instance_code,
367: MSC_UTIL.G_WARNING
368: );
369:
370: IF lv_retcode = MSC_UTIL.G_ERROR THEN
371: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
366: MSC_CL_COLLECTION.v_instance_code,
367: MSC_UTIL.G_WARNING
368: );
369:
370: IF lv_retcode = MSC_UTIL.G_ERROR THEN
371: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
372: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
373: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
374: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
367: MSC_UTIL.G_WARNING
368: );
369:
370: IF lv_retcode = MSC_UTIL.G_ERROR THEN
371: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
372: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
373: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
374: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
375: END IF;
369:
370: IF lv_retcode = MSC_UTIL.G_ERROR THEN
371: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
372: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
373: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
374: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
375: END IF;
376: END IF;
377:
370: IF lv_retcode = MSC_UTIL.G_ERROR THEN
371: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
372: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
373: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
374: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
375: END IF;
376: END IF;
377:
378:
376: END IF;
377:
378:
379: /*--------- PS requirements - New table to collect asset number details ---------*/
380: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'In Procedure LOAD_EAM_INFO -- EAM asset Equip');
381:
382: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR
383: MSC_CL_COLLECTION.v_is_partial_refresh) THEN
384: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag =
381:
382: IF (MSC_CL_COLLECTION.v_is_complete_refresh OR
383: MSC_CL_COLLECTION.v_is_partial_refresh) THEN
384: IF MSC_CL_COLLECTION.v_coll_prec.org_group_flag =
385: MSC_UTIL.G_ALL_ORGANIZATIONS THEN
386: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_EAM_ASSET_EQUIP_DTLS',
387: MSC_CL_COLLECTION.v_instance_id,
388: -1);
389: ELSE
387: MSC_CL_COLLECTION.v_instance_id,
388: -1);
389: ELSE
390: MSC_CL_COLLECTION.v_sub_str :=
391: ' AND ORGANIZATION_ID '||MSC_UTIL.v_in_org_str;
392: MSC_CL_COLLECTION.DELETE_MSC_TABLE( 'MSC_EAM_ASSET_EQUIP_DTLS',
393: MSC_CL_COLLECTION.v_instance_id,
394: null,
395: MSC_CL_COLLECTION.v_sub_str);
396: END IF;
397: END IF;
398:
399: -- ========= Prepare the Cursor Statement ==========
400: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
401: lv_tbl:= 'EAM_ASSET_EQUIP_DTLS_'||MSC_CL_COLLECTION.v_instance_code;
402: ELSE
403: lv_tbl:= 'MSC_EAM_ASSET_EQUIP_DTLS';
404: END IF;
427: ||' AND mse.SR_INSTANCE_ID= m2.SR_INSTANCE_ID'
428: ||' AND m2.SR_INVENTORY_ITEM_ID= mse.ASSET_ACTIVITY_ID'
429: ||' AND mse.SR_INSTANCE_ID= m3.SR_INSTANCE_ID'
430: ||' AND m3.SR_INVENTORY_ITEM_ID= mse.EQUIPMENT_ITEM_ID'
431: ||' AND mse.DELETED_FLAG= '||MSC_UTIL.SYS_NO;
432:
433: -- ========= Prepare SQL Statement for INSERT ==========
434: lv_sql_stmt:= 'insert into '||lv_tbl
435: ||'(ASSET_GROUP_ITEM_ID,'
469: ||' :v_current_user)';
470:
471: IF (MSC_CL_COLLECTION.v_is_complete_refresh
472: OR MSC_CL_COLLECTION.v_is_partial_refresh)
473: AND MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
474:
475: BEGIN
476: lv_sql_ins:= 'insert into '||lv_tbl
477: ||'(ASSET_GROUP_ITEM_ID,'
520: ||' AND mse.SR_INSTANCE_ID= m2.SR_INSTANCE_ID'
521: ||' AND m2.SR_INVENTORY_ITEM_ID= mse.ASSET_ACTIVITY_ID'
522: ||' AND mse.SR_INSTANCE_ID= m3.SR_INSTANCE_ID'
523: ||' AND m3.SR_INVENTORY_ITEM_ID= mse.EQUIPMENT_ITEM_ID'
524: ||' AND mse.DELETED_FLAG= '||MSC_UTIL.SYS_NO;
525:
526:
527: EXECUTE IMMEDIATE lv_sql_ins
528: USING MSC_CL_COLLECTION.v_last_collection_id,
530: MSC_CL_COLLECTION.v_current_user,
531: MSC_CL_COLLECTION.v_current_date,
532: MSC_CL_COLLECTION.v_current_user;
533: COMMIT;
534: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
535: 'Eam asset equipment details loaded');
536: EXCEPTION
537: WHEN OTHERS THEN
538: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
535: 'Eam asset equipment details loaded');
536: EXCEPTION
537: WHEN OTHERS THEN
538: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
539: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
540: '========================================');
541: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
542: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
543: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ASSET_EQUIP_DTLS');
540: '========================================');
541: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
542: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
543: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ASSET_EQUIP_DTLS');
544: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
545: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
546: RAISE;
547: ELSE
548: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
541: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
542: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
543: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ASSET_EQUIP_DTLS');
544: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
545: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
546: RAISE;
547: ELSE
548: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
549: '========================================');
544: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
545: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
546: RAISE;
547: ELSE
548: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
549: '========================================');
550: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
551: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
552: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ASSET_EQUIP_DTLS');
549: '========================================');
550: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
551: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
552: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ASSET_EQUIP_DTLS');
553: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
554: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
555: END IF;
556: END;
557:
550: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
551: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
552: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ASSET_EQUIP_DTLS');
553: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
554: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
555: END IF;
556: END;
557:
558: END IF; -- MSC_CL_COLLECTION.v_is_complete_refresh
644:
645: EXCEPTION
646: WHEN OTHERS THEN
647: IF SQLCODE IN (-01683,-01653,-01650,-01562) THEN
648: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
649: '========================================');
650: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
651: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
652: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ASSET_EQUIP_DTLS');
649: '========================================');
650: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
651: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
652: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ASSET_EQUIP_DTLS');
653: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
654: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
655: RAISE;
656:
657: ELSE
650: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
651: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
652: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ASSET_EQUIP_DTLS');
653: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
654: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
655: RAISE;
656:
657: ELSE
658: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
654: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
655: RAISE;
656:
657: ELSE
658: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
659:
660: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
661: '========================================');
662: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
656:
657: ELSE
658: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
659:
660: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
661: '========================================');
662: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
663: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
664: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ASSET_EQUIP_DTLS');
661: '========================================');
662: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
663: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
664: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ASSET_EQUIP_DTLS');
665: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
666:
667: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
668: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
669: FND_MESSAGE.SET_TOKEN('VALUE',
668: FND_MESSAGE.SET_TOKEN('COLUMN', 'ORGANIZATION_CODE');
669: FND_MESSAGE.SET_TOKEN('VALUE',
670: MSC_GET_NAME.ORG_CODE( lv_ORGANIZATION_ID,
671: MSC_CL_COLLECTION.v_instance_id));
672: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
673:
674: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
675: FND_MESSAGE.SET_TOKEN('COLUMN', 'ASSET_GROUP_ITEM_ID');
676: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR(lv_ASSET_ACTIVITY_ID));
673:
674: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
675: FND_MESSAGE.SET_TOKEN('COLUMN', 'ASSET_GROUP_ITEM_ID');
676: FND_MESSAGE.SET_TOKEN('VALUE', TO_CHAR(lv_ASSET_ACTIVITY_ID));
677: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
678:
679: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
680: FND_MESSAGE.SET_TOKEN('COLUMN', 'ASSET_ACTIVITY_ID');
681: FND_MESSAGE.SET_TOKEN('VALUE',
679: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
680: FND_MESSAGE.SET_TOKEN('COLUMN', 'ASSET_ACTIVITY_ID');
681: FND_MESSAGE.SET_TOKEN('VALUE',
682: TO_CHAR(lv_ASSET_REBUILD_ITEM_ID));
683: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
684:
685: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
686: END IF;
687: END;
681: FND_MESSAGE.SET_TOKEN('VALUE',
682: TO_CHAR(lv_ASSET_REBUILD_ITEM_ID));
683: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
684:
685: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
686: END IF;
687: END;
688: END LOOP;
689: END IF; -- MSC_CL_COLLECTION.v_is_incremental_refresh
694: END IF;
695:
696: BEGIN
697: IF ((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <>
698: MSC_UTIL.G_ALL_ORGANIZATIONS )
699: AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
700:
701: lv_tbl:= 'EAM_ASSET_EQUIP_DTLS_'||MSC_CL_COLLECTION.v_instance_code;
702: lv_sql_stmt:= 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
695:
696: BEGIN
697: IF ((MSC_CL_COLLECTION.v_coll_prec.org_group_flag <>
698: MSC_UTIL.G_ALL_ORGANIZATIONS )
699: AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
700:
701: lv_tbl:= 'EAM_ASSET_EQUIP_DTLS_'||MSC_CL_COLLECTION.v_instance_code;
702: lv_sql_stmt:= 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
703: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_EAM_ASSET_EQUIP_DTLS'
698: MSC_UTIL.G_ALL_ORGANIZATIONS )
699: AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
700:
701: lv_tbl:= 'EAM_ASSET_EQUIP_DTLS_'||MSC_CL_COLLECTION.v_instance_code;
702: lv_sql_stmt:= 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
703: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_EAM_ASSET_EQUIP_DTLS'
704: ||' WHERE sr_instance_id = '
705: ||MSC_CL_COLLECTION.v_instance_id
706: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
699: AND (MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES)) THEN
700:
701: lv_tbl:= 'EAM_ASSET_EQUIP_DTLS_'||MSC_CL_COLLECTION.v_instance_code;
702: lv_sql_stmt:= 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
703: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_EAM_ASSET_EQUIP_DTLS'
704: ||' WHERE sr_instance_id = '
705: ||MSC_CL_COLLECTION.v_instance_id
706: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
707:
702: lv_sql_stmt:= 'INSERT INTO '||MSC_UTIL.G_MSC_SCHEMA||'.'||lv_tbl
703: ||' SELECT * from '||MSC_UTIL.G_MSC_SCHEMA||'.MSC_EAM_ASSET_EQUIP_DTLS'
704: ||' WHERE sr_instance_id = '
705: ||MSC_CL_COLLECTION.v_instance_id
706: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
707:
708: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The sql statement is '
709: ||lv_sql_stmt);
710: EXECUTE IMMEDIATE lv_sql_stmt;
704: ||' WHERE sr_instance_id = '
705: ||MSC_CL_COLLECTION.v_instance_id
706: ||' AND organization_id not '||MSC_UTIL.v_in_org_str;
707:
708: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The sql statement is '
709: ||lv_sql_stmt);
710: EXECUTE IMMEDIATE lv_sql_stmt;
711: COMMIT;
712: END IF;
712: END IF;
713:
714: EXCEPTION
715: WHEN OTHERS THEN
716: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
717: RAISE;
718: END;
719:
720: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
716: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
717: RAISE;
718: END;
719:
720: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
721: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
722: lv_retcode,
723: 'MSC_EAM_ASSET_EQUIP_DTLS',
724: MSC_CL_COLLECTION.v_instance_code,
721: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
722: lv_retcode,
723: 'MSC_EAM_ASSET_EQUIP_DTLS',
724: MSC_CL_COLLECTION.v_instance_code,
725: MSC_UTIL.G_WARNING
726: );
727:
728: IF lv_retcode = MSC_UTIL.G_ERROR THEN
729: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
724: MSC_CL_COLLECTION.v_instance_code,
725: MSC_UTIL.G_WARNING
726: );
727:
728: IF lv_retcode = MSC_UTIL.G_ERROR THEN
729: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
730: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
731: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
732: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
725: MSC_UTIL.G_WARNING
726: );
727:
728: IF lv_retcode = MSC_UTIL.G_ERROR THEN
729: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
730: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
731: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
732: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
733: END IF;
727:
728: IF lv_retcode = MSC_UTIL.G_ERROR THEN
729: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
730: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
731: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
732: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
733: END IF;
734: END IF;
735:
728: IF lv_retcode = MSC_UTIL.G_ERROR THEN
729: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
730: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
731: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
732: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
733: END IF;
734: END IF;
735:
736: EXCEPTION
737: WHEN OTHERS THEN
738: IF c4%ISOPEN THEN
739: CLOSE c4;
740: END IF;
741: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
743: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
744: END IF;
745: IF lv_sql_stmt IS NOT NULL THEN
739: CLOSE c4;
740: END IF;
741: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
742: IF lv_cursor_stmt IS NOT NULL THEN
743: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
745: IF lv_sql_stmt IS NOT NULL THEN
746: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
747: END IF;
742: IF lv_cursor_stmt IS NOT NULL THEN
743: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
744: END IF;
745: IF lv_sql_stmt IS NOT NULL THEN
746: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
748: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
749: RAISE;
750: COMMIT;
744: END IF;
745: IF lv_sql_stmt IS NOT NULL THEN
746: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
747: END IF;
748: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
749: RAISE;
750: COMMIT;
751: END LOAD_EAM_INFO;
752:
761:
762:
763: EXCEPTION
764: WHEN OTHERS THEN
765: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
766: 'An error has occurred during deletion of Eam info.');
767: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
768: RAISE;
769: END;
763: EXCEPTION
764: WHEN OTHERS THEN
765: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
766: 'An error has occurred during deletion of Eam info.');
767: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
768: RAISE;
769: END;
770: END LOOP;
771:
771:
772: COMMIT;
773:
774: BEGIN
775: IF MSC_CL_COLLECTION.v_exchange_mode = MSC_UTIL.SYS_YES THEN
776: lv_tbl:= 'EAM_ACT_ASSOCIATIONS_'||MSC_CL_COLLECTION.v_instance_code;
777: ELSE
778: lv_tbl:= 'MSC_EAM_ACT_ASSOCIATIONS';
779: END IF;
776: lv_tbl:= 'EAM_ACT_ASSOCIATIONS_'||MSC_CL_COLLECTION.v_instance_code;
777: ELSE
778: lv_tbl:= 'MSC_EAM_ACT_ASSOCIATIONS';
779: END IF;
780: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,
781: 'In Procedure LOAD_EAM_INFO lv_tbl'||lv_tbl);
782:
783: lv_sql_stmt:=
784: 'INSERT INTO '||lv_tbl
875: WHEN OTHERS THEN
876:
877: IF SQLCODE IN (-01683,-01653,-01650,-01562) THEN
878:
879: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
880: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
881: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
882: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ACT_ASSOCIATIONS');
883: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
879: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
880: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
881: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
882: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ACT_ASSOCIATIONS');
883: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
884:
885: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
886: RAISE;
887:
881: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
882: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ACT_ASSOCIATIONS');
883: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
884:
885: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
886: RAISE;
887:
888: ELSE
889:
886: RAISE;
887:
888: ELSE
889:
890: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
891:
892: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
893: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
894: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
888: ELSE
889:
890: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
891:
892: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
893: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
894: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
895: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ACT_ASSOCIATIONS');
896: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
892: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '========================================');
893: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
894: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_INFO');
895: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_EAM_ACT_ASSOCIATIONS');
896: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
897:
898: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
899: FND_MESSAGE.SET_TOKEN('COLUMN', 'ASSET_ACTIVITY_ID');
900: FND_MESSAGE.SET_TOKEN('VALUE',c_rec.ASSET_ACTIVITY_ID );
897:
898: FND_MESSAGE.SET_NAME('MSC','MSC_OL_DATA_ERR_DETAIL');
899: FND_MESSAGE.SET_TOKEN('COLUMN', 'ASSET_ACTIVITY_ID');
900: FND_MESSAGE.SET_TOKEN('VALUE',c_rec.ASSET_ACTIVITY_ID );
901: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
902:
903: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
904: END IF;
905:
899: FND_MESSAGE.SET_TOKEN('COLUMN', 'ASSET_ACTIVITY_ID');
900: FND_MESSAGE.SET_TOKEN('VALUE',c_rec.ASSET_ACTIVITY_ID );
901: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
902:
903: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
904: END IF;
905:
906:
907: --END;
906:
907: --END;
908:
909:
910: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Total MSC_JOB_OPERATIONS = '|| total_count);
911: END IF;
912:
913: COMMIT;
914: END;
912:
913: COMMIT;
914: END;
915:
916: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
917: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
918: lv_retcode,
919: 'MSC_EAM_ACT_ASSOCIATIONS',
920: MSC_CL_COLLECTION.v_INSTANCE_CODE,
917: MSC_CL_COLLECTION.alter_temp_table (lv_errbuf,
918: lv_retcode,
919: 'MSC_EAM_ACT_ASSOCIATIONS',
920: MSC_CL_COLLECTION.v_INSTANCE_CODE,
921: MSC_UTIL.G_ERROR);
922:
923: IF lv_retcode = MSC_UTIL.G_ERROR THEN
924: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
925: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
919: 'MSC_EAM_ACT_ASSOCIATIONS',
920: MSC_CL_COLLECTION.v_INSTANCE_CODE,
921: MSC_UTIL.G_ERROR);
922:
923: IF lv_retcode = MSC_UTIL.G_ERROR THEN
924: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
925: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
926: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
927: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
920: MSC_CL_COLLECTION.v_INSTANCE_CODE,
921: MSC_UTIL.G_ERROR);
922:
923: IF lv_retcode = MSC_UTIL.G_ERROR THEN
924: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
925: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
926: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
927: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
928: END IF;
922:
923: IF lv_retcode = MSC_UTIL.G_ERROR THEN
924: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
925: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
926: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
927: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
928: END IF;
929: END IF;
930:
923: IF lv_retcode = MSC_UTIL.G_ERROR THEN
924: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, lv_errbuf);
925: RAISE MSC_CL_COLLECTION.ALTER_TEMP_TABLE_ERROR;
926: ELSIF lv_retcode = MSC_UTIL.G_WARNING THEN
927: MSC_CL_COLLECTION.v_warning_flag := MSC_UTIL.SYS_YES;
928: END IF;
929: END IF;
930:
931: EXCEPTION
931: EXCEPTION
932: WHEN OTHERS THEN
933: --IF cgen%ISOPEN THEN CLOSE cgen; END IF;
934:
935: -- MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
937: -- MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
938: -- END IF;
939: -- IF lv_sql_stmt IS NOT NULL THEN
933: --IF cgen%ISOPEN THEN CLOSE cgen; END IF;
934:
935: -- MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
936: --- IF lv_cursor_stmt IS NOT NULL THEN
937: -- MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
939: -- IF lv_sql_stmt IS NOT NULL THEN
940: -- MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
941: -- END IF;
936: --- IF lv_cursor_stmt IS NOT NULL THEN
937: -- MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
938: -- END IF;
939: -- IF lv_sql_stmt IS NOT NULL THEN
940: -- MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
942: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
943: RAISE;*/
944:
938: -- END IF;
939: -- IF lv_sql_stmt IS NOT NULL THEN
940: -- MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
941: -- END IF;
942: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
943: RAISE;*/
944:
945:
946: PROCEDURE LOAD_EAM_FORECASTS IS
949: lv_retcode NUMBER;
950: lv_tbl VARCHAR2(30);
951: lv_sql_ins VARCHAR2(6000);
952: BEGIN
953: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'In Procedure LOAD_EAM_FORECASTS ');
954:
955: /*Delete msc_table based on org group ???? wher wil that be handled...*/
956:
957: -- ========= Prepare the Cursor Statement ==========
954:
955: /*Delete msc_table based on org group ???? wher wil that be handled...*/
956:
957: -- ========= Prepare the Cursor Statement ==========
958: IF MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
959: lv_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
960: ELSE
961: lv_tbl:= 'MSC_SUPPLIES';
962: END IF;
962: END IF;
963:
964: IF (MSC_CL_COLLECTION.v_is_complete_refresh
965: OR MSC_CL_COLLECTION.v_is_partial_refresh)
966: AND MSC_CL_COLLECTION.v_exchange_mode=MSC_UTIL.SYS_YES THEN
967:
968: BEGIN
969:
970: lv_sql_ins := 'insert into '||lv_tbl
1025: ||' WHERE t1.SR_INVENTORY_ITEM_ID= -1002'
1026: ||' AND t1.SR_INSTANCE_ID= ms.SR_INSTANCE_ID'
1027: ||' AND t2.SR_INVENTORY_ITEM_ID= ms.ASSET_ITEM_ID '
1028: ||' AND t2.SR_INSTANCE_ID= ms.SR_INSTANCE_ID'
1029: ||' AND ms.DELETED_FLAG = '|| MSC_UTIL.SYS_NO
1030: ||' AND ms.SCHEDULE_DESIGNATOR_ID = md.SRC_SIM_FCST_ID'
1031: ||' AND md.SR_INSTANCE_ID= ms.SR_INSTANCE_ID'
1032: ||' AND ms.SR_INSTANCE_ID= '||MSC_CL_COLLECTION.v_instance_id
1033: ||' AND ms.ORDER_TYPE = 92'
1035: ||' AND md.DESIGNATOR_TYPE = 12'
1036: ||' AND md.organization_id = ms.organization_id '
1037: ||' AND md.designator = ''-23453''';
1038:
1039: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Sql stmt - '||lv_sql_ins);
1040:
1041: EXECUTE IMMEDIATE lv_sql_ins
1042: USING MSC_CL_COLLECTION.v_last_collection_id,
1043: MSC_CL_COLLECTION.v_current_date,
1044: MSC_CL_COLLECTION.v_current_user,
1045: MSC_CL_COLLECTION.v_current_date,
1046: MSC_CL_COLLECTION.v_current_user;
1047:
1048: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'no.of rows inserted '||SQL%ROWCOUNT);
1049: COMMIT;
1050: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Eam forecasts loaded');
1051: EXCEPTION
1052: WHEN OTHERS THEN
1046: MSC_CL_COLLECTION.v_current_user;
1047:
1048: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'no.of rows inserted '||SQL%ROWCOUNT);
1049: COMMIT;
1050: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Eam forecasts loaded');
1051: EXCEPTION
1052: WHEN OTHERS THEN
1053: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
1054: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
1050: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Eam forecasts loaded');
1051: EXCEPTION
1052: WHEN OTHERS THEN
1053: IF SQLCODE IN (-01653,-01650,-01562,-01683) THEN
1054: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
1055: '========================================');
1056: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1057: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_FORECASTS');
1058: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_SUPPLIES');
1055: '========================================');
1056: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1057: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_FORECASTS');
1058: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_SUPPLIES');
1059: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1060: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1061: RAISE;
1062: ELSE
1063: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
1056: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1057: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_FORECASTS');
1058: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_SUPPLIES');
1059: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1060: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1061: RAISE;
1062: ELSE
1063: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
1064: '========================================');
1059: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1060: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1061: RAISE;
1062: ELSE
1063: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,
1064: '========================================');
1065: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1066: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_FORECASTS');
1067: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_SUPPLIES');
1064: '========================================');
1065: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1066: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_FORECASTS');
1067: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_SUPPLIES');
1068: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1069: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1070: END IF;
1071: END;
1072: END IF; -- MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh
1065: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_DATA_ERR_HEADER');
1066: FND_MESSAGE.SET_TOKEN('PROCEDURE', 'LOAD_EAM_FORECASTS');
1067: FND_MESSAGE.SET_TOKEN('TABLE', 'MSC_SUPPLIES');
1068: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, FND_MESSAGE.GET);
1069: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1070: END IF;
1071: END;
1072: END IF; -- MSC_CL_COLLECTION.v_is_complete_refresh OR MSC_CL_COLLECTION.v_is_partial_refresh
1073:
1080:
1081: EXCEPTION
1082: WHEN OTHERS THEN
1083: IF lv_sql_ins IS NOT NULL THEN
1084: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
1086: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1087: RAISE;
1088:
1082: WHEN OTHERS THEN
1083: IF lv_sql_ins IS NOT NULL THEN
1084: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
1085: END IF;
1086: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1087: RAISE;
1088:
1089: COMMIT;
1090: END LOAD_EAM_FORECASTS;
1097: lv_sql_stmt VARCHAR2(32767);
1098: lv_supplies_tbl VARCHAR2(30);
1099:
1100: BEGIN
1101: IF MSC_CL_COLLECTION.v_exchange_mode = MSC_UTIL.SYS_YES THEN
1102: lv_tbl:= 'DEMANDS_'||MSC_CL_COLLECTION.v_instance_code;
1103: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
1104: ELSE
1105: lv_tbl:= 'MSC_DEMANDS';
1139: ||' AND ms.SOURCE_ITEM_ID =md.USING_ASSEMBLY_ITEM_ID'
1140: ||' AND ms.SCHEDULE_DESIGNATOR_ID = md1.DESIGNATOR_ID'
1141: ||' AND md.ASSET_ITEM_ID = ms.INVENTORY_ITEM_ID'
1142: ||' AND md.CLASS_CODE = ms.CLASS_CODE'
1143: --||' AND ms.DELETED_FLAG ='|| MSC_UTIL.SYS_NO
1144: ||' AND ms.ORDER_TYPE = 92 '
1145: ||' AND md.ORIGINATION_TYPE = 92'
1146: ||' AND ms.PLAN_ID = -1'
1147: ||' AND ms.NEW_WIP_START_DATE = md.USING_ASSEMBLY_DEMAND_DATE'
1197:
1198: EXCEPTION
1199: WHEN OTHERS THEN
1200:
1201: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
1203: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
1204: END IF;
1205: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1199: WHEN OTHERS THEN
1200:
1201: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
1202: IF lv_sql_stmt IS NOT NULL THEN
1203: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
1205: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1206:
1207: ROLLBACK WORK TO SAVEPOINT Load_eam_dem;
1201: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
1202: IF lv_sql_stmt IS NOT NULL THEN
1203: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
1204: END IF;
1205: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1206:
1207: ROLLBACK WORK TO SAVEPOINT Load_eam_dem;
1208:
1209: END;
1222: lv_sql_stmt VARCHAR2(32767);
1223:
1224: BEGIN
1225:
1226: IF MSC_CL_COLLECTION.v_exchange_mode = MSC_UTIL.SYS_YES THEN
1227: lv_tbl:= 'RESOURCE_REQUIREMENTS_'||MSC_CL_COLLECTION.v_instance_code;
1228: lv_supplies_tbl:= 'SUPPLIES_'||MSC_CL_COLLECTION.v_instance_code;
1229: ELSE
1230: lv_tbl:= 'MSC_RESOURCE_REQUIREMENTS';
1323:
1324: EXCEPTION
1325: WHEN OTHERS THEN
1326:
1327: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
1329: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
1330: END IF;
1331: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1325: WHEN OTHERS THEN
1326:
1327: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
1328: IF lv_sql_stmt IS NOT NULL THEN
1329: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
1331: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1332:
1333: ROLLBACK WORK TO SAVEPOINT Load_eam_res;
1327: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
1328: IF lv_sql_stmt IS NOT NULL THEN
1329: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, '<
1330: END IF;
1331: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1332:
1333: ROLLBACK WORK TO SAVEPOINT Load_eam_res;
1334: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Switching to Row-By-Row processing.');
1335:
1330: END IF;
1331: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, SQLERRM);
1332:
1333: ROLLBACK WORK TO SAVEPOINT Load_eam_res;
1334: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'Switching to Row-By-Row processing.');
1335:
1336: END;
1337:
1338: END IF;
1376: cnt2 NUMBER;
1377:
1378: BEGIN
1379:
1380: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '==========================================================');
1381: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Starting LINK_REBUILD_BOM_ACTIVITY ......');
1382: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '==========================================================');
1383:
1384: lv_cursor_stmt := 'SELECT b.BILL_SEQUENCE_ID, '
1377:
1378: BEGIN
1379:
1380: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '==========================================================');
1381: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Starting LINK_REBUILD_BOM_ACTIVITY ......');
1382: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '==========================================================');
1383:
1384: lv_cursor_stmt := 'SELECT b.BILL_SEQUENCE_ID, '
1385: ||'b.ASSEMBLY_TYPE, '
1378: BEGIN
1379:
1380: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '==========================================================');
1381: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Starting LINK_REBUILD_BOM_ACTIVITY ......');
1382: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '==========================================================');
1383:
1384: lv_cursor_stmt := 'SELECT b.BILL_SEQUENCE_ID, '
1385: ||'b.ASSEMBLY_TYPE, '
1386: ||'mea.ASSET_REBUILD_ITEM_ID, '
1436:
1437: cnt := cnt+1;
1438: END LOOP;
1439:
1440: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'after update of MSC_BOMS: count ' || cnt);
1441:
1442: lv_ins_stmt :=
1443: 'INSERT INTO MSC_BOMS ( '
1444: ||'BILL_SEQUENCE_ID, '
1480: ||'(select BILL_SEQUENCE_ID,ASSEMBLY_ITEM_ID,ACTIVITY_ITEM_ID,ORGANIZATION_ID '
1481: ||'from MSC_BOMS where PLAN_ID =-1 '
1482: ||' AND SR_INSTANCE_ID = ' || MSC_CL_COLLECTION.v_instance_id ||') ';
1483:
1484: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'stmt being executed-- ' || lv_ins_stmt);
1485:
1486: EXECUTE IMMEDIATE lv_ins_stmt USING MSC_CL_COLLECTION.v_last_collection_id,
1487: MSC_CL_COLLECTION.v_current_date,
1488: MSC_CL_COLLECTION.v_current_user,
1487: MSC_CL_COLLECTION.v_current_date,
1488: MSC_CL_COLLECTION.v_current_user,
1489: MSC_CL_COLLECTION.v_current_date,
1490: MSC_CL_COLLECTION.v_current_user;
1491: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'rows inserted into msc_boms '
1492: ||SQL%ROWCOUNT);
1493: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '==========================================================');
1494:
1495: COMMIT;
1489: MSC_CL_COLLECTION.v_current_date,
1490: MSC_CL_COLLECTION.v_current_user;
1491: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'rows inserted into msc_boms '
1492: ||SQL%ROWCOUNT);
1493: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '==========================================================');
1494:
1495: COMMIT;
1496:
1497: EXCEPTION WHEN NO_DATA_FOUND THEN
1494:
1495: COMMIT;
1496:
1497: EXCEPTION WHEN NO_DATA_FOUND THEN
1498: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'No link for BOM:' );
1499:
1500: WHEN OTHERS THEN
1501: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The Error Message is: '||SQLERRM);
1502: NULL;
1497: EXCEPTION WHEN NO_DATA_FOUND THEN
1498: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'No link for BOM:' );
1499:
1500: WHEN OTHERS THEN
1501: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The Error Message is: '||SQLERRM);
1502: NULL;
1503:
1504: END;
1505:
1560: cnt1 := cnt1+1;
1561:
1562: END LOOP;
1563:
1564: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'after update of MSC_ROUTINGS: count ' || cnt1);
1565:
1566: lv_ins_stmt1 :=
1567: 'INSERT INTO MSC_ROUTINGS ( '
1568: ||'ROUTING_SEQUENCE_ID, '
1605: ||'from MSC_ROUTINGS where PLAN_ID =-1 '
1606: ||'AND SR_INSTANCE_ID = ' || MSC_CL_COLLECTION.v_instance_id ||') ';
1607:
1608:
1609: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'stmt being executed-- ' || lv_ins_stmt1);
1610:
1611: EXECUTE IMMEDIATE lv_ins_stmt1 USING MSC_CL_COLLECTION.v_last_collection_id,
1612: MSC_CL_COLLECTION.v_current_date,
1613: MSC_CL_COLLECTION.v_current_user,
1612: MSC_CL_COLLECTION.v_current_date,
1613: MSC_CL_COLLECTION.v_current_user,
1614: MSC_CL_COLLECTION.v_current_date,
1615: MSC_CL_COLLECTION.v_current_user;
1616: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'rows inserted into msc_routings'
1617: ||SQL%ROWCOUNT);
1618: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '==========================================================');
1619:
1620: COMMIT;
1614: MSC_CL_COLLECTION.v_current_date,
1615: MSC_CL_COLLECTION.v_current_user;
1616: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'rows inserted into msc_routings'
1617: ||SQL%ROWCOUNT);
1618: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '==========================================================');
1619:
1620: COMMIT;
1621:
1622: EXCEPTION WHEN NO_DATA_FOUND THEN
1619:
1620: COMMIT;
1621:
1622: EXCEPTION WHEN NO_DATA_FOUND THEN
1623: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'No link for ROUTING:' );
1624:
1625: WHEN OTHERS THEN
1626: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The Error Message is: '||SQLERRM);
1627: NULL;
1622: EXCEPTION WHEN NO_DATA_FOUND THEN
1623: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'No link for ROUTING:' );
1624:
1625: WHEN OTHERS THEN
1626: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The Error Message is: '||SQLERRM);
1627: NULL;
1628:
1629: END;
1630:
1698: cnt2 := cnt2+1;
1699:
1700: END LOOP;
1701:
1702: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'after update of MSC_PROCESS_EFFECTIVITY: count ' || cnt2);
1703:
1704: lv_ins_stmt2 :=
1705: 'INSERT INTO MSC_PROCESS_EFFECTIVITY ( '
1706: ||'PROCESS_SEQUENCE_ID, '
1749: ||' from MSC_PROCESS_EFFECTIVITY where PLAN_ID =-1 '
1750: ||' AND SR_INSTANCE_ID = ' || MSC_CL_COLLECTION.v_instance_id ||') ';
1751:
1752:
1753: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'stmt being executed--' || lv_ins_stmt2);
1754:
1755: EXECUTE IMMEDIATE lv_ins_stmt2 USING MSC_CL_COLLECTION.v_last_collection_id,
1756: MSC_CL_COLLECTION.v_current_date,
1757: MSC_CL_COLLECTION.v_current_user,
1756: MSC_CL_COLLECTION.v_current_date,
1757: MSC_CL_COLLECTION.v_current_user,
1758: MSC_CL_COLLECTION.v_current_date,
1759: MSC_CL_COLLECTION.v_current_user;
1760: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'rows inserted into msc_process_effec'
1761: ||'tivity '||SQL%ROWCOUNT);
1762: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '==========================================================');
1763:
1764: COMMIT;
1758: MSC_CL_COLLECTION.v_current_date,
1759: MSC_CL_COLLECTION.v_current_user;
1760: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'rows inserted into msc_process_effec'
1761: ||'tivity '||SQL%ROWCOUNT);
1762: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '==========================================================');
1763:
1764: COMMIT;
1765:
1766: EXCEPTION WHEN NO_DATA_FOUND THEN
1763:
1764: COMMIT;
1765:
1766: EXCEPTION WHEN NO_DATA_FOUND THEN
1767: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'No link for ROUTING:' );
1768:
1769: WHEN OTHERS THEN
1770: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The Error Message is: '||SQLERRM);
1771: NULL;
1766: EXCEPTION WHEN NO_DATA_FOUND THEN
1767: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'No link for ROUTING:' );
1768:
1769: WHEN OTHERS THEN
1770: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS, 'The Error Message is: '||SQLERRM);
1771: NULL;
1772:
1773: END;
1774:
1796: order by s.transaction_id;
1797:
1798: BEGIN
1799:
1800: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Updation of Produces_to_stock flag' );
1801:
1802: for c_rec in c_prod_stock loop
1803: update msc_supplies ms
1804: set ms.produces_to_stock =1
1811: and ms.organization_id = c_rec.organization_id
1812: and ms.inventory_item_id = c_rec.inventory_item_id
1813: and ms.activity_item_id = c_rec.activity_item_id ;
1814:
1815: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Updated rows'||SQL%ROWCOUNT);
1816: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '==========================================================');
1817: commit;
1818: end loop;
1819:
1812: and ms.inventory_item_id = c_rec.inventory_item_id
1813: and ms.activity_item_id = c_rec.activity_item_id ;
1814:
1815: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Updated rows'||SQL%ROWCOUNT);
1816: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '==========================================================');
1817: commit;
1818: end loop;
1819:
1820:
1820:
1821: EXCEPTION
1822: WHEN OTHERS THEN
1823: ROLLBACK;
1824: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_STATUS,SQLERRM);
1825:
1826:
1827: END UPD_PROD_STOCK;
1828: