Redis購物車

個(gè)人商城系統(tǒng)阴颖，后臺(tái)對(duì)購物車數(shù)據(jù)進(jìn)行“半持久化”掉盅。
因?yàn)橘徫镘囋鰟h改的操作很頻繁，如果使用mysql效率會(huì)很低泡嘴，
所以使用redis進(jìn)行存儲(chǔ)。如果擔(dān)心redis會(huì)掛逆济，可使用redis集群酌予，還是很靠譜的

配置文件 和redis連接池

參考上一篇redis進(jìn)行緩存
購物車redis緩存設(shè)置:
CartPrefix.class

public class CartPrefix extends BasePrefix{

    public CartPrefix(int expireSeconds, String prefix) {
        super(expireSeconds, prefix);
    }

    /**
     * 設(shè)置購物車緩存
     */
    public static CartPrefix getCartList= new CartPrefix(0,"cart");
}

購物車service層代碼：
CartService.class\

@Service
@Slf4j
public class CartServiceImpl implements CartService {
    @Autowired
    RedisService redisService;

    @Autowired
    ProductInfoDao productInfoDao;

    @Override
    public int addCart(String userId, String productId, int num) {
        //key為 userId_cart,校驗(yàn)是否已存在
        Boolean exists = redisService.existsValue(CartPrefix.getCartList,userId,productId);
        if (exists){
            //獲取現(xiàn)有的購物車中的數(shù)據(jù)
            String json = redisService.hget(CartPrefix.getCartList,userId,productId);
            if (json !=null){
                //轉(zhuǎn)換為java實(shí)體類
                CartDto cartDto = JSON.toJavaObject(JSONObject.parseObject(json),CartDto.class);
                cartDto.setProductNum(cartDto.getProductNum()+num);
                redisService.hset(CartPrefix.getCartList,userId,productId,JSON.toJSON(cartDto).toString());
            }else {
                return 0;
            }
            return 1;
        }
        //根據(jù)商品id獲取商品
        ProductInfo productInfo = productInfoDao.findProductById(productId);
        if (productInfo==null){
            return 0;
        }
        //設(shè)置購物車值
        CartDto cartDto = new CartDto();
        cartDto.setProductId(productId);
        cartDto.setProductName(productInfo.getProductName());
        cartDto.setProductIcon(productInfo.getProductIcon());
        cartDto.setProductPrice(productInfo.getProductPrice());
        cartDto.setProductStatus(productInfo.getProductStatus());
        cartDto.setProductNum(num);
        cartDto.setCheck("1");
        redisService.hset(CartPrefix.getCartList,userId,productId,JSON.toJSON(cartDto).toString());
        return 1;
    }

    /**
     * 展示購物車
     * @param userId
     * @return
     */
    @Override
    public List<CartDto> getCartList(String userId) {
        List<String> jsonList = redisService.hvals(CartPrefix.getCartList,userId);
        List<CartDto> cartDtoList = new LinkedList<>();
        for (String json:jsonList){
            CartDto cartDto = JSON.toJavaObject(JSONObject.parseObject(json),CartDto.class);
            cartDtoList.add(cartDto);
        }
        return cartDtoList;
    }

    /**
     * 更新數(shù)量
     * @param userId
     * @param productId
     * @param num
     * @return
     */
    @Override
    public int updateCartNum(String userId, String productId, int num) {
        String json = redisService.hget(CartPrefix.getCartList,userId,productId);
        if (json==null){
            return 0;
        }
        CartDto cartDto = JSON.toJavaObject(JSONObject.parseObject(json),CartDto.class);
        cartDto.setProductNum(num);
        redisService.hset(CartPrefix.getCartList,userId,productId,JSON.toJSON(cartDto).toString());
        return 1;
    }

