diff --git a/src/JiShe.CollectBus.Application/Workers/SubscriberFifteenMinuteWorker.cs b/src/JiShe.CollectBus.Application/Workers/SubscriberFifteenMinuteWorker.cs
new file mode 100644
index 0000000..90c032f
--- /dev/null
+++ b/src/JiShe.CollectBus.Application/Workers/SubscriberFifteenMinuteWorker.cs
@@ -0,0 +1,44 @@
+using System.Threading;
+using System.Threading.Tasks;
+using Hangfire;
+using JiShe.CollectBus.ScheduledMeterReading;
+using Microsoft.Extensions.Logging;
+using Volo.Abp.BackgroundWorkers.Hangfire;
+using Volo.Abp.DependencyInjection;
+using Volo.Abp.Uow;
+
+namespace JiShe.CollectBus.Workers
+{
+    /// <summary>
+    /// 15分钟采集数据
+    /// </summary>
+    public class SubscriberFifteenMinuteWorker : HangfireBackgroundWorkerBase, ITransientDependency, ICollectWorker
+    {
+        private readonly ILogger<SubscriberFifteenMinuteWorker> _logger;
+        private readonly IScheduledMeterReadingService _scheduledMeterReadingService;
+
+        /// <summary>
+        /// Initializes a new instance of the <see cref="SubscriberFifteenMinuteWorker"/> class.
+        /// </summary>
+        /// <param name="logger">The logger.</param>
+        /// <param name="scheduledMeterReadingService">定时任务</param>
+        public SubscriberFifteenMinuteWorker(ILogger<SubscriberFifteenMinuteWorker> logger, IScheduledMeterReadingService scheduledMeterReadingService)
+        {
+            _logger = logger;
+            RecurringJobId = nameof(SubscriberFifteenMinuteWorker);
+            CronExpression = Cron.Hourly(15);
+            this._scheduledMeterReadingService = scheduledMeterReadingService;
+        }
+
+
+        public override async Task DoWorkAsync(CancellationToken cancellationToken = new CancellationToken())
+        {
+            await _scheduledMeterReadingService.AmmeterScheduledMeterFifteenMinuteReading();
+            //using (var uow = LazyServiceProvider.LazyGetRequiredService<IUnitOfWorkManager>().Begin())
+            //{
+            //    Logger.LogInformation("Executed MyLogWorker..!");
+            //    return Task.CompletedTask;
+            //}
+        }
+    }
+}
diff --git a/src/JiShe.CollectBus.Application/Workers/SubscriberFiveMinuteWorker.cs b/src/JiShe.CollectBus.Application/Workers/SubscriberFiveMinuteWorker.cs
new file mode 100644
index 0000000..f20cf86
--- /dev/null
+++ b/src/JiShe.CollectBus.Application/Workers/SubscriberFiveMinuteWorker.cs
@@ -0,0 +1,39 @@
+using System.Threading;
+using System.Threading.Tasks;
+using Hangfire;
+using JiShe.CollectBus.ScheduledMeterReading;
+using Microsoft.Extensions.Logging;
+using Volo.Abp.BackgroundWorkers.Hangfire;
+using Volo.Abp.DependencyInjection;
+using Volo.Abp.Uow;
+
+namespace JiShe.CollectBus.Workers
+{
+    /// <summary>
+    /// 5分钟采集数据
+    /// </summary>
+    public class SubscriberFiveMinuteWorker : HangfireBackgroundWorkerBase, ITransientDependency,ICollectWorker
+    {
+        private readonly ILogger<SubscriberFiveMinuteWorker> _logger;
+        private readonly IScheduledMeterReadingService _scheduledMeterReadingService;
+
+        /// <summary>
+        /// Initializes a new instance of the <see cref="SubscriberFifteenMinuteWorker"/> class.
+        /// </summary>
+        /// <param name="logger">The logger.</param>
+        /// <param name="scheduledMeterReadingService">定时任务</param>
+        public SubscriberFiveMinuteWorker(ILogger<SubscriberFiveMinuteWorker> logger, IScheduledMeterReadingService scheduledMeterReadingService)
+        {
+            _logger = logger;
+            RecurringJobId = nameof(SubscriberFiveMinuteWorker);
+            CronExpression = Cron.Hourly(15);
+            this._scheduledMeterReadingService = scheduledMeterReadingService;
+        }
+
+
+        public override async Task DoWorkAsync(CancellationToken cancellationToken = new CancellationToken())
+        {
+            await _scheduledMeterReadingService.AmmeterScheduledMeterFifteenMinuteReading();
+        }
+    }
+}
diff --git a/src/JiShe.CollectBus.Application/Workers/SubscriberOneMinuteWorker.cs b/src/JiShe.CollectBus.Application/Workers/SubscriberOneMinuteWorker.cs
new file mode 100644
index 0000000..2132cdf
--- /dev/null
+++ b/src/JiShe.CollectBus.Application/Workers/SubscriberOneMinuteWorker.cs
@@ -0,0 +1,39 @@
+using System.Threading;
+using System.Threading.Tasks;
+using Hangfire;
+using JiShe.CollectBus.ScheduledMeterReading;
+using Microsoft.Extensions.Logging;
+using Volo.Abp.BackgroundWorkers.Hangfire;
+using Volo.Abp.DependencyInjection;
+using Volo.Abp.Uow;
+
+namespace JiShe.CollectBus.Workers
+{
+    /// <summary>
+    /// 1分钟采集数据
+    /// </summary>
+    public class SubscriberOneMinuteWorker : HangfireBackgroundWorkerBase, ITransientDependency,ICollectWorker
+    {
+        private readonly ILogger<SubscriberOneMinuteWorker> _logger;
+        private readonly IScheduledMeterReadingService _scheduledMeterReadingService;
+
+        /// <summary>
+        /// Initializes a new instance of the <see cref="SubscriberFifteenMinuteWorker"/> class.
+        /// </summary>
+        /// <param name="logger">The logger.</param>
+        /// <param name="scheduledMeterReadingService">定时任务</param>
+        public SubscriberOneMinuteWorker(ILogger<SubscriberOneMinuteWorker> logger, IScheduledMeterReadingService scheduledMeterReadingService)
+        {
+            _logger = logger;
+            RecurringJobId = nameof(SubscriberOneMinuteWorker);
+            CronExpression = Cron.Hourly(15);
+            this._scheduledMeterReadingService = scheduledMeterReadingService;
+        }
+
+
+        public override async Task DoWorkAsync(CancellationToken cancellationToken = new CancellationToken())
+        {
+            await _scheduledMeterReadingService.AmmeterScheduledMeterFifteenMinuteReading();
+        }
+    }
+}