From 530fed8ec225453572d57b15c200ab062c335457 Mon Sep 17 00:00:00 2001 From: zhangqian <zhangqian@123.com> Date: 星期三, 01 十一月 2023 19:20:21 +0800 Subject: [PATCH] 公海member_id使用0 --- service/salesDetails.go | 56 +++++++++++++++++++++++++++++++++----------------------- 1 files changed, 33 insertions(+), 23 deletions(-) diff --git a/service/salesDetails.go b/service/salesDetails.go index d925e9d..dec2d36 100644 --- a/service/salesDetails.go +++ b/service/salesDetails.go @@ -1,8 +1,8 @@ package service import ( - "aps_crm/constvar" "aps_crm/model" + "aps_crm/model/request" "aps_crm/pkg/ecode" "github.com/shopspring/decimal" "gorm.io/gorm" @@ -22,6 +22,9 @@ salesDetails.AmountTotal = salesDetails.AmountTotal.Round(2) salesDetails.AmountReceivable = salesDetails.AmountTotal salesDetails.AmountUnInvoiced = salesDetails.AmountTotal + for _, product := range salesDetails.Products { + product.Id = 0 + } err := model.NewSalesDetailsSearch().Create(salesDetails) if err != nil { return ecode.SalesDetailsExist @@ -59,46 +62,49 @@ } var totalAmount decimal.Decimal totalAmount = salesDetails.AmountTotal - newProducts, removedProducts := NewProductsService().PickDiffProducts(salesDetails.Products, old.Products) - for _, product := range newProducts { + for _, product := range salesDetails.Products { totalAmount = totalAmount.Add(product.Amount.Mul(product.Price)) - } - removedProductIds := make([]uint, 0, len(removedProducts)) - for _, product := range removedProducts { - totalAmount = totalAmount.Sub(product.Amount.Mul(product.Price)) - removedProductIds = append(removedProductIds, product.Id) } salesDetails.AmountTotal = totalAmount.Round(2) salesDetails.AmountReceivable = salesDetails.AmountTotal.Sub(salesDetails.AmountReceived) salesDetails.AmountUnInvoiced = salesDetails.AmountTotal.Sub(salesDetails.AmountInvoiced) + newProducts, removedProducts := NewProductsService().PickDiffProducts(salesDetails.Products, old.Products) err = model.WithTransaction(func(db *gorm.DB) error { err = model.NewSalesDetailsSearch().SetId(salesDetails.Id).Update(salesDetails) if err != nil { return err } - if len(removedProductIds) > 0 { + if len(removedProducts) > 0 { + removedProductIds := make([]uint, 0, len(removedProducts)) + for _, product := range removedProducts { + totalAmount = totalAmount.Sub(product.Amount.Mul(product.Price)) + removedProductIds = append(removedProductIds, product.Id) + } err = model.NewProductSearch(db).SetIds(removedProductIds).Delete() if err != nil { return err } } if len(newProducts) > 0 { + for _, p := range newProducts { + p.Id = 0 + } err = model.NewProductSearch(db).CreateBatch(newProducts) if err != nil { return err } - //var rel []*model.SalesDetailsProduct - //for _, p := range newProducts { - // rel = append(rel, &model.SalesDetailsProduct{ - // SalesDetailsId: salesDetails.Id, - // ProductId: p.Id, - // }) - //} - //err = model.NewSalesDetailsProductSearch().CreateBatch(rel) - //if err != nil { - // return err - //} + var rel []*model.SalesDetailsProduct + for _, p := range newProducts { + rel = append(rel, &model.SalesDetailsProduct{ + SalesDetailsId: salesDetails.Id, + ProductId: p.Id, + }) + } + err = model.NewSalesDetailsProductSearch().CreateBatch(rel) + if err != nil { + return err + } } return nil @@ -111,12 +117,16 @@ return ecode.OK } -func (SalesDetailsService) GetSalesDetailsList(page, pageSize int, keywordType constvar.SalesDetailsKeywordType, keyword string) ([]*model.SalesDetails, int64, int) { +func (SalesDetailsService) GetSalesDetailsList(params request.GetSalesDetailsList, memberIds []int) ([]*model.SalesDetails, int64, int) { // get contact list contacts, total, err := model.NewSalesDetailsSearch(). SetPreload(true). - SetKeywordType(keywordType). - SetKeyword(keyword).SetPage(page, pageSize).FindAll() + SetMemberIds(memberIds). + SetKeywordType(params.KeywordType). + SetSaleChanceId(params.SaleChanceId). + SetClientId(params.ClientId). + SetNumber(params.Number). + SetKeyword(params.Keyword).SetPage(params.Page, params.PageSize).FindAll() if err != nil { return nil, 0, ecode.SalesDetailsListErr } -- Gitblit v1.8.0