first

hongshu-common/pom.xml

@@ -134,6 +134,18 @@
             <groupId>co.elastic.clients</groupId>
             <artifactId>elasticsearch-java</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.elasticsearch.client</groupId>
+            <artifactId>elasticsearch-rest-client</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>jakarta.json</groupId>
+            <artifactId>jakarta.json-api</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.eclipse.parsson</groupId>
+            <artifactId>parsson</artifactId>
+        </dependency>
         <!-- gson-->
         <dependency>
             <groupId>com.google.code.gson</groupId>

hongshu-server/src/main/resources/application-druid.yml

@@ -8,7 +8,7 @@ spring:
             master:
                 url: jdbc:mysql://localhost:3306/hongshu_springboot?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&serverTimezone=GMT%2B8
                 username: root
-                password: Myj950501
+                password: 123456
             # 从库数据源
             slave:
                 # 从数据源开关/默认关闭

hongshu-server/src/main/resources/application.yml

@@ -75,7 +75,7 @@ spring:
     # 数据库索引
     database: 0
     # 密码
-    password: Myj950501
+    password:
     # 连接超时时间
     timeout: 10s
     lettuce:

hongshu-web/src/main/java/com/hongshu/web/service/impl/WebEsNoteServiceImpl.java

@@ -300,6 +300,10 @@ public class WebEsNoteServiceImpl extends ServiceImpl<WebNoteMapper, WebNote> im
     @Override
     public void addNoteBulkData() {
         List<WebNote> noteList = noteMapper.selectList(new QueryWrapper<WebNote>().eq("audit_status", 1));
+        if (CollectionUtil.isEmpty(noteList)) {
+            log.info("数据库中没有需要同步的笔记数据，跳过批量插入。");
+            return;
+        }
         List<NoteSearchVO> noteSearchVOList = DozerUtil.convertor(noteList, NoteSearchVO.class);
         for (NoteSearchVO noteSearchVo : noteSearchVOList) {
             WebUser user = userMapper.selectOne(new QueryWrapper<WebUser>().like("id", noteSearchVo.getUid()));

pom.xml

@@ -41,7 +41,7 @@
         <jwt.version>0.9.1</jwt.version>
         <lombok.version>1.18.24</lombok.version>
         <hutool.version>5.7.22</hutool.version>
-        <elasticsearch-version>8.1.0</elasticsearch-version>
+        <elasticsearch.version>8.13.4</elasticsearch.version>
         <guava.version>20.0</guava.version>
         <gson.version>2.9.0</gson.version>
         <mybatisplus.version>3.5.2</mybatisplus.version>
@@ -156,8 +156,24 @@
             <dependency>
                 <groupId>co.elastic.clients</groupId>
                 <artifactId>elasticsearch-java</artifactId>
-                <version>${elasticsearch-version}</version>
+                <version>${elasticsearch.version}</version>
             </dependency>
+            <dependency>
+                <groupId>org.elasticsearch.client</groupId>
+                <artifactId>elasticsearch-rest-client</artifactId>
+                <version>${elasticsearch.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>jakarta.json</groupId>
+                <artifactId>jakarta.json-api</artifactId>
+                <version>2.0.1</version>
+            </dependency>
+            <dependency>
+                <groupId>org.eclipse.parsson</groupId>
+                <artifactId>parsson</artifactId>
+                <version>1.0.5</version>
+            </dependency>
+
             <!-- guava-->
             <dependency>
                 <groupId>com.google.guava</groupId>