Add EpayMicroaccountStrategy

samples/epay_microaccount_2019-11-22_11-22-33.csv

@@ -0,0 +1,15 @@
+"Дата и час","Приход","Разход","Системен код","Кореспондент","Описание"
+"01.04.2019 09:14:08","0.00","1.96","1234567890123456","Кореспондент","Описание"
+"02.04.2019 09:14:08","0.00","1.68","1234567890123456","Кореспондент","Описание"
+"03.05.2019 11:22:51","0.00","33.67","1234567890123456","Кореспондент","Описание"
+"04.05.2019 11:22:51","0.00","3.64","1234567890123456","Кореспондент","Описание"
+"05.05.2019 11:22:52","0.00","3.60","1234567890123456","Кореспондент","Описание"
+"06.05.2019 11:22:52","0.00","1.45","1234567890123456","Кореспондент","Описание"
+"07.05.2019 11:22:52","0.00","5.48","1234567890123456","Кореспондент","Описание"
+"08.06.2019 12:07:32","0.00","1.80","1234567890123456","Кореспондент","Описание"
+"09.07.2019 13:27:16","0.00","5.18","1234567890123456","Кореспондент","Описание"
+"10.07.2019 13:27:17","0.00","3.64","1234567890123456","Кореспондент","Описание"
+"11.07.2019 13:27:17","0.00","1.80","1234567890123456","Кореспондент","Описание"
+"12.07.2019 13:27:17","0.00","6.40","1234567890123456","Кореспондент","Описание"
+"13.08.2019 19:00:47","0.00","3.64","1234567890123456","Кореспондент","Описание"
+"14.08.2019 19:00:48","0.00","1.57","1234567890123456","Кореспондент","Описание"

src/ConverterFactory.js

