// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0xd030=['DROP\x20TABLE\x20','voice_queues_has_cm_lists','voice_queues','VoiceQueueId','campaigns_has_cm_lists','campaigns','campaigns_has_cm_blacklists','CampaignId','each','then','affectedRows','unlink','complete','arguments\x20<filename>\x20<parameters>\x20<agents>','server/files/tmp','argv','existsSync','file\x20doesn\x27t\x20exists','binding\x20doesn\x27t\x20exists','firstName\x20is\x20mandatory','parse','No\x20agent\x20available','uncaughtException','path','papaparse','bluebird','moment','squel','../../../config/environment','../../../config/logger','import','localhost','select','field','phone','from','join','.id\x20=\x20','where','\x20=\x20','.dialCheckDuplicateType\x20IN\x20(','cm_contacts.phone','cm_contacts.scheduledat','cm_contacts.id','cm_contacts.createdAt','cm_contacts.updatedAt','cm_contacts.priority','cm_contacts.UserId','insert','into','cm_hopper','fromQuery','scheduledat','ListId','createdAt','updatedAt','priority','UserId','recallme','fields','cm_contacts','cm_contacts.ListId\x20=\x20','.CmListId\x20=\x20?','cm_contacts.phone\x20NOT\x20IN\x20(?)','\x22always\x22','\x22onlyIfOpen\x22','toString','cm_contacts.ListId','cm_hopper_black','.CmListId','ListId\x20=\x20?','\x20=\x20?','concat','keys','CompanyId',')\x20NOT\x20IN\x20?','id\x20IN\x20?','min_id','group','info','Received\x20SIGINT','message','exit','push','sequelize','spread','catch','main','stringify','send','binding','socket_timestamp','root','.csv','header','writeFileSync','createReadStream','data','rows','errors','hasOwnProperty','trim','isValid','scheduledat\x20wrong\x20format\x20(YYYY-MM-DD\x20HH:mm:ss)','isNaN','isNumber','includes','agent\x20not\x20exists','email','email\x20wrong\x20format','dateOfBirth','YYYY-MM-DD','dateOfBirth\x20wrong\x20format\x20(YYYY-MM-DD)','firstName','length','SystemRow','emit','Abort\x20parser','abort','SystemError','error','step','duplicates','cm_contacts_','CREATE\x20TABLE\x20','\x20LIKE\x20cm_contacts;','format'];(function(_0x3659f0,_0x52b677){var _0xb3cfe5=function(_0x47952c){while(--_0x47952c){_0x3659f0['push'](_0x3659f0['shift']());}};_0xb3cfe5(++_0x52b677);}(_0xd030,0x96));var _0x0d03=function(_0xf4ba3e,_0x35800d){_0xf4ba3e=_0xf4ba3e-0x0;var _0x117e4a=_0xd030[_0xf4ba3e];return _0x117e4a;};'use strict';var fs=require('fs');var path=require(_0x0d03('0x0'));var _=require('lodash');var Papa=require(_0x0d03('0x1'));var util=require('util');var BPromise=require(_0x0d03('0x2'));var moment=require(_0x0d03('0x3'));var squel=require(_0x0d03('0x4'));var db=require('../../../mysqldb')['db'];var config=require(_0x0d03('0x5'));var logger=require(_0x0d03('0x6'))(_0x0d03('0x7'));var socket=require('socket.io-emitter')({'host':_0x0d03('0x8'),'port':0x18eb});var stats={'finish':![],'errors':[],'rows':0x0,'affectedRows':0x0};var results=[];var stopped=![];var NOW=moment()['format']('YYYY-MM-DD\x20HH:mm:ss');function isEmail(_0x230c88){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'](_0x230c88);}function selectNotIn(_0x67ee25,_0x1fc0e9,_0x9380db,_0xdf2535,_0x1f8f5b){return squel[_0x0d03('0x9')]()[_0x0d03('0xa')](_0x0d03('0xb'))[_0x0d03('0xc')](_0xdf2535)[_0x0d03('0xd')](_0x1fc0e9,null,_0x1fc0e9+_0x0d03('0xe')+_0xdf2535+'.'+_0x9380db)[_0x0d03('0xf')](_0xdf2535+'.'+_0x9380db+_0x0d03('0x10')+_0x67ee25+'.'+_0x9380db)[_0x0d03('0xf')](_0x1fc0e9+_0x0d03('0x11')+_0x1f8f5b[_0x0d03('0xd')]()+')');}function insertCmHopper(_0x5c34d1,_0x42ef63,_0x1616f1,_0x1670fb,_0x390a16){var _0x2ded79=[_0x0d03('0x12'),_0x0d03('0x13'),_0x0d03('0x14'),'cm_contacts.ListId',_0x42ef63+'.'+_0x1670fb,_0x0d03('0x15'),_0x0d03('0x16'),_0x0d03('0x17'),_0x0d03('0x18'),'\x22'+_0x390a16+'\x22'];return squel[_0x0d03('0x19')]()[_0x0d03('0x1a')](_0x0d03('0x1b'))[_0x0d03('0x1c')]([_0x0d03('0xb'),_0x0d03('0x1d'),'ContactId',_0x0d03('0x1e'),_0x1670fb,_0x0d03('0x1f'),_0x0d03('0x20'),_0x0d03('0x21'),_0x0d03('0x22'),_0x0d03('0x23')],squel['select']()[_0x0d03('0x24')](_0x2ded79)[_0x0d03('0xc')](_0x42ef63)['join'](_0x0d03('0x25'),null,_0x0d03('0x26')+_0x42ef63+'.CmListId')[_0x0d03('0xd')](_0x1616f1,null,_0x1616f1+_0x0d03('0xe')+_0x42ef63+'.'+_0x1670fb)['where'](_0x42ef63+_0x0d03('0x27'),_0x5c34d1)[_0x0d03('0xf')]('cm_contacts.createdAt\x20=\x20?',NOW)[_0x0d03('0xf')](_0x0d03('0x28'),selectNotIn(_0x42ef63,_0x1616f1,_0x1670fb,'cm_hopper',[_0x0d03('0x29'),_0x0d03('0x2a')]))[_0x0d03('0xf')]('cm_contacts.phone\x20NOT\x20IN\x20(?)',selectNotIn(_0x42ef63,_0x1616f1,_0x1670fb,_0x0d03('0x1b'),['\x22always\x22'])))[_0x0d03('0x2b')]();}function insertCmHopperBlack(_0x2cd98b,_0x20b9f4,_0x48fc31,_0x1c5861){var _0x14fb62=[_0x0d03('0x12'),_0x0d03('0x14'),_0x0d03('0x2c'),_0x20b9f4+'.'+_0x1c5861,_0x0d03('0x15'),_0x0d03('0x16')];return squel[_0x0d03('0x19')]()[_0x0d03('0x1a')](_0x0d03('0x2d'))[_0x0d03('0x1c')]([_0x0d03('0xb'),'ContactId','ListId',_0x1c5861,_0x0d03('0x1f'),_0x0d03('0x20')],squel['select']()[_0x0d03('0x24')](_0x14fb62)[_0x0d03('0xc')](_0x20b9f4)[_0x0d03('0xd')](_0x0d03('0x25'),null,_0x0d03('0x26')+_0x20b9f4+_0x0d03('0x2e'))[_0x0d03('0xd')](_0x48fc31,null,_0x48fc31+_0x0d03('0xe')+_0x20b9f4+'.'+_0x1c5861)[_0x0d03('0xf')](_0x20b9f4+'.CmListId\x20=\x20?',_0x2cd98b)[_0x0d03('0xf')]('cm_contacts.createdAt\x20=\x20?',NOW)[_0x0d03('0xf')](_0x0d03('0x28'),squel[_0x0d03('0x9')]()[_0x0d03('0xa')]('phone')[_0x0d03('0xc')](_0x0d03('0x2d'))['where'](_0x0d03('0x2f'),_0x2cd98b)[_0x0d03('0xf')](_0x1c5861+_0x0d03('0x30'),_0x20b9f4+'.'+_0x1c5861)))[_0x0d03('0x2b')]();}function insertCmContact(_0x104324,_0x446fd1,_0x2d9e9f,_0x4e48aa){var _0x5f43f9=_[_0x0d03('0x31')](_[_0x0d03('0x32')](_0x4e48aa),[_0x0d03('0x1e'),_0x0d03('0x33'),_0x0d03('0x1f'),_0x0d03('0x20')]);return squel[_0x0d03('0x19')]()['into'](_0x0d03('0x25'))['fromQuery'](_0x5f43f9,squel[_0x0d03('0x9')]()[_0x0d03('0x24')](_0x5f43f9)['from'](_0x446fd1)['where']('('+_0x2d9e9f[_0x0d03('0xd')](',')+_0x0d03('0x34'),squel['select']()[_0x0d03('0x24')](_0x2d9e9f)['from'](_0x0d03('0x25'))[_0x0d03('0xf')](_0x0d03('0x2f'),_0x104324))['where'](_0x0d03('0x35'),squel[_0x0d03('0x9')]()[_0x0d03('0xa')]('MIN(id)',_0x0d03('0x36'))['from'](_0x446fd1)[_0x0d03('0x37')](_0x2d9e9f[_0x0d03('0xd')](','))))['toString']();}function handleStop(){logger[_0x0d03('0x38')](_0x0d03('0x39'));stopped=!![];}function handleUncaughtException(_0x1dffe5){logger['error'](_0x1dffe5[_0x0d03('0x3a')]);process[_0x0d03('0x3b')](0x1);}function handleError(_0x35b5a0,_0x19c674){stats['errors'][_0x0d03('0x3c')]({'name':_0x19c674['code'],'message':_0x19c674[_0x0d03('0x3a')],'row':_0x35b5a0});}function handleQuery(_0x3e95e1){logger[_0x0d03('0x38')](_0x3e95e1);return db[_0x0d03('0x3d')]['query'](_0x3e95e1)[_0x0d03('0x3e')](function(_0x1adc77){results[_0x0d03('0x3c')](_0x1adc77);})[_0x0d03('0x3f')](function(_0x4396ec){logger['error'](_0x4396ec[_0x0d03('0x3a')]);});}function main(_0x41768d,_0x4222cf,_0x3f1a2c,_0x29f258){logger['info'](_0x0d03('0x40'),_0x41768d,JSON[_0x0d03('0x41')](_0x4222cf));process[_0x0d03('0x42')]('start');var _0x23e734=_0x4222cf[_0x0d03('0x43')];var _0x57d0c2=_0x4222cf[_0x0d03('0x44')];var _0x20c250=path[_0x0d03('0xd')](config[_0x0d03('0x45')],'server/files/tmp',_0x57d0c2+_0x0d03('0x46'));var _0x1df698=_['keys'](_0x23e734)[_0x0d03('0xd')]();logger[_0x0d03('0x38')](_0x0d03('0x47'),_0x1df698);fs[_0x0d03('0x48')](_0x20c250,_0x1df698+'\x0a');Papa['parse'](fs[_0x0d03('0x49')](_0x41768d),{'header':!![],'skipEmptyLines':!![],'step':function(_0x341d93,_0x4978f6){try{for(var _0x5a0a8b=0x0,_0x239540=[];_0x5a0a8b<_0x341d93[_0x0d03('0x4a')]['length'];_0x5a0a8b++){stats[_0x0d03('0x4b')]+=0x1;if(_0x341d93[_0x0d03('0x4c')][_0x5a0a8b]){handleError(_0x341d93[_0x0d03('0x4a')][_0x5a0a8b],_0x341d93[_0x0d03('0x4c')][_0x5a0a8b]);}else{var _0xb16cc2=[];for(var _0x788370 in _0x23e734){if(_0x23e734[_0x0d03('0x4d')](_0x788370)){if(_0x341d93[_0x0d03('0x4a')][_0x5a0a8b][_0x23e734[_0x788370]]){var _0x2d32a4=_[_0x0d03('0x4e')](_0x341d93[_0x0d03('0x4a')][_0x5a0a8b][_0x23e734[_0x788370]]['replace'](/"/g,'\x27'));switch(_0x788370){case _0x0d03('0x1d'):var _0x1c1dec=moment(_0x2d32a4,'YYYY-MM-DD\x20HH:mm:ss',!![]);if(_0x1c1dec[_0x0d03('0x4f')]()){_0x239540[_0x0d03('0x3c')]('\x22'+_0x2d32a4+'\x22');}else{_0xb16cc2[_0x0d03('0x3c')](_0x0d03('0x50'));}break;case'priority':var _0x22c433=parseInt(_0x2d32a4);_0x2d32a4=_[_0x0d03('0x51')](_0x22c433)||_0x22c433<0x0||_0x22c433>0x4?_0x29f258?0x3:0x2:_0x22c433;_0x239540[_0x0d03('0x3c')]('\x22'+_0x2d32a4+'\x22');break;case _0x0d03('0x22'):var _0x50ecf6=parseInt(_0x2d32a4);if(_[_0x0d03('0x52')](_0x50ecf6)&&_[_0x0d03('0x53')](_0x3f1a2c,_0x50ecf6)){_0x239540[_0x0d03('0x3c')]('\x22'+_0x50ecf6+'\x22');}else{_0xb16cc2['push'](_0x0d03('0x54'));}break;case _0x0d03('0x55'):if(isEmail(_0x2d32a4)){_0x239540[_0x0d03('0x3c')]('\x22'+_0x2d32a4+'\x22');}else{_0xb16cc2['push'](_0x0d03('0x56'));}break;case _0x0d03('0x57'):var _0x1dd91e=moment(_0x2d32a4,_0x0d03('0x58'),!![]);if(_0x1dd91e[_0x0d03('0x4f')]()){_0x239540[_0x0d03('0x3c')]('\x22'+_0x2d32a4+'\x22');}else{_0xb16cc2[_0x0d03('0x3c')](_0x0d03('0x59'));}break;default:_0x239540[_0x0d03('0x3c')]('\x22'+_0x2d32a4+'\x22');}}else{switch(_0x788370){case _0x0d03('0x5a'):case'phone':_0xb16cc2['push'](_0x788370+'\x20not\x20specified');break;default:_0x239540[_0x0d03('0x3c')]('\x22\x22');}}}}if(_0xb16cc2[_0x0d03('0x5b')]){handleError(_0x341d93[_0x0d03('0x4a')][_0x5a0a8b],{'code':_0x0d03('0x5c'),'message':_0xb16cc2[_0x0d03('0xd')]()});}else{fs['appendFileSync'](_0x20c250,_0x239540['join']()+'\x0a');}_0x239540=[];}if(!(stats[_0x0d03('0x4b')]%0xc8)){socket[_0x0d03('0x5d')]('contact:import:'+_0x57d0c2,stats);stats[_0x0d03('0x4c')]=[];}}if(stopped){logger[_0x0d03('0x38')](_0x0d03('0x5e'));_0x4978f6[_0x0d03('0x5f')]();}}catch(_0x4847e6){handleError(_0x341d93['data'][_0x5a0a8b],{'code':_0x0d03('0x60'),'message':_0x4847e6[_0x0d03('0x3a')]});logger[_0x0d03('0x61')](_0x0d03('0x62'),_0x4847e6[_0x0d03('0x3a')]);}},'complete':function(){try{var _0x53171a=[];var _0x712f34='cm_contacts';if(_0x4222cf[_0x0d03('0x63')]&&_0x4222cf[_0x0d03('0x63')][_0x0d03('0x5b')]){_0x712f34=_0x0d03('0x64')+_0x57d0c2;_0x53171a['push'](_0x0d03('0x65')+_0x712f34+_0x0d03('0x66'));}var _0x2f7ed1=util[_0x0d03('0x67')]('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',_0x20c250,_0x712f34,_0x1df698,_0x4222cf['ListId'],_0x4222cf[_0x0d03('0x33')]||null,NOW,NOW);if(_['isNil'](_0x23e734['scheduledat'])){_0x2f7ed1+=',\x20scheduledAt\x20=\x20NOW()';}_0x53171a[_0x0d03('0x3c')](_0x2f7ed1);if(_0x4222cf[_0x0d03('0x63')]&&_0x4222cf[_0x0d03('0x63')][_0x0d03('0x5b')]){_0x53171a[_0x0d03('0x3c')](insertCmContact(_0x4222cf[_0x0d03('0x1e')],_0x712f34,_0x4222cf[_0x0d03('0x63')],_0x23e734));_0x53171a['push'](_0x0d03('0x68')+_0x712f34+';');}_0x53171a[_0x0d03('0x3c')](insertCmHopper(_0x4222cf[_0x0d03('0x1e')],_0x0d03('0x69'),_0x0d03('0x6a'),_0x0d03('0x6b'),_0x29f258));_0x53171a[_0x0d03('0x3c')](insertCmHopperBlack(_0x4222cf[_0x0d03('0x1e')],'voice_queues_has_cm_blacklists',_0x0d03('0x6a'),_0x0d03('0x6b')));_0x53171a['push'](insertCmHopper(_0x4222cf[_0x0d03('0x1e')],_0x0d03('0x6c'),_0x0d03('0x6d'),'CampaignId',_0x29f258));_0x53171a['push'](insertCmHopperBlack(_0x4222cf[_0x0d03('0x1e')],_0x0d03('0x6e'),_0x0d03('0x6d'),_0x0d03('0x6f')));BPromise[_0x0d03('0x70')](_0x53171a,handleQuery)[_0x0d03('0x71')](function(_0x2ddaa0){stats['finish']=!![];stats[_0x0d03('0x72')]=_0x4222cf[_0x0d03('0x63')]&&_0x4222cf['duplicates'][_0x0d03('0x5b')]?results[0x2]['affectedRows']:results[0x0][_0x0d03('0x72')];socket[_0x0d03('0x5d')]('contact:import:'+_0x57d0c2,stats);fs[_0x0d03('0x73')](_0x41768d);fs[_0x0d03('0x73')](_0x20c250);process['exit'](0x0);})['catch'](function(_0x23281f){logger['error'](_0x23281f['message']);process['exit'](0x1);});}catch(_0x1e3ea3){logger[_0x0d03('0x61')](_0x0d03('0x74'),_0x1e3ea3[_0x0d03('0x3a')]);process[_0x0d03('0x3b')](0x1);}},'error':function(_0x13a39f,_0x589dd0,_0x2e20f8,_0x29323c){throw new Error(_0x29323c);}});}function validate(){if(process['argv']&&process['argv'][_0x0d03('0x5b')]<0x4){throw new Error(_0x0d03('0x75'));}var _0x1e3618=path['join'](config['root'],_0x0d03('0x76'),process[_0x0d03('0x77')][0x2]);if(!fs[_0x0d03('0x78')](_0x1e3618)){throw new Error(_0x0d03('0x79'));}var _0x126632={};try{_0x126632=JSON['parse'](process[_0x0d03('0x77')][0x3]);if(!_0x126632['binding']){throw new Error(_0x0d03('0x7a'));}if(!_0x126632[_0x0d03('0x43')][_0x0d03('0xb')]){throw new Error('phone\x20is\x20mandatory');}if(!_0x126632[_0x0d03('0x43')][_0x0d03('0x5a')]){throw new Error(_0x0d03('0x7b'));}var _0x2d82cc=0x0;if(_0x126632['binding'][_0x0d03('0x22')]){_0x2d82cc=0x1;}if(!_0x126632['ListId']){throw new Error('ListId\x20is\x20mandatory');}}catch(_0x153fe9){throw new Error('body\x20id\x20mandatory');}var _0x1471d8=[];try{_0x1471d8=_['map'](JSON[_0x0d03('0x7c')](process['argv'][0x4]),'id');}catch(_0x2a067e){logger[_0x0d03('0x38')](_0x0d03('0x7d'));}main(_0x1e3618,_0x126632,_0x1471d8,_0x2d82cc);}validate();process['on']('SIGINT',handleStop);process['on'](_0x0d03('0x7e'),handleUncaughtException);
\ No newline at end of file
+var _0xd046=['agent\x20not\x20exists','email','email\x20wrong\x20format','dateOfBirth','dateOfBirth\x20wrong\x20format\x20(YYYY-MM-DD)','firstName','\x20not\x20specified','SystemRow','appendFileSync','rows','emit','contact:import:','Abort\x20parser','abort','SystemError','duplicates','cm_contacts_','CREATE\x20TABLE\x20','\x20LIKE\x20cm_contacts;','format','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()','voice_queues_has_cm_lists','voice_queues','VoiceQueueId','campaigns_has_cm_lists','campaigns','CampaignId','campaigns_has_cm_blacklists','each','then','affectedRows','unlink','exit','complete','argv','arguments\x20<filename>\x20<parameters>\x20<agents>','existsSync','parse','binding\x20doesn\x27t\x20exists','phone\x20is\x20mandatory','firstName\x20is\x20mandatory','body\x20id\x20mandatory','map','path','lodash','papaparse','bluebird','moment','../../../mysqldb','../../../config/environment','../../../config/logger','import','socket.io-emitter','localhost','YYYY-MM-DD\x20HH:mm:ss','test','select','field','phone','from','join','.id\x20=\x20','.dialCheckDuplicateType\x20IN\x20(','cm_contacts.phone','cm_contacts.scheduledat','cm_contacts.ListId','cm_contacts.createdAt','cm_contacts.updatedAt','cm_contacts.priority','cm_contacts.UserId','insert','cm_hopper','fromQuery','scheduledat','ContactId','ListId','createdAt','updatedAt','priority','UserId','recallme','fields','cm_contacts.ListId\x20=\x20','where','.CmListId\x20=\x20?','cm_contacts.createdAt\x20=\x20?','cm_contacts.phone\x20NOT\x20IN\x20(?)','\x22always\x22','\x22onlyIfOpen\x22','toString','into','cm_hopper_black','cm_contacts','ListId\x20=\x20?','concat','keys','CompanyId','id\x20IN\x20?','MIN(id)','min_id','group','info','error','message','push','code','sequelize','query','spread','catch','main','stringify','send','start','binding','socket_timestamp','root','server/files/tmp','writeFileSync','createReadStream','data','length','errors','hasOwnProperty','trim','replace','isValid','scheduledat\x20wrong\x20format\x20(YYYY-MM-DD\x20HH:mm:ss)','isNaN','isNumber','includes'];(function(_0x32528e,_0x171692){var _0x45a77d=function(_0x41fba9){while(--_0x41fba9){_0x32528e['push'](_0x32528e['shift']());}};_0x45a77d(++_0x171692);}(_0xd046,0x1bc));var _0x6d04=function(_0x33416e,_0x1d8f89){_0x33416e=_0x33416e-0x0;var _0x4e3837=_0xd046[_0x33416e];return _0x4e3837;};'use strict';var fs=require('fs');var path=require(_0x6d04('0x0'));var _=require(_0x6d04('0x1'));var Papa=require(_0x6d04('0x2'));var util=require('util');var BPromise=require(_0x6d04('0x3'));var moment=require(_0x6d04('0x4'));var squel=require('squel');var db=require(_0x6d04('0x5'))['db'];var config=require(_0x6d04('0x6'));var logger=require(_0x6d04('0x7'))(_0x6d04('0x8'));var socket=require(_0x6d04('0x9'))({'host':_0x6d04('0xa'),'port':0x18eb});var stats={'finish':![],'errors':[],'rows':0x0,'affectedRows':0x0};var results=[];var stopped=![];var NOW=moment()['format'](_0x6d04('0xb'));function isEmail(_0x5a461b){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))*$/[_0x6d04('0xc')](_0x5a461b);}function selectNotIn(_0x2ee693,_0x41bdb5,_0x13988e,_0x127445,_0x4251f4){return squel[_0x6d04('0xd')]()[_0x6d04('0xe')](_0x6d04('0xf'))[_0x6d04('0x10')](_0x127445)[_0x6d04('0x11')](_0x41bdb5,null,_0x41bdb5+_0x6d04('0x12')+_0x127445+'.'+_0x13988e)['where'](_0x127445+'.'+_0x13988e+'\x20=\x20'+_0x2ee693+'.'+_0x13988e)['where'](_0x41bdb5+_0x6d04('0x13')+_0x4251f4[_0x6d04('0x11')]()+')');}function insertCmHopper(_0x350b0f,_0x4c5b30,_0x30bcc3,_0x12df72,_0x56e2cd){var _0x32426d=[_0x6d04('0x14'),_0x6d04('0x15'),'cm_contacts.id',_0x6d04('0x16'),_0x4c5b30+'.'+_0x12df72,_0x6d04('0x17'),_0x6d04('0x18'),_0x6d04('0x19'),_0x6d04('0x1a'),'\x22'+_0x56e2cd+'\x22'];return squel[_0x6d04('0x1b')]()['into'](_0x6d04('0x1c'))[_0x6d04('0x1d')]([_0x6d04('0xf'),_0x6d04('0x1e'),_0x6d04('0x1f'),_0x6d04('0x20'),_0x12df72,_0x6d04('0x21'),_0x6d04('0x22'),_0x6d04('0x23'),_0x6d04('0x24'),_0x6d04('0x25')],squel[_0x6d04('0xd')]()[_0x6d04('0x26')](_0x32426d)['from'](_0x4c5b30)[_0x6d04('0x11')]('cm_contacts',null,_0x6d04('0x27')+_0x4c5b30+'.CmListId')[_0x6d04('0x11')](_0x30bcc3,null,_0x30bcc3+_0x6d04('0x12')+_0x4c5b30+'.'+_0x12df72)[_0x6d04('0x28')](_0x4c5b30+_0x6d04('0x29'),_0x350b0f)['where'](_0x6d04('0x2a'),NOW)['where'](_0x6d04('0x2b'),selectNotIn(_0x4c5b30,_0x30bcc3,_0x12df72,_0x6d04('0x1c'),[_0x6d04('0x2c'),_0x6d04('0x2d')]))[_0x6d04('0x28')](_0x6d04('0x2b'),selectNotIn(_0x4c5b30,_0x30bcc3,_0x12df72,_0x6d04('0x1c'),[_0x6d04('0x2c')])))[_0x6d04('0x2e')]();}function insertCmHopperBlack(_0x5ffcdb,_0x536962,_0x45f9f2,_0xb3c9f0){var _0x1a1767=[_0x6d04('0x14'),'cm_contacts.id',_0x6d04('0x16'),_0x536962+'.'+_0xb3c9f0,_0x6d04('0x17'),_0x6d04('0x18')];return squel[_0x6d04('0x1b')]()[_0x6d04('0x2f')](_0x6d04('0x30'))[_0x6d04('0x1d')](['phone',_0x6d04('0x1f'),_0x6d04('0x20'),_0xb3c9f0,_0x6d04('0x21'),_0x6d04('0x22')],squel['select']()[_0x6d04('0x26')](_0x1a1767)[_0x6d04('0x10')](_0x536962)[_0x6d04('0x11')](_0x6d04('0x31'),null,_0x6d04('0x27')+_0x536962+'.CmListId')['join'](_0x45f9f2,null,_0x45f9f2+_0x6d04('0x12')+_0x536962+'.'+_0xb3c9f0)['where'](_0x536962+_0x6d04('0x29'),_0x5ffcdb)['where'](_0x6d04('0x2a'),NOW)[_0x6d04('0x28')](_0x6d04('0x2b'),squel['select']()[_0x6d04('0xe')](_0x6d04('0xf'))['from']('cm_hopper_black')[_0x6d04('0x28')](_0x6d04('0x32'),_0x5ffcdb)[_0x6d04('0x28')](_0xb3c9f0+'\x20=\x20?',_0x536962+'.'+_0xb3c9f0)))['toString']();}function insertCmContact(_0xe81b80,_0xcfc955,_0x34876b,_0x2969e4){var _0x3eb4be=_[_0x6d04('0x33')](_[_0x6d04('0x34')](_0x2969e4),[_0x6d04('0x20'),_0x6d04('0x35'),_0x6d04('0x21'),'updatedAt']);return squel[_0x6d04('0x1b')]()[_0x6d04('0x2f')](_0x6d04('0x31'))[_0x6d04('0x1d')](_0x3eb4be,squel[_0x6d04('0xd')]()['fields'](_0x3eb4be)[_0x6d04('0x10')](_0xcfc955)[_0x6d04('0x28')]('('+_0x34876b['join'](',')+')\x20NOT\x20IN\x20?',squel['select']()[_0x6d04('0x26')](_0x34876b)[_0x6d04('0x10')]('cm_contacts')['where'](_0x6d04('0x32'),_0xe81b80))[_0x6d04('0x28')](_0x6d04('0x36'),squel['select']()[_0x6d04('0xe')](_0x6d04('0x37'),_0x6d04('0x38'))[_0x6d04('0x10')](_0xcfc955)[_0x6d04('0x39')](_0x34876b[_0x6d04('0x11')](','))))[_0x6d04('0x2e')]();}function handleStop(){logger[_0x6d04('0x3a')]('Received\x20SIGINT');stopped=!![];}function handleUncaughtException(_0x596660){logger[_0x6d04('0x3b')](_0x596660[_0x6d04('0x3c')]);process['exit'](0x1);}function handleError(_0x342921,_0x218fe2){stats['errors'][_0x6d04('0x3d')]({'name':_0x218fe2[_0x6d04('0x3e')],'message':_0x218fe2[_0x6d04('0x3c')],'row':_0x342921});}function handleQuery(_0x24f1dc){logger[_0x6d04('0x3a')](_0x24f1dc);return db[_0x6d04('0x3f')][_0x6d04('0x40')](_0x24f1dc)[_0x6d04('0x41')](function(_0x5ae791){results['push'](_0x5ae791);})[_0x6d04('0x42')](function(_0x2f0de9){logger[_0x6d04('0x3b')](_0x2f0de9[_0x6d04('0x3c')]);});}function main(_0x1d9775,_0x3a28b2,_0x1f62ea,_0x2417a4){logger[_0x6d04('0x3a')](_0x6d04('0x43'),_0x1d9775,JSON[_0x6d04('0x44')](_0x3a28b2));process[_0x6d04('0x45')](_0x6d04('0x46'));var _0x4320c9=_0x3a28b2[_0x6d04('0x47')];var _0x2d3970=_0x3a28b2[_0x6d04('0x48')];var _0x353b75=path[_0x6d04('0x11')](config[_0x6d04('0x49')],_0x6d04('0x4a'),_0x2d3970+'.csv');var _0x38a260=_[_0x6d04('0x34')](_0x4320c9)[_0x6d04('0x11')]();logger[_0x6d04('0x3a')]('header',_0x38a260);fs[_0x6d04('0x4b')](_0x353b75,_0x38a260+'\x0a');Papa['parse'](fs[_0x6d04('0x4c')](_0x1d9775),{'header':!![],'skipEmptyLines':!![],'step':function(_0x55cbed,_0x214ae0){try{for(var _0x28fc42=0x0,_0x18c187=[];_0x28fc42<_0x55cbed[_0x6d04('0x4d')][_0x6d04('0x4e')];_0x28fc42++){stats['rows']+=0x1;if(_0x55cbed[_0x6d04('0x4f')][_0x28fc42]){handleError(_0x55cbed[_0x6d04('0x4d')][_0x28fc42],_0x55cbed[_0x6d04('0x4f')][_0x28fc42]);}else{var _0x36923b=[];for(var _0x1de79b in _0x4320c9){if(_0x4320c9[_0x6d04('0x50')](_0x1de79b)){if(_0x55cbed['data'][_0x28fc42][_0x4320c9[_0x1de79b]]){var _0x3f51ad=_[_0x6d04('0x51')](_0x55cbed['data'][_0x28fc42][_0x4320c9[_0x1de79b]][_0x6d04('0x52')](/"/g,'\x27'));switch(_0x1de79b){case _0x6d04('0x1e'):var _0x61e12=moment(_0x3f51ad,'YYYY-MM-DD\x20HH:mm:ss',!![]);if(_0x61e12[_0x6d04('0x53')]()){_0x18c187[_0x6d04('0x3d')]('\x22'+_0x3f51ad+'\x22');}else{_0x36923b[_0x6d04('0x3d')](_0x6d04('0x54'));}break;case _0x6d04('0x23'):var _0x17ddda=parseInt(_0x3f51ad);_0x3f51ad=_[_0x6d04('0x55')](_0x17ddda)||_0x17ddda<0x0||_0x17ddda>0x4?_0x2417a4?0x3:0x2:_0x17ddda;_0x18c187[_0x6d04('0x3d')]('\x22'+_0x3f51ad+'\x22');break;case _0x6d04('0x24'):var _0x277631=parseInt(_0x3f51ad);if(_[_0x6d04('0x56')](_0x277631)&&_[_0x6d04('0x57')](_0x1f62ea,_0x277631)){_0x18c187['push']('\x22'+_0x277631+'\x22');}else{_0x36923b[_0x6d04('0x3d')](_0x6d04('0x58'));}break;case _0x6d04('0x59'):if(isEmail(_0x3f51ad)){_0x18c187[_0x6d04('0x3d')]('\x22'+_0x3f51ad+'\x22');}else{_0x36923b[_0x6d04('0x3d')](_0x6d04('0x5a'));}break;case _0x6d04('0x5b'):var _0x2c5c77=moment(_0x3f51ad,'YYYY-MM-DD',!![]);if(_0x2c5c77[_0x6d04('0x53')]()){_0x18c187['push']('\x22'+_0x3f51ad+'\x22');}else{_0x36923b['push'](_0x6d04('0x5c'));}break;default:_0x18c187[_0x6d04('0x3d')]('\x22'+_0x3f51ad+'\x22');}}else{switch(_0x1de79b){case _0x6d04('0x5d'):case'phone':_0x36923b[_0x6d04('0x3d')](_0x1de79b+_0x6d04('0x5e'));break;default:_0x18c187[_0x6d04('0x3d')]('\x22\x22');}}}}if(_0x36923b[_0x6d04('0x4e')]){handleError(_0x55cbed[_0x6d04('0x4d')][_0x28fc42],{'code':_0x6d04('0x5f'),'message':_0x36923b[_0x6d04('0x11')]()});}else{fs[_0x6d04('0x60')](_0x353b75,_0x18c187[_0x6d04('0x11')]()+'\x0a');}_0x18c187=[];}if(!(stats[_0x6d04('0x61')]%0xc8)){socket[_0x6d04('0x62')](_0x6d04('0x63')+_0x2d3970,stats);stats[_0x6d04('0x4f')]=[];}}if(stopped){logger[_0x6d04('0x3a')](_0x6d04('0x64'));_0x214ae0[_0x6d04('0x65')]();}}catch(_0x234508){handleError(_0x55cbed[_0x6d04('0x4d')][_0x28fc42],{'code':_0x6d04('0x66'),'message':_0x234508[_0x6d04('0x3c')]});logger['error']('step',_0x234508[_0x6d04('0x3c')]);}},'complete':function(){try{var _0x3626f5=[];var _0x44bf5c=_0x6d04('0x31');if(_0x3a28b2[_0x6d04('0x67')]&&_0x3a28b2[_0x6d04('0x67')][_0x6d04('0x4e')]){_0x44bf5c=_0x6d04('0x68')+_0x2d3970;_0x3626f5[_0x6d04('0x3d')](_0x6d04('0x69')+_0x44bf5c+_0x6d04('0x6a'));}var _0x502dfe=util[_0x6d04('0x6b')](_0x6d04('0x6c'),_0x353b75,_0x44bf5c,_0x38a260,_0x3a28b2[_0x6d04('0x20')],_0x3a28b2['CompanyId']||null,NOW,NOW);if(_[_0x6d04('0x6d')](_0x4320c9[_0x6d04('0x1e')])){_0x502dfe+=_0x6d04('0x6e');}_0x3626f5[_0x6d04('0x3d')](_0x502dfe);if(_0x3a28b2[_0x6d04('0x67')]&&_0x3a28b2[_0x6d04('0x67')][_0x6d04('0x4e')]){_0x3626f5[_0x6d04('0x3d')](insertCmContact(_0x3a28b2[_0x6d04('0x20')],_0x44bf5c,_0x3a28b2[_0x6d04('0x67')],_0x4320c9));_0x3626f5['push']('DROP\x20TABLE\x20'+_0x44bf5c+';');}_0x3626f5[_0x6d04('0x3d')](insertCmHopper(_0x3a28b2[_0x6d04('0x20')],_0x6d04('0x6f'),_0x6d04('0x70'),_0x6d04('0x71'),_0x2417a4));_0x3626f5[_0x6d04('0x3d')](insertCmHopperBlack(_0x3a28b2[_0x6d04('0x20')],'voice_queues_has_cm_blacklists',_0x6d04('0x70'),_0x6d04('0x71')));_0x3626f5[_0x6d04('0x3d')](insertCmHopper(_0x3a28b2[_0x6d04('0x20')],_0x6d04('0x72'),_0x6d04('0x73'),_0x6d04('0x74'),_0x2417a4));_0x3626f5[_0x6d04('0x3d')](insertCmHopperBlack(_0x3a28b2[_0x6d04('0x20')],_0x6d04('0x75'),'campaigns',_0x6d04('0x74')));BPromise[_0x6d04('0x76')](_0x3626f5,handleQuery)[_0x6d04('0x77')](function(_0x473112){stats['finish']=!![];stats['affectedRows']=_0x3a28b2[_0x6d04('0x67')]&&_0x3a28b2[_0x6d04('0x67')][_0x6d04('0x4e')]?results[0x2][_0x6d04('0x78')]:results[0x0]['affectedRows'];socket[_0x6d04('0x62')](_0x6d04('0x63')+_0x2d3970,stats);fs[_0x6d04('0x79')](_0x1d9775);fs['unlink'](_0x353b75);process[_0x6d04('0x7a')](0x0);})[_0x6d04('0x42')](function(_0x2c10ec){logger[_0x6d04('0x3b')](_0x2c10ec[_0x6d04('0x3c')]);process[_0x6d04('0x7a')](0x1);});}catch(_0x460645){logger[_0x6d04('0x3b')](_0x6d04('0x7b'),_0x460645[_0x6d04('0x3c')]);process[_0x6d04('0x7a')](0x1);}},'error':function(_0x4746d0,_0x50b54c,_0x3c30ac,_0x26dcae){throw new Error(_0x26dcae);}});}function validate(){if(process[_0x6d04('0x7c')]&&process[_0x6d04('0x7c')]['length']<0x4){throw new Error(_0x6d04('0x7d'));}var _0x2e4cb1=path['join'](config['root'],_0x6d04('0x4a'),process[_0x6d04('0x7c')][0x2]);if(!fs[_0x6d04('0x7e')](_0x2e4cb1)){throw new Error('file\x20doesn\x27t\x20exists');}var _0x23fc6d={};try{_0x23fc6d=JSON[_0x6d04('0x7f')](process[_0x6d04('0x7c')][0x3]);if(!_0x23fc6d['binding']){throw new Error(_0x6d04('0x80'));}if(!_0x23fc6d[_0x6d04('0x47')]['phone']){throw new Error(_0x6d04('0x81'));}if(!_0x23fc6d[_0x6d04('0x47')][_0x6d04('0x5d')]){throw new Error(_0x6d04('0x82'));}var _0x6adfec=0x0;if(_0x23fc6d[_0x6d04('0x47')][_0x6d04('0x24')]){_0x6adfec=0x1;}if(!_0x23fc6d['ListId']){throw new Error('ListId\x20is\x20mandatory');}}catch(_0x360ac8){throw new Error(_0x6d04('0x83'));}var _0x3588c9=[];try{_0x3588c9=_[_0x6d04('0x84')](JSON[_0x6d04('0x7f')](process['argv'][0x4]),'id');}catch(_0xeb90ad){logger[_0x6d04('0x3a')]('No\x20agent\x20available');}main(_0x2e4cb1,_0x23fc6d,_0x3588c9,_0x6adfec);}validate();process['on']('SIGINT',handleStop);process['on']('uncaughtException',handleUncaughtException);
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff