|
@@ -388,17 +388,12 @@ class AutoReplyCardsMonitorMapper(AutoReplyCardsMonitorUtils):
|
|
|
|
|
|
|
|
# 获取带解析的任务
|
|
# 获取带解析的任务
|
|
|
async def get_extract_tasks(self):
|
|
async def get_extract_tasks(self):
|
|
|
- # query = """
|
|
|
|
|
- # SELECT task_id, result FROM cooperate_accounts_task WHERE extract_status = %s AND task_status = %s;
|
|
|
|
|
- # """
|
|
|
|
|
- # return await self.pool.async_fetch(
|
|
|
|
|
- # query=query, params=(self.INIT_STATUS, self.SUCCESS_STATUS)
|
|
|
|
|
- # )
|
|
|
|
|
-
|
|
|
|
|
query = """
|
|
query = """
|
|
|
- SELECT task_id, result FROM cooperate_accounts_task WHERE task_id = 'auto_reply_08faad23-7e2b-414f-a422-7472d8354b30';
|
|
|
|
|
- """
|
|
|
|
|
- return await self.pool.async_fetch(query=query)
|
|
|
|
|
|
|
+ SELECT task_id, result FROM cooperate_accounts_task WHERE extract_status = %s AND task_status = %s;
|
|
|
|
|
+ """
|
|
|
|
|
+ return await self.pool.async_fetch(
|
|
|
|
|
+ query=query, params=(self.INIT_STATUS, self.SUCCESS_STATUS)
|
|
|
|
|
+ )
|
|
|
|
|
|
|
|
# 存储解析结果
|
|
# 存储解析结果
|
|
|
async def store_extract_result(self, query, row_table):
|
|
async def store_extract_result(self, query, row_table):
|