lizixuan/m2pool_web_backend
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update mona,grs,nexa,rxd 矿机收益定时任务修改

Browse Source
This commit is contained in:
yyb
2025-10-15 14:33:10 +08:00
parent 3bf81f5749
commit 4462ba7e7e
1 changed files with 34 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

63
m2pool-modules/m2pool-pool/src/main/java/com/m2pool/pool/task/IncomeTask.java
View File

@@ -99,14 +99,15 @@ public class IncomeTask {
BigDecimal totalPower = nexaMinerIncomes.stream()
.map(MinerIncomeDto::getAvgPower)
.reduce(BigDecimal::add).orElse(BigDecimal.ZERO);
//3.获取当前nexa币价
String price = redisService.getCacheObject(RedisKey.NEXA_PRICE);
BigDecimal nexaPrice;
if (price == null){
nexaPrice = poolMapper.selectPrice("nexa");
}else{
nexaPrice = new BigDecimal(price);
}
//3.获取当前nexa币价（这个key是在6379 redis实例的 6 号数据库中，但是默认配置是0号库获取的币价一定为null）
//String price = redisService.getCacheObject(RedisKey.NEXA_PRICE);
//BigDecimal nexaPrice ;
//if (price == null){
// nexaPrice = poolMapper.selectPrice("nexa");
//}else{
// nexaPrice = new BigDecimal(price);
//}
BigDecimal nexaPrice = poolMapper.selectPrice("nexa");
//4.获取nexa 1-2小时前的报块数
BigDecimal nexaBlocks = incomeMapper.getVaildBlcoks("nexa", start, end);
@@ -140,13 +141,15 @@ public class IncomeTask {
.map(MinerIncomeDto::getAvgPower)
.reduce(BigDecimal::add).orElse(BigDecimal.ZERO);
//3.获取当前rxd币价
String price = redisService.getCacheObject(RedisKey.RXD_PRICE);
BigDecimal rxdPrice;
if (price == null){
rxdPrice = poolMapper.selectPrice("rxd");
}else{
rxdPrice = new BigDecimal(price);
}
//String price = redisService.getCacheObject(RedisKey.RXD_PRICE);
//BigDecimal rxdPrice;
//if (price == null){
// rxdPrice = poolMapper.selectPrice("rxd");
//}else{
// rxdPrice = new BigDecimal(price);
//}
BigDecimal rxdPrice = poolMapper.selectPrice("rxd");
//4.获取rxd 1-2小时前的报块数
BigDecimal rxdBlocks = incomeMapper.getVaildBlcoks("rxd", start, end);
@@ -180,13 +183,14 @@ public class IncomeTask {
.map(MinerIncomeDto::getAvgPower)
.reduce(BigDecimal::add).orElse(BigDecimal.ZERO);
//3.获取当前mona币价
String price = redisService.getCacheObject(RedisKey.MONA_PRICE);
BigDecimal monaPrice;
if (price == null){
monaPrice = poolMapper.selectPrice("mona");
}else{
monaPrice = new BigDecimal(price);
}
//String price = redisService.getCacheObject(RedisKey.MONA_PRICE);
//BigDecimal monaPrice;
//if (price == null){
// monaPrice = poolMapper.selectPrice("mona");
//}else{
// monaPrice = new BigDecimal(price);
//}
BigDecimal monaPrice = poolMapper.selectPrice("mona");
//4.获取mona 1-2小时前的报块数
BigDecimal monaBlocks = incomeMapper.getVaildBlcoks("rxd", start, end);
@@ -220,13 +224,14 @@ public class IncomeTask {
.map(MinerIncomeDto::getAvgPower)
.reduce(BigDecimal::add).orElse(BigDecimal.ZERO);
//3.获取当前grs币价
String price = redisService.getCacheObject(RedisKey.GRS_PRICE);
BigDecimal grsPrice ;
if (price == null){
grsPrice = poolMapper.selectPrice("grs");
}else{
grsPrice = new BigDecimal(price);
}
//String price = redisService.getCacheObject(RedisKey.GRS_PRICE);
//BigDecimal grsPrice ;
//if (price == null){
// grsPrice = poolMapper.selectPrice("grs");
//}else{
// grsPrice = new BigDecimal(price);
//}
BigDecimal grsPrice = poolMapper.selectPrice("grs");
//4.获取rxd 1-2小时前的报块数
BigDecimal grsBlocks = incomeMapper.getVaildBlcoks("grs", start, end);