584 lines
23 KiB
C#
584 lines
23 KiB
C#
using System.Web;
|
||
using JNPF.Common.Configuration;
|
||
using JNPF.Common.Core.Manager;
|
||
using JNPF.Common.Core.Manager.Files;
|
||
using JNPF.Common.Enums;
|
||
using JNPF.Common.Extension;
|
||
using JNPF.Common.Filter;
|
||
using JNPF.Common.Models;
|
||
using JNPF.Common.Options;
|
||
using JNPF.Common.Security;
|
||
using JNPF.DependencyInjection;
|
||
using JNPF.DynamicApiController;
|
||
using JNPF.Extend.Entitys;
|
||
using JNPF.Extend.Entitys.Dto.Email;
|
||
using JNPF.Extras.Thirdparty.Email;
|
||
using JNPF.FriendlyException;
|
||
using JNPF.LinqBuilder;
|
||
using Mapster;
|
||
using Microsoft.AspNetCore.Mvc;
|
||
using Newtonsoft.Json.Linq;
|
||
using SqlSugar;
|
||
|
||
namespace JNPF.Extend;
|
||
|
||
/// <summary>
|
||
/// 邮件收发
|
||
/// 版 本：V3.2
|
||
/// 版 权：拓通智联科技有限公司（http://www.tuotong-tech.com）
|
||
/// 日 期：2021-06-01 .
|
||
/// </summary>
|
||
[ApiDescriptionSettings(Tag = "Extend", Name = "Email", Order = 600)]
|
||
[Route("api/extend/[controller]")]
|
||
public class EmailService : IDynamicApiController, ITransient
|
||
{
|
||
private readonly ISqlSugarRepository<EmailReceiveEntity> _repository;
|
||
private readonly ITenant _db;
|
||
private readonly IUserManager _userManager;
|
||
private readonly IFileManager _fileManager;
|
||
|
||
public EmailService(ISqlSugarRepository<EmailReceiveEntity> repository, IUserManager userManager, ISqlSugarClient context, IFileManager fileManager)
|
||
{
|
||
_repository = repository;
|
||
_userManager = userManager;
|
||
_db = context.AsTenant();
|
||
_fileManager = fileManager;
|
||
}
|
||
|
||
#region Get
|
||
|
||
/// <summary>
|
||
/// (带分页)获取邮件列表(收件箱、标星件、草稿箱、已发送).
|
||
/// </summary>
|
||
/// <param name="input">请求参数</param>
|
||
/// <returns></returns>
|
||
[HttpGet("")]
|
||
public async Task<dynamic> GetList([FromQuery] EmailListQuery input)
|
||
{
|
||
switch (input.type)
|
||
{
|
||
case "inBox"://收件箱
|
||
return await GetReceiveList(input);
|
||
case "star"://标星件
|
||
return await GetStarredList(input);
|
||
case "draft"://草稿箱
|
||
return await GetDraftList(input);
|
||
case "sent"://已发送
|
||
return await GetSentList(input);
|
||
default:
|
||
return PageResult<EmailListOutput>.SqlSugarPageResult(new SqlSugarPagedList<EmailListOutput>());
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 信息（收件/发件）.
|
||
/// </summary>
|
||
/// <param name="id">主键值.</param>
|
||
/// <returns></returns>
|
||
[HttpGet("{id}")]
|
||
public async Task<dynamic> GetInfo_Api(string id)
|
||
{
|
||
var output = new EmailInfoOutput();
|
||
var data = await GetInfo(id);
|
||
var jobj = data.ToObject<JObject>();
|
||
if (jobj.ContainsKey("Read"))
|
||
{
|
||
var entity = data.Adapt<EmailReceiveEntity>();
|
||
output = entity.Adapt<EmailInfoOutput>();
|
||
output.bodyText = HttpUtility.HtmlDecode(entity.BodyText);
|
||
}
|
||
else
|
||
{
|
||
var entity = data.Adapt<EmailSendEntity>();
|
||
output = entity.Adapt<EmailInfoOutput>();
|
||
output.bodyText = HttpUtility.HtmlDecode(entity.BodyText);
|
||
}
|
||
return output;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 信息（配置）.
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpGet("Config")]
|
||
public async Task<dynamic> GetConfigInfo_Api()
|
||
{
|
||
return (await GetConfigInfo()).Adapt<EmailConfigInfoOutput>();
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region Post
|
||
|
||
/// <summary>
|
||
/// 删除.
|
||
/// </summary>
|
||
/// <param name="id">主键值.</param>
|
||
/// <returns></returns>
|
||
[HttpDelete("{id}")]
|
||
public async Task Delete(string id)
|
||
{
|
||
try
|
||
{
|
||
_db.BeginTran();
|
||
|
||
var entity = await GetInfo(id);
|
||
if (entity is EmailReceiveEntity)
|
||
{
|
||
//删除邮件
|
||
var mailConfig = await GetConfigInfo();
|
||
var mailReceiveEntity = entity as EmailReceiveEntity;
|
||
MailUtil.Delete(new MailParameterInfo { Account = mailConfig.Account, Password = mailConfig.Password, POP3Host = mailConfig.POP3Host, POP3Port = mailConfig.POP3Port.ParseToInt() }, mailReceiveEntity.MID);
|
||
}
|
||
//删除数据
|
||
var isOk = false;
|
||
if (entity is EmailReceiveEntity)
|
||
isOk = await _repository.AsSugarClient().Updateable((EmailReceiveEntity)entity).CallEntityMethod(m => m.Delete()).UpdateColumns(it => new { it.DeleteMark, it.DeleteTime, it.DeleteUserId }).ExecuteCommandHasChangeAsync();
|
||
else
|
||
isOk = await _repository.AsSugarClient().Updateable((EmailSendEntity)entity).CallEntityMethod(m => m.Delete()).UpdateColumns(it => new { it.DeleteMark, it.DeleteTime, it.DeleteUserId }).ExecuteCommandHasChangeAsync();
|
||
if (!isOk)
|
||
throw Oops.Oh(ErrorCode.COM1002);
|
||
|
||
_db.CommitTran();
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
_db.RollbackTran();
|
||
throw Oops.Oh(ErrorCode.COM1002);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 设置已读邮件.
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <returns></returns>
|
||
[HttpPut("{id}/Actions/Read")]
|
||
public async Task ReceiveRead(string id)
|
||
{
|
||
var isOk = await _repository.AsSugarClient().Updateable<EmailReceiveEntity>().SetColumns(it => new EmailReceiveEntity()
|
||
{
|
||
Read = 1,
|
||
LastModifyUserId = _userManager.UserId,
|
||
LastModifyTime = SqlFunc.GetDate()
|
||
}).Where(it => it.Id.Equals(id)).ExecuteCommandHasChangeAsync();
|
||
if (!isOk)
|
||
throw Oops.Oh(ErrorCode.COM1008);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 设置未读邮件.
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <returns></returns>
|
||
[HttpPut("{id}/Actions/Unread")]
|
||
public async Task ReceiveUnread(string id)
|
||
{
|
||
var isOk = await _repository.AsSugarClient().Updateable<EmailReceiveEntity>().SetColumns(it => new EmailReceiveEntity()
|
||
{
|
||
Read = 0,
|
||
LastModifyUserId = _userManager.UserId,
|
||
LastModifyTime = SqlFunc.GetDate()
|
||
}).Where(it => it.Id.Equals(id)).ExecuteCommandHasChangeAsync();
|
||
if (!isOk)
|
||
throw Oops.Oh(ErrorCode.COM1008);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 设置星标邮件
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <returns></returns>
|
||
[HttpPut("{id}/Actions/Star")]
|
||
public async Task ReceiveYesStarred(string id)
|
||
{
|
||
var isOk = await _repository.AsSugarClient().Updateable<EmailReceiveEntity>().SetColumns(it => new EmailReceiveEntity()
|
||
{
|
||
Starred = 1,
|
||
LastModifyUserId = _userManager.UserId,
|
||
LastModifyTime = SqlFunc.GetDate()
|
||
}).Where(it => it.Id.Equals(id)).ExecuteCommandHasChangeAsync();
|
||
if (!isOk)
|
||
throw Oops.Oh(ErrorCode.COM1008);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 设置取消星标.
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <returns></returns>
|
||
[HttpPut("{id}/Actions/Unstar ")]
|
||
public async Task ReceiveNoStarred(string id)
|
||
{
|
||
var isOk = await _repository.AsSugarClient().Updateable<EmailReceiveEntity>().SetColumns(it => new EmailReceiveEntity()
|
||
{
|
||
Starred = 0,
|
||
LastModifyUserId = _userManager.UserId,
|
||
LastModifyTime = SqlFunc.GetDate()
|
||
}).Where(it => it.Id.Equals(id)).ExecuteCommandHasChangeAsync();
|
||
if (!isOk)
|
||
throw Oops.Oh(ErrorCode.COM1008);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 收邮件.
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost("Receive")]
|
||
public async Task<dynamic> Receive()
|
||
{
|
||
var mailConfig = await GetConfigInfo();
|
||
if (mailConfig != null)
|
||
{
|
||
var mailAccount = mailConfig.Adapt<MailParameterInfo>();
|
||
if (MailUtil.CheckConnected(mailAccount))
|
||
{
|
||
new List<EmailReceiveEntity>();
|
||
var startTime = Convert.ToDateTime(DateTime.Now.ToString("yyyy-MM-dd") + " 00:00");
|
||
var endTime = Convert.ToDateTime(DateTime.Now.ToString("yyyy-MM-dd") + " 23:59");
|
||
var receiveCount = await _repository.AsSugarClient().Queryable<EmailReceiveEntity>().CountAsync(x => x.MAccount == mailConfig.Account && SqlFunc.Between(x.CreatorTime, startTime, endTime));
|
||
List<EmailReceiveEntity> entitys = MailUtil.Get(mailAccount, receiveCount).Select(item => new EmailReceiveEntity
|
||
{
|
||
MAccount = mailConfig.Account,
|
||
MID = item.UID,
|
||
Sender = item.To,
|
||
SenderName = item.ToName,
|
||
Subject = item.Subject,
|
||
BodyText = HttpUtility.HtmlEncode(item.BodyText),
|
||
Attachment = item.Attachment.ToJsonString(),
|
||
Date = item.Date,
|
||
Read = 0
|
||
}).ToList();
|
||
|
||
if (entitys.Count > 0)
|
||
{
|
||
await _repository.AsSugarClient().Insertable(entitys).CallEntityMethod(m => m.Creator()).ExecuteCommandAsync();
|
||
}
|
||
|
||
return entitys.Count;
|
||
}
|
||
else
|
||
{
|
||
throw Oops.Oh(ErrorCode.Ex0003);
|
||
}
|
||
}
|
||
else
|
||
{
|
||
throw Oops.Oh(ErrorCode.Ex0004);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 存草稿.
|
||
/// </summary>
|
||
/// <param name="input">对象实体.</param>
|
||
/// <returns></returns>
|
||
[HttpPost("Actions/SaveDraft")]
|
||
public async Task SaveDraft([FromBody] EmailActionsSaveDraftInput input)
|
||
{
|
||
var entity = input.Adapt<EmailSendEntity>();
|
||
entity.BodyText = HttpUtility.HtmlEncode(entity.BodyText);
|
||
entity.To = input.recipient;
|
||
entity.Sender = App.GetConfig<AppOptions>("JNPF_App", true).ErrorReportTo;
|
||
var isOk = 0;
|
||
entity.State = -1;
|
||
if (entity.Id.IsEmpty())
|
||
{
|
||
isOk = await _repository.AsSugarClient().Insertable(entity).CallEntityMethod(m => m.Creator()).ExecuteCommandAsync();
|
||
}
|
||
else
|
||
{
|
||
isOk = await _repository.AsSugarClient().Updateable(entity).IgnoreColumns(ignoreAllNullColumns: true).CallEntityMethod(m => m.LastModify()).ExecuteCommandAsync();
|
||
}
|
||
|
||
if (isOk < 1)
|
||
throw Oops.Oh(ErrorCode.COM1008);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 发邮件.
|
||
/// </summary>
|
||
/// <param name="input">对象实体.</param>
|
||
/// <returns></returns>
|
||
[HttpPost("")]
|
||
public async Task SaveSent([FromBody] EmailSendInput input)
|
||
{
|
||
var entity = input.Adapt<EmailSendEntity>();
|
||
var mailConfig = await GetConfigInfo();
|
||
foreach (var item in input.recipient.Split(","))
|
||
{
|
||
if (!item.IsEmail())
|
||
throw Oops.Oh(ErrorCode.Ex0003);
|
||
if (mailConfig != null)
|
||
{
|
||
entity.BodyText = HttpUtility.HtmlEncode(entity.BodyText);
|
||
entity.To = item;
|
||
entity.Sender = App.GetConfig<AppOptions>("JNPF_App", true).ErrorReportTo;
|
||
entity.State = 1;
|
||
var isOk = 0;
|
||
if (entity.Id.IsEmpty())
|
||
{
|
||
entity.Sender = mailConfig.Account;
|
||
isOk = await _repository.AsSugarClient().Insertable(entity).CallEntityMethod(m => m.Creator()).ExecuteCommandAsync();
|
||
}
|
||
else
|
||
{
|
||
isOk = await _repository.AsSugarClient().Updateable(entity).IgnoreColumns(ignoreAllNullColumns: true).CallEntityMethod(m => m.LastModify()).ExecuteCommandAsync();
|
||
}
|
||
//拷贝文件,注意：从临时文件夹拷贝到邮件文件夹
|
||
var attachmentList = entity.Attachment.ToList<MailFileParameterInfo>();
|
||
var temporaryFile = FileVariable.TemporaryFilePath;
|
||
var mailFilePath = FileVariable.EmailFilePath;
|
||
foreach (MailFileParameterInfo mailFile in attachmentList)
|
||
{
|
||
FileHelper.MoveFile(Path.Combine(temporaryFile, mailFile.fileId), Path.Combine(mailFilePath, mailFile.fileId));
|
||
mailFile.fileName = mailFile.name;
|
||
}
|
||
//发送邮件
|
||
var mailModel = new MailInfo();
|
||
mailModel.To = entity.To;
|
||
mailModel.CC = entity.CC;
|
||
mailModel.Bcc = entity.BCC;
|
||
mailModel.Subject = entity.Subject;
|
||
mailModel.BodyText = HttpUtility.HtmlDecode(entity.BodyText);
|
||
mailModel.Attachment = attachmentList;
|
||
MailUtil.Send(new MailParameterInfo { AccountName = mailConfig.SenderName, Account = mailConfig.Account, Password = mailConfig.Password, SMTPHost = mailConfig.SMTPHost, SMTPPort = mailConfig.SMTPPort.ParseToInt(), Ssl = mailConfig.Ssl == 1 }, mailModel);
|
||
if (isOk < 1)
|
||
throw Oops.Oh(ErrorCode.COM1008);
|
||
}
|
||
else
|
||
{
|
||
throw Oops.Oh(ErrorCode.Ex0004);
|
||
}
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 保存邮箱配置
|
||
/// </summary>
|
||
/// <param name="input">对象实体</param>
|
||
/// <returns></returns>
|
||
[HttpPut("Config")]
|
||
public async Task SaveConfig([FromBody] EmailConfigUpInput input)
|
||
{
|
||
var entity = input.Adapt<EmailConfigEntity>();
|
||
var data = await GetConfigInfo();
|
||
var isOk = 0;
|
||
if (data == null)
|
||
{
|
||
isOk = await _repository.AsSugarClient().Insertable(entity).CallEntityMethod(m => m.Creator()).ExecuteCommandAsync();
|
||
}
|
||
else
|
||
{
|
||
entity.Id = data.Id;
|
||
isOk = await _repository.AsSugarClient().Updateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
|
||
}
|
||
if (isOk < 1)
|
||
throw Oops.Oh(ErrorCode.COM1008);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 邮箱账户密码验证.
|
||
/// </summary>
|
||
/// <param name="input">对象实体</param>
|
||
[HttpPost("Config/Actions/CheckMail")]
|
||
public void CheckLogin([FromBody] EmailConfigActionsCheckMailInput input)
|
||
{
|
||
var entity = input.Adapt<EmailConfigEntity>();
|
||
if (!MailUtil.CheckConnected(entity.Adapt<MailParameterInfo>()))
|
||
throw Oops.Oh(ErrorCode.Ex0003);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 下载附件.
|
||
/// </summary>
|
||
/// <param name="fileModel">文件对象</param>
|
||
[HttpPost("Download")]
|
||
public async Task Download(AnnexModel fileModel)
|
||
{
|
||
var filePath = Path.Combine(FileVariable.EmailFilePath, fileModel.FileId);
|
||
if (await _fileManager.ExistsFile(filePath))
|
||
{
|
||
_fileManager.DownloadFileByType(filePath, fileModel.FileName);
|
||
}
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region PrivateMethod
|
||
|
||
/// <summary>
|
||
/// 信息（配置）.
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
private async Task<EmailConfigEntity> GetConfigInfo()
|
||
{
|
||
return await _repository.AsSugarClient().Queryable<EmailConfigEntity>().FirstAsync(x => x.CreatorUserId == _userManager.UserId);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 列表（收件箱）.
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
private async Task<dynamic> GetReceiveList(EmailListQuery input)
|
||
{
|
||
var whereLambda = LinqExpression.And<EmailReceiveEntity>();
|
||
whereLambda = whereLambda.And(x => x.CreatorUserId == _userManager.UserId && x.DeleteMark == null);
|
||
if (input.endTime != null && input.startTime != null)
|
||
{
|
||
var start = Convert.ToDateTime(string.Format("{0:yyyy-MM-dd 00:00:00}", input.startTime?.TimeStampToDateTime()));
|
||
var end = Convert.ToDateTime(string.Format("{0:yyyy-MM-dd 23:59:59}", input.endTime?.TimeStampToDateTime()));
|
||
whereLambda = whereLambda.And(x => SqlFunc.Between(x.Date, start, end));
|
||
}
|
||
if (!string.IsNullOrEmpty(input.keyword))
|
||
{
|
||
whereLambda = whereLambda.And(m => m.Sender.Contains(input.keyword) || m.Subject.Contains(input.keyword));
|
||
}
|
||
var list = await _repository.AsSugarClient().Queryable<EmailReceiveEntity>().Where(whereLambda)
|
||
.OrderBy(x => x.Date, OrderByType.Desc).ToPagedListAsync(input.currentPage, input.pageSize);
|
||
var pageList = new SqlSugarPagedList<EmailListOutput>()
|
||
{
|
||
list = list.list.Adapt<List<EmailListOutput>>(),
|
||
pagination = list.pagination
|
||
};
|
||
return PageResult<EmailListOutput>.SqlSugarPageResult(pageList);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 列表（未读邮件）.
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
private async Task<dynamic> GetUnreadList(EmailListQuery input)
|
||
{
|
||
var whereLambda = LinqExpression.And<EmailReceiveEntity>();
|
||
whereLambda = whereLambda.And(x => x.CreatorUserId == _userManager.UserId && x.Read == 0 && x.DeleteMark == null);
|
||
if (input.endTime != null && input.startTime != null)
|
||
{
|
||
var start = Convert.ToDateTime(string.Format("{0:yyyy-MM-dd 00:00:00}", input.startTime?.TimeStampToDateTime()));
|
||
var end = Convert.ToDateTime(string.Format("{0:yyyy-MM-dd 23:59:59}", input.endTime?.TimeStampToDateTime()));
|
||
whereLambda = whereLambda.And(x => SqlFunc.Between(x.CreatorTime, start, end));
|
||
}
|
||
if (!string.IsNullOrEmpty(input.keyword))
|
||
{
|
||
whereLambda = whereLambda.And(m => m.Sender.Contains(input.keyword) || m.Subject.Contains(input.keyword));
|
||
}
|
||
var list = await _repository.AsSugarClient().Queryable<EmailReceiveEntity>().Where(whereLambda).OrderBy(x => x.Date, OrderByType.Desc).ToPagedListAsync(input.currentPage, input.pageSize);
|
||
var pageList = new SqlSugarPagedList<EmailListOutput>()
|
||
{
|
||
list = list.list.Adapt<List<EmailListOutput>>(),
|
||
pagination = list.pagination
|
||
};
|
||
return PageResult<EmailListOutput>.SqlSugarPageResult(pageList);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 列表（星标件）.
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
private async Task<dynamic> GetStarredList(EmailListQuery input)
|
||
{
|
||
var whereLambda = LinqExpression.And<EmailReceiveEntity>();
|
||
whereLambda = whereLambda.And(x => x.CreatorUserId == _userManager.UserId && x.Starred == 1 && x.DeleteMark == null);
|
||
if (input.endTime != null && input.startTime != null)
|
||
{
|
||
var start = Convert.ToDateTime(string.Format("{0:yyyy-MM-dd 00:00:00}", input.startTime?.TimeStampToDateTime()));
|
||
var end = Convert.ToDateTime(string.Format("{0:yyyy-MM-dd 23:59:59}", input.endTime?.TimeStampToDateTime()));
|
||
whereLambda = whereLambda.And(x => SqlFunc.Between(x.CreatorTime, start, end));
|
||
}
|
||
//关键字（用户、IP地址、功能名称）
|
||
if (!string.IsNullOrEmpty(input.keyword))
|
||
{
|
||
whereLambda = whereLambda.And(m => m.Sender.Contains(input.keyword) || m.Subject.Contains(input.keyword));
|
||
}
|
||
var list = await _repository.AsSugarClient().Queryable<EmailReceiveEntity>().Where(whereLambda).OrderBy(x => x.Date, OrderByType.Desc).ToPagedListAsync(input.currentPage, input.pageSize);
|
||
var pageList = new SqlSugarPagedList<EmailListOutput>()
|
||
{
|
||
list = list.list.Adapt<List<EmailListOutput>>(),
|
||
pagination = list.pagination
|
||
};
|
||
return PageResult<EmailListOutput>.SqlSugarPageResult(pageList);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 列表（草稿箱）.
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
private async Task<dynamic> GetDraftList(EmailListQuery input)
|
||
{
|
||
var whereLambda = LinqExpression.And<EmailSendEntity>();
|
||
whereLambda = whereLambda.And(x => x.CreatorUserId == _userManager.UserId && x.State == -1 && x.DeleteMark == null);
|
||
if (input.endTime != null && input.startTime != null)
|
||
{
|
||
var start = Convert.ToDateTime(string.Format("{0:yyyy-MM-dd 00:00:00}", input.startTime?.TimeStampToDateTime()));
|
||
var end = Convert.ToDateTime(string.Format("{0:yyyy-MM-dd 23:59:59}", input.endTime?.TimeStampToDateTime()));
|
||
whereLambda = whereLambda.And(x => SqlFunc.Between(x.CreatorTime, start, end));
|
||
}
|
||
if (!string.IsNullOrEmpty(input.keyword))
|
||
{
|
||
whereLambda = whereLambda.And(m => m.Sender.Contains(input.keyword) || m.Subject.Contains(input.keyword));
|
||
}
|
||
var list = await _repository.AsSugarClient().Queryable<EmailSendEntity>().Where(whereLambda).OrderBy(x => x.CreatorTime, OrderByType.Desc).ToPagedListAsync(input.currentPage, input.pageSize);
|
||
var pageList = new SqlSugarPagedList<EmailListOutput>()
|
||
{
|
||
list = list.list.Adapt<List<EmailListOutput>>(),
|
||
pagination = list.pagination
|
||
};
|
||
return PageResult<EmailListOutput>.SqlSugarPageResult(pageList);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 列表（已发送）.
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
private async Task<dynamic> GetSentList(EmailListQuery input)
|
||
{
|
||
var whereLambda = LinqExpression.And<EmailSendEntity>();
|
||
whereLambda = whereLambda.And(x => x.CreatorUserId == _userManager.UserId && x.State != -1 && x.DeleteMark == null);
|
||
if (input.endTime != null && input.startTime != null)
|
||
{
|
||
var start = Convert.ToDateTime(string.Format("{0:yyyy-MM-dd 00:00:00}", input.startTime?.TimeStampToDateTime()));
|
||
var end = Convert.ToDateTime(string.Format("{0:yyyy-MM-dd 23:59:59}", input.endTime?.TimeStampToDateTime()));
|
||
whereLambda = whereLambda.And(x => SqlFunc.Between(x.CreatorTime, start, end));
|
||
}
|
||
if (!string.IsNullOrEmpty(input.keyword))
|
||
{
|
||
whereLambda = whereLambda.And(m => m.Sender.Contains(input.keyword) || m.Subject.Contains(input.keyword));
|
||
}
|
||
var list = await _repository.AsSugarClient().Queryable<EmailSendEntity>().Where(whereLambda).OrderBy(x => x.CreatorTime, OrderByType.Desc).ToPagedListAsync(input.currentPage, input.pageSize);
|
||
var pageList = new SqlSugarPagedList<EmailListOutput>()
|
||
{
|
||
list = list.list.Adapt<List<EmailListOutput>>(),
|
||
pagination = list.pagination
|
||
};
|
||
return PageResult<EmailListOutput>.SqlSugarPageResult(pageList);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 信息.
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <returns></returns>
|
||
private async Task<object> GetInfo(string id)
|
||
{
|
||
var entity = new object();
|
||
if (await _repository.AsSugarClient().Queryable<EmailReceiveEntity>().AnyAsync(x => x.Id == id && x.DeleteMark == null))
|
||
{
|
||
var receiveInfo = await _repository.AsSugarClient().Queryable<EmailReceiveEntity>().FirstAsync(x => x.Id == id && x.DeleteMark == null);
|
||
receiveInfo.Read = 1;
|
||
await _repository.AsSugarClient().Updateable(receiveInfo).CallEntityMethod(m => m.LastModify()).UpdateColumns(x => new { x.LastModifyTime, x.LastModifyUserId, x.Read }).ExecuteCommandHasChangeAsync();
|
||
entity = receiveInfo;
|
||
}
|
||
else
|
||
{
|
||
entity = await _repository.AsSugarClient().Queryable<EmailSendEntity>().FirstAsync(x => x.Id == id && x.DeleteMark == null);
|
||
}
|
||
return entity;
|
||
}
|
||
#endregion
|
||
}
|