devbox
Cpp五条
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

【SpringBoot3+Vue3】二【实战篇】-后端

作者：Cpp五条 | 2024-05-14 06:18:59

赞

踩

springboot3+vue3

目录

一、环境搭建

1、数据库脚本

2、pom

3、yml

4、通过mybatis-X生成实体pojo等

4.1 Article

4.2 Category

4.3 User

5、 Mapper

5.1 ArticleMapper

5.2 CategoryMapper

5.3 UserMapper

6、service

6.1 ArticleService

6.2 CategoryService

6.3 UserService

7、serviceImpl

7.1 ArticleServiceImpl

7.2 CategoryServiceImpl

7.3 UserServiceImpl

8、统一返回类Result

9、工具类

9.1 MD5加密工具类Md5Util

9.2 jwt生成token工具类JwtUtils 

9.3 工具类ThreadLocalUtil

 9.4 AliOSSProperties阿里云参数实体

9.5 阿里云AliOSSUtils

10、全局异常处理类GlobalExceptionHandler

11、拦截器LoginCheckInterceptor

12、配置类

 12.1 配置类WebConfig注册拦截器

12.2   MybatisPlus分页配置类MybatisPlusConfig

13、自定义注解（新增文章）

13.1 新增文章自定义注解State接口

13.2 新增文章自定义注解实现类StateValidation

14、封装分页实体PageBean

二、用户

1、注册

1.1 UserController

1.2 service

1.3 serviceImpl

2、登录

2.1 UserController

2.2 登录认证 

3、获取用户详细信息

3.1 UserController

 3.2 servcie

3.3 servcieImpl

3.4 优化版本UserController（使用ThreadLocal）

4、更新用户基本信息

4.1 UserController

4.2 servcie

4.3 serviceImpl

5、更新用户头像

5.2 UserController 

5.2 servcie

5.3 servcieImpl

6、更新用户密码

6.1 UserController

6.2 service

6.3 serviceImpl

三、文章分类

1、新增文章分类

1.1 CategoryController

1.2 service

1.3 servcieImpl

2、文章分类列表

2.1 CategoryController

2.2 service

2.3 servcieImpl

3、 获取文章分类详情

3.1 CategoryController

3.2 service

3.3 servcieImpl

4、更新文章分类

4.1 CategoryController

4.2 service

4.3 servcieImpl

5、删除文章分类

5.1 CategoryController

5.2 service

5.3 servcieImpl

四、文章管理

1、新增文章

1.1 ArticleCtroller

1.2 service

1.3 serviceImpl

2、文章列表（条件分页）

2.1 ArticleCtroller

2.2 service

2.3 serviceImpl

3、获取文章详情

3.1 ArticleCtroller

3.2 service

3.3 serviceImpl

4、更新文章

4.1 ArticleCtroller

4.2 service

4.3 serviceImpl

5、删除文章

5.1 ArticleCtroller

5.2 service

5.3 serviceImpl

五、上传接口

1、FileUploadController

前言：SpringBoot3+Vue3项目实战-后端

一、环境搭建

1、数据库脚本

  1. -- 用户表
  2. create table user (
  3.                       id int unsigned primary key auto_increment comment 'ID',
  4.                       username varchar(20) not null unique comment '用户名',
  5.                       password varchar(32)  comment '密码',
  6.                       nickname varchar(10)  default '' comment '昵称',
  7.                       email varchar(128) default '' comment '邮箱',
  8.                       user_pic varchar(128) default '' comment '头像',
  9.                       create_time datetime not null comment '创建时间',
  10.                       update_time datetime not null comment '修改时间'
  11. ) comment '用户表';
  12.  
  13. -- 分类表
  14. create table category(
  15.                          id int unsigned primary key auto_increment comment 'ID',
  16.                          category_name varchar(32) not null comment '分类名称',
  17.                          category_alias varchar(32) not null comment '分类别名',
  18.                          create_user int unsigned not null comment '创建人ID',
  19.                          create_time datetime not null comment '创建时间',
  20.                          update_time datetime not null comment '修改时间',
  21.                          constraint fk_category_user foreign key (create_user) references user(id) -- 外键约束
  22. );
  23.  
  24. -- 文章表
  25. create table article(
  26.                         id int unsigned primary key auto_increment comment 'ID',
  27.                         title varchar(30) not null comment '文章标题',
  28.                         content varchar(10000) not null comment '文章内容',
  29.                         cover_img varchar(128) not null  comment '文章封面',
  30.                         state varchar(3) default '草稿' comment '文章状态: 只能是[已发布] 或者 [草稿]',
  31.                         category_id int unsigned comment '文章分类ID',
  32.                         create_user int unsigned not null comment '创建人ID',
  33.                         create_time datetime not null comment '创建时间',
  34.                         update_time datetime not null comment '修改时间',
  35.                         constraint fk_article_category foreign key (category_id) references category(id),-- 外键约束
  36.                         constraint fk_article_user foreign key (create_user) references user(id) -- 外键约束
  37. )

2、pom

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>org.springframework.boot</groupId>
  7.         <artifactId>spring-boot-starter-parent</artifactId>
  8.         <version>3.1.5</version>
  9.         <relativePath/> <!-- lookup parent from repository -->
  10.     </parent>
  11.     <groupId>com.bocai</groupId>
  12.     <artifactId>mybatis-plus-module</artifactId>
  13.     <version>0.0.1-SNAPSHOT</version>
  14.     <name>mybatis-plus-module</name>
  15.     <description>mybatis-plus-module</description>
  16.     <properties>
  17.         <java.version>17</java.version>
  18.         <aliyun-sdk-oss.version>3.15.1</aliyun-sdk-oss.version>
  19.         <jaxb-api.version>2.3.1</jaxb-api.version>
  20.         <activation.version>1.1.1</activation.version>
  21.         <jaxb-runtime.version>2.3.3</jaxb-runtime.version>
  22.         <mybatis-plus.version>3.5.3</mybatis-plus.version>
  23.         <druid.version>1.1.23</druid.version>
  24.         <jjwt.version>0.9.0</jjwt.version>
  25.         <fastjson.version>1.2.76</fastjson.version>
  26.     </properties>
  27.     <dependencies>
  28.         <dependency>
  29.             <groupId>org.springframework.boot</groupId>
  30.             <artifactId>spring-boot-starter-web</artifactId>
  31.         </dependency>
  32.  
  33.         <dependency>
  34.             <groupId>com.mysql</groupId>
  35.             <artifactId>mysql-connector-j</artifactId>
  36.             <scope>runtime</scope>
  37.         </dependency>
  38.         <dependency>
  39.             <groupId>org.projectlombok</groupId>
  40.             <artifactId>lombok</artifactId>
  41.             <optional>true</optional>
  42.         </dependency>
  43.         <dependency>
  44.             <groupId>org.springframework.boot</groupId>
  45.             <artifactId>spring-boot-starter-test</artifactId>
  46.             <scope>test</scope>
  47.         </dependency>
  48.         <!--  校验 引入validation -->
  49.         <dependency>
  50.             <groupId>org.springframework.boot</groupId>
  51.             <artifactId>spring-boot-starter-validation</artifactId>
  52.         </dependency>
  53.  
  54.         <!--  3、 引入mybatisplus -->
  55.         <dependency>
  56.             <groupId>com.baomidou</groupId>
  57.             <artifactId>mybatis-plus-boot-starter</artifactId>
  58.             <version>${mybatis-plus.version}</version>
  59.         </dependency>
  60.         <dependency>
  61.             <groupId>com.alibaba</groupId>
  62.             <artifactId>druid-spring-boot-starter</artifactId>
  63.             <version>${druid.version}</version>
  64.         </dependency>
  65.         <!--        阿里云OSS依赖-->
  66.         <dependency>
  67.             <groupId>com.aliyun.oss</groupId>
  68.             <artifactId>aliyun-sdk-oss</artifactId>
  69.             <version>${aliyun-sdk-oss.version}</version>
  70.         </dependency>
  71.         <!--  如果是java9 还需要下面几个依赖   本项目按理不需要-->
  72.         <dependency>
  73.             <groupId>javax.xml.bind</groupId>
  74.             <artifactId>jaxb-api</artifactId>
  75.             <version>${jaxb-api.version}</version>
  76.         </dependency>
  77.         <dependency>
  78.             <groupId>javax.activation</groupId>
  79.             <artifactId>activation</artifactId>
  80.             <version>${activation.version}</version>
  81.         </dependency>
  82.         <!-- no more than 2.3.3-->
  83.         <dependency>
  84.             <groupId>org.glassfish.jaxb</groupId>
  85.             <artifactId>jaxb-runtime</artifactId>
  86.             <version>${jaxb-runtime.version}</version>
  87.         </dependency>
  88.         <!--  上面都是阿里云的 依赖-  -->
  89.  
  90.         <!--JWT令牌-->
  91.         <dependency>
  92.             <groupId>io.jsonwebtoken</groupId>
  93.             <artifactId>jjwt</artifactId>
  94.             <version>${jjwt.version}</version>
  95.         </dependency>
  96.  
  97.         <dependency>
  98.             <groupId>com.alibaba</groupId>
  99.             <artifactId>fastjson</artifactId>
  100.             <version>${fastjson.version}</version>
  101.         </dependency>
  102.  
  103.     </dependencies>
  104.  
  105.     <build>
  106.         <plugins>
  107.             <plugin>
  108.                 <groupId>org.springframework.boot</groupId>
  109.                 <artifactId>spring-boot-maven-plugin</artifactId>
  110.                 <configuration>
  111.                     <image>
  112.                         <builder>paketobuildpacks/builder-jammy-base:latest</builder>
  113.                     </image>
  114.                     <excludes>
  115.                         <exclude>
  116.                             <groupId>org.projectlombok</groupId>
  117.                             <artifactId>lombok</artifactId>
  118.                         </exclude>
  119.                     </excludes>
  120.                 </configuration>
  121.             </plugin>
  122.         </plugins>
  123.     </build>
  124.  
  125. </project>

3、yml

  1. spring:
  2.   datasource:
  3.     type: com.alibaba.druid.pool.DruidDataSource
  4.     driver-class-name: com.mysql.cj.jdbc.Driver
  5.     url: jdbc:mysql://localhost:3306/springboot_vue?serverTimezone=UTC
  6.     username: root
  7.     password: Miami
  8.   main:
  9.     banner-mode: off  # 关闭控制台springboot的logo
  10.  
  11.  
  12. mybatis-plus:
  13.   configuration:
  14.     map-underscore-to-camel-case: true # 在映射实体或者属性时，将数据库中表名和字段名中的下划线去掉，按照驼峰命名法映射
  15.     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl  # 控制台显示sql
  16.     default-enum-type-handler: com.baomidou.mybatisplus.core.handlers.MybatisEnumTypeHandler  # 配置全局枚举处理器，好像还有说json的
  17.   global-config:
  18.     db-config:
  19.       id-type: auto   # 数据库id生产规则全局 配置 # ASSIGN_ID雪花算法，数据库id建议使用Long类型
  20.       logic-delete-field: deleted # 全局配置逻辑删除字段名
  21.       logic-delete-value: 0 # 全局配置# 逻辑已删除值(默认为 1)这里因为我是反的所以改成0
  22.       logic-not-delete-value: 1  # 逻辑未删除值(默认为 0）这里因为我是反的所以改成1
  23.       # table-prefix: tbl_    # 数据库表前缀全局配置
  24.     banner: false   # 关闭控制台mybatis-plus的logo
  25. #  type-enums-package: com.bocai.enums   # 扫描通用枚举包 或者使用上面那个枚举全局配置
  26.  
  27. # 阿里云OSS配置
  28. aliyun:
  29.   oss:
  30.     endpoint: https://oss-cn-hanzhou.aliyuncs.com
  31.     accessKeyId: LTjfk332422slksPqy
  32.     accessKeySecret: Pfslfksd2;lf2sALHfdsfsTHm6fdsfsdsR
  33.     bucketName: web-spring3bocai

4、通过mybatis-X生成实体pojo等

4.1 Article

  1. package com.bocai.pojo;
  2.  
  3. import com.baomidou.mybatisplus.annotation.IdType;
  4. import com.baomidou.mybatisplus.annotation.TableField;
  5. import com.baomidou.mybatisplus.annotation.TableId;
  6. import com.baomidou.mybatisplus.annotation.TableName;
  7. import java.io.Serializable;
  8. import java.time.LocalDateTime;
  9. import java.util.Date;
  10.  
  11. import com.bocai.anno.State;
  12. import com.fasterxml.jackson.annotation.JsonFormat;
  13. import com.fasterxml.jackson.annotation.JsonIgnore;
  14. import jakarta.validation.constraints.NotEmpty;
  15. import jakarta.validation.constraints.NotNull;
  16. import jakarta.validation.constraints.Pattern;
  17. import jakarta.validation.groups.Default;
  18. import lombok.Data;
  19. import org.hibernate.validator.constraints.URL;
  20.  
  21. /**
  22.  * 
  23.  * @TableName article
  24.  */
  25. @TableName(value ="article")
  26. @Data
  27. public class Article implements Serializable {
  28.     /**
  29.      * ID
  30.      */
  31.     @NotNull(groups = Article.Update.class)
  32.     @TableId(type = IdType.AUTO)
  33.     private Integer id;
  34.  
  35.     /**
  36.      * 文章标题
  37.      */
  38.     @NotEmpty
  39.     @Pattern(regexp = "^\\S{1,10}$")
  40.     private String title;
  41.  
  42.     /**
  43.      * 文章内容
  44.      */
  45.     @NotEmpty
  46.     private String content;
  47.  
  48.     /**
  49.      * 文章封面
  50.      */
  51.     @NotEmpty
  52.     @URL
  53.     private String coverImg;
  54.  
  55.     /**
  56.      * 文章状态: 只能是[已发布] 或者 [草稿]
  57.      */
  58.     @State  //自定义注解
  59.     private String state;
  60.  
  61.     /**
  62.      * 文章分类ID
  63.      */
  64.     @NotNull
  65.     private Integer categoryId;
  66.  
  67.     /**
  68.      * 创建人ID
  69.      */
  70.     @JsonIgnore  // json返回不显示
  71.     private Integer createUser;
  72.  
  73.     /**
  74.      * 创建时间
  75.      */
  76.     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
  77.     private LocalDateTime createTime;
  78.  
  79.     /**
  80.      * 修改时间
  81.      */
  82.     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
  83.     private LocalDateTime updateTime;
  84.  
  85.     @TableField(exist = false)
  86.     private static final long serialVersionUID = 1L;
  87.  
  88.     // 如果说某个校验项没有指定分钟，默认属于Default分组
  89.     //分组之间可以继承，A extend B， 那么A 就拥有B的所有校验项
  90.     /**
  91.      * 为了校验分组
  92.      */
  93.     public interface Add extends Default {
  94.  
  95.     }
  96.  
  97.     /**
  98.      * 为了校验分组
  99.      */
  100.     public interface Update extends Default{
  101.  
  102.     }
  103. }

4.2 Category

  1. package com.bocai.pojo;
  2.  
  3. import com.baomidou.mybatisplus.annotation.IdType;
  4. import com.baomidou.mybatisplus.annotation.TableField;
  5. import com.baomidou.mybatisplus.annotation.TableId;
  6. import com.baomidou.mybatisplus.annotation.TableName;
  7. import java.io.Serializable;
  8. import java.time.LocalDateTime;
  9. import java.util.Date;
  10.  
  11. import com.fasterxml.jackson.annotation.JsonFormat;
  12. import com.fasterxml.jackson.annotation.JsonIgnore;
  13. import jakarta.validation.constraints.NotEmpty;
  14. import jakarta.validation.constraints.NotNull;
  15. import jakarta.validation.groups.Default;
  16. import lombok.Data;
  17.  
  18. /**
  19.  * 
  20.  * @TableName category
  21.  */
  22. @TableName(value ="category")
  23. @Data
  24. public class Category implements Serializable {
  25.     /**
  26.      * ID
  27.      */
  28.     @NotNull(groups = Update.class)
  29.     @TableId(type = IdType.AUTO)
  30.     private Integer id;
  31.  
  32.     /**
  33.      * 分类名称
  34.      */
  35.     @NotEmpty  //值不能为空，并且内容不能为空
  36.     private String categoryName;
  37.  
  38.     /**
  39.      * 分类别名
  40.      */
  41.     @NotEmpty //值不能为空，并且内容不能为空
  42. //    @NotEmpty(groups = {Update.class,Add.class})
  43.     private String categoryAlias;
  44.  
  45.     /**
  46.      * 创建人ID
  47.      */
  48.     @JsonIgnore  // json返回不显示
  49.     private Integer createUser;
  50.  
  51.     /**
  52.      * 创建时间
  53.      */
  54.     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
  55.     private LocalDateTime createTime;
  56.  
  57.     /**
  58.      * 修改时间
  59.      */
  60.     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
  61.     private LocalDateTime updateTime;
  62.  
  63.     @TableField(exist = false)
  64.     private static final long serialVersionUID = 1L;
  65.  
  66.     // 如果说某个校验项没有指定分钟，默认属于Default分组
  67.     //分组之间可以继承，A extend B， 那么A 就拥有B的所有校验项
  68.     /**
  69.      * 为了校验分组
  70.      */
  71.     public interface Add extends Default {
  72.  
  73.     }
  74.  
  75.     /**
  76.      * 为了校验分组
  77.      */
  78.     public interface Update extends Default{
  79.  
  80.     }
  81. }

4.3 User

  1. package com.bocai.pojo;
  2.  
  3. import com.baomidou.mybatisplus.annotation.IdType;
  4. import com.baomidou.mybatisplus.annotation.TableField;
  5. import com.baomidou.mybatisplus.annotation.TableId;
  6. import com.baomidou.mybatisplus.annotation.TableName;
  7. import java.io.Serializable;
  8. import java.time.LocalDateTime;
  9. import java.util.Date;
  10.  
  11. import com.fasterxml.jackson.annotation.JsonFormat;
  12. import com.fasterxml.jackson.annotation.JsonIgnore;
  13. import jakarta.validation.constraints.Email;
  14. import jakarta.validation.constraints.NotEmpty;
  15. import jakarta.validation.constraints.NotNull;
  16. import jakarta.validation.constraints.Pattern;
  17. import lombok.Data;
  18.  
  19. /**
  20.  * 用户表
  21.  * @TableName user
  22.  */
  23. @TableName(value ="user")
  24. @Data
  25. public class User implements Serializable {
  26.     /**
  27.      * ID
  28.      */
  29.     @NotNull //不能为空
  30.     @TableId(type = IdType.AUTO)
  31.     private Integer id;
  32.  
  33.     /**
  34.      * 用户名
  35.      */
  36.     private String username;
  37.  
  38.     /**
  39.      * 密码
  40.      */
  41.     @JsonIgnore //springboot把当前对象转换成json字符串的时候忽略这个字段
  42.     private String password;
  43.  
  44.     /**
  45.      * 昵称
  46.      */
  47.     @NotEmpty  //值不能为空，并且内容不能为空
  48.     @Pattern(regexp = "^\\S{1,10}$")  //正则
  49.     private String nickname;
  50.  
  51.     /**
  52.      * 邮箱
  53.      */
  54.     @Email //满足邮箱格式
  55.     private String email;
  56.  
  57.     /**
  58.      * 头像
  59.      */
  60.     private String userPic;
  61.  
  62.     /**
  63.      * 创建时间
  64.      */
  65.     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
  66.     private LocalDateTime createTime;
  67.  
  68.     /**
  69.      * 修改时间
  70.      */
  71.     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
  72.     private LocalDateTime updateTime;
  73.  
  74.     @TableField(exist = false)
  75.     private static final long serialVersionUID = 1L;
  76. }

5、 Mapper

5.1 ArticleMapper

  1. package com.bocai.mapper;
  2.  
  3. import com.bocai.pojo.Article;
  4. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  5. import org.apache.ibatis.annotations.Mapper;
  6.  
  7. /**
  8. * @author cheng
  9. * @description 针对表【article】的数据库操作Mapper
  10. * @createDate 2023-11-13 19:55:11
  11. * @Entity com.bocai.pojo.Article
  12. */
  13. @Mapper
  14. public interface ArticleMapper extends BaseMapper<Article> {
  15.  
  16. }
  17.  
  18.  
  19.  
  20.

5.2 CategoryMapper

  1. package com.bocai.mapper;
  2.  
  3. import com.bocai.pojo.Category;
  4. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  5. import org.apache.ibatis.annotations.Mapper;
  6.  
  7. /**
  8. * @author cheng
  9. * @description 针对表【category】的数据库操作Mapper
  10. * @createDate 2023-11-13 19:55:04
  11. * @Entity com.bocai.pojo.Category
  12. */
  13. @Mapper
  14. public interface CategoryMapper extends BaseMapper<Category> {
  15.  
  16. }
  17.  
  18.  
  19.  
  20.

5.3 UserMapper

  1. package com.bocai.mapper;
  2.  
  3. import com.bocai.pojo.User;
  4. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  5. import org.apache.ibatis.annotations.Mapper;
  6.  
  7. /**
  8. * @author cheng
  9. * @description 针对表【user(用户表)】的数据库操作Mapper
  10. * @createDate 2023-11-13 19:54:41
  11. * @Entity com.bocai.pojo.User
  12. */
  13. @Mapper
  14. public interface UserMapper extends BaseMapper<User> {
  15.  
  16. }
  17.  
  18.  
  19.  
  20.

6、service

6.1 ArticleService

  1. package com.bocai.service;
  2.  
  3. import com.bocai.pojo.Article;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5.  
  6. /**
  7. * @author cheng
  8. * @description 针对表【article】的数据库操作Service
  9. * @createDate 2023-11-13 19:55:11
  10. */
  11. public interface ArticleService extends IService<Article> {
  12.  
  13. }

6.2 CategoryService

  1. package com.bocai.service;
  2.  
  3. import com.bocai.pojo.Category;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5.  
  6. /**
  7. * @author cheng
  8. * @description 针对表【category】的数据库操作Service
  9. * @createDate 2023-11-13 19:55:04
  10. */
  11. public interface CategoryService extends IService<Category> {
  12.  
  13. }

6.3 UserService

  1. package com.bocai.service;
  2.  
  3. import com.bocai.pojo.User;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5.  
  6. /**
  7. * @author cheng
  8. * @description 针对表【user(用户表)】的数据库操作Service
  9. * @createDate 2023-11-13 19:54:41
  10. */
  11. public interface UserService extends IService<User> {
  12.  
  13. }

7、serviceImpl

7.1 ArticleServiceImpl

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  4. import com.bocai.pojo.Article;
  5. import com.bocai.service.ArticleService;
  6. import com.bocai.mapper.ArticleMapper;
  7. import org.springframework.stereotype.Service;
  8.  
  9. /**
  10. * @author cheng
  11. * @description 针对表【article】的数据库操作Service实现
  12. * @createDate 2023-11-13 19:55:11
  13. */
  14. @Service
  15. public class ArticleServiceImpl extends ServiceImpl<ArticleMapper, Article>
  16.     implements ArticleService{
  17.  
  18. }
  19.  
  20.  
  21.  
  22.

7.2 CategoryServiceImpl

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  4. import com.bocai.pojo.Category;
  5. import com.bocai.service.CategoryService;
  6. import com.bocai.mapper.CategoryMapper;
  7. import org.springframework.stereotype.Service;
  8.  
  9. /**
  10. * @author cheng
  11. * @description 针对表【category】的数据库操作Service实现
  12. * @createDate 2023-11-13 19:55:04
  13. */
  14. @Service
  15. public class CategoryServiceImpl extends ServiceImpl<CategoryMapper, Category>
  16.     implements CategoryService{
  17.  
  18. }
  19.  
  20.  
  21.  
  22.

7.3 UserServiceImpl

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  4. import com.bocai.pojo.User;
  5. import com.bocai.service.UserService;
  6. import com.bocai.mapper.UserMapper;
  7. import org.springframework.stereotype.Service;
  8.  
  9. /**
  10. * @author cheng
  11. * @description 针对表【user(用户表)】的数据库操作Service实现
  12. * @createDate 2023-11-13 19:54:41
  13. */
  14. @Service
  15. public class UserServiceImpl extends ServiceImpl<UserMapper, User>
  16.     implements UserService{
  17.  
  18. }
  19.  
  20.  
  21.  
  22.

8、统一返回类Result

  1. package com.bocai.common;
  2.  
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  6.  
  7. @Data
  8. @NoArgsConstructor
  9. @AllArgsConstructor
  10. public class Result {
  11.     private Integer code;//响应码，1 代表成功; 0 代表失败
  12.     private String msg;  //响应信息 描述字符串
  13.     private Object data; //返回的数据
  14.  
  15.     //增删改 成功响应
  16.     public static Result success(){
  17.         return new Result(1,"success",null);
  18.     }
  19.     //查询 成功响应
  20.     public static Result success(Object data){
  21.         return new Result(1,"success",data);
  22.     }
  23.     //失败响应
  24.     public static Result error(String msg){
  25.         return new Result(0,msg,null);
  26.     }
  27. }

9、工具类

9.1 MD5加密工具类Md5Util

  1. package com.bocai.utils;
  2.  
  3.  
  4. import java.security.MessageDigest;
  5. import java.security.NoSuchAlgorithmException;
  6.  
  7. public class Md5Util {
  8.     /**
  9.      * 默认的密码字符串组合，用来将字节转换成 16 进制表示的字符,apache校验下载的文件的正确性用的就是默认的这个组合
  10.      */
  11.     protected static char hexDigits[] = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'};
  12.  
  13.     protected static MessageDigest messagedigest = null;
  14.  
  15.     static {
  16.         try {
  17.             messagedigest = MessageDigest.getInstance("MD5");
  18.         } catch (NoSuchAlgorithmException nsaex) {
  19.             System.err.println(Md5Util.class.getName() + "初始化失败，MessageDigest不支持MD5Util。");
  20.             nsaex.printStackTrace();
  21.         }
  22.     }
  23.  
  24.     /**
  25.      * 生成字符串的md5校验值
  26.      *
  27.      * @param s
  28.      * @return
  29.      */
  30.     public static String getMD5String(String s) {
  31.         return getMD5String(s.getBytes());
  32.     }
  33.  
  34.     /**
  35.      * 判断字符串的md5校验码是否与一个已知的md5码相匹配
  36.      *
  37.      * @param password  要校验的字符串
  38.      * @param md5PwdStr 已知的md5校验码
  39.      * @return
  40.      */
  41.     public static boolean checkPassword(String password, String md5PwdStr) {
  42.         String s = getMD5String(password);
  43.         return s.equals(md5PwdStr);
  44.     }
  45.  
  46.  
  47.     public static String getMD5String(byte[] bytes) {
  48.         messagedigest.update(bytes);
  49.         return bufferToHex(messagedigest.digest());
  50.     }
  51.  
  52.     private static String bufferToHex(byte bytes[]) {
  53.         return bufferToHex(bytes, 0, bytes.length);
  54.     }
  55.  
  56.     private static String bufferToHex(byte bytes[], int m, int n) {
  57.         StringBuffer stringbuffer = new StringBuffer(2 * n);
  58.         int k = m + n;
  59.         for (int l = m; l < k; l++) {
  60.             appendHexPair(bytes[l], stringbuffer);
  61.         }
  62.         return stringbuffer.toString();
  63.     }
  64.  
  65.     private static void appendHexPair(byte bt, StringBuffer stringbuffer) {
  66.         char c0 = hexDigits[(bt & 0xf0) >> 4];// 取字节中高 4 位的数字转换, >>>
  67.         // 为逻辑右移，将符号位一起右移,此处未发现两种符号有何不同
  68.         char c1 = hexDigits[bt & 0xf];// 取字节中低 4 位的数字转换
  69.         stringbuffer.append(c0);
  70.         stringbuffer.append(c1);
  71.     }
  72.  
  73. }

9.2 jwt生成token工具类JwtUtils 

  1. package com.bocai.utils;
  2.  
  3. import io.jsonwebtoken.Claims;
  4. import io.jsonwebtoken.Jwts;
  5. import io.jsonwebtoken.SignatureAlgorithm;
  6.  
  7. import java.util.Date;
  8. import java.util.Map;
  9.  
  10. public class JwtUtils {
  11.  
  12.     private static String signKey = "bocai";
  13.     private static Long expire = 43200000L;  // 12h
  14.  
  15.     /**
  16.      * 生成JWT令牌
  17.      * @param claims JWT第二部分负载 payload 中存储的内容
  18.      * @return
  19.      */
  20.     public static String generateJwt(Map<String, Object> claims){
  21.         String jwt = Jwts.builder()
  22.                 .addClaims(claims)
  23.                 .signWith(SignatureAlgorithm.HS256, signKey)
  24.                 .setExpiration(new Date(System.currentTimeMillis() + expire))
  25.                 .compact();
  26.         return jwt;
  27.     }
  28.  
  29.     /**
  30.      * 解析JWT令牌
  31.      * @param jwt JWT令牌
  32.      * @return JWT第二部分负载 payload 中存储的内容
  33.      */
  34.     public static Claims parseJWT(String jwt){
  35.         Claims claims = Jwts.parser()
  36.                 .setSigningKey(signKey)
  37.                 .parseClaimsJws(jwt)
  38.                 .getBody();
  39.         return claims;
  40.     }
  41. }

9.3 工具类ThreadLocalUtil

  1. package com.bocai.utils;
  2.  
  3. import java.util.HashMap;
  4. import java.util.Map;
  5.  
  6. /**
  7.  * ThreadLocal 工具类
  8.  */
  9. @SuppressWarnings("all")
  10. public class ThreadLocalUtil {
  11.     //提供ThreadLocal对象,
  12.     private static final ThreadLocal THREAD_LOCAL = new ThreadLocal();
  13.  
  14.     //根据键获取值
  15.     public static <T> T get(){
  16.         return (T) THREAD_LOCAL.get();
  17.     }
  18. 	
  19.     //存储键值对
  20.     public static void set(Object value){
  21.         THREAD_LOCAL.set(value);
  22.     }
  23.  
  24.  
  25.     //清除ThreadLocal 防止内存泄漏
  26.     public static void remove(){
  27.         THREAD_LOCAL.remove();
  28.     }
  29. }

 9.4 AliOSSProperties阿里云参数实体

  1. package com.bocai.utils;
  2.  
  3. import lombok.Data;
  4. import org.springframework.boot.context.properties.ConfigurationProperties;
  5. import org.springframework.stereotype.Component;
  6.  
  7. @Data
  8. @Component
  9. @ConfigurationProperties(prefix = "aliyun.oss")
  10. public class AliOSSProperties {
  11.  
  12.     private String endpoint;
  13.     private String accessKeyId;
  14.     private String accessKeySecret;
  15.     private String bucketName;
  16. }

9.5 阿里云AliOSSUtils

  1. package com.bocai.utils;
  2.  
  3. import com.aliyun.oss.OSS;
  4. import com.aliyun.oss.OSSClientBuilder;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.stereotype.Component;
  7. import org.springframework.web.multipart.MultipartFile;
  8.  
  9. import java.io.IOException;
  10. import java.io.InputStream;
  11. import java.util.UUID;
  12.  
  13. /**
  14.  * 阿里云 OSS 工具类
  15.  */
  16. @Component
  17. public class AliOSSUtils {
  18.  
  19. //    @Value("${aliyun.oss.endpoint}")
  20. //    private String endpoint;
  21. //    @Value("${aliyun.oss.accessKeyId}")
  22. //    private String accessKeyId;
  23. //    @Value("${aliyun.oss.accessKeySecret}")
  24. //    private String accessKeySecret;
  25. //    @Value("${aliyun.oss.bucketName}")
  26. //    private String bucketName;
  27.     @Autowired
  28.     private AliOSSProperties aliOSSProperties;
  29.  
  30.     /**
  31.      * 实现上传图片到OSS
  32.      */
  33.     public String upload(MultipartFile file) throws IOException {
  34.         // 获取阿里云OSS参数
  35.         String endpoint = aliOSSProperties.getEndpoint();
  36.         String accessKeyId = aliOSSProperties.getAccessKeyId();
  37.         String accessKeySecret = aliOSSProperties.getAccessKeySecret();
  38.         String bucketName = aliOSSProperties.getBucketName();
  39.         // 获取上传的文件的输入流
  40.         InputStream inputStream = file.getInputStream();
  41.  
  42.         // 避免文件覆盖
  43.         String originalFilename = file.getOriginalFilename();
  44.         String fileName = UUID.randomUUID().toString() + originalFilename.substring(originalFilename.lastIndexOf("."));
  45.  
  46.         //上传文件到 OSS
  47.         OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
  48.         ossClient.putObject(bucketName, fileName, inputStream);
  49.  
  50.         //文件访问路径
  51.         String url = endpoint.split("//")[0] + "//" + bucketName + "." + endpoint.split("//")[1] + "/" + fileName;
  52.         // 关闭ossClient
  53.         ossClient.shutdown();
  54.         return url;// 把上传到oss的路径返回
  55.     }
  56.  
  57. }

10、全局异常处理类GlobalExceptionHandler

  1. package com.bocai.exception;
  2.  
  3. import com.bocai.common.Result;
  4. import org.springframework.web.bind.annotation.ExceptionHandler;
  5. import org.springframework.web.bind.annotation.RestControllerAdvice;
  6.  
  7. /**
  8.  * =========================全局异常处理器========================
  9.  */
  10. @RestControllerAdvice
  11. public class GlobalExceptionHandler {
  12.  
  13.     @ExceptionHandler(Exception.class)//捕获所有异常
  14.     public Result ex(Exception ex){
  15.         ex.printStackTrace();
  16.         return Result.error("对不起,操作失败,请联系管理员");
  17.     }
  18.  
  19. }

11、拦截器LoginCheckInterceptor

  1. package com.bocai.interceptor;
  2.  
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.bocai.common.Result;
  5. import com.bocai.utils.JwtUtils;
  6. import com.bocai.utils.ThreadLocalUtil;
  7. import jakarta.servlet.http.HttpServletRequest;
  8. import jakarta.servlet.http.HttpServletResponse;
  9. import lombok.extern.slf4j.Slf4j;
  10. import org.springframework.stereotype.Component;
  11. import org.springframework.util.StringUtils;
  12. import org.springframework.web.servlet.HandlerInterceptor;
  13. import org.springframework.web.servlet.ModelAndView;
  14.  
  15. import java.util.Map;
  16.  
  17.  
  18. /**
  19.  *   =========================LoginCheckInterceptor 拦截器 interceptor========================
  20.  */
  21. @Slf4j
  22. @Component
  23. public class LoginCheckInterceptor implements HandlerInterceptor {
  24.     @Override //目标资源方法运行前运行, 返回true: 放行, 放回false, 不放行
  25.     public boolean preHandle(HttpServletRequest req, HttpServletResponse resp, Object handler) throws Exception {
  26.         //1.获取请求url。
  27.         String url = req.getRequestURL().toString();
  28.         log.info("请求的url: {}",url);
  29.  
  30.         //2.判断请求url中是否包含login，如果包含，说明是登录操作，放行。
  31.         if(url.contains("login")){
  32.             log.info("登录操作, 放行...");
  33.             return true;
  34.         }
  35.  
  36.         //3.获取请求头中的令牌（ Authorization）。
  37.  
  38.         String jwt = req.getHeader("Authorization");
  39.  
  40.         //4.判断令牌是否存在，如果不存在，返回错误结果（未登录）。
  41.         if(!StringUtils.hasLength(jwt)){
  42.             log.info("请求头Authorization为空,返回未登录的信息");
  43.             Result error = Result.error("NOT_LOGIN");
  44.             //手动转换 对象--json --------> 阿里巴巴fastJSON
  45.             String notLogin = JSONObject.toJSONString(error);
  46.             resp.getWriter().write(notLogin);
  47.             return false;
  48.         }
  49.  
  50.         //5.解析token，如果解析失败，返回错误结果（未登录）。
  51.         try {
  52.             Map<String, Object> claims = JwtUtils.parseJWT(jwt);
  53.             //6.把业务数据存储到ThreadLocal中
  54.             ThreadLocalUtil.set(claims);
  55.             //7.放行。
  56.             log.info("令牌合法, 放行");
  57.             return true;
  58.  
  59.         } catch (Exception e) {//jwt解析失败
  60.             e.printStackTrace();
  61.             log.info("解析令牌失败, 返回未登录错误信息");
  62.             Result error = Result.error("NOT_LOGIN");
  63.             //手动转换 对象--json --------> 阿里巴巴fastJSON
  64.             String notLogin = JSONObject.toJSONString(error);
  65.             resp.getWriter().write(notLogin);
  66.             return false;
  67.         }
  68.  
  69.  
  70.     }
  71.  
  72.     @Override //目标资源方法运行后运行
  73.     public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) throws Exception {
  74.         System.out.println("postHandle ...");
  75.     }
  76.  
  77.     @Override //视图渲染完毕后运行, 最后运行
  78.     public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
  79.         // 清空ThreadLocal中的数据,防止内存泄漏
  80.         ThreadLocalUtil.remove();
  81.  
  82.         System.out.println("afterCompletion...");
  83.     }
  84. }

12、配置类

 12.1 配置类WebConfig注册拦截器

  1. package com.bocai.config;
  2.  
  3. import com.bocai.interceptor.LoginCheckInterceptor;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.context.annotation.Configuration;
  6. import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
  7. import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
  8.  
  9.  
  10. /**
  11.  *   =========================LoginCheckInterceptor 的配置类 ========================
  12.  */
  13. @Configuration //配置类
  14. public class WebConfig implements WebMvcConfigurer {
  15.  
  16.     @Autowired
  17.     private LoginCheckInterceptor loginCheckInterceptor;
  18.  
  19.     /**
  20.      * 注册拦截器, 拦截所有url，除登录
  21.      * @param registry
  22.      */
  23.     @Override
  24.     public void addInterceptors(InterceptorRegistry registry) {
  25.         registry.addInterceptor(loginCheckInterceptor).addPathPatterns("/**").excludePathPatterns("/user/login","/user/register");
  26.     }
  27. }

