2 var _ = require('lodash');
\r
3 var csvtojson = require('csvtojson');
\r
4 var async = require('async');
\r
5 var uuid = require('node-uuid'); // generate a uuid with "uuid.v1()"
\r
6 var path = require('path');
\r
7 var fs = require("fs");
\r
8 var moment = require('moment');
\r
10 var helpers = module.exports;
\r
12 function puts(obj) { console.log(obj); }
\r
13 function putd(obj) { console.log(obj); }
\r
14 helpers.puts = puts;
\r
15 helpers.putd = putd;
\r
18 helpers.readCsv = function(filedir, filename, callback) {
\r
21 var Converter=csvtojson.Converter;
\r
22 var csvFileName=path.join(filedir,filename);
\r
23 var fileStream=fs.createReadStream(csvFileName);
\r
24 fileStream.on('error', function(err){
\r
25 callback(err, null);
\r
27 var param={noheader:true, checkType:false};
\r
28 var csvConverter=new Converter(param);
\r
29 csvConverter.on("end_parsed",function(jsonObj){
\r
30 var returnValue = jsonObj;
\r
31 callback(null, returnValue);
\r
33 fileStream.on('error', function(err) {
\r
37 fileStream.pipe(csvConverter);
\r
40 helpers.getParam = function(csv, matchField, matchValue, returnField) {
\r
41 dataRow=_.find(csv, matchField, matchValue);
\r
42 dataValue=dataRow[returnField];
\r
46 helpers.writeOutput = function(req, filename, jsonOutput, callback) {
\r
48 fs.writeFileSync(filename, jsonOutput);
\r
55 helpers.getFileName = function(req, defFilename) {
\r
58 for (var x=0; x < req.files.length; x++)
\r
60 var fileObj = req.files[x];
\r
61 if ( fileObj.filename.indexOf(defFilename) != -1 ){
\r
62 return fileObj.filename;
\r