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;
|