关于Nodejs async parallel的问题

async.inject(ids, 0, function (successLen, id, callback) {
  Model.findByIdAndUpdate(id, update, function (err, Model) {
    if (err) return callback(err)
    callback(null, ++successLen)
  })
},

function (err, successLen) {
  if (err) return // handle err...
  console.log('successLen', successLen)
})

這樣寫會不會更簡單些：

Model.update(conditions, update, { multi: true }, function (err, numberAffected) {
  if (err) return // handle err...
  console.log('numberAffected', numberAffected)
})

參考討論看看。 :)

在使用 Node.js 和 Mongoose 进行批量更新时，async 库中的 parallel 方法可以帮助你并行执行多个异步操作。这不仅可以提高效率，还能更清晰地组织代码。下面是如何使用 async.parallel 来处理你的需求，并获取最终成功更新的数量。

示例代码

首先，确保你已经安装了 async 库：

npm install async

然后，你可以按照以下方式重构你的代码：

const async = require('async');
const mongoose = require('mongoose');

// 假设 merchandiseModel 是你的 Mongoose 模型
const merchandiseModel = mongoose.model('Merchandise', new mongoose.Schema({}));

var ids = [1, 2, 3, 4, 5];
var successCount = 0;

async.parallel(
    ids.map(id => callback => 
        merchandiseModel.findByIdAndUpdate(id, 
            { $inc: { order_num: 2 } }, 
            { new: true }, // 确保返回更新后的文档
            (err, doc) => {
                if (err) {
                    console.error(err.message);
                    callback(err); // 将错误传递给 async
                    return;
                }
                if (doc) {
                    successCount++;
                }
                callback(null, doc); // 成功时调用 callback 并传入结果
            }
        )
    ),
    (err, results) => {
        if (err) {
            console.error("An error occurred:", err);
            return;
        }
        console.log(`Total successful updates: ${successCount}`);
        // results 包含每个异步操作的结果
    }
);

解释

1. async.parallel: 该函数接受两个参数：一个任务数组和一个回调函数。任务数组中的每个元素都是一个函数，该函数接收一个 callback 函数作为参数。

2. ids.map: 使用 map 方法遍历 ids 数组，并为每个 id 创建一个任务。每个任务是一个函数，它调用 findByIdAndUpdate 方法来更新数据库。

3. findByIdAndUpdate: 这个方法用于查找文档并更新它。我们传递 { new: true } 参数以确保返回更新后的文档，而不是原始文档。

4. callback: 在 findByIdAndUpdate 的回调中，我们检查是否有错误发生。如果有错误，则通过 callback(err) 传递错误。如果更新成功，我们增加 successCount 计数器。

5. 最终的回调: 当所有并行任务完成后，async.parallel 的第二个参数将被调用。此时，results 参数包含了每个任务的结果。你可以在这里处理这些结果或进行其他清理工作。

这种方法不仅使代码更简洁、更易读，而且利用了 async.parallel 的能力来高效地并行执行多个异步操作。