diff --git a/internal/domains/api/services/processors/qygl/qygl5s1i_processor.go b/internal/domains/api/services/processors/qygl/qygl5s1i_processor.go index f8d1094..4e1cf04 100644 --- a/internal/domains/api/services/processors/qygl/qygl5s1i_processor.go +++ b/internal/domains/api/services/processors/qygl/qygl5s1i_processor.go @@ -21,24 +21,23 @@ func ProcessQYGL5S1IRequest(ctx context.Context, params []byte, deps *processors if err := deps.Validator.ValidateStruct(paramsDto); err != nil { return nil, errors.Join(processors.ErrInvalidParam, err) } - if paramsDto.EntCode == "" && paramsDto.EntName == "" { - return nil, errors.Join(processors.ErrInvalidParam, errors.New("必须提供企业统一信用代码或企业名称中的一个")) + + encryptedEntName, err := deps.ZhichaService.Encrypt(paramsDto.EntName) + if err != nil { + return nil, errors.Join(processors.ErrSystem, err) + } + encryptedEntCode, err := deps.ZhichaService.Encrypt(paramsDto.EntCode) + if err != nil { + return nil, errors.Join(processors.ErrSystem, err) } - // 优先使用企业名称,否则使用统一信用代码 - var enterpriseNo, enterpriseName string + // 按企业名称时传 enterpriseNo(加密名),按统一信用代码时传 enterpriseName(加密代码) + reqData := map[string]interface{}{} if paramsDto.EntName != "" { - enterpriseName = paramsDto.EntName + reqData["enterpriseNo"] = encryptedEntName } if paramsDto.EntCode != "" { - enterpriseNo = paramsDto.EntCode - } else { - enterpriseNo = "not null" - } - - reqData := map[string]interface{}{ - "enterpriseNo": enterpriseNo, - "enterpriseName": enterpriseName, + reqData["enterpriseName"] = encryptedEntCode } respData, err := deps.ZhichaService.CallAPI(ctx, "ZCI088", reqData)