[Home] [Help]
1: PACKAGE BODY CAC_SYNC_TASK_COMMON AS
2: /* $Header: cacvstcb.pls 120.63.12010000.1 2008/07/24 18:03:24 appldev ship $ */
3: /*======================================================================+
4: | Copyright (c) 1995 Oracle Corporation Redwood Shores, California, USA|
5: | All rights reserved. |
56: BEGIN
57: -------------------------------------------
58: -- Returns TRUE:
59: -- 1) if an appointment spans over a year
60: -- 2) if a task is endless and parameter G_CAC_SYNC_TASK_NO_DATE is set to no
61: -------------------------------------------
62: x_status := FALSE;
63:
64: open getTaskRecur(p_task_id);
66:
67:
68: IF (p_entity=G_TASK --source_object_type_code = G_TASK
69: AND p_calendar_end_date IS NULL AND
70: G_CAC_SYNC_TASK_NO_DATE ='N'
71: )
72: OR
73: ( p_entity = G_APPOINTMENT AND getTaskRecur%FOUND )
74:
176: END IF;
177: END convert_recur_date_to_gmt;
178:
179: PROCEDURE process_exclusions (
180: p_exclusion_tbl IN OUT NOCOPY cac_sync_task.exclusion_tbl,
181: p_rec_rule_id IN NUMBER,
182: p_repeating_task_id IN NUMBER,
183: p_task_rec IN OUT NOCOPY cac_sync_task.task_rec
184: )
179: PROCEDURE process_exclusions (
180: p_exclusion_tbl IN OUT NOCOPY cac_sync_task.exclusion_tbl,
181: p_rec_rule_id IN NUMBER,
182: p_repeating_task_id IN NUMBER,
183: p_task_rec IN OUT NOCOPY cac_sync_task.task_rec
184: )
185: IS
186: i NUMBER := 0;
187: l_exclude_task_id NUMBER ;
254: END LOOP;
255: END process_exclusions;
256:
257: procedure create_updation_record
258: (p_exclusion IN OUT NOCOPY cac_sync_task.exclusion_rec,
259: p_task_rec IN cac_sync_task.task_rec ,
260: p_exclude_task_id IN NUMBER,
261: p_rec_rule_id IN NUMBER )
262:
255: END process_exclusions;
256:
257: procedure create_updation_record
258: (p_exclusion IN OUT NOCOPY cac_sync_task.exclusion_rec,
259: p_task_rec IN cac_sync_task.task_rec ,
260: p_exclude_task_id IN NUMBER,
261: p_rec_rule_id IN NUMBER )
262:
263: is
443: --fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
444: -- fnd_msg_pub.add;
445:
446: -- fnd_message.set_name('JTF', 'JTA_SYNC_INVALID_SYNCID');
447: -- fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.IS_THIS_NEW_TASK');
448: -- fnd_msg_pub.add;
449:
450: -- raise_application_error (-20100,cac_sync_common.get_messages);
451: RETURN TRUE;
490: END count_excluded_tasks;
491:
492: FUNCTION check_for_exclusion (
493: p_sync_id IN NUMBER,
494: p_exclusion_tbl IN OUT NOCOPY cac_sync_task.exclusion_tbl,
495: p_calendar_start_date IN DATE,
496: p_client_time_zone_id IN NUMBER
497: )
498: RETURN BOOLEAN
526:
527: FUNCTION get_excluding_taskid (
528: p_sync_id IN NUMBER,
529: p_recurrence_rule_id IN NUMBER,
530: p_exclusion_rec IN OUT NOCOPY cac_sync_task.exclusion_rec
531: )
532: RETURN NUMBER
533: IS
534: CURSOR c_recur_tasks (b_recurrence_rule_id NUMBER,
629: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
630: fnd_msg_pub.add;
631:
632: fnd_message.set_name('JTF', 'JTA_SYNC_INVALID_SYNCID');
633: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_TASK_ID');
634: fnd_msg_pub.add;
635:
636: raise_application_error (-20100,cac_sync_common.get_messages);
637:
647: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
648: fnd_msg_pub.add;
649:
650: fnd_message.set_name('JTF', 'JTA_SYNC_NOTFOUND_TASKID');
651: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_TASK_ID');
652: fnd_msg_pub.add;
653:
654: raise_application_error (-20100,cac_sync_common.get_messages);
655: ELSIF l_task_id IS NULL
659: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
660: fnd_msg_pub.add;
661:
662: fnd_message.set_name('JTF', 'JTA_SYNC_NULL_TASKID');
663: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_TASK_ID');
664: fnd_msg_pub.add;
665:
666: raise_application_error (-20100,cac_sync_common.get_messages);
667: END IF;
691: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
692: fnd_msg_pub.add;
693:
694: fnd_message.set_name('JTF', 'JTA_SYNC_NOTFOUND_TASKID');
695: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_TASK_ID');
696: fnd_msg_pub.add;
697:
698: raise_application_error (-20100,cac_sync_common.get_messages);
699: END IF;
723: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
724: fnd_msg_pub.add;
725:
726: fnd_message.set_name('JTF', 'JTA_SYNC_TIMEZONEID_NOTFOUND');
727: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_TASK_TIMEZONE_ID');
728: fnd_msg_pub.add;
729:
730: raise_application_error (-20100,cac_sync_common.get_messages);
731:
762:
763: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
764: fnd_msg_pub.add;
765:
766: fnd_message.set_name('JTF', 'cac_sync_task_OVN_NOTFOUND');
767: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_OVN');
768: fnd_msg_pub.add;
769:
770: raise_application_error (-20100,cac_sync_common.get_messages);
763: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
764: fnd_msg_pub.add;
765:
766: fnd_message.set_name('JTF', 'cac_sync_task_OVN_NOTFOUND');
767: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_OVN');
768: fnd_msg_pub.add;
769:
770: raise_application_error (-20100,cac_sync_common.get_messages);
771: END IF;
795: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
796: fnd_msg_pub.add;
797:
798: fnd_message.set_name('JTF', 'JTA_SYNC_ASSIGNMT_OVN_NOTFOUND');
799: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_OVN');
800: fnd_msg_pub.add;
801:
802: raise_application_error (-20100,cac_sync_common.get_messages);
803: END IF;
827: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
828: fnd_msg_pub.add;
829:
830: fnd_message.set_name('JTF', 'JTA_SYNC_RESOURCE_NOTFOUND');
831: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_RESOURCE_DETAILS');
832: fnd_msg_pub.add;
833:
834: raise_application_error (-20100,cac_sync_common.get_messages);
835: END IF;
855: INTO x_task_sync_id
856: FROM dual;
857: END IF;
858:
859: cac_sync_task_map_pkg.insert_row (
860: p_task_sync_id => x_task_sync_id,
861: p_task_id => p_task_id,
862: p_resource_id => cac_sync_task.g_login_resource_id,
863: p_principal_id => p_principal_id
858:
859: cac_sync_task_map_pkg.insert_row (
860: p_task_sync_id => x_task_sync_id,
861: p_task_id => p_task_id,
862: p_resource_id => cac_sync_task.g_login_resource_id,
863: p_principal_id => p_principal_id
864: );
865: ELSIF p_operation = g_modify
866: THEN
863: p_principal_id => p_principal_id
864: );
865: ELSIF p_operation = g_modify
866: THEN
867: cac_sync_task_map_pkg.update_row (
868: p_task_sync_id => x_task_sync_id,
869: p_task_id => p_task_id,
870: p_resource_id => cac_sync_task.g_login_resource_id,
871: p_principal_id => p_principal_id
866: THEN
867: cac_sync_task_map_pkg.update_row (
868: p_task_sync_id => x_task_sync_id,
869: p_task_id => p_task_id,
870: p_resource_id => cac_sync_task.g_login_resource_id,
871: p_principal_id => p_principal_id
872: );
873: /* ELSIF p_operation = G_DELETE
874: THEN
871: p_principal_id => p_principal_id
872: );
873: /* ELSIF p_operation = G_DELETE
874: THEN
875: cac_sync_task_map_pkg.delete_row (
876: p_task_sync_id => x_task_sync_id
877: );*/
878:
879: END IF;
1028: x_resources (res_index).resource_type := p_resource_type;
1029: END get_group_resource;
1030:
1031: PROCEDURE get_alarm_mins (
1032: p_task_rec IN cac_sync_task.task_rec,
1033: x_alarm_mins OUT NOCOPY NUMBER
1034: )
1035: IS
1036: l_alarm_days NUMBER;
1129: RETURN l_date;
1130: END convert_gmt_to_server;
1131:
1132: PROCEDURE convert_dates (
1133: p_task_rec IN cac_sync_task.task_rec,
1134: p_operation IN VARCHAR2, --CREATE OR UPDATE
1135: x_planned_start OUT NOCOPY DATE,
1136: x_planned_end OUT NOCOPY DATE,
1137: x_scheduled_start OUT NOCOPY DATE,
1185: p_scheduled_end_date IN DATE,
1186: p_actual_start_date IN DATE,
1187: p_actual_end_date IN DATE,
1188: p_item_display_type IN NUMBER,
1189: x_task_rec IN OUT NOCOPY cac_sync_task.task_rec
1190: )
1191: IS
1192: BEGIN
1193:
1249: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
1250: fnd_msg_pub.add;
1251:
1252: fnd_message.set_name('JTF', 'JTA_SYNC_INVALID_RECUR_RULE_ID');
1253: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_MAX_ENDDATE');
1254: fnd_msg_pub.add;
1255:
1256: raise_application_error (-20100,cac_sync_common.get_messages);
1257: END IF;
1263: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
1264: fnd_msg_pub.add;
1265:
1266: fnd_message.set_name('JTF', 'JTA_SYNC_NULL_CALENDAR_ENDDATE');
1267: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_MAX_ENDDATE');
1268: fnd_msg_pub.add;
1269:
1270: raise_application_error (-20100,cac_sync_common.get_messages);
1271: END IF;
1309: p_timezone_id IN NUMBER,
1310: p_principal_id IN Number,
1311: p_resource_id IN Number,
1312: p_resource_type IN VARCHAR2,
1313: p_exclusion_data IN OUT NOCOPY cac_sync_task.exclusion_tbl
1314: )
1315: --- RETURN cac_sync_task.exclusion_tbl
1316: IS
1317:
1311: p_resource_id IN Number,
1312: p_resource_type IN VARCHAR2,
1313: p_exclusion_data IN OUT NOCOPY cac_sync_task.exclusion_tbl
1314: )
1315: --- RETURN cac_sync_task.exclusion_tbl
1316: IS
1317:
1318: l_date DATE;
1319: l_alarm_date DATE;
1316: IS
1317:
1318: l_date DATE;
1319: l_alarm_date DATE;
1320: l_exclusion cac_sync_task_cursors.c_exclusions%ROWTYPE;
1321: i BINARY_INTEGER := nvl(p_exclusion_data.last,0) ;
1322: BEGIN
1323:
1324: FOR l_exclusion in cac_sync_task_cursors.c_exclusions(
1320: l_exclusion cac_sync_task_cursors.c_exclusions%ROWTYPE;
1321: i BINARY_INTEGER := nvl(p_exclusion_data.last,0) ;
1322: BEGIN
1323:
1324: FOR l_exclusion in cac_sync_task_cursors.c_exclusions(
1325: p_syncanchor,
1326: p_recurrence_rule_id,
1327: p_resource_id,
1328: p_resource_type)
1404:
1405:
1406: FUNCTION already_selected(p_task_id IN NUMBER
1407: ,p_sync_id IN NUMBER
1408: ,p_task_tbl IN cac_sync_task.task_tbl)
1409: RETURN BOOLEAN
1410: IS
1411: l_selected BOOLEAN := FALSE;
1412: BEGIN
1484: --p_get_data IN BOOLEAN,
1485: p_locations IN VARCHAR2,
1486: p_free_busy_type IN VARCHAR2,
1487: p_dial_in IN VARCHAR2,
1488: x_task_rec IN OUT NOCOPY cac_sync_task.task_rec
1489: )
1490: IS
1491: l_category_name VARCHAR2(240); -- Fix bug 2540722
1492: l_status BOOLEAN;
1590: make_prefix (
1591: p_assignment_status_id => get_assignment_status_id (p_task_id, p_resource_id),
1592: p_source_object_type_code => x_task_rec.objectcode,
1593: p_resource_type => p_owner_type_code,
1594: p_resource_id => cac_sync_task.g_login_resource_id,
1595: p_group_id => p_resource_id,
1596: x_subject => x_task_rec.subject
1597: );
1598: END IF;
1848: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
1849: fnd_msg_pub.add;
1850:
1851: fnd_message.set_name('JTF', 'JTA_SYNC_ASSIGNMENT_NOTFOUND');
1852: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_ASSIGNMENT_ID');
1853: fnd_msg_pub.add;
1854:
1855: raise_application_error (-20100,cac_sync_common.get_messages);
1856: END IF;
1884: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
1885: fnd_msg_pub.add;
1886:
1887: fnd_message.set_name('JTF', 'JTA_SYNC_ASSIGN_STSID_NOTFOUND');
1888: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_ASSIGNMENT_STATUS_ID');
1889: fnd_msg_pub.add;
1890:
1891: raise_application_error (-20100,cac_sync_common.get_messages);
1892: END IF;
1920: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
1921: fnd_msg_pub.add;
1922:
1923: fnd_message.set_name('JTF', 'JTA_SYNC_NOTFOUND_TASKID');
1924: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_OWNER_INFO');
1925: fnd_msg_pub.add;
1926:
1927: raise_application_error (-20100,cac_sync_common.get_messages);
1928: END IF;
1984: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
1985: fnd_msg_pub.add;
1986:
1987: fnd_message.set_name('JTF', 'JTA_SYNC_ASSIGNMENT_NOTFOUND');
1988: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_ASSIGNMENT_INFO');
1989: fnd_msg_pub.add;
1990:
1991: raise_application_error (-20100,cac_sync_common.get_messages);
1992: END IF;
2038: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
2039: fnd_msg_pub.add;
2040:
2041: fnd_message.set_name('JTF', 'JTA_SYNC_ACCESS_PRIV_NOTFOUND');
2042: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_ACCESS');
2043: fnd_msg_pub.add;
2044:
2045: raise_application_error (-20100,cac_sync_common.get_messages);
2046: END IF;
2070: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
2071: fnd_msg_pub.add;
2072:
2073: fnd_message.set_name('JTF', 'JTA_SYNC_NOTFOUND_TASKID');
2074: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_SOURCE_OBJECT_TYPE');
2075: fnd_msg_pub.add;
2076:
2077: raise_application_error (-20100,cac_sync_common.get_messages);
2078: END IF;
2150: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
2151: fnd_msg_pub.add;
2152:
2153: fnd_message.set_name('JTF', 'JTA_SYNC_ASSIGNMENT_NOTFOUND');
2154: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_SYNC_TYPE');
2155: fnd_msg_pub.add;
2156:
2157: raise_application_error (-20100,cac_sync_common.get_messages);
2158: END IF;
2220:
2221: END get_update_type;
2222:
2223: FUNCTION compare_task_rec(
2224: p_task_rec IN OUT NOCOPY cac_sync_task.task_rec
2225: )
2226: return boolean
2227: is
2228:
2308: IF (task_info.task_name<>p_task_rec.subject) THEN RETURN FALSE; END IF; --code changed for bug # 5396599
2309:
2310: if (NVL(task_info.description, 'A')<>NVL(p_task_rec.description, 'A')) then return false; end if; --code changed for bug # 5264362
2311: if( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
2312: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_sync_task_common.compare_task_rec', ' description didnt match ');
2313:
2314: end if;
2315: if (task_info.private_flag<>p_task_rec.privateflag) then return false;end if;
2316: -- if (task_info.occurs_which<>p_task_rec.occurs_which) then return false;end if;
2314: end if;
2315: if (task_info.private_flag<>p_task_rec.privateflag) then return false;end if;
2316: -- if (task_info.occurs_which<>p_task_rec.occurs_which) then return false;end if;
2317: if( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
2318: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_sync_task_common.compare_task_rec', ' private flag didnt match ');
2319:
2320: end if;
2321: if (task_info.locations<>p_task_rec.locations) then return false;end if;
2322: if (NVL(task_info.locations,'AaBb')<>NVL(p_task_rec.locations,'AaBb')) then return false;end if;
2321: if (task_info.locations<>p_task_rec.locations) then return false;end if;
2322: if (NVL(task_info.locations,'AaBb')<>NVL(p_task_rec.locations,'AaBb')) then return false;end if;
2323:
2324: if( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
2325: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_sync_task_common.compare_task_rec', ' location didnt match ');
2326:
2327: end if;
2328:
2329: g_fb_type_changed := false;
2337: if ((NVL(task_info.alarm_on,'N')<>NVL(p_task_rec.alarmFlag,'N')) or
2338: (NVL(task_info.alarm_start,0) <> NVL(l_alarm_start,0)))
2339: then
2340: if( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
2341: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_sync_task_common.compare_task_rec', 'alarm didnt match ');
2342: end if;
2343: return false;
2344: end if;
2345:
2381: x_saturday => l_saturday);
2382:
2383: if (TO_CHAR(l_start_date, 'DD-MON-YYYY')<>TO_CHAR(p_task_rec.start_date, 'DD-MON-YYYY')) then return false;end if;
2384: if( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
2385: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_sync_task_common.compare_task_rec', ' start date active didnt match ');
2386:
2387: end if;
2388: if (TO_CHAR(l_end_date, 'DD-MON-YYYY')<>TO_CHAR(p_task_rec.end_date, 'DD-MON-YYYY')) then return false;end if;
2389: if( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
2386:
2387: end if;
2388: if (TO_CHAR(l_end_date, 'DD-MON-YYYY')<>TO_CHAR(p_task_rec.end_date, 'DD-MON-YYYY')) then return false;end if;
2389: if( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
2390: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_sync_task_common.compare_task_rec', ' end date active didnt match ');
2391:
2392: end if;
2393: /*if (l_sunday<>p_task_rec.sunday) then return false;end if;
2394: if (l_monday<>p_task_rec.monday) then return false;end if;
2572: p_get_data IN BOOLEAN,
2573: x_totalnew IN OUT NOCOPY NUMBER,
2574: x_totalmodified IN OUT NOCOPY NUMBER,
2575: -- x_totaldeleted IN OUT NOCOPY NUMBER,
2576: x_data IN OUT NOCOPY cac_sync_task.task_tbl
2577: --p_new_syncanchor IN DATE
2578: )
2579: IS
2580: x_task_rec cac_sync_task.task_rec;
2576: x_data IN OUT NOCOPY cac_sync_task.task_tbl
2577: --p_new_syncanchor IN DATE
2578: )
2579: IS
2580: x_task_rec cac_sync_task.task_rec;
2581: i INTEGER := p_recordindex;
2582: l_invalid BOOLEAN;
2583: l_end_date DATE;
2584: BEGIN
2581: i INTEGER := p_recordindex;
2582: l_invalid BOOLEAN;
2583: l_end_date DATE;
2584: BEGIN
2585: FOR rec_modify_nonrepeat IN cac_sync_task_cursors.c_modify_non_repeat_task (
2586: p_syncanchor,
2587: p_resource_id,
2588: p_principal_id,
2589: p_resource_type,
2674: END IF; -- l_invalid
2675:
2676: END LOOP;
2677:
2678: FOR rec_new_nonrepeat IN cac_sync_task_cursors.c_new_non_repeat_task (
2679: p_syncanchor,
2680: p_resource_id,
2681: p_principal_id,
2682: p_resource_type,
2778: p_resource_type IN VARCHAR2,
2779: p_source_object_type IN VARCHAR2,
2780: p_get_data IN BOOLEAN,
2781: x_totaldeleted IN OUT NOCOPY NUMBER,
2782: x_data IN OUT NOCOPY cac_sync_task.task_tbl
2783: )
2784: IS
2785: i INTEGER := nvl(x_data.last,0);
2786: BEGIN
2783: )
2784: IS
2785: i INTEGER := nvl(x_data.last,0);
2786: BEGIN
2787: FOR rec_delete IN cac_sync_task_cursors.c_delete_task (
2788: p_syncanchor,
2789: p_resource_id,
2790: p_principal_id,
2791: p_resource_type,
2801: x_data(i).recordindex:= i;
2802: x_data(i).eventtype := g_delete;
2803: x_data(i).resultid := 0;
2804:
2805: cac_sync_task_map_pkg.delete_row (
2806: p_task_sync_id => rec_delete.task_sync_id
2807: );
2808:
2809: x_data(i).syncanchor := convert_server_to_gmt (SYSDATE);
2815: x_totaldeleted := x_totaldeleted + 1;
2816: END IF;
2817: END LOOP;
2818:
2819: FOR rec_delete IN cac_sync_task_cursors.c_delete_assignee_reject (
2820: p_syncanchor,
2821: p_resource_id,
2822: p_principal_id,
2823: p_resource_type,
2836:
2837: /* Commented this for bug#5191856 bcos for deleted appointments, records are not deleted
2838: from jtf_task_all_assignments table and the user has the option of Accepting the declined
2839: Appointment. */
2840: /*cac_sync_task_map_pkg.delete_row (
2841: p_task_sync_id => rec_delete.task_sync_id
2842: );*/
2843:
2844: x_data(i).syncanchor := convert_server_to_gmt (SYSDATE);
2850: x_totaldeleted := x_totaldeleted + 1;
2851: END IF;
2852: END LOOP;
2853:
2854: FOR rec_delete IN cac_sync_task_cursors.c_delete_assignment (
2855: p_syncanchor,
2856: p_resource_id,
2857: p_resource_type,
2858: p_principal_id,
2868: x_data(i).syncid := rec_delete.task_sync_id;
2869: x_data(i).recordindex:= i;
2870: x_data(i).resultid := 0;
2871:
2872: cac_sync_task_map_pkg.delete_row (
2873: p_task_sync_id => rec_delete.task_sync_id
2874: );
2875:
2876: x_data(i).syncanchor := convert_server_to_gmt (SYSDATE);
2882: x_totaldeleted := x_totaldeleted + 1;
2883: END IF;
2884: END LOOP;
2885:
2886: FOR rec_delete IN cac_sync_task_cursors.c_delete_rejected_tasks (
2887: p_syncanchor,
2888: p_resource_id,
2889: p_resource_type,
2890: p_principal_id,
2900: x_data(i).recordindex := i;
2901: x_data (i).eventtype := g_delete;
2902: x_data (i).resultid := 0;
2903:
2904: cac_sync_task_map_pkg.delete_row (
2905: p_task_sync_id => rec_delete.task_sync_id
2906: );
2907:
2908: x_data (i).syncanchor := convert_server_to_gmt (SYSDATE);
2914: x_totaldeleted := x_totaldeleted + 1;
2915: END IF;
2916: END LOOP;
2917:
2918: FOR rec_delete IN cac_sync_task_cursors.c_delete_unsubscribed(
2919: p_resource_id,
2920: p_resource_type,
2921: p_principal_id,
2922: p_source_object_type
2931: x_data(i).recordindex := i;
2932: x_data (i).eventtype := g_delete;
2933: x_data (i).resultid := 0;
2934:
2935: cac_sync_task_map_pkg.delete_row (
2936: p_task_sync_id => rec_delete.task_sync_id
2937: );
2938:
2939: x_data (i).syncanchor := convert_server_to_gmt (SYSDATE);
2960: p_get_data IN BOOLEAN,
2961: x_totalnew IN OUT NOCOPY NUMBER,
2962: x_totalmodified IN OUT NOCOPY NUMBER,
2963: -- x_totaldeleted IN OUT NOCOPY NUMBER,
2964: x_data IN OUT NOCOPY cac_sync_task.task_tbl,
2965: x_exclusion_data IN OUT NOCOPY cac_sync_task.exclusion_tbl
2966: --p_new_syncanchor IN DATE
2967: )
2968: IS
2961: x_totalnew IN OUT NOCOPY NUMBER,
2962: x_totalmodified IN OUT NOCOPY NUMBER,
2963: -- x_totaldeleted IN OUT NOCOPY NUMBER,
2964: x_data IN OUT NOCOPY cac_sync_task.task_tbl,
2965: x_exclusion_data IN OUT NOCOPY cac_sync_task.exclusion_tbl
2966: --p_new_syncanchor IN DATE
2967: )
2968: IS
2969: i INTEGER := nvl(x_data.last,0);
2966: --p_new_syncanchor IN DATE
2967: )
2968: IS
2969: i INTEGER := nvl(x_data.last,0);
2970: x_task_rec cac_sync_task.task_rec;
2971: l_invalid BOOLEAN;
2972:
2973:
2974: BEGIN
2974: BEGIN
2975:
2976:
2977:
2978: FOR rec_modify_repeat IN cac_sync_task_cursors.c_modify_repeating_task (
2979: p_syncanchor,
2980: p_resource_id,
2981: p_principal_id,
2982: p_resource_type,
3003: x_data(i).recordindex:= i;
3004: x_data(i).eventtype := g_delete;
3005: x_data(i).resultid := 0;
3006:
3007: cac_sync_task_map_pkg.delete_row (
3008: p_task_sync_id => rec_modify_repeat.task_sync_id
3009: );
3010:
3011: x_data(i).syncanchor := convert_server_to_gmt (SYSDATE);
3100: END IF; -- l_invalid
3101:
3102: END LOOP;
3103:
3104: FOR rec_new_repeat IN cac_sync_task_cursors.c_new_repeating_task (
3105: p_syncanchor,
3106: p_resource_id,
3107: p_principal_id,
3108: p_resource_type,
3214: END get_collab_id;
3215:
3216:
3217: PROCEDURE create_new_data (
3218: p_task_rec IN OUT NOCOPY cac_sync_task.task_rec,
3219: p_mapping_type IN VARCHAR2,
3220: p_exclusion_tbl IN OUT NOCOPY cac_sync_task.exclusion_tbl,
3221: p_resource_id IN NUMBER,
3222: p_resource_type IN VARCHAR2
3216:
3217: PROCEDURE create_new_data (
3218: p_task_rec IN OUT NOCOPY cac_sync_task.task_rec,
3219: p_mapping_type IN VARCHAR2,
3220: p_exclusion_tbl IN OUT NOCOPY cac_sync_task.exclusion_tbl,
3221: p_resource_id IN NUMBER,
3222: p_resource_type IN VARCHAR2
3223: )
3224: IS
3329: );
3330:
3331:
3332:
3333: l_category_id := cac_sync_task_category.get_category_id (
3334: p_category_name => p_task_rec.category,
3335: p_profile_id => cac_sync_task_category.get_profile_id (p_resource_id)
3336: );
3337:
3331:
3332:
3333: l_category_id := cac_sync_task_category.get_category_id (
3334: p_category_name => p_task_rec.category,
3335: p_profile_id => cac_sync_task_category.get_profile_id (p_resource_id)
3336: );
3337:
3338:
3339: l_subject := get_subject( p_subject => p_task_rec.subject
3731:
3732: cac_sync_common.put_messages_to_result (
3733: p_task_rec,
3734: p_status => 2,
3735: p_user_message => 'cac_sync_task_CREATION_FAILED'
3736: );
3737: END IF; -- end-check if task creation is successed or not
3738:
3739: /*insert_or_update_mapping (
3767:
3768:
3769:
3770: PROCEDURE overwrite_task_record (
3771: p_task_rec IN OUT NOCOPY cac_sync_task.task_rec,
3772: p_resource_id IN NUMBER,
3773: p_resource_type IN VARCHAR2)
3774:
3775: is
3845: open get_task_info('ASSIGNEE',l_task_id);
3846: fetch get_task_info into task_info;
3847:
3848: /* if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
3849: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_sync_task_common.create_new_data', 'point 1 p_task_rec.syncid '||p_task_rec.syncid);
3850: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_sync_task_common.create_new_data', 'point 1 l_task_id '|| l_task_id);
3851: end if;*/
3852:
3853: if ( get_task_info%FOUND) then
3846: fetch get_task_info into task_info;
3847:
3848: /* if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
3849: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_sync_task_common.create_new_data', 'point 1 p_task_rec.syncid '||p_task_rec.syncid);
3850: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_sync_task_common.create_new_data', 'point 1 l_task_id '|| l_task_id);
3851: end if;*/
3852:
3853: if ( get_task_info%FOUND) then
3854:
3970: make_prefix (
3971: p_assignment_status_id => get_assignment_status_id (l_task_id, p_resource_id),
3972: p_source_object_type_code => p_task_rec.objectcode,
3973: p_resource_type => task_info.owner_type_code,
3974: p_resource_id => cac_sync_task.g_login_resource_id,
3975: p_group_id => p_resource_id,
3976: x_subject => task_info.task_name
3977: );
3978:
3978:
3979: p_task_rec.subject := task_info.task_name;
3980:
3981: /* if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
3982: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_sync_task_common.create_new_data', 'point 1 p_task_rec.subject '||p_task_rec.subject);
3983: end if;*/
3984: end if;
3985:
3986: if (get_task_info%ISOPEN) then
4002:
4003:
4004:
4005: PROCEDURE update_existing_data (
4006: p_task_rec IN OUT NOCOPY cac_sync_task.task_rec,
4007: p_exclusion_tbl IN OUT NOCOPY cac_sync_task.exclusion_tbl,
4008: p_resource_id IN NUMBER,
4009: p_resource_type IN VARCHAR2
4010: )
4003:
4004:
4005: PROCEDURE update_existing_data (
4006: p_task_rec IN OUT NOCOPY cac_sync_task.task_rec,
4007: p_exclusion_tbl IN OUT NOCOPY cac_sync_task.exclusion_tbl,
4008: p_resource_id IN NUMBER,
4009: p_resource_type IN VARCHAR2
4010: )
4011: IS
4135: p_task_status_id => p_task_rec.statusid,
4136: p_source_object_type_code => p_task_rec.objectcode
4137: );
4138: */ ---commented out this code as it not used.
4139: /* l_category_id := cac_sync_task_category.get_category_id (
4140: p_category_name => p_task_rec.category,
4141: p_profile_id => cac_sync_task_category.get_profile_id(p_resource_id)
4142: );*/ ---commented out this code as it not used.
4143:
4137: );
4138: */ ---commented out this code as it not used.
4139: /* l_category_id := cac_sync_task_category.get_category_id (
4140: p_category_name => p_task_rec.category,
4141: p_profile_id => cac_sync_task_category.get_profile_id(p_resource_id)
4142: );*/ ---commented out this code as it not used.
4143:
4144: l_update_type := get_update_type (
4145: p_task_id => l_task_id,
4160: repeat_to_nonrepeat:=true;
4161:
4162: if( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
4163:
4164: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_sync_task_common.create_new_data', ' Converting repeating into non-repeating ' );
4165:
4166: end if;
4167:
4168: elsif ((l_rec_rule_id is null) and (p_task_rec.unit_of_measure is not null) ) then
4170: nonrepeat_to_repeat:=true;
4171:
4172: if( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
4173:
4174: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_sync_task_common.create_new_data', ' Converting non-repeating into repeating ' );
4175:
4176: end if;
4177:
4178: end if;
4195: p_repeating_task_id => l_task_id,
4196: p_task_rec => p_task_rec
4197: );
4198: ELSE -- p_exclusion_tbl.COUNT = 0 and check change rule
4199: l_changed_rule := cac_sync_task_common.changed_repeat_rule(p_task_rec => p_task_rec);
4200:
4201: IF l_changed_rule AND
4202: l_update_type = cac_sync_task_common.g_update_all
4203: THEN -- Changed Repeating Rule
4198: ELSE -- p_exclusion_tbl.COUNT = 0 and check change rule
4199: l_changed_rule := cac_sync_task_common.changed_repeat_rule(p_task_rec => p_task_rec);
4200:
4201: IF l_changed_rule AND
4202: l_update_type = cac_sync_task_common.g_update_all
4203: THEN -- Changed Repeating Rule
4204:
4205:
4206: -- include open end dates also
4681: ELSE--IF --(l_update_type=g_do_nothing) then
4682: /*
4683:
4684: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
4685: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_sync_task_common.create_new_data', ' When l_update_type=g_do_nothing for task '|| p_task_rec.subject);
4686: end if;*/
4687: if not (compare_task_rec(p_task_rec)) then -- code added for bug 5264362
4688:
4689: cac_sync_common.put_messages_to_result (
4748:
4749:
4750: PROCEDURE delete_exclusion_task (
4751: p_repeating_task_id IN NUMBER,
4752: x_task_rec IN OUT NOCOPY cac_sync_task.task_rec
4753: )
4754: IS
4755: l_ovn NUMBER;
4756: l_return_status VARCHAR2(1);
4802: END IF;
4803: END delete_exclusion_task;
4804:
4805: PROCEDURE delete_task_data (
4806: p_task_rec IN OUT NOCOPY cac_sync_task.task_rec,
4807: p_delete_map_flag IN BOOLEAN
4808: )
4809: IS
4810:
4827:
4828: IF p_delete_map_flag
4829: THEN
4830:
4831: cac_sync_task_map_pkg.delete_row (
4832: p_task_sync_id => p_task_rec.syncid
4833: );
4834: END IF;
4835:
4847: END IF;
4848:
4849: END delete_task_data;
4850:
4851: PROCEDURE reject_task_data (p_task_rec IN OUT NOCOPY cac_sync_task.task_rec)
4852: IS
4853: l_task_id NUMBER;
4854: l_rec_rule_id NUMBER;
4855: l_task_assignment_id NUMBER;
4915: p_status => g_sync_success,
4916: p_user_message => 'JTA_SYNC_SUCCESS'
4917: );
4918:
4919: cac_sync_task_map_pkg.delete_row(p_task_sync_id => p_task_rec.syncid);
4920: ELSE
4921: cac_sync_common.put_messages_to_result (
4922: p_task_rec,
4923: p_status => 2,
4925: );
4926: END IF;
4927: END reject_task_data;
4928:
4929: FUNCTION changed_repeat_rule (p_task_rec IN cac_sync_task.task_rec)
4930: RETURN BOOLEAN
4931: IS
4932: CURSOR c_task_recur (b_task_id NUMBER)
4933: IS
5034: IF (p_task_status_id = 8)
5035: OR (p_task_status_id = 4)
5036: OR (p_task_status_id = 7)
5037: THEN
5038: x_operation := cac_sync_task_common.g_delete;
5039: END IF;
5040:
5041: IF (p_task_status_id = 12)
5042: OR (p_task_status_id = 15)
5054: OR (NVL (l_rejected_flag, 'N') = 'Y')
5055: OR (NVL (l_completed_flag, 'N') = 'Y')
5056: OR (NVL (l_cancelled_flag, 'N') = 'Y')
5057: THEN
5058: x_operation := cac_sync_task_common.g_delete;
5059: END IF;
5060: CLOSE c_task_status;
5061: END IF;
5062:
5072: OR (NVL (l_rejected_flag, 'N') = 'Y')
5073: OR (NVL (l_completed_flag, 'N') = 'Y')
5074: OR (NVL (l_cancelled_flag, 'N') = 'Y')
5075: THEN
5076: x_operation := cac_sync_task_common.g_delete;
5077: ELSIF (NVL (l_assigned_flag, 'N') = 'Y')
5078: THEN p_task_status_id := 12;
5079: ELSIF (NVL (l_working_flag, 'N') = 'Y')
5080: THEN p_task_status_id := 15;
5086: THEN p_task_status_id := 16;
5087: ELSIF (NVL (l_approved_flag, 'N') = 'Y')
5088: THEN p_task_status_id := 15;
5089: END IF;
5090: x_operation := cac_sync_task_common.g_modify;
5091:
5092: CLOSE c_task_status;
5093:
5094: END IF;
5170: fnd_message.set_name('JTF', 'JTA_SYNC_APPL_ERROR');
5171: fnd_msg_pub.add;
5172:
5173: fnd_message.set_name('JTF', 'JTA_SYNC_INVALID_SYNCID');
5174: fnd_message.set_token('PROC_NAME','cac_sync_task_COMMON.GET_TASK_ID');
5175: fnd_msg_pub.add;
5176:
5177: raise_application_error (-20100,cac_sync_common.get_messages);
5178: END IF;
5286: fetch getBookings into p_getBookings ;
5287:
5288: /* if (getBookings%NOTFOUND) then
5289: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
5290: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_sync_task_common.delete_booking', 'no booking is found for the principal id ' || p_principal_id);
5291: end if;
5292: else
5293:
5294: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
5291: end if;
5292: else
5293:
5294: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
5295: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_sync_task_common.delete_booking', 'booking is found for the principal id ' || p_principal_id);
5296: end if;
5297:
5298: end if;*/
5299:
5306:
5307:
5308: IF cac_sync_common.is_success (l_return_status)
5309: THEN
5310: cac_sync_task_map_pkg.delete_row (
5311: p_task_sync_id => p_getBookings.task_sync_id);
5312:
5313: /* if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
5314: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_sync_task_common.delete_booking', 'success from cac_bookings_pub.delete_booking');
5310: cac_sync_task_map_pkg.delete_row (
5311: p_task_sync_id => p_getBookings.task_sync_id);
5312:
5313: /* if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
5314: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_sync_task_common.delete_booking', 'success from cac_bookings_pub.delete_booking');
5315: end if;
5316:
5317: else --failure from delete_booking API
5318:
5316:
5317: else --failure from delete_booking API
5318:
5319: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
5320: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_sync_task_common.delete_booking', 'failure from cac_bookings_pub.delete_booking');
5321: end if;
5322: */
5323:
5324: END IF;
5334:
5335:
5336:
5337: function is_recur_rule_same (
5338: p_task_rec IN OUT NOCOPY cac_sync_task.task_rec
5339:
5340: ) return boolean
5341: IS
5342:
5360:
5361: BEGIN
5362:
5363: l_task_id:=get_task_id (p_sync_id=>p_task_rec.syncid );
5364: cac_sync_task_common.get_resource_details (l_resource_id, l_resource_type);
5365:
5366: l_update_type := get_update_type (
5367: p_task_id => l_task_id,
5368: p_resource_id => l_resource_id,
5570:
5571: END is_appointment_existing;
5572:
5573:
5574: END CAC_SYNC_TASK_COMMON ;