dws17.go 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149
  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. "adm-dws/common.in/utils"
  6. "go.uber.org/zap"
  7. "gorm.io/gorm"
  8. "time"
  9. )
  10. type Dws17 struct {
  11. ID int64 `gorm:"primary_key" json:"-"`
  12. Vin string `json:"vin"`
  13. ThirdStyleId string `json:"third_style_id"`
  14. ThirdStyleIds string `json:"third_style_ids" gorm:"-"`
  15. Source string `json:"source"`
  16. CreatedAt int64 `json:"-"`
  17. UpdatedAt int64 `json:"-"`
  18. }
  19. func (Dws17) TableName() string {
  20. return "t_adm_dws17"
  21. }
  22. // Insert 插入一条记录
  23. func (p *Dws17) Insert(db *gorm.DB) error {
  24. timeNow := time.Now().Unix()
  25. p.CreatedAt = timeNow
  26. p.UpdatedAt = 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 *Dws17) 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 *Dws17) 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 *Dws17) Save(db *gorm.DB) error {
  58. timeNow := time.Now().Unix()
  59. p.UpdatedAt = timeNow
  60. //db.Model().Update()
  61. err := db.Save(p).Error
  62. if err != nil {
  63. l.Error("mysql",
  64. zap.String("sql", "save "+p.TableName()),
  65. zap.String("fields", utils.MarshalJsonString(*p)),
  66. zap.String("error", err.Error()))
  67. }
  68. return err
  69. }
  70. func (p *Dws17) Update(db *gorm.DB) error {
  71. timeNow := time.Now().Unix()
  72. p.CreatedAt = 0
  73. p.UpdatedAt = timeNow
  74. err := db.Model(p).Updates(p).Error
  75. if err != nil {
  76. l.Error("mysql",
  77. zap.String("sql", "update "+p.TableName()),
  78. zap.String("fields", utils.MarshalJsonString(*p)),
  79. zap.String("error", err.Error()))
  80. }
  81. return err
  82. }
  83. func (p *Dws17) UpdateByMap(db *gorm.DB, data map[string]interface{}) error {
  84. data["updated_at"] = time.Now().Unix()
  85. err := db.Model(p).Updates(data).Error
  86. if err != nil {
  87. l.Error("mysql",
  88. zap.String("sql", "update "+p.TableName()),
  89. zap.String("fields", utils.MarshalJsonString(data)),
  90. zap.String("error", err.Error()))
  91. }
  92. return err
  93. }
  94. // 通过结构体变量更新字段值, gorm库会忽略零值字段。就是字段值等于0, nil, "", false这些值会被忽略掉,不会更新。如果想更新零值,可以使用map类型替代结构体。
  95. func (p *Dws17) UpdateSome(db *gorm.DB, filed map[string]interface{}) error {
  96. /*if filed == nil {
  97. return errors.ParamsError
  98. }*/
  99. timeNow := time.Now().Unix()
  100. filed["updated_at"] = timeNow
  101. err := db.Model(p).Updates(filed).Error
  102. if err != nil {
  103. l.Error("mysql",
  104. zap.String("sql", "update "+p.TableName()),
  105. zap.String("fields", utils.MarshalJsonString(filed)),
  106. zap.String("error", err.Error()))
  107. }
  108. return err
  109. }
  110. func (p *Dws17) Query(db *gorm.DB, filter map[string]interface{}) error {
  111. err := db.Where(filter).Find(p).Error
  112. if err != nil {
  113. l.Error("mysql",
  114. zap.String("sql", "select from "+p.TableName()),
  115. zap.String("fields", utils.MarshalJsonString(filter)),
  116. zap.String("error", err.Error()))
  117. }
  118. if p.ID == 0 {
  119. return gorm.ErrRecordNotFound
  120. }
  121. return err
  122. }
  123. func (p *Dws17) QueryAll(db *gorm.DB, filter map[string]interface{}, out interface{}) error {
  124. err := db.Where(filter).Find(out).Error
  125. if err != nil {
  126. l.Error("mysql",
  127. zap.String("sql", "select from "+p.TableName()),
  128. zap.String("fields", utils.MarshalJsonString(filter)),
  129. zap.String("error", err.Error()))
  130. }
  131. return err
  132. }