package models import ( "fmt" "gorm.io/gorm" "outsourcing/pkg/mysqlx" ) type ( OutsourcingOrderDelivery struct { BaseModelInt OutsourcingOrderID uint `json:"outsourcingOrderID" gorm:"comment:委外订单ID"` Number string `json:"number" gorm:"type:varchar(255);comment:发货单号"` //发货单号 Carrier string `json:"carrier" gorm:"type:varchar(255);comment:承运商"` //承运商 WaybillNumber string `json:"waybillNumber" gorm:"type:varchar(255);comment:运单号"` //运单号 } OutsourcingOrderDeliverySearch struct { OutsourcingOrderDelivery PageNum int PageSize int Orm *gorm.DB } ) func (slf OutsourcingOrderDelivery) TableName() string { return "outsourcing_order_delivery" } func NewOutsourcingOrderDeliverySearch() *OutsourcingOrderDeliverySearch { return &OutsourcingOrderDeliverySearch{Orm: mysqlx.GetDB()} } func (slf *OutsourcingOrderDeliverySearch) SetOrm(tx *gorm.DB) *OutsourcingOrderDeliverySearch { slf.Orm = tx return slf } func (slf *OutsourcingOrderDeliverySearch) SetPage(page, size int) *OutsourcingOrderDeliverySearch { slf.PageNum, slf.PageSize = page, size return slf } func (slf *OutsourcingOrderDeliverySearch) SetOutsourcingOrderID(id uint) *OutsourcingOrderDeliverySearch { slf.OutsourcingOrderID = id return slf } func (slf *OutsourcingOrderDeliverySearch) build() *gorm.DB { var db = slf.Orm.Table(slf.TableName()) if slf.OutsourcingOrderID != 0 { db = db.Where("outsourcing_order_id = ?", slf.OutsourcingOrderID) } return db } // Create 单条插入 func (slf *OutsourcingOrderDeliverySearch) Create(record *OutsourcingOrderDelivery) error { var db = slf.build() if err := db.Create(record).Error; err != nil { return fmt.Errorf("create err: %v, record: %+v", err, record) } return nil } func (slf *OutsourcingOrderDeliverySearch) Find() ([]*OutsourcingOrderDelivery, int64, error) { var ( records = make([]*OutsourcingOrderDelivery, 0) total int64 db = slf.build() ) if err := db.Count(&total).Error; err != nil { return records, total, fmt.Errorf("find count err: %v", err) } if slf.PageNum*slf.PageSize > 0 { db = db.Offset((slf.PageNum - 1) * slf.PageSize).Limit(slf.PageSize) } if err := db.Find(&records).Error; err != nil { return records, total, fmt.Errorf("find records err: %v", err) } return records, total, nil } func (slf *OutsourcingOrderDeliverySearch) FindNotTotal() ([]*OutsourcingOrderDelivery, error) { var ( records = make([]*OutsourcingOrderDelivery, 0) db = slf.build() ) if err := db.Find(&records).Error; err != nil { return records, fmt.Errorf("find records err: %v", err) } return records, nil }