Built motion from commit ddca4d0d.|2.5.47
[motion2.git] / server / components / import / cm / csv2.js
index 78f4c2b..db3e05c 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0xefee=['cm_contacts','cm_contacts.ListId\x20=\x20','.CmListId\x20=\x20?','\x22always\x22','\x22onlyIfOpen\x22','cm_contacts.phone\x20NOT\x20IN\x20(?)','cm_contacts.updatedAt','cm_hopper_black','fromQuery','ContactId','ListId','cm_contacts.createdAt\x20=\x20?','ListId\x20=\x20?','\x20=\x20?','toString','date_add(cm_contacts.scheduledat,interval\x20','.offset-cm_contacts.utcOffset\x20minute)','cm_contacts.createdAt','scheduledat','select','fields','.CmListId','concat','keys','CompanyId','deletedAt\x20IS\x20NULL','min_id','group','info','message','exit','errors','push','code','sequelize','query','spread','campaigns','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_has_cm_lists.CmListId=','error','timezones','dialTimezone','utcOffset','set','offset','catch','stringify','start','binding','socket_timestamp','server/files/tmp','.csv','header','writeFileSync','parse','data','rows','hasOwnProperty','trim','replace','isValid','scheduledat\x20wrong\x20format\x20(YYYY-MM-DD\x20HH:mm:ss)','isNaN','isNumber','includes','agent\x20not\x20exists','email\x20wrong\x20format','dateOfBirth','YYYY-MM-DD','firstName','\x20not\x20specified','SystemRow','emit','contact:import:','Abort\x20parser','abort','SystemError','duplicates','cm_contacts_','\x20LIKE\x20cm_contacts;','campaigns_','voice_queues_','CREATE\x20TABLE\x20','(id\x20int,dialTimezone\x20varchar(255),offset\x20int);','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','isNil',',\x20scheduledAt\x20=\x20NOW()','VoiceQueueId','campaigns_has_cm_lists','CampaignId','campaigns_has_cm_blacklists','voice_queues_has_cm_blacklists','DROP\x20TABLE\x20','each','affectedRows','unlink','argv','arguments\x20<filename>\x20<parameters>\x20<agents>','root','existsSync','file\x20doesn\x27t\x20exists','phone\x20is\x20mandatory','firstName\x20is\x20mandatory','body\x20id\x20mandatory','map','No\x20agent\x20available','SIGINT','uncaughtException','path','lodash','papaparse','util','bluebird','moment','squel','ioredis','../../../mysqldb','../../../config/environment/shared','import','redis','defaults','localhost','format','YYYY-MM-DD\x20HH:mm:ss','test','field','phone','from','join','.id\x20=\x20','where','\x20=\x20','.dialCheckDuplicateType\x20IN\x20(','cm_contacts.phone','cm_contacts.scheduledat','cm_contacts.id','cm_contacts.ListId','cm_contacts.priority','cm_contacts.UserId','insert','into','cm_hopper','createdAt','updatedAt','priority','UserId','recallme'];(function(_0x10dc64,_0x11bb29){var _0x9cf98d=function(_0x558d71){while(--_0x558d71){_0x10dc64['push'](_0x10dc64['shift']());}};_0x9cf98d(++_0x11bb29);}(_0xefee,0x10f));var _0xeefe=function(_0x14bcfe,_0xda89f2){_0x14bcfe=_0x14bcfe-0x0;var _0x234e9a=_0xefee[_0x14bcfe];return _0x234e9a;};'use strict';var fs=require('fs');var path=require(_0xeefe('0x0'));var _=require(_0xeefe('0x1'));var Papa=require(_0xeefe('0x2'));var util=require(_0xeefe('0x3'));var BPromise=require(_0xeefe('0x4'));var moment=require(_0xeefe('0x5'));var squel=require(_0xeefe('0x6'));var Redis=require(_0xeefe('0x7'));var db=require(_0xeefe('0x8'))['db'];var config=require('../../../config/environment');var shared=require(_0xeefe('0x9'));var logger=require('../../../config/logger')(_0xeefe('0xa'));config[_0xeefe('0xb')]=_[_0xeefe('0xc')](config[_0xeefe('0xb')],{'host':_0xeefe('0xd'),'port':0x18eb});var socket=require('socket.io-emitter')(new Redis(config[_0xeefe('0xb')]));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()[_0xeefe('0xe')](_0xeefe('0xf'));function isEmail(_0x5c562c){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))*$/[_0xeefe('0x10')](_0x5c562c);}function selectNotIn(_0x3277a2,_0x515617,_0x123bf5,_0x2933cd,_0x544edb){return squel['select']()[_0xeefe('0x11')](_0xeefe('0x12'))[_0xeefe('0x13')](_0x2933cd)[_0xeefe('0x14')](_0x515617,null,_0x515617+_0xeefe('0x15')+_0x2933cd+'.'+_0x123bf5)[_0xeefe('0x16')](_0x2933cd+'.'+_0x123bf5+_0xeefe('0x17')+_0x3277a2+'.'+_0x123bf5)[_0xeefe('0x16')](_0x515617+_0xeefe('0x18')+_0x544edb[_0xeefe('0x14')]()+')');}function insertCmHopper(_0x4ca3b1,_0x391ab3,_0x48a578,_0x25f714,_0x4d59c7){var _0x5278bd=[_0xeefe('0x19'),_0xeefe('0x1a'),_0xeefe('0x1b'),_0xeefe('0x1c'),_0x391ab3+'.'+_0x25f714,'cm_contacts.createdAt','cm_contacts.updatedAt',_0xeefe('0x1d'),_0xeefe('0x1e'),'\x22'+_0x4d59c7+'\x22'];return squel[_0xeefe('0x1f')]()[_0xeefe('0x20')](_0xeefe('0x21'))['fromQuery']([_0xeefe('0x12'),'scheduledat','ContactId','ListId',_0x25f714,_0xeefe('0x22'),_0xeefe('0x23'),_0xeefe('0x24'),_0xeefe('0x25'),_0xeefe('0x26')],squel['select']()['fields'](_0x5278bd)[_0xeefe('0x13')](_0x391ab3)[_0xeefe('0x14')](_0xeefe('0x27'),null,_0xeefe('0x28')+_0x391ab3+'.CmListId')[_0xeefe('0x14')](_0x48a578,null,_0x48a578+_0xeefe('0x15')+_0x391ab3+'.'+_0x25f714)[_0xeefe('0x16')](_0x391ab3+_0xeefe('0x29'),_0x4ca3b1)[_0xeefe('0x16')]('cm_contacts.createdAt\x20=\x20?',NOW)['where']('cm_contacts.phone\x20NOT\x20IN\x20(?)',selectNotIn(_0x391ab3,_0x48a578,_0x25f714,_0xeefe('0x21'),[_0xeefe('0x2a'),_0xeefe('0x2b')]))[_0xeefe('0x16')](_0xeefe('0x2c'),selectNotIn(_0x391ab3,_0x48a578,_0x25f714,'cm_hopper',['\x22always\x22'])))['toString']();}function insertCmHopperBlack(_0xe5dff4,_0xb584c6,_0x51de59,_0xfec2e9){var _0x38d5f3=[_0xeefe('0x19'),'cm_contacts.id',_0xeefe('0x1c'),_0xb584c6+'.'+_0xfec2e9,'cm_contacts.createdAt',_0xeefe('0x2d')];return squel[_0xeefe('0x1f')]()[_0xeefe('0x20')](_0xeefe('0x2e'))[_0xeefe('0x2f')](['phone',_0xeefe('0x30'),_0xeefe('0x31'),_0xfec2e9,_0xeefe('0x22'),_0xeefe('0x23')],squel['select']()['fields'](_0x38d5f3)['from'](_0xb584c6)['join'](_0xeefe('0x27'),null,'cm_contacts.ListId\x20=\x20'+_0xb584c6+'.CmListId')[_0xeefe('0x14')](_0x51de59,null,_0x51de59+_0xeefe('0x15')+_0xb584c6+'.'+_0xfec2e9)[_0xeefe('0x16')](_0xb584c6+_0xeefe('0x29'),_0xe5dff4)['where'](_0xeefe('0x32'),NOW)[_0xeefe('0x16')](_0xeefe('0x2c'),squel['select']()[_0xeefe('0x11')](_0xeefe('0x12'))[_0xeefe('0x13')](_0xeefe('0x2e'))[_0xeefe('0x16')](_0xeefe('0x33'),_0xe5dff4)[_0xeefe('0x16')](_0xfec2e9+_0xeefe('0x34'),_0xb584c6+'.'+_0xfec2e9)))[_0xeefe('0x35')]();}function insertTzCmHopper(_0x5126c3,_0x3f4ef4,_0x1ef1d1,_0x2532d2,_0x6749e,_0x436c7f){var _0x33df91=['cm_contacts.phone',_0xeefe('0x36')+_0x436c7f+_0xeefe('0x37'),_0xeefe('0x1b'),_0xeefe('0x1c'),_0x3f4ef4+'.'+_0x2532d2,_0xeefe('0x38'),_0xeefe('0x2d'),'cm_contacts.priority',_0xeefe('0x1e'),'\x22'+_0x6749e+'\x22'];var _0x418dff=squel[_0xeefe('0x1f')]()['into'](_0xeefe('0x21'))['fromQuery']([_0xeefe('0x12'),_0xeefe('0x39'),_0xeefe('0x30'),_0xeefe('0x31'),_0x2532d2,_0xeefe('0x22'),_0xeefe('0x23'),'priority',_0xeefe('0x25'),_0xeefe('0x26')],squel[_0xeefe('0x3a')]()[_0xeefe('0x3b')](_0x33df91)[_0xeefe('0x13')](_0x3f4ef4)['join'](_0xeefe('0x27'),null,_0xeefe('0x28')+_0x3f4ef4+_0xeefe('0x3c'))[_0xeefe('0x14')](_0x1ef1d1,null,_0x1ef1d1+_0xeefe('0x15')+_0x3f4ef4+'.'+_0x2532d2)['join'](_0x436c7f,null,_0x436c7f+_0xeefe('0x15')+_0x3f4ef4+'.'+_0x2532d2)['where'](_0x3f4ef4+'.CmListId\x20=\x20?',_0x5126c3)[_0xeefe('0x16')](_0xeefe('0x32'),NOW)[_0xeefe('0x16')](_0xeefe('0x2c'),selectNotIn(_0x3f4ef4,_0x1ef1d1,_0x2532d2,'cm_hopper',[_0xeefe('0x2a'),'\x22onlyIfOpen\x22']))[_0xeefe('0x16')]('cm_contacts.phone\x20NOT\x20IN\x20(?)',selectNotIn(_0x3f4ef4,_0x1ef1d1,_0x2532d2,'cm_hopper',[_0xeefe('0x2a')])))[_0xeefe('0x35')]();return _0x418dff;}function insertTzCmHopperBlack(_0x32827e,_0x1ffa68,_0x16ae9f,_0x3fedc7){var _0x3aaef4=['cm_contacts.phone',_0xeefe('0x1b'),_0xeefe('0x1c'),_0x1ffa68+'.'+_0x3fedc7,_0xeefe('0x38'),'cm_contacts.updatedAt'];return squel[_0xeefe('0x1f')]()[_0xeefe('0x20')](_0xeefe('0x2e'))[_0xeefe('0x2f')](['phone',_0xeefe('0x30'),_0xeefe('0x31'),_0x3fedc7,_0xeefe('0x22'),_0xeefe('0x23')],squel['select']()[_0xeefe('0x3b')](_0x3aaef4)[_0xeefe('0x13')](_0x1ffa68)['join']('cm_contacts',null,_0xeefe('0x28')+_0x1ffa68+'.CmListId')[_0xeefe('0x14')](_0x16ae9f,null,_0x16ae9f+_0xeefe('0x15')+_0x1ffa68+'.'+_0x3fedc7)['where'](_0x1ffa68+_0xeefe('0x29'),_0x32827e)['where'](_0xeefe('0x32'),NOW)[_0xeefe('0x16')]('cm_contacts.phone\x20NOT\x20IN\x20(?)',squel[_0xeefe('0x3a')]()[_0xeefe('0x11')](_0xeefe('0x12'))[_0xeefe('0x13')](_0xeefe('0x2e'))[_0xeefe('0x16')](_0xeefe('0x33'),_0x32827e)[_0xeefe('0x16')](_0x3fedc7+_0xeefe('0x34'),_0x1ffa68+'.'+_0x3fedc7)))[_0xeefe('0x35')]();}function insertCmContact(_0x50dac5,_0x545af7,_0x550cb4,_0x5c9bff){var _0x5b1aa2=_[_0xeefe('0x3d')](_[_0xeefe('0x3e')](_0x5c9bff),[_0xeefe('0x31'),_0xeefe('0x3f'),_0xeefe('0x22'),_0xeefe('0x23')]);return squel[_0xeefe('0x1f')]()[_0xeefe('0x20')](_0xeefe('0x27'))[_0xeefe('0x2f')](_0x5b1aa2,squel[_0xeefe('0x3a')]()[_0xeefe('0x3b')](_0x5b1aa2)[_0xeefe('0x13')](_0x545af7)[_0xeefe('0x16')]('('+_0x550cb4['join'](',')+')\x20NOT\x20IN\x20?',squel[_0xeefe('0x3a')]()[_0xeefe('0x3b')](_0x550cb4)[_0xeefe('0x13')](_0xeefe('0x27'))[_0xeefe('0x16')]('ListId\x20=\x20?',_0x50dac5)['where'](_0xeefe('0x40')))['where']('id\x20IN\x20?',squel[_0xeefe('0x3a')]()[_0xeefe('0x11')]('MIN(id)',_0xeefe('0x41'))[_0xeefe('0x13')](_0x545af7)[_0xeefe('0x42')](_0x550cb4['join'](','))))[_0xeefe('0x35')]();}function handleStop(){logger[_0xeefe('0x43')]('Received\x20SIGINT');stopped=!![];}function handleUncaughtException(_0x288556){logger['error'](_0x288556[_0xeefe('0x44')]);process[_0xeefe('0x45')](0x1);}function handleError(_0x4e4128,_0x4916c0){stats[_0xeefe('0x46')][_0xeefe('0x47')]({'name':_0x4916c0[_0xeefe('0x48')],'message':_0x4916c0[_0xeefe('0x44')],'row':_0x4e4128});}function handleQuery(_0x4912bd){logger[_0xeefe('0x43')](_0x4912bd);return db[_0xeefe('0x49')][_0xeefe('0x4a')](_0x4912bd)[_0xeefe('0x4b')](function(_0x54b139){results[_0xeefe('0x47')](_0x54b139);})['catch'](function(_0x9de909){logger['error'](_0x9de909['message']);});}function updateTzCampaigns(_0x379997){return new Promise(function(_0x434ce6,_0x2d0ee3){var _0x46a1f9=squel[_0xeefe('0x3a')]()[_0xeefe('0x3b')](['campaigns.id','campaigns.dialTimezone'])[_0xeefe('0x13')](_0xeefe('0x4c'))[_0xeefe('0x14')]('campaigns_has_cm_lists',null,_0xeefe('0x4d'))['where']('campaigns_has_cm_lists.CmListId='+_0x379997);db[_0xeefe('0x49')][_0xeefe('0x4a')](_0x46a1f9[_0xeefe('0x35')]())[_0xeefe('0x4b')](function(_0x4c9601){var _0x9bf08d=[];for(var _0x266a57=0x0;_0x266a57<_0x4c9601[_0xeefe('0x4e')];_0x266a57++){_0x9bf08d[_0xeefe('0x47')](getTimezoneData(_0x4c9601[_0x266a57],tmp_campaigns));}BPromise[_0xeefe('0x4f')](_0x9bf08d)[_0xeefe('0x50')](function(){_0x434ce6({'val':0x1});});})['catch'](function(_0x549e13){logger['error'](_0x549e13[_0xeefe('0x44')]);_0x434ce6({'val':0x0});});});}function updateTzVoiceQueues(_0x3762ad){return new Promise(function(_0x4aac39,_0x462a45){var _0x376be3=squel[_0xeefe('0x3a')]()[_0xeefe('0x3b')]([_0xeefe('0x51'),_0xeefe('0x52')])[_0xeefe('0x13')](_0xeefe('0x53'))[_0xeefe('0x14')](_0xeefe('0x54'),null,'voice_queues.id\x20=\x20voice_queues_has_cm_lists.VoiceQueueId')[_0xeefe('0x16')](_0xeefe('0x55')+_0x3762ad);db['sequelize']['query'](_0x376be3[_0xeefe('0x35')]())[_0xeefe('0x4b')](function(_0xb8791c){var _0x207529=[];for(var _0x578950=0x0;_0x578950<_0xb8791c['length'];_0x578950++){_0x207529[_0xeefe('0x47')](getTimezoneData(_0xb8791c[_0x578950],tmp_voice_queues));}BPromise[_0xeefe('0x4f')](_0x207529)[_0xeefe('0x50')](function(){_0x4aac39({'val':0x1});});})['catch'](function(_0x5aaaab){logger[_0xeefe('0x56')](_0x5aaaab[_0xeefe('0x44')]);_0x4aac39({'val':0x0});});});}function getTimezoneData(_0x5392cb,_0x1f78ef){return new Promise(function(_0x58a0d7,_0x1efd7f){var _0x4914c4=shared[_0xeefe('0x57')];var _0x562e9e=_0x4914c4[_0x5392cb[_0xeefe('0x58')]];if(_['isNil'](_0x562e9e)){_0x58a0d7({'ret':0x1});}else{var _0x474e3e=_0x562e9e[_0xeefe('0x59')];var _0x193274=squel['insert']()[_0xeefe('0x20')](_0x1f78ef)[_0xeefe('0x5a')]('id',_0x5392cb['id'])[_0xeefe('0x5a')](_0xeefe('0x5b'),_0x474e3e)[_0xeefe('0x5a')]('dialTimezone',_0x5392cb[_0xeefe('0x58')])[_0xeefe('0x35')]();return db[_0xeefe('0x49')]['query'](_0x193274)[_0xeefe('0x4b')](function(_0x2168d8){_0x58a0d7({'ret':0x1});})[_0xeefe('0x5c')](function(_0x5b740e){logger[_0xeefe('0x56')](_0x5b740e['message']);_0x1efd7f({'ret':0x1});});}});}function handleTZQuery(_0xac4f1c){logger[_0xeefe('0x43')](_0xac4f1c);return db['sequelize'][_0xeefe('0x4a')](_0xac4f1c)[_0xeefe('0x4b')](function(_0x37c7d7){})[_0xeefe('0x5c')](function(_0x54dbd2){logger[_0xeefe('0x56')](_0x54dbd2[_0xeefe('0x44')]);});}function main(_0x1fe2bd,_0x375259,_0x4ba0b4,_0x45169e){logger['info']('main',_0x1fe2bd,JSON[_0xeefe('0x5d')](_0x375259));process['send'](_0xeefe('0x5e'));var _0x16f391=_0x375259[_0xeefe('0x5f')];var _0x5bbcc9=_0x375259[_0xeefe('0x60')];var _0x4a226c=path[_0xeefe('0x14')](config['root'],_0xeefe('0x61'),_0x5bbcc9+_0xeefe('0x62'));hasTZ=_[_0xeefe('0x3e')](_0x16f391)['includes'](_0xeefe('0x58'));var _0x6482ba=_[_0xeefe('0x3e')](_0x16f391)[_0xeefe('0x14')]();logger[_0xeefe('0x43')](_0xeefe('0x63'),_0x6482ba);if(hasTZ)_0x6482ba+=',utcOffset';fs[_0xeefe('0x64')](_0x4a226c,_0x6482ba+'\x0a');Papa[_0xeefe('0x65')](fs['createReadStream'](_0x1fe2bd),{'header':!![],'skipEmptyLines':!![],'step':function(_0x3d003e,_0x52ad7b){try{for(var _0x4f3541=0x0,_0x5909f8=[];_0x4f3541<_0x3d003e[_0xeefe('0x66')][_0xeefe('0x4e')];_0x4f3541++){stats[_0xeefe('0x67')]+=0x1;if(_0x3d003e[_0xeefe('0x46')][_0x4f3541]){handleError(_0x3d003e[_0xeefe('0x66')][_0x4f3541],_0x3d003e['errors'][_0x4f3541]);}else{var _0x675920=[];for(var _0x986f1c in _0x16f391){if(_0x16f391[_0xeefe('0x68')](_0x986f1c)){if(_0x3d003e[_0xeefe('0x66')][_0x4f3541][_0x16f391[_0x986f1c]]){var _0x5f0dc1=_[_0xeefe('0x69')](_0x3d003e[_0xeefe('0x66')][_0x4f3541][_0x16f391[_0x986f1c]][_0xeefe('0x6a')](/"/g,'\x27'));switch(_0x986f1c){case'scheduledat':var _0x5e04de=moment(_0x5f0dc1,_0xeefe('0xf'),!![]);if(_0x5e04de[_0xeefe('0x6b')]()){_0x5909f8[_0xeefe('0x47')]('\x22'+_0x5f0dc1+'\x22');}else{_0x675920[_0xeefe('0x47')](_0xeefe('0x6c'));}break;case _0xeefe('0x24'):var _0x1a3c58=parseInt(_0x5f0dc1);_0x5f0dc1=_[_0xeefe('0x6d')](_0x1a3c58)||_0x1a3c58<0x0||_0x1a3c58>0x4?_0x45169e?0x3:0x2:_0x1a3c58;_0x5909f8[_0xeefe('0x47')]('\x22'+_0x5f0dc1+'\x22');break;case _0xeefe('0x25'):var _0xe948fc=parseInt(_0x5f0dc1);if(_[_0xeefe('0x6e')](_0xe948fc)&&_[_0xeefe('0x6f')](_0x4ba0b4,_0xe948fc)){_0x5909f8[_0xeefe('0x47')]('\x22'+_0xe948fc+'\x22');}else{_0x675920[_0xeefe('0x47')](_0xeefe('0x70'));}break;case'email':if(isEmail(_0x5f0dc1)){_0x5909f8['push']('\x22'+_0x5f0dc1+'\x22');}else{_0x675920[_0xeefe('0x47')](_0xeefe('0x71'));}break;case _0xeefe('0x72'):var _0x2abd48=moment(_0x5f0dc1,_0xeefe('0x73'),!![]);if(_0x2abd48[_0xeefe('0x6b')]()){_0x5909f8['push']('\x22'+_0x5f0dc1+'\x22');}else{_0x675920[_0xeefe('0x47')]('dateOfBirth\x20wrong\x20format\x20(YYYY-MM-DD)');}break;case _0xeefe('0x58'):var _0x50ec5e=shared[_0xeefe('0x57')];var _0x2637f8=_0x50ec5e[_0x5f0dc1];if(!_['isNil'](_0x2637f8)){var _0x5c76e7=_0x2637f8[_0xeefe('0x59')];_0x5909f8[_0xeefe('0x47')]('\x22'+_0x5f0dc1+'\x22');_0x5909f8[_0xeefe('0x47')]('\x22'+_0x5c76e7+'\x22');}break;default:_0x5909f8['push']('\x22'+_0x5f0dc1+'\x22');}}else{switch(_0x986f1c){case _0xeefe('0x74'):case _0xeefe('0x12'):_0x675920[_0xeefe('0x47')](_0x986f1c+_0xeefe('0x75'));break;default:_0x5909f8[_0xeefe('0x47')]('\x22\x22');}}}}if(_0x675920[_0xeefe('0x4e')]){handleError(_0x3d003e[_0xeefe('0x66')][_0x4f3541],{'code':_0xeefe('0x76'),'message':_0x675920[_0xeefe('0x14')]()});}else{fs['appendFileSync'](_0x4a226c,_0x5909f8['join']()+'\x0a');}_0x5909f8=[];}if(!(stats[_0xeefe('0x67')]%0xc8)){socket[_0xeefe('0x77')](_0xeefe('0x78')+_0x5bbcc9,stats);stats['errors']=[];}}if(stopped){logger[_0xeefe('0x43')](_0xeefe('0x79'));_0x52ad7b[_0xeefe('0x7a')]();}}catch(_0x5e989b){handleError(_0x3d003e['data'][_0x4f3541],{'code':_0xeefe('0x7b'),'message':_0x5e989b['message']});logger['error']('step',_0x5e989b['message']);}},'complete':function(){try{var _0x514bc3=[];var _0x41c075=[];var _0x29fd44=_0xeefe('0x27');if(_0x375259[_0xeefe('0x7c')]&&_0x375259[_0xeefe('0x7c')][_0xeefe('0x4e')]){_0x29fd44=_0xeefe('0x7d')+_0x5bbcc9;_0x514bc3[_0xeefe('0x47')]('CREATE\x20TABLE\x20'+_0x29fd44+_0xeefe('0x7e'));}tmp_campaigns=_0xeefe('0x7f')+_0x5bbcc9;tmp_voice_queues=_0xeefe('0x80')+_0x5bbcc9;_0x41c075[_0xeefe('0x47')](_0xeefe('0x81')+tmp_campaigns+_0xeefe('0x82'));_0x41c075[_0xeefe('0x47')]('CREATE\x20TABLE\x20'+tmp_voice_queues+'(id\x20int,dialTimezone\x20varchar(255),offset\x20int);');BPromise['each'](_0x41c075,handleTZQuery)[_0xeefe('0x50')](function(_0x2cf25f){updateTzCampaigns(_0x375259['ListId'])[_0xeefe('0x50')](function(_0x13ec55){updateTzVoiceQueues(_0x375259['ListId'])['then'](function(_0x48deae){var _0x75db93=util[_0xeefe('0xe')](_0xeefe('0x83'),_0x4a226c,_0x29fd44,_0x6482ba,_0x375259[_0xeefe('0x31')],_0x375259[_0xeefe('0x3f')]||null,NOW,NOW);if(_[_0xeefe('0x84')](_0x16f391[_0xeefe('0x39')])){_0x75db93+=_0xeefe('0x85');}_0x514bc3[_0xeefe('0x47')](_0x75db93);if(_0x375259[_0xeefe('0x7c')]&&_0x375259[_0xeefe('0x7c')][_0xeefe('0x4e')]){_0x514bc3[_0xeefe('0x47')](insertCmContact(_0x375259[_0xeefe('0x31')],_0x29fd44,_0x375259[_0xeefe('0x7c')],_0x16f391));_0x514bc3[_0xeefe('0x47')]('DROP\x20TABLE\x20'+_0x29fd44+';');}if(hasTZ){_0x514bc3[_0xeefe('0x47')](insertTzCmHopper(_0x375259[_0xeefe('0x31')],_0xeefe('0x54'),'voice_queues','VoiceQueueId',_0x45169e,tmp_voice_queues));_0x514bc3[_0xeefe('0x47')](insertTzCmHopperBlack(_0x375259[_0xeefe('0x31')],'voice_queues_has_cm_blacklists','voice_queues',_0xeefe('0x86')));_0x514bc3['push'](insertTzCmHopper(_0x375259[_0xeefe('0x31')],_0xeefe('0x87'),'campaigns',_0xeefe('0x88'),_0x45169e,tmp_campaigns));_0x514bc3[_0xeefe('0x47')](insertTzCmHopperBlack(_0x375259[_0xeefe('0x31')],_0xeefe('0x89'),_0xeefe('0x4c'),_0xeefe('0x88')));}else{_0x514bc3[_0xeefe('0x47')](insertCmHopper(_0x375259[_0xeefe('0x31')],'voice_queues_has_cm_lists',_0xeefe('0x53'),'VoiceQueueId',_0x45169e));_0x514bc3[_0xeefe('0x47')](insertCmHopperBlack(_0x375259[_0xeefe('0x31')],_0xeefe('0x8a'),'voice_queues',_0xeefe('0x86')));_0x514bc3[_0xeefe('0x47')](insertCmHopper(_0x375259[_0xeefe('0x31')],'campaigns_has_cm_lists',_0xeefe('0x4c'),_0xeefe('0x88'),_0x45169e));_0x514bc3[_0xeefe('0x47')](insertCmHopperBlack(_0x375259[_0xeefe('0x31')],_0xeefe('0x89'),_0xeefe('0x4c'),'CampaignId'));}_0x514bc3[_0xeefe('0x47')](_0xeefe('0x8b')+tmp_campaigns+';');_0x514bc3[_0xeefe('0x47')](_0xeefe('0x8b')+tmp_voice_queues+';');BPromise[_0xeefe('0x8c')](_0x514bc3,handleQuery)[_0xeefe('0x50')](function(_0x1a897e){stats['finish']=!![];stats[_0xeefe('0x8d')]=_0x375259[_0xeefe('0x7c')]&&_0x375259[_0xeefe('0x7c')][_0xeefe('0x4e')]?results[0x2][_0xeefe('0x8d')]:results[0x0][_0xeefe('0x8d')];socket['emit']('contact:import:'+_0x5bbcc9,stats);fs[_0xeefe('0x8e')](_0x1fe2bd);fs[_0xeefe('0x8e')](_0x4a226c);process['exit'](0x0);})[_0xeefe('0x5c')](function(_0x443cc6){logger['error'](_0x443cc6['message']);process[_0xeefe('0x45')](0x1);});});});});}catch(_0xe6cf2d){logger['error']('complete',_0xe6cf2d[_0xeefe('0x44')]);process[_0xeefe('0x45')](0x1);}},'error':function(_0xf466be,_0x2d2fae,_0x31fd56,_0x41af33){throw new Error(_0x41af33);}});}function validate(){if(process[_0xeefe('0x8f')]&&process['argv'][_0xeefe('0x4e')]<0x4){throw new Error(_0xeefe('0x90'));}var _0x1e29cb=path['join'](config[_0xeefe('0x91')],'server/files/tmp',process[_0xeefe('0x8f')][0x2]);if(!fs[_0xeefe('0x92')](_0x1e29cb)){throw new Error(_0xeefe('0x93'));}var _0x46ffde={};try{_0x46ffde=JSON['parse'](process['argv'][0x3]);if(!_0x46ffde[_0xeefe('0x5f')]){throw new Error('binding\x20doesn\x27t\x20exists');}if(!_0x46ffde['binding'][_0xeefe('0x12')]){throw new Error(_0xeefe('0x94'));}if(!_0x46ffde[_0xeefe('0x5f')][_0xeefe('0x74')]){throw new Error(_0xeefe('0x95'));}var _0x5c3ffd=0x0;if(_0x46ffde[_0xeefe('0x5f')][_0xeefe('0x25')]){_0x5c3ffd=0x1;}if(!_0x46ffde[_0xeefe('0x31')]){throw new Error('ListId\x20is\x20mandatory');}}catch(_0x19ffef){throw new Error(_0xeefe('0x96'));}var _0x47a93a=[];try{_0x47a93a=_[_0xeefe('0x97')](JSON[_0xeefe('0x65')](process[_0xeefe('0x8f')][0x4]),'id');}catch(_0x2110a5){logger[_0xeefe('0x43')](_0xeefe('0x98'));}main(_0x1e29cb,_0x46ffde,_0x47a93a,_0x5c3ffd);}validate();process['on'](_0xeefe('0x99'),handleStop);process['on'](_0xeefe('0x9a'),handleUncaughtException);
\ No newline at end of file
+var _0xc380=['push','code','sequelize','spread','catch','campaigns.id','campaigns.dialTimezone','campaigns.id\x20=\x20campaigns_has_cm_lists.CampaignId','campaigns_has_cm_lists.CmListId=','query','length','all','voice_queues.id','voice_queues.dialTimezone','voice_queues','voice_queues_has_cm_lists','voice_queues.id\x20=\x20voice_queues_has_cm_lists.VoiceQueueId','voice_queues_has_cm_lists.CmListId=','timezones','dialTimezone','isNil','utcOffset','set','offset','main','stringify','start','binding','root','server/files/tmp','includes','info',',utcOffset','writeFileSync','createReadStream','data','errors','hasOwnProperty','trim','replace','isValid','isNaN','isNumber','email','email\x20wrong\x20format','dateOfBirth','YYYY-MM-DD','dateOfBirth\x20wrong\x20format\x20(YYYY-MM-DD)','firstName','\x20not\x20specified','SystemRow','appendFileSync','rows','emit','contact:import:','Abort\x20parser','abort','SystemError','duplicates','cm_contacts_','\x20LIKE\x20cm_contacts;','CREATE\x20TABLE\x20','(id\x20int,dialTimezone\x20varchar(255),offset\x20int);','each','then','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',',\x20scheduledAt\x20=\x20NOW()','VoiceQueueId','voice_queues_has_cm_blacklists','campaigns_has_cm_lists','campaigns','CampaignId','campaigns_has_cm_blacklists','DROP\x20TABLE\x20','finish','affectedRows','unlink','exit','complete','argv','arguments\x20<filename>\x20<parameters>\x20<agents>','existsSync','file\x20doesn\x27t\x20exists','parse','binding\x20doesn\x27t\x20exists','phone\x20is\x20mandatory','firstName\x20is\x20mandatory','body\x20id\x20mandatory','map','No\x20agent\x20available','uncaughtException','path','lodash','papaparse','util','bluebird','moment','squel','ioredis','../../../mysqldb','../../../config/environment','../../../config/environment/shared','../../../config/logger','import','redis','defaults','localhost','format','YYYY-MM-DD\x20HH:mm:ss','test','field','phone','from','.id\x20=\x20','\x20=\x20','where','join','cm_contacts.phone','cm_contacts.id','cm_contacts.updatedAt','cm_contacts.UserId','into','cm_hopper','fromQuery','scheduledat','ListId','createdAt','updatedAt','priority','UserId','recallme','select','fields','cm_contacts','cm_contacts.ListId\x20=\x20','.CmListId','.CmListId\x20=\x20?','cm_contacts.createdAt\x20=\x20?','cm_contacts.phone\x20NOT\x20IN\x20(?)','\x22always\x22','\x22onlyIfOpen\x22','toString','cm_contacts.ListId','cm_contacts.createdAt','insert','cm_hopper_black','ListId\x20=\x20?','date_add(cm_contacts.scheduledat,interval\x20','.offset-cm_contacts.utcOffset\x20minute)','cm_contacts.priority','ContactId','\x20=\x20?','keys',')\x20NOT\x20IN\x20?','deletedAt\x20IS\x20NULL','id\x20IN\x20?','MIN(id)','group','error','message'];(function(_0x4b369d,_0x265eb8){var _0x571a98=function(_0x56341a){while(--_0x56341a){_0x4b369d['push'](_0x4b369d['shift']());}};_0x571a98(++_0x265eb8);}(_0xc380,0xfd));var _0x0c38=function(_0x496ffa,_0x53583f){_0x496ffa=_0x496ffa-0x0;var _0x3dd12e=_0xc380[_0x496ffa];return _0x3dd12e;};'use strict';var fs=require('fs');var path=require(_0x0c38('0x0'));var _=require(_0x0c38('0x1'));var Papa=require(_0x0c38('0x2'));var util=require(_0x0c38('0x3'));var BPromise=require(_0x0c38('0x4'));var moment=require(_0x0c38('0x5'));var squel=require(_0x0c38('0x6'));var Redis=require(_0x0c38('0x7'));var db=require(_0x0c38('0x8'))['db'];var config=require(_0x0c38('0x9'));var shared=require(_0x0c38('0xa'));var logger=require(_0x0c38('0xb'))(_0x0c38('0xc'));config[_0x0c38('0xd')]=_[_0x0c38('0xe')](config['redis'],{'host':_0x0c38('0xf'),'port':0x18eb});var socket=require('socket.io-emitter')(new Redis(config[_0x0c38('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()[_0x0c38('0x10')](_0x0c38('0x11'));function isEmail(_0x2d0f18){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))*$/[_0x0c38('0x12')](_0x2d0f18);}function selectNotIn(_0x5e857a,_0x3e4144,_0x29aaec,_0x3bd284,_0x590d1b){return squel['select']()[_0x0c38('0x13')](_0x0c38('0x14'))[_0x0c38('0x15')](_0x3bd284)['join'](_0x3e4144,null,_0x3e4144+_0x0c38('0x16')+_0x3bd284+'.'+_0x29aaec)['where'](_0x3bd284+'.'+_0x29aaec+_0x0c38('0x17')+_0x5e857a+'.'+_0x29aaec)[_0x0c38('0x18')](_0x3e4144+'.dialCheckDuplicateType\x20IN\x20('+_0x590d1b[_0x0c38('0x19')]()+')');}function insertCmHopper(_0x369a96,_0x405cac,_0x1bc187,_0x5c10ca,_0x16cd25){var _0x51d100=[_0x0c38('0x1a'),'cm_contacts.scheduledat',_0x0c38('0x1b'),'cm_contacts.ListId',_0x405cac+'.'+_0x5c10ca,'cm_contacts.createdAt',_0x0c38('0x1c'),'cm_contacts.priority',_0x0c38('0x1d'),'\x22'+_0x16cd25+'\x22'];return squel['insert']()[_0x0c38('0x1e')](_0x0c38('0x1f'))[_0x0c38('0x20')]([_0x0c38('0x14'),_0x0c38('0x21'),'ContactId',_0x0c38('0x22'),_0x5c10ca,_0x0c38('0x23'),_0x0c38('0x24'),_0x0c38('0x25'),_0x0c38('0x26'),_0x0c38('0x27')],squel[_0x0c38('0x28')]()[_0x0c38('0x29')](_0x51d100)['from'](_0x405cac)[_0x0c38('0x19')](_0x0c38('0x2a'),null,_0x0c38('0x2b')+_0x405cac+_0x0c38('0x2c'))[_0x0c38('0x19')](_0x1bc187,null,_0x1bc187+_0x0c38('0x16')+_0x405cac+'.'+_0x5c10ca)['where'](_0x405cac+_0x0c38('0x2d'),_0x369a96)[_0x0c38('0x18')](_0x0c38('0x2e'),NOW)[_0x0c38('0x18')](_0x0c38('0x2f'),selectNotIn(_0x405cac,_0x1bc187,_0x5c10ca,_0x0c38('0x1f'),[_0x0c38('0x30'),_0x0c38('0x31')]))[_0x0c38('0x18')](_0x0c38('0x2f'),selectNotIn(_0x405cac,_0x1bc187,_0x5c10ca,'cm_hopper',[_0x0c38('0x30')])))[_0x0c38('0x32')]();}function insertCmHopperBlack(_0xc7476a,_0x5cd20a,_0x2b6498,_0x24080f){var _0x503025=[_0x0c38('0x1a'),_0x0c38('0x1b'),_0x0c38('0x33'),_0x5cd20a+'.'+_0x24080f,_0x0c38('0x34'),_0x0c38('0x1c')];return squel[_0x0c38('0x35')]()[_0x0c38('0x1e')](_0x0c38('0x36'))[_0x0c38('0x20')]([_0x0c38('0x14'),'ContactId',_0x0c38('0x22'),_0x24080f,_0x0c38('0x23'),_0x0c38('0x24')],squel[_0x0c38('0x28')]()['fields'](_0x503025)[_0x0c38('0x15')](_0x5cd20a)[_0x0c38('0x19')](_0x0c38('0x2a'),null,_0x0c38('0x2b')+_0x5cd20a+'.CmListId')[_0x0c38('0x19')](_0x2b6498,null,_0x2b6498+_0x0c38('0x16')+_0x5cd20a+'.'+_0x24080f)[_0x0c38('0x18')](_0x5cd20a+'.CmListId\x20=\x20?',_0xc7476a)[_0x0c38('0x18')]('cm_contacts.createdAt\x20=\x20?',NOW)[_0x0c38('0x18')](_0x0c38('0x2f'),squel[_0x0c38('0x28')]()['field'](_0x0c38('0x14'))['from']('cm_hopper_black')[_0x0c38('0x18')](_0x0c38('0x37'),_0xc7476a)[_0x0c38('0x18')](_0x24080f+'\x20=\x20?',_0x5cd20a+'.'+_0x24080f)))[_0x0c38('0x32')]();}function insertTzCmHopper(_0x301a7f,_0x38b3ba,_0x6f6a48,_0x3739d4,_0x3663bc,_0x100f79){var _0x10e93b=[_0x0c38('0x1a'),_0x0c38('0x38')+_0x100f79+_0x0c38('0x39'),_0x0c38('0x1b'),_0x0c38('0x33'),_0x38b3ba+'.'+_0x3739d4,_0x0c38('0x34'),_0x0c38('0x1c'),_0x0c38('0x3a'),_0x0c38('0x1d'),'\x22'+_0x3663bc+'\x22'];var _0x5e56f5=squel[_0x0c38('0x35')]()['into']('cm_hopper')[_0x0c38('0x20')](['phone',_0x0c38('0x21'),_0x0c38('0x3b'),_0x0c38('0x22'),_0x3739d4,_0x0c38('0x23'),_0x0c38('0x24'),_0x0c38('0x25'),_0x0c38('0x26'),_0x0c38('0x27')],squel[_0x0c38('0x28')]()[_0x0c38('0x29')](_0x10e93b)[_0x0c38('0x15')](_0x38b3ba)[_0x0c38('0x19')](_0x0c38('0x2a'),null,_0x0c38('0x2b')+_0x38b3ba+_0x0c38('0x2c'))[_0x0c38('0x19')](_0x6f6a48,null,_0x6f6a48+_0x0c38('0x16')+_0x38b3ba+'.'+_0x3739d4)[_0x0c38('0x19')](_0x100f79,null,_0x100f79+_0x0c38('0x16')+_0x38b3ba+'.'+_0x3739d4)['where'](_0x38b3ba+'.CmListId\x20=\x20?',_0x301a7f)['where'](_0x0c38('0x2e'),NOW)['where'](_0x0c38('0x2f'),selectNotIn(_0x38b3ba,_0x6f6a48,_0x3739d4,_0x0c38('0x1f'),[_0x0c38('0x30'),'\x22onlyIfOpen\x22']))[_0x0c38('0x18')](_0x0c38('0x2f'),selectNotIn(_0x38b3ba,_0x6f6a48,_0x3739d4,_0x0c38('0x1f'),[_0x0c38('0x30')])))[_0x0c38('0x32')]();return _0x5e56f5;}function insertTzCmHopperBlack(_0x169f5d,_0x19333d,_0x4a55bd,_0x43f0c4){var _0x7c7211=[_0x0c38('0x1a'),_0x0c38('0x1b'),_0x0c38('0x33'),_0x19333d+'.'+_0x43f0c4,_0x0c38('0x34'),_0x0c38('0x1c')];return squel[_0x0c38('0x35')]()[_0x0c38('0x1e')](_0x0c38('0x36'))[_0x0c38('0x20')]([_0x0c38('0x14'),_0x0c38('0x3b'),'ListId',_0x43f0c4,_0x0c38('0x23'),_0x0c38('0x24')],squel[_0x0c38('0x28')]()['fields'](_0x7c7211)[_0x0c38('0x15')](_0x19333d)[_0x0c38('0x19')](_0x0c38('0x2a'),null,'cm_contacts.ListId\x20=\x20'+_0x19333d+'.CmListId')[_0x0c38('0x19')](_0x4a55bd,null,_0x4a55bd+'.id\x20=\x20'+_0x19333d+'.'+_0x43f0c4)[_0x0c38('0x18')](_0x19333d+_0x0c38('0x2d'),_0x169f5d)[_0x0c38('0x18')](_0x0c38('0x2e'),NOW)[_0x0c38('0x18')](_0x0c38('0x2f'),squel['select']()[_0x0c38('0x13')](_0x0c38('0x14'))[_0x0c38('0x15')](_0x0c38('0x36'))[_0x0c38('0x18')](_0x0c38('0x37'),_0x169f5d)[_0x0c38('0x18')](_0x43f0c4+_0x0c38('0x3c'),_0x19333d+'.'+_0x43f0c4)))[_0x0c38('0x32')]();}function insertCmContact(_0x4e8c82,_0x1551f0,_0x35d672,_0x560ff1){var _0xfb8d1b=_['concat'](_[_0x0c38('0x3d')](_0x560ff1),[_0x0c38('0x22'),'CompanyId',_0x0c38('0x23'),_0x0c38('0x24')]);return squel[_0x0c38('0x35')]()['into'](_0x0c38('0x2a'))[_0x0c38('0x20')](_0xfb8d1b,squel[_0x0c38('0x28')]()['fields'](_0xfb8d1b)[_0x0c38('0x15')](_0x1551f0)[_0x0c38('0x18')]('('+_0x35d672[_0x0c38('0x19')](',')+_0x0c38('0x3e'),squel[_0x0c38('0x28')]()[_0x0c38('0x29')](_0x35d672)[_0x0c38('0x15')](_0x0c38('0x2a'))['where']('ListId\x20=\x20?',_0x4e8c82)[_0x0c38('0x18')](_0x0c38('0x3f')))[_0x0c38('0x18')](_0x0c38('0x40'),squel['select']()[_0x0c38('0x13')](_0x0c38('0x41'),'min_id')[_0x0c38('0x15')](_0x1551f0)[_0x0c38('0x42')](_0x35d672[_0x0c38('0x19')](','))))['toString']();}function handleStop(){logger['info']('Received\x20SIGINT');stopped=!![];}function handleUncaughtException(_0x29eb94){logger[_0x0c38('0x43')](_0x29eb94[_0x0c38('0x44')]);process['exit'](0x1);}function handleError(_0x4ab8ec,_0x395651){stats['errors'][_0x0c38('0x45')]({'name':_0x395651[_0x0c38('0x46')],'message':_0x395651[_0x0c38('0x44')],'row':_0x4ab8ec});}function handleQuery(_0x577be5){logger['info'](_0x577be5);return db[_0x0c38('0x47')]['query'](_0x577be5)[_0x0c38('0x48')](function(_0x2665a3){results[_0x0c38('0x45')](_0x2665a3);})[_0x0c38('0x49')](function(_0x3d3d63){logger[_0x0c38('0x43')](_0x3d3d63[_0x0c38('0x44')]);});}function updateTzCampaigns(_0x483104){return new Promise(function(_0x12dc75,_0x2e238b){var _0x4c4a25=squel['select']()[_0x0c38('0x29')]([_0x0c38('0x4a'),_0x0c38('0x4b')])[_0x0c38('0x15')]('campaigns')[_0x0c38('0x19')]('campaigns_has_cm_lists',null,_0x0c38('0x4c'))[_0x0c38('0x18')](_0x0c38('0x4d')+_0x483104);db[_0x0c38('0x47')][_0x0c38('0x4e')](_0x4c4a25[_0x0c38('0x32')]())[_0x0c38('0x48')](function(_0x223504){var _0x598f54=[];for(var _0x3db1d1=0x0;_0x3db1d1<_0x223504[_0x0c38('0x4f')];_0x3db1d1++){_0x598f54['push'](getTimezoneData(_0x223504[_0x3db1d1],tmp_campaigns));}BPromise[_0x0c38('0x50')](_0x598f54)['then'](function(){_0x12dc75({'val':0x1});});})[_0x0c38('0x49')](function(_0x1faf3e){logger[_0x0c38('0x43')](_0x1faf3e['message']);_0x12dc75({'val':0x0});});});}function updateTzVoiceQueues(_0x2f3803){return new Promise(function(_0x18271a,_0x14e474){var _0x20dd35=squel[_0x0c38('0x28')]()['fields']([_0x0c38('0x51'),_0x0c38('0x52')])['from'](_0x0c38('0x53'))[_0x0c38('0x19')](_0x0c38('0x54'),null,_0x0c38('0x55'))[_0x0c38('0x18')](_0x0c38('0x56')+_0x2f3803);db['sequelize'][_0x0c38('0x4e')](_0x20dd35['toString']())[_0x0c38('0x48')](function(_0x32f3bb){var _0x44a735=[];for(var _0x2bddfd=0x0;_0x2bddfd<_0x32f3bb[_0x0c38('0x4f')];_0x2bddfd++){_0x44a735[_0x0c38('0x45')](getTimezoneData(_0x32f3bb[_0x2bddfd],tmp_voice_queues));}BPromise[_0x0c38('0x50')](_0x44a735)['then'](function(){_0x18271a({'val':0x1});});})[_0x0c38('0x49')](function(_0x24f515){logger[_0x0c38('0x43')](_0x24f515[_0x0c38('0x44')]);_0x18271a({'val':0x0});});});}function getTimezoneData(_0x438f57,_0x1f8409){return new Promise(function(_0x2ca801,_0x52ffd4){var _0x40f471=shared[_0x0c38('0x57')];var _0x5ba436=_0x40f471[_0x438f57[_0x0c38('0x58')]];if(_[_0x0c38('0x59')](_0x5ba436)){_0x2ca801({'ret':0x1});}else{var _0x45508d=_0x5ba436[_0x0c38('0x5a')];var _0x550549=squel['insert']()[_0x0c38('0x1e')](_0x1f8409)[_0x0c38('0x5b')]('id',_0x438f57['id'])[_0x0c38('0x5b')](_0x0c38('0x5c'),_0x45508d)[_0x0c38('0x5b')]('dialTimezone',_0x438f57[_0x0c38('0x58')])[_0x0c38('0x32')]();return db[_0x0c38('0x47')][_0x0c38('0x4e')](_0x550549)[_0x0c38('0x48')](function(_0x34da49){_0x2ca801({'ret':0x1});})['catch'](function(_0x451b){logger[_0x0c38('0x43')](_0x451b['message']);_0x52ffd4({'ret':0x1});});}});}function handleTZQuery(_0x1086cb){logger['info'](_0x1086cb);return db[_0x0c38('0x47')][_0x0c38('0x4e')](_0x1086cb)['spread'](function(_0x37c458){})[_0x0c38('0x49')](function(_0x254a34){logger['error'](_0x254a34['message']);});}function main(_0x12671d,_0x2fad85,_0x4677c7,_0x2fd42d){logger['info'](_0x0c38('0x5d'),_0x12671d,JSON[_0x0c38('0x5e')](_0x2fad85));process['send'](_0x0c38('0x5f'));var _0x244855=_0x2fad85[_0x0c38('0x60')];var _0x5035ca=_0x2fad85['socket_timestamp'];var _0x3f1e40=path[_0x0c38('0x19')](config[_0x0c38('0x61')],_0x0c38('0x62'),_0x5035ca+'.csv');hasTZ=_[_0x0c38('0x3d')](_0x244855)[_0x0c38('0x63')](_0x0c38('0x58'));var _0x194d55=_[_0x0c38('0x3d')](_0x244855)['join']();logger[_0x0c38('0x64')]('header',_0x194d55);if(hasTZ)_0x194d55+=_0x0c38('0x65');fs[_0x0c38('0x66')](_0x3f1e40,_0x194d55+'\x0a');Papa['parse'](fs[_0x0c38('0x67')](_0x12671d),{'header':!![],'skipEmptyLines':!![],'step':function(_0x530822,_0x44b6a6){try{for(var _0x4f0fda=0x0,_0x57ea7e=[];_0x4f0fda<_0x530822[_0x0c38('0x68')][_0x0c38('0x4f')];_0x4f0fda++){stats['rows']+=0x1;if(_0x530822[_0x0c38('0x69')][_0x4f0fda]){handleError(_0x530822['data'][_0x4f0fda],_0x530822['errors'][_0x4f0fda]);}else{var _0x1db55c=[];for(var _0x6c103b in _0x244855){if(_0x244855[_0x0c38('0x6a')](_0x6c103b)){if(_0x530822[_0x0c38('0x68')][_0x4f0fda][_0x244855[_0x6c103b]]){var _0x48a417=_[_0x0c38('0x6b')](_0x530822[_0x0c38('0x68')][_0x4f0fda][_0x244855[_0x6c103b]][_0x0c38('0x6c')](/"/g,'\x27'));switch(_0x6c103b){case'scheduledat':var _0x327743=moment(_0x48a417,_0x0c38('0x11'),!![]);if(_0x327743[_0x0c38('0x6d')]()){_0x57ea7e[_0x0c38('0x45')]('\x22'+_0x48a417+'\x22');}else{_0x1db55c[_0x0c38('0x45')]('scheduledat\x20wrong\x20format\x20(YYYY-MM-DD\x20HH:mm:ss)');}break;case'priority':var _0x46f061=parseInt(_0x48a417);_0x48a417=_[_0x0c38('0x6e')](_0x46f061)||_0x46f061<0x0||_0x46f061>0x4?_0x2fd42d?0x3:0x2:_0x46f061;_0x57ea7e[_0x0c38('0x45')]('\x22'+_0x48a417+'\x22');break;case _0x0c38('0x26'):var _0x379ec6=parseInt(_0x48a417);if(_[_0x0c38('0x6f')](_0x379ec6)&&_['includes'](_0x4677c7,_0x379ec6)){_0x57ea7e[_0x0c38('0x45')]('\x22'+_0x379ec6+'\x22');}else{_0x1db55c[_0x0c38('0x45')]('agent\x20not\x20exists');}break;case _0x0c38('0x70'):if(isEmail(_0x48a417)){_0x57ea7e[_0x0c38('0x45')]('\x22'+_0x48a417+'\x22');}else{_0x1db55c[_0x0c38('0x45')](_0x0c38('0x71'));}break;case _0x0c38('0x72'):var _0xc9c893=moment(_0x48a417,_0x0c38('0x73'),!![]);if(_0xc9c893['isValid']()){_0x57ea7e['push']('\x22'+_0x48a417+'\x22');}else{_0x1db55c[_0x0c38('0x45')](_0x0c38('0x74'));}break;case'dialTimezone':var _0x522a08=shared[_0x0c38('0x57')];var _0x5a416b=_0x522a08[_0x48a417];if(!_[_0x0c38('0x59')](_0x5a416b)){var _0x3e59b2=_0x5a416b[_0x0c38('0x5a')];_0x57ea7e[_0x0c38('0x45')]('\x22'+_0x48a417+'\x22');_0x57ea7e[_0x0c38('0x45')]('\x22'+_0x3e59b2+'\x22');}break;default:_0x57ea7e[_0x0c38('0x45')]('\x22'+_0x48a417+'\x22');}}else{switch(_0x6c103b){case _0x0c38('0x75'):case _0x0c38('0x14'):_0x1db55c[_0x0c38('0x45')](_0x6c103b+_0x0c38('0x76'));break;default:_0x57ea7e[_0x0c38('0x45')]('\x22\x22');}}}}if(_0x1db55c[_0x0c38('0x4f')]){handleError(_0x530822[_0x0c38('0x68')][_0x4f0fda],{'code':_0x0c38('0x77'),'message':_0x1db55c[_0x0c38('0x19')]()});}else{fs[_0x0c38('0x78')](_0x3f1e40,_0x57ea7e[_0x0c38('0x19')]()+'\x0a');}_0x57ea7e=[];}if(!(stats[_0x0c38('0x79')]%0xc8)){socket[_0x0c38('0x7a')](_0x0c38('0x7b')+_0x5035ca,stats);stats['errors']=[];}}if(stopped){logger[_0x0c38('0x64')](_0x0c38('0x7c'));_0x44b6a6[_0x0c38('0x7d')]();}}catch(_0x22f427){handleError(_0x530822[_0x0c38('0x68')][_0x4f0fda],{'code':_0x0c38('0x7e'),'message':_0x22f427[_0x0c38('0x44')]});logger['error']('step',_0x22f427['message']);}},'complete':function(){try{var _0x4dfd2f=[];var _0xccc22=[];var _0xb927c5='cm_contacts';if(_0x2fad85[_0x0c38('0x7f')]&&_0x2fad85[_0x0c38('0x7f')]['length']){_0xb927c5=_0x0c38('0x80')+_0x5035ca;_0x4dfd2f[_0x0c38('0x45')]('CREATE\x20TABLE\x20'+_0xb927c5+_0x0c38('0x81'));}tmp_campaigns='campaigns_'+_0x5035ca;tmp_voice_queues='voice_queues_'+_0x5035ca;_0xccc22[_0x0c38('0x45')](_0x0c38('0x82')+tmp_campaigns+_0x0c38('0x83'));_0xccc22[_0x0c38('0x45')](_0x0c38('0x82')+tmp_voice_queues+_0x0c38('0x83'));BPromise[_0x0c38('0x84')](_0xccc22,handleTZQuery)[_0x0c38('0x85')](function(_0x16280b){updateTzCampaigns(_0x2fad85[_0x0c38('0x22')])['then'](function(_0x35a2c5){updateTzVoiceQueues(_0x2fad85['ListId'])[_0x0c38('0x85')](function(_0x3670f1){var _0xd8fdd7=util['format'](_0x0c38('0x86'),_0x3f1e40,_0xb927c5,_0x194d55,_0x2fad85[_0x0c38('0x22')],_0x2fad85[_0x0c38('0x87')]||null,NOW,NOW);if(_[_0x0c38('0x59')](_0x244855['scheduledat'])){_0xd8fdd7+=_0x0c38('0x88');}_0x4dfd2f[_0x0c38('0x45')](_0xd8fdd7);if(_0x2fad85['duplicates']&&_0x2fad85[_0x0c38('0x7f')][_0x0c38('0x4f')]){_0x4dfd2f[_0x0c38('0x45')](insertCmContact(_0x2fad85[_0x0c38('0x22')],_0xb927c5,_0x2fad85[_0x0c38('0x7f')],_0x244855));_0x4dfd2f[_0x0c38('0x45')]('DROP\x20TABLE\x20'+_0xb927c5+';');}if(hasTZ){_0x4dfd2f[_0x0c38('0x45')](insertTzCmHopper(_0x2fad85[_0x0c38('0x22')],_0x0c38('0x54'),'voice_queues',_0x0c38('0x89'),_0x2fd42d,tmp_voice_queues));_0x4dfd2f[_0x0c38('0x45')](insertTzCmHopperBlack(_0x2fad85[_0x0c38('0x22')],_0x0c38('0x8a'),_0x0c38('0x53'),_0x0c38('0x89')));_0x4dfd2f[_0x0c38('0x45')](insertTzCmHopper(_0x2fad85[_0x0c38('0x22')],_0x0c38('0x8b'),_0x0c38('0x8c'),_0x0c38('0x8d'),_0x2fd42d,tmp_campaigns));_0x4dfd2f[_0x0c38('0x45')](insertTzCmHopperBlack(_0x2fad85[_0x0c38('0x22')],_0x0c38('0x8e'),'campaigns',_0x0c38('0x8d')));}else{_0x4dfd2f[_0x0c38('0x45')](insertCmHopper(_0x2fad85['ListId'],_0x0c38('0x54'),_0x0c38('0x53'),'VoiceQueueId',_0x2fd42d));_0x4dfd2f[_0x0c38('0x45')](insertCmHopperBlack(_0x2fad85[_0x0c38('0x22')],_0x0c38('0x8a'),'voice_queues',_0x0c38('0x89')));_0x4dfd2f[_0x0c38('0x45')](insertCmHopper(_0x2fad85['ListId'],_0x0c38('0x8b'),'campaigns',_0x0c38('0x8d'),_0x2fd42d));_0x4dfd2f['push'](insertCmHopperBlack(_0x2fad85[_0x0c38('0x22')],_0x0c38('0x8e'),_0x0c38('0x8c'),_0x0c38('0x8d')));}_0x4dfd2f['push'](_0x0c38('0x8f')+tmp_campaigns+';');_0x4dfd2f[_0x0c38('0x45')]('DROP\x20TABLE\x20'+tmp_voice_queues+';');BPromise[_0x0c38('0x84')](_0x4dfd2f,handleQuery)[_0x0c38('0x85')](function(_0x5aa36d){stats[_0x0c38('0x90')]=!![];stats[_0x0c38('0x91')]=_0x2fad85[_0x0c38('0x7f')]&&_0x2fad85['duplicates'][_0x0c38('0x4f')]?results[0x2]['affectedRows']:results[0x0][_0x0c38('0x91')];socket[_0x0c38('0x7a')](_0x0c38('0x7b')+_0x5035ca,stats);fs[_0x0c38('0x92')](_0x12671d);fs[_0x0c38('0x92')](_0x3f1e40);process['exit'](0x0);})['catch'](function(_0x107126){logger[_0x0c38('0x43')](_0x107126[_0x0c38('0x44')]);process[_0x0c38('0x93')](0x1);});});});});}catch(_0x5cea54){logger[_0x0c38('0x43')](_0x0c38('0x94'),_0x5cea54[_0x0c38('0x44')]);process[_0x0c38('0x93')](0x1);}},'error':function(_0x4a46ba,_0x44df3a,_0x407054,_0x37bf1f){throw new Error(_0x37bf1f);}});}function validate(){if(process[_0x0c38('0x95')]&&process[_0x0c38('0x95')][_0x0c38('0x4f')]<0x4){throw new Error(_0x0c38('0x96'));}var _0xa13076=path['join'](config[_0x0c38('0x61')],'server/files/tmp',process[_0x0c38('0x95')][0x2]);if(!fs[_0x0c38('0x97')](_0xa13076)){throw new Error(_0x0c38('0x98'));}var _0x3909ea={};try{_0x3909ea=JSON[_0x0c38('0x99')](process[_0x0c38('0x95')][0x3]);if(!_0x3909ea[_0x0c38('0x60')]){throw new Error(_0x0c38('0x9a'));}if(!_0x3909ea['binding'][_0x0c38('0x14')]){throw new Error(_0x0c38('0x9b'));}if(!_0x3909ea[_0x0c38('0x60')][_0x0c38('0x75')]){throw new Error(_0x0c38('0x9c'));}var _0x8fa046=0x0;if(_0x3909ea[_0x0c38('0x60')][_0x0c38('0x26')]){_0x8fa046=0x1;}if(!_0x3909ea[_0x0c38('0x22')]){throw new Error('ListId\x20is\x20mandatory');}}catch(_0x183673){throw new Error(_0x0c38('0x9d'));}var _0x4acf45=[];try{_0x4acf45=_[_0x0c38('0x9e')](JSON['parse'](process[_0x0c38('0x95')][0x4]),'id');}catch(_0x57cb93){logger[_0x0c38('0x64')](_0x0c38('0x9f'));}main(_0xa13076,_0x3909ea,_0x4acf45,_0x8fa046);}validate();process['on']('SIGINT',handleStop);process['on'](_0x0c38('0xa0'),handleUncaughtException);
\ No newline at end of file