project,

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

Leo chen Leo chen Follow Apr 02, 2019 · 12 mins read
用Node+wechaty写一个爬虫脚本每天定时给女(男)朋友发微信暖心话

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

项目介绍

灵感来源

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

项目地址

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

使用库

功能

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

数据来源

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

定时任务

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

实现效果

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

koa2

koa2

代码说明

目录结构

koa2

  • config: 存放公共变量和superagent的配置
  • schedule: 任务调度的配置
  • superagent: 获取每日一句和天气信息
  • untils: 抽取的共用方法

核心代码

index.js

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

    /**
     * WechatBot
     *  - https://github.com/gengchen528/wechatBot
     */
    import {Wechaty,Friendship}  from 'wechaty'
    import schedule  from './schedule/index'
    import config  from './config/index'
    import untils  from './untils/index'
    import superagent  from './superagent/index'
    import {FileBox}  from 'file-box' //文件读取模块
    //  二维码生成
    function onScan (qrcode, status) {
      require('qrcode-terminal').generate(qrcode)  // 在console端显示二维码
      const qrcodeImageUrl = [
      'https://api.qrserver.com/v1/create-qr-code/?data=',
      encodeURIComponent(qrcode),
      ].join('')
      console.log(qrcodeImageUrl)
    }

    // 登录
    async function onLogin (user) {
      console.log(`贴心小助理${user}登录了`)
      // 登陆后创建定时任务
      schedule.setSchedule(config.SENDDATE,()=>{
      console.log('你的贴心小助理开始工作啦！')
        main()
      })
    }

    //登出
    function onLogout(user) {
      console.log(`${user} 登出`)
    }
    // 监听对话 根据关键词自动加群
    async function onMessage (msg) {
      const contact = msg.from() // 发消息人
      const content = msg.text() //消息内容
      const room = msg.room() //是否是群消息
      const roomCodeUrl = FileBox.fromUrl(config.ROOMCODEURL) //来自url的文件
      const roomCodeLocal = FileBox.fromFile(config.ROOMLOCALPATH) //添加本地文件
      if (msg.self()) {
      return
      }
      if(room){ // 如果是群消息
      const topic = await room.topic()
        console.log(`群名: ${topic} 发消息人: ${contact.name()} 内容: ${content}`)
      }else { // 如果非群消息
      console.log(`发消息人: ${contact.name()} 消息内容: ${content}`)
      let addRoomReg = eval(config.ADDROOMWORD)
      let roomReg = eval(config.ROOMNAME)
      if(addRoomReg.test(content)&&!room){
        let keyRoom = await this.Room.find({topic: roomReg})
        if(keyRoom){
          try{
            await contact.say(roomCodeLocal||roomCodeUrl)
            await keyRoom.say('微信每日说：欢迎新朋友', contact)
          }catch (e) {
            console.error(e)
          }
        }
      }else {
        await contact.say('你好，不要轻易调戏我，我只会发群二维码，不会聊天的！')
        await contact.say('请回复暗号：加群  获取群二维码图片')
      }
      }
    }
    // 自动加好友功能
    async function onFriendShip(friendship) {
      let logMsg
      try {
      logMsg = '添加好友' + friendship.contact().name()
      console.log(logMsg)

      switch (friendship.type()) {
        /**
         *
         * 1. New Friend Request
         *
         * when request is set, we can get verify message from `request.hello`,
         * and accept this request by `request.accept()`
         */
        case Friendship.Type.Receive:
          let addFriendReg = eval(config.ADDFRIENDWORD)
        if (addFriendReg.test(friendship.hello())) {
          logMsg = '自动添加好友，因为验证信息中带关键字‘每日说’'
          await friendship.accept()
        } else {
          logMsg = '没有通过验证 ' + friendship.hello()
        }
        break
        /**
         *
         * 2. Friend Ship Confirmed
         *
         */
        case Friendship.Type.Confirm:
        logMsg = 'friend ship confirmed with ' + friendship.contact().name()
        break
      }
      } catch (e) {
      logMsg = e.message
      }
      console.log(logMsg)
    }
    // 自动发消息功能
    async function main() {
      let  contact = await bot.Contact.find({name:config.NICKNAME}) || await bot.Contact.find({alias:config.NAME}) // 获取你要发送的联系人
      let one = await superagent.getOne() //获取每日一句
      let weather = await superagent.getWeather() //获取天气信息
      let today = await untils.formatDate(new Date())//获取今天的日期
      let memorialDay = untils.getDay(config.MEMORIAL_DAY)//获取纪念日天数
      let str = today + '<br>' + '今天是我们在一起的第' + memorialDay + '天'
        + '<br><br>今日天气早知道<br><br>' + weather.weatherTips +'<br><br>' +weather.todayWeather+ '每日一句:<br><br>'+one+'<br><br>'+'------来自最爱你的我'
      await contact.say(str)//发送消息
    }

    const bot = new Wechaty()

    bot.on('scan',    onScan)
    bot.on('login',   onLogin)
    bot.on('logout',  onLogout)
    bot.on('message', onMessage)
    bot.on('friendship', onFriendShip)

    bot.start()
      .then(() => console.log('开始登陆微信'))
      .catch(e => console.error(e))

