From 4929188dd73894fb01ea7d92d523a561af15e3ed Mon Sep 17 00:00:00 2001 From: yyb <1416014977@qq.com> Date: Mon, 13 Oct 2025 16:17:35 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E7=9F=BF=E6=9C=BA=E7=A6=BB=E7=BA=BF?= =?UTF-8?q?=E9=82=AE=E7=AE=B1=E5=8F=91=E9=80=81=E5=AE=9A=E6=97=B6=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/m2pool/pool/service/impl/PoolServiceImpl.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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())){