image.png
image.png
image.png

1. 用户注册

1.1 用户名登录注册流程

image.png

1.2 邮箱注册流程

image.png

1.3 手机号注册

image.png

2.检验用户名是否存在

image.png
image.png

  1. <!-- apache 工具类 -->
  2.         <!-- 文件检测 -->
  3.         <!-- https://mvnrepository.com/artifact/org.apache.tika/tika-core -->
  4.         <dependency>
  5.             <groupId>org.apache.tika</groupId>
  6.             <artifactId>tika-core</artifactId>
  7.             <version>2.2.1</version>
  8.         </dependency>
  9.         <!-- https://mvnrepository.com/artifact/commons-codec/commons-codec -->
  10.         <dependency>
  11.             <groupId>commons-codec</groupId>
  12.             <artifactId>commons-codec</artifactId>
  13.             <version>1.15</version>
  14.         </dependency>
  15.         <!-- https://mvnrepository.com/artifact/org.apache.commons/commons-lang3 -->
  16.         <dependency>
  17.             <groupId>org.apache.commons</groupId>
  18.             <artifactId>commons-lang3</artifactId>
  19.             <version>3.12.0</version>
  20.         </dependency>
  21.         <!-- https://mvnrepository.com/artifact/commons-io/commons-io -->
  22.         <dependency>
  23.             <groupId>commons-io</groupId>
  24.             <artifactId>commons-io</artifactId>
  25.             <version>2.11.0</version>
  26.         </dependency>

image.png
运行测试
image.png

3. 状态码修改

image.png
image.png

4. 使用自定义响应数据类型

https://www.yuque.com/meishimokeqide/myi2rx/gahnvo/edit

image.png

5. 接受前端注册消息

我们统一将前端传过来的信息定义为xxxBO类
image.png
image.png

image.png
加密，设置时间，全局唯一id
image.png
image.png
image.png
image.png
image.png
https://www.yuque.com/meishimokeqide/myi2rx/iugpp7

6. 实现登录功能

image.png
image.png

7. 页面显示信息，使用Cookie

image.png

