"""

# logging.warning("%s", msg)

msg_id = msg["MsgId"] # 消息ID

from_user_name = msg["FromUserName"] # 消息发送者ID

to_user_name = msg["ToUserName"] # 消息接受者ID

msg_type = msg["MsgType"] # 消息类型

msg_content = msg["Content"] # 消息内容

msg_time = datetime.datetime.fromtimestamp(msg["CreateTime"]) # 消息发送时间

msg_file = msg["FileName"] # 消息中所带文件的名称

msg_url = msg["Url"] # 消息中带有的链接地址

wind_name = msg["User"]["RemarkName"] if msg["User"].get("RemarkName") else (

msg["User"]["NickName"] if msg["User"].get("NickName") else to_user_name

)

if from_user_name.startswith("@@"):

nick_name = msg["ActualNickName"] if (msg["ActualUserName"] not in my.friends) or \

(not my.friends[msg["ActualUserName"]]["RemarkName"]) else my.friends[msg["ActualUserName"]]["RemarkName"]

else:

nick_name = wind_name

we_type = msg["Type"] # 消息类型

we_text = msg["Text"] # 消息内容

logging.warning("wind: %s, nick:%s, %s/%s, %s/%s, %s", wind_name, nick_name, msg_type, we_type, msg_content, we_text, msg_time)

"""

# 消息提取

msg_id, from_user_name, to_user_name, msg_type, msg_content, msg_time, msg_file, msg_url, wind_name, nick_name, we_type, we_text = get_msg_list(msg)

# 消息过滤, 只监测文字、注解、分享、图片、语音、视频、附件等

if we_type not in ["Text", "Note", "Sharing", "Picture", "Recording", "Video", "Attachment"]:

logging.warning("message type isn't included, ignored")

return

# 处理来自自己的消息

if from_user_name == my.loginInfo["User"]["UserName"]:

logging.warning("message is from myself, ignored")

return

# 消息存储，删除过期消息

my.msg_store[msg_id] = msg

for _id in [_id for _id in my.msg_store if time.time() - my.msg_store[_id]["CreateTime"] > 120]:

logging.warning("delete message, message_id = %s", _id)

my.msg_store.pop(_id)

# 处理群消息

if from_user_name.startswith("@@"):

# 红包消息处理

if we_type == "Note" and we_text.find("收到红包，请在手机上查看") >= 0:

my.send("【%s】中有红包，快抢！" % wind_name, toUserName=my.to_user_name)

# 关键字消息处理

for key in my.global_keys:

if msg_content.find(key) >= 0:

my.send("【%s】中有关键字【%s】:\nFrom: %s\nTime: %s\n%s" % (wind_name, key, nick_name, msg_time, msg_content), toUserName=my.to_user_name)

break

# 撤回消息处理

if we_type == "Note" and we_text.find("撤回了一条消息") >= 0:

old_msg = my.msg_store.get(msg_content[msg_content.find("<msgid>")+7: msg_content.find("</msgid>")])

if not old_msg:

logging.warning("not message id in my.msg_store")

return

msg_id, from_user_name, to_user_name, msg_type, msg_content, msg_time, msg_file, msg_url, wind_name, nick_name, we_type, we_text = get_msg_list(old_msg)

if we_type in ["Picture", "Recording", "Video", "Attachment"]:

re_length = re.search("[\"\s]length=\"(?P<length>[\d]+?)\"", msg_content, flags=re.IGNORECASE)

if (not msg_content) or (re_length and (int(re_length.group("length")) < 5000000)):

we_text(".Cache/" + msg_file)

logging.warning("downloading %s to .Cache/", msg_file)

# 更改内容

msg_content = msg_file

elif we_type == "Sharing":

msg_content = we_text + ": " + msg_url

my.send("【%s】中有消息被撤回:\nFrom: %s\nType: %s\nTime: %s\n%s" % (wind_name, nick_name, we_type, msg_time, msg_content), toUserName=my.to_user_name)