瑞吉外卖实战项目全攻略——第二天

瑞吉外卖实战项目全攻略——第二天

该系列将记录一份完整的实战项目的完成过程,该篇属于第二天

案例来自B站黑马程序员Java项目实战《瑞吉外卖》,请结合课程资料阅读以下内容

该篇我们将完成以下内容:

  • 完善登陆系统
  • 新增员工
  • 员工信息分页查询
  • 启用/禁止员工账号
  • 编辑员工信息

完善登陆系统

我们的功能完善一般分为三步

需求分析

我们在前面的文章中已经实现了login的系统登录

但是我们页面的访问并没有设置限制,如果我们直接跳过登陆页面直接输入系统内部页面的url同样可以进入

瑞吉外卖实战项目全攻略——第二天

所以我们在进入内部页面时需要先进行检测用户是否登录

我们在之前的login功能中如果登陆成功就会给Session加入一个employee的ID值,我们凭借ID来判断是否登录

此外,我们需要在进入页面之前进行判断,那么我们就需要构造一个过滤器或者拦截器,下面我们采用过滤器Filter实现

代码实现

我们创建一个filter文件夹专门存放filter过滤器

下面我们根据逻辑进行代码实现过程:

package com.qiuluo.reggie.filter;  import com.alibaba.fastjson.JSON; import com.qiuluo.reggie.common.Result; import lombok.extern.slf4j.Slf4j; import org.springframework.util.AntPathMatcher;  import javax.servlet.*; import javax.servlet.annotation.WebFilter; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.IOException;  /**  * 检查用户是否已经完成登录  */  // 注意:需要在启动类上添加@ServletComponentScan注解来帮助识别过滤器 // 过滤器需要添加@WebFilter,设置filterName过滤器名,urlPatterns选择过滤路径 @WebFilter(filterName = "loginCheckFilter",urlPatterns = "/*") @Slf4j // 注意:需要继承Filter过滤器 public class LoginCheckFilter implements Filter{          //路径匹配器,支持通配符(类似于工具类,带有方法)     public static final AntPathMatcher PATH_MATCHER = new AntPathMatcher();      // 实现doFilter方法     @Override     public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {                  // 类型转换,便于使用对应方法         HttpServletRequest request = (HttpServletRequest) servletRequest;         HttpServletResponse response = (HttpServletResponse) servletResponse;          //1、获取本次请求的URI:/backend/index.html         String requestURI = request.getRequestURI();          log.info("拦截到请求:{}",requestURI);          // 中间步骤:定义不需要处理的请求路径         String[] urls = new String[]{                 "/employee/login",                 "/employee/logout",                 "/backend/**",                 "/front/**"         };           //2、判断本次请求是否需要处理         boolean check = check(urls, requestURI);          //3、如果不需要处理,则直接放行         if(check){             log.info("本次请求{}不需要处理",requestURI);             filterChain.doFilter(request,response);             return;         }          //4、判断登录状态,如果已登录,则直接放行         if(request.getSession().getAttribute("employee") != null){             log.info("用户已登录,用户id为:{}",request.getSession().getAttribute("employee"));             filterChain.doFilter(request,response);             return;         }          log.info("用户未登录");         //5、如果未登录则返回未登录结果,通过输出流方式向客户端页面响应数据         //(前端代码需要我们返回一个"NOTLOGIN"来告诉前端没有登录)         response.getWriter().write(JSON.toJSONString(Result.error("NOTLOGIN")));         return;      }      /**      * 路径匹配,检查本次请求是否需要放行      * @param urls      * @param requestURI      * @return      */     public boolean check(String[] urls,String requestURI){         for (String url : urls) {             boolean match = PATH_MATCHER.match(url, requestURI);             if(match){                 return true;             }         }         return false;     } } 

实际测试

我们首先需要采用clean,清除之前存有的数据操作

直接在浏览器输入系统内部网页的登录URL,如果代码正确,我们会闪回到登陆界面进行登录

新增员工

我们的功能完善一般分为三步

需求分析

我们在系统内部页面中点击新增员工,会跳转到另一个页面,这属于前端工作

接下来我们在页面中填写信息,前端会将这些信息封装起来,以Employee的形式发送给后端端口

瑞吉外卖实战项目全攻略——第二天

我们打开F12,输入数据点击保存后查看数据的请求方式(点击负载,可以查看到填写信息的Employee内容,这里不再展示):

