项目1个人接口开发指导#

该文档用来指导大家开发个人接口

依赖#

javax.servlet-api、lombok、mysql-connector-java、mybatis、jackson、pagehelper

1
<dependencies>
2
  <dependency>
3
    <groupId>javax.servlet</groupId>
4
    <artifactId>javax.servlet-api</artifactId>
5
    <version>3.1.0</version>
6
    <scope>provided</scope>
7
  </dependency>
8
  <dependency>
9
    <groupId>org.projectlombok</groupId>
10
    <artifactId>lombok</artifactId>
11
    <version>1.18.24</version>
12
  </dependency>
13
  <dependency>
14
    <groupId>mysql</groupId>
15
    <artifactId>mysql-connector-java</artifactId>
16
    <version>5.1.47</version>
17
  </dependency>
18
  <dependency>
19
    <groupId>org.mybatis</groupId>
20
    <artifactId>mybatis</artifactId>
21
    <version>3.5.10</version>
22
  </dependency>
23
  <!--json响应-->
24
  <dependency>
25
    <groupId>com.fasterxml.jackson.datatype</groupId>
26
    <artifactId>jackson-datatype-jsr310</artifactId>
27
    <version>2.13.0</version>
28
  </dependency>
29
  <dependency>
30
    <groupId>com.github.pagehelper</groupId>
31
    <artifactId>pagehelper</artifactId>
32
    <version>5.2.0</version>
33
  </dependency>
34
</dependencies>

通用部分#

跨域#

跨域问题，需要在响应报文中增加一些响应头，这个是通用的部分，这时候我们要考虑使用Filter来完成

1
@WebFilter("/*")
2
public class CorsFilter implements Filter {
3
    @Override
4
    public void init(FilterConfig filterConfig) throws ServletException {
5

6
    }
7

8
    @Override
9
    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
10
        HttpServletResponse response = (HttpServletResponse) servletResponse;
11
        response.addHeader("Access-Control-Allow-Origin", "*");
12
        response.addHeader("Access-Control-Allow-Methods", "*");
13
        response.addHeader("Access-Control-Allow-Headers", "*");
14
        filterChain.doFilter(servletRequest,servletResponse);
15
    }
16

17
    @Override
18
    public void destroy() {
19

20
    }
21
}

初始化（选做）#

初始化MyBatis的SqlSessionFactory，并且放入到ServletContext中

1
@WebListener
2
public class MyBatisInitializationListener implements ServletContextListener {
3
    @Override
4
    public void contextInitialized(ServletContextEvent servletContextEvent) {
5
        ServletContext servletContext = servletContextEvent.getServletContext();
6
        try {
7
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(Resources.getResourceAsStream("mybatis.xml"));
8
            servletContext.setAttribute(WdConstant.SQL_SESSION_FACTORY,sqlSessionFactory);
9
        } catch (IOException e) {
10
            e.printStackTrace();
11
        }
12
    }
13

14
    @Override
15
    public void contextDestroyed(ServletContextEvent servletContextEvent) {
16

17
    }
18
}

个人信息（跨域导致Session失效的情况）#

跨域请求的话SessionID每次都会变化，其实意味着每一次请求的时候Session会变化，也就意味着就算是同一个用户，放入到Session中的信息仍然也是拿不到的，这时候就会有一些问题，比如登录，之前是将用户信息放在Session中，现在这块无法运行了。

我们可以在应用程序中维护一个这样的一块空间，用户登录成功之后可以开辟一块空间放该用户的信息，并且放在其中的信息是有时间限制（可以设置默认30min）的

我们提供一个Map，key为不可重复的随机值，value中可以放用户的信息，同时包含时间信息，超过这个时间会移除到Map中的这组信息

方法	说明
getInfo(String key)	根据key获得没有过期的信息，如果已经过期则去掉该信息
genInfo(Object info)	传入信息，创建key，生成过期时间，放入到map中，返回生成的key

