modified: bot.py
This commit is contained in:
58
bot.py
58
bot.py
@@ -280,51 +280,45 @@ def save_global_permission(user_id, permission_level):
|
|||||||
#-----------------------------------------------------------------------------------------------------------
|
#-----------------------------------------------------------------------------------------------------------
|
||||||
|
|
||||||
async def update_all_users():
|
async def update_all_users():
|
||||||
|
try:
|
||||||
connection = connect_to_database()
|
connection = connect_to_database()
|
||||||
cursor = connection.cursor()
|
cursor = connection.cursor()
|
||||||
|
guild_ids = [guild_id for (guild_id,) in cursor.execute("SELECT guild_id FROM guilds").fetchall()]
|
||||||
|
|
||||||
# Hole alle Guild-IDs aus der guilds-Datenbank
|
count = 0
|
||||||
cursor.execute("SELECT guild_id FROM guilds")
|
for guild_id in guild_ids:
|
||||||
guilds = cursor.fetchall()
|
|
||||||
|
|
||||||
for (guild_id,) in guilds:
|
|
||||||
guild = client.get_guild(int(guild_id))
|
guild = client.get_guild(int(guild_id))
|
||||||
if not guild:
|
if guild is None:
|
||||||
continue # Falls der Bot auf diesem Server nicht mehr aktiv ist, überspringen
|
continue
|
||||||
|
|
||||||
print(f"Updating users for guild: {guild_id}")
|
|
||||||
|
|
||||||
# Aktualisiere Benutzerdaten für alle Mitglieder im Server
|
|
||||||
for member in guild.members:
|
for member in guild.members:
|
||||||
user_id = member.id
|
user_data = load_user_data(member.id, guild.id)
|
||||||
user_data = load_user_data(user_id, guild_id)
|
|
||||||
|
|
||||||
print(f"Processing member: {member.display_name} (ID: {user_id})")
|
nickname = member.nick if member.nick else member.name
|
||||||
|
profile_picture = member.display_avatar.url
|
||||||
|
join_date = member.joined_at.date() if member.joined_at else None
|
||||||
|
|
||||||
# Aktualisiere Nickname, Profilbild und Join-Datum für vorhandene Mitglieder
|
# Update nickname, profile_picture, and join_date in database
|
||||||
update_user_data(user_id, guild_id, "nickname", member.display_name)
|
update_user_data(member.id, guild.id, "nickname", nickname)
|
||||||
update_user_data(user_id, guild_id, "profile_picture", str(member.display_avatar.url))
|
update_user_data(member.id, guild.id, "profile_picture", profile_picture)
|
||||||
update_user_data(user_id, guild_id, "join_date", member.joined_at.date())
|
update_user_data(member.id, guild.id, "join_date", join_date)
|
||||||
|
|
||||||
# Entferne leave_date, falls der Benutzer noch auf dem Server ist und leave_date gesetzt war
|
# Check if the user is still on the server, update leave_date if not
|
||||||
if user_data.get("leave_date") is not None:
|
if not member.bot and member.status == discord.Status.offline:
|
||||||
print(f"Clearing leave_date for user: {member.display_name}")
|
|
||||||
update_user_data(user_id, guild_id, "leave_date", None)
|
|
||||||
|
|
||||||
# Überprüfe alle Benutzer in `user_data`, die nicht mehr auf dem Server sind
|
|
||||||
cursor.execute("SELECT user_id FROM user_data WHERE guild_id = %s", (guild_id,))
|
|
||||||
all_users = cursor.fetchall()
|
|
||||||
|
|
||||||
for (user_id,) in all_users:
|
|
||||||
member = guild.get_member(int(user_id))
|
|
||||||
if member is None: # Benutzer hat den Server verlassen
|
|
||||||
print(f"User {user_id} has left the guild {guild_id}, setting leave_date.")
|
|
||||||
leave_date = datetime.now().date()
|
leave_date = datetime.now().date()
|
||||||
update_user_data(user_id, guild_id, "leave_date", leave_date)
|
update_user_data(member.id, guild.id, "leave_date", leave_date)
|
||||||
|
else:
|
||||||
|
update_user_data(member.id, guild.id, "leave_date", None)
|
||||||
|
|
||||||
|
count += 1
|
||||||
|
if count >= 100: # After every 100 users, take a short pause
|
||||||
|
await asyncio.sleep(1) # Short pause
|
||||||
|
count = 0
|
||||||
|
|
||||||
cursor.close()
|
cursor.close()
|
||||||
connection.close()
|
connection.close()
|
||||||
print("User data update completed.")
|
except Exception as e:
|
||||||
|
logger.error(f"Error updating all users: {e}")
|
||||||
|
|
||||||
def save_giveaway_to_db(guild_id, platform, name, prize_uuid, game_key):
|
def save_giveaway_to_db(guild_id, platform, name, prize_uuid, game_key):
|
||||||
connection = connect_to_database()
|
connection = connect_to_database()
|
||||||
|
|||||||
Reference in New Issue
Block a user