diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/order/service/impl/ShopOrderReturnServiceImpl.java b/mall-shop/src/main/java/com/suisung/mall/shop/order/service/impl/ShopOrderReturnServiceImpl.java index 049413ae..de3b31b4 100644 --- a/mall-shop/src/main/java/com/suisung/mall/shop/order/service/impl/ShopOrderReturnServiceImpl.java +++ b/mall-shop/src/main/java/com/suisung/mall/shop/order/service/impl/ShopOrderReturnServiceImpl.java @@ -58,6 +58,7 @@ import com.suisung.mall.shop.sfexpress.service.SFExpressApiService; import com.suisung.mall.shop.store.service.ShopStoreBaseService; import com.suisung.mall.shop.store.service.ShopStoreConfigService; import com.suisung.mall.shop.store.service.ShopStoreShippingAddressService; +import com.suisung.mall.shop.sync.service.SyncThirdDataService; import io.seata.spring.annotation.GlobalTransactional; import lombok.extern.slf4j.Slf4j; import org.slf4j.Logger; @@ -203,6 +204,9 @@ public class ShopOrderReturnServiceImpl extends BaseServiceImpl> statisticState() { UserDto user = getCurrentUser(); @@ -1506,6 +1510,13 @@ public class ShopOrderReturnServiceImpl extends BaseServiceImpl stockDeltaMap = new HashMap<>(); + String item_src_id= productItem.getItem_src_id(); + stockDeltaMap.put(item_src_id + "-" + shopOrderItem.getOrder_id(), returnNum); + syncThirdDataService.incrProductStockToRedis(stockDeltaMap); + logger.info("退货返回给思迅,存入redis成功,item_src_id:{},订单号:{},数量:{}",item_src_id,shopOrderReturn.getOrder_id(),returnNum); } else { logger.warn("退货数量为空,无法增加库存,订单项ID: {}", orderItemId); }