'use strict';

var _createClass = (function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ('value' in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; })();
require('babel/register');

function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError('Cannot call a class as a function'); } }

var Zoho = require('./Zoho.js');
var ZohoCredentials = require('./zohoConfig.json');
var MyAdmin = require('./MyAdmin.js');
var config = require('./config.json');
var ZenduitDebugger = require('./zendu.debugger.js');
var myAdmin = new MyAdmin();
var zoho = new Zoho(ZohoCredentials.auth);

var argv = require('minimist')(process.argv.slice(2));
var _debug = argv.x ? true : false;
var _debugger = argv.x === 'debugger';

var zenduHelper = new ZenduitDebugger(_debug, false, _debugger);

var PORT = config.server.ContactCreator.port;
var URL = config.server.ContactCreator.url;
var params = [];
params.selectColumns = 'Accounts(GeotabContactID)';
params.fromIndex = 1;
params.toIndex = 200;

var accountCheck = null;
var accounts = [];
var geoAccounts = {};
var _this = null;
var totals = { terminated: 0, devices: 0, unActivated: 0, suspended: 0 };
var churnRate = 0;

var CrmSync = (function () {
	function CrmSync() {
		_classCallCheck(this, CrmSync);

		zenduHelper.bind(this, 'Init');
		zenduHelper.bind(this, 'authenticate');
		zenduHelper.bind(this, 'getDevices');
		zenduHelper.bind(this, 'sortDevices');
		zenduHelper.bind(this, 'AccountsCallBack');
		zenduHelper.bind(this, 'getAccounts');
		zenduHelper.bind(this, 'Next');
		zenduHelper.bind(this, 'finish');
		zenduHelper.bind(this, 'finish2');
		zenduHelper.bind(this, 'checkAccounts');
	}

	_createClass(CrmSync, [{
		key: 'Init',
		value: function Init() {
			_this = this;
			this['continue'] = false;
			this.getAccounts();
			accountCheck = setInterval(this.checkAccounts, 1000);
		}
	}, {
		key: 'Next',
		value: function Next() {
			var _this2 = this;

			Promise.resolve().then(this.authenticate).then(function (user) {
				return _this2.user = user;
			}).then(this.getDevices).then(function (devices) {
				return _this2.devices = devices;
			}).then(this.sortDevices)['catch'](zenduHelper.errFn);
		}
	}, {
		key: 'checkAccounts',
		value: function checkAccounts() {
			if (this['continue']) {
				clearInterval(accountCheck);
				accountCheck = null;
				this.Next();
			}
		}
	}, {
		key: 'authenticate',
		value: function authenticate() {
			zenduHelper.log('Authenticating...');
			return myAdmin.authenticate(config.myAdmin);
		}
	}, {
		key: 'getDevices',
		value: function getDevices() {
			var apiKey = this.user.userId;
			var sessionId = this.user.sessionId;
			var today = new Date();
			var DeviceParams = {
				apiKey: apiKey,
				sessionId: sessionId,
				forAccount: 'GOFL02',
				fromDate: today,
				toDate: today
			};
			return myAdmin.call('GetDeviceContracts', DeviceParams);
		}
	}, {
		key: 'getAccounts',
		value: function getAccounts() {
			zoho.getRecords(params, this.AccountsCallBack);
		}
	}, {
		key: 'AccountsCallBack',
		value: function AccountsCallBack(err, response, body) {

			var res = JSON.parse(body).response;

			var _rows = res.result.Accounts.row;
			_rows.forEach(function (value) {
				var tmpdb = [];
				if (typeof value.FL != 'undefined') {
					if (value.FL.constructor === Array) {
						value.FL.forEach(function (data, index) {
							if (data.val == 'ACCOUNTID') tmpdb.id = data.content;else data.val == 'GeotabContactID';
							tmpdb.geotabID = data.content;
						});
						if (tmpdb.geotabID != 0) accounts.push(tmpdb);
					}
				}
			});
			if (_rows.length >= 200) {
				params.fromIndex += 200;
				params.toIndex += 200;
				zoho.getRecords(params, _this.AccountsCallBack);
			} else {
				this['continue'] = true;
			}
		}
	}, {
		key: 'finish',
		value: function finish(err, response, body) {}
	}, {
		key: 'sortDevices',
		value: function sortDevices() {

			for (var i = 0; i < this.devices.length - 1; i++) {
				var device = this.devices[i];
				var userContact = 0;

				if (typeof device.userContact != 'undefined') {
					userContact = device.userContact.id;
				}

				if (typeof geoAccounts[userContact] == 'undefined' && userContact > 0) {
					geoAccounts[userContact] = {};
					geoAccounts[userContact].deviceTypes = { proPlusMode: 0, proMode: 0, baseMode: 0, suspendMode: 0, customDevice: 0, passiveMode: 0, terminated: 0, unactivated: 0, other: 0, total: 0 };
				}
				if (userContact > 0) {

					if (device.device.serialNumber.charAt(0) == 'C') {
						geoAccounts[userContact].deviceTypes.customDevice++;
					} else {
						totals.devices++;
						if (typeof device.activeDevicePlan != 'undefined') if (device.activeDevicePlan.name == 'ProPlus Mode') geoAccounts[userContact].deviceTypes.proPlusMode++;else if (device.activeDevicePlan.name == 'Pro Mode') geoAccounts[userContact].deviceTypes.proMode++;else if (device.activeDevicePlan.name == 'Base Mode') geoAccounts[userContact].deviceTypes.baseMode++;else if (device.activeDevicePlan.name == 'Suspend Mode') {
							geoAccounts[userContact].deviceTypes.suspendMode++;
							totals.suspended++;
						} else if (device.activeDevicePlan.name == 'Passive Mode') {
							geoAccounts[userContact].deviceTypes.passiveMode++;
						} else console.log(device);else {
							if (device.isTerminated) {
								geoAccounts[userContact].deviceTypes.terminated++;
								totals.terminated++;
							} else if (device.isUnactivated) {
								geoAccounts[userContact].deviceTypes.unactivated++;
								totals.unActivated++;
							} else geoAccounts[userContact].deviceTypes.other++;
						}
					}
					geoAccounts[userContact].deviceTypes.total++;
				}
			}

			var xmlData = '<Accounts>';
			var count = 0;
			for (var i = 0; i < accounts.length; i++) {
				if (typeof geoAccounts[accounts[i].geotabID] != 'undefined') {
					count++;
					xmlData += '\n<row no="' + count + '">';
					xmlData += '\n\t<FL val="Id">' + accounts[i].id + '</FL>';
					xmlData += '\n\t<FL val="MONTHLY-PROPLUS">' + geoAccounts[accounts[i].geotabID].deviceTypes.proPlusMode + '</FL>';
					xmlData += '\n\t<FL val="MONTHLY-PRO">' + geoAccounts[accounts[i].geotabID].deviceTypes.proMode + '</FL>';
					xmlData += '\n\t<FL val="MONTHLY-BASE">' + geoAccounts[accounts[i].geotabID].deviceTypes.baseMode + '</FL>';
					xmlData += '\n\t<FL val="MONTHLY-SUSPEND">' + geoAccounts[accounts[i].geotabID].deviceTypes.suspendMode + '</FL>';
					xmlData += '\n\t<FL val="MONTHLY-TERMINATED">' + geoAccounts[accounts[i].geotabID].deviceTypes.terminated + '</FL>';
					xmlData += '\n\t<FL val="MONTHLY-CUSTOM-ASSET">' + geoAccounts[accounts[i].geotabID].deviceTypes.customDevice + '</FL>';
					xmlData += '\n\t<FL val="MONTHLY-OTHER">' + geoAccounts[accounts[i].geotabID].deviceTypes.other + '</FL>';
					xmlData += '\n\t<FL val="Not Activated">' + geoAccounts[accounts[i].geotabID].deviceTypes.unactivated + '</FL>';
					xmlData += '\n</row>';

					if (count % 100 == 0) {
						xmlData += '</Accounts>';
						var updateParams = {};
						updateParams.version = 4;
						updateParams.xmlData = xmlData;
						zoho.updateRecord(updateParams, this.finish);
						xmlData = '<Accounts>';
						count = 0;
					}
				}
			}
			xmlData += '</Accounts>';
			var updateParams = {};
			updateParams.version = 4;
			updateParams.xmlData = xmlData;
			zoho.updateRecord(updateParams, this.finish);
			churnRate = totals.terminated / totals.devices;

			var reportParams = 'TotalDevices=' + totals.devices + '&TotalUnactivated=' + totals.unActivated + '&TotalSuspended=' + totals.suspended + '&TotalTerminated=' + totals.terminated + '&ChurnRate=' + Math.round(churnRate * 10000) / 100;
			zoho.updateReports(reportParams, this.finish2);
		}
	}, {
		key: 'finish2',
		value: function finish2(err, response, body) { console.log("Finshed Sync!"); }
	}]);

	return CrmSync;
})();

;

var CS = new CrmSync();
CS.Init();

//console.log(body);

//console.log(body)