用Node+wechaty写一个爬虫脚本每天定时给女(男)朋友发微信暖心话

  • A+
所属分类:node 微信开发

wechatBot

微信每日说,每日自动发送微信消息给你心爱的人

项目介绍

灵感来源

在掘金看到了一篇《用Node + EJS写一个爬虫脚本每天定时女朋友发一封暖心邮件》后, 在评论区偶然看到一位读者说可不可以用微信实现一下。然后最近刚好在做微信机器人的小项目,那就把这个定时任务放到微信上去做吧,说干就干,撸了一下午终于撸出来了。

项目地址

github:https://github.com/gengchen528/wechatBot

使用库

功能

  • 定时给朋友发送每日天气提醒以及每日一句
  • 根据关键词自动加好友和自动拉群功能
  • 后续继续扩展吧...(你有好的想法也可以提pr)

数据来源

  • 每日一句和上面的大佬一样也是来自one
  • 天气信息来自墨迹天气

定时任务

node-schedule非你莫属了, 可以定时每个月、每个礼拜、每天具体什么时候执行什么任务

实现效果

由于是微信定时发送消息,较邮件来说,微信无法把图片和文字放在同一消息框中,所以美观度来说可能没有邮件好,不过文字进行排版后还是可以的,由于时间仓促,所以文字比较少,后续会继续增加内容;

用Node+wechaty写一个爬虫脚本每天定时给女(男)朋友发微信暖心话
用Node+wechaty写一个爬虫脚本每天定时给女(男)朋友发微信暖心话

代码说明

目录结构

用Node+wechaty写一个爬虫脚本每天定时给女(男)朋友发微信暖心话
  • config: 存放公共变量和superagent的配置
  • schedule: 任务调度的配置
  • superagent: 获取每日一句和天气信息
  • untils: 抽取的共用方法

核心代码

index.js

