| | |
| | | "aps_crm/constvar" |
| | | "aps_crm/model" |
| | | "aps_crm/pkg/ecode" |
| | | "errors" |
| | | "github.com/shopspring/decimal" |
| | | "gorm.io/gorm" |
| | | ) |
| | |
| | | for _, product := range salesRefund.Products { |
| | | amount = amount.Add(product.Amount.Mul(product.Price)) |
| | | } |
| | | |
| | | code := ecode.OK |
| | | err = model.WithTransaction(func(db *gorm.DB) error { |
| | | err = model.NewSalesRefundSearch().Create(salesRefund) |
| | | if err != nil { |
| | | code = ecode.DBErr |
| | | return err |
| | | } |
| | | salesReturnRecord.AmountHasRefund = salesReturnRecord.AmountHasRefund.Add(amount).Round(2) |
| | | if salesReturnRecord.AmountHasRefund.GreaterThan(salesReturnRecord.AmountTotal) { |
| | | code = ecode.SalesRefundProductBeyondTotalAmount |
| | | return errors.New("退货产品对应总价超出应退总价") |
| | | } |
| | | salesReturnRecord.AmountShouldRefund = salesReturnRecord.AmountTotal.Sub(salesReturnRecord.AmountHasRefund).Round(2) |
| | | err = model.NewSalesReturnSearch().SetId(salesRefund.SourceId).Update(salesReturnRecord) |
| | | if err != nil { |
| | | code = ecode.DBErr |
| | | return err |
| | | } |
| | | return nil |
| | | }) |
| | | |
| | | if err != nil { |
| | | return ecode.SalesRefundExist |
| | | return code |
| | | } |
| | | |
| | | return ecode.OK |
| | |
| | | if returnProductsMap[product.Id] == nil { |
| | | return ecode.SalesRefundProductNotExist |
| | | } |
| | | if returnProductsMap[product.Id].Price != product.Price || product.Amount.GreaterThan(returnProductsMap[product.Id].Amount) { |
| | | if !returnProductsMap[product.Id].Price.Equal(product.Price) || product.Amount.GreaterThan(returnProductsMap[product.Id].Amount) { |
| | | return ecode.SalesRefundProductPriceOrAmountErr |
| | | } |
| | | } |
| | |
| | | diffAmount = diffAmount.Sub(product.Amount.Mul(product.Price)) |
| | | } |
| | | |
| | | code := ecode.OK |
| | | err = model.WithTransaction(func(db *gorm.DB) error { |
| | | err = model.NewSalesRefundSearch().SetId(salesRefund.Id).Update(salesRefund) |
| | | if err != nil { |
| | | code = ecode.DBErr |
| | | return err |
| | | } |
| | | salesReturnRecord.AmountHasRefund = salesReturnRecord.AmountHasRefund.Sub(diffAmount).Round(2) |
| | | salesReturnRecord.AmountShouldRefund = salesReturnRecord.AmountTotal.Sub(salesReturnRecord.AmountHasRefund).Round(2) |
| | | |
| | | if salesReturnRecord.AmountHasRefund.GreaterThan(salesReturnRecord.AmountTotal) { |
| | | code = ecode.SalesRefundProductBeyondTotalAmount |
| | | return errors.New("退货产品对应总价超出应退总价") |
| | | } |
| | | |
| | | err = model.NewSalesReturnSearch().SetId(salesRefund.SourceId).Update(salesReturnRecord) |
| | | if err != nil { |
| | | code = ecode.DBErr |
| | | return err |
| | | } |
| | | return nil |
| | | }) |
| | | |
| | | if err != nil { |
| | | return ecode.SalesRefundSetErr |
| | | return code |
| | | } |
| | | |
| | | return ecode.OK |