From 69cad7bdee366cf365e5a7427675d09848eab68a Mon Sep 17 00:00:00 2001
From: ChenYi <296215406@outlook.com>
Date: Tue, 18 Mar 2025 17:10:54 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=AE=9A=E6=97=B6=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=E5=8F=91=E9=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../BasicScheduledMeterReadingService.cs                     | 5 +++--
 src/JiShe.CollectBus.Common/Consts/RedisConst.cs             | 2 +-
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/JiShe.CollectBus.Application/ScheduledMeterReading/BasicScheduledMeterReadingService.cs b/src/JiShe.CollectBus.Application/ScheduledMeterReading/BasicScheduledMeterReadingService.cs
index e477551..09c5126 100644
--- a/src/JiShe.CollectBus.Application/ScheduledMeterReading/BasicScheduledMeterReadingService.cs
+++ b/src/JiShe.CollectBus.Application/ScheduledMeterReading/BasicScheduledMeterReadingService.cs
@@ -398,7 +398,8 @@ namespace JiShe.CollectBus.ScheduledMeterReading
             {
                 foreach (var ammerterItem in focusItem.Value)
                 {
-                     _= _capBus.PublishAsync(ProtocolConst.AmmeterSubscriberWorkerFifteenMinuteIssuedEventName, ammerterItem.Value);
+                    //todo 可能需要优化，如果使用等待，会很慢，但使用不等待，mongodb 连接池又没法抗住，先发送微妙级的延时队列消息，暂时先这样处理
+                     _= _capBus.PublishDelayAsync(TimeSpan.FromMicroseconds(500), ProtocolConst.AmmeterSubscriberWorkerFifteenMinuteIssuedEventName, ammerterItem.Value);
                     meterTaskInfosList.Add(ammerterItem.Value);
                 }
             }
@@ -408,7 +409,7 @@ namespace JiShe.CollectBus.ScheduledMeterReading
             }
 
             //删除任务数据
-            await FreeRedisProvider.Instance.DelAsync(redisKeyList);
+            await FreeRedisProvider.Instance.DelAsync(oneMinutekeyList);
 
             //缓存下一个时间的任务
             TasksToBeIssueModel nextTask = new TasksToBeIssueModel()
diff --git a/src/JiShe.CollectBus.Common/Consts/RedisConst.cs b/src/JiShe.CollectBus.Common/Consts/RedisConst.cs
index 1447d4c..9b921c9 100644
--- a/src/JiShe.CollectBus.Common/Consts/RedisConst.cs
+++ b/src/JiShe.CollectBus.Common/Consts/RedisConst.cs
@@ -11,7 +11,7 @@ namespace JiShe.CollectBus.Common.Consts
         /// <summary>
         /// 缓存基础目录
         /// </summary>
-        public const string CacheBasicDirectoryKey = "CollectBus";
+        public const string CacheBasicDirectoryKey = "CollectBus:";
 
         /// <summary>
         /// 1分钟采集间隔