按采购编号查询质检单列表

zhangqian

2023-08-29 9984c2c7cef1cca16055ae5d49d5ad275a7981ab

 service/purchase/purchase.go

@@ -25,27 +25,11 @@
//@return: err error

func (slf *PurchaseService) CreatePurchase(record *purchase.Purchase, productList []*purchase.PurchaseProducts) (err error) {
   err = DealPrice(record, productList)
   if err != nil {
      return err
   }
   err = global.GVA_DB.Transaction(func(tx *gorm.DB) error {
      var quantity decimal.Decimal
      var totalPrice decimal.Decimal
      var realTotalPrice decimal.Decimal
      for _, product := range productList {
         quantity = quantity.Add(product.Amount)
         totalPrice = totalPrice.Add(product.Price.Mul(product.Amount))
      }
      if !totalPrice.Equal(record.TotalPrice) {
         return errors.New("价税总计计算错误")
      }
      if !quantity.Equal(record.Quantity) {
         return errors.New("产品数量计算错误")
      }
      realTotalPrice = record.CalcRealTotalPrice()
      if !realTotalPrice.Equal(record.RealTotalPrice) {
         return errors.New("最终价格计算错误")
      }
      record.UnInvoiceAmount = record.RealTotalPrice
      record.ShouldPayAmount = record.RealTotalPrice

      err = tx.Create(&record).Error
      if err != nil {
         return err
@@ -57,6 +41,29 @@
   })

   return err
}

func DealPrice(record *purchase.Purchase, productList []*purchase.PurchaseProducts) error {
   var quantity decimal.Decimal
   var totalPrice decimal.Decimal
   var realTotalPrice decimal.Decimal
   for _, product := range productList {
      quantity = quantity.Add(product.Amount)
      totalPrice = totalPrice.Add(product.Price.Mul(product.Amount))
   }
   if !totalPrice.Equal(record.TotalPrice) {
      return errors.New("价税总计计算错误")
   }
   if !quantity.Equal(record.Quantity) {
      return errors.New("产品数量计算错误")
   }
   realTotalPrice = record.CalcRealTotalPrice()
   if !realTotalPrice.Equal(record.RealTotalPrice) {
      return errors.New("最终价格计算错误")
   }
   record.UnInvoiceAmount = record.RealTotalPrice
   record.ShouldPayAmount = record.RealTotalPrice
   return nil
}

//@function: DeletePurchase
@@ -81,12 +88,11 @@
//@return: err error

func (slf *PurchaseService) UpdatePurchase(params *purchase.Purchase, productList []*purchase.PurchaseProducts) (err error) {
   err = DealPrice(params, productList)
   if err != nil {
      return err
   }
   err = global.GVA_DB.Transaction(func(tx *gorm.DB) error {
      var quantity decimal.Decimal
      for _, product := range productList {
         quantity = quantity.Add(product.Amount)
      }
      params.Quantity = quantity
      err = tx.Where("id = ?", params.ID).Updates(params).Error
      if err != nil {
         return err
@@ -131,7 +137,7 @@
         Or("Product.name like ?", "%"+info.Keyword+"%").
         Or("supplier.name like ?", "%"+info.Keyword+"%")
   }
   var purchaseList []purchase.Purchase
   var purchaseList []*purchase.Purchase
   err = db.Count(&total).Error
   if err != nil {
      return purchaseList, total, err
@@ -210,20 +216,24 @@
         continue
      }
      inspectOrder := &qualityinspect.QualityInspect{
         InspectType:   qualityinspect.InspectType_InspectTypePurchase,
         MaterialType:  qualityinspect.MaterialType_MaterialTypeRaw,
         MaterialName:  product.Name,
         MaterialId:    product.Number,
         MaterialTp:    product.ModelNumber,
         MaterialUnit:  product.Unit,
         Supplier:      record.Supplier.Name,
         WarehouseName: "采购总仓",
         ReportAmount:  productItem.Amount.InexactFloat64(),
         InspectMethod: qualityinspect.InspectMethod_InspectMethodAll,
         InspectAmount: productItem.Amount.InexactFloat64(),
         InspectType:     qualityinspect.InspectType_InspectTypePurchase,
         MaterialType:    qualityinspect.MaterialType_MaterialTypeRaw,
         MaterialName:    product.Name,
         MaterialId:      product.Number,
         MaterialTp:      product.ModelNumber,
         MaterialUnit:    product.Unit,
         Supplier:        record.Supplier.Name,
         WarehouseName:   "采购总仓",
         ReportAmount:    productItem.Amount.InexactFloat64(),
         InspectMethod:   qualityinspect.InspectMethod_InspectMethodAll,
         InspectAmount:   productItem.Amount.InexactFloat64(),
         PurchaseOrderId: record.Number,
      }
      inspectOrders = append(inspectOrders, inspectOrder)
   }
   if len(inspectOrders) == 0 {
      return nil
   }
   inspectRequest := qualityinspect.SendPurchaseInspectRequest{List: inspectOrders}
   _, err = qualityinspect.NewQualityInspectServiceClient(qualityinspect.Conn).SendPurchaseInspect(context.Background(), &inspectRequest)
   return err