Update agent_service: for debug

agent_service.py

@@ -277,9 +277,15 @@ if __name__ == "__main__":
         if not text:
             continue
         message_id += 1
-        message = Message.build(MessageType.TEXT, MessageChannel.CORP_WECHAT,
-            '7881301263964433','1688854492669990', text, int(time.time() * 1000)
-        )
+        sender = '7881301263964433'
+        receiver = '1688854492669990'
+        if text == MessageType.AGGREGATION_TRIGGER.name:
+            message = Message.build(MessageType.AGGREGATION_TRIGGER, MessageChannel.CORP_WECHAT,
+                sender, receiver, None, int(time.time() * 1000))
+        else:
+            message = Message.build(MessageType.TEXT, MessageChannel.CORP_WECHAT,
+                sender,receiver, text, int(time.time() * 1000)
+            )
         message.msgId = message_id
         receive_queue.produce(message)
         time.sleep(0.1)