diff --git a/transferIndustrySatistics_python.py b/transferIndustrySatistics_python.py index fa7de25..21d3227 100644 --- a/transferIndustrySatistics_python.py +++ b/transferIndustrySatistics_python.py @@ -55,6 +55,7 @@ try: db_a_cursor.execute(sql_trade_qurey,sql_trade) trading_dates = db_a_cursor.fetchall() + # 查询交易日期 - 交易日的指数数据 - 计算周期数据 - 转存 queryType = ['1','5','10','20','30'] #查询类型 testRet = 0 for row in trading_dates: @@ -93,7 +94,7 @@ try: print('start transfer statistics ',trading_date , ' data.') #查询日交易数据 - sql_stock_query = 'select code,name,trade_day, open,close,high,low,differrange,volume,amount,limitupnum,limitdownnum,suspendnum,risenum,fallnum,flatnum,componentnum,mv,pettm,pettm_mid,liqmv,rcnthigh,rcntlow from stock_index where trade_day = %s' + sql_stock_query = 'select code,name,trade_day, open,close,high,low,differrange,volume,amount,limitupnum,limitdownnum,suspendnum,risenum,fallnum,flatnum,componentnum,mv,pettm,pettm_mid,liqmv,rcnthigh,rcntlow from stock_index where trade_day = %s order by volume DESC' db_a_cursor.execute(sql_stock_query,trading_date) datas = db_a_cursor.fetchall() sortIndex = 1 @@ -101,31 +102,69 @@ try: for stock_index_data in datas: code,name,trade_day, open,close,high,low,differrange,volumn,amount,limitupnum,limitdownnum,suspendnum,risenum,fallnum,flatnum,componentnum,mv,pettm,pettm_mid,liqmv,rcnthigh,rcntlow = stock_index_data business_date = trading_date - sort = sortIndex - sortIndex +=1 security_code = code security_name = name - security_type = 'EI' - number_ingredients = componentnum - opening_price = open - closing_price = close - volume = volumn turnover = amount - total_capitalization = mv - free_capitalization = liqmv - change_percentage = differrange - highest_price = high - lowest_price = low + turnover_sort = sortIndex + sortIndex +=1 + turnover_change = '' #todo + turnover_ratio = '' #todo + turnover_ratio_change = '' #todo + turnover_sort_change = ''#todo + turnover5 = '' #todo + turnover5_change = '' #todo + turnover5_ratio = '' #todo + turnover5_ratio_change = '' #todo + turnover5_sort = '' #todo + turnover5_sort_change = ''#todo + turnover10 = '' #todo + turnover10_change = '' #todo + turnover10_ratio = '' #todo + turnover10_ratio_change = '' #todo + turnover10_sort = '' #todo + turnover10_sort_change = ''#todo + turnover20 = '' #todo + turnover20_change = '' #todo + turnover20_ratio = '' #todo + turnover20_ratio_change = '' #todo + turnover20_sort = '' #todo + turnover20_sort_change = ''#todo + turnover30 = '' #todo + turnover30_change = '' #todo + turnover30_ratio = '' #todo + turnover30_ratio_change = '' #todo + turnover30_sort = '' #todo + turnover30_sort_change = ''#todo rise_number = risenum + rise_number_change = ''#todo losses_number = fallnum + losses_number_change = '' #todo flat_number = flatnum - rise_stop_number = limitupnum - losses_stop_number = limitdownnum - stop_number = suspendnum - recently_high = rcnthigh - recently_low = rcntlow - pe_ttm= pettm - pe_center_ttm = pettm_mid + flat_number_change = '' #todo + rise5_number = '' #todo + rise5_number_change = ''#todo + losses5_number = '' #todo + losses5_number_change = '' #todo + flat5_number = '' #todo + flat5_number_change = '' #todo + rise10_number = '' #todo + rise10_number_change = ''#todo + losses10_number = '' #todo + losses10_number_change = '' #todo + flat10_number = '' #todo + flat10_number_change = '' #todo + rise20_number = '' #todo + rise20_number_change = ''#todo + losses20_number = '' #todo + losses20_number_change = '' #todo + flat20_number = '' #todo + flat20_number_change = '' #todo + rise30_number = '' #todo + rise30_number_change = ''#todo + losses30_number = '' #todo + losses30_number_change = '' #todo + flat30_number = '' #todo + flat30_number_change = '' #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))