@@ -1,14 +1,4 @@
-const DbCreditCardStrategy = require(`./strategy/DbCreditCardStrategy.js`);
-const DbDebitCardStrategy = require(`./strategy/DbDebitCardStrategy.js`);
-const DkbCreditCardStrategy = require(`./strategy/DkbCreditCardStrategy.js`);
-const DkbGirokontoStrategy = require(`./strategy/DkbGirokontoStrategy.js`);
-
-const strategies = {
-  DbCreditCardStrategy,
-  DbDebitCardStrategy,
-  DkbCreditCardStrategy,
-  DkbGirokontoStrategy,
-};
+const strategies = require('./strategy/index');
 
 class ConverterFactory {
 

src/lib/file.js

@@ -1,6 +1,6 @@
 const fs = require('fs');
 
-const getInput = function (inFile, sliceStart = 1, sliceEnd = null, encoding = 'latin1') {
+const getInput = function (inFile, sliceStart = 1, sliceEnd = null, encoding = 'utf8') {
   const end = sliceEnd ? sliceEnd : undefined;
   const getLines = data => (data.match(/\r?\n/g) || '').length + 1;
   const getSlicedInput = input => input.split('\n').slice(sliceStart, end).join('\n');

src/strategy/BaseStrategy.js

@@ -1,7 +1,5 @@
-const parse = require('csv-parse/lib/sync');
 const transform = require('stream-transform');
 const stringify = require('csv-stringify');
-const { getInput, writeOut } = require('../lib/file.js');
 
 const SETTINGS = {
   delimiter: ';',

src/strategy/DbCreditCardStrategy.js

@@ -1,6 +1,4 @@
 const parse = require('csv-parse/lib/sync');
-const transform = require('stream-transform');
-const stringify = require('csv-stringify');
 const { getInput, writeOut } = require('../lib/file.js');
 const BaseStrategy = require('./BaseStrategy');
 

src/strategy/DbDebitCardStrategy.js

@@ -1,6 +1,4 @@
 const parse = require('csv-parse/lib/sync');
-const transform = require('stream-transform');
-const stringify = require('csv-stringify');
 const { getInput, writeOut } = require('../lib/file.js');
 const BaseStrategy = require('./BaseStrategy');
 const { parseIntlNumber } = require('../lib/helper.js');

src/strategy/DkbCreditCardStrategy.js

@@ -1,6 +1,4 @@
 const parse = require('csv-parse/lib/sync');
-const transform = require('stream-transform');
-const stringify = require('csv-stringify');
 const parseDecimalNumber = require('parse-decimal-number');
 const { getInput, writeOut } = require('../lib/file.js');
 const BaseStrategy = require('./BaseStrategy');

src/strategy/DkbGirokontoStrategy.js

@@ -1,6 +1,4 @@
 const parse = require('csv-parse/lib/sync');
-const transform = require('stream-transform');
-const stringify = require('csv-stringify');
 const parseDecimalNumber = require('parse-decimal-number');
 const { getInput, writeOut } = require('../lib/file.js');
 const BaseStrategy = require('./BaseStrategy');

src/strategy/EpayMicroaccountStrategy.js

@@ -0,0 +1,101 @@
+const parse = require('csv-parse/lib/sync');
+const { getInput, writeOut } = require('../lib/file.js');
+const BaseStrategy = require('./BaseStrategy');
+
+const SETTINGS = {
+  delimiter: ',',
+  skip_empty_lines: true,
+  skip_lines_with_empty_values: true,
+  columns: [
+    'dateTime',
+    'inBGN',
+    'outBGN',
+    'systemId',
+    'recipient',
+    'comment',
+  ],
+  sliceBegin: 1,
+  sliceEnd: Infinity,
+  stringifier: {
+    header: true,
+    delimiter: ',',
+    columns: [
+      'Date',
+      'Payee',
+      'Category',
+      'Memo',
+      'Outflow',
+      'Inflow'
+    ],
+  }
+};
+
+const RATE_EUR_BGN = 1.95583;
+
+class EpayMicroaccountStrategy extends BaseStrategy {
+
+  constructor() {
+    super();
+    console.log('EpayMicroaccountStrategy:constructor');
+  }
+
+  static toEUR(amount) {
+    return amount * 1 / RATE_EUR_BGN;
+  }
+
+  static toDate(dateTime) {
+    return String(dateTime).replace(/^(\d{2})\.(\d{2})\.(\d{4}).+/g,'$3-$2-$1');
+  }
+
+  /**
+   *
+   * @param data
+   * @returns {*[]}
+   */
+  static lineTransform(data) {
+    const amountOut = EpayMicroaccountStrategy.toEUR(data.outBGN);
+    const amountIn = EpayMicroaccountStrategy.toEUR(data.inBGN);
+    const date = EpayMicroaccountStrategy.toDate(data.dateTime);
+    const result = [
+      date,
+      data.recipient,
+      '',
+      data.comment,
+      Math.abs(amountOut),
+      Math.abs(amountIn)
+    ];
+    return result;
+  }
+
+  /**
+   *
+   * @param inFile
+   * @param outFile
+   * @returns {Promise<void>}
+   */
+  async convert(inFile, outFile) {
+    console.log(`In: ${inFile}`);
+
+    const input = getInput(inFile, SETTINGS.sliceBegin, SETTINGS.sliceEnd);
+
+    const data = parse(input, SETTINGS);
+
+    console.log(`Transform: ${data.length}`);
+
+    const result = await super.transformAsync(data, EpayMicroaccountStrategy.lineTransform);
+
+    writeOut(outFile, result);
+    console.log(`Written: ${outFile}`);
+  }
+
+  /**
+   * E.g. epay_microaccount_2019-08-08_11-43-49.csv
+   * @param inFile
+   * @returns {boolean}
+   */
+  static isMatch(inFile) {
+    return !!inFile.match(/epay_microaccount_\d{4}-\d{2}-\d{2}_\d{2}-\d{2}-\d{2}.csv$/g);
+  }
+}
+
+module.exports = EpayMicroaccountStrategy;

src/strategy/index.js

@@ -0,0 +1,13 @@
+const DbCreditCardStrategy = require(`./DbCreditCardStrategy.js`);
+const DbDebitCardStrategy = require(`./DbDebitCardStrategy.js`);
+const DkbCreditCardStrategy = require(`./DkbCreditCardStrategy.js`);
+const DkbGirokontoStrategy = require(`./DkbGirokontoStrategy.js`);
+const EpayMicroaccountStrategy = require(`./EpayMicroaccountStrategy.js`);
+
+module.exports = {
+  DbCreditCardStrategy,
+  DbDebitCardStrategy,
+  DkbCreditCardStrategy,
+  DkbGirokontoStrategy,
+  EpayMicroaccountStrategy,
+};