| | |
| | | dappFundFlowDao.updateById(dappFundFlowEntity); |
| | | } |
| | | |
| | | // public static void main(String[] args) { |
| | | // String address = "0x7a9bfE048d110EF90a467803653f9B8666f9096C"; |
| | | // /** |
| | | // * 发起USDT转账 |
| | | // */ |
| | | // String hash = ChainService.getInstance(ChainEnum.BSC_USDT_W_POOL_CONTRACT.name()).transferUSDT(address, new BigDecimal("0.99")); |
| | | // System.out.println(hash); |
| | | // } |
| | | |
| | | @Override |
| | | public void AntACoinBPollInMsg(Long id) { |
| | | log.info("{}",id); |
| | |
| | | log.info("amount:{},address:{}",amount,address); |
| | | ThreadUtil.sleep(5000); |
| | | // String hash = ChainService.getInstance(ChainEnum.BSC_USDT_W_POOL_CONTRACT.name()).transferUSDT(address, amount); |
| | | String hash = ChainService.getInstance(ChainEnum.BSC_USDT_W_POOL.name()).transferUSDT(address, amount); |
| | | // String hash = ChainService.getInstance(ChainEnum.BSC_USDT_W_POOL.name()).transferUSDT(address, amount); |
| | | |
| | | String hash = ChainService.getInstance(ChainEnum.BSC_USDT_W_POOL.name()).transfer(address, amount); |
| | | if(StrUtil.isEmpty(hash)){ |
| | | // hash = ChainService.getInstance(ChainEnum.BSC_USDT_W_POOL.name()).transfer(address, amount); |
| | | return; |
| | | } |
| | | // if(StrUtil.isEmpty(hash)){ |
| | |
| | | */ |
| | | // public static void main(String[] args) { |
| | | // BigDecimal amount = new BigDecimal("0.01"); |
| | | // String address = "0xB3cF9669F398f444DfCAebbAd2A49bF32ba41fE3"; |
| | | // String address = "0xA60AaC0da34C76F3f60207ee09e9F75043319ab4"; |
| | | // |
| | | // String hash = ChainService.getInstance(ChainEnum.BSC_USDT_W_POOL_CONTRACT.name()).transferUSDT(address, amount); |
| | | // |
| | | // System.out.println(hash); |
| | | // |
| | | // |
| | | //// int i = ChainService.getInstance(ChainEnum.BSC_TFC.name()).allowanceCnt("0x80098f854950f9327C4F4E747d285Fd2d41fbf3e"); |
| | | // } |
| | | |
| | | @Override |
| | |
| | | chainProducer.sendAntACoinInBPoolMsg(fundFlowToB.getId()); |
| | | } |
| | | |
| | | public static void main(String[] args) { |
| | | |
| | | System.out.print(1); |
| | | System.out.print(2); |
| | | // ThreadUtil.execute(() -> { |
| | | // //90%进入A币底池 |
| | | // System.out.print(1); |
| | | // ThreadUtil.sleep(5000); |
| | | // //10%进入B币LP薄饼底池 |
| | | // System.out.print(2); |
| | | // }); |
| | | } |
| | | |
| | | @Override |
| | | public void contractAnDaoInMsg(Long flowId) { |
| | | /** |
| | |
| | | dappMemberDao.updateMemberActiveStatus(1,memberId); |
| | | |
| | | } |
| | | |
| | | /** |
| | | * 测试转账 |
| | | * @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 |