0

在我的程序中上传 excel 文件时，需要将其转换为 CSV 文件才能读取。该过程运行良好，我正在使用asyc/await，但是每当我尝试使用csvtojsonNode 中的包读取文件时，文件都无法正确读取。如果我直接使用 CSV 文件，那么它工作正常。发生转换时会出现问题。

产品.js

const multer = require('multer');
const express = require('express');
const router = express.Router();
const csv = require('csvtojson');
const fs = require('fs');
const xlsx = require('node-xlsx');

router.post('/upload', upload.single('singleFile'), async (req, res) => {
    let csvFilePath = req.file.path;
    let fileType = req.file.mimetype;

    const convertToCSV = async _ => {
        console.log("2");
        if (fileType === 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet' ||
            fileType === 'application/vnd.ms-excel') {
            let obj = xlsx.parse(csvFilePath);
            let rows = [];
            let writeStr = "";

            for (let i = 0; i < obj.length; i++) {
                let sheet = obj[i];
                for (let j = 0; j < sheet['data'].length; j++) {
                    rows.push(sheet['data'][j]);
                }
            }

            //creates the csv string to write it to a file
            for (let i = 0; i < rows.length; i++) {
                writeStr += rows[i].join(",") + "\n";
            }

            console.log("3");
            fs.writeFile("csv/out.csv", writeStr, function (err) {
                if (err) {
                    return res.status(400).send({'error': err});
                }
                console.log("4");
                console.log("out.csv was saved in the current directory!");
            });
        }
    }
    console.log("1");
    await convertToCSV().then(async _ => {
        console.log("5");
        const jsonArray = await csv({flatKeys: true})
            .fromFile(csvFilePath)
            .then(async (jsonObj) => {
                console.log("6");
                console.log(jsonObj[0]);
                ...
                
                //Few more functions
                
            }).catch(err => {
                return res.status(400).send(err);
            });
    });
});

我的控制台日志看起来像这样

1
2
3
5
4
out.csv was saved in the current directory!
6
{
  'PK\u0003\u0004\u0014\u0000\u0006\u0000\b\u0000\u0000\u0000!\u0000b�h^\u0001\u0000\u0000�\u0004\u0000\u0000\u0013\u0000\b\u0002[Content_Types].xml �\u0004\u0002(�\u0000\u0002\u0000\u0000\
u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u00

而如果上传新的 CSV 文件或使用现有的 CSV，则输出console.log(jsonObj[0]);为

{
  'Column1': 'Column 1 Data',
  field2: 'field2 Data',
  field3: 'field 3 Data',
  Categories: 'categories',
  ....
}

我await之前添加了fs.writeFile但是出现了同样的问题。有两个文件保存在目录下csv/

c33129f3bdef482657992dbf452d2c1b
out.csv

并且读取前一个文件的内容（假设，因为它们非常相似）并且out.csv不被读取。

更新

包装了一个承诺fs.writeFile，现在订购了控制台，但是读取数据的输出仍然相同：

 const convertToCSV = async _ => {
        return new Promise(((resolve, reject) => {
            console.log("2");
            ....

                console.log("3");
                fs.writeFile("csv/out.csv", writeStr, function (err) {
                    if (err) {
                        return res.status(400).send({'error': err});
                    }
                    console.log("4");
                    console.log("out.csv was saved in the current directory!");
                    resolve();
                });
            }
        }));
    }

控制台日志

1
2
3
4
out.csv was saved in the current directory!
5
6
{
  'PK\u0003\u0004\u0014\u0000\u0006\u0000\b\u0000\u0000\u0000!\u0000b�h^\u0001\u0000\u0000�\u0004\u0000\u0000\u0013\u0000\b\u0002[Content_Types].xml �\u0004\u0002(�\u0000\u0002\u0000\u0000\
u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u00
4

1 回答 1

1

您无需等待fs.writeFile("csv/out.csv"，这就是您在控制台5之前获得的原因。4你应该将你的函数内容包装到 Promise 中：

const convertToCSV = async _ => {
  return new Promise((resolve, reject) => {
     console.log("2");
     ...
     console.log("3");
     fs.writeFile("csv/out.csv", writeStr, function (err) {
        if (err) {
          // I'd prefer to call "reject" here and add try/catch outside for sending 400
          return resolve(res.status(400).send({'error': err}));
        }
        console.log("4");
        console.log("out.csv was saved in the current directory!");
        resolve();
     });
  })
)

您还阅读csvFilePath了包含 Excel 文件的文件名，而不是存储在csv/out.csv名称下的 CSV。

于 2020-11-01T17:43:07.850 回答