yyfbaloot/servers/micros/money/handler/transfermanager.go

package handler

import (
	"encoding/json"
	"fmt"
	"os"
	"strconv"
	"time"

	"bet24.com/log"
	"bet24.com/servers/common"
	platformconfig "bet24.com/servers/micros/platformconfig/proto"
	"bet24.com/servers/micros/userservices/handler/mail"
	userservices "bet24.com/servers/micros/userservices/proto"
)

var transMgr *transferManager

const config_key = "money_transferconfig"
const refresh_config_sec = 1800

func getTransferManager() *transferManager {
	if transMgr == nil {
		transMgr = new(transferManager)
		transMgr.ctor()
	}
	return transMgr
}

type transferManager struct {
	GoldConfig GoldTransferConfig

	configString string
}

func (tm *transferManager) ctor() {
	log.Debug("transferManager.ctor")
	tm.readConf()
}

func (tm *transferManager) readConf() {
	time.AfterFunc(time.Second*refresh_config_sec, tm.readConf)
	configString := platformconfig.GetConfig(config_key)

	if configString == "" {
		data, err := os.ReadFile(fmt.Sprintf("serviceconf/%s.json", config_key))
		if err != nil {
			log.Release("transferManager.loadData read config failed")
			return
		}
		configString = string(data)
		if configString != "" {
			platformconfig.SetConfig(config_key, configString)
		}
	}

	if configString == tm.configString {
		return
	}

	tm.configString = configString
	// 读取配置

	err := json.Unmarshal([]byte(configString), &tm)
	if err != nil {
		log.Release("transferManager.loadData Unmarshal failed %s", configString)
	}
}

func (tm *transferManager) dump(param1, param2 string) {
	log.Release("-------------------------------")
	log.Release("transferManager.dump %s,%s", param1, param2)
	defer func() {
		log.Release("+++++++++++++++++++++++++++++++")
		log.Release("")
	}()

	if param1 == "count" {
		getTransferCountMgr().dump(param2)
		return
	}

	if param1 == "user" {
		var userId int
		var err error
		userId, err = strconv.Atoi(param2)
		if err != nil {
			log.Release("invalid userId")
			return
		}
		log.Release(tm.getGoldTransferConfig(userId))
		return
	}

	log.Release(tm.configString)
}

func (tm *transferManager) transferGold(userId int, toUserId int, amount int, ipAddress string) (ok bool, errorMsg string) {
	// 不能赠送给自己
	if userId == toUserId {
		errorMsg = "Can't give it to yourself"
		return
	}

	if tm.GoldConfig.DailyTransferCount == 0 {
		errorMsg = "Transfer not open"
		log.Release("transferManager.transferGold Transfer not open")
		return
	}

	// 用户是否存在
	usr := userservices.GetUserInfo(userId)
	if usr == nil {
		errorMsg = "User not exist"
		log.Release("transferManager.transferGold userId[%d] not exist", userId)
		return
	}

	if userservices.IsBlackList(userId) {
		log.Release("transferManager.transferGold userId[%d] blacklist", userId)
		return
	}

	// 接收用户
	toUsr := userservices.GetUserInfo(toUserId)
	if toUsr == nil {
		errorMsg = "Target User not exist"
		log.Release("transferManager.transferGold toUserId[%d] not exist", toUserId)
		return
	}

	if amount < tm.GoldConfig.MinAmount {
		ok = false
		errorMsg = "Invalid Amount"
		log.Release("transferManager.transferGold userId[%d] amount[%d]<MinAmount[%d]",
			userId, amount, tm.GoldConfig.MinAmount)
		return
	}

	reduceAmount := amount * (100 + tm.GoldConfig.TaxRate) / 100

	// 判断金额
	if usr.Gold-tm.GoldConfig.ReservedAmount < reduceAmount {
		ok = false
		errorMsg = "Not Enough Amount"
		log.Release("transferManager.transferGold userId[%d] amount[%d->%d]>Gold[%d]Reserved[%d]",
			userId, amount, reduceAmount, usr.Gold, tm.GoldConfig.ReservedAmount)
		return
	}

	// 判断我的次数
	if !tm.checkGoldTransferCount(userId) {
		ok = false
		errorMsg = "Daily Transfer Limited"
		return
	}

	// 先扣减金币
	retCode := cash.reduceMoney(userId, reduceAmount, common.LOGTYPE_TRANSFER_CONSUME, "cash", "transfer", ipAddress)
	if retCode != 1 {
		ok = false
		errorMsg = "Failed to deduct gold coins"
		return
	}

	// 加金币
	cash.giveMoney(toUserId, amount, common.LOGTYPE_TRANSFER_ADD, "cash", "transfer", ipAddress)

	// 添加转账记录
	cash.addTransferLog(usr.UserId, usr.NickName,
		toUsr.UserId, toUsr.NickName,
		amount, reduceAmount-amount,
		ipAddress)

	// TODO：发送邮件通知
	go mail.SendSysMail(toUserId, &userservices.SysMail{
		Id:         0,
		Title:      tm.GoldConfig.MailTitle,
		Content:    fmt.Sprintf(tm.GoldConfig.MailContent, amount, usr.NickName, userId),
		Status:     0,
		SourceName: tm.GoldConfig.MailSource,
		Crdate:     common.GetTimeStamp(),
		Tools:      nil,
	})

	// 转账成功，增加当日次数
	getTransferCountMgr().addTransferCount(userId)
	go userservices.UpdateUserInfo(userId)
	ok = true
	return
}

