czg_team
/
cashier_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

同步时 清楚缓存

This commit is contained in:
wangw 2025-10-31 15:05:17 +08:00
parent 35bc20c77e
commit ad8c293579
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ShopSyncServiceImpl.java
View File

@ -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");