diff --git a/script/src/main/java/com/xiang/xservice/application/script/jntyzx/schedule/VenueQuerySchedule.java b/script/src/main/java/com/xiang/xservice/application/script/jntyzx/schedule/VenueQuerySchedule.java index 8d28898..4dd7fdc 100644 --- a/script/src/main/java/com/xiang/xservice/application/script/jntyzx/schedule/VenueQuerySchedule.java +++ b/script/src/main/java/com/xiang/xservice/application/script/jntyzx/schedule/VenueQuerySchedule.java @@ -36,7 +36,7 @@ public class VenueQuerySchedule { @Scheduled(cron = "0 30 8 * * ?") public void venueQueryTask() { log.info("每日8:30拉取江体小程序数据定时任务"); - List sitePositionLists = venueService.queryVenueService(); + List sitePositionLists = venueService.queryTomorrowVenue(); // 6-8场地 Map> map1 = Maps.newLinkedHashMap(); // 8-10场地 diff --git a/script/src/main/java/com/xiang/xservice/application/script/jntyzx/schedule/VenueSubscribeSchedule.java b/script/src/main/java/com/xiang/xservice/application/script/jntyzx/schedule/VenueSubscribeSchedule.java new file mode 100644 index 0000000..730a764 --- /dev/null +++ b/script/src/main/java/com/xiang/xservice/application/script/jntyzx/schedule/VenueSubscribeSchedule.java @@ -0,0 +1,50 @@ +package com.xiang.xservice.application.script.jntyzx.schedule; + +import com.xiang.xservice.application.script.jntyzx.entity.pojo.VenueInfoDO; +import com.xiang.xservice.application.script.jntyzx.service.DingTalkScriptVenueService; +import com.xiang.xservice.application.script.jntyzx.service.IJntyzxHttpService; +import com.xiang.xservice.application.script.jntyzx.service.IUserTokenInfoService; +import com.xiang.xservice.application.script.jntyzx.service.IVenueService; +import com.xiang.xservice.application.script.jntyzx.utils.VenueInfoUtils; +import lombok.RequiredArgsConstructor; +import org.apache.commons.collections4.CollectionUtils; +import org.apache.commons.lang3.StringUtils; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +import java.time.LocalDateTime; +import java.util.List; +import java.util.Map; +import java.util.stream.Collectors; + +/** + * @Author: xiang + * @Date: 2025-12-16 14:26 + */ +@Component +@RequiredArgsConstructor +public class VenueSubscribeSchedule { + private final IVenueService venueService; + private final IJntyzxHttpService jntyzxHttpService; + private final IUserTokenInfoService userTokenInfoService; + private final DingTalkScriptVenueService dingTalkScriptVenueService; + @Scheduled(cron = "0 0 9 * * ?") + public void subscribe() { + List venueInfoDOS = venueService.queryCanBuyVenue(); + if (CollectionUtils.isEmpty(venueInfoDOS)) { + return; + } + Map> map = venueInfoDOS.stream().filter(VenueInfoUtils::get1221VenueInfo4Mor).collect(Collectors.groupingBy(VenueInfoDO::getPlaceName)); + String token = userTokenInfoService.getToken("Xiang"); + if (StringUtils.isBlank(token)) { + return; + } + map.keySet().parallelStream().forEach(placeName -> { + List venueInfoDOList = map.get(placeName); + Boolean order = jntyzxHttpService.createOrder(venueInfoDOList, token); + if (order) { + dingTalkScriptVenueService.sendScriptMsg("场地:" + placeName + "下单成功,请付款!时间:" + LocalDateTime.now()); + } + }); + } +}