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

黑马头条day08实战_黑马头条day8平台管理

作者：Guff_9hys | 2024-08-16 11:33:12

赞

踩

黑马头条day8平台管理

目录

一、平台管理前端

1.nginx配置

 二、登录及网关

1.网关

1.1 nacos配置

1.2 bootstrap.yaml

1.3 登录拦截认证

1.4 AppJwtUtil

1.5启动类

2.登录

1.1 nacos配置

1.2 WebMvcConfig

1.3 mvc拦截器 AdTokenInterceptor

1.4 controller 接口

1.5 service实现类 

3. 测试

三、敏感词

1.1 在model模块中创建实体类

1.2 controller接口

1.3 service接口

1.4 service实现类

1.5 测试

四、频道管理

1.1 实体类创建

1.2 controller接口

1.3 service接口

1.4 service实现类

1.5 测试

一、平台管理前端

1.nginx配置

在nginx的配置文件下新增 heima-leadnews-admin.conf 文件，注意将admin-web文件夹的地址修改为自己的。

  1. upstream  heima-admin-gateway{
  2.     server localhost:51603;
  3. }
  4.  
  5. server {
  6. 	listen 8803;
  7. 	location / {
  8. 		root E:/FrameworkRevise/heima-leadnews/admin-web/;
  9. 		index index.html;
  10. 	}
  11. 	
  12. 	location ~/service_6001/(.*) {
  13. 		proxy_pass http://heima-admin-gateway/$1;
  14. 		proxy_set_header HOST $host;  # 不改变源请求头的值
  15. 		proxy_pass_request_body on;  #开启获取请求体
  16. 		proxy_pass_request_headers on;  #开启获取请求头
  17. 		proxy_set_header X-Real-IP $remote_addr;   # 记录真实发出请求的客户端IP
  18. 		proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;  #记录代理信息
  19. 	}
  20. }

配置完成之后可以启动nginx访问localhost:8803试一下，友情提醒，老师给的说明文档中的界面截图跟他给的资料中前端的是不一样的。能访问到这个界面就可以。

 二、登录及网关

1.网关

创建heima-leadnews-admin模块,目录结构如下

1.1 nacos配置

在nacos中新增配置 leadnews-admin-gateway

  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: admin
  16.           uri: lb://leadnews-admin
  17.           predicates:
  18.             - Path=/admin/**
  19.           filters:
  20.             - StripPrefix= 1
  21.         # 自媒体端
  22.         - id: wemedia
  23.           uri: lb://leadnews-wemedia
  24.           predicates:
  25.             - Path=/wemedia/**
  26.           filters:
  27.             - StripPrefix= 1
  28.         # 用户端
  29.         - id: user
  30.           uri: lb://leadnews-user
  31.           predicates:
  32.             - Path=/user/**
  33.           filters:
  34.             - StripPrefix= 1
1.2 bootstrap.yaml
  1. server:
  2.   port: 51603
  3. spring:
  4.   application:
  5.     name: leadnews-admin-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
1.3 登录拦截认证

AuthorizeFilter.java

  1. package com.heima.admin.gateway.filter;
  2.  
  3. import com.heima.admin.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.  
  26.         //2.判断是否是登录
  27.         if(request.getURI().getPath().contains("/login")){
  28.             //放行
  29.             return chain.filter(exchange);
  30.         }
  31.  
  32.         //3.获取token
  33.         String token = request.getHeaders().getFirst("token");
  34.  
  35.         //4.判断token是否存在
  36.         if(StringUtils.isBlank(token)){
  37.             response.setStatusCode(HttpStatus.UNAUTHORIZED);
  38.             return response.setComplete();
  39.         }
  40.  
  41.         //5.判断token是否有效
  42.         try {
  43.             Claims claimsBody = AppJwtUtil.getClaimsBody(token);
  44.             //是否是过期
  45.             int result = AppJwtUtil.verifyToken(claimsBody);
  46.             if(result == 1 || result  == 2){
  47.                 response.setStatusCode(HttpStatus.UNAUTHORIZED);
  48.                 return response.setComplete();
  49.             }
  50.             //获取用户信息
  51.             Object userId = claimsBody.get("id");
  52.             //存入hadder
  53.             ServerHttpRequest serverHttpRequest = request.mutate().headers(httpHeaders -> {
  54.                 httpHeaders.add("userId", userId + "");
  55.             }).build();
  56.             //重置请求
  57.             exchange.mutate().request(serverHttpRequest);
  58.  
  59.         } catch (Exception e) {
  60.             e.printStackTrace();
  61.         }
  62.  
  63.         //6.放行
  64.         return chain.filter(exchange);
  65.     }
  66.  
  67.     /**
  68.      * 优先级设置  值越小  优先级越高
  69.      * @return
  70.      */
  71.     @Override
  72.     public int getOrder() {
  73.         return 0;
  74.     }
  75. }
