From d458c480f0abe3d0be5cc35056ed0f7d9a163556 Mon Sep 17 00:00:00 2001 From: lb2281075105 <2281075105@qq.com> Date: Sun, 15 Apr 2018 22:18:16 +0800 Subject: [PATCH] =?UTF-8?q?=20itchat=E8=8E=B7=E5=8F=96=E5=BE=AE=E4=BF=A1?= =?UTF-8?q?=E5=A5=BD=E5=8F=8B=E6=88=96=E8=80=85=E5=BE=AE=E4=BF=A1=E7=BE=A4?= =?UTF-8?q?=E5=88=86=E4=BA=AB=E6=96=87=E7=AB=A0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .DS_Store | Bin 6148 -> 6148 bytes .../PythonItChat.py" | 229 ++++++++++++++++++ .../README.md" | 0 README.md | 2 + 4 files changed, 231 insertions(+) create mode 100644 "01 itchat\350\216\267\345\217\226\345\276\256\344\277\241\345\245\275\345\217\213\346\210\226\350\200\205\345\276\256\344\277\241\347\276\244\345\210\206\344\272\253\346\226\207\347\253\240/PythonItChat.py" rename "\345\276\256\344\277\241\346\216\245\345\217\243\350\207\252\345\212\250/README.md" => "01 itchat\350\216\267\345\217\226\345\276\256\344\277\241\345\245\275\345\217\213\346\210\226\350\200\205\345\276\256\344\277\241\347\276\244\345\210\206\344\272\253\346\226\207\347\253\240/README.md" (100%) diff --git a/.DS_Store b/.DS_Store index 8ca2210b173b221e9eefd0867226ee762bc3a72e..7c279d8f85bdab79c72557c7ff68c468779b5966 100644 GIT binary patch delta 329 zcmZoMXfc=|#>B)qu~2NHo)!;72}3eN216o4N%Qv26B(B?*0V4$Fi0>MFc>l@Fk~W2 z2VaX{=l?LWHu!XsSOY7FUB4uV&2M#Td)0%Sbi?4}{M-VdUKk+RjNE(|mz2`_l4J&k zYu^;#R*3>lBEygrpdl2P!3^}x<{HM|ESuRm_&I<91q_w%%#-;=EIAk%7=Va@VRL}U G7G?ln4QU(z delta 195 zcmZoMXfc=|#>B`mu~2NHo)%l67`G*VeNzFfg#iuk(MHyfpYRMBFeqIX|}m zC=LTC^11mgE-9rY$qWqFzA3(~5(O$klTX1bUyy-p{$?rWw=A0tm?to9X6NAN06KBA ZBJ+3V$^0Ug93bl%85o#02Z(H81^`MaK&1cx diff --git "a/01 itchat\350\216\267\345\217\226\345\276\256\344\277\241\345\245\275\345\217\213\346\210\226\350\200\205\345\276\256\344\277\241\347\276\244\345\210\206\344\272\253\346\226\207\347\253\240/PythonItChat.py" "b/01 itchat\350\216\267\345\217\226\345\276\256\344\277\241\345\245\275\345\217\213\346\210\226\350\200\205\345\276\256\344\277\241\347\276\244\345\210\206\344\272\253\346\226\207\347\253\240/PythonItChat.py" new file mode 100644 index 0000000..b833321 --- /dev/null +++ "b/01 itchat\350\216\267\345\217\226\345\276\256\344\277\241\345\245\275\345\217\213\346\210\226\350\200\205\345\276\256\344\277\241\347\276\244\345\210\206\344\272\253\346\226\207\347\253\240/PythonItChat.py" @@ -0,0 +1,229 @@ +#coding=utf-8 +''' +itchat:获取分享给群或者个人的技术文章 +(0) 熟悉itchat,(https://www.cnblogs.com/Chenjiabing/p/6907397.html) +(1) itchat 扫码次数太多会被限制扫码登录微信。 +(2) itchat:获取分享给群或者个人的技术文章,提取出文章链接、文章标题、文章首页图片、文章内容 +(3) 通过获取到的文章链接，爬虫文章内容。 +(4) 判断是接收方(ToUserName)是谁、发送方(FromUserName)是谁就是通过唯一的ID来判别的。 +(5) python itchat 热登陆(itchat.auto_login(hotReload=True)) +(6) xpath模块爬取文章标题、文章内图片 +(7) 搭建web服务器环境(Mac使用XAMPP) +(8) pymysql模块自动创建数据库、创建字段、保存内容到字段 +(9) navicat 的使用 +(10) python 相关模块的使用 +''' + +# 爬取微信群或者是好友分享的文章 +# 监听微信公众号分享的文章 +import itchat +# import全部消息类型 +from itchat.content import * +import urllib2 +import lxml.etree +import os +import pymysql +import json + +# 连接数据库 +tablename = 'pythonitchat' +db = pymysql.connect(host='127.0.0.1', user='root', passwd='', db='itchat', charset='utf8') +cur = db.cursor() +cur.execute('USE itchat') + +# 处理个人分享消息 +# 包括文本、位置、名片、通知、分享(49重点) +@itchat.msg_register([TEXT, MAP, CARD, NOTE, SHARING]) +def text_reply(msg): + print msg + # 微信里，每个用户和群聊，都使用很长的ID来区分 + if msg["MsgType"] == 49: + print "个人分享文章地址链接Url:" + "---------------------------" + + xmlcontent = lxml.etree.HTML(get_html(msg["Url"])) + print xmlcontent + title = xmlcontent.xpath('//h2[@class="rich_media_title"]/text()') + + imgArray = xmlcontent.xpath('//img[@data-type="png"]/@data-src') + # 下载图片 + source = xmlcontent.xpath('//span[@class="rich_media_meta rich_media_meta_text rich_media_meta_nickname"]/text()') + time = xmlcontent.xpath('//em[@class="rich_media_meta rich_media_meta_text"]/text()') + print "来源" + print source, time + # 下载图片 + print "下载图片" + # print imgArray + # print title[0] + get_image(title, imgArray, source, time,msg["Url"]) + + print msg["Url"] + print "个人分享文章类型编号MsgType:" + "---------------------------" + print msg["MsgType"] + print "个人分享Content:" + "---------------------------" + print msg["Content"] + print "个人分享FromUserName:" + "---------------------------" + print msg["FromUserName"] + print "个人分享ToUserName:" + "---------------------------" + print msg["ToUserName"] + print "个人分享链接标题FileName:" + "---------------------------" + print msg["FileName"] + + # return msg['Text'] + # itchat.send('%s: %s : %s' % (msg['Type'], msg['Text'],msg['Url']), msg['FromUserName']) + print "lalallala" + # 获取到的信息是某某人和登录者之间的通讯，如果不是和登录这通讯就获取不到 + print itchat.search_friends(userName=msg['FromUserName'])['NickName'] + print itchat.search_friends(userName=msg['ToUserName'])['NickName'] + + else: + print "不是个人分享的文章" + + +# 处理群聊消息 +@itchat.msg_register([TEXT, MAP, CARD, NOTE, SHARING], isGroupChat=True) +def text_reply(msg): + print msg + if msg["MsgType"] == 49: + print "群聊分享文章地址链接Url:" + "---------------------------" + print msg["Url"] + + xmlcontent = lxml.etree.HTML(get_html(msg["Url"])) + title = xmlcontent.xpath('//h2[@class="rich_media_title"]/text()') + imgArray = xmlcontent.xpath('//img[@data-type="png"]/@data-src') + # 来源 + source = xmlcontent.xpath('//span[@class="rich_media_meta rich_media_meta_text rich_media_meta_nickname"]/text()') + time = xmlcontent.xpath('//em[@class="rich_media_meta rich_media_meta_text"]/text()') + print "来源" + print source,time + # 下载图片 + print "下载图片" + # print imgArray + # print title[0] + get_image(title,imgArray,source,time,msg["Url"]) + + print "群聊分享文章类型编号MsgType:" + "---------------------------" + print msg["MsgType"] + print "群聊分享Content:" + "---------------------------" + print msg["Content"] + print "群聊分享FromUserName:" + "---------------------------" + print msg["FromUserName"] + print "群聊分享ToUserName:" + "---------------------------" + print msg["ToUserName"] + print "群聊分享链接标题FileName:" + "---------------------------" + print msg["FileName"] + # print "分享者昵称ActualNickName:" + "---------------------------" + # print msg["ActualNickName"] + print "lalallala群" + # itchat.send('%s: %s : %s' % (msg['Type'], msg['Text'], msg['Url']), msg['FromUserName']) + + print msg['FromUserName'] + print msg['ToUserName'] + + receiver = "@123c6bbefef9d63462d989f117152dd0d05e0fe94c82a273ea4238a170eb0862" + # "@@df97b8b54074a1c5af029d9f637f2bbc58eb796126285a0c22cb450ac912ff7f" + if msg['FromUserName'] == receiver: + print "----------- 自己在群里发的文章 ------------" + # 自己在群里发的文章 + print "昵称:" + print msg['ActualNickName'] + print " ----------- " + print "群名称:" + print itchat.search_chatrooms(userName=msg['ToUserName'])['NickName'] + chatRoomName = "呵呵各地" + if itchat.search_chatrooms(userName=msg['ToUserName'])['NickName'] == chatRoomName: + pass + else: + pass + + else: + # 群友发的文章 + print "----------- 群友发的文章 -----------" + print "昵称:" + print msg['ActualNickName'] + print " ----------- " + print "群名称:" + print itchat.search_chatrooms(userName=msg['FromUserName'])['NickName'] + chatRoomName = "呵呵各地" + if itchat.search_chatrooms(userName=msg['FromUserName'])['NickName'] == chatRoomName: + pass + else: + pass +else: + print "不是群聊分享的文章" +# return msg['Text'] + + +# 处理微信公众号消息 +@itchat.msg_register([TEXT, MAP, CARD, NOTE, SHARING], isMpChat=True) +def text_reply(msg): + print msg + print itchat.search_mps(name='PythonCoder') + if msg["MsgType"] == 49: + print "监听到制定微信公众号分享的文章链接：" + print msg["Url"] + else: + print "微信公众号分享的不是文章" + +# 获取网页内容 +def get_html(url): + request = urllib2.Request(url) + response = urllib2.urlopen(request) + html = response.read() + return html + +# 下载图片 +def get_image(title,imgArray,source,time,linkurl): + print "标题" + result = cur.execute("select url from pythonitchat WHERE url='"+ linkurl + "'") + print(str(result) + '------------url-----------') + + if result: + print("数据库里面存在此数据") + else: + if os.path.isdir('./imgs'): + pass + else: + os.mkdir("./imgs") + for item in imgArray: + with open('imgs/' + (item)[-30:].replace('/','-') + ".png", 'a+') as file: + file.write(get_html(item)) + file.close + +cur.execute( + 'INSERT INTO ' + tablename + ' (title,url, img,source,time) VALUES (%s, %s,%s,%s, %s)', + (title[0].strip().replace("\n", ""),linkurl, json.dumps(imgArray, ensure_ascii=False),source[0].strip().replace("\n", ""),time[0].strip().replace("\n", ""))) + cur.connection.commit() + print title[0] + print("------------------------ 插入成功 ----------------------------------") + +# 连接数据库 +def get_connect(): + + try: + # 创建表 + cur.execute( + 'CREATE TABLE ' + tablename + ' (id BIGINT(7) NOT NULL AUTO_INCREMENT, title VARCHAR(1000),url VARCHAR(10000), img VARCHAR(1000), source VARCHAR(1000), time VARCHAR(1000), created TIMESTAMP DEFAULT CURRENT_TIMESTAMP, PRIMARY KEY(id))') + except pymysql.err.InternalError as e: + print(e) + # 修改表字段 + cur.execute('ALTER DATABASE itchat CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci') + cur.execute( + 'ALTER TABLE ' + tablename + ' CONVERT TO CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci') +cur.execute( + 'ALTER TABLE ' + tablename + ' CHANGE title title VARCHAR(1000) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci') + cur.execute( + 'ALTER TABLE ' + tablename + ' CHANGE url url VARCHAR(10000) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci') + cur.execute( + 'ALTER TABLE ' + tablename + ' CHANGE img img VARCHAR(1000) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci') + cur.execute( + 'ALTER TABLE ' + tablename + ' CHANGE source source VARCHAR(1000) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci') + cur.execute( + 'ALTER TABLE ' + tablename + ' CHANGE time time VARCHAR(1000) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci') + + +# 热登录(在一段时间内不用扫码登录还能保持登录状态) +get_connect() +print "哈哈" +itchat.auto_login(hotReload=True) +# 绑定消息响应事件后，让itchat运行起来，监听消息 +itchat.run() diff --git "a/\345\276\256\344\277\241\346\216\245\345\217\243\350\207\252\345\212\250/README.md" "b/01 itchat\350\216\267\345\217\226\345\276\256\344\277\241\345\245\275\345\217\213\346\210\226\350\200\205\345\276\256\344\277\241\347\276\244\345\210\206\344\272\253\346\226\207\347\253\240/README.md" similarity index 100% rename from "\345\276\256\344\277\241\346\216\245\345\217\243\350\207\252\345\212\250/README.md" rename to "01 itchat\350\216\267\345\217\226\345\276\256\344\277\241\345\245\275\345\217\213\346\210\226\350\200\205\345\276\256\344\277\241\347\276\244\345\210\206\344\272\253\346\226\207\347\253\240/README.md" diff --git a/README.md b/README.md index d3bec09..ab9541c 100644 --- a/README.md +++ b/README.md @@ -1,2 +1,4 @@ # Python-WeChat-ItChat itchat微信接口 + +01 itchat获取微信好友或者微信群分享文章