Compare commits
3 Commits
f046427480
...
7d3b3758f3
| Author | SHA1 | Date | |
|---|---|---|---|
| 7d3b3758f3 | |||
| d6aab42892 | |||
| 5cd4875cf9 |
@@ -58,8 +58,10 @@ public class TaskController extends SimpleControllerSupport<Task, Void, TaskCont
|
||||
}
|
||||
|
||||
private TaskCost calculateCost(LocalDateTime start, LocalDateTime finish) {
|
||||
if (ObjectUtil.isNull(start) || ObjectUtil.isNull(finish)) {
|
||||
if (ObjectUtil.isNull(start)) {
|
||||
return new TaskCost(null, null);
|
||||
} else if (ObjectUtil.isNull(finish)) {
|
||||
finish = LocalDateTime.now();
|
||||
}
|
||||
var duration = Duration.between(start, finish).toMillis();
|
||||
return new TaskCost(
|
||||
|
||||
@@ -56,10 +56,12 @@ public class UpdateDailyTask extends TaskRunner {
|
||||
var existsTradeDates = dailyRepository.findDistinctTradeDate();
|
||||
var nowDate = LocalDate.now();
|
||||
var stocksMap = stockRepository.findAll().stream().collect(Collectors.toMap(Stock::getCode, stock -> stock));
|
||||
tradeDates.parallelStream()
|
||||
var targetTradeDates = tradeDates.stream()
|
||||
.filter(date -> date.isBefore(nowDate) || date.isEqual(nowDate))
|
||||
.filter(date -> !existsTradeDates.contains(date))
|
||||
.forEach(tradeDate -> {
|
||||
.toList();
|
||||
for (int index = 0, total = targetTradeDates.size(); index < total; index++) {
|
||||
var tradeDate = targetTradeDates.get(index);
|
||||
var factorResponse = tuShareService.factorList(tradeDate);
|
||||
var factorMap = new HashMap<String, Double>();
|
||||
for (List<String> item : factorResponse.data().items()) {
|
||||
@@ -88,7 +90,8 @@ public class UpdateDailyTask extends TaskRunner {
|
||||
dailyRepository.save(daily);
|
||||
}
|
||||
}
|
||||
});
|
||||
updater.update(index * 1.0 / total);
|
||||
}
|
||||
|
||||
return null;
|
||||
}
|
||||
|
||||
@@ -28,7 +28,7 @@
|
||||
</appender>
|
||||
|
||||
<logger name="com.zaxxer.hikari" level="ERROR"/>
|
||||
<logger name="org.hibernate.SQL" level="DEBUG"/>
|
||||
<!--<logger name="org.hibernate.SQL" level="DEBUG"/>-->
|
||||
|
||||
<root level="INFO">
|
||||
<appender-ref ref="Console"/>
|
||||
|
||||
Reference in New Issue
Block a user