C#教程

关注公众号 jb51net

关闭
首页 > 软件编程 > C#教程 > C# SQL Server数据自动化处理

利用C#和SQL Server实现自动化解决邮件数据的处理

作者：葡萄城技术团队

本文将介绍如何利用 C# 和 SQL Server 构建一个自动化解决方案,实现从邮件读取、附件下载到数据库更新的全流程自动化处理,文中的示例代码讲解详细,感兴趣的小伙伴可以了解下

引言

在金融应用领域，通过电子邮件手动管理用户分配数据不仅耗时而且容易出错。传统的人工处理方式需要工作人员每天检查邮件、下载附件、解析数据并更新数据库，这一系列重复性工作既低效又存在数据录入错误的风险。本文将介绍如何利用 C# 和 SQL Server 构建一个自动化解决方案，实现从邮件读取、附件下载到数据库更新的全流程自动化处理。该系统特别适用于处理主题包含"AllotmentsFiles"的邮件，并更新 SQL Server 中的 bidfiledetails 表，显著提高数据处理效率和准确性。

1. 系统概述与优势

1.1 处理流程

该自动化系统主要包含三个核心处理步骤：

1.2 系统优势

2. 开发环境与工具配置

2.1 所需工具

2.2 配置设置

系统配置存储在 web.config 文件中，包含邮件服务器连接信息：

<appSettings>
  <add key="HostServer" value="pop.gmail.com" />
  <add key="MailPort" value="995" />
  <add key="MailUser" value="your-email@gmail.com" />
  <add key="MailPwd" value="your-password" />
</appSettings>

此配置允许灵活更改邮件服务器设置而无需修改代码。

3. 邮件处理核心代码实现

读取邮件功能

以下 C# 代码实现了从邮件服务器读取并处理目标邮件的功能：

public void ReadTheDataFromTheMail()
{
    try
    {
        string mailHost = ConfigurationManager.AppSettings["HostServer"];
        int mailPort = Convert.ToInt32(ConfigurationManager.AppSettings["MailPort"]);
        string mailID = ConfigurationManager.AppSettings["MailUser"];
        string mailPwd = ConfigurationManager.AppSettings["MailPwd"];

        using (Pop3Client client = new Pop3Client())
        {
            client.Connect(mailHost, mailPort, true);
            client.Authenticate(mailID, mailPwd);

            int messageCount = client.GetMessageCount();
            DateTime today = DateTime.UtcNow.Date;

            for (int i = messageCount; i > 0; i--)
            {
                MessageHeader headers = client.GetMessageHeaders(i);
                string subject = headers.Subject;
                DateTime emailDate = headers.DateSent;

                if (!string.IsNullOrEmpty(subject) && subject.Contains("AllotmentsFiles") && emailDate.Date == today)
                {
                    OpenPop.Mime.Message message = client.GetMessage(i);

                    foreach (var attachment in message.FindAllAttachments())
                    {
                        if (attachment.FileName.Contains("AllotmentsFiles_") && attachment.FileName.EndsWith(".csv"))
                        {
                            string baseDirectory = @"E:\Allotment - Applns\Allotmentfiles";
                            string dateFolder = DateTime.Now.ToString("yyyy-MM-dd");
                            string fileFolder = Path.Combine(baseDirectory, dateFolder);

                            if (!Directory.Exists(fileFolder))
                                Directory.CreateDirectory(fileFolder);

                            string filePath = Path.Combine(fileFolder, attachment.FileName);
                            File.WriteAllBytes(filePath, attachment.Body);

                            errorlog($"CSV file '{attachment.FileName}'", "Downloaded successfully!");
                            ProcessAllotmentData(filePath);
                        }
                    }
                }
            }
        }
    }
    catch (Exception ex)
    {
        errorlog("Error reading emails", ex.Message);
    }
}

这段代码实现了以下功能：

4. CSV数据处理与数据库更新

数据处理流程

下载的 CSV 文件需要被解析并更新到数据库中，以下是实现代码：

public void ProcessAllotmentData(string filePath)
{
    try
    {
        string fileName = Path.GetFileName(filePath);
        string[] parts = fileName.Split('_');
        string scriptName = parts.Length > 0 ? parts[0] : null;

        using (StreamReader sr = new StreamReader(filePath))
        {
            string[] rows = sr.ReadToEnd().Split('\n');

            for (int i = 1; i < rows.Length; i++)
            {
                string[] rowValues = rows[i].Split(',');
                if (rowValues.Length > 7)
                {
                    string appNo = rowValues[2].Trim();
                    string pan = rowValues[4].Trim();
                    string qty = rowValues[5].Trim();
                    string clientName = rowValues[6].Trim();
                    string reason = rowValues[7].Trim();

                    SqlParameter[] param = {
                        new SqlParameter("@symbol", scriptName),
                        new SqlParameter("@appno", appNo),
                        new SqlParameter("@pan", pan),
                        new SqlParameter("@qty", qty),
                        new SqlParameter("@reason", reason)
                    };

                    string statusQuery = @"SELECT * FROM bidfiledetails  (NOLOCK)
                                           WHERE AppNo=@appno AND Symbol=@symbol AND PanNo=@pan AND AllotmentFlag != 'Y'";

                    DataSet ds = SqlHelper.ExecuteDataset(SqlCon, CommandType.Text, statusQuery, param);

                    if (ds.Tables[0].Rows.Count > 0)
                    {
                        string updateQuery = @"UPDATE bidfiledetails
                                               SET AllotmentFlag='Y', SharesAlloted=@qty, Sharesrej_reason=@reason
                                               WHERE AppNo=@appno AND PanNo=@pan AND Symbol=@symbol";

                        SqlHelper.ExecuteNonQuery(SqlCon, CommandType.Text, updateQuery, param);
                        errorlog("Updated Record", $"PanNo: {pan}, ApplicationNo: {appNo}, Symbol: {scriptName}");
                    }
                    else
                    {
                        string header = "ApplicationNo|ClientName|Quantity|Reason|PanNo";
                        string message = $"{appNo}|{clientName}|{qty}|{reason}|{pan}{Environment.NewLine}";
                        errorlog(header, message);
                    }
                }
                else
                {
                    errorlog("Row does not have enough columns", "");
                }
            }
        }
    }
    catch (Exception ex)
    {
        ExceptionLogging.Exceptionlog("Exception in ProcessAllotmentData", ex.Message);
    }
}

此代码实现了：

5. 关键技术与实现要点

5.1 核心技术组件

5.2 系统部署方式

6. 系统扩展与优化方向

6.1 功能增强建议

6.2 性能优化建议

结论

本文详细介绍了一个基于C#和SQL Server的自动化邮件处理系统，能够高效地从邮件中提取分配数据并更新数据库。该系统通过自动化取代了繁琐的手工操作，显著提高了金融应用中分配数据处理的效率和准确性。核心功能包括邮件服务器连接、目标邮件筛选、CSV附件下载与解析以及数据库更新等完整流程。系统采用模块化设计，具有良好的可扩展性，可通过转换为Windows服务、添加通知功能等方式进一步增强。该解决方案不仅适用于金融领域的分配数据处理，其设计思路和实现方法也可应用于其他需要从邮件自动提取数据并更新数据库的类似场景。

以上就是利用C#和SQL Server实现自动化解决邮件数据的处理的详细内容，更多关于C# SQL Server数据自动化处理的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:
阅读全文