rc-plugin/apps/daily.js

import common from '../../../lib/common/common.js'
import fetch from 'node-fetch'
import schedule from 'node-schedule'
import { Group, segment } from 'oicq'

// 指定定时发送的群号
const groupList = [ '169721415' ]

// 是否开启定时推送，默认为 true
let isAutoPush = true
function autoTask (func, time) {
    if (isAutoPush) {
        schedule.scheduleJob(time, () => {
            for (let i = 0; i < groupList.length; i++) {
                let group = Bot.pickGroup(groupList[i])
                func(group)
                common.sleep(1000)
            }
        })
    }
}

// 定时任务合集
autoTask(pushDailyWorld, '0 30 8 * * ?')

export class daily extends plugin {
    constructor (e) {
        super({
            name: 'rconsole插件帮助',
            dsc: 'rconsole插件帮助插件帮助',
            event: 'message',
            priority: 500,
            rule: [
                {
                    reg: '^#每天60秒$',
                    fnc: 'pushDailyWorld'
                },
                {
                    reg: '^#开关每日推送$',
                    fnc: 'shutdown'
                },
            ]
        })
    }

    async dailyWorld (e) {
        // 定时发送时间，采用 Cron 表达式，当前默认为每日 8:30 分推送
        await pushDailyWorld(e)
        return true
    }

    async shutdown (e) {
        isAutoPush = !isAutoPush
        e.reply(`【当前推送状态】：${ isAutoPush ? '开启' : '关闭' }`)
    }
}

/**
 * 推送每天60秒读懂世界
 * @param e oicq传递的事件参数e
 */
async function pushDailyWorld (e) {
    // 每天60秒读懂世界接口地址
    const url = await fetch('http://bjb.yunwj.top/php/tp/lj.php')
        .catch(err => logger.error(err))
    const imgUrl = await url.json()
    const res = await imgUrl.tp

    // 判断接口是否请求成功
    if (!res) {
        e.reply('[60秒读懂世界] 接口请求失败')
    }

    // 回复消息
    if (e instanceof Group) {
        e.sendMsg(segment.image(res))
    } else {
        e.reply(segment.image(res))
    }
}