[Home] [Help]
30: l_errbuf VARCHAR2(100);
31:
32: BEGIN
33:
34: mth_util_pkg.log_msg('PROCESS_UDA start', mth_util_pkg.G_DBG_PROC_FUN_START);
35: mth_util_pkg.log_msg('p_mode = ' || p_mode , mth_util_pkg.G_DBG_PARAM_VAL);
36: 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);
37: 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);
38: mth_util_pkg.log_msg('p_equipment_pk_key = ' || p_equipment_pk_key , mth_util_pkg.G_DBG_PARAM_VAL);
31:
32: BEGIN
33:
34: mth_util_pkg.log_msg('PROCESS_UDA start', mth_util_pkg.G_DBG_PROC_FUN_START);
35: mth_util_pkg.log_msg('p_mode = ' || p_mode , mth_util_pkg.G_DBG_PARAM_VAL);
36: 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);
37: 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);
38: mth_util_pkg.log_msg('p_equipment_pk_key = ' || p_equipment_pk_key , mth_util_pkg.G_DBG_PARAM_VAL);
39: mth_util_pkg.log_msg('p_plant_fk_key = ' || p_plant_fk_key , mth_util_pkg.G_DBG_PARAM_VAL);
32: BEGIN
33:
34: mth_util_pkg.log_msg('PROCESS_UDA start', mth_util_pkg.G_DBG_PROC_FUN_START);
35: mth_util_pkg.log_msg('p_mode = ' || p_mode , mth_util_pkg.G_DBG_PARAM_VAL);
36: 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);
37: 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);
38: mth_util_pkg.log_msg('p_equipment_pk_key = ' || p_equipment_pk_key , mth_util_pkg.G_DBG_PARAM_VAL);
39: mth_util_pkg.log_msg('p_plant_fk_key = ' || p_plant_fk_key , mth_util_pkg.G_DBG_PARAM_VAL);
40:
33:
34: mth_util_pkg.log_msg('PROCESS_UDA start', mth_util_pkg.G_DBG_PROC_FUN_START);
35: mth_util_pkg.log_msg('p_mode = ' || p_mode , mth_util_pkg.G_DBG_PARAM_VAL);
36: 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);
37: 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);
38: mth_util_pkg.log_msg('p_equipment_pk_key = ' || p_equipment_pk_key , mth_util_pkg.G_DBG_PARAM_VAL);
39: mth_util_pkg.log_msg('p_plant_fk_key = ' || p_plant_fk_key , mth_util_pkg.G_DBG_PARAM_VAL);
40:
41: IF p_mode IN ('INCR','INIT') THEN
34: mth_util_pkg.log_msg('PROCESS_UDA start', mth_util_pkg.G_DBG_PROC_FUN_START);
35: mth_util_pkg.log_msg('p_mode = ' || p_mode , mth_util_pkg.G_DBG_PARAM_VAL);
36: 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);
37: 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);
38: mth_util_pkg.log_msg('p_equipment_pk_key = ' || p_equipment_pk_key , mth_util_pkg.G_DBG_PARAM_VAL);
39: mth_util_pkg.log_msg('p_plant_fk_key = ' || p_plant_fk_key , mth_util_pkg.G_DBG_PARAM_VAL);
40:
41: IF p_mode IN ('INCR','INIT') THEN
42: PROCESS_EQUIPUDA_IN_INCR_MODE(l_retcode,l_errbuf);
35: mth_util_pkg.log_msg('p_mode = ' || p_mode , mth_util_pkg.G_DBG_PARAM_VAL);
36: 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);
37: 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);
38: mth_util_pkg.log_msg('p_equipment_pk_key = ' || p_equipment_pk_key , mth_util_pkg.G_DBG_PARAM_VAL);
39: mth_util_pkg.log_msg('p_plant_fk_key = ' || p_plant_fk_key , mth_util_pkg.G_DBG_PARAM_VAL);
40:
41: IF p_mode IN ('INCR','INIT') THEN
42: PROCESS_EQUIPUDA_IN_INCR_MODE(l_retcode,l_errbuf);
43: /* ELSE IF p_mode = 'INIT'
52: l_errbuf
53: );
54: END IF;
55:
56: mth_util_pkg.log_msg('PROCESS_UDA end', mth_util_pkg.G_DBG_PROC_FUN_END);
57:
58: EXCEPTION
59: WHEN OTHERS THEN
60: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_UDA', mth_util_pkg.G_DBG_EXCEPTION);
56: mth_util_pkg.log_msg('PROCESS_UDA end', mth_util_pkg.G_DBG_PROC_FUN_END);
57:
58: EXCEPTION
59: WHEN OTHERS THEN
60: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_UDA', mth_util_pkg.G_DBG_EXCEPTION);
61: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
62: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
63: p_retcode := 2;
64: RAISE;
57:
58: EXCEPTION
59: WHEN OTHERS THEN
60: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_UDA', mth_util_pkg.G_DBG_EXCEPTION);
61: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
62: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
63: p_retcode := 2;
64: RAISE;
65:
58: EXCEPTION
59: WHEN OTHERS THEN
60: mth_util_pkg.log_msg('Exception OTHERS in PROCESS_UDA', mth_util_pkg.G_DBG_EXCEPTION);
61: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
62: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
63: p_retcode := 2;
64: RAISE;
65:
66: END PROCESS_UDA;
96: IF( p_mode = 'RECAL') THEN
97:
98: -- Validate the parameters passed
99: IF ( (p_recal_from_date IS NULL) OR (p_recal_to_date IS NULL) ) THEN
100: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
101: p_retcode := 2;
102: RAISE NULL_DATES;
103: END IF;
104:
110: (TAG.CREATION_DATE < p_recal_from_date
111: AND TAG.CREATION_DATE > p_recal_to_date)
112: OR TAG.last_update_date >= RUN_LOG.FROM_DATE;
113: IF v_tag_reading_count > 0 THEN
114: mth_util_pkg.log_msg('All data from tag reading is still not populated to output table.',mth_util_pkg.G_DBG_EXCEPTION);p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
115: p_retcode := 2;
116: RAISE DATE_VAL;
117: END IF;
118: END IF;
119:
120: EXCEPTION
121: WHEN NULL_DATES THEN
122: --Call logging API and then throw exception
123: mth_util_pkg.log_msg('Exception NULL_DATES in VALIDATION', mth_util_pkg.G_DBG_EXCEPTION);
124: mth_util_pkg.log_msg('Recalculation from date passed is null. Please correct and re-run the program.', mth_util_pkg.G_DBG_EXCEPTION);
125: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
126: p_retcode := 2;
127: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
120: EXCEPTION
121: WHEN NULL_DATES THEN
122: --Call logging API and then throw exception
123: mth_util_pkg.log_msg('Exception NULL_DATES in VALIDATION', mth_util_pkg.G_DBG_EXCEPTION);
124: mth_util_pkg.log_msg('Recalculation from date passed is null. Please correct and re-run the program.', mth_util_pkg.G_DBG_EXCEPTION);
125: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
126: p_retcode := 2;
127: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
128: RAISE;
121: WHEN NULL_DATES THEN
122: --Call logging API and then throw exception
123: mth_util_pkg.log_msg('Exception NULL_DATES in VALIDATION', mth_util_pkg.G_DBG_EXCEPTION);
124: mth_util_pkg.log_msg('Recalculation from date passed is null. Please correct and re-run the program.', mth_util_pkg.G_DBG_EXCEPTION);
125: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
126: p_retcode := 2;
127: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
128: RAISE;
129: WHEN DATE_VAL THEN
123: mth_util_pkg.log_msg('Exception NULL_DATES in VALIDATION', mth_util_pkg.G_DBG_EXCEPTION);
124: mth_util_pkg.log_msg('Recalculation from date passed is null. Please correct and re-run the program.', mth_util_pkg.G_DBG_EXCEPTION);
125: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
126: p_retcode := 2;
127: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
128: RAISE;
129: WHEN DATE_VAL THEN
130: --Call logging API and then throw exception
131: mth_util_pkg.log_msg('Exception DATE_VAL in VALIDATION', mth_util_pkg.G_DBG_EXCEPTION);
127: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
128: RAISE;
129: WHEN DATE_VAL THEN
130: --Call logging API and then throw exception
131: mth_util_pkg.log_msg('Exception DATE_VAL in VALIDATION', mth_util_pkg.G_DBG_EXCEPTION);
132: mth_util_pkg.log_msg('Recalculation from date is greater than recalculation to date. Please correct and re-run the program.', mth_util_pkg.G_DBG_EXCEPTION);
133: mth_util_pkg.log_msg(-20002, mth_util_pkg.G_DBG_EXCEPTION);
134: p_retcode := 2;
135: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
128: RAISE;
129: WHEN DATE_VAL THEN
130: --Call logging API and then throw exception
131: mth_util_pkg.log_msg('Exception DATE_VAL in VALIDATION', mth_util_pkg.G_DBG_EXCEPTION);
132: mth_util_pkg.log_msg('Recalculation from date is greater than recalculation to date. Please correct and re-run the program.', mth_util_pkg.G_DBG_EXCEPTION);
133: mth_util_pkg.log_msg(-20002, mth_util_pkg.G_DBG_EXCEPTION);
134: p_retcode := 2;
135: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
136: RAISE;
129: WHEN DATE_VAL THEN
130: --Call logging API and then throw exception
131: mth_util_pkg.log_msg('Exception DATE_VAL in VALIDATION', mth_util_pkg.G_DBG_EXCEPTION);
132: mth_util_pkg.log_msg('Recalculation from date is greater than recalculation to date. Please correct and re-run the program.', mth_util_pkg.G_DBG_EXCEPTION);
133: mth_util_pkg.log_msg(-20002, mth_util_pkg.G_DBG_EXCEPTION);
134: p_retcode := 2;
135: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
136: RAISE;
137: WHEN OTHERS THEN
131: mth_util_pkg.log_msg('Exception DATE_VAL in VALIDATION', mth_util_pkg.G_DBG_EXCEPTION);
132: mth_util_pkg.log_msg('Recalculation from date is greater than recalculation to date. Please correct and re-run the program.', mth_util_pkg.G_DBG_EXCEPTION);
133: mth_util_pkg.log_msg(-20002, mth_util_pkg.G_DBG_EXCEPTION);
134: p_retcode := 2;
135: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
136: RAISE;
137: WHEN OTHERS THEN
138: mth_util_pkg.log_msg('Exception OTHERS in VALIDATE', mth_util_pkg.G_DBG_EXCEPTION);
139: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
134: p_retcode := 2;
135: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
136: RAISE;
137: WHEN OTHERS THEN
138: mth_util_pkg.log_msg('Exception OTHERS in VALIDATE', mth_util_pkg.G_DBG_EXCEPTION);
139: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
140: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
141: p_retcode := 2;
142: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
135: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
136: RAISE;
137: WHEN OTHERS THEN
138: mth_util_pkg.log_msg('Exception OTHERS in VALIDATE', mth_util_pkg.G_DBG_EXCEPTION);
139: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
140: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
141: p_retcode := 2;
142: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
143: RAISE;
136: RAISE;
137: WHEN OTHERS THEN
138: mth_util_pkg.log_msg('Exception OTHERS in VALIDATE', mth_util_pkg.G_DBG_EXCEPTION);
139: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
140: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
141: p_retcode := 2;
142: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
143: RAISE;
144:
138: mth_util_pkg.log_msg('Exception OTHERS in VALIDATE', mth_util_pkg.G_DBG_EXCEPTION);
139: mth_util_pkg.log_msg(substr(sqlerrm,1,300), mth_util_pkg.G_DBG_EXCEPTION);
140: mth_util_pkg.log_msg(sqlcode, mth_util_pkg.G_DBG_EXCEPTION);
141: p_retcode := 2;
142: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
143: RAISE;
144:
145: END VALIDATE;
146:
163: v_log_to_date DATE;
164: v_unassigned_val VARCHAR2(30);
165: BEGIN
166:
167: mth_util_pkg.log_msg('PROCESS_EQUIPUDA_IN_INCR_MODE start', mth_util_pkg.G_DBG_PROC_FUN_START);
168:
169: -- Initialize default parameters
170: v_log_to_date := sysdate;
171: v_unassigned_val := MTH_UTIL_PKG.MTH_UA_GET_VAL;
167: mth_util_pkg.log_msg('PROCESS_EQUIPUDA_IN_INCR_MODE start', mth_util_pkg.G_DBG_PROC_FUN_START);
168:
169: -- Initialize default parameters
170: v_log_to_date := sysdate;
171: v_unassigned_val := MTH_UTIL_PKG.MTH_UA_GET_VAL;
172:
173: -- Call mth_run_log_pre_load
174: mth_util_pkg.mth_run_log_pre_load('MTH_EQUIPMENTS_EXT_B',v_unassigned_val,'INCR',NULL,0,v_log_to_date);
175:
170: v_log_to_date := sysdate;
171: v_unassigned_val := MTH_UTIL_PKG.MTH_UA_GET_VAL;
172:
173: -- Call mth_run_log_pre_load
174: mth_util_pkg.mth_run_log_pre_load('MTH_EQUIPMENTS_EXT_B',v_unassigned_val,'INCR',NULL,0,v_log_to_date);
175:
176: -- Call GET_RUN_LOG_DATES
177: mth_util_pkg.GET_RUN_LOG_DATES('MTH_EQUIPMENTS_EXT_B',NULL,NULL,NULL,v_log_from_date,v_log_to_date);
178: mth_util_pkg.log_msg('v_log_from_date : '||v_log_from_date, mth_util_pkg.G_DBG_PROC_FUN_START);
173: -- Call mth_run_log_pre_load
174: mth_util_pkg.mth_run_log_pre_load('MTH_EQUIPMENTS_EXT_B',v_unassigned_val,'INCR',NULL,0,v_log_to_date);
175:
176: -- Call GET_RUN_LOG_DATES
177: mth_util_pkg.GET_RUN_LOG_DATES('MTH_EQUIPMENTS_EXT_B',NULL,NULL,NULL,v_log_from_date,v_log_to_date);
178: mth_util_pkg.log_msg('v_log_from_date : '||v_log_from_date, mth_util_pkg.G_DBG_PROC_FUN_START);
179: mth_util_pkg.log_msg('v_log_to_date : '||v_log_to_date, mth_util_pkg.G_DBG_PROC_FUN_START);
180:
181:
174: mth_util_pkg.mth_run_log_pre_load('MTH_EQUIPMENTS_EXT_B',v_unassigned_val,'INCR',NULL,0,v_log_to_date);
175:
176: -- Call GET_RUN_LOG_DATES
177: mth_util_pkg.GET_RUN_LOG_DATES('MTH_EQUIPMENTS_EXT_B',NULL,NULL,NULL,v_log_from_date,v_log_to_date);
178: mth_util_pkg.log_msg('v_log_from_date : '||v_log_from_date, mth_util_pkg.G_DBG_PROC_FUN_START);
179: mth_util_pkg.log_msg('v_log_to_date : '||v_log_to_date, mth_util_pkg.G_DBG_PROC_FUN_START);
180:
181:
182: INSERT INTO MTH_TAG_READINGS_T_STG
175:
176: -- Call GET_RUN_LOG_DATES
177: mth_util_pkg.GET_RUN_LOG_DATES('MTH_EQUIPMENTS_EXT_B',NULL,NULL,NULL,v_log_from_date,v_log_to_date);
178: mth_util_pkg.log_msg('v_log_from_date : '||v_log_from_date, mth_util_pkg.G_DBG_PROC_FUN_START);
179: mth_util_pkg.log_msg('v_log_to_date : '||v_log_to_date, mth_util_pkg.G_DBG_PROC_FUN_START);
180:
181:
182: INSERT INTO MTH_TAG_READINGS_T_STG
183: (EQUIPMENT_FK_KEY,
217: AND EGO.ATTR_GROUP_NAME = EGO_ATTR_GRP.ATTR_GROUP_NAME
218: AND EGO.ATTR_ID = TAG.ATTRIBUTE
219: AND TAG.processed_flag = 0);
220:
221: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS_T_STG - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
222:
223:
224: UPDATE MTH_TAG_READINGS
225: SET processed_flag = 1
227: FROM MTH_TAG_READINGS_T_STG)
228: AND processed_flag=0
229: AND mth_entity IS NULL;
230:
231: mth_util_pkg.log_msg('Number of rows inserted in MTH_TAG_READINGS - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
232:
233:
234: TB_UPLOAD_NO_COMMIT();
235: p_retcode := 0;
234: TB_UPLOAD_NO_COMMIT();
235: p_retcode := 0;
236:
237: ----Call mth_run_log_post_load
238: mth_util_pkg.mth_run_log_post_load('MTH_EQUIPMENTS_EXT_B',v_unassigned_val);
239:
240: mth_util_pkg.log_msg('PROCESS_EQUIPUDA_IN_INCR_MODE end', mth_util_pkg.G_DBG_PROC_FUN_START);
241:
242: EXCEPTION
236:
237: ----Call mth_run_log_post_load
238: mth_util_pkg.mth_run_log_post_load('MTH_EQUIPMENTS_EXT_B',v_unassigned_val);
239:
240: mth_util_pkg.log_msg('PROCESS_EQUIPUDA_IN_INCR_MODE end', mth_util_pkg.G_DBG_PROC_FUN_START);
241:
242: EXCEPTION
243: WHEN OTHERS THEN
244: mth_util_pkg.log_msg('Exception in PROCESS_EQUIPUDA_IN_INCR_MODE.', mth_util_pkg.G_DBG_EXCEPTION);
240: mth_util_pkg.log_msg('PROCESS_EQUIPUDA_IN_INCR_MODE end', mth_util_pkg.G_DBG_PROC_FUN_START);
241:
242: EXCEPTION
243: WHEN OTHERS THEN
244: mth_util_pkg.log_msg('Exception in PROCESS_EQUIPUDA_IN_INCR_MODE.', mth_util_pkg.G_DBG_EXCEPTION);
245: mth_util_pkg.log_msg('Unknown Exception occured while processing INCR mode');
246: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
247: p_retcode := 2;
248: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
241:
242: EXCEPTION
243: WHEN OTHERS THEN
244: mth_util_pkg.log_msg('Exception in PROCESS_EQUIPUDA_IN_INCR_MODE.', mth_util_pkg.G_DBG_EXCEPTION);
245: mth_util_pkg.log_msg('Unknown Exception occured while processing INCR mode');
246: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
247: p_retcode := 2;
248: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
249: RAISE;
242: EXCEPTION
243: WHEN OTHERS THEN
244: mth_util_pkg.log_msg('Exception in PROCESS_EQUIPUDA_IN_INCR_MODE.', mth_util_pkg.G_DBG_EXCEPTION);
245: mth_util_pkg.log_msg('Unknown Exception occured while processing INCR mode');
246: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
247: p_retcode := 2;
248: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
249: RAISE;
250:
244: mth_util_pkg.log_msg('Exception in PROCESS_EQUIPUDA_IN_INCR_MODE.', mth_util_pkg.G_DBG_EXCEPTION);
245: mth_util_pkg.log_msg('Unknown Exception occured while processing INCR mode');
246: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
247: p_retcode := 2;
248: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
249: RAISE;
250:
251: END PROCESS_EQUIPUDA_IN_INCR_MODE;
252:
270: ) IS
271:
272: BEGIN
273:
274: mth_util_pkg.log_msg('PROCESS_EQUIPMENTS_UDA_IN_INIT_MODE start', mth_util_pkg.G_DBG_PROC_FUN_START);
275: mth_util_pkg.log_msg('p_equipment_pk_key = ' || , mth_util_pkg.G_DBG_PARAM_VAL);
276:
277: INSERT INTO MTH_TAG_READINGS_T_STG
278: (EQUIPMENT_FK_KEY,
271:
272: BEGIN
273:
274: mth_util_pkg.log_msg('PROCESS_EQUIPMENTS_UDA_IN_INIT_MODE start', mth_util_pkg.G_DBG_PROC_FUN_START);
275: mth_util_pkg.log_msg('p_equipment_pk_key = ' || , mth_util_pkg.G_DBG_PARAM_VAL);
276:
277: INSERT INTO MTH_TAG_READINGS_T_STG
278: (EQUIPMENT_FK_KEY,
279: WORKORDER_FK_KEY,
316: p_retcode := 0;
317:
318: EXCEPTION
319:
320: mth_util_pkg.log_msg('Exception in PROCESS_EQUIPUDA_IN_INCR_MODE.', mth_util_pkg.G_DBG_EXCEPTION);
321: mth_util_pkg.log_msg('Unknown Exception occured while processing Incremental mode');
322: p_retcode := 2;
323: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
324: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
317:
318: EXCEPTION
319:
320: mth_util_pkg.log_msg('Exception in PROCESS_EQUIPUDA_IN_INCR_MODE.', mth_util_pkg.G_DBG_EXCEPTION);
321: mth_util_pkg.log_msg('Unknown Exception occured while processing Incremental mode');
322: p_retcode := 2;
323: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
324: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
325: RAISE;
319:
320: mth_util_pkg.log_msg('Exception in PROCESS_EQUIPUDA_IN_INCR_MODE.', mth_util_pkg.G_DBG_EXCEPTION);
321: mth_util_pkg.log_msg('Unknown Exception occured while processing Incremental mode');
322: p_retcode := 2;
323: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
324: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
325: RAISE;
326:
327: END PROCESS_EQUIPMENTS_UDA_IN_INIT_MODE;
320: mth_util_pkg.log_msg('Exception in PROCESS_EQUIPUDA_IN_INCR_MODE.', mth_util_pkg.G_DBG_EXCEPTION);
321: mth_util_pkg.log_msg('Unknown Exception occured while processing Incremental mode');
322: p_retcode := 2;
323: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
324: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
325: RAISE;
326:
327: END PROCESS_EQUIPMENTS_UDA_IN_INIT_MODE;
328: */
353: ) IS
354:
355: BEGIN
356:
357: mth_util_pkg.log_msg('REPROCES_EQUIPMENTS_UDA start', mth_util_pkg.G_DBG_PROC_FUN_START);
358: mth_util_pkg.log_msg('p_equipment_pk_key = ' || p_equipment_pk_key, mth_util_pkg.G_DBG_PARAM_VAL);
359: mth_util_pkg.log_msg('p_plant = ' || p_plant, mth_util_pkg.G_DBG_PARAM_VAL);
360:
361: DELETE FROM MTH_EQUIPMENTS_EXT_B EQEXT
354:
355: BEGIN
356:
357: mth_util_pkg.log_msg('REPROCES_EQUIPMENTS_UDA start', mth_util_pkg.G_DBG_PROC_FUN_START);
358: mth_util_pkg.log_msg('p_equipment_pk_key = ' || p_equipment_pk_key, mth_util_pkg.G_DBG_PARAM_VAL);
359: mth_util_pkg.log_msg('p_plant = ' || p_plant, mth_util_pkg.G_DBG_PARAM_VAL);
360:
361: DELETE FROM MTH_EQUIPMENTS_EXT_B EQEXT
362: WHERE EQEXT.READ_TIME > p_recal_from_date
355: BEGIN
356:
357: mth_util_pkg.log_msg('REPROCES_EQUIPMENTS_UDA start', mth_util_pkg.G_DBG_PROC_FUN_START);
358: mth_util_pkg.log_msg('p_equipment_pk_key = ' || p_equipment_pk_key, mth_util_pkg.G_DBG_PARAM_VAL);
359: mth_util_pkg.log_msg('p_plant = ' || p_plant, mth_util_pkg.G_DBG_PARAM_VAL);
360:
361: DELETE FROM MTH_EQUIPMENTS_EXT_B EQEXT
362: WHERE EQEXT.READ_TIME > p_recal_from_date
363: AND EQEXT.READ_TIME <= p_recal_to_date
410: p_retcode := 0;
411:
412: EXCEPTION
413: WHEN OTHERS THEN
414: mth_util_pkg.log_msg('Exception in REPROCES_EQUIPMENTS_UDA.', mth_util_pkg.G_DBG_EXCEPTION);
415: mth_util_pkg.log_msg('Unknown Exception occured while processing Recalculation');
416: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
417: p_retcode := 2;
418: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
411:
412: EXCEPTION
413: WHEN OTHERS THEN
414: mth_util_pkg.log_msg('Exception in REPROCES_EQUIPMENTS_UDA.', mth_util_pkg.G_DBG_EXCEPTION);
415: mth_util_pkg.log_msg('Unknown Exception occured while processing Recalculation');
416: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
417: p_retcode := 2;
418: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
419: RAISE;
412: EXCEPTION
413: WHEN OTHERS THEN
414: mth_util_pkg.log_msg('Exception in REPROCES_EQUIPMENTS_UDA.', mth_util_pkg.G_DBG_EXCEPTION);
415: mth_util_pkg.log_msg('Unknown Exception occured while processing Recalculation');
416: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
417: p_retcode := 2;
418: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
419: RAISE;
420:
414: mth_util_pkg.log_msg('Exception in REPROCES_EQUIPMENTS_UDA.', mth_util_pkg.G_DBG_EXCEPTION);
415: mth_util_pkg.log_msg('Unknown Exception occured while processing Recalculation');
416: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
417: p_retcode := 2;
418: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
419: RAISE;
420:
421: END REPROCES_EQUIPMENTS_UDA;
422:
473: VALUES (TS.TAG_DATA,EGO_EXTFWK_S.NEXTVAL, TS.EQUIPMENT_FK_KEY, TS.WORKORDER_FK_KEY, TS.SEGMENT_FK_KEY,TS.SHIFT_WORKDAY_FK_KEY,TS.HOUR_FK_KEY, TS.ITEM_FK_KEY, TS.READ_TIME,';
474:
475: v_stmt := v_stmt||'TS.ATTR_GROUP_ID,'||''''||SYSDATE||''''||',TS.l_updated_by,TS.l_last_update_login,TS.l_updated_by,'||''''||SYSDATE||''''||',TS.RECIPE_NUM, TS.RECIPE_VERSION)';
476:
477: mth_util_pkg.log_msg('v_stmt : '||v_stmt,mth_util_pkg.G_DBG_DYN_SQL);
478:
479: --DBMS_OUTPUT.PUT_LINE(v_stmt);
480: v_stmt_no := 20;
481: EXECUTE IMMEDIATE v_stmt;
507:
508: PROCEDURE PROCESS_INTERFACE_TO_STAGING (P_ENTITY IN VARCHAR2) IS
509:
510: BEGIN
511: mth_util_pkg.log_msg('PROCESS_INTERFACE_TO_STAGING start', mth_util_pkg.G_DBG_PROC_FUN_START);
512: mth_util_pkg.log_msg('p_entity = ' || p_entity , mth_util_pkg.G_DBG_PARAM_VAL);
513:
514: INSERT INTO MTH_EXT_ATTR_ERR
515: (
508: PROCEDURE PROCESS_INTERFACE_TO_STAGING (P_ENTITY IN VARCHAR2) IS
509:
510: BEGIN
511: mth_util_pkg.log_msg('PROCESS_INTERFACE_TO_STAGING start', mth_util_pkg.G_DBG_PROC_FUN_START);
512: mth_util_pkg.log_msg('p_entity = ' || p_entity , mth_util_pkg.G_DBG_PARAM_VAL);
513:
514: INSERT INTO MTH_EXT_ATTR_ERR
515: (
516: ATTR_GRP_NAME,
573: )
574: )
575: );
576:
577: mth_util_pkg.log_msg('Number of rows inserted in MTH_EXT_ATTR_ERR - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
578:
579:
580:
581:
647: )
648: )
649: );
650:
651: mth_util_pkg.log_msg('Number of rows inserted in MTH_EXT_ATTR_T_STG - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
652:
653:
654:
655:
674: (stg.GROUP_ID = err.GROUP_ID) AND
675: ( egv.ATTR_GROUP_NAME = err.ATTR_GRP_NAME)
676: );
677:
678: mth_util_pkg.log_msg('Number of rows inserted in MTH_EXT_ATTR_ERR - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
679:
680:
681: DELETE
682: FROM
697: 'PRODUCTION_SCHEDULES','MTH_PROD_SCH_GROUP','PRODUCTION_SEGMENTS','MTH_PRODUCTION_SEGMENTS_GROUP',
698: 'USER_ENTITIES','MTH_USER_ENTITIES_GROUP')) AND
699: (err.ATTR_GRP_NAME = egv.ATTR_GROUP_NAME)
700: ));
701: mth_util_pkg.log_msg('Number of rows deleted from MTH_EXT_ATTR_T_STG - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
702: mth_util_pkg.log_msg('PROCESS_INTERFACE_TO_STAGING end', mth_util_pkg.G_DBG_PROC_FUN_END);
703:
704: END PROCESS_INTERFACE_TO_STAGING;
705:
698: 'USER_ENTITIES','MTH_USER_ENTITIES_GROUP')) AND
699: (err.ATTR_GRP_NAME = egv.ATTR_GROUP_NAME)
700: ));
701: mth_util_pkg.log_msg('Number of rows deleted from MTH_EXT_ATTR_T_STG - ' || SQL%ROWCOUNT, mth_util_pkg.G_DBG_ROW_CNT);
702: mth_util_pkg.log_msg('PROCESS_INTERFACE_TO_STAGING end', mth_util_pkg.G_DBG_PROC_FUN_END);
703:
704: END PROCESS_INTERFACE_TO_STAGING;
705:
706: /*******************************************************************************
726: --PRODUCTION_SCHEDULES
727: --USER_ENTITIES
728: Begin
729: --MTH_EXT_ATTR_EQ,IT,OT,PSG,PS,UE_PF--
730: mth_util_pkg.log_msg('PROCESS_UDA_STATIC_DATA start', mth_util_pkg.G_DBG_PROC_FUN_START);
731: mth_util_pkg.log_msg('p_entity = ' || p_entity , mth_util_pkg.G_DBG_PARAM_VAL);
732:
733: MTH_UTIL_PKG.MTH_TRUNCATE_TABLE('MTH_EXT_ATTR_ERR');
734: MTH_PROCESS_UDA_PKG.PROCESS_INTERFACE_TO_STAGING(p_entity);
727: --USER_ENTITIES
728: Begin
729: --MTH_EXT_ATTR_EQ,IT,OT,PSG,PS,UE_PF--
730: mth_util_pkg.log_msg('PROCESS_UDA_STATIC_DATA start', mth_util_pkg.G_DBG_PROC_FUN_START);
731: mth_util_pkg.log_msg('p_entity = ' || p_entity , mth_util_pkg.G_DBG_PARAM_VAL);
732:
733: MTH_UTIL_PKG.MTH_TRUNCATE_TABLE('MTH_EXT_ATTR_ERR');
734: MTH_PROCESS_UDA_PKG.PROCESS_INTERFACE_TO_STAGING(p_entity);
735: IF p_entity = 'USER_ENTITIES' THEN
729: --MTH_EXT_ATTR_EQ,IT,OT,PSG,PS,UE_PF--
730: mth_util_pkg.log_msg('PROCESS_UDA_STATIC_DATA start', mth_util_pkg.G_DBG_PROC_FUN_START);
731: mth_util_pkg.log_msg('p_entity = ' || p_entity , mth_util_pkg.G_DBG_PARAM_VAL);
732:
733: MTH_UTIL_PKG.MTH_TRUNCATE_TABLE('MTH_EXT_ATTR_ERR');
734: MTH_PROCESS_UDA_PKG.PROCESS_INTERFACE_TO_STAGING(p_entity);
735: IF p_entity = 'USER_ENTITIES' THEN
736: MTH_COMMON_PKG.CALL_NTB_UPLOAD_COMPOSITE_PK(p_entity);
737: ELSE
736: MTH_COMMON_PKG.CALL_NTB_UPLOAD_COMPOSITE_PK(p_entity);
737: ELSE
738: MTH_UDA_PKG.NTB_UPLOAD(p_entity);
739: END IF;
740: MTH_UTIL_PKG.MTH_TRUNCATE_TABLE('MTH_EXT_ATTR_I_STG');
741: MTH_UTIL_PKG.MTH_TRUNCATE_TABLE('MTH_EXT_ATTR_T_STG');
742: p_retcode := 0;
743:
744: mth_util_pkg.log_msg('PROCESS_UDA_STATIC_DATA end', mth_util_pkg.G_DBG_PROC_FUN_END);
737: ELSE
738: MTH_UDA_PKG.NTB_UPLOAD(p_entity);
739: END IF;
740: MTH_UTIL_PKG.MTH_TRUNCATE_TABLE('MTH_EXT_ATTR_I_STG');
741: MTH_UTIL_PKG.MTH_TRUNCATE_TABLE('MTH_EXT_ATTR_T_STG');
742: p_retcode := 0;
743:
744: mth_util_pkg.log_msg('PROCESS_UDA_STATIC_DATA end', mth_util_pkg.G_DBG_PROC_FUN_END);
745:
740: MTH_UTIL_PKG.MTH_TRUNCATE_TABLE('MTH_EXT_ATTR_I_STG');
741: MTH_UTIL_PKG.MTH_TRUNCATE_TABLE('MTH_EXT_ATTR_T_STG');
742: p_retcode := 0;
743:
744: mth_util_pkg.log_msg('PROCESS_UDA_STATIC_DATA end', mth_util_pkg.G_DBG_PROC_FUN_END);
745:
746: EXCEPTION
747: WHEN OTHERS THEN
748: mth_util_pkg.log_msg('Exception in PROCESS_UDA_STATIC_DATA', mth_util_pkg.G_DBG_EXCEPTION);
744: mth_util_pkg.log_msg('PROCESS_UDA_STATIC_DATA end', mth_util_pkg.G_DBG_PROC_FUN_END);
745:
746: EXCEPTION
747: WHEN OTHERS THEN
748: mth_util_pkg.log_msg('Exception in PROCESS_UDA_STATIC_DATA', mth_util_pkg.G_DBG_EXCEPTION);
749: mth_util_pkg.log_msg('Unknown Exception occured while processing');
750: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
751: p_retcode := 2;
752: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
745:
746: EXCEPTION
747: WHEN OTHERS THEN
748: mth_util_pkg.log_msg('Exception in PROCESS_UDA_STATIC_DATA', mth_util_pkg.G_DBG_EXCEPTION);
749: mth_util_pkg.log_msg('Unknown Exception occured while processing');
750: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
751: p_retcode := 2;
752: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
753: RAISE;
746: EXCEPTION
747: WHEN OTHERS THEN
748: mth_util_pkg.log_msg('Exception in PROCESS_UDA_STATIC_DATA', mth_util_pkg.G_DBG_EXCEPTION);
749: mth_util_pkg.log_msg('Unknown Exception occured while processing');
750: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
751: p_retcode := 2;
752: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
753: RAISE;
754:
748: mth_util_pkg.log_msg('Exception in PROCESS_UDA_STATIC_DATA', mth_util_pkg.G_DBG_EXCEPTION);
749: mth_util_pkg.log_msg('Unknown Exception occured while processing');
750: mth_util_pkg.log_msg(-20001, mth_util_pkg.G_DBG_EXCEPTION);
751: p_retcode := 2;
752: p_err_buff := mth_util_pkg.G_DBG_EXCEPTION;
753: RAISE;
754:
755:
756: