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_TAG_READINGS_RAW

Line 101: MTH_TAG_READINGS_RAW_ERR

97: v_ret_code NUMBER;
98: BEGIN
99: INSERT
100: INTO
101: MTH_TAG_READINGS_RAW_ERR
102: (GROUP_ID,
103: READING_TIME,
104: TAG_CODE,
105: TAG_DATA,

Line 137: FROM MTH_TAG_READINGS_RAW_PROCESSED RP

133: MAX(RP.QUALITY_FLAG) QUALITY_FLAG,
134: MAX(RP.CREATION_DATE) CREATION_DATE ,
135: -- COUNT(RP.TAG_CODE) DUP_COUNT,
136: 'DUP' ERROR_CODE
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);

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 204: MTH_TAG_READINGS_RAW_PROCESSED RP

200: MAX(RP.CREATION_DATE) CREATION_DATE,
201: COUNT(RP.TAG_CODE) DUP_COUNT
202: FROM
203:
204: MTH_TAG_READINGS_RAW_PROCESSED RP
205: GROUP BY
206: RP.READING_TIME , RP.TAG_CODE ) RAW_DATA ,MTH_TAG_MASTER TM ,MTH_TAG_DESTINATION_MAP TDM ,MTH_EQUIPMENTS_D EQP
207: WHERE
208: RAW_DATA.TAG_CODE = TM.TAG_CODE

Line 298: MTH_TAG_READINGS_RAW_PROCESSED RP

294: MAX(RP.QUALITY_FLAG) QUALITY_FLAG,
295: MAX(RP.CREATION_DATE) CREATION_DATE,
296: COUNT(RP.TAG_CODE) DUP_COUNT
297: FROM
298: MTH_TAG_READINGS_RAW_PROCESSED RP
299: --WHERE (r.CREATION_DATE >= v_log_from_date and r.CREATION_DATE < v_log_to_date )
300: GROUP BY
301: RP.READING_TIME , RP.TAG_CODE ) RAW_DATA ,MTH_TAG_MASTER TM ,MTH_TAG_DESTINATION_MAP TDM ,MTH_EQUIPMENTS_D EQP
302: WHERE

Line 1582: * Description :Load data from the table MTH_TAG_READINGS_RAW *

1578: END MTH_MANUAL_BASED_CONTEXTUALIZE;
1579:
1580: /* ****************************************************************************
1581: * Procedure : mth_recal_tag_raw_to_processed *
1582: * Description :Load data from the table MTH_TAG_READINGS_RAW *
1583: * into meter readings table MTH_TAG_READINGS_RAW_PROCESSED *
1584: * File Name :MTHTAGB.PLS *
1585: * Visibility :Private *
1586: * Parameters :p_curr_partition (value of the partition column *

Line 1583: * into meter readings table MTH_TAG_READINGS_RAW_PROCESSED *

1579:
1580: /* ****************************************************************************
1581: * Procedure : mth_recal_tag_raw_to_processed *
1582: * Description :Load data from the table MTH_TAG_READINGS_RAW *
1583: * into meter readings table MTH_TAG_READINGS_RAW_PROCESSED *
1584: * File Name :MTHTAGB.PLS *
1585: * Visibility :Private *
1586: * Parameters :p_curr_partition (value of the partition column *
1587: * :p_from_tz (value for from time zone ) *

Line 1596: INSERT INTO MTH_TAG_READINGS_RAW_PROCESSED

1592: VARCHAR2, p_to_tz IN VARCHAR2,p_ret_code OUT NOCOPY NUMBER)
1593: IS
1594: BEGIN
1595: -- Insert the data into the mth_tag_readings_processed table
1596: INSERT INTO MTH_TAG_READINGS_RAW_PROCESSED
1597: ( GROUP_ID,
1598: READING_TIME ,
1599: TAG_CODE,
1600: TAG_DATA,

Line 1629: FROM MTH_TAG_READINGS_RAW r);

1625: r.USER_MEASURE3,
1626: r.USER_MEASURE4,
1627: r.USER_MEASURE5,
1628: r.QUALITY_FLAG
1629: FROM MTH_TAG_READINGS_RAW r);
1630:
1631: -- Update/Create entry in MTH_TAG_READINGS_LATEST
1632:
1633: UPDATE MTH_TAG_READINGS_LATEST latest

Line 1634: SET (latest.reading_time,latest.tag_value)= ( SELECT a.reading_time,rraw.tag_data FROM mth_tag_readings_raw rraw ,

1630:
1631: -- Update/Create entry in MTH_TAG_READINGS_LATEST
1632:
1633: UPDATE MTH_TAG_READINGS_LATEST latest
1634: SET (latest.reading_time,latest.tag_value)= ( SELECT a.reading_time,rraw.tag_data FROM mth_tag_readings_raw rraw ,
1635: ( SELECT r.tag_code,Max(r.reading_time) reading_time FROM mth_tag_readings_raw r
1636: GROUP BY r.tag_code)a ,mth_tag_readings_latest l
1637: WHERE rraw.reading_time=a.reading_time
1638: AND rraw.tag_code=a.tag_code

Line 1635: ( SELECT r.tag_code,Max(r.reading_time) reading_time FROM mth_tag_readings_raw r

1631: -- Update/Create entry in MTH_TAG_READINGS_LATEST
1632:
1633: UPDATE MTH_TAG_READINGS_LATEST latest
1634: SET (latest.reading_time,latest.tag_value)= ( SELECT a.reading_time,rraw.tag_data FROM mth_tag_readings_raw rraw ,
1635: ( SELECT r.tag_code,Max(r.reading_time) reading_time FROM mth_tag_readings_raw r
1636: GROUP BY r.tag_code)a ,mth_tag_readings_latest l
1637: WHERE rraw.reading_time=a.reading_time
1638: AND rraw.tag_code=a.tag_code
1639: AND a.tag_code IN l.tag_code

Line 1651: ( SELECT a.tag_code,a.reading_time,rraw.tag_data FROM mth_tag_readings_raw rraw ,

1647: INSERT INTO MTH_TAG_READINGS_LATEST
1648: ( TAG_CODE,
1649: READING_TIME,
1650: TAG_VALUE)
1651: ( SELECT a.tag_code,a.reading_time,rraw.tag_data FROM mth_tag_readings_raw rraw ,
1652: ( SELECT r.tag_code,Max(r.reading_time) reading_time FROM mth_tag_readings_raw r
1653: GROUP BY r.tag_code)a
1654: WHERE rraw.reading_time=a.reading_time
1655: AND rraw.tag_code=a.tag_code

Line 1652: ( SELECT r.tag_code,Max(r.reading_time) reading_time FROM mth_tag_readings_raw r

1648: ( TAG_CODE,
1649: READING_TIME,
1650: TAG_VALUE)
1651: ( SELECT a.tag_code,a.reading_time,rraw.tag_data FROM mth_tag_readings_raw rraw ,
1652: ( SELECT r.tag_code,Max(r.reading_time) reading_time FROM mth_tag_readings_raw r
1653: GROUP BY r.tag_code)a
1654: WHERE rraw.reading_time=a.reading_time
1655: AND rraw.tag_code=a.tag_code
1656: AND NOT EXISTS (SELECT tag_code

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 2195: DELETE FROM MTH_TAG_READINGS_RAW_ERR;

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:
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);

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 2198: DELETE FROM MTH_TAG_READINGS_RAW_PROCESSED;

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:
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);

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 2261: DELETE FROM MTH_TAG_READINGS_RAW_PROCESSED;

2257: END IF;
2258:
2259: IF(p_ret_code <> 2) THEN
2260:
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);

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 2289: UPDATE MTH_TAG_READINGS_RAW

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;
2293:

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 2396: DELETE FROM MTH_TAG_READINGS_RAW_PROCESSED;

2392: --Dbms_Output.put_line('p_ret_code3' || p_ret_code);
2393:
2394: IF(p_ret_code <> 2) THEN
2395:
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);

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 2425: UPDATE MTH_TAG_READINGS_RAW

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;
2429: END IF;

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 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 2501: DELETE FROM MTH_TAG_READINGS_RAW_PROCESSED ;

2497: l_sql_stmt:= 'BEGIN ' || ' v_desc' || ' :1; ' || 'END;';
2498: EXECUTE IMMEDIATE l_sql_stmt USING OUT v_ret_code;
2499: IF(v_ret_code <> 2)
2500: THEN
2501: DELETE FROM MTH_TAG_READINGS_RAW_PROCESSED ;
2502: /* p_ret_code := MTH_LOAD_TAG_READINGS_PKG.MTH_READINGS_ERRORS_TO_STG();
2503: IF(p_ret_code <> 2)
2504: THEN */
2505: p_ret_code :=MTH_LOAD_TAG_READINGS_PKG.MTH_TAG_BASED_CONTEXTUALIZE();