1
@Data
2
public class WdTokenHolder {
3

4
    private static Map<String,InfoWithExpiredTime> map = new ConcurrentHashMap<>();
5

6
    public static Object getInfo(String key) throws NoInfoException, InfoExpiredException {
7
        InfoWithExpiredTime info = map.get(key);
8
        if (info == null) {
9
            throw new NoInfoException();
10
        }
11
        Date expiredTime = info.getExpiredTime();
12
        if (new Date().after(expiredTime)) {
13
            map.remove(key);
14
            throw new InfoExpiredException();
15
        }
16
        Object validInfo = info.getInfo();
17
        return validInfo;
18
    }
19

20
    public static String genKey(Object validInfo) {
21
        String uuid = UUID.randomUUID().toString();
22
        Date now = new Date();
23
        Date afterDate = getAfterDate(now, 0, 0, 0, 0, 30, 0);
24
        InfoWithExpiredTime info = new InfoWithExpiredTime(validInfo,afterDate);
25
        map.put(uuid,info);
26
        return uuid;
27
    }
28

29
    private static Date getAfterDate(Date date, int year, int month, int day, int hour, int minute, int second){
30
        if(date == null){
31
            date = new Date();
32
        }
33

34
        Calendar cal = new GregorianCalendar();
35

36
        cal.setTime(date);
37
        if(year != 0){
38
            cal.add(Calendar.YEAR, year);
39
        }
40
        if(month != 0){
41
            cal.add(Calendar.MONTH, month);
42
        }
43
        if(day != 0){
44
            cal.add(Calendar.DATE, day);
45
        }
46
        if(hour != 0){
47
            cal.add(Calendar.HOUR_OF_DAY, hour);
48
        }
49
        if(minute != 0){
50
            cal.add(Calendar.MINUTE, minute);
51
        }
52
        if(second != 0){
53
            cal.add(Calendar.SECOND, second);
54
        }
55
        return cal.getTime();
56
    }
57

58
    @Data
59
    @AllArgsConstructor
60
    @NoArgsConstructor
61
    public static class InfoWithExpiredTime{
62
        Object info;
63
        Date expiredTime;
64
    }
65
}

接下来就可以这样子做，当我们登录成功的时候，将我们需要存储的信息，通过WdTokenHolder的genKey来生成并存储信息，然后返回这个key给到前端

前端发起这个请求的时候再把这个key携带过来，可以使用特定的请求头携带过来，这时候我们就可以通过key来获得这个信息

全局的Json转换#

全局使用一个ObjectMapper即可，同时设置其日期格式

方法	说明
read(String ,Class<T>)	传入Json字符串和需要转换的实例对应的Class，转换为实例返回
write(Object)	将传入的实例转为对应的Json字符串

1
public class JacksonUtil {
2

3
    private static ObjectMapper objectMapper = new ObjectMapper();
4
    private static final String DEFAULT_DATE_TIME_FORMAT = "yyyy-MM-dd HH:mm:ss";
5
    private static final String DEFAULT_DATE_FORMAT = "yyyy-MM-dd";
6
    private static final String DEFAULT_TIME_FORMAT = "HH:mm:ss";
7
    static {
8
        JavaTimeModule javaTimeModule = new JavaTimeModule();
9
        // 增加LocalDate和LocalTime和LocalDateTime的解析格式的支持
10
        javaTimeModule.addSerializer(LocalDateTime.class, new LocalDateTimeSerializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_TIME_FORMAT)));
11
        javaTimeModule.addSerializer(LocalDate.class, new LocalDateSerializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_FORMAT)));
12
        javaTimeModule.addSerializer(LocalTime.class, new LocalTimeSerializer(DateTimeFormatter.ofPattern(DEFAULT_TIME_FORMAT)));
13
        javaTimeModule.addDeserializer(LocalDateTime.class, new LocalDateTimeDeserializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_TIME_FORMAT)));
14
        javaTimeModule.addDeserializer(LocalDate.class, new LocalDateDeserializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_FORMAT)));
15
        javaTimeModule.addDeserializer(LocalTime.class, new LocalTimeDeserializer(DateTimeFormatter.ofPattern(DEFAULT_TIME_FORMAT)));
16
        objectMapper.registerModule(javaTimeModule);
17
    }
18
    public static ObjectMapper getObjectMapper() {
19
        return objectMapper;
20
    }
21

22
    public static <T> T read(String jsonStr,Class<T> clazz) {
23
        T instance = null;
24
        try {
25
            instance = objectMapper.readValue(jsonStr, clazz);
26
        } catch (JsonProcessingException e) {
27
            e.printStackTrace();
28
        }
29
        return instance;
30
    }
31

32
    public static String write(Object instance) {
33
        String jsonStr = null;
34
        try {
35
            jsonStr = objectMapper.writeValueAsString(instance);
36
        } catch (JsonProcessingException e) {
37
            e.printStackTrace();
38
        }
39
        return jsonStr;
40
    }
41

42
}

Json响应字符串工具#

