苍穹外卖1到2

1
git config --global user.name "Firebat"
2
# 配置全局邮箱（建议和 GitHub 账号邮箱保持一致）
3
git config --global user.email "firebat@example.com"
4
#生成公钥和私钥
5
ssh-keygen -t ed25519 -C "2860556024@qq.com"
6
#测试连通性
7
ssh -T git@github.com
8
ssh -T git@gitee.com
9
#ssh克隆到本地
10
git clone git@github.com:Firebat/zhongwen-shortdrama-context.git
11
# 查看当前 remote 地址
12
git remote -v
13

14
# 切换为 SSH 地址
15
git remote set-url origin git@github.com:Firebat/zhongwen-shortdrama-context.git
16
git remote set-url origin git@gitee.com:lyf_80/sky-take-out.git
17
# 再次确认
18
git remote -v
19
//切换地址后，下次 push/pull 就会用新地址。不需要重新 clone
20

21
#提交
22
git add README.md     //git add . 添加到暂存区
23
git commit -m "fix: 修正 README 错别字"
24
git push -u origin main //首次提交加上-u
25
git push origin main

1
@Service
2
public class EmployeeServiceImpl implements EmployeeService {
3

4
    @Autowired
5
    private EmployeeMapper employeeMapper;
6

7
    /**
8
     * 员工登录
9
     *
10
     * @param employeeLoginDTO
11
     * @return
12
     */
13
    public Employee login(EmployeeLoginDTO employeeLoginDTO) {
14
        String username = employeeLoginDTO.getUsername();
15
        String password = employeeLoginDTO.getPassword();
16

17
        //1、根据用户名查询数据库中的数据
18
        Employee employee = employeeMapper.getByUsername(username);
19

20
        //2、处理各种异常情况（用户名不存在、密码不对、账号被锁定）
21
        if (employee == null) {
22
            //账号不存在
23
//抛出异常类
24
            throw new AccountNotFoundException(MessageConstant.ACCOUNT_NOT_FOUND);
25
        }
26

27
        //密码比对
28
        // TODO 后期需要进行md5加密，然后再进行比对
29
        if (!password.equals(employee.getPassword())) {
30
            //密码错误
31
            throw new PasswordErrorException(MessageConstant.PASSWORD_ERROR);
32
        }
33

34
        if (employee.getStatus() == StatusConstant.DISABLE) {
35
            //账号被锁定
36
            throw new AccountLockedException(MessageConstant.ACCOUNT_LOCKED);
37
        }
38

39
        //3、返回实体对象
40
        return employee;
41
    }
42

43
}

1
/**
2
 * 账号不存在异常
3
 */
4
public class AccountNotFoundException extends BaseException {
5

6
    public AccountNotFoundException() {
7
    }
8

9
    public AccountNotFoundException(String msg) {
10
        super(msg);
11
    }
12

13
}
14
/**
15
 * 业务异常
16
 */
17
public class BaseException extends RuntimeException {
18

19
    public BaseException() {
20
    }
21

22
    public BaseException(String msg) {
23
        super(msg);
24
    }
25

26
}
27

28
/**
29
 * 全局异常处理器，处理项目中抛出的业务异常
30
 */
31
@RestControllerAdvice
32
@Slf4j
33
public class GlobalExceptionHandler {
34

35
    /**
36
     * 捕获业务异常
37
     * @param ex
38
     * @return
39
     */
40
    @ExceptionHandler
41
    public Result exceptionHandler(BaseException ex){
42
        log.error("异常信息：{}", ex.getMessage());
43
        return Result.error(ex.getMessage());
44
    }
45

46
}

1
/**
2
 * 员工管理
3
 */
4
@RestController
5
@RequestMapping("/admin/employee")
6
@Slf4j
7
public class EmployeeController {
8

9
    @Autowired
10
    private EmployeeService employeeService;
11
    @Autowired
12
    private JwtProperties jwtProperties;
13
//把信息设置为配置属性类
14

15
    /**
16
     * 登录
17
     *
18
     * @param employeeLoginDTO
19
     * @return
20
     */
21
    @PostMapping("/login")
22
    public Result<EmployeeLoginVO> login(@RequestBody EmployeeLoginDTO employeeLoginDTO) {
23
        log.info("员工登录：{}", employeeLoginDTO);
24

25
        Employee employee = employeeService.login(employeeLoginDTO);
26

27
        //登录成功后，生成jwt令牌
28
        Map<String, Object> claims = new HashMap<>();
29
        claims.put(JwtClaimsConstant.EMP_ID, employee.getId());
30
        String token = JwtUtil.createJWT(
31
                jwtProperties.getAdminSecretKey(),
32
                jwtProperties.getAdminTtl(),
33
                claims);
34
//封装数据
35
        EmployeeLoginVO employeeLoginVO = EmployeeLoginVO.builder()
36
                .id(employee.getId())
37
                .userName(employee.getUsername())
38
                .name(employee.getName())
39
                .token(token)
40
                .build();
41

42
        return Result.success(employeeLoginVO);
43
    }
44

45
    /**
46
     * 退出
47
     *
48
     * @return
49
     */
50
    @PostMapping("/logout")
51
    public Result<String> logout() {
52
        return Result.success();
53
    }
54

55
}

1
<?xml version="1.0" encoding="UTF-8" ?>
2
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
3
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
4
<mapper namespace="com.sky.mapper.EmployeeMapper">
5
    <select id="list" resultType="com.sky.entity.Employee">
