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

黑马头条详解（一）

作者：IT小白 | 2024-08-16 12:05:50

赞

踩

黑马头条

一、登录功能

1、需求分析

 2、表结构

3、加密方式（手动加密：md5+盐）

4、微服务结构

1.1、代码实现

①定义LoginDto

  1. package com.heima.model.user.dtos;
  2.  
  3. import lombok.Data;
  4.  
  5. @Data
  6. public class LoginDto {
  7.     /**
  8.      * 手机号
  9.      */
  10.     private String phone;
  11.     /**
  12.      * 密码
  13.      */
  14.     private String password;
  15. }

②定义控制层controller

  1. package com.heima.user.controller.v1;
  2.  
  3. import com.heima.model.common.dtos.ResponseResult;
  4. import com.heima.model.user.dtos.LoginDto;
  5. import com.heima.user.service.ApUserService;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.web.bind.annotation.PostMapping;
  8. import org.springframework.web.bind.annotation.RequestBody;
  9. import org.springframework.web.bind.annotation.RequestMapping;
  10. import org.springframework.web.bind.annotation.RestController;
  11.  
  12. @RestController
  13. @RequestMapping("/api/v1/login")
  14. public class ApUserLoginController {
  15.     @Autowired
  16.     private ApUserService apUserService;
  17.     @PostMapping("/login_auth")
  18.     public ResponseResult login(@RequestBody LoginDto dto){
  19.  
  20.         return apUserService.login(dto);
  21.     }
  22. }

③定义持久层mapper

  1. package com.heima.user.mapper;
  2.  
  3. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  4. import com.heima.model.user.pojos.ApUser;
  5. import org.apache.ibatis.annotations.Mapper;
  6.  
  7. @Mapper
  8. public interface ApUserMapper extends BaseMapper<ApUser> {
  9. }

④定义service

  1. package com.heima.user.service;
  2.  
  3. import com.baomidou.mybatisplus.extension.service.IService;
  4. import com.heima.model.common.dtos.ResponseResult;
  5. import com.heima.model.user.dtos.LoginDto;
  6. import com.heima.model.user.pojos.ApUser;
  7.  
  8. public interface ApUserService extends IService<ApUser> {
  9.     /**
  10.      * app端登录功能
  11.      * @param dto
  12.      * @return
  13.      */
  14.     public ResponseResult login(LoginDto dto);
  15. }

实现类

  1. package com.heima.user.service.impl;
  2.  
  3.  
  4. import com.baomidou.mybatisplus.core.toolkit.Wrappers;
  5. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  6. import com.heima.model.common.dtos.ResponseResult;
  7. import com.heima.model.common.enums.AppHttpCodeEnum;
  8. import com.heima.model.user.dtos.LoginDto;
  9. import com.heima.model.user.pojos.ApUser;
  10. import com.heima.user.mapper.ApUserMapper;
  11. import com.heima.user.service.ApUserService;
  12. import com.heima.utils.common.AppJwtUtil;
  13. import lombok.extern.slf4j.Slf4j;
  14. import org.apache.commons.lang3.StringUtils;
  15. import org.springframework.stereotype.Service;
  16. import org.springframework.transaction.annotation.Transactional;
  17. import org.springframework.util.DigestUtils;
  18.  
  19. import java.util.HashMap;
  20. import java.util.Map;
  21.  
  22. @Service
  23. @Transactional
  24. @Slf4j
  25. public class ApUserServiceImpl extends ServiceImpl<ApUserMapper, ApUser> implements ApUserService {
  26.     /**
  27.      * app端登录功能
  28.      * @param dto
  29.      * @return
  30.      */
  31.     @Override
  32.     public ResponseResult login(LoginDto dto) {
  33.         //1.正常登录 用户名和密码
  34.         if(StringUtils.isNoneBlank(dto.getPhone()) && StringUtils.isNoneBlank(dto.getPassword())){
  35.             //1.1 根据手机号查询用户信息
  36.             ApUser dbUser = getOne(Wrappers.<ApUser>lambdaQuery().eq(ApUser::getPhone, dto.getPhone()));
  37.             if(dbUser == null){
  38.                 return ResponseResult.errorResult(AppHttpCodeEnum.DATA_NOT_EXIST,"用户信息不存在");
  39.             }
  40.             //1.2 比对密码
  41.             String salt = dbUser.getSalt();
  42.             String password = dto.getPassword();
  43.             String pswd = DigestUtils.md5DigestAsHex((password+salt).getBytes());
  44.             if(!pswd.equals(dbUser.getPassword())){
  45.                 return ResponseResult.errorResult(AppHttpCodeEnum.LOGIN_PASSWORD_ERROR);
  46.             }
  47.             //1.3 返回数据 jwt  user
  48.             String token = AppJwtUtil.getToken(dbUser.getId().longValue());
  49.             Map<String,Object> map = new HashMap<>();
  50.             map.put("token",token);
  51.             dbUser.setSalt("");
  52.             dbUser.setPassword("");
  53.             map.put("user",dbUser);
  54.             return ResponseResult.okResult(map);
  55.         }else {
  56.             //2.游客登陆
  57.             Map<String,Object> map = new HashMap<>();
  58.             map.put("token",AppJwtUtil.getToken(0L));
  59.             return ResponseResult.okResult(map);
  60.         }
  61.     }
  62. }

 ⑤postman测试

 1.2、app端网关

通过网关进行路由，选择对应的微服务

 项目中网关的服务工程结构

 ①在heima-leadnews-gateway导入以下依赖

  1. <dependencies>
  2.     <dependency>
  3.         <groupId>org.springframework.cloud</groupId>
  4.         <artifactId>spring-cloud-starter-gateway</artifactId>
  5.     </dependency>
  6.     <dependency>
  7.         <groupId>com.alibaba.cloud</groupId>
  8.         <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  9.     </dependency>
  10.      <dependency>
  11.             <groupId>com.alibaba.cloud</groupId>
  12.             <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
  13.         </dependency>
  14.     <dependency>
  15.         <groupId>io.jsonwebtoken</groupId>
  16.         <artifactId>jjwt</artifactId>
  17.     </dependency>
  18. </dependencies>

②在heima-leadnews-gateway下创建heima-leadnews-app-gateway微服务

启动类

  1. package com.heima.app.gateway;
  2.  
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  6.  
  7. @SpringBootApplication
  8. @EnableDiscoveryClient  //开启注册中心
  9. public class AppGatewayApplication {
  10.  
  11.     public static void main(String[] args) {
  12.         SpringApplication.run(AppGatewayApplication.class,args);
  13.     }
  14. }

bootstrap.yml

  1. server:
  2.   port: 51601
  3. spring:
  4.   application:
  5.     name: leadnews-app-gateway
  6.   cloud:
  7.     nacos:
  8.       discovery:
  9.         server-addr: 192.168.200.130:8848
  10.       config:
  11.         server-addr: 192.168.200.130:8848
  12.         file-extension: yml

