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

黑马头条Day08-平台管理_黑马头条day8

作者：运维做开发 | 2024-08-16 11:41:28

赞

踩

黑马头条day8

一、平台管理前端

步骤①：拷贝资料中提供的前端项目到没有中文的目录下

步骤②：在leadnews.conf文件夹下新增heima-leadnews-admin.conf配置文件

内容如下：根据自己的情况更改root地址

  1. upstream  heima-admin-gateway{
  2.     server localhost:51603;
  3. }
  4.  
  5. server {
  6. 	listen 8803;
  7. 	location / {
  8. 		root D:/IDEA/frontProject/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，访问 http://localhost:8803/#/login

二、登录及网关

1. 登录

步骤①：导入资料中的leadnews_admin.sql

  1. /*
  2.  Navicat Premium Data Transfer
  4.  Source Server         : localhost
  5.  Source Server Type    : MySQL
  6.  Source Server Version : 50721
  7.  Source Host           : localhost:3306
  8.  Source Schema         : leadnews_admin
  10.  Target Server Type    : MySQL
  11.  Target Server Version : 50721
  12.  File Encoding         : 65001
  14.  Date: 26/07/2021 01:45:37
  15. */
  16. DROP DATABASE IF EXISTS leadnews_admin;
  17. CREATE DATABASE leadnews_admin;
  18. USE leadnews_admin;
  19.  
  20. SET NAMES utf8mb4;
  21. SET FOREIGN_KEY_CHECKS = 0;
  22.  
  23. -- ----------------------------
  24. -- Table structure for ad_article_statistics
  25. -- ----------------------------
  26. DROP TABLE IF EXISTS `ad_article_statistics`;
  27. CREATE TABLE `ad_article_statistics`  (
  28.   `id` int(11) UNSIGNED NOT NULL COMMENT '主键',
  29.   `article_we_media` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '主账号ID',
  30.   `article_crawlers` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '子账号ID',
  31.   `channel_id` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '频道ID',
  32.   `read_20` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '草读量',
  33.   `read_100` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '读完量',
  34.   `read_count` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '阅读量',
  35.   `comment` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '评论量',
  36.   `follow` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '关注量',
  37.   `collection` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '收藏量',
  38.   `forward` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '转发量',
  39.   `likes` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '点赞量',
  40.   `unlikes` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '不喜欢',
  41.   `unfollow` int(11) UNSIGNED NULL DEFAULT NULL COMMENT 'unfollow',
  42.   `created_time` datetime(0) NULL DEFAULT NULL COMMENT '创建时间',
  43.   PRIMARY KEY (`id`) USING BTREE
  44. ) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '文章数据统计表' ROW_FORMAT = DYNAMIC;
  45.  
  46. -- ----------------------------
  47. -- Records of ad_article_statistics
  48. -- ----------------------------
  49.  
  50. -- ----------------------------
  51. -- Table structure for ad_channel_label
  52. -- ----------------------------
  53. DROP TABLE IF EXISTS `ad_channel_label`;
  54. CREATE TABLE `ad_channel_label`  (
  55.   `id` int(11) UNSIGNED NOT NULL AUTO_INCREMENT COMMENT '主键',
  56.   `channel_id` int(11) UNSIGNED NULL DEFAULT NULL,
  57.   `label_id` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '标签ID',
  58.   `ord` int(5) UNSIGNED NULL DEFAULT NULL COMMENT '排序',
  59.   PRIMARY KEY (`id`) USING BTREE
  60. ) ENGINE = InnoDB AUTO_INCREMENT = 1118 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '频道标签信息表' ROW_FORMAT = DYNAMIC;
  61.  
  62. -- ----------------------------
  63. -- Records of ad_channel_label
  64. -- ----------------------------
  65. INSERT INTO `ad_channel_label` VALUES (1108, 1, 1, 0);
  66. INSERT INTO `ad_channel_label` VALUES (1109, 1, 8, 0);
  67. INSERT INTO `ad_channel_label` VALUES (1110, 7, 7, 0);
  68. INSERT INTO `ad_channel_label` VALUES (1111, 7, 9, 0);
  69. INSERT INTO `ad_channel_label` VALUES (1112, 3, 3, 0);
  70. INSERT INTO `ad_channel_label` VALUES (1113, 7, 2, 0);
  71. INSERT INTO `ad_channel_label` VALUES (1114, 3, 4, 0);
  72. INSERT INTO `ad_channel_label` VALUES (1115, 5, 5, 0);
  73. INSERT INTO `ad_channel_label` VALUES (1116, 4, 6, 0);
  74. INSERT INTO `ad_channel_label` VALUES (1117, 6, 10, 0);
  75.  
  76. -- ----------------------------
  77. -- Table structure for ad_function
  78. -- ----------------------------
  79. DROP TABLE IF EXISTS `ad_function`;
  80. CREATE TABLE `ad_function`  (
  81.   `id` int(11) UNSIGNED NOT NULL,
  82.   `name` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '功能名称',
  83.   `code` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '功能代码',
  84.   `parent_id` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '父功能',
  85.   `created_time` datetime(0) NULL DEFAULT NULL COMMENT '登录时间',
  86.   PRIMARY KEY (`id`) USING BTREE
  87. ) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '页面功能信息表' ROW_FORMAT = DYNAMIC;
  88.  
  89. -- ----------------------------
  90. -- Records of ad_function
  91. -- ----------------------------
  92.  
  93. -- ----------------------------
  94. -- Table structure for ad_label
  95. -- ----------------------------
  96. DROP TABLE IF EXISTS `ad_label`;
  97. CREATE TABLE `ad_label`  (
  98.   `id` int(11) UNSIGNED NOT NULL AUTO_INCREMENT,
  99.   `name` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '频道名称',
  100.   `type` tinyint(1) UNSIGNED NULL DEFAULT NULL COMMENT '0系统增加\r\n            1人工增加',
  101.   `created_time` datetime(0) NULL DEFAULT NULL COMMENT '创建时间',
  102.   PRIMARY KEY (`id`) USING BTREE,
  103.   UNIQUE INDEX `idx_name`(`name`) USING BTREE
  104. ) ENGINE = InnoDB AUTO_INCREMENT = 24237 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '标签信息表' ROW_FORMAT = DYNAMIC;
  105.  
  106. -- ----------------------------
  107. -- Records of ad_label
  108. -- ----------------------------
  109. INSERT INTO `ad_label` VALUES (1, 'java', 0, '2019-08-22 16:30:16');
  110. INSERT INTO `ad_label` VALUES (2, 'docker', 0, '2019-08-22 16:30:52');
  111. INSERT INTO `ad_label` VALUES (3, 'mysql', 0, '2019-08-22 16:31:17');
  112. INSERT INTO `ad_label` VALUES (4, 'vue', 0, '2019-08-22 16:35:39');
  113. INSERT INTO `ad_label` VALUES (5, 'Weex', 0, '2019-08-22 16:36:08');
  114. INSERT INTO `ad_label` VALUES (6, 'Python', 0, '2019-08-22 16:36:34');
  115. INSERT INTO `ad_label` VALUES (7, '大数据', 0, '2019-08-22 16:36:48');
  116. INSERT INTO `ad_label` VALUES (8, 'spring', 0, '2019-08-22 16:39:11');
  117. INSERT INTO `ad_label` VALUES (9, 'hbase', 0, '2019-08-22 16:39:35');
  118. INSERT INTO `ad_label` VALUES (10, 'hive', 0, '2019-08-22 16:43:44');
  119. INSERT INTO `ad_label` VALUES (23858, '工具', 1, '2019-08-22 16:43:55');
  120. INSERT INTO `ad_label` VALUES (23859, 'c', 1, '2019-08-22 16:44:01');
  121. INSERT INTO `ad_label` VALUES (23860, '电话', 1, '2019-08-22 16:44:22');
  122. INSERT INTO `ad_label` VALUES (23861, '照片', 1, '2019-08-22 16:44:22');
  123. INSERT INTO `ad_label` VALUES (23862, '咨询', 1, '2019-08-22 16:44:22');
  124. INSERT INTO `ad_label` VALUES (23863, '智能', 1, '2019-08-22 16:46:00');
  125. INSERT INTO `ad_label` VALUES (23864, '人工智能', 1, '2019-08-22 16:46:00');
  126. INSERT INTO `ad_label` VALUES (23865, 'AI', 1, '2019-08-22 16:46:00');
  127. INSERT INTO `ad_label` VALUES (23866, '智能协会', 1, '2019-08-22 16:46:00');
  128. INSERT INTO `ad_label` VALUES (23867, '人工智能协会', 1, '2019-08-22 16:46:00');
  129. INSERT INTO `ad_label` VALUES (23868, '5G', 1, '2019-08-22 16:47:21');
  130. INSERT INTO `ad_label` VALUES (23869, '高通', 1, '2019-08-22 16:47:21');
  131. INSERT INTO `ad_label` VALUES (23870, '苹果', 1, '2019-08-22 16:47:21');
  132. INSERT INTO `ad_label` VALUES (23871, '英特尔', 1, '2019-08-22 16:47:21');
  133. INSERT INTO `ad_label` VALUES (23872, '智能手机', 1, '2019-08-22 16:47:21');
  134. INSERT INTO `ad_label` VALUES (23873, 'google', 1, '2019-08-22 16:47:49');
  135. INSERT INTO `ad_label` VALUES (23874, '芯片', 1, '2019-08-22 16:47:49');
  136. INSERT INTO `ad_label` VALUES (23875, '交互', 1, '2019-08-22 16:47:49');
  137. INSERT INTO `ad_label` VALUES (23876, '智能交互', 1, '2019-08-22 16:47:49');
  138. INSERT INTO `ad_label` VALUES (23877, '手势交互', 1, '2019-08-22 16:47:49');
  139. INSERT INTO `ad_label` VALUES (23878, '智慧酒店', 1, '2019-08-22 16:48:54');
  140. INSERT INTO `ad_label` VALUES (23879, '人脸识别', 1, '2019-08-22 16:49:06');
  141. INSERT INTO `ad_label` VALUES (23880, '软硬件开发流程', 1, '2019-08-22 16:49:26');
  142. INSERT INTO `ad_label` VALUES (23881, '软硬件结合', 1, '2019-08-22 16:50:23');
  143. INSERT INTO `ad_label` VALUES (23882, 'React', 1, '2019-08-22 17:18:59');
  144. INSERT INTO `ad_label` VALUES (23883, '前端技术', 1, '2019-08-22 17:18:59');
  145. INSERT INTO `ad_label` VALUES (23903, 'IDEA', 1, '2019-08-22 17:22:21');
  146. INSERT INTO `ad_label` VALUES (23904, 'git', 1, '2019-08-22 17:32:54');
  147. INSERT INTO `ad_label` VALUES (23905, 'java学习', 1, '2019-08-22 17:43:34');
  148. INSERT INTO `ad_label` VALUES (23906, '机器学习', 1, '2019-08-22 17:46:40');
  149. INSERT INTO `ad_label` VALUES (23907, '陆奇', 1, '2019-08-22 17:46:55');
  150. INSERT INTO `ad_label` VALUES (23908, '设计模式', 1, '2019-08-22 17:47:40');
  151. INSERT INTO `ad_label` VALUES (23909, '谷歌', 1, '2019-08-22 17:48:11');
  152. INSERT INTO `ad_label` VALUES (23916, '工业数字化', 1, '2019-08-22 17:49:16');
  153. INSERT INTO `ad_label` VALUES (23949, '个人生活', 1, '2019-08-22 17:57:38');
  154. INSERT INTO `ad_label` VALUES (23950, '安徽', 1, '2019-08-22 17:57:38');
  155. INSERT INTO `ad_label` VALUES (23951, '黄山', 1, '2019-08-22 17:57:38');
  156. INSERT INTO `ad_label` VALUES (23952, 'SVN信息', 1, '2019-08-22 18:00:27');
  157. INSERT INTO `ad_label` VALUES (23953, '清除', 1, '2019-08-22 18:00:27');
  158. INSERT INTO `ad_label` VALUES (23954, '删除', 1, '2019-08-22 18:00:27');
  159. INSERT INTO `ad_label` VALUES (23955, 'svn', 1, '2019-08-22 18:00:27');
  160. INSERT INTO `ad_label` VALUES (23956, '排序', 1, '2019-08-22 18:01:27');
  161. INSERT INTO `ad_label` VALUES (23957, '快排', 1, '2019-08-22 18:01:27');
  162. INSERT INTO `ad_label` VALUES (23958, '归并排序', 1, '2019-08-22 18:01:27');
  163. INSERT INTO `ad_label` VALUES (23959, '程序人生', 1, '2019-08-22 18:05:25');
  164. INSERT INTO `ad_label` VALUES (23960, '毕业一年', 1, '2019-08-22 18:05:25');
  165. INSERT INTO `ad_label` VALUES (23961, '毕业总结', 1, '2019-08-22 18:05:25');
  166. INSERT INTO `ad_label` VALUES (23962, '毕业感想', 1, '2019-08-22 18:05:25');
  167. INSERT INTO `ad_label` VALUES (23979, 'dom', 1, '2019-08-22 18:09:39');
  168. INSERT INTO `ad_label` VALUES (23980, 'javascript', 1, '2019-08-22 18:09:39');
  169. INSERT INTO `ad_label` VALUES (23981, 'web开发', 1, '2019-08-22 18:09:39');
  170. INSERT INTO `ad_label` VALUES (23995, 'IT', 1, '2019-08-22 18:13:50');
  171. INSERT INTO `ad_label` VALUES (23996, '科技', 1, '2019-08-22 18:13:50');
  172. INSERT INTO `ad_label` VALUES (23998, '自动化', 1, '2019-08-22 18:16:20');
  173. INSERT INTO `ad_label` VALUES (23999, '运维', 1, '2019-08-22 18:16:20');
  174. INSERT INTO `ad_label` VALUES (24000, 'ansible', 1, '2019-08-22 18:16:20');
  175. INSERT INTO `ad_label` VALUES (24001, '入门', 1, '2019-08-22 18:16:20');
  176. INSERT INTO `ad_label` VALUES (24002, 'c#', 1, '2019-08-22 18:16:45');
  177. INSERT INTO `ad_label` VALUES (24003, '正则', 1, '2019-08-22 18:16:45');
  178. INSERT INTO `ad_label` VALUES (24004, 'regex', 1, '2019-08-22 18:16:45');
  179. INSERT INTO `ad_label` VALUES (24005, '字符串', 1, '2019-08-22 18:16:45');
  180. INSERT INTO `ad_label` VALUES (24015, 'openstack', 1, '2019-08-22 18:19:42');
  181. INSERT INTO `ad_label` VALUES (24016, 'k8s', 1, '2019-08-22 18:20:47');
  182. INSERT INTO `ad_label` VALUES (24017, 'kubernetes', 1, '2019-08-22 18:20:47');
  183. INSERT INTO `ad_label` VALUES (24018, 'kubectl', 1, '2019-08-22 18:20:47');
  184. INSERT INTO `ad_label` VALUES (24019, 'supervisor', 1, '2019-08-22 18:24:43');
  185. INSERT INTO `ad_label` VALUES (24020, 'linux', 1, '2019-08-22 18:24:43');
  186. INSERT INTO `ad_label` VALUES (24021, '进程管理', 1, '2019-08-22 18:24:43');
  187. INSERT INTO `ad_label` VALUES (24109, '百度网盘', 1, '2019-08-22 19:14:19');
  188. INSERT INTO `ad_label` VALUES (24110, '百度云', 1, '2019-08-22 19:14:19');
  189. INSERT INTO `ad_label` VALUES (24111, '免费', 1, '2019-08-22 19:14:19');
  190. INSERT INTO `ad_label` VALUES (24112, '不限速', 1, '2019-08-22 19:14:19');
  191. INSERT INTO `ad_label` VALUES (24113, '破解', 1, '2019-08-22 19:14:19');
  192. INSERT INTO `ad_label` VALUES (24123, '脚本', 1, '2019-08-22 19:14:26');
  193. INSERT INTO `ad_label` VALUES (24124, '作业', 1, '2019-08-22 19:14:26');
  194. INSERT INTO `ad_label` VALUES (24125, '自动化运维', 1, '2019-08-22 19:14:26');
  195. INSERT INTO `ad_label` VALUES (24126, '极客头条', 1, '2019-08-22 20:34:33');
  196. INSERT INTO `ad_label` VALUES (24198, '业界新闻', 1, '2019-08-23 07:28:27');
  197. INSERT INTO `ad_label` VALUES (24206, '杂谈', 1, '2019-08-23 07:31:09');
  198. INSERT INTO `ad_label` VALUES (24207, '零信任网络', 1, '2019-08-23 07:33:37');
  199. INSERT INTO `ad_label` VALUES (24208, '网络安全', 1, '2019-08-23 07:33:37');
  200. INSERT INTO `ad_label` VALUES (24209, 'Go语言', 1, '2019-08-23 07:33:54');
  201. INSERT INTO `ad_label` VALUES (24210, '程序员', 1, '2019-08-23 07:33:54');
  202. INSERT INTO `ad_label` VALUES (24223, 'Android', 1, '2019-08-23 07:35:42');
  203. INSERT INTO `ad_label` VALUES (24224, '架构', 1, '2019-08-23 07:35:42');
  204. INSERT INTO `ad_label` VALUES (24232, 'flume', 1, '2019-08-23 07:37:05');
  205. INSERT INTO `ad_label` VALUES (24233, 'hive优化', 1, '2019-08-23 07:37:27');
  206. INSERT INTO `ad_label` VALUES (24234, 'parquet', 1, '2019-08-23 07:37:27');
  207. INSERT INTO `ad_label` VALUES (24235, 'orc', 1, '2019-08-23 07:37:27');
  208. INSERT INTO `ad_label` VALUES (24236, 'snappy', 1, '2019-08-23 07:37:27');
  209.  
  210. -- ----------------------------
  211. -- Table structure for ad_menu
  212. -- ----------------------------
  213. DROP TABLE IF EXISTS `ad_menu`;
  214. CREATE TABLE `ad_menu`  (
  215.   `id` int(11) UNSIGNED NOT NULL,
  216.   `name` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '菜单名称',
  217.   `code` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '菜单代码',
  218.   `parent_id` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '父菜单',
  219.   `created_time` datetime(0) NULL DEFAULT NULL COMMENT '登录时间',
  220.   PRIMARY KEY (`id`) USING BTREE
  221. ) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '菜单资源信息表' ROW_FORMAT = DYNAMIC;
  222.  
  223. -- ----------------------------
  224. -- Records of ad_menu
  225. -- ----------------------------
  226.  
  227. -- ----------------------------
  228. -- Table structure for ad_recommend_strategy
  229. -- ----------------------------
  230. DROP TABLE IF EXISTS `ad_recommend_strategy`;
  231. CREATE TABLE `ad_recommend_strategy`  (
  232.   `id` int(5) UNSIGNED NOT NULL COMMENT '主键',
  233.   `name` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '策略名称',
  234.   `description` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '策略描述',
  235.   `is_enable` tinyint(1) NULL DEFAULT NULL COMMENT '是否有效',
  236.   `group_id` int(5) UNSIGNED NULL DEFAULT NULL COMMENT '分组ID',
  237.   `created_time` datetime(0) NULL DEFAULT NULL COMMENT '创建时间',
  238.   PRIMARY KEY (`id`) USING BTREE
  239. ) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '推荐策略信息表' ROW_FORMAT = DYNAMIC;
  240.  
  241. -- ----------------------------
  242. -- Records of ad_recommend_strategy
  243. -- ----------------------------
  244.  
  245. -- ----------------------------
  246. -- Table structure for ad_role
  247. -- ----------------------------
  248. DROP TABLE IF EXISTS `ad_role`;
  249. CREATE TABLE `ad_role`  (
  250.   `id` int(11) UNSIGNED NOT NULL,
  251.   `name` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '角色名称',
  252.   `description` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '角色描述',
  253.   `is_enable` tinyint(1) UNSIGNED NULL DEFAULT NULL COMMENT '是否有效',
  254.   `created_time` datetime(0) NULL DEFAULT NULL COMMENT '登录时间',
  255.   PRIMARY KEY (`id`) USING BTREE
  256. ) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '角色信息表' ROW_FORMAT = DYNAMIC;
  257.  
  258. -- ----------------------------
  259. -- Records of ad_role
  260. -- ----------------------------
  261.  
  262. -- ----------------------------
  263. -- Table structure for ad_role_auth
  264. -- ----------------------------
  265. DROP TABLE IF EXISTS `ad_role_auth`;
  266. CREATE TABLE `ad_role_auth`  (
  267.   `id` int(11) UNSIGNED NOT NULL,
  268.   `role_id` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '角色ID',
  269.   `type` tinyint(1) UNSIGNED NULL DEFAULT NULL COMMENT '资源类型\r\n            0 菜单\r\n            1 功能',
  270.   `entry_id` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '资源ID',
  271.   `created_time` datetime(0) NULL DEFAULT NULL COMMENT '登录时间',
  272.   PRIMARY KEY (`id`) USING BTREE
  273. ) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '角色权限信息表' ROW_FORMAT = DYNAMIC;
  274.  
  275. -- ----------------------------
  276. -- Records of ad_role_auth
  277. -- ----------------------------
  278.  
  279. -- ----------------------------
  280. -- Table structure for ad_strategy_group
  281. -- ----------------------------
  282. DROP TABLE IF EXISTS `ad_strategy_group`;
  283. CREATE TABLE `ad_strategy_group`  (
  284.   `id` int(5) UNSIGNED NOT NULL COMMENT '主键',
  285.   `name` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '策略名称',
  286.   `description` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '策略描述',
  287.   `created_time` datetime(0) NULL DEFAULT NULL COMMENT '创建时间',
  288.   PRIMARY KEY (`id`) USING BTREE
  289. ) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '推荐策略分组信息表' ROW_FORMAT = DYNAMIC;
  290.  
  291. -- ----------------------------
  292. -- Records of ad_strategy_group
  293. -- ----------------------------
  294.  
  295. -- ----------------------------
  296. -- Table structure for ad_user
  297. -- ----------------------------
  298. DROP TABLE IF EXISTS `ad_user`;
  299. CREATE TABLE `ad_user`  (
  300.   `id` int(11) UNSIGNED NOT NULL COMMENT '主键',
  301.   `name` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '登录用户名',
  302.   `password` varchar(36) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '登录密码',
  303.   `salt` varchar(36) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '盐',
  304.   `nickname` varchar(2) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '昵称',
  305.   `image` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '头像',
  306.   `phone` varchar(36) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '手机号',
  307.   `status` tinyint(11) UNSIGNED NULL DEFAULT NULL COMMENT '状态\r\n            0 暂时不可用\r\n            1 永久不可用\r\n            9 正常可用',
  308.   `email` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '邮箱',
  309.   `login_time` datetime(0) NULL DEFAULT NULL COMMENT '最后一次登录时间',
  310.   `created_time` datetime(0) NULL DEFAULT NULL COMMENT '创建时间',
  311.   PRIMARY KEY (`id`) USING BTREE
  312. ) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '管理员用户信息表' ROW_FORMAT = DYNAMIC;
  313.  
  314. -- ----------------------------
  315. -- Records of ad_user
  316. -- ----------------------------
  317. INSERT INTO `ad_user` VALUES (1, 'wukong', '123', NULL, 'mo', NULL, '13320325525', 1, 'wukong@qq.com', '2019-07-30 10:16:41', '2019-07-30 10:16:43');
  318. INSERT INTO `ad_user` VALUES (2, 'admin', '5d4e1a406d4a9edbf7b4f10c2a390405', '123abc', 'ad', NULL, '13320325528', 1, 'admin@qq.com', '2020-03-04 17:07:37', '2020-03-04 17:07:40');
  319. INSERT INTO `ad_user` VALUES (3, 'guest', '34e20b52f5bd120db806e57e27f47ed0', '123456', 'gu', NULL, '13412345676', 1, 'guest@qq.com', '2020-07-30 15:00:03', '2020-07-30 15:00:06');
  320.  
  321. -- ----------------------------
  322. -- Table structure for ad_user_equipment
  323. -- ----------------------------
  324. DROP TABLE IF EXISTS `ad_user_equipment`;
  325. CREATE TABLE `ad_user_equipment`  (
  326.   `id` int(11) UNSIGNED NOT NULL,
  327.   `user_id` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '用户ID',
  328.   `type` tinyint(1) UNSIGNED NULL DEFAULT NULL COMMENT '0PC\r\n            1ANDROID\r\n            2IOS\r\n            3PAD\r\n            9 其他',
  329.   `version` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '设备版本',
  330.   `sys` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '设备系统',
  331.   `no` varchar(36) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '设备唯一号，MD5加密',
  332.   `created_time` datetime(0) NULL DEFAULT NULL COMMENT '登录时间',
  333.   PRIMARY KEY (`id`) USING BTREE
  334. ) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '管理员设备信息表' ROW_FORMAT = DYNAMIC;
  335.  
  336. -- ----------------------------
  337. -- Records of ad_user_equipment
  338. -- ----------------------------
  339.  
  340. -- ----------------------------
  341. -- Table structure for ad_user_login
  342. -- ----------------------------
  343. DROP TABLE IF EXISTS `ad_user_login`;
  344. CREATE TABLE `ad_user_login`  (
  345.   `id` int(11) UNSIGNED NOT NULL,
  346.   `user_id` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '用户ID',
  347.   `equipment_id` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '登录设备ID',
  348.   `ip` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '登录IP',
  349.   `address` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '登录地址',
  350.   `longitude` decimal(5, 5) NULL DEFAULT NULL COMMENT '经度',
  351.   `latitude` decimal(5, 5) NULL DEFAULT NULL COMMENT '纬度',
  352.   `created_time` datetime(0) NULL DEFAULT NULL COMMENT '登录时间',
  353.   PRIMARY KEY (`id`) USING BTREE
  354. ) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '管理员登录行为信息表' ROW_FORMAT = DYNAMIC;
  355.  
  356. -- ----------------------------
  357. -- Records of ad_user_login
  358. -- ----------------------------
  359.  
  360. -- ----------------------------
  361. -- Table structure for ad_user_opertion
  362. -- ----------------------------
  363. DROP TABLE IF EXISTS `ad_user_opertion`;
  364. CREATE TABLE `ad_user_opertion`  (
  365.   `id` int(11) UNSIGNED NOT NULL,
  366.   `user_id` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '用户ID',
  367.   `equipment_id` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '登录设备ID',
  368.   `ip` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '登录IP',
  369.   `address` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '登录地址',
  370.   `type` int(5) NULL DEFAULT NULL COMMENT '操作类型',
  371.   `description` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL COMMENT '操作描述',
  372.   `created_time` datetime(0) NULL DEFAULT NULL COMMENT '登录时间',
  373.   PRIMARY KEY (`id`) USING BTREE
  374. ) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '管理员操作行为信息表' ROW_FORMAT = DYNAMIC;
  375.  
  376. -- ----------------------------
  377. -- Records of ad_user_opertion
  378. -- ----------------------------
  379.  
  380. -- ----------------------------
  381. -- Table structure for ad_user_role
  382. -- ----------------------------
  383. DROP TABLE IF EXISTS `ad_user_role`;
  384. CREATE TABLE `ad_user_role`  (
  385.   `id` int(11) UNSIGNED NOT NULL,
  386.   `role_id` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '角色ID',
  387.   `user_id` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '用户ID',
  388.   `created_time` datetime(0) NULL DEFAULT NULL COMMENT '登录时间',
  389.   PRIMARY KEY (`id`) USING BTREE
  390. ) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '管理员角色信息表' ROW_FORMAT = DYNAMIC;
  391.  
  392. -- ----------------------------
  393. -- Records of ad_user_role
  394. -- ----------------------------
  395.  
  396. -- ----------------------------
  397. -- Table structure for ad_vistor_statistics
  398. -- ----------------------------
  399. DROP TABLE IF EXISTS `ad_vistor_statistics`;
  400. CREATE TABLE `ad_vistor_statistics`  (
  401.   `id` int(11) UNSIGNED NOT NULL COMMENT '主键',
  402.   `activity` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '日活',
  403.   `vistor` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '访问量',
  404.   `ip` int(11) UNSIGNED NULL DEFAULT NULL COMMENT 'IP量',
  405.   `register` int(11) UNSIGNED NULL DEFAULT NULL COMMENT '注册量',
  406.   `created_time` datetime(0) NULL DEFAULT NULL COMMENT '创建时间',
  407.   PRIMARY KEY (`id`) USING BTREE
  408. ) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '访问数据统计表' ROW_FORMAT = DYNAMIC;
  409.  
  410. -- ----------------------------
  411. -- Records of ad_vistor_statistics
  412. -- ----------------------------
  413.  
  414. SET FOREIGN_KEY_CHECKS = 1;

②从资料中拷贝AdUser类放到admin包下

  1. package com.heima.model.admin.pojos;
  2.  
  3. import com.baomidou.mybatisplus.annotation.TableField;
  4. import com.baomidou.mybatisplus.annotation.TableName;
  5. import lombok.Data;
  6.  
  7. import java.io.Serializable;
  8. import java.util.Date;
  9.  
  10. /**
  11.  * <p>
  12.  * 管理员用户信息表
  13.  * </p>
  14.  *
  15.  * @author itheima
  16.  */
  17. @Data
  18. @TableName("ad_user")
  19. public class AdUser implements Serializable {
  20.  
  21.     private static final long serialVersionUID = 1L;
  22.  
  23.     /**
  24.      * 主键
  25.      */
  26.     private Integer id;
  27.  
  28.     /**
  29.      * 登录用户名
  30.      */
  31.     @TableField("name")
  32.     private String name;
  33.  
  34.     /**
  35.      * 登录密码
  36.      */
  37.     @TableField("password")
  38.     private String password;
  39.  
  40.     /**
  41.      * 盐
  42.      */
  43.     @TableField("salt")
  44.     private String salt;
  45.  
  46.     /**
  47.      * 昵称
  48.      */
  49.     @TableField("nickname")
  50.     private String nickname;
  51.  
  52.     /**
  53.      * 头像
  54.      */
  55.     @TableField("image")
  56.     private String image;
  57.  
  58.     /**
  59.      * 手机号
  60.      */
  61.     @TableField("phone")
  62.     private String phone;
  63.  
  64.     /**
  65.      * 状态
  66.             0 暂时不可用
  67.             1 永久不可用
  68.             9 正常可用
  69.      */
  70.     @TableField("status")
  71.     private Integer status;
  72.  
  73.     /**
  74.      * 邮箱
  75.      */
  76.     @TableField("email")
  77.     private String email;
  78.  
  79.     /**
  80.      * 最后一次登录时间
  81.      */
  82.     @TableField("login_time")
  83.     private Date loginTime;
  84.  
  85.     /**
  86.      * 创建时间
  87.      */
  88.     @TableField("created_time")
  89.     private Date createdTime;
  90.  
  91. }

③在service模块下新建heima-leadnews-admin模块

④在admin模块新建如下

bootstrap.yml配置如下：

  1. server:
  2.   port: 51809
  3. spring:
  4.   application:
  5.     name: leadnews-admin
  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

logback.xml内容如下：

  1. <?xml version="1.0" encoding="UTF-8"?>
  2.  
  3. <configuration>
  4.     <!--定义日志文件的存储地址,使用绝对路径-->
  5.     <property name="LOG_HOME" value="e:/logs"/>
  6.  
  7.     <!-- Console 输出设置 -->
  8.     <appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
  9.         <encoder>
  10.             <!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符-->
  11.             <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
  12.             <charset>utf8</charset>
  13.         </encoder>
  14.     </appender>
  15.  
  16.     <!-- 按照每天生成日志文件 -->
  17.     <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
  18.         <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
  19.             <!--日志文件输出的文件名-->
  20.             <fileNamePattern>${LOG_HOME}/leadnews.%d{yyyy-MM-dd}.log</fileNamePattern>
  21.         </rollingPolicy>
  22.         <encoder>
  23.             <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
  24.         </encoder>
  25.     </appender>
  26.  
  27.     <!-- 异步输出 -->
  28.     <appender name="ASYNC" class="ch.qos.logback.classic.AsyncAppender">
  29.         <!-- 不丢失日志.默认的,如果队列的80%已满,则会丢弃TRACT、DEBUG、INFO级别的日志 -->
  30.         <discardingThreshold>0</discardingThreshold>
  31.         <!-- 更改默认的队列的深度,该值会影响性能.默认值为256 -->
  32.         <queueSize>512</queueSize>
  33.         <!-- 添加附加的appender,最多只能添加一个 -->
  34.         <appender-ref ref="FILE"/>
  35.     </appender>
  36.  
  37.  
  38.     <logger name="org.apache.ibatis.cache.decorators.LoggingCache" level="DEBUG" additivity="false">
  39.         <appender-ref ref="CONSOLE"/>
  40.     </logger>
  41.     <logger name="org.springframework.boot" level="debug"/>
  42.     <root level="info">
  43.         <!--<appender-ref ref="ASYNC"/>-->
  44.         <appender-ref ref="FILE"/>
  45.         <appender-ref ref="CONSOLE"/>
  46.     </root>
  47. </configuration>

在nacos配置中心创建配置文件leadnews-admin.yml

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

⑤接口定义

说明
接口地址/login/in
请求方式POST
参数AdUserDto
响应结果ResponseResult

新增AdUserDto

  1. package com.heima.model.admin.dtos;
  2.  
  3. import lombok.Data;
  4.  
  5. @Data
  6. public class AdUserDto {
  7.     /**
  8.      * 用户名
  9.      */
  10.     private String name;
  11.     /**
  12.      * 密码
  13.      */
  14.     private String password;
  15. }

⑥新建AdUserMapper

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

⑦新增LoginController

  1. package com.heima.admin.controller.v1;
  2.  
  3. import com.heima.admin.service.AdUserService;
  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. @RestController
  13. @RequestMapping("/login")
  14. public class LoginController {
  15.     @Autowired
  16.     private AdUserService adUserService;
  17.  
  18.     @PostMapping("/in")
  19.     public ResponseResult login(@RequestBody AdUserDto dto) {
  20.         return adUserService.login(dto);
  21.     }
  22. }

⑧新增AdUserService

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

⑨新增实现类AdUserServiceImpl

  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.AdUserMapper;
  6. import com.heima.admin.service.AdUserService;
  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.transaction.annotation.Transactional;
  16. import org.springframework.util.DigestUtils;
  17.  
  18. import java.util.HashMap;
  19. import java.util.Map;
  20.  
  21. @Service
  22. @Slf4j
  23. @Transactional
  24. public class AdUserServiceImpl extends ServiceImpl<AdUserMapper, AdUser> implements AdUserService {
  25.     /**
  26.      * 登录
  27.      * @param dto
  28.      * @return
  29.      */
  30.     @Override
  31.     public ResponseResult login(AdUserDto dto) {
  32.         // 1. 检查参数
  33.         if(StringUtils.isBlank(dto.getName()) || StringUtils.isBlank(dto.getPassword())) {
  34.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID, "用户名或密码不能为空");
  35.         }
  36.  
  37.         // 2. 查询用户
  38.         AdUser user = getOne(Wrappers.<AdUser>lambdaQuery().eq(AdUser::getName, dto.getName()));
  39.         if(user == null) {
  40.             return ResponseResult.errorResult(AppHttpCodeEnum.DATA_NOT_EXIST, "用户不存在");
  41.         }
  42.  
  43.         // 3. 比对密码
  44.         String salt = user.getSalt();
  45.         String password = dto.getPassword();
  46.         // md5加密
  47.         password = DigestUtils.md5DigestAsHex((password + salt).getBytes());
  48.         if(password.equals(user.getPassword())) {
  49.             // 4. 返回数据 - jwt
  50.             Map<String, Object> map = new HashMap<>();
  51.             map.put("token", AppJwtUtil.getToken(user.getId().longValue()));
  52.             user.setSalt("");
  53.             user.setPassword("");
  54.             map.put("user", user);
  55.  
  56.             return ResponseResult.okResult(map);
  57.         } else {
  58.             // 密码错误
  59.             return ResponseResult.errorResult(AppHttpCodeEnum.LOGIN_PASSWORD_ERROR);
  60.         }
  61.     }
  62. }

⑩新增引导类AdminApplication

  1. package com.heima.admin;
  2.  
  3. import org.mybatis.spring.annotation.MapperScan;
  4. import org.springframework.boot.SpringApplication;
  5. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  7.  
  8. @SpringBootApplication
  9. @MapperScan("com.heima.admin.mapper")
  10. @EnableDiscoveryClient
  11. public class AdminApplication {
  12.     public static void main(String[] args) {
  13.         SpringApplication.run(AdminApplication.class, args);
  14.     }
  15. }

2. 网关

步骤①：创建模块heima-leadnews-admin-gateway

②在heima-leadnews-admin-gateway的resources文件夹下新增bootstrap.yml

  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

③新增引导类AdminGatewayApplication

  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. @SpringBootApplication
  8. @EnableDiscoveryClient
  9. public class AdminGatewayApplication {
  10.     public static void main(String[] args) {
  11.         SpringApplication.run(AdminGatewayApplication.class, args);
  12.     }
  13. }

④在nacos配置中心添加leadnews-admin-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: admin
  19.           uri: lb://leadnews-admin
  20.           predicates:
  21.             - Path=/admin/**
  22.           filters:
  23.             - StripPrefix= 1
  24.         # 用户微服务
  25.         - id: user
  26.           uri: lb://leadnews-user
  27.           predicates:
  28.             - Path=/user/**
  29.           filters:
  30.             - StripPrefix= 1
  31.         # 文章微服务
  32.         - id: article
  33.           uri: lb://leadnews-article
  34.           predicates:
  35.             - Path=/article/**
  36.           filters:
  37.             - StripPrefix= 1
  38.         # 频道微服务
  39.         - id: wemedia
  40.           uri: lb://leadnews-wemedia
  41.           predicates:
  42.             - Path=/wemedia/**
  43.           filters:
  44.             - StripPrefix= 1
  45.         # 敏感词微服务
  46.         - id: sensitive
  47.           uri: lb://leadnews-sensitive
  48.           predicates:
  49.             - Path=/sensitive/**
  50.           filters:
  51.             - StripPrefix= 1
  52.         #搜索微服务
  53.         - id: leadnews-search
  54.           uri: lb://leadnews-search
  55.           predicates:
  56.             - Path=/search/**
  57.           filters:
  58.             - StripPrefix= 1

⑤拷贝一份jwt解析工具类到AppJwtUtil到admin-gateway模块下

  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. }

⑥在admin网关微服务中新建全局过滤器

  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.             // 判断token是否过期
  45.             int result = AppJwtUtil.verifyToken(claimsBody);
  46.             if (result == 1 || result == 2) {
  47.                 response.setStatusCode(HttpStatus.UNAUTHORIZED);
  48.                 return response.setComplete();
  49.             }
  50.  
  51.             // 获取token解析后的用户信息
  52.             Object userId = claimsBody.get("id");
  53.  
  54.             // 存入header中
  55.             ServerHttpRequest serverHttpRequest = request.mutate().headers(httpHeaders -> {
  56.                 httpHeaders.add("userId", userId + "");
  57.             }).build();
  58.  
  59.             // 重置请求
  60.             exchange.mutate().request(serverHttpRequest);
  61.  
  62.         } catch (Exception e) {
  63.             e.printStackTrace();
  64.             response.setStatusCode(HttpStatus.UNAUTHORIZED);
  65.             return response.setComplete();
  66.         }
  67.  
  68.         // 6. 放行
  69.         return chain.filter(exchange);
  70.     }
  71.  
  72.     /**
  73.      * 优先级设置：值越小，优先级越高
  74.      * @return
  75.      */
  76.     @Override
  77.     public int getOrder() {
  78.         return 0;
  79.     }
  80. }

⑦启动AdminGatewayApplication和AdminApplication进行测试

三、频道管理

1. 新增频道

（1）需求分析

  • 前台输入内容进行频道的保存
  • 频道名称不能重复

（2）接口定义

说明
接口地址/api/v1/channel/save
请求方式POST
参数WmChannel
响应结果ResponseResult

（3）实现步骤

wemedia模块

步骤①：新增接口 - WmChannelController

  1.     /**
  2.      * 新增频道
  3.      * @param adChannel
  4.      * @return
  5.      */
  6.     @PostMapping("/save")
  7.     public ResponseResult insert(@RequestBody WmChannel adChannel) {
  8.         return wmChannelService.insert(adChannel);
  9.     }

②业务层 - WmChannelService

  1.     /**
  2.      * 新增保存频道
  3.      * @param adChannel
  4.      * @return
  5.      */
  6.     ResponseResult insert(WmChannel adChannel);

③实现类 - WmChannelServiceImpl

  1.     /**
  2.      * 新增保存频道
  3.      * @param adChannel
  4.      * @return
  5.      */
  6.     @Override
  7.     public ResponseResult insert(WmChannel adChannel) {
  8.         // 1. 检查参数
  9.         if(adChannel == null) {
  10.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
  11.         }
  12.         // 检查是否存在频道名称相同的情况
  13.         WmChannel channel = getOne(Wrappers.<WmChannel>lambdaQuery().eq(WmChannel::getName, adChannel.getName()));
  14.         if(channel != null) {
  15.             return ResponseResult.errorResult(AppHttpCodeEnum.DATA_EXIST, "频道已存在");
  16.         }
  17.  
  18.         // 2. 保存频道
  19.         adChannel.setCreatedTime(new Date());
  20.         save(adChannel);
  21.  
  22.         return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
  23.     }

