ic-ctbu-backend/plugin/mq/enqueueLepaoStartRun.js

const mq = require('./index')
const { assertRunforgeTaskIngress, publishRunforgeTask } = require('./runforgeTaskMq')

/**
 * 将乐跑任务写入 MQ，由 Worker 执行（与 SingleRun 一致）
 */
async function enqueueLepaoStartRun(studentNum, logger) {
    try {
        const channel = await mq.getChannel('lepao_account_autorun')
        await assertRunforgeTaskIngress(channel, logger)
        const taskId = `lepao:account:${Date.now()}:${studentNum}`
        publishRunforgeTask(channel, {
            id: taskId,
            type: 'lepao.startRun',
            data: {
                taskId,
                account: studentNum
            },
            retry: 0
        })
    } catch (e) {
        logger?.error?.(`投递自动乐跑任务失败 ${studentNum}: ${e.message || e}`)
    }
}

module.exports = { enqueueLepaoStartRun }