[Home] [Help]
8: g_object_name CONSTANT VARCHAR2(30) := 'CSM_COUNTER_VALUES_PKG'; -- package name
9: g_pub_name CONSTANT VARCHAR2(30) := 'CSF_M_COUNTER_VALUES'; -- publication item name
10: g_debug_level NUMBER; -- debug level
11:
12: CURSOR c_CS_COUNTER_VALUES( b_user_name VARCHAR2, b_tranid NUMBER) is
13: SELECT *
14: FROM CSF_M_COUNTER_VALUES_inq
15: WHERE tranid$$ = b_tranid
16: AND clid$$cs = b_user_name;
134: This procedure is called by APPLY_CLIENT_CHANGES when an inserted record is to be processed.
135: ***/
136: PROCEDURE APPLY_INSERT
137: (
138: p_record IN c_CS_COUNTER_VALUES%ROWTYPE,
139: p_error_msg OUT NOCOPY VARCHAR2,
140: x_return_status IN OUT NOCOPY VARCHAR2
141: ) IS
142:
142:
143: CURSOR c_counter_value_id (b_counter_value_id number)
144: IS
145: SELECT counter_value_id
146: FROM cs_counter_values
147: WHERE counter_value_id = b_counter_value_id;
148:
149: --Cursor for counter property readings
150: CURSOR c_ctr_prop_value (b_counter_value_id number, c_tranid NUMBER, c_user_name VARCHAR2)
292: This procedure is called by APPLY_CLIENT_CHANGES when an updated record is to be processed.
293: ***/
294: PROCEDURE APPLY_UPDATE
295: (
296: p_record IN c_CS_COUNTER_VALUES%ROWTYPE,
297: p_error_msg OUT NOCOPY VARCHAR2,
298: x_return_status IN OUT NOCOPY VARCHAR2
299: ) IS
300: CURSOR c_counter_value
311:
312: CURSOR c_counter_value_check (b_counter_value_id NUMBER)
313: IS
314: SELECT counter_reading
315: FROM cs_counter_values
316: WHERE counter_value_id = b_counter_value_id;
317:
318:
319:
461: This procedure is called by APPLY_CLIENT_CHANGES for every record in in-queue that needs to be processed.
462: ***/
463: PROCEDURE APPLY_RECORD
464: (
465: p_record IN c_CS_COUNTER_VALUES%ROWTYPE,
466: p_error_msg OUT NOCOPY VARCHAR2,
467: x_return_status IN OUT NOCOPY VARCHAR2
468: ) IS
469: l_err_msg VARCHAR2(4000);
545: x_return_status := FND_API.G_RET_STS_ERROR;
546: END APPLY_RECORD;
547:
548: /***
549: This procedure is called by CSM_SERVICEP_WRAPPER_PKG when publication item CS_COUNTER_VALUES
550: is dirty. This happens when a mobile field service device executed DML on an updatable table and did
551: a fast sync. This procedure will insert the data that came from mobile into the backend tables using
552: public APIs.
553: ***/
568: l_error_msg := 'Entering ' || g_object_name || '.Apply_Client_Changes';
569: CSM_UTIL_PKG.LOG(l_error_msg,'CSM_COUNTER_VALUES_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_PROCEDURE);
570:
571:
572: /*** loop through CS_COUNTER_VALUES records in inqueue ***/
573: FOR r_CS_COUNTER_VALUES IN c_CS_COUNTER_VALUES( p_user_name, p_tranid) LOOP
574:
575: SAVEPOINT save_rec;
576:
569: CSM_UTIL_PKG.LOG(l_error_msg,'CSM_COUNTER_VALUES_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_PROCEDURE);
570:
571:
572: /*** loop through CS_COUNTER_VALUES records in inqueue ***/
573: FOR r_CS_COUNTER_VALUES IN c_CS_COUNTER_VALUES( p_user_name, p_tranid) LOOP
574:
575: SAVEPOINT save_rec;
576:
577: /*** apply record ***/
576:
577: /*** apply record ***/
578: APPLY_RECORD
579: (
580: r_CS_COUNTER_VALUES
581: , l_error_msg
582: , l_process_status
583: );
584:
585: /*** was record processed successfully? ***/
586: IF l_process_status = FND_API.G_RET_STS_SUCCESS THEN
587: /*** Yes -> delete record from inqueue ***/
588: l_error_msg := 'Record successfully processed, deleting from inqueue ' || g_object_name
589: || ' for PK ' || r_CS_COUNTER_VALUES.COUNTER_VALUE_ID;
590: CSM_UTIL_PKG.LOG(l_error_msg,'CSM_COUNTER_VALUES_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_ERROR);
591:
592: CSM_UTIL_PKG.DELETE_RECORD
593: (
592: CSM_UTIL_PKG.DELETE_RECORD
593: (
594: p_user_name,
595: p_tranid,
596: r_CS_COUNTER_VALUES.seqno$$,
597: r_CS_COUNTER_VALUES.COUNTER_VALUE_ID, -- put PK column here
598: g_object_name,
599: g_pub_name,
600: l_error_msg,
593: (
594: p_user_name,
595: p_tranid,
596: r_CS_COUNTER_VALUES.seqno$$,
597: r_CS_COUNTER_VALUES.COUNTER_VALUE_ID, -- put PK column here
598: g_object_name,
599: g_pub_name,
600: l_error_msg,
601: l_process_status
604: /*** was delete successful? ***/
605: IF l_process_status <> FND_API.G_RET_STS_SUCCESS THEN
606: /*** no -> rollback ***/
607: l_error_msg := 'Deleting from inqueue failed, rolling back to savepoint for entity ' || g_object_name
608: || ' and PK ' || r_CS_COUNTER_VALUES.COUNTER_VALUE_ID ;
609: CSM_UTIL_PKG.LOG(l_error_msg,'CSM_COUNTER_VALUES_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_ERROR);
610:
611: ROLLBACK TO save_rec;
612: END IF;
614:
615: IF l_process_Status <> FND_API.G_RET_STS_SUCCESS THEN
616: /*** Record was not processed successfully or delete failed -> defer and reject record ***/
617: l_error_msg :='Record not processed successfully, deferring and rejecting record for entity ' || g_object_name
618: || ' and PK ' || r_CS_COUNTER_VALUES.COUNTER_VALUE_ID ;
619: CSM_UTIL_PKG.LOG(l_error_msg,'CSM_COUNTER_VALUES_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_ERROR);
620:
621: CSM_UTIL_PKG.DEFER_RECORD
622: (
621: CSM_UTIL_PKG.DEFER_RECORD
622: (
623: p_user_name
624: , p_tranid
625: , r_CS_COUNTER_VALUES.seqno$$
626: , r_CS_COUNTER_VALUES.COUNTER_VALUE_ID -- put PK column here
627: , g_object_name
628: , g_pub_name
629: , l_error_msg
622: (
623: p_user_name
624: , p_tranid
625: , r_CS_COUNTER_VALUES.seqno$$
626: , r_CS_COUNTER_VALUES.COUNTER_VALUE_ID -- put PK column here
627: , g_object_name
628: , g_pub_name
629: , l_error_msg
630: , l_process_status
627: , g_object_name
628: , g_pub_name
629: , l_error_msg
630: , l_process_status
631: , r_CS_COUNTER_VALUES.dmltype$$
632: );
633:
634: /*** Was defer successful? ***/
635: IF l_process_status <> FND_API.G_RET_STS_SUCCESS THEN
634: /*** Was defer successful? ***/
635: IF l_process_status <> FND_API.G_RET_STS_SUCCESS THEN
636: /*** no -> rollback ***/
637: l_error_msg :='Defer record failed, rolling back to savepoint for entity ' || g_object_name
638: || ' and PK ' || r_CS_COUNTER_VALUES.COUNTER_VALUE_ID;
639: CSM_UTIL_PKG.LOG(l_error_msg,'CSM_COUNTER_VALUES_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_ERROR);
640:
641: ROLLBACK TO save_rec;
642: END IF;