|
@@ -852,12 +852,21 @@ class NewContentIdTask(object):
|
|
|
NewContentIdTaskConst.TASK_INIT_STATUS
|
|
NewContentIdTaskConst.TASK_INIT_STATUS
|
|
|
)
|
|
)
|
|
|
)
|
|
)
|
|
|
|
|
+ # 查询出该content_id所对应的标题
|
|
|
|
|
+ select_sql = f"""
|
|
|
|
|
+ SELECT article_title
|
|
|
|
|
+ FROM {self.article_text_table}
|
|
|
|
|
+ WHRER content_id = '{content_id}';
|
|
|
|
|
+ """
|
|
|
|
|
+ result = await self.mysql_client.async_select(select_sql)
|
|
|
bot(
|
|
bot(
|
|
|
title="KIMI 处理失败",
|
|
title="KIMI 处理失败",
|
|
|
detail={
|
|
detail={
|
|
|
"content_id": content_id,
|
|
"content_id": content_id,
|
|
|
- "affected_rows": affected_rows
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ "affected_rows": affected_rows,
|
|
|
|
|
+ "article_title": result[0][0]
|
|
|
|
|
+ },
|
|
|
|
|
+ mention=False
|
|
|
)
|
|
)
|
|
|
|
|
|
|
|
async def process_task(self, params):
|
|
async def process_task(self, params):
|
