f

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

@@ -7,7 +7,7 @@ import (
 
 	"tyapi-server/internal/domains/api/dto"
 	"tyapi-server/internal/domains/api/services/processors"
-	"tyapi-server/internal/infrastructure/external/zhicha"
+	"tyapi-server/internal/infrastructure/external/nuoer"
 )
 
 // ProcessIVYZRAX2Request IVYZRAX2 API处理方法 - 融御反欺诈分
@@ -21,45 +21,34 @@ func ProcessIVYZRAX2Request(ctx context.Context, params []byte, deps *processors
 		return nil, errors.Join(processors.ErrInvalidParam, err)
 	}
 
-	// encryptedName, err := deps.ZhichaService.Encrypt(paramsDto.Name)
-	// if err != nil {
-	// 	return nil, errors.Join(processors.ErrSystem, err)
-	// }
-
-	// encryptedIDCard, err := deps.ZhichaService.Encrypt(paramsDto.IDCard)
-	// if err != nil {
-	// 	return nil, errors.Join(processors.ErrSystem, err)
-	// }
-	// encryptedMoblie, err := deps.ZhichaService.Encrypt(paramsDto.MobileNo)
-	// if err != nil {
-	// 	return nil, errors.Join(processors.ErrSystem, err)
-	// }
-
-	md5Name := deps.ZhichaService.MD5(paramsDto.Name)
-	md5IDCard := deps.ZhichaService.MD5(paramsDto.IDCard)
-	md5Mobile := deps.ZhichaService.MD5(paramsDto.MobileNo)
-
-	reqData := map[string]interface{}{
-		// "name":       encryptedName,
-		// "idCard":     encryptedIDCard,
-		// "phone":      encryptedMoblie,
-		"authorized": paramsDto.Authorized,
-		"name":       md5Name,
-		"idCard":     md5IDCard,
-		"phone":      md5Mobile,
+	body := map[string]string{
+		"name":   paramsDto.Name,
+		"idCard": paramsDto.IDCard,
+		"mobile": paramsDto.MobileNo,
 	}
 
-	respData, err := deps.ZhichaService.CallAPI(ctx, "ZCI083", reqData)
+	nuoerDoCheckAPIKey := "kunyu_fix_v3_tg_model"
+	ApiPath := "/v1/doCheck"
+
+	resp, err := deps.NuoerService.CallAPI(ctx, nuoerDoCheckAPIKey, ApiPath, body)
 	if err != nil {
-		if errors.Is(err, zhicha.ErrDatasource) {
+		if errors.Is(err, nuoer.ErrDatasource) {
 			return nil, errors.Join(processors.ErrDatasource, err)
-		} else {
-			return nil, errors.Join(processors.ErrSystem, err)
 		}
+		if errors.Is(err, nuoer.ErrNotFound) {
+			return nil, errors.Join(processors.ErrNotFound, err)
+		}
+		return nil, errors.Join(processors.ErrSystem, err)
 	}
 
-	// 将响应数据转换为JSON字节
-	respBytes, err := json.Marshal(respData)
+	rawData, ok := resp.Data.(map[string]interface{})
+	if !ok {
+		return nil, errors.Join(processors.ErrSystem, errors.New("响应格式错误"))
+	}
+
+	result := mapNuoerKunyuFixToResponse(rawData)
+
+	respBytes, err := json.Marshal(result)
 	if err != nil {
 		return nil, errors.Join(processors.ErrSystem, err)
 	}

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

@@ -0,0 +1,45 @@
+package ivyz
+
+import (
+	"fmt"
+	"strconv"
+)
+
+// mapNuoerKunyuFixToResponse 将 nuoer 响应（2json.md）转为对外结构（1json.md）：
+// 解包 result，将 score 映射为 scoreafywbase。
+func mapNuoerKunyuFixToResponse(data map[string]interface{}) map[string]interface{} {
+	score := ""
+	if data != nil {
+		payload := data
+		if result, ok := data["result"].(map[string]interface{}); ok {
+			payload = result
+		}
+		if raw, ok := payload["score"]; ok && raw != nil {
+			score = stringifyKunyuFixScore(raw)
+		}
+	}
+	return map[string]interface{}{
+		"scoreafywbase": score,
+	}
+}
+
+func stringifyKunyuFixScore(v interface{}) string {
+	if v == nil {
+		return ""
+	}
+	switch val := v.(type) {
+	case string:
+		return val
+	case float64:
+		if val == float64(int64(val)) {
+			return strconv.FormatInt(int64(val), 10)
+		}
+		return strconv.FormatFloat(val, 'f', -1, 64)
+	case int:
+		return strconv.Itoa(val)
+	case int64:
+		return strconv.FormatInt(val, 10)
+	default:
+		return fmt.Sprint(val)
+	}
+}