diff --git a/aspnet-core/modules/elsa/LINGYUN.Abp.ElsaNext.Email/FodyWeavers.xml b/aspnet-core/modules/elsa/LINGYUN.Abp.ElsaNext.Email/FodyWeavers.xml
new file mode 100644
index 000000000..5d6962159
--- /dev/null
+++ b/aspnet-core/modules/elsa/LINGYUN.Abp.ElsaNext.Email/FodyWeavers.xml
@@ -0,0 +1,3 @@
+
+
+
\ No newline at end of file
diff --git a/aspnet-core/modules/elsa/LINGYUN.Abp.ElsaNext.Email/FodyWeavers.xsd b/aspnet-core/modules/elsa/LINGYUN.Abp.ElsaNext.Email/FodyWeavers.xsd
new file mode 100644
index 000000000..3f3946e28
--- /dev/null
+++ b/aspnet-core/modules/elsa/LINGYUN.Abp.ElsaNext.Email/FodyWeavers.xsd
@@ -0,0 +1,30 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 'true' to run assembly verification (PEVerify) on the target assembly after all weavers have been executed.
+
+
+
+
+ A comma-separated list of error codes that can be safely ignored in assembly verification.
+
+
+
+
+ 'false' to turn off automatic generation of the XML Schema file.
+
+
+
+
+
\ No newline at end of file
diff --git a/aspnet-core/modules/elsa/LINGYUN.Abp.ElsaNext.Email/LINGYUN.Abp.ElsaNext.Email.csproj b/aspnet-core/modules/elsa/LINGYUN.Abp.ElsaNext.Email/LINGYUN.Abp.ElsaNext.Email.csproj
new file mode 100644
index 000000000..8277c0b2b
--- /dev/null
+++ b/aspnet-core/modules/elsa/LINGYUN.Abp.ElsaNext.Email/LINGYUN.Abp.ElsaNext.Email.csproj
@@ -0,0 +1,29 @@
+
+
+
+
+
+
+ net10.0
+ LINGYUN.Abp.ElsaNext.Email
+ LINGYUN.Abp.ElsaNext.Email
+ false
+ false
+ false
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/aspnet-core/modules/elsa/LINGYUN.Abp.ElsaNext.Email/LINGYUN/Abp/ElsaNext/Email/AbpElsaNextEmailModule.cs b/aspnet-core/modules/elsa/LINGYUN.Abp.ElsaNext.Email/LINGYUN/Abp/ElsaNext/Email/AbpElsaNextEmailModule.cs
new file mode 100644
index 000000000..b73c13f66
--- /dev/null
+++ b/aspnet-core/modules/elsa/LINGYUN.Abp.ElsaNext.Email/LINGYUN/Abp/ElsaNext/Email/AbpElsaNextEmailModule.cs
@@ -0,0 +1,38 @@
+using Elsa.Features.Services;
+using LINGYUN.Abp.ElsaNext.Email.Extensions;
+using LINGYUN.Abp.ElsaNext.Localization;
+using Volo.Abp.Emailing;
+using Volo.Abp.Localization;
+using Volo.Abp.Modularity;
+using Volo.Abp.VirtualFileSystem;
+
+namespace LINGYUN.Abp.ElsaNext.Email;
+
+[DependsOn(
+ typeof(AbpEmailingModule),
+ typeof(AbpElsaNextModule))]
+public class AbpElsaNextEmailModule : AbpModule
+{
+ public override void PreConfigureServices(ServiceConfigurationContext context)
+ {
+ PreConfigure(elsa =>
+ {
+ elsa.UseAbpEmail();
+ });
+ }
+
+ public override void ConfigureServices(ServiceConfigurationContext context)
+ {
+ Configure(options =>
+ {
+ options.FileSets.AddEmbedded();
+ });
+
+ Configure(options =>
+ {
+ options.Resources
+ .Get()
+ .AddVirtualJson("/LINGYUN/Abp/ElsaNext/Email/Localization/Resources");
+ });
+ }
+}
diff --git a/aspnet-core/modules/elsa/LINGYUN.Abp.ElsaNext.Email/LINGYUN/Abp/ElsaNext/Email/Activities/SendEmail.cs b/aspnet-core/modules/elsa/LINGYUN.Abp.ElsaNext.Email/LINGYUN/Abp/ElsaNext/Email/Activities/SendEmail.cs
new file mode 100644
index 000000000..a9cc3e01e
--- /dev/null
+++ b/aspnet-core/modules/elsa/LINGYUN.Abp.ElsaNext.Email/LINGYUN/Abp/ElsaNext/Email/Activities/SendEmail.cs
@@ -0,0 +1,274 @@
+using Elsa.Extensions;
+using Elsa.Workflows;
+using Elsa.Workflows.Attributes;
+using Elsa.Workflows.Models;
+using Elsa.Workflows.UIHints;
+using LINGYUN.Abp.ElsaNext.Email.Contracts;
+using Microsoft.Extensions.Logging;
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using System.Dynamic;
+using System.IO;
+using System.Net.Mail;
+using System.Net.Mime;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+using Volo.Abp.Emailing;
+using Volo.Abp.Json;
+
+namespace LINGYUN.Abp.ElsaNext.Email.Activities;
+
+[Activity("Elsa", "Email", "Send an email message.", Kind = ActivityKind.Task)]
+public class SendEmail : Activity
+{
+ ///
+ /// The sender's email address.
+ ///
+ [Input(Description = "The sender's email address.")]
+ public Input From { get; set; } = null!;
+
+ ///
+ /// The recipients email addresses.
+ ///
+ [Input(Description = "The recipients email addresses.", UIHint = InputUIHints.MultiText)]
+ public Input> To { get; set; } = null!;
+
+ ///
+ /// The CC recipient email addresses.
+ ///
+ [Input(
+ Description = "The CC recipient email addresses.",
+ UIHint = InputUIHints.MultiText,
+ Category = "More")]
+ public Input> Cc { get; set; } = null!;
+
+ ///
+ /// The BCC recipients email addresses.
+ ///
+ [Input(
+ Description = "The BCC recipients email addresses.",
+ UIHint = InputUIHints.MultiText,
+ Category = "More")]
+ public Input> Bcc { get; set; } = null!;
+
+ ///
+ /// The subject of the email message.
+ ///
+ [Input(Description = "The subject of the email message.")]
+ public Input Subject { get; set; } = null!;
+
+ ///
+ /// The attachments to send with the email message.
+ ///
+ [Input(
+ Description = "The attachments to send with the email message. Can be (an array of) a fully-qualified file path, URL, stream, byte array or instances of EmailAttachment.",
+ UIHint = InputUIHints.MultiLine
+ )]
+ public Input Attachments { get; set; } = null!;
+
+ ///
+ /// The body of the email message.
+ ///
+ [Input(
+ Description = "The body of the email message.",
+ UIHint = InputUIHints.MultiLine
+ )]
+ public Input Body { get; set; } = null!;
+
+ ///
+ /// The activity to execute when an error occurs while trying to send the email.
+ ///
+ [Port] public IActivity? Error { get; set; }
+
+ ///
+ protected override async ValueTask ExecuteAsync(ActivityExecutionContext context)
+ {
+ var cancellationToken = context.CancellationToken;
+ var message = new MailMessage();
+ var from = From.GetOrDefault(context);
+
+ if (MailAddress.TryCreate(from, out var fromAddress))
+ {
+ message.Sender = fromAddress;
+ message.From = fromAddress;
+ }
+ message.Subject = Subject.GetOrDefault(context) ?? "";
+
+ await AddAttachmentsAsync(context, message, cancellationToken);
+
+ message.Body = Body.GetOrDefault(context);
+
+ SetRecipientsEmailAddresses(message.To, GetAddresses(context, To));
+ SetRecipientsEmailAddresses(message.CC, GetAddresses(context, Cc));
+ SetRecipientsEmailAddresses(message.Bcc, GetAddresses(context, Bcc));
+
+ var emailSender = context.GetRequiredService();
+ var logger = context.GetRequiredService>();
+
+ try
+ {
+ await emailSender.SendAsync(message);
+ await context.CompleteActivityAsync();
+ }
+ catch (Exception e)
+ {
+ logger.LogWarning(e, "Error while sending email message");
+ context.AddExecutionLogEntry("Error", e.Message, payload: new
+ {
+ e.StackTrace
+ });
+ await context.ScheduleActivityAsync(Error, OnErrorCompletedAsync);
+ }
+ }
+
+ private async ValueTask OnErrorCompletedAsync(ActivityCompletedContext context) => await context.TargetContext.CompleteActivityAsync();
+
+ private static ICollection GetAddresses(ActivityExecutionContext context, Input> input)
+ {
+ return input.GetOrDefault(context) ?? new List(0);
+ }
+
+ private async Task AddAttachmentsAsync(ActivityExecutionContext context, MailMessage mailMessage, CancellationToken cancellationToken)
+ {
+ var attachments = Attachments.GetOrDefault(context);
+
+ if (attachments == null || attachments is string s && string.IsNullOrWhiteSpace(s))
+ {
+ return;
+ }
+
+ var index = 0;
+ var attachmentObjects = InterpretAttachmentsModel(attachments);
+
+ foreach (var attachmentObject in attachmentObjects)
+ {
+ switch (attachmentObject)
+ {
+ case Uri url:
+ await AttachOnlineFileAsync(context, mailMessage, url, cancellationToken);
+ break;
+ case string path when path?.Contains("://") == true:
+ await AttachOnlineFileAsync(context, mailMessage, new Uri(path), cancellationToken);
+ break;
+ case string path when !string.IsNullOrWhiteSpace(path):
+ AttachLocalFile(mailMessage, path);
+ break;
+ case byte[] bytes:
+ {
+ var fileName = $"Attachment-{++index}";
+ var byteStream = new MemoryStream(bytes.Length);
+ await byteStream.WriteAsync(bytes, cancellationToken);
+ mailMessage.Attachments.Add(new Attachment(byteStream, new ContentType { Name = fileName }));
+ break;
+ }
+ case Stream stream:
+ {
+ var fileName = $"Attachment-{++index}";
+ mailMessage.Attachments.Add(new Attachment(stream, new ContentType { Name = fileName }));
+ break;
+ }
+ case Attachment attachment:
+ {
+ attachment.Name ??= $"Attachment-{++index}";
+ mailMessage.Attachments.Add(attachment);
+ break;
+ }
+ case EmailAttachment emailAttachment when emailAttachment.File != null:
+ {
+ var fileName = emailAttachment.Name ?? $"Attachment-{++index}";
+ var emailAttachmentStream = new MemoryStream(emailAttachment.File.Length);
+ await emailAttachmentStream.WriteAsync(emailAttachment.File, cancellationToken);
+ mailMessage.Attachments.Add(new Attachment(emailAttachmentStream, new ContentType { Name = fileName }));
+ break;
+ }
+ case ExpandoObject expandoObject:
+ {
+ var dictionary = new Dictionary(expandoObject!, StringComparer.OrdinalIgnoreCase);
+ var fileName = dictionary.GetValue("FileName") ?? $"Attachment-{++index}";
+ var contentType = dictionary.GetValue("ContentType") ?? "application/octet-stream";
+ var parsedContentType = new ContentType(contentType);
+ var content = dictionary.GetValue