package model import ( "aps_crm/pkg/mysqlx" "gorm.io/gorm" "sync" ) type ( Satisfaction struct { Id int `json:"id" gorm:"column:id;primary_key;AUTO_INCREMENT"` Name string `json:"name" gorm:"column:name;type:varchar(255);comment:满意度名称"` } SatisfactionSearch struct { Satisfaction Orm *gorm.DB } ) func (Satisfaction) TableName() string { return "satisfaction" } func NewSatisfactionSearch() *SatisfactionSearch { return &SatisfactionSearch{ Orm: mysqlx.GetDB(), } } func (slf *SatisfactionSearch) build() *gorm.DB { var db = slf.Orm.Model(&Satisfaction{}) if slf.Id != 0 { db = db.Where("id = ?", slf.Id) } if slf.Name != "" { db = db.Where("name = ?", slf.Name) } return db } func (slf *SatisfactionSearch) Create(record *Satisfaction) error { var db = slf.build() return db.Create(record).Error } func (slf *SatisfactionSearch) Delete() error { var db = slf.build() return db.Delete(&Satisfaction{}).Error } func (slf *SatisfactionSearch) Update(record *Satisfaction) error { var db = slf.build() return db.Updates(record).Error } func (slf *SatisfactionSearch) Find() (*Satisfaction, error) { var db = slf.build() var record = new(Satisfaction) err := db.First(record).Error return record, err } func (slf *SatisfactionSearch) FindAll() ([]*Satisfaction, error) { var db = slf.build() var records = make([]*Satisfaction, 0) err := db.Find(&records).Error return records, err } func (slf *SatisfactionSearch) SetId(id int) *SatisfactionSearch { slf.Id = id return slf } func (slf *SatisfactionSearch) Updates(data map[string]interface{}) error { var db = slf.build() return db.Updates(data).Error } func (slf *SatisfactionSearch) CreateBatch(records []*Satisfaction) error { var db = slf.build() return db.Create(records).Error } // InitDefaultData 初始化数据 func (slf *SatisfactionSearch) InitDefaultData(errCh chan<- error, wg *sync.WaitGroup) { var ( db = slf.Orm.Table(slf.TableName()) total int64 = 0 ) defer wg.Done() if err := db.Count(&total).Error; err != nil { errCh <- err return } if total != 0 { return } records := []*Satisfaction{ {1, "100%"}, {2, "90%"}, {3, "80%"}, {4, "70%"}, {5, "60%"}, {6, "50%"}, {7, "40%"}, {8, "30%"}, {9, "20%"}, {10, "10%"}, } err := slf.CreateBatch(records) if err != nil { errCh <- err return } }