using JiShe.CollectBus.Common.Enums;
using System;
using Volo.Abp.Domain.Entities;

namespace JiShe.CollectBus.IotSystems.MessageIssueds
{
    /// <summary>
    /// 定时抄读Kafka消息实体，1分钟、5分钟、15分钟
    /// </summary>
    public class ScheduledMeterReadingIssuedEventMessage 
    {
        /// <summary>
        /// 下发消息内容
        /// </summary>
        public string MessageHexString { get; set; }

        /// <summary>
        /// 集中器编号
        /// </summary>
        public string FocusAddress { get; set; }

        /// <summary>
        /// 采集时间间隔，通过Kafka主题区分(分钟，如15)
        /// </summary>
        public string TimeDensity { get; set; }

        /// <summary>
        /// 消息Id
        /// </summary>
        public string MessageId { get; set; }

        /// <summary>
        /// 最后一次消息Id，用于在消费消息时检查上一个任务是否处理完。
        /// </summary>
        public string LastMessageId { get; set; }

    }
}