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