[Home] [Help]
1: PACKAGE BODY CSI_COUNTER_READINGS_PUB as
2: /* $Header: csipcrdb.pls 120.3.12010000.2 2008/10/31 21:13:03 rsinn ship $ */
3:
4: G_PKG_NAME CONSTANT VARCHAR2(30):= 'CSI_COUNTER_READINGS_PUB';
5: G_FILE_NAME CONSTANT VARCHAR2(12) := 'csipcrdb.pls';
1: PACKAGE BODY CSI_COUNTER_READINGS_PUB as
2: /* $Header: csipcrdb.pls 120.3.12010000.2 2008/10/31 21:13:03 rsinn ship $ */
3:
4: G_PKG_NAME CONSTANT VARCHAR2(30):= 'CSI_COUNTER_READINGS_PUB';
5: G_FILE_NAME CONSTANT VARCHAR2(12) := 'csipcrdb.pls';
6: --
7: /*----------------------------------------------------*/
8: /* procedure name: Capture_Counter_Reading */
57: --
58: CURSOR LATER_READINGS_CUR(p_counter_id IN NUMBER,p_value_timestamp IN DATE) IS
59: select counter_value_id,counter_reading,net_reading,value_timestamp,adjustment_reading
60: ,reset_mode,adjustment_type,include_target_resets
61: from CSI_COUNTER_READINGS
62: where counter_id = p_counter_id
63: and nvl(disabled_flag,'N') = 'N'
64: and value_timestamp > p_value_timestamp
65: ORDER BY value_timestamp asc, counter_value_id asc;
82: and ccv.counter_id = ccr.object_counter_id;
83: --
84: CURSOR UPD_TARGET_CUR(p_ctr_value_id IN NUMBER,p_src_ctr_id IN NUMBER) IS
85: SELECT crg.counter_id
86: from CSI_COUNTER_READINGS crg,
87: CSI_COUNTER_RELATIONSHIPS ccr,
88: CSI_COUNTERS_B ccv
89: where crg.source_counter_value_id = p_ctr_value_id
90: and ccr.object_counter_id = crg.counter_id
93: and ccv.counter_id = crg.counter_id;
94: --
95: CURSOR DERIVE_CUR(p_ctr_value_id IN NUMBER) IS
96: SELECT ctr.counter_id
97: FROM CSI_COUNTERS_B ctr, CSI_COUNTER_READINGS cv
98: WHERE cv.counter_value_id = p_ctr_value_id
99: AND ctr.derive_counter_id = cv.counter_id
100: AND NVL(ctr.start_date_active,sysdate) <= cv.value_timestamp
101: AND NVL(ctr.end_date_active,(sysdate+1)) > cv.value_timestamp;
141: IF p_txn_tbl.EXISTS(j) THEN
142: csi_ctr_gen_utility_pvt.put_line('Dumping Transaction Record # '||to_char(j));
143: csi_ctr_gen_utility_pvt.dump_txn_rec(p_txn_rec => p_txn_tbl(j));
144: csi_ctr_gen_utility_pvt.put_line('Calling Create_Reading_Transaction...');
145: Csi_Counter_Readings_Pvt.Create_Reading_Transaction
146: ( p_api_version => 1.0
147: ,p_commit => fnd_api.g_false
148: ,p_init_msg_list => fnd_api.g_true
149: ,p_validation_level => fnd_api.g_valid_level_full
174: END LOOP; -- End of Txn Tbl Loop
175: --
176: -- Calling Customer Pre-processing Hook
177: IF ( JTF_USR_HKS.Ok_to_execute( G_PKG_NAME, l_api_name, 'B', 'C' ) ) then
178: CSI_COUNTER_READINGS_CUHK.CAPTURE_COUNTER_READING_PRE
179: (
180: p_api_version => p_api_version
181: ,p_commit => p_commit
182: ,p_init_msg_list => p_init_msg_list
188: ,x_msg_count => x_msg_count
189: ,x_msg_data => x_msg_data
190: );
191: IF NOT(x_return_status = FND_API.G_RET_STS_SUCCESS) THEN
192: csi_ctr_gen_utility_pvt.put_line('ERROR FROM CSI_COUNTER_READINGS_CUHK.Capture_Counter_Reading_Pre API ');
193: l_msg_index := 1;
194: l_msg_count := x_msg_count;
195: WHILE l_msg_count > 0 LOOP
196: x_msg_data := FND_MSG_PUB.GET
206: END IF;
207: --
208: -- Calling Vertical Pre-processing Hook
209: IF ( JTF_USR_HKS.Ok_to_execute( G_PKG_NAME, l_api_name, 'B', 'V' ) ) then
210: CSI_COUNTER_READINGS_VUHK.CAPTURE_COUNTER_READING_PRE
211: (
212: p_api_version => p_api_version
213: ,p_commit => p_commit
214: ,p_init_msg_list => p_init_msg_list
220: ,x_msg_count => x_msg_count
221: ,x_msg_data => x_msg_data
222: );
223: IF NOT(x_return_status = FND_API.G_RET_STS_SUCCESS) THEN
224: csi_ctr_gen_utility_pvt.put_line('ERROR FROM CSI_COUNTER_READINGS_VUHK.Capture_Counter_Reading_Pre API ');
225: l_msg_index := 1;
226: l_msg_count := x_msg_count;
227: WHILE l_msg_count > 0 LOOP
228: x_msg_data := FND_MSG_PUB.GET
326: END IF;
327: END IF; -- Call Update_Last_Service_Reading_WO check
328: --
329: csi_ctr_gen_utility_pvt.put_line('Calling Capture_Counter_Reading_pvt...');
330: Csi_Counter_Readings_Pvt.Capture_Counter_Reading
331: (
332: p_api_version => 1.0
333: ,p_commit => p_commit
334: ,p_init_msg_list => p_init_msg_list
363: p_ctr_prop_rdg_tbl(k).value_timestamp := p_ctr_rdg_tbl(j).value_timestamp;
364: -- Call Property reading PVT;
365: csi_ctr_gen_utility_pvt.dump_ctr_property_readings_rec(p_ctr_prop_rdg_tbl(k));
366: csi_ctr_gen_utility_pvt.put_line('Calling Capture_Ctr_Property_Reading...');
367: Csi_Counter_Readings_Pvt.Capture_Ctr_Property_Reading
368: (
369: p_api_version => 1.0
370: ,p_commit => p_commit
371: ,p_init_msg_list => p_init_msg_list
406: l_dflt_ctr_prop_rec.counter_value_id := p_ctr_rdg_tbl(j).counter_value_id;
407: --
408: csi_ctr_gen_utility_pvt.dump_ctr_property_readings_rec(l_dflt_ctr_prop_rec);
409: csi_ctr_gen_utility_pvt.put_line('Calling Capture_Ctr_Property_Reading for Dflt Property');
410: Csi_Counter_Readings_Pvt.Capture_Ctr_Property_Reading
411: (
412: p_api_version => 1.0
413: ,p_commit => p_commit
414: ,p_init_msg_list => p_init_msg_list
447: l_derive_ctr_rec.source_line_id := p_ctr_rdg_tbl(j).source_line_id;
448: --
449: -- Call Compute Derive Counters
450: csi_ctr_gen_utility_pvt.put_line('Calling Compute_Derive_Counters...');
451: Csi_Counter_Readings_Pvt.Compute_Derive_Counters
452: (
453: p_api_version => 1.0
454: ,p_commit => p_commit
455: ,p_init_msg_list => p_init_msg_list
489: l_derive_ctr_rec.counter_id := p_ctr_rdg_tbl(j).counter_id;
490: l_derive_ctr_rec.value_timestamp := later_rdg.value_timestamp;
491: --
492: csi_ctr_gen_utility_pvt.put_line('Calling Compute_Derive_Counters for Update...');
493: Csi_Counter_Readings_Pvt.Compute_Derive_Counters
494: (
495: p_api_version => 1.0
496: ,p_commit => p_commit
497: ,p_init_msg_list => p_init_msg_list
521: END IF; -- End of Derive counter call check
522: END LOOP;
523: END IF; -- l_reset_only check
524: -- Call Compute Formula
525: Csi_Counter_Readings_Pvt.Compute_Formula_Counters
526: (
527: p_api_version => 1.0
528: ,p_commit => p_commit
529: ,p_init_msg_list => p_init_msg_list
556: --
557: csi_ctr_gen_utility_pvt.put_line('End of Private API Calls...');
558: -- Calling Customer Post-processing Hook
559: IF ( JTF_USR_HKS.Ok_to_execute( G_PKG_NAME, l_api_name, 'A', 'C' ) ) then
560: CSI_COUNTER_READINGS_CUHK.CAPTURE_COUNTER_READING_POST
561: (
562: p_api_version => p_api_version
563: ,p_commit => p_commit
564: ,p_init_msg_list => p_init_msg_list
570: ,x_msg_count => x_msg_count
571: ,x_msg_data => x_msg_data
572: );
573: IF NOT(x_return_status = FND_API.G_RET_STS_SUCCESS) THEN
574: csi_ctr_gen_utility_pvt.put_line('ERROR FROM CSI_COUNTER_READINGS_CUHK.Capture_Counter_Reading_Post API ');
575: l_msg_index := 1;
576: l_msg_count := x_msg_count;
577: WHILE l_msg_count > 0 LOOP
578: x_msg_data := FND_MSG_PUB.GET
588: END IF;
589: --
590: -- Calling Vertical Post-processing Hook
591: IF ( JTF_USR_HKS.Ok_to_execute( G_PKG_NAME, l_api_name, 'A', 'V' ) ) then
592: CSI_COUNTER_READINGS_VUHK.CAPTURE_COUNTER_READING_POST
593: (
594: p_api_version => p_api_version
595: ,p_commit => p_commit
596: ,p_init_msg_list => p_init_msg_list
602: ,x_msg_count => x_msg_count
603: ,x_msg_data => x_msg_data
604: );
605: IF NOT(x_return_status = FND_API.G_RET_STS_SUCCESS) THEN
606: csi_ctr_gen_utility_pvt.put_line('ERROR FROM CSI_COUNTER_READINGS_VUHK.Capture_Counter_Reading_Post API ');
607: l_msg_index := 1;
608: l_msg_count := x_msg_count;
609: WHILE l_msg_count > 0 LOOP
610: x_msg_data := FND_MSG_PUB.GET
797: and ccv.counter_id = ccr.object_counter_id;
798: --
799: CURSOR UPD_TARGET_CUR(p_ctr_value_id IN NUMBER,p_src_ctr_id IN NUMBER) IS
800: SELECT crg.counter_id
801: from CSI_COUNTER_READINGS crg,
802: CSI_COUNTER_RELATIONSHIPS ccr,
803: CSI_COUNTERS_B ccv
804: where crg.source_counter_value_id = p_ctr_value_id
805: and ccr.object_counter_id = crg.counter_id
808: and ccv.counter_id = crg.counter_id;
809: --
810: CURSOR DERIVE_CUR(p_ctr_value_id IN NUMBER) IS
811: SELECT ctr.counter_id
812: FROM CSI_COUNTERS_B ctr, CSI_COUNTER_READINGS cv
813: WHERE cv.counter_value_id = p_ctr_value_id
814: AND ctr.derive_counter_id = cv.counter_id
815: AND NVL(ctr.start_date_active,sysdate) <= cv.value_timestamp
816: AND NVL(ctr.end_date_active,(sysdate+1)) > cv.value_timestamp;
851: nvl(p_validation_level,FND_API.G_VALID_LEVEL_FULL) );
852: END IF;
853: -- Calling Customer Pre-processing Hook
854: IF ( JTF_USR_HKS.Ok_to_execute( G_PKG_NAME, l_api_name, 'B', 'C' ) ) then
855: CSI_COUNTER_READINGS_CUHK.UPDATE_COUNTER_READING_PRE
856: (
857: p_api_version => p_api_version
858: ,p_commit => p_commit
859: ,p_init_msg_list => p_init_msg_list
863: ,x_msg_count => x_msg_count
864: ,x_msg_data => x_msg_data
865: );
866: IF NOT(x_return_status = FND_API.G_RET_STS_SUCCESS) THEN
867: csi_ctr_gen_utility_pvt.put_line('ERROR FROM CSI_COUNTER_READINGS_CUHK.Update_Counter_Reading_Pre API ');
868: l_msg_index := 1;
869: l_msg_count := x_msg_count;
870: WHILE l_msg_count > 0 LOOP
871: x_msg_data := FND_MSG_PUB.GET
881: END IF;
882: --
883: -- Calling Vertical Pre-processing Hook
884: IF ( JTF_USR_HKS.Ok_to_execute( G_PKG_NAME, l_api_name, 'B', 'V' ) ) then
885: CSI_COUNTER_READINGS_VUHK.UPDATE_COUNTER_READING_PRE
886: (
887: p_api_version => p_api_version
888: ,p_commit => p_commit
889: ,p_init_msg_list => p_init_msg_list
893: ,x_msg_count => x_msg_count
894: ,x_msg_data => x_msg_data
895: );
896: IF NOT(x_return_status = FND_API.G_RET_STS_SUCCESS) THEN
897: csi_ctr_gen_utility_pvt.put_line('ERROR FROM CSI_COUNTER_READINGS_VUHK.Update_Counter_Reading_Pre API ');
898: l_msg_index := 1;
899: l_msg_count := x_msg_count;
900: WHILE l_msg_count > 0 LOOP
901: x_msg_data := FND_MSG_PUB.GET
915: IF p_ctr_rdg_tbl.EXISTS(j) THEN
916: -- Call Update Counter reading PVT;
917: csi_ctr_gen_utility_pvt.dump_counter_readings_rec(p_ctr_rdg_tbl(j));
918: csi_ctr_gen_utility_pvt.put_line('Calling Update_Counter_Reading_pvt...');
919: Csi_Counter_Readings_Pvt.Update_Counter_Reading
920: (
921: p_api_version => 1.0
922: ,p_commit => p_commit
923: ,p_init_msg_list => p_init_msg_list
947: END IF;
948: --
949: -- Calling Customer Post-processing Hook
950: IF ( JTF_USR_HKS.Ok_to_execute( G_PKG_NAME, l_api_name, 'A', 'C' ) ) then
951: CSI_COUNTER_READINGS_CUHK.UPDATE_COUNTER_READING_POST
952: (
953: p_api_version => p_api_version
954: ,p_commit => p_commit
955: ,p_init_msg_list => p_init_msg_list
959: ,x_msg_count => x_msg_count
960: ,x_msg_data => x_msg_data
961: );
962: IF NOT(x_return_status = FND_API.G_RET_STS_SUCCESS) THEN
963: csi_ctr_gen_utility_pvt.put_line('ERROR FROM CSI_COUNTER_READINGS_CUHK.Update_Counter_Reading_Post API ');
964: l_msg_index := 1;
965: l_msg_count := x_msg_count;
966: WHILE l_msg_count > 0 LOOP
967: x_msg_data := FND_MSG_PUB.GET
977: END IF;
978: --
979: -- Calling Vertical Post-processing Hook
980: IF ( JTF_USR_HKS.Ok_to_execute( G_PKG_NAME, l_api_name, 'A', 'V' ) ) then
981: CSI_COUNTER_READINGS_VUHK.UPDATE_COUNTER_READING_POST
982: (
983: p_api_version => p_api_version
984: ,p_commit => p_commit
985: ,p_init_msg_list => p_init_msg_list
989: ,x_msg_count => x_msg_count
990: ,x_msg_data => x_msg_data
991: );
992: IF NOT(x_return_status = FND_API.G_RET_STS_SUCCESS) THEN
993: csi_ctr_gen_utility_pvt.put_line('ERROR FROM CSI_COUNTER_READINGS_VUHK.Update_Counter_Reading_Post API ');
994: l_msg_index := 1;
995: l_msg_count := x_msg_count;
996: WHILE l_msg_count > 0 LOOP
997: x_msg_data := FND_MSG_PUB.GET
1132: p_data => x_msg_data
1133: );
1134: END Update_Counter_Reading;
1135:
1136: END CSI_COUNTER_READINGS_PUB;