222: ----1) Insert new record into XFR_RUN_INFO and get the generated Run_ID for this import
223:
224: IF(inRun_ID IS NOT NULL)THEN
225: genRun_ID:=inRun_ID;
226: INSERT INTO CZ_XFR_RUN_INFOS (RUN_ID,STARTED,LAST_ACTIVITY,COMPLETED)
227: SELECT genRun_ID,SYSDATE,SYSDATE,'0' FROM DUAL WHERE NOT EXISTS
228: (SELECT 1 FROM CZ_XFR_RUN_INFOS WHERE RUN_ID=genRun_ID);
229: UPDATE CZ_XFR_RUN_INFOS SET
230: STARTED=SYSDATE,LAST_ACTIVITY=SYSDATE,COMPLETED='0'
224: IF(inRun_ID IS NOT NULL)THEN
225: genRun_ID:=inRun_ID;
226: INSERT INTO CZ_XFR_RUN_INFOS (RUN_ID,STARTED,LAST_ACTIVITY,COMPLETED)
227: SELECT genRun_ID,SYSDATE,SYSDATE,'0' FROM DUAL WHERE NOT EXISTS
228: (SELECT 1 FROM CZ_XFR_RUN_INFOS WHERE RUN_ID=genRun_ID);
229: UPDATE CZ_XFR_RUN_INFOS SET
230: STARTED=SYSDATE,LAST_ACTIVITY=SYSDATE,COMPLETED='0'
231: WHERE RUN_ID=genRun_ID;
232: COMMIT;
225: genRun_ID:=inRun_ID;
226: INSERT INTO CZ_XFR_RUN_INFOS (RUN_ID,STARTED,LAST_ACTIVITY,COMPLETED)
227: SELECT genRun_ID,SYSDATE,SYSDATE,'0' FROM DUAL WHERE NOT EXISTS
228: (SELECT 1 FROM CZ_XFR_RUN_INFOS WHERE RUN_ID=genRun_ID);
229: UPDATE CZ_XFR_RUN_INFOS SET
230: STARTED=SYSDATE,LAST_ACTIVITY=SYSDATE,COMPLETED='0'
231: WHERE RUN_ID=genRun_ID;
232: COMMIT;
233:
245: END;
246: END LOOP;
247: CLOSE C_IMPORT_ORDER;
248: ELSE
249: SELECT CZ_XFR_RUN_INFOS_S.NEXTVAL INTO genRun_ID FROM DUAL;
250: INSERT INTO CZ_XFR_RUN_INFOS (RUN_ID,STARTED,LAST_ACTIVITY,COMPLETED)
251: SELECT genRun_ID,SYSDATE,SYSDATE,'0' FROM DUAL WHERE NOT EXISTS
252: (SELECT 1 FROM CZ_XFR_RUN_INFOS WHERE RUN_ID=genRun_ID);
253: UPDATE CZ_XFR_RUN_INFOS SET
246: END LOOP;
247: CLOSE C_IMPORT_ORDER;
248: ELSE
249: SELECT CZ_XFR_RUN_INFOS_S.NEXTVAL INTO genRun_ID FROM DUAL;
250: INSERT INTO CZ_XFR_RUN_INFOS (RUN_ID,STARTED,LAST_ACTIVITY,COMPLETED)
251: SELECT genRun_ID,SYSDATE,SYSDATE,'0' FROM DUAL WHERE NOT EXISTS
252: (SELECT 1 FROM CZ_XFR_RUN_INFOS WHERE RUN_ID=genRun_ID);
253: UPDATE CZ_XFR_RUN_INFOS SET
254: STARTED=SYSDATE,LAST_ACTIVITY=SYSDATE,COMPLETED='0'
248: ELSE
249: SELECT CZ_XFR_RUN_INFOS_S.NEXTVAL INTO genRun_ID FROM DUAL;
250: INSERT INTO CZ_XFR_RUN_INFOS (RUN_ID,STARTED,LAST_ACTIVITY,COMPLETED)
251: SELECT genRun_ID,SYSDATE,SYSDATE,'0' FROM DUAL WHERE NOT EXISTS
252: (SELECT 1 FROM CZ_XFR_RUN_INFOS WHERE RUN_ID=genRun_ID);
253: UPDATE CZ_XFR_RUN_INFOS SET
254: STARTED=SYSDATE,LAST_ACTIVITY=SYSDATE,COMPLETED='0'
255: WHERE RUN_ID=genRun_ID;
256: COMMIT;
249: SELECT CZ_XFR_RUN_INFOS_S.NEXTVAL INTO genRun_ID FROM DUAL;
250: INSERT INTO CZ_XFR_RUN_INFOS (RUN_ID,STARTED,LAST_ACTIVITY,COMPLETED)
251: SELECT genRun_ID,SYSDATE,SYSDATE,'0' FROM DUAL WHERE NOT EXISTS
252: (SELECT 1 FROM CZ_XFR_RUN_INFOS WHERE RUN_ID=genRun_ID);
253: UPDATE CZ_XFR_RUN_INFOS SET
254: STARTED=SYSDATE,LAST_ACTIVITY=SYSDATE,COMPLETED='0'
255: WHERE RUN_ID=genRun_ID;
256: COMMIT;
257:
330: CLOSE C_IMPORT_ORDER;
331:
332: import_after_complete(genRun_ID);
333:
334: ----4) Finally update the (LAST_ACTIVITY,COMPLETED) fields of CZ_XFR_RUN_INFOS
335:
336: UPDATE CZ_XFR_RUN_INFOS SET
337: LAST_ACTIVITY=SYSDATE,
338: COMPLETED='1'
332: import_after_complete(genRun_ID);
333:
334: ----4) Finally update the (LAST_ACTIVITY,COMPLETED) fields of CZ_XFR_RUN_INFOS
335:
336: UPDATE CZ_XFR_RUN_INFOS SET
337: LAST_ACTIVITY=SYSDATE,
338: COMPLETED='1'
339: WHERE RUN_ID=genRun_ID;
340: COMMIT;