ads18.go 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151
  1. // Copyright 2019 getensh.com. All rights reserved.
  2. // Use of this source code is governed by getensh.com.
  3. package model
  4. import (
  5. "time"
  6. "adm-ads/common.in/utils"
  7. "go.uber.org/zap"
  8. "gorm.io/gorm"
  9. )
  10. type Ads18 struct {
  11. ID int64 `gorm:"primary_key" json:"-"`
  12. ModelNo string `json:"model_no"`
  13. PlateType string `json:"plate_type"`
  14. VehicleType string `json:"vehicle_type"`
  15. VehicleTypeDetail string `json:"vehicle_type_detail"`
  16. CreatedAt int64 `json:"-"`
  17. UpdatedAt int64 `json:"-"`
  18. }
  19. func (Ads18) TableName() string {
  20. return "t_adm_ads18"
  21. }
  22. // Insert 插入一条记录
  23. func (p *Ads18) Insert(db *gorm.DB) error {
  24. timeNow := time.Now().Unix()
  25. p.UpdatedAt = timeNow
  26. p.CreatedAt = timeNow
  27. err := db.Create(p).Error
  28. if err != nil {
  29. l.Error("mysql",
  30. zap.String("sql", "insert into "+p.TableName()),
  31. zap.String("fields", utils.MarshalJsonString(*p)),
  32. zap.String("error", err.Error()))
  33. }
  34. return err
  35. }
  36. func (p *Ads18) InsertByMap(db *gorm.DB, data map[string]interface{}) error {
  37. data["updated_at"] = time.Now().Unix()
  38. err := db.Model(p).Create(data).Error
  39. if err != nil {
  40. l.Error("mysql",
  41. zap.String("sql", "insert into "+p.TableName()),
  42. zap.String("fields", utils.MarshalJsonString(data)),
  43. zap.String("error", err.Error()))
  44. }
  45. return err
  46. }
  47. func (p *Ads18) Delete(db *gorm.DB, filter map[string]interface{}) error {
  48. err := db.Where(filter).Delete(p).Error
  49. if err != nil {
  50. l.Error("mysql",
  51. zap.String("sql", "delete from "+p.TableName()),
  52. zap.String("fields", utils.MarshalJsonString(filter)),
  53. zap.String("error", err.Error()))
  54. }
  55. return err
  56. }
  57. func (p *Ads18) Save(db *gorm.DB) error {
  58. timeNow := time.Now().Unix()
  59. p.UpdatedAt = timeNow
  60. p.CreatedAt = timeNow
  61. //db.Model().Update()
  62. err := db.Save(p).Error
  63. if err != nil {
  64. l.Error("mysql",
  65. zap.String("sql", "save "+p.TableName()),
  66. zap.String("fields", utils.MarshalJsonString(*p)),
  67. zap.String("error", err.Error()))
  68. }
  69. return err
  70. }
  71. func (p *Ads18) Update(db *gorm.DB) error {
  72. timeNow := time.Now().Unix()
  73. p.CreatedAt = 0
  74. p.UpdatedAt = timeNow
  75. err := db.Model(p).Updates(p).Error
  76. if err != nil {
  77. l.Error("mysql",
  78. zap.String("sql", "update "+p.TableName()),
  79. zap.String("fields", utils.MarshalJsonString(*p)),
  80. zap.String("error", err.Error()))
  81. }
  82. return err
  83. }
  84. func (p *Ads18) UpdateByMap(db *gorm.DB, data map[string]interface{}) error {
  85. data["updated_at"] = time.Now().Unix()
  86. err := db.Model(p).Updates(data).Error
  87. if err != nil {
  88. l.Error("mysql",
  89. zap.String("sql", "update "+p.TableName()),
  90. zap.String("fields", utils.MarshalJsonString(data)),
  91. zap.String("error", err.Error()))
  92. }
  93. return err
  94. }
  95. // 通过结构体变量更新字段值, gorm库会忽略零值字段。就是字段值等于0, nil, "", false这些值会被忽略掉,不会更新。如果想更新零值,可以使用map类型替代结构体。
  96. func (p *Ads18) UpdateSome(db *gorm.DB, filed map[string]interface{}) error {
  97. /*if filed == nil {
  98. return errors.ParamsError
  99. }*/
  100. timeNow := time.Now().Unix()
  101. filed["updated_at"] = timeNow
  102. err := db.Model(p).Updates(filed).Error
  103. if err != nil {
  104. l.Error("mysql",
  105. zap.String("sql", "update "+p.TableName()),
  106. zap.String("fields", utils.MarshalJsonString(filed)),
  107. zap.String("error", err.Error()))
  108. }
  109. return err
  110. }
  111. func (p *Ads18) Query(db *gorm.DB, filter map[string]interface{}) error {
  112. err := db.Where(filter).Find(p).Error
  113. if err != nil {
  114. l.Error("mysql",
  115. zap.String("sql", "select from "+p.TableName()),
  116. zap.String("fields", utils.MarshalJsonString(filter)),
  117. zap.String("error", err.Error()))
  118. }
  119. if p.ID == 0 {
  120. return gorm.ErrRecordNotFound
  121. }
  122. return err
  123. }
  124. func (p *Ads18) QueryAll(db *gorm.DB, filter map[string]interface{}, out interface{}) error {
  125. err := db.Where(filter).Find(out).Error
  126. if err != nil {
  127. l.Error("mysql",
  128. zap.String("sql", "select from "+p.TableName()),
  129. zap.String("fields", utils.MarshalJsonString(filter)),
  130. zap.String("error", err.Error()))
  131. }
  132. return err
  133. }