srm查询入库单

liujiandao

2024-03-23 8397fb4c46d08d0332300f9fde1e7b3eb04845fe

 proto/product_inventory/server.go

@@ -330,6 +330,7 @@
}

func (s *Server) OrderProductOutput(ctx context.Context, req *OrderProductOutputRequest) (resp *OrderProductOutputResponse, err error) {
   resp = new(OrderProductOutputResponse)
   if req.OrderNumber == "" || len(req.Products) == 0 {
      return nil, errors.New("参数缺失")
   }
@@ -426,11 +427,17 @@
      productInfoList := make([]*service.ProductInfo, 0)
      for productNumber, productAmount := range locationProductAmounts {
         remainAmount := productNeedSendAmount[productNumber].Sub(productHasSendAmount[productNumber])
         if remainAmount.LessThanOrEqual(decimal.Zero) {
            continue
         }
         var locationSendAmount decimal.Decimal
         if productAmount.GreaterThanOrEqual(remainAmount) {
            locationSendAmount = remainAmount
         } else {
            locationSendAmount = productAmount
         }
         if locationSendAmount.LessThanOrEqual(decimal.Zero) {
            continue
         }
         productInfoList = append(productInfoList, &service.ProductInfo{
            ProductID: productNumber,
@@ -450,10 +457,10 @@
   err = service.AddOutputOperations(outputInfoList)

   if err != nil {
      logx.Errorf("OrderProductOutput AddOutputOperations err:%v", err)
      return nil, err
   }

   resp.Code = 1
   resp.Msg = "success"
   return nil, nil
   return resp, nil
}