feat: 创建文档模型时进行数据校验

jobs/fetch_article_earning_ranking_records.py

@@ -93,7 +93,7 @@ async def process_item(
             to_author=item.fp_to_author_anount,
             to_voter=item.fp_to_voter_amount,
         ),
-    )
+    ).validate()
 
 
 @flow(

jobs/fetch_assets_ranking_records.py

@@ -84,7 +84,7 @@ async def process_item(
             slug=item.user_info.slug,
             name=item.user_info.name,
         ),
-    )
+    ).validate()
 
 
 @flow(

jobs/fetch_daily_update_ranking_records.py

@@ -43,7 +43,7 @@ def process_item(
             slug=item.user_info.slug,
             name=item.user_info.name,
         ),
-    )
+    ).validate()
 
 
 @flow(

jobs/fetch_jianshu_lottery_win_records.py

@@ -53,7 +53,7 @@ def process_item(item: JianshuLotteryWinRecord, /) -> JianshuLotteryWinRecordDoc
             slug=item.user_info.slug,
             name=item.user_info.name,
         ),
-    )
+    ).validate()
 
 
 @flow(

jobs/fetch_jpep_ftn_trade_orders.py

@@ -81,7 +81,7 @@ def process_item(
             hashed_name=item.publisher_info.hashed_name,
             credit=item.publisher_info.credit,
         ),
-    )
+    ).validate()
 
 
 @flow(

utils/document_model.py

@@ -22,6 +22,9 @@ class Field(Struct, **FIELD_OBJECT_CONFIG):
 class Documemt(Struct, **DOCUMENT_OBJECT_CONFIG):
     _id: ObjectId
 
+    def validate(self) -> Self:
+        return convert(to_builtins(self), type=self.__class__)
+
     @classmethod
     def from_dict(cls, data: Dict[str, Any]) -> Self:
         return convert(data, type=cls)