From 541d39139bf88ebb7299ceaa41a7e8408c5b1802 Mon Sep 17 00:00:00 2001
From: Qihang Zhang <zqh6200@qq.com>
Date: Sat, 5 Apr 2025 22:26:36 +0800
Subject: [PATCH] =?UTF-8?q?=F0=9F=9B=A0=EF=B8=8F=20refactor(data=5Fdownloa?=
 =?UTF-8?q?der.py):=20=E4=BF=AE=E6=AD=A3=E6=9B=B4=E6=96=B0=E6=97=B6?=
 =?UTF-8?q?=E9=97=B4=E9=80=BB=E8=BE=91=EF=BC=8C=E5=B9=B6=E4=BF=AE=E5=A4=8D?=
 =?UTF-8?q?=E6=9B=B4=E6=96=B0=E6=A8=A1=E5=BC=8F=E6=9F=A5=E8=AF=A2=E9=80=BB?=
 =?UTF-8?q?=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 data_downloader.py | 13 +++++--------
 1 file changed, 5 insertions(+), 8 deletions(-)

diff --git a/data_downloader.py b/data_downloader.py
index dd81a6e..9f1777c 100644
--- a/data_downloader.py
+++ b/data_downloader.py
@@ -339,7 +339,7 @@ def split_list_into_chunks(data_list, num_chunks):
     return chunks
 
 
-def process_stock_batch(batch, config, update_mode, start_date, end_date, update_time):
+def process_stock_batch(batch, config, update_mode, start_date, end_date):
     """
     处理一批股票的工作函数(在单独进程中运行)
 
@@ -349,7 +349,6 @@ def process_stock_batch(batch, config, update_mode, start_date, end_date, update
         update_mode: 更新模式 'full' 或 'incremental'
         start_date: 开始日期
         end_date: 结束日期
-        update_time: 当前更新时间戳
 
     Returns:
         dict: 包含处理结果统计信息的字典
@@ -373,6 +372,8 @@ def process_stock_batch(batch, config, update_mode, start_date, end_date, update
     total_stocks = len(batch)
 
     for i, stock_info in enumerate(batch):
+        # 当前更新时间
+        update_time = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
         # 根据更新模式获取不同的参数
         if update_mode == 'full':
             ts_code = stock_info
@@ -588,7 +589,7 @@ def perform_full_update(start_year=2020, processes=4, resume=False):
             query = """
             SELECT ts_code
             FROM stock_metadata
-            WHERE list_status = 'L' AND status = 2
+            WHERE list_status = 'L' AND status != 1 
             """
         else:
             # 查询所有已上市的股票
@@ -610,9 +611,6 @@ def perform_full_update(start_year=2020, processes=4, resume=False):
 
     print(f"共找到 {len(stock_codes)} 只股票需要{update_type}")
 
-    # 当前更新时间
-    update_time = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
-
     # 将股票列表分成多个批次
     batches = split_list_into_chunks(stock_codes, processes)
 
@@ -624,8 +622,7 @@ def perform_full_update(start_year=2020, processes=4, resume=False):
             config=config,
             update_mode='full',
             start_date=start_date,
-            end_date=end_date,
-            update_time=update_time
+            end_date=end_date
         )
 
         # 启动多进程处理并收集结果