1. 描述清楚新增员工的实现流程

1.1需求分析与设计

参考产品原型，设计表和接口。

1.1.1设计表

看员工管理的产品原型：

有员工姓名、账号、手机号、账号状态、最后操作时间等。

注意，操作一栏不是字段，其中的启用禁用才是。

再看添加员工的原型：

可以发现还有性别和身份证号。

不要忘了旁边：

还有密码。

总结出了以下字段：

员工姓名name

用户名username

密码password

手机号tel

性别gender

身份证号idNumber

启用禁用状态status

更新时间update_time

这些统称为业务字段。

不过除了这些，还有基础字段：

主键id

创建时间create_time

创建操作人create_user

更新时间update_time

更新操作人update_user

这样就设计完了表。

作为练习，然后我们可以回过头来和设计好的表进行对比，看我们漏了哪一步没有。

可以看到，多了一个昨天加的，用来验证登录的盐值salt，其他都一样。

1.1.2设计接口

设计接口需要设计4个东西：

请求路径
请求参数
请求方式
响应数据

对应我们这个新增员工的接口就是如下设计：

请求路径 /admin/employee（可以加/add，也可以通过请求方式确定添加操作）
请求参数传json（如{“username”:”xxx”, “name”:””, “tel”:””, “sex(或gender)”:””}）
请求方式 POST
响应数据 {“code”:””,”msg(错误信息，错了是什么原因)”:””, data:””}

注意，在公司里，接口设计或多或少都会和现在学的有些出入，这是正常的，习惯一下。

另外，正真在公司里，设计表会比较少，因为就那么几个；但设计接口会比较多。而复杂点的表，小后端的水平也设计不太来。没关系，慢慢学。

1.2代码开发

3步，分别是写Controller、写Service、写Mapper。

1.2.1写入表现层Controller

接受请求参数，调用service完成添加操作，响应结果。

代码如下：

/*** 员工管理*/
@RestController
@RequestMapping("/admin/employee")
@Slf4j
@Api(tags = "硬普洛伊康戳勒 员工相关接口")
public class EmployeeController {@Autowiredprivate EmployeeService employeeService;.../*** 员工新增功能* @param employeeDTO 前端提交的参数* @return 成功的结果*/@PostMappingpublic Result add(@RequestBody EmployeeDTO employeeDTO) {employeeService.addEmp(employeeDTO);return Result.success();}
}

1.2.2写入业务层Service

根据数据库中字段的要求，完善数据，调用mapper完成添加操作。

接口中：

public interface EmployeeService {.../*** 员工新增功能*/void addEmp(EmployeeDTO employeeDTO);
}

实现类中：