12.2   MybatisPlus分页配置类MybatisPlusConfig

  1. package com.bocai.config;
  2.  
  3. import com.baomidou.mybatisplus.annotation.DbType;
  4. import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
  5. import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor;
  6. import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
  7. import org.springframework.context.annotation.Bean;
  8. import org.springframework.context.annotation.Configuration;
  9.  
  10. /**
  11.  * 配置MP的分页插件
  12.  */
  13. @Configuration
  14. public class MybatisPlusConfig {
  15.  
  16.     @Bean
  17.     public MybatisPlusInterceptor mybatisPlusInterceptor(){
  18.         // 1、定义MybatisPlus拦截器
  19.         MybatisPlusInterceptor mybatisPlusInterceptor = new MybatisPlusInterceptor();
  20.         // 2、添加分页的拦截器
  21.         mybatisPlusInterceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
  22.         // 3、添加乐观锁的拦截器
  23.         mybatisPlusInterceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
  24.         return mybatisPlusInterceptor;
  25.  
  26.     }
  27. }

13、自定义注解（新增文章）

13.1 新增文章自定义注解State接口

  1. package com.bocai.anno;
  2.  
  3. import com.bocai.validation.StateValidation;
  4. import jakarta.validation.Constraint;
  5. import jakarta.validation.Payload;
  6. import jakarta.validation.constraints.NotEmpty;
  7.  
  8. import java.lang.annotation.Documented;
  9. import java.lang.annotation.Repeatable;
  10. import java.lang.annotation.Retention;
  11. import java.lang.annotation.Target;
  12.  
  13. import static java.lang.annotation.ElementType.*;
  14. import static java.lang.annotation.ElementType.TYPE_USE;
  15. import static java.lang.annotation.RetentionPolicy.RUNTIME;
  16.  
  17. @Documented//元注解
  18. @Target({ FIELD})//元注解
  19. @Retention(RUNTIME)//元注解
  20. @Constraint(validatedBy = { StateValidation.class})//指定提供校验规则的类
  21. public @interface State {
  22.     //提供校验失败后的提示信息
  23.     String message() default "state参数的值只能是已发布或者草稿";
  24.     //指定分组
  25.     Class<?>[] groups() default { };
  26.     //负载  获取到State注解的附加信息
  27.     Class<? extends Payload>[] payload() default { };
  28. }

13.2 新增文章自定义注解实现类StateValidation

  1. package com.bocai.validation;
  2.  
  3. import com.bocai.anno.State;
  4. import jakarta.validation.ConstraintValidator;
  5. import jakarta.validation.ConstraintValidatorContext;
  6.  
  7. public class StateValidation implements ConstraintValidator<State,String> {
  8.     /**
  9.      *
  10.      * @param value 将来要校验的数据
  11.      * @param context context in which the constraint is evaluated
  12.      *
  13.      * @return 如果返回false,则校验不通过,如果返回true,则校验通过
  14.      */
  15.     @Override
  16.     public boolean isValid(String value, ConstraintValidatorContext context) {
  17.         //提供校验规则
  18.         if (value == null){
  19.             return false;
  20.         }
  21.         if (value.equals("已发布") || value.equals("草稿")){
  22.             return true;
  23.         }
  24.         return false;
  25.     }
  26. }

14、封装分页实体PageBean

  1. package com.bocai.pojo;
  2.  
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  6.  
  7. import java.util.List;
  8.  
  9. /**
  10.  * 分页查询结果封装类
  11.  */
  12. @Data
  13. @NoArgsConstructor
  14. @AllArgsConstructor
  15. public class PageBean {
  16.  
  17.     private Long total;//总记录数
  18.     private List items;//数据列表
  19.  
  20. }

二、用户

1、注册

1.1 UserController

  1. package com.bocai.controller;
  2.  
  3. import com.bocai.common.Result;
  4. import com.bocai.pojo.User;
  5. import com.bocai.service.UserService;
  6. import jakarta.validation.constraints.Pattern;
  7. import lombok.extern.slf4j.Slf4j;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.validation.annotation.Validated;
  10. import org.springframework.web.bind.annotation.GetMapping;
  11. import org.springframework.web.bind.annotation.PostMapping;
  12. import org.springframework.web.bind.annotation.RequestMapping;
  13. import org.springframework.web.bind.annotation.RestController;
  14.  
  15. @RestController
  16. @Slf4j
  17. @Validated
  18. @RequestMapping("/user")
  19. public class UserController {
  20.  
  21.     @Autowired
  22.     private UserService userService;
  23.  
  24.     /**
  25.      * 用户注册
  26.      * @param username
  27.      * @param password
  28.      * @return
  29.      */
  30.     @PostMapping("/register")
  31.     public Result register(@Pattern(regexp = "^\\S{5,16}$") String username, @Pattern(regexp = "^\\S{5,16}$")String password){
  32.         log.info("注册用户名：{}，密码为：{}",username,password);
  33.         // 查询用户
  34.         User user = userService.queryUserByUsername(username,password);
  35.         if (user == null){
  36.             //没有占用，可以注册
  37.             //注册用户
  38.             userService.register(username,password);
  39.             return Result.success();
  40.         }else{
  41.             return Result.error("用户名被占用");
  42.         }
  43.  
  44.     }
  45.  
  46.  
  47.  
  48. }

1.2 service

  1. package com.bocai.service;
  2.  
  3. import com.bocai.pojo.User;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5.  
  6. /**
  7. * @author cheng
  8. * @description 针对表【user(用户表)】的数据库操作Service
  9. * @createDate 2023-11-13 19:54:41
  10. */
  11. public interface UserService extends IService<User> {
  12.  
  13.     /**
  14.      * 用户注册
  15.      * @param username
  16.      * @param password
  17.      */
  18.     void register(String username, String password);
  19.  
  20.     /**
  21.      * 根据用户名 --查询用户
  22.      * @param username  
  23.      * @return
  24.      */
  25.     User queryUserByUsername(String username);
  26. }

1.3 serviceImpl

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  5. import com.bocai.pojo.User;
  6. import com.bocai.service.UserService;
  7. import com.bocai.mapper.UserMapper;
  8. import com.bocai.utils.Md5Util;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.stereotype.Service;
  11.  
  12. import java.time.LocalDateTime;
  13.  
  14. /**
  15. * @author cheng
  16. * @description 针对表【user(用户表)】的数据库操作Service实现
  17. * @createDate 2023-11-13 19:54:41
  18. */
  19. @Service
  20. public class UserServiceImpl extends ServiceImpl<UserMapper, User>
  21.     implements UserService{
  22.  
  23.     @Autowired
  24.     private UserMapper userMapper;
  25.  
  26.     /**
  27.      * 注册
  28.      * @param username
  29.      * @param password
  30.      */
  31.     @Override
  32.     public void register(String username, String password) {
  33.  
  34.         //密码加密
  35.         String md5String = Md5Util.getMD5String(password);
  36.         User user = new User();
  37.         user.setUsername(username);
  38.         user.setPassword(md5String);
  39.         user.setCreateTime(LocalDateTime.now());
  40.         user.setUpdateTime(LocalDateTime.now());
  41.         userMapper.insert(user);
  42.  
  43.  
  44.     }
  45.  
  46.     /**
  47.      * 查询用户
  48.      * @param username    
  49.      * @return
  50.      */
  51.     @Override
  52.     public User queryUserByUsername(String username) {
  53.         //查询用户
  54.         LambdaQueryWrapper<User> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  55.         lambdaQueryWrapper.eq(username != null, User::getUsername,username);
  56.         User user = userMapper.selectOne(lambdaQueryWrapper);
  57.         return user;
  58.     }
  59. }
  60.  
  61.  
  62.  
  63.

2、登录

2.1 UserController

  1. package com.bocai.controller;
  2.  
  3. import com.bocai.common.Result;
  4. import com.bocai.pojo.User;
  5. import com.bocai.service.UserService;
  6. import com.bocai.utils.Md5Util;
  7. import jakarta.validation.constraints.Pattern;
  8. import lombok.extern.slf4j.Slf4j;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.validation.annotation.Validated;
  11. import org.springframework.web.bind.annotation.GetMapping;
  12. import org.springframework.web.bind.annotation.PostMapping;
  13. import org.springframework.web.bind.annotation.RequestMapping;
  14. import org.springframework.web.bind.annotation.RestController;
  15.  
  16. @RestController
  17. @Slf4j
  18. @Validated
  19. @RequestMapping("/user")
  20. public class UserController {
  21.  
  22.     @Autowired
  23.     private UserService userService;
  24.  
  25.     /**
  26.      * 用户注册
  27.      * @param username
  28.      * @param password
  29.      * @return
  30.      */
  31.     @PostMapping("/register")
  32.     public Result register(@Pattern(regexp = "^\\S{5,16}$") String username, @Pattern(regexp = "^\\S{5,16}$")String password){
  33.         log.info("注册用户名：{}，密码为：{}",username,password);
  34.         // 查询用户
  35.         User user = userService.queryUserByUsername(username);
  36.         if (user == null){
  37.             //没有占用，可以注册
  38.             //注册用户
  39.             userService.register(username,password);
  40.             return Result.success();
  41.         }else{
  42.             return Result.error("用户名被占用");
  43.         }
  44.  
  45.     }
  46.  
  47.     @PostMapping("/login")
  48.     public Result login(@Pattern(regexp = "^\\S{5,16}$") String username, @Pattern(regexp = "^\\S{5,16}$")String password) {
  49.         log.info("登录用户名：{}，密码为：{}", username, password);
  50.         // 查询用户
  51.         User loginUser = userService.queryUserByUsername(username);
  52.         // 判断用户是否存在
  53.         if (loginUser == null) {
  54.             return Result.error("用户名不存在");
  55.         }
  56.  
  57.         // 判断密码是否正确，loginUser对象中的password是密文
  58.         if(Md5Util.getMD5String(password).equals(loginUser.getPassword())){
  59.             // 登录成功
  60.             return Result.success("JWT");
  61.         }
  62.         return Result.error("密码错误！");
  63.     }
  64. }

2.2 登录认证 

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  5. import com.bocai.pojo.User;
  6. import com.bocai.service.UserService;
  7. import com.bocai.mapper.UserMapper;
  8. import com.bocai.utils.Md5Util;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.stereotype.Service;
  11.  
  12. import java.time.LocalDateTime;
  13. import java.util.HashMap;
  14. import java.util.Map;
  15.  
  16. /**
  17. * @author cheng
  18. * @description 针对表【user(用户表)】的数据库操作Service实现
  19. * @createDate 2023-11-13 19:54:41
  20. */
  21. @Service
  22. public class UserServiceImpl extends ServiceImpl<UserMapper, User>
  23.     implements UserService{
  24.  
  25.     @Autowired
  26.     private UserMapper userMapper;
  27.  
  28.     /**
  29.      * 注册
  30.      * @param username
  31.      * @param password
  32.      */
  33.     @Override
  34.     public void register(String username, String password) {
  35.  
  36.         //密码加密
  37.         String md5String = Md5Util.getMD5String(password);
  38.         User user = new User();
  39.         user.setUsername(username);
  40.         user.setPassword(md5String);
  41.         user.setCreateTime(LocalDateTime.now());
  42.         user.setUpdateTime(LocalDateTime.now());
  43.         userMapper.insert(user);
  44.  
  45.  
  46.     }
  47.  
  48.     /**
  49.      * 查询用户
  50.      * @param username
  51.      * @return
  52.      */
  53.     @Override
  54.     public User queryUserByUsername(String username) {
  55.         //查询用户
  56.         LambdaQueryWrapper<User> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  57.         lambdaQueryWrapper.eq(username != null, User::getUsername,username);
  58.         User user = userMapper.selectOne(lambdaQueryWrapper);
  59.         return user;
  60.     }
  61. }
  62.  
  63.  
  64.  
  65.

3、获取用户详细信息

3.1 UserController

  1. package com.bocai.controller;
  2.  
  3. import com.bocai.common.Result;
  4. import com.bocai.pojo.User;
  5. import com.bocai.service.UserService;
  6. import com.bocai.utils.JwtUtils;
  7. import com.bocai.utils.Md5Util;
  8. import jakarta.validation.constraints.Pattern;
  9. import lombok.extern.slf4j.Slf4j;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.validation.annotation.Validated;
  12. import org.springframework.web.bind.annotation.*;
  13.  
  14. import java.util.HashMap;
  15. import java.util.Map;
  16.  
  17. @RestController
  18. @Slf4j
  19. @Validated
  20. @RequestMapping("/user")
  21. public class UserController {
  22.  
  23.     @Autowired
  24.     private UserService userService;
  25.  
  26.     /**
  27.      * 用户注册
  28.      * @param username
  29.      * @param password
  30.      * @return
  31.      */
  32.     @PostMapping("/register")
  33.     public Result register(@Pattern(regexp = "^\\S{5,16}$") String username, @Pattern(regexp = "^\\S{5,16}$")String password){
  34.         log.info("注册用户名：{}，密码为：{}",username,password);
  35.         // 查询用户
  36.         User user = userService.queryUserByUsername(username);
  37.         if (user == null){
  38.             //没有占用，可以注册
  39.             //注册用户
  40.             userService.register(username,password);
  41.             return Result.success();
  42.         }else{
  43.             return Result.error("用户名被占用");
  44.         }
  45.  
  46.     }
  47.  
  48.     @PostMapping("/login")
  49.     public Result login(@Pattern(regexp = "^\\S{5,16}$") String username, @Pattern(regexp = "^\\S{5,16}$")String password) {
  50.         log.info("登录用户名：{}，密码为：{}", username, password);
  51.         // 查询用户
  52.         User loginUser = userService.queryUserByUsername(username);
  53.         // 判断用户是否存在
  54.         if (loginUser == null) {
  55.             return Result.error("用户名不存在");
  56.         }
  57.  
  58.         // 判断密码是否正确，loginUser对象中的password是密文
  59.         if(Md5Util.getMD5String(password).equals(loginUser.getPassword())){
  60.             // 登录成功
  61.             Map<String, Object> claims = new HashMap<>();
  62.             claims.put("id", loginUser.getId());
  63.             claims.put("username",loginUser.getUsername());
  64.             String jwt = JwtUtils.generateJwt(claims); //让jwt包含了当前登录的员工信息
  65.  
  66.             return Result.success(jwt);
  67.         }
  68.         return Result.error("密码错误！");
  69.     }
  70.  
  71.     /**
  72.      * 查询用户信息（从token获取）
  73.      * @param token
  74.      * @return
  75.      */
  76.     @GetMapping("/userInfo")
  77.     public Result userInfo(@RequestHeader(name = "Authorization")String token){
  78.         log.info("查询用户全部信息");
  79.         //根据用户名查询用户
  80.         Map<String, Object> claims = JwtUtils.parseJWT(token);
  81.         String username = (String) claims.get("username");
  82.         User user = userService.queryUserByUsername(username);
  83.         return Result.success(user);
  84.     }
  85. }

 3.2 servcie

  1. package com.bocai.service;
  2.  
  3. import com.bocai.pojo.User;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5.  
  6. /**
  7. * @author cheng
  8. * @description 针对表【user(用户表)】的数据库操作Service
  9. * @createDate 2023-11-13 19:54:41
  10. */
  11. public interface UserService extends IService<User> {
  12.  
  13.     /**
  14.      * 用户注册
  15.      * @param username
  16.      * @param password
  17.      */
  18.     void register(String username, String password);
  19.  
  20.     /**
  21.      * 根据用户名 --查询用户
  22.      * @param username
  23.      * @return
  24.      */
  25.     User queryUserByUsername(String username);
  26.  
  27.     /**
  28.      * 更新用户
  29.      * @param user
  30.      */
  31.     void updateUser(User user);
  32.  
  33.    
  34. }

3.3 servcieImpl

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  5. import com.bocai.pojo.User;
  6. import com.bocai.service.UserService;
  7. import com.bocai.mapper.UserMapper;
  8. import com.bocai.utils.Md5Util;
  9. import com.bocai.utils.ThreadLocalUtil;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.stereotype.Service;
  12.  
  13. import java.time.LocalDateTime;
  14. import java.util.HashMap;
  15. import java.util.Map;
  16.  
  17. /**
  18. * @author cheng
  19. * @description 针对表【user(用户表)】的数据库操作Service实现
  20. * @createDate 2023-11-13 19:54:41
  21. */
  22. @Service
  23. public class UserServiceImpl extends ServiceImpl<UserMapper, User>
  24.     implements UserService{
  25.  
  26.     @Autowired
  27.     private UserMapper userMapper;
  28.  
  29.     /**
  30.      * 注册
  31.      * @param username
  32.      * @param password
  33.      */
  34.     @Override
  35.     public void register(String username, String password) {
  36.  
  37.         //密码加密
  38.         String md5String = Md5Util.getMD5String(password);
  39.         User user = new User();
  40.         user.setUsername(username);
  41.         user.setPassword(md5String);
  42.         user.setCreateTime(LocalDateTime.now());
  43.         user.setUpdateTime(LocalDateTime.now());
  44.         userMapper.insert(user);
  45.  
  46.  
  47.     }
  48.  
  49.     /**
  50.      * 查询用户
  51.      * @param username
  52.      * @return
  53.      */
  54.     @Override
  55.     public User queryUserByUsername(String username) {
  56.         //查询用户
  57.         LambdaQueryWrapper<User> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  58.         lambdaQueryWrapper.eq(username != null, User::getUsername,username);
  59.         User user = userMapper.selectOne(lambdaQueryWrapper);
  60.         return user;
  61.     }
  62.  
  63.     /**
  64.      * 更新用户
  65.      * @param user
  66.      */
  67.     @Override
  68.     public void updateUser(User user) {
  69.         user.setUpdateTime(LocalDateTime.now());
  70.         userMapper.updateById(user);
  71.     }
  72.  
  73.   
  74. }
  75.  
  76.  
  77.  
  78.

