1 changed files with 1 additions and 1 deletions
+ 1
- 1
app/endpoints/pipeline_endpoint.py
View File
| @@ -1067,7 +1067,7 @@ async def handle_add_friend_notice_async(request: Request,token_id,app_id, wxid, | |||
| input_wx_content_dialogue_message=[{"type": "text", "text": msg_content}] | |||
| input_message=dialogue_message(to_contact_wxid,wxid,input_wx_content_dialogue_message) | |||
| await request.app.state.gewe_service.send_message_async(input_message) | |||
| await request.app.state.kafka_service.send_message_async(input_message) | |||
| logger.info("发送对话 %s",input_message) | |||
| callback_to_user=to_contact_wxid | |||
Loading…