feat: :sparkles: handle contiguous messages

wechat-server/web.py

@@ -1,6 +1,5 @@
 #!/usr/bin/env python
 # -*- coding: utf-8 -*-
-import json
 import os
 from functools import lru_cache
 from xml.etree.ElementTree import fromstring
@@ -36,6 +35,9 @@ WECHAT_SECRET = os.environ.get("WECHAT_SECRET")
 CODEDOG_PORT = int(os.environ.get("CODEDOG_PORT", 32167))
 wxcpt = WXBizMsgCrypt(WECHAT_TOKEN, WECHAT_AESKEY, WECHAT_CORPID)
 
+# 先用个简单的字典存一下，后面可以考虑用 redis
+last_reply_time = dict()
+
 
 def access_token():
     url_base = "https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=%s&corpsecret=%s"
@@ -86,15 +88,30 @@ def handle_message(message_token: str):
     history = get_chat_history(access_token=access_token(),
                                message_token=message_token)["msg_list"]
 
-    message_block = history[-1]
-
-    open_kfid = message_block.get("open_kfid", None)
-    external_userid = message_block.get("external_userid", None)
-    if open_kfid is None or external_userid is None:
-        print("open_kfid or external_userid is None")
+    text_message_blocks = []
+
+    # 这里收集一下 我们能处理的消息
+    for message_block in history:
+        open_kfid = message_block.get("open_kfid", None)
+        external_userid = message_block.get("external_userid", None)
+        if open_kfid is None or external_userid is None:
+            print("open_kfid or external_userid is None")
+            continue
+        print("message_block", message_block)
+        if message_block.get("msgtype", None) == "text":
+            content = message_block["text"]["content"]
+            if content["send_time"] > last_reply_time.get(external_userid, 0):
+                text_message_blocks.append(message_block)
+        if message_block.get("msgtype", None) == "image":
+            content = message_block["image"]["media_id"]
+            print("image block", content)
+
+    if len(text_message_blocks) == 0:
         return
-    content = message_block["text"]["content"]
-    print("message_block", message_block)
+
+    content = "\n".join([message_block["text"]["content"] for message_block in text_message_blocks])
+    last_reply_time[message_block[-1]["external_userid"]] = message_block[-1]["send_time"]
+
     # print(open_kfid, external_userid, content)
     result = task.ask(content, session=False)
     print("handle_message", result)