③在nacos的配置中心创建dataid为leadnews-app-gateway的yml配置

  1. spring:
  2.   cloud:
  3.     gateway:
  4.       globalcors:
  5.         add-to-simple-url-handler-mapping: true
  6.         corsConfigurations:
  7.           '[/**]':
  8.             allowedHeaders: "*"
  9.             allowedOrigins: "*"
  10.             allowedMethods:
  11.               - GET
  12.               - POST
  13.               - DELETE
  14.               - PUT
  15.               - OPTION
  16.       routes:
  17.         # 平台管理
  18.         - id: user
  19.           uri: lb://leadnews-user
  20.           predicates:
  21.             - Path=/user/**
  22.           filters:
  23.             - StripPrefix= 1

环境搭建完成以后，启动项目网关和用户两个服务，使用postman进行测试

 1.3、全局过滤器实现jwt校验

流程图

思路分析：

1. 用户进入网关开始登陆，网关过滤器进行判断，如果是登录，则路由到后台管理微服务进行登录
2. 用户登录成功，后台管理微服务签发JWT TOKEN信息返回给用户
3. 用户再次进入网关开始访问，网关过滤器接收用户携带的TOKEN 
4. 网关过滤器解析TOKEN ，判断是否有权限，如果有，则放行，如果没有则返回未认证错误

再网关微服务中新建全局过滤器

  1. package com.heima.app.gateway.filter;
  2.  
  3. import com.heima.app.gateway.util.AppJwtUtil;
  4. import io.jsonwebtoken.Claims;
  5. import lombok.extern.slf4j.Slf4j;
  6. import org.apache.commons.lang.StringUtils;
  7. import org.springframework.cloud.gateway.filter.GatewayFilterChain;
  8. import org.springframework.cloud.gateway.filter.GlobalFilter;
  9. import org.springframework.core.Ordered;
  10. import org.springframework.http.HttpStatus;
  11. import org.springframework.http.server.reactive.ServerHttpRequest;
  12. import org.springframework.http.server.reactive.ServerHttpResponse;
  13. import org.springframework.stereotype.Component;
  14. import org.springframework.web.server.ServerWebExchange;
  15. import reactor.core.publisher.Mono;
  16.  
  17. @Component
  18. @Slf4j
  19. public class AuthorizeFilter implements Ordered, GlobalFilter {
  20.     @Override
  21.     public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
  22.         //1.获取request和response
  23.         ServerHttpRequest request = exchange.getRequest();
  24.         ServerHttpResponse response = exchange.getResponse();
  25.         //2.判断是否是登录
  26.         if (request.getURI().getPath().contains("/login")) {
  27.             //放行
  28.             return chain.filter(exchange);
  29.         }
  30.         //3.获取token
  31.         String token = request.getHeaders().getFirst("token");
  32.  
  33.         //4.判断token是否存在
  34.         if (StringUtils.isBlank(token)) {
  35.             response.setStatusCode(HttpStatus.UNAUTHORIZED);
  36.             return response.setComplete();//结束请求并返回给前端401
  37.         }
  38.         //5.判断token是否有效
  39.         try {
  40.             Claims claimsBody = AppJwtUtil.getClaimsBody(token);
  41.             //是否是过期
  42.             int result = AppJwtUtil.verifyToken(claimsBody); //-1：有效，0：有效，1：过期，2：过期
  43.             if (result == 1 || result == 2) {
  44.                 response.setStatusCode(HttpStatus.UNAUTHORIZED);
  45.                 return response.setComplete();//结束请求并返回给前端401
  46.             }
  47.         }catch (Exception e){
  48.             e.printStackTrace();
  49.             response.setStatusCode(HttpStatus.UNAUTHORIZED);
  50.             return response.setComplete();//结束请求并返回给前端401
  51.         }
  52.  
  53.         //6.放行
  54.         return chain.filter(exchange);
  55.     }
  56.  
  57.     /**
  58.      * 设置优先级 值越小 优先级越高
  59.      *
  60.      * @return
  61.      */
  62.     @Override
  63.     public int getOrder() {
  64.         return 0;
  65.     }
  66. }

 1.4、app前端项目集成

通过nginx来进行配置，功能如下

- 通过nginx的反向代理功能访问后台的网关资源
- 通过nginx的静态服务器功能访问前端静态页面

二、app端文章列表

需求

文章表结构

 为什么要拆分文章表

使用垂直分表的方式

实现思路及实现功能

2.1、文章列表功能实现

①导入heima-leadnews-article微服务。注意：需要在heima-leadnews-service的pom文件夹中添加子模块信息，如下：

 在nacos中进行如下配置

  1. spring:
  2.   datasource:
  3.     driver-class-name: com.mysql.jdbc.Driver
  4.     url: jdbc:mysql://localhost:3306/leadnews_article?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
  5.     username: root
  6.     password: root
  7. # 设置Mapper接口所对应的XML文件位置，如果你在Mapper接口中有自定义方法，需要进行该配置
  8. mybatis-plus:
  9.   mapper-locations: classpath*:mapper/*.xml
  10.   # 设置别名包扫描路径，通过该属性可以给包中的类注册别名
  11.   type-aliases-package: com.heima.model.article.pojos

 ②定义控制层controller

  1. package com.heima.article.controller.v1;
  2.  
  3. import com.heima.article.service.ApArticleService;
  4. import com.heima.common.constants.ArticleConstants;
  5. import com.heima.model.article.dtos.ArticleHomeDto;
  6. import com.heima.model.common.dtos.ResponseResult;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.web.bind.annotation.PostMapping;
  9. import org.springframework.web.bind.annotation.RequestBody;
  10. import org.springframework.web.bind.annotation.RequestMapping;
  11. import org.springframework.web.bind.annotation.RestController;
  12.  
  13. @RestController
  14. @RequestMapping("/api/v1/article")
  15. public class ArticleHomeController {
  16.     @Autowired
  17.     private ApArticleService apArticleService;
  18.  
  19.     /**
  20.      * 加载首页
  21.      * @param dto
  22.      * @return
  23.      */
  24.     @PostMapping("/load")
  25.     public ResponseResult load(@RequestBody ArticleHomeDto dto) {
  26.         return apArticleService.load(dto, ArticleConstants.LOADTYPE_LOAD_MORE);
  27.     }
  28.  
  29.     /**
  30.      * 加载更多
  31.      * @param dto
  32.      * @return
  33.      */
  34.     @PostMapping("/loadmore")
  35.     public ResponseResult loadMore(@RequestBody ArticleHomeDto dto) {
  36.         return apArticleService.load(dto, ArticleConstants.LOADTYPE_LOAD_MORE);
  37.     }
  38.  
  39.     /**
  40.      * 加载最新
  41.      * @param dto
  42.      * @return
  43.      */
  44.     @PostMapping("/loadnew")
  45.     public ResponseResult loadNew(@RequestBody ArticleHomeDto dto) {
  46.         return apArticleService.load(dto, ArticleConstants.LOADTYPE_LOAD_NEW);
  47.     }
  48. }

③定义持久层mapper

  1. package com.heima.article.mapper;
  2.  
  3. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  4. import com.heima.model.article.dtos.ArticleHomeDto;
  5. import com.heima.model.article.pojos.ApArticle;
  6. import org.apache.ibatis.annotations.Mapper;
  7. import org.apache.ibatis.annotations.Param;
  8.  
  9. import java.util.List;
  10.  
  11. @Mapper
  12. public interface ApArticleMapper extends BaseMapper<ApArticle> {
  13.  
  14.     public List<ApArticle> loadArticleList(@Param("dto") ArticleHomeDto dto, @Param("type") Short type);
  15.  
  16. }

