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 | 76 +++++++++++++++++++++++++++++++------ 1 files changed, 63 insertions(+), 13 deletions(-) diff --git a/service/salesDetails.go b/service/salesDetails.go index 81e10b2..dec2d36 100644 --- a/service/salesDetails.go +++ b/service/salesDetails.go @@ -1,10 +1,11 @@ package service import ( - "aps_crm/constvar" "aps_crm/model" + "aps_crm/model/request" "aps_crm/pkg/ecode" "github.com/shopspring/decimal" + "gorm.io/gorm" ) type SalesDetailsService struct{} @@ -21,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 @@ -42,28 +46,70 @@ return ecode.OK } +func (SalesDetailsService) BatchDeleteSalesDetails(ids []int) int { + err := model.NewSalesDetailsSearch().DeleteByIds(ids) + if err != nil { + return ecode.DBErr + } + return ecode.OK +} + func (SalesDetailsService) UpdateSalesDetails(salesDetails *model.SalesDetails) int { // check salesDetails exist - old, err := model.NewSalesDetailsSearch().SetId(salesDetails.Id).First() + old, err := model.NewSalesDetailsSearch().SetId(salesDetails.Id).SetPreload(true).First() if err != nil { return ecode.SalesDetailsNotExist } 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) - err = model.NewSalesDetailsSearch().SetId(salesDetails.Id).Update(salesDetails) + 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(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 + } + } + return nil + + }) + if err != nil { return ecode.SalesDetailsSetErr } @@ -71,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