fix(exporter): 修复ymt数据源下reseller_id_eq过滤器处理

- 不再将reseller_id_eq转换为merchant_id_in过滤条件
- 保留reseller_id_eq作为独立的WHERE子句进行过滤
- 删除零值的reseller_id_eq以避免无效查询条件
- 优化了过滤器的逻辑,避免删改遗漏问题
This commit is contained in:
zhouyonggao 2025-12-18 17:57:07 +08:00
parent bc6bc3945e
commit 57ecdbe692
1 changed files with 2 additions and 6 deletions

View File

@ -178,17 +178,13 @@ func BuildSQLWithFields(req BuildRequest, whitelist map[string]bool) (string, []
delete(req.Filters, "merchant_id_eq") delete(req.Filters, "merchant_id_eq")
} }
} }
// normalize reseller_id_eq (YMT 直连 merchant_id) // reseller_id_eq (YMT): 不再转换为 merchant_id_in保留作为单独 WHERE 条件
if req.Datasource == "ymt" && (req.MainTable == "order" || req.MainTable == "order_info") { if req.Datasource == "ymt" && (req.MainTable == "order" || req.MainTable == "order_info") {
if v, ok := req.Filters["reseller_id_eq"]; ok { if v, ok := req.Filters["reseller_id_eq"]; ok {
if isZeroID(v) { if isZeroID(v) {
delete(req.Filters, "reseller_id_eq") delete(req.Filters, "reseller_id_eq")
} else {
if _, has := req.Filters["merchant_id_in"]; !has {
req.Filters["merchant_id_in"] = []interface{}{v}
}
delete(req.Filters, "reseller_id_eq")
} }
// 保留 reseller_id_eq 作为单独 WHERE 条件
} }
} }