La fluidez y precisión de la información son pilares fundamentales en la gestión empresarial moderna. Este artículo detalla una metodología práctica para la integración efectiva de los registros de órdenes de salida de ventas desde Wandiantong Enterprise Qimen hacia Kingdee Cloud Starry Sky, utilizando una plataforma de integración de datos especializada.

El objetivo principal de esta implementación es asegurar una transferencia de datos precisa y oportuna para las órdenes de salida de ventas de distribución, abarcando tanto transacciones comerciales regulares como aquellas clasificadas como "órdenes de prueba" o "simuladas". Para lograr este flujo de datos armonizado, se aprovechan capacidades clave de la plataforma, incluyendo una alta capacidad de procesamiento, un sistema de monitoreo y alertas en tiempo real, lógica de transformación de datos personalizable y herramientas visuales intuitivas para el diseño de flujos.

El proceso comienza con la extracción programada y fiable de los datos más recientes de las órdenes de salida de ventas desde Wandiantong Enterprise Qimen, mediante la invocación de su interfaz de programación de aplicaciones (API) wdt.stockout.order.query.trade. Una vez recopilados, estos datos se someten a un procesamiento de adaptación, utilizando lógica de transformación definida por el usuario para alinearlos con los requisitos específicos y la estructura de datos de Kingdee Cloud Starry Sky. La plataforma de integración facilita la visualización y gestión de todo este flujo de datos, haciéndolo transparente y manejable.

Posteriormente, para garantizar la carga rápida y sin omisiones de grandes volúmenes de datos en Kingdee Cloud Starry Sky, se emplea su API de escritura por lotes, conocida como batchSave. Un sistema centralizado de monitoreo y alertas permite supervisar el estado y el rendimiento de cada tarea de integración en tiempo real, lo que posibilita la detección y corrección proactiva de cualquier anomalía. Adicionalmente, se ha diseñado un mecanismo robusto de reintento de errores para solventar desafíos como la paginación y las limitaciones de tasa (rate limiting), asegurando así la transmisión completa de toda la información.

Finalmente, a lo largo de todo el ciclo de integración, la plataforma ofrece funcionalidades exhaustivas de monitoreo de calidad de datos y detección de inconsistencias. Esto es crucial no solo para identificar y abordar posibles problemas de datos de forma oportuna, sino también para certificar que cada registro insertado en Kingdee Cloud Starry Sky sea preciso e íntegro. Este enfoque integral incrementa la visibilidad operativa y la eficiencia, estableciendo una sincronización impecable entre Wandiantong Enterprise Qimen y Kingdee Cloud Starry Sky.

Extracción y Procesamiento de Datos desde la API de Wandiantong Enterprise Qimen

La fase de extracción de datos es fundamental en cualquier proceso de integración. Aquí se detalla cómo se confiugra la llamada a la API wdt.stockout.order.query.trade de Wandiantong Enterprise Qimen y el tratamiento inicial de los datos obtenidos.

Configuración de la Interfaz y Llamada

Es primordial configurar los metadatos de la interfaz para una invocación correcta. Los parámetros clave incluyen:

• API: wdt.stockout.order.query.trade
• Método de Petición: POST
• Rango Temporal para Datos Incrementales: Definido por start_time y end_time.
• Filtro de Estado: Se utilizan valores específicos para status, como "110" (despachado) y "95" (completado).
• Parámetros de Paginación: page_size y page_no.

Esta configuración garantiza una recuperación eficiente de los datos requeridos, con soporte para el manejo de grandes volúmenes mediante paginación.

{
 "api_endpoint": "wdt.stockout.order.query.trade",
 "http_method": "POST",
 "request_parameters": [
   {"param_name": "start_time", "value_source": "{{ULTIMA_SINCRO_DATETIME}}"},
   {"param_name": "end_time", "value_source": "{{TIEMPO_ACTUAL_DATETIME}}"},
   {"param_name": "status", "value_filter": "110,95"},
   {"param_name": "page_size", "value_template": "{TAMANO_PAGINA_INTEGRACION}"},
   {"param_name": "page_no", "value_template": "{NUMERO_PAGINA_INICIO}"}
 ]
}

Limpieza y Transformación de Datos

Después de obtener los datos brutos, el siguiente paso es la depuración y transformación. Esta fase asegura la exactitud y homogeneidad de los datos, preparándolos para su inserción en el sistema destino.

1. Conversión de Formato de Fechas: Unificación de los campos de fecha a un formato estándar.
2. Mapeo de Códigos de Estado: Traducción de los códigos de estado del sistema fuente a los equivalentes del sistema destino, según las reglas de negocio.
3. Renombrado de Campos y Conversión de Tipo: Por ejemplo, el identificador original src_tid se renombra al nombre de campo requerido por el sistema destino, asegurando que su tipo de dato sea el adecuado.

La plataforma facilita la configuración de estas reglas de procesamiento.

{
     "id_validation_enabled": true,
     "auto_response_fill": true
     // ... otras configuraciones para limpieza
   }

Manejo de Paginación y Límites de Tasa

