| 
					
				 | 
			
			
				@@ -852,12 +852,21 @@ class NewContentIdTask(object): 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                         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( 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                     title="KIMI 处理失败", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                     detail={ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                         "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): 
			 |