2. 查询频道列表

（1）需求分析

  • 查询需要按照创建时间倒序查询
  • 按照频道名称模糊查询
  • 可以按照状态进行精确查找（1：启用 true 0：禁用 false）
  • 分页查询

（2）接口定义

说明
接口地址/api/v1/channel/list
请求方式POST
参数ChannelDto
响应结果ResponseResult

（3）实现步骤

步骤①：新增实体类ChannelDto

  1. package com.heima.model.wemedia.dtos;
  2.  
  3. import com.heima.model.common.dtos.PageRequestDto;
  4. import io.swagger.annotations.ApiModelProperty;
  5. import lombok.Data;
  6.  
  7. @Data
  8. public class ChannelDto extends PageRequestDto {
  9.     /**
  10.      * 频道名称
  11.      */
  12.     @ApiModelProperty(value = "频道名称")
  13.     private String name;
  14. }

②WmChannelController中新增接口

  1.     /**
  2.      * 根据频道名称模糊分页查询
  3.      * @param dto
  4.      * @return
  5.      */
  6.     @PostMapping("/list")
  7.     public ResponseResult findByNameAndPage(@RequestBody ChannelDto dto) {
  8.         return wmChannelService.findByNameAndPage(dto);
  9.     }

③WmChannelService

  1.     /**
  2.      * 根据频道名称模糊分页查询
  3.      * @param dto
  4.      * @return
  5.      */
  6.     ResponseResult findByNameAndPage(ChannelDto dto);

