|
var restify = require('restify');
|
var path=require("path")
|
var ip_addr = '127.0.0.1';
|
var port = '8900';
|
var maxLength=5*1024 *1024; //最大请求
|
var server = restify.createServer({
|
name : "sendmail"
|
});
|
var fs=require("fs");
|
const { getTaskReportInfoAsync,getTaskReportInfoWeekAsync } = require('./mail/task');
|
var plugins=restify.plugins;
|
server.use(plugins.acceptParser(server.acceptable));
|
server.use(plugins.queryParser());
|
server.use(plugins.bodyParser({ maxBodySize:maxLength }));
|
server.listen(port ,ip_addr, function(){
|
console.log('%s listening at %s ', server.name , server.url);
|
});
|
|
var PATH="/mail";
|
function responseOK(res,result,data,info){
|
return res.send({result:result,message:info,data:data});
|
|
}
|
|
server.post({path : PATH+"/sendattach" , version: '0.0.1'} ,sendMailAttach);
|
async function sendMailAttach(req, res , next){
|
res.setHeader('Access-Control-Allow-Origin','*');
|
|
var query = req.body;
|
if(!query){
|
return responseOK(res,false,null,"参数有误，请输入正确的参数 0")
|
}
|
if(req.getContentLength()>=maxLength){
|
return responseOK(res,false,null,"附件内容大小，超过了5M")
|
}
|
console.log(query);
|
|
var account=query.account;
|
var receivename=query.receivename; //接收人名称
|
var toemail=query.toemail;
|
var title=query.title;
|
var content=query.content;
|
if(!account ||!toemail ||!title ||!content || !receivename){
|
return responseOK(res,false,null,"参数有误，请输入正确的参数 -1")
|
}
|
if(account!="rushmail"){
|
return responseOK(res,false,null,"参数有误，请输入正确的参数 -2")
|
}
|
var attachment=[]
|
console.log(req.files)
|
if(req.files){
|
var keys=Object.keys(req.files);
|
for(var key of keys){
|
var sourceStr=req.files[key].path;
|
var destStr=path.join("./temp/",key);
|
fs.copyFileSync(sourceStr,destStr);
|
attachment.push(destStr);
|
}
|
|
}
|
if(attachment.length>0){
|
var {sendWidthAttachmentAsync} = require("./sendmail");
|
var ret=await sendWidthAttachmentAsync(receivename,toemail,title,content,attachment)
|
.then((e)=>{return {status:true,data:e}})
|
.catch((e)=>{return {status:false,data:e}})
|
//发附件
|
|
if(ret.status){
|
for(var att of attachment){
|
fs.unlinkSync(att);
|
}
|
return responseOK(res,true,{taskid:ret.data},"发送成功")
|
}else{
|
return responseOK(res,true,null,"发送失败"+ret.data);
|
}
|
|
}else{
|
var {sendAsync} = require("./sendmail");
|
var ret=await sendAsync(receivename,toemail,title,content)
|
.then((e)=>{return {status:true,data:e}})
|
.catch((e)=>{return {status:false,data:e}})
|
|
if(ret.status){
|
return responseOK(res,true,{taskid:ret.data},"发送成功")
|
}else{
|
return responseOK(res,true,null,"发送失败"+ret.data)
|
}
|
}
|
|
}
|
|
|
|
server.post({path : PATH+"/send" , version: '0.0.1'} ,sendMail);
|
async function sendMail(req, res , next){
|
res.setHeader('Access-Control-Allow-Origin','*');
|
var query = req.body;
|
if(!query){
|
return responseOK(res,false,null,"参数有误，请输入正确的参数 0")
|
}
|
|
var account=query.account;
|
var receivename=query.receivename; //接收人名称
|
var toemail=query.toemail;
|
var title=query.title;
|
var content=query.content;
|
if(!account ||!toemail ||!title ||!content || !receivename){
|
return responseOK(res,false,null,"参数有误，请输入正确的参数 -1")
|
}
|
if(account!="rushmail"){
|
return responseOK(res,false,null,"参数有误，请输入正确的参数 -2")
|
}
|
var attachment=query.attachment;
|
if(attachment){
|
if(attachment instanceof Array){
|
for(var att of attachment){
|
if(!fs.existsSync(att)){
|
// console.log("attachments")
|
return responseOK(res,false,null,"附件不存在!"+att);
|
}
|
}
|
}else{
|
if(!fs.existsSync(attachment)){
|
return responseOK(res,false,null,"附件不存在!");
|
}
|
}
|
|
var {sendWidthAttachmentAsync} = require("./sendmail");
|
var ret=await sendWidthAttachmentAsync(receivename,toemail,title,content,attachment)
|
.then((e)=>{return {status:true,data:e}})
|
.catch((e)=>{return {status:false,data:e}})
|
//发附件
|
|
if(ret.status){
|
return responseOK(res,true,{taskid:ret.data},"发送成功")
|
}else{
|
return responseOK(res,true,null,"发送失败"+ret.data);
|
}
|
}else{
|
var {sendAsync} = require("./sendmail");
|
var ret=await sendAsync(receivename,toemail,title,content)
|
.then((e)=>{return {status:true,data:e}})
|
.catch((e)=>{return {status:false,data:e}})
|
|
if(ret.status){
|
return responseOK(res,true,{taskid:ret.data},"发送成功")
|
}else{
|
return responseOK(res,true,null,"发送失败"+ret.data)
|
}
|
}
|
|
|
}
|
|
server.post({path : PATH+"/report" , version: '0.0.1'} ,searchReport);
|
async function searchReport(req, res , next){
|
res.setHeader('Access-Control-Allow-Origin','*');
|
var query = req.body;
|
if(!query){
|
return responseOK(res,false,null,"参数有误，请输入正确的参数 0")
|
}
|
// console.log(req.body)
|
var date=query.date;
|
var account=query.account;
|
if(account!="rushmail"){
|
return responseOK(res,false,null,"参数有误，请输入正确的参数 -4")
|
}
|
if(!date){
|
return responseOK(res,false,null,"参数有误，请输入正确的参数 -5")
|
}
|
var ret=await getTaskReportInfoAsync(date)
|
.then((e)=>{return {status:true,data:e}})
|
.catch((e)=>{return {status:false,data:e}})
|
if(ret.status)
|
return responseOK(res,true,ret.data,"获取报告成功");
|
else
|
return responseOK(res,false,null,"获取报告失败"+ret.data);
|
}
|
|
|
server.post({path : PATH+"/reportweek" , version: '0.0.1'} ,searchReportWeek);
|
|
async function searchReportWeek(req, res , next){
|
res.setHeader('Access-Control-Allow-Origin','*');
|
var query = req.body;
|
if(!query){
|
return responseOK(res,false,null,"参数有误，请输入正确的参数 0")
|
}
|
// console.log(req.body)
|
|
|
var account=query.account;
|
if(account!="rushmail"){
|
return responseOK(res,false,null,"参数有误，请输入正确的参数 -4")
|
}
|
//一周内的
|
var date=new Date();
|
var ret=await getTaskReportInfoWeekAsync(date)
|
.then((e)=>{return {status:true,data:e}})
|
.catch((e)=>{return {status:false,data:e}})
|
if(ret.status)
|
return responseOK(res,true,ret.data,"获取报告成功");
|
else
|
return responseOK(res,false,null,"获取报告失败"+ret.data);
|
}
|