对应的映射文件,在resources中新建mapper/ApArticleMapper.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3. <mapper namespace="com.heima.article.mapper.ApArticleMapper">
  4.  
  5.     <resultMap id="resultMap" type="com.heima.model.article.pojos.ApArticle">
  6.         <id column="id" property="id"/>
  7.         <result column="title" property="title"/>
  8.         <result column="author_id" property="authorId"/>
  9.         <result column="author_name" property="authorName"/>
  10.         <result column="channel_id" property="channelId"/>
  11.         <result column="channel_name" property="channelName"/>
  12.         <result column="layout" property="layout"/>
  13.         <result column="flag" property="flag"/>
  14.         <result column="images" property="images"/>
  15.         <result column="labels" property="labels"/>
  16.         <result column="likes" property="likes"/>
  17.         <result column="collection" property="collection"/>
  18.         <result column="comment" property="comment"/>
  19.         <result column="views" property="views"/>
  20.         <result column="province_id" property="provinceId"/>
  21.         <result column="city_id" property="cityId"/>
  22.         <result column="county_id" property="countyId"/>
  23.         <result column="created_time" property="createdTime"/>
  24.         <result column="publish_time" property="publishTime"/>
  25.         <result column="sync_status" property="syncStatus"/>
  26.         <result column="static_url" property="staticUrl"/>
  27.     </resultMap>
  28.     <select id="loadArticleList" resultMap="resultMap">
  29.         SELECT
  30.         aa.*
  31.         FROM
  32.         `ap_article` aa
  33.         LEFT JOIN ap_article_config aac ON aa.id = aac.article_id
  34.         <where>
  35.             and aac.is_delete != 1
  36.             and aac.is_down != 1
  37.             <!-- loadmore -->
  38.             <if test="type != null and type == 1">
  39.                 and aa.publish_time <![CDATA[<]]> #{dto.minBehotTime}
  40.             </if>
  41.             <if test="type != null and type == 2">
  42.                 and aa.publish_time <![CDATA[>]]> #{dto.maxBehotTime}
  43.             </if>
  44.             <if test="dto.tag != '__all__'">
  45.                 and aa.channel_id = #{dto.tag}
  46.             </if>
  47.         </where>
  48.         order by aa.publish_time desc
  49.         limit #{dto.size}
  50.     </select>
  51.  
  52. </mapper>

④定义业务层service

  1. package com.heima.article.service;
  2.  
  3. import com.baomidou.mybatisplus.extension.service.IService;
  4. import com.heima.model.article.dtos.ArticleHomeDto;
  5. import com.heima.model.article.pojos.ApArticle;
  6. import com.heima.model.common.dtos.ResponseResult;
  7.  
  8. public interface ApArticleService extends IService<ApArticle> {
  9.     /**
  10.      * 加载文章列表
  11.      * @param dto
  12.      * @param type  1 加载更多   2 加载最新
  13.      * @return
  14.      */
  15.     public ResponseResult load(ArticleHomeDto dto,Short type);
  16. }

实现类

  1. package com.heima.article.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  4. import com.heima.article.mapper.ApArticleMapper;
  5. import com.heima.article.service.ApArticleService;
  6. import com.heima.common.constants.ArticleConstants;
  7. import com.heima.model.article.dtos.ArticleHomeDto;
  8. import com.heima.model.article.pojos.ApArticle;
  9. import com.heima.model.common.dtos.ResponseResult;
  10. import lombok.extern.slf4j.Slf4j;
  11. import org.apache.commons.lang.StringUtils;
  12. import org.springframework.beans.factory.annotation.Autowired;
  13. import org.springframework.stereotype.Service;
  14. import org.springframework.transaction.annotation.Transactional;
  15.  
  16. import java.util.Date;
  17. import java.util.List;
  18.  
  19. @Service
  20. @Transactional
  21. @Slf4j
  22. public class ApArticleServiceImpl extends ServiceImpl<ApArticleMapper, ApArticle> implements ApArticleService {
  23.     @Autowired
  24.     private ApArticleMapper apArticleMapper;
  25.  
  26.     private final static short MAX_PAGE_SIZE = 50;
  27.  
  28.  
  29.     /**
  30.      * 加载文章列表
  31.      *
  32.      * @param dto
  33.      * @param type 1 加载更多   2 加载最新
  34.      * @return
  35.      */
  36.     @Override
  37.     public ResponseResult load(ArticleHomeDto dto, Short type) {
  38.         //1. 校验参数
  39.         //分页条数的校验
  40.         Integer size = dto.getSize();
  41.         if (size == null || size == 0) {
  42.             size = 10;
  43.         }
  44.         //分页的值不超过50
  45.         size = Math.min(size, MAX_PAGE_SIZE);
  46.         dto.setSize(size);
  47.         //校验参数type
  48.         if (!type.equals(ArticleConstants.LOADTYPE_LOAD_MORE) && !type.equals(ArticleConstants.LOADTYPE_LOAD_NEW)) {
  49.             type = ArticleConstants.LOADTYPE_LOAD_MORE;
  50.         }
  51.         //频道参数校验
  52.         if (StringUtils.isBlank(dto.getTag())) {
  53.             dto.setTag(ArticleConstants.DEFAULT_TAG);
  54.         }
  55.         //时间校验
  56.         if (dto.getMaxBehotTime() == null) dto.setMaxBehotTime(new Date());
  57.         if (dto.getMinBehotTime() == null) dto.setMinBehotTime(new Date());
  58.  
  59.         //2.查询
  60.         List<ApArticle> articleList = apArticleMapper.loadArticleList(dto, type);
  61.         //3.返回结果
  62.         return ResponseResult.okResult(articleList);
  63.     }
  64. }

