ENTIDAD SILVER DE ORDENES DE VENTAS 

Este modelo de datos pertenece a la capa Silver de la arquitectura de medallón, donde los datos han sido limpiados, integrados y estructurados para su uso en el ambito OI o BI. Se centra en los pedidos de venta dentro del módulo Sales and Distribution (SD) en SAP ECC, consolidando la información de órdenes de venta realizadas por los clientes.

El objetivo de este modelo es proporcionar una visión detallada y estructurada de los pedidos de venta facilitando su análisis asegurando un flujo eficiente de productos y servicios.

Categorización de la Entidad 

Esta entidad está categorizada en los siguientes ámbitos, según su propósito y aplicación:

BI_SILVER_SD_SALES_ORDER_ECC 

• Propósito: Análisis avanzados, generación de informes y dashboards sobre pedidos de venta. 

OI_SILVER_SD_SALES_ORDER_ECC 

• Propósito: Monitorización en tiempo real y mejora de la eficiencia en la gestión operativa de pedidos de venta. 
• Alcance de los Datos: Solo almacena pedidos con una antigüedad no mayor a un año, asegurando que los datos sean recientes y relevantes para análisis operacionales. Esta restricción mejora la calidad de los datos dentro del ámbito OI, optimizando el rendimiento en consultas en tiempo real. 
  

1. Ruta:
   \<raíz_del_proyecto>\dbt_oneconnect_ecc\models\ORDER_TO_CASH\
2. Nombre del archivo BI:
   BI_ORDER_TO_CASH\BI_SILVER_SD_SALES_ORDER_ECC.sql
3. Nombre del archivo OI:
   OI_ORDER_TO_CASH\OI_SILVER_SD_SALES_ORDER_ECC.sql

Dependencias 

• VBAK (Cabecera de Documento de Ventas)
  Contiene los datos generales de la cabecera de un documento de ventas en SAP, incluyendo información sobre el tipo de documento, fechas clave, cliente y condiciones de venta.
  <client>_<environment>_SD_PEDIDO_CABECERA
• VBAP (Posiciones de Documento de Ventas)
  Almacena los detalles de los ítems dentro de un documento de ventas, incluyendo materiales, cantidades, precios y condiciones de venta aplicables.
  <client>_<environment>_SD_PEDIDO_PARTIDA
• VBEP (Planificación de Entrega de Documento de Ventas)
  Contiene información sobre la planificación de entregas para cada posición del documento de ventas, incluyendo fechas de entrega, cantidades confirmadas y estado de disponibilidad.
  <client>_<environment>_SD_PEDIDO_REPARTO
• VBKD (Condiciones Comerciales del Documento de Ventas)
  Almacena información sobre condiciones comerciales específicas aplicadas en un documento de ventas, tales como acuerdos de pago, condiciones especiales y determinación de precios.
  <client>_<environment>_SD_PEDIDO_DATOS_VENTAS
• VBPA (Socios Comerciales del Documento de Ventas)
  Contiene los datos de los diferentes socios comerciales involucrados en un documento de ventas, como el cliente, destinatario, pagador y vendedor.
  <client>_<environment>_SD_PEDIDO_INTERLOCUTORES
• VBUK (Estado General del Documento de Ventas)
  Proporciona información sobre el estado general de un documento de ventas, incluyendo el estado de facturación, entrega, rechazo y bloqueo del pedido.
  <client>_<environment>_SD_PEDIDO_STATUS_CABECERA

Supuestos 

• Se consideran pedidos de venta únicamente aquellos registros donde el tipo de documento en SAP corresponde a 'C'. 
• Se considera como cliente solicitante del pedido al socio comercial donde vbpa.posicion = 0 y vbpa.funcion = 'AG', este filtro garantiza que cada pedido de venta se asocie correctamente con el cliente que lo generó, excluyendo otros socios comerciales como destinatarios de entrega, pagadores o transportistas. 
  

Instalación 

• Business Intelligence (BI)

docker-compose up -d dbt_bi_sales_order --build

• Operational Intelligence (OI)
  

docker-compose up -d dbt_oi_sales_order --build

Nota importante: En el ámbito OI, también se instalarán en cadena las entidades OI_GOLD_SD_OPEN_TRACKER_ECC y OI_GOLD_SD_INVENTORY_ECC. Es necesario verificar que ambas entidades estén listas para su ejecución antes de proceder. 

1. {{ config(
2.    order_by="(
3.        mandante_vbak, docvtas_vbak,  
4.        mandante_vbap, docvtas_vbap, posicion_vbap,
5.        mandante_vbep, docvtas_vbep, posicion_vbep, reparto_vbep,
6.        mandante_vbkd, doccomer_vbkd, posicion_vbkd,
7.        mandante_vbpa, doccomer_vbpa, posicion_vbpa, funcion_vbpa,
8.        mandante_vbuk, doccomer_vbuk
9.    )",
10.    engine='ReplacingMergeTree(_version)',
11.    materialized='incremental',
12.    incremental_strategy='append',
13.    pre_hook=[
14.         "{% if is_incremental() %}
15.             ALTER TABLE {{this}} DELETE
16.                WHERE docvtas_vbak IN (
17.                    SELECT docvtas_vbak
18.                    FROM {{this}} AS this FINAL
19.                    LEFT JOIN {{ source('oneconnect', 'PR0_B_SD_PEDIDO_CABECERA') }} AS src
20.                        ON src.tipo_doc = 'C' AND  src.docvtas = this.docvtas_vbak
21.                    WHERE src.docvtas = ''
22.                )
23.         {% endif %}"
24.     ]
25.    
26. )}}