1
public class ResponseUtil {
2

3
    public static void responseJson(HttpServletResponse response, Object instance) throws IOException {
4
        response.setContentType("application/json;charset=utf-8");
5
        response.getWriter().println(JacksonUtil.write(instance));
6
    }
7
}

常量管理#

创建WdConstant类，在其中管理实例

1
public class WdConstant {
2

3
    public static final String SQL_SESSION_FACTORY = "sqlSessionFactory";
4

5
}

URI分析后缀#

1
public class URIUtil {
2

3
    public static String getOperation(Class<?> servletClass,HttpServletRequest request) {
4
        String uri = request.getRequestURI();
5
        String contextPath = request.getContextPath();
6
        String appUri = uri.replaceAll(contextPath, "");
7
        WebServlet webServlet = servletClass.getDeclaredAnnotation(WebServlet.class);
8
        String urlPattern = webServlet.value()[0];
9
        String operation = appUri.substring(urlPattern.length() - 2);
10
        return operation;
11
    }
12
}

分页配置#

mybatis.xml中增加分页的配置

1
<plugins>
2
    <plugin interceptor="com.github.pagehelper.PageInterceptor">
3
        <property name="helperDialect" value="mysql"/>
4
        <property name="reasonable" value="true"/>
5
    </plugin>
6
</plugins>

具体部分#

登录 (/admin/auth/login)#

核心点：存储登录信息

验证用户名和密码，如果没有问题，WdTokenHolder中生成对应的key，存储用户的信息，并且响应Json数据

1
private void login(HttpServletRequest request, HttpServletResponse response) throws IOException {
2
    String jsonStr = request.getReader().readLine();
3
    Map<String, String> map = JacksonUtil.read(jsonStr, Map.class);
4
    String username = map.get("username");
5
    String password = map.get("password");
6

7
    MarketAdmin admin = adminService.query(username, password);
8
    // 找不到当前用户
9
    if (admin == null) {
10
        BaseRespVo baseRespVo = BaseRespVo.unAuthc();
11
        ResponseUtil.responseJson(response, baseRespVo);
12
        return;
13
    }
14
    // 能够找到当前用户
15
    String token = WdTokenHolder.genKey(admin);
16
    // todo：更新log中的日志信息
17
    AdminInfoBean adminInfoBean = new AdminInfoBean(username, admin.getAvatar());
18
    LoginUserData data = new LoginUserData(adminInfoBean, token);
19
    ResponseUtil.responseJson(response,BaseRespVo.ok(data));
20
}

上面第15行，就是登陆成功后，将信息在本地存储起来，通过返回值token后面可以取出该信息

个人信息 (/admin/auth/info)#

核心点：拿到登录的时候存储的个人信息

查看个人具体信息，其中权限的信息为*

首先拿到请求头中的token值
然后根据token在WdTokenHolder中获取对应的用户信息

1
String token = request.getHeader(WdConstant.MARKET_TOKEN);
2
MarketAdmin info = WdTokenHolder.getInfo(token);

也可以通过工具类封装，让我们在全局都能够获取信息

1
MarketAdmin admin = (MarketAdmin) AuthenticationUtil.getPrincipal();

这时候有一个问题，为何在工具类中，就可以直接拿到用户信息

增加一个Filter，在Filter中根据请求头拿到Token，并且将Token保存起来
在AuthenticationUtil中getPrincipal的时候，先拿到token，然后根据token调用WdTokenHolder的getInfo方法

1
@WebFilter("/*")
2
public class AuthenticationInfoFilter implements Filter {
3
    @Override
4
    public void init(FilterConfig filterConfig) throws ServletException {
5

6
    }
7

8
    @Override
9
    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
10
        HttpServletRequest request = (HttpServletRequest) servletRequest;
11
        if (request.getMethod().equals("OPTIONS") || request.getRequestURI().endsWith("/login")) {
12
            filterChain.doFilter(servletRequest, servletResponse);
13
            return;
14
        }
15

16
        String token = request.getHeader(WdConstant.MARKET_TOKEN);
17
        AuthenticationUtil.setToken(token);
18
        filterChain.doFilter(servletRequest, servletResponse);
19

20
    }
21

22
    @Override
23
    public void destroy() {
24

25
    }
26
}

1
public class AuthenticationUtil {
2
    private static ThreadLocal<String> localVar = new ThreadLocal<String>();
3

4
    public static Object getPrincipal() throws NoInfoException, InfoExpiredException {
5
        String token = localVar.get();
6
        Object info = WdTokenHolder.getInfo(token);
7
        return info;
8
    }
9

10
    public static void setToken(String token) {
11
        localVar.set(token);
12
    }
13
}

