当前位置：网站首页>DEMO：测试接口短时间内接收重复数据创建单据

DEMO：测试接口短时间内接收重复数据创建单据

2022-07-27 22:34:00 【51CTO】

群号：775662808

申请时请提供城市-模块-昵称，如：北京-ABAP-森林木。

所有群管理严格，严格禁止一切外来链接、招聘、广告等垃圾信息!

如果您觉得这篇干货文章有用，请帮忙转载、分享给更多人，谢谢~

场景：

第三方调用SAP接口，创建单据，如果对方因为某种原因在极短的时间内，使用重复数据连续调用了sap接口，怎样防止重复创建单据。

之前群里聊过这个问题，我把问题抛出来，大家随便聊聊而已。

场景其实挺简单，也很常见，至于怎么实现，无非是什么加锁，加日志之类的。

我也是做了一个简单测试。

场景是推送数据到sap，创建PO。

先创建了个log表：

DEMO：测试接口短时间内接收重复数据创建单据_码农

DEMO：测试接口短时间内接收重复数据创建单据_批量修改_02

然后建了个锁

DEMO：测试接口短时间内接收重复数据创建单据_码农_03

DEMO：测试接口短时间内接收重复数据创建单据_码农_04

然后写了俩函数，分别是用锁和用log表。

第一个函数

       
       FUNCTION*"----------------------------------------------------------------------*"*"本地接口：*"*"     VALUE(IS_DATA) TYPE  ZLMT_PO_LOG OPTIONAL*"*"     VALUE(ES_DATA) TYPE  ZLMT_PO_LOG*"----------------------------------------------------------------------
       
DATA:LT_LOG TYPE TABLE OF ZLMT_PO_LOG.DATA:LS_LOG TYPE ZLMT_PO_LOG.
       
DATA:    LT_RETURN  LIKE TABLE OF BAPIRET2,    LT_POITEM  LIKE TABLE OF BAPIMEPOITEM,    LT_POITEMX LIKE TABLE OF BAPIMEPOITEMX,    LT_POCOND  LIKE TABLE OF BAPIMEPOCOND,    LT_POCONDX LIKE TABLE OF BAPIMEPOCONDX,    LS_POCOND  LIKE    BAPIMEPOCOND,    LS_POCONDX LIKE   BAPIMEPOCONDX.DATA:    LS_POHEADER  LIKE BAPIMEPOHEADER,    LS_POHEADERX LIKE BAPIMEPOHEADERX,    LS_RETURN    LIKE BAPIRET2,    LS_POITEM    LIKE BAPIMEPOITEM,    LS_POITEMX   LIKE BAPIMEPOITEMX.DATA:LV_PO_NUMBER LIKE  BAPIMEPOHEADER-PO_NUMBER.
       
*--------------------------------------------------------------------** 参数赋值*--------------------------------------------------------------------*
       
IF    MOVE-CORRESPONDING IS_DATA TO LS_LOG.  ELSE.
       
FUNCTION '/SAPSLL/GUID_CREATE'      IMPORTING        EV_GUID_32 = LS_LOG-GUID.
       
'LM00001'  ."外部单据号    LS_LOG-BUKRS         = '1710'  ."公司代码'NB'  ."订单类型（采购）    LS_LOG-LIFNR         = 'USSU-VSF04'  ."供应商或债权人的帐号'1710'  ."采购组织    LS_LOG-EKGRP         = '002'  ."采购组'MZ-RM-R300-01'  ."物料编号    LS_LOG-WERKS         = '1710'  ."工厂'171C'  ."库存地点    LS_LOG-KSCHA         = 'PMP0'  ."条件类型'1'  ."条件金额    LS_LOG-WAERS         = 'USD'  ."货币码
       
    LS_LOG-UNAME = SY-UNAME.    LS_LOG-DATUM = SY-DATUM.    LS_LOG-UZEIT = SY-UZEIT.
       
  ENDIF.
       
*--------------------------------------------------------------------** 枷锁*--------------------------------------------------------------------*
       
FUNCTION 'ENQUEUE_EZLMT_PO_LOG'    EXPORTING'X'      MANDT            = SY-MANDT      WEB_ORDER        = LS_LOG-WEB_ORDER'3'    EXCEPTIONS123.IF SY-SUBRC <> 0.'E'.'被锁'.
       
    INSERT ZLMT_PO_LOG FROM LS_LOG.    COMMIT WORK AND WAIT.
       
    ES_DATA = LS_LOG.    RETURN.  ENDIF.
       
