【fix】事件分析开放范围

src/main/java/com/zzsn/event/task/EventHotTask.java

@@ -55,9 +55,9 @@ public class EventHotTask {
      */
     @Scheduled(cron = "0 0 0/3 * * ?")
     public void hot() {
-        LambdaQueryWrapper<Event> queryWrapper = Wrappers.lambdaQuery();
-        queryWrapper.eq(Event::getFacePublic,1).eq(Event::getPublishStatus,1);
-        List<Event> list = eventService.list(queryWrapper);
+        //LambdaQueryWrapper<Event> queryWrapper = Wrappers.lambdaQuery();
+        //queryWrapper.eq(Event::getFacePublic,1).eq(Event::getPublishStatus,1);
+        List<Event> list = eventService.list();
         List<HotVO> countList = new ArrayList<>();
         for (Event event : list) {
             CompletableFuture<HotVO> async = CompletableFuture.supplyAsync(() -> {

src/main/java/com/zzsn/event/task/SynClbEventDataTask.java

@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.zzsn.event.entity.Event;
+import com.zzsn.event.entity.EventClb;
 import com.zzsn.event.entity.EventTag;
 import com.zzsn.event.entity.EventTagClb;
 import com.zzsn.event.mapper.EventClbMapper;
@@ -49,18 +50,18 @@ public class SynClbEventDataTask {
             return;
         }
         log.info("同步克虏宝中事件信息到研究中心数据库开始");
-        LambdaQueryWrapper<Event> queryWrapper = Wrappers.lambdaQuery();
-        queryWrapper.eq(Event::getFacePublic,1).eq(Event::getPublishStatus,1);
-        List<Event> list = eventService.list(queryWrapper);
+        //LambdaQueryWrapper<Event> queryWrapper = Wrappers.lambdaQuery();
+        //queryWrapper.eq(Event::getFacePublic,1).eq(Event::getPublishStatus,1);
+        List<Event> list = eventService.list();
         for (Event event : list) {
             try{
                 // 克虏宝事件表
                 String eventId = event.getId();
-                EventVO eventVOClb = eventClbMapper.queryInfo(eventId);
-                if (eventVOClb != null) {
+                EventClb eventClb = eventClbMapper.selectById(eventId);
+                if (eventClb != null) {
                     LambdaUpdateWrapper<Event> lambdaUpdateWrapper = Wrappers.lambdaUpdate(Event.class).eq(Event::getId, eventId)
-                            .set(Event::getRelationEvents, eventVOClb.getRelationEvents()) // 事件关联事件
-                            .set(Event::getEventLabel, eventVOClb.getEventLabel()) // 事件表中打的标签
+                            .set(Event::getRelationEvents, eventClb.getRelationEvents()) // 事件关联事件
+                            .set(Event::getEventLabel, eventClb.getEventLabel()) // 事件表中打的标签
                             // total_hot根据所有事件定时统计，这个使用研究中心自己的
                             ;
                     eventService.update(lambdaUpdateWrapper);
@@ -70,7 +71,7 @@ public class SynClbEventDataTask {
                             .last(" limit 1"));
                     LambdaUpdateWrapper<EventTag> tagUpdateWrapper = Wrappers.lambdaUpdate(EventTag.class)
                             .eq(EventTag::getEventId, eventId)
-                            .set(EventTag::getExtractIndustryTag, eventTagClb.getExtractIndustryTag()) // 事件关联事件
+                            .set(EventTag::getExtractIndustryTag, eventTagClb.getExtractIndustryTag())
                             .set(EventTag::getExtractCompanyTag, eventTagClb.getExtractCompanyTag())
                             .set(EventTag::getExtractPersonTag, eventTagClb.getExtractPersonTag())
                             .set(EventTag::getExtractSentimentTag, eventTagClb.getExtractSentimentTag())