提交 18ee6352 作者: 刘凯歌

合并分支 'event_fusion_dev' 到 'event_fusion'

【自定义专题】统计接口特殊处理,后续优化

查看合并请求 !12
......@@ -264,14 +264,15 @@ public class SubjectManageController {
*/
@GetMapping(value = "/statisticInfo")
private Result<?> statisticInfo(@RequestParam List<String> subjectIds) {
List<SubjectStatisticInfo> statisticInfoList = subjectService.statisticInfo(subjectIds);
//异步更新专题统计信息表的数据
CompletableFuture.runAsync(() -> {
if (CollectionUtils.isNotEmpty(statisticInfoList)) {
subjectStatisticInfoService.batchModify(statisticInfoList);
}
});
return Result.OK(statisticInfoList);
//List<SubjectStatisticInfo> statisticInfoList = subjectService.statisticInfo(subjectIds);
////异步更新专题统计信息表的数据
//CompletableFuture.runAsync(() -> {
// if (CollectionUtils.isNotEmpty(statisticInfoList)) {
// subjectStatisticInfoService.batchModify(statisticInfoList);
// }
//});
//return Result.OK(statisticInfoList);
return Result.OK(new ArrayList<>());
}
/**
......
......@@ -32,7 +32,7 @@ public class SubjectStatisticTask {
@Autowired
private SubjectStatisticInfoService subjectStatisticInfoService;
@Scheduled(cron = "0 30 0 * * ?")
//@Scheduled(cron = "0 30 0 * * ?")
public void statistic() {
LambdaQueryWrapper<Subject> queryWrapper = Wrappers.lambdaQuery();
queryWrapper.select(Subject::getId).eq(Subject::getSubjectType, 1);
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论