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

解决bug

Browse Source
This commit is contained in:
liuwei
2025-06-10 17:30:40 +08:00
parent 7b08e8dec8
commit e08c5fa5c4
1 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
plugins/message_push_task/main.py
View File

@@ -142,14 +142,21 @@ class MessagePushTask(MessagePluginInterface):
recurring_time = task.get('recurring_time') recurring_time = task.get('recurring_time')
if recurring_time: if recurring_time:
try: try:
hour, minute = map(int, recurring_time.split(':')) # 处理带秒数的时间格式
time_parts = recurring_time.split(':')
if len(time_parts) == 3:
hour, minute, second = map(int, time_parts)
else:
hour, minute = map(int, time_parts)
second = 0
# 检查当前时间是否在目标时间的前后5秒内 # 检查当前时间是否在目标时间的前后5秒内
target_time = now.replace(hour=hour, minute=minute, second=0, microsecond=0) target_time = now.replace(hour=hour, minute=minute, second=second, microsecond=0)
time_diff = abs((now - target_time).total_seconds()) time_diff = abs((now - target_time).total_seconds())
if time_diff > 5: # 允许5秒的误差 if time_diff > 5: # 允许5秒的误差
continue continue
except (ValueError, AttributeError): except (ValueError, AttributeError) as e:
self.LOG.error(f"无效的执行时间格式: {recurring_time}") self.LOG.error(f"无效的执行时间格式: {recurring_time}, 错误: {e}")
continue continue
# 更新任务状态为执行中 # 更新任务状态为执行中