⑤在app网关的微服务的nacos的配置中心添加文章微服务的路由

  1. spring:
  2.   cloud:
  3.     gateway:
  4.       globalcors:
  5.         cors-configurations:
  6.           '[/**]': # 匹配所有请求
  7.             allowedOrigins: "*" #跨域处理 允许所有的域
  8.             allowedMethods: # 支持的方法
  9.               - GET
  10.               - POST
  11.               - PUT
  12.               - DELETE
  13.       routes:
  14.         # 用户微服务
  15.         - id: user
  16.           uri: lb://leadnews-user
  17.           predicates:
  18.             - Path=/user/**
  19.           filters:
  20.             - StripPrefix= 1
  21.         # 文章微服务
  22.         - id: article
  23.           uri: lb://leadnews-article
  24.           predicates:
  25.             - Path=/article/**
  26.           filters:
  27.             - StripPrefix= 1

2.2、文章详情功能实现

需求分析

实现方案一

实现方案二 

2.2.1、Freemarker

输出静态化文件

 2.2.2、MinIO

快速入门，把list.html文件上传到minio中，并且可以在浏览器中访问

 ①创建工程，引入依赖

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>heima-leadnews-test</artifactId>
  7.         <groupId>com.heima</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  11.  
  12.     <artifactId>minio-demo</artifactId>
  13.  
  14.     <properties>
  15.         <maven.compiler.source>8</maven.compiler.source>
  16.         <maven.compiler.target>8</maven.compiler.target>
  17.     </properties>
  18.  
  19.     <dependencies>
  20.  
  21.         <dependency>
  22.             <groupId>io.minio</groupId>
  23.             <artifactId>minio</artifactId>
  24.             <version>7.1.0</version>
  25.         </dependency>
  26.         <dependency>
  27.             <groupId>org.springframework.boot</groupId>
  28.             <artifactId>spring-boot-starter-web</artifactId>
  29.         </dependency>
  30.  
  31.         <dependency>
  32.             <groupId>org.springframework.boot</groupId>
  33.             <artifactId>spring-boot-starter-test</artifactId>
  34.         </dependency>
  35.     </dependencies>
  36.  
  37. </project>

②创建启动类

  1. package com.heima.minio;
  2.  
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5.  
  6.  
  7. @SpringBootApplication
  8. public class MinIOApplication {
  9.  
  10.     public static void main(String[] args) {
  11.         SpringApplication.run(MinIOApplication.class,args);
  12.     }
  13. }

③创建测试类，上传html文件

  1. package com.heima.minio.test;
  2.  
  3. import io.minio.MinioClient;
  4. import io.minio.PutObjectArgs;
  5.  
  6. import java.io.FileInputStream;
  7.  
  8. public class MinIOTest {
  9.  
  10.  
  11.     public static void main(String[] args) {
  12.  
  13.         FileInputStream fileInputStream = null;
  14.         try {
  15.  
  16.             fileInputStream =  new FileInputStream("D:\\list.html");;
  17.  
  18.             //1.创建minio链接客户端
  19.             MinioClient minioClient = MinioClient.builder().credentials("minio", "minio123").endpoint("http://192.168.200.130:9000").build();
  20.             //2.上传
  21.             PutObjectArgs putObjectArgs = PutObjectArgs.builder()
  22.                     .object("list.html")//文件名
  23.                     .contentType("text/html")//文件类型
  24.                     .bucket("leadnews")//桶名词  与minio创建的名词一致
  25.                     .stream(fileInputStream, fileInputStream.available(), -1) //文件流
  26.                     .build();
  27.             minioClient.putObject(putObjectArgs);
  28.  
  29.             System.out.println("http://192.168.200.130:9000/leadnews/list.html");
  30.  
  31.         } catch (Exception ex) {
  32.             ex.printStackTrace();
  33.         }
  34.     }
  35.  
  36. }

封装MinIO为starter

2.2.3、静态模板展示 

 ①在文章微服务中添加FreeMarker和Minio依赖

  1. <dependencies>
  2.     <dependency>
  3.         <groupId>org.springframework.boot</groupId>
  4.         <artifactId>spring-boot-starter-freemarker</artifactId>
  5.     </dependency>
  6.     <dependency>
  7.         <groupId>com.heima</groupId>
  8.         <artifactId>heima-file-starter</artifactId>
  9.         <version>1.0-SNAPSHOT</version>
  10.     </dependency>
  11. </dependencies>

②新建ApArticleContentMapper

  1. package com.heima.article.mapper;
  2.  
  3. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  4. import com.heima.model.article.pojos.ApArticleContent;
  5. import org.apache.ibatis.annotations.Mapper;
  6.  
  7. @Mapper
  8. public interface ApArticleContentMapper extends BaseMapper<ApArticleContent> {
  9. }

③在artile微服务中新增测试类（后期新增文章的时候创建详情静态页，目前暂时手动生成）

  1. package com.heima.article.test;
  2.  
  3.  
  4. import com.alibaba.fastjson.JSONArray;
  5. import com.baomidou.mybatisplus.core.toolkit.Wrappers;
  6. import com.heima.article.ArticleApplication;
  7. import com.heima.article.mapper.ApArticleContentMapper;
  8. import com.heima.article.mapper.ApArticleMapper;
  9. import com.heima.file.service.FileStorageService;
  10. import com.heima.model.article.pojos.ApArticle;
  11. import com.heima.model.article.pojos.ApArticleContent;
  12. import freemarker.template.Configuration;
  13. import freemarker.template.Template;
  14. import org.apache.commons.lang3.StringUtils;
  15. import org.junit.Test;
  16. import org.junit.runner.RunWith;
  17. import org.springframework.beans.factory.annotation.Autowired;
  18. import org.springframework.boot.test.context.SpringBootTest;
  19. import org.springframework.test.context.junit4.SpringRunner;
  20.  
  21. import java.io.ByteArrayInputStream;
  22. import java.io.InputStream;
  23. import java.io.StringWriter;
  24. import java.util.HashMap;
  25. import java.util.Map;
  26.  
  27. @SpringBootTest(classes = ArticleApplication.class)
  28. @RunWith(SpringRunner.class)
  29. public class ArticleFreemarkerTest {
  30.  
  31.     @Autowired
  32.     private Configuration configuration;
  33.  
  34.     @Autowired
  35.     private FileStorageService fileStorageService;
  36.  
  37.  
  38.     @Autowired
  39.     private ApArticleMapper apArticleMapper;
  40.  
  41.     @Autowired
  42.     private ApArticleContentMapper apArticleContentMapper;
  43.  
  44.     @Test
  45.     public void createStaticUrlTest() throws Exception {
  46.         //1.获取文章内容
  47.         ApArticleContent apArticleContent = apArticleContentMapper.selectOne(Wrappers.<ApArticleContent>lambdaQuery().eq(ApArticleContent::getArticleId, 1390536764510310401L));
  48.         if(apArticleContent != null && StringUtils.isNotBlank(apArticleContent.getContent())){
  49.             //2.文章内容通过freemarker生成html文件
  50.             StringWriter out = new StringWriter();
  51.             Template template = configuration.getTemplate("article.ftl");
  52.  
  53.             Map<String, Object> params = new HashMap<>();
  54.             params.put("content", JSONArray.parseArray(apArticleContent.getContent()));
  55.  
  56.             template.process(params, out);
  57.             InputStream is = new ByteArrayInputStream(out.toString().getBytes());
  58.  
  59.             //3.把html文件上传到minio中
  60.             String path = fileStorageService.uploadHtmlFile("", apArticleContent.getArticleId() + ".html", is);
  61.  
  62.             //4.修改ap_article表，保存static_url字段
  63.             ApArticle article = new ApArticle();
  64.             article.setId(apArticleContent.getArticleId());
  65.             article.setStaticUrl(path);
  66.             apArticleMapper.updateById(article);
  67.  
  68.         }
  69.     }
  70. }

三、自媒体文章发布

功能

自媒体端环境搭建

前端

3.1、自媒体素材管理

 功能

表结构

问题

1.在素材表中的用户信息如何得到? user_id
2.素材的信息保存到什么位置? 

3.1.1、素材表中的用户信息如何得到问题解决思路

①：网关进行token解析后，把解析后的用户信息存储到header中

  1. package com.heima.wemedia.gateway.filter;
  2.  
  3.  
  4. import com.heima.wemedia.gateway.util.AppJwtUtil;
  5. import io.jsonwebtoken.Claims;
  6. import lombok.extern.slf4j.Slf4j;
  7. import org.apache.commons.lang.StringUtils;
  8. import org.springframework.cloud.gateway.filter.GatewayFilterChain;
  9. import org.springframework.cloud.gateway.filter.GlobalFilter;
  10. import org.springframework.core.Ordered;
  11. import org.springframework.http.HttpStatus;
  12. import org.springframework.http.server.reactive.ServerHttpRequest;
  13. import org.springframework.http.server.reactive.ServerHttpResponse;
  14. import org.springframework.stereotype.Component;
  15. import org.springframework.web.server.ServerWebExchange;
  16. import reactor.core.publisher.Mono;
  17.  
  18. @Component
  19. @Slf4j
  20. public class AuthorizeFilter implements Ordered, GlobalFilter {
  21.     @Override
  22.     public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
  23.         //1.获取request和response对象
  24.         ServerHttpRequest request = exchange.getRequest();
  25.         ServerHttpResponse response = exchange.getResponse();
  26.  
  27.         //2.判断是否是登录
  28.         if (request.getURI().getPath().contains("/login")) {
  29.             //放行
  30.             return chain.filter(exchange);
  31.         }
  32.  
  33.         //3.获取token
  34.         String token = request.getHeaders().getFirst("token");
  35.  
  36.         //4.判断token是否存在
  37.         if (StringUtils.isBlank(token)) {
  38.             response.setStatusCode(HttpStatus.UNAUTHORIZED);
  39.             return response.setComplete();
  40.         }
  41.  
  42.         //5.判断token是否有效
  43.         try {
  44.             Claims claimsBody = AppJwtUtil.getClaimsBody(token);
  45.             //是否是过期
  46.             int result = AppJwtUtil.verifyToken(claimsBody);
  47.             if (result == 1 || result == 2) {
  48.                 response.setStatusCode(HttpStatus.UNAUTHORIZED);
  49.                 return response.setComplete();
  50.             }
  51. //———————————————————————————————————————————————————————————————————————————————————————
  52. //解决思路
  53.             //获取用户信息
  54.             Object userId = claimsBody.get("id");
  55.             //存入header
  56.             ServerHttpRequest serverHttpRequest = request.mutate().headers(httpHeaders -> {
  57.                 httpHeaders.add("userId", userId + "");
  58.             }).build();
  59.  
  60.             //重置请求
  61.             exchange.mutate().request(serverHttpRequest);
  62. //———————————————————————————————————————————————————————————————————————————————————————
  63.         } catch (Exception e) {
  64.             e.printStackTrace();
  65.         }
  66.  
  67.         //6.放行
  68.         return chain.filter(exchange);
  69.     }
  70.  
  71.     /**
  72.      * 优先级设置  值越小  优先级越高
  73.      *
  74.      * @return
  75.      */
  76.     @Override
  77.     public int getOrder() {
  78.         return 0;
  79.     }
  80. }

