|
@@ -3,7 +3,9 @@
|
|
# vim:fenc=utf-8
|
|
# vim:fenc=utf-8
|
|
from datetime import datetime
|
|
from datetime import datetime
|
|
import re
|
|
import re
|
|
-
|
|
|
|
|
|
+import sys
|
|
|
|
+import os
|
|
|
|
+sys.path.append(os.curdir)
|
|
import configs
|
|
import configs
|
|
from message import MessageChannel, Message
|
|
from message import MessageChannel, Message
|
|
from message_queue_backend import AliyunRocketMQQueueBackend
|
|
from message_queue_backend import AliyunRocketMQQueueBackend
|
|
@@ -63,7 +65,7 @@ def main():
|
|
staff_id, user_id = match.groups()
|
|
staff_id, user_id = match.groups()
|
|
processed_users.add(user_id)
|
|
processed_users.add(user_id)
|
|
|
|
|
|
- if "skip reply" in log:
|
|
|
|
|
|
+ elif "skip reply" in log:
|
|
match = re.search(r"staff\[(\d+)\] user\[(\d+)\]", log)
|
|
match = re.search(r"staff\[(\d+)\] user\[(\d+)\]", log)
|
|
if not match:
|
|
if not match:
|
|
continue
|
|
continue
|