From 0b2b3bc3d23f6f434ff6293105fe97e36bd18fab Mon Sep 17 00:00:00 2001
From: ChenYi <296215406@outlook.com>
Date: Mon, 17 Mar 2025 15:13:54 +0800
Subject: [PATCH] =?UTF-8?q?=E5=90=AF=E5=8A=A8=E5=AE=9A=E6=97=B6=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Workers/SubscriberFifteenMinuteWorker.cs  | 44 +++++++++++++++++++
 .../Workers/SubscriberFiveMinuteWorker.cs     | 39 ++++++++++++++++
 .../Workers/SubscriberOneMinuteWorker.cs      | 39 ++++++++++++++++
 3 files changed, 122 insertions(+)
 create mode 100644 src/JiShe.CollectBus.Application/Workers/SubscriberFifteenMinuteWorker.cs
 create mode 100644 src/JiShe.CollectBus.Application/Workers/SubscriberFiveMinuteWorker.cs
 create mode 100644 src/JiShe.CollectBus.Application/Workers/SubscriberOneMinuteWorker.cs

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();
+        }
+    }
+}