zhangqian
2023-08-24 a91f274d753217814c29c0e54a80b3931da5f593
service/salesRefund.go
@@ -4,6 +4,7 @@
   "aps_crm/constvar"
   "aps_crm/model"
   "aps_crm/pkg/ecode"
   "errors"
   "github.com/shopspring/decimal"
   "gorm.io/gorm"
)
@@ -23,23 +24,29 @@
   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
@@ -54,7 +61,7 @@
      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
      }
   }
@@ -131,22 +138,31 @@
      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