From 50f21283e835e8cf26bea10d578fdfd40b20e7a6 Mon Sep 17 00:00:00 2001
From: Mrx <18278715334@163.com>
Date: Tue, 9 Jun 2026 16:46:01 +0800
Subject: [PATCH] f

---
 .../processors/ivyz/ivyzp2q6_processor.go     | 70 ++++++++++++++-----
 1 file changed, 54 insertions(+), 16 deletions(-)

diff --git a/internal/domains/api/services/processors/ivyz/ivyzp2q6_processor.go b/internal/domains/api/services/processors/ivyz/ivyzp2q6_processor.go
index 2e361dc..ffa072e 100644
--- a/internal/domains/api/services/processors/ivyz/ivyzp2q6_processor.go
+++ b/internal/domains/api/services/processors/ivyz/ivyzp2q6_processor.go
@@ -7,10 +7,10 @@ import (
 
 	"tyapi-server/internal/domains/api/dto"
 	"tyapi-server/internal/domains/api/services/processors"
-	"tyapi-server/internal/infrastructure/external/haiyuapi"
+	"tyapi-server/internal/infrastructure/external/shumai"
 )
 
-// ProcessIVYZP2Q6Request IVYZP2Q6 API处理方法 - 身份认证二要素（电签版，海宇API）
+// ProcessIVYZP2Q6Request IVYZP2Q6 API处理方法 - 身份认证二要素
 func ProcessIVYZP2Q6Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) {
 	var paramsDto dto.IVYZP2Q6Req
 	if err := json.Unmarshal(params, &paramsDto); err != nil {
@@ -21,26 +21,64 @@ func ProcessIVYZP2Q6Request(ctx context.Context, params []byte, deps *processors
 		return nil, errors.Join(processors.ErrInvalidParam, err)
 	}
 
-	if deps.HaiyuapiService == nil {
-		return nil, errors.Join(processors.ErrSystem, errors.New("海宇API服务未初始化"))
+	reqFormData := map[string]interface{}{
+		"idcard": paramsDto.IDCard,
+		"name":   paramsDto.Name,
 	}
 
-	reqParams := map[string]interface{}{
-		"name":    paramsDto.Name,
-		"id_card": paramsDto.IDCard,
-	}
+	// 以表单方式调用数脉 API；参数在 CallAPIForm 内转为 application/x-www-form-urlencoded
+	apiPath := "/v4/id_card/check" // 接口路径，根据数脉文档填写（如 v4/xxx）
 
-	apiPath := "/api/v1/IVYZP2Q6"
-	respBytes, err := deps.HaiyuapiService.CallAPI(ctx, apiPath, reqParams)
+	// 先尝试使用政务接口（app_id2 和 app_secret2）
+	respBytes, err := deps.ShumaiService.CallAPIForm(ctx, apiPath, reqFormData, true)
 	if err != nil {
-		if errors.Is(err, haiyuapi.ErrNotFound) {
-			return nil, errors.Join(processors.ErrNotFound, err)
-		}
-		if errors.Is(err, haiyuapi.ErrDatasource) {
-			return nil, errors.Join(processors.ErrDatasource, err)
+		// 使用实时接口（app_id 和 app_secret）重试
+		respBytes, err = deps.ShumaiService.CallAPIForm(ctx, apiPath, reqFormData, false)
+		// 如果重试后仍然失败，返回错误
+		if err != nil {
+			if errors.Is(err, shumai.ErrNotFound) {
+				// 查无记录情况
+				return nil, errors.Join(processors.ErrNotFound, err)
+			} else if errors.Is(err, shumai.ErrDatasource) {
+				// 数据源错误
+				return nil, errors.Join(processors.ErrDatasource, err)
+			} else if errors.Is(err, shumai.ErrSystem) {
+				// 系统错误
+				return nil, errors.Join(processors.ErrSystem, err)
+			} else {
+				// 其他未知错误
+				return nil, errors.Join(processors.ErrSystem, err)
+			}
 		}
+	}
+
+	// 数据源返回 result(0-一致/1-不一致/2-无记录)，映射为 state(1-匹配/2-不匹配/3-异常情况)
+	var dsResp struct {
+		Result int `json:"result"` // 0-一致 1-不一致 2-无记录(预留)
+	}
+	if err := json.Unmarshal(respBytes, &dsResp); err != nil {
 		return nil, errors.Join(processors.ErrSystem, err)
 	}
 
-	return respBytes, nil
+	state := resultToState(dsResp.Result)
+
+	out := map[string]interface{}{
+		"errMsg": "",
+		"state":  state,
+	}
+	return json.Marshal(out)
+}
+
+// resultToState 将数据源 result 映射为接口 state：1-匹配 2-不匹配 3-异常情况
+func resultToState(result int) int {
+	switch result {
+	case 0: // 一致 → 匹配
+		return 1
+	case 1: // 不一致 → 不匹配
+		return 2
+	case 2: // 无记录(预留) → 异常情况
+		return 3
+	default:
+		return 3 // 未知/异常 → 异常情况
+	}
 }