@Service
public class EmployeeServiceImpl implements EmployeeService {@Autowiredprivate EmployeeMapper employeeMapper;...@Overridepublic void addEmp(EmployeeDTO employeeDTO) {// employeeDTO: username name phone sex idNumber// database: id password status salt create_tim create_user update_time update_user// our preparing work: password(described in origin) salt create_time update_time// our preparing work: create_user update_user(awkward somehow, do it later)// Create object of EmployeeEmployee employee = new Employee();// copy data in EmployeeDTO to employeeBeanUtils.copyProperties(employeeDTO, employee);// supplement dataLocalDateTime now = LocalDateTime.now();employee.setUpdateTime(now);employee.setCreateTime(now);// TODO create user and update user haven't finish rightlyemployee.setCreateUser(666L);employee.setUpdateUser(666L);String password = "123456";// product a random saltString salt = UUID.randomUUID().toString().replace("-", "");// finish MD5 with both salt and origin passwordpassword = DigestUtils.md5DigestAsHex((password + salt).getBytes());employee.setPassword(password);employee.setSalt(salt);// insertemployeeMapper.insertEmp(employee);}}

注意那个TODO注释，可以在idea下面窗口中显示你还需要完善的代码。

讲到这，老师讲了一个惨痛的经历：

有个老哥，写测试类忘改了，下单都是0.01元，给公司损失了几十上百万……

这老哥被开没开，被告没告，不知道，不过大家一定要吸取教训啊。

1.2.3写入持久层Mapper

@Mapper
public interface EmployeeMapper {/*** 根据用户名查询员工* @param username* @return*/@Select("select * from employee where username = #{username}")Employee getByUsername(String username);/*** 添加员工* @param employee*/void insertEmp(Employee employee);
}

对应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"><insert id="insertEmp">insert into employee (name, username, password, phone, sex, id_number, create_time, update_time, create_user,update_user, salt)value (#{name}, #{username}, #{password}, #{phone}, #{sex}, #{idNumber}, #{createTime}, #{updateTime},#{createUser}, #{updateUser}, #{salt})</insert></mapper>

1.2.4Swagger测试

运行项目，进入Swagger链接：

http://localhost:8080/doc.html

首先到登录接口，用管理员账户登录，获得请求头。

到全局参数设置，加入我们的请求头。

然后进入添加员工界面，输入参数测试是否正常添加员工。

查看显示结果：

1.3代码完善

1.3.1异常处理

用户输入的用户名在数据库中已经存在，这种情况下会报错，需要处理。

解决方式：

在全局异常处理器中添加一个方法，专门处理这个异常；

在异常处理方法中，截取重复的用户名，响应错误信息给前端。

代码：

@ExceptionHandler
public Result sqlIntegrityConstraintViolationExceptionHandler(SQLIntegrityConstraintViolationException ex){String message = ex.getMessage();log.error("异常信息：{}", message);// 1. 判断异常类型是否是想处理的类型 / 是否包含Duplicate entryif (message.contains("Duplicate entry")) {// 2. 如果是，则获取异常message  Duplicate entry 'abc' for key 'employee.idx_username'// 3. 截取用户名信息String username = message.split(" ")[2];// 4. 拼接提示信息 “xxx用户名已存在，请重新输入”// 5. 返回错误信息给前端return Result.error(username+"用户名已存在，请重新输入");}return Result.error(ex.getMessage());
}

1.3.2创建/修改人设置(ThreadLocal)

详见下面第三大问。

1.4测试

1.4.1接口测试

用Swagger。

测试正常添加功能：

在数据库中查看添加人情况：

添加重复名称员工，测试异常处理功能：

1.4.2前端后端联调

测试正常添加功能：

在数据库中查看添加人情况：

添加重复名称员工，测试异常处理功能：

2. 描述清楚员工分页条件查询的实现流程

2.1需求分析

2.1.1分析产品原型扣细节

查询需要加分页和查询条件（模糊匹配，动态SQL）。

排序按照创建时间降序排列。

2.1.2接口设计

请求路径
/admin/employee
至于添加子路径，那得看情况。可能有很多不同种的查询，就加路径；简单情况下，还是用get请求就行了。
所以加路径就/admin/employee/page
请求参数 ?page=1&pageSize=10&name=zhangsan
请求方式 GET
响应数据
{
“code”:1
“msg”:””,（失败才有msg）
“data”:{
“total（或rows）”:100,
“records”: [
{},
{},
]
}
}

2.2代码开发

2.2.1Controller层

@ApiOperation(value = "员工分页查询接口")
@GetMapping("/page")
public Result page(EmployeePageQueryDTO employeePageQueryDTO) {PageResult pr = employeeService.pageQuery(employeePageQueryDTO);return Result.success(pr);
}

2.2.2Service层

@Override
public PageResult pageQuery(EmployeePageQueryDTO employeePageQueryDTO) {// 1. 设置分页参数，开启分页查询PageHelper.startPage(employeePageQueryDTO.getPage(), employeePageQueryDTO.getPageSize());// 2. 调用mapper执行分页查询，返回分页结果对象 PagePage<Employee> page = employeeMapper.selectByPageAndName(employeePageQueryDTO.getName());// 3. 通过分页对象Page中获取当前页的数据和总记录long total = page.getTotal();List<Employee> records = page.getResult();// 4. 封装当前页数据和总记录，封装进PageResult，并返回return new PageResult(total, records);
}

2.2.3Mapper层

<select id="selectByPageAndName" resultType="com.sky.entity.Employee">select * from employee<where><if test="name!=null and name!=''">name like concat('%', #{name}, '%')</if></where>order by create_time desc
</select>

2.3测试

2.3.1接口测试

Swagger结果：

2.3.2前后端联调

3. 如何用ThreadLocal实现员工ID的获取？

3.1简化意义

之前学过拿到请求头的方法。大致是：注入request对象，获取请求头，拿到token，再解析token拿到登入id。

这样子做是可以。但存在问题：

代码太繁琐了，后期其他地方用到id又要再次编写上面代码，冗余的地方就会很多。

于是我们用到了新方案：利用线程对象（包含一个集合，可以实现在一个线程之间共享数据），在登录验证的拦截器中实现获取id的操作，id设置到线程对象变成共享的，使用的时候获取即可。这就是ThreadLocal技术思路。

3.2实现

我们已经定义好了一个封装了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();}}

3.2.1set方法

其中setCurrentId调用了ThreadLocal的set方法，设置id。

3.2.2get方法

getCurrentId则调用了get方法，用于得到设置好的，或者默认的id。

3.2.3remove方法

removeCurrentId调用了remove方法，可以移除设置的参数，让内存回收。

再看入具体实现：

3.2.4拦截器中添加代码

//2、校验令牌
try {log.info("jwt校验:{}", token);Claims claims = JwtUtil.parseJWT(jwtProperties.getAdminSecretKey(), token);Long empId = Long.valueOf(claims.get(JwtClaimsConstant.EMP_ID).toString());log.info("当前员工id：{}", empId);// put hte id in threadBaseContext.setCurrentId(empId);  // 添加到此处//3、通过，放行return true;
} catch (Exception ex) {//4、不通过，响应401状态码response.setStatus(401);return false;
}

再这里，我们要获取当前员工的id，并得到。之后就可以调用ThreadLocal对象，直接得到员工id，方便插入操作人的操作。

3.2.5业务层添加代码

添加代码如下：

Long currentId = BaseContext.getCurrentId();
employee.setCreateUser(currentId);
employee.setUpdateUser(currentId);

这里就直接用保存的员工id，进行添加了。

3.2.6思考题

什么时候remove比较合适呢？代码又应该写在哪里呢？

3.3原理

我们可以看一看ThreadLocal中的set方法：

public void set(T value) {Thread t = Thread.currentThread();ThreadLocalMap map = getMap(t);if (map != null)map.set(this, value);elsecreateMap(t, value);
}

可以看到，它将线程和map绑定，以达到我们的用线程可以得到绑定值的效果。

再看看get方法：

public T get() {Thread t = Thread.currentThread();ThreadLocalMap map = getMap(t);if (map != null) {ThreadLocalMap.Entry e = map.getEntry(this);if (e != null) {@SuppressWarnings("unchecked")T result = (T)e.value;return result;}}return setInitialValue();
}

也是同上的原理，调用绑定的线程就可以获取对应的设置的值。

如果还有不清楚，可以再点进具体的类中看看，比如getMap函数、ThreadLocalMap对象中去看。

3.4思考题答案

我们在线程结束，request结束的时候，把它remove了最好。在这之前，可能还是会用到。

所以写在拦截器的后面两个要重写的方法中即可。这里就挑第一个，postHandle。第二个的afterCompletion也可以。

@Override
public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) throws Exception {BaseContext.removeCurrentId();
}

