From 52995fddbdb87e8cbba094cc4d2951133a3abdc1 Mon Sep 17 00:00:00 2001 From: laixingyu Date: Sun, 6 Aug 2023 19:14:25 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E8=8E=B7=E5=8F=96=E5=89=8D=E4=B8=80?= =?UTF-8?q?=E6=97=A5=E4=BA=A4=E6=98=93=E6=95=B0=E6=8D=AE=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- transferIndustrySatistics_python.py | 8 ++++++++ 1 file changed, 8 insertions(+) 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: