// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0x888f=['isNaN','isNumber','includes','agent\x20not\x20exists','email','dateOfBirth','YYYY-MM-DD','dateOfBirth\x20wrong\x20format\x20(YYYY-MM-DD)','firstName','\x20not\x20specified','length','emit','contact:import:','Abort\x20parser','step','duplicates','cm_contacts_','CREATE\x20TABLE\x20','\x20LIKE\x20cm_contacts;','DROP\x20TABLE\x20','voice_queues_has_cm_blacklists','voice_queues','VoiceQueueId','campaigns','CampaignId','campaigns_has_cm_blacklists','each','then','affectedRows','unlink','complete','argv','arguments\x20<filename>\x20<parameters>\x20<agents>','existsSync','phone\x20is\x20mandatory','ListId\x20is\x20mandatory','No\x20agent\x20available','papaparse','util','bluebird','../../../mysqldb','../../../config/logger','import','defaults','socket.io-emitter','redis','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.createdAt','cm_contacts.updatedAt','cm_contacts.UserId','insert','cm_hopper','fromQuery','ContactId','createdAt','updatedAt','priority','UserId','recallme','select','fields','cm_contacts','.CmListId\x20=\x20?','cm_contacts.createdAt\x20=\x20?','\x22always\x22','cm_contacts.phone\x20NOT\x20IN\x20(?)','toString','cm_hopper_black','ListId','cm_contacts.ListId\x20=\x20','.CmListId','concat','keys','CompanyId','into',')\x20NOT\x20IN\x20?','ListId\x20=\x20?','MIN(id)','min_id','group','info','Received\x20SIGINT','error','exit','push','code','sequelize','query','spread','catch','message','stringify','start','binding','root','server/files/tmp','.csv','header','parse','createReadStream','data','rows','errors','trim','replace','scheduledat','isValid'];(function(_0x3c2d95,_0x6783cf){var _0x1ecf41=function(_0x3fda54){while(--_0x3fda54){_0x3c2d95['push'](_0x3c2d95['shift']());}};_0x1ecf41(++_0x6783cf);}(_0x888f,0x190));var _0xf888=function(_0x52c493,_0x28b6c8){_0x52c493=_0x52c493-0x0;var _0x3ce871=_0x888f[_0x52c493];return _0x3ce871;};'use strict';var fs=require('fs');var path=require('path');var _=require('lodash');var Papa=require(_0xf888('0x0'));var util=require(_0xf888('0x1'));var BPromise=require(_0xf888('0x2'));var moment=require('moment');var squel=require('squel');var Redis=require('ioredis');var db=require(_0xf888('0x3'))['db'];var config=require('../../../config/environment');var logger=require(_0xf888('0x4'))(_0xf888('0x5'));config['redis']=_[_0xf888('0x6')](config['redis'],{'host':'localhost','port':0x18eb});var socket=require(_0xf888('0x7'))(new Redis(config[_0xf888('0x8')]));var stats={'finish':![],'errors':[],'rows':0x0,'affectedRows':0x0};var results=[];var stopped=![];var NOW=moment()[_0xf888('0x9')](_0xf888('0xa'));function isEmail(_0x53eb30){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))*$/[_0xf888('0xb')](_0x53eb30);}function selectNotIn(_0x2c19ae,_0x52c30e,_0x13b0b7,_0x1ee833,_0xd50702){return squel['select']()[_0xf888('0xc')](_0xf888('0xd'))[_0xf888('0xe')](_0x1ee833)[_0xf888('0xf')](_0x52c30e,null,_0x52c30e+_0xf888('0x10')+_0x1ee833+'.'+_0x13b0b7)[_0xf888('0x11')](_0x1ee833+'.'+_0x13b0b7+_0xf888('0x12')+_0x2c19ae+'.'+_0x13b0b7)[_0xf888('0x11')](_0x52c30e+_0xf888('0x13')+_0xd50702[_0xf888('0xf')]()+')');}function insertCmHopper(_0x1674b2,_0x34a7e5,_0x447d04,_0x320e1f,_0x2bead7){var _0x225849=[_0xf888('0x14'),_0xf888('0x15'),_0xf888('0x16'),_0xf888('0x17'),_0x34a7e5+'.'+_0x320e1f,_0xf888('0x18'),_0xf888('0x19'),'cm_contacts.priority',_0xf888('0x1a'),'\x22'+_0x2bead7+'\x22'];return squel[_0xf888('0x1b')]()['into'](_0xf888('0x1c'))[_0xf888('0x1d')]([_0xf888('0xd'),'scheduledat',_0xf888('0x1e'),'ListId',_0x320e1f,_0xf888('0x1f'),_0xf888('0x20'),_0xf888('0x21'),_0xf888('0x22'),_0xf888('0x23')],squel[_0xf888('0x24')]()[_0xf888('0x25')](_0x225849)[_0xf888('0xe')](_0x34a7e5)[_0xf888('0xf')](_0xf888('0x26'),null,'cm_contacts.ListId\x20=\x20'+_0x34a7e5+'.CmListId')[_0xf888('0xf')](_0x447d04,null,_0x447d04+_0xf888('0x10')+_0x34a7e5+'.'+_0x320e1f)[_0xf888('0x11')](_0x34a7e5+_0xf888('0x27'),_0x1674b2)[_0xf888('0x11')](_0xf888('0x28'),NOW)['where']('cm_contacts.phone\x20NOT\x20IN\x20(?)',selectNotIn(_0x34a7e5,_0x447d04,_0x320e1f,'cm_hopper',[_0xf888('0x29'),'\x22onlyIfOpen\x22']))[_0xf888('0x11')](_0xf888('0x2a'),selectNotIn(_0x34a7e5,_0x447d04,_0x320e1f,_0xf888('0x1c'),['\x22always\x22'])))[_0xf888('0x2b')]();}function insertCmHopperBlack(_0x12851d,_0x4fbf11,_0x4a7e0a,_0x1af664){var _0x19088a=[_0xf888('0x14'),_0xf888('0x16'),_0xf888('0x17'),_0x4fbf11+'.'+_0x1af664,_0xf888('0x18'),_0xf888('0x19')];return squel[_0xf888('0x1b')]()['into'](_0xf888('0x2c'))[_0xf888('0x1d')]([_0xf888('0xd'),'ContactId',_0xf888('0x2d'),_0x1af664,_0xf888('0x1f'),_0xf888('0x20')],squel[_0xf888('0x24')]()[_0xf888('0x25')](_0x19088a)[_0xf888('0xe')](_0x4fbf11)[_0xf888('0xf')](_0xf888('0x26'),null,_0xf888('0x2e')+_0x4fbf11+_0xf888('0x2f'))[_0xf888('0xf')](_0x4a7e0a,null,_0x4a7e0a+_0xf888('0x10')+_0x4fbf11+'.'+_0x1af664)[_0xf888('0x11')](_0x4fbf11+_0xf888('0x27'),_0x12851d)[_0xf888('0x11')](_0xf888('0x28'),NOW)[_0xf888('0x11')](_0xf888('0x2a'),squel[_0xf888('0x24')]()[_0xf888('0xc')](_0xf888('0xd'))[_0xf888('0xe')]('cm_hopper_black')[_0xf888('0x11')]('ListId\x20=\x20?',_0x12851d)['where'](_0x1af664+'\x20=\x20?',_0x4fbf11+'.'+_0x1af664)))[_0xf888('0x2b')]();}function insertCmContact(_0x5523ee,_0x35687e,_0x2a1f44,_0x1ffc8d){var _0x715db4=_[_0xf888('0x30')](_[_0xf888('0x31')](_0x1ffc8d),[_0xf888('0x2d'),_0xf888('0x32'),_0xf888('0x1f'),'updatedAt']);return squel[_0xf888('0x1b')]()[_0xf888('0x33')]('cm_contacts')[_0xf888('0x1d')](_0x715db4,squel['select']()[_0xf888('0x25')](_0x715db4)[_0xf888('0xe')](_0x35687e)[_0xf888('0x11')]('('+_0x2a1f44['join'](',')+_0xf888('0x34'),squel[_0xf888('0x24')]()['fields'](_0x2a1f44)[_0xf888('0xe')](_0xf888('0x26'))[_0xf888('0x11')](_0xf888('0x35'),_0x5523ee))[_0xf888('0x11')]('id\x20IN\x20?',squel[_0xf888('0x24')]()[_0xf888('0xc')](_0xf888('0x36'),_0xf888('0x37'))[_0xf888('0xe')](_0x35687e)[_0xf888('0x38')](_0x2a1f44[_0xf888('0xf')](','))))[_0xf888('0x2b')]();}function handleStop(){logger[_0xf888('0x39')](_0xf888('0x3a'));stopped=!![];}function handleUncaughtException(_0x3a5295){logger[_0xf888('0x3b')](_0x3a5295['message']);process[_0xf888('0x3c')](0x1);}function handleError(_0x12b33d,_0x13d5f2){stats['errors'][_0xf888('0x3d')]({'name':_0x13d5f2[_0xf888('0x3e')],'message':_0x13d5f2['message'],'row':_0x12b33d});}function handleQuery(_0x15274c){logger[_0xf888('0x39')](_0x15274c);return db[_0xf888('0x3f')][_0xf888('0x40')](_0x15274c)[_0xf888('0x41')](function(_0x2fd851){results['push'](_0x2fd851);})[_0xf888('0x42')](function(_0x3f8295){logger[_0xf888('0x3b')](_0x3f8295[_0xf888('0x43')]);});}function main(_0x25eec5,_0x27c822,_0x3d8060,_0x1cd9a9){logger[_0xf888('0x39')]('main',_0x25eec5,JSON[_0xf888('0x44')](_0x27c822));process['send'](_0xf888('0x45'));var _0x458228=_0x27c822[_0xf888('0x46')];var _0x37ddea=_0x27c822['socket_timestamp'];var _0x389532=path['join'](config[_0xf888('0x47')],_0xf888('0x48'),_0x37ddea+_0xf888('0x49'));var _0x35e753=_['keys'](_0x458228)[_0xf888('0xf')]();logger[_0xf888('0x39')](_0xf888('0x4a'),_0x35e753);fs['writeFileSync'](_0x389532,_0x35e753+'\x0a');Papa[_0xf888('0x4b')](fs[_0xf888('0x4c')](_0x25eec5),{'header':!![],'skipEmptyLines':!![],'step':function(_0x45607c,_0x295c63){try{for(var _0x1a3dbf=0x0,_0x5df165=[];_0x1a3dbf<_0x45607c[_0xf888('0x4d')]['length'];_0x1a3dbf++){stats[_0xf888('0x4e')]+=0x1;if(_0x45607c[_0xf888('0x4f')][_0x1a3dbf]){handleError(_0x45607c[_0xf888('0x4d')][_0x1a3dbf],_0x45607c[_0xf888('0x4f')][_0x1a3dbf]);}else{var _0x58cdc0=[];for(var _0x404239 in _0x458228){if(_0x458228['hasOwnProperty'](_0x404239)){if(_0x45607c[_0xf888('0x4d')][_0x1a3dbf][_0x458228[_0x404239]]){var _0x320916=_[_0xf888('0x50')](_0x45607c['data'][_0x1a3dbf][_0x458228[_0x404239]][_0xf888('0x51')](/"/g,'\x27'));switch(_0x404239){case _0xf888('0x52'):var _0x51584e=moment(_0x320916,'YYYY-MM-DD\x20HH:mm:ss',!![]);if(_0x51584e[_0xf888('0x53')]()){_0x5df165[_0xf888('0x3d')]('\x22'+_0x320916+'\x22');}else{_0x58cdc0['push']('scheduledat\x20wrong\x20format\x20(YYYY-MM-DD\x20HH:mm:ss)');}break;case'priority':var _0x1a60ae=parseInt(_0x320916);_0x320916=_[_0xf888('0x54')](_0x1a60ae)||_0x1a60ae<0x0||_0x1a60ae>0x4?_0x1cd9a9?0x3:0x2:_0x1a60ae;_0x5df165['push']('\x22'+_0x320916+'\x22');break;case _0xf888('0x22'):var _0x1da9ae=parseInt(_0x320916);if(_[_0xf888('0x55')](_0x1da9ae)&&_[_0xf888('0x56')](_0x3d8060,_0x1da9ae)){_0x5df165[_0xf888('0x3d')]('\x22'+_0x1da9ae+'\x22');}else{_0x58cdc0[_0xf888('0x3d')](_0xf888('0x57'));}break;case _0xf888('0x58'):if(isEmail(_0x320916)){_0x5df165[_0xf888('0x3d')]('\x22'+_0x320916+'\x22');}else{_0x58cdc0['push']('email\x20wrong\x20format');}break;case _0xf888('0x59'):var _0x8848a7=moment(_0x320916,_0xf888('0x5a'),!![]);if(_0x8848a7[_0xf888('0x53')]()){_0x5df165[_0xf888('0x3d')]('\x22'+_0x320916+'\x22');}else{_0x58cdc0['push'](_0xf888('0x5b'));}break;default:_0x5df165[_0xf888('0x3d')]('\x22'+_0x320916+'\x22');}}else{switch(_0x404239){case _0xf888('0x5c'):case _0xf888('0xd'):_0x58cdc0[_0xf888('0x3d')](_0x404239+_0xf888('0x5d'));break;default:_0x5df165[_0xf888('0x3d')]('\x22\x22');}}}}if(_0x58cdc0[_0xf888('0x5e')]){handleError(_0x45607c[_0xf888('0x4d')][_0x1a3dbf],{'code':'SystemRow','message':_0x58cdc0[_0xf888('0xf')]()});}else{fs['appendFileSync'](_0x389532,_0x5df165[_0xf888('0xf')]()+'\x0a');}_0x5df165=[];}if(!(stats[_0xf888('0x4e')]%0xc8)){socket[_0xf888('0x5f')](_0xf888('0x60')+_0x37ddea,stats);stats['errors']=[];}}if(stopped){logger[_0xf888('0x39')](_0xf888('0x61'));_0x295c63['abort']();}}catch(_0x1a0c8f){handleError(_0x45607c[_0xf888('0x4d')][_0x1a3dbf],{'code':'SystemError','message':_0x1a0c8f[_0xf888('0x43')]});logger[_0xf888('0x3b')](_0xf888('0x62'),_0x1a0c8f[_0xf888('0x43')]);}},'complete':function(){try{var _0x4679e1=[];var _0x210c58='cm_contacts';if(_0x27c822[_0xf888('0x63')]&&_0x27c822['duplicates'][_0xf888('0x5e')]){_0x210c58=_0xf888('0x64')+_0x37ddea;_0x4679e1['push'](_0xf888('0x65')+_0x210c58+_0xf888('0x66'));}var _0x434b04=util[_0xf888('0x9')]('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',_0x389532,_0x210c58,_0x35e753,_0x27c822[_0xf888('0x2d')],_0x27c822['CompanyId']||null,NOW,NOW);if(_['isNil'](_0x458228[_0xf888('0x52')])){_0x434b04+=',\x20scheduledAt\x20=\x20NOW()';}_0x4679e1[_0xf888('0x3d')](_0x434b04);if(_0x27c822[_0xf888('0x63')]&&_0x27c822['duplicates']['length']){_0x4679e1['push'](insertCmContact(_0x27c822['ListId'],_0x210c58,_0x27c822[_0xf888('0x63')],_0x458228));_0x4679e1[_0xf888('0x3d')](_0xf888('0x67')+_0x210c58+';');}_0x4679e1['push'](insertCmHopper(_0x27c822[_0xf888('0x2d')],'voice_queues_has_cm_lists','voice_queues','VoiceQueueId',_0x1cd9a9));_0x4679e1[_0xf888('0x3d')](insertCmHopperBlack(_0x27c822[_0xf888('0x2d')],_0xf888('0x68'),_0xf888('0x69'),_0xf888('0x6a')));_0x4679e1[_0xf888('0x3d')](insertCmHopper(_0x27c822['ListId'],'campaigns_has_cm_lists',_0xf888('0x6b'),_0xf888('0x6c'),_0x1cd9a9));_0x4679e1[_0xf888('0x3d')](insertCmHopperBlack(_0x27c822[_0xf888('0x2d')],_0xf888('0x6d'),'campaigns',_0xf888('0x6c')));BPromise[_0xf888('0x6e')](_0x4679e1,handleQuery)[_0xf888('0x6f')](function(_0x464cef){stats['finish']=!![];stats[_0xf888('0x70')]=_0x27c822[_0xf888('0x63')]&&_0x27c822[_0xf888('0x63')][_0xf888('0x5e')]?results[0x2][_0xf888('0x70')]:results[0x0]['affectedRows'];socket[_0xf888('0x5f')](_0xf888('0x60')+_0x37ddea,stats);fs[_0xf888('0x71')](_0x25eec5);fs[_0xf888('0x71')](_0x389532);process['exit'](0x0);})[_0xf888('0x42')](function(_0x3769c7){logger['error'](_0x3769c7[_0xf888('0x43')]);process[_0xf888('0x3c')](0x1);});}catch(_0x43a932){logger[_0xf888('0x3b')](_0xf888('0x72'),_0x43a932[_0xf888('0x43')]);process[_0xf888('0x3c')](0x1);}},'error':function(_0x2d93d8,_0x68adb2,_0x58eca2,_0x4d566e){throw new Error(_0x4d566e);}});}function validate(){if(process[_0xf888('0x73')]&&process['argv'][_0xf888('0x5e')]<0x4){throw new Error(_0xf888('0x74'));}var _0x41e2ae=path[_0xf888('0xf')](config[_0xf888('0x47')],_0xf888('0x48'),process[_0xf888('0x73')][0x2]);if(!fs[_0xf888('0x75')](_0x41e2ae)){throw new Error('file\x20doesn\x27t\x20exists');}var _0x42e321={};try{_0x42e321=JSON['parse'](process[_0xf888('0x73')][0x3]);if(!_0x42e321[_0xf888('0x46')]){throw new Error('binding\x20doesn\x27t\x20exists');}if(!_0x42e321[_0xf888('0x46')][_0xf888('0xd')]){throw new Error(_0xf888('0x76'));}if(!_0x42e321[_0xf888('0x46')][_0xf888('0x5c')]){throw new Error('firstName\x20is\x20mandatory');}var _0x5ff466=0x0;if(_0x42e321[_0xf888('0x46')][_0xf888('0x22')]){_0x5ff466=0x1;}if(!_0x42e321[_0xf888('0x2d')]){throw new Error(_0xf888('0x77'));}}catch(_0x33aafb){throw new Error('body\x20id\x20mandatory');}var _0x358b66=[];try{_0x358b66=_['map'](JSON[_0xf888('0x4b')](process[_0xf888('0x73')][0x4]),'id');}catch(_0x623e3d){logger[_0xf888('0x39')](_0xf888('0x78'));}main(_0x41e2ae,_0x42e321,_0x358b66,_0x5ff466);}validate();process['on']('SIGINT',handleStop);process['on']('uncaughtException',handleUncaughtException);
\ No newline at end of file
+var _0xccf0=['scheduledat\x20wrong\x20format\x20(YYYY-MM-DD\x20HH:mm:ss)','isNaN','UserId','isNumber','includes','agent\x20not\x20exists','email','email\x20wrong\x20format','dateOfBirth','YYYY-MM-DD','firstName','\x20not\x20specified','SystemRow','appendFileSync','rows','emit','contact:import:','Abort\x20parser','abort','step','duplicates','cm_contacts_','CREATE\x20TABLE\x20','isNil',',\x20scheduledAt\x20=\x20NOW()','DROP\x20TABLE\x20','voice_queues_has_cm_lists','voice_queues','VoiceQueueId','campaigns_has_cm_lists','campaigns','CampaignId','campaigns_has_cm_blacklists','each','finish','affectedRows','unlink','argv','arguments\x20<filename>\x20<parameters>\x20<agents>','root','server/files/tmp','binding\x20doesn\x27t\x20exists','phone\x20is\x20mandatory','ListId\x20is\x20mandatory','body\x20id\x20mandatory','No\x20agent\x20available','SIGINT','lodash','util','bluebird','squel','ioredis','../../../mysqldb','../../../config/logger','import','defaults','localhost','socket.io-emitter','redis','format','YYYY-MM-DD\x20HH:mm:ss','test','select','phone','from','join','where','\x20=\x20','.dialCheckDuplicateType\x20IN\x20(','cm_contacts.phone','cm_contacts.id','cm_contacts.ListId','cm_contacts.priority','cm_contacts.UserId','into','fromQuery','scheduledat','ListId','createdAt','updatedAt','priority','recallme','fields','cm_contacts','cm_contacts.ListId\x20=\x20','.CmListId','.id\x20=\x20','cm_contacts.createdAt\x20=\x20?','cm_contacts.phone\x20NOT\x20IN\x20(?)','\x22onlyIfOpen\x22','cm_hopper','\x22always\x22','cm_contacts.createdAt','insert','ContactId','.CmListId\x20=\x20?','field','cm_hopper_black','toString','concat','CompanyId',')\x20NOT\x20IN\x20?','ListId\x20=\x20?','id\x20IN\x20?','MIN(id)','min_id','group','error','exit','errors','code','message','info','sequelize','query','spread','catch','main','stringify','start','binding','keys','writeFileSync','parse','createReadStream','data','length','hasOwnProperty','trim','replace','isValid','push'];(function(_0x480d8b,_0x5a5722){var _0x2861ae=function(_0x4cee76){while(--_0x4cee76){_0x480d8b['push'](_0x480d8b['shift']());}};_0x2861ae(++_0x5a5722);}(_0xccf0,0x137));var _0x0ccf=function(_0x1ae7e6,_0x545195){_0x1ae7e6=_0x1ae7e6-0x0;var _0x198d46=_0xccf0[_0x1ae7e6];return _0x198d46;};'use strict';var fs=require('fs');var path=require('path');var _=require(_0x0ccf('0x0'));var Papa=require('papaparse');var util=require(_0x0ccf('0x1'));var BPromise=require(_0x0ccf('0x2'));var moment=require('moment');var squel=require(_0x0ccf('0x3'));var Redis=require(_0x0ccf('0x4'));var db=require(_0x0ccf('0x5'))['db'];var config=require('../../../config/environment');var logger=require(_0x0ccf('0x6'))(_0x0ccf('0x7'));config['redis']=_[_0x0ccf('0x8')](config['redis'],{'host':_0x0ccf('0x9'),'port':0x18eb});var socket=require(_0x0ccf('0xa'))(new Redis(config[_0x0ccf('0xb')]));var stats={'finish':![],'errors':[],'rows':0x0,'affectedRows':0x0};var results=[];var stopped=![];var NOW=moment()[_0x0ccf('0xc')](_0x0ccf('0xd'));function isEmail(_0x25236e){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))*$/[_0x0ccf('0xe')](_0x25236e);}function selectNotIn(_0x4a5ae5,_0xc25bbd,_0x1ed05f,_0x500883,_0x29fcc9){return squel[_0x0ccf('0xf')]()['field'](_0x0ccf('0x10'))[_0x0ccf('0x11')](_0x500883)[_0x0ccf('0x12')](_0xc25bbd,null,_0xc25bbd+'.id\x20=\x20'+_0x500883+'.'+_0x1ed05f)[_0x0ccf('0x13')](_0x500883+'.'+_0x1ed05f+_0x0ccf('0x14')+_0x4a5ae5+'.'+_0x1ed05f)['where'](_0xc25bbd+_0x0ccf('0x15')+_0x29fcc9[_0x0ccf('0x12')]()+')');}function insertCmHopper(_0x5bf2d1,_0x4ba8e2,_0x4aa53a,_0x40dca1,_0x1cee3c){var _0x74a2a=[_0x0ccf('0x16'),'cm_contacts.scheduledat',_0x0ccf('0x17'),_0x0ccf('0x18'),_0x4ba8e2+'.'+_0x40dca1,'cm_contacts.createdAt','cm_contacts.updatedAt',_0x0ccf('0x19'),_0x0ccf('0x1a'),'\x22'+_0x1cee3c+'\x22'];return squel['insert']()[_0x0ccf('0x1b')]('cm_hopper')[_0x0ccf('0x1c')]([_0x0ccf('0x10'),_0x0ccf('0x1d'),'ContactId',_0x0ccf('0x1e'),_0x40dca1,_0x0ccf('0x1f'),_0x0ccf('0x20'),_0x0ccf('0x21'),'UserId',_0x0ccf('0x22')],squel['select']()[_0x0ccf('0x23')](_0x74a2a)['from'](_0x4ba8e2)[_0x0ccf('0x12')](_0x0ccf('0x24'),null,_0x0ccf('0x25')+_0x4ba8e2+_0x0ccf('0x26'))['join'](_0x4aa53a,null,_0x4aa53a+_0x0ccf('0x27')+_0x4ba8e2+'.'+_0x40dca1)[_0x0ccf('0x13')](_0x4ba8e2+'.CmListId\x20=\x20?',_0x5bf2d1)[_0x0ccf('0x13')](_0x0ccf('0x28'),NOW)['where'](_0x0ccf('0x29'),selectNotIn(_0x4ba8e2,_0x4aa53a,_0x40dca1,'cm_hopper',['\x22always\x22',_0x0ccf('0x2a')]))[_0x0ccf('0x13')]('cm_contacts.phone\x20NOT\x20IN\x20(?)',selectNotIn(_0x4ba8e2,_0x4aa53a,_0x40dca1,_0x0ccf('0x2b'),[_0x0ccf('0x2c')])))['toString']();}function insertCmHopperBlack(_0x38cb0e,_0x30707c,_0x430cd8,_0x2272c6){var _0x27fd9a=[_0x0ccf('0x16'),_0x0ccf('0x17'),_0x0ccf('0x18'),_0x30707c+'.'+_0x2272c6,_0x0ccf('0x2d'),'cm_contacts.updatedAt'];return squel[_0x0ccf('0x2e')]()['into']('cm_hopper_black')[_0x0ccf('0x1c')](['phone',_0x0ccf('0x2f'),_0x0ccf('0x1e'),_0x2272c6,_0x0ccf('0x1f'),_0x0ccf('0x20')],squel['select']()['fields'](_0x27fd9a)[_0x0ccf('0x11')](_0x30707c)[_0x0ccf('0x12')](_0x0ccf('0x24'),null,_0x0ccf('0x25')+_0x30707c+'.CmListId')[_0x0ccf('0x12')](_0x430cd8,null,_0x430cd8+_0x0ccf('0x27')+_0x30707c+'.'+_0x2272c6)[_0x0ccf('0x13')](_0x30707c+_0x0ccf('0x30'),_0x38cb0e)[_0x0ccf('0x13')](_0x0ccf('0x28'),NOW)[_0x0ccf('0x13')](_0x0ccf('0x29'),squel[_0x0ccf('0xf')]()[_0x0ccf('0x31')]('phone')[_0x0ccf('0x11')](_0x0ccf('0x32'))['where']('ListId\x20=\x20?',_0x38cb0e)[_0x0ccf('0x13')](_0x2272c6+'\x20=\x20?',_0x30707c+'.'+_0x2272c6)))[_0x0ccf('0x33')]();}function insertCmContact(_0x287fd0,_0x4e54e9,_0x832ed6,_0x3916ea){var _0x36ee9d=_[_0x0ccf('0x34')](_['keys'](_0x3916ea),[_0x0ccf('0x1e'),_0x0ccf('0x35'),_0x0ccf('0x1f'),'updatedAt']);return squel[_0x0ccf('0x2e')]()[_0x0ccf('0x1b')]('cm_contacts')[_0x0ccf('0x1c')](_0x36ee9d,squel['select']()[_0x0ccf('0x23')](_0x36ee9d)[_0x0ccf('0x11')](_0x4e54e9)[_0x0ccf('0x13')]('('+_0x832ed6[_0x0ccf('0x12')](',')+_0x0ccf('0x36'),squel[_0x0ccf('0xf')]()['fields'](_0x832ed6)['from'](_0x0ccf('0x24'))[_0x0ccf('0x13')](_0x0ccf('0x37'),_0x287fd0))[_0x0ccf('0x13')](_0x0ccf('0x38'),squel[_0x0ccf('0xf')]()[_0x0ccf('0x31')](_0x0ccf('0x39'),_0x0ccf('0x3a'))['from'](_0x4e54e9)[_0x0ccf('0x3b')](_0x832ed6[_0x0ccf('0x12')](','))))[_0x0ccf('0x33')]();}function handleStop(){logger['info']('Received\x20SIGINT');stopped=!![];}function handleUncaughtException(_0x229c80){logger[_0x0ccf('0x3c')](_0x229c80['message']);process[_0x0ccf('0x3d')](0x1);}function handleError(_0x474087,_0x2c8bf2){stats[_0x0ccf('0x3e')]['push']({'name':_0x2c8bf2[_0x0ccf('0x3f')],'message':_0x2c8bf2[_0x0ccf('0x40')],'row':_0x474087});}function handleQuery(_0x4adba5){logger[_0x0ccf('0x41')](_0x4adba5);return db[_0x0ccf('0x42')][_0x0ccf('0x43')](_0x4adba5)[_0x0ccf('0x44')](function(_0x2753e6){results['push'](_0x2753e6);})[_0x0ccf('0x45')](function(_0x19386d){logger[_0x0ccf('0x3c')](_0x19386d[_0x0ccf('0x40')]);});}function main(_0x106794,_0x1fd1ae,_0xd7c47c,_0x1e1745){logger['info'](_0x0ccf('0x46'),_0x106794,JSON[_0x0ccf('0x47')](_0x1fd1ae));process['send'](_0x0ccf('0x48'));var _0x37af16=_0x1fd1ae[_0x0ccf('0x49')];var _0x5c85ef=_0x1fd1ae['socket_timestamp'];var _0xa360e6=path['join'](config['root'],'server/files/tmp',_0x5c85ef+'.csv');var _0x3961c4=_[_0x0ccf('0x4a')](_0x37af16)[_0x0ccf('0x12')]();logger[_0x0ccf('0x41')]('header',_0x3961c4);fs[_0x0ccf('0x4b')](_0xa360e6,_0x3961c4+'\x0a');Papa[_0x0ccf('0x4c')](fs[_0x0ccf('0x4d')](_0x106794),{'header':!![],'skipEmptyLines':!![],'step':function(_0x1f19a0,_0x272213){try{for(var _0x217b61=0x0,_0x26b7b4=[];_0x217b61<_0x1f19a0[_0x0ccf('0x4e')][_0x0ccf('0x4f')];_0x217b61++){stats['rows']+=0x1;if(_0x1f19a0[_0x0ccf('0x3e')][_0x217b61]){handleError(_0x1f19a0[_0x0ccf('0x4e')][_0x217b61],_0x1f19a0['errors'][_0x217b61]);}else{var _0x3da4ef=[];for(var _0x2ff7cc in _0x37af16){if(_0x37af16[_0x0ccf('0x50')](_0x2ff7cc)){if(_0x1f19a0[_0x0ccf('0x4e')][_0x217b61][_0x37af16[_0x2ff7cc]]){var _0x114ecd=_[_0x0ccf('0x51')](_0x1f19a0[_0x0ccf('0x4e')][_0x217b61][_0x37af16[_0x2ff7cc]][_0x0ccf('0x52')](/"/g,'\x27'));switch(_0x2ff7cc){case _0x0ccf('0x1d'):var _0x15ccc1=moment(_0x114ecd,_0x0ccf('0xd'),!![]);if(_0x15ccc1[_0x0ccf('0x53')]()){_0x26b7b4['push']('\x22'+_0x114ecd+'\x22');}else{_0x3da4ef[_0x0ccf('0x54')](_0x0ccf('0x55'));}break;case'priority':var _0x2ad2c2=parseInt(_0x114ecd);_0x114ecd=_[_0x0ccf('0x56')](_0x2ad2c2)||_0x2ad2c2<0x0||_0x2ad2c2>0x4?_0x1e1745?0x3:0x2:_0x2ad2c2;_0x26b7b4[_0x0ccf('0x54')]('\x22'+_0x114ecd+'\x22');break;case _0x0ccf('0x57'):var _0x2227be=parseInt(_0x114ecd);if(_[_0x0ccf('0x58')](_0x2227be)&&_[_0x0ccf('0x59')](_0xd7c47c,_0x2227be)){_0x26b7b4[_0x0ccf('0x54')]('\x22'+_0x2227be+'\x22');}else{_0x3da4ef['push'](_0x0ccf('0x5a'));}break;case _0x0ccf('0x5b'):if(isEmail(_0x114ecd)){_0x26b7b4[_0x0ccf('0x54')]('\x22'+_0x114ecd+'\x22');}else{_0x3da4ef[_0x0ccf('0x54')](_0x0ccf('0x5c'));}break;case _0x0ccf('0x5d'):var _0x5c98ab=moment(_0x114ecd,_0x0ccf('0x5e'),!![]);if(_0x5c98ab['isValid']()){_0x26b7b4[_0x0ccf('0x54')]('\x22'+_0x114ecd+'\x22');}else{_0x3da4ef[_0x0ccf('0x54')]('dateOfBirth\x20wrong\x20format\x20(YYYY-MM-DD)');}break;default:_0x26b7b4[_0x0ccf('0x54')]('\x22'+_0x114ecd+'\x22');}}else{switch(_0x2ff7cc){case _0x0ccf('0x5f'):case _0x0ccf('0x10'):_0x3da4ef[_0x0ccf('0x54')](_0x2ff7cc+_0x0ccf('0x60'));break;default:_0x26b7b4['push']('\x22\x22');}}}}if(_0x3da4ef[_0x0ccf('0x4f')]){handleError(_0x1f19a0[_0x0ccf('0x4e')][_0x217b61],{'code':_0x0ccf('0x61'),'message':_0x3da4ef[_0x0ccf('0x12')]()});}else{fs[_0x0ccf('0x62')](_0xa360e6,_0x26b7b4[_0x0ccf('0x12')]()+'\x0a');}_0x26b7b4=[];}if(!(stats[_0x0ccf('0x63')]%0xc8)){socket[_0x0ccf('0x64')](_0x0ccf('0x65')+_0x5c85ef,stats);stats[_0x0ccf('0x3e')]=[];}}if(stopped){logger[_0x0ccf('0x41')](_0x0ccf('0x66'));_0x272213[_0x0ccf('0x67')]();}}catch(_0x561cf6){handleError(_0x1f19a0['data'][_0x217b61],{'code':'SystemError','message':_0x561cf6[_0x0ccf('0x40')]});logger[_0x0ccf('0x3c')](_0x0ccf('0x68'),_0x561cf6[_0x0ccf('0x40')]);}},'complete':function(){try{var _0x4f6663=[];var _0x4d8659=_0x0ccf('0x24');if(_0x1fd1ae[_0x0ccf('0x69')]&&_0x1fd1ae[_0x0ccf('0x69')][_0x0ccf('0x4f')]){_0x4d8659=_0x0ccf('0x6a')+_0x5c85ef;_0x4f6663[_0x0ccf('0x54')](_0x0ccf('0x6b')+_0x4d8659+'\x20LIKE\x20cm_contacts;');}var _0x2cf915=util[_0x0ccf('0xc')]('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',_0xa360e6,_0x4d8659,_0x3961c4,_0x1fd1ae[_0x0ccf('0x1e')],_0x1fd1ae[_0x0ccf('0x35')]||null,NOW,NOW);if(_[_0x0ccf('0x6c')](_0x37af16[_0x0ccf('0x1d')])){_0x2cf915+=_0x0ccf('0x6d');}_0x4f6663[_0x0ccf('0x54')](_0x2cf915);if(_0x1fd1ae['duplicates']&&_0x1fd1ae['duplicates']['length']){_0x4f6663[_0x0ccf('0x54')](insertCmContact(_0x1fd1ae['ListId'],_0x4d8659,_0x1fd1ae[_0x0ccf('0x69')],_0x37af16));_0x4f6663['push'](_0x0ccf('0x6e')+_0x4d8659+';');}_0x4f6663[_0x0ccf('0x54')](insertCmHopper(_0x1fd1ae[_0x0ccf('0x1e')],_0x0ccf('0x6f'),_0x0ccf('0x70'),_0x0ccf('0x71'),_0x1e1745));_0x4f6663[_0x0ccf('0x54')](insertCmHopperBlack(_0x1fd1ae[_0x0ccf('0x1e')],'voice_queues_has_cm_blacklists',_0x0ccf('0x70'),_0x0ccf('0x71')));_0x4f6663['push'](insertCmHopper(_0x1fd1ae['ListId'],_0x0ccf('0x72'),_0x0ccf('0x73'),_0x0ccf('0x74'),_0x1e1745));_0x4f6663[_0x0ccf('0x54')](insertCmHopperBlack(_0x1fd1ae[_0x0ccf('0x1e')],_0x0ccf('0x75'),'campaigns',_0x0ccf('0x74')));BPromise[_0x0ccf('0x76')](_0x4f6663,handleQuery)['then'](function(_0x3f2d96){stats[_0x0ccf('0x77')]=!![];stats['affectedRows']=_0x1fd1ae[_0x0ccf('0x69')]&&_0x1fd1ae[_0x0ccf('0x69')]['length']?results[0x2][_0x0ccf('0x78')]:results[0x0][_0x0ccf('0x78')];socket[_0x0ccf('0x64')]('contact:import:'+_0x5c85ef,stats);fs[_0x0ccf('0x79')](_0x106794);fs[_0x0ccf('0x79')](_0xa360e6);process[_0x0ccf('0x3d')](0x0);})[_0x0ccf('0x45')](function(_0x15939c){logger[_0x0ccf('0x3c')](_0x15939c['message']);process[_0x0ccf('0x3d')](0x1);});}catch(_0x127e5e){logger['error']('complete',_0x127e5e[_0x0ccf('0x40')]);process[_0x0ccf('0x3d')](0x1);}},'error':function(_0x1a041a,_0x237850,_0x213d4a,_0x5daa40){throw new Error(_0x5daa40);}});}function validate(){if(process[_0x0ccf('0x7a')]&&process[_0x0ccf('0x7a')][_0x0ccf('0x4f')]<0x4){throw new Error(_0x0ccf('0x7b'));}var _0xbfb23=path[_0x0ccf('0x12')](config[_0x0ccf('0x7c')],_0x0ccf('0x7d'),process[_0x0ccf('0x7a')][0x2]);if(!fs['existsSync'](_0xbfb23)){throw new Error('file\x20doesn\x27t\x20exists');}var _0x1dc91a={};try{_0x1dc91a=JSON[_0x0ccf('0x4c')](process[_0x0ccf('0x7a')][0x3]);if(!_0x1dc91a[_0x0ccf('0x49')]){throw new Error(_0x0ccf('0x7e'));}if(!_0x1dc91a[_0x0ccf('0x49')][_0x0ccf('0x10')]){throw new Error(_0x0ccf('0x7f'));}if(!_0x1dc91a[_0x0ccf('0x49')]['firstName']){throw new Error('firstName\x20is\x20mandatory');}var _0x142064=0x0;if(_0x1dc91a[_0x0ccf('0x49')][_0x0ccf('0x57')]){_0x142064=0x1;}if(!_0x1dc91a['ListId']){throw new Error(_0x0ccf('0x80'));}}catch(_0x273849){throw new Error(_0x0ccf('0x81'));}var _0x82da14=[];try{_0x82da14=_['map'](JSON['parse'](process[_0x0ccf('0x7a')][0x4]),'id');}catch(_0x29e0c3){logger[_0x0ccf('0x41')](_0x0ccf('0x82'));}main(_0xbfb23,_0x1dc91a,_0x82da14,_0x142064);}validate();process['on'](_0x0ccf('0x83'),handleStop);process['on']('uncaughtException',handleUncaughtException);
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff