The following lines contain the word 'select', 'insert', 'update' or 'delete':
SELECT /*+ INDEX (acc CSM_TASK_ASSIGNMENTS_ACC_U1)*/
acc.task_assignment_id,
jt.task_id,
jt.source_object_type_code
FROM csm_task_assignments_acc acc,
jtf_task_assignments jta,
jtf_tasks_b jt,
jtf_task_statuses_b jts,
jtf_task_statuses_b jts_jta
WHERE acc.task_assignment_id = jta.task_assignment_id
AND jt.task_id = jta.task_id
AND (jt.scheduled_start_date
< (SYSDATE - csm_profile_pkg.get_task_history_days(acc.user_id)))
AND jts.task_status_id = jt.task_status_id
AND jts_jta.task_status_id = jta.assignment_status_id
AND (jts.cancelled_flag = 'Y' OR jts.closed_flag = 'Y'
OR jts.completed_flag = 'Y' OR jts.rejected_flag = 'Y'
OR jts_jta.cancelled_flag = 'Y' OR jts_jta.closed_flag = 'Y'
OR jts_jta.completed_flag = 'Y' OR jts_jta.rejected_flag = 'Y')
AND NOT EXISTS (SELECT 'x'
FROM csm_service_history_acc hist,
cs_incidents_all_b cia,
cs_incident_statuses_b ists
WHERE hist.user_id = acc.user_id
AND hist.history_incident_id = jt.source_object_id
AND jt.source_object_type_code = 'SR'
AND hist.incident_id = cia.incident_id
AND cia.INCIDENT_STATUS_ID = ists.INCIDENT_STATUS_ID
AND NVL(ists.CLOSE_FLAG, 'N') <> 'Y');
SELECT 1
FROM jtm_con_request_data
WHERE product_code = 'CSM'
AND package_name = 'CSM_TASK_ASSIGNMENT_EVENT_PKG'
AND procedure_name = 'PURGE_TASK_ASSIGNMENTS_CONC'
FOR UPDATE OF last_run_date NOWAIT
;
l_purge_task_tbl.DELETE;
l_task_src_type_tbl.DELETE;
--Delete SR tasks only if the corresponding SR is closed
IF l_task_src_type_tbl(i) ='SR' AND CSM_SR_EVENT_PKG.IS_SR_OPEN(l_task_id) = FALSE THEN
csm_task_assignment_event_pkg.TASK_ASSIGNMENT_PURGE_INIT(p_task_assignment_id=>l_task_assignment_id,
p_error_msg=>l_error_msg,
x_return_status=>l_return_status);
UPDATE jtm_con_request_data
SET last_run_date = l_last_run_date
WHERE CURRENT OF l_upd_last_run_date_csr;
SELECT dh.debrief_header_id
FROM csf_debrief_headers dh
WHERE dh.task_assignment_id =p_task_assg_id
AND NOT EXISTS
(SELECT 1
FROM csm_debrief_headers_acc acc
WHERE acc.debrief_header_id = dh.debrief_header_id
AND acc.user_id = p_user_id);
SELECT dl.debrief_line_id,
dh.debrief_header_id
FROM csf_debrief_lines dl,
csf_debrief_headers dh
WHERE dh.task_assignment_id =p_task_assg_id
AND dl.debrief_header_id = dh.debrief_header_id
AND NOT EXISTS
(SELECT 1
FROM csm_debrief_lines_acc acc
WHERE acc.debrief_line_id = dl.debrief_line_id
AND acc.user_id = p_user_id);
SELECT hdr.requirement_header_id,
jta.resource_id
FROM jtf_task_assignments jta,
csp_requirement_headers hdr
WHERE jta.task_assignment_id = p_task_assg_id
AND hdr.task_id = jta.task_id
AND NOT EXISTS
(SELECT 1
FROM csm_req_headers_acc acc
WHERE acc.requirement_header_id = hdr.requirement_header_id
AND acc.user_id = p_user_id
);
SELECT line.requirement_line_id
FROM jtf_task_assignments jta,
csp_requirement_headers hdr,
csp_requirement_lines line,
asg_user au
WHERE jta.task_assignment_id = p_task_assg_id
AND hdr.task_id = jta.task_id
AND line.requirement_header_id = hdr.requirement_header_id
AND au.resource_id=jta.resource_id
AND au.user_id=p_user_id
AND NOT EXISTS
(SELECT 1
FROM csm_req_lines_acc acc
WHERE acc.requirement_line_id = line.requirement_line_id
AND acc.user_id = au.user_id
);
FOR rec IN (SELECT req_line_detail_id from csp_req_line_details WHERE requirement_line_id=r_req_lines_rec.requirement_line_id)
LOOP
CSM_CSP_REQ_LINES_EVENT_PKG.REQ_LINE_DTL_IUD(rec.req_line_detail_id,'I');
SELECT 1
FROM csm_tasks_acc
WHERE user_id = p_user_id
AND task_id = p_task_id;
csm_task_event_pkg.acc_insert(p_task_id=>p_task_id, p_user_id=>p_user_id);
csm_task_assignment_event_pkg.acc_insert(p_task_assignment_id=>p_task_assignment_id,
p_user_id=>p_user_id);
PROCEDURE ACC_INSERT(p_task_assignment_id IN NUMBER, p_user_id IN NUMBER)
IS
l_sqlerrno VARCHAR2(20);
CSM_UTIL_PKG.LOG('Entering ACC_INSERT for task_assignment_id: ' || p_task_assignment_id,
'CSM_TASK_ASSIGNMENT_EVENT_PKG.ACC_INSERT',FND_LOG.LEVEL_PROCEDURE);
CSM_ACC_PKG.Insert_Acc
( P_PUBLICATION_ITEM_NAMES => g_pubi_name
,P_ACC_TABLE_NAME => g_acc_table_name
,P_SEQ_NAME => g_acc_seq_name
,P_PK1_NAME => g_pk1_name
,P_PK1_NUM_VALUE => p_task_assignment_id
,P_USER_ID => p_user_id
);
CSM_UTIL_PKG.LOG('Leaving ACC_INSERT for task_assignment_id: ' || p_task_assignment_id,
'CSM_TASK_ASSIGNMENT_EVENT_PKG.ACC_INSERT',FND_LOG.LEVEL_PROCEDURE);
l_error_msg := ' Exception in ACC_INSERT for task_assignment_id:'
|| to_char(p_task_assignment_id) || ':' || l_sqlerrno || ':' || l_sqlerrmsg;
CSM_UTIL_PKG.LOG(l_error_msg, 'CSM_TASK_ASSIGNMENT_EVENT_PKG.ACC_INSERT',FND_LOG.LEVEL_EXCEPTION);
END ACC_INSERT;
CSM_LOBS_EVENT_PKG.INSERT_ACC_RECORD(p_task_assignment_id, p_resource_id);
SELECT au.user_id,
jta.resource_id,
jta.task_id,
csi.incident_id,
csi.customer_id,
hz_ps.party_site_id,
hz_ps.party_id,
csi.inventory_item_id,
csi.inv_organization_id,
csi.contract_service_id,
csi.customer_product_id,
hz_ps.location_id,
jt.source_object_type_code,
csi.incident_location_type,
jt.address_id,
csi.org_id
FROM JTF_TASK_ASSIGNMENTS jta,
asg_user au,
asg_user_pub_resps aupr,
jtf_tasks_b jt,
cs_incidents_all_b csi,
hz_party_sites hz_ps
WHERE jta.task_assignment_id = p_taskassgid
AND jta.assignee_role = 'ASSIGNEE'
AND au.resource_id = jta.resource_id
AND au.user_name = aupr.user_name
AND aupr.pub_name = 'SERVICEP'
AND jt.task_id = jta.task_id
AND jt.source_object_type_code = 'SR'
AND jt.source_object_id = csi.incident_id
AND hz_ps.party_site_id = NVL(csi.incident_location_id, jt.ADDRESS_ID)
AND NVL(csi.incident_location_type,'HZ_PARTY_SITE')='HZ_PARTY_SITE'
UNION
SELECT au.user_id,
jta.resource_id,
jta.task_id,
csi.incident_id,
csi.customer_id,
NULL,
csi.customer_id,
csi.inventory_item_id,
csi.inv_organization_id,
csi.contract_service_id,
csi.customer_product_id,
lc.location_id,
jt.source_object_type_code,
csi.incident_location_type,
jt.address_id,
csi.org_id
FROM JTF_TASK_ASSIGNMENTS jta,
asg_user au,
asg_user_pub_resps aupr,
jtf_tasks_b jt,
cs_incidents_all_b csi,
hz_locations lc
WHERE jta.task_assignment_id = p_taskassgid
AND jta.assignee_role = 'ASSIGNEE'
AND au.resource_id = jta.resource_id
AND au.user_name = aupr.user_name
AND aupr.pub_name = 'SERVICEP'
AND jt.task_id = jta.task_id
AND jt.source_object_type_code = 'SR'
AND jt.source_object_id = csi.incident_id
AND lc.location_id = NVL(jt.LOCATION_ID,csi.incident_location_id)
AND csi.incident_location_type='HZ_LOCATION'
UNION
SELECT au.user_id,
jta.resource_id,
jta.task_id,
to_number(NULL),
to_number(NULL),
to_number(NULL),
to_number(NULL),
to_number(NULL),
to_number(NULL),
to_number(NULL),
to_number(NULL),
to_number(NULL),
jt.source_object_type_code,
to_char(NULL),
jt.address_id,
to_number(NULL)
FROM JTF_TASK_ASSIGNMENTS jta,
asg_user au,
asg_user_pub_resps aupr,
jtf_tasks_b jt
WHERE jta.task_assignment_id = p_taskassgid
AND jta.assignee_role = 'ASSIGNEE'
AND au.resource_id = jta.resource_id
AND au.user_name = aupr.user_name
AND aupr.pub_name = 'SERVICEP'
AND jt.task_id = jta.task_id
AND (jt.source_object_type_code = 'TASK' OR jt.source_object_type_code IS NULL);
--insert location for the task
CSM_HZ_LOCATIONS_EVENT_PKG.insert_location(p_location_id => l_taskassgdetails_rec.location_id,
p_user_id => l_taskassgdetails_rec.user_id);
--insert Accounts for the above party-R12
CSM_CUSTOMER_ACCOUNT_EVENT_PKG.CUST_ACCOUNTS_INS
(p_party_id=> l_taskassgdetails_rec.customer_id
,p_user_id => l_taskassgdetails_rec.user_id);
CSM_UTIL_PKG.LOG('Inserting task address for htm user','CSM_TASK_ASSIGNMENT_EVENT_PKG.TASK_ASSIGNMENT_INITIALIZER',FND_LOG.LEVEL_PROCEDURE);
SELECT jta.resource_id,
jta.task_id,
csi.incident_id,
csi.customer_id,
NVL(csi.incident_location_id, jt.ADDRESS_ID) AS incident_location_id,
hz_ps.party_site_id,
hz_ps.party_id,
csi.inventory_item_id,
csi.inv_organization_id,
csi.contract_service_id,
csi.customer_product_id,
hz_ps.location_id,
jt.source_object_type_code,
csi.incident_location_type
FROM JTF_TASK_ASSIGNMENTS jta,
jtf_tasks_b jt,
cs_incidents_all_b csi,
hz_party_sites hz_ps
WHERE jta.task_assignment_id = p_taskassgid
AND jt.task_id = jta.task_id
AND jt.source_object_type_code = 'SR'
AND jt.source_object_id = csi.incident_id
AND hz_ps.party_site_id = NVL(csi.incident_location_id, jt.ADDRESS_ID) -- csi.install_site_use_id
AND NVL(csi.incident_location_type,'HZ_PARTY_SITE')='HZ_PARTY_SITE'
UNION
SELECT jta.resource_id,
jta.task_id,
csi.incident_id,
csi.customer_id,
NVL(csi.incident_location_id, jt.ADDRESS_ID) AS incident_location_id,
NULL,
csi.customer_id,
csi.inventory_item_id,
csi.inv_organization_id,
csi.contract_service_id,
csi.customer_product_id,
lc.location_id,
jt.source_object_type_code,
csi.incident_location_type
FROM JTF_TASK_ASSIGNMENTS jta,
jtf_tasks_b jt,
cs_incidents_all_b csi,
hz_locations lc
WHERE jta.task_assignment_id = p_taskassgid
AND jt.task_id = jta.task_id
AND jt.source_object_type_code = 'SR'
AND jt.source_object_id = csi.incident_id
AND lc.location_id = NVL(jt.LOCATION_ID,csi.incident_location_id) -- csi.install_site_use_id;
--insert location for the sr
CSM_HZ_LOCATIONS_EVENT_PKG.insert_location(p_location_id => l_taskassgdetails_rec.location_id,
p_user_id => p_user_id);
--insert Accounts for the above party-R12
CSM_CUSTOMER_ACCOUNT_EVENT_PKG.CUST_ACCOUNTS_INS
(p_party_id=> l_taskassgdetails_rec.customer_id
,p_user_id => p_user_id);
SELECT /*+ INDEX (acc CSM_TASK_ASSIGNMENTS_ACC_U1)*/ au.user_id,
au.resource_id,
jt.task_id,
csi.incident_id,
csi.customer_id,
NVL(csi.incident_location_id, jt.ADDRESS_ID) AS incident_location_id,
hz_ps.party_id,
csi.inventory_item_id,
csi.inv_organization_id,
csi.contract_service_id,
csi.customer_product_id,
hz_ps.location_id,
jt.source_object_type_code,
csi.incident_location_type,
jt.ADDRESS_ID,
csi.org_id
FROM csm_task_assignments_acc acc,
jtf_task_assignments jta,
asg_user au,
asg_user_pub_resps aupr,
jtf_tasks_b jt,
cs_incidents_all_b csi,
hz_party_sites hz_ps
WHERE acc.task_assignment_id = p_task_assignment_id
AND acc.task_assignment_id = jta.task_assignment_id
AND acc.user_id = au.user_id
AND au.user_name = aupr.user_name
AND aupr.pub_name = 'SERVICEP'
AND jta.task_id = jt.task_id
AND jt.source_object_type_code = 'SR'
AND jt.source_object_id = csi.INCIDENT_ID
AND hz_ps.party_site_id = NVL(csi.incident_location_id, jt.ADDRESS_ID)
AND NVL(csi.incident_location_type,'HZ_PARTY_SITE')='HZ_PARTY_SITE'
UNION
SELECT /*+ INDEX (acc CSM_TASK_ASSIGNMENTS_ACC_U1)*/ au.user_id,
au.resource_id,
jt.task_id,
csi.incident_id,
csi.customer_id,
NVL(csi.incident_location_id, jt.ADDRESS_ID) AS incident_location_id,
csi.customer_id,
csi.inventory_item_id,
csi.inv_organization_id,
csi.contract_service_id,
csi.customer_product_id,
lc.location_id,
jt.source_object_type_code,
csi.incident_location_type,
jt.ADDRESS_ID,
csi.org_id
FROM csm_task_assignments_acc acc,
jtf_task_assignments jta,
asg_user au,
asg_user_pub_resps aupr,
jtf_tasks_b jt,
cs_incidents_all_b csi,
hz_locations lc
WHERE acc.task_assignment_id = p_task_assignment_id
AND acc.task_assignment_id = jta.task_assignment_id
AND acc.user_id = au.user_id
AND au.user_name = aupr.user_name
AND aupr.pub_name = 'SERVICEP'
AND jta.task_id = jt.task_id
AND jt.source_object_type_code = 'SR'
AND jt.source_object_id = csi.INCIDENT_ID
AND lc.location_id = NVL(jt.LOCATION_ID,csi.incident_location_id)
AND csi.incident_location_type='HZ_LOCATION'
UNION
SELECT /*+ INDEX (acc CSM_TASK_ASSIGNMENTS_ACC_U1)*/ au.user_id,
au.resource_id,
jt.task_id,
TO_NUMBER(NULL),
TO_NUMBER(NULL),
TO_NUMBER(NULL),
TO_NUMBER(NULL),
TO_NUMBER(NULL),
TO_NUMBER(NULL),
TO_NUMBER(NULL),
TO_NUMBER(NULL),
TO_NUMBER(NULL),
jt.source_object_type_code,
TO_CHAR(NULL),
jt.ADDRESS_ID,
TO_NUMBER(NULL)
FROM csm_task_assignments_acc acc,
JTF_TASK_ASSIGNMENTS jta,
asg_user au,
asg_user_pub_resps aupr,
jtf_tasks_b jt
WHERE acc.task_assignment_id = p_task_assignment_id
AND acc.task_assignment_id = jta.task_assignment_id
AND acc.user_id = au.user_id
AND au.user_name = aupr.user_name
AND aupr.pub_name = 'SERVICEP'
AND jt.task_id = jta.task_id
AND (jt.source_object_type_code = 'TASK' OR jt.source_object_type_code IS NULL);
-- delete SR notes
IF l_task_assg_purge_rec.incident_id IS NOT NULL THEN
csm_notes_event_pkg.notes_make_dirty_d_grp(p_sourceobjectcode=>'SR',
p_sourceobjectid=>l_task_assg_purge_rec.incident_id,
p_userid=>l_task_assg_purge_rec.user_id,
p_error_msg=>l_error_msg,
x_return_status=>l_return_status);
-- delete contract notes
IF l_task_assg_purge_rec.contract_service_id IS NOT NULL THEN
csm_notes_event_pkg.notes_make_dirty_d_grp(p_sourceobjectcode=>'OKS_COV_NOTE',
p_sourceobjectid=>l_task_assg_purge_rec.contract_service_id,
p_userid=>l_task_assg_purge_rec.user_id,
p_error_msg=>l_error_msg,
x_return_status=>l_return_status);
--delete location for the sr
CSM_HZ_LOCATIONS_EVENT_PKG.delete_location(p_location_id => l_task_assg_purge_rec.location_id,
p_user_id => l_task_assg_purge_rec.user_id);
--Delete Accounts for the above party-R12
CSM_CUSTOMER_ACCOUNT_EVENT_PKG.CUST_ACCOUNTS_DEL
(p_party_id=>l_task_assg_purge_rec.customer_id
,p_user_id =>l_task_assg_purge_rec.user_id);
csm_service_history_event_pkg.delete_history(p_task_assignment_id=>p_task_assignment_id,
p_incident_id=>l_task_assg_purge_rec.incident_id,
p_user_id=>l_task_assg_purge_rec.user_id);
CSM_LOBS_EVENT_PKG.DELETE_ACC_RECORD(p_task_assignment_id, p_resource_id);
SELECT hdr.debrief_header_id
FROM csm_debrief_headers_acc acc,
csf_debrief_headers hdr
WHERE hdr.task_assignment_id = p_task_assg_id
AND acc.debrief_header_id = hdr.debrief_header_id
AND acc.user_id = p_user_id
;
SELECT dl.debrief_line_id,
dl.debrief_header_id
FROM csm_debrief_lines_acc acc,
csF_debrief_headers hdr,
csf_debrief_lines dl
WHERE hdr.task_assignment_id = p_task_assg_id
AND hdr.DEBRIEF_HEADER_ID = dl.DEBRIEF_HEADER_ID
AND acc.debrief_line_id = dl.debrief_line_id
AND acc.user_id = p_user_id
;
SELECT hdr.requirement_header_id,
jta.resource_id
FROM jtf_task_assignments jta,
csp_requirement_headers hdr
WHERE jta.task_assignment_id = p_task_assg_id
AND hdr.task_id = jta.task_id
AND EXISTS
(SELECT 1
FROM csm_req_headers_acc acc
WHERE acc.requirement_header_id = hdr.requirement_header_id
AND acc.user_id = p_user_id
);
SELECT line.requirement_line_id,
line.requirement_header_id,
acc.user_id
FROM jtf_task_assignments jta,
csp_requirement_headers hdr,
csp_requirement_lines line,
csm_req_lines_acc acc
WHERE jta.task_assignment_id = p_task_assg_id
AND hdr.task_id = jta.task_id
AND line.requirement_header_id = hdr.requirement_header_id
AND acc.requirement_line_id = line.requirement_line_id
AND acc.user_id=p_user_id;
FOR rec IN (SELECT req_line_detail_id from csp_req_line_details WHERE requirement_line_id=r_req_lines_rec.requirement_line_id)
LOOP
CSM_CSP_REQ_LINES_EVENT_PKG.REQ_LINE_DTL_IUD(rec.req_line_detail_id,'D');
csm_task_event_pkg.acc_delete(p_user_id=>p_user_id, p_task_id=>p_task_id);
csm_task_assignment_event_pkg.acc_delete(p_task_assignment_id=>p_task_assignment_id,
p_user_id=>p_user_id);
PROCEDURE ACC_DELETE(p_task_assignment_id IN NUMBER, p_user_id IN NUMBER)
IS
l_sqlerrno VARCHAR2(20);
CSM_UTIL_PKG.LOG('Entering ACC_DELETE for task_assignment_id: ' || p_task_assignment_id,
'CSM_TASK_ASSIGNMENT_EVENT_PKG.ACC_DELETE',FND_LOG.LEVEL_PROCEDURE);
CSM_ACC_PKG.Delete_Acc
( P_PUBLICATION_ITEM_NAMES => g_pubi_name
,P_ACC_TABLE_NAME => g_acc_table_name
,P_PK1_NAME => g_pk1_name
,P_PK1_NUM_VALUE => p_task_assignment_id
,P_USER_ID => p_user_id
);
CSM_UTIL_PKG.LOG('Leaving ACC_DELETE for task_assignment_id: ' || p_task_assignment_id,
'CSM_TASK_ASSIGNMENT_EVENT_PKG.ACC_DELETE',FND_LOG.LEVEL_PROCEDURE);
l_error_msg := ' Exception in ACC_DELETE for task_assignment_id:'
|| to_char(p_task_assignment_id) || ':' || l_sqlerrno || ':' || l_sqlerrmsg;
CSM_UTIL_PKG.LOG(l_error_msg, 'CSM_TASK_ASSIGNMENT_EVENT_PKG.ACC_DELETE',FND_LOG.LEVEL_EXCEPTION);
END ACC_DELETE;
SELECT jta.resource_id,
jta.task_id,
csi.incident_id,
csi.customer_id,
NVL(csi.incident_location_id, jt.ADDRESS_ID) AS incident_location_id,
hz_ps.party_site_id,
hz_ps.party_id,
csi.inventory_item_id,
csi.inv_organization_id,
csi.contract_service_id,
csi.customer_product_id,
hz_ps.location_id,
jt.source_object_type_code,
csi.incident_location_type
FROM JTF_TASK_ASSIGNMENTS jta,
jtf_tasks_b jt,
cs_incidents_all_b csi,
hz_party_sites hz_ps
WHERE jta.task_assignment_id = p_task_assignment_id
AND jt.task_id = jta.task_id
AND jt.source_object_type_code = 'SR'
AND jt.source_object_id = csi.incident_id
AND hz_ps.party_site_id = NVL(csi.incident_location_id, jt.ADDRESS_ID) -- csi.install_site_use_id
AND NVL(csi.incident_location_type,'HZ_PARTY_SITE')='HZ_PARTY_SITE'
UNION
SELECT jta.resource_id,
jta.task_id,
csi.incident_id,
csi.customer_id,
NVL(csi.incident_location_id, jt.ADDRESS_ID) AS incident_location_id,
NULL,
csi.customer_id,
csi.inventory_item_id,
csi.inv_organization_id,
csi.contract_service_id,
csi.customer_product_id,
lc.location_id,
jt.source_object_type_code,
csi.incident_location_type
FROM JTF_TASK_ASSIGNMENTS jta,
jtf_tasks_b jt,
cs_incidents_all_b csi,
hz_locations lc
WHERE jta.task_assignment_id = p_task_assignment_id
AND jt.task_id = jta.task_id
AND jt.source_object_type_code = 'SR'
AND jt.source_object_id = csi.incident_id
AND lc.location_id = NVL(jt.LOCATION_ID,csi.incident_location_id ) -- csi.install_site_use_id;
--insert location for the sr
csm_hz_locations_event_pkg.delete_location(p_location_id => l_TaskAssgHistPurge_rec.location_id,
p_user_id => p_user_id);
--Delete Accounts for the above party-R12
CSM_CUSTOMER_ACCOUNT_EVENT_PKG.CUST_ACCOUNTS_DEL
(p_party_id=> l_TaskAssgHistPurge_rec.customer_id
,p_user_id => p_user_id);