微头条（全栈进阶项目，主要偏向于后端）

首先讲述一下该项目能实现的功能，通过这些功能开始编写后端代码。

所运用到的前后端技术栈：

本次项目开发依旧利用到了mvc的设计模式结构，具体的解释可以见我上一篇博客。

如图该项目依旧是和上一篇日程管理系统的结构大相径庭。common层是规定后端给前端相应的状态码，dao层用来和后端数据库发生交互，filters层放入了校验相关的过滤器，pojo层是创建相关实体类，service层是处理除了和数据库交互之外的其他业务需求（例如将明文暗码转换为密文暗码，以及背面要讲到的处理消息分页查询功能），util层放入相关的工具类。
controller层我们这次也称为业务处理接口，作用就是连接前后端，前端发送需求给后端，controller层举行吸收然后发送给service层继承后端的操作。这次项目会接纳接口文档的方式来对后端代码举行开发，对照接口文档对controller层代码举行开发。
同时在截图中我也是给出了相关的jar包，在maven中都可以找到资源并下载。
Vo层解析

这次在开发pojo层的时候会发现多了一层叫Vo层

这层Vo用于办理多表查询时，好几个表要用到一个实体类来装，这时pojo层单独的实体类就装不了这些数据了。通俗来说就是一个实体类的属性少于SQL 查询结果的字段，就装不下全部的数据，以是要再定义一个类。背面会利用到多表查询就是要利用Vo层中的类，将多张表中的属性封装到一个实体类中。
Pojo层代码

 NewsUser :

1. import lombok.AllArgsConstructor;
2. import lombok.Data;
3. import lombok.NoArgsConstructor;
4. import java.io.Serializable;
6. @AllArgsConstructor
7. @NoArgsConstructor
8. @Data
9. public class NewsUser implements Serializable {
10.     private Integer uid;
11.     private String username;
12.     private String userPwd;
13.     private String nickName;
14. }

复制代码

NewsType:

1. import lombok.AllArgsConstructor;
2. import lombok.Data;
3. import lombok.NoArgsConstructor;
4. import java.io.Serializable;
6. @AllArgsConstructor
7. @NoArgsConstructor
8. @Data
9. public class NewsType implements Serializable {
10.     private Integer tid;
11.     private String tname;
12. }

复制代码

NewsHeadline:

1. import lombok.AllArgsConstructor;
2. import lombok.Data;
3. import lombok.NoArgsConstructor;
4. import java.io.Serializable;
5. import java.util.Date;
7. @AllArgsConstructor
8. @NoArgsConstructor
9. @Data
10. public class NewsHeadline implements Serializable {
11.     private Integer hid;
12.     private String title;
13.     private String article;
14.     private Integer type;
15.     private Integer publisher;
16.     private Integer pageViews;
17.     private Date createTime;
18.     private Date updateTime;
19.     private Integer isDeleted;
21. }

复制代码

HeadlineDetailVo:

1. import lombok.AllArgsConstructor;
2. import lombok.Data;
3. import lombok.NoArgsConstructor;
4. import java.io.Serializable;
6. @AllArgsConstructor
7. @NoArgsConstructor
8. @Data
9. public class HeadlineDetailVo implements Serializable {
10.     private Integer hid;
11.     private String title;
12.     private String article;
13.     private Integer type;
14.     private String typeName;
15.     private Integer pageViews;
16.     private Long pastHours;
17.     private Integer publisher;
18.     private String author;
19. }

复制代码

HeadlinePageVo:

1. import lombok.AllArgsConstructor;
2. import lombok.Data;
3. import lombok.NoArgsConstructor;
4. import java.io.Serializable;
6. @AllArgsConstructor
7. @NoArgsConstructor
8. @Data
9. public class HeadlinePageVo implements Serializable {
10.     private Integer hid;
11.     private String title;
12.     private Integer type;
13.     private Integer pageViews;
14.     private Long pastHours;
15.     private Integer publisher;
16. }

复制代码

HeadlineQueryVo:

1. import lombok.AllArgsConstructor;
2. import lombok.Data;
3. import lombok.NoArgsConstructor;
4. import java.io.Serializable;
6. @AllArgsConstructor
7. @NoArgsConstructor
8. @Data
9. public class HeadlineQueryVo implements Serializable {
10.     private String keyWords;
11.     private Integer type ;
12.     private Integer pageNum;
13.     private Integer pageSize;
14. }

复制代码

Postman工具

PostMan是一个接口测试工具，在做接口测试的时候，Postman相当于一个客户端，它可以模拟用户发起的各类http请求，将请求数据发送至服务端，获取对应的相应结果，从而验证相应中的结果数据是否和预期值相匹配。

 右边的POST那一行是输入要往后端的哪一个方法发送的url，即发送到Controller层。旁边的POST也可以修改成GET，即指定发送方式。下面的Key-Value就是指定要发送的键值对格式。
以第一个需求（将消息的5种范例表现在页面最上方）举例

