import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.Date;

import java.util.List;

import DNA.Network.Rest.RestException;

import DNA.sdk.info.account.AccountAsset;

import DNA.sdk.info.account.AccountInfo;

import DNA.sdk.info.asset.AssetInfo;

import DNA.sdk.info.mutil.TxJoiner;

import DNA.sdk.info.transaction.TransactionInfo;

import DNA.sdk.wallet.AccountManager;

/**

* DNA sdk 测试Demo

*

* @author 12146

*

*/

public class TestMain4CLI {

public static void main(String[] args) throws Exception {

boolean flag = true;

// 实例化账户管理类

AccountManager wm = getAccountManager();

// 启动同步

wm.startSyncBlock();

// 等待同步完成

while(!wm.hasFinishedSyncBlock()) {

Thread.sleep(1000*1);

}

// 创建多个账户

List<String> list = wm.createAccount(3);

String addr1 = list.get(0);

String addr2 = list.get(1);

String addr3 = list.get(2);

print("user1:"+addr1 + ","+wm.address2UInt160(addr1) + ",addr.len="+addr1.length()+",uint160.len="+wm.address2UInt160(addr1).length());

print("user2:"+addr2 + ","+wm.address2UInt160(addr2));

print("user3:"+addr3 + ","+wm.address2UInt160(addr3));

String txid = null,assetid = null;

if(flag) {

// 注册资产(资产控制者为addr1)

print("test regAsset..............................................[st]");

txid = wm.reg(addr1, "Token001", 10000, "用户1注册资产S01", addr1);

print("test regAsset..............................................[ed],txid="+txid);

assetid = txid;

// 分发资产(账户addr1分发资产给addr2)

print("test issAsset..............................................[st]");

txid = wm.iss(addr1, assetid, 100, addr2, "用户1 分发给 用户2");

print("test issAsset..............................................[ed],txid="+txid);

// 转移资产(账户addr2转移资产只addr3)

print("test trfAsset..............................................[st]");

txid = wm.trf(addr2, assetid, 11, addr3, "用户2转账给用户3");

print("test trfAsset..............................................[ed],txid="+txid);

// 存证

String content = "ts_"+new Date();

print("test storeCert..............................................[st]");

txid = wm.storeCert(content, "存证交易test");

print("test storeCert..............................................[ed],txid="+txid+",len="+txid.length());

Thread.sleep(1000*10);

// 取证

print("test queryCert..............................................[st]");

String newContent = wm.queryCert(txid);

print(String.format("\n\told=%s\n\tnew=%s", content, newContent));

print("test queryCert..............................................[ed],txid=end");

// 分发给多个接收者

List<TxJoiner> tlist = new ArrayList<TxJoiner>();

tlist.add(newTxJoiner(addr2, assetid, 45));

tlist.add(newTxJoiner(addr3, assetid, 55));

txid = wm.iss(tlist, addr1, "u1 转账给 u2 和 u3");

// 转账给多个接收者

tlist.clear();

tlist.add(newTxJoiner(addr1, assetid, 1));

tlist.add(newTxJoiner(addr2, assetid, 2));

txid = wm.trf(tlist, addr3, "u3 转账给 u1 和 u2");

// 查询所有账户地址

List<String> addrList = wm.listAccount();

System.out.println("Query All Account:-------------------------\n"+addrList);

// 查询账户信息

AccountInfo accountInfo = wm.getAccountInfo(addr1);

System.out.println("Query Account info:-------------------------\n"+accountInfo);

// 查询账户资产

AccountAsset accountAsset = wm.getAccountAsset(addr1);

System.out.println("Query Account asset:-------------------------\n"+accountAsset);

// 查询资产信息

AssetInfo assetInfo = wm.getAssetInfo(assetid);

System.out.println("Query Asset info:-------------------------\n"+assetInfo);

// 查询交易信息

TransactionInfo transactionInfo = wm.getTransactionInfo(txid);

System.out.println("Query Transaction info:-------------------------\n"+transactionInfo);

// 查询所有账户资产

wm.listAccount().forEach(p -> {

print("query acc.asset:"+wm.getAccountAsset(p));

});

// 账户管理器

System.out.println("#######################################################################################");

}

}

private static void print(String ss) {

System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS").format(new Date()) + " " + ss);

}

private static TxJoiner newTxJoiner(String address, String assetid, long value) {

TxJoiner tt = new TxJoiner();

tt.address = address;

tt.assetid = assetid;

tt.value = value;

return tt;

}

public void testCreateAccount() {

// 打开账户管理器

AccountManager wm = getAccountManager();

// 创建账户

String user01 = wm.createAccount(); // 创建单个账户

List<String> list = wm.createAccount(10); // 批量创建10个账户

System.out.println("user:"+user01);

System.out.println("list:"+list);

}

public void testRegAsset() throws Exception {

// 打开账户管理器

AccountManager wm = getAccountManager();

// 注册资产

String issuer= ""; // 资产发行者地址

String name = ""; // 资产名称

long amount = 10000; // 资产数量

String desc = ""; // 描述

String controller = ""; // 资产控制者地址

String assetid = wm.reg(issuer, name, amount , desc, controller);

System.out.println("rs:"+assetid);

}

public void testIssAsset() throws Exception {

// 打开账户管理器

AccountManager wm = getAccountManager();

// 分发资产

String controller= ""; // 资产控制者地址

String assetid = ""; // 资产编号(由注册资产产生)

long amount = 100; // 分发数量

String recver = ""; // 分发资产接收者地址

String desc = ""; // 描述

String txid = wm.iss(controller, assetid, amount , recver , desc );

System.out.println("rs:"+txid);

}

public void testTrfAsset() throws Exception {

// 打开账户管理器

AccountManager wm = getAccountManager();

// 转移资产

String controller= ""; // 资产控制者地址

String assetid = ""; // 资产编号(由注册资产产生)

long amount = 100; // 转移数量

String recver = ""; // 转移资产接收者地址

String desc = ""; // 描述

String txid = wm.trf(controller, assetid, amount , recver , desc );

System.out.println("rs:"+txid);

}

public static void testStoreCert() throws Exception {

// 打开账户管理器

AccountManager wm = getAccountManager();

// 存证

String content = "ts"; // 待存储的信息

String desc = "dd"; // 描述

String txid = wm.storeCert(content, desc);

System.out.println("rs:"+txid);

}

public void testQueryCert() throws Exception {

// 打开账户管理器

AccountManager wm = getAccountManager();

// 取证

String txid = ""; // 存证编号

String contetn= wm.queryCert(txid);

System.out.println("rs:"+contetn);

}

public static void testAccountInfo() {

// 打开账户管理器

AccountManager wm = getAccountManager();

// 查询账户信息

String userAddr = "AZg3vyDawyHtET8tNhs1odKPa6yy8qFgxK"; // 账户地址

AccountInfo info = wm.getAccountInfo(userAddr);

System.out.println("rs:"+info);

}

public static void testAccountAsset() {

// 打开账户管理器

AccountManager wm = getAccountManager();

// 查询账户资产

String userAddr = "AZsbZYCFh9Xat2HdBwniZKDFfau4WWy9Sg";

AccountAsset info = wm.getAccountAsset(userAddr);

System.out.println("rs:"+info);

}

public static void testAssetInfo() throws RestException {

// 打开账户管理器

AccountManager wm = getAccountManager();

// 查询账户资产

String assetid = "c35d2195b197f8f75a2fb0367d667d2f63a02ba9e1929ab6378ffe91218f0446";

AssetInfo info = wm.getAssetInfo(assetid);

System.out.println("rs:"+info);

}

public static void testTransactionInfo() throws Exception {

// 打开账户管理器

AccountManager wm = getAccountManager();

// 查询账户资产

String txid = "05eee614559bf42dbedb2b062a6d5ef6b813abcc130ed3f55b3d0cdfec8c86ad";

TransactionInfo info = wm.getTransactionInfo(txid);

System.out.println("rs:"+info);

}

public static void testListAccount() {

AccountManager wm = getAccountManager();

wm.listAccount().forEach(p -> System.out.println(p));

}

public static AccountManager getAccountManager() {

// 打开账户管理器

// v1.0

// String path = "./dat/tsGo_01.db3";

// String url = "http://localhost:20334";

// String accessToken = ""; // 从认证服务器获取该访问令牌

// UserWalletManager wm = UserWalletManager.getWallet(path, url, accessToken);

// v1.1

String dnaUrl = "http://127.0.0.1:20334";

String dnaToken = "";

String path = "./4.db3";

AccountManager wm = AccountManager.getWallet(path, dnaUrl, dnaToken);

print(String.format("[param=%s,%s]", dnaUrl, path));

print(String.format("start to test....hh:%s", wm.getBlockHeight()));

return wm;

}

}