0806 新增novel-news模块

novel-cloud-demo/novel-book/novel-book-service/pom.xml

@@ -8,7 +8,7 @@
         <version>1.0-SNAPSHOT</version>
     </parent>
 
-    <groupId>com.sf.book</groupId>
+    <groupId>com.sf</groupId>
     <artifactId>novel-book-service</artifactId>
     <name>novel-book-service</name>
     <description>novel-book-service</description>

novel-cloud-demo/novel-book/novel-book-service/src/main/java/com/sf/book/controller/BookRankController.java

@@ -0,0 +1,48 @@
+package com.sf.book.controller;
+
+import com.sf.book.dto.resp.BookRankRespDto;
+import com.sf.book.service.IBookRankService;
+import com.sf.core.dto.RestResp;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+@Tag(name = "BookRankController", description = "书籍排行榜模块")
+@RestController
+public class BookRankController {
+
+    // 如果有多个实现类 可以通过名字进行对象注入
+    // There is more than one bean of 'IBookRankService' type.
+    @Qualifier("bookRankServiceByRedis")
+//    @Qualifier("bookRankServiceByMysql")
+    @Autowired
+    private IBookRankService bookRankService;
+
+    @Operation(summary = "点击量排行榜接口")
+    @GetMapping("/api/front/book/visit_rank")
+    public RestResp<List<BookRankRespDto>> listVisitRankBooks() {
+        List<BookRankRespDto> bookRankRespDtos = bookRankService.listVisitRankBooks();
+        return RestResp.ok(bookRankRespDtos);
+    }
+
+    @Operation(summary = "新书排行榜接口")
+    @GetMapping("/api/front/book/newest_rank")
+    public RestResp<List<BookRankRespDto>> listNewestRankBooks() {
+        List<BookRankRespDto> bookRankRespDtos = bookRankService.listNewestRankBooks();
+        return RestResp.ok(bookRankRespDtos);
+    }
+
+    @Operation(summary = "更新排行榜接口")
+    @GetMapping("/api/front/book/update_rank")
+    public RestResp<List<BookRankRespDto>> listUpdateRankBooks() {
+        List<BookRankRespDto> bookRankRespDtos = bookRankService.listUpdateRankBooks();
+        return RestResp.ok(bookRankRespDtos);
+    }
+
+
+}

novel-cloud-demo/novel-book/novel-book-service/src/main/java/com/sf/book/dto/resp/BookRankRespDto.java

@@ -0,0 +1,84 @@
+package com.sf.book.dto.resp;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * 小说排行榜 响应DTO
+ *
+ * @author xiongxiaoyang
+ * @date 2022/5/14
+ */
+@Data
+public class BookRankRespDto implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * ID
+     */
+    @Schema(description = "小说ID")
+    private Long id;
+
+    /**
+     * 类别ID
+     */
+    @Schema(description = "类别ID")
+    private Long categoryId;
+
+    /**
+     * 类别名
+     */
+    @Schema(description = "类别名")
+    private String categoryName;
+
+    /**
+     * 小说封面地址
+     */
+    @Schema(description = "小说封面地址")
+    private String picUrl;
+
+    /**
+     * 小说名
+     */
+    @Schema(description = "小说名")
+    private String bookName;
+
+    /**
+     * 作家名
+     */
+    @Schema(description = "作家名")
+    private String authorName;
+
+    /**
+     * 书籍描述
+     */
+    @Schema(description = "书籍描述")
+    private String bookDesc;
+
+    /**
+     * 总字数
+     */
+    @Schema(description = "总字数")
+    private Integer wordCount;
+
+    /**
+     * 最新章节名
+     */
+    @Schema(description = "最新章节名")
+    private String lastChapterName;
+
+    /**
+     * 最新章节更新时间
+     */
+    @Schema(description = "最新章节更新时间")
+    @JsonFormat(pattern = "MM/dd HH:mm")
+    private LocalDateTime lastChapterUpdateTime;
+
+}

novel-cloud-demo/novel-book/novel-book-service/src/main/java/com/sf/book/service/IBookRankService.java

@@ -0,0 +1,36 @@
+package com.sf.book.service;
+
+import com.sf.book.dto.resp.BookRankRespDto;
+
+import java.util.List;
+
+// 为什么service层都是先写接口 再写实现类
+// 虽然大部分时候 一个接口只有一个实现类 但是一个接口是支持多种实现的
+public interface IBookRankService {
+
+    /**
+     * 小说点击榜查询
+     *
+     * @return 小说点击排行列表
+     */
+    List<BookRankRespDto> listVisitRankBooks();
+
+    /**
+     * 小说新书榜查询
+     *
+     * @return 小说新书排行列表
+     */
+    List<BookRankRespDto> listNewestRankBooks();
+
+    /**
+     * 小说更新榜查询
+     *
+     * @return 小说更新排行列表
+     */
+    List<BookRankRespDto> listUpdateRankBooks();
+
+    /**
+     * 更新排行榜中点击量
+     */
+    void updateVisitRank(Long bookId);
+}

novel-cloud-demo/novel-book/novel-book-service/src/main/java/com/sf/book/service/impl/BookRankByRedisServiceImpl.java

@@ -0,0 +1,78 @@
+package com.sf.book.service.impl;
+
+import com.google.gson.Gson;
+import com.sf.book.dto.resp.BookRankRespDto;
+import com.sf.book.entity.BookInfo;
+import com.sf.book.mapper.BookInfoMapper;
+import com.sf.book.service.IBookRankService;
+import com.sf.core.cons.RedisKeyConst;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.BeanUtils;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.ZSetOperations;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Set;
+
+// 基于redis
+@Service("bookRankServiceByRedis")
+@RequiredArgsConstructor
+public class BookRankByRedisServiceImpl implements IBookRankService {
+    // 数据初始化
+    private final BookInfoMapper bookInfoMapper;
+    private final RedisTemplate redisTemplate;
+    private final Gson gson;
+
+    @Override
+    public List<BookRankRespDto> listVisitRankBooks() {
+        return getRankDataByRedis(RedisKeyConst.VISIT_ZSET);
+    }
+
+    @Override
+    public List<BookRankRespDto> listNewestRankBooks() {
+        return getRankDataByRedis(RedisKeyConst.NEW_ZSET);
+    }
+
+    @Override
+    public List<BookRankRespDto> listUpdateRankBooks() {
+        return getRankDataByRedis(RedisKeyConst.UPDATE_ZSET);
+    }
+
+    private List<BookRankRespDto> getRankDataByRedis(String key){
+        ZSetOperations zSetOperations = redisTemplate.opsForZSet();
+        Set<String> set = zSetOperations.reverseRange(key, 0, 29);
+        return set.stream().map(str -> {
+            // 将map中的每一个元素 转化为BookRankRespDto
+            BookInfo bookInfo = gson.fromJson(str, BookInfo.class);
+            BookRankRespDto bookRankRespDto = new BookRankRespDto();
+            BeanUtils.copyProperties(bookInfo, bookRankRespDto);
+            return bookRankRespDto;
+        }).toList();
+    }
+
+    // 数据初始化
+//    private void initData() {
+//        List<BookInfo> bookInfos = bookInfoMapper.selectList(null);
+//        ZSetOperations zSetOperations = redisTemplate.opsForZSet();
+//        for (BookInfo bookInfo : bookInfos) {
+//            Long visitCount = bookInfo.getVisitCount();
+//            String bookInfoJson = gson.toJson(bookInfo);
+//            zSetOperations.add(RedisKeyConst.VISIT_ZSET, bookInfoJson, visitCount);
+//        }
+//    }
+
+
+    // 这是实时榜单的处理逻辑
+    @Override
+    public void updateVisitRank(Long bookId) {
+        BookInfo bookInfo = bookInfoMapper.selectById(bookId);
+        String json = gson.toJson(bookInfo);
+        // 此时的问题 是json中包含了访问量参数 而访问量会频繁变化
+        ZSetOperations zSetOperations = redisTemplate.opsForZSet();
+        // 每一次更新访问量 就将旧的数据移除  新的数据添加进去  保证数据的统一
+        zSetOperations.remove(RedisKeyConst.VISIT_ZSET, json);
+        bookInfo.setVisitCount(bookInfo.getVisitCount() + 1);
+        zSetOperations.add(RedisKeyConst.VISIT_ZSET, gson.toJson(bookInfo), bookInfo.getVisitCount());
+    }
+}

novel-cloud-demo/novel-book/novel-book-service/src/main/java/com/sf/book/service/impl/BookRankServiceImpl.java

@@ -0,0 +1,65 @@
+package com.sf.book.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.sf.book.dto.resp.BookRankRespDto;
+import com.sf.book.entity.BookInfo;
+import com.sf.book.mapper.BookInfoMapper;
+import com.sf.book.service.IBookRankService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+// 基于mysql实现
+@Service("bookRankServiceByMysql")
+@RequiredArgsConstructor
+public class BookRankServiceImpl implements IBookRankService {
+
+    private final BookInfoMapper bookInfoMapper;
+
+    @Override
+    public List<BookRankRespDto> listVisitRankBooks() {
+        LambdaQueryWrapper<BookInfo> bookInfoQueryWrapper = new LambdaQueryWrapper<>();
+        bookInfoQueryWrapper.orderByDesc(BookInfo::getVisitCount);
+        return listRankBooks(bookInfoQueryWrapper);
+    }
+
+    /**
+     * 查询小说新书榜列表，并放入缓存中
+     */
+    @Override
+    public List<BookRankRespDto> listNewestRankBooks() {
+        LambdaQueryWrapper<BookInfo> bookInfoQueryWrapper = new LambdaQueryWrapper<>();
+        bookInfoQueryWrapper.orderByDesc(BookInfo::getCreateTime);
+        return listRankBooks(bookInfoQueryWrapper);
+    }
+
+    /**
+     * 查询小说更新榜列表，并放入缓存中
+     */
+    @Override
+    public List<BookRankRespDto> listUpdateRankBooks() {
+        LambdaQueryWrapper<BookInfo> bookInfoQueryWrapper = new LambdaQueryWrapper<>();
+        bookInfoQueryWrapper.orderByDesc(BookInfo::getUpdateTime);
+        return listRankBooks(bookInfoQueryWrapper);
+    }
+
+    @Override
+    public void updateVisitRank(Long bookId) {
+
+    }
+
+    private List<BookRankRespDto> listRankBooks(LambdaQueryWrapper<BookInfo> bookInfoQueryWrapper) {
+        // 先将不同的排序规则传入 点击量、创建时间、更新时间
+        // 相同的筛选规则是 字数>0 返回30行
+        bookInfoQueryWrapper.gt(BookInfo::getWordCount, 0).last("limit 30");
+        List<BookInfo> bookInfos = bookInfoMapper.selectList(bookInfoQueryWrapper);
+        // 将数据库中的数据 映射成接口要返回的数据dto
+        return bookInfos.stream().map(bookInfo -> {
+            BookRankRespDto respDto = new BookRankRespDto();
+            BeanUtils.copyProperties(bookInfo, respDto);
+            return respDto;
+        }).toList();
+    }
+}

novel-cloud-demo/novel-core/pom.xml

@@ -113,5 +113,10 @@
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>
         </dependency>
+
+        <dependency>
+            <groupId>com.google.code.gson</groupId>
+            <artifactId>gson</artifactId>
+        </dependency>
     </dependencies>
 </project>

novel-cloud-demo/novel-core/src/main/java/com/sf/core/config/GsonConfig.java

