diff --git a/transferIndustrySatistics_python.py b/transferIndustrySatistics_python.py index 2479d52..7b26175 100644 --- a/transferIndustrySatistics_python.py +++ b/transferIndustrySatistics_python.py @@ -129,6 +129,11 @@ def getPeriodDiff(dbconfig,dbcursor,startDate,endDate): periodDiffMap[industryMap[blemind2]] = {'rise':0,'flat':0,'fall':1} return periodDiffMap +def getPreData(dbconfig,dbcursor,date): + preDataMap = {} + + return preDataMap + def main(): # #数据库A的连接信息;NAS数据库 # db_a_config = { @@ -228,6 +233,9 @@ def main(): periodIndex += 1 print('start transfer statistics ',trading_date , ' data.') + # 获取前一日数据 + preIndustryDataMap = getPreData(db_a_conn,db_a_cursor,period_trading_dateMap['1']) + # 获取多日成交额汇总数据 turnOver5 = getPeriodTurnOver(db_a_conn,db_a_cursor,period_trading_dateMap['5'],trading_date) for data in turnOver5: