|
@@ -92,13 +92,16 @@ if __name__ == "__main__":
|
|
|
continue
|
|
|
message_id += 1
|
|
|
sender = '7881301903997433'
|
|
|
- receiver = '1688855931724582'
|
|
|
+ receiver = '1688854974625870'
|
|
|
if text in (MessageType.AGGREGATION_TRIGGER.name,
|
|
|
MessageType.HUMAN_INTERVENTION_END.name):
|
|
|
message = MqMessage.build(
|
|
|
MessageType.__members__.get(text),
|
|
|
MessageChannel.CORP_WECHAT,
|
|
|
sender, receiver, None, int(time.time() * 1000))
|
|
|
+ elif text == 'S_PUSH':
|
|
|
+ service._check_initiative_conversations()
|
|
|
+ continue
|
|
|
else:
|
|
|
message = MqMessage.build(MessageType.TEXT, MessageChannel.CORP_WECHAT,
|
|
|
sender, receiver, text, int(time.time() * 1000)
|