model.go 2.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135
  1. package model
  2. import (
  3. "fmt"
  4. "github.com/0xJacky/Nginx-UI/logger"
  5. "github.com/0xJacky/Nginx-UI/server/settings"
  6. "github.com/gin-gonic/gin"
  7. "github.com/spf13/cast"
  8. "gorm.io/driver/sqlite"
  9. "gorm.io/gen"
  10. "gorm.io/gorm"
  11. gormlogger "gorm.io/gorm/logger"
  12. "path"
  13. "time"
  14. )
  15. var db *gorm.DB
  16. type Model struct {
  17. ID int `gorm:"primary_key" json:"id"`
  18. CreatedAt time.Time `json:"created_at"`
  19. UpdatedAt time.Time `json:"updated_at"`
  20. DeletedAt *gorm.DeletedAt `gorm:"index" json:"deleted_at"`
  21. }
  22. func GenerateAllModel() []any {
  23. return []any{
  24. ConfigBackup{},
  25. Auth{},
  26. AuthToken{},
  27. Cert{},
  28. ChatGPTLog{},
  29. Site{},
  30. DnsCredential{},
  31. }
  32. }
  33. func Init() *gorm.DB {
  34. dbPath := path.Join(path.Dir(settings.ConfPath), fmt.Sprintf("%s.db", settings.ServerSettings.Database))
  35. var err error
  36. db, err = gorm.Open(sqlite.Open(dbPath), &gorm.Config{
  37. Logger: gormlogger.Default.LogMode(gormlogger.Info),
  38. PrepareStmt: true,
  39. DisableForeignKeyConstraintWhenMigrating: true,
  40. })
  41. if err != nil {
  42. logger.Fatal(err.Error())
  43. }
  44. // Migrate the schema
  45. err = db.AutoMigrate(GenerateAllModel()...)
  46. if err != nil {
  47. logger.Fatal(err.Error())
  48. }
  49. return db
  50. }
  51. func orderAndPaginate(c *gin.Context) func(db *gorm.DB) *gorm.DB {
  52. return func(db *gorm.DB) *gorm.DB {
  53. sort := c.DefaultQuery("sort", "desc")
  54. order := c.DefaultQuery("order_by", "id") +
  55. " " + sort
  56. page := cast.ToInt(c.Query("page"))
  57. if page == 0 {
  58. page = 1
  59. }
  60. pageSize := settings.ServerSettings.PageSize
  61. reqPageSize := c.Query("page_size")
  62. if reqPageSize != "" {
  63. pageSize = cast.ToInt(reqPageSize)
  64. }
  65. offset := (page - 1) * pageSize
  66. return db.Order(order).Offset(offset).Limit(pageSize)
  67. }
  68. }
  69. func totalPage(total int64, pageSize int) int64 {
  70. n := total / int64(pageSize)
  71. if total%int64(pageSize) > 0 {
  72. n++
  73. }
  74. return n
  75. }
  76. type Pagination struct {
  77. Total int64 `json:"total"`
  78. PerPage int `json:"per_page"`
  79. CurrentPage int `json:"current_page"`
  80. TotalPages int64 `json:"total_pages"`
  81. }
  82. type DataList struct {
  83. Data interface{} `json:"data"`
  84. Pagination Pagination `json:"pagination,omitempty"`
  85. }
  86. func GetListWithPagination(models interface{},
  87. c *gin.Context, totalRecords int64) (result DataList) {
  88. page := cast.ToInt(c.Query("page"))
  89. if page == 0 {
  90. page = 1
  91. }
  92. result = DataList{}
  93. result.Data = models
  94. pageSize := settings.ServerSettings.PageSize
  95. reqPageSize := c.Query("page_size")
  96. if reqPageSize != "" {
  97. pageSize = cast.ToInt(reqPageSize)
  98. }
  99. result.Pagination = Pagination{
  100. Total: totalRecords,
  101. PerPage: pageSize,
  102. CurrentPage: page,
  103. TotalPages: totalPage(totalRecords, pageSize),
  104. }
  105. return
  106. }
  107. type Method interface {
  108. // FirstByID Where("id=@id")
  109. FirstByID(id int) (*gen.T, error)
  110. // DeleteByID update @@table set deleted_at=strftime('%Y-%m-%d %H:%M:%S','now') where id=@id
  111. DeleteByID(id int) error
  112. }