②自媒体微服务使用拦截器获取到header中的的用户信息，并放入到threadlocal中

ThreadLocal

  1. package com.heima.utils.thread;
  2.  
  3. import com.heima.model.wemedia.pojos.WmUser;
  4.  
  5. public class WmThreadLocalUtil {
  6.  
  7.     private final static ThreadLocal<WmUser> WM_USER_THREAD_LOCAL = new ThreadLocal<>();
  8.  
  9.     /**
  10.      * 添加用户
  11.      * @param wmUser
  12.      */
  13.     public static void  setUser(WmUser wmUser){
  14.         WM_USER_THREAD_LOCAL.set(wmUser);
  15.     }
  16.  
  17.     /**
  18.      * 获取用户
  19.      */
  20.     public static WmUser getUser(){
  21.         return WM_USER_THREAD_LOCAL.get();
  22.     }
  23.  
  24.     /**
  25.      * 清理用户
  26.      */
  27.     public static void clear(){
  28.         WM_USER_THREAD_LOCAL.remove();
  29.     }
  30. }

拦截器 

  1. package com.heima.wemedia.interceptor;
  2.  
  3. import com.heima.model.wemedia.pojos.WmUser;
  4. import com.heima.utils.thread.WmThreadLocalUtil;
  5. import org.springframework.web.servlet.HandlerInterceptor;
  6. import org.springframework.web.servlet.ModelAndView;
  7.  
  8. import javax.servlet.http.HttpServletRequest;
  9. import javax.servlet.http.HttpServletResponse;
  10.  
  11. public class WmTokenInterceptor implements HandlerInterceptor {
  12.     /**
  13.      * 得到header信息并存入当前线程中
  14.      * @param request
  15.      * @param response
  16.      * @param handler
  17.      * @return
  18.      * @throws Exception
  19.      */
  20.     @Override
  21.     public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
  22.         String userId = request.getHeader("userId");
  23.         if (userId!=null) {
  24.             //存入当前线程中
  25.             WmUser wmUser = new WmUser();
  26.             wmUser.setId(Integer.valueOf(userId));
  27.             WmThreadLocalUtil.setUser(wmUser);
  28.         }
  29.  
  30.         return true;
  31.     }
  32.  
  33.     /**
  34.      * 清理线程中的数据
  35.      * @param request
  36.      * @param response
  37.      * @param handler
  38.      * @param modelAndView
  39.      * @throws Exception
  40.      */
  41.     @Override
  42.     public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) throws Exception {
  43.         WmThreadLocalUtil.clear();
  44.     }
  45. }

配置拦截器生效

  1. package com.heima.wemedia.config;
  2.  
  3. import com.heima.wemedia.interceptor.WmTokenInterceptor;
  4. import org.springframework.context.annotation.Configuration;
  5. import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
  6. import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
  7.  
  8. @Configuration
  9. public class WebMvcConfig implements WebMvcConfigurer {
  10.  
  11.     @Override
  12.     public void addInterceptors(InterceptorRegistry registry) {
  13.         registry.addInterceptor(new WmTokenInterceptor()).addPathPatterns("/**");
  14.     }
  15. }

3.1.2、图片上传功能

 ①在自媒体导入heima-file-starter（MinIO）

  1. <dependencies>
  2.     <dependency>
  3.         <groupId>com.heima</groupId>
  4.         <artifactId>heima-file-starter</artifactId>
  5.         <version>1.0-SNAPSHOT</version>
  6.     </dependency>
  7. </dependencies>

②在自媒体微服务的nacos配置中心添加以下配置：

  1. minio:
  2.   accessKey: minio
  3.   secretKey: minio123
  4.   bucket: leadnews
  5.   endpoint: http://192.168.200.130:9000
  6.   readPath: http://192.168.200.130:9000

③创建WmMaterialController

  1. package com.heima.wemedia.controller.v1;
  2.  
  3. import com.heima.model.common.dtos.ResponseResult;
  4. import com.heima.wemedia.service.WmMaterialService;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.web.bind.annotation.PostMapping;
  7. import org.springframework.web.bind.annotation.RequestMapping;
  8. import org.springframework.web.bind.annotation.RestController;
  9. import org.springframework.web.multipart.MultipartFile;
  10.  
  11. @RestController
  12. @RequestMapping("/api/v1/material")
  13. public class WmMaterialController {
  14.     @Autowired
  15.     private WmMaterialService wmMaterialService;
  16.  
  17.     @PostMapping("/upload_picture")
  18.     public ResponseResult uploadPicture(MultipartFile multipartFile) {
  19.         return wmMaterialService.uploadPicture(multipartFile);
  20.     }
  21. }

④ 创建mapper

  1. package com.heima.wemedia.mapper;
  2.  
  3. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  4. import com.heima.model.wemedia.pojos.WmMaterial;
  5. import org.apache.ibatis.annotations.Mapper;
  6.  
  7. @Mapper
  8. public interface WmMaterialMapper extends BaseMapper<WmMaterial> {
  9. }

⑤service

  1. package com.heima.wemedia.service;
  2.  
  3. import com.baomidou.mybatisplus.extension.service.IService;
  4. import com.heima.model.common.dtos.ResponseResult;
  5. import com.heima.model.wemedia.pojos.WmMaterial;
  6. import org.springframework.web.multipart.MultipartFile;
  7.  
  8. public interface WmMaterialService extends IService<WmMaterial> {
  9.     /**
  10.      * 图片上传
  11.      * @param multipartFile
  12.      * @return
  13.      */
  14.     public ResponseResult uploadPicture(MultipartFile multipartFile);
  15. }

