39 lines
1.0 KiB
C#
39 lines
1.0 KiB
C#
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; }
|
||
|
||
}
|
||
}
|