④WmChannelServiceImpl

  1.     /**
  2.      * 根据频道名称模糊分页查询
  3.      * @param dto
  4.      * @return
  5.      */
  6.     @Override
  7.     public ResponseResult findByNameAndPage(ChannelDto dto) {
  8.         // 1. 检查参数
  9.         if(dto == null) {
  10.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
  11.         }
  12.  
  13.         // 2. 检查分页
  14.         dto.checkParam();
  15.  
  16.         // 3. 模糊查询 + 分页
  17.         IPage page = new Page(dto.getPage(), dto.getSize());
  18.         // 频道名称模糊查询
  19.         LambdaQueryWrapper<WmChannel> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  20.         if(StringUtils.isNotBlank(dto.getName())) {
  21.             lambdaQueryWrapper.like(WmChannel::getName, dto.getName());
  22.         }
  23.  
  24.         page = page(page, lambdaQueryWrapper);
  25.  
  26.         // 4. 结果返回
  27.         ResponseResult responseResult = new PageResponseResult(dto.getPage(), dto.getSize(), (int)page.getTotal());
  28.         responseResult.setData(page.getRecords());
  29.  
  30.         return responseResult;
  31.     }

⑤启动以下服务进行测试

3. 修改频道

（1）需求分析

  • 点击编辑后可以修改频道
  • 如果频道被引用则不能禁用