1.4 AppJwtUtil

AppJwtUtil.java

  1. package com.heima.admin.gateway.util;
  2.  
  3. import io.jsonwebtoken.*;
  4.  
  5. import javax.crypto.SecretKey;
  6. import javax.crypto.spec.SecretKeySpec;
  7. import java.util.*;
  8.  
  9. public class AppJwtUtil {
  10.  
  11.     // TOKEN的有效期一天（S）
  12.     private static final int TOKEN_TIME_OUT = 3_600;
  13.     // 加密KEY
  14.     private static final String TOKEN_ENCRY_KEY = "MDk4ZjZiY2Q0NjIxZDM3M2NhZGU0ZTgzMjYyN2I0ZjY";
  15.     // 最小刷新间隔(S)
  16.     private static final int REFRESH_TIME = 300;
  17.  
  18.     // 生产ID
  19.     public static String getToken(Long id){
  20.         Map<String, Object> claimMaps = new HashMap<>();
  21.         claimMaps.put("id",id);
  22.         long currentTime = System.currentTimeMillis();
  23.         return Jwts.builder()
  24.                 .setId(UUID.randomUUID().toString())
  25.                 .setIssuedAt(new Date(currentTime))  //签发时间
  26.                 .setSubject("system")  //说明
  27.                 .setIssuer("heima") //签发者信息
  28.                 .setAudience("app")  //接收用户
  29.                 .compressWith(CompressionCodecs.GZIP)  //数据压缩方式
  30.                 .signWith(SignatureAlgorithm.HS512, generalKey()) //加密方式
  31.                 .setExpiration(new Date(currentTime + TOKEN_TIME_OUT * 1000))  //过期时间戳
  32.                 .addClaims(claimMaps) //cla信息
  33.                 .compact();
  34.     }
  35.  
  36.     /**
  37.      * 获取token中的claims信息
  38.      *
  39.      * @param token
  40.      * @return
  41.      */
  42.     private static Jws<Claims> getJws(String token) {
  43.             return Jwts.parser()
  44.                     .setSigningKey(generalKey())
  45.                     .parseClaimsJws(token);
  46.     }
  47.  
  48.     /**
  49.      * 获取payload body信息
  50.      *
  51.      * @param token
  52.      * @return
  53.      */
  54.     public static Claims getClaimsBody(String token) {
  55.         try {
  56.             return getJws(token).getBody();
  57.         }catch (ExpiredJwtException e){
  58.             return null;
  59.         }
  60.     }
  61.  
  62.     /**
  63.      * 获取hearder body信息
  64.      *
  65.      * @param token
  66.      * @return
  67.      */
  68.     public static JwsHeader getHeaderBody(String token) {
  69.         return getJws(token).getHeader();
  70.     }
  71.  
  72.     /**
  73.      * 是否过期
  74.      *
  75.      * @param claims
  76.      * @return -1：有效，0：有效，1：过期，2：过期
  77.      */
  78.     public static int verifyToken(Claims claims) {
  79.         if(claims==null){
  80.             return 1;
  81.         }
  82.         try {
  83.             claims.getExpiration()
  84.                     .before(new Date());
  85.             // 需要自动刷新TOKEN
  86.             if((claims.getExpiration().getTime()-System.currentTimeMillis())>REFRESH_TIME*1000){
  87.                 return -1;
  88.             }else {
  89.                 return 0;
  90.             }
  91.         } catch (ExpiredJwtException ex) {
  92.             return 1;
  93.         }catch (Exception e){
  94.             return 2;
  95.         }
  96.     }
  97.  
  98.     /**
  99.      * 由字符串生成加密key
  100.      *
  101.      * @return
  102.      */
  103.     public static SecretKey generalKey() {
  104.         byte[] encodedKey = Base64.getEncoder().encode(TOKEN_ENCRY_KEY.getBytes());
  105.         SecretKey key = new SecretKeySpec(encodedKey, 0, encodedKey.length, "AES");
  106.         return key;
  107.     }
  108.  
  109.     public static void main(String[] args) {
  110.        /* Map map = new HashMap();
  111.         map.put("id","11");*/
  112.         System.out.println(AppJwtUtil.getToken(1102L));
  113.         Jws<Claims> jws = AppJwtUtil.getJws("eyJhbGciOiJIUzUxMiIsInppcCI6IkdaSVAifQ.H4sIAAAAAAAAADWLQQqEMAwA_5KzhURNt_qb1KZYQSi0wi6Lf9942NsMw3zh6AVW2DYmDGl2WabkZgreCaM6VXzhFBfJMcMARTqsxIG9Z888QLui3e3Tup5Pb81013KKmVzJTGo11nf9n8v4nMUaEY73DzTabjmDAAAA.4SuqQ42IGqCgBai6qd4RaVpVxTlZIWC826QA9kLvt9d-yVUw82gU47HDaSfOzgAcloZedYNNpUcd18Ne8vvjQA");
  114.         Claims claims = jws.getBody();
  115.         System.out.println(claims.get("id"));
  116.  
  117.     }
  118.  
  119. }