@@ -0,0 +1,49 @@
+package com.sf.core.config;
+
+import com.google.gson.*;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+
+/**
+ * 优化Gson对LocalDateTime的转换
+ *
+ * @Author i8023tp
+ **/
+@Configuration
+public class GsonConfig {
+    //序列化
+    final static JsonSerializer<LocalDateTime> jsonSerializerDateTime =
+            (localDateTime, type, jsonSerializationContext)
+                    -> new JsonPrimitive(localDateTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+    final static JsonSerializer<LocalDate> jsonSerializerDate =
+            (localDate, type, jsonSerializationContext)
+                    -> new JsonPrimitive(localDate.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+    //反序列化
+    final static JsonDeserializer<LocalDateTime> jsonDeserializerDateTime =
+            (jsonElement, type, jsonDeserializationContext)
+                    -> LocalDateTime.parse(jsonElement.getAsJsonPrimitive().getAsString(),
+                    DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+    final static JsonDeserializer<LocalDate> jsonDeserializerDate =
+            (jsonElement, type, jsonDeserializationContext)
+                    -> LocalDate.parse(jsonElement.getAsJsonPrimitive().getAsString(),
+                    DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+
+    @Bean
+    @Primary
+    public Gson gson() {
+        return new GsonBuilder()
+                .setPrettyPrinting()
+                /* 更改先后顺序没有影响 */
+                .registerTypeAdapter(LocalDateTime.class, jsonSerializerDateTime)
+                .registerTypeAdapter(LocalDate.class, jsonSerializerDate)
+                .registerTypeAdapter(LocalDateTime.class, jsonDeserializerDateTime)
+                .registerTypeAdapter(LocalDate.class, jsonDeserializerDate)
+                .create();
+    }
+
+}

novel-cloud-demo/novel-core/src/main/java/com/sf/core/util/GeneUtils.java

@@ -19,43 +19,38 @@ public class GeneUtils {
         // 单体项目的路径
         String projectPathTmp = "";
         String packageNameTmp = "";
+        List<String> list = new ArrayList<>();
 
         System.out.println("输入要生成代码的微服务名称: ");
         Scanner scanner = new Scanner(System.in);
         String moduleName = scanner.nextLine();
         switch (moduleName) {
+            // 每个微服务只能调用自己管理的表
+            // 如果需要获取其他表的数据 调用对应微服务的接口
             // home微服务
             case "home":
                 projectPathTmp = "novel-home/";
                 packageNameTmp = ".home";
+//                list.add("home_book");
+//                list.add("home_friend_link"); // 首页友情链接表
                 break;
             // book微服务
             case "book":
                 projectPathTmp = "novel-book/novel-book-service/";
                 packageNameTmp = ".book";
-                break;
-            default:
-        }
 
-        // 因为下列的代码是lambda 所以此处做一个中转
-        String projectPath = projectPathTmp;
-        String packageName = packageNameTmp;
-
-
-        List<String> list = new ArrayList<>();
-        switch (moduleName) {
-            // 每个微服务只能调用自己管理的表
-            // 如果需要获取其他表的数据 调用对应微服务的接口
-            case "home":
-//                list.add("home_book");
-                list.add("home_friend_link"); // 首页友情链接表
-                break;
-            case "book":
 //                list.add("book_info");  // 书籍表
 //                list.add("book_chapter"); // 书籍章节表
 //                list.add("book_content"); // 章节内容表
-                list.add("book_category"); // 书籍种类表
+//                list.add("book_category"); // 书籍种类表
                 break;
+            case "news":
+                projectPathTmp = "novel-news/";
+                packageNameTmp = ".news";
+
+                list.add("news_info"); // 新闻列表
+                list.add("news_content"); // 新闻内容表
+            default:
         }
 //        list.add("home_book");  // 首页书籍信息表
 //        list.add("home_friend_link"); // 首页友情链接表
@@ -72,6 +67,11 @@ public class GeneUtils {
 //        list.add("book_comment"); // 书籍评论表
 //        list.add("author_info"); // 作者信息表
 
+        // 因为下列的代码是lambda 所以此处做一个中转
+        String projectPath = projectPathTmp;
+        String packageName = packageNameTmp;
+
+
         // 快速生成器
         FastAutoGenerator.create("jdbc:mysql://localhost:3306/novel-cloud?useUnicode=true&characterEncoding=utf-8&allowPublicKeyRetrieval=true&useSSL=false&serverTimezone=Asia/Shanghai",
                         "root", "root123456")

novel-cloud-demo/novel-gateway/src/main/resources/application.yml

@@ -32,4 +32,10 @@ spring:
           uri: lb://novel-book-service
           predicates:
             # 路由断言，路径相匹配的进行路由
-            - Path=/api/front/book/**
+            - Path=/api/front/book/**,/api/front/search/**
+        - id: novel-news
+          # 使用loadbalancer负载均衡来分发
+          uri: lb://novel-news
+          predicates:
+            # 路由断言，路径相匹配的进行路由
+            - Path=/api/front/news/**

novel-cloud-demo/novel-home/pom.xml

@@ -8,9 +8,7 @@
 		<version>1.0-SNAPSHOT</version>
 	</parent>
 
-	<groupId>com.sf</groupId>
 	<artifactId>novel-home</artifactId>
-	<version>0.0.1-SNAPSHOT</version>
 	<name>novel-home</name>
 	<description>novel-home</description>
 

novel-cloud-demo/novel-home/src/main/java/com/sf/home/dto/resp/HomeFriendLinkRespDto.java

@@ -0,0 +1,32 @@
+package com.sf.home.dto.resp;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+
+/**
+ * 首页友情链接 响应DTO
+ *
+ * @author xiongxiaoyang
+ * @date 2022/5/14
+ */
+@Data
+public class HomeFriendLinkRespDto implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 链接名
+     */
+    @Schema(description = "链接名")
+    private String linkName;
+
+    /**
+     * 链接url
+     */
+    @Schema(description = "链接url")
+    private String linkUrl;
+}

novel-cloud-demo/novel-home/src/main/java/com/sf/home/service/IHomeFriendLinkService.java

@@ -1,8 +1,11 @@
 package com.sf.home.service;
 
+import com.sf.home.dto.resp.HomeFriendLinkRespDto;
 import com.sf.home.entity.HomeFriendLink;
 import com.baomidou.mybatisplus.extension.service.IService;
 
+import java.util.List;
+
 /**
  * <p>
  * 友情链接 服务类
@@ -12,5 +15,5 @@ import com.baomidou.mybatisplus.extension.service.IService;
  * @since 2024-08-05
  */
 public interface IHomeFriendLinkService extends IService<HomeFriendLink> {
-
+    List<HomeFriendLinkRespDto> listHomeFriendLinks();
 }

novel-cloud-demo/novel-home/src/main/java/com/sf/home/service/impl/HomeFriendLinkServiceImpl.java

@@ -1,11 +1,16 @@
 package com.sf.home.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.sf.home.dto.resp.HomeFriendLinkRespDto;
 import com.sf.home.entity.HomeFriendLink;
 import com.sf.home.mapper.HomeFriendLinkMapper;
 import com.sf.home.service.IHomeFriendLinkService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 /**
  * <p>
  * 友情链接 服务实现类
@@ -15,6 +20,20 @@ import org.springframework.stereotype.Service;
  * @since 2024-08-05
  */
 @Service
+@RequiredArgsConstructor
 public class HomeFriendLinkServiceImpl extends ServiceImpl<HomeFriendLinkMapper, HomeFriendLink> implements IHomeFriendLinkService {
 
+    private final HomeFriendLinkMapper homeFriendLinkMapper;
+
+    @Override
+    public List<HomeFriendLinkRespDto> listHomeFriendLinks() {
+        LambdaQueryWrapper<HomeFriendLink> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.orderByAsc(HomeFriendLink::getSort);
+        return homeFriendLinkMapper.selectList(queryWrapper).stream().map(v -> {
+            HomeFriendLinkRespDto respDto = new HomeFriendLinkRespDto();
+            respDto.setLinkName(v.getLinkName());
+            respDto.setLinkUrl(v.getLinkUrl());
+            return respDto;
+        }).toList();
+    }
 }

novel-cloud-demo/novel-news/.mvn/wrapper/maven-wrapper.properties

@@ -0,0 +1,19 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#   https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+wrapperVersion=3.3.2
+distributionType=only-script
+distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.9.7/apache-maven-3.9.7-bin.zip

novel-cloud-demo/novel-news/mvnw

@@ -0,0 +1,259 @@
+#!/bin/sh
+# ----------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#    https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+# ----------------------------------------------------------------------------
+
+# ----------------------------------------------------------------------------
+# Apache Maven Wrapper startup batch script, version 3.3.2
+#
+# Optional ENV vars
+# -----------------
+#   JAVA_HOME - location of a JDK home dir, required when download maven via java source
+#   MVNW_REPOURL - repo url base for downloading maven distribution
+#   MVNW_USERNAME/MVNW_PASSWORD - user and password for downloading maven
+#   MVNW_VERBOSE - true: enable verbose log; debug: trace the mvnw script; others: silence the output
+# ----------------------------------------------------------------------------
+
+set -euf
+[ "${MVNW_VERBOSE-}" != debug ] || set -x
+
+# OS specific support.
+native_path() { printf %s\\n "$1"; }
+case "$(uname)" in
+CYGWIN* | MINGW*)
+  [ -z "${JAVA_HOME-}" ] || JAVA_HOME="$(cygpath --unix "$JAVA_HOME")"
+  native_path() { cygpath --path --windows "$1"; }
+  ;;
+esac
+
+# set JAVACMD and JAVACCMD
+set_java_home() {
+  # For Cygwin and MinGW, ensure paths are in Unix format before anything is touched
+  if [ -n "${JAVA_HOME-}" ]; then
+    if [ -x "$JAVA_HOME/jre/sh/java" ]; then
+      # IBM's JDK on AIX uses strange locations for the executables
+      JAVACMD="$JAVA_HOME/jre/sh/java"
+      JAVACCMD="$JAVA_HOME/jre/sh/javac"
+    else
+      JAVACMD="$JAVA_HOME/bin/java"
+      JAVACCMD="$JAVA_HOME/bin/javac"
+
+      if [ ! -x "$JAVACMD" ] || [ ! -x "$JAVACCMD" ]; then
+        echo "The JAVA_HOME environment variable is not defined correctly, so mvnw cannot run." >&2
+        echo "JAVA_HOME is set to \"$JAVA_HOME\", but \"\$JAVA_HOME/bin/java\" or \"\$JAVA_HOME/bin/javac\" does not exist." >&2
+        return 1
+      fi
+    fi
+  else
+    JAVACMD="$(
+      'set' +e
+      'unset' -f command 2>/dev/null
+      'command' -v java
+    )" || :
+    JAVACCMD="$(
+      'set' +e
+      'unset' -f command 2>/dev/null
+      'command' -v javac
+    )" || :
+
+    if [ ! -x "${JAVACMD-}" ] || [ ! -x "${JAVACCMD-}" ]; then
+      echo "The java/javac command does not exist in PATH nor is JAVA_HOME set, so mvnw cannot run." >&2
+      return 1
+    fi
+  fi
+}
+
+# hash string like Java String::hashCode
+hash_string() {
+  str="${1:-}" h=0
+  while [ -n "$str" ]; do
+    char="${str%"${str#?}"}"
+    h=$(((h * 31 + $(LC_CTYPE=C printf %d "'$char")) % 4294967296))
+    str="${str#?}"
+  done
+  printf %x\\n $h
+}
+
+verbose() { :; }
+[ "${MVNW_VERBOSE-}" != true ] || verbose() { printf %s\\n "${1-}"; }
+
+die() {
+  printf %s\\n "$1" >&2
+  exit 1
+}
+
+trim() {
+  # MWRAPPER-139:
+  #   Trims trailing and leading whitespace, carriage returns, tabs, and linefeeds.
+  #   Needed for removing poorly interpreted newline sequences when running in more
+  #   exotic environments such as mingw bash on Windows.
+  printf "%s" "${1}" | tr -d '[:space:]'
+}
+
+# parse distributionUrl and optional distributionSha256Sum, requires .mvn/wrapper/maven-wrapper.properties
+while IFS="=" read -r key value; do
+  case "${key-}" in
+  distributionUrl) distributionUrl=$(trim "${value-}") ;;
+  distributionSha256Sum) distributionSha256Sum=$(trim "${value-}") ;;
+  esac
+done <"${0%/*}/.mvn/wrapper/maven-wrapper.properties"
+[ -n "${distributionUrl-}" ] || die "cannot read distributionUrl property in ${0%/*}/.mvn/wrapper/maven-wrapper.properties"
+
+case "${distributionUrl##*/}" in
+maven-mvnd-*bin.*)
+  MVN_CMD=mvnd.sh _MVNW_REPO_PATTERN=/maven/mvnd/
+  case "${PROCESSOR_ARCHITECTURE-}${PROCESSOR_ARCHITEW6432-}:$(uname -a)" in
+  *AMD64:CYGWIN* | *AMD64:MINGW*) distributionPlatform=windows-amd64 ;;
+  :Darwin*x86_64) distributionPlatform=darwin-amd64 ;;
+  :Darwin*arm64) distributionPlatform=darwin-aarch64 ;;
+  :Linux*x86_64*) distributionPlatform=linux-amd64 ;;
+  *)
+    echo "Cannot detect native platform for mvnd on $(uname)-$(uname -m), use pure java version" >&2
+    distributionPlatform=linux-amd64
+    ;;
+  esac
+  distributionUrl="${distributionUrl%-bin.*}-$distributionPlatform.zip"
+  ;;
+maven-mvnd-*) MVN_CMD=mvnd.sh _MVNW_REPO_PATTERN=/maven/mvnd/ ;;
+*) MVN_CMD="mvn${0##*/mvnw}" _MVNW_REPO_PATTERN=/org/apache/maven/ ;;
+esac
+
+# apply MVNW_REPOURL and calculate MAVEN_HOME
+# maven home pattern: ~/.m2/wrapper/dists/{apache-maven-<version>,maven-mvnd-<version>-<platform>}/<hash>
+[ -z "${MVNW_REPOURL-}" ] || distributionUrl="$MVNW_REPOURL$_MVNW_REPO_PATTERN${distributionUrl#*"$_MVNW_REPO_PATTERN"}"
+distributionUrlName="${distributionUrl##*/}"
+distributionUrlNameMain="${distributionUrlName%.*}"
+distributionUrlNameMain="${distributionUrlNameMain%-bin}"
+MAVEN_USER_HOME="${MAVEN_USER_HOME:-${HOME}/.m2}"
+MAVEN_HOME="${MAVEN_USER_HOME}/wrapper/dists/${distributionUrlNameMain-}/$(hash_string "$distributionUrl")"
+
+exec_maven() {
+  unset MVNW_VERBOSE MVNW_USERNAME MVNW_PASSWORD MVNW_REPOURL || :
+  exec "$MAVEN_HOME/bin/$MVN_CMD" "$@" || die "cannot exec $MAVEN_HOME/bin/$MVN_CMD"
+}
+
+if [ -d "$MAVEN_HOME" ]; then
+  verbose "found existing MAVEN_HOME at $MAVEN_HOME"
+  exec_maven "$@"
+fi
+
+case "${distributionUrl-}" in
+*?-bin.zip | *?maven-mvnd-?*-?*.zip) ;;
+*) die "distributionUrl is not valid, must match *-bin.zip or maven-mvnd-*.zip, but found '${distributionUrl-}'" ;;
+esac
+
+# prepare tmp dir
+if TMP_DOWNLOAD_DIR="$(mktemp -d)" && [ -d "$TMP_DOWNLOAD_DIR" ]; then
+  clean() { rm -rf -- "$TMP_DOWNLOAD_DIR"; }
+  trap clean HUP INT TERM EXIT
+else
+  die "cannot create temp dir"
+fi
+
+mkdir -p -- "${MAVEN_HOME%/*}"
+
+# Download and Install Apache Maven
+verbose "Couldn't find MAVEN_HOME, downloading and installing it ..."
+verbose "Downloading from: $distributionUrl"
+verbose "Downloading to: $TMP_DOWNLOAD_DIR/$distributionUrlName"
+
+# select .zip or .tar.gz
+if ! command -v unzip >/dev/null; then
+  distributionUrl="${distributionUrl%.zip}.tar.gz"
+  distributionUrlName="${distributionUrl##*/}"
+fi
+
+# verbose opt
+__MVNW_QUIET_WGET=--quiet __MVNW_QUIET_CURL=--silent __MVNW_QUIET_UNZIP=-q __MVNW_QUIET_TAR=''
+[ "${MVNW_VERBOSE-}" != true ] || __MVNW_QUIET_WGET='' __MVNW_QUIET_CURL='' __MVNW_QUIET_UNZIP='' __MVNW_QUIET_TAR=v
+
+# normalize http auth
+case "${MVNW_PASSWORD:+has-password}" in
+'') MVNW_USERNAME='' MVNW_PASSWORD='' ;;
+has-password) [ -n "${MVNW_USERNAME-}" ] || MVNW_USERNAME='' MVNW_PASSWORD='' ;;
+esac
+
+if [ -z "${MVNW_USERNAME-}" ] && command -v wget >/dev/null; then
+  verbose "Found wget ... using wget"
+  wget ${__MVNW_QUIET_WGET:+"$__MVNW_QUIET_WGET"} "$distributionUrl" -O "$TMP_DOWNLOAD_DIR/$distributionUrlName" || die "wget: Failed to fetch $distributionUrl"
+elif [ -z "${MVNW_USERNAME-}" ] && command -v curl >/dev/null; then
+  verbose "Found curl ... using curl"
+  curl ${__MVNW_QUIET_CURL:+"$__MVNW_QUIET_CURL"} -f -L -o "$TMP_DOWNLOAD_DIR/$distributionUrlName" "$distributionUrl" || die "curl: Failed to fetch $distributionUrl"
+elif set_java_home; then
+  verbose "Falling back to use Java to download"
+  javaSource="$TMP_DOWNLOAD_DIR/Downloader.java"
+  targetZip="$TMP_DOWNLOAD_DIR/$distributionUrlName"
+  cat >"$javaSource" <<-END
+	public class Downloader extends java.net.Authenticator
+	{
+	  protected java.net.PasswordAuthentication getPasswordAuthentication()
+	  {
+	    return new java.net.PasswordAuthentication( System.getenv( "MVNW_USERNAME" ), System.getenv( "MVNW_PASSWORD" ).toCharArray() );
+	  }
+	  public static void main( String[] args ) throws Exception
+	  {
+	    setDefault( new Downloader() );
+	    java.nio.file.Files.copy( java.net.URI.create( args[0] ).toURL().openStream(), java.nio.file.Paths.get( args[1] ).toAbsolutePath().normalize() );
+	  }
+	}
+	END
+  # For Cygwin/MinGW, switch paths to Windows format before running javac and java
+  verbose " - Compiling Downloader.java ..."
+  "$(native_path "$JAVACCMD")" "$(native_path "$javaSource")" || die "Failed to compile Downloader.java"
+  verbose " - Running Downloader.java ..."
+  "$(native_path "$JAVACMD")" -cp "$(native_path "$TMP_DOWNLOAD_DIR")" Downloader "$distributionUrl" "$(native_path "$targetZip")"
+fi
+
+# If specified, validate the SHA-256 sum of the Maven distribution zip file
+if [ -n "${distributionSha256Sum-}" ]; then
+  distributionSha256Result=false
+  if [ "$MVN_CMD" = mvnd.sh ]; then
+    echo "Checksum validation is not supported for maven-mvnd." >&2
+    echo "Please disable validation by removing 'distributionSha256Sum' from your maven-wrapper.properties." >&2
+    exit 1
+  elif command -v sha256sum >/dev/null; then
+    if echo "$distributionSha256Sum  $TMP_DOWNLOAD_DIR/$distributionUrlName" | sha256sum -c >/dev/null 2>&1; then
+      distributionSha256Result=true
+    fi
+  elif command -v shasum >/dev/null; then
+    if echo "$distributionSha256Sum  $TMP_DOWNLOAD_DIR/$distributionUrlName" | shasum -a 256 -c >/dev/null 2>&1; then
+      distributionSha256Result=true
+    fi
+  else
+    echo "Checksum validation was requested but neither 'sha256sum' or 'shasum' are available." >&2
+    echo "Please install either command, or disable validation by removing 'distributionSha256Sum' from your maven-wrapper.properties." >&2
+    exit 1
+  fi
+  if [ $distributionSha256Result = false ]; then
+    echo "Error: Failed to validate Maven distribution SHA-256, your Maven distribution might be compromised." >&2
+    echo "If you updated your Maven version, you need to update the specified distributionSha256Sum property." >&2
+    exit 1
+  fi
+fi
+
+# unzip and move
+if command -v unzip >/dev/null; then
+  unzip ${__MVNW_QUIET_UNZIP:+"$__MVNW_QUIET_UNZIP"} "$TMP_DOWNLOAD_DIR/$distributionUrlName" -d "$TMP_DOWNLOAD_DIR" || die "failed to unzip"
+else
+  tar xzf${__MVNW_QUIET_TAR:+"$__MVNW_QUIET_TAR"} "$TMP_DOWNLOAD_DIR/$distributionUrlName" -C "$TMP_DOWNLOAD_DIR" || die "failed to untar"
+fi
+printf %s\\n "$distributionUrl" >"$TMP_DOWNLOAD_DIR/$distributionUrlNameMain/mvnw.url"
+mv -- "$TMP_DOWNLOAD_DIR/$distributionUrlNameMain" "$MAVEN_HOME" || [ -d "$MAVEN_HOME" ] || die "fail to move MAVEN_HOME"
+
+clean || :
+exec_maven "$@"

