diff --git a/cash-api/order-server/src/main/java/com/czg/config/OTimeTask.java b/cash-api/order-server/src/main/java/com/czg/task/OTimeTask.java similarity index 97% rename from cash-api/order-server/src/main/java/com/czg/config/OTimeTask.java rename to cash-api/order-server/src/main/java/com/czg/task/OTimeTask.java index e7e74cd2..014f66d4 100644 --- a/cash-api/order-server/src/main/java/com/czg/config/OTimeTask.java +++ b/cash-api/order-server/src/main/java/com/czg/task/OTimeTask.java @@ -1,4 +1,4 @@ -package com.czg.config; +package com.czg.task; import cn.hutool.core.date.DateUtil; import com.czg.order.entity.OrderInfo; diff --git a/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoServiceImpl.java b/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoServiceImpl.java index e9a5cc91..ddab8268 100644 --- a/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoServiceImpl.java +++ b/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoServiceImpl.java @@ -46,7 +46,6 @@ import org.apache.dubbo.config.annotation.DubboReference; import org.apache.dubbo.config.annotation.DubboService; import org.jetbrains.annotations.NotNull; import org.springframework.context.annotation.Lazy; -import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.math.BigDecimal; @@ -483,11 +482,14 @@ public class OrderInfoServiceImpl extends ServiceImpl { - rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId)); - }); + ThreadUtil.execAsync(() -> rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId))); log.info("ProductService.--------------------------------------------库存更新成功"); } @@ -191,9 +192,7 @@ public class ProductRpcServiceImpl implements ProductRpcService { consStockFlowMapper.insert(consStockFlow); } } - ThreadUtil.execAsync(() -> { - rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId)); - }); + ThreadUtil.execAsync(() -> rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId))); log.info("ProductService.--------------------------------------------库存更新成功"); } @@ -266,9 +265,7 @@ public class ProductRpcServiceImpl implements ProductRpcService { consStockFlowMapper.insert(consStockFlow); } } - ThreadUtil.execAsync(() -> { - rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId)); - }); + ThreadUtil.execAsync(() -> rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId))); log.info("ProductService.--------------------------------------------库存更新成功"); } }