6
        select * from employee
7
        <where>
8
            <if test="name != null and name != ''">
9
                and name like concat('%',#{name},'%')
10
            </if>
11
        </where>
12
        order by create_time desc
13

14
    </select>
15
</mapper>

1
    <update id="update" parameterType="Employee">
2
  <--parameterType="Employee可以这样写是因为type-aliases-package: com.sky.entity-->
3
        update employee
4
        <set>
5
            <if test="name != null">name = #{name},</if>
6
            <if test="username != null">username = #{username},</if>
7
            <if test="password != null">password = #{password},</if>
8
            <if test="phone != null">phone = #{phone},</if>
9
            <if test="sex != null">sex = #{sex},</if>
10
            <if test="idNumber != null">id_number = #{idNumber},</if>
11
            <if test="updateTime != null">update_time = #{updateTime},</if>
12
            <if test="updateUser != null">update_user = #{updateUser},</if>
13
            <if test="status != null">status = #{status},</if>
14
        </set>
15
        where id = #{id}
16
    </update>

1
 //编辑员工信息
2
    //1.查询回显数据
3
    @ApiOperation("回显员工信息")
4
    @GetMapping("/{id}")
5
    public Result<Employee> getById(@PathVariable Long id){
6
        Employee employee=employeeService.getById(id);
7
        return Result.success(employee);
8
    }
9
    //2.修改员工信息
10
    @ApiOperation("修改员工信息")
11
    @PutMapping
12
    public Result update(@RequestBody EmployeeDTO dto){
13
        log.info("员工修改：{}",dto);
14
        employeeService.update(dto);
15
        return Result.success();
16
    }

1
    //编辑员工信息
2
        //1.根据id查询员工
3
    @Override
4
    public Employee getById(Long id) {
5
        Employee employee = employeeMapper.getById(id);
6
        employee.setPassword("****");
7
        return employee;
8
    }
9
       // 2.修改员工信息
10
    @Override
11
    public void update(EmployeeDTO dto) {
12
        Employee employee = new Employee();
13
        //BeanUtils拷贝属性
14
        BeanUtils.copyProperties(dto,employee);
15
      //利用SpingMvC消息转换器进行日期转换
16
        employee.setUpdateTime(LocalDateTime.now());
17
        //利用threadLocal获取当前用户id
18
        //借助工具类在jwt拦截器获取id
19
        employee.setUpdateUser(BaseContext.getCurrentId());
20
        employeeMapper.update(employee);
21
    }

1
<!--    启用暂停账号-->
2
    <update id="update" parameterType="Employee">
3
        update employee
4
        <set>
5
            <if test="name != null">name = #{name},</if>
6
            <if test="username != null">username = #{username},</if>
7
            <if test="password != null">password = #{password},</if>
8
            <if test="phone != null">phone = #{phone},</if>
9
            <if test="sex != null">sex = #{sex},</if>
10
            <if test="idNumber != null">id_number = #{idNumber},</if>
11
            <if test="updateTime != null">update_time = #{updateTime},</if>
12
            <if test="updateUser != null">update_user = #{updateUser},</if>
13
            <if test="status != null">status = #{status},</if>
14
        </set>
15
        where id = #{id}
16
    </update>

1
// 修改密码
2
    @Override
3
    public void editPassword(PasswordEditDTO dto) {
4
        // 1. 设置当前登录用户 id
5
        dto.setEmpId(BaseContext.getCurrentId());
6
        // 2. 查数据库原密码（密文）
7
        String storedPassword = employeeMapper.SelectPassword(dto);
8
        // 3. 旧密码 MD5 加密后比对，不匹配则抛异常
9
        String oldPasswordMd5 = DigestUtils.md5DigestAsHex(dto.getOldPassword().getBytes());
10
        if (!oldPasswordMd5.equals(storedPassword)) {
11
            throw new PasswordErrorException(MessageConstant.PASSWORD_ERROR);
12
        }
13
        // 4. 新密码加密后更新
14
        dto.setNewPassword(DigestUtils.md5DigestAsHex(dto.getNewPassword().getBytes()));
15
        employeeMapper.editPassword(dto);
16
    }

1
@RestController
2
@RequestMapping("/admin/category")
3
@Api(tags = "分类相关接口")
4
@Slf4j
5
public class CategoryController {
6

7
    @Autowired
8
    private CategoryService categoryService;
9
    //新增分类
10
    @PostMapping
11
    @ApiOperation("新增分类")
12
    public Result<String> save(@RequestBody CategoryDTO categoryDTO){
13
        log.info("新增分类：{}", categoryDTO);
14
        categoryService.save(categoryDTO);
15
        return Result.success();
16
    }

1
   public void save(CategoryDTO categoryDTO) {
2
        Category category = new Category();
3
        //属性拷贝
4
        BeanUtils.copyProperties(categoryDTO, category);
5
        //补充属性
6
        //分类状态默认为禁用状态0
7
        category.setStatus(StatusConstant.DISABLE);
8
        //设置创建时间、修改时间、创建人、修改人
9
        category.setCreateTime(LocalDateTime.now());
10
        category.setUpdateTime(LocalDateTime.now());
11
        //利用threadLocal获取当前登录用户id
12
        category.setCreateUser(BaseContext.getCurrentId());
13
        category.setUpdateUser(BaseContext.getCurrentId());
14
        categoryMapper.insert(category);
15
    }