行政区域(/admin/region/list)#

核心点：三层嵌套如何封装：可以多表查询，也可以通过流全部查出，然后拼接

行政区域的省、市、区县逐级封装

可以先把所有的Region表信息都查出来

把type为1的全部筛选出来 → 所有的省的list
把type为2的全部筛选出来 → 所有的市的list
把type为3的全部筛选出来 → 所有的区的list

同时获得Pid和RegionList的对应Map，比如根据山东省的id，就可以获得山东省的市的List，再比如根据武汉市的id可以获得武汉市的区的List

然后省市区三层遍历，分别进行封装

1
private void list(HttpServletRequest request, HttpServletResponse response) throws IOException {
2
    List<RegionVo> regionVoList = new ArrayList<>();
3

4
    List<MarketRegion> marketRegions = regionService.getAll();
5
    Map<Byte, List<MarketRegion>> collect = marketRegions.stream().collect(Collectors.groupingBy(MarketRegion::getType));
6
    byte provinceType = 1;
7
    List<MarketRegion> provinceList = collect.get(provinceType);
8
    byte cityType = 2;
9
    List<MarketRegion> city = collect.get(cityType);
10
    Map<Integer, List<MarketRegion>> cityListMap = city.stream().collect(Collectors.groupingBy(MarketRegion::getPid));
11
    byte areaType = 3;
12
    List<MarketRegion> areas = collect.get(areaType);
13
    Map<Integer, List<MarketRegion>> areaListMap = areas.stream().collect(Collectors.groupingBy(MarketRegion::getPid));
14

15
    for (MarketRegion province : provinceList) {
16
        RegionVo provinceVO = new RegionVo();
17
        provinceVO.setId(province.getId());
18
        provinceVO.setName(province.getName());
19
        provinceVO.setCode(province.getCode());
20
        provinceVO.setType(province.getType());
21

22
        List<MarketRegion> cityList = cityListMap.get(province.getId());
23
        List<RegionVo> cityVOList = new ArrayList<>();
24
        for (MarketRegion cityVo : cityList) {
25
            RegionVo cityVO = new RegionVo();
26
            cityVO.setId(cityVo.getId());
27
            cityVO.setName(cityVo.getName());
28
            cityVO.setCode(cityVo.getCode());
29
            cityVO.setType(cityVo.getType());
30

31
            List<MarketRegion> areaList = areaListMap.get(cityVo.getId());
32
            List<RegionVo> areaVOList = new ArrayList<>();
33
            for (MarketRegion area : areaList) {
34
                RegionVo areaVO = new RegionVo();
35
                areaVO.setId(area.getId());
36
                areaVO.setName(area.getName());
37
                areaVO.setCode(area.getCode());
38
                areaVO.setType(area.getType());
39
                areaVOList.add(areaVO);
40
            }
41

42
            cityVO.setChildren(areaVOList);
43
            cityVOList.add(cityVO);
44
        }
45
        provinceVO.setChildren(cityVOList);
46
        regionVoList.add(provinceVO);
47
    }
48
    ResponseUtil.responseJson(response, BaseRespVo.ok(CommonData.data(regionVoList)));
49
}

订单列表(/admin/order/list)#

核心点：这里涉及到很多不同类型的请求参数的接收，并且要关注空值的判断，还需要关注条件查询和分页查询

market_order表

1
@SneakyThrows
2
private void list(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
3
    Integer userId = request.getParameter("userId") == null ? null : Integer.parseInt(request.getParameter("userId"));
4
    String orderSn = request.getParameter("orderSn");
5
    DateTimeFormatter formatter = DateTimeFormatter.ofPattern(WdConstant.DEFAULT_DATETIME_PATTERN);
6
    //LocalDateTime start = LocalDateTime.parse(request.getParameter("start"), formatter);
7
    //LocalDateTime end = LocalDateTime.parse(request.getParameter("end"), formatter);
8
    SimpleDateFormat df = new SimpleDateFormat();
9
    Date start = StringUtil.isEmpty(request.getParameter("start")) ? null : df.parse(request.getParameter("start"));
10
    Date end = StringUtil.isEmpty(request.getParameter("end")) ? null : df.parse(request.getParameter("end"));
11
    List<Short> orderStatusArray = new ArrayList<>();
12
    String[] orderStatusArrays = request.getParameterValues("orderStatusArray");
13
    if (!ArrayUtil.isEmpty(orderStatusArrays)) {
14
        orderStatusArray = Arrays.asList(orderStatusArrays).stream().map(Short::valueOf).collect(Collectors.toList());
15
    }
16
    Integer page = Integer.parseInt(request.getParameter("page"));
17
    Integer limit = Integer.parseInt(request.getParameter("limit"));
18
    String sort = request.getParameter("sort");
19
    String order = request.getParameter("order");
20
    CommonData<MarketOrder> commonData = orderService.list(userId, orderSn, start, end, orderStatusArray, page, limit, sort, order);
21
    ResponseUtil.responseJson(response, BaseRespVo.ok(commonData));
22
}

