lucky_bot/magic_server/telegram/redpacket.go

package telegram

import (
	"app/commons/core"
	"app/commons/services"
	"fmt"
	tgbotapi "github.com/go-telegram-bot-api/telegram-bot-api/v5"
	"strings"
)

// handleCallbackQuery 处理回调查询
func handleCallbackQuery(callback *tgbotapi.CallbackQuery) {
	data := callback.Data

	// 处理抢红包
	if strings.HasPrefix(data, "grab_") {
		packetNo := strings.TrimPrefix(data, "grab_")
		grabRedPacket(callback, packetNo)
		return
	}

	// 其他回调
	answerCallback(callback.ID, "未知操作")
}

// grabRedPacket 抢红包
func grabRedPacket(callback *tgbotapi.CallbackQuery, packetNo string) {
	telegramID := callback.From.ID
	username := callback.From.UserName

	// 检查绑定状态
	bindService := &services.TgBindService{}
	bound, userId := bindService.IsUserBound(telegramID)

	if !bound {
		answerCallback(callback.ID, "⚠️ 请先绑定账户！私聊我发送 /bind")
		// 私聊发送绑定提示
		sendTextMessage(telegramID, "⚠️ 您尚未绑定平台账户，无法抢红包。\n\n请发送 /bind 获取绑定链接。")
		core.Log.Infof("抢红包 - 用户: %s, 红包: %s, 结果: 未绑定", username, packetNo)
		return
	}

	// 用真实 userId 抢红包
	redPacketService := &services.RedPacketService{}
	record, err := redPacketService.GrabRedPacket(
		packetNo,
		userId,
		telegramID,
		username,
	)

	if err != nil {
		answerCallback(callback.ID, err.Error())
		core.Log.Infof("抢红包 - 用户: %s(userId:%d), 红包: %s, 结果: %s",
			username, userId, packetNo, err.Error())
		return
	}

	// 抢到红包
	amount := record.Amount.InexactFloat64()
	answerCallback(callback.ID, fmt.Sprintf("🎉 恭喜抢到 %.2f VND！", amount))

	// 更新原消息
	editText := fmt.Sprintf("%s\n\n✅ @%s 抢到了 %.2f VND",
		callback.Message.Text, username, amount)
	editMessage(callback.Message.Chat.ID, callback.Message.MessageID, editText)

	core.Log.Infof("抢红包 - 用户: %s(userId:%d), 红包: %s, 金额: %s, 结果: 成功",
		username, userId, packetNo, record.Amount.String())
}