钱包开发经验分享：omniUSDT篇

关于propertyId可以参考区块链浏览器，从区块链浏览器可以看到，USDT在omni协议中的propertyId是31。propertyId可以认为是omni协议实现的代币的主键，每个token的propertyId是不同的，而omniUSDT的propertyId是31。签名的结果是原始交易的Hex字符串，需要广播出去这笔交易才会被网络认可，广播交易可以用推送原始交易端点进行广播，有一些区块链浏览器也提供了广播交易的API，可以去翻找一下。

在做代币归集的时候，代币支付的矿工费一般都是公链的币种，例如erc20USDT的转账是使用ETH支付矿工费的，而omniUSDT则是使用BTC支付矿工费，omniUSDT矿工费的支付在归集的面前成了一个棘手的难题。一般在做归集的时候会发生两次转账，一次是打入矿工费的转账，一次是归集的转账，而在omniUSDT归集的时候，这两次转账所支付的矿工费有时候是多余的，因为omniUSDT基于BTC公链，BTC公链本身就拥堵，矿工费又高，这样频繁归集来回打手续费，支出了太多不必要的矿工费。一般会有两个解决方案，一个是omniUSDT和BTC账户直接不做归集，需要的时候在手动归集，另一个设置一个打手续费的门槛和归集的门槛，当账户余额不大于某个阈值不考虑归集。其实还有第三种做法，指定支付矿工费地址，参考USDT钱包归集。

参考代码:

    
    public static String createRawTransaction(String privBtcKey, String btcAddress, String privUsdtKey, String usdtAddress, String recevieUsdtAddr,  long amount, int propertyId, boolean isMainNet) {

 // 获取未花费列表
 List unBtcUtxos = getUnspentFromTestNet(btcAddress);
 List unUsdtUtxos = getUnspentFromTestNet(usdtAddress);

 // 优化列表
 Collections.sort(unBtcUtxos, (o1, o2) -> BigInteger.valueOf(o2.getValue().value).compareTo(BigInteger.valueOf(o1.getValue().value)));


 List btcUtxos = new ArrayList<>();
 List usdtUtxos = new ArrayList<>();

 // 获取手续费
 Long fee = getFee(546L, unBtcUtxos);

 // 过滤输入
 long btcTotalMoney = 0;
 long usdtTotalMoney = 0;
 for (UTXO us : unBtcUtxos) {
     if (btcTotalMoney >= (1092L + fee))
  break;
     UTXO utxo = new UTXO(us.getHash(), us.getIndex(), us.getValue(), us.getHeight(), us.isCoinbase(), us.getscript());
     btcUtxos.add(utxo);
     btcTotalMoney += us.getValue().value;
 }
 for (UTXO us : unUsdtUtxos) {
     if (usdtTotalMoney >= 546L)
  break;
     UTXO utxo = new UTXO(us.getHash(), us.getIndex(), us.getValue(), us.getHeight(), us.isCoinbase(), us.getscript());
     usdtUtxos.add(utxo);
     usdtTotalMoney += us.getValue().value;
 }

 // 判断是测试链还是正式链
 NetworkParameters networkParameters = isMainNet ? MainNetParams.get() : TestNet3Params.get();
 try {
     if (!btcUtxos.isEmpty() && !usdtUtxos.isEmpty()) {
  // find a btc eckey info
  DumpedPrivateKey btcPrivateKey = DumpedPrivateKey.frombase58(networkParameters, privBtcKey);
  ECKey btcKey = btcPrivateKey.getKey();
  // a usdt eckey info
  DumpedPrivateKey usdtPrivateKey = DumpedPrivateKey.frombase58(networkParameters, privUsdtKey);
  ECKey usdtKey = usdtPrivateKey.getKey();

  // receive address
  Address receiveAddress = Address.frombase58(networkParameters, recevieUsdtAddr);
  // create a transaction
  Transaction tx = new Transaction(networkParameters);
  // odd address
  Address oddAddress = Address.frombase58(networkParameters, btcAddress);
  // 如果需要找零 消费列表总金额 - 已经转账的金额 - 手续费
  long value_btc = btcUtxos.stream().mapToLong(x -> x.getValue().value).sum();
  long value_usdt = usdtUtxos.stream().mapToLong(x -> x.getValue().value).sum();
  // 总输入 - 手续费 - 546 -546 = 找零金额
  long leave = (value_btc + value_usdt) - fee - 1092;
  if (leave > 0) {
      tx.addOutput(Coin.valueOf(leave), oddAddress);
  }

  String usdtHex = "6a146f6d6e69" + String.format("%016x", propertyId) + String.format("%016x", amount);

  // usdt transaction
  tx.addOutput(Coin.valueOf(546), new script(Utils.HEX.decode(usdtHex)));
  // send to address
  tx.addOutput(Coin.valueOf(546), receiveAddress);

  // create usdt utxo data
  for (UTXO utxo : usdtUtxos) {
      TransactionOutPoint outPoint = new TransactionOutPoint(networkParameters, utxo.getIndex(), utxo.getHash());
      tx.addSignedInput(outPoint, utxo.getscript(), usdtKey, Transaction.SigHash.ALL, true);
  }

  for (UTXO utxo : btcUtxos) {
      TransactionOutPoint outPoint = new TransactionOutPoint(networkParameters, utxo.getIndex(), utxo.getHash());
      tx.addSignedInput(outPoint, utxo.getscript(), btcKey, Transaction.SigHash.ALL, true);
  }

  new Context(networkParameters);
  tx.getConfidence().setSource(TransactionConfidence.Source.NETWORK);
  tx.setPurpose(Transaction.Purpose.USER_PAYMENT);

  return Hex.toHexString(tx.bitcoinSerialize());
     }
 } catch (Exception e) {
     e.printStackTrace();
 }
 return null;
    }

	@Test
	public void sendUsdtSpecifyMineAddress(){
		String btcAddress = "mtESbeXpf5qYkbYnphhKEJ7FU3UyQKYQzy";
		String btcPrivateKey = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx";
		String usdtAddress = "mnvDACAJgny2yxxHNhud96sq9KRazbEeX2";
		String usdtPrivateKey = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx";
		String receiveAddress = "miiJAkDV4zfiZhSMwtiMCZr2rr4UecToMz";
		String signTx = BtcUtil.createRawTransaction(btcPrivateKey, btcAddress, usdtPrivateKey, usdtAddress, receiveAddress, 100000000, 1, false);
		String response = BtcUtil.sendTx(signTx, false);
		logger.warn("response: {}", response);
	}

    
    public static String getUsdtBalance(String address){
 String url = "https://api.omniexplorer.info/v1/address/addr/";
 OkHttpClient client = new OkHttpClient();
 String content = "addr=" + address;
 String response = null;
 try {
     response = client.newCall(new Request.Builder().url(url).post(RequestBody.create(MediaType.parse("application/x-www-form-urlencoded"), content)).build()).execute().body().string();
 } catch (IOException e) {
     e.printStackTrace();
 }
 JSonObject jsonObject = JSONObject.parseObject(response);
 JSonArray balances = jsonObject.getJSONArray("balance");
 List