|
@@ -168,7 +168,7 @@ class PushTaskWorkerPool:
|
|
|
messages_to_send.append(item)
|
|
|
current_ts = int(time.time())
|
|
|
with self.agent_service.AgentDBSession() as session:
|
|
|
- msg_list = []
|
|
|
+ msg_list = [{"type": msg["type"].value, "content": msg["content"]} for msg in messages_to_send]
|
|
|
record = AgentPushRecord(staff_id=staff_id, user_id=user_id,
|
|
|
content=json.dumps(msg_list, ensure_ascii=False),
|
|
|
timestamp=current_ts)
|