| | |
| | | } |
| | | salesReturn.AmountShouldRefund = salesReturn.AmountTotal |
| | | |
| | | err = model.NewSalesReturnSearch().SetId(salesReturn.Id).Update(salesReturn) |
| | | old, err := model.NewSalesReturnSearch().SetId(salesReturn.Id).SetPreload(true).First() |
| | | if err != nil { |
| | | return ecode.SalesReturnSetErr |
| | | return ecode.DBErr |
| | | } |
| | | newProducts, removedProducts := NewProductsService().PickDiffProducts(salesReturn.Products, old.Products) |
| | | err = model.WithTransaction(func(db *gorm.DB) error { |
| | | err := model.NewSalesReturnSearch().SetId(salesReturn.Id).Update(salesReturn) |
| | | if err != nil { |
| | | return err |
| | | } |
| | | if len(removedProducts) > 0 { |
| | | removedProductIds := make([]uint, 0, len(removedProducts)) |
| | | for _, product := range removedProducts { |
| | | 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.SalesReturnProduct |
| | | for _, p := range newProducts { |
| | | rel = append(rel, &model.SalesReturnProduct{ |
| | | SalesReturnId: salesReturn.Id, |
| | | ProductId: p.Id, |
| | | }) |
| | | } |
| | | err = model.NewSalesReturnProductSearch().CreateBatch(rel) |
| | | if err != nil { |
| | | return err |
| | | } |
| | | } |
| | | return nil |
| | | }) |
| | | |
| | | if err != nil { |
| | | return ecode.DBErr |
| | | } |
| | | |
| | | return ecode.OK |