ecc/SDDocumentFlow.sql (22 lines of code) (raw):

SELECT SO.mandt AS Client_MANDT, SO.VBELV AS SalesOrder_VBELV, SO.POSNV AS SalesItem_POSNV, Deliveries.VBELV AS DeliveryNumber_VBELV, Deliveries.POSNV AS DeliveryItem_POSNV, Deliveries.VBELN AS InvoiceNumber_VBELN, Deliveries.POSNN AS InvoiceItem_POSNN, SO.RFMNG AS DeliveredQty_RFMNG, SO.MEINS AS DeliveredUoM_MEINS, Deliveries.RFMNG AS InvoiceQty_RFMNG, Deliveries.MEINS AS InvoiceUoM_MEINS, Deliveries.RFWRT AS InvoiceValue_RFWRT, Deliveries.WAERS AS InvoiceCurrency_WAERS FROM `{{ project_id_src }}.{{ dataset_cdc_processed_ecc }}.vbfa` AS SO LEFT OUTER JOIN `{{ project_id_src }}.{{ dataset_cdc_processed_ecc }}.vbfa` AS Deliveries ON SO.VBELN = Deliveries.VBELV AND SO.mandt = Deliveries.mandt AND SO.POSNN = Deliveries.POSNV WHERE SO.vbtyp_V = 'C' AND SO.vbtyp_n IN ('J', 'T') AND Deliveries.vbtyp_n IN ('M') ORDER BY SO.VBELV