    /**
     * 全選商品
     * @param userId
     * @param checked
     * @return
     */
    @Override
    public int checkAll(String userId, String checked) {
        //獲取商品列表
        List<String> jsonList = redisService.hvals(CartPrefix.getCartList,userId);
        for (String json:jsonList){
            CartDto cartDto = JSON.toJavaObject(JSONObject.parseObject(json),CartDto.class);
            if ("true".equals(checked)){
                cartDto.setCheck("1");
            }else if ("false".equals(checked)){
                cartDto.setCheck("0");
            }else {
                return 0;
            }
            redisService.hset(CartPrefix.getCartList,userId,cartDto.getProductId(),JSON.toJSON(cartDto).toString());
        }
        return 1;
    }

    /**
     * 刪除商品
     * @param userId
     * @param productId
     * @return
     */
    @Override
    public int delCartProduct(String userId, String productId) {
        redisService.hdel(CartPrefix.getCartList,userId,productId);
        return 1;
    }

    /**
     * 清空購物車
     * @param userId
     * @return
     */
    @Override
    public int delCart(String userId) {
        redisService.delete(CartPrefix.getCartList,userId);
        return 1;
    }
}

購物車接口實(shí)現(xiàn)：
CartController.class

@RestController
@RequestMapping("/cart")
@Slf4j
public class CartController {
    @Autowired
    CartService cartService;

    /**
     * 加入購物車
     * @param reqMap
     * @param user
     * @return
     */
    @PostMapping(value = "/add")
    @Autorization
    public Object addCart(@RequestBody Map<String, Object> reqMap, @CurrentUser User user){
        //獲取登陸用戶的userId
        String userId = RequestUtil.getMapString(user.getId());
        String productId = RequestUtil.getMapString(reqMap.get("product_id").toString());
        String numString = RequestUtil.getMapString(reqMap.get("product_num").toString());
        Integer num = Integer.parseInt(numString);
        //加入購物車
        int effectNum = cartService.addCart(userId,productId,num);
        if (effectNum<=0){
            return ResultUtil.fail(ResultEnum.ADD_CART_ERROR);
        }
        return ResultUtil.ok(ResultEnum.ADD_CART_SUCCESS.getMessage());
    }

    @GetMapping(value = "/getCartList")
    @Autorization
    public Object getCartList(@CurrentUser User user){
        String userId = RequestUtil.getMapString(user.getId());
        List<CartDto> cartDtoList = cartService.getCartList(userId);
        return ResultUtil.ok(cartDtoList);
    }

    @PostMapping(value = "/updateCartNum")
    @Autorization
    public Object updateCartNum(@RequestBody Map<String,Object> reqMap,@CurrentUser User user){
        String userId = RequestUtil.getMapString(user.getId());
        String productId = RequestUtil.getMapString(reqMap.get("product_id").toString());
        String numString = RequestUtil.getMapString(reqMap.get("product_num").toString());
        Integer num = Integer.parseInt(numString);

        int effectNum = cartService.updateCartNum(userId,productId,num);
        if (effectNum <=0){
            return ResultUtil.fail();
        }
        return ResultUtil.ok();
    }

    @PostMapping(value = "/checkAll")
    @Autorization
    public Object checkAll(@RequestBody Map<String,Object> reqMap,@CurrentUser User user){
        String userId = RequestUtil.getMapString(user.getId());
        String check = RequestUtil.getMapString(reqMap.get("check").toString());

        int effectNum = cartService.checkAll(userId,check);
        if (effectNum <=0){
            return ResultUtil.fail();
        }
        return ResultUtil.ok();
    }

    @PostMapping("/delCartProduct")
    @Autorization
    public Object delCartProduct(@RequestBody Map<String,Object> reqMap,@CurrentUser User user){
        String userId = RequestUtil.getMapString(user.getId());
        String productId = RequestUtil.getMapString(reqMap.get("product_id").toString());

        int effectNum = cartService.delCartProduct(userId,productId);
        if (effectNum <=0){
            return ResultUtil.fail();
        }
        return ResultUtil.ok();
    }

    @PostMapping("/delCart")
    @Autorization
    public Object delCart(@CurrentUser User user){
        String userId = RequestUtil.getMapString(user.getId());

        int effectNum = cartService.delCart(userId);
        if (effectNum <=0){
            return ResultUtil.fail();
        }
        return ResultUtil.ok();
    }

}

商城項(xiàng)目地址 https://github.com/627886474/sneaker