DBA Data[Home] [Help]

APPS.JTF_IH_IMPORT dependencies on JTF_IH_INTERACTIONS_STG

Line 45: SELECT COUNT(*) INTO nCount FROM jtf_ih_interactions_stg WHERE interaction_id = nId

41: v_Session_no := 0;
42: --end Perf fix for literal Usage
43: --dbms_output.put_line('Check Duplicate for '||sTableType||' '||nId||' '||nvl(nSessionNo,-1));
44: IF sTableType = 'INTERACTION' THEN
45: SELECT COUNT(*) INTO nCount FROM jtf_ih_interactions_stg WHERE interaction_id = nId
46: AND (Session_No = pnSessionNo OR Session_No IS NULL OR Session_No = v_Session_no);
47: ELSIF sTableType = 'MEDIAITEM' THEN
48: SELECT COUNT(*) INTO nCount FROM jtf_ih_media_items_stg WHERE media_id = nId
49: AND (Session_No = pnSessionNo OR Session_No IS NULL OR Session_No = v_Session_no);

Line 123: SELECT Count(*) INTO nCount from jtf_ih_interactions_stg

119: v_Status_Fl2 :=2 ;
120: v_Session_no := 0;
121: --end Perf fix for literal Usage
122: -- dbms_output.put_line(pnSessionNo);
123: SELECT Count(*) INTO nCount from jtf_ih_interactions_stg
124: WHERE (Session_No = pnSessionNo OR Session_No IS NULL OR Session_No = v_Session_no);
125: -- Control Session number;
126: IF nCount = 0 THEN
127: SELECT Count(*) INTO nCount from jtf_ih_media_items_stg

Line 147: distinct Interaction_ID FROM jtf_ih_interactions_stg

143: --
144: nRowsCompleted := 0;
145: -- Check all records for current sessino which has staus_fl = 0 (uncomplited or has some errors)
146: FOR curInteraction IN (select
147: distinct Interaction_ID FROM jtf_ih_interactions_stg
148: WHERE (Session_No IS NULL OR Session_No = pnSessionNo OR Session_No = v_Session_no )
149: AND (Status_FL IS NULL OR Status_FL = v_Status_Fl0) ORDER BY Interaction_ID) LOOP
150: --
151: BEGIN

Line 169: UPDATE jtf_ih_interactions_stg SET Status_Fl = v_Status_Fl0, Session_Date = SYSDATE, Session_No = nNxtSessionNo

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
170: WHERE Interaction_ID = curInteraction.Interaction_ID and (Session_No = pnSessionNo OR Session_No IS NULL OR Session_No = v_Session_no);
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);

Line 190: UPDATE jtf_ih_interactions_stg SET Status_Fl = v_Status_Fl1, Session_No = nNxtSessionNo, Session_Date = SYSDATE

186: END IF;
187: END IF;
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;

Line 197: UPDATE jtf_ih_interactions_stg SET Status_Fl = v_Status_Fl0, Session_Date = SYSDATE, Session_No = nNxtSessionNo

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
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

Line 354: FROM jtf_ih_interactions_stg WHERE

350: '' as bulk_writer_code ,
351: '' as bulk_batch_type,
352: NULL as bulk_batch_id,
353: NULL as bulk_interaction_id
354: FROM jtf_ih_interactions_stg WHERE
355: Status_Fl = v_Status_Fl1 AND (Session_No IN (nSessionNo, v_Session_no) OR Session_No IS NULL)
356: ORDER BY interaction_id;
357:
358: l_interaction_stg_rec curInteraction%ROWTYPE;

Line 492: SELECT Count(Interaction_ID) INTO nTotInter FROM jtf_ih_interactions_stg

488: -- dbms_output.put_line('nSessionNo - '||nSessionNo);
489: -- dbms_output.put_line('Session Number is '||to_char(nSessionNo));
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

Line 545: UPDATE jtf_ih_interactions_stg SET Status_Fl = v_Status_Fl0, Session_Date = SYSDATE, Session_No = nSessionNo

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);
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;

Line 627: SELECT Active INTO nActive FROM jtf_ih_interactions_stg

623: AND Interaction_ID = l_interaction_stg
624: AND (Session_No IN (nSessionNo,v_Session_no) OR Session_No IS NULL);
625: END LOOP;
626: CLOSE curActivity;
627: SELECT Active INTO nActive FROM jtf_ih_interactions_stg
628: WHERE Interaction_ID = l_interaction_stg
629: AND (Session_No IN (nSessionNo,v_Session_no) OR Session_No IS NULL);
630: IF nActive = 'N' THEN
631: -- dbms_output.put_line('Interaction No '||l_interaction_id||' was closed');

Line 648: UPDATE jtf_ih_interactions_stg SET Interaction_ID = l_interaction_id, Status_Fl = v_Status_Fl2,

644: IF l_return_status <> 'S' THEN
645: RAISE e_Errors;
646: END IF;
647: END IF;
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,

Line 662: UPDATE jtf_ih_interactions_stg SET Status_Fl = v_Status_Fl0, Session_Date = SYSDATE, Session_No = nSessionNo

658: l_msg_data := '';
659: FOR j in 1..FND_MSG_PUB.Count_Msg LOOP
660: l_msg_data := l_msg_data || FND_MSG_PUB.Get(p_msg_index => j, p_encoded=>'F');
661: END LOOP;
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

Line 690: (SELECT interaction_id FROM jtf_ih_interactions_stg_log

686: FND_FILE.PUT_LINE(FND_FILE.LOG,FND_MESSAGE.GET);
687:
688: -- If import has any errors then show message about them
689: SELECT COUNT(*) INTO nErr_InterCnt FROM
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

Line 741: INSERT INTO JTF_IH_INTERACTIONS_STG_LOG(

737: PROCEDURE Insert_Interaction_Log( nInteraction NUMBER, sComments VARCHAR2, nSessionNo IN OUT NOCOPY NUMBER) AS
738: l_Comments VARCHAR(2000);
739: BEGIN
740: l_Comments := sComments;
741: INSERT INTO JTF_IH_INTERACTIONS_STG_LOG(
742: interaction_id,
743: object_version_number,
744: creation_date,
745: created_by,

Line 876: FROM jtf_ih_interactions_stg WHERE interaction_id = nInteraction

872: SYSDATE AS session_date,
873: primary_party_id,
874: contact_rel_party_id,
875: contact_party_id
876: FROM jtf_ih_interactions_stg WHERE interaction_id = nInteraction
877: AND session_no = nSessionNo;
878: EXCEPTION
879: WHEN OTHERS THEN
880: FND_MESSAGE.SET_NAME('JTF','JTF_IH_IMPORT_ERROR');