1.5启动类
  1. package com.heima.admin.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. /**
  8.  * @author Z-熙玉
  9.  * @version 1.0
  10.  */
  11. @SpringBootApplication
  12. @EnableDiscoveryClient
  13. public class AdminGatewayApplication {
  14.  
  15.     public static void main(String[] args) {
  16.         SpringApplication.run(AdminGatewayApplication.class, args);
  17.     }
  18. }

2.登录

创建heima-leadnews-admin模块,（之后的bootstrap配置都大致一样，就都省略了，参考之前的稍微改一下即可）导入资料中admin的sql文件。目录结构如下

1.1 nacos配置

新增nacos heima-leadnews-admin配置

  1. spring:
  2.   redis:
  3.     host: 192.168.200.130
  4.     password: leadnews
  5.     port: 6379
  6.   kafka:
  7.     bootstrap-servers: 192.168.200.130:9092
  8.     producer:
  9.       retries: 10
  10.       key-serializer: org.apache.kafka.common.serialization.StringSerializer
  11.       value-serializer: org.apache.kafka.common.serialization.StringSerializer
  12.   datasource:
  13.     driver-class-name: com.mysql.jdbc.Driver
  14.     url: jdbc:mysql://192.168.200.130:3306/leadnews_admin?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC&useSSL=false
  15.     username: root
  16.     password: root
  17. # 设置Mapper接口所对应的XML文件位置，如果你在Mapper接口中有自定义方法，需要进行该配置
  18. mybatis-plus:
  19.   mapper-locations: classpath*:mapper/*.xml
  20.   # 设置别名包扫描路径，通过该属性可以给包中的类注册别名
  21.   type-aliases-package: com.heima.model.admin.pojos
  23. minio:
  24.   accessKey: minio
  25.   secretKey: minio123
  26.   bucket: leadnews
  27.   endpoint: http://192.168.200.130:9000
  28.   readPath: http://192.168.200.130:9000
  30. feign:
  31.   # 开启feign对hystrix熔断降级的支持
  32.   hystrix:
  33.     enabled: true
  34.   # 修改调用超时时间
  35.   client:
  36.     config:
  37.       default:
  38.         connectTimeout: 5000
  39.         readTimeout: 5000
1.2 WebMvcConfig
  1. package com.heima.admin.config;
  2.  
  3. import com.heima.admin.interceptor.AdTokenInterceptor;
  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. /**
  9.  * @author Z-熙玉
  10.  * @version 1.0
  11.  */
  12. @Configuration
  13. public class WebMvcConfig implements WebMvcConfigurer {
  14.  
  15.     @Override
  16.     public void addInterceptors(InterceptorRegistry registry) {
  17.         registry.addInterceptor(new AdTokenInterceptor())
  18.                 .addPathPatterns("/**");
  19.     }
  20. }
1.3 mvc拦截器 AdTokenInterceptor
  1. package com.heima.admin.interceptor;
  2.  
  3. import com.heima.model.admin.pojos.AdUser;
  4. import com.heima.model.wemedia.pojos.WmUser;
  5. import com.heima.utils.thread.AdThreadLocalUtil;
  6. import com.heima.utils.thread.WmThreadLocalUtil;
  7. import lombok.extern.slf4j.Slf4j;
  8. import org.springframework.web.servlet.HandlerInterceptor;
  9. import org.springframework.web.servlet.ModelAndView;
  10.  
  11. import javax.servlet.http.HttpServletRequest;
  12. import javax.servlet.http.HttpServletResponse;
  13.  
  14. /**
  15.  * @author Z-熙玉
  16.  * @version 1.0
  17.  */
  18. @Slf4j
  19. public class AdTokenInterceptor implements HandlerInterceptor {
  20.  
  21.     /**
  22.      * 得到用户信息并且存入当前线程中
  23.      * @param request
  24.      * @param response
  25.      * @param handler
  26.      * @return
  27.      * @throws Exception
  28.      */
  29.     @Override
  30.     public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
  31.         String userId = request.getHeader("userId");
  32.         if (userId != null) {
  33.             //存入到当前线程中
  34.             AdUser adUser = new AdUser();
  35.             adUser.setId(Integer.valueOf(userId));
  36.             AdThreadLocalUtil.setUser(adUser);
  37.             log.info("AdTokenInterceptor.存入AdThreadLocalUtil成功,adUserId={}",adUser.getId());
  38.         }
  39.         return true;
  40.     }
  41.  
  42.     /**
  43.      * 清理线程中的数据
  44.      * @param request
  45.      * @param response
  46.      * @param handler
  47.      * @param modelAndView
  48.      * @throws Exception
  49.      */
  50.     @Override
  51.     public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) throws Exception {
  52.         //AdThreadLocalUtil.clear();
  53.     }
  54.  
  55.     /**
  56.      * @param request
  57.      * @param response
  58.      * @param handler
  59.      * @param ex
  60.      * @throws Exception
  61.      */
  62.     @Override
  63.     public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
  64.         AdThreadLocalUtil.clear();;
  65.     }
  66. }
