Fix link avatar bug

planetarium · Feb 26, 2024 · 09b1b47 · 09b1b47
1 parent 0d81bf2
commit 09b1b47
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/NineChroniclesUtilBackend.Store/Services/MongoDbStore.cs b/NineChroniclesUtilBackend.Store/Services/MongoDbStore.cs
@@ -156,12 +156,12 @@ public async Task LinkAvatarsToArenaAsync()
 
             foreach (var address in batchAddresses)
             {
-                var avatarFilter = Builders<BsonDocument>.Filter.Eq("address", address.ToHex());
+                var avatarFilter = Builders<BsonDocument>.Filter.Eq("Avatar.address", address.ToHex());
                 var avatar = await _avatarCollection.Find(avatarFilter).FirstOrDefaultAsync();
                 if (avatar != null)
                 {
                     var objectId = avatar["_id"].AsObjectId;
-                    var arenaFilter = Builders<BsonDocument>.Filter.Eq("avatarAddress", address.ToHex());
+                    var arenaFilter = Builders<BsonDocument>.Filter.Eq("AvatarAddress", address.ToHex());
                     var update = Builders<BsonDocument>.Update.Set("avatarObjectId", objectId);
                     var updateModel = new UpdateOneModel<BsonDocument>(arenaFilter, update) { IsUpsert = false };
                     bulkOps.Add(updateModel);

diff --git a/NineChroniclesUtilBackend.Store/Worker.cs b/NineChroniclesUtilBackend.Store/Worker.cs
@@ -23,7 +23,7 @@ public Worker(ILogger<Worker> logger,  ILogger<ArenaScrapper> scrapperLogger, IS
     protected override async Task ExecuteAsync(CancellationToken stoppingToken)
     {
         await _scrapper.ExecuteAsync();
-        // await _store.FlushAsync();
+        await _store.FlushAsync();
         await _store.LinkAvatarsToArenaAsync();
 
         _store.Result.TotalElapsedMinutes = DateTime.UtcNow.Subtract(_store.Result.StartTime).Minutes;