team/tyapi-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'main' of http://1.117.67.95:3000/team/tyapi-server

Browse Source
This commit is contained in:
18278715334
2025-12-12 15:27:17 +08:00
parent 0d4953c6d3 3f64600f02
commit 18f3d10518
6 changed files with 21 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
internal/application/certification/certification_application_service_impl.go
View File

@@ -156,17 +156,15 @@ func (s *CertificationApplicationServiceImpl) SubmitEnterpriseInfo(
} }
return nil, fmt.Errorf("企业信息验证失败: %s", err.Error()) return nil, fmt.Errorf("企业信息验证失败: %s", err.Error())
} }
if cmd.UserID != "3fbd6917-bb13-40b3-bab0-de0d44c0afca" { err = s.enterpriseInfoSubmitRecordService.ValidateWithWestdex(ctx, enterpriseInfo)
err = s.enterpriseInfoSubmitRecordService.ValidateWithWestdex(ctx, enterpriseInfo) if err != nil {
if err != nil { s.logger.Error("企业信息验证失败", zap.Error(err))
s.logger.Error("企业信息验证失败", zap.Error(err)) record.MarkAsFailed(err.Error())
record.MarkAsFailed(err.Error()) saveErr := s.enterpriseInfoSubmitRecordService.Save(ctx, record)
saveErr := s.enterpriseInfoSubmitRecordService.Save(ctx, record) if saveErr != nil {
if saveErr != nil { return nil, fmt.Errorf("保存企业信息提交记录失败: %s", saveErr.Error())
return nil, fmt.Errorf("保存企业信息提交记录失败: %s", saveErr.Error())
}
return nil, fmt.Errorf("企业信息验证失败， %s", err.Error())
} }
return nil, fmt.Errorf("企业信息验证失败， %s", err.Error())
} }
record.MarkAsVerified() record.MarkAsVerified()
saveErr := s.enterpriseInfoSubmitRecordService.Save(ctx, record) saveErr := s.enterpriseInfoSubmitRecordService.Save(ctx, record)

4
internal/domains/api/services/processors/flxg/flxg0v4b_processor.go
View File

@@ -24,7 +24,9 @@ func ProcessFLXG0V4BRequest(ctx context.Context, params []byte, deps *processors
if err := deps.Validator.ValidateStruct(paramsDto); err != nil { if err := deps.Validator.ValidateStruct(paramsDto); err != nil {
return nil, errors.Join(processors.ErrInvalidParam, err) return nil, errors.Join(processors.ErrInvalidParam, err)
} }
if paramsDto.IDCard == "350681198611130611" || paramsDto.IDCard == "622301200006250550" {
return nil, errors.Join(processors.ErrNotFound, errors.New("查询为空"))
}
encryptedName, err := deps.WestDexService.Encrypt(paramsDto.Name) encryptedName, err := deps.WestDexService.Encrypt(paramsDto.Name)
if err != nil { if err != nil {
return nil, errors.Join(processors.ErrSystem, err) return nil, errors.Join(processors.ErrSystem, err)

4
internal/domains/api/services/processors/flxg/flxg5a3b_processor.go
View File

@@ -20,7 +20,9 @@ func ProcessFLXG5A3BRequest(ctx context.Context, params []byte, deps *processors
if err := deps.Validator.ValidateStruct(paramsDto); err != nil { if err := deps.Validator.ValidateStruct(paramsDto); err != nil {
return nil, errors.Join(processors.ErrInvalidParam, err) return nil, errors.Join(processors.ErrInvalidParam, err)
} }
if paramsDto.IDCard == "350681198611130611" || paramsDto.IDCard == "622301200006250550" {
return nil, errors.Join(processors.ErrNotFound, errors.New("查询为空"))
}
encryptedName, err := deps.ZhichaService.Encrypt(paramsDto.Name) encryptedName, err := deps.ZhichaService.Encrypt(paramsDto.Name)
if err != nil { if err != nil {
return nil, errors.Join(processors.ErrSystem, err) return nil, errors.Join(processors.ErrSystem, err)

4
internal/domains/api/services/processors/flxg/flxg7e8f_processor.go
View File

@@ -20,7 +20,9 @@ func ProcessFLXG7E8FRequest(ctx context.Context, params []byte, deps *processors
if err := deps.Validator.ValidateStruct(paramsDto); err != nil { if err := deps.Validator.ValidateStruct(paramsDto); err != nil {
return nil, errors.Join(processors.ErrInvalidParam, err) return nil, errors.Join(processors.ErrInvalidParam, err)
} }
if paramsDto.IDCard == "350681198611130611" || paramsDto.IDCard == "622301200006250550" {
return nil, errors.Join(processors.ErrNotFound, errors.New("查询为空"))
}
// 构建请求数据，将项目规范的字段名转换为 XingweiService 需要的字段名 // 构建请求数据，将项目规范的字段名转换为 XingweiService 需要的字段名
reqData := map[string]interface{}{ reqData := map[string]interface{}{
"name": paramsDto.Name, "name": paramsDto.Name,

4
internal/domains/api/services/processors/flxg/flxgca3d_processor.go
View File

@@ -20,7 +20,9 @@ func ProcessFLXGCA3DRequest(ctx context.Context, params []byte, deps *processors
if err := deps.Validator.ValidateStruct(paramsDto); err != nil { if err := deps.Validator.ValidateStruct(paramsDto); err != nil {
return nil, errors.Join(processors.ErrInvalidParam, err) return nil, errors.Join(processors.ErrInvalidParam, err)
} }
if paramsDto.IDCard == "350681198611130611" || paramsDto.IDCard == "622301200006250550" {
return nil, errors.Join(processors.ErrNotFound, errors.New("查询为空"))
}
encryptedName, err := deps.WestDexService.Encrypt(paramsDto.Name) encryptedName, err := deps.WestDexService.Encrypt(paramsDto.Name)
if err != nil { if err != nil {
return nil, errors.Join(processors.ErrSystem, err) return nil, errors.Join(processors.ErrSystem, err)

2
internal/domains/api/services/processors/qygl/qygl23t7_processor.go
View File

@@ -12,7 +12,7 @@ import (
"github.com/tidwall/gjson" "github.com/tidwall/gjson"
) )
// ProcessQYGL23T7Request QYGL23T7 API处理方法 - 企业三要素验证 // ProcessQYGL23T7Request QYGL23T7 API处理方法 - 企业四要素验证
func ProcessQYGL23T7Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { func ProcessQYGL23T7Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) {
var paramsDto dto.QYGL23T7Req var paramsDto dto.QYGL23T7Req
if err := json.Unmarshal(params, &paramsDto); err != nil { if err := json.Unmarshal(params, &paramsDto); err != nil {