1. WITH PEDIDO_CABECERA AS (
2.    SELECT 
3.        vbak.mandante AS mandante_vbak,
4.        vbak.docvtas AS docvtas_vbak,
5.        vbak.el AS el_vbak,
6.        vbak.hora AS hora_vbak,
7.        vbak.creado AS creado_vbak,
8.        vbak.valido_de AS valido_de_vbak,
9.        vbak.validez_a AS validez_a_vbak,
10.        vbak.fecha_doc AS fecha_doc_vbak,
11.        vbak.tipo_doc AS tipo_doc_vbak,
12.        vbak.grtrans AS grtrans_vbak,
13.        vbak.cldocventa AS cldocventa_vbak,
14.        vbak.motivo_ped AS motivo_ped_vbak,
15.        vbak.licitacion AS licitacion_vbak,
16.        vbak.bloqentreg AS bloqentreg_vbak,
17.        vbak.bloqfact AS bloqfact_vbak,
18.        vbak.valor_neto AS valor_neto_vbak,
19.        vbak.moneda AS moneda_vbak,
20.        vbak.orgventas AS orgventas_vbak,
21.        vbak.candistr AS candistr_vbak,
22.        vbak.sector AS sector_vbak,
23.        vbak.grvendedor AS grvendedor_vbak,
24.        vbak.oficvta AS oficvta_vbak,
25.        vbak.valido_de1 AS valido_de1_vbak,
26.        vbak.validez_a1 AS validez_a1_vbak,
27.        vbak.conddoc AS conddoc_vbak,
28.        vbak.feprefent AS feprefent_vbak,
29.        vbak.periodo AS periodo_vbak,
30.        vbak.entrcomp AS entrcomp_vbak,
31.        vbak.esqcalc AS esqcalc_vbak,
32.        vbak.condexp AS condexp_vbak,
33.        vbak.clfacped AS clfacped_vbak,
34.        vbak.probabil AS probabil_vbak,
35.        vbak.denom AS denom_vbak,
36.        vbak.pedido AS pedido_vbak,
37.        vbak.clpedido AS clpedido_vbak,
38.        vbak.fepedcpas AS fepedcpas_vbak,
39.        vbak.suplemento AS suplemento_vbak,
40.        vbak.referencia AS referencia_vbak,
41.        vbak.nombre AS nombre_vbak,
42.        vbak.telefono AS telefono_vbak,
43.        vbak.solic AS solic_vbak,
44.        vbak.cecoste AS cecoste_vbak,
45.        vbak.grupo_act AS grupo_act_vbak,
46.        vbak.moneda1 AS moneda1_vbak,
47.        vbak.mod AS mod_vbak,
48.        vbak.grclient1 AS grclient1_vbak,
49.        vbak.grclient2 AS grclient2_vbak,
50.        vbak.grclient3 AS grclient3_vbak,
51.        vbak.grclient5 AS grclient5_vbak,
52.        vbak.socco AS socco_vbak,
53.        vbak.acontrol AS acontrol_vbak,
54.        vbak.ctacred AS ctacred_vbak,
55.        vbak.grcclte AS grcclte_vbak,
56.        vbak.respons AS respons_vbak,
57.        vbak.clriesgo AS clriesgo_vbak,
58.        vbak.moneda2 AS moneda2_vbak,
59.        vbak.liberacion AS liberacion_vbak,
60.        vbak.fecha_sig AS fecha_sig_vbak,
61.        vbak.valcredito AS valcredito_vbak,
62.        vbak.jertipprec AS jertipprec_vbak,
63.        vbak.docmodelo AS docmodelo_vbak,
64.        vbak.soc_fact AS soc_fact_vbak,
65.        vbak.dif_clfis AS dif_clfis_vbak,
66.        vbak.clfis2clt AS clfis2clt_vbak,
67.        vbak.clfis3clt AS clfis3clt_vbak,
68.        vbak.referencia1 AS referencia1_vbak,
69.        vbak.asignacion AS asignacion_vbak,
70.        vbak.tipo_doc1 AS tipo_doc1_vbak,
71.        vbak.esqbusq AS esqbusq_vbak,
72.        vbak.perperiod AS perperiod_vbak,
73.        vbak.orden AS orden_vbak,
74.        vbak.h_entrdes AS h_entrdes_vbak,
75.        vbak.paisrecfis AS paisrecfis_vbak,
76.        vbak.ps_impto AS ps_impto_vbak,
77.        vbak.optriang AS optriang_vbak,
78.        vbak.puesdismat AS puesdismat_vbak,
79.        vbak.version AS version_vbak,
80.        vbak.pgcontrol AS pgcontrol_vbak,
81.        vbak.char70 AS char70_vbak,
82.        vbak.fechsol AS fechsol_vbak,
83.        vbak.hrsolped AS hrsolped_vbak,
84.        vbak.timestamp AS timestamp_vbak
85.    FROM {{ source('oneconnect', 'PR0_B_SD_PEDIDO_CABECERA') }} AS vbak
86.    FINAL
87.    WHERE 
88.        {% if is_incremental() %}
89.        vbak.timestamp >= (select max(timestamp_vbak) from {{this}}) AND
90.        {% endif %}
91.        vbak.tipo_doc = 'C'
92. ),
93. 
    
94. PEDIDO_INTERLOCUTORES AS (
95.    SELECT
96.        vbpa.mandante AS mandante_vbpa,
97.        vbpa.doccomer AS doccomer_vbpa,
98.        vbpa.posicion AS posicion_vbpa,
99.        vbpa.funcion AS funcion_vbpa,
100.        vbpa.cliente AS cliente_vbpa,
101.        vbpa.acreedor AS acreedor_vbpa,
102.        vbpa.n_pers AS n_pers_vbpa,
103.        vbpa.interl AS interl_vbpa,
104.        vbpa.direccion AS direccion_vbpa,
105.        vbpa.ptodesc AS ptodesc_vbpa,
106.        vbpa.pais AS pais_vbpa,
107.        vbpa.inddirec AS inddirec_vbpa,
108.        vbpa.cuenta_cpd AS cuenta_cpd_vbpa,
109.        vbpa.denointerl AS denointerl_vbpa,
110.        vbpa.zona AS zona_vbpa,
111.        vbpa.nifcom AS nifcom_vbpa,
112.        vbpa.persona AS persona_vbpa,
113.        vbpa.fecha AS fecha_vbpa,
114.        vbpa.timestamp AS timestamp_vbpa
115.    FROM {{ source('oneconnect', 'PR0_B_SD_PEDIDO_INTERLOCUTORES') }} AS vbpa
116.    FINAL
117.    WHERE
118.        {% if is_incremental() %}
119.        vbpa.timestamp >= (select max(timestamp_vbpa) from {{this}}) AND
120.        {% endif %}
121.        vbpa.posicion = 0 AND vbpa.funcion = 'AG'
122. 
     
123. ),
124. 
     
125. PEDIDO_STATUS_CABECERA AS (
126.    SELECT
127.        vbuk.mandante AS mandante_vbuk,
128.        vbuk.doccomer AS doccomer_vbuk,
129.        vbuk.status_ref AS status_ref_vbuk,
130.        vbuk.statreftot AS statreftot_vbuk,
131.        vbuk.confirmado AS confirmado_vbuk,
132.        vbuk.statentreg AS statentreg_vbuk,
133.        vbuk.entregatot AS entregatot_vbuk,
134.        vbuk.sttotmovme AS sttotmovme_vbuk,
135.        vbuk.statfact AS statfact_vbuk,
136.        vbuk.statfacped AS statfacped_vbuk,
137.        vbuk.statuscont AS statuscont_vbuk,
138.        vbuk.statrechaz AS statrechaz_vbuk,
139.        vbuk.statusglob AS statusglob_vbuk,
140.        vbuk.sttotpick AS sttotpick_vbuk,
141.        vbuk.statglwm AS statglwm_vbuk,
142.        vbuk.datos_pos AS datos_pos_vbuk,
143.        vbuk.datposentr AS datposentr_vbuk,
144.        vbuk.datposfact AS datposfact_vbuk,
145.        vbuk.datos_cab AS datos_cab_vbuk,
146.        vbuk.cabentrega AS cabentrega_vbuk,
147.        vbuk.cab_fact AS cab_fact_vbuk,
148.        vbuk.detprc AS detprc_vbuk,
149.        vbuk.tipo_doc AS tipo_doc_vbuk,
150.        vbuk.objeto AS objeto_vbuk,
151.        vbuk.mod AS mod_vbuk,
152.        vbuk.sttotci AS sttotci_vbuk,
153.        vbuk.estatica AS estatica_vbuk,
154.        vbuk.dinamica AS dinamica_vbuk,
155.        vbuk.valor AS valor_vbuk,
156.        vbuk.condpago AS condpago_vbuk,
157.        vbuk.partabiert AS partabiert_vbuk,
158.        vbuk.docfinanc AS docfinanc_vbuk,
159.        vbuk.reserva1 AS reserva1_vbuk,
160.        vbuk.statuscred AS statuscred_vbuk,
161.        vbuk.status_pt AS status_pt_vbuk,
162.        vbuk.confirm AS confirm_vbuk,
163.        vbuk.release AS release_vbuk,
164.        vbuk.datposemb AS datposemb_vbuk,
165.        vbuk.datpospick AS datpospick_vbuk,
166.        vbuk.datposmm AS datposmm_vbuk,
167.        vbuk.embcab AS embcab_vbuk,
168.        vbuk.cabpick AS cabpick_vbuk,
169.        vbuk.cabmovmcia AS cabmovmcia_vbuk,
170.        vbuk.stbqfctgrl AS stbqfctgrl_vbuk,
171.        vbuk.stbloqentr AS stbloqentr_vbuk,
172.        vbuk.stbloqtot AS stbloqtot_vbuk,
173.        vbuk.timestamp AS timestamp_vbuk
174.    FROM {{ source('oneconnect', 'PR0_B_SD_PEDIDO_STATUS_CABECERA') }} AS vbuk
175.    FINAL
176.    {% if is_incremental() %}
177.    WHERE
178.        vbuk.timestamp >= (select max(timestamp_vbuk) from {{this}}) 
179.    {% endif %}
180. ),
181. 
     
