sys-dapp.git - Gitblit

parent: 2389e7e3 | patch | commit | show whitespace

Helius

2022-06-14 400410b7fec6af004920ccb77708ba10f6a833a7

fix chain bug

8 files modified

	src/main/java/cc/mrbird/febs/dapp/controller/ApiCommonController.java	2 ●●●●● patch \| view \| raw \| blame \| history
	src/main/java/cc/mrbird/febs/dapp/service/DappSystemService.java	4 ●●●●● patch \| view \| raw \| blame \| history
	src/main/java/cc/mrbird/febs/dapp/service/impl/BscCoinContractEvent.java	4 ●●●●● patch \| view \| raw \| blame \| history
	src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java	6 ●●●●● patch \| view \| raw \| blame \| history
	src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java	92 ●●●●● patch \| view \| raw \| blame \| history
	src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java	2 ●●●●● patch \| view \| raw \| blame \| history
	src/main/java/cc/mrbird/febs/job/SystemTradeJob.java	86 ●●●●● patch \| view \| raw \| blame \| history
	src/main/resources/application-dev.yml	2 ●●●●● patch \| view \| raw \| blame \| history

 src/main/java/cc/mrbird/febs/dapp/controller/ApiCommonController.java

@@ -23,7 +23,7 @@
 * @date 2022-03-17
 **/
@Slf4j
@EncryptEnable
//@EncryptEnable
@RequiredArgsConstructor
@CrossOrigin("*")
@RestController

 src/main/java/cc/mrbird/febs/dapp/service/DappSystemService.java

@@ -35,4 +35,8 @@
    void userBuyReward(Long id);

    void startSystem();

    void transferPoolSetting();

    void sourcePoolUsdtOutLimitSetting();
}

 src/main/java/cc/mrbird/febs/dapp/service/impl/BscCoinContractEvent.java

@@ -154,6 +154,10 @@
                }
                OnlineTransferUtil.addTransferRecord(e.from, e.to, amount, e.log.getTransactionHash(), DappTransferRecordEntity.TRANSFER_SOURCE_FLAG_APPLICATION, AppContants.SYMBOL_COIN);

                if (fundFlow.getAmount().add(fundFlow.getFee()).compareTo(amount) != 0) {
                    return;
                }

                BigDecimal newPrice = fundFlow.getNewestPrice();
                BigDecimal transferAmount = amount.multiply(newPrice);


 src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java

@@ -124,6 +124,12 @@

            OnlineTransferUtil.addTransferRecord(e.from, e.to, amount, e.log.getTransactionHash(), DappTransferRecordEntity.TRANSFER_SOURCE_FLAG_APPLICATION, "USDT");


            BigDecimal realCoin = amount.divide(fundFlow.getNewestPrice(), decimals, RoundingMode.HALF_UP);
            if (fundFlow.getAmount().subtract(new BigDecimal("0.1")).compareTo(realCoin) > 0) {
                fundFlow.setAmount(realCoin);
            }

            // 更改状态为已同步
            fundFlow.setStatus(2);
            fundFlow.setTargetAmount(amount);

 src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java

@@ -406,8 +406,6 @@
        chainProducer.sendOnlineTransfer(JSONObject.toJSONString(map));
    }

    @Autowired
    private SystemTradeJob systemTradeJob;

    @Override
    public void startSystem() {
@@ -416,11 +414,97 @@
        Thread thread = new Thread(new Runnable() {
            @Override
            public void run() {
                systemTradeJob.transferPoolVol();
                systemTradeJob.sourcePoolUsdtOutLimit();
                transferPoolSetting();
                sourcePoolUsdtOutLimitSetting();
            }
        });

        thread.start();
    }

    // 最低容量(百分比)
    private final BigDecimal volProp = new BigDecimal("0.5");

    @Override
    public void transferPoolSetting() {
        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);
    }

    @Override
    public void sourcePoolUsdtOutLimitSetting() {
        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);
    }
}

 src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java

@@ -144,6 +144,8 @@
            dappFundFlowEntity.setType(recordInPageDto.getType());
        }
        dappFundFlowEntity.setMemberId(member.getId());
        dappFundFlowEntity.setStatus(2);

        IPage<DappFundFlowEntity> records = dappFundFlowDao.selectInPage(page, dappFundFlowEntity);
        return records.getRecords();
    }

 src/main/java/cc/mrbird/febs/job/SystemTradeJob.java

@@ -28,14 +28,7 @@
public class SystemTradeJob {

