当前位置：首页 > news >正文

`SaveKeyDataAsync` 重构优化版本

news 2026/5/27 22:53:29

✅SaveKeyDataAsync重构优化版本

以下是针对StationRepository中SaveKeyDataAsync方法的完整重构，包含生产级最佳实践。

1. 重构后的`StationRepository.cs`（重点方法）

// MaxWell.Repository/StationRepository.csusingMicrosoft.EntityFrameworkCore;usingMaxWell.Interface;usingMaxWell.Model;usingSystem;usingSystem.Threading.Tasks;namespaceMaxWell.Repository{publicclassStationRepository:IStationRepository{privatereadonlyIDbContextFactory<AppDbContext>_dbContextFactory;publicStationRepository(IDbContextFactory<AppDbContext>dbContextFactory){_dbContextFactory=dbContextFactory??thrownewArgumentNullException(nameof(dbContextFactory));}/// <summary>/// 重构后的 SaveKeyDataAsync - 推荐最终版本/// </summary>publicasyncTaskSaveKeyDataAsync(HardwareDatadata){if(data==null)return;// 基础数据验证if(string.IsNullOrWhiteSpace(data.HardwareSN)&&string.IsNullOrWhiteSpace(data.Address)){return;}awaitusingvarcontext=await_dbContextFactory.CreateDbContextAsync();try{varlogEntity=newHardwareDataLog{StationId=data.StationId??"Unknown",HardwareSN=data.HardwareSN,Address=data.Address,Value=data.Value?.ToString()??string.Empty,DataType=data.SignalDataType??"Unknown",Quality=data.Quality??"Good",Timestamp=data.Timestamp.ToLocalTime(),CreatedAt=DateTime.UtcNow,IsKeyData=data.IsKeyData};context.HardwareDataLogs.Add(logEntity);// 性能优化：批量插入时可使用 AddRangeawaitcontext.SaveChangesAsync();}catch(DbUpdateExceptiondbEx){// 处理数据库更新异常（如唯一约束违反等）// 可在此处记录日志或发送报警thrownewInvalidOperationException($"保存硬件数据失败 [Station:{data.StationId}]",dbEx);}catch(Exceptionex){thrownewInvalidOperationException($"保存硬件数据时发生未知错误",ex);}}// ... 其他方法保持不变}}

2. 推荐的实体模型（`HardwareDataLog`）

请在MaxWell.Model或MaxWell.Repository.Entities中添加以下实体：

// MaxWell.Model/HardwareDataLog.csusingSystem;usingSystem.ComponentModel.DataAnnotations;usingSystem.ComponentModel.DataAnnotations.Schema;namespaceMaxWell.Model{[Table("HardwareDataLogs")]publicclassHardwareDataLog{[Key][DatabaseGenerated(DatabaseGeneratedOption.Identity)]publiclongId{get;set;}[Required][MaxLength(50)]publicstringStationId{get;set;}=string.Empty;[MaxLength(100)]publicstringHardwareSN{get;set;}=string.Empty;[MaxLength(100)]publicstringAddress{get;set;}=string.Empty;publicstringValue{get;set;}=string.Empty;[MaxLength(20)]publicstringDataType{get;set;}=string.Empty;[MaxLength(20)]publicstringQuality{get;set;}="Good";publicDateTimeTimestamp{get;set;}publicDateTimeCreatedAt{get;set;}publicboolIsKeyData{get;set;}// 可扩展字段publicstring?ExtraInfo{get;set;}}}

3. 在`AppDbContext`中映射（推荐）

publicclassAppDbContext:DbContext{publicDbSet<HardwareDataLog>HardwareDataLogs{get;set;}=null!;protectedoverridevoidOnModelCreating(ModelBuildermodelBuilder){modelBuilder.Entity<HardwareDataLog>(entity=>{entity.HasIndex(e=>new{e.StationId,e.Timestamp});entity.HasIndex(e=>e.HardwareSN);entity.Property(e=>e.Value).HasMaxLength(500);});}}