diff --git a/app/core/redis_client.py b/app/core/redis_client.py index 58c5646..918aeda 100644 --- a/app/core/redis_client.py +++ b/app/core/redis_client.py @@ -93,7 +93,7 @@ class RedisClient: logging.error(f"添加新订单到队列失败: {str(e)}") return False - def pop_new_orders_from_queue(self, user_id: int, count: int = 10) -> List[str]: + def pop_new_orders_from_queue(self, user_id: int) -> List[str]: """ 获取社区新订单列表 @@ -108,7 +108,7 @@ class RedisClient: try: key = f"deliveryman:{user_id}:new_orders" # 获取订单列表, - orders = self.client.lpop(key, count) + orders = self.client.lpop(key) return orders except Exception as e: logging.error(f"获取社区新订单列表失败: {str(e)}") diff --git a/jobs.sqlite b/jobs.sqlite index 11cba6e..c5d4190 100644 Binary files a/jobs.sqlite and b/jobs.sqlite differ