package models
|
|
import (
|
"fmt"
|
"github.com/shopspring/decimal"
|
"gorm.io/gorm"
|
"wms/constvar"
|
"wms/pkg/mysqlx"
|
)
|
|
type (
|
LocationProductAmount struct {
|
WmsModel
|
Id int `json:"id" gorm:"column:id;primary_key;AUTO_INCREMENT"`
|
//LocationProductId int `json:"locationProductId" gorm:"type:int;not null;comment:上架规则id"` //上架规则id
|
//LocationProduct LocationProduct `json:"locationProduct" gorm:"foreignKey:LocationProductId;references:Id"`
|
LocationId int `json:"locationId" gorm:"type:int;not null;comment:位置id"` //位置id
|
Location Location `json:"location" gorm:"foreignKey:LocationId;references:id"`
|
ProductCategoryID int `json:"productCategoryId" gorm:"type:int;not null;comment:产品种类id"` //产品种类id
|
ProductCategory ProductCategory `json:"productCategory" gorm:"foreignKey:ProductCategoryID;references:Id"`
|
ProductId string `json:"productId" gorm:"type:varchar(191);not null;comment:产品id"` //产品id
|
Product Material `json:"product" gorm:"foreignKey:ProductId;references:ID"`
|
Amount decimal.Decimal `json:"amount" gorm:"type:decimal(20,2);not null;comment:库存数量"` //库存数量
|
CreateDate string `json:"createDate" gorm:"type:varchar(63);comment:日期"` //日期
|
}
|
|
LocationProductAmountSearch struct {
|
LocationProductAmount
|
Order string
|
PageNum int
|
PageSize int
|
Keyword string
|
Orm *gorm.DB
|
Preload bool
|
//LocationProductIds []int
|
LocationIds []int
|
ProductIds []string
|
Ids []int
|
Query string
|
}
|
|
LocationProductAmountWithOperation struct {
|
//LocationProductAmount LocationProductAmount `json:"locationProductAmount"`
|
LocationProductAmountId int `json:"locationProductAmountId" gorm:"location_product_amount_id"`
|
LocationId int `json:"locationId" gorm:"column:location_id"`
|
LocationName string `json:"locationName" gorm:"column:location_name"`
|
ProductId string `json:"productId" gorm:"column:product_id"`
|
ProductName string `json:"productName" gorm:"column:product_name"`
|
Amount decimal.Decimal `json:"amount" gorm:"column:amount"`
|
Unit string `json:"unit" gorm:"column:unit"`
|
CreateDate string `json:"createDate" gorm:"column:create_date"`
|
AdjustAmount decimal.Decimal `json:"adjustAmount" gorm:"column:adjust_amount"` //差值
|
DifferenceAmount decimal.Decimal `json:"differenceAmount" gorm:"-"` //计数数量
|
OperationId int `json:"operationId" gorm:"column:operation_id"`
|
Status constvar.OperationStatus `json:"status" gorm:"status"`
|
BaseOperationType constvar.BaseOperationType `json:"baseOperationType" gorm:"base_operation_type"`
|
Weight decimal.Decimal `gorm:"type:decimal(20,3);comment:重量" json:"weight"` //重量
|
}
|
)
|
|
func (slf *LocationProductAmount) TableName() string {
|
return "wms_location_product_amount"
|
}
|
|
func NewLocationProductAmountSearch() *LocationProductAmountSearch {
|
return &LocationProductAmountSearch{Orm: mysqlx.GetDB()}
|
}
|
|
func (slf *LocationProductAmountSearch) SetOrm(tx *gorm.DB) *LocationProductAmountSearch {
|
slf.Orm = tx
|
return slf
|
}
|
|
func (slf *LocationProductAmountSearch) SetPage(page, size int) *LocationProductAmountSearch {
|
slf.PageNum, slf.PageSize = page, size
|
return slf
|
}
|
|
func (slf *LocationProductAmountSearch) SetOrder(order string) *LocationProductAmountSearch {
|
slf.Order = order
|
return slf
|
}
|
|
func (slf *LocationProductAmountSearch) SetID(id int) *LocationProductAmountSearch {
|
slf.Id = id
|
return slf
|
}
|
|
func (slf *LocationProductAmountSearch) SetIds(ids []int) *LocationProductAmountSearch {
|
slf.Ids = ids
|
return slf
|
}
|
|
func (slf *LocationProductAmountSearch) SetKeyword(keyword string) *LocationProductAmountSearch {
|
slf.Keyword = keyword
|
return slf
|
}
|
|
func (slf *LocationProductAmountSearch) SetPreload(preload bool) *LocationProductAmountSearch {
|
slf.Preload = preload
|
return slf
|
}
|
|
func (slf *LocationProductAmountSearch) SetProductId(productId string) *LocationProductAmountSearch {
|
slf.ProductId = productId
|
return slf
|
}
|
|
func (slf *LocationProductAmountSearch) SetLocationId(locationId int) *LocationProductAmountSearch {
|
slf.LocationId = locationId
|
return slf
|
}
|
|
func (slf *LocationProductAmountSearch) SetProductIds(ids []string) *LocationProductAmountSearch {
|
slf.ProductIds = ids
|
return slf
|
}
|
|
func (slf *LocationProductAmountSearch) SetLocationIds(ids []int) *LocationProductAmountSearch {
|
slf.LocationIds = ids
|
return slf
|
}
|
|
func (slf *LocationProductAmountSearch) SetQuery(query string) *LocationProductAmountSearch {
|
slf.Query = query
|
return slf
|
}
|
|
func (slf *LocationProductAmountSearch) build() *gorm.DB {
|
var db = slf.Orm.Model(&LocationProductAmount{})
|
|
if slf.Id != 0 {
|
db = db.Where("id = ?", slf.Id)
|
}
|
if slf.Order != "" {
|
db = db.Order(slf.Order)
|
}
|
|
if slf.Keyword != "" {
|
db = db.Joins("left join wms_location on wms_location_product_amount.location_id = wms_location.id").
|
Joins("left join material on wms_location_product_amount.product_id = material.id").
|
Joins("left join wms_product_category on wms_location_product_amount.product_category_id = wms_product_category.id").
|
Where("wms_location.name like ?", "%"+slf.Keyword+"%").Or("material.name like ?", "%"+slf.Keyword+"%").
|
Or("wms_product_category.name like ?", "%"+slf.Keyword+"%")
|
}
|
|
if slf.Preload {
|
db = db.Model(&LocationProductAmount{}).Preload("Location").Preload("Product").Preload("ProductCategory")
|
}
|
//if slf.LocationProductId != 0 {
|
// db = db.Where("location_product_id=?", slf.LocationProductId)
|
//}
|
if len(slf.ProductIds) > 0 {
|
db = db.Where("product_id in (?)", slf.ProductIds)
|
}
|
|
if len(slf.LocationIds) > 0 {
|
db = db.Where("location_id in (?)", slf.LocationIds)
|
}
|
|
if slf.LocationId != 0 {
|
db = db.Where("location_id = ?", slf.LocationId)
|
}
|
|
if slf.ProductId != "" {
|
db = db.Where("product_id=?", slf.ProductId)
|
}
|
|
if len(slf.Ids) > 0 {
|
db = db.Where("id in (?)", slf.Ids)
|
}
|
|
if slf.Query != "" {
|
db = db.Where(slf.Query)
|
}
|
|
return db
|
}
|
|
// Create 单条插入
|
func (slf *LocationProductAmountSearch) Create(record *LocationProductAmount) error {
|
var db = slf.build()
|
|
if err := db.Create(record).Error; err != nil {
|
return err
|
}
|
|
return nil
|
}
|
|
// CreateBatch 批量插入
|
func (slf *LocationProductAmountSearch) CreateBatch(records []*LocationProductAmount) error {
|
var db = slf.build()
|
|
if err := db.Create(&records).Error; err != nil {
|
return fmt.Errorf("create batch err: %v, records: %+v", err, records)
|
}
|
|
return nil
|
}
|
|
func (slf *LocationProductAmountSearch) Update(record *LocationProductAmount) error {
|
var db = slf.build()
|
|
if err := db.Omit("CreatedAt").Updates(record).Error; err != nil {
|
return fmt.Errorf("save err: %v, record: %+v", err, record)
|
}
|
|
return nil
|
}
|
|
func (slf *LocationProductAmountSearch) Delete() error {
|
var db = slf.build()
|
return db.Unscoped().Delete(&LocationProductAmount{}).Error
|
}
|
|
func (slf *LocationProductAmountSearch) First() (*LocationProductAmount, error) {
|
var (
|
record = new(LocationProductAmount)
|
db = slf.build()
|
)
|
|
if err := db.First(record).Error; err != nil {
|
return record, err
|
}
|
|
return record, nil
|
}
|
|
func (slf *LocationProductAmountSearch) FindByPage() ([]*LocationProductAmount, int64, error) {
|
var (
|
records = make([]*LocationProductAmount, 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 *LocationProductAmountSearch) Find() ([]*LocationProductAmount, error) {
|
var (
|
records = make([]*LocationProductAmount, 0)
|
db = slf.build()
|
)
|
|
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, fmt.Errorf("find records err: %v", err)
|
}
|
|
return records, nil
|
}
|
|
func (slf *LocationProductAmountSearch) FirstRes() (*LocationProductAmount, *gorm.DB) {
|
var (
|
record = new(LocationProductAmount)
|
db = slf.build()
|
)
|
|
return record, db.First(&record)
|
}
|
|
func (slf *LocationProductAmountSearch) Count() (int64, error) {
|
var (
|
total int64
|
db = slf.build()
|
)
|
err := db.Count(&total).Error
|
return total, err
|
}
|
|
func (slf *LocationProductAmountSearch) UpdateByMap(upMap map[string]interface{}) error {
|
var (
|
db = slf.build()
|
)
|
|
if err := db.Updates(upMap).Error; err != nil {
|
return fmt.Errorf("update by map err: %v, upMap: %+v", err, upMap)
|
}
|
|
return nil
|
}
|
|
func (slf *LocationProductAmountSearch) GroupCount(field string) ([]*GroupCount, error) {
|
var (
|
db = slf.build()
|
result = make([]*GroupCount, 0)
|
)
|
if err := db.Select("count(*) as total, " + field + " as class").Group(field).Scan(&result).Error; err != nil {
|
return nil, fmt.Errorf("select group err: %v", err)
|
}
|
return result, nil
|
}
|
|
func (slf *LocationProductAmountSearch) GroupSum(groupField string, sumField string) ([]*GroupSum, error) {
|
var (
|
db = slf.build()
|
result = make([]*GroupSum, 0)
|
)
|
if err := db.Select("sum(" + sumField + ") as sum, " + groupField + " as class").Group(groupField).Scan(&result).Error; err != nil {
|
return nil, fmt.Errorf("select group err: %v", err)
|
}
|
return result, nil
|
}
|
