Commit 0483b2b5 authored by wang zhengwei's avatar wang zhengwei

修复tamp fund表,应该使用tamp product

parent 349fb21f
...@@ -235,10 +235,10 @@ def get_tamp_fund(): ...@@ -235,10 +235,10 @@ def get_tamp_fund():
Returns: Returns:
""" """
with TAMP_SQL(tamp_fund_engine) as tamp_fund: with TAMP_SQL(tamp_product_engine) as tamp_prod:
tamp_fund_session = tamp_fund.session tamp_prod_session = tamp_prod.session
sql = "SELECT id FROM tamp_fund_info WHERE id LIKE 'HF%'" sql = "SELECT id FROM fund_info WHERE `status` = 1 and strategy!=7"
cur = tamp_fund_session.execute(sql) cur = tamp_prod_session.execute(sql)
data = cur.fetchall() data = cur.fetchall()
# df = pd.read_sql(sql, con) # df = pd.read_sql(sql, con)
df = pd.DataFrame(list(data), columns=['fund_id']) df = pd.DataFrame(list(data), columns=['fund_id'])
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment