| | |
| | | @Resource
|
| | | private MemberWalletCoinDao memberWalletCoinDao;
|
| | |
|
| | | @Test
|
| | | public void pool() throws ExecutionException, InterruptedException {
|
| | | //List<MemberCoinChargeEntity> list = memberCoinChargeDao.selectAllBySymbolAndTag(CoinTypeEnum.USDT.name(), "ERC20", 1);
|
| | | List<MemberCoinChargeEntity> list = new ArrayList<MemberCoinChargeEntity>();
|
| | |
| | | usdtStr = usdtStr.substring(0, usdtStr.lastIndexOf("."));
|
| | | }
|
| | |
|
| | | String hash = ethService.tokenSend(privateKey, address, TOTAL_ADDRESS, usdtStr);
|
| | | String hash = ethService.tokenSend(privateKey, address, TOTAL_ADDRESS, usdtStr,null);
|
| | | System.out.println("归集:"+hash);
|
| | | if (StrUtil.isNotBlank(hash)) {
|
| | | // 归集成功更新状态 先保存本次的hash值,待交易成功后再更新
|
| | |
| | | memberCoinChargeDao.updateById(coinCharge);
|
| | | }
|
| | | } else {
|
| | | String hash = ethService.ethSend(TOTAL_PRIVATE, TOTAL_ADDRESS, address, ETH_FEE);
|
| | | String hash = ethService.ethSend(TOTAL_PRIVATE, TOTAL_ADDRESS, address, ETH_FEE,null);
|
| | | System.out.println("转手续费:"+hash);
|
| | | }
|
| | | }
|
| | |
| | | */
|
| | | @Test
|
| | | public void pushFee() {
|
| | | String toAddress = "";
|
| | | String toAddress = "0xbc6050a2898511bda406660267e6667448070552";
|
| | | EthService ethService = new EthService();
|
| | | try {
|
| | | String hash = ethService.ethSend(TOTAL_PRIVATE, TOTAL_ADDRESS, toAddress, ETH_FEE);
|
| | | String hash = ethService.ethSend(TOTAL_PRIVATE, TOTAL_ADDRESS, toAddress, "0.0032",null);
|
| | | System.out.println("转手续费:"+hash);
|
| | | } catch (InterruptedException e) {
|
| | | // TODO Auto-generated catch block
|