消费主题修改

src/main/java/com/zzsn/event/constant/Constants.java

@@ -29,9 +29,9 @@ public class Constants {
     //kafka 接收 观点分析结果 主题
     public static final String VIEWPOINT_RECEIVE_TOPIC = "event_viewpoint_result_data";
     //kafka 接收 事件脉络结果 主题
-    public static final String EVENT_CONTEXT_RECEIVE_TOPIC = "event_topic_result_data";
+    public static final String EVENT_CONTEXT_RECEIVE_TOPIC = "event_context_result_data";
     //kafka 接收 伪事件脉络结果 主题
-    public static final String FAKE_EVENT_CONTEXT_RECEIVE_TOPIC = "fake_event_context-result_data";
+    public static final String FAKE_EVENT_CONTEXT_RECEIVE_TOPIC = "fake_event_context_result_data";
     //kafka 接收 事件分析报告 主题
     public static final String EVENT_REPORT_RECEIVE_TOPIC = "event_report_result_data";
 

src/main/java/com/zzsn/event/controller/EventAnalysisController.java

@@ -167,15 +167,11 @@ public class EventAnalysisController {
     @ApiOperation(value = "专题信息列表-分页列表查询", notes = "专题信息列表-分页列表查询")
     @GetMapping(value = "/listEventAnalysis")
     public Result<?> listEventAnalysis(@RequestParam(name = "eventId") String eventId,
-                                       @RequestParam(name = "type", defaultValue = "0") Integer type) {
+                                       @RequestParam(name = "type") Integer type) {
         LambdaQueryWrapper<SubjectAnalysis> wrapper = new LambdaQueryWrapper<SubjectAnalysis>()
                 .eq(SubjectAnalysis::getSubjectId, eventId)
-                .eq(SubjectAnalysis::getCategory, 1);
-        if (4 == type) {
-            wrapper.eq(SubjectAnalysis::getType, 4);
-        } else {
-            wrapper.isNull(SubjectAnalysis::getType);
-        }
+                .eq(SubjectAnalysis::getCategory, 1)
+                .eq(SubjectAnalysis::getType, type);
         List<SubjectAnalysis> list = subjectAnalysisService.list(wrapper);
         return Result.OK(list);
     }