（2）接口定义

说明
接口地址/api/v1/channel/update
请求方式POST
参数WmChannel
响应结果ResponseResult

（3）实现步骤

步骤①：WmChannelController新增接口

  1.     /**
  2.      * 修改频道信息
  3.      * @param adChannel
  4.      * @return
  5.      */
  6.     @PostMapping("/update")
  7.     public ResponseResult update(@RequestBody WmChannel adChannel) {
  8.         return wmChannelService.update(adChannel);
  9.     }

②WmChannelService新增业务

  1.     /**
  2.      * 修改频道信息
  3.      * @param adChannel
  4.      * @return
  5.      */
  6.     ResponseResult update(WmChannel adChannel);

③WmChannelServiceImpl实现业务方法

  1.     /**
  2.      * 修改频道信息
  3.      * @param adChannel
  4.      * @return
  5.      */
  6.     @Override
  7.     public ResponseResult update(WmChannel adChannel) {
  8.         // 1. 检查参数
  9.         if(adChannel == null || adChannel.getId() == null) {
  10.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
  11.         }
  12.  
  13.         // 2. 判断频道是否被已发布的文章引用
  14.         int count = wmNewsService.count(Wrappers
  15.                 .<WmNews>lambdaQuery()
  16.                 .eq(WmNews::getChannelId, adChannel.getId())
  17.                 .eq(WmNews::getStatus, WmNews.Status.PUBLISHED.getCode()));
  18.  
  19.         if(count > 0) {
  20.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID, "频道被引用不能修改或禁用");
  21.         }
  22.  
  23.         // 3. 修改
  24.         updateById(adChannel);
  25.  
  26.         // 4. 返回结果
  27.         return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
  28.     }

④测试

4. 删除频道

（1）需求分析

  • 只有禁用的频道才能被删除

（2）接口定义

说明
接口地址/api/v1/channel/del/{id}
请求方式GET
参数频道id
响应结果ResponseResult

（3）实现步骤

步骤①：新增接口 - WmChannelController

  1.     /**
  2.      * 删除频道
  3.      * @param id
  4.      * @return
  5.      */
  6.     @GetMapping("del/{id}")
  7.     public ResponseResult delete(@PathVariable("id") Integer id) {
  8.         return wmChannelService.delete(id);
  9.     }

②新增业务方法 - WmChannelService

  1.     /**
  2.      * 删除频道
  3.      * @param id
  4.      * @return
  5.      */
  6.     ResponseResult delete(Integer id);

③实现 - WmChannelServiceImpl

  1.     /**
  2.      * 删除频道
  3.      * @param id
  4.      * @return
  5.      */
  6.     @Override
  7.     public ResponseResult delete(Integer id) {
  8.         // 1. 检查参数
  9.         if(id == null) {
  10.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
  11.         }
  12.  
  13.         // 2. 查询频道
  14.         WmChannel wmChannel = getById(id);
  15.         if(wmChannel == null) {
  16.             return ResponseResult.errorResult(AppHttpCodeEnum.DATA_NOT_EXIST);
  17.         }
  18.  
  19.         // 3. 频道是否有效 -> 启动
  20.         if(wmChannel.getStatus()) {
  21.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID, "频道有效，不能删除");
  22.         }
  23.  
  24.         // 4. 判断频道是否被已发表的文章引用
  25.         int count = wmNewsService.count(Wrappers
  26.                 .<WmNews>lambdaQuery()
  27.                 .eq(WmNews::getChannelId, wmChannel.getId())
  28.                 .eq(WmNews::getStatus, WmNews.Status.PUBLISHED.getCode()));
  29.         if(count > 0) {
  30.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID, "频道被引用，不能删除");
  31.         }
  32.  
  33.         // 5. 删除频道
  34.         removeById(id);
  35.  
  36.         return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
  37.     }

④测试

四、敏感词管理

1. 新增敏感词

（1）需求分析

  • 弹出的输入框，输入敏感词可直接保存
  • 已存在的敏感词则不能保存

（2）接口定义

说明
接口地址/api/v1/sensitive/save
请求方式POST
参数WmSensitive
响应结果ResponseResult

（3）实现步骤

步骤①：在model模块的wemedia模块新增SentitiveDto 

  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 SensitiveDto extends PageRequestDto {
  8.  
  9.     /**
  10.      * 敏感词名称
  11.      */
  12.     private String name;
  13. }

②wemedia模块mapper下新增WmSensitiveMapper

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

③WmSensitiveController

  1. package com.heima.wemedia.controller.v1;
  2.  
  3. import com.heima.model.common.dtos.ResponseResult;
  4. import com.heima.model.wemedia.pojos.WmSensitive;
  5. import com.heima.wemedia.service.WmSensitiveService;
  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/sensitive")
  14. public class WmSensitiveController {
  15.     @Autowired
  16.     private WmSensitiveService wmSensitiveService;
  17.  
  18.     /**
  19.      * 新增敏感词
  20.      * @param wmSensitive
  21.      * @return
  22.      */
  23.     @PostMapping("/save")
  24.     public ResponseResult insert(@RequestBody WmSensitive wmSensitive) {
  25.         return wmSensitiveService.insert(wmSensitive);
  26.     }
  27.  
  28. }

④WmSensitiveService

  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.WmSensitive;
  6.  
  7. public interface WmSensitiveService extends IService<WmSensitive> {
  8.  
  9.     /**
  10.      * 新增敏感词
  11.      * @param wmSensitive
  12.      * @return
  13.      */
  14.     ResponseResult insert(WmSensitive wmSensitive);
  15. }

⑤WmSensitiveServiceImpl

  1. package com.heima.wemedia.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.toolkit.Wrappers;
  4. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  5. import com.heima.model.common.dtos.ResponseResult;
  6. import com.heima.model.common.enums.AppHttpCodeEnum;
  7. import com.heima.model.wemedia.pojos.WmSensitive;
  8. import com.heima.wemedia.mapper.WmSensitiveMapper;
  9. import com.heima.wemedia.service.WmSensitiveService;
  10. import lombok.extern.slf4j.Slf4j;
  11. import org.springframework.stereotype.Service;
  12. import org.springframework.transaction.annotation.Transactional;
  13.  
  14. import java.util.Date;
  15.  
  16. @Service
  17. @Slf4j
  18. @Transactional
  19. public class WmSensitiveServiceImpl extends ServiceImpl<WmSensitiveMapper, WmSensitive> implements WmSensitiveService {
  20.  
  21.  
  22.     /**
  23.      * 新增敏感词
  24.      * @param wmSensitive
  25.      * @return
  26.      */
  27.     @Override
  28.     public ResponseResult insert(WmSensitive wmSensitive) {
  29.         // 1. 检查参数
  30.         if(wmSensitive == null) {
  31.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
  32.         }
  33.  
  34.         // 2. 已存在的敏感词，不能保存
  35.         WmSensitive sensitive = getOne(Wrappers
  36.                 .<WmSensitive>lambdaQuery()
  37.                 .eq(WmSensitive::getSensitives, wmSensitive.getSensitives()));
  38.         if(sensitive != null) {
  39.             return ResponseResult.errorResult(AppHttpCodeEnum.DATA_EXIST, "敏感词已存在");
  40.         }
  41.  
  42.         // 3. 保存敏感词
  43.         wmSensitive.setCreatedTime(new Date());
  44.         save(wmSensitive);
  45.  
  46.         return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
  47.     }
  48. }

