DBA Data[Home] [Help]

APPS.JTF_IH_IMPORT dependencies on JTF_IH_ACTIVITIES_STG

Line 153: -- Looking for records in the JTF_IH_ACTIVITIES_STG

149: AND (Status_FL IS NULL OR Status_FL = v_Status_Fl0) ORDER BY Interaction_ID) LOOP
150: --
151: BEGIN
152: n_Interaction_Id := curInteraction.Interaction_ID;
153: -- Looking for records in the JTF_IH_ACTIVITIES_STG
154: -- table which are depend with Current Interaction's record
155: -- if not found then leave STATUS_FL = 0.
156:
157: -- dbms_output.put_line('Looking for Activities for current Interaction ');

Line 165: SELECT Count(*) INTO nCount FROM jtf_ih_activities_stg

161: l_Message := FND_MESSAGE.GET;
162: RAISE e_ErrorInteraction;
163: END IF;
164:
165: SELECT Count(*) INTO nCount FROM jtf_ih_activities_stg
166: WHERE Interaction_ID = curInteraction.Interaction_ID AND (Session_No = pnSessionNo OR Session_No IS NULL OR Session_No = v_Session_no);
167: IF nCount = 0 THEN
168: -- dbms_output.put_line('Activities were not found for Interaction No: '||curInteraction.Interaction_ID);
169: UPDATE jtf_ih_interactions_stg SET Status_Fl = v_Status_Fl0, Session_Date = SYSDATE, Session_No = nNxtSessionNo

