liuwei_x_x/abot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加聊天功能

Browse Source
This commit is contained in:
liuwei
2025-05-29 16:09:35 +08:00
parent 20a72cd41f
commit 949a3cbd07
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
admin/dashboard/blueprints/contacts.py
View File

@@ -216,7 +216,7 @@ def api_send_message():
# 获取机器人实例 # 获取机器人实例
server = current_app.dashboard_server server = current_app.dashboard_server
if not server or not server.robot: if not server or not server.client:
return jsonify({'success': False, 'message': '机器人未初始化'}) return jsonify({'success': False, 'message': '机器人未初始化'})
# 创建事件循环 # 创建事件循环
@@ -226,7 +226,7 @@ def api_send_message():
# 根据消息类型调用不同的发送方法 # 根据消息类型调用不同的发送方法
if msg_type == 'text': if msg_type == 'text':
client_msg_id, create_time, new_msg_id = loop.run_until_complete( client_msg_id, create_time, new_msg_id = loop.run_until_complete(
server.robot.send_text_message(wxid, content) server.client.send_text_message(wxid, content)
) )
return jsonify({ return jsonify({
'success': True, 'success': True,
@@ -242,7 +242,7 @@ def api_send_message():
return jsonify({'success': False, 'message': '未上传文件'}) return jsonify({'success': False, 'message': '未上传文件'})
file = request.files['file'] file = request.files['file']
client_msg_id, create_time, new_msg_id = loop.run_until_complete( client_msg_id, create_time, new_msg_id = loop.run_until_complete(
server.robot.send_image_message(wxid, file.read()) server.client.send_image_message(wxid, file.read())
) )
return jsonify({ return jsonify({
'success': True, 'success': True,
@@ -258,7 +258,7 @@ def api_send_message():
return jsonify({'success': False, 'message': '未上传文件'}) return jsonify({'success': False, 'message': '未上传文件'})
file = request.files['file'] file = request.files['file']
client_msg_id, create_time, new_msg_id = loop.run_until_complete( client_msg_id, create_time, new_msg_id = loop.run_until_complete(
server.robot.send_voice_message(wxid, file.read()) server.client.send_voice_message(wxid, file.read())
) )
return jsonify({ return jsonify({
'success': True, 'success': True,
@@ -274,7 +274,7 @@ def api_send_message():
return jsonify({'success': False, 'message': '未上传文件'}) return jsonify({'success': False, 'message': '未上传文件'})
file = request.files['file'] file = request.files['file']
client_msg_id, new_msg_id = loop.run_until_complete( client_msg_id, new_msg_id = loop.run_until_complete(
server.robot.send_video_message(wxid, file.read()) server.client.send_video_message(wxid, file.read())
) )
return jsonify({ return jsonify({
'success': True, 'success': True,
@@ -289,7 +289,7 @@ def api_send_message():
title = content.get('title', '') title = content.get('title', '')
description = content.get('description', '') description = content.get('description', '')
client_msg_id, create_time, new_msg_id = loop.run_until_complete( client_msg_id, create_time, new_msg_id = loop.run_until_complete(
server.robot.send_link_message(wxid, url, title, description) server.client.send_link_message(wxid, url, title, description)
) )
return jsonify({ return jsonify({
'success': True, 'success': True,