fix: 同步数据0814

master
laixingyu 3 years ago
parent b9ada44046
commit 06c7ce99a5

@ -32,7 +32,7 @@ def main() :
db_b_conn = pymysql.connect(**db_b_config) db_b_conn = pymysql.connect(**db_b_config)
db_b_cursor = db_b_conn.cursor() db_b_cursor = db_b_conn.cursor()
trade_date = '2023-08-11' trade_date = '2023-08-14'
#传输ry库其他数据 #传输ry库其他数据
trd.toTransRyOhterData(db_a_conn,db_a_cursor,db_b_conn,db_b_cursor,trade_date) trd.toTransRyOhterData(db_a_conn,db_a_cursor,db_b_conn,db_b_cursor,trade_date)

@ -329,7 +329,7 @@ def toTransStocksNewRecord(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date)
if code in mojin_stocksNeRecord_map: if code in mojin_stocksNeRecord_map:
continue continue
else: else:
sql_insert = f"INSERT INTO stocks_new_record (ode,trade_day,isHigh,isLow) VALUES ( %s, %s, %s, %s)" sql_insert = f"INSERT INTO stocks_new_record (code,trade_day,isHigh,isLow) VALUES ( %s, %s, %s, %s)"
db_mojin_cursor.execute(sql_insert, (code,trade_day,isHigh,isLow)) db_mojin_cursor.execute(sql_insert, (code,trade_day,isHigh,isLow))
hasInsertData = True hasInsertData = True
if hasInsertData: if hasInsertData:
@ -370,7 +370,7 @@ def toTransStocksTmp(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date):
if code in mojin_stocksTmp_map: if code in mojin_stocksTmp_map:
continue continue
else: else:
sql_insert = f"INSERT INTO stocks_new_record (code,trade_day,differrange3,differrange5,differrange15,differrange30) VALUES ( %s, %s, %s, %s,%s,%s)" sql_insert = f"INSERT INTO stocks_tmp (code,trade_day,differrange3,differrange5,differrange15,differrange30) VALUES ( %s, %s, %s, %s,%s,%s)"
db_mojin_cursor.execute(sql_insert, (code,trade_day,differrange3,differrange5,differrange15,differrange30)) db_mojin_cursor.execute(sql_insert, (code,trade_day,differrange3,differrange5,differrange15,differrange30))
hasInsertData = True hasInsertData = True
if hasInsertData: if hasInsertData:

Loading…
Cancel
Save