封控

domain/service/diamond_s/diamond.go

 package diamond_s
 
 import (
+	"errors"
 	"git.hilo.cn/hilo-common/domain"
 	"git.hilo.cn/hilo-common/mycontext"
 	"git.hilo.cn/hilo-common/resource/mysql"
@@ -8,6 +9,7 @@ import (
 	"hilo-group/domain/model/diamond_m"
 	"hilo-group/domain/model/groupPower_m"
 	"hilo-group/domain/model/res_m"
+	"hilo-group/domain/model/user_m"
 	"hilo-group/myerr"
 	"hilo-group/myerr/bizerr"
 )
@@ -24,6 +26,22 @@ func NewDiamondService(myContext *mycontext.MyContext) *DiamondService {
 // 币商转账钻石-家族限制检查
 func (this *DiamondService) CheckDealerTransferFamilyLimit(dealerId, userId uint64, lang string) error {
 	model := domain.CreateModelContext(this.svc.MyContext)
+
+	//获取国家信息
+	_, dealerArea, err := user_m.GetUserCountryArea(model, dealerId)
+	if err != nil {
+		model.Log.Errorf("CheckDealerTransferFamilyLimit 获取国家资源错误 dealerId:%d, err:%v", dealerId, err)
+		return err
+	}
+	_, area, err := user_m.GetUserCountryArea(model, userId)
+	if err != nil {
+		model.Log.Errorf("CheckDealerTransferFamilyLimit 获取国家资源错误 userId:%d, err:%v", userId, err)
+		return err
+	}
+	if dealerArea != area {
+		return errors.New("fail")
+	}
+
 	// 代理、用户是否加入了家族
 	dealerFamily, err := groupPower_m.GetGroupPowerUserOrNil(model, dealerId)
 	if err != nil {