用python写给微信自动回复的人(实现自动回复和微信好友分布等)
用python写给微信自动回复的人(实现自动回复和微信好友分布等)我先谈一谈我的想法,抛砖引玉。一般发送消息需要用到队列,进行入队和出队,我在这里设置了一个字典来保存消息发送者的数据。键为消息发送者的昵称,值是一个长度为2的数组,分别保存消息发送者的微信id和接收消息时的时间戳。这样我将每条发送过来的朋友信息保存在这个字典中,再通过将设定延迟时间同消息时间戳求和与当前时间戳进行对比,若当前时间戳较大,那么执行发送消息的操作。#获取发送消息的朋友的信息 target_friend=itchat.search_friends(userName = msg['FromUserName']) if target_friend: #获取ta的昵称 nickName=target_friend['NickName'] if not REPLY_DICT.__contains_
微信自上线以来,一直没有自动回复的功能,想必是有他们的理念。但是有些人群,确实对此功能有一定需求,我举两个栗子:
不被消息打扰的人
消息需要批量处理的人们(比如微商)
设计了几个功能:
- 收到消息立即自动回复
- 收到消息延迟指定时间回复
- 对不同好友定制不同的回复内容
- 在手机端随时进行控制
itchat的原理是通过扫码进行远程微信网页端的登录,然后通过在移动端进行操作,网页端进行响应,来实现一些功能,虽然似乎绕了个弯子,但是在微信的限制下,这似乎已经是一种最佳的方式了,犹如戴着镣铐起舞。
我们可以先通过设定几个全局变量来做作为功能的开关和保存数据的容器。
#自动回复开关SWITCH_REPLY=True#延迟回复开关SWITCH_DELAY=False#延迟时间DELAY_TIME=120#消息前缀开关SWITCH_PREFIX=True#消息前缀内容PREFIX_CONTENT="[自动回复]"#回复内容字典REPLY_DICT={}#延迟回复字典DELAY_REPLY_DICT={}
然后通过判断web端在”文件管理器“中接收到的字符串指令来进行不同操作,这一部分的代码比较简单且冗长,这里就不贴出来了,完整源码地址将会在文末给出。
假如此时我们收到了朋友的消息,需要程序给出自动回复。
#获取发送消息的朋友的信息 target_friend=itchat.search_friends(userName = msg['FromUserName']) if target_friend: #获取ta的昵称 nickName=target_friend['NickName'] if not REPLY_DICT.__contains__(nickName): #设置默认回复 REPLY_DICT[nickName]="抱歉我有事暂未看到消息,稍后回复,若有急事可以电话联系(•ω•`)" reply_content=REPLY_DICT[nickName] #判断自动回复开关 if SWITCH_REPLY: #判断延时回复开关 if SWITCH_DELAY: localtime = time.time() DELAY_REPLY_DICT[nickName]=[localtime msg['FromUserName']] print (DELAY_REPLY_DICT) if not SWITCH_DELAY: #判断消息前缀开关 if SWITCH_PREFIX: reply_content = PREFIX_CONTENT REPLY_DICT[nickName] else: reply_content = REPLY_DICT[nickName] #发送消息 itchat.send(reply_content toUserName=msg['FromUserName'])
收到朋友消息即时进行自动回复是很简单的,但是如何去做延时发送回复消息呢?(至于做这个功能有没有必要的问题可以先搁置,不过我认为在很多场景下是需要这个功能的,大家也可以在评论区讨论在什么场景下需要延迟自动回复)现在就回到技术的问题,如何实现可设置时间的延时自动回复。
我先谈一谈我的想法,抛砖引玉。一般发送消息需要用到队列,进行入队和出队,我在这里设置了一个字典来保存消息发送者的数据。键为消息发送者的昵称,值是一个长度为2的数组,分别保存消息发送者的微信id和接收消息时的时间戳。这样我将每条发送过来的朋友信息保存在这个字典中,再通过将设定延迟时间同消息时间戳求和与当前时间戳进行对比,若当前时间戳较大,那么执行发送消息的操作。
此时再开启一个线程作为定时任务,定时去检测字典中每条数据是否到达了发送的临界要求(当前时间戳>=消息时间戳 设定的延迟时间)Python中有个专门做定时任务的模块叫sched,但是我尝试了一下,sched会阻塞当前主线程,也会阻塞itchat的线程,所以并不合适。这里我还是采用了threading的Timer来充当定时器,不过要注意使用递归,否则将会出现运行一次就结束的情况。
#延迟发送消息的函数def delay_reply(): #print("开始执行") global DELAY_REPLY_DICT if SWITCH_DELAY: while len(DELAY_REPLY_DICT)>0: localtime = time.time() # print (localtime) # print (DELAY_REPLY_DICT[item][0]) # print (int(DELAY_TIME)) for item in list(DELAY_REPLY_DICT.keys()): if SWITCH_REPLY: reply_content = item " " str(round(int(DELAY_TIME) / 60 1)) "分钟过去了," REPLY_DICT[item] itchat.send(reply_content toUserName=DELAY_REPLY_DICT[item][1]) # print ("发送消息") del DELAY_REPLY_DICT[item] print (DELAY_REPLY_DICT)
global timer1 timer1=threading.Timer(DELAY_TIME delay_reply) timer1.start()
到此为止,主要的功能已经实现了,我用一个测试账号对我的微信进行了各种测试,看一下以下截图:
这时功能基本已经完成了,这就结束了吗?别着急,再想想有没有需要完善一下的地方?用过微信web端的同学应该知道,当web端长期处于未操作的状态下会失去连接。在我们这个情况下,假如你长时间未收到微信消息,后台程序将会与微信失去连接,再次开启需要登上服务器重启程序,这显然非常麻烦。有没有什么简单的解决办法呢?我想到一些应用的后台通常会做一道心跳检测机制,那我就模仿这个思路,定时给我的”文件管理器“发一个字符串,来保持连接。
def keep_alive():text="保持登录"itchat.send(text toUserName="filehelper")global timer2timer2 = threading.Timer(60*60 keep_alive)timer2.start()
最后,我们需要将这个程序发布在服务器上,让它全天候为我的微信服务。
这里需要注意,如果仅用python xxxx.py来运行的话,关闭shell会导致进程结束,所以我们需要使用nohup python xxxx.py &来全方位守护进程,这里啰嗦一句,nohup和&的功能是不一样的,很多人容易混淆,感兴趣的话可以去查下资料区分一下。
到此,微信经过了我们的稍稍调教,已经乖了一点。但是,这远远不够,思路可以继续拓展,比如实现通过手机微信来控制电脑的开关机,电脑软件的启动关闭,都是可以的,甚至实现控制家中的空调,理论上也未尝不可,只是比较有难度。
简单分析微信好友信息上文提到,既然我们能通过itchat来获取好友的信息,name自然会有很多好玩的信息(这里不做具体解析)。
性别比例
def get_sex():# 获取好友数据my_friends = itchat.get_friends(update=True)[0:]sex = {"male": 0 "female": 0 "other": 0}for item in my_friends[1:]: s = item["Sex"] if s == 1: sex["male"] = 1 elif s == 2: sex["female"] = 1 else: sex["other"] = 1total = len(my_friends[1:])
# 开始画饼图attr = list(sex.keys())v1 = list(sex.values())pie = Pie("好友性别比例")pie.add("" attr v1 v1 is_label_show=True)pie.render(path="sex_html/sex.html")
性别比例
全国好友省级分布
def friends_province():# 获取好友省份province= get_data("Province")# 分类province_distribution = {}for item in province: #删除英文省份,因为中国地图表中没有 if bool(re.search('[a-z]' item)): continue elif not province_distribution.__contains__(item): province_distribution[item] = 1 else: province_distribution[item] = 1#将省份名为空的删除province_distribution.pop('')#提取地图接口需要的数据格式# print(province_distribution)province_keys=province_distribution.keys()province_values=province_distribution.values()
return province_keys province_values
注意:这里需要自己安装地图,否则会只显示南海诸岛问题,https://www.jianshu.com/p/20fd061d0b96:
解决方案,手动安装地图
- 全球国家地图: echarts-countries-pypkg (1.9MB)(https://github.com/echarts-maps/echarts-countries-pypkg) 世界地图和 213 个国家,包括中国地图
- 中国省级地图: echarts-china-provinces-pypkg (730KB)(https://github.com/echarts-maps/echarts-china-provinces-pypkg):23 个省,5 个自治区
- 中国市级地图: echarts-china-cities-pypkg (3.8MB)(https://github.com/echarts-maps/echarts-china-cities-pypkg):370 个中国城市
需要这些地图的朋友,可以装 pip 命令行:
pip install echarts-countries-pypkgpip install echarts-china-provinces-pypkgpip install echarts-china-cities-pypkg
特别注明,中国地图在 echarts-countries-pypkg 里。
全国好友分布
好友标签
def friends_signature():signature = get_data("Signature")wash_signature=[]for item in signature: #去除emoji表情等非文字 if "emoji" in item: continue rep = re.compile("1f\d \w*|[<>/=【】『』♂ω]") item=rep.sub("" item) wash_signature.append(item)
words="".join(wash_signature)
print(wash_signature)
wordlist = jieba.cut(words cut_all=True)word_space_split = " ".join(wordlist)
global NickNameglobal Sex
# print(NickName Sex)
# 图片的作用:生成的图片是这个图片的两倍大小# 根据性别选择对应的性别模板图if Sex == 2: coloring = np.array(Image.open("standard/girl.jpg"))elif Sex == 1: coloring = np.array(Image.open("standard/boy.jpg"))else: coloring = np.array(Image.open("standard/num.jpg"))
# simkai.ttf 必填项 识别中文的字体,例:simkai.ttf,my_wordcloud = WordCloud(background_color="white" max_words=800 mask=coloring max_font_size=120 random_state=30 scale=2 font_path="fonts/STKAITI.TTF").generate(word_space_split)
image_colors = ImageColorGenerator(coloring)plt.imshow(my_wordcloud.recolor(color_func=image_colors))plt.imshow(my_wordcloud)plt.axis("off")plt.show()
# 保存图片my_wordcloud.to_file('Signature/signature.png')
说明两点:
1、一定要有标签样版图,生成对应样式
2、要添加识别中文的字体