最近在做PI和BW的一个接口,从其他数据源发送数据到BW的“直

1、Chunguangz-技术人员参考 最近在做PI和BW的一个接口，从其他数据源发送数据到BW的“直接更新”类型的CUBE，确切的说应该是BCS单户数据。当中，遇到了2个问题：1 DSO的最多只能设置16个主键，而我们的模型需要设置超过16个主键？2 上载数据如何实现增量上载？解决方法：1 自定义一个字段，作为主键，其他字段都作为数据字段。在开始例程中判断数据是否已经存在，存在，取原数据的主键；不存在，取时间戳和数据包上载记录的顺序号做为DSO的主键。2 利用DSO的增量机制，KEY FIGURE的Aggregation属性设置为OVERWRITE，上载数据默认为后镜像数据，每次上载的数据覆盖以

2、前的数据，这样，对于修改和新增的数据都可以实现增量。对于数据包中删除的数据，将数据为0的记录写入到数据包。这样做，可以将删除的数据清为0。但要注意的是，在判断数据是否删除之前，必须要指定一个范围，即指定在哪个范围的数据内操作，否则程序会将除上载数据外的所有数据都置为0。如：我们的例子中规定，每次上载一个合并单位下的某个期间的数据，在第二次上载的时候，我就要考虑数据是否在这个范围（合并单位+年度+期间）内存在，如果不存在，才将key figure为0的数据记录写入。关于DELTA机制，请参考：  METHOD start_routine.*= Segmen

3、ts =    FIELD-SYMBOLS:      <SOURCE_FIELDS>    TYPE _ty_s_SC_1.    DATA:      MONITOR_REC     TYPE rstmonitor.*$*$ begin of&

4、#160;routine - insert your code only below this line        *-*    . "insert your code here*-  fill table "MONITOR" with values of

5、 structure "MONITOR_REC"*-   to make monitor entries    . "to cancel the update process*    raise exception type CX_RSROUT_ABORT.    DATA: l

6、t_dso type TABLE OF /BIC/AZTBCSD0100,          ls_dso type /BIC/AZTBCSD0100.    data: lv_index type i,          lv_index_str(6) ty

7、pe c.    data: lv_stamp1(14) type c,          lv_stamp2(14) type c.    data: sf_fields type _ty_s_SC_1.    types: BEGIN OF ts_id&#

8、160;,          FISCPER3 type /BIC/AZTBCSD0100-FISCPER3,          FISCYEAR type /BIC/AZTBCSD0100-FISCYEAR,          CS_UNIT &#

9、160;type /BIC/AZTBCSD0100-CS_UNIT,      END OF ts_id.    data: lt_id type TABLE OF ts_id,          ls_id type ts_id.    select

10、0;* from /BIC/AZTBCSD0100 into table lt_dso.    concatenate sy-datum sy-uzeit into lv_stamp1.    move lv_stamp1 to lv_stamp2.* 设置DSO主键    loop at SOURCE_PACKAGE ASSI

11、GNING <source_fields>.* 如果时间过1秒，事件重新从1开始累计      concatenate sy-datum sy-uzeit into lv_stamp2.      if lv_stamp1 <> lv_stamp2.        clear lv_i

12、ndex.        move lv_stamp2 to lv_stamp1.      endif.      lv_index = lv_index + 1.* 查询数据是否已存在，本例中，所有字段都是主键      read table l

13、t_dso with key        CS_VERSION     = <source_fields>-CS_VERSION        CS_CHART       = <source_fields>-CS_CHART  &#

14、160;     CS_ITEM        = <source_fields>-CS_ITEM        COUNTRY        = <source_fields>-COUNTRY      

15、  MOVE_TYPE      = <source_fields>-MOVE_TYPE        ACQ_YEAR       = <source_fields>-ACQ_YEAR        ACQ_PER  

16、60;     = <source_fields>-ACQ_PER        BLINE_DATE     = <source_fields>-BLINE_DATE        CS_PARTNER     = <sourc

17、e_fields>-CS_PARTNER        FUNC_AREA      = <source_fields>-FUNC_AREA        /BIC/Z03BCS_01 = <source_fields>-/BIC/Z03BCS_01      

18、;  /BIC/Z03BCS_02 = <source_fields>-/BIC/Z03BCS_02        /BIC/Z03BCS_03 = <source_fields>-/BIC/Z03BCS_03        /BIC/Z03BCS_04 = <source_fields>-/BIC/Z03BCS_04&#

19、160;       /BIC/Z03BCS_05 = <source_fields>-/BIC/Z03BCS_05        /BIC/Z03BCS_06 = <source_fields>-/BIC/Z03BCS_06        /BIC/Z03BCS_07 = <s

20、ource_fields>-/BIC/Z03BCS_07        /BIC/Z03BCS_08 = <source_fields>-/BIC/Z03BCS_08        /BIC/Z03BCS_09 = <source_fields>-/BIC/Z03BCS_09        