182. PEDIDO_DATOS_VENTAS AS (
183.    SELECT
184.        vbkd.mandante AS mandante_vbkd,
185.        vbkd.doccomer AS doccomer_vbkd,
186.        vbkd.posicion AS posicion_vbkd,
187.        vbkd.grprecios AS grprecios_vbkd,
188.        vbkd.grclient AS grclient_vbkd,
189.        vbkd.zona_vta AS zona_vta_vbkd,
190.        vbkd.listaprec AS listaprec_vbkd,
191.        vbkd.incoterms AS incoterms_vbkd,
192.        vbkd.incoterms2 AS incoterms2_vbkd,
193.        vbkd.agrupam AS agrupam_vbkd,
194.        vbkd.fefacturac AS fefacturac_vbkd,
195.        vbkd.tratpostfc AS tratpostfc_vbkd,
196.        vbkd.cambiocont AS cambiocont_vbkd,
197.        vbkd.dias_valor AS dias_valor_vbkd,
198.        vbkd.fevalfijad AS fevalfijad_vbkd,
199.        vbkd.condpago AS condpago_vbkd,
200.        vbkd.via_pago AS via_pago_vbkd,
201.        vbkd.grimput AS grimput_vbkd,
202.        vbkd.tpcambio AS tpcambio_vbkd,
203.        vbkd.feprecio AS feprecio_vbkd,
204.        vbkd.fechafact AS fechafact_vbkd,
205.        vbkd.fepresserv AS fepresserv_vbkd,
206.        vbkd.periodo AS periodo_vbkd,
207.        vbkd.ticambest AS ticambest_vbkd,
208.        vbkd.clvrecl AS clvrecl_vbkd,
209.        vbkd.bloqrecl AS bloqrecl_vbkd,
210.        vbkd.plfact AS plfact_vbkd,
211.        vbkd.esqgarant AS esqgarant_vbkd,
212.        vbkd.n_docfin AS n_docfin_vbkd,
213.        vbkd.depto AS depto_vbkd,
214.        vbkd.ptorecep AS ptorecep_vbkd,
215.        vbkd.pedido AS pedido_vbkd,
216.        vbkd.fepedcpas AS fepedcpas_vbkd,
217.        vbkd.clpedido AS clpedido_vbkd,
218.        vbkd.referencia AS referencia_vbkd,
219.        vbkd.pedidocomp AS pedidocomp_vbkd,
220.        vbkd.feped AS feped_vbkd,
221.        vbkd.clase_ped AS clase_ped_vbkd,
222.        vbkd.caracter AS caracter_vbkd,
223.        vbkd.pospedido AS pospedido_vbkd,
224.        vbkd.feconv AS feconv_vbkd,
225.        vbkd.feconv1 AS feconv1_vbkd,
226.        vbkd.grcond1 AS grcond1_vbkd,
227.        vbkd.grcond2 AS grcond2_vbkd,
228.        vbkd.moncartcre AS moncartcre_vbkd,
229.        vbkd.tpcambcart AS tpcambcart_vbkd,
230.        vbkd.pedido1 AS pedido1_vbkd,
231.        vbkd.perfil AS perfil_vbkd,
232.        vbkd.formfactur AS formfactur_vbkd,
233.        vbkd.t_camion AS t_camion_vbkd,
234.        vbkd.clmedtrans AS clmedtrans_vbkd,
235.        vbkd.relare AS relare_vbkd,
236.        vbkd.timestamp AS timestamp_vbkd
237.    FROM {{ source('oneconnect', 'PR0_B_SD_PEDIDO_DATOS_VENTAS') }} AS vbkd
238.    FINAL
239.    {% if is_incremental() %}
240.    WHERE
241.        vbkd.timestamp >= (select max(timestamp_vbkd) from {{this}}) 
242.    {% endif %}
243. ),
244. 
     
