引言在金融应用领域通过电子邮件手动管理用户分配数据不仅耗时而且容易出错。传统的人工处理方式需要工作人员每天检查邮件、下载附件、解析数据并更新数据库这一系列重复性工作既低效又存在数据录入错误的风险。本文将介绍如何利用 C# 和 SQL Server 构建一个自动化解决方案实现从邮件读取、附件下载到数据库更新的全流程自动化处理。该系统特别适用于处理主题包含AllotmentsFiles的邮件并更新 SQL Server 中的 bidfiledetails 表显著提高数据处理效率和准确性。1. 系统概述与优势1.1 处理流程该自动化系统主要包含三个核心处理步骤连接邮件服务器使用 POP3 协议连接到邮件服务器支持 Gmail 等常见邮件服务提供商。筛选目标邮件自动筛选出当天收到的、主题包含AllotmentsFiles的邮件。处理附件并更新数据库下载邮件中的 CSV 附件解析内容并更新 SQL Server 数据库中的分配数据。1.2 系统优势自动化重复工作取代人工检查邮件和处理附件的过程减少人为错误自动化的数据处理流程避免了手工录入可能导致的错误全天候运行系统可配置为每日自动运行无需人工干预高效数据处理批量处理大量分配数据显著提高工作效率2. 开发环境与工具配置2.1 所需工具开发工具Visual StudioC#数据库SQL ServerNuGet 包OpenPop.NET用于通过 POP3 协议读取邮件System.Data.SqlClient用于数据库连接和操作2.2 配置设置系统配置存储在 web.config 文件中包含邮件服务器连接信息123456appSettingsaddkeyHostServervaluepop.gmail.com/addkeyMailPortvalue995/addkeyMailUservalueyour-emailgmail.com/addkeyMailPwdvalueyour-password//appSettings此配置允许灵活更改邮件服务器设置而无需修改代码。3. 邮件处理核心代码实现读取邮件功能以下 C# 代码实现了从邮件服务器读取并处理目标邮件的功能123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354publicvoidReadTheDataFromTheMail(){try{stringmailHost ConfigurationManager.AppSettings[HostServer];intmailPort Convert.ToInt32(ConfigurationManager.AppSettings[MailPort]);stringmailID ConfigurationManager.AppSettings[MailUser];stringmailPwd ConfigurationManager.AppSettings[MailPwd];using(Pop3Client client newPop3Client()){client.Connect(mailHost, mailPort,true);client.Authenticate(mailID, mailPwd);intmessageCount client.GetMessageCount();DateTime today DateTime.UtcNow.Date;for(inti messageCount; i 0; i--){MessageHeader headers client.GetMessageHeaders(i);stringsubject 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 attachmentinmessage.FindAllAttachments()){if(attachment.FileName.Contains(AllotmentsFiles_) attachment.FileName.EndsWith(.csv)){stringbaseDirectory E:\Allotment - Applns\Allotmentfiles;stringdateFolder DateTime.Now.ToString(yyyy-MM-dd);stringfileFolder Path.Combine(baseDirectory, dateFolder);if(!Directory.Exists(fileFolder))Directory.CreateDirectory(fileFolder);stringfilePath 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);}}这段代码实现了以下功能从配置读取邮件服务器连接信息使用 POP3 连接到邮件服务器筛选当天且主题包含AllotmentsFiles的邮件下载符合条件的 CSV 附件并保存到按日期组织的文件夹中调用数据处理方法处理下载的附件4. CSV数据处理与数据库更新数据处理流程下载的 CSV 文件需要被解析并更新到数据库中以下是实现代码12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364publicvoidProcessAllotmentData(stringfilePath){try{stringfileName Path.GetFileName(filePath);string[] parts fileName.Split(_);stringscriptName parts.Length 0 ? parts[0] :null;using(StreamReader sr newStreamReader(filePath)){string[] rows sr.ReadToEnd().Split(\n);for(inti 1; i rows.Length; i){string[] rowValues rows[i].Split(,);if(rowValues.Length 7){stringappNo rowValues[2].Trim();stringpan rowValues[4].Trim();stringqty rowValues[5].Trim();stringclientName rowValues[6].Trim();stringreason rowValues[7].Trim();SqlParameter[] param {newSqlParameter(symbol, scriptName),newSqlParameter(appno, appNo),newSqlParameter(pan, pan),newSqlParameter(qty, qty),newSqlParameter(reason, reason)};stringstatusQuery SELECT * FROM bidfiledetails (NOLOCK)WHERE AppNoappno AND Symbolsymbol AND PanNopan AND AllotmentFlag ! Y;DataSet ds SqlHelper.ExecuteDataset(SqlCon, CommandType.Text, statusQuery, param);if(ds.Tables[0].Rows.Count 0){stringupdateQuery UPDATE bidfiledetailsSET AllotmentFlagY, SharesAllotedqty, Sharesrej_reasonreasonWHERE AppNoappno AND PanNopan AND Symbolsymbol;SqlHelper.ExecuteNonQuery(SqlCon, CommandType.Text, updateQuery, param);errorlog(Updated Record, $PanNo: {pan}, ApplicationNo: {appNo}, Symbol: {scriptName});}else{stringheader ApplicationNo|ClientName|Quantity|Reason|PanNo;stringmessage ${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);}}此代码实现了从CSV文件名提取脚本名称逐行读取CSV文件内容验证数据完整性确保有足够列数检查数据库中的记录状态更新符合条件的记录或记录未匹配的情况全面的错误处理和日志记录5. 关键技术与实现要点5.1 核心技术组件邮件处理使用 OpenPop.NET 库通过 POP3 协议读取邮件文件处理系统自动按日期组织下载的附件文件数据验证严格检查CSV文件结构和数据完整性数据库操作使用参数化查询确保SQL注入防护错误处理全面的异常捕获和日志记录机制