实现类

  1. package com.heima.wemedia.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  4. import com.heima.file.service.FileStorageService;
  5. import com.heima.model.common.dtos.ResponseResult;
  6. import com.heima.model.common.enums.AppHttpCodeEnum;
  7. import com.heima.model.wemedia.pojos.WmMaterial;
  8. import com.heima.utils.thread.WmThreadLocalUtil;
  9. import com.heima.wemedia.mapper.WmMaterialMapper;
  10. import com.heima.wemedia.service.WmMaterialService;
  11. import lombok.extern.slf4j.Slf4j;
  12. import org.springframework.beans.factory.annotation.Autowired;
  13. import org.springframework.stereotype.Service;
  14. import org.springframework.transaction.annotation.Transactional;
  15. import org.springframework.web.multipart.MultipartFile;
  16.  
  17. import java.io.IOException;
  18. import java.util.Date;
  19. import java.util.UUID;
  20.  
  21.  
  22. @Slf4j
  23. @Service
  24. @Transactional
  25. public class WmMaterialServiceImpl extends ServiceImpl<WmMaterialMapper, WmMaterial> implements WmMaterialService {
  26.  
  27.     @Autowired
  28.     private FileStorageService fileStorageService;
  29.  
  30.     /**
  31.      * 图片上传
  32.      *
  33.      * @param multipartFile
  34.      * @return
  35.      */
  36.     @Override
  37.     public ResponseResult uploadPicture(MultipartFile multipartFile) {
  38.         //1.检查参数
  39.         if (multipartFile == null || multipartFile.getSize() == 0) {
  40.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
  41.         }
  42.         //2.上传图片到minIO
  43.         String fileName = UUID.randomUUID().toString().replace("-", "");
  44.         //原图片的名字a.jpg
  45.         String originalFilename = multipartFile.getOriginalFilename();
  46.         String postfix = originalFilename.substring(originalFilename.lastIndexOf("."));
  47.         String fileId = null;
  48.         try {
  49.             fileId = fileStorageService.uploadImgFile("", fileName + postfix, multipartFile.getInputStream());
  50.             log.info("上传图片到MinIO中，fileID：{}", fileId);
  51.         } catch (IOException e) {
  52.             e.printStackTrace();
  53.             log.info("WmMaterialServiceImpl-上传文件失败");
  54.         }
  55.         //3.保存数据到数据库
  56.         WmMaterial wmMaterial = new WmMaterial();
  57.         wmMaterial.setUserId(WmThreadLocalUtil.getUser().getId());
  58.         wmMaterial.setUrl(fileId);
  59.         wmMaterial.setIsCollection((short) 0);
  60.         wmMaterial.setType((short) 0);
  61.         wmMaterial.setCreatedTime(new Date());
  62.         save(wmMaterial);
  63.         //4.返回结果
  64.         return ResponseResult.okResult(wmMaterial);
  65.     }
  66. }

3.1.3、素材列表查询

接口定义

 ①创建WmMaterialDto

  1. package com.heima.model.wemedia.dtos;
  2.  
  3. import com.heima.model.common.dtos.PageRequestDto;
  4. import lombok.Data;
  5.  
  6. @Data
  7. public class WmMaterialDto extends PageRequestDto {
  8.     /**
  9.      * 1 收藏
  10.      * 0 未收藏
  11.      */
  12.     private Short isCollection;
  13. }

②在WmMaterialController添加方法

  1. @PostMapping("/list")
  2.     public ResponseResult findList(@RequestBody WmMaterialDto dto) {
  3.         return wmMaterialService.findList(dto);
  4.     }

③ 在WmMaterialService中新增方法

  1.  /**
  2.      * 素材列表查询
  3.      * @param dto
  4.      * @return
  5.      */
  6.     public ResponseResult findList( WmMaterialDto dto);

实现类中实现

  1. /**
  2.      * 素材列表查询
  3.      *
  4.      * @param dto
  5.      * @return
  6.      */
  7.     @Override
  8.     public ResponseResult findList(WmMaterialDto dto) {
  9.         //1.检查参数
  10.         dto.checkParam();
  11.  
  12.         //2.分页查询
  13.         IPage page = new Page(dto.getPage(), dto.getSize());
  14.         LambdaQueryWrapper<WmMaterial> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  15.         //是否收藏
  16.         if (dto.getIsCollection() != null && dto.getIsCollection() == 1) {
  17.             lambdaQueryWrapper.eq(WmMaterial::getIsCollection, dto.getIsCollection());
  18.         }
  19.         //按照用户查询
  20.         lambdaQueryWrapper.eq(WmMaterial::getUserId, WmThreadLocalUtil.getUser().getId());
  21.         //按照时间倒叙查询
  22.         lambdaQueryWrapper.orderByDesc(WmMaterial::getCreatedTime);
  23.         page = page(page, lambdaQueryWrapper);
  24.  
  25.         //3.返回结果
  26.         ResponseResult responseResult = new PageResponseResult(dto.getPage(), dto.getSize(), (int) page.getTotal());
  27.         responseResult.setData(page.getRecords());
  28.         return responseResult;
  29.     }

④在引导类WemediaApplication中添加mybatis-plus的分页拦截器

  1.     @Bean
  2.     public MybatisPlusInterceptor mybatisPlusInterceptor() {
  3.         MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
  4.         interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
  5.         return interceptor;
  6.     }

 3.2、自媒体文章管理

3.2.1、查询所有频道

功能如下

功能实现 

①创建WmchannelController

  1. package com.heima.wemedia.controller.v1;
  2.  
  3. import com.heima.model.common.dtos.ResponseResult;
  4. import com.heima.wemedia.service.WmChannelService;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.web.bind.annotation.GetMapping;
  7. import org.springframework.web.bind.annotation.RequestMapping;
  8. import org.springframework.web.bind.annotation.RestController;
  9.  
  10. @RestController
  11. @RequestMapping("/api/v1/channel")
  12. public class WmchannelController {
  13.  
  14.     @Autowired
  15.     private WmChannelService wmChannelService;
  16.  
  17.     @GetMapping("/channels")
  18.     public ResponseResult findAll(){
  19.         return wmChannelService.findAll();
  20.     }
  21. }

②创建WmChannelMapper

  1. package com.heima.wemedia.mapper;
  2.  
  3. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  4. import com.heima.model.wemedia.pojos.WmChannel;
  5. import org.apache.ibatis.annotations.Mapper;
  6.  
  7. @Mapper
  8. public interface WmChannelMapper extends BaseMapper<WmChannel> {
  9. }

③创建 WmChannelService 

  1. package com.heima.wemedia.service;
  2.  
  3. import com.baomidou.mybatisplus.extension.service.IService;
  4. import com.heima.model.common.dtos.ResponseResult;
  5. import com.heima.model.wemedia.pojos.WmChannel;
  6.  
  7. public interface WmChannelService extends IService<WmChannel> {
  8.  
  9.     /**
  10.      * 查询所有频道
  11.      * @return
  12.      */
  13.     public ResponseResult findAll();
  14.  
  15.  
  16. }

实现类

  1. package com.heima.wemedia.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  4. import com.heima.model.common.dtos.ResponseResult;
  5. import com.heima.model.wemedia.pojos.WmChannel;
  6. import com.heima.wemedia.mapper.WmChannelMapper;
  7. import com.heima.wemedia.service.WmChannelService;
  8. import lombok.extern.slf4j.Slf4j;
  9. import org.springframework.stereotype.Service;
  10. import org.springframework.transaction.annotation.Transactional;
  11.  
  12. @Service
  13. @Transactional
  14. @Slf4j
  15. public class WmChannelServiceImpl extends ServiceImpl<WmChannelMapper, WmChannel> implements WmChannelService {
  16.  
  17.  
  18.     /**
  19.      * 查询所有频道
  20.      * @return
  21.      */
  22.     @Override
  23.     public ResponseResult findAll() {
  24.         return ResponseResult.okResult(list());
  25.     }
  26. }