3.4 优化版本UserController（使用ThreadLocal）

 

  1. package com.bocai.controller;
  2.  
  3. import com.bocai.common.Result;
  4. import com.bocai.pojo.User;
  5. import com.bocai.service.UserService;
  6. import com.bocai.utils.JwtUtils;
  7. import com.bocai.utils.Md5Util;
  8. import com.bocai.utils.ThreadLocalUtil;
  9. import jakarta.validation.constraints.Pattern;
  10. import lombok.extern.slf4j.Slf4j;
  11. import org.springframework.beans.factory.annotation.Autowired;
  12. import org.springframework.validation.annotation.Validated;
  13. import org.springframework.web.bind.annotation.*;
  14.  
  15. import java.util.HashMap;
  16. import java.util.Map;
  17.  
  18. @RestController
  19. @Slf4j
  20. @Validated
  21. @RequestMapping("/user")
  22. public class UserController {
  23.  
  24.     @Autowired
  25.     private UserService userService;
  26.  
  27.     /**
  28.      * 用户注册
  29.      * @param username
  30.      * @param password
  31.      * @return
  32.      */
  33.     @PostMapping("/register")
  34.     public Result register(@Pattern(regexp = "^\\S{5,16}$") String username, @Pattern(regexp = "^\\S{5,16}$")String password){
  35.         log.info("注册用户名：{}，密码为：{}",username,password);
  36.         // 查询用户
  37.         User user = userService.queryUserByUsername(username);
  38.         if (user == null){
  39.             //没有占用，可以注册
  40.             //注册用户
  41.             userService.register(username,password);
  42.             return Result.success();
  43.         }else{
  44.             return Result.error("用户名被占用");
  45.         }
  46.  
  47.     }
  48.  
  49.     @PostMapping("/login")
  50.     public Result login(@Pattern(regexp = "^\\S{5,16}$") String username, @Pattern(regexp = "^\\S{5,16}$")String password) {
  51.         log.info("登录用户名：{}，密码为：{}", username, password);
  52.         // 查询用户
  53.         User loginUser = userService.queryUserByUsername(username);
  54.         // 判断用户是否存在
  55.         if (loginUser == null) {
  56.             return Result.error("用户名不存在");
  57.         }
  58.  
  59.         // 判断密码是否正确，loginUser对象中的password是密文
  60.         if(Md5Util.getMD5String(password).equals(loginUser.getPassword())){
  61.             // 登录成功
  62.             Map<String, Object> claims = new HashMap<>();
  63.             claims.put("id", loginUser.getId());
  64.             claims.put("username",loginUser.getUsername());
  65.             String jwt = JwtUtils.generateJwt(claims); //让jwt包含了当前登录的员工信息
  66.  
  67.             return Result.success(jwt);
  68.         }
  69.         return Result.error("密码错误！");
  70.     }
  71.  
  72.     /**
  73.      * 查询用户信息（从线程获取）
  74.      * @return
  75.      */
  76.     @GetMapping("/userInfo")
  77.     public Result userInfo(){
  78.         // 从线程获取存储的jwt信息
  79.         Map<String, Object> map = ThreadLocalUtil.get();
  80.         String username = (String) map.get("username");
  81.         log.info("查询用户全部信息,从token获取信息为：{}",username);
  82.         //根据用户名查询用户
  83.  
  84.         User user = userService.queryUserByUsername(username);
  85.         return Result.success(user);
  86.     }
  87.         //使用上面的的优化版本
  88. //    /**
  89. //     * 查询用户信息（从token获取）
  90. //     * @param token
  91. //     * @return
  92. //     */
  93. //    @GetMapping("/userInfo")
  94. //    public Result userInfo(@RequestHeader(name = "Authorization")String token){
  95. //        log.info("查询用户全部信息,从token获取信息为：{}",token);
  96. //        //根据用户名查询用户
  97. //        Map<String, Object> claims = JwtUtils.parseJWT(token);
  98. //        String username = (String) claims.get("username");
  99. //        User user = userService.queryUserByUsername(username);
  100. //        return Result.success(user);
  101. //    }
  102. }

4、更新用户基本信息

4.1 UserController

@Validated

  1. package com.bocai.controller;
  2.  
  3. import com.bocai.common.Result;
  4. import com.bocai.pojo.User;
  5. import com.bocai.service.UserService;
  6. import com.bocai.utils.JwtUtils;
  7. import com.bocai.utils.Md5Util;
  8. import com.bocai.utils.ThreadLocalUtil;
  9. import jakarta.validation.constraints.Pattern;
  10. import lombok.extern.slf4j.Slf4j;
  11. import org.springframework.beans.factory.annotation.Autowired;
  12. import org.springframework.validation.annotation.Validated;
  13. import org.springframework.web.bind.annotation.*;
  14.  
  15. import java.util.HashMap;
  16. import java.util.Map;
  17.  
  18. @RestController
  19. @Slf4j
  20. @Validated
  21. @RequestMapping("/user")
  22. public class UserController {
  23.  
  24.     @Autowired
  25.     private UserService userService;
  26.  
  27.     /**
  28.      * 用户注册
  29.      * @param username
  30.      * @param password
  31.      * @return
  32.      */
  33.     @PostMapping("/register")
  34.     public Result register(@Pattern(regexp = "^\\S{5,16}$") String username, @Pattern(regexp = "^\\S{5,16}$")String password){
  35.         log.info("注册用户名：{}，密码为：{}",username,password);
  36.         // 查询用户
  37.         User user = userService.queryUserByUsername(username);
  38.         if (user == null){
  39.             //没有占用，可以注册
  40.             //注册用户
  41.             userService.register(username,password);
  42.             return Result.success();
  43.         }else{
  44.             return Result.error("用户名被占用");
  45.         }
  46.  
  47.     }
  48.  
  49.     @PostMapping("/login")
  50.     public Result login(@Pattern(regexp = "^\\S{5,16}$") String username, @Pattern(regexp = "^\\S{5,16}$")String password) {
  51.         log.info("登录用户名：{}，密码为：{}", username, password);
  52.         // 查询用户
  53.         User loginUser = userService.queryUserByUsername(username);
  54.         // 判断用户是否存在
  55.         if (loginUser == null) {
  56.             return Result.error("用户名不存在");
  57.         }
  58.  
  59.         // 判断密码是否正确，loginUser对象中的password是密文
  60.         if(Md5Util.getMD5String(password).equals(loginUser.getPassword())){
  61.             // 登录成功
  62.             Map<String, Object> claims = new HashMap<>();
  63.             claims.put("id", loginUser.getId());
  64.             claims.put("username",loginUser.getUsername());
  65.             String jwt = JwtUtils.generateJwt(claims); //让jwt包含了当前登录的员工信息
  66.  
  67.             return Result.success(jwt);
  68.         }
  69.         return Result.error("密码错误！");
  70.     }
  71.  
  72.     /**
  73.      * 查询用户信息（从线程获取）
  74.      * @return
  75.      */
  76.     @GetMapping("/userInfo")
  77.     public Result userInfo(){
  78.         // 从线程获取存储的jwt信息
  79.         Map<String, Object> map = ThreadLocalUtil.get();
  80.         String username = (String) map.get("username");
  81.         log.info("查询用户全部信息,从token获取信息为：{}",username);
  82.         //根据用户名查询用户
  83.  
  84.         User user = userService.queryUserByUsername(username);
  85.         return Result.success(user);
  86.     }
  87.         //使用上面的的优化版本
  88. //    /**
  89. //     * 查询用户信息（从token获取）
  90. //     * @param token
  91. //     * @return
  92. //     */
  93. //    @GetMapping("/userInfo")
  94. //    public Result userInfo(@RequestHeader(name = "Authorization")String token){
  95. //        log.info("查询用户全部信息,从token获取信息为：{}",token);
  96. //        //根据用户名查询用户
  97. //        Map<String, Object> claims = JwtUtils.parseJWT(token);
  98. //        String username = (String) claims.get("username");
  99. //        User user = userService.queryUserByUsername(username);
  100. //        return Result.success(user);
  101. //    }
  102.  
  103.  
  104.     /**
  105.      * 更新用户
  106.      * @param user
  107.      * @return
  108.      */
  109.     @PutMapping("/update")
  110.     public Result update(@RequestBody @Validated  User user){
  111.         log.info("修改的用户为：{}",user);
  112.         userService.updateUser(user);
  113.         return Result.success();
  114.     }
  115. }

4.2 servcie

  1. package com.bocai.service;
  2.  
  3. import com.bocai.pojo.User;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5.  
  6. /**
  7. * @author cheng
  8. * @description 针对表【user(用户表)】的数据库操作Service
  9. * @createDate 2023-11-13 19:54:41
  10. */
  11. public interface UserService extends IService<User> {
  12.  
  13.     /**
  14.      * 用户注册
  15.      * @param username
  16.      * @param password
  17.      */
  18.     void register(String username, String password);
  19.  
  20.     /**
  21.      * 根据用户名 --查询用户
  22.      * @param username
  23.      * @return
  24.      */
  25.     User queryUserByUsername(String username);
  26.  
  27.     /**
  28.      * 更新用户
  29.      * @param user
  30.      */
  31.     void updateUser(User user);
  32.  
  33.  
  34. }

4.3 serviceImpl

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  5. import com.bocai.pojo.User;
  6. import com.bocai.service.UserService;
  7. import com.bocai.mapper.UserMapper;
  8. import com.bocai.utils.Md5Util;
  9. import com.bocai.utils.ThreadLocalUtil;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.stereotype.Service;
  12.  
  13. import java.time.LocalDateTime;
  14. import java.util.HashMap;
  15. import java.util.Map;
  16.  
  17. /**
  18. * @author cheng
  19. * @description 针对表【user(用户表)】的数据库操作Service实现
  20. * @createDate 2023-11-13 19:54:41
  21. */
  22. @Service
  23. public class UserServiceImpl extends ServiceImpl<UserMapper, User>
  24.     implements UserService{
  25.  
  26.     @Autowired
  27.     private UserMapper userMapper;
  28.  
  29.     /**
  30.      * 注册
  31.      * @param username
  32.      * @param password
  33.      */
  34.     @Override
  35.     public void register(String username, String password) {
  36.  
  37.         //密码加密
  38.         String md5String = Md5Util.getMD5String(password);
  39.         User user = new User();
  40.         user.setUsername(username);
  41.         user.setPassword(md5String);
  42.         user.setCreateTime(LocalDateTime.now());
  43.         user.setUpdateTime(LocalDateTime.now());
  44.         userMapper.insert(user);
  45.  
  46.  
  47.     }
  48.  
  49.     /**
  50.      * 查询用户
  51.      * @param username
  52.      * @return
  53.      */
  54.     @Override
  55.     public User queryUserByUsername(String username) {
  56.         //查询用户
  57.         LambdaQueryWrapper<User> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  58.         lambdaQueryWrapper.eq(username != null, User::getUsername,username);
  59.         User user = userMapper.selectOne(lambdaQueryWrapper);
  60.         return user;
  61.     }
  62.  
  63.     /**
  64.      * 更新用户
  65.      * @param user
  66.      */
  67.     @Override
  68.     public void updateUser(User user) {
  69.         user.setUpdateTime(LocalDateTime.now());
  70.         userMapper.updateById(user);
  71.     }
  72.  
  73.  
  74. }
  75.  
  76.  
  77.  
  78.

5、更新用户头像

5.2 UserController 

本内容2个知识点：

1、@URL 判断传参是不是url

2、@PatchMapping

@PutMapping和@PatchMapping是Spring MVC中用于处理HTTP请求的注解，它们在功能和使用上有一些区别。

  1. 请求方式：@PutMapping用于处理PUT请求，而@PatchMapping用于处理PATCH请求。
  2. 请求范围：@PutMapping通常用于执行大规模的替换操作，而不是更新操作。如果省略了订单上的某个属性，那么该属性的值应该被NULL所替代，甚至订单中的某个物品的实体数据也应一起重新设置，否则它们将从订单中移除。而@PatchMapping则用于对资源的部分更新，即只更新请求中指定的属性或关系。
  3. 参数绑定：@PutMapping可以使用@RequestBody注解将请求体中的JSON数据映射到Java对象中，而@PatchMapping则无法直接使用@RequestBody注解，需要使用其他方式来解析请求体中的JSON数据。
  1. package com.bocai.controller;
  2.  
  3. import com.bocai.common.Result;
  4. import com.bocai.pojo.User;
  5. import com.bocai.service.UserService;
  6. import com.bocai.utils.JwtUtils;
  7. import com.bocai.utils.Md5Util;
  8. import com.bocai.utils.ThreadLocalUtil;
  9. import jakarta.validation.constraints.Pattern;
  10. import lombok.extern.slf4j.Slf4j;
  11. import org.hibernate.validator.constraints.URL;
  12. import org.springframework.beans.factory.annotation.Autowired;
  13. import org.springframework.validation.annotation.Validated;
  14. import org.springframework.web.bind.annotation.*;
  15.  
  16. import java.util.HashMap;
  17. import java.util.Map;
  18.  
  19. @RestController
  20. @Slf4j
  21. @Validated
  22. @RequestMapping("/user")
  23. public class UserController {
  24.  
  25.     @Autowired
  26.     private UserService userService;
  27.  
  28.     /**
  29.      * 用户注册
  30.      * @param username
  31.      * @param password
  32.      * @return
  33.      */
  34.     @PostMapping("/register")
  35.     public Result register(@Pattern(regexp = "^\\S{5,16}$") String username, @Pattern(regexp = "^\\S{5,16}$")String password){
  36.         log.info("注册用户名：{}，密码为：{}",username,password);
  37.         // 查询用户
  38.         User user = userService.queryUserByUsername(username);
  39.         if (user == null){
  40.             //没有占用，可以注册
  41.             //注册用户
  42.             userService.register(username,password);
  43.             return Result.success();
  44.         }else{
  45.             return Result.error("用户名被占用");
  46.         }
  47.  
  48.     }
  49.  
  50.     @PostMapping("/login")
  51.     public Result login(@Pattern(regexp = "^\\S{5,16}$") String username, @Pattern(regexp = "^\\S{5,16}$")String password) {
  52.         log.info("登录用户名：{}，密码为：{}", username, password);
  53.         // 查询用户
  54.         User loginUser = userService.queryUserByUsername(username);
  55.         // 判断用户是否存在
  56.         if (loginUser == null) {
  57.             return Result.error("用户名不存在");
  58.         }
  59.  
  60.         // 判断密码是否正确，loginUser对象中的password是密文
  61.         if(Md5Util.getMD5String(password).equals(loginUser.getPassword())){
  62.             // 登录成功
  63.             Map<String, Object> claims = new HashMap<>();
  64.             claims.put("id", loginUser.getId());
  65.             claims.put("username",loginUser.getUsername());
  66.             String jwt = JwtUtils.generateJwt(claims); //让jwt包含了当前登录的员工信息
  67.  
  68.             return Result.success(jwt);
  69.         }
  70.         return Result.error("密码错误！");
  71.     }
  72.  
  73.     /**
  74.      * 查询用户信息（从线程获取）
  75.      * @return
  76.      */
  77.     @GetMapping("/userInfo")
  78.     public Result userInfo(){
  79.         // 从线程获取存储的jwt信息
  80.         Map<String, Object> map = ThreadLocalUtil.get();
  81.         String username = (String) map.get("username");
  82.         log.info("查询用户全部信息,从token获取信息为：{}",username);
  83.         //根据用户名查询用户
  84.  
  85.         User user = userService.queryUserByUsername(username);
  86.         return Result.success(user);
  87.     }
  88.         //使用上面的的优化版本
  89. //    /**
  90. //     * 查询用户信息（从token获取）
  91. //     * @param token
  92. //     * @return
  93. //     */
  94. //    @GetMapping("/userInfo")
  95. //    public Result userInfo(@RequestHeader(name = "Authorization")String token){
  96. //        log.info("查询用户全部信息,从token获取信息为：{}",token);
  97. //        //根据用户名查询用户
  98. //        Map<String, Object> claims = JwtUtils.parseJWT(token);
  99. //        String username = (String) claims.get("username");
  100. //        User user = userService.queryUserByUsername(username);
  101. //        return Result.success(user);
  102. //    }
  103.  
  104.  
  105.     /**
  106.      * 更新用户
  107.      * @param user
  108.      * @return
  109.      */
  110.     @PutMapping("/update")
  111.     public Result update(@RequestBody @Validated  User user){
  112.         log.info("修改的用户为：{}",user);
  113.         userService.updateUser(user);
  114.         return Result.success();
  115.     }
  116.  
  117.     /**
  118.      * 更新头像
  119.      * @param avatarUrl
  120.      * @return
  121.      */
  122.     @PatchMapping("/updateAvatar")
  123.     public Result updateAvatar(@RequestParam @URL String avatarUrl){
  124.         log.info("头像地址是{}",avatarUrl);
  125.         userService.updateAvatar(avatarUrl);
  126.         return Result.success();
  127.     }
  128. }

5.2 servcie

  1. package com.bocai.service;
  2.  
  3. import com.bocai.pojo.User;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5.  
  6. /**
  7. * @author cheng
  8. * @description 针对表【user(用户表)】的数据库操作Service
  9. * @createDate 2023-11-13 19:54:41
  10. */
  11. public interface UserService extends IService<User> {
  12.  
  13.     /**
  14.      * 用户注册
  15.      * @param username
  16.      * @param password
  17.      */
  18.     void register(String username, String password);
  19.  
  20.     /**
  21.      * 根据用户名 --查询用户
  22.      * @param username
  23.      * @return
  24.      */
  25.     User queryUserByUsername(String username);
  26.  
  27.     /**
  28.      * 更新用户
  29.      * @param user
  30.      */
  31.     void updateUser(User user);
  32.  
  33.     /**
  34.      * 更新头像
  35.      * @param avatarUrl
  36.      */
  37.     void updateAvatar(String avatarUrl);
  38.  
  39.  
  40. }

5.3 servcieImpl

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  5. import com.bocai.pojo.User;
  6. import com.bocai.service.UserService;
  7. import com.bocai.mapper.UserMapper;
  8. import com.bocai.utils.Md5Util;
  9. import com.bocai.utils.ThreadLocalUtil;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.stereotype.Service;
  12.  
  13. import java.time.LocalDateTime;
  14. import java.util.HashMap;
  15. import java.util.Map;
  16.  
  17. /**
  18. * @author cheng
  19. * @description 针对表【user(用户表)】的数据库操作Service实现
  20. * @createDate 2023-11-13 19:54:41
  21. */
  22. @Service
  23. public class UserServiceImpl extends ServiceImpl<UserMapper, User>
  24.     implements UserService{
  25.  
  26.     @Autowired
  27.     private UserMapper userMapper;
  28.  
  29.     /**
  30.      * 注册
  31.      * @param username
  32.      * @param password
  33.      */
  34.     @Override
  35.     public void register(String username, String password) {
  36.  
  37.         //密码加密
  38.         String md5String = Md5Util.getMD5String(password);
  39.         User user = new User();
  40.         user.setUsername(username);
  41.         user.setPassword(md5String);
  42.         user.setCreateTime(LocalDateTime.now());
  43.         user.setUpdateTime(LocalDateTime.now());
  44.         userMapper.insert(user);
  45.  
  46.  
  47.     }
  48.  
  49.     /**
  50.      * 查询用户
  51.      * @param username
  52.      * @return
  53.      */
  54.     @Override
  55.     public User queryUserByUsername(String username) {
  56.         //查询用户
  57.         LambdaQueryWrapper<User> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  58.         lambdaQueryWrapper.eq(username != null, User::getUsername,username);
  59.         User user = userMapper.selectOne(lambdaQueryWrapper);
  60.         return user;
  61.     }
  62.  
  63.     /**
  64.      * 更新用户
  65.      * @param user
  66.      */
  67.     @Override
  68.     public void updateUser(User user) {
  69.         user.setUpdateTime(LocalDateTime.now());
  70.         userMapper.updateById(user);
  71.     }
  72.  
  73.     /**
  74.      * 更新头像
  75.      * @param avatarUrl
  76.      */
  77.     @Override
  78.     public void updateAvatar(String avatarUrl) {
  79.         Map<String, Object> map = ThreadLocalUtil.get();
  80.         Integer id = (Integer) map.get("id");
  81.         User user = new User();
  82.         user.setId(id);
  83.         user.setUpdateTime(LocalDateTime.now());
  84.         user.setUserPic(avatarUrl);
  85.         userMapper.updateById(user);
  86.     }
  87.  
  88.  
  89. }
  90.  
  91.  
  92.  
  93.

6、更新用户密码

6.1 UserController

  1. package com.bocai.controller;
  2.  
  3. import com.bocai.common.Result;
  4. import com.bocai.pojo.User;
  5. import com.bocai.service.UserService;
  6. import com.bocai.utils.JwtUtils;
  7. import com.bocai.utils.Md5Util;
  8. import com.bocai.utils.ThreadLocalUtil;
  9. import jakarta.validation.constraints.Pattern;
  10. import lombok.extern.slf4j.Slf4j;
  11. import org.hibernate.validator.constraints.URL;
  12. import org.springframework.beans.factory.annotation.Autowired;
  13. import org.springframework.util.StringUtils;
  14. import org.springframework.validation.annotation.Validated;
  15. import org.springframework.web.bind.annotation.*;
  16.  
  17. import java.util.HashMap;
  18. import java.util.Map;
  19.  
  20. @RestController
  21. @Slf4j
  22. @Validated
  23. @RequestMapping("/user")
  24. public class UserController {
  25.  
  26.     @Autowired
  27.     private UserService userService;
  28.  
  29.     /**
  30.      * 用户注册
  31.      * @param username
  32.      * @param password
  33.      * @return
  34.      */
  35.     @PostMapping("/register")
  36.     public Result register(@Pattern(regexp = "^\\S{5,16}$") String username, @Pattern(regexp = "^\\S{5,16}$")String password){
  37.         log.info("注册用户名：{}，密码为：{}",username,password);
  38.         // 查询用户
  39.         User user = userService.queryUserByUsername(username);
  40.         if (user == null){
  41.             //没有占用，可以注册
  42.             //注册用户
  43.             userService.register(username,password);
  44.             return Result.success();
  45.         }else{
  46.             return Result.error("用户名被占用");
  47.         }
  48.  
  49.     }
  50.  
  51.     @PostMapping("/login")
  52.     public Result login(@Pattern(regexp = "^\\S{5,16}$") String username, @Pattern(regexp = "^\\S{5,16}$")String password) {
  53.         log.info("登录用户名：{}，密码为：{}", username, password);
  54.         // 查询用户
  55.         User loginUser = userService.queryUserByUsername(username);
  56.         // 判断用户是否存在
  57.         if (loginUser == null) {
  58.             return Result.error("用户名不存在");
  59.         }
  60.  
  61.         // 判断密码是否正确，loginUser对象中的password是密文
  62.         if(Md5Util.getMD5String(password).equals(loginUser.getPassword())){
  63.             // 登录成功
  64.             Map<String, Object> claims = new HashMap<>();
  65.             claims.put("id", loginUser.getId());
  66.             claims.put("username",loginUser.getUsername());
  67.             String jwt = JwtUtils.generateJwt(claims); //让jwt包含了当前登录的员工信息
  68.  
  69.             return Result.success(jwt);
  70.         }
  71.         return Result.error("密码错误！");
  72.     }
  73.  
  74.     /**
  75.      * 查询用户信息（从线程获取）
  76.      * @return
  77.      */
  78.     @GetMapping("/userInfo")
  79.     public Result userInfo(){
  80.         // 从线程获取存储的jwt信息
  81.         Map<String, Object> map = ThreadLocalUtil.get();
  82.         String username = (String) map.get("username");
  83.         log.info("查询用户全部信息,从token获取信息为：{}",username);
  84.         //根据用户名查询用户
  85.  
  86.         User user = userService.queryUserByUsername(username);
  87.         return Result.success(user);
  88.     }
  89.         //使用上面的的优化版本
  90. //    /**
  91. //     * 查询用户信息（从token获取）
  92. //     * @param token
  93. //     * @return
  94. //     */
  95. //    @GetMapping("/userInfo")
  96. //    public Result userInfo(@RequestHeader(name = "Authorization")String token){
  97. //        log.info("查询用户全部信息,从token获取信息为：{}",token);
  98. //        //根据用户名查询用户
  99. //        Map<String, Object> claims = JwtUtils.parseJWT(token);
  100. //        String username = (String) claims.get("username");
  101. //        User user = userService.queryUserByUsername(username);
  102. //        return Result.success(user);
  103. //    }
  104.  
  105.  
  106.     /**
  107.      * 更新用户
  108.      * @param user
  109.      * @return
  110.      */
  111.     @PutMapping("/update")
  112.     public Result update(@RequestBody @Validated  User user){
  113.         log.info("修改的用户为：{}",user);
  114.         userService.updateUser(user);
  115.         return Result.success();
  116.     }
  117.  
  118.     /**
  119.      * 更新头像
  120.      * @param avatarUrl
  121.      * @return
  122.      */
  123.     @PatchMapping("/updateAvatar")
  124.     public Result updateAvatar(@RequestParam @URL String avatarUrl){
  125.         log.info("头像地址是{}",avatarUrl);
  126.         userService.updateAvatar(avatarUrl);
  127.         return Result.success();
  128.     }
  129.  
  130.     /**
  131.      * 更新密码
  132.      * @param params json数据包含old_pwd,new_pwd,re_pwd
  133.      * @return
  134.      */
  135.     @PatchMapping("/updatePwd")
  136.     public Result updatePwd(@RequestBody Map<String, String> params){
  137.         log.info("修改密码传过来数据是:{}",params);
  138.         // 1、校验参数
  139.         String old_pwd = params.get("old_pwd");
  140.         String new_pwd = params.get("new_pwd");
  141.         String re_pwd = params.get("re_pwd");
  142.         if(!StringUtils.hasLength(old_pwd) || !StringUtils.hasLength(new_pwd) || !StringUtils.hasLength(re_pwd)){
  143.             return Result.error("缺少必要参数！");
  144.         }
  145.         //原密码是否正确
  146.         Map<String, Object> map = ThreadLocalUtil.get();
  147.         String username = (String) map.get("username");
  148.         User loginUser = userService.queryUserByUsername(username);
  149.  
  150.         if(!loginUser.getPassword().equals(Md5Util.getMD5String(old_pwd))){
  151.             return Result.error("原密码不正确！");
  152.         }
  153.  
  154.         //新、老密码是否一致
  155.         if(old_pwd.equals(new_pwd)){
  156.             return Result.error("新、老密码一样！！");
  157.         }
  158.  
  159.         //新密码和确认密码不一致！
  160.         if(!re_pwd.equals(new_pwd)){
  161.             return Result.error("新密码和确认密码不一致！！");
  162.         }
  163.         // 2 、调用userService
  164.         userService.updatePwd(new_pwd);
  165.         return Result.success();
  166.     }
  167. }

6.2 service

  1. package com.bocai.service;
  2.  
  3. import com.bocai.pojo.User;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5.  
  6. /**
  7. * @author cheng
  8. * @description 针对表【user(用户表)】的数据库操作Service
  9. * @createDate 2023-11-13 19:54:41
  10. */
  11. public interface UserService extends IService<User> {
  12.  
  13.     /**
  14.      * 用户注册
  15.      * @param username
  16.      * @param password
  17.      */
  18.     void register(String username, String password);
  19.  
  20.     /**
  21.      * 根据用户名 --查询用户
  22.      * @param username
  23.      * @return
  24.      */
  25.     User queryUserByUsername(String username);
  26.  
  27.     /**
  28.      * 更新用户
  29.      * @param user
  30.      */
  31.     void updateUser(User user);
  32.  
  33.     /**
  34.      * 更新头像
  35.      * @param avatarUrl
  36.      */
  37.     void updateAvatar(String avatarUrl);
  38.  
  39.     /**
  40.      * 更新密码
  41.      * @param newPwd
  42.      */
  43.     void updatePwd(String newPwd);
  44. }

6.3 serviceImpl

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  5. import com.bocai.pojo.User;
  6. import com.bocai.service.UserService;
  7. import com.bocai.mapper.UserMapper;
  8. import com.bocai.utils.Md5Util;
  9. import com.bocai.utils.ThreadLocalUtil;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.stereotype.Service;
  12.  
  13. import java.time.LocalDateTime;
  14. import java.util.HashMap;
  15. import java.util.Map;
  16.  
  17. /**
  18. * @author cheng
  19. * @description 针对表【user(用户表)】的数据库操作Service实现
  20. * @createDate 2023-11-13 19:54:41
  21. */
  22. @Service
  23. public class UserServiceImpl extends ServiceImpl<UserMapper, User>
  24.     implements UserService{
  25.  
  26.     @Autowired
  27.     private UserMapper userMapper;
  28.  
  29.     /**
  30.      * 注册
  31.      * @param username
  32.      * @param password
  33.      */
  34.     @Override
  35.     public void register(String username, String password) {
  36.  
  37.         //密码加密
  38.         String md5String = Md5Util.getMD5String(password);
  39.         User user = new User();
  40.         user.setUsername(username);
  41.         user.setPassword(md5String);
  42.         user.setCreateTime(LocalDateTime.now());
  43.         user.setUpdateTime(LocalDateTime.now());
  44.         userMapper.insert(user);
  45.  
  46.  
  47.     }
  48.  
  49.     /**
  50.      * 查询用户
  51.      * @param username
  52.      * @return
  53.      */
  54.     @Override
  55.     public User queryUserByUsername(String username) {
  56.         //查询用户
  57.         LambdaQueryWrapper<User> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  58.         lambdaQueryWrapper.eq(username != null, User::getUsername,username);
  59.         User user = userMapper.selectOne(lambdaQueryWrapper);
  60.         return user;
  61.     }
  62.  
  63.     /**
  64.      * 更新用户
  65.      * @param user
  66.      */
  67.     @Override
  68.     public void updateUser(User user) {
  69.         user.setUpdateTime(LocalDateTime.now());
  70.         userMapper.updateById(user);
  71.     }
  72.  
  73.     /**
  74.      * 更新头像
  75.      * @param avatarUrl
  76.      */
  77.     @Override
  78.     public void updateAvatar(String avatarUrl) {
  79.         Map<String, Object> map = ThreadLocalUtil.get();
  80.         Integer id = (Integer) map.get("id");
  81.         User user = new User();
  82.         user.setId(id);
  83.         user.setUpdateTime(LocalDateTime.now());
  84.         user.setUserPic(avatarUrl);
  85.         userMapper.updateById(user);
  86.     }
  87.  
  88.     /**
  89.      * 更新密码
  90.      * @param newPwd
  91.      */
  92.     @Override
  93.     public void updatePwd(String newPwd) {
  94.         Map<String, Object> map = ThreadLocalUtil.get();
  95.         Integer id = (Integer) map.get("id");
  96.         User user = new User();
  97.         user.setId(id);
  98.         user.setUpdateTime(LocalDateTime.now());
  99.         user.setPassword(Md5Util.getMD5String(newPwd));
  100.         userMapper.updateById(user);
  101.     }
  102. }
  103.  
  104.  
  105.  
  106.

三、文章分类

1、新增文章分类

1.1 CategoryController

@Validated

  1. package com.bocai.controller;
  2.  
  3. import com.bocai.common.Result;
  4. import com.bocai.pojo.Category;
  5. import com.bocai.pojo.User;
  6. import com.bocai.service.CategoryService;
  7. import lombok.extern.slf4j.Slf4j;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.validation.annotation.Validated;
  10. import org.springframework.web.bind.annotation.PostMapping;
  11. import org.springframework.web.bind.annotation.RequestBody;
  12. import org.springframework.web.bind.annotation.RequestMapping;
  13. import org.springframework.web.bind.annotation.RestController;
  14.  
  15. @RestController
  16. @Slf4j
  17. @RequestMapping("/category")
  18. public class CategoryController {
  19.  
  20.     @Autowired
  21.     private CategoryService categoryService;
  22.  
  23.     /**
  24.      * 添加文章分类
  25.      * @param category
  26.      * @return
  27.      */
  28.     @PostMapping
  29.     public Result add(@RequestBody @Validated(Category.Add.class) Category category){
  30.         log.info("新增的文章为：{}",category);
  31.         // 查询文章分类是否已被创建
  32.         Category queryCategory = categoryService.queryCategoryByCategoryName(category);
  33.         if (queryCategory == null){
  34.             //文章分类没有被创建
  35.             categoryService.add(category);
  36.             return Result.success();
  37.         }else{
  38.             return Result.error("文章分类被占用，不能创建重复");
  39.         }
  40.     }
  41.  
  42. }

1.2 service

  1. package com.bocai.service;
  2.  
  3. import com.bocai.pojo.Category;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5.  
  6. /**
  7. * @author cheng
  8. * @description 针对表【category】的数据库操作Service
  9. * @createDate 2023-11-13 19:55:04
  10. */
  11. public interface CategoryService extends IService<Category> {
  12.  
  13.     /**
  14.      * 新增文章分类
  15.      * @param category
  16.      */
  17.     void add(Category category);
  18.  
  19.       /**
  20.      * 根据分类名称查询文章分类
  21.      * @param category
  22.      * @return
  23.      */
  24.     Category queryCategoryByCategoryName(Category category);
  25. }

1.3 servcieImpl

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  5. import com.bocai.pojo.Category;
  6. import com.bocai.service.CategoryService;
  7. import com.bocai.mapper.CategoryMapper;
  8. import com.bocai.utils.ThreadLocalUtil;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.stereotype.Service;
  11.  
  12. import java.time.LocalDateTime;
  13. import java.util.Map;
  14.  
  15. /**
  16. * @author cheng
  17. * @description 针对表【category】的数据库操作Service实现
  18. * @createDate 2023-11-13 19:55:04
  19. */
  20. @Service
  21. public class CategoryServiceImpl extends ServiceImpl<CategoryMapper, Category>
  22.     implements CategoryService{
  23.  
  24.     @Autowired
  25.     private CategoryMapper categoryMapper;
  26.  
  27.     /**
  28.      * 新增文章分类
  29.      * @param category
  30.      */
  31.     @Override
  32.     public void add(Category category) {
  33.         Map<String, Object> map = ThreadLocalUtil.get();
  34.         Integer createUserId = (Integer) map.get("id");
  35.         category.setCreateTime(LocalDateTime.now());
  36.         category.setUpdateTime(LocalDateTime.now());
  37.         category.setCreateUser(createUserId);
  38.         categoryMapper.insert(category);
  39.     }
  40.  
  41.     /**
  42.      * 根据传入参数判断当前对象是否在对象中存在
  43.      * @param category
  44.      * @return
  45.      */
  46.     @Override
  47.     public Category queryCategoryByCategoryName(Category category) {
  48.         LambdaQueryWrapper<Category> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  49.         lambdaQueryWrapper.eq(category.getCategoryName() != null, Category::getCategoryName,category.getCategoryName())
  50.                 .ne(category.getId() != null, Category::getId,category.getId()) ;
  51.         Category queryCategory = categoryMapper.selectOne(lambdaQueryWrapper);
  52.         return queryCategory;
  53.     }
  54. }
  55.  
  56.  
  57.  
  58.

2、文章分类列表

2.1 CategoryController

1、实体类Category指定日期返回格式   @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")

2、实体类Category   @JsonIgnore // json返回不显示

  1. package com.bocai.controller;
  2.  
  3. import com.bocai.common.Result;
  4. import com.bocai.pojo.Category;
  5. import com.bocai.pojo.User;
  6. import com.bocai.service.CategoryService;
  7. import lombok.extern.slf4j.Slf4j;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.validation.annotation.Validated;
  10. import org.springframework.web.bind.annotation.*;
  11.  
  12. import java.util.List;
  13.  
  14. @RestController
  15. @Slf4j
  16. @RequestMapping("/category")
  17. public class CategoryController {
  18.  
  19.     @Autowired
  20.     private CategoryService categoryService;
  21.  
  22.     /**
  23.      * 添加文章分类
  24.      * @param category
  25.      * @return
  26.      */
  27.     @PostMapping
  28.     public Result add(@RequestBody @Validated(Category.Add.class) Category category){
  29.         log.info("新增的文章为：{}",category);
  30.         // 查询文章分类是否已被创建
  31.         Category queryCategory = categoryService.queryCategoryByCategoryName(category);
  32.         if (queryCategory == null){
  33.             //文章分类没有被创建
  34.             categoryService.add(category);
  35.             return Result.success();
  36.         }else{
  37.             return Result.error("文章分类被占用，不能创建重复");
  38.         }
  39.     }
  40.  
  41.     /**
  42.      * 列表查询当前登录用户创建的文章分类
  43.      * @return
  44.      */
  45.     @GetMapping
  46.     public Result list(){
  47.         log.info("列表查询当前登录用户创建的文章分类");
  48.         List list = categoryService.categorylist();
  49.         return Result.success(list);
  50.     }
  51.  
  52.  
  53. }

2.2 service

  1. package com.bocai.service;
  2.  
  3. import com.bocai.pojo.Category;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5.  
  6. import java.util.List;
  7.  
  8. /**
  9. * @author cheng
  10. * @description 针对表【category】的数据库操作Service
  11. * @createDate 2023-11-13 19:55:04
  12. */
  13. public interface CategoryService extends IService<Category> {
  14.  
  15.     /**
  16.      * 新增文章分类
  17.      * @param category
  18.      */
  19.     void add(Category category);
  20.  
  21.     /**
  22.      * 根据分类名称查询文章分类
  23.      * @param category
  24.      * @return
  25.      */
  26.     Category queryCategoryByCategoryName(Category category);
  27.  
  28.     /**
  29.      * 列表查询当前登录用户创建的文章分类
  30.      * @return
  31.      */
  32.     List categorylist();
  33. }

2.3 servcieImpl

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  5. import com.bocai.pojo.Category;
  6. import com.bocai.service.CategoryService;
  7. import com.bocai.mapper.CategoryMapper;
  8. import com.bocai.utils.ThreadLocalUtil;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.stereotype.Service;
  11.  
  12. import java.time.LocalDateTime;
  13. import java.util.List;
  14. import java.util.Map;
  15.  
  16. /**
  17. * @author cheng
  18. * @description 针对表【category】的数据库操作Service实现
  19. * @createDate 2023-11-13 19:55:04
  20. */
  21. @Service
  22. public class CategoryServiceImpl extends ServiceImpl<CategoryMapper, Category>
  23.     implements CategoryService{
  24.  
  25.     @Autowired
  26.     private CategoryMapper categoryMapper;
  27.  
  28.     /**
  29.      * 新增文章分类
  30.      * @param category
  31.      */
  32.     @Override
  33.     public void add(Category category) {
  34.         Map<String, Object> map = ThreadLocalUtil.get();
  35.         Integer createUserId = (Integer) map.get("id");
  36.         category.setCreateTime(LocalDateTime.now());
  37.         category.setUpdateTime(LocalDateTime.now());
  38.         category.setCreateUser(createUserId);
  39.         categoryMapper.insert(category);
  40.     }
  41.  
  42.     /**
  43.      * 根据传入参数判断当前对象是否在对象中存在
  44.      * @param category
  45.      * @return
  46.      */
  47.     @Override
  48.     public Category queryCategoryByCategoryName(Category category) {
  49.         LambdaQueryWrapper<Category> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  50.         lambdaQueryWrapper.eq(category.getCategoryName() != null, Category::getCategoryName,category.getCategoryName())
  51.                 .ne(category.getId() != null, Category::getId,category.getId()) ;
  52.         Category queryCategory = categoryMapper.selectOne(lambdaQueryWrapper);
  53.         return queryCategory;
  54.     }
  55.  
  56.     /**
  57.      * 列表查询当前登录用户创建的文章分类
  58.      * @return
  59.      */
  60.     @Override
  61.     public List categorylist() {
  62.         Map<String, Object> map = ThreadLocalUtil.get();
  63.         Integer userId = (Integer) map.get("id");
  64.         LambdaQueryWrapper<Category> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  65.         lambdaQueryWrapper.eq(userId != null,Category::getCreateUser,userId);
  66.         return categoryMapper.selectList(lambdaQueryWrapper);
  67.     }
  68. }
  69.  
  70.  
  71.  
  72.

3、 获取文章分类详情

3.1 CategoryController

  1. package com.bocai.controller;
  2.  
  3. import com.bocai.common.Result;
  4. import com.bocai.pojo.Category;
  5. import com.bocai.pojo.User;
  6. import com.bocai.service.CategoryService;
  7. import lombok.extern.slf4j.Slf4j;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.validation.annotation.Validated;
  10. import org.springframework.web.bind.annotation.*;
  11.  
  12. import java.util.List;
  13.  
  14. @RestController
  15. @Slf4j
  16. @RequestMapping("/category")
  17. public class CategoryController {
  18.  
  19.     @Autowired
  20.     private CategoryService categoryService;
  21.  
  22.     /**
  23.      * 添加文章分类
  24.      * @param category
  25.      * @return
  26.      */
  27.     @PostMapping
  28.     public Result add(@RequestBody @Validated(Category.Add.class) Category category){
  29.         log.info("新增的文章为：{}",category);
  30.         // 查询文章分类是否已被创建
  31.         Category queryCategory = categoryService.queryCategoryByCategoryName(category);
  32.         if (queryCategory == null){
  33.             //文章分类没有被创建
  34.             categoryService.add(category);
  35.             return Result.success();
  36.         }else{
  37.             return Result.error("文章分类被占用，不能创建重复");
  38.         }
  39.     }
  40.  
  41.     /**
  42.      * 列表查询当前登录用户创建的文章分类
  43.      * @return
  44.      */
  45.     @GetMapping
  46.     public Result list(){
  47.         log.info("列表查询当前登录用户创建的文章分类");
  48.         List list = categoryService.categorylist();
  49.         return Result.success(list);
  50.     }
  51.  
  52.     /**
  53.      * 根据id查询文章分类
  54.      * @param id
  55.      * @return
  56.      */
  57.     @GetMapping("/detail")
  58.     public Result detail(Integer id){
  59.         log.info("查询ID为：{}文章分类详情",id);
  60.         Category category = categoryService.queryCategoryById(id);
  61.         return Result.success(category);
  62.     }
  63.  
  64.  
  65. }

3.2 service

  1. package com.bocai.service;
  2.  
  3. import com.bocai.pojo.Category;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5.  
  6. import java.util.List;
  7.  
  8. /**
  9. * @author cheng
  10. * @description 针对表【category】的数据库操作Service
  11. * @createDate 2023-11-13 19:55:04
  12. */
  13. public interface CategoryService extends IService<Category> {
  14.  
  15.     /**
  16.      * 新增文章分类
  17.      * @param category
  18.      */
  19.     void add(Category category);
  20.  
  21.     /**
  22.      * 根据分类名称查询文章分类
  23.      * @param category
  24.      * @return
  25.      */
  26.     Category queryCategoryByCategoryName(Category category);
  27.  
  28.     /**
  29.      * 列表查询当前登录用户创建的文章分类
  30.      * @return
  31.      */
  32.     List categorylist();
  33.  
  34.     /**
  35.      * 根据id查询文章分类
  36.      * @param id
  37.      * @return
  38.      */
  39.     Category queryCategoryById(Integer id);
  40. }

3.3 servcieImpl

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  5. import com.bocai.pojo.Category;
  6. import com.bocai.service.CategoryService;
  7. import com.bocai.mapper.CategoryMapper;
  8. import com.bocai.utils.ThreadLocalUtil;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.stereotype.Service;
  11.  
  12. import java.time.LocalDateTime;
  13. import java.util.List;
  14. import java.util.Map;
  15.  
  16. /**
  17. * @author cheng
  18. * @description 针对表【category】的数据库操作Service实现
  19. * @createDate 2023-11-13 19:55:04
  20. */
  21. @Service
  22. public class CategoryServiceImpl extends ServiceImpl<CategoryMapper, Category>
  23.     implements CategoryService{
  24.  
  25.     @Autowired
  26.     private CategoryMapper categoryMapper;
  27.  
  28.     /**
  29.      * 新增文章分类
  30.      * @param category
  31.      */
  32.     @Override
  33.     public void add(Category category) {
  34.         Map<String, Object> map = ThreadLocalUtil.get();
  35.         Integer createUserId = (Integer) map.get("id");
  36.         category.setCreateTime(LocalDateTime.now());
  37.         category.setUpdateTime(LocalDateTime.now());
  38.         category.setCreateUser(createUserId);
  39.         categoryMapper.insert(category);
  40.     }
  41.  
  42.     /**
  43.      * 根据传入参数判断当前对象是否在对象中存在
  44.      * @param category
  45.      * @return
  46.      */
  47.     @Override
  48.     public Category queryCategoryByCategoryName(Category category) {
  49.         LambdaQueryWrapper<Category> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  50.         lambdaQueryWrapper.eq(category.getCategoryName() != null, Category::getCategoryName,category.getCategoryName())
  51.                 .ne(category.getId() != null, Category::getId,category.getId()) ;
  52.         Category queryCategory = categoryMapper.selectOne(lambdaQueryWrapper);
  53.         return queryCategory;
  54.     }
  55.  
  56.     /**
  57.      * 列表查询当前登录用户创建的文章分类
  58.      * @return
  59.      */
  60.     @Override
  61.     public List categorylist() {
  62.         Map<String, Object> map = ThreadLocalUtil.get();
  63.         Integer userId = (Integer) map.get("id");
  64.         LambdaQueryWrapper<Category> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  65.         lambdaQueryWrapper.eq(userId != null,Category::getCreateUser,userId);
  66.         return categoryMapper.selectList(lambdaQueryWrapper);
  67.     }
  68.  
  69.     /**
  70.      * 根据id查询文章分类
  71.      * @param id
  72.      * @return
  73.      */
  74.     @Override
  75.     public Category queryCategoryById(Integer id) {
  76.  
  77.         return  categoryMapper.selectById(id);
  78.     }
  79. }
  80.  
  81.  
  82.  
  83.

4、更新文章分类

4.1 CategoryController

分组校验，这里主要原因是实体id字段新增不需要验证，修改需要验证。

在实体类进行修改，然后在CategoryController指定使用哪个分组

  1. package com.bocai.controller;
  2.  
  3. import com.bocai.common.Result;
  4. import com.bocai.pojo.Category;
  5. import com.bocai.pojo.User;
  6. import com.bocai.service.CategoryService;
  7. import lombok.extern.slf4j.Slf4j;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.validation.annotation.Validated;
  10. import org.springframework.web.bind.annotation.*;
  11.  
  12. import java.util.List;
  13.  
  14. @RestController
  15. @Slf4j
  16. @RequestMapping("/category")
  17. public class CategoryController {
  18.  
  19.     @Autowired
  20.     private CategoryService categoryService;
  21.  
  22.     /**
  23.      * 添加文章分类
  24.      * @param category
  25.      * @return
  26.      */
  27.     @PostMapping
  28.     public Result add(@RequestBody @Validated(Category.Add.class) Category category){
  29.         log.info("新增的文章为：{}",category);
  30.         // 查询文章分类是否已被创建
  31.         Category queryCategory = categoryService.queryCategoryByCategoryName(category);
  32.         if (queryCategory == null){
  33.             //文章分类没有被创建
  34.             categoryService.add(category);
  35.             return Result.success();
  36.         }else{
  37.             return Result.error("文章分类被占用，不能创建重复");
  38.         }
  39.     }
  40.  
  41.     /**
  42.      * 列表查询当前登录用户创建的文章分类
  43.      * @return
  44.      */
  45.     @GetMapping
  46.     public Result list(){
  47.         log.info("列表查询当前登录用户创建的文章分类");
  48.         List list = categoryService.categorylist();
  49.         return Result.success(list);
  50.     }
  51.  
  52.     /**
  53.      * 根据id查询文章分类
  54.      * @param id
  55.      * @return
  56.      */
  57.     @GetMapping("/detail")
  58.     public Result detail(Integer id){
  59.         log.info("查询ID为：{}文章分类详情",id);
  60.         Category category = categoryService.queryCategoryById(id);
  61.         return Result.success(category);
  62.     }
  63.  
  64.     /**
  65.      * 根据id修改文章分类
  66.      * @param category
  67.      * @return
  68.      */
  69.     @PutMapping
  70.     public Result update(@RequestBody @Validated(Category.Update.class) Category category) {
  71.         log.info("修改的文章分类为：{}", category);
  72.         // 查询文章分类是否已被创建
  73.         Category queryCategory = categoryService.queryCategoryByCategoryName(category);
  74.  
  75.         if (queryCategory == null){
  76.             //文章分类没有重复
  77.             categoryService.updateCategoryById(category);
  78.             return Result.success();
  79.         }else{
  80.             return Result.error("文章分类被占用，不能修改为重复");
  81.         }
  82.  
  83.     }
  84.  
  85.  
  86. }

4.2 service

  1. package com.bocai.service;
  2.  
  3. import com.bocai.pojo.Category;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5.  
  6. import java.util.List;
  7.  
  8. /**
  9. * @author cheng
  10. * @description 针对表【category】的数据库操作Service
  11. * @createDate 2023-11-13 19:55:04
  12. */
  13. public interface CategoryService extends IService<Category> {
  14.  
  15.     /**
  16.      * 新增文章分类
  17.      * @param category
  18.      */
  19.     void add(Category category);
  20.  
  21.     /**
  22.      * 根据分类名称查询文章分类
  23.      * @param category
  24.      * @return
  25.      */
  26.     Category queryCategoryByCategoryName(Category category);
  27.  
  28.     /**
  29.      * 列表查询当前登录用户创建的文章分类
  30.      * @return
  31.      */
  32.     List categorylist();
  33.  
  34.     /**
  35.      * 根据id查询文章分类
  36.      * @param id
  37.      * @return
  38.      */
  39.     Category queryCategoryById(Integer id);
  40.  
  41.     /**
  42.      * 根据id修改文章分类
  43.      * @param category
  44.      */
  45.     void updateCategoryById(Category category);
  46. }

4.3 servcieImpl

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  5. import com.bocai.pojo.Category;
  6. import com.bocai.service.CategoryService;
  7. import com.bocai.mapper.CategoryMapper;
  8. import com.bocai.utils.ThreadLocalUtil;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.stereotype.Service;
  11.  
  12. import java.time.LocalDateTime;
  13. import java.util.List;
  14. import java.util.Map;
  15.  
  16. /**
  17. * @author cheng
  18. * @description 针对表【category】的数据库操作Service实现
  19. * @createDate 2023-11-13 19:55:04
  20. */
  21. @Service
  22. public class CategoryServiceImpl extends ServiceImpl<CategoryMapper, Category>
  23.     implements CategoryService{
  24.  
  25.     @Autowired
  26.     private CategoryMapper categoryMapper;
  27.  
  28.     /**
  29.      * 新增文章分类
  30.      * @param category
  31.      */
  32.     @Override
  33.     public void add(Category category) {
  34.         Map<String, Object> map = ThreadLocalUtil.get();
  35.         Integer createUserId = (Integer) map.get("id");
  36.         category.setCreateTime(LocalDateTime.now());
  37.         category.setUpdateTime(LocalDateTime.now());
  38.         category.setCreateUser(createUserId);
  39.         categoryMapper.insert(category);
  40.     }
  41.  
  42.     /**
  43.      * 根据传入参数判断当前对象是否在对象中存在
  44.      * @param category
  45.      * @return
  46.      */
  47.     @Override
  48.     public Category queryCategoryByCategoryName(Category category) {
  49.         LambdaQueryWrapper<Category> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  50.         lambdaQueryWrapper.eq(category.getCategoryName() != null, Category::getCategoryName,category.getCategoryName())
  51.                 .ne(category.getId() != null, Category::getId,category.getId()) ;
  52.         Category queryCategory = categoryMapper.selectOne(lambdaQueryWrapper);
  53.         return queryCategory;
  54.     }
  55.  
  56.     /**
  57.      * 列表查询当前登录用户创建的文章分类
  58.      * @return
  59.      */
  60.     @Override
  61.     public List categorylist() {
  62.         Map<String, Object> map = ThreadLocalUtil.get();
  63.         Integer userId = (Integer) map.get("id");
  64.         LambdaQueryWrapper<Category> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  65.         lambdaQueryWrapper.eq(userId != null,Category::getCreateUser,userId);
  66.         return categoryMapper.selectList(lambdaQueryWrapper);
  67.     }
  68.  
  69.     /**
  70.      * 根据id查询文章分类
  71.      * @param id
  72.      * @return
  73.      */
  74.     @Override
  75.     public Category queryCategoryById(Integer id) {
  76.  
  77.         return  categoryMapper.selectById(id);
  78.     }
  79.  
  80.     /**
  81.      * 根据id修改文章分类
  82.      * @param category
  83.      */
  84.     @Override
  85.     public void updateCategoryById(Category category) {
  86.         category.setUpdateTime(LocalDateTime.now());
  87.         categoryMapper.updateById(category);
  88.  
  89.     }
  90. }
  91.  
  92.  
  93.  
  94.

5、删除文章分类

5.1 CategoryController

  1. package com.bocai.controller;
  2.  
  3. import com.bocai.common.Result;
  4. import com.bocai.pojo.Category;
  5. import com.bocai.pojo.User;
  6. import com.bocai.service.CategoryService;
  7. import lombok.extern.slf4j.Slf4j;
  8. import org.apache.ibatis.annotations.Delete;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.validation.annotation.Validated;
  11. import org.springframework.web.bind.annotation.*;
  12.  
  13. import java.util.List;
  14.  
  15. @RestController
  16. @Slf4j
  17. @RequestMapping("/category")
  18. public class CategoryController {
  19.  
  20.     @Autowired
  21.     private CategoryService categoryService;
  22.  
  23.     /**
  24.      * 添加文章分类
  25.      * @param category
  26.      * @return
  27.      */
  28.     @PostMapping
  29.     public Result add(@RequestBody @Validated(Category.Add.class) Category category){
  30.         log.info("新增的文章为：{}",category);
  31.         // 查询文章分类是否已被创建
  32.         Category queryCategory = categoryService.queryCategoryByCategoryName(category);
  33.         if (queryCategory == null){
  34.             //文章分类没有被创建
  35.             categoryService.add(category);
  36.             return Result.success();
  37.         }else{
  38.             return Result.error("文章分类被占用，不能创建重复");
  39.         }
  40.     }
  41.  
  42.     /**
  43.      * 列表查询当前登录用户创建的文章分类
  44.      * @return
  45.      */
  46.     @GetMapping
  47.     public Result list(){
  48.         log.info("列表查询当前登录用户创建的文章分类");
  49.         List list = categoryService.categorylist();
  50.         return Result.success(list);
  51.     }
  52.  
  53.     /**
  54.      * 根据id查询文章分类
  55.      * @param id
  56.      * @return
  57.      */
  58.     @GetMapping("/detail")
  59.     public Result detail(Integer id){
  60.         log.info("查询ID为：{}文章分类详情",id);
  61.         Category category = categoryService.queryCategoryById(id);
  62.         return Result.success(category);
  63.     }
  64.  
  65.     /**
  66.      * 根据id修改文章分类
  67.      * @param category
  68.      * @return
  69.      */
  70.     @PutMapping
  71.     public Result update(@RequestBody @Validated(Category.Update.class) Category category) {
  72.         log.info("修改的文章分类为：{}", category);
  73.         // 查询文章分类是否已被创建
  74.         Category queryCategory = categoryService.queryCategoryByCategoryName(category);
  75.  
  76.         if (queryCategory == null){
  77.             //文章分类没有重复
  78.             categoryService.updateCategoryById(category);
  79.             return Result.success();
  80.         }else{
  81.             return Result.error("文章分类被占用，不能修改为重复");
  82.         }
  83.  
  84.     }
  85.  
  86.     /**
  87.      * 根据id删除文章分类
  88.      * @param id
  89.      * @return
  90.      */
  91.     @DeleteMapping
  92.     public Result delete(Integer id){
  93.         log.info("根据id删除文章分类{}",id);
  94.         categoryService.deleteCategoryById(id);
  95.         return Result.success();
  96.     }
  97.  
  98.  
  99. }

5.2 service

  1. package com.bocai.service;
  2.  
  3. import com.bocai.pojo.Category;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5.  
  6. import java.util.List;
  7.  
  8. /**
  9. * @author cheng
  10. * @description 针对表【category】的数据库操作Service
  11. * @createDate 2023-11-13 19:55:04
  12. */
  13. public interface CategoryService extends IService<Category> {
  14.  
  15.     /**
  16.      * 新增文章分类
  17.      * @param category
  18.      */
  19.     void add(Category category);
  20.  
  21.     /**
  22.      * 根据分类名称查询文章分类
  23.      * @param category
  24.      * @return
  25.      */
  26.     Category queryCategoryByCategoryName(Category category);
  27.  
  28.     /**
  29.      * 列表查询当前登录用户创建的文章分类
  30.      * @return
  31.      */
  32.     List categorylist();
  33.  
  34.     /**
  35.      * 根据id查询文章分类
  36.      * @param id
  37.      * @return
  38.      */
  39.     Category queryCategoryById(Integer id);
  40.  
  41.     /**
  42.      * 根据id修改文章分类
  43.      * @param category
  44.      */
  45.     void updateCategoryById(Category category);
  46.  
  47.     /**
  48.      * 根据id删除文章分类
  49.      * @param id
  50.      */
  51.     void deleteCategoryById(Integer id);
  52. }

