f 去掉66sl

This commit is contained in:
Mrx
2026-01-28 15:55:38 +08:00
parent b1f573c230
commit b2f0b47896
2 changed files with 30 additions and 30 deletions

View File

@@ -454,37 +454,37 @@ func enrichCompaniesWithDetails(ctx context.Context, companies []CompanyInfo, id
}() }()
// 调用QYGL66SL- 企业涉诉信息 // 调用QYGL66SL- 企业涉诉信息
detailWg.Add(1) // detailWg.Add(1)
go func() { // go func() {
defer detailWg.Done() // defer detailWg.Done()
result := callQYGL66SLProcessorSafely(ctx, comp.CreditCode, comp.Name, deps) // result := callQYGL66SLProcessorSafely(ctx, comp.CreditCode, comp.Name, deps)
enriched.LawsuitInfo = result // enriched.LawsuitInfo = result
// QYGL66SL返回的是特殊格式需要检查是否有数据 // // QYGL66SL返回的是特殊格式需要检查是否有数据
hasData := false // hasData := false
if resultMap, ok := result.(map[string]interface{}); ok { // if resultMap, ok := result.(map[string]interface{}); ok {
for _, v := range resultMap { // for _, v := range resultMap {
if vMap, ok := v.(map[string]interface{}); ok { // if vMap, ok := v.(map[string]interface{}); ok {
if msg, ok := vMap["msg"].(string); ok && msg == "成功" { // if msg, ok := vMap["msg"].(string); ok && msg == "成功" {
hasData = true // hasData = true
break // break
} // }
} // }
} // }
} // }
detailMu.Lock() // detailMu.Lock()
status := "success" // status := "success"
if !hasData { // if !hasData {
status = "empty" // status = "empty"
} // }
processorResults = append(processorResults, processorResult{ // processorResults = append(processorResults, processorResult{
processorType: "QYGL66SL", // processorType: "QYGL66SL",
status: status, // status: status,
hasData: hasData, // hasData: hasData,
}) // })
detailMu.Unlock() // detailMu.Unlock()
}() // }()
// 调用QYGL7D9A - 欠税公告 // 调用QYGL7D9A - 欠税公告
detailWg.Add(1) detailWg.Add(1)

View File

@@ -43,4 +43,4 @@ func ProcessYYSYF7DBRequest(ctx context.Context, params []byte, deps *processors
} }
return respBytes, nil return respBytes, nil
} }