3.2.2、查询自媒体文章

接口

功能实现

①创建WmNewsController

  1. package com.heima.wemedia.controller.v1;
  2.  
  3. import com.heima.model.common.dtos.ResponseResult;
  4. import com.heima.model.wemedia.dtos.WmNewsPageReqDto;
  5. import com.heima.wemedia.service.WmNewsService;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.web.bind.annotation.PostMapping;
  8. import org.springframework.web.bind.annotation.RequestBody;
  9. import org.springframework.web.bind.annotation.RequestMapping;
  10. import org.springframework.web.bind.annotation.RestController;
  11.  
  12. @RestController
  13. @RequestMapping("/api/v1/news")
  14. public class WmNewsController {
  15.  
  16.  
  17.     @Autowired
  18.     private WmNewsService wmNewsService;
  19.  
  20.     @PostMapping("/list")
  21.     public ResponseResult findAll(@RequestBody WmNewsPageReqDto dto){
  22.         return  wmNewsService.findAll(dto);
  23.     }
  24.  
  25. }

②创建 WmNewsMapper  

  1. package com.heima.wemedia.mapper;
  2.  
  3. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  4. import com.heima.model.wemedia.pojos.WmNews;
  5. import org.apache.ibatis.annotations.Mapper;
  6.  
  7. @Mapper
  8. public interface WmNewsMapper  extends BaseMapper<WmNews> {
  9.     
  10. }

③创建WmNewsService 

  1. package com.heima.wemedia.service;
  2.  
  3.  
  4. import com.baomidou.mybatisplus.extension.service.IService;
  5. import com.heima.model.common.dtos.ResponseResult;
  6. import com.heima.model.wemedia.dtos.WmNewsPageReqDto;
  7. import com.heima.model.wemedia.pojos.WmNews;
  8.  
  9. public interface WmNewsService extends IService<WmNews> {
  10.  
  11.     /**
  12.      * 查询文章
  13.      * @param dto
  14.      * @return
  15.      */
  16.     public ResponseResult findAll(WmNewsPageReqDto dto);
  17.  
  18. }

 实现类

  1. package com.heima.wemedia.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.core.metadata.IPage;
  5. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  6. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  7. import com.heima.model.common.dtos.PageResponseResult;
  8. import com.heima.model.common.dtos.ResponseResult;
  9. import com.heima.model.common.enums.AppHttpCodeEnum;
  10. import com.heima.model.wemedia.dtos.WmNewsPageReqDto;
  11. import com.heima.model.wemedia.pojos.WmNews;
  12. import com.heima.model.wemedia.pojos.WmUser;
  13. import com.heima.utils.thread.WmThreadLocalUtil;
  14. import com.heima.wemedia.mapper.WmNewsMapper;
  15. import com.heima.wemedia.service.WmNewsService;
  16. import lombok.extern.slf4j.Slf4j;
  17. import org.apache.commons.lang3.StringUtils;
  18. import org.springframework.stereotype.Service;
  19. import org.springframework.transaction.annotation.Transactional;
  20.  
  21. @Service
  22. @Slf4j
  23. @Transactional
  24. public class WmNewsServiceImpl  extends ServiceImpl<WmNewsMapper, WmNews> implements WmNewsService {
  25.  
  26.     /**
  27.      * 查询文章
  28.      * @param dto
  29.      * @return
  30.      */
  31.     @Override
  32.     public ResponseResult findAll(WmNewsPageReqDto dto) {
  33.  
  34.         //1.检查参数
  35.         if(dto == null){
  36.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
  37.         }
  38.         //分页参数检查
  39.         dto.checkParam();
  40.         //获取当前登录人的信息
  41.         WmUser user = WmThreadLocalUtil.getUser();
  42.         if(user == null){
  43.             return ResponseResult.errorResult(AppHttpCodeEnum.NEED_LOGIN);
  44.         }
  45.  
  46.         //2.分页条件查询
  47.         IPage page = new Page(dto.getPage(),dto.getSize());
  48.         LambdaQueryWrapper<WmNews> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  49.         //状态精确查询
  50.         if(dto.getStatus() != null){
  51.             lambdaQueryWrapper.eq(WmNews::getStatus,dto.getStatus());
  52.         }
  53.  
  54.         //频道精确查询
  55.         if(dto.getChannelId() != null){
  56.             lambdaQueryWrapper.eq(WmNews::getChannelId,dto.getChannelId());
  57.         }
  58.  
  59.         //时间范围查询
  60.         if(dto.getBeginPubDate()!=null && dto.getEndPubDate()!=null){
  61.             lambdaQueryWrapper.between(WmNews::getPublishTime,dto.getBeginPubDate(),dto.getEndPubDate());
  62.         }
  63.  
  64.         //关键字模糊查询
  65.         if(StringUtils.isNotBlank(dto.getKeyword())){
  66.             lambdaQueryWrapper.like(WmNews::getTitle,dto.getKeyword());
  67.         }
  68.  
  69.         //查询当前登录用户的文章
  70.         lambdaQueryWrapper.eq(WmNews::getUserId,user.getId());
  71.  
  72.         //发布时间倒序查询
  73.         lambdaQueryWrapper.orderByDesc(WmNews::getCreatedTime);
  74.  
  75.         page = page(page,lambdaQueryWrapper);
  76.  
  77.         //3.结果返回
  78.         ResponseResult responseResult = new PageResponseResult(dto.getPage(),dto.getSize(),(int)page.getTotal());
  79.         responseResult.setData(page.getRecords());
  80.  
  81.         return responseResult;
  82.     }
  83.    
  84. }

3.2.3、发布文章

 需求

表结构

 实现思路

 接口

WmNewsDto数据结构

 响应结果

功能实现

①在新增WmNewsController中新增方法

  1.     @PostMapping("/submit")
  2.     public ResponseResult submitNews(@RequestBody WmNewsDto dto) {
  3.         return wmNewsService.submitNews(dto);
  4.     }

②新增WmNewsMaterialMapper类，文章与素材的关联关系需要批量保存，索引需要定义mapper文件和对应的映射文件

  1. package com.heima.wemedia.mapper;
  2.  
  3. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  4. import com.heima.model.wemedia.pojos.WmNewsMaterial;
  5. import org.apache.ibatis.annotations.Mapper;
  6. import org.apache.ibatis.annotations.Param;
  7.  
  8. import java.util.List;
  9.  
  10. @Mapper
  11. public interface WmNewsMaterialMapper extends BaseMapper<WmNewsMaterial> {
  12.  
  13.      void saveRelations(@Param("materialIds") List<Integer> materialIds,@Param("newsId") Integer newsId, @Param("type")Short type);
  14. }

