|
@@ -11,7 +11,7 @@ import logging
|
|
|
|
|
|
|
|
from src.infra.xxl_jobs import xxl_job
|
|
from src.infra.xxl_jobs import xxl_job
|
|
|
from src.domains.content_supply import DemandSearchArticle, ContentSupplyConst
|
|
from src.domains.content_supply import DemandSearchArticle, ContentSupplyConst
|
|
|
-from src.handlers._utils import get_db, parse_params
|
|
|
|
|
|
|
+from src.handlers._utils import get_db, parse_params, parse_limit
|
|
|
|
|
|
|
|
logger = logging.getLogger(__name__)
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
|
@@ -20,7 +20,7 @@ logger = logging.getLogger(__name__)
|
|
|
async def article_search(param: str) -> dict:
|
|
async def article_search(param: str) -> dict:
|
|
|
p = parse_params(param)
|
|
p = parse_params(param)
|
|
|
dt = p.get("dt") or None
|
|
dt = p.get("dt") or None
|
|
|
- limit = ContentSupplyConst.SEARCH_DEAL_LIMIT
|
|
|
|
|
|
|
+ limit = parse_limit(param, ContentSupplyConst.SEARCH_DEAL_LIMIT)
|
|
|
logger.info("articleSearch started, dt=%s, limit=%d", dt, limit)
|
|
logger.info("articleSearch started, dt=%s, limit=%d", dt, limit)
|
|
|
|
|
|
|
|
try:
|
|
try:
|