From 8de41412c2b7bed9d57f54095fd52a3715d119ad Mon Sep 17 00:00:00 2001
From: liangzai <2440983361@qq.com>
Date: Thu, 23 Oct 2025 15:54:39 +0800
Subject: [PATCH] add new api

---
 .../api/internal/service/apirequestService.go | 111 ++++++++++++++++--
 1 file changed, 102 insertions(+), 9 deletions(-)

diff --git a/app/main/api/internal/service/apirequestService.go b/app/main/api/internal/service/apirequestService.go
index 002b06f..df904ad 100644
--- a/app/main/api/internal/service/apirequestService.go
+++ b/app/main/api/internal/service/apirequestService.go
@@ -251,6 +251,10 @@ var requestProcessors = map[string]func(*ApiRequestService, context.Context, []b
 
 	// 天远API
 	"QCXG9P1C": (*ApiRequestService).ProcessQCXG9P1CRequest,
+	"FLXGDEA9": (*ApiRequestService).ProcessFLXGDEA9Request, // 公安个人不良加强版
+	"IVYZ6G7H": (*ApiRequestService).ProcessIVYZ6G7HRequest, // 单人婚姻状态(补证版)
+	"IVYZ3A7F": (*ApiRequestService).ProcessIVYZ3A7FRequest, // 学历信息查询(学校名称版)
+	"YYSY7D3E": (*ApiRequestService).ProcessYYSY7D3ERequest, // 携号转网查询
 }
 
 // PreprocessRequestApi 调用指定的请求处理函数
@@ -2165,15 +2169,15 @@ func (a *ApiRequestService) ProcessBehaviorRiskScanRequest(ctx context.Context,
 	}()
 
 	// 风险等级
-	go func() {
-		defer wg.Done()
-		data, err := a.ProcessG34BJ03Request(ctx, params)
-		var resultData []byte
-		if data != nil {
-			resultData = data.Data
-		}
-		results <- apiResult{name: "risk_level", data: resultData, err: err}
-	}()
+	// go func() {
+	// 	defer wg.Done()
+	// 	data, err := a.ProcessG34BJ03Request(ctx, params)
+	// 	var resultData []byte
+	// 	if data != nil {
+	// 		resultData = data.Data
+	// 	}
+	// 	results <- apiResult{name: "risk_level", data: resultData, err: err}
+	// }()
 
 	// 关闭结果通道
 	go func() {
@@ -2532,3 +2536,92 @@ func (a *ApiRequestService) ProcessQCXG9P1CRequest(ctx context.Context, params [
 		Data: jsonResult,
 	}, nil
 }
+func (a *ApiRequestService) ProcessFLXGDEA9Request(ctx context.Context, params []byte) (*APIInternalResult, error) {
+	name := gjson.GetBytes(params, "name")
+	idCard := gjson.GetBytes(params, "id_card")
+	if !name.Exists() || !idCard.Exists() {
+		return nil, errors.New("api请求, FLXGDEA9, 获取相关参数失败")
+	}
+	request := map[string]interface{}{
+		"name":    name.String(),
+		"id_card": idCard.String(),
+	}
+	resp, err := a.tianyuanapiService.CallInterface("FLXGDEA9", request)
+	if err != nil {
+		return nil, err
+	}
+	jsonResult, err := json.Marshal(resp.Data)
+	if err != nil {
+		return nil, fmt.Errorf("处理公安个人不良加强版查询结果失败: %v", err)
+	}
+	return &APIInternalResult{
+		Data: jsonResult,
+	}, nil
+}
+
+func (a *ApiRequestService) ProcessIVYZ6G7HRequest(ctx context.Context, params []byte) (*APIInternalResult, error) {
+	name := gjson.GetBytes(params, "name")
+	idCard := gjson.GetBytes(params, "id_card")
+	if !name.Exists() || !idCard.Exists() {
+		return nil, errors.New("api请求, IVYZ6G7H, 获取相关参数失败")
+	}
+	request := map[string]interface{}{
+		"name":    name.String(),
+		"id_card": idCard.String(),
+	}
+	resp, err := a.tianyuanapiService.CallInterface("IVYZ6G7H", request)
+	if err != nil {
+		return nil, err
+	}
+	jsonResult, err := json.Marshal(resp.Data)
+	if err != nil {
+		return nil, fmt.Errorf("处理单人婚姻状态(补证版)查询结果失败: %v", err)
+	}
+	return &APIInternalResult{
+		Data: jsonResult,
+	}, nil
+}
+
+func (a *ApiRequestService) ProcessIVYZ3A7FRequest(ctx context.Context, params []byte) (*APIInternalResult, error) {
+	name := gjson.GetBytes(params, "name")
+	idCard := gjson.GetBytes(params, "id_card")
+	if !name.Exists() || !idCard.Exists() {
+		return nil, errors.New("api请求, IVYZ3A7F, 获取相关参数失败")
+	}
+	request := map[string]interface{}{
+		"name":    name.String(),
+		"id_card": idCard.String(),
+	}
+	resp, err := a.tianyuanapiService.CallInterface("IVYZ3A7F", request)
+	if err != nil {
+		return nil, err
+	}
+	jsonResult, err := json.Marshal(resp.Data)
+	if err != nil {
+		return nil, fmt.Errorf("处理学历信息查询(学校名称版)结果失败: %v", err)
+	}
+	return &APIInternalResult{
+		Data: jsonResult,
+	}, nil
+}
+
+func (a *ApiRequestService) ProcessYYSY7D3ERequest(ctx context.Context, params []byte) (*APIInternalResult, error) {
+	mobileNo := gjson.GetBytes(params, "mobile_no")
+	if !mobileNo.Exists() {
+		return nil, errors.New("api请求, YYSY7D3E, 获取相关参数失败")
+	}
+	request := map[string]interface{}{
+		"mobile_no": mobileNo.String(),
+	}
+	resp, err := a.tianyuanapiService.CallInterface("YYSY7D3E", request)
+	if err != nil {
+		return nil, err
+	}
+	jsonResult, err := json.Marshal(resp.Data)
+	if err != nil {
+		return nil, fmt.Errorf("处理携号转网查询结果失败: %v", err)
+	}
+	return &APIInternalResult{
+		Data: jsonResult,
+	}, nil
+}