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

fix enterprise validate

Browse Source
This commit is contained in:
liangzai
2025-07-28 21:25:59 +08:00
parent deaf4f1614
commit 722a29e52c
2 changed files with 19 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
internal/domains/api/services/processors/qygl/qygl45bd_processor.go
View File

@@ -54,6 +54,9 @@ func ProcessQYGL45BDRequest(ctx context.Context, params []byte, deps *processors
respBytes, err := deps.WestDexService.CallAPI("WEST00021", reqData) respBytes, err := deps.WestDexService.CallAPI("WEST00021", reqData)
if err != nil { if err != nil {
if errors.Is(err, westdex.ErrDatasource) { if errors.Is(err, westdex.ErrDatasource) {
if respBytes != nil {
return respBytes,nil
}
return nil, fmt.Errorf("%s: %w", processors.ErrDatasource, err) return nil, fmt.Errorf("%s: %w", processors.ErrDatasource, err)
} else { } else {
return nil, fmt.Errorf("%s: %w", processors.ErrSystem, err) return nil, fmt.Errorf("%s: %w", processors.ErrSystem, err)

26
internal/domains/certification/services/enterprise_info_submit_record_service.go
View File

@@ -58,12 +58,12 @@ func (s *EnterpriseInfoSubmitRecordService) ValidateWithWestdex(ctx context.Cont
} }
// 开发环境下跳过外部验证 // 开发环境下跳过外部验证
if s.appConfig.IsDevelopment() { // if s.appConfig.IsDevelopment() {
s.logger.Info("开发环境：跳过企业信息外部验证", // s.logger.Info("开发环境：跳过企业信息外部验证",
zap.String("company_name", info.CompanyName), // zap.String("company_name", info.CompanyName),
zap.String("legal_person", info.LegalPersonName)) // zap.String("legal_person", info.LegalPersonName))
return nil // return nil
} // }
encryptedEntName, err := s.westdexService.Encrypt(info.CompanyName) encryptedEntName, err := s.westdexService.Encrypt(info.CompanyName)
if err != nil { if err != nil {
return fmt.Errorf("%s: %w", "企业四要素验证", err) return fmt.Errorf("%s: %w", "企业四要素验证", err)
@@ -92,14 +92,20 @@ func (s *EnterpriseInfoSubmitRecordService) ValidateWithWestdex(ctx context.Cont
"idcard": encryptedIDCard, "idcard": encryptedIDCard,
}, },
} }
var respData []byte
resp, err := s.westdexService.CallAPI("WEST00021", reqParams) resp, err := s.westdexService.CallAPI("WEST00021", reqParams)
if err != nil { if err != nil {
return err if errors.Is(err, westdex.ErrDatasource) && resp != nil {
respData = resp
} else {
return err
}
} }
s.logger.Info("验证企业四要素响应", zap.Any("response", resp)) respData = resp
resultState := gjson.GetBytes(resp, "result.state") s.logger.Info("验证企业四要素响应", zap.Any("response", respData))
resultState := gjson.GetBytes(respData, "result.state")
if !resultState.Exists() { if !resultState.Exists() {
return fmt.Errorf("校验企业信息错误") return fmt.Errorf("企业信息不一致")
} }
if resultState.Int() != 1 { if resultState.Int() != 1 {
return fmt.Errorf("企业信息不一致") return fmt.Errorf("企业信息不一致")