ENTIDAD SILVER DE ÓRDENES DE PRODUCCIÓN 

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 analítico. Se centra en la gestión de las órdenes de producción dentro del módulo Production Planning (PP) en SAP ECC, consolidando la información sobre la planificación, ejecución y control de la producción en planta.

El objetivo de este modelo es proporcionar una visión detallada y estructurada de las órdenes de producción, permitiendo un análisis preciso del uso de materiales, tiempos de operación, consumos y avances en el proceso productivo.

Categorización de la Entidad 

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

BI_SILVER_PP_PRODUCTION_ORDER_ECC 

• Propósito: Análisis avanzados, generación de informes y dashboards sobre la gestión de órdenes de producción. 

OI_SILVER_PP_PRODUCTION_ORDER_ECC 

• Propósito: Monitorización en tiempo real y mejora de la eficiencia en la ejecución de órdenes de producción. 
• Alcance de los Datos: Solo almacena órdenes de producción 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\PLAN_TO_PRODUCE\
2. Nombre del archivo BI:
   BI_PLAN_TO_PRODUCE\BI_SILVER_PP_PRODUCTION_ORDER_ECC.sql
3. Nombre del archivo OI:
   OI_PLAN_TO_PRODUCE\OI_SILVER_PP_PRODUCTION_ORDER_ECC.sql

Dependencias 

• AFKO (Cabecera de Orden de Producción - Datos de Operación)
  Contiene la información general de la orden de producción enfocada en la planificación de operaciones, incluyendo detalles sobre el proceso de fabricación y su vinculación con centros de trabajo.
  <client>_<environment>_PP_ORDEN_CABECERA
• AUFK (Cabecera de Orden de Producción - Datos Generales)
  Almacena los datos generales de la orden de producción, incluyendo información sobre el tipo de orden, centro de producción y estado de la orden.
  <client>_<environment>_PP_ORDEN_DATOSM
• AFPO (Posiciones de Orden de Producción)
  Contiene los detalles de los productos a fabricar en cada orden de producción, incluyendo cantidades y materiales específicos involucrados en el proceso productivo.
  <client>_<environment>_PP_ORDEN_PARTIDA
• RESB (Reservas de Material para Producción)
  Registra las reservas de materiales requeridas para la ejecución de órdenes de producción, asegurando la disponibilidad de insumos en el momento adecuado.
  <client>_<environment>_PP_RESERVAS_MATERIAL
• AFVV (Datos de Fechas y Tiempos de Producción)
  Contiene información sobre la programación y los tiempos de ejecución de las operaciones dentro de la orden de producción, permitiendo el control de plazos y planificación.
  <client>_<environment>_PP_VALOR_OPERACION
• AFRU (Confirmaciones de Producción)
  Registra las confirmaciones de las operaciones dentro de una orden de producción, incluyendo cantidades fabricadas, tiempos reales de ejecución y consumos de materiales.
  <client>_<environment>_PP_ORDEN_CONFIRMA

Instalación 

• Business Intelligence (BI)

docker-compose up -d dbt_bi_production_order --build

• Operational Intelligence (OI)
  
  

docker-compose up -d dbt_oi_production_order --build

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

Modelo sql BI ejecutado 

1. {{ config(
2.    order_by="(
3.       mandante_afko, orden_afko,
4.       mandante_aufk, orden_aufk, 
5.       mandante_afpo, orden_afpo, n_posicion_afpo,
6.       mandante_resb, reserva_resb, posicion_resb, clreg_resb,
7.       mandante_afvv, n_hruta_op_afvv, contador_afvv,
8.       mandante_afru, notificacion_afru, contador_afru
9.    )",
10.    engine='ReplacingMergeTree(_version)',
11.    materialized='incremental',
12.    incremental_strategy='append'
13. )
14. }}
15. -- afko
16. WITH PP_ORDEN_CABECERA AS (
17.    SELECT
18.        afko.mandante AS mandante_afko,
19.        afko.orden AS orden_afko,
20.        afko.fefin_extrema AS fefin_extrema_afko,
21.        afko.feinicextrema AS feinicextrema_afko,
22.        afko.liberacion AS liberacion_afko,
23.        afko.fin_programado AS fin_programado_afko,
24.        afko.inicio_program AS inicio_program_afko,
25.        afko.feinicio_real AS feinicio_real_afko,
26.        afko.fecha_fin_real AS fecha_fin_real_afko,
27.        afko.fecha_fin_real1 AS fecha_fin_real1_afko,
28.        afko.liberacion_real AS liberacion_real_afko,
29.        afko.reserva AS reserva_afko,
30.        afko.rechazo AS rechazo_afko,
31.        afko.ctdteorica AS ctdteorica_afko,
32.        afko.um_base AS um_base_afko,
33.        afko.material AS material_afko,
34.        afko.tipo_hoja_ruta AS tipo_hoja_ruta_afko,
35.        afko.gpohojas_ruta AS gpohojas_ruta_afko,
36.        afko.aplicachruta AS aplicachruta_afko,
37.        afko.contgpohruta AS contgpohruta_afko,
38.        afko.utilizacion AS utilizacion_afko,
39.        afko.fecha_explosion AS fecha_explosion_afko,
40.        afko.tamano_lote_a AS tamano_lote_a_afko,
41.        afko.um_hoja_ruta AS um_hoja_ruta_afko,
42.        afko.valido_de AS valido_de_afko,
43.        afko.grupo_planif AS grupo_planif_afko,
44.        afko.tipo_lmat AS tipo_lmat_afko,
45.        afko.material1 AS material1_afko,
46.        afko.statlista_mat AS statlista_mat_afko,
47.        afko.lista_mat AS lista_mat_afko,
48.        afko.valido_de1 AS valido_de1_afko,
49.        afko.cantidad_base AS cantidad_base_afko,
50.        afko.um_base1 AS um_base1_afko,
51.        afko.n_modif AS n_modif_afko,
52.        afko.alternativa AS alternativa_afko,
53.        afko.utilizacion1 AS utilizacion1_afko,
54.        afko.tamano_lote_a1 AS tamano_lote_a1_afko,
55.        afko.fechaexpl AS fechaexpl_afko,
56.        afko.planifneces AS planifneces_afko,
57.        afko.n_hruta_op AS n_hruta_op_afko,
58.        afko.respctrlprod AS respctrlprod_afko,
59.        afko.clave_horizonte AS clave_horizonte_afko,
60.        afko.clase_program AS clase_program_afko,
61.        afko.prioridad AS prioridad_afko,
62.        afko.perfil_grafo AS perfil_grafo_afko,
63.        afko.fechas_modific AS fechas_modific_afko,
64.        afko.numeroident AS numeroident_afko,
65.        afko.defproyecto AS defproyecto_afko,
66.        afko.contador AS contador_afko,
67.        afko.contador1 AS contador1_afko,
68.        afko.contcritadic AS contcritadic_afko,
69.        afko.lote_insp AS lote_insp_afko,
70.        afko.varcalcosplan AS varcalcosplan_afko,
71.        afko.varcalcos_real AS varcalcos_real_afko,
72.        afko.bsprogramacion AS bsprogramacion_afko,
73.        afko.ind_datos_reo AS ind_datos_reo_afko,
74.        afko.indtrabajo AS indtrabajo_afko,
75.        afko.clprogrpron AS clprogrpron_afko,
76.        afko.notificacion AS notificacion_afko,
77.        afko.contador2 AS contador2_afko,
78.        afko.ctdnotificada AS ctdnotificada_afko,
79.        afko.fin_hora AS fin_hora_afko,
80.        afko.hora_inicio AS hora_inicio_afko,
81.        afko.progrno_autom AS progrno_autom_afko,
82.        afko.calcno_autom AS calcno_autom_afko,
83.        afko.cam AS cam_afko,
84.        afko.orden_superior AS orden_superior_afko,
85.        afko.relevplanifnec AS relevplanifnec_afko,
86.        afko.n_de_secuencia AS n_de_secuencia_afko,
87.        afko.con_descansos AS con_descansos_afko,
88.        afko.programado_el AS programado_el_afko,
89.        afko.hora_fin_extr AS hora_fin_extr_afko,
90.        afko.hora_inicio1 AS hora_inicio1_afko,
91.        afko.hora_inreal AS hora_inreal_afko,
92.        afko.fin_real_hora AS fin_real_hora_afko,
93.        afko.orden_principal AS orden_principal_afko,
94.        afko.inicio AS inicio_afko,
95.        afko.fin AS fin_afko,
96.        afko.ningnecescap AS ningnecescap_afko,
97.        afko.perfilfabr AS perfilfabr_afko,
98.        afko.sin_costes_plan AS sin_costes_plan_afko,
99.        afko.opermod AS opermod_afko,
100.        afko.version AS version_afko,
101.        afko.nota_progr AS nota_progr_afko,
102.        afko.timestamp AS timestamp_afko
103.    FROM  {{ source('oneconnect', 'PR0_B_PP_ORDEN_CABECERA') }} AS afko
104.    FINAL
105.    {% if is_incremental() %}
106.    WHERE 
107.        afko.timestamp >= (select max(timestamp_afko) from {{this}}) 
108.    {% endif %}
109. ),
110. 
     