245. PEDIDO_PARTIDA AS (
246.    SELECT 
247.        vbap.mandante AS mandante_vbap,
248.        vbap.docvtas AS docvtas_vbap,
249.        vbap.posicion AS posicion_vbap,
250.        vbap.material AS material_vbap,
251.        vbap.matintr AS matintr_vbap,
252.        vbap.lote AS lote_vbap,
253.        vbap.gpoartic AS gpoartic_vbap,
254.        vbap.denomin AS denomin_vbap,
255.        vbap.tipo_pos AS tipo_pos_vbap,
256.        vbap.clase_pos AS clase_pos_vbap,
257.        vbap.pos_entr AS pos_entr_vbap,
258.        vbap.relfact AS relfact_vbap,
259.        vbap.pos_sup AS pos_sup_vbap,
260.        vbap.motivrech AS motivrech_vbap,
261.        vbap.jquiaprod AS jquiaprod_vbap,
262.        vbap.ctdprev AS ctdprev_vbap,
263.        vbap.umctdprev AS umctdprev_vbap,
264.        vbap.contador AS contador_vbap,
265.        vbap.denom AS denom_vbap,
266.        vbap.unidad AS unidad_vbap,
267.        vbap.pospedido AS pospedido_vbap,
268.        vbap.matcliente AS matcliente_vbap,
269.        vbap.claspos AS claspos_vbap,
270.        vbap.utiliz AS utiliz_vbap,
271.        vbap.grentrega AS grentrega_vbap,
272.        vbap.ctdfija AS ctdfija_vbap,
273.        vbap.ilimitado AS ilimitado_vbap,
274.        vbap.bloqfact AS bloqfact_vbap,
275.        vbap.sector AS sector_vbap,
276.        vbap.division AS division_vbap,
277.        vbap.valor_neto AS valor_neto_vbap,
278.        vbap.moneda AS moneda_vbap,
279.        vbap.maxentrpar AS maxentrpar_vbap,
280.        vbap.ctdped AS ctdped_vbap,
281.        vbap.entregreq AS entregreq_vbap,
282.        vbap.cantacconf AS cantacconf_vbap,
283.        vbap.cantacconf1 AS cantacconf1_vbap,
284.        vbap.um_venta AS um_venta_vbap,
285.        vbap.contador1 AS contador1_vbap,
286.        vbap.denomin1 AS denomin1_vbap,
287.        vbap.bruto AS bruto_vbap,
288.        vbap.peso_neto AS peso_neto_vbap,
289.        vbap.unidad1 AS unidad1_vbap,
290.        vbap.volumen AS volumen_vbap,
291.        vbap.unvolumen AS unvolumen_vbap,
292.        vbap.causante AS causante_vbap,
293.        vbap.posicion1 AS posicion1_vbap,
294.        vbap.docmodelo AS docmodelo_vbap,
295.        vbap.posmodelo AS posmodelo_vbap,
296.        vbap.refcompl AS refcompl_vbap,
297.        vbap.actflujo AS actflujo_vbap,
298.        vbap.reglas_liq AS reglas_liq_vbap,
299.        vbap.priorentr AS priorentr_vbap,
300.        vbap.centro AS centro_vbap,
301.        vbap.almacen AS almacen_vbap,
302.        vbap.puestexped AS puestexped_vbap,
303.        vbap.ruta AS ruta_vbap,
304.        vbap.origlismat AS origlismat_vbap,
305.        vbap.fefijlmat AS fefijlmat_vbap,
306.        vbap.lista_mat AS lista_mat_vbap,
307.        vbap.probabil AS probabil_vbap,
308.        vbap.el AS el_vbap,
309.        vbap.creado AS creado_vbap,
310.        vbap.hora AS hora_vbap,
311.        vbap.clasiffisc AS clasiffisc_vbap,
312.        vbap.clasiffisc1 AS clasiffisc1_vbap,
313.        vbap.clasiffisc2 AS clasiffisc2_vbap,
314.        vbap.antref AS antref_vbap,
315.        vbap.prcneto AS prcneto_vbap,
316.        vbap.unidad2 AS unidad2_vbap,
317.        vbap.unidad3 AS unidad3_vbap,
318.        vbap.devoluc AS devoluc_vbap,
319.        vbap.der_desc AS der_desc_vbap,
320.        vbap.verifdisp AS verifdisp_vbap,
321.        vbap.total_nec AS total_nec_vbap,
322.        vbap.grmater AS grmater_vbap,
323.        vbap.grimpmat AS grimpmat_vbap,
324.        vbap.grprappels AS grprappels_vbap,
325.        vbap.grcomis AS grcomis_vbap,
326.        vbap.detprc AS detprc_vbap,
327.        vbap.clvalor AS clvalor_vbap,
328.        vbap.valsepar AS valsepar_vbap,
329.        vbap.sujetlote AS sujetlote_vbap,
330.        vbap.lotes AS lotes_vbap,
331.        vbap.cantentr AS cantentr_vbap,
332.        vbap.grupo_act AS grupo_act_vbap,
333.        vbap.costint AS costint_vbap,
334.        vbap.subtotal_1 AS subtotal_1_vbap,
335.        vbap.subtotal_2 AS subtotal_2_vbap,
336.        vbap.subtotal_3 AS subtotal_3_vbap,
337.        vbap.subtotal_4 AS subtotal_4_vbap,
338.        vbap.subtotal_5 AS subtotal_5_vbap,
339.        vbap.subtotal_6 AS subtotal_6_vbap,
340.        vbap.cambestad AS cambestad_vbap,
341.        vbap.mod AS mod_vbap,
342.        vbap.eanupc AS eanupc_vbap,
343.        vbap.fijada AS fijada_vbap,
344.        vbap.cebe AS cebe_vbap,
345.        vbap.grmater1 AS grmater1_vbap,
346.        vbap.grmater2 AS grmater2_vbap,
347.        vbap.grmater3 AS grmater3_vbap,
348.        vbap.grmater4 AS grmater4_vbap,
349.        vbap.grmater5 AS grmater5_vbap,
350.        vbap.cantidad AS cantidad_vbap,
351.        vbap.stockesp AS stockesp_vbap,
352.        vbap.indasig AS indasig_vbap,
353.        vbap.objetos_pa AS objetos_pa_vbap,
354.        vbap.orden AS orden_vbap,
355.        vbap.matpreplan AS matpreplan_vbap,
356.        vbap.centprepl AS centprepl_vbap,
357.        vbap.umgrpr AS umgrpr_vbap,
358.        vbap.conversion AS conversion_vbap,
359.        vbap.tpimput AS tpimput_vbap,
360.        vbap.consumo AS consumo_vbap,
361.        vbap.n_obj_ps AS n_obj_ps_vbap,
362.        vbap.clvper AS clvper_vbap,
363.        vbap.clnec AS clnec_vbap,
364.        vbap.precio AS precio_vbap,
365.        vbap.credactivo AS credactivo_vbap,
366.        vbap.cambio AS cambio_vbap,
367.        vbap.nobj_int AS nobj_int_vbap,
368.        vbap.precprev AS precprev_vbap,
369.        vbap.perfil AS perfil_vbap,
370.        vbap.ctdnserie AS ctdnserie_vbap,
371.        vbap.grmatme AS grmatme_vbap,
372.        vbap.prcman AS prcman_vbap,
373.        vbap.tipo_doc AS tipo_doc_vbap,
374.        vbap.utl_poss AS utl_poss_vbap,
375.        vbap.n_cc AS n_cc_vbap,
376.        vbap.varcc AS varcc_vbap,
377.        vbap.posicion2 AS posicion2_vbap,
378.        vbap.valestadis AS valestadis_vbap,
379.        vbap.opercial AS opercial_vbap,
380.        vbap.nrgtocdlt AS nrgtocdlt_vbap,
381.        vbap.tipolmat AS tipolmat_vbap,
382.        vbap.nodos AS nodos_vbap,
383.        vbap.contador2 AS contador2_vbap,
384.        vbap.esqcalc AS esqcalc_vbap,
385.        vbap.matdprcppr AS matdprcppr_vbap,
386.        vbap.grmatppr AS grmatppr_vbap,
387.        vbap.preccred AS preccred_vbap,
388.        vbap.formgarant AS formgarant_vbap,
389.        vbap.garantiz AS garantiz_vbap,
390.        vbap.valoracion AS valoracion_vbap,
391.        vbap.ctrolentbe AS ctrolentbe_vbap,
392.        vbap.impuesto AS impuesto_vbap,
393.        vbap.areaplnec AS areaplnec_vbap,
394.        vbap.cebenfact AS cebenfact_vbap,
395.        vbap.sistlog AS sistlog_vbap,
396.        vbap.el1 AS el1_vbap,
397.        vbap.a_las AS a_las_vbap,
398.        vbap.cecoste AS cecoste_vbap,
399.        vbap.estado AS estado_vbap,
400.        vbap.creado1 AS creado1_vbap,
401.        vbap.el2 AS el2_vbap,
402.        vbap.timestamp AS timestamp_vbap
403.    FROM {{ source('oneconnect', 'PR0_B_SD_PEDIDO_PARTIDA') }} AS vbap 
404.    FINAL
405.    {% if is_incremental() %}
406.    WHERE
407.        vbap.timestamp >= (select max(timestamp_vbap) from {{this}}) 
408.    {% endif %}
409. ),
410. 
     
411. PEDIDO_REPARTO AS (
412.    SELECT
413.        vbep.mandante AS mandante_vbep,
414.        vbep.docvtas AS docvtas_vbep,
415.        vbep.posicion AS posicion_vbep,
416.        vbep.reparto AS reparto_vbep,
417.        vbep.tiporepart AS tiporepart_vbep,
418.        vbep.pos_entr AS pos_entr_vbep,
419.        vbep.feentrega AS feentrega_vbep,
420.        vbep.horaentreg AS horaentreg_vbep,
421.        vbep.ctdped AS ctdped_vbep,
422.        vbep.ctdconf AS ctdconf_vbep,
423.        vbep.um_venta AS um_venta_vbep,
424.        vbep.ctdneces AS ctdneces_vbep,
425.        vbep.unidad AS unidad_vbep,
426.        vbep.clnec AS clnec_vbep,
427.        vbep.clplanif AS clplanif_vbep,
428.        vbep.fechareser AS fechareser_vbep,
429.        vbep.tipo_fecha AS tipo_fecha_vbep,
430.        vbep.pltransp AS pltransp_vbep,
431.        vbep.puesdismat AS puesdismat_vbep,
432.        vbep.fecarga AS fecarga_vbep,
433.        vbep.salmcias AS salmcias_vbep,
434.        vbep.ctdcorr AS ctdcorr_vbep,
435.        vbep.bloqentreg AS bloqentreg_vbep,
436.        vbep.contador AS contador_vbep,
437.        vbep.denomin AS denomin_vbep,
438.        vbep.confirmado AS confirmado_vbep,
439.        vbep.clmov AS clmov_vbep,
440.        vbep.modific AS modific_vbep,
441.        vbep.garantiz AS garantiz_vbep,
442.        vbep.h_pdispmat AS h_pdispmat_vbep,
443.        vbep.hplantrans AS hplantrans_vbep,
444.        vbep.hora_carga AS hora_carga_vbep,
445.        vbep.hora_sm AS hora_sm_vbep,
446.        vbep.timestamp AS timestamp_vbep
447.    FROM {{ source('oneconnect', 'PR0_B_SD_PEDIDO_REPARTO') }} AS vbep
448.    FINAL
449.    {% if is_incremental() %}
450.    WHERE
451.        vbep.timestamp >= (select max(timestamp_vbep) from {{this}}) 
452.    {% endif %}
453. )
454. 
     