关于微信的登录,定时任务的创建,发送信息的获取都在这个文件里

  1. /**
  2.  * WechatBot
  3.  *  - https://github.com/gengchen528/wechatBot
  4.  */
  5. const {Wechaty,Friendship} = require('wechaty')
  6. const schedule = require('./schedule/index')
  7. const config = require('./config/index')
  8. const untils = require('./untils/index')
  9. const superagent = require('./superagent/index')
  10. const {FileBox} = require('file-box') //文件读取模块
  11. //  二维码生成
  12. function onScan (qrcode, status) {
  13.   require('qrcode-terminal').generate(qrcode)  // 在console端显示二维码
  14.   const qrcodeImageUrl = [
  15.     'https://api.qrserver.com/v1/create-qr-code/?data=',
  16.     encodeURIComponent(qrcode),
  17.   ].join('')
  18.   console.log(qrcodeImageUrl)
  19. }
  20. // 登录
  21. async function onLogin (user) {
  22.   console.log(`贴心小助理${user}登录了`)
  23.   // 登陆后创建定时任务
  24.   schedule.setSchedule(config.SENDDATE,()=>{
  25.     console.log('你的贴心小助理开始工作啦!')
  26.     main()
  27.   })
  28. }
  29. //登出
  30. function onLogout(user) {
  31.   console.log(`${user} 登出`)
  32. }
  33. // 监听对话 根据关键词自动加群
  34. async function onMessage (msg) {
  35.   const contact = msg.from() // 发消息人
  36.   const content = msg.text() //消息内容
  37.   const room = msg.room() //是否是群消息
  38.   const roomCodeUrl = FileBox.fromUrl(config.ROOMCODEURL) //来自url的文件
  39.   const roomCodeLocal = FileBox.fromFile(config.ROOMLOCALPATH) //添加本地文件
  40.   if (msg.self()) {
  41.     return
  42.   }
  43.   if(room){ // 如果是群消息
  44.     const topic = await room.topic()
  45.     console.log(`群名: ${topic} 发消息人: ${contact.name()} 内容: ${content}`)
  46.   }else { // 如果非群消息
  47.     console.log(`发消息人: ${contact.name()} 消息内容: ${content}`)
  48.     let addRoomReg = eval(config.ADDROOMWORD)
  49.     let roomReg = eval(config.ROOMNAME)
  50.     if(addRoomReg.test(content)&&!room){
  51.       let keyRoom = await this.Room.find({topic: roomReg})
  52.       if(keyRoom){
  53.         try{
  54.           await contact.say(roomCodeLocal||roomCodeUrl)
  55.           await keyRoom.say('微信每日说:欢迎新朋友', contact)
  56.         }catch (e) {
  57.           console.error(e)
  58.         }
  59.       }
  60.     }else {
  61.       await contact.say('你好,不要轻易调戏我,我只会发群二维码,不会聊天的!')
  62.       await contact.say('请回复暗号:加群  获取群二维码图片')
  63.     }
  64.   }
  65. }
  66. // 自动加好友功能
  67. async function onFriendShip(friendship) {
  68.   let logMsg
  69.   try {
  70.     logMsg = '添加好友' + friendship.contact().name()
  71.     console.log(logMsg)
  72.     switch (friendship.type()) {
  73.         /**
  74.          *
  75.          * 1. New Friend Request
  76.          *
  77.          * when request is set, we can get verify message from `request.hello`,
  78.          * and accept this request by `request.accept()`
  79.          */
  80.       case Friendship.Type.Receive:
  81.         let addFriendReg = eval(config.ADDFRIENDWORD)
  82.         if (addFriendReg.test(friendship.hello())) {
  83.           logMsg = '自动添加好友,因为验证信息中带关键字‘每日说’'
  84.           await friendship.accept()
  85.         } else {
  86.           logMsg = '没有通过验证 ' + friendship.hello()
  87.         }
  88.         break
  89.         /**
  90.          *
  91.          * 2. Friend Ship Confirmed
  92.          *
  93.          */
  94.       case Friendship.Type.Confirm:
  95.         logMsg = 'friend ship confirmed with ' + friendship.contact().name()
  96.         break
  97.     }
  98.   } catch (e) {
  99.     logMsg = e.message
  100.   }
  101.   console.log(logMsg)
  102. }
  103. // 自动发消息功能
  104. async function main() {
  105.   let  contact = await bot.Contact.find({name:config.NICKNAME}) || await bot.Contact.find({alias:config.NAME}) // 获取你要发送的联系人
  106.   let one = await superagent.getOne() //获取每日一句
  107.   let weather = await superagent.getWeather() //获取天气信息
  108.   let today = await untils.formatDate(new Date())//获取今天的日期
  109.   let memorialDay = untils.getDay(config.MEMORIAL_DAY)//获取纪念日天数
  110.   let str = today + '<br>' + '今天是我们在一起的第' + memorialDay + '天'
  111.       + '<br><br>今日天气早知道<br><br>' + weather.weatherTips +'<br><br>' +weather.todayWeather+ '每日一句:<br><br>'+one+'<br><br>'+'------来自最爱你的我'
  112.   await contact.say(str)//发送消息
  113. }
  114. const bot = new Wechaty()
  115. bot.on('scan',    onScan)
  116. bot.on('login',   onLogin)
  117. bot.on('logout',  onLogout)
  118. bot.on('message', onMessage)
  119. bot.on('friendship', onFriendShip)
  120. bot.start()
  121.     .then(() => console.log('开始登陆微信'))
  122.     .catch(e => console.error(e))

superagent/index.js

  1. const superagent = require('../config/superagent')
  2. const config = require('../config/index')
  3. const cheerio = require('cheerio')
  4. async function getOne() { // 获取每日一句
  5.   let res = await superagent.req(config.ONE,'GET')
  6.   let $ = cheerio.load(res.text)
  7.   let todayOneList = $('#carousel-one .carousel-inner .item')
  8.   let todayOne = $(todayOneList[0]).find('.fp-one-cita').text().replace(/(^\s*)|(\s*$)/g, "")
  9.   return todayOne;
  10. }
  11. async function getWeather() { //获取墨迹天气
  12.   let url = config.MOJI_HOST+config.CITY+'/'+config.LOCATION
  13.   let res = await superagent.req(url,'GET')
  14.   let $ = cheerio.load(res.text)
  15.   let weatherTips = $('.wea_tips em').text()
  16.   const today = $('.forecast .days').first().find('li');
  17.   let todayInfo = {
  18.       Day:$(today[0]).text().replace(/(^\s*)|(\s*$)/g, ""),
  19.       WeatherText:$(today[1]).text().replace(/(^\s*)|(\s*$)/g, ""),
  20.       Temp:$(today[2]).text().replace(/(^\s*)|(\s*$)/g, ""),
  21.       Wind:$(today[3]).find('em').text().replace(/(^\s*)|(\s*$)/g, ""),
  22.       WindLevel:$(today[3]).find('b').text().replace(/(^\s*)|(\s*$)/g, ""),
  23.       PollutionLevel:$(today[4]).find('strong').text().replace(/(^\s*)|(\s*$)/g, "")
  24.   }
  25.   let obj = {
  26.     weatherTips:weatherTips,
  27.     todayWeather:todayInfo.Day + ':' + todayInfo.WeatherText + '<br>' + '温度:' + todayInfo.Temp +  '<br>'
  28.         + todayInfo.Wind + todayInfo.WindLevel + '<br>' + '空气:' + todayInfo.PollutionLevel + '<br>'
  29.   }
  30.   return  obj
  31. }
  32. module.exports ={
  33.   getOne,getWeather
  34. }