4. Java对象转json的日期格式如何指定？

4.1方案一

在每个日期属性上都加上格式转换的代码。

@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private LocalDateTime createTime;@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private LocalDateTime updateTime;

4.1.1缺点

繁琐，每一个都要加。

4.2方案二

在WebMvcConfiguration中扩展SpringMVC的消息转换器，统一对日期类型进行格式处理。

使用sky-common模块中，json包下的JacksonObjectMapper类

package com.sky.json;import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.module.SimpleModule;
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.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_DATE_TIME_FORMAT = "yyyy-MM-dd HH:mm";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(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);}
}

然后在配置类WebMvcConfiguration中加入以下代码：

protected void extendMessageConverters(List<HttpMessageConverter<?>> converters) {log.info("扩展消息转换器...");//创建一个消息转换器对象MappingJackson2HttpMessageConverter converter = new MappingJackson2HttpMessageConverter();//需要为消息转换器设置一个对象转换器，对象转换器可以将Java对象序列化为json数据converter.setObjectMapper(new JacksonObjectMapper());//将自己的消息转化器加入容器中converters.add(0,converter);
}

4.3结果验证

5. 描述清楚修改员工的实现流程

包括修改员工状态和编辑员工。

5.1需求分析和设计

5.1.1具体业务

修改员工状态：

