diff --git a/m2pool-modules/m2pool-pool/src/main/java/com/m2pool/pool/service/impl/PoolServiceImpl.java b/m2pool-modules/m2pool-pool/src/main/java/com/m2pool/pool/service/impl/PoolServiceImpl.java index 3b7272c..0ceb5bf 100644 --- a/m2pool-modules/m2pool-pool/src/main/java/com/m2pool/pool/service/impl/PoolServiceImpl.java +++ b/m2pool-modules/m2pool-pool/src/main/java/com/m2pool/pool/service/impl/PoolServiceImpl.java @@ -33,6 +33,7 @@ import java.time.LocalDateTime; import java.time.ZoneId; import java.util.*; import java.util.concurrent.CompletableFuture; +import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; /** @@ -192,8 +193,8 @@ public class PoolServiceImpl implements PoolService { List priceList = poolMapper.getHourPoolPowerList(pool.getCoin()); int scale = PoolProfitScale.getScaleByCoin(pool.getCoin()); - PowerLineDto powerLineDto = priceList.stream() + .filter(e -> e.getDate().after(DateUtils.toDate(LocalDateTime.now().toLocalDate().atStartOfDay()))) .max(Comparator.comparing(PowerLineDto::getPrice)).orElse(new PowerLineDto()); if("1h".equals(vo.getInterval()) || "rt".equals(vo.getInterval())){