[Home] [Help]
419: Inserts, Updates, x_failed, Dups, inXFR_GROUP);
420: ELSIF(lower_table_name='cz_prices') THEN
421: CZ_IMP_PR_MAIN.MAIN_PRICE(inRun_ID, commit_size, max_err,
422: Inserts, Updates, x_failed, Dups, inXFR_GROUP);
423: ELSIF(lower_table_name='cz_price_groups') THEN
424: CZ_IMP_PR_MAIN.MAIN_PRICE_GROUP(inRun_ID, commit_size, max_err,
425: Inserts, Updates, x_failed, Dups, inXFR_GROUP);
426: ELSIF(lower_table_name='cz_localized_texts') THEN
427: CZ_IMP_PS_NODE.MAIN_INTL_TEXT(inRun_ID, commit_size, max_err,
470: ------------------------------------------------------------------------------------------
471: PROCEDURE import_before_start IS
472: CURSOR C_GET_ID(nPriceGroupID number) IS
473: SELECT substr(ORIG_SYS_REF,1,instr(ORIG_SYS_REF,'.')-1)
474: FROM CZ_PRICE_GROUPS
475: WHERE to_number(substr(ORIG_SYS_REF,instr(ORIG_SYS_REF,'.')+1))=nPriceGroupID
476: AND instr(ORIG_SYS_REF,'.')<>0;
477: CURSOR C_SET_ID IS
478: SELECT PRICE_GROUP_ID FROM CZ_PRICE_GROUPS
474: FROM CZ_PRICE_GROUPS
475: WHERE to_number(substr(ORIG_SYS_REF,instr(ORIG_SYS_REF,'.')+1))=nPriceGroupID
476: AND instr(ORIG_SYS_REF,'.')<>0;
477: CURSOR C_SET_ID IS
478: SELECT PRICE_GROUP_ID FROM CZ_PRICE_GROUPS
479: WHERE ORIG_SYS_REF IS NULL FOR UPDATE;
480:
481: nPriceGroupID CZ_PRICE_GROUPS.PRICE_GROUP_ID%TYPE;
482: sOrigSysRef CZ_PRICE_GROUPS.ORIG_SYS_REF%TYPE;
477: CURSOR C_SET_ID IS
478: SELECT PRICE_GROUP_ID FROM CZ_PRICE_GROUPS
479: WHERE ORIG_SYS_REF IS NULL FOR UPDATE;
480:
481: nPriceGroupID CZ_PRICE_GROUPS.PRICE_GROUP_ID%TYPE;
482: sOrigSysRef CZ_PRICE_GROUPS.ORIG_SYS_REF%TYPE;
483: bIdFound BOOLEAN := FALSE;
484: xERROR BOOLEAN := FALSE;
485:
478: SELECT PRICE_GROUP_ID FROM CZ_PRICE_GROUPS
479: WHERE ORIG_SYS_REF IS NULL FOR UPDATE;
480:
481: nPriceGroupID CZ_PRICE_GROUPS.PRICE_GROUP_ID%TYPE;
482: sOrigSysRef CZ_PRICE_GROUPS.ORIG_SYS_REF%TYPE;
483: bIdFound BOOLEAN := FALSE;
484: xERROR BOOLEAN := FALSE;
485:
486: BEGIN
495: CLOSE C_GET_ID;
496:
497: IF(bIdFound) THEN
498: BEGIN
499: UPDATE CZ_PRICE_GROUPS SET ORIG_SYS_REF=sOrigSysRef WHERE CURRENT OF C_SET_ID;
500: EXCEPTION
501: WHEN OTHERS THEN
502: xERROR:=cz_utils.log_report(SQLERRM,1,'CZ_IMP_ALL.IMPORT_BEFORE_START',11276);
503: END;
508: COMMIT;
509: END import_before_start;
510: ------------------------------------------------------------------------------------------
511: PROCEDURE import_after_complete(inRUN_ID IN PLS_INTEGER) IS
512: CURSOR C_GET_RELATED(sOrigSysRef CZ_PRICE_GROUPS.ORIG_SYS_REF%TYPE) IS
513: SELECT PRICE_GROUP_ID FROM CZ_PRICE_GROUPS
514: WHERE instr(ORIG_SYS_REF,'.')<>0 AND
515: substr(ORIG_SYS_REF,1,instr(ORIG_SYS_REF,'.')-1)=sOrigSysRef;
516: CURSOR C_GET_HOST IS
509: END import_before_start;
510: ------------------------------------------------------------------------------------------
511: PROCEDURE import_after_complete(inRUN_ID IN PLS_INTEGER) IS
512: CURSOR C_GET_RELATED(sOrigSysRef CZ_PRICE_GROUPS.ORIG_SYS_REF%TYPE) IS
513: SELECT PRICE_GROUP_ID FROM CZ_PRICE_GROUPS
514: WHERE instr(ORIG_SYS_REF,'.')<>0 AND
515: substr(ORIG_SYS_REF,1,instr(ORIG_SYS_REF,'.')-1)=sOrigSysRef;
516: CURSOR C_GET_HOST IS
517: SELECT * FROM CZ_PRICE_GROUPS
513: SELECT PRICE_GROUP_ID FROM CZ_PRICE_GROUPS
514: WHERE instr(ORIG_SYS_REF,'.')<>0 AND
515: substr(ORIG_SYS_REF,1,instr(ORIG_SYS_REF,'.')-1)=sOrigSysRef;
516: CURSOR C_GET_HOST IS
517: SELECT * FROM CZ_PRICE_GROUPS
518: WHERE ORIG_SYS_REF IS NOT NULL AND instr(ORIG_SYS_REF,'.')=0
519: FOR UPDATE;
520: P_GET_HOST C_GET_HOST%ROWTYPE;
521:
518: WHERE ORIG_SYS_REF IS NOT NULL AND instr(ORIG_SYS_REF,'.')=0
519: FOR UPDATE;
520: P_GET_HOST C_GET_HOST%ROWTYPE;
521:
522: nPriceGroupID CZ_PRICE_GROUPS.PRICE_GROUP_ID%TYPE;
523: bRelatedFound BOOLEAN := FALSE;
524: xERROR BOOLEAN := FALSE;
525: nAllocateBlock PLS_INTEGER:=1;
526: nAllocateCounter PLS_INTEGER;
536: cursor c_listcontrol is
537: select price_list_id from cz_xfr_price_lists
538: where deleted_flag='0';
539: cursor c_pricegroup(nPriceListId number) is
540: select desc_text from cz_price_groups
541: where orig_sys_ref=to_char(nPriceListId)
542: and deleted_flag='0';
543:
544: nPriceListId cz_xfr_price_lists.price_list_id%type;
541: where orig_sys_ref=to_char(nPriceListId)
542: and deleted_flag='0';
543:
544: nPriceListId cz_xfr_price_lists.price_list_id%type;
545: sDescription cz_price_groups.desc_text%type;
546: sDisabled cz_xfr_tables.disabled%type;
547: xERROR BOOLEAN := FALSE;
548:
549: begin
549: begin
550:
551: begin
552: select disabled into sDisabled
553: from cz_xfr_tables where dst_table='CZ_PRICE_GROUPS' and xfr_group='IMPORT';
554: exception
555: when others then
556: sDisabled:='1';
557: end;
614: CLOSE C_GET_RELATED;
615:
616: IF(bRelatedFound)THEN
617: BEGIN
618: UPDATE CZ_PRICE_GROUPS SET
619: DESC_TEXT=P_GET_HOST.DESC_TEXT,
620: CURRENCY=P_GET_HOST.CURRENCY,
621: NAME=P_GET_HOST.NAME,
622: USER_NUM01=P_GET_HOST.USER_NUM01,
634: LAST_UPDATED_BY=P_GET_HOST.LAST_UPDATED_BY,
635: SECURITY_MASK=P_GET_HOST.SECURITY_MASK,
636: CHECKOUT_USER=P_GET_HOST.CHECKOUT_USER
637: WHERE PRICE_GROUP_ID=nPriceGroupID;
638: UPDATE CZ_PRICE_GROUPS SET ORIG_SYS_REF=NULL
639: WHERE CURRENT OF C_GET_HOST;
640: EXCEPTION
641: WHEN OTHERS THEN
642: xERROR:=cz_utils.log_report(SQLERRM,1,'CZ_IMP_ALL.IMPORT_AFTER_COMPLETE',11276,inRUN_ID);
645: BEGIN
646: nAllocateCounter:=nAllocateCounter+1;
647: IF(nAllocateCounter=nAllocateBlock)THEN
648: nAllocateCounter:=0;
649: SELECT CZ_PRICE_GROUPS_S.NEXTVAL INTO nNextValue FROM DUAL;
650: END IF;
651: INSERT INTO CZ_PRICE_GROUPS
652: (PRICE_GROUP_ID,DESC_TEXT,CURRENCY,ORIG_SYS_REF,
653: NAME,USER_NUM01,USER_NUM02,USER_NUM03,USER_NUM04,
647: IF(nAllocateCounter=nAllocateBlock)THEN
648: nAllocateCounter:=0;
649: SELECT CZ_PRICE_GROUPS_S.NEXTVAL INTO nNextValue FROM DUAL;
650: END IF;
651: INSERT INTO CZ_PRICE_GROUPS
652: (PRICE_GROUP_ID,DESC_TEXT,CURRENCY,ORIG_SYS_REF,
653: NAME,USER_NUM01,USER_NUM02,USER_NUM03,USER_NUM04,
654: USER_STR01,USER_STR02,USER_STR03,USER_STR04,DELETED_FLAG,
655: SECURITY_MASK,CHECKOUT_USER,
663: P_GET_HOST.USER_STR03,P_GET_HOST.USER_STR04,P_GET_HOST.DELETED_FLAG,
664: P_GET_HOST.SECURITY_MASK,
665: P_GET_HOST.CHECKOUT_USER,
666: SYSDATE,SYSDATE,1,1);
667: UPDATE CZ_PRICE_GROUPS SET ORIG_SYS_REF=NULL
668: WHERE CURRENT OF C_GET_HOST;
669: EXCEPTION
670: WHEN OTHERS THEN
671: xERROR:=cz_utils.log_report(SQLERRM,1,'CZ_IMP_ALL.IMPORT_AFTER_COMPLETE',11276,inRUN_ID);