The following lines contain the word 'select', 'insert', 'update' or 'delete':
/* description : Validation checks for before inserting */
/* new record as well before modification */
/* takes place */
/*---------------------------------------------------------*/
G_DEBUG VARCHAR2(1):=AHL_DEBUG_PUB.is_log_enabled;
P_DELETE_FLAG IN VARCHAR2 := 'N')
IS
-- Cursor to retrieve the status code from fnd lookups table
CURSOR get_status_code(c_status_code VARCHAR2)
IS
SELECT lookup_code
FROM FND_LOOKUP_VALUES_VL
WHERE lookup_code = c_status_code
AND lookup_type = 'AHL_SUBSCRIBE_STATUS_TYPE'
AND sysdate between start_date_active
AND nvl(end_date_active,sysdate);
SELECT lookup_code
FROM FND_LOOKUP_VALUES_VL
WHERE lookup_code = c_frequency_code
AND lookup_type = 'AHL_FREQUENCY_TYPE'
AND sysdate between start_date_active
AND nvl(end_date_active,sysdate);
SELECT lookup_code
FROM FND_LOOKUP_VALUES_VL
WHERE lookup_code = c_subscription_type_code
AND lookup_type = 'AHL_SUBSCRIPTION_TYPE'
AND sysdate between start_date_active
AND nvl(end_date_active,sysdate);
SELECT lookup_code
FROM FND_LOOKUP_VALUES_VL
WHERE lookup_code = c_media_type_code
AND lookup_type = 'AHL_MEDIA_TYPE'
AND sysdate between start_date_active
AND nvl(end_date_active,sysdate);
SELECT 'x'
FROM AHL_SUPPLIER_DOCUMENTS S
WHERE S.supplier_id = c_subscribed_frm_pty_id;
SELECT 'x'
FROM AHL_SUPPLIER_DOCUMENTS S
WHERE S.supplier_id = c_subscribed_frm_pty_id
AND S.document_id = c_document_id;
SELECT 'X'
FROM AHL_DOCUMENTS_B
WHERE document_id = c_document_id;
SELECT document_id,
status_code,
requested_by_party_id,
quantity,
frequency_code,
subscribed_frm_party_id,
start_date,
end_date,
media_type_code
FROM AHL_SUBSCRIPTIONS_B
WHERE subscription_id = c_subscription_id;
SELECT 'X'
FROM AHL_SUBSCRIPTIONS_B
WHERE document_id = c_document_id
AND requested_by_party_id = c_requested_by_party_id;
SELECT party_name
FROM ahl_hz_per_employees_v
WHERE party_id= c_requested_by_party_id;
SELECT PARTY_NAME
FROM HZ_PARTIES
WHERE party_id= c_requested_by_party_id
AND PARTY_TYPE ='PERSON';
SELECT PPF.FULL_NAME
FROM PER_PEOPLE_F PPF, PER_PERSON_TYPES PPT
WHERE PPF.PERSON_ID= c_requested_by_party_id
AND TRUNC(SYSDATE) BETWEEN PPF.EFFECTIVE_START_DATE AND PPF.EFFECTIVE_END_DATE
AND NVL(PPF.CURRENT_EMPLOYEE_FLAG, 'X') = 'Y'
AND PPF.PERSON_TYPE_ID = PPT.PERSON_TYPE_ID
AND PPT.SYSTEM_PERSON_TYPE ='EMP';
SELECT distinct segment1
FROM PO_HEADERS_V
WHERE nvl(approved_flag, 'N')='Y' and upper(segment1) = upper(c_ponumber);
IF (NVL(p_delete_flag, 'N') = 'N' )
THEN
IF G_DEBUG='Y' THEN
AHL_DEBUG_PUB.enable_debug;
SELECT AHL_DI_DOC_INDEX_PVT.GET_PRODUCT_INSTALL_STATUS('PER')
INTO l_prod_install_status
FROM DUAL;
p_delete_flag =>p_x_subscription_tbl(i).delete_flag
);
Select AHL_SUBSCRIPTIONS_B_S.Nextval Into
l_subscription_id from dual;
/* procedure name: AHL_SUBSCRIPTIONS_PKG.INSERT_ROW */
/* description : Added by Senthil to call Table Handler */
/* Date : Dec 31 2001 */
/*---------------------------------------------------------*/
-- Insert the new record into subscriptions table and trans table
AHL_SUBSCRIPTIONS_PKG.INSERT_ROW (
X_ROWID => l_rowid,
X_SUBSCRIPTION_ID => l_subscription_id,
X_ATTRIBUTE5 => l_subscription_info.attribute5,
X_DOCUMENT_ID => p_x_subscription_tbl(i).document_id,
X_REQUESTED_BY_PARTY_ID => p_x_subscription_tbl(i).requested_by_party_id,
X_ATTRIBUTE6 => l_subscription_info.attribute6,
X_ATTRIBUTE7 => l_subscription_info.attribute7,
X_ATTRIBUTE8 => l_subscription_info.attribute8,
X_ATTRIBUTE9 => l_subscription_info.attribute9,
X_ATTRIBUTE10 => l_subscription_info.attribute10,
X_ATTRIBUTE11 => l_subscription_info.attribute11,
X_ATTRIBUTE12 => l_subscription_info.attribute12,
X_ATTRIBUTE13 => l_subscription_info.attribute13,
X_ATTRIBUTE14 => l_subscription_info.attribute14,
X_ATTRIBUTE_CATEGORY => l_subscription_info.attribute_category,
X_ATTRIBUTE1 => l_subscription_info.attribute1,
X_ATTRIBUTE2 => l_subscription_info.attribute2,
X_ATTRIBUTE3 => l_subscription_info.attribute3,
X_ATTRIBUTE4 => l_subscription_info.attribute4,
X_OBJECT_VERSION_NUMBER => 1,
X_ATTRIBUTE15 => l_subscription_info.attribute15,
X_SUBSCRIBED_FRM_PARTY_ID => l_subscription_info.subscribed_frm_party_id,
X_QUANTITY => p_x_subscription_tbl(i).quantity,
X_STATUS_CODE => p_x_subscription_tbl(i).status_code,
X_PURCHASE_ORDER_NO => l_subscription_info.purchase_order_no,
X_FREQUENCY_CODE => l_subscription_info.frequency_code,
X_SUBSCRIPTION_TYPE_CODE => l_subscription_info.subscription_type_code,
X_MEDIA_TYPE_CODE => l_subscription_info.media_type_code,
X_START_DATE => l_subscription_info.start_date,
X_END_DATE => l_subscription_info.end_date,
X_COMMENTS => l_subscription_info.comments,
X_CREATION_DATE => sysdate,
X_CREATED_BY => fnd_global.user_id,
X_LAST_UPDATE_DATE => sysdate,
X_LAST_UPDATED_BY => fnd_global.user_id,
X_LAST_UPDATE_LOGIN => fnd_global.login_id
) ;
INSERT INTO AHL_SUBSCRIPTIONS_B
(
SUBSCRIPTION_ID,
DOCUMENT_ID,
STATUS_CODE,
REQUESTED_BY_PARTY_ID,
QUANTITY,
FREQUENCY_CODE,
SUBSCRIBED_FRM_PARTY_ID,
START_DATE,
END_DATE,
PURCHASE_ORDER_NO,
SUBSCRIPTION_TYPE_CODE,
MEDIA_TYPE_CODE,
OBJECT_VERSION_NUMBER,
ATTRIBUTE_CATEGORY,
ATTRIBUTE1,
ATTRIBUTE2,
ATTRIBUTE3,
ATTRIBUTE4,
ATTRIBUTE5,
ATTRIBUTE6,
ATTRIBUTE7,
ATTRIBUTE8,
ATTRIBUTE9,
ATTRIBUTE10,
ATTRIBUTE11,
ATTRIBUTE12,
ATTRIBUTE13,
ATTRIBUTE14,
ATTRIBUTE15,
LAST_UPDATE_DATE,
LAST_UPDATED_BY,
CREATION_DATE,
CREATED_BY,
LAST_UPDATE_LOGIN
)
VALUES
(
l_subscription_id,
p_x_subscription_tbl(i).document_id,
p_x_subscription_tbl(i).status_code,
p_x_subscription_tbl(i).requested_by_party_id,
p_x_subscription_tbl(i).quantity,
l_subscription_info.frequency_code,
l_subscription_info.subscribed_frm_party_id,
l_subscription_info.start_date,
l_subscription_info.end_date,
l_subscription_info.purchase_order_no,
l_subscription_info.subscription_type_code,
l_subscription_info.media_type_code,
1,
l_subscription_info.attribute_category,
l_subscription_info.attribute1,
l_subscription_info.attribute2,
l_subscription_info.attribute3,
l_subscription_info.attribute4,
l_subscription_info.attribute5,
l_subscription_info.attribute6,
l_subscription_info.attribute7,
l_subscription_info.attribute8,
l_subscription_info.attribute9,
l_subscription_info.attribute10,
l_subscription_info.attribute11,
l_subscription_info.attribute12,
l_subscription_info.attribute13,
l_subscription_info.attribute14,
l_subscription_info.attribute15,
sysdate,
fnd_global.user_id,
sysdate,
fnd_global.user_id,
fnd_global.login_id
);
INSERT INTO AHL_SUBSCRIPTIONS_TL
(
SUBSCRIPTION_ID,
LAST_UPDATE_DATE,
LAST_UPDATED_BY,
CREATION_DATE,
CREATED_BY,
COMMENTS,
LANGUAGE,
SOURCE_LANG
)
SELECT
l_subscription_id,
sysdate,
fnd_global.user_id,
sysdate,
fnd_global.user_id,
l_subscription_info.comments,
L.LANGUAGE_CODE,
userenv('LANG')
FROM FND_LANGUAGES L
WHERE L.INSTALLED_FLAG IN ('I','B')
AND NOT EXISTS
(SELECT NULL
FROM AHL_SUBSCRIPTIONS_TL T
WHERE T.subscription_id = l_subscription_id
AND T.language = L.LANGUAGE_CODE);
SELECT subscribe_to_flag
INTO l_subscribe_to_flag
FROM AHL_DOCUMENTS_B
WHERE document_id = p_x_subscription_tbl(i).document_id;
UPDATE AHL_DOCUMENTS_B
SET subscribe_to_flag = 'Y'
WHERE document_id = p_x_subscription_tbl(i).document_id;
/* description : Update the existing subscription recor*/
/* d and removes the subscription record */
/* for an associated document */
/* */
/*------------------------------------------------------*/
PROCEDURE MODIFY_SUBSCRIPTION
(
p_api_version IN NUMBER := 1.0 ,
p_init_msg_list IN VARCHAR2 := FND_API.G_TRUE ,
p_commit IN VARCHAR2 := FND_API.G_FALSE ,
p_validate_only IN VARCHAR2 := FND_API.G_TRUE ,
p_validation_level IN NUMBER := FND_API.G_VALID_LEVEL_FULL,
p_x_subscription_tbl IN OUT NOCOPY subscription_tbl ,
x_return_status OUT NOCOPY VARCHAR2 ,
x_msg_count OUT NOCOPY NUMBER ,
x_msg_data OUT NOCOPY VARCHAR2
)
IS
-- Cursor to retrieve the existing subscriptions record
CURSOR get_sub_rec_b_info(c_subscription_id NUMBER)
IS
SELECT ROWID row_id,
document_id,
status_code,
requested_by_party_id,
quantity,
frequency_code,
subscribed_frm_party_id,
start_date,
end_date,
purchase_order_no,
subscription_type_code,
media_type_code,
object_version_number,
attribute_category,
attribute1,
attribute2,
attribute3,
attribute4,
attribute5,
attribute6,
attribute7,
attribute8,
attribute9,
attribute10,
attribute11,
attribute12,
attribute13,
attribute14,
attribute15
FROM AHL_SUBSCRIPTIONS_B
WHERE subscription_id = c_subscription_id
FOR UPDATE OF object_version_number NOWAIT;
SELECT ROWID,
comments
FROM AHL_SUBSCRIPTIONS_TL
WHERE subscription_id = c_subscription_id
FOR UPDATE OF subscription_id NOWAIT;
SELECT subscription_id
FROM AHL_SUBSCRIPTIONS_B
WHERE document_id = c_document_id AND
requested_by_party_id = c_requested_by_party_id;
SELECT MAX(NVL(end_date,SYSDATE))
FROM AHL_SUBSCRIPTIONS_B
WHERE document_id = c_document_id;
SELECT party_name
FROM ahl_hz_per_employees_v
WHERE party_id= c_requested_by_party_id;
SELECT PARTY_NAME
FROM HZ_PARTIES
WHERE party_id= c_requested_by_party_id
AND PARTY_TYPE ='PERSON';
SELECT PPF.FULL_NAME
FROM PER_PEOPLE_F PPF, PER_PERSON_TYPES PPT
WHERE PPF.PERSON_ID= c_requested_by_party_id
AND TRUNC(SYSDATE) BETWEEN PPF.EFFECTIVE_START_DATE AND PPF.EFFECTIVE_END_DATE
AND NVL(PPF.CURRENT_EMPLOYEE_FLAG, 'X') = 'Y'
AND PPF.PERSON_TYPE_ID = PPT.PERSON_TYPE_ID
AND PPT.SYSTEM_PERSON_TYPE ='EMP';
SELECT AHL_DI_DOC_INDEX_PVT.GET_PRODUCT_INSTALL_STATUS('PER')
INTO l_prod_install_status
FROM DUAL;
IF (NVL(p_x_subscription_tbl(i).delete_flag, 'N') = 'N' )
THEN
-- Calling validate subscriptions
VALIDATE_SUBSCRIPTION
(
p_subscription_id => p_x_subscription_tbl(i).subscription_id,
p_document_id =>p_x_subscription_tbl(i).document_id,
p_status_code =>p_x_subscription_tbl(i).status_code,
p_requested_by_party_id =>p_x_subscription_tbl(i).requested_by_party_id,
p_quantity =>p_x_subscription_tbl(i).quantity,
p_frequency_code =>p_x_subscription_tbl(i).frequency_code,
p_subscribed_frm_party_id =>p_x_subscription_tbl(i).subscribed_frm_party_id,
p_start_date =>p_x_subscription_tbl(i).start_date,
p_end_date =>p_x_subscription_tbl(i).end_date,
p_media_type_code =>p_x_subscription_tbl(i).media_type_code,
p_subscription_type_code =>p_x_subscription_tbl(i).subscription_type_code,
p_purchase_order_no =>p_x_subscription_tbl(i).purchase_order_no,
p_delete_flag =>p_x_subscription_tbl(i).delete_flag
);
/* procedure name: AHL_SUBSCRIPTIONS_PKG.UPDATE_ROW */
/* description : Added by Senthil to call Table Handler */
/* Date : Dec 31 2001 */
/*---------------------------------------------------------*/
-- Updates subscriptions record and tranlation table
--Enhancement nos #2034767 and #2205830: pbarman : April 2003
IF (p_x_subscription_tbl(i).subscription_id IS NOT NULL AND
NVL(p_x_subscription_tbl(i).delete_flag, 'N') = 'N' )
THEN
AHL_SUBSCRIPTIONS_PKG.UPDATE_ROW (
X_SUBSCRIPTION_ID => p_x_subscription_tbl(i).subscription_id,
X_ATTRIBUTE5 => l_subscription_info.attribute5,
X_DOCUMENT_ID => l_subscription_info.document_id,
X_REQUESTED_BY_PARTY_ID => l_subscription_info.requested_by_party_id,
X_ATTRIBUTE6 => l_subscription_info.attribute6,
X_ATTRIBUTE7 => l_subscription_info.attribute7,
X_ATTRIBUTE8 => l_subscription_info.attribute8,
X_ATTRIBUTE9 => l_subscription_info.attribute9,
X_ATTRIBUTE10 => l_subscription_info.attribute10,
X_ATTRIBUTE11 => l_subscription_info.attribute11,
X_ATTRIBUTE12 => l_subscription_info.attribute12,
X_ATTRIBUTE13 => l_subscription_info.attribute13,
X_ATTRIBUTE14 => l_subscription_info.attribute14,
X_ATTRIBUTE_CATEGORY => l_subscription_info.attribute_category,
X_ATTRIBUTE1 => l_subscription_info.attribute1,
X_ATTRIBUTE2 => l_subscription_info.attribute2,
X_ATTRIBUTE3 => l_subscription_info.attribute3,
X_ATTRIBUTE4 => l_subscription_info.attribute4,
X_OBJECT_VERSION_NUMBER => l_subscription_info.object_version_number+1,
X_ATTRIBUTE15 => l_subscription_info.attribute15,
X_SUBSCRIBED_FRM_PARTY_ID => l_subscription_info.subscribed_frm_party_id,
X_QUANTITY => l_subscription_info.quantity,
X_STATUS_CODE => l_subscription_info.status_code,
X_PURCHASE_ORDER_NO => l_subscription_info.purchase_order_no,
X_FREQUENCY_CODE => l_subscription_info.frequency_code,
X_SUBSCRIPTION_TYPE_CODE => l_subscription_info.subscription_type_code,
X_MEDIA_TYPE_CODE => l_subscription_info.media_type_code,
X_START_DATE => l_subscription_info.start_date,
X_END_DATE => l_subscription_info.end_date,
X_COMMENTS => l_comments,
X_LAST_UPDATE_DATE => sysdate,
X_LAST_UPDATED_BY => fnd_global.user_id,
X_LAST_UPDATE_LOGIN => fnd_global.login_id
);
UPDATE AHL_SUBSCRIPTIONS_B
SET document_id = l_subscription_info.document_id,
status_code = l_subscription_info.status_code,
requested_by_party_id = l_subscription_info.requested_by_party_id,
quantity = l_subscription_info.quantity,
frequency_code = l_subscription_info.frequency_code,
subscribed_frm_party_id =l_subscription_info.subscribed_frm_party_id,
start_date = l_subscription_info.start_date,
end_date = l_subscription_info.end_date,
purchase_order_no = l_subscription_info.purchase_order_no,
subscription_type_code = l_subscription_info.subscription_type_code,
media_type_code = l_subscription_info.media_type_code,
object_version_number = l_subscription_info.object_version_number+1,
attribute_category = l_subscription_info.attribute_category,
attribute1 = l_subscription_info.attribute1,
attribute2 = l_subscription_info.attribute2,
attribute3 = l_subscription_info.attribute3,
attribute4 = l_subscription_info.attribute4,
attribute5 = l_subscription_info.attribute5,
attribute6 = l_subscription_info.attribute6,
attribute7 = l_subscription_info.attribute7,
attribute8 = l_subscription_info.attribute8,
attribute9 = l_subscription_info.attribute9,
attribute10 = l_subscription_info.attribute10,
attribute11 = l_subscription_info.attribute11,
attribute12 = l_subscription_info.attribute12,
attribute13 = l_subscription_info.attribute13,
attribute14 = l_subscription_info.attribute14,
attribute15 = l_subscription_info.attribute15,
last_update_date = sysdate,
last_updated_by = fnd_global.user_id,
last_update_login = fnd_global.login_id
WHERE subscription_id = p_x_subscription_tbl(i).subscription_id;
UPDATE AHL_SUBSCRIPTIONS_TL
SET comments = l_comments,
last_update_date = sysdate,
last_updated_by = fnd_global.user_id,
last_update_login = fnd_global.login_id
WHERE SUBSCRIPTION_ID = p_x_subscription_tbl(i).subscription_id
AND userenv('LANG') in (LANGUAGE, SOURCE_LANG);
UPDATE AHL_DOCUMENTS_B
SET subscribe_to_flag = 'N'
WHERE document_id = p_x_subscription_tbl(i).document_id;
UPDATE AHL_DOCUMENTS_B
SET subscribe_to_flag = 'Y'
WHERE document_id = p_x_subscription_tbl(i).document_id;
NVL(p_x_subscription_tbl(i).delete_flag, 'N') = 'Y' )
THEN
-- Added pjha 28-Jun-2002 for bug#2438718: Begin
l_subscription_tbl(1).subscription_id := p_x_subscription_tbl(i).subscription_id;
DELETE_SUBSCRIPTION
(
p_api_version => 1.0 ,
p_init_msg_list => FND_API.G_TRUE ,
p_commit => FND_API.G_FALSE ,
p_validate_only => FND_API.G_TRUE ,
p_validation_level => FND_API.G_VALID_LEVEL_FULL ,
p_x_subscription_tbl => l_subscription_tbl ,
x_return_status => x_return_status ,
x_msg_count => x_msg_count ,
x_msg_data => x_msg_data);
UPDATE AHL_DOCUMENTS_B
SET subscribe_to_flag = 'N'
WHERE document_id = p_x_subscription_tbl(i).document_id;
UPDATE AHL_DOCUMENTS_B
SET subscribe_to_flag = 'Y'
WHERE document_id = p_x_subscription_tbl(i).document_id;
/* procedure name: delete_subscription */
/* description :we are not using this procedure, probably*/
/* next phase */
/* */
/*-------------------------------------------------------*/
PROCEDURE DELETE_SUBSCRIPTION
(
p_api_version IN NUMBER := 1.0 ,
p_init_msg_list IN VARCHAR2 := FND_API.G_TRUE ,
p_commit IN VARCHAR2 := FND_API.G_FALSE ,
p_validate_only IN VARCHAR2 := FND_API.G_TRUE ,
p_validation_level IN NUMBER := FND_API.G_VALID_LEVEL_FULL,
p_x_subscription_tbl IN OUT NOCOPY subscription_tbl ,
x_return_status OUT NOCOPY VARCHAR2 ,
x_msg_count OUT NOCOPY NUMBER ,
x_msg_data OUT NOCOPY VARCHAR2
)
IS
CURSOR get_sub_rec_b_info(c_subscription_id NUMBER)
IS
SELECT ROWID,
start_date,
end_date,
object_version_number
FROM AHL_SUBSCRIPTIONS_B
WHERE subscription_id = c_subscription_id
FOR UPDATE OF object_version_number NOWAIT;
l_api_name CONSTANT VARCHAR2(30) := 'DELETE_SUBSCRIPTION';
SAVEPOINT delete_subscriptions;
/* Not required, user should be able to delete subscriptions
after they have become obsolete: pjha 09-Jul-2002
IF (l_end_date IS NOT NULL AND l_end_date < sysdate )
THEN
FND_MESSAGE.SET_NAME('AHL','AHL_DI_SUB_RECORD_CLOSED');
AHL_SUBSCRIPTIONS_PKG.DELETE_ROW(
X_SUBSCRIPTION_ID => p_x_subscription_tbl(i).subscription_id);
UPDATE AHL_SUBSCRIPTIONS_B
SET END_DATE = sysdate
WHERE ROWID = l_rowid;
ROLLBACK TO delete_subscription;
ROLLBACK TO delete_subscription;
ROLLBACK TO delete_subscription;
p_procedure_name => 'DELETE_SUBSCRIPTION',
p_error_text => SUBSTR(SQLERRM,1,240));
END DELETE_SUBSCRIPTION;