在 dataweave 2.0 上按不同 json 元素的位置连接数据

Question

我有一个 SAP 函数的 JSON 输出：

{
    "Z_HYD_GET_INVOICES": {
        "import": {
            "BRANCH": "0142",
            "DOCNUMS": null,
            "FINAL_DATE": "Tue Oct 08 00:00:00 BST 2019",
            "INITIAL_DATE": "Mon Oct 07 00:00:00 BST 2019"
        },
        "export": {
            "ACCOUNTING": {
                "row": {
                    "DOCNUM": "0002990790",
                    "PSTDAT": "Mon Oct 07 00:00:00 BST 2019",
                    "BUKRS": "TRV"
                },
                "row": {
                    "DOCNUM": "0003006170",
                    "PSTDAT": "Mon Oct 07 00:00:00 BST 2019",
                    "BUKRS": "TRV"
                }
            },
            "FISCAL": {
                "row": {
                    "DOC_DOCNUM": "0002990790",
                    "DOC_NFTYPE": "ZW"
                },
                "row": {
                    "DOC_DOCNUM": "0003006170",
                    "DOC_INVTYPE": "ZW"
                }
            },
            "MESSAGE_RETURN": null,
            "STATUS_RETURN": null
        }
    }
}

我希望它是这样的：

{
  "invoices": [
    {
      "accounting": 
        {
          "accountingDocumentID": "0002990790",
          "taxEntryDate": "Mon Oct 07 00:00:00 BST 2019",
          "company": "TRV"
        },
      "fiscal": 
        {
          "fiscalDocument": {
            "fiscalDocumentID": "0002990790",
            "fiscalDocumentCategory": "ZW"
          }
        }
    },
    {
    "accounting": 
        {
          "accountingDocumentID": "0003006170",
          "taxEntryDate": "Mon Oct 07 00:00:00 BST 2019",
          "company": "TRV"
        },
    "fiscal": 
        {
          "fiscalDocument": {
            "fiscalDocumentID": "0003006170",
            "fiscalDocumentCategory": "ZW"
          }
        }
    }
  ]
}

我已经用 map 和 mapObject 尝试了一些代码，但都没有用。

FISCAL.DOC_DOCNUM 等于 FISCAL.DOCNUM，但如果变换按位置拟合可能会更好。我的意思是，将ACCOUNTING的第一个元素与FISCAL的第一个元素连接起来，依此类推...如果有人也可以通过ID提供转换连接，那就太好了，以供将来参考。

Answer 1

试一试。

%dw 2.0
output application/json
fun returnFiscalDoc (docnum) = {
    fiscalDocument : {(payload.Z_HYD_GET_INVOICES.export.FISCAL.*row filter ($.DOC_DOCNUM ~= docnum) map  {
        fiscalDocumentID: $.DOC_DOCNUM,
        fiscalDocumentCategory: $.DOC_NFTYPE default $.DOC_INVTYPE
    })}
}
---
invoices: payload.Z_HYD_GET_INVOICES.export.ACCOUNTING.*row map {
   accounting : 
     {
         accountingDocumentID: $.DOCNUM,
         taxEntryDate: $.PSTDAT,
         company:$.BUKRS
     },
   fiscal: returnFiscalDoc($.DOCNUM)
}

不过请记住，您在 FISCA.row 下的数据有 DOC_NFTYPE 和 DOC_INVTYPE。因此在上面的函数中使用了默认值来获得所需的值。

"FISCAL": {
                "row": {
                    "DOC_DOCNUM": "0002990790",
                    "DOC_NFTYPE": "ZW"
                },
                "row": {
                    "DOC_DOCNUM": "0003006170",
                    "DOC_INVTYPE": "ZW"
                }
            }

Answer 2

像这样的东西应该可以工作

%dw 2.0
output application/json
var filteredExport = (payload.Z_HYD_GET_INVOICES."export") filterObject ($$ ~= "ACCOUNTING" or $$ ~= "FISCAL")
var filteredExportArray = filteredExport pluck $
var accounting = filteredExport.ACCOUNTING pluck $
var fiscal = filteredExport.FISCAL pluck $
---
{
    invoices: filteredExportArray map {
        accounting: {
            accountingDocumentID: accounting[$$].DOCNUM,
            taxEntryDate: accounting[$$].PSTDAT,
            company: accounting[$$].BUKRS
        },
        fiscal: {
            fiscalDocument: {
                fiscalDocumentID: fiscal[$$].DOC_DOCNUM,
                fiscalDocumentCategory: if(!isEmpty(fiscal[$$].DOC_NFTYPE)) fiscal[$$].DOC_NFTYPE else if(!isEmpty(fiscal[$$].DOC_INVTYPE)) fiscal[$$].DOC_INVTYPE else null
            }
        }
    }
}

您也可以像您提到的那样在两个数组上使用连接函数

%dw 2.0
import * from dw::core::Arrays
output application/json
var filteredExport = (payload.Z_HYD_GET_INVOICES."export") filterObject ($$ ~= "ACCOUNTING" or $$ ~= "FISCAL")
var accounting = filteredExport.ACCOUNTING pluck $
var fiscal = filteredExport.FISCAL pluck $
var joined = leftJoin(accounting, fiscal, (a) -> a.DOCNUM, (f) -> f.DOC_DOCNUM)
---
{
    invoices: joined map {
        accounting: {
            accountingDocumentID: $.l.DOCNUM,
            taxEntryDate: $.l.PSTDAT,
            company: $.l.BUKRS
        },
        fiscal: {
            fiscalDocument: {
                fiscalDocumentID: $.r.DOC_DOCNUM,
                fiscalDocumentCategory: $.r.DOC_NFTYPE
            }
        }
    }
}

在 dataweave 2.0 上按不同 json 元素的位置连接数据

join data by position of different json elements on dataweave 2.0

json

mule

dataweave