1.4 controller 接口
  1. package com.heima.admin.controller.v1;
  2.  
  3. import com.heima.admin.service.AdminUserService;
  4. import com.heima.model.admin.dtos.AdUserDto;
  5. import com.heima.model.common.dtos.ResponseResult;
  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. /**
  13.  * @author Z-熙玉
  14.  * @version 1.0
  15.  */
  16. @RestController
  17. @RequestMapping("/login")
  18. public class LoginController {
  19.  
  20.     @Autowired
  21.     private AdminUserService adminUserService;
  22.  
  23.     @PostMapping("/in")
  24.     public ResponseResult login(@RequestBody AdUserDto dto) {
  25.         return adminUserService.login(dto);
  26.     }
  27. }
1.5 service实现类 

AdminUserServiceImpl .java

  1. package com.heima.admin.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.toolkit.Wrappers;
  4. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  5. import com.heima.admin.mapper.AdminUserMapper;
  6. import com.heima.admin.service.AdminUserService;
  7. import com.heima.model.admin.dtos.AdUserDto;
  8. import com.heima.model.admin.pojos.AdUser;
  9. import com.heima.model.common.dtos.ResponseResult;
  10. import com.heima.model.common.enums.AppHttpCodeEnum;
  11. import com.heima.utils.common.AppJwtUtil;
  12. import lombok.extern.slf4j.Slf4j;
  13. import org.apache.commons.lang3.StringUtils;
  14. import org.springframework.stereotype.Service;
  15. import org.springframework.util.DigestUtils;
  16.  
  17. import java.util.HashMap;
  18. import java.util.Map;
  19.  
  20. /**
  21.  * @author Z-熙玉
  22.  * @version 1.0
  23.  */
  24. @Service
  25. @Slf4j
  26. public class AdminUserServiceImpl extends ServiceImpl<AdminUserMapper, AdUser> implements AdminUserService {
  27.  
  28.     /**
  29.      * 管理端用户登录
  30.      * @param dto
  31.      * @return
  32.      */
  33.     @Override
  34.     public ResponseResult login(AdUserDto dto) {
  35.         //检查参数
  36.         if (StringUtils.isBlank(dto.getName()) || StringUtils.isBlank(dto.getPassword())) {
  37.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID,"用户名或密码为空");
  38.         }
  39.  
  40.         //查询用户
  41.         AdUser user = getOne(Wrappers.<AdUser>lambdaQuery().eq(AdUser::getName, dto.getName()));
  42.         if (user == null) {
  43.             return ResponseResult.errorResult(AppHttpCodeEnum.DATA_NOT_EXIST, "用户名不存在");
  44.         }
  45.  
  46.         //对比密码
  47.         String salt = user.getSalt();
  48.         String pswd = dto.getPassword();
  49.         pswd = DigestUtils.md5DigestAsHex((pswd + salt).getBytes());
  50.         if (pswd.equals(user.getPassword())) {
  51.             //返回数据 jwt
  52.             Map<String,Object> map = new HashMap<>();
  53.             map.put("token", AppJwtUtil.getToken(user.getId().longValue()));
  54.             user.setSalt("");
  55.             user.setPassword("");
  56.             map.put("user",user);
  57.             return ResponseResult.okResult(map);
  58.         } else {
  59.             return ResponseResult.errorResult(AppHttpCodeEnum.LOGIN_PASSWORD_ERROR);
  60.         }
  61.     }
  62. }

3. 测试

启动heima-leadnews-admin-gateway和heima-leadnews-admin进行登录测试，可以正常登录

三、敏感词

前置说明：敏感词功能在自媒体模块中进行完善，因为前端发送的请求是以wemedia为前缀的，所以会被网关路由到自媒体模块，我也不晓得为什么这么设计，不改前端的话只能这么做了。

1.1 在model模块中创建实体类

sensitiveDto.java

  1. package com.heima.model.admin.dtos;
  2.  
  3. import com.heima.model.common.dtos.PageRequestDto;
  4. import lombok.Data;
  5.  
  6. /**
  7.  * @author Z-熙玉
  8.  * @version 1.0
  9.  */
  10. @Data
  11. public class SensitiveDto extends PageRequestDto {
  12.     private String name;
  13. }

