+++ /dev/null
-\r
-var _ = require('lodash');\r
-var csvtojson = require('csvtojson');\r
-var async = require('async');\r
-var uuid = require('node-uuid'); // generate a uuid with "uuid.v1()"\r
-var path = require('path');\r
-var fs = require("fs");\r
-var moment = require('moment');\r
-\r
-var helpers = module.exports;\r
-\r
-function puts(obj) { console.log(obj); } \r
-function putd(obj) { console.log(obj); } \r
-helpers.puts = puts;\r
-helpers.putd = putd;\r
-\r
-\r
-helpers.readCsv = function(filedir, filename, callback) {\r
-\r
-\r
- var Converter=csvtojson.Converter;\r
- var csvFileName=path.join(filedir,filename);\r
- var fileStream=fs.createReadStream(csvFileName);\r
- fileStream.on('error', function(err){\r
- callback(err, null);\r
- });\r
- var param={noheader:true, checkType:false};\r
- var csvConverter=new Converter(param);\r
- csvConverter.on("end_parsed",function(jsonObj){\r
- var returnValue = jsonObj;\r
- callback(null, returnValue);\r
- });\r
- fileStream.on('error', function(err) {\r
- putd(err);\r
- callback(err,"");\r
- });\r
- fileStream.pipe(csvConverter);\r
-}\r
-\r
-helpers.getParam = function(csv, matchField, matchValue, returnField) {\r
- dataRow=_.find(csv, matchField, matchValue);\r
- dataValue=dataRow[returnField];\r
- return dataValue;\r
-}\r
-\r
-helpers.writeOutput = function(req, filename, jsonOutput, callback) {\r
- try {\r
- fs.writeFileSync(filename, jsonOutput);\r
- }\r
- catch(err){\r
- callback(err);\r
- }\r
-}\r
-\r
-helpers.getFileName = function(req, defFilename) {\r
- \r
- var fileObj = null;\r
- for (var x=0; x < req.files.length; x++)\r
- {\r
- var fileObj = req.files[x];\r
- if ( fileObj.filename.indexOf(defFilename) != -1 ){\r
- return fileObj.filename;\r
- }\r
- }\r
- return null;\r
-}\r