*--------------------------------------------------------------------** 检查库表内该 web order是否已经成功创建 po*--------------------------------------------------------------------*DATA(LS_TMP)    WHERE  WEB_ORDER = @LS_LOG-WEB_ORDER.
       
IF SY-SUBRC = 0.'E'.'重复创建'.    INSERT ZLMT_PO_LOG FROM LS_LOG.    COMMIT WORK AND WAIT.
       
    ES_DATA = LS_LOG.    RETURN.  ENDIF.*--------------------------------------------------------------------** 赋值 call bapi*--------------------------------------------------------------------*  CLEAR LS_POHEADER.  CLEAR LS_POHEADERX.  LS_POHEADER-COMP_CODE      = LS_LOG-BUKRS.  LS_POHEADER-CURRENCY       = LS_LOG-WAERS.  LS_POHEADER-DOC_DATE       = SY-DATUM.  LS_POHEADER-DOC_TYPE       = LS_LOG-BSART.  LS_POHEADER-VENDOR         = LS_LOG-LIFNR.  LS_POHEADER-PURCH_ORG      = LS_LOG-EKORG.  LS_POHEADER-PUR_GROUP      = LS_LOG-EKGRP.'X'.'X'.'X'.'X'.'X'.'X'.'X'.  CLEAR: LS_POITEM,LS_POITEMX.  CLEAR: LT_POITEM[],LT_POITEMX[].
       
'10'.                   "采购凭证的项目编号  LS_POITEM-MATERIAL        = LS_LOG-MATNR.          "商品代码1."           "采购订单数量'EA' .                   "采购订单的计量单位  LS_POITEM-PLANT           = LS_LOG-WERKS.          "工厂"库存地点
       
  APPEND LS_POITEM TO LT_POITEM.
       
  LS_POITEMX-PO_ITEM         =  '10'.          "采购凭证的项目编号'X'.            "商品代码  LS_POITEMX-QUANTITY        = 'X'.            "采购订单数量'X' .           "采购订单的计量单位  LS_POITEMX-PLANT           = 'X'.            "工厂'X'.            "库存地点
       
  APPEND LS_POITEMX TO LT_POITEMX.
       
  CLEAR LT_POCOND[].  CLEAR LT_POCONDX[].  CLEAR LS_POCOND.
       
  LS_POCOND-ITM_NUMBER = '10'.  LS_POCOND-COND_TYPE  = LS_LOG-KSCHA.  "定价条件  LS_POCOND-COND_VALUE = LS_LOG-AMOUNT."币别  LS_POCOND-CHANGE_ID   = 'I'.  "修改类型 I U  D
       
  APPEND LS_POCOND TO LT_POCOND.
       
  CLEAR LS_POCONDX.
       
'10'."定价条件  LS_POCONDX-COND_VALUE = 'X'.  "价格'X'.  "修改类型
       
  IF LS_POCOND-CURRENCY IS NOT INITIAL.    LS_POCONDX-CURRENCY   = 'X'.  "币别  ENDIF.
       
  APPEND LS_POCONDX TO LT_POCONDX.
       
*& call bapi
       
FUNCTION 'BAPI_PO_CREATE1'    EXPORTING      POHEADER         = LS_POHEADER      POHEADERX        = LS_POHEADERX    IMPORTING      EXPPURCHASEORDER = LV_PO_NUMBER    TABLESRETURN      POITEM           = LT_POITEM      POITEMX          = LT_POITEMX      POCOND           = LT_POCOND      POCONDX          = LT_POCONDX.
       
*--------------------------------------------------------------------**  save log*--------------------------------------------------------------------*  LS_LOG-EBELN = LV_PO_NUMBER.'S'.'创建成功'.
       
  LS_LOG-UNAME = SY-UNAME.  LS_LOG-DATUM = SY-DATUM.  LS_LOG-UZEIT = SY-UZEIT.
       
  ES_DATA = LS_LOG.
       
  INSERT ZLMT_PO_LOG FROM LS_LOG.
       
FUNCTION 'BAPI_TRANSACTION_COMMIT'    EXPORTING'X'.
       
*--------------------------------------------------------------------** 解锁*--------------------------------------------------------------------*FUNCTION 'DEQUEUE_EZLMT_PO_LOG'    EXPORTING*     MODE_ZLMT_PO_LOG       = 'X'      MANDT     = SY-MANDT      WEB_ORDER = LS_LOG-WEB_ORDER*     X_WEB_ORDER = ''*     _SCOPE    = '3'*     _SYNCHRON = ' '*     _COLLECT  = ' '    .ENDFUNCTION.
      
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.