diff --git a/DMS.Application/Services/Database/TriggerVariableAppService.cs b/DMS.Application/Services/Database/TriggerVariableAppService.cs index f79fd65..41086d9 100644 --- a/DMS.Application/Services/Database/TriggerVariableAppService.cs +++ b/DMS.Application/Services/Database/TriggerVariableAppService.cs @@ -65,7 +65,7 @@ public class TriggerVariableAppService : ITriggerVariableAppService /// public async Task> AddTriggerVariablesAsync(List triggerVariables) { - return await _repositoryManager.TriggerVariables.AddBatchAsync(triggerVariables); + return await _repositoryManager.TriggerVariables.AddAsync(triggerVariables); } } \ No newline at end of file diff --git a/DMS.Application/Services/Database/VariableAppService.cs b/DMS.Application/Services/Database/VariableAppService.cs index 62229b9..b39bb95 100644 --- a/DMS.Application/Services/Database/VariableAppService.cs +++ b/DMS.Application/Services/Database/VariableAppService.cs @@ -224,7 +224,7 @@ public class VariableAppService : IVariableAppService try { var variableModels = _mapper.Map>(variables); - var addedVariables = await _repoManager.Variables.AddBatchAsync(variableModels); + var addedVariables = await _repoManager.Variables.AddAsync(variableModels); return _mapper.Map>(addedVariables); } catch (Exception ex) diff --git a/DMS.Application/Services/Processors/HistoryProcessor.cs b/DMS.Application/Services/Processors/HistoryProcessor.cs index ab4d147..dff1e0a 100644 --- a/DMS.Application/Services/Processors/HistoryProcessor.cs +++ b/DMS.Application/Services/Processors/HistoryProcessor.cs @@ -94,7 +94,7 @@ public class HistoryProcessor : IVariableProcessor, IDisposable { try { - await _repositoryManager.VariableHistories.AddBatchAsync(itemsToProcess); + await _repositoryManager.VariableHistories.AddAsync(itemsToProcess); _logger.LogInformation("成功插入 {Count} 条变量历史记录到数据库", itemsToProcess.Count); } catch (Exception ex) diff --git a/DMS.Core/Interfaces/Repositories/IBaseRepository.cs b/DMS.Core/Interfaces/Repositories/IBaseRepository.cs index f4c3fba..4e4d645 100644 --- a/DMS.Core/Interfaces/Repositories/IBaseRepository.cs +++ b/DMS.Core/Interfaces/Repositories/IBaseRepository.cs @@ -50,5 +50,5 @@ public interface IBaseRepository where T : class /// 异步批量添加实体。 /// /// 要添加的实体列表。 - Task> AddBatchAsync(List entities); + Task> AddAsync(List entities); } \ No newline at end of file diff --git a/DMS.Infrastructure/Repositories/BaseRepository.cs b/DMS.Infrastructure/Repositories/BaseRepository.cs index 19194fd..f017a8e 100644 --- a/DMS.Infrastructure/Repositories/BaseRepository.cs +++ b/DMS.Infrastructure/Repositories/BaseRepository.cs @@ -151,7 +151,7 @@ public abstract class BaseRepository - public async Task> AddBatchAsync(List entities) + public async Task> AddAsync(List entities) { var stopwatch = new Stopwatch(); stopwatch.Start(); diff --git a/DMS.Infrastructure/Repositories/DeviceRepository.cs b/DMS.Infrastructure/Repositories/DeviceRepository.cs index 02ca7e4..103d3d0 100644 --- a/DMS.Infrastructure/Repositories/DeviceRepository.cs +++ b/DMS.Infrastructure/Repositories/DeviceRepository.cs @@ -65,7 +65,7 @@ public class DeviceRepository : BaseRepository, IDeviceRepository /// /// 要更新的设备实体。 /// 受影响的行数。 - public async Task UpdateAsync(Core.Models.Device model) => await base.UpdateAsync(_mapper.Map(model)); + public async Task UpdateAsync(Device model) => await base.UpdateAsync(_mapper.Map(model)); /// @@ -76,10 +76,10 @@ public class DeviceRepository : BaseRepository, IDeviceRepository public async Task DeleteAsync(Device model) => await base.DeleteAsync(new List { _mapper.Map(model) }); - public async Task> AddBatchAsync(List entities) + public async Task> AddAsync(List entities) { var dbEntities = _mapper.Map>(entities); - var addedEntities = await base.AddBatchAsync(dbEntities); + var addedEntities = await base.AddAsync(dbEntities); return _mapper.Map>(addedEntities); } diff --git a/DMS.Infrastructure/Repositories/EmailAccountRepository.cs b/DMS.Infrastructure/Repositories/EmailAccountRepository.cs index 37571bb..0db437a 100644 --- a/DMS.Infrastructure/Repositories/EmailAccountRepository.cs +++ b/DMS.Infrastructure/Repositories/EmailAccountRepository.cs @@ -118,7 +118,7 @@ namespace DMS.Infrastructure.Repositories /// /// 异步批量添加实体。 /// - public async Task> AddBatchAsync(List entities) + public async Task> AddAsync(List entities) { var dbEntities = _mapper.Map>(entities); var insertedEntities = new List(); diff --git a/DMS.Infrastructure/Repositories/EmailLogRepository.cs b/DMS.Infrastructure/Repositories/EmailLogRepository.cs index 71147ed..6a854b9 100644 --- a/DMS.Infrastructure/Repositories/EmailLogRepository.cs +++ b/DMS.Infrastructure/Repositories/EmailLogRepository.cs @@ -94,7 +94,7 @@ namespace DMS.Infrastructure.Repositories /// /// 异步批量添加实体。 /// - public async Task> AddBatchAsync(List entities) + public async Task> AddAsync(List entities) { var dbEntities = _mapper.Map>(entities); var insertedEntities = new List(); diff --git a/DMS.Infrastructure/Repositories/EmailMessageRepository.cs b/DMS.Infrastructure/Repositories/EmailMessageRepository.cs index fa8db6a..845271a 100644 --- a/DMS.Infrastructure/Repositories/EmailMessageRepository.cs +++ b/DMS.Infrastructure/Repositories/EmailMessageRepository.cs @@ -93,7 +93,7 @@ namespace DMS.Infrastructure.Repositories /// /// 异步批量添加实体。 /// - public async Task> AddBatchAsync(List entities) + public async Task> AddAsync(List entities) { var dbEntities = _mapper.Map>(entities); var insertedEntities = new List(); diff --git a/DMS.Infrastructure/Repositories/EmailTemplateRepository.cs b/DMS.Infrastructure/Repositories/EmailTemplateRepository.cs index 3c09600..f660c97 100644 --- a/DMS.Infrastructure/Repositories/EmailTemplateRepository.cs +++ b/DMS.Infrastructure/Repositories/EmailTemplateRepository.cs @@ -93,7 +93,7 @@ namespace DMS.Infrastructure.Repositories /// /// 异步批量添加实体。 /// - public async Task> AddBatchAsync(List entities) + public async Task> AddAsync(List entities) { var dbEntities = _mapper.Map>(entities); var insertedEntities = new List(); diff --git a/DMS.Infrastructure/Repositories/MenuRepository.cs b/DMS.Infrastructure/Repositories/MenuRepository.cs index e684dc4..bd39e59 100644 --- a/DMS.Infrastructure/Repositories/MenuRepository.cs +++ b/DMS.Infrastructure/Repositories/MenuRepository.cs @@ -148,10 +148,10 @@ public class MenuRepository : BaseRepository, IMenuRepository } - public async Task> AddBatchAsync(List entities) + public async Task> AddAsync(List entities) { var dbEntities = _mapper.Map>(entities); - var addedEntities = await base.AddBatchAsync(dbEntities); + var addedEntities = await base.AddAsync(dbEntities); return _mapper.Map>(addedEntities); } diff --git a/DMS.Infrastructure/Repositories/MqttAliasRepository.cs b/DMS.Infrastructure/Repositories/MqttAliasRepository.cs index d2f84cb..688bf26 100644 --- a/DMS.Infrastructure/Repositories/MqttAliasRepository.cs +++ b/DMS.Infrastructure/Repositories/MqttAliasRepository.cs @@ -80,10 +80,10 @@ public class MqttAliasRepository : BaseRepository, IMqttAliasReposi - public async Task> AddBatchAsync(List entities) + public async Task> AddAsync(List entities) { var dbEntities = _mapper.Map>(entities); - var addedEntities = await base.AddBatchAsync(dbEntities); + var addedEntities = await base.AddAsync(dbEntities); return _mapper.Map>(addedEntities); } diff --git a/DMS.Infrastructure/Repositories/MqttServerRepository.cs b/DMS.Infrastructure/Repositories/MqttServerRepository.cs index bf4ed95..05db5b8 100644 --- a/DMS.Infrastructure/Repositories/MqttServerRepository.cs +++ b/DMS.Infrastructure/Repositories/MqttServerRepository.cs @@ -76,10 +76,10 @@ public class MqttServerRepository : BaseRepository, IMqttServerRep - public async Task> AddBatchAsync(List entities) + public async Task> AddAsync(List entities) { var dbEntities = _mapper.Map>(entities); - var addedEntities = await base.AddBatchAsync(dbEntities); + var addedEntities = await base.AddAsync(dbEntities); return _mapper.Map>(addedEntities); } diff --git a/DMS.Infrastructure/Repositories/NlogRepository.cs b/DMS.Infrastructure/Repositories/NlogRepository.cs index ca19592..134763d 100644 --- a/DMS.Infrastructure/Repositories/NlogRepository.cs +++ b/DMS.Infrastructure/Repositories/NlogRepository.cs @@ -110,10 +110,10 @@ public class NlogRepository : BaseRepository, INlogRepository /// /// 要添加的Nlog日志实体列表。 /// 添加的Nlog日志实体列表。 - public new async Task> AddBatchAsync(List entities) + public new async Task> AddAsync(List entities) { var dbEntities = _mapper.Map>(entities); - var addedEntities = await base.AddBatchAsync(dbEntities); + var addedEntities = await base.AddAsync(dbEntities); return _mapper.Map>(addedEntities); } diff --git a/DMS.Infrastructure/Repositories/TriggerRepository.cs b/DMS.Infrastructure/Repositories/TriggerRepository.cs index e1188e2..a9c2379 100644 --- a/DMS.Infrastructure/Repositories/TriggerRepository.cs +++ b/DMS.Infrastructure/Repositories/TriggerRepository.cs @@ -88,10 +88,10 @@ namespace DMS.Infrastructure.Repositories - public async Task> AddBatchAsync(List entities) + public async Task> AddAsync(List entities) { var dbEntities = _mapper.Map>(entities); - var addedEntities = await base.AddBatchAsync(dbEntities); + var addedEntities = await base.AddAsync(dbEntities); return _mapper.Map>(addedEntities); } diff --git a/DMS.Infrastructure/Repositories/TriggerVariableRepository.cs b/DMS.Infrastructure/Repositories/TriggerVariableRepository.cs index fe0abfc..e9b5abd 100644 --- a/DMS.Infrastructure/Repositories/TriggerVariableRepository.cs +++ b/DMS.Infrastructure/Repositories/TriggerVariableRepository.cs @@ -80,10 +80,10 @@ public class TriggerVariableRepository : BaseRepository, ITri - public async Task> AddBatchAsync(List entities) + public async Task> AddAsync(List entities) { var dbEntities = _mapper.Map>(entities); - var addedEntities = await base.AddBatchAsync(dbEntities); + var addedEntities = await base.AddAsync(dbEntities); return _mapper.Map>(addedEntities); } diff --git a/DMS.Infrastructure/Repositories/UserRepository.cs b/DMS.Infrastructure/Repositories/UserRepository.cs index 7300783..f4a8b17 100644 --- a/DMS.Infrastructure/Repositories/UserRepository.cs +++ b/DMS.Infrastructure/Repositories/UserRepository.cs @@ -79,10 +79,10 @@ public class UserRepository : BaseRepository, IUserRepository - public async Task> AddBatchAsync(List entities) + public async Task> AddAsync(List entities) { var dbEntities = _mapper.Map>(entities); - var addedEntities = await base.AddBatchAsync(dbEntities); + var addedEntities = await base.AddAsync(dbEntities); return _mapper.Map>(addedEntities); } diff --git a/DMS.Infrastructure/Repositories/VariableHistoryRepository.cs b/DMS.Infrastructure/Repositories/VariableHistoryRepository.cs index 5c4f215..9a8117f 100644 --- a/DMS.Infrastructure/Repositories/VariableHistoryRepository.cs +++ b/DMS.Infrastructure/Repositories/VariableHistoryRepository.cs @@ -78,10 +78,10 @@ public class VariableHistoryRepository : BaseRepository, IVar - public async Task> AddBatchAsync(List entities) + public async Task> AddAsync(List entities) { var dbEntities = _mapper.Map>(entities); - var addedEntities = await base.AddBatchAsync(dbEntities); + var addedEntities = await base.AddAsync(dbEntities); return _mapper.Map>(addedEntities); } diff --git a/DMS.Infrastructure/Repositories/VariableRepository.cs b/DMS.Infrastructure/Repositories/VariableRepository.cs index a4b127d..835eba3 100644 --- a/DMS.Infrastructure/Repositories/VariableRepository.cs +++ b/DMS.Infrastructure/Repositories/VariableRepository.cs @@ -95,10 +95,10 @@ public class VariableRepository : BaseRepository, IVariableRepositor - public async Task> AddBatchAsync(List entities) + public async Task> AddAsync(List entities) { var dbEntities = _mapper.Map>(entities); - var addedEntities = await base.AddBatchAsync(dbEntities); + var addedEntities = await base.AddAsync(dbEntities); return _mapper.Map>(addedEntities); } diff --git a/DMS.Infrastructure/Repositories/VariableTableRepository.cs b/DMS.Infrastructure/Repositories/VariableTableRepository.cs index 16877bc..a446444 100644 --- a/DMS.Infrastructure/Repositories/VariableTableRepository.cs +++ b/DMS.Infrastructure/Repositories/VariableTableRepository.cs @@ -100,10 +100,10 @@ public class VariableTableRepository : BaseRepository, IVariabl - public async Task> AddBatchAsync(List entities) + public async Task> AddAsync(List entities) { var dbEntities = _mapper.Map>(entities); - var addedEntities = await base.AddBatchAsync(dbEntities); + var addedEntities = await base.AddAsync(dbEntities); return _mapper.Map>(addedEntities); }