MarseyWorld/files/helpers/lottery.py

129 lines
4.0 KiB
Python
Raw Normal View History

import time
from random import choice
from sqlalchemy import *
from files.helpers.alerts import *
from files.helpers.wrappers import *
from files.helpers.actions import *
2022-05-30 00:49:14 +00:00
from flask import g
from .const import *
LOTTERY_WINNER_BADGE_ID = 137
2022-05-30 00:49:14 +00:00
def get_active_lottery():
2022-06-13 18:33:25 +00:00
return g.db.query(Lottery).order_by(Lottery.id.desc()).filter(Lottery.is_active).one_or_none()
2022-05-29 06:01:45 +00:00
2022-05-30 00:49:14 +00:00
def get_users_participating_in_lottery():
2022-06-13 18:33:25 +00:00
return g.db.query(User) \
.filter(User.currently_held_lottery_tickets > 0) \
.order_by(User.currently_held_lottery_tickets.desc()).all()
2022-05-29 06:01:45 +00:00
2022-05-30 00:49:14 +00:00
def get_active_lottery_stats():
2022-06-13 18:33:25 +00:00
active_lottery = get_active_lottery()
participating_users = get_users_participating_in_lottery()
2022-05-29 06:01:45 +00:00
2022-09-04 23:15:37 +00:00
return None if active_lottery is None else active_lottery.stats, len(participating_users)
2022-05-29 06:01:45 +00:00
2022-05-30 00:49:14 +00:00
def end_lottery_session():
2022-06-13 18:33:25 +00:00
active_lottery = get_active_lottery()
2022-06-13 18:33:25 +00:00
if (active_lottery is None):
return False, "There is no active lottery."
2022-06-13 18:33:25 +00:00
participating_users = get_users_participating_in_lottery()
raffle = []
for user in participating_users:
for _ in range(user.currently_held_lottery_tickets):
raffle.append(user.id)
if len(raffle) == 0:
active_lottery.is_active = False
return True, "Lottery ended with no participants."
2022-06-13 18:33:25 +00:00
winner = choice(raffle)
active_lottery.winner_id = winner
winning_user = next(filter(lambda x: x.id == winner, participating_users))
winning_user.coins += active_lottery.prize
winning_user.total_lottery_winnings += active_lottery.prize
badge_grant(user=winning_user, badge_id=LOTTERY_WINNER_BADGE_ID)
2022-06-13 18:33:25 +00:00
for user in participating_users:
chance_to_win = user.currently_held_lottery_tickets / len(raffle) * 100
if user.id == winner:
2022-06-28 00:54:44 +00:00
notification_text = f'You won {active_lottery.prize} coins in the lottershe! ' \
2022-06-13 18:33:25 +00:00
+ f'Congratulations!\nYour odds of winning were: {chance_to_win}%'
else:
2022-06-28 00:54:44 +00:00
notification_text = f'You did not win the lottershe. Better luck next time!\n' \
2022-06-13 18:33:25 +00:00
+ f'Your odds of winning were: {chance_to_win}%\nWinner: @{winning_user.username} (won {active_lottery.prize} coins)'
send_repeatable_notification(user.id, notification_text)
user.currently_held_lottery_tickets = 0
2022-06-13 18:33:25 +00:00
active_lottery.is_active = False
2022-06-13 18:33:25 +00:00
return True, f'{winning_user.username} won {active_lottery.prize} coins!'
2022-05-30 00:49:14 +00:00
def start_new_lottery_session():
2022-06-13 18:33:25 +00:00
end_lottery_session()
2022-06-13 18:33:25 +00:00
lottery = Lottery()
epoch_time = int(time.time())
2022-06-16 02:23:21 +00:00
# Subtract 4 minutes from one cycle so cronjob interval doesn't cause the
# time to drift toward over multiple cycles.
one_week_from_now = epoch_time + LOTTERY_DURATION - (4 * 60)
2022-06-13 18:33:25 +00:00
lottery.ends_at = one_week_from_now
lottery.is_active = True
2022-06-13 18:33:25 +00:00
g.db.add(lottery)
2022-06-07 11:36:55 +00:00
def check_if_end_lottery_task():
2022-06-13 18:33:25 +00:00
active_lottery = get_active_lottery()
2022-06-07 11:36:55 +00:00
2022-06-13 18:33:25 +00:00
if active_lottery is None:
return False
elif active_lottery.timeleft > 0:
return False
2022-06-07 11:36:55 +00:00
2022-06-13 18:33:25 +00:00
start_new_lottery_session()
return True
2022-06-07 11:36:55 +00:00
def lottery_ticket_net_value():
2022-06-13 18:33:25 +00:00
return LOTTERY_TICKET_COST - LOTTERY_SINK_RATE
2022-06-07 11:36:55 +00:00
def purchase_lottery_tickets(v, quantity=1):
2022-06-13 18:33:25 +00:00
if quantity < 1:
2022-06-28 00:54:44 +00:00
return False, f"Must purchase one or more lottershe tickets."
2022-06-13 18:33:25 +00:00
elif (v.coins < LOTTERY_TICKET_COST * quantity):
return False, f'Lottery tickets cost {LOTTERY_TICKET_COST} coins each.'
2022-06-13 18:33:25 +00:00
most_recent_lottery = get_active_lottery()
if (most_recent_lottery is None):
return False, "There is no active lottery."
2022-06-13 18:33:25 +00:00
v.coins -= LOTTERY_TICKET_COST * quantity
v.currently_held_lottery_tickets += quantity
v.total_held_lottery_tickets += quantity
2022-06-13 18:33:25 +00:00
net_ticket_value = lottery_ticket_net_value() * quantity
most_recent_lottery.prize += net_ticket_value
most_recent_lottery.tickets_sold += quantity
2022-06-28 00:54:44 +00:00
if quantity == 1: return True, f'Successfully purchased {quantity} lottershe ticket!'
return True, f'Successfully purchased {quantity} lottershe tickets!'
def grant_lottery_tickets_to_user(v, quantity):
2022-06-13 18:33:25 +00:00
active_lottery = get_active_lottery()
prize_value = lottery_ticket_net_value() * quantity
2022-06-13 18:33:25 +00:00
if active_lottery:
v.currently_held_lottery_tickets += quantity
v.total_held_lottery_tickets += quantity
2022-06-13 18:33:25 +00:00
active_lottery.prize += prize_value
active_lottery.tickets_sold += quantity