From bd7944db558c92d6c5654bf30294d7ba65acfee1 Mon Sep 17 00:00:00 2001 From: laixingyu Date: Wed, 9 Aug 2023 23:39:51 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E6=9B=B4=E6=96=B0=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E5=88=B08=E6=9C=889=E6=97=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- transferData_python.py | 6 +++--- transferIndustryData_python.py | 6 +++--- transferIndustrySatistics_python.py | 5 ++++- transferNewrecordData_python.py | 6 +++--- 4 files changed, 13 insertions(+), 10 deletions(-) diff --git a/transferData_python.py b/transferData_python.py index 3d8fe30..52c9767 100644 --- a/transferData_python.py +++ b/transferData_python.py @@ -48,8 +48,8 @@ try: stock_basic_map = {} - #查询交易日数据 8月9日，更新数据到8月8日 - sql_trade_qurey = 'select date,week,trade from trade_dates where trade = %s and date > "2023-08-02"' + #查询交易日数据 8月9日，更新数据到8月9日 + sql_trade_qurey = 'select date,week,trade from trade_dates where trade = %s and date > "2023-08-08"' sql_trade = "trading" db_a_cursor.execute(sql_trade_qurey,sql_trade) trading_dates = db_a_cursor.fetchall() @@ -78,7 +78,7 @@ try: for row in trading_dates: trading_date,week,trade = row print('start transfer data ',trading_date , ' data.') - if trading_date == '2023-08-09': + if trading_date == '2023-08-10': print('break then finish transfer data ',trading_date , ' data.') break #查询日交易数据 diff --git a/transferIndustryData_python.py b/transferIndustryData_python.py index 51901b5..04e9069 100644 --- a/transferIndustryData_python.py +++ b/transferIndustryData_python.py @@ -48,8 +48,8 @@ try: stock_basic_map = {} - #查询交易日数据 更新到8月8日 - sql_trade_qurey = 'select date,week,trade from trade_dates where trade = %s and date > "2023-07-28"' + #查询交易日数据 更新到8月9日 + sql_trade_qurey = 'select date,week,trade from trade_dates where trade = %s and date > "2023-08-08"' sql_trade = "trading" db_a_cursor.execute(sql_trade_qurey,sql_trade) trading_dates = db_a_cursor.fetchall() @@ -57,7 +57,7 @@ try: for row in trading_dates: trading_date,week,trade = row print('start transfer IndustryData ',trading_date , ' data.') - if trading_date == '2023-08-09': + if trading_date == '2023-08-10': print('break then finished transfer IndustryData',trading_date , ' data.') break #查询日交易数据 diff --git a/transferIndustrySatistics_python.py b/transferIndustrySatistics_python.py index 0a00317..c38ecbb 100644 --- a/transferIndustrySatistics_python.py +++ b/transferIndustrySatistics_python.py @@ -296,7 +296,7 @@ def main(): stock_basic_map = {} #转换数据的日期（单日) - trans_date = '2022-03-07' + trans_date = '2023-08-08' #查询交易日数据 sql_trade_qurey = 'select date,week,trade from trade_dates where trade = %s and date > %s' @@ -313,6 +313,9 @@ def main(): # period_trading_dateMap = getTradingDates(db_a_conn,db_a_cursor,sql_trade,trans_date) period_trading_dateMap2 = {} # 用于计算区间涨跌数量等，区间涨跌等需要查询个股;区间涨跌是以前一日的收盘价与当前收盘价计算的 trading_date,week,trade = row + if trading_date == '2023-08-10': + print('break then finish transfer data ',trading_date , ' data.') + break # 获取周期,不包含当前交易日 sql_trade_period_qurey = 'select date,week,trade from trade_dates where trade = %s and date < %s order by date desc limit 30' sql_trade_period = "trading" diff --git a/transferNewrecordData_python.py b/transferNewrecordData_python.py index 6b568d8..628231a 100644 --- a/transferNewrecordData_python.py +++ b/transferNewrecordData_python.py @@ -48,8 +48,8 @@ try: stock_basic_map = {} - #查询交易日数据 更新数据到 8月8日 - sql_trade_qurey = 'select date,week,trade from trade_dates where trade = %s and date > "2023-07-28"' + #查询交易日数据 更新数据到 8月9日 + sql_trade_qurey = 'select date,week,trade from trade_dates where trade = %s and date > "2023-08-08"' sql_trade = "trading" db_a_cursor.execute(sql_trade_qurey,sql_trade) trading_dates = db_a_cursor.fetchall() @@ -78,7 +78,7 @@ try: for row in trading_dates: trading_date,week,trade = row print('start transfer newrecord data ',trading_date , ' data.') - if trading_date == '2023-08-09': + if trading_date == '2023-08-10': print('break then finished transfer newrecord ',trading_date , ' data.') break sql_stock_query = 'select code,trade_day, open,close,high,low,islimit,isdrop,differrange,trade_days,volumn,amount,differrange10,differrange20,differrange60,avg_volume20,freefloat_market_value,total_market_value,agencies_hold from stocks where trade_day = %s'