【添加日志】

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

@@ -155,10 +155,13 @@ public class EventManageController {
             keyWordsService.saveBaseAndMap(event, keywordsVO.getKeyword(), keywordsVO.getExclusionWord());
             CompletableFuture.runAsync(() -> {
                 //插入xxlJob
+                log.info("新增事件，插入xxlJob，事件id：{}", event.getId());
                 iXxlJobInfoService.eventInsert(event);
                 //通知采集
+                log.info("新增事件，通知采集，事件id：{}", event.getId());
                 configurationMessageService.bindKeyWordsEventSend(event.getId());
                 //事件分析
+                log.info("新增事件，事件分析，事件id：{}", event.getId());
                 kafkaTemplate.send(EVENT_MODEL_KAFKA_CHANNEL, event.getEventCode());
             });
             return Result.OK();

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

@@ -365,16 +365,25 @@ public class EventServiceImpl extends ServiceImpl<EventMapper, Event> implements
         baseMapper.insert(event);
         String eventId = event.getId();
         CompletableFuture.runAsync(() -> {
-            setRedisCache(eventId);
-            //插入专题-类别、项目的绑定关系
-            saveMapMain(event, addEventParam);
-            //事件标签
-            eventTagService.save(EventTag.builder().eventId(eventId).build());
-            //地缘关系绑定
-            List<RegionVO> regionList = addEventParam.getRegionList();
-            addRegionMap(eventId, regionList);
-            //默认绑定搜索引擎、模型
-            saveDefaultMap(eventId);
+            try {
+                log.info("开始补充redis日期缓存-{}",event.getEventCode());
+                setRedisCache(eventId);
+                //插入专题-类别、项目的绑定关系
+                log.info("开始插入关系");
+                saveMapMain(event, addEventParam);
+                //事件标签
+                log.info("开始插入事件标签");
+                eventTagService.save(EventTag.builder().eventId(eventId).build());
+                //地缘关系绑定
+                log.info("地缘关系绑定");
+                List<RegionVO> regionList = addEventParam.getRegionList();
+                addRegionMap(eventId, regionList);
+                //默认绑定搜索引擎、模型
+                saveDefaultMap(eventId);
+            } catch (Exception e) {
+                log.error("事件配置异常:{}",e.getMessage(),e);
+                throw new RuntimeException(e);
+            }
         });
         return event;
     }
@@ -769,6 +778,7 @@ public class EventServiceImpl extends ServiceImpl<EventMapper, Event> implements
 
     private void saveMapMain(Event subject, AddEventParam addEventParam) {
         if (StringUtils.isNotEmpty(addEventParam.getSubjectTypeId())) {
+            log.info("事件专题类别id：{}-事件专题id:{}", addEventParam.getSubjectTypeId(),subject.getId());
             SubjectTypeMap subjectTypeMap = new SubjectTypeMap();
             subjectTypeMap.setSubjectId(subject.getId());
             subjectTypeMap.setUpdateBy(subject.getUpdateBy());
@@ -777,6 +787,7 @@ public class EventServiceImpl extends ServiceImpl<EventMapper, Event> implements
             iSubjectTypeMapService.save(subjectTypeMap);
         }
         if (StringUtils.isNotEmpty(addEventParam.getProjectId())) {
+            log.info("项目id：{}-事件专题id:{}", addEventParam.getProjectId(),subject.getId());
             ProjectSubjectMap projectSubjectMap = new ProjectSubjectMap();
             projectSubjectMap.setProjectId(addEventParam.getProjectId());
             projectSubjectMap.setSubjectId(subject.getId());