OrderServiceImpl中的list方法

1
@Override
2
public CommonData list(Integer userId, String orderSn, Date start, Date end, List<Short> orderStatusArray, Integer page, Integer limit, String sort, String order) {
3
    MarketOrderExample example = new MarketOrderExample();
4
    MarketOrderExample.Criteria criteria = example.createCriteria();
5

6
    if (userId != null) {
7
        criteria.andUserIdEqualTo(userId);
8
    }
9
    if (!StringUtil.isEmpty(orderSn)) {
10
        criteria.andOrderSnEqualTo(orderSn);
11
    }
12
    if(start != null){
13
        criteria.andAddTimeGreaterThanOrEqualTo(start);
14
    }
15
    if(end != null){
16
        criteria.andAddTimeLessThanOrEqualTo(end);
17
    }
18
    if (orderStatusArray != null && orderStatusArray.size() != 0) {
19
        criteria.andOrderStatusIn(orderStatusArray);
20
    }
21
    criteria.andDeletedEqualTo(false);
22

23
    if (!StringUtil.isEmpty(sort) && !StringUtil.isEmpty(order)) {
24
        example.setOrderByClause(sort + " " + order);
25
    }
26

27
    MarketOrderMapper orderMapper = sqlSessionFactory.openSession().getMapper(MarketOrderMapper.class);
28
    PageHelper.startPage(page, limit);
29
    List<MarketOrder> marketOrders = orderMapper.selectByExample(example);
30
    return CommonData.data(new PageInfo(marketOrders));
31
}

订单详情(/admin/order/detail)#

核心点：根据order、order_goods和user之间的关系来做查询

查询market_order\market_order_goods\market_user

（直接参考代码文件AdminOrderServlet、OrderService和实现类、OrderGoodsService和实现类、UserService和实现类）

订单退款(/admin/order/refund)#

核心点：修改订单状态、商品货品增加、返还优惠券，需要增加事务（

）

保证当前这个请求过程，执行的增删改操作使用的都是同一个SqlSession，那么使用ThreadLocal来管理SqlSession

我们可以创建一个工具类，

开启事务的方法，创建SqlSession并且保存起来
获取SqlSession（或先获取SqlSession，然后进一步获得Mapper实例）
提交事务方法

1
public class TransactionUtil {
2
    private static ThreadLocal<SqlSession> localVar = new ThreadLocal<SqlSession>();
3

4
    public static void startTransaction() {
5
        setSqlSession();
6
    }
7

8
    public static void commit() {
9
        SqlSession sqlSession = localVar.get();
10
        System.out.println("sqlSession = " + sqlSession);
11
        if (sqlSession != null) {
12
            sqlSession.commit();
13
            sqlSession.close();
14
        }
15
    }
16

17
    private static void setSqlSession() {
18
        SqlSession sqlSession = MyBatisUtil.getSqlSessionFactory().openSession();
19
        System.out.println("存入sqlSession = " + sqlSession);
20
        localVar.set(sqlSession);
21
    }
22

23
    public static SqlSession getSqlSession() {
24
        return localVar.get();
25
    }
26

27
    public static <T> T getMapper(Class<T> mapperClass) {
28
        T mapper = getSqlSession().getMapper(mapperClass);
29
        return mapper;
30
    }
31
}

其他代码参考：OrderServiceImpl、CouponUserServiceImpl、LogServiceImpl、orderGoodsServiceImpl

订单物流(/admin/order/channel)#

核心点：可以将这个物流信息放在配置文件中加载

查询物流信息

1
public class VendorsProperties {
2
    private static List<Map<String, String>> vendors=new ArrayList<>();
3
    static {
4
        InputStream inputStream = VendorsProperties.class.getClassLoader().getResourceAsStream("express_vendors.properties");
5
        Properties properties = new Properties();
6
        try {
7
            properties.load(new InputStreamReader(inputStream,"utf-8"));
8
        } catch (IOException e) {
9
            e.printStackTrace();
10
        }
11
        Enumeration<?> enumeration = properties.propertyNames();
12
        while (enumeration.hasMoreElements()) {
13
            String key = (String) enumeration.nextElement();
14
            String value = properties.getProperty(key);
15
            HashMap<String, String> map = new HashMap<>();
16
            map.put("code", key);
17
            map.put("name",value);
18
            vendors.add(map);
19
        }
20
    }
21

22
    public static List<Map<String, String>> getVendors() {
23
        return vendors;
24
    }
25
}