111. --afpo    
112. PP_ORDEN_PARTIDA AS (
113.    SELECT
114.        afpo.mandante AS mandante_afpo,
115.        afpo.orden AS orden_afpo,
116.        afpo.n_posicion AS n_posicion_afpo,
117.        afpo.aprovisespec AS aprovisespec_afpo,
118.        afpo.orden_previs AS orden_previs_afpo,
119.        afpo.feinicio_pl AS feinicio_pl_afpo,
120.        afpo.feaperordpr AS feaperordpr_afpo,
121.        afpo.pedido_cliente AS pedido_cliente_afpo,
122.        afpo.pospedclte AS pospedclte_afpo,
123.        afpo.cantrechazo AS cantrechazo_afpo,
124.        afpo.cantidad_pos AS cantidad_pos_afpo,
125.        afpo.cantidad_em AS cantidad_em_afpo,
126.        afpo.desviacion_prev AS desviacion_prev_afpo,
127.        afpo.umorden AS umorden_afpo,
128.        afpo.um_base AS um_base_afpo,
129.        afpo.numero_material AS numero_material_afpo,
130.        afpo.cantidad_orden AS cantidad_orden_afpo,
131.        afpo.tipo_imputacion AS tipo_imputacion_afpo,
132.        afpo.conversparcial AS conversparcial_afpo,
133.        afpo.fechentrreal AS fechentrreal_afpo,
134.        afpo.fecha_entrprev AS fecha_entrprev_afpo,
135.        afpo.ilimitado AS ilimitado_afpo,
136.        afpo.tipo_de_stocks AS tipo_de_stocks_afpo,
137.        afpo.entrada_mcia AS entrada_mcia_afpo,
138.        afpo.clvaloracion AS clvaloracion_afpo,
139.        afpo.tipo_valoracion AS tipo_valoracion_afpo,
140.        afpo.centro_planif AS centro_planif_afpo,
141.        afpo.almacen AS almacen_afpo,
142.        afpo.numerad AS numerad_afpo,
143.        afpo.denominador AS denominador_afpo,
144.        afpo.tmpotratamem AS tmpotratamem_afpo,
145.        afpo.entregado_compl AS entregado_compl_afpo,
146.        afpo.version_fabr AS version_fabr_afpo,
147.        afpo.centro AS centro_afpo,
148.        afpo.tipo_de_orden AS tipo_de_orden_afpo,
149.        afpo.clase_de_orden AS clase_de_orden_afpo,
150.        afpo.fefin_extrema AS fefin_extrema_afpo,
151.        afpo.fin_programado AS fin_programado_afpo,
152.        afpo.inliberacion AS inliberacion_afpo,
153.        afpo.no_relevante AS no_relevante_afpo,
154.        afpo.stock_especial AS stock_especial_afpo,
155.        afpo.consumo AS consumo_afpo,
156.        afpo.valor_de_em AS valor_de_em_afpo,
157.        afpo.em_no_valorada AS em_no_valorada_afpo,
158.        afpo.puesto_descarga AS puesto_descarga_afpo,
159.        afpo.destinatario AS destinatario_afpo,
160.        afpo.lote AS lote_afpo,
161.        afpo.division AS division_afpo,
162.        afpo.em_modificable AS em_modificable_afpo,
163.        afpo.confirm AS confirm_afpo,
164.        afpo.confirm_global AS confirm_global_afpo,
165.        afpo.clverifdisp AS clverifdisp_afpo,
166.        afpo.valoracion AS valoracion_afpo,
167.        afpo.perfil_numserie AS perfil_numserie_afpo,
168.        afpo.ctdn_serie AS ctdn_serie_afpo,
169.        afpo.area_plnec AS area_plnec_afpo,
170.        afpo.timestamp AS timestamp_afpo
171.    FROM  {{ source('oneconnect', 'PR0_B_PP_ORDEN_PARTIDA') }} AS afpo
172.    FINAL
173.    {% if is_incremental() %}
174.    WHERE 
175.        afpo.timestamp >= (select max(timestamp_afpo) from {{this}}) 
176.    {% endif %}
177. ),
178. 
     
179. --aufk
180. PP_ORDEN_DATOSM AS (
181.    SELECT
182.        aufk.mandante AS mandante_aufk,
183.        aufk.orden AS orden_aufk,
184.        aufk.clase_de_orden AS clase_de_orden_aufk,
185.        aufk.tipo_de_orden AS tipo_de_orden_aufk,
186.        aufk.orden1 AS orden1_aufk,
187.        aufk.autor AS autor_aufk,
188.        aufk.fecha_entrada AS fecha_entrada_aufk,
189.        aufk.modificado_por AS modificado_por_aufk,
190.        aufk.fecha_modific AS fecha_modific_aufk,
191.        aufk.texto_breve AS texto_breve_aufk,
192.        aufk.existtxtexpl AS existtxtexpl_aufk,
193.        aufk.sociedad AS sociedad_aufk,
194.        aufk.centro AS centro_aufk,
195.        aufk.division AS division_aufk,
196.        aufk.sociedad_co AS sociedad_co_aufk,
197.        aufk.colector_costes AS colector_costes_aufk,
198.        aufk.ceco_responsab AS ceco_responsab_aufk,
199.        aufk.ubicacion AS ubicacion_aufk,
200.        aufk.centro_emplaz AS centro_emplaz_aufk,
201.        aufk.estadistico AS estadistico_aufk,
202.        aufk.moneda AS moneda_aufk,
203.        aufk.abierto AS abierto_aufk,
204.        aufk.liberado AS liberado_aufk,
205.        aufk.cierre_tecnico AS cierre_tecnico_aufk,
206.        aufk.concl AS concl_aufk,
207.        aufk.liberacion AS liberacion_aufk,
208.        aufk.cierre_tecnico1 AS cierre_tecnico1_aufk,
209.        aufk.cierre AS cierre_aufk,
210.        aufk.id_del_objeto AS id_del_objeto_aufk,
211.        aufk.petborrado AS petborrado_aufk,
212.        aufk.utilizacion AS utilizacion_aufk,
213.        aufk.aplicacion AS aplicacion_aufk,
214.        aufk.esqcalccoste AS esqcalccoste_aufk,
215.        aufk.centro_de_coste AS centro_de_coste_aufk,
216.        aufk.contcentcoste AS contcentcoste_aufk,
217.        aufk.solicitante AS solicitante_aufk,
218.        aufk.telefono AS telefono_aufk,
219.        aufk.responsable AS responsable_aufk,
220.        aufk.telefono1 AS telefono1_aufk,
221.        aufk.gsts_estimados AS gsts_estimados_aufk,
222.        aufk.fecha_solicitud AS fecha_solicitud_aufk,
223.        aufk.departamento AS departamento_aufk,
224.        aufk.inicio_trabajo AS inicio_trabajo_aufk,
225.        aufk.fin_de_trabajo AS fin_de_trabajo_aufk,
226.        aufk.autoriztrabajo AS autoriztrabajo_aufk,
227.        aufk.n_objeto AS n_objeto_aufk,
228.        aufk.cebe AS cebe_aufk,
229.        aufk.elemento_pep AS elemento_pep_aufk,
230.        aufk.clvperiodif AS clvperiodif_aufk,
231.        aufk.area_funcional AS area_funcional_aufk,
232.        aufk.clase_de_objeto AS clase_de_objeto_aufk,
233.        aufk.integracplan AS integracplan_aufk,
234.        aufk.pedido_cliente AS pedido_cliente_aufk,
235.        aufk.pospedclte AS pospedclte_aufk,
236.        aufk.n_orden_exter AS n_orden_exter_aufk,
237.        aufk.sosolicitante AS sosolicitante_aufk,
238.        aufk.ceco_solicit AS ceco_solicit_aufk,
239.        aufk.escala AS escala_aufk,
240.        aufk.destino_invers AS destino_invers_aufk,
241.        aufk.invprotmedamb AS invprotmedamb_aufk,
242.        aufk.n_direccion AS n_direccion_aufk,
243.        aufk.creado_a_las AS creado_a_las_aufk,
244.        aufk.hora_modific AS hora_modific_aufk,
245.        aufk.usuario_respons AS usuario_respons_aufk,
246.        aufk.ptotbjoresp AS ptotbjoresp_aufk,
247.        aufk.timestamp AS timestamp_aufk
248.    FROM  {{ source('oneconnect', 'PR0_B_PP_ORDEN_DATOSM') }} AS aufk
249.    FINAL
250.    {% if is_incremental() %}
251.    WHERE 
252.        aufk.timestamp >= (select max(timestamp_aufk) from {{this}}) 
253.    {% endif %}
254. ),
255. 
     
256. -- afru    
257. PP_ORDEN_CONFIRMA AS (
258.    SELECT
259.        afru.mandante AS mandante_afru,
260.        afru.notificacion AS notificacion_afru,
261.        afru.contador AS contador_afru,
262.        afru.registrado_el AS registrado_el_afru,
263.        afru.regpor AS regpor_afru,
264.        afru.ultima_modif AS ultima_modif_afru,
265.        afru.modificado_por AS modificado_por_afru,
266.        afru.fecha_contab AS fecha_contab_afru,
267.        afru.id_objeto AS id_objeto_afru,
268.        afru.centro AS centro_afru,
269.        afru.texto_notific AS texto_notific_afru,
270.        afru.idioma AS idioma_afru,
271.        afru.unactividad AS unactividad_afru,
272.        afru.activa_notif AS activa_notif_afru,
273.        afru.grado_realizac AS grado_realizac_afru,
274.        afru.trabajo_real AS trabajo_real_afru,
275.        afru.unidad_trabajo AS unidad_trabajo_afru,
276.        afru.clase_actividad AS clase_actividad_afru,
277.        afru.durreal_notif AS durreal_notif_afru,
278.        afru.undurreal AS undurreal_afru,
279.        afru.ccnomina AS ccnomina_afru,
280.        afru.notifcantfabr AS notifcantfabr_afru,
281.        afru.notctdbuena AS notctdbuena_afru,
282.        afru.rechazo_notif AS rechazo_notif_afru,
283.        afru.um_base AS um_base_afru,
284.        afru.unidmednotif AS unidmednotif_afru,
285.        afru.motdesviac AS motdesviac_afru,
286.        afru.n_personal AS n_personal_afru,
287.        afru.inicio_ejecuc AS inicio_ejecuc_afru,
288.        afru.inicrealhora AS inicrealhora_afru,
289.        afru.fin_ejecucion AS fin_ejecucion_afru,
290.        afru.fin_realhora AS fin_realhora_afru,
291.        afru.fin_pronostic AS fin_pronostic_afru,
292.        afru.fin_pronostic1 AS fin_pronostic1_afru,
293.        afru.docmaterial AS docmaterial_afru,
294.        afru.doc_moverroneo AS doc_moverroneo_afru,
295.        afru.notiffinal AS notiffinal_afru,
296.        afru.compreservas AS compreservas_afru,
297.        afru.tipo_notific AS tipo_notific_afru,
298.        afru.notifichitos AS notifichitos_afru,
299.        afru.n_hruta_op AS n_hruta_op_afru,
300.        afru.contador1 AS contador1_afru,
301.        afru.orden AS orden_afru,
302.        afru.secuencia AS secuencia_afru,
303.        afru.operacion AS operacion_afru,
304.        afru.nodos_total AS nodos_total_afru,
305.        afru.trabajo_rest AS trabajo_rest_afru,
306.        afru.untrbjo_rest AS untrbjo_rest_afru,
307.        afru.sin_tbjorest AS sin_tbjorest_afru,
308.        afru.undurrestante AS undurrestante_afru,
309.        afru.anulado AS anulado_afru,
310.        afru.notifanulada AS notifanulada_afru,
311.        afru.ctdoperacion AS ctdoperacion_afru,
312.        afru.numero AS numero_afru,
313.        afru.aplicacion AS aplicacion_afru,
314.        afru.origen AS origen_afru,
315.        afru.trabajo_repaso AS trabajo_repaso_afru,
316.        afru.clreg AS clreg_afru,
317.        afru.hora AS hora_afru,
318.        afru.criterio_calc AS criterio_calc_afru,
319.        afru.unidad_trabajo1 AS unidad_trabajo1_afru,
320.        afru.unidad_trabajo2 AS unidad_trabajo2_afru,
321.        afru.ejercdocmat AS ejercdocmat_afru,
322.        afru.timestamp AS timestamp_afru
323.    FROM  {{ source('oneconnect', 'PR0_B_PP_ORDEN_CONFIRMA') }} AS afru
324.    FINAL
325.    {% if is_incremental() %}
326.    WHERE 
327.        afru.timestamp >= (select max(timestamp_afru) from {{this}}) 
328.    {% endif %}
329. ),
330. 
     
331. --afvv    
332. PP_VALOR_OPERACION AS (
333.    SELECT
334.        afvv.mandante AS mandante_afvv,
335.        afvv.n_hruta_op AS n_hruta_op_afvv,
336.        afvv.contador AS contador_afvv,
337.        afvv.unmedida_oper AS unmedida_oper_afvv,
338.        afvv.denominador AS denominador_afvv,
339.        afvv.contador1 AS contador1_afvv,
340.        afvv.cantidad_base AS cantidad_base_afvv,
341.        afvv.unvalprefij AS unvalprefij_afvv,
342.        afvv.datpref AS datpref_afvv,
343.        afvv.unvalprefij1 AS unvalprefij1_afvv,
344.        afvv.datpref1 AS datpref1_afvv,
345.        afvv.unvalprefij2 AS unvalprefij2_afvv,
346.        afvv.datpref2 AS datpref2_afvv,
347.        afvv.unvalprefij3 AS unvalprefij3_afvv,
348.        afvv.datpref3 AS datpref3_afvv,
349.        afvv.unvalprefij4 AS unvalprefij4_afvv,
350.        afvv.datpref4 AS datpref4_afvv,
351.        afvv.plazentrprev AS plazentrprev_afvv,
352.        afvv.duracion_normal AS duracion_normal_afvv,
353.        afvv.undurnormal AS undurnormal_afvv,
354.        afvv.limitinicio AS limitinicio_afvv,
355.        afvv.limitacion_fin AS limitacion_fin_afvv,
356.        afvv.trabajo AS trabajo_afvv,
357.        afvv.unidad_trabajo AS unidad_trabajo_afvv,
358.        afvv.ctdoperacion AS ctdoperacion_afvv,
359.        afvv.notifctdbuena AS notifctdbuena_afvv,
360.        afvv.notifctdbuena1 AS notifctdbuena1_afvv,
361.        afvv.activnotif AS activnotif_afvv,
362.        afvv.activnotif1 AS activnotif1_afvv,
363.        afvv.activnotif2 AS activnotif2_afvv,
364.        afvv.activnotif3 AS activnotif3_afvv,
365.        afvv.activnotif4 AS activnotif4_afvv,
366.        afvv.trabajo_real AS trabajo_real_afvv,
367.        afvv.fechainicmastmp AS fechainicmastmp_afvv,
368.        afvv.horainicmastmpr AS horainicmastmpr_afvv,
369.        afvv.fechainicmastmp1 AS fechainicmastmp1_afvv,
370.        afvv.horainicmastmpr1 AS horainicmastmpr1_afvv,
371.        afvv.fechainicmastmp2 AS fechainicmastmp2_afvv,
372.        afvv.horainicmastmpr2 AS horainicmastmpr2_afvv,
373.        afvv.fechafinmastmpr AS fechafinmastmpr_afvv,
374.        afvv.horafinmastempr AS horafinmastempr_afvv,
375.        afvv.fechainicmastmp3 AS fechainicmastmp3_afvv,
376.        afvv.horainicmastmpr3 AS horainicmastmpr3_afvv,
377.        afvv.fechafinmastmpr1 AS fechafinmastmpr1_afvv,
378.        afvv.horafinmastempr1 AS horafinmastempr1_afvv,
379.        afvv.feintardio AS feintardio_afvv,
380.        afvv.horainicmastrd AS horainicmastrd_afvv,
381.        afvv.fechainicmastrd AS fechainicmastrd_afvv,
382.        afvv.horainicmastrd1 AS horainicmastrd1_afvv,
383.        afvv.fechainicmastrd1 AS fechainicmastrd1_afvv,
384.        afvv.horainicmastrd2 AS horainicmastrd2_afvv,
385.        afvv.fechafinmastrd AS fechafinmastrd_afvv,
386.        afvv.horafinmastard AS horafinmastard_afvv,
387.        afvv.fechainicmastrd2 AS fechainicmastrd2_afvv,
388.        afvv.horainicmastrd3 AS horainicmastrd3_afvv,
389.        afvv.fechafinmastrd1 AS fechafinmastrd1_afvv,
390.        afvv.horafinmastard1 AS horafinmastard1_afvv,
391.        afvv.inicio_real_op AS inicio_real_op_afvv,
392.        afvv.fin_real_op AS fin_real_op_afvv,
393.        afvv.fechainicioreal AS fechainicioreal_afvv,
394.        afvv.hora_inicreal AS hora_inicreal_afvv,
395.        afvv.fecha_fin_real AS fecha_fin_real_afvv,
396.        afvv.hora_fin_real AS hora_fin_real_afvv,
397.        afvv.fechainicioreal1 AS fechainicioreal1_afvv,
398.        afvv.hora_inicreal1 AS hora_inicreal1_afvv,
399.        afvv.fecha_fin_real1 AS fecha_fin_real1_afvv,
400.        afvv.hora_fin_real1 AS hora_fin_real1_afvv,
401.        afvv.fechainicioreal2 AS fechainicioreal2_afvv,
402.        afvv.hora_inicreal2 AS hora_inicreal2_afvv,
403.        afvv.fecha_fin_real2 AS fecha_fin_real2_afvv,
404.        afvv.hora_fin_real2 AS hora_fin_real2_afvv,
405.        afvv.fin_pronostic AS fin_pronostic_afvv,
406.        afvv.fin_pronostic1 AS fin_pronostic1_afvv,
407.        afvv.holgura_libre AS holgura_libre_afvv,
408.        afvv.holgura_total AS holgura_total_afvv,
409.        afvv.liminicio AS liminicio_afvv,
410.        afvv.limhora_inicio AS limhora_inicio_afvv,
411.        afvv.fin_limitacion AS fin_limitacion_afvv,
412.        afvv.horafinlim AS horafinlim_afvv,
413.        afvv.unprondurnr AS unprondurnr_afvv,
414.        afvv.unidad_prepar AS unidad_prepar_afvv,
415.        afvv.tmpotrat AS tmpotrat_afvv,
416.        afvv.unidad_tratam AS unidad_tratam_afvv,
417.        afvv.undesmontaje AS undesmontaje_afvv,
418.        afvv.pronosttrabajo AS pronosttrabajo_afvv,
419.        afvv.factor_ejec AS factor_ejec_afvv,
420.        afvv.unactividad AS unactividad_afvv,
421.        afvv.unactividad1 AS unactividad1_afvv,
422.        afvv.unactividad2 AS unactividad2_afvv,
423.        afvv.unactividad3 AS unactividad3_afvv,
424.        afvv.unactividad4 AS unactividad4_afvv,
425.        afvv.timestamp AS timestamp_afvv
426.    FROM  {{ source('oneconnect', 'PR0_B_PP_VALOR_OPERACION') }} AS afvv
427.    FINAL
428.    {% if is_incremental() %}
429.    WHERE 
430.        afvv.timestamp >= (select max(timestamp_afvv) from {{this}}) 
431.    {% endif %}
432. ),
433. 
     
434. --resb    
435. PP_RESERVAS_MATERIAL AS (
436.    SELECT
437.        resb.mandante AS mandante_resb,
438.        resb.reserva AS reserva_resb,
439.        resb.posicion AS posicion_resb,
440.        resb.clreg AS clreg_resb,
441.        resb.clnecesidad AS clnecesidad_resb,
442.        resb.status_reserva AS status_reserva_resb,
443.        resb.borrado AS borrado_resb,
444.        resb.movimperm AS movimperm_resb,
445.        resb.salida_final AS salida_final_resb,
446.        resb.falta AS falta_resb,
447.        resb.material AS material_resb,
448.        resb.centro AS centro_resb,
449.        resb.almacen AS almacen_resb,
450.        resb.lote AS lote_resb,
451.        resb.stock_especial AS stock_especial_resb,
452.        resb.fecha_necesidad AS fecha_necesidad_resb,
453.        resb.ctdnecesaria AS ctdnecesaria_resb,
454.        resb.um_base AS um_base_resb,
455.        resb.debehaber AS debehaber_resb,
456.        resb.cantidad_fija AS cantidad_fija_resb,
457.        resb.cantidad_toma AS cantidad_toma_resb,
458.        resb.valor_de_toma AS valor_de_toma_resb,
459.        resb.moneda AS moneda_resb,
460.        resb.ctden_ume AS ctden_ume_resb,
461.        resb.um_entrada AS um_entrada_resb,
462.        resb.orden_previs AS orden_previs_resb,
463.        resb.solpedido AS solpedido_resb,
464.        resb.possolpedido AS possolpedido_resb,
465.        resb.orden AS orden_resb,
466.        resb.causante AS causante_resb,
467.        resb.pedido_cliente AS pedido_cliente_resb,
468.        resb.pospedclte AS pospedclte_resb,
469.        resb.clmovimiento AS clmovimiento_resb,
470.        resb.ctamayor AS ctamayor_resb,
471.        resb.division AS division_resb,
472.        resb.centro_receptor AS centro_receptor_resb,
473.        resb.almreceptor AS almreceptor_resb,
474.        resb.ctda_emplear AS ctda_emplear_resb,
475.        resb.tipo_posicion AS tipo_posicion_resb,
476.        resb.poslista_mat AS poslista_mat_resb,
477.        resb.texto AS texto_resb,
478.        resb.tipo_lmat AS tipo_lmat_resb,
479.        resb.lista_mat AS lista_mat_resb,
480.        resb.nodos_pos AS nodos_pos_resb,
481.        resb.contador AS contador_resb,
482.        resb.iditextoexpl AS iditextoexpl_resb,
483.        resb.texto_posicion AS texto_posicion_resb,
484.        resb.texto_posicion1 AS texto_posicion1_resb,
485.        resb.relevancia_cc AS relevancia_cc_resb,
486.        resb.n_modif AS n_modif_resb,
487.        resb.numerad AS numerad_resb,
488.        resb.denominador AS denominador_resb,
489.        resb.concepto_clas AS concepto_clas_resb,
490.        resb.fenectardia AS fenectardia_resb,
491.        resb.aprovisdirecto AS aprovisdirecto_resb,
492.        resb.posicion_texto AS posicion_texto_resb,
493.        resb.indpieza_fac AS indpieza_fac_resb,
494.        resb.doccompras AS doccompras_resb,
495.        resb.posicion1 AS posicion1_resb,
496.        resb.reparto AS reparto_resb,
497.        resb.tipo_imputacion AS tipo_imputacion_resb,
498.        resb.consumo AS consumo_resb,
499.        resb.n_hruta_op AS n_hruta_op_resb,
500.        resb.secuencia AS secuencia_resb,
501.        resb.operacion AS operacion_resb,
502.        resb.contador1 AS contador1_resb,
503.        resb.n_objeto AS n_objeto_resb,
504.        resb.clase_secuencia AS clase_secuencia_resb,
505.        resb.preciomoneda AS preciomoneda_resb,
506.        resb.precio_fijome AS precio_fijome_resb,
507.        resb.cantidad_base AS cantidad_base_resb,
508.        resb.toma_retroact AS toma_retroact_resb,
509.        resb.grupo_compras AS grupo_compras_resb,
510.        resb.ctdverifdisp AS ctdverifdisp_resb,
511.        resb.plazoentrg_d AS plazoentrg_d_resb,
512.        resb.relevplanifnec AS relevplanifnec_resb,
513.        resb.fecha_necesidad1 AS fecha_necesidad1_resb,
514.        resb.ctd_por_unidad AS ctd_por_unidad_resb,
515.        resb.n_objeto_int AS n_objeto_int_resb,
516.        resb.clave_de_lote AS clave_de_lote_resb,
517.        resb.posicion2 AS posicion2_resb,
518.        resb.destinatario AS destinatario_resb,
519.        resb.puesto_descarga AS puesto_descarga_resb,
520.        resb.origen_material AS origen_material_resb,
521.        resb.grupo_articulos AS grupo_articulos_resb,
522.        resb.acreedor AS acreedor_resb,
523.        resb.flgex AS flgex_resb,
524.        resb.funcion AS funcion_resb,
525.        resb.preciomonl AS preciomonl_resb,
526.        resb.precio_fijoml AS precio_fijoml_resb,
527.        resb.cantidad_base1 AS cantidad_base1_resb,
528.        resb.registro_info AS registro_info_resb,
529.        resb.entrar_lote AS entrar_lote_resb,
530.        resb.alternativa AS alternativa_resb,
531.        resb.nodos_pos1 AS nodos_pos1_resb,
532.        resb.cuenta_manualm AS cuenta_manualm_resb,
533.        resb.preplanif AS preplanif_resb,
534.        resb.valoracion AS valoracion_resb,
535.        resb.opermod AS opermod_resb,
536.        resb.indesptrasl AS indesptrasl_resb,
537.        resb.timestamp AS timestamp_resb
538.    FROM  {{ source('oneconnect', 'PR0_B_PP_RESERVAS_MATERIAL') }} AS resb
539.    FINAL
540.    {% if is_incremental() %}
541.    WHERE 
542.        resb.timestamp >= (select max(timestamp_resb) from {{this}}) 
543.    {% endif %}
544. )
545. 
     