21、;/BIC/Z03BCS_14 = <source_fields>-/BIC/Z03BCS_14        /BIC/Z03BCS_15 = <source_fields>-/BIC/Z03BCS_15        /BIC/Z03BCS_16 = <source_fields>-/BIC/Z03BCS_16  &#

22、160;     /BIC/Z03BCS_66 = <source_fields>-/BIC/Z03BCS_66        /BIC/Z03BCS_67 = <source_fields>-/BIC/Z03BCS_67        /BIC/Z03BCS_68 = <source_fields

23、>-/BIC/Z03BCS_68        /BIC/Z03BCS_69 = <source_fields>-/BIC/Z03BCS_69        /BIC/Z03BCS_70 = <source_fields>-/BIC/Z03BCS_70        /BIC/Z03BCS

24、_72 = <source_fields>-/BIC/Z03BCS_72        /BIC/Z03BCS_71 = <source_fields>-/BIC/Z03BCS_71        /BIC/Z03BCS_74 = <source_fields>-/BIC/Z03BCS_74    &#

25、160;   /BIC/Z03BCS_75 = <source_fields>-/BIC/Z03BCS_75        /BIC/Z03BCS_76 = <source_fields>-/BIC/Z03BCS_76        /BIC/Z03BCS_77 = <source_fields>-/BIC/Z0

26、3BCS_77        /BIC/Z03BCS_10 = <source_fields>-/BIC/Z03BCS_10        /BIC/Z03BCS_11 = <source_fields>-/BIC/Z03BCS_11        /BIC/Z03BCS_12 =&#

27、160;<source_fields>-/BIC/Z03BCS_12        /BIC/Z03BCS_13 = <source_fields>-/BIC/Z03BCS_13        /BIC/Z03BCS_78 = <source_fields>-/BIC/Z03BCS_78      &#

28、160; /BIC/Z03BCS_80 = <source_fields>-/BIC/Z03BCS_80        /BIC/Z03BCS_81 = <source_fields>-/BIC/Z03BCS_81        /BIC/Z03BCS_82 = <source_fields>-/BIC/Z03BCS_82 

29、;       /BIC/Z03BCS_83 = <source_fields>-/BIC/Z03BCS_83        /BIC/Z03BCS_84 = <source_fields>-/BIC/Z03BCS_84        /BIC/Z03BCS_85 = <sour

30、ce_fields>-/BIC/Z03BCS_85        /BIC/Z03BCS_86 = <source_fields>-/BIC/Z03BCS_86        /BIC/Z03BCS_79 = <source_fields>-/BIC/Z03BCS_79        BC

31、S_DIDIEL     = <source_fields>-BCS_DIDIEL        BCS_PRGRP      = <source_fields>-BCS_PRGRP        /BIC/Z03BCS_17 = <source_fields

32、>-/BIC/Z03BCS_17        SEM_ACOMP      = <source_fields>-SEM_ACOMP        CS_INVESTO     = <source_fields>-CS_INVESTO    

33、;    CS_PLEVEL      = <source_fields>-CS_PLEVEL        BCS_DOCTY      = <source_fields>-BCS_DOCTY        BCS_CTFLG

34、0;     = <source_fields>-BCS_CTFLG        CS_INVESTE     = <source_fields>-CS_INVESTE        CURKEY_GC      = <

35、;source_fields>-CURKEY_GC        CURKEY_LC      = <source_fields>-CURKEY_LC        UNIT           = <source_field

36、s>-UNIT        CURKEY_TC      = <source_fields>-CURKEY_TC        CS_DIMEN       = <source_fields>-CS_DIMEN    

37、    CS_UNIT        = <source_fields>-CS_UNIT        CS_GROUP       = <source_fields>-CS_GROUP        FI

38、SCYEAR       = <source_fields>-FISCYEAR        FISCVARNT      = <source_fields>-FISCVARNT        FISCPER3    

39、0;  = <source_fields>-FISCPER3        into ls_dso.      if sy-subrc eq 0.* 如果数据已存在，则使用系统中数据的ZTMSTAMP作为现有的主键        <source_fields>-/BIC/ZTMSTAM

40、P = ls_dso-/BIC/ZTMSTAMP.      else.* 如果数据不存在，则使用获得的时间戳+INDEX作为主键        MOVE LV_INDEX TO LV_INDEX_STR.        CALL FUNCTION 'CONVERSION_EXIT_ALPHA_INP

41、UT'          EXPORTING            INPUT  = lv_index_str          IMPORTING        

42、;    OUTPUT = lv_index_str.        CONCATENATE lv_stamp1 lv_index_str into        <source_fields>-/BIC/ZTMSTAMP.      endif.  

43、60;   modify SOURCE_PACKAGE from <source_fields>.* 归集不同数据包（当有多家公司上载时）      MOVE-CORRESPONDING <source_fields> to ls_id.      collect ls_id into lt_id .  

44、  endloop.    loop at lt_id into ls_id.* 对不同公司分别处理      loop at lt_dso into ls_dso         where FISCPER3 eq ls_id-FISCPER3   

