mini_read_space_front/destroy/upload.main.js

const {fork} = require('child_process');
const fs = require('fs');
const path = require('path');

let config = {
    appIds: [], // 小程序appid
    version: "",//版本号
    desc: "",//版本描述
    env: '正式环境'
}

function publishMiniProgram(options) {
    return new Promise((resolve, reject) => {
        const child = fork('./destroy/upload.wx.js');
        // console.log('入参：',options);
        child.send(options);
        child.on('message', (msg) => {
            if (msg.error) {
                reject(new Error(msg.error));
            } else {
                resolve(msg);
            }
        });
        child.on('error', reject);
        child.on('exit', (code) => {
            if (code !== 0) {
                reject(new Error(`child process exited with code ${code}`));
            }
        });
    })
}

exports.start = async () => {
    try {
        const file = await fs.promises.readFile(
            path.join(__dirname, '../destroy/config.json'),
            'utf-8'
        );
        const fileJson = JSON.parse(file);
        config = {
            ...config,
            appIds: fileJson.appIds,
            version: fileJson.version,
            desc: fileJson.desc,
            env: fileJson.env || '正式环境',
            robot: fileJson.robot
        };
        let desc_one = `本次提交小程序: ${config.appIds.map(item => `${item.name} (${item.appid})`).join(', ')}`;
        let desc_two = `版本: ${config.version}`;
        let desc_three = `描述: ${config.desc}` + '\n' + '▶️ 开始上传IAA小说代码';
        console.log(desc_one);
        console.log(desc_two);
        console.log(`环境: ${config.env}`);
        console.log(desc_three);
        sendNotice(desc_one + '\n' + desc_two + '\n' +
            '-----------------------------------'
            + desc_three);
        // 3. 顺序发布（避免并发资源竞争）
        let successCount = 0;
        let failedCount = 0;
        let failApp = '';
        for (const [index, item] of config.appIds.entries()) {
            try {
                console.log(`\n开始发布第 ${index + 1} 个小程序: ${item.name} (${item.appid})  版本：${config.version}`);
                await publishMiniProgram({
                    appid: item.appid,
                    name: item.name,
                    version: config.version,
                    desc: `${config.env}——${config.desc}`,
                    env: config.env
                });
                successCount++;
                console.log(`✅ 发布成功: ${item.name} 版本：${config.version}`);
            } catch (err) {
                failedCount++;
                console.error(`❌ 发布失败: ${item.name} 版本：${config.version}`, err.message);
                failApp += `${item.name} (${item.appid})\n`;
            }
        }
        resultMsg = '版本：' + config.version + `\n发布结果: ✅ ${successCount} 个小程序发布成功，❌ ${failedCount} 个小程序发布失败。` + '\n失败列表：' + failApp;
        sendNotice(resultMsg);
        // 4. 返回统计结果
        return {
            success: successCount,
            failed: failedCount,
        };
    } catch (e) {
        console.error('❌ 启动发布流程失败:', e.message);
        throw e;
    }
}

function sendNotice(msg) {
    console.log(msg)
    url = config.robot
    if (url) {
        fetch(url, {
            method: 'POST',
            headers: {
                'Content-Type': 'application/json'
            },
            body: JSON.stringify({
                msgtype: 'text',
                text: {
                    content: msg
                }
            })
        })
    } else {
        console.log('未配置机器人地址')
    }
}