This commit is contained in:
Mrx
2026-02-24 15:00:40 +08:00
parent 86bda66271
commit e1f62efecd

View File

@@ -102,6 +102,7 @@ func (a *ApiRequestService) ProcessRequests(params []byte, productID int64, orde
// 在原始 params 上附加 order_no供异步车辆类接口自动生成回调地址使用 // 在原始 params 上附加 order_no供异步车辆类接口自动生成回调地址使用
var baseParams map[string]interface{} var baseParams map[string]interface{}
if err := json.Unmarshal(params, &baseParams); err != nil { if err := json.Unmarshal(params, &baseParams); err != nil {
logx.Errorf("解析查询参数失败, Params: %s, Error: %v", string(params), err)
return nil, fmt.Errorf("解析查询参数失败: %w", err) return nil, fmt.Errorf("解析查询参数失败: %w", err)
} }
if orderNo != "" { if orderNo != "" {
@@ -109,6 +110,7 @@ func (a *ApiRequestService) ProcessRequests(params []byte, productID int64, orde
} }
paramsWithOrder, err := json.Marshal(baseParams) paramsWithOrder, err := json.Marshal(baseParams)
if err != nil { if err != nil {
logx.Errorf("序列化查询参数失败, Params: %s, Error: %v", string(params), err)
return nil, fmt.Errorf("序列化查询参数失败: %w", err) return nil, fmt.Errorf("序列化查询参数失败: %w", err)
} }
var ( var (
@@ -155,6 +157,9 @@ func (a *ApiRequestService) ProcessRequests(params []byte, productID int64, orde
} }
} }
if preprocessErr != nil { if preprocessErr != nil {
// 在这里添加日志记录入参
logx.Errorf("API请求处理器失败, ApiID: %s, Params: %s, Error: %v", feature.ApiId, string(paramsWithOrder), preprocessErr)
result.Timestamp = timestamp result.Timestamp = timestamp
result.Error = preprocessErr.Error() result.Error = preprocessErr.Error()
result.Data = resp result.Data = resp