using Kean.Application.Command.Interfaces;
using Kean.Infrastructure.Hangfire;
using Microsoft.Extensions.Configuration;
using System.Threading.Tasks;

namespace Kean.Presentation.Rest.Jobs
{
    /// <summary>
    /// 发送TV统计数据处理作业
    /// </summary>
    public class ClearRecordJob : IRecurringJob
    {
        private readonly IConfiguration _configuration;
        private readonly IInterfaceService _interfaceService; 

        /// <summary>
        /// 依赖注入
        /// </summary>
        public ClearRecordJob(
            IInterfaceService interfaceService,
            IConfiguration configuration)
        {
            _configuration = configuration;
            _interfaceService = interfaceService;
        }

        /*
         * 实现 Kean.Infrastructure.Hangfire.IRecurringJob.Execute 方法
         */
        [DisallowConcurrentExecution]
        public async Task Execute()
        {
            await _interfaceService.Clear(_configuration["SystemSetting:RecordRetainTime"]);
        }
    }
}