superagent/index.js

    import superagent  from '../config/superagent'
    import config  from '../config/index'
    import cheerio  from 'cheerio'

    async function getOne() { // 获取每日一句
      let res = await superagent.req(config.ONE,'GET')
      let $ = cheerio.load(res.text)
      let todayOneList = $('#carousel-one .carousel-inner .item')
      let todayOne = $(todayOneList[0]).find('.fp-one-cita').text().replace(/(^\s*)|(\s*$)/g, "")
      return todayOne;
    }

    async function getWeather() { //获取墨迹天气
      let url = config.MOJI_HOST+config.CITY+'/'+config.LOCATION
      let res = await superagent.req(url,'GET')
      let $ = cheerio.load(res.text)
      let weatherTips = $('.wea_tips em').text()
      const today = $('.forecast .days').first().find('li');
      let todayInfo = {
        Day:$(today[0]).text().replace(/(^\s*)|(\s*$)/g, ""),
        WeatherText:$(today[1]).text().replace(/(^\s*)|(\s*$)/g, ""),
        Temp:$(today[2]).text().replace(/(^\s*)|(\s*$)/g, ""),
        Wind:$(today[3]).find('em').text().replace(/(^\s*)|(\s*$)/g, ""),
        WindLevel:$(today[3]).find('b').text().replace(/(^\s*)|(\s*$)/g, ""),
        PollutionLevel:$(today[4]).find('strong').text().replace(/(^\s*)|(\s*$)/g, "")
      }
      let obj = {
      weatherTips:weatherTips,
      todayWeather:todayInfo.Day + ':' + todayInfo.WeatherText + '<br>' + '温度:' + todayInfo.Temp +  '<br>'
        + todayInfo.Wind + todayInfo.WindLevel + '<br>' + '空气:' + todayInfo.PollutionLevel + '<br>'
      }
      return  obj
    }
    module.exports ={
      getOne,getWeather
    }

项目运行

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

npm

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

yarn

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

然后进行项目安装

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

参数配置

wechatBot/config/index.js

项目相关配置

