你想每天定时向你的女朋友发一句早安吗 ？教你实现一个微信机器人

import { Wechaty } from 'wechaty'

const bot = new Wechaty({
  // 微信机器人使用了 iPad 协议登录，puppet 为 `PuppetPadplus`
  puppet: new PuppetPadplus(),
  name: 'daxiange'
})

bot
  .on('scan', (qrcode, status) => console.log(`Scan QR Code to login: ${status}\nhttps://api.qrserver.com/v1/create-qr-code/?data=${encodeURIComponent(qrcode)}`))
  .on('message',       message => console.log(`Message: ${message}`))
  .start()

$ WECHATY_PUPPET_PADPLUS_TOKEN=HELLOSHANYUE ts-node index.ts

import { Friendship } from 'wechaty'

bot
   .on('friendship', handleFriendShip)

const handleFriendShip = async (friendship) => {
  // 如果是添加好友请求
  if (friendship.type() === Friendship.Type.Receive) {
    // 通过好友请求
    await friendship.accept()

    const room = await bot.Room.find({ topic: 'wechat' })
    if (room) {
      try {
        // 添加好友入群
        await room.add(friendship.contact())
      } catch(e) {
        console.error(e)
      }
    }
}

// index.ts
bot
  .on('message', message.handleMessage)

// message.ts
const defaultRoute = { keyword: '', handle: covid.keyword }
const routes = [
  { keyword: '基金', handle: fund.topFund },
  { keyword: '面试', handle: interview.randomQuestion },
  { keyword: '文章', handle: recentArticle },
  defaultRoute
]

async function reply (msg: Message, _data) {
  const data = _.concat(_data)
  for (const text of data) {
    if (text) {
      await msg.say(text)
    }
  }
}

export async function handleMessage (msg: Message) {
  // 如果收到了文本消息
  if (msg.type() === Message.Type.Text) {
    // 如果不是微信群
    if (!msg.room()) {
      const text = msg.text()
      // 通过用户回复关键字，进行路由处理，找到对应的处理函数
      const route = routes.find(route => {
        return text.includes(route.keyword)
      }) || defaultRoute
      const data = await route.handle(text)
      await reply(msg, data)
    }
  }
}

// index.ts
import { schedule } from './schedule'

bot
  .start()
  .then(() => {
    schedule(bot)
  })

// schedule/index.ts
import { Wechaty } from 'wechaty'

import articleBot from './article'

export async function schedule (bot: Wechaty) {
  await articleBot(bot)
  // await schedule1(bot)
  // await schedule2(bot)
}

// schedule/article.ts
// 定时定点群发消息
import { Wechaty } from 'wechaty'
import { CronJob } from 'cron'

export default async (bot: Wechaty) => {
  return new CronJob('13 12 * * *', async () => {
    const rooms = await bot.Room.findAll()
    const article = await recentArticle()
    await pMap(targetRooms, async room => {
      await room.say(article)
    }, {
      concurrency: 6
    })
  }, null, true, 'Asia/Shanghai')
}

Sentry.init({
  dsn
})

bot.on('error', (error) => {
  Sentry.captureException(error)
})