配置文件express_vendors.properties

1
ZTO=中通快递
2
YTO=圆通速递
3
YD=韵达速递
4
YZPY=邮政快递包裹
5
EMS=EMS
6
DBL=德邦快递
7
FAST=快捷快递
8
ZJS=宅急送
9
TNT=TNT快递
10
UPS=UPS
11
DHL=DHL
12
FEDEX=FEDEX联邦(国内件)
13
FEDEX_GJ=FEDEX联邦(国际件)

订单发货(/admin/order/ship)#

核心点：和退款一样,修改订单状态，同时完成日志的记录，需要增加事务

修改订单状态

参考OrderServiceImpl、LogServiceImpl

订单删除(/admin/order/delete)#

核心点：和退款一样,修改订单的deleted字段，同时修改orderGoods中的deleted字段，同时完成日志的记录，需要增加事务

去掉该订单信息，可以物理删除，也可以逻辑删除

参考OrderServiceImpl、LogServiceImpl

图片上传(/admin/storage/create)#

核心点：使用getPart方法获得文件部分，然后获得InputStream，然后通过工具方法做保存

使用InputStream存储到指定位置，同时生成storage记录存储到market_storage表中

1
private void create(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
2
    Part filePart = request.getPart("file");
3
    InputStream inputStream = filePart.getInputStream();
4
    String originFileName = filePart.getSubmittedFileName();
5
    MarketStorage marketStorage = storageService.store(inputStream, filePart.getSize(),
6
            filePart.getContentType(), originFileName);
7
    ResponseUtil.responseOkJsonVo(response,marketStorage);
8
}

1
public class StorageServiceImpl implements StorageService {
2
    private LocalStorage storage = new LocalStorage();
3
    @Override
4
    public MarketStorage store(InputStream inputStream, long size, String contentType, String fileName) {
5
        String key = generateKey(fileName);
6
        storage.store(inputStream, size, contentType, key);
7

8
        String url = generateUrl(key);
9
        MarketStorage storageInfo = new MarketStorage();
10
        storageInfo.setName(fileName);
11
        storageInfo.setSize((int) size);
12
        storageInfo.setType(contentType);
13
        storageInfo.setKey(key);
14
        storageInfo.setUrl(url);
15
        this.add(storageInfo);
16

17
        return storageInfo;
18
    }
19

20
    @Override
21
    public int add(MarketStorage storageInfo) {
22
        Date now = new Date();
23
        storageInfo.setAddTime(now);
24
        storageInfo.setUpdateTime(now);
25
        MarketStorageMapper storageMapper = TransactionUtil.getMapper(MarketStorageMapper.class);
26
        int insert = storageMapper.insert(storageInfo);
27
        TransactionUtil.commit();
28
        return insert;
29
    }
30

31
    private String generateUrl(String key) {
32
    // 这个前缀也可以写在配置文件中
33
        return "http://localhost:8083/wx/storage/fetch/" + key;
34
    }
35

36
    private String generateKey(String originalFilename) {
37
        int index = originalFilename.lastIndexOf('.');
38
        String suffix = originalFilename.substring(index);
39

40
        String key = UUID.randomUUID().toString().replaceAll("-","") + suffix;
41

42
        return key;
43
    }
44
}

商品创建(/admin/goods/create)#

核心点：需要增加market_goods、market_goods_product、market_goods_attribute、market_goods_specification，同时需要关注brand和category的校验；JSON字符串对应的Java实体类，可以借助GsonFormat(Plus)工具来辅助生成；数据库的JDBC类型和Java中的类型不一致，可以使用MyBatis的TypeHandler

创建商品涉及多张表，要使用事务

参考GoodsServiceImpl、GoodsAttributeServiceImpl、GoodsProductServiceImpl、GoodsSpecificationServiceImpl、BrandServiceImpl、CategoryServiceImpl

