| | |
| | | dappFundFlowDao.updateById(dappFundFlowEntity); |
| | | BigDecimal subtract = amountTC.subtract(teamIncomePerkTotal); |
| | | //用户的A币账户增加divide数量 |
| | | if(amountTC.compareTo(teamIncomePerkTotal) > 0){ |
| | | DappFundFlowEntity nodeAPercentFundFlowAva = new DappFundFlowEntity( |
| | | 294L, |
| | | subtract, |
| | | FundFlowEnum.LEVEL_A_PERCENT_CNT_MEMBER.getCode(), |
| | | 2, |
| | | BigDecimal.ZERO, |
| | | null, |
| | | systemProfitId); |
| | | dappFundFlowDao.insert(nodeAPercentFundFlowAva); |
| | | dappWalletService.updateWalletMineWithLock(subtract, |
| | | 294L,1); |
| | | } |
| | | // if(amountTC.compareTo(teamIncomePerkTotal) > 0){ |
| | | // DappFundFlowEntity nodeAPercentFundFlowAva = new DappFundFlowEntity( |
| | | // 294L, |
| | | // subtract, |
| | | // FundFlowEnum.LEVEL_A_PERCENT_CNT_MEMBER.getCode(), |
| | | // 2, |
| | | // BigDecimal.ZERO, |
| | | // null, |
| | | // systemProfitId); |
| | | // dappFundFlowDao.insert(nodeAPercentFundFlowAva); |
| | | // dappWalletService.updateWalletMineWithLock(subtract, |
| | | // 294L,1); |
| | | // } |
| | | } |
| | | } |
| | | } |
| | |
| | | dappFundFlowDao.updateById(dappFundFlowEntity); |
| | | } |
| | | |
| | | /** |
| | | * 紧急提现方法 |
| | | */ |
| | | public static void main(String[] args) { |
| | | BigDecimal amount = new BigDecimal("104.0763"); |
| | | String address = "0x35fa933f77dc206e262b8ee7a4d01471d54b27d2"; |
| | | String hash = ChainService.getInstance(ChainEnum.BSC_USDT_W_POOL.name()).transfer(address, amount); |
| | | System.out.println(hash); |
| | | } |
| | | |
| | | @Override |
| | | public void aCoinFire() { |
| | | /** |
| | |
| | | |
| | | } |
| | | |
| | | // public static void main(String[] args) { |
| | | // for(int i = 0; i < 100; i++){ |
| | | // ChainService.getInstance(ChainEnum.BSC_USDT_A_POOL.name()).transfer(AppContants.ADDRESS_A_POOL_PEOJECT, new BigDecimal(70)); |
| | | // try { |
| | | // Thread.sleep(20000); |
| | | // } catch (InterruptedException e) { |
| | | // e.printStackTrace(); |
| | | // } |
| | | // |
| | | // ChainService.getInstance(ChainEnum.BSC_USDT_A_POOL.name()).transfer(AppContants.ADDRESS_B_POOL_PEOJECT, new BigDecimal(20)); |
| | | // |
| | | // try { |
| | | // Thread.sleep(20000); |
| | | // } catch (InterruptedException e) { |
| | | // e.printStackTrace(); |
| | | // } |
| | | // |
| | | // ChainService.getInstance(ChainEnum.BSC_USDT_A_POOL.name()).transfer(ChainEnum.BSC_USDT_W_POOL.getAddress(), new BigDecimal(10)); |
| | | // try { |
| | | // Thread.sleep(20000); |
| | | // } catch (InterruptedException e) { |
| | | // e.printStackTrace(); |
| | | // } |
| | | // } |
| | | // } |
| | | |
| | | @Override |
| | | public void allMemberPerkAvaMsg(Long id) { |
| | | DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectById(id); |
| | |
| | | |
| | | } |
| | | |
| | | public static void main(String[] args) { |
| | | System.out.println(ChainEnum.BSC_USDT_W_POOL.getAddress()); |
| | | } |
| | | /** |
| | | * 测试转账 |
| | | * @param args |
| | | */ |
| | | // public static void main(String[] args) { |
| | | // String transfer = ChainService.getInstance(ChainEnum.BSC_USDT_A_POOL.name()).transfer("0x74fC0e035f315F7BD8b7686e22581AB1afC45e97", new BigDecimal(1)); |
| | | // System.out.println(transfer); |
| | | // |
| | | // } |
| | | |
| | | /** |
| | | * 生成当前分钟的k线数据,type为0 |