⑥测试

2. 查询敏感词列表

（1）需求分析

  • 查询需要按照创建时间倒序查询
  • 按照敏感词名称模糊查询
  • 分页查询

（2）接口定义

说明
接口地址/api/v1/sensitive/list
请求方式POST
参数SensitiveDto
响应结果ResponseResult

（3）实现步骤

步骤①：在WmSensitiveController新增接口

  1.     /**
  2.      * 查询敏感词列表
  3.      * @param dto
  4.      * @return
  5.      */
  6.     @PostMapping("/list")
  7.     public ResponseResult list(@RequestBody SensitiveDto dto) {
  8.         return wmSensitiveService.list(dto);
  9.     }

②WmSensitiveService新增业务方法

  1.     /**
  2.      * 查询敏感词列表
  3.      * @param dto
  4.      * @return
  5.      */
  6.     ResponseResult list( SensitiveDto dto);

③WmSenstiveServiceImpl实现业务方法

  1.     /**
  2.      * 查询敏感词列表
  3.      * @param dto
  4.      * @return
  5.      */
  6.     @Override
  7.     public ResponseResult list(SensitiveDto dto) {
  8.         // 1. 检查参数
  9.         if(dto == null) {
  10.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
  11.         }
  12.  
  13.         // 2. 检查分页
  14.         dto.checkParam();
  15.  
  16.         // 3. 模糊查询 + 分页
  17.         IPage page = new Page(dto.getPage(), dto.getSize());
  18.         LambdaQueryWrapper<WmSensitive> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  19.         if(StringUtils.isNotBlank(dto.getName())) {
  20.             lambdaQueryWrapper.like(WmSensitive::getSensitives, dto.getName());
  21.         }
  22.         page = page(page, lambdaQueryWrapper);
  23.  
  24.         // 4. 结果返回
  25.         ResponseResult responseResult = new PageResponseResult(dto.getPage(), dto.getSize(), (int)page.getTotal());
  26.         responseResult.setData(page.getRecords());
  27.         return responseResult;
  28.     }

④启动ScheduleApplication、AdminApplication、AdminGatewayApplication、WemediaGatewayApplication、WemediaApplication进行测试

3. 修改敏感词

（1）需求分析

（2）接口定义

说明
接口地址/api/v1/sensitive/update
请求方式POST
参数WmSensitive
响应结果ResponseResult

（3）实现步骤

步骤①：WmSensitiveController

  1.     /**
  2.      * 修改敏感词信息
  3.      * @param wmSensitive
  4.      * @return
  5.      */
  6.     @PostMapping("/update")
  7.     public ResponseResult update(@RequestBody WmSensitive wmSensitive) {
  8.         return wmSensitiveService.update(wmSensitive);
  9.     }

②WmSensitiveService

  1.     /**
  2.      * 修改名称信息
  3.      * @param wmSensitive
  4.      * @return
  5.      */
  6.     ResponseResult update(WmSensitive wmSensitive);

③WmSensitiveServiceImpl

  1.     /**
  2.      * 修改敏感词信息
  3.      * @param wmSensitive
  4.      * @return
  5.      */
  6.     @Override
  7.     public ResponseResult update(WmSensitive wmSensitive) {
  8.         // 1. 检查参数
  9.         if(wmSensitive == null || wmSensitive.getId() == null) {
  10.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
  11.         }
  12.  
  13.         // 2. 根据id查询敏感词信息
  14.         WmSensitive sensitive = getById(wmSensitive);
  15.         if(sensitive == null) {
  16.             return ResponseResult.errorResult(AppHttpCodeEnum.DATA_NOT_EXIST);
  17.         }
  18.  
  19.         // 3. 修改敏感词信息
  20.         updateById(wmSensitive);
  21.  
  22.         // 4. 结果返回
  23.         return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
  24.     }

④测试

4. 删除敏感词

（1）需求分析

  • 直接根据敏感词id删除即可

（2）接口定义

说明
接口地址/api/v1/sensitive/del{id}
请求方式DELETE
参数敏感词id
响应结果ResponseResult

（3）实现步骤

步骤①：WmSensitiveController

  1.     /**
  2.      * 删除敏感词
  3.      * @param id
  4.      * @return
  5.      */
  6.     @DeleteMapping("del/{id}")
  7.     public ResponseResult delete(@PathVariable("id") Integer id) {
  8.         return wmSensitiveService.delete(id);
  9.     }

②WmSensitiveService

  1.     /**
  2.      * 删除敏感词
  3.      * @param id
  4.      * @return
  5.      */
  6.     ResponseResult delete(Integer id);

③WmSensitiveImpl

  1.     /**
  2.      * 删除敏感词
  3.      * @param id
  4.      * @return
  5.      */
  6.     @Override
  7.     public ResponseResult delete(Integer id) {
  8.         // 1. 检查参数
  9.         if(id == null) {
  10.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
  11.         }
  12.  
  13.         // 2. 查询敏感词
  14.         WmSensitive wmSensitive = getById(id);
  15.         if(wmSensitive == null) {
  16.             return ResponseResult.errorResult(AppHttpCodeEnum.DATA_NOT_EXIST);
  17.         }
  18.  
  19.         // 3. 删除
  20.         removeById(id);
  21.  
  22.         // 4. 结果返回
  23.         return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
  24.     }

④测试

五、用户认证审核

  • 在app端的个人中心用户可以实名认证，需要材料为：姓名、身份证号、身份证正面照、身份证反面照、手持照片、活体照片（通过微笑、眨眼、张嘴、摇头、点头等组合动作，确保操作的为真实活体人脸），当用户提交审核后就到了后端让运营人员进行审核
  • 平台运营端查看用户认证信息，进行审核，其中审核包括了用户身份审核，需要对接公安系统校验身份证信息
  • 用户通过审核后需要开通自媒体账号（该账户的用户名和密码与app端一致）

1. 分页查询认证查询列表

（1）需求分析

  • 可根据审核状态条件查询
  • 需要分页查询

（2）接口设计

说明
接口地址/api/v1/auth/list
请求方式POST
参数AuthDto
响应结果ResponseResult

（3）实现步骤

步骤①：在leadnews-user模块新增Mapper - ApUserRealnameMapper

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

②在model模块的user模块下新增AuthDto实体类

  1. package com.heima.model.user.dtos;
  2.  
  3. import com.heima.model.common.dtos.PageRequestDto;
  4. import lombok.Data;
  5.  
  6. @Data
  7. public class AuthDto  extends PageRequestDto {
  8.  
  9.     /**
  10.      * 状态
  11.      */
  12.     private Short status;
  13.  
  14.     private Integer id;
  15.  
  16.     //驳回的信息
  17.     private String msg;
  18. }

③在model模块的user模块下新增ApUserRealname实体类

  1. package com.heima.model.user.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.  * APP实名认证信息表
  15.  * </p>
  16.  *
  17.  * @author itheima
  18.  */
  19. @Data
  20. @TableName("ap_user_realname")
  21. public class ApUserRealname 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.      * 账号ID
  33.      */
  34.     @TableField("user_id")
  35.     private Integer userId;
  36.  
  37.     /**
  38.      * 用户名称
  39.      */
  40.     @TableField("name")
  41.     private String name;
  42.  
  43.     /**
  44.      * 资源名称
  45.      */
  46.     @TableField("idno")
  47.     private String idno;
  48.  
  49.     /**
  50.      * 正面照片
  51.      */
  52.     @TableField("font_image")
  53.     private String fontImage;
  54.  
  55.     /**
  56.      * 背面照片
  57.      */
  58.     @TableField("back_image")
  59.     private String backImage;
  60.  
  61.     /**
  62.      * 手持照片
  63.      */
  64.     @TableField("hold_image")
  65.     private String holdImage;
  66.  
  67.     /**
  68.      * 活体照片
  69.      */
  70.     @TableField("live_image")
  71.     private String liveImage;
  72.  
  73.     /**
  74.      * 状态
  75.             0 创建中
  76.             1 待审核
  77.             2 审核失败
  78.             9 审核通过
  79.      */
  80.     @TableField("status")
  81.     private Short status;
  82.  
  83.     /**
  84.      * 拒绝原因
  85.      */
  86.     @TableField("reason")
  87.     private String reason;
  88.  
  89.     /**
  90.      * 创建时间
  91.      */
  92.     @TableField("created_time")
  93.     private Date createdTime;
  94.  
  95.     /**
  96.      * 提交时间
  97.      */
  98.     @TableField("submited_time")
  99.     private Date submitedTime;
  100.  
  101.     /**
  102.      * 更新时间
  103.      */
  104.     @TableField("updated_time")
  105.     private Date updatedTime;
  106.  
  107. }

④在leadnews-user模块下新增ApUserRealnameController

  1. package com.heima.user.controller.v1;
  2.  
  3. import com.heima.model.common.dtos.ResponseResult;
  4. import com.heima.model.user.dtos.AuthDto;
  5. import com.heima.user.service.ApUserRealnameService;
  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/auth")
  14. public class ApUserRealnameController {
  15.     @Autowired
  16.     private ApUserRealnameService apUserRealnameService;
  17.  
  18.     /**
  19.      * 查询用户列表
  20.      * @param dto
  21.      * @return
  22.      */
  23.     @PostMapping("/list")
  24.     public ResponseResult list(@RequestBody AuthDto dto) {
  25.         return apUserRealnameService.list(dto);
  26.     }
  27.  
  28. }

⑤ApUserRealnameService

  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.AuthDto;
  6. import com.heima.model.user.pojos.ApUserRealname;
  7.  
  8. public interface ApUserRealnameService extends IService<ApUserRealname> {
  9.  
  10.     /**
  11.      * 分页查询认证列表
  12.      * @param dto
  13.      * @return
  14.      */
  15.     ResponseResult list(AuthDto dto);
  16. }

