当前位置：首页 > news >正文

黑马头条平台管理实战

news 来源：原创 2025/5/10 5:09:45

黑马头条 08平台管理

1.开始准备和开发思路
- 1.1.开发网关
- 1.2编写admin-gateway 代码
2.开发登录微服务
- 2.1编写登录微服务
3.频道管理
4.敏感词管理
5.用户认证审核
6.自媒体文章人工审核
99. 最后开发中碰到的问题汇总
- 1.关于nacos 配置问题
- 2.在开发频道管理新增频道后端无法接收到前端请求
- 3.观察了两个方法
- 4.规范性 dto 和pojo类

程序源码会以压缩包形式放在这需要的可以取用
需求和接口文档
https://javazhang.lan删zn.com/ix除9CG2k4exxc

https://javazhang.la删nzn.com/iJau除e2k4eyid

1.开始准备和开发思路

（1）发现有登录请求都需要一个网关作为支撑，所以先解决网关问题

1.1.开发网关

待完成项

nacos 写一套配置
完成网关类编写

学习nacos 配置中学到了 CORS（跨域资源共享），它是一种安全机制，可以指定哪些外部来源（域、协议或端口）可以访问其资源，当一个网页尝试从不同于他的源（即域名、协议或端口号不同）加载资源，浏览器会检查是否允许这种跨域请求
初步nacos配置

spring:cloud:gateway:globalcors:cors-configurations:'[/**]': #匹配所有请求都处理ocrs跨域问题allowerdOrigins: "*"  #跨域处理哪些请求会被允许 allowedMethods:   #可以跨域请求的方法- GET- POST- PUT- DELETE

编写网关配置类
routes: 下的是每一个微服务，只有编写微服务才有对应的uri 等配置
网关类看懂后，参考完成的类复制粘贴即可
一共需要网关配一套 nacos 微服务也有一套nacos 网关中nacos 嵌套微服务的地址，达到转发的目的

1.2编写admin-gateway 代码

在这里插入图片描述
过滤器和工具类可以从wemedia 网关中拷贝一份
AuthorizeFilter 类