5.3 servcieImpl

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  5. import com.bocai.pojo.Category;
  6. import com.bocai.service.CategoryService;
  7. import com.bocai.mapper.CategoryMapper;
  8. import com.bocai.utils.ThreadLocalUtil;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.stereotype.Service;
  11.  
  12. import java.time.LocalDateTime;
  13. import java.util.List;
  14. import java.util.Map;
  15.  
  16. /**
  17. * @author cheng
  18. * @description 针对表【category】的数据库操作Service实现
  19. * @createDate 2023-11-13 19:55:04
  20. */
  21. @Service
  22. public class CategoryServiceImpl extends ServiceImpl<CategoryMapper, Category>
  23.     implements CategoryService{
  24.  
  25.     @Autowired
  26.     private CategoryMapper categoryMapper;
  27.  
  28.     /**
  29.      * 新增文章分类
  30.      * @param category
  31.      */
  32.     @Override
  33.     public void add(Category category) {
  34.         Map<String, Object> map = ThreadLocalUtil.get();
  35.         Integer createUserId = (Integer) map.get("id");
  36.         category.setCreateTime(LocalDateTime.now());
  37.         category.setUpdateTime(LocalDateTime.now());
  38.         category.setCreateUser(createUserId);
  39.         categoryMapper.insert(category);
  40.     }
  41.  
  42.     @Override
  43.     public Category queryCategoryByCategoryName(String categoryName) {
  44.         LambdaQueryWrapper<Category> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  45.         lambdaQueryWrapper.eq(categoryName != null, Category::getCategoryName,categoryName);
  46.         Category category = categoryMapper.selectOne(lambdaQueryWrapper);
  47.         return category;
  48.     }
  49.  
  50.     /**
  51.      * 列表查询当前登录用户创建的文章分类
  52.      * @return
  53.      */
  54.     @Override
  55.     public List categorylist() {
  56.         Map<String, Object> map = ThreadLocalUtil.get();
  57.         Integer userId = (Integer) map.get("id");
  58.         LambdaQueryWrapper<Category> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  59.         lambdaQueryWrapper.eq(userId != null,Category::getCreateUser,userId);
  60.         return categoryMapper.selectList(lambdaQueryWrapper);
  61.     }
  62.  
  63.     /**
  64.      * 根据id查询文章分类
  65.      * @param id
  66.      * @return
  67.      */
  68.     @Override
  69.     public Category queryCategoryById(Integer id) {
  70.  
  71.         return  categoryMapper.selectById(id);
  72.     }
  73.  
  74.     /**
  75.      * 根据id修改文章分类
  76.      * @param category
  77.      */
  78.     @Override
  79.     public void updateCategoryById(Category category) {
  80.         category.setUpdateTime(LocalDateTime.now());
  81.         categoryMapper.updateById(category);
  82.  
  83.     }
  84.  
  85.     /**
  86.      * 根据id删除文章分类
  87.      * @param id
  88.      */
  89.     @Override
  90.     public void deleteCategoryById(Integer id) {
  91.         categoryMapper.deleteById(id);
  92.  
  93.     }
  94. }
  95.  
  96.  
  97.  
  98.

四、文章管理

1、新增文章

1.1 ArticleCtroller

自定义校验

  1. package com.bocai.controller;
  2.  
  3.  
  4. import com.bocai.common.Result;
  5. import com.bocai.pojo.Article;
  6. import com.bocai.pojo.Category;
  7. import com.bocai.service.ArticleService;
  8. import lombok.extern.slf4j.Slf4j;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.validation.annotation.Validated;
  11. import org.springframework.web.bind.annotation.PostMapping;
  12. import org.springframework.web.bind.annotation.RequestBody;
  13. import org.springframework.web.bind.annotation.RequestMapping;
  14. import org.springframework.web.bind.annotation.RestController;
  15.  
  16. @RestController
  17. @Slf4j
  18. @RequestMapping("/article")
  19. public class ArticleCtroller {
  20.  
  21.     @Autowired
  22.     private ArticleService articleService;
  23.  
  24.     /**
  25.      * 添加文章
  26.      * @param article
  27.      * @return
  28.      */
  29.     @PostMapping
  30.     public Result add(@RequestBody @Validated Article article){
  31.         log.info("新增文章为：{}",article);
  32.         //查询文章标题是否被创建
  33.         Article queryArticle = articleService.queryArticleByTitle(article);
  34.         if(queryArticle == null){
  35.             //没有重复的文章标题
  36.             articleService.add(article);
  37.             return Result.success();
  38.         }
  39.         else {
  40.             // 存在重复文章标题
  41.             return Result.error("文章标题重复！");
  42.         }
  43.  
  44.     }
  45. }

1.2 service

  1. package com.bocai.service;
  2.  
  3. import com.bocai.pojo.Article;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5.  
  6. /**
  7. * @author cheng
  8. * @description 针对表【article】的数据库操作Service
  9. * @createDate 2023-11-13 19:55:11
  10. */
  11. public interface ArticleService extends IService<Article> {
  12.  
  13.     /**
  14.      * 新增文章
  15.      * @param article
  16.      */
  17.     void add(Article article);
  18.  
  19.      /**
  20.      * 根据文章标题查询文章
  21.      * @param article
  22.      * @return
  23.      */
  24.     Article queryArticleByTitle(Article article);
  25. }

1.3 serviceImpl

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  5. import com.bocai.pojo.Article;
  6. import com.bocai.pojo.Category;
  7. import com.bocai.service.ArticleService;
  8. import com.bocai.mapper.ArticleMapper;
  9. import com.bocai.utils.ThreadLocalUtil;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.stereotype.Service;
  12.  
  13. import java.time.LocalDateTime;
  14. import java.util.Map;
  15.  
  16. /**
  17. * @author cheng
  18. * @description 针对表【article】的数据库操作Service实现
  19. * @createDate 2023-11-13 19:55:11
  20. */
  21. @Service
  22. public class ArticleServiceImpl extends ServiceImpl<ArticleMapper, Article>
  23.     implements ArticleService{
  24.  
  25.  
  26.     @Autowired
  27.     private ArticleMapper articleMapper;
  28.  
  29.     /**
  30.      * 新增文章
  31.      * @param article
  32.      */
  33.     @Override
  34.     public void add(Article article) {
  35.         Map<String, Object> map = ThreadLocalUtil.get();
  36.         Integer createUserId = (Integer) map.get("id");
  37.         article.setCreateUser(createUserId);
  38.         article.setCreateTime(LocalDateTime.now());
  39.         article.setUpdateTime(LocalDateTime.now());
  40.         articleMapper.insert(article);
  41.     }
  42.  
  43.     /**
  44.      * 根据文章标题查询文章
  45.      * @param article
  46.      * @return
  47.      */
  48.     @Override
  49.     public Article queryArticleByTitle(Article article) {
  50.         LambdaQueryWrapper<Article> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  51.         lambdaQueryWrapper.eq(article.getTitle() != null, Article::getTitle,article.getTitle())
  52.                 .ne(article.getId() != null,Article::getId,article.getId());
  53.  
  54.         return articleMapper.selectOne(lambdaQueryWrapper);
  55.     }
  56. }
  57.  
  58.  
  59.  
  60.

2、文章列表（条件分页）

2.1 ArticleCtroller

  1. package com.bocai.controller;
  2.  
  3.  
  4. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  5. import com.baomidou.mybatisplus.core.toolkit.StringUtils;
  6. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  7. import com.bocai.common.Result;
  8. import com.bocai.pojo.Article;
  9. import com.bocai.pojo.Category;
  10. import com.bocai.pojo.Emp;
  11. import com.bocai.pojo.PageBean;
  12. import com.bocai.service.ArticleService;
  13. import lombok.extern.slf4j.Slf4j;
  14. import org.springframework.beans.factory.annotation.Autowired;
  15. import org.springframework.format.annotation.DateTimeFormat;
  16. import org.springframework.validation.annotation.Validated;
  17. import org.springframework.web.bind.annotation.*;
  18.  
  19. import java.time.LocalDate;
  20.  
  21. @RestController
  22. @Slf4j
  23. @RequestMapping("/article")
  24. public class ArticleCtroller {
  25.  
  26.     @Autowired
  27.     private ArticleService articleService;
  28.  
  29.     /**
  30.      * 添加文章
  31.      * @param article
  32.      * @return
  33.      */
  34.     @PostMapping
  35.     public Result add(@RequestBody @Validated Article article){
  36.         log.info("新增文章为：{}",article);
  37.         //查询文章标题是否被创建
  38.         Article queryArticle = articleService.queryArticleByTitle(article);
  39.         if(queryArticle == null){
  40.             //没有重复的文章标题
  41.             articleService.add(article);
  42.             return Result.success();
  43.         }
  44.         else {
  45.             // 存在重复文章标题
  46.             return Result.error("文章标题重复！");
  47.         }
  48.  
  49.     }
  50.  
  51.     /**
  52.      * 文章根据条件查询，并分页
  53.      * @param pageNum
  54.      * @param pageSize
  55.      * @param categoryId
  56.      * @param state
  57.      * @return
  58.      */
  59.     @GetMapping
  60.     public Result page(@RequestParam(defaultValue = "1") Integer pageNum,
  61.                       @RequestParam(defaultValue = "10") Integer pageSize,
  62.                        String categoryId, String state){
  63.         log.info("分页查询参数：当前页：{} 每页条数： {} 文章分类ID：{}  状态：{} ",pageNum,pageSize,categoryId,state);
  64.         PageBean pageBean = articleService.pageList(pageNum,pageSize,categoryId,state);
  65.         return Result.success(pageBean);
  66.     }
  67. }
  68.

2.2 service

  1. package com.bocai.service;
  2.  
  3. import com.bocai.pojo.Article;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5. import com.bocai.pojo.PageBean;
  6.  
  7. /**
  8. * @author cheng
  9. * @description 针对表【article】的数据库操作Service
  10. * @createDate 2023-11-13 19:55:11
  11. */
  12. public interface ArticleService extends IService<Article> {
  13.  
  14.     /**
  15.      * 新增文章
  16.      * @param article
  17.      */
  18.     void add(Article article);
  19.  
  20.    /**
  21.      * 根据文章标题查询文章
  22.      * @param article
  23.      * @return
  24.      */
  25.     Article queryArticleByTitle(Article article);
  26.  
  27.     /**
  28.      * 文章根据条件查询，并分页
  29.      * @param pageNum 当前页码
  30.      * @param pageSize 每页条数
  31.      * @param categoryId 文章分类ID
  32.      * @param state 状态
  33.      * @return
  34.      */
  35.     PageBean pageList(Integer pageNum, Integer pageSize, String categoryId, String state);
  36. }

2.3 serviceImpl

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.core.toolkit.StringUtils;
  5. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  6. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  7. import com.bocai.pojo.Article;
  8. import com.bocai.pojo.Category;
  9. import com.bocai.pojo.PageBean;
  10. import com.bocai.service.ArticleService;
  11. import com.bocai.mapper.ArticleMapper;
  12. import com.bocai.utils.ThreadLocalUtil;
  13. import org.springframework.beans.factory.annotation.Autowired;
  14. import org.springframework.stereotype.Service;
  15.  
  16. import java.time.LocalDateTime;
  17. import java.util.Map;
  18.  
  19. /**
  20. * @author cheng
  21. * @description 针对表【article】的数据库操作Service实现
  22. * @createDate 2023-11-13 19:55:11
  23. */
  24. @Service
  25. public class ArticleServiceImpl extends ServiceImpl<ArticleMapper, Article>
  26.     implements ArticleService{
  27.  
  28.  
  29.     @Autowired
  30.     private ArticleMapper articleMapper;
  31.  
  32.     /**
  33.      * 新增文章
  34.      * @param article
  35.      */
  36.     @Override
  37.     public void add(Article article) {
  38.         Map<String, Object> map = ThreadLocalUtil.get();
  39.         Integer createUserId = (Integer) map.get("id");
  40.         article.setCreateUser(createUserId);
  41.         article.setCreateTime(LocalDateTime.now());
  42.         article.setUpdateTime(LocalDateTime.now());
  43.         articleMapper.insert(article);
  44.     }
  45.  
  46.      /**
  47.      * 根据文章标题查询文章
  48.      * @param article
  49.      * @return
  50.      */
  51.     @Override
  52.     public Article queryArticleByTitle(Article article) {
  53.         LambdaQueryWrapper<Article> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  54.         lambdaQueryWrapper.eq(article.getTitle() != null, Article::getTitle,article.getTitle())
  55.                 .ne(article.getId() != null,Article::getId,article.getId());
  56.  
  57.         return articleMapper.selectOne(lambdaQueryWrapper);
  58.     }
  59.  
  60.     /**
  61.      * 文章根据条件查询，并分页
  62.      * @param pageNum 当前页码
  63.      * @param pageSize 每页条数
  64.      * @param categoryId 文章分类ID
  65.      * @param state 状态
  66.      * @return
  67.      */
  68.     @Override
  69.     public PageBean pageList(Integer pageNum, Integer pageSize, String categoryId, String state) {
  70.         Map<String,Object> map = ThreadLocalUtil.get();
  71.         String userId = (String) map.get("id");
  72.         LambdaQueryWrapper<Article> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  73.         lambdaQueryWrapper.eq(categoryId != null,Article::getCategoryId,categoryId)
  74.                 .eq(state != null,Article::getState,state)
  75.                 .eq(userId != null,Article::getCreateUser,userId);
  76.  
  77.         Page<Article> pageArticle = new Page<>(pageNum,pageSize);
  78.         articleMapper.selectPage(pageArticle,lambdaQueryWrapper);
  79.         PageBean pageBean = new PageBean(pageArticle.getTotal(),pageArticle.getRecords());
  80.  
  81.         return pageBean;
  82.     }
  83. }
  84.  
  85.  
  86.

3、获取文章详情

3.1 ArticleCtroller

  1. package com.bocai.controller;
  2.  
  3.  
  4. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  5. import com.baomidou.mybatisplus.core.toolkit.StringUtils;
  6. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  7. import com.bocai.common.Result;
  8. import com.bocai.pojo.Article;
  9. import com.bocai.pojo.Category;
  10. import com.bocai.pojo.Emp;
  11. import com.bocai.pojo.PageBean;
  12. import com.bocai.service.ArticleService;
  13. import lombok.extern.slf4j.Slf4j;
  14. import org.springframework.beans.factory.annotation.Autowired;
  15. import org.springframework.format.annotation.DateTimeFormat;
  16. import org.springframework.validation.annotation.Validated;
  17. import org.springframework.web.bind.annotation.*;
  18.  
  19. import java.time.LocalDate;
  20.  
  21. @RestController
  22. @Slf4j
  23. @RequestMapping("/article")
  24. public class ArticleCtroller {
  25.  
  26.     @Autowired
  27.     private ArticleService articleService;
  28.  
  29.     /**
  30.      * 添加文章
  31.      * @param article
  32.      * @return
  33.      */
  34.     @PostMapping
  35.     public Result add(@RequestBody @Validated Article article){
  36.         log.info("新增文章为：{}",article);
  37.         //查询文章标题是否被创建
  38.         String articleTitle = article.getTitle();
  39.         Article queryArticle = articleService.queryArticleByTitle(articleTitle);
  40.         if(queryArticle == null){
  41.             //没有重复的文章标题
  42.             articleService.add(article);
  43.             return Result.success();
  44.         }
  45.         else {
  46.             // 存在重复文章标题
  47.             return Result.error("文章标题重复！");
  48.         }
  49.  
  50.     }
  51.  
  52.     /**
  53.      * 文章根据条件查询，并分页
  54.      * @param pageNum
  55.      * @param pageSize
  56.      * @param categoryId
  57.      * @param state
  58.      * @return
  59.      */
  60.     @GetMapping
  61.     public Result page(@RequestParam(defaultValue = "1") Integer pageNum,
  62.                       @RequestParam(defaultValue = "10") Integer pageSize,
  63.                        String categoryId, String state){
  64.         log.info("分页查询参数：当前页：{} 每页条数： {} 文章分类ID：{}  状态：{} ",pageNum,pageSize,categoryId,state);
  65.         PageBean pageBean = articleService.pageList(pageNum,pageSize,categoryId,state);
  66.         return Result.success(pageBean);
  67.     }
  68.  
  69.     /**
  70.      * 文章详情
  71.      * @param id
  72.      * @return
  73.      */
  74.     @GetMapping("/detail")
  75.     public Result detail(Integer id){
  76.         log.info("文章id{}详情",id);
  77.         Article article = articleService.detail(id);
  78.         return Result.success(article);
  79.     }
  80. }
  81.

3.2 service

  1. package com.bocai.service;
  2.  
  3. import com.bocai.pojo.Article;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5. import com.bocai.pojo.PageBean;
  6.  
  7. /**
  8. * @author cheng
  9. * @description 针对表【article】的数据库操作Service
  10. * @createDate 2023-11-13 19:55:11
  11. */
  12. public interface ArticleService extends IService<Article> {
  13.  
  14.     /**
  15.      * 新增文章
  16.      * @param article
  17.      */
  18.     void add(Article article);
  19.  
  20.     /**
  21.      * 根据文章标题查询文章
  22.      * @param articleTitle
  23.      * @return
  24.      */
  25.     Article queryArticleByTitle(String articleTitle);
  26.  
  27.     /**
  28.      * 文章根据条件查询，并分页
  29.      * @param pageNum 当前页码
  30.      * @param pageSize 每页条数
  31.      * @param categoryId 文章分类ID
  32.      * @param state 状态
  33.      * @return
  34.      */
  35.     PageBean pageList(Integer pageNum, Integer pageSize, String categoryId, String state);
  36.  
  37.     /**
  38.      * 文章详情
  39.      * @param id
  40.      * @return
  41.      */
  42.     Article detail(Integer id);
  43. }

3.3 serviceImpl

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.core.toolkit.StringUtils;
  5. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  6. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  7. import com.bocai.pojo.Article;
  8. import com.bocai.pojo.Category;
  9. import com.bocai.pojo.PageBean;
  10. import com.bocai.service.ArticleService;
  11. import com.bocai.mapper.ArticleMapper;
  12. import com.bocai.utils.ThreadLocalUtil;
  13. import org.springframework.beans.factory.annotation.Autowired;
  14. import org.springframework.stereotype.Service;
  15.  
  16. import java.time.LocalDateTime;
  17. import java.util.Map;
  18.  
  19. /**
  20. * @author cheng
  21. * @description 针对表【article】的数据库操作Service实现
  22. * @createDate 2023-11-13 19:55:11
  23. */
  24. @Service
  25. public class ArticleServiceImpl extends ServiceImpl<ArticleMapper, Article>
  26.     implements ArticleService{
  27.  
  28.  
  29.     @Autowired
  30.     private ArticleMapper articleMapper;
  31.  
  32.     /**
  33.      * 新增文章
  34.      * @param article
  35.      */
  36.     @Override
  37.     public void add(Article article) {
  38.         Map<String, Object> map = ThreadLocalUtil.get();
  39.         Integer createUserId = (Integer) map.get("id");
  40.         article.setCreateUser(createUserId);
  41.         article.setCreateTime(LocalDateTime.now());
  42.         article.setUpdateTime(LocalDateTime.now());
  43.         articleMapper.insert(article);
  44.     }
  45.  
  46.     /**
  47.      * 根据文章标题查询文章
  48.      * @param articleTitle
  49.      * @return
  50.      */
  51.     @Override
  52.     public Article queryArticleByTitle(String articleTitle) {
  53.         LambdaQueryWrapper<Article> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  54.         lambdaQueryWrapper.eq(articleTitle != null, Article::getTitle,articleTitle);
  55.  
  56.         return articleMapper.selectOne(lambdaQueryWrapper);
  57.     }
  58.  
  59.     /**
  60.      * 文章根据条件查询，并分页
  61.      * @param pageNum 当前页码
  62.      * @param pageSize 每页条数
  63.      * @param categoryId 文章分类ID
  64.      * @param state 状态
  65.      * @return
  66.      */
  67.     @Override
  68.     public PageBean pageList(Integer pageNum, Integer pageSize, String categoryId, String state) {
  69.         Map<String,Object> map = ThreadLocalUtil.get();
  70.         String userId = (String) map.get("id");
  71.         LambdaQueryWrapper<Article> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  72.         lambdaQueryWrapper.eq(categoryId != null,Article::getCategoryId,categoryId)
  73.                 .eq(state != null,Article::getState,state)
  74.                 .eq(userId != null,Article::getCreateUser,userId);
  75.  
  76.         Page<Article> pageArticle = new Page<>(pageNum,pageSize);
  77.         articleMapper.selectPage(pageArticle,lambdaQueryWrapper);
  78.         PageBean pageBean = new PageBean(pageArticle.getTotal(),pageArticle.getRecords());
  79.  
  80.         return pageBean;
  81.     }
  82.  
  83.     /**
  84.      * 文章详情
  85.      * @param id
  86.      * @return
  87.      */
  88.     @Override
  89.     public Article detail(Integer id) {
  90.         return articleMapper.selectById(id);
  91.     }
  92. }
  93.  
  94.  
  95.