novel-cloud-demo/novel-news/mvnw.cmd

@@ -0,0 +1,149 @@
+<# : batch portion
+@REM ----------------------------------------------------------------------------
+@REM Licensed to the Apache Software Foundation (ASF) under one
+@REM or more contributor license agreements.  See the NOTICE file
+@REM distributed with this work for additional information
+@REM regarding copyright ownership.  The ASF licenses this file
+@REM to you under the Apache License, Version 2.0 (the
+@REM "License"); you may not use this file except in compliance
+@REM with the License.  You may obtain a copy of the License at
+@REM
+@REM    https://www.apache.org/licenses/LICENSE-2.0
+@REM
+@REM Unless required by applicable law or agreed to in writing,
+@REM software distributed under the License is distributed on an
+@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+@REM KIND, either express or implied.  See the License for the
+@REM specific language governing permissions and limitations
+@REM under the License.
+@REM ----------------------------------------------------------------------------
+
+@REM ----------------------------------------------------------------------------
+@REM Apache Maven Wrapper startup batch script, version 3.3.2
+@REM
+@REM Optional ENV vars
+@REM   MVNW_REPOURL - repo url base for downloading maven distribution
+@REM   MVNW_USERNAME/MVNW_PASSWORD - user and password for downloading maven
+@REM   MVNW_VERBOSE - true: enable verbose log; others: silence the output
+@REM ----------------------------------------------------------------------------
+
+@IF "%__MVNW_ARG0_NAME__%"=="" (SET __MVNW_ARG0_NAME__=%~nx0)
+@SET __MVNW_CMD__=
+@SET __MVNW_ERROR__=
+@SET __MVNW_PSMODULEP_SAVE=%PSModulePath%
+@SET PSModulePath=
+@FOR /F "usebackq tokens=1* delims==" %%A IN (`powershell -noprofile "& {$scriptDir='%~dp0'; $script='%__MVNW_ARG0_NAME__%'; icm -ScriptBlock ([Scriptblock]::Create((Get-Content -Raw '%~f0'))) -NoNewScope}"`) DO @(
+  IF "%%A"=="MVN_CMD" (set __MVNW_CMD__=%%B) ELSE IF "%%B"=="" (echo %%A) ELSE (echo %%A=%%B)
+)
+@SET PSModulePath=%__MVNW_PSMODULEP_SAVE%
+@SET __MVNW_PSMODULEP_SAVE=
+@SET __MVNW_ARG0_NAME__=
+@SET MVNW_USERNAME=
+@SET MVNW_PASSWORD=
+@IF NOT "%__MVNW_CMD__%"=="" (%__MVNW_CMD__% %*)
+@echo Cannot start maven from wrapper >&2 && exit /b 1
+@GOTO :EOF
+: end batch / begin powershell #>
+
+$ErrorActionPreference = "Stop"
+if ($env:MVNW_VERBOSE -eq "true") {
+  $VerbosePreference = "Continue"
+}
+
+# calculate distributionUrl, requires .mvn/wrapper/maven-wrapper.properties
+$distributionUrl = (Get-Content -Raw "$scriptDir/.mvn/wrapper/maven-wrapper.properties" | ConvertFrom-StringData).distributionUrl
+if (!$distributionUrl) {
+  Write-Error "cannot read distributionUrl property in $scriptDir/.mvn/wrapper/maven-wrapper.properties"
+}
+
+switch -wildcard -casesensitive ( $($distributionUrl -replace '^.*/','') ) {
+  "maven-mvnd-*" {
+    $USE_MVND = $true
+    $distributionUrl = $distributionUrl -replace '-bin\.[^.]*$',"-windows-amd64.zip"
+    $MVN_CMD = "mvnd.cmd"
+    break
+  }
+  default {
+    $USE_MVND = $false
+    $MVN_CMD = $script -replace '^mvnw','mvn'
+    break
+  }
+}
+
+# apply MVNW_REPOURL and calculate MAVEN_HOME
+# maven home pattern: ~/.m2/wrapper/dists/{apache-maven-<version>,maven-mvnd-<version>-<platform>}/<hash>
+if ($env:MVNW_REPOURL) {
+  $MVNW_REPO_PATTERN = if ($USE_MVND) { "/org/apache/maven/" } else { "/maven/mvnd/" }
+  $distributionUrl = "$env:MVNW_REPOURL$MVNW_REPO_PATTERN$($distributionUrl -replace '^.*'+$MVNW_REPO_PATTERN,'')"
+}
+$distributionUrlName = $distributionUrl -replace '^.*/',''
+$distributionUrlNameMain = $distributionUrlName -replace '\.[^.]*$','' -replace '-bin$',''
+$MAVEN_HOME_PARENT = "$HOME/.m2/wrapper/dists/$distributionUrlNameMain"
+if ($env:MAVEN_USER_HOME) {
+  $MAVEN_HOME_PARENT = "$env:MAVEN_USER_HOME/wrapper/dists/$distributionUrlNameMain"
+}
+$MAVEN_HOME_NAME = ([System.Security.Cryptography.MD5]::Create().ComputeHash([byte[]][char[]]$distributionUrl) | ForEach-Object {$_.ToString("x2")}) -join ''
+$MAVEN_HOME = "$MAVEN_HOME_PARENT/$MAVEN_HOME_NAME"
+
+if (Test-Path -Path "$MAVEN_HOME" -PathType Container) {
+  Write-Verbose "found existing MAVEN_HOME at $MAVEN_HOME"
+  Write-Output "MVN_CMD=$MAVEN_HOME/bin/$MVN_CMD"
+  exit $?
+}
+
+if (! $distributionUrlNameMain -or ($distributionUrlName -eq $distributionUrlNameMain)) {
+  Write-Error "distributionUrl is not valid, must end with *-bin.zip, but found $distributionUrl"
+}
+
+# prepare tmp dir
+$TMP_DOWNLOAD_DIR_HOLDER = New-TemporaryFile
+$TMP_DOWNLOAD_DIR = New-Item -Itemtype Directory -Path "$TMP_DOWNLOAD_DIR_HOLDER.dir"
+$TMP_DOWNLOAD_DIR_HOLDER.Delete() | Out-Null
+trap {
+  if ($TMP_DOWNLOAD_DIR.Exists) {
+    try { Remove-Item $TMP_DOWNLOAD_DIR -Recurse -Force | Out-Null }
+    catch { Write-Warning "Cannot remove $TMP_DOWNLOAD_DIR" }
+  }
+}
+
+New-Item -Itemtype Directory -Path "$MAVEN_HOME_PARENT" -Force | Out-Null
+
+# Download and Install Apache Maven
+Write-Verbose "Couldn't find MAVEN_HOME, downloading and installing it ..."
+Write-Verbose "Downloading from: $distributionUrl"
+Write-Verbose "Downloading to: $TMP_DOWNLOAD_DIR/$distributionUrlName"
+
+$webclient = New-Object System.Net.WebClient
+if ($env:MVNW_USERNAME -and $env:MVNW_PASSWORD) {
+  $webclient.Credentials = New-Object System.Net.NetworkCredential($env:MVNW_USERNAME, $env:MVNW_PASSWORD)
+}
+[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12
+$webclient.DownloadFile($distributionUrl, "$TMP_DOWNLOAD_DIR/$distributionUrlName") | Out-Null
+
+# If specified, validate the SHA-256 sum of the Maven distribution zip file
+$distributionSha256Sum = (Get-Content -Raw "$scriptDir/.mvn/wrapper/maven-wrapper.properties" | ConvertFrom-StringData).distributionSha256Sum
+if ($distributionSha256Sum) {
+  if ($USE_MVND) {
+    Write-Error "Checksum validation is not supported for maven-mvnd. `nPlease disable validation by removing 'distributionSha256Sum' from your maven-wrapper.properties."
+  }
+  Import-Module $PSHOME\Modules\Microsoft.PowerShell.Utility -Function Get-FileHash
+  if ((Get-FileHash "$TMP_DOWNLOAD_DIR/$distributionUrlName" -Algorithm SHA256).Hash.ToLower() -ne $distributionSha256Sum) {
+    Write-Error "Error: Failed to validate Maven distribution SHA-256, your Maven distribution might be compromised. If you updated your Maven version, you need to update the specified distributionSha256Sum property."
+  }
+}
+
+# unzip and move
+Expand-Archive "$TMP_DOWNLOAD_DIR/$distributionUrlName" -DestinationPath "$TMP_DOWNLOAD_DIR" | Out-Null
+Rename-Item -Path "$TMP_DOWNLOAD_DIR/$distributionUrlNameMain" -NewName $MAVEN_HOME_NAME | Out-Null
+try {
+  Move-Item -Path "$TMP_DOWNLOAD_DIR/$MAVEN_HOME_NAME" -Destination $MAVEN_HOME_PARENT | Out-Null
+} catch {
+  if (! (Test-Path -Path "$MAVEN_HOME" -PathType Container)) {
+    Write-Error "fail to move MAVEN_HOME"
+  }
+} finally {
+  try { Remove-Item $TMP_DOWNLOAD_DIR -Recurse -Force | Out-Null }
+  catch { Write-Warning "Cannot remove $TMP_DOWNLOAD_DIR" }
+}
+
+Write-Output "MVN_CMD=$MAVEN_HOME/bin/$MVN_CMD"

novel-cloud-demo/novel-news/pom.xml

@@ -0,0 +1,32 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>com.sf</groupId>
+        <artifactId>novel-cloud-demo</artifactId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>novel-news</artifactId>
+    <name>novel-news</name>
+    <description>novel-news</description>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.sf</groupId>
+            <artifactId>novel-core</artifactId>
+            <version>${project.parent.version}</version>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

novel-cloud-demo/novel-news/src/main/java/com/sf/news/NovelNewsApplication.java

@@ -0,0 +1,15 @@
+package com.sf.news;
+
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@MapperScan("com.sf.news.mapper")
+@SpringBootApplication
+public class NovelNewsApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(NovelNewsApplication.class, args);
+    }
+
+}

