1. 商品信息变动刷新库存

2. 商品信息变动发生Mq消息

cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductRpcServiceImpl.java

@@ -3,6 +3,7 @@ package com.czg.service.product.service.impl;
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.convert.Convert;
+import cn.hutool.core.thread.ThreadUtil;
 import cn.hutool.core.util.NumberUtil;
 import com.czg.config.RabbitPublisher;
 import com.czg.constant.CacheConstant;
@@ -108,11 +109,9 @@ public class ProductRpcServiceImpl implements ProductRpcService {
                 consStockFlowMapper.insert(consStockFlow);
             }
         }
-        /*try {
+        ThreadUtil.execAsync(() -> {
             rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId));
-        } catch (Exception e) {
-            log.error("发送商品信息变更Mq消息失败：", e);
-        }*/
+        });
         log.info("ProductService.--------------------------------------------库存更新成功");
     }