From 2bfc37cbc679ceb5cef3b714e93ce4ebf55f9512 Mon Sep 17 00:00:00 2001 From: jiangshuai <291802688@qq.com> Date: 星期三, 08 十一月 2023 17:24:58 +0800 Subject: [PATCH] 修改缩略图尺寸 config文件覆盖修复 --- controllers/operation.go | 488 +++++++++++++++++++++++++++++++++++++++++++++++++----- 1 files changed, 443 insertions(+), 45 deletions(-) diff --git a/controllers/operation.go b/controllers/operation.go index 06b3c19..5bd16ef 100644 --- a/controllers/operation.go +++ b/controllers/operation.go @@ -1,15 +1,21 @@ package controllers import ( + "encoding/json" "errors" + "fmt" "github.com/gin-gonic/gin" - "github.com/spf13/cast" + "github.com/shopspring/decimal" "gorm.io/gorm" + "os" + "sort" "strconv" + "time" "wms/constvar" "wms/extend/code" "wms/extend/util" "wms/models" + "wms/opa" "wms/pkg/logx" "wms/pkg/structx" "wms/request" @@ -45,13 +51,43 @@ return } + if CheckDetailsRepeat(params.Details) { + util.ResponseFormat(c, code.RequestParamError, "鏄庣粏涓笉鑳藉瓨鍦ㄩ噸澶嶇殑浜у搧") + return + } + + operationType, err := models.NewOperationTypeSearch().SetID(uint(params.OperationTypeId)).First() + if err != nil { + util.ResponseFormat(c, code.RequestParamError, err.Error()) + return + } + params.Status = constvar.OperationStatus_Ready + params.Number = strconv.FormatInt(time.Now().Unix(), 10) + params.BaseOperationType = operationType.BaseOperationType if err := models.NewOperationSearch().Create(¶ms); err != nil { logx.Errorf("Operation create err: %v", err) util.ResponseFormat(c, code.SaveFail, "娣诲姞澶辫触锛�"+err.Error()) return } util.ResponseFormat(c, code.Success, "娣诲姞鎴愬姛") +} + +func CheckDetailsRepeat(details []*models.OperationDetails) bool { + var detailIDs []string + var tempID string + for _, v := range details { + detailIDs = append(detailIDs, v.ProductId) + } + sort.Strings(detailIDs) + for _, v := range detailIDs { + if v != tempID { + tempID = v + } else { + return true + } + } + return false } func (slf OperationController) FormatLocation(params *models.Operation) error { @@ -63,9 +99,9 @@ if location, err := models.NewLocationSearch().SetType(int(constvar.LocationTypeVendor)).First(); err != nil { return err } else { - params.FromLocationId = location.Id + params.FromLocationID = location.Id } - if params.ToLocationId == 0 { + if params.ToLocationID == 0 { return errors.New("璇烽�夋嫨鐩爣浣嶇疆") } } @@ -73,17 +109,17 @@ if location, err := models.NewLocationSearch().SetType(int(constvar.LocationTypeCustomer)).First(); err != nil { return err } else { - params.ToLocationId = location.Id + params.ToLocationID = location.Id } - if params.FromLocationId == 0 { + if params.FromLocationID == 0 { return errors.New("璇烽�夋嫨婧愪綅缃�") } } if operationType.BaseOperationType == constvar.BaseOperationTypeInternal { - if params.ToLocationId == 0 { + if params.ToLocationID == 0 { return errors.New("璇烽�夋嫨鐩爣浣嶇疆") } - if params.FromLocationId == 0 { + if params.FromLocationID == 0 { return errors.New("璇烽�夋嫨婧愪綅缃�") } } @@ -95,8 +131,8 @@ return errors.New("璇峰~鍏ユ簮鍗曞彿") } - if params.OperationTypeId == 0 { - return errors.New("operationTypeId涓�0") + if params.OperationTypeId == 0 && int(params.BaseOperationType) == 0 { + return errors.New("鏈瘑鍒璁板綍绫诲瀷") } if params.OperationDate == "" { @@ -110,12 +146,12 @@ //妫�鏌ユ槑缁嗛儴鍒� for _, v := range params.Details { if v.ProductId == "" { - return errors.New("productID涓�0") + return errors.New("productID涓虹┖") } - if v.ProductName == "" { - return errors.New("浜у搧鍚嶇О寮傚父") - } - if v.Quantity.IsNegative() { + //if v.ProductName == "" { + // return errors.New("浜у搧鍚嶇О寮傚父") + //} + if v.Amount.IsNegative() { return errors.New("浜у搧鏁伴噺鍑洪敊") } } @@ -127,13 +163,12 @@ // @Tags 鍏ュ簱/鍑哄簱 // @Summary 鍏ュ簱/鍑哄簱鍒楄〃 // @Produce application/json -// @Accept json -// @Param object query request.OperationList true "鍙傛暟" -// @Success 200 {object} util.Response "鎴愬姛" -// @Router /api-wms/v1/operation/operation [get] +// @Param object body request.OperationList true "鏌ヨ鍙傛暟" +// @Success 200 {object} util.Response "鎴愬姛" +// @Router /api-wms/v1/operation/list [post] func (slf OperationController) List(c *gin.Context) { var params request.OperationList - if err := c.ShouldBindQuery(¶ms); err != nil { + if err := c.BindJSON(¶ms); err != nil { util.ResponseFormat(c, code.RequestParamError, "鍙傛暟瑙f瀽澶辫触锛屾暟鎹被鍨嬮敊璇�:"+err.Error()) return } @@ -143,14 +178,19 @@ } search := models.NewOperationSearch() search.SetPage(params.Page, params.PageSize) + if params.Number != "" { + search.SetKeyword(params.Number) + } + if int(params.Status) != 0 { + search.SetStatus(params.Status) + } list, total, err := search.SetOperationTypeId(params.OperationTypeId).SetPreload(true).SetOrder("created_at desc").Find() if err != nil { util.ResponseFormat(c, code.RequestError, "鏌ユ壘澶辫触:"+err.Error()) return } - util.ResponseFormatList(c, code.Success, list, int(total)) - + util.ResponseFormatListWithPage(c, code.Success, list, int(total), params.Page, params.PageSize) } func (slf OperationController) CheckListParams(params *request.OperationList) error { @@ -168,15 +208,9 @@ // @Summary 淇敼鍏ュ簱/鍑哄簱淇℃伅 // @Produce application/json // @Param object body request.UpdateOperation true "鍏ュ簱淇℃伅" -// @Param id path int true "鍏ュ簱淇℃伅id" // @Success 200 {object} util.Response "鎴愬姛" -// @Router /api-wms/v1/operation/operation/{id} [put] +// @Router /api-wms/v1/operation/update [post] func (slf OperationController) Update(c *gin.Context) { - id := cast.ToUint(c.Param("id")) - if id == 0 { - util.ResponseFormat(c, code.RequestParamError, "绌虹殑璁板綍id") - return - } var reqParams request.UpdateOperation var params models.Operation if err := c.BindJSON(&reqParams); err != nil { @@ -195,12 +229,20 @@ util.ResponseFormat(c, code.RequestParamError, err.Error()) return } + if CheckDetailsRepeat(params.Details) { + util.ResponseFormat(c, code.RequestParamError, "鏄庣粏涓笉鑳藉瓨鍦ㄩ噸澶嶇殑浜у搧") + return + } if err := slf.FormatLocation(¶ms); err != nil { util.ResponseFormat(c, code.RequestParamError, err.Error()) return } if err := models.WithTransaction(func(tx *gorm.DB) error { if err := models.NewOperationDetailsSearch().SetOrm(tx).SetOperationId(params.Id).Delete(); err != nil { + return err + } + operationSearch := models.NewOperationSearch().SetOrm(tx) + if err := operationSearch.Orm.Model(¶ms).Association("Details").Replace(params.Details); err != nil { return err } if err := models.NewOperationSearch().SetOrm(tx).SetID(params.Id).Save(¶ms); err != nil { @@ -275,7 +317,7 @@ util.ResponseFormat(c, code.RequestParamError, "id涓�0") return } - operation, err := models.NewOperationSearch().SetID(id).First() + operation, err := models.NewOperationSearch().SetPreload(true).SetID(id).First() if err != nil { util.ResponseFormat(c, code.RequestParamError, "鏈壘鍒扮浉鍏冲嚭鍏ュ簱淇℃伅:"+err.Error()) return @@ -284,28 +326,353 @@ util.ResponseFormat(c, code.RequestError, "璇ュ嚭鍏ュ簱淇℃伅鏃犳硶瀹屾垚") return } - //operationType, err := models.NewOperationTypeSearch().SetID(uint(operation.OperationTypeId)).First() - //if err != nil { - // util.ResponseFormat(c, code.RequestError, err.Error()) - // return - //} - //if operationType.BaseOperationType == constvar.BaseOperationTypeIncoming { - // if location, err := models.NewLocationSearch().SetType(int(constvar.LocationTypeVendor)).First(); err != nil { - // return err - // } else { - // params.FromLocationId = location.Id - // } - // if params.ToLocationId == 0 { - // return errors.New("璇烽�夋嫨鐩爣浣嶇疆") - // } - //} if err := models.WithTransaction(func(tx *gorm.DB) error { if err := models.NewOperationSearch().SetOrm(tx).SetID(id).Update(&models.Operation{Status: constvar.OperationStatus_Finish}); err != nil { return err } - if err := models.NewMaterialSearch().Orm.Exec("update material INNER JOIN wms_operation_details on wms_operation_details.product_id=material.id INNER JOIN wms_operation on wms_operation.id=wms_operation_details.operation_id set material.amount=material.amount + wms_operation_details.quantity where wms_operation.id=?", id).Error; err != nil { + + var listProdtId []string + var listProdt []*models.Material + mapProdt := make(map[string]decimal.Decimal) + listDetails, err := models.NewOperationDetailsSearch().SetOperationId(operation.Id).FindAll() + if err != nil { return err + } + for _, v := range listDetails { + listProdtId = append(listProdtId, v.ProductId) + mapProdt[v.ProductId] = v.Amount + } + + if err := models.NewMaterialSearch().Orm.Where("id IN ?", listProdtId).Find(&listProdt).Error; err != nil { + return err + } + + if operation.BaseOperationType == constvar.BaseOperationTypeIncoming { + var operationInputs []*models.Operation + for k, v := range listProdt { + value, ok := mapProdt[v.ID] + if !ok { + return errors.New("浜у搧绉嶇被寮傚父") + } + + listProdt[k].Amount = listProdt[k].Amount.Add(value) + if err := tx.Save(listProdt[k]).Error; err != nil { + return err + } + + locationRule, err := models.NewLocationProductSearch().SetProductId(v.ID).SetAreaId(operation.ToLocationID).First() + if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { + return err + } + + if err == nil { + operationTransfer := &models.Operation{ + Number: operation.Number, + SourceNumber: operation.SourceNumber, + OperationTypeId: 0, + OperationTypeName: operation.OperationTypeName, + Status: constvar.OperationStatus_Finish, + FromLocationID: locationRule.AreaId, + ToLocationID: locationRule.LocationId, + OperationDate: operation.OperationDate, + ContacterID: operation.ContacterID, + ContacterName: operation.ContacterName, + CompanyID: operation.CompanyID, + CompanyName: operation.CompanyName, + Comment: operation.Comment, + BaseOperationType: constvar.BaseOperationTypeInternal, + Details: []*models.OperationDetails{ + { + ProductId: v.ID, + Amount: value, + }, + }, + } + operationInputs = append(operationInputs, operationTransfer) + + //if err := tx.Create(&operationTransfer).Error; err != nil { + // return err + //} + + //TODO:鍑哄叆搴撶殑finish鍜屾姤搴熺殑finish閮借澧炲姞瀵筶ocation_product_amount琛ㄦ暟閲忕殑鏇存柊,鍥犱负姝よ〃鏈塒roductCategory瀛楁锛屾墍浠peration_details琛ㄤ腑瑕佸鍔燩roductCategoryId瀛楁 + locAmount, err := models.NewLocationProductAmountSearch(). + SetProductId(v.ID). + SetLocationId(locationRule.LocationId). + First() + if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { + return err + } + locAmount.LocationId = locationRule.LocationId + locAmount.ProductId = v.ID + locAmount.CreateDate = time.Now().Format("2006-01-02 15:04:05") + locAmount.Amount = locAmount.Amount.Add(value) + if res := models.NewLocationProductAmountSearch().Orm.Where("id=?", locAmount.ID).Save(locAmount); res.Error != nil { + return res.Error + } + } else { + locationRule, err = models.NewLocationProductSearch().SetProductCategoryId(v.CategoryId).SetAreaId(operation.ToLocationID).First() + if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { + return err + } + if err == nil { + operationTransfer := &models.Operation{ + Number: operation.Number, + SourceNumber: operation.SourceNumber, + OperationTypeId: 0, + OperationTypeName: operation.OperationTypeName, + Status: constvar.OperationStatus_Finish, + FromLocationID: locationRule.AreaId, + ToLocationID: locationRule.LocationId, + OperationDate: operation.OperationDate, + ContacterID: operation.ContacterID, + ContacterName: operation.ContacterName, + CompanyID: operation.CompanyID, + CompanyName: operation.CompanyName, + Comment: operation.Comment, + BaseOperationType: constvar.BaseOperationTypeInternal, + Details: []*models.OperationDetails{ + { + ProductId: v.ID, + Amount: value, + }, + }, + } + operationInputs = append(operationInputs, operationTransfer) + + //if err := tx.Create(&operationTransfer).Error; err != nil { + // return err + //} + + //TODO:鍑哄叆搴撶殑finish鍜屾姤搴熺殑finish閮借澧炲姞瀵筶ocation_product_amount琛ㄦ暟閲忕殑鏇存柊,鍥犱负姝よ〃鏈塒roductCategory瀛楁锛屾墍浠peration_details琛ㄤ腑瑕佸鍔燩roductCategoryId瀛楁 + locAmount, err := models.NewLocationProductAmountSearch(). + SetProductId(v.ID). + SetLocationId(locationRule.LocationId). + First() + if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { + return err + } + locAmount.LocationId = locationRule.LocationId + locAmount.ProductId = v.ID + locAmount.CreateDate = time.Now().Format("2006-01-02 15:04:05") + locAmount.Amount = locAmount.Amount.Add(value) + if res := models.NewLocationProductAmountSearch().Orm.Where("id=?", locAmount.ID).Save(locAmount); res.Error != nil { + return res.Error + } + } else { + //TODO:鍑哄叆搴撶殑finish鍜屾姤搴熺殑finish閮借澧炲姞瀵筶ocation_product_amount琛ㄦ暟閲忕殑鏇存柊,鍥犱负姝よ〃鏈塒roductCategory瀛楁锛屾墍浠peration_details琛ㄤ腑瑕佸鍔燩roductCategoryId瀛楁 + locAmount, err := models.NewLocationProductAmountSearch(). + SetProductId(v.ID). + SetLocationId(operation.ToLocationID). + First() + if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { + return err + } + locAmount.LocationId = operation.ToLocationID + locAmount.ProductId = v.ID + locAmount.CreateDate = time.Now().Format("2006-01-02 15:04:05") + locAmount.Amount = locAmount.Amount.Add(value) + if res := models.NewLocationProductAmountSearch().Orm.Where("id=?", locAmount.ID).Save(locAmount); res.Error != nil { + return res.Error + } + } + } + } + if len(operationInputs) > 0 { + if err := tx.Create(&operationInputs).Error; err != nil { + return err + } + } + + } + + if operation.BaseOperationType == constvar.BaseOperationTypeOutgoing { + for k, v := range listProdt { + value, ok := mapProdt[v.ID] + if !ok { + return errors.New("浜у搧绉嶇被寮傚父") + } + //todo 婕旂ず娴嬭瘯鏁版嵁 + data, err := os.ReadFile("conf/input.json") + if err != nil { + return errors.New("鏂囦欢璇诲彇澶辫触") + } + m := make(map[string]interface{}) + err = json.Unmarshal(data, &m) + if err != nil { + return errors.New("鏍煎紡杞崲澶辫触") + } + if opa.OpaCheck(c, m, "operation") { + if v.Amount.LessThan(value) { + return errors.New(fmt.Sprintf("浜у搧锛�%v,搴撳瓨锛�%v,鍑哄簱锛�%v,鏁伴噺涓嶅锛屾棤娉曞畬鎴愬嚭搴撴搷浣�", v.Name, v.Amount.String(), value.String())) + } + } + listProdt[k].Amount = listProdt[k].Amount.Sub(value) + if err := tx.Save(listProdt[k]).Error; err != nil { + return err + } + locAmount, res := models.NewLocationProductAmountSearch(). + SetProductId(v.ID). + SetLocationId(operation.ToLocationID). + FirstRes() + if res.Error != nil { + return err + } + if locAmount.Amount.LessThan(value) { + return errors.New(fmt.Sprintf("浜у搧锛�%v,搴撳瓨锛�%v,鍑哄簱锛�%v,鏁伴噺涓嶅锛屾棤娉曞畬鎴愬嚭搴撴搷浣�", v.Name, v.Amount.String(), value.String())) + } + locAmount.Amount = locAmount.Amount.Sub(value) + if err := models.NewLocationProductAmountSearch().SetID(locAmount.Id).Update(locAmount); err != nil { + return err + } + } + } + + if operation.BaseOperationType == constvar.BaseOperationTypeInternal { + var operationInputs []*models.Operation + for _, v := range listProdt { + value, ok := mapProdt[v.ID] + if !ok { + return errors.New("浜у搧绉嶇被寮傚父") + } + //listProdt[k].Amount = listProdt[k].Amount.Add(value) + //if err := tx.Save(listProdt[k]).Error; err != nil { + // return err + //} + fromLocAmount, res := models.NewLocationProductAmountSearch(). + SetProductId(v.ID). + SetLocationId(operation.FromLocationID). + FirstRes() + if res.Error != nil { + return err + } + if fromLocAmount.Amount.LessThan(value) { + return errors.New(fmt.Sprintf("浜у搧锛�%v,搴撳瓨锛�%v,璋冩嫧锛�%v,鏁伴噺涓嶅锛屾棤娉曞畬鎴愯皟鎷ㄦ搷浣�", v.Name, v.Amount.String(), value.String())) + } + fromLocAmount.Amount = fromLocAmount.Amount.Sub(value) + if err := models.NewLocationProductAmountSearch().SetID(fromLocAmount.Id).Update(fromLocAmount); err != nil { + return err + } + + locationRule, err := models.NewLocationProductSearch().SetProductId(v.ID).SetAreaId(operation.ToLocationID).First() + if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { + return err + } + + if err == nil { + operationTransfer := &models.Operation{ + Number: operation.Number, + SourceNumber: operation.SourceNumber, + OperationTypeId: 0, + OperationTypeName: operation.OperationTypeName, + Status: constvar.OperationStatus_Finish, + FromLocationID: locationRule.AreaId, + ToLocationID: locationRule.LocationId, + OperationDate: operation.OperationDate, + ContacterID: operation.ContacterID, + ContacterName: operation.ContacterName, + CompanyID: operation.CompanyID, + CompanyName: operation.CompanyName, + Comment: operation.Comment, + BaseOperationType: constvar.BaseOperationTypeInternal, + Details: []*models.OperationDetails{ + { + ProductId: v.ID, + Amount: value, + }, + }, + } + operationInputs = append(operationInputs, operationTransfer) + + //if err := tx.Create(&operationTransfer).Error; err != nil { + // return err + //} + + locAmount, err := models.NewLocationProductAmountSearch(). + SetProductId(v.ID). + SetLocationId(locationRule.LocationId). + First() + if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { + return err + } + locAmount.LocationId = locationRule.LocationId + locAmount.ProductId = v.ID + locAmount.CreateDate = time.Now().Format("2006-01-02 15:04:05") + locAmount.Amount = locAmount.Amount.Add(value) + if res := models.NewLocationProductAmountSearch().Orm.Where("id=?", locAmount.ID).Save(locAmount); res.Error != nil { + return res.Error + } + } else { + locationRule, err = models.NewLocationProductSearch().SetProductCategoryId(v.CategoryId).SetAreaId(operation.ToLocationID).First() + if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { + return err + } + if err == nil { + operationTransfer := &models.Operation{ + Number: operation.Number, + SourceNumber: operation.SourceNumber, + OperationTypeId: 0, + OperationTypeName: operation.OperationTypeName, + Status: constvar.OperationStatus_Finish, + FromLocationID: locationRule.AreaId, + ToLocationID: locationRule.LocationId, + OperationDate: operation.OperationDate, + ContacterID: operation.ContacterID, + ContacterName: operation.ContacterName, + CompanyID: operation.CompanyID, + CompanyName: operation.CompanyName, + Comment: operation.Comment, + BaseOperationType: constvar.BaseOperationTypeInternal, + Details: []*models.OperationDetails{ + { + ProductId: v.ID, + Amount: value, + }, + }, + } + operationInputs = append(operationInputs, operationTransfer) + + //if err := tx.Create(&operationTransfer).Error; err != nil { + // return err + //} + + locAmount, err := models.NewLocationProductAmountSearch(). + SetProductId(v.ID). + SetLocationId(locationRule.LocationId). + First() + if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { + return err + } + locAmount.LocationId = locationRule.LocationId + locAmount.ProductId = v.ID + locAmount.CreateDate = time.Now().Format("2006-01-02 15:04:05") + locAmount.Amount = locAmount.Amount.Add(value) + if res := models.NewLocationProductAmountSearch().Orm.Where("id=?", locAmount.ID).Save(locAmount); res.Error != nil { + return res.Error + } + } else { + locAmount, err := models.NewLocationProductAmountSearch(). + SetProductId(v.ID). + SetLocationId(operation.ToLocationID). + First() + if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) { + return err + } + locAmount.LocationId = operation.ToLocationID + locAmount.ProductId = v.ID + locAmount.CreateDate = time.Now().Format("2006-01-02 15:04:05") + locAmount.Amount = locAmount.Amount.Add(value) + if res := models.NewLocationProductAmountSearch().Orm.Where("id=?", locAmount.ID).Save(locAmount); res.Error != nil { + return res.Error + } + } + } + } + if len(operationInputs) > 0 { + if err := tx.Create(&operationInputs).Error; err != nil { + return err + } + } } return nil }); err != nil { @@ -314,3 +681,34 @@ } util.ResponseFormat(c, code.Success, "鎿嶄綔鎴愬姛") } + +// listTransfer +// @Tags 鍏ュ簱/鍑哄簱 +// @Summary 搴撳瓨璋冩嫧鍒楄〃 +// @Produce application/json +// @Param object body request.OperationAllList true "鍙傛暟" +// @Success 200 {object} util.Response "鎴愬姛" +// @Router /api-wms/v1/operation/listTransfer [post] +func (slf OperationController) ListTransfer(c *gin.Context) { + var params request.OperationAllList + if err := c.BindJSON(¶ms); err != nil { + util.ResponseFormat(c, code.RequestParamError, "鍙傛暟瑙f瀽澶辫触锛屾暟鎹被鍨嬮敊璇�:"+err.Error()) + return + } + if !params.PageInfo.Check() { + util.ResponseFormat(c, code.RequestParamError, "鏁版嵁鍒嗛〉淇℃伅閿欒") + return + } + search := models.NewOperationSearch() + search.SetPage(params.Page, params.PageSize) + search.SetPage(params.Page, params.PageSize) + if params.Number != "" { + search.SetKeyword(params.Number) + } + list, total, err := search.SetPreload(true).SetBaseOperationType(constvar.BaseOperationTypeInternal).SetOrder("created_at desc").Find() + if err != nil { + util.ResponseFormat(c, code.RequestError, "鏌ユ壘澶辫触:"+err.Error()) + return + } + util.ResponseFormatListWithPage(c, code.Success, list, int(total), params.Page, params.PageSize) +} -- Gitblit v1.8.0