send new topic to kafka

src/main/java/com/zzsn/knowbase/controller/KnowledgeController.java

@@ -78,7 +78,7 @@ public class KnowledgeController {
         if(!knowledgeVO.getPublishDate().isEmpty()){
             knowledgeVO.setPublishDate(EsDateUtil.esFieldDateMapping(knowledgeVO.getPublishDate()));
         }
-        if(!knowledgeVO.getVerifyTime().isEmpty()){
+        if(null!=knowledgeVO.getVerifyTime()&&(!knowledgeVO.getVerifyTime().isEmpty())){
             knowledgeVO.setVerifyTime(EsDateUtil.esFieldDateMapping(knowledgeVO.getVerifyTime()));
         }
         return Result.OK(knowledgeVO);

src/main/java/com/zzsn/knowbase/entity/Knowledge.java

@@ -102,7 +102,7 @@ public class Knowledge implements Serializable {
      * 知识库id
      */
     private String kbKnowledgeId;
-    private String content;
+    private String contentAll;
     /**
      * 类型
      */

src/main/java/com/zzsn/knowbase/kafka/cloudstream/KnowledgeChannel.java

@@ -21,5 +21,5 @@ public interface KnowledgeChannel {
     MessageChannel knowledgeContents();
 
     @Output
-    MessageChannel knowledgeExcelContents();
+    MessageChannel knowledgeExcels();
 }

src/main/java/com/zzsn/knowbase/kafka/message/KnowledgeMessage.java

@@ -50,6 +50,7 @@ public class KnowledgeMessage {
      */
     private String type;
     private String author;
+    private String contentAll;
 
     private List<Content> contents;
 

src/main/java/com/zzsn/knowbase/kafka/producer/ProduceInfo.java

@@ -36,6 +36,6 @@ public class ProduceInfo {
     public void sendKnowledgeExcelContents(KnowledgeMessage knowledgeMessage) {
         String msg = JSON.toJSONString(knowledgeMessage);
         Message<String> message = MessageBuilder.withPayload(msg).build();
-        channel.knowledgeExcelContents().send(message);
+        channel.knowledgeExcels().send(message);
     }
 }

src/main/java/com/zzsn/knowbase/service/impl/KnowledgeServiceImpl.java

@@ -518,12 +518,11 @@ class KnowledgeServiceImpl implements IKnowledgeService {
                     continue;
                 }
                 if (StringUtils.isNotEmpty(info.get(1))) {
-                    specialInformation.setContent(info.get(1));
-                    //段落切分
-
-                    specialInformation.setContents(Collections.singletonList(Content.builder()
-                            .contentId(codeGenerateUtil.geneIdNo(Constants.FINANCE, 8))
-                            .content(info.get(1)).build()));
+                    specialInformation.setContentAll(info.get(1));
+//                    //段落切分
+//                    specialInformation.setContents(Collections.singletonList(Content.builder()
+//                            .contentId(codeGenerateUtil.geneIdNo(Constants.FINANCE, 8))
+//                            .content(info.get(1)).build()));
                 } else {
                     log.error("上传的数据{}正文为空，此条数据忽略", info.get(0));
                     continue;

src/main/java/com/zzsn/knowbase/vo/KnowledgeVO.java

@@ -31,6 +31,7 @@ public class KnowledgeVO {
     private String verifierName;
     private String origin;
     private String author;
+    private String contentAll;
     private Integer score;
     private Integer verifyStatus;
     private Integer importData;