feat: 增加新高表数据转存

transferIndustryData_python.py

@@ -1,42 +1,42 @@
 #导入指数数据
 import pymysql
 
-# 数据库A的连接信息；NAS数据库
-# db_a_config = {
-#     'host': '192.168.0.222',
-#     'user': 'root',
-#     'password': '1qazse42W3',
-#     'db': 'ry',
-#     'charset': 'utf8mb4',
-# }
-
-# # 数据库B的连接信息；NAS数据库
-# db_b_config = {
-#     'host': '192.168.0.222',
-#     'user': 'root',
-#     'password': '1qazse42W3',
-#     'db': 'mojin',
-#     'charset': 'utf8mb4',
-# }
-
-# 数据库A的连接信息；腾讯云数据库
+#数据库A的连接信息；NAS数据库
 db_a_config = {
-    'host': '124.223.98.178',
+    'host': '192.168.0.222',
     'user': 'root',
     'password': '1qazse42W3',
     'db': 'ry',
     'charset': 'utf8mb4',
 }
 
-# 数据库B的连接信息；腾讯云数据库
+# 数据库B的连接信息；NAS数据库
 db_b_config = {
-    'host': '124.223.98.178',
+    'host': '192.168.0.222',
     'user': 'root',
     'password': '1qazse42W3',
     'db': 'mojin',
     'charset': 'utf8mb4',
 }
 
+# # 数据库A的连接信息；腾讯云数据库
+# db_a_config = {
+#     'host': '124.223.98.178',
+#     'user': 'root',
+#     'password': '1qazse42W3',
+#     'db': 'ry',
+#     'charset': 'utf8mb4',
+# }
+
+# # 数据库B的连接信息；腾讯云数据库
+# db_b_config = {
+#     'host': '124.223.98.178',
+#     'user': 'root',
+#     'password': '1qazse42W3',
+#     'db': 'mojin',
+#     'charset': 'utf8mb4',
+# }
+
 try:
     # 连接数据库A
     db_a_conn = pymysql.connect(**db_a_config)
@@ -58,7 +58,7 @@ try:
         trading_date,week,trade = row
         print('start transfer ',trading_date , ' data.')
         #查询日交易数据
-        sql_stock_query = 'select code,trade_day, open,close,high,low,differrange,volumn,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'
         db_a_cursor.execute(sql_stock_query,trading_date)
         datas = db_a_cursor.fetchall()
         sortIndex = 1
@@ -92,8 +92,8 @@ try:
             pe_ttm= pettm
             pe_center_ttm = pettm_mid
             # 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     rise_losses_current_day,dong_cai_industry_index_level2,dong_cai_industry_index_level3,range_rise_losses20,range_rise_losses10,range_rise_losses60,initial_listing_date,number_days_available,volume,turnover,dong_cai_industry_index_code2,free_capitalization,average_volume_day20,total_institutional_positions,rise_stop,losses_stop) 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, %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     rise_losses_current_day,dong_cai_industry_index_level2,dong_cai_industry_index_level3,range_rise_losses20,range_rise_losses10,range_rise_losses60,initial_listing_date,number_days_available,volume,turnover,dong_cai_industry_index_code2,free_capitalization,average_volume_day20,total_institutional_positions,rise_stop,losses_stop))
+            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))
         #提交数据到数据库B中 
         db_b_conn.commit()
         print('successed transfer ',trading_date , ' data.' )