novel-cloud-demo/novel-news/src/main/java/com/sf/news/controller/NewsContentController.java

@@ -0,0 +1,37 @@
+package com.sf.news.controller;
+
+import com.sf.core.dto.RestResp;
+import com.sf.news.dto.NewsInfoRespDto;
+import com.sf.news.service.INewsContentService;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * <p>
+ * 新闻内容 前端控制器
+ * </p>
+ *
+ * @author baomidou
+ * @since 2024-08-06
+ */
+@Tag(name = "NewsContentController", description = "新闻内容模块")
+@RestController
+public class NewsContentController {
+
+    @Autowired
+    private INewsContentService newsContentService;
+
+    @Operation(summary = "新闻内容接口")
+    @GetMapping("/api/front/news/{id}")
+    public RestResp<NewsInfoRespDto> getNews(@PathVariable Long id) {
+        NewsInfoRespDto newsInfoRespDto = newsContentService.getNews(id);
+        return RestResp.ok(newsInfoRespDto);
+    }
+
+}

novel-cloud-demo/novel-news/src/main/java/com/sf/news/controller/NewsInfoController.java

@@ -0,0 +1,39 @@
+package com.sf.news.controller;
+
+import com.sf.core.dto.RestResp;
+import com.sf.news.dto.NewsInfoRespDto;
+import com.sf.news.service.INewsInfoService;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 新闻信息 前端控制器
+ * </p>
+ *
+ * @author baomidou
+ * @since 2024-08-06
+ */
+@Tag(name = "NewsInfoController", description = "新闻信息模块")
+@RestController
+public class NewsInfoController {
+
+    @Autowired
+    private INewsInfoService newsInfoService;
+
+    // http://127.0.0.1:8888/api/front/news/latest_list
+    @Operation(summary = "新闻信息列表接口")
+    @GetMapping("/api/front/news/latest_list")
+    public RestResp<List<NewsInfoRespDto>> listLatestNews() {
+        // ctrl+alt 可以直接进入实现类的方法中
+        List<NewsInfoRespDto> newsInfoRespDtos = newsInfoService.listLatestNews();
+        return RestResp.ok(newsInfoRespDtos);
+    }
+}

