事件脉络消费逻辑优化

src/main/java/com/zzsn/event/kafka/KafkaConsumer.java

@@ -13,6 +13,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.kafka.annotation.KafkaListener;
 import org.springframework.stereotype.Component;
 
+import java.util.ArrayList;
 import java.util.List;
 
 /**
@@ -62,6 +63,7 @@ public class KafkaConsumer {
             } else {
                 keyNodeId = one.getId();
             }
+            List<EventContext> saveList = new ArrayList<>();
             List<EventContext> eventContextList = contextKafkaVO.getRelatedArticles();
             if (CollectionUtils.isNotEmpty(eventContextList)) {
                 for (int i = 0; i < eventContextList.size(); i++) {
@@ -73,9 +75,13 @@ public class KafkaConsumer {
                         eventContext.setEventId(eventId);
                         eventContext.setParentId(keyNodeId);
                         eventContext.setSortNumber(maxSortNumber + i + 1);
+                        if (eventContext.getTitle().length() > 500) {
+                            eventContext.setTitle(eventContext.getTitle().substring(0, 500));
+                        }
+                        saveList.add(eventContext);
                     }
                 }
-                eventContextService.saveBatch(eventContextList);
+                eventContextService.saveBatch(saveList);
             }
         }
         log.info("事件-{}，本次事件脉络更新完成",eventContextKafkaList.get(0).getEventId());