Dado que las respuestas de la API pueden ser extensas, se implementa un mecanismo de paginación mediante los parámetros page_size y page_no para recuperar los datos por bloques. Para evitar problemas de límites de tasa (rate limiting) por un exceso de solicitudes, es posible introducir retardos apropiados entre las llamadas a la API o emplear un esquema de programación de tareas asíncronas.

Monitoreo en Tiempo Real y Registro de Eventos

Para asegurar la transparencia y control del proceso, la plataforma de integración ofrece capacidades de monitoreo en tiempo real y registro detallado. Estas herramientas permiten supervisar el estado de ejecución de las tareas, los indicadores de rendimiento y la aparición de posibles problemas, facilitando una respuesta rápida y ajustes si es necesario.

Gestión de Excepciones y Reintento Automático

En operaciones reales, son inevitables situaciones anómalas como interrupciones de red o tiempos de espera de la API. Por ello, se diseña un mecanismo robusto de gestión de excepciones, que incluye la captura de errores, notificaciones de alerta y estrategias de reintento automático, para garantizar la estabilidad y fiabilidad del proceso de integración de datos.

Carga y Transformación ETL: Órdenes de Salida de Ventas a Kingdee Cloud Starry Sky

Una vez que los datos de Wandiantong han sido extraídos y pre-procesados, la siguiente fase crítica es su transformación final y carga en Kingdee Cloud Starry Sky, asegurando que se adapten al formato y las reglas de negocio del sistema destino.

Proceso de Transformación y Escritura

Con los datos de origen limpios, el siguiente paso es conformarlos a los requisitos de la API de Kingdee Cloud Starry Sky para su ingestión. Los pasos cruciales incluyen:

1. Configuración de Metadatos

La configuración de metadatos define las reglas de mapeo y transformación de los campos de datos. A continuación, un ejemplo de configuración de metadatos típica:

{
     "endpoint_path": "batchSave",
     "action_type": "EXECUTE",
     "request_method": "POST",
     "id_validation_enabled": true,
     "operation_details": {
       "batch_mode": "batchArraySave",
       "min_rows_per_batch": 1,
       "data_array_key": "array"
     },
     // ...otros parámetros de configuración
   }

2. Mapeo y Transformación de Campos

En la fase ETL, es esencial mapear los campos de datos de origen a sus equivalentes en el sistema destino y aplicar las transformaciones necesarias según la lógica de negocio. Ejemplos:

• Tipo de Documento (FBillTypeID): Se determina en función del valor del campo flag_name. Si es "刷单" (orden de prueba), el tipo será "ZYD-106"; de lo contrario, "ZYD-017".
• Organización de Ventas (FSaleOrgId): Se asigna según el campo shop_no. Por ejemplo, si shop_no es 'E0029', la organización será '3000'.

Estas reglas se definen mediante las propiedades value y parser en la configuración de metadatos.

{
     "target_field": "FBillTypeID",
     "display_name": "Tipo de Documento",
     "data_type": "string",
     "transformation_rule": "_FUNCTION EVALUATE CASE WHEN {source.flag_name} = '刷单' THEN 'ZYD-106' ELSE 'ZYD-017' END",
     "description": "Determina el tipo de documento de salida según la clasificación de la venta."
   }

3. Procesamiento y Envío por Lotes

Para optimizar la eficiencia, se utiliza un enfoque de procesamiento por lotes, donde múltiples registros se empaquetan en una única solicitud a la API de Kingdee Cloud Starry Sky. La propiedad operation_details.batch_mode en la configuración de metadatos especifica el método de procesamiento masivo, como batchArraySave.

4. Invocación de la API de Destino

Al invocar la API de Kingdee Cloud Starry Sky, es crucial asegurar que el formato de la solicitud cumpla con sus especificaciones. Esto generalmente implica el uso del método POST y la inclusión de todos los parámetros necesarios en el cuerpo de la solictiud.

{
     "parameter_name": "FormId",
     "parameter_value": "SAL_OUTSTOCK",
     "description": "Identificador del formulario de salida de inventario en Kingdee Cloud Starry Sky."
   }

Monitoreo de la Calidad de los Datos y Gestión de Anomalías

Durante todo el ciclo ETL, el monitoreo continuo y la gestión de excepciones son fundamentales. La plataforma de integración proporciona un sistema centralizado de alertas que permite seguir el estado y el rendimiento de las tareas en tiempo real. En caso de errores, los mecanismos de reintento garantizan la coherencia final de los datos.

Lógica de Transformación de Datos Personalizada

Para adaptarse a requisitos de negocio específicos, se pueden implementar lógicas de transformación de datos a medida. Un ejemplo es la determinación del número de lote (FLot) basada en el código de material (spec_no): si el código de material comienza con '8', el lote se establece en '0'; de lo contrario, se deja vacío.

{
     "target_field": "FLot",
     "description": "Número de Lote asignado al material.",
     "transformation_expression": "_COMPUTE_VALUE IF {source.spec_no} STARTS_WITH '8' THEN '0' ELSE '' END"
   }