perf:过滤小馆

This commit is contained in:
Xiang
2026-04-03 09:04:05 +08:00
parent 9d14b3b7dc
commit a20cdc46fd

View File

@@ -48,7 +48,10 @@ public class JtVenueSubscribeTask {
return; return;
} }
List<VenueInfoDO> venueInfoDOS = venueService.queryTomorrowCanBuyVenue(); List<VenueInfoDO> venueInfoDOS = venueService.queryTomorrowCanBuyVenue();
Map<String, List<VenueInfoDO>> venueInfoMap = venueInfoDOS.stream().filter(VenueInfoUtils::get8210VenueInfo).collect(Collectors.groupingByConcurrent(VenueInfoDO::getPlaceName)); Map<String, List<VenueInfoDO>> venueInfoMap = venueInfoDOS.stream()
.filter(VenueInfoUtils::get8210VenueInfo)
.filter(item -> !StringUtils.contains(item.getPlaceName(), "小馆"))
.collect(Collectors.groupingByConcurrent(VenueInfoDO::getPlaceName));
if (MapUtils.isEmpty(venueInfoMap)) { if (MapUtils.isEmpty(venueInfoMap)) {
log.info("暂无可下单场地time:{}", System.currentTimeMillis()); log.info("暂无可下单场地time:{}", System.currentTimeMillis());
return; return;