提交

Service/TakeStock/TakeStockService.cs

@@ -331,8 +331,12 @@ namespace Service.TakeStock
 
         public async Task PushTakeStockMsg(TakeStockOrder order)
         {
-            string message = JsonConvert.SerializeObject(new { Code = order.Code, WarehouseCode = order.WarehouseCode, Sku = order.Sku, Quantity = order.AfterQuantity ?? 0 });
-            _bus.Send("skuputin_queue", message);
+            if (order.AfterQuantity > 0)
+            {
+                string message = JsonConvert.SerializeObject(new { Code = order.Code, WarehouseCode = order.WarehouseCode, Sku = order.Sku, Quantity = order.AfterQuantity });
+                _bus.Send("skuputin_queue", message);
+                _bus.Dispose();
+            }
 
             //TakeStockMessage msg = new TakeStockMessage
             //{