package com.xcong.excoin.modules.blackchain.service;

import java.math.BigDecimal;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.apache.commons.codec.binary.Base64;
import org.apache.commons.lang3.StringUtils;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;


public class UsdtService {
//	public static void main(String[] args) throws IOException {
//		ECKey key = new ECKey();
//		//logger.info("We created a new key:\n" + key);
//		// TEST 网络
//		NetworkParameters params = MainNetParams.get();
//		Address addressFromKey = key.toAddress(params);
//		System.out.println("Public Address generated: " + addressFromKey);
//		//logger.info("Public Address generated: " + addressFromKey);
//		String privateKey = key.getPrivateKeyEncoded(params).toString();
//		System.out.println("Private key is: " + privateKey);
//		//logger.info("Private key is: " + privateKey);
//		//logger.info("Private Hex key is: " + key.getPrivateKeyAsHex());
//		Wallet wallet = new Wallet(TestNet3Params.get());
//		File walletFile = new File("D//:test.wallet");
//		wallet.importKey(key);
//		wallet.saveToFile(walletFile);
//	}

    private static UsdtService service = null;
    private final static String RESULT = "result";
    private final static String METHOD_SEND_TO_ADDRESS = "sendtoaddress";
    private final static String METHOD_GET_TRANSACTION = "gettransaction";
    private final static String METHOD_LIST_TRANSACTIONS = "listtransactions";
    private final static String METHOD_GET_BLOCK_COUNT = "getblockcount";
    private final static String METHOD_NEW_ADDRESS = "getnewaddress";
    private final static String METHOD_GET_BALANCE = "getbalance";
    private final static String METHOD_GET_BALANCE_ADDRESS = "getreceivedbyaddress";
    private final static String METHOD_WALLET_PASSPHRASE = "walletpassphrase";
    private final static String METHOD_WALLET_LOCK = "walletlock";

    private String url = "http://120.55.86.146:1880";
    private String username = "biyi";
    private String password = "biyi1234";

    public static UsdtService getInstance() {
        if (service != null) {
            return service;
        }
        return new UsdtService();
    }

    private UsdtService() {
    }

    /**
     * 创建BTC钱包 每个账户对应一个地址 方便后续操作
     *
     * @param mId 账户
     * @return
     */
    public static Map<String, String> createWallet(String mId) {
        UsdtService btcService = getInstance();
        // 创建钱包地址
        String address = btcService.getAddress(mId);
        // 私钥
        String privateKey = btcService.dumpprivkey(address);
        Map<String, String> result = new HashMap<String, String>();
        result.put("address", address);
        result.put("privateKey", privateKey);
        return result;
    }

    public String getAddress(String label) {
        try {
            JSONObject json = doRequest(METHOD_NEW_ADDRESS, label);
            if (isError(json)) {
                return "";
            }
            return json.getString(RESULT);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

    private JSONObject doRequest(String method, Object... params) {
        JSONObject param = new JSONObject();
        param.put("id", System.currentTimeMillis() + "");
        param.put("jsonrpc", "2.0");
        param.put("method", method);
        if (params != null) {
            param.put("params", params);
        }
        String creb = Base64.encodeBase64String((username + ":" + password).getBytes());
        Map<String, String> headers = new HashMap<>(2);
        headers.put("Authorization", "Basic " + creb);
        return JSON.parseObject(HttpUtil.jsonPost(url, headers, param.toJSONString()));
    }

    private boolean isError(JSONObject json) {
        if (json == null || (StringUtils.isNotEmpty(json.getString("error")) && json.get("error") != "null")) {
            return true;
        }
        return false;
    }

    public String dumpprivkey(String address) {
        try {
            JSONObject obj = doRequest("dumpprivkey", address);
            System.out.println(obj);
            if (!isError(obj)) {
                return obj.getString(RESULT);
            } else {
                return null;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

    /**
     * 查询给定地址的总收款额（只计算接受的）
     *
     * @param address
     * @return
     */
    public BigDecimal getBalance(String address) {
        try {
            JSONObject json = doRequest("omni_getbalance", address, 31);
            if (!isError(json)) {
                return new BigDecimal(json.getJSONObject(RESULT).get("balance").toString());
            } else {
                return null;
            }
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("BTC-USDT查询余额失败");
            return null;
        }

    }

    public String METHOD_GET_BLOCK_COUNT() {
        JSONObject json = doRequest(METHOD_GET_BLOCK_COUNT);
        if (!isError(json)) {
            return json.getString(RESULT);
        } else {
            return null;
        }
    }





    public static void main(String[] args) {

        System.out.println(UsdtService.getInstance().getBalance("1PLCr8A2z7YLEtoPLJdzzqpfb3Ym87UCtt"));
    }
}