DBA Data[Home] [Help]

APPS.MTH_UTIL_PKG dependencies on MTH_TAG_READINGS

Line 2128: * from mth_tag_readings_stg, mth_tag_readings, *

2124:
2125: /* ****************************************************************************
2126: * Function :GET_PREV_TAG_READING *
2127: * Description :This function is used to retrive the previous reading *
2128: * from mth_tag_readings_stg, mth_tag_readings, *
2129: and mth_tag_readings_err *
2130: * for the given tag_code and reading time is earlier than *
2131: * the reading time specified and within the range specified *
2132: * by the range_in_hour *

Line 2129: and mth_tag_readings_err *

2125: /* ****************************************************************************
2126: * Function :GET_PREV_TAG_READING *
2127: * Description :This function is used to retrive the previous reading *
2128: * from mth_tag_readings_stg, mth_tag_readings, *
2129: and mth_tag_readings_err *
2130: * for the given tag_code and reading time is earlier than *
2131: * the reading time specified and within the range specified *
2132: * by the range_in_hour *
2133: * File Name :MTHUTILB.PLS *

Line 2171: FROM mth_tag_readings_stg

2167: CURSOR c_readings_stg (p_tag_code IN VARCHAR2,
2168: p_start_reading_time IN DATE,
2169: p_end_reading_time IN DATE) IS
2170: SELECT tag_data, reading_time, processed_flag
2171: FROM mth_tag_readings_stg
2172: WHERE tag_code = p_tag_code AND
2173: reading_time < p_start_reading_time AND
2174: reading_time >= p_end_reading_time
2175: ORDER BY reading_time desc;

Line 2181: FROM mth_tag_readings

2177: CURSOR c_readings (p_tag_code IN VARCHAR2,
2178: p_start_reading_time IN DATE,
2179: p_end_reading_time IN DATE) IS
2180: SELECT tag_data, reading_time
2181: FROM mth_tag_readings
2182: WHERE tag_code = p_tag_code AND
2183: reading_time < p_start_reading_time AND
2184: reading_time >= p_end_reading_time
2185: ORDER BY reading_time desc;

Line 2191: FROM mth_tag_readings_err

2187: CURSOR c_readings_err (p_tag_code IN VARCHAR2,
2188: p_start_reading_time IN DATE,
2189: p_end_reading_time IN DATE) IS
2190: SELECT tag_data, reading_time
2191: FROM mth_tag_readings_err
2192: WHERE tag_code = p_tag_code AND
2193: reading_time < p_start_reading_time AND
2194: reading_time >= p_end_reading_time
2195: ORDER BY reading_time desc;

Line 2240: * from mth_tag_readings_stg, mth_tag_readings, *

2236:
2237: /* ****************************************************************************
2238: * Procedure :GET_PREV_TAG_READING_INFO *
2239: * Description :This function is used to retrive the previous reading *
2240: * from mth_tag_readings_stg, mth_tag_readings, *
2241: and mth_tag_readings_err *
2242: * for the given tag_code and reading time is earlier than *
2243: * the reading time specified and within the range specified *
2244: * by the range_in_hour *

Line 2241: and mth_tag_readings_err *

2237: /* ****************************************************************************
2238: * Procedure :GET_PREV_TAG_READING_INFO *
2239: * Description :This function is used to retrive the previous reading *
2240: * from mth_tag_readings_stg, mth_tag_readings, *
2241: and mth_tag_readings_err *
2242: * for the given tag_code and reading time is earlier than *
2243: * the reading time specified and within the range specified *
2244: * by the range_in_hour *
2245: * File Name :MTHUTILB.PLS *

Line 2294: FROM mth_tag_readings_stg

2290: CURSOR c_readings_stg (p_tag_code IN VARCHAR2,
2291: p_start_reading_time IN DATE,
2292: p_end_reading_time IN DATE) IS
2293: SELECT tag_data, reading_time, equipment_fk_key
2294: FROM mth_tag_readings_stg
2295: WHERE tag_code = p_tag_code AND
2296: reading_time < p_start_reading_time AND
2297: reading_time >= p_end_reading_time
2298: ORDER BY reading_time desc;

Line 2304: FROM mth_tag_readings

2300: CURSOR c_readings (p_tag_code IN VARCHAR2,
2301: p_start_reading_time IN DATE,
2302: p_end_reading_time IN DATE) IS
2303: SELECT tag_data, reading_time, equipment_fk_key
2304: FROM mth_tag_readings
2305: WHERE tag_code = p_tag_code AND
2306: reading_time < p_start_reading_time AND
2307: reading_time >= p_end_reading_time
2308: ORDER BY reading_time desc;

Line 2314: FROM mth_tag_readings_err

2310: CURSOR c_readings_err (p_tag_code IN VARCHAR2,
2311: p_start_reading_time IN DATE,
2312: p_end_reading_time IN DATE) IS
2313: SELECT tag_data, reading_time, equipment_fk_key
2314: FROM mth_tag_readings_err
2315: WHERE tag_code = p_tag_code AND
2316: reading_time < p_start_reading_time AND
2317: reading_time >= p_end_reading_time
2318: ORDER BY reading_time desc;

Line 2381: * from mth_tag_readings_stg, mth_tag_readings, *

2377:
2378: /* ****************************************************************************
2379: * Procedure :GET_PREV_TAG_READING_SET *
2380: * Description :This function is used to retrive the previous reading set *
2381: * from mth_tag_readings_stg, mth_tag_readings, *
2382: and mth_tag_readings_err *
2383: * for the given tag_codes and reading time is earlier than *
2384: * the reading time specified and within the range specified *
2385: * by the range_in_hour. The reading set bounded by the same *

Line 2382: and mth_tag_readings_err *

2378: /* ****************************************************************************
2379: * Procedure :GET_PREV_TAG_READING_SET *
2380: * Description :This function is used to retrive the previous reading set *
2381: * from mth_tag_readings_stg, mth_tag_readings, *
2382: and mth_tag_readings_err *
2383: * for the given tag_codes and reading time is earlier than *
2384: * the reading time specified and within the range specified *
2385: * by the range_in_hour. The reading set bounded by the same *
2386: * group id contains both tags *

Line 2417: FROM mth_tag_readings_stg r1, mth_tag_readings_stg r2

2413: SELECT tag_data1, reading_time1, tag_data2, reading_time2
2414: FROM (
2415: SELECT r1.tag_data tag_data1, r1.reading_time reading_time1,
2416: r2.tag_data tag_data2, r2.reading_time reading_time2
2417: FROM mth_tag_readings_stg r1, mth_tag_readings_stg r2
2418: WHERE r1.group_id = r2.GROUP_id AND
2419: r1.reading_time < p_reading_time1 AND
2420: r2.reading_time < p_reading_time2 AND
2421: r1.reading_time >= p_end_time AND

Line 2428: FROM mth_tag_readings r1, mth_tag_readings r2

2424: r2.tag_code = p_tag_code2
2425: UNION ALL
2426: SELECT r1.tag_data tag_data1, r1.reading_time reading_time1,
2427: r2.tag_data tag_data2, r2.reading_time reading_time2
2428: FROM mth_tag_readings r1, mth_tag_readings r2
2429: WHERE r1.group_id = r2.GROUP_id AND
2430: r1.reading_time < p_reading_time1 AND
2431: r2.reading_time < p_reading_time2 AND
2432: r1.reading_time >= p_end_time AND

Line 2439: FROM mth_tag_readings_err r1, mth_tag_readings_err r2

2435: r2.tag_code = p_tag_code2
2436: UNION ALL
2437: SELECT r1.tag_data tag_data1, r1.reading_time reading_time1,
2438: r2.tag_data tag_data2, r2.reading_time reading_time2
2439: FROM mth_tag_readings_err r1, mth_tag_readings_err r2
2440: WHERE r1.group_id = r2.GROUP_id AND
2441: r1.reading_time < p_reading_time1 AND
2442: r2.reading_time < p_reading_time2 AND
2443: r1.reading_time >= p_end_time AND

Line 2521: FROM mth_tag_readings_stg

2517: p_end_time IN DATE) IS
2518: SELECT tag_data, reading_time
2519: FROM (
2520: SELECT tag_data, reading_time
2521: FROM mth_tag_readings_stg
2522: WHERE reading_time < p_reading_time AND
2523: reading_time >= p_end_time AND
2524: tag_code = p_tag_code
2525: UNION ALL

Line 2527: FROM mth_tag_readings

2523: reading_time >= p_end_time AND
2524: tag_code = p_tag_code
2525: UNION ALL
2526: SELECT tag_data, reading_time
2527: FROM mth_tag_readings
2528: WHERE reading_time < p_reading_time AND
2529: reading_time >= p_end_time AND
2530: tag_code = p_tag_code
2531: UNION ALL

Line 2533: FROM mth_tag_readings_err

2529: reading_time >= p_end_time AND
2530: tag_code = p_tag_code
2531: UNION ALL
2532: SELECT tag_data, reading_time
2533: FROM mth_tag_readings_err
2534: WHERE reading_time < p_reading_time AND
2535: reading_time >= p_end_time AND
2536: tag_code = p_tag_code
2537: )

Line 3414: * for a tag if table MTH_TAG_READINGS_LATEST already *

3410:
3411: /* ****************************************************************************
3412: * Procedure :update_tag_to_latest_tab *
3413: * Description :Update an existing the latest reading time and tag value *
3414: * for a tag if table MTH_TAG_READINGS_LATEST already *
3415: * has a entry for the tag. Otherwise, insert a new row *
3416: * File Name :MTHUTILB.PLS *
3417: * Visibility :Private *
3418: * Parameters :p_tag_code - tag code *

Line 3423: * MTH_TAG_READINGS_LATEST or not *

3419: * p_latest_reading_time - reading time of the latest *
3420: * p_latest_tag_value - latest tag reading *
3421: * p_lookup_entry_exist - whether the entry with the *
3422: * same tag code exists in the *
3423: * MTH_TAG_READINGS_LATEST or not *
3424: * Return Value :None *
3425: **************************************************************************** */
3426:
3427: PROCEDURE update_tag_to_latest_tab(p_tag_code IN VARCHAR2,

Line 3435: UPDATE MTH_TAG_READINGS_LATEST

3431: IS
3432: BEGIN
3433: -- If the entry exists, do the update; otherwise, do the insert
3434: IF (p_lookup_entry_exist) THEN
3435: UPDATE MTH_TAG_READINGS_LATEST
3436: SET reading_time = p_latest_reading_time, tag_value = p_latest_tag_value
3437: WHERE tag_code = p_tag_code;
3438: ELSE
3439: INSERT INTO MTH_TAG_READINGS_LATEST

Line 3439: INSERT INTO MTH_TAG_READINGS_LATEST

3435: UPDATE MTH_TAG_READINGS_LATEST
3436: SET reading_time = p_latest_reading_time, tag_value = p_latest_tag_value
3437: WHERE tag_code = p_tag_code;
3438: ELSE
3439: INSERT INTO MTH_TAG_READINGS_LATEST
3440: (TAG_CODE, READING_TIME, TAG_VALUE) VALUES
3441: (p_tag_code, p_latest_reading_time, p_latest_tag_value);
3442: END IF;
3443:

Line 3449: * Description :Check if the raw from MTH_TAG_READINGS_RAW is valid *

3445:
3446:
3447: /* ****************************************************************************
3448: * Function :MTH_IS_TAG_RAW_DATA_ROW_VALID *
3449: * Description :Check if the raw from MTH_TAG_READINGS_RAW is valid *
3450: * or not. *
3451: * File Name :MTHUTILB.PLS *
3452: * Visibility :Private *
3453: * Parameters :p_tag_code - Tag code *

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

3535:
3536:
3537: /* ****************************************************************************
3538: * Procedure :MTH_LOAD_TAG_RAW_TO_PROCESSED *
3539: * Description :Load data from the table MTH_TAG_READINGS_RAW *
3540: * into meter readings table MTH_TAG_READINGS_RAW_PROCESSED *
3541: * File Name :MTHUTILB.PLS *
3542: * Visibility :Private *
3543: * Parameters :p_curr_partition (value of the partition column *

Line 3540: * into meter readings table MTH_TAG_READINGS_RAW_PROCESSED *

3536:
3537: /* ****************************************************************************
3538: * Procedure :MTH_LOAD_TAG_RAW_TO_PROCESSED *
3539: * Description :Load data from the table MTH_TAG_READINGS_RAW *
3540: * into meter readings table MTH_TAG_READINGS_RAW_PROCESSED *
3541: * File Name :MTHUTILB.PLS *
3542: * Visibility :Private *
3543: * Parameters :p_curr_partition (value of the partition column *
3544: * :p_from_tz (value for from time zone ) *

Line 3567: FROM MTH_TAG_READINGS_RAW R, MTH_TAG_MASTER T

3563: Decode(DATA_TYPE, 'NUM', 1, 0) IS_NUMBER,
3564: Decode(T.READING_TYPE, 'CHNG', 1, 0) AS IS_CUMULATIVE,
3565: Decode(T.ORDER_TYPE, 'ASC', 1, 0) IS_ASSENDING,
3566: T.INITIAL_VALUE, T.MAX_RESET_VALUE, R.GROUP_ID, R.CREATION_DATE, R.USER_ATTR1, R.USER_ATTR2, R.USER_ATTR3, R.USER_ATTR4, R.USER_ATTR5, R.USER_MEASURE1, R.USER_MEASURE2, R.USER_MEASURE3, R.USER_MEASURE4, R.USER_MEASURE5, R.QUALITY_FLAG
3567: FROM MTH_TAG_READINGS_RAW R, MTH_TAG_MASTER T
3568: WHERE R.PROCESSING_FLAG = p_processing_flag AND
3569: R.TAG_CODE = T.TAG_CODE (+)
3570: ORDER BY TAG_CODE, READING_TIME;
3571:

Line 3575: FROM MTH_TAG_READINGS_LATEST

3571:
3572: -- Fetch the previous reading time for the given tag code
3573: CURSOR c_getPrevReadingTimeForTag (p_tag_code IN VARCHAR2) IS
3574: SELECT TAG_VALUE, READING_TIME
3575: FROM MTH_TAG_READINGS_LATEST
3576: WHERE TAG_CODE = p_tag_code;
3577:
3578: v_curr_partition NUMBER := p_curr_partition;
3579: v_curr_tag_code VARCHAR2(255) := NULL;

Line 3642: -- in the lookup table MTH_TAG_READINGS_LATEST

3638: v_prev_tag_value := NULL;
3639: v_prev_reading_time := NULL;
3640:
3641: -- 2.1.2 Find previous reading time and tag value for the currenttag
3642: -- in the lookup table MTH_TAG_READINGS_LATEST
3643: OPEN c_getPrevReadingTimeForTag(v_curr_tag_code);
3644: FETCH c_getPrevReadingTimeForTag INTO
3645: v_prev_tag_value, v_prev_reading_time;
3646: CLOSE c_getPrevReadingTimeForTag;

Line 3667: INSERT INTO MTH_TAG_READINGS_UNPROCESS_ERR

3663:
3664: -- 2.3 Insert data into either meter readings or error table
3665: IF (v_err_code IS NOT NULL OR Length(v_err_code) > 0) THEN
3666: -- 2.3.1 Insert the error row to error table if there is any error
3667: INSERT INTO MTH_TAG_READINGS_UNPROCESS_ERR
3668: (GROUP_ID, READING_TIME , TAG_CODE, TAG_DATA, CREATION_DATE, USER_ATTR1, USER_ATTR2, USER_ATTR3, USER_ATTR4, USER_ATTR5, USER_MEASURE1, USER_MEASURE2, USER_MEASURE3, USER_MEASURE4, USER_MEASURE5, QUALITY_FLAG, REPROCESSED_READY_YN, ERR_CODE)
3669: VALUES (r_raw_data.GROUP_ID, r_raw_data.READING_TIME, r_raw_data.TAG_CODE, r_raw_data.TAG_DATA, r_raw_data.CREATION_DATE, r_raw_data.USER_ATTR1, r_raw_data.USER_ATTR2, r_raw_data.USER_ATTR3, r_raw_data.USER_ATTR4, r_raw_data.USER_ATTR5,
3670: r_raw_data.USER_MEASURE1, r_raw_data.USER_MEASURE2, r_raw_data.USER_MEASURE3, r_raw_data.USER_MEASURE4, r_raw_data.USER_MEASURE5, r_raw_data.QUALITY_FLAG,'N', v_err_code);
3671: ELSE

Line 3681: -- 2.3.3 Insert the data into the mth_tag_readings_processed table

3677: r_raw_data.INITIAL_VALUE,
3678: r_raw_data.MAX_RESET_VALUE,
3679: v_prev_tag_value);
3680:
3681: -- 2.3.3 Insert the data into the mth_tag_readings_processed table
3682: INSERT INTO MTH_TAG_READINGS_RAW_PROCESSED (GROUP_ID, READING_TIME , TAG_CODE, TAG_DATA, CREATION_DATE, USER_ATTR1, USER_ATTR2, USER_ATTR3, USER_ATTR4, USER_ATTR5, USER_MEASURE1, USER_MEASURE2, USER_MEASURE3, USER_MEASURE4,
3683: USER_MEASURE5, QUALITY_FLAG) VALUES ( r_raw_data.GROUP_ID, r_raw_data.READING_TIME, r_raw_data.TAG_CODE, v_incr_tag_value, r_raw_data.CREATION_DATE, r_raw_data.USER_ATTR1, r_raw_data.USER_ATTR2, r_raw_data.USER_ATTR3,
3684: r_raw_data.USER_ATTR4, r_raw_data.USER_ATTR5, r_raw_data.USER_MEASURE1, r_raw_data.USER_MEASURE2, r_raw_data.USER_MEASURE3, r_raw_data.USER_MEASURE4, r_raw_data.USER_MEASURE5, r_raw_data.QUALITY_FLAG);
3685:

Line 3682: INSERT INTO MTH_TAG_READINGS_RAW_PROCESSED (GROUP_ID, READING_TIME , TAG_CODE, TAG_DATA, CREATION_DATE, USER_ATTR1, USER_ATTR2, USER_ATTR3, USER_ATTR4, USER_ATTR5, USER_MEASURE1, USER_MEASURE2, USER_MEASURE3, USER_MEASURE4,

3678: r_raw_data.MAX_RESET_VALUE,
3679: v_prev_tag_value);
3680:
3681: -- 2.3.3 Insert the data into the mth_tag_readings_processed table
3682: INSERT INTO MTH_TAG_READINGS_RAW_PROCESSED (GROUP_ID, READING_TIME , TAG_CODE, TAG_DATA, CREATION_DATE, USER_ATTR1, USER_ATTR2, USER_ATTR3, USER_ATTR4, USER_ATTR5, USER_MEASURE1, USER_MEASURE2, USER_MEASURE3, USER_MEASURE4,
3683: USER_MEASURE5, QUALITY_FLAG) VALUES ( r_raw_data.GROUP_ID, r_raw_data.READING_TIME, r_raw_data.TAG_CODE, v_incr_tag_value, r_raw_data.CREATION_DATE, r_raw_data.USER_ATTR1, r_raw_data.USER_ATTR2, r_raw_data.USER_ATTR3,
3684: r_raw_data.USER_ATTR4, r_raw_data.USER_ATTR5, r_raw_data.USER_MEASURE1, r_raw_data.USER_MEASURE2, r_raw_data.USER_MEASURE3, r_raw_data.USER_MEASURE4, r_raw_data.USER_MEASURE5, r_raw_data.QUALITY_FLAG);
3685:
3686: END IF;

Line 3710: -- 2.6 Update/Create entry in MTH_TAG_READINGS_LATEST for the last tag

3706: v_last_tag_value := v_prev_tag_value;
3707: END IF;
3708: END LOOP;
3709:
3710: -- 2.6 Update/Create entry in MTH_TAG_READINGS_LATEST for the last tag
3711: -- Since we have kept the information for the last reading, just
3712: -- need to make sure that v_last_tag_code exists.
3713: IF (v_last_tag_code is not NULL) THEN
3714: update_tag_to_latest_tab(v_last_tag_code,