diff --git a/internal/domains/api/services/processors/flxg/flxg5a3b_processor.go b/internal/domains/api/services/processors/flxg/flxg5a3b_processor.go index 8f56db4..6925c1e 100644 --- a/internal/domains/api/services/processors/flxg/flxg5a3b_processor.go +++ b/internal/domains/api/services/processors/flxg/flxg5a3b_processor.go @@ -45,7 +45,7 @@ func ProcessFLXG5A3BRequest(ctx context.Context, params []byte, deps *processors rawData, ok := resp.Data.(map[string]interface{}) if !ok { - return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) + return processors.MarshalRawResponse(resp.Data) } result := mapNuoerPersonalLawsuitToResponse(rawData) diff --git a/internal/domains/api/services/processors/flxg/flxg7e8f_processor.go b/internal/domains/api/services/processors/flxg/flxg7e8f_processor.go index 8742681..8a3c093 100644 --- a/internal/domains/api/services/processors/flxg/flxg7e8f_processor.go +++ b/internal/domains/api/services/processors/flxg/flxg7e8f_processor.go @@ -51,7 +51,7 @@ func ProcessFLXG7E8FRequest(ctx context.Context, params []byte, deps *processors respMap, ok := respData.(map[string]interface{}) if !ok { - return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) + return processors.MarshalRawResponse(respData) } result := map[string]interface{}{ diff --git a/internal/domains/api/services/processors/flxg/flxgdea9_processor.go b/internal/domains/api/services/processors/flxg/flxgdea9_processor.go index 3139fb8..0e454ea 100644 --- a/internal/domains/api/services/processors/flxg/flxgdea9_processor.go +++ b/internal/domains/api/services/processors/flxg/flxgdea9_processor.go @@ -45,7 +45,7 @@ func ProcessFLXGDEA9Request(ctx context.Context, params []byte, deps *processors rawData, ok := resp.Data.(map[string]interface{}) if !ok { - return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) + return processors.MarshalRawResponse(resp.Data) } result := mapNuoerIdRiskToResponse(rawData) diff --git a/internal/domains/api/services/processors/ivyz/ivyzrax2_processor.go b/internal/domains/api/services/processors/ivyz/ivyzrax2_processor.go index e32ec31..7d0c3a3 100644 --- a/internal/domains/api/services/processors/ivyz/ivyzrax2_processor.go +++ b/internal/domains/api/services/processors/ivyz/ivyzrax2_processor.go @@ -43,7 +43,7 @@ func ProcessIVYZRAX2Request(ctx context.Context, params []byte, deps *processors rawData, ok := resp.Data.(map[string]interface{}) if !ok { - return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) + return processors.MarshalRawResponse(resp.Data) } result := mapNuoerKunyuFixToResponse(rawData) diff --git a/internal/domains/api/services/processors/jrzq/jrzq1d09_processor.go b/internal/domains/api/services/processors/jrzq/jrzq1d09_processor.go index 585f217..84e09b0 100644 --- a/internal/domains/api/services/processors/jrzq/jrzq1d09_processor.go +++ b/internal/domains/api/services/processors/jrzq/jrzq1d09_processor.go @@ -43,7 +43,7 @@ func ProcessJRZQ1D09Request(ctx context.Context, params []byte, deps *processors rawData, ok := resp.Data.(map[string]interface{}) if !ok { - return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) + return processors.MarshalRawResponse(resp.Data) } result := mapNuoerLoanRiskTagV18ToResponse(rawData) diff --git a/internal/domains/api/services/processors/jrzq/jrzq2f8a_processor.go b/internal/domains/api/services/processors/jrzq/jrzq2f8a_processor.go index 66e18a2..ad2cb20 100644 --- a/internal/domains/api/services/processors/jrzq/jrzq2f8a_processor.go +++ b/internal/domains/api/services/processors/jrzq/jrzq2f8a_processor.go @@ -43,7 +43,7 @@ func ProcessJRZQ2F8ARequest(ctx context.Context, params []byte, deps *processors rawData, ok := resp.Data.(map[string]interface{}) if !ok { - return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) + return processors.MarshalRawResponse(resp.Data) } result := mapNuoerLoanRiskTagV9ToResponse(rawData) diff --git a/internal/domains/api/services/processors/jrzq/jrzq3c7b_processor.go b/internal/domains/api/services/processors/jrzq/jrzq3c7b_processor.go index 185a9e2..d865ec7 100644 --- a/internal/domains/api/services/processors/jrzq/jrzq3c7b_processor.go +++ b/internal/domains/api/services/processors/jrzq/jrzq3c7b_processor.go @@ -43,7 +43,7 @@ func ProcessJRZQ3C7BRequest(ctx context.Context, params []byte, deps *processors rawData, ok := resp.Data.(map[string]interface{}) if !ok { - return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) + return processors.MarshalRawResponse(resp.Data) } result := mapNuoerApplyLoanToResponse(rawData) diff --git a/internal/domains/api/services/processors/jrzq/jrzq4b6c_processor.go b/internal/domains/api/services/processors/jrzq/jrzq4b6c_processor.go index d7cc13f..1f37526 100644 --- a/internal/domains/api/services/processors/jrzq/jrzq4b6c_processor.go +++ b/internal/domains/api/services/processors/jrzq/jrzq4b6c_processor.go @@ -42,7 +42,7 @@ func ProcessJRZQ4B6CRequest(ctx context.Context, params []byte, deps *processors rawData, ok := resp.Data.(map[string]interface{}) if !ok { - return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) + return processors.MarshalRawResponse(resp.Data) } result := mapNuoerLoanRiskTagV10ToResponse(rawData) diff --git a/internal/domains/api/services/processors/jrzq/jrzq5e9f_processor.go b/internal/domains/api/services/processors/jrzq/jrzq5e9f_processor.go index b7ed42d..10c89bb 100644 --- a/internal/domains/api/services/processors/jrzq/jrzq5e9f_processor.go +++ b/internal/domains/api/services/processors/jrzq/jrzq5e9f_processor.go @@ -43,7 +43,7 @@ func ProcessJRZQ5E9FRequest(ctx context.Context, params []byte, deps *processors rawData, ok := resp.Data.(map[string]interface{}) if !ok { - return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) + return processors.MarshalRawResponse(resp.Data) } result := mapNuoerLoanRiskToResponse(rawData) diff --git a/internal/domains/api/services/processors/jrzq/jrzq6f2a_processor.go b/internal/domains/api/services/processors/jrzq/jrzq6f2a_processor.go index a677d56..ce9c828 100644 --- a/internal/domains/api/services/processors/jrzq/jrzq6f2a_processor.go +++ b/internal/domains/api/services/processors/jrzq/jrzq6f2a_processor.go @@ -55,7 +55,7 @@ func ProcessJRZQ6F2ARequest(ctx context.Context, params []byte, deps *processors respMap, ok := respData.(map[string]interface{}) if !ok { - return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) + return processors.MarshalRawResponse(respData) } result := mapJRZQ3C7BToJRZQ6F2A(respMap) diff --git a/internal/domains/api/services/processors/jrzq/jrzq7f1a_processor.go b/internal/domains/api/services/processors/jrzq/jrzq7f1a_processor.go index cda3f1d..5aa0e64 100644 --- a/internal/domains/api/services/processors/jrzq/jrzq7f1a_processor.go +++ b/internal/domains/api/services/processors/jrzq/jrzq7f1a_processor.go @@ -43,7 +43,7 @@ func ProcessJRZQ7F1ARequest(ctx context.Context, params []byte, deps *processors rawData, ok := resp.Data.(map[string]interface{}) if !ok { - return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) + return processors.MarshalRawResponse(resp.Data) } result := mapNuoerLoanRiskTagV8ToResponse(rawData) diff --git a/internal/domains/api/services/processors/jrzq/jrzq8a2d_processor.go b/internal/domains/api/services/processors/jrzq/jrzq8a2d_processor.go index 943bc8e..c306c92 100644 --- a/internal/domains/api/services/processors/jrzq/jrzq8a2d_processor.go +++ b/internal/domains/api/services/processors/jrzq/jrzq8a2d_processor.go @@ -43,7 +43,7 @@ func ProcessJRZQ8A2DRequest(ctx context.Context, params []byte, deps *processors rawData, ok := resp.Data.(map[string]interface{}) if !ok { - return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) + return processors.MarshalRawResponse(resp.Data) } result := mapNuoerSpecialListToResponse(rawData) diff --git a/internal/domains/api/services/processors/jrzq/jrzq8b3c_processor.go b/internal/domains/api/services/processors/jrzq/jrzq8b3c_processor.go index 1ff5ce1..b98a1bc 100644 --- a/internal/domains/api/services/processors/jrzq/jrzq8b3c_processor.go +++ b/internal/domains/api/services/processors/jrzq/jrzq8b3c_processor.go @@ -43,7 +43,7 @@ func ProcessJRZQ8B3CRequest(ctx context.Context, params []byte, deps *processors rawData, ok := resp.Data.(map[string]interface{}) if !ok { - return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) + return processors.MarshalRawResponse(resp.Data) } result := mapNuoerConsumerTagToResponse(rawData) diff --git a/internal/domains/api/services/processors/jrzq/jrzq9d4e_processor.go b/internal/domains/api/services/processors/jrzq/jrzq9d4e_processor.go index 3a3e7fe..a75526d 100644 --- a/internal/domains/api/services/processors/jrzq/jrzq9d4e_processor.go +++ b/internal/domains/api/services/processors/jrzq/jrzq9d4e_processor.go @@ -43,7 +43,7 @@ func ProcessJRZQ9D4ERequest(ctx context.Context, params []byte, deps *processors rawData, ok := resp.Data.(map[string]interface{}) if !ok { - return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) + return processors.MarshalRawResponse(resp.Data) } result := mapNuoerLoanRiskTagV23ToResponse(rawData) diff --git a/internal/domains/api/services/processors/qygl/qygl5f6a_processor.go b/internal/domains/api/services/processors/qygl/qygl5f6a_processor.go index b5d7f94..a9c4779 100644 --- a/internal/domains/api/services/processors/qygl/qygl5f6a_processor.go +++ b/internal/domains/api/services/processors/qygl/qygl5f6a_processor.go @@ -40,7 +40,7 @@ func ProcessQYGL5F6ARequest(ctx context.Context, params []byte, deps *processors rawData, ok := resp.Data.(map[string]interface{}) if !ok { - return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) + return processors.MarshalRawResponse(resp.Data) } result := mapNuoerIdRelationToEntReportResponse(rawData) diff --git a/internal/domains/api/services/processors/qygl/qygl6f2d_processor.go b/internal/domains/api/services/processors/qygl/qygl6f2d_processor.go index c454828..43e32a7 100644 --- a/internal/domains/api/services/processors/qygl/qygl6f2d_processor.go +++ b/internal/domains/api/services/processors/qygl/qygl6f2d_processor.go @@ -40,7 +40,7 @@ func ProcessQYGL6F2DRequest(ctx context.Context, params []byte, deps *processors rawData, ok := resp.Data.(map[string]interface{}) if !ok { - return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误")) + return processors.MarshalRawResponse(resp.Data) } result := mapNuoerIdRelationToResponse(rawData) diff --git a/internal/domains/api/services/processors/response.go b/internal/domains/api/services/processors/response.go new file mode 100644 index 0000000..bed2050 --- /dev/null +++ b/internal/domains/api/services/processors/response.go @@ -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 +}