From 8ea08e74a044ed9fa434dea995009ad8d339daa2 Mon Sep 17 00:00:00 2001
From: liangzai <2440983361@qq.com>
Date: Thu, 23 Oct 2025 18:57:43 +0800
Subject: [PATCH] fix

---
 .../api/internal/service/apirequestService.go | 88 ++++++++++++-------
 1 file changed, 56 insertions(+), 32 deletions(-)

diff --git a/app/main/api/internal/service/apirequestService.go b/app/main/api/internal/service/apirequestService.go
index df904ad..9d49847 100644
--- a/app/main/api/internal/service/apirequestService.go
+++ b/app/main/api/internal/service/apirequestService.go
@@ -2122,45 +2122,45 @@ func (a *ApiRequestService) ProcessBehaviorRiskScanRequest(ctx context.Context,
 	results := make(chan apiResult, 5) // 5个风险检测项
 
 	// 并行调用五个不同的风险检测API
-	wg.Add(5) // 修改为5，与实际启动的goroutine数量一致
+	wg.Add(1) // 修改为5，与实际启动的goroutine数量一致
 
-	// 黑灰产检测
-	go func() {
-		defer wg.Done()
-		data, err := a.ProcessG30BJ05Request(ctx, params)
-		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.ProcessG30BJ05Request(ctx, params)
+	// 	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)
-		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.ProcessG31BJ05Request(ctx, params)
+	// 	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)
-		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.ProcessG32BJ05Request(ctx, params)
+	// 	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)
+		data, err := a.ProcessFLXG0687Request(params)
 		var resultData []byte
 		if data != nil {
 			resultData = data.Data
@@ -2625,3 +2625,27 @@ func (a *ApiRequestService) ProcessYYSY7D3ERequest(ctx context.Context, params [
 		Data: jsonResult,
 	}, nil
 }
+
+// ProcessFLXG0687Request 反诈反赌核验
+func (a *ApiRequestService) ProcessFLXG0687Request(params []byte) (*APIInternalResult, error) {
+	idCard := gjson.GetBytes(params, "id_card")
+	if !idCard.Exists() {
+		return nil, errors.New("api请求, FLXG0687, 获取相关参数失败")
+	}
+
+	resp, err := a.tianyuanapiService.CallInterface("FLXG0687", map[string]interface{}{
+		"id_card": idCard.String(),
+	})
+
+	if err != nil {
+		return nil, fmt.Errorf("处理反诈反赌核验查询结果失败: %v", err)
+	}
+
+	jsonResult, err := json.Marshal(resp.Data)
+	if err != nil {
+		return nil, fmt.Errorf("处理反诈反赌核验查询结果失败: %v", err)
+	}
+	return &APIInternalResult{
+		Data: jsonResult,
+	}, nil
+}