|
|
@@ -24,7 +24,7 @@ class CooperateAccountsMonitorTaskConst:
|
|
|
HAS_MINI_PROGRAM = 1
|
|
|
DONT_HAS_MINI_PROGRAM = 0
|
|
|
|
|
|
- ARTICLE_NUM = 500
|
|
|
+ ARTICLE_NUM = 200
|
|
|
|
|
|
|
|
|
class CooperateAccountsMonitorTaskUtils(CooperateAccountsMonitorTaskConst):
|
|
|
@@ -340,7 +340,8 @@ class CooperateAccountsMonitorTask(CooperateAccountsMonitorMapper):
|
|
|
# 获取待处理的文章
|
|
|
async def get_article_list(self):
|
|
|
query = """
|
|
|
- SELECT wx_sn, article_link FROM cooperate_accounts_daily_detail WHERE fetch_status = %s LIMIT %s;
|
|
|
+ SELECT wx_sn, article_link FROM cooperate_accounts_daily_detail
|
|
|
+ WHERE fetch_status = %s ORDER BY position LIMIT %s;
|
|
|
"""
|
|
|
return await self.pool.async_fetch(
|
|
|
query=query, params=(self.INIT_STATUS, self.ARTICLE_NUM)
|