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-06-10 12:44:01 +08:00
parent 004902ae72
commit 5a37459e5f
2 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
db/task_db.py
View File

@@ -219,12 +219,14 @@ class TaskDBOperator(BaseDBOperator):
%s, %s, %s, %s, %s %s, %s, %s, %s, %s
) )
""" """
# 将changes字典转换为JSON字符串
changes_json = json.dumps(log_data['changes'], ensure_ascii=False)
params = ( params = (
log_data['log_id'], log_data['log_id'],
log_data['task_id'], log_data['task_id'],
log_data['action'], log_data['action'],
log_data['user_id'], log_data['user_id'],
log_data['changes'] changes_json
) )
return self.execute_update(sql, params) return self.execute_update(sql, params)
except Exception as e: except Exception as e:

12
plugins/message_push_task/main.py
View File

@@ -150,7 +150,9 @@ class MessagePushTask(MessagePluginInterface):
}) })
# 发送消息到目标群组 # 发送消息到目标群组
bot = self.event_system.get_bot() if not self.bot:
raise Exception("机器人实例未初始化")
success_count = 0 success_count = 0
fail_count = 0 fail_count = 0
@@ -158,19 +160,19 @@ class MessagePushTask(MessagePluginInterface):
try: try:
# 发送文本消息 # 发送文本消息
if content_text: if content_text:
await bot.send_text_message(group_id, content_text) await self.bot.send_text_message(group_id, content_text)
# 发送图片消息 # 发送图片消息
if content_image: if content_image:
await bot.send_image_message(group_id, content_image) await self.bot.send_image_message(group_id, content_image)
# 发送链接消息 # 发送链接消息
if content_link: if content_link:
await bot.send_link_message(group_id, content_link) await self.bot.send_link_message(group_id, content_link)
# 发送小程序消息 # 发送小程序消息
if content_miniprogram: if content_miniprogram:
await bot.send_miniprogram_message( await self.bot.send_miniprogram_message(
group_id, group_id,
content_miniprogram.get('title'), content_miniprogram.get('title'),
content_miniprogram.get('appid'), content_miniprogram.get('appid'),