wxBot/main.py at master · MatioYoshitoki/wxBot · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
#!/usr/bin/env python3.6
#coding=utf-8
from wxpy import *
import datetime
import time
import requests
import json
from MySnow import snow
from db_oper import MySQL
# from db_oper import MySQL
from concurrent.futures import ProcessPoolExecutor
import httpUnit

# def qrBack():
#     print("获得新的二维码")

botID = "18969899383"
bot = Bot(cache_path=True, qr_path=botID+".png", console_qr=False)# 用于接入微信的机器人
# print(bot.friends());
# ssp = bot.friends().search('测试机器人')[0]
# sent_msgs = bot.messages.search(sender=ssp)
# print(sent_msgs)
# ssp.send('开始进行')

def recordmood():
    # while True:
    friends = bot.friends()
    for friend in friends:
        remark_name = friend.remark_name
        v0 = remark_name.split("&amp;")
        print(friend.nick_name + "===>" + friend.remark_name)
        print(friend.signature)
        if len(v0) != 2:
            continue
        remark_name = v0[0]
        user_id = v0[1][2:20]
        gender = friend.sex
        city = friend.city
        province = friend.province

        mysql = MySQL()
        sql = "SELECT * FROM TWXUser WHERE UserID = '"+user_id+"' AND RemarkName = '"+remark_name+"' AND BotID = '"+botID+"'";
        data = mysql.exe(sql=sql)
        if len(data) != 0:
            continue

        # snow = MySnow(dataID="00")
        sql = "INSERT INTO TWXUser (id, RemarkName, UserID, City, Province, Gender, BotID) VALUES ("+str(snow.get_id())+", '"+remark_name+"', '"+user_id+"', '"+city+"', '"+province+"', '"+str(gender)+"', '"+botID+"')"
        mysql.exe(sql=sql)

            #

            # print(friend.alias)
            # print("\n")

        # print(bot.friends())
        # time.sleep(60)
#

#接受来自朋友的语音消息
# @bot.register(msg_types=RECORDING)
# def reply_my_friend(msg):
#     return "语音已收到"
#
# @bot.register(msg_types=TEXT, chats=Friend)
# def reply_my_friend(msg):
#     print(msg)
#     # mysql = MySQL()
#     # sql = "INSERT INTO TWXLog (GroupName, NickName, LogContent) VALUES ('" + msg.chat.name + "', '" + msg.member.name + "', '" + msg.text + "')"
#     # mysql.exe(sql=sql)
#     return "测试信息已收到，稍后接入闲聊。"
#
# @bot.register(msg_types=NOTE, chats=Friend)
# def system_msg(msg):
#     print(msg)
#     # mysql = MySQL()
#     # sql = "INSERT INTO TWXLog (GroupName, NickName, LogContent) VALUES ('" + msg.chat.name + "', '" + msg.member.name + "', '" + msg.text + "')"
#     # mysql.exe(sql=sql)
#     # return "测试信息已收到，稍后接入闲聊。"
#
# @bot.register(msg_types=PICTURE, chats=Friend)
# def reply_my_friend(msg):
#     mysql = MySQL()
#     sql = "INSERT INTO TWXLog (GroupName, NickName, LogContent) VALUES ('" + msg.chat.name + "', '" + msg.member.name + "', '" + msg.text + "')"
#     mysql.exe(sql=sql)
#     return "测试图片已收到。"


#接受群消息被@时回复
# @bot.register(Group, TEXT)
# def auto_reply(msg):
#     # 如果是群聊，但没有被 @，则不回复
#     if isinstance(msg.chat, Group) and not msg.is_at:
#         return
#     else:
#         # 回复消息内容和类型
#         return '收到 @{} 的消息: {} '.format(msg.member.name, msg.text)

@bot.register(Group, RECORDING)
def auto_reply(msg):
    return

@bot.register(msg_types=FRIENDS)
# 自动接受验证信息中包含 'wxpy' 的好友请求
def auto_accept_friends(msg):
    # 判断好友请求中的验证文本
    # if '心镜' in msg.text.lower():
        # 接受好友 (msg.card 为该请求的用户对象)
    new_friend = bot.accept_friend(msg.card)
    # 或 new_friend = msg.card.accept()
    # 向新的好友发送消息
    new_friend.send('您好,我是您的心理小助手。\n打印评测报告请点击下方图片，识别图中二维码。')
    new_friend.send_image('1.jpg');


# httpUnit.getImage("1.jpg")
# 堵塞线程，并进入 Python 命令行
pool = ProcessPoolExecutor(max_workers=4)
# future1 = pool.submit(sendmessagebytime(10,45,'今天的文章推送~ https://mp.weixin.qq.com/s/MZRb14cTThF48X-kIH7PQg'))
record = pool.submit(recordmood())


# future1 = pool.submit(sendmessagebytime(0,00,'晚安晚安~[月亮][月亮]'))
# embed()