team/tyapi-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

f

Browse Source
This commit is contained in:
Mrx
2026-03-06 16:39:00 +08:00
parent 57d18be972
commit b0ec75d1af
2 changed files with 4 additions and 82 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
internal/domains/api/services/processors/qygl/qyglj0q1_processor.go
View File

@@ -51,8 +51,8 @@ func ProcessQYGLJ0Q1Request(ctx context.Context, params []byte, deps *processors
return nil, errors.Join(processors.ErrSystem, err)
}
// 解析响应中的JSON字符串
parsedResp, err := ParseJsonResponse(data)
// 解析响应中的 JSON 字符串（使用 qyglb4c0 中的 RecursiveParse）
parsedResp, err := RecursiveParse(data)
if err != nil {
return nil, errors.Join(processors.ErrSystem, err)
}
@@ -63,42 +63,3 @@ func ProcessQYGLJ0Q1Request(ctx context.Context, params []byte, deps *processors
}
return respBytes, nil
}
// ParseJsonResponse 直接解析JSON响应数据
// data: 接口返回的数据
// Returns: 解析后的数据
func ParseJsonResponse(data interface{}) (interface{}, error) {
return RecursiveParse(data)
}
// RecursiveParse 递归解析JSON数据
func RecursiveParse(data interface{}) (interface{}, error) {
switch v := data.(type) {
case string:
var parsed interface{}
if err := json.Unmarshal([]byte(v), &parsed); err == nil {
return RecursiveParse(parsed)
}
return v, nil
case map[string]interface{}:
for key, val := range v {
parsed, err := RecursiveParse(val)
if err != nil {
return nil, err
}
v[key] = parsed
}
return v, nil
case []interface{}:
for i, item := range v {
parsed, err := RecursiveParse(item)
if err != nil {
return nil, err
}
v[i] = parsed
}
return v, nil
default:
return v, nil
}
}

43
internal/domains/api/services/processors/qygl/qygluy3s_processor.go
View File

@@ -42,8 +42,8 @@ func ProcessQYGLUY3SRequest(ctx context.Context, params []byte, deps *processors
return nil, errors.Join(processors.ErrSystem, err)
}
// 解析响应中的JSON字符串
parsedResp, err := ParseJsonResponse(data)
// 解析响应中的 JSON 字符串（使用 qyglb4c0 中的 RecursiveParse）
parsedResp, err := RecursiveParse(data)
if err != nil {
return nil, errors.Join(processors.ErrSystem, err)
}
@@ -54,42 +54,3 @@ func ProcessQYGLUY3SRequest(ctx context.Context, params []byte, deps *processors
}
return respBytes, nil
}
// ParseJsonResponse 直接解析JSON响应数据
// data: 接口返回的数据
// Returns: 解析后的数据
func ParseJsonResponse(data interface{}) (interface{}, error) {
return RecursiveParse(data)
}
// RecursiveParse 递归解析JSON数据
func RecursiveParse(data interface{}) (interface{}, error) {
switch v := data.(type) {
case string:
var parsed interface{}
if err := json.Unmarshal([]byte(v), &parsed); err == nil {
return RecursiveParse(parsed)
}
return v, nil
case map[string]interface{}:
for key, val := range v {
parsed, err := RecursiveParse(val)
if err != nil {
return nil, err
}
v[key] = parsed
}
return v, nil
case []interface{}:
for i, item := range v {
parsed, err := RecursiveParse(item)
if err != nil {
return nil, err
}
v[i] = parsed
}
return v, nil
default:
return v, nil
}
}