From 37781e32e137fe22f10fc95d73aa6dffb0de0af8 Mon Sep 17 00:00:00 2001 From: zenghongyao <873884283@qq.com> Date: Tue, 22 Apr 2025 09:40:09 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Subscribers/SubscriberAppService.cs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/services/JiShe.CollectBus.Application/Subscribers/SubscriberAppService.cs b/services/JiShe.CollectBus.Application/Subscribers/SubscriberAppService.cs index 3afc05f..569186b 100644 --- a/services/JiShe.CollectBus.Application/Subscribers/SubscriberAppService.cs +++ b/services/JiShe.CollectBus.Application/Subscribers/SubscriberAppService.cs @@ -20,6 +20,7 @@ using TouchSocket.Sockets; using Volo.Abp.Domain.Repositories; using System.Collections.Generic; using JiShe.CollectBus.Kafka.Internal; +using JiShe.CollectBus.IoTDB.Provider; namespace JiShe.CollectBus.Subscribers { @@ -47,7 +48,7 @@ namespace JiShe.CollectBus.Subscribers IServiceProvider serviceProvider, IRepository messageReceivedLoginEventRepository, IRepository messageReceivedHeartbeatEventRepository, - IIoTDbProvider dbProvider, + IoTDBProvider dbProvider, IMeterReadingRecordRepository meterReadingRecordsRepository) { _logger = logger;