DBA Data[Home] [Help]

APPS.CSM_NOTIFICATION_EVENT_PKG dependencies on CSM_AUTO_SYNC_NFN

Line 432: Step-1 : Purge all CSM_AUTO_SYNC_NFN/CLIENT notifications that are created earlier than

428: AND sysdate between nvl(start_date,sysdate-1) and nvl(end_date,sysdate+1));
429:
430:
431: /*12.1.2 PURGE AUTO SYNC Notifications
432: Step-1 : Purge all CSM_AUTO_SYNC_NFN/CLIENT notifications that are created earlier than
433: purge interval
434: Step-2 : Close unresponded notifications that are older than purge interval
435: These records will get purged from WF Notifications table
436: after another purge interval has elapsed

Line 446: FOR nfn_rec IN (SELECT NOTIFICATION_ID,USER_ID FROM csm_auto_sync_nfn

442: IF c_purge_days%FOUND AND l_days IS NOT NULL AND l_days>0 THEN
443:
444: --STEP-1
445:
446: FOR nfn_rec IN (SELECT NOTIFICATION_ID,USER_ID FROM csm_auto_sync_nfn
447: WHERE CREATION_DATE < SYSDATE-l_days)
448: LOOP
449: CSM_ACC_PKG.Delete_Acc
450: ( P_PUBLICATION_ITEM_NAMES => CSM_ACC_PKG.t_publication_item_list('CSM_AUTO_SYNC_NFN')

Line 450: ( P_PUBLICATION_ITEM_NAMES => CSM_ACC_PKG.t_publication_item_list('CSM_AUTO_SYNC_NFN')

446: FOR nfn_rec IN (SELECT NOTIFICATION_ID,USER_ID FROM csm_auto_sync_nfn
447: WHERE CREATION_DATE < SYSDATE-l_days)
448: LOOP
449: CSM_ACC_PKG.Delete_Acc
450: ( P_PUBLICATION_ITEM_NAMES => CSM_ACC_PKG.t_publication_item_list('CSM_AUTO_SYNC_NFN')
451: ,P_ACC_TABLE_NAME => 'CSM_AUTO_SYNC_NFN_ACC'
452: ,P_PK1_NAME => 'NOTIFICATION_ID'
453: ,P_PK1_NUM_VALUE => nfn_rec.NOTIFICATION_ID
454: ,P_USER_ID => nfn_rec.USER_ID

Line 451: ,P_ACC_TABLE_NAME => 'CSM_AUTO_SYNC_NFN_ACC'

447: WHERE CREATION_DATE < SYSDATE-l_days)
448: LOOP
449: CSM_ACC_PKG.Delete_Acc
450: ( P_PUBLICATION_ITEM_NAMES => CSM_ACC_PKG.t_publication_item_list('CSM_AUTO_SYNC_NFN')
451: ,P_ACC_TABLE_NAME => 'CSM_AUTO_SYNC_NFN_ACC'
452: ,P_PK1_NAME => 'NOTIFICATION_ID'
453: ,P_PK1_NUM_VALUE => nfn_rec.NOTIFICATION_ID
454: ,P_USER_ID => nfn_rec.USER_ID
455: );

Line 458: DELETE FROM csm_auto_sync_nfn WHERE CREATION_DATE < SYSDATE-l_days;

454: ,P_USER_ID => nfn_rec.USER_ID
455: );
456: END LOOP;
457:
458: DELETE FROM csm_auto_sync_nfn WHERE CREATION_DATE < SYSDATE-l_days;
459:
460: FOR nfn_rec IN (SELECT NOTIFICATION_ID,USER_ID FROM csm_client_nfn_log_acc acc
461: WHERE NOT EXISTS (SELECT 1 FROM csm_auto_sync_nfn b
462: WHERE b.NOTIFICATION_ID=acc.NOTIFICATION_ID))

Line 461: WHERE NOT EXISTS (SELECT 1 FROM csm_auto_sync_nfn b

457:
458: DELETE FROM csm_auto_sync_nfn WHERE CREATION_DATE < SYSDATE-l_days;
459:
460: FOR nfn_rec IN (SELECT NOTIFICATION_ID,USER_ID FROM csm_client_nfn_log_acc acc
461: WHERE NOT EXISTS (SELECT 1 FROM csm_auto_sync_nfn b
462: WHERE b.NOTIFICATION_ID=acc.NOTIFICATION_ID))
463: LOOP
464: CSM_ACC_PKG.Delete_Acc
465: ( P_PUBLICATION_ITEM_NAMES => CSM_ACC_PKG.t_publication_item_list('CSM_CLIENT_NFN_LOG')

Line 474: WHERE NOT EXISTS (SELECT 1 FROM csm_auto_sync_nfn b WHERE b.NOTIFICATION_ID=cl.NOTIFICATION_ID);

470: );
471: END LOOP;
472:
473: DELETE FROM csm_client_nfn_log cl
474: WHERE NOT EXISTS (SELECT 1 FROM csm_auto_sync_nfn b WHERE b.NOTIFICATION_ID=cl.NOTIFICATION_ID);
475:
476: COMMIT;
477:
478: --STEP-2

Line 974: FROM jtf_task_assignments asg, csm_auto_sync_nfn nfn,

970:
971: CURSOR c_sr(b_sr_id NUMBER,b_user_id NUMBER)
972: IS
973: SELECT 1
974: FROM jtf_task_assignments asg, csm_auto_sync_nfn nfn,
975: asg_system_dirty_queue sdq,csm_auto_sync_nfn_acc acc,
976: jtf_tasks_b tsk
977: where tsk.source_object_id=b_sr_id
978: and tsk.source_object_type_code='SR'

Line 975: asg_system_dirty_queue sdq,csm_auto_sync_nfn_acc acc,

971: CURSOR c_sr(b_sr_id NUMBER,b_user_id NUMBER)
972: IS
973: SELECT 1
974: FROM jtf_task_assignments asg, csm_auto_sync_nfn nfn,
975: asg_system_dirty_queue sdq,csm_auto_sync_nfn_acc acc,
976: jtf_tasks_b tsk
977: where tsk.source_object_id=b_sr_id
978: and tsk.source_object_type_code='SR'
979: and tsk.task_id=asg.task_id

Line 994: and sdq.PUB_ITEM ='CSM_AUTO_SYNC_NFN'

990: and acc.notification_id=nfn.notification_id
991: and acc.user_id=nfn.user_id
992: and sdq.access_id=acc.access_id
993: and sdq.transaction_id is NULL
994: and sdq.PUB_ITEM ='CSM_AUTO_SYNC_NFN'
995: and rownum < 2;
996:
997: CURSOR c_task(b_task_id NUMBER,b_user_id NUMBER) IS
998: SELECT 1

Line 999: FROM jtf_task_assignments asg, csm_auto_sync_nfn nfn,

995: and rownum < 2;
996:
997: CURSOR c_task(b_task_id NUMBER,b_user_id NUMBER) IS
998: SELECT 1
999: FROM jtf_task_assignments asg, csm_auto_sync_nfn nfn,
1000: asg_system_dirty_queue sdq,csm_auto_sync_nfn_acc acc
1001: where task_id=b_task_id
1002: and (
1003: (nfn.object_name='TASK' and nfn.object_id=task_id)

Line 1000: asg_system_dirty_queue sdq,csm_auto_sync_nfn_acc acc

996:
997: CURSOR c_task(b_task_id NUMBER,b_user_id NUMBER) IS
998: SELECT 1
999: FROM jtf_task_assignments asg, csm_auto_sync_nfn nfn,
1000: asg_system_dirty_queue sdq,csm_auto_sync_nfn_acc acc
1001: where task_id=b_task_id
1002: and (
1003: (nfn.object_name='TASK' and nfn.object_id=task_id)
1004: OR

Line 1014: and sdq.PUB_ITEM ='CSM_AUTO_SYNC_NFN'

1010: and acc.notification_id=nfn.notification_id
1011: and acc.user_id=nfn.user_id
1012: and sdq.access_id=acc.access_id
1013: and sdq.transaction_id is NULL
1014: and sdq.PUB_ITEM ='CSM_AUTO_SYNC_NFN'
1015: and rownum < 2;
1016:
1017:
1018: CURSOR c_task_asg(b_task_ass_id NUMBER,b_user_id NUMBER) IS

Line 1020: FROM jtf_task_assignments asg, csm_auto_sync_nfn nfn,

1016:
1017:
1018: CURSOR c_task_asg(b_task_ass_id NUMBER,b_user_id NUMBER) IS
1019: SELECT 1
1020: FROM jtf_task_assignments asg, csm_auto_sync_nfn nfn,
1021: asg_system_dirty_queue sdq,csm_auto_sync_nfn_acc acc,
1022: jtf_tasks_b tsk
1023: where task_assignment_id=b_task_ass_id
1024: and tsk.task_id=asg.task_id

Line 1021: asg_system_dirty_queue sdq,csm_auto_sync_nfn_acc acc,

1017:
1018: CURSOR c_task_asg(b_task_ass_id NUMBER,b_user_id NUMBER) IS
1019: SELECT 1
1020: FROM jtf_task_assignments asg, csm_auto_sync_nfn nfn,
1021: asg_system_dirty_queue sdq,csm_auto_sync_nfn_acc acc,
1022: jtf_tasks_b tsk
1023: where task_assignment_id=b_task_ass_id
1024: and tsk.task_id=asg.task_id
1025: and nfn.object_name='TASK_ASSIGNMENT' and nfn.object_id=task_assignment_id

Line 1033: and sdq.PUB_ITEM ='CSM_AUTO_SYNC_NFN'

1029: and acc.notification_id=nfn.notification_id
1030: and acc.user_id=nfn.user_id
1031: and sdq.access_id=acc.access_id
1032: and sdq.transaction_id is NULL
1033: and sdq.PUB_ITEM ='CSM_AUTO_SYNC_NFN'
1034: and rownum < 2;
1035:
1036: l_result NUMBER :=0;
1037: BEGIN

Line 1529: INSERT INTO csm_auto_sync_nfn(USER_ID,NOTIFICATION_ID,OBJECT_NAME,OBJECT_ID,DML,REMINDERS_SENT,CREATION_DATE,CREATED_BY

1525: FOR I in 1..l_cnt
1526: LOOP
1527: IF(l_not_tab(I) <> -1) THEN
1528: -- insert into auto sync table
1529: INSERT INTO csm_auto_sync_nfn(USER_ID,NOTIFICATION_ID,OBJECT_NAME,OBJECT_ID,DML,REMINDERS_SENT,CREATION_DATE,CREATED_BY
1530: ,LAST_UPDATE_DATE,LAST_UPDATED_BY)
1531: VALUES(l_usr_tab(I),l_not_tab(I),l_entity,l_pk_value,l_mode,0,sysdate,1,sysdate,1);
1532:
1533: CSM_ACC_PKG.Insert_Acc

Line 1534: ( P_PUBLICATION_ITEM_NAMES => CSM_ACC_PKG.t_publication_item_list('CSM_AUTO_SYNC_NFN')

1530: ,LAST_UPDATE_DATE,LAST_UPDATED_BY)
1531: VALUES(l_usr_tab(I),l_not_tab(I),l_entity,l_pk_value,l_mode,0,sysdate,1,sysdate,1);
1532:
1533: CSM_ACC_PKG.Insert_Acc
1534: ( P_PUBLICATION_ITEM_NAMES => CSM_ACC_PKG.t_publication_item_list('CSM_AUTO_SYNC_NFN')
1535: ,P_ACC_TABLE_NAME => 'CSM_AUTO_SYNC_NFN_ACC'
1536: ,P_SEQ_NAME => 'CSM_AUTO_SYNC_NFN_ACC_S'
1537: ,P_PK1_NAME => 'NOTIFICATION_ID'
1538: ,P_PK1_NUM_VALUE => l_not_tab(I)

Line 1535: ,P_ACC_TABLE_NAME => 'CSM_AUTO_SYNC_NFN_ACC'

1531: VALUES(l_usr_tab(I),l_not_tab(I),l_entity,l_pk_value,l_mode,0,sysdate,1,sysdate,1);
1532:
1533: CSM_ACC_PKG.Insert_Acc
1534: ( P_PUBLICATION_ITEM_NAMES => CSM_ACC_PKG.t_publication_item_list('CSM_AUTO_SYNC_NFN')
1535: ,P_ACC_TABLE_NAME => 'CSM_AUTO_SYNC_NFN_ACC'
1536: ,P_SEQ_NAME => 'CSM_AUTO_SYNC_NFN_ACC_S'
1537: ,P_PK1_NAME => 'NOTIFICATION_ID'
1538: ,P_PK1_NUM_VALUE => l_not_tab(I)
1539: ,P_USER_ID => l_usr_tab(I)

Line 1536: ,P_SEQ_NAME => 'CSM_AUTO_SYNC_NFN_ACC_S'

1532:
1533: CSM_ACC_PKG.Insert_Acc
1534: ( P_PUBLICATION_ITEM_NAMES => CSM_ACC_PKG.t_publication_item_list('CSM_AUTO_SYNC_NFN')
1535: ,P_ACC_TABLE_NAME => 'CSM_AUTO_SYNC_NFN_ACC'
1536: ,P_SEQ_NAME => 'CSM_AUTO_SYNC_NFN_ACC_S'
1537: ,P_PK1_NAME => 'NOTIFICATION_ID'
1538: ,P_PK1_NUM_VALUE => l_not_tab(I)
1539: ,P_USER_ID => l_usr_tab(I)
1540: );

Line 1603: UPDATE CSM_AUTO_SYNC_NFN

1599: RETURN;
1600: END;
1601:
1602:
1603: UPDATE CSM_AUTO_SYNC_NFN
1604: SET RESPONSE= l_text_value
1605: ,RESPONDED_ON=SYSDATE
1606: WHERE NOTIFICATION_ID=l_nid;
1607:

Line 1682: UPDATE CSM_AUTO_SYNC_NFN

1678:
1679: --try sending Email again
1680: wf_notification.forward(l_nid,l_role);
1681:
1682: UPDATE CSM_AUTO_SYNC_NFN
1683: SET REMINDERS_SENT = REMINDERS_SENT + 1
1684: WHERE NOTIFICATION_ID=l_nid;
1685:
1686: l_try := l_try + 1;

Line 2074: INSERT INTO csm_auto_sync_nfn(USER_ID,NOTIFICATION_ID,OBJECT_NAME,OBJECT_ID,DML,REMINDERS_SENT,CREATION_DATE,CREATED_BY

2070: l_notification_id:=send_email(p_user_name,l_subject,l_body);
2071:
2072: IF(l_notification_id <> -1) THEN
2073: -- insert into auto sync table
2074: INSERT INTO csm_auto_sync_nfn(USER_ID,NOTIFICATION_ID,OBJECT_NAME,OBJECT_ID,DML,REMINDERS_SENT,CREATION_DATE,CREATED_BY
2075: ,LAST_UPDATE_DATE,LAST_UPDATED_BY)
2076: VALUES(asg_base.get_user_id(p_user_name),l_notification_id,'DEFERRED_TRANSACTION',l_tracking_id,'NEW',0,sysdate,1,sysdate,1);
2077:
2078: CSM_ACC_PKG.Insert_Acc

Line 2079: ( P_PUBLICATION_ITEM_NAMES => CSM_ACC_PKG.t_publication_item_list('CSM_AUTO_SYNC_NFN')

2075: ,LAST_UPDATE_DATE,LAST_UPDATED_BY)
2076: VALUES(asg_base.get_user_id(p_user_name),l_notification_id,'DEFERRED_TRANSACTION',l_tracking_id,'NEW',0,sysdate,1,sysdate,1);
2077:
2078: CSM_ACC_PKG.Insert_Acc
2079: ( P_PUBLICATION_ITEM_NAMES => CSM_ACC_PKG.t_publication_item_list('CSM_AUTO_SYNC_NFN')
2080: ,P_ACC_TABLE_NAME => 'CSM_AUTO_SYNC_NFN_ACC'
2081: ,P_SEQ_NAME => 'CSM_AUTO_SYNC_NFN_ACC_S'
2082: ,P_PK1_NAME => 'NOTIFICATION_ID'
2083: ,P_PK1_NUM_VALUE => l_notification_id

Line 2080: ,P_ACC_TABLE_NAME => 'CSM_AUTO_SYNC_NFN_ACC'

2076: VALUES(asg_base.get_user_id(p_user_name),l_notification_id,'DEFERRED_TRANSACTION',l_tracking_id,'NEW',0,sysdate,1,sysdate,1);
2077:
2078: CSM_ACC_PKG.Insert_Acc
2079: ( P_PUBLICATION_ITEM_NAMES => CSM_ACC_PKG.t_publication_item_list('CSM_AUTO_SYNC_NFN')
2080: ,P_ACC_TABLE_NAME => 'CSM_AUTO_SYNC_NFN_ACC'
2081: ,P_SEQ_NAME => 'CSM_AUTO_SYNC_NFN_ACC_S'
2082: ,P_PK1_NAME => 'NOTIFICATION_ID'
2083: ,P_PK1_NUM_VALUE => l_notification_id
2084: ,P_USER_ID => asg_base.get_user_id(p_user_name)

Line 2081: ,P_SEQ_NAME => 'CSM_AUTO_SYNC_NFN_ACC_S'

2077:
2078: CSM_ACC_PKG.Insert_Acc
2079: ( P_PUBLICATION_ITEM_NAMES => CSM_ACC_PKG.t_publication_item_list('CSM_AUTO_SYNC_NFN')
2080: ,P_ACC_TABLE_NAME => 'CSM_AUTO_SYNC_NFN_ACC'
2081: ,P_SEQ_NAME => 'CSM_AUTO_SYNC_NFN_ACC_S'
2082: ,P_PK1_NAME => 'NOTIFICATION_ID'
2083: ,P_PK1_NUM_VALUE => l_notification_id
2084: ,P_USER_ID => asg_base.get_user_id(p_user_name)
2085: );

Line 2158: delete from csm_auto_sync_nfn_acc where user_id=p_user_id;

2154: PROCEDURE PURGE_USER(p_user_id IN NUMBER)
2155: IS
2156: BEGIN
2157:
2158: delete from csm_auto_sync_nfn_acc where user_id=p_user_id;
2159:
2160: delete from csm_deferred_transactions_acc where user_id=p_user_id;
2161:
2162: delete from csm_deferred_nfn_info where client_id=csm_util_pkg.get_user_name(p_user_id);

Line 2164: for rec in (select nfn.notification_id from csm_auto_sync_nfn nfn, wf_notifications wfn

2160: delete from csm_deferred_transactions_acc where user_id=p_user_id;
2161:
2162: delete from csm_deferred_nfn_info where client_id=csm_util_pkg.get_user_name(p_user_id);
2163:
2164: for rec in (select nfn.notification_id from csm_auto_sync_nfn nfn, wf_notifications wfn
2165: where nfn.user_id=p_user_id and nfn.notification_id = wfn.notification_id
2166: and wfn.status='OPEN')
2167: loop
2168: wf_notification.respond(rec.notification_id);

Line 2172: WHERE EXISTS (SELECT 1 FROM csm_auto_sync_nfn b WHERE b.NOTIFICATION_ID=cl.NOTIFICATION_ID and user_id=p_user_id);

2168: wf_notification.respond(rec.notification_id);
2169: end loop;
2170:
2171: DELETE FROM csm_client_nfn_log cl
2172: WHERE EXISTS (SELECT 1 FROM csm_auto_sync_nfn b WHERE b.NOTIFICATION_ID=cl.NOTIFICATION_ID and user_id=p_user_id);
2173:
2174: delete from csm_auto_sync_nfn where user_id=p_user_id;
2175:
2176: delete from CSM_SYNC_ERROR_NFN_INFO where client_id=csm_util_pkg.get_user_name(p_user_id);

Line 2174: delete from csm_auto_sync_nfn where user_id=p_user_id;

2170:
2171: DELETE FROM csm_client_nfn_log cl
2172: WHERE EXISTS (SELECT 1 FROM csm_auto_sync_nfn b WHERE b.NOTIFICATION_ID=cl.NOTIFICATION_ID and user_id=p_user_id);
2173:
2174: delete from csm_auto_sync_nfn where user_id=p_user_id;
2175:
2176: delete from CSM_SYNC_ERROR_NFN_INFO where client_id=csm_util_pkg.get_user_name(p_user_id);
2177:
2178: END PURGE_USER;