From 88787c61459abe804d16ed4a2e349212beb3bfad Mon Sep 17 00:00:00 2001 From: liangzai <2440983361@qq.com> Date: Thu, 29 Jan 2026 15:25:30 +0800 Subject: [PATCH] f --- internal/domains/api/dto/pdfg_dto.go | 1 - .../processors/pdfg/pdfg01gz_processor.go | 31 +++++++------------ 2 files changed, 12 insertions(+), 20 deletions(-) diff --git a/internal/domains/api/dto/pdfg_dto.go b/internal/domains/api/dto/pdfg_dto.go index a351c70..8d97b4e 100644 --- a/internal/domains/api/dto/pdfg_dto.go +++ b/internal/domains/api/dto/pdfg_dto.go @@ -5,7 +5,6 @@ type PDFG01GZReq 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"` - AuthAuthorizeFileCode string `json:"auth_authorize_file_code" validate:"required"` // IVYZ5A9O需要 Authorized string `json:"authorized" validate:"required,oneof=0 1"` // 授权标识,0或1 } diff --git a/internal/domains/api/services/processors/pdfg/pdfg01gz_processor.go b/internal/domains/api/services/processors/pdfg/pdfg01gz_processor.go index b287a8f..8ca35d7 100644 --- a/internal/domains/api/services/processors/pdfg/pdfg01gz_processor.go +++ b/internal/domains/api/services/processors/pdfg/pdfg01gz_processor.go @@ -37,7 +37,6 @@ func ProcessPDFG01GZRequest(ctx context.Context, params []byte, deps *processors zap.String("id_card", paramsDto.IDCard), zap.String("mobile_no", paramsDto.MobileNo), zap.String("authorized", paramsDto.Authorized), - zap.String("auth_authorize_file_code", paramsDto.AuthAuthorizeFileCode), ) // 从context获取config(如果存在) @@ -219,35 +218,29 @@ func collectAPIData(ctx context.Context, params dto.PDFG01GZReq, deps *processor results := make(chan processorResult, 5) - // 调用IVYZ5A9O - 需要: name, id_card, auth_authorize_file_code + // 调用JRZQ0L85 - 需要: name, id_card, mobile_no go func() { defer func() { if r := recover(); r != nil { - logger.Error("调用IVYZ5A9O处理器时发生panic", + logger.Error("调用JRZQ0L85处理器时发生panic", zap.Any("panic", r), ) - results <- processorResult{"IVYZ5A9O", nil, fmt.Errorf("处理器panic: %v", r)} + results <- processorResult{"JRZQ0L85", nil, fmt.Errorf("处理器panic: %v", r)} } }() - // 检查必需字段 - if params.AuthAuthorizeFileCode == "" { - logger.Warn("IVYZ5A9O缺少auth_authorize_file_code字段,跳过调用") - results <- processorResult{"IVYZ5A9O", nil, fmt.Errorf("缺少必需字段: auth_authorize_file_code")} - return + jrzq0l85Params := map[string]interface{}{ + "name": params.Name, + "id_card": params.IDCard, + "mobileNo": params.MobileNo, } - ivyzParams := map[string]interface{}{ - "name": params.Name, - "id_card": params.IDCard, - "auth_authorize_file_code": params.AuthAuthorizeFileCode, - } - paramsBytes, err := json.Marshal(ivyzParams) + paramsBytes, err := json.Marshal(jrzq0l85Params) if err != nil { - logger.Warn("序列化IVYZ5A9O参数失败", zap.Error(err)) - results <- processorResult{"IVYZ5A9O", nil, err} + logger.Warn("序列化JRZQ0L85参数失败", zap.Error(err)) + results <- processorResult{"JRZQ0L85", nil, err} return } - data, err := callProcessor(ctx, "IVYZ5A9O", paramsBytes, deps) - results <- processorResult{"IVYZ5A9O", data, err} + data, err := callProcessor(ctx, "JRZQ0L85", paramsBytes, deps) + results <- processorResult{"JRZQ0L85", data, err} }() // 调用JRZQ8A2D - 需要: name, id_card, mobile_no, authorized