用户点击启用/禁用按钮，切换用户状态。

编辑员工：

数据回显：根据id查询员工信息，并展示在编辑的表单中。

提交修改：根据id修改数据。

5.1.2设计接口

修改员工状态：

请求路径 /admin/employee/status/{status}
请求参数 ?id=1
请求方式 POST
响应数据
{
“code”:1,
“msg”:””,
“data”:null
}

编辑员工：

请求路径 /admin/employee
请求参数 json，用EmployeeDTO接收
请求方式 PUT
响应数据还是code、msg和data。

5.2代码开发

5.2.1Controller层

/*** 启用/禁用员工账号接口* @param status* @param id* @return*/
@ApiOperation(value = "启用/禁用员工账号接口")
@PostMapping("/status/{status}")
public Result updateStatus(@PathVariable Integer status, Long id) {employeeService.updateStatus(status, id);return Result.success();
}/*** 根据id查询员工信息* @param id* @return*/
@GetMapping("/{id}")
public Result getByID(@PathVariable Long id) {Employee employee = employeeService.getById(id);return Result.success(employee);
}/*** 编辑员工信息* @param employeeDTO* @return*/
@PutMapping
public Result update(@RequestBody EmployeeDTO employeeDTO) {employeeService.update(employeeDTO);return Result.success();
}

5.2.2Service层

public void updateStatus(Integer status, Long id) {Employee employee = new Employee();employee.setStatus(status);employee.setId(id);employee.setUpdateTime(LocalDateTime.now());employee.setUpdateUser(BaseContext.getCurrentId());employeeMapper.updateById(employee);
}@Override
public Employee getById(Long id) {return employeeMapper.getById(id);
}@Override
public void update(EmployeeDTO employeeDTO) {Employee employee = new Employee();BeanUtils.copyProperties(employeeDTO, employee);employee.setUpdateTime(LocalDateTime.now());employee.setUpdateUser(BaseContext.getCurrentId());employeeMapper.updateById(employee);
}

5.2.3Mapper层

Java代码：

/*** 根据id修改员工状态* @param employee*/void updateById(Employee employee);@Select("select * from employee where id=#{id}")Employee getById(Long id);

xml文件：

<update id="updateById">update employee<set><if test="name!=null and name!=''">name = #{name},</if><if test="username != null and name !=''">username = #{username},</if><if test="password != null and name !=''">password = #{password},</if><if test="phone != null">phone = #{phone},</if><if test="sex != null">sex = #{sex},</if><if test="idNumber != null">id_number = #{idNumber},</if><if test="updateTime != null">update_time = #{updateTime},</if><if test="updateUser != null">update_user = #{updateUser},</if><if test="status != null">status = #{status},</if></set>where id = #{id};
</update>