diff --git a/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ShopSyncServiceImpl.java b/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ShopSyncServiceImpl.java index 12fe6a6f..41468178 100644 --- a/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ShopSyncServiceImpl.java +++ b/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ShopSyncServiceImpl.java @@ -13,6 +13,7 @@ import com.czg.account.service.ShopConfigService; import com.czg.account.service.ShopInfoService; import com.czg.account.service.ShopUserService; import com.czg.account.service.SyncNoticeService; +import com.czg.constant.CacheConstant; import com.czg.exception.CzgException; import com.czg.market.entity.ShopCoupon; import com.czg.market.service.ShopCouponService; @@ -26,6 +27,7 @@ import jakarta.annotation.Resource; import lombok.extern.slf4j.Slf4j; import org.apache.dubbo.config.annotation.DubboReference; import org.apache.dubbo.config.annotation.DubboService; +import org.springframework.cache.annotation.CacheEvict; import org.springframework.transaction.annotation.Transactional; import java.math.BigDecimal; @@ -125,6 +127,7 @@ public class ShopSyncServiceImpl implements ShopSyncService { @Override @Transactional(rollbackFor = Exception.class) + @CacheEvict(value = {CacheConstant.USER_CLIENT_HOTS_PRODUCT, CacheConstant.USER_CLIENT_GROUPS_PRODUCT}, key = "#targetShopId") public void sync(Long sourceShopId, Long targetShopId, Long sysUserId) { log.info("同步开始,源店铺ID:{},目标店铺ID:{}", sourceShopId, targetShopId); try { @@ -244,6 +247,7 @@ public class ShopSyncServiceImpl implements ShopSyncService { @Override @Transactional(rollbackFor = Exception.class) + @CacheEvict(value = {CacheConstant.USER_CLIENT_HOTS_PRODUCT, CacheConstant.USER_CLIENT_GROUPS_PRODUCT}, allEntries = true) public void syncUnitBySourceShop(Long sourceShopId, Long unitId, Long sysUserId) { assertAutoSync(sourceShopId); AssertUtil.isNull(unitId, "{}不能为空", "单位ID"); @@ -346,6 +350,7 @@ public class ShopSyncServiceImpl implements ShopSyncService { @Override @Transactional(rollbackFor = Exception.class) + @CacheEvict(value = {CacheConstant.USER_CLIENT_HOTS_PRODUCT, CacheConstant.USER_CLIENT_GROUPS_PRODUCT}, allEntries = true) public void syncSpecBySourceShop(Long sourceShopId, Long specId, Long sysUserId) { assertAutoSync(sourceShopId); AssertUtil.isNull(specId, "{}不能为空", "规格ID"); @@ -470,6 +475,7 @@ public class ShopSyncServiceImpl implements ShopSyncService { @Override @Transactional(rollbackFor = Exception.class) + @CacheEvict(value = {CacheConstant.USER_CLIENT_HOTS_PRODUCT, CacheConstant.USER_CLIENT_GROUPS_PRODUCT}, allEntries = true) public void syncCategoryBySourceShop(Long sourceShopId, Long categoryId, Long sysUserId) { assertAutoSync(sourceShopId); AssertUtil.isNull(categoryId, "{}不能为空", "分类ID"); @@ -580,6 +586,7 @@ public class ShopSyncServiceImpl implements ShopSyncService { @Override @Transactional(rollbackFor = Exception.class) + @CacheEvict(value = {CacheConstant.USER_CLIENT_HOTS_PRODUCT, CacheConstant.USER_CLIENT_GROUPS_PRODUCT}, allEntries = true) public void syncProductBySourceShop(Long sourceShopId, Long productId, Long sysUserId) { try { log.info("商品同步开始,源店铺ID:{},商品ID:{}", sourceShopId, productId); @@ -739,6 +746,7 @@ public class ShopSyncServiceImpl implements ShopSyncService { @Override @Transactional(rollbackFor = Exception.class) + @CacheEvict(value = {CacheConstant.USER_CLIENT_HOTS_PRODUCT, CacheConstant.USER_CLIENT_GROUPS_PRODUCT}, allEntries = true) public void syncGroupBySourceShop(Long sourceShopId, Long groupId, Long sysUserId) { assertAutoSync(sourceShopId); AssertUtil.isNull(groupId, "{}不能为空", "分组ID");