项目运行

由于需要安装chromium, 所以要先配置一下镜像,注意由于wechaty的限制,最好使用node10以上版本

npm

  1. npm config set registry https://registry.npm.taobao.org
  2. npm config set disturl https://npm.taobao.org/dist
  3. npm config set puppeteer_download_host https://npm.taobao.org/mirrors

yarn

  1. yarn config set registry https://registry.npm.taobao.org
  2. yarn config set disturl https://npm.taobao.org/dist
  3. yarn config set puppeteer_download_host https://npm.taobao.org/mirrors

然后进行项目安装

  1. git clone git@github.com:gengchen528/wechatBot.git
  2. cd wechatBot
  3. npm install 或 cnpm install

参数配置

wechatBot/config/index.js

  1. // 配置文件
  2. module.exports ={
  3.   // 基础定时发送功能配置项(必填项)
  4.   NAME:'A兔子',//备注姓名
  5.   NICKNAME:'嗯哼', //昵称
  6.   MEMORIAL_DAY:'2015/04/18', //你和收信者的纪念日
  7.   CITY:'shanghai',//收信者所在城市
  8.   LOCATION:'pudong-new-district',//收信者所在区 (可以访问墨迹天气网站后,查询区的英文拼写)
  9.   SENDDATE:'0 0 8 * * *',//定时发送时间 每天8点0分0秒发送,规则见 /schedule/index.js
  10.   ONE:'http://wufazhuce.com/',////ONE的web版网站
  11.   MOJI_HOST:'https://tianqi.moji.com/weather/china/', //中国墨迹天气url
  12.   //高级功能配置项(非必填项)
  13.   AUTOADDFRIEND:false,//自动加好友功能  默认关闭
  14.   AUTOADDROOM:false,//自动拉群功能 默认关闭
  15.   AUTOREPLY:false,//自动聊天功能 默认关闭
  16.   AIBOTAPI:'http://www.tuling123.com/openapi/api',//图灵机器人API 注册地址http://www.turingapi.com/
  17.   APIKEY:'你的图灵机器人apikey',//图灵机器人apikey
  18.   ROOMNAME:'/^你的群名/i', //群名(请只修改中文,不要删除符号,这是正则)
  19.   ADDFRIENDWORD:'/你要触发的关键词/i',//自动加好友触发的关键词(请只修改中文,不要删除符号,这是正则)
  20.   ADDROOMWORD:'/加群/',//自动发送群图片触发关键词(请只修改中文,不要删除符号,这是正则)
  21.   ROOMCODEURL:'http://image.bloggeng.com/qun.png',//群二维码url链接(与本地群二维码路径选填一个)
  22.   ROOMLOCALPATH:'./static/qun.png',//本地群二维码图片路径(与群url选填一个)
  23. }

开始运行

  1. npm run start
  2. 然后掏出你的手机,最好使用小号,扫描控制台的二维码即可

待解决问题

  • 最好能够使用小号登录,如果是常用微信登录,在电脑客户端登陆后可能会wechaty挤掉
  • 墨迹天气页面在获取的时候可能会存在延时,有时可能获取不到

后续功能

  • 为了防止占用你的微信号,你和你的爱人添加我的微信后。你发送指定内容,我将会每天帮你发送消息
  • 还有在思考中...(你有好的想法也可以提出来)

最后

因为给这个微信加了自动加好友和拉群功能,所以有兴趣的小伙伴可以加我的微信进行测试,记得在加好友的时候带上暗号:微信每日说,加好友后发送加群,会自动发送群的二维码;

注意 加好友请在验证中填写 微信每日说 才可以自动加好友

用Node+wechaty写一个爬虫脚本每天定时给女(男)朋友发微信暖心话

赶快亲自试一试吧,相信你会挖掘出更多好玩的功能

github:https://github.com/gengchen528/wechatBot

另外我的公众号已经接入微软小冰,关注后发语音会有小姐姐的声音陪你聊天,也可以和她文字聊天,有兴趣可以试试看,单身的欢迎来撩

用Node+wechaty写一个爬虫脚本每天定时给女(男)朋友发微信暖心话
weinxin
我的微信
这是我的微信扫一扫
kiven

发表评论

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen: