moliparty/peko-java
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

幸运24-结算-取消土耳其区华语区

Browse Source
This commit is contained in:
khalil
2025-01-23 11:03:12 +08:00
parent 38df06aadb
commit b86c06f690
1 changed files with 7 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
accompany-scheduler/accompany-scheduler-service/src/main/java/com/accompany/scheduler/task/luckyBag/Lucky24WeekRankTask.java
View File

@@ -1,10 +1,8 @@
package com.accompany.scheduler.task.luckyBag;
import com.accompany.business.service.lucky.rank.Lucky24SendWeekRankRewardService;
import com.accompany.business.service.lucky.rank.Lucky24SendWeekRankService;
import com.accompany.common.utils.DateTimeUtil;
import com.accompany.core.model.PartitionInfo;
import com.accompany.core.service.partition.PartitionInfoService;
import com.accompany.core.enumeration.PartitionEnum;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
@@ -12,19 +10,15 @@ import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.time.DayOfWeek;
import java.time.Duration;
import java.time.ZoneId;
import java.time.ZonedDateTime;
import java.util.Date;
import java.util.List;
import java.util.concurrent.ThreadPoolExecutor;
@Component
@Slf4j
public class Lucky24WeekRankTask {
@Autowired
private PartitionInfoService partitionInfoService;
@Resource(name = "bizExecutor")
private ThreadPoolExecutor bizExecutor;
@Autowired
@@ -33,9 +27,11 @@ public class Lucky24WeekRankTask {
@Scheduled(cron = "0 1 * * * ? ")
public void lucky24WeekRankSettlement() {
Date now = new Date();
List<PartitionInfo> partitionInfoList = partitionInfoService.listAll();
for (PartitionInfo partitionInfo : partitionInfoList) {
ZonedDateTime zdt = DateTimeUtil.convertWithZoneId(now, partitionInfo.getZoneId());
for (PartitionEnum partitionEnum : PartitionEnum.values()) {
if (PartitionEnum.TURKEY.equals(partitionEnum) || PartitionEnum.CHINESS.equals(partitionEnum)){
continue;
}
ZonedDateTime zdt = DateTimeUtil.convertWithZoneId(now, partitionEnum.getZoneId());
ZonedDateTime hourAgo = zdt.minusHours(1L);
log.info("[lucky24WeekRankSettlement] zdt {} hourAgo {}, zdtDay {} hourAgoDay {}",
zdt, hourAgo, zdt.getDayOfWeek(), hourAgo.getDayOfWeek());
@@ -44,7 +40,7 @@ public class Lucky24WeekRankTask {
}
bizExecutor.execute(() -> {
Date systemHourAgo = DateTimeUtil.converLocalDateTimeToDate(hourAgo.withZoneSameInstant(ZoneId.systemDefault()).toLocalDateTime());
service.settlement(partitionInfo.getId(), systemHourAgo, true);
service.settlement(partitionEnum.getId(), systemHourAgo, true);
});
}
}