config/index.js

    // 配置文件
    module.exports ={
      // 基础定时发送功能配置项（必填项）
      NAME:'A兔子',//备注姓名
      NICKNAME:'嗯哼', //昵称
      MEMORIAL_DAY:'2015/04/18', //你和收信者的纪念日
      CITY:'shanghai',//收信者所在城市
      LOCATION:'pudong-new-district',//收信者所在区 （可以访问墨迹天气网站后，查询区的英文拼写）
      SENDDATE:'0 0 8 * * *',//定时发送时间 每天8点0分0秒发送，规则见 /schedule/index.js
      ONE:'http://wufazhuce.com/',////ONE的web版网站
      MOJI_HOST:'https://tianqi.moji.com/weather/china/', //中国墨迹天气url

      //高级功能配置项（非必填项）
      AUTOADDFRIEND:false,//自动加好友功能  默认关闭
      AUTOADDROOM:false,//自动拉群功能 默认关闭
      AUTOREPLY:false,//自动聊天功能 默认关闭
      AIBOTAPI:'http://www.tuling123.com/openapi/api',//图灵机器人API 注册地址http://www.turingapi.com/
      APIKEY:'你的图灵机器人apikey',//图灵机器人apikey
      ROOMNAME:'/^你的群名/i', //群名(请只修改中文，不要删除符号，这是正则)
      ADDFRIENDWORD:'/你要触发的关键词/i',//自动加好友触发的关键词(请只修改中文，不要删除符号，这是正则)
      ADDROOMWORD:'/加群/',//自动发送群图片触发关键词(请只修改中文，不要删除符号，这是正则)
      ROOMCODEURL:'http://image.bloggeng.com/qun.png',//群二维码url链接(与本地群二维码路径选填一个)
      ROOMLOCALPATH:'./static/qun.png',//本地群二维码图片路径（与群url选填一个）
    }

开始运行

npm run start

然后掏出你的手机，最好使用小号，扫描控制台的二维码即可

待解决问题

  • 墨迹天气页面在获取的时候可能会存在延时，有时可能获取不到

常见问题处理

  1. 我的微信号无法登陆

从2017年6月下旬开始，使用基于web版微信接入方案存在大概率的被限制登陆的可能性。 主要表现为：无法登陆Web 微信，但不影响手机等其他平台。 验证是否被限制登陆： https://wx.qq.com 上扫码查看是否能登陆。 更多内容详见：

  1. 执行npm run start时无法安装puppet-puppeteer&&Chromium

Centos7下部署出现以下问题

image

问题原因:https://segmentfault.com/a/1190000011382062

解决方案:

#依赖库
yum install pango.x86_64 libXcomposite.x86_64 libXcursor.x86_64 libXdamage.x86_64 libXext.x86_64 libXi.x86_64 libXtst.x86_64 cups-libs.x86_64 libXScrnSaver.x86_64 libXrandr.x86_64 GConf2.x86_64 alsa-lib.x86_64 atk.x86_64 gtk3.x86_64 -y

#字体
yum install ipa-gothic-fonts xorg-x11-fonts-100dpi xorg-x11-fonts-75dpi xorg-x11-utils xorg-x11-fonts-cyrillic xorg-x11-fonts-Type1 xorg-x11-fonts-misc -y
  • windows下，下载puppeteer失败

链接：https://pan.baidu.com/s/1YF09nELpO-4KZh3D2nAOhA
提取码：0mrz
把下载的文件放到如下图路径，并解压到当前文件夹中即可
image

  1. 支持 红包、转账、朋友圈… 吗

支付相关 - 红包、转账、收款 等都不支持

  1. 更多关于wechaty功能相关接口

参考wechaty官网文档

  1. 其他问题解决方案

    • 先检查node版本是否大于10
    • 确认npm或yarn已经配置好淘宝源
    • 存在package-lock.json文件先删除
    • 删除node_modules后重新执行npm install 或cnpm install

注意

本项目属于个人兴趣开发，开源出来是为了技术交流，请勿使用此项目做违反微信规定或者其他违法事情。 建议使用小号进行测试，有被微信封禁网页端登录权限的风险（客户端不受影响），请确保自愿使用。因为个人使用不当导致网页端登录权限被封禁，均与作者无关，谢谢理解

最后

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

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

image

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

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

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

image

作者: Leo_chen，前端工程师，喜欢使用node做各种小项目，就职于大数据公司。本篇文章首发于掘金: 用Node+wechaty写一个爬虫脚本每天定时给女(男)朋友发微信暖心话

code featured social entertainment
Join Newsletter
Get the latest news right in your inbox. We never spam!
Leo chen
Written by Leo chen
高级前端工程师一枚，喜欢用node做各种项目，生命不止，折腾不息！
使用koa2+wechaty打造个人微信小秘书
居然有人能忘记吃饭？写个微信机器人提醒他