13 PRODUCCTION DASHBOARD

13 PRODUCCTION DASHBOARD


ENTIDADES GOLD DEL TABLERO DE PRODUCCIÓN 

El Tablero de Producción está compuesto por múltiples entidades Gold, proporcionando información clave sobre las órdenes de producción y su ejecución por período. Estas entidades permiten el análisis detallado del uso de materiales, tiempos de producción y cumplimiento de planes productivos, facilitando la optimización del rendimiento operativo.



Entidades que componen el Tablero de Producción

Las siguientes entidades forman parte de este modelo:

  1. OI_GOLD_PP_PRODUCTION_COMPONENT_DETAIL.sql
  2. OI_GOLD_PP_PRODUCTION_MONTHLY_SUMMARY.sql
  3. OI_GOLD_PP_PRODUCTION_SUMMARY.sql


    OI_GOLD_PP_PRODUCTION_COMPONENT_DETAIL 

Este modelo pertenece a la capa Gold de la arquitectura de medallón y se compone de la entidad Silver OI_SILVER_PP_PRODUCTION_ORDER_ECC. Su propósito es proporcionar una visión detallada de los componentes requeridos en la producción, permitiendo un seguimiento preciso de los materiales utilizados en cada orden de producción.

Características del Modelo

  • Detalle de Componentes: Identifica los materiales necesarios para la fabricación de productos, permitiendo analizar el consumo de insumos en cada proceso productivo. 
  • Seguimiento del Estado: Registra el estado de inicio y finalización de la producción de cada componente, facilitando el monitoreo del avance en la ejecución de órdenes de producción. 


Dependencias 
  • OI_SILVER_PP_PRODUCTION_ORDER_ECC (Órdenes de Producción - Capa Silver)
    Contiene información consolidada de las órdenes de producción dentro del módulo PP en SAP, permitiendo el análisis y seguimiento de materiales en proceso de fabricación y su impacto en la disponibilidad de stock.
    OI_SILVER_PP_PRODUCTION_ORDER_ECC
  • MARD (Stock de Material por Almacén)
    Almacena información sobre los niveles de inventario de los materiales en cada almacén, permitiendo gestionar la disponibilidad de stock en tiempo real.
    <client>_<environment>_MM_MATERIAL_ALMACEN
  • T001W (Centros de Planta)
    Contiene la lista de centros en SAP, representando ubicaciones físicas donde se realizan operaciones logísticas, productivas o de almacenamiento.
    <client>_<environment>_DM_PLANTAS
  • MAKT (Descripción de Materiales)
    Contiene las descripciones de los materiales en diferentes idiomas.
    <client>_<environment>_MM_MATERIAL_DESCRIPCION
  • T023T (Grupo de Materiales - Descripción)
    Almacena las descripciones de los grupos de materiales en diferentes idiomas, facilitando la categorización de productos.
    <client>_<environment>_DM_GRUPO_MATERIAL_TXT
  • T179T (Jerarquía de Materiales - Descripción)
    Almacena la información estructurada de la jerarquía de materiales, facilitando la clasificación de productos dentro del sistema.
    <client>_<environment>_DM_JERARQUIA_MATERIALES_TXT

    Supuestos 
  • Se considera una producción demorado "Delayed" si la fecha real de finalización fue mayor a la fecha de finalización planificada: 

...

(case 

   when actual_finish_date > planned_finish_date 

       or now() > parseDateTimeBestEffort(toString(toDateOrNull(planned_finish_date)))   

   then 'Delayed'

   else 'On time' 

end ) as  status_com,

...





Instalación 

docker-compose up -d dbt_oi_production_order --build