func (tm *transferManager) checkGoldTransferCount(userId int) bool {
	if tm.GoldConfig.DailyTransferCount < 0 || userservices.IsWhiteList(userId) {
		return true
	}

	totalCount := tm.GoldConfig.DailyTransferCount + userservices.GetUserPrivilegeValue(userId, userservices.VipPrivilege_ExtraGoldTransferCount)
	if totalCount <= 0 {
		return false
	}

	return getTransferCountMgr().getTransferCount(userId) < totalCount
}

func (tm *transferManager) getGoldTransferLog(userId int) string {
	type transferLog struct {
		UserId   int    // 对方用户ID
		NickName string // 对方昵称
		FaceUrl  string
		FaceId   int
		Amount   int // 大于0接收，小于0赠送
		Crdate   string
	}

	var ret []transferLog

	logs := cashTransferLog(userId, 30)
	for _, v := range logs {
		var tl transferLog
		if v.UserID == userId { // 赠送
			tl.Amount = -v.Amount
			tl.UserId = v.AcceptUserID
			tl.NickName = v.AcceptNickName

		} else { // 接收
			tl.Amount = v.Amount
			tl.UserId = v.UserID
			tl.NickName = v.NickName
		}

		toUser := userservices.GetUserInfo(tl.UserId)
		if toUser == nil {
			log.Debug("transferManager.getGoldTransferLog userId[%d] not exist", tl.UserId)
		} else {
			tl.NickName = toUser.NickName
			tl.FaceId = toUser.FaceId
			tl.FaceUrl = toUser.FaceUrl
		}
		tl.Crdate = v.Crdate

		ret = append(ret, tl)
	}

	d, _ := json.Marshal(ret)
	return string(d)
}

func (tm *transferManager) getGoldTransferConfig(userId int) string {
	if tm.GoldConfig.DailyTransferCount == 0 {
		return ""
	}
	// 用户是否存在
	usr := userservices.GetUserInfo(userId)
	if usr == nil {
		log.Release("transferManager.transferGold userId[%d] not exist", userId)
		return ""
	}

	if userservices.IsBlackList(userId) {
		log.Release("transferManager.transferGold userId[%d] blacklist", userId)
		return ""
	}

	var info UserGoldTransferConfig
	info.MinAmount = tm.GoldConfig.MinAmount
	info.TaxRate = tm.GoldConfig.TaxRate
	info.MaxAmount = (usr.Gold - tm.GoldConfig.ReservedAmount) * 100 / (100 + tm.GoldConfig.TaxRate)
	if info.MaxAmount < info.MinAmount {
		info.MaxAmount = 0
	}
	if tm.GoldConfig.DailyTransferCount > 0 {
		if userservices.IsWhiteList(userId) {
			info.TotalCount = 999
		} else {
			info.TotalCount = tm.GoldConfig.DailyTransferCount + userservices.GetUserPrivilegeValue(userId, userservices.VipPrivilege_ExtraGoldTransferCount)
			info.UsedCount = getTransferCountMgr().getTransferCount(userId)
		}
	} else {
		info.TotalCount = 999
	}
	d, _ := json.Marshal(info)
	return string(d)
}