1
0

feat: 升级JDK到21

This commit is contained in:
2025-09-17 17:02:20 +08:00
parent 868feeb34d
commit 585b37a1cc
7 changed files with 96 additions and 9 deletions

View File

@@ -36,7 +36,7 @@ public class QuartzService {
var tasks = new ArrayList<QuartzTask>();
for (var key : scheduler.getJobKeys(GroupMatcher.anyGroup())) {
var detail = scheduler.getJobDetail(key);
var trigger = (CronTrigger) scheduler.getTriggersOfJob(key).get(0);
var trigger = (CronTrigger) scheduler.getTriggersOfJob(key).getFirst();
tasks.add(new QuartzTask(
detail.getKey().getName(),
detail.getJobDataMap().getLong("template_id"),

View File

@@ -41,7 +41,7 @@ public class CheckDailyNode extends TaskNodeComponent {
.data()
.items()
.stream()
.map(item -> LocalDate.parse(item.get(0), TuShareService.TRADE_FORMAT))
.map(item -> LocalDate.parse(item.getFirst(), TuShareService.TRADE_FORMAT))
.filter(date -> date.isBefore(nowDate) || date.isEqual(nowDate))
.toList();
var total = stocks.size();

View File

@@ -42,8 +42,8 @@ public class UpdateDailyNode extends NodeComponent {
for (String exchange : List.of("SSE", "SZSE", "BSE")) {
var response = tuShareService.tradeDateList(exchange);
for (List<String> item : response.data().items()) {
if (ObjectUtil.isNotEmpty(item) && StrUtil.isNotBlank(item.get(0))) {
tradeDates.add(LocalDate.parse(item.get(0), TuShareService.TRADE_FORMAT));
if (ObjectUtil.isNotEmpty(item) && StrUtil.isNotBlank(item.getFirst())) {
tradeDates.add(LocalDate.parse(item.getFirst(), TuShareService.TRADE_FORMAT));
}
}
}
@@ -53,7 +53,7 @@ public class UpdateDailyNode extends NodeComponent {
tradeDates.parallelStream()
.filter(date -> date.isBefore(nowDate) || date.isEqual(nowDate))
.filter(date -> !existsTradeDates.contains(date))
.filter(date -> date.isAfter(LocalDate.of(2024, 12, 31)))
// .filter(date -> date.isAfter(LocalDate.of(2024, 12, 31)))
.forEach(tradeDate -> {
var factorResponse = tuShareService.factorList(tradeDate);
var factorMap = new HashMap<String, Double>();