From 4957e91b9cbd769a95872329d5fd628c211d5655 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 03 Nov 2022 17:24:50 +0800
Subject: [PATCH] 20221021
---
src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java | 88 +++++++++++++++++++++++++++++++++++--------
1 files changed, 71 insertions(+), 17 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 f2427b0..ff4c479 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
@@ -1,6 +1,7 @@
package cc.mrbird.febs.dapp.service.impl;
import cc.mrbird.febs.common.contants.AppContants;
+import cc.mrbird.febs.common.entity.FebsResponse;
import cc.mrbird.febs.common.utils.LoginUserUtil;
import cc.mrbird.febs.common.utils.RedisUtils;
import cc.mrbird.febs.dapp.chain.ChainEnum;
@@ -14,31 +15,25 @@
import cc.mrbird.febs.dapp.utils.OnlineTransferUtil;
import cc.mrbird.febs.dapp.vo.RedisTransferPoolVo;
import cc.mrbird.febs.dapp.vo.SlipSettingVo;
-import cc.mrbird.febs.job.SystemTradeJob;
import cc.mrbird.febs.rabbit.producer.ChainProducer;
import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.date.DateField;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUnit;
import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.RandomUtil;
import cn.hutool.core.util.StrUtil;
+import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSONObject;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
-import org.jsoup.Jsoup;
-import org.jsoup.nodes.Document;
-import org.jsoup.nodes.Element;
-import org.jsoup.select.Elements;
-import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
-import java.io.IOException;
import java.math.BigDecimal;
import java.math.BigInteger;
import java.math.RoundingMode;
-import java.net.MalformedURLException;
-import java.net.URL;
import java.util.*;
/**
@@ -62,6 +57,7 @@
private final DappMemberBoxRecordMapper dappMemberBoxRecordMapper;
private final DappWalletCoinDao dappWalletCoinDao;
private final DappSdeWithdrawFeeDao dappSdeWithdrawFeeDao;
+ private final DappPriceRecordDao dappPriceRecordDao;
@Override
@@ -145,12 +141,9 @@
Object o = redisUtils.get(AppContants.REDIS_KEY_COIN_REMAIN + member.getAddress());
- BigDecimal minLimit = new BigDecimal(50);
- BigDecimal coinTotal;
- if (balance.compareTo(minLimit) > 0) {
+ BigDecimal coinTotal = balance;
+ if (this.hasProfit(member.getAddress())) {
coinTotal = balance.multiply(BigDecimal.valueOf(0.3)).setScale(instance.decimals(), RoundingMode.HALF_DOWN);
- } else {
- coinTotal = new BigDecimal(50);
}
BigDecimal remain;
@@ -892,9 +885,6 @@
return cardCntMap;
}
- @Autowired
- private DappPriceRecordDao dappPriceRecordDao;
-
@Override
public void tfcNewPrice() {
BigDecimal newPrice = newestPrice();
@@ -919,4 +909,68 @@
// 给影子生态发送价格
chainProducer.sendTfcNewPrice(newPrice.toPlainString());
}
+
+ @Override
+ public List<DappPriceRecordEntity> findPriceListIn24H() {
+ DateTime startTime = DateUtil.offset(new Date(), DateField.HOUR, -24);
+ List<DappPriceRecordEntity> list = dappPriceRecordDao.selectPriceListInStartTimeAndEndTime(startTime, new Date());
+ list.forEach(item -> {
+ item.setTime(DateUtil.format(item.getCreateTime(), "HH:mm"));
+ });
+ return list;
+ }
+
+ @Override
+ public List<DataDictionaryCustom> findDataDicByType(String type) {
+ return dataDictionaryCustomMapper.selectDicByType(type);
+ }
+
+ @Override
+ public void levelSystemSetting(Map<String, Object> map) {
+ for (Map.Entry<String, Object> entry : map.entrySet()) {
+ if (entry.getValue() instanceof String) {
+ dataDictionaryCustomMapper.updateDicValueByTypeAndCode(null, entry.getKey(), (String) entry.getValue());
+ } else {
+ List<LinkedHashMap<String, Object>> value = (List<LinkedHashMap<String, Object>>) entry.getValue();
+
+ for (LinkedHashMap<String, Object> dic : value) {
+ String type = (String) dic.get("type");
+ String code = (String) dic.get("code");
+ String dataValue = (String) dic.get("value");
+ dataDictionaryCustomMapper.updateDicValueByTypeAndCode(type, code, dataValue);
+ }
+ }
+ }
+ }
+
+ @Override
+ @Transactional
+ public FebsResponse enableOnHook(Long id) {
+ DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectById(id);
+ if (ObjectUtil.isEmpty(dataDictionaryCustom)) {
+ return new FebsResponse().fail().message("网络繁忙，请刷新当前页面");
+ }
+ String type = dataDictionaryCustom.getType();
+ String code = dataDictionaryCustom.getCode();
+ String dicValue = dataDictionaryCustom.getValue();
+ cn.hutool.json.JSONObject jsonObject = JSONUtil.parseObj(dicValue);
+ jsonObject.set("state",1);
+ dataDictionaryCustomMapper.updateDicValueByTypeAndCode(type, code, jsonObject.toString());
+ return new FebsResponse().success();
+ }
+
+ @Override
+ public FebsResponse disableOnHook(Long id) {
+ DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectById(id);
+ if (ObjectUtil.isEmpty(dataDictionaryCustom)) {
+ return new FebsResponse().fail().message("网络繁忙，请刷新当前页面");
+ }
+ String type = dataDictionaryCustom.getType();
+ String code = dataDictionaryCustom.getCode();
+ String dicValue = dataDictionaryCustom.getValue();
+ cn.hutool.json.JSONObject jsonObject = JSONUtil.parseObj(dicValue);
+ jsonObject.set("state",2);
+ dataDictionaryCustomMapper.updateDicValueByTypeAndCode(type, code, jsonObject.toString());
+ return new FebsResponse().success();
+ }
}
--
Gitblit v1.9.1