WmSensitive.java

  1. package com.heima.model.wemedia.pojos;
  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 lombok.Data;
  8.  
  9. import java.io.Serializable;
  10. import java.util.Date;
  11.  
  12. /**
  13.  * <p>
  14.  * 敏感词信息表
  15.  * </p>
  16.  *
  17.  * @author itheima
  18.  */
  19. @Data
  20. @TableName("wm_sensitive")
  21. public class WmSensitive implements Serializable {
  22.  
  23.     private static final long serialVersionUID = 1L;
  24.  
  25.     /**
  26.      * 主键
  27.      */
  28.     @TableId(value = "id", type = IdType.AUTO)
  29.     private Integer id;
  30.  
  31.     /**
  32.      * 敏感词
  33.      */
  34.     @TableField("sensitives")
  35.     private String sensitives;
  36.  
  37.     /**
  38.      * 创建时间
  39.      */
  40.     @TableField("created_time")
  41.     private Date createdTime;
  42.  
  43. }
1.2 controller接口

WmSensitiveController.java

  1. package com.heima.wemedia.controller.v1;
  2.  
  3. import com.heima.model.admin.dtos.SensitiveDto;
  4. import com.heima.model.admin.pojos.AdSensitive;
  5. import com.heima.model.common.dtos.ResponseResult;
  6. import com.heima.wemedia.service.WmSensitiveService;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.web.bind.annotation.*;
  9.  
  10. /**
  11.  * @author Z-熙玉
  12.  * @version 1.0
  13.  */
  14. @RestController
  15. @RequestMapping("/api/v1/sensitive")
  16. public class WmSensitiveController {
  17.  
  18.     @Autowired
  19.     private WmSensitiveService wmSensitiveService;
  20.  
  21.     @PostMapping("/list")
  22.     public ResponseResult list(@RequestBody SensitiveDto dto) {
  23.         return wmSensitiveService.findList(dto);
  24.     }
  25.  
  26.     @DeleteMapping("/del/{id}")
  27.     public ResponseResult del(@PathVariable("id") Integer id) {
  28.         return wmSensitiveService.delSensitive(id);
  29.     }
  30.  
  31.     @PostMapping("/save")
  32.     public ResponseResult save(@RequestBody AdSensitive adSensitive) {
  33.         return wmSensitiveService.saveSensitive(adSensitive);
  34.     }
  35.  
  36.     @PostMapping("/update")
  37.     public ResponseResult update(@RequestBody AdSensitive adSensitive) {
  38.         return wmSensitiveService.updateSensitive(adSensitive);
  39.     }
  40. }
1.3 service接口

WmSensitiveService.java

  1. package com.heima.wemedia.service;
  2.  
  3. import com.baomidou.mybatisplus.extension.service.IService;
  4. import com.heima.model.admin.dtos.SensitiveDto;
  5. import com.heima.model.admin.pojos.AdSensitive;
  6. import com.heima.model.common.dtos.ResponseResult;
  7. import com.heima.model.wemedia.pojos.WmSensitive;
  8.  
  9. /**
  10.  * @author Z-熙玉
  11.  * @version 1.0
  12.  */
  13. public interface WmSensitiveService extends IService<WmSensitive> {
  14.  
  15.     /**
  16.      * 敏感词列表
  17.      * @param dto
  18.      * @return
  19.      */
  20.     ResponseResult findList(SensitiveDto dto);
  21.  
  22.     /**
  23.      * 根据id删除敏感词信息
  24.      * @param id
  25.      * @return
  26.      */
  27.     ResponseResult delSensitive(Integer id);
  28.  
  29.     /**
  30.      * 保存敏感词
  31.      * @param adSensitive
  32.      * @return
  33.      */
  34.     ResponseResult saveSensitive(AdSensitive adSensitive);
  35.  
  36.     /**
  37.      * 更新敏感词信息
  38.      * @param adSensitive
  39.      * @return
  40.      */
  41.     ResponseResult updateSensitive(AdSensitive adSensitive);
  42. }
1.4 service实现类

