fix(wechat.py): fix time init (#327)

config.ini

@@ -174,6 +174,10 @@ dir = "wkteam"
 
 # 群号和介绍
 # 茴香豆相关
+[frontend.wechat_wkteam.43925126702]
+name = "茴香豆群（大暑）"
+introduction = "github https://github.com/InternLM/HuixiangDou 用户体验群"
+
 [frontend.wechat_wkteam.44546611710]
 name = "茴香豆群（立夏）"
 introduction = "github https://github.com/InternLM/HuixiangDou 用户体验群"

huixiangdou/frontend/wechat.py

@@ -9,7 +9,7 @@
 import xml.etree.ElementTree as ET
 from datetime import datetime
 from multiprocessing import Process
-
+import pdb
 import pytoml
 import redis
 import requests
@@ -261,7 +261,7 @@ class Talk:
     query: str
     reply: str = ''
     refs: tuple = ()
-    now: int = time.time()
+    now: float = field(default_factory=time.time)
 
 def convert_talk_to_dict(talk: Talk):
     return {'query': talk.query, 'reply': talk.reply, 'refs': talk.refs, 'now': talk.now}
@@ -316,15 +316,15 @@ def concat(self):
         now = time.time()
         for item in self.history:
             if abs(now - item.now) > 7200:
-                # 1小时前，太久的消息就不要了
+                # 2小时前，太久的消息就不要了
                 continue
 
             answer = item.reply
             if answer is not None and len(answer) > 0:
                 ret.append(item)
             else:
                 merge_list.append(item.query)
-        
+
         concat_query = '\n'.join(merge_list)
         concat_talk = Talk(query=concat_query)
         ret.append(concat_talk)
@@ -767,6 +767,7 @@ def loop(self, worker):
                         # if user image or link contains question, do not process
                         continue
 
+                    logger.debug('before concat {}'.format(user))
                     user.concat()
                     logger.debug('after concat {}'.format(user))
                     assert len(user.history) > 0