Fix[#31]: 데일리 가중치 스케줄러와 사용자 가중치 동시 업데이트 시 업데이트 누락 방지

app/repositories/user_weight_repository.py

@@ -1,8 +1,6 @@
 from typing import List, Dict
-from motor.motor_asyncio import AsyncIOMotorClient, AsyncIOMotorCollection
 from pymongo import UpdateOne
-
-from app.models import db_w2v_mapper
+from motor.motor_asyncio import AsyncIOMotorClient, AsyncIOMotorCollection
 
 
 class UserWeightRepository:
@@ -15,7 +13,6 @@ def update_user_weights(
     ):
         operations = []
         for meta_id, name in meta_info:
-            name = db_w2v_mapper.translate_genre(name)
             operations.append(
                 UpdateOne(
                     {"user_id": user_id, "meta_info_id": meta_id},
@@ -36,8 +33,7 @@ async def update_user_weights_from_log(self, log: dict, weight: float):
         operations = []
 
         # 1. 장르
-        for genre in meta_info.get("genres", []):
-            name = db_w2v_mapper.translate_genre(genre)
+        for name in meta_info.get("genres", []):
             operations.append(
                 UpdateOne(
                     {"user_id": user_id, "name": name},
@@ -86,9 +82,9 @@ async def find_by_user_id(self, user_id: int) -> List[Dict]:
         results = await cursor.to_list(length=None)
         return results
 
-    async def reset_weight(self, user_id: int, genre: str, weight: float):
-        filter = {"user_id": user_id, "name": genre}
-        update = {"$set": {"weight": weight}}
+    async def update_user_weight(self, user_id: int, meta_info_name: str, diff: float):
+        filter = {"user_id": user_id, "name": meta_info_name}
+        update = {"$inc": {"weight": diff}}
         await self.collection.update_one(filter, update, upsert=True)
 
     async def decrease_user_weights_from_log(self, log: dict, weight: float):
@@ -97,8 +93,7 @@ async def decrease_user_weights_from_log(self, log: dict, weight: float):
 
         operations = []
 
-        for genre in meta_info.get("genres", []):
-            name = db_w2v_mapper.translate_genre(genre)
+        for name in meta_info.get("genres", []):
             operations.append(
                 UpdateOne(
                     {"user_id": user_id, "name": name},

app/services/daily_weight_resizer.py

@@ -56,6 +56,7 @@ async def resize_weight(
             weight = weight_strategy.convert_to_weight(action_type, value)
             # 가중치 resize
             resized_weight = exponential_decay_weight(weight, log['timestamp'])
+            diff = resized_weight - weight
 
             meta = log.get('metaInfo', {})
             genres = meta.get('genres', {})
@@ -64,38 +65,38 @@ async def resize_weight(
             countries = meta.get('country', {})
 
             for _, genre_name in genres.items():
-                genre_dict[genre_name] += resized_weight
+                genre_dict[genre_name] += diff
             for _, actor_name in actors.items():
-                actor_dict[actor_name] += resized_weight
+                actor_dict[actor_name] += diff
             for _, director_name in directors.items():
-                director_dict[director_name] += resized_weight
+                director_dict[director_name] += diff
             for _, country_name in countries.items():
-                country_dict[country_name] += resized_weight
+                country_dict[country_name] += diff
 
 
         # MongoDB에 resized 가중치 저장
-        for genre_name, resized_weight in genre_dict.items():
+        for genre_name, diff in genre_dict.items():
             try:
-                await user_weight_repo.reset_weight(user_id, genre_name, resized_weight)
+                await user_weight_repo.update_user_weight(user_id, genre_name, diff)
             except Exception:
                 failed.append((user_id, genre_name, resize_weight))
 
         await asyncio.sleep(5)
-        for actor_name, resized_weight in actor_dict.items():
+        for actor_name, diff in actor_dict.items():
             try:
-                await user_weight_repo.reset_weight(user_id, actor_name, resized_weight)
+                await user_weight_repo.update_user_weight(user_id, actor_name, diff)
             except Exception:
                 failed.append((user_id, actor_name, resize_weight))
 
-        for director_name, resized_weight in director_dict.items():
+        for director_name, diff in director_dict.items():
             try:
-                await user_weight_repo.reset_weight(user_id, director_name, resized_weight)
+                await user_weight_repo.update_user_weight(user_id, director_name, diff)
             except Exception:
                 failed.append((user_id, director_name, resize_weight))
 
-        for country_name, resized_weight in country_dict.items():
+        for country_name, diff in country_dict.items():
             try:
-                await user_weight_repo.reset_weight(user_id, country_name, resized_weight)
+                await user_weight_repo.update_user_weight(user_id, country_name, diff)
             except Exception:
                 failed.append((user_id, country_name, resize_weight))