WmSensitiveServiceImpl.java

  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.core.toolkit.Wrappers;
  6. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  7. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  8. import com.heima.model.admin.dtos.SensitiveDto;
  9. import com.heima.model.admin.pojos.AdSensitive;
  10. import com.heima.model.common.dtos.PageResponseResult;
  11. import com.heima.model.common.dtos.ResponseResult;
  12. import com.heima.model.common.enums.AppHttpCodeEnum;
  13. import com.heima.model.wemedia.pojos.WmChannel;
  14. import com.heima.model.wemedia.pojos.WmSensitive;
  15. import com.heima.wemedia.mapper.WmSensitiveMapper;
  16. import com.heima.wemedia.service.WmSensitiveService;
  17. import lombok.extern.slf4j.Slf4j;
  18. import org.apache.commons.lang3.StringUtils;
  19. import org.springframework.beans.BeanUtils;
  20. import org.springframework.stereotype.Service;
  21.  
  22. import java.util.Date;
  23.  
  24. /**
  25.  * @author Z-熙玉
  26.  * @version 1.0
  27.  */
  28. @Service
  29. @Slf4j
  30. public class WmSensitiveServiceImpl extends ServiceImpl<WmSensitiveMapper, WmSensitive> implements WmSensitiveService {
  31.  
  32.  
  33.     /**
  34.      * 敏感词分页条件查询
  35.      * @param dto
  36.      * @return
  37.      */
  38.     @Override
  39.     public ResponseResult findList(SensitiveDto dto) {
  40.         //检查参数
  41.         dto.checkParam();
  42.  
  43.         //分页查询
  44.         IPage page = new Page(dto.getPage(), dto.getSize());
  45.         LambdaQueryWrapper<WmSensitive> queryWrapper = new LambdaQueryWrapper<>();
  46.  
  47.         //按照创建时间倒序查询
  48.         queryWrapper.orderByDesc(WmSensitive::getCreatedTime);
  49.  
  50.         //按照敏感词模糊查询
  51.         if (StringUtils.isNotBlank(dto.getName())) {
  52.             queryWrapper.like(WmSensitive::getSensitives, dto.getName());
  53.         }
  54.  
  55.         page = page(page, queryWrapper);
  56.  
  57.         //返回结果
  58.         ResponseResult responseResult = new PageResponseResult(dto.getPage(), dto.getSize(), (int) page.getTotal());
  59.         responseResult.setData(page.getRecords());
  60.         return responseResult;
  61.     }
  62.  
  63.     /**
  64.      * 根据id删除敏感词信息
  65.      * @param id
  66.      * @return
  67.      */
  68.     @Override
  69.     public ResponseResult delSensitive(Integer id) {
  70.  
  71.         //校验参数
  72.         if (id == null) {
  73.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_REQUIRE);
  74.         }
  75.  
  76.         //查询数据是否存在
  77.         WmSensitive wmSensitive = getById(id);
  78.         if (wmSensitive == null) {
  79.             return ResponseResult.errorResult(AppHttpCodeEnum.DATA_NOT_EXIST);
  80.         }
  81.  
  82.         //根据id删除
  83.         removeById(id);
  84.         return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
  85.     }
  86.  
  87.     /**
  88.      * 保存敏感词
  89.      * @param adSensitive
  90.      * @return
  91.      */
  92.     @Override
  93.     public ResponseResult saveSensitive(AdSensitive adSensitive) {
  94.  
  95.         //参数校验
  96.         if (adSensitive == null) {
  97.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
  98.         }
  99.  
  100.         //属性拷贝
  101.         WmSensitive wmSensitive = new WmSensitive();
  102.         BeanUtils.copyProperties(adSensitive, wmSensitive);
  103.  
  104.         //判断敏感词是否已经存在
  105.         WmSensitive sensitive = getOne(Wrappers.<WmSensitive>lambdaQuery()
  106.                 .eq(WmSensitive::getSensitives, adSensitive.getSensitives()));
  107.         if (sensitive != null) {
  108.             return ResponseResult.errorResult(AppHttpCodeEnum.DATA_EXIST);
  109.         }
  110.  
  111.         wmSensitive.setCreatedTime(new Date());
  112.         save(wmSensitive);
  113.         return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
  114.     }
  115.  
  116.     /**
  117.      * 更新敏感词信息
  118.      * @param adSensitive
  119.      * @return
  120.      */
  121.     @Override
  122.     public ResponseResult updateSensitive(AdSensitive adSensitive) {
  123.  
  124.         //校验参数
  125.         if (adSensitive == null) {
  126.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
  127.         }
  128.  
  129.         //属性拷贝
  130.         WmSensitive wmSensitive = new WmSensitive();
  131.         BeanUtils.copyProperties(adSensitive, wmSensitive);
  132.  
  133.         //修改信息
  134.         updateById(wmSensitive);
  135.         return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
  136.     }
  137. }
1.5 测试

启动admin和wemedia以及他们的网关，以及schedule模块进行测试。

四、频道管理

这部分还是在自媒体模块当中完成。提醒：在频道分页查询中，在接口文档中所示，channelDto并没有status参数，也就是不能根据状态进行精确查询，小伙伴们可以自己在channelDto中加上status属性，试一下可不可以根据状态进行精确查询

1.1 实体类创建