455. SELECT 
456.    vbak.*,
457.    vbap.*,
458.    vbep.*,
459.    vbkd.*,
460.    vbpa.*,
461.    vbuk.*,
462.    now64() as _version
463. 
     
464. FROM PEDIDO_CABECERA AS vbak
465. INNER JOIN PEDIDO_INTERLOCUTORES AS vbpa
466.    ON vbpa.mandante_vbpa = vbak.mandante_vbak 
467.    AND vbpa.doccomer_vbpa = vbak.docvtas_vbak
468. INNER JOIN PEDIDO_STATUS_CABECERA AS vbuk
469.    ON vbuk.mandante_vbuk = vbak.mandante_vbak
470.    AND vbuk.doccomer_vbuk = vbak.docvtas_vbak
471. INNER JOIN PEDIDO_DATOS_VENTAS AS vbkd
472.    ON vbkd.mandante_vbkd = vbak.mandante_vbak
473.    AND vbkd.doccomer_vbkd = vbak.docvtas_vbak
474. INNER JOIN PEDIDO_PARTIDA AS vbap 
475.    ON vbap.mandante_vbap = vbak.mandante_vbak
476.    AND vbap.docvtas_vbap = vbak.docvtas_vbak
477. INNER JOIN PEDIDO_REPARTO AS vbep
478.    ON vbep.mandante_vbep = vbap.mandante_vbap
479.    AND vbep.docvtas_vbep = vbap.docvtas_vbap
480.    AND  vbep.posicion_vbep = vbap.posicion_vbap

Modelo sql OI ejecutado 

1. {{ config(
2.    order_by="(
3.        mandante_vbak, docvtas_vbak,  
4.        mandante_vbap, docvtas_vbap, posicion_vbap,
5.        mandante_vbep, docvtas_vbep, posicion_vbep, reparto_vbep,
6.        mandante_vbkd, doccomer_vbkd, posicion_vbkd,
7.        mandante_vbpa, doccomer_vbpa, posicion_vbpa, funcion_vbpa,
8.        mandante_vbuk, doccomer_vbuk
9.    )",
10.    engine='ReplacingMergeTree(_version)',
11.    materialized='incremental',
12.    incremental_strategy='append',
13.    pre_hook=[
14.         "{% if is_incremental() %}
15.             ALTER TABLE {{this}} DELETE
16.                WHERE docvtas_vbak IN (
17.                    SELECT docvtas_vbak
18.                    FROM {{this}} AS this FINAL
19.                    LEFT JOIN {{ source('oneconnect', 'PR0_B_SD_PEDIDO_CABECERA') }} AS src
20.                        ON src.tipo_doc = 'C' AND  src.docvtas = this.docvtas_vbak
21.                    WHERE src.docvtas = ''
22.                )
23.         {% endif %}",
24.        "{% if is_incremental() %}
25.             ALTER TABLE {{this}} DELETE
26.                WHERE toDate(el_vbak, 'YYYYMMDD') < toDate(subtractYears(now(), 1))
27.         {% endif %}"
28.     ]
29.    
30. )}}
31. 
    
32. 
    
33. WITH PEDIDO_CABECERA AS (
34.    SELECT 
35.        vbak.mandante AS mandante_vbak,
36.        vbak.docvtas AS docvtas_vbak,
37.        vbak.el AS el_vbak,
38.        vbak.hora AS hora_vbak,
39.        vbak.creado AS creado_vbak,
40.        vbak.valido_de AS valido_de_vbak,
41.        vbak.validez_a AS validez_a_vbak,
42.        vbak.fecha_doc AS fecha_doc_vbak,
43.        vbak.tipo_doc AS tipo_doc_vbak,
44.        vbak.grtrans AS grtrans_vbak,
45.        vbak.cldocventa AS cldocventa_vbak,
46.        vbak.motivo_ped AS motivo_ped_vbak,
47.        vbak.licitacion AS licitacion_vbak,
48.        vbak.bloqentreg AS bloqentreg_vbak,
49.        vbak.bloqfact AS bloqfact_vbak,
50.        vbak.valor_neto AS valor_neto_vbak,
51.        vbak.moneda AS moneda_vbak,
52.        vbak.orgventas AS orgventas_vbak,
53.        vbak.candistr AS candistr_vbak,
54.        vbak.sector AS sector_vbak,
55.        vbak.grvendedor AS grvendedor_vbak,
56.        vbak.oficvta AS oficvta_vbak,
57.        vbak.valido_de1 AS valido_de1_vbak,
58.        vbak.validez_a1 AS validez_a1_vbak,
59.        vbak.conddoc AS conddoc_vbak,
60.        vbak.feprefent AS feprefent_vbak,
61.        vbak.periodo AS periodo_vbak,
62.        vbak.entrcomp AS entrcomp_vbak,
63.        vbak.esqcalc AS esqcalc_vbak,
64.        vbak.condexp AS condexp_vbak,
65.        vbak.clfacped AS clfacped_vbak,
66.        vbak.probabil AS probabil_vbak,
67.        vbak.denom AS denom_vbak,
68.        vbak.pedido AS pedido_vbak,
69.        vbak.clpedido AS clpedido_vbak,
70.        vbak.fepedcpas AS fepedcpas_vbak,
71.        vbak.suplemento AS suplemento_vbak,
72.        vbak.referencia AS referencia_vbak,
73.        vbak.nombre AS nombre_vbak,
74.        vbak.telefono AS telefono_vbak,
75.        vbak.solic AS solic_vbak,
76.        vbak.cecoste AS cecoste_vbak,
77.        vbak.grupo_act AS grupo_act_vbak,
78.        vbak.moneda1 AS moneda1_vbak,
79.        vbak.mod AS mod_vbak,
80.        vbak.grclient1 AS grclient1_vbak,
81.        vbak.grclient2 AS grclient2_vbak,
82.        vbak.grclient3 AS grclient3_vbak,
83.        vbak.grclient5 AS grclient5_vbak,
84.        vbak.socco AS socco_vbak,
85.        vbak.acontrol AS acontrol_vbak,
86.        vbak.ctacred AS ctacred_vbak,
87.        vbak.grcclte AS grcclte_vbak,
88.        vbak.respons AS respons_vbak,
89.        vbak.clriesgo AS clriesgo_vbak,
90.        vbak.moneda2 AS moneda2_vbak,
91.        vbak.liberacion AS liberacion_vbak,
92.        vbak.fecha_sig AS fecha_sig_vbak,
93.        vbak.valcredito AS valcredito_vbak,
94.        vbak.jertipprec AS jertipprec_vbak,
95.        vbak.docmodelo AS docmodelo_vbak,
96.        vbak.soc_fact AS soc_fact_vbak,
97.        vbak.dif_clfis AS dif_clfis_vbak,
98.        vbak.clfis2clt AS clfis2clt_vbak,
99.        vbak.clfis3clt AS clfis3clt_vbak,
100.        vbak.referencia1 AS referencia1_vbak,
101.        vbak.asignacion AS asignacion_vbak,
102.        vbak.tipo_doc1 AS tipo_doc1_vbak,
103.        vbak.esqbusq AS esqbusq_vbak,
104.        vbak.perperiod AS perperiod_vbak,
105.        vbak.orden AS orden_vbak,
106.        vbak.h_entrdes AS h_entrdes_vbak,
107.        vbak.paisrecfis AS paisrecfis_vbak,
108.        vbak.ps_impto AS ps_impto_vbak,
109.        vbak.optriang AS optriang_vbak,
110.        vbak.puesdismat AS puesdismat_vbak,
111.        vbak.version AS version_vbak,
112.        vbak.pgcontrol AS pgcontrol_vbak,
113.        vbak.char70 AS char70_vbak,
114.        vbak.fechsol AS fechsol_vbak,
115.        vbak.hrsolped AS hrsolped_vbak,
116.        vbak.timestamp AS timestamp_vbak
117.    FROM {{ source('oneconnect', 'PR0_B_SD_PEDIDO_CABECERA') }} AS vbak
118.    FINAL
119.    WHERE 
120.        toDate(vbak.el) >= toDate(subtractYears(now(), 1))
121.        {% if is_incremental() %}
122.        AND vbak.timestamp >= (select max(timestamp_vbak) from {{this}})
123.        {% endif %}
124.        AND vbak.tipo_doc = 'C'
125. ),
126. 
     
