SingleSRMAnalysis.cs 1.06 KB
using HHECS.DAQHandle.Common.Enums;
using HHECS.DAQHandle.Models;

namespace HHECS.DAQHandle.EquipmentHandle
{
    internal class SingleSRMAnalysis : BaseAnalysis
    {
        public override void Execute(IEnumerable<EquipmentDataRecord> records)
        {
            try
            {
                Context.Equipment.Where(x => true).ToList();
                foreach (var item in records.GroupBy(x => x.EquipmentCode))
                {
                    var equipmentSN = item.Key;
                    UpdateTagValue(item.OrderByDescending(x => x.Timestamp).Last());
                    var statusCodes = new List<SingleSRMProp>();
                    UpdateEquipmentStatus(equipmentSN, statusCodes, item.ToList());

                    var alarmCodes = new List<SingleSRMProp>();
                    UpdateEquipmentAlarm(equipmentSN, alarmCodes, item.ToList());
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine($"[{nameof(SingleSRMAnalysis)}]解析异常:{ex.Message}");
            }
        }
    }
}