前台调用controller的各个方法注释写的都很清楚了 ,数据存储的话如果没登陆的话,存入到cookie当中,如果登录成功的状态话,存入redis当中,数据类型使用hash,因为如果购物车里数据多的话,每次修改购物车都得把所有信息都查出来这样影响redis的性能,因为redis是单线程的,频完的使用无所谓但是一个key里存的value值过大就会影响性能,所以使用hash,key使用用户名存,value的key是商品的id这样修改哪个商品的信息的话直接修改就可以了
package cn.e3mall.cart.controller;
import java.util.ArrayList;
import java.util.List;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import cn.e3mall.cart.service.CartService;
import cn.e3mall.common.utils.CookieUtils;
import cn.e3mall.common.utils.E3Result;
import cn.e3mall.common.utils.JsonUtils;
import cn.e3mall.pojo.TbItem;
import cn.e3mall.pojo.TbUser;
import cn.e3mall.service.ItemService;
/**
* 购物车处理Controller
* <p>Title: CartController</p>
* <p>Description: </p>
* <p>Company: www.itcast.cn</p>
* @version 1.0
*/
@Controller
public class CartController {
@Value("${COOKIE_CART_EXPIRE}")
private Integer COOKIE_CART_EXPIRE;
@Autowired
private ItemService itemService;
@Autowired
private CartService cartService;
//添加一个商品调用的方法
@RequestMapping("/cart/add/{itemId}")
public String addCart(@PathVariable Long itemId, @RequestParam(defaultValue="1")Integer num,
HttpServletRequest request, HttpServletResponse response) {
//判断用户是否登录
TbUser user = (TbUser) request.getAttribute("user");
//如果是登录状态,把购物车写入redis
if (user != null) {
//保存到服务端
cartService.addCart(user.getId(), itemId, num);
//返回逻辑视图
return "cartSuccess";
}
//如果未登录使用cookie
//从cookie中取购物车列表
List<TbItem> cartList = getCartListFromCookie(request);
//判断商品在商品列表中是否存在
boolean flag = false;
for (TbItem tbItem : cartList) {
//如果存在数量相加
if (tbItem.getId() == itemId.longValue()) {
flag = true;
//找到商品,数量相加
tbItem.setNum(tbItem.getNum() + num);
//跳出循环
break;
}
}
//如果不存在
if (!flag) {
//根据商品id查询商品信息。得到一个TbItem对象
TbItem tbItem = itemService.getItemById(itemId);
//设置商品数量
tbItem.setNum(num);
//取一张图片
String image = tbItem.getImage();
if (StringUtils.isNotBlank(image)) {
tbItem.setImage(image.split(",")[0]);
}
//把商品添加到商品列表
cartList.add(tbItem);
}
//写入cookie
CookieUtils.setCookie(request, response, "cart", JsonUtils.objectToJson(cartList), COOKIE_CART_EXPIRE, true);
//返回添加成功页面
return "cartSuccess";
}
/**
* 从cookie中取购物车列表的处理
* <p>Title: getCartListFromCookie</p>
* <p>Description: </p>
* @param request
* @return
*/
private List<TbItem> getCartListFromCookie(HttpServletRequest request) {
String json = CookieUtils.getCookieValue(request, "cart", true);
//判断json是否为空
if (StringUtils.isBlank(json)) {
return new ArrayList<>();
}
//把json转换成商品列表
List<TbItem> list = JsonUtils.jsonToList(json, TbItem.class);
return list;
}
/**
* 展示购物车列表
* <p>Title: showCatList</p>
* <p>Description: </p>
* @param request
* @return
*/
@RequestMapping("/cart/cart")
public String showCatList(HttpServletRequest request, HttpServletResponse response) {
//从cookie中取购物车列表
List<TbItem> cartList = getCartListFromCookie(request);
//判断用户是否为登录状态
TbUser user = (TbUser) request.getAttribute("user");
//如果是登录状态
if (user != null) {
//从cookie中取购物车列表
//如果不为空,把cookie中的购物车商品和服务端的购物车商品合并。也就是商品相同数量相加,商品不同添加新的商品
cartService.mergeCart(user.getId(), cartList);
//把cookie中的购物车删除
CookieUtils.deleteCookie(request, response, "cart");
//从服务端取购物车列表
cartList = cartService.getCartList(user.getId());
}
//把列表传递给页面
request.setAttribute("cartList", cartList);
//返回逻辑视图
return "cart";
}
/**
* 更新购物车商品数量
*/
@RequestMapping("/cart/update/num/{itemId}/{num}")
@ResponseBody
public E3Result updateCartNum(@PathVariable Long itemId, @PathVariable Integer num
, HttpServletRequest request ,HttpServletResponse response) {
//判断用户是否为登录状态
TbUser user = (TbUser) request.getAttribute("user");
if (user != null) {
cartService.updateCartNum(user.getId(), itemId, num);
return E3Result.ok();
}
//从cookie中取购物车列表
List<TbItem> cartList = getCartListFromCookie(request);
//遍历商品列表找到对应的商品
for (TbItem tbItem : cartList) {
if (tbItem.getId().longValue() == itemId) {
//更新数量
tbItem.setNum(num);
break;
}
}
//把购物车列表写回cookie
CookieUtils.setCookie(request, response, "cart", JsonUtils.objectToJson(cartList), COOKIE_CART_EXPIRE, true);
//返回成功
return E3Result.ok();
}
/**
* 删除购物车商品
*/
@RequestMapping("/cart/delete/{itemId}")
public String deleteCartItem(@PathVariable Long itemId, HttpServletRequest request,
HttpServletResponse response) {
//判断用户是否为登录状态
TbUser user = (TbUser) request.getAttribute("user");
if (user != null) {
cartService.deleteCartItem(user.getId(), itemId);
return "redirect:/cart/cart.html";
}
//从cookie中取购物车列表
List<TbItem> cartList = getCartListFromCookie(request);
//遍历列表,找到要删除的商品
for (TbItem tbItem : cartList) {
if (tbItem.getId().longValue() == itemId) {
//删除商品
cartList.remove(tbItem);
//跳出循环
break;
}
}
//把购物车列表写入cookie
CookieUtils.setCookie(request, response, "cart", JsonUtils.objectToJson(cartList), COOKIE_CART_EXPIRE, true);
//返回逻辑视图
return "redirect:/cart/cart.html";
}
}
动态参数
json工具类
package cn.e3mall.common.utils;
import java.util.List;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.JavaType;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
/**
* 淘淘商城自定义响应结构
*/
public class JsonUtils {
// 定义jackson对象
private static final ObjectMapper MAPPER = new ObjectMapper();
/**
* 将对象转换成json字符串。
* <p>Title: pojoToJson</p>
* <p>Description: </p>
* @param data
* @return
*/
public static String objectToJson(Object data) {
try {
String string = MAPPER.writeValueAsString(data);
return string;
} catch (JsonProcessingException e) {
e.printStackTrace();
}
return null;
}
/**
* 将json结果集转化为对象
*
* @param jsonData json数据
* @param clazz 对象中的object类型
* @return
*/
public static <T> T jsonToPojo(String jsonData, Class<T> beanType) {
try {
T t = MAPPER.readValue(jsonData, beanType);
return t;
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/**
* 将json数据转换成pojo对象list
* <p>Title: jsonToList</p>
* <p>Description: </p>
* @param jsonData
* @param beanType
* @return
*/
public static <T>List<T> jsonToList(String jsonData, Class<T> beanType) {
JavaType javaType = MAPPER.getTypeFactory().constructParametricType(List.class, beanType);
try {
List<T> list = MAPPER.readValue(jsonData, javaType);
return list;
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
}
cookie工具类
package cn.e3mall.common.utils;
import java.io.UnsupportedEncodingException;
import java.net.URLDecoder;
import java.net.URLEncoder;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
/**
*
* Cookie 工具类
*
*/
public final class CookieUtils {
/**
* 得到Cookie的值, 不编码
*
* @param request
* @param cookieName
* @return
*/
public static String getCookieValue(HttpServletRequest request, String cookieName) {
return getCookieValue(request, cookieName, false);
}
/**
* 得到Cookie的值,
*
* @param request
* @param cookieName
* @return
*/
public static String getCookieValue(HttpServletRequest request, String cookieName, boolean isDecoder) {
Cookie[] cookieList = request.getCookies();
if (cookieList == null || cookieName == null) {
return null;
}
String retValue = null;
try {
for (int i = 0; i < cookieList.length; i++) {
if (cookieList[i].getName().equals(cookieName)) {
if (isDecoder) {
retValue = URLDecoder.decode(cookieList[i].getValue(), "UTF-8");
} else {
retValue = cookieList[i].getValue();
}
break;
}
}
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
return retValue;
}
/**
* 得到Cookie的值,
*
* @param request
* @param cookieName
* @return
*/
public static String getCookieValue(HttpServletRequest request, String cookieName, String encodeString) {
Cookie[] cookieList = request.getCookies();
if (cookieList == null || cookieName == null) {
return null;
}
String retValue = null;
try {
for (int i = 0; i < cookieList.length; i++) {
if (cookieList[i].getName().equals(cookieName)) {
retValue = URLDecoder.decode(cookieList[i].getValue(), encodeString);
break;
}
}
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
return retValue;
}
/**
* 设置Cookie的值 不设置生效时间默认浏览器关闭即失效,也不编码
*/
public static void setCookie(HttpServletRequest request, HttpServletResponse response, String cookieName,
String cookieValue) {
setCookie(request, response, cookieName, cookieValue, -1);
}
/**
* 设置Cookie的值 在指定时间内生效,但不编码
*/
public static void setCookie(HttpServletRequest request, HttpServletResponse response, String cookieName,
String cookieValue, int cookieMaxage) {
setCookie(request, response, cookieName, cookieValue, cookieMaxage, false);
}
/**
* 设置Cookie的值 不设置生效时间,但编码
*/
public static void setCookie(HttpServletRequest request, HttpServletResponse response, String cookieName,
String cookieValue, boolean isEncode) {
setCookie(request, response, cookieName, cookieValue, -1, isEncode);
}
/**
* 设置Cookie的值 在指定时间内生效, 编码参数
*/
public static void setCookie(HttpServletRequest request, HttpServletResponse response, String cookieName,
String cookieValue, int cookieMaxage, boolean isEncode) {
doSetCookie(request, response, cookieName, cookieValue, cookieMaxage, isEncode);
}
/**
* 设置Cookie的值 在指定时间内生效, 编码参数(指定编码)
*/
public static void setCookie(HttpServletRequest request, HttpServletResponse response, String cookieName,
String cookieValue, int cookieMaxage, String encodeString) {
doSetCookie(request, response, cookieName, cookieValue, cookieMaxage, encodeString);
}
/**
* 删除Cookie带cookie域名
*/
public static void deleteCookie(HttpServletRequest request, HttpServletResponse response,
String cookieName) {
doSetCookie(request, response, cookieName, "", -1, false);
}
/**
* 设置Cookie的值,并使其在指定时间内生效
*
* @param cookieMaxage cookie生效的最大秒数
*/
private static final void doSetCookie(HttpServletRequest request, HttpServletResponse response,
String cookieName, String cookieValue, int cookieMaxage, boolean isEncode) {
try {
if (cookieValue == null) {
cookieValue = "";
} else if (isEncode) {
cookieValue = URLEncoder.encode(cookieValue, "utf-8");
}
Cookie cookie = new Cookie(cookieName, cookieValue);
if (cookieMaxage > 0)
cookie.setMaxAge(cookieMaxage);
if (null != request) {// 设置域名的cookie
String domainName = getDomainName(request);
System.out.println(domainName);
if (!"localhost".equals(domainName)) {
cookie.setDomain(domainName);
}
}
cookie.setPath("/");
response.addCookie(cookie);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 设置Cookie的值,并使其在指定时间内生效
*
* @param cookieMaxage cookie生效的最大秒数
*/
private static final void doSetCookie(HttpServletRequest request, HttpServletResponse response,
String cookieName, String cookieValue, int cookieMaxage, String encodeString) {
try {
if (cookieValue == null) {
cookieValue = "";
} else {
cookieValue = URLEncoder.encode(cookieValue, encodeString);
}
Cookie cookie = new Cookie(cookieName, cookieValue);
if (cookieMaxage > 0)
cookie.setMaxAge(cookieMaxage);
if (null != request) {// 设置域名的cookie
String domainName = getDomainName(request);
System.out.println(domainName);
if (!"localhost".equals(domainName)) {
cookie.setDomain(domainName);
}
}
cookie.setPath("/");
response.addCookie(cookie);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 得到cookie的域名
*/
private static final String getDomainName(HttpServletRequest request) {
String domainName = null;
String serverName = request.getRequestURL().toString();
if (serverName == null || serverName.equals("")) {
domainName = "";
} else {
serverName = serverName.toLowerCase();
serverName = serverName.substring(7);
final int end = serverName.indexOf("/");
serverName = serverName.substring(0, end);
final String[] domains = serverName.split("\\.");
int len = domains.length;
if (len > 3) {
// www.xxx.com.cn
domainName = "." + domains[len - 3] + "." + domains[len - 2] + "." + domains[len - 1];
} else if (len <= 3 && len > 1) {
// xxx.com or xxx.cn
domainName = "." + domains[len - 2] + "." + domains[len - 1];
} else {
domainName = serverName;
}
}
if (domainName != null && domainName.indexOf(":") > 0) {
String[] ary = domainName.split("\\:");
domainName = ary[0];
}
return domainName;
}
}
自定义拦截器,实现判断用户是否登录状态
package cn.e3mall.cart.interceptor;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.servlet.HandlerInterceptor;
import org.springframework.web.servlet.ModelAndView;
import cn.e3mall.common.utils.CookieUtils;
import cn.e3mall.common.utils.E3Result;
import cn.e3mall.pojo.TbUser;
import cn.e3mall.sso.service.TokenService;
/**
* 用户登录处理拦截器
* <p>Title: LoginInterceptor</p>
* <p>Description: </p>
* <p>Company: www.itcast.cn</p>
* @version 1.0
*/
public class LoginInterceptor implements HandlerInterceptor {
@Autowired
private TokenService tokenService;
@Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
// 前处理,执行handler之前执行此方法。
//返回true,放行 false:拦截
//1.从cookie中取token
String token = CookieUtils.getCookieValue(request, "token");
//2.如果没有token,未登录状态,直接放行
if (StringUtils.isBlank(token)) {
return true;
}
//3.取到token,需要调用sso系统的服务,根据token取用户信息
E3Result e3Result = tokenService.getUserByToken(token);
//4.没有取到用户信息。登录过期,直接放行。
if (e3Result.getStatus() != 200) {
return true;
}
//5.取到用户信息。登录状态。
TbUser user = (TbUser) e3Result.getData();
//6.把用户信息放到request中。只需要在Controller中判断request中是否包含user信息。放行
request.setAttribute("user", user);
return true;
}
@Override
public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView)
throws Exception {
//handler执行之后,返回ModeAndView之前
}
@Override
public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex)
throws Exception {
//完成处理,返回ModelAndView之后。
//可以再此处理异常
}
}
登录状态下对购物车的增删改
package cn.e3mall.cart.service.impl;
import java.util.ArrayList;
import java.util.List;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import cn.e3mall.cart.service.CartService;
import cn.e3mall.common.jedis.JedisClient;
import cn.e3mall.common.utils.E3Result;
import cn.e3mall.common.utils.JsonUtils;
import cn.e3mall.mapper.TbItemMapper;
import cn.e3mall.pojo.TbItem;
/**
* 购物车处理服务
* <p>Title: CartServiceImpl</p>
* <p>Description: </p>
* <p>Company: www.itcast.cn</p>
* @version 1.0
*/
@Service
public class CartServiceImpl implements CartService {
@Autowired
private JedisClient jedisClient;
@Value("${REDIS_CART_PRE}")
private String REDIS_CART_PRE;
@Autowired
private TbItemMapper itemMapper;
@Override
public E3Result addCart(long userId, long itemId, int num) {
//向redis中添加购物车。
//数据类型是hash key:用户id field:商品id value:商品信息
//判断商品是否存在
Boolean hexists = jedisClient.hexists(REDIS_CART_PRE + ":" + userId, itemId + "");
//如果存在数量相加
if (hexists) {
String json = jedisClient.hget(REDIS_CART_PRE + ":" + userId, itemId + "");
//把json转换成TbItem
TbItem item = JsonUtils.jsonToPojo(json, TbItem.class);
item.setNum(item.getNum() + num);
//写回redis
jedisClient.hset(REDIS_CART_PRE + ":" + userId, itemId + "", JsonUtils.objectToJson(item));
return E3Result.ok();
}
//如果不存在,根据商品id取商品信息
TbItem item = itemMapper.selectByPrimaryKey(itemId);
//设置购物车数据量
item.setNum(num);
//取一张图片
String image = item.getImage();
if (StringUtils.isNotBlank(image)) {
item.setImage(image.split(",")[0]);
}
//添加到购物车列表
jedisClient.hset(REDIS_CART_PRE + ":" + userId, itemId + "", JsonUtils.objectToJson(item));
return E3Result.ok();
}
@Override
public E3Result mergeCart(long userId, List<TbItem> itemList) {
//遍历商品列表
//把列表添加到购物车。
//判断购物车中是否有此商品
//如果有,数量相加
//如果没有添加新的商品
for (TbItem tbItem : itemList) {
addCart(userId, tbItem.getId(), tbItem.getNum());
}
//返回成功
return E3Result.ok();
}
@Override
public List<TbItem> getCartList(long userId) {
//根据用户id查询购车列表
List<String> jsonList = jedisClient.hvals(REDIS_CART_PRE + ":" + userId);
List<TbItem> itemList = new ArrayList<>();
for (String string : jsonList) {
//创建一个TbItem对象
TbItem item = JsonUtils.jsonToPojo(string, TbItem.class);
//添加到列表
itemList.add(item);
}
return itemList;
}
@Override
public E3Result updateCartNum(long userId, long itemId, int num) {
//从redis中取商品信息
String json = jedisClient.hget(REDIS_CART_PRE + ":" + userId, itemId + "");
//更新商品数量
TbItem tbItem = JsonUtils.jsonToPojo(json, TbItem.class);
tbItem.setNum(num);
//写入redis
jedisClient.hset(REDIS_CART_PRE + ":" + userId, itemId + "", JsonUtils.objectToJson(tbItem));
return E3Result.ok();
}
@Override
public E3Result deleteCartItem(long userId, long itemId) {
// 删除购物车商品
jedisClient.hdel(REDIS_CART_PRE + ":" + userId, itemId + "");
return E3Result.ok();
}
}