127. PEDIDO_INTERLOCUTORES AS (
128.    SELECT
129.        vbpa.mandante AS mandante_vbpa,
130.        vbpa.doccomer AS doccomer_vbpa,
131.        vbpa.posicion AS posicion_vbpa,
132.        vbpa.funcion AS funcion_vbpa,
133.        vbpa.cliente AS cliente_vbpa,
134.        vbpa.acreedor AS acreedor_vbpa,
135.        vbpa.n_pers AS n_pers_vbpa,
136.        vbpa.interl AS interl_vbpa,
137.        vbpa.direccion AS direccion_vbpa,
138.        vbpa.ptodesc AS ptodesc_vbpa,
139.        vbpa.pais AS pais_vbpa,
140.        vbpa.inddirec AS inddirec_vbpa,
141.        vbpa.cuenta_cpd AS cuenta_cpd_vbpa,
142.        vbpa.denointerl AS denointerl_vbpa,
143.        vbpa.zona AS zona_vbpa,
144.        vbpa.nifcom AS nifcom_vbpa,
145.        vbpa.persona AS persona_vbpa,
146.        vbpa.fecha AS fecha_vbpa,
147.        vbpa.timestamp AS timestamp_vbpa
148.    FROM {{ source('oneconnect', 'PR0_B_SD_PEDIDO_INTERLOCUTORES') }} AS vbpa
149.    FINAL
150.    WHERE
151.        {% if is_incremental() %}
152.        vbpa.timestamp >= (select max(timestamp_vbpa) from {{this}}) AND
153.        {% endif %}
154.        vbpa.posicion = 0 AND vbpa.funcion = 'AG'
155. 
     
156. ),
157. 
     
158. PEDIDO_STATUS_CABECERA AS (
159.    SELECT
160.        vbuk.mandante AS mandante_vbuk,
161.        vbuk.doccomer AS doccomer_vbuk,
162.        vbuk.status_ref AS status_ref_vbuk,
163.        vbuk.statreftot AS statreftot_vbuk,
164.        vbuk.confirmado AS confirmado_vbuk,
165.        vbuk.statentreg AS statentreg_vbuk,
166.        vbuk.entregatot AS entregatot_vbuk,
167.        vbuk.sttotmovme AS sttotmovme_vbuk,
168.        vbuk.statfact AS statfact_vbuk,
169.        vbuk.statfacped AS statfacped_vbuk,
170.        vbuk.statuscont AS statuscont_vbuk,
171.        vbuk.statrechaz AS statrechaz_vbuk,
172.        vbuk.statusglob AS statusglob_vbuk,
173.        vbuk.sttotpick AS sttotpick_vbuk,
174.        vbuk.statglwm AS statglwm_vbuk,
175.        vbuk.datos_pos AS datos_pos_vbuk,
176.        vbuk.datposentr AS datposentr_vbuk,
177.        vbuk.datposfact AS datposfact_vbuk,
178.        vbuk.datos_cab AS datos_cab_vbuk,
179.        vbuk.cabentrega AS cabentrega_vbuk,
180.        vbuk.cab_fact AS cab_fact_vbuk,
181.        vbuk.detprc AS detprc_vbuk,
182.        vbuk.tipo_doc AS tipo_doc_vbuk,
183.        vbuk.objeto AS objeto_vbuk,
184.        vbuk.mod AS mod_vbuk,
185.        vbuk.sttotci AS sttotci_vbuk,
186.        vbuk.estatica AS estatica_vbuk,
187.        vbuk.dinamica AS dinamica_vbuk,
188.        vbuk.valor AS valor_vbuk,
189.        vbuk.condpago AS condpago_vbuk,
190.        vbuk.partabiert AS partabiert_vbuk,
191.        vbuk.docfinanc AS docfinanc_vbuk,
192.        vbuk.reserva1 AS reserva1_vbuk,
193.        vbuk.statuscred AS statuscred_vbuk,
194.        vbuk.status_pt AS status_pt_vbuk,
195.        vbuk.confirm AS confirm_vbuk,
196.        vbuk.release AS release_vbuk,
197.        vbuk.datposemb AS datposemb_vbuk,
198.        vbuk.datpospick AS datpospick_vbuk,
199.        vbuk.datposmm AS datposmm_vbuk,
200.        vbuk.embcab AS embcab_vbuk,
201.        vbuk.cabpick AS cabpick_vbuk,
202.        vbuk.cabmovmcia AS cabmovmcia_vbuk,
203.        vbuk.stbqfctgrl AS stbqfctgrl_vbuk,
204.        vbuk.stbloqentr AS stbloqentr_vbuk,
205.        vbuk.stbloqtot AS stbloqtot_vbuk,
206.        vbuk.timestamp AS timestamp_vbuk
207.    FROM {{ source('oneconnect', 'PR0_B_SD_PEDIDO_STATUS_CABECERA') }} AS vbuk
208.    FINAL
209.    {% if is_incremental() %}
210.    WHERE
211.        vbuk.timestamp >= (select max(timestamp_vbuk) from {{this}}) 
212.    {% endif %}
213. ),
214. 
     
