diff --git a/app/user/cmd/api/internal/service/apirequestService.go b/app/user/cmd/api/internal/service/apirequestService.go index 638b807..042bf32 100644 --- a/app/user/cmd/api/internal/service/apirequestService.go +++ b/app/user/cmd/api/internal/service/apirequestService.go @@ -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} }() // 关闭结果通道