fix_syntax_error

sync_data.py

@@ -38,6 +38,7 @@ def get_stock_list() -> pd.DataFrame:
     logger.info("Fetching all-market target list...")
     all_lists = []
     
+    # A股列表获取（带重试）
     max_retries = 3
     for attempt in range(max_retries):
         try:
@@ -45,6 +46,7 @@ def get_stock_list() -> pd.DataFrame:
             df_a.columns = ['code', 'name']
             df_a['market'] = df_a['code'].apply(lambda x: '主板' if x.startswith(('60', '00')) else ('创业板' if x.startswith('30') else ('科创板' if x.startswith('68') else ('北交所' if x.startswith(('8', '4', '920')) else '其他'))))
             all_lists.append(df_a)
+            logger.info(f"A-stock list fetched: {len(df_a)} stocks")
             break  # 成功则退出重试循环
         except Exception as e:
             if attempt == max_retries - 1:
@@ -52,42 +54,49 @@ def get_stock_list() -> pd.DataFrame:
             else:
                 logger.warning(f"Attempt {attempt + 1} failed, retrying... Error: {e}")
                 time.sleep(5)  # 重试前等待 5 秒
-        
-        # ETF / LOF / REITs (增加容错)
-        try:
-            df_etf = ak.fund_etf_spot_em()[['代码', '名称']]
-            df_etf.columns = ['code', 'name']
-            df_etf['market'] = 'ETF'
-            all_lists.append(df_etf)
-        except Exception as e:
-            logger.warning(f"ETF list fetch failed: {e}")
 
-        try:
-            df_lof = ak.fund_lof_spot_em()[['代码', '名称']]
-            df_lof.columns = ['code', 'name']
-            df_lof['market'] = 'LOF'
-            all_lists.append(df_lof)
-        except Exception as e:
-            logger.warning(f"LOF list fetch failed: {e}")
+    # ETF (增加容错)
+    try:
+        df_etf = ak.fund_etf_spot_em()[['代码', '名称']]
+        df_etf.columns = ['code', 'name']
+        df_etf['market'] = 'ETF'
+        all_lists.append(df_etf)
+        logger.info(f"ETF list fetched: {len(df_etf)} funds")
+    except Exception as e:
+        logger.warning(f"ETF list fetch failed: {e}")
 
-        try:
-            df_reits = ak.reits_realtime_em()[['代码', '名称']]
-            df_reits.columns = ['code', 'name']
-            df_reits['market'] = 'REITs'
-            all_lists.append(df_reits)
-        except Exception as e:
-            logger.warning(f"REITs list fetch failed: {e}")
-        
-        try:
-            df_cb = ak.bond_zh_hs_cov_spot()
-            c_code = '代码' if '代码' in df_cb.columns else 'symbol'
-            c_name = '名称' if '名称' in df_cb.columns else 'name'
-            df_cb = df_cb[[c_code, c_name]]; df_cb.columns = ['code', 'name']; df_cb['market'] = '可转债'; all_lists.append(df_cb)
-        except Exception as e:
-            logger.warning(f"Convertible bond list fetch failed: {e}")
+    # LOF
+    try:
+        df_lof = ak.fund_lof_spot_em()[['代码', '名称']]
+        df_lof.columns = ['code', 'name']
+        df_lof['market'] = 'LOF'
+        all_lists.append(df_lof)
+        logger.info(f"LOF list fetched: {len(df_lof)} funds")
+    except Exception as e:
+        logger.warning(f"LOF list fetch failed: {e}")
 
+    # REITs
+    try:
+        df_reits = ak.reits_realtime_em()[['代码', '名称']]
+        df_reits.columns = ['code', 'name']
+        df_reits['market'] = 'REITs'
+        all_lists.append(df_reits)
+        logger.info(f"REITs list fetched: {len(df_reits)} products")
+    except Exception as e:
+        logger.warning(f"REITs list fetch failed: {e}")
+    
+    # 可转债
+    try:
+        df_cb = ak.bond_zh_hs_cov_spot()
+        c_code = '代码' if '代码' in df_cb.columns else 'symbol'
+        c_name = '名称' if '名称' in df_cb.columns else 'name'
+        df_cb = df_cb[[c_code, c_name]]
+        df_cb.columns = ['code', 'name']
+        df_cb['market'] = '可转债'
+        all_lists.append(df_cb)
+        logger.info(f"Convertible bond list fetched: {len(df_cb)} bonds")
     except Exception as e:
-        logger.error(f"List fetching error: {e}")
+        logger.warning(f"Convertible bond list fetch failed: {e}")
 
     if not all_lists:
         db = get_db()