4、更新文章

4.1 ArticleCtroller

  1. package com.bocai.controller;
  2.  
  3.  
  4. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  5. import com.baomidou.mybatisplus.core.toolkit.StringUtils;
  6. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  7. import com.bocai.common.Result;
  8. import com.bocai.pojo.Article;
  9. import com.bocai.pojo.Category;
  10. import com.bocai.pojo.Emp;
  11. import com.bocai.pojo.PageBean;
  12. import com.bocai.service.ArticleService;
  13. import lombok.extern.slf4j.Slf4j;
  14. import org.springframework.beans.factory.annotation.Autowired;
  15. import org.springframework.format.annotation.DateTimeFormat;
  16. import org.springframework.validation.annotation.Validated;
  17. import org.springframework.web.bind.annotation.*;
  18.  
  19. import java.time.LocalDate;
  20.  
  21. @RestController
  22. @Slf4j
  23. @RequestMapping("/article")
  24. public class ArticleCtroller {
  25.  
  26.     @Autowired
  27.     private ArticleService articleService;
  28.  
  29.     /**
  30.      * 添加文章
  31.      * @param article
  32.      * @return
  33.      */
  34.     @PostMapping
  35.     public Result add(@RequestBody @Validated(Article.Add.class) Article article){
  36.         log.info("新增文章为：{}",article);
  37.         //查询文章标题是否被创建
  38.         Article queryArticle = articleService.queryArticleByTitle(article);
  39.         if(queryArticle == null){
  40.             //没有重复的文章标题
  41.             articleService.add(article);
  42.             return Result.success();
  43.         }
  44.         else {
  45.             // 存在重复文章标题
  46.             return Result.error("文章标题重复！");
  47.         }
  48.  
  49.     }
  50.  
  51.     /**
  52.      * 文章根据条件查询，并分页
  53.      * @param pageNum
  54.      * @param pageSize
  55.      * @param categoryId
  56.      * @param state
  57.      * @return
  58.      */
  59.     @GetMapping
  60.     public Result page(@RequestParam(defaultValue = "1") Integer pageNum,
  61.                       @RequestParam(defaultValue = "10") Integer pageSize,
  62.                        String categoryId, String state){
  63.         log.info("分页查询参数：当前页：{} 每页条数： {} 文章分类ID：{}  状态：{} ",pageNum,pageSize,categoryId,state);
  64.         PageBean pageBean = articleService.pageList(pageNum,pageSize,categoryId,state);
  65.         return Result.success(pageBean);
  66.     }
  67.  
  68.     /**
  69.      * 文章详情
  70.      * @param id
  71.      * @return
  72.      */
  73.     @GetMapping("/detail")
  74.     public Result detail(Integer id){
  75.         log.info("文章id{}详情",id);
  76.         Article article = articleService.detail(id);
  77.         return Result.success(article);
  78.     }
  79.  
  80.     /**
  81.      * 根据id更新文章
  82.      * @param article
  83.      * @return
  84.      */
  85.     @PutMapping
  86.     public Result update(@RequestBody @Validated(Article.Update.class) Article article){
  87.         log.info("根据id更新文章这些属性{}",article);
  88.         Article queryArticle = articleService.queryArticleByTitle(article);
  89.         if(queryArticle == null){
  90.             articleService.updateArticleById(article);
  91.             return Result.success();
  92.         }else {
  93.             return Result.error("不能修改为文章标题重复名称");
  94.         }
  95.  
  96.     }
  97. }
  98.

4.2 service

  1. package com.bocai.service;
  2.  
  3. import com.bocai.pojo.Article;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5. import com.bocai.pojo.PageBean;
  6.  
  7. /**
  8. * @author cheng
  9. * @description 针对表【article】的数据库操作Service
  10. * @createDate 2023-11-13 19:55:11
  11. */
  12. public interface ArticleService extends IService<Article> {
  13.  
  14.     /**
  15.      * 新增文章
  16.      * @param article
  17.      */
  18.     void add(Article article);
  19.  
  20.     /**
  21.      * 根据文章标题查询文章
  22.      * @param article
  23.      * @return
  24.      */
  25.     Article queryArticleByTitle(Article article);
  26.  
  27.     /**
  28.      * 文章根据条件查询，并分页
  29.      * @param pageNum 当前页码
  30.      * @param pageSize 每页条数
  31.      * @param categoryId 文章分类ID
  32.      * @param state 状态
  33.      * @return
  34.      */
  35.     PageBean pageList(Integer pageNum, Integer pageSize, String categoryId, String state);
  36.  
  37.     /**
  38.      * 文章详情
  39.      * @param id
  40.      * @return
  41.      */
  42.     Article detail(Integer id);
  43.  
  44.     /**
  45.      *     根据id更新文章
  46.      * @param article
  47.      */
  48.     void updateArticleById(Article article);
  49. }

4.3 serviceImpl

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.core.toolkit.StringUtils;
  5. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  6. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  7. import com.bocai.pojo.Article;
  8. import com.bocai.pojo.Category;
  9. import com.bocai.pojo.PageBean;
  10. import com.bocai.service.ArticleService;
  11. import com.bocai.mapper.ArticleMapper;
  12. import com.bocai.utils.ThreadLocalUtil;
  13. import org.springframework.beans.factory.annotation.Autowired;
  14. import org.springframework.stereotype.Service;
  15.  
  16. import java.time.LocalDateTime;
  17. import java.util.Map;
  18.  
  19. /**
  20. * @author cheng
  21. * @description 针对表【article】的数据库操作Service实现
  22. * @createDate 2023-11-13 19:55:11
  23. */
  24. @Service
  25. public class ArticleServiceImpl extends ServiceImpl<ArticleMapper, Article>
  26.     implements ArticleService{
  27.  
  28.  
  29.     @Autowired
  30.     private ArticleMapper articleMapper;
  31.  
  32.     /**
  33.      * 新增文章
  34.      * @param article
  35.      */
  36.     @Override
  37.     public void add(Article article) {
  38.         Map<String, Object> map = ThreadLocalUtil.get();
  39.         Integer createUserId = (Integer) map.get("id");
  40.         article.setCreateUser(createUserId);
  41.         article.setCreateTime(LocalDateTime.now());
  42.         article.setUpdateTime(LocalDateTime.now());
  43.         articleMapper.insert(article);
  44.     }
  45.  
  46.     /**
  47.      * 根据文章标题查询文章
  48.      * @param article
  49.      * @return
  50.      */
  51.     @Override
  52.     public Article queryArticleByTitle(Article article) {
  53.         LambdaQueryWrapper<Article> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  54.         lambdaQueryWrapper.eq(article.getTitle() != null, Article::getTitle,article.getTitle())
  55.                 .ne(article.getId() != null,Article::getId,article.getId());
  56.  
  57.         return articleMapper.selectOne(lambdaQueryWrapper);
  58.     }
  59.  
  60.     /**
  61.      * 文章根据条件查询，并分页
  62.      * @param pageNum 当前页码
  63.      * @param pageSize 每页条数
  64.      * @param categoryId 文章分类ID
  65.      * @param state 状态
  66.      * @return
  67.      */
  68.     @Override
  69.     public PageBean pageList(Integer pageNum, Integer pageSize, String categoryId, String state) {
  70.         Map<String,Object> map = ThreadLocalUtil.get();
  71.         String userId = (String) map.get("id");
  72.         LambdaQueryWrapper<Article> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  73.         lambdaQueryWrapper.eq(categoryId != null,Article::getCategoryId,categoryId)
  74.                 .eq(state != null,Article::getState,state)
  75.                 .eq(userId != null,Article::getCreateUser,userId);
  76.  
  77.         Page<Article> pageArticle = new Page<>(pageNum,pageSize);
  78.         articleMapper.selectPage(pageArticle,lambdaQueryWrapper);
  79.         PageBean pageBean = new PageBean(pageArticle.getTotal(),pageArticle.getRecords());
  80.  
  81.         return pageBean;
  82.     }
  83.  
  84.     /**
  85.      * 文章详情
  86.      * @param id
  87.      * @return
  88.      */
  89.     @Override
  90.     public Article detail(Integer id) {
  91.         return articleMapper.selectById(id);
  92.     }
  93.  
  94.     /**
  95.      * 根据id更新文章
  96.      * @param article
  97.      */
  98.     @Override
  99.     public void updateArticleById(Article article) {
  100.         article.setUpdateTime(LocalDateTime.now());
  101.         articleMapper.updateById(article);
  102.     }
  103. }
  104.  
  105.  
  106.

5、删除文章

5.1 ArticleCtroller

  1. package com.bocai.controller;
  2.  
  3.  
  4. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  5. import com.baomidou.mybatisplus.core.toolkit.StringUtils;
  6. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  7. import com.bocai.common.Result;
  8. import com.bocai.pojo.Article;
  9. import com.bocai.pojo.Category;
  10. import com.bocai.pojo.Emp;
  11. import com.bocai.pojo.PageBean;
  12. import com.bocai.service.ArticleService;
  13. import lombok.extern.slf4j.Slf4j;
  14. import org.springframework.beans.factory.annotation.Autowired;
  15. import org.springframework.format.annotation.DateTimeFormat;
  16. import org.springframework.validation.annotation.Validated;
  17. import org.springframework.web.bind.annotation.*;
  18.  
  19. import java.time.LocalDate;
  20.  
  21. @RestController
  22. @Slf4j
  23. @RequestMapping("/article")
  24. public class ArticleCtroller {
  25.  
  26.     @Autowired
  27.     private ArticleService articleService;
  28.  
  29.     /**
  30.      * 添加文章
  31.      * @param article
  32.      * @return
  33.      */
  34.     @PostMapping
  35.     public Result add(@RequestBody @Validated(Article.Add.class) Article article){
  36.         log.info("新增文章为：{}",article);
  37.         //查询文章标题是否被创建
  38.         Article queryArticle = articleService.queryArticleByTitle(article);
  39.         if(queryArticle == null){
  40.             //没有重复的文章标题
  41.             articleService.add(article);
  42.             return Result.success();
  43.         }
  44.         else {
  45.             // 存在重复文章标题
  46.             return Result.error("文章标题重复！");
  47.         }
  48.  
  49.     }
  50.  
  51.     /**
  52.      * 文章根据条件查询，并分页
  53.      * @param pageNum
  54.      * @param pageSize
  55.      * @param categoryId
  56.      * @param state
  57.      * @return
  58.      */
  59.     @GetMapping
  60.     public Result page(@RequestParam(defaultValue = "1") Integer pageNum,
  61.                       @RequestParam(defaultValue = "10") Integer pageSize,
  62.                        String categoryId, String state){
  63.         log.info("分页查询参数：当前页：{} 每页条数： {} 文章分类ID：{}  状态：{} ",pageNum,pageSize,categoryId,state);
  64.         PageBean pageBean = articleService.pageList(pageNum,pageSize,categoryId,state);
  65.         return Result.success(pageBean);
  66.     }
  67.  
  68.     /**
  69.      * 文章详情
  70.      * @param id
  71.      * @return
  72.      */
  73.     @GetMapping("/detail")
  74.     public Result detail(Integer id){
  75.         log.info("文章id{}详情",id);
  76.         Article article = articleService.detail(id);
  77.         return Result.success(article);
  78.     }
  79.  
  80.     /**
  81.      * 根据id更新文章
  82.      * @param article
  83.      * @return
  84.      */
  85.     @PutMapping
  86.     public Result update(@RequestBody @Validated(Article.Update.class) Article article){
  87.         log.info("根据id更新文章这些属性{}",article);
  88.         Article queryArticle = articleService.queryArticleByTitle(article);
  89.         if(queryArticle == null){
  90.             articleService.updateArticleById(article);
  91.             return Result.success();
  92.         }else {
  93.             return Result.error("不能修改为文章标题重复名称");
  94.         }
  95.  
  96.     }
  97.  
  98.     /**
  99.      * 根据id删除文章
  100.      * @param id
  101.      * @return
  102.      */
  103.     @DeleteMapping
  104.     public Result delete(Integer id){
  105.         log.info("根据id{}，删除文章",id);
  106.         articleService.deleteArticleById(id);
  107.         return Result.success();
  108.     }
  109. }
  110.

5.2 service

  1. package com.bocai.service;
  2.  
  3. import com.bocai.pojo.Article;
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5. import com.bocai.pojo.PageBean;
  6.  
  7. /**
  8. * @author cheng
  9. * @description 针对表【article】的数据库操作Service
  10. * @createDate 2023-11-13 19:55:11
  11. */
  12. public interface ArticleService extends IService<Article> {
  13.  
  14.     /**
  15.      * 新增文章
  16.      * @param article
  17.      */
  18.     void add(Article article);
  19.  
  20.     /**
  21.      * 根据文章标题查询文章
  22.      * @param article
  23.      * @return
  24.      */
  25.     Article queryArticleByTitle(Article article);
  26.  
  27.     /**
  28.      * 文章根据条件查询，并分页
  29.      * @param pageNum 当前页码
  30.      * @param pageSize 每页条数
  31.      * @param categoryId 文章分类ID
  32.      * @param state 状态
  33.      * @return
  34.      */
  35.     PageBean pageList(Integer pageNum, Integer pageSize, String categoryId, String state);
  36.  
  37.     /**
  38.      * 文章详情
  39.      * @param id
  40.      * @return
  41.      */
  42.     Article detail(Integer id);
  43.  
  44.     /**
  45.      *     根据id更新文章
  46.      * @param article
  47.      */
  48.     void updateArticleById(Article article);
  49.  
  50.     /**
  51.      * 根据id删除文章
  52.      * @param id
  53.      */
  54.     void deleteArticleById(Integer id);
  55. }

5.3 serviceImpl

  1. package com.bocai.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.core.toolkit.StringUtils;
  5. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  6. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  7. import com.bocai.pojo.Article;
  8. import com.bocai.pojo.Category;
  9. import com.bocai.pojo.PageBean;
  10. import com.bocai.service.ArticleService;
  11. import com.bocai.mapper.ArticleMapper;
  12. import com.bocai.utils.ThreadLocalUtil;
  13. import org.springframework.beans.factory.annotation.Autowired;
  14. import org.springframework.stereotype.Service;
  15.  
  16. import java.time.LocalDateTime;
  17. import java.util.Map;
  18.  
  19. /**
  20. * @author cheng
  21. * @description 针对表【article】的数据库操作Service实现
  22. * @createDate 2023-11-13 19:55:11
  23. */
  24. @Service
  25. public class ArticleServiceImpl extends ServiceImpl<ArticleMapper, Article>
  26.     implements ArticleService{
  27.  
  28.  
  29.     @Autowired
  30.     private ArticleMapper articleMapper;
  31.  
  32.     /**
  33.      * 新增文章
  34.      * @param article
  35.      */
  36.     @Override
  37.     public void add(Article article) {
  38.         Map<String, Object> map = ThreadLocalUtil.get();
  39.         Integer createUserId = (Integer) map.get("id");
  40.         article.setCreateUser(createUserId);
  41.         article.setCreateTime(LocalDateTime.now());
  42.         article.setUpdateTime(LocalDateTime.now());
  43.         articleMapper.insert(article);
  44.     }
  45.  
  46.     /**
  47.      * 根据文章标题查询文章
  48.      * @param article
  49.      * @return
  50.      */
  51.     @Override
  52.     public Article queryArticleByTitle(Article article) {
  53.         LambdaQueryWrapper<Article> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  54.         lambdaQueryWrapper.eq(article.getTitle() != null, Article::getTitle,article.getTitle())
  55.                 .ne(article.getId() != null,Article::getId,article.getId());
  56.  
  57.         return articleMapper.selectOne(lambdaQueryWrapper);
  58.     }
  59.  
  60.     /**
  61.      * 文章根据条件查询，并分页
  62.      * @param pageNum 当前页码
  63.      * @param pageSize 每页条数
  64.      * @param categoryId 文章分类ID
  65.      * @param state 状态
  66.      * @return
  67.      */
  68.     @Override
  69.     public PageBean pageList(Integer pageNum, Integer pageSize, String categoryId, String state) {
  70.         Map<String,Object> map = ThreadLocalUtil.get();
  71.         String userId = (String) map.get("id");
  72.         LambdaQueryWrapper<Article> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  73.         lambdaQueryWrapper.eq(categoryId != null,Article::getCategoryId,categoryId)
  74.                 .eq(state != null,Article::getState,state)
  75.                 .eq(userId != null,Article::getCreateUser,userId);
  76.  
  77.         Page<Article> pageArticle = new Page<>(pageNum,pageSize);
  78.         articleMapper.selectPage(pageArticle,lambdaQueryWrapper);
  79.         PageBean pageBean = new PageBean(pageArticle.getTotal(),pageArticle.getRecords());
  80.  
  81.         return pageBean;
  82.     }
  83.  
  84.     /**
  85.      * 文章详情
  86.      * @param id
  87.      * @return
  88.      */
  89.     @Override
  90.     public Article detail(Integer id) {
  91.         return articleMapper.selectById(id);
  92.     }
  93.  
  94.     /**
  95.      * 根据id更新文章
  96.      * @param article
  97.      */
  98.     @Override
  99.     public void updateArticleById(Article article) {
  100.         article.setUpdateTime(LocalDateTime.now());
  101.         articleMapper.updateById(article);
  102.     }
  103.  
  104.     /**
  105.      * 根据id删除文章
  106.      * @param id
  107.      */
  108.     @Override
  109.     public void deleteArticleById(Integer id) {
  110.         articleMapper.deleteById(id);
  111.     }
  112. }
  113.  
  114.  
  115.

五、上传接口

1、FileUploadController

  1. package com.bocai.controller;
  2.  
  3. import com.bocai.common.Result;
  4. import com.bocai.utils.AliOSSUtils;
  5. import lombok.extern.slf4j.Slf4j;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.web.bind.annotation.PostMapping;
  8. import org.springframework.web.bind.annotation.RestController;
  9. import org.springframework.web.multipart.MultipartFile;
  10.  
  11. import java.io.IOException;
  12.  
  13. @RestController
  14. @Slf4j
  15. public class FileUploadController {
  16.  
  17.     @Autowired
  18.     private AliOSSUtils aliOSSUtils;
  19.  
  20.     @PostMapping("/upload")
  21.     public Result upload(MultipartFile file) throws IOException {
  22.         log.info("上传的文件名：{}",file.getOriginalFilename());
  23.         String url = aliOSSUtils.upload(file);
  24.  
  25.         return Result.success(url);
  26.     }
  27.  
  28. }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/Cpp五条/article/detail/567696
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号