WenshuLegal 的字段设置为 mysql text 类型

search/search-service/src/main/java/cn/reghao/tnb/search/app/model/po/WenshuLegal.java

@@ -5,6 +5,7 @@ import lombok.Getter;
 import lombok.NoArgsConstructor;
 import lombok.Setter;
 
+import javax.persistence.Column;
 import javax.persistence.Embeddable;
 
 /**
@@ -17,5 +18,6 @@ import javax.persistence.Embeddable;
 @Getter
 @Embeddable
 public class WenshuLegal {
+    @Column(columnDefinition = "text")
     private String legalBasis;
 }

search/search-service/src/main/java/cn/reghao/tnb/search/app/service/WenshuService.java

@@ -195,19 +195,16 @@ public class WenshuService {
             wenshuDocList.add(wenshuDoc);
             wenshuLuceneList.add(wenshuLucene);
         }
-
-        wenshuDocRepository.saveAll(wenshuDocList);
-
         List<Document> luceneDocumentList = wenshuLuceneList.stream()
                 .map(wenshuLucene -> luceneDocument.getDocumentByWenshuLucene(wenshuLucene))
                 .collect(Collectors.toList());
         try {
+            wenshuDocRepository.saveAll(wenshuDocList);
             luceneIndex.createIndex(indexName, luceneDocumentList);
-        } catch (IOException e) {
+            log.info("index {} documents...", wenshuList.size());
+        } catch (Exception e) {
             e.printStackTrace();
         }
-
-        log.info("index {} documents...", wenshuList.size());
     }
 
     public void deleteAll() throws IOException {