设备巡检管理系统与物联网集成：实时数据采集、自动预警的进阶应用方案

// 设备实体模型
public class Equipment
{
    public int Id { get; set; }
    public string Name { get; set; }
    public string Location { get; set; }
    public EquipmentStatus Status { get; set; }
    // 导航属性：一台设备对应多条传感器数据记录
    public virtual ICollection SensorDataRecords { get; set; }
}

// 传感器数据实体模型
public class SensorData
{
    public int Id { get; set; }
    public int EquipmentId { get; set; }
    public double Temperature { get; set; } // 温度值
    public double Vibration { get; set; }   // 振动值
    public DateTime Timestamp { get; set; } // 数据采集时间戳
    // 外键关联
    public virtual Equipment Equipment { get; set; }
}

public enum EquipmentStatus
{
    Normal = 0,
    Warning = 1,
    Fault = 2
}

// 使用Fetch API获取设备状态列表
async function fetchEquipmentStatus() {
    try {
        const response = await fetch('/api/equipment/status');
        const equipmentList = await response.json();

        // 更新前端监控界面
        equipmentList.forEach(equip => {
            updateEquipmentCard(equip.id, equip.name, equip.status);
        });
    } catch (error) {
        console.error('获取设备状态失败:', error);
        // 触发网络异常预警
        triggerNetworkAlert();
    }
}

// 根据状态更新设备卡片显示
function updateEquipmentCard(id, name, status) {
    const cardElement = document.querySelector(`[data-equipment-id="${id}"]`);
    if (cardElement) {
        cardElement.querySelector('.equip-name').textContent = name;
        cardElement.className = `equipment-card status-${status.toLowerCase()}`;
    }
}

// 一个简单的预警规则检查服务示例
public class AlertService
{
    private readonly IEquipmentRepository _equipmentRepo;

    public AlertService(IEquipmentRepository equipmentRepo)
    {
        _equipmentRepo = equipmentRepo;
    }

    public async Task CheckAndTriggerAlerts(int equipmentId)
    {
        var recentData = await _equipmentRepo.GetRecentSensorDataAsync(equipmentId, TimeSpan.FromHours(1));
        var equipment = await _equipmentRepo.GetByIdAsync(equipmentId);

        // 规则1：温度连续超标预警
        if (recentData.All(d => d.Temperature > 85))
        {
            await TriggerAlert(equipment, AlertLevel.Warning, "温度持续过高");
        }

        // 规则2：振动值突增预警
        var avgVibration = recentData.Average(d => d.Vibration);
        if (avgVibration > equipment.NormalVibrationLevel * 2.0)
        {
            await TriggerAlert(equipment, AlertLevel.Critical, "振动异常突增");
        }
    }

    private async Task TriggerAlert(Equipment equipment, AlertLevel level, string message)
    {
        // 实现预警信息持久化和推送逻辑
        // ...
    }
}