逻辑优化

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

@@ -59,8 +59,6 @@ public class EventManageController {
     private ConfigurationMessageService configurationMessageService;
     @Autowired
     private IKeyWordsService keyWordsService;
-    @Autowired
-    private ClbModelArrangeSubjectMapService clbModelArrangeSubjectMapService;
     @Resource
     private KafkaTemplate<String, String> kafkaTemplate;
     @Autowired

src/main/java/com/zzsn/event/controller/yjzx/EventDataController.java

@@ -79,6 +79,8 @@ public class EventDataController {
     private ObsUtil obsUtil;
     @Autowired
     private SysDictItemService dictItemService;
+    @Autowired
+    private AnalysisService analysisService;
 
     @Value("${translate.url:}")
     private String TRANSLATE_URL;
@@ -276,12 +278,18 @@ public class EventDataController {
             //新增关键词
             keyWordsService.saveBaseAndMap(event, keywordsVO.getKeyword(), keywordsVO.getExclusionWord());
             CompletableFuture.runAsync(() -> {
+                try {
                     //插入xxlJob
                     iXxlJobInfoService.eventInsert(event);
                     //通知采集
                     configurationMessageService.bindKeyWordsEventSend(event.getId());
                     //事件分析
                     kafkaTemplate.send(EVENT_MODEL_KAFKA_CHANNEL, event.getEventCode());
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+                //立马执行一次事件分析
+                analysisService.regenerate(event.getId());
             });
             return Result.OK();
         } else {

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

@@ -2,9 +2,7 @@ package com.zzsn.event.service.impl;
 
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.collection.CollectionUtil;
-import cn.hutool.core.date.DateTime;
 import cn.hutool.core.map.MapUtil;
-import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
@@ -27,8 +25,6 @@ import com.zzsn.event.util.tree.TreeUtil;
 import com.zzsn.event.util.user.UserUtil;
 import com.zzsn.event.util.user.UserVo;
 import com.zzsn.event.vo.*;
-import com.zzsn.event.xxljob.entity.XxlJobInfo;
-import com.zzsn.event.xxljob.service.IXxlJobInfoService;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;