eta_mini_ht_api/service/facade/ht_account_service.go

package facade

import (
	"eta/eta_mini_ht_api/api"
	logger "eta/eta_mini_ht_api/common/component/log"
	"eta/eta_mini_ht_api/common/exception"
	permissionService "eta/eta_mini_ht_api/domian/config"
	"eta/eta_mini_ht_api/service/product"
	"eta/eta_mini_ht_api/service/user"
	"fmt"
	"strconv"
	"strings"
)

var (
	htApi = api.GetInstance()
)

const (
	RiskUnTest   = 432
	RiskNotMatch = 433
	RiskExpired  = 434
)

func SyncRiskInfo(mobile string) (info string, err error) {

	return "", nil
}

func CheckUserRiskLevel(templateUserId int, productId int) (code int, err error) {
	//是否完成风测
	//风测是否过期
	//风测等级是否符合
	if productId <= 0 {
		logger.Error("产品id异常:%v", productId)
		code = 200
		err = exception.New(exception.IllegalProductId)
		return
	}
	if templateUserId <= 0 {
		logger.Error("用户id异常:%v", templateUserId)
		code = 200
		err = exception.New(exception.IllegalTemplateUserId)
		return
	}
	product, err := product.GetProductInfoById(productId)
	if err != nil {
		logger.Error("获取产品信息失败:%v", err)
		code = 200
		err = exception.New(exception.ProductInfoError)
		return
	}
	userInfo, userErr := user.GetUserProfile(templateUserId)
	if userErr != nil {
		logger.Error("获取临时用户信息失败:%v,userId:%v", userErr, templateUserId)
	}
	officialUser, err := user.GetUserByTemplateUserId(templateUserId)
	if err != nil {
		if userErr != nil {
			logger.Error("获取正式用户信息失败:%v,templateUserId:%v", userErr, templateUserId)
			code = 200
			err = exception.New(exception.OfficialUserFoundError)
			return

		}
	}
	customerInfo, err := htApi.GetCustomerRiskLevelInfo(api.ClientSuitInfoReq{
		ClientName: officialUser.RealName,
		IdKind:     officialUser.IdKind,
		IdNo:       officialUser.IdNo,
	})

	if err != nil {
		logger.Error("api获取客户风险信息失败:%v", err)
		if userInfo.RiskLevelStatus == user.RiskUnTest {
			logger.Error("客户风险等级未测试,mobile:%v", userInfo.Mobile)
			code = RiskUnTest
			err = exception.New(exception.RiskUnTestError)
			return
		}
		if userInfo.RiskLevelStatus == user.RiskExpired {
			logger.Error("客户风险等级已过期,mobile:%v", userInfo.Mobile)
			code = RiskExpired
			err = exception.New(exception.RiskExpiredError)
			return
		}
		mapping, mappingErr := permissionService.GetRiskMappingByCustomerRiskLevel(userInfo.RiskLevel)
		if mappingErr != nil {
			logger.Error("查询产品风险等级映射失败:%v", mappingErr)
			code = 200
			err = exception.New(exception.QueryRiskMappingError)
			return
		}
		return compareRisk(mapping.ProductRiskLevel, product.RiskLevel)
	}
	mapping, mappingErr := permissionService.GetRiskMappingByCustomerRiskLevel(customerInfo.RiskInfo.CorpRiskLevel)
	if mappingErr != nil {
		logger.Error("查询产品风险等级映射失败:%v", mappingErr)
		code = 200
		err = exception.New(exception.IllegalProductId)
		return
	}
	return compareRisk(mapping.ProductRiskLevel, product.RiskLevel)
}
func parseRiskLevel(level string) (int, error) {
	parts := strings.Split(level, "R")
	if len(parts) < 2 {
		return 0, fmt.Errorf("无效的风险等级: %s", level)
	}
	numberStr := parts[1]
	number, err := strconv.Atoi(numberStr)
	if err != nil {
		return 0, fmt.Errorf("无法将风险等级转换为数字: %s", err)
	}
	return number, nil
}
func compareRisk(cusPdRisk string, pdRisk string) (code int, err error) {
	riskLevelNum, err := parseRiskLevel(cusPdRisk)
	if err != nil {
		logger.Error("客户风险等级映射风险等级解析失败:%v,risk:%v", err, cusPdRisk)
		code = 200
		err = exception.New(exception.QueryRiskMappingError)
		return
	}
	pRiskNum, riskErr := parseRiskLevel(pdRisk)
	if riskErr != nil {
		logger.Error("产品风险等级解析失败:risk:%v", pdRisk)
		code = 200
		err = exception.New(exception.QueryRiskMappingError)
		return
	}
	if pRiskNum > riskLevelNum {
		code = RiskNotMatch
		err = exception.New(exception.RiskUnMatchError)
		return
	}
	return
}