小年糕账号

core/models/rule_models.py

@@ -9,11 +9,11 @@ class RuleField(BaseModel):
     min: Union[int, float] = 0
     max: Union[int, float] = 0
 
-    @validator('max')
-    def validate_min_max(cls, v, values, field):
-        if 'min' in values and v != 0 and values['min'] > v:
-            raise ValueError('min value cannot be greater than max value')
-        return v
+    # @validator('max')
+    # def validate_min_max(cls, v, values, field):
+    #     if 'min' in values and v != 0 and values['min'] > v:
+    #         raise ValueError('min value cannot be greater than max value')
+    #     return v
 
 
 class RuleModel(BaseModel):

services/async_mysql_service.py

@@ -161,7 +161,8 @@ class AsyncMysqlService:
         return result["cnt"] if result else 0
 
     async def get_xng_mid(self) -> int:
-        sql = """select uid,link,nick_name from crawler_user_v3 where task_id=21;"""
+        #  order by `create_time` desc
+        sql = """select uid,link,nick_name from crawler_user_v3 where task_id=21"""
         result = await self.fetch_all(sql)
         return result if result else 0
 

services/pipeline.py

@@ -25,11 +25,11 @@ class PiaoQuanPipeline:
         self.account = account
 
         # 使用Pydantic模型验证规则字典
-        try:
-            self.validated_rules = RuleModel(**rule_dict)
-        except Exception as e:
-            LoggerManager.get_logger(platform=platform, mode=mode).warning(f"规则验证失败: {e}")
-            self.validated_rules = None
+        # try:
+        #     self.validated_rules = RuleModel(**rule_dict)
+        # except Exception as e:
+        #     LoggerManager.get_logger(platform=platform, mode=mode).warning(f"规则验证失败: {e}")
+        #     self.validated_rules = None
 
         self.mysql = AsyncMysqlService(platform=platform, mode=mode)
         self.logger = LoggerManager.get_logger(platform=platform, mode=mode)