CartServiceImpl.java

package com.youlai.mall.oms.service.impl;

import com.youlai.common.web.util.RequestUtils;
import com.youlai.mall.oms.constant.OmsConstants;
import com.youlai.mall.oms.pojo.vo.CartVO;
import com.youlai.mall.oms.service.ICartService;
import com.youlai.mall.pms.api.app.PmsSkuFeignService;
import com.youlai.mall.pms.pojo.domain.PmsSku;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.core.BoundHashOperations;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

import java.util.List;
import java.util.concurrent.CompletableFuture;


/**
 * 购物车模块
 * <p>
 * 技术点：BoundHashOperations
 * 数据格式：
 * -- key <----> 购物车
 * -- hKey:value <----> 购物车商品1
 * -- hKey:value <----> 购物车商品2
 * -- hKey:value <----> 购物车商品3
 */
@Service
@Slf4j
@AllArgsConstructor
public class CartServiceImpl implements ICartService {

    private RedisTemplate redisTemplate;
    private PmsSkuFeignService skuFeignService;

    /**
     * 获取用户购物车
     */
    @Override
    public CartVO getCart() {
        CartVO cart = new CartVO();
        BoundHashOperations cartHashOperations = getCartHashOperations();
        List<CartVO.CartItem> cartItems = cartHashOperations.values();
        cart.setItems(cartItems);
        return cart;
    }

    @Override
    public List<CartVO.CartItem> getCartItems() {
        BoundHashOperations cartHashOperations = getCartHashOperations();
        List<CartVO.CartItem> cartItems = cartHashOperations.values();
        return cartItems;
    }


    /**
     * 删除用户购物车(清空购物车)
     */
    @Override
    public boolean deleteCart() {
        String key = OmsConstants.CART_PREFIX + RequestUtils.getUserId();
        redisTemplate.delete(key);
        return true;
    }

    /**
     * 添加商品至购物车
     */
    @Override
    public boolean addCartItem(Long skuId) {
        BoundHashOperations cartHashOperations = getCartHashOperations();
        String hKey = skuId + "";

        CartVO.CartItem cartItem;
        // 购物车已存在该商品，更新商品数量
        if (cartHashOperations.get(hKey) != null) {
            cartItem = (CartVO.CartItem) cartHashOperations.get(hKey);
            cartItem.setCount(cartItem.getCount() + 1); // 点击一次“加入购物车”，数量+1
            cartHashOperations.put(hKey, cartItem);
            return true;
        }
        // 购物车不存在该商品，添加商品至购物车
        cartItem = new CartVO.CartItem();
        CompletableFuture<Void> cartItemCompletableFuture = CompletableFuture.runAsync(() -> {
            PmsSku sku = skuFeignService.getSkuById(skuId).getData();
            if (sku != null) {
                cartItem.setSkuId(sku.getId());
                cartItem.setCount(1);
                cartItem.setPrice(sku.getPrice());
                cartItem.setPic(sku.getPic());
                cartItem.setSkuId(sku.getId());
                cartItem.setTitle(sku.getTitle());
            }
        });
        CompletableFuture.allOf(cartItemCompletableFuture).join();
        return true;
    }

    /**
     * 更新购物车总商品数量、选中状态
     */
    @Override
    public boolean updateCartItem(CartVO.CartItem cartItem) {
        BoundHashOperations cartHashOperations = getCartHashOperations();
        String hKey = cartItem.getSkuId() + "";
        if (cartHashOperations.get(hKey) != null) {
            cartHashOperations.put(hKey, cartItem);
        }
        return true;
    }

    /**
     * 移除购物车的商品
     */
    @Override
    public boolean removeCartItem(Long skuId) {
        BoundHashOperations cartHashOperations = getCartHashOperations();
        String hKey = skuId + "";
        cartHashOperations.delete(hKey);
        return true;
    }


    /**
     * 设置商品全选
     */
    @Override
    public boolean checkAll(boolean checked) {
        BoundHashOperations cartHashOperations = getCartHashOperations();
        for (Object value : cartHashOperations.values()) {
            CartVO.CartItem cartItem = (CartVO.CartItem) value;
            cartItem.setChecked(checked);
            String hKey = cartItem.getSkuId() + "";
            cartHashOperations.put(hKey, cartItem);
        }
        return true;
    }


    /**
     * 移除购物车选中的商品
     * — 场景：支付后删除购物车的商品
     */
    @Override
    public boolean removeCheckedItem() {
        BoundHashOperations cartHashOperations = getCartHashOperations();
        for (Object value : cartHashOperations.values()) {
            CartVO.CartItem cartItem = (CartVO.CartItem) value;
            if (cartItem.isChecked()) {
                cartHashOperations.delete(cartItem.getSkuId()+"");
            }
        }
        return true;
    }

    /**
     * 获取第一层，即某个用户的购物车
     */
    private BoundHashOperations getCartHashOperations() {
        Long userId = RequestUtils.getUserId();
        String cartKey = OmsConstants.CART_PREFIX + userId;
        BoundHashOperations operations = redisTemplate.boundHashOps(cartKey);
        return operations;
    }
}