CardCollector/CardCollector/Commands/CallbackQuery/BuyByGems.cs

using System;
using System.Threading.Tasks;
using CardCollector.Controllers;
using CardCollector.DataBase.Entity;
using CardCollector.DataBase.EntityDao;
using CardCollector.Resources;
using CardCollector.Session.Modules;
using Telegram.Bot.Types;

namespace CardCollector.Commands.CallbackQuery
{
    public class BuyByGems : CallbackQueryCommand
    {
        protected override string CommandText => Command.buy_by_gems;
        public override async Task Execute()
        {
            var offerInfo = User.Session.GetModule<ShopModule>().SelectedPosition;
            if (User.Cash.Gems < offerInfo.ResultPriceGems)
                await MessageController.AnswerCallbackQuery(User, CallbackQueryId, Messages.not_enougth_gems);
            else if (offerInfo.Expired)
                await MessageController.AnswerCallbackQuery(User, CallbackQueryId, Messages.offer_expired);
            else if (offerInfo.IsSpecial && !offerInfo.IsInfinite && await SpecialOfferUsersDao.NowUsed(User.Id, offerInfo.Id))
                await MessageController.AnswerCallbackQuery(User, CallbackQueryId, Messages.you_already_use_this_offer);
            else
            {
                await User.ClearChat();
                User.Cash.Gems -= offerInfo.ResultPriceGems;
                if (offerInfo.IsSpecial && !offerInfo.IsInfinite)
                    await SpecialOfferUsersDao.AddNew(User.Id, offerInfo.Id);
                var userPacks = await UsersPacksDao.GetUserPacks(User.Id);
                switch (offerInfo.PackId)
                {
                    case 1:
                        userPacks.RandomCount += offerInfo.Count;
                        break;
                    case 2:
                        userPacks.AuthorCount += offerInfo.Count;
                        break;
                    default:
                        var info = await SpecificPackDao.GetInfo(User.Id, offerInfo.PackId);
                        info.Count += offerInfo.Count;
                        break;
                }
                await MessageController.EditMessage(User, CallbackMessageId, Messages.thanks_for_buying);
                if (offerInfo.AdditionalPrize != "") await GivePrize(offerInfo.AdditionalPrize);
            }
        }

        private async Task GivePrize(string prizeInfo)
        {
            var data = prizeInfo.Split('=');
            StickerEntity sticker = null;
            switch (data[0])
            {
                case "tier":
                    var tier = int.Parse(data[1]);
                    var stickers = await StickerDao.GetListWhere(item => item.Tier == tier);
                    var rnd = new Random();
                    sticker = stickers[rnd.Next(stickers.Count)];
                    break;
                case "sticker":
                    sticker = await StickerDao.GetStickerByHash(data[1]);
                    break;
            }
            if (sticker != null)
            {
                if (!User.Stickers.ContainsKey(sticker.Md5Hash))
                    await UserStickerRelationDao.AddNew(User, sticker, 1);
                else
                    User.Stickers[sticker.Md5Hash].Count ++;
                var stickerMessage = await MessageController.SendSticker(User, sticker.Id);
                var message = await MessageController.SendMessage(User, $"{Messages.congratulation}\n{sticker}");
                User.Session.Messages.Add(stickerMessage.MessageId);
                User.Session.Messages.Add(message.MessageId);
            }
        }

        public BuyByGems() { }
        public BuyByGems(UserEntity user, Update update) : base(user, update) { }
    }
}