diff --git a/src/main/java/com/chaozhanggui/system/cashierservice/service/CartService.java b/src/main/java/com/chaozhanggui/system/cashierservice/service/CartService.java
index 6d6f849..72d6b4b 100644
--- a/src/main/java/com/chaozhanggui/system/cashierservice/service/CartService.java
+++ b/src/main/java/com/chaozhanggui/system/cashierservice/service/CartService.java
@@ -643,11 +643,6 @@ public class CartService {
                     return;
                 }
 
-                // 发送判断耗材是否耗尽消息
-                JSONObject objectMsg = new JSONObject();
-                objectMsg.put("skuId", Integer.valueOf(cashierCart.getSkuId()));
-                objectMsg.put("shopId", Integer.valueOf(cashierCart.getShopId()));
-                producer.con_msg(objectMsg.toString());
 
                 totalAmount = totalAmount.add(cashierCart.getTotalAmount());
                 packAMount = packAMount.add(cashierCart.getPackFee());
@@ -849,6 +844,17 @@ public class CartService {
             log.info("开始发送mq消息，消耗耗材，消息内容：{}", jsonObject2);
             producer.cons(jsonObject2.toString());
 
+            for (int i = 0; i < array.size(); i++) {
+                JSONObject object = array.getJSONObject(i);
+                TbCashierCart cashierCart = JSONUtil.parseJSONStr2T(object.toJSONString(), TbCashierCart.class);
+                // 发送判断耗材是否耗尽消息
+                JSONObject objectMsg = new JSONObject();
+                objectMsg.put("skuId", Integer.valueOf(cashierCart.getSkuId()));
+                objectMsg.put("shopId", Integer.valueOf(cashierCart.getShopId()));
+                producer.con_msg(objectMsg.toString());
+            }
+
+
             redisUtil.saveMessage(RedisCst.TABLE_CART.concat(jsonObject.getString("tableId")).concat("-").concat(shopId), array.toJSONString());
             orderInfo.setDetailList(orderDetails);
             JSONObject jsonObject1 = new JSONObject();