首先我们需要在controller层中多创建一个PortalController层作为门户控制器，那些不需要登录，不需要做增删改的门户页的请求都放在这里。然后根据前端需要的信息：

 可知所需要的实体类是pojo中的NewsType类。
1，创建方法用于调用service层：

1.     /**
2.      * 查询所有头条类型的业务接口实现
3.      * @param req
4.      * @param resp
5.      * @throws ServletException
6.      * @throws IOException
7.      */
8.     protected void findAllTypes(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
9.         //查询所有的新闻类型，装入Result响应给客户端
10.         List<NewsType> newsTypeList = typeService.findAll();
11.         WebUtil.writeJson(resp, Result.ok(newsTypeList));
12.     }

复制代码

2，在NewsTypeService接口中实现：

1. import com.ryy.headline.pojo.NewsType;
2. import java.util.List;
4. public interface NewsTypeService {
5.     /**
6.      * 查询所有头条类型的方法
7.      * @return 多个头条类型以List<NewsType>集合形式返回
8.      */
9.     List<NewsType> findAll();
10. }

复制代码

3，调用dao层代码：

1. import com.ryy.headline.dao.NewsTypeDao;
2. import com.ryy.headline.dao.Impl.NewsTypeDaoImpl;
3. import com.ryy.headline.pojo.NewsType;
4. import com.ryy.headline.service.NewsTypeService;
6. import java.util.List;
8. public class NewsTypeServiceImpl implements NewsTypeService {
9.     private NewsTypeDao typeDao =new NewsTypeDaoImpl();
10.     @Override
11.     public List<NewsType> findAll() {
12.         return typeDao.findAll();
13.     }
14. }

复制代码

4，发送sql语句：

1. import com.ryy.headline.dao.BaseDao;
2. import com.ryy.headline.dao.NewsTypeDao;
3. import com.ryy.headline.pojo.NewsType;
5. import java.util.List;
7. public class NewsTypeDaoImpl extends BaseDao implements NewsTypeDao {
8.     @Override
9.     public List<NewsType> findAll() {
10.         String sql = "select tid,tname from news_type";
11.         return baseQuery(NewsType.class,sql);
12.     }
13. }

复制代码

当这些代码编写好之后我们就能利用postman举行测试：

我们输入相应的url举行查询，postman就会表现后端发送过来的数据，而返回的数据与刚才前端需要的样子类似，即代表代码无题目。
登录需求的实现

token

在实现登录功能之前需要讲述一个知识点叫token，其作用其实和我们之前利用的session域的作用是一样的，都是将数据暂时存储起来然后下次登录时候就去这些域中探求检察是否已经登岸过。
而利用token的优势就在于后端不用产生大量session对象，前端也不用存储一大堆cookie，token会存储在客户端的localStorage中，每次发送请求时，都将token以请求头的情势发送给服务器。不用session域的原因是当session特殊多的时候就牵扯到高并发题目，对于Io流的读取就会造成巨大的性能损失。如图：

我们可以发现token是存储在客户端中的，而如许做可以大大减小后端服务器的压力。
以登录功能举例：（第一步）

这里要注意登录乐成之后还会要将token口令给到客户端，而客户端下次发送任何请求时只需要判断本地token是否为空，而无需再次触发登录验证。可以或许实现的业务逻辑就是用户可以或许在规定时间内免登录直接访问消息首页。
（第二步）

在登录乐成之后页面右上角的“注册”“登录”将会变为“欢迎...登录”。后端通过解析token将id取出然后到数据库中找到对应数据，前端就会将返回的nickName存储到pinia中，然后通过前端页面绑定pinia即可将nickName表现到页面上。
token的相关工具类：

由于token是在后端生成的：（一共有三个方法，第一是生成token密文字符串，第二是解析token密文，第三是判断token的时效性是否到期），该工具类放在utils包下

1. import com.alibaba.druid.util.StringUtils;
2. import io.jsonwebtoken.*;
4. import java.util.Date;
6. public class JwtHelper {
7.     private static long tokenExpiration = 1000*60*60;  //定义token的过期时间
8.     private static String tokenSignKey = "123456"; //需要知道这一段数据才能解析出token密文
10.     //生成token字符串
11.     public static String createToken(Long userId ) {
12.         String token = Jwts.builder()
14.                 .setSubject("YYGH-USER")
15.                 .setExpiration(new Date(System.currentTimeMillis() + tokenExpiration))
16.                 .claim("userId", userId) //返回的密文信息有userId
18.                 .signWith(SignatureAlgorithm.HS512, tokenSignKey)
19.                 .compressWith(CompressionCodecs.GZIP)
20.                 .compact();
21.         return token;
22.     }
24.     //从token字符串获取userid，即从密文形式解析出userId
25.     public static Long getUserId(String token) {
26.         if(StringUtils.isEmpty(token)) return null;
27.         Jws<Claims> claimsJws = Jwts.parser().setSigningKey(tokenSignKey).parseClaimsJws(token);
28.         Claims claims = claimsJws.getBody();
29.         Integer userId = (Integer)claims.get("userId");
30.         return userId.longValue();
31.     }
35.     //判断token是否有效
36.     public static boolean isExpiration(String token){
37.         try {
38.             boolean isExpire = Jwts.parser()
39.                     .setSigningKey(tokenSignKey)
40.                     .parseClaimsJws(token)
41.                     .getBody()
42.                     .getExpiration().before(new Date());
43.             //没有过期，有效，返回false
44.             return isExpire;
45.         }catch(Exception e) {
46.             //过期出现异常，返回true
47.             return true;
48.         }
49.     }
50. }

