fish/finance-talk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

删除合约/品种时同步清空对应行情数据

Browse Source
This commit is contained in:
fish
2026-07-24 22:55:39 +08:00
parent 57f792fbe5
commit de62f0779b
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
ft-app/app/routers/admin.py
+3
View File
@@ -112,6 +112,7 @@ def toggle_contract(contract_id: int, db: Session = Depends(get_db)):
def delete_contract(contract_id: int, db: Session = Depends(get_db)): def delete_contract(contract_id: int, db: Session = Depends(get_db)):
c = db.query(Contract).filter(Contract.id == contract_id).first() c = db.query(Contract).filter(Contract.id == contract_id).first()
if c: if c:
db.query(DailyBar).filter(DailyBar.contract == c.code).delete()
db.delete(c) db.delete(c)
db.commit() db.commit()
return RedirectResponse("/admin/?tab=contract", status_code=303) return RedirectResponse("/admin/?tab=contract", status_code=303)
@@ -121,6 +122,8 @@ def delete_contract(contract_id: int, db: Session = Depends(get_db)):
def delete_product(product_id: int, db: Session = Depends(get_db)): def delete_product(product_id: int, db: Session = Depends(get_db)):
p = db.query(Product).filter(Product.id == product_id).first() p = db.query(Product).filter(Product.id == product_id).first()
if p: if p:
for c in p.contracts:
db.query(DailyBar).filter(DailyBar.contract == c.code).delete()
db.delete(p) db.delete(p)
db.commit() db.commit()
return RedirectResponse("/admin/?tab=product", status_code=303) return RedirectResponse("/admin/?tab=product", status_code=303)