From 51d7a6c5aeb76ff33f8d7ffdae2bbc9e570c1367 Mon Sep 17 00:00:00 2001 From: stephanchrst Date: Wed, 13 Nov 2024 10:06:15 +0700 Subject: add fulfillment --- calculate_pareto_status.ktr | 1 + collect_fulfillment.ktr | 1506 +++++++++++++++++++++++++++++++++++++ collect_fulfillment_po.ktr | 888 ++++++++++++++++++++++ example_use_param_table_input.ktr | 903 ++++++++++++++++++++++ run_fulfillment_job.kjb | 413 ++++++++++ update_null_md_vendor.ktr | 937 +++++++++++++++++++++++ update_state_reserve_picking.ktr | 552 ++++++++++++++ 7 files changed, 5200 insertions(+) create mode 100644 collect_fulfillment.ktr create mode 100644 collect_fulfillment_po.ktr create mode 100644 example_use_param_table_input.ktr create mode 100644 run_fulfillment_job.kjb create mode 100644 update_null_md_vendor.ktr create mode 100644 update_state_reserve_picking.ktr diff --git a/calculate_pareto_status.ktr b/calculate_pareto_status.ktr index 1cb14ff..b636486 100644 --- a/calculate_pareto_status.ktr +++ b/calculate_pareto_status.ktr @@ -6,6 +6,7 @@ Normal + 0 / diff --git a/collect_fulfillment.ktr b/collect_fulfillment.ktr new file mode 100644 index 0000000..6197a8d --- /dev/null +++ b/collect_fulfillment.ktr @@ -0,0 +1,1506 @@ + + + + collect_fulfillment + + + + Normal + / + + + + + + + + + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2024/11/09 08:11:14.886 + - + 2024/11/09 08:11:14.886 + H4sIAAAAAAAAAAMAAAAAAAAAAAA= + N + + + + + erp indoteknik production (localhost) + 10.148.0.3 + POSTGRESQL + Native + erp_indoteknik + 5432 + odoo + Encrypted 2be98afc82bdfd8dd9a2ca45acc83f6c3 + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 5432 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + N + + + USE_POOLING + N + + + + + + sale order + so+deliv + Y + + + delivered qty + so+deliv + Y + + + so+deliv + so+deliv+reserv + Y + + + reserved qty + so+deliv+reserv + Y + + + so+deliv+reserv + so+deliv+reserv+po + Y + + + po qty + so+deliv+reserv+po + Y + + + so+deliv+reserv+po + so+deliv+reserv+po+received + Y + + + received qty + so+deliv+reserv+po+received + Y + + + Select values + Insert / update + Y + + + so+deliv+reserv+po+received + Add constants + Y + + + Add constants + Select values + Y + + + + Insert / update + InsertUpdate + + Y + + 1 + + none + + + erp indoteknik production (localhost) + 100 + N + + public +
sales_order_fulfillment_v2
+ + sale_order_line_id + sale_order_line_id + = + + + + sale_order_id + sale_order_id + Y + + + sale_order_line_id + sale_order_line_id + N + + + product_id + product_id + Y + + + so_qty + so_qty + Y + + + delivered_qty + delivered_qty + Y + + + reserved_stock_qty + reserved_stock_qty + Y + + + po_qty + po_qty + Y + + + received_qty + received_qty + Y + + + create_date + current_date + N + + + write_date + current_date + Y + + + create_uid + created_by_id + Y + + + write_uid + created_by_id + Y + + + + + + + + + + + + 848 + 368 + Y + + + + Select values + SelectValues + + Y + + 1 + + none + + + + + sale_order_id + + + + sale_order_line_id + + + + product_id + + + + so_qty + + + + current_date + + + + delivered_qty + + + + reserved_stock_qty + + + + po_qty + + + + received_qty + + + + created_by_id + + + N + + + + + + + + + + + 1008 + 368 + Y + + + + delivered qty + TableInput + + Y + + 1 + + none + + + erp indoteknik production (localhost) + select sm.sale_line_id as sale_order_line_id, sml.product_id, sum(sml.qty_done) as delivered_qty +from stock_move_line sml +join stock_move sm on sm.id = sml.move_id +join stock_picking sp on sp.id = sm.picking_id +where 1=1 +and sp.state not in ('cancel') +and sm.sale_line_id is not null +and sm.write_date >= (now() - '180 days'::interval) +group by sm.sale_line_id, sml.product_id +order by sm.sale_line_id, sml.product_id + 0 + + N + N + N + N + + + Integer + normal + sale_order_line_id + 9 + 0 + delivered qty + sale_order_line_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + Integer + normal + product_id + 9 + 0 + delivered qty + product_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + BigNumber + normal + delivered_qty + -1 + -1 + delivered qty + delivered_qty + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + + + + + + + + + + 288 + 96 + Y + + + + po qty + TableInput + + Y + + 1 + + none + + + erp indoteknik production (localhost) + select posm.sale_line_id as sale_order_line_id, posm.product_id, sum(posm.qty_po) as po_qty +from purchase_order_sales_match posm +join purchase_order po on po.id = posm.purchase_order_id +where 1=1 +and po.state in ('done', 'purchase') +and posm.write_date >= (now() - '180 days'::interval) +group by posm.sale_line_id, posm.product_id +order by posm.sale_line_id, posm.product_id + 0 + + N + N + N + N + + + Integer + normal + sale_order_line_id + 9 + 0 + po qty + sale_order_line_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + Integer + normal + product_id + 9 + 0 + po qty + product_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + Number + normal + po_qty + -1 + -1 + po qty + po_qty + ####0.0#########;-####0.0######### + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + + + + + + + + + + 608 + 96 + Y + + + + received qty + TableInput + + Y + + 1 + + none + + + erp indoteknik production (localhost) + select posm.sale_line_id as sale_order_line_id, sml.product_id, sum(sml.qty_done) as received_qty +from purchase_order_sales_match posm +join purchase_order po on po.id = posm.purchase_order_id +join purchase_order_line pol on (pol.order_id = po.id and pol.product_id = posm.product_id) +join stock_move sm on sm.purchase_line_id = pol.id +join stock_move_line sml on sml.move_id = sm.id +join stock_picking sp on sp.id = sm.picking_id +where 1=1 +and po.state in ('done', 'purchase') +and sp.state not in ('cancel') +and posm.write_date >= (now() - '180 days'::interval) +group by posm.sale_line_id, sml.product_id +order by posm.sale_line_id, sml.product_id + 0 + + N + N + N + N + + + Integer + normal + sale_order_line_id + 9 + 0 + received qty + sale_order_line_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + Integer + normal + product_id + 9 + 0 + received qty + product_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + BigNumber + normal + received_qty + -1 + -1 + received qty + received_qty + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + + + + + + + + + + 800 + 96 + Y + + + + reserved qty + TableInput + + Y + + 1 + + none + + + erp indoteknik production (localhost) + select sm.sale_line_id as sale_order_line_id, sml.product_id, sum(sml.product_uom_qty) as reserved_stock_qty +from stock_move_line sml +join stock_move sm on sm.id = sml.move_id +join stock_picking sp on sp.id = sm.picking_id +where 1=1 +and sp.state not in ('cancel') +and sm.sale_line_id is not null +and sm.write_date >= (now() - '180 days'::interval) +group by sm.sale_line_id, sml.product_id +order by sm.sale_line_id, sml.product_id + 0 + + N + N + N + N + + + Integer + normal + sale_order_line_id + 9 + 0 + reserved qty + sale_order_line_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + Integer + normal + product_id + 9 + 0 + reserved qty + product_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + BigNumber + normal + reserved_stock_qty + -1 + -1 + reserved qty + reserved_stock_qty + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + + + + + + + + + + 448 + 96 + Y + + + + sale order + TableInput + + Y + + 1 + + none + + + erp indoteknik production (localhost) + select so.id as sale_order_id, sol.id as sale_order_line_id, +sol.product_id as product_id, sol.product_uom_qty as so_qty, +now()::timestamp as current_date +from sale_order_line sol +join sale_order so on so.id = sol.order_id +join product_product pp on pp.id = sol.product_id +where 1=1 +and so.state in ('sale', 'done') +and sol.product_uom_qty <> sol.qty_delivered +and sol.write_date >= (now() - '180 days'::interval) +order by sol.id, sol.product_id + 0 + + N + N + N + N + + + Integer + normal + sale_order_id + 9 + 0 + sale order + sale_order_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + Integer + normal + sale_order_line_id + 9 + 0 + sale order + sale_order_line_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + Integer + normal + product_id + 9 + 0 + sale order + product_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + BigNumber + normal + so_qty + -1 + -1 + sale order + so_qty + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + Timestamp + normal + current_date + 6 + -1 + sale order + current_date + + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + + + + + + + + + + 144 + 224 + Y + + + + so+deliv + MergeJoin + + Y + + 1 + + none + + + LEFT OUTER + sale order + delivered qty + + sale_order_line_id + + + sale_order_line_id + + + + + + + + + + + 288 + 224 + Y + + + + so+deliv+reserv + MergeJoin + + Y + + 1 + + none + + + LEFT OUTER + so+deliv + reserved qty + + sale_order_line_id + + + sale_order_line_id + + + + + + + + + + + 448 + 224 + Y + + + + so+deliv+reserv+po + MergeJoin + + Y + + 1 + + none + + + LEFT OUTER + so+deliv+reserv + po qty + + sale_order_line_id + + + sale_order_line_id + + + + + + + + + + + 608 + 224 + Y + + + + so+deliv+reserv+po+received + MergeJoin + + Y + + 1 + + none + + + LEFT OUTER + so+deliv+reserv+po + received qty + + sale_order_line_id + + + sale_order_line_id + + + + + + + + + + + 800 + 224 + Y + + + + Add constants + Constant + + Y + + 1 + + none + + + + + created_by_id + Integer + + + + + 1 + -1 + -1 + N + + + + + + + + + + + + 1008 + 224 + Y + + + + + + + N + + diff --git a/collect_fulfillment_po.ktr b/collect_fulfillment_po.ktr new file mode 100644 index 0000000..6683ec9 --- /dev/null +++ b/collect_fulfillment_po.ktr @@ -0,0 +1,888 @@ + + + + collect_fulfillment_po + + + + Normal + / + + + + + + + + + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2024/11/13 08:53:00.392 + - + 2024/11/13 08:53:00.392 + + N + + + + + erp indoteknik production (localhost) + 10.148.0.3 + POSTGRESQL + Native + erp_indoteknik + 5432 + odoo + Encrypted 2be98afc82bdfd8dd9a2ca45acc83f6c3 + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 5432 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + N + + + USE_POOLING + N + + + + + + match po so + match po so with fulfillment + Y + + + fulfillment + match po so with fulfillment + Y + + + match po so with fulfillment + Filter fulfillment is not null + Y + + + Filter fulfillment is not null + Select values + Y + + + Filter fulfillment is not null + log fulfillment null + Y + + + Select values + Insert / update + Y + + + + fulfillment + TableInput + + Y + + 1 + + none + + + erp indoteknik production (localhost) + select id as fulfillment_id, sale_order_line_id +from sales_order_fulfillment_v2 +where 1=1 +and write_date >= (now() - '180 days'::interval) +order by sale_order_line_id + 0 + + N + N + N + N + + + Integer + normal + fulfillment_id + 9 + 0 + fulfillment + fulfillment_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + Integer + normal + sale_order_line_id + 9 + 0 + fulfillment + sale_order_line_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + + + + + + + + + + 368 + 96 + Y + + + + match po so + TableInput + + Y + + 1 + + none + + + erp indoteknik production (localhost) + select posm.sale_line_id as sale_order_line_id, po.id as purchase_order_id +from purchase_order_sales_match posm +join purchase_order po on po.id = posm.purchase_order_id +where 1=1 +and po.state in ('purchase', 'done') +and posm.write_date >= (now() - '180 days'::interval) +order by posm.sale_line_id + 0 + + N + N + N + N + + + Integer + normal + sale_order_line_id + 9 + 0 + match po so + sale_order_line_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + Integer + normal + purchase_order_id + 9 + 0 + match po so + purchase_order_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + + + + + + + + + + 160 + 192 + Y + + + + match po so with fulfillment + MergeJoin + + Y + + 1 + + none + + + LEFT OUTER + match po so + fulfillment + + sale_order_line_id + + + sale_order_line_id + + + + + + + + + + + 368 + 192 + Y + + + + Filter fulfillment is not null + FilterRows + + Y + + 1 + + none + + + Select values + log fulfillment null + + + N + fulfillment_id + IS NOT NULL + + + + + + + + + + + + + 592 + 192 + Y + + + + Select values + SelectValues + + Y + + 1 + + none + + + + + sale_order_line_id + + + + purchase_order_id + + + + fulfillment_id + + + N + + + + + + + + + + + 752 + 192 + Y + + + + log fulfillment null + WriteToLog + + Y + + 1 + + none + + + log_level_basic + Y + N + 0 + + + + + + + + + + + + + 592 + 304 + Y + + + + Insert / update + InsertUpdate + + Y + + 1 + + none + + + erp indoteknik production (localhost) + 100 + N + + public +
purchase_order_sales_order_fulfillment_v2_rel
+ + fulfillment_id + sales_order_fulfillment_v2_id + = + + + + purchase_order_id + purchase_order_id + Y + + + sales_order_fulfillment_v2_id + fulfillment_id + N + + + + + + + + + + + + 912 + 192 + Y + + + + + + + N + + diff --git a/example_use_param_table_input.ktr b/example_use_param_table_input.ktr new file mode 100644 index 0000000..c5bb577 --- /dev/null +++ b/example_use_param_table_input.ktr @@ -0,0 +1,903 @@ + + + + example_use_param_table_input + + + + Normal + 0 + / + + + + + + + + + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2024/11/09 07:41:25.978 + - + 2024/11/09 07:41:25.978 + + N + + + + + erp indoteknik production + localhost + POSTGRESQL + Native + erp_indoteknik + 5901 + odoo + Encrypted 2be98afc82bdfd8dd9a2ca45acc83f6c3 + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 5901 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + + Table input 2 + Select values + Y + + + Table input + Select values 2 + Y + + + Table input + Select values 3 + Y + + + Select values 3 + Table input 2 + Y + + + Select values 2 + Merge join + Y + + + Select values + Merge join + Y + + + Merge join + Select values 4 + Y + + + + Table input + TableInput + + N + + 1 + + none + + + erp indoteknik production + select id, name from sale_order where date_order between '2023-01-01' and '2023-12-31' order by id + 0 + + N + N + N + N + + + Integer + normal + id + 9 + 0 + Table input + id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + String + normal + name + 2147483647 + -1 + Table input + name + + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + + + + + + + + + + 128 + 80 + Y + + + + Select values + SelectValues + + Y + + 1 + + none + + + + + sale_order_id + + + + po + + + N + + + + + + + + + + + 544 + 80 + Y + + + + Table input 2 + TableInput + + Y + + 1 + + none + + + erp indoteknik production + select sale_order_id, name as po +from purchase_order +where sale_order_id = ? +order by sale_order_id + 0 + Select values 3 + Y + Y + N + N + + + Integer + normal + id + 9 + 0 + Table input + id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + Integer + normal + sale_order_id + 9 + 0 + Table input 2 + sale_order_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + String + normal + po + 2147483647 + -1 + Table input 2 + po + + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + + + + + + + + + + 352 + 80 + Y + + + + Select values 2 + SelectValues + + Y + + 1 + + none + + + + + id + + + + name + + + N + + + + + + + + + + + 128 + 192 + Y + + + + Select values 3 + SelectValues + + Y + + 1 + + none + + + + + id + + + N + + + + + + + + + + + 240 + 80 + Y + + + + Merge join + MergeJoin + + Y + + 1 + + none + + + INNER + Select values 2 + Select values + + id + + + sale_order_id + + + + + + + + + + + 352 + 192 + Y + + + + Select values 4 + SelectValues + + Y + + 1 + + none + + + + + id + + + + name + + + + sale_order_id + + + + po + + + N + + + + + + + + + + + 576 + 192 + Y + + + + + + + N + + diff --git a/run_fulfillment_job.kjb b/run_fulfillment_job.kjb new file mode 100644 index 0000000..93b36a3 --- /dev/null +++ b/run_fulfillment_job.kjb @@ -0,0 +1,413 @@ + + + run_fulfillment_job + + + + / + - + 2024/11/13 09:55:25.528 + - + 2024/11/13 09:55:25.528 + + + + + + + +
+ + + + + ID_JOB + Y + ID_JOB + + + CHANNEL_ID + Y + CHANNEL_ID + + + JOBNAME + Y + JOBNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + START_JOB_ENTRY + N + START_JOB_ENTRY + + + CLIENT + N + CLIENT + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + JOBNAME + Y + TRANSNAME + + + JOBENTRYNAME + Y + STEPNAME + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + RESULT + Y + RESULT + + + NR_RESULT_ROWS + Y + NR_RESULT_ROWS + + + NR_RESULT_FILES + Y + NR_RESULT_FILES + + + LOG_FIELD + N + LOG_FIELD + + + COPY_NR + N + COPY_NR + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + N + + + + collect fulfillment + + TRANS + + filename + + /home/stephan/transformation-job-bi/collect_fulfillment.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + N + + Y + + N + Y + 0 + 384 + 80 + + + + Start + + SPECIAL + + Y + N + N + 0 + 0 + 60 + 12 + 0 + 1 + 1 + N + Y + 0 + 176 + 80 + + + + collect fulfillment po + + TRANS + + filename + + /home/stephan/transformation-job-bi/collect_fulfillment_po.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + N + + Y + + N + Y + 0 + 576 + 80 + + + + + + Start + collect fulfillment + 0 + 0 + Y + Y + Y + + + collect fulfillment + collect fulfillment po + 0 + 0 + Y + Y + N + + + + + + diff --git a/update_null_md_vendor.ktr b/update_null_md_vendor.ktr new file mode 100644 index 0000000..ba50cef --- /dev/null +++ b/update_null_md_vendor.ktr @@ -0,0 +1,937 @@ + + + + update_null_md_vendor + + + + Normal + / + + + + + + +
+ + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2024/10/17 14:45:16.821 + - + 2024/10/17 14:45:16.821 + + N + + + + + erp indoteknik production + localhost + POSTGRESQL + Native + erp_indoteknik + 5901 + odoo + Encrypted 2be98afc82bdfd8dd9a2ca45acc83f6c3 + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + 5901 + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + + sale order line + Merge join + Y + + + pricelist_winner + Merge join + Y + + + Merge join + Filter rows + Y + + + Filter rows + Select values + Y + + + Filter rows + Write to log + Y + + + Select values + Update + Y + + + + pricelist_winner + TableInput + + Y + + 1 + + none + + + erp indoteknik production + SELECT id as pricelist_id, product_id, vendor_id FROM purchase_pricelist +where is_winner = true +order by product_id + 0 + + N + N + N + N + + + Integer + normal + pricelist_id + 9 + 0 + pricelist_winner + pricelist_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + Integer + normal + product_id + 9 + 0 + pricelist_winner + product_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + Integer + normal + vendor_id + 9 + 0 + pricelist_winner + vendor_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + + + + + + + + + + 240 + 144 + Y + + + + Merge join + MergeJoin + + Y + + 1 + + none + + + LEFT OUTER + sale order line + pricelist_winner + + product_id + + + product_id + + + + + + + + + + + 384 + 256 + Y + + + + sale order line + TableInput + + Y + + 1 + + none + + + erp indoteknik production + select id as orderline_id, product_id, name from sale_order_line +where vendor_md_id is null and order_id = 30881 +order by product_id + 0 + + N + N + N + N + + + Integer + normal + orderline_id + 9 + 0 + sale order line + orderline_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + Integer + normal + product_id + 9 + 0 + sale order line + product_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + String + normal + name + 2147483647 + -1 + sale order line + name + + . + , + + none + N + Y + 0 + N + N + N + en_US + Asia/Bangkok + N + + + + + + + + + + + + 240 + 336 + Y + + + + Filter rows + FilterRows + + Y + + 1 + + none + + + Select values + Write to log + + + N + vendor_id + IS NOT NULL + + + + + + + + + + + + + 528 + 256 + Y + + + + Select values + SelectValues + + Y + + 1 + + none + + + + + orderline_id + + + + product_id + + + + name + + + + pricelist_id + + + + product_id_1 + + + + vendor_id + + + N + + + + + + + + + + + 672 + 256 + Y + + + + Write to log + WriteToLog + + Y + + 1 + + none + + + log_level_basic + Y + N + 0 + + + + + + + + + + + + + 528 + 336 + Y + + + + Update + Update + + Y + + 1 + + none + + + erp indoteknik production + N + 100 + N + N + + + public +
sale_order_line
+ + orderline_id + id + = + + + + md_vendor_id + vendor_id + + + + + + + + + + + + 816 + 256 + Y + + + + + + + N + + diff --git a/update_state_reserve_picking.ktr b/update_state_reserve_picking.ktr new file mode 100644 index 0000000..f7b17a9 --- /dev/null +++ b/update_state_reserve_picking.ktr @@ -0,0 +1,552 @@ + + + + update_state_reserve_picking + + + + Normal + / + + + + + + + + + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2024/11/08 15:58:55.966 + - + 2024/11/08 15:58:55.966 + H4sIAAAAAAAAAAMAAAAAAAAAAAA= + N + + + + + + + Table input + TableInput + + Y + + 1 + + none + + + + SELECT <values> FROM <table name> WHERE <conditions> + 0 + + N + N + N + N + + + + + + + + + + + 112 + 96 + Y + + + + Execute row SQL script + ExecSQLRow + + Y + + 1 + + none + + + 1 + + + + + + + N + Y + + + + + + + + + + 272 + 96 + Y + + + + Execute SQL script + ExecSQL + + Y + + 1 + + none + + + + N + N + N + N + + N + + + + + + + + + + + + + + + + 304 + 256 + Y + + + + + + + N + + -- cgit v1.2.3