546. SELECT
547.    afko.*,
548.    aufk.*,
549.    afpo.*,
550.    resb.*,
551.    afvv.*,
552.    afru.*,
553.    now64() AS _version
554. FROM PP_ORDEN_CABECERA AS afko
555. INNER JOIN PP_ORDEN_DATOSM AS aufk
556.    ON afko.mandante_afko = aufk.mandante_aufk 
557.    AND afko.orden_afko = aufk.orden_aufk
558. INNER JOIN PP_ORDEN_PARTIDA AS afpo
559.    ON afko.mandante_afko = afpo.mandante_afpo
560.    AND afko.orden_afko = afpo.orden_afpo
561. INNER JOIN PP_RESERVAS_MATERIAL AS resb
562.    ON afko.mandante_afko = resb.mandante_resb 
563.    AND afko.orden_afko = resb.orden_resb
564. LEFT JOIN PP_VALOR_OPERACION AS afvv
565.    ON afvv.n_hruta_op_afvv = resb.n_hruta_op_resb 
566.    AND afvv.contador_afvv = resb.contador1_resb
567. LEFT JOIN PP_ORDEN_CONFIRMA AS afru
568.    ON afko.mandante_afko = afru.mandante_afru
569.    AND afko.orden_afko = afru.orden_afru

1. {{ config(
2.    order_by="(
3.       mandante_afko, orden_afko,
4.       mandante_aufk, orden_aufk, 
5.       mandante_afpo, orden_afpo, n_posicion_afpo,
6.       mandante_resb, reserva_resb, posicion_resb, clreg_resb,
7.       mandante_afvv, n_hruta_op_afvv, contador_afvv,
8.       mandante_afru, notificacion_afru, contador_afru
9.    )",
10.    engine='ReplacingMergeTree(_version)',
11.    materialized='incremental',
12.    incremental_strategy='append')
13. }}
14. -- afko
15. WITH PP_ORDEN_CABECERA AS (
16.    SELECT
17.        afko.mandante AS mandante_afko,
18.        afko.orden AS orden_afko,
19.        afko.fefin_extrema AS fefin_extrema_afko,
20.        afko.feinicextrema AS feinicextrema_afko,
21.        afko.liberacion AS liberacion_afko,
22.        afko.fin_programado AS fin_programado_afko,
23.        afko.inicio_program AS inicio_program_afko,
24.        afko.feinicio_real AS feinicio_real_afko,
25.        afko.fecha_fin_real AS fecha_fin_real_afko,
26.        afko.fecha_fin_real1 AS fecha_fin_real1_afko,
27.        afko.liberacion_real AS liberacion_real_afko,
28.        afko.reserva AS reserva_afko,
29.        afko.rechazo AS rechazo_afko,
30.        afko.ctdteorica AS ctdteorica_afko,
31.        afko.um_base AS um_base_afko,
32.        afko.material AS material_afko,
33.        afko.tipo_hoja_ruta AS tipo_hoja_ruta_afko,
34.        afko.gpohojas_ruta AS gpohojas_ruta_afko,
35.        afko.aplicachruta AS aplicachruta_afko,
36.        afko.contgpohruta AS contgpohruta_afko,
37.        afko.utilizacion AS utilizacion_afko,
38.        afko.fecha_explosion AS fecha_explosion_afko,
39.        afko.tamano_lote_a AS tamano_lote_a_afko,
40.        afko.um_hoja_ruta AS um_hoja_ruta_afko,
41.        afko.valido_de AS valido_de_afko,
42.        afko.grupo_planif AS grupo_planif_afko,
43.        afko.tipo_lmat AS tipo_lmat_afko,
44.        afko.material1 AS material1_afko,
45.        afko.statlista_mat AS statlista_mat_afko,
46.        afko.lista_mat AS lista_mat_afko,
47.        afko.valido_de1 AS valido_de1_afko,
48.        afko.cantidad_base AS cantidad_base_afko,
49.        afko.um_base1 AS um_base1_afko,
50.        afko.n_modif AS n_modif_afko,
51.        afko.alternativa AS alternativa_afko,
52.        afko.utilizacion1 AS utilizacion1_afko,
53.        afko.tamano_lote_a1 AS tamano_lote_a1_afko,
54.        afko.fechaexpl AS fechaexpl_afko,
55.        afko.planifneces AS planifneces_afko,
56.        afko.n_hruta_op AS n_hruta_op_afko,
57.        afko.respctrlprod AS respctrlprod_afko,
58.        afko.clave_horizonte AS clave_horizonte_afko,
59.        afko.clase_program AS clase_program_afko,
60.        afko.prioridad AS prioridad_afko,
61.        afko.perfil_grafo AS perfil_grafo_afko,
62.        afko.fechas_modific AS fechas_modific_afko,
63.        afko.numeroident AS numeroident_afko,
64.        afko.defproyecto AS defproyecto_afko,
65.        afko.contador AS contador_afko,
66.        afko.contador1 AS contador1_afko,
67.        afko.contcritadic AS contcritadic_afko,
68.        afko.lote_insp AS lote_insp_afko,
69.        afko.varcalcosplan AS varcalcosplan_afko,
70.        afko.varcalcos_real AS varcalcos_real_afko,
71.        afko.bsprogramacion AS bsprogramacion_afko,
72.        afko.ind_datos_reo AS ind_datos_reo_afko,
73.        afko.indtrabajo AS indtrabajo_afko,
74.        afko.clprogrpron AS clprogrpron_afko,
75.        afko.notificacion AS notificacion_afko,
76.        afko.contador2 AS contador2_afko,
77.        afko.ctdnotificada AS ctdnotificada_afko,
78.        afko.fin_hora AS fin_hora_afko,
79.        afko.hora_inicio AS hora_inicio_afko,
80.        afko.progrno_autom AS progrno_autom_afko,
81.        afko.calcno_autom AS calcno_autom_afko,
82.        afko.cam AS cam_afko,
83.        afko.orden_superior AS orden_superior_afko,
84.        afko.relevplanifnec AS relevplanifnec_afko,
85.        afko.n_de_secuencia AS n_de_secuencia_afko,
86.        afko.con_descansos AS con_descansos_afko,
87.        afko.programado_el AS programado_el_afko,
88.        afko.hora_fin_extr AS hora_fin_extr_afko,
89.        afko.hora_inicio1 AS hora_inicio1_afko,
90.        afko.hora_inreal AS hora_inreal_afko,
91.        afko.fin_real_hora AS fin_real_hora_afko,
92.        afko.orden_principal AS orden_principal_afko,
93.        afko.inicio AS inicio_afko,
94.        afko.fin AS fin_afko,
95.        afko.ningnecescap AS ningnecescap_afko,
96.        afko.perfilfabr AS perfilfabr_afko,
97.        afko.sin_costes_plan AS sin_costes_plan_afko,
98.        afko.opermod AS opermod_afko,
99.        afko.version AS version_afko,
100.        afko.nota_progr AS nota_progr_afko,
101.        afko.rechazo_notif AS rechazo_notif_afko,
102.        afko.timestamp AS timestamp_afko
103.    FROM  {{ source('oneconnect', 'PR0_B_PP_ORDEN_CABECERA') }} AS afko
104.    FINAL
105.    WHERE
106.        substring(afko.inicio_program, 1, 4) = '2024'
107.        --toDate(afko.inicio_program, 'YYYYMMDD') <= toDate(subtractYears(now(), 1)) 
108.    {% if is_incremental() %}
109.       AND afko.timestamp >= (select max(timestamp_afko) from {{this}}) 
110.    {% endif %}
111. ),
112. 
     
