From c871d9045a3038ca925cf6fb81a01c71307d9914 Mon Sep 17 00:00:00 2001 From: wanggang <76527413@qq.com> Date: Tue, 12 Jan 2021 15:23:56 +0800 Subject: [PATCH] update Former-commit-id: ab537da368422aa24afd5df897037c851406efb8 Former-commit-id: 9e274e869576ccd5bafb4514232d9affc24fc897 --- projects/Infrastructure/Data/EfDbContext.cs | 6 +- .../Infrastructure/Events/EntityDeleted.cs | 9 ++ .../Events/EntityDeletedEvent.cs | 9 -- .../Infrastructure/Events/EntityInserted.cs | 9 ++ .../Events/EntityInsertedEvent.cs | 9 -- .../Infrastructure/Events/EntityUpdated.cs | 9 ++ .../Events/EntityUpdatedEvent.cs | 9 -- .../DeviceServices/BaseDeviceService.cs | 3 +- projects/IoTNode/Services/IoTNodeClient.cs | 10 +- .../IoTNode/Services/IoTNodeEventHandler.cs | 28 ++-- .../Services/IoTNodeToServerEventHandler.cs | 143 +++++------------- .../Platform/Services/CacheEventHandler.cs | 12 +- .../Services/IoTCenterEventHandler.cs | 96 ++++++------ projects/Platform/Services/IoTCenterHub.cs | 8 +- 14 files changed, 143 insertions(+), 217 deletions(-) create mode 100644 projects/Infrastructure/Events/EntityDeleted.cs delete mode 100644 projects/Infrastructure/Events/EntityDeletedEvent.cs create mode 100644 projects/Infrastructure/Events/EntityInserted.cs delete mode 100644 projects/Infrastructure/Events/EntityInsertedEvent.cs create mode 100644 projects/Infrastructure/Events/EntityUpdated.cs delete mode 100644 projects/Infrastructure/Events/EntityUpdatedEvent.cs diff --git a/projects/Infrastructure/Data/EfDbContext.cs b/projects/Infrastructure/Data/EfDbContext.cs index ce218339..43d1933e 100644 --- a/projects/Infrastructure/Data/EfDbContext.cs +++ b/projects/Infrastructure/Data/EfDbContext.cs @@ -99,15 +99,15 @@ namespace Infrastructure.Data } if (entry.State == EntityState.Added) { - events.Add(Activator.CreateInstance(typeof(EntityInsertedEvent<>).MakeGenericType(entry.Entity.GetType()), entry.Entity)); + events.Add(Activator.CreateInstance(typeof(EntityInserted<>).MakeGenericType(entry.Entity.GetType()), entry.Entity)); } else if (entry.State == EntityState.Modified) { - events.Add(Activator.CreateInstance(typeof(EntityUpdatedEvent<>).MakeGenericType(entry.Entity.GetType()), entry.Entity)); + events.Add(Activator.CreateInstance(typeof(EntityUpdated<>).MakeGenericType(entry.Entity.GetType()), entry.Entity)); } else if (entry.State == EntityState.Deleted) { - events.Add(Activator.CreateInstance(typeof(EntityDeletedEvent<>).MakeGenericType(entry.Entity.GetType()), entry.Entity)); + events.Add(Activator.CreateInstance(typeof(EntityDeleted<>).MakeGenericType(entry.Entity.GetType()), entry.Entity)); } this._logger.LogDebug($"{nameof(EfDbContext)}>{entity.GetType().Name}:{entry.State}"); } diff --git a/projects/Infrastructure/Events/EntityDeleted.cs b/projects/Infrastructure/Events/EntityDeleted.cs new file mode 100644 index 00000000..9726ef09 --- /dev/null +++ b/projects/Infrastructure/Events/EntityDeleted.cs @@ -0,0 +1,9 @@ +namespace Infrastructure.Events +{ + public class EntityDeleted : BaseEvent + { + public EntityDeleted(T entity) : base(entity, nameof(EntityDeleted)) + { + } + } +} \ No newline at end of file diff --git a/projects/Infrastructure/Events/EntityDeletedEvent.cs b/projects/Infrastructure/Events/EntityDeletedEvent.cs deleted file mode 100644 index 0dd4c5aa..00000000 --- a/projects/Infrastructure/Events/EntityDeletedEvent.cs +++ /dev/null @@ -1,9 +0,0 @@ -namespace Infrastructure.Events -{ - public class EntityDeletedEvent : BaseEvent - { - public EntityDeletedEvent(T entity) : base(entity, "EntityDeleted") - { - } - } -} \ No newline at end of file diff --git a/projects/Infrastructure/Events/EntityInserted.cs b/projects/Infrastructure/Events/EntityInserted.cs new file mode 100644 index 00000000..c1c88be5 --- /dev/null +++ b/projects/Infrastructure/Events/EntityInserted.cs @@ -0,0 +1,9 @@ +namespace Infrastructure.Events +{ + public class EntityInserted : BaseEvent + { + public EntityInserted(T entity) : base(entity, nameof(EntityInserted)) + { + } + } +} \ No newline at end of file diff --git a/projects/Infrastructure/Events/EntityInsertedEvent.cs b/projects/Infrastructure/Events/EntityInsertedEvent.cs deleted file mode 100644 index c118d3dd..00000000 --- a/projects/Infrastructure/Events/EntityInsertedEvent.cs +++ /dev/null @@ -1,9 +0,0 @@ -namespace Infrastructure.Events -{ - public class EntityInsertedEvent : BaseEvent - { - public EntityInsertedEvent(T entity) : base(entity, "EntityInserted") - { - } - } -} \ No newline at end of file diff --git a/projects/Infrastructure/Events/EntityUpdated.cs b/projects/Infrastructure/Events/EntityUpdated.cs new file mode 100644 index 00000000..acc62872 --- /dev/null +++ b/projects/Infrastructure/Events/EntityUpdated.cs @@ -0,0 +1,9 @@ +namespace Infrastructure.Events +{ + public class EntityUpdated : BaseEvent + { + public EntityUpdated(T entity) : base(entity, nameof(EntityUpdated)) + { + } + } +} \ No newline at end of file diff --git a/projects/Infrastructure/Events/EntityUpdatedEvent.cs b/projects/Infrastructure/Events/EntityUpdatedEvent.cs deleted file mode 100644 index ecaf735b..00000000 --- a/projects/Infrastructure/Events/EntityUpdatedEvent.cs +++ /dev/null @@ -1,9 +0,0 @@ -namespace Infrastructure.Events -{ - public class EntityUpdatedEvent : BaseEvent - { - public EntityUpdatedEvent(T entity) : base(entity, "EntityUpdated") - { - } - } -} \ No newline at end of file diff --git a/projects/IoTNode/DeviceServices/BaseDeviceService.cs b/projects/IoTNode/DeviceServices/BaseDeviceService.cs index c4ab28d2..1356961a 100644 --- a/projects/IoTNode/DeviceServices/BaseDeviceService.cs +++ b/projects/IoTNode/DeviceServices/BaseDeviceService.cs @@ -18,6 +18,7 @@ using System.ComponentModel.DataAnnotations; using NJsonSchema; using System.Globalization; using Microsoft.EntityFrameworkCore; +using Infrastructure.Events; namespace IoTNode.DeviceServices { @@ -104,7 +105,7 @@ namespace IoTNode.DeviceServices var response = httpClient.GetStringAsync(url).Result.FromJson(); if (!response) { - scope.ServiceProvider.GetRequiredService().ClientToServer($"{nameof(IoTProduct)}EntityUpdated", product, null); + scope.ServiceProvider.GetRequiredService().ClientToServer($"{nameof(IoTProduct)}{nameof(EntityUpdated)}", product, null); } } catch (Exception ex) diff --git a/projects/IoTNode/Services/IoTNodeClient.cs b/projects/IoTNode/Services/IoTNodeClient.cs index 3962133a..14f73f28 100644 --- a/projects/IoTNode/Services/IoTNodeClient.cs +++ b/projects/IoTNode/Services/IoTNodeClient.cs @@ -212,13 +212,13 @@ namespace IoT.Shared.Services public void OnConnected() { //上传网关 - this.UpdateEntityIdList(null, $"{nameof(IoTGateway)}EntityUpdated"); + this.UpdateEntityIdList(null, $"{nameof(IoTGateway)}{nameof(EntityUpdated)}"); //上传产品 - this.UpdateEntityIdList(null, $"{nameof(IoTProduct)}EntityUpdated"); + this.UpdateEntityIdList(null, $"{nameof(IoTProduct)}{nameof(EntityUpdated)}"); //上传设备Id列表、设备 - this.UpdateEntityIdList(Methods.UpdateDeviceIdList, $"{nameof(IoTDevice)}EntityUpdated"); + this.UpdateEntityIdList(Methods.UpdateDeviceIdList, $"{nameof(IoTDevice)}{nameof(EntityUpdated)}"); //上传数据 this.UpdateEntityIdList(null, $"{nameof(IoTData)}EntityUpdated", null, o => !o.Hidden); @@ -258,13 +258,13 @@ namespace IoT.Shared.Services dataService.Delete(model); this.ClientToServer(method, model, null); } - else if (method == $"{nameof(IoTData)}EntityInserted"|| method == $"{nameof(IoTData)}EntityUpdated")//服务端插入或更新数据 + else if (method == $"{nameof(IoTData)}{nameof(EntityDeleted)}" || method == $"{nameof(IoTData)}{nameof(EntityUpdated)}")//服务端插入或更新数据 { var model = message.FromJson(); dataService.Edit(model); this.ClientToServer(method, model, null); } - else if (method == $"{nameof(IoTData)}EntityDeleted")//服务端删除数据 + else if (method == $"{nameof(IoTData)}{nameof(EntityDeleted)}")//服务端删除数据 { var model = message.FromJson(); dataService.Delete(model); diff --git a/projects/IoTNode/Services/IoTNodeEventHandler.cs b/projects/IoTNode/Services/IoTNodeEventHandler.cs index 54d2d2f5..1b5f86e7 100644 --- a/projects/IoTNode/Services/IoTNodeEventHandler.cs +++ b/projects/IoTNode/Services/IoTNodeEventHandler.cs @@ -14,13 +14,13 @@ using System.Threading.Tasks; namespace IoTNode.Services { public class IoTNodeEventHandler : - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander> + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander> { private readonly ILogger _logger; @@ -42,7 +42,7 @@ namespace IoTNode.Services this._ioTNodeClient = ioTNodeClient; } - public void Handle(EntityUpdatedEvent message) + public void Handle(EntityUpdated message) { if (message.Data.Name == "stream.rtmp" || message.Data.Name == "ffmpeg.args") { @@ -62,32 +62,32 @@ namespace IoTNode.Services } } - public void Handle(EntityInsertedEvent message) + public void Handle(EntityInserted message) { this.Notify(message); } - public void Handle(EntityUpdatedEvent message) + public void Handle(EntityUpdated message) { this.Notify(message); } - public void Handle(EntityDeletedEvent message) + public void Handle(EntityDeleted message) { this.Notify(message); } - public void Handle(EntityInsertedEvent message) + public void Handle(EntityInserted message) { this.Upload(message); } - public void Handle(EntityUpdatedEvent message) + public void Handle(EntityUpdated message) { this.Upload(message); } - public void Handle(EntityDeletedEvent message) + public void Handle(EntityDeleted message) { this.Upload(message); } diff --git a/projects/IoTNode/Services/IoTNodeToServerEventHandler.cs b/projects/IoTNode/Services/IoTNodeToServerEventHandler.cs index 5295f315..70f99503 100644 --- a/projects/IoTNode/Services/IoTNodeToServerEventHandler.cs +++ b/projects/IoTNode/Services/IoTNodeToServerEventHandler.cs @@ -6,126 +6,111 @@ using Application.Domain.Entities; namespace IoTNode.Services { public class IoTNodeToServerEventHandler : - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander> - //IEventHander>, - //IEventHander>, - //IEventHander>, - //IEventHander>, - //IEventHander>, - //IEventHander>, - //IEventHander>, - //IEventHander>, - //IEventHander>, - //IEventHander>, - //IEventHander>, - //IEventHander> + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander> { - //private readonly ISceneTiggerService _sceneTiggerService; private readonly OnvifService _onvifService; private readonly IoTNodeClient _iotNodeClient; public IoTNodeToServerEventHandler( - //ISceneTiggerService sceneTiggerService, OnvifService onvifService, IoTNodeClient iotNodeClient) { - //this._sceneTiggerService = sceneTiggerService; this._onvifService = onvifService; this._iotNodeClient = iotNodeClient; } private void ClientToServer(BaseEvent message) { - if (message is EntityInsertedEvent || message is EntityUpdatedEvent) + if (message is EntityInserted || message is EntityUpdated) { _iotNodeClient.ClientToServer($"Edit{typeof(T).Name}", message.Data, null); } - else if (message is EntityDeletedEvent) + else if (message is EntityDeleted) { _iotNodeClient.ClientToServer($"Delete{typeof(T).Name}", message.Data, null); } } - public void Handle(EntityInsertedEvent message) + public void Handle(EntityInserted message) { this.ClientToServer(message); } - public void Handle(EntityUpdatedEvent message) + public void Handle(EntityUpdated message) { this.ClientToServer(message); } - public void Handle(EntityDeletedEvent message) + public void Handle(EntityDeleted message) { this.ClientToServer(message); } - public void Handle(EntityInsertedEvent message) + public void Handle(EntityInserted message) { this.ClientToServer(message); } - public void Handle(EntityUpdatedEvent message) + public void Handle(EntityUpdated message) { this.ClientToServer(message); } - public void Handle(EntityDeletedEvent message) + public void Handle(EntityDeleted message) { this.ClientToServer(message); } - public void Handle(EntityInsertedEvent message) + public void Handle(EntityInserted message) { this.ClientToServer(message); } - public void Handle(EntityUpdatedEvent message) + public void Handle(EntityUpdated message) { this.ClientToServer(message); } - public void Handle(EntityDeletedEvent message) + public void Handle(EntityDeleted message) { this.ClientToServer(message); } - public void Handle(EntityUpdatedEvent message) + public void Handle(EntityUpdated message) { this.ClientToServer(message); } - public void Handle(EntityInsertedEvent message) + public void Handle(EntityInserted message) { this.ClientToServer(message); } - public void Handle(EntityUpdatedEvent message) + public void Handle(EntityUpdated message) { this.ClientToServer(message); } - public void Handle(EntityDeletedEvent message) + public void Handle(EntityDeleted message) { this.ClientToServer(message); } - public void Handle(EntityInsertedEvent message) + public void Handle(EntityInserted message) { if (!message.Data.Hidden) { @@ -133,7 +118,7 @@ namespace IoTNode.Services } } - public void Handle(EntityUpdatedEvent message) + public void Handle(EntityUpdated message) { if (!message.Data.Hidden) { @@ -141,72 +126,12 @@ namespace IoTNode.Services } } - public void Handle(EntityDeletedEvent message) + public void Handle(EntityDeleted message) { if (!message.Data.Hidden) { this.ClientToServer(message); } } - - //public void Handle(EntityInsertedEvent message) - //{ - // this.ClientToServer(message); - //} - - //public void Handle(EntityUpdatedEvent message) - //{ - // this.ClientToServer(message); - //} - - //public void Handle(EntityDeletedEvent message) - //{ - // this.ClientToServer(message); - //} - - //public void Handle(EntityInsertedEvent message) - //{ - // this.ClientToServer(message); - //} - - //public void Handle(EntityUpdatedEvent message) - //{ - // this.ClientToServer(message); - //} - - //public void Handle(EntityDeletedEvent message) - //{ - // this.ClientToServer(message); - //} - - //public void Handle(EntityInsertedEvent message) - //{ - // this.ClientToServer(message); - //} - - //public void Handle(EntityUpdatedEvent message) - //{ - // this.ClientToServer(message); - //} - - //public void Handle(EntityDeletedEvent message) - //{ - // this.ClientToServer(message); - //} - - //public void Handle(EntityInsertedEvent message) - //{ - // this.ClientToServer(message); - //} - - //public void Handle(EntityUpdatedEvent message) - //{ - // this.ClientToServer(message); - //} - - //public void Handle(EntityDeletedEvent message) - //{ - // this.ClientToServer(message); - //} } } diff --git a/projects/Platform/Services/CacheEventHandler.cs b/projects/Platform/Services/CacheEventHandler.cs index 85c4dc22..00e2598f 100644 --- a/projects/Platform/Services/CacheEventHandler.cs +++ b/projects/Platform/Services/CacheEventHandler.cs @@ -5,9 +5,9 @@ using Microsoft.Extensions.Caching.Distributed; namespace Platform.Services { public class CacheEventHandler : - IEventHander>, - IEventHander>, - IEventHander> + IEventHander>, + IEventHander>, + IEventHander> { private readonly IDistributedCache _cache; @@ -16,17 +16,17 @@ namespace Platform.Services this._cache = cache; } - public void Handle(EntityInsertedEvent message) + public void Handle(EntityInserted message) { this.Remove(); } - public void Handle(EntityUpdatedEvent message) + public void Handle(EntityUpdated message) { this.Remove(); } - public void Handle(EntityDeletedEvent message) + public void Handle(EntityDeleted message) { this.Remove(); } diff --git a/projects/Platform/Services/IoTCenterEventHandler.cs b/projects/Platform/Services/IoTCenterEventHandler.cs index 948d3c37..09ddf0a3 100644 --- a/projects/Platform/Services/IoTCenterEventHandler.cs +++ b/projects/Platform/Services/IoTCenterEventHandler.cs @@ -25,30 +25,30 @@ using Vibrant.InfluxDB.Client.Rows; namespace Platform.Services { public class IoTCenterEventHandler : - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander>, - IEventHander> + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander>, + IEventHander> { private readonly IConfiguration _cfg; @@ -106,45 +106,45 @@ namespace Platform.Services } //Organ - public void Handle(EntityInsertedEvent message) + public void Handle(EntityInserted message) { this.Notify(message); } - public void Handle(EntityUpdatedEvent message) + public void Handle(EntityUpdated message) { this.Notify(message); } - public void Handle(EntityDeletedEvent message) + public void Handle(EntityDeleted message) { this.Notify(message); } //Building - public void Handle(EntityInsertedEvent message) + public void Handle(EntityInserted message) { this.Notify(message); } - public void Handle(EntityUpdatedEvent message) + public void Handle(EntityUpdated message) { this.Notify(message); } - public void Handle(EntityDeletedEvent message) + public void Handle(EntityDeleted message) { this.Notify(message); } //Product - public void Handle(EntityInsertedEvent message) + public void Handle(EntityInserted message) { UpdateProduct(message.Data); this.Notify(message); } - public void Handle(EntityUpdatedEvent message) + public void Handle(EntityUpdated message) { UpdateProduct(message.Data); this.Notify(message); @@ -163,24 +163,24 @@ namespace Platform.Services } } - public void Handle(EntityDeletedEvent message) + public void Handle(EntityDeleted message) { this.Notify(message); } - public void Handle(EntityInsertedEvent message) + public void Handle(EntityInserted message) { var timer = message.Data; RecurringJob.AddOrUpdate(timer.Id.ToString(), () => Handle(timer.Id), timer.Cron, TimeZoneInfo.Local); } - public void Handle(EntityUpdatedEvent message) + public void Handle(EntityUpdated message) { var timer = message.Data; RecurringJob.AddOrUpdate(timer.Id.ToString(), () => Handle(timer.Id), timer.Cron, TimeZoneInfo.Local); } - public void Handle(EntityDeletedEvent message) + public void Handle(EntityDeleted message) { var timer = message.Data; RecurringJob.RemoveIfExists(timer.Id.ToString()); @@ -209,37 +209,37 @@ namespace Platform.Services } } - public void Handle(EntityInsertedEvent message) + public void Handle(EntityInserted message) { this.Notify(message); } - public void Handle(EntityUpdatedEvent message) + public void Handle(EntityUpdated message) { this.Notify(message); } - public void Handle(EntityDeletedEvent message) + public void Handle(EntityDeleted message) { this.Notify(message); } - public void Handle(EntityInsertedEvent message) + public void Handle(EntityInserted message) { this.Notify(message); } - public void Handle(EntityUpdatedEvent message) + public void Handle(EntityUpdated message) { this.Notify(message); } - public void Handle(EntityDeletedEvent message) + public void Handle(EntityDeleted message) { this.Notify(message); } - public void Handle(EntityInsertedEvent message) + public void Handle(EntityInserted message) { message.Data.IoTDevice = _deviceRepo.ReadOnlyTable().Include(o => o.IoTGateway).Where(o => o.Id == message.Data.IoTDeviceId).FirstOrDefault(); this.Notify(message); @@ -247,7 +247,7 @@ namespace Platform.Services this.LogData(message.Data); } - public void Handle(EntityUpdatedEvent message) + public void Handle(EntityUpdated message) { message.Data.IoTDevice = _deviceRepo.ReadOnlyTable().Include(o => o.IoTGateway).Where(o => o.Id == message.Data.IoTDeviceId).FirstOrDefault(); this.Notify(message); @@ -255,22 +255,22 @@ namespace Platform.Services this.LogData(message.Data); } - public void Handle(EntityDeletedEvent message) + public void Handle(EntityDeleted message) { this.Notify(message); } - public void Handle(EntityInsertedEvent message) + public void Handle(EntityInserted message) { this.Notify(message); } - public void Handle(EntityUpdatedEvent message) + public void Handle(EntityUpdated message) { this.Notify(message); } - public void Handle(EntityDeletedEvent message) + public void Handle(EntityDeleted message) { this.Notify(message); } diff --git a/projects/Platform/Services/IoTCenterHub.cs b/projects/Platform/Services/IoTCenterHub.cs index 8bae31c0..5cc99cc5 100644 --- a/projects/Platform/Services/IoTCenterHub.cs +++ b/projects/Platform/Services/IoTCenterHub.cs @@ -122,12 +122,12 @@ namespace Platform.Services try { //网关上传 - if (method == $"{nameof(IoTGateway)}EntityUpdated")//接收网关 + if (method == $"{nameof(IoTGateway)}{nameof(EntityUpdated)}")//接收网关 { var entity = message.FromJson(); this._dataService.Update(entity, o => o.Number == entity.Number, new string[] { nameof(IoTGateway.BuildingId) }); } - else if (method == $"{nameof(IoTProduct)}EntityUpdated")//接收产品 + else if (method == $"{nameof(IoTProduct)}{nameof(EntityUpdated)}")//接收产品 { var entity = message.FromJson(); this._dataService.Update(entity, o => o.Number == entity.Number, skips: new string[] { nameof(IoTProduct.IoTProductCategoryId), nameof(IoTProduct.DisplayOrder) }); @@ -136,12 +136,12 @@ namespace Platform.Services { this._dataService.UpdateList(message, o => o.IoTGateway.Number == from); } - else if (method == $"{nameof(IoTDevice)}EntityUpdated")//接收设备 + else if (method == $"{nameof(IoTDevice)}{nameof(EntityUpdated)}")//接收设备 { var entity = message.FromJson(); this._dataService.Update(entity, o => o.Number == entity.Number); } - else if (method == $"{nameof(IoTData)}EntityUpdated")//接收数据 + else if (method == $"{nameof(IoTData)}{nameof(EntityUpdated)}")//接收数据 { this._dataService.Update(message.FromJson()); }