45、;      and   FISCYEAR eq ls_id-FISCYEAR         and   CS_UNIT  eq ls_id-CS_UNIT .        read table SOURCE_PACKAGE&

46、#160;with key          CS_VERSION     = ls_dso-CS_VERSION          CS_CHART       = ls_dso-CS_CHART    &#

47、160;     CS_ITEM        = ls_dso-CS_ITEM          COUNTRY        = ls_dso-COUNTRY         

48、 MOVE_TYPE      = ls_dso-MOVE_TYPE          ACQ_YEAR       = ls_dso-ACQ_YEAR          ACQ_PER    

49、60;   = ls_dso-ACQ_PER          BLINE_DATE     = ls_dso-BLINE_DATE          CS_PARTNER     = ls_dso-CS_PARTNER 

50、0;        FUNC_AREA      = ls_dso-FUNC_AREA          /BIC/Z03BCS_01 = ls_dso-/BIC/Z03BCS_01          /BIC/Z03BCS_02

51、 = ls_dso-/BIC/Z03BCS_02          /BIC/Z03BCS_03 = ls_dso-/BIC/Z03BCS_03          /BIC/Z03BCS_04 = ls_dso-/BIC/Z03BCS_04        &#

52、160; /BIC/Z03BCS_05 = ls_dso-/BIC/Z03BCS_05          /BIC/Z03BCS_06 = ls_dso-/BIC/Z03BCS_06          /BIC/Z03BCS_07 = ls_dso-/BIC/Z03BCS_07    &#

53、160;     /BIC/Z03BCS_08 = ls_dso-/BIC/Z03BCS_08          /BIC/Z03BCS_09 = ls_dso-/BIC/Z03BCS_09          /BIC/Z03BCS_14 = ls_dso-/BIC/Z03BCS_14&#

54、160;         /BIC/Z03BCS_15 = ls_dso-/BIC/Z03BCS_15          /BIC/Z03BCS_16 = ls_dso-/BIC/Z03BCS_16          /BIC/Z03BCS_66 = 

55、;ls_dso-/BIC/Z03BCS_66          /BIC/Z03BCS_67 = ls_dso-/BIC/Z03BCS_67          /BIC/Z03BCS_68 = ls_dso-/BIC/Z03BCS_68          /B

56、IC/Z03BCS_69 = ls_dso-/BIC/Z03BCS_69          /BIC/Z03BCS_70 = ls_dso-/BIC/Z03BCS_70          /BIC/Z03BCS_72 = ls_dso-/BIC/Z03BCS_72      &#

57、160;   /BIC/Z03BCS_71 = ls_dso-/BIC/Z03BCS_71          /BIC/Z03BCS_74 = ls_dso-/BIC/Z03BCS_74          /BIC/Z03BCS_75 = ls_dso-/BIC/Z03BCS_75  &#

58、160;       /BIC/Z03BCS_76 = ls_dso-/BIC/Z03BCS_76          /BIC/Z03BCS_77 = ls_dso-/BIC/Z03BCS_77          /BIC/Z03BCS_10 = ls_dso-/BIC

59、/Z03BCS_10          /BIC/Z03BCS_11 = ls_dso-/BIC/Z03BCS_11          /BIC/Z03BCS_12 = ls_dso-/BIC/Z03BCS_12          /BIC/Z03BCS_13

60、 = ls_dso-/BIC/Z03BCS_13          /BIC/Z03BCS_78 = ls_dso-/BIC/Z03BCS_78          /BIC/Z03BCS_80 = ls_dso-/BIC/Z03BCS_80        &#

61、160; /BIC/Z03BCS_81 = ls_dso-/BIC/Z03BCS_81          /BIC/Z03BCS_82 = ls_dso-/BIC/Z03BCS_82          /BIC/Z03BCS_83 = ls_dso-/BIC/Z03BCS_83    &#

62、160;     /BIC/Z03BCS_84 = ls_dso-/BIC/Z03BCS_84          /BIC/Z03BCS_85 = ls_dso-/BIC/Z03BCS_85          /BIC/Z03BCS_86 = ls_dso-/BIC/Z03BCS_86&#

63、160;         /BIC/Z03BCS_79 = ls_dso-/BIC/Z03BCS_79          BCS_DIDIEL     = ls_dso-BCS_DIDIEL          BCS_PRGRP&

64、#160;     = ls_dso-BCS_PRGRP          /BIC/Z03BCS_17 = ls_dso-/BIC/Z03BCS_17          SEM_ACOMP      = ls_dso-SEM_ACOMP 

65、         CS_INVESTO     = ls_dso-CS_INVESTO          CS_PLEVEL      = ls_dso-CS_PLEVEL         

66、 BCS_DOCTY      = ls_dso-BCS_DOCTY          BCS_CTFLG      = ls_dso-BCS_CTFLG          CS_INVESTE    

67、0;= ls_dso-CS_INVESTE          CURKEY_GC      = ls_dso-CURKEY_GC          CURKEY_LC      = ls_dso-CURKEY_LC          UNIT           = ls_dso-UNIT  &#