0

我现在坚持使用 NodeJS 和 Busboy 进行我的项目。我正在尝试从路由器中检索所有变量并将其发送到控制器。

app.js(路由)

router.post('/product', function (req, res) {
var fields = {};
req.busboy.on('field', function(fieldname, val) {
        fields[fieldname] = val;
});
req.busboy.on('file', function (fieldname, file, filename, encoding, mimetype) {
    fields[filename] = file;
});
req.pipe(req.busboy);


productController.addNewProduct(fields, function (data) {
    res.json(data);
});
});

ProductController.js

addNewProduct: function (params, callback) {
    productLogic.addNewProduct(params, function (data) {
        callback(data);
    });
},

ProductLogic.js

addNewProduct: function (params, callback) {
    Product.findOne({ name: params.name }, function (err, product) {
        if(err) callback({ status: false, message: err });

        if(product)
            callback({ status: false, message: 'Produk sudah ada.' });

        var newProduct = new Product({
            name: params.name,
            category_id: params.category_id,
            description: params.description,
            is_active: true
        });

        newProduct.save(function (err, result) {
            if(err) callback({ status: false, message: err });

            callback({ status: true, message: result });
        });
    });
},

我的目标是一次处理所有数据。现在我不确定我是否可以用 busboy 实现它。

请帮助我。

提前致谢

4

2 回答 2

0

我想我已经找到了答案。感谢马顿的提醒。

我试过了:

busboy.on('finish', function() {});

但它从未发出过。

原因是我必须在我的 busboy.on('file') 中使用 file.resume(),例如:

busboy.on('file', function(fieldname, file, filename, encoding, mimetype) {
fields[fieldname] = file;
file.resume();

再次感谢:)

于 2016-07-08T16:02:54.230 回答
0

在调用您的方法之前,您应该等待 busboy 完成对表单的解析。

busboy.on('finish', function() {
  productController.addNewProduct(fields, function (data) {
    res.json(data);
  });
});
于 2016-07-08T08:52:22.327 回答