电商项目（二十一）购物车（登陆情况下）

梦里梦外; 2023-07-17 06:29 137阅读 0赞

# 一、用户登录状态下的购物车操作 #

## 1. 将商品添加到购物车 ##

### 1.1 在common\_redis服务中实现缓存购物车信息 ###

在common\_redis模块，新增CartController，新增方法：将购物车的信息缓存到redis，方法的参数:@RequestBody Map<String,Object> map，方法的返回值：void

在业务层中实现将商品添加到缓存中  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70]

### 1.2 在common\_redis服务中实现查询购物车信息 ###

在common\_redis模块，新增CartController，新增方法：根据用户ID查询购物车，方法的参数:@RequestParam String userId，方法的返回值：Map<String ,CartItem >

在业务层中实现查询购物车  
![在这里插入图片描述][20200320100654151.png]

### 1.3 在frontend\_cart服务中实现用户在登陆状态下向购物车添加商品 ###

在CartController中，在用户已经登录的情况下，  
在业务层层中，方法的参数：Long itemId，Integer num，String userId，返回值： Result  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 1]  
流程：  
第一，查询商品  
定义方法，查询商品  
![在这里插入图片描述][20200320101447649.png]  
第二，获取购物车（根据用户的id）  
定义方法，获取购物车  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 2]

第三，将商品加入购物车  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 3]

第四，将购物车信息保存到Redis中  
![在这里插入图片描述][20200320101543909.png]

### 1.4 在frontend\_cart服务中实现用户在登陆状态下向查看购物车商品 ###

在CartController中实现用户登录的情况下的购物车  
在业务层中RedisCartServiceImpl中，新增方法，查看购物车，![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 4]

### 1.5 在frontend\_cart服务中实现用户在登陆状态下购物车商品的数量修改 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 5]

### 1.6 在frontend\_cart服务中实现用户在登陆状态下购物车商品的删除 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 6]

### 1.7 在frontend\_sso模块实现用户登录业务实现购物车同步业务和删除 ###

将临时购物车的商品同步到永久购物车