package com.heima.admin.gateway.filter;import com.heima.admin.gateway.util.AppJwtUtil;
import io.jsonwebtoken.*;
import org.apache.commons.lang.StringUtils;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.http.HttpStatus;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;import javax.crypto.SecretKey;
import javax.crypto.spec.SecretKeySpec;
import java.util.*;public class AuthorizeFilter implements Ordered, GlobalFilter {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {//1.获取request 和 response 对象ServerHttpRequest request = exchange.getRequest();ServerHttpResponse response = exchange.getResponse();//2.判断是否是登陆//uri 是完整路径   path 是从完整路径里取到路径if (request.getURI().getPath().contains("/login")){//放行return chain.filter(exchange);}//3.获取tokenString tocken = request.getHeaders().getFirst("token");//4.判断token是否岑在if (StringUtils.isBlank(tocken)){response.setStatusCode(HttpStatus.UNAUTHORIZED);return response.setComplete();}//5.判断token是否有效try {Claims claimsBody = AppJwtUtil.getClaimsBody(tocken);//判断是否过期int i = AppJwtUtil.verifyToken(claimsBody);if (i ==1 || i== 2){response.setStatusCode(HttpStatus.UNAUTHORIZED);return response.setComplete();}//获取用户信息存入hader中Object userId = claimsBody.get("id");ServerHttpRequest serverHttpRequest = request.mutate().headers(httpHeaders -> {httpHeaders.add("userId", userId + "");}).build();//重置请求exchange.mutate().request(serverHttpRequest);}catch (Exception e){e.printStackTrace();}//6.放行return chain.filter(exchange);}/*** 优先级设置 值越小 优先级越大* @return*/@Overridepublic int getOrder() {return 0;}}

AppJwtUtil 类

package com.heima.admin.gateway.util;import io.jsonwebtoken.*;import javax.crypto.SecretKey;
import javax.crypto.spec.SecretKeySpec;
import java.util.*;public class AppJwtUtil {//TOKEN的有效期一天private static final int TOKEN_TIME_OUT = 24 * 60 * 60;//加密KEYprivate static final String TOKEN_ENCRY_KEY="MDk4ZjZiY2Q0NjIxZDM3M2NhZGU0ZTgzMjYyN2I0ZjY";//最小刷新间隔Sprivate static final int REFRESH_TIME = 300;//生产IDpublic static String getToken(Long id){Map<String , Object> claimMaps = new HashMap<>();long currentTime = System.currentTimeMillis();claimMaps.put("id",id);return Jwts.builder().setId(UUID.randomUUID().toString()).setIssuedAt(new Date(currentTime)) //签发时间.setSubject("system").setAudience("app").compressWith(CompressionCodecs.GZIP).signWith(SignatureAlgorithm.HS512 , generalKey()).setExpiration(new Date(currentTime + TOKEN_TIME_OUT * 1000))//过期时间戳.addClaims(claimMaps).compact();}/*** 获取token中的claims信息** @param token* @return*/private static Jws<Claims> getJws(String token) {return Jwts.parser().setSigningKey(generalKey()).parseClaimsJws(token);}/*** 获取payload body信息** @param token* @return*/public static Claims getClaimsBody(String token) {try {return getJws(token).getBody();}catch (ExpiredJwtException e){return null;}}/*** 获取hearder body信息** @param token* @return*/public static JwsHeader getHeaderBody(String token) {return getJws(token).getHeader();}/*** 是否过期** @param claims* @return -1：有效，0：有效，1：过期，2：过期*/public static int verifyToken(Claims claims) {if(claims==null){return 1;}try {claims.getExpiration().before(new Date());// 需要自动刷新TOKENif((claims.getExpiration().getTime()-System.currentTimeMillis())>REFRESH_TIME*1000){return -1;}else {return 0;}} catch (ExpiredJwtException ex) {return 1;}catch (Exception e){return 2;}}/*** 由字符串生成加密key** @return*/public static SecretKey generalKey() {byte[] encodedKey = Base64.getEncoder().encode(TOKEN_ENCRY_KEY.getBytes());SecretKey key = new SecretKeySpec(encodedKey, 0, encodedKey.length, "AES");return key;}public static void main(String[] args) {/* Map map = new HashMap();map.put("id","11");*/System.out.println(AppJwtUtil.getToken(1102L));Jws<Claims> jws = AppJwtUtil.getJws("eyJhbGciOiJIUzUxMiIsInppcCI6IkdaSVAifQ.H4sIAAAAAAAAADWLQQqEMAwA_5KzhURNt_qb1KZYQSi0wi6Lf9942NsMw3zh6AVW2DYmDGl2WabkZgreCaM6VXzhFBfJMcMARTqsxIG9Z888QLui3e3Tup5Pb81013KKmVzJTGo11nf9n8v4nMUaEY73DzTabjmDAAAA.4SuqQ42IGqCgBai6qd4RaVpVxTlZIWC826QA9kLvt9d-yVUw82gU47HDaSfOzgAcloZedYNNpUcd18Ne8vvjQA");Claims claims = jws.getBody();System.out.println(claims.get("id"));}
}

主启动类 AdminWebGatewayAplication

package com.heima.admin.gateway;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;@SpringBootApplication
@EnableDiscoveryClient
public class AdminWebGatewayAplication {public static void main(String[] args) {SpringApplication.run(AdminWebGatewayAplication.class,args);}
}

配置文件

server:port: 6001
spring:application:name: leadnews-admin-web-gatewaycloud:nacos:discovery:server-addr: 192.168.200.130:8848config:server-addr: 192.168.200.130:8848file-extension: yml

Nacos 配置

spring:cloud:gateway:globalcors:add-to-simple-url-handler-mapping: truecorsConfigurations:'[/**]':allowedHeaders: "*"allowedOrigins: "*"allowedMethods:- GET- POST- DELETE- PUT- OPTION

2.开发登录微服务

别忘记按照要求导入pojo类
在这里插入图片描述

2.1编写登录微服务

创建对应模块
在这里插入图片描述

LoginController 代码

package com.heima.adminWeb.controller.v1;import com.heima.adminWeb.service.AwUserService;
import com.heima.model.admin.web.dto.AdminLoginDto;
import com.heima.model.common.dtos.ResponseResult;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
@RequestMapping("/login")
@Slf4j
public class LoginController {@Autowiredprivate AwUserService awUserService;@PostMapping("/in")public ResponseResult login(@RequestBody AdminLoginDto dto){log.info("dto{}",dto);return   awUserService.login(dto);}
}

AwUserMapper代码

package com.heima.adminWeb.mapper;import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.heima.model.admin.web.pojo.AdUser;
import org.apache.ibatis.annotations.Mapper;@Mapper
public interface AwUserMapper extends BaseMapper<AdUser> {
}

service 和 impl 实现类

package com.heima.adminWeb.service;import com.baomidou.mybatisplus.extension.service.IService;
import com.heima.model.admin.web.dto.AdminLoginDto;
import com.heima.model.admin.web.pojo.AdUser;
import com.heima.model.common.dtos.ResponseResult;public interface AwUserService extends IService<AdUser> {ResponseResult login( AdminLoginDto dto);
}

package com.heima.adminWeb.service.impl;import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.heima.adminWeb.mapper.AwUserMapper;
import com.heima.adminWeb.service.AwUserService;
import com.heima.model.admin.web.dto.AdminLoginDto;
import com.heima.model.admin.web.pojo.AdUser;
import com.heima.model.common.dtos.ResponseResult;import com.heima.model.common.enums.AppHttpCodeEnum;
import com.heima.utils.common.AppJwtUtil;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
import org.springframework.util.DigestUtils;import java.util.HashMap;@Service
public class AwUserServiceImpl  extends ServiceImpl<AwUserMapper , AdUser> implements AwUserService {/*** @param dto* @return*/@Overridepublic ResponseResult login(AdminLoginDto dto) {//1.检查参数if (StringUtils.isBlank(dto.getName()) || StringUtils.isBlank(dto.getPassword()) ){return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);}//检查用户是否存在AdUser adUser = getOne(Wrappers.<AdUser>lambdaQuery().eq(AdUser::getName, dto.getName()));if (adUser == null){return ResponseResult.errorResult(AppHttpCodeEnum.DATA_NOT_EXIST);}//验证密码String salt = adUser.getSalt();String password = dto.getPassword();String pswd = DigestUtils.md5DigestAsHex((password + salt).getBytes());if (pswd.equals(adUser.getPassword())){//返回数据jwtHashMap<String, Object> map = new HashMap<>();map.put("token" , AppJwtUtil.getToken(adUser.getId().longValue()));//删除密码和盐 保护隐私adUser.setSalt("");adUser.setPassword("");map.put("user" , adUser);return ResponseResult.okResult(map);}else{return ResponseResult.errorResult(AppHttpCodeEnum.LOGIN_PASSWORD_ERROR);}}
}

主启动类

package com.heima.adminWeb;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;@SpringBootApplication
@EnableDiscoveryClient
public class AdminWebApplication {public static void main(String[] args) {SpringApplication.run(AdminWebApplication.class , args);}
}

配置文件

server:port: 51809
spring:application:name: leadnews-admin-webcloud:nacos:discovery:server-addr: 192.168.200.130:8848config:server-addr: 192.168.200.130:8848file-extension: yml
logging:level:root: INFOorg.springframework.cloud.gateway: DEBUGorg.springframework.web: DEBUGcom.heima.adminWeb: DEBUGfile:name: ./logs/${spring.application.name}.logpattern:console: "%d{yyyy-MM-dd HH:mm:ss} %-5level %logger{36} - %msg%n"file: "%d{yyyy-MM-dd HH:mm:ss} %-5level [%thread] %logger{36} - %msg%n"

登录Nacos配置
复制粘贴别的配置文件即可注意数据库改操作数据库名称

spring:kafka:bootstrap-servers: 192.168.200.130:9092producer:retries: 10key-serializer: org.apache.kafka.common.serialization.StringSerializervalue-serializer: org.apache.kafka.common.serialization.StringSerializerdatasource:driver-class-name: com.mysql.jdbc.Driverurl: jdbc:mysql://localhost:3306/leadnews_admin?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTCusername: rootpassword: root
# 设置Mapper接口所对应的XML文件位置，如果你在Mapper接口中有自定义方法，需要进行该配置
mybatis-plus:mapper-locations: classpath*:mapper/*.xml# 设置别名包扫描路径，通过该属性可以给包中的类注册别名type-aliases-package: com.heima.model.media.pojosminio:accessKey: miniosecretKey: minio123bucket: leadnewsendpoint: http://192.168.200.130:9000readPath: http://192.168.200.130:9000
aliyun:accessKeyId: LTAI5tCWHCcfvqQzu8k2oKmXsecret: auoKUFsghimbfVQHpy7gtRyBkoR4vc#aliyun.scenes=porn,terrorism,ad,qrcode,live,logoscenes: terrorismfeign:# 开启feign对hystrix熔断降级的支持hystrix:enabled: true# 修改调用超时时间client:config:default:connectTimeout: 2000readTimeout: 2000

网关Nacos 自媒体微服务是下一节频道管理用到的

spring:cloud:gateway:globalcors:add-to-simple-url-handler-mapping: truecorsConfigurations:'[/**]':allowedHeaders: "*"allowedOrigins: "*"allowedMethods:- GET- POST- DELETE- PUT- OPTIONroutes:# 平台管理登录- id: adminloginuri: lb://leadnews-admin-webpredicates:- Path=/admin/**filters:- StripPrefix= 1#自媒体服务- id: leadnews-wemediauri: lb://leadnews-wemediapredicates:- Path=/wemedia/**filters:- StripPrefix= 1

3.频道管理

增删改查频道功能代码一起给出主要编写图中三个类
在这里插入图片描述
WmchannelController

package com.heima.wemedia.controller.v1;import com.heima.model.common.dtos.ResponseResult;
import com.heima.model.wemedia.dtos.WmFindDto;
import com.heima.model.wemedia.pojos.WmChannel;
import com.heima.wemedia.service.WmChannelService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;import javax.annotation.Resource;@RestController
@RequestMapping("/api/v1/channel")
@Slf4j
public class WmchannelController {@Autowiredprivate WmChannelService wmChannelService;;@GetMapping("/channels")public ResponseResult findAll() {return wmChannelService.findAll();}//   频道管理 功能开始//新增频道@PostMapping("/save")public ResponseResult saveChanel(@RequestBody WmChannel wmChannel){return wmChannelService.saveChanel(wmChannel);}//分页查询@PostMapping("/list")public ResponseResult findList(@RequestBody WmFindDto dto){return wmChannelService.findList( dto);}/*** 修改频道*/@PostMapping("/update")public ResponseResult update(@RequestBody WmChannel wmChannel){return wmChannelService.update(wmChannel);}//删除频道@GetMapping("/del/{id}")public ResponseResult remove(@PathVariable Integer id) {return wmChannelService.removeChanel(id);}}

WmChannelService

package com.heima.wemedia.service;import com.baomidou.mybatisplus.extension.service.IService;
import com.heima.model.common.dtos.ResponseResult;
import com.heima.model.wemedia.dtos.WmFindDto;
import com.heima.model.wemedia.pojos.WmChannel;
import org.springframework.web.bind.annotation.RequestBody;public interface WmChannelService extends IService<WmChannel> {//查询所有频道public ResponseResult findAll();//查看文章详情public ResponseResult select(Integer id);//保存文章频道public ResponseResult saveChanel( WmChannel wmChannel);/*** 查询所有频道* @param dto* @return*/ResponseResult findList(WmFindDto dto);//修改频道ResponseResult update(WmChannel wmChannel);//删除频道ResponseResult removeChanel(Integer id);}

WmChannelServiceImpl

package com.heima.wemedia.service.impl;import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.heima.model.common.dtos.PageResponseResult;
import com.heima.model.common.dtos.ResponseResult;
import com.heima.model.common.enums.AppHttpCodeEnum;
import com.heima.model.wemedia.dtos.WmFindDto;
import com.heima.model.wemedia.pojos.WmChannel;
import com.heima.model.wemedia.pojos.WmNews;
import com.heima.wemedia.mapper.WmChannelMapper;
import com.heima.wemedia.mapper.WmNewsMapper;
import com.heima.wemedia.service.WmChannelService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;import java.util.Date;@Service
@Transactional
@Slf4j
public class WmChannelServiceImpl extends ServiceImpl<WmChannelMapper, WmChannel> implements WmChannelService {/*** @return*/@Overridepublic ResponseResult findAll() {return ResponseResult.okResult(list());}/*** 查看文章** @param id* @return*/@Overridepublic ResponseResult select(Integer id) {WmChannel byId = super.getById(id);return ResponseResult.okResult(byId);}/*** 保存频道** @param wmChannel* @return*/@Overridepublic ResponseResult saveChanel(WmChannel wmChannel) {if (wmChannel == null || StringUtils.isBlank(wmChannel.getName())) {return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);}String name = wmChannel.getName();WmChannel one = getOne(Wrappers.<WmChannel>lambdaQuery().eq(WmChannel::getName, name));if (one == null) {wmChannel.setIsDefault(true);wmChannel.setCreatedTime(new Date());save(wmChannel);return ResponseResult.okResult("保存成功");} else {return ResponseResult.errorResult(AppHttpCodeEnum.DATA_EXIST);}}/*** 查询所有频道** @param dto* @return*/@Overridepublic ResponseResult findList(WmFindDto dto) {if (dto == null) {return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);}//如果当前页是空 那就给一个初始值 ， 每页条数也是if (dto.getPage() == null || dto.getSize() == null) {dto.setPage(1);dto.setSize(10);}//开始分页查询Page page = new Page(dto.getPage(), dto.getSize());//构建查询LambdaQueryWrapper<WmChannel> wrapper = new LambdaQueryWrapper();//如果有名称就根据名称查询if (StringUtils.isNoneBlank(dto.getName())) {wrapper.like(WmChannel::getName, dto.getName());}//如果有状态根据状态查询if (dto.getStatus() != null) {wrapper.eq(WmChannel::getStatus, dto.getStatus());}//倒叙wrapper.orderByDesc(WmChannel::getCreatedTime);//开始分页page = page(page, wrapper);//结果返回ResponseResult responseResult = new PageResponseResult(dto.getPage(), dto.getSize(), (int) page.getTotal());responseResult.setData(page.getRecords());return responseResult;}@Autowiredprivate WmNewsMapper wmNewsMapper;/*** 更新频道** @param wmChannel* @return*/@Overridepublic ResponseResult update(WmChannel wmChannel) {if (wmChannel.getId() == null || wmChannel == null) {return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);}//设置缺少属性wmChannel.setCreatedTime(new Date());wmChannel.setIsDefault(true);//查看是否被引用if (wmChannel.getStatus() == false) {LambdaQueryWrapper<WmNews> query = new LambdaQueryWrapper();query.eq(WmNews::getChannelId, wmChannel.getId());//审核中的文章使用这个频道也不能删除//    List<WmNews> wmNews = wmNewsMapper.selectList(query);int count = wmNewsMapper.selectCount(query);if (count > 0) {return ResponseResult.errorResult(AppHttpCodeEnum.NO_OPERATOR_AUTH, "素材已被引用");}}updateById(wmChannel);return ResponseResult.okResult("更新成功");}/*** 删除频道* @param id* @return*/@Overridepublic ResponseResult removeChanel(Integer id) {if (id == null) {return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);}WmChannel channel = getById(id);if (channel.getStatus() != false){return ResponseResult.errorResult(AppHttpCodeEnum.NO_OPERATOR_AUTH, "素材已启用无法删除");}removeById(id);return ResponseResult.okResult("删除成功");}
}

4.敏感词管理

nacos 配置不用动就是最基本增删改查列出核心代码
AdSensitiveController

package com.heima.wemedia.controller.v1;import com.heima.model.common.dtos.ResponseResult;
import com.heima.model.common.enums.AppHttpCodeEnum;
import com.heima.model.wemedia.dtos.AdSentiveDto;
import com.heima.model.wemedia.pojos.WmSensitive;
import com.heima.wemedia.service.AdSensitiveService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;@RestController
@RequestMapping("/api/v1/sensitive")
public class AdSensitiveController {@Autowiredprivate AdSensitiveService adSensitiveService;//新增敏感词@PostMapping("/save")public ResponseResult save(@RequestBody WmSensitive wmSensitive) {return adSensitiveService.saveSensitive(wmSensitive);}@PostMapping("/list")public ResponseResult list(@RequestBody AdSentiveDto dto) {return adSensitiveService.selectList(dto);}@DeleteMapping("/del/{id}")public ResponseResult del(@PathVariable Integer id) {if ( adSensitiveService.removeById(id)){return ResponseResult.okResult("删除成功");}else{return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID,"删除失败");}}@PostMapping("/update")public ResponseResult update(@RequestBody WmSensitive wmSensitive) {return adSensitiveService.updateSensitive(wmSensitive);}}

AdSensitiveService

package com.heima.wemedia.service;import com.baomidou.mybatisplus.extension.service.IService;
import com.heima.model.common.dtos.ResponseResult;
import com.heima.model.wemedia.dtos.AdSentiveDto;
import com.heima.model.wemedia.pojos.WmSensitive;public interface AdSensitiveService extends IService<WmSensitive> {//新增敏感词ResponseResult saveSensitive(WmSensitive wmSensitive);//分页查询敏感词ResponseResult selectList(AdSentiveDto dto);//修改敏感词ResponseResult updateSensitive(WmSensitive wmSensitive);
}

AdSensitiveServiceImpl

package com.heima.wemedia.service.impl;import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.injector.methods.SelectList;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.heima.model.common.dtos.PageResponseResult;
import com.heima.model.common.dtos.ResponseResult;
import com.heima.model.common.enums.AppHttpCodeEnum;
import com.heima.model.wemedia.dtos.AdSentiveDto;
import com.heima.model.wemedia.pojos.WmSensitive;
import com.heima.wemedia.mapper.WmSensitiveMapper;
import com.heima.wemedia.service.AdSensitiveService;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;import java.util.Date;@Service
public class AdSensitiveServiceImpl extends ServiceImpl<WmSensitiveMapper , WmSensitive> implements AdSensitiveService {/*** 新增敏感词* @param wmSensitive*/@Overridepublic ResponseResult saveSensitive(WmSensitive wmSensitive) {if(StringUtils.isBlank(wmSensitive.getSensitives())){return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);}String sensitives = wmSensitive.getSensitives();WmSensitive sensitive = getOne(Wrappers.<WmSensitive>lambdaQuery().eq(WmSensitive::getSensitives, sensitives));if (sensitive != null){return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID,"敏感词已存在");}wmSensitive.setCreatedTime(new Date());save(wmSensitive);return ResponseResult.okResult("新增成功");}/*** 分页查询敏感词* @param dto* @return*/@Overridepublic ResponseResult selectList(AdSentiveDto dto) {//设置初始值if (dto.getPage() == null || dto.getSize() == null){dto.setPage(1);dto.setSize(10);}//开始分页IPage page = new Page(dto.getPage(), dto.getSize());LambdaQueryWrapper<WmSensitive> wrapper = new LambdaQueryWrapper();if (StringUtils.isNoneBlank(dto.getName())){wrapper.like(WmSensitive::getSensitives,dto.getName());}//返回结果page = page(page,wrapper);ResponseResult responseResult = new PageResponseResult(dto.getPage(), dto.getSize(), (int) page.getTotal());responseResult.setData(page.getRecords());return responseResult;}/*** @param wmSensitive* @return*/@Overridepublic ResponseResult updateSensitive(WmSensitive wmSensitive) {if (wmSensitive.getId() == null){return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);}wmSensitive.setCreatedTime(new Date());updateById(wmSensitive);return ResponseResult.okResult("修改成功");}
}

5.用户认证审核

http://localhost:8803/service_6001/user/api/v1/auth/list
请求路径，发现需要经过nacos 设置可以转发到user微服务，不转发自己配一套应该也可以就是太麻烦所以直接用

spring:cloud:gateway:globalcors:add-to-simple-url-handler-mapping: truecorsConfigurations:'[/**]':allowedHeaders: "*"allowedOrigins: "*"allowedMethods:- GET- POST- DELETE- PUT- OPTIONroutes:# 平台管理登录- id: adminloginuri: lb://leadnews-admin-webpredicates:- Path=/admin/**filters:- StripPrefix= 1#自媒体服务- id: leadnews-wemediauri: lb://leadnews-wemediapredicates:- Path=/wemedia/**filters:- StripPrefix= 1#用户服务- id: useruri: lb://leadnews-userpredicates:- Path=/user/**filters:- StripPrefix= 1

测试后发现请求成功到达在这里插入图片描述

主要代码如下
AdAuthController

package com.heima.user.controller.v1;import com.heima.model.admin.web.dto.AdUserDto;
import com.heima.model.admin.web.pojo.ApUserRealname;
import com.heima.model.common.dtos.ResponseResult;
import com.heima.user.service.AdUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
@RequestMapping("/api/v1/auth")
public class AdAuthController {@Autowiredprivate AdUserService adUserService;//分页查询@PostMapping("/list")public ResponseResult selectList(@RequestBody AdUserDto dto) {return  adUserService.selectList(dto);}@PostMapping("/authFail")public ResponseResult authErrot(@RequestBody ApUserRealname dto){dto.setStatus((short) 2);dto.setReason("审核不通过");return adUserService.authErrot(dto);}@PostMapping("/authPass")public ResponseResult authPass(@RequestBody ApUserRealname dto){dto.setStatus((short) 9);return adUserService.authErrot(dto);}}

AdUserService

package com.heima.user.service;import com.baomidou.mybatisplus.extension.service.IService;
import com.heima.model.admin.web.dto.AdUserDto;
import com.heima.model.admin.web.pojo.AdUser;
import com.heima.model.admin.web.pojo.ApUserRealname;
import com.heima.model.common.dtos.ResponseResult;
import com.heima.model.user.pojos.ApUser;public interface AdUserService extends IService<ApUserRealname> {// 分页查询ResponseResult selectList(AdUserDto dto);//审核成功或失败通用ResponseResult authErrot(ApUserRealname dto);
}

impl

package com.heima.user.service.impl;import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.heima.model.admin.web.dto.AdUserDto;
import com.heima.model.admin.web.pojo.AdUser;
import com.heima.model.admin.web.pojo.ApUserRealname;
import com.heima.model.common.dtos.PageResponseResult;
import com.heima.model.common.dtos.ResponseResult;
import com.heima.model.common.enums.AppHttpCodeEnum;
import com.heima.user.mapper.AdUserMapper;
import com.heima.user.mapper.ApUserRealnameMapper;
import com.heima.user.service.AdUserService;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import java.util.Date;@Service
public class AdUserServiceImpl extends ServiceImpl<ApUserRealnameMapper, ApUserRealname> implements AdUserService {/*** @param dto* @return*/@Overridepublic ResponseResult selectList(AdUserDto dto) {if (dto.getPage() == null || dto.getSize() == null){dto.setPage(1);dto.setSize(10);}IPage page = new Page(dto.getPage(), dto.getSize());LambdaQueryWrapper<ApUserRealname> wrapper = new LambdaQueryWrapper();if (dto.getStatus() != null){wrapper.eq(ApUserRealname::getStatus,dto.getStatus());page = page(page ,wrapper);}else{page = page(page);}ResponseResult responseResult = new PageResponseResult(dto.getPage(), dto.getSize(), (int) page.getTotal());responseResult.setData(page.getRecords());return responseResult;}//审核失败逻辑/*** @param dto* @return*/@Overridepublic ResponseResult authErrot(ApUserRealname dto) {if (dto.getId()==null){return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);}ApUserRealname byId = getById(dto.getId());byId.setStatus(dto.getStatus());if (dto.getReason() != null) {byId.setReason(dto.getReason());}byId.setUpdatedTime(new Date());updateById(byId);return ResponseResult.okResult("修改成功");}
}

6.自媒体文章人工审核

99. 最后开发中碰到的问题汇总

1.关于nacos 配置问题

这个是正确的 nacos 关于登录的配置


spring:cloud:gateway:globalcors:add-to-simple-url-handler-mapping: truecorsConfigurations:'[/**]':allowedHeaders: "*"allowedOrigins: "*"allowedMethods:- GET- POST- DELETE- PUT- OPTIONroutes:# 平台管理微服务- id: adminuri: lb://leadnews-admin      #这个lb 后面的是 登录微服务的微服务配置文件名称predicates:

routes 的 uri 路径 /service_6001/admin/login/** 我写成这个就无法访问到后端而写/admin/** 就可以虽然知道 /admin 匹配更宽泛但是为什么我写精准的就不行呢
在这里插入图片描述

答：
结合nginx 配置发现
这里的正则表达式~/service_6001/(.*)会匹配以/service_6001/开头的任何URI，并捕获/service_6001/之后的部分作为变量$1。当您将前端请求发送到http://localhost:8803/service_6001/admin/login/in时，该请求会被这个location块捕获，并且$1将等于admin/login/in。

2.在开发频道管理新增频道后端无法接收到前端请求

！！不需要新建一个模块，用leadnews-wemedia模块就能完成
因为请求url 根据nginx 配置会发给 admin-web-gateway 的配置文件
应在配置文件中配置这个路径转发到哪不然后端接收到
http://localhost:8803/service_6001/wemedia/api/v1/channel/save
正确配置

spring:cloud:gateway:globalcors:add-to-simple-url-handler-mapping: truecorsConfigurations:'[/**]':allowedHeaders: "*"allowedOrigins: "*"allowedMethods:- GET- POST- DELETE- PUT- OPTIONroutes:# 平台管理登录- id: adminloginuri: lb://leadnews-admin-webpredicates:- Path=/admin/**filters:- StripPrefix= 1#自媒体服务- id: leadnews-wemedia   #名字自定义不重复即可uri: lb://leadnews-wemedia   #对应wemedia 的微服务配置文件名称predicates:- Path=/wemedia/**filters:- StripPrefix= 1

3.观察了两个方法

selectList
在这里插入图片描述

在这里插入图片描述
selectCount

4.规范性 dto 和pojo类

pojo用于和数据库交互 dto 用于和前端交互，开发时应注意规范性