diff --git a/transferData_python.py b/transferData_python.py index 52c9767..a65eb9f 100644 --- a/transferData_python.py +++ b/transferData_python.py @@ -49,7 +49,7 @@ try: stock_basic_map = {} #查询交易日数据 8月9日,更新数据到8月9日 - sql_trade_qurey = 'select date,week,trade from trade_dates where trade = %s and date > "2023-08-08"' + sql_trade_qurey = 'select date,week,trade from trade_dates where trade = %s and date > "2023-08-09"' 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-10': + if trading_date == '2023-08-11': print('break then finish transfer data ',trading_date , ' data.') break #查询日交易数据 diff --git a/transferIndustryData_python.py b/transferIndustryData_python.py index 04e9069..51062a9 100644 --- a/transferIndustryData_python.py +++ b/transferIndustryData_python.py @@ -49,7 +49,7 @@ try: stock_basic_map = {} #查询交易日数据 更新到8月9日 - sql_trade_qurey = 'select date,week,trade from trade_dates where trade = %s and date > "2023-08-08"' + sql_trade_qurey = 'select date,week,trade from trade_dates where trade = %s and date > "2023-08-09"' 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-10': + if trading_date == '2023-08-11': print('break then finished transfer IndustryData',trading_date , ' data.') break #查询日交易数据 diff --git a/transferIndustrySatistics_python.py b/transferIndustrySatistics_python.py index c38ecbb..8b56ddf 100644 --- a/transferIndustrySatistics_python.py +++ b/transferIndustrySatistics_python.py @@ -296,7 +296,7 @@ def main(): stock_basic_map = {} #转换数据的日期(单日) - trans_date = '2023-08-08' + trans_date = '2023-08-09' #查询交易日数据 sql_trade_qurey = 'select date,week,trade from trade_dates where trade = %s and date > %s' @@ -313,7 +313,7 @@ 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': + if trading_date == '2023-08-11': print('break then finish transfer data ',trading_date , ' data.') break # 获取周期,不包含当前交易日 diff --git a/transferNewrecordData_python.py b/transferNewrecordData_python.py index 628231a..2501900 100644 --- a/transferNewrecordData_python.py +++ b/transferNewrecordData_python.py @@ -49,7 +49,7 @@ try: stock_basic_map = {} #查询交易日数据 更新数据到 8月9日 - sql_trade_qurey = 'select date,week,trade from trade_dates where trade = %s and date > "2023-08-08"' + sql_trade_qurey = 'select date,week,trade from trade_dates where trade = %s and date > "2023-08-09"' 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-10': + if trading_date == '2023-08-11': 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'