Modelo sql ejecutado 

  1. {{ config(
  2.    order_by='(sales_order_com, material_pt_com, posicion_resb)',
  3.    engine='ReplacingMergeTree(_version)',
  4.    materialized='incremental',
  5.    incremental_strategy='append'

  7. ) }}

  9. --MARD
  10. WITH inventory AS (
  11.    SELECT 
  12.        libre_utiliz,
  13.        material, 
  14.        centro, 
  15.        almacen 
  16.    FROM {{ source('oneconnect', 'PR0_B_MM_MATERIAL_ALMACEN') }} FINAL
  17. ),

  19. component_detail as (
  20.    --COMPONENT DETAIL
  21.    SELECT  
  22.        DISTINCT 
  23.        spp.orden_resb  as sales_order_com, -- where tipo = 10
  24.        spp.numero_material_afpo,
  25.        spp.material_resb  as material_pt_com,
  26.        spp.centro_resb,
  27.        spp.almacen_resb,
  28.        spp.operacion_resb as operation_com,
  29.        spp.ctdnecesaria_resb as planned_qty_com,
  30.        spp.feintardio_afvv  as planned_start_date_com,
  31.        spp.fechafinmastrd_afvv as planned_finish_date_com,
  32.        spp.cantidad_toma_resb  as actual_qty_com,

  34.        (case
  35.         when spp.ctdnecesaria_resb != 0 then divide(spp.cantidad_toma_resb,spp.ctdnecesaria_resb)
  36.         else 0 end ) as actual_qty_com_divide_planned_qty_com,

  38.        spp.rechazo_notif_afru  as rejected_qty_com,
  39.        spp.inicio_ejecuc_afru  as actual_start_date_com,
  40.        spp.fin_ejecucion_afru  as actual_finish_date_com,
  41.        spp.feinicio_real_afko  as actual_start_date,
  42.        spp.fecha_fin_real1_afko  as actual_finish_date,
  43.        spp.fin_programado_afko as planned_finish_date,
  44.        spp.posicion_resb,
  45.        (case 
  46.            when actual_finish_date > planned_finish_date 
  47.                or now() > parseDateTimeBestEffort(toString(toDateOrNull(planned_finish_date)))   
  48.            then 'Delayed'
  49.            else 'On time' 
  50.        end ) as  status_com,
  51.        CONCAT(SUBSTRING(spp.inicio_program_afko,1,4),'-',SUBSTRING(spp.inicio_program_afko,5,2)) as MY_planned_start_date,

  53.        maktc.denominacion as material_com,
  54.        t001w.nom1 as nom1,
  55.        t023t.gpoartic1 as matl_group,
  56.        t179t.denom as prodhier,
  57.        makt.denominacion as material,
  58.        
  59.        spp.rechazo_afko,
  60.        spp.rechazo_notif_afko,

  62.         (case
  63.     when spp.fin_programado_afko = '00000000' then  null
  64.     else   parseDateTimeBestEffort(toString(toDateTimeOrNull(CONCAT( SUBSTRING(spp.fin_programado_afko,1,4),'-' , SUBSTRING(spp.fin_programado_afko,5,2),'-',SUBSTRING(spp.fin_programado_afko,7,2)
  65.    ,' ', fin_hora_afko  ))))  end ) as planned_end_time,
  66.    (case
  67.     when spp.inicio_program_afko = '00000000' then  null
  68.     else  parseDateTimeBestEffort(toString(toDateTimeOrNull(CONCAT( SUBSTRING(spp.inicio_program_afko,1,4),'-' , SUBSTRING(spp.inicio_program_afko,5,2),'-',SUBSTRING(spp.inicio_program_afko,7,2)
  69.    ,' ', hora_inicio_afko  ))))   end )  as planned_start_time,
  70.    DATEDIFF(HOUR,planned_end_time, planned_start_time) as planned_time,

  72.     -- act_start_afko GSTRI
  73.     -- actstart_afko GSUZI
  74.    (case
  75.     when spp.feinicio_real_afko = '00000000' then  null
  76.     else  parseDateTimeBestEffort(toString(toDateTimeOrNull(CONCAT( SUBSTRING(spp.feinicio_real_afko,1,4),'-' , SUBSTRING(spp.feinicio_real_afko,5,2),'-',SUBSTRING(spp.feinicio_real_afko,7,2)
  77.    ,' ', hora_inreal_afko ))))  end ) as actual_start_time,
  78.    -- actfinish_afko GLTRI
  79.    -- actfinish1_afko GEUZI
  80.    (case
  81.     when spp.fecha_fin_real1_afko = '00000000' then  null
  82.     else parseDateTimeBestEffort(toString(toDateTimeOrNull(CONCAT( SUBSTRING(spp.fecha_fin_real1_afko,1,4),'-' , SUBSTRING(spp.fecha_fin_real1_afko,5,2),'-',SUBSTRING(spp.fecha_fin_real1_afko,7,2)
  83.    ,' ', fin_real_hora_afko )))) end ) as actual_end_time,
  84.    
  85.     -- 
  86.    /*
  87.    Lead Time Overtime % vs plan    Acumulado por mes actual  (depende de la fecha seleccionada)
  88.    Total de tiempo Planeado    AFKO- GLTRS - AFKO-GSTRS 
  89.    tOTAL DE Tiiempo Real    AFKO- GETRI - AFKO-GSTRI    
  90.    Solo aquellas ordenes que el tiempo real es mayor que el tiempo planeado     100 - ((Tiempo Real / Tiempo Planeado ) *100)
  91.    */
  92.     (case
  93.     when actual_end_time IS NULL then  0
  94.     else DATEDIFF(HOUR,actual_end_time, actual_start_time)  end )  as real_time,

  96.      (case when real_time > planned_time
  97.                 then 1
  98.                 else 0
  99.             end) as real_time_greater_than_planned_time,
  100.    /*
  101.    Stock Level (Component) vs planned qty    unir por material centro almacen 
  102.    MARD-LABST  -    SUMA DE RESB-BDMNG/MARD-LABST  
  103.    SUMA DE RESB-BDMNG    
  104.    */
  105.    -- DEPRECATED
  106.    (case
  107.     when mard.libre_utiliz != 0 then divide(spp.ctdnecesaria_resb ,mard.libre_utiliz)
  108.     else 0 end ) as ctdnecesaria_resb_divide_libre_utiliz,
  109.    
  110.     SUM (ctdnecesaria_resb) OVER (PARTITION BY material_resb, centro_resb, almacen_resb) ctdnecesaria_resb_total,
  111.    
  112.    liberacion_aufk,
  113.    cierre_tecnico1_aufk,
  114.    cierre_aufk,
  115.    mard.libre_utiliz
  116.    


  119.    FROM {{ ref('OI_SILVER_PP_PRODUCTION_ORDER_ECC')}} AS spp FINAL
  120.    LEFT JOIN inventory AS mard
  121.        ON mard.material = spp.material_resb  
  122.        and mard.centro = spp.centro_resb 
  123.        and mard.almacen = spp.almacen_resb
  124.    LEFT JOIN (SELECT cp, nom1, centro , idioma   FROM {{ source('oneconnect', 'PR0_B_DM_PLANTAS') }} FINAL) AS  t001w  on t001w.centro  = spp.centro_afpo AND t001w.idioma ='S'
  125.    LEFT JOIN (SELECT denominacion, material, idioma FROM {{ source('oneconnect', 'PR0_B_MM_MATERIAL_DESCRIPCION') }} FINAL) AS makt ON makt.material = spp.numero_material_afpo and makt.idioma ='S'
  126.    LEFT JOIN (SELECT denominacion, material, idioma FROM {{ source('oneconnect', 'PR0_B_MM_MATERIAL_DESCRIPCION') }} FINAL) AS maktc ON maktc.material = spp.material_resb and maktc.idioma ='S'
  127.    LEFT JOIN (SELECT * from {{ source('oneconnect', 'PR0_B_MM_MAESTRO_MATERIALES') }}  FINAL)  AS mara ON mara.material = spp.numero_material_afpo
  128.    LEFT JOIN (SELECT gpoartic1, gpoartic, idioma FROM {{ source('oneconnect', 'PR0_B_DM_GRUPO_MATERIAL_TXT') }} FINAL) AS t023t  on  t023t.gpoartic = mara.grupo_articulos and t023t.idioma ='S'
  129.    LEFT JOIN (SELECT idioma, jquiaprod, denom  FROM {{ source('oneconnect', 'PR0_B_DM_JERARQUIA_MATERIALES_TXT') }} FINAL) AS t179t  on t179t.jquiaprod = mara.jquiaproductos and t179t.idioma ='S'
  130.    WHERE spp.utilizacion_afko = '1' and spp.tipo_de_orden_aufk = '10'
  131.    --AND spp.orden_resb = '005041000601' AND material_resb = '000000001801001239'
  132.    ORDER BY spp.orden_resb, spp.material_resb
  133. )

  135. SELECT 
  136.    *,
  137.    now64() as _version
  138. FROM component_detail

   

