事件处理器或者预处理方法，能否拦截事件并对消息内容作出修改后再转发给其它低优先级事件处理器？

[colorthoro]

如题。目前想实现一个通用定时事件处理器。比如，已有一个内置echo命令，我想要10分钟后再echo，可以发送类似这样的命令：
/echo -t 10m -m 你好
实现一个高优先级的定时命令处理器，先拦截解析消息中的定时参数，-t 10m，然后线程阻塞或异步暂停10m，然后去除消息中的该参数再恢复事件的传播。如此，其它所有命令都可以设置定时处理。

[colorthoro]

@yanyongyu 大神🤩，教教🥲

[yanyongyu]

你可以用event pre processor来做处理，通过raise IgnoredException 来阻止事件传播，然后定时再广播事件

[colorthoro]

你可以用event pre processor来做处理，通过raise IgnoredException 来阻止事件传播，然后定时再广播事件

怎么把消息内容改了再广播事件呢？

[yanyongyu]

你可以直接修改消息事件的内容

[colorthoro]

感谢，一开始想给event重新赋值一个message，结果发现不行；原来可以直接修改message的内容😂。
后面用这种方法实现了用户命令倒计时执行，欢迎大家指教。

####################### 计时器钩子 #######################

timing_working_set = set()
on_cancel_timing = on_regex(r'^tcel\s*(-?\d+)$', permission=SUPERUSER)


@on_cancel_timing.handle()
async def _(arg: tuple = RegexGroup()):
    global timing_working_set
    t = int(arg[0])
    if t in timing_working_set:
        timing_working_set.remove(t)
        await on_cancel_timing.send(f'[{t}]\n倒计时已取消')
    else:
        await on_cancel_timing.send(f'[{t}]\n倒计时不存在')


async def timing_work(bot: Bot, event: MessageEvent, t: int, need_timing_echo: str, timing_echo: str):
    global timing_working_set
    timing_working_set.add(event.message_id)
    origin_t = t
    interval = -1
    if not need_timing_echo:
        interval = 10  # 保留一定间隔，以便及时取消
    elif timing_echo == 's':
        interval = 1
    elif timing_echo == 'm':
        interval = 60
    elif timing_echo == 'h':
        interval = 60 * 60
    elif timing_echo == 'd':
        interval = 60 * 60 * 24
    while t > 0:
        if need_timing_echo or t == origin_t:  # 首次和需要显示的时候显示
            # 将剩余秒数转为可读的时间显示
            m, s = divmod(t, 60)
            h, m = divmod(m, 60)
            d, h = divmod(h, 24)
            msg = f'{d}天' * bool(d) + f'{h}小时' * bool(h) + f'{m}分钟' * bool(m) + f'{s}秒' * bool(s)
            await bot.send(event, f'{event.raw_message}\n[{event.message_id}]\n倒计时：{msg}')
        if interval == -1:
            # 根据剩余时间动态调整间隔，最后5秒内每秒更新，最后5分钟内每分钟更新，最后5小时内每小时更新，更长时间内每天更新
            if t <= 5:
                interval = 1
            elif t <= 60*5:
                interval = min(60, t - 5)
            elif t <= 60*60*5:
                interval = min(60*60, t - 60*5)
            else:
                interval = min(60*60*24, t - 60*60*5)
        await async_sleep(min(interval, t))
        if event.message_id not in timing_working_set:
            return
        t -= interval
    if event.message_id not in timing_working_set:
        return
    await bot.handle_event(event)
    timing_working_set.remove(event.message_id)


@ event_preprocessor
async def _(bot: Bot, event: MessageEvent):
    event._copy_and_set_values
    raw_msg = event.raw_message
    pat = re.compile(r',\s*t\s*((\d+)(s|m|h|d|y)?(c(s|m|h|d)?)?)+\s*(,\s*|$)')
    time_arg = pat.search(raw_msg)
    if time_arg:
        time_args = time_arg.groups()
        print(time_args)
        time_num = int(time_args[1])
        time_unit = time_args[2]
        need_timing_echo = time_args[3]
        timing_echo = time_args[4]
        t = time_num
        if time_unit == 'm':
            t *= 60
        elif time_unit == 'h':
            t *= 60 * 60
        elif time_unit == 'd':
            t *= 60 * 60 * 24
        elif time_unit == 'y':
            t *= 60 * 60 * 24 * 365
        new_msg = pat.sub('', raw_msg)
        event.message[0].data['text'] = new_msg
        event.raw_message = new_msg
        async_create_task(timing_work(bot, event, t, need_timing_echo, timing_echo))
        raise IgnoredException('timing message detected')

###############################################################