事件分析-脉络排序规则优化

src/main/java/com/zzsn/event/service/impl/EventContextServiceImpl.java

@@ -110,6 +110,7 @@ public class EventContextServiceImpl extends ServiceImpl<EventContextMapper, Eve
         LambdaQueryWrapper<EventContext> queryWrapper = Wrappers.lambdaQuery();
         queryWrapper.eq(EventContext::getEventId, eventId)
                 .eq(EventContext::getYnKeyNode, 1)
+                .orderByDesc(EventContext::getPublishDate)
                 .orderByDesc(EventContext::getSortNumber);
         return baseMapper.selectList(queryWrapper);
     }
@@ -120,6 +121,7 @@ public class EventContextServiceImpl extends ServiceImpl<EventContextMapper, Eve
         LambdaQueryWrapper<EventContext> queryWrapper = Wrappers.lambdaQuery();
         queryWrapper.eq(EventContext::getEventId, eventId)
                 .eq(EventContext::getParentId, keyNodeId)
+                .orderByDesc(EventContext::getPublishDate)
                 .orderByDesc(EventContext::getSortNumber);
         return baseMapper.selectPage(page,queryWrapper);
     }

src/main/resources/application-dev.yml

@@ -158,6 +158,7 @@ kafka:
   topic:
     subject:
       run: subjectModelTest
+    eventContext: eventContexTopic
 clb:
   subject:
     default: