From a2cdeffb0c3f3debe6c0f877e158e7c7cd3c9d07 Mon Sep 17 00:00:00 2001 From: Mrx <18278715334@163.com> Date: Wed, 3 Jun 2026 14:15:48 +0800 Subject: [PATCH] f --- .../processors/ivyz/ivyzvjj6_processor.go | 4 +- .../processors/jrzq/jrzqv3hm_processor.go | 2 +- .../processors/nuoer/flxgg0s4_processor.go | 49 ------------------ .../processors/nuoer/ivyzv1o6_processor.go | 49 ------------------ .../processors/nuoer/ivyzvjj6_processor.go | 50 ------------------ .../processors/nuoer/ivyzvxf6_processor.go | 50 ------------------ .../processors/nuoer/jrzqbhz4_processor.go | 50 ------------------ .../processors/nuoer/jrzqv07t_processor.go | 50 ------------------ .../processors/nuoer/jrzqv0md_processor.go | 50 ------------------ .../processors/nuoer/jrzqv1o0_processor.go | 50 ------------------ .../processors/nuoer/jrzqv2o1_processor.go | 50 ------------------ .../processors/nuoer/jrzqv3hm_processor.go | 49 ------------------ .../processors/nuoer/jrzqv4tf_processor.go | 51 ------------------- .../processors/nuoer/jrzqv5f4_processor.go | 50 ------------------ .../processors/nuoer/jrzqv7d1_processor.go | 50 ------------------ .../processors/nuoer/jrzqv7md_processor.go | 50 ------------------ .../processors/nuoer/jrzqv87m_processor.go | 50 ------------------ .../processors/nuoer/jrzqv8v8_processor.go | 50 ------------------ .../processors/nuoer/jrzqv9v9_processor.go | 50 ------------------ .../processors/nuoer/jrzqvkk6_processor.go | 51 ------------------- .../processors/nuoer/jrzqvt43_processor.go | 48 ----------------- .../processors/nuoer/jrzqvz2y_processor.go | 50 ------------------ .../processors/nuoer/jrzqvz3y_processor.go | 50 ------------------ .../processors/nuoer/jrzqvztf_processor.go | 51 ------------------- .../processors/nuoer/jrzqvzxf_processor.go | 51 ------------------- .../processors/nuoer/qcxgm4cl_processor.go | 48 ----------------- .../processors/nuoer/qyglv4s6_processor.go | 50 ------------------ .../processors/nuoer/qyglvr76_processor.go | 48 ----------------- 28 files changed, 3 insertions(+), 1298 deletions(-) delete mode 100644 internal/domains/api/services/processors/nuoer/flxgg0s4_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/ivyzv1o6_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/ivyzvjj6_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/ivyzvxf6_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqbhz4_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqv07t_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqv0md_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqv1o0_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqv2o1_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqv3hm_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqv4tf_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqv5f4_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqv7d1_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqv7md_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqv87m_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqv8v8_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqv9v9_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqvkk6_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqvt43_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqvz2y_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqvz3y_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqvztf_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/jrzqvzxf_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/qcxgm4cl_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/qyglv4s6_processor.go delete mode 100644 internal/domains/api/services/processors/nuoer/qyglvr76_processor.go diff --git a/internal/domains/api/services/processors/ivyz/ivyzvjj6_processor.go b/internal/domains/api/services/processors/ivyz/ivyzvjj6_processor.go index 3edc90a..c5f8949 100644 --- a/internal/domains/api/services/processors/ivyz/ivyzvjj6_processor.go +++ b/internal/domains/api/services/processors/ivyz/ivyzvjj6_processor.go @@ -10,7 +10,7 @@ import ( "hyapi-server/internal/infrastructure/external/nuoer" ) -// ProcessIVYZVJJ6Request IVYZVJJ6 API处理方法 -收入等级 +// ProcessIVYZVJJ6Request IVYZVJJ6 API处理方法 -收入等级tax_income_level_v8 func ProcessIVYZVJJ6Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { var paramsDto dto.IVYZVJJ6Req if err := json.Unmarshal(params, ¶msDto); err != nil { @@ -27,7 +27,7 @@ func ProcessIVYZVJJ6Request(ctx context.Context, params []byte, deps *processors "mobile": paramsDto.MobileNo, } - nuoerDoCheckAPIKey := "tax_income_level_v2" + nuoerDoCheckAPIKey := "tax_income_level_v8" ApiPath := "/v1/doCheck" resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) diff --git a/internal/domains/api/services/processors/jrzq/jrzqv3hm_processor.go b/internal/domains/api/services/processors/jrzq/jrzqv3hm_processor.go index 7add1fe..8be4aad 100644 --- a/internal/domains/api/services/processors/jrzq/jrzqv3hm_processor.go +++ b/internal/domains/api/services/processors/jrzq/jrzqv3hm_processor.go @@ -26,7 +26,7 @@ func ProcessJRZQV3HMRequest(ctx context.Context, params []byte, deps *processors "mobile": paramsDto.MobileNo, } - nuoerDoCheckAPIKey := "loanRiskTagV12" + nuoerDoCheckAPIKey := "blackListV121_3_1" ApiPath := "/v1/doCheck" resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) diff --git a/internal/domains/api/services/processors/nuoer/flxgg0s4_processor.go b/internal/domains/api/services/processors/nuoer/flxgg0s4_processor.go deleted file mode 100644 index 978e9dd..0000000 --- a/internal/domains/api/services/processors/nuoer/flxgg0s4_processor.go +++ /dev/null @@ -1,49 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessFLXGG0S4Request FLXGG0S4 API处理方法 - 个人诉讼定制版 -func ProcessFLXGG0S4Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.FLXGG0S4Req - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - } - - nuoerDoCheckAPIKey := "personalLawsuit_cv1" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/ivyzv1o6_processor.go b/internal/domains/api/services/processors/nuoer/ivyzv1o6_processor.go deleted file mode 100644 index 3ce1ced..0000000 --- a/internal/domains/api/services/processors/nuoer/ivyzv1o6_processor.go +++ /dev/null @@ -1,49 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessIVYZV1O6Request IVYZV1O6 API处理方法 -身份风险V106 -func ProcessIVYZV1O6Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.IVYZV1O6Req - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - } - - nuoerDoCheckAPIKey := "idRiskTagV106" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/ivyzvjj6_processor.go b/internal/domains/api/services/processors/nuoer/ivyzvjj6_processor.go deleted file mode 100644 index 747dda3..0000000 --- a/internal/domains/api/services/processors/nuoer/ivyzvjj6_processor.go +++ /dev/null @@ -1,50 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessIVYZVJJ6Request IVYZVJJ6 API处理方法 -收入等级 -func ProcessIVYZVJJ6Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.IVYZVJJ6Req - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "tax_income_level_v2" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/ivyzvxf6_processor.go b/internal/domains/api/services/processors/nuoer/ivyzvxf6_processor.go deleted file mode 100644 index 6e7d979..0000000 --- a/internal/domains/api/services/processors/nuoer/ivyzvxf6_processor.go +++ /dev/null @@ -1,50 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessIVYZVXF6Request IVYZVXF6 API处理方法 -消费能力 -func ProcessIVYZVXF6Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.IVYZVXF6Req - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "consumerTagV1" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqbhz4_processor.go b/internal/domains/api/services/processors/nuoer/jrzqbhz4_processor.go deleted file mode 100644 index 003e335..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqbhz4_processor.go +++ /dev/null @@ -1,50 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQBHZ4Request JRZQBHZ4 API处理方法 - 支付行为指数博汇 -func ProcessJRZQBHZ4Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQBHZ4Req - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "paymentTagS26" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqv07t_processor.go b/internal/domains/api/services/processors/nuoer/jrzqv07t_processor.go deleted file mode 100644 index 366a0fb..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqv07t_processor.go +++ /dev/null @@ -1,50 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQV07TRequest JRZQV07T API处理方法 - 洞侦多头履约行为 -func ProcessJRZQV07TRequest(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQV07TReq - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "loanRiskTagV23" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqv0md_processor.go b/internal/domains/api/services/processors/nuoer/jrzqv0md_processor.go deleted file mode 100644 index 55fe834..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqv0md_processor.go +++ /dev/null @@ -1,50 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQV0MDRequest JRZQV0MDRequest API处理方法 - 特殊名单 -func ProcessJRZQV0MDRequest(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQV0MDReq - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "blackListV110" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqv1o0_processor.go b/internal/domains/api/services/processors/nuoer/jrzqv1o0_processor.go deleted file mode 100644 index fac1ea4..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqv1o0_processor.go +++ /dev/null @@ -1,50 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQV1O0Request JRZQV1O0 API处理方法 - 风险量级V10 -func ProcessJRZQV1O0Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQV1O0Req - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "loanRiskTagV10" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqv2o1_processor.go b/internal/domains/api/services/processors/nuoer/jrzqv2o1_processor.go deleted file mode 100644 index 87f9ac0..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqv2o1_processor.go +++ /dev/null @@ -1,50 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQV2O1Request JRZQV2O1 API处理方法 - 信用全景V21 -func ProcessJRZQV2O1Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQV2O1Req - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "loanRiskTagV21" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqv3hm_processor.go b/internal/domains/api/services/processors/nuoer/jrzqv3hm_processor.go deleted file mode 100644 index 2a99bac..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqv3hm_processor.go +++ /dev/null @@ -1,49 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQV3HMRequest JRZQV3HM API处理方法 - 债务逾期黑名单V3_1 -func ProcessJRZQV3HMRequest(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQV3HMReq - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "loanRiskTagV12" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqv4tf_processor.go b/internal/domains/api/services/processors/nuoer/jrzqv4tf_processor.go deleted file mode 100644 index 04a7df6..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqv4tf_processor.go +++ /dev/null @@ -1,51 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQV4TFRequest JRZQV4TFRequest API处理方法 - 智瞳分尊享版 - -func ProcessJRZQV4TFRequest(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQV4TFReq - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "zhitong_ultra_v4_score" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqv5f4_processor.go b/internal/domains/api/services/processors/nuoer/jrzqv5f4_processor.go deleted file mode 100644 index 8338aa0..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqv5f4_processor.go +++ /dev/null @@ -1,50 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQV5F4Request JRZQV5F4 API处理方法 - 风险变量V5F4 -func ProcessJRZQV5F4Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQV5F4Req - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "loanRiskTagV5" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqv7d1_processor.go b/internal/domains/api/services/processors/nuoer/jrzqv7d1_processor.go deleted file mode 100644 index ae1a2e8..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqv7d1_processor.go +++ /dev/null @@ -1,50 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQV7D1Request JRZQV7D1 API处理方法 - 借贷意向验证 -func ProcessJRZQV7D1Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQV7D1Req - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "loanRiskTagV11" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqv7md_processor.go b/internal/domains/api/services/processors/nuoer/jrzqv7md_processor.go deleted file mode 100644 index 25ccaa8..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqv7md_processor.go +++ /dev/null @@ -1,50 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQVZ3YRequest JRZQVZ3Y API处理方法 - 特殊名单 -func ProcessJRZQV7MDRequest(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQV7MDReq - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "loanRiskTagV12" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqv87m_processor.go b/internal/domains/api/services/processors/nuoer/jrzqv87m_processor.go deleted file mode 100644 index a8f9262..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqv87m_processor.go +++ /dev/null @@ -1,50 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQV87MReqest JRZQV87MReq API处理方法 - 黑名单V110_c10 -func ProcessJRZQV87MReqest(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQV87MReq - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "blackListV110_c10" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqv8v8_processor.go b/internal/domains/api/services/processors/nuoer/jrzqv8v8_processor.go deleted file mode 100644 index 1c7ef4b..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqv8v8_processor.go +++ /dev/null @@ -1,50 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQV8V8Request JRZQV8V8 API处理方法 - 风险量级V8 -func ProcessJRZQV8V8Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQV8V8Req - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "loanRiskTagV8" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqv9v9_processor.go b/internal/domains/api/services/processors/nuoer/jrzqv9v9_processor.go deleted file mode 100644 index 13a5912..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqv9v9_processor.go +++ /dev/null @@ -1,50 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQV9V9Request JRZQV9V9 API处理方法 - 风险量级V9 -func ProcessJRZQV9V9Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQV9V9Req - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "loanRiskTagV9" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqvkk6_processor.go b/internal/domains/api/services/processors/nuoer/jrzqvkk6_processor.go deleted file mode 100644 index 023c3f7..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqvkk6_processor.go +++ /dev/null @@ -1,51 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQVKK6Request JRZQVKK6Request API处理方法 - 坤羽模型V3-标签版 - -func ProcessJRZQVKK6Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQVKK6Req - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "kunyu_fix_v3_tg_model" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqvt43_processor.go b/internal/domains/api/services/processors/nuoer/jrzqvt43_processor.go deleted file mode 100644 index 8c88ad7..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqvt43_processor.go +++ /dev/null @@ -1,48 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQVT43Request JRZQVT43 API处理方法 - 投诉风险筛查V709 -func ProcessJRZQVT43Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQVT43Req - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "mobileRiskV709" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqvz2y_processor.go b/internal/domains/api/services/processors/nuoer/jrzqvz2y_processor.go deleted file mode 100644 index 30a5749..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqvz2y_processor.go +++ /dev/null @@ -1,50 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQVZ2YRequest JRZQVZ2Y API处理方法 - 借贷申请意向V22 -func ProcessJRZQVZ2YRequest(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQVZ2YReq - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "loanRiskTagV22" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqvz3y_processor.go b/internal/domains/api/services/processors/nuoer/jrzqvz3y_processor.go deleted file mode 100644 index a9bd6f4..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqvz3y_processor.go +++ /dev/null @@ -1,50 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQVZ3YRequest JRZQVZ3Y API处理方法 - 租赁申请意向 -func ProcessJRZQVZ3YRequest(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQVZ3YReq - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "loanRiskTagV18" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqvztf_processor.go b/internal/domains/api/services/processors/nuoer/jrzqvztf_processor.go deleted file mode 100644 index 23f2bfd..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqvztf_processor.go +++ /dev/null @@ -1,51 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQVZTFRequest JRZQVZTFRequest API处理方法 - 智瞳-通用版 - -func ProcessJRZQVZTFRequest(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQVZTFReq - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "zhiTongModelG" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/jrzqvzxf_processor.go b/internal/domains/api/services/processors/nuoer/jrzqvzxf_processor.go deleted file mode 100644 index b345469..0000000 --- a/internal/domains/api/services/processors/nuoer/jrzqvzxf_processor.go +++ /dev/null @@ -1,51 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessJRZQVZXFRequest JRZQVZXFRequest API处理方法 - 智享分 - -func ProcessJRZQVZXFRequest(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.JRZQVZXFReq - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "name": paramsDto.Name, - "idCard": paramsDto.IDCard, - "mobile": paramsDto.MobileNo, - } - - nuoerDoCheckAPIKey := "zhixiangScore" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/qcxgm4cl_processor.go b/internal/domains/api/services/processors/nuoer/qcxgm4cl_processor.go deleted file mode 100644 index b339f4a..0000000 --- a/internal/domains/api/services/processors/nuoer/qcxgm4cl_processor.go +++ /dev/null @@ -1,48 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessQCXGM4CLRequest QCXGM4CL API处理方法 - 名下车辆诺尔 -func ProcessQCXGM4CLRequest(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.QCXGM4CLReq - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "idCard": paramsDto.IDCard, - } - - nuoerDoCheckAPIKey := "id_vehicle_query_102" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/qyglv4s6_processor.go b/internal/domains/api/services/processors/nuoer/qyglv4s6_processor.go deleted file mode 100644 index 071677b..0000000 --- a/internal/domains/api/services/processors/nuoer/qyglv4s6_processor.go +++ /dev/null @@ -1,50 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessQYGLV4S6Request QYGLV4S6 API处理方法 -企业诉讼定制版 - -func ProcessQYGLV4S6Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.QYGLV4S6Req - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "entCode": paramsDto.EntCode, - "entName": paramsDto.EntName, - } - - nuoerDoCheckAPIKey := "personalLawsuit_cv2" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -} diff --git a/internal/domains/api/services/processors/nuoer/qyglvr76_processor.go b/internal/domains/api/services/processors/nuoer/qyglvr76_processor.go deleted file mode 100644 index 59f143f..0000000 --- a/internal/domains/api/services/processors/nuoer/qyglvr76_processor.go +++ /dev/null @@ -1,48 +0,0 @@ -package nuoer - -import ( - "context" - "encoding/json" - "errors" - - "hyapi-server/internal/domains/api/dto" - "hyapi-server/internal/domains/api/services/processors" - nuoerext "hyapi-server/internal/infrastructure/external/nuoer" -) - -// ProcessQYGLVR76Request QYGLVR76 API处理方法 -人企关联 -func ProcessQYGLVR76Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.QYGLVR76Req - if err := json.Unmarshal(params, ¶msDto); err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - if err := deps.Validator.ValidateStruct(paramsDto); err != nil { - return nil, errors.Join(processors.ErrInvalidParam, err) - } - - body := map[string]string{ - "idCard": paramsDto.IDCard, - } - - nuoerDoCheckAPIKey := "idRelationV101" - ApiPath := "/v1/doCheck" - - resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body) - if err != nil { - if errors.Is(err, nuoerext.ErrDatasource) { - return nil, errors.Join(processors.ErrDatasource, err) - } - if errors.Is(err, nuoerext.ErrNotFound) { - return nil, errors.Join(processors.ErrNotFound, err) - } - return nil, errors.Join(processors.ErrSystem, err) - } - - respBytes, err := json.Marshal(resp.Data) - if err != nil { - return nil, errors.Join(processors.ErrSystem, err) - } - - return respBytes, nil -}