18 var _0x2284=['campaigns_has_cm_lists','campaigns','CampaignId','campaigns_has_cm_blacklists','each','then','finish','affectedRows','contact:import:','unlink','exit','complete','argv','arguments\x20<filename>\x20<parameters>\x20<agents>','file\x20doesn\x27t\x20exists','binding\x20doesn\x27t\x20exists','binding','firstName\x20is\x20mandatory','ListId\x20is\x20mandatory','body\x20id\x20mandatory','map','No\x20agent\x20available','uncaughtException','path','lodash','papaparse','util','squel','ioredis','../../../mysqldb','../../../config/logger','import','redis','defaults','localhost','socket.io-emitter','format','YYYY-MM-DD\x20HH:mm:ss','test','select','field','from','join','.id\x20=\x20','where','\x20=\x20','cm_contacts.phone','cm_contacts.scheduledat','cm_contacts.ListId','cm_contacts.createdAt','cm_contacts.updatedAt','cm_contacts.priority','insert','cm_hopper','fromQuery','phone','ContactId','createdAt','updatedAt','priority','UserId','recallme','cm_contacts','.CmListId','.CmListId\x20=\x20?','cm_contacts.createdAt\x20=\x20?','cm_contacts.phone\x20NOT\x20IN\x20(?)','\x22onlyIfOpen\x22','\x22always\x22','toString','cm_contacts.id','into','cm_hopper_black','ListId','fields','cm_contacts.ListId\x20=\x20','\x20=\x20?','concat','keys','CompanyId',')\x20NOT\x20IN\x20?','ListId\x20=\x20?','id\x20IN\x20?','MIN(id)','min_id','group','error','errors','push','info','sequelize','query','spread','catch','stringify','send','start','socket_timestamp','root','server/files/tmp','.csv','header','writeFileSync','parse','createReadStream','data','length','rows','hasOwnProperty','trim','scheduledat','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','firstName','\x20not\x20specified','SystemRow','emit','Abort\x20parser','SystemError','message','step','duplicates','cm_contacts_','CREATE\x20TABLE\x20','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()','DROP\x20TABLE\x20','voice_queues_has_cm_lists','voice_queues','VoiceQueueId'];(function(_0x249565,_0x2a026a){var _0x43dee8=function(_0x15a1ab){while(--_0x15a1ab){_0x249565['push'](_0x249565['shift']());}};_0x43dee8(++_0x2a026a);}(_0x2284,0x12d));var _0x4228=function(_0x4966c3,_0x58da94){_0x4966c3=_0x4966c3-0x0;var _0x5e8d59=_0x2284[_0x4966c3];return _0x5e8d59;};'use strict';var fs=require('fs');var path=require(_0x4228('0x0'));var _=require(_0x4228('0x1'));var Papa=require(_0x4228('0x2'));var util=require(_0x4228('0x3'));var BPromise=require('bluebird');var moment=require('moment');var squel=require(_0x4228('0x4'));var Redis=require(_0x4228('0x5'));var db=require(_0x4228('0x6'))['db'];var config=require('../../../config/environment');var logger=require(_0x4228('0x7'))(_0x4228('0x8'));config[_0x4228('0x9')]=_[_0x4228('0xa')](config[_0x4228('0x9')],{'host':_0x4228('0xb'),'port':0x18eb});var socket=require(_0x4228('0xc'))(new Redis(config[_0x4228('0x9')]));var stats={'finish':![],'errors':[],'rows':0x0,'affectedRows':0x0};var results=[];var stopped=![];var NOW=moment()[_0x4228('0xd')](_0x4228('0xe'));function isEmail(_0x3c6009){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))*$/[_0x4228('0xf')](_0x3c6009);}function selectNotIn(_0x429332,_0x779622,_0x28b9be,_0x138c39,_0x4d265a){return squel[_0x4228('0x10')]()[_0x4228('0x11')]('phone')[_0x4228('0x12')](_0x138c39)[_0x4228('0x13')](_0x779622,null,_0x779622+_0x4228('0x14')+_0x138c39+'.'+_0x28b9be)[_0x4228('0x15')](_0x138c39+'.'+_0x28b9be+_0x4228('0x16')+_0x429332+'.'+_0x28b9be)[_0x4228('0x15')](_0x779622+'.dialCheckDuplicateType\x20IN\x20('+_0x4d265a[_0x4228('0x13')]()+')');}function insertCmHopper(_0x539c67,_0xce1ed6,_0x3631e2,_0x1aecc1,_0x4497a8){var _0x173e37=[_0x4228('0x17'),_0x4228('0x18'),'cm_contacts.id',_0x4228('0x19'),_0xce1ed6+'.'+_0x1aecc1,_0x4228('0x1a'),_0x4228('0x1b'),_0x4228('0x1c'),'cm_contacts.UserId','\x22'+_0x4497a8+'\x22'];return squel[_0x4228('0x1d')]()['into'](_0x4228('0x1e'))[_0x4228('0x1f')]([_0x4228('0x20'),'scheduledat',_0x4228('0x21'),'ListId',_0x1aecc1,_0x4228('0x22'),_0x4228('0x23'),_0x4228('0x24'),_0x4228('0x25'),_0x4228('0x26')],squel[_0x4228('0x10')]()['fields'](_0x173e37)[_0x4228('0x12')](_0xce1ed6)[_0x4228('0x13')](_0x4228('0x27'),null,'cm_contacts.ListId\x20=\x20'+_0xce1ed6+_0x4228('0x28'))[_0x4228('0x13')](_0x3631e2,null,_0x3631e2+_0x4228('0x14')+_0xce1ed6+'.'+_0x1aecc1)[_0x4228('0x15')](_0xce1ed6+_0x4228('0x29'),_0x539c67)['where'](_0x4228('0x2a'),NOW)[_0x4228('0x15')](_0x4228('0x2b'),selectNotIn(_0xce1ed6,_0x3631e2,_0x1aecc1,'cm_hopper',['\x22always\x22',_0x4228('0x2c')]))[_0x4228('0x15')](_0x4228('0x2b'),selectNotIn(_0xce1ed6,_0x3631e2,_0x1aecc1,_0x4228('0x1e'),[_0x4228('0x2d')])))[_0x4228('0x2e')]();}function insertCmHopperBlack(_0x3e8e7c,_0x3fc4ef,_0x35e2fd,_0x459e88){var _0x3db471=['cm_contacts.phone',_0x4228('0x2f'),_0x4228('0x19'),_0x3fc4ef+'.'+_0x459e88,_0x4228('0x1a'),_0x4228('0x1b')];return squel[_0x4228('0x1d')]()[_0x4228('0x30')](_0x4228('0x31'))['fromQuery'](['phone',_0x4228('0x21'),_0x4228('0x32'),_0x459e88,_0x4228('0x22'),_0x4228('0x23')],squel[_0x4228('0x10')]()[_0x4228('0x33')](_0x3db471)['from'](_0x3fc4ef)[_0x4228('0x13')]('cm_contacts',null,_0x4228('0x34')+_0x3fc4ef+_0x4228('0x28'))[_0x4228('0x13')](_0x35e2fd,null,_0x35e2fd+_0x4228('0x14')+_0x3fc4ef+'.'+_0x459e88)[_0x4228('0x15')](_0x3fc4ef+'.CmListId\x20=\x20?',_0x3e8e7c)[_0x4228('0x15')](_0x4228('0x2a'),NOW)[_0x4228('0x15')](_0x4228('0x2b'),squel['select']()['field'](_0x4228('0x20'))[_0x4228('0x12')](_0x4228('0x31'))['where']('ListId\x20=\x20?',_0x3e8e7c)[_0x4228('0x15')](_0x459e88+_0x4228('0x35'),_0x3fc4ef+'.'+_0x459e88)))['toString']();}function insertCmContact(_0xd553f2,_0xb4991b,_0x13eed2,_0x15aaa9){var _0x2bb1e2=_[_0x4228('0x36')](_[_0x4228('0x37')](_0x15aaa9),[_0x4228('0x32'),_0x4228('0x38'),_0x4228('0x22'),_0x4228('0x23')]);return squel[_0x4228('0x1d')]()['into'](_0x4228('0x27'))[_0x4228('0x1f')](_0x2bb1e2,squel['select']()[_0x4228('0x33')](_0x2bb1e2)['from'](_0xb4991b)[_0x4228('0x15')]('('+_0x13eed2[_0x4228('0x13')](',')+_0x4228('0x39'),squel[_0x4228('0x10')]()['fields'](_0x13eed2)[_0x4228('0x12')](_0x4228('0x27'))[_0x4228('0x15')](_0x4228('0x3a'),_0xd553f2)[_0x4228('0x15')]('deletedAt\x20IS\x20NULL'))[_0x4228('0x15')](_0x4228('0x3b'),squel['select']()[_0x4228('0x11')](_0x4228('0x3c'),_0x4228('0x3d'))['from'](_0xb4991b)[_0x4228('0x3e')](_0x13eed2[_0x4228('0x13')](','))))[_0x4228('0x2e')]();}function handleStop(){logger['info']('Received\x20SIGINT');stopped=!![];}function handleUncaughtException(_0x446999){logger[_0x4228('0x3f')](_0x446999['message']);process['exit'](0x1);}function handleError(_0x466536,_0x4ac138){stats[_0x4228('0x40')][_0x4228('0x41')]({'name':_0x4ac138['code'],'message':_0x4ac138['message'],'row':_0x466536});}function handleQuery(_0x1c8570){logger[_0x4228('0x42')](_0x1c8570);return db[_0x4228('0x43')][_0x4228('0x44')](_0x1c8570)[_0x4228('0x45')](function(_0x5d36a8){results['push'](_0x5d36a8);})[_0x4228('0x46')](function(_0x133021){logger['error'](_0x133021['message']);});}function main(_0x1f1ac3,_0x45b5a0,_0x34c513,_0xa019b7){logger[_0x4228('0x42')]('main',_0x1f1ac3,JSON[_0x4228('0x47')](_0x45b5a0));process[_0x4228('0x48')](_0x4228('0x49'));var _0x48735d=_0x45b5a0['binding'];var _0x2bf99f=_0x45b5a0[_0x4228('0x4a')];var _0x55851e=path[_0x4228('0x13')](config[_0x4228('0x4b')],_0x4228('0x4c'),_0x2bf99f+_0x4228('0x4d'));var _0x2c7779=_[_0x4228('0x37')](_0x48735d)[_0x4228('0x13')]();logger['info'](_0x4228('0x4e'),_0x2c7779);fs[_0x4228('0x4f')](_0x55851e,_0x2c7779+'\x0a');Papa[_0x4228('0x50')](fs[_0x4228('0x51')](_0x1f1ac3),{'header':!![],'skipEmptyLines':!![],'step':function(_0x1f72f9,_0x3bf8ed){try{for(var _0x1c441f=0x0,_0x1753fd=[];_0x1c441f<_0x1f72f9[_0x4228('0x52')][_0x4228('0x53')];_0x1c441f++){stats[_0x4228('0x54')]+=0x1;if(_0x1f72f9[_0x4228('0x40')][_0x1c441f]){handleError(_0x1f72f9[_0x4228('0x52')][_0x1c441f],_0x1f72f9[_0x4228('0x40')][_0x1c441f]);}else{var _0x510710=[];for(var _0x195a76 in _0x48735d){if(_0x48735d[_0x4228('0x55')](_0x195a76)){if(_0x1f72f9[_0x4228('0x52')][_0x1c441f][_0x48735d[_0x195a76]]){var _0x3d2a0c=_[_0x4228('0x56')](_0x1f72f9[_0x4228('0x52')][_0x1c441f][_0x48735d[_0x195a76]]['replace'](/"/g,'\x27'));switch(_0x195a76){case _0x4228('0x57'):var _0x74a771=moment(_0x3d2a0c,_0x4228('0xe'),!![]);if(_0x74a771[_0x4228('0x58')]()){_0x1753fd[_0x4228('0x41')]('\x22'+_0x3d2a0c+'\x22');}else{_0x510710[_0x4228('0x41')](_0x4228('0x59'));}break;case _0x4228('0x24'):var _0x1a4ef6=parseInt(_0x3d2a0c);_0x3d2a0c=_[_0x4228('0x5a')](_0x1a4ef6)||_0x1a4ef6<0x0||_0x1a4ef6>0x4?_0xa019b7?0x3:0x2:_0x1a4ef6;_0x1753fd['push']('\x22'+_0x3d2a0c+'\x22');break;case'UserId':var _0x431324=parseInt(_0x3d2a0c);if(_[_0x4228('0x5b')](_0x431324)&&_[_0x4228('0x5c')](_0x34c513,_0x431324)){_0x1753fd[_0x4228('0x41')]('\x22'+_0x431324+'\x22');}else{_0x510710['push'](_0x4228('0x5d'));}break;case _0x4228('0x5e'):if(isEmail(_0x3d2a0c)){_0x1753fd['push']('\x22'+_0x3d2a0c+'\x22');}else{_0x510710['push'](_0x4228('0x5f'));}break;case _0x4228('0x60'):var _0x3ddae9=moment(_0x3d2a0c,_0x4228('0x61'),!![]);if(_0x3ddae9[_0x4228('0x58')]()){_0x1753fd[_0x4228('0x41')]('\x22'+_0x3d2a0c+'\x22');}else{_0x510710[_0x4228('0x41')]('dateOfBirth\x20wrong\x20format\x20(YYYY-MM-DD)');}break;default:_0x1753fd[_0x4228('0x41')]('\x22'+_0x3d2a0c+'\x22');}}else{switch(_0x195a76){case _0x4228('0x62'):case _0x4228('0x20'):_0x510710[_0x4228('0x41')](_0x195a76+_0x4228('0x63'));break;default:_0x1753fd[_0x4228('0x41')]('\x22\x22');}}}}if(_0x510710[_0x4228('0x53')]){handleError(_0x1f72f9['data'][_0x1c441f],{'code':_0x4228('0x64'),'message':_0x510710[_0x4228('0x13')]()});}else{fs['appendFileSync'](_0x55851e,_0x1753fd[_0x4228('0x13')]()+'\x0a');}_0x1753fd=[];}if(!(stats['rows']%0xc8)){socket[_0x4228('0x65')]('contact:import:'+_0x2bf99f,stats);stats[_0x4228('0x40')]=[];}}if(stopped){logger[_0x4228('0x42')](_0x4228('0x66'));_0x3bf8ed['abort']();}}catch(_0x2a95c0){handleError(_0x1f72f9[_0x4228('0x52')][_0x1c441f],{'code':_0x4228('0x67'),'message':_0x2a95c0[_0x4228('0x68')]});logger[_0x4228('0x3f')](_0x4228('0x69'),_0x2a95c0[_0x4228('0x68')]);}},'complete':function(){try{var _0x1592e2=[];var _0x5a6e8b='cm_contacts';if(_0x45b5a0[_0x4228('0x6a')]&&_0x45b5a0[_0x4228('0x6a')]['length']){_0x5a6e8b=_0x4228('0x6b')+_0x2bf99f;_0x1592e2['push'](_0x4228('0x6c')+_0x5a6e8b+'\x20LIKE\x20cm_contacts;');}var _0x2b0d41=util['format'](_0x4228('0x6d'),_0x55851e,_0x5a6e8b,_0x2c7779,_0x45b5a0['ListId'],_0x45b5a0[_0x4228('0x38')]||null,NOW,NOW);if(_[_0x4228('0x6e')](_0x48735d[_0x4228('0x57')])){_0x2b0d41+=_0x4228('0x6f');}_0x1592e2[_0x4228('0x41')](_0x2b0d41);if(_0x45b5a0[_0x4228('0x6a')]&&_0x45b5a0[_0x4228('0x6a')][_0x4228('0x53')]){_0x1592e2[_0x4228('0x41')](insertCmContact(_0x45b5a0[_0x4228('0x32')],_0x5a6e8b,_0x45b5a0['duplicates'],_0x48735d));_0x1592e2[_0x4228('0x41')](_0x4228('0x70')+_0x5a6e8b+';');}_0x1592e2['push'](insertCmHopper(_0x45b5a0[_0x4228('0x32')],_0x4228('0x71'),'voice_queues','VoiceQueueId',_0xa019b7));_0x1592e2[_0x4228('0x41')](insertCmHopperBlack(_0x45b5a0[_0x4228('0x32')],'voice_queues_has_cm_blacklists',_0x4228('0x72'),_0x4228('0x73')));_0x1592e2[_0x4228('0x41')](insertCmHopper(_0x45b5a0[_0x4228('0x32')],_0x4228('0x74'),_0x4228('0x75'),_0x4228('0x76'),_0xa019b7));_0x1592e2[_0x4228('0x41')](insertCmHopperBlack(_0x45b5a0[_0x4228('0x32')],_0x4228('0x77'),'campaigns',_0x4228('0x76')));BPromise[_0x4228('0x78')](_0x1592e2,handleQuery)[_0x4228('0x79')](function(_0x5d968f){stats[_0x4228('0x7a')]=!![];stats[_0x4228('0x7b')]=_0x45b5a0[_0x4228('0x6a')]&&_0x45b5a0[_0x4228('0x6a')][_0x4228('0x53')]?results[0x2]['affectedRows']:results[0x0][_0x4228('0x7b')];socket[_0x4228('0x65')](_0x4228('0x7c')+_0x2bf99f,stats);fs[_0x4228('0x7d')](_0x1f1ac3);fs['unlink'](_0x55851e);process[_0x4228('0x7e')](0x0);})[_0x4228('0x46')](function(_0x58f4ce){logger[_0x4228('0x3f')](_0x58f4ce[_0x4228('0x68')]);process[_0x4228('0x7e')](0x1);});}catch(_0x3b9ec7){logger[_0x4228('0x3f')](_0x4228('0x7f'),_0x3b9ec7[_0x4228('0x68')]);process[_0x4228('0x7e')](0x1);}},'error':function(_0x3139a1,_0x44ec7b,_0x30200b,_0x3acbfa){throw new Error(_0x3acbfa);}});}function validate(){if(process[_0x4228('0x80')]&&process['argv'][_0x4228('0x53')]<0x4){throw new Error(_0x4228('0x81'));}var _0x50f2a0=path['join'](config[_0x4228('0x4b')],_0x4228('0x4c'),process[_0x4228('0x80')][0x2]);if(!fs['existsSync'](_0x50f2a0)){throw new Error(_0x4228('0x82'));}var _0x4f579c={};try{_0x4f579c=JSON[_0x4228('0x50')](process[_0x4228('0x80')][0x3]);if(!_0x4f579c['binding']){throw new Error(_0x4228('0x83'));}if(!_0x4f579c[_0x4228('0x84')][_0x4228('0x20')]){throw new Error('phone\x20is\x20mandatory');}if(!_0x4f579c[_0x4228('0x84')]['firstName']){throw new Error(_0x4228('0x85'));}var _0x36fd69=0x0;if(_0x4f579c['binding']['UserId']){_0x36fd69=0x1;}if(!_0x4f579c[_0x4228('0x32')]){throw new Error(_0x4228('0x86'));}}catch(_0x1ab139){throw new Error(_0x4228('0x87'));}var _0x4519d4=[];try{_0x4519d4=_[_0x4228('0x88')](JSON[_0x4228('0x50')](process[_0x4228('0x80')][0x4]),'id');}catch(_0x3b6f6c){logger[_0x4228('0x42')](_0x4228('0x89'));}main(_0x50f2a0,_0x4f579c,_0x4519d4,_0x36fd69);}validate();process['on']('SIGINT',handleStop);process['on'](_0x4228('0x8a'),handleUncaughtException);
git://repos.xcallymotion.com / motion2.git / blob