OI_GOLD_PP_PRODUCTION_MONTHLY_SUMMARY 

Este modelo pertenece a la capa Gold de la arquitectura de medallón y se compone de la entidad Silver OI_SILVER_PP_PRODUCTION_ORDER_ECC. Su propósito es proporcionar una visión detallada de la planificación de producción en comparación con los tiempos reales de ejecución por período, permitiendo un seguimiento preciso de cada orden de producción.


Características del Modelo

  • Comparación Plan vs. Real: Evalúa la diferencia entre los tiempos planificados y los tiempos reales de producción, asi como tambien la calidad y eficiencia de producción. 
Dependencias 
  • OI_SILVER_PP_PRODUCTION_ORDER_ECC (Órdenes de Producción - Capa Silver)
    Contiene información consolidada de las órdenes de producción dentro del módulo PP en SAP, permitiendo el análisis y seguimiento de materiales en proceso de fabricación y su impacto en la disponibilidad de stock.
    OI_SILVER_PP_PRODUCTION_ORDER_ECC
  • MARD (Stock de Material por Almacén)
    Almacena información sobre los niveles de inventario de los materiales en cada almacén, permitiendo gestionar la disponibilidad de stock en tiempo real.
    <client>_<environment>_MM_MATERIAL_ALMACEN