113. --afpo    
114. PP_ORDEN_PARTIDA AS (
115.    SELECT
116.        afpo.mandante AS mandante_afpo,
117.        afpo.orden AS orden_afpo,
118.        afpo.n_posicion AS n_posicion_afpo,
119.        afpo.aprovisespec AS aprovisespec_afpo,
120.        afpo.orden_previs AS orden_previs_afpo,
121.        afpo.feinicio_pl AS feinicio_pl_afpo,
122.        afpo.feaperordpr AS feaperordpr_afpo,
123.        afpo.pedido_cliente AS pedido_cliente_afpo,
124.        afpo.pospedclte AS pospedclte_afpo,
125.        afpo.cantrechazo AS cantrechazo_afpo,
126.        afpo.cantidad_pos AS cantidad_pos_afpo,
127.        afpo.cantidad_em AS cantidad_em_afpo,
128.        afpo.desviacion_prev AS desviacion_prev_afpo,
129.        afpo.umorden AS umorden_afpo,
130.        afpo.um_base AS um_base_afpo,
131.        afpo.numero_material AS numero_material_afpo,
132.        afpo.cantidad_orden AS cantidad_orden_afpo,
133.        afpo.tipo_imputacion AS tipo_imputacion_afpo,
134.        afpo.conversparcial AS conversparcial_afpo,
135.        afpo.fechentrreal AS fechentrreal_afpo,
136.        afpo.fecha_entrprev AS fecha_entrprev_afpo,
137.        afpo.ilimitado AS ilimitado_afpo,
138.        afpo.tipo_de_stocks AS tipo_de_stocks_afpo,
139.        afpo.entrada_mcia AS entrada_mcia_afpo,
140.        afpo.clvaloracion AS clvaloracion_afpo,
141.        afpo.tipo_valoracion AS tipo_valoracion_afpo,
142.        afpo.centro_planif AS centro_planif_afpo,
143.        afpo.almacen AS almacen_afpo,
144.        afpo.numerad AS numerad_afpo,
145.        afpo.denominador AS denominador_afpo,
146.        afpo.tmpotratamem AS tmpotratamem_afpo,
147.        afpo.entregado_compl AS entregado_compl_afpo,
148.        afpo.version_fabr AS version_fabr_afpo,
149.        afpo.centro AS centro_afpo,
150.        afpo.tipo_de_orden AS tipo_de_orden_afpo,
151.        afpo.clase_de_orden AS clase_de_orden_afpo,
152.        afpo.fefin_extrema AS fefin_extrema_afpo,
153.        afpo.fin_programado AS fin_programado_afpo,
154.        afpo.inliberacion AS inliberacion_afpo,
155.        afpo.no_relevante AS no_relevante_afpo,
156.        afpo.stock_especial AS stock_especial_afpo,
157.        afpo.consumo AS consumo_afpo,
158.        afpo.valor_de_em AS valor_de_em_afpo,
159.        afpo.em_no_valorada AS em_no_valorada_afpo,
160.        afpo.puesto_descarga AS puesto_descarga_afpo,
161.        afpo.destinatario AS destinatario_afpo,
162.        afpo.lote AS lote_afpo,
163.        afpo.division AS division_afpo,
164.        afpo.em_modificable AS em_modificable_afpo,
165.        afpo.confirm AS confirm_afpo,
166.        afpo.confirm_global AS confirm_global_afpo,
167.        afpo.clverifdisp AS clverifdisp_afpo,
168.        afpo.valoracion AS valoracion_afpo,
169.        afpo.perfil_numserie AS perfil_numserie_afpo,
170.        afpo.ctdn_serie AS ctdn_serie_afpo,
171.        afpo.area_plnec AS area_plnec_afpo,
172.        afpo.timestamp AS timestamp_afpo
173.    FROM  {{ source('oneconnect', 'PR0_B_PP_ORDEN_PARTIDA') }} AS afpo
174.    FINAL
175.    {% if is_incremental() %}
176.    WHERE 
177.        afpo.timestamp >= (select max(timestamp_afpo) from {{this}}) 
178.    {% endif %}
179. ),
180. 
     
181. --aufk
182. PP_ORDEN_DATOSM AS (
183.    SELECT
184.        aufk.mandante AS mandante_aufk,
185.        aufk.orden AS orden_aufk,
186.        aufk.clase_de_orden AS clase_de_orden_aufk,
187.        aufk.tipo_de_orden AS tipo_de_orden_aufk,
188.        aufk.orden1 AS orden1_aufk,
189.        aufk.autor AS autor_aufk,
190.        aufk.fecha_entrada AS fecha_entrada_aufk,
191.        aufk.modificado_por AS modificado_por_aufk,
192.        aufk.fecha_modific AS fecha_modific_aufk,
193.        aufk.texto_breve AS texto_breve_aufk,
194.        aufk.existtxtexpl AS existtxtexpl_aufk,
195.        aufk.sociedad AS sociedad_aufk,
196.        aufk.centro AS centro_aufk,
197.        aufk.division AS division_aufk,
198.        aufk.sociedad_co AS sociedad_co_aufk,
199.        aufk.colector_costes AS colector_costes_aufk,
200.        aufk.ceco_responsab AS ceco_responsab_aufk,
201.        aufk.ubicacion AS ubicacion_aufk,
202.        aufk.centro_emplaz AS centro_emplaz_aufk,
203.        aufk.estadistico AS estadistico_aufk,
204.        aufk.moneda AS moneda_aufk,
205.        aufk.abierto AS abierto_aufk,
206.        aufk.liberado AS liberado_aufk,
207.        aufk.cierre_tecnico AS cierre_tecnico_aufk,
208.        aufk.concl AS concl_aufk,
209.        aufk.liberacion AS liberacion_aufk,
210.        aufk.cierre_tecnico1 AS cierre_tecnico1_aufk,
211.        aufk.cierre AS cierre_aufk,
212.        aufk.id_del_objeto AS id_del_objeto_aufk,
213.        aufk.petborrado AS petborrado_aufk,
214.        aufk.utilizacion AS utilizacion_aufk,
215.        aufk.aplicacion AS aplicacion_aufk,
216.        aufk.esqcalccoste AS esqcalccoste_aufk,
217.        aufk.centro_de_coste AS centro_de_coste_aufk,
218.        aufk.contcentcoste AS contcentcoste_aufk,
219.        aufk.solicitante AS solicitante_aufk,
220.        aufk.telefono AS telefono_aufk,
221.        aufk.responsable AS responsable_aufk,
222.        aufk.telefono1 AS telefono1_aufk,
223.        aufk.gsts_estimados AS gsts_estimados_aufk,
224.        aufk.fecha_solicitud AS fecha_solicitud_aufk,
225.        aufk.departamento AS departamento_aufk,
226.        aufk.inicio_trabajo AS inicio_trabajo_aufk,
227.        aufk.fin_de_trabajo AS fin_de_trabajo_aufk,
228.        aufk.autoriztrabajo AS autoriztrabajo_aufk,
229.        aufk.n_objeto AS n_objeto_aufk,
230.        aufk.cebe AS cebe_aufk,
231.        aufk.elemento_pep AS elemento_pep_aufk,
232.        aufk.clvperiodif AS clvperiodif_aufk,
233.        aufk.area_funcional AS area_funcional_aufk,
234.        aufk.clase_de_objeto AS clase_de_objeto_aufk,
235.        aufk.integracplan AS integracplan_aufk,
236.        aufk.pedido_cliente AS pedido_cliente_aufk,
237.        aufk.pospedclte AS pospedclte_aufk,
238.        aufk.n_orden_exter AS n_orden_exter_aufk,
239.        aufk.sosolicitante AS sosolicitante_aufk,
240.        aufk.ceco_solicit AS ceco_solicit_aufk,
241.        aufk.escala AS escala_aufk,
242.        aufk.destino_invers AS destino_invers_aufk,
243.        aufk.invprotmedamb AS invprotmedamb_aufk,
244.        aufk.n_direccion AS n_direccion_aufk,
245.        aufk.creado_a_las AS creado_a_las_aufk,
246.        aufk.hora_modific AS hora_modific_aufk,
247.        aufk.usuario_respons AS usuario_respons_aufk,
248.        aufk.ptotbjoresp AS ptotbjoresp_aufk,
249.        aufk.timestamp AS timestamp_aufk
250.    FROM  {{ source('oneconnect', 'PR0_B_PP_ORDEN_DATOSM') }} AS aufk
251.    FINAL
252.    --WHERE 
253.    --toDate(aufk.fecha_entrada, 'YYYYMMDD') <= toDate(subtractYears(now(), 1)) 
254.   
255.    {% if is_incremental() %}
256.    WHERE aufk.timestamp >= (select max(timestamp_aufk) from {{this}}) 
257.    {% endif %}
258. ),
259. 
     
