// Copyright 2019 getensh.com. All rights reserved. // Use of this source code is governed by getensh.com. package model import ( "git.getensh.com/common/gopkgs/logger" "git.getensh.com/common/gopkgs/util" "go.uber.org/zap" "gorm.io/gorm" "time" ) type TGateVisitor struct { ID int64 `gorm:"column:id;PRIMARY_KEY" json:"id"` Uid int64 `gorm:"column:uid" json:"uid"` Name string `gorm:"column:name" json:"name"` Phone string `gorm:"column:phone" json:"phone"` Visitor string `gorm:"column:visitor" json:"visitor"` VisitorPhone string `gorm:"column:visitor_phone" json:"visitor_phone"` Start int64 `gorm:"column:start" json:"start"` End int64 `gorm:"column:end" json:"end"` OpenTime int64 `gorm:"column:open_time" json:"open_time"` DeviceId int64 `gorm:"column:device_id" json:"device_id"` GardenId int64 `gorm:"column:garden_id" json:"garden_id"` Comment string `gorm:"column:comment" json:"comment"` Qcode string `gorm:"column:qcode" json:"qcode"` CreatedAt time.Time `gorm:"column:created_at" json:"created_at"` UpdatedAt time.Time `gorm:"column:updated_at" json:"updated_at"` } func (p *TGateVisitor) TableName() string { return "t_gate_visitor" } func (p *TGateVisitor) Find(db *gorm.DB, where [][2]interface{}) error { cond, val, err := whereBuild(where) if err != nil { if err != nil { fields, _ := util.MarshalToString(where) logger.Error("mysql", zap.String("sql", "find "+p.TableName()), zap.String("fields", fields), zap.String("error", err.Error())) } return err } err = db.Table(p.TableName()).Where(cond, val...).First(p).Error if err != nil { fields, _ := util.MarshalToString(where) logger.Error("mysql", zap.String("sql", "select from "+p.TableName()), zap.String("fields", fields), zap.String("error", err.Error())) } return err } func (p *TGateVisitor) Last(db *gorm.DB) error { err := db.Table(p.TableName()).Last(p).Error if err != nil { logger.Error("mysql", zap.String("sql", "select last from "+p.TableName()), zap.String("fields", ""), zap.String("error", err.Error())) } return err } // Insert 插入一条记录 func (p *TGateVisitor) Insert(db *gorm.DB) error { err := db.Create(p).Error if err != nil { fields, _ := util.MarshalToString(*p) logger.Error("mysql", zap.String("sql", "insert into "+p.TableName()), zap.String("fields", fields), zap.String("error", err.Error())) } return err } // Insert 插入多条记录 func (p *TGateVisitor) InsertMulti(db *gorm.DB, values interface{}) error { err := db.Table(p.TableName()).Create(values).Error if err != nil { fields, _ := util.MarshalToString(*p) logger.Error("mysql", zap.String("sql", "insert into "+p.TableName()), zap.String("fields", fields), zap.String("error", err.Error())) } return err } func (p *TGateVisitor) Delete(db *gorm.DB, filter [][2]interface{}) error { cond, val, err := whereBuild(filter) if err != nil { if err != nil { fields, _ := util.MarshalToString(filter) logger.Error("mysql", zap.String("sql", "delete "+p.TableName()), zap.String("fields", fields), zap.String("error", err.Error())) } return err } err = db.Where(cond, val...).Delete(p).Error if err != nil { fields, _ := util.MarshalToString(filter) logger.Error("mysql", zap.String("sql", "delete from "+p.TableName()), zap.String("where", fields), zap.String("error", err.Error())) } return err } func (p *TGateVisitor) Update(db *gorm.DB, where [][2]interface{}, values map[string]interface{}) error { cond, val, err := whereBuild(where) if err != nil { if err != nil { fields, _ := util.MarshalToString(values) logger.Error("mysql", zap.String("sql", "update "+p.TableName()), zap.String("fields", fields), zap.String("error", err.Error())) } return err } return db.Table(p.TableName()).Where(cond, val...).Updates(values).Error } func (p *TGateVisitor) Count(db *gorm.DB, where [][2]interface{}, or [][2]interface{}) (int64, error) { cond, val, err := whereBuildAndOr(where, or) if err != nil { return 0, err } ret := int64(0) err = db.Table(p.TableName()).Where(cond, val...).Count(&ret).Error if err != nil { fields, _ := util.MarshalToString(where) logger.Error("mysql", zap.String("sql", "select count "+p.TableName()), zap.String("fields", fields), zap.String("error", err.Error())) } return ret, err } func (p *TGateVisitor) List(db *gorm.DB, where [][2]interface{}, or [][2]interface{}, page int, pageSize int) (list []TGateVisitor, err error) { cond, val, err := whereBuildAndOr(where, or) if err != nil { return list, err } if pageSize < 0 { result := db.Table(p.TableName()).Where(cond, val...).Order("created_at desc").Find(&list) if result.Error != nil { wherefields, _ := util.MarshalToString(where) logger.Error("mysql", zap.String("sql", "select * from "+p.TableName()), zap.String("where", wherefields), zap.String("error", result.Error.Error())) } return list, result.Error } offset := (page - 1) * pageSize result := db.Table(p.TableName()).Where(cond, val...).Limit(pageSize).Offset(offset).Order("created_at desc").Find(&list) if result.Error != nil { wherefields, _ := util.MarshalToString(where) logger.Error("mysql", zap.String("sql", "select * from "+p.TableName()), zap.String("where", wherefields), zap.String("error", result.Error.Error())) } return list, result.Error }