From 1e5a1f565219882108a38618d9e3ff3b1abdf8c7 Mon Sep 17 00:00:00 2001 From: sophon Date: Sun, 10 Aug 2025 19:26:47 +0800 Subject: [PATCH] modify scripts --- src/db_utils/reports_mysql.py | 2 +- src/em_reports/fetch.py | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/src/db_utils/reports_mysql.py b/src/db_utils/reports_mysql.py index 1da5597..d449efb 100644 --- a/src/db_utils/reports_mysql.py +++ b/src/db_utils/reports_mysql.py @@ -121,7 +121,7 @@ class StockReportMysql: result = self.cursor.fetchone() return result[0] if result else None except pymysql.MySQLError as e: - logging.error(f"插入或更新数据失败: {e}") + logging.error(f"插入或更新数据失败: {e}, data: {data}") self.conn.rollback() # 出错时回滚 return None diff --git a/src/em_reports/fetch.py b/src/em_reports/fetch.py index 449c937..2bc7b7b 100644 --- a/src/em_reports/fetch.py +++ b/src/em_reports/fetch.py @@ -95,6 +95,8 @@ def fetch_reports_list_general(fetch_func, table_name, s_date, e_date, data_dir_ row['newPeIssueA'] = float(row.get('newPeIssueA', 0)) except ValueError: row['newPeIssueA'] = 0.0 + else: + row['newPeIssueA'] = 0.0 row_id = db_tools.insert_or_update_common(row, table_name) if row_id: logging.debug(f'insert one row. rowid:{row_id}, ')