215. PEDIDO_DATOS_VENTAS AS (
216.    SELECT
217.        vbkd.mandante AS mandante_vbkd,
218.        vbkd.doccomer AS doccomer_vbkd,
219.        vbkd.posicion AS posicion_vbkd,
220.        vbkd.grprecios AS grprecios_vbkd,
221.        vbkd.grclient AS grclient_vbkd,
222.        vbkd.zona_vta AS zona_vta_vbkd,
223.        vbkd.listaprec AS listaprec_vbkd,
224.        vbkd.incoterms AS incoterms_vbkd,
225.        vbkd.incoterms2 AS incoterms2_vbkd,
226.        vbkd.agrupam AS agrupam_vbkd,
227.        vbkd.fefacturac AS fefacturac_vbkd,
228.        vbkd.tratpostfc AS tratpostfc_vbkd,
229.        vbkd.cambiocont AS cambiocont_vbkd,
230.        vbkd.dias_valor AS dias_valor_vbkd,
231.        vbkd.fevalfijad AS fevalfijad_vbkd,
232.        vbkd.condpago AS condpago_vbkd,
233.        vbkd.via_pago AS via_pago_vbkd,
234.        vbkd.grimput AS grimput_vbkd,
235.        vbkd.tpcambio AS tpcambio_vbkd,
236.        vbkd.feprecio AS feprecio_vbkd,
237.        vbkd.fechafact AS fechafact_vbkd,
238.        vbkd.fepresserv AS fepresserv_vbkd,
239.        vbkd.periodo AS periodo_vbkd,
240.        vbkd.ticambest AS ticambest_vbkd,
241.        vbkd.clvrecl AS clvrecl_vbkd,
242.        vbkd.bloqrecl AS bloqrecl_vbkd,
243.        vbkd.plfact AS plfact_vbkd,
244.        vbkd.esqgarant AS esqgarant_vbkd,
245.        vbkd.n_docfin AS n_docfin_vbkd,
246.        vbkd.depto AS depto_vbkd,
247.        vbkd.ptorecep AS ptorecep_vbkd,
248.        vbkd.pedido AS pedido_vbkd,
249.        vbkd.fepedcpas AS fepedcpas_vbkd,
250.        vbkd.clpedido AS clpedido_vbkd,
251.        vbkd.referencia AS referencia_vbkd,
252.        vbkd.pedidocomp AS pedidocomp_vbkd,
253.        vbkd.feped AS feped_vbkd,
254.        vbkd.clase_ped AS clase_ped_vbkd,
255.        vbkd.caracter AS caracter_vbkd,
256.        vbkd.pospedido AS pospedido_vbkd,
257.        vbkd.feconv AS feconv_vbkd,
258.        vbkd.feconv1 AS feconv1_vbkd,
259.        vbkd.grcond1 AS grcond1_vbkd,
260.        vbkd.grcond2 AS grcond2_vbkd,
261.        vbkd.moncartcre AS moncartcre_vbkd,
262.        vbkd.tpcambcart AS tpcambcart_vbkd,
263.        vbkd.pedido1 AS pedido1_vbkd,
264.        vbkd.perfil AS perfil_vbkd,
265.        vbkd.formfactur AS formfactur_vbkd,
266.        vbkd.t_camion AS t_camion_vbkd,
267.        vbkd.clmedtrans AS clmedtrans_vbkd,
268.        vbkd.relare AS relare_vbkd,
269.        vbkd.timestamp AS timestamp_vbkd
270.    FROM {{ source('oneconnect', 'PR0_B_SD_PEDIDO_DATOS_VENTAS') }} AS vbkd
271.    FINAL
272.    {% if is_incremental() %}
273.    WHERE
274.        vbkd.timestamp >= (select max(timestamp_vbkd) from {{this}}) 
275.    {% endif %}
276. ),
277. 
     
278. PEDIDO_PARTIDA AS (
279.    SELECT 
280.        vbap.mandante AS mandante_vbap,
281.        vbap.docvtas AS docvtas_vbap,
282.        vbap.posicion AS posicion_vbap,
283.        vbap.material AS material_vbap,
284.        vbap.matintr AS matintr_vbap,
285.        vbap.lote AS lote_vbap,
286.        vbap.gpoartic AS gpoartic_vbap,
287.        vbap.denomin AS denomin_vbap,
288.        vbap.tipo_pos AS tipo_pos_vbap,
289.        vbap.clase_pos AS clase_pos_vbap,
290.        vbap.pos_entr AS pos_entr_vbap,
291.        vbap.relfact AS relfact_vbap,
292.        vbap.pos_sup AS pos_sup_vbap,
293.        vbap.motivrech AS motivrech_vbap,
294.        vbap.jquiaprod AS jquiaprod_vbap,
295.        vbap.ctdprev AS ctdprev_vbap,
296.        vbap.umctdprev AS umctdprev_vbap,
297.        vbap.contador AS contador_vbap,
298.        vbap.denom AS denom_vbap,
299.        vbap.unidad AS unidad_vbap,
300.        vbap.pospedido AS pospedido_vbap,
301.        vbap.matcliente AS matcliente_vbap,
302.        vbap.claspos AS claspos_vbap,
303.        vbap.utiliz AS utiliz_vbap,
304.        vbap.grentrega AS grentrega_vbap,
305.        vbap.ctdfija AS ctdfija_vbap,
306.        vbap.ilimitado AS ilimitado_vbap,
307.        vbap.bloqfact AS bloqfact_vbap,
308.        vbap.sector AS sector_vbap,
309.        vbap.division AS division_vbap,
310.        vbap.valor_neto AS valor_neto_vbap,
311.        vbap.moneda AS moneda_vbap,
312.        vbap.maxentrpar AS maxentrpar_vbap,
313.        vbap.ctdped AS ctdped_vbap,
314.        vbap.entregreq AS entregreq_vbap,
315.        vbap.cantacconf AS cantacconf_vbap,
316.        vbap.cantacconf1 AS cantacconf1_vbap,
317.        vbap.um_venta AS um_venta_vbap,
318.        vbap.contador1 AS contador1_vbap,
319.        vbap.denomin1 AS denomin1_vbap,
320.        vbap.bruto AS bruto_vbap,
321.        vbap.peso_neto AS peso_neto_vbap,
322.        vbap.unidad1 AS unidad1_vbap,
323.        vbap.volumen AS volumen_vbap,
324.        vbap.unvolumen AS unvolumen_vbap,
325.        vbap.causante AS causante_vbap,
326.        vbap.posicion1 AS posicion1_vbap,
327.        vbap.docmodelo AS docmodelo_vbap,
328.        vbap.posmodelo AS posmodelo_vbap,
329.        vbap.refcompl AS refcompl_vbap,
330.        vbap.actflujo AS actflujo_vbap,
331.        vbap.reglas_liq AS reglas_liq_vbap,
332.        vbap.priorentr AS priorentr_vbap,
333.        vbap.centro AS centro_vbap,
334.        vbap.almacen AS almacen_vbap,
335.        vbap.puestexped AS puestexped_vbap,
336.        vbap.ruta AS ruta_vbap,
337.        vbap.origlismat AS origlismat_vbap,
338.        vbap.fefijlmat AS fefijlmat_vbap,
339.        vbap.lista_mat AS lista_mat_vbap,
340.        vbap.probabil AS probabil_vbap,
341.        vbap.el AS el_vbap,
342.        vbap.creado AS creado_vbap,
343.        vbap.hora AS hora_vbap,
344.        vbap.clasiffisc AS clasiffisc_vbap,
345.        vbap.clasiffisc1 AS clasiffisc1_vbap,
346.        vbap.clasiffisc2 AS clasiffisc2_vbap,
347.        vbap.antref AS antref_vbap,
348.        vbap.prcneto AS prcneto_vbap,
349.        vbap.unidad2 AS unidad2_vbap,
350.        vbap.unidad3 AS unidad3_vbap,
351.        vbap.devoluc AS devoluc_vbap,
352.        vbap.der_desc AS der_desc_vbap,
353.        vbap.verifdisp AS verifdisp_vbap,
354.        vbap.total_nec AS total_nec_vbap,
355.        vbap.grmater AS grmater_vbap,
356.        vbap.grimpmat AS grimpmat_vbap,
357.        vbap.grprappels AS grprappels_vbap,
358.        vbap.grcomis AS grcomis_vbap,
359.        vbap.detprc AS detprc_vbap,
360.        vbap.clvalor AS clvalor_vbap,
361.        vbap.valsepar AS valsepar_vbap,
362.        vbap.sujetlote AS sujetlote_vbap,
363.        vbap.lotes AS lotes_vbap,
364.        vbap.cantentr AS cantentr_vbap,
365.        vbap.grupo_act AS grupo_act_vbap,
366.        vbap.costint AS costint_vbap,
367.        vbap.subtotal_1 AS subtotal_1_vbap,
368.        vbap.subtotal_2 AS subtotal_2_vbap,
369.        vbap.subtotal_3 AS subtotal_3_vbap,
370.        vbap.subtotal_4 AS subtotal_4_vbap,
371.        vbap.subtotal_5 AS subtotal_5_vbap,
372.        vbap.subtotal_6 AS subtotal_6_vbap,
373.        vbap.cambestad AS cambestad_vbap,
374.        vbap.mod AS mod_vbap,
375.        vbap.eanupc AS eanupc_vbap,
376.        vbap.fijada AS fijada_vbap,
377.        vbap.cebe AS cebe_vbap,
378.        vbap.grmater1 AS grmater1_vbap,
379.        vbap.grmater2 AS grmater2_vbap,
380.        vbap.grmater3 AS grmater3_vbap,
381.        vbap.grmater4 AS grmater4_vbap,
382.        vbap.grmater5 AS grmater5_vbap,
383.        vbap.cantidad AS cantidad_vbap,
384.        vbap.stockesp AS stockesp_vbap,
385.        vbap.indasig AS indasig_vbap,
386.        vbap.objetos_pa AS objetos_pa_vbap,
387.        vbap.orden AS orden_vbap,
388.        vbap.matpreplan AS matpreplan_vbap,
389.        vbap.centprepl AS centprepl_vbap,
390.        vbap.umgrpr AS umgrpr_vbap,
391.        vbap.conversion AS conversion_vbap,
392.        vbap.tpimput AS tpimput_vbap,
393.        vbap.consumo AS consumo_vbap,
394.        vbap.n_obj_ps AS n_obj_ps_vbap,
395.        vbap.clvper AS clvper_vbap,
396.        vbap.clnec AS clnec_vbap,
397.        vbap.precio AS precio_vbap,
398.        vbap.credactivo AS credactivo_vbap,
399.        vbap.cambio AS cambio_vbap,
400.        vbap.nobj_int AS nobj_int_vbap,
401.        vbap.precprev AS precprev_vbap,
402.        vbap.perfil AS perfil_vbap,
403.        vbap.ctdnserie AS ctdnserie_vbap,
404.        vbap.grmatme AS grmatme_vbap,
405.        vbap.prcman AS prcman_vbap,
406.        vbap.tipo_doc AS tipo_doc_vbap,
407.        vbap.utl_poss AS utl_poss_vbap,
408.        vbap.n_cc AS n_cc_vbap,
409.        vbap.varcc AS varcc_vbap,
410.        vbap.posicion2 AS posicion2_vbap,
411.        vbap.valestadis AS valestadis_vbap,
412.        vbap.opercial AS opercial_vbap,
413.        vbap.nrgtocdlt AS nrgtocdlt_vbap,
414.        vbap.tipolmat AS tipolmat_vbap,
415.        vbap.nodos AS nodos_vbap,
416.        vbap.contador2 AS contador2_vbap,
417.        vbap.esqcalc AS esqcalc_vbap,
418.        vbap.matdprcppr AS matdprcppr_vbap,
419.        vbap.grmatppr AS grmatppr_vbap,
420.        vbap.preccred AS preccred_vbap,
421.        vbap.formgarant AS formgarant_vbap,
422.        vbap.garantiz AS garantiz_vbap,
423.        vbap.valoracion AS valoracion_vbap,
424.        vbap.ctrolentbe AS ctrolentbe_vbap,
425.        vbap.impuesto AS impuesto_vbap,
426.        vbap.areaplnec AS areaplnec_vbap,
427.        vbap.cebenfact AS cebenfact_vbap,
428.        vbap.sistlog AS sistlog_vbap,
429.        vbap.el1 AS el1_vbap,
430.        vbap.a_las AS a_las_vbap,
431.        vbap.cecoste AS cecoste_vbap,
432.        vbap.estado AS estado_vbap,
433.        vbap.creado1 AS creado1_vbap,
434.        vbap.el2 AS el2_vbap,
435.        vbap.timestamp AS timestamp_vbap
436.    FROM {{ source('oneconnect', 'PR0_B_SD_PEDIDO_PARTIDA') }} AS vbap 
437.    FINAL
438.    {% if is_incremental() %}
439.    WHERE
440.        vbap.timestamp >= (select max(timestamp_vbap) from {{this}}) 
441.    {% endif %}
442. ),
443. 
     
