From 582a5daeea3857385dcdfc5f80ab34a0a8bc6a49 Mon Sep 17 00:00:00 2001 From: zhouyonggao <1971162852@qq.com> Date: Fri, 12 Dec 2025 18:32:03 +0800 Subject: [PATCH] =?UTF-8?q?feat(exporter):=20=E6=B7=BB=E5=8A=A0=E8=AE=A2?= =?UTF-8?q?=E5=8D=95=E9=87=8D=E8=AF=95=E7=8A=B6=E6=80=81=E7=9A=84SQL?= =?UTF-8?q?=E6=9E=84=E5=BB=BA=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- server/internal/exporter/sqlbuilder.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/server/internal/exporter/sqlbuilder.go b/server/internal/exporter/sqlbuilder.go index d1090f9..11359a1 100644 --- a/server/internal/exporter/sqlbuilder.go +++ b/server/internal/exporter/sqlbuilder.go @@ -99,6 +99,10 @@ func BuildSQL(req BuildRequest, whitelist map[string]bool) (string, []interface{ cols = append(cols, "CASE `"+mt+"`.pay_status WHEN 1 THEN '待支付' WHEN 2 THEN '支付中' WHEN 3 THEN '已支付' WHEN 4 THEN '取消支付' WHEN 5 THEN '退款中' WHEN 6 THEN '退款成功' ELSE '' END AS `order.pay_status`") continue } + if f == "is_retry" { + cols = append(cols, "CASE `"+mt+"`.is_retry WHEN 0 THEN '可以失败重试' WHEN 1 THEN '可以失败重试' WHEN 2 THEN '不可以失败重试' ELSE '' END AS `order.is_retry`") + continue + } if f == "supplier_name" { cols = append(cols, "'' AS `order.supplier_name`") continue @@ -120,6 +124,11 @@ func BuildSQL(req BuildRequest, whitelist map[string]bool) (string, []interface{ continue } } + // Generic mapping for order.is_retry across datasources + if t == "order" && f == "is_retry" { + cols = append(cols, "CASE `"+mt+"`.is_retry WHEN 0 THEN '可以失败重试' WHEN 1 THEN '可以失败重试' WHEN 2 THEN '不可以失败重试' ELSE '' END AS `order.is_retry`") + continue + } // Generic mapping for order.is_inner across datasources if t == "order" && f == "is_inner" { cols = append(cols, "CASE `"+mt+"`.is_inner WHEN 1 THEN '内部供应商' ELSE '外部供应商' END AS `order.is_inner`")