Supuestos 
  • Fecha de inicio actual:
    Se obtiene concatenando los campos feinicio_real_afko y hora_inreal_afko, considerando únicamente los registros donde feinicio_real_afko sea diferente de '00000000'.

(case

   when spp.feinicio_real_afko = '00000000' then null

   else parseDateTimeBestEffort(toString(toDateTimeOrNull(CONCAT(

       SUBSTRING(spp.feinicio_real_afko,1,4),'-', 

       SUBSTRING(spp.feinicio_real_afko,5,2),'-',

       SUBSTRING(spp.feinicio_real_afko,7,2),' ',

       hora_inreal_afko ))))  

end ) as actual_start_time,


  • Fecha de finalización actual:
    Se calcula concatenando los campos fecha_fin_real1_afko y fin_real_hora_afko, considerando únicamente los registros donde fecha_fin_real1_afko sea diferente de '00000000'.

...

(case

   when spp.fecha_fin_real1_afko = '00000000' then null

   else parseDateTimeBestEffort(toString(toDateTimeOrNull(CONCAT(

       SUBSTRING(spp.fecha_fin_real1_afko,1,4),'-', 

       SUBSTRING(spp.fecha_fin_real1_afko,5,2),'-',

       SUBSTRING(spp.fecha_fin_real1_afko,7,2),' ',

       fin_real_hora_afko ))))  

end ) as actual_end_time,

...