    @Autowired
    private RedisUtils redisUtils;
    @Autowired
    private DappSystemService systemService;
    @Resource
    private DataDictionaryCustomMapper dataDictionaryCustomMapper;

    // 最低容量(百分比)
    private final BigDecimal volProp = new BigDecimal("0.5");

    /**
     * 中转池容量计算
@@ -49,72 +42,7 @@
    @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);
        systemService.transferPoolSetting();
    }

    /**
@@ -125,17 +53,7 @@
    @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);
        systemService.sourcePoolUsdtOutLimitSetting();
    }



 src/main/resources/application-dev.yml

@@ -51,4 +51,4 @@
system:
  online-transfer: false
  chain-listener: false
  trade-job: true
  trade-job: false

			@@ -23,7 +23,7 @@
			* @date 2022-03-17
			**/
			@Slf4j
			@EncryptEnable
			//@EncryptEnable
			@RequiredArgsConstructor
			@CrossOrigin("*")
			@RestController

			@@ -35,4 +35,8 @@
			void userBuyReward(Long id);

			void startSystem();

			void transferPoolSetting();

			void sourcePoolUsdtOutLimitSetting();
			}

			@@ -154,6 +154,10 @@
			}
			OnlineTransferUtil.addTransferRecord(e.from, e.to, amount, e.log.getTransactionHash(), DappTransferRecordEntity.TRANSFER_SOURCE_FLAG_APPLICATION, AppContants.SYMBOL_COIN);

			if (fundFlow.getAmount().add(fundFlow.getFee()).compareTo(amount) != 0) {
			return;
			}

			BigDecimal newPrice = fundFlow.getNewestPrice();
			BigDecimal transferAmount = amount.multiply(newPrice);

			@@ -124,6 +124,12 @@

			OnlineTransferUtil.addTransferRecord(e.from, e.to, amount, e.log.getTransactionHash(), DappTransferRecordEntity.TRANSFER_SOURCE_FLAG_APPLICATION, "USDT");


			BigDecimal realCoin = amount.divide(fundFlow.getNewestPrice(), decimals, RoundingMode.HALF_UP);
			if (fundFlow.getAmount().subtract(new BigDecimal("0.1")).compareTo(realCoin) > 0) {
			fundFlow.setAmount(realCoin);
			}

			// 更改状态为已同步
			fundFlow.setStatus(2);
			fundFlow.setTargetAmount(amount);

			@@ -406,8 +406,6 @@
			chainProducer.sendOnlineTransfer(JSONObject.toJSONString(map));
			}

			@Autowired
			private SystemTradeJob systemTradeJob;

			@Override
			public void startSystem() {
			@@ -416,11 +414,97 @@
			Thread thread = new Thread(new Runnable() {
			@Override
			public void run() {
			systemTradeJob.transferPoolVol();
			systemTradeJob.sourcePoolUsdtOutLimit();
			transferPoolSetting();
			sourcePoolUsdtOutLimitSetting();
			}
			});

			thread.start();
			}

			// 最低容量(百分比)
			private final BigDecimal volProp = new BigDecimal("0.5");

			@Override
			public void transferPoolSetting() {
			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);
			}

			@Override
			public void sourcePoolUsdtOutLimitSetting() {
			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);
			}
			}

			@@ -144,6 +144,8 @@
			dappFundFlowEntity.setType(recordInPageDto.getType());
			}
			dappFundFlowEntity.setMemberId(member.getId());
			dappFundFlowEntity.setStatus(2);

			IPage<DappFundFlowEntity> records = dappFundFlowDao.selectInPage(page, dappFundFlowEntity);
			return records.getRecords();
			}

			@@ -28,14 +28,7 @@
			public class SystemTradeJob {

			@Autowired
			private RedisUtils redisUtils;
			@Autowired
			private DappSystemService systemService;
			@Resource
			private DataDictionaryCustomMapper dataDictionaryCustomMapper;

			// 最低容量(百分比)
			private final BigDecimal volProp = new BigDecimal("0.5");

			/**
			* 中转池容量计算
			@@ -49,72 +42,7 @@
			@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);
			systemService.transferPoolSetting();
			}

			/**
			@@ -125,17 +53,7 @@
			@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);
			systemService.sourcePoolUsdtOutLimitSetting();
			}

			@@ -51,4 +51,4 @@
			system:
			online-transfer: false
			chain-listener: false
			trade-job: true
			trade-job: false