xservice/xservice-cornucopia
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

perf:周六周日过滤小馆，不查询当天小馆信息

Browse Source
This commit is contained in:
Xiang
2026-01-19 11:22:03 +08:00
parent 906a1d84fa
commit ec8826508a
1 changed files with 19 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
xservice-server/src/main/java/com/xiang/app/schedule/jntyzx/JtVenuePullTask.java
View File

@@ -18,8 +18,8 @@ import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import java.time.DayOfWeek;
import java.time.LocalDate; import java.time.LocalDate;
import java.time.LocalDateTime;
import java.util.List; import java.util.List;
import java.util.Objects; import java.util.Objects;
@@ -47,6 +47,8 @@ public class JtVenuePullTask {
return; return;
} }
String token; String token;
LocalDateTime now = LocalDateTime.now();
int dayOfWeek = now.getDayOfWeek().getValue();
for (UserTokenInfoDO userTokenInfoDO : availableUser) { for (UserTokenInfoDO userTokenInfoDO : availableUser) {
if (Objects.isNull(userTokenInfoDO)) { if (Objects.isNull(userTokenInfoDO)) {
@@ -62,14 +64,11 @@ public class JtVenuePullTask {
} }
venueService.saveOrUpdateTodayVenueInfo(sitePositionLists); venueService.saveOrUpdateTodayVenueInfo(sitePositionLists);
sitePositionLists = sitePositionLists.stream().filter(VenueInfoUtils::get8210VenueInfo).toList(); sitePositionLists = handleMsgSendList(sitePositionLists, dayOfWeek);
if (CollectionUtils.isEmpty(sitePositionLists)) {
return;
}
sitePositionLists = sitePositionLists.stream().filter(item -> StringUtils.equals(item.getContacts(), "0")).toList();
if (CollectionUtils.isEmpty(sitePositionLists)) { if (CollectionUtils.isEmpty(sitePositionLists)) {
return; return;
} }
StringBuffer msg = new StringBuffer("查询到20:00-22:00空闲场地信息===>时间:" + DateUtils.getDateFromDate(LocalDate.now()) + "\n"); StringBuffer msg = new StringBuffer("查询到20:00-22:00空闲场地信息===>时间:" + DateUtils.getDateFromDate(LocalDate.now()) + "\n");
sitePositionLists.forEach(item -> { sitePositionLists.forEach(item -> {
msg.append(item.getPlaceName()).append("\n"); msg.append(item.getPlaceName()).append("\n");
@@ -77,4 +76,18 @@ public class JtVenuePullTask {
jtDingTalkFactory.sendMsg(msg.toString()); jtDingTalkFactory.sendMsg(msg.toString());
} }
} }
private List<SitePositionList> handleMsgSendList(List<SitePositionList> sitePositionLists, int dayOfWeek) {
if (dayOfWeek == 6 || dayOfWeek == 7) {
return sitePositionLists.stream()
.filter(VenueInfoUtils::get8210VenueInfo)
.filter(item -> StringUtils.equals(item.getContacts(), "0"))
.filter(item -> !item.getPlaceName().contains("小馆"))
.toList();
}
return sitePositionLists.stream()
.filter(VenueInfoUtils::get8210VenueInfo)
.filter(item -> StringUtils.equals(item.getContacts(), "0"))
.toList();
}
} }