⑥ApUserRealnameServiceImpl

  1. package com.heima.user.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.user.dtos.AuthDto;
  11. import com.heima.model.user.pojos.ApUserRealname;
  12. import com.heima.user.mapper.ApUserRealnameMapper;
  13. import com.heima.user.service.ApUserRealnameService;
  14. import lombok.extern.slf4j.Slf4j;
  15. import org.springframework.stereotype.Service;
  16. import org.springframework.transaction.annotation.Transactional;
  17.  
  18. @Service
  19. @Slf4j
  20. @Transactional
  21. public class ApUserRealnameServiceImpl extends ServiceImpl<ApUserRealnameMapper, ApUserRealname> implements ApUserRealnameService {
  22.  
  23.     /**
  24.      * 分页查询认证列表
  25.      * @param dto
  26.      * @return
  27.      */
  28.     @Override
  29.     public ResponseResult list(AuthDto dto) {
  30.         // 1. 检查参数
  31.         if(dto == null) {
  32.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
  33.         }
  34.  
  35.         // 2. 分页条件查询
  36.         dto.checkParam();
  37.  
  38.         // 3. 分页根据状态精确查询
  39.         IPage page = new Page(dto.getPage(), dto.getSize());
  40.         LambdaQueryWrapper<ApUserRealname> lambdaQueryWrapper = new LambdaQueryWrapper<>();
  41.         if (dto.getStatus() != null) {
  42.             lambdaQueryWrapper.eq(ApUserRealname::getStatus, dto.getStatus());
  43.         }
  44.         page = page(page, lambdaQueryWrapper);
  45.  
  46.         // 4. 结果返回
  47.         ResponseResult responseResult = new PageResponseResult(dto.getPage(), dto.getSize(), (int)page.getTotal());
  48.         responseResult.setData(page.getRecords());
  49.  
  50.         return responseResult;
  51.     }
  52. }

⑦测试

2. 审核失败

（1）需求分析

  • 审核不通过，拒绝注册为自媒体用户

（2）接口设计

说明
接口地址/api/v1/auth/authFail
请求方式POST
参数AuthDto
响应结果ResponseResult

（3）实现步骤

步骤①：在common模块新增常量类 UserConstants

  1. package com.heima.common.constants;
  2.  
  3. public class UserConstants {
  4.     public static final Short PASS_AUTH = 9;
  5.     public static final Short FAIL_AUTH = 2;
  6.     public static final Integer AUTH_TYPE = 2;
  7. }

②ApUserRealnameController

  1.     /**
  2.      * 审核不通过
  3.      * @param dto
  4.      * @return
  5.      */
  6.     @PostMapping("/authFail")
  7.     public ResponseResult authFail(@RequestBody AuthDto dto) {
  8.         return apUserRealnameService.updateByStatus(dto, UserConstants.FAIL_AUTH);
  9.     }

③ApUserRealnameService

  1.     /**
  2.      * 根据审核状态更新审核结果
  3.      * @param dto
  4.      * @param status 2审核失败 9审核成功
  5.      * @return
  6.      */
  7.     ResponseResult updateByStatus(AuthDto dto, Short status);

④ApUserRealnameServiceImpl

  1.     /**
  2.      * 根据状态更新审核结果
  3.      * @param dto
  4.      * @param status 2审核失败 9审核成功
  5.      * @return
  6.      */
  7.     @Override
  8.     public ResponseResult updateByStatus(AuthDto dto, Short status) {
  9.         // 1. 检查参数
  10.         if(dto == null || dto.getId() == null) {
  11.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
  12.         }
  13.  
  14.         // 2. 修改认证状态
  15.         ApUserRealname apUserRealname = new ApUserRealname();
  16.         apUserRealname.setId(dto.getId());
  17.         apUserRealname.setStatus(status);
  18.         apUserRealname.setUpdatedTime(new Date());
  19.         if(StringUtils.isNotBlank(dto.getMsg())) {
  20.             // 审核不通过原因
  21.             apUserRealname.setReason(dto.getMsg());
  22.         }
  23.         updateById(apUserRealname);
  24.  
  25.         // 3. 如果审核状态为成功->9，需要创建自媒体账户
  26.         if(status.equals(UserConstants.PASS_AUTH)) {
  27.             // 通过审核
  28.             ResponseResult responseResult = createWmUserAndAuthor(dto);
  29.             if(responseResult != null) {
  30.                 return responseResult;
  31.             }
  32.         }
  33.  
  34.         // 4. 返回结果
  35.         return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
  36.     }
  37.  
  38.     /**
  39.      * 创建自媒体账户
  40.      * @param dto
  41.      * @return
  42.      */
  43.     private ResponseResult createWmUserAndAuthor(AuthDto dto) {
  44.         Integer userRealnameId = dto.getId();
  45.         // 1. 查询用户认证信息
  46.         ApUserRealname apUserRealname = getById(userRealnameId);
  47.         if(apUserRealname == null) {
  48.             return ResponseResult.errorResult(AppHttpCodeEnum.DATA_NOT_EXIST);
  49.         }
  50.  
  51.         // 2. 查询app端用户信息
  52.         Integer userId = apUserRealname.getUserId();
  53.         ApUser apUser = apUserMapper.selectById(userId);
  54.         if(apUser == null) {
  55.             return ResponseResult.errorResult(AppHttpCodeEnum.DATA_NOT_EXIST);
  56.         }
  57.  
  58.         // 3. 创建自媒体用户
  59.         WmUser wmUser =wemediaClient.findWmUserByName(apUser.getName());
  60.         if(wmUser == null) {
  61.             wmUser = new WmUser();
  62.             wmUser.setApUserId(apUser.getId());
  63.             wmUser.setCreatedTime(new Date());
  64.             wmUser.setName(apUser.getName());
  65.             wmUser.setPassword(apUser.getPassword());
  66.             wmUser.setSalt(apUser.getSalt());
  67.             wmUser.setPhone(apUser.getPhone());
  68.             wmUser.setStatus(9);
  69.             wemediaClient.saveWmUser(wmUser);
  70.         }
  71.  
  72.         apUser.setFlag((short) 1);
  73.         apUserMapper.updateById(apUser);
  74.  
  75.         return null;
  76.     }

⑤在heima-leadnews-feign-api添加远程调用接口 - IWemediaClient

  1. package com.heima.apis.wemedia;
  2.  
  3. import com.heima.model.common.dtos.ResponseResult;
  4. import com.heima.model.wemedia.pojos.WmUser;
  5. import org.springframework.cloud.openfeign.FeignClient;
  6. import org.springframework.web.bind.annotation.GetMapping;
  7. import org.springframework.web.bind.annotation.PathVariable;
  8. import org.springframework.web.bind.annotation.PostMapping;
  9. import org.springframework.web.bind.annotation.RequestBody;
  10.  
  11. @FeignClient("leadnews-wemedia")
  12. public interface IWemediaClient {
  13.  
  14.  
  15.     @GetMapping("/api/v1/user/findByName/{name}")
  16.     WmUser findWmUserByName(@PathVariable("name") String name);
  17.  
  18.     @PostMapping("/api/v1/wm_user/save")
  19.     ResponseResult saveWmUser(@RequestBody WmUser wmUser);
  20.  
  21.     @GetMapping("/api/v1/channel/list")
  22.     public ResponseResult getChannels();
  23. }

⑥在heima-leadnews-wemedia新增feign包，新增WemediaClient类

  1. package com.heima.wemedia.feign;
  2.  
  3. import com.baomidou.mybatisplus.core.toolkit.Wrappers;
  4. import com.heima.apis.wemedia.IWemediaClient;
  5. import com.heima.model.common.dtos.ResponseResult;
  6. import com.heima.model.common.enums.AppHttpCodeEnum;
  7. import com.heima.model.wemedia.pojos.WmUser;
  8. import com.heima.wemedia.service.WmChannelService;
  9. import com.heima.wemedia.service.WmUserService;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.web.bind.annotation.*;
  12.  
  13. @RestController
  14. public class WemediaClient implements IWemediaClient {
  15.  
  16.     @Autowired
  17.     private WmUserService wmUserService;
  18.  
  19.     @Override
  20.     @GetMapping("/api/v1/user/findByName/{name}")
  21.     public WmUser findWmUserByName(@PathVariable("name") String name) {
  22.         return wmUserService.getOne(Wrappers.<WmUser>lambdaQuery().eq(WmUser::getName, name));
  23.     }
  24.  
  25.     @Override
  26.     @PostMapping("/api/v1/wm_user/save")
  27.     public ResponseResult saveWmUser(@RequestBody WmUser wmUser) {
  28.         wmUserService.save(wmUser);
  29.         return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
  30.     }
  31.  
  32.     @Autowired
  33.     private WmChannelService wmChannelService;
  34.  
  35.     @GetMapping("/api/v1/channel/list")
  36.     @Override
  37.     public ResponseResult getChannels() {
  38.         return wmChannelService.findAll();
  39.     }
  40. }

⑦在user模块开启远程调用

  1. package com.heima.user;
  2.  
  3. import org.mybatis.spring.annotation.MapperScan;
  4. import org.springframework.boot.SpringApplication;
  5. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  7. import org.springframework.cloud.openfeign.EnableFeignClients;
  8.  
  9. @SpringBootApplication
  10. @EnableDiscoveryClient
  11. @MapperScan("com.heima.user.mapper")
  12. @EnableFeignClients(basePackages = "com.heima.apis")
  13. public class UserApplication {
  14.     public static void main(String[] args) {
  15.         SpringApplication.run(UserApplication.class, args);
  16.     }
  17. }

3. 审核成功

（1）需求分析

  • 实名认证通过后，为用户新建自媒体用户账户

（2）接口设计

说明
接口地址/api/v1/auth/authPass
请求方式POST
参数AuthDto
响应结果ResponseResult

（3）实现步骤

①ApUserRealnameController

  1.     /**
  2.      * 审核成功
  3.      * @param dto
  4.      * @return
  5.      */
  6.     @PostMapping("/authPass")
  7.     public ResponseResult authPass(@RequestBody AuthDto dto) {
  8.         return apUserRealnameService.updateByStatus(dto, UserConstants.PASS_AUTH);
  9.     }

②重启服务进行测试

ap_user_realname表

wm_user表

六、自媒体文章人工审核

自媒体文章如果没有自动审核成功，而是到了人工审核（自媒体文章状态为3），需要在admin端人工处理文章的审核：

  • 平台管理员可以查看待人工审核的文章信息，如果存在违规内容则驳回（状态修改为2，文章审核失败）
  • 平台管理员可以查看待人工审核的文章信息，如果不存在违规，则需要创建app端的文章信息，并更新自媒体文章的状态
  • 也可以通过点击查看按钮，查看文章详细信息，查看详情后可以根据内容判断是否需要通过审核

1. 查询文章列表

1）需求分析

  • 分页查询自媒体文章
  • 可以按照标题模糊查询
  • 可以按照审核状态ji进行精确检索
  • 文章查询按照创建时间倒序查询
  • 注意：需要展示作者名称

（2）接口设计