1
public BaseRespVo create(GoodsVo goodsVo) {
2
    TransactionUtil.startTransaction();
3
    try {
4
        BaseRespVo error = validate(goodsVo);
5
        if (error != null) {
6
            return error;
7
        }
8

9
        MarketGoods goods = goodsVo.getGoods();
10
        MarketGoodsAttribute[] attributes = goodsVo.getAttributes();
11
        MarketGoodsSpecification[] specifications = goodsVo.getSpecifications();
12
        MarketGoodsProduct[] products = goodsVo.getProducts();
13

14
        String name = goods.getName();
15
        if (this.checkExistByName(name)) {
16
            return BaseRespVo.fail(611, "商品名已经存在");
17
        }
18

19
        // 商品表里面有一个字段retailPrice记录当前商品的最低价
20
        BigDecimal retailPrice = new BigDecimal(Integer.MAX_VALUE);
21
        for (MarketGoodsProduct product : products) {
22
            BigDecimal productPrice = product.getPrice();
23
            if(retailPrice.compareTo(productPrice) == 1){
24
                retailPrice = productPrice;
25
            }
26
        }
27
        goods.setRetailPrice(retailPrice);
28

29
        // 商品基本信息表market_goods
30
        this.add(goods);
31

32

33
        // 商品规格表market_goods_specification
34
        for (MarketGoodsSpecification specification : specifications) {
35
            specification.setGoodsId(goods.getId());
36
            specification.setId(null);
37
            specificationService.add(specification);
38
        }
39

40
        // 商品参数表market_goods_attribute
41
        for (MarketGoodsAttribute attribute : attributes) {
42
            attribute.setGoodsId(goods.getId());
43
            attribute.setId(null);
44
            attributeService.add(attribute);
45
        }
46

47
        // 商品货品表market_product
48
        for (MarketGoodsProduct product : products) {
49
            product.setId(null);
50
            product.setGoodsId(goods.getId());
51
            productService.add(product);
52
        }
53
    } catch (Exception exception) {
54
        exception.printStackTrace();
55
        TransactionUtil.rollback();
56
    }
57
    TransactionUtil.commit();
58
    return BaseRespVo.ok();
59
}

优惠券列表(/admin/coupon/list)#

核心点：做优惠券信息的条件查询

1
private void list(HttpServletRequest request, HttpServletResponse response) throws IOException {
2
    String name = request.getParameter("name");
3
    String typeStr = request.getParameter("type");
4
    Short type = StringUtil.isNotEmpty(typeStr)?Short.parseShort(typeStr):null;
5
    Short status = StringUtil.isNotEmpty(request.getParameter("status"))?Short.parseShort(request.getParameter("status")):null;
6
    Integer page = StringUtil.isNotEmpty(request.getParameter("page"))?Integer.parseInt(request.getParameter("page")):null;
7
    Integer limit = StringUtil.isNotEmpty(request.getParameter("limit"))?Integer.parseInt(request.getParameter("limit")):null;
8
    String sort = request.getParameter("sort");
9
    String order = request.getParameter("order");
10
    CommonData<MarketCoupon> data = couponService.querySelective(name, type, status, page, limit, sort, order);
11
    ResponseUtil.responseJson(response, BaseRespVo.ok(data));
12
}

1
public class CouponServiceImpl implements CouponService {
2
    @Override
3
    public CommonData<MarketCoupon> querySelective(String name, Short type, Short status, Integer page, Integer limit, String sort, String order) {
4
        MarketCouponExample example = new MarketCouponExample();
5
        MarketCouponExample.Criteria criteria = example.createCriteria();
6

7
        if (!StringUtil.isEmpty(name)) {
8
            criteria.andNameLike("%" + name + "%");
9
        }
10
        if (type != null) {
11
            criteria.andTypeEqualTo(type);
12
        }
13
        if (status != null) {
14
            criteria.andStatusEqualTo(status);
15
        }
16
        criteria.andDeletedEqualTo(false);
17

18
        if (!StringUtil.isEmpty(sort) && !StringUtil.isEmpty(order)) {
19
            example.setOrderByClause(sort + " " + order);
20
        }
21

22
        PageHelper.startPage(page, limit);
23
        MarketCouponMapper couponMapper = MyBatisUtil.getMapper(MarketCouponMapper.class);
24
        List<MarketCoupon> marketCoupons = couponMapper.selectByExample(example);
25
        return CommonData.data(marketCoupons);
26
    }
27
}

优惠券创建(/admin/coupon/create)#

核心点：提前做好Jackson的日期序列化和反序列化的配置

创建过程中涉及到日期的Json字符串参数