novel-cloud-demo/novel-news/src/main/java/com/sf/news/dto/NewsInfoRespDto.java

@@ -0,0 +1,60 @@
+package com.sf.news.dto;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.time.LocalDateTime;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class NewsInfoRespDto {
+
+    /**
+     * ID
+     */
+    @Schema(description = "新闻ID")
+    private Long id;
+
+    /**
+     * 类别ID
+     */
+    @Schema(description = "类别ID")
+    private Long categoryId;
+
+    /**
+     * 类别名
+     */
+    @Schema(description = "类别名")
+    private String categoryName;
+
+    /**
+     * 新闻来源
+     */
+    @Schema(description = "新闻来源")
+    private String sourceName;
+
+    /**
+     * 新闻标题
+     */
+    @Schema(description = "新闻标题")
+    private String title;
+
+    /**
+     * 更新时间
+     */
+    @Schema(description = "更新时间")
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    private LocalDateTime updateTime;
+
+    /**
+     * 新闻内容
+     * */
+    @Schema(description = "新闻内容")
+    private String content;
+}

novel-cloud-demo/novel-news/src/main/java/com/sf/news/entity/NewsContent.java

@@ -0,0 +1,51 @@
+package com.sf.news.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * <p>
+ * 新闻内容
+ * </p>
+ *
+ * @author baomidou
+ * @since 2024-08-06
+ */
+@Getter
+@Setter
+@TableName("news_content")
+public class NewsContent implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 新闻ID
+     */
+    private Long newsId;
+
+    /**
+     * 新闻内容
+     */
+    private String content;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createTime;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updateTime;
+}