444. PEDIDO_REPARTO AS (
445.    SELECT
446.        vbep.mandante AS mandante_vbep,
447.        vbep.docvtas AS docvtas_vbep,
448.        vbep.posicion AS posicion_vbep,
449.        vbep.reparto AS reparto_vbep,
450.        vbep.tiporepart AS tiporepart_vbep,
451.        vbep.pos_entr AS pos_entr_vbep,
452.        vbep.feentrega AS feentrega_vbep,
453.        vbep.horaentreg AS horaentreg_vbep,
454.        vbep.ctdped AS ctdped_vbep,
455.        vbep.ctdconf AS ctdconf_vbep,
456.        vbep.um_venta AS um_venta_vbep,
457.        vbep.ctdneces AS ctdneces_vbep,
458.        vbep.unidad AS unidad_vbep,
459.        vbep.clnec AS clnec_vbep,
460.        vbep.clplanif AS clplanif_vbep,
461.        vbep.fechareser AS fechareser_vbep,
462.        vbep.tipo_fecha AS tipo_fecha_vbep,
463.        vbep.pltransp AS pltransp_vbep,
464.        vbep.puesdismat AS puesdismat_vbep,
465.        vbep.fecarga AS fecarga_vbep,
466.        vbep.salmcias AS salmcias_vbep,
467.        vbep.ctdcorr AS ctdcorr_vbep,
468.        vbep.bloqentreg AS bloqentreg_vbep,
469.        vbep.contador AS contador_vbep,
470.        vbep.denomin AS denomin_vbep,
471.        vbep.confirmado AS confirmado_vbep,
472.        vbep.clmov AS clmov_vbep,
473.        vbep.modific AS modific_vbep,
474.        vbep.garantiz AS garantiz_vbep,
475.        vbep.h_pdispmat AS h_pdispmat_vbep,
476.        vbep.hplantrans AS hplantrans_vbep,
477.        vbep.hora_carga AS hora_carga_vbep,
478.        vbep.hora_sm AS hora_sm_vbep,
479.        vbep.timestamp AS timestamp_vbep
480.    FROM {{ source('oneconnect', 'PR0_B_SD_PEDIDO_REPARTO') }} AS vbep
481.    FINAL
482.    {% if is_incremental() %}
483.    WHERE
484.        vbep.timestamp >= (select max(timestamp_vbep) from {{this}}) 
485.    {% endif %}
486. )
487. 
     
488. SELECT 
489.    vbak.*,
490.    vbap.*,
491.    vbep.*,
492.    vbkd.*,
493.    vbpa.*,
494.    vbuk.*,
495.    now64() as _version
496. 
     
497. FROM PEDIDO_CABECERA AS vbak
498. INNER JOIN PEDIDO_INTERLOCUTORES AS vbpa
499.    ON vbpa.mandante_vbpa = vbak.mandante_vbak 
500.    AND vbpa.doccomer_vbpa = vbak.docvtas_vbak
501. INNER JOIN PEDIDO_STATUS_CABECERA AS vbuk
502.    ON vbuk.mandante_vbuk = vbak.mandante_vbak
503.    AND vbuk.doccomer_vbuk = vbak.docvtas_vbak
504. INNER JOIN PEDIDO_DATOS_VENTAS AS vbkd
505.    ON vbkd.mandante_vbkd = vbak.mandante_vbak
506.    AND vbkd.doccomer_vbkd = vbak.docvtas_vbak
507. INNER JOIN PEDIDO_PARTIDA AS vbap 
508.    ON vbap.mandante_vbap = vbak.mandante_vbak
509.    AND vbap.docvtas_vbap = vbak.docvtas_vbak
510. INNER JOIN PEDIDO_REPARTO AS vbep
511.    ON vbep.mandante_vbep = vbap.mandante_vbap
512.    AND vbep.docvtas_vbep = vbap.docvtas_vbap
513.    AND  vbep.posicion_vbep = vbap.posicion_vbap
514.