From e1f62efecd18369c08866e4a917cf213bef8fd38 Mon Sep 17 00:00:00 2001 From: Mrx <18278715334@163.com> Date: Tue, 24 Feb 2026 15:00:40 +0800 Subject: [PATCH 1/3] f --- app/main/api/internal/service/apirequestService.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/app/main/api/internal/service/apirequestService.go b/app/main/api/internal/service/apirequestService.go index 8a7bd9f..00fd496 100644 --- a/app/main/api/internal/service/apirequestService.go +++ b/app/main/api/internal/service/apirequestService.go @@ -102,6 +102,7 @@ func (a *ApiRequestService) ProcessRequests(params []byte, productID int64, orde // 在原始 params 上附加 order_no,供异步车辆类接口自动生成回调地址使用 var baseParams map[string]interface{} if err := json.Unmarshal(params, &baseParams); err != nil { + logx.Errorf("解析查询参数失败, Params: %s, Error: %v", string(params), err) return nil, fmt.Errorf("解析查询参数失败: %w", err) } if orderNo != "" { @@ -109,6 +110,7 @@ func (a *ApiRequestService) ProcessRequests(params []byte, productID int64, orde } paramsWithOrder, err := json.Marshal(baseParams) if err != nil { + logx.Errorf("序列化查询参数失败, Params: %s, Error: %v", string(params), err) return nil, fmt.Errorf("序列化查询参数失败: %w", err) } var ( @@ -155,6 +157,9 @@ func (a *ApiRequestService) ProcessRequests(params []byte, productID int64, orde } } if preprocessErr != nil { + // 在这里添加日志记录入参 + logx.Errorf("API请求处理器失败, ApiID: %s, Params: %s, Error: %v", feature.ApiId, string(paramsWithOrder), preprocessErr) + result.Timestamp = timestamp result.Error = preprocessErr.Error() result.Data = resp From 15c0d205080ae1e90f2ede28245165248f991d15 Mon Sep 17 00:00:00 2001 From: Mrx <18278715334@163.com> Date: Tue, 24 Feb 2026 15:14:33 +0800 Subject: [PATCH 2/3] f --- app/main/api/internal/service/apirequestService.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/app/main/api/internal/service/apirequestService.go b/app/main/api/internal/service/apirequestService.go index 00fd496..8e3e55c 100644 --- a/app/main/api/internal/service/apirequestService.go +++ b/app/main/api/internal/service/apirequestService.go @@ -105,6 +105,13 @@ func (a *ApiRequestService) ProcessRequests(params []byte, productID int64, orde logx.Errorf("解析查询参数失败, Params: %s, Error: %v", string(params), err) return nil, fmt.Errorf("解析查询参数失败: %w", err) } + + // 参数转换:将 mobile 转换为 mobile_no + if mobile, exists := baseParams["mobile"]; exists { + baseParams["mobile_no"] = mobile + delete(baseParams, "mobile") // 删除原始的 mobile 字段 + } + if orderNo != "" { baseParams["order_no"] = orderNo } From de78857139bf16892f0abf0cb27ad53fd08a23e0 Mon Sep 17 00:00:00 2001 From: Mrx <18278715334@163.com> Date: Tue, 24 Feb 2026 15:25:05 +0800 Subject: [PATCH 3/3] f --- app/main/api/internal/service/apirequestService.go | 1 - 1 file changed, 1 deletion(-) diff --git a/app/main/api/internal/service/apirequestService.go b/app/main/api/internal/service/apirequestService.go index 8e3e55c..81b34c1 100644 --- a/app/main/api/internal/service/apirequestService.go +++ b/app/main/api/internal/service/apirequestService.go @@ -109,7 +109,6 @@ func (a *ApiRequestService) ProcessRequests(params []byte, productID int64, orde // 参数转换:将 mobile 转换为 mobile_no if mobile, exists := baseParams["mobile"]; exists { baseParams["mobile_no"] = mobile - delete(baseParams, "mobile") // 删除原始的 mobile 字段 } if orderNo != "" {