|
|
|
@@ -18,6 +18,8 @@ import com.iformall.mapper.WxCouponChannelMapper; |
|
|
|
import com.iformall.mapper.WxCouponMerchantMapper; |
|
|
|
import com.iformall.mapper.WxMerchantMapper; |
|
|
|
import com.iformall.service.*; |
|
|
|
import com.iformall.utils.JsonUtil; |
|
|
|
import org.apache.commons.lang3.StringUtils; |
|
|
|
import org.slf4j.Logger; |
|
|
|
import org.slf4j.LoggerFactory; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
@@ -129,8 +131,8 @@ public class WxCouponChannelServiceImpl implements WxCouponChannelService { |
|
|
|
* @param tenantId |
|
|
|
*/ |
|
|
|
public void clearCache(String tenantId){ |
|
|
|
for (int i = 1; i <=20 ; i++) { |
|
|
|
String key = "couponChannelList_"+tenantId+"_" + i + ":"; |
|
|
|
for (int i = 1; i <=5 ; i++) { |
|
|
|
String key = EnumCacheKey.C_INDEX_PAGE_LIST.getMessage()+tenantId+"_" + i + ":"; |
|
|
|
cdRedisTemplate.delete(key); |
|
|
|
} |
|
|
|
} |
|
|
|
@@ -306,20 +308,24 @@ public class WxCouponChannelServiceImpl implements WxCouponChannelService { |
|
|
|
@Override |
|
|
|
public PageInfo<WxCouponChannelVo> listPageCVo(WxCouponChannel record, Integer pageIndex, Integer pageSize) { |
|
|
|
PageInfo<WxCouponChannelVo> pageInfo; |
|
|
|
//首页走缓存 |
|
|
|
if(EnumTargetAd.LIST.getCode().equals(record.getTargetAd()) && new Integer(6).equals(pageSize) && pageIndex.intValue() <=20 ) { |
|
|
|
logger.info("---------chache"); |
|
|
|
String key = "couponChannelList_"+record.getTenantId()+"_" + pageIndex + ":"; |
|
|
|
//仅c端首页走缓存 |
|
|
|
if(EnumCouponChannelType.COUPON_CHANNEL_ID_LIST.getCode().equals(record.getTargetAd()) |
|
|
|
&& new Integer(6).equals(pageSize) |
|
|
|
&& pageIndex.intValue() <=5 |
|
|
|
&& record.getBusiness() == null) { |
|
|
|
|
|
|
|
logger.info("listPageCVo.chache"); |
|
|
|
String key = EnumCacheKey.C_INDEX_PAGE_LIST.getMessage() +record.getTenantId()+"_" + pageIndex + ":"; |
|
|
|
ValueOperations<String, PageInfo<WxCouponChannelVo>> operations = cdRedisTemplate.opsForValue(); |
|
|
|
boolean hasKey = cdRedisTemplate.hasKey(key); |
|
|
|
if (hasKey) { |
|
|
|
pageInfo = operations.get(key); |
|
|
|
logger.info("---------get:{}",pageInfo.getList().size()); |
|
|
|
logger.info("listPageCVo.chache.get:{}", pageInfo.getList()==null?0:pageInfo.getList().size()); |
|
|
|
}else{ |
|
|
|
pageInfo = PageHelper.startPage(pageIndex, pageSize).doSelectPageInfo(() -> wxCouponChannelMapper.findVoList(record)); |
|
|
|
} |
|
|
|
//插入缓存 |
|
|
|
operations.set(key, pageInfo, 3600, TimeUnit.SECONDS); |
|
|
|
operations.set(key, pageInfo, 60, TimeUnit.SECONDS); |
|
|
|
return pageInfo; |
|
|
|
} |
|
|
|
|
|
|
|
|