var {getToken,category_id,customeId,httprequest}=require("./httprequest") var querystring = require('querystring'); function addPool(tomail,callbackFunc,errCallBackFunc){ var url="http://edmapi.rushmail.com/api.php?module=wc-pool&action=pool-add"; var pdata={token: getToken(),customer_id:customeId,category_id:category_id,name:tomail}; var post_data = querystring.stringify(pdata) httprequest(url,post_data,function(ret){ if(ret.code=="success"){ console.log("添加地址池成功",ret.status) if(callbackFunc) callbackFunc(ret.status) } else{ console.log("添加地址池失败",ret.message); if(errCallBackFunc) { errCallBackFunc(ret.message); } } }) } var cachePools={}; function searchPool(tomail,name,callbackFunc,errCallBackFunc){ if(cachePools[tomail]){ if(callbackFunc) callbackFunc(cachePools[tomail]); return; } var url="http://edmapi.rushmail.com/api.php?module=wc-pool&action=pool-list"; var pdata={token: getToken(),customer_id:customeId,category_id:category_id} var post_data = querystring.stringify(pdata) httprequest(url,post_data,function(ret){ if(ret.status){ var result=0; for(var r of ret.data.pool_list){ cachePools[r.name]=r.pool_id; if(r.name==tomail) result=r.pool_id; } if(result==0){ addPool(tomail,function(poolId){ console.log("添加地址池成功",poolId) cachePools[tomail]=poolId; addEmail(tomail,name,poolId,function(ret){ if(callbackFunc){ callbackFunc(poolId); } }) }) }else{ if(callbackFunc) callbackFunc(result); } } else{ console.log("查询地址池失败",ret); if(errCallBackFunc){ errCallBackFunc("查询地址池失败") } } },errCallBackFunc) } function addEmail(tomail,username,poolId,callbackFunc,errCallBack){ // var email="66905212@qq.com\\t王立忠\\t\\n"; var email=`${tomail}\\t${username}\\t\\n`; var pdata={token: getToken(),customer_id:customeId,data:email,pool_id:poolId} var post_data = querystring.stringify(pdata) httprequest("http://edmapi.rushmail.com/api.php?module=wc-pool&action=address-add",post_data,function(ret){ if(ret.code=="success"){ console.log("发送人添加成功"); if(callbackFunc){ callbackFunc(ret.status); } }else{ console.log("发送人添加失败",ret.message) if(errCallBack){ errCallBack } } }) } exports.searchPool=searchPool;