eTRM uses javascript that opens and focuses a separate window to display reports. Your browser does not appear to support javascript. This should not prevent you from using eTRM but it does mean the window focus feature will not work. Please check the contents of other windows on your desktop if you click on a link that does not appear to do anything.

APPS.MTH_LOAD_TAG_READINGS_PKG dependencies on MTH_UTIL_PKG

Line 50: mth_util_pkg.log_msg('PROCESS_READINGS start', mth_util_pkg.G_DBG_PROC_FUN_START);

46: ) IS
47:
48: BEGIN
49: p_ret_code := 0;
50: mth_util_pkg.log_msg('PROCESS_READINGS start', mth_util_pkg.G_DBG_PROC_FUN_START);
51: mth_util_pkg.log_msg('p_mode = ' || p_mode , mth_util_pkg.G_DBG_PARAM_VAL);
52: mth_util_pkg.log_msg('p_recal_from_date = ' || to_char(p_recal_from_date,'DD-MON-YYYY HH24:MI:SS') , mth_util_pkg.G_DBG_PARAM_VAL);
53: mth_util_pkg.log_msg('p_recal_to_date = ' || to_char(p_recal_to_date,'DD-MON-YYYY HH24:MI:SS') , mth_util_pkg.G_DBG_PARAM_VAL);
54: mth_util_pkg.log_msg('p_equipment_pk_key = ' || p_equipment_pk_key, mth_util_pkg.G_DBG_PARAM_VAL);

Line 51: mth_util_pkg.log_msg('p_mode = ' || p_mode , mth_util_pkg.G_DBG_PARAM_VAL);

47:
48: BEGIN
49: p_ret_code := 0;
50: mth_util_pkg.log_msg('PROCESS_READINGS start', mth_util_pkg.G_DBG_PROC_FUN_START);
51: mth_util_pkg.log_msg('p_mode = ' || p_mode , mth_util_pkg.G_DBG_PARAM_VAL);
52: mth_util_pkg.log_msg('p_recal_from_date = ' || to_char(p_recal_from_date,'DD-MON-YYYY HH24:MI:SS') , mth_util_pkg.G_DBG_PARAM_VAL);
53: mth_util_pkg.log_msg('p_recal_to_date = ' || to_char(p_recal_to_date,'DD-MON-YYYY HH24:MI:SS') , mth_util_pkg.G_DBG_PARAM_VAL);
54: mth_util_pkg.log_msg('p_equipment_pk_key = ' || p_equipment_pk_key, mth_util_pkg.G_DBG_PARAM_VAL);
55:

Line 52: mth_util_pkg.log_msg('p_recal_from_date = ' || to_char(p_recal_from_date,'DD-MON-YYYY HH24:MI:SS') , mth_util_pkg.G_DBG_PARAM_VAL);

48: BEGIN
49: p_ret_code := 0;
50: mth_util_pkg.log_msg('PROCESS_READINGS start', mth_util_pkg.G_DBG_PROC_FUN_START);
51: mth_util_pkg.log_msg('p_mode = ' || p_mode , mth_util_pkg.G_DBG_PARAM_VAL);
52: mth_util_pkg.log_msg('p_recal_from_date = ' || to_char(p_recal_from_date,'DD-MON-YYYY HH24:MI:SS') , mth_util_pkg.G_DBG_PARAM_VAL);
53: mth_util_pkg.log_msg('p_recal_to_date = ' || to_char(p_recal_to_date,'DD-MON-YYYY HH24:MI:SS') , mth_util_pkg.G_DBG_PARAM_VAL);
54: mth_util_pkg.log_msg('p_equipment_pk_key = ' || p_equipment_pk_key, mth_util_pkg.G_DBG_PARAM_VAL);
55:
56: IF p_mode = 'INIT' THEN

Line 53: mth_util_pkg.log_msg('p_recal_to_date = ' || to_char(p_recal_to_date,'DD-MON-YYYY HH24:MI:SS') , mth_util_pkg.G_DBG_PARAM_VAL);

49: p_ret_code := 0;
50: mth_util_pkg.log_msg('PROCESS_READINGS start', mth_util_pkg.G_DBG_PROC_FUN_START);
51: mth_util_pkg.log_msg('p_mode = ' || p_mode , mth_util_pkg.G_DBG_PARAM_VAL);
52: mth_util_pkg.log_msg('p_recal_from_date = ' || to_char(p_recal_from_date,'DD-MON-YYYY HH24:MI:SS') , mth_util_pkg.G_DBG_PARAM_VAL);
53: mth_util_pkg.log_msg('p_recal_to_date = ' || to_char(p_recal_to_date,'DD-MON-YYYY HH24:MI:SS') , mth_util_pkg.G_DBG_PARAM_VAL);
54: mth_util_pkg.log_msg('p_equipment_pk_key = ' || p_equipment_pk_key, mth_util_pkg.G_DBG_PARAM_VAL);
55:
56: IF p_mode = 'INIT' THEN
57: INIT_READINGS_FROM_RAW(

Line 54: mth_util_pkg.log_msg('p_equipment_pk_key = ' || p_equipment_pk_key, mth_util_pkg.G_DBG_PARAM_VAL);

50: mth_util_pkg.log_msg('PROCESS_READINGS start', mth_util_pkg.G_DBG_PROC_FUN_START);
51: mth_util_pkg.log_msg('p_mode = ' || p_mode , mth_util_pkg.G_DBG_PARAM_VAL);
52: mth_util_pkg.log_msg('p_recal_from_date = ' || to_char(p_recal_from_date,'DD-MON-YYYY HH24:MI:SS') , mth_util_pkg.G_DBG_PARAM_VAL);
53: mth_util_pkg.log_msg('p_recal_to_date = ' || to_char(p_recal_to_date,'DD-MON-YYYY HH24:MI:SS') , mth_util_pkg.G_DBG_PARAM_VAL);
54: mth_util_pkg.log_msg('p_equipment_pk_key = ' || p_equipment_pk_key, mth_util_pkg.G_DBG_PARAM_VAL);
55:
56: IF p_mode = 'INIT' THEN
57: INIT_READINGS_FROM_RAW(
58: p_from_tz,

Line 77: mth_util_pkg.log_msg('PROCESS_READINGS end', mth_util_pkg.G_DBG_PROC_FUN_END);

73: p_to_tz,
74: p_ret_code
75: );
76: END IF;
77: mth_util_pkg.log_msg('PROCESS_READINGS end', mth_util_pkg.G_DBG_PROC_FUN_END);
78:
79: EXCEPTION
80: WHEN OTHERS THEN
81: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);

Line 81: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);

77: mth_util_pkg.log_msg('PROCESS_READINGS end', mth_util_pkg.G_DBG_PROC_FUN_END);
78:
79: EXCEPTION
80: WHEN OTHERS THEN
81: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);
82: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
83: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
84: p_ret_code :=2;
85:

Line 82: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);

78:
79: EXCEPTION
80: WHEN OTHERS THEN
81: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);
82: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
83: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
84: p_ret_code :=2;
85:
86: END PROCESS_READINGS;

Line 83: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);

79: EXCEPTION
80: WHEN OTHERS THEN
81: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);
82: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
83: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
84: p_ret_code :=2;
85:
86: END PROCESS_READINGS;
87: /*******************************************************************************

Line 141: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_RAW_ERR while proceesing the data from tag readings raw processed table - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

137: FROM MTH_TAG_READINGS_RAW_PROCESSED RP
138: GROUP BY RP.READING_TIME , RP.TAG_CODE
139: HAVING COUNT(RP.TAG_CODE) > 1
140: ) ;
141: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_RAW_ERR while proceesing the data from tag readings raw processed table - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
142:
143: ---Inserting records missing equipment or plant or incorrect status information or missing mth entity,attribute group and attribute information in tag readings staging error table
144:
145: INSERT

Line 229: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_STG_ERR while proceesing the data from tag readings raw processed table- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

225: AND TDM.ATTRIBUTE IS NULL )
226: )
227: )
228: ;
229: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_STG_ERR while proceesing the data from tag readings raw processed table- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
230:
231: -- Inserting records in tag readings staging table
232: INSERT
233: INTO

Line 322: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_STG while proceesing the data from tag readings raw processed table - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

318: TDM.ATTRIBUTE IS NULL)
319: )
320:
321: ;
322: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_STG while proceesing the data from tag readings raw processed table - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
323: v_ret_code:=0;
324: RETURN v_ret_code;
325: EXCEPTION
326: WHEN OTHERS THEN

Line 327: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);

323: v_ret_code:=0;
324: RETURN v_ret_code;
325: EXCEPTION
326: WHEN OTHERS THEN
327: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);
328: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
329: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
330: v_ret_code :=2;
331: RETURN v_ret_code;

Line 328: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);

324: RETURN v_ret_code;
325: EXCEPTION
326: WHEN OTHERS THEN
327: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);
328: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
329: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
330: v_ret_code :=2;
331: RETURN v_ret_code;
332:

Line 329: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);

325: EXCEPTION
326: WHEN OTHERS THEN
327: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);
328: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
329: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
330: v_ret_code :=2;
331: RETURN v_ret_code;
332:
333: END MTH_TRANSFORM_TAG_DATA_TO_STG;

Line 392: NVL( TRE.WORKORDER_FK_KEY , MTH_UTIL_PKG.MTH_UA_GET_VAL() ) ,

388: TRE.MTH_ENTITY,
389: TRE.ATTRIBUTE_GROUP,
390: TRE.ATTRIBUTE,
391: TRE.EQUIPMENT_FK_KEY,
392: NVL( TRE.WORKORDER_FK_KEY , MTH_UTIL_PKG.MTH_UA_GET_VAL() ) ,
393: NVL( TRE.SEGMENT_FK_KEY , MTH_UTIL_PKG.MTH_UA_GET_VAL() ),
394: TRE.SHIFT_WORKDAY_FK_KEY,
395: NVL( TRE.ITEM_FK_KEY , MTH_UTIL_PKG.MTH_UA_GET_VAL() ),
396: TRE.HOUR_FK_KEY,

Line 393: NVL( TRE.SEGMENT_FK_KEY , MTH_UTIL_PKG.MTH_UA_GET_VAL() ),

389: TRE.ATTRIBUTE_GROUP,
390: TRE.ATTRIBUTE,
391: TRE.EQUIPMENT_FK_KEY,
392: NVL( TRE.WORKORDER_FK_KEY , MTH_UTIL_PKG.MTH_UA_GET_VAL() ) ,
393: NVL( TRE.SEGMENT_FK_KEY , MTH_UTIL_PKG.MTH_UA_GET_VAL() ),
394: TRE.SHIFT_WORKDAY_FK_KEY,
395: NVL( TRE.ITEM_FK_KEY , MTH_UTIL_PKG.MTH_UA_GET_VAL() ),
396: TRE.HOUR_FK_KEY,
397: TRE.PROCESSED_FLAG,

Line 395: NVL( TRE.ITEM_FK_KEY , MTH_UTIL_PKG.MTH_UA_GET_VAL() ),

391: TRE.EQUIPMENT_FK_KEY,
392: NVL( TRE.WORKORDER_FK_KEY , MTH_UTIL_PKG.MTH_UA_GET_VAL() ) ,
393: NVL( TRE.SEGMENT_FK_KEY , MTH_UTIL_PKG.MTH_UA_GET_VAL() ),
394: TRE.SHIFT_WORKDAY_FK_KEY,
395: NVL( TRE.ITEM_FK_KEY , MTH_UTIL_PKG.MTH_UA_GET_VAL() ),
396: TRE.HOUR_FK_KEY,
397: TRE.PROCESSED_FLAG,
398: SYSDATE - 0.0001,
399: SYSDATE - 0.0001,

Line 400: MTH_UTIL_PKG.MTH_UA_GET_VAL(),

396: TRE.HOUR_FK_KEY,
397: TRE.PROCESSED_FLAG,
398: SYSDATE - 0.0001,
399: SYSDATE - 0.0001,
400: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
401: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
402: TRE.PLANT_FK_KEY,
403: TRE.USER_ATTR1,
404: TRE.USER_ATTR2,

Line 401: MTH_UTIL_PKG.MTH_UA_GET_VAL(),

397: TRE.PROCESSED_FLAG,
398: SYSDATE - 0.0001,
399: SYSDATE - 0.0001,
400: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
401: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
402: TRE.PLANT_FK_KEY,
403: TRE.USER_ATTR1,
404: TRE.USER_ATTR2,
405: TRE.USER_ATTR3,

Line 427: TRE.WORKORDER_FK_KEY IS NOT NULL And TRE.WORKORDER_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL() ) AND

423: AND TRE.SHIFT_WORKDAY_FK_KEY IS NOT NULL AND
424: TRE.HOUR_FK_KEY IS NOT NULL AND
425: TRE.EQUIPMENT_STATUS = 'ACTIVE' AND
426: ( MCR.WO_REQUIRED <> 'Y' Or
427: TRE.WORKORDER_FK_KEY IS NOT NULL And TRE.WORKORDER_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL() ) AND
428: ( MCR.WO_SEGMENT_REQUIRED <> 'Y' Or
429: TRE.SEGMENT_FK_KEY IS NOT NULL And TRE.SEGMENT_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL()) AND
430: ( MCR.ITEM_REQUIRED <> 'Y' Or
431: TRE.ITEM_FK_KEY IS NOT NULL And TRE.ITEM_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL() )

Line 429: TRE.SEGMENT_FK_KEY IS NOT NULL And TRE.SEGMENT_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL()) AND

425: TRE.EQUIPMENT_STATUS = 'ACTIVE' AND
426: ( MCR.WO_REQUIRED <> 'Y' Or
427: TRE.WORKORDER_FK_KEY IS NOT NULL And TRE.WORKORDER_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL() ) AND
428: ( MCR.WO_SEGMENT_REQUIRED <> 'Y' Or
429: TRE.SEGMENT_FK_KEY IS NOT NULL And TRE.SEGMENT_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL()) AND
430: ( MCR.ITEM_REQUIRED <> 'Y' Or
431: TRE.ITEM_FK_KEY IS NOT NULL And TRE.ITEM_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL() )
432: )
433: ;

Line 431: TRE.ITEM_FK_KEY IS NOT NULL And TRE.ITEM_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL() )

427: TRE.WORKORDER_FK_KEY IS NOT NULL And TRE.WORKORDER_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL() ) AND
428: ( MCR.WO_SEGMENT_REQUIRED <> 'Y' Or
429: TRE.SEGMENT_FK_KEY IS NOT NULL And TRE.SEGMENT_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL()) AND
430: ( MCR.ITEM_REQUIRED <> 'Y' Or
431: TRE.ITEM_FK_KEY IS NOT NULL And TRE.ITEM_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL() )
432: )
433: ;
434: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS from tag readings error table- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
435:

Line 434: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS from tag readings error table- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

430: ( MCR.ITEM_REQUIRED <> 'Y' Or
431: TRE.ITEM_FK_KEY IS NOT NULL And TRE.ITEM_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL() )
432: )
433: ;
434: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS from tag readings error table- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
435:
436: -- Inserting scheduled based contextualization records in tag readings staging table for the equipment whose staus is active
437: INSERT
438: INTO

Line 495: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_STG from tag readings error table- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

491: AND MCM.CONTEXTUALIZE_METHOD = 2
492: AND TRE.EQUIPMENT_STATUS = 'ACTIVE'
493: )
494: ;
495: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_STG from tag readings error table- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
496:
497: -- Inserting Remaining records in tag readings error table
498: INSERT
499: INTO

Line 590: TRE.WORKORDER_FK_KEY IS NOT NULL And TRE.WORKORDER_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL() ) And

586: TRE.SHIFT_WORKDAY_FK_KEY IS NOT NULL And
587: TRE.HOUR_FK_KEY IS NOT NULL And
588: TRE.EQUIPMENT_STATUS = 'ACTIVE' And
589: (MCR.WO_REQUIRED <> 'Y' Or
590: TRE.WORKORDER_FK_KEY IS NOT NULL And TRE.WORKORDER_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL() ) And
591: (MCR.WO_SEGMENT_REQUIRED <> 'Y' Or
592: TRE.SEGMENT_FK_KEY IS NOT NULL And TRE.SEGMENT_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL() ) And
593: (MCR.ITEM_REQUIRED <> 'Y' Or
594: TRE.ITEM_FK_KEY IS NOT NULL And TRE.ITEM_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL())))

Line 592: TRE.SEGMENT_FK_KEY IS NOT NULL And TRE.SEGMENT_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL() ) And

588: TRE.EQUIPMENT_STATUS = 'ACTIVE' And
589: (MCR.WO_REQUIRED <> 'Y' Or
590: TRE.WORKORDER_FK_KEY IS NOT NULL And TRE.WORKORDER_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL() ) And
591: (MCR.WO_SEGMENT_REQUIRED <> 'Y' Or
592: TRE.SEGMENT_FK_KEY IS NOT NULL And TRE.SEGMENT_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL() ) And
593: (MCR.ITEM_REQUIRED <> 'Y' Or
594: TRE.ITEM_FK_KEY IS NOT NULL And TRE.ITEM_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL())))
595: )
596: ;

Line 594: TRE.ITEM_FK_KEY IS NOT NULL And TRE.ITEM_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL())))

590: TRE.WORKORDER_FK_KEY IS NOT NULL And TRE.WORKORDER_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL() ) And
591: (MCR.WO_SEGMENT_REQUIRED <> 'Y' Or
592: TRE.SEGMENT_FK_KEY IS NOT NULL And TRE.SEGMENT_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL() ) And
593: (MCR.ITEM_REQUIRED <> 'Y' Or
594: TRE.ITEM_FK_KEY IS NOT NULL And TRE.ITEM_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL())))
595: )
596: ;
597: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_ERR from tag readings error table which have re_process_flag as Y- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
598:

Line 597: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_ERR from tag readings error table which have re_process_flag as Y- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

593: (MCR.ITEM_REQUIRED <> 'Y' Or
594: TRE.ITEM_FK_KEY IS NOT NULL And TRE.ITEM_FK_KEY <> MTH_UTIL_PKG.MTH_UA_GET_VAL())))
595: )
596: ;
597: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_ERR from tag readings error table which have re_process_flag as Y- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
598:
599: -- Deleting from tag readings error table all the records where re_process_flag is Y
600: DELETE
601: FROM

Line 605: mth_util_pkg.log_msg('Number of rows deleted from MTH_TAG_READINGS_ERR which have re_process_flag as Y- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

601: FROM
602: MTH_TAG_READINGS_ERR
603: WHERE RE_PROCESS_FLAG = 'Y' ;
604:
605: mth_util_pkg.log_msg('Number of rows deleted from MTH_TAG_READINGS_ERR which have re_process_flag as Y- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
606: v_ret_code:=0;
607: RETURN v_ret_code;
608: EXCEPTION
609: WHEN OTHERS THEN

Line 610: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);

606: v_ret_code:=0;
607: RETURN v_ret_code;
608: EXCEPTION
609: WHEN OTHERS THEN
610: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);
611: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
612: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
613: v_ret_code:=2;
614: RETURN v_ret_code;

Line 611: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);

607: RETURN v_ret_code;
608: EXCEPTION
609: WHEN OTHERS THEN
610: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);
611: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
612: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
613: v_ret_code:=2;
614: RETURN v_ret_code;
615: END MTH_READINGS_ERRORS_TO_STG;

Line 612: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);

608: EXCEPTION
609: WHEN OTHERS THEN
610: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);
611: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
612: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
613: v_ret_code:=2;
614: RETURN v_ret_code;
615: END MTH_READINGS_ERRORS_TO_STG;
616:

Line 684: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_ERR which has contextualization method other than 1,2 or 3 - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

680: STG.EQUIPMENT_FK_KEY = CM.EQUIPMENT_FK_KEY (+)
681: AND CM.CONTEXTUALIZE_METHOD NOT IN ( 1 , 2 , 3 )
682: )
683: ;
684: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_ERR which has contextualization method other than 1,2 or 3 - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
685:
686: -- Inserting records in tag readings error table for tag based contextualization missing/incorrect required context information
687: INSERT
688: INTO

Line 770: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )

766: TAG_DATA1.STATUS
767: FROM
768: ( SELECT
769: case when BUS_CONTEXT.WORKORDER is null
770: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )
771: else BUS_CONTEXT.WORKORDER || '-' || PLANTS.PLANT_PK
772: END WORKORDER_PK,
773: case when BUS_CONTEXT.ITEM is null
774: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )

Line 774: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )

770: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )
771: else BUS_CONTEXT.WORKORDER || '-' || PLANTS.PLANT_PK
772: END WORKORDER_PK,
773: case when BUS_CONTEXT.ITEM is null
774: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )
775: else BUS_CONTEXT.ITEM || '-' || PLANTS.PLANT_PK
776: END ITEM_PK,
777: case when (BUS_CONTEXT.SEGMENT1 is null or BUS_CONTEXT.WORKORDER is null)
778: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )

Line 778: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )

774: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )
775: else BUS_CONTEXT.ITEM || '-' || PLANTS.PLANT_PK
776: END ITEM_PK,
777: case when (BUS_CONTEXT.SEGMENT1 is null or BUS_CONTEXT.WORKORDER is null)
778: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )
779: else BUS_CONTEXT.SEGMENT1 || '-' || BUS_CONTEXT.WORKORDER || '-' || PLANTS.PLANT_PK
780: END SEGMENT_PK,
781: TAG_DATA.GROUP_ID,
782: TAG_DATA.READING_TIME,

Line 917: TO_CHAR(PROD_SCHD.WORKORDER_PK_KEY) =TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL())) Or

913: PROD_SCHD.WORKORDER_PK_KEY IS NULL Or
914: PROD_SEG.SEGMENT_PK_KEY IS NULL Or
915: ITEMS.ITEM_PK_KEY IS NULL Or
916: (MCR.WO_REQUIRED = 'Y' AND
917: TO_CHAR(PROD_SCHD.WORKORDER_PK_KEY) =TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL())) Or
918: (MCR.WO_SEGMENT_REQUIRED = 'Y' AND
919: TO_CHAR(PROD_SEG.SEGMENT_PK_KEY) = TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL())) Or
920: (MCR.ITEM_REQUIRED = 'Y' AND
921: TO_CHAR(ITEMS.ITEM_PK_KEY) = TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL()))

Line 919: TO_CHAR(PROD_SEG.SEGMENT_PK_KEY) = TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL())) Or

915: ITEMS.ITEM_PK_KEY IS NULL Or
916: (MCR.WO_REQUIRED = 'Y' AND
917: TO_CHAR(PROD_SCHD.WORKORDER_PK_KEY) =TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL())) Or
918: (MCR.WO_SEGMENT_REQUIRED = 'Y' AND
919: TO_CHAR(PROD_SEG.SEGMENT_PK_KEY) = TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL())) Or
920: (MCR.ITEM_REQUIRED = 'Y' AND
921: TO_CHAR(ITEMS.ITEM_PK_KEY) = TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL()))
922: )
923:

Line 921: TO_CHAR(ITEMS.ITEM_PK_KEY) = TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL()))

917: TO_CHAR(PROD_SCHD.WORKORDER_PK_KEY) =TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL())) Or
918: (MCR.WO_SEGMENT_REQUIRED = 'Y' AND
919: TO_CHAR(PROD_SEG.SEGMENT_PK_KEY) = TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL())) Or
920: (MCR.ITEM_REQUIRED = 'Y' AND
921: TO_CHAR(ITEMS.ITEM_PK_KEY) = TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL()))
922: )
923:
924: );
925: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_ERR for tag based contextualziation- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

Line 925: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_ERR for tag based contextualziation- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

921: TO_CHAR(ITEMS.ITEM_PK_KEY) = TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL()))
922: )
923:
924: );
925: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_ERR for tag based contextualziation- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
926:
927: ---
928:
929: INSERT

Line 981: MTH_UTIL_PKG.MTH_UA_GET_VAL(),

977: TAG_DATA1.HOUR_FK_KEY,
978: TAG_DATA1.PROCESSED_FLAG,
979: SYSDATE,
980: SYSDATE,
981: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
982: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
983: TAG_DATA1.PLANT_FK_KEY,
984: TAG_DATA1.USER_ATTR1,
985: TAG_DATA1.USER_ATTR2,

Line 982: MTH_UTIL_PKG.MTH_UA_GET_VAL(),

978: TAG_DATA1.PROCESSED_FLAG,
979: SYSDATE,
980: SYSDATE,
981: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
982: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
983: TAG_DATA1.PLANT_FK_KEY,
984: TAG_DATA1.USER_ATTR1,
985: TAG_DATA1.USER_ATTR2,
986: TAG_DATA1.USER_ATTR3,

Line 1000: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )

996: TAG_DATA1.RECIPE_VERSION
997: FROM
998: (SELECT
999: case when BUS_CONTEXT.WORKORDER is null
1000: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )
1001: else BUS_CONTEXT.WORKORDER || '-' || PLANTS.PLANT_PK
1002: END WORKORDER_PK,
1003: case when BUS_CONTEXT.ITEM is null
1004: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )

Line 1004: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )

1000: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )
1001: else BUS_CONTEXT.WORKORDER || '-' || PLANTS.PLANT_PK
1002: END WORKORDER_PK,
1003: case when BUS_CONTEXT.ITEM is null
1004: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )
1005: else BUS_CONTEXT.ITEM || '-' || PLANTS.PLANT_PK
1006: END ITEM_PK,
1007: case when (BUS_CONTEXT.SEGMENT1 is null or BUS_CONTEXT.WORKORDER is null)
1008: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )

Line 1008: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )

1004: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )
1005: else BUS_CONTEXT.ITEM || '-' || PLANTS.PLANT_PK
1006: END ITEM_PK,
1007: case when (BUS_CONTEXT.SEGMENT1 is null or BUS_CONTEXT.WORKORDER is null)
1008: then TO_CHAR( MTH_UTIL_PKG.MTH_UA_GET_VAL() )
1009: else BUS_CONTEXT.SEGMENT1 || '-' || BUS_CONTEXT.WORKORDER || '-' || PLANTS.PLANT_PK
1010: END SEGMENT_PK,
1011: TAG_DATA.GROUP_ID,
1012: TAG_DATA.READING_TIME,

Line 1141: TO_CHAR(PROD_SCHD.WORKORDER_PK_KEY) =TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL())) Or

1137: PROD_SCHD.WORKORDER_PK_KEY IS NULL Or
1138: PROD_SEG.SEGMENT_PK_KEY IS NULL Or
1139: ITEMS.ITEM_PK_KEY IS NULL Or
1140: (MCR.WO_REQUIRED = 'Y' AND
1141: TO_CHAR(PROD_SCHD.WORKORDER_PK_KEY) =TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL())) Or
1142: (MCR.WO_SEGMENT_REQUIRED = 'Y' AND
1143: TO_CHAR(PROD_SEG.SEGMENT_PK_KEY) = TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL())) Or
1144: (MCR.ITEM_REQUIRED = 'Y' AND
1145: TO_CHAR(ITEMS.ITEM_PK_KEY) = TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL()))

Line 1143: TO_CHAR(PROD_SEG.SEGMENT_PK_KEY) = TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL())) Or

1139: ITEMS.ITEM_PK_KEY IS NULL Or
1140: (MCR.WO_REQUIRED = 'Y' AND
1141: TO_CHAR(PROD_SCHD.WORKORDER_PK_KEY) =TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL())) Or
1142: (MCR.WO_SEGMENT_REQUIRED = 'Y' AND
1143: TO_CHAR(PROD_SEG.SEGMENT_PK_KEY) = TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL())) Or
1144: (MCR.ITEM_REQUIRED = 'Y' AND
1145: TO_CHAR(ITEMS.ITEM_PK_KEY) = TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL()))
1146: )
1147: )

Line 1145: TO_CHAR(ITEMS.ITEM_PK_KEY) = TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL()))

1141: TO_CHAR(PROD_SCHD.WORKORDER_PK_KEY) =TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL())) Or
1142: (MCR.WO_SEGMENT_REQUIRED = 'Y' AND
1143: TO_CHAR(PROD_SEG.SEGMENT_PK_KEY) = TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL())) Or
1144: (MCR.ITEM_REQUIRED = 'Y' AND
1145: TO_CHAR(ITEMS.ITEM_PK_KEY) = TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL()))
1146: )
1147: )
1148: ;
1149: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS for tag based contextualziation-- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

Line 1149: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS for tag based contextualziation-- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

1145: TO_CHAR(ITEMS.ITEM_PK_KEY) = TO_CHAR(MTH_UTIL_PKG.MTH_UA_GET_VAL()))
1146: )
1147: )
1148: ;
1149: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS for tag based contextualziation-- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
1150: v_ret_code:=0;
1151: RETURN v_ret_code;
1152: EXCEPTION
1153: WHEN OTHERS THEN

Line 1154: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);

1150: v_ret_code:=0;
1151: RETURN v_ret_code;
1152: EXCEPTION
1153: WHEN OTHERS THEN
1154: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);
1155: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
1156: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
1157: v_ret_code:=2;
1158: RETURN v_ret_code;

Line 1155: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);

1151: RETURN v_ret_code;
1152: EXCEPTION
1153: WHEN OTHERS THEN
1154: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);
1155: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
1156: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
1157: v_ret_code:=2;
1158: RETURN v_ret_code;
1159:

Line 1156: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);

1152: EXCEPTION
1153: WHEN OTHERS THEN
1154: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);
1155: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
1156: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
1157: v_ret_code:=2;
1158: RETURN v_ret_code;
1159:
1160:

Line 1271: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_ERR for schedule based contextualziation-- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

1267: AND EQUIPMENTS.STATUS IS NOT NULL
1268: AND EQUIPMENTS.STATUS = 'ACTIVE')))
1269: )
1270: ;
1271: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_ERR for schedule based contextualziation-- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
1272:
1273:
1274: ---
1275: INSERT

Line 1325: MTH_UTIL_PKG.MTH_UA_GET_VAL(),

1321: HOURS.HOUR_PK_KEY,
1322: NVL(STG.PROCESSED_FLAG , 0),
1323: SYSDATE,
1324: SYSDATE,
1325: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
1326: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
1327: STG.PLANT_FK_KEY,
1328: STG.USER_ATTR1,
1329: STG.USER_ATTR2,

Line 1326: MTH_UTIL_PKG.MTH_UA_GET_VAL(),

1322: NVL(STG.PROCESSED_FLAG , 0),
1323: SYSDATE,
1324: SYSDATE,
1325: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
1326: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
1327: STG.PLANT_FK_KEY,
1328: STG.USER_ATTR1,
1329: STG.USER_ATTR2,
1330: STG.USER_ATTR3,

Line 1373: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS for schedule based contextualziation- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

1369: AND EQUIPMENTS.STATUS IS NOT NULL
1370: AND EQUIPMENTS.STATUS = 'ACTIVE'
1371: )
1372: ;
1373: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS for schedule based contextualziation- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
1374: v_ret_code:=0;
1375: RETURN v_ret_code;
1376: EXCEPTION
1377: WHEN OTHERS THEN

Line 1378: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);

1374: v_ret_code:=0;
1375: RETURN v_ret_code;
1376: EXCEPTION
1377: WHEN OTHERS THEN
1378: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);
1379: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
1380: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
1381: v_ret_code:=2;
1382: RETURN v_ret_code;

Line 1379: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);

1375: RETURN v_ret_code;
1376: EXCEPTION
1377: WHEN OTHERS THEN
1378: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);
1379: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
1380: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
1381: v_ret_code:=2;
1382: RETURN v_ret_code;
1383:

Line 1380: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);

1376: EXCEPTION
1377: WHEN OTHERS THEN
1378: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);
1379: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
1380: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
1381: v_ret_code:=2;
1382: RETURN v_ret_code;
1383:
1384:

Line 1439: MTH_UTIL_PKG.MTH_UA_GET_VAL(),

1435: STG.MTH_ENTITY,
1436: STG.ATTRIBUTE_GROUP,
1437: STG.ATTRIBUTE,
1438: STG.EQUIPMENT_FK_KEY,
1439: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
1440: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
1441: EQP_SHIFTS.SHIFT_WORKDAY_FK_KEY,
1442: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
1443: HOURS.HOUR_PK_KEY,

Line 1440: MTH_UTIL_PKG.MTH_UA_GET_VAL(),

1436: STG.ATTRIBUTE_GROUP,
1437: STG.ATTRIBUTE,
1438: STG.EQUIPMENT_FK_KEY,
1439: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
1440: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
1441: EQP_SHIFTS.SHIFT_WORKDAY_FK_KEY,
1442: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
1443: HOURS.HOUR_PK_KEY,
1444: NVL(STG.PROCESSED_FLAG , 0),

Line 1442: MTH_UTIL_PKG.MTH_UA_GET_VAL(),

1438: STG.EQUIPMENT_FK_KEY,
1439: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
1440: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
1441: EQP_SHIFTS.SHIFT_WORKDAY_FK_KEY,
1442: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
1443: HOURS.HOUR_PK_KEY,
1444: NVL(STG.PROCESSED_FLAG , 0),
1445: SYSDATE,
1446: SYSDATE,

Line 1447: MTH_UTIL_PKG.MTH_UA_GET_VAL(),

1443: HOURS.HOUR_PK_KEY,
1444: NVL(STG.PROCESSED_FLAG , 0),
1445: SYSDATE,
1446: SYSDATE,
1447: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
1448: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
1449: STG.PLANT_FK_KEY,
1450: STG.USER_ATTR1,
1451: STG.USER_ATTR2,

Line 1448: MTH_UTIL_PKG.MTH_UA_GET_VAL(),

1444: NVL(STG.PROCESSED_FLAG , 0),
1445: SYSDATE,
1446: SYSDATE,
1447: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
1448: MTH_UTIL_PKG.MTH_UA_GET_VAL(),
1449: STG.PLANT_FK_KEY,
1450: STG.USER_ATTR1,
1451: STG.USER_ATTR2,
1452: STG.USER_ATTR3,

Line 1486: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS for manual based contextualziation- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

1482: OR EQUIPMENTS.STATUS IS NULL
1483: OR EQUIPMENTS.STATUS <> 'ACTIVE')))
1484: )
1485: ;
1486: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS for manual based contextualziation- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
1487:
1488: -----
1489: INSERT
1490: INTO MTH_TAG_READINGS_ERR

Line 1566: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_ERR for manual based contextualziation- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

1562: OR EQUIPMENTS.STATUS IS NULL
1563: OR EQUIPMENTS.STATUS <> 'ACTIVE')
1564: )
1565: ;
1566: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_ERR for manual based contextualziation- ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
1567: v_ret_code:=0;
1568: RETURN v_ret_code;
1569: EXCEPTION
1570: WHEN OTHERS THEN

Line 1571: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);

1567: v_ret_code:=0;
1568: RETURN v_ret_code;
1569: EXCEPTION
1570: WHEN OTHERS THEN
1571: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);
1572: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
1573: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
1574: v_ret_code:=2;
1575: RETURN v_ret_code;

Line 1572: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);

1568: RETURN v_ret_code;
1569: EXCEPTION
1570: WHEN OTHERS THEN
1571: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);
1572: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
1573: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
1574: v_ret_code:=2;
1575: RETURN v_ret_code;
1576:

Line 1573: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);

1569: EXCEPTION
1570: WHEN OTHERS THEN
1571: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_READINGS', mth_util_pkg.G_DBG_EXCEPTION);
1572: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
1573: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
1574: v_ret_code:=2;
1575: RETURN v_ret_code;
1576:
1577:

Line 1665: mth_util_pkg.log_msg('Exception OTHERS in INIT_READINGS_FROM_RAW', mth_util_pkg.G_DBG_EXCEPTION);

1661: p_ret_code := 0;
1662:
1663: EXCEPTION
1664: WHEN OTHERS THEN
1665: mth_util_pkg.log_msg('Exception OTHERS in INIT_READINGS_FROM_RAW', mth_util_pkg.G_DBG_EXCEPTION);
1666: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
1667: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
1668: p_ret_code := 2;
1669:

Line 1666: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);

1662:
1663: EXCEPTION
1664: WHEN OTHERS THEN
1665: mth_util_pkg.log_msg('Exception OTHERS in INIT_READINGS_FROM_RAW', mth_util_pkg.G_DBG_EXCEPTION);
1666: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
1667: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
1668: p_ret_code := 2;
1669:
1670:

Line 1667: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);

1663: EXCEPTION
1664: WHEN OTHERS THEN
1665: mth_util_pkg.log_msg('Exception OTHERS in INIT_READINGS_FROM_RAW', mth_util_pkg.G_DBG_EXCEPTION);
1666: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
1667: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
1668: p_ret_code := 2;
1669:
1670:
1671:

Line 1710: v_previous_tag_reading_data := MTH_UTIL_PKG.get_prev_tag_reading(r_readings.TAG_CODE,r_readings.READING_TIME);

1706: loop
1707: fetch c_readings into r_readings ;
1708: exit when c_readings%NOTFOUND ;
1709: IF (r_readings.PREV_STATUS IS NULL) THEN
1710: v_previous_tag_reading_data := MTH_UTIL_PKG.get_prev_tag_reading(r_readings.TAG_CODE,r_readings.READING_TIME);
1711: IF (v_previous_tag_reading_data <>'3' OR v_previous_tag_reading_data IS NULL) THEN
1712: MTH_EVENT_PKG.HANDLE_EVENT (r_readings.equipment_fk_key,'DOWN',NULL,NULL,r_readings.READING_TIME,NULL,TO_NUMBER(r_readings.tag_data),'Equipment is Down');
1713: END IF;
1714: ELSE

Line 1788: MTH_UTIL_PKG.get_upper_lower_limits(r_readings.EQUIPMENT_FK_KEY,r_readings.ATTR_NAME,'SPECIFICATIONS','LLIMIT','ULIMIT',v_lower_limit,v_upper_limit);

1784: loop
1785: fetch c_readings into r_readings ;
1786: exit when c_readings%NOTFOUND ;
1787:
1788: MTH_UTIL_PKG.get_upper_lower_limits(r_readings.EQUIPMENT_FK_KEY,r_readings.ATTR_NAME,'SPECIFICATIONS','LLIMIT','ULIMIT',v_lower_limit,v_upper_limit);
1789: MTH_UTIL_PKG.get_prev_tag_reading_info(r_readings.TAG_CODE,r_readings.READING_TIME,NULL,v_previous_tag_data,v_pre_reading_time,v_pre_eqp_avail);
1790:
1791: IF((TO_NUMBER(r_readings.TAG_DATA) < v_lower_limit AND (TO_NUMBER(v_previous_tag_data) >= v_lower_limit OR v_previous_tag_data IS NULL))
1792: OR (TO_NUMBER(r_readings.TAG_DATA) > v_upper_limit AND ( v_previous_tag_data <= v_upper_limit OR v_previous_tag_data IS NULL)))THEN

Line 1789: MTH_UTIL_PKG.get_prev_tag_reading_info(r_readings.TAG_CODE,r_readings.READING_TIME,NULL,v_previous_tag_data,v_pre_reading_time,v_pre_eqp_avail);

1785: fetch c_readings into r_readings ;
1786: exit when c_readings%NOTFOUND ;
1787:
1788: MTH_UTIL_PKG.get_upper_lower_limits(r_readings.EQUIPMENT_FK_KEY,r_readings.ATTR_NAME,'SPECIFICATIONS','LLIMIT','ULIMIT',v_lower_limit,v_upper_limit);
1789: MTH_UTIL_PKG.get_prev_tag_reading_info(r_readings.TAG_CODE,r_readings.READING_TIME,NULL,v_previous_tag_data,v_pre_reading_time,v_pre_eqp_avail);
1790:
1791: IF((TO_NUMBER(r_readings.TAG_DATA) < v_lower_limit AND (TO_NUMBER(v_previous_tag_data) >= v_lower_limit OR v_previous_tag_data IS NULL))
1792: OR (TO_NUMBER(r_readings.TAG_DATA) > v_upper_limit AND ( v_previous_tag_data <= v_upper_limit OR v_previous_tag_data IS NULL)))THEN
1793: MTH_EVENT_PKG.HANDLE_EVENT (r_readings.equipment_fk_key,'OUT_CTL',NULL,NULL,r_readings.READING_TIME,NULL,TO_NUMBER(r_readings.tag_data),CASE WHEN TO_NUMBER( r_readings.TAG_DATA ) > v_upper_limit THEN

Line 1871: v_verify_tag_data_trend := MTH_UTIL_PKG.verify_tag_data_trend(r_readings.TAG_CODE,r_readings.TAG_DATA,r_readings.READING_TIME,'SPECIFICATIONS','MEAN',v_ctl_limit_threshold,NULL);

1867: open c_readings;
1868: loop
1869: fetch c_readings into r_readings ;
1870: exit when c_readings%NOTFOUND ;
1871: v_verify_tag_data_trend := MTH_UTIL_PKG.verify_tag_data_trend(r_readings.TAG_CODE,r_readings.TAG_DATA,r_readings.READING_TIME,'SPECIFICATIONS','MEAN',v_ctl_limit_threshold,NULL);
1872: IF(v_verify_tag_data_trend >0)THEN
1873: MTH_EVENT_PKG.HANDLE_EVENT (r_readings.equipment_fk_key,'CTL_WG',NULL,NULL,r_readings.READING_TIME,NULL,TO_NUMBER(r_readings.tag_data),CASE WHEN v_verify_tag_data_trend = 1 THEN
1874: v_ctl_limit_threshold || ' consecutive values of Equipment Parameter value for ' ||
1875: r_readings.attribute|| ' parameter is above mean value'

Line 1965: MTH_UTIL_PKG.get_prev_tag_reading_set(r_readings.TAG_CODE1,r_readings.READING_TIME1,r_readings.TAG_CODE2,r_readings.READING_TIME2,NULL,p_pre_tag_data1,p_pre_tag_data2);

1961: loop
1962: fetch c_readings into r_readings ;
1963: exit when c_readings%NOTFOUND ;
1964: IF ((v_previous_tag_code1 IS NULL AND v_previous_tag_data1 IS NULL) AND (v_previous_tag_code2 IS NULL AND v_previous_tag_data2 IS NULL)AND (r_readings.TAG_DATA1> v_unstab_threshold1 AND r_readings.TAG_DATA2> v_unstab_threshold2 ) ) THEN
1965: MTH_UTIL_PKG.get_prev_tag_reading_set(r_readings.TAG_CODE1,r_readings.READING_TIME1,r_readings.TAG_CODE2,r_readings.READING_TIME2,NULL,p_pre_tag_data1,p_pre_tag_data2);
1966: IF( ((p_pre_tag_data1 <= v_unstab_threshold1 AND p_pre_tag_data2 <=v_unstab_threshold2) OR (p_pre_tag_data1 IS NULL AND p_pre_tag_data2 IS NULL)) AND(r_readings.TAG_DATA1> v_unstab_threshold1 AND r_readings.TAG_DATA2> v_unstab_threshold2 ))THEN
1967: MTH_EVENT_PKG.HANDLE_EVENT (r_readings.equipment_fk_key,'UNSTAB',NULL,NULL,CASE WHEN r_readings.READING_TIME1 >= r_readings.READING_TIME2
1968: THEN r_readings.READING_TIME1 ELSE r_readings.READING_TIME2 END, NULL,NULL,'Equipment is unstable due to combination of parameter readings beyond limits, ' ||
1969: r_readings.TAG_CODE1 || ' = ' || r_readings.TAG_DATA1 || ' ' ||

Line 2017: v_previous_tag_reading_data := MTH_UTIL_PKG.get_prev_tag_reading(r_readings.TAG_CODE,r_readings.READING_TIME);

2013: loop
2014: fetch c_readings into r_readings ;
2015: exit when c_readings%NOTFOUND ;
2016: IF (r_readings.PREV_TAG_DATA IS NULL) THEN
2017: v_previous_tag_reading_data := MTH_UTIL_PKG.get_prev_tag_reading(r_readings.TAG_CODE,r_readings.READING_TIME);
2018: IF (v_previous_tag_reading_data <> v_EQP_FAULT_THRESHOLD OR v_previous_tag_reading_data IS NULL) THEN
2019: MTH_EVENT_PKG.HANDLE_EVENT (r_readings.equipment_fk_key,'FAULT',NULL,NULL,r_readings.READING_TIME,NULL,TO_NUMBER(r_readings.tag_data),'Equipment fault. ' || r_readings.TAG_CODE || ' = ' || r_readings.TAG_DATA);
2020: END IF;
2021: ELSE

Line 2098: v_previous_tag_reading_data := MTH_UTIL_PKG.get_prev_tag_reading(r_readings.TAG_CODE,r_readings.READING_TIME);

2094: loop
2095: fetch c_readings into r_readings ;
2096: exit when c_readings%NOTFOUND ;
2097: IF (r_readings.TAG_DATA >= v_recal_threshold)THEN
2098: v_previous_tag_reading_data := MTH_UTIL_PKG.get_prev_tag_reading(r_readings.TAG_CODE,r_readings.READING_TIME);
2099: IF (v_previous_tag_reading_data < v_recal_threshold OR v_previous_tag_reading_data IS NULL ) THEN
2100: MTH_EVENT_PKG.HANDLE_EVENT (r_readings.equipment_fk_key,'RECAL',NULL,NULL,r_readings.READING_TIME,NULL,TO_NUMBER(r_readings.tag_data),'Equipment ready for recalibration. ' || r_readings.TAG_CODE ||
2101: ' = ' || r_readings.TAG_DATA);
2102: END IF;

Line 2143: mth_util_pkg.log_msg('Exception while calling custom hook - ' || v_desc1, mth_util_pkg.G_DBG_EXCEPTION);

2139: EXECUTE IMMEDIATE l_sql_stmt1;
2140: END IF;
2141: EXCEPTION
2142: WHEN OTHERS THEN
2143: mth_util_pkg.log_msg('Exception while calling custom hook - ' || v_desc1, mth_util_pkg.G_DBG_EXCEPTION);
2144: END;
2145: END IF;
2146:
2147: END MTH_GEN_HDL_EVENTS_READINGS;

Line 2179: mth_util_pkg.log_msg('INIT_READINGS_FROM_RAW start', mth_util_pkg.G_DBG_PROC_FUN_START);

2175: v_count number;
2176:
2177:
2178: BEGIN
2179: mth_util_pkg.log_msg('INIT_READINGS_FROM_RAW start', mth_util_pkg.G_DBG_PROC_FUN_START);
2180:
2181: -- Initialize default parameters
2182: v_log_date := sysdate;
2183: v_unassigned_val := MTH_UTIL_PKG.MTH_UA_GET_VAL;

Line 2183: v_unassigned_val := MTH_UTIL_PKG.MTH_UA_GET_VAL;

2179: mth_util_pkg.log_msg('INIT_READINGS_FROM_RAW start', mth_util_pkg.G_DBG_PROC_FUN_START);
2180:
2181: -- Initialize default parameters
2182: v_log_date := sysdate;
2183: v_unassigned_val := MTH_UTIL_PKG.MTH_UA_GET_VAL;
2184:
2185: mth_util_pkg.switch_column_default_value ( 'MTH_TAG_READINGS_RAW', v_current_processing_flag);
2186: SELECT Count(*) INTO v_reprocess_flag FROM MTH_TAG_READINGS_ERR WHERE RE_PROCESS_FLAG='Y';
2187:

Line 2185: mth_util_pkg.switch_column_default_value ( 'MTH_TAG_READINGS_RAW', v_current_processing_flag);

2181: -- Initialize default parameters
2182: v_log_date := sysdate;
2183: v_unassigned_val := MTH_UTIL_PKG.MTH_UA_GET_VAL;
2184:
2185: mth_util_pkg.switch_column_default_value ( 'MTH_TAG_READINGS_RAW', v_current_processing_flag);
2186: SELECT Count(*) INTO v_reprocess_flag FROM MTH_TAG_READINGS_ERR WHERE RE_PROCESS_FLAG='Y';
2187:
2188: --delete all the tables
2189: DELETE FROM MTH_TAG_READINGS_LATEST;

Line 2190: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINSG_LATEST - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

2186: SELECT Count(*) INTO v_reprocess_flag FROM MTH_TAG_READINGS_ERR WHERE RE_PROCESS_FLAG='Y';
2187:
2188: --delete all the tables
2189: DELETE FROM MTH_TAG_READINGS_LATEST;
2190: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINSG_LATEST - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2191:
2192: DELETE FROM MTH_TAG_READINGS_UNPROCESS_ERR;
2193: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_UNPROCESS_ERR - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2194:

Line 2193: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_UNPROCESS_ERR - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

2189: DELETE FROM MTH_TAG_READINGS_LATEST;
2190: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINSG_LATEST - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2191:
2192: DELETE FROM MTH_TAG_READINGS_UNPROCESS_ERR;
2193: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_UNPROCESS_ERR - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2194:
2195: DELETE FROM MTH_TAG_READINGS_RAW_ERR;
2196: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_RAW_ERR - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2197:

Line 2196: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_RAW_ERR - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

2192: DELETE FROM MTH_TAG_READINGS_UNPROCESS_ERR;
2193: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_UNPROCESS_ERR - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2194:
2195: DELETE FROM MTH_TAG_READINGS_RAW_ERR;
2196: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_RAW_ERR - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2197:
2198: DELETE FROM MTH_TAG_READINGS_RAW_PROCESSED;
2199: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_RAW_PROCESSED - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2200:

Line 2199: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_RAW_PROCESSED - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

2195: DELETE FROM MTH_TAG_READINGS_RAW_ERR;
2196: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_RAW_ERR - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2197:
2198: DELETE FROM MTH_TAG_READINGS_RAW_PROCESSED;
2199: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_RAW_PROCESSED - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2200:
2201: DELETE FROM MTH_TAG_READINGS;
2202: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2203:

Line 2202: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

2198: DELETE FROM MTH_TAG_READINGS_RAW_PROCESSED;
2199: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_RAW_PROCESSED - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2200:
2201: DELETE FROM MTH_TAG_READINGS;
2202: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2203:
2204: DELETE FROM MTH_TAG_READINGS_STG_ERR;
2205: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_STG_ERR - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2206:

Line 2205: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_STG_ERR - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

2201: DELETE FROM MTH_TAG_READINGS;
2202: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2203:
2204: DELETE FROM MTH_TAG_READINGS_STG_ERR;
2205: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_STG_ERR - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2206:
2207: DELETE FROM MTH_TAG_READINGS_ERR;
2208: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_ERR - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2209:

Line 2208: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_ERR - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

2204: DELETE FROM MTH_TAG_READINGS_STG_ERR;
2205: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_STG_ERR - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2206:
2207: DELETE FROM MTH_TAG_READINGS_ERR;
2208: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_ERR - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2209:
2210: DELETE FROM MTH_EVENTS;
2211: mth_util_pkg.log_msg('Number of rows deleted in MTH_EVENTS - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2212:

Line 2211: mth_util_pkg.log_msg('Number of rows deleted in MTH_EVENTS - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

2207: DELETE FROM MTH_TAG_READINGS_ERR;
2208: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_ERR - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2209:
2210: DELETE FROM MTH_EVENTS;
2211: mth_util_pkg.log_msg('Number of rows deleted in MTH_EVENTS - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2212:
2213: DELETE FROM MTH_EVENT_ACTIONS;
2214: mth_util_pkg.log_msg('Number of rows deleted in MTH_EVENT_ACTIONS - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2215:

Line 2214: mth_util_pkg.log_msg('Number of rows deleted in MTH_EVENT_ACTIONS - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

2210: DELETE FROM MTH_EVENTS;
2211: mth_util_pkg.log_msg('Number of rows deleted in MTH_EVENTS - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2212:
2213: DELETE FROM MTH_EVENT_ACTIONS;
2214: mth_util_pkg.log_msg('Number of rows deleted in MTH_EVENT_ACTIONS - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2215:
2216:
2217: IF (v_current_processing_flag=1 OR v_current_processing_flag=2 OR v_reprocess_flag>0 ) THEN
2218:

Line 2219: mth_util_pkg.mth_load_tag_raw_to_processed(v_current_processing_flag, p_from_tz , p_to_tz); --commit to be removed from procedure

2215:
2216:
2217: IF (v_current_processing_flag=1 OR v_current_processing_flag=2 OR v_reprocess_flag>0 ) THEN
2218:
2219: mth_util_pkg.mth_load_tag_raw_to_processed(v_current_processing_flag, p_from_tz , p_to_tz); --commit to be removed from procedure
2220:
2221: p_ret_code := MTH_LOAD_TAG_READINGS_PKG.MTH_TRANSFORM_TAG_DATA_TO_STG();
2222:
2223: IF (p_ret_code <> 2) THEN

Line 2251: mth_util_pkg.log_msg('Exception while calling custom hook - ' || v_desc, mth_util_pkg.G_DBG_EXCEPTION);

2247: WHEN NO_DATA_FOUND THEN
2248: p_ret_code := 0;
2249:
2250: WHEN OTHERS THEN
2251: mth_util_pkg.log_msg('Exception while calling custom hook - ' || v_desc, mth_util_pkg.G_DBG_EXCEPTION);
2252: p_ret_code := 2;
2253: END;
2254: ELSE
2255: p_ret_code := 0;

Line 2265: mth_util_pkg.log_msg('MTH_READINGS_ERRORS_TO_STG completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);

2261: DELETE FROM MTH_TAG_READINGS_RAW_PROCESSED;
2262: MTH_GEN_HDL_EVENTS_READINGS();
2263: p_ret_code := MTH_LOAD_TAG_READINGS_PKG.MTH_READINGS_ERRORS_TO_STG();
2264: IF(p_ret_code <> 2) THEN
2265: mth_util_pkg.log_msg('MTH_READINGS_ERRORS_TO_STG completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2266: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_TAG_BASED_CONTEXTUALIZE();
2267: IF(p_ret_code <> 2) THEN
2268: mth_util_pkg.log_msg('MTH_TAG_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2269: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_SCHD_BASED_CONTEXTUALIZE();

Line 2268: mth_util_pkg.log_msg('MTH_TAG_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);

2264: IF(p_ret_code <> 2) THEN
2265: mth_util_pkg.log_msg('MTH_READINGS_ERRORS_TO_STG completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2266: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_TAG_BASED_CONTEXTUALIZE();
2267: IF(p_ret_code <> 2) THEN
2268: mth_util_pkg.log_msg('MTH_TAG_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2269: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_SCHD_BASED_CONTEXTUALIZE();
2270: IF(p_ret_code <> 2) THEN
2271: mth_util_pkg.log_msg('MTH_SCHD_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2272: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_MANUAL_BASED_CONTEXTUALIZE();

Line 2271: mth_util_pkg.log_msg('MTH_SCHD_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);

2267: IF(p_ret_code <> 2) THEN
2268: mth_util_pkg.log_msg('MTH_TAG_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2269: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_SCHD_BASED_CONTEXTUALIZE();
2270: IF(p_ret_code <> 2) THEN
2271: mth_util_pkg.log_msg('MTH_SCHD_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2272: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_MANUAL_BASED_CONTEXTUALIZE();
2273: IF(p_ret_code <> 2) THEN
2274: mth_util_pkg.log_msg('MTH_MANUAL_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2275: DELETE FROM MTH_TAG_READINGS_STG;

Line 2274: mth_util_pkg.log_msg('MTH_MANUAL_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);

2270: IF(p_ret_code <> 2) THEN
2271: mth_util_pkg.log_msg('MTH_SCHD_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2272: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_MANUAL_BASED_CONTEXTUALIZE();
2273: IF(p_ret_code <> 2) THEN
2274: mth_util_pkg.log_msg('MTH_MANUAL_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2275: DELETE FROM MTH_TAG_READINGS_STG;
2276: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_STG - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2277: IF(v_current_processing_flag=1 OR v_current_processing_flag=2 ) THEN
2278: mth_util_pkg.truncate_table_partition('MTH_TAG_READINGS_RAW' ,v_current_processing_flag);

Line 2276: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_STG - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

2272: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_MANUAL_BASED_CONTEXTUALIZE();
2273: IF(p_ret_code <> 2) THEN
2274: mth_util_pkg.log_msg('MTH_MANUAL_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2275: DELETE FROM MTH_TAG_READINGS_STG;
2276: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_STG - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2277: IF(v_current_processing_flag=1 OR v_current_processing_flag=2 ) THEN
2278: mth_util_pkg.truncate_table_partition('MTH_TAG_READINGS_RAW' ,v_current_processing_flag);
2279: END IF;
2280: COMMIT;

Line 2278: mth_util_pkg.truncate_table_partition('MTH_TAG_READINGS_RAW' ,v_current_processing_flag);

2274: mth_util_pkg.log_msg('MTH_MANUAL_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2275: DELETE FROM MTH_TAG_READINGS_STG;
2276: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_STG - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2277: IF(v_current_processing_flag=1 OR v_current_processing_flag=2 ) THEN
2278: mth_util_pkg.truncate_table_partition('MTH_TAG_READINGS_RAW' ,v_current_processing_flag);
2279: END IF;
2280: COMMIT;
2281: END IF;
2282: END IF;

Line 2288: mth_util_pkg.switch_column_default_value ( 'MTH_TAG_READINGS_RAW', v_current_processing_flag);

2284: END IF;
2285:
2286: IF(p_ret_code = 2) THEN
2287: ROLLBACK;
2288: mth_util_pkg.switch_column_default_value ( 'MTH_TAG_READINGS_RAW', v_current_processing_flag);
2289: UPDATE MTH_TAG_READINGS_RAW
2290: SET processing_flag = Decode(v_current_processing_flag,1,2,1)
2291: WHERE processing_flag = v_current_processing_flag;
2292: END IF;

Line 2298: mth_util_pkg.log_msg('INIT_READINGS_FROM_RAW end', mth_util_pkg.G_DBG_PROC_FUN_END);

2294: END IF;
2295: END IF;
2296: END IF;
2297:
2298: mth_util_pkg.log_msg('INIT_READINGS_FROM_RAW end', mth_util_pkg.G_DBG_PROC_FUN_END);
2299:
2300:
2301: EXCEPTION
2302: WHEN OTHERS THEN

Line 2303: mth_util_pkg.log_msg('Exception OTHERS in INIT_READINGS_FROM_RAW', mth_util_pkg.G_DBG_EXCEPTION);

2299:
2300:
2301: EXCEPTION
2302: WHEN OTHERS THEN
2303: mth_util_pkg.log_msg('Exception OTHERS in INIT_READINGS_FROM_RAW', mth_util_pkg.G_DBG_EXCEPTION);
2304: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
2305: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
2306: p_ret_code := 2;
2307: ROLLBACK;

Line 2304: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);

2300:
2301: EXCEPTION
2302: WHEN OTHERS THEN
2303: mth_util_pkg.log_msg('Exception OTHERS in INIT_READINGS_FROM_RAW', mth_util_pkg.G_DBG_EXCEPTION);
2304: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
2305: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
2306: p_ret_code := 2;
2307: ROLLBACK;
2308:

Line 2305: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);

2301: EXCEPTION
2302: WHEN OTHERS THEN
2303: mth_util_pkg.log_msg('Exception OTHERS in INIT_READINGS_FROM_RAW', mth_util_pkg.G_DBG_EXCEPTION);
2304: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
2305: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
2306: p_ret_code := 2;
2307: ROLLBACK;
2308:
2309: END INIT_READINGS_FROM_RAW;

Line 2335: mth_util_pkg.log_msg('INCR_READINGS_FROM_RAW start', mth_util_pkg.G_DBG_PROC_FUN_START);

2331: v_count number;
2332:
2333:
2334: BEGIN
2335: mth_util_pkg.log_msg('INCR_READINGS_FROM_RAW start', mth_util_pkg.G_DBG_PROC_FUN_START);
2336:
2337: -- Initialize default parameters
2338: v_log_date := sysdate;
2339: v_unassigned_val := MTH_UTIL_PKG.MTH_UA_GET_VAL;

Line 2339: v_unassigned_val := MTH_UTIL_PKG.MTH_UA_GET_VAL;

2335: mth_util_pkg.log_msg('INCR_READINGS_FROM_RAW start', mth_util_pkg.G_DBG_PROC_FUN_START);
2336:
2337: -- Initialize default parameters
2338: v_log_date := sysdate;
2339: v_unassigned_val := MTH_UTIL_PKG.MTH_UA_GET_VAL;
2340:
2341: mth_util_pkg.switch_column_default_value ( 'MTH_TAG_READINGS_RAW', v_current_processing_flag);
2342: SELECT Count(*) INTO v_reprocess_flag FROM MTH_TAG_READINGS_ERR WHERE RE_PROCESS_FLAG='Y';
2343:

Line 2341: mth_util_pkg.switch_column_default_value ( 'MTH_TAG_READINGS_RAW', v_current_processing_flag);

2337: -- Initialize default parameters
2338: v_log_date := sysdate;
2339: v_unassigned_val := MTH_UTIL_PKG.MTH_UA_GET_VAL;
2340:
2341: mth_util_pkg.switch_column_default_value ( 'MTH_TAG_READINGS_RAW', v_current_processing_flag);
2342: SELECT Count(*) INTO v_reprocess_flag FROM MTH_TAG_READINGS_ERR WHERE RE_PROCESS_FLAG='Y';
2343:
2344: IF(v_current_processing_flag=1 OR v_current_processing_flag=2 OR v_reprocess_flag>0 ) THEN
2345: mth_util_pkg.mth_load_tag_raw_to_processed(v_current_processing_flag, p_from_tz , p_to_tz );

Line 2345: mth_util_pkg.mth_load_tag_raw_to_processed(v_current_processing_flag, p_from_tz , p_to_tz );

2341: mth_util_pkg.switch_column_default_value ( 'MTH_TAG_READINGS_RAW', v_current_processing_flag);
2342: SELECT Count(*) INTO v_reprocess_flag FROM MTH_TAG_READINGS_ERR WHERE RE_PROCESS_FLAG='Y';
2343:
2344: IF(v_current_processing_flag=1 OR v_current_processing_flag=2 OR v_reprocess_flag>0 ) THEN
2345: mth_util_pkg.mth_load_tag_raw_to_processed(v_current_processing_flag, p_from_tz , p_to_tz );
2346: p_ret_code := MTH_LOAD_TAG_READINGS_PKG.MTH_TRANSFORM_TAG_DATA_TO_STG();
2347: IF(p_ret_code <> 2)
2348: THEN
2349: -- Dbms_Output.put_line('p_ret_code1' || p_ret_code);

Line 2385: mth_util_pkg.log_msg('Exception while calling custom hook - ' || v_desc, mth_util_pkg.G_DBG_EXCEPTION);

2381:
2382: WHEN OTHERS THEN
2383: -- Dbms_Output.put_line('p_ret_code5' || p_ret_code);
2384:
2385: mth_util_pkg.log_msg('Exception while calling custom hook - ' || v_desc, mth_util_pkg.G_DBG_EXCEPTION);
2386: p_ret_code := 2;
2387: END;
2388: ELSE
2389: p_ret_code := 0;

Line 2400: mth_util_pkg.log_msg('MTH_READINGS_ERRORS_TO_STG completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);

2396: DELETE FROM MTH_TAG_READINGS_RAW_PROCESSED;
2397: MTH_GEN_HDL_EVENTS_READINGS();
2398: p_ret_code := MTH_LOAD_TAG_READINGS_PKG.MTH_READINGS_ERRORS_TO_STG();
2399: IF(p_ret_code <> 2) THEN
2400: mth_util_pkg.log_msg('MTH_READINGS_ERRORS_TO_STG completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2401: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_TAG_BASED_CONTEXTUALIZE();
2402: IF(p_ret_code <> 2) THEN
2403: mth_util_pkg.log_msg('MTH_TAG_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2404: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_SCHD_BASED_CONTEXTUALIZE();

Line 2403: mth_util_pkg.log_msg('MTH_TAG_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);

2399: IF(p_ret_code <> 2) THEN
2400: mth_util_pkg.log_msg('MTH_READINGS_ERRORS_TO_STG completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2401: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_TAG_BASED_CONTEXTUALIZE();
2402: IF(p_ret_code <> 2) THEN
2403: mth_util_pkg.log_msg('MTH_TAG_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2404: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_SCHD_BASED_CONTEXTUALIZE();
2405: IF(p_ret_code <> 2) THEN
2406: mth_util_pkg.log_msg('MTH_SCHD_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2407: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_MANUAL_BASED_CONTEXTUALIZE();

Line 2406: mth_util_pkg.log_msg('MTH_SCHD_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);

2402: IF(p_ret_code <> 2) THEN
2403: mth_util_pkg.log_msg('MTH_TAG_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2404: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_SCHD_BASED_CONTEXTUALIZE();
2405: IF(p_ret_code <> 2) THEN
2406: mth_util_pkg.log_msg('MTH_SCHD_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2407: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_MANUAL_BASED_CONTEXTUALIZE();
2408: IF(p_ret_code <> 2) THEN
2409: mth_util_pkg.log_msg('MTH_MANUAL_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2410: DELETE FROM MTH_TAG_READINGS_STG;

Line 2409: mth_util_pkg.log_msg('MTH_MANUAL_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);

2405: IF(p_ret_code <> 2) THEN
2406: mth_util_pkg.log_msg('MTH_SCHD_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2407: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_MANUAL_BASED_CONTEXTUALIZE();
2408: IF(p_ret_code <> 2) THEN
2409: mth_util_pkg.log_msg('MTH_MANUAL_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2410: DELETE FROM MTH_TAG_READINGS_STG;
2411: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_STG - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2412: IF(v_current_processing_flag=1 OR v_current_processing_flag=2 ) THEN
2413:

Line 2411: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_STG - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

2407: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_MANUAL_BASED_CONTEXTUALIZE();
2408: IF(p_ret_code <> 2) THEN
2409: mth_util_pkg.log_msg('MTH_MANUAL_BASED_CONTEXTUALIZE completeled succesfully', mth_util_pkg.G_DBG_PROC_FUN_END);
2410: DELETE FROM MTH_TAG_READINGS_STG;
2411: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_STG - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2412: IF(v_current_processing_flag=1 OR v_current_processing_flag=2 ) THEN
2413:
2414: mth_util_pkg.truncate_table_partition('MTH_TAG_READINGS_RAW' ,v_current_processing_flag);
2415:

Line 2414: mth_util_pkg.truncate_table_partition('MTH_TAG_READINGS_RAW' ,v_current_processing_flag);

2410: DELETE FROM MTH_TAG_READINGS_STG;
2411: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_STG - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2412: IF(v_current_processing_flag=1 OR v_current_processing_flag=2 ) THEN
2413:
2414: mth_util_pkg.truncate_table_partition('MTH_TAG_READINGS_RAW' ,v_current_processing_flag);
2415:
2416: END IF;
2417: COMMIT;
2418: END IF;

Line 2424: mth_util_pkg.switch_column_default_value ( 'MTH_TAG_READINGS_RAW', v_current_processing_flag);

2420: END IF;
2421: END IF;
2422: IF(p_ret_code = 2) THEN
2423: ROLLBACK;
2424: mth_util_pkg.switch_column_default_value ( 'MTH_TAG_READINGS_RAW', v_current_processing_flag);
2425: UPDATE MTH_TAG_READINGS_RAW
2426: SET processing_flag = Decode(v_current_processing_flag,1,2,1)
2427: WHERE processing_flag = v_current_processing_flag;
2428: END IF;

Line 2434: mth_util_pkg.log_msg('INCR_READINGS_FROM_RAW end', mth_util_pkg.G_DBG_PROC_FUN_END);

2430: END IF;
2431: END IF;
2432:
2433:
2434: mth_util_pkg.log_msg('INCR_READINGS_FROM_RAW end', mth_util_pkg.G_DBG_PROC_FUN_END);
2435:
2436:
2437: EXCEPTION
2438: WHEN OTHERS THEN

Line 2439: mth_util_pkg.log_msg('Exception OTHERS in INCR_READINGS_FROM_RAW', mth_util_pkg.G_DBG_EXCEPTION);

2435:
2436:
2437: EXCEPTION
2438: WHEN OTHERS THEN
2439: mth_util_pkg.log_msg('Exception OTHERS in INCR_READINGS_FROM_RAW', mth_util_pkg.G_DBG_EXCEPTION);
2440: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
2441: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
2442: p_ret_code := 2;
2443: ROLLBACK;

Line 2440: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);

2436:
2437: EXCEPTION
2438: WHEN OTHERS THEN
2439: mth_util_pkg.log_msg('Exception OTHERS in INCR_READINGS_FROM_RAW', mth_util_pkg.G_DBG_EXCEPTION);
2440: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
2441: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
2442: p_ret_code := 2;
2443: ROLLBACK;
2444:

Line 2441: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);

2437: EXCEPTION
2438: WHEN OTHERS THEN
2439: mth_util_pkg.log_msg('Exception OTHERS in INCR_READINGS_FROM_RAW', mth_util_pkg.G_DBG_EXCEPTION);
2440: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
2441: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
2442: p_ret_code := 2;
2443: ROLLBACK;
2444:
2445:

Line 2473: mth_util_pkg.log_msg('RECAL_READINGS_FROM_RAW start', mth_util_pkg.G_DBG_PROC_FUN_START);

2469: v_ret_code NUMBER ;
2470:
2471:
2472: BEGIN
2473: mth_util_pkg.log_msg('RECAL_READINGS_FROM_RAW start', mth_util_pkg.G_DBG_PROC_FUN_START);
2474:
2475: -- Initialize default parameters
2476: v_log_date := sysdate;
2477: v_unassigned_val := MTH_UTIL_PKG.MTH_UA_GET_VAL;

Line 2477: v_unassigned_val := MTH_UTIL_PKG.MTH_UA_GET_VAL;

2473: mth_util_pkg.log_msg('RECAL_READINGS_FROM_RAW start', mth_util_pkg.G_DBG_PROC_FUN_START);
2474:
2475: -- Initialize default parameters
2476: v_log_date := sysdate;
2477: v_unassigned_val := MTH_UTIL_PKG.MTH_UA_GET_VAL;
2478:
2479: mth_util_pkg.switch_column_default_value ( 'MTH_TAG_READINGS_RAW', v_current_processing_flag);
2480:
2481: IF(v_current_processing_flag=1 OR v_current_processing_flag=2) THEN

Line 2479: mth_util_pkg.switch_column_default_value ( 'MTH_TAG_READINGS_RAW', v_current_processing_flag);

2475: -- Initialize default parameters
2476: v_log_date := sysdate;
2477: v_unassigned_val := MTH_UTIL_PKG.MTH_UA_GET_VAL;
2478:
2479: mth_util_pkg.switch_column_default_value ( 'MTH_TAG_READINGS_RAW', v_current_processing_flag);
2480:
2481: IF(v_current_processing_flag=1 OR v_current_processing_flag=2) THEN
2482: DELETE FROM MTH_TAG_READINGS o
2483: WHERE o.EQUIPMENT_FK_KEY = nvl(p_equipment_pk_key,o.EQUIPMENT_FK_KEY)

Line 2486: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

2482: DELETE FROM MTH_TAG_READINGS o
2483: WHERE o.EQUIPMENT_FK_KEY = nvl(p_equipment_pk_key,o.EQUIPMENT_FK_KEY)
2484: AND o.READING_TIME BETWEEN p_recal_from_date AND nvl(p_recal_to_date,o.READING_TIME);
2485:
2486: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2487:
2488: MTH_LOAD_TAG_READINGS_PKG.mth_recal_tag_raw_to_processed(v_current_processing_flag, p_from_tz , p_to_tz,p_ret_code);
2489: IF(p_ret_code <> 2)
2490: THEN

Line 2491: mth_util_pkg.truncate_table_partition('MTH_TAG_READINGS_RAW' ,v_current_processing_flag);

2487:
2488: MTH_LOAD_TAG_READINGS_PKG.mth_recal_tag_raw_to_processed(v_current_processing_flag, p_from_tz , p_to_tz,p_ret_code);
2489: IF(p_ret_code <> 2)
2490: THEN
2491: mth_util_pkg.truncate_table_partition('MTH_TAG_READINGS_RAW' ,v_current_processing_flag);
2492: p_ret_code := MTH_LOAD_TAG_READINGS_PKG.MTH_TRANSFORM_TAG_DATA_TO_STG();
2493: IF(p_ret_code <> 2)
2494: THEN
2495: SELECT B.DESCRIPTION INTO v_desc FROM FND_LOOKUPS B

Line 2515: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_STG - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);

2511: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_MANUAL_BASED_CONTEXTUALIZE();
2512: IF(p_ret_code <> 2)
2513: THEN
2514: DELETE FROM MTH_TAG_READINGS_STG;
2515: mth_util_pkg.log_msg('Number of rows deleted in MTH_TAG_READINGS_STG - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
2516: END IF;
2517: END IF;
2518: END IF;
2519: END IF;

Line 2525: mth_util_pkg.log_msg('RECAL_READINGS_FROM_RAW end', mth_util_pkg.G_DBG_PROC_FUN_END);

2521: END IF;
2522: END IF;
2523:
2524:
2525: mth_util_pkg.log_msg('RECAL_READINGS_FROM_RAW end', mth_util_pkg.G_DBG_PROC_FUN_END);
2526:
2527: EXCEPTION
2528: WHEN OTHERS THEN
2529: mth_util_pkg.log_msg('Exception OTHERS in IRECAL_READINGS_FROM_RAW', mth_util_pkg.G_DBG_EXCEPTION);

Line 2529: mth_util_pkg.log_msg('Exception OTHERS in IRECAL_READINGS_FROM_RAW', mth_util_pkg.G_DBG_EXCEPTION);

2525: mth_util_pkg.log_msg('RECAL_READINGS_FROM_RAW end', mth_util_pkg.G_DBG_PROC_FUN_END);
2526:
2527: EXCEPTION
2528: WHEN OTHERS THEN
2529: mth_util_pkg.log_msg('Exception OTHERS in IRECAL_READINGS_FROM_RAW', mth_util_pkg.G_DBG_EXCEPTION);
2530: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
2531: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
2532: p_ret_code := 2;
2533:

Line 2530: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);

2526:
2527: EXCEPTION
2528: WHEN OTHERS THEN
2529: mth_util_pkg.log_msg('Exception OTHERS in IRECAL_READINGS_FROM_RAW', mth_util_pkg.G_DBG_EXCEPTION);
2530: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
2531: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
2532: p_ret_code := 2;
2533:
2534:

Line 2531: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);

2527: EXCEPTION
2528: WHEN OTHERS THEN
2529: mth_util_pkg.log_msg('Exception OTHERS in IRECAL_READINGS_FROM_RAW', mth_util_pkg.G_DBG_EXCEPTION);
2530: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
2531: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
2532: p_ret_code := 2;
2533:
2534:
2535: END RECAL_READINGS_FROM_RAW;