1. 程式人生 > >區塊鏈教程交易所基礎開發通過接口查詢各個幣種的提幣情況-eth

區塊鏈教程交易所基礎開發通過接口查詢各個幣種的提幣情況-eth

acc int url err this hub -o chain origin

兄弟連區塊鏈教程交易所基礎開發通過接口查詢各個幣種的提幣情況-eth

package main

import (

"errors"

"fmt"

"math"

"strconv"

"strings"

"github.com/buger/jsonparser"

"github.com/levigross/grequests"

)

const min = 0.000000000001

func isEqual(f1, f2 float64) bool {

if f1 < f2 {

    return isEqual(f2, f1)

}

return math.Dim(f1, f2) < min

}

// HTTPGet asfdadsf.

func HTTPGet(url string, requestOptions *grequests.RequestOptions) (response []byte, err error) {

httpResponse, err := grequests.Get(url, requestOptions)

if err == nil {

    if httpResponse.StatusCode == 200 {

        response = httpResponse.Bytes()

    }

}

return

}

// EthBlocksChainCheck 根據提幣的數量,提幣方地址以及目標方地址來檢查提幣是否已經confirmed.

// 返回值有兩個:提幣狀態以及已收到的提幣數量(扣除手續費)

func EthBlocksChainCheck(withdrawAmount float64, originalAddress string, targetAddress string) (status string, netWithdrawAmount float64, confirmations int64, err error) {

url := fmt.Sprintf("https://api.etherscan.io/api?module=account&action=txlist&address=%s&startblock=0&endblock=99999999&page=1&offset=10&sort=asc&apikey=YourApiKeyToken", targetAddress)

bData, err := HTTPGet(url, nil)

if err != nil {

    return

}

transactions, _, _, err := jsonparser.Get(bData, "result")

_, err = jsonparser.ArrayEach(transactions, func(value []byte, dataType jsonparser.ValueType, offset int, e error) {

    _from, _, _, e := jsonparser.Get(value, "from")

    _to, _, _, e := jsonparser.Get(value, "to")

    _value, _, _, e := jsonparser.Get(value, "value")

    _txreceiptStatus, _, _, e := jsonparser.Get(value, "txreceipt_status")

    _gasPrice, _, _, e := jsonparser.Get(value, "gasPrice")

    _gasUsed, _, _, e := jsonparser.Get(value, "gasUsed")

    _confirmations, _, _, e := jsonparser.Get(value, "confirmations")

    sf := strings.ToLower(string(_from))

    st := strings.ToLower(string(_to))

    sv := strings.ToLower(string(_value))

    iv, _ := strconv.ParseFloat(sv, 64)

    sts := string(_txreceiptStatus)

    sgp := string(_gasPrice)

    igp, _ := strconv.ParseFloat(sgp, 64)

    sgu := string(_gasUsed)

    igu, _ := strconv.ParseFloat(sgu, 64)

    sc := string(_confirmations)

    if sf == strings.ToLower(originalAddress) && st == strings.ToLower(targetAddress) && isEqual(iv, withdrawAmount) {

        // fmt.Println(sf, st, sv, iv, sgp, igp, sgu, igu, sc)

        // 已完成的提幣數量,未扣除提幣的手續費

        fmt.Println("gas:", igp*igu)

        // 已收到幣的實際數量,扣除了提幣的手續費

        fmt.Println("net_receive_amount:", iv)

        if sts == "" || sts == "1" {

            status = "confirmed"

        } else {

            status = "online"

        }

        netWithdrawAmount = iv

        confirmations, _ = strconv.ParseInt(sc, 10, 64)

    } else {

        e = errors.New("this is a new error")

    }

})

return

}

func main() {

status, netReceiveAmount, confirmations, err := EthBlocksChainCheck(10000000000000000000, "0xe026434251afc388882d82969126ec4569aa74cf", "0x7725e0bc98e61c47dceb1906be968492e8cd9080")

if err != nil {

    fmt.Println("request failed...")

    return

}

fmt.Println(fmt.Sprintf("status: %s, net_withdraw_amount: %f, confirmations: %d", status, netReceiveAmount, confirmations))

}

效果如下:技術分享圖片

區塊鏈教程交易所基礎開發通過接口查詢各個幣種的提幣情況-eth