|
|
|
@ -4,101 +4,66 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
|
|
import com.wayn.common.config.WaynConfig;
|
|
|
|
|
import com.wayn.common.constant.Constants;
|
|
|
|
|
import com.wayn.common.core.domain.shop.Banner;
|
|
|
|
|
import com.wayn.common.core.domain.shop.Diamond;
|
|
|
|
|
import com.wayn.common.core.domain.shop.Goods;
|
|
|
|
|
import com.wayn.common.core.domain.shop.vo.HomeIndexResponseVO;
|
|
|
|
|
import com.wayn.common.core.service.shop.IBannerService;
|
|
|
|
|
import com.wayn.common.core.service.shop.ICategoryService;
|
|
|
|
|
import com.wayn.common.core.service.shop.IDiamondService;
|
|
|
|
|
import com.wayn.common.core.service.shop.IGoodsService;
|
|
|
|
|
import com.wayn.common.util.R;
|
|
|
|
|
import com.wayn.data.redis.manager.RedisCache;
|
|
|
|
|
import com.wayn.mobile.api.service.IHomeService;
|
|
|
|
|
import lombok.AllArgsConstructor;
|
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
import org.apache.commons.collections4.MapUtils;
|
|
|
|
|
import org.springframework.data.redis.core.RedisTemplate;
|
|
|
|
|
import org.springframework.cache.annotation.CacheConfig;
|
|
|
|
|
import org.springframework.cache.annotation.Cacheable;
|
|
|
|
|
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
|
|
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
|
|
|
|
import java.util.ArrayList;
|
|
|
|
|
import java.util.List;
|
|
|
|
|
import java.util.Map;
|
|
|
|
|
import java.util.concurrent.CompletableFuture;
|
|
|
|
|
|
|
|
|
|
import static com.wayn.data.redis.constant.CacheConstants.SHOP_HOME_INDEX_HASH;
|
|
|
|
|
import static com.wayn.data.redis.constant.CacheConstants.SHOP_HOME_INDEX_HASH_EXPIRATION_FIELD;
|
|
|
|
|
|
|
|
|
|
@Slf4j
|
|
|
|
|
@Service
|
|
|
|
|
@CacheConfig(keyGenerator = "cacheKeyGenerator")
|
|
|
|
|
@AllArgsConstructor
|
|
|
|
|
public class IHomeServiceImpl implements IHomeService {
|
|
|
|
|
|
|
|
|
|
private IBannerService iBannerService;
|
|
|
|
|
private ICategoryService iCategoryService;
|
|
|
|
|
private IGoodsService iGoodsService;
|
|
|
|
|
private RedisCache redisCache;
|
|
|
|
|
private RedisTemplate<String, Object> redisTemplate;
|
|
|
|
|
private IDiamondService iDiamondService;
|
|
|
|
|
private ThreadPoolTaskExecutor commonThreadPoolTaskExecutor;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Cacheable(value = "home_index_cache#600", unless = "#result == null")
|
|
|
|
|
@Override
|
|
|
|
|
public R index() {
|
|
|
|
|
R success = R.success();
|
|
|
|
|
Map<String, Object> shopHomeIndexHash = redisCache.getCacheMap(SHOP_HOME_INDEX_HASH);
|
|
|
|
|
// 当缓存中存在数据,并且过期时间不为空而且小于等于过期时间则直接从缓存中取出数据
|
|
|
|
|
long nowTime = System.currentTimeMillis();
|
|
|
|
|
if (MapUtils.isNotEmpty(shopHomeIndexHash) && shopHomeIndexHash.containsKey(SHOP_HOME_INDEX_HASH_EXPIRATION_FIELD)) {
|
|
|
|
|
long time = (long) shopHomeIndexHash.get(SHOP_HOME_INDEX_HASH_EXPIRATION_FIELD);
|
|
|
|
|
if ((nowTime - time) <= Constants.ONE_DAY) {
|
|
|
|
|
shopHomeIndexHash.forEach(success::add);
|
|
|
|
|
log.info("getHomeIndexDataCompletableFuture:{}", success);
|
|
|
|
|
return success;
|
|
|
|
|
}
|
|
|
|
|
public HomeIndexResponseVO index() {
|
|
|
|
|
HomeIndexResponseVO responseVO = new HomeIndexResponseVO();
|
|
|
|
|
try {
|
|
|
|
|
List<CompletableFuture<Void>> list = new ArrayList<>(4);
|
|
|
|
|
CompletableFuture<Void> f1 = CompletableFuture.supplyAsync(
|
|
|
|
|
() -> iBannerService.list(Wrappers.lambdaQuery(Banner.class).eq(Banner::getStatus, 0).orderByAsc(Banner::getSort)), commonThreadPoolTaskExecutor)
|
|
|
|
|
.thenAccept(responseVO::setBannerList);
|
|
|
|
|
CompletableFuture<Void> f2 = CompletableFuture.supplyAsync(
|
|
|
|
|
() -> iDiamondService.list(Wrappers.lambdaQuery(Diamond.class).orderByAsc(Diamond::getSort).last("limit 10")), commonThreadPoolTaskExecutor)
|
|
|
|
|
.thenAccept(responseVO::setCategoryList);
|
|
|
|
|
CompletableFuture<Void> f3 = CompletableFuture.supplyAsync(
|
|
|
|
|
() -> iGoodsService.selectHomeIndexGoods(Goods.builder().isNew(true).build()), commonThreadPoolTaskExecutor)
|
|
|
|
|
.thenAccept(responseVO::setNewGoodsList);
|
|
|
|
|
CompletableFuture<Void> f4 = CompletableFuture.supplyAsync(
|
|
|
|
|
() -> iGoodsService.selectHomeIndexGoods(Goods.builder().isHot(true).build()), commonThreadPoolTaskExecutor)
|
|
|
|
|
.thenAccept(responseVO::setHotGoodsList);
|
|
|
|
|
list.add(f1);
|
|
|
|
|
list.add(f2);
|
|
|
|
|
list.add(f3);
|
|
|
|
|
list.add(f4);
|
|
|
|
|
CompletableFuture.allOf(list.toArray(new CompletableFuture[0])).join();
|
|
|
|
|
return responseVO;
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
log.error(e.getMessage(), e);
|
|
|
|
|
}
|
|
|
|
|
List<CompletableFuture<Void>> list = new ArrayList<>(4);
|
|
|
|
|
CompletableFuture<Void> f1 = CompletableFuture.supplyAsync(
|
|
|
|
|
() -> iBannerService.list(Wrappers.lambdaQuery(Banner.class).eq(Banner::getStatus, 0).orderByAsc(Banner::getSort)), commonThreadPoolTaskExecutor)
|
|
|
|
|
.thenAccept(data -> {
|
|
|
|
|
String key = "bannerList";
|
|
|
|
|
redisCache.setCacheMapValue(SHOP_HOME_INDEX_HASH, key, data);
|
|
|
|
|
log.info("bannerList:{}", data);
|
|
|
|
|
success.add(key, data);
|
|
|
|
|
});
|
|
|
|
|
CompletableFuture<Void> f2 = CompletableFuture.supplyAsync(
|
|
|
|
|
() -> iDiamondService.list(Wrappers.lambdaQuery(Diamond.class).orderByAsc(Diamond::getSort).last("limit 10")), commonThreadPoolTaskExecutor)
|
|
|
|
|
.thenAccept(data -> {
|
|
|
|
|
String key = "categoryList";
|
|
|
|
|
redisCache.setCacheMapValue(SHOP_HOME_INDEX_HASH, key, data);
|
|
|
|
|
log.info("categoryList:{}", data);
|
|
|
|
|
success.add(key, data);
|
|
|
|
|
});
|
|
|
|
|
CompletableFuture<Void> f3 = CompletableFuture.supplyAsync(
|
|
|
|
|
() -> iGoodsService.selectHomeIndexGoods(Goods.builder().isNew(true).build()), commonThreadPoolTaskExecutor)
|
|
|
|
|
.thenAccept(data -> {
|
|
|
|
|
String key = "newGoodsList";
|
|
|
|
|
redisCache.setCacheMapValue(SHOP_HOME_INDEX_HASH, key, data);
|
|
|
|
|
log.info("newGoodsList:{}", data);
|
|
|
|
|
success.add(key, data);
|
|
|
|
|
});
|
|
|
|
|
CompletableFuture<Void> f4 = CompletableFuture.supplyAsync(
|
|
|
|
|
() -> iGoodsService.selectHomeIndexGoods(Goods.builder().isHot(true).build()), commonThreadPoolTaskExecutor)
|
|
|
|
|
.thenAccept(data -> {
|
|
|
|
|
String key = "hotGoodsList";
|
|
|
|
|
redisCache.setCacheMapValue(SHOP_HOME_INDEX_HASH, key, data);
|
|
|
|
|
log.info("hotGoodsList:{}", data);
|
|
|
|
|
success.add(key, data);
|
|
|
|
|
});
|
|
|
|
|
list.add(f1);
|
|
|
|
|
list.add(f2);
|
|
|
|
|
list.add(f3);
|
|
|
|
|
list.add(f4);
|
|
|
|
|
CompletableFuture.allOf(list.toArray(new CompletableFuture[0])).join();
|
|
|
|
|
// 通过hash的field设置过期时间,防止过期时间设置失败导致缓存无法删除
|
|
|
|
|
redisCache.setCacheMapValue(SHOP_HOME_INDEX_HASH, SHOP_HOME_INDEX_HASH_EXPIRATION_FIELD, nowTime);
|
|
|
|
|
return success;
|
|
|
|
|
return null ;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|