7.1 CookieUtils

  1. package com.lv.utils;
  3. import org.slf4j.Logger;
  4. import org.slf4j.LoggerFactory;
  6. import javax.servlet.http.Cookie;
  7. import javax.servlet.http.HttpServletRequest;
  8. import javax.servlet.http.HttpServletResponse;
  9. import java.io.UnsupportedEncodingException;
  10. import java.net.URLDecoder;
  11. import java.net.URLEncoder;
  14. /**
  15.  * 
  16.  * @Title: CookieUtils.java
  17.  * @Package com.lv.utils
  18.  * @Description: Cookie 工具类
  19.  * Copyright: Copyright (c)
  20.  * Company: www.lv.com
  21.  *
  22.  * @author imooc
  23.  * @version V1.0
  24.  */
  25. public final class 
  26. {
  28.     final static Logger logger = LoggerFactory.getLogger(CookieUtils.class);
  30.     /**
  31.      * 
  32.      * @Description: 得到Cookie的值, 不编码
  33.      * @param request
  34.      * @param cookieName
  35.      * @return
  36.      */
  37.     public static String getCookieValue(HttpServletRequest request, String cookieName) {
  38.         return getCookieValue(request, cookieName, false);
  39.     }
  41.     /**
  42.      * 
  43.      * @Description: 得到Cookie的值
  44.      * @param request
  45.      * @param cookieName
  46.      * @param isDecoder
  47.      * @return
  48.      */
  49.     public static String getCookieValue(HttpServletRequest request, String cookieName, boolean isDecoder) {
  50.         Cookie[] cookieList = request.getCookies();
  51.         if (cookieList == null || cookieName == null) {
  52.             return null;
  53.         }
  54.         String retValue = null;
  55.         try {
  56.             for (int i = 0; i < cookieList.length; i++) {
  57.                 if (cookieList[i].getName().equals(cookieName)) {
  58.                     if (isDecoder) {
  59.                         retValue = URLDecoder.decode(cookieList[i].getValue(), "UTF-8");
  60.                     } else {
  61.                         retValue = cookieList[i].getValue();
  62.                     }
  63.                     break;
  64.                 }
  65.             }
  66.         } catch (UnsupportedEncodingException e) {
  67.             e.printStackTrace();
  68.         }
  69.         return retValue;
  70.     }
  72.     /**
  73.      * 
  74.      * @Description: 得到Cookie的值
  75.      * @param request
  76.      * @param cookieName
  77.      * @param encodeString
  78.      * @return
  79.      */
  80.     public static String getCookieValue(HttpServletRequest request, String cookieName, String encodeString) {
  81.         Cookie[] cookieList = request.getCookies();
  82.         if (cookieList == null || cookieName == null) {
  83.             return null;
  84.         }
  85.         String retValue = null;
  86.         try {
  87.             for (int i = 0; i < cookieList.length; i++) {
  88.                 if (cookieList[i].getName().equals(cookieName)) {
  89.                     retValue = URLDecoder.decode(cookieList[i].getValue(), encodeString);
  90.                     break;
  91.                 }
  92.             }
  93.         } catch (UnsupportedEncodingException e) {
  94.              e.printStackTrace();
  95.         }
  96.         return retValue;
  97.     }
  99.     /**
  100.      * 
  101.      * @Description: 设置Cookie的值 不设置生效时间默认浏览器关闭即失效,也不编码
  102.      * @param request
  103.      * @param response
  104.      * @param cookieName
  105.      * @param cookieValue
  106.      */
  107.     public static void setCookie(HttpServletRequest request, HttpServletResponse response, String cookieName,
  108.             String cookieValue) {
  109.         setCookie(request, response, cookieName, cookieValue, -1);
  110.     }
  112.     /**
  113.      * 
  114.      * @Description: 设置Cookie的值 在指定时间内生效,但不编码
  115.      * @param request
  116.      * @param response
  117.      * @param cookieName
  118.      * @param cookieValue
  119.      * @param cookieMaxage
  120.      */
  121.     public static void setCookie(HttpServletRequest request, HttpServletResponse response, String cookieName,
  122.             String cookieValue, int cookieMaxage) {
  123.         setCookie(request, response, cookieName, cookieValue, cookieMaxage, false);
  124.     }
  126.     /**
  127.      * 
  128.      * @Description: 设置Cookie的值 不设置生效时间,但编码
  129.      * 在服务器被创建，返回给客户端，并且保存客户端
  130.      * 如果设置了SETMAXAGE(int seconds)，会把cookie保存在客户端的硬盘中
  131.      * 如果没有设置，会默认把cookie保存在浏览器的内存中
  132.      * 一旦设置setPath()：只能通过设置的路径才能获取到当前的cookie信息
  133.      * @param request
  134.      * @param response
  135.      * @param cookieName
  136.      * @param cookieValue
  137.      * @param isEncode
  138.      */
  139.     public static void setCookie(HttpServletRequest request, HttpServletResponse response, String cookieName,
  140.             String cookieValue, boolean isEncode) {
  141.         setCookie(request, response, cookieName, cookieValue, -1, isEncode);
  142.     }
  144.    /**
  145.     * 
  146.     * @Description: 设置Cookie的值 在指定时间内生效, 编码参数
  147.     * @param request
  148.     * @param response
  149.     * @param cookieName
  150.     * @param cookieValue
  151.     * @param cookieMaxage
  152.     * @param isEncode
  153.     */
  154.     public static void setCookie(HttpServletRequest request, HttpServletResponse response, String cookieName,
  155.             String cookieValue, int cookieMaxage, boolean isEncode) {
  156.         doSetCookie(request, response, cookieName, cookieValue, cookieMaxage, isEncode);
  157.     }
  159.     /**
  160.      * 
  161.      * @Description: 设置Cookie的值 在指定时间内生效, 编码参数(指定编码)
  162.      * @param request
  163.      * @param response
  164.      * @param cookieName
  165.      * @param cookieValue
  166.      * @param cookieMaxage
  167.      * @param encodeString
  168.      */
  169.     public static void setCookie(HttpServletRequest request, HttpServletResponse response, String cookieName,
  170.             String cookieValue, int cookieMaxage, String encodeString) {
  171.         doSetCookie(request, response, cookieName, cookieValue, cookieMaxage, encodeString);
  172.     }
  174.     /**
  175.      * 
  176.      * @Description: 删除Cookie带cookie域名
  177.      * @param request
  178.      * @param response
  179.      * @param cookieName
  180.      */
  181.     public static void deleteCookie(HttpServletRequest request, HttpServletResponse response,
  182.             String cookieName) {
  183.         doSetCookie(request, response, cookieName, null, -1, false);
  184. //        doSetCookie(request, response, cookieName, "", -1, false);
  185.     }
  188.     /**
  189.      * 
  190.      * @Description: 设置Cookie的值，并使其在指定时间内生效
  191.      * @param request
  192.      * @param response
  193.      * @param cookieName
  194.      * @param cookieValue
  195.      * @param cookieMaxage    cookie生效的最大秒数
  196.      * @param isEncode
  197.      */
  198.     private static final void doSetCookie(HttpServletRequest request, HttpServletResponse response,
  199.             String cookieName, String cookieValue, int cookieMaxage, boolean isEncode) {
  200.         try {
  201.             if (cookieValue == null) {
  202.                 cookieValue = "";
  203.             } else if (isEncode) {
  204.                 cookieValue = URLEncoder.encode(cookieValue, "utf-8");
  205.             }
  206.             Cookie cookie = new Cookie(cookieName, cookieValue);
  207.             if (cookieMaxage > 0)
  208.                 cookie.setMaxAge(cookieMaxage);
  209.             if (null != request) {// 设置域名的cookie
  210.                 String domainName = getDomainName(request);
  211.                 logger.info("========== domainName: {} ==========", domainName);
  212.                 if (!"localhost".equals(domainName)) {
  213.                     cookie.setDomain(domainName);
  214.                 }
  215.             }
  216.             cookie.setPath("/");
  217.             response.addCookie(cookie);
  218.         } catch (Exception e) {
  219.              e.printStackTrace();
  220.         }
  221.     }
  223.     /**
  224.      * 
  225.      * @Description: 设置Cookie的值，并使其在指定时间内生效
  226.      * @param request
  227.      * @param response
  228.      * @param cookieName
  229.      * @param cookieValue
  230.      * @param cookieMaxage    cookie生效的最大秒数
  231.      * @param encodeString
  232.      */
  233.     private static final void doSetCookie(HttpServletRequest request, HttpServletResponse response,
  234.             String cookieName, String cookieValue, int cookieMaxage, String encodeString) {
  235.         try {
  236.             if (cookieValue == null) {
  237.                 cookieValue = "";
  238.             } else {
  239.                 cookieValue = URLEncoder.encode(cookieValue, encodeString);
  240.             }
  241.             Cookie cookie = new Cookie(cookieName, cookieValue);
  242.             if (cookieMaxage > 0)
  243.                 cookie.setMaxAge(cookieMaxage);
  244.             if (null != request) {// 设置域名的cookie
  245.                 String domainName = getDomainName(request);
  246.                 logger.info("========== domainName: {} ==========", domainName);
  247.                 if (!"localhost".equals(domainName)) {
  248.                     cookie.setDomain(domainName);
  249.                 }
  250.             }
  251.             cookie.setPath("/");
  252.             response.addCookie(cookie);
  253.         } catch (Exception e) {
  254.              e.printStackTrace();
  255.         }
  256.     }
  258.     /**
  259.      * 
  260.      * @Description: 得到cookie的域名
  261.      * @return
  262.      */
  263.     private static final String getDomainName(HttpServletRequest request) {
  264.         String domainName = null;
  266.         String serverName = request.getRequestURL().toString();
  267.         if (serverName == null || serverName.equals("")) {
  268.             domainName = "";
  269.         } else {
  270.             serverName = serverName.toLowerCase();
  271.             serverName = serverName.substring(7);
  272.             final int end = serverName.indexOf("/");
  273.             serverName = serverName.substring(0, end);
  274.             if (serverName.indexOf(":") > 0) {
  275.                 String[] ary = serverName.split("\\:");
  276.                 serverName = ary[0];
  277.             }
  279.             final String[] domains = serverName.split("\\.");
  280.             int len = domains.length;
  281.             if (len > 3 && !isIp(serverName)) {
  282.                 // www.xxx.com.cn
  283.                 domainName = "." + domains[len - 3] + "." + domains[len - 2] + "." + domains[len - 1];
  284.             } else if (len <= 3 && len > 1) {
  285.                 // xxx.com or xxx.cn
  286.                 domainName = "." + domains[len - 2] + "." + domains[len - 1];
  287.             } else {
  288.                 domainName = serverName;
  289.             }
  290.         }
  291.         return domainName;
  292.     }
  294.     public static String trimSpaces(String IP){//去掉IP字符串前后所有的空格  
  295.         while(IP.startsWith(" ")){  
  296.                IP= IP.substring(1,IP.length()).trim();  
  297.             }  
  298.         while(IP.endsWith(" ")){  
  299.                IP= IP.substring(0,IP.length()-1).trim();  
  300.             }  
  301.         return IP;  
  302.     }  
  304.     public static boolean isIp(String IP){//判断是否是一个IP  
  305.         boolean b = false;  
  306.         IP = trimSpaces(IP);  
  307.         if(IP.matches("\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}")){  
  308.             String s[] = IP.split("\\.");  
  309.             if(Integer.parseInt(s[0])<255)  
  310.                 if(Integer.parseInt(s[1])<255)  
  311.                     if(Integer.parseInt(s[2])<255)  
  312.                         if(Integer.parseInt(s[3])<255)  
  313.                             b = true;  
  314.         }  
  315.         return b;  
  316.     }  
  318. }