1
@Override
2
public BaseRespVo create(MarketCoupon coupon) {
3
    BaseRespVo error = validate(coupon);
4
    if (error != null) {
5
        return error;
6
    }
7

8
    // 如果是兑换码类型，则这里需要生存一个兑换码
9
    if (coupon.getType().equals(2)) {
10
        String code = this.generateCode();
11
        coupon.setCode(code);
12
    }
13
    TransactionUtil.startTransaction();
14
    coupon.setId(null);
15
    this.add(coupon);
16
    TransactionUtil.commit();
17
    return BaseRespVo.ok(coupon);
18
}

商场配置(/admin/mall/config)#

核心点：请求方法不同，业务处理的方式不同

GET请求做查询

POST请求做更新

1
@WebServlet("/admin/config/*")
2
public class AdminConfigServlet extends WdBaseServlet{
3
    private SystemConfigService systemConfigService = new SystemConfigServiceImpl();
4
    @Override
5
    protected void handle(String operation, HttpServletRequest request, HttpServletResponse response) throws IOException {
6
        switch (operation) {
7
            case "/mall":
8
                mall(request, response);
9
                break;
10
        }
11
    }
12

13
    private void mall(HttpServletRequest request, HttpServletResponse response) throws IOException {
14
        String method = request.getMethod();
15
        if ("GET".equals(method)) {
16
            //GET方法做查询
17
            mallQuery(request, response);
18
        }else {
19
            //POST方法做更新
20
            mallModify(request, response);
21
        }
22
    }
23

24
    private void mallModify(HttpServletRequest request, HttpServletResponse response) throws IOException {
25
        String jsonStr = request.getReader().readLine();
26
        Map<String, String> data = JacksonUtil.read(jsonStr, Map.class);
27
        systemConfigService.updateConfig(data);
28
        ResponseUtil.responseOkJsonVo(response,null);
29
    }
30

31
    private void mallQuery(HttpServletRequest request, HttpServletResponse response) throws IOException {
32
        Map<String, String> data = systemConfigService.listMall();
33
        ResponseUtil.responseOkJsonVo(response,data);
34
    }
35
}

用户统计(/admin/stat/user)#

核心点：使用groupby语句来统计，需要关注封装的格式，因为前端的图表中接收固定格式的数据才能正确的显示

1
private void user(HttpServletRequest request, HttpServletResponse response) throws IOException {
2
    List<Map> rows = statService.statUser();
3
    String[] columns = new String[]{"day", "users"};
4
    StatVo statVo = new StatVo();
5
    statVo.setColumns(columns);
6
    statVo.setRows(rows);
7
    ResponseUtil.responseOkJsonVo(response,statVo);
8
}

1
select
2
        substr(add_time,1,10) as day,
3
        count(distinct id) as users
4
        from market_user
5
        group by substr(add_time,1,10)

项目1个人接口开发指导#

依赖#

通用部分#

跨域#

初始化（选做）#

个人信息（跨域导致Session失效的情况）#

全局的Json转换#

Json响应字符串工具#

常量管理#

URI分析后缀#

分页配置#

具体部分#

登录 (/admin/auth/login)#

个人信息 (/admin/auth/info)#

行政区域(/admin/region/list)#

订单列表(/admin/order/list)#

订单详情(/admin/order/detail)#

订单退款(/admin/order/refund)#

订单物流(/admin/order/channel)#

订单发货(/admin/order/ship)#

订单删除(/admin/order/delete)#

图片上传(/admin/storage/create)#

商品创建(/admin/goods/create)#

优惠券列表(/admin/coupon/list)#

优惠券创建(/admin/coupon/create)#

商场配置(/admin/mall/config)#

用户统计(/admin/stat/user)#

文章分享

文章目录

Java Web 开发：项目一个人开发指导

项目1个人接口开发指导#

依赖#

通用部分#

跨域#

初始化（选做）#

个人信息（跨域导致Session失效的情况）#

全局的Json转换#

Json响应字符串工具#

常量管理#

URI分析后缀#

分页配置#

具体部分#

登录 (/admin/auth/login)#

个人信息 (/admin/auth/info)#

行政区域(/admin/region/list)#

订单列表(/admin/order/list)#

订单详情(/admin/order/detail)#

订单退款(/admin/order/refund)#

订单物流(/admin/order/channel)#

订单发货(/admin/order/ship)#

订单删除(/admin/order/delete)#

图片上传(/admin/storage/create)#

商品创建(/admin/goods/create)#

优惠券列表(/admin/coupon/list)#

优惠券创建(/admin/coupon/create)#

商场配置(/admin/mall/config)#

用户统计(/admin/stat/user)#

文章分享

文章目录