feat: 移除大转盘中奖记录采集任务

main.py

@@ -4,6 +4,12 @@
 
 from jobs import DEPLOYMENTS
 from models import MODELS
+from models.new.jianshu.article_earning_ranking_record import (
+    ArticleEarningRankingRecord,
+)
+from models.new.jianshu.assets_ranking_record import AssetsRankingRecord
+from models.new.jianshu.daily_update_ranking_record import DailyUpdateRankingRecord
+from models.new.jianshu.user import User
 from utils.log import logger
 
 
@@ -12,6 +18,12 @@ async def main() -> None:
     for model in MODELS:
         await model.ensure_indexes()
     logger.info("索引创建完成")
+    logger.info("正在初始化新版数据库")
+    await ArticleEarningRankingRecord.init()
+    await AssetsRankingRecord.init()
+    await DailyUpdateRankingRecord.init()
+    await User.init()
+    logger.info("初始化新版数据库完成")
 
     logger.info("启动工作流")
     await serve(*DEPLOYMENTS, print_starting_message=False)  # type: ignore

models/__init__.py

@@ -3,7 +3,6 @@
 from .jianshu.article_earning_ranking_record import ArticleEarningRankingRecordDocument
 from .jianshu.assets_ranking_record import AssetsRankingRecordDocument
 from .jianshu.daily_update_ranking_record import DailyUpdateRankingRecordDocument
-from .jianshu.lottery_win_record import LotteryWinRecordDocument
 from .jianshu.user import UserDocument as JianshuUserDocument
 from .jpep.credit_history import CreditHistoryDocument
 from .jpep.ftn_trade_order import FTNTradeOrderDocument
@@ -13,7 +12,6 @@
     ArticleEarningRankingRecordDocument,
     AssetsRankingRecordDocument,
     DailyUpdateRankingRecordDocument,
-    LotteryWinRecordDocument,
     JianshuUserDocument,
     CreditHistoryDocument,
     FTNTradeOrderDocument,