fix: 增加查询统计数据及变量定义

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
+            turnover_sort = sortIndex
-            free_capitalization = liqmv
+            sortIndex +=1
-            change_percentage = differrange
+            turnover_change = '' #todo
-            highest_price = high
+            turnover_ratio = '' #todo
-            lowest_price = low
+            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
+            flat_number_change = '' #todo
-            losses_stop_number = limitdownnum
+            rise5_number = '' #todo
-            stop_number = suspendnum
+            rise5_number_change = ''#todo
-            recently_high = rcnthigh
+            losses5_number = '' #todo
-            recently_low = rcntlow
+            losses5_number_change = '' #todo
-            pe_ttm= pettm
+            flat5_number = '' #todo
-            pe_center_ttm = pettm_mid
+            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))