Line 175: FOR curActivity IN (SELECT Activity_ID, Media_ID FROM jtf_ih_activities_stg WHERE

171: FND_MESSAGE.SET_NAME('JTF','JTF_IH_IMPORT_NO_ACTIVITY');
172: l_Message := FND_MESSAGE.GET;
173: Insert_Interaction_Log(curInteraction.Interaction_ID, l_Message, nNxtSessionNo);
174: ELSE
175: FOR curActivity IN (SELECT Activity_ID, Media_ID FROM jtf_ih_activities_stg WHERE
176: Interaction_ID = curInteraction.Interaction_Id and
177: (Session_No IS NULL OR Session_No = pnSessionNo OR Session_No = v_Session_no)) LOOP
178: IF (curActivity.Media_ID IS NOT NULL) AND (curActivity.Media_ID <> fnd_api.g_miss_num) THEN
179: /* Looking for Media_ID in the JTF_IH_MEDIA_ITEM_STG */

Line 192: UPDATE jtf_ih_activities_stg SET Status_Fl = v_Status_Fl1, Session_No = nNxtSessionNo, Session_Date = SYSDATE

188: END LOOP;
189:
190: UPDATE jtf_ih_interactions_stg SET Status_Fl = v_Status_Fl1, Session_No = nNxtSessionNo, Session_Date = SYSDATE
191: WHERE Interaction_ID = curInteraction.Interaction_ID and (Session_No = pnSessionNo OR Session_No IS NULL OR Session_No = v_Session_no);
192: UPDATE jtf_ih_activities_stg SET Status_Fl = v_Status_Fl1, Session_No = nNxtSessionNo, Session_Date = SYSDATE
193: WHERE Interaction_ID = curInteraction.Interaction_ID and (Session_No = pnSessionNo OR Session_No IS NULL OR Session_No = v_Session_no);
194: END IF;
195: EXCEPTION
196: WHEN e_ErrorInteraction THEN

Line 201: UPDATE jtf_ih_activities_stg SET Status_Fl = v_Status_Fl0, Session_Date = SYSDATE, Session_No = nNxtSessionNo

197: UPDATE jtf_ih_interactions_stg SET Status_Fl = v_Status_Fl0, Session_Date = SYSDATE, Session_No = nNxtSessionNo
198: WHERE Interaction_ID = curInteraction.Interaction_ID and (Session_No = pnSessionNo OR Session_No IS NULL OR Session_No = v_Session_no);
199: Insert_Interaction_Log(curInteraction.Interaction_ID, l_Message, nNxtSessionNo);
200:
201: UPDATE jtf_ih_activities_stg SET Status_Fl = v_Status_Fl0, Session_Date = SYSDATE, Session_No = nNxtSessionNo
202: WHERE Interaction_ID = curInteraction.Interaction_ID and (Session_No = pnSessionNo OR Session_No IS NULL OR Session_No = v_Session_no);
203:
204: FOR curErrAct IN (SELECT Activity_ID FROM jtf_ih_activities_stg WHERE interaction_id = n_Interaction_ID AND Session_No = nNxtSessionNo) LOOP
205: Insert_activity_Log(curErrAct.Activity_Id, curInteraction.Interaction_ID, l_Message, nNxtSessionNo);

Line 204: FOR curErrAct IN (SELECT Activity_ID FROM jtf_ih_activities_stg WHERE interaction_id = n_Interaction_ID AND Session_No = nNxtSessionNo) LOOP

200:
201: UPDATE jtf_ih_activities_stg SET Status_Fl = v_Status_Fl0, Session_Date = SYSDATE, Session_No = nNxtSessionNo
202: WHERE Interaction_ID = curInteraction.Interaction_ID and (Session_No = pnSessionNo OR Session_No IS NULL OR Session_No = v_Session_no);
203:
204: FOR curErrAct IN (SELECT Activity_ID FROM jtf_ih_activities_stg WHERE interaction_id = n_Interaction_ID AND Session_No = nNxtSessionNo) LOOP
205: Insert_activity_Log(curErrAct.Activity_Id, curInteraction.Interaction_ID, l_Message, nNxtSessionNo);
206: END LOOP;
207: END;
208: -- Row's counter. When nRowsCompleted like nCntTransRows then make COMMIT

Line 409: FROM JTF_IH_ACTIVITIES_STG

405: NULL as bulk_batch_id,
406: NULL as bulk_interaction_id
407: -- Removed by IAleshin 06/05/2002
408: --,resource_id
409: FROM JTF_IH_ACTIVITIES_STG
410: WHERE Status_FL = v_Status_Fl1 AND Interaction_ID = nIntrctID
411: AND (Session_No IN (nSessionNo, v_Session_no) OR Session_No IS NULL);
412: --l_activity_rec curActivity%rowtype;
413: l_activity_rec JTF_IH_PUB.Activity_Rec_Type;

Line 494: SELECT Count(Activity_ID) INTO nTotActiv FROM jtf_ih_activities_stg

490: /*Import from JTF_IH_Media_Items_STG*/
491:
492: SELECT Count(Interaction_ID) INTO nTotInter FROM jtf_ih_interactions_stg
493: WHERE (Session_No IN (nSessionNo,v_Session_no) OR Session_No IS NULL);
494: SELECT Count(Activity_ID) INTO nTotActiv FROM jtf_ih_activities_stg
495: WHERE (Session_No IN (nSessionNo,v_Session_no) OR Session_No IS NULL);
496: SELECT Count(Media_ID) INTO nTotMdaItm FROM jtf_ih_media_items_stg
497: WHERE (Session_No IN (nSessionNo,v_Session_no) OR Session_No IS NULL);
498:

Line 525: UPDATE jtf_ih_activities_stg SET Media_ID = l_media_item_id

521: RAISE e_Errors;
522: END IF;
523: UPDATE jtf_ih_media_items_stg SET Status_Fl = v_Status_Fl2, Media_ID = l_media_item_id, Session_No = nSessionNo
524: WHERE Media_ID = l_media_id_stg AND (Session_No IN (nSessionNo,v_Session_no) OR Session_No IS NULL);
525: UPDATE jtf_ih_activities_stg SET Media_ID = l_media_item_id
526: WHERE Media_ID = l_media_id_stg AND (Session_No IN (nSessionNo,v_Session_no) OR Session_No IS NULL);
527: COMMIT;
528: nCntMdaItm := nCntMdaItm + 1;
529: EXCEPTION

Line 541: FOR curErrActive IN (SELECT Activity_ID, Interaction_ID FROM jtf_ih_activities_stg WHERE Interaction_ID = (

537: WHERE Media_ID = l_media_id_stg AND (Session_No IN (nSessionNo,v_Session_no) OR Session_No IS NULL);
538: --nErr_MediaCnt := nErr_MediaCnt + SQL%ROWCOUNT;
539: Insert_Media_Item_Log(l_media_id_stg, l_msg_data, nSessionNo);
540: -- Add into into Activities_Stg log
541: FOR curErrActive IN (SELECT Activity_ID, Interaction_ID FROM jtf_ih_activities_stg WHERE Interaction_ID = (
542: SELECT Interaction_ID FROM jtf_ih_activities_stg
543: WHERE Media_ID = l_media_id_stg AND (Session_No IN (nSessionNo,v_Session_no)
544: OR Session_No IS NULL))) LOOP
545: UPDATE jtf_ih_interactions_stg SET Status_Fl = v_Status_Fl0, Session_Date = SYSDATE, Session_No = nSessionNo

Line 542: SELECT Interaction_ID FROM jtf_ih_activities_stg

538: --nErr_MediaCnt := nErr_MediaCnt + SQL%ROWCOUNT;
539: Insert_Media_Item_Log(l_media_id_stg, l_msg_data, nSessionNo);
540: -- Add into into Activities_Stg log
541: FOR curErrActive IN (SELECT Activity_ID, Interaction_ID FROM jtf_ih_activities_stg WHERE Interaction_ID = (
542: SELECT Interaction_ID FROM jtf_ih_activities_stg
543: WHERE Media_ID = l_media_id_stg AND (Session_No IN (nSessionNo,v_Session_no)
544: OR Session_No IS NULL))) LOOP
545: UPDATE jtf_ih_interactions_stg SET Status_Fl = v_Status_Fl0, Session_Date = SYSDATE, Session_No = nSessionNo
546: WHERE Interaction_Id = curErrActive.Interaction_ID AND (Session_No IN (nSessionNo,v_Session_no) OR Session_No IS NULL);

Line 551: UPDATE jtf_ih_activities_stg SET Status_Fl = v_Status_Fl0, Session_Date = SYSDATE, Session_No = nSessionNo

547: IF curErrActive.Interaction_ID <> nDupInteraction OR nDupInteraction IS NULL THEN
548: Insert_Interaction_Log(curErrActive.Interaction_ID, l_msg_data, nSessionNo);
549: nDupInteraction := curErrActive.Interaction_ID;
550: END IF;
551: UPDATE jtf_ih_activities_stg SET Status_Fl = v_Status_Fl0, Session_Date = SYSDATE, Session_No = nSessionNo
552: WHERE Activity_ID = curErrActive.Activity_ID AND Interaction_Id = curErrActive.Interaction_ID
553: AND (Session_No IN (nSessionNo,v_Session_no) OR Session_No IS NULL);
554: Insert_Activity_Log(curErrActive.Activity_ID, curErrActive.Interaction_ID, l_msg_data, nSessionNo);
555: --nErr_ActivCnt := nErr_ActivCnt + 1;

Line 620: UPDATE jtf_ih_activities_stg SET Activity_ID = l_activity_id_1, Status_Fl = v_Status_Fl2,

616: IF l_return_status <> 'S' THEN
617: CLOSE curActivity;
618: RAISE e_Errors;
619: END IF;
620: UPDATE jtf_ih_activities_stg SET Activity_ID = l_activity_id_1, Status_Fl = v_Status_Fl2,
621: Session_Date = SYSDATE, Session_No = nSessionNo
622: WHERE Activity_ID = l_activity_stg
623: AND Interaction_ID = l_interaction_stg
624: AND (Session_No IN (nSessionNo,v_Session_no) OR Session_No IS NULL);

Line 652: UPDATE jtf_ih_activities_stg SET Interaction_ID = l_interaction_id, Status_Fl = v_Status_Fl2,

648: UPDATE jtf_ih_interactions_stg SET Interaction_ID = l_interaction_id, Status_Fl = v_Status_Fl2,
649: Session_Date = SYSDATE, Session_No = nSessionNo
650: WHERE Interaction_ID = l_interaction_stg AND (Session_No IN (nSessionNo,v_Session_no) OR Session_No IS NULL);
651: nCntInter := nCntInter + 1;
652: UPDATE jtf_ih_activities_stg SET Interaction_ID = l_interaction_id, Status_Fl = v_Status_Fl2,
653: Session_Date = SYSDATE, Session_No = nSessionNo
654: WHERE Interaction_ID = l_interaction_stg AND (Session_No IN (nSessionNo,v_Session_no) OR Session_No IS NULL);
655: nCntActiv := nCntActiv + SQL%ROWCOUNT;
656: EXCEPTION

Line 666: UPDATE jtf_ih_activities_stg SET Status_Fl = v_Status_Fl0, Session_Date = SYSDATE, Session_No = nSessionNo

662: UPDATE jtf_ih_interactions_stg SET Status_Fl = v_Status_Fl0, Session_Date = SYSDATE, Session_No = nSessionNo
663: WHERE Interaction_ID = l_interaction_stg AND (Session_No IN (nSessionNo,v_Session_no) OR Session_No IS NULL);
664: Insert_Interaction_Log(l_interaction_stg, l_msg_data, nSessionNo);
665: nErr_InterCnt := nErr_InterCnt + SQL%ROWCOUNT;
666: UPDATE jtf_ih_activities_stg SET Status_Fl = v_Status_Fl0, Session_Date = SYSDATE, Session_No = nSessionNo
667: WHERE Interaction_ID = l_interaction_stg AND (Session_No IN (nSessionNo,v_Session_no) OR Session_No IS NULL);
668: nErr_ActivCnt := nErr_ActivCnt + SQL%ROWCOUNT;
669: FOR currActivErr IN (SELECT Activity_ID, Interaction_ID FROM jtf_ih_activities_stg WHERE Interaction_ID = l_interaction_stg
670: AND (Session_No IN (nSessionNo,v_Session_no) OR Session_No IS NULL)) LOOP

Line 669: FOR currActivErr IN (SELECT Activity_ID, Interaction_ID FROM jtf_ih_activities_stg WHERE Interaction_ID = l_interaction_stg

665: nErr_InterCnt := nErr_InterCnt + SQL%ROWCOUNT;
666: UPDATE jtf_ih_activities_stg SET Status_Fl = v_Status_Fl0, Session_Date = SYSDATE, Session_No = nSessionNo
667: WHERE Interaction_ID = l_interaction_stg AND (Session_No IN (nSessionNo,v_Session_no) OR Session_No IS NULL);
668: nErr_ActivCnt := nErr_ActivCnt + SQL%ROWCOUNT;
669: FOR currActivErr IN (SELECT Activity_ID, Interaction_ID FROM jtf_ih_activities_stg WHERE Interaction_ID = l_interaction_stg
670: AND (Session_No IN (nSessionNo,v_Session_no) OR Session_No IS NULL)) LOOP
671: Insert_Activity_Log(currActivErr.Activity_ID,currActivErr.Interaction_ID, l_msg_data, nSessionNo);
672: END LOOP;
673: WHEN OTHERS THEN

Line 694: (SELECT activity_id FROM jtf_ih_activities_stg_log

690: (SELECT interaction_id FROM jtf_ih_interactions_stg_log
691: WHERE session_no = nSessionNo);
692:
693: SELECT COUNT(*) INTO nErr_ActivCnt FROM
694: (SELECT activity_id FROM jtf_ih_activities_stg_log
695: WHERE session_no = nSessionNo);
696:
697: SELECT COUNT(*) INTO nErr_MediaCnt FROM
698: (SELECT media_id FROM jtf_ih_media_items_stg_log

Line 963: INSERT INTO jtf_ih_activities_stg_log(

959: PROCEDURE Insert_Activity_Log( nActivityID NUMBER, nInteractionID NUMBER, sComments VARCHAR2, nSessionNo IN OUT NOCOPY NUMBER) AS
960: l_Comments VARCHAR(2000);
961: BEGIN
962: l_Comments := sComments;
963: INSERT INTO jtf_ih_activities_stg_log(
964: activity_id,
965: object_version_number,
966: creation_date,
967: created_by,

Line 1089: FROM jtf_ih_activities_stg

1085: script_trans_id,
1086: l_Comments AS error_message,
1087: nSessionNo AS session_no,
1088: SYSDATE AS session_date
1089: FROM jtf_ih_activities_stg
1090: WHERE activity_id = nActivityID
1091: AND Interaction_Id = nInteractionID
1092: AND session_no = nSessionNo;
1093: EXCEPTION