From 73b6baf6af3d88cdcb0e2df7932a9bd96b0b85c5 Mon Sep 17 00:00:00 2001 From: zhangqian <zhangqian@123.com> Date: 星期一, 01 七月 2024 22:32:34 +0800 Subject: [PATCH] 月度统计出入库按类型汇总报表定时任务和手动跑任务接口 --- models/operation.go | 103 ++++++++++++++++++++++++++++++++++++++++++++------- 1 files changed, 88 insertions(+), 15 deletions(-) diff --git a/models/operation.go b/models/operation.go index 15e2fd9..826208d 100644 --- a/models/operation.go +++ b/models/operation.go @@ -4,6 +4,7 @@ "fmt" "github.com/shopspring/decimal" "gorm.io/gorm" + "time" "wms/constvar" "wms/pkg/mysqlx" ) @@ -25,7 +26,7 @@ OperationDate string `json:"operationDate" gorm:"type:varchar(31);comment:瀹夋帓鏃ユ湡"` ContacterID int `json:"contacterID" gorm:"type:int;comment:鑱旂郴浜篒D"` ContacterName string `json:"contacterName" gorm:"type:varchar(63);comment:鑱旂郴浜哄鍚�"` - CompanyID int `json:"companyID" gorm:"type:int;comment:鍏徃ID-瀹㈡埛"` + CompanyID string `json:"companyID" gorm:"type:varchar(255);comment:鍏徃ID-瀹㈡埛"` CompanyName string `json:"companyName" gorm:"type:varchar(127);comment:鍏徃鍚嶇О-瀹㈡埛"` Comment string `json:"comment" gorm:"type:text;comment:澶囨敞"` LogisticCompanyId string `json:"logisticCompanyId" gorm:"type:varchar(191);comment:鐗╂祦鍏徃id"` @@ -50,23 +51,39 @@ ToLocation Location `json:"toLocation" gorm:"foreignKey:ToLocationID;references:Id"` //鐩爣浣嶇疆 SalesDetailsNumber string `gorm:"type:varchar(191);comment:閿�鍞槑缁嗙紪鐮�" json:"salesDetailsNumber"` - Manager string `json:"manager" gorm:"type:varchar(255);comment:涓荤"` - Accountant string `json:"accountant" gorm:"type:varchar(255);comment:浼氳"` - Custodian string `json:"custodian" gorm:"type:varchar(255);comment:淇濈鍛�"` + ManagerId string `json:"managerId" gorm:"type:varchar(255);comment:涓荤id"` + Manager string `json:"manager" gorm:"type:varchar(255);comment:涓荤鍚嶇О"` + AccountantId string `json:"accountantId" gorm:"type:varchar(255);comment:浼氳id"` + Accountant string `json:"accountant" gorm:"type:varchar(255);comment:浼氳鍚嶇О"` + CustodianId string `json:"custodianId" gorm:"type:varchar(255);comment:淇濈鍛榠d"` + Custodian string `json:"custodian" gorm:"type:varchar(255);comment:淇濈鍛樺悕绉�"` + CreatedBy string `json:"createBy" gorm:"type:varchar(255);comment:鍒涘缓鑰匲serId"` + CheckedBy string `json:"checkedBy" gorm:"type:varchar(255);comment:楠岃瘉鑰匲serId"` + Remark string `json:"remark"` + + WarehouseId int `json:"warehouseId" gorm:"type:int;not null;comment:浠撳簱id"` + Warehouse Warehouse `json:"warehouse" gorm:"foreignKey:WarehouseId"` + IsInternalOutput bool `json:"isInternalOutput"` //鏄惁璋冩嫧浜х敓鐨勫嚭搴� + InventoryDealerType int `json:"inventoryDealerType" gorm:"type:varchar(255);comment:璋冩嫧鍑哄叆搴撳垎绫�(瀵瑰簲dict瀛楀吀琛ㄧ殑ID)"` + InventoryDealer MiniDict `json:"inventoryDealer" gorm:"foreignKey:InventoryDealerType;"` } OperationSearch struct { Operation - Order string - PageNum int - PageSize int - Keyword string - Orm *gorm.DB - Preload bool - Disuse bool - Ids []int - SourceNumbers []string - SalesDetailsNumbers []string + Order string + PageNum int + PageSize int + Keyword string + Orm *gorm.DB + Preload bool + Disuse bool + Ids []int + SourceNumbers []string + SalesDetailsNumbers []string + Fields string + BeginTime time.Time + EndTime time.Time + InventoryDealerTypeIds []int // } ) @@ -100,6 +117,11 @@ func (slf *OperationSearch) SetKeyword(keyword string) *OperationSearch { slf.Keyword = keyword + return slf +} + +func (slf *OperationSearch) SetFields(fields string) *OperationSearch { + slf.Fields = fields return slf } @@ -163,6 +185,22 @@ return slf } +func (slf *OperationSearch) SetTimeBetween(beginTime, endTime time.Time) *OperationSearch { + slf.BeginTime = beginTime + slf.EndTime = endTime + return slf +} + +func (slf *OperationSearch) SetInventoryDealerTypeIds(inventoryDealerTypeArr []int) *OperationSearch { + slf.InventoryDealerTypeIds = inventoryDealerTypeArr + return slf +} + +func (slf *OperationSearch) SetWarehouseId(warehouseId int) *OperationSearch { + slf.WarehouseId = warehouseId + return slf +} + func (slf *OperationSearch) build() *gorm.DB { var db = slf.Orm.Model(&Operation{}) @@ -194,7 +232,14 @@ } if slf.Preload { - db = db.Model(&Operation{}).Preload("Details").Preload("Details.Product").Preload("LogisticCompany").Preload("Location").Preload("ToLocation").Preload("Details.FromLocation").Preload("Details.ToLocation") + db = db.Model(&Operation{}).Preload("Details"). + Preload("Details.Product"). + Preload("LogisticCompany"). + Preload("Location"). + Preload("ToLocation"). + Preload("Details.FromLocation"). + Preload("Details.ToLocation"). + Preload("InventoryDealer").Preload("Warehouse") } if slf.Disuse { @@ -223,6 +268,22 @@ if slf.OperationSource != 0 { db = db.Where("operation_source = ?", slf.OperationSource) + } + + if slf.Fields != "" { + db = db.Select(slf.Fields) + } + + if !slf.BeginTime.IsZero() && !slf.EndTime.IsZero() { + db = db.Where("created_at between ? and ?", slf.BeginTime, slf.EndTime) + } + + if len(slf.InventoryDealerTypeIds) > 0 { + db = db.Where("inventory_dealer_type in (?)", slf.InventoryDealerTypeIds) + } + + if slf.WarehouseId != 0 { + db = db.Where("warehouse_id = ?", slf.WarehouseId) } return db @@ -348,6 +409,18 @@ return records, nil } +func (slf *OperationSearch) FindIds() ([]int, error) { + var ( + records = make([]int, 0) + db = slf.build() + ) + if err := db.Find(&records).Error; err != nil { + return records, fmt.Errorf("find records err: %v", err) + } + + return records, nil +} + // FindByQuery 鎸囧畾鏉′欢鏌ヨ. func (slf *OperationSearch) FindByQuery(query string, args []interface{}) ([]*Operation, int64, error) { var ( -- Gitblit v1.8.0