2 Commits 23f026e9c1 ... 5d0d268da0

Author SHA1 Message Date
  fusu 5d0d268da0 refactor(admin): 优化 WAF 日志字段映射匹配逻辑- 移除了对 API 名称的强制小写转换,提高匹配准确性 3 days ago
  fusu ff5079a9ab refactor(admin): 优化 WAF 日志数据清洗配置 3 days ago
1 changed files with 8 additions and 8 deletions
  1. 8 8
      internal/service/admin/waflogdataclean.go

+ 8 - 8
internal/service/admin/waflogdataclean.go

@@ -36,24 +36,24 @@ var apiFieldMappings = map[string]map[string]FieldPathConfig{
 		"Comment":         {Paths: []string{"comment", "data.comment", "desc"}},
 		"Port":            {Paths: []string{"port", "data.port"}},
 		"RuleID":          {Paths: []string{"ruleId", "data.ruleId", "ids", "data.ids"}, FieldType: "array_int"},
-		"AddrBackendList": {Paths: []string{"addrBackendList", "data.addrBackendList"}, FieldType: "array_string"},
+		"AddrBackendList": {Paths: []string{"backendList", "data.backendList"}, FieldType: "array_string"},
 	},
 	"udp": { // UDP 和 TCP 结构类似
 		"Comment":         {Paths: []string{"comment", "data.comment", "desc"}},
 		"Port":            {Paths: []string{"port", "data.port"}},
 		"RuleID":          {Paths: []string{"ruleId", "data.ruleId", "ids", "data.ids"}, FieldType: "array_int"},
-		"AddrBackendList": {Paths: []string{"addrBackendList", "data.addrBackendList"}, FieldType: "array_string"},
+		"AddrBackendList": {Paths: []string{"backendList", "data.backendList"}, FieldType: "array_string"},
 	},
-	"globalLimit": {
+	"实例": {
 		"Comment": {Paths: []string{"comment", "data.comment", "desc"}},
 		"RuleID":  {Paths: []string{"ruleId", "data.ruleId", "ids", "data.ids"}, FieldType: "array_int"},
 	},
-	"allowAndDeny": {
-		"AllowAndDenyIps": {Paths: []string{"ip", "ips"}, FieldType: "array_string"},
+	"黑白名单": {
+		"AllowAndDenyIps": {Paths: []string{"ip", "ips", "data.ip", "data.ips"}, FieldType: "array_string"},
 		"RuleID":          {Paths: []string{"ruleId", "data.ruleId", "ids", "data.ids"}, FieldType: "array_int"},
 	},
-	"ccIpList": {
-		"AllowAndDenyIps": {Paths: []string{"ip", "ips","newIp"}}, // 精确指定 ccIpList 只查找 "ip"
+	"CC": {
+		"AllowAndDenyIps": {Paths: []string{"ips","newIp", "data.newIp","data.ips", "ip",  "data.ip" }},
 		"RuleID":          {Paths: []string{"ruleId", "data.ruleId", "ids", "data.ids"}, FieldType: "array_int"},
 	},
 	// "分配网关组" 的日志通常不包含用户层面的业务数据,所以这里不定义
@@ -105,7 +105,7 @@ func (s *wafLogDataCleanService) ParseWafLogExtraData(extraDataBytes json.RawMes
 	// 根据 apiName 找到对应的字段映射配置
 	var fieldConfig map[string]FieldPathConfig
 	for keyword, config := range apiFieldMappings {
-		if strings.Contains(strings.ToLower(apiName), keyword) {
+		if strings.Contains(apiName, keyword) {
 			fieldConfig = config
 			break
 		}