using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using IStation.RedisCache;

namespace IStation.Service
{
    /// <summary>
    /// 实时监测记录
    /// </summary>
    public partial class MonitorRecord
    {
        #region 最近一条记录

        /// <summary>
        /// 获取最近一条记录
        /// </summary>
        public Model.MonitorRecord GetLastRecord(long monitorPointId)
        {
            var redisHelper = new MonitorRecordCacheHelper();
            var record = redisHelper.GetLastRecord(monitorPointId);
            return record;
        }

        /// <summary>
        /// 获取最近一条记录
        /// </summary>
        public List<Model.MonitorRecord> GetLastRecord(IEnumerable<long> monitorPointIds)
        {
            if (monitorPointIds == null || monitorPointIds.Count() < 1)
                return default;
            var redisHelper = new MonitorRecordCacheHelper();
            var record = redisHelper.GetLastRecord(monitorPointIds);
            return record;
        }

        #endregion




        #region Insert




        /// <summary>
        /// 插入最近多条记录
        /// </summary>
        public bool InsertsLastRecord(List<Model.MonitorRecord> list)
        {
            if (list == null || list.Count() < 1)
                return default;
            var queueHelper = new RabbitMqQueueHelper();
            var bol = queueHelper.Push(ConfigHelper.StoreQueueName, list);
            if (bol)
            {
                var redisHelper = new MonitorRecordCacheHelper();
                redisHelper.SetLastRecord(list, out string info);
            }
            return bol;
        }

        #endregion


    }
}