consume_fail.go 3.9 KB

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