【苍穹外卖JAVA项目】第2天：新增员工
在EmployeeMapper.java中插入数据：一、新增员工
1.产品原型
2.接口设计
由于需要提交员工信息，用post请求方式，可以携带json数据
3.设计数据库的employee表
4.设计DTO
数据传输对象（DTO）：封装前端提交过来的数据
实体类如下：包含更多属性
public class Employee implements Serializable {private static final long serialVersionUID = 1L;private Long id;private String username;private String name;private String password;private String phone;private String sex;private String idNumber;private Integer status;//@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")private LocalDateTime createTime;//@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")private LocalDateTime updateTime;private Long createUser;private Long updateUser;}5.开发
在EmployeeController.java中创建新增员工的方法：
说明：接收前端的HTTP POST请求，将请求体中的JSON数据转换为
EmployeeDTO对象，记录日志，调用业务逻辑层的save方法来保存员工数据，并返回一个成功的响应
/*** 新增员工* @param employeeDTO* @return*/@PostMapping //表明此方法用来处理客户端发送的POST请求@ApiOperation("新增员工") //为API提供文档说明//@RequestBody主要用来接收前端传递给后端的json对象，并将该对象自动转换为EmployeeDTO类型的实例public Result save(@RequestBody EmployeeDTO employeeDTO){log.info("新增员工：{}",employeeDTO); //日志记录，{}是占位符，用于插入变量的值employeeService.save(employeeDTO); //该方法后续步骤会定义，用于处理保存的逻辑return Result.success(); //Result是自定义的类，用于封装API方法的响应数据}在EmployeeService.java中声明新增员工方法：
/*** 新增员工* @param employeeDTO*/void save(EmployeeDTO employeeDTO);在实现类EmployeeServicelmpl.java中实现新增员工方法：
说明：将
EmployeeDTO对象转换为Employee对象并保存到数据库中
/*** 新增员工** @param employeeDTO*/public void save(EmployeeDTO employeeDTO) {Employee employee = new Employee();//将EmployeeDTO对象的属性复制到Employee对象中BeanUtils.copyProperties(employeeDTO, employee);//设置账号的状态，默认正常状态 1表示正常 0表示锁定employee.setStatus(StatusConstant.ENABLE);//设置密码，默认密码123456employee.setPassword(DigestUtils.md5DigestAsHex(PasswordConstant.DEFAULT_PASSWORD.getBytes()));//设置当前记录的创建时间和修改时间employee.setCreateTime(LocalDateTime.now());employee.setUpdateTime(LocalDateTime.now());//设置当前记录创建人id和修改人idemployee.setCreateUser(10L);//目前写个假数据，后期修改employee.setUpdateUser(10L);employeeMapper.insert(employee);//后续步骤定义，将Employee对象保存到数据库中}在EmployeeMapper.java中插入员工数据：
说明：使用MyBatis框架的Java接口方法，定义了插入员工数据到数据库的操作
/*** 插入员工数据* @param employee*///@Insert是一个MyBatis框架的注解，用来指定SQL插入语句//#{name}、#{username}等是MyBatis的参数占位符，它们将被实际的员工对象属性值所替换@Insert("insert into employee (name, username, password, phone, sex, id_number, create_time, update_time, create_user, update_user,status) " +"values " +"(#{name},#{username},#{password},#{phone},#{sex},#{idNumber},#{createTime},#{updateTime},#{createUser},#{updateUser},#{status})")void insert(Employee employee);6.功能测试
（1）通过前后端联调测试
由于前后端并行开发，后端开发完之后，前端可能没有开发完成，因此此方法局限性大，不常用
添加成功
（2）通过接口文档测试
在接口文档中的员工登录中生成一个jwt令牌，复制到全局参数设置中，刷新页面（令牌会2小时后失效，若报错401的话需要重新生成令牌）
在新增员工中自动添加了请求头部，此时发送请求就可以返回响应，数据库中成功添加了数据
7.代码完善
（1）录入的用户名已存在，抛出异常后没有处理
当重新提交zhangsan的数据时，因数据重复会抛出异常，需要重写异常
说明：异常处理方法，它使用了Spring框架的
@ExceptionHandler注解来捕获并处理特定的异常类型：SQLIntegrityConstraintViolationException
/*** 处理SQL异常* @param ex* @return*/@ExceptionHandler //捕获并处理特定的异常类型public Result exceptionHandler(SQLIntegrityConstraintViolationException ex){//Duplicate entry 'zhangsan' for key 'employee.idx_username'String message = ex.getMessage(); //获取异常的详细信息if(message.contains("Duplicate entry")){String[] sp = message.split(" "); //通过空格分割异常消息，然后提取用户名String username = sp[2];String msg = username + MessageConstant.ALREADY_EXISTS; //自定义的错误消息:用户已存在return Result.error(msg);}else {return Result.error(MessageConstant.UNKNOWN_ERROR);//自定义的错误消息:未知错误}}
（2）新增员工时，创建人id和修改人id设置为了固定值
需要通过某种方式动态获取当前登录员工的id
客户端发送的每一个请求对应一个线程，因此可以把id存入ThreadLocal，再在server里取出来
在使用ThreadLocal时往往会进行一个简单的封装，包装成一个工具类common-context-BaseContext
package com.sky.context;public class BaseContext {public static ThreadLocal<Long> threadLocal = new ThreadLocal<>();public static void setCurrentId(Long id) {threadLocal.set(id);}public static Long getCurrentId() {return threadLocal.get();}public static void removeCurrentId() {threadLocal.remove();}}需要在JwtTokenAdminlnterceptor.java拦截器取出ID：
BaseContext.setCurrentId(empId);需要在EmployeeServicelmpl.java实现类获得ID：
//设置当前记录创建人id和修改人idemployee.setCreateUser(BaseContext.getCurrentId());employee.setUpdateUser(BaseContext.getCurrentId());二、员工分页查询
1.产品原型
2.接口设计
3.设计DTO
4.开发
在EmployeeController.java中创建员工分页查询的方法：
/*** 员工分页查询* @param employeePageQueryDTO* @return*/@GetMapping("/page")@ApiOperation("员工分页查询")public Result<PageResult> page(EmployeePageQueryDTO employeePageQueryDTO){log.info("员工分页查询，参数为：{}", employeePageQueryDTO);PageResult pageResult = employeeService.pageQuery(employeePageQueryDTO); //service存储分页查询的方法return Result.success(pageResult);}在EmployeeService.java中声明员工分页查询方法：
/*** 分页查询方法* @param employeePageQueryDTO* @return*/PageResult pageQuery(EmployeePageQueryDTO employeePageQueryDTO);在实现类EmployeeServicelmpl.java中实现员工分页查询方法：
说明：使用mybatis中的pagehelper插件，已经在初始代码pom.xml中引入，可以简化分页操作，
<dependency><groupId>com.github.pagehelper</groupId><artifactId>pagehelper-spring-boot-starter</artifactId></dependency> /*** 分页查询* @param employeePageQueryDTO* @return*/public PageResult pageQuery(EmployeePageQueryDTO employeePageQueryDTO) {//select * from employee limit 0,10（limit关键字查询第0-10条）//实现原理：将page封装后存入threadlocal，在分页查询前取出来，动态拼接实现SQLPageHelper.startPage(employeePageQueryDTO.getPage(),employeePageQueryDTO.getPageSize());Page<Employee> page = employeeMapper.pageQuery(employeePageQueryDTO); //返回pagehelper格式的对象long total = page.getTotal();List<Employee> records = page.getResult();return new PageResult(total, records);}在EmployeeMapper.java中插入数据：
/*** 员工分页查询* @param employeePageQueryDTO* @return*/Page<Employee> pageQuery(EmployeePageQueryDTO employeePageQueryDTO);说明：使用动态SQL，不再使用注解的方式，需要写到映射文件server-resources-mapper-EmployeeMapper.xml中
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.sky.mapper.EmployeeMapper"><select id="pageQuery" resultType="com.sky.entity.Employee">select * from employee<where><if test="name != null and name != ''">and name like concat('%',#{name},'%')</if></where>order by create_time desc</select>
</mapper>