JiShe.CollectBus/services/JiShe.CollectBus.Application.Contracts/Subscribers/IWorkerSubscriberAppService.cs

using JiShe.CollectBus.IotSystems.MessageIssueds;
using JiShe.CollectBus.IotSystems.MessageReceiveds;
using JiShe.CollectBus.IotSystems.MeterReadingRecords;
using JiShe.CollectBus.Kafka;
using System.Collections.Generic;
using System.Threading.Tasks;
using Volo.Abp.Application.Services;

namespace JiShe.CollectBus.Subscribers
{
    /// <summary>
    /// 定时抄读任务消息订阅
    /// </summary>
    public interface IWorkerSubscriberAppService : IApplicationService
    {

        #region 电表消息采集

        /// <summary>
        /// 1分钟采集电表数据下行消息消费订阅
        /// </summary>
        /// <returns></returns>
        Task<ISubscribeAck> AmmeterScheduledMeterOneMinuteReadingIssuedEvent(ScheduledMeterReadingIssuedEventMessage issuedEventMessage);

        /// <summary>
        /// 5分钟采集电表数据下行消息消费订阅
        /// </summary>
        /// <returns></returns>
        Task<ISubscribeAck> AmmeterScheduledMeterFiveMinuteReadingIssuedEvent(ScheduledMeterReadingIssuedEventMessage issuedEventMessage);

        /// <summary>
        /// 15分钟采集电表数据下行消息消费订阅
        /// </summary>
        /// <returns></returns>
        Task<ISubscribeAck> AmmeterScheduledMeterFifteenMinuteReadingIssuedEvent(ScheduledMeterReadingIssuedEventMessage issuedEventMessage);
        #endregion

        #region 水表消息采集
        /// <summary>
        /// 1分钟采集水表数据下行消息消费订阅
        /// </summary>
        /// <returns></returns>
        Task<ISubscribeAck> WatermeterSubscriberWorkerAutoReadingIssuedEvent(ScheduledMeterReadingIssuedEventMessage issuedEventMessage);
         
        #endregion
    }
}