瑞吉外卖实战项目全攻略——第二天

这个请求方式的路径就是我们需要完善的代码URL的路径

代码开发

现在我们来到IDEA中进行简单的开发:

package com.qiuluo.reggie.controller;  import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.qiuluo.reggie.common.Result; import com.qiuluo.reggie.domain.Employee; import com.qiuluo.reggie.service.EmployeeService; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.util.DigestUtils; import org.springframework.web.bind.annotation.*;  import javax.servlet.http.HttpServletRequest; import java.time.LocalDateTime;  @Slf4j @RestController @RequestMapping("/employee") public class EmployeeController {      @Autowired     private EmployeeService employeeService;      /**      * 新增员工      * @param employee      * @return      */     @PostMapping     public Result<String> save(HttpServletRequest request,@RequestBody Employee employee){         // 日志输出         log.info("添加员工");          // 1.根据数据库的设置,补全相关信息(密码,注册事件,修改时间,注册人ID,修改人ID)         employee.setPassword(DigestUtils.md5DigestAsHex("123456".getBytes()));          employee.setCreateTime(LocalDateTime.now());         employee.setUpdateTime(LocalDateTime.now());          Long empId = (Long) request.getSession().getAttribute("employee");          employee.setCreateUser(empId);         employee.setUpdateUser(empId);          // 2.调用业务层方法直接新增数据进入数据库中         employeeService.save(employee);          // 3.返回Result返回体         return Result.success("新增员工成功");     }  }  

实际测试

在主页面输入相关资料后,查看数据库是否发生改变即可(因为主页面的分页操作还未完成,我们无法在前台看到信息)

异常处理

在介绍下一节之前,我们需要注意:

  • 数据库中的ID设为主键,意味着我们的账号只能设置单独的ID

因此,如果我们连续两次输入ID相同的员工创建,就会报错导致程序出现异常

因此我们需要对异常进行处理,异常处理通常分为两种方法:

  • 在Controller方法中使用try,catch进行异常捕获
  • 使用异常处理器进行全局异常捕获

第一种方法只能作用在当前情况下,但这种情况并不仅仅在当前情况出现,例如我们修改id如果修改为相同id也会报错

第二种方法可以作用在全局状态下,只要遇见这种问题,我们都会进行处理

因此我们采用第二种方法处理:

package com.qiuluo.reggie.common;  import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.*;  import java.sql.SQLIntegrityConstraintViolationException;  /**  * 全局异常处理  * @ControllerAdvice 来书写需要修改异常的注解类(该类中包含以下注解)  * @ResponseBody 因为返回数据为JSON数据,需要进行格式转换  */ @ControllerAdvice(annotations = {RestController.class, Controller.class}) @ResponseBody @Slf4j public class GlobalExceptionHandler {      /**      * 处理异常      * @ExceptionHandler 来书写需要修改的异常      * SQLIntegrityConstraintViolationException.class是我们错误时系统弹出的,直接复制即可      * @return      */     @ExceptionHandler(SQLIntegrityConstraintViolationException.class)     public Result<String> exceptionHandler(SQLIntegrityConstraintViolationException ex){          // 我们可以通过log.error输出错误提醒         // (我们可以得到以下提示信息:Duplicate entry '123' for key 'employee.idx_username')         log.error(ex.getMessage());         // 我们希望将id:123提取出来做一个简单的反馈信息         if (ex.getMessage().contains("Duplicate entry")){             String[] split = ex.getMessage().split(" ");             String msg = split[2] + "已存在";             return Result.error(msg);         }         return Result.error("未知错误");     }  } 

员工信息分页查询

我们的功能完善一般分为三步

需求分析

我们要将数据库信息通过分页查询的方法查询出来并反馈到页面中

我们打开页面后,直接查找报错的部分,查看其请求信息以及相关URL:
瑞吉外卖实战项目全攻略——第二天

打开负载,查看传递的信息:

瑞吉外卖实战项目全攻略——第二天

还需要注意的是,当我们输入查询信息后,我们会多一个参数name,这个参数也需要进行后台操作:

瑞吉外卖实战项目全攻略——第二天

我们需要注意的是我们采用的是数据库的分页查询,因此我们需要设置一个分页插件来将数据插入

此外我们的代码书写只需要采用page,pageSize查询数据,将name进行近似匹配并当作查询条件即可

代码实现

首先我们先来实现分页插件:

package com.qiuluo.reggie.config;  import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor; import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration;  /**  * 配置MP的分页插件  * 注意:设置为配置类,使Spring可以搜索到  */ @Configuration public class MyBatisPlusConfig {      // 设置为Bean,受管理权限     @Bean     public MybatisPlusInterceptor mybatisPlusInterceptor(){         // 1.创建一个大型Interceptor          MybatisPlusInterceptor mybatisPlusInterceptor = new MybatisPlusInterceptor();         // 2.添加PaginationInnerInterceptor进Interceptor里即可         mybatisPlusInterceptor.addInnerInterceptor(new PaginationInnerInterceptor());         // 3.返回Interceptor          return mybatisPlusInterceptor;     } } 

接下来再来实现主页面的代码:

package com.qiuluo.reggie.controller;  import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.qiuluo.reggie.common.Result; import com.qiuluo.reggie.domain.Employee; import com.qiuluo.reggie.service.EmployeeService; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.util.DigestUtils; import org.springframework.web.bind.annotation.*;  import javax.servlet.http.HttpServletRequest; import java.time.LocalDateTime;  @Slf4j @RestController @RequestMapping("/employee") public class EmployeeController {      @Autowired     private EmployeeService employeeService;      /**      * 员工信息分页查询      */     @GetMapping("/page")     public Result<Page> page(int page, int pageSize, String name){          // 构造分页构造器         Page pageInfo = new Page(page,pageSize);         // 构造条件构造器         LambdaQueryWrapper<Employee> queryWrapper = new LambdaQueryWrapper<>();         queryWrapper.like(StringUtils.isNotEmpty(name),Employee::getName,name);         // 添加排序条件         queryWrapper.orderByDesc(Employee::getUpdateTime);         // 执行查询         employeeService.page(pageInfo,queryWrapper);         return Result.success(pageInfo);     }  }  

实际测试

打开主页面,数据出现即为成功

启动/禁用员工账号

我们的功能完善一般分为三步

需求分析

当点击我们的员工行列后的启动/禁止,数据库的Status进行转换

我们同样点击后打开F12查看请求URL以及参数:

瑞吉外卖实战项目全攻略——第二天

瑞吉外卖实战项目全攻略——第二天

我们可以看到它将id作为判断员工的标准,将status的值传入便于我们修改

其中前端将修改状态的操作和修改员工信息的操作列为同一个请求,所以我们直接完成修改员工全部信息的操作即可

代码实现

我们直接书写后端代码:

package com.qiuluo.reggie.controller;  import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.qiuluo.reggie.common.Result; import com.qiuluo.reggie.domain.Employee; import com.qiuluo.reggie.service.EmployeeService; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.util.DigestUtils; import org.springframework.web.bind.annotation.*;  import javax.servlet.http.HttpServletRequest; import java.time.LocalDateTime;  @Slf4j @RestController @RequestMapping("/employee") public class EmployeeController {      @Autowired     private EmployeeService employeeService;      /**      * 根据id修改员工信息      * @param employee      * @return      */     @PutMapping     public Result<String> update(HttpServletRequest request,@RequestBody Employee employee){          // 1.得到当前修改人的id         long empId = (long)request.getSession().getAttribute("employee");          // 2.对被修改员工的修改时间和修改人进行修改         employee.setUpdateTime(LocalDateTime.now());         employee.setUpdateUser(empId);          // 3.直接将数据修改即可(被修改的数据已经被封装到了employee中,所以我们直接传递即可)         employeeService.updateById(employee);          return Result.success("更新成功");     }  } 

实际测试

我们点击启动或者禁用,数据库或前端页面的状态码发生变化,即为成功

异常处理

如果按照上述操作进行,是无法成功修改状态的,但是程序也不会发生报错

这是因为我们的数据库ID中设置长度为19位,但是我们的JS处理器的Long类型只能精确到前16位

这就会导致我们的ID数据的最后三位在传递时变化为000,导致前端传递ID与数据库实际ID无法匹配,无法成功修改

我们采用的处理方法是将服务端传递的JSON数据进行处理,我们希望将Long类型的数据全部转变为String类型,这样就不会省略为0

具体步骤如下:

  1. 提供对象转换器JacksonObjectMapper,基于Jackson进行Java对象到json数据的转换(资料提供)
package com.qiuluo.reggie.common;  import com.fasterxml.jackson.databind.DeserializationFeature; import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.module.SimpleModule; import com.fasterxml.jackson.databind.ser.std.ToStringSerializer; import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateDeserializer; import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateTimeDeserializer; import com.fasterxml.jackson.datatype.jsr310.deser.LocalTimeDeserializer; import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateSerializer; import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateTimeSerializer; import com.fasterxml.jackson.datatype.jsr310.ser.LocalTimeSerializer;  import java.math.BigInteger; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.LocalTime; import java.time.format.DateTimeFormatter;  import static com.fasterxml.jackson.databind.DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES;  /**  * 对象映射器:基于jackson将Java对象转为json,或者将json转为Java对象  * 将JSON解析为Java对象的过程称为 [从JSON反序列化Java对象]  * 从Java对象生成JSON的过程称为 [序列化Java对象到JSON]  */ public class JacksonObjectMapper extends ObjectMapper {      public static final String DEFAULT_DATE_FORMAT = "yyyy-MM-dd";     public static final String DEFAULT_DATE_TIME_FORMAT = "yyyy-MM-dd HH:mm:ss";     public static final String DEFAULT_TIME_FORMAT = "HH:mm:ss";      public JacksonObjectMapper() {         super();         //收到未知属性时不报异常         this.configure(FAIL_ON_UNKNOWN_PROPERTIES, false);          //反序列化时,属性不存在的兼容处理         this.getDeserializationConfig().withoutFeatures(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES);           SimpleModule simpleModule = new SimpleModule()                 .addDeserializer(LocalDateTime.class, new LocalDateTimeDeserializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_TIME_FORMAT)))                 .addDeserializer(LocalDate.class, new LocalDateDeserializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_FORMAT)))                 .addDeserializer(LocalTime.class, new LocalTimeDeserializer(DateTimeFormatter.ofPattern(DEFAULT_TIME_FORMAT)))                  .addSerializer(BigInteger.class, ToStringSerializer.instance)                 .addSerializer(Long.class, ToStringSerializer.instance)                 .addSerializer(LocalDateTime.class, new LocalDateTimeSerializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_TIME_FORMAT)))                 .addSerializer(LocalDate.class, new LocalDateSerializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_FORMAT)))                 .addSerializer(LocalTime.class, new LocalTimeSerializer(DateTimeFormatter.ofPattern(DEFAULT_TIME_FORMAT)));          //注册功能模块 例如,可以添加自定义序列化器和反序列化器         this.registerModule(simpleModule);     } } 
  1. 在WebMvcConfig配置类中扩展springMvc的消息转换器,在此消息转换器中使用提供的对象转换器进行Java到Json数据的转换
package com.qiuluo.reggie.config;  import com.qiuluo.reggie.common.JacksonObjectMapper; import lombok.extern.slf4j.Slf4j; import org.springframework.context.annotation.Configuration; import org.springframework.http.converter.HttpMessageConverter; import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter; import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry; import org.springframework.web.servlet.config.annotation.WebMvcConfigurationSupport;  import java.util.List;  @Slf4j @Configuration public class WebMvcConfig extends WebMvcConfigurationSupport {      @Override     protected void addResourceHandlers(ResourceHandlerRegistry registry) {         log.info("开始静态映射");          registry.addResourceHandler("/backend/**").addResourceLocations("classpath:/backend/");         registry.addResourceHandler("/front/**").addResourceLocations("classpath:/front/");      }      /**      * 扩展mvc框架的消息转换器      * @param converters      */     @Override     protected void extendMessageConverters(List<HttpMessageConverter<?>> converters) {         log.info("扩展消息转换器...");         //创建消息转换器对象         MappingJackson2HttpMessageConverter messageConverter = new MappingJackson2HttpMessageConverter();         //设置对象转换器,底层使用Jackson将Java对象转为json         messageConverter.setObjectMapper(new JacksonObjectMapper());         //将上面的消息转换器对象追加到mvc框架的转换器集合中         converters.add(0,messageConverter);     } } 

编辑员工信息

我们的功能完善一般分为三步

需求分析

当我们点击页面员工的编辑后,跳转页面:

瑞吉外卖实战项目全攻略——第二天

这里我们需要注意,我们的数据会直接出现在页面中,这说明我们在点击编辑时,后台会将我们的数据传递给前端,前端才能将数据展现出来

所以我们回到上一步,F12查看操作:

瑞吉外卖实战项目全攻略——第二天

我们会发现,它调用了GET类型的请求,并将我们的id传入,这说明我们需要创建一个路径来根据id获得数据

然后我们点击编辑里的保存,查看F12:

瑞吉外卖实战项目全攻略——第二天

我们会发现,这个路径和我们上一步实现的启动禁用账号的路径相同,所以当我们点击修改后自动调用根据id修改参数的方法

代码实现

我们只需要实现第一个方法根据ID获得数据即可:

package com.qiuluo.reggie.controller;  import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.qiuluo.reggie.common.Result; import com.qiuluo.reggie.domain.Employee; import com.qiuluo.reggie.service.EmployeeService; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.util.DigestUtils; import org.springframework.web.bind.annotation.*;  import javax.servlet.http.HttpServletRequest; import java.time.LocalDateTime;  @Slf4j @RestController @RequestMapping("/employee") public class EmployeeController {      @Autowired     private EmployeeService employeeService;      /**      * 根据id查询员工      * @param id      * @return      */     @GetMapping("/{id}")     public Result<Employee> getById(@PathVariable Long id){          // 根据路径获得id,直接调用业务层方法获得employee         Employee emp = employeeService.getById(id);         if (emp != null){             return Result.success(emp);         }else {             return Result.error("未查询成功");         }     } } 

实际测试

返回主页面,点击员工后面的编辑后,跳转页面时带有数据即可

易错点

在这里我们会点出该项目目前容易出错的位置

过滤器的使用

Filter也称之为过滤器,它是Servlet技术中的技术,Web开发人员通过Filter技术,对web服务器管理的所有web资源

实现步骤主要分为两步:

  1. 创建Java类,添加注解,继承Filter
package com.qiuluo.reggie.filter;  import com.alibaba.fastjson.JSON; import com.qiuluo.reggie.common.Result; import lombok.extern.slf4j.Slf4j; import org.springframework.util.AntPathMatcher;  import javax.servlet.*; import javax.servlet.annotation.WebFilter; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.IOException;  /**  * 检查用户是否已经完成登录  */ // @WebFilter注解配置相关信息 @WebFilter(filterName = "loginCheckFilter",urlPatterns = "/*") public class LoginCheckFilter implements Filter{  } 
  1. 继承并书写doFilter方法
package com.qiuluo.reggie.filter;  import com.alibaba.fastjson.JSON; import com.qiuluo.reggie.common.Result; import lombok.extern.slf4j.Slf4j; import org.springframework.util.AntPathMatcher;  import javax.servlet.*; import javax.servlet.annotation.WebFilter; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.IOException;  /**  * 检查用户是否已经完成登录  */ @WebFilter(filterName = "loginCheckFilter",urlPatterns = "/*") @Slf4j public class LoginCheckFilter implements Filter{     //路径匹配器,支持通配符     public static final AntPathMatcher PATH_MATCHER = new AntPathMatcher();           /*     doFilter用来实现过滤功能     在最开始我们设置了需要过滤的路径     doFilter里在来设置在该路径下哪些路径可以直接跳过     doFilter里也可以设置需要经过哪些判断或哪些处理才能经过     filterChain携带req和resp来表示通过过滤器         */     @Override     public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {         HttpServletRequest request = (HttpServletRequest) servletRequest;         HttpServletResponse response = (HttpServletResponse) servletResponse;          //1、获取本次请求的URI         String requestURI = request.getRequestURI();// /backend/index.html          log.info("拦截到请求:{}",requestURI);          //定义不需要处理的请求路径         String[] urls = new String[]{                 "/employee/login",                 "/employee/logout",                 "/backend/**",                 "/front/**"         };           //2、判断本次请求是否需要处理         boolean check = check(urls, requestURI);          //3、如果不需要处理,则直接放行         if(check){             log.info("本次请求{}不需要处理",requestURI);             filterChain.doFilter(request,response);             return;         }          //4、判断登录状态,如果已登录,则直接放行         if(request.getSession().getAttribute("employee") != null){             log.info("用户已登录,用户id为:{}",request.getSession().getAttribute("employee"));             filterChain.doFilter(request,response);             return;         }          log.info("用户未登录");         //5、如果未登录则返回未登录结果,通过输出流方式向客户端页面响应数据         response.getWriter().write(JSON.toJSONString(Result.error("NOTLOGIN")));         return;      }      /**      * 路径匹配,检查本次请求是否需要放行      * @param urls      * @param requestURI      * @return      */     public boolean check(String[] urls,String requestURI){         for (String url : urls) {             boolean match = PATH_MATCHER.match(url, requestURI);             if(match){                 return true;             }         }         return false;     } } 

数据库的分页操作

数据库的分页操作需要在数据库内部的特定位置(limit)处修改值

所以需要设置一个MyBatisPlus拦截器来完成操作,MyBatisPlus已经为我们简化了步骤,我们只需要将相对应的拦截器添加即可:

package com.qiuluo.reggie.config;  import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor; import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration;  /**  * 配置MP的分页插件  */ @Configuration public class MyBatisPlusConfig {      @Bean     public MybatisPlusInterceptor mybatisPlusInterceptor(){         MybatisPlusInterceptor mybatisPlusInterceptor = new MybatisPlusInterceptor();         mybatisPlusInterceptor.addInnerInterceptor(new PaginationInnerInterceptor());         return mybatisPlusInterceptor;     } } 

然后我们就需要注意业务层继承的实现类中所给的方法的参数即可:

package com.qiuluo.reggie.controller;  import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.qiuluo.reggie.common.Result; import com.qiuluo.reggie.domain.Employee; import com.qiuluo.reggie.service.EmployeeService; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.util.DigestUtils; import org.springframework.web.bind.annotation.*;  import javax.servlet.http.HttpServletRequest; import java.time.LocalDateTime;  @Slf4j @RestController @RequestMapping("/employee") public class EmployeeController {      @Autowired     private EmployeeService employeeService;      /**      * 员工信息分页查询      */     @GetMapping("/page")     public Result<Page> page(int page, int pageSize, String name){          // 构造分页构造器         Page pageInfo = new Page(page,pageSize);         // 构造条件构造器         LambdaQueryWrapper<Employee> queryWrapper = new LambdaQueryWrapper<>();         // 这里是一个like自带的判断,如果StringUtils.isNotEmpty(name)为true,才会执行该操作,否则无效         queryWrapper.like(StringUtils.isNotEmpty(name),Employee::getName,name);         // 添加排序条件         queryWrapper.orderByDesc(Employee::getUpdateTime);         // 执行查询(参数为Page和qw类型,所以我们前面创建相应类型填充数据)         employeeService.page(pageInfo,queryWrapper);         return Result.success(pageInfo);     }  } 

消息转换器

首先我们来简单解释一下消息转换器是什么:

  • 消息转换器用于将请求/响应体内部的数据提取出来
  • 例如在请求体中是URL的一部分,但是我们的后台代码中却是参数
  • 消息转换器就是用于这一部分参数的转换,系统中配置了许多默认的消息转换器

但默认的消息转换器有时不能满足我们的需求,例如上述异常处理中,我们希望直接将JSON数据转化为String类型的数据

这时我们就需要手动设置消息转换器:

package com.qiuluo.reggie.config;  import com.qiuluo.reggie.common.JacksonObjectMapper; import lombok.extern.slf4j.Slf4j; import org.springframework.context.annotation.Configuration; import org.springframework.http.converter.HttpMessageConverter; import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter; import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry; import org.springframework.web.servlet.config.annotation.WebMvcConfigurationSupport;  import java.util.List;  @Slf4j @Configuration public class WebMvcConfig extends WebMvcConfigurationSupport {      /**      * 扩展mvc框架的消息转换器      * 其中JacksonObjectMapper是我们自己创建的/下载的消息转换器,里面设置了我们所需要的转换方式      * 下述操作只是将该转换器添加到系统的转换器队列中,以便于能够执行该转换器的操作      * @param converters      */     @Override     protected void extendMessageConverters(List<HttpMessageConverter<?>> converters) {         //创建消息转换器对象         MappingJackson2HttpMessageConverter messageConverter = new MappingJackson2HttpMessageConverter();         //设置对象转换器,底层使用Jackson将Java对象转为json         messageConverter.setObjectMapper(new JacksonObjectMapper());         //将上面的消息转换器对象追加到mvc框架的转换器集合中         converters.add(0,messageConverter);     } } 

结束语

该篇内容到这里就结束了,希望能为你带来帮助~

附录

该文章属于学习内容,具体参考B站黑马程序员的Java项目实战《瑞吉外卖》

这里附上视频链接:业务开发Day2-01-本章内容介绍_哔哩哔哩_bilibili

发表评论

评论已关闭。

相关文章