说明
接口地址/api/v1/news/list_vo
请求方式POST
参数NewsAuthDto
响应结果ResponseResult

（3）实现步骤

步骤①：在model模块下的wemedia新增实体类WmNewsVo  

  1. package com.heima.model.wemedia.vo;
  2.  
  3. import com.heima.model.wemedia.pojos.WmNews;
  4. import lombok.Data;
  5.  
  6. @Data
  7. public class WmNewsVo  extends WmNews {
  8.     /**
  9.      * 作者名称
  10.      */
  11.     private String authorName;
  12. }

②在heima-leadnews-wemedia模块新增WmNewsMapper

  1. package com.heima.wemedia.mapper;
  2.  
  3. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  4. import com.heima.model.wemedia.dtos.NewsAuthDto;
  5. import com.heima.model.wemedia.pojos.WmNews;
  6. import com.heima.model.wemedia.vo.WmNewsVo;
  7. import org.apache.ibatis.annotations.Mapper;
  8. import org.apache.ibatis.annotations.Param;
  9.  
  10. import java.util.List;
  11.  
  12. @Mapper
  13. public interface WmNewsMapper extends BaseMapper<WmNews> {
  14.  
  15.     List<WmNewsVo> findListAndPage(@Param("dto") NewsAuthDto dto);
  16.  
  17.     int findListCount(@Param("dto") NewsAuthDto dto);
  18. }

③在resources/mapper下新建对应的映射文件 - WmNewsMapper.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.WmNewsMapper">
  4.     <select id="findListAndPage" parameterType="com.heima.model.wemedia.dtos.NewsAuthDto"
  5.     resultType="com.heima.model.wemedia.vo.WmNewsVo">
  6.         SELECT
  7.             wn.*,wu.`name` authorName
  8.         FROM
  9.             wm_news  wn
  10.                 LEFT JOIN
  11.             wm_user wu
  12.             ON wn.user_id = wu.id
  13.         <where>
  14.             <if test="dto.title!=null and dto.title!=''">
  15.                 and wn.title like concat('%',#{dto.title},'%')
  16.             </if>
  17.             <if test="dto.status!=null">
  18.                 and wn.status = #{dto.status}
  19.             </if>
  20.         </where>
  21.         limit #{dto.page},#{dto.size}
  22.     </select>
  23.  
  24.     <select id="findListCount" parameterType="com.heima.model.wemedia.dtos.NewsAuthDto"
  25.             resultType="int">
  26.         SELECT
  27.         count(1)
  28.         FROM
  29.         wm_news  wn
  30.         LEFT JOIN
  31.         wm_user wu
  32.         ON wn.user_id = wu.id
  33.         <where>
  34.             <if test="dto.title!=null and dto.title!=''">
  35.                 and wn.title like concat('%',#{dto.title},'%')
  36.             </if>
  37.             <if test="dto.status!=null">
  38.                 and wn.status = #{dto.status}
  39.             </if>
  40.         </where>
  41.  
  42.     </select>
  43.  
  44. </mapper>

④WmNewsController新增接口

  1.     /**
  2.      * 查询（待审核）文章列表
  3.      * @param dto
  4.      * @return
  5.      */
  6.     @PostMapping("/list_vo")
  7.     public ResponseResult findList(@RequestBody NewsAuthDto dto) {
  8.         return wmNewsService.findList(dto);
  9.     }

⑤WmNewsService新增业务方法

  1.     /**
  2.      * 查询文章列表
  3.      * @param dto
  4.      * @return
  5.      */
  6.     ResponseResult findList(NewsAuthDto dto);

⑥WmNewsServiceImpl实现业务方法

  1.     @Autowired
  2.     private WmNewsMapper wmNewsMapper;
  3.  
  4.     /**
  5.      * 查询（待审核）文章列表
  6.      * @param dto
  7.      * @return
  8.      */
  9.     @Override
  10.     public ResponseResult findList(NewsAuthDto dto) {
  11.         // 1. 参数检查
  12.         dto.checkParam();
  13.  
  14.         // 2. 记录当前页
  15.         int currentPage = dto.getPage();
  16.  
  17.         // 3. 分页查询 + count查询
  18.         dto.setPage((dto.getPage() - 1) * dto.getSize());
  19.         List<WmNewsVo> wmNewsVoList = wmNewsMapper.findListAndPage(dto);
  20.         int count = wmNewsMapper.findListCount(dto);
  21.  
  22.         // 4. 结果返回
  23.         ResponseResult responseResult = new PageResponseResult(currentPage, dto.getSize(), count);
  24.         responseResult.setData(wmNewsVoList);
  25.         return responseResult;
  26.     }

⑦测试

2. 查询文章详情

1）需求分析

  • 可以查看文章详细内容
  • 注意：需要展示作者名称

（2）接口设计

说明
接口地址/api/v1/news/one_vo/{id}
请求方式GET
参数文章id
响应结果ResponseResult

（3）实现步骤

步骤①：WmNewsController

  1.     /**
  2.      * 查看文章详情
  3.      * @param id
  4.      * @return
  5.      */
  6.     @GetMapping("/one_vo/{id}")
  7.     public ResponseResult findWmNewsVo(@PathVariable("id") Integer id) {
  8.         return wmNewsService.findWmNewsVo(id);
  9.     }

②WmNewsService

  1.     /**
  2.      * 查看文章详情
  3.      * @param id
  4.      * @return
  5.      */
  6.     ResponseResult findWmNewsVo(Integer id);

③WmNewsServiceImpl

  1.     @Autowired
  2.     private WmUserMapper wmUserMapper;
  3.  
  4.  
  5.     /**
  6.      * 查看文章详情
  7.      * @param id
  8.      * @return
  9.      */
  10.     @Override
  11.     public ResponseResult findWmNewsVo(Integer id) {
  12.         // 1. 检查参数
  13.         if(id == null) {
  14.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
  15.         }
  16.  
  17.         // 2. 查询文章信息
  18.         WmNews wmNews = getById(id);
  19.         if(wmNews == null) {
  20.             return ResponseResult.errorResult(AppHttpCodeEnum.DATA_NOT_EXIST);
  21.         }
  22.  
  23.         // 3. 查询用户信息
  24.         WmUser wmUser = wmUserMapper.selectById(wmNews.getUserId());
  25.  
  26.         // 4. 封装vo返回
  27.         WmNewsVo vo = new WmNewsVo();
  28.         // 属性拷贝
  29.         BeanUtils.copyProperties(wmNews, vo);
  30.         if(wmUser != null) {
  31.             vo.setAuthorName(wmUser.getName());
  32.         }
  33.  
  34.         // 5. 结果返回
  35.         ResponseResult responseResult = new ResponseResult<>().ok(vo);
  36.         return responseResult;
  37.     }

⑦测试

3. 审核失败

1）需求分析

  • 拒绝以后需要给出原因，并修改文章的状态为2

（2）接口设计

说明
接口地址/api/v1/news/auth_fail
请求方式POST
参数NewsAuthDto
响应结果ResponseResult

（3）实现步骤

步骤①：在WemediaConstants添加两个常量

  1.     public static final Short WM_NEWS_AUTH_PASS = 4;
  2.     public static final Short WM_NEWS_AUTH_FAIL = 2;

②WmNewsController

  1.     /**
  2.      * 审核失败
  3.      * @param dto
  4.      * @return
  5.      */
  6.     @PostMapping("/auth_fail")
  7.     public ResponseResult authFail(@RequestBody NewsAuthDto dto) {
  8.         return wmNewsService.updateByStatus(WemediaConstants.WM_NEWS_AUTH_FAIL, dto);
  9.     }

③WmNewsService

  1.     /**
  2.      * 文章审核，修改状态
  3.      * @param status 2审核失败 4审核成功
  4.      * @param dto
  5.      * @return
  6.      */
  7.     ResponseResult updateByStatus(Short status, NewsAuthDto dto);

④WmNewsServiceImpl

  1.     @Override
  2.     public ResponseResult updateByStatus(Short status, NewsAuthDto dto) {
  3.         // 1. 检查参数
  4.         if(dto == null || dto.getId() == null) {
  5.             return ResponseResult.errorResult(AppHttpCodeEnum.PARAM_INVALID);
  6.         }
  7.  
  8.         // 2. 查询文章信息
  9.         WmNews wmNews = getById(dto.getId());
  10.         if(wmNews == null) {
  11.             return ResponseResult.errorResult(AppHttpCodeEnum.DATA_NOT_EXIST);
  12.         }
  13.  
  14.         // 3. 修改文章的状态
  15.         wmNews.setStatus(status);
  16.         if(StringUtils.isNotBlank(dto.getMsg())) {
  17.             wmNews.setReason(dto.getMsg());
  18.         }
  19.         updateById(wmNews);
  20.  
  21.         // 4. 审核成功，则要创建app端文章数据，并修改自媒体文章
  22.         if(status.equals(WemediaConstants.WM_NEWS_AUTH_PASS)) {
  23.             // 创建app端文章数据
  24.             ResponseResult responseResult = wmNewsAutoScanService.saveAppArticle(wmNews);
  25.             if(responseResult.getCode().equals(200)) {
  26.                 wmNews.setArticleId((Long) responseResult.getData());
  27.                 wmNews.setStatus(WmNews.Status.PUBLISHED.getCode());
  28.                 updateById(wmNews);
  29.             }
  30.         }
  31.  
  32.         // 5. 结果返回
  33.         return ResponseResult.okResult(AppHttpCodeEnum.SUCCESS);
  34.     }

⑤WmNewsAutoScanService

  1.     /**
  2.      * 保存app端文章数据
  3.      * @param wmNews
  4.      * @return
  5.      */
  6.     ResponseResult saveAppArticle(WmNews wmNews);

⑥测试

4. 审核成功

1）需求分析

  • 需要创建app端的文章信息，并更新自媒体文章的状态

（2）接口设计

说明
接口地址/api/v1/news/auth_pass
请求方式POST
参数NewsAuthDto
响应结果ResponseResult

（3）实现步骤

①WmNewsController

  1.     /**
  2.      * 审核成功
  3.      * @param dto
  4.      * @return
  5.      */
  6.     @PostMapping("/auth_pass")
  7.     public ResponseResult authPass(@RequestBody NewsAuthDto dto) {
  8.         return wmNewsService.updateByStatus(WemediaConstants.WM_NEWS_AUTH_PASS, dto);
  9.     }

②测试

可能有不对或遗漏的地方，多多谅解！！！

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

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

  

闽ICP备14008679号