From 076f911a3b8d09364d1d8c98a92b48e601ae6a21 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期三, 31 七月 2024 11:30:27 +0800
Subject: [PATCH] 位置对应产品列表增加产品类别筛选

---
 controllers/product_controller.go |   35 ++++++++++++++++++++++++++---------
 1 files changed, 26 insertions(+), 9 deletions(-)

diff --git a/controllers/product_controller.go b/controllers/product_controller.go
index 9b81e63..fa48b5f 100644
--- a/controllers/product_controller.go
+++ b/controllers/product_controller.go
@@ -109,6 +109,7 @@
 // @Summary   鑾峰彇浜у搧鍒楄〃
 // @Produce   application/json
 // @Param     object  body  request.GetProductList true  "鏌ヨ鍙傛暟"
+// @Param     Authorization	header string true "token"
 // @Success   200 {object} util.ResponseList{data=[]models.Material}	"鎴愬姛"
 // @Router    /api-wms/v1/product/getProductList [post]
 func (slf ProductController) GetProductList(c *gin.Context) {
@@ -121,7 +122,12 @@
 	if params.PageInfo.Check() {
 		search.SetPage(params.Page, params.PageSize)
 	}
-	products, total, err := search.SetPreload(true).SetKeyword(params.KeyWord).SetCategoryId(params.CategoryId).SetOrder("created_at desc").Find()
+	products, total, err := search.SetPreload(true).
+		SetKeyword(params.KeyWord).
+		SetCategoryId(params.CategoryId).
+		SetCategoryIds(params.CategoryIds).
+		SetOrder("created_at desc").
+		Find()
 	if err != nil {
 		util.ResponseFormat(c, code.RequestParamError, "鏌ユ壘澶辫触")
 		return
@@ -136,15 +142,14 @@
 		util.ResponseFormat(c, code.RequestParamError, "浜у搧绫诲瀷鏌ユ壘澶辫触")
 		return
 	}
+	categoryMap := models.CategoryMap(categories)
 	for _, product := range products {
-		for _, category := range categories {
-			if product.CategoryId == int(category.ID) {
-				product.CategoryName = category.Name
-			}
+		if product.CategoryId != 0 && categoryMap[product.CategoryId] != nil {
+			product.CategoryName = categoryMap[product.CategoryId].Name
 		}
 		var totalAmount decimal.Decimal
-		if err := models.NewOperationSearch().Orm.
-			Table("wms_operation_details").
+		db := models.NewOperationSearch().Orm
+		if err := db.Table("wms_operation_details").
 			InnerJoins("INNER JOIN wms_operation on wms_operation_details.operation_id=wms_operation.id").
 			Select("IFNULL(SUM(wms_operation_details.amount), 0) as total_count").
 			Where("wms_operation_details.product_id=? and wms_operation.`status`=? and wms_operation.base_operation_type in (?)", product.ID, constvar.OperationStatus_Ready, []constvar.BaseOperationType{constvar.BaseOperationTypeIncoming, constvar.BaseOperationTypeOutgoing, constvar.BaseOperationTypeDisuse}).
@@ -157,7 +162,8 @@
 		product.PredictionAmount = product.Amount.Add(totalAmount)
 
 		var statisticsList []*request.ProductStatistics
-		if err := models.NewOperationSearch().Orm.Table("wms_operation").
+		db2 := models.NewOperationSearch().Orm
+		if err := db2.Table("wms_operation").
 			InnerJoins("INNER JOIN wms_operation_details on wms_operation_details.operation_id=wms_operation.id").
 			Select("SUM(wms_operation_details.amount) as total_amount,wms_operation.base_operation_type").
 			Where("wms_operation_details.product_id=? and wms_operation.`status`=? and wms_operation.base_operation_type in (?)", product.ID, constvar.OperationStatus_Finish, []constvar.BaseOperationType{constvar.BaseOperationTypeIncoming, constvar.BaseOperationTypeOutgoing, constvar.BaseOperationTypeDisuse}).
@@ -797,6 +803,7 @@
 				return errors.New(fmt.Sprintf("浜у搧锛�%v,搴撳瓨锛�%v,鎶ュ簾锛�%v,鏁伴噺涓嶅锛屾棤娉曞畬鎴愭姤搴熸搷浣�", v.Product.Name, v.Product.Amount.String(), v.Amount.String()))
 			}
 			listDetails[k].Product.Amount = listDetails[k].Product.Amount.Sub(v.Amount)
+			listDetails[k].Product.StockMoreUnitList = service.SubMoreUnit(listDetails[k].Product.StockMoreUnitList, v.MoreUnitList)
 			if err := tx.Save(&listDetails[k].Product).Error; err != nil {
 				return err
 			}
@@ -1022,6 +1029,16 @@
 		v.Sort = i + 1
 	}
 
+	//鏍¢獙閲嶅
+	m := make(map[string]struct{})
+	for _, v := range params {
+		if _, ok := m[v.Name]; ok {
+			util.ResponseFormat(c, code.RequestParamError, "鍗曚綅閲嶅锛�"+v.Name)
+			return
+		}
+		m[v.Name] = struct{}{}
+	}
+
 	err := models.WithTransaction(func(tx *gorm.DB) error {
 		err := models.NewUnitDictSearch().SetOrm(tx).Delete()
 		if err != nil {
@@ -1035,7 +1052,7 @@
 		return nil
 	})
 	if err != nil {
-		util.ResponseFormat(c, code.RequestParamError, "鍒犻櫎澶辫触")
+		util.ResponseFormat(c, code.RequestParamError, "淇濆瓨澶辫触")
 		return
 	}
 

--
Gitblit v1.8.0