From 2a0bda76e5a33ef20e4a47885cf5c02a0668aa81 Mon Sep 17 00:00:00 2001
From: liyxie <liy200110@163.com>
Date: Sat, 10 Jan 2026 19:13:51 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8F=96=E6=B6=88daily=E6=8F=92=E5=85=A5?=
 =?UTF-8?q?=E6=9F=A5=E9=87=8D=E5=A4=84=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/services/daily.py | 27 +++++++++++++++------------
 1 file changed, 15 insertions(+), 12 deletions(-)

diff --git a/app/services/daily.py b/app/services/daily.py
index b41f577..6a763b1 100644
--- a/app/services/daily.py
+++ b/app/services/daily.py
@@ -38,7 +38,7 @@ class DailyDataService(BaseService[DailyData]):
         批量创建记录，支持两种输入格式：
         - List[DailyData]：模型实例列表
         - List[dict]：字典列表（自动转换为实例）
-        通过 (account_id, NYID) 联合判断是否已存在，存在则忽略
+        通过 (account_id, NYID) 联合判断是否已存在，存在则忽略  --(暂时取消查重)
         """
         try:
             data_list = self._ensure_instances(data)
@@ -56,23 +56,26 @@ class DailyDataService(BaseService[DailyData]):
             logger.warning("批量创建失败：所有记录缺少 account_id 或 NYID")
             return []
 
-        existing_pairs: Set[Tuple[int, int]] = {
-            (item.account_id, item.NYID) 
-            for item in db.query(DailyData.account_id, DailyData.NYID)
-                         .filter(DailyData.account_id.in_([p[0] for p in target_pairs]),
-                                 DailyData.NYID.in_([p[1] for p in target_pairs]))
-                         .all()
-        }
+
+        # 取消查重处理
+        # existing_pairs: Set[Tuple[int, int]] = {
+        #     (item.account_id, item.NYID) 
+        #     for item in db.query(DailyData.account_id, DailyData.NYID)
+        #                  .filter(DailyData.account_id.in_([p[0] for p in target_pairs]),
+        #                          DailyData.NYID.in_([p[1] for p in target_pairs]))
+        #                  .all()
+        # }
 
         to_create = [
             item for item in data_list 
-            if (item.account_id, item.NYID) not in existing_pairs
+            # if (item.account_id, item.NYID) not in existing_pairs
         ]
 
-        ignored_count = len(data_list) - len(to_create)
-        if ignored_count > 0:
-            logger.info(f"批量创建时忽略{ignored_count}条已存在记录（account_id和NYID已存在）")
+        # ignored_count = len(data_list) - len(to_create)
+        # if ignored_count > 0:
+        #     logger.info(f"批量创建时忽略{ignored_count}条已存在记录（account_id和NYID已存在）")
 
+        logger.info(f"批量创建 {to_create}")
         if not to_create:
             return []