From 673d9890158a00c42a0cb187d7f40b599d272da9 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Sun, 28 Apr 2024 12:03:03 +0800
Subject: [PATCH] 测试环境新版
---
src/main/java/cc/mrbird/febs/job/SystemTradeJob.java | 302 +++++++++++++++++++++++++-------------------------
1 files changed, 152 insertions(+), 150 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/job/SystemTradeJob.java b/src/main/java/cc/mrbird/febs/job/SystemTradeJob.java
index 3cb70b3..ef403f2 100644
--- a/src/main/java/cc/mrbird/febs/job/SystemTradeJob.java
+++ b/src/main/java/cc/mrbird/febs/job/SystemTradeJob.java
@@ -1,150 +1,152 @@
-package cc.mrbird.febs.job;
-
-import cc.mrbird.febs.common.contants.AppContants;
-import cc.mrbird.febs.common.utils.RedisUtils;
-import cc.mrbird.febs.dapp.chain.ChainEnum;
-import cc.mrbird.febs.dapp.chain.ChainService;
-import cc.mrbird.febs.dapp.entity.DataDictionaryCustom;
-import cc.mrbird.febs.dapp.mapper.DataDictionaryCustomMapper;
-import cc.mrbird.febs.dapp.service.DappSystemService;
-import cc.mrbird.febs.dapp.vo.RedisTransferPoolVo;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Component;
-
-import javax.annotation.Resource;
-import java.math.BigDecimal;
-import java.math.RoundingMode;
-
-/**
- * @author wzy
- * @date 2022-05-30
- **/
-@Slf4j
-@Component
-public class SystemTradeJob {
-
- @Autowired
- private RedisUtils redisUtils;
- @Autowired
- private DappSystemService systemService;
- @Resource
- private DataDictionaryCustomMapper dataDictionaryCustomMapper;
-
- // 最低容量(百分比)
- private final BigDecimal volProp = new BigDecimal("0.5");
-
- /**
- * 中转池容量计算
- *
- * 源池出币量最低为0.5%每天基础量，作为可s交易量
- * 按当天交易完成量的百分比，第二天出币补齐已成交部分
- * 按每天的基础量，同一阶段累计完成5次100%交易量后增加0.5%基础出币量比例出币，无上限……
- * 当一个阶段的当日量72小时未100%交易完成，中转池回到上一阶段阶容量。
- * 例：当进入一个新阶段为每天出币量为3%时，此笔出量累计72小时未完全成交，源池出币量回到上一阶段每天出币2.5%，需重计5倍量，……以此类推增加或递减
- */
- @Scheduled(cron = "0 0 0 * * ?")
- public void transferPoolVol() {
- log.info("中转池容量");
-
- String hasStart = redisUtils.getString(AppContants.SYSTEM_START_FLAG);
- if (!"start".equals(hasStart)) {
- log.info("系统未启动");
- return;
- }
-
- // 源池初始化容量
- DataDictionaryCustom dic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(AppContants.DIC_TYPE_SYSTEM_SETTING, AppContants.DIC_VALUE_SYSTEM_SOURCE_POOL_VOL);
- BigDecimal basicVol = new BigDecimal(dic.getValue());
-
- Object o = redisUtils.get(AppContants.REDIS_KEY_TRANSFER_POOL_VOL);
- if (o == null) {
- RedisTransferPoolVo transferPool= new RedisTransferPoolVo();
- BigDecimal total = basicVol.multiply(volProp.divide(BigDecimal.valueOf(100), 4, RoundingMode.HALF_UP));
- transferPool.setTodayVol(total);
- transferPool.setTodayProp(volProp);
- transferPool.setFinishCnt(0);
- transferPool.setFinishCnt(0);
- redisUtils.set(AppContants.REDIS_KEY_TRANSFER_POOL_VOL, transferPool);
- redisUtils.set(AppContants.REDIS_KEY_TRANSFER_POOL_VOL_REMAIN, total);
-
- redisUtils.set(AppContants.REDIS_KEY_MINE_TRANSFER_POOL_TRADE_CNT, BigDecimal.ZERO);
- return;
- }
-
- RedisTransferPoolVo transferPool = (RedisTransferPoolVo) o;
- BigDecimal remain = (BigDecimal) redisUtils.get(AppContants.REDIS_KEY_TRANSFER_POOL_VOL_REMAIN);
-
- // 设置当日成交量
- redisUtils.set(AppContants.REDIS_KEY_MINE_TRANSFER_POOL_TRADE_CNT, transferPool.getTodayVol().subtract(remain));
-
- // 全卖了
- if (remain.compareTo(BigDecimal.ZERO) == 0) {
- int finishCnt = transferPool.getFinishCnt() + 1;
- BigDecimal targetProp = transferPool.getTodayProp();
- if (finishCnt == 5) {
- targetProp = transferPool.getTodayVol().add(volProp);
- transferPool.setTodayProp(targetProp);
- transferPool.setFinishCnt(0);
- } else {
- transferPool.setFinishCnt(finishCnt);
- }
-
- BigDecimal total = basicVol.multiply(targetProp.divide(BigDecimal.valueOf(100), 4, RoundingMode.HALF_UP));
- transferPool.setTodayVol(total);
- transferPool.setUnFinishCnt(0);
- redisUtils.set(AppContants.REDIS_KEY_TRANSFER_POOL_VOL_REMAIN, total);
-
- } else {
- int unFinishCnt = transferPool.getUnFinishCnt() + 1;
- BigDecimal targetProp = transferPool.getTodayProp();
- if (unFinishCnt >= 3) {
- targetProp = transferPool.getTodayProp().compareTo(volProp) == 0 ? volProp : transferPool.getTodayProp().subtract(volProp);
- transferPool.setTodayProp(targetProp);
- transferPool.setUnFinishCnt(0);
- } else {
- transferPool.setUnFinishCnt(unFinishCnt);
- }
- BigDecimal aa = targetProp.divide(BigDecimal.valueOf(100), 4, RoundingMode.HALF_UP);
- BigDecimal total = basicVol.multiply(aa);
- transferPool.setTodayVol(total);
- redisUtils.set(AppContants.REDIS_KEY_TRANSFER_POOL_VOL_REMAIN, total);
- }
-
- redisUtils.set(AppContants.REDIS_KEY_TRANSFER_POOL_VOL, transferPool);
- }
-
- /**
- * 源池每日出U限制
- *
- * 源池每天可交易量为源池总USDT数量的10%，以上一天00:00时读取源池实时USDT数量为参考，作为当天可交易USDT数量。
- */
- @Scheduled(cron = "0 0 0 * * ?")
- public void sourcePoolUsdtOutLimit() {
- log.info("源池每日出U限制");
-
- String hasStart = redisUtils.getString(AppContants.SYSTEM_START_FLAG);
- if (!"start".equals(hasStart)) {
- log.info("系统未启动");
- return;
- }
- BigDecimal sourceBalance = ChainService.getInstance(ChainEnum.BSC_USDT.name()).balanceOf(ChainEnum.BSC_USDT_SOURCE.getAddress());
-
- BigDecimal total = sourceBalance.multiply(BigDecimal.valueOf(0.1)).setScale(4, RoundingMode.HALF_DOWN);
- redisUtils.set(AppContants.REDIS_KEY_USDT_OUT_LIMIT, total);
- redisUtils.set(AppContants.REDIS_KEY_USDT_OUT_LIMIT_REMAIN, total);
- }
-
-
- /**
- * 挖矿
- *
- * 以中转池成交数1：1出矿（中转池卖出多少，矿池则1：1出币），每个地址所得=出币量*（单个地址持币量/全网持币量）
- */
- @Scheduled(cron = "0 0 2 * * ?")
- public void mineJob() {
- log.info("挖矿");
- systemService.mining();
- }
-}
+//package cc.mrbird.febs.job;
+//
+//import cc.mrbird.febs.common.contants.AppContants;
+//import cc.mrbird.febs.common.utils.RedisUtils;
+//import cc.mrbird.febs.dapp.chain.ChainEnum;
+//import cc.mrbird.febs.dapp.chain.ChainService;
+//import cc.mrbird.febs.dapp.entity.DataDictionaryCustom;
+//import cc.mrbird.febs.dapp.mapper.DataDictionaryCustomMapper;
+//import cc.mrbird.febs.dapp.service.DappSystemService;
+//import cc.mrbird.febs.dapp.vo.RedisTransferPoolVo;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+//import org.springframework.scheduling.annotation.Scheduled;
+//import org.springframework.stereotype.Component;
+//
+//import javax.annotation.Resource;
+//import java.math.BigDecimal;
+//import java.math.RoundingMode;
+//
+///**
+// * @author wzy
+// * @date 2022-05-30
+// **/
+//@Slf4j
+//@Component
+//@ConditionalOnProperty(prefix = "system", name = "trade-job", havingValue = "true")
+//public class SystemTradeJob {
+//
+// @Autowired
+// private RedisUtils redisUtils;
+// @Autowired
+// private DappSystemService systemService;
+// @Resource
+// private DataDictionaryCustomMapper dataDictionaryCustomMapper;
+//
+// // 最低容量(百分比)
+// private final BigDecimal volProp = new BigDecimal("0.5");
+//
+// /**
+// * 中转池容量计算
+// *
+// * 源池出币量最低为0.5%每天基础量，作为可s交易量
+// * 按当天交易完成量的百分比，第二天出币补齐已成交部分
+// * 按每天的基础量，同一阶段累计完成5次100%交易量后增加0.5%基础出币量比例出币，无上限……
+// * 当一个阶段的当日量72小时未100%交易完成，中转池回到上一阶段阶容量。
+// * 例：当进入一个新阶段为每天出币量为3%时，此笔出量累计72小时未完全成交，源池出币量回到上一阶段每天出币2.5%，需重计5倍量，……以此类推增加或递减
+// */
+// @Scheduled(cron = "0 0 0 * * ?")
+// public void transferPoolVol() {
+// log.info("中转池容量");
+//
+// String hasStart = redisUtils.getString(AppContants.SYSTEM_START_FLAG);
+// if (!"start".equals(hasStart)) {
+// log.info("系统未启动");
+// return;
+// }
+//
+// // 源池初始化容量
+// DataDictionaryCustom dic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(AppContants.DIC_TYPE_SYSTEM_SETTING, AppContants.DIC_VALUE_SYSTEM_SOURCE_POOL_VOL);
+// BigDecimal basicVol = new BigDecimal(dic.getValue());
+//
+// Object o = redisUtils.get(AppContants.REDIS_KEY_TRANSFER_POOL_VOL);
+// if (o == null) {
+// RedisTransferPoolVo transferPool= new RedisTransferPoolVo();
+// BigDecimal total = basicVol.multiply(volProp.divide(BigDecimal.valueOf(100), 4, RoundingMode.HALF_UP));
+// transferPool.setTodayVol(total);
+// transferPool.setTodayProp(volProp);
+// transferPool.setFinishCnt(0);
+// transferPool.setFinishCnt(0);
+// redisUtils.set(AppContants.REDIS_KEY_TRANSFER_POOL_VOL, transferPool);
+// redisUtils.set(AppContants.REDIS_KEY_TRANSFER_POOL_VOL_REMAIN, total);
+//
+// redisUtils.set(AppContants.REDIS_KEY_MINE_TRANSFER_POOL_TRADE_CNT, BigDecimal.ZERO);
+// return;
+// }
+//
+// RedisTransferPoolVo transferPool = (RedisTransferPoolVo) o;
+// BigDecimal remain = (BigDecimal) redisUtils.get(AppContants.REDIS_KEY_TRANSFER_POOL_VOL_REMAIN);
+//
+// // 设置当日成交量
+// redisUtils.set(AppContants.REDIS_KEY_MINE_TRANSFER_POOL_TRADE_CNT, transferPool.getTodayVol().subtract(remain));
+//
+// // 全卖了
+// if (remain.compareTo(BigDecimal.ZERO) == 0) {
+// int finishCnt = transferPool.getFinishCnt() + 1;
+// BigDecimal targetProp = transferPool.getTodayProp();
+// if (finishCnt == 5) {
+// targetProp = transferPool.getTodayVol().add(volProp);
+// transferPool.setTodayProp(targetProp);
+// transferPool.setFinishCnt(0);
+// } else {
+// transferPool.setFinishCnt(finishCnt);
+// }
+//
+// BigDecimal total = basicVol.multiply(targetProp.divide(BigDecimal.valueOf(100), 4, RoundingMode.HALF_UP));
+// transferPool.setTodayVol(total);
+// transferPool.setUnFinishCnt(0);
+// redisUtils.set(AppContants.REDIS_KEY_TRANSFER_POOL_VOL_REMAIN, total);
+//
+// } else {
+// int unFinishCnt = transferPool.getUnFinishCnt() + 1;
+// BigDecimal targetProp = transferPool.getTodayProp();
+// if (unFinishCnt >= 3) {
+// targetProp = transferPool.getTodayProp().compareTo(volProp) == 0 ? volProp : transferPool.getTodayProp().subtract(volProp);
+// transferPool.setTodayProp(targetProp);
+// transferPool.setUnFinishCnt(0);
+// } else {
+// transferPool.setUnFinishCnt(unFinishCnt);
+// }
+// BigDecimal aa = targetProp.divide(BigDecimal.valueOf(100), 4, RoundingMode.HALF_UP);
+// BigDecimal total = basicVol.multiply(aa);
+// transferPool.setTodayVol(total);
+// redisUtils.set(AppContants.REDIS_KEY_TRANSFER_POOL_VOL_REMAIN, total);
+// }
+//
+// redisUtils.set(AppContants.REDIS_KEY_TRANSFER_POOL_VOL, transferPool);
+// }
+//
+// /**
+// * 源池每日出U限制
+// *
+// * 源池每天可交易量为源池总USDT数量的10%，以上一天00:00时读取源池实时USDT数量为参考，作为当天可交易USDT数量。
+// */
+// @Scheduled(cron = "0 0 0 * * ?")
+// public void sourcePoolUsdtOutLimit() {
+// log.info("源池每日出U限制");
+//
+// String hasStart = redisUtils.getString(AppContants.SYSTEM_START_FLAG);
+// if (!"start".equals(hasStart)) {
+// log.info("系统未启动");
+// return;
+// }
+// BigDecimal sourceBalance = ChainService.getInstance(ChainEnum.BSC_USDT.name()).balanceOf(ChainEnum.BSC_USDT_SOURCE.getAddress());
+//
+// BigDecimal total = sourceBalance.multiply(BigDecimal.valueOf(0.1)).setScale(4, RoundingMode.HALF_DOWN);
+// redisUtils.set(AppContants.REDIS_KEY_USDT_OUT_LIMIT, total);
+// redisUtils.set(AppContants.REDIS_KEY_USDT_OUT_LIMIT_REMAIN, total);
+// }
+//
+//
+// /**
+// * 挖矿
+// *
+// * 以中转池成交数1：1出矿（中转池卖出多少，矿池则1：1出币），每个地址所得=出币量*（单个地址持币量/全网持币量）
+// */
+// @Scheduled(cron = "0 0 2 * * ?")
+// public void mineJob() {
+// log.info("挖矿");
+// systemService.mining();
+// }
+//}
--
Gitblit v1.9.1