channelDto

  1. package com.heima.model.admin.dtos;
  2.  
  3. import com.heima.model.common.dtos.PageRequestDto;
  4. import lombok.Data;
  5.  
  6. /**
  7.  * @author Z-熙玉
  8.  * @version 1.0
  9.  */
  10. @Data
  11. public class ChannelDto extends PageRequestDto {
  12.  
  13.     /**
  14.      * 频道名称
  15.      */
  16.     private String name;
  17. }

AdChannel

  1. package com.heima.model.admin.pojos;
  2.  
  3. import com.heima.model.wemedia.pojos.WmChannel;
  4.  
  5. /**
  6.  * @author Z-熙玉
  7.  * @version 1.0
  8.  */
  9. public class AdChannel extends WmChannel {
  10. }
1.2 controller接口

WmChannelController

  1. package com.heima.wemedia.controller.v1;
  2.  
  3. import com.heima.model.admin.dtos.ChannelDto;
  4. import com.heima.model.admin.pojos.AdChannel;
  5. import com.heima.model.common.dtos.ResponseResult;
  6. import com.heima.wemedia.service.WmChannelService;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.web.bind.annotation.*;
  9.  
  10. /**
  11.  * @author Z-熙玉
  12.  * @version 1.0
  13.  */
  14. @RestController
  15. @RequestMapping("/api/v1/channel")
  16. public class WmChannelController {
  17.  
  18.     @Autowired
  19.     private WmChannelService wmChannelService;
  20.  
  21.     @GetMapping("/channels")
  22.     public ResponseResult findAll() {
  23.         return wmChannelService.findAll();
  24.     }
  25.  
  26.     @PostMapping("/list")
  27.     public ResponseResult list(@RequestBody ChannelDto dto) {
  28.         return wmChannelService.findList(dto);
  29.     }
  30.  
  31.     @PostMapping("/save")
  32.     public ResponseResult save(@RequestBody AdChannel adChannel) {
  33.         return wmChannelService.saveChannel(adChannel);
  34.     }
  35.  
  36.     @PostMapping("/update")
  37.     public ResponseResult update(@RequestBody AdChannel adChannel) {
  38.         return wmChannelService.updateChannel(adChannel);
  39.     }
  40.  
  41.     @GetMapping("/del/{id}")
  42.     public ResponseResult del(@PathVariable("id") Integer id) {
  43.         return wmChannelService.deleteChannel(id);
  44.     }
  45. }
1.3 service接口

WmChannelService

  1. package com.heima.wemedia.service;
  2.  
  3. import com.baomidou.mybatisplus.extension.service.IService;
  4. import com.heima.model.admin.dtos.ChannelDto;
  5. import com.heima.model.admin.pojos.AdChannel;
  6. import com.heima.model.common.dtos.ResponseResult;
  7. import com.heima.model.wemedia.pojos.WmChannel;
  8.  
  9. public interface WmChannelService extends IService<WmChannel> {
  10.  
  11.     /**
  12.      * 查询所有频道
  13.      * @return
  14.      */
  15.     ResponseResult findAll();
  16.  
  17.     /**
  18.      * 根据条件查询频道
  19.      * @param dto
  20.      * @return
  21.      */
  22.     ResponseResult findList(ChannelDto dto);
  23.  
  24.     /**
  25.      * 新增频道
  26.      * @param adChannel
  27.      * @return
  28.      */
  29.     ResponseResult saveChannel(AdChannel adChannel);
  30.  
  31.     /**
  32.      * 修改频道信息
  33.      * @param adChannel
  34.      * @return
  35.      */
  36.     ResponseResult updateChannel(AdChannel adChannel);
  37.  
  38.     /**
  39.      * 根据id删除频道信息
  40.      * @param id
  41.      * @return
  42.      */
  43.     ResponseResult deleteChannel(Integer id);
  44. }
1.4 service实现类

