update 矿机离线邮箱发送定时任务修改
This commit is contained in:
@@ -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<PowerLineDto> 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())){
|
||||
|
||||
Reference in New Issue
Block a user