7.2 JsonUtils

  1. package com.lv.utils;
  3. import com.fasterxml.jackson.core.JsonProcessingException;
  4. import com.fasterxml.jackson.databind.JavaType;
  5. import com.fasterxml.jackson.databind.ObjectMapper;
  7. import java.util.List;
  9. /**
  10.  *
  11.  * @Title: JsonUtils.java
  12.  * @Package com.lv.utils
  13.  * @Description: json转换类
  14.  * Copyright: Copyright (c)
  15.  * Company: www.lv.com
  16.  *
  17.  * @author imooc
  18.  */
  19. public class JsonUtils {
  21.     // 定义jackson对象
  22.     private static final ObjectMapper MAPPER = new ObjectMapper();
  24.     /**
  25.      * 将对象转换成json字符串。
  26.      * @param data
  27.      * @return
  28.      */
  29.     public static String objectToJson(Object data) {
  30.         try {
  31.             return MAPPER.writeValueAsString(data);
  32.         } catch (JsonProcessingException e) {
  33.             e.printStackTrace();
  34.         }
  35.         return null;
  36.     }
  38.     /**
  39.      * 将json结果集转化为对象
  40.      *
  41.      * @param jsonData json数据
  42.      * @param beanType 对象中的object类型
  43.      * @return
  44.      */
  45.     public static <T> T jsonToPojo(String jsonData, Class<T> beanType) {
  46.         try {
  47.             T t = MAPPER.readValue(jsonData, beanType);
  48.             return t;
  49.         } catch (Exception e) {
  50.             e.printStackTrace();
  51.         }
  52.         return null;
  53.     }
  55.     /**
  56.      * 将json数据转换成pojo对象list
  57.      * @param jsonData
  58.      * @param beanType
  59.      * @return
  60.      */
  61.     public static <T>List<T> jsonToList(String jsonData, Class<T> beanType) {
  62.         JavaType javaType = MAPPER.getTypeFactory().constructParametricType(List.class, beanType);
  63.         try {
  64.             List<T> list = MAPPER.readValue(jsonData, javaType);
  65.             return list;
  66.         } catch (Exception e) {
  67.             e.printStackTrace();
  68.         }
  70.         return null;
  71.     }
  73. }

image.png
前后端对应
image.png
在注册后也将信息保存到cookie
image.png

8 用户退出，清除信息

image.png

9. 前端轮播图

创建servicel和serviceImpl
image.png

对固定的数据创建枚举类

image.png
创建controller
image.png

10. 首页分类需求分析

10.1 查询一级分类

image.png
image.png
image.png
image.png
image.png

