增加新的接收信息装饰器, 并支持自定义函数接受信息类型, 增加防撤回

This commit is contained in:
Mr.yang 2023-10-08 22:41:25 +08:00
parent f321ed6d85
commit 15a6264f0d
6 changed files with 12 additions and 8 deletions

View File

@ -98,6 +98,7 @@ def main():
撤回消息函数装饰器
"""
print(msg)
print(msg.get_revoke_msg())
def judge(msg: WxMsg):
"""

View File

@ -83,6 +83,7 @@ def main():
撤回消息函数装饰器
"""
print(msg)
print(msg.get_revoke_msg())
def judge(msg: WxMsg):
"""

View File

@ -144,8 +144,6 @@ class Register(Event):
raise NotImplementedError
def group_changed_register(self,
isGroup: bool = False,
isDivision: bool = False,
isPyq: bool = False,
allow_other_receive: bool = True):
"""

View File

@ -79,7 +79,9 @@ def _processing_async_func(self,
return await func(bot, message)
except:
traceback.print_exc()
return __async_func
return _async_func
@ -109,7 +111,9 @@ def _processing_universal_func(self,
return func(bot, message)
except:
traceback.print_exc()
return universal_func
return _universal_func
@ -144,8 +148,6 @@ def revoke_message_register(self,
def group_changed_register(self,
isGroup: bool = False,
isDivision: bool = False,
isPyq: bool = False,
allow_other_receive: bool = True):
def judge_msg(msg):
@ -154,9 +156,9 @@ def group_changed_register(self,
return True
return False
return self._processing_async_func(isGroup,
isDivision,
isPyq,
return self._processing_async_func(isPyq=isPyq,
isGroup=True,
isDivision=True,
register_name='groupChanged',
allow_other_receive=allow_other_receive,
judge_msg=judge_msg)

View File

@ -9,7 +9,7 @@ class messageList(list):
super(messageList, self).__init__(*args, **kwargs)
self.__isRunning = True
self.__th = None
self.__time_step = 2*60
self.__time_step = 3*60
self.__msg_queen = queue.Queue()
self.start()

View File

@ -40,6 +40,8 @@ class WxMsgV2(WxMsg):
"""
def __init__(self, msg: WxMsg) -> None:
self._is_group = msg._is_group
self._is_self = msg._is_self
self._type = msg.type
self._id = msg.id
self._ts = msg.ts