update

enum/user_virtual_amount_flow.go

@@ -15,6 +15,7 @@ const (
 	PersonEggGetByTeamEggEnergyRelease
 	SettlementStarLevelDividends
 	EggEnergyToExchangeToAmount
+	EggPointCoinToAliPayRealName
 )
 
 func (kind UserVirtualAmountFlowTransferType) String() string {
@@ -41,6 +42,8 @@ func (kind UserVirtualAmountFlowTransferType) String() string {
 		return "星级分红"
 	case EggEnergyToExchangeToAmount:
 		return "个人蛋蛋能量兑换余额"
+	case EggPointCoinToAliPayRealName:
+		return "个人蛋蛋积分实名认证"
 	default:
 		return "未知状态"
 	}

enum/withdraw_apply.go

@@ -61,9 +61,9 @@ const (
 func (kind FinWithdrawApplyWithdrawKind) String() string {
 	switch kind {
 	case FinWithdrawApplyWithdrawKindForAli:
-		return "支付宝"
+		return "alipay"
 	case FinWithdrawApplyWithdrawKindForWx:
-		return "微信"
+		return "wx"
 	default:
 		return "未知状态"
 	}

rule/egg_energy/give_activty_coin.go

@@ -14,6 +14,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"github.com/shopspring/decimal"
 	"strings"
 	"time"
 	"xorm.io/xorm"
@@ -223,6 +224,118 @@ func SettlementGiveActivityCoin(engine *xorm.Engine, uid int64, ch *rabbit.Chann
 	return
 }
 
+func ActivityCoinToAlipayRealName(engine *xorm.Engine, uid int64, amount string) (err error) {
+	amountValue, _ := decimal.NewFromString(amount)
+
+	//1、查找 `egg_energy_basic_setting` 基础设置
+	eggEnergyBasicSettingDb := implement.NewEggEnergyBasicSettingDb(engine)
+	eggEnergyBasicSetting, err := eggEnergyBasicSettingDb.EggEnergyBasicSettingGetOneByParams(map[string]interface{}{
+		"key":   "is_open",
+		"value": 1,
+	})
+	if err != nil {
+		return
+	}
+	if eggEnergyBasicSetting == nil {
+		err = errors.New("蛋蛋能量设置未开启！")
+		return
+	}
+
+	var coin model.VirtualCoin
+	_, err = engine.Where("id = ?", eggEnergyBasicSetting.PersonEggPointsCoinId).Get(&coin)
+	if err != nil {
+		return
+	}
+	personActivePointsCoinExchangeRatioValue, _ := decimal.NewFromString(coin.ExchangeRatio)
+
+	//2、判断个人蛋蛋积分是否足够
+	var personUserVirtualAmount model.UserVirtualAmount
+	_, err = engine.Where("coin_id = ?", eggEnergyBasicSetting.PersonEggPointsCoinId).Get(&personUserVirtualAmount)
+	if err != nil {
+		fmt.Println("err:::::1111", err)
+		return
+	}
+	personUserVirtualAmountValue, _ := decimal.NewFromString(personUserVirtualAmount.Amount)
+	needVirtualAmountValue := amountValue.Mul(personActivePointsCoinExchangeRatioValue)
+	needVirtualAmount, _ := amountValue.Mul(personActivePointsCoinExchangeRatioValue).Float64()
+	if personUserVirtualAmountValue.LessThan(needVirtualAmountValue) {
+		err = errors.New("当前蛋蛋积分不足！")
+		return
+	}
+
+	//3、扣除对应个人蛋蛋积分
+	session := engine.NewSession()
+	defer func() {
+		session.Close()
+		if err := recover(); err != nil {
+			_ = zhios_order_relate_logx.Error(err)
+		}
+	}()
+	session.Begin()
+
+	//给相应的用户加上"个人"活跃积分
+	err = rule.DealUserVirtualCoin(session, md.DealUserVirtualCoinReq{
+		Kind:         "sub",
+		Title:        enum.UserVirtualAmountFlowTransferType.String(enum.EggPointCoinToAliPayRealName),
+		TransferType: int(enum.EggPointCoinToAliPayRealName),
+		CoinId:       eggEnergyBasicSetting.PersonEggPointsCoinId,
+		Uid:          uid,
+		Amount:       needVirtualAmount,
+	})
+	if err != nil {
+		_ = session.Rollback()
+		fmt.Println("err:::::2222", err)
+		return err
+	}
+
+	err = session.Commit()
+	if err != nil {
+		_ = session.Rollback()
+		return errors.New("事务提交失败")
+	}
+
+	return
+}
+
+func CheckActivityCoinToAlipayRealName(engine *xorm.Engine, uid int64, amount string) (err error, isCan bool) {
+	amountValue, _ := decimal.NewFromString(amount)
+
+	//1、查找 `egg_energy_basic_setting` 基础设置
+	eggEnergyBasicSettingDb := implement.NewEggEnergyBasicSettingDb(engine)
+	eggEnergyBasicSetting, err := eggEnergyBasicSettingDb.EggEnergyBasicSettingGetOneByParams(map[string]interface{}{
+		"key":   "is_open",
+		"value": 1,
+	})
+	if err != nil {
+		return
+	}
+	if eggEnergyBasicSetting == nil {
+		err = errors.New("蛋蛋能量设置未开启！")
+		return
+	}
+
+	var coin model.VirtualCoin
+	_, err = engine.Where("id = ?", eggEnergyBasicSetting.PersonEggPointsCoinId).Get(&coin)
+	if err != nil {
+		return
+	}
+	personActivePointsCoinExchangeRatioValue, _ := decimal.NewFromString(coin.ExchangeRatio)
+
+	//2、判断个人蛋蛋积分是否足够
+	var personUserVirtualAmount model.UserVirtualAmount
+	_, err = engine.Where("coin_id = ?", eggEnergyBasicSetting.PersonEggPointsCoinId).Get(&personUserVirtualAmount)
+	if err != nil {
+		fmt.Println("err:::::1111", err)
+		return
+	}
+	personUserVirtualAmountValue, _ := decimal.NewFromString(personUserVirtualAmount.Amount)
+	needVirtualAmountValue := amountValue.Mul(personActivePointsCoinExchangeRatioValue)
+	if personUserVirtualAmountValue.GreaterThan(needVirtualAmountValue) {
+		isCan = true
+	}
+	return
+}
+
 // CalcUserContinuousDailyActivityDays 计算用户连续活跃天数
 func CalcUserContinuousDailyActivityDays(engine *xorm.Engine, uid int, startDate string, endDate string) (err error, days int, isContinuousDailyActivity bool) {
 	startAt, err := time.ParseInLocation("2006-01-02", startDate, time.Local) //起始时间

rule/egg_energy/md/mq_egg_app.go

@@ -0,0 +1,27 @@
+package md
+
+const EggAppExchange = "egg.app"
+
+const (
+	EggFinWithdrawApply = "egg_fin_withdraw_apply" // 提现申请
+)
+
+type EggFinWithdrawApplyData struct {
+	Id              int64  `json:"id"`
+	Uid             int64  `json:"uid"`
+	AdmId           int    `json:"adm_id"`
+	Amount          string `json:"amount"`
+	RealAmount      string `json:"real_amount"`
+	Fee             string `json:"fee"`
+	Type            int    `json:"type"`
+	WithdrawAccount string `json:"withdraw_account"`
+	WithdrawName    string `json:"withdraw_name"`
+	Reason          int    `json:"reason"`
+	PaymentDate     string `json:"payment_date"`
+	State           int    `json:"state"`
+	WithdrawKind    int    `json:"withdraw_kind"`
+	IsFirst         int    `json:"is_first"`
+	Memo            string `json:"memo"`
+	UpdateAt        string `json:"update_at"`
+	CreateAt        string `json:"create_at"`
+}