对应的WmNewsMaterialMapper.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3. <mapper namespace="com.heima.wemedia.mapper.WmNewsMaterialMapper">
  4.  
  5.     <insert id="saveRelations">
  6.         insert into wm_news_material (material_id,news_id,type,ord)
  7.         values
  8.         <foreach collection="materialIds" index="ord" item="mid" separator=",">
  9.             (#{mid},#{newsId},#{type},#{ord})
  10.         </foreach>
  11.     </insert>
  12.  
  13. </mapper>

③在WmNewsService中新增方法

  1.     /**
  2.      * 发布文章或保存为草稿
  3.      * @param dto
  4.      * @return
  5.      */
  6.     public ResponseResult submitNews(WmNewsDto dto);

 实现类中对应的实现方法

  1. /**
  2.      * 发布修改文章或保存为草稿
  3.      * @param dto
  4.      * @return
  5.      */
  6. @Override
  7. public ResponseResult submitNews(WmNewsDto dto) {
  8.  
  9.     //0.条件判断
  10.     if(dto == null || dto.getContent() == null){
  11.         return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
  12.     }
  13.  
  14.     //1.保存或修改文章
  15.  
  16.     WmNews wmNews = new WmNews();
  17.     //属性拷贝 属性名词和类型相同才能拷贝
  18.     BeanUtils.copyProperties(dto,wmNews);
  19.     //封面图片  list---> string
  20.     if(dto.getImages() != null && dto.getImages().size() > 0){
  21.         //[1dddfsd.jpg,sdlfjldk.jpg]-->   1dddfsd.jpg,sdlfjldk.jpg
  22.         String imageStr = StringUtils.join(dto.getImages(), ",");
  23.         wmNews.setImages(imageStr);
  24.     }
  25.     //如果当前封面类型为自动 -1
  26.     if(dto.getType().equals(WemediaConstants.WM_NEWS_TYPE_AUTO)){
  27.         wmNews.setType(null);
  28.     }
  29.  
  30.     saveOrUpdateWmNews(wmNews);
  31.  
  32.     //2.判断是否为草稿  如果为草稿结束当前方法
  33.     if(dto.getStatus().equals(WmNews.Status.NORMAL.getCode())){
  34.         return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
  35.     }
  36.  
  37.     //3.不是草稿，保存文章内容图片与素材的关系
  38.     //获取到文章内容中的图片信息
  39.     List<String> materials =  ectractUrlInfo(dto.getContent());
  40.     saveRelativeInfoForContent(materials,wmNews.getId());
  41.  
  42.     //4.不是草稿，保存文章封面图片与素材的关系，如果当前布局是自动，需要匹配封面图片
  43.     saveRelativeInfoForCover(dto,wmNews,materials);
  44.  
  45.     return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
  46.  
  47. }
  48.  
  49. /**
  50.      * 第一个功能：如果当前封面类型为自动，则设置封面类型的数据
  51.      * 匹配规则：
  52.      * 1，如果内容图片大于等于1，小于3  单图  type 1
  53.      * 2，如果内容图片大于等于3  多图  type 3
  54.      * 3，如果内容没有图片，无图  type 0
  55.      *
  56.      * 第二个功能：保存封面图片与素材的关系
  57.      * @param dto
  58.      * @param wmNews
  59.      * @param materials
  60.      */
  61. private void saveRelativeInfoForCover(WmNewsDto dto, WmNews wmNews, List<String> materials) {
  62.  
  63.     List<String> images = dto.getImages();
  64.  
  65.     //如果当前封面类型为自动，则设置封面类型的数据
  66.     if(dto.getType().equals(WemediaConstants.WM_NEWS_TYPE_AUTO)){
  67.         //多图
  68.         if(materials.size() >= 3){
  69.             wmNews.setType(WemediaConstants.WM_NEWS_MANY_IMAGE);
  70.             images = materials.stream().limit(3).collect(Collectors.toList());
  71.         }else if(materials.size() >= 1 && materials.size() < 3){
  72.             //单图
  73.             wmNews.setType(WemediaConstants.WM_NEWS_SINGLE_IMAGE);
  74.             images = materials.stream().limit(1).collect(Collectors.toList());
  75.         }else {
  76.             //无图
  77.             wmNews.setType(WemediaConstants.WM_NEWS_NONE_IMAGE);
  78.         }
  79.  
  80.         //修改文章
  81.         if(images != null && images.size() > 0){
  82.             wmNews.setImages(StringUtils.join(images,","));
  83.         }
  84.         updateById(wmNews);
  85.     }
  86.     if(images != null && images.size() > 0){
  87.         saveRelativeInfo(images,wmNews.getId(),WemediaConstants.WM_COVER_REFERENCE);
  88.     }
  89.  
  90. }
  91.  
  92.  
  93. /**
  94.      * 处理文章内容图片与素材的关系
  95.      * @param materials
  96.      * @param newsId
  97.      */
  98. private void saveRelativeInfoForContent(List<String> materials, Integer newsId) {
  99.     saveRelativeInfo(materials,newsId,WemediaConstants.WM_CONTENT_REFERENCE);
  100. }
  101.  
  102. @Autowired
  103. private WmMaterialMapper wmMaterialMapper;
  104.  
  105. /**
  106.      * 保存文章图片与素材的关系到数据库中
  107.      * @param materials
  108.      * @param newsId
  109.      * @param type
  110.      */
  111. private void saveRelativeInfo(List<String> materials, Integer newsId, Short type) {
  112.     if(materials!=null && !materials.isEmpty()){
  113.         //通过图片的url查询素材的id
  114.         List<WmMaterial> dbMaterials = wmMaterialMapper.selectList(Wrappers.<WmMaterial>lambdaQuery().in(WmMaterial::getUrl, materials));
  115.  
  116.         //判断素材是否有效
  117.         if(dbMaterials==null || dbMaterials.size() == 0){
  118.             //手动抛出异常   第一个功能：能够提示调用者素材失效了，第二个功能，进行数据的回滚
  119.             throw new CustomException(AppHttpCodeEnum.MATERIASL_REFERENCE_FAIL);
  120.         }
  121.  
  122.         if(materials.size() != dbMaterials.size()){
  123.             throw new CustomException(AppHttpCodeEnum.MATERIASL_REFERENCE_FAIL);
  124.         }
  125.  
  126.         List<Integer> idList = dbMaterials.stream().map(WmMaterial::getId).collect(Collectors.toList());
  127.  
  128.         //批量保存
  129.         wmNewsMaterialMapper.saveRelations(idList,newsId,type);
  130.     }
  131.  
  132. }
  133.  
  134.  
  135. /**
  136.      * 提取文章内容中的图片信息
  137.      * @param content
  138.      * @return
  139.      */
  140. private List<String> ectractUrlInfo(String content) {
  141.     List<String> materials = new ArrayList<>();
  142.  
  143.     List<Map> maps = JSON.parseArray(content, Map.class);
  144.     for (Map map : maps) {
  145.         if(map.get("type").equals("image")){
  146.             String imgUrl = (String) map.get("value");
  147.             materials.add(imgUrl);
  148.         }
  149.     }
  150.  
  151.     return materials;
  152. }
  153.  
  154. @Autowired
  155. private WmNewsMaterialMapper wmNewsMaterialMapper;
  156.  
  157. /**
  158.      * 保存或修改文章
  159.      * @param wmNews
  160.      */
  161. private void saveOrUpdateWmNews(WmNews wmNews) {
  162.     //补全属性
  163.     wmNews.setUserId(WmThreadLocalUtil.getUser().getId());
  164.     wmNews.setCreatedTime(new Date());
  165.     wmNews.setSubmitedTime(new Date());
  166.     wmNews.setEnable((short)1);//默认上架
  167.  
  168.     if(wmNews.getId() == null){
  169.         //保存
  170.         save(wmNews);
  171.     }else {
  172.         //修改
  173.         //删除文章图片与素材的关系
  174.         wmNewsMaterialMapper.delete(Wrappers.<WmNewsMaterial>lambdaQuery().eq(WmNewsMaterial::getNewsId,wmNews.getId()));
  175.         updateById(wmNews);
  176.     }
  177.  
  178. }

本文内容由网友自发贡献，转载请注明出处：【wpsshop博客】
推荐阅读
相关标签

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

  

闽ICP备14008679号