MVC下如何遍历数据表获取单元格值？Events表邮件发送逻辑实现

针对你这个需求，核心是要筛选未发送邮件的记录、调用SMTP发送、更新发送状态（避免重复发送），下面给你两种实际项目里常用的实现方案：

方案一：用Python脚本实现（灵活易维护） #

Python处理这类数据库+邮件的任务非常顺手，而且不需要在数据库端做复杂配置，步骤如下：

1. 先安装依赖包：

pip install pyodbc  # 用于连接数据库，smtplib是Python内置邮件库无需额外安装

2. 核心代码示例：

import pyodbc
import smtplib
from email.mime.text import MIMEText

# 1. 数据库连接配置
DB_CONFIG = {
    'driver': '{SQL Server}',
    'server': '你的数据库地址',
    'database': '你的数据库名',
    'username': '数据库账号',
    'password': '数据库密码'
}

# 2. SMTP邮件配置
SMTP_CONFIG = {
    'server': 'smtp.xxx.com',  # 比如smtp.gmail.com或企业邮箱SMTP地址
    'port': 587,
    'username': '你的邮箱账号',
    'password': '邮箱授权码',  # 注意不是登录密码，是邮箱的授权码
    'sender': 'your_email@xxx.com',
    'recipient': 'target_email@xxx.com'  # 也可以根据EquipID动态指定收件人
}

def send_email(equip_id):
    """根据EquipID生成并发送邮件"""
    subject = f"设备事件提醒：{equip_id}"
    body = f"您好，设备 {equip_id} 触发了待处理事件，请及时跟进。"
    msg = MIMEText(body, 'plain', 'utf-8')
    msg['Subject'] = subject
    msg['From'] = SMTP_CONFIG['sender']
    msg['To'] = SMTP_CONFIG['recipient']

    try:
        with smtplib.SMTP(SMTP_CONFIG['server'], SMTP_CONFIG['port']) as server:
            server.starttls()  # 启用加密传输
            server.login(SMTP_CONFIG['username'], SMTP_CONFIG['password'])
            server.send_message(msg)
        return True
    except Exception as e:
        print(f"设备 {equip_id} 的邮件发送失败：{str(e)}")
        return False

def process_event_emails():
    conn = pyodbc.connect(**DB_CONFIG)
    cursor = conn.cursor()

    try:
        # 3. 查询所有未发送邮件的记录
        cursor.execute("SELECT EquipID FROM Events WHERE EmailSent = 'no'")
        rows = cursor.fetchall()

        for row in rows:
            equip_id = row[0]
            # 4. 尝试发送邮件
            if send_email(equip_id):
                # 5. 发送成功后更新状态，避免重复发送
                cursor.execute("UPDATE Events SET EmailSent = 'yes' WHERE EquipID = ?", (equip_id,))
                conn.commit()
                print(f"设备 {equip_id} 的邮件已发送，状态已更新")
            else:
                # 可选：发送失败标记为'failed'，方便后续排查
                cursor.execute("UPDATE Events SET EmailSent = 'failed' WHERE EquipID = ?", (equip_id,))
                conn.commit()
    except Exception as e:
        print(f"处理过程出错：{str(e)}")
        conn.rollback()
    finally:
        cursor.close()
        conn.close()

if __name__ == "__main__":
    process_event_emails()

方案二：用数据库存储过程实现（适合数据库定时任务） #

如果需要用数据库的定时作业（比如SQL Server Agent）自动触发，也可以用存储过程+游标实现，以SQL Server为例：

SQL Server存储过程示例（需提前配置数据库邮件） #

USE 你的数据库名;
GO

CREATE PROCEDURE dbo.ProcessEventEmails
AS
BEGIN
    SET NOCOUNT ON;

    -- 声明变量
    DECLARE @EquipID VARCHAR(50);
    DECLARE @MailSubject NVARCHAR(255);
    DECLARE @MailBody NVARCHAR(MAX);

    -- 声明游标遍历未发送邮件的记录
    DECLARE event_cursor CURSOR FOR
        SELECT EquipID FROM Events WHERE EmailSent = 'no';

    OPEN event_cursor;
    FETCH NEXT FROM event_cursor INTO @EquipID;

    WHILE @@FETCH_STATUS = 0
    BEGIN
        BEGIN TRY
            -- 构造邮件内容
            SET @MailSubject = N'设备事件提醒：' + @EquipID;
            SET @MailBody = N'您好，设备 ' + @EquipID + N' 触发了待处理事件，请及时跟进。';

            -- 调用数据库邮件发送（需提前配置好数据库邮件配置文件）
            EXEC msdb.dbo.sp_send_dbmail
                @profile_name = '你的数据库邮件配置文件名',
                @recipients = 'target_email@xxx.com',
                @subject = @MailSubject,
                @body = @MailBody;

            -- 发送成功后更新状态
            UPDATE Events SET EmailSent = 'yes' WHERE EquipID = @EquipID;
            PRINT '设备 ' + @EquipID + ' 的邮件已发送';
        END TRY
        BEGIN CATCH
            -- 发送失败标记为失败状态
            UPDATE Events SET EmailSent = 'failed' WHERE EquipID = @EquipID;
            PRINT '设备 ' + @EquipID + ' 的邮件发送失败：' + ERROR_MESSAGE();
        END CATCH

        FETCH NEXT FROM event_cursor INTO @EquipID;
    END

    CLOSE event_cursor;
    DEALLOCATE event_cursor;
END
GO

注意：使用SQL Server的sp_send_dbmail需要先配置数据库邮件，若未启用相关功能，需执行以下语句开启：

sp_configure 'show advanced options', 1;
RECONFIGURE;
sp_configure 'Ole Automation Procedures', 1;
RECONFIGURE;

关键注意事项 #

• 必须更新EmailSent状态，否则每次运行都会重复发送同一批邮件
• 加入异常处理，避免单个邮件发送失败导致整个任务中断
• 如果是定时执行，建议设置合理的执行间隔（比如每小时一次），避免频繁查询数据库

内容的提问来源于stack exchange，提问作者Maheswarha Rajagopal