novel-cloud-demo/novel-news/src/main/java/com/sf/news/entity/NewsInfo.java

@@ -0,0 +1,61 @@
+package com.sf.news.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * <p>
+ * 新闻信息
+ * </p>
+ *
+ * @author baomidou
+ * @since 2024-08-06
+ */
+@Getter
+@Setter
+@TableName("news_info")
+public class NewsInfo implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 类别ID
+     */
+    private Long categoryId;
+
+    /**
+     * 类别名
+     */
+    private String categoryName;
+
+    /**
+     * 新闻来源
+     */
+    private String sourceName;
+
+    /**
+     * 新闻标题
+     */
+    private String title;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createTime;
+
+    /**
+     * 更新时间
+     */
+    private LocalDateTime updateTime;
+}

novel-cloud-demo/novel-news/src/main/java/com/sf/news/mapper/NewsContentMapper.java

@@ -0,0 +1,16 @@
+package com.sf.news.mapper;
+
+import com.sf.news.entity.NewsContent;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 新闻内容 Mapper 接口
+ * </p>
+ *
+ * @author baomidou
+ * @since 2024-08-06
+ */
+public interface NewsContentMapper extends BaseMapper<NewsContent> {
+
+}

novel-cloud-demo/novel-news/src/main/java/com/sf/news/mapper/NewsInfoMapper.java