WmChannelServiceImpl

  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.core.toolkit.Wrappers;
  6. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  7. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  8. import com.heima.model.admin.dtos.ChannelDto;
  9. import com.heima.model.admin.pojos.AdChannel;
  10. import com.heima.model.common.dtos.PageResponseResult;
  11. import com.heima.model.common.dtos.ResponseResult;
  12. import com.heima.model.common.enums.AppHttpCodeEnum;
  13. import com.heima.model.wemedia.pojos.WmChannel;
  14. import com.heima.model.wemedia.pojos.WmNews;
  15. import com.heima.wemedia.mapper.WmChannelMapper;
  16. import com.heima.wemedia.mapper.WmNewsMapper;
  17. import com.heima.wemedia.service.WmChannelService;
  18. import lombok.extern.slf4j.Slf4j;
  19. import org.apache.commons.lang3.StringUtils;
  20. import org.springframework.beans.BeanUtils;
  21. import org.springframework.beans.factory.annotation.Autowired;
  22. import org.springframework.stereotype.Service;
  23. import org.springframework.transaction.annotation.Transactional;
  24.  
  25. import java.util.Date;
  26.  
  27. @Service
  28. @Transactional
  29. @Slf4j
  30. public class WmChannelServiceImpl extends ServiceImpl<WmChannelMapper, WmChannel> implements WmChannelService {
  31.  
  32.     /**
  33.      * 查询所有频道
  34.      * @return
  35.      */
  36.     @Override
  37.     public ResponseResult findAll() {
  38.         return ResponseResult.okResult(list());
  39.     }
  40.  
  41.     /**
  42.      * 频道条件分页查询
  43.      * @param dto
  44.      * @return
  45.      */
  46.     public ResponseResult findList(ChannelDto dto) {
  47.  
  48.         //检查参数
  49.         dto.checkParam();
  50.  
  51.         //分页条件查询
  52.         IPage page = new Page(dto.getPage(),dto.getSize());
  53.         LambdaQueryWrapper<WmChannel> queryWrapper = new LambdaQueryWrapper<>();
  54.  
  55.         //按照时间倒序查询
  56.         queryWrapper.orderByDesc(WmChannel::getCreatedTime);
  57.         //根据名称模糊查询
  58.         if (StringUtils.isNotBlank(dto.getName())) {
  59.             queryWrapper.like(WmChannel::getName, dto.getName());
  60.         }
  61.         // TODO 根据状态精确查询
  62.  
  63.         //根据默认排序进行排序
  64.         queryWrapper.orderByAsc(WmChannel::getOrd);
  65.  
  66.         page = page(page, queryWrapper);
  67.         //返回结果
  68.         ResponseResult responseResult = new PageResponseResult(dto.getPage(), dto.getSize(), (int) page.getTotal());
  69.         responseResult.setData(page.getRecords());
  70.         return responseResult;
  71.     }
  72.  
  73.     /**
  74.      * 新增频道
  75.      * @param adChannel
  76.      * @return
  77.      */
  78.     @Override
  79.     public ResponseResult saveChannel(AdChannel adChannel) {
  80.         //属性拷贝
  81.         WmChannel wmChannel = new WmChannel();
  82.         BeanUtils.copyProperties(adChannel, wmChannel);
  83.  
  84.         //判断名称是否重复
  85.         LambdaQueryWrapper<WmChannel> queryWrapper = new LambdaQueryWrapper<>();
  86.         queryWrapper.eq(WmChannel::getName, wmChannel.getName());
  87.         int count = count(queryWrapper);
  88.         if (count > 0) {
  89.             return ResponseResult.errorResult(AppHttpCodeEnum.DATA_EXIST,"频道名称已存在");
  90.         }
  91.  
  92.         //设置默认属性值
  93.         wmChannel.setOrd(1);
  94.         wmChannel.setCreatedTime(new Date());
  95.         wmChannel.setIsDefault(true);
  96.  
  97.         //保存数据
  98.         save(wmChannel);
  99.         return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS.getCode(),"新增频道成功");
  100.     }
  101.  
  102.     @Autowired
  103.     private WmNewsMapper wmNewsMapper;
  104.  
  105.     /**
  106.      * 修改频道信息
  107.      * @param adChannel
  108.      * @return
  109.      */
  110.     @Override
  111.     public ResponseResult updateChannel(AdChannel adChannel) {
  112.         //属性拷贝
  113.         WmChannel wmChannel = new WmChannel();
  114.         BeanUtils.copyProperties(adChannel, wmChannel);
  115.  
  116.         //判断当前频道是否被引用
  117.         Integer count = wmNewsMapper
  118.                 .selectCount(Wrappers.<WmNews>lambdaQuery().eq(WmNews::getChannelId, wmChannel.getId()));
  119.         if (count > 0) {
  120.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID,"该频道已被引用不能禁用");
  121.         }
  122.  
  123.         updateById(wmChannel);
  124.         return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
  125.     }
  126.  
  127.     /**
  128.      * 根据id删除频道信息
  129.      * @param id
  130.      * @return
  131.      */
  132.     @Override
  133.     public ResponseResult deleteChannel(Integer id) {
  134.         //校验参数
  135.         if (id == null) {
  136.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
  137.         }
  138.  
  139.         //判断是否被禁用
  140.         WmChannel wmChannel = getById(id);
  141.         if (wmChannel.getStatus()) {
  142.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID,"频道启用中无法删除");
  143.         }
  144.  
  145.         removeById(id);
  146.         return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
  147.     }
  148. }
1.5 测试

略

用户审核和自媒体文章审核明天更新哦，这两部分内容偏多，明天准时更新哦。有什么问题，可以在评论区留言。最后可以的话，点赞加关注支持一下吧~

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

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

  

闽ICP备14008679号