260. -- afru    
261. PP_ORDEN_CONFIRMA AS (
262.    SELECT
263.        afru.mandante AS mandante_afru,
264.        afru.notificacion AS notificacion_afru,
265.        afru.contador AS contador_afru,
266.        afru.registrado_el AS registrado_el_afru,
267.        afru.regpor AS regpor_afru,
268.        afru.ultima_modif AS ultima_modif_afru,
269.        afru.modificado_por AS modificado_por_afru,
270.        afru.fecha_contab AS fecha_contab_afru,
271.        afru.id_objeto AS id_objeto_afru,
272.        afru.centro AS centro_afru,
273.        afru.texto_notific AS texto_notific_afru,
274.        afru.idioma AS idioma_afru,
275.        afru.unactividad AS unactividad_afru,
276.        afru.activa_notif AS activa_notif_afru,
277.        afru.grado_realizac AS grado_realizac_afru,
278.        afru.trabajo_real AS trabajo_real_afru,
279.        afru.unidad_trabajo AS unidad_trabajo_afru,
280.        afru.clase_actividad AS clase_actividad_afru,
281.        afru.durreal_notif AS durreal_notif_afru,
282.        afru.undurreal AS undurreal_afru,
283.        afru.ccnomina AS ccnomina_afru,
284.        afru.notifcantfabr AS notifcantfabr_afru,
285.        afru.notctdbuena AS notctdbuena_afru,
286.        afru.rechazo_notif AS rechazo_notif_afru,
287.        afru.um_base AS um_base_afru,
288.        afru.unidmednotif AS unidmednotif_afru,
289.        afru.motdesviac AS motdesviac_afru,
290.        afru.n_personal AS n_personal_afru,
291.        afru.inicio_ejecuc AS inicio_ejecuc_afru,
292.        afru.inicrealhora AS inicrealhora_afru,
293.        afru.fin_ejecucion AS fin_ejecucion_afru,
294.        afru.fin_realhora AS fin_realhora_afru,
295.        afru.fin_pronostic AS fin_pronostic_afru,
296.        afru.fin_pronostic1 AS fin_pronostic1_afru,
297.        afru.docmaterial AS docmaterial_afru,
298.        afru.doc_moverroneo AS doc_moverroneo_afru,
299.        afru.notiffinal AS notiffinal_afru,
300.        afru.compreservas AS compreservas_afru,
301.        afru.tipo_notific AS tipo_notific_afru,
302.        afru.notifichitos AS notifichitos_afru,
303.        afru.n_hruta_op AS n_hruta_op_afru,
304.        afru.contador1 AS contador1_afru,
305.        afru.orden AS orden_afru,
306.        afru.secuencia AS secuencia_afru,
307.        afru.operacion AS operacion_afru,
308.        afru.nodos_total AS nodos_total_afru,
309.        afru.trabajo_rest AS trabajo_rest_afru,
310.        afru.untrbjo_rest AS untrbjo_rest_afru,
311.        afru.sin_tbjorest AS sin_tbjorest_afru,
312.        afru.undurrestante AS undurrestante_afru,
313.        afru.anulado AS anulado_afru,
314.        afru.notifanulada AS notifanulada_afru,
315.        afru.ctdoperacion AS ctdoperacion_afru,
316.        afru.numero AS numero_afru,
317.        afru.aplicacion AS aplicacion_afru,
318.        afru.origen AS origen_afru,
319.        afru.trabajo_repaso AS trabajo_repaso_afru,
320.        afru.clreg AS clreg_afru,
321.        afru.hora AS hora_afru,
322.        afru.criterio_calc AS criterio_calc_afru,
323.        afru.unidad_trabajo1 AS unidad_trabajo1_afru,
324.        afru.unidad_trabajo2 AS unidad_trabajo2_afru,
325.        afru.ejercdocmat AS ejercdocmat_afru,
326.        afru.timestamp AS timestamp_afru
327.    FROM  {{ source('oneconnect', 'PR0_B_PP_ORDEN_CONFIRMA') }} AS afru
328.    FINAL
329.    {% if is_incremental() %}
330.    WHERE 
331.        afru.timestamp >= (select max(timestamp_afru) from {{this}}) 
332.    {% endif %}
333. ),
334. 
     
335. --afvv    
336. PP_VALOR_OPERACION AS (
337.    SELECT
338.        afvv.mandante AS mandante_afvv,
339.        afvv.n_hruta_op AS n_hruta_op_afvv,
340.        afvv.contador AS contador_afvv,
341.        afvv.unmedida_oper AS unmedida_oper_afvv,
342.        afvv.denominador AS denominador_afvv,
343.        afvv.contador1 AS contador1_afvv,
344.        afvv.cantidad_base AS cantidad_base_afvv,
345.        afvv.unvalprefij AS unvalprefij_afvv,
346.        afvv.datpref AS datpref_afvv,
347.        afvv.unvalprefij1 AS unvalprefij1_afvv,
348.        afvv.datpref1 AS datpref1_afvv,
349.        afvv.unvalprefij2 AS unvalprefij2_afvv,
350.        afvv.datpref2 AS datpref2_afvv,
351.        afvv.unvalprefij3 AS unvalprefij3_afvv,
352.        afvv.datpref3 AS datpref3_afvv,
353.        afvv.unvalprefij4 AS unvalprefij4_afvv,
354.        afvv.datpref4 AS datpref4_afvv,
355.        afvv.plazentrprev AS plazentrprev_afvv,
356.        afvv.duracion_normal AS duracion_normal_afvv,
357.        afvv.undurnormal AS undurnormal_afvv,
358.        afvv.limitinicio AS limitinicio_afvv,
359.        afvv.limitacion_fin AS limitacion_fin_afvv,
360.        afvv.trabajo AS trabajo_afvv,
361.        afvv.unidad_trabajo AS unidad_trabajo_afvv,
362.        afvv.ctdoperacion AS ctdoperacion_afvv,
363.        afvv.notifctdbuena AS notifctdbuena_afvv,
364.        afvv.notifctdbuena1 AS notifctdbuena1_afvv,
365.        afvv.activnotif AS activnotif_afvv,
366.        afvv.activnotif1 AS activnotif1_afvv,
367.        afvv.activnotif2 AS activnotif2_afvv,
368.        afvv.activnotif3 AS activnotif3_afvv,
369.        afvv.activnotif4 AS activnotif4_afvv,
370.        afvv.trabajo_real AS trabajo_real_afvv,
371.        afvv.fechainicmastmp AS fechainicmastmp_afvv,
372.        afvv.horainicmastmpr AS horainicmastmpr_afvv,
373.        afvv.fechainicmastmp1 AS fechainicmastmp1_afvv,
374.        afvv.horainicmastmpr1 AS horainicmastmpr1_afvv,
375.        afvv.fechainicmastmp2 AS fechainicmastmp2_afvv,
376.        afvv.horainicmastmpr2 AS horainicmastmpr2_afvv,
377.        afvv.fechafinmastmpr AS fechafinmastmpr_afvv,
378.        afvv.horafinmastempr AS horafinmastempr_afvv,
379.        afvv.fechainicmastmp3 AS fechainicmastmp3_afvv,
380.        afvv.horainicmastmpr3 AS horainicmastmpr3_afvv,
381.        afvv.fechafinmastmpr1 AS fechafinmastmpr1_afvv,
382.        afvv.horafinmastempr1 AS horafinmastempr1_afvv,
383.        afvv.feintardio AS feintardio_afvv,
384.        afvv.horainicmastrd AS horainicmastrd_afvv,
385.        afvv.fechainicmastrd AS fechainicmastrd_afvv,
386.        afvv.horainicmastrd1 AS horainicmastrd1_afvv,
387.        afvv.fechainicmastrd1 AS fechainicmastrd1_afvv,
388.        afvv.horainicmastrd2 AS horainicmastrd2_afvv,
389.        afvv.fechafinmastrd AS fechafinmastrd_afvv,
390.        afvv.horafinmastard AS horafinmastard_afvv,
391.        afvv.fechainicmastrd2 AS fechainicmastrd2_afvv,
392.        afvv.horainicmastrd3 AS horainicmastrd3_afvv,
393.        afvv.fechafinmastrd1 AS fechafinmastrd1_afvv,
394.        afvv.horafinmastard1 AS horafinmastard1_afvv,
395.        afvv.inicio_real_op AS inicio_real_op_afvv,
396.        afvv.fin_real_op AS fin_real_op_afvv,
397.        afvv.fechainicioreal AS fechainicioreal_afvv,
398.        afvv.hora_inicreal AS hora_inicreal_afvv,
399.        afvv.fecha_fin_real AS fecha_fin_real_afvv,
400.        afvv.hora_fin_real AS hora_fin_real_afvv,
401.        afvv.fechainicioreal1 AS fechainicioreal1_afvv,
402.        afvv.hora_inicreal1 AS hora_inicreal1_afvv,
403.        afvv.fecha_fin_real1 AS fecha_fin_real1_afvv,
404.        afvv.hora_fin_real1 AS hora_fin_real1_afvv,
405.        afvv.fechainicioreal2 AS fechainicioreal2_afvv,
406.        afvv.hora_inicreal2 AS hora_inicreal2_afvv,
407.        afvv.fecha_fin_real2 AS fecha_fin_real2_afvv,
408.        afvv.hora_fin_real2 AS hora_fin_real2_afvv,
409.        afvv.fin_pronostic AS fin_pronostic_afvv,
410.        afvv.fin_pronostic1 AS fin_pronostic1_afvv,
411.        afvv.holgura_libre AS holgura_libre_afvv,
412.        afvv.holgura_total AS holgura_total_afvv,
413.        afvv.liminicio AS liminicio_afvv,
414.        afvv.limhora_inicio AS limhora_inicio_afvv,
415.        afvv.fin_limitacion AS fin_limitacion_afvv,
416.        afvv.horafinlim AS horafinlim_afvv,
417.        afvv.unprondurnr AS unprondurnr_afvv,
418.        afvv.unidad_prepar AS unidad_prepar_afvv,
419.        afvv.tmpotrat AS tmpotrat_afvv,
420.        afvv.unidad_tratam AS unidad_tratam_afvv,
421.        afvv.undesmontaje AS undesmontaje_afvv,
422.        afvv.pronosttrabajo AS pronosttrabajo_afvv,
423.        afvv.factor_ejec AS factor_ejec_afvv,
424.        afvv.unactividad AS unactividad_afvv,
425.        afvv.unactividad1 AS unactividad1_afvv,
426.        afvv.unactividad2 AS unactividad2_afvv,
427.        afvv.unactividad3 AS unactividad3_afvv,
428.        afvv.unactividad4 AS unactividad4_afvv,
429.        afvv.timestamp AS timestamp_afvv
430.    FROM  {{ source('oneconnect', 'PR0_B_PP_VALOR_OPERACION') }} AS afvv
431.    FINAL
432.    {% if is_incremental() %}
433.    WHERE 
434.        afvv.timestamp >= (select max(timestamp_afvv) from {{this}}) 
435.    {% endif %}
436. ),
437. 
     
