Built motion from commit 9d5c653a.|2.5.44
[motion2.git] / server / components / import / cm / csv2.js
index 564c56e..b956228 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0x5715=['fields','cm_contacts','cm_contacts.ListId\x20=\x20','.CmListId','cm_contacts.createdAt\x20=\x20?','cm_contacts.phone\x20NOT\x20IN\x20(?)','\x22onlyIfOpen\x22','\x22always\x22','toString','cm_contacts.id','cm_contacts.ListId','cm_contacts.createdAt','cm_contacts.updatedAt','updatedAt','cm_hopper_black','\x20=\x20?','.offset-cm_contacts.utcOffset\x20minute)','priority','UserId','recallme','.CmListId\x20=\x20?','ListId\x20=\x20?','keys',')\x20NOT\x20IN\x20?','MIN(id)','min_id','group','info','Received\x20SIGINT','error','message','push','sequelize','spread','campaigns.id','campaigns.dialTimezone','campaigns_has_cm_lists','campaigns_has_cm_lists.CmListId=','length','all','then','catch','voice_queues.id','voice_queues.dialTimezone','voice_queues','voice_queues_has_cm_lists','voice_queues.id\x20=\x20voice_queues_has_cm_lists.VoiceQueueId','timezones','dialTimezone','set','offset','query','main','stringify','send','start','socket_timestamp','root','server/files/tmp','.csv','includes','header',',utcOffset','parse','createReadStream','data','rows','errors','hasOwnProperty','trim','replace','YYYY-MM-DD\x20HH:mm:ss','isNaN','isNumber','agent\x20not\x20exists','email','email\x20wrong\x20format','dateOfBirth','YYYY-MM-DD','dateOfBirth\x20wrong\x20format\x20(YYYY-MM-DD)','isNil','firstName','\x20not\x20specified','SystemRow','appendFileSync','emit','abort','SystemError','step','cm_contacts_','CREATE\x20TABLE\x20','\x20LIKE\x20cm_contacts;','campaigns_','voice_queues_','(id\x20int,dialTimezone\x20varchar(255),offset\x20int);','each','LOAD\x20DATA\x20LOCAL\x20INFILE\x20\x27%s\x27\x20INTO\x20TABLE\x20%s\x20CHARACTER\x20SET\x20UTF8\x20FIELDS\x20TERMINATED\x20BY\x20\x27,\x27\x20ENCLOSED\x20BY\x20\x27\x22\x27\x20LINES\x20TERMINATED\x20BY\x20\x27\x0a\x27\x20IGNORE\x201\x20ROWS\x20(%s)\x20SET\x20id\x20=\x20NULL,\x20ListId\x20=\x20%s,\x20CompanyId\x20=\x20%s,\x20createdAt\x20=\x20\x27%s\x27,\x20updatedAt\x20=\x20\x27%s\x27','CompanyId','duplicates','DROP\x20TABLE\x20','VoiceQueueId','voice_queues_has_cm_blacklists','CampaignId','campaigns_has_cm_blacklists','campaigns','finish','affectedRows','unlink','exit','complete','argv','arguments\x20<filename>\x20<parameters>\x20<agents>','file\x20doesn\x27t\x20exists','binding','phone\x20is\x20mandatory','firstName\x20is\x20mandatory','body\x20id\x20mandatory','map','SIGINT','path','lodash','papaparse','util','bluebird','squel','ioredis','../../../mysqldb','../../../config/environment','../../../config/logger','import','defaults','redis','socket.io-emitter','format','select','field','phone','from','.id\x20=\x20','where','\x20=\x20','join','cm_contacts.phone','cm_contacts.scheduledat','cm_contacts.priority','cm_contacts.UserId','insert','into','cm_hopper','fromQuery','scheduledat','ContactId','ListId','createdAt'];(function(_0x489c95,_0x53159c){var _0x10e7a7=function(_0xcb4342){while(--_0xcb4342){_0x489c95['push'](_0x489c95['shift']());}};_0x10e7a7(++_0x53159c);}(_0x5715,0x111));var _0x5571=function(_0x455150,_0x274121){_0x455150=_0x455150-0x0;var _0x12ca9c=_0x5715[_0x455150];return _0x12ca9c;};'use strict';var fs=require('fs');var path=require(_0x5571('0x0'));var _=require(_0x5571('0x1'));var Papa=require(_0x5571('0x2'));var util=require(_0x5571('0x3'));var BPromise=require(_0x5571('0x4'));var moment=require('moment');var squel=require(_0x5571('0x5'));var Redis=require(_0x5571('0x6'));var db=require(_0x5571('0x7'))['db'];var config=require(_0x5571('0x8'));var shared=require('../../../config/environment/shared');var logger=require(_0x5571('0x9'))(_0x5571('0xa'));config['redis']=_[_0x5571('0xb')](config[_0x5571('0xc')],{'host':'localhost','port':0x18eb});var socket=require(_0x5571('0xd'))(new Redis(config[_0x5571('0xc')]));var stats={'finish':![],'errors':[],'rows':0x0,'affectedRows':0x0};var results=[];var stopped=![];var tmp_voice_queues;var tmp_campaigns;var tzOffset=0x0;var hasTZ;var NOW=moment()[_0x5571('0xe')]('YYYY-MM-DD\x20HH:mm:ss');function isEmail(_0x36567e){return/^([^\x00-\x20\x22\x28\x29\x2c\x2e\x3a-\x3c\x3e\x40\x5b-\x5d\x7f-\xff]+|\x22([^\x0d\x22\x5c\x80-\xff]|\x5c[\x00-\x7f])*\x22)(\x2e([^\x00-\x20\x22\x28\x29\x2c\x2e\x3a-\x3c\x3e\x40\x5b-\x5d\x7f-\xff]+|\x22([^\x0d\x22\x5c\x80-\xff]|\x5c[\x00-\x7f])*\x22))*\x40([^\x00-\x20\x22\x28\x29\x2c\x2e\x3a-\x3c\x3e\x40\x5b-\x5d\x7f-\xff]+|\x5b([^\x0d\x5b-\x5d\x80-\xff]|\x5c[\x00-\x7f])*\x5d)(\x2e([^\x00-\x20\x22\x28\x29\x2c\x2e\x3a-\x3c\x3e\x40\x5b-\x5d\x7f-\xff]+|\x5b([^\x0d\x5b-\x5d\x80-\xff]|\x5c[\x00-\x7f])*\x5d))*$/['test'](_0x36567e);}function selectNotIn(_0x14c699,_0x417721,_0x1c019f,_0x2d9a4b,_0x50442d){return squel[_0x5571('0xf')]()[_0x5571('0x10')](_0x5571('0x11'))[_0x5571('0x12')](_0x2d9a4b)['join'](_0x417721,null,_0x417721+_0x5571('0x13')+_0x2d9a4b+'.'+_0x1c019f)[_0x5571('0x14')](_0x2d9a4b+'.'+_0x1c019f+_0x5571('0x15')+_0x14c699+'.'+_0x1c019f)[_0x5571('0x14')](_0x417721+'.dialCheckDuplicateType\x20IN\x20('+_0x50442d[_0x5571('0x16')]()+')');}function insertCmHopper(_0x3b488a,_0x532319,_0x175173,_0x127d22,_0x810e42){var _0x49d9ed=[_0x5571('0x17'),_0x5571('0x18'),'cm_contacts.id','cm_contacts.ListId',_0x532319+'.'+_0x127d22,'cm_contacts.createdAt','cm_contacts.updatedAt',_0x5571('0x19'),_0x5571('0x1a'),'\x22'+_0x810e42+'\x22'];return squel[_0x5571('0x1b')]()[_0x5571('0x1c')](_0x5571('0x1d'))[_0x5571('0x1e')]([_0x5571('0x11'),_0x5571('0x1f'),_0x5571('0x20'),_0x5571('0x21'),_0x127d22,_0x5571('0x22'),'updatedAt','priority','UserId','recallme'],squel[_0x5571('0xf')]()[_0x5571('0x23')](_0x49d9ed)['from'](_0x532319)[_0x5571('0x16')](_0x5571('0x24'),null,_0x5571('0x25')+_0x532319+_0x5571('0x26'))[_0x5571('0x16')](_0x175173,null,_0x175173+_0x5571('0x13')+_0x532319+'.'+_0x127d22)[_0x5571('0x14')](_0x532319+'.CmListId\x20=\x20?',_0x3b488a)['where'](_0x5571('0x27'),NOW)[_0x5571('0x14')](_0x5571('0x28'),selectNotIn(_0x532319,_0x175173,_0x127d22,'cm_hopper',['\x22always\x22',_0x5571('0x29')]))['where'](_0x5571('0x28'),selectNotIn(_0x532319,_0x175173,_0x127d22,_0x5571('0x1d'),[_0x5571('0x2a')])))[_0x5571('0x2b')]();}function insertCmHopperBlack(_0x2a9442,_0xed3b2e,_0x25d2d6,_0xf4e4d3){var _0xf6e220=[_0x5571('0x17'),_0x5571('0x2c'),_0x5571('0x2d'),_0xed3b2e+'.'+_0xf4e4d3,_0x5571('0x2e'),_0x5571('0x2f')];return squel[_0x5571('0x1b')]()[_0x5571('0x1c')]('cm_hopper_black')[_0x5571('0x1e')]([_0x5571('0x11'),_0x5571('0x20'),'ListId',_0xf4e4d3,'createdAt',_0x5571('0x30')],squel['select']()[_0x5571('0x23')](_0xf6e220)[_0x5571('0x12')](_0xed3b2e)[_0x5571('0x16')](_0x5571('0x24'),null,'cm_contacts.ListId\x20=\x20'+_0xed3b2e+'.CmListId')[_0x5571('0x16')](_0x25d2d6,null,_0x25d2d6+'.id\x20=\x20'+_0xed3b2e+'.'+_0xf4e4d3)[_0x5571('0x14')](_0xed3b2e+'.CmListId\x20=\x20?',_0x2a9442)[_0x5571('0x14')]('cm_contacts.createdAt\x20=\x20?',NOW)[_0x5571('0x14')]('cm_contacts.phone\x20NOT\x20IN\x20(?)',squel[_0x5571('0xf')]()[_0x5571('0x10')](_0x5571('0x11'))[_0x5571('0x12')](_0x5571('0x31'))['where']('ListId\x20=\x20?',_0x2a9442)[_0x5571('0x14')](_0xf4e4d3+_0x5571('0x32'),_0xed3b2e+'.'+_0xf4e4d3)))['toString']();}function insertTzCmHopper(_0x4312f9,_0x50f934,_0x56d287,_0xf61022,_0x1d4862,_0x47254f){var _0x79447a=[_0x5571('0x17'),'date_add(cm_contacts.scheduledat,interval\x20'+_0x47254f+_0x5571('0x33'),_0x5571('0x2c'),'cm_contacts.ListId',_0x50f934+'.'+_0xf61022,'cm_contacts.createdAt',_0x5571('0x2f'),_0x5571('0x19'),_0x5571('0x1a'),'\x22'+_0x1d4862+'\x22'];var _0x5a3f0c=squel[_0x5571('0x1b')]()[_0x5571('0x1c')](_0x5571('0x1d'))[_0x5571('0x1e')]([_0x5571('0x11'),_0x5571('0x1f'),_0x5571('0x20'),_0x5571('0x21'),_0xf61022,_0x5571('0x22'),_0x5571('0x30'),_0x5571('0x34'),_0x5571('0x35'),_0x5571('0x36')],squel[_0x5571('0xf')]()['fields'](_0x79447a)['from'](_0x50f934)[_0x5571('0x16')]('cm_contacts',null,'cm_contacts.ListId\x20=\x20'+_0x50f934+_0x5571('0x26'))[_0x5571('0x16')](_0x56d287,null,_0x56d287+_0x5571('0x13')+_0x50f934+'.'+_0xf61022)[_0x5571('0x16')](_0x47254f,null,_0x47254f+_0x5571('0x13')+_0x50f934+'.'+_0xf61022)[_0x5571('0x14')](_0x50f934+_0x5571('0x37'),_0x4312f9)[_0x5571('0x14')](_0x5571('0x27'),NOW)['where'](_0x5571('0x28'),selectNotIn(_0x50f934,_0x56d287,_0xf61022,_0x5571('0x1d'),[_0x5571('0x2a'),_0x5571('0x29')]))[_0x5571('0x14')](_0x5571('0x28'),selectNotIn(_0x50f934,_0x56d287,_0xf61022,_0x5571('0x1d'),['\x22always\x22'])))[_0x5571('0x2b')]();return _0x5a3f0c;}function insertTzCmHopperBlack(_0xe34b18,_0x4d919a,_0x2c5026,_0x3cc4fc){var _0x17422c=[_0x5571('0x17'),_0x5571('0x2c'),'cm_contacts.ListId',_0x4d919a+'.'+_0x3cc4fc,_0x5571('0x2e'),'cm_contacts.updatedAt'];return squel[_0x5571('0x1b')]()[_0x5571('0x1c')]('cm_hopper_black')[_0x5571('0x1e')](['phone',_0x5571('0x20'),_0x5571('0x21'),_0x3cc4fc,_0x5571('0x22'),_0x5571('0x30')],squel[_0x5571('0xf')]()['fields'](_0x17422c)[_0x5571('0x12')](_0x4d919a)[_0x5571('0x16')](_0x5571('0x24'),null,'cm_contacts.ListId\x20=\x20'+_0x4d919a+_0x5571('0x26'))[_0x5571('0x16')](_0x2c5026,null,_0x2c5026+_0x5571('0x13')+_0x4d919a+'.'+_0x3cc4fc)[_0x5571('0x14')](_0x4d919a+_0x5571('0x37'),_0xe34b18)[_0x5571('0x14')](_0x5571('0x27'),NOW)['where']('cm_contacts.phone\x20NOT\x20IN\x20(?)',squel[_0x5571('0xf')]()[_0x5571('0x10')](_0x5571('0x11'))[_0x5571('0x12')](_0x5571('0x31'))[_0x5571('0x14')](_0x5571('0x38'),_0xe34b18)[_0x5571('0x14')](_0x3cc4fc+_0x5571('0x32'),_0x4d919a+'.'+_0x3cc4fc)))[_0x5571('0x2b')]();}function insertCmContact(_0x784420,_0x6bed6a,_0x26b69e,_0x4d5a27){var _0x23a3f4=_['concat'](_[_0x5571('0x39')](_0x4d5a27),[_0x5571('0x21'),'CompanyId','createdAt',_0x5571('0x30')]);return squel['insert']()[_0x5571('0x1c')](_0x5571('0x24'))[_0x5571('0x1e')](_0x23a3f4,squel[_0x5571('0xf')]()[_0x5571('0x23')](_0x23a3f4)[_0x5571('0x12')](_0x6bed6a)[_0x5571('0x14')]('('+_0x26b69e[_0x5571('0x16')](',')+_0x5571('0x3a'),squel[_0x5571('0xf')]()[_0x5571('0x23')](_0x26b69e)[_0x5571('0x12')](_0x5571('0x24'))[_0x5571('0x14')](_0x5571('0x38'),_0x784420)[_0x5571('0x14')]('deletedAt\x20IS\x20NULL'))[_0x5571('0x14')]('id\x20IN\x20?',squel[_0x5571('0xf')]()[_0x5571('0x10')](_0x5571('0x3b'),_0x5571('0x3c'))['from'](_0x6bed6a)[_0x5571('0x3d')](_0x26b69e[_0x5571('0x16')](','))))['toString']();}function handleStop(){logger[_0x5571('0x3e')](_0x5571('0x3f'));stopped=!![];}function handleUncaughtException(_0x51fb72){logger[_0x5571('0x40')](_0x51fb72[_0x5571('0x41')]);process['exit'](0x1);}function handleError(_0x58b7b4,_0x485817){stats['errors'][_0x5571('0x42')]({'name':_0x485817['code'],'message':_0x485817[_0x5571('0x41')],'row':_0x58b7b4});}function handleQuery(_0x9f943f){logger[_0x5571('0x3e')](_0x9f943f);return db[_0x5571('0x43')]['query'](_0x9f943f)[_0x5571('0x44')](function(_0x85deef){results[_0x5571('0x42')](_0x85deef);})['catch'](function(_0xc38526){logger[_0x5571('0x40')](_0xc38526[_0x5571('0x41')]);});}function updateTzCampaigns(_0x5f167c){return new Promise(function(_0x2650d4,_0x441d59){var _0x390c70=squel[_0x5571('0xf')]()[_0x5571('0x23')]([_0x5571('0x45'),_0x5571('0x46')])[_0x5571('0x12')]('campaigns')[_0x5571('0x16')](_0x5571('0x47'),null,'campaigns.id\x20=\x20campaigns_has_cm_lists.CampaignId')['where'](_0x5571('0x48')+_0x5f167c);db['sequelize']['query'](_0x390c70[_0x5571('0x2b')]())[_0x5571('0x44')](function(_0x4996b1){var _0x1ebf76=[];for(var _0x1d93b6=0x0;_0x1d93b6<_0x4996b1[_0x5571('0x49')];_0x1d93b6++){_0x1ebf76[_0x5571('0x42')](getTimezoneData(_0x4996b1[_0x1d93b6],tmp_campaigns));}BPromise[_0x5571('0x4a')](_0x1ebf76)[_0x5571('0x4b')](function(){_0x2650d4({'val':0x1});});})[_0x5571('0x4c')](function(_0x37e998){logger[_0x5571('0x40')](_0x37e998['message']);_0x2650d4({'val':0x0});});});}function updateTzVoiceQueues(_0x2deec7){return new Promise(function(_0x2fe10b,_0x4f3baf){var _0x38ec21=squel[_0x5571('0xf')]()[_0x5571('0x23')]([_0x5571('0x4d'),_0x5571('0x4e')])[_0x5571('0x12')](_0x5571('0x4f'))[_0x5571('0x16')](_0x5571('0x50'),null,_0x5571('0x51'))[_0x5571('0x14')]('voice_queues_has_cm_lists.CmListId='+_0x2deec7);db[_0x5571('0x43')]['query'](_0x38ec21['toString']())[_0x5571('0x44')](function(_0x558bd4){var _0x3e8a9a=[];for(var _0x7304e5=0x0;_0x7304e5<_0x558bd4[_0x5571('0x49')];_0x7304e5++){_0x3e8a9a[_0x5571('0x42')](getTimezoneData(_0x558bd4[_0x7304e5],tmp_voice_queues));}BPromise[_0x5571('0x4a')](_0x3e8a9a)[_0x5571('0x4b')](function(){_0x2fe10b({'val':0x1});});})[_0x5571('0x4c')](function(_0x130b73){logger['error'](_0x130b73['message']);_0x2fe10b({'val':0x0});});});}function getTimezoneData(_0x6eb9cc,_0x306344){return new Promise(function(_0x4e4c5b,_0x376468){var _0xed01ac=shared[_0x5571('0x52')];var _0x14b852=_0xed01ac[_0x6eb9cc[_0x5571('0x53')]];if(_['isNil'](_0x14b852)){_0x4e4c5b({'ret':0x1});}else{var _0x510325=_0x14b852['utcOffset'];var _0x3553a5=squel[_0x5571('0x1b')]()['into'](_0x306344)[_0x5571('0x54')]('id',_0x6eb9cc['id'])[_0x5571('0x54')](_0x5571('0x55'),_0x510325)[_0x5571('0x54')](_0x5571('0x53'),_0x6eb9cc[_0x5571('0x53')])['toString']();return db[_0x5571('0x43')][_0x5571('0x56')](_0x3553a5)[_0x5571('0x44')](function(_0x33f078){_0x4e4c5b({'ret':0x1});})[_0x5571('0x4c')](function(_0x26aa56){logger[_0x5571('0x40')](_0x26aa56[_0x5571('0x41')]);_0x376468({'ret':0x1});});}});}function handleTZQuery(_0x427116){logger[_0x5571('0x3e')](_0x427116);return db[_0x5571('0x43')][_0x5571('0x56')](_0x427116)[_0x5571('0x44')](function(_0x19fa86){})['catch'](function(_0x204f65){logger[_0x5571('0x40')](_0x204f65[_0x5571('0x41')]);});}function main(_0x2f6800,_0x3a6e36,_0x490855,_0x2dce6f){logger[_0x5571('0x3e')](_0x5571('0x57'),_0x2f6800,JSON[_0x5571('0x58')](_0x3a6e36));process[_0x5571('0x59')](_0x5571('0x5a'));var _0x43fd8d=_0x3a6e36['binding'];var _0x43bb5b=_0x3a6e36[_0x5571('0x5b')];var _0x3e3099=path[_0x5571('0x16')](config[_0x5571('0x5c')],_0x5571('0x5d'),_0x43bb5b+_0x5571('0x5e'));hasTZ=_['keys'](_0x43fd8d)[_0x5571('0x5f')](_0x5571('0x53'));var _0x137fb1=_[_0x5571('0x39')](_0x43fd8d)[_0x5571('0x16')]();logger['info'](_0x5571('0x60'),_0x137fb1);if(hasTZ)_0x137fb1+=_0x5571('0x61');fs['writeFileSync'](_0x3e3099,_0x137fb1+'\x0a');Papa[_0x5571('0x62')](fs[_0x5571('0x63')](_0x2f6800),{'header':!![],'skipEmptyLines':!![],'step':function(_0xb65b65,_0xd3c8b3){try{for(var _0x512107=0x0,_0x1aa342=[];_0x512107<_0xb65b65[_0x5571('0x64')]['length'];_0x512107++){stats[_0x5571('0x65')]+=0x1;if(_0xb65b65[_0x5571('0x66')][_0x512107]){handleError(_0xb65b65[_0x5571('0x64')][_0x512107],_0xb65b65[_0x5571('0x66')][_0x512107]);}else{var _0x122b5a=[];for(var _0x1d38da in _0x43fd8d){if(_0x43fd8d[_0x5571('0x67')](_0x1d38da)){if(_0xb65b65[_0x5571('0x64')][_0x512107][_0x43fd8d[_0x1d38da]]){var _0x49450c=_[_0x5571('0x68')](_0xb65b65[_0x5571('0x64')][_0x512107][_0x43fd8d[_0x1d38da]][_0x5571('0x69')](/"/g,'\x27'));switch(_0x1d38da){case _0x5571('0x1f'):var _0x4c79e8=moment(_0x49450c,_0x5571('0x6a'),!![]);if(_0x4c79e8['isValid']()){_0x1aa342['push']('\x22'+_0x49450c+'\x22');}else{_0x122b5a[_0x5571('0x42')]('scheduledat\x20wrong\x20format\x20(YYYY-MM-DD\x20HH:mm:ss)');}break;case'priority':var _0x3d6582=parseInt(_0x49450c);_0x49450c=_[_0x5571('0x6b')](_0x3d6582)||_0x3d6582<0x0||_0x3d6582>0x4?_0x2dce6f?0x3:0x2:_0x3d6582;_0x1aa342[_0x5571('0x42')]('\x22'+_0x49450c+'\x22');break;case'UserId':var _0x3d6ac2=parseInt(_0x49450c);if(_[_0x5571('0x6c')](_0x3d6ac2)&&_[_0x5571('0x5f')](_0x490855,_0x3d6ac2)){_0x1aa342['push']('\x22'+_0x3d6ac2+'\x22');}else{_0x122b5a[_0x5571('0x42')](_0x5571('0x6d'));}break;case _0x5571('0x6e'):if(isEmail(_0x49450c)){_0x1aa342[_0x5571('0x42')]('\x22'+_0x49450c+'\x22');}else{_0x122b5a[_0x5571('0x42')](_0x5571('0x6f'));}break;case _0x5571('0x70'):var _0x4288a7=moment(_0x49450c,_0x5571('0x71'),!![]);if(_0x4288a7['isValid']()){_0x1aa342[_0x5571('0x42')]('\x22'+_0x49450c+'\x22');}else{_0x122b5a['push'](_0x5571('0x72'));}break;case _0x5571('0x53'):var _0x4014ec=shared[_0x5571('0x52')];var _0x4b83a=_0x4014ec[_0x49450c];if(!_[_0x5571('0x73')](_0x4b83a)){var _0x1f4f6f=_0x4b83a['utcOffset'];_0x1aa342[_0x5571('0x42')]('\x22'+_0x49450c+'\x22');_0x1aa342[_0x5571('0x42')]('\x22'+_0x1f4f6f+'\x22');}break;default:_0x1aa342[_0x5571('0x42')]('\x22'+_0x49450c+'\x22');}}else{switch(_0x1d38da){case _0x5571('0x74'):case _0x5571('0x11'):_0x122b5a[_0x5571('0x42')](_0x1d38da+_0x5571('0x75'));break;default:_0x1aa342['push']('\x22\x22');}}}}if(_0x122b5a['length']){handleError(_0xb65b65[_0x5571('0x64')][_0x512107],{'code':_0x5571('0x76'),'message':_0x122b5a['join']()});}else{fs[_0x5571('0x77')](_0x3e3099,_0x1aa342[_0x5571('0x16')]()+'\x0a');}_0x1aa342=[];}if(!(stats[_0x5571('0x65')]%0xc8)){socket[_0x5571('0x78')]('contact:import:'+_0x43bb5b,stats);stats['errors']=[];}}if(stopped){logger[_0x5571('0x3e')]('Abort\x20parser');_0xd3c8b3[_0x5571('0x79')]();}}catch(_0x49d1d6){handleError(_0xb65b65[_0x5571('0x64')][_0x512107],{'code':_0x5571('0x7a'),'message':_0x49d1d6[_0x5571('0x41')]});logger[_0x5571('0x40')](_0x5571('0x7b'),_0x49d1d6[_0x5571('0x41')]);}},'complete':function(){try{var _0x4886b8=[];var _0x52072a=[];var _0xbfef5b=_0x5571('0x24');if(_0x3a6e36['duplicates']&&_0x3a6e36['duplicates'][_0x5571('0x49')]){_0xbfef5b=_0x5571('0x7c')+_0x43bb5b;_0x4886b8[_0x5571('0x42')](_0x5571('0x7d')+_0xbfef5b+_0x5571('0x7e'));}tmp_campaigns=_0x5571('0x7f')+_0x43bb5b;tmp_voice_queues=_0x5571('0x80')+_0x43bb5b;_0x52072a[_0x5571('0x42')]('CREATE\x20TABLE\x20'+tmp_campaigns+'(id\x20int,dialTimezone\x20varchar(255),offset\x20int);');_0x52072a[_0x5571('0x42')](_0x5571('0x7d')+tmp_voice_queues+_0x5571('0x81'));BPromise[_0x5571('0x82')](_0x52072a,handleTZQuery)['then'](function(_0x3db9c6){updateTzCampaigns(_0x3a6e36['ListId'])[_0x5571('0x4b')](function(_0x403386){updateTzVoiceQueues(_0x3a6e36[_0x5571('0x21')])['then'](function(_0x27d9e5){var _0x187152=util[_0x5571('0xe')](_0x5571('0x83'),_0x3e3099,_0xbfef5b,_0x137fb1,_0x3a6e36['ListId'],_0x3a6e36[_0x5571('0x84')]||null,NOW,NOW);if(_[_0x5571('0x73')](_0x43fd8d[_0x5571('0x1f')])){_0x187152+=',\x20scheduledAt\x20=\x20NOW()';}_0x4886b8[_0x5571('0x42')](_0x187152);if(_0x3a6e36[_0x5571('0x85')]&&_0x3a6e36[_0x5571('0x85')][_0x5571('0x49')]){_0x4886b8[_0x5571('0x42')](insertCmContact(_0x3a6e36[_0x5571('0x21')],_0xbfef5b,_0x3a6e36[_0x5571('0x85')],_0x43fd8d));_0x4886b8['push'](_0x5571('0x86')+_0xbfef5b+';');}if(hasTZ){_0x4886b8[_0x5571('0x42')](insertTzCmHopper(_0x3a6e36[_0x5571('0x21')],'voice_queues_has_cm_lists','voice_queues',_0x5571('0x87'),_0x2dce6f,tmp_voice_queues));_0x4886b8[_0x5571('0x42')](insertTzCmHopperBlack(_0x3a6e36[_0x5571('0x21')],_0x5571('0x88'),_0x5571('0x4f'),_0x5571('0x87')));_0x4886b8[_0x5571('0x42')](insertTzCmHopper(_0x3a6e36[_0x5571('0x21')],'campaigns_has_cm_lists','campaigns',_0x5571('0x89'),_0x2dce6f,tmp_campaigns));_0x4886b8[_0x5571('0x42')](insertTzCmHopperBlack(_0x3a6e36[_0x5571('0x21')],_0x5571('0x8a'),'campaigns',_0x5571('0x89')));}else{_0x4886b8[_0x5571('0x42')](insertCmHopper(_0x3a6e36[_0x5571('0x21')],'voice_queues_has_cm_lists',_0x5571('0x4f'),'VoiceQueueId',_0x2dce6f));_0x4886b8[_0x5571('0x42')](insertCmHopperBlack(_0x3a6e36[_0x5571('0x21')],'voice_queues_has_cm_blacklists','voice_queues',_0x5571('0x87')));_0x4886b8['push'](insertCmHopper(_0x3a6e36[_0x5571('0x21')],_0x5571('0x47'),_0x5571('0x8b'),_0x5571('0x89'),_0x2dce6f));_0x4886b8[_0x5571('0x42')](insertCmHopperBlack(_0x3a6e36[_0x5571('0x21')],'campaigns_has_cm_blacklists',_0x5571('0x8b'),'CampaignId'));}_0x4886b8[_0x5571('0x42')](_0x5571('0x86')+tmp_campaigns+';');_0x4886b8[_0x5571('0x42')](_0x5571('0x86')+tmp_voice_queues+';');BPromise[_0x5571('0x82')](_0x4886b8,handleQuery)[_0x5571('0x4b')](function(_0x1dec56){stats[_0x5571('0x8c')]=!![];stats[_0x5571('0x8d')]=_0x3a6e36['duplicates']&&_0x3a6e36[_0x5571('0x85')]['length']?results[0x2]['affectedRows']:results[0x0][_0x5571('0x8d')];socket[_0x5571('0x78')]('contact:import:'+_0x43bb5b,stats);fs[_0x5571('0x8e')](_0x2f6800);fs[_0x5571('0x8e')](_0x3e3099);process[_0x5571('0x8f')](0x0);})[_0x5571('0x4c')](function(_0x5f28da){logger[_0x5571('0x40')](_0x5f28da[_0x5571('0x41')]);process[_0x5571('0x8f')](0x1);});});});});}catch(_0x119766){logger[_0x5571('0x40')](_0x5571('0x90'),_0x119766[_0x5571('0x41')]);process[_0x5571('0x8f')](0x1);}},'error':function(_0x22e4c6,_0x5ae48b,_0xfc4f9,_0xe7e990){throw new Error(_0xe7e990);}});}function validate(){if(process['argv']&&process[_0x5571('0x91')][_0x5571('0x49')]<0x4){throw new Error(_0x5571('0x92'));}var _0x2b0072=path[_0x5571('0x16')](config[_0x5571('0x5c')],_0x5571('0x5d'),process[_0x5571('0x91')][0x2]);if(!fs['existsSync'](_0x2b0072)){throw new Error(_0x5571('0x93'));}var _0x24b69c={};try{_0x24b69c=JSON['parse'](process['argv'][0x3]);if(!_0x24b69c[_0x5571('0x94')]){throw new Error('binding\x20doesn\x27t\x20exists');}if(!_0x24b69c['binding'][_0x5571('0x11')]){throw new Error(_0x5571('0x95'));}if(!_0x24b69c['binding'][_0x5571('0x74')]){throw new Error(_0x5571('0x96'));}var _0x24b745=0x0;if(_0x24b69c[_0x5571('0x94')][_0x5571('0x35')]){_0x24b745=0x1;}if(!_0x24b69c[_0x5571('0x21')]){throw new Error('ListId\x20is\x20mandatory');}}catch(_0x4bf825){throw new Error(_0x5571('0x97'));}var _0x12baaa=[];try{_0x12baaa=_[_0x5571('0x98')](JSON[_0x5571('0x62')](process[_0x5571('0x91')][0x4]),'id');}catch(_0xa53fe2){logger[_0x5571('0x3e')]('No\x20agent\x20available');}main(_0x2b0072,_0x24b69c,_0x12baaa,_0x24b745);}validate();process['on'](_0x5571('0x99'),handleStop);process['on']('uncaughtException',handleUncaughtException);
\ No newline at end of file
+var _0xc24d=['offset','stringify','send','start','binding','socket_timestamp','root','server/files/tmp','.csv','includes','header',',utcOffset','writeFileSync','rows','data','hasOwnProperty','trim','isValid','isNaN','isNumber','agent\x20not\x20exists','email','email\x20wrong\x20format','dateOfBirth','YYYY-MM-DD','dateOfBirth\x20wrong\x20format\x20(YYYY-MM-DD)','isNil','firstName','\x20not\x20specified','SystemRow','appendFileSync','emit','contact:import:','Abort\x20parser','duplicates','cm_contacts_','CREATE\x20TABLE\x20','\x20LIKE\x20cm_contacts;','campaigns_','voice_queues_','(id\x20int,dialTimezone\x20varchar(255),offset\x20int);','each','DROP\x20TABLE\x20','VoiceQueueId','voice_queues_has_cm_blacklists','campaigns_has_cm_blacklists','CampaignId','affectedRows','unlink','complete','argv','file\x20doesn\x27t\x20exists','binding\x20doesn\x27t\x20exists','phone\x20is\x20mandatory','firstName\x20is\x20mandatory','ListId\x20is\x20mandatory','body\x20id\x20mandatory','parse','No\x20agent\x20available','SIGINT','uncaughtException','path','lodash','papaparse','util','bluebird','moment','squel','ioredis','../../../config/environment','../../../config/environment/shared','../../../config/logger','import','defaults','redis','localhost','format','YYYY-MM-DD\x20HH:mm:ss','select','field','phone','join','where','\x20=\x20','.dialCheckDuplicateType\x20IN\x20(','cm_contacts.phone','cm_contacts.scheduledat','cm_contacts.updatedAt','cm_contacts.priority','cm_contacts.UserId','insert','into','cm_hopper','fromQuery','scheduledat','ListId','createdAt','priority','UserId','recallme','fields','cm_contacts','cm_contacts.ListId\x20=\x20','.id\x20=\x20','cm_contacts.createdAt\x20=\x20?','cm_contacts.phone\x20NOT\x20IN\x20(?)','\x22always\x22','\x22onlyIfOpen\x22','toString','cm_contacts.id','cm_contacts.ListId','cm_contacts.createdAt','cm_hopper_black','ContactId','updatedAt','from','ListId\x20=\x20?','\x20=\x20?','date_add(cm_contacts.scheduledat,interval\x20','.offset-cm_contacts.utcOffset\x20minute)','.CmListId','.CmListId\x20=\x20?','keys','CompanyId',')\x20NOT\x20IN\x20?','id\x20IN\x20?','min_id','group','info','Received\x20SIGINT','error','exit','errors','push','code','message','sequelize','query','spread','catch','campaigns.id','campaigns.dialTimezone','campaigns','campaigns_has_cm_lists','campaigns.id\x20=\x20campaigns_has_cm_lists.CampaignId','length','all','then','voice_queues.id','voice_queues.dialTimezone','voice_queues','voice_queues_has_cm_lists','voice_queues.id\x20=\x20voice_queues_has_cm_lists.VoiceQueueId','dialTimezone','utcOffset','set'];(function(_0x509c83,_0x511882){var _0x534626=function(_0x9d21cf){while(--_0x9d21cf){_0x509c83['push'](_0x509c83['shift']());}};_0x534626(++_0x511882);}(_0xc24d,0xd9));var _0xdc24=function(_0x3e91a9,_0x53c466){_0x3e91a9=_0x3e91a9-0x0;var _0x25c9ad=_0xc24d[_0x3e91a9];return _0x25c9ad;};'use strict';var fs=require('fs');var path=require(_0xdc24('0x0'));var _=require(_0xdc24('0x1'));var Papa=require(_0xdc24('0x2'));var util=require(_0xdc24('0x3'));var BPromise=require(_0xdc24('0x4'));var moment=require(_0xdc24('0x5'));var squel=require(_0xdc24('0x6'));var Redis=require(_0xdc24('0x7'));var db=require('../../../mysqldb')['db'];var config=require(_0xdc24('0x8'));var shared=require(_0xdc24('0x9'));var logger=require(_0xdc24('0xa'))(_0xdc24('0xb'));config['redis']=_[_0xdc24('0xc')](config[_0xdc24('0xd')],{'host':_0xdc24('0xe'),'port':0x18eb});var socket=require('socket.io-emitter')(new Redis(config[_0xdc24('0xd')]));var stats={'finish':![],'errors':[],'rows':0x0,'affectedRows':0x0};var results=[];var stopped=![];var tmp_voice_queues;var tmp_campaigns;var tzOffset=0x0;var hasTZ;var NOW=moment()[_0xdc24('0xf')](_0xdc24('0x10'));function isEmail(_0xd43f47){return/^([^\x00-\x20\x22\x28\x29\x2c\x2e\x3a-\x3c\x3e\x40\x5b-\x5d\x7f-\xff]+|\x22([^\x0d\x22\x5c\x80-\xff]|\x5c[\x00-\x7f])*\x22)(\x2e([^\x00-\x20\x22\x28\x29\x2c\x2e\x3a-\x3c\x3e\x40\x5b-\x5d\x7f-\xff]+|\x22([^\x0d\x22\x5c\x80-\xff]|\x5c[\x00-\x7f])*\x22))*\x40([^\x00-\x20\x22\x28\x29\x2c\x2e\x3a-\x3c\x3e\x40\x5b-\x5d\x7f-\xff]+|\x5b([^\x0d\x5b-\x5d\x80-\xff]|\x5c[\x00-\x7f])*\x5d)(\x2e([^\x00-\x20\x22\x28\x29\x2c\x2e\x3a-\x3c\x3e\x40\x5b-\x5d\x7f-\xff]+|\x5b([^\x0d\x5b-\x5d\x80-\xff]|\x5c[\x00-\x7f])*\x5d))*$/['test'](_0xd43f47);}function selectNotIn(_0x44572e,_0xe2eb0e,_0x366193,_0x491122,_0xb62226){return squel[_0xdc24('0x11')]()[_0xdc24('0x12')](_0xdc24('0x13'))['from'](_0x491122)[_0xdc24('0x14')](_0xe2eb0e,null,_0xe2eb0e+'.id\x20=\x20'+_0x491122+'.'+_0x366193)[_0xdc24('0x15')](_0x491122+'.'+_0x366193+_0xdc24('0x16')+_0x44572e+'.'+_0x366193)['where'](_0xe2eb0e+_0xdc24('0x17')+_0xb62226[_0xdc24('0x14')]()+')');}function insertCmHopper(_0x3615e4,_0x5b2261,_0x188fc5,_0x10cb15,_0x43ed38){var _0x24f0a5=[_0xdc24('0x18'),_0xdc24('0x19'),'cm_contacts.id','cm_contacts.ListId',_0x5b2261+'.'+_0x10cb15,'cm_contacts.createdAt',_0xdc24('0x1a'),_0xdc24('0x1b'),_0xdc24('0x1c'),'\x22'+_0x43ed38+'\x22'];return squel[_0xdc24('0x1d')]()[_0xdc24('0x1e')](_0xdc24('0x1f'))[_0xdc24('0x20')]([_0xdc24('0x13'),_0xdc24('0x21'),'ContactId',_0xdc24('0x22'),_0x10cb15,_0xdc24('0x23'),'updatedAt',_0xdc24('0x24'),_0xdc24('0x25'),_0xdc24('0x26')],squel[_0xdc24('0x11')]()[_0xdc24('0x27')](_0x24f0a5)['from'](_0x5b2261)[_0xdc24('0x14')](_0xdc24('0x28'),null,_0xdc24('0x29')+_0x5b2261+'.CmListId')['join'](_0x188fc5,null,_0x188fc5+_0xdc24('0x2a')+_0x5b2261+'.'+_0x10cb15)[_0xdc24('0x15')](_0x5b2261+'.CmListId\x20=\x20?',_0x3615e4)[_0xdc24('0x15')](_0xdc24('0x2b'),NOW)[_0xdc24('0x15')](_0xdc24('0x2c'),selectNotIn(_0x5b2261,_0x188fc5,_0x10cb15,_0xdc24('0x1f'),[_0xdc24('0x2d'),_0xdc24('0x2e')]))[_0xdc24('0x15')]('cm_contacts.phone\x20NOT\x20IN\x20(?)',selectNotIn(_0x5b2261,_0x188fc5,_0x10cb15,_0xdc24('0x1f'),[_0xdc24('0x2d')])))[_0xdc24('0x2f')]();}function insertCmHopperBlack(_0x9292b7,_0x4bc2e6,_0x45cd39,_0xe08d5){var _0x150cd3=[_0xdc24('0x18'),_0xdc24('0x30'),_0xdc24('0x31'),_0x4bc2e6+'.'+_0xe08d5,_0xdc24('0x32'),_0xdc24('0x1a')];return squel[_0xdc24('0x1d')]()[_0xdc24('0x1e')](_0xdc24('0x33'))[_0xdc24('0x20')]([_0xdc24('0x13'),_0xdc24('0x34'),_0xdc24('0x22'),_0xe08d5,_0xdc24('0x23'),_0xdc24('0x35')],squel[_0xdc24('0x11')]()[_0xdc24('0x27')](_0x150cd3)[_0xdc24('0x36')](_0x4bc2e6)[_0xdc24('0x14')](_0xdc24('0x28'),null,_0xdc24('0x29')+_0x4bc2e6+'.CmListId')[_0xdc24('0x14')](_0x45cd39,null,_0x45cd39+_0xdc24('0x2a')+_0x4bc2e6+'.'+_0xe08d5)[_0xdc24('0x15')](_0x4bc2e6+'.CmListId\x20=\x20?',_0x9292b7)[_0xdc24('0x15')](_0xdc24('0x2b'),NOW)[_0xdc24('0x15')](_0xdc24('0x2c'),squel['select']()[_0xdc24('0x12')](_0xdc24('0x13'))[_0xdc24('0x36')](_0xdc24('0x33'))[_0xdc24('0x15')](_0xdc24('0x37'),_0x9292b7)[_0xdc24('0x15')](_0xe08d5+_0xdc24('0x38'),_0x4bc2e6+'.'+_0xe08d5)))[_0xdc24('0x2f')]();}function insertTzCmHopper(_0x18806d,_0x1bac99,_0x310cd8,_0x16ddce,_0x35da2e,_0xbe64fd){var _0x5a6db7=[_0xdc24('0x18'),_0xdc24('0x39')+_0xbe64fd+_0xdc24('0x3a'),_0xdc24('0x30'),'cm_contacts.ListId',_0x1bac99+'.'+_0x16ddce,_0xdc24('0x32'),_0xdc24('0x1a'),'cm_contacts.priority','cm_contacts.UserId','\x22'+_0x35da2e+'\x22'];var _0x649e85=squel[_0xdc24('0x1d')]()[_0xdc24('0x1e')](_0xdc24('0x1f'))[_0xdc24('0x20')]([_0xdc24('0x13'),'scheduledat',_0xdc24('0x34'),'ListId',_0x16ddce,'createdAt',_0xdc24('0x35'),_0xdc24('0x24'),'UserId',_0xdc24('0x26')],squel['select']()['fields'](_0x5a6db7)[_0xdc24('0x36')](_0x1bac99)[_0xdc24('0x14')](_0xdc24('0x28'),null,_0xdc24('0x29')+_0x1bac99+_0xdc24('0x3b'))[_0xdc24('0x14')](_0x310cd8,null,_0x310cd8+_0xdc24('0x2a')+_0x1bac99+'.'+_0x16ddce)[_0xdc24('0x14')](_0xbe64fd,null,_0xbe64fd+_0xdc24('0x2a')+_0x1bac99+'.'+_0x16ddce)['where'](_0x1bac99+_0xdc24('0x3c'),_0x18806d)[_0xdc24('0x15')]('cm_contacts.createdAt\x20=\x20?',NOW)[_0xdc24('0x15')](_0xdc24('0x2c'),selectNotIn(_0x1bac99,_0x310cd8,_0x16ddce,_0xdc24('0x1f'),[_0xdc24('0x2d'),_0xdc24('0x2e')]))[_0xdc24('0x15')]('cm_contacts.phone\x20NOT\x20IN\x20(?)',selectNotIn(_0x1bac99,_0x310cd8,_0x16ddce,_0xdc24('0x1f'),[_0xdc24('0x2d')])))['toString']();return _0x649e85;}function insertTzCmHopperBlack(_0x50a118,_0x49fcc3,_0xa79604,_0x2a803c){var _0x260baf=[_0xdc24('0x18'),_0xdc24('0x30'),_0xdc24('0x31'),_0x49fcc3+'.'+_0x2a803c,_0xdc24('0x32'),_0xdc24('0x1a')];return squel['insert']()[_0xdc24('0x1e')](_0xdc24('0x33'))[_0xdc24('0x20')]([_0xdc24('0x13'),_0xdc24('0x34'),_0xdc24('0x22'),_0x2a803c,_0xdc24('0x23'),_0xdc24('0x35')],squel[_0xdc24('0x11')]()['fields'](_0x260baf)[_0xdc24('0x36')](_0x49fcc3)[_0xdc24('0x14')](_0xdc24('0x28'),null,_0xdc24('0x29')+_0x49fcc3+_0xdc24('0x3b'))[_0xdc24('0x14')](_0xa79604,null,_0xa79604+_0xdc24('0x2a')+_0x49fcc3+'.'+_0x2a803c)[_0xdc24('0x15')](_0x49fcc3+_0xdc24('0x3c'),_0x50a118)[_0xdc24('0x15')](_0xdc24('0x2b'),NOW)[_0xdc24('0x15')](_0xdc24('0x2c'),squel[_0xdc24('0x11')]()[_0xdc24('0x12')]('phone')['from'](_0xdc24('0x33'))[_0xdc24('0x15')]('ListId\x20=\x20?',_0x50a118)[_0xdc24('0x15')](_0x2a803c+_0xdc24('0x38'),_0x49fcc3+'.'+_0x2a803c)))[_0xdc24('0x2f')]();}function insertCmContact(_0x1d13f5,_0x37867a,_0x58931c,_0x4072d3){var _0x25feb9=_['concat'](_[_0xdc24('0x3d')](_0x4072d3),[_0xdc24('0x22'),_0xdc24('0x3e'),'createdAt',_0xdc24('0x35')]);return squel[_0xdc24('0x1d')]()[_0xdc24('0x1e')](_0xdc24('0x28'))[_0xdc24('0x20')](_0x25feb9,squel['select']()[_0xdc24('0x27')](_0x25feb9)[_0xdc24('0x36')](_0x37867a)[_0xdc24('0x15')]('('+_0x58931c[_0xdc24('0x14')](',')+_0xdc24('0x3f'),squel[_0xdc24('0x11')]()[_0xdc24('0x27')](_0x58931c)[_0xdc24('0x36')](_0xdc24('0x28'))[_0xdc24('0x15')](_0xdc24('0x37'),_0x1d13f5)['where']('deletedAt\x20IS\x20NULL'))[_0xdc24('0x15')](_0xdc24('0x40'),squel[_0xdc24('0x11')]()[_0xdc24('0x12')]('MIN(id)',_0xdc24('0x41'))[_0xdc24('0x36')](_0x37867a)[_0xdc24('0x42')](_0x58931c[_0xdc24('0x14')](','))))[_0xdc24('0x2f')]();}function handleStop(){logger[_0xdc24('0x43')](_0xdc24('0x44'));stopped=!![];}function handleUncaughtException(_0x3d0c90){logger[_0xdc24('0x45')](_0x3d0c90['message']);process[_0xdc24('0x46')](0x1);}function handleError(_0x31c325,_0x315180){stats[_0xdc24('0x47')][_0xdc24('0x48')]({'name':_0x315180[_0xdc24('0x49')],'message':_0x315180[_0xdc24('0x4a')],'row':_0x31c325});}function handleQuery(_0xf82987){logger[_0xdc24('0x43')](_0xf82987);return db[_0xdc24('0x4b')][_0xdc24('0x4c')](_0xf82987)[_0xdc24('0x4d')](function(_0xca53f4){results['push'](_0xca53f4);})[_0xdc24('0x4e')](function(_0x50fd40){logger[_0xdc24('0x45')](_0x50fd40[_0xdc24('0x4a')]);});}function updateTzCampaigns(_0xf2c731){return new Promise(function(_0x9613c9,_0x42f04d){var _0x4689de=squel[_0xdc24('0x11')]()['fields']([_0xdc24('0x4f'),_0xdc24('0x50')])['from'](_0xdc24('0x51'))['join'](_0xdc24('0x52'),null,_0xdc24('0x53'))[_0xdc24('0x15')]('campaigns_has_cm_lists.CmListId='+_0xf2c731);db['sequelize'][_0xdc24('0x4c')](_0x4689de[_0xdc24('0x2f')]())[_0xdc24('0x4d')](function(_0x57e4bc){var _0xba0636=[];for(var _0x555cc8=0x0;_0x555cc8<_0x57e4bc[_0xdc24('0x54')];_0x555cc8++){_0xba0636[_0xdc24('0x48')](getTimezoneData(_0x57e4bc[_0x555cc8],tmp_campaigns));}BPromise[_0xdc24('0x55')](_0xba0636)[_0xdc24('0x56')](function(){_0x9613c9({'val':0x1});});})[_0xdc24('0x4e')](function(_0x3a0946){logger[_0xdc24('0x45')](_0x3a0946[_0xdc24('0x4a')]);_0x9613c9({'val':0x0});});});}function updateTzVoiceQueues(_0x3ff572){return new Promise(function(_0x538717,_0x2c798b){var _0x55c0cb=squel[_0xdc24('0x11')]()[_0xdc24('0x27')]([_0xdc24('0x57'),_0xdc24('0x58')])[_0xdc24('0x36')](_0xdc24('0x59'))['join'](_0xdc24('0x5a'),null,_0xdc24('0x5b'))['where']('voice_queues_has_cm_lists.CmListId='+_0x3ff572);db[_0xdc24('0x4b')][_0xdc24('0x4c')](_0x55c0cb[_0xdc24('0x2f')]())['spread'](function(_0x1d698e){var _0xeba97e=[];for(var _0x5439cd=0x0;_0x5439cd<_0x1d698e[_0xdc24('0x54')];_0x5439cd++){_0xeba97e[_0xdc24('0x48')](getTimezoneData(_0x1d698e[_0x5439cd],tmp_voice_queues));}BPromise['all'](_0xeba97e)[_0xdc24('0x56')](function(){_0x538717({'val':0x1});});})['catch'](function(_0x517f67){logger[_0xdc24('0x45')](_0x517f67['message']);_0x538717({'val':0x0});});});}function getTimezoneData(_0x114e99,_0x34c5c1){return new Promise(function(_0x36ab7e,_0xc8ec12){var _0x215a2a=shared['timezones'];var _0x28877f=_0x215a2a[_0x114e99[_0xdc24('0x5c')]];if(_['isNil'](_0x28877f)){_0x36ab7e({'ret':0x1});}else{var _0x1e9a83=_0x28877f[_0xdc24('0x5d')];var _0x4f51ac=squel[_0xdc24('0x1d')]()[_0xdc24('0x1e')](_0x34c5c1)['set']('id',_0x114e99['id'])[_0xdc24('0x5e')](_0xdc24('0x5f'),_0x1e9a83)[_0xdc24('0x5e')](_0xdc24('0x5c'),_0x114e99[_0xdc24('0x5c')])[_0xdc24('0x2f')]();return db[_0xdc24('0x4b')]['query'](_0x4f51ac)['spread'](function(_0x356aed){_0x36ab7e({'ret':0x1});})[_0xdc24('0x4e')](function(_0x5ea62d){logger[_0xdc24('0x45')](_0x5ea62d[_0xdc24('0x4a')]);_0xc8ec12({'ret':0x1});});}});}function handleTZQuery(_0xf6384f){logger['info'](_0xf6384f);return db[_0xdc24('0x4b')]['query'](_0xf6384f)[_0xdc24('0x4d')](function(_0x3111a4){})['catch'](function(_0x29522d){logger[_0xdc24('0x45')](_0x29522d['message']);});}function main(_0x32ec5b,_0x4ac9c7,_0x137668,_0x54b51e){logger['info']('main',_0x32ec5b,JSON[_0xdc24('0x60')](_0x4ac9c7));process[_0xdc24('0x61')](_0xdc24('0x62'));var _0x2df2b9=_0x4ac9c7[_0xdc24('0x63')];var _0x4ca80e=_0x4ac9c7[_0xdc24('0x64')];var _0x41c3f0=path[_0xdc24('0x14')](config[_0xdc24('0x65')],_0xdc24('0x66'),_0x4ca80e+_0xdc24('0x67'));hasTZ=_[_0xdc24('0x3d')](_0x2df2b9)[_0xdc24('0x68')]('dialTimezone');var _0x3f6e75=_[_0xdc24('0x3d')](_0x2df2b9)[_0xdc24('0x14')]();logger[_0xdc24('0x43')](_0xdc24('0x69'),_0x3f6e75);if(hasTZ)_0x3f6e75+=_0xdc24('0x6a');fs[_0xdc24('0x6b')](_0x41c3f0,_0x3f6e75+'\x0a');Papa['parse'](fs['createReadStream'](_0x32ec5b),{'header':!![],'skipEmptyLines':!![],'step':function(_0x586d33,_0xfb27e1){try{for(var _0x2e074b=0x0,_0x16b6c7=[];_0x2e074b<_0x586d33['data']['length'];_0x2e074b++){stats[_0xdc24('0x6c')]+=0x1;if(_0x586d33['errors'][_0x2e074b]){handleError(_0x586d33[_0xdc24('0x6d')][_0x2e074b],_0x586d33['errors'][_0x2e074b]);}else{var _0x5af4df=[];for(var _0x1bb03a in _0x2df2b9){if(_0x2df2b9[_0xdc24('0x6e')](_0x1bb03a)){if(_0x586d33[_0xdc24('0x6d')][_0x2e074b][_0x2df2b9[_0x1bb03a]]){var _0x3f6f07=_[_0xdc24('0x6f')](_0x586d33[_0xdc24('0x6d')][_0x2e074b][_0x2df2b9[_0x1bb03a]]['replace'](/"/g,'\x27'));switch(_0x1bb03a){case _0xdc24('0x21'):var _0xf79c73=moment(_0x3f6f07,_0xdc24('0x10'),!![]);if(_0xf79c73[_0xdc24('0x70')]()){_0x16b6c7['push']('\x22'+_0x3f6f07+'\x22');}else{_0x5af4df['push']('scheduledat\x20wrong\x20format\x20(YYYY-MM-DD\x20HH:mm:ss)');}break;case _0xdc24('0x24'):var _0x5aadfb=parseInt(_0x3f6f07);_0x3f6f07=_[_0xdc24('0x71')](_0x5aadfb)||_0x5aadfb<0x0||_0x5aadfb>0x4?_0x54b51e?0x3:0x2:_0x5aadfb;_0x16b6c7['push']('\x22'+_0x3f6f07+'\x22');break;case'UserId':var _0x4d0694=parseInt(_0x3f6f07);if(_[_0xdc24('0x72')](_0x4d0694)&&_['includes'](_0x137668,_0x4d0694)){_0x16b6c7[_0xdc24('0x48')]('\x22'+_0x4d0694+'\x22');}else{_0x5af4df[_0xdc24('0x48')](_0xdc24('0x73'));}break;case _0xdc24('0x74'):if(isEmail(_0x3f6f07)){_0x16b6c7[_0xdc24('0x48')]('\x22'+_0x3f6f07+'\x22');}else{_0x5af4df[_0xdc24('0x48')](_0xdc24('0x75'));}break;case _0xdc24('0x76'):var _0x8596fa=moment(_0x3f6f07,_0xdc24('0x77'),!![]);if(_0x8596fa[_0xdc24('0x70')]()){_0x16b6c7[_0xdc24('0x48')]('\x22'+_0x3f6f07+'\x22');}else{_0x5af4df[_0xdc24('0x48')](_0xdc24('0x78'));}break;case'dialTimezone':var _0x4c4f92=shared['timezones'];var _0x3bb832=_0x4c4f92[_0x3f6f07];if(!_[_0xdc24('0x79')](_0x3bb832)){var _0x30db3d=_0x3bb832['utcOffset'];_0x16b6c7[_0xdc24('0x48')]('\x22'+_0x3f6f07+'\x22');_0x16b6c7['push']('\x22'+_0x30db3d+'\x22');}break;default:_0x16b6c7[_0xdc24('0x48')]('\x22'+_0x3f6f07+'\x22');}}else{switch(_0x1bb03a){case _0xdc24('0x7a'):case _0xdc24('0x13'):_0x5af4df[_0xdc24('0x48')](_0x1bb03a+_0xdc24('0x7b'));break;default:_0x16b6c7[_0xdc24('0x48')]('\x22\x22');}}}}if(_0x5af4df['length']){handleError(_0x586d33[_0xdc24('0x6d')][_0x2e074b],{'code':_0xdc24('0x7c'),'message':_0x5af4df['join']()});}else{fs[_0xdc24('0x7d')](_0x41c3f0,_0x16b6c7[_0xdc24('0x14')]()+'\x0a');}_0x16b6c7=[];}if(!(stats[_0xdc24('0x6c')]%0xc8)){socket[_0xdc24('0x7e')](_0xdc24('0x7f')+_0x4ca80e,stats);stats[_0xdc24('0x47')]=[];}}if(stopped){logger[_0xdc24('0x43')](_0xdc24('0x80'));_0xfb27e1['abort']();}}catch(_0x45a166){handleError(_0x586d33[_0xdc24('0x6d')][_0x2e074b],{'code':'SystemError','message':_0x45a166['message']});logger[_0xdc24('0x45')]('step',_0x45a166['message']);}},'complete':function(){try{var _0x3761e5=[];var _0x1fbdf6=[];var _0x4e5f97=_0xdc24('0x28');if(_0x4ac9c7['duplicates']&&_0x4ac9c7[_0xdc24('0x81')][_0xdc24('0x54')]){_0x4e5f97=_0xdc24('0x82')+_0x4ca80e;_0x3761e5[_0xdc24('0x48')](_0xdc24('0x83')+_0x4e5f97+_0xdc24('0x84'));}tmp_campaigns=_0xdc24('0x85')+_0x4ca80e;tmp_voice_queues=_0xdc24('0x86')+_0x4ca80e;_0x1fbdf6[_0xdc24('0x48')](_0xdc24('0x83')+tmp_campaigns+_0xdc24('0x87'));_0x1fbdf6['push'](_0xdc24('0x83')+tmp_voice_queues+'(id\x20int,dialTimezone\x20varchar(255),offset\x20int);');BPromise[_0xdc24('0x88')](_0x1fbdf6,handleTZQuery)[_0xdc24('0x56')](function(_0x343237){updateTzCampaigns(_0x4ac9c7['ListId'])[_0xdc24('0x56')](function(_0x155ff1){updateTzVoiceQueues(_0x4ac9c7[_0xdc24('0x22')])[_0xdc24('0x56')](function(_0xa5bdee){var _0x4e53fb=util[_0xdc24('0xf')]('LOAD\x20DATA\x20LOCAL\x20INFILE\x20\x27%s\x27\x20INTO\x20TABLE\x20%s\x20CHARACTER\x20SET\x20UTF8\x20FIELDS\x20TERMINATED\x20BY\x20\x27,\x27\x20ENCLOSED\x20BY\x20\x27\x22\x27\x20LINES\x20TERMINATED\x20BY\x20\x27\x0a\x27\x20IGNORE\x201\x20ROWS\x20(%s)\x20SET\x20id\x20=\x20NULL,\x20ListId\x20=\x20%s,\x20CompanyId\x20=\x20%s,\x20createdAt\x20=\x20\x27%s\x27,\x20updatedAt\x20=\x20\x27%s\x27',_0x41c3f0,_0x4e5f97,_0x3f6e75,_0x4ac9c7[_0xdc24('0x22')],_0x4ac9c7['CompanyId']||null,NOW,NOW);if(_[_0xdc24('0x79')](_0x2df2b9[_0xdc24('0x21')])){_0x4e53fb+=',\x20scheduledAt\x20=\x20NOW()';}_0x3761e5[_0xdc24('0x48')](_0x4e53fb);if(_0x4ac9c7[_0xdc24('0x81')]&&_0x4ac9c7[_0xdc24('0x81')]['length']){_0x3761e5[_0xdc24('0x48')](insertCmContact(_0x4ac9c7[_0xdc24('0x22')],_0x4e5f97,_0x4ac9c7['duplicates'],_0x2df2b9));_0x3761e5[_0xdc24('0x48')](_0xdc24('0x89')+_0x4e5f97+';');}if(hasTZ){_0x3761e5[_0xdc24('0x48')](insertTzCmHopper(_0x4ac9c7[_0xdc24('0x22')],_0xdc24('0x5a'),_0xdc24('0x59'),_0xdc24('0x8a'),_0x54b51e,tmp_voice_queues));_0x3761e5['push'](insertTzCmHopperBlack(_0x4ac9c7[_0xdc24('0x22')],_0xdc24('0x8b'),_0xdc24('0x59'),_0xdc24('0x8a')));_0x3761e5[_0xdc24('0x48')](insertTzCmHopper(_0x4ac9c7[_0xdc24('0x22')],_0xdc24('0x52'),_0xdc24('0x51'),'CampaignId',_0x54b51e,tmp_campaigns));_0x3761e5['push'](insertTzCmHopperBlack(_0x4ac9c7[_0xdc24('0x22')],_0xdc24('0x8c'),_0xdc24('0x51'),_0xdc24('0x8d')));}else{_0x3761e5[_0xdc24('0x48')](insertCmHopper(_0x4ac9c7[_0xdc24('0x22')],'voice_queues_has_cm_lists',_0xdc24('0x59'),_0xdc24('0x8a'),_0x54b51e));_0x3761e5[_0xdc24('0x48')](insertCmHopperBlack(_0x4ac9c7[_0xdc24('0x22')],_0xdc24('0x8b'),'voice_queues',_0xdc24('0x8a')));_0x3761e5[_0xdc24('0x48')](insertCmHopper(_0x4ac9c7[_0xdc24('0x22')],_0xdc24('0x52'),_0xdc24('0x51'),'CampaignId',_0x54b51e));_0x3761e5[_0xdc24('0x48')](insertCmHopperBlack(_0x4ac9c7[_0xdc24('0x22')],_0xdc24('0x8c'),_0xdc24('0x51'),_0xdc24('0x8d')));}_0x3761e5['push'](_0xdc24('0x89')+tmp_campaigns+';');_0x3761e5[_0xdc24('0x48')]('DROP\x20TABLE\x20'+tmp_voice_queues+';');BPromise['each'](_0x3761e5,handleQuery)[_0xdc24('0x56')](function(_0x349f0e){stats['finish']=!![];stats[_0xdc24('0x8e')]=_0x4ac9c7[_0xdc24('0x81')]&&_0x4ac9c7[_0xdc24('0x81')]['length']?results[0x2][_0xdc24('0x8e')]:results[0x0]['affectedRows'];socket[_0xdc24('0x7e')]('contact:import:'+_0x4ca80e,stats);fs['unlink'](_0x32ec5b);fs[_0xdc24('0x8f')](_0x41c3f0);process[_0xdc24('0x46')](0x0);})[_0xdc24('0x4e')](function(_0x2d6ddd){logger['error'](_0x2d6ddd[_0xdc24('0x4a')]);process[_0xdc24('0x46')](0x1);});});});});}catch(_0x2c5f4e){logger[_0xdc24('0x45')](_0xdc24('0x90'),_0x2c5f4e[_0xdc24('0x4a')]);process[_0xdc24('0x46')](0x1);}},'error':function(_0x56a0fe,_0xebdbe9,_0x1eaba5,_0x20b64b){throw new Error(_0x20b64b);}});}function validate(){if(process[_0xdc24('0x91')]&&process[_0xdc24('0x91')]['length']<0x4){throw new Error('arguments\x20<filename>\x20<parameters>\x20<agents>');}var _0x120355=path[_0xdc24('0x14')](config[_0xdc24('0x65')],'server/files/tmp',process[_0xdc24('0x91')][0x2]);if(!fs['existsSync'](_0x120355)){throw new Error(_0xdc24('0x92'));}var _0x27df59={};try{_0x27df59=JSON['parse'](process[_0xdc24('0x91')][0x3]);if(!_0x27df59[_0xdc24('0x63')]){throw new Error(_0xdc24('0x93'));}if(!_0x27df59['binding'][_0xdc24('0x13')]){throw new Error(_0xdc24('0x94'));}if(!_0x27df59[_0xdc24('0x63')]['firstName']){throw new Error(_0xdc24('0x95'));}var _0x113e8b=0x0;if(_0x27df59['binding'][_0xdc24('0x25')]){_0x113e8b=0x1;}if(!_0x27df59[_0xdc24('0x22')]){throw new Error(_0xdc24('0x96'));}}catch(_0x1694ec){throw new Error(_0xdc24('0x97'));}var _0x2838c0=[];try{_0x2838c0=_['map'](JSON[_0xdc24('0x98')](process[_0xdc24('0x91')][0x4]),'id');}catch(_0x4f6c98){logger[_0xdc24('0x43')](_0xdc24('0x99'));}main(_0x120355,_0x27df59,_0x2838c0,_0x113e8b);}validate();process['on'](_0xdc24('0x9a'),handleStop);process['on'](_0xdc24('0x9b'),handleUncaughtException);
\ No newline at end of file