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-05-29 20:13:12 +08:00
parent 2a174e49e5
commit 4b1176b1e3
17 changed files with 31 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
internal/domains/api/services/processors/flxg/flxg5a3b_processor.go
View File

@@ -45,7 +45,7 @@ func ProcessFLXG5A3BRequest(ctx context.Context, params []byte, deps *processors
rawData, ok := resp.Data.(map[string]interface{}) rawData, ok := resp.Data.(map[string]interface{})
if !ok { if !ok {
return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) return processors.MarshalRawResponse(resp.Data)
} }
result := mapNuoerPersonalLawsuitToResponse(rawData) result := mapNuoerPersonalLawsuitToResponse(rawData)

2
internal/domains/api/services/processors/flxg/flxg7e8f_processor.go
View File

@@ -51,7 +51,7 @@ func ProcessFLXG7E8FRequest(ctx context.Context, params []byte, deps *processors
respMap, ok := respData.(map[string]interface{}) respMap, ok := respData.(map[string]interface{})
if !ok { if !ok {
return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) return processors.MarshalRawResponse(respData)
} }
result := map[string]interface{}{ result := map[string]interface{}{

2
internal/domains/api/services/processors/flxg/flxgdea9_processor.go
View File

@@ -45,7 +45,7 @@ func ProcessFLXGDEA9Request(ctx context.Context, params []byte, deps *processors
rawData, ok := resp.Data.(map[string]interface{}) rawData, ok := resp.Data.(map[string]interface{})
if !ok { if !ok {
return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) return processors.MarshalRawResponse(resp.Data)
} }
result := mapNuoerIdRiskToResponse(rawData) result := mapNuoerIdRiskToResponse(rawData)

2
internal/domains/api/services/processors/ivyz/ivyzrax2_processor.go
View File

@@ -43,7 +43,7 @@ func ProcessIVYZRAX2Request(ctx context.Context, params []byte, deps *processors
rawData, ok := resp.Data.(map[string]interface{}) rawData, ok := resp.Data.(map[string]interface{})
if !ok { if !ok {
return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) return processors.MarshalRawResponse(resp.Data)
} }
result := mapNuoerKunyuFixToResponse(rawData) result := mapNuoerKunyuFixToResponse(rawData)

2
internal/domains/api/services/processors/jrzq/jrzq1d09_processor.go
View File

@@ -43,7 +43,7 @@ func ProcessJRZQ1D09Request(ctx context.Context, params []byte, deps *processors
rawData, ok := resp.Data.(map[string]interface{}) rawData, ok := resp.Data.(map[string]interface{})
if !ok { if !ok {
return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) return processors.MarshalRawResponse(resp.Data)
} }
result := mapNuoerLoanRiskTagV18ToResponse(rawData) result := mapNuoerLoanRiskTagV18ToResponse(rawData)

2
internal/domains/api/services/processors/jrzq/jrzq2f8a_processor.go
View File

@@ -43,7 +43,7 @@ func ProcessJRZQ2F8ARequest(ctx context.Context, params []byte, deps *processors
rawData, ok := resp.Data.(map[string]interface{}) rawData, ok := resp.Data.(map[string]interface{})
if !ok { if !ok {
return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) return processors.MarshalRawResponse(resp.Data)
} }
result := mapNuoerLoanRiskTagV9ToResponse(rawData) result := mapNuoerLoanRiskTagV9ToResponse(rawData)

2
internal/domains/api/services/processors/jrzq/jrzq3c7b_processor.go
View File

@@ -43,7 +43,7 @@ func ProcessJRZQ3C7BRequest(ctx context.Context, params []byte, deps *processors
rawData, ok := resp.Data.(map[string]interface{}) rawData, ok := resp.Data.(map[string]interface{})
if !ok { if !ok {
return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) return processors.MarshalRawResponse(resp.Data)
} }
result := mapNuoerApplyLoanToResponse(rawData) result := mapNuoerApplyLoanToResponse(rawData)

2
internal/domains/api/services/processors/jrzq/jrzq4b6c_processor.go
View File

@@ -42,7 +42,7 @@ func ProcessJRZQ4B6CRequest(ctx context.Context, params []byte, deps *processors
rawData, ok := resp.Data.(map[string]interface{}) rawData, ok := resp.Data.(map[string]interface{})
if !ok { if !ok {
return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) return processors.MarshalRawResponse(resp.Data)
} }
result := mapNuoerLoanRiskTagV10ToResponse(rawData) result := mapNuoerLoanRiskTagV10ToResponse(rawData)

2
internal/domains/api/services/processors/jrzq/jrzq5e9f_processor.go
View File

@@ -43,7 +43,7 @@ func ProcessJRZQ5E9FRequest(ctx context.Context, params []byte, deps *processors
rawData, ok := resp.Data.(map[string]interface{}) rawData, ok := resp.Data.(map[string]interface{})
if !ok { if !ok {
return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) return processors.MarshalRawResponse(resp.Data)
} }
result := mapNuoerLoanRiskToResponse(rawData) result := mapNuoerLoanRiskToResponse(rawData)

2
internal/domains/api/services/processors/jrzq/jrzq6f2a_processor.go
View File

@@ -55,7 +55,7 @@ func ProcessJRZQ6F2ARequest(ctx context.Context, params []byte, deps *processors
respMap, ok := respData.(map[string]interface{}) respMap, ok := respData.(map[string]interface{})
if !ok { if !ok {
return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) return processors.MarshalRawResponse(respData)
} }
result := mapJRZQ3C7BToJRZQ6F2A(respMap) result := mapJRZQ3C7BToJRZQ6F2A(respMap)

2
internal/domains/api/services/processors/jrzq/jrzq7f1a_processor.go
View File

@@ -43,7 +43,7 @@ func ProcessJRZQ7F1ARequest(ctx context.Context, params []byte, deps *processors
rawData, ok := resp.Data.(map[string]interface{}) rawData, ok := resp.Data.(map[string]interface{})
if !ok { if !ok {
return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) return processors.MarshalRawResponse(resp.Data)
} }
result := mapNuoerLoanRiskTagV8ToResponse(rawData) result := mapNuoerLoanRiskTagV8ToResponse(rawData)

2
internal/domains/api/services/processors/jrzq/jrzq8a2d_processor.go
View File

@@ -43,7 +43,7 @@ func ProcessJRZQ8A2DRequest(ctx context.Context, params []byte, deps *processors
rawData, ok := resp.Data.(map[string]interface{}) rawData, ok := resp.Data.(map[string]interface{})
if !ok { if !ok {
return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) return processors.MarshalRawResponse(resp.Data)
} }
result := mapNuoerSpecialListToResponse(rawData) result := mapNuoerSpecialListToResponse(rawData)

2
internal/domains/api/services/processors/jrzq/jrzq8b3c_processor.go
View File

@@ -43,7 +43,7 @@ func ProcessJRZQ8B3CRequest(ctx context.Context, params []byte, deps *processors
rawData, ok := resp.Data.(map[string]interface{}) rawData, ok := resp.Data.(map[string]interface{})
if !ok { if !ok {
return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) return processors.MarshalRawResponse(resp.Data)
} }
result := mapNuoerConsumerTagToResponse(rawData) result := mapNuoerConsumerTagToResponse(rawData)

2
internal/domains/api/services/processors/jrzq/jrzq9d4e_processor.go
View File

@@ -43,7 +43,7 @@ func ProcessJRZQ9D4ERequest(ctx context.Context, params []byte, deps *processors
rawData, ok := resp.Data.(map[string]interface{}) rawData, ok := resp.Data.(map[string]interface{})
if !ok { if !ok {
return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) return processors.MarshalRawResponse(resp.Data)
} }
result := mapNuoerLoanRiskTagV23ToResponse(rawData) result := mapNuoerLoanRiskTagV23ToResponse(rawData)

2
internal/domains/api/services/processors/qygl/qygl5f6a_processor.go
View File

@@ -40,7 +40,7 @@ func ProcessQYGL5F6ARequest(ctx context.Context, params []byte, deps *processors
rawData, ok := resp.Data.(map[string]interface{}) rawData, ok := resp.Data.(map[string]interface{})
if !ok { if !ok {
return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) return processors.MarshalRawResponse(resp.Data)
} }
result := mapNuoerIdRelationToEntReportResponse(rawData) result := mapNuoerIdRelationToEntReportResponse(rawData)

2
internal/domains/api/services/processors/qygl/qygl6f2d_processor.go
View File

@@ -40,7 +40,7 @@ func ProcessQYGL6F2DRequest(ctx context.Context, params []byte, deps *processors
rawData, ok := resp.Data.(map[string]interface{}) rawData, ok := resp.Data.(map[string]interface{})
if !ok { if !ok {
return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) return processors.MarshalRawResponse(resp.Data)
} }
result := mapNuoerIdRelationToResponse(rawData) result := mapNuoerIdRelationToResponse(rawData)

15
internal/domains/api/services/processors/response.go Normal file
View File

@@ -0,0 +1,15 @@
package processors
import (
"encoding/json"
"errors"
)
// MarshalRawResponse 将上游原始响应数据序列化后返回（格式不符合预期时使用）。
func MarshalRawResponse(data interface{}) ([]byte, error) {
respBytes, err := json.Marshal(data)
if err != nil {
return nil, errors.Join(ErrSystem, err)
}
return respBytes, nil
}