@@ -0,0 +1,16 @@
+package com.sf.news.mapper;
+
+import com.sf.news.entity.NewsInfo;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 新闻信息 Mapper 接口
+ * </p>
+ *
+ * @author baomidou
+ * @since 2024-08-06
+ */
+public interface NewsInfoMapper extends BaseMapper<NewsInfo> {
+
+}

novel-cloud-demo/novel-news/src/main/java/com/sf/news/service/INewsContentService.java

@@ -0,0 +1,17 @@
+package com.sf.news.service;
+
+import com.sf.news.dto.NewsInfoRespDto;
+import com.sf.news.entity.NewsContent;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ * 新闻内容 服务类
+ * </p>
+ *
+ * @author baomidou
+ * @since 2024-08-06
+ */
+public interface INewsContentService extends IService<NewsContent> {
+    NewsInfoRespDto getNews(Long id);
+}

novel-cloud-demo/novel-news/src/main/java/com/sf/news/service/INewsInfoService.java

@@ -0,0 +1,19 @@
+package com.sf.news.service;
+
+import com.sf.news.dto.NewsInfoRespDto;
+import com.sf.news.entity.NewsInfo;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 新闻信息 服务类
+ * </p>
+ *
+ * @author baomidou
+ * @since 2024-08-06
+ */
+public interface INewsInfoService extends IService<NewsInfo> {
+    List<NewsInfoRespDto> listLatestNews();
+}

novel-cloud-demo/novel-news/src/main/java/com/sf/news/service/impl/NewsContentServiceImpl.java

@@ -0,0 +1,46 @@
+package com.sf.news.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.sf.news.dto.NewsInfoRespDto;
+import com.sf.news.entity.NewsContent;
+import com.sf.news.entity.NewsInfo;
+import com.sf.news.mapper.NewsContentMapper;
+import com.sf.news.mapper.NewsInfoMapper;
+import com.sf.news.service.INewsContentService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 新闻内容 服务实现类
+ * </p>
+ *
+ * @author baomidou
+ * @since 2024-08-06
+ */
+@Service
+public class NewsContentServiceImpl extends ServiceImpl<NewsContentMapper, NewsContent> implements INewsContentService {
+
+    @Autowired
+    private NewsInfoMapper newsInfoMapper;
+    @Autowired
+    private NewsContentMapper newsContentMapper;
+
+    @Override
+    public NewsInfoRespDto getNews(Long id) {
+        // select * from news_info where id = '1';
+        NewsInfo newsInfo = newsInfoMapper.selectById(id);
+        // select * from news_content where id = '1' limit 1;
+        LambdaQueryWrapper<NewsContent> queryWrapper = new LambdaQueryWrapper<>();
+        // eq = equals 等于
+        queryWrapper.eq(NewsContent::getId, id).last("limit 1");
+        NewsContent newsContent = newsContentMapper.selectOne(queryWrapper);
+        return NewsInfoRespDto.builder()
+                .title(newsInfo.getTitle())
+                .sourceName(newsInfo.getSourceName())
+                .updateTime(newsInfo.getUpdateTime())
+                .content(newsContent.getContent())
+                .build();
+    }
+}

novel-cloud-demo/novel-news/src/main/java/com/sf/news/service/impl/NewsInfoServiceImpl.java

@@ -0,0 +1,54 @@
+package com.sf.news.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.sf.news.dto.NewsInfoRespDto;
+import com.sf.news.entity.NewsInfo;
+import com.sf.news.mapper.NewsInfoMapper;
+import com.sf.news.service.INewsInfoService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 新闻信息 服务实现类
+ * </p>
+ *
+ * @author baomidou
+ * @since 2024-08-06
+ */
+@Service
+public class NewsInfoServiceImpl extends ServiceImpl<NewsInfoMapper, NewsInfo> implements INewsInfoService {
+
+    @Autowired
+    private NewsInfoMapper newsInfoMapper;
+
+    @Override
+    public List<NewsInfoRespDto> listLatestNews() {
+        // 从新闻信息表中查询出最新发布的两条新闻
+        // select * from news_info order by create_time desc limit 2;
+        LambdaQueryWrapper<NewsInfo> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.orderByDesc(NewsInfo::getCreateTime).last("limit 2");
+        List<NewsInfo> newsInfos = newsInfoMapper.selectList(queryWrapper);
+        // map是映射处理 将list中每个newsInfo对象转换为NewsInfoRespDto对象
+        // toList是将stream流的处理结果接收为list
+
+        // 翻译一下stream
+//        List<NewsInfoRespDto> newsInfoRespDtos = new ArrayList<>();
+//        for (NewsInfo newsInfo : newsInfos) {
+//            NewsInfoRespDto newsInfoRespDto = NewsInfoRespDto.builder().build();
+//            BeanUtils.copyProperties(newsInfo, newsInfoRespDto);
+//            newsInfoRespDtos.add(newsInfoRespDto);
+//        }
+
+        return newsInfos.stream().map(newsInfo -> {
+            NewsInfoRespDto newsInfoRespDto = NewsInfoRespDto.builder().build();
+            BeanUtils.copyProperties(newsInfo, newsInfoRespDto);
+            return newsInfoRespDto;
+        }).toList();
+    }
+}
+

novel-cloud-demo/novel-news/src/main/resources/application.yml

@@ -0,0 +1,8 @@
+spring:
+  #  application:
+  #    name: novel-news
+  profiles:
+    include: common
+
+server:
+  port: 8902

novel-cloud-demo/novel-news/src/main/resources/bootstrap.yml

@@ -0,0 +1,6 @@
+spring:
+  application:
+    name: novel-news
+  # 将通用的application.yml文件引入进来
+  profiles:
+    include: common

novel-cloud-demo/novel-news/src/main/resources/mapper/NewsContentMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.sf.news.mapper.NewsContentMapper">
+
+</mapper>

novel-cloud-demo/novel-news/src/main/resources/mapper/NewsInfoMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.sf.news.mapper.NewsInfoMapper">
+
+</mapper>

novel-cloud-demo/novel-news/src/test/java/com/sf/news/NovelNewsApplicationTests.java

@@ -0,0 +1,13 @@
+package com.sf.news;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest
+class NovelNewsApplicationTests {
+
+    @Test
+    void contextLoads() {
+    }
+
+}

novel-cloud-demo/pom.xml

@@ -37,6 +37,7 @@
         <mybatis-plus.version>3.5.5</mybatis-plus.version>
         <freemarker.version>2.3.32</freemarker.version>
         <swagger.version>2.0.2</swagger.version>
+        <gson.version>2.11.0</gson.version>
     </properties>
 
     <!-- 删除了父项目的依赖引入 -->
@@ -128,6 +129,13 @@
                 <artifactId>lombok</artifactId>
                 <version>${lombok.version}</version>
             </dependency>
+
+            <dependency>
+                <groupId>com.google.code.gson</groupId>
+                <artifactId>gson</artifactId>
+                <version>${gson.version}</version>
+            </dependency>
+
         </dependencies>
     </dependencyManagement>