From 842bbf18db5e0c218b699fe853b8de83848202e5 Mon Sep 17 00:00:00 2001 From: Tankaikai Date: Tue, 4 Mar 2025 16:24:08 +0800 Subject: [PATCH] =?UTF-8?q?1.=20=E5=95=86=E5=93=81=E4=BF=A1=E6=81=AF?= =?UTF-8?q?=E5=8F=98=E5=8A=A8=E5=88=B7=E6=96=B0=E5=BA=93=E5=AD=98=202.=20?= =?UTF-8?q?=E5=95=86=E5=93=81=E4=BF=A1=E6=81=AF=E5=8F=98=E5=8A=A8=E5=8F=91?= =?UTF-8?q?=E7=94=9FMq=E6=B6=88=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../order/service/impl/OrderInfoRpcServiceImpl.java | 1 + .../product/service/impl/ProductRpcServiceImpl.java | 9 ++++++++- .../service/product/service/impl/ProductServiceImpl.java | 3 +-- 3 files changed, 10 insertions(+), 3 deletions(-) diff --git a/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoRpcServiceImpl.java b/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoRpcServiceImpl.java index 26f6778e3..8050aa3cc 100644 --- a/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoRpcServiceImpl.java +++ b/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoRpcServiceImpl.java @@ -142,6 +142,7 @@ public class OrderInfoRpcServiceImpl implements OrderInfoRpcService { log.error("调用商品服务扣减库存失败", e); throw e; } + log.info("OrderService.--------------------------------------------库存更新成功"); } @Override diff --git a/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductRpcServiceImpl.java b/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductRpcServiceImpl.java index 6e00dac73..05e1e478c 100644 --- a/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductRpcServiceImpl.java +++ b/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductRpcServiceImpl.java @@ -19,6 +19,7 @@ import com.czg.service.product.mapper.ProdConsRelationMapper; import com.czg.service.product.mapper.ProductMapper; import com.mybatisflex.core.query.QueryWrapper; import jakarta.annotation.Resource; +import lombok.extern.slf4j.Slf4j; import org.apache.dubbo.config.annotation.DubboService; import org.springframework.cache.annotation.CacheEvict; import org.springframework.stereotype.Service; @@ -35,6 +36,7 @@ import java.util.Map; * @author tankaikai * @since 2025-03-01 10:19 */ +@Slf4j @Service @DubboService public class ProductRpcServiceImpl implements ProductRpcService { @@ -106,7 +108,12 @@ public class ProductRpcServiceImpl implements ProductRpcService { consStockFlowMapper.insert(consStockFlow); } } - rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId)); + try { + rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId)); + } catch (Exception e) { + log.error("发送商品信息变更Mq消息失败：", e); + } + log.info("ProductService.--------------------------------------------库存更新成功"); } @Override diff --git a/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductServiceImpl.java b/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductServiceImpl.java index 886ca2b8d..3f214339f 100644 --- a/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductServiceImpl.java +++ b/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductServiceImpl.java @@ -15,7 +15,6 @@ import com.czg.product.dto.ProdConsRelationDTO; import com.czg.product.dto.ProdSkuDTO; import com.czg.product.dto.ProductDTO; import com.czg.product.entity.ConsInfo; -import com.czg.product.entity.ProdConsRelation; import com.czg.product.entity.ProdSku; import com.czg.product.entity.Product; import com.czg.product.enums.ProductIsSaleTypeEnum; @@ -166,7 +165,7 @@ public class ProductServiceImpl extends ServiceImpl impl ProductDTO dto = super.getOneAs(queryWrapper, ProductDTO.class); List skuList = prodSkuMapper.selectListByQueryAs(query().eq(ProdSku::getProductId, id).eq(ProdSku::getIsDel, DeleteEnum.NORMAL.value()), ProdSkuDTO.class); dto.setSkuList(skuList); - List consList = prodConsRelationMapper.selectListByQueryAs(query().eq(ProdConsRelation::getProductId, dto.getId()), ProdConsRelationDTO.class); + List consList = prodConsRelationMapper.selectListByProdId(dto.getId()); dto.setConsList(consList); return dto; }