diff --git a/transferIndustrySatistics_python.py b/transferIndustrySatistics_python.py index f739159..1af21e0 100644 --- a/transferIndustrySatistics_python.py +++ b/transferIndustrySatistics_python.py @@ -204,7 +204,7 @@ def main(): stock_basic_map = {} #转换数据的日期（单日) - trans_date = '2022-03-10' + trans_date = '2022-03-07' #查询交易日数据 sql_trade_qurey = 'select date,week,trade from trade_dates where trade = %s and date > %s' @@ -334,7 +334,6 @@ def main(): turnover5_ratio = (turnover5*Decimal('100.00') )/ Decimal(turnOver5[code]['total']) if hasTurnOver5 else ratio #todo turnover5_ratio_change = turnover5_ratio - Decimal(prevIndustryDataMap[code]['turnover5_ratio']) if hasPrevIndustryData else turnover5_ratio #todo turnover5_sort = Decimal(turnOver5[code]['turnover_sort']) if hasTurnOver5 else turnover_sort #todo - print('code:',code ,' turnover5_sort:',prevIndustryDataMap[code]['turnover5_sort']) turnover5_sort_change = Decimal(prevIndustryDataMap[code]['turnover5_sort']) - turnover5_sort if hasPrevIndustryData else turnover5_sort #todo turnover10 = Decimal(turnOver10[code]['turnover']) if hasTurnOver10 else turnover #todo turnover10_change = turnover10 - Decimal(prevIndustryDataMap[code]['turnover10']) if hasPrevIndustryData else turnover10 #todo @@ -361,29 +360,29 @@ def main(): losses_number_change = losses_number - Decimal(prevIndustryDataMap[code]['losses_number']) if hasPrevIndustryData else losses_number #todo flat_number_change = flat_number - Decimal(prevIndustryDataMap[code]['flat_number']) if hasPrevIndustryData else flat_number #todo rise5_number = Decimal(periodUpDownMap5[code]['rise']) #todo - rise5_number_change = rise5_number - Decimal(periodUpDownMap5[code]['rise']) if hasPeriodUpDownMap5 else rise5_number #todo + rise5_number_change = rise5_number - Decimal(prevIndustryDataMap[code]['rise5_number']) if hasPrevIndustryData else rise5_number #todo losses5_number = Decimal(periodUpDownMap5[code]['fall']) #todo - losses5_number_change = losses5_number - Decimal(periodUpDownMap5[code]['fall']) if hasPeriodUpDownMap5 else losses5_number #todo + losses5_number_change = losses5_number - Decimal(prevIndustryDataMap[code]['losses5_number']) if hasPrevIndustryData else losses5_number #todo flat5_number = Decimal(periodUpDownMap5[code]['flat']) #todo - flat5_number_change = flat5_number - Decimal(periodUpDownMap5[code]['flat']) if hasPeriodUpDownMap5 else flat5_number #todo + flat5_number_change = flat5_number - Decimal(prevIndustryDataMap[code]['flat5_number']) if hasPrevIndustryData else flat5_number #todo rise10_number = Decimal(periodUpDownMap10[code]['rise']) #todo - rise10_number_change = rise10_number - Decimal(periodUpDownMap10[code]['rise']) if hasPeriodUpDownMap10 else rise10_number #todo + rise10_number_change = rise10_number - Decimal(prevIndustryDataMap[code]['rise10_number']) if hasPrevIndustryData else rise10_number #todo losses10_number = Decimal(periodUpDownMap10[code]['fall']) #todo - losses10_number_change = losses10_number - Decimal(periodUpDownMap10[code]['fall']) if hasPeriodUpDownMap10 else losses10_number #todo + losses10_number_change = losses10_number - Decimal(prevIndustryDataMap[code]['losses10_number']) if hasPrevIndustryData else losses10_number #todo flat10_number = Decimal(periodUpDownMap10[code]['flat']) #todo - flat10_number_change = flat10_number - Decimal(periodUpDownMap10[code]['flat']) if hasPeriodUpDownMap10 else flat10_number #todo + flat10_number_change = flat10_number - Decimal(prevIndustryDataMap[code]['flat10_number']) if hasPrevIndustryData else flat10_number #todo rise20_number = Decimal(periodUpDownMap20[code]['rise']) #todo - rise20_number_change = rise20_number - Decimal(periodUpDownMap20[code]['rise']) if hasPeriodUpDownMap20 else rise20_number#todo + rise20_number_change = rise20_number - Decimal(prevIndustryDataMap[code]['rise20_number']) if hasPrevIndustryData else rise20_number#todo losses20_number = Decimal(periodUpDownMap20[code]['fall']) #todo - losses20_number_change = losses20_number - Decimal(periodUpDownMap20[code]['fall']) if hasPeriodUpDownMap20 else losses20_number #todo + losses20_number_change = losses20_number - Decimal(prevIndustryDataMap[code]['losses20_number']) if hasPrevIndustryData else losses20_number #todo flat20_number = Decimal(periodUpDownMap20[code]['flat']) #todo - flat20_number_change = flat20_number - Decimal(periodUpDownMap20[code]['flat']) if hasPeriodUpDownMap20 else flat20_number #todo + flat20_number_change = flat20_number - Decimal(prevIndustryDataMap[code]['flat20_number']) if hasPrevIndustryData else flat20_number #todo rise30_number = Decimal(periodUpDownMap30[code]['rise']) #todo - rise30_number_change = rise30_number - Decimal(periodUpDownMap30[code]['rise']) if hasPeriodUpDownMap30 else rise30_number #todo + rise30_number_change = rise30_number - Decimal(prevIndustryDataMap[code]['rise30_number']) if hasPrevIndustryData else rise30_number #todo losses30_number = Decimal(periodUpDownMap30[code]['fall']) #todo - losses30_number_change = losses30_number - Decimal(periodUpDownMap30[code]['fall']) if hasPeriodUpDownMap30 else losses30_number #todo + losses30_number_change = losses30_number - Decimal(prevIndustryDataMap[code]['losses30_number']) if hasPrevIndustryData else losses30_number #todo flat30_number = Decimal(periodUpDownMap30[code]['flat']) #todo - flat30_number_change = flat30_number - Decimal(periodUpDownMap30[code]['flat']) if hasPeriodUpDownMap30 else flat30_number #todo + flat30_number_change = flat30_number - Decimal(prevIndustryDataMap[code]['flat30_number']) if hasPrevIndustryData else flat30_number #todo # create_time = # sql_insert = f"INSERT INTO dong_cai_secondary_industry (business_date,sort,security_code,security_name,security_type,number_ingredients,opening_price,closing_price,volume,turnover,total_capitalization,free_capitalization,change_percentage,highest_price,lowest_price,rise_number,losses_number,flat_number,rise_stop_number,losses_stop_number,stop_number,recently_high,recently_low,pe_ttm,pe_center_ttm) VALUES ( %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s,%s, %s, %s, %s)" # db_b_cursor.execute(sql_insert, (business_date,sort,security_code,security_name,security_type,number_ingredients,opening_price,closing_price,volume,turnover,total_capitalization,free_capitalization,change_percentage,highest_price,lowest_price,rise_number,losses_number,flat_number,rise_stop_number,losses_stop_number,stop_number,recently_high,recently_low,pe_ttm,pe_center_ttm))