From ee787fe1df157b30f20b3b994126d98e06cce377 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Wed, 31 May 2023 10:49:27 +0800
Subject: [PATCH] twoCoin项目修改
---
src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java | 14 +++++---------
1 files changed, 5 insertions(+), 9 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
index e013699..d0f307c 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
@@ -1661,6 +1661,7 @@
DataDictionaryCustom coinAPriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
PoolEnum.COIN_A_PRICE.getType(),
PoolEnum.COIN_A_PRICE.getCode());
+
BigDecimal coinAPrice = coinAUsdt.divide(coinACnt,12,BigDecimal.ROUND_DOWN);
coinAPriceDic.setValue(coinAPrice.toString());
dataDictionaryCustomMapper.updateById(coinAPriceDic);
@@ -1675,7 +1676,7 @@
DappAKlineEntity oldOne = dappAKlineMapper.selectOneByType();
if(ObjectUtil.isNotEmpty(oldOne)){
dappAKlineEntity.setOpenPrice(oldOne.getClosePrice());
- dappAKlineEntity.setLowestPrice(oldOne.getOpenPrice());
+ dappAKlineEntity.setLowestPrice(oldOne.getClosePrice());
}else{
dappAKlineEntity.setOpenPrice(coinAPrice);
dappAKlineEntity.setLowestPrice(coinAPrice);
@@ -1752,7 +1753,7 @@
dappAKlineEntity.setType(1);
if(CollUtil.isNotEmpty(dappAKlineEntities)){
- List<BigDecimal> openPriceList = dappAKlineEntities.stream().map(DappAKlineEntity::getClosePrice).collect(Collectors.toList());
+ List<BigDecimal> openPriceList = dappAKlineEntities.stream().map(DappAKlineEntity::getOpenPrice).collect(Collectors.toList());
BigDecimal openPrice = openPriceList.stream().min(BigDecimal::compareTo).get();
dappAKlineEntity.setOpenPrice(openPrice);
//获取最高价
@@ -1768,12 +1769,7 @@
dappAKlineEntity.setHighestPrice(coinAPrice);
dappAKlineEntity.setLowestPrice(coinAPrice);
}
- DappAKlineEntity oldOne = dappAKlineMapper.selectOneByType();
- if(ObjectUtil.isNotEmpty(oldOne)){
- dappAKlineEntity.setClosePrice(oldOne.getClosePrice());
- }else{
- dappAKlineEntity.setClosePrice(coinAPrice);
- }
+ dappAKlineEntity.setClosePrice(coinAPrice);
dappAKlineMapper.insert(dappAKlineEntity);
chainProducer.sendAntKLineMsg(1);
@@ -1991,7 +1987,7 @@
DappAKlineEntity oldOne = dappAKlineMapper.selectOneByType();
if(ObjectUtil.isNotEmpty(oldOne)){
dappAKlineEntity.setOpenPrice(oldOne.getClosePrice());
- dappAKlineEntity.setLowestPrice(oldOne.getOpenPrice());
+ dappAKlineEntity.setLowestPrice(oldOne.getClosePrice());
}else{
dappAKlineEntity.setOpenPrice(coinAPrice);
dappAKlineEntity.setLowestPrice(coinAPrice);
--
Gitblit v1.9.1