438. --resb    
439. PP_RESERVAS_MATERIAL AS (
440.    SELECT
441.        resb.mandante AS mandante_resb,
442.        resb.reserva AS reserva_resb,
443.        resb.posicion AS posicion_resb,
444.        resb.clreg AS clreg_resb,
445.        resb.clnecesidad AS clnecesidad_resb,
446.        resb.status_reserva AS status_reserva_resb,
447.        resb.borrado AS borrado_resb,
448.        resb.movimperm AS movimperm_resb,
449.        resb.salida_final AS salida_final_resb,
450.        resb.falta AS falta_resb,
451.        resb.material AS material_resb,
452.        resb.centro AS centro_resb,
453.        resb.almacen AS almacen_resb,
454.        resb.lote AS lote_resb,
455.        resb.stock_especial AS stock_especial_resb,
456.        resb.fecha_necesidad AS fecha_necesidad_resb,
457.        resb.ctdnecesaria AS ctdnecesaria_resb,
458.        resb.um_base AS um_base_resb,
459.        resb.debehaber AS debehaber_resb,
460.        resb.cantidad_fija AS cantidad_fija_resb,
461.        resb.cantidad_toma AS cantidad_toma_resb,
462.        resb.valor_de_toma AS valor_de_toma_resb,
463.        resb.moneda AS moneda_resb,
464.        resb.ctden_ume AS ctden_ume_resb,
465.        resb.um_entrada AS um_entrada_resb,
466.        resb.orden_previs AS orden_previs_resb,
467.        resb.solpedido AS solpedido_resb,
468.        resb.possolpedido AS possolpedido_resb,
469.        resb.orden AS orden_resb,
470.        resb.causante AS causante_resb,
471.        resb.pedido_cliente AS pedido_cliente_resb,
472.        resb.pospedclte AS pospedclte_resb,
473.        resb.clmovimiento AS clmovimiento_resb,
474.        resb.ctamayor AS ctamayor_resb,
475.        resb.division AS division_resb,
476.        resb.centro_receptor AS centro_receptor_resb,
477.        resb.almreceptor AS almreceptor_resb,
478.        resb.ctda_emplear AS ctda_emplear_resb,
479.        resb.tipo_posicion AS tipo_posicion_resb,
480.        resb.poslista_mat AS poslista_mat_resb,
481.        resb.texto AS texto_resb,
482.        resb.tipo_lmat AS tipo_lmat_resb,
483.        resb.lista_mat AS lista_mat_resb,
484.        resb.nodos_pos AS nodos_pos_resb,
485.        resb.contador AS contador_resb,
486.        resb.iditextoexpl AS iditextoexpl_resb,
487.        resb.texto_posicion AS texto_posicion_resb,
488.        resb.texto_posicion1 AS texto_posicion1_resb,
489.        resb.relevancia_cc AS relevancia_cc_resb,
490.        resb.n_modif AS n_modif_resb,
491.        resb.numerad AS numerad_resb,
492.        resb.denominador AS denominador_resb,
493.        resb.concepto_clas AS concepto_clas_resb,
494.        resb.fenectardia AS fenectardia_resb,
495.        resb.aprovisdirecto AS aprovisdirecto_resb,
496.        resb.posicion_texto AS posicion_texto_resb,
497.        resb.indpieza_fac AS indpieza_fac_resb,
498.        resb.doccompras AS doccompras_resb,
499.        resb.posicion1 AS posicion1_resb,
500.        resb.reparto AS reparto_resb,
501.        resb.tipo_imputacion AS tipo_imputacion_resb,
502.        resb.consumo AS consumo_resb,
503.        resb.n_hruta_op AS n_hruta_op_resb,
504.        resb.secuencia AS secuencia_resb,
505.        resb.operacion AS operacion_resb,
506.        resb.contador1 AS contador1_resb,
507.        resb.n_objeto AS n_objeto_resb,
508.        resb.clase_secuencia AS clase_secuencia_resb,
509.        resb.preciomoneda AS preciomoneda_resb,
510.        resb.precio_fijome AS precio_fijome_resb,
511.        resb.cantidad_base AS cantidad_base_resb,
512.        resb.toma_retroact AS toma_retroact_resb,
513.        resb.grupo_compras AS grupo_compras_resb,
514.        resb.ctdverifdisp AS ctdverifdisp_resb,
515.        resb.plazoentrg_d AS plazoentrg_d_resb,
516.        resb.relevplanifnec AS relevplanifnec_resb,
517.        resb.fecha_necesidad1 AS fecha_necesidad1_resb,
518.        resb.ctd_por_unidad AS ctd_por_unidad_resb,
519.        resb.n_objeto_int AS n_objeto_int_resb,
520.        resb.clave_de_lote AS clave_de_lote_resb,
521.        resb.posicion2 AS posicion2_resb,
522.        resb.destinatario AS destinatario_resb,
523.        resb.puesto_descarga AS puesto_descarga_resb,
524.        resb.origen_material AS origen_material_resb,
525.        resb.grupo_articulos AS grupo_articulos_resb,
526.        resb.acreedor AS acreedor_resb,
527.        resb.flgex AS flgex_resb,
528.        resb.funcion AS funcion_resb,
529.        resb.preciomonl AS preciomonl_resb,
530.        resb.precio_fijoml AS precio_fijoml_resb,
531.        resb.cantidad_base1 AS cantidad_base1_resb,
532.        resb.registro_info AS registro_info_resb,
533.        resb.entrar_lote AS entrar_lote_resb,
534.        resb.alternativa AS alternativa_resb,
535.        resb.nodos_pos1 AS nodos_pos1_resb,
536.        resb.cuenta_manualm AS cuenta_manualm_resb,
537.        resb.preplanif AS preplanif_resb,
538.        resb.valoracion AS valoracion_resb,
539.        resb.opermod AS opermod_resb,
540.        resb.indesptrasl AS indesptrasl_resb,
541.        resb.timestamp AS timestamp_resb
542.    FROM  {{ source('oneconnect', 'PR0_B_PP_RESERVAS_MATERIAL') }} AS resb
543.    FINAL
544.    {% if is_incremental() %}
545.    WHERE 
546.        resb.timestamp >= (select max(timestamp_resb) from {{this}}) 
547.    {% endif %}
548. )
549. 
     
550. SELECT
551.    afko.*,
552.    aufk.*,
553.    afpo.*,
554.    resb.*,
555.    afvv.*,
556.    afru.*,
557.    now64() AS _version
558. FROM PP_ORDEN_DATOSM AS aufk
559. INNER JOIN PP_ORDEN_CABECERA AS afko
560.    ON afko.mandante_afko = aufk.mandante_aufk 
561.    AND afko.orden_afko = aufk.orden_aufk
562. INNER JOIN PP_ORDEN_PARTIDA AS afpo
563.    ON afko.mandante_afko = afpo.mandante_afpo
564.    AND afko.orden_afko = afpo.orden_afpo
565. INNER JOIN PP_RESERVAS_MATERIAL AS resb
566.    ON afko.mandante_afko = resb.mandante_resb 
567.    AND afko.orden_afko = resb.orden_resb
568. LEFT JOIN PP_VALOR_OPERACION AS afvv
569.    ON afvv.n_hruta_op_afvv = resb.n_hruta_op_resb 
570.    AND afvv.contador_afvv = resb.contador1_resb
571. LEFT JOIN PP_ORDEN_CONFIRMA AS afru
572.    ON afko.mandante_afko = afru.mandante_afru
573.    AND afko.orden_afko = afru.orden_afru