@@ -445,7 +445,7 @@ namespace HealthMonitor.Service.Resolver | |||||
#endregion | #endregion | ||||
#region 定时下发触发器 | #region 定时下发触发器 | ||||
var key = $"health_moniter/schedule_push/imei/{bp.Serialno}"; | |||||
var key = $"health_monitor/schedule_push/imei/{bp.Serialno}"; | |||||
var schedule_push = await _serviceEtcd.GetValAsync(key).ConfigureAwait(false); | var schedule_push = await _serviceEtcd.GetValAsync(key).ConfigureAwait(false); | ||||
if (string.IsNullOrWhiteSpace(schedule_push)) | if (string.IsNullOrWhiteSpace(schedule_push)) | ||||
{ | { | ||||
@@ -58,7 +58,7 @@ namespace HealthMonitor.Service.Resolver | |||||
var messageId = _messageId.Value; | var messageId = _messageId.Value; | ||||
var phr = _msgData.Value!; | var phr = _msgData.Value!; | ||||
#region 定时下发触发器 | #region 定时下发触发器 | ||||
var key = $"health_moniter/schedule_push/pregnancy_heart_rate/imei/{phr.Serialno}"; | |||||
var key = $"health_monitor/schedule_push/pregnancy_heart_rate/imei/{phr.Serialno}"; | |||||
var schedule_push = await _serviceEtcd.GetValAsync(key).ConfigureAwait(false); | var schedule_push = await _serviceEtcd.GetValAsync(key).ConfigureAwait(false); | ||||
if (string.IsNullOrWhiteSpace(schedule_push)) | if (string.IsNullOrWhiteSpace(schedule_push)) | ||||
@@ -91,7 +91,7 @@ namespace HealthMonitor.WebApi | |||||
}, stoppingToken), | }, stoppingToken), | ||||
Task.Run(() => | Task.Run(() => | ||||
_serviceEtcd.WacthKeysWithPrefixResponseAsync("health_moniter/schedule_push", WatchEvents), | |||||
_serviceEtcd.WacthKeysWithPrefixResponseAsync("health_monitor/schedule_push", WatchEvents), | |||||
stoppingToken) | stoppingToken) | ||||
}; | }; | ||||
@@ -119,7 +119,7 @@ namespace HealthMonitor.WebApi | |||||
//Console.BackgroundColor = ConsoleColor.Green; | //Console.BackgroundColor = ConsoleColor.Green; | ||||
//Console.WriteLine($"--- {e.Type}--{e.Kv.Key.ToStringUtf8()}--{e.Kv.Value.ToStringUtf8()}---{DateTime.Now}"); | //Console.WriteLine($"--- {e.Type}--{e.Kv.Key.ToStringUtf8()}--{e.Kv.Value.ToStringUtf8()}---{DateTime.Now}"); | ||||
// var key = $"health_moniter/schedule_push/imei/{bp.Serialno}"; | |||||
// var key = $"health_monitor/schedule_push/imei/{bp.Serialno}"; | |||||
var key = e.Kv.Key.ToStringUtf8(); | var key = e.Kv.Key.ToStringUtf8(); | ||||
var imeiDel = key.Split('/')[^1]; | var imeiDel = key.Split('/')[^1]; | ||||
var schedule_push = await _serviceEtcd.GetValAsync(key).ConfigureAwait(false); | var schedule_push = await _serviceEtcd.GetValAsync(key).ConfigureAwait(false); | ||||