f

internal/domains/api/services/processors/ivyz/ivyzn2p8_processor.go

@@ -4,12 +4,10 @@ import (
 	"context"
 	"encoding/json"
 	"errors"
-	"strconv"
-	"strings"
 
 	"tyapi-server/internal/domains/api/dto"
 	"tyapi-server/internal/domains/api/services/processors"
-	"tyapi-server/internal/infrastructure/external/alicloud"
+	"tyapi-server/internal/infrastructure/external/shumai"
 )
 
 // ProcessIVYZN2P8Request IVYZN2P8 身份证实名认证政务版 API处理方法
@@ -27,75 +25,97 @@ func ProcessIVYZN2P8Request(ctx context.Context, params []byte, deps *processors
 		"name":   paramsDto.Name,
 		"idcard": paramsDto.IDCard,
 	}
-	respBytes, err := deps.AlicloudService.CallAPI("api-mall/api/id_card/check", reqData)
+
+	// 以表单方式调用数脉 API；参数在 CallAPIForm 内转为 application/x-www-form-urlencoded
+	apiPath := "/v4/id_card/check"
+
+	// 先尝试使用政务接口（app_id2 和 app_secret2）
+	respBytes, err := deps.ShumaiService.CallAPIForm(ctx, apiPath, reqData, true)
 	if err != nil {
-		if errors.Is(err, alicloud.ErrDatasource) {
+		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)
 		}
-
-	// 对齐 yysybe08test 的原始响应结构，取 data 字段映射为 ivyzn2p8 返回
-	var aliyunData struct {
-		Code int `json:"code"`
-		Data struct {
-			Birthday string      `json:"birthday"`
-			Result   interface{} `json:"result"`
-			Address  string      `json:"address"`
-			OrderNo  string      `json:"orderNo"`
-			Sex      string      `json:"sex"`
-			Desc     string      `json:"desc"`
-		} `json:"data"`
-		Result interface{} `json:"result"`
-		Desc   string      `json:"desc"`
 	}
-	if err := json.Unmarshal(respBytes, &aliyunData); err != nil {
+	return respBytes, nil
-		return nil, errors.Join(processors.ErrSystem, err)
 }
 
-	rawResult := aliyunData.Result
+// respBytes, err := deps.AlicloudService.CallAPI("api-mall/api/id_card/check", reqData)
-	rawDesc := aliyunData.Desc
+// if err != nil {
-	if aliyunData.Code == 200 {
+// 	if errors.Is(err, alicloud.ErrDatasource) {
-		rawResult = aliyunData.Data.Result
+// 		return nil, errors.Join(processors.ErrDatasource, err)
-		rawDesc = aliyunData.Data.Desc
+// 	}
-	}
+// 	return nil, errors.Join(processors.ErrSystem, err)
+// }
 
-	response := map[string]interface{}{
+// return respBytes, nil
-		"result":   normalizeResult(rawResult),
+// // 对齐 yysybe08test 的原始响应结构，取 data 字段映射为 ivyzn2p8 返回
-		"order_no": aliyunData.Data.OrderNo,
+// var aliyunData struct {
-		"desc":     rawDesc,
+// 	Code int `json:"code"`
-		"sex":      aliyunData.Data.Sex,
+// 	Data struct {
-		"birthday": aliyunData.Data.Birthday,
+// 		Birthday string      `json:"birthday"`
-		"address":  aliyunData.Data.Address,
+// 		Result   interface{} `json:"result"`
-	}
+// 		Address  string      `json:"address"`
-	return json.Marshal(response)
+// 		OrderNo  string      `json:"orderNo"`
-}
+// 		Sex      string      `json:"sex"`
+// 		Desc     string      `json:"desc"`
+// 	} `json:"data"`
+// 	Result interface{} `json:"result"`
+// 	Desc   string      `json:"desc"`
+// }
+// if err := json.Unmarshal(respBytes, &aliyunData); err != nil {
+// 	return nil, errors.Join(processors.ErrSystem, err)
+// }
 
-func normalizeResult(v interface{}) int {
+// rawResult := aliyunData.Result
-	switch r := v.(type) {
+// rawDesc := aliyunData.Desc
-	case float64:
+// if aliyunData.Code == 200 {
-		return int(r)
+// 	rawResult = aliyunData.Data.Result
-	case int:
+// 	rawDesc = aliyunData.Data.Desc
-		return r
+// }
-	case int32:
+
-		return int(r)
+// response := map[string]interface{}{
-	case int64:
+// 	"result":   normalizeResult(rawResult),
-		return int(r)
+// 	"order_no": aliyunData.Data.OrderNo,
-	case json.Number:
+// 	"desc":     rawDesc,
-		n, err := r.Int64()
+// 	"sex":      aliyunData.Data.Sex,
-		if err == nil {
+// 	"birthday": aliyunData.Data.Birthday,
-			return int(n)
+// 	"address":  aliyunData.Data.Address,
-		}
+// }
-	case string:
+// return json.Marshal(response)
-		s := strings.TrimSpace(r)
+// }
-		if s == "" {
+
-			return 1
+// func normalizeResult(v interface{}) int {
-		}
+// 	switch r := v.(type) {
-		n, err := strconv.Atoi(s)
+// 	case float64:
-		if err == nil {
+// 		return int(r)
-			return n
+// 	case int:
-		}
+// 		return r
-	}
+// 	case int32:
-	// 默认按不一致处理
+// 		return int(r)
-	return 1
+// 	case int64:
-}
+// 		return int(r)
+// 	case json.Number:
+// 		n, err := r.Int64()
+// 		if err == nil {
+// 			return int(n)
+// 		}
+// 	case string:
+// 		s := strings.TrimSpace(r)
+// 		if s == "" {
+// 			return 1
+// 		}
+// 		n, err := strconv.Atoi(s)
+// 		if err == nil {
+// 			return n
+// 		}
+// 	}
+// 	// 默认按不一致处理
+// 	return 1
+// }