From b935c557b9af5f5ca060b96e1cc67f2e7838a8ea Mon Sep 17 00:00:00 2001 From: liangzai <2440983361@qq.com> Date: Fri, 24 Jul 2026 12:05:52 +0800 Subject: [PATCH] f --- .../product_application_service_impl.go | 1 + internal/domains/api/dto/api_request_dto.go | 7 +++ .../api/services/api_request_service.go | 1 + .../api/services/form_config_service.go | 1 + .../processors/jrzq/jrzq0oo1_processor.go | 46 +++++++++++++++++++ 5 files changed, 56 insertions(+) create mode 100644 internal/domains/api/services/processors/jrzq/jrzq0oo1_processor.go diff --git a/internal/application/product/product_application_service_impl.go b/internal/application/product/product_application_service_impl.go index c81f474..ec09550 100644 --- a/internal/application/product/product_application_service_impl.go +++ b/internal/application/product/product_application_service_impl.go @@ -1169,6 +1169,7 @@ func (s *ProductApplicationServiceImpl) getDTOMap() map[string]interface{} { "JRZQK9P2": &dto.JRZQK9P2Req{}, //洞侦1.0(海宇) "JRZQR4N7": &dto.JRZQR4N7Req{}, //借贷意向验证3.0(海宇) "JRZQP8D2": &dto.JRZQP8D2Req{}, //全景雷达BH(海宇) + "JRZQ0OO1": &dto.JRZQ0OO1Req{}, //戎行贷后信息 Info360(海宇) } } diff --git a/internal/domains/api/dto/api_request_dto.go b/internal/domains/api/dto/api_request_dto.go index 4a39452..f9c43ce 100644 --- a/internal/domains/api/dto/api_request_dto.go +++ b/internal/domains/api/dto/api_request_dto.go @@ -131,6 +131,13 @@ type JRZQP8D2Req struct { IDCard string `json:"id_card" validate:"required,validIDCard"` MobileNo string `json:"mobile_no" validate:"required,min=11,max=11,validMobileNo"` } + +// JRZQ0OO1Req 戎行贷后信息 Info360(转发海宇 JRZQ0OO1) +type JRZQ0OO1Req struct { + Name string `json:"name" validate:"required,min=1,validName"` + IDCard string `json:"id_card" validate:"required,validIDCard"` + MobileNo string `json:"mobile_no" validate:"required,min=11,max=11,validMobileNo"` +} type JRZQT57ZReq struct { MobileNo string `json:"mobile_no" validate:"required,min=11,max=11,validMobileNo"` IDCard string `json:"id_card" validate:"required,validIDCard"` diff --git a/internal/domains/api/services/api_request_service.go b/internal/domains/api/services/api_request_service.go index c2e9858..e5acd84 100644 --- a/internal/domains/api/services/api_request_service.go +++ b/internal/domains/api/services/api_request_service.go @@ -243,6 +243,7 @@ func registerAllProcessors(combService *comb.CombService) { "JRZQK9P2": jrzq.ProcessJRZQK9P2Request, // 洞侦1.0(海宇,查空计费) "JRZQR4N7": jrzq.ProcessJRZQR4N7Request, // 借贷意向验证3.0(海宇,查空计费) "JRZQP8D2": jrzq.ProcessJRZQP8D2Request, // 全景雷达BH(海宇,查空不计费) + "JRZQ0OO1": jrzq.ProcessJRZQ0OO1Request, // 戎行贷后信息 Info360(海宇) // QYGL系列处理器 "QYGL8261": qygl.ProcessQYGL8261Request, diff --git a/internal/domains/api/services/form_config_service.go b/internal/domains/api/services/form_config_service.go index dfccb3d..06b2448 100644 --- a/internal/domains/api/services/form_config_service.go +++ b/internal/domains/api/services/form_config_service.go @@ -345,6 +345,7 @@ func (s *FormConfigServiceImpl) getDTOStruct(ctx context.Context, apiCode string "JRZQK9P2": &dto.JRZQK9P2Req{}, //洞侦1.0(海宇,查空计费) "JRZQR4N7": &dto.JRZQR4N7Req{}, //借贷意向验证3.0(海宇,查空计费) "JRZQP8D2": &dto.JRZQP8D2Req{}, //全景雷达BH(海宇,查空不计费) + "JRZQ0OO1": &dto.JRZQ0OO1Req{}, //戎行贷后信息 Info360(海宇) "IVYZX7J9": &dto.IVYZX7J9Req{}, //学历核验政务 "IVYZFC59": &dto.IVYZFC59Req{}, //房产核验 "IVYZGJ99": &dto.IVYZGJ99Req{}, //公积金核验 diff --git a/internal/domains/api/services/processors/jrzq/jrzq0oo1_processor.go b/internal/domains/api/services/processors/jrzq/jrzq0oo1_processor.go new file mode 100644 index 0000000..fa0cc47 --- /dev/null +++ b/internal/domains/api/services/processors/jrzq/jrzq0oo1_processor.go @@ -0,0 +1,46 @@ +package jrzq + +import ( + "context" + "encoding/json" + "errors" + + "tyapi-server/internal/domains/api/dto" + "tyapi-server/internal/domains/api/services/processors" + "tyapi-server/internal/infrastructure/external/haiyuapi" +) + +// ProcessJRZQ0OO1Request JRZQ0OO1 API处理方法 - 戎行贷后信息 Info360(转发海宇 JRZQ0OO1) +func ProcessJRZQ0OO1Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { + var paramsDto dto.JRZQ0OO1Req + 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) + } + + if deps.HaiyuapiService == nil { + return nil, errors.Join(processors.ErrSystem, errors.New("海宇API服务未初始化")) + } + + reqParams := map[string]interface{}{ + "name": paramsDto.Name, + "id_card": paramsDto.IDCard, + "mobile_no": paramsDto.MobileNo, + } + + respBytes, err := deps.HaiyuapiService.CallAPI(ctx, "JRZQ0OO1", reqParams) + if err != nil { + if errors.Is(err, haiyuapi.ErrNotFound) { + return nil, errors.Join(processors.ErrNotFound, err) + } + if errors.Is(err, haiyuapi.ErrDatasource) { + return nil, errors.Join(processors.ErrDatasource, err) + } + return nil, errors.Join(processors.ErrSystem, err) + } + + return respBytes, nil +}