88: then
89: l_ctr_grp_id := r_counter_group.counter_group_id;
90: l_customer_product_id := r_counter_group.source_object_id;
91: else
92: l_ctr_grp_id := FND_API.G_MISS_NUM;
93: l_customer_product_id := FND_API.G_MISS_NUM;
94: end if;
95: close c_counter_group;
96:
89: l_ctr_grp_id := r_counter_group.counter_group_id;
90: l_customer_product_id := r_counter_group.source_object_id;
91: else
92: l_ctr_grp_id := FND_API.G_MISS_NUM;
93: l_customer_product_id := FND_API.G_MISS_NUM;
94: end if;
95: close c_counter_group;
96:
97: -- The public API closes a counter log after inserting a counter value. After
135: -- Call the public API
136:
137: Cs_Ctr_Capture_Reading_Pub.Capture_Counter_Reading
138: ( p_api_version_number => 1.0
139: , p_validation_level => FND_API.G_VALID_LEVEL_FULL
140: , p_init_msg_list => FND_API.G_TRUE
141: , p_commit => FND_API.G_FALSE
142: , p_ctr_rdg_tbl => l_ctr_rdg_tbl_pub
143: , p_ctr_grp_log_rec => l_ctr_grp_log_rec_pub
136:
137: Cs_Ctr_Capture_Reading_Pub.Capture_Counter_Reading
138: ( p_api_version_number => 1.0
139: , p_validation_level => FND_API.G_VALID_LEVEL_FULL
140: , p_init_msg_list => FND_API.G_TRUE
141: , p_commit => FND_API.G_FALSE
142: , p_ctr_rdg_tbl => l_ctr_rdg_tbl_pub
143: , p_ctr_grp_log_rec => l_ctr_grp_log_rec_pub
144: , x_return_status => x_return_status
137: Cs_Ctr_Capture_Reading_Pub.Capture_Counter_Reading
138: ( p_api_version_number => 1.0
139: , p_validation_level => FND_API.G_VALID_LEVEL_FULL
140: , p_init_msg_list => FND_API.G_TRUE
141: , p_commit => FND_API.G_FALSE
142: , p_ctr_rdg_tbl => l_ctr_rdg_tbl_pub
143: , p_ctr_grp_log_rec => l_ctr_grp_log_rec_pub
144: , x_return_status => x_return_status
145: , x_msg_count => l_msg_count
160: -- Call the (first of the) private API(s)
161:
162: Cs_Ctr_Capture_Reading_Pvt.Pre_Capture_Counter_Reading
163: ( p_api_version_number => 1.0
164: , p_init_msg_list => FND_API.G_TRUE
165: , p_commit => FND_API.G_FALSE
166: , p_validation_level => FND_API.G_VALID_LEVEL_FULL
167: , p_ctr_grp_log_rec => l_ctr_grp_log_rec_pvt
168: , x_counter_grp_log_id => l_ctr_grp_log_id
161:
162: Cs_Ctr_Capture_Reading_Pvt.Pre_Capture_Counter_Reading
163: ( p_api_version_number => 1.0
164: , p_init_msg_list => FND_API.G_TRUE
165: , p_commit => FND_API.G_FALSE
166: , p_validation_level => FND_API.G_VALID_LEVEL_FULL
167: , p_ctr_grp_log_rec => l_ctr_grp_log_rec_pvt
168: , x_counter_grp_log_id => l_ctr_grp_log_id
169: , x_return_status => x_return_status
162: Cs_Ctr_Capture_Reading_Pvt.Pre_Capture_Counter_Reading
163: ( p_api_version_number => 1.0
164: , p_init_msg_list => FND_API.G_TRUE
165: , p_commit => FND_API.G_FALSE
166: , p_validation_level => FND_API.G_VALID_LEVEL_FULL
167: , p_ctr_grp_log_rec => l_ctr_grp_log_rec_pvt
168: , x_counter_grp_log_id => l_ctr_grp_log_id
169: , x_return_status => x_return_status
170: , x_msg_count => l_msg_count
170: , x_msg_count => l_msg_count
171: , x_msg_data => l_msg_data
172: );
173:
174: if x_return_status = FND_API.G_RET_STS_SUCCESS
175: then
176: -- Call the (second of the) private API(s)
177:
178: l_ctr_rdg_rec_pvt.counter_value_id := p_record.counter_value_id;
187: l_ctr_rdg_rec_pvt.misc_reading := p_record.misc_reading;
188:
189: Cs_Ctr_Capture_Reading_Pvt.Capture_Counter_Reading
190: ( p_api_version_number => 1.0
191: , p_init_msg_list => FND_API.G_TRUE
192: , p_commit => FND_API.G_FALSE
193: , p_validation_level => FND_API.G_VALID_LEVEL_FULL
194: , p_ctr_rdg_rec => l_ctr_rdg_rec_pvt
195: , p_counter_grp_log_id => l_ctr_grp_log_id
188:
189: Cs_Ctr_Capture_Reading_Pvt.Capture_Counter_Reading
190: ( p_api_version_number => 1.0
191: , p_init_msg_list => FND_API.G_TRUE
192: , p_commit => FND_API.G_FALSE
193: , p_validation_level => FND_API.G_VALID_LEVEL_FULL
194: , p_ctr_rdg_rec => l_ctr_rdg_rec_pvt
195: , p_counter_grp_log_id => l_ctr_grp_log_id
196: , x_return_status => x_return_status
189: Cs_Ctr_Capture_Reading_Pvt.Capture_Counter_Reading
190: ( p_api_version_number => 1.0
191: , p_init_msg_list => FND_API.G_TRUE
192: , p_commit => FND_API.G_FALSE
193: , p_validation_level => FND_API.G_VALID_LEVEL_FULL
194: , p_ctr_rdg_rec => l_ctr_rdg_rec_pvt
195: , p_counter_grp_log_id => l_ctr_grp_log_id
196: , x_return_status => x_return_status
197: , x_msg_count => l_msg_count
200: end if;
201: end if;
202: */
203:
204: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
205: /*** exception occurred in API -> return errmsg ***/
206: p_error_msg := CSL_SERVICEL_WRAPPER_PKG.GET_ERROR_MESSAGE_TEXT
207: (
208: p_api_error => TRUE
239: , v_message => 'Leaving ' || g_object_name || '.APPLY_INSERT'
240: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL);
241: END IF;
242:
243: x_return_status := FND_API.G_RET_STS_ERROR;
244: END APPLY_INSERT;
245:
246: /***
247: This procedure is called by APPLY_CLIENT_CHANGES when an updated record is to be processed.
316: then
317: l_ctr_grp_id := r_counter_group.counter_group_id;
318: l_customer_product_id := r_counter_group.source_object_id;
319: else
320: l_ctr_grp_id := FND_API.G_MISS_NUM;
321: l_customer_product_id := FND_API.G_MISS_NUM;
322: end if;
323: close c_counter_group;
324:
317: l_ctr_grp_id := r_counter_group.counter_group_id;
318: l_customer_product_id := r_counter_group.source_object_id;
319: else
320: l_ctr_grp_id := FND_API.G_MISS_NUM;
321: l_customer_product_id := FND_API.G_MISS_NUM;
322: end if;
323: close c_counter_group;
324:
325: l_ctr_grp_log_rec.counter_group_id := l_ctr_grp_id;
349: -- Make sure we have the right object_version_number
350: l_ctr_rdg_rec.object_version_number := r_counter_value.object_version_number;
351: else
352: -- Let the API complain with a good message.
353: l_ctr_grp_log_id := FND_API.G_MISS_NUM;
354: l_ctr_rdg_rec.object_version_number := FND_API.G_MISS_NUM;
355: end if;
356: close c_counter_value;
357:
350: l_ctr_rdg_rec.object_version_number := r_counter_value.object_version_number;
351: else
352: -- Let the API complain with a good message.
353: l_ctr_grp_log_id := FND_API.G_MISS_NUM;
354: l_ctr_rdg_rec.object_version_number := FND_API.G_MISS_NUM;
355: end if;
356: close c_counter_value;
357:
358: l_ctr_rdg_tbl(1) := l_ctr_rdg_rec;
361: l_ctr_rdg_tbl(1).object_version_number := r_counter_value.object_version_number;
362:
363: Cs_Ctr_Capture_Reading_pub.Update_Counter_Reading
364: ( p_api_version_number => 1.0
365: , p_validation_level => FND_API.G_VALID_LEVEL_FULL
366: , p_init_msg_list => FND_API.G_TRUE
367: , p_commit => FND_API.G_FALSE
368: , p_ctr_rdg_tbl => l_ctr_rdg_tbl
369: , p_ctr_grp_log_id => l_ctr_grp_log_id
362:
363: Cs_Ctr_Capture_Reading_pub.Update_Counter_Reading
364: ( p_api_version_number => 1.0
365: , p_validation_level => FND_API.G_VALID_LEVEL_FULL
366: , p_init_msg_list => FND_API.G_TRUE
367: , p_commit => FND_API.G_FALSE
368: , p_ctr_rdg_tbl => l_ctr_rdg_tbl
369: , p_ctr_grp_log_id => l_ctr_grp_log_id
370: , x_return_status => x_return_status
363: Cs_Ctr_Capture_Reading_pub.Update_Counter_Reading
364: ( p_api_version_number => 1.0
365: , p_validation_level => FND_API.G_VALID_LEVEL_FULL
366: , p_init_msg_list => FND_API.G_TRUE
367: , p_commit => FND_API.G_FALSE
368: , p_ctr_rdg_tbl => l_ctr_rdg_tbl
369: , p_ctr_grp_log_id => l_ctr_grp_log_id
370: , x_return_status => x_return_status
371: , x_msg_count => l_msg_count
373: );
374:
375: */
376:
377: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
378: /*** exception occurred in API -> return errmsg ***/
379: p_error_msg := CSL_SERVICEL_WRAPPER_PKG.GET_ERROR_MESSAGE_TEXT
380: (
381: p_api_error => TRUE
412: , v_message => 'Leaving ' || g_object_name || '.APPLY_UPDATE'
413: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL);
414: END IF;
415:
416: x_return_status := FND_API.G_RET_STS_ERROR;
417: END APPLY_UPDATE;
418:
419: /***
420: This procedure is called by APPLY_CLIENT_CHANGES for every record in in-queue that needs to be processed.
426: x_return_status IN OUT NOCOPY VARCHAR2
427: ) IS
428: BEGIN
429: /*** initialize return status and message list ***/
430: x_return_status := FND_API.G_RET_STS_SUCCESS;
431: FND_MSG_PUB.INITIALIZE;
432:
433: IF g_debug_level = JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
434: jtm_message_log_pkg.Log_Msg
479: , p_token_name1 => 'DML'
480: , p_token_value1 => p_record.dmltype$$
481: );
482:
483: x_return_status := FND_API.G_RET_STS_ERROR;
484: ELSE
485: -- invalid dml type
486: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR THEN
487: jtm_message_log_pkg.Log_Msg
497: , p_token_name1 => 'DML'
498: , p_token_value1 => p_record.dmltype$$
499: );
500:
501: x_return_status := FND_API.G_RET_STS_ERROR;
502: END IF;
503:
504: IF g_debug_level = JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
505: jtm_message_log_pkg.Log_Msg
531: , v_message => 'Leaving ' || g_object_name || '.APPLY_RECORD'
532: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL);
533: END IF;
534:
535: x_return_status := FND_API.G_RET_STS_ERROR;
536: END APPLY_RECORD;
537:
538: /***
539: This procedure is called by CSL_SERVICEL_WRAPPER_PKG when publication item CS_COUNTER_VALUES
552: l_process_status VARCHAR2(1);
553: l_error_msg VARCHAR2(4000);
554: BEGIN
555: g_debug_level := p_debug_level;
556: x_return_status := FND_API.G_RET_STS_SUCCESS;
557:
558: IF g_debug_level = JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_FULL THEN
559: jtm_message_log_pkg.Log_Msg
560: ( v_object_id => null
576: , l_process_status
577: );
578:
579: /*** was record processed successfully? ***/
580: IF l_process_status = FND_API.G_RET_STS_SUCCESS THEN
581: /*** Yes -> delete record from inqueue ***/
582: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM THEN
583: jtm_message_log_pkg.Log_Msg
584: ( v_object_id => r_CS_COUNTER_VALUES.COUNTER_VALUE_ID -- put PK column here
599: l_process_status
600: );
601:
602: /*** was delete successful? ***/
603: IF l_process_status <> FND_API.G_RET_STS_SUCCESS THEN
604: /*** no -> rollback ***/
605: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM THEN
606: jtm_message_log_pkg.Log_Msg
607: ( v_object_id => r_CS_COUNTER_VALUES.COUNTER_VALUE_ID -- put PK column here
612: ROLLBACK TO save_rec;
613: END IF;
614: END IF;
615:
616: IF l_process_Status <> FND_API.G_RET_STS_SUCCESS THEN
617: /*** Record was not processed successfully or delete failed -> defer and reject record ***/
618: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM THEN
619: jtm_message_log_pkg.Log_Msg
620: ( v_object_id => r_CS_COUNTER_VALUES.COUNTER_VALUE_ID -- put PK column here
635: , l_process_status
636: );
637:
638: /*** Was defer successful? ***/
639: IF l_process_status <> FND_API.G_RET_STS_SUCCESS THEN
640: /*** no -> rollback ***/
641: IF g_debug_level >= JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_MEDIUM THEN
642: jtm_message_log_pkg.Log_Msg
643: ( v_object_id => r_CS_COUNTER_VALUES.COUNTER_VALUE_ID -- put PK column here
667: , v_object_name => g_object_name
668: , v_message => 'Exception occurred in APPLY_CLIENT_CHANGES:' || fnd_global.local_chr(10) || sqlerrm
669: , v_level_id => JTM_HOOK_UTIL_PKG.G_DEBUG_LEVEL_ERROR);
670: END IF;
671: x_return_status := FND_API.G_RET_STS_ERROR;
672: END APPLY_CLIENT_CHANGES;
673:
674: END CSL_COUNTER_VALUES_PKG;