117 lines
3.9 KiB
C#
117 lines
3.9 KiB
C#
|
||
//--------------------------------------------------------------------
|
||
// 此代码由liquid模板自动生成 byzhouhang 20240909
|
||
// 生成时间 2025-10-28 06:22:42Z
|
||
// 对此文件的更改可能会导致不正确的行为，并且如果重新生成代码，这些更改将会丢失。
|
||
//--------------------------------------------------------------------
|
||
using IRaCIS.Core.Application.Interfaces;
|
||
using IRaCIS.Core.Application.ViewModel;
|
||
using IRaCIS.Core.Domain.Models;
|
||
using IRaCIS.Core.Infra.EFCore;
|
||
using IRaCIS.Core.Infrastructure.Extention;
|
||
using MailKit;
|
||
using MailKit.Net.Imap;
|
||
using MailKit.Search;
|
||
using MailKit.Security;
|
||
using Microsoft.AspNetCore.Mvc;
|
||
using Microsoft.Extensions.Options;
|
||
using System.Threading.Tasks;
|
||
namespace IRaCIS.Core.Application.Service;
|
||
|
||
[ ApiExplorerSettings(GroupName = "Test")]
|
||
public class EmailLogService(IRepository<EmailLog> _emailLogRepository,
|
||
IOptionsMonitor<SystemEmailSendConfig> systemEmailConfig,
|
||
IMapper _mapper, IUserInfo _userInfo, IStringLocalizer _localizer): BaseService, IEmailLogService
|
||
{
|
||
private readonly SystemEmailSendConfig _systemEmailConfig = systemEmailConfig.CurrentValue;
|
||
|
||
[HttpPost]
|
||
public async Task<PageOutput<EmailLogView>> GetEmailLogList(EmailLogQuery inQuery)
|
||
{
|
||
|
||
List<IMessageSummary> emailList = new List<IMessageSummary>();
|
||
|
||
|
||
|
||
|
||
|
||
|
||
using (var client = new ImapClient())
|
||
{
|
||
|
||
|
||
try
|
||
{
|
||
// 连接阿里邮箱 IMAP 服务器（使用 SSL）
|
||
client.Connect(_systemEmailConfig.Imap, 993, SecureSocketOptions.SslOnConnect);
|
||
|
||
// 登录
|
||
client.Authenticate(_systemEmailConfig.FromEmail, _systemEmailConfig.AuthorizationCode);
|
||
|
||
// 3. 获取发件箱文件夹 - 使用你找到的“已发送”
|
||
var sentFolder = client.GetFolder("已发送");
|
||
sentFolder.Open(FolderAccess.ReadOnly);
|
||
|
||
// 4. 搜索所有邮件（你可以在这里添加更精确的搜索条件）
|
||
var uids = sentFolder.Search(SearchQuery.All);
|
||
Console.WriteLine($"找到 {uids.Count} 封已发送邮件");
|
||
|
||
// 5. 遍历并处理邮件（示例中处理前10封）
|
||
foreach (var uid in uids.Take(10))
|
||
{
|
||
var message = sentFolder.GetMessage(uid);
|
||
|
||
// 输出邮件基本信息
|
||
Console.WriteLine($"主题: {message.Subject}");
|
||
Console.WriteLine($"收件人: {string.Join(", ", message.To.Mailboxes.Select(m => m.Address))}");
|
||
Console.WriteLine($"日期: {message.Date.LocalDateTime:yyyy-MM-dd HH:mm:ss}");
|
||
Console.WriteLine($"发件人: {message.From}");
|
||
Console.WriteLine("----------------------------------");
|
||
}
|
||
|
||
sentFolder.Close();
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
Console.WriteLine($"操作失败: {ex.Message}");
|
||
}
|
||
finally
|
||
{
|
||
client.Disconnect(true);
|
||
}
|
||
}
|
||
|
||
var emailLogQueryable =_emailLogRepository
|
||
.ProjectTo<EmailLogView>(_mapper.ConfigurationProvider);
|
||
|
||
var pageList= await emailLogQueryable.ToPagedListAsync(inQuery);
|
||
|
||
return pageList;
|
||
}
|
||
|
||
|
||
|
||
public async Task<IResponseOutput> AddOrUpdateEmailLog(EmailLogAddOrEdit addOrEditEmailLog)
|
||
{
|
||
|
||
|
||
|
||
var entity = await _emailLogRepository.InsertOrUpdateAsync(addOrEditEmailLog, true);
|
||
|
||
return ResponseOutput.Ok(entity.Id.ToString());
|
||
|
||
}
|
||
|
||
|
||
[HttpDelete("{emailLogId:guid}")]
|
||
public async Task<IResponseOutput> DeleteEmailLog(Guid emailLogId)
|
||
{
|
||
var success = await _emailLogRepository.DeleteFromQueryAsync(t => t.Id == emailLogId,true);
|
||
return ResponseOutput.Ok();
|
||
}
|
||
|
||
}
|
||
|
||
|
||
|