//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();
|
// }
|
//}
|
