fix ProcessBehaviorRiskScanRequest

This commit is contained in:
liangzai 2025-04-24 14:31:09 +08:00
parent 3671c40c46
commit e7c2de0d55

View File

@ -2130,41 +2130,61 @@ func (a *ApiRequestService) ProcessBehaviorRiskScanRequest(ctx context.Context,
results := make(chan apiResult, 5) // 5个风险检测项
// 并行调用五个不同的风险检测API
wg.Add(4)
wg.Add(5) // 修改为5与实际启动的goroutine数量一致
// 黑灰产检测
go func() {
defer wg.Done()
data, err := a.ProcessG30BJ05Request(ctx, params)
results <- apiResult{name: "black_gray_level", data: data.Data, err: err}
var resultData []byte
if data != nil {
resultData = data.Data
}
results <- apiResult{name: "black_gray_level", data: resultData, err: err}
}()
// 电诈风险预警
go func() {
defer wg.Done()
data, err := a.ProcessG31BJ05Request(ctx, params)
results <- apiResult{name: "telefraud_level", data: data.Data, err: err}
var resultData []byte
if data != nil {
resultData = data.Data
}
results <- apiResult{name: "telefraud_level", data: resultData, err: err}
}()
// 团伙欺诈排查
go func() {
defer wg.Done()
data, err := a.ProcessG32BJ05Request(ctx, params)
results <- apiResult{name: "fraud_group", data: data.Data, err: err}
var resultData []byte
if data != nil {
resultData = data.Data
}
results <- apiResult{name: "fraud_group", data: resultData, err: err}
}()
// // 反诈反赌核验
go func() {
defer wg.Done()
data, err := a.ProcessRIS031Request(ctx, params)
results <- apiResult{name: "anti_fraud_gaming", data: data.Data, err: err}
var resultData []byte
if data != nil {
resultData = data.Data
}
results <- apiResult{name: "anti_fraud_gaming", data: resultData, err: err}
}()
// 风险等级
go func() {
defer wg.Done()
data, err := a.ProcessG34BJ03Request(ctx, params)
results <- apiResult{name: "risk_level", data: data.Data, err: err}
var resultData []byte
if data != nil {
resultData = data.Data
}
results <- apiResult{name: "risk_level", data: resultData, err: err}
}()
// 关闭结果通道