10.2通过自连接查询二级分类

  1. ![image.png](https://cdn.nlark.com/yuque/0/2022/png/23122776/1641562629652-b4284cd6-99ba-452b-968f-428fe7296acf.png#crop=0&crop=0&crop=1&crop=1&height=250&id=u09f58102&margin=%5Bobject%20Object%5D&name=image.png&originHeight=500&originWidth=512&originalType=binary&ratio=1&rotation=0&showTitle=false&size=123094&status=done&style=none&title=&width=256)

image.png

10.3 通过自定义Mapper实现查询子分类

1.自定义mapper类
我们这里需要多表联查所以单体查询已经不能满足需求，要创建自定义mapper
image.png

  1. package com.lv.mapper;
  3. import com.lv.pojo.vo.CategoryVO;
  4. import com.lv.pojo.vo.NewItemsVO;
  5. import org.apache.ibatis.annotations.Mapper;
  6. import org.apache.ibatis.annotations.Param;
  8. import java.util.List;
  9. import java.util.Map;
  11. /**
  12.  * @author ziming.xing
  13.  * Create Date：2021/5/18
  14.  */
  15. @Mapper
  16. public interface CategoryCustomMapper {
  17.     List<CategoryVO> getSubCatList(@Param("rootCatId") Integer rootCatId);
  19.     List<NewItemsVO> getSixNewItemLazy(@Param("paramsMap") Map<String, Object> paramsMap);
  20. }

2.创建vo包，之前的bo是前端传给后端的数据，这个vo是后端传给前端，前端view上显示的数据
image.png
image.png
image.png

3.创建mybatis的xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3. <mapper namespace="com.lv.mapper.CategoryCustomMapper">
  4.     <!--
  5.      collection 标签：用于定义关联的list集合类型的封装规则
  6.      property：对应三级分类的list属性名
  7.      ofType：集合的类型，三级分类的VO
  8.      -->
  9.     <resultMap id="MyCategoryVO" type="com.lv.pojo.vo.CategoryVO">
  10.         <id column="id" jdbcType="INTEGER" property="id"/>
  11.         <result column="name" jdbcType="VARCHAR" property="name"/>
  12.         <result column="type" jdbcType="INTEGER" property="type"/>
  13.         <result column="father_id" jdbcType="INTEGER" property="fatherId"/>
  14.         <collection property="subCatList" ofType="com.lv.pojo.vo.SubCategoryVO">
  15.             <id column="sub_id" jdbcType="INTEGER" property="subId"/>
  16.             <result column="sub_name" jdbcType="VARCHAR" property="subName"/>
  17.             <result column="sub_type" jdbcType="INTEGER" property="subType"/>
  18.             <result column="sub_father_id" jdbcType="INTEGER" property="subFatherId"/>
  19.         </collection>
  20.     </resultMap>
  22.     <select id="getSubCatList" resultMap="MyCategoryVO">
  23.         SELECT f.id,
  24.                f.`name`,
  25.                f.type,
  26.                f.father_id,
  27.                c.id        AS sub_id,
  28.                c.`name`    AS sub_name,
  29.                c.type      AS sub_type,
  30.                c.father_id AS sub_father_id
  31.         FROM `category` AS f
  32.                      LEFT JOIN `category` AS c ON f.id = c.father_id
  33.         WHERE f.father_id = #{rootCatId,jdbcType=INTEGER}
  34.     </select>
  35. </mapper>

image.png
image.pngimage.png

10.4.首页商品推荐

image.png

  1.  <resultMap id="MyNewItemsVO" type="com.lv.pojo.vo.NewItemsVO">
  2.         <id column="root_cat_id" jdbcType="INTEGER" property="rootCatId"/>
  3.         <result column="root_cat_name" jdbcType="VARCHAR" property="rootCatName"/>
  4.         <result column="slogan" jdbcType="VARCHAR" property="slogan"/>
  5.         <result column="cat_image" jdbcType="VARCHAR" property="catImage"/>
  6.         <result column="bg_color" jdbcType="VARCHAR" property="bgColor"/>
  7.         <collection property="simpleItemList" ofType="cn.myst.web.pojo.vo.SimpleItemVO">
  8.             <result column="item_id" jdbcType="VARCHAR" property="itemId"/>
  9.             <result column="item_name" jdbcType="VARCHAR" property="itemName"/>
  10.             <result column="item_url" jdbcType="VARCHAR" property="itemUrl"/>
  11.         </collection>
  12.     </resultMap>
  13.     <select id="getSixNewItemLazy" resultMap="MyNewItemsVO">
  14.         SELECT f.id        AS root_cat_id,
  15.                f.`name`    AS root_cat_name,
  16.                f.slogan,
  17.                f.cat_image,
  18.                f.bg_color,
  19.                i.id        AS item_id,
  20.                i.item_name AS item_name,
  21.                ii.url      AS item_url,
  22.                i.created_time
  23.         FROM category f
  24.                      LEFT JOIN items i ON f.id = i.root_cat_id
  25.                      LEFT JOIN items_img ii ON i.id = ii.item_id
  26.         WHERE f.type = 1
  27.           AND i.root_cat_id = #{paramsMap.rootCatId}
  28.           AND ii.is_main = 1
  29.         ORDER BY i.created_time DESC
  30.         LIMIT 0,6
  31.     </select>

mapper
image.png
serviceImpl
image.png
controller
image.png

11.商品详情功能分析

11.1 搜索信息

image.png
image.png
image.png

11.2 编写相关查询servcie

我们查询都是和商品相关的，并且都是单表查询，所以我们使用通用mapper就可以
image.png
image.png
创建一个vo将数据传给前端

image.png
image.png
image.png

12.商品的评价

12.1 查询商品评价等级数量

创建评价vo
image.png、
创建评价枚举
image.png
service层，查询评价等级和各个等级数量，在做和
image.png
controller层
image.png

image.pngimage.png

12.2 自定义mapper查询

因为涉及到多表关联，通用mapper不能完成

  • 数据库设计

image.png

  • mapper层

image.pngimage.png

  • service层

image.png

12.3 mybatis分页插件

引入相关依赖，设置yml
image.png
image.png
image.png

  • controller层

image.png
创建一个BaseController
image.png
image.png

12.4 信息脱敏

image.png

  2. /**
  3.  * 通用脱敏工具类
  4.  * 可用于：
  5.  *      用户名
  6.  *      手机号
  7.  *      邮箱
  8.  *      地址等
  9.  */
  10. public class DesensitizationUtil {
  12.     private static final int SIZE = 6;
  13.     private static final String SYMBOL = "*";
  15.     /**
  16.      * 通用脱敏方法
  17.      * @param value
  18.      * @return
  19.      */
  20.     public static String commonDisplay(String value) {
  21.         if (null == value || "".equals(value)) {
  22.             return value;
  23.         }
  24.         int len = value.length();
  25.         int pamaone = len / 2;
  26.         int pamatwo = pamaone - 1;
  27.         int pamathree = len % 2;
  28.         StringBuilder stringBuilder = new StringBuilder();
  29.         if (len <= 2) {
  30.             if (pamathree == 1) {
  31.                 return SYMBOL;
  32.             }
  33.             stringBuilder.append(SYMBOL);
  34.             stringBuilder.append(value.charAt(len - 1));
  35.         } else {
  36.             if (pamatwo <= 0) {
  37.                 stringBuilder.append(value.substring(0, 1));
  38.                 stringBuilder.append(SYMBOL);
  39.                 stringBuilder.append(value.substring(len - 1, len));
  41.             } else if (pamatwo >= SIZE / 2 && SIZE + 1 != len) {
  42.                 int pamafive = (len - SIZE) / 2;
  43.                 stringBuilder.append(value.substring(0, pamafive));
  44.                 for (int i = 0; i < SIZE; i++) {
  45.                     stringBuilder.append(SYMBOL);
  46.                 }
  47.                 if ((pamathree == 0 && SIZE / 2 == 0) || (pamathree != 0 && SIZE % 2 != 0)) {
  48.                     stringBuilder.append(value.substring(len - pamafive, len));
  49.                 } else {
  50.                     stringBuilder.append(value.substring(len - (pamafive + 1), len));
  51.                 }
  52.             } else {
  53.                 int pamafour = len - 2;
  54.                 stringBuilder.append(value.substring(0, 1));
  55.                 for (int i = 0; i < pamafour; i++) {
  56.                     stringBuilder.append(SYMBOL);
  57.                 }
  58.                 stringBuilder.append(value.substring(len - 1, len));
  59.             }
  60.         }
  61.         return stringBuilder.toString();
  62.     }
  64. }

image.png

13. 商品搜索功能

13.1主页搜索框关键字商品搜索

  • 会用到多表关联，也会用到分页操作

image.png

  • sql语句 ```sql SELECT i.id as itemId, i.item_name as itemName, i.sell_counts as sellCounts, ii.url as imgUrl, tempSpec.price_discount as price FROM items i LEFT JOIN items_img ii ON i.id=ii.item_id LEFT JOIN (

    1. SELECT 
    2.       item_id,MIN(price_discount) as price_discount
    3.   FROM
    4.       items_spec
    5.   GROUP BY
    6.       item_id

    ) tempSpec ON i.id =tempSpec.item_id WHERE ii.is_main =1;

  1.   xml
  2. ```xml
  4. <!--    k:默认，代表默认排序，根据name-->
  5. <!--    c:根据销量排序-->
  6. <!--    p:根据价格排序-->
  7. <!--    -->
  8.     <select id="searchItems" parameterType="Map" resultType="com.lv.pojo.vo.SearchItemsVO">
  9.         SELECT
  10.             i.id as itemId,
  11.             i.item_name as itemName,
  12.             i.sell_counts as sellCounts,
  13.             ii.url as imgUrl,
  14.             tempSpec.price_discount as price
  15.         FROM
  16.             items i
  17.         LEFT JOIN
  18.             items_img ii
  19.         ON
  20.             i.id=ii.item_id
  21.         LEFT JOIN
  22.             ( SELECT item_id,MIN(price_discount) as price_discount FROM items_spec GROUP BY item_id ) tempSpec
  23.         ON
  24.             i.id =tempSpec.item_id
  25.         WHERE
  26.             ii.is_main =1;
  27.             <if test="paramsMap.keywords !=null and paramsMap.keywords !='' ">
  28.                 AND i.item_name LIKE '%${paramsMap.keywords}%'
  29.             </if>
  30.         ORDER BY
  31.             <choose>
  32.                 <when test="paramsMap.sort==&quot;c&quot;">
  33.                      i.sell_counts desc
  34.                  </when>
  35.                 <when test="paramsMap.sort==&quot;p&quot;">
  36.                     tempSpec.price_discount asc
  37.                 </when>
  39.                 <otherwise>
  40.                     i.item_name asc
  41.                 </otherwise>
  42.             </choose>
  43.     </select>

多表联查，要用到自定义mapper和VO
image.png
mapper
image.png
service
image.png
controller
image.png

13.2 前端业务与商品分类搜索

通过主页的三级分类id，进行搜索
image.png

  1. <select id="searchItemsByThirdCat" parameterType="Map" resultType="com.lv.pojo.vo.SearchItemsVO">
  2.         SELECT
  3.             i.id as itemId,
  4.             i.item_name as itemName,
  5.             i.sell_counts as sellCounts,
  6.             ii.url as imgUrl,
  7.             tempSpec.price_discount as price
  8.         FROM
  9.             items i
  10.         LEFT JOIN
  11.             items_img ii
  12.         ON
  13.             i.id=ii.item_id
  14.         LEFT JOIN
  15.         ( SELECT item_id,MIN(price_discount) as price_discount FROM items_spec GROUP BY item_id ) tempSpec
  16.         ON
  17.             i.id =tempSpec.item_id
  18.         WHERE
  19.             ii.is_main =1
  20.         AND
  21.             i.cat_id = #{paramsMap.catId}
  22.         ORDER BY
  23.             <choose>
  24.                 <when test="paramsMap.sort==&quot;c&quot;">
  25.                     i.sell_counts desc
  26.                 </when>
  27.                 <when test="paramsMap.sort==&quot;p&quot;">
  28.                     tempSpec.price_discount asc
  29.                 </when>
  31.                 <otherwise>
  32.                     i.item_name asc
  33.                 </otherwise>
  34.             </choose>
  35.     </select>

mapper
image.png
service
image.png
controller
image.png

14.购物车

14.1 购物车存储形式

使用Cookie和redis一起做，同时我们可以仿造京东购物车
image.png
image.png
image.png
image.png

14.2 使用Cookie和Redis，编写未登录和已登录加入购物车的代码

image.png
前端需要把购物车信息传给后端，这里需要前端传一个VO给后端
image.png

14.3 渲染(刷新)购物车

不能直接使用Cookie中的信息，因为有可能商品的信息，价格发生了更改，我们需要通过商品规格id重新刷新一下购物车信息。

  • 要使用到多表关联，我们要用自定义mapper和数据层的VO，封装购物车信息

image.png

  • mapper.xml ```xml

  2. - **自定义mapper**
  4. ![image.png](https://cdn.nlark.com/yuque/0/2022/png/23122776/1641818351909-4a2b5115-f56a-481a-a35a-30d135f2e809.png#crop=0&crop=0&crop=1&crop=1&height=339&id=uc306c198&margin=%5Bobject%20Object%5D&name=image.png&originHeight=677&originWidth=1622&originalType=binary&ratio=1&rotation=0&showTitle=false&size=142066&status=done&style=none&title=&width=811)
  6. - **service和serviceImpl**
  8. ![image.png](https://cdn.nlark.com/yuque/0/2022/png/23122776/1641818513489-42d26bc4-0906-445d-afcf-b7ca65464c4d.png#crop=0&crop=0&crop=1&crop=1&height=78&id=u32f05707&margin=%5Bobject%20Object%5D&name=image.png&originHeight=156&originWidth=711&originalType=binary&ratio=1&rotation=0&showTitle=false&size=20808&status=done&style=none&title=&width=355.5)<br />![image.png](https://cdn.nlark.com/yuque/0/2022/png/23122776/1641818729805-ce733816-0c06-44a5-806a-97a42e122164.png#crop=0&crop=0&crop=1&crop=1&height=170&id=u679d5e47&margin=%5Bobject%20Object%5D&name=image.png&originHeight=339&originWidth=810&originalType=binary&ratio=1&rotation=0&showTitle=false&size=50269&status=done&style=none&title=&width=405)
  10. - **controller**
  12. ![image.png](https://cdn.nlark.com/yuque/0/2022/png/23122776/1641819250247-36d03f1d-b7c1-45cd-9baa-0b1ecda63760.png#crop=0&crop=0&crop=1&crop=1&height=313&id=ub6d15422&margin=%5Bobject%20Object%5D&name=image.png&originHeight=626&originWidth=1756&originalType=binary&ratio=1&rotation=0&showTitle=false&size=156856&status=done&style=none&title=&width=878)
  13. <a name="fpFQe"></a>
  14. ## 14.4 其他业务操作
  15. 删除操作
  17. ![image.png](https://cdn.nlark.com/yuque/0/2022/png/23122776/1641868535792-9c9096e9-4cf0-4df3-b3eb-72676fdb9019.png#crop=0&crop=0&crop=1&crop=1&height=261&id=u637dee5b&margin=%5Bobject%20Object%5D&name=image.png&originHeight=522&originWidth=1047&originalType=binary&ratio=1&rotation=0&showTitle=false&size=88953&status=done&style=none&title=&width=523.5)
  18. <a name="wKXlm"></a>
  19. # 15.收货地址
  20. <a name="pDcFe"></a>
  21. ## 15.1 需求分析
  23. - 进入页面后，需要将所有的收货地址列出来
  24. - 可以新增地址
  25. - 可以修改之前的地址
  26. - 可以设置为默认：默认会被选中
  27. <a name="G6QNI"></a>
  28. ## 15.2 表设计
  29. ![image.png](https://cdn.nlark.com/yuque/0/2022/png/23122776/1641877492404-44980249-5741-4e70-be8e-620a639c3e6e.png#crop=0&crop=0&crop=1&crop=1&height=269&id=u17865d1f&margin=%5Bobject%20Object%5D&name=image.png&originHeight=538&originWidth=577&originalType=binary&ratio=1&rotation=0&showTitle=false&size=206971&status=done&style=none&title=&width=288.5)
  31. - 关联用户 ID：一个用户会有多个收货地址
  32. - 扩展字段：可能会有详细地址 2
  34. 用户在确认订单页面，可以针对收货地址做如下操作：
  36. 1. 查询用户的所有收货地址列表
  37. 2. 新增收货地址
  38. 3. 删除收货地址
  39. 4. 修改收货地址
  40. 5. 设置默认地址
  42. 另外在编辑地址时，所需要的省市区信息的维护：本课程是放在前端 js 中维护的，这种信息一般半年才维护一次，变动不太大。
  43. <a name="qv42K"></a>
  44. ## 15.3 查询用户的所有收货地址列表
  45. controller
  46. ```java
  47.     @ApiOperation(value = "根据用户id查询收货地址列表", notes = "根据用户id查询收货地址列表", httpMethod = "POST")
  48.     @PostMapping("/list")
  49.     public JSONResult list(
  50.             @RequestParam String userId) {
  52.         if (StringUtils.isBlank(userId)) {
  53.             return JSONResult.errorMsg("");
  54.         }
  56.         List<UserAddress> list = addressService.queryAll(userId);
  57.         return JSONResult.ok(list);
  58.     }

service

  1.     @Transactional(propagation = Propagation.SUPPORTS)
  2.     @Override
  3.     public List<UserAddress> queryAll(String userId) {
  5.         UserAddress ua = new UserAddress();
  6.         ua.setUserId(userId);
  8.         return userAddressMapper.select(ua);
  9.     }

15.4 新增收获地址

  1.     @ApiOperation(value = "用户新增地址", notes = "用户新增地址", httpMethod = "POST")
  2.     @PostMapping("/add")
  3.     public JSONResult add(@RequestBody AddressBO addressBO) {
  5.         JSONResult checkRes = checkAddress(addressBO);
  6.         if (checkRes.getStatus() != 200) {
  7.             return checkRes;
  8.         }
  10.         addressService.addNewUserAddress(addressBO);
  12.         return JSONResult.ok();
  13.     }
  15.     private JSONResult checkAddress(AddressBO addressBO) {
  16.         String receiver = addressBO.getReceiver();
  17.         if (StringUtils.isBlank(receiver)) {
  18.             return JSONResult.errorMsg("收货人不能为空");
  19.         }
  20.         if (receiver.length() > 12) {
  21.             return JSONResult.errorMsg("收货人姓名不能太长");
  22.         }
  24.         String mobile = addressBO.getMobile();
  25.         if (StringUtils.isBlank(mobile)) {
  26.             return JSONResult.errorMsg("收货人手机号不能为空");
  27.         }
  28.         if (mobile.length() != 11) {
  29.             return JSONResult.errorMsg("收货人手机号长度不正确");
  30.         }
  31.         boolean isMobileOk = MobileEmailUtils.checkMobileIsOk(mobile);
  32.         if (!isMobileOk) {
  33.             return JSONResult.errorMsg("收货人手机号格式不正确");
  34.         }
  36.         String province = addressBO.getProvince();
  37.         String city = addressBO.getCity();
  38.         String district = addressBO.getDistrict();
  39.         String detail = addressBO.getDetail();
  40.         if (StringUtils.isBlank(province) ||
  41.                 StringUtils.isBlank(city) ||
  42.                 StringUtils.isBlank(district) ||
  43.                 StringUtils.isBlank(detail)) {
  44.             return JSONResult.errorMsg("收货地址信息不能为空");
  45.         }
  47.         return JSONResult.ok();
  48.     }

Bo

  1. /**
  2.  * 用户新增或修改地址的 BO
  3.  */
  4. public class AddressBO {
  6.     private String addressId;
  8.     private String userId;
  9.     private String receiver;
  10.     private String mobile;
  11.     private String province;
  12.     private String city;
  13.     private String district;
  14.     private String detail;

service

  1. @Transactional(propagation = Propagation.REQUIRED)
  2.     @Override
  3.     public void addNewUserAddress(AddressBO addressBO) {
  5.         // 1. 判断当前用户是否存在地址，如果没有，则新增为‘默认地址’
  6.         Integer isDefault = 0;
  7.         List<UserAddress> addressList = this.queryAll(addressBO.getUserId());
  8.         if (addressList == null || addressList.isEmpty() || addressList.size() == 0) {
  9.             isDefault = 1;
  10.         }
  12.         String addressId = sid.nextShort();
  14.         // 2. 保存地址到数据库
  15.         UserAddress newAddress = new UserAddress();
  16.         BeanUtils.copyProperties(addressBO, newAddress);
  18.         newAddress.setId(addressId);
  19.         newAddress.setIsDefault(isDefault);
  20.         newAddress.setCreatedTime(new Date());
  21.         newAddress.setUpdatedTime(new Date());
  23.         userAddressMapper.insert(newAddress);
  24.     }

15.5 删除收货地址

controller

  1.  @ApiOperation(value = "用户删除地址", notes = "用户删除地址", httpMethod = "POST")
  2.     @PostMapping("/delete")
  3.     public JSONResult delete(
  4.             @RequestParam String userId,
  5.             @RequestParam String addressId) {
  7.         if (StringUtils.isBlank(userId) || StringUtils.isBlank(addressId)) {
  8.             return JSONResult.errorMsg("");
  9.         }
  11.         addressService.deleteUserAddress(userId, addressId);
  12.         return JSONResult.ok();
  13.     }

service

  1.     @Transactional(propagation = Propagation.REQUIRED)
  2.     @Override
  3.     public void deleteUserAddress(String userId, String addressId) {
  5.         UserAddress address = new UserAddress();
  6.         address.setId(addressId);
  7.         address.setUserId(userId);
  9.         userAddressMapper.delete(address);
  10.     }

15.6 修改收货地址

controller

  1.     @ApiOperation(value = "用户修改地址", notes = "用户修改地址", httpMethod = "POST")
  2.     @PostMapping("/update")
  3.     public JSONResult update(@RequestBody AddressBO addressBO) {
  5.         if (StringUtils.isBlank(addressBO.getAddressId())) {
  6.             return JSONResult.errorMsg("修改地址错误：addressId不能为空");
  7.         }
  9.         JSONResult checkRes = checkAddress(addressBO);
  10.         if (checkRes.getStatus() != 200) {
  11.             return checkRes;
  12.         }
  14.         addressService.updateUserAddress(addressBO);
  16.         return JSONResult.ok();
  17.     }

service

  1.     @Transactional(propagation = Propagation.REQUIRED)
  2.     @Override
  3.     public void updateUserAddress(AddressBO addressBO) {
  5.         String addressId = addressBO.getAddressId();
  7.         UserAddress pendingAddress = new UserAddress();
  8.         BeanUtils.copyProperties(addressBO, pendingAddress);
  10.         pendingAddress.setId(addressId);
  11.         pendingAddress.setUpdatedTime(new Date());
  13.         userAddressMapper.updateByPrimaryKeySelective(pendingAddress);
  14.     }

15.7 设置默认地址

controller

  1.     @ApiOperation(value = "用户设置默认地址", notes = "用户设置默认地址", httpMethod = "POST")
  2.     @PostMapping("/setDefalut")
  3.     public JSONResult setDefalut(
  4.             @RequestParam String userId,
  5.             @RequestParam String addressId) {
  7.         if (StringUtils.isBlank(userId) || StringUtils.isBlank(addressId)) {
  8.             return JSONResult.errorMsg("");
  9.         }
  11.         addressService.updateUserAddressToBeDefault(userId, addressId);
  12.         return JSONResult.ok();
  13.     }

servcie

  1.  @Transactional(propagation = Propagation.REQUIRED)
  2.     @Override
  3.     public void updateUserAddressToBeDefault(String userId, String addressId) {
  5.         // 1. 查找默认地址，设置为不默认
  6.         UserAddress queryAddress = new UserAddress();
  7.         queryAddress.setUserId(userId);
  8.         queryAddress.setIsDefault(YesOrNo.YES.type);
  9.         List<UserAddress> list = userAddressMapper.select(queryAddress);
  10.         for (UserAddress ua : list) {
  11.             ua.setIsDefault(YesOrNo.NO.type);
  12.             userAddressMapper.updateByPrimaryKeySelective(ua);
  13.         }
  15.         // 2. 根据地址id修改为默认的地址
  16.         UserAddress defaultAddress = new UserAddress();
  17.         defaultAddress.setId(addressId);
  18.         defaultAddress.setUserId(userId);
  19.         defaultAddress.setIsDefault(YesOrNo.YES.type);
  20.         userAddressMapper.updateByPrimaryKeySelective(defaultAddress);
  21.     }

16. 订单流程和状态

16.1 需求分析

image.png

  • 用户浏览商品
  • 添加到购物车
  • 订单结算：相当于是订单确认
  • 发起支付

image.png

  • 前往支付：这里生成订单？
  • 待发货 变成 待收货，这里需要有 客服系统或则商家系统 来做这件事，本阶段不涉及该系统，可以直接修改状态来演示

image.png

  • 付款中：有可能是一些第三方平台，或则政府平台，同步等待结果的话，可能会超过 10 秒，长的可能几分钟，这里异步等待回调

  • 取消订单，待退款：是需要客服等人员去审核的

    16.2 表设计

    image.png
    订单表：

  • 收货 xx 快照：基本上下达填写收货地址后，再去更改收货地址信息，订单中的收货地址是不会被影响的

  • 实际支付总价格：可能会有优惠卷之类的；但是在本阶段没有这些优惠功能
  • 邮费：本阶段邮费都是包邮的
  • 买家是否评价：判断是否对该订单是否进行了评价
  • 逻辑删除状态：订单这种数据对我们公司来说是宝贵的数据，对于用户来说是看不到了，但是对于我们公司来说它是有价值的

订单商品关联表：子订单表

  • 这里关于商品的一些信息，也是快照信息，而不是直接是一个 ID
  • 商品 ID、规格 ID：这些数据也是比较珍贵的，可以用来做一些大数据分析之类的

订单状态表：可以和订单表进行合并的，但是为了性能，就拆开来了（列多，查询性能低）

  • 订单 ID：与订单表的 ID 是一样的
  • 订单状态：订单状态表;订单的每个状态更改都需要进行记录
    10：待付款 20：已付款，待发货 30：已发货，待收货（7天自动确认） 40：交易成功（此时可以评价）50：交易关闭（待付款时，用户取消 或 长时间未付款，系统识别后自动关闭）
    退货/退货（退款），此分支流程不做，所以不加入

16.4 聚合支付中心

image.png

16.5 提交并接受订单信息

前端代码

  1.                 // 提交订单，创建订单
  2.                 submitOrder() {
  3.                     // 判断提交的商品不能为空
  4.                     var orderItemList = this.orderItemList;
  5.                     if (orderItemList == null || orderItemList == undefined || orderItemList == '' || orderItemList.length <= 0) {
  6.                         alert("没有商品信息，订单无法提交~！");
  7.                         return;
  8.                     }
  9.                     // 拼接规格ids
  10.                     var itemSpecIds = "";
  11.                     for (var i = 0 ; i < orderItemList.length ; i ++) {
  12.                         var tmpSpecId = orderItemList[i].specId;
  13.                         itemSpecIds += tmpSpecId;
  14.                         if (i < orderItemList.length-1) {
  15.                             itemSpecIds += ",";
  16.                         }
  17.                     }
  19.                     // 判断选中的地址id不能为空
  20.                     var choosedAddressId = this.choosedAddressId;
  21.                     if (choosedAddressId == null || choosedAddressId == undefined || choosedAddressId == '') {
  22.                         alert("请选择收货地址！");
  23.                         return;
  24.                     }
  26.                     // 判断支付方式不能为空
  27.                     var choosedPayMethod = parseInt(this.choosedPayMethod);
  28.                     if (choosedPayMethod != 1 && choosedPayMethod != 2) {
  29.                         alert("请选择支付方式！");
  30.                         return;
  31.                     }
  33.                     // var newWindow = window.open();
  35.                     // 买家备注可以为空
  36.                     var orderRemarker = this.orderRemarker;
  37.                     // console.log(orderRemarker);
  39.                     var userInfo = this.userInfo;
  40.                     var serverUrl = app.serverUrl;
  41.                     axios.defaults.withCredentials = true;
  42.                     axios.post(
  43.                             serverUrl + '/orders/create', 
  44.                             {
  45.                                 "userId": userInfo.id,
  46.                                 "itemSpecIds": itemSpecIds,
  47.                                 "addressId": choosedAddressId,
  48.                                 "payMethod": choosedPayMethod,
  49.                                 "leftMsg": orderRemarker,
  50.                             },
  51.                             {
  52.                                 headers: {
  53.                                     'headerUserId': userInfo.id,
  54.                                     'headerUserToken': userInfo.userUniqueToken
  55.                                 }
  56.                             })
  57.                             .then(res => {
  58.                                 if (res.data.status == 200) {
  59.                                     // alert("OK");
  60.                                     var orderId = res.data.data;
  61.                                     // 判断是否微信还是支付宝支付
  62.                                     if (choosedPayMethod == 1) {
  63.                                         // 微信支付则跳转到微信支付页面，并且获得支付二维码
  64.                                         window.location.href = "wxpay.html?orderId=" + orderId;
  65.                                     } else if (choosedPayMethod == 2) {
  66.                                         this.orderId = orderId;
  68.                                         // 支付宝支付直接跳转
  69.                                         window.location.href = "alipay.html?orderId=" + orderId + "&amount="+this.totalAmount;
  70.                                         window.open("alipayTempTransit.html?orderId=" + orderId);
  71.                                         // const newWindow = window.open();
  72.                                         // 弹出的新窗口进行支付
  73.                                         // newWindow.location = "alipayTempTransit.html?orderId=" + orderId;
  74.                                         // this.$nextTick(()=> {
  75.                                         //     // 当前页面跳转后会轮训支付结果
  76.                                         //     newWindow.location.href = "alipay.html?orderId=" + orderId;
  77.                                         // })
  78.                                     } else {
  79.                                         alert("目前只支持微信或支付宝支付！");
  80.                                     }
  82.                                 } else {
  83.                                     alert(res.data.msg);
  84.                                 }
  85.                             });
  86.                 },

大致流程如下：

  1. 获取到商品的规格 ID
  2. 拿到选择的地址 ID
  3. 拿到支付的方式
  4. 创建订单 /orders/create
  5. 订单创建成功之后，再处理支付相关的业务，后面再说

这里主要是需要先实现创建订单的功能

用户下单（创建订单）接口

BO

  2. /**
  3.  * 用于创建订单的 BO 对象
  4.  */
  5. public class SubmitOrderBO {
  7.     private String userId;
  8.     private String itemSpecIds;
  9.     private String addressId;
  10.     private Integer payMethod;
  11.     private String leftMsg;

service

  1. //@SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection")
  2. @Service
  3. public class OrderServiceImpl implements OrderService {
  4.     //@SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection")
  5.     @Autowired
  6.     private OrdersMapper ordersMapper;
  7.     @Autowired
  8.     private Sid sid;
  9.     @Autowired
  10.     private AddressService addressService;
  11.     @Autowired
  12.     private ItemService itemService;
  13.     @Autowired
  14.     private OrderItemsMapper orderItemsMapper;
  15.     @Autowired
  16.     private OrderStatusMapper orderStatusMapper;
  18.     @Transactional(propagation = Propagation.REQUIRED)
  19.     @Override
  20.     public OrderVO createOrder(SubmitOrderBO submitOrderBO) {
  22.         String userId = submitOrderBO.getUserId();
  23.         String addressId = submitOrderBO.getAddressId();
  24.         String itemSpecIds = submitOrderBO.getItemSpecIds();
  25.         Integer payMethod = submitOrderBO.getPayMethod();
  26.         String leftMsg = submitOrderBO.getLeftMsg();
  27.         // 包邮费用设置为0
  28.         Integer postAmount = 0;
  30.         // 使用 sid 生成
  31.         String orderId = sid.nextShort();
  33.         UserAddress address = addressService.queryUserAddres(userId, addressId);
  35.         // 1. 新订单数据保存
  36.         Orders newOrder = new Orders();
  37.         newOrder.setId(orderId);
  38.         newOrder.setUserId(userId);
  40.         // 地址快照
  41.         newOrder.setReceiverName(address.getReceiver());
  42.         newOrder.setReceiverMobile(address.getMobile());
  43.         newOrder.setReceiverAddress(address.getProvince() + " "
  44.                 + address.getCity() + " "
  45.                 + address.getDistrict() + " "
  46.                 + address.getDetail());
  48.         // 在保存子订单后，计算出总价和真实价格后再填充
  49.         //        newOrder.setTotalAmount();
  50.         //        newOrder.setRealPayAmount();
  52.         // 设置运费，真实的业务中，会动态设置的，要获取到
  53.         newOrder.setPostAmount(postAmount);
  55.         newOrder.setPayMethod(payMethod);
  56.         newOrder.setLeftMsg(leftMsg); // 买家留言
  58.         newOrder.setIsComment(YesOrNo.NO.type);
  59.         newOrder.setIsDelete(YesOrNo.NO.type);
  60.         newOrder.setCreatedTime(new Date());
  61.         newOrder.setUpdatedTime(new Date());
  64.         // 2. 循环根据 itemSpecIds 保存订单商品信息表
  65.         String itemSpecIdArr[] = itemSpecIds.split(",");
  66.         Integer totalAmount = 0;    // 商品原价累计
  67.         Integer realPayAmount = 0;  // 优惠后的实际支付价格累计
  68.         for (String itemSpecId : itemSpecIdArr) {
  70.             // TODO 整合 redis 后，商品购买的数量重新从 redis 的购物车中获取
  71.             int buyCounts = 1;
  73.             // 2.1 根据规格 id，查询规格的具体信息，主要获取价格
  74.             ItemsSpec itemSpec = itemService.queryItemSpecById(itemSpecId);
  75.             totalAmount += itemSpec.getPriceNormal() * buyCounts;
  76.             realPayAmount += itemSpec.getPriceDiscount() * buyCounts;
  78.             // 2.2 根据商品 id，获得商品信息以及商品主图
  79.             String itemId = itemSpec.getItemId();
  80.             Items item = itemService.queryItemById(itemId);
  81.             String imgUrl = itemService.queryItemMainImgById(itemId);
  83.             // 2.3 循环保存子订单数据到数据库
  84.             String subOrderId = sid.nextShort();
  85.             OrderItems subOrderItem = new OrderItems();
  86.             subOrderItem.setId(subOrderId);
  87.             subOrderItem.setOrderId(orderId);
  88.             subOrderItem.setItemId(itemId);
  89.             subOrderItem.setItemName(item.getItemName());
  90.             subOrderItem.setItemImg(imgUrl);
  91.             subOrderItem.setBuyCounts(buyCounts);
  92.             subOrderItem.setItemSpecId(itemSpecId);
  93.             subOrderItem.setItemSpecName(itemSpec.getName());
  94.             subOrderItem.setPrice(itemSpec.getPriceDiscount());
  95.             orderItemsMapper.insert(subOrderItem);
  97.             // 2.4 在用户提交订单以后，规格表中需要扣除库存
  98.             itemService.decreaseItemSpecStock(itemSpecId, buyCounts);
  99.         }
  101.         newOrder.setTotalAmount(totalAmount);
  102.         newOrder.setRealPayAmount(realPayAmount);
  103.         ordersMapper.insert(newOrder);
  105.         // 3. 保存订单状态表
  106.         OrderStatus waitPayOrderStatus = new OrderStatus();
  107.         waitPayOrderStatus.setOrderId(orderId);
  108.         waitPayOrderStatus.setOrderStatus(OrderStatusEnum.WAIT_PAY.type);
  109.         waitPayOrderStatus.setCreatedTime(new Date());
  110.         orderStatusMapper.insert(waitPayOrderStatus);
  112.         // 4. 构建商户订单，用于传给支付中心
  113.         MerchantOrdersVO merchantOrdersVO = new MerchantOrdersVO();
  114.         merchantOrdersVO.setMerchantOrderId(orderId);
  115.         merchantOrdersVO.setMerchantUserId(userId);
  116.         merchantOrdersVO.setAmount(realPayAmount + postAmount);
  117.         merchantOrdersVO.setPayMethod(payMethod);
  119.         // 5. 构建自定义订单 vo
  120.         OrderVO orderVO = new OrderVO();
  121.         orderVO.setOrderId(orderId);
  122.         orderVO.setMerchantOrdersVO(merchantOrdersVO);
  124.         return orderVO;
  125.     }
  126. }