/** * 用户注册与登录业务层 */
    @Service
    public class SSOServiceImpl implements SSOService { 
    
        @Autowired
        private TbUserMapper tbUserMapper;
    
        @Autowired
        private CommonRedisFeignClient commonRedisFeignClient;
    
    
        @Value("${cart_cookie_name}")
        private String cart_cookie_name;
    
        /** * 对用户的注册信息(用户名与电话号码)做数据校验 */
        @Override
        public Result checkUserInfo(String checkValue, Integer checkFlag) { 
            TbUserExample example =new TbUserExample();
            TbUserExample.Criteria criteria = example.createCriteria();
            if(checkFlag == 1){ 
                criteria.andUsernameEqualTo(checkValue);
            }else if(checkFlag == 2){ 
                criteria.andPhoneEqualTo(checkValue);
            }
            Integer rows = this.tbUserMapper.countByExample(example);
            if(rows > 0){ 
                return Result.error("数据不可用");
            }
            return Result.ok(checkValue);
        }
    
        /** * 用户注册 */
        @Override
        @LcnTransaction
        public Result userRegister(TbUser user) { 
            //将密码做加密处理。
            String pwd = MD5Utils.digest(user.getPassword());
            user.setPassword(pwd);
            //补齐数据
            user.setCreated(new Date());
            user.setUpdated(new Date());
            this.tbUserMapper.insert(user);
            return Result.ok();
        }
    
        /** * 用户登录 * @param username * @param password * @return */
        @Override
        public Result userLogin(String username, String password,HttpServletRequest request,HttpServletResponse response) { 
            //根据用户名密码查询数据库
            TbUser tbUser = this.login(username,password);
            if(tbUser == null){ 
                return Result.error("用户名或密码有误，请重新输入");
            }
            //将用户添加到Redis中
            String userToken = UUID.randomUUID().toString();
            Integer flag = this.insertUserToRedis(tbUser,userToken);
            if(flag == 500){ 
                return Result.error("登录失败");
            }
            Map<String,String> map = new HashMap<>();
            map.put("token",userToken);
            map.put("userid",tbUser.getId().toString());
            map.put("username",tbUser.getUsername());
    
            //将临时购物车中的商品同步到永久购物车中
            this.syncCart(tbUser.getId().toString(),request);
            //同步购物车成功后，需要将临时购物车中的商品删除掉
            this.deleteCookieCart(request,response);
            return Result.ok(map);
        }
    
        /** * 同步购物车 */
        private void syncCart(String userId,HttpServletRequest request){ 
            //获取临时购物车
            Map<String,CartItem> cookieCart = this.getCart(request);
            //获取永久购物车
            Map<String,CartItem> redisCart = this.getCart(userId);
            //删除永久购物车中所包含临时购物车中的商品
            Set<String> keys = cookieCart.keySet();
            for(String key:keys){ 
                redisCart.remove(key);
            }
            //将同步后的购物车缓存到redis中
            redisCart.putAll(cookieCart);
            //将永久购物车重新缓存到redis中
            this.addCartToRedis(userId,redisCart);
        }
        /** * 获取临时购物车 */
        private Map<String,CartItem> getCart(HttpServletRequest request){ 
            //临时购物车已存在
            String cartJson= CookieUtils.getCookieValue(request,this.cart_cookie_name,true);
            if(StringUtils.isBlank(cartJson)){ 
                //临时购物车不存在
                return new HashMap<String,CartItem>();
            }
            try{ 
                //如果含有临时购物车，那么需要做json转换
                Map<String,CartItem> map = JsonUtils.jsonToMap(cartJson,CartItem.class);
                return map;
            }catch(Exception e){ 
                e.printStackTrace();
            }
            return new HashMap<String,CartItem>();
        }
        /** * 获取永久购物车 */
        private Map<String,CartItem> getCart(String userId){ 
            try{ 
                Map<String,CartItem> cart = this.commonRedisFeignClient.selectCartByUserId(userId);
                if(cart == null){ 
                    cart = new HashMap<String,CartItem>();
                }
                return cart;
            }catch(Exception e){ 
                e.printStackTrace();
            }
            return new HashMap<String,CartItem>();
        }
    
        /** * 将永久购物车重新缓存到redis中 */
        private void addCartToRedis(String userId,Map<String,CartItem> cart){ 
            Map<String,Object> map = new HashMap<>();
            map.put("userId",userId);
            map.put("cart",cart);
            this.commonRedisFeignClient.insertCart(map);
        }
    
        /** * 用户登录业务处理 */
        private TbUser login(String username,String password){ 
            String pwd = MD5Utils.digest(password);
            TbUserExample example = new TbUserExample();
            TbUserExample.Criteria criteria = example.createCriteria();
            criteria.andUsernameEqualTo(username);
            criteria.andPasswordEqualTo(pwd);
            List<TbUser> list = this.tbUserMapper.selectByExample(example);
            if(list == null || list.size() <= 0){ 
                return null;
            }
            return list.get(0);
        }
        /** * 将用户添加到Redis中 */
        private Integer insertUserToRedis(TbUser tbUser,String userToken){ 
            try{ 
                this.commonRedisFeignClient.insertUser(tbUser,userToken);
                return 200;
            }catch(Exception e){ 
                e.printStackTrace();
            }
            return 500;
        }
    
       
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70]: /images/20230528/9d147e10fc9a4de2aa02cba4faca7d73.png
[20200320100654151.png]: /images/20230528/6750b802b6924fca9e7de6a2e096942b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 1]: /images/20230528/5859ed587b91495fa32e629088b91017.png
[20200320101447649.png]: /images/20230528/d1e5dae170e64c599e2dc0b8011e4339.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 2]: /images/20230528/0545961924264a9fa10a72e80cb3a6fb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 3]: /images/20230528/fb4098878596455b9a13f54e4cd17aae.png
[20200320101543909.png]: /images/20230528/a84efc8c790541e88084bfe6818a5649.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 4]: /images/20230528/54ac6d49dc3e4b07a354910be47c421c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 5]: /images/20230528/323fdb58a9ac469c97c1dbed3596fa7c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzY2NjA1MQ_size_16_color_FFFFFF_t_70 6]: /images/20230528/03c644b2a4f84ee686b5b60152bea2e8.png