DatabaseInitializer.cs 2.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061
  1. using SqlSugar;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Linq;
  5. using System.Text;
  6. using System.Threading.Tasks;
  7. using TeamAAS_VP.Interfaces;
  8. using TeamAAS_VP.Models;
  9. namespace TeamAAS_VP.Data
  10. {
  11. // 数据库初始化实现
  12. public class DatabaseInitializer : IDatabaseInitializer
  13. {
  14. private readonly ISqlSugarClient _db;
  15. public DatabaseInitializer(ISqlSugarClient db)
  16. {
  17. _db = db;
  18. }
  19. public void InitializeDatabase()
  20. {
  21. try
  22. {
  23. // 创建数据库(如果不存在)
  24. _db.DbMaintenance.CreateDatabase();
  25. // 创建表
  26. _db.CodeFirst.InitTables(typeof(User), typeof(ProductionRecord), typeof(UserLoginRecord), typeof(AlarmRecord));
  27. // 创建索引
  28. CreateIndexes();
  29. // 如果用户表为空,插入三个基础用户
  30. var userCount = _db.Queryable<User>().Count();
  31. if (userCount == 0)
  32. {
  33. var op = new User { UserName = "操作员", UserPassword = "123", userPart = Enums.UserPart.Operator, CreateTime = DateTime.Now, IsRemember = false };
  34. var eng = new User { UserName = "工程师", UserPassword = "123", userPart = Enums.UserPart.Engineer, CreateTime = DateTime.Now, IsRemember = false };
  35. var admin = new User { UserName = "管理员", UserPassword = "team123456", userPart = Enums.UserPart.Administrator, CreateTime = DateTime.Now, IsRemember = false };
  36. _db.Insertable(new List<User> { op, eng, admin }).ExecuteCommand();
  37. }
  38. }
  39. catch (Exception ex)
  40. {
  41. // 记录日志
  42. throw new Exception($"数据库初始化失败: {ex.Message}", ex);
  43. }
  44. }
  45. public bool DatabaseExists()
  46. {
  47. return _db.DbMaintenance.GetDataBaseList().Contains("AlignerDB");
  48. }
  49. private void CreateIndexes()
  50. {
  51. // 索引创建逻辑(同上一个回答)
  52. }
  53. }
  54. }