提交 0d36d106 作者: 925993793@qq.com

事件数据清空时,逻辑补充

上级 1f47141f
...@@ -99,7 +99,7 @@ public class SubjectManageController { ...@@ -99,7 +99,7 @@ public class SubjectManageController {
private KafkaTemplate<String, String> kafkaTemplate; private KafkaTemplate<String, String> kafkaTemplate;
@Autowired @Autowired
private PythonUtil pythonUtil; private PythonUtil pythonUtil;
@Autowired(required = false) @Autowired
private RemoteModelService remoteModelService; private RemoteModelService remoteModelService;
@Autowired @Autowired
private ConfigurationMessageService configurationMessageService; private ConfigurationMessageService configurationMessageService;
......
...@@ -480,6 +480,20 @@ public class EventServiceImpl extends ServiceImpl<EventMapper, Event> implements ...@@ -480,6 +480,20 @@ public class EventServiceImpl extends ServiceImpl<EventMapper, Event> implements
BoolQueryBuilder boolQuery = QueryBuilders.boolQuery(); BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
boolQuery.must(QueryBuilders.termQuery("subjectId.keyword", eventId)); boolQuery.must(QueryBuilders.termQuery("subjectId.keyword", eventId));
esOpUtil.docDeleteByQuery(Constants.SUBJECT_INDEX, boolQuery); esOpUtil.docDeleteByQuery(Constants.SUBJECT_INDEX, boolQuery);
try {
Thread.sleep(30000);
} catch (InterruptedException e) {
e.printStackTrace();
}
//事件默认开启,这里清空数据后,重新开启
LambdaUpdateWrapper<Event> update = Wrappers.lambdaUpdate();
update.eq(Event::getId, eventId)
.set(Event::getStatus, 1)
.set(Event::getFirstOpenTime, new Date());
this.update(update);
//删除数据处理到的时间节点
Event event = this.getById(eventId);
redisUtil.del("SUBJECT_DATA_TO_REDIS::" + event.getEventCode());
}); });
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论