​
  • Tiempo de producción real:
    Se obtiene calculando la diferencia en horas entre actual_end_time y actual_start_time. En caso de que actual_end_time sea NULL, el tiempo de producción se establece en 0. 

...

(case 

   when actual_end_time IS NULL then 0

   else DATEDIFF(HOUR, actual_end_time, actual_start_time)

end ) as real_time,

...

​
  • Fecha de inicio planificada:
    Se obtiene concatenando los campos inicio_program_afko y hora_inicio_afko, considerando únicamente los registros donde inicio_program_afko sea diferente de '00000000'. 

...

(case

   when spp.inicio_program_afko = '00000000' then null

   else parseDateTimeBestEffort(toString(toDateTimeOrNull(CONCAT(

       SUBSTRING(spp.inicio_program_afko,1,4),'-', 

       SUBSTRING(spp.inicio_program_afko,5,2),'-',

       SUBSTRING(spp.inicio_program_afko,7,2),' ',

       hora_inicio_afko ))))  

end ) as planned_start_time,

...

​
  • Fecha de finalización planificada:
    Se calcula concatenando los campos fin_programado_afko y fin_hora_afko, considerando únicamente los registros donde fin_programado_afko sea diferente de '00000000'. 

...

(case

   when spp.fin_programado_afko = '00000000' then null

   else parseDateTimeBestEffort(toString(toDateTimeOrNull(CONCAT(

       SUBSTRING(spp.fin_programado_afko,1,4),'-', 

       SUBSTRING(spp.fin_programado_afko,5,2),'-',

       SUBSTRING(spp.fin_programado_afko,7,2),' ',

       fin_hora_afko ))))

end ) as planned_end_time,

...

​
  • Tiempo de planificación:
    Se obtiene calculando la diferencia en horas entre planned_end_time y planned_start_time. 

DATEDIFF(HOUR, planned_end_time, planned_start_time) as planned_time,

​

​

Instalación 

docker-compose up -d dbt_oi_production_order --build

​

​

Modelo sql ejecutado 

  1. {{ config(
  2.    order_by='(orden_afko)',
  3.    engine='ReplacingMergeTree(_version)',
  4.    materialized='incremental',
  5.    incremental_strategy='append'

  7. ) }}

  9. WITH inventory AS (
  10.    SELECT 
  11.        libre_utiliz,
  12.        material, 
  13.        centro, 
  14.        almacen 
  15.    FROM {{ source('oneconnect', 'PR0_B_MM_MATERIAL_ALMACEN') }} FINAL
  16. )


  19. SELECT
  20.    --material_afpo MATNR
  21.    numero_material_afpo,
  22.    --plant_afpo DWERK
  23.    centro_afpo,
  24.    -- location_afpo LGORT
  25.    almacen_afpo,
  26.    --order_afko AUFNR
  27.    orden_afko,
  28.    -- schedstart_afko GSTRS
  29.    CONCAT(SUBSTRING(spp.inicio_program_afko,1,4),'-',SUBSTRING(spp.inicio_program_afko,5,2)) as MY_planned_start_date,
  30.     -- act_start_afko GSTRI
  31.     -- actstart_afko GSUZI
  32.    (case
  33.     when spp.feinicio_real_afko = '00000000' then  null
  34.     else  parseDateTimeBestEffort(toString(toDateTimeOrNull(CONCAT( SUBSTRING(spp.feinicio_real_afko,1,4),'-' , SUBSTRING(spp.feinicio_real_afko,5,2),'-',SUBSTRING(spp.feinicio_real_afko,7,2)
  35.    ,' ', hora_inreal_afko ))))  end ) as actual_start_time,
  36.    -- actfinish_afko GLTRI
  37.    -- actfinish1_afko GEUZI
  38.    (case
  39.     when spp.fecha_fin_real1_afko = '00000000' then  null
  40.     else parseDateTimeBestEffort(toString(toDateTimeOrNull(CONCAT( SUBSTRING(spp.fecha_fin_real1_afko,1,4),'-' , SUBSTRING(spp.fecha_fin_real1_afko,5,2),'-',SUBSTRING(spp.fecha_fin_real1_afko,7,2)
  41.    ,' ', fin_real_hora_afko )))) end ) as actual_end_time,
  42.     -- 
  43.     (case
  44.     when actual_end_time IS NULL then  0
  45.     else DATEDIFF(HOUR,actual_end_time, actual_start_time )  end )  as real_time,
  46.    --schedstart_afko  GSTRS
  47.    --start_time_afko GSUZS
  48.    --GSTRS y GSUZS
  49.    (case
  50.     when spp.inicio_program_afko = '00000000' then  null
  51.     else  parseDateTimeBestEffort(toString(toDateTimeOrNull(CONCAT( SUBSTRING(spp.inicio_program_afko,1,4),'-' , SUBSTRING(spp.inicio_program_afko,5,2),'-',SUBSTRING(spp.inicio_program_afko,7,2)
  52.    ,' ', hora_inicio_afko  ))))   end )  as planned_start_time,
  53.     --schedfin_afko GLTRS
  54.     -- finish_tme_afko GLUZS
  55.     --GLTRS y GLUZS
  56.     (case
  57.     when spp.fin_programado_afko = '00000000' then  null
  58.     else   parseDateTimeBestEffort(toString(toDateTimeOrNull(CONCAT( SUBSTRING(spp.fin_programado_afko,1,4),'-' , SUBSTRING(spp.fin_programado_afko,5,2),'-',SUBSTRING(spp.fin_programado_afko,7,2)
  59.    ,' ', fin_hora_afko  ))))  end ) as planned_end_time,
  60.    
  61.    DATEDIFF(HOUR,planned_end_time, planned_start_time) as planned_time,
  62.    spp._version as updated_at,
  63.    now64() as _version
  64. FROM {{ ref('OI_SILVER_PP_PRODUCTION_ORDER_ECC')}} AS spp final
  65. LEFT JOIN inventory AS mard
  66.    ON mard.material = spp.numero_material_afpo  
  67.    and mard.centro = spp.centro_afpo 
  68.    and mard.almacen = spp.almacen_afpo
  69. WHERE 
  70.    spp.utilizacion_afko = '1' AND 
  71.    spp.tipo_de_orden_aufk = '10'


    • Related Articles

    • PRODUCCTION DASHBOARD

      Tablero de Producción Descripción General Propósito: Seguimiento de ordenes y el seguimiento del performance de los procesos de producción, como la cantidad, calidad y eficiencia. Fuente de Datos: ClickHouse. Instalación del Tablero Paso 1: Importar ...

    • INVOICE DASHBOARD

      Tablero de Facturación Descripción General Propósito: Análisis de ventas y facturación mensual. Fuente de Datos: ClickHouse. Instalación del Tablero Paso 1: Importar el JSON en Grafana Iniciar sesión en Grafana. Ir a Dashboards → Manage → Import. ...

    • INVENTORY DASHBOARD

      Tablero de Inventarios Descripción General Propósito: El Tablero de Inventario está compuesto por entidades que consolidan información clave de órdenes de compra, órdenes de venta y órdenes de producción para mostrar los materiales entrantes y ...

    • 11 INVOICE DASHBOARD

      ENTIDAD GOLD DE TABLERO DE FACTURAS También conocido como Tablero de Ventas, este modelo pertenece a la capa Gold de la arquitectura de medallón y está compuesto por la entidad BI_SILVER_SD_INVOICE_ECC. Su objetivo principal es proporcionar una ...

    • 12. INVENTORY DASHBOARD

      ENTIDADES GOLD DEL TABLERO DE INVENTARIOS El Tablero de Inventario está compuesto por entidades que consolidan información clave de órdenes de compra, órdenes de venta, órdenes de producción y tablas descriptivas (tablas TXT). Su objetivo es ...