feat: 挂载核心股路由并启动每日采集任务

Co-Authored-By: Claude <noreply@anthropic.com>
This commit is contained in:
Sakurasan
2026-08-10 20:20:55 +08:00
co-authored by Claude
parent ffabf3d396
commit 6b12b04cab
+9 -2
View File
@@ -1,3 +1,4 @@
import asyncio
import os
from fastapi import FastAPI
from fastapi.middleware.cors import CORSMiddleware
@@ -6,7 +7,8 @@ from contextlib import asynccontextmanager
from dotenv import load_dotenv
from database import init_db
from routes import stock, collections, shares, sectors, themes
from routes import stock, collections, shares, sectors, themes, core_stocks
from services.daily_collector import collector_loop
load_dotenv()
@@ -14,7 +16,11 @@ load_dotenv()
@asynccontextmanager
async def lifespan(app: FastAPI):
init_db()
yield
collector_task = asyncio.create_task(collector_loop())
try:
yield
finally:
collector_task.cancel()
app = FastAPI(title="AUV API", version="1.0.0", lifespan=lifespan)
@@ -32,6 +38,7 @@ app.include_router(collections.router, prefix="/api/collections")
app.include_router(shares.router, prefix="/api/share")
app.include_router(sectors.router, prefix="/api/sectors")
app.include_router(themes.router, prefix="/api/themes")
app.include_router(core_stocks.router, prefix="/api/core-stocks")
# 生产模式:后端同时托管前端静态文件
# catch-all 路由在 API 路由之后注册,所以 API 优先级更高