From c3d2209a1364b5f208e5979b2131cfc495b7417b Mon Sep 17 00:00:00 2001 From: rogeraabbccdd Date: Tue, 2 Jul 2024 17:24:41 +0800 Subject: [PATCH] Fix database queries --- WeaponSynchronization.cs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/WeaponSynchronization.cs b/WeaponSynchronization.cs index d2e8e4b4..3571058d 100644 --- a/WeaponSynchronization.cs +++ b/WeaponSynchronization.cs @@ -1,4 +1,4 @@ -using System.Collections.Concurrent; +using System.Collections.Concurrent; using Dapper; using MySqlConnector; @@ -17,7 +17,7 @@ internal class WeaponSynchronization internal async Task GetPlayerDatabaseIndex(PlayerInfo playerInfo) { - if (playerInfo.SteamId == null || playerInfo.Slot == 0) return; + if (playerInfo.SteamId == null || playerInfo.Slot < 0) return; Console.WriteLine("test"); try { @@ -29,7 +29,7 @@ internal class WeaponSynchronization if (databaseIndex != null) { WeaponPaints.g_playersDatabaseIndex[playerInfo.Slot] = (int)databaseIndex; - query = "UPDATE `wp_users` SET `last_update` = @lastUpdate WHERE `id` = @databaseIndex"; + query = "UPDATE `wp_users` SET `last_online` = @lastUpdate WHERE `id` = @databaseIndex"; await connection.ExecuteAsync(query, new { lastUpdate = DateTime.Now, @@ -208,7 +208,7 @@ internal class WeaponSynchronization await using var transaction = await connection.BeginTransactionAsync(); var userIds = await connection.QueryAsync( - $"SELECT id FROM wp_users WHERE last_update < NOW() - INTERVAL {_config.Additional.ExpireOlderThan} DAY", + $"SELECT id FROM wp_users WHERE last_online < NOW() - INTERVAL {_config.Additional.ExpireOlderThan} DAY", transaction: transaction ); @@ -367,7 +367,7 @@ internal class WeaponSynchronization { await using var connection = await _database.GetConnectionAsync(); const string query = - "INSERT INTO `wp_users_musics` (`user_id`, `music_id`) VALUES(@userId, @newMusic) ON DUPLICATE KEY UPDATE `music_id` = @newMusic"; + "INSERT INTO `wp_users_musics` (`user_id`, `music`) VALUES(@userId, @newMusic) ON DUPLICATE KEY UPDATE `music` = @newMusic"; await connection.ExecuteAsync(query, new { userId = WeaponPaints.g_playersDatabaseIndex[player.Slot], newMusic = music }); } catch (Exception e)