复制代码

token的相关前端代码：

1，token-utils.ts中先得到token：

1. const TokenKey = 'vue_admin_template_token'
3. export function getToken() {
4.   return localStorage.getItem(TokenKey)
5. }
7. export function setToken(token: string) {
8.   localStorage.setItem(TokenKey, token)
9. }
11. export function removeToken() {
12.   localStorage.removeItem(TokenKey)
13. }

复制代码

2，userInfo.js中的pinia共享数据来得到token：

1. import { getToken, removeToken, setToken } from '../utils/token-utils';
3. export const useUserInfoStore = defineStore('userInfo', {
5.         state: () => ({
6.     token: getToken(),
7.     nickName: '',
8.     uid: '',
9.   }),

复制代码

3，request.js来判断token是否为空，即添加一个请求拦截器：

1. // 添加请求拦截器
2. service.interceptors.request.use((config) => {
3.   NProgress.start()//开启进度条
4.   // 如果有token, 通过请求头携带给后台
5.   const userInfoStore = useUserInfoStore(pinia) // 如果不是在组件中调用,必须传入pinia
6.   const token = userInfoStore.token
7.      if (token) {
8.       // config.headers['token'] = token  // 报错: headers对象并没有声明有token, 不能随便添加
9.       (config.headers)['token'] = token
10.     }
11.   return config;
12. });

复制代码

4，请求乐成后, 取出token保存  pinia和local中

1.         import { getLogin,getUserInfo } from '../api/index';
3.     actions: {
4.     // 登陆的异步action
5.     async login (loginForm) {
6.        // 发送登陆的请求
7.       const result = await getLogin(loginForm)
8.       // 请求成功后, 取出token保存  pinia和local中
9.       const token = result.token
10.       
11.       this.token = token
12.       setToken(token)
13.     },

复制代码

5，以post情势向后端发送请求（api/index）

1. //登录的接口
2. export const getLogin = (info) => {
3.   return request.post("user/login",info);
4. };

复制代码

正式实现登录需求

登录功能看图可知后端接口需要有吸收两个请求，一个是校验暗码和用户名是否精确，一个是解析客户端发来的token。

 
处理登岸表单提交的业务接口实现

根据文档提供的路径可知在NewsUserController类中需要有一个login的方法用来吸收POST请求情势发来的数据并且将数据发送给service层再到数据库中举行一系列操作。同时还需要验证如果数据库中确实存在该用户，那就需要给客户端创建一个token口令并返回表示登录乐成。
同时还需要注意格式题目，在文档中可以看到token情势是："token":"... ..."，说明返回的token需要是键值对的情势，因此需要创建一个Map来封装。
代码实现：

1.     /**
2.      * 处理登陆表单提交的业务接口实现
3.      *
4.      * @param req
5.      * @param resp
6.      * @throws ServletException
7.      * @throws IOException
8.      */
9.     protected void login(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
10.         //接收用户名和密码
11.         /*{
12.             "username":"zahngsan", //用户名
13.             "userPwd":"123456", //明文密码
14.          */
15.         NewsUser paramUser = WebUtil.readJson(req, NewsUser.class);
17.         //调用服务层方法实现登录
18.         NewsUser loginUser = userService.findByUsername(paramUser.getUsername());
19.         Result result = null;
20.         if (null != loginUser) {
21.             if (MD5Util.encrypt(paramUser.getUserPwd()).equalsIgnoreCase(loginUser.getUserPwd())) {
22.                 //返回的信息还需要有一个token，因此在这里创建一个token密文
23.                 Integer uid = loginUser.getUid();
24.                 String token = JwtHelper.createToken(uid.longValue());
25.                 //由于需要返回键值对形式的token，因此需要创建一个Map进行发送
26.                 //"token":"... ..."
27.                 Map data = new HashMap();
28.                 data.put("token", token);
29.                 result = Result.ok(data);
30.             } else {
31.                 result = Result.build(null, ResultCodeEnum.PASSWORD_ERROR);
32.             }
33.         } else {
34.             result = Result.build(null, ResultCodeEnum.USERNAME_ERROR);
35.         }
36.         //向客户端响应登录验证信息
37.         WebUtil.writeJson(resp, result);
38.     }

复制代码

然后就是按照MVC设计模式到Service层，再从Service层到DAO层书写相关sql语句对数据库举行CRUD操作。
NewsUserServiceImpl:

1.     @Override
2.     public NewsUser findByUsername(String username) {
3.         return userDao.findByUsername(username);
4.     }

复制代码

NewsUserDaoImpl:

1.     @Override
2.     public NewsUser findByUsername(String username) {
3.         String sql = """
4.                 select
5.                     uid,
6.                     username,
7.                     user_pwd userPwd,
8.                     nick_name nickName
9.                 from
10.                     news_user
11.                 where
12.                     username=?
13.                 """;
14.         //由于baseQueryObject是返回单个值的，而此处的需求是返回具体的对象，即使只有一个对象
15.         List<NewsUser> newsUserList = baseQuery(NewsUser.class, sql, username);
16.         return newsUserList != null && newsUserList.size() > 0 ? newsUserList.get(0) : null;
17.     }

复制代码

根据token口令得到用户信息的接口实现

这里主要是写对于请求头中的token举行的解析操作，判断完token不为空并且时效性还在之后会根据token中解析出来的id到数据库中探求对应id并且把nickName返回表现在页面右上角原本是登录和注册按钮的位置。
返回情势以键值对情势返回。
注意这边有一个细节就是根据文档要将userPwd设置为空串，不然全部人都知道暗码了，不符合业务逻辑。
NewsUserController:

1.     /**
2.      * 根据token口令获得用户信息的接口实现
3.      *
4.      * @param req
5.      * @param resp
6.      * @throws ServletException
7.      * @throws IOException
8.      */
9.     protected void getUserInfo(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
10.         //获取请求中的token
11.         String token = req.getHeader("token");
12.         Result result = Result.build(null, ResultCodeEnum.NOTLOGIN);
13.         if (null != token && (!"".equals(token))) { //判断是否为空串
14.             if (!JwtHelper.isExpiration(token)) { //判断token是否过期
15.                 Integer userId = JwtHelper.getUserId(token).intValue();
16.                 NewsUser newsUser = userService.findByUid(userId);
17.                 if (null != newsUser) {
18.                     //通过校验 查询用户信息放入Result
19.                     Map data = new HashMap(); //依旧需要键值对形式
20.                     newsUser.setUserPwd(""); //需要将密码设置为空串进行返回
21.                     data.put("loginUser", newsUser);
22.                     result = Result.ok(data);
23.                 }
24.             }
25.         }
26.         WebUtil.writeJson(resp, result);
27.     }

复制代码

 然后依旧利用MVC模式到DAO层，我这边就直接演示DAO层代码了：（根据文档提供的格式将用户数据以List情势返回）

1.     @Override
2.     public NewsUser findByUid(Integer userId) {
3.         String sql = """
4.                 select
5.                     uid,
6.                     username,
7.                     user_pwd userPwd,
8.                     nick_name nickName
9.                 from
10.                     news_user
11.                 where
12.                     uid=?
13.                 """;
14.         //由于baseQueryObject是返回单个值的，而此处的需求是返回具体的对象，即使只有一个对象
15.         List<NewsUser> newsUserList = baseQuery(NewsUser.class, sql, userId);
16.         return newsUserList != null && newsUserList.size() > 0 ? newsUserList.get(0) : null;
17.     }

复制代码

注册需求的实现

注册用户的操作和校验用户是否已经被抢注的两个接口，前端先向后端发送校验请求（见api-index.js）然后然后再向后端发送注册的请求

根据文档相关信息可知，首先需要去数据库校验该注册的用户是否己经在数据库中存在了，实行checkUsername方法，如果返回的结果为空则说明数据库中没有该用户，代表可以注册，既然可以注册那就实行login方法举行注册。
NewsUserController:

1.     /**
2.      * 完成注册的业务接口
3.      *
4.      * @param req
5.      * @param resp
6.      * @throws ServletException
7.      * @throws IOException
8.      */
9.     protected void regist(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
10.         //接收JSON信息
11.         NewsUser registUser = WebUtil.readJson(req, NewsUser.class);
12.         //调用服务层方法
13.         Integer rows = userService.registUser(registUser);
14.         //根据存入是否成功处理响应值
15.         Result result = Result.ok(null);
16.         if (rows == 0) {
17.             result = Result.build(null, ResultCodeEnum.USERNAME_USED);
18.         }
19.         WebUtil.writeJson(resp, result);
20.     }
22.     /**
23.      * 校验用户名是否被占用的业务接口实现
24.      *
25.      * @param req
26.      * @param resp
27.      * @throws ServletException
28.      * @throws IOException
29.      */
30.     protected void checkUserName(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
31.         //获取账号（以键值对形式接收）
32.         String username = req.getParameter("username");
34.         //根据用户名查询用户信息 找到了返回505 找不到就返回200（代表能够注册）
35.         NewsUser newsUser = userService.findByUsername(username);
36.         Result result = Result.ok(null);  //先给result一个初始的默认值
37.         if (null != newsUser) {
38.             //如果返回的结果不是为空代表已经被抢注了
39.             result = Result.build(null, ResultCodeEnum.USERNAME_USED);
40.         }
41.         WebUtil.writeJson(resp, result);
42.     }

复制代码

DAO层：

1.     @Override
2.     public NewsUser findByUsername(String username) {
3.         String sql = """
4.                 select
5.                     uid,
6.                     username,
7.                     user_pwd userPwd,
8.                     nick_name nickName
9.                 from
10.                     news_user
11.                 where
12.                     username=?
13.                 """;
14.         //由于baseQueryObject是返回单个值的，而此处的需求是返回具体的对象，即使只有一个对象
15.         List<NewsUser> newsUserList = baseQuery(NewsUser.class, sql, username);
16.         return newsUserList != null && newsUserList.size() > 0 ? newsUserList.get(0) : null;
17.     }

复制代码

registUser的service层需要实行将明文暗码转为密文暗码的操作，不能写在dao层中，
NewsUserServiceImpl:

1.     @Override
2.     public Integer registUser(NewsUser registUser) {
3.         //处理增加数据的业务
4.         //用户传来的信息需要将明文密码转换成密文密码
5.         registUser.setUserPwd(MD5Util.encrypt(registUser.getUserPwd()));
6.         return userDao.insertUser(registUser);
7.     }

复制代码

DAO层实现向数据库中新增数据的操作：

1.     @Override
2.     public Integer insertUser(NewsUser registUser) {
3.         String sql = """
4.                 insert into news_user values (DEFAULT,?,?,?)
5.                 """;
6.         return baseUpdate(sql,
7.                 registUser.getUsername(),
8.                 registUser.getUserPwd(),
9.                 registUser.getNickName()
10.         );
11.     }

复制代码

分页查询

首先需要解释一下分页查询：即用户点击差别的消息范例，在页面上会表现出对应消息范例的消息。并且用户如果利用关键词搜索也能在页面上表现出对应关键字的消息。
细节：一页上可以表现多少条消息可以修改。当点击下一页时，页面数会+1。若查询出来6条消息纪录，一页上最多表现5条纪录，末了一条消息就必须再单开一页到下一页上表现。

 如上图利用F12之后表现出的数据：
keyWords:关键字查询，type：查询消息的范例（体育？娱乐？... ...），
pageNum：查询出来的消息数一共占多少页，pageSize：一页上最多表现多少条消息。
如图文档所示为服务器相应回来的数据：

首先需要对文档中的各个参数举行分类：
根据请求参数，此时就要利用到vo中本身创建的实体类了
此处一共举行了两次Map的嵌套：
第一层就是外层的pageInfo为key，然后pageInfo中存储的各对象为value
第二层是内部的pageInfo，此时key为pageData, pageNum, pageSize... ...，pageData数组中存放的各页面属性为value（如消息id，消息标题等），pageNum背面的页码数... ...
   //将参数转达给服务层举行分页查询
        Map pageInfo = headlineService.findPage(headlineQueryVo);
        Map data = new HashMap();
        data.put("pageInfo", pageInfo);
  
PortalController:

1.     protected void findNewsPage(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
2.         //接收请求中的参数
3.         HeadlineQueryVo headlineQueryVo = WebUtil.readJson(req, HeadlineQueryVo.class);
4.         //将参数传递给服务层进行分页查询
5.         /*
6.         pageData:[
7.             {
8.                     "hid":"1",                     // 新闻id
9.                                     "title":"尚硅谷宣布 ... ...",   // 新闻标题
10.                                     "type":"1",                    // 新闻所属类别编号
11.                                     "pageViews":"40",              // 新闻浏览量
12.                                     "pastHours":"3",              // 发布时间已过小时数
13.                                     "publisher":"1"
14.            }
15.         ]
16.         pageNum:1,
17.         pageSize:1,
18.         totalPage:1,
19.         totalSize:1
20.          */
21.         Map pageInfo = headlineService.findPage(headlineQueryVo);
22.         Map data = new HashMap();
23.         data.put("pageInfo", pageInfo);
24.         //将分页查询的结果转换成json相应给客户端
25.         WebUtil.writeJson(resp, Result.ok(data));
26.     }
27. }

复制代码

内层的map文档给我们提供了5个需要的参数：pageNum，pageSize，totalSize，totalSize，pageInfo。
NewsHeadlineServiceImpl：（注：办理了页数加一题目）

1.     @Override
2.     public Map findPage(HeadlineQueryVo headlineQueryVo) {
3.         //这两条数据都是从客户端传来的信息，可以原封不动进行返回
4.         int pageNum = headlineQueryVo.getPageNum();
5.         int pageSize = headlineQueryVo.getPageSize();
6.         //要将pageData数组中的对象做成一个集合，里面需要的实体类对象在Vo中已经创建完毕
7.         List<HeadlinePageVo> pageData = headlineDao.findPageList(headlineQueryVo);
8.         int totalSize = headlineDao.findPageCount(headlineQueryVo);
10.         //totalPage的总页码数是根据totalSize和pageNum共同决定的，总页数如果可以被整除那就直接返回页数
11.         //如果不能被整除那就把余下的新闻加一页显示到下一页上去
12.         int totalPage = totalSize % pageSize == 0 ? totalSize/pageSize : totalSize/pageSize + 1;
13.         //把上面五条数据放在一个大的Map中
14.         Map pageInfo = new HashMap();
15.         pageInfo.put("pageNum", pageNum);
16.         pageInfo.put("pageSize", pageSize);
17.         pageInfo.put("totalSize", totalSize);
18.         pageInfo.put("totalPage", totalPage);
19.         pageInfo.put("pageData", pageData);
21.         return pageInfo;
22.     }

复制代码

findPageList的DAO层代码：

1.     /*  HeadlinePageVo中的各实体类（pageData）
2.         private Integer hid;
3.         private String title;
4.         private Integer type;
5.         private Integer pageViews;
6.         private Long pastHours;
7.         private Integer publisher;
9.         剩余的四条数据
10.         private String keyWords;
11.         private Integer type ;
12.         private Integer pageNum;
13.         private Integer pageSize;
14.      */
15.     @Override
16.     public List<HeadlinePageVo> findPageList(HeadlineQueryVo headlineQueryVo) {
17.         //需要准备一个集合用来装入拼接到sql语句最后的？中的参数，此处传来的是一个类对象而不是一个属性，因此需要集合进行封装
18.         List params = new ArrayList();
19.         //TIMESTAMPDIFF(HOUR,create_time,now())时间计算函数，返回当前时间减去发布时间的时间差，并且以小时为单位
20.         String sql = """
21.                 select
22.                    hid,
23.                    title,
24.                    type,
25.                    page_views pageViews,
26.                    TIMESTAMPDIFF(HOUR,create_time,now()) pastHours,
27.                    publisher
28.                 from
29.                    news_headline
30.                 where
31.                    is_deleted = 0
32.                 """;
33.         if (headlineQueryVo.getType() != 0) { //查询新闻类型，只要点击的是界面上微头条标题以外的其他类型新闻都能执行查询和页面跳转
34.             sql = sql.concat(" and type = ? ");
35.             params.add(headlineQueryVo.getType());
36.         }
37.         //搜索框中输入的不是空串，也会到数据库中去进行查询并返回关键字对应的新闻
38.         if (headlineQueryVo.getKeyWords() != null && !headlineQueryVo.getKeyWords().equals("")) {
39.             sql = sql.concat(" and title like ? "); //使用了模糊查询
40.             params.add("%" + headlineQueryVo.getKeyWords() + "%");
41.         }
42.         //根据发布的时间进行升序排列，如果发布时间相同再根据浏览量进行降序排列
43.         sql = sql.concat(" order by pastHours ASC, page_views DESC ");
44.         //由于是分页查询，因此还涉及到目标新闻的前面已经过去了多少条新闻，以及距离目标新闻页面还要取多少条新闻才能到目标页
45.         sql = sql.concat(" limit ? , ? ");
46.         params.add((headlineQueryVo.getPageNum() - 1) * headlineQueryVo.getPageSize());
47.         params.add(headlineQueryVo.getPageSize());
49.         return baseQuery(HeadlinePageVo.class, sql, params.toArray());
50.     }

复制代码

需要举行消息范例与关键词搜索举行if语句的判断对sql语句举行适当的拼接然后到数据库中举行对应查找。需要注意的细节是消息是讲究一个发布时间，浏览量的排序的，因此也需要将发布的时间举行升序排列，如果发布时间类似再根据浏览量举行降序排列。
代码解析：
   分页查询题目：//由于是分页查询，因此还涉及到目标消息的前面已经过去了多少条消息，以及隔断目标消息页面还要取多少条消息才能到目标页
        sql = sql.concat(" limit ? , ? ");
        params.add((headlineQueryVo.getPageNum() - 1) * headlineQueryVo.getPageSize());
        params.add(headlineQueryVo.getPageSize());
  这段代码在我本身理解的时候也有一些含糊不清，我会只管以举例的方式解释清楚：
这段代码的作用是根据用户请求的页码和每页表现的纪录数，对查询结果举行分页，返回指定页码的数据。
举例：假设 headlineQueryVo.getPageNum() = 2 （消息到达第二页）且 headlineQueryVo.getPageSize() = 10（每页只能表现10条消息），那么分页查询的 limit 子句将被解释为 LIMIT 10, 10，表示从第11条纪录开始，返回接下来的10条纪录（即需要表现下一页上的消息），如果剩余纪录数不足10条那就将剩余纪录全部返回。
还需要的一个是totalSize，即一共通过搜索返回了多少条消息，只有得到了消息的总数才能对消息举行分页操作。
findPageCount：（代码与上面的分页查询返回对应消息的代码相似）

1.     @Override
2.     public int findPageCount(HeadlineQueryVo headlineQueryVo) {
3.         //需要准备一个集合用来装入拼接到sql语句最后的？中的参数，此处传来的是一个类对象而不是一个属性，因此需要集合进行封装
4.         List params = new ArrayList();
5.         //TIMESTAMPDIFF(HOUR,create_time,now())时间计算函数，返回当前时间减去发布时间的时间差，并且以小时为单位
6.         String sql = """
7.                 select
8.                    count(1)
9.                 from
10.                    news_headline
11.                 where
12.                    is_deleted = 0
13.                 """;
14.         if (headlineQueryVo.getType() != 0) { //查询新闻类型，只要点击的是界面上微头条标题以外的其他类型新闻都能执行查询和页面跳转
15.             sql = sql.concat(" and type = ? ");
16.             params.add(headlineQueryVo.getType());
17.         }
18.         //搜索框中输入的不是空串，也会到数据库中去进行查询并返回关键字对应的新闻
19.         if (headlineQueryVo.getKeyWords() != null && !headlineQueryVo.getKeyWords().equals("")) {
20.             sql = sql.concat(" and title like ? "); //使用了模糊查询
21.             params.add("%" + headlineQueryVo.getKeyWords() + "%");
22.         }
24.         Long count = baseQueryObject(Long.class, sql, params.toArray());
25.         return count.intValue();
26.     }

复制代码

检察头条详情

不但要做到检察全文，还要做到当前浏览量+1，并且还涉及到sql的多表查询题目。

 根据文档注释的参数可知要调用的是HeadlineDetailVo实体类，并且需要得到用户的hid
PortalController层：

1.     /**
2.      * 查看头条全文的接口实现
3.      * @param req
4.      * @param resp
5.      * @throws ServletException
6.      * @throws IOException
7.      */
8.     protected void showHeadlineDetail(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
9.         //接收要查询的头条的hid
10.         int hid = Integer.parseInt(req.getParameter("hid"));
11.         //调用服务层完成查询处理
12.         HeadlineDetailVo headlineDetailVo = headlineService.findHeadlineDetail(hid);
13.         //将查询到的信息响应给客户端
14.         Map data = new HashMap();
15.         data.put("headline", headlineDetailVo);
16.         WebUtil.writeJson(resp, Result.ok(data));
17.     }

复制代码

要做到当前浏览量+1和查询头条详情需要分别到dao层中去实现
NewsHeadlineServiceImpl：

1.     @Override
2.     public HeadlineDetailVo findHeadlineDetail(int hid) {
3.         //修改该头条的浏览量 +1
4.         headlineDao.incrPageViews(hid);
5.         //查询头条的详情
6.         return headlineDao.findHeadlineDetail(hid);
7.     }

复制代码

dao层中浏览量+1:

1.     @Override
2.     public int incrPageViews(int hid) {
3.         String sql = "update news_headline set page_views = page_views+1 where hid = ?";
4.         return baseUpdate(sql, hid);
5.     }

复制代码

查询头条详情需要利用sql语句的多表查询：（即将多个表格中一样的属性作为条件拼接多张表格）设计语法有left，其含义为左连接。

1.     @Override
2.     public HeadlineDetailVo findHeadlineDetail(int hid) {
3.         /*  需要返回的实体类
4.             private Integer hid;
5.             private String title;
6.             private String article;
7.             private Integer type;
8.             private String typeName;
9.             private Integer pageViews;
10.             private Long pastHours;
11.             private Integer publisher;
12.             private String author;
13.          */
14.         //此处涉及多表查询问题
15.         String sql = """
16.                 select
17.                     h.hid hid ,
18.                     h.title title ,
19.                     h.article article ,
20.                     h.type type ,
21.                     t.tname typeName ,
22.                     h.page_views pageViews ,
23.                     TIMESTAMPDIFF(HOUR,create_time,now()) pastHours ,
24.                     h.publisher publisher ,
25.                     u.nick_name author
26.                 from
27.                     news_headline h
28.                 left join
29.                     news_type t
30.                 on h.type = t.tid
31.                 left join
32.                     news_user u
33.                 on h.publisher = u.uid
34.                 where
35.                     h.hid = ?
36.                 """;
37.         List<HeadlineDetailVo> list = baseQuery(HeadlineDetailVo.class, sql, hid);
38.         return null != list && list.size() > 0 ? list.get(0) : null;
39.     }

复制代码

用户对本身发布的消息举行增删改业务

登录校验：

在修改本身发布的消息之前需要先向服务端发送一个是否还处在登岸状态的请求（即：token有没有逾期），如果token已经逾期则无法完成修改。

1. NewsUserController：

复制代码

1.     /**
2.      * 前端自己校验是否失去登录状态的接口
3.      * @param req
4.      * @param resp
5.      * @throws ServletException
6.      * @throws IOException
7.      */
8.     protected void checkLogin(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
9.         String token = req.getHeader("token");
10.         Result result = Result.build(null, ResultCodeEnum.NOTLOGIN);
11.         if(null != token){
12.             if(!JwtHelper.isExpiration(token)){
13.                 result = Result.ok(null);
14.             }
15.         }
16.         WebUtil.writeJson(resp, result);
17.     }

复制代码

注意：但是会有一个题目就是后端留好了这个校验是否处在登录状态的接口，但是前端大概不向这个接口发请求，因此必须做一个过滤器对请求举行拦截。登录过滤器是不可以把全部的请求都拦截的，只需要拦截NewsHeadlineController下的请求，因此需要注解配置。如果拦在PortalController和NewsUserController那就会变成必须要登录才能检察消息，不符合业务需求。因此拦在NewsHeadlineController。
LoginFilter：

1. import com.ryy.headline.common.Result;
2. import com.ryy.headline.common.ResultCodeEnum;
3. import com.ryy.headline.util.JwtHelper;
4. import com.ryy.headline.util.WebUtil;
5. import jakarta.servlet.*;
6. import jakarta.servlet.annotation.WebFilter;
7. import jakarta.servlet.http.HttpServletRequest;
8. import jakarta.servlet.http.HttpServletResponse;
10. import java.io.IOException;
12. @WebFilter("/headline/*")
13. public class LoginFilter implements Filter {
14.     @Override
15.     public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
16.         HttpServletRequest request = (HttpServletRequest) servletRequest;
17.         HttpServletResponse response = (HttpServletResponse) servletResponse;
18.         String token = request.getHeader("token");
20.         boolean flag = null != token && (!JwtHelper.isExpiration(token));
22.         if(flag){  //如果还在登陆状态就放行到Controller层继续执行接下去的代码
23.             filterChain.doFilter(servletRequest,servletResponse);
24.         }else{
25.             WebUtil.writeJson(response, Result.build(null, ResultCodeEnum.NOTLOGIN));
26.         }
27.     }
28. }

复制代码

修改头条并回显：

即用户点击修改之后需要向后端发送一个请求返回对应的头条详情并举行修改。

1.     /**
2.      * 修改头条回显业务接口
3.      * @param req
4.      * @param resp
5.      * @throws ServletException
6.      * @throws IOException
7.      */
8.     protected void findHeadlineByHid(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
9.         Integer hid = Integer.parseInt(req.getParameter("hid"));
10.         NewsHeadline headline = headlineService.findByHid(hid);
12.         //注意这里前端要求的返回格式是键值对形式
13.         Map data = new HashMap();
14.         data.put("headline", headline);
15.         WebUtil.writeJson(resp, Result.ok(data));
16.     }

复制代码

DAO层（NewsHeadlineDaoImpl）中得sql：

1.     public NewsHeadline findByHid(Integer hid) {
2.         String sql = """
3.                 select
4.                     hid,
5.                     title,
6.                     article,
7.                     type,
8.                     publisher,
9.                     page_views pageViews,
10.                     create_time createTime,
11.                     update_time updateTime,
12.                     is_deleted isDeleted
13.                 from
14.                     news_headline
15.                 where
16.                     hid = ?
17.                 """;
18.         List<NewsHeadline> list = baseQuery(NewsHeadline.class, sql, hid);
19.         return null != list && list.size() > 0 ? list.get(0) : null;
20.     }

复制代码

保存修改业务：

1.     /**
2.      * 修改头条并保存进入数据库的接口实现
3.      * @param req
4.      * @param resp
5.      * @throws ServletException
6.      * @throws IOException
7.      */
8.     protected void update(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
9.         NewsHeadline newsHeadline = WebUtil.readJson(req, NewsHeadline.class);
10.         headlineService.update(newsHeadline);
12.         WebUtil.writeJson(resp, Result.ok(null));
13.     }

复制代码

 DAO层的sql:

1.     @Override
2.     public int update(NewsHeadline newsHeadline) {
3.         String sql = """
4.                 update
5.                     news_headline
6.                 set
7.                     title = ?,
8.                     article = ?,
9.                     type = ?,
10.                     update_time = now()
11.                 where
12.                     hid = ?
13.                 """;
14.         return baseUpdate(sql,
15.                 newsHeadline.getTitle(),
16.                 newsHeadline.getArticle(),
17.                 newsHeadline.getType(),
18.                 newsHeadline.getHid()
19.         );
20.     }

复制代码

删除业务：

末了的删除业务实际上是一个修改状态的操作，即把is_deleted属性设置为1，因为前面查询消息的这些业务逻辑都是查is_deleted=0的消息。
这里提供dao层写法：

1.     @Override
2.     public int removeByHid(int hid) {
3.         String sql = "update news_headline set is_deleted = 1 where hid = ?";
4.         return baseUpdate(sql, hid);
5.     }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。