// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0x66c6=['test','select','field','join','.id\x20=\x20','\x20=\x20','where','.dialCheckDuplicateType\x20IN\x20(','cm_contacts.createdAt','cm_contacts.updatedAt','cm_contacts.priority','cm_contacts.UserId','insert','into','cm_hopper','fromQuery','phone','ContactId','ListId','createdAt','priority','UserId','fields','from','cm_contacts','cm_contacts.ListId\x20=\x20','.CmListId','.CmListId\x20=\x20?','\x22onlyIfOpen\x22','cm_contacts.phone\x20NOT\x20IN\x20(?)','\x22always\x22','toString','cm_contacts.phone','updatedAt','cm_contacts.createdAt\x20=\x20?','cm_hopper_black','ListId\x20=\x20?','\x20=\x20?','concat','keys','CompanyId',')\x20NOT\x20IN\x20?','id\x20IN\x20?','MIN(id)','min_id','info','Received\x20SIGINT','error','message','exit','errors','spread','push','main','stringify','start','socket_timestamp','root','.csv','writeFileSync','createReadStream','data','length','rows','hasOwnProperty','trim','replace','scheduledat','isValid','isNaN','isNumber','email','email\x20wrong\x20format','dateOfBirth\x20wrong\x20format\x20(YYYY-MM-DD)','SystemRow','appendFileSync','contact:import:','SystemError','duplicates','cm_contacts_','CREATE\x20TABLE\x20','\x20LIKE\x20cm_contacts;','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','DROP\x20TABLE\x20','voice_queues_has_cm_lists','voice_queues','VoiceQueueId','voice_queues_has_cm_blacklists','campaigns_has_cm_lists','campaigns','CampaignId','then','affectedRows','unlink','catch','complete','argv','arguments\x20<filename>\x20<parameters>\x20<agents>','server/files/tmp','existsSync','file\x20doesn\x27t\x20exists','parse','binding','binding\x20doesn\x27t\x20exists','phone\x20is\x20mandatory','firstName','firstName\x20is\x20mandatory','ListId\x20is\x20mandatory','body\x20id\x20mandatory','map','No\x20agent\x20available','SIGINT','path','lodash','papaparse','bluebird','squel','../../../mysqldb','../../../config/logger','localhost','format','YYYY-MM-DD\x20HH:mm:ss'];(function(_0x49e132,_0xaf827a){var _0x6403c2=function(_0x49888b){while(--_0x49888b){_0x49e132['push'](_0x49e132['shift']());}};_0x6403c2(++_0xaf827a);}(_0x66c6,0x167));var _0x666c=function(_0x34e853,_0x5809c3){_0x34e853=_0x34e853-0x0;var _0x351fa=_0x66c6[_0x34e853];return _0x351fa;};'use strict';var fs=require('fs');var path=require(_0x666c('0x0'));var _=require(_0x666c('0x1'));var Papa=require(_0x666c('0x2'));var util=require('util');var BPromise=require(_0x666c('0x3'));var moment=require('moment');var squel=require(_0x666c('0x4'));var db=require(_0x666c('0x5'))['db'];var config=require('../../../config/environment');var logger=require(_0x666c('0x6'))('import');var socket=require('socket.io-emitter')({'host':_0x666c('0x7'),'port':0x18eb});var stats={'finish':![],'errors':[],'rows':0x0,'affectedRows':0x0};var results=[];var stopped=![];var NOW=moment()[_0x666c('0x8')](_0x666c('0x9'));function isEmail(_0x32740c){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))*$/[_0x666c('0xa')](_0x32740c);}function selectNotIn(_0xc9afa9,_0x29bf20,_0x34aa90,_0x1bcbad,_0x5289db){return squel[_0x666c('0xb')]()[_0x666c('0xc')]('phone')['from'](_0x1bcbad)[_0x666c('0xd')](_0x29bf20,null,_0x29bf20+_0x666c('0xe')+_0x1bcbad+'.'+_0x34aa90)['where'](_0x1bcbad+'.'+_0x34aa90+_0x666c('0xf')+_0xc9afa9+'.'+_0x34aa90)[_0x666c('0x10')](_0x29bf20+_0x666c('0x11')+_0x5289db['join']()+')');}function insertCmHopper(_0x3ed593,_0x4123e7,_0xccce0c,_0x3ef912,_0x3c3dfb){var _0x597729=['cm_contacts.phone','cm_contacts.scheduledat','cm_contacts.id','cm_contacts.ListId',_0x4123e7+'.'+_0x3ef912,_0x666c('0x12'),_0x666c('0x13'),_0x666c('0x14'),_0x666c('0x15'),'\x22'+_0x3c3dfb+'\x22'];return squel[_0x666c('0x16')]()[_0x666c('0x17')](_0x666c('0x18'))[_0x666c('0x19')]([_0x666c('0x1a'),'scheduledat',_0x666c('0x1b'),_0x666c('0x1c'),_0x3ef912,_0x666c('0x1d'),'updatedAt',_0x666c('0x1e'),_0x666c('0x1f'),'recallme'],squel[_0x666c('0xb')]()[_0x666c('0x20')](_0x597729)[_0x666c('0x21')](_0x4123e7)[_0x666c('0xd')](_0x666c('0x22'),null,_0x666c('0x23')+_0x4123e7+_0x666c('0x24'))['join'](_0xccce0c,null,_0xccce0c+_0x666c('0xe')+_0x4123e7+'.'+_0x3ef912)[_0x666c('0x10')](_0x4123e7+_0x666c('0x25'),_0x3ed593)['where']('cm_contacts.createdAt\x20=\x20?',NOW)[_0x666c('0x10')]('cm_contacts.phone\x20NOT\x20IN\x20(?)',selectNotIn(_0x4123e7,_0xccce0c,_0x3ef912,_0x666c('0x18'),['\x22always\x22',_0x666c('0x26')]))[_0x666c('0x10')](_0x666c('0x27'),selectNotIn(_0x4123e7,_0xccce0c,_0x3ef912,_0x666c('0x18'),[_0x666c('0x28')])))[_0x666c('0x29')]();}function insertCmHopperBlack(_0x1cc440,_0x430360,_0x3b3137,_0x24e509){var _0x573e8e=[_0x666c('0x2a'),'cm_contacts.id','cm_contacts.ListId',_0x430360+'.'+_0x24e509,_0x666c('0x12'),_0x666c('0x13')];return squel[_0x666c('0x16')]()[_0x666c('0x17')]('cm_hopper_black')[_0x666c('0x19')]([_0x666c('0x1a'),'ContactId',_0x666c('0x1c'),_0x24e509,_0x666c('0x1d'),_0x666c('0x2b')],squel[_0x666c('0xb')]()[_0x666c('0x20')](_0x573e8e)[_0x666c('0x21')](_0x430360)[_0x666c('0xd')](_0x666c('0x22'),null,'cm_contacts.ListId\x20=\x20'+_0x430360+_0x666c('0x24'))[_0x666c('0xd')](_0x3b3137,null,_0x3b3137+_0x666c('0xe')+_0x430360+'.'+_0x24e509)[_0x666c('0x10')](_0x430360+'.CmListId\x20=\x20?',_0x1cc440)[_0x666c('0x10')](_0x666c('0x2c'),NOW)[_0x666c('0x10')]('cm_contacts.phone\x20NOT\x20IN\x20(?)',squel[_0x666c('0xb')]()[_0x666c('0xc')](_0x666c('0x1a'))['from'](_0x666c('0x2d'))['where'](_0x666c('0x2e'),_0x1cc440)[_0x666c('0x10')](_0x24e509+_0x666c('0x2f'),_0x430360+'.'+_0x24e509)))[_0x666c('0x29')]();}function insertCmContact(_0x251588,_0x2cbd6b,_0x5e2f8b,_0x1a09a1){var _0xabf574=_[_0x666c('0x30')](_[_0x666c('0x31')](_0x1a09a1),[_0x666c('0x1c'),_0x666c('0x32'),_0x666c('0x1d'),_0x666c('0x2b')]);return squel[_0x666c('0x16')]()['into'](_0x666c('0x22'))[_0x666c('0x19')](_0xabf574,squel['select']()[_0x666c('0x20')](_0xabf574)[_0x666c('0x21')](_0x2cbd6b)['where']('('+_0x5e2f8b[_0x666c('0xd')](',')+_0x666c('0x33'),squel[_0x666c('0xb')]()[_0x666c('0x20')](_0x5e2f8b)[_0x666c('0x21')]('cm_contacts')[_0x666c('0x10')](_0x666c('0x2e'),_0x251588))[_0x666c('0x10')](_0x666c('0x34'),squel[_0x666c('0xb')]()['field'](_0x666c('0x35'),_0x666c('0x36'))[_0x666c('0x21')](_0x2cbd6b)['group'](_0x5e2f8b[_0x666c('0xd')](','))))[_0x666c('0x29')]();}function handleStop(){logger[_0x666c('0x37')](_0x666c('0x38'));stopped=!![];}function handleUncaughtException(_0xa6c42f){logger[_0x666c('0x39')](_0xa6c42f[_0x666c('0x3a')]);process[_0x666c('0x3b')](0x1);}function handleError(_0x5e99ec,_0x13cbf5){stats[_0x666c('0x3c')]['push']({'name':_0x13cbf5['code'],'message':_0x13cbf5['message'],'row':_0x5e99ec});}function handleQuery(_0x539895){logger[_0x666c('0x37')](_0x539895);return db['sequelize']['query'](_0x539895)[_0x666c('0x3d')](function(_0x2dcb74){results[_0x666c('0x3e')](_0x2dcb74);})['catch'](function(_0x1d8f37){logger[_0x666c('0x39')](_0x1d8f37['message']);});}function main(_0x1a3a38,_0x4de615,_0x535f74,_0x176019){logger[_0x666c('0x37')](_0x666c('0x3f'),_0x1a3a38,JSON[_0x666c('0x40')](_0x4de615));process['send'](_0x666c('0x41'));var _0x2c4319=_0x4de615['binding'];var _0x15049e=_0x4de615[_0x666c('0x42')];var _0x163336=path[_0x666c('0xd')](config[_0x666c('0x43')],'server/files/tmp',_0x15049e+_0x666c('0x44'));var _0x37d995=_['keys'](_0x2c4319)[_0x666c('0xd')]();logger[_0x666c('0x37')]('header',_0x37d995);fs[_0x666c('0x45')](_0x163336,_0x37d995+'\x0a');Papa['parse'](fs[_0x666c('0x46')](_0x1a3a38),{'header':!![],'skipEmptyLines':!![],'step':function(_0x5ec84b,_0x3abc07){try{for(var _0xa8512b=0x0,_0x5dc72a=[];_0xa8512b<_0x5ec84b[_0x666c('0x47')][_0x666c('0x48')];_0xa8512b++){stats[_0x666c('0x49')]+=0x1;if(_0x5ec84b['errors'][_0xa8512b]){handleError(_0x5ec84b[_0x666c('0x47')][_0xa8512b],_0x5ec84b[_0x666c('0x3c')][_0xa8512b]);}else{var _0x49855b=[];for(var _0x1e2265 in _0x2c4319){if(_0x2c4319[_0x666c('0x4a')](_0x1e2265)){if(_0x5ec84b['data'][_0xa8512b][_0x2c4319[_0x1e2265]]){var _0x126a32=_[_0x666c('0x4b')](_0x5ec84b[_0x666c('0x47')][_0xa8512b][_0x2c4319[_0x1e2265]][_0x666c('0x4c')](/"/g,'\x27'));switch(_0x1e2265){case _0x666c('0x4d'):var _0x203cdb=moment(_0x126a32,_0x666c('0x9'),!![]);if(_0x203cdb[_0x666c('0x4e')]()){_0x5dc72a[_0x666c('0x3e')]('\x22'+_0x126a32+'\x22');}else{_0x49855b[_0x666c('0x3e')]('scheduledat\x20wrong\x20format\x20(YYYY-MM-DD\x20HH:mm:ss)');}break;case _0x666c('0x1e'):var _0x4584fa=parseInt(_0x126a32);_0x126a32=_[_0x666c('0x4f')](_0x4584fa)||_0x4584fa<0x0||_0x4584fa>0x4?_0x176019?0x3:0x2:_0x4584fa;_0x5dc72a[_0x666c('0x3e')]('\x22'+_0x126a32+'\x22');break;case'UserId':var _0x4709b6=parseInt(_0x126a32);if(_[_0x666c('0x50')](_0x4709b6)&&_['includes'](_0x535f74,_0x4709b6)){_0x5dc72a[_0x666c('0x3e')]('\x22'+_0x4709b6+'\x22');}else{_0x49855b[_0x666c('0x3e')]('agent\x20not\x20exists');}break;case _0x666c('0x51'):if(isEmail(_0x126a32)){_0x5dc72a['push']('\x22'+_0x126a32+'\x22');}else{_0x49855b['push'](_0x666c('0x52'));}break;case'dateOfBirth':var _0x2ee43b=moment(_0x126a32,'YYYY-MM-DD',!![]);if(_0x2ee43b[_0x666c('0x4e')]()){_0x5dc72a['push']('\x22'+_0x126a32+'\x22');}else{_0x49855b['push'](_0x666c('0x53'));}break;default:_0x5dc72a['push']('\x22'+_0x126a32+'\x22');}}else{switch(_0x1e2265){case'firstName':case _0x666c('0x1a'):_0x49855b[_0x666c('0x3e')](_0x1e2265+'\x20not\x20specified');break;default:_0x5dc72a[_0x666c('0x3e')]('\x22\x22');}}}}if(_0x49855b[_0x666c('0x48')]){handleError(_0x5ec84b[_0x666c('0x47')][_0xa8512b],{'code':_0x666c('0x54'),'message':_0x49855b[_0x666c('0xd')]()});}else{fs[_0x666c('0x55')](_0x163336,_0x5dc72a['join']()+'\x0a');}_0x5dc72a=[];}if(!(stats[_0x666c('0x49')]%0xc8)){socket['emit'](_0x666c('0x56')+_0x15049e,stats);stats[_0x666c('0x3c')]=[];}}if(stopped){logger[_0x666c('0x37')]('Abort\x20parser');_0x3abc07['abort']();}}catch(_0x1542d3){handleError(_0x5ec84b[_0x666c('0x47')][_0xa8512b],{'code':_0x666c('0x57'),'message':_0x1542d3[_0x666c('0x3a')]});logger[_0x666c('0x39')]('step',_0x1542d3[_0x666c('0x3a')]);}},'complete':function(){try{var _0x9625da=[];var _0x734e29='cm_contacts';if(_0x4de615['duplicates']&&_0x4de615[_0x666c('0x58')]['length']){_0x734e29=_0x666c('0x59')+_0x15049e;_0x9625da[_0x666c('0x3e')](_0x666c('0x5a')+_0x734e29+_0x666c('0x5b'));}var _0x182b38=util['format'](_0x666c('0x5c'),_0x163336,_0x734e29,_0x37d995,_0x4de615[_0x666c('0x1c')],_0x4de615['CompanyId']||null,NOW,NOW);if(_[_0x666c('0x5d')](_0x2c4319[_0x666c('0x4d')])){_0x182b38+=',\x20scheduledAt\x20=\x20NOW()';}_0x9625da['push'](_0x182b38);if(_0x4de615[_0x666c('0x58')]&&_0x4de615[_0x666c('0x58')][_0x666c('0x48')]){_0x9625da[_0x666c('0x3e')](insertCmContact(_0x4de615['ListId'],_0x734e29,_0x4de615[_0x666c('0x58')],_0x2c4319));_0x9625da['push'](_0x666c('0x5e')+_0x734e29+';');}_0x9625da[_0x666c('0x3e')](insertCmHopper(_0x4de615['ListId'],_0x666c('0x5f'),_0x666c('0x60'),_0x666c('0x61'),_0x176019));_0x9625da[_0x666c('0x3e')](insertCmHopperBlack(_0x4de615[_0x666c('0x1c')],_0x666c('0x62'),_0x666c('0x60'),_0x666c('0x61')));_0x9625da[_0x666c('0x3e')](insertCmHopper(_0x4de615['ListId'],_0x666c('0x63'),_0x666c('0x64'),'CampaignId',_0x176019));_0x9625da[_0x666c('0x3e')](insertCmHopperBlack(_0x4de615[_0x666c('0x1c')],'campaigns_has_cm_blacklists','campaigns',_0x666c('0x65')));BPromise['each'](_0x9625da,handleQuery)[_0x666c('0x66')](function(_0x5bc666){stats['finish']=!![];stats[_0x666c('0x67')]=_0x4de615[_0x666c('0x58')]&&_0x4de615[_0x666c('0x58')][_0x666c('0x48')]?results[0x2][_0x666c('0x67')]:results[0x0][_0x666c('0x67')];socket['emit']('contact:import:'+_0x15049e,stats);fs[_0x666c('0x68')](_0x1a3a38);fs[_0x666c('0x68')](_0x163336);process['exit'](0x0);})[_0x666c('0x69')](function(_0x2d0432){logger['error'](_0x2d0432[_0x666c('0x3a')]);process[_0x666c('0x3b')](0x1);});}catch(_0x5df23d){logger[_0x666c('0x39')](_0x666c('0x6a'),_0x5df23d['message']);process[_0x666c('0x3b')](0x1);}},'error':function(_0x719b94,_0x499c33,_0x1924ba,_0x3bd8d5){throw new Error(_0x3bd8d5);}});}function validate(){if(process[_0x666c('0x6b')]&&process['argv'][_0x666c('0x48')]<0x4){throw new Error(_0x666c('0x6c'));}var _0x1592f7=path[_0x666c('0xd')](config[_0x666c('0x43')],_0x666c('0x6d'),process['argv'][0x2]);if(!fs[_0x666c('0x6e')](_0x1592f7)){throw new Error(_0x666c('0x6f'));}var _0x2e02c8={};try{_0x2e02c8=JSON[_0x666c('0x70')](process['argv'][0x3]);if(!_0x2e02c8[_0x666c('0x71')]){throw new Error(_0x666c('0x72'));}if(!_0x2e02c8[_0x666c('0x71')][_0x666c('0x1a')]){throw new Error(_0x666c('0x73'));}if(!_0x2e02c8[_0x666c('0x71')][_0x666c('0x74')]){throw new Error(_0x666c('0x75'));}var _0x42c582=0x0;if(_0x2e02c8['binding'][_0x666c('0x1f')]){_0x42c582=0x1;}if(!_0x2e02c8[_0x666c('0x1c')]){throw new Error(_0x666c('0x76'));}}catch(_0x4d3544){throw new Error(_0x666c('0x77'));}var _0x2921cb=[];try{_0x2921cb=_[_0x666c('0x78')](JSON['parse'](process[_0x666c('0x6b')][0x4]),'id');}catch(_0x135b08){logger[_0x666c('0x37')](_0x666c('0x79'));}main(_0x1592f7,_0x2e02c8,_0x2921cb,_0x42c582);}validate();process['on'](_0x666c('0x7a'),handleStop);process['on']('uncaughtException',handleUncaughtException);
\ No newline at end of file
+var _0xf3e5=['includes','agent\x20not\x20exists','dateOfBirth','dateOfBirth\x20wrong\x20format\x20(YYYY-MM-DD)','firstName','\x20not\x20specified','SystemRow','emit','contact:import:','Abort\x20parser','abort','duplicates','cm_contacts_','CREATE\x20TABLE\x20','\x20LIKE\x20cm_contacts;','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','isNil','DROP\x20TABLE\x20','voice_queues_has_cm_lists','voice_queues','VoiceQueueId','voice_queues_has_cm_blacklists','campaigns_has_cm_lists','campaigns','CampaignId','campaigns_has_cm_blacklists','each','then','finish','affectedRows','unlink','complete','argv','root','existsSync','binding\x20doesn\x27t\x20exists','phone\x20is\x20mandatory','ListId\x20is\x20mandatory','map','No\x20agent\x20available','uncaughtException','path','lodash','util','bluebird','moment','squel','../../../config/environment','../../../config/logger','socket.io-emitter','format','YYYY-MM-DD\x20HH:mm:ss','test','field','phone','from','join','.id\x20=\x20','where','.dialCheckDuplicateType\x20IN\x20(','cm_contacts.phone','cm_contacts.scheduledat','cm_contacts.id','cm_contacts.ListId','cm_contacts.createdAt','cm_contacts.updatedAt','cm_contacts.priority','cm_contacts.UserId','insert','into','cm_hopper','ContactId','ListId','createdAt','updatedAt','priority','UserId','recallme','select','fields','.CmListId','cm_contacts.phone\x20NOT\x20IN\x20(?)','\x22always\x22','\x22onlyIfOpen\x22','toString','cm_hopper_black','fromQuery','cm_contacts','cm_contacts.ListId\x20=\x20','.CmListId\x20=\x20?','cm_contacts.createdAt\x20=\x20?','ListId\x20=\x20?','concat','keys',')\x20NOT\x20IN\x20?','id\x20IN\x20?','min_id','info','Received\x20SIGINT','message','exit','errors','code','sequelize','spread','push','catch','error','send','binding','socket_timestamp','server/files/tmp','.csv','header','parse','createReadStream','length','rows','data','hasOwnProperty','trim','replace','scheduledat','isValid','scheduledat\x20wrong\x20format\x20(YYYY-MM-DD\x20HH:mm:ss)','isNumber'];(function(_0x2ea802,_0x77184c){var _0x1cc258=function(_0x529519){while(--_0x529519){_0x2ea802['push'](_0x2ea802['shift']());}};_0x1cc258(++_0x77184c);}(_0xf3e5,0x1a7));var _0x5f3e=function(_0x2b5eae,_0x55010d){_0x2b5eae=_0x2b5eae-0x0;var _0x5f3ac9=_0xf3e5[_0x2b5eae];return _0x5f3ac9;};'use strict';var fs=require('fs');var path=require(_0x5f3e('0x0'));var _=require(_0x5f3e('0x1'));var Papa=require('papaparse');var util=require(_0x5f3e('0x2'));var BPromise=require(_0x5f3e('0x3'));var moment=require(_0x5f3e('0x4'));var squel=require(_0x5f3e('0x5'));var db=require('../../../mysqldb')['db'];var config=require(_0x5f3e('0x6'));var logger=require(_0x5f3e('0x7'))('import');var socket=require(_0x5f3e('0x8'))({'host':'localhost','port':0x18eb});var stats={'finish':![],'errors':[],'rows':0x0,'affectedRows':0x0};var results=[];var stopped=![];var NOW=moment()[_0x5f3e('0x9')](_0x5f3e('0xa'));function isEmail(_0x151d1e){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))*$/[_0x5f3e('0xb')](_0x151d1e);}function selectNotIn(_0x5a82a4,_0x59233f,_0x29b809,_0x31d000,_0x500555){return squel['select']()[_0x5f3e('0xc')](_0x5f3e('0xd'))[_0x5f3e('0xe')](_0x31d000)[_0x5f3e('0xf')](_0x59233f,null,_0x59233f+_0x5f3e('0x10')+_0x31d000+'.'+_0x29b809)[_0x5f3e('0x11')](_0x31d000+'.'+_0x29b809+'\x20=\x20'+_0x5a82a4+'.'+_0x29b809)['where'](_0x59233f+_0x5f3e('0x12')+_0x500555[_0x5f3e('0xf')]()+')');}function insertCmHopper(_0x4020da,_0x31c3b5,_0x4783ad,_0x56195a,_0x5790ac){var _0x985ba9=[_0x5f3e('0x13'),_0x5f3e('0x14'),_0x5f3e('0x15'),_0x5f3e('0x16'),_0x31c3b5+'.'+_0x56195a,_0x5f3e('0x17'),_0x5f3e('0x18'),_0x5f3e('0x19'),_0x5f3e('0x1a'),'\x22'+_0x5790ac+'\x22'];return squel[_0x5f3e('0x1b')]()[_0x5f3e('0x1c')](_0x5f3e('0x1d'))['fromQuery']([_0x5f3e('0xd'),'scheduledat',_0x5f3e('0x1e'),_0x5f3e('0x1f'),_0x56195a,_0x5f3e('0x20'),_0x5f3e('0x21'),_0x5f3e('0x22'),_0x5f3e('0x23'),_0x5f3e('0x24')],squel[_0x5f3e('0x25')]()[_0x5f3e('0x26')](_0x985ba9)[_0x5f3e('0xe')](_0x31c3b5)[_0x5f3e('0xf')]('cm_contacts',null,'cm_contacts.ListId\x20=\x20'+_0x31c3b5+_0x5f3e('0x27'))[_0x5f3e('0xf')](_0x4783ad,null,_0x4783ad+'.id\x20=\x20'+_0x31c3b5+'.'+_0x56195a)['where'](_0x31c3b5+'.CmListId\x20=\x20?',_0x4020da)[_0x5f3e('0x11')]('cm_contacts.createdAt\x20=\x20?',NOW)['where'](_0x5f3e('0x28'),selectNotIn(_0x31c3b5,_0x4783ad,_0x56195a,_0x5f3e('0x1d'),[_0x5f3e('0x29'),_0x5f3e('0x2a')]))['where'](_0x5f3e('0x28'),selectNotIn(_0x31c3b5,_0x4783ad,_0x56195a,_0x5f3e('0x1d'),[_0x5f3e('0x29')])))[_0x5f3e('0x2b')]();}function insertCmHopperBlack(_0x401bd9,_0x37a548,_0x1cbb39,_0x17e45c){var _0x37a9a6=[_0x5f3e('0x13'),_0x5f3e('0x15'),_0x5f3e('0x16'),_0x37a548+'.'+_0x17e45c,'cm_contacts.createdAt',_0x5f3e('0x18')];return squel[_0x5f3e('0x1b')]()[_0x5f3e('0x1c')](_0x5f3e('0x2c'))[_0x5f3e('0x2d')](['phone','ContactId',_0x5f3e('0x1f'),_0x17e45c,_0x5f3e('0x20'),'updatedAt'],squel[_0x5f3e('0x25')]()[_0x5f3e('0x26')](_0x37a9a6)[_0x5f3e('0xe')](_0x37a548)['join'](_0x5f3e('0x2e'),null,_0x5f3e('0x2f')+_0x37a548+_0x5f3e('0x27'))[_0x5f3e('0xf')](_0x1cbb39,null,_0x1cbb39+_0x5f3e('0x10')+_0x37a548+'.'+_0x17e45c)['where'](_0x37a548+_0x5f3e('0x30'),_0x401bd9)['where'](_0x5f3e('0x31'),NOW)['where']('cm_contacts.phone\x20NOT\x20IN\x20(?)',squel['select']()['field']('phone')['from'](_0x5f3e('0x2c'))['where'](_0x5f3e('0x32'),_0x401bd9)[_0x5f3e('0x11')](_0x17e45c+'\x20=\x20?',_0x37a548+'.'+_0x17e45c)))[_0x5f3e('0x2b')]();}function insertCmContact(_0x3577fa,_0x53956a,_0x324e12,_0x122567){var _0x35d9c3=_[_0x5f3e('0x33')](_[_0x5f3e('0x34')](_0x122567),[_0x5f3e('0x1f'),'CompanyId','createdAt',_0x5f3e('0x21')]);return squel[_0x5f3e('0x1b')]()[_0x5f3e('0x1c')]('cm_contacts')[_0x5f3e('0x2d')](_0x35d9c3,squel[_0x5f3e('0x25')]()['fields'](_0x35d9c3)[_0x5f3e('0xe')](_0x53956a)[_0x5f3e('0x11')]('('+_0x324e12[_0x5f3e('0xf')](',')+_0x5f3e('0x35'),squel[_0x5f3e('0x25')]()[_0x5f3e('0x26')](_0x324e12)[_0x5f3e('0xe')](_0x5f3e('0x2e'))['where'](_0x5f3e('0x32'),_0x3577fa))[_0x5f3e('0x11')](_0x5f3e('0x36'),squel['select']()[_0x5f3e('0xc')]('MIN(id)',_0x5f3e('0x37'))[_0x5f3e('0xe')](_0x53956a)['group'](_0x324e12[_0x5f3e('0xf')](','))))[_0x5f3e('0x2b')]();}function handleStop(){logger[_0x5f3e('0x38')](_0x5f3e('0x39'));stopped=!![];}function handleUncaughtException(_0x2814d1){logger['error'](_0x2814d1[_0x5f3e('0x3a')]);process[_0x5f3e('0x3b')](0x1);}function handleError(_0x515543,_0xf00446){stats[_0x5f3e('0x3c')]['push']({'name':_0xf00446[_0x5f3e('0x3d')],'message':_0xf00446[_0x5f3e('0x3a')],'row':_0x515543});}function handleQuery(_0x975ca1){logger[_0x5f3e('0x38')](_0x975ca1);return db[_0x5f3e('0x3e')]['query'](_0x975ca1)[_0x5f3e('0x3f')](function(_0x4ea427){results[_0x5f3e('0x40')](_0x4ea427);})[_0x5f3e('0x41')](function(_0x324fd0){logger[_0x5f3e('0x42')](_0x324fd0[_0x5f3e('0x3a')]);});}function main(_0x2766b9,_0x25c790,_0x2c7e25,_0x5c9569){logger['info']('main',_0x2766b9,JSON['stringify'](_0x25c790));process[_0x5f3e('0x43')]('start');var _0x185313=_0x25c790[_0x5f3e('0x44')];var _0x47b8e1=_0x25c790[_0x5f3e('0x45')];var _0x1fe3bf=path[_0x5f3e('0xf')](config['root'],_0x5f3e('0x46'),_0x47b8e1+_0x5f3e('0x47'));var _0x272d34=_['keys'](_0x185313)[_0x5f3e('0xf')]();logger[_0x5f3e('0x38')](_0x5f3e('0x48'),_0x272d34);fs['writeFileSync'](_0x1fe3bf,_0x272d34+'\x0a');Papa[_0x5f3e('0x49')](fs[_0x5f3e('0x4a')](_0x2766b9),{'header':!![],'skipEmptyLines':!![],'step':function(_0x141d7d,_0x27ea6c){try{for(var _0xbc27a6=0x0,_0x28e5eb=[];_0xbc27a6<_0x141d7d['data'][_0x5f3e('0x4b')];_0xbc27a6++){stats[_0x5f3e('0x4c')]+=0x1;if(_0x141d7d['errors'][_0xbc27a6]){handleError(_0x141d7d[_0x5f3e('0x4d')][_0xbc27a6],_0x141d7d[_0x5f3e('0x3c')][_0xbc27a6]);}else{var _0x15c277=[];for(var _0x2284da in _0x185313){if(_0x185313[_0x5f3e('0x4e')](_0x2284da)){if(_0x141d7d[_0x5f3e('0x4d')][_0xbc27a6][_0x185313[_0x2284da]]){var _0x10166e=_[_0x5f3e('0x4f')](_0x141d7d['data'][_0xbc27a6][_0x185313[_0x2284da]][_0x5f3e('0x50')](/"/g,'\x27'));switch(_0x2284da){case _0x5f3e('0x51'):var _0x1dd0c0=moment(_0x10166e,_0x5f3e('0xa'),!![]);if(_0x1dd0c0[_0x5f3e('0x52')]()){_0x28e5eb[_0x5f3e('0x40')]('\x22'+_0x10166e+'\x22');}else{_0x15c277[_0x5f3e('0x40')](_0x5f3e('0x53'));}break;case _0x5f3e('0x22'):var _0x1df13e=parseInt(_0x10166e);_0x10166e=_['isNaN'](_0x1df13e)||_0x1df13e<0x0||_0x1df13e>0x4?_0x5c9569?0x3:0x2:_0x1df13e;_0x28e5eb['push']('\x22'+_0x10166e+'\x22');break;case'UserId':var _0x4b7773=parseInt(_0x10166e);if(_[_0x5f3e('0x54')](_0x4b7773)&&_[_0x5f3e('0x55')](_0x2c7e25,_0x4b7773)){_0x28e5eb[_0x5f3e('0x40')]('\x22'+_0x4b7773+'\x22');}else{_0x15c277['push'](_0x5f3e('0x56'));}break;case'email':if(isEmail(_0x10166e)){_0x28e5eb['push']('\x22'+_0x10166e+'\x22');}else{_0x15c277['push']('email\x20wrong\x20format');}break;case _0x5f3e('0x57'):var _0x300cae=moment(_0x10166e,'YYYY-MM-DD',!![]);if(_0x300cae[_0x5f3e('0x52')]()){_0x28e5eb[_0x5f3e('0x40')]('\x22'+_0x10166e+'\x22');}else{_0x15c277[_0x5f3e('0x40')](_0x5f3e('0x58'));}break;default:_0x28e5eb['push']('\x22'+_0x10166e+'\x22');}}else{switch(_0x2284da){case _0x5f3e('0x59'):case _0x5f3e('0xd'):_0x15c277[_0x5f3e('0x40')](_0x2284da+_0x5f3e('0x5a'));break;default:_0x28e5eb[_0x5f3e('0x40')]('\x22\x22');}}}}if(_0x15c277[_0x5f3e('0x4b')]){handleError(_0x141d7d[_0x5f3e('0x4d')][_0xbc27a6],{'code':_0x5f3e('0x5b'),'message':_0x15c277['join']()});}else{fs['appendFileSync'](_0x1fe3bf,_0x28e5eb['join']()+'\x0a');}_0x28e5eb=[];}if(!(stats[_0x5f3e('0x4c')]%0xc8)){socket[_0x5f3e('0x5c')](_0x5f3e('0x5d')+_0x47b8e1,stats);stats[_0x5f3e('0x3c')]=[];}}if(stopped){logger['info'](_0x5f3e('0x5e'));_0x27ea6c[_0x5f3e('0x5f')]();}}catch(_0x2aca1f){handleError(_0x141d7d[_0x5f3e('0x4d')][_0xbc27a6],{'code':'SystemError','message':_0x2aca1f[_0x5f3e('0x3a')]});logger[_0x5f3e('0x42')]('step',_0x2aca1f[_0x5f3e('0x3a')]);}},'complete':function(){try{var _0x30262f=[];var _0x542b3a=_0x5f3e('0x2e');if(_0x25c790[_0x5f3e('0x60')]&&_0x25c790[_0x5f3e('0x60')][_0x5f3e('0x4b')]){_0x542b3a=_0x5f3e('0x61')+_0x47b8e1;_0x30262f[_0x5f3e('0x40')](_0x5f3e('0x62')+_0x542b3a+_0x5f3e('0x63'));}var _0x48c61e=util[_0x5f3e('0x9')](_0x5f3e('0x64'),_0x1fe3bf,_0x542b3a,_0x272d34,_0x25c790['ListId'],_0x25c790[_0x5f3e('0x65')]||null,NOW,NOW);if(_[_0x5f3e('0x66')](_0x185313[_0x5f3e('0x51')])){_0x48c61e+=',\x20scheduledAt\x20=\x20NOW()';}_0x30262f[_0x5f3e('0x40')](_0x48c61e);if(_0x25c790[_0x5f3e('0x60')]&&_0x25c790[_0x5f3e('0x60')][_0x5f3e('0x4b')]){_0x30262f['push'](insertCmContact(_0x25c790[_0x5f3e('0x1f')],_0x542b3a,_0x25c790['duplicates'],_0x185313));_0x30262f[_0x5f3e('0x40')](_0x5f3e('0x67')+_0x542b3a+';');}_0x30262f[_0x5f3e('0x40')](insertCmHopper(_0x25c790[_0x5f3e('0x1f')],_0x5f3e('0x68'),_0x5f3e('0x69'),_0x5f3e('0x6a'),_0x5c9569));_0x30262f[_0x5f3e('0x40')](insertCmHopperBlack(_0x25c790[_0x5f3e('0x1f')],_0x5f3e('0x6b'),_0x5f3e('0x69'),_0x5f3e('0x6a')));_0x30262f[_0x5f3e('0x40')](insertCmHopper(_0x25c790['ListId'],_0x5f3e('0x6c'),_0x5f3e('0x6d'),_0x5f3e('0x6e'),_0x5c9569));_0x30262f[_0x5f3e('0x40')](insertCmHopperBlack(_0x25c790[_0x5f3e('0x1f')],_0x5f3e('0x6f'),'campaigns',_0x5f3e('0x6e')));BPromise[_0x5f3e('0x70')](_0x30262f,handleQuery)[_0x5f3e('0x71')](function(_0x500825){stats[_0x5f3e('0x72')]=!![];stats[_0x5f3e('0x73')]=_0x25c790['duplicates']&&_0x25c790[_0x5f3e('0x60')]['length']?results[0x2][_0x5f3e('0x73')]:results[0x0][_0x5f3e('0x73')];socket[_0x5f3e('0x5c')](_0x5f3e('0x5d')+_0x47b8e1,stats);fs[_0x5f3e('0x74')](_0x2766b9);fs[_0x5f3e('0x74')](_0x1fe3bf);process[_0x5f3e('0x3b')](0x0);})[_0x5f3e('0x41')](function(_0xea1d4a){logger['error'](_0xea1d4a[_0x5f3e('0x3a')]);process[_0x5f3e('0x3b')](0x1);});}catch(_0x8fad66){logger[_0x5f3e('0x42')](_0x5f3e('0x75'),_0x8fad66[_0x5f3e('0x3a')]);process[_0x5f3e('0x3b')](0x1);}},'error':function(_0x2c19f6,_0x2a1968,_0x32c3cb,_0x480d5a){throw new Error(_0x480d5a);}});}function validate(){if(process[_0x5f3e('0x76')]&&process['argv']['length']<0x4){throw new Error('arguments\x20<filename>\x20<parameters>\x20<agents>');}var _0x4725a3=path['join'](config[_0x5f3e('0x77')],'server/files/tmp',process[_0x5f3e('0x76')][0x2]);if(!fs[_0x5f3e('0x78')](_0x4725a3)){throw new Error('file\x20doesn\x27t\x20exists');}var _0x16fa6d={};try{_0x16fa6d=JSON[_0x5f3e('0x49')](process[_0x5f3e('0x76')][0x3]);if(!_0x16fa6d['binding']){throw new Error(_0x5f3e('0x79'));}if(!_0x16fa6d[_0x5f3e('0x44')][_0x5f3e('0xd')]){throw new Error(_0x5f3e('0x7a'));}if(!_0x16fa6d[_0x5f3e('0x44')][_0x5f3e('0x59')]){throw new Error('firstName\x20is\x20mandatory');}var _0x4aa66b=0x0;if(_0x16fa6d[_0x5f3e('0x44')]['UserId']){_0x4aa66b=0x1;}if(!_0x16fa6d[_0x5f3e('0x1f')]){throw new Error(_0x5f3e('0x7b'));}}catch(_0x382e36){throw new Error('body\x20id\x20mandatory');}var _0x3db378=[];try{_0x3db378=_[_0x5f3e('0x7c')](JSON[_0x5f3e('0x49')](process['argv'][0x4]),'id');}catch(_0x5eb163){logger[_0x5f3e('0x38')](_0x5f3e('0x7d'));}main(_0x4725a3,_0x16fa6d,_0x3db378,_0x4aa66